IhC&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)HeadersResponseRequest BaseClientpypy_version_infoi)maxsizecPdjd|jdDS)N-c3<K|]}|jywN) capitalize).0ps U/var/www/html/planif/env/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/r0r1r2r3itemssetattr isinstancerr4) selfr-r.r/r0r1r2r3r4kwargskvs r__init__zRequest.__init__ts+  %h/<79 ' 3&y1' 3&y1   $1a# $'7+gm,G r"c<|jj||yr)r/then)r;callbackerrbacks rrAz 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?rArGr*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'. ) requestcoder4buffer effective_urlerrorstatus_bodyr5Nc||_||_||n t|_||_|xs |j |_d|_|xs tj|jd|_ ||_ |jF|jdks|jdkDr't|j|j||_ yyy)NUnknowni+) r_r`rr4rar-rbrergetrdrcr )r;r_r`r4rarbrcrds 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)rcrFs 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. )reragetvaluerFs rrIz Response.bodys6 :: {{&![[113 zzr"c|jSr)r`rFs r status_codezResponse.status_code yyr"c|jSr)rIrFs rcontentzResponse.contentrpr")NNNNN) r$r%r&r'r\r]r?rkpropertyrIrorrr*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)rrilstriprstrip)keytliner4pkeyr values r header_parserrs w ??7 # #G   !W__ $$DHHgkk$&7&=2t{{}%MNGDMC+JC&*3i /C'# ;;=GCL sB4B6cXeZdZdZeZeZeZdZdZdZ dZ dZ dZ d dZ y ) rzBase class for HTTP clients. This class provides the basic structure and functionality for HTTP clients. Subclasses should implement specific HTTP client behavior. c 0||_t|_yr)hubr_header_parser)r;rr<s rr?zBaseClient.__init__s+or"c t|xsgD]<}t||js|j|fi|}|j|>yr)r r:r 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*rFs rclosezBaseClient.closes r"c |jjt||fy#t$rt |_YywxYwr)rsendr StopIterationr)r;r4r~s rr3zBaseClient.on_header s> 2    $ $l4&8'%B C 2"//D  2s&)AAc|Srr*rFs 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&r'rrrr?rrrr3rrr*r"rrrsb 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"