Oj8ddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl mZmZddlmZmZddlmZmZmZmZddlmZmZmZmZmZmZmZddl m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)dd l*m+Z+dd l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7dd l8m9Z9dd l:m;Z;me j~dZ@d dZAd!d"dZBd!d#dZCd$dZDd%dZE d&dZFGdde jeHeHfZIGddZJGddZKGdde jeHeHfZLy)') annotationsN)AsyncGeneratorMapping)Cookie CookieJar) ByteStreamUnattachedStreamencode_requestencode_response) ByteChunkerContentDecoderIdentityDecoder LineDecoder MultiDecoder TextChunker TextDecoder)CookieConflictHTTPStatusErrorRequestNotReadResponseNotRead StreamClosedStreamConsumedrequest_context)(get_multipart_boundary_from_content_type)codes) AsyncByteStream CookieTypes HeaderTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesResponseContentResponseExtensionsSyncByteStream)URL)to_bytes_or_strto_str)CookiesHeadersRequestResponse authorizationzproxy-authorization_TcN tj|y#t$rYywxYw)z7 Return `True` if `encoding` is a known codec. FT)codecslookup LookupErrorencodings e/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/httpx2/_models.py_is_known_encodingr8:s, h  s  $$cPt|tr|S|j|xsdS)zE Coerce str/bytes into a strictly byte-wise HTTP header key. ascii) isinstancebytesencode)keyr6s r7_normalize_header_keyr?Es&S%(3Mcjj9LW.MMct|tr|St|tstdt ||j |xsdS)zG Coerce str/bytes into a strictly byte-wise HTTP header value. z'Header value must be str or bytes, not r:)r;r<str TypeErrortyper=)valuer6s r7_normalize_header_valuerFLsH% eS !A$u+OPP <<+G ,,r@cltjj}||d<|jdS)N content-type)failobj)emailmessageMessageget_content_charset) content_typemsgs r7_parse_content_type_charsetrPWs4 --   !C&C  " "4 " 00r@cg}d}|j|}|s|Stjd|D]} |jdd\}}d|jdi}|jdD]:} |jd\}}|j|||j|<<|j ||S#t$r|d}}YwxYw#t$rY4wxYw) a7 Returns a list of parsed link headers, for more info see: https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Link The generic syntax of those is: Link: < uri-reference >; param1=value1; param2="value2" So for instance: Link; '; type="image/jpeg",;' would return [ {"url": "http:/.../front.jpeg", "type": "image/jpeg"}, {"url": "http://.../back.jpeg"}, ] :param value: HTTP Link entity-header field :return: list of parsed link headers z '"z, *<;rurlz<> '"=)stripresplit ValueErrorappend) rElinks replace_charsvalrTparamslinkparamr>s r7_parse_header_linksra_s #%EM KK &E  xx&  "))C+KCsyy*+\\#& HE "[[- U.3[[-GD=) *  H  T  L "rC "   s#B?1C? CC CCc#K|D]7\}}t|jtvr td|}||f9yw)Nz[secure]) match_type_of)r*lowerSENSITIVE_HEADERSr))itemskvs r7_obfuscate_sensitive_headersrisD1 !'')  1 1 !Ac\eZdZdZ d ddZeddZejddZed dZd!dZ d"dZ d#d Z d$d Z e jd%d Ze jd&d Zd'd(d Zd)d*dZd'd+dZd,dZd-dZd-dZd.dZd/dZd0dZd1dZd2dZd3dZd4dZd5dZddZy)6r,z9 HTTP headers, as a case-insensitive multi-dict. Nc g|_t|tr"t|j|_||_ yt|trd|j D]I\}}t ||}t||}|jj||j|fK||_ y|N|D]I\}}t ||}t||}|jj||j|fK||_ yN) _listr;r,listrrfr?rFrZrd _encoding)selfheadersr6rgrh bytes_key bytes_values r7__init__zHeaders.__init__s 8: gw 'gmm,DJ" )  O11!X> 5aB  !!9ioo.?"MN O"   O11!X> 5aB  !!9ioo.?"MN O "r@c|jXdD]L}|jD](\}} |j||j|*||_|jSd|_|jS#t$rYnwxYw)zn Header encoding is mandated as ascii, but we allow fallbacks to utf-8 or iso-8859-1. )r:utf-8z iso-8859-1)rorawdecodeUnicodeDecodeError)rpr6r>rEs r7r6zHeaders.encodings >> !. ."&(( JC 8, X. &.DN ~~! .".~~.s"A11 A>=A>c||_yrl)rorprEs r7r6zHeaders.encodings r@cX|jDcgc] \}}}||f c}}}Scc}}}w)zH Returns a list of the raw header items, as byte pairs. )rm)rpraw_key_rEs r7rwz Headers.raws+ ;?**EE%6Wa% EEEs%c|jDcic]"\}}}|j|jd$c}}}jScc}}}wrl)rmrxr6keys)rpr~r>_values r7rz Headers.keyss>FJjjQQNAsF 4==)4/QVVXXQs'A ci}|jD]V\}}}|j|j}|j|j}||vr||xxd|z cc<R|||<X|jS)N, )rmrxr6valuesrp values_dictr~r>rEstr_key str_values r7rzHeaders.valuess~&( !ZZ 1MAsEjj/G T]]3I+%G$"YK(88$'0 G$  1!!##r@ci}|jD]V\}}}|j|j}|j|j}||vr||xxd|z cc<R|||<X|jS)z Return `(key, value)` items of headers. Concatenate headers into a single comma separated value when a key occurs multiple times. r)rmrxr6rfrs r7rfz Headers.itemss ') !ZZ 1MAsEjj/G T]]3I+%G$"YK(88$'0 G$  1  ""r@c |jDcgc]<\}}}|j|j|j|jf>c}}}Scc}}}w)z Return a list of `(key, value)` pairs of headers. Allow multiple occurrences of the same key without concatenating into a single comma separated value. )rmrxr6)rpr~r>rEs r7 multi_itemszHeaders.multi_itemssJ _c^h^hii]QPSUZDMM*ELL,GHiiisAAcyrl)rpr>s r7getz Headers.gets.1r@cyrlrrpr>defaults r7rz Headers.gets69r@c0 ||S#t$r|cYSwxYw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyErrorrs r7rz Headers.gets%  9  N s  c|jj|j}|jDcgc]4\}}}|j|k(r|j |j6}}}}|s|Sg}|D]>} |j | j dD cgc]} | jc} @|Scc}}}wcc} w)z Return a list of all header values for a given key. If `split_commas=True` is passed, then any comma separated header values are split into multiple return strings. ,)rdr=r6rmrxextendrXrV) rpr> split_commasget_header_keyr~item_key item_valuer split_valuesrEitems r7get_listzHeaders.get_lists ++DMM:,0::  '8Z~~>1   dmm ,  M"$  ME   %++c:J K$ K L M !Ls 9C C ct|}|jD]}||vs|j||jj |jyrl)r,rpoprmr)rprqr>s r7updatezHeaders.updatesK'"<<> Cd{   '--(r@c0t||jS)Nr5)r,r6rps r7copyz Headers.copystdmm44r@ctt|tstS|j}|j ||Srl)r;rNotImplementedrrrpothermergeds r7__or__zHeaders.__or__!s.%)! ! e r@cjt|tstSt|}|j ||Srl)r;rrr,rrs r7__ror__zHeaders.__ror__(s,%)! ! d r@c(|j||Srl)r)rprs r7__ior__zHeaders.__ior__/s E r@c|jj|j}|jDcgc]&\}}}||k(r|j |j(}}}}|rdj |St |cc}}}w)z Return a single header value. If there are multiple headers with the same key, then we concatenate them with commas. See: https://tools.ietf.org/html/rfc7230#section-3.2.2 r)rdr=r6rmrxjoinr)rpr>normalized_keyr~ header_key header_valuerfs r7 __getitem__zHeaders.__getitem__3s++DMM:04zz  +:|^+    .  99U# #sm s+Bc|j|jxsd}|j|jxsd}|j}t|jDcgc]\}\}}}||k(s|} }}}t | ddD]}|j|=| r| d}|||f|j|<y|jj |||fycc}}}w)zs Set the header `key` to `value`, removing any duplicate entries. Retains insertion order. rvrNr)r=rord enumeratermreversedrZ) rpr>rEset_key set_value lookup_keyidxr~r found_indexess r7 __setitem__zHeaders.__setitem__Gs **T^^6w7LL!:7; ]]_ :CDJJ:Ojj!6&6q(AS[_iSij jM!"-. C 3  "C& I>DJJsO JJ  w I> ?ks (C:Cc:|jj|j}t|jDcgc]\}\}}}|j|k(s|!}}}}|s t |t |D]}|j|=ycc}}}w)z* Remove the header `key`. N)rdr=r6rrmrr)rpr>del_keyrr~r pop_indexess r7 __delitem__zHeaders.__delitem__[s))+$$T]]38A$**8Mmm4s$4Q!QYQ_Q_QaelQlsm m3- K( C 3 ns B#Bc|jj|j}||jDcgc]\}}}| c}}vScc}}wrl)rdr=r6rm)rpr>rr~s r7 __contains__zHeaders.__contains__is?YY['' 6 4::>iaac>>>>s A c4t|jSrl)iterrrs r7__iter__zHeaders.__iter__msDIIK  r@c,t|jSrl)lenrmrs r7__len__zHeaders.__len__ps4::r@c t|}|jDcgc] \}}}||f }}}}|jDcgc] \}}}||f }}}}t|t|k(S#t$rYywxYwcc}}}wcc}}}w)NF)r,rYrmsorted)rpr other_headersr~r>rE self_list other_lists r7__eq__zHeaders.__eq__ss #ENM8rBrr)r>rBrr0rzstr | _Trl)r>rBrz _T | Nonerzstr | _T | None)F)r>rBrboolrz list[str])rqrrr)rr,)rzMapping[str, str]rr,)rrrr,)r>rBrrB)r>rBrErBrr)r>rBrr)r> typing.Anyrr)rztyping.Iterator[typing.Any]rint)rrrr)r __module__ __qualname____doc__rtpropertyr6setterrwrrrfrtypingoverloadrrrrrrrrrrrrrrrrr@r7r,r,s '+#"#""  ",0__FF Y $ #j __11 __99,)5(@(  ?!7 :r@r,c eZdZdddddddddd d dZd dZed dZd dZd dZddZ dd Z dd Z y)r-N) r^rqcookiescontentdatafilesjsonstream extensionsc 0|j|_| t|n t|||_t ||_| in t | |_|rt|j|| |j jd} t|||| t| r%| j|j jnd\}} |j|| |_t#| t$r|j'yy| |_y)N)r^rH)rN)rrrrboundary)uppermethodr(rTr,rqrrr+set_cookie_headerrr rr=r6_preparerr;r read) rprrTr^rqrrrrrrrrNs r7rtzRequest.__init__slln %~3s83s63Jw' * 2"Z8H  G  . .t 4 >'+||'7'7'GL,AO[!4!4T\\5J5J!Kae OGV MM' " DK&*- ."!DKr@c^|jD]e\}}|jdk(rd|jvr(|jdk(rd|jvrJ|jj||gg}d|jv}d|jvxsd|jv}|s=|jj r'|j d|jjf|s|jdvr|j dt||jjz|_y) Ncontent-lengthzTransfer-Encodingtransfer-encodingzContent-LengthHostsHost)POSTPUTPATCHQUERY)sContent-Length0) rfrdrq setdefaultrThostrZnetlocrr,rw)rpdefault_headersr>rE auto_headershas_hosthas_content_lengths r7rzRequest._prepares)//1 0JCyy{..3F$,,3Vyy{116F$,,6V LL # #C / 035 T\\)-=dATX\XdXdAdDHHMM   $((// : ;!dkk5V&V    9 :|dll.>.>>? r@cFt|ds t|jSN_content)hasattrrrrs r7rzRequest.contentstZ( " "}}r@c&t|dszt|jtjsJdj |j|_t|jtst|j |_|j S)6 Read and return the request content. rr@)rr;rrIterablerrr rs r7rz Request.readsdtZ(dkk6??; ;;HHT[[1DMdkk:6)7 }}r@cjKt|dsMt|jtjsJdj |j2cgc3d{}| |j S76ncc}wc}|_t|jtr)rrrBrTr)rprrTs r7rzRequest.__repr__s=^^,, $((m:,a br::r@ct|jjDcic] \}}|dvs ||c}}Scc}}w)N)rr__dict__rfrpnamerEs r7 __getstate__zRequest.__getstate__s3/3}}/B/B/Dm eTlHle mmms 44cz|jD]\}}t|||i|_t|_yrl)rfsetattrrr rrpstaterrEs r7 __setstate__zRequest.__setstate__s8 ;;= 'KD% D$ & '&( r@)rrBrTz URL | strr^zQueryParamTypes | NonerqrrCookieTypes | NonerzRequestContent | NonerzRequestData | NonerzRequestFiles | Nonerztyping.Any | Noner'SyncByteStream | AsyncByteStream | NonerzRequestExtensions | Nonerrrzdict[str, str]rrrr<rrdict[str, typing.Any]r"r)rr) rrrrtrrrrrrrr#rr@r7r-r-s *.&*&*)-#'%)"&:>/36!6!6! ' 6! $ 6!$6!'6!!6!#6! 6!86!-6! 6!p@,  ; n)r@r-c eZdZddddddddddd d.dZd/dZed0dZejd1dZed2dZejd3d Zed4d Z ed4d Z ed5d Z ed6d Z ed4dZ ed7dZejd8dZed7dZd9dZed:dZed:dZed:dZed:dZed:dZed:dZed:dZd;dZddZed?dZd4dZd@d ZdAd!Zd6d"Z dBdCd#Z!dBdDd$Z"dEd%Z#dBdCd&Z$dFd'Z%d6d(Z&dBdGd)Z'dBdHd*Z(dId+Z)dBdGd,Z*dFd-Z+y)Jr.Nrv) rqrtexthtmlrrrequestrhistorydefault_encodingc ||_t||_||_d|_| in t | |_| gn t| |_d|_ d|_ | |_ |Qt||||\}}|j|||_t|t r|j#d|_y||_d|_y)NFr) status_coder,rq_request next_requestrrrnr/ is_closedis_stream_consumedr0r rrr;r r_num_bytes_downloaded) rpr2rqrr,r-rrr.rr/r0s r7rtzResponse.__init__s'w' (/ -1 * 2"Z8H$_r$w- "' 0 >-gtT4HOGV MM' " DK&*- &'"!DK%&"r@c|jD]C\}}|jdk(rd|jvr(|jj||Ey)Nrr)rfrdrqr)rprr>rEs r7rzResponse._prepareEsP)//1 0JCyy{116F$,,6V LL # #C /  0r@c~t|ds&t|jdd}||Std|jS)ze Returns the time taken for the complete request/response cycle to complete. _elapsedelapsedNzK'.elapsed' may only be accessed after the response has been read or closed.)rgetattrr RuntimeErrorr:)rpstream_elapseds r7r;zResponse.elapsedLsC tZ(8? YX\8]N)%%lm m}}r@c||_yrl)r:)rpr;s r7r;zResponse.elapsedYs  r@cH|j td|jS)zR Returns the request instance associated to the current response. z7The request instance has not been set on this response.)r3r=rs r7r.zResponse.request]s$ == XY Y}}r@c||_yrl)r3r{s r7r.zResponse.requestfs  r@cf |jd}|jddS#t$rYywxYw)N http_versionr:ignoreerrorszHTTP/1.1)rrxr)rprCs r7rCzResponse.http_versionjsB A"&//."AL &&wx&@ @  s $ 00c |jd}|jddS#t$r"tj|j cYSwxYw)N reason_phraser:rDrE)rrxrrget_reason_phraser2)rprHs r7rHzResponse.reason_phrasessV B#'???#CM!'''A A =**4+;+;< < =s$(AAc.|jjS)zA Returns the URL for which the request was made. )r.rTrs r7rTz Response.url|s ||r@cFt|ds t|jSr )rrrrs r7rzResponse.contentstZ(!# #}}r@c&t|dsz|j}|sd|_|jSt|jxsd}dj |j |j|jg|_|jS)N_textrSrvr5)rrrMrr6rrxflush)rprdecoders r7r,z Response.textsrtW%llG zz&t}}/GHWWgnnT\\&BGMMO%TU zzr@ct|dsr|j}| t|sNt|jt r |j}n't|dr|j |j }|xsd|_|jS)a Return an encoding to use for decoding the byte content into text. The priority for determining this is given by... * `.encoding = <>` has been set explicitly. * The encoding as specified by the charset parameter in the Content-Type header. * The encoding as determined by `default_encoding`, which may either be a string like "utf-8" indicating the encoding to use, or may be a callable which enables charset autodetection. rorrv)rcharset_encodingr8r;r0rBrro)rpr6s r7r6zResponse.encodingsvt[),,H'9('Cd33S9#44HT:.#44T]]CH%0DN~~r@c@t|dr td||_y)z Set the encoding to use for decoding the byte content into text. If the `text` attribute has been accessed, attempting to set the encoding will throw a ValueError. rMz?Setting encoding after `text` has been accessed is not allowed.N)rrYror{s r7r6zResponse.encodings! 4 !^_ _r@cT|jjd}|yt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)rqrrP)rprNs r7rQzResponse.charset_encodings, ||''7  *<88r@ct|ds|jjdd}|Dcgc] }|jj "}}t |Dcgc] }|dk7s | c}}t |jdk(r |jd|_|jS|jr||_|jSt|_|jScc}wcc}w)z Returns a decoder instance which can be used to decode the raw byte content, depending on the Content-Encoding used in the response. _decoderzcontent-encodingT)ridentityrr) rrqrrVrdrrchildrenrUr)rprrE encodingsr6rOs r7_get_content_decoderzResponse._get_content_decoders tZ(\\**+=D*QF Raise the `HTTPStatusError` if one occurred. zYCannot call `raise_for_status` as the request instance has not been set on this response.z{error_type} '{0.status_code} {0.reason_phrase}' for url '{0.url}' Redirect location: '{0.headers[location]}' For more information check: https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/{0.status_code}z{error_type} '{0.status_code} {0.reason_phrase}' for url '{0.url}' For more information check: https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/{0.status_code}dzInformational responsezRedirect responsez Client errorz Server error)rzInvalid status code) error_type)r.response)r3r=r]rnr2rformatr)rpr.rK status_class error_typesrts r7raise_for_statuszResponse.raise_for_statuss-- ?k  ??K  % %w w  ''3. '"  !__\3HI ..*.=gwFFr@c Btj|jfi|Srl)jsonlibloadsr)rpkwargss r7rz Response.json=s}}T\\4V44r@ct|ds*t|_|jj||jS)N_cookies)rr+rextract_cookiesrs r7rzResponse.cookies@s1tZ(#IDM MM ) )$ /}}r@c|jjd}|iSt|Dcic]'}|jdxs|jd|)c}Scc}w)zI Returns the parsed header links of the response, if any r_relrT)rqrra)rpheaderr_s r7r[zResponse.linksGsV !!&) >IGZ[aGbct%3DHHUOd:cccs,Ac|jSrl)r7rs r7num_bytes_downloadedzResponse.num_bytes_downloadedRs)))r@c<d|jd|jdS)Nz )r2rHrs r7rzResponse.__repr__Vs%T--.a0B0B/C2FFr@cr|jjDcic] \}}|dvr||c}}Scc}}w)N)rrr5rUrrs r7rzResponse.__getstate__YsB $}}224 eLL %K   s3c|jD]\}}t|||d|_i|_t |_y)NT)rfr r5rr rr!s r7r#zResponse.__setstate__`s? ;;= 'KD% D$ & '&( r@czt|ds$dj|j|_|jS)7 Read and return the response content. rr@)rr iter_bytesrrs r7rz Response.readgs/tZ(HHT__%67DM}}r@c#Kt|dr]|t|jn|}tdt|jt |dD]}|j|||zy|j }t |}t|j5|jD]2}|j|D]}|j|D]}|4|jD]}|j|D]}||jD]}| dddy#1swYyxYwwz A byte-iterator over the decoded response content. This allows us to handle gzip, deflate, brotli, and zstd encoded responses. rNrr chunk_sizer.) rrrrangemaxrYr rr3iter_rawrxrN)rprirOchunker raw_bytesdecodedchunks r7rzResponse.iter_bytesos8 4 $/9/AT]]+zJ1c$--0#j!2DE 8mmAJ77 8//1G!Z8G 7 !%(I#*>>)#<(%,^^G%<(E"'K((( '}}$G!(!8$# $$%]]_ EK  sBEBD6- E6D?;Ec#Kt|jxsd}t|}t|j5|j D]-}|j |}|j |D]}|/|j}|j |D]}||jD]}| dddy#1swYyxYwwz A str-iterator over the decoded response content that handles both gzip, deflate, etc but also detects the content's string encoding. rvr5rrN)rr6rrr3rrxrNrprrOr byte_content text_contentrs r7 iter_textzResponse.iter_texts t}}'?@4 T]] 3  $ 1 &~~l; $^^L9 EK  #==?L  5          s=CBC  C CCc#Kt}t|j5|jD]}|j |D]}||j D]}| dddy#1swYyxYwwNr)rrr3rrxrNrprOr,lines r7 iter_lineszResponse.iter_liness|- T]] 3 ( #NN40DJ         s!BA A6- B6A?;Bc#LK|jr t|jr tt |j t s tdd|_d|_t|} t|j5|j D]:}|xjt|z c_|j|D]}|< ddd|jD]}| |jy#1swY4xYw#|jwxYww)@ A byte-iterator over the raw response content. z5Attempted to call a sync iterator on an async stream.TrrrN)r6rr5rr;rr'r=r7r rr3rrxrNclose)rprrraw_stream_bytesrs r7rzResponse.iter_raws  " " " " >>. $++~6VW W"&%&"4  7 $(, $$..#6F2GG.!(0@!A$# $$ $ !    JJL $ $ JJLs7A,D$/DA D!D2D$D DD!!D$ct|jts td|jsAd|_t |j 5|jjdddyy#1swYyxYw) Close the response and release the connection. Automatically called if the response body is read to completion. z2Attempted to call a sync close on an async stream.TrN)r;rr'r=r5rr3rrs r7rzResponse.closesg $++~6ST T~~!DN 7 $ !!# $ $ $ $s A44A=c tKt|dsItj|j4d{}dj |2cgc3d{}| |j S7-76ncc}wc}|_dddd{7|j S#1d{7swY|j SxYww)rrNr@)r contextlibaclosing aiter_bytesrr)rppartsrs r7rzResponse.areadstZ(!**4+;+;+=> I I% #)G)G$}} I)G)G)G H  I I I}} I I I}}st4B8A$B8B A* A( A&A( A*  B8&A( (A* )B; B8B B8B5B! B5&B8c.Kt|dr^|t|jn|}tdt|jt |dD]}|j|||zy|j }t |}t|j5tj|j4d{}|23d{}|j|D]}|j|D]}| ;7A786dddd{7n#1d{7swYnxYw|jD]}|j|D]}| |jD]}|  dddy#1swYyxYwwr)rrrrrrYr rr3rr aiter_rawrxrN) rprrrOr raw_streamrrrs r7rzResponse.aiter_bytess{ 4 $/9/AT]]+zJ1c$--0#j!2DE 8mmAJ77 8//1G!Z8G 7 %..t~~/?@,,J+5,,i'.~~i'@,G)0)@,&+ ,,,,:,,,,, '}}$G!(!8$# $$%]]_ EK  sBF(F D F  D D D D 3D  F  D  D  F DF  D2 &D)'D2 .AF  F FFcKt|jxsd}t|}t|j5|j 23d{}|j |}|j |D]}| 6716|j}|j |D]}| |jD]}|  dddy#1swYyxYwwr)rr6rrr3rrxrNrs r7 aiter_textzResponse.aiter_texts t}}'?@4 T]] 3 &*&6&6&8  l&~~l; $^^L9 EK  &8#==?L  5          sA=C$CBBB.CBAC C$C!C$cKt}t|j5|j23d{}|j |D]}| %7 6|j D]}|  dddy#1swYyxYwwr)rrr3rrxrNrs r7 aiter_lineszResponse.aiter_liness- T]] 3 "oo/  d#NN40DJ /        s<!B BAAABAB7 B B B cJK|jr t|jr tt |j t s tdd|_d|_t|}|j j} t|j5|23d{}|xjt|z c_|j|D]}| C7>6 dddn #1swYnxYw|jD]}|  t |t r|j#d{7|j#d{7y#t |t r|j#d{7|j#d{7wxYww)rz5Attempted to call an async iterator on a sync stream.TrrrN)r6rr5rr;rrr=r7r __aiter__rr3rrxrNraclose)rprrrrrs r7rzResponse.aiter_rawsS  " " " " >>. $++7VW W"&%&"4&&(  7 $.4$$*..#6F2GG.!(0@!A$# $$f $ $ $ !   &.1mmo%%++-  &.1mmo%%++-  sBF# EC2"C'&C%'C'*;C2%C''C2) E2C;7!E#F#<D?=F#EF#$F FF FF  F#cKt|jts td|jsId|_t |j 5|jjd{dddyy7#1swYyxYww)rz2Attempted to call an async close on a sync stream.TrN)r;rrr=r5rr3rrs r7rzResponse.aclose%sv $++7ST T~~!DN 7 +kk((*** + ++ + +s0AB B/A>0B4 B >BB B )r2rrqrrzResponseContent | Noner,rr-rrrrr%r.zRequest | NonerzResponseExtensions | Noner/zlist[Response] | Noner0z*str | typing.Callable[[bytes], str | None]rrr&)rdatetime.timedelta)r;rrr)rr-)rEr-rrr)rr(r')rrr)rrrr)rr.)r}rrr)rr+)rz dict[str | None, dict[str, str]]rr(r*rl)r int | Nonerztyping.Iterator[bytes])rrrtyping.Iterator[str]rr)rr)rrrz"typing.AsyncGenerator[bytes, None])rrrtyping.AsyncIterator[str])rr),rrrrtrrr;rr.rCrHrTrr,r6rQrYr[r]r_rardrfrnryrrr[rrrr#rrrrrrrrrrrrrr@r7r.r. s '+*.:>"&04)-GN5'5'$ 5' ( 5'  5'5'5'85' 5'.5''5'E5' 5'n0   ^^   ^^AABB   *__  99$88 22  3 377 77 00   ,"GH5 dd**G ) .&6 $ 0& < +r@r.ceZdZdZdddZddZddZdddZ d ddZ d ddZ dd d Z ddd Z d!d Z d"d Z d#d Zd$dZd%dZd&dZd'dZGddej(j*ZGddZy)(r+z- HTTP Cookies, as a mutable mapping. Nc|t|trKt|_t|tr+|j D]\}}|j ||yyt|t r,t|_|D]\}}|j ||yt|trrEcookies r7rtzCookies.__init__8s ?j$7 {DH'4(")--/)JCHHS%()) & {DH% % Ue$ %  ) {DH!++ ,##F+ ,DHr@cd|jvrd|jvry|j|}|j|j}|jj ||y)zO Loads any cookies based on the response `Set-Cookie` headers. z set-cookiez set-cookie2N)rq_CookieCompatResponse_CookieCompatRequestr.rr)rpruurllib_responseurllib_requests r7rzCookies.extract_cookiesIs\ x// /MIYIY4Y 44X>2283C3CD   .Ar@c\|j|}|jj|y)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rradd_cookie_header)rpr.rs r7rzCookies.set_cookie_headerUs&227; "">2r@ciddd|d|ddddd |d t|d |jd d |dt|dddddddddddddidd}tdi|}|jj |y)zU Set a cookie value by name. May optionally include domain and path. versionrrrEportNport_specifiedFdomaindomain_specifieddomain_initial_dot.pathpath_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r)r startswithrrr)rprrErrr}rs r7rz Cookies.set\s  q D  U  D  e  f   V   !&"3"3C"8  D  d4j  e  t  t  t  4 Z&! " u# &!&! F#r@cd}|jD]T}|j|k(s||j|k(s%||j|k(s7|d|}t ||j }V||S|S)z Get a cookie by name. May optionally include domain and path in order to specify exactly which cookie to retrieve. Nz!Multiple cookies exist with name=)rrrrrrE)rprrrrrErrKs r7rz Cookies.getvshh -F{{d">V]]f%<|v{{d': ,(I$&PG"0"99 &  - =N r@ch|||jj|||S|jDcgc]5}|j|k(r$||j|k(r||j|k(r|7}}|D]=}|jj|j|j|j?ycc}w)z Delete a cookie by name. May optionally include domain and path in order to specify exactly which cookie to delete. N)rclearrrr)rprrrrremoves r7deletezCookies.deletes  $"288>>&$5 5(( {{d"6==F#:!4    DF HHNN6==&++v{{ C D s:B/cg}||j|||J|j||jj|y)z Delete all cookies. Optionally include a domain and path in order to only delete a subset of all the cookies. N)rZrr)rprrargss r7rz Cookies.clearsK    KK   % %% KK r@crt|}|jD]}|jj|yrl)r+rr)rprrs r7rzCookies.updates1'"kk (F HH   ' (r@c&|j||Srl)rrs r7rzCookies.__setitem__sxxe$$r@cB|j|}| t||Srl)rrrs r7rzCookies.__getitem__s# =4.  r@c$|j|Srl)r)rprs r7rzCookies.__delitem__s{{4  r@c,t|jSrl)rrrs r7rzCookies.__len__s488}r@c(d|jDS)Nc34K|]}|jywrl)r).0rs r7 z#Cookies.__iter__..s3 3srrs r7rzCookies.__iter__s3$((33r@c(|jD]}yy)NTFr)rpr~s r7__bool__zCookies.__bool__s A r@c dj|jDcgc],}d|jd|jd|jd.c}}d|dScc}w)Nrzz r]rs r7rz4Cookies._CookieCompatRequest.add_unredirected_headers& G +C 5(+DLL  %r@r.r-rr)r>rBr]rBrr)rrrrrtr __classcell__)rs@r7rrs  # , ,r@rc eZdZdZddZddZy)Cookies._CookieCompatResponserc||_yrl)ru)rprus r7rtz&Cookies._CookieCompatResponse.__init__s $DMr@ctjj}|jjj D] \}}|||< |Srl)rJrKrLrurqr)rpinfor>rEs r7rz"Cookies._CookieCompatResponse.infosL==((*D"mm33??A " U"S  " Kr@Nrur.rr)rzemail.message.Message)rrrrrtrrr@r7rrs  % r@rrl)rr$rrrr)rS/) rrBrErBrrBrrBrr)NNN) rrBrrrrrrrrr)rrBrrrrrr)rrrrrr)rrBrErBrr)rrBrrB)rrBrrrrrr)rrrrrtrrrrrrrrrrrrrrurllibr.r-rrrr@r7r+r+3s" B3$:#!      8" DDD D  D0 ( % !4 ,,v~~55,$r@r+)r6rBrrrl)r> str | bytesr6rrr<)rErr6rrr<)rNrBrr)rErBrzlist[dict[str, str]])rfz4typing.Iterable[tuple[typing.AnyStr, typing.AnyStr]]rz4typing.Iterator[tuple[typing.AnyStr, typing.AnyStr]])M __future__rr2rdatetime email.messagerJrr{rWrurllib.requestrcollections.abcrrhttp.cookiejarrrrr r r r _decodersr rrrrrr _exceptionsrrrrrrr _multipartr _status_codesr_typesrrrr r!r"r#r$r%r&r'_urlsr(_utilsr)r*__all__reTypeVarr0r8r?rFrPrariMutableMappingrBr,r-r.r+rr@r7rs"  3,SSA     + 7$&;<V^^DN-1"J ?9}:f##CH-}:@})})@c+c+LFf##CH-Fr@