id1 UdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m 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,dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@dd lAmBZBmCZCmDZDmEZEmFZFdd lGmHZHddlImJZJmKZKmLZLmMZMddlNmOZOddlPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYddl)mZZZm[Z[m\Z\m]Z]ddl^m_Z_m`Z`maZambZbddlcmdZdddlemfZfmgZgddlhmiZimjZjmkZkmlZlmmZmdZn ddlompZpn #eq$rerZpYnwxYwejsdddGddZtetdZueietevd<edZwGd d!ZxGd"d#eeeewfeewZyGd$d%eyeCZzGd&d'eyeHZ{Gd(d)Z|dddddddd*ddd+ddddeXde)j}dddd,d-e~d.emd/eee~e~fd0ed1ed2eeld3eee~d4eeSd5ed6ed7ee~d8eed9ed:eed;edeeterfd?eekd@e[dAeeJdBeedCeejdDe|f0dEZdS)FzHTTP Client for asyncio.N)suppress)SimpleNamespace TracebackType)Any AwaitableCallable Coroutine FrozenSet GeneratorGenericIterableListMappingOptionalSetTupleTypeTypeVarUnion) CIMultiDict MultiDictMultiDictProxyistr)URL)hdrshttppayload)AbstractCookieJar)ClientConnectionErrorClientConnectorCertificateErrorClientConnectorErrorClientConnectorSSLError ClientErrorClientHttpProxyError ClientOSErrorClientPayloadErrorClientProxyConnectionErrorClientResponseErrorClientSSLErrorContentTypeError InvalidURLServerConnectionErrorServerDisconnectedErrorServerFingerprintMismatchServerTimeoutErrorTooManyRedirectsWSServerHandshakeError) ClientRequestClientResponse Fingerprint RequestInfo_merge_ssl_params)ClientWebSocketResponse) BaseConnectorNamedPipeConnector TCPConnector UnixConnector) CookieJar) DEBUGPY_36 BasicAuth TimeoutHandle ceil_timeoutget_env_proxy_for_urlget_running_loopsentinelstrip_auth_from_url)WS_KEY HttpVersionWebSocketReaderWebSocketWriter)WSHandshakeError WSMessage ws_ext_gen ws_ext_parse)FlowControlDataQueue)Trace TraceConfig)Final JSONEncoder LooseCookies LooseHeadersStrOrURL)r r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r9r;r<r:r8 ClientSession ClientTimeoutrequest) SSLContextT) auto_attribsfrozenslotscxeZdZUdZeeed<dZeeed<dZeeed<dZ eeed<dS)rXNtotalconnect sock_read sock_connect) __name__ __module__ __qualname__r_rfloat__annotations__r`rarbC/opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/client.pyrXrXsb!E8E?!!!#GXe_###!%Ix%%%$(L(5/(((((rirXi,r_DEFAULT_TIMEOUT_RetTypec7 eZdZdZegdZdZdZ dwddddddej e e e e jdddededddddddeed eed eejd eed eed eeedeededee dee dee dedeedededee e!fdee dee!e"fdedededee#e$de%ddf0d Z&d!edddfd"Z'e(r d#ed$e)ddffd% Z*e+fd&e)ddfd'Z,d(ed)ed*e)dd+fd,Z-d-ede.fd.Z/ddddddddd/dddddddedddddddd0d(ed-ed1ee0eefd2e)d3e)d eed eed eeedeed4ed5e%d6eed7eed8edeed9ed:eed;eedee"e!fdee2d?eee2ee3fd@eedAee4dee%de f6dBZ5e6j7dCdDddddddddddddddddEdFdGd)ed(edHeede dIee dJedKedLee deedMeed1ee0eefd eed:eed;eed?ee2ede3fdee2d@eed6e%dNe%ddOf,dPZ8e6j7dCdDddddddddddddddddEdFdGd)ed(edHeede dIee dJedKedLee deedMeed1ee0eefd eed:eed;eed?ee2ede3fdee2d@eed6e%dNe%de f,dQZ9d eeddRfdSZ:ddTd)ed4ed*e)dd+fdUZ;ddTd)ed4ed*e)dd+fdVZddXd)ed2e)d*e)dd+fdZZ?ddXd)ed2e)d*e)dd+fd[Z@d)ed*e)dd+fd\ZAdxd]ZBeCdefd^ZDeCdeefd_ZEeCdefd`ZFeCdeGe%e%ffdaZHeCdefdbZIeIjJd$eddfdcZIeCdejfddZKeCde"fdeZLeCdydfZMeCdeNeOfdgZPeCdeefdhZQeCdefdiZReCdefdjZSeCdeeeTe geUdfffdkZVeCdefdlZWeCdefdmZXeCde#e$fdnZYdxdoZZdxdpZ[dqeee\dree\dsee]ddfdtZ^dzduZ_dqeee\dree\dsee]ddfdvZ`xZaS){rWz/First-class interface for making HTTP requests.) _base_url_source_traceback _connectorrequote_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_bufsizeNTF) connectorloopcookiesheadersskip_auto_headersauthjson_serialize request_classresponse_classws_response_classversion cookie_jarconnector_ownerraise_for_status read_timeout conn_timeouttimeoutauto_decompress trust_envrr trace_configs read_bufsizebase_urlrrrrrrrrrrrrrrrrrrrrrrrreturnc6| ||j}t|}|t|tr||_nt||_|t |}|j|urt d||_|r+tj tj d|_ | t|} | |_||j|||_||_||_| |_||_|t*urt,|_|t*urz)ClientSession.__init__..0s(/S/SAQ/S/S/S/S/S/Sri),rsrD isinstancerror; RuntimeError get_debug traceback extract_stacksys _getframerpr=rtupdate_cookiesrqrurvrwrxrErlrzwarningswarnDeprecationWarningattrevolve ValueErrorr{r|r}ryrrr~ frozensetrrrrrfreeze)selfrrrrrrrrrrrrrrrrrrrrrrrr real_headers trace_configs rj__init__zClientSession.__init__s6 <$ %%  z(C88 ,4DNN ]]DN  $$///I ?$ & &QRR R >>   O%.%  (&//S/SAR/S/S/S&S&SD # #&/kkD #+-"3+1r / " "L    ! ! ! ! " "riclscntjd|jtddS)Nz6Inheritance class {} from ClientSession is discouragedrr)rrformatrcr)rs rj__init_subclass__zClientSession.__init_subclass__<s?  #VCL11        rinamevalc||jvr/tjd|tdt ||dS)Nz8Setting custom ClientSession.{} attribute is discouragedrr)ATTRSrrrrsuper __setattr__)rrr __class__s rjrzClientSession.__setattr__Fsa4:%% %%+VD\\&  GG  c * * * * *ri _warningsc|jsWtrd|i}ni}|jd|tfi||dd}|j |j|d<|j|dSdS)NsourcezUnclosed client session zUnclosed client session)client_sessionmessagesource_traceback)closedr?rResourceWarningrprscall_exception_handler)rrkwargscontexts rj__del__zClientSession.__del__Ps{ 7 "D) IN3433_  HN   *.:STTG%1.2.D*+ J - -g 6 6 6 6 6 7 7rimethodurlr_RequestContextManagerc :t|j||fi|S)zPerform HTTP request.)r_request)rrrrs rjrYzClientSession.request^s(&mdmFC&J&J6&J&JKKKri str_or_urlcft|}|j|S|j|Sr)rrojoin)rrrs rj _build_urlzClientSession._build_urlds2*oo > !J>&&s++ +ri )paramsdatajsonrrrrallow_redirects max_redirectscompresschunked expect100rread_until_eofproxy proxy_authr verify_ssl fingerprint ssl_contextssl proxy_headerstrace_request_ctxrrrrrrrrrrrrrrrrrrcKjrtdt||||}||td|t j|j}t| ts| tj dtd}g}j } |} |} |}n"#t$r}t||d}~wwxYwt!j} |'|D]$}!| t'|!%|3 t)|}n"#t$r}t||d}~wwxYw|t*urj}"n(t|t.st/|}"n|}"t1j|"j}#|#}$|j}fdjD}%|%D]2}&|&||||d{V3|# }' |'5 tC|\}}(| r|(rtd | |(} | j"} || tFj$|vrtd j%&|})|OtO}*|*(||*&|}+|+r|))|+|t)|}nEj*r>tWtX5t[|\}}dddn #1swxYwY.||||| ||)| || | |jj/|||'|||% }, ta|"j14d{Vj21|,|%|" d{V}-dddd{Vn#1d{VswxYwYn:#tfj4$r(}.tkd 6||.d}.~.wwxYw|-j78|'|9dk|j:|"j;| |,<|-d{V}/ |/|-d{Vn##tz$r|/>wxYwn##tz$r|->wxYwnM#t~$rt$r6}.|.jAt|.tfj4rt|.jC|.d}.~.wwxYwj%(|/jD|/jE|/jFdvrf| rc|%D]3}&|&G|||||/d{V4|dz }|H|/| rB|| kr<|/>t|djJt||/jFdkr|/jLtFjMks|/jFdvra|/jLtFjNkrLtFjO}d}|PtFjQr|RtFjQ|/jSPtFjTp#|/jSPtFjU}0|0n|/V t)|0jW }1n"#t$r}t|0|d}~wwxYw|1jX}2|2dvr#|/>td|2s|Y|1}1|Z|1Zkr"d} |RtFj$d|1}d}|/V dddn #1swxYwY|j[}|r|/\|$;|/j] |/j]^|$j_n|$_t||/_`|%D]3}&|&a|||||/d{V4|/S#tz$rh}|#>|$r|$_d}$|%D]3}&|&b|||||d{V4d}~wwxYw)NzSession is closedz9data and json parameters can not be used at the same time)dumpszChunk size is deprecated #1615rrkc Zg|]'}t||(S))r)rPtrace_config_ctx)rrrrs rj z*ClientSession._request..sP    --@Q-RR     riTz>>&4&C&CC&H&H &:',,[999( #E K%k22KK0Ec0J0J-E:KKKKKKKKKKKKKKK--% '*6! +! '!) '"+!Z'+';##-# $&3%+.C2 ##/ 0D#E#E)-)@)@ #FL*A**$$$$$$D #/###0>EEcJJ"##M55#%+\\^^v%='5(,(=%1%;%1 6@ "),$#7#7#7#7#7#7D&&*jj&6&6 6 6 6 6 6 6 6 6#0&&& $ %&!7 -""" JJLLL!" !7'"@@@9,CAU1V1V,!+SX6C?@ $33DL$(KKK{&???O?%+E"'"="= &(8(8(@(@'4##"Q t,,,(Y--G-G JJLLL"2 ' 7w## !K3..4;$.3P3P K:55$+:W:W%)]F#'D&{{4+>??A ' D,? @ @ @ $ 0 0 ? ?!4>> JJLLL",-Q"R"RR!'>),*)=)=J::<<:+<+<+>+>>>#'D#KK(:DAAA(!%  Uj j j j j j j j j j j j j j j Z '#'#9  (%%'''!?.O00????MMOOO!'NNDM  ,,C,,V44gtK    HHJJJ    22C,,V44gq  sPC C9$C44C9<E E+E&&E+<b >C-_+M > _ M _M 7_ O,$$OO, O$ $O,'O$ (O,+_,P#;#PP##A_(SR S SSS( S$$S('_(T2<1T--T22F2_%[=<_= \\\B/_ b _b _B*b c<A#c77c<rhg$@ri@r protocolsrreceive_timeout autocloseautoping heartbeatrr#rrrrrrrrrr max_msg_sizer=r>r?r@rAr#rB_WSRequestContextManagercpt|||||||||| | | | | ||||||||S)zInitiate websocket connection.r<)rC _ws_connect)rrrr=rr>r?r@rArr#rrrrrrrrrrrBs rj ws_connectzClientSession.ws_connectsm4(   # /#!#%%''+!)+      ricK| t}nt| }tjdtjdtjdi}|D]\}}|||tjtj d}| |tj <|r"d ||tj<| | |tj<|rt!|}||tj<t%||||}|||| |d| | ||| d{V} |jd kr(t+|j|jd |j|j |jtjd dkr(t+|j|jd |j|j |jtjd dkr(t+|j|jd|j|j |jtjd }tjt9j|t<z }||kr(t+|j|jd|j|j d}|rTtj|jvrAd|jtj dD} | D] }!|!|vr|!}n d}"|r|jtj}#|#rZ tC|#\}}"nJ#tD$r9}$t+|j|j|$j#d|j|j |$d}$~$wwxYwd}d}"|j$}%|%j%}&|%j&}'tO|&d|j(}(|&)tU|(||(tW|&|'d||"})|,|(|)||||||j(||||" S#tZ$r|.wxYw)N websocketupgrade13,)rF)rrrrrrrrezInvalid response status)rrrrzInvalid upgrade headerzInvalid connection headerzInvalid challenge responsec6g|]}|Srh)strip)rprotos rjrz-ClientSession._ws_connect..Ds0"""KKMM"""rirrrT)use_maskr notakeover)r>rArclient_notakeover)/rrUPGRADE CONNECTIONSEC_WEBSOCKET_VERSIONitems setdefaultbase64 b64encodeosurandomdecodeSEC_WEBSOCKET_KEYrSEC_WEBSOCKET_PROTOCOLORIGINrMSEC_WEBSOCKET_EXTENSIONSr7rYrr2rr+rrlowerSEC_WEBSOCKET_ACCEPThashlibsha1rGdigestsplitrNrKrr$r  transportrOrs set_parserrIrJrrr)*rrrr=rr>r?r@rArr#rrrrrrrrrrrBrdefault_headerskeyvaluesec_keyextstrr9r_keymatchr resp_protocolsrPrR compress_hdrsr8r7 conn_protorhreaderwriters* rjrEzClientSession._ws_connects 4 ?-8]]LL&w//L L+ OY  &  *//11 0 0JC  # #C / / / /"2:b>>22/6~~/?/? T+,  L8;8K8KL4 5  (.L %  A222F:@L6 7ZkJJ\\    !'"         k {c!!,%L5; L | b117799[HH,%L4; L |44::<< II,%L7; L L$$T%>CCE$W\'F2B%C%C%J%J%L%LMMTTVVE~~,%L8; L H T8DLHH""!%d.I!J!P!PQT!U!U""" ,E ))#(* J ' $ 0 01N O O  ' #/;M/J/J,**+###4 - L$'HQK#';$(L  # ## !H!&J?DJI6JE 777F  ! !/&,"G"G P P P$!% F** /#!",+        JJLLL  s2H Q/NQ O 4OOA+Q Q6CIMultiDict[str]cBt|j}|rt|ttfst|}t }|D]:\}}||vr||| |||<||;|S)z3Add default headers and transform it to CIMultiDict)rr~rrrrrWr)rrresult added_namesrkrls rjrzClientSession._prepare_headerssT233  )g 'BCC /%g..$'EEK%mmoo ) ) U+%%JJsE****"'F3KOOC(((( ri)rc Rt|jtj|fd|i|S)zPerform HTTP GET request.r)rrrrrrrrs rjrzClientSession.gets7& DM$- X Xo XQW X X   ric Rt|jtj|fd|i|S)zPerform HTTP OPTIONS request.r)rrr METH_OPTIONSr{s rjoptionszClientSession.optionssD& DM!3  8G KQ     ric Rt|jtj|fd|i|S)zPerform HTTP HEAD request.r)rrrrr{s rjheadzClientSession.headsC& DM  5D HN     ri)rc Rt|jtj|fd|i|S)zPerform HTTP POST request.r)rrrrrrrrs rjpostzClientSession.posts6& DM$.# C CD CF C C   ric Rt|jtj|fd|i|S)zPerform HTTP PUT request.r)rrrMETH_PUTrs rjputzClientSession.puts6& DM$- B B4 B6 B B   ric Rt|jtj|fd|i|S)zPerform HTTP PATCH request.r)rrr METH_PATCHrs rjpatchzClientSession.patchs6& DM$/3 D DT DV D D   ric Nt|jtj|fi|S)zPerform HTTP DELETE request.)rrr METH_DELETE)rrrs rjdeletezClientSession.deletes)%mdmD4Dc&T&TV&T&TUUUricK|js6|j&|jr|jd{Vd|_dSdS)zMClose underlying connector. Release all acquired resources. N)rrqrurrs rjrzClientSession.closes] { #*t/D*o++---------"DOOO # #ric,|jdup |jjS)z@Is client session closed. A readonly property. N)rqrrs rjrzClientSession.closeds $&@$/*@@ric|jS)z(Connector instance used for the session.rqrs rjrzClientSession.connectors ric|jS)zThe session cookies.)rtrs rjrzClientSession.cookie_jars ric|jS)z"The session HTTP protocol version.)rwrs rjrzClientSession.version }ric|jS))Do URL requoting on redirection handling.)ryrs rjrrz"ClientSession.requote_redirect_urls ))ricLtjdtd||_dS)rz=session.requote_redirect_url modification is deprecated #2778rrN)rrrry)rrs rjrrz"ClientSession.requote_redirect_urls6  N     &)"""ricHtjdtd|jS)zSession's loop.z"client.loop property is deprecatedrr)rrrrsrs rjrzClientSession.loops0  02DQR    zric|jS)zTimeout for the session.)rzrs rjrzClientSession.timeoutrric|jS)z*The default headers of the client session.)r~rs rjrzClientSession.headers  $$ric|jS)z2Headers for which autogeneration should be skipped)rrs rjrzClientSession.skip_auto_headerss &&ric|jS)z2An object that represents HTTP Basic Authorization)rvrs rjrzClientSession.auths !!ric|jS)zJson serializer callable)rxrs rjrzClientSession.json_serializes ##ric|jS)z-Should connector be closed on session closing)rurs rjrzClientSession.connector_ownerrric|jS)zGShould `ClientResponse.raise_for_status()` be called for each response.)r{rs rjrzClientSession.raise_for_status#s %%ric|jS)z7Should the body response be automatically decompressed.)r|rs rjrzClientSession.auto_decompress*rric|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. )r}rs rjrzClientSession.trust_env/s ric|jS)z7A list of TraceConfig instances used for client tracing)rrs rjrzClientSession.trace_configs9s ""ricd|_dS)zwDetach connector from session without closing the former. Session is switched to closed state anyway. Nrrs rjdetachzClientSession.detach>s ric td)NzUse async with instead) TypeErrorrs rj __enter__zClientSession.__enter__Es0111riexc_typeexc_valexc_tbcdSrrhrrrrs rj__exit__zClientSession.__exit__Hs  ric K|Srrhrs rj __aenter__zClientSession.__aenter__Qs  ric>K|d{VdSr)rrs rj __aexit__zClientSession.__aexit__Ts. jjllrirrN)rrv)rrW)brcrdre__doc__rrrprqrrr3r4r8r HttpVersion11rErrVr9r AbstractEventLooprTrUr strr@rSrrHrrrrfobjectrXrrQintrrr>rrrrrYrrrbytesrZr5rrrrrFrErrr~rrrrrrpropertyrrrrrrrsetterrrrr rrrrrrrrrrrrrrrrrr __classcell__)rs@rjrWrWs 99 I     E6J(,u".248*.*.59$(&*j-:/=;R#126 $!&-5(,08 $%)59!3u"u"u"8$u"M* u" w01 u" ,' u",'u"$HSM2u"y!u"$u"M*u"^,u" 78u"u"./u" !u""#u"$E6M*%u"&uo'u"(v},-)u"*+u",-u".#/u"0 [ 121u"23u"4 5u"u"u"u"n tO4      + +C +c +d + + + + + +(0 7 7 7D 7 7 7 7LL (L47L !LLLL ,X,#,,,,/3*.*.59$( $"&"&+/#$(*.08%)'+,0>B047;&*9sssss c*+ s  ss,'s,'s$HSM2sy!sss3-s$s !s"#4.#s$%s&!'s(Y')s*}f,-+s,TN-s.e_/s0j)1s2eJk9: ;3s4 -5s6$O47s8sm9s: ;ssssr m#%+/%)$( $.2*.$(*.:>%)'+,004+/2 2 2 2  2 C= 2  2 "%2 2 2 E?2 y!2  2 c*+2 ,'2 !2 Y'!2 ":tT;6 7#2 $TN%2 &e_'2 (j))2 * -+2 ,-2 ./2 0 $12 2 2 2 pm#%+/%)$( $.2*.$(*.:>%)'+,004+/nnn n n C= n  n"%nnnE?ny!n nc*+n,'n!n Y'!n":tT;6 7#n$TN%n&e_'n(j))n* -+n,-n./n0 !1nnnn`(>CU"9=    15 HK !    9=    15 HK !    9>    15 IL !    -1    &) >> import aiohttp >>> resp = await aiohttp.request('GET', 'http://python.org/') >>> resp >>> data = await resp.read() FNT)r force_close)rrrrrr)rrrrrrrrrrrrrrrr)r;rWrr)rrrrrrrrrrrrrrrrrrrrrrrrrs rjrYrYs|O d===  ' G )  /+'-)!%%   ( +  ri)rr rYrdrr[rrr contextlibrtypesrrtypingrrrr r r r r rrrrrrrrr multidictrrrryarlrrrrrabcrclient_exceptionsr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2 client_reqrepr3r4r5r6r7 client_wsr8rr9r:r;r< cookiejarr=helpersr>r?r@rArBrCrDrErFrGrHrIrJhttp_websocketrKrLrMrNstreamsrOtracingrPrQtypedefsrRrSrTrUrV__all__rrZ ImportErrorrsrXrlrgrmrWrrrCrrrrrrrYrhrirjrs  00000000& BBBBBBBBBBBB!!!!!!!!!!""""""*JIIIII !                       HGGGGGGGGGGGQQQQQQQQQQQQ))))))''''''''NNNNNNNNNNNNNN% PJJJT$d333)))))))43)*)6 F(C(C(C}%CCC 7:  vvvvvvvvr3X+=!>@Q87G" ! ! ! ! !9:QR ! ! !$$$$$$$$J+/&*15 $ ""'+ $&*,4&*-)-"&041bbb b b WS#X& ' b  b  bl #b  .b 9 bbbsmbd^bbtnb !b" H #b$#%b&=&( )'b(l #)b*+b, &-b.3-/b0 7, -1b2#3bbbbbbsD D*)D*