
    h%                        U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl	m
Z
 ddlmZ ddlmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z  ddl!Z!ddl"m#Z#m$Z$m%Z%m&Z& ddl'm(Z( dd	l)m*Z*m+Z+m,Z, dd
l-m.Z. ddl/m0Z0 ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZN ddlOmPZPmQZQmRZRmSZSmTZT ddlUmVZVmWZWmXZX ddlYmZZZm[Z[m\Z\m]Z]m^Z^ ddl_m`Z` ddlambZbmcZcmdZdmeZemfZfmgZgmhZhmiZi ddl+mjZjmkZkmlZlmmZm ddlnmoZompZpmqZq ddlrmsZsmtZt ddlumvZvmwZwmxZxmyZymzZz dZ{erddl|m}Z} ndZ}ej~        dk    rerddlmZ  G d ded          Z e!j        ddd           G d  d!                      Z ed"d#$          Zee         ed%<    eh d&          Z ed'eQeW          ZeeQegef         Z G d( d)          Z G d* d+eeeef         ee                   ZeeQ         ZeeW         Z G d, d-          Zej~        dk    r7er5e+j        ddd.d/ed0ezd1ekd2ee[         d3eej                 d4ee         d5efd6ZdS e+j        ddd.d/ed0ezd1ekd2ee[         d3eej                 d4ed5efd7ZdS )8zHTTP Client for asyncio.    N)suppress)TracebackType)TYPE_CHECKINGAny	AwaitableCallable	CoroutineFinal	FrozenSet	GeneratorGenericIterableListMappingOptionalSetTupleType	TypedDictTypeVarUnion)CIMultiDict	MultiDictMultiDictProxyistr)URL   )hdrshttppayload)WebSocketDataQueue)AbstractCookieJar)ClientConnectionErrorClientConnectionResetErrorClientConnectorCertificateErrorClientConnectorDNSErrorClientConnectorErrorClientConnectorSSLErrorClientErrorClientHttpProxyErrorClientOSErrorClientPayloadErrorClientProxyConnectionErrorClientResponseErrorClientSSLErrorConnectionTimeoutErrorContentTypeError
InvalidURLInvalidUrlClientErrorInvalidUrlRedirectClientErrorNonHttpUrlClientErrorNonHttpUrlRedirectClientErrorRedirectClientErrorServerConnectionErrorServerDisconnectedErrorServerFingerprintMismatchServerTimeoutErrorSocketTimeoutErrorTooManyRedirectsWSMessageTypeErrorWSServerHandshakeError)ClientRequestClientResponseFingerprintRequestInfo_merge_ssl_params)DEFAULT_WS_CLIENT_TIMEOUTClientWebSocketResponseClientWSTimeout)HTTP_AND_EMPTY_SCHEMA_SETBaseConnectorNamedPipeConnectorTCPConnectorUnixConnector)	CookieJar)	_SENTINELDEBUGEMPTY_BODY_METHODS	BasicAuthTimeoutHandleget_env_proxy_for_urlsentinelstrip_auth_from_url)WS_KEYHttpVersionWebSocketReaderWebSocketWriter)WSHandshakeError
ws_ext_genws_ext_parse)TraceTraceConfig)JSONEncoderLooseCookiesLooseHeadersQueryStrOrURL)*r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r7   r5   r4   r6   r8   r9   r:   r;   r<   r=   r?   r@   rA   rB   rC   rI   rK   rL   rJ   rF   ClientSessionClientTimeoutrG   requestr>   )
SSLContext      )Unpackc                   Z   e Zd ZU eed<   eed<   eed<   eedf         ed<   eedf         ed<   ee	e
         df         ed<   eedf         ed<   eed	<   eed
