idmFddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z ddl m Z mZmZddlmZmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddl m!Z!m"Z"m#Z#m$Z$ddl%m&Z&dd l'm(Z(m)Z)m*Z*m+Z+m,Z,dd l-m.Z.dd l/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5dd l6m7Z7dd l)m8Z8m9Z9m:Z:m;Z;mZ>m?Z?ddl*m@Z@mAZAmBZBmCZCddlDmEZEddlFmGZGddlHmIZImJZJmKZKmLZLmMZM ddlNZNddlNmOZOn#eP$rdZNeQZOYnwxYw ddlRZSn#eP$rddlTZSYnwxYwdZUerddlVmWZWddlXmYZYddlZm[Z[ej\dZ]ej^dddGddZ_ej^dddGddZ`GddZaeNeNjOebeaecdfZdn ecdZdd ed!ebeadfd"eebd#ed!d$eeed%ed!ebeadff d&Zfej^ddd'Gd(d)Zgd*ehd+ehd%ebfd,ZiGd-d.ZjGd/d0e;ZkdS)1N)md5sha1sha256) CookieErrorMorsel SimpleCookie)MappingProxyType TracebackType) TYPE_CHECKINGAnyDictIterableListMappingOptionalTupleTypeUnioncast) CIMultiDictCIMultiDictProxy MultiDictMultiDictProxy)URL)hdrshelpershttp multipartpayload)AbstractStreamWriter)ClientConnectionError ClientOSErrorClientResponseErrorContentTypeError InvalidURLServerFingerprintMismatch)FormData)PY_36BaseTimerContext BasicAuth HeadersMixin TimerNoopnoopreify set_result)SERVER_SOFTWARE HttpVersion10 HttpVersion11 StreamWriter) client_logger) StreamReader)DEFAULT_JSON_DECODER JSONDecoder LooseCookies LooseHeaders RawHeaders) SSLContext) ClientRequestClientResponse RequestInfo Fingerprint) ClientSession) Connection)Tracez!^application/(?:[\w.+-]+?\+)?jsonT) auto_attribsfrozenslotscFeZdZUeeed<ded<eeed<dS)ContentDispositiontypezMappingProxyType[str, str] parametersfilenameN)__name__ __module__ __qualname__rstr__annotations__J/opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/client_reqrep.pyrHrHWs> 3-,,,,smrRrHc|eZdZUeed<eed<ded<ejZeed<ej defdZ dS) r?urlmethodCIMultiDictProxy[str]headersreal_urlreturnc|jSN)rUselfs rSreal_url_defaultzRequestInfo.real_url_defaultes xrRN) rLrMrNrrPrOattribrYdefaultr_rQrRrSr?r?^su HHH KKK $$$$DGIIHc #rRr?c`eZdZeeedZdeddfdZe defdZ de j ddfdZ dS) r@) fingerprintrZNct|}|j|}|std|tus |t urtd||_||_dS)Nzfingerprint has invalid lengthz8md5 and sha1 are insecure and not supported. Use sha256.)lenHASHFUNC_BY_DIGESTLENget ValueErrorrr _hashfunc _fingerprint)r^rg digestlenhashfuncs rS__init__zFingerprint.__init__qs{ $$ -11)<< =>> > __D 0 0M "'rRc|jSr\)rnr]s rSrgzFingerprint.fingerprint}   rR transportcL|dsdS|d}|d}||}||jkr/|d^}}}t |j|||dS)N sslcontext ssl_objectT) binary_formpeername)get_extra_info getpeercertrmdigestrnr')r^rtsslobjcertgothostport_s rScheckzFingerprint.checks'' 55  F)),77!!d!33nnT""))++ $# # #&55jAAND$+D,=sD$OO O $ #rR)rLrMrNrrrrjbytesrqpropertyrgasyncio TransportrrQrRrSr@r@js    (E (d ( ( ( (!U!!!X!Pw0PTPPPPPPrRr@sslr< verify_ssl ssl_contextrgrZc|1|s/tjdtd|tdd}|/tjdtd|td|}|dAd.Z?dee#d dfd/Z@d0e!d dfd1ZAdBd2e%d dfd3ZBdeedee#deed dfd4ZCd e%fd5ZDd6eEd7d8d dfd9ZFdCd:ZGdAd;ZHdAd<ZIdeded=eJd dfd>ZKdeded d?d dfd@ZLdS)Dr=z*/*z gzip, deflaterRNF)paramsrXskip_auto_headersdatacookiesauthversioncompresschunked expect100loopresponse_classrrtimersessionr proxy_headerstracesrVrUrrXrrrrrrrrrrr>rrrrrArrrrCc| tj} td||_|rXt |j}||}||j||}||_| d|_ | |_ | |_ | |_| |_d|_|t"}n|}||_||n t'|_||_| r+t/jt3jd|_|| ||||||| ||!||"||#||||$|||j |j%vr|&|'| |g}||_(dS)NrAr))rget_event_loopr_sessionrquery with_queryextend original_url with_fragmentrUupperrVrrrlengthr>rr-_timer_ssl get_debug traceback extract_stacksys _getframe_source_tracebackupdate_version update_hostupdate_headersupdate_auto_headersupdate_cookiesupdate_content_encoding update_auth update_proxyupdate_body_from_data GET_METHODSupdate_transfer_encodingupdate_expect_continue_traces)r^rVrUrrXrrrrrrrrrrrrrrrrrqurl2real_response_classs rSrqzClientRequest.__init__s04 <)++D _g66  $#)$$A>>&))D HHTZ ..##C$$T**llnn       !"0  "0 4G$0eeikk  >>   O%.%F rRrZc|jjdvS)N)httpswss)rUschemer]s rSrzClientRequest.is_sslAsx"222rRr<c|jSr\)rr]s rSrzClientRequest.sslD yrRc  |j}|r9ttd|D}nd}t |j|j||j|j |j |S)Nc3$K|] \}}||fV dSr\rQ).0kvs rS z/ClientRequest.connection_key..Ls*)S)STQ1a&)S)S)S)S)S)SrR) rhashtupleitemsrrrrrrr)r^rhs rSconnection_keyzClientRequest.connection_keyHs*  #E)S)S]=P=P=R=R)S)S)S$S$STTAAA I I KKMM H J O    rRc|jj}|Sr\)rUraw_host)r^rets rSrzClientRequest.hostYsh rRc|jjSr\)rUrr]s rSrzClientRequest.port_s x}rRclt|j}t|j|j||jSr\)rrXr?rUrVr)r^rXs rS request_infozClientRequest.request_infocs,)9$,)G)G48T['4;LMMMrRc|jst||j|j}}|rt j||pd|_dSdS)z8Update destination host, port and connection type (ssl).N)rr&userpasswordrr+r)r^rUusernamers rSrzClientRequest.update_hosthsZ| "S// !!Xs|(  D)(HNCCDIII D DrRc:t|tr~d|ddD} tjt |dt |d}n!#t $rt d|dwxYw||_dS)zdConvert request version to two elements tuple. parser HTTP version '1.1' => (1, 1) c6g|]}|SrQ)strip)rparts rS z0ClientRequest.update_version..ys @@@$@@@rR.rrz#Can not parse http version number: N)rrOsplitr HttpVersionrrlr)r^rrs rSrzClientRequest.update_versionss gs # # @@'--Q*?*?@@@A *3qt99c!A$ii@@    C'CC  s ;A33BcNt|_tt|jj}t j|rd|d}|jj8|j s|dt|jjzz }||jtj <|r|t|tttfr|}|D]E\}}|dkr ||j|<(|j||DdSdS)zUpdate request headers.[]N:r)rrXrrOrUrris_ipv6_addressris_default_portrHOSTrdictrrrloweradd)r^rXnetlockeyvalues rSrzClientRequest.update_headerss)4 c48,--  "6 * * #"]]]F 8= $TX-E-E-G-G $ cC ... .F"( TY  1'D.)#DEE *!--//% 1 1 U99;;&(((-DL%%L$$S%0000 1 1 1 1rRctdt|D|_|j}||j|jD]$\}}||vr|j||%tj |vrt|jtj <dSdS)Nc3K|]}|dfV dSr\rQ)rhdrs rSrz4ClientRequest.update_auto_headers..s7- - S$K- - - - - - rR) rsortedrrXcopyrDEFAULT_HEADERSrrr USER_AGENTr1)r^r used_headersr vals rSrz!ClientRequest.update_auto_headerss!,- - #)*;#<#<- - - " " |((** D2333,2244 + +HC,&&   c*** ?, . .,;DL ) ) ) / .rRc|sdSt}tj|jvrJ||jtjd|jtj=t |tr|}n|}|D]r\}}t |trS||j t}| |j |j |j |||<m|||<s|dd|jtj<dS)zUpdate request cookies header.Nr;)headersep)rrCOOKIErXloadrkrrrrrsetr coded_valueoutputr)r^rc iter_cookiesnamermrsl_vals rSrzClientRequest.update_cookiess   F+~~ ;$, & & FF4<##DK44 5 5 5 T[) gw ' ' #"==??LL"L'  KD%%((  99UY99 UY U5FGGG"$$$%HHBCH$@$@$F$F$H$H T[!!!rRcD|dS|jtjd}|r|jrt ddS|jrCt|jtsd|_|j|jtj<d|_ dSdS)zSet request content encoding.Nrz9compress can not be set if Content-Encoding header is setdeflateT) rXrkrCONTENT_ENCODINGrrrlrrOr)r^rencs rSrz%ClientRequest.update_content_encodings < Flt4b99??AA  }  R  ] dmS11 * ) 26-DL. /DLLL   rRc|jtjd}d|vr|jrt ddS|jr8tj|jvrt dd|jtj<dStj|jvr5tt|j |jtj<dSdS)z!Analyze transfer-encoding header.rrzDchunked can not be set if "Transfer-Encoding: chunked" header is setz6chunked can not be set if Content-Length header is setN) rXrkrTRANSFER_ENCODINGrrrlCONTENT_LENGTHrOribody)r^tes rSrz&ClientRequest.update_transfer_encodings \  d4b 9 9 ? ? A A ??|  D   \ H"dl22 O4=DL/ 0 0 0"$,6647DI4G4G T011176rRc||j}|dSt|tjst d||jtj<dS)zSet basic auth.Nz%BasicAuth() tuple is required instead) rrrr+rencoderXr AUTHORIZATION)r^rs rSrzClientRequest.update_authsZ <9D < F$ 122 ECDD D+/;;== T'(((rRr&c0|dSt|tr |} tj|d}n,#tj$rt|}YnwxYw||_|jsXtj |j vrE|j }|d|_n4tj |j vr!t||j tj <|j D]#\}}||j vr||jvr||j |<$dS)N) dispositionT)rr(r PAYLOAD_REGISTRYrk LookupErrorr&rrr%rXsizerOrr)r^r&r/rrs rSrz#ClientRequest.update_body_from_datas? < F dH % % 466D $+//$/GGDD" $ $ $!8D>>##DDD $ | F"$,66y<#'DLL*$,>> %,,.. . = $)W_55 .ioof----------di%);<<-!% DI!Y..E ,,u----------""$$ $ $ $ $ $ $ $ $ 0 0 0y ZW5I%J%J &&s++++'IBTXM'*#$'!&&w///% , , ,; ,&&s+++ ( ( (  " "3 ' ' ' ' ' ' ' ' ( DLLL4DL    sUB-C'&G' G 1A7E-(G-G ?F G G -GGG  G G!c K|jtjkr8|jj}t j|rd|d}|d|jj}nZ|jr)| st|j}n*|jj }|jj r|d|jj zz }|j }t||jt!j|j|j|jt!j|j|j|j}|jr||j|j||j|jvr:tj|jvr'tj|jvrd|jtj<|jtj}|s9|r|jt@krd}n|jtBkrd}|||jtj<d "|j||j}|#||jd{V|j$|%|||_&|j'}||j|j(|j&|j)|j*|j+|j,|j|j- |_.|j.S) Nrrr?) on_chunk_senton_headers_sentzapplication/octet-streamr7r8z{0} {1} HTTP/{2[0]}.{2[1]})r; continue100rrrrr)/rVr METH_CONNECTrUrrrrrrrOraw_pathraw_query_stringr?r4r functoolspartial_on_chunk_request_sent_on_headers_request_sentrenable_compressionrenable_chunking POST_METHODS CONTENT_TYPErrXrkr9r:rr2r3r write_headers create_taskrQrMrrr4rrrrresponse) r^r< connect_hostpathr?r; connection status_liners rSsendzClientRequest.send`s ;$+ + +8,L&|44 32<222 "44TX]44DD Z 8  8tx==DD8$Dx( 8dh777=  I#++T[$(&--t{DH     = 5  % %dm 4 4 4 < #  " " $ $ $ K4, , ,!)???!55.HDL* +\%%do66  )   )<=00!-J<=00!(J  !,6DL )399 Kt|  ""; =========y,,T-=-=fd-K-KLL ,& K  <+*<M     }rRc^K|j# |jd{Vd|_dS#d|_wxYwdSr\)rMr]s rSr8zClientRequest.closesS < # $l"""""""# t #### $ #s ! *c|j;|js|jd|_dSdSr\)rMr is_closedcancelr]s rS terminatezClientRequest.terminatesG < #9&&(( & ##%%%DLLL $ #rRrNcXK|jD]}||||d{V dSr\)rsend_request_chunk_sent)r^rVrUrNtraces rSr\z$ClientRequest._on_chunk_request_sentsR\ D DE//UCC C C C C C C C C D DrRzCIMultiDict[str]cXK|jD]}||||d{V dSr\)rsend_request_headers)r^rVrUrXrqs rSr]z&ClientRequest._on_headers_request_sentsT\ C CE,,VS'BB B B B B B B B B C CrRrZN)F)r<rBrZr>)MrLrMrNrMETH_GET METH_HEAD METH_OPTIONS METH_TRACEr METH_PATCH METH_POSTMETH_PUTr`union METH_DELETE ALL_METHODSACCEPTACCEPT_ENCODINGrr&rrdrMr4 frozensetrr3rOrrrr:rr r9r+rrrAbstractEventLooprr*rr<r@rrqrrrrrrrrr?rrrrrrrrrrrrr:r!rQrir8rnrr\r]rQrRrSr=r=s     K OT^T]CL##L11779I8JKKK U oO D DHGI/3*.+49;;*.$($($6"&"&48;?#*.,0-1:>04*./HHHHH c*+ H ,' H$C=HH,'Hy!H!H3-H$HHw01H !&6!78!H"}#H$Y'%H&()'H(/*)H*:t[$6 7+H, --H.g'/HHHHT33333U<t[@AX    X cX hsmXNkNNNXN Ds Dt D D D D eD,& & & & & POOOOb$$$$    D3DSDDSWDDDDCC #C.@C CCCCCCrRr=cbeZdZUdZdZeed<dZdZe ed<dZ ded<dZ e ed<dZ dZdZdZd ed ed d d eddedededdejddddfdZedefdZedefdZedefdZedefdZedDdZede fdZ edefdZ!edee"fdZ#e$fd e%ddfd!Z&defd"Z'e(ded#fd$Z)ede*d%fd&Z+edEd(Z,dFd*Z-dGd+Z.e(de/fd,Z0dGd-Z1de%fd.Z2e(de/fd/Z3dGd0Z4dGd1Z5dGd2Z6dGd3Z7de8fd4Z9defd5Z:dHd7eed8edefd9Z;deZ>dId?Z?d@ee@eAdAeeAdBeeBddfdCZCdS)Jr>NstatuscontentrW_headers _raw_headersTFrVrUr;zasyncio.Task[None]rVzasyncio.Future[bool]rrrrCrrrArZc||_t|_||_|d|_d|_||_||_d|_ d|_ ||_ ||n t|_ i|_||_||_| |_|r-t'jt+jd|_dSdS)NTrQr)rVrr _real_urlr_url_bodyrMr4_closed_history _request_infor-r_cacher_looprrrrrrr) r^rVrUr;rVrrrrrs rSrqzClientResponse.__init__s *6.. %%d++  5; $ 46 )$0eeikk &(   18 >>   O%.%)file) ioStringIOrOrUreasonr)decodeprintrrrXgetvalue)r^outascii_encodable_urlascii_encodable_reasons rS__repr__zClientResponse.__repr__9skmm!$(mm ; 1%)[%7%7+&&fWoo # "&*[ " * 1 1#T[2H       dl%%%%||~~rRrBc|jSr\)rr]s rSrgzClientResponse.connectionKs rR)r>.c|jS)z2A sequence of of responses, if redirects occurred.)rr]s rShistoryzClientResponse.historyOs }rR/MultiDictProxy[MultiDictProxy[Union[str, URL]]]c Pd|jdg}|stt St }t jd|D](}t jd|}||\}}|ddd}t }|D]T} t jd| t j }|%|\} } } } | | | U| d|} | d |j t|| | t|*t|S) Nz, linkz ,(?=\s*<)z \s*<(.*)>(.*)rrz%^\s*(\S*)\s*=\s*(['\"]?)(.*?)(\2)\s*$relrU)joinrXgetallrrrerrgroupsMrrkrUr) r^ links_strlinksrrrU params_strrrparamrrrs rSrzClientResponse.linksTswIIdl11&"==>>  /!)++.. .> Qqe$$$$((5#&&C HHUDHMM#c((33 4 4 4 IIc>$// 0 0 0 0e$$$rRrgc pKd|_|j|_||_|j5 |j}|d{V\}}nE#t j$r3}t|j |j |j |j |j |d}~wwxYw|j dks|j dks |j dkrn$|jt|jdd|_ dddn #1swxYwY|j|j|j|_|j |_|j|_|j |_|j|_||_|j t4jdD]I} |j|#t<$r}t?j d |Yd}~Bd}~wwxYw|S) zStart response processing.FTNrrrXderQz!Can not load response cookies: %s)!rr? _protocolrrreadrHttpProcessingErrorr$rrcoderrXr4r0on_eof _response_eofrrrrrrrrr SET_COOKIErrrr5warning)r^rgr?rr rOr s rSstartzClientResponse.startxsD #,% [ * * * #~H-5]]__'<'<'<'<'<'<$GWW/-) "x # #   <#%%););w|s?R?R>-t~t444%)DN' *! * * * * * * * * * * * * * * *. t)*** l n   #/ <&&t;; P PC P !!#&&&& P P P%&I3OOOOOOOO P sMC$$A  C$ B.B  BA C$$C(+C(/F  F3F..F3c|jrdS|j?|jj|jjjrdS|jd|_d|_|dSNT)rrr?upgradedrrr]s rSrzClientResponse._response_eofs| <  F   ' )5$-66   $ $ & & &#D   rRc|jSr\)rr]s rSrKzClientResponse.closeds |rRc|js||jrdSd|_|j|jrdS|j |jd|_|dSr) _released_notify_contentrrrlrr8rr]s rSr8zClientResponse.closes~ #  " " " <  F : !5!5!7!7  F   '   " " $ $ $#D  rRc|js||jrtSd|_|j |jd|_|tSr)rrrr.rrrr]s rSrzClientResponse.releasesy~ #  " " " < 66M   '   $ $ & & &#D  vv rRcd|jkS)zReturns ``True`` if ``status`` is less than ``400``, ``False`` if not. This is **not** a check for ``200 OK`` but a check that the response status is under 400. i)rr]s rSokzClientResponse.oksT[  rRc|jsA|t|j|j|j|j|jdS)Nr)rrr$rrrrrXr]s rSraise_for_statuszClientResponse.raise_for_statussVw  LLNNN%! {     rRcb|j|jd|_d|_dSr\)rMrmrr]s rSrzClientResponse._cleanup_writers0 < # L   ! ! !  rRc|j}|r6|"|tdd|_dS)NConnection closedT)r exceptionrGr"r)r^rs rSrzClientResponse._notify_contentsL,  Nw((**2  ! !"78K"L"L M M MrRcK|j" |jd{Vd|_n #d|_wxYw|dSr\)rMrr]s rSwait_for_closezClientResponse.wait_for_closesZ < # $l"""""""# t #### s )cLK|j |jd{V|_|jD].}||j|j|jd{V/n9#t$r|wxYw|j rtd|jS)zRead response payload.Nr) rrrrsend_response_chunk_receivedrVrU BaseExceptionr8rr")r^rqs rSrzClientResponse.read s :  #'<#4#4#6#6666666 !\E<< TXtz!     ^ ='(;<< <zs AA&& Bc|jtjd}t j|}|jd}|r( tj |n#t$rd}YnwxYw|sY|j dkr|j dks |j dkrd}n5|j tdtj|j d}|sd}|S) Nrcharset applicationjsonrdapzutf-8z0Cannot guess the encoding of a not yet read bodyencoding)rXrkrrarrparse_mimetyperJcodecslookupr.rIsubtyper RuntimeErrorchardetdetect)r^ctypemimetypers rS get_encodingzClientResponse.get_encodings   !2B77==??)%00&**955    h''''     B} -- F**h.>&.H.H##"I#>$*55jA Hs)A>> B  B strictrerrorscK|j|d{V||}|j||S)z!Read response payload and decode.N)r)rrrr)r^rrs rStextzClientResponse.text6si : ))++         ((**Hz  V!   rRr)rloads content_typerrcK|j|d{V|rl|jtjd}t||s%t|j |j d|z|j|j }|sdS|| }|| |S)zRead and decodes JSON response.Nrz3Attempt to decode JSON with unexpected mimetype: %s)rrX)rrrXrkrrarrr%rrrrr)r^rrrrstrippeds rSrzClientResponse.jsonBs : ))++         L$$T%6;;AACCE,ULAA &%LPSXX L :##%% 4  ((**HuX__X..///rRc K|Sr\rQr]s rS __aenter__zClientResponse.__aenter__bs  rRexc_typeexc_valexc_tbc2K|dSr\)r)r^r r rs rS __aexit__zClientResponse.__aexit__es rR)rZrW)rZr)rgrBrZr>rt)Nr)rZr>)DrLrMrNrrrrPrrr6rrr;rrrrrOrrr*r?rrrrqr/rUrrYrrXrrrHrrr rrrrgrrrrrrrKr8rrrrrrrrrrr7r8rr rrr rrQrRrSr>r>s$GFC F G\   (,H%,,,#L*###KGI!O!O!O % !O 45 !O !O"!OW !O'!O!!O !O!O!O!OF S U  U # U c U  U !Z!!! U! "k""" U" FX.@%AFFF UF(0;;;D;;;;&#$ H\2   X  45 U !%!%!% U!%F1111f&X         !D!!!X!      E"c8   8C=    TW     #'1&8 0003-0 0 sm 0 0000@ 4 ./ -( '        rRr>)lrrrZrrrrrhashlibrrr http.cookiesrrrtypesr r typingr r r rrrrrrrrr` multidictrrrryarlrrrrrrr abcr!client_exceptionsr"r#r$r%r&r'formdatar(r)r*r+r,r-r.r/r0r1r2r3r4logr5streamsr6typedefsr7r8r9r:r;rr< ImportErrorobjectcchardetrcharset_normalizer__all__clientrA connectorrBtracingrCcompilersrHr?r@rrIrrrrrOrr=r>rQrRrSr's1  %%%%%%%%%%::::::::::11111111                           NNNNNNNNNNNN55555555555555%%%%%%                    NMMMMMMMMMMM!!!!!!JJJ CJJJ))))(((((() L%%%%%%%%%%%% "*9 : :T$d33343 T$d33343PPPPPPPPD?{DDJJGT 2 |T;4 522,'2% 2  <{D 01 2222jTd333 & & & & & & &43 &::7:: ::::jCjCjCjCjCjCjCjCZeeeee\eeeees$ C C)(C)-C22 C>=C>