File: //usr/local/lib/python3.9/site-packages/kombu/asynchronous/http/__pycache__/base.cpython-39.pyc
a
X>hC& � @ s� d Z ddlmZ ddlZddlmZ ddlmZ ddlm Z m
Z
m Z ddl m
Z
ddlmZ dd lmZ dd
lmZmZ er�dd lmZ d Zeed
�Zedd�dd� �ZG dd� de�Z e j G dd� d��Z G dd� d�Z eefdd��Z G dd� d�Z!dS ) z&Base async HTTP client implementation.� )� annotationsN)� responses)�
TYPE_CHECKING)�Thenable�
maybe_promise�promise)� HttpError)�coro)� bytes_to_str)�
maybe_list�memoize)�
TracebackType)�Headers�Response�Request�
BaseClient�pypy_version_infoi� )�maxsizec C s d� dd� | �d�D ��S )N�-c s s | ]}|� � V qd S �N)�
capitalize)�.0�p� r �F/usr/local/lib/python3.9/site-packages/kombu/asynchronous/http/base.py� <genexpr> � z#normalize_header.<locals>.<genexpr>)�join�split)�keyr r r �normalize_header s r c @ s e Zd ZdZdZdZdS )r z%Represents a mapping of HTTP headers.FN)�__name__�
__module__� __qualname__�__doc__�complete� _prev_keyr r r r r s r c @ s� e Zd ZdZd Z Z Z Z Z Z Z
Z Z Z
Z ZZdZdZdZdZdZdZes`dZddd �Zdd
d �Zd d
� ZdS )r a? 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� )
�url�method�on_ready�
on_timeout� on_stream�
on_prepare� on_header�headers� __weakref__�__dict__�GETc K s� || _ |p| j| _t|�p t� | _t|�| _t|�| _t|�| _t|�| _| rl| � � D ]\}
} t
| |
| � qVt |t �s�t |p~i �}|| _
d S r )r( r) r r r* r+ r, r- r. �items�setattr�
isinstancer r/ ) �selfr( r) r* r+ r, r- r. r/ �kwargs�k�vr r r �__init__t s
zRequest.__init__c C s | j �||� d S r )r* �then)r6 �callbackZerrbackr r r r; � s z Request.thenc C s
d� | �S )Nz&<Request: {0.method} {0.url} {0.body}>)�format�r6 r r r �__repr__� s zRequest.__repr__)r2 NNNNNN)N) r! r" r# r$ �body�
user_agentZnetwork_interfaceZ
auth_usernameZ
auth_passwordZ auth_mode�
proxy_host�
proxy_port�proxy_username�proxy_password�ca_certsZ
client_key� client_cert�connect_timeout�request_timeoutZfollow_redirects�
max_redirectsZuse_gzipZ
validate_cert�PYPY� __slots__r: r; r? r r r r r * sD :��������� �
r c @ sN e Zd ZdZesdZddd�Zdd� Zedd � �Z ed
d � �Z
ed d
� �Z dS )r a 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'.
) �request�coder/ �buffer�
effective_url�error�status�_bodyr0 Nc C s� || _ || _|d ur|nt� | _|| _|p.|j| _d | _|pHt� | jd�| _
|| _ | j d u r�| jdk sp| jdkr�t | j| j
| �| _ d S )N�Unknown�� i+ )
rM rN r r/ rO r( rP rS r �getrR rQ r )r6 rM rN r/ rO rP rQ rR r r r r: � s zResponse.__init__c C s | j r | j �dS )z�Raise if the request resulted in an HTTP error code.
Raises
------
:class:`~kombu.exceptions.HttpError`
N)rQ r> r r r �raise_for_error� s zResponse.raise_for_errorc C s& | j du r | jdur | j�� | _ | j S )z�The full contents of the response body.
Note:
----
Accessing this property will evaluate the buffer
and subsequent accesses will be cached.
N)rS rO �getvaluer> r r r r@ � s
z
Response.bodyc C s | j S r )rN r> r r r � status_code� s zResponse.status_codec C s | j S r )r@ r> r r r �content� s zResponse.content)NNNNN) r! r" r# r$ rK rL r: rW �propertyr@ rY rZ r r r r r � s �
r c c s� d V \}}|� d�rq q |s&d|_q q |d �� rZ|j}d�|�|�pHd|�� g�||< q |�dd�\}}| |� }|_|�� ||< q d S )NzHTTP/Tr � � �:� ) �
startswithr% �isspacer& r rV �lstripr �strip)Zkeyt�liner/ �pkeyr �valuer r r �
header_parser� s
"rg c @ s` e Zd ZdZeZeZeZdd� Zdd� Zdd� Z dd � Z
d
d � Z d d
� Z ddddd�dd�Z
dS )r z�Base class for HTTP clients.
This class provides the basic structure and functionality for HTTP clients.
Subclasses should implement specific HTTP client behavior.
c K s || _ t� | _d S r )�hubrg �_header_parser)r6 rh r7 r r r r: � s zBaseClient.__init__c K s> t |�p
g D ],}t|| j�s.| j|fi |��}| �|� q d S r )r r5 r � add_request)r6 rM r7 �reqr r r �perform� s zBaseClient.performc C s t d��d S )Nzmust implement add_request)�NotImplementedError)r6 rM r r r rj s zBaseClient.add_requestc C s d S r r r> r r r �close s zBaseClient.closec C s8 z| j �t|�|f� W n ty2 t� | _ Y n0 d S r )ri �sendr
�
StopIterationrg )r6 r/ rd r r r r. s zBaseClient.on_headerc C s | S r r r> r r r � __enter__ s zBaseClient.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None�None)�exc_type�exc_val�exc_tb�returnc C s | � � d S r )rn )r6 rs rt ru r r r �__exit__ s zBaseClient.__exit__N)r! r" r# r$ r r r r: rl rj rn r. rq rw r r r r r � s r )"r$ �
__future__r �sys� http.clientr �typingr Zviner r r Zkombu.exceptionsr Zkombu.utils.compatr Zkombu.utils.encodingr
Zkombu.utils.functionalr r �typesr
�__all__�hasattrrK r �dictr �registerr r rg r r r r r �<module> s,
aP