<   ee
edf         ed<   eedf         ed<   eed<   edeeeged         f         f         ed<   eed<   eedf         ed<   eedf         ed<   ded<   eeeef         ed<   ee
df         ed<   eedf         ed<   eee
ef         df         ed<   eedf         ed<   eedf         ed<   eedf         ed<   eedf         ed<   dS )_RequestOptionsparamsdatajsonNcookiesheadersskip_auto_headersauthallow_redirectsmax_redirectscompresschunked	expect100raise_for_statusread_until_eofproxy
proxy_authz%Union[ClientTimeout, _SENTINEL, None]timeoutsslserver_hostnameproxy_headerstrace_request_ctxread_bufsizeauto_decompressmax_line_sizemax_field_size)__name__
__module____qualname__rb   __annotations__r   r   r`   ra   r   strrQ   boolintr   rA   r   rc   rg   rB   r        P/var/www/html/prod/cognitive/venv/lib/python3.11/site-packages/aiohttp/client.pyrm   rm      s        MMM
III
III<%&&&&<%&&&&Xc]D01111
	4
    CtO$$$$4:OOOD$.1A9T?1R(SSTTTT4    io&&&&4444	z4,	----39%%%%t+,,,,WS#X.45555T	""""4:&&&&d#####t)$$$$$$r   rm   FtotalT)auto_attribsfrozenslotsc                       e Zd ZU dZee         ed<   dZee         ed<   dZee         ed<   dZ	ee         ed<   dZ
eed<   dS )re   Nr   connect	sock_readsock_connect   ceil_threshold)r   r   r   r   r   floatr   r   r   r   r   r   r   r   re   re      sr         !E8E?!!!#GXe_###!%Ix%%%$(L(5/(((NEr   re   i,     )r   r   DEFAULT_TIMEOUT>   GETPUTHEADTRACEDELETEOPTIONS_RetTypec            ?           e Zd ZU dZ eg d          ZdZeej	                 e
d<   dZee         e
d<   	 dddddddddej        eeeej        dddededddddd	d	d
 ddee         dee         deej                 dee         dee         dee         dee         deee                  dee         dedee         dee         dee         dedee          de!de"e!e#ege$d         f         f         de"e%e&f         dee%         de"e'e(f         d e!d!e!d"e!d#ee)e*                  d$e+d%e+d&e+d'e,d(df:d)Z-d*ed          d(dfd+Z.e/rd,ed-e0d(df fd.Z1e2fd/e0d(dfd0Z3e4j5        d1k    re6rd2ed3ed4e7e8         d(d5fd6Z9nd2ed3ed4e0d(d5fd7Z9d8ed(e:fd9Z;ddddddddd:dddddddedddddddddddd;d2ed8ed<e<d=e0d>e0dee         dee         deee                  dee         d?e!d@e+dAe"ee!df         dBee!         dCe!de"de!e#ege$d         f         f         dDe!dee         dee         de"e(e&f         dEee!         dFee=         dGee>         dHe"e>e!e?f         dIee         dJee         dKee@ee0f                  d$ee+         d ee!         d%ee+         d&ee+         d(ef>dLZAeBjC        dMedddddddddddddddddNdOdPd3ed2edQee         de"eDe&f         dRee%         dSe!dTe!dUee%         dee         dVee         d<e<dee         dee         dee         dHe"e>e!e?f         dEee!         dFee=         dGee>         dIee         dJee         dAe+dWe+d(dXf.dYZEeBjC        dMedddddddddddddddddNdOdPd3ed2edQee         de"eDe&f         dRee%         dSe!dTe!dUee%         dee         dVee         d<e<dee         dee         dee         dHe"e>e!e?f         dEee!         dFee=         dGee>         dIee         dJee         dAe+dWe+d(ef.dZZFdee         d(d[fd\ZGe4j5        d1k    rse6rqd3ed4e7e8         d(d5fd]ZHd3ed4e7e8         d(d5fd^ZId3ed4e7e8         d(d5fd_ZJd3ed4e7e8         d(d5fd`ZKd3ed4e7e8         d(d5fdaZLd3ed4e7e8         d(d5fdbZMd3ed4e7e8         d(d5fdcZNnddddd3ed?e!d4e0d(d5fdeZHdddd3ed?e!d4e0d(d5fdfZIdddd3ed?e!d4e0d(d5fdgZJddhd3ed=e0d4e0d(d5fdiZKddhd3ed=e0d4e0d(d5fdjZLddhd3ed=e0d4e0d(d5fdkZMd3ed4e0d(d5fdlZNddmZOePd(e!fdn            ZQePd(ee         fdo            ZRePd(e fdp            ZSePd(eTe+e+f         fdq            ZUePd(e!fdr            ZVeVjW        d-e!d(dfds            ZVePd(ej        fdt            ZXePd(e(fdu            ZYePddv            ZZePd(e[e\         fdw            Z]ePd(ee         fdx            Z^ePd(efdy            Z_ePd(e!fdz            Z`ePd(e"e!e#ege$d         f         f         fd{            ZaePd(e!fd|            ZbePd(e!fd}            ZcePd(e)e*         fd~            ZdddZeddZfdeeeg                  deeg         deeh         d(dfdZiddZjdeeeg                  deeg         deeh         d(dfdZk xZlS )rd   z/First-class interface for making HTTP requests.)	_base_url_base_url_origin_source_traceback
_connector_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_bufsize_max_line_size_max_field_size_resolve_charset_default_proxy_default_proxy_auth_retry_connectionrequote_redirect_urlNr   r   TF   i  c                     dS )Nzutf-8r   )rbs     r   <lambda>zClientSession.<lambda>,  s    7 r   )	connectorlooprq   rr   r|   r}   rs   rt   json_serializerequest_classresponse_classws_response_classversion
cookie_jarconnector_ownerrz   read_timeoutconn_timeoutr~   r   	trust_envr   trace_configsr   r   r   fallback_charset_resolverbase_urlr   r   rq   rr   r|   r}   rs   rt   r   r   r   r   r   r   r   rz   r   r   r~   r   r   r   r   r   r   r   r   returnc                   d | _         |	||j        }|pt          j                    }|t	          |t
                    r%|| _        |d n|                                | _        nHt          |          | _        | j                                        | _        | j        j	        s
J d            | j        .| j        j
                            d          st          d          |t          u s|t          | _        |t          ur<t!          j        dt$          d           t'          j        | j        |          | _        |<t'          j        | j        |          | _        t!          j        d	t$          d           net	          |t*                    s t          d
t-          |           d          || _        |t          urt          d          |t          d          |t/          |          }|j        |urt1          d          || _        |                                r+t5          j        t9          j        d                    | _        |t?          |          }|| _         |r| j         !                    |           || _         || _"        |	| _#        || _$        |
| _%        || _&        || _'        || _(        || _)        || _*        || _+        || _,        |rt[          |          }nt[                      }|| _.        |t_          d |D                       | _0        nt_                      | _0        || _1        || _2        || _3        |pg | _4        | j4        D ]}|5                                 || _6        || _7        || _8        d| _9        d S )Nz Only absolute URLs are supported/z!base_url must have a trailing '/'z8read_timeout is deprecated, use timeout argument instead   
stacklevelr   )r   z8conn_timeout is deprecated, use timeout argument insteadztimeout parameter cannot be of z. type, please use 'timeout=ClientTimeout(...)'zGread_timeout and timeout parameters conflict, please setup timeout.readzJconn_timeout and timeout parameters conflict, please setup timeout.connectr   z0Session and connector has to use same event loopr   c              3   4   K   | ]}t          |          V  d S Nr   .0is     r   	<genexpr>z)ClientSession.__init__.<locals>.<genexpr>  s(      /S/SAQ/S/S/S/S/S/Sr   T):r   r   asyncioget_running_loop
isinstancer   r   originr   absolutepathendswith
ValueErrorrT   r   r   warningswarnDeprecationWarningattrevolvere   typerK   RuntimeError	get_debug	tracebackextract_stacksys	_getframer   rM   r   update_cookiesr   r   r   r   r   r   r   r   r   r   r   r   r   	frozensetr   r   r   r   r   freezer   r   r   r   )selfr   r   r   rq   rr   r|   r}   rs   rt   r   r   r   r   r   r   r   rz   r   r   r~   r   r   r   r   r   r   r   r   real_headerstrace_configs                                  r   __init__zClientSession.__init__  s   H 48<$ 1w/11z(C88,4DN,4,<DD(//BSBSD!! ]]DN$(N$9$9$;$;D!>*NN,NNN*>%dn.A.J.J3.O.O%@AAAh'/+DM8++N&    
 !%DM N N N' $DM< P P PN&     g}55  >d7mm > > >   $DM8++ #  
 ' &   $$///I?$&&QRRR
>> 	O%.%<S]1=M=M%N%ND""---J% 	5++G444# /!-!1 /#%9")+-  	)-8-A-ALL&==L2>(&//S/SAR/S/S/S&S&SD##&/kkD#+-"3+1r / 	" 	"L!!!! 9##- '+r   clsc                 n    t          j        d                    | j                  t          d           d S )Nz6Inheritance class {} from ClientSession is discouragedr   r   )r   r   formatr   r   )r  s    r   __init_subclass__zClientSession.__init_subclass__  s?    #VCL11		
 	
 	
 	
 	
 	
r   namevalc                     || j         vr/t          j        d                    |          t          d           t                                          ||           d S )Nz8Setting custom ClientSession.{} attribute is discouragedr   r   )ATTRSr   r   r  r   super__setattr__)r   r  r  	__class__s      r   r
  zClientSession.__setattr__  sa    4:%%%%+VD\\& 	    GGc*****r   	_warningsc                     | j         sMd| i} |j        d| t          fi | | dd}| j        
| j        |d<   | j                            |           d S d S )NsourcezUnclosed client session zUnclosed client session)client_sessionmessagesource_traceback)closedr   ResourceWarningr   r   call_exception_handler)r   r  kwargscontexts       r   __del__zClientSession.__del__  s    { 	7%FIN3433_ HN   *.:STTG%1.2.D*+J--g66666	7 	7r   rh   methodurlr  _RequestContextManagerc                     d S r   r   r   r  r  r  s       r   rf   zClientSession.request  s	    
 (+sr   c                 :    t           | j        ||fi |          S )zPerform HTTP request.)r  _requestr  s       r   rf   zClientSession.request  s(     *-$-*N*Nv*N*NOOOr   
str_or_urlc                 x    t          |          }| j        |S |j        rJ | j                            |          S r   )r   r   r   join)r   r  r  s      r   
_build_urlzClientSession._build_url  s>    *oo>!J|###>&&s+++r   
   )rn   ro   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   rz   r{   r|   r}   r~   
verify_sslfingerprintssl_contextr   r   r   r   r   r   r   r   rn   ro   rp   ru   rv   rw   rx   ry   r{   r$  r%  r&  r   r   r   r   c                   K    j         rt          d          t          ||||          }||t          d          |t	          j        | j                  }t          |t                    s|t          j
        dt                     d}g }  j        }!|pi }                     |          }	                      |          }"n"# t          $ r}#t          |          |#d }#~#ww xY w j        J |"j         j        j        vrt'          |"          |d |D              j        z  }$n j        r j        }$nd }$| j        }| j        }|d }nH                     |          }	 t/          |          }n"# t          $ r}#t1          |          |#d }#~#ww xY w|t2          u r j        }%n(t          |t6                    st7          |          }%n|}%t9           j        |%j        |%j                  }&|&                                 }'| j!        }| j"        }| j#        }| j$        } fd	 j%        D             }(|(D ]2})|)&                    ||"'                    |          |           d {V  3|&(                                }*	 |*5   j)        o|tT          v }+	 tW          |"          \  }"},|"j,        s|rtZ          nt          }- |-|"          | s|	r|,rt          d          |	| r|,|,}	|	2 j.        r+ j/        r j0        |"1                                k    r j.        }	||	td          j3        |v rt          d           j4        5                    |"          }.|[tm           j4        j7                  }/|/8                    |           |/5                    |"          }0|0r|.9                    |0           |t/          |          }nE j:        r>tw          tx                    5  t{          |"          \  }}d d d            n# 1 swxY w Y    >                    ||"|||$||.|	|!||| j         j?        |||* ||nd
|||( j@                  }1	  j        A                    |1|(|%           d {V }2n*# t          jC        $ r}3t          d|"           |3d }3~3ww xY w|2jE        J |2jF        J |2jF        G                    |*|t          v |||%jI        | j        jJ        ||	  	         	 	 |1K                    |2           d {V }4	 |4                     |2           d {V  n## t          $ r |4M                                  w xY wn## t          $ r |2M                                  w xY wne# t          t          f$ r	 |+rd}+Y  t          $ r  t          $ r6}3|3jR        t          |3t          jC                  r t          |3jS         |3d }3~3ww xY w|4jT        x}r  j4        8                    ||4jU                   |4jV        dv r|
r|(D ]3})|)W                    ||"'                    |          ||4           d {V  4|dz  }| X                    |4           |rB||k    r<|4M                                 t          | d         jZ        t          |                     |4jV        dk    r|4j\        td          j]        k    s|4jV        dv ra|4j\        td          j^        k    rLtd          j_        }d }|`                    td          ja                  r|b                    td          ja                   |4jc        `                    td          jd                  p#|4jc        `                    td          je                  }5|5n(|4f                                 	 t/          |5 jg                   }6n## t          $ r}#t[          |5d          |#d }#~#ww xY w|6j        }7|7t          vr#|4M                                 t          |5          |7s|"j                    |6          }6	 |61                                }8n## t          $ r}9t[          |6d          |9d }9~9ww xY w|"1                                |8k    r"d }	|b                    td          j3        d            |6}"i }|4f                                 	 d d d            n# 1 swxY w Y   | jk        }|n7t          |          r ||4           d {V  n|r|4m                                 |';|4jn         |4jn        o                    |'jp                   n|'p                                 t          |           |4_q        |(D ]3})|)r                    ||"'                    |          ||4           d {V  4|4S # t          $ rh}#|&M                                 |'r|'p                                 d }'|(D ]3})|)s                    ||"'                    |          ||#           d {V  4 d }#~#ww xY w)NzSession is closedz9data and json parameters can not be used at the same time)dumpszChunk size is deprecated #1615r   c                 ,    h | ]}t          |          S r   r   r   s     r   	<setcomp>z)ClientSession._request.<locals>.<setcomp>!  s+       Q  r   r   )r   c           	      Z    g | ]'}t          ||                                         (S ))r   )r]   trace_config_ctx)r   r   r   r   s     r   
<listcomp>z*ClientSession._request.<locals>.<listcomp>Q  sP     
 
 
  --@Q-RR 
 
 
r   Tz<Cannot combine AUTH argument with credentials encoded in URLzTCannot combine AUTHORIZATION header with AUTH argument or credentials encoded in URL)quote_cookie)rn   rr   rs   ro   rq   rt   r   rw   rx   ry   r   r   r|   r}   timersessionr   r   r   tracesr   )r1  r~   zConnection timeout to host )	r/  skip_payloadr{   r   r   r   timeout_ceil_thresholdr   r   F)-  .  /  i3  i4  r   r6  )r4  r5  )encodedzHServer attempted redirecting to a location that does not look like a URLzInvalid redirect URL origin)tr  r   rD   r   r    JsonPayloadr   r   r   r   r   r   r   _prepare_headersr"  r3   r   schemeallowed_protocol_schema_setr5   r   r   r   r   r2   rT   r   re   rR   r   r   r   startr   r   r   r   r   send_request_startupdate_queryr/  r   IDEMPOTENT_METHODSrU   raw_hostr4   r   r   r   r   r   AUTHORIZATIONr   filter_cookiesrM   r.  r   loadr   r   LookupErrorrS   r   r   r   r   r   TimeoutErrorr0   	transportprotocolset_response_paramsrP   r   _timeout_ceil_thresholdsendBaseExceptioncloser+   r9   r)   OSErrorerrnoargs_cookiesr  statussend_request_redirectappendr=   request_infotupler  	METH_HEAD	METH_POSTMETH_GETgetCONTENT_LENGTHpoprr   LOCATIONURIreleaser   rH   r6   r!  r   callablerz   
connectionadd_callbackcancel_historysend_request_endsend_request_exception):r   r  r  rn   ro   rp   rq   rr   rs   rt   ru   rv   rw   rx   ry   rz   r{   r|   r}   r~   r$  r%  r&  r   r   r   r   r   r   r   r   	redirectshistoryr   r  eskip_headersreal_timeouttmhandler1  tracer/  retry_persistent_connectionauth_from_urlerr_exc_clsall_cookiestmp_cookie_jarreq_cookiesreqconnexcrespr_urlparsed_redirect_urlr:  redirect_originorigin_val_errs:   `                         `                               r   r  zClientSession._request  s     R ; 	42333ZkJJ 0K   &t43GHHHD'4(( 	PW-@M:<NOOO	(*-2 ''00	;//*--CC 	; 	; 	;'
33:	; ***:T_HHH',,, ( !2  '(LL $ 	 2LLL='E1J= MM 11-@@M/E

 / / / ''Q./ h*.-LLg}55 ',7;;;& J*<;V
 
 
 -L""3O  /M!!1N
 
 
 
 
 !% 3
 
 
  	V 	VE**633C3CF3K3KWUUUUUUUUUU

@	 X X *Kv9K/K ,S)<S)A)A&C< /
  )799!6 $
 *k#... #   (9   ||M4M,  . % !% % 372G3::<<2W2W  $1  + , .'99(-   #'"2"A"A#"F"FK*)2)-)9)F* * * '55g>>>&4&C&CC&H&H& :',,[999( #E

 K%k22 K K0Ec0J0J-E:K K K K K K K K K K K K K K K --% '*6! +! '!) '"+!Z'+';##-# $#&?CC(7&3%"&./ .  C6#%)_%<%< &= & &             #/ # # #4?#?? "##
  >555=444M55#%+/A%A'5(7%1%;%1/3/V&3'5 6 
 
 
@	"),$#7#7#7#7#7#7D&&*jj&6&6 6 6 6 6 6 6 6 6#0 & & & $

 %& !7  - " " " JJLLL!"	 !7 *+BC   6 %:?7$H&   " @ @ @9,CAU1V1V,!+SX6C?@
 #'-/w K(77JJJ {&???O?%+  E"'"="= &(8(8(@(@'4# #         "Q	t,,,( Y--G-G JJLLL"2 '
 7w# #  !K3..4;$.3P3P K:55$+:W:W%)]F#'D&{{4+>?? A 'D,? @ @ @ $ 0 0 ? ? !4<CSCS HD D !=! !LLNNN%25 %43M/M3 3 3//  * % % %"? % j# # $%%% "5!;!)BBB JJLLL"?"F"FF!' P25((;N2O2O/2.A.H.H.J.JOO) 2 2 2"? 3 =# # $222 ::<<?::#'D#KK(:DAAA1!# qX X X X X X X X X X X X X X Xv  '#'#9 '*++ (&&t,,,,,,,,,,! (%%''' !?.O00????MMOOO!'NNDM  ,,C,,V44gt          K 	 	 	HHJJJ   22C,,V44gq          	s^  3C	 	
C(C##C(+E; ;
FFFf  Eb)+P
>b)
P	b)P	Ab)#Q98b)9R RR  Ab)0UT('U( UUU0 U,,U0/b)0Wb)W1WWF7b)
^"!b)"
_,^==_Ab)`%$b)%
a/a  aAb)f  )b--f  0b-1Cf   
g2
A#g--g2r   r   i  @ r  	protocolsr~   receive_timeout	autocloseautoping	heartbeatrt   r   rn   rr   r|   r}   r   r$  r%  r&  r   r   rw   max_msg_sizer}  r~  r  r  r  r   r  _WSRequestContextManagerc                r    t          |                     |||||||||	|
||||||||||||                    S )zInitiate websocket connection.r|  )r  _ws_connect)r   r  r  r}  r~   r~  r  r  r  rt   r   rn   rr   r|   r}   r   r$  r%  r&  r   r   rw   r  s                          r   
ws_connectzClientSession.ws_connect`  sp    6 (# /#!#%%'' /+!)-   
 
 	
r   c                
  K   |t           urEt          |t                    r|}n4t          j        dt
          d           t          |          }nt          }|2t          j        dt
          d           t          j        ||          }|t                      }nt          |          }t          j        dt          j        dt          j        d	i}|                                D ]\  }}|                    ||           t!          j        t%          j        d
                    }|                                |t          j        <   |r"d                    |          |t          j        <   |
