HEX

File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/client.cpython-37.pyc
B

�k�a~��@s�UdZddlZddlZddlZddlZddlZddlZddlZddlZddl	m
Z
ddlmZm
Z
ddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZddlZddl m!Z!m"Z"m#Z#m$Z$ddl%m&Z&dd	l'm(Z(m)Z)m*Z*dd
l+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFdd
lGmHZHddlImJZJmKZKmLZLmMZMddlNmOZOddlPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYddl)mZZZm[Z[m\Z\m]Z]ddl^m_Z_m`Z`maZambZbddlcmdZdddlemfZfmgZgddlhmiZimjZjmkZkmlZlmmZmdZnyddlompZpWneqk
�rXerZpYnXejsdddd�Gdd�d��Ztetdd�Zueietevd<ed�ZwGd d!�d!�ZxGd"d#�d#eeeewfeew�ZyGd$d%�d%eyeC�ZzGd&d'�d'eyeH�Z{Gd(d)�d)�Z|dddddddd*ddd+ddddeXde)j}dddd,�e~emeee~e~feeeeleee~eeSee�ee~eeeeeeeemeeSeeterfeeke[eeJee�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)rr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r8r:r;r9r7�
ClientSession�
ClientTimeout�request)�
SSLContextT)Zauto_attribs�frozen�slotsc@sNeZdZUdZeeed<dZeeed<dZeeed<dZ	eeed<dS)rWN�total�connect�	sock_read�sock_connect)
�__name__�
__module__�__qualname__r\r�float�__annotations__r]r^r_�rere�A/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/client.pyrW�s
rWi,)r\�DEFAULT_TIMEOUT�_RetTypecsXeZdZdZedddddddd	d
ddd
ddddddddddg�ZdZd�ddddddeje	e
eej
dddededddddd�eeeeeejeeeeeeeeeeee	ee
eeeeeeeeee feeee e!feeeee"e#e$dd�dd�Z%eddd �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/eefe(e(eeeeeeeeeee$eeeeeeeeeeeeee!e feeee0ee1eee1ee2feeee3ee$e
d2�d3d4�Z4e5j6d5d6dddddddddddddddd7d8d9�eeeeeeeeeeeeeeeee/eefeeeeeeee1ede2feeee0ee1eee$e$d:d;�d<d=�Z7e5j6d5d6dddddddddddddddd7d8d9�eeeeeeeeeeeeeeeee/eefeeeeeeee1ede2feeee0ee1eee$e$ed;�d>d?�Z8eed@dA�dBdC�Z9ddD�eee(d)dE�dFdG�Z:ddD�eee(d)dE�dHdI�Z;ddD�eee(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�ZAeBedW�dZd[��ZCeBeedW�d\d]��ZDeBedW�d^d_��ZEeBeFe$e$fdW�d`da��ZGeBedW�dbdc��ZHeHjIeddd�dedc��ZHeBejdW�dfdg��ZJeBee e!fdW�dhdi��ZKeBd@dW�djdk��ZLeBeMeNdW�dldm��ZOeBeedW�dndo��ZPeBedW�dpdq��ZQeBedW�drds��ZReBeeeSe
geTdffdW�dtdu��ZUeBedW�dvdw��ZVeBedW�dxdy��ZWeBe"e#dW�dzd{��ZXddW�d|d}�ZYddW�d~d�ZZeee[ee[ee\dd��d�d��Z]ddW�d�d��Z^eee[ee[ee\dd��d�d��Z_�Z`S)�rVz/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_urlrr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rlr�r��returncCs|dkr|dk	r|j}t|�}|dks0t|t�r8||_n"t|�|_|j��|jksZtd��|dkrlt|d�}|j|k	r~td��||_|�	�r�t
�t�
d��|_|
dkr�t|d�}
|
|_|dk	r�|j�|�||_||_||_||_||_|tk�rRt|_|tk	�r$tjdtdd�tj|j|d�|_|dk	�r|tj|j|d	�|_tjd
tdd�n*||_|tk	�rjtd��|dk	�r|td��||_ ||_!||_"||_#||_$|�r�t%|�}nt%�}||_&|dk	�r�t'd
d�|D��|_(nt'�|_(|	|_)|
|_*||_+|�p�g|_,x|j,D]}|�-��qWdS)Nz2Only absolute URLs without path part are supported)r�z0Session and connector has to use same event looprz8read_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.connectcss|]}t|�VqdS)N)r)�.0�irererf�	<genexpr>/sz)ClientSession.__init__.<locals>.<genexpr>).rmrC�
isinstancerri�origin�AssertionErrorr:�RuntimeErrorZ	get_debug�	traceback�
extract_stack�sys�	_getframerjr<rn�update_cookiesrkrorprqrrrDrgrt�warnings�warn�DeprecationWarning�attrZevolve�
ValueErrorrurvrwrsr~rrx�	frozensetryrzr{r|r}Zfreeze)�selfr�rr�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rlr�r��real_headers�trace_configrererf�__init__�s�











