Qjx%DdZddlmZddlZddlmZddlmZddlm Z m Z m Z ddl m Z ddlmZdd lmZdd lmZmZerdd lmZd Zeed ZeddZGddeZe j:GddZGddZeefdZ GddZ!y)z&Base async HTTP client implementation.) annotationsN) responses) TYPE_CHECKING)Thenable maybe_promisepromise) HttpError)coro) bytes_to_str) maybe_listmemoize) TracebackType)HeadersResponseRequestpypy_version_infoi)maxsizecPdjd|jdDS)N-c3<K|]}|jywN) capitalize).0ps X/var/www/html/truck-me/venv/lib/python3.12/site-packages/kombu/asynchronous/http/base.py z#normalize_header..s;qALLN;s)joinsplit)keys rnormalize_headerr s 88;CIIcN; ;;ceZdZdZdZdZy)rz%Represents a mapping of HTTP headers.FN)__name__ __module__ __qualname____doc__complete _prev_keyr!rrrs/ HIr!rceZdZdZdxZxZxZxZxZxZ xZ xZ xZ xZ xZxZZdZdZdZdZdZdZesdZ d dZd dZd Zy) 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__c  ||_|xs |j|_t|xs t|_t||_t||_t||_t||_| r%| jD]\} } t|| | t|tst|xsi}||_ yr)r,r-rrr.r/r0r1r2itemssetattr isinstancerr3) selfr,r-r.r/r0r1r2r3kwargskvs r__init__zRequest.__init__ts+  %h/<79 ' 3&y1' 3&y1   $1a# $'7+gm,G r!c<|jj||yr)r.then)r:callbackerrbacks rr@z Request.thens 8W-r!c$dj|S)Nz&)formatr:s r__repr__zRequest.__repr__s7>>tDDr!)GETNNNNNNr)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>r@rFr)r!rrr*s5t/33D3:3)33%3(1333"033A3 3 OOMHM 0 EI<@".Er!rcZeZdZdZesdZ d dZdZedZ edZ edZ y) 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_bodyr4Nc||_||_||n t|_||_|xs |j |_d|_|xs tj|jd|_ ||_ |jF|jdks|jdkDr't|j|j||_ yyy)NUnknowni+) r^r_rr3r`r,rardrgetrcrbr )r:r^r_r3r`rarbrcs rr>zResponse.__init__s  ")"5w79  *9gkk C dii C  :: 499s?dii#o"499dkk4@DJ7F r!c4|jr |jy)zRaise if the request resulted in an HTTP error code. Raises ------ :class:`~kombu.exceptions.HttpError` N)rbrEs rraise_for_errorzResponse.raise_for_errors ::**  r!c|j+|j|jj|_|jS)zThe full contents of the response body. Note: ---- Accessing this property will evaluate the buffer and subsequent accesses will be cached. )rdr`getvaluerEs rrHz Response.bodys6 :: {{&![[113 zzr!c|jSr)r_rEs r status_codezResponse.status_code yyr!c|jSr)rHrEs rcontentzResponse.contentror!)NNNNN) r#r$r%r&r[r\r>rjpropertyrHrnrqr)r!rrrsd6 @ <@8< A  r!rc#pK d\}}|jdr|sd|_$|djrD|j}dj |j |xsd|j g||<n7|jdd\}}||x}|_|j||<w)NzHTTP/Tr :) startswithr'isspacer(rrhlstriprstrip)keytliner3pkeyrvalues r header_parserrs w ??7 # #G   !W__ $$DHHgkk$&7&=2t{{}%MNGDMC+JC&*3i /C'# ;;=GCL sB4B6cTeZdZeZeZeZdZdZdZdZ dZ dZ d dZ y) BaseClientc 0||_t|_yr)hubr_header_parser)r:rr;s rr>zBaseClient.__init__s+or!c t|xsgD]<}t||js|j|fi|}|j|>yr)r r9r add_request)r:r^r;reqs rperformzBaseClient.performsLg&," "Cc4<<0"dll31&1   S ! "r!ctd)Nzmust implement add_request)NotImplementedError)r:r^s rrzBaseClient.add_requests!">??r!cyrr)rEs rclosezBaseClient.closes r!c |jjt||fy#t$rt |_YywxYwr)rsendr StopIterationr)r:r3r}s rr2zBaseClient.on_headers> 2    $ $l4&8'%B C 2"//D  2s&)AAc|Srr)rEs r __enter__zBaseClient.__enter__ s r!c$|jyr)r)r:exc_typeexc_valexc_tbs r__exit__zBaseClient.__exit__ s r!N)rztype[BaseException] | NonerzBaseException | NonerzTracebackType | NonereturnNone) r#r$r%rrrr>rrrr2rrr)r!rrrs[GGH." @ 2 ,&%   r!r)"r& __future__rsys http.clientrtypingrvinerrrkombu.exceptionsr kombu.utils.compatr kombu.utils.encodingr kombu.utils.functionalr r typesr__all__hasattrr[r dictrregisterrrrrr)r!rrs," ! 11&#-6# ,s'( << d  ^E^E^EBMM`'))"$$r!