|
|t          j        <   |rt3          |          }||t          j        <   |t          j        dt
          d           d}t7          ||||          }|                     ||||d|	|||||           d {V }	 |j        dk    r(t=          |j        |j         d|j        |j!                  |j!        "                    t          j        d          #                                dk    r(t=          |j        |j         d|j        |j!                  |j!        "                    t          j        d          #                                dk    r(t=          |j        |j         d|j        |j!                  |j!        "                    t          j$        d          }t!          j        tK          j&        |tN          z             (                                                                          } || k    r(t=          |j        |j         d|j        |j!                  d }!|rTt          j        |j!        v rAd |j!        t          j                 )                    d          D             }"|"D ]
}#|#|v r|#}! nd}$|r|j!        "                    t          j                  }%|%rZ	 tU          |%          \  }}$nJ# tV          $ r9}&t=          |j        |j         |&j,        d         |j        |j!                  |&d }&~&ww xY wd}d}$|j-        }'|'J |'j.        }(|(J |j/        d |(_0        n&|(j0        tc          |j/        |(j0                  |(_0        |'j2        })|)J tg          |(d| j4                  }*|(5                    tm          |*|          |*           to          |(|)d||$          }+| 8                    |*|+|!||||| j4        |||$          S # tr          $ r |:                                  w xY w)Nzeparameter 'timeout' of type 'float' is deprecated, please use 'timeout=ClientWSTimeout(ws_close=...)'r   r   )ws_closezofloat parameter 'receive_timeout' is deprecated, please use parameter 'timeout=ClientWSTimeout(ws_receive=...)')
ws_receive	websocketUpgrade13   ,)rw   z+ssl=None is deprecated, please use ssl=TrueTF)	rn   rr   r{   rt   r|   r}   r   r   r   e   zInvalid response status)r  rQ  rr    zInvalid upgrade headerupgradezInvalid connection headerzInvalid challenge responsec                 6    g | ]}|                                 S r   )strip)r   protos     r   r-  z-ClientSession._ws_connect.<locals>.<listcomp>&  s0     " " " KKMM" " "r   r   r   r   )use_maskrw   
notakeover)r  rw   client_notakeover);rT   r   rG   r   r   r   rE   r   r   r   r   UPGRADE
CONNECTIONSEC_WEBSOCKET_VERSIONitems
setdefaultbase64	b64encodeosurandomdecodeSEC_WEBSOCKET_KEYr!  SEC_WEBSOCKET_PROTOCOLORIGINr[   SEC_WEBSOCKET_EXTENSIONSrD   rf   rQ  r?   rT  rg  rr   rY  lowerSEC_WEBSOCKET_ACCEPThashlibsha1rV   digestsplitr\   rZ   rO  r`  rG  r  r   maxrF  r!   r   
set_parserrX   rY   r   rK  rL  ),r   r  r  r}  r~   r~  r  r  r  rt   r   rn   rr   r|   r}   r   r$  r%  r&  r   r   rw   r  
ws_timeoutr   default_headerskeyvaluesec_keyextstrrw  r_keymatchrG  resp_protocolsr  r  compress_hdrsrv  ru  
conn_protorF  readerwriters,                                               r   r  zClientSession._ws_connect  s9     4 (""'?33 
?$

> '     -g>>>

2J&M< #    ZOLLLJ?-8]]LL&w//L L+OY&
 *//11 	0 	0JC##C////"2:b>>22/6~~/?/?T+, 	L8;8K8KL45(.L% 	A222F:@L67 ;M="   
 CZkJJ \\  !+' " 
 
 
 
 
 
 
 
s	{c!!,%L5; L    |b117799[HH,%L4; L    |44::<<	II,%L7; L    L$$T%>CCE$W\'F2B%C%C%J%J%L%LMMTTVVE~~,%L8; L    H 	T8DLHH" "!%d.I!J!P!PQT!U!U" " "
 ,  E	))#( *
 J ' $ 0 01N O O  '	#/;M/J/J,**+ # # #4 - L$'HQK#';$(L    ###  !H!&J?D###J))) $,*.
''(4*-):+B+ +
' I((('
E
KKKF!!/&,"G"GPPP$!%  F **
#!", +   	  	 	 	JJLLL	s2   8H U  P, +U  ,
Q/64Q**Q//B,U    U CIMultiDict[str]c                 B   t          | j                  }|rt          |t          t          f          st          |          }t                      }|                                D ]:\  }}||v r|                    ||            |||<   |                    |           ;|S )z3Add default headers and transform it to CIMultiDict)r   r   r   r   r   setr  add)r   rr   resultadded_namesr  r  s         r   r9  zClientSession._prepare_headerso  s     T233 		)g	'BCC /%g..$'EEK%mmoo ) )
U+%%JJsE****"'F3KOOC((((r   c                     d S r   r   r   r  r  s      r   rY  zClientSession.get  	     (+sr   c                     d S r   r   r  s      r   optionszClientSession.options  r  r   c                     d S r   r   r  s      r   headzClientSession.head  r  r   c                     d S r   r   r  s      r   postzClientSession.post  r  r   c                     d S r   r   r  s      r   putzClientSession.put  r  r   c                     d S r   r   r  s      r   patchzClientSession.patch  r  r   c                     d S r   r   r  s      r   deletezClientSession.delete  r  r   )ru   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP GET request.ru   )r  r  r   rX  r   r  ru   r  s       r   rY  zClientSession.get  sC     *M3 8GKQ   r   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP OPTIONS request.ru   )r  r  r   METH_OPTIONSr  s       r   r  zClientSession.options  sD     *%s <KOU   r   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP HEAD request.ru   )r  r  r   rV  r  s       r   r  zClientSession.head  sC     *NC 9HLR   r   )ro   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP POST request.ro   )r  r  r   rW  r   r  ro   r  s       r   r  zClientSession.post  s6     *dncGGGGG  r   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP PUT request.ro   )r  r  r   METH_PUTr  s       r   r  zClientSession.put  s6     *dmSFFtFvFF  r   c                R    t           | j        t          j        |fd|i|          S )zPerform HTTP PATCH request.ro   )r  r  r   
METH_PATCHr  s       r   r  zClientSession.patch  s6     *dosHHHHH  r   c                 N    t           | j        t          j        |fi |          S )zPerform HTTP DELETE request.)r  r  r   METH_DELETEr  s      r   r  zClientSession.delete  s0    )d.>>v>>  r   c                    K   | j         s6| j        &| j        r| j                                         d{V  d| _        dS dS )zMClose underlying connector.

        Release all acquired resources.
        N)r  r   r   rL  r   s    r   rL  zClientSession.close  s]      
 { 	#*t/D*o++---------"DOOO	# 	#r   c                 ,    | j         du p| j         j        S )z@Is client session closed.

        A readonly property.
        N)r   r  r  s    r   r  zClientSession.closed  s     $&@$/*@@r   c                     | j         S )z(Connector instance used for the session.r   r  s    r   r   zClientSession.connector  s     r   c                     | j         S )zThe session cookies.)r   r  s    r   r   zClientSession.cookie_jar   s     r   c                     | j         S )z"The session HTTP protocol version.)r   r  s    r   r   zClientSession.version       }r   c                     | j         S ))Do URL requoting on redirection handling.)r   r  s    r   r   z"ClientSession.requote_redirect_url
  s     ))r   c                 L    t          j        dt          d           || _        dS )r  z=session.requote_redirect_url modification is deprecated #2778r   r   N)r   r   r   r   )r   r  s     r   r   z"ClientSession.requote_redirect_url  s6     	K	
 	
 	
 	

 &)"""r   c                 H    t          j        dt          d           | j        S )zSession's loop.z"client.loop property is deprecatedr   r   )r   r   r   r   r  s    r   r   zClientSession.loop  s0     	02DQR	
 	
 	
 	
 zr   c                     | j         S )zTimeout for the session.)r   r  s    r   r~   zClientSession.timeout!  r  r   c                     | j         S )z*The default headers of the client session.)r   r  s    r   rr   zClientSession.headers&       $$r   c                     | j         S )z2Headers for which autogeneration should be skipped)r   r  s    r   rs   zClientSession.skip_auto_headers+  s     &&r   c                     | j         S )z2An object that represents HTTP Basic Authorization)r   r  s    r   rt   zClientSession.auth0  s     !!r   c                     | j         S )zJson serializer callable)r   r  s    r   r   zClientSession.json_serialize5  s     ##r   c                     | j         S )z-Should connector be closed on session closing)r   r  s    r   r   zClientSession.connector_owner:  r  r   c                     | j         S )zGShould `ClientResponse.raise_for_status()` be called for each response.)r   r  s    r   rz   zClientSession.raise_for_status?  s    
 %%r   c                     | j         S )z7Should the body response be automatically decompressed.)r   r  s    r   r   zClientSession.auto_decompressF  r  r   c                     | 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.
        )r   r  s    r   r   zClientSession.trust_envK  s     r   c                     | j         S )z7A list of TraceConfig instances used for client tracing)r   r  s    r   r   zClientSession.trace_configsU  s     ""r   c                     d| _         dS )zwDetach connector from session without closing the former.

        Session is switched to closed state anyway.
        Nr  r  s    r   detachzClientSession.detachZ  s    
 r   c                      t          d          )NzUse async with instead)	TypeErrorr  s    r   	__enter__zClientSession.__enter__a  s    0111r   exc_typeexc_valexc_tbc                     d S r   r   r   r  r  r  s       r   __exit__zClientSession.__exit__d  s	     	r   c                 
   K   | S r   r   r  s    r   
__aenter__zClientSession.__aenter__m  s      r   c                 >   K   |                                   d {V  d S r   )rL  r  s       r   	__aexit__zClientSession.__aexit__p  s.       jjllr   r   r   N)r   r  )r   rd   )mr   r   r   __doc__r   r  r   r   r   StackSummaryr   r   rI   rp   r(  r@   rA   rF   r   HttpVersion11rT   rc   r   AbstractEventLoopr`   ra   rQ   r   r   r_   r   rW   r"   r   r   r   r   r   rN   objectre   r   r^   r   _CharsetResolverr   r  rO   r   r
  r   r  r   version_infor   rk   rm   rf   r   r"  rb   bytesrg   rB   r   r  r   rX  rG   r  r  r9  rY  r  r  r  r  r  r  rL  propertyr  r   r   r   r   r   setterr   r~   rr   r   r   rs   rt   r   r   rz   r   r   r   r  r  rK  r   r  r   r  __classcell__)r  s   @r   rd   rd      s        99I	
 	
 	
   ED ;?x	 67>>>*.J'... (,P, .248*.*.$(*.59$(&*j-:/=;R#126 $ 08(,08 $%)59!!"6J6JAP, P, P,8$P, M*	P,
 w01P, ,'P, ,'P, !P, Y'P, $HSM2P, y!P, $P, M*P, ^,P,   78P,  !P," ./#P,$ %P,&  (N+Yt_<==
'P,, E9,--P,. uo/P,0 v},-1P,2 3P,4 5P,6 #7P,8  [ 129P,: ;P,< =P,> ?P,@ $4AP,B 
CP, P, P, P,d
tO4 
 
 
 
 
  
+	+C 	+c 	+d 	+ 	+ 	+ 	+ 	+ 	+ (0 	7 	7 	7D 	7 	7 	7 	7 7""}"	+	+ 	+ _-		+
 &	+ 	+ 	+ 	+ 	+	P	P$,	P8;	P%	P 	P 	P 	P,X ,# , , , , *.*.59$( $+/"& #$(*.3;%)'+,048)-049=&**.'+(,EH H HH H
 H H H ,'H ,'H $HSM2H y!H H H T4(H $H  !H"  $.!19T?!BCC
#H( )H* !+H, Y'-H. }i/0/H0 TN1H2 e_3H4 j)5H6 :t[017H8 "#9H:  -;H< $GCH$56=H> sm?H@ "$AHB  }CHD !EHF 
GH H H H\ m#%5=+/%)$( $*.$(*.48%)'+,0)-04+14
 4
 4
4
 	4

 C=4
 	124
 "%4
 4
 4
 E?4
 y!4
 4
 4
 ,'4
 !4
  Y'!4
" :t[01#4
$ TN%4
& e_'4
( j))4
* "#+4
,  --4
. /4
0 14
2 
$34
 4
 4
 4
t m#%5=+/%)$( $*.$(*.48%)'+,0)-04+1W W WW 	W
 C=W 	12W "%W W W E?W y!W W W ,'W !W  Y'!W" :t[01#W$ TN%W& e_'W( j))W* "#+W,  --W. /W0 1W2 
!3W W W Wr(> CU      7""}"	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+	+	+ _-	+ &		+ 	+ 	+ 	+ 	+ =A	 	 		59	LO	%	 	 	 	 =A	 	 		59	LO	%	 	 	 	 =B	 	 		59	MP	%	 	 	 	 15	 	 		*-	@C	%	 	 	 	 15	 	 		*-	@C	%	 	 	 	 15	 	 		*-	@C	%	 	 	 		h 	# 	:R 	 	 	 	# # # # A A A A XA 8M2    X  -       X  sCx    X *d * * * X*  ) ) ) ) ) ! ) g/    X     X % % % X% '9T? ' ' ' X' "hy) " " " X" $ $ $ $ X$ % % % % X% &	tX~.	$?@@	A& & & X& % % % % X% 4    X #tK0 # # # X#   2 2 2 24./ -( '	
 
      4./ -( '	
 
       r   rd   c                       e Zd ZdZdeddef         ddfdZddZd	ed
eddfdZ	ddZ
deedef         fdZdeedef         fdZdefdZdeee                  dee         dee         ddfdZdS )_BaseRequestContextManager)_coro_respcoroasyncio.Future[Any]Nr   c                     || _         d S r   )r  )r   r  s     r   r   z#_BaseRequestContextManager.__init__}  s    GK