zClientSession.__init__)�clsr�cCstjd�|j�tdd�dS)Nz6Inheritance class {} from ClientSession is discouragedr�)r�)r�r��formatr`r�)r�rererf�__init_subclass__;s
zClientSession.__init_subclass__)�name�valr�cs2||jkr tjd�|�tdd�t��||�dS)Nz8Setting custom ClientSession.{} attribute is discouragedr�)r�)�ATTRSr�r�r�r��super�__setattr__)r�r�r�)�	__class__rerfr�Es
zClientSession.__setattr__)�	_warningsr�cCs\|jsXtrd|i}ni}|jd|��tf|�|dd�}|jdk	rL|j|d<|j�|�dS)N�sourcezUnclosed client session zUnclosed client session)Zclient_session�messageZsource_traceback)�closedr>r��ResourceWarningrjrmZcall_exception_handler)r�r��kwargs�contextrererf�__del__Os



zClientSession.__del__�_RequestContextManager)�method�urlr�r�cKst|j||f|��S)zPerform HTTP request.)r��_request)r�r�r�r�rererfrX]szClientSession.request)�
str_or_urlr�cCs>t|�}|jdkr|S|��s*|j�d�s.t�|j�|�SdS)N�/)rri�is_absolute�path�
startswithr��join)r�r�r�rererf�
_build_urlcs

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�c3�sX�jrtd��t||||�}|dk	r6|dk	r6td��n|dk	rNtj|�jd�}t|
t�sl|
dk	rlt	�
dt�d}g}�j}��
|�}��
|�}y��|�}Wn,tk
r�}zt|�|�Wdd}~XYnXt�j�} |dk	r�x|D]}!| �t|!��q�W|dk	�r>yt|�}Wn.tk
�r<}zt|�|�Wdd}~XYnX|tk�rP�j}"nt|t��sht|d�}"n|}"t�j|"j�}#|#��}$|dk�r��j}��fdd��jD�}%x(|%D] }&|&�||�|�|�IdH�q�W|#� �}'�y
|'��x�xnt!|�\}}(|	�r
|(�r
td	��|	dk�r|(}	|	dk�r(�j"}	|dk	�rP|	dk	�rPt#j$|k�rPtd
���j%�&|�})|dk	�r�t'�}*|*�(|�|*�&|�}+|+�r�|)�)|+�|dk	�r�t|�}n(�j*�r�t+t,��t-|�\}}WdQRX�j.||||| ||)|	|||
|�j�j/|||'�|||%d�},yPt0|"j1�4IdH�.�j2dk	�s*t3��j2j1|,|%|"d�IdH}-WdQIdHRXWn6t4j5k
�r�}.zt6d
�7|��|.�Wdd}.~.XYnX|-j8dk	�s�t3�|-j9dk	�s�t3�|-j9j:|'|�;�dk|�j<|"j=|d�ypyJ|,�>|-�IdH}/y|/�|-�IdHWn t?k
�r|/�@��YnXWn t?k
�r<|-�@��YnXWnFtAk
�rX�Yn0tBk
�r�}.ztC|.jD�|.�Wdd}.~.XYnX�j%�(|/jE|/jF�|/jGdk�rP|
�rPx*|%D]"}&|&�H||�|�||/�IdH�q�W|d7}|�I|/�|�r||k�r|/�@�tJ|djKtL|���|/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|0dk�r�Pn|/�W�yt|0�jXd�}1Wn.tk
�r�}zt|0�|�Wdd}~XYnX|1jY}2|2dk�r|/�@�td��n|2�s|�Z|1�}1|�[�|1�[�k�r<d}	|�St#j$d�|1}d}|/�W��q�P�q�WWdQRX|dk�rr�j\}|�r�|/�]�|$dk	�r�|/j^dk	�r�|/j^�_|$j`�n|$�`�tL|�|/_ax*|%D]"}&|&�b||�|�||/�IdH�q�W|/St?k
�rR}zL|#�@�|$�r|$�`�d}$x*|%D]"}&|&�c||�|�||�IdH�qW�Wdd}~XYnXdS)NzSession is closedz9data and json parameters can not be used at the same time)�dumpszChunk size is deprecated #1615r)r\cs g|]}t�||j�d���qS))r�)rOZtrace_config_ctx)r�r�)r�r�rerf�
<listcomp>�sz*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�zConnection timeout to host {}ZHEAD)r�Zskip_payloadr�r�r�r�)i-i.i/i3i4ri/)i-i.)�encoded)r�https�z"Can redirect only to http or https)dr�r�r6r�rZJsonPayloadrrr��boolr�r�r�rq�_prepare_headersr�r+�setry�addrrrDrtrWr@rmr\�startr~r}Zsend_request_startZupdate_queryr�rErprZ
AUTHORIZATIONrnZfilter_cookiesr<r��loadrwr�LookupErrorrBrzr{rAr]rkr��asyncio�TimeoutErrorr/r��	transport�protocolZset_response_params�upperrvr^�send�
BaseException�closer#�OSErrorr%�argsr�r��statusZsend_request_redirect�appendr0�request_info�tupler��	METH_HEAD�	METH_POST�METH_GET�getZCONTENT_LENGTH�popr�ZLOCATION�URI�releasers�schemer�r�rur��
connectionZadd_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��eZskip_headersr�Zreal_timeout�tm�handler��tracer�Z
auth_from_urlZall_cookiesZtmp_cookie_jarZreq_cookies�req�conn�exc�respZr_url�
parsed_urlrre)r�r�rfr�ksx#








 










