o tBh(@sddlZddlZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z ddlZddlmZmZmZddlmZddlmZmZddlmZmZmZmZeeZGd d d Z Gd d d ee Z!Gd ddee Z"dS)N) AnyAsyncGeneratorCallableDictListOptionalTupleTypeUnioncast) DocumentNodeExecutionResult print_ast) extract_files)AsyncTransport Transport)TransportAlreadyConnectedTransportClosedTransportProtocolErrorTransportServerErrorc@seZdZUejfZeeedfe d<dZ e e j e d<ejfdeee jfdefddZ    dd ed e eeefd e ed e eeefdedeeeff ddZdeeeffddZde jdefddZde jdefddZdS)_HTTPXTransport. file_classesNresponse_headersurljson_serializecKs||_||_||_dS)aCInitialize the transport with the given httpx parameters. :param url: The GraphQL server URL. Example: 'https://server.com:PORT/path'. :param json_serialize: Json serializer callable. By default json.dumps() function. :param kwargs: Extra args passed to the `httpx` client. N)rrkwargs)selfrrrrj/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/gql/transport/httpx.py__init__%s  z_HTTPXTransport.__init__Fdocumentvariable_valuesoperation_name extra_args upload_filesreturnc Cs~t|}d|i}|r||d<|r|dusJ|||}n |r#||d<d|i}ttjr6td|||r=|||S)Nquery operationName variablesjsonz>>> %s) r_prepare_file_uploadslog isEnabledForloggingDEBUGdebugrupdate) rr"r#r$r%r& query_strpayload post_argsrrr _prepare_request6s    z _HTTPXTransport._prepare_requestcCst||jd\}}||d<i}i}i}t|D]0\}\} } t|} | g|| <ttt| d| } t| dd} | durB| | f|| <q| | | f|| <q||}t d|||d<||}t d|||d<||d S) N)r*rr*name content_typez operations %s operationsz file_map %smap)datafiles) rr enumerateitemsstrr getattrrr-r1)rr#r4nulled_variable_valuesr<r;file_map file_streamsipathfkeyr7r8operations_str file_map_strrrr r,\s.        z%_HTTPXTransport._prepare_file_uploadsresponsecCs|j|_ttjrtd|jz|}Wnt y&| |dYnwd|vr5d|vr5| |dt | d| d| ddS)Nz<<< %szNot a JSON answererrorsr;z$No "data" or "errors" keys in answer extensions)rKr;rL) headersrr-r.r/r0r1textr+ Exception_raise_response_errorr get)rrJresultrrr _prepare_results    z_HTTPXTransport._prepare_resultreasonc CsRz|Wntjy}z tt||jj|d}~wwtd|d|j)Nz(Server did not return a GraphQL result: z: ) raise_for_statushttpxHTTPStatusErrorrr?rJ status_coderrN)rrJrTerrr rPs z%_HTTPXTransport._raise_response_errorNNNF)__name__ __module__ __qualname__ioIOBaserrr r__annotations__rrrVHeadersr+dumpsr r?URLrr!r rboolr6r,Responser rSrPrrrr r s:     &0rc @s|eZdZUdZdZeejed<ddZ    dde dee e e fd ee d ee e e fd ed ef d dZddZdS)HTTPXTransportz:ref:`Sync Transport ` used to execute GraphQL queries on remote servers. The transport uses the httpx library to send HTTP POST requests. NclientcCs0|jrtdtdtjdi|j|_dSNzTransport is already connectedzConnecting transportr)rgrr-r1rVClientrrrrr connects zHTTPXTransport.connectFr"r#r$r%r&r'cCs@|jstd||||||}|jj|jfi|}||S)aZExecute GraphQL query. Execute the provided document AST against the configured remote server. This uses the httpx library to perform a HTTP POST request to the remote server. :param document: GraphQL query as AST Node object. :param variable_values: Dictionary of input parameters (Default: None). :param operation_name: Name of the operation that shall be executed. Only required in multi-operation documents (Default: None). :param extra_args: additional arguments to send to the httpx post method :param upload_files: Set to True if you want to put files in the variable values :return: The result of execution. `data` is the result of executing the query, `errors` is null if no errors occurred, and is a non-empty array if an error occurred. Transport is not connectedrgrr6postrrSrr"r#r$r%r&r5rJrrr executes zHTTPXTransport.executecCs|jr |jd|_dSdSz2Closing the transport by closing the inner sessionN)rgcloserjrrr rrs  zHTTPXTransport.closerZ)r[r\r]__doc__rgrrVrir`rkr rr?rrdr rprrrrrr rfs,   &rfc @seZdZUdZdZeejed<ddZ    dde dee e e fd ee d ee e e fd ed ef d dZddZ  dde dee e e fd ee d eedffddZdS)HTTPXAsyncTransportz:ref:`Async Transport ` used to execute GraphQL queries on remote servers. The transport uses the httpx library with anyio. Nrgcs2|jrtdtdtjdi|j|_dSrh)rgrr-r1rV AsyncClientrrjrrr rks  zHTTPXAsyncTransport.connectFr"r#r$r%r&r'csH|jstd||||||}|jj|jfi|IdH}||S)aqExecute GraphQL query. Execute the provided document AST against the configured remote server. This uses the httpx library to perform a HTTP POST request asynchronously to the remote server. :param document: GraphQL query as AST Node object. :param variable_values: Dictionary of input parameters (Default: None). :param operation_name: Name of the operation that shall be executed. Only required in multi-operation documents (Default: None). :param extra_args: additional arguments to send to the httpx post method :param upload_files: Set to True if you want to put files in the variable values :return: The result of execution. `data` is the result of executing the query, `errors` is null if no errors occurred, and is a non-empty array if an error occurred. rlNrmrorrr rps zHTTPXAsyncTransport.executecs&|jr|jIdHd|_dSdSrq)rgacloserjrrr rr's  zHTTPXAsyncTransport.closecCstd)zDSubscribe is not supported on HTTP. :meta private: z1The HTTP transport does not support subscriptions)NotImplementedError)rr"r#r$rrr subscribe-s zHTTPXAsyncTransport.subscriberZ)NN)r[r\r]rsrgrrVrur`rkr rr?rrdr rprrrrxrrrr rtsB   '  rt)#r^r+r/typingrrrrrrrr r r rVgraphqlr r rutilsrrr exceptionsrrrr getLoggerr[r-rrfrtrrrr s0   >