r   argc                 6    | j                             |          S r   )r  rJ  )r   r  s     r   rJ  z_BaseRequestContextManager.send  s    zs###r   rO  r  c                 &     | j         j        |i |S r   )r  throw)r   rO  r  s      r   r  z _BaseRequestContextManager.throw  s    tz0000r   c                 4    | j                                         S r   )r  rL  r  s    r   rL  z _BaseRequestContextManager.close  s    z!!!r   c                 8    | j                                         }|S r   )r  	__await__)r   rets     r   r  z$_BaseRequestContextManager.__await__  s    j""$$
r   c                 *    |                                  S r   )r  r  s    r   __iter__z#_BaseRequestContextManager.__iter__  s    ~~r   c                 h   K   | j          d {V | _        | j                                         d {V S r   )r  r  r   r  s    r   r   z%_BaseRequestContextManager.__aenter__  sG      %)Z//////
Z**,,,,,,,,,r   r  rv  tbc                 N   K   | j                             |||           d {V  d S r   )r  r  r   r  rv  r!  s       r   r  z$_BaseRequestContextManager.__aexit__  s:       j""8S"55555555555r   )r  Nr   r  r  )r   r   r   	__slots__r	   r   r   rJ  r   r  rL  r   r  r  r   r   r   rK  r   r  r   r   r   r  r  y  sX       "ILY'<dH'LM LRV L L L L$ $ $ $13 1# 12G 1 1 1 1" " " "9S$%89     )Cx$78        -( - - - -64./6 m$6 ]#	6
 
