o e'@sxddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ddl mZmZmZmZddlmZmZmZmZmZmZmZmZddlmZmZmZmZm Z m!Z!m"Z"ddl#m$Z$dd l%m&Z&dd l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2dd l3m4Z4dd l5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;me>fZ?GdddZ@GdddZAGdddej=e>e>fZBdS)N)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)guess_json_utfis_known_encodingnormalize_header_keynormalize_header_valueobfuscate_sensitive_headersparse_content_type_charsetparse_header_linksc@seZdZdZ  d3dejedejeddfddZe defdd Z e j d eddfd d Z e dej ej eeffd d ZdejefddZdejefddZdejeeffddZdej ej eeffddZd4dedejdejfddZd5dededej efddZd4dejeddfddZd6d d!Zdedefd"d#Zded eddfd$d%Zdeddfd&d'Zdejdefd(d)Z dej!ejfd*d+Z"de#fd,d-Z$d.ejdefd/d0Z%defd1d2Z&dS)7Headersz9 HTTP headers, as a case-insensitive multi-dict. Nheadersencodingreturncsj|durg|_n(t|trt|j|_nt|tr&fdd|D|_n fdd|D|_|_dS)Nc4g|]\}}t|ddt|ddt|fqSF)lowerr0Tr)r*.0kvr0=D:\Projects\ConvertPro\env\Lib\site-packages\httpx/_models.py G z$Headers.__init__..cr2r3r5r6r:r;r<r=Pr>)_list isinstancer.listritems _encoding)selfr/r0r;r:r<__init__=s     zHeaders.__init__c 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)asciiutf-8z iso-8859-1)rCrawdecodeUnicodeDecodeError)rDr0keyvaluer;r;r<r0[s    zHeaders.encodingrLcC ||_dSNrCrDrLr;r;r<r0t cCdd|jDS)zH Returns a list of the raw header items, as byte pairs. cSsg|] \}}}||fqSr;r;)r7Zraw_key_rLr;r;r<r=}zHeaders.raw..r?rDr;r;r<rHxsz Headers.rawcsfddjDS)Ncs i|] \}}}|jdqSrNrIr0r7rSrKrLrVr;r< s z Headers.keys..)r?keysrVr;rVr<rZsz Headers.keyscC^i}|jD]%\}}}||j}||j}||vr&||d|7<q|||<q|S)N, )r?rIr0valuesrDZ values_dictrSrKrLZstr_keyZ str_valuer;r;r<r]s   zHeaders.valuescCr[)z Return `(key, value)` items of headers. Concatenate headers into a single comma separated value when a key occurs multiple times. r\)r?rIr0rBr^r;r;r<rBs   z Headers.itemscsfddjDS)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|jfqSr;rWrXrVr;r<r=sz'Headers.multi_items..rUrVr;rVr< multi_itemss zHeaders.multi_itemsrKdefaultcCs"z||WSty|YSw)z Return a header value. If multiple occurrences of the header occur then concatenate them together with commas. )KeyError)rDrKr`r;r;r<gets   z Headers.getF split_commascsZ|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|jqSr;)r4rIr0)r7rSitem_keyZ item_valueZget_header_keyrDr;r<r=s   z$Headers.get_list..cSsg|]}|qSr;)strip)r7itemr;r;r<r=s,)r4encoder0r?extendsplit)rDrKrcr]Z split_valuesrLr;rer<get_lists zHeaders.get_listcCs:t|}|D] }||vr||q|j|jdSrN)r.rZpopr?rj)rDr/rKr;r;r<updates   zHeaders.updatecCst||jdS)Nr:)r.r0rVr;r;r<copysz Headers.copycs<|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|jqSr;rW)r7rS header_key header_valueZnormalized_keyrDr;r<r=s  z'Headers.__getitem__..r\)r4rir0r?joinra)rDrKrBr;rrr< __getitem__s  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. rGcs"g|] \}\}}}|kr|qSr;r;r7idxrSrdZ lookup_keyr;r<r=s  z'Headers.__setitem__..rNr)rirCr4 enumerater?reversedappend)rDrKrLZset_key set_valueZ found_indexesrvr;rwr< __setitem__s  zHeaders.__setitem__csN||jfddt|jD}|st|t|D]}|j|=qdS)z* Remove the header `key`. cs&g|]\}\}}}|kr|qSr;)r4ruZdel_keyr;r<r=s   z'Headers.__delitem__..N)r4rir0rxr?rary)rDrKZ pop_indexesrvr;r}r< __delitem__s   zHeaders.__delitem__cCs$||j}|dd|jDvS)NcSsg|]\}}}|qSr;r;)r7rSrKr;r;r<r=sz(Headers.__contains__..)r4rir0r?)rDrKrpr;r;r< __contains__szHeaders.__contains__cCs t|SrN)iterrZrVr;r;r<__iter__ zHeaders.__iter__cC t|jSrN)lenr?rVr;r;r<__len__ zHeaders.__len__othercCsRzt|}Wn tyYdSwdd|jD}dd|jD}t|t|kS)NFcSg|] \}}}||fqSr;r;rXr;r;r<r=rTz"Headers.__eq__..cSrr;r;rXr;r;r<r= rT)r. ValueErrorr?sorted)rDrZ other_headersZ self_listZ other_listr;r;r<__eq__s  zHeaders.__eq__cCsv|jj}d}|jdkrd|j}tt|}t|}t|t|k}|r1|d||dS|d||dS)NrFz , encoding=()) __class____name__r0rAr+r_dictr)rD class_nameZ encoding_stras_listas_dictZno_duplicate_keysr;r;r<__repr__#s  zHeaders.__repr__NNrN)F)r1r.)'r __module__ __qualname____doc__typingOptionalrstrrEpropertyr0setterListTuplebytesrHKeysViewrZ ValuesViewr] ItemsViewrBr_Anyrbboolrlrnrortr|r~rIteratorrintrrrr;r;r;r<r.8sB       r.c@s:eZdZdddddddddd dejeefdejdefdejedeje deje d eje d eje d eje d ejejd ejeedfdejefddZdejeefddfddZedefddZdefddZdefddZdefddZdejeejffddZdejeejfddfd d!ZdS)"RequestN) paramsr/cookiescontentdatafilesjsonstream extensionsmethodurlr&rr/rrrrrrrc Cst|tr |dn||_t||_|dur"|jj|d|_t||_ | dur-in| |_ |r9t | || duro|j d} t|||| t| rR| |j jnddd\}} ||| |_t| trm|dSdS| |_dS)NrF)rz content-type) content_type)rrrrboundary)r@rrIupperrr&rZcopy_merge_paramsr.r/rCookiesset_cookie_headerrbrrrir0_preparerrread) rDrrrr/rrrrrrrrr;r;r<rE4s<       zRequest.__init__default_headersr1cCs|D]\}}|dkrd|jvrq|j||qg}d|jv}d|jvp,d|jv}|s<|jjr<|d|jjf|sH|jdvrH|dt ||jj |_dS)Ntransfer-encodingzContent-LengthHostzTransfer-EncodingsHost)POSTPUTPATCH)sContent-Length0) rBr4r/ setdefaultrhostrznetlocrr.rH)rDrrKrLZ auto_headersZhas_hostZhas_content_lengthr;r;r<rss   zRequest._preparecCt|dst|jSN_content)hasattrrrrVr;r;r<r zRequest.contentcCsHt|ds!t|jtjsJd|j|_t|jts!t|j|_|jS)6 Read and return the request content. r)rr@rrIterablersrrrVr;r;r<rs   z Request.readcsZt|ds*t|jtjsJddd|j2IdH|_t|jts*t|j|_|jS)rrrcg|z3dHW}|q6SrNr;r7partr;r;r<r=z!Request.aread..N)rr@rr AsyncIterablersrrrVr;r;r<areads   z Request.areadcCs,|jj}t|j}d|d|jd|dS)N)rrrrr)rDrrr;r;r<rs zRequest.__repr__cCdd|jDS)NcSi|] \}}|dvr||qS))rrr;r7namerLr;r;r<rY z(Request.__getstate__..__dict__rBrVr;r;r< __getstate__zRequest.__getstate__statecCs0|D] \}}t|||qi|_t|_dSrN)rBsetattrrrrrDrrrLr;r;r< __setstate__s zRequest.__setstate__)rrrrUnionrrrrrrrr r"rr%rr!rEDictrrrrrrrrr;r;r;r<r3sR       ?"rc@s&eZdZddddddddddd dedejedejedejedejed ej d ej e e dfd eje d ejed ejejddej eejegefffddZdejeefddfddZedejfddZejdejddfddZede fddZejde ddfddZedefddZedefdd Zedefd!d"Zedefd#d$Zedefd%d&Z edejefd'd(Z!e!jdeddfd)d(Z!edejefd*d+Z"de#fd,d-Z$ede%fd.d/Z&ede%fd0d1Z'ede%fd2d3Z(ede%fd4d5Z)ede%fd6d7Z*ede%fd8d9Z+ede%fd:d;Z,dhdej dej fd?d@Z.edidBdCZ/edejejeejeefffdDdEZ0edefdFdGZ1defdHdIZ2dejeej ffdJdKZ3dLejeej fddfdMdNZ4defdOdPZ5 djdQejedej6efdRdSZ7 djdQejedej6efdTdUZ8dej6efdVdWZ9 djdQejedej6efdXdYZ:dkdZd[Z;defd\d]Z< djdQejedej=efd^d_Z> djdQejedej=efd`daZ?dej=efdbdcZ@ djdQejedej=efdddeZAdkdfdgZBdS)lResponseNrG) r/rtexthtmlrrrequestrhistorydefault_encoding status_coder/rrrrrrrrrc Cs||_t||_||_d|_| durin| |_| durgnt| |_d|_d|_ | |_ |durJt ||||\}}| |||_ t|trI|n||_ d|_dS)NFr)rr.r/_requestZ next_requestrrAr is_closedis_stream_consumedrr rrr@rr_num_bytes_downloaded) rDrr/rrrrrrrrrr;r;r<rEs$    zResponse.__init__rr1cCs<|D]\}}|dkrd|jvrq|j||qdS)Nrzcontent-length)rBr4r/r)rDrrKrLr;r;r<rs zResponse._preparecCst|ds td|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 RuntimeErrorrrVr;r;r<elapseds zResponse.elapsedrcCrMrN)r)rDrr;r;r<r rQcCs|jdur td|jS)zR Returns the request instance associated to the current response. Nz7The request instance has not been set on this response.)rrrVr;r;r<r s zResponse.requestrLcCrMrN)rrPr;r;r<rrQcCs2z|jd}Wn tyYdSw|jdddS)N http_versionzHTTP/1.1rFignoreerrors)rrarI)rDrr;r;r<rs  zResponse.http_versioncCs<z|jd}Wntyt|jYSw|jdddS)N reason_phraserFrr)rrarZget_reason_phraserrI)rDrr;r;r<r%s  zResponse.reason_phrasecCs|jjS)zA Returns the URL for which the request was made. )rrrVr;r;r<r.sz Response.urlcCrr)rrrrVr;r;r<r5rzResponse.contentcCsRt|ds&|j}|sd|_|jSt|jpdd}d||j|g|_|jS)N_textrrGr:)rrrrr0rsrIflush)rDrdecoderr;r;r<r;s 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. rCNrrG)rcharset_encodingr(r@rrrrC)rDr0r;r;r<r0Fs     zResponse.encodingcCrMrNrOrPr;r;r<r0\rQcCs |jd}|dur dSt|S)zO Return the encoding, as specified by the Content-Type header. z Content-TypeN)r/rbr,)rDrr;r;r<r`s zResponse.charset_encodingc Cst|dsPg}|jjddd}|D]}|}z t|}||Wqty.Yqwt|dkr=|d|_ |j St|dkrLt |d|_ |j St |_ |j S)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)rcrr)children) rr/rlrfr4r rzrarrrr )rDZdecodersr]rLZ decoder_clsr;r;r<_get_content_decoderks&      zResponse._get_content_decodercC t|jS)zU A property which is `True` for 1xx status codes, `False` otherwise. )ris_informationalrrVr;r;r<r zResponse.is_informationalcCr)zU A property which is `True` for 2xx status codes, `False` otherwise. )r is_successrrVr;r;r<rrzResponse.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_redirectrrVr;r;r<rs zResponse.is_redirectcCr)zU A property which is `True` for 4xx status codes, `False` otherwise. )ris_client_errorrrVr;r;r<rrzResponse.is_client_errorcCr)zU A property which is `True` for 5xx status codes, `False` otherwise. )ris_server_errorrrVr;r;r<rrzResponse.is_server_errorcCr)z] A property which is `True` for 4xx and 5xx status codes, `False` otherwise. )ris_errorrrVr;r;r<rrzResponse.is_errorcCs(|jtjtjtjtjtjfvod|jvS)zs Returns True for 3xx responses with a properly formed URL redirection, `False` otherwise. ZLocation)rrMOVED_PERMANENTLYFOUND SEE_OTHERTEMPORARY_REDIRECTPERMANENT_REDIRECTr/rVr;r;r<has_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)rresponse)rrrr rrbformatr)rDrmessageZ status_classZ error_typesrr;r;r<raise_for_statuss*  zResponse.raise_for_statuskwargscKs^|jdur%|jr%t|jdkr%t|j}|dur%tj|j|fi|Stj|jfi|S)Nr )rrrr'jsonlibloadsrIr)rDrr0r;r;r<rs  z Response.jsonrcCs$t|dst|_|j||jS)N_cookies)rrrextract_cookiesrVr;r;r<rs  zResponse.cookiescCsF|jd}i}|r!t|}|D]}|dp|d}|||<q|S)zI Returns the parsed header links of the response, if any linkrelr)r/rbr-)rDheaderZldictlinksrrKr;r;r<rs  zResponse.linkscCs|jSrN)rrVr;r;r<num_bytes_downloaded szResponse.num_bytes_downloadedcCsd|jd|jdS)Nz )rrrVr;r;r<rszResponse.__repr__cCr)NcSr))rrrrr;rr;r;r<rYrz)Response.__getstate__..rrVr;r;r<rrzResponse.__getstate__rcCs6|D] \}}t|||qd|_i|_t|_dS)NT)rBrrrrrrr;r;r<rs  zResponse.__setstate__cCs t|ds d||_|jS)7 Read and return the response content. rr)rrs iter_bytesrrVr;r;r<r s z Response.read chunk_sizeccst|dr,|durt|jn|}tdt|jt|dD] }|j|||VqdS|}t|d}t|jd9| D]}| |}| |D]}|VqLq@| }| |D]}|Vq\| D]}|VqfWddS1swwYdSz A byte-iterator over the decoded response content. This allows us to handle gzip, deflate, and brotli encoded responses. rNrrr"r) rrrrangemaxrr rriter_rawrIrrDr"irchunkerZ raw_bytesdecodedchunkr;r;r<r!(s*     "zResponse.iter_bytesccst|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. rGr:r$r%N)rr0rrrr!rIrrDr"rr+Z byte_contentZ text_contentr-r;r;r< iter_textAs     "zResponse.iter_textccsrt}t|jd%|D] }||D]}|Vqq|D]}|Vq!WddS1s2wYdSNr%)rrrr0rIrrDrrliner;r;r< iter_linesVs  "zResponse.iter_linesccs|jrt|jr tt|jtstdd|_d|_t |d}t |j d"|jD]}|jt |7_| |D]}|Vq.N)rrs aiter_bytesrrVr;r;r<rs  zResponse.areadcCst|dr,|durt|jn|}tdt|jt|dD] }|j|||VqdS|}t|d}t|jd>| 2z3dHW}| |}| |D]}|VqPq@6| }| |D]}|Vqa| D]}|VqkWddS1s|wYdSr#) rrrr&r'rr rr aiter_rawrIrr)r;r;r<r9s,    "zResponse.aiter_bytescCst|jpdd}t|d}t|jd>|2z3dHW}||}||D]}|Vq)q6|}||D]}|Vq:|D]}|VqDWddS1sUwYdSr.)rr0rrrr9rIrr/r;r;r< aiter_texts"   "zResponse.aiter_textcCs|t}t|jd*|2z3dHW}||D]}|Vqq6|D]}|Vq&WddS1s7wYdSr1)rrrr;rIrr2r;r;r< aiter_liness "zResponse.aiter_linescCs|jrt|jr tt|jtstdd|_d|_t |d}t |j d'|j2z3dHW}|jt |7_| |D]}|Vq@q,6Wdn1sRwY|D]}|Vq[|IdHdS)r5z6Attempted to call an async iterator on an sync stream.Trr$r%N)rrrrr@rrrrr rrrrIracloser7r;r;r<r:s*   zResponse.aiter_rawcsht|jts td|js2d|_t|jd|jIdHWddS1s+wYdSdS)r8z3Attempted to call an async close on an sync stream.Tr%N)r@rrrrrrr=rVr;r;r<r=s "zResponse.aclose)r1r)r1rrN)r1N)Crrrrrrrr#rrrr%rrr$rCallablerrErrrdatetime timedeltarrrrrr&rrrr0rr rrrrrrrrr rrrrrrrrrrr!r0r4r(r6r AsyncIteratorr9r;r<r:r=r;r;r;r<rs     7      % *            rc @seZdZdZd0dejeddfddZdeddfdd Z d e ddfd d Z d1de de de de ddf ddZ   d2de deje deje deje deje f ddZ  d3de deje deje ddfddZ d3deje deje ddfddZd0dejeddfddZde de ddfddZde de fd d!Zde ddfd"d#Zdefd$d%Zdeje fd&d'Zdefd(d)Zde fd*d+ZGd,d-d-ejj ZGd.d/d/ZdS)4rz- HTTP Cookies, as a mutable mapping. Nrr1cCs|dus t|tr%t|_t|tr!|D] \}}|||qdSdSt|tr=t|_|D] \}}|||q0dSt|trTt|_|jD]}|j|qIdS||_dSrN) r@rrjarrBsetrAr set_cookie)rDrrKrLcookier;r;r<rEs$      zCookies.__init__rcCs(||}||j}|j||dS)zO Loads any cookies based on the response `Set-Cookie` headers. N)_CookieCompatResponse_CookieCompatRequestrrBr)rDrZurllib_responseurllib_requestr;r;r<rs  zCookies.extract_cookiesrcCs||}|j|dS)zM Sets an appropriate 'Cookie:' HTTP header on the `Request`. N)rGrBadd_cookie_header)rDrrHr;r;r<rs zCookies.set_cookie_headerr/rrLdomainpathcCsiddd|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. versionrrrLportNport_specifiedFrKdomain_specifieddomain_initial_dot.rLpath_specifiedsecureexpiresdiscardTcomment comment_urlrestHttpOnlyrfc2109r;)r startswithrrBrD)rDrrLrKrLrrEr;r;r<rCsJ      z Cookies.setr`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=)rBrrKrLrrL)rDrr`rKrLrLrErr;r;r<rb1s   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|qSrN)rrKrLr7rErKrrLr;r<r=Ws z"Cookies.delete..)rBclearrKrLr)rDrrKrLremoverEr;r^r<deleteJs 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)rzrBr_)rDrKrLargsr;r;r<r_bs   z Cookies.clearcCs$t|}|jD]}|j|qdSrN)rrBrD)rDrrEr;r;r<rnqs zCookies.updatecCs |||SrN)rCrDrrLr;r;r<r|vrzCookies.__setitem__cCs||}|dur t||SrN)rbrarcr;r;r<rtys zCookies.__getitem__cCs ||SrN)ra)rDrr;r;r<r~rzCookies.__delitem__cCrrN)rrBrVr;r;r<rrzCookies.__len__cCrR)Ncss|]}|jVqdSrN)rr]r;r;r< sz#Cookies.__iter__..rBrVr;r;r<rszCookies.__iter__cCs|jD]}dSdS)NTFre)rDrSr;r;r<__bool__s zCookies.__bool__cCs"ddd|jD}d|dS)Nr\c Ss*g|]}d|jd|jd|jdqS)z)rrLrKr]r;r;r<r=sz$Cookies.__repr__..z s2 ($ 4 $ | 8