&












zClientSession._requestreg$@ri@)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�rrrrr�r�r�r�r�r�r�r�r�r�r�r�rr�cCs8t|j|||||||||	|
|||
||||||||d��S)zInitiate websocket connection.)r�r
r�rrrrr�r�r�r�r�r�r�r�r�r�r�r�r)r�_ws_connect)r�r�r�r
r�rrrrr�r�r�r�r�r�r�r�r�r�r�r�rrererf�
ws_connect�s.zClientSession.ws_connectc*�sP|dkrt�}nt|�}tjdtjdtjdi}x |��D]\}}|�||�q8Wt�t	�
d��}|��|tj<|r�d�
|�|tj<|
dk	r�|
|tj<|r�t|d�}||tj<t||||�}|j||||d|	|
|||d�
IdH}�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�Wd}"|�r�|j�tj�}#|#�r�yt!|#�\}}"WnFt"k
�r�}$z&t|j|j|$j#d|j|jd�|$�Wdd}$~$XYnXnd}d}"|j$}%|%dk	�s�t%�|%j&}&|&dk	�s�t%�|%j'}'|'dk	�s�t%�t(|&d|j)d�}(|&�*t+|(|�|(�t,|&|'d||"d�})Wn t-k
�r&|�.��Yn&X|j/|(|)||||||j)||||"d�SdS)NZ	websocketZupgradeZ13��,)r�F)r�r�r�r�r�r�r�r��ezInvalid response status)r�r�r�r�zInvalid upgrade headerzInvalid connection headerzInvalid challenge responsecSsg|]}|���qSre)�strip)r��protorererfr�Bsz-ClientSession._ws_connect.<locals>.<listcomp>ri)r�T)Zuse_maskr��
notakeover)rrr�Zclient_notakeover)0rrZUPGRADEZ
CONNECTIONZSEC_WEBSOCKET_VERSION�items�
setdefault�base64�	b64encode�os�urandom�decodeZSEC_WEBSOCKET_KEYr�ZSEC_WEBSOCKET_PROTOCOLZORIGINrLZSEC_WEBSOCKET_EXTENSIONSr6rXr�r1r�rr�r��lowerZSEC_WEBSOCKET_ACCEPT�hashlib�sha1rF�digest�splitrMrJr�rr�r�r�rNrmZ
set_parserrHrIr�r�r|)*r�r�r�r
r�rrrrr�r�r�r�r�r�r�r�r�r�r�r�rr�Zdefault_headers�key�valueZsec_keyZextstrrZr_key�matchr�Zresp_protocolsrrZ
compress_hdrsr
r	Z
conn_protor��reader�writerrererfr�s�










