U .ex%@sdZddlmZddlZddlmZddlmZddlm Z m Z m Z ddl m Z ddlmZdd lmZdd lmZmZerdd lmZd Zeed ZeddddZGdddeZe jGdddZGdddZeefddZ GdddZ!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)maxsizecCsddd|dDS)N-css|]}|VqdSN) capitalize).0pr@/tmp/pip-unpacked-wheel-48hrr5dg/kombu/asynchronous/http/base.py sz#normalize_header..)joinsplit)keyrrrnormalize_headersrc@seZdZdZdZdZdS)rz%Represents a mapping of HTTP headers.FN)__name__ __module__ __qualname____doc__complete _prev_keyrrrrrsrc@seZdZdZdZZZZZZ Z Z Z Z ZZZdZdZdZdZdZdZes`dZddd Zdd d Zd d 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 Ks||_|p|j|_t|pt|_t||_t||_t||_t||_| rl| D]\} } t || | qVt |t st |p~i}||_ dSr)r&r'rrr(r)r*r+r,itemssetattr isinstancerr-) selfr&r'r(r)r*r+r,r-kwargskvrrr__init__ts       zRequest.__init__cCs|j||dSr)r(then)r4callbackZerrbackrrrr9sz Request.thencCs d|S)Nz&)formatr4rrr__repr__szRequest.__repr__)r0NNNNNN)N)rr r!r"body user_agentZnetwork_interfaceZ auth_usernameZ auth_passwordZ auth_modeZ proxy_hostZ proxy_portZproxy_usernameZproxy_passwordca_certsZ client_key client_certconnect_timeoutrequest_timeoutZfollow_redirects max_redirectsZuse_gzipZ validate_certPYPY __slots__r8r9r=rrrrr*sJ:  rc@sNeZdZdZesdZdddZddZedd Z ed d Z ed d Z 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'. ) requestcoder-buffer effective_urlerrorstatus_bodyr.NcCs||_||_|dk r|nt|_||_|p.|j|_d|_|pHt |jd|_ ||_ |j dkr|jdksp|jdkrt |j|j ||_ dS)NUnknowni+) rGrHrr-rIr&rJrMrgetrLrKr)r4rGrHr-rIrJrKrLrrrr8s zResponse.__init__cCs|jr |jdS)zRaise if the request resulted in an HTTP error code. Raises ------ :class:`~kombu.exceptions.HttpError` N)rKr<rrrraise_for_errorszResponse.raise_for_errorcCs&|jdkr |jdk r |j|_|jS)zThe full contents of the response body. Note: ---- Accessing this property will evaluate the buffer and subsequent accesses will be cached. N)rMrIgetvaluer<rrrr>s   z Response.bodycCs|jSr)rHr<rrr status_codeszResponse.status_codecCs|jSr)r>r<rrrcontentszResponse.content)NNNNN) rr r!r"rErFr8rQpropertyr>rSrTrrrrrs    rccsdV\}}|drqq|s&d|_qq|drZ|j}d||pHd|g||<q|dd\}}||}|_|||<qdS)NzHTTP/Tr :) startswithr#isspacer$rrPlstriprstrip)Zkeytliner-Zpkeyrvaluerrr header_parsers   "r`c@s\eZdZeZeZeZddZddZddZddZ d d Z d d Z d ddddddZ dS) BaseClientcKs||_t|_dSr)hubr`_header_parser)r4rbr5rrrr8szBaseClient.__init__cKs:t|p gD](}t||js*|j|f|}||q dSr)r r3r add_request)r4rGr5reqrrrperforms zBaseClient.performcCs tddS)Nzmust implement add_request)NotImplementedError)r4rGrrrrdszBaseClient.add_requestcCsdSrrr<rrrcloseszBaseClient.closecCs:z|jt||fWntk r4t|_YnXdSr)rcsendr StopIterationr`)r4r-r^rrrr,szBaseClient.on_headercCs|Srrr<rrr __enter__ szBaseClient.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | NoneNone)exc_typeexc_valexc_tbreturncCs |dSr)rh)r4rmrnrorrr__exit__ szBaseClient.__exit__N) rr r!rrrr8rfrdrhr,rkrqrrrrrasra)"r" __future__rsys http.clientrtypingrZvinerrrZkombu.exceptionsrZkombu.utils.compatr Zkombu.utils.encodingr Zkombu.utils.functionalr r typesr __all__hasattrrErdictrregisterrrr`rarrrrs,          aP