/j DddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl mZmZddlmZmZddlmZmZmZmZddlmZddlmZmZmZmZmZm Z m!Z!dd l"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/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9dd l:m;Z;ddlZ>gdZ?ddhZ@e jdZBd!dZCd"d#dZDd"d$dZEd%dZFd&dZG d'dZHGdde jeJeJfZKGddZLGddZMGdd e jeJeJfZNy)() annotationsN)AsyncGeneratorMapping)Cookie CookieJar) ByteStreamUnattachedStreamencode_requestencode_response)IndexedCookieJar) 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 Q/root/repos/pocs/video-evals/.venv/lib/python3.12/site-packages/httpx2/_models.py_is_known_encodingr9;s, h  s  $$cPt|tr|S|j|xsdS)zE Coerce str/bytes into a strictly byte-wise HTTP header key. ascii) isinstancebytesencode)keyr7s r8_normalize_header_keyr@Fs&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>)valuer7s r8_normalize_header_valuerGMsH% eS !A$u+OPP <<+G ,,rAcltjj}||d<|jdS)N content-type)failobj)emailmessageMessageget_content_charset) content_typemsgs r8_parse_content_type_charsetrQXs4 --   !C&C  " "4 " 00rAcg}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) rFlinks replace_charsvalrUparamslinkparamr?s r8_parse_header_linksrb`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 r8_obfuscate_sensitive_headersrjsD1 !'')  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-listrrgr@rGr[re _encoding)selfheadersr7rhri bytes_key bytes_values r8__init__zHeaders.__init__s 8: gw 'gmm,DJ" )  O11!X> 5aB  !!9ioo.?"MN O"   O11!X> 5aB  !!9ioo.?"MN O "rAc|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)rprawdecodeUnicodeDecodeError)rqr7r?rFs r8r7zHeaders.encodings >> !. ."&(( JC 8, X. &.DN ~~! .".~~.s"A11 A>=A>c||_yrm)rprqrFs r8r7zHeaders.encodings rAcX|jDcgc] \}}}||f c}}}Scc}}}w)zH Returns a list of the raw header items, as byte pairs. )rn)rqraw_key_rFs r8rxz Headers.raws+ ;?**EE%6Wa% EEEs%c|jDcic]"\}}}|j|jd$c}}}jScc}}}wrm)rnryr7keys)rqrr?_values r8rz Headers.keyss>FJjjQQNAsF 4==)4/QVVXXQs'A ci}|jD]V\}}}|j|j}|j|j}||vr||xxd|z cc<R|||<X|jS)N, )rnryr7valuesrq values_dictrr?rFstr_key str_values r8rzHeaders.valuess~&( !ZZ 1MAsEjj/G T]]3I+%G$"YK(88$'0 G$  1!!##rAci}|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)rnryr7rgrs r8rgz Headers.itemss ') !ZZ 1MAsEjj/G T]]3I+%G$"YK(88$'0 G$  1  ""rAc |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. )rnryr7)rqrr?rFs r8 multi_itemszHeaders.multi_itemssJ _c^h^hii]QPSUZDMM*ELL,GHiiisAAcyrm)rqr?s r8getz Headers.gets.1rAcyrmrrqr?defaults r8rz Headers.gets69rAc0 ||S#t$r|cYSwxYw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyErrorrs r8rz 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. ,)rer>r7rnryextendrYrW) rqr? split_commasget_header_keyritem_key item_valuer split_valuesrFitems r8get_listzHeaders.get_lists ++DMM:,0::  '8Z~~>1   dmm ,  M"$  ME   %++c:J K$ K L M !Ls 9C C ct|}|jD]}||vs|j||jj |jyrm)r-rpoprnr)rqrrr?s r8updatezHeaders.updatesK'"<<> Cd{   '--(rAc0t||jS)Nr6)r-r7rqs r8copyz Headers.copystdmm44rActt|tstS|j}|j ||Srm)r<rNotImplementedrrrqothermergeds r8__or__zHeaders.__or__"s.%)! ! e rAcjt|tstSt|}|j ||Srm)r<rrr-rrs r8__ror__zHeaders.__ror__)s,%)! ! d rAc(|j||Srm)r)rqrs r8__ior__zHeaders.__ior__0s E rAc|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)rer>r7rnryjoinr)rqr?normalized_keyr header_key header_valuergs r8 __getitem__zHeaders.__getitem__4s++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. rwrNr)r>rpre enumeraternreversedr[) rqr?rFset_key set_value lookup_keyidxrr found_indexess r8 __setitem__zHeaders.__setitem__Hs **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)rer>r7rrnrr)rqr?del_keyrrr pop_indexess r8 __delitem__zHeaders.__delitem__\s))+$$T]]38A$**8Mmm4s$4Q!QYQ_Q_QaelQlsm m3- K( C 3 ns B#Bc|jj|j}||jDcgc]\}}}| c}}vScc}}wrm)rer>r7rn)rqr?rrs r8 __contains__zHeaders.__contains__js?YY['' 6 4::>iaac>>>>s A c4t|jSrm)iterrrs r8__iter__zHeaders.__iter__nsDIIK  rAc,t|jSrm)lenrnrs r8__len__zHeaders.__len__qs4::rAc t|}|jDcgc] \}}}||f }}}}|jDcgc] \}}}||f }}}}t|t|k(S#t$rYywxYwcc}}}wcc}}}w)NF)r-rZrnsorted)rqr other_headersrr?rF self_list other_lists r8__eq__zHeaders.__eq__ts #ENM8r7_preparerr read) rqrrUr_rrrrrrrrrrOs r8ruzRequest.__init__slln %~3s83s63Jw' * 2"Z8H "7G4W'':J ] ]^b c >'+||'7'7'GL,AO[!4!4T\\5J5J!Kae OGV MM' " DK&*- ."!DKrAc^|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) rgrerr setdefaultrUhostr[netlocrr-rx)rqdefault_headersr?rF auto_headershas_hosthas_content_lengths r8rzRequest._prepares)//1 0JCyy{..3F$,,3Vyy{116F$,,6V LL # #C / 035 T\\)-=dATX\XdXdAdDHHMM   $((// : ;!dkk5V&V    9 :|dll.>.>>? rAcFt|ds t|jSN_content)hasattrrrrs r8rzRequest.contentstZ( " "}}rAc&t|dszt|jtjsJdj |j|_t|jtst|j |_|j S)6 Read and return the request content. rrA)rr<rrIterablerrr rs r8rz Request.readsdtZ(dkk6??; ;;HHT[[1DMdkk:6)7 }}rAcjKt|dsMt|jtjsJdj |j2cgc3d{}| |j S76ncc}wc}|_t|jtr)rrrCrUr)rqrrUs r8rzRequest.__repr__s=^^,, $((m:,a br::rAct|jjDcic] \}}|dvs ||c}}Scc}}w)N)rr__dict__rgrqnamerFs r8 __getstate__zRequest.__getstate__s3/3}}/B/B/Dm eTlHle mmms 44cz|jD]\}}t|||i|_t|_yrm)rgsetattrrr rrqstaterrFs r8 __setstate__zRequest.__setstate__s8 ;;= 'KD% D$ & '&( rA)rrCrUz URL | strr_zQueryParamTypes | NonerrrrCookieTypes | NonerzRequestContent | NonerzRequestData | NonerzRequestFiles | Nonerztyping.Any | Noner'SyncByteStream | AsyncByteStream | NonerzRequestExtensions | Nonerrr zdict[str, str]rrrr=rrdict[str, typing.Any]r#r*rr) rrrrurrrrrrrr$rrAr8r.r.s *.&*&*)-#'%)"&:>/36!6!6! ' 6! $ 6!$6!'6!!6!#6! 6!86!-6! 6!p@,  ; n)rAr.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/Nrw) rrrtexthtmlrrrequestrhistorydefault_encodingc ||_t||_||_d|_| in t | |_| gn t| |_d|_ d|_ | |_ |Qt||||\}}|j|||_t|t r|j#d|_y||_d|_y)NFr) status_coder-rr_request next_requestrrror0 is_closedis_stream_consumedr1r rrr<r r_num_bytes_downloaded) rqr3rrrr-r.rrr/rr0r1s r8ruzResponse.__init__s'w' (/ -1 * 2"Z8H$_r$w- "' 0 >-gtT4HOGV MM' " DK&*- &'"!DK%&"rAc|jD]C\}}|jdk(rd|jvr(|jj||Ey)Nrr)rgrerrr)rqr r?rFs r8rzResponse._prepareFsP)//1 0JCyy{116F$,,6V LL # #C /  0rAc~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;)rqstream_elapseds r8r<zResponse.elapsedMsC tZ(8? YX\8]N)%%lm m}}rAc||_yrm)r;)rqr<s r8r<zResponse.elapsedZs  rAcH|j td|jS)zR Returns the request instance associated to the current response. z7The request instance has not been set on this response.)r4r>rs r8r/zResponse.request^s$ == XY Y}}rAc||_yrm)r4r|s r8r/zResponse.requestgs  rAcf |jd}|jddS#t$rYywxYw)N http_versionr;ignoreerrorszHTTP/1.1)rryr)rqrDs r8rDzResponse.http_versionksB A"&//."AL &&wx&@ @  s $ 00c |jd}|jddS#t$r"tj|j cYSwxYw)N reason_phraser;rErF)rryrrget_reason_phraser3)rqrIs r8rIzResponse.reason_phrasetsV B#'???#CM!'''A A =**4+;+;< < =s$(AAc.|jjS)zA Returns the URL for which the request was made. )r/rUrs r8rUz Response.url}s ||rAcFt|ds t|jSr)rrrrs r8rzResponse.contentstZ(!# #}}rAc&t|dsz|j}|sd|_|jSt|jxsd}dj |j |j|jg|_|jS)N_textrTrwr6)rrrNrr7rryflush)rqrdecoders r8r-z Response.textsrtW%llG zz&t}}/GHWWgnnT\\&BGMMO%TU zzrAct|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. rprrw)rcharset_encodingr9r<r1rCrrp)rqr7s r8r7zResponse.encodingsvt[),,H'9('Cd33S9#44HT:.#44T]]CH%0DN~~rAc@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. rNz?Setting encoding after `text` has been accessed is not allowed.N)rrZrpr|s r8r7zResponse.encodings! 4 !^_ _rAcT|jjd}|yt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)rrrrQ)rqrOs r8rRzResponse.charset_encodings, ||''7  *<88rAct|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) rrrrrWrerrchildrenrVr)rqrrF encodingsr7rPs r8_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)r4r>r^ror3rformatr)rqr/rL status_class error_typesrus r8raise_for_statuszResponse.raise_for_statuss-- ?k  ??K  % %w w  ''3. '"  !__\3HI ..*.=gwFFrAc Btj|jfi|Srm)jsonlibloadsr)rqkwargss r8rz Response.json>s}}T\\4V44rAct|ds*t|_|jj||jS)N_cookies)rr,rextract_cookiesrs r8rzResponse.cookiesAs1tZ(#IDM MM ) )$ /}}rAc|jjd}|iSt|Dcic]'}|jdxs|jd|)c}Scc}w)zI Returns the parsed header links of the response, if any r`relrU)rrrrb)rqheaderr`s r8r\zResponse.linksHsV !!&) >IGZ[aGbct%3DHHUOd:cccs,Ac|jSrm)r8rs r8num_bytes_downloadedzResponse.num_bytes_downloadedSs)))rAc<d|jd|jdS)Nz )r3rIrs r8rzResponse.__repr__Ws%T--.a0B0B/C2FFrAcr|jjDcic] \}}|dvr||c}}Scc}}w)N)rrr6rVrrs r8rzResponse.__getstate__ZsB $}}224 eLL %K   s3c|jD]\}}t|||d|_i|_t |_y)NT)rgr!r6rr rr"s r8r$zResponse.__setstate__as? ;;= 'KD% D$ & '&( rAczt|ds$dj|j|_|jS)7 Read and return the response content. rrA)rr iter_bytesrrs r8rz Response.readhs/tZ(HHT__%67DM}}rAc#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/) rrrrangemaxrZrrr4iter_rawryrO)rqrirPchunker raw_bytesdecodedchunks r8rzResponse.iter_bytesps8 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. rwr6rrN)rr7rrr4rryrOrqrrPr byte_content text_contentrs r8 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)rrr4rryrOrqrPr-lines r8 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)r7rr6rr<rr(r>r8rrr4rryrOclose)rqrrraw_stream_bytesrs r8rzResponse.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>r6rr4rrs r8rzResponse.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)rrNrA)r contextlibaclosing aiter_bytesrr)rqpartsrs r8rzResponse.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)rrrrrrZrrr4rr aiter_rawryrO) rqrrrPr raw_streamrrrs r8rzResponse.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)rr7rrr4rryrOrs r8 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)rrr4rryrOrs r8 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)r7rr6rr<rrr>r8r __aiter__rr4rryrOraclose)rqrrrrrs r8rzResponse.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>r6rr4rrs r8rzResponse.aclose&sv $++7ST T~~!DN 7 +kk((*** + ++ + +s0AB B/A>0B4 B >BB B )r3rrrrrzResponseContent | Noner-rr.rrrrr&r/zRequest | NonerzResponseExtensions | Noner0zlist[Response] | Noner1z*str | typing.Callable[[bytes], str | None]rrr')rdatetime.timedelta)r<rrr)rr.)rFr.rrr)rr)r()rrr)rrrr)rr/)r~rrr)rr,)rz dict[str | None, dict[str, str]]rr)r+rm)r int | Nonerztyping.Iterator[bytes])rrrtyping.Iterator[str]rr)rr)rrrz"typing.AsyncGenerator[bytes, None])rrrtyping.AsyncIterator[str])rr),rrrrurrr<rr/rDrIrUrr-r7rRrZr\r^r`rbrergrorzrrr\rrrr$rrrrrrrrrrrrrrAr8r/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& < +rAr/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|tr2283C3CD   .ArAc\|j|}|jj|y)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rradd_cookie_header)rqr/rs r8rzCookies.set_cookie_headerVs&227; "">2rAciddd|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. versionrrrFportNport_specifiedFdomaindomain_specifieddomain_initial_dot.pathpath_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r)r startswithrrr)rqrrFrrr~rs r8rz Cookies.set]s  q D  U  D  e  f   V   !&"3"3C"8  D  d4j  e  t  t  t  4 Z&! " u# &!&! F#rAcd}|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=)rrrrrrF)rqrrrrrFrrLs r8rz Cookies.getwshh -F{{d">V]]f%<|v{{d': ,(I$&PG"0"99 &  - =N rAch|||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)rqrrrrremoves r8deletezCookies.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)r[rr)rqrrargss r8rz Cookies.clearsK    KK   % %% KK rAcrt|}|jD]}|jj|yrm)r,rr)rqrrs r8rzCookies.updates1'"kk (F HH   ' (rAc&|j||Srm)rrs r8rzCookies.__setitem__sxxe$$rAcB|j|}| t||Srm)rrrs r8rzCookies.__getitem__s# =4.  rAc$|j|Srm)r)rqrs r8rzCookies.__delitem__s{{4  rAc,t|jSrm)rrrs r8rzCookies.__len__s488}rAc(d|jDS)Nc34K|]}|jywrm)r).0rs r8 z#Cookies.__iter__..s3 3srrs r8rzCookies.__iter__s3$((33rAc(|jD]}yy)NTFr)rqrs r8__bool__zCookies.__bool__s A rAc dj|jDcgc],}d|jd|jd|jd.c}}d|dScc}w)Nrzz rs"  3,SS&A     + 7$&;<V^^DN-1"J ?9}:f##CH-}:@})})@c+c+LFf##CH-FrA