$gddlmZddlmZmZmZmZmZmZddl m Z m Z ddl m Z ddlmZmZmZmZmZddlmZddlmZdd lmZmZdd lmZmZd d lmZd dgZ ddededededeee efdee deedeedeeeeffdZ! ddededededeee efdee deedeeeeffdZ"dedeefdZ#dS)) isawaitable)Any AsyncIterable AsyncIteratorDictOptionalUnion) GraphQLError located_error)collect_fields) assert_valid_execution_argumentsexecute get_field_defExecutionContextExecutionResult)get_argument_values) DocumentNode)Pathinspect)GraphQLFieldResolver GraphQLSchema)MapAsyncIterator subscribecreate_source_event_streamNschemadocument root_value context_valuevariable_valuesoperation_namefield_resolversubscribe_field_resolverreturnc Kt||d{V}t|tr|Sdtdtffd } t || S)ahCreate a GraphQL subscription. Implements the "Subscribe" algorithm described in the GraphQL spec. Returns a coroutine object which yields either an AsyncIterator (if successful) or an ExecutionResult (client error). The coroutine will raise an exception if a server error occurs. If the client-provided arguments to this function do not result in a compliant subscription, a GraphQL Response (ExecutionResult) with descriptive errors and no data will be returned. If the source stream could not be created due to faulty subscription resolver logic or underlying systems, the coroutine object will yield a single ExecutionResult containing ``errors`` and no ``data``. If the operation succeeded, the coroutine will yield an AsyncIterator, which yields a stream of ExecutionResults representing the response stream. Npayloadr%c dKt|}t|r|d{Vn|S)aMap source to response. For each payload yielded from a subscription, map it over the normal GraphQL :func:`~graphql.execute` function, with ``payload`` as the ``root_value``. This implements the "MapSourceToResponseEvent" algorithm described in the GraphQL specification. The :func:`~graphql.execute` function provides the "ExecuteSubscriptionEvent" algorithm, as it is nearly identical to the "ExecuteQuery" algorithm, for which :func:`~graphql.execute` is also used. N)rr)r'resultr rr#r"rr!s [/var/www/html/netbox-4.1.3/venv/lib/python3.11/site-packages/graphql/execution/subscribe.pymap_source_to_responsez)subscribe..map_source_to_responseFsR          +622>V|||||||>)r isinstancerrr) rrrr r!r"r#r$result_or_streamr+s `` ```` r*rrs:8 "O44 ?c?o???????????, ,.D E EEr,c Kt|||tj|||||||}t|trt d|S t |d{V}t|ts tdt|d|S#t$r} t d| gcYd} ~ Sd} ~ wwxYw)a,Create source event stream Implements the "CreateSourceEventStream" algorithm described in the GraphQL specification, resolving the subscription source event stream. Returns a coroutine that yields an AsyncIterable. If the client-provided arguments to this function do not result in a compliant subscription, a GraphQL Response (ExecutionResult) with descriptive errors and no data will be returned. If the source stream could not be created due to faulty subscription resolver logic or underlying systems, the coroutine object will yield a single ExecutionResult containing ``errors`` and no ``data``. A source event stream represents a sequence of events, each of which triggers a GraphQL execution for that event. This may be useful when hosting the stateful subscription service in a different process or machine than the stateless GraphQL execution engine, or otherwise separating these two steps. For more on this, see the "Supporting Subscriptions at Scale" information in the GraphQL spec. )r$N)dataerrorsz8Subscription field must return AsyncIterable. Received: .) rrbuildr-listrexecute_subscriptionr TypeErrorrr ) rrrr r!r"r$context event_streamerrors r*rr_s$D%VXGGG$!9G'4  :D9999 :1':::::::: , 66 7%l33777  :::D%999999999:sA B"" C,C=CCr7c$K|j}|j}|td|jt ||j|j||jj}tt| \}}t|||d}|s&|dj j }td|d|td||j }|||||} t!||d|j} |jp|j} | |j| fi| } || r| d{V} t+| t,r| | S#t,$r(} t/| ||d} ~ wwxYw)Nz;Schema is not configured to execute subscription operation.rzThe subscription field 'z' is not defined.)rsubscription_typer operationr fragmentsr! selection_setnextiteritemsrnamevaluerbuild_resolve_inforrr$r is_awaitabler- Exceptionr as_list)r7r root_type root_fields response_name field_nodes field_def field_namepathinfoargs resolve_fnr8r9s r*r5r5s ^F(I I     !' K"&d;+<+<+>+>&?&?!@!@M;fiQ@@I   ^(.  Dz D D Dk    mY^ 4 4D  % %ii N ND @#9k!ng>UVV(LG,L !z'"4dCCdCC    - - .!-------L lI . .   @@@E; ???@s.A.E F'#F  F)NNNNNN)NNNNN)$rrtypingrrrrrr r9r r execution.collect_fieldsr execution.executerrrrrexecution.valuesrlanguagerpyutilsrtyperrmap_async_iteratorr__all__strrrr5r,r*r]s0///////555555322222##############66666666000000 4 5 04$(59?C?F?F ?F?F?F ?F d38n- ?F SM ?F12?F'';<?F = )? :;?F?F?F?FJ04$(?CA:A: A:A:A: A: d38n- A: SM A:'';<A: =  ./A:A:A:A:H1@(81@]3=O1@1@1@1@1@1@r,