zClientSession._ws_connectzCIMultiDict[str])r�r�cCslt|j�}|rht|ttf�s$t|�}t�}x<|��D]0\}}||krR|�||�q4|||<|�|�q4W|S)z3Add default headers and transform it to CIMultiDict)rrxr�rrr�rr�)r�r��resultZadded_namesr(r)rererfr��s
zClientSession._prepare_headers)r�)r�r�r�r�cKst|jtj|fd|i|���S)zPerform HTTP GET request.r�)r�r�rr�)r�r�r�r�rererfr��szClientSession.getcKst|jtj|fd|i|���S)zPerform HTTP OPTIONS request.r�)r�r�rZMETH_OPTIONS)r�r�r�r�rererf�options�szClientSession.optionscKst|jtj|fd|i|���S)zPerform HTTP HEAD request.r�)r�r�rr�)r�r�r�r�rererf�head�szClientSession.head)r�)r�r�r�r�cKst|jtj|fd|i|���S)zPerform HTTP POST request.r�)r�r�rr�)r�r�r�r�rererf�post�szClientSession.postcKst|jtj|fd|i|���S)zPerform HTTP PUT request.r�)r�r�rZMETH_PUT)r�r�r�r�rererf�put�szClientSession.putcKst|jtj|fd|i|���S)zPerform HTTP PATCH request.r�)r�r�rZ
METH_PATCH)r�r�r�r�rererf�patch�szClientSession.patch)r�r�r�cKst|jtj|f|��S)zPerform HTTP DELETE request.)r�r�rZMETH_DELETE)r�r�r�rererf�delete�szClientSession.delete)r�c�s0|js,|jdk	r&|jr&|j��IdHd|_dS)zMClose underlying connector.

        Release all acquired resources.
        N)r�rkror�)r�rererfr��szClientSession.closecCs|jdkp|jjS)z@Is client session closed.

        A readonly property.
        N)rkr�)r�rererfr��szClientSession.closedcCs|jS)z(Connector instance used for the session.)rk)r�rererfr�szClientSession.connectorcCs|jS)zThe session cookies.)rn)r�rererfr��szClientSession.cookie_jarcCs|jS)z"The session HTTP protocol version.)rq)r�rererfr��szClientSession.versioncCs|jS)z)Do URL requoting on redirection handling.)rs)r�rererfrl�sz"ClientSession.requote_redirect_url)r�r�cCstjdtdd�||_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�rererfrl�s
cCstjdtdd�|jS)zSession's loop.z"client.loop property is deprecatedr�)r�)r�r�r�rm)r�rererfr��szClientSession.loopcCs|jS)zTimeout for the session.)rt)r�rererfr�szClientSession.timeoutcCs|jS)z*The default headers of the client session.)rx)r�rererfr�szClientSession.headerscCs|jS)z2Headers for which autogeneration should be skipped)ry)r�rererfr�szClientSession.skip_auto_headerscCs|jS)z2An object that represents HTTP Basic Authorization)rp)r�rererfr�szClientSession.authcCs|jS)zJson serializer callable)rr)r�rererfr�szClientSession.json_serializecCs|jS)z-Should connector be closed on session closing)ro)r�rererfr�szClientSession.connector_ownercCs|jS)zGShould `ClientResponse.raise_for_status()` be called for each response.)ru)r�rererfr� szClientSession.raise_for_statuscCs|jS)z7Should the body response be automatically decompressed.)rv)r�rererfr�'szClientSession.auto_decompresscCs|jS)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�rererfr�,szClientSession.trust_envcCs|jS)z7A list of TraceConfig instances used for client tracing)r})r�rererfr�6szClientSession.trace_configscCs
d|_dS)zwDetach connector from session without closing the former.

        Session is switched to closed state anyway.
        N)rk)r�rererf�detach;szClientSession.detachcCstd��dS)NzUse async with instead)�	TypeError)r�rererf�	__enter__BszClientSession.__enter__)�exc_type�exc_val�exc_tbr�cCsdS)Nre)r�r7r8r9rererf�__exit__EszClientSession.__exit__c�s|S)Nre)r�rererf�
