o gR@sddlZddlZddlmZmZddlmZddlZddlmZddl m Z ddl m Z ddl mZmZddlmZzddlZWn eyKdZYnwd d gZGd d d ZGd d d eZdS) N)closingcontextmanager)urlparse)Response) FileAdapter)TransportError)get_media_type get_version)etree_to_stringAsyncTransport Transportc@sXeZdZdZdddZddZdd Zd d Zd d ZddZ e dddZ ddZ dS)r aThe transport object handles all communication to the SOAP server. :param cache: The cache object to be used to cache GET requests :param timeout: The timeout for loading wsdl and xsd documents. :param operation_timeout: The timeout for operations (POST/GET). By default this is None (no timeout). :param session: A :py:class:`request.Session()` object (optional) N,cCsZ||_||_||_tt|_| |_|pt |_ |j dt dt |j jd<dS)Nzfile://Zeep/%s (www.python-zeep.org) User-Agent)cache load_timeoutoperation_timeoutlogging getLogger__name__logger_close_sessionrequestsSessionsessionmountrr headers)selfrtimeoutrrrH/home/ubuntu/webapp/venv/lib/python3.10/site-packages/zeep/transports.py__init__"s zTransport.__init__cCs|jj||||jd}|S)zProxy to requests.get() :param address: The URL for the request :param params: The query parameters :param headers: a dictionary with the HTTP headers. )paramsrr)rgetrraddressr"rresponserrr r#/s z Transport.getcCs|jtjr|}t|tr|d}|jd|||jj ||||j d}|jtjrXt |j dd}|dkr>|j}n|j}t|trN||jpLd}|jd||j||S)zProxy to requests.posts() :param address: The URL for the request :param message: The content for the body :param headers: a dictionary with the HTTP headers. zutf-8HTTP Post to %s: %s)datarrz Content-Typeztext/xmlzmultipart/related&HTTP Response from %s (status: %d): %s)r isEnabledForrDEBUG isinstancebytesdecodedebugrpostrrrr#contentencoding status_code)rr%messager log_messager& media_typerrr r0<s0     zTransport.postcCst|}||||S)a.Post the envelope xml element to the given address with the headers. This method is intended to be overriden if you want to customize the serialization of the xml element. By default the body is formatted and encoded as utf-8. See ``zeep.wsdl.utils.etree_to_string``. )r r0)rr%enveloperr4rrr post_xmlcszTransport.post_xmlcCs|stdt|j}|dvr/|jr|j|}|rt|S||}|jr-|j|||Stt j |d }| WdS1sGwYdS)z#Load the content from the given URLzNo url given to load)httphttpsfilerbN) ValueErrorrschemerr#r-_load_remote_dataaddopenospath expanduserread)rurlr>r&r1fhrrr loadns   $zTransport.loadcCsZ|jd||jj||jd}t|||jWdS1s&wYdS)NzLoading remote data from: %s)r)rr/rr#rrraise_for_statusr1)rrFr&rrr r?s  $zTransport._load_remote_dataccs|j}||_dV||_dS)abContext manager to temporarily overrule options. Example:: transport = zeep.Transport() with transport.settings(timeout=10): client.service.fast_call() :param timeout: Set the timeout for POST/GET operations (not used for loading external WSDL or XSD documents) N)r)rr old_timeoutrrr settingss  zTransport.settingscCs|jr |jdSdSN)rrcloserrrr __del__szTransport.__del__)Nr NNrL) r __module__ __qualname____doc__r!r#r0r8rHr?rrKrOrrrr r s   '   c@sXeZdZdZ       dddZddZd d Zd d Zd dZddZ ddZ dS)r zAsynchronous Transport class using httpx. Note that loading the wsdl is still a sync process since and only the operations can be called via async. Nr TcCs|tdurtdd|_||_|ptj|||d|_|p"tj|||d|_t t |_ ddt i|j_ ddt i|j_ dS)Nz/The AsyncTransport is based on the httpx moduleF)verifyproxiesrrr)httpx RuntimeErrorrrClient wsdl_client AsyncClientclientrrrrr r)rrZrXrrr verify_sslproxyrrr r!s&     zAsyncTransport.__init__cs|jIdHdSrL)rZacloserNrrr r]szAsyncTransport.aclosecCs@|j|}|}z|W|Stjyt|jdw)N)r3)rXr#rErIrUHTTPStatusErrorrr3)rrFr&resultrrr r?s   z AsyncTransport._load_remote_datacsF|jd|||jj|||dIdH}|jd||j||S)Nr')r1rr))rr/rZr0r3rE)rr%r4rr&rrr r0s zAsyncTransport.postcs(t|}||||IdH}||SrL)r r0 new_response)rr%r7rr4r&rrr r8s zAsyncTransport.post_xmlcs$|jj|||dIdH}||S)N)r"r)rZr#r`r$rrr r#s zAsyncTransport.getcCs8|}t}||_|j|_|j|_|j|_|j|_|S)z@Convert an aiohttp.Response object to a requests.Response object)rEr_contentr3rcookiesr2)rr&bodynewrrr r`szAsyncTransport.new_response)NNNr NTN) rrPrQrRr!r]r?r0r8r#r`rrrr r s   "  )rrB contextlibrr urllib.parserrr requests_filerzeep.exceptionsr zeep.utilsrr zeep.wsdl.utilsr rU ImportError__all__r r rrrr s&