hddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddlmZmZddlmZmZmZmZddlmZmZmZmZmZmZmZmZddlm 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.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6dd l7m8Z8dd l9m:Z:m;Z;gdZd.d/dZ?d.d0dZ@d1dZAd2d ZBd3d$ZCGd%d&e jDeEeEfZFGd'd(ZGGd)d*ZHGd+d,e jDeEeEfZIdS)4) annotationsN)Mapping)Cookie CookieJar) ByteStreamUnattachedStreamencode_requestencode_response)SUPPORTED_DECODERS 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-authorizationencodingstrreturnboolcT tj|n#t$rYdSwxYwdS)z7 Return `True` if `encoding` is a known codec. FT)codecslookup LookupErrorr0s O/var/www/html/prod/cognitive/venv/lib/python3.11/site-packages/httpx/_models.py_is_known_encodingr:8sA h uu 4s  %%key str | bytes str | Nonebytesc^t|tr|n||pdS)zE Coerce str/bytes into a strictly byte-wise HTTP header key. ascii) isinstancer>encode)r;r0s r9_normalize_header_keyrCCs.S%(( M33cjj9LW.M.MMvaluect|tr|St|tstdt |||pdS)zG Coerce str/bytes into a strictly byte-wise HTTP header value. z'Header value must be str or bytes, not r@)rAr>r1 TypeErrortyperB)rEr0s r9_normalize_header_valuerIJsb% eS ! !QO$u++OOPPP <<+G , ,,rD content_typecttj}||d<|dS)N content-type)failobj)emailmessageMessageget_content_charset)rJmsgs r9_parse_content_type_charsetrSUs8 -   ! !C&C  " "4 " 0 00rDlist[dict[str, str]]cg}d}||}|s|Stjd|D]} |dd\}}n#t$r|d}}YnwxYwd|di}|dD]X} |d\}}n#t$rYn0wxYw|||||<Y|||S) 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_charsvalrXparamslinkparamr;s r9_parse_header_linksre]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))rfkvs r9_obfuscate_sensitive_headersrosb1 !''))   1 1 1 !<<d$Zd?d%Zd@d&ZdAd(ZdBd*ZdCd,Zd0d-ZdS)Dr,z9 HTTP headers, as a case-insensitive multi-dict. NheadersHeaderTypes | Noner0r=r2Nonec0g|_t|trt|j|_nt|trj|D]T\}}t ||}t||}|j|| |fUnY|W|D]T\}}t ||}t||}|j|| |fU||_ dSN) _listrAr,listrrfrCrIr^rk _encoding)selfrqr0rmrn bytes_key bytes_values r9__init__zHeaders.__init__s  gw ' ' Ogm,,DJJ  ) ) O  O O11!X>> 5aBB  !!9ioo.?.?"MNNNN O  O O11!X>> 5aBB  !!9ioo.?.?"MNNNN!rDr1c|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)r@utf-8z iso-8859-1)rxrawdecodeUnicodeDecodeError)ryr0r;rEs r9r0zHeaders.encodings > !. . ."&(  JC 8,,, X....- &.DNE ".~s*A AArEc||_dSru)rxryrEs r9r0zHeaders.encodings rDlist[tuple[bytes, bytes]]c$d|jDS)zH Returns a list of the raw header items, as byte pairs. cg|] \}}}||f Sr).0raw_key_rEs r9 zHeaders.raw..s$EEE%6Wa% EEErDrvrys r9rz Headers.raws FE$*EEEErDtyping.KeysView[str]cNfdjDS)NcNi|]!\}}}|jd"Srurr0rrr;rErys r9 z Headers.keys..s/PPPMAsE 4=))4PPPrD)rvkeysrs`r9rz Headers.keyss+PPPPTZPPPUUWWWrDtyping.ValuesView[str]ci}|jD]W\}}}||j}||j}||vr||xxd|z cc<R|||<X|S)N, )rvrr0valuesry values_dictrr;rEstr_key str_values r9rzHeaders.valuess&( !Z 1 1MAsEjj//G T]33I+%%G$$$(8Y(8(88$$$$'0 G$$!!###rDtyping.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)rvrr0rfrs r9rfz Headers.itemss ') !Z 1 1MAsEjj//G T]33I+%%G$$$(8Y(8(88$$$$'0 G$$  """rDlist[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;Srrrs r9rz'Headers.multi_items..sP   3ZZ & & T](C(C D   rDrrs`r9 multi_itemszHeaders.multi_itemss0     !%    rDr;default typing.Anyc8 ||S#t$r|cYSwxYw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyError)ryr;rs r9getz Headers.gets5  9    NNN s  F split_commasr3 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)rkrr0)rritem_key item_valueget_header_keyrys r9rz$Headers.get_list..sN   '8Z~~>11   dm , ,111rDc6g|]}|Sr)rZ)ritems r9rz$Headers.get_list..s K K K$ K K KrD,)rkrBr0rvextendr\)ryr;rr split_valuesrErs` @r9get_listzHeaders.get_lists ++DM::     +/:     M  M ME    K K%++c:J:J K K K L L L LrDct|}|D]}||vr|||j|jdSru)r,rpoprvr)ryrqr;s r9updatezHeaders.updates]'""<<>>  Cd{{  '-(((((rDc.t||jS)Nr8)r,r0rs r9copyz Headers.copystdm4444rDc|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_keyrys r9rz'Headers.__getitem__..%sD   +:|^++    . .+++rDr)rkrBr0rvjoinr)ryr;rfrs` @r9 __getitem__zHeaders.__getitem__sz++DM::     /3z     $99U## #smmrDc||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. r~c.g|]\}\}}}|k|Srr)ridxrr lookup_keys r9rz'Headers.__setitem__..9s9   %%a1:%% %%%rDrNr)rBrxrk enumeratervreversedr^)ryr;rEset_key set_value found_indexesrrs @r9 __setitem__zHeaders.__setitem__0s **T^6w77LL!:7;; ]]__     )24:)>)>   M!""-..  C 3  @"C& I>DJsOOO J  w I> ? ? ? ? ?rDc||jfdt|jD}|st |t |D] }|j|= dS)z* Remove the header `key`. cRg|]#\}\}}}|k!|$Sr)rk)rrrrdel_keys r9rz'Headers.__delitem__..NsC   %%a1~~7** ***rDN)rkrBr0rrvrr)ryr; pop_indexesrrs @r9 __delitem__zHeaders.__delitem__Hs))++$$T]33    )24:)>)>    3-- K((  C 3  rDc||j}|d|jDvS)Ncg|]\}}}| Srr)rrr;s r9rz(Headers.__contains__..\s>>>iaac>>>rD)rkrBr0rv)ryr;rs r9 __contains__zHeaders.__contains__Zs;YY[['' 66 >>4:>>>>>rDtyping.Iterator[typing.Any]cDt|Sru)iterrrs r9__iter__zHeaders.__iter__^sDIIKK   rDintc*t|jSru)lenrvrs r9__len__zHeaders.__len__as4:rDotherc t|}n#t$rYdSwxYwd|jD}d|jD}t|t|kS)NFcg|] \}}}||f Srrrrr;rEs r9rz"Headers.__eq__..js"BBBmaec5\BBBrDcg|] \}}}||f Srrrs r9rz"Headers.__eq__..ks"LLL}q#usElLLLrD)r,r]rvsorted)ryr other_headers self_list other_lists r9__eq__zHeaders.__eq__ds #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)NrWr@z , encoding=()) __class____name__r0rwrordictr)ry class_name encoding_stras_listas_dictno_duplicate_keyss r9__repr__zHeaders.__repr__ns^,  =G # #:::L3D4D4D4F4FGGHHw--LLCLL8  > ==7=l=== =99w9,9999rDNN)rqrrr0r=r2rsr2r1rEr1r2rs)r2r)r2r)r2r)r2r)r2rru)r;r1rrr2r)F)r;r1rr3r2r)rqrrr2rs)r2r,)r;r1r2r1r;r1rEr1r2rs)r;r1r2rs)r;rr2r3)r2rr2r)rrr2r3)r __module__ __qualname____doc__r|propertyr0setterrrrrfrrrrrrrrrrrrrrrDr9r,r,s '+#""""",X0__FFFXF XXXX $ $ $ $ # # # #     ,)))))5555(@@@@0    $????!!!!7777 : : : : : :rDr,c teZdZdddddddddd d(dZd)dZed*d Zd*d!Zd*d"Zd+d#Z d,d%Z d-d'Z dS).r-N) rbrqcookiescontentdatafilesjsonstream extensionsmethodr1rX URL | strrbQueryParamTypes | NonerqrrrCookieTypes | NonerRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | Noner'SyncByteStream | AsyncByteStream | NonerRequestExtensions | Noner2rsc ||_|t|nt|||_t ||_| int | |_|r"t| || |j d} t|||| t| r| |jjnd\}} ||| |_t#| t$r|dSdS| |_dS)N)rbrL)rJ)rrrrboundary)upperrr(rXr,rqrrr+set_cookie_headerrr rrBr0_preparerrArread) ryrrXrbrqrrrrrrrrJs r9r|zRequest.__init__sHllnn %~3s8883s63J3J3Jw'' * 2""Z8H8H  5 G   . .t 4 4 4 >'+|'7'7'G'GL,A#"!4!4T\5J!K!K!K   OGV MM' " " " DK&*--    "!DKKKrDdefault_headersdict[str, str]c|D]B\}}|dkr d|jvr'|j||Cg}d|jv}d|jvpd|jv}|s-|jjr!|d|jjf|s|jdvr|dt||jj z|_dS)Ntransfer-encodingzContent-LengthHostzTransfer-EncodingsHost)POSTPUTPATCH)sContent-Length0) rfrkrq setdefaultrXhostr^netlocrr,r)ryrr;rE auto_headershas_hosthas_content_lengths r9rzRequest._prepares)//11 0 0JCyy{{1116F$,6V6V L # #C / / / /24 T\)  , S0Ct|0S  >?? rDr>cLt|dst|jSN_content)hasattrrr$rs r9rzRequest.contents(tZ(( # "" "}rDct|dsst|jtjsJd|j|_t|jtst|j|_|jS)6 Read and return the request content. r$rD)r%rArtypingIterablerr$rrs r9rz Request.readsttZ(( 8dk6?;; ; ;;HHT[11DMdk:66 8)77 }rDc:Kt|dst|jtjsJdd|j2d{V|_t|jtst|j|_|jS)r'r$rDc"Kg|3d{V}| 6Srurrparts r9rz!Request.aread..s.%I%I%I%I%I%I%I%ITd%I%I%I%IN)r%rArr( AsyncIterablerr$rrs r9areadz Request.areadstZ(( 8dk6+?@@ @ @@HH%I%IT[%I%I%I%I%I%I%I%I%IJJDMdk:66 8)77 }rDcd|jj}t|j}d|d|jd|dS)N)rrr1rXr)ryrrXs r9rzRequest.__repr__s<^, $(mm:::: ::::::rDdict[str, typing.Any]cHd|jDS)Nc"i|] \}}|dv || S))rrrrnamerEs r9rz(Request.__getstate__..s4   e333 %333rD__dict__rfrs r9 __getstate__zRequest.__getstate__1  #}2244    rDstatec|D]\}}t|||i|_t|_dSru)rfsetattrrr rryr<r7rEs r9 __setstate__zRequest.__setstate__sJ ;;== ' 'KD% D$ & & & &&(( rD)rr1rXrrbrrqrrrrrrrrrr rr rr rr r2rsrrr2rsr2r>rr2r3r<r3r2rs) rrrr|rrrrr0rr:r@rrDr9r-r-~s *.&*&*)-#'%)"&:>/38!8!8!8!8!8!t@@@@*X        ;;;;     ))))))rDr-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~) rqrtexthtmlrrrequestrhistorydefault_encoding status_coderrqrrrResponseContent | NonerFr=rGrrrr rHRequest | NonerResponseExtensions | NonerIlist[Response] | NonerJ#str | typing.Callable[[bytes], str]r2rsc ||_t||_||_d|_| int | |_| gnt| |_d|_ d|_ | |_ |[t||||\}}| |||_t|t r|n||_d|_dS)NFr)rKr,rq_request next_requestrrrwrI is_closedis_stream_consumedrJr rrrArr_num_bytes_downloaded) ryrKrqrrFrGrrrHrrIrJs r9r|zResponse.__init__s'w'' (/ -1 * 2""Z8H8H$_rr$w-- "' 0 >-gtT4HHOGV MM' " " " DK&*--  !DK%&"""rDrrc|D]B\}}|dkr d|jvr'|j||CdS)Nrzcontent-length)rfrkrqr)ryrr;rEs r9rzResponse._prepare;sj)//11 0 0JCyy{{1116F$,6V6V L # #C / / / /  0 0rDdatetime.timedeltacNt|dstd|jS)ze Returns the time taken for the complete request/response cycle to complete. _elapsedzK'.elapsed' may only be accessed after the response has been read or closed.)r% RuntimeErrorrZrs r9elapsedzResponse.elapsedBs7 tZ(( + }rDr\c||_dSru)rZ)ryr\s r9r\zResponse.elapsedOs  rDr-c<|jtd|jS)zR Returns the request instance associated to the current response. Nz7The request instance has not been set on this response.)rRr[rs r9rHzResponse.requestSs+ = I }rDrEc||_dSru)rRrs r9rHzResponse.request^s  rDr1cn |jd}|ddS#t$rYdSwxYw)N http_versionr@ignoreerrorszHTTP/1.1)rrr)ryras r9razResponse.http_versionbsS A"&/."AL &&wx&@@ @   :: s & 44c |jd}|ddS#t$rtj|jcYSwxYw)N reason_phraser@rbrc)rrrrget_reason_phraserK)ryrfs r9rfzResponse.reason_phraseksf B#'??#CM!'''AA A = = =*4+;<< < < < =s &#A  A r(c|jjS)zA Returns the URL for which the request was made. )rHrXrs r9rXz Response.urlts |rDr>cLt|dst|jSr#)r%rr$rs r9rzResponse.content{s(tZ(( $!## #}rDc t|dsn|j}|sd|_n]t|jpd}d||j|g|_|jS)N_textrWr~r8)r%rrkrr0rrflush)ryrdecoders r9rFz Response.texts{tW%% VlG V %t}/GHHHWWgnnT\&B&BGMMOO%TUU zrDc 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. rxNr$r~)r%charset_encodingr:rArJr1r$rx)ryr0s r9r0zResponse.encodingst[)) 1,H'9('C'Cd3S99D#4HHT:..D#44T]CCH%0DN~rDcRt|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. rkz?Setting encoding after `text` has been accessed is not allowed.N)r%r]rxrs r9r0zResponse.encodings8 4 ! ! Q rDc\|jd}|dSt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)rqrrS)ryrJs r9rozResponse.charset_encodings2 |''77  4*<888rDrct|dsg}|jdd}|D]c}|} t |}||T#t$rY`wxYwt|dkr|d|_ n 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)rHresponse)rRr[r{rrKrformatr)ryrHrO status_class error_typesrs r9raise_for_statuszResponse.raise_for_statuss- ?>  ? K  % w Gw  '3. '"   !__\3HII ..*.==gwFFFFrDkwargsc 0tj|jfi|Sru)jsonlibloadsr)ryrs r9rz Response.json?s}T\44V444rDr+ct|ds-t|_|j||jS)N_cookies)r%r+rextract_cookiesrs r9rzResponse.cookiesBs=tZ(( 0#IIDM M ) )$ / / /}rD dict[str | None, dict[str, str]]cp|jd}|iSdt|DS)zI Returns the parsed header links of the response, if any rcNcdi|]-}|dp|d|.S)relrX)r)rrcs r9rz"Response.links..RsC   XXe__ /$   rD)rqrre)ryheaders r9r_zResponse.linksIsL !!&)) >I  +F33    rDc|jSru)rVrs r9num_bytes_downloadedzResponse.num_bytes_downloadedWs ))rDc(d|jd|jdS)Nz )rKrfrs r9rzResponse.__repr__[s!FT-FF0BFFFFrDr3cHd|jDS)Nc"i|] \}}|dv || S))rrrTrsrr6s r9rz)Response.__getstate__.._s4   eLLL %LLLrDr8rs r9r:zResponse.__getstate__^r;rDr<c|D]\}}t|||d|_i|_t |_dS)NT)rfr>rTrr rr?s r9r@zResponse.__setstate__esQ ;;== ' 'KD% D$ & & & &&(( rDct|ds,d||_|jS)7 Read and return the response content. r$rD)r%r iter_bytesr$rs r9rz Response.readls;tZ(( 8HHT__%6%677DM}rD chunk_size int | Nonetyping.Iterator[bytes]c#Kt|drb|t|jn|}tdt|jt |dD]}|j|||zVdS|}t |}t|j5| D]3}| |}| |D]}|V4| }| |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. r$NrrrrH) r%rr$rangemaxrwr rrRiter_rawrrlryrirmchunker raw_bytesdecodedchunks r9rzResponse.iter_bytests 4 $ $ /9/AT]+++zJ1c$-00#j!2D2DEE 8 8mAJ$677777 8 8//11G!Z888G 777 !%$$I%nnY77G!(!8!8$$# $!--//$^^G44  EKKKK$]]__  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. r~r8rrN)rr0rrrRrrrlryrrmr byte_content text_contentrs r9 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)rrrRrrrlryrmrFlines r9 iter_lineszResponse.iter_liness-- T] 3 3 3  ((  #NN400DJJJJ                        sABB Bc#,K|jrt|jrtt |jt stdd|_d|_t|}t|j 5|jD];}|xjt|z c_| |D]}|V< dddn #1swxYwY|D]}|V|dS)@ A byte-iterator over the raw response content. z5Attempted to call a sync iterator on an async stream.TrrrN)rUrrTrrArr'r[rVr rrRrrrlcloseryrrraw_stream_bytesrs r9rzResponse.iter_rawst  " # "" " > !.. $+~66 XVWW W"&%&"444 T] 3 3 3  $(K   **c2B.C.CC**$^^,<==  EKKKK                 ]]__  EKKKK s ACC!Cct|jtstd|jsPd|_t |j5|jddddS#1swxYwYdSdS) Close the response and release the connection. Automatically called if the response body is read to completion. z3Attempted to call an sync close on an async stream.TrN)rArr'r[rTrrRrrs r9rzResponse.closes $+~66 VTUU U~ $!DN 777 $ $ !!### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s A44A8;A8cKt|ds.s.%P%P%P%P%P%P%P%PTd%P%P%P%Pr.N)r%r aiter_bytesr$rs r9r0zResponse.areadsctZ(( RHH%P%PT=M=M=O=O%P%P%P%P%P%P%P%P%PQQDM}rDtyping.AsyncIterator[bytes]cKt|drc|t|jn|}tdt|jt |dD]}|j|||zWVdS|}t |}t|j5| 23d{V}| |}| |D]}|WV:6| }| |D]}|WV| D]}|WV ddddS#1swxYwYdSr) r%rr$rrrwr rrR aiter_rawrrlrs r9rzResponse.aiter_bytess 4 $ $ /9/AT]+++zJ1c$-00#j!2D2DEE 8 8mAJ$6777777 8 8//11G!Z888G 777 '+~~'7'7$$$$$$$)%nnY77G!(!8!8$$# $(8"--//$^^G44  EKKKKK$]]__  EKKKKK  s/EC> BEE!Etyping.AsyncIterator[str]cKt|jpd}t|}t|j5|23d{V}||}||D]}|WV:6|}||D]}|WV|D]}|WV ddddS#1swxYwYdSr)rr0rrrRrrrlrs r9 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)rrrRrrrlrs r9 aiter_lineszResponse.aiter_liness-- T] 3 3 3  "oo//       d#NN400DJJJJJ0                        sB A  !.. $+77 YWXX X"&%&"444 T] 3 3 3  *.+       &**c2B.C.CC**$^^,<==  EKKKKK +6+               ]]__  EKKKKKkkmms C!C=C!!C%(C%cKt|jtstd|jsVd|_t |j5|jd{VddddS#1swxYwYdSdS)rz3Attempted to call an async close on an sync stream.TrN)rArrr[rTrrRrrs r9rzResponse.aclose)s $+77 VTUU U~ +!DN 777 + +k((********* + + + + + + + + + + + + + + + + + + + +s A<<BB)rKrrqrrrrLrFr=rGr=rrrr rHrMrrNrIrOrJrPr2rsrA)r2rX)r\rXr2rs)r2r-)rEr-r2rsr)r2r(rB)r2r=r)r2rr2r3)r2r.)rrr2r)r2r+)r2rrrCrDru)rrr2r)rrr2rr2r)r2rs)rrr2r)rrr2r)r2r),rrrr|rrr\rrHrarfrXrrFr0rorwryr{r}rrrrrrrr_rrr:r@rrrrrrr0rrrrrrrDr9r.r.s '+*.:>"&04)-@G5'5'5'5'5'5'n0000   X  ^   ^ X ^^AAAXABBBXB   X X XX*_   _ 999X92888X8 222X2  3 3 3X 3777X7 777X7 000X0    X ,#G#G#G#GJ5555X     X  ***X*GGGG    ))))     .&4 $ $ $ $(,     4(,*(,8 + + + + + +rDr.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   .AAAAArDrHr-cd||}|j|dS)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rradd_cookie_header)ryrHrs r9rzCookies.set_cookie_headerVs3227;; "">22222rDrW/r7r1rEdomainpathciddd|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. versionrr7rEportNport_specifiedFrdomain_specifieddomain_initial_dot.rpath_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r)r3 startswithrrr)ryr7rErrrrs r9rz Cookies.set]s! q D  U  D  e  f   V   !&"3"3C"8"8  D  d4jj  e  t  t  t  4 Z&! " u# &!!&!! F#####rDrr=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=)rr7rrrrE)ryr7rrrrErrOs r9rz Cookies.getwsh - -F{d"">V]f%<%<|v{d':': ,&P$&P&PG"0"9"99 &  =N rDc|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'|*Sru)r7rr)rrrr7rs r9rz"Cookies.delete..sT   {d""6=F#:#:!4!4 "5!4!4rD)rclearrrr7)ryr7rrremovers ``` r9deletezCookies.deletes  $"28>>&$55 5      (    D DF HNN6=&+v{ C C C C D DrDcg}|||||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)ryrrargss r9rz Cookies.clears\    KK     %%% KK   rDclt|}|jD]}|j|dSru)r+rr)ryrrs r9rzCookies.updatesC'""k ( (F H   ' ' ' ' ( (rDc.|||Sru)rryr7rEs r9rzCookies.__setitem__sxxe$$$rDcR||}|t||Sru)rrr s r9rzCookies.__getitem__s' =4..  rDc,||Sru)r)ryr7s r9rzCookies.__delitem__s{{4   rDrc*t|jSru)rrrs r9rzCookies.__len__s48}}rDrc$d|jDS)Nc3$K|] }|jV dSru)r7rrs r9 z#Cookies.__iter__..s$33 333333rDrrs r9rzCookies.__iter__s33$(3333rDr3c|jD]}dSdS)NTFr)ryrs r9__bool__zCookies.__bool__s  A44urDcVdd|jD}d|dS)Nrc Dg|]}d|jd|jd|jdS)z)r7rErrs r9rz$Cookies.__repr__..sJ   O6;NNNNFMNNN   rDz )rEr<r0r=r2r>)rJr1r2r=)rEr1r2rT)rfrgr2rh)J __future__rr5datetime email.messagerNrrr[r(urllib.requestr+collections.abcrhttp.cookiejarrrr$rr r r _decodersr r rrrrrr _exceptionsrrrrrrr _multipartr _status_codesr_typesrrrr r!r"r#r$r%r&r'_urlsr(_utilsr)r*__all__rlr:rCrIrSreroMutableMappingr1r,r-r.r+rrDr9r;s""""""  ######,,,,,,,,SSSSSSSSSSSS                    A@@@@@                           ++++++++ 7 7 7$&;<NNNNN-----1111""""Jp:p:p:p:p:f#CH-p:p:p:fB)B)B)B)B)B)B)B)Jq+q+q+q+q+q+q+q+hFFFFFf#CH-FFFFFrD