__aenter__NszClientSession.__aenter__c�s|��IdHdS)N)r�)r�r7r8r9rererf�	__aexit__QszClientSession.__aexit__)N)ar`rarb�__doc__r�r�rjr�r�r2r3r7r�
HttpVersion11rDrrUr8r��AbstractEventLooprSrTr�strr?rRrrGrr�rrc�objectrWr
rP�intr�r�r=rr�r�r�rXrr�r�bytesrYr4rr�rr�rrr�r�r.r/r0r1r2r3r��propertyr�rr�rr�rl�setterr�r�r�r	rr�r�r�r�rrr�r�r�r�r4r6r�rr:r;r<�
__classcell__rere)r�rfrV�st�]

�x x		
	&	

rVc@s�eZdZdZeddefdd�dd�Zddd�dd	�Zedd�d
d�Z	dd�d
d�Z
eedefd�dd�Z
eedefd�dd�Zed�dd�ZdS)�_BaseRequestContextManager)�_coro�_respzasyncio.Future[Any]N)�coror�cCs
||_dS)N)rH)r�rJrererfr�^sz#_BaseRequestContextManager.__init__)�argr�cCs|j�|�S)N)rHr�)r�rKrererfr�asz_BaseRequestContextManager.sendcCs|j�|�dS)N)rH�throw)r�rKrererfrLdsz _BaseRequestContextManager.throw)r�cCs
|j��S)N)rHr�)r�rererfr�gsz _BaseRequestContextManager.closecCs|j��}|S)N)rH�	__await__)r��retrererfrMjs
z$_BaseRequestContextManager.__await__cCs|��S)N)rM)r�rererf�__iter__nsz#_BaseRequestContextManager.__iter__c�s|jIdH|_|jS)N)rHrI)r�rererfr;qsz%_BaseRequestContextManager.__aenter__)r`rarb�	__slots__rrhr�r�r�rLr�r
rrMrOr;rerererfrGZsrGc@s4eZdZdZeeeeeeedd�dd�ZdS)r�reN)r7r
�tbr�c�s|j��dS)N)rIr�)r�r7r
rQrererfr<ysz _RequestContextManager.__aexit__)	r`rarbrPrrr�rr<rerererfr�vs

r�c@s4eZdZdZeeeeeeedd�dd�ZdS)rreN)r7r
rQr�c�s|j��IdHdS)N)rIr�)r�r7r
rQrererfr<�sz"_WSRequestContextManager.__aexit__)	r`rarbrPrrr�rr<rerererfr�s

rc@s^eZdZdZeddefedd�dd�Zed�dd	�Ze	e
ee	ee	edd
�dd�Z
dS)
�_SessionRequestContextManager)rHrI�_sessionzasyncio.Future[Any]N)rJr�r�cCs||_d|_||_dS)N)rHrIrS)r�rJr�rererfr��sz&_SessionRequestContextManager.__init__)r�c�sDy|jIdH|_Wn&tk
r8|j��IdH�YnX|jSdS)N)rHrIr�rSr�)r�rererfr;�sz(_SessionRequestContextManager.__aenter__)r7r
rQr�c�s,|jdk	st�|j��|j��IdHdS)N)rIr�r�rS)r�r7r
rQrererfr<�s
z'_SessionRequestContextManager.__aexit__)r`rarbrPrr3rVr�r;rrr�rr<rerererfrR�s
rRr�F)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rr�r�)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rr�r�r�cCsdd}|dkrd}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�Zforce_close)r�r�r�r�rr�)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�)r:rVrRr�)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rr�r�r�r�rererfrX�s@>rX)�r=r�rr$r�r r�r�r��
contextlibr�typesrr�typingrrrrr	r
rrr
rrrrrrrr�Z	multidictrrrrZyarlrr�rrr�abcrZclient_exceptionsrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1Z
client_reqrepr2r3r4r5r6Z	client_wsr7rr8r9r:r;Z	cookiejarr<Zhelpersr=r>r?r@rArBrCrDrErFrGrHrIZhttp_websocketrJrKrLrMZstreamsrN�tracingrOrPZtypedefsrQrRrSrTrU�__all__r�rY�ImportErrorrA�srWrgrdrhrVrGr�rrRr>r@r�rBr?rXrerererf�<module>s�HT,&
= %~