j>ddlmZddlZddlZddlZddlZddlZddl 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/d0dZBd/d1dZCd2dZDd3d!ZEd4d%ZFGd&d'e jGeHeHfZIGd(d)ZJGd*d+ZKGd,d-e jGeHeHfZLdS)5) 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_TencodingstrreturnboolcT tj|n#t$rYdSwxYwdS)z7 Return `True` if `encoding` is a known codec. FT)codecslookup LookupErrorr1s ; 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_charsvalrYparamslinkparamr<s r:_parse_header_linksrf_s= #%EM KK & &E  x&&   "))C++KC " " "rCCC "syy**+\\#&& H HE "[[-- UU    -2[[-G-GD=)) * * T Ls#AA! A!B,, B:9B:items4typing.Iterable[tuple[typing.AnyStr, typing.AnyStr]]4typing.Iterator[tuple[typing.AnyStr, typing.AnyStr]]c#K|D]D\}}t|tvrtd|}||fVEdS)Nz[secure]) match_type_of)r*lowerSENSITIVE_HEADERSr))rgkvs r:_obfuscate_sensitive_headersrpsb1 !''))   1 1 1 !<<dZ d?dZ d@dZ dAdZ e jdBdZe jdCdZdDdEd ZdFdGd%ZdDdHd&ZdId'ZdJd*ZdJd+ZdKd-ZdLd.ZdMd/ZdNd0ZdOd2ZdPd4ZdQd6ZdRd7Zd;d8ZdS)Sr,z9 HTTP headers, as a case-insensitive multi-dict. NheadersHeaderTypes | Noner1r>r3Nonec0g|_t|trt|j|_nt|trj|D]T\}}t ||}t||}|j|| |fUnY|W|D]T\}}t ||}t||}|j|| |fU||_ dSN) _listrBr,listrrgrDrJr_rl _encoding)selfrrr1rnro bytes_key bytes_values r:__init__zHeaders.__init__s 8: gw ' ' Ogm,,DJJ  ) ) O  O O11!X>> 5aBB  !!9ioo.?.?"MNNNN O  O O11!X>> 5aBB  !!9ioo.?.?"MNNNN!rEr2c|j^dD]T}|jD]A\}} ||||1#t$rYn wxYw||_nUd|_|jS)zn Header encoding is mandated as ascii, but we allow fallbacks to utf-8 or iso-8859-1. N)rAutf-8z iso-8859-1)ryrawdecodeUnicodeDecodeError)rzr1r<rFs r:r1zHeaders.encodings > !. . ."&(  JC 8,,, X....- &.DNE ".~s*A AArFc||_dSrv)ryrzrFs r:r1zHeaders.encodings rElist[tuple[bytes, bytes]]c$d|jDS)zH Returns a list of the raw header items, as byte pairs. cg|] \}}}||f Sr).0raw_key_rFs r: zHeaders.raw..s$EEE%6Wa% EEErErwrzs r:rz Headers.raws FE$*EEEErEtyping.KeysView[str]cNfdjDS)NcNi|]!\}}}|jd"Srvrr1)rrr<_valuerzs r: z Headers.keys..s/QQQNAsF 4=))4QQQrE)rwkeysrs`r:rz Headers.keyss+QQQQdjQQQVVXXXrEtyping.ValuesView[str]ci}|jD]W\}}}||j}||j}||vr||xxd|z cc<R|||<X|S)N, )rwrr1valuesrz values_dictrr<rFstr_key str_values r:rzHeaders.valuess&( !Z 1 1MAsEjj//G T]33I+%%G$$$(8Y(8(88$$$$'0 G$$!!###rEtyping.ItemsView[str, str]ci}|jD]W\}}}||j}||j}||vr||xxd|z cc<R|||<X|S)z Return `(key, value)` items of headers. Concatenate headers into a single comma separated value when a key occurs multiple times. r)rwrr1rgrs r:rgz Headers.itemss ') !Z 1 1MAsEjj//G T]33I+%%G$$$(8Y(8(88$$$$'0 G$$  """rElist[tuple[str, str]]c*fdjDS)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. cg|]:\}}}|j|jf;Srr)rrr<rFrzs r:rz'Headers.multi_items..sBiii]QPSUZDM**ELL,G,GHiiirErrs`r: multi_itemszHeaders.multi_itemss$ jiii^b^hiiiirEr<cdSrvr)rzr<s r:getz Headers.gets.1crEdefaultr0str | _TcdSrvrrzr<rs r:rz Headers.gets69crE _T | Nonestr | _T | Nonec8 ||S#t$r|cYSwxYw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyErrorrs r:rz Headers.gets5  9    NNN s  F split_commasr4 list[str]c|jfdjD}|s|Sg}|D]4}|d|dD5|S)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. c|g|]8\}}}|k|j9Sr)rlrr1)rritem_key item_valueget_header_keyrzs r:rz$Headers.get_list.. sN   '8Z~~>11   dm , ,111rEc6g|]}|Sr)r[)ritems r:rz$Headers.get_list..s K K K$ K K KrE,)rlrCr1rwextendr])rzr<rr split_valuesrFrs` @r:get_listzHeaders.get_lists ++DM::     +/:     M"$  M ME    K K%++c:J:J K K K L L L LrEct|}|D]}||vr|||j|jdSrv)r,rpoprwr)rzrrr<s r:updatezHeaders.updates]'""<<>>  Cd{{  '-(((((rEc.t||jS)Nr9)r,r1rs r:copyz Headers.copystdm4444rEotherMapping[str, str]ct|tstS|}|||Srv)rBrNotImplementedrrrzrmergeds r:__or__zHeaders.__or__!s>%)) "! ! e rEct|tstSt|}|||Srv)rBrrr,rrs r:__ror__zHeaders.__ror__(s<%)) "! ! d rErc0|||Srv)r)rzrs r:__ior__zHeaders.__ior__/s E rEc|jfdjD}|rd|St |)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 cXg|]&\}}}|k |j'Srr)rr header_key header_valuenormalized_keyrzs r:rz'Headers.__getitem__..<sD   +:|^++    . .+++rEr)rlrCr1rwjoinr)rzr<rgrs` @r: __getitem__zHeaders.__getitem__3sz++DM::     /3z     $99U## #smmrEc||jpd}||jpd}|fdt|jD}t |ddD] }|j|= |r|d}||f|j|<dS|j||fdS)zs Set the header `key` to `value`, removing any duplicate entries. Retains insertion order. rc.g|]\}\}}}|k|Srr)ridxrr lookup_keys r:rz'Headers.__setitem__..Ps1jjj!6&6q(AS[_iSiSiSiSiSirErNr)rCryrl enumeraterwreversedr_)rzr<rFset_key set_value found_indexesrrs @r: __setitem__zHeaders.__setitem__Gs **T^6w77LL!:7;; ]]__ jjjj)DJ:O:Ojjj M!""-..  C 3  @"C& I>DJsOOO J  w I> ? ? ? ? ?rEc||jfdt|jD}|st |t |D] }|j|= dS)z* Remove the header `key`. cRg|]#\}\}}}|k!|$Sr)rl)rrrrdel_keys r:rz'Headers.__delitem__..as=mmm4s$4Q!QYQ_Q_QaQaelQlQlsQlQlQlrEN)rlrCr1rrwrr)rzr< pop_indexesrrs @r: __delitem__zHeaders.__delitem__[s))++$$T]33mmmm $*8M8Mmmm  3-- K((  C 3  rE typing.Anyc||j}|d|jDvS)Ncg|]\}}}| Srr)rrr<s r:rz(Headers.__contains__..ks>>>iaac>>>rE)rlrCr1rw)rzr<rs r: __contains__zHeaders.__contains__is;YY[['' 66 >>4:>>>>>rEtyping.Iterator[typing.Any]cDt|Srv)iterrrs r:__iter__zHeaders.__iter__msDIIKK   rEintc*t|jSrv)lenrwrs r:__len__zHeaders.__len__ps4:rEc t|}n#t$rYdSwxYwd|jD}d|jD}t|t|kS)NFcg|] \}}}||f Srrrrr<rFs r:rz"Headers.__eq__..ys"BBBmaec5\BBBrEcg|] \}}}||f Srrrs r:rz"Headers.__eq__..zs"LLL}q#usElLLLrE)r,r^rwsorted)rzr other_headers self_list other_lists r:__eq__zHeaders.__eq__ss #ENNMM   55 CBtzBBB LL 8KLLL i  F:$6$666s   c.|jj}d}|jdkr d|j}tt |}t |}t|t|k}|r |d||dS|d||dS)NrXrAz , encoding=()) __class____name__r1rxrprdictr)rz class_name encoding_stras_listas_dictno_duplicate_keyss r:__repr__zHeaders.__repr__}s^,  =G # #:::L3D4D4D4F4FGGHHw--LLCLL8  > ==7=l=== =99w9,9999rENN)rrrsr1r>r3rtr3r2rFr2r3rt)r3r)r3r)r3r)r3r)r3r)r<r2r3r>)r<r2rr0r3rrv)r<r2rrr3r)F)r<r2rr4r3r)rrrsr3rt)r3r,)rrr3r,)rrr3r,)r<r2r3r2)r<r2rFr2r3rt)r<r2r3rt)r<rr3r4)r3rr3r)rrr3r4)r __module__ __qualname____doc__r}propertyr1setterrrrrgrtypingoverloadrrrrrrrrrrrrrrrrrEr:r,r,sn '+#""""",X0__FFFXF YYYY $ $ $ $ # # # #jjjj _111_1 _999_9,)))))5555(@@@@(     ????!!!!7777 : : : : : :rEr,c teZdZdddddddddd d(dZd)dZed*d Zd*d!Zd*d"Zd+d#Z d,d%Z d-d'Z dS).r-N) rcrrcookiescontentdatafilesjsonstream extensionsmethodr2rY URL | strrcQueryParamTypes | NonerrrsrCookieTypes | NonerRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | Noner'SyncByteStream | AsyncByteStream | NonerRequestExtensions | Noner3rtc ||_|t|nt|||_t ||_| int | |_|r"t| || |j d} t|||| t| r| |jjnd\}} ||| |_t#| t$r|dSdS| |_dS)N)rcrM)rK)rrrrboundary)upperrr(rYr,rrrrr+set_cookie_headerrr rrCr1_preparerrBr read) rzrrYrcrrrrrrrrrrKs r:r}zRequest.__init__sFllnn %~3s8883s63J3J3Jw'' * 2""Z8H8H  5 G   . .t 4 4 4 >'+|'7'7'G'GL,AO[!e!4!4T\5J!K!K!Kae OGV MM' " " " DK&*--    "!DKKKrEdefault_headersdict[str, str]c|D]d\}}|dkr d|jvr'|dkr d|jvrI|j||eg}d|jv}d|jvpd|jv}|s-|jjr!|d|jjf|s|jdvr|dt||jj z|_dS) Ncontent-lengthzTransfer-Encodingtransfer-encodingzContent-LengthHostsHost)POSTPUTPATCHQUERY)sContent-Length0) rgrlrr setdefaultrYhostr_netlocrr,r)rzr%r<rF auto_headershas_hosthas_content_lengths r:r#zRequest._prepares()//11 0 0JCyy{{...3F$,3V3Vyy{{1116F$,6V6V L # #C / / / /24 T\)-=dATX\XdAd >?? rEr?cLt|dst|jSN_content)hasattrrr8rs r:rzRequest.contents(tZ(( # "" "}rEct|dsst|jtjsJd|j|_t|jtst|j|_|jS)6 Read and return the request content. r8rE)r9rBrr Iterablerr8r rs r:r$z Request.readsttZ(( 8dk6?;; ; ;;HHT[11DMdk:66 8)77 }rEc:Kt|dst|jtjsJdd|j2d{V|_t|jtst|j|_|jS)r;r8rEc"Kg|3d{V}| 6Srvrrparts r:rz!Request.aread..s.%I%I%I%I%I%I%I%ITd%I%I%I%IN)r9rBrr  AsyncIterablerr8r rs r:areadz Request.areadstZ(( 8dk6+?@@ @ @@HH%I%IT[%I%I%I%I%I%I%I%I%IJJDMdk:66 8)77 }rEcd|jj}t|j}d|d|jd|dS)N)rrr2rYr)rzrrYs r:rzRequest.__repr__s<^, $(mm:::: ::::::rEdict[str, typing.Any]cHd|jDS)Nc"i|] \}}|dv || S))rrrrnamerFs r:rz(Request.__getstate__..s)mmm eTlHlHleHlHlHlrE__dict__rgrs r: __getstate__zRequest.__getstate__s$mmt}/B/B/D/DmmmmrEstatec|D]\}}t|||i|_t|_dSrv)rgsetattrrr rrzrNrJrFs r: __setstate__zRequest.__setstate__sJ ;;== ' 'KD% D$ & & & &&(( rE)rr2rYrrcrrrrsrrrrrrrrrrrrrrr3rtr%r&r3rtr3r?rr3rFrNrFr3rt) rrrr}r#r rr$rCrrMrRrrEr:r-r-s *.&*&*)-#'%)"&:>/36!6!6!6!6!6!p@@@@,X        ;;;; nnnn))))))rEr-c eZdZddddddddddd d[dZd\dZed]d Zejd^d"Zed_d$Zejd`d&Zedad(Z edad)Z edbd+Z edcd-Z edad.Z eddd/Zejded0Zeddd1Zdfd3Zedgd5Zedgd6Zedgd7Zedgd8Zedgd9Zedgd:Zedgd;Zdhd<Zdid>Zedjd@ZedkdBZedldCZdadDZdmdFZdndHZdcdIZ dodpdMZ!dodqdOZ"drdPZ#dodpdQZ$dsdRZ%dcdSZ&dodtdUZ'dodudWZ(dvdXZ)dodtdYZ*dsdZZ+dS)wr.Nr) rrrtexthtmlrrrequestrhistorydefault_encoding status_coderrrrsrResponseContent | NonerXr>rYrrrrrZRequest | NonerResponseExtensions | Noner[list[Response] | Noner\*str | typing.Callable[[bytes], str | None]r3rtc ||_t||_||_d|_| int | |_| gnt| |_d|_ d|_ | |_ |[t||||\}}| |||_t|t r|n||_d|_dS)NFr)r]r,rr_request next_requestrrrxr[ is_closedis_stream_consumedr\r r#rrBr r$_num_bytes_downloaded) rzr]rrrrXrYrrrZrr[r\s r:r}zResponse.__init__s'w'' (/ -1 * 2""Z8H8H$_rr$w-- "' 0 >-gtT4HHOGV MM' " " " DK&*--  !DK%&"""rEr%r&c|D]B\}}|dkr d|jvr'|j||CdS)Nr)r()rgrlrrr0)rzr%r<rFs r:r#zResponse._prepareEsj)//11 0 0JCyy{{1116F$,6V6V L # #C / / / /  0 0rEdatetime.timedeltact|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.)r9getattrr RuntimeErrorrl)rzstream_elapseds r:rmzResponse.elapsedLsN tZ(( n8? YX\8]8]N)%%lmm m}rErmc||_dSrv)rl)rzrms r:rmzResponse.elapsedYs  rEr-c<|jtd|jS)zR Returns the request instance associated to the current response. Nz7The request instance has not been set on this response.)rdrors r:rZzResponse.request]s# = XYY Y}rErFc||_dSrv)rdrs r:rZzResponse.requestfs  rEr2cn |jd}|ddS#t$rYdSwxYw)N http_versionrAignoreerrorszHTTP/1.1)rrr)rzrus r:ruzResponse.http_versionjsS A"&/."AL &&wx&@@ @   :: s & 44c |jd}|ddS#t$rtj|jcYSwxYw)N reason_phraserArvrw)rrrrget_reason_phraser])rzrzs r:rzzResponse.reason_phrasessf B#'??#CM!'''AA A = = =*4+;<< < < < =s &#A  A r(c|jjS)zA Returns the URL for which the request was made. )rZrYrs r:rYz Response.url|s |rEr?cLt|dst|jSr7)r9rr8rs r:rzResponse.contents(tZ(( $!## #}rEc t|dsn|j}|sd|_n]t|jpd}d||j|g|_|jS)N_textrXrr9)r9rrrr1rrflush)rzrdecoders r:rXz Response.texts{tW%% VlG V %t}/GHHHWWgnnT\&B&BGMMOO%TUU zrEc t|dsm|j}|t|sLt|jt r|j}n*t|dr||j}|pd|_|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. ryNr8r)r9charset_encodingr;rBr\r2r8ry)rzr1s r:r1zResponse.encodingst[)) 1,H'9('C'Cd3S99D#4HHT:..D#44T]CCH%0DN~rEcRt|drtd||_dS)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. rz?Setting encoding after `text` has been accessed is not allowed.N)r9r^ryrs r:r1zResponse.encodings1 4 ! ! `^__ _rEc\|jd}|dSt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)rrrrT)rzrKs r:rzResponse.charset_encodings2 |''77  4*<888rErcLt|ds|jdd}d|D}td|D}t |jdkr|jd|_n"|jr||_nt|_|jS) 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)rcZg|](}|)Sr)r[rl)rrFs r:rz1Response._get_content_decoder..s,CCC5,,..CCCrEcg|] }|dk| S)identityr)rr1s r:rz1Response._get_content_decoder..s##a#a#a(V`J`J`HJ`J`J`rErr)r9rrrrrchildrenrr)rzr encodingsrs r:_get_content_decoderzResponse._get_content_decoders tZ(( 2\**+=D*QQFCCFCCCI"#a#aY#a#a#abbG7#$$)) ' 0 3 ! 2 ' / 1 1 }rEr4c4tj|jS)zU A property which is `True` for 1xx status codes, `False` otherwise. )ris_informationalr]rs r:rzResponse.is_informationals %d&6777rEc4tj|jS)zU A property which is `True` for 2xx status codes, `False` otherwise. )r is_successr]rs r:rzResponse.is_successs  0111rEc4tj|jS)a A property which is `True` for 3xx status codes, `False` otherwise. Note that not all responses with a 3xx status code indicate a URL redirect. Use `response.has_redirect_location` to determine responses with a properly formed URL redirection. )r is_redirectr]rs r:rzResponse.is_redirects !1222rEc4tj|jS)zU A property which is `True` for 4xx status codes, `False` otherwise. )ris_client_errorr]rs r:rzResponse.is_client_error $T%5666rEc4tj|jS)zU A property which is `True` for 5xx status codes, `False` otherwise. )ris_server_errorr]rs r:rzResponse.is_server_errorrrEc4tj|jS)z] A property which is `True` for 4xx and 5xx status codes, `False` otherwise. )ris_errorr]rs r:rzResponse.is_errors ~d.///rEc|jtjtjtjtjtjfvod|jvS)zs Returns True for 3xx responses with a properly formed URL redirection, `False` otherwise. Location)r]rMOVED_PERMANENTLYFOUND SEE_OTHERTEMPORARY_REDIRECTPERMANENT_REDIRECTrrrs r:has_redirect_locationzResponse.has_redirect_locationsH  ' ((   +dl* rEc|j}|td|jr|S|jrd}nd}|jdz}dddd d }||d }||| }t||| )z> Raise the `HTTPStatusError` if one occurred. NzYCannot 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)rZresponse)rdrorrr]rformatr)rzrZrP status_class error_typesrs r:raise_for_statuszResponse.raise_for_statuss- ?k  ? K  % w Gw  '3. '"   !__\3HII ..*.==gwFFFFrEkwargsc 0tj|jfi|Srv)jsonlibloadsr)rzrs r:rz Response.json=s}T\44V444rEr+ct|ds-t|_|j||jS)N_cookies)r9r+rextract_cookiesrs r:rzResponse.cookies@s=tZ(( 0#IIDM M ) )$ / / /}rE dict[str | None, dict[str, str]]cp|jd}|iSdt|DS)zI Returns the parsed header links of the response, if any rdNcdi|]-}|dp|d|.S)relrY)r)rrds r:rz"Response.links..Ps3ccct%3DHHUOOdcccrE)rrrrf)rzheaders r:r`zResponse.linksGsA !!&)) >IccGZ[aGbGbccccrEc|jSrv)rhrs r:num_bytes_downloadedzResponse.num_bytes_downloadedRs ))rEc(d|jd|jdS)Nz )r]rzrs r:rzResponse.__repr__Vs!FT-FF0BFFFFrErFcHd|jDS)Nc"i|] \}}|dv || S))rrrfrrrIs r:rz)Response.__getstate__..Zs4   eLLL %LLLrErKrs r:rMzResponse.__getstate__Ys1  #}2244    rErNc|D]\}}t|||d|_i|_t |_dS)NT)rgrPrfrr rrQs r:rRzResponse.__setstate__`sQ ;;== ' 'KD% D$ & & & &&(( rEct|ds,d||_|jS)7 Read and return the response content. r8rE)r9r iter_bytesr8rs r:r$z Response.readgs;tZ(( 8HHT__%6%677DM}rE chunk_size int | Nonetyping.Iterator[bytes]c#Kt|drb|t|jn|}tdt|jt |dD]}|j|||zVdS|}t |}t|j5| D]6}| |D]}| |D]}|V7| D]}| |D]}|V| D]}|V ddddS#1swxYwYdSz A byte-iterator over the decoded response content. This allows us to handle gzip, deflate, brotli, and zstd encoded responses. r8NrrrrZ) r9rr8rangemaxrr rrditer_rawrr)rzrirchunker raw_bytesdecodedchunks r:rzResponse.iter_bytesos 4 $ $ /9/AT]+++zJ1c$-00#j!2D2DEE 8 8mAJ$677777 8 8//11G!Z888G 777 !%((I#*>>)#<#<((%,^^G%<%<((E"'KKKK(( '}}$$G!(!8!8$$# $$]]__  EKKKK  s.BEEEtyping.Iterator[str]c#Kt|jpd}t|}t|j5|D]3}||}||D]}|V4|}||D]}|V|D]}|V ddddS#1swxYwYdSz A str-iterator over the decoded response content that handles both gzip, deflate, etc but also detects the content's string encoding. rr9rrN)rr1rrrdrrrrzrrr byte_content text_contentrs r: iter_textzResponse.iter_textsU t}'?@@@444 T] 3 3 3   $ 1 1  &~~l;; $^^L99  EKKKK "==??L  55                          sBC!!C%(C%c# Kt}t|j5|D]}||D]}|V|D]}|V ddddS#1swxYwYdSNr)rrrdrrrrzrrXlines r: iter_lineszResponse.iter_liness-- T] 3 3 3  ((  #NN400DJJJJ                        sABB Bc#bK|jrt|jrtt |jt stdd|_d|_t|} t|j 5|jD];}|xjt|z c_| |D]}|V< dddn #1swxYwY|D]}|V |dS#|wxYw)@ A byte-iterator over the raw response content. z5Attempted to call a sync iterator on an async stream.TrrrN)rgrrfrrBrr'rorhr rrdrrrclose)rzrrraw_stream_bytesrs r:rzResponse.iter_raws  " # "" " > !.. $+~66 XVWW W"&%&"444  777 $ $(, $$$..#6F2G2GG..!(0@!A!A$$# $$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ !     JJLLLLLDJJLLLLs15D AC DCD"C#DD.ct|jtstd|jsPd|_t |j5|jddddS#1swxYwYdSdS) 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)rBrr'rorfrrdrrs r:rzResponse.closes $+~66 USTT T~ $!DN 777 $ $ !!### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A44A8;A8c(Kt|dsztj|4d{V}dd|2d{V|_dddd{Vn#1d{VswxYwY|jS)rr8NrEc"Kg|3d{V}| 6Srvrr?s r:rz"Response.aread..s.)G)G)G)G)G)G)G)G$)G)G)G)GrA)r9 contextlibaclosing aiter_bytesrr8)rzpartss r:rCzResponse.areadsBtZ(( I!*4+;+;+=+=>> I I I I I I I% #)G)G)G)G)G)G)G)G)G)G)G H H  I I I I I I I I I I I I I I I I I I I I I I I I I I I}s+A<< B B"typing.AsyncGenerator[bytes, None]cXKt|drc|t|jn|}tdt|jt |dD]}|j|||zWVdS|}t |}t|j5tj | 4d{V}|23d{V}| |D]}| |D]}|WV =6 dddd{Vn#1d{VswxYwY| D]}| |D]}|WV | D]}|WV ddddS#1swxYwYdSr)r9rr8rrrr rrdrr aiter_rawrr) rzrrrr raw_streamrrrs r:rzResponse.aiter_bytess 4 $ $ /9/AT]+++zJ1c$-00#j!2D2DEE 8 8mAJ$6777777 8 8//11G!Z888G 777 %.t~~/?/?@@,,,,,,,J+5,,,,,,,i'.~~i'@'@,,G)0)@)@,,&+ ,,,6:,,,,,,,,,,,,,,,,,,,,,,,,,,, '}}$$G!(!8!8$$# $$]]__  EKKKKK  sC/-FD0D%8D0F0 D: :F=D: >AFF#&F#typing.AsyncIterator[str]cKt|jpd}t|}t|j5|23d{V}||}||D]}|WV:6|}||D]}|WV|D]}|WV ddddS#1swxYwYdSr)rr1rrrdrrrrs r: aiter_textzResponse.aiter_texts} t}'?@@@444 T] 3 3 3  &*&6&6&8&8       l&~~l;; $^^L99  EKKKKK '9#==??L  55                          sC*BBC**C.1C.c0Kt}t|j5|23d{V}||D]}|WV%6|D]}|WV ddddS#1swxYwYdSr)rrrdrrrrs r: aiter_lineszResponse.aiter_liness-- T] 3 3 3  "oo//       d#NN400DJJJJJ0                        sB A  !.. $+77 XVWW W"&%&"444&&((  777 $ $.4$$$$$$$*..#6F2G2GG..!(0@!A!A$$# $/5f $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ !    &.11 &mmoo%%%%%%%++--         &.11 &mmoo%%%%%%%++--        s=E)#C6&C(,=C6* E)6C::E)=C:>E))A F4cKt|jtstd|jsVd|_t |j5|jd{VddddS#1swxYwYdSdS)rz2Attempted to call an async close on a sync stream.TrN)rBrrrorfrrdrrs r:rzResponse.aclose%s $+77 USTT T~ +!DN 777 + +k((********* + + + + + + + + + + + + + + + + + + + +s A<<BB)r]rrrrsrr^rXr>rYr>rrrrrZr_rr`r[rar\rbr3rtrS)r3rj)rmrjr3rt)r3r-)rFr-r3rtr)r3r(rT)r3r>r)r3rr3r4)r3r.)rrr3r)r3r+)r3rrrUrVrv)rrr3r)rrr3rr3r)r3rt)rrr3r)rrr3r)r3r),rrrr}r#r rmr rZrurzrYrrXr1rrrrrrrrrrrrr`rrrMrRr$rrrrrrCrrrrrrrEr:r.r. s '+*.:>"&04)-GN5'5'5'5'5'5'n0000   X  ^   ^ X ^^AAAXABBBXB   X X XX*_   _ 999X9$888X8 222X2  3 3 3X 3777X7 777X7 000X0    X ,"G"G"G"GH5555X dddXd***X*GGGG    ))))     .&6 $ $ $ $     0&     < + + + + + +rEr.ceZdZdZd*d+dZd,d Zd-d Zd.d/dZ d0d1dZ d2d3dZ d2d4dZ d*d+dZ d5dZ d6dZ d7dZd8d Zd9d"Zd:d$Zd;d%ZGd&d'ejjZGd(d)ZdS)>2283CDD   .AAAAArErZr-cd||}|j|dS)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rradd_cookie_header)rzrZrs r:r"zCookies.set_cookie_headerUs3227;; "">22222rErX/rJr2rFdomainpathciddd|d|ddddd |d t|d |d d |dt|dddddddddddddidd}tdi|}|j|dS)zU Set a cookie value by name. May optionally include domain and path. versionrrJrFportNport_specifiedFr domain_specifieddomain_initial_dot.r path_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r)r4 startswithrrr)rzrJrFr r rrs r:rz Cookies.set\s! q D  U  D  e  f   V   !&"3"3C"8"8  D  d4jj  e  t  t  t  4 Z&! " u# &!!&!! F#####rErr>cd}|jD]D}|j|kr7| |j|kr*| |j|kr|d|}t ||j}E||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=)rrJr r rrF)rzrJrr r rFrrPs r:rz Cookies.getvsh - -F{d"">V]f%<%<|v{d':': ,&P$&P&PG"0"9"99 &  =N rEc|jSfd|jD}|D]-}|j|j|j|j.dS)z Delete a cookie by name. May optionally include domain and path in order to specify exactly which cookie to delete. Nc^g|])}|jkr |jkr |jk'|*Srv)rJr r )rrr rJr s r:rz"Cookies.delete..sT   {d""6=F#:#:!4!4 "5!4!4rE)rclearr r rJ)rzrJr r removers ``` r:deletezCookies.deletes  $"28>>&$55 5      (    D DF HNN6=&+v{ C C C C D DrEcg}|||||J|||jj|dS)z Delete all cookies. Optionally include a domain and path in order to only delete a subset of all the cookies. N)r_rr)rzr r argss r:rz Cookies.clears\    KK     %%% KK   rEclt|}|jD]}|j|dSrv)r+rr)rzrrs r:rzCookies.updatesC'""k ( (F H   ' ' ' ' ( (rEc.|||Srv)rrzrJrFs r:rzCookies.__setitem__sxxe$$$rEcR||}|t||Srv)rrr&s r:rzCookies.__getitem__s' =4..  rEc,||Srv)r!)rzrJs r:rzCookies.__delitem__s{{4   rErc*t|jSrv)rrrs r:rzCookies.__len__s48}}rErc$d|jDS)Nc3$K|] }|jV dSrv)rJrrs r: z#Cookies.__iter__..s$33 333333rErrs r:rzCookies.__iter__s33$(3333rEr4c|jD]}dSdS)NTFr.)rzrs r:__bool__zCookies.__bool__s  A44urEcVdd|jD}d|dS)Nrc Dg|]}d|jd|jd|jdS)z)rJrFr r,s r:rz$Cookies.__repr__..s; c c cPV K K Kfl K K K K K c c crEz sF   % % % %      rErrv)rrr3rtrCr;)rXr) rJr2rFr2r r2r r2r3rt)NNN) rJr2rr>r r>r r>r3r>r)rJr2r r>r r>r3rt)r r>r r>r3rt)rJr2rFr2r3rt)rJr2r3r2)rJr2r3rtrrrr)rrrrr}rr"rrr!rrrrrrrr0rurllibrZr-rrrrEr:r+r+3s" B B B B3333$$$$$:#! 8" DDDDD0     ((((( %%%% !!!!4444 ,,,,,,,,,v~5,,,$rEr+)r1r2r3r4rv)r<r=r1r>r3r?)rFr=r1r>r3r?)rKr2r3r>)rFr2r3rU)rgrhr3ri)M __future__rr6rdatetime email.messagerOrrr\r urllib.requestrDcollections.abcrrhttp.cookiejarrrr8r r r r _decodersr rrrrrr _exceptionsrrrrrrr _multipartr _status_codesr_typesrrrr r!r"r#r$r%r&r'_urlsr(_utilsr)r*__all__rmTypeVarr0r;rDrJrTrfrpMutableMappingr2r,r-r.r+rrEr:rUs""""""  33333333,,,,,,,,SSSSSSSSSSSSA@@@@@                           ++++++++ 7 7 7$&;<V^DNNNNN-----1111""""J}:}:}:}:}:f#CH-}:}:}:@})})})})})})})})@c+c+c+c+c+c+c+c+LFFFFFf#CH-FFFFFrE