| Server IP : 192.158.238.246 / Your IP : 3.141.38.5 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/ |
Upload File : |
B
�k�a~� � @ s� U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z m
Z
ddlmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z ddl Z ddl m!Z!m"Z"m#Z#m$Z$ ddl%m&Z& dd l'm(Z(m)Z)m*Z* dd
l+m,Z, dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ dd lAmBZBmCZCmDZDmEZEmFZF dd
lGmHZH ddlImJZJmKZKmLZLmMZM ddlNmOZO ddlPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZY ddl)mZZZm[Z[m\Z\m]Z] ddl^m_Z_m`Z`maZambZb ddlcmdZd ddlemfZfmgZg ddlhmiZimjZjmkZkmlZlmmZm dZnyddlompZp W n eqk
�rX erZpY nX e jsdddd�G dd� d��Ztetd d �Zueiet evd < e d �ZwG d d!� d!�ZxG d"d#� d#eeeewf eew �ZyG d$d%� d%eyeC �ZzG d&d'� d'eyeH �Z{G d(d)� d)�Z|dddddddd*ddd+ddddeXde)j}dddd,�e~emeee~e~f eeeel eee~ eeS ee�ee~ ee eee eeem eeS e eterf eek e[eeJ ee� eej� e|d-�d.d/�Z�dS )0zHTTP Client for asyncio.� N)�suppress)�SimpleNamespace�
TracebackType)�Any� Awaitable�Callable� Coroutine� FrozenSet� Generator�Generic�Iterable�List�Mapping�Optional�Set�Tuple�Type�TypeVar�Union)� CIMultiDict� MultiDict�MultiDictProxy�istr)�URL� )�hdrs�http�payload)�AbstractCookieJar)�ClientConnectionError� ClientConnectorCertificateError�ClientConnectorError�ClientConnectorSSLError� ClientError�ClientHttpProxyError�
ClientOSError�ClientPayloadError�ClientProxyConnectionError�ClientResponseError�ClientSSLError�ContentTypeError�
InvalidURL�ServerConnectionError�ServerDisconnectedError�ServerFingerprintMismatch�ServerTimeoutError�TooManyRedirects�WSServerHandshakeError)�
ClientRequest�ClientResponse� Fingerprint� RequestInfo�_merge_ssl_params)�ClientWebSocketResponse)�
BaseConnector�NamedPipeConnector� TCPConnector�
UnixConnector)� CookieJar) �DEBUG�PY_36� BasicAuth�
TimeoutHandle� ceil_timeout�get_env_proxy_for_url�get_running_loop�sentinel�strip_auth_from_url)�WS_KEY� HttpVersion�WebSocketReader�WebSocketWriter)�WSHandshakeError� WSMessage�
ws_ext_gen� ws_ext_parse)�FlowControlDataQueue)�Trace� TraceConfig)�Final� JSONEncoder� LooseCookies� LooseHeaders�StrOrURL) r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r8 r: r; r9 r7 �
ClientSession�
ClientTimeout�request)�
SSLContextT)Z auto_attribs�frozen�slotsc @ sN e Zd ZU dZee ed< dZee ed< dZee ed< dZ ee ed< dS )rW N�total�connect� sock_read� sock_connect)
�__name__�
__module__� __qualname__r\ r �float�__annotations__r] r^ r_ � re re �A/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/client.pyrW � s
rW i, )r\ �DEFAULT_TIMEOUT�_RetTypec sX e Zd ZdZedddddddd d
d d d
ddddddddddg�ZdZd�ddddddeje e
e e j
dddededddddd �ee ee eej ee ee eee ee eee ee
ee eee e e e e e f ee e e e!f e e e ee"e# e$dd �d d �Z%ed dd �d!d"�Z&e'�r4ee(dd#�� fd$d%� Z)e*fe(dd&�d'd(�Z+eee(d)d*�d+d,�Z,ee-d-�d.d/�Z.ddddddddd0dddddddedddddddd1�eeee/eef e(e(ee ee eee ee e e$ee ee e ee e ee ee e e!e f ee ee0 ee1 ee e1e e2f ee ee3 ee$ e
d2�d3d4�Z4e5j6d5d6dddddddddddddddd7d8d9�eeee e ee e e ee ee ee ee/eef ee ee ee e e1e de2f ee ee0 ee1 ee e$e$d:d;�d<d=�Z7e5j6d5d6dddddddddddddddd7d8d9�eeee e ee e e ee ee ee ee/eef ee ee ee e e1e de2f ee ee0 ee1 ee e$e$e d;�d>d?�Z8ee d@dA�dBdC�Z9ddD�ee e(d)dE�dFdG�Z:ddD�ee e(d)dE�dHdI�Z;ddD�ee e(d)dE�dJdK�Z<ddL�ee(e(d)dM�dNdO�Z=ddL�ee(e(d)dM�dPdQ�Z>ddL�ee(e(d)dM�dRdS�Z?ee(d)dT�dUdV�Z@ddW�dXdY�ZAeBe dW�dZd[��ZCeBee dW�d\d]��ZDeBe dW�d^d_��ZEeBeFe$e$f dW�d`da��ZGeBe dW�dbdc��ZHeHjIe ddd�dedc��ZHeBejdW�dfdg��ZJeBe e e!f dW�dhdi��ZKeBd@dW�djdk��ZLeBeMeN dW�dldm��ZOeBee dW�dndo��ZPeBedW�dpdq��ZQeBe dW�drds��ZReBe e eSe
geTd f f dW�dtdu��ZUeBe dW�dvdw��ZVeBe dW�dxdy��ZWeBe"e# dW�dzd{��ZXddW�d|d}�ZYddW�d~d�ZZeee[ ee[ ee\ dd��d�d��Z]d dW�d�d��Z^eee[ ee[ ee\ dd��d�d��Z_� Z`S )�rV z/First-class interface for making HTTP requests.� _base_url�_source_traceback�
_connector�requote_redirect_url�_loop� _cookie_jar�_connector_owner�
_default_auth�_version�_json_serialize�_requote_redirect_url�_timeout�_raise_for_status�_auto_decompress�
_trust_env�_default_headers�_skip_auto_headers�_request_class�_response_class�_ws_response_class�_trace_configs�
_read_bufsizeNTFi )� connector�loop�cookies�headers�skip_auto_headers�auth�json_serialize�
request_class�response_class�ws_response_class�version�
cookie_jar�connector_owner�raise_for_status� read_timeout� conn_timeout�timeout�auto_decompress� trust_envrl �
trace_configs� read_bufsize)�base_urlr r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rl r� r� �returnc C s |d kr|d k r|j }t|�}|d ks0t|t�r8|| _n"t|�| _| j�� | jksZtd��|d krlt|d�}|j |k r~td��|| _ |� � r�t
� t �
d��| _|
d kr�t|d�}
|
| _|d k r�| j�|� || _|| _|| _| | _|| _|tk�rRt| _|tk �r$tjdt dd� t j | j|d�| _|d k �r|t j | j|d �| _tjd
t dd� n*|| _|tk �rjt d ��|d k �r|t d ��|| _ || _!|| _"|| _#|| _$|�r�t%|�}nt%� }|| _&|d k �r�t'd
d� |D ��| _(nt'� | _(| | _)|
| _*| | _+|�p�g | _,x| j,D ]}|�-� �qW d S )Nz2Only absolute URLs without path part are supported)r� z0Session and connector has to use same event loopr z8read_timeout is deprecated, use timeout argument instead� )�
stacklevel)r\ )r] z8conn_timeout is deprecated, use timeout argument insteadzGread_timeout and timeout parameters conflict, please setup timeout.readzJconn_timeout and timeout parameters conflict, please setup timeout.connectc s s | ]}t |�V qd S )N)r )�.0�ire re rf � <genexpr>/ s z)ClientSession.__init__.<locals>.<genexpr>).rm rC �
isinstancer ri �origin�AssertionErrorr: � RuntimeErrorZ get_debug� traceback�
extract_stack�sys� _getframerj r< rn �update_cookiesrk ro rp rq rr rD rg rt �warnings�warn�DeprecationWarning�attrZevolve�
ValueErrorru rv rw rs r~ r rx � frozensetry rz r{ r| r} Zfreeze)�selfr� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rl r� r� � real_headers� trace_configre re rf �__init__� s�
zClientSession.__init__)�clsr� c C s t jd�| j�tdd� d S )Nz6Inheritance class {} from ClientSession is discouragedr� )r� )r� r� �formatr` r� )r� re re rf �__init_subclass__; s
z ClientSession.__init_subclass__)�name�valr� c s2 || j kr tjd�|�tdd� t� �||� d S )Nz8Setting custom ClientSession.{} attribute is discouragedr� )r� )�ATTRSr� r� r� r� �super� __setattr__)r� r� r� )� __class__re rf r� E s
zClientSession.__setattr__)� _warningsr� c C s\ | j sXtrd| i}ni }|jd| ��tf|� | dd�}| jd k rL| j|d< | j�|� d S )N�sourcezUnclosed client session zUnclosed client session)Zclient_session�messageZsource_traceback)�closedr> r� �ResourceWarningrj rm Zcall_exception_handler)r� r� �kwargs�contextre re rf �__del__O s
zClientSession.__del__�_RequestContextManager)�method�urlr� r� c K s t | j||f|��S )zPerform HTTP request.)r� �_request)r� r� r� r� re re rf rX ] s zClientSession.request)�
str_or_urlr� c C s> t |�}| jd kr|S |�� s*|j�d�s.t�| j�|�S d S )N�/)r ri Z is_absolute�path�
startswithr� �join)r� r� r� re re rf �
_build_urlc s
zClientSession._build_url�
)�params�data�jsonr� r� r� r� �allow_redirects�
max_redirects�compress�chunked� expect100r� �read_until_eof�proxy�
proxy_authr� �
verify_ssl� fingerprint� ssl_context�ssl�
proxy_headers�trace_request_ctxr� )r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� c 3 � sX � j rtd��t||||�}|d k r6|d k r6td��n|d k rNtj|� jd�}t|
t�sl|
d k rlt �
dt � d}g } � j } � �
|�}� �
|�}y� �|�} W n, tk
r� } zt|�| �W d d } ~ X Y nX t� j�} |d k r�x|D ]}!| �t|!�� q�W |d k �r>y t|�}W n. tk
�r< } zt|�| �W d d } ~ X Y nX |tk�rP� j}"n t|t��sht|d�}"n|}"t� j|"j�}#|#�� }$|d k�r�� j }� �fdd�� j D �}%x(|%D ] }&|&� || � |�|�I d H �q�W |#� � }'�y
|'��x �xnt!| �\} }(| �r
|(�r
td ��| d k�r|(} | d k�r(� j"} |d k �rP| d k �rPt#j$|k�rPtd
��� j%�&| �})|d k �r�t'� }*|*�(|� |*�&| �}+|+�r�|)�)|+� |d k �r�t|�}n(� j*�r�t+t,�� t-| �\}}W d Q R X � j.|| ||| ||)| | | |
|� j� j/|||'� |||%d �},yPt0|"j1�4 I d H �. � j2d k �s*t3�� j2j1|,|%|"d �I d H }-W d Q I d H R X W n6 t4j5k
�r� }. zt6d
�7| ��|.�W d d }.~.X Y nX |-j8d k �s�t3�|-j9d k �s�t3�|-j9j:|'|�;� dk|� j<|"j=|d� ypyJ|,�>|-�I d H }/y|/�|-�I d H W n t?k
�r |/�@� � Y nX W n t?k
�r< |-�@� � Y nX W nF tAk
�rX � Y n0 tBk
�r� }. ztC|.jD� |.�W d d }.~.X Y nX � j%�(|/jE|/jF� |/jGdk�rP|
�rPx*|%D ]"}&|&�H|| � |�||/�I d H �q�W |d7 }| �I|/� | �r|| k�r|/�@� tJ| d jKtL| ���|/jGdk�r0|/jMt#jNk�sJ|/jGdk�rn|/jMt#jOk�rnt#jP}d }|�Qt#jR��rn|�St#jR� |/jT�Qt#jU��p�|/jT�Qt#jV�}0|0d k�r�P n|/�W� yt|0� jX d�}1W n. tk
�r� } zt|0�| �W d d } ~ X Y nX |1jY}2|2dk�r|/�@� td��n|2�s| �Z|1�}1| �[� |1�[� k�r<d } |�St#j$d � |1} d }|/�W� �q�P �q�W W d Q R X |d k�rr� j\}|�r�|/�]� |$d k �r�|/j^d k �r�|/j^�_|$j`� n|$�`� tL| �|/_ax*|%D ]"}&|&�b|| � |�||/�I d H �q�W |/S t?k
�rR } zL|#�@� |$�r|$�`� d }$x*|%D ]"}&|&�c|| � |�|| �I d H �qW � W d d } ~ X Y nX d S )NzSession is closedz9data and json parameters can not be used at the same time)�dumpsz Chunk size is deprecated #1615r )r\ c s g | ]}t � ||j�d ���qS ))r� )rO Ztrace_config_ctx)r� r� )r� r� re rf �
<listcomp>� s z*ClientSession._request.<locals>.<listcomp>z<Cannot combine AUTH argument with credentials encoded in URLzTCannot combine AUTHORIZATION header with AUTH argument or credentials encoded in URL)r� r� r� r� r� r� r� r� r� r� r� r� r� r� �timer�sessionr� r� �traces)r� r� z Connection timeout to host {}ZHEAD)r� Z skip_payloadr� r� r� r� )i- i. i/ i3 i4 r i/ )i- i. )Zencoded)r Zhttps� z"Can redirect only to http or https)dr� r� r6 r� r Z JsonPayloadrr r� �boolr� r� r� rq �_prepare_headersr� r+ �setry �addr r rD rt rW r@ rm r\ �startr~ r} Zsend_request_startZ update_queryr� rE rp r Z
AUTHORIZATIONrn Zfilter_cookiesr< r� �loadrw r � LookupErrorrB rz r{ rA r] rk r� �asyncio� TimeoutErrorr/ r� � transport�protocolZset_response_params�upperrv r^ �send�
BaseException�closer# �OSErrorr% �argsr� r� �statusZsend_request_redirect�appendr0 � request_info�tupler� � METH_HEAD� METH_POST�METH_GET�getZCONTENT_LENGTH�popr� ZLOCATIONZURI�releasers �schemer� r� ru r� �
connectionZ add_callback�cancelZ_historyZsend_request_endZsend_request_exception)3r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� Z redirects�historyr� r� �eZ skip_headersr� Z real_timeoutZtmZhandler� Ztracer� Z
auth_from_urlZ all_cookiesZtmp_cookie_jarZ req_cookiesZreq�conn�exc�respZr_urlZ
parsed_urlr� re )r� r� rf r� k sx #
&
zClientSession._requestre g $@r i @ )r� � protocolsr� �receive_timeout� autoclose�autoping� heartbeatr� r� r� r� r� r� r� r� r� r� r� r� � max_msg_size�_WSRequestContextManager)r� r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r r� c C s8 t | j||||||||| |
| | |
||||||||d��S )z Initiate websocket connection.)r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r )r
� _ws_connect)r� r� r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r re re rf �
ws_connect� s. zClientSession.ws_connectc * � sP | d krt � }nt | �}tjdtjdtjdi}x |�� D ]\}}|�||� q8W t�t �
d��}|� � |tj < |r�d�
|�|tj< |
d k r�|
|tj< |r�t|d�}||tj< t||||�}| j||| |d| |
|||d�
I d H } �y&| jd k�rt| j| jd
| j| jd ��| j�tjd ��� dk�r<t| j| jd
| j| jd ��| j�tjd ��� dk�rpt| j| jd| j| jd ��| j�tjd �} t�t � |t �� � �� � } | | k�r�t| j| jd| j| jd ��d } |�rtj| jk�rdd� | jtj � d�D �} x | D ]}!|!|k�r�|!} P �q�W d}"|�r�| j�tj�}#|#�r�yt!|#�\}}"W nF t"k
�r� }$ z&t| j| j|$j#d | j| jd �|$�W d d }$~$X Y nX nd}d}"| j$}%|%d k �s�t%�|%j&}&|&d k �s�t%�|%j'}'|'d k �s�t%�t(|&d| j)d�}(|&�*t+|(|�|(� t,|&|'d||"d�})W n t-k
�r& | �.� � Y n&X | j/|(|)| | |||| j)||||"d� S d S )NZ websocketZupgradeZ13� �,)r� F)r� r� r� r� r� r� r� r� �e zInvalid response status)r� r� r� r� zInvalid upgrade headerzInvalid connection headerzInvalid challenge responsec S s g | ] }|� � �qS re )�strip)r� �protore re rf r� B s z-ClientSession._ws_connect.<locals>.<listcomp>r i )r� T)Zuse_maskr� �
notakeover)r r r� Zclient_notakeover)0r r ZUPGRADEZ
CONNECTIONZSEC_WEBSOCKET_VERSION�items�
setdefault�base64Z b64encode�os�urandom�decodeZSEC_WEBSOCKET_KEYr� ZSEC_WEBSOCKET_PROTOCOLZORIGINrL ZSEC_WEBSOCKET_EXTENSIONSr6 rX r� r1 r� r� r� r� �lowerZSEC_WEBSOCKET_ACCEPT�hashlibZsha1rF Zdigest�splitrM rJ r� r� r� r� r� rN rm Z
set_parserrH rI r� r� r| )*r� r� r� r r� r r r r r� r� r� r� r� r� r� r� r� r� r� r� r r� Zdefault_headers�key�valueZsec_keyZextstrr Zr_key�matchr� Zresp_protocolsr r Z
compress_hdrsr r Z
conn_protor� �reader�writerre re rf r � s�
zClientSession._ws_connectzCIMultiDict[str])r� r� c C sl t | j�}|rht|ttf�s$t |�}t� }x<|�� D ]0\}}||krR|�||� q4|||< |�|� q4W |S )z3Add default headers and transform it to CIMultiDict)r rx r� r r r� r r� )r� r� �resultZ added_namesr r re re rf r� � s
z ClientSession._prepare_headers)r� )r� r� r� r� c K s t | jtj|fd|i|���S )zPerform HTTP GET request.r� )r� r� r r� )r� r� r� r� re re rf r� � s zClientSession.getc K s t | jtj|fd|i|���S )z Perform HTTP OPTIONS request.r� )r� r� r Z METH_OPTIONS)r� r� r� r� re re rf �options� s zClientSession.optionsc K s t | jtj|fd|i|���S )zPerform HTTP HEAD request.r� )r� r� r r� )r� r� r� r� re re rf �head� s zClientSession.head)r� )r� r� r� r� c K s t | jtj|fd|i|���S )zPerform HTTP POST request.r� )r� r� r r� )r� r� r� r� re re rf �post� s zClientSession.postc K s t | jtj|fd|i|���S )zPerform HTTP PUT request.r� )r� r� r ZMETH_PUT)r� r� r� r� re re rf �put� s zClientSession.putc K s t | jtj|fd|i|���S )zPerform HTTP PATCH request.r� )r� r� r Z
METH_PATCH)r� r� r� r� re re rf �patch� s zClientSession.patch)r� r� r� c K s t | jtj|f|��S )z Perform HTTP DELETE request.)r� r� r Z METH_DELETE)r� r� r� re re rf �delete� s zClientSession.delete)r� c � s0 | j s,| jdk r&| jr&| j�� I dH d| _dS )zMClose underlying connector.
Release all acquired resources.
N)r� rk ro r� )r� re re rf r� � s zClientSession.closec C s | j dkp| j jS )z@Is client session closed.
A readonly property.
N)rk r� )r� re re rf r� � s zClientSession.closedc C s | j S )z(Connector instance used for the session.)rk )r� re re rf r � s zClientSession.connectorc C s | j S )zThe session cookies.)rn )r� re re rf r� � s zClientSession.cookie_jarc C s | j S )z"The session HTTP protocol version.)rq )r� re re rf r� � s zClientSession.versionc C s | j S )z)Do URL requoting on redirection handling.)rs )r� re re rf rl � s z"ClientSession.requote_redirect_url)r� r� c C s t jdtdd� || _dS )z)Do URL requoting on redirection handling.z=session.requote_redirect_url modification is deprecated #2778r� )r� N)r� r� r� rs )r� r� re re rf rl � s
c C s t jdtdd� | jS )zSession's loop.z"client.loop property is deprecatedr� )r� )r� r� r� rm )r� re re rf r� � s zClientSession.loopc C s | j S )zTimeout for the session.)rt )r� re re rf r� s zClientSession.timeoutc C s | j S )z*The default headers of the client session.)rx )r� re re rf r� s zClientSession.headersc C s | j S )z2Headers for which autogeneration should be skipped)ry )r� re re rf r� s z ClientSession.skip_auto_headersc C s | j S )z2An object that represents HTTP Basic Authorization)rp )r� re re rf r� s zClientSession.authc C s | j S )zJson serializer callable)rr )r� re re rf r� s z ClientSession.json_serializec C s | j S )z-Should connector be closed on session closing)ro )r� re re rf r� s z ClientSession.connector_ownerc C s | j S )zGShould `ClientResponse.raise_for_status()` be called for each response.)ru )r� re re rf r� s z ClientSession.raise_for_statusc C s | j S )z7Should the body response be automatically decompressed.)rv )r� re re rf r� ' s z ClientSession.auto_decompressc C s | j S )z�
Should proxies information from environment or netrc be trusted.
Information is from HTTP_PROXY / HTTPS_PROXY environment variables
or ~/.netrc file if present.
)rw )r� re re rf r� , s zClientSession.trust_envc C s | j S )z7A list of TraceConfig instances used for client tracing)r} )r� re re rf r� 6 s zClientSession.trace_configsc C s
d| _ dS )zwDetach connector from session without closing the former.
Session is switched to closed state anyway.
N)rk )r� re re rf �detach; s zClientSession.detachc C s t d��d S )NzUse async with instead)� TypeError)r� re re rf � __enter__B s zClientSession.__enter__)�exc_type�exc_val�exc_tbr� c C s d S )Nre )r� r+ r, r- re re rf �__exit__E s zClientSession.__exit__c � s | S )Nre )r� re re rf �
__aenter__N s zClientSession.__aenter__c � s | � � I d H d S )N)r� )r� r+ r, r- re re rf � __aexit__Q s zClientSession.__aexit__)N)ar` ra rb �__doc__r� r� rj r� r� r2 r3 r7 r �
HttpVersion11rD r rU r8 r� �AbstractEventLooprS rT r �strr? rR r rG r r� r rc �objectrW r
rP �intr� r� r= r r� r� r� rX r r� r �bytesrY r4 r r� r r� r r r� r� r" r# r$ r% r& r' r� �propertyr� r r� r r� rl �setterr� r� r� r r r� r� r� r� r r r� r� r� r� r( r* r� r r. r/ r0 �
__classcell__re re )r� rf rV � st �]
� x x
&
rV c @ s� e Zd ZdZeddef dd�dd�Zddd�dd �Zedd�d
d �Z dd �d
d�Z
e e def d �dd�Z
e e def d �dd�Zed �dd�ZdS )�_BaseRequestContextManager)�_coro�_respzasyncio.Future[Any]N)�coror� c C s
|| _ d S )N)r< )r� r> re re rf r� ^ s z#_BaseRequestContextManager.__init__)�argr� c C s | j �|�S )N)r< r� )r� r? re re rf r� a s z _BaseRequestContextManager.sendc C s | j �|� d S )N)r< �throw)r� r? re re rf r@ d s z _BaseRequestContextManager.throw)r� c C s
| j �� S )N)r< r� )r� re re rf r� g s z _BaseRequestContextManager.closec C s | j �� }|S )N)r< � __await__)r� Zretre re rf rA j s
z$_BaseRequestContextManager.__await__c C s | � � S )N)rA )r� re re rf �__iter__n s z#_BaseRequestContextManager.__iter__c � s | j I d H | _| jS )N)r< r= )r� re re rf r/ q s z%_BaseRequestContextManager.__aenter__)r` ra rb � __slots__r rh r� r� r� r@ r� r
r rA rB r/ re re re rf r; Z s r; c @ s4 e Zd ZdZeee ee ee dd�dd�ZdS )r� re N)r+ r �tbr� c � s | j �� d S )N)r= r� )r� r+ r rD re re rf r0 y s z _RequestContextManager.__aexit__) r` ra rb rC r r r� r r0 re re re rf r� v s
r� c @ s4 e Zd ZdZeee ee ee dd�dd�ZdS )r
re N)r+ r rD r� c � s | j �� I d H d S )N)r= r� )r� r+ r rD re re rf r0 � s z"_WSRequestContextManager.__aexit__) r` ra rb rC r r r� r r0 re re re rf r
� s
r
c @ s^ e Zd ZdZeddef edd�dd�Zed�dd �Ze e
e e e e e dd
�d d �Z
dS )
� _SessionRequestContextManager)r< r= �_sessionzasyncio.Future[Any]N)r> r� r� c C s || _ d | _|| _d S )N)r< r= rF )r� r> r� re re rf r� � s z&_SessionRequestContextManager.__init__)r� c � sD y| j I d H | _W n& tk
r8 | j�� I d H � Y nX | jS d S )N)r< r= r� rF r� )r� re re rf r/ � s z(_SessionRequestContextManager.__aenter__)r+ r rD r� c � s, | j d k st�| j �� | j�� I d H d S )N)r= r� r� rF )r� r+ r rD re re rf r0 � s
z'_SessionRequestContextManager.__aexit__)r` ra rb rC r r3 rV r� r/ r r r� r r0 re re re rf rE � s
rE r� F)r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� )r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� c C sd d}|dkr d}t |dd�}t||||||d�}t|j| ||||||||| |
| | |
||||d�|�S )a� Constructs and sends a request.
Returns response object.
method - HTTP method
url - request url
params - (optional) Dictionary or bytes to be sent in the query
string of the new request
data - (optional) Dictionary, bytes, or file-like object to
send in the body of the request
json - (optional) Any json compatible python object
headers - (optional) Dictionary of HTTP Headers to send with
the request
cookies - (optional) Dict object to send with the request
auth - (optional) BasicAuth named tuple represent HTTP Basic Auth
auth - aiohttp.helpers.BasicAuth
allow_redirects - (optional) If set to False, do not follow
redirects
version - Request HTTP version.
compress - Set to True if request has to be compressed
with deflate encoding.
chunked - Set to chunk size for chunked transfer encoding.
expect100 - Expect 100-continue response from server.
connector - BaseConnector sub-class instance to support
connection pooling.
read_until_eof - Read response until eof if response
does not have Content-Length header.
loop - Optional event loop.
timeout - Optional ClientTimeout settings structure, 5min
total timeout by default.
Usage::
>>> import aiohttp
>>> resp = await aiohttp.request('GET', 'http://python.org/')
>>> resp
<ClientResponse(python.org/) [200]>
>>> data = await resp.read()
FNT)r� Z force_close)r� r� r� r� r r� )r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� )r: rV rE r� )r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r� r� r� r� re re rf rX � s@ > rX )�r1 r� r r r� r r� r� r� �
contextlibr �typesr r �typingr r r r r r
r r r
r r r r r r r r� Z multidictr r r r Zyarlr r� r r r �abcr Zclient_exceptionsr r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 Z
client_reqrepr2 r3 r4 r5 r6 Z client_wsr7 r r8 r9 r: r; Z cookiejarr< Zhelpersr= r> r? r@ rA rB rC rD rE rF rG rH rI Zhttp_websocketrJ rK rL rM ZstreamsrN �tracingrO rP ZtypedefsrQ rR rS rT rU �__all__r� rY � ImportErrorr5 �srW rg rd rh rV r; r� r
rE r2 r4 r� r6 r3 rX re re re rf �<module> s� H T , &
= %~