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_urlrrrrrrrrrrrrrrrrrrrrrrrreturnc| ||j}t|}|t|tr||_n@t||_|j|jks Jd|t |}|j|urtd||_|r+tj tj d|_ | t|} | |_||j|||_||_||_| |_||_|t,urt.|_|t,urz)ClientSession.__init__..0s(/S/SAQ/S/S/S/S/S/Sri)-rsrD isinstancerrooriginr; 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%%''4>999C:99  $$///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_urlct|}|j|S|s|jdsJ|j|S)N/)rro is_absolutepath startswithjoin)rrrs rj _build_urlzClientSession._build_urlds[*oo > !J(( ESX-@-@-E-E E E E>&&s++ +ri )paramsdatajsonrrrrallow_redirects max_redirectscompresschunked expect100rread_until_eofproxy proxy_authr verify_ssl fingerprint ssl_contextssl proxy_headerstrace_request_ctxrrrrrrrrrrrrrrrrrrc4Kjrtdt||||}||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{Vj2Jj21|,|%|" d{V}-dddd{Vn#1d{VswxYwYn:#tfj4$r(}.tkd 6||.d}.~.wwxYw|-j7J|-j8J|-j89|'|:dk|j;|"j<| |,=|-d{V}/ |/|-d{Vn##t|$r|/?wxYwn##t|$r|-?wxYwnM#t$rt$r6}.|.jBt|.tfj4rt|.jD|.d}.~.wwxYwj%(|/jE|/jF|/jGdvrf| rc|%D]3}&|&H|||||/d{V4|dz }|I|/| rB|| kr<|/?t|djKt||/jGdkr|/jMtFjNks|/jGdvra|/jMtFjOkrLtFjP}d}|QtFjRr|StFjR|/jTQtFjUp#|/jTQtFjV}0|0n|/W t)|0jX }1n"#t$r}t|0|d}~wwxYw|1jY}2|2dvr#|/?td|2s|Z|1}1|[|1[kr"d} |StFj$d|1}d}|/W dddn #1swxYwY|j\}|r|/]|$;|/j^ |/j^_|$j`n|$`t||/_a|%D]3}&|&b|||||/d{V4|/S#t|$rh}|#?|$r|$`d}$|%D]3}&|&c|||||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"##  >555=444M55#%+\\^^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-_2+M > _2 M _2M 7_2 O5$-O#O5# O- -O50O- 1O54_25P,#P''P,,A_2SR;:S; SST S??T_2U 1UU  F2_2\_2 \7"\22\77B/_2& b%2_66b%9_6:B*b%% d/A#ddrhg$@ri@r protocolsrreceive_timeout autocloseautoping heartbeatrrrrrrrrrrrr max_msg_sizerBrCrDrErFrrG_WSRequestContextManagercpt|||||||||| | | | | ||||||||S)zInitiate websocket connection.rA)rH _ws_connect)rrrrBrrCrDrErFrrrrrrrrrrrrrGs rj ws_connectzClientSession.ws_connectsm4(   # /#!#%%''+!)+      ric K| 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%}&|&J|%j&}'|'JtO|&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)rCrFrclient_notakeover)/rrUPGRADE CONNECTIONSEC_WEBSOCKET_VERSIONitems setdefaultbase64 b64encodeosurandomdecodeSEC_WEBSOCKET_KEYrSEC_WEBSOCKET_PROTOCOLORIGINrMSEC_WEBSOCKET_EXTENSIONSr7rYrr2rr0rr"lowerSEC_WEBSOCKET_ACCEPThashlibsha1rGdigestsplitrNrKrr)rrrOrs set_parserrIrJrrr)*rrrrBrrCrDrErFrrrrrrrrrrrrrGrdefault_headerskeyvaluesec_keyextstrr>r_keymatchrresp_protocolsrUrW compress_hdrsr=r< conn_protorreaderwriters* rjrJzClientSession._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?D###J)))I(((6JE 777F  ! !/&,"G"G P P P$!% F** /#!",+        JJLLL  s2H Q"/NQ" O 4OOA7Q"" RCIMultiDict[str]cBt|j}|rt|ttfst|}t }|D]:\}}||vr||| |||<||;|S)z3Add default headers and transform it to CIMultiDict)rr~rrrrr\r)rrresult added_namesrorps rjrzClientSession._prepare_headerssT233  )g 'BCC /%g..$'EEK%mmoo ) ) U+%%JJsE****"'F3KOOC(((( ri)rc Rt|jtj|fd|i|S)zPerform HTTP GET request.r)rrrr!rrrrs rjr"zClientSession.gets7& DM$- X Xo XQW X X   ric Rt|jtj|fd|i|S)zPerform HTTP OPTIONS request.r)rrr METH_OPTIONSrs rjoptionszClientSession.optionssD& DM!3  8G KQ     ric Rt|jtj|fd|i|S)zPerform HTTP HEAD request.r)rrrrrs rjheadzClientSession.headsC& DM  5D HN     ri)rc Rt|jtj|fd|i|S)zPerform HTTP POST request.r)rrrr rrrrs 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)rrz)rrW)brcrdre__doc__rrrprqrrr3r4r8r HttpVersion11rErrVr9rAbstractEventLooprTrUr strr@rSrrHrrrrfobjectrXrrQintrrr>rrrrrYrrrbytesrZr5rrrr!rKrJrr"rrrrrrrpropertyrrrrrrrsetterrrrr 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)rrr^rirr`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 ImportErrorrsrXrlrgrmrWrrrHrrrrrrrYrhrirjrs  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*