o ;i!@sddlZddlZddlZddlZddlmZmZddlmZddlm Z m Z ddl Z ddl m Z mZddlmZejrAddlmZdd ZGd d d eZGd d d ZGdddZdS)N)Counter defaultdict) Awaitable)AnyCallable) GRPCErrorStatus)logger)MockClientServicercsdtffdd }tjdd}|_d_dd}tD]-}t|}t|d d r7t|||||q|d rKt |rKt||||qt _ S) aAdds an `.intercept()` context manager method This allows for context-local tracking and assertions of all calls performed on the servicer during a context, e.g.: ```python notest with servicer.intercept() as ctx: await some_complex_method() assert ctx.calls == [("SomeMethod", MyMessage(foo="bar"))] ``` Also allows to set a predefined queue of responses, temporarily replacing a mock servicer's default responses for a method: ```python notest with servicer.intercept() as ctx: ctx.add_response("SomeMethod", [ MyResponse(bar="baz") ]) ctx.add_response("SomeMethod", [ MyResponse(bar="baz2") ]) await service_stub.SomeMethod(Empty()) # receives MyResponse(bar="baz") await service_stub.SomeMethod(Empty()) # receives MyResponse(bar="baz2") ``` Also patches all unimplemented abstract methods in a mock servicer with default error implementations. namecsdfdd }|S)Nreturncsttjdt)Nz" not implemented in mock servicer )rr UNIMPLEMENTEDrepr)selfstream)clsr M/home/ubuntu/.local/lib/python3.10/site-packages/modal/_utils/grpc_testing.py _fallback1sz8patch_mock_servicer..fallback.._fallback)r Nr)r rr)r rfallback0sz%patch_mock_servicer..fallbackcss(t|}||_|V|d|_dSN)InterceptionContextinterception_context_assert_responses_consumed)servicerctxrrr intercept6s  z&patch_mock_servicer..interceptNcsfdd}|S)Ncsz4|j}|r-t||IdH}||j}|r$|||IdHWS||IdHWS||IdHWSty=tyItdw)Nz!Error in mock servicer responder:) rInterceptedStream initialize_next_custom_responderrequest_messager Exceptionr exception) servicer_selfrrintercepted_streamcustom_responder method_nameoriginal_methodrrpatched_methodBs    zFpatch_mock_servicer..patch_grpc_method..patched_methodr)r(r)r*rr'rpatch_grpc_methodAsz.patch_mock_servicer..patch_grpc_method__isabstractmethod__Fr) str contextlibcontextmanagerrrdirgetattrsetattrisupperinspect isfunction frozenset__abstractmethods__)rrrr+r methodrrrpatch_mock_servicers    r9cs&eZdZdeeffdd ZZS)ResponseNotConsumedunconsumed_requestscs$||_t|}td|dS)Nz5Expected but did not receive the following requests: )r;rsuper__init__)rr; request_count __class__rrr=dszResponseNotConsumed.__init__)__name__ __module__ __qualname__listr-r= __classcell__rrr?rr:csr:c@seZdZddZddddedeegeffdd Zded ed e j j ge d ffd dZ ddZdedeefddZdefddZddZddZd S)rcCs ||_g|_tt|_i|_dSr) _servicercallsrrDcustom_responsescustom_defaults)rrrrrr=ks  zInterceptionContext.__init__cCsdS)NTr)reqrrrrszInterceptionContext.)request_filterr(rLcCs|j|||gfdS)aNAdds one response payload to an expected queue of responses for a method. These responses will be used once each instead of calling the MockServicer's implementation of the method. The interception context will throw an exception on exit if not all of the added responses have been consumed. N)rHappend)rr( first_payloadrLrrr add_responseqs z InterceptionContext.add_response responderr NcCs||j|<dS)aReplace the default responder from the MockClientServicer with a custom implementation ```python notest def custom_responder(servicer, stream): request = stream.recv_message() await stream.send_message(api_pb2.SomeMethodResponse(foo=123)) with servicer.intercept() as ctx: ctx.set_responder("SomeMethod", custom_responder) ``` Responses added via `.add_response()` take precedence over the use of this replacement N)rI)rr(rPrrr set_responder~sz!InterceptionContext.set_respondercCsLt|jD]\}\}}||kr|j|dd|_|Sqtd|j)Nz&No message of that type in call list: ) enumeraterGKeyError)rr(i _method_namemsgrrr pop_requests zInterceptionContext.pop_requestr cs.t|js tdfdd|jDS)Nz. not in MockServicer - did you spell it right?csg|] \}}|kr|qSrr).0rVrWr(rr sz4InterceptionContext.get_requests..)hasattrrF ValueErrorrG)rr(rrZr get_requestss z InterceptionContext.get_requestscCs|j||fdSr)rGrM)rr(rWrrr _add_recvszInterceptionContext._add_recvc s|j|}t|D]1\}\}}z||}Wn ty"tdw|r:||d|||dd|j|<n q |j|}|sEdS|Sfdd} | S)NzError when filtering requestsrRcs.|IdHD] }||IdHq dSr) recv_message send_message)r$rrWnext_response_messagesrrrPs z=InterceptionContext._next_custom_responder..responder)rHrSr"loggingr#rIget) rr(requestmethod_responsesrUrLresponse_messagesrequest_matchescustom_defaultrPrrbrr s&    "  z*InterceptionContext._next_custom_respondercCs:g}|jD] \}}||gt|7}q|rt|dSr)rHitemslenr:)r unconsumedr(queued_responsesrrrrs z.InterceptionContext._assert_responses_consumed)rArBrCr=r-rrboolrOgrpclibserverStreamrrQrXrDr^r_r rrrrrrjs$      rc@s>eZdZdedefddZddZddZd d Zd d Z d S)rrr(cCs||_||_||_d|_dSr)rr(rr!)rrr(rrrrr=s zInterceptedStream.__init__cs|IdH|_|Sr)r`r!)rrrrrszInterceptedStream.initializecs<|jr |j}d|_|S|jIdH}|j|j||Sr)r!rr`rr_r()rretrWrrrr`szInterceptedStream.recv_messagecs|j|IdHdSr)rra)rrWrrrraszInterceptedStream.send_messagecCs t|j|Sr)r1r)rattrrrr __getattr__s zInterceptedStream.__getattr__N) rArBrCrr-r=rr`rarurrrrrs  r)r.r4rdtyping collectionsrrcollections.abcrrrgrpclib.serverrprr modal.configr TYPE_CHECKING test.conftestr r9r"r:rrrrrrs    P^