o Tj@sddlmZddlZddlZddlZddlZddlZddl 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 ?dZ@d4ddZAd5d6ddZBd5d7dd ZCd8d"d#ZDd9d%d&ZEd:d*d+ZFGd,d-d-e jGeHeHfZIGd.d/d/ZJGd0d1d1ZKGd2d3d3e jGeHeHfZLdS);) 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_TencodingstrreturnboolcCs&zt|WdStyYdSw)z7 Return `True` if `encoding` is a known codec. FT)codecslookup LookupErrorr0r8Q/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/httpx2/_models.py_is_known_encoding:s   r:key str | bytes str | NonebytescCst|tr|S||p dS)zE Coerce str/bytes into a strictly byte-wise HTTP header key. ascii) isinstancer>encode)r;r0r8r8r9_normalize_header_keyEsrBvaluecCs8t|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?)r@r>r1 TypeErrortyperA)rCr0r8r8r9_normalize_header_valueLs  rF content_typecCstj}||d<|jddS)N content-type)failobj)emailmessageMessageget_content_charset)rGmsgr8r8r9_parse_content_type_charsetWs  rOlist[dict[str, str]]c Csg}d}||}|s |Std|D]M}z |dd\}}Wnty-|d}}Ynwd|di}|dD] }z |d\}}Wn tyOYn w|||||<q:||q|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) rClinks replace_charsvalrSparamslinkparamr;r8r8r9_parse_header_links_s*    r`items4typing.Iterable[tuple[typing.AnyStr, typing.AnyStr]]4typing.Iterator[tuple[typing.AnyStr, typing.AnyStr]]ccs:|D]\}}t|tvrtd|d}||fVqdS)Nz[secure]) match_type_of)r)lowerSENSITIVE_HEADERSr()rakvr8r8r9_obfuscate_sensitive_headerss    ric@s0eZdZdZ  dOdPd d ZedQd d ZejdRdd ZedSddZdTddZ dUddZ dVddZ dWddZ e jdXd d!Ze jdYd%d!ZdZd[d(d!Zd\d]d-d.ZdZd^d/d0Zd_d1d2Zd`d5d6Zd`d7d8Zdad:d;Zdbdd?Zddd@dAZdedCdDZdfdFdGZdgdIdJZdhdKdLZdQdMdNZdS)ir+z9 HTTP headers, as a case-insensitive multi-dict. NheadersHeaderTypes | Noner0r=r2NonecCsg|_t|trt|j|_nDt|tr3|D]\}}t||}t||}|j|| |fqn |durS|D]\}}t||}t||}|j|| |fq9||_ dSN) _listr@r+listrrarBrFrYre _encoding)selfrjr0rgrh bytes_key bytes_valuer8r8r9__init__s        zHeaders.__init__r1c Csj|jdur2dD]'}|jD]\}}z ||||Wq ty&Ynw||_|jSqd|_|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)rprawdecodeUnicodeDecodeError)rqr0r;rCr8r8r9r0s    zHeaders.encodingrCcC ||_dSrm)rprqrCr8r8r9r0 list[tuple[bytes, bytes]]cCdd|jDS)zH Returns a list of the raw header items, as byte pairs. cSsg|] \}}}||fqSr8r8).0raw_key_rCr8r8r9 zHeaders.raw..rnrqr8r8r9rvsz Headers.rawtyping.KeysView[str]csfddjDS)Ncs i|] \}}}|jdqSrmrwr0)r~rr;_valuerr8r9 s z Headers.keys..)rnkeysrr8rr9rsz Headers.keystyping.ValuesView[str]cC^i}|jD]%\}}}||j}||j}||vr&||d|7<q|||<q|S)N, )rnrwr0valuesrq values_dictrr;rCstr_key str_valuer8r8r9rs   zHeaders.valuestyping.ItemsView[str, str]cCr)z Return `(key, value)` items of headers. Concatenate headers into a single comma separated value when a key occurs multiple times. r)rnrwr0rarr8r8r9ras   z Headers.itemslist[tuple[str, str]]csfddjDS)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. cs*g|]\}}}|j|jfqSr8rr~rr;rCrr8r9r*z'Headers.multi_items..rrr8rr9 multi_itemsszHeaders.multi_itemsr;cCdSrmr8)rqr;r8r8r9getz Headers.getdefaultr/str | _TcCrrmr8rqr;rr8r8r9rr _T | Nonestr | _T | NonecCs"z||WSty|YSw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyErrorrr8r8r9rs   F split_commasr3 list[str]csZ|jfddjD}|s|Sg}|D]}|dd|dDq|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. cs*g|]\}}}|kr|jqSr8)rerwr0)r~ritem_key item_valueget_header_keyrqr8r9r s   z$Headers.get_list..cSsg|]}|qSr8)rU)r~itemr8r8r9rs,)rerAr0rnextendrW)rqr;rr split_valuesrCr8rr9get_lists zHeaders.get_listcCs:t|}|D] }||vr||q|j|jdSrm)r+rpoprnr)rqrjr;r8r8r9updates   zHeaders.updatecCst||jdS)Nr7)r+r0rr8r8r9copysz Headers.copyotherMapping[str, str]cCs$t|tstS|}|||Srm)r@rNotImplementedrrrqrmergedr8r8r9__or__!  zHeaders.__or__cCs$t|tstSt|}|||Srm)r@rrr+rrr8r8r9__ror__(rzHeaders.__ror__rcCs|||Srm)r)rqrr8r8r9__ior__/s zHeaders.__ior__cs<|jfddjD}|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 cs&g|]\}}}|kr|jqSr8r)r~r header_key header_valuenormalized_keyrqr8r9r<s  z'Headers.__getitem__..r)rerAr0rnjoinr)rqr;rar8rr9 __getitem__3s  zHeaders.__getitem__cs||jpd}||jpd}|fddt|jD}t|ddD]}|j|=q(|r?|d}||f|j|<dS|j||fdS)zs Set the header `key` to `value`, removing any duplicate entries. Retains insertion order. rucs"g|] \}\}}}|kr|qSr8r8r~idxrr lookup_keyr8r9rP"z'Headers.__setitem__..rNr)rArpre enumeraternreversedrY)rqr;rCset_key set_value found_indexesrr8rr9 __setitem__Gs zHeaders.__setitem__csN||jfddt|jD}|st|t|D]}|j|=qdS)z* Remove the header `key`. cs&g|]\}\}}}|kr|qSr8)rerdel_keyr8r9ras&z'Headers.__delitem__..N)rerAr0rrnrr)rqr; pop_indexesrr8rr9 __delitem__[s  zHeaders.__delitem__ typing.AnycCs$||j}|dd|jDvS)NcSsg|]\}}}|qSr8r8)r~rr;r8r8r9rksz(Headers.__contains__..)rerAr0rn)rqr;rr8r8r9 __contains__iszHeaders.__contains__typing.Iterator[typing.Any]cCs t|Srm)iterrrr8r8r9__iter__m zHeaders.__iter__intcC t|jSrm)lenrnrr8r8r9__len__p zHeaders.__len__cCsRzt|}Wn tyYdSwdd|jD}dd|jD}t|t|kS)NFcSg|] \}}}||fqSr8r8rr8r8r9ryrz"Headers.__eq__..cSrr8r8rr8r8r9rzr)r+rXrnsorted)rqr other_headers self_list other_listr8r8r9__eq__ss  zHeaders.__eq__cCsv|jj}d}|jdkrd|j}tt|}t|}t|t|k}|r1|d||dS|d||dS)NrRr?z , encoding=()) __class____name__r0rorirdictr)rq class_name encoding_stras_listas_dictno_duplicate_keysr8r8r9__repr__}s  zHeaders.__repr__NN)rjrkr0r=r2rlr2r1rCr1r2rl)r2r|)r2r)r2r)r2r)r2r)r;r1r2r=)r;r1rr/r2rrm)r;r1rrr2r)F)r;r1rr3r2r)rjrkr2rl)r2r+)rrr2r+)rrr2r+)r;r1r2r1)r;r1rCr1r2rl)r;r1r2rl)r;rr2r3)r2rr2r)rrr2r3)r __module__ __qualname____doc__rtpropertyr0setterrvrrrartypingoverloadrrrrrrrrrrrrrrrr8r8r8r9r+sD                       r+c @sveZdZdddddddddd d0ddZd1dd Zed2d"d#Zd2d$d%Zd2d&d'Zd3d(d)Z d4d+d,Z d5d.d/Z dS)6r,N) r]rjcookiescontentdatafilesjsonstream extensionsmethodr1rS URL | strr]QueryParamTypes | NonerjrkrCookieTypes | NonerRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | Noner'SyncByteStream | AsyncByteStream | NonerRequestExtensions | Noner2rlc Cs||_|dur t|nt||d|_t||_| durint| |_|r-t| || durc|j d} t |||| t | rF| |jjnddd\}} ||| |_t| tra|dSdS| |_dS)N)r]rH)rG)rrrrboundary)upperrr'rSr+rjrrr*set_cookie_headerrr rrAr0_preparerr@rread) rqrrSr]rjrrrrrrrrGr8r8r9rts.       zRequest.__init__default_headersdict[str, str]cCs|D]#\}}|dkrd|jvrq|dkr d|jvr q|j||qg}d|jv}d|jvp8d|jv}|sH|jjrH|d|jjf|sT|jdvrT|dt ||jj |_dS) Ncontent-lengthzTransfer-Encodingtransfer-encodingzContent-LengthHostsHost)POSTPUTPATCHQUERY)sContent-Length0) rarerj setdefaultrShostrYnetlocrr+rv)rqr r;rC auto_headershas_hosthas_content_lengthr8r8r9rs   zRequest._preparer>cCt|dst|jSN_content)hasattrrrrr8r8r9r zRequest.contentcCsHt|ds!t|jtjsJd|j|_t|jts!t|j|_|jS)6 Read and return the request content. r)rr@rrIterablerrrrr8r8r9rs   z Request.readcsZt|ds*t|jtjsJddd|j2IdH|_t|jts*t|j|_|jS)rrrcg|z3dHW}|q6Srmr8r~partr8r8r9rz!Request.aread..N)rr@rr AsyncIterablerrrrr8r8r9areads   z Request.areadcCs,|jj}t|j}d|d|jd|dS)N)rrr1rSr)rqrrSr8r8r9rs zRequest.__repr__dict[str, typing.Any]cCdd|jDS)NcSi|] \}}|dvr||qS))rrr8r~namerCr8r8r9rsz(Request.__getstate__..__dict__rarr8r8r9 __getstate__zRequest.__getstate__statecCs0|D] \}}t|||qi|_t|_dSrm)rasetattrrr rrqr1r,rCr8r8r9 __setstate__s zRequest.__setstate__)rr1rSrr]rrjrkrrrrrrrrrrrrrrr2rlr r r2rlr2r>rr2r(r1r(r2rl) rrrrtrrrrr&rr/r4r8r8r8r9r,s& 8     r,c @s2eZdZddddddddddd dddZddd Zedd"d#Zejdd%d#Zedd'd(Zejdd*d(Zedd,d-Z edd.d/Z edd1d2Z edd4d5Z edd6d7Z edd8d9Zejdd:d9Zedd;d<Zdd>d?ZeddAdBZeddCdDZeddEdFZeddGdHZeddIdJZeddKdLZeddMdNZddOdPZddRdSZeddUdVZeddXdYZeddZd[Zdd\d]Zdd_d`ZddbdcZddddeZ dddidjZ!dddldmZ"ddndoZ#dddpdqZ$ddrdsZ%ddtduZ&dddwdxZ'dddzd{Z(dd|d}Z)ddd~dZ*dddZ+dS)r-Nru) rjrtexthtmlrrrequestrhistorydefault_encoding status_coderrjrkrResponseContent | Noner9r=r:rrrrr;Request | NonerResponseExtensions | Noner<list[Response] | Noner=*str | typing.Callable[[bytes], str | None]r2rlc Cs||_t||_||_d|_| durint| |_| durgnt| |_d|_ d|_ | |_ |durLt ||||\}}| |||_t|trK|n||_d|_dS)NFr)r>r+rj_request next_requestrrror< is_closedis_stream_consumedr=r rrr@rr_num_bytes_downloaded) rqr>rjrr9r:rrr;rr<r=r8r8r9rts$    zResponse.__init__r r cCs<|D]\}}|dkrd|jvrq|j||qdS)Nr r )rarerjr)rqr r;rCr8r8r9rEs zResponse._preparedatetime.timedeltacCs2t|dst|jdd}|dur|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 RuntimeErrorrJ)rqstream_elapsedr8r8r9rKLs zResponse.elapsedrKcCryrm)rJ)rqrKr8r8r9rKYr{r,cCs|jdur td|jS)zR Returns the request instance associated to the current response. Nz7The request instance has not been set on this response.)rDrMrr8r8r9r;]s zResponse.requestrCcCryrm)rDrzr8r8r9r;fr{r1cCs2z|jd}Wn tyYdSw|jdddS)N http_versionzHTTP/1.1r?ignoreerrors)rrrw)rqrOr8r8r9rOjs  zResponse.http_versioncCs<z|jd}Wntyt|jYSw|jdddS)N reason_phraser?rPrQ)rrrget_reason_phraser>rw)rqrSr8r8r9rSss  zResponse.reason_phraser'cCs|jjS)zA Returns the URL for which the request was made. )r;rSrr8r8r9rS|sz Response.urlr>cCrr)rrrrr8r8r9rrzResponse.contentcCsRt|ds&|j}|sd|_|jSt|jpdd}d||j|g|_|jS)N_textrRrur7)rrrUrr0rrwflush)rqrdecoderr8r8r9r9s z Response.textcCsZt|ds*|j}|dust|s%t|jtr|j}n t|dr%||j}|p(d|_|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. rpNrru)rcharset_encodingr:r@r=r1rrp)rqr0r8r8r9r0s     zResponse.encodingcCst|dr td||_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. rUz?Setting encoding after `text` has been accessed is not allowed.N)rrXrprzr8r8r9r0s  cCs |jd}|dur dSt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)rjrrO)rqrGr8r8r9rXs zResponse.charset_encodingr cCszt|ds:|jjddd}dd|D}tdd|D}t|jdkr-|jd |_|jS|jr6||_|jSt|_|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)rcSsg|]}|qSr8)rUre)r~rCr8r8r9rz1Response._get_content_decoder..cSsg|]}|dkr|qS)identityr8)r~r0r8r8r9rrZrr)rrjrrrchildrenrYr)rqr encodingsrWr8r8r9_get_content_decoders  zResponse._get_content_decoderr3cC t|jS)zU A property which is `True` for 1xx status codes, `False` otherwise. )ris_informationalr>rr8r8r9r` zResponse.is_informationalcCr_)zU A property which is `True` for 2xx status codes, `False` otherwise. )r is_successr>rr8r8r9rbrazResponse.is_successcCr_)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>rr8r8r9rcs zResponse.is_redirectcCr_)zU A property which is `True` for 4xx status codes, `False` otherwise. )ris_client_errorr>rr8r8r9rdrazResponse.is_client_errorcCr_)zU A property which is `True` for 5xx status codes, `False` otherwise. )ris_server_errorr>rr8r8r9rerazResponse.is_server_errorcCr_)z] A property which is `True` for 4xx and 5xx status codes, `False` otherwise. )ris_errorr>rr8r8r9rfrazResponse.is_errorcCs(|jtjtjtjtjtjfvod|jvS)zs Returns True for 3xx responses with a properly formed URL redirection, `False` otherwise. Location)r>rMOVED_PERMANENTLYFOUND SEE_OTHERTEMPORARY_REDIRECTPERMANENT_REDIRECTrjrr8r8r9has_redirect_locations zResponse.has_redirect_locationcCsp|j}|dur td|jr|S|jrd}nd}|jd}dddd d }||d }|j||d }t|||d )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)r;response)rDrMrbrmr>rformatr)rqr;rK status_class error_typesrrr8r8r9raise_for_statuss*  zResponse.raise_for_statuskwargscKstj|jfi|Srm)jsonlibloadsr)rqrxr8r8r9r=r0z Response.jsonr*cCs$t|dst|_|j||jS)N_cookies)rr*r{extract_cookiesrr8r8r9r@s  zResponse.cookies dict[str | None, dict[str, str]]cCs*|jd}|dur iSddt|DS)zI Returns the parsed header links of the response, if any r^NcSs"i|] }|dp |d|qS)relrS)r)r~r^r8r8r9rPrz"Response.links..)rjrr`)rqheaderr8r8r9rZGs zResponse.linkscCs|jSrm)rHrr8r8r9num_bytes_downloadedRszResponse.num_bytes_downloadedcCsd|jd|jdS)Nz )r>rSrr8r8r9rVszResponse.__repr__r(cCr))NcSr*))rrrFrYr8r+r8r8r9rZs z)Response.__getstate__..r-rr8r8r9r/YszResponse.__getstate__r1cCs6|D] \}}t|||qd|_i|_t|_dS)NT)rar2rFrr rr3r8r8r9r4`s  zResponse.__setstate__cCs t|ds d||_|jS)7 Read and return the response content. rr)rr iter_bytesrrr8r8r9rgs z Response.read chunk_size int | Nonetyping.Iterator[bytes]ccst|dr,|durt|jn|}tdt|jt|dD] }|j|||VqdS|}t|d}t|jd?| D]}| |D] }| |D]}|VqNqGq@| D] }| |D]}|VqaqZ| D]}|VqlWddS1s}wYdSz A byte-iterator over the decoded response content. This allows us to handle gzip, deflate, brotli, and zstd encoded responses. rNrrrr;) rrrrangemaxr^r rrDiter_rawrwrV)rqrirWchunker raw_bytesdecodedchunkr8r8r9ros.     "zResponse.iter_bytestyping.Iterator[str]ccst|jpdd}t|d}t|jd9|D]}||}||D]}|Vq%q|}||D]}|Vq5|D]}|Vq?WddS1sPwYdSz A str-iterator over the decoded response content that handles both gzip, deflate, etc but also detects the content's string encoding. rur7rrN)rr0rrrDrrwrVrqrrWr byte_content text_contentrr8r8r9 iter_texts     "zResponse.iter_textccsrt}t|jd%|D] }||D]}|Vqq|D]}|Vq!WddS1s2wYdSNr)rrrDrrwrVrqrWr9liner8r8r9 iter_liness  "zResponse.iter_linesccs|jrt|jr tt|jtstdd|_d|_t |d}zAt |j d"|jD]}|jt |7_| |D]}|Vq=q-Wdn1sNwY|D]}|VqWW|dS|w)@ A byte-iterator over the raw response content. z5Attempted to call a sync iterator on an async stream.TrrrN)rGrrFrr@rr&rMrHr rrDrrwrVclose)rqrrraw_stream_bytesrr8r8r9rs.    zResponse.iter_rawcCs`t|jts td|js.d|_t|jd|jWddS1s'wYdSdS) 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&rMrFrrDrrr8r8r9rs  "zResponse.closec stt|ds7t|4IdH}ddd|2IdH|_WdIdH|jS1IdHs2wY|jS)rrNrcr!rmr8r"r8r8r9rr$z"Response.aread..)r contextlibaclosing aiter_bytesrr)rqpartsr8r8r9r&s zResponse.aread"typing.AsyncGenerator[bytes, None]c CsPt|dr,|durt|jn|}tdt|jt|dD] }|j|||VqdS|}t|d}t|jdct | 4IdH(}|2z3dHW}| |D] }| |D]}|Vq\qUqJ6WdIdHn 1IdHsuwY| D] }| |D]}|Vqq~| D]}|VqWddS1swYdSr)rrrrrr^r rrDrr aiter_rawrwrV) rqrrrWr raw_streamrrrr8r8r9rs4  (  "zResponse.aiter_bytestyping.AsyncIterator[str]cCst|jpdd}t|d}t|jd>|2z3dHW}||}||D]}|Vq)q6|}||D]}|Vq:|D]}|VqDWddS1sUwYdSr)rr0rrrDrrwrVrr8r8r9 aiter_texts"   "zResponse.aiter_textcCs|t}t|jd*|2z3dHW}||D]}|Vqq6|D]}|Vq&WddS1s7wYdSr)rrrDrrwrVrr8r8r9 aiter_liness "zResponse.aiter_linesc Cs |jrt|jr tt|jtstdd|_d|_t |d}|j }zTt |j d&|2z3dHW}|jt |7_||D]}|VqEq16Wdn1sWwY|D]}|Vq`Wt|trs|IdH|IdHdSt|tr|IdH|IdHw)rz5Attempted to call an async iterator on a sync stream.TrrrN)rGrrFrr@rrrMrHr __aiter__rrDrrwrVraclose)rqrrrrrr8r8r9rs:      zResponse.aiter_rawcsht|jts td|js2d|_t|jd|jIdHWddS1s+wYdSdS)rz2Attempted to call an async close on a sync stream.TrN)r@rrrMrFrrDrrr8r8r9r%s "zResponse.aclose)r>rrjrkrr?r9r=r:r=rrrrr;r@rrAr<rBr=rCr2rlr5)r2rI)rKrIr2rl)r2r,)rCr,r2rlr)r2r'r6)r2r=r)r2r r2r3)r2r-)rxrr2r)r2r*)r2r}rr7r8rm)rrr2r)rrr2rr2r)r2rl)rrr2r)rrr2r)r2r),rrrrtrrrKrr;rOrSrSrr9r0rXr^r`rbrcrdrerfrmrwrrrZrrr/r4rrrrrrr&rrrrrr8r8r8r9r- s 7                      $              r-c@seZdZdZd9d:ddZd;d d ZdddZ   d?d@ddZ  dAdBddZ dAdCd d!Z d9d:d"d#Z dDd$d%Z dEd&d'Z dFd(d)ZdGd+d,ZdHd.d/ZdId1d2ZdJd3d4ZGd5d6d6ejjZGd7d8d8ZdS)Kr*z- HTTP Cookies, as a mutable mapping. Nrrr2rlcCs|dus t|tr%t|_t|tr!|D] \}}|||qdSdSt|tr=t|_|D] \}}|||q0dSt|trTt|_|jD]}|j|qIdS||_dSrm) r@rrjarrasetror* set_cookie)rqrr;rCcookier8r8r9rt8s$      zCookies.__init__rsr-cCs@d|jvr d|jvr dS||}||j}|j||dS)zO Loads any cookies based on the response `Set-Cookie` headers. z set-cookiez set-cookie2N)rj_CookieCompatResponse_CookieCompatRequestr;rr|)rqrsurllib_responseurllib_requestr8r8r9r|Is   zCookies.extract_cookiesr;r,cCs||}|j|dS)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rradd_cookie_header)rqr;rr8r8r9rUs zCookies.set_cookie_headerrR/r,r1rCdomainpathcCsiddd|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. versionrr,rCportNport_specifiedFrdomain_specifieddomain_initial_dot.rpath_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r8)r3 startswithrrr)rqr,rCrrrxrr8r8r9r\sJ      z Cookies.setrr=cCsnd}|jD])}|j|kr.|dus|j|kr.|dus|j|kr.|dur+d|}t||j}q|dur5|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=)rr,rrrrC)rqr,rrrrCrrKr8r8r9rvs   z Cookies.getcs\durdur|jSfdd|jD}|D] }|j|j|j|jqdS)z Delete a cookie by name. May optionally include domain and path in order to specify exactly which cookie to delete. Ncs>g|]}|jkrdus|jkrdus|jkr|qSrm)r,rrr~rrr,rr8r9rs z"Cookies.delete..)rclearrrr,)rqr,rrremoverr8rr9deletes zCookies.deletecCsDg}|dur |||dur|dusJ|||jj|dS)z Delete all cookies. Optionally include a domain and path in order to only delete a subset of all the cookies. N)rYrr)rqrrargsr8r8r9rs   z Cookies.clearcCs$t|}|jD]}|j|qdSrm)r*rr)rqrrr8r8r9rs zCookies.updatecCs |||Srm)rrqr,rCr8r8r9rrzCookies.__setitem__cCs||}|dur t||Srm)rrrr8r8r9rs zCookies.__getitem__cCs ||Srm)r)rqr,r8r8r9rrzCookies.__delitem__rcCrrm)rrrr8r8r9rrzCookies.__len__rcCr})Ncss|]}|jVqdSrm)r,rr8r8r9 sz#Cookies.__iter__..rrr8r8r9rszCookies.__iter__r3cCs|jD]}dSdS)NTFr)rqrr8r8r9__bool__s zCookies.__bool__cCs"ddd|jD}d|dS)Nrc Ss*g|]}d|jd|jd|jdqS)z)r,rCrrr8r8r9rrz$Cookies.__repr__..z )rCr<r0r=r2r>)rGr1r2r=)rCr1r2rP)rarbr2rc)M __future__rr4rdatetime email.messagerJrryrVrurllib.requestrcollections.abcrrhttp.cookiejarrrrrr r r _decodersr r rrrrr _exceptionsrrrrrrr _multipartr _status_codesr_typesrrrrr r!r"r#r$r%r&_urlsr'_utilsr(r)__all__rfTypeVarr/r:rBrFrOr`riMutableMappingr1r+r,r-r*r8r8r8r9sN $$ 4      % *