^fx%rdZddlmZddlZddlmZddlmZddlm Z m Z m Z ddl m Z ddlmZdd lmZdd lmZmZerdd lmZd Zeed ZeddZGddeZe jGddZGddZeefdZ GddZ!dS)z&Base async HTTP client implementation.) annotationsN) responses) TYPE_CHECKING)Thenable maybe_promisepromise) HttpError)coro) bytes_to_str) maybe_listmemoize) TracebackType)HeadersResponseRequestpypy_version_infoi)maxsizecfdd|dDS)N-c3>K|]}|VdSN) capitalize).0ps N/var/www/html/env/lib/python3.11/site-packages/kombu/asynchronous/http/base.py z#normalize_header..s*;;qALLNN;;;;;;)joinsplit)keys rnormalize_headerr!s- 88;;CIIcNN;;; ; ;;rceZdZdZdZdZdS)rz%Represents a mapping of HTTP headers.FN)__name__ __module__ __qualname____doc__complete _prev_keyrrrrs"// HIIIrrceZdZdZdxZxZxZxZxZxZ xZ xZ xZ xZ xZxZZdZdZdZdZdZdZesdZ d dZd d Zd ZdS) ra? A HTTP Request. Arguments: --------- url (str): The URL to request. method (str): The HTTP method to use (defaults to ``GET``). Keyword Arguments: ----------------- headers (Dict, ~kombu.asynchronous.http.Headers): Optional headers for this request body (str): Optional body for this request. connect_timeout (float): Connection timeout in float seconds Default is 30.0. timeout (float): Time in float seconds before the request times out Default is 30.0. follow_redirects (bool): Specify if the client should follow redirects Enabled by default. max_redirects (int): Maximum number of redirects (default 6). use_gzip (bool): Allow the server to use gzip compression. Enabled by default. validate_cert (bool): Set to true if the server certificate should be verified when performing ``https://`` requests. Enabled by default. auth_username (str): Username for HTTP authentication. auth_password (str): Password for HTTP authentication. auth_mode (str): Type of HTTP authentication (``basic`` or ``digest``). user_agent (str): Custom user agent for this request. network_interface (str): Network interface to use for this request. on_ready (Callable): Callback to be called when the response has been received. Must accept single ``response`` argument. on_stream (Callable): Optional callback to be called every time body content has been read from the socket. If specified then the response body and buffer attributes will not be available. on_timeout (callable): Optional callback to be called if the request times out. on_header (Callable): Optional callback to be called for every header line received from the server. The signature is ``(headers, line)`` and note that if you want ``response.headers`` to be populated then your callback needs to also call ``client.on_header(headers, line)``. on_prepare (Callable): Optional callback that is implementation specific (e.g. curl client will pass the ``curl`` instance to this callback). proxy_host (str): Optional proxy host. Note that a ``proxy_port`` must also be provided or a :exc:`ValueError` will be raised. proxy_username (str): Optional username to use when logging in to the proxy. proxy_password (str): Optional password to use when authenticating with the proxy server. ca_certs (str): Custom CA certificates file to use. client_key (str): Optional filename for client SSL key. client_cert (str): Optional filename for client SSL certificate. Ng>@T) urlmethodon_ready on_timeout on_stream on_prepare on_headerheaders __weakref____dict__GETc  ||_|p|j|_t|p t|_t||_t||_t||_t||_| r+| D]\} } t|| | t|tst|pi}||_ dSr)r,r-rrr.r/r0r1r2itemssetattr isinstancerr3) selfr,r-r.r/r0r1r2r3kwargskvs r__init__zRequest.__init__ts+  %h//<799 ' 33&y11' 33&y11  $  $ $1a####'7++ -gm,,G rc<|j||dSr)r.then)r;callbackerrbacks rrAz Request.thens  8W-----rc,d|S)Nz&)formatr;s r__repr__zRequest.__repr__s7>>tDDDr)r6NNNNNNr)r#r$r%r&body user_agentnetwork_interface auth_username auth_password auth_mode proxy_host proxy_portproxy_usernameproxy_passwordca_certs client_key client_certconnect_timeoutrequest_timeoutfollow_redirects max_redirectsuse_gzip validate_certPYPY __slots__r?rArGr)rrrr*s55t/33D3:3)33%3(1333"033A3 3 OOMHM 00 EI<@"....EEEEErrcneZdZdZesdZ d dZdZedZ edZ edZ dS) ra HTTP Response. Arguments --------- request (~kombu.asynchronous.http.Request): See :attr:`request`. code (int): See :attr:`code`. headers (~kombu.asynchronous.http.Headers): See :attr:`headers`. buffer (bytes): See :attr:`buffer` effective_url (str): See :attr:`effective_url`. status (str): See :attr:`status`. Attributes ---------- request (~kombu.asynchronous.http.Request): object used to get this response. code (int): HTTP response code (e.g. 200, 404, or 500). headers (~kombu.asynchronous.http.Headers): HTTP headers for this response. buffer (bytes): Socket read buffer. effective_url (str): The destination url for this request after following redirects. error (Exception): Error instance if the request resulted in a HTTP error code. status (str): Human equivalent of :attr:`code`, e.g. ``OK``, `Not found`, or 'Internal Server Error'. ) requestcoder3buffer effective_urlerrorstatus_bodyr4NcZ||_||_||n t|_||_|p|j|_d|_|ptj |jd|_ ||_ |j 8|jdks |jdkr$t|j|j ||_ dSdSdS)NUnknowni+) r^r_rr3r`r,rardrgetrcrbr )r;r^r_r3r`rarbrcs rr?zResponse.__init__s  ")"5ww799  *9gk C di C C  : 49s??di#oo"49dk4@@DJJJ  oorc"|jr|jdS)zRaise if the request resulted in an HTTP error code. Raises ------ :class:`~kombu.exceptions.HttpError` N)rbrFs rraise_for_errorzResponse.raise_for_errors  : *   rch|j%|j|j|_|jS)zThe full contents of the response body. Note: ---- Accessing this property will evaluate the buffer and subsequent accesses will be cached. )rdr`getvaluerFs rrHz Response.bodys1 : {&![1133 zrc|jSr)r_rFs r status_codezResponse.status_code yrc|jSr)rHrFs rcontentzResponse.contentror)NNNNN) r#r$r%r&r[r\r?rjpropertyrHrnrqr)rrrrs6 @@ <@8< A A A A  X XXrrc#K dV\}}|dr|sd|_(|drI|j}d||pd|g||<nB|dd\}}||x}|_|||<)NzHTTP/Tr :) startswithr'isspacer(rrhlstriprstrip)keytliner3pkeyr values r header_parserrs )%%w ??7 # # )  )#G   !W__   )$DHHgkk$&7&7&=2t{{}}%MNNGDMMC++JC&*d3ii /C'# ;;==GCL )rcFeZdZeZeZeZdZdZdZdZ dZ dZ ddZ dS) BaseClientc :||_t|_dSr)hubr_header_parser)r;rr<s rr?zBaseClient.__init__s+oorc t|pgD]:}t||js|j|fi|}||;dSr)r r:r add_request)r;r^r<reqs rperformzBaseClient.performslg&&," " "Cc4<00 2"dl311&11   S ! ! ! ! " "rc td)Nzmust implement add_request)NotImplementedError)r;r^s rrzBaseClient.add_requests!">???rcdSrr)rFs rclosezBaseClient.closes rc |jt||fdS#t$rt |_YdSwxYwr)rsendr StopIterationr)r;r3r}s rr2zBaseClient.on_headersa 2   $ $l4&8&8'%B C C C C C 2 2 2"///D     2s)-A Ac|Srr)rFs r __enter__zBaseClient.__enter__ s rexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NonereturnNonec.|dSr)r)r;rrrs r__exit__zBaseClient.__exit__ s rN)rrrrrrrr) r#r$r%rrrr?rrrr2rrr)rrrrsGGH...""" @@@   222 rr)"r& __future__rsys http.clientrtypingrvinerrrkombu.exceptionsr kombu.utils.compatr kombu.utils.encodingr kombu.utils.functionalr r typesr__all__hasattrr[r!dictrregisterrrrrr)rrrs ,,"""""" !!!!!! 1111111111&&&&&&######------66666666$###### ,ws'(( <<<     d    ^E^E^E^E^E^E^E^EBMMMMMMMM`'))))"$$$$$$$$$$r