6 6 6 6 6 6r   r  c                       e Zd ZdZdeddef         deddfdZdefdZd	e	e
e                  d
e	e         de	e         ddfdZdS )_SessionRequestContextManagerr  r  _sessionr  r  Nr0  r   c                 0    || _         d | _        || _        d S r   r'  )r   r  r0  s      r   r   z&_SessionRequestContextManager.__init__  s    
 
/3
r   c                    K   	 | j          d {V | _        | j        S # t          $ r! | j                                         d {V   w xY wr   )r  r  rK  r(  rL  r  s    r   r   z(_SessionRequestContextManager.__aenter__  sv      	#z))))))DJ
 :	  	 	 	-%%'''''''''	s	    +Ar  rv  r!  c                    K   | j         J | j                                          | j                                         d {V  d S r   )r  rL  r(  r#  s       r   r  z'_SessionRequestContextManager.__aexit__  sV       z%%%
m!!###########r   )r   r   r   r$  r	   rA   rd   r   r   r   r   rK  r   r  r   r   r   r&  r&    s        .I -t^CD    
	       .    $4./$ m$$ ]#	$
 
$ $ $ $ $ $r   r&  )r   r   r   r  r  r   r   r   r  r   c                    d S r   r   )r  r  r   r   r   r  s         r   rf   rf     s	     ),r   c          	          d}|d}t          |d          }t          ||                    dd          ||                    dt                    ||          }t	           |j        | |fi ||          S )aB  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
        >>> async with aiohttp.request('GET', 'http://python.org/') as resp:
        ...    print(resp)
        ...    data = await resp.read()
        <ClientResponse(https://www.python.org/) [200 OK]>
        FNT)r   force_closerq   r~   )r   rq   r   r~   r   r   )rK   rd   r[  rT   r&  r  )r  r  r   r   r   r  r   r0  s           r   rf   rf     s    Z  "O$$DAAAIJJy$//JJy(33+
 
 
 -GVS33F33
 
 	
r   )r  r   r  r  rp   r  r   r   r   
contextlibr   typesr   typingr   r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   	multidictr   r   r   r   yarlr   r  r   r   r    _websocket.readerr!   abcr"   client_exceptionsr#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   client_reqrepr@   rA   rB   rC   rD   	client_wsrE   rF   rG   r   rH   rI   rJ   rK   rL   	cookiejarrM   helpersrN   rO   rP   rQ   rR   rS   rT   rU   rV   rW   rX   rY   http_websocketrZ   r[   r\   tracingr]   r^   typedefsr_   r`   ra   rb   rc   __all__r   rg   r
  rk   rm   sre   r   r   r   r?  r   r  r   r	  rd   r  r  r  r&  r  r  rf   r   r   r   <module>r@     s          				 



                                                          ,  B B B B B B B B B B B B       ! ! ! ! ! ! ! ! ! ! 1 1 1 1 1 1 " " " " " "                                                             >                      
              !          	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 H G G G G G G G G G G G F F F F F F F F F F ' ' ' ' ' ' ' ' N N N N N N N N N N N N N N0f  Jw=% % % % %iu % % % %8 T$d333       43, )6FQS(T(T(T}% T T T YSSSTT 7:~/FGG^U3S89 R R R R R R R Rj$!6 !6 !6 !6 !63X+=!>@Q !6 !6 !6H 4NC 56MN $ $ $ $ $ $ $ $B w=  $1-148, , ,,, 	,
 M*, w01, ), 
', , , , , ,   $1-148>
 >
 >
>
>
 	>

 M*>
 w01>
 >
 
'>
 >
 >
 >
 >
 >
r   