nbi!BdZddlmZddlZddlZddlZddlZddlZ ddl Z n#e $rddl Z YnwxYwddl Z e jrddlmZddlmZddlmZddlmZddlmZdd lmZmZmZdd lmZd d l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.d d l/m0Z0m1Z1d dl2m3Z3m4Z4d dl5m6Z6m7Z7m8Z8m9Z9d dl:m;Z;mZ>m?Z?m@Z@mAZAmBZBd dl:mCZDd dl:mEZFd dlGmHZHd dlImJZKd dlImLZLmMZMmNZNd dlOmPZPmQZQmRZRd dlSmTZTmUZUmVZVd dlWmXZXmYZYmZZZm[Z[mEZEd dl\m]Z]d dl^m_Z_m`Z`d dlambZbd dlcmdZdd dlemfZfd dlgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqedjredjsedjtedjuedjvfZwdZxd Zyd!ZzGd"d#Z{Gd$d%Z|Gd&d'Z}Gd(d)Z~Gd*d+e~ZdS),z` requests.models ~~~~~~~~~~~~~~~ This module contains the primary objects that power Requests. ) annotationsN)Literal)Mapping) cookiejar) CookieJar)UnsupportedOperation) urlencodeurlsplit urlunparse) from_bytes) AsyncBodyType AsyncHookTypeAsyncHttpAuthenticationType BodyFormTypeBodyType CookiesType HeadersTypeHookCallableTypeHookTypeHttpAuthenticationTypeHttpMethodTypeMultiPartFilesAltTypeMultiPartFilesTypeQueryParameterType)Headersparse_it)BearerTokenAuth HTTPBasicAuth)RequestsCookieJar_copy_cookie_jarcookiejar_from_dictget_cookie_header)ChunkedEncodingErrorConnectionErrorContentDecodingError HTTPErrorInvalidJSONError InvalidURLMultiplexingErrorStreamConsumedError)JSONDecodeError)SSLError) default_hooks)AsyncHTTPResponse)BaseHTTPResponseConnectionInfoResponsePromise)RawExtensionFromHTTP ServerSideEventExtensionFromHTTPWebSocketExtensionFromHTTP)AsyncRawExtensionFromHTTP%AsyncServerSideEventExtensionFromHTTPAsyncWebSocketExtensionFromHTTP) DecodeErrorLocationParseError ProtocolErrorReadTimeoutErrorr-) RequestField)choose_boundaryencode_multipart_formdata) parse_url)codes)CaseInsensitiveDict) astream_decode_response_unicodeget_auth_from_urlguess_filename iter_slicesparse_header_links parse_scheme requote_uristream_decode_response_unicode super_lento_key_val_listi(c4eZdZdZeddZd dZdS) TransferProgressc>d|_d|_d|_d|_dS)NrF)totalcontent_length is_completed any_errorselfs _/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/niquests/models.py__init__zTransferProgress.__init__s$ *."'$return float | NonecT|jdSt|j|jz dzdS)NgY@)rSroundrRrVs rX percentagezTransferProgress.percentages/   &4dj4#66%?CCCrZstrcx|jrd|jd|jd|jdSd|jd|jdurdnddS) Nz z bytes sent (Fz in progress completed)rSr`rRrTrVs rX__repr__zTransferProgress.__repr__sd   \[[[TZ[[DDW[[[ [uDJuudFW[`F`F`]]fquuuurZN)r[r\r[ra)__name__ __module__ __qualname__rYpropertyr`rdrZrXrPrPsa%%% DDDXD vvvvvvrZrPcjeZdZdZ d(d)dZed*dZd+dZd,d"Zd-d%Z d.d'Z dS)/Requesta{A user-created :class:`Request ` object. Used to prepare a :class:`PreparedRequest `, which is sent to the server. :param method: HTTP method to use. :param url: URL to send. :param headers: dictionary of headers to send. :param files: dictionary of {filename: fileobject} files to multipart upload. :param data: the body to attach to the request. If a dictionary or list of tuples ``[(key, value)]`` is provided, form-encoding will take place. :param json: json for the body to attach to the request (if files or data is not specified). :param params: URL parameters to append to the URL. If a dictionary or list of tuples ``[(key, value)]`` is provided, form-encoding will take place. :param auth: Auth handler or (user, pass) tuple. :param cookies: dictionary or CookieJar of cookies to attach to this request. :param hooks: dictionary of callback hooks, for internal usage. Usage:: >>> import niquests >>> req = niquests.Request('GET', 'https://httpbin.org/get') >>> req.prepare() NmethodHttpMethodType | Noneurl str | NoneheadersHeadersType | Nonefiles1MultiPartFilesType | MultiPartFilesAltType | NonedataBodyType | AsyncBodyType | NoneparamsQueryParameterType | Noneauth;HttpAuthenticationType | AsyncHttpAuthenticationType | NonecookiesCookiesType | NonehooksHookType | AsyncHookType | Nonejsontyping.Any | Nonebase_urlc |gn|}|gn|}|tn|}|in|}| in| } t|_t| D]\} } || | ||_||_||_||_ ||_ | |_ ||_ ||_ ||_| |_dS)N)eventhook)rBr.r}listitems register_hookrmrorqrsrurrwryr{r)rWrmrorqrsrurwryr{r}rrkvs rXrYzRequest.__init__s\rrtm+2?%'''~6m;H?? '' 0 0DAq   QQ  / / / /          rZr[rc*t|jSNrrqrVs rXoheaderszRequest.oheaders %%%rZracd|jdS)Nz rmrVs rXrdzRequest.__repr__s+DK++++rZrraHookCallableType[Response | PreparedRequest] | list[HookCallableType[Response | PreparedRequest]]Nonec"||jvrtd|dt|r"|j||dSt |t r,|j|d|DdSdS)Properly register a hook..Unsupported event specified, with event name ""c38K|]}t||VdSrcallable.0hs rX z(Request.register_hook..-$D$D1 $DQ$D$D$D$D$D$DrZN)r} ValueErrorrappend isinstancerextendrWrrs rXrzRequest.register_hooks  " "VeVVVWW W D>> E Ju  $ $T * * * * * d # # E Ju  $ $$D$D$D$D$D D D D D D E ErZ,HookCallableType[Response | PreparedRequest]boolcj |j||dS#t$rYdSwxYwziDeregister a previously registered hook. Returns True if the hook existed, False if not. TFr}removerrs rXderegister_hookzRequest.deregister_hookI   Ju  $ $T * * *4   55  $ 22PreparedRequestc t}||j|j|j|j|j|j|j|j |j |j |j  |S)zXConstructs a :class:`PreparedRequest ` for transmission and returns it.) rmrorqrsrurrwryr{r}r) rpreparermrorqrsrurrwryr{r}rrWps rXrzRequest.preparesf    ;L*;L*]  rZ NNNNNNNNNNN)rmrnrorprqrrrsrtrurvrwrxryrzr{r|r}r~rrrrpr[rre)rrarrr[r)rrarrr[rr[r) rfrgrh__doc__rYrirrdrrrrjrZrXrlrls:)-&*CG04,0LP&*15"&#"!"!"!"!"!H&&&X&,,,, E E E E    rZrlceZdZUdZded<d;dZeddZd?d!Z d@d"Z dAd#Z d d$dBd%Z dCd&Z dDdEd'ZdFd)Z dGdHd+ZdId,Zd;d-Zd;d.ZdJd1Zed?d2Ze dDdKd6ZedLd:Zd S)Mra0The fully mutable :class:`PreparedRequest ` object, containing the exact bytes that will be sent to the server. Instances are generated from a :class:`Request ` object, and should not be instantiated manually; doing so may produce undesirable effects. Usage:: >>> import niquests >>> req = niquests.Request('GET', 'https://httpbin.org/get') >>> r = req.prepare() >>> r >>> s = niquests.Session() >>> s.send(r) r_pending_async_authr[rcd|_d|_d|_d|_d|_t |_d|_d|_d|_ d|_ d|_ dS)NF) rmrorq_cookiesbodyr.r}_body_position conn_info ocsp_verifiedupload_progress_asynchronous_authrVs rXrYzPreparedRequest.__init__+s`-1 #37 ?C 59 ;H?? 3704*.8<(-rZrc*t|jSrrrVs rXrzPreparedRequest.oheadersDrrZNrmrnrorprqrrrsrtrurvrwrxryrzr{r|r}+HookType[Response | PreparedRequest] | Nonerrrc 6|||||| |||||||| |||| dS)z6Prepares the entire request with the given parameters.rN)prepare_method prepare_urlprepare_headersprepare_cookies prepare_body prepare_auth prepare_hooks) rWrmrorqrsrurwryr{r}rrs rXrzPreparedRequest.prepareHs F### fx888 W%%% W%%% $t,,, $ 5!!!!!rZracd|jdS)Nz|dr |dd}|dsd|}||z}t|tr|d}nt |}|}t|ds ||_dS t|\}}}}}} } n #t$r} t| j d} ~ wwxYw|std |d |d rtd |rd |vr"|s |s|ds ||_dS|pd} | r| dz } | |z } |r| d|z } |sd}|r~t|tr|d}| |} | r=t| ttfr| d} | r| d| } n| } tt!|| |d| | g|_dS)zPrepares the given HTTP URL.NzMissing URL in PreparedRequest)default/rNutf8httpz Invalid URL z: No host supplied)*.zURL has an invalid label.%zxn--@:utf-8&)rHendswith startswithrbytesdecoderalstripror@r:r)args_encode_params bytearrayrIr )rWrorwrschemeryhostportpathqueryfragmentenetloc enc_paramss rXrzPreparedRequest.prepare_urlws @  C,,,22$$S))-'}H~~c**$#c))Cn c5 ! ! **V$$CCc((Cjjll C  ++F33 DH F &>Gnn ;FD$dE88! & & &af% % & GECEEEFF F ??: & & :899 9 4fT__]cMdMdDH F   cMF$  ! j$jj F D  '&%(( 0w//,,V44J 'j5)*<==D  DcNt|_|rt|tr)|jt|dS|D]<}|\}}t|t r|}||j|<;dSdS)z Prepares the given HTTP headers.N)rBrqrrupdaterrr)rWrqheadernamevalues rXrzPreparedRequest.prepare_headerss+,,  /'4(( / ##$7$@$@AAAAA%mmoo//F"(KD%!$..-#{{}}).DL&& / ///rZc t|jJd}d}d}|s|d}i}ttdsd|d< tj|fi|}n##t$r}t ||d}~wwxYwt |tr|d}t|dpEtt|d t |ttttf g} | r t|} n#ttt f$rd} YnwxYw|}|Nt|d r> ||_n##t&$rt)|_YnwxYw|rt+d | rt| |jd <n|r d |jd<n|rXt |tt,fs"| t dt/|d|||\}}n|rd|jvod|jdv}|rp|r_|jjddur>|jjd|jjdn t;} nd} ||| }t |tst|drd}n |sd}nd| }t |tt,fdusJ|||rd|jvr ||jd<n|r |r ||jd<||_ dS)z"Prepares the given HTTP body data.NFzapplication/json;charset=utf-8orjson allow_nan)requestr __aiter____iter__tellz1Streamed bodies and files are mutually exclusive.Content-LengthchunkedzTransfer-Encodingz@Conflicting parameters. Cannot pass files with given data: type()z content-typezmultipart/form-databoundary)boundary_for_multipartreadz!application/x-www-form-urlencodedzmultipart/form-data; boundary=z Content-Type)!rqhasattr_jsondumpsrr(rraencodeallrtuplerrK TypeErrorAttributeErrorrrrOSErrorobjectNotImplementedErrordicttype _encode_filesr content_typehas_manygetr>rprepare_content_lengthr) rWrursrrrenforce_form_data json_kwargsve is_streamlengthform_data_boundarys rXrzPreparedRequest.prepare_bodys'|'''15#' ! ,(14V -.. >4= 01' a   w|$%uhlmqhrhr%u%u%uvvv'+'9'9%'F'F$||a(6$,(F)AK`dhdpqeALA%( 2 13 $ : C CJ O OSX X X $ : > >z J J V!M6:::FFF"1!2!2 +*.2*../A/D"$,,af0E0Ea'+ 0a+NLL+`L^+`+`LdT4L11U::::  ' ' - - - <t|!C!C/; ^,, <"3 Prepare Content-Length header based on request method and bodyNr)GETHEAD0)rqrKrarmr)rWrrs rXrz&PreparedRequest.prepare_content_lengthQs|'''  t__F =25V -... = =[ / /DL4D4DEU4V4V4^.1DL) * * *0 /4^4^rZrc|j Jd|'t|j}t|r|nd}|r t|trt |dkr t |}n$t|trt|}t|stdt|dotj |jptj ||_|jsF||}|j|j||jdS||_dSdS)z"Prepares the given HTTP auth data.NzACannot invoke prepare_auth method with incomplete PreparedRequestzXUnexpected non-callable authentication. Did you pass unsupported tuple to auth argument?__call__)rorDanyrrlenrrarrrrasyncioiscoroutinefunctionrr__dict__rrrr)rWryrourl_authrs rXrzPreparedRequest.prepare_auth`s\x##%h### <(22H"8}}688$D  0$&& -3t99>>$d+D#&& -&t,,D>> } !{|||j))Xg.I$-.X.X'3,T22  #* 0DJJ $$QZ000++DI66666+/(((1 0 0rZc|j Jdt|tjr||_nt ||_t |j|}| ||jd<dSdS)aPrepares the given HTTP cookie data. This function eventually generates a ``Cookie`` header from the given cookies using cookielib. Due to cookielib's design, the header will not be regenerated if it already exists, meaning this function can only be called once for the life of the :class:`PreparedRequest ` object. Any subsequent calls to ``prepare_cookies`` will have no actual effect, unless the "Cookie" header is removed beforehand. Nz>  $%2DL " " " % $rZcP|pg}|D]}||||dS)zPrepares the given hooks.N)r)rWr}rs rXrzPreparedRequest.prepare_hookssC   4 4E   ueEl 3 3 3 3 4 4rZc||jvrtd|dt|r"|j||dSt |dr,|j|d|DdSdS)rrrrc38K|]}t||VdSrrrs rXrz0PreparedRequest.register_hook..rrZN)r}rrrrrrs rXrzPreparedRequest.register_hooks  " "VeVVVWW W D>> E Ju  $ $T * * * * * T: & & E Ju  $ $$D$D$D$D$D D D D D D E ErZrrcj |j||dS#t$rYdSwxYwrrrs rXrzPreparedRequest.deregister_hookrrc|jJg}t|j}|j}|sd}|||j}|r*|d||d|S)zBuild the path URL to use.Nr?r)ror rrrjoin)rWrorrrs rXpath_urlzPreparedRequest.path_urlsx### TX  v D 4   JJsOOO JJu   wws||rZ-QueryParameterType | BodyFormType | typing.IOrstr | bytes | bytearrayc Ht|tttfr|St |dr|St |dr*g}t |D]\}}t|tttttfst |ds3|-t|ttfst|g}n |g}n||ng}|D]o}|k| t|tr| dn|t|tr| dn|fp|rt||dSt|dStd t|d ) zEncode parameters in a piece of data. Will successfully encode parameters when passed as a dict or a list of 2-tuples. Order is retained if data is a list of 2-tuples but arbitrary if parameters are supplied as a dict. rrNr)rrT)doseqz9Function _encode_params got an unexpected type argument '')rrarrrrrLintfloatrrrr?r rr )rurresultrvs iterable_vsrs rXrzPreparedRequest._encode_paramss dS%3 4 4& hK T6 " "$ h99;;  T: & &" hF(..  2b3sE4"@AA?QSU_I`I`?~j!//~(+2wwi ')d (*""BK$A} 5?35G5G N 1 1 1Q5?35G5G N 1 1 1Q& 03V4000 0fY]^bYcYcfffgg grZ*MultiPartFilesType | MultiPartFilesAltTypeMdict[str | bytes, str | bytes] | list[tuple[str | bytes, str | bytes]] | Nonetuple[bytes, str]c |stdt|trtdg}t|pi}t|pi}|D]\}}t|ttfst |ds|g}n|}|D]}|t|tst|}|t|tr|dn|t|tr|dn|f|D]:\} } d} d} t| ttfrbt| dkrt| \} }ntt| dkrt| \} }} nMt| \} }} } n8t| tttfr| } nt| p| } | }t|tttfr|}nIt |dr|}n$|td t|d  | rt| t r| } t%}t| D]^\}}t|tr|d }t|tr|d }|||<_nd}n"#t&$r}td |d}~wwxYwt)| || |}|| ||%+]]9%=%=F/5 V,, 6$(L% p p p !ghhnoo p4eb,WWWB   2  . . .   b ! ! ! !6zBBl\!!sB*L L%L  L%r[rrr)rmrnrorprqrrrsrtrurvrwrxryrzr{r|r}rrrrrpr[rrer)rmrnr[r)rorprwrxrrpr[r)rqrrr[rr)rurvrsrtrrr[r)rrvr[r)r)ryrzrorar[r)r{r|r[r)rrar[r)rur3rrpr[r4)rsr=rur>r[r?)rfrgrhr__annotations__rYrirrrdrrrrrrrrrrrr2 staticmethodrrrjrZrXrrs?(5444....2&&&X& )-&*CG04,0LP&*=A"&#""""":4444    ;;;; $ OZOZOZOZOZOZb / / / /&#' xxxxxt 1 1 1 1$&0&0&0&0&0P3333,4444 E E E E    X(.21h1h1h1h\1hfh"h"h"\h"h"h"rZrceZdZUdZgdZhdZded<ded<dHd ZedId Z edJfd Z dHfd Z fdZ dZ dZfdZdZdKdZdJdZdLdZedJdZedJdZedJdZedMdZedNd ZedOd"Zej dPdQd(ZejdRdSd+Zed,fdTd.ZefdUd/Zej dVdWd2Zej dRd#d3dXd4Zed,d5fdYd6ZedZd8Z edZd9Z!ed[d;Z"ed\d=Z#d]d@Z$edAZ%ed^dCZ&d_dDZ'dHdEZ(d_dFZ)dHdGZ*xZ+S)`ResponsezhThe :class:`Response ` object, which contains a server's response to an HTTP request. ) _content status_coderqrohistoryencodingreasonr{elapsedr>okrornexttextlinksr`contentr{rarqr\r_ iter_lines is_redirectr] iter_contentis_permanent_redirectr2_promisezDtyping.Callable[[Response, PreparedRequest], PreparedRequest | None]_resolve_redirectr[rcFd|_d|_d|_d|_t |_t |_d|_d|_d|_ g|_ d|_ ti|_ tjd|_d|_d|_dS)NFr)r\_content_consumed_nextr]rBrqtrailersrawror_r^r`r"r{datetime timedeltarardownload_progressrVs rXrYzResponse.__init__s7< ',-1 (, -@,A,A .A-B-B -1 $%) (* #' #6b"9"9 ,4+=a+@+@ 04 ;?rZWebSocketExtensionFromHTTP | RawExtensionFromHTTP | ServerSideEventExtensionFromHTTP | AsyncWebSocketExtensionFromHTTP | AsyncRawExtensionFromHTTP | AsyncServerSideEventExtensionFromHTTP | NonecV|j!t|jdr |jjndS)aAccess the I/O after an Upgraded connection. E.g. for a WebSocket handler. If the server opened a WebSocket, then the extension will be of type WebSocketExtensionFromHTTP. Otherwise, on unknown protocol, it will be RawExtensionFromHTTP. Warning: If you stand in an async inclosure, the type will be AsyncWebSocketExtensionFromHTTP or AsyncRawExtensionFromHTTP.N extensionrqrrwrVs rXrwzResponse.extensions2&x#+(F(F# H   rZrcn tddS#t$rYdSwxYw)z Determine if response isn't received and is actually a placeholder. Only significant if request was sent through a multiplexed connection. rkTF)super__getattribute__rrW __class__s rXlazyz Response.lazysG   GG $ $Z 0 0 04   55 s !& 44c tdtd|dS#t$rYdSwxYwz`internals used for lazy responses. Do not try to access this unless you know what you are doing.rk connectionN)rzr{gatherrr|s rX_gatherzResponse._gathersn  GG $ $Z 0 0 0 GG $ $\ 2 2 9 9$ ? ? ? ? ?    DD sAA A('A(c td|tjvrtdrpt jtdjrtdtdn#t$rYnwxYwt|S)Nrqr~rAccessing a lazy response produced by an AsyncSession is forbidden. Either call await session.gather() or set stream=True to produce an AsyncResponse that you can access directly.r) rzr{r[__lazy_attrs__r"r#rr*rrWitemr}s rXr{zResponse.__getattribute__s ww''..648CZ;Z;Z_d_f_f_w_wx~__;Z.uww/G/G /U/U/\]]:+8 8EGG,,Y77999    D ww''---sCC CCc|SrrjrVs rX __enter__zResponse.__enter__ rZc.|dSrclose)rWrs rX__exit__zResponse.__exit__s rZc jr[tjtdjrt djsj fdj DS)Nrrc4i|]}|t|dSr)getattr)rattrrWs rX z)Response.__getstate__..-s'KKKDgdD$//KKKrZ) r~r"r#rzr{rr*rrnrf __attrs__r|s`rX __getstate__zResponse.__getstate__s 9 *577+C+CL+Q+Q+XYY '4  %  LLKKKKDNKKKKrZct|ddt|dd|D]\}}t|||dS)NrnTrq)setattrr)rWstaterrs rX __setstate__zResponse.__setstate__/sa)4000eT""" ;;== ' 'KD% D$ & & & & ' 'rZrac|j|jj|jjj d|jdS|jjjjdd}|jrd|dSd|d|jdS) Nzz ..PPrZcRd|jvo|jtjtjfvS)z@True if this Response one of the permanent versions of redirect.r)rqr]rAmoved_permanentlypermanent_redirectrVs rXrjzResponse.is_permanent_redirectgs4T\) d.>  #  $C /  rZPreparedRequest | Nonec|jS)zTReturns a PreparedRequest for the next request in a redirect chain, if there is one.)rorVs rXrcz Response.nextos zrZConnectionInfo | NonecV|jr!t|jdr |jjSdS)zSProvide context to the established connection that was used to perform the request.rN)rrrrVs rXrzResponse.conn_infots1 < *GDL+>> *<) )trZ bool | NonecV|jr!t|jdr |jjSdS)z4Marker that can inform you of the OCSP verification.rN)rrrrVs rXrzResponse.ocsp_verified{s1 < .GDL/BB .<- -trZ. chunk_sizer8decode_unicodeLiteral[False]cdSrrjrWrrs rXrizResponse.iter_contents /2crZ Literal[True]!typing.Generator[str, None, None]cdSrrjrs rXrizResponse.iter_contentsz}z}rZF)typing.Generator[bytes | str, None, None]c`dfd }jr(tjtrt 5tt s t dtdtjpd}|}jr|n|}|rt|S|S) anIterates over the response data. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. The chunk size is the number of bytes it should read into memory. This is not necessarily the length of each item returned as decoding can take place. chunk_size must be of type int or None. A value of None will function differently depending on the value of `stream`. stream=True will read data as it arrives in whatever size the chunks are received. If stream=False, data is returned as a single chunk. If decode_unicode is True, content will be decoded using the best available encoding based on the response. We recommend setting chunk_size=-1 (default) to receive chunk as they come for performance purposes. r[rc36KjJtjdotjjd}|rYjRdjvrIt _ t jdj_n#t$rYnwxYwtjdr j dD](}jjjj j_ |V)n#t$r'}j dj_ t|d}~wt$r'}j dj_ t!|d}~wt"$r'}j dj_ t%|d}~wt&$r'}j dj_ t)|d}~wwxYw j}|sn|V"j3tjdrt-jj_d_dS)N_fp data_in_countcontent-lengthstreamTdecode_contentrprqrrrtrqrPr8rSrrrrRr;rUr$r9r&r<r%r-RequestsSSLErrorrrBrprncan_track_progresschunkrrrWs rXgeneratez'Response.iter_content..generatesi8'''!(5!9!9!dgdhlTc>d>d ! d&<&D#t|33-=-?-?D*@CDLQaDb@c@c.==%tx** .!%D!Q!Q$$1=;?8<;UD28# $%222-9;?.8.q111"222-9;?.8.q111'----9;?.8)!,,,...-9;?.8*1---.   HMM*55E KKK  x#*(E(E# 3DH4E F F %)D " " "O"$B BB.AC44 F2>"D  F2-"E F2"E>> F2 "F--F2N+chunk_size must be an int, it is instead a rrZr[r) rnrr\rr+r8rr rFrJ)rWrrr reused_chunks stream_chunkschunkss`` rXrizResponse.iter_contents,. *. *. *. *. *. *. *`  ! _j&E&E _%'' '  #Jz3,G,G #]$zJZJZ]]]^^ ^#DM$8S*EE   "&"8Km  @1&$?? ? rZc4dfd }jr(tjtrt 5tt s t dtdtjpd}jr|n |S) aIterates over the response raw and possibly compressed data. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. The chunk size is the number of bytes it should read into memory. This is not necessarily the length of each item returned as decoding can take place. chunk_size must be of type int or None. A value of None will function differently depending on the value of `stream`. stream=True will read data as it arrives in whatever size the chunks are received. If stream=False, data is returned as a single chunk. If decode_unicode is True, content will be decoded using the best available encoding based on the response. We recommend setting chunk_size=-1 (default) to receive chunk as they come for performance purposes. r[rc36KjJtjdotjjd}|rYjRdjvrIt _ t jdj_n#t$rYnwxYwtjdr j dD](}jjjj j_ |V)n#t$r'}j dj_ t|d}~wt$r'}j dj_ t!|d}~wt"$r'}j dj_ t%|d}~wt&$r'}j dj_ t)|d}~wwxYw j}|sn|V"j3tjdrt-jj_d_dS) NrrrrFrTrprrs rXrz#Response.iter_raw..generatesi8'''!(5!9!9!dgdhlTc>d>d ! d&<&D#t|33-=-?-?D*@CDLQaDb@c@c.==%tx** .!%E!R!R$$1=;?8<;UD28# $%222-9;?.8.q111"222-9;?.8.q111'----9;?.8)!,,,...-9;?.8*1---.   HMM*55E KKK  x#*(E(E# 3DH4E F F %)D " " "rNrrrZr) rnrr\rr+r8rr rF)rWrrrs`` rXiter_rawzResponse.iter_raws*. *. *. *. *. *. *. *`  ! _j&E&E _%'' '  #Jz3,G,G #]$zJZJZ]]]^^ ^#DM$8S*EE $ 6F}}HHJJFrZ delimiterstr | bytes | NonecdSrrjrWrrrs rXrgzResponse.iter_lines.s /2crZrcdSrrjrs rXrgzResponse.iter_lines6s -0CrZNc#K|(|dur$t|trtdd}|||D]x}|||z}|r||}n|}|r7|dr/|r-|dd|dkr|}nd}|Ed{Vy||VdSdS)zIterates over the response data, one line at a time. When stream=True is set on the request, this avoids reading the content at once into memory for large responses. .. note:: This method is not reentrant safe. NFdelimiter MUST match the desired output type. e.g. if decode_unicode is set to True, delimiter MUST be a str, otherwise we expect a bytes-like variable.rrrNrrarrisplit splitlinespop)rWrrrpendingrliness rXrgzResponse.iter_lines?s'  ^u%<%<IWZA[A[%<x  &&!.'    E"% + I..((** r u r2%)1K1K))++          MMMMM  rZrcn|jrt|j}|dz}|St|jS)a- Retrieve headers as they were objects. There is no need to parse headers yourself. A simple Mapping isn't enough to quickly access and analyze them. Read the full documentation of object-oriented headers at https://jawah.github.io/kiss-headers/ >>> import niquests >>> r = niquests.get("https://google.com") >>> r.oheaders.content_type.charset 'ISO-8859-1' >>> r.oheaders.content_type 'text/html; charset=ISO-8859-1' >>> r.oheaders.content_type[0] 'text/html' z Set-Cookie)rqrrq)rWrqs rXrzResponse.oheadershs< 8 tx((G | #GN %%%rZcj|jrt|jjSt|jS)ze Retrieve trailers as they were objects. There is no need to parse headers yourself. )rqrrprVs rX otrailerszResponse.otrailers}s1 8 /DH-.. . &&&rZ bytes | Nonec|jdur|jrtd|jdks|jd|_n t |jdr!|jd|_n|j|_nu#t$r}t|d}~wt$r}t|d}~wt$r}t|d}~wt$r}t|d}~wwxYwd|_|j3t |jdrt|jj|_|jS) z"Content of the response, in bytes.F2The content for this response was already consumedrNrTrrp)r\rn RuntimeErrorr]rqrrr;r$r9r&r<r%r-rrBrprWrs rXrfzResponse.contentsh =E ! !% Y"#WXXX1$$(8 $  .tx228(, T (J(J (,  $222.q111"222.q111'---)!,,,...*1---."& 8 GDHj$A$A /0ABBDM}s<AB DB)) D6C DC!! D.C==Drpc|jsdS|jM tj|j}t |dr |jdurdSn#t $r d|_YnwxYw|jCt|j}|r|j|_t|S|jdSt|j|jdS)aContent of the response, in unicode. If Response.encoding is None, encoding will be guessed using ``charset_normalizer``. The encoding of the response content is determined based solely on HTTP headers, following RFC 2616 to the letter. If you can take advantage of non-HTTP knowledge to make a better guess at the encoding, you should set ``r.encoding`` appropriately before accessing this property. rN_is_text_encodingFrerrors rfr_codecslookuprr LookupErrorr bestra)rWinfoencoding_guesss rXrdz Response.texts| 2 = $ %}T]334!455 $:PTY:Y:Y4 % % % $  % = ' 55::<*** = 44<yAAAAs2AAAkwargs typing.Anyc 4|jstddd|jst|jgd}|c|j|_ t jt|fi|S#t j$r%}t|j |j |j d}~wwxYwd|_|j }|tddd t j|fi|S#t j$r%}t|j |j |j d}~wwxYw) a"Returns the json-encoded content of a response, if any. :param \*\*kwargs: Optional arguments that ``json.loads`` takes. :raises requests.exceptions.JSONDecodeError: If the response body does not contain valid json or if content-type is not about json. response content is not JSONrrrArzutf-16zutf-32z utf-16-lez utf-16-bez utf-32-lez utf-32-be cp_isolationNrz&response cannot lead to decodable JSON rfRequestsJSONDecodeErrorr_r rrloadsrar,msgdocposrd)rWrrr plain_contents rXrz Response.jsons^| Q)*H"aPP P} ( (       dff ) . 7 G ;s>':':EEfEEE,GGG1!%FFFG!(   )*RTVXYZZ Z ?;}7777 7$ ? ? ?*!%>> > ?s0A88B, B''B,C##D2 DDc|jd}i}|rCt|}|D]1}|dp|d}|||<2|S)z8Returns the parsed header links of the response, if any.linkrelro)rqrrG)rWrresolved_linksrerkeys rXrezResponse.linksss!!&))  +&v..E + +hhuoo8%&*s##rZ int | Nonec,|jr |jjndS)zShortcut to negotiated HTTP version protocol. See HttpVersion from urllib3.future. It returns an integer. It is as follows: - 11 for HTTP/1.1 - 20 for HTTP/2 - 30 for HTTP/3 N)rqversionrVs rXrzResponse.http_versions$(85tx5rZc|j|Sd}t|jtrF |jd}n1#t $r|jd}Yn wxYw|j}d|jcxkrdkrnn|jd|d|j}n)d|jcxkrd krnn|jd |d|j}|rt|| |S) z+Raises :class:`HTTPError`, if one occurred.Nrrz iso-8859-1iiz Client Error: z for url: iXz Server Error: )response)r]rr`rrrDror')rWhttp_error_msgr`s rXrzResponse.raise_for_statuss4   #K dk5 ) ) !  :++G44% : : :++L99 :[F $" ( ( ( (S ( ( ( ( ( $ 0]]]]SWS[]]NN D$ * * * *s * * * * * $ 0]]]]SWS[]]N  ;NT::: : sA$A)(A)c|jdurY|jRtj|jjs|jnt jdtt|jdd}| |dSdS)zReleases the connection back to the pool. Once this method has been called the underlying ``raw`` object must not be accessed again. *Note: Should not normally need to be called explicitly.* FNzQuse 'async with response' to be able to cleanly close the response in async mode. release_conn) rnrqr"r#rwarningswarn UserWarningrrWrs rXrzResponse.close;s  !U * *tx/C.tx~>>      g tx>>  # LNNNNN $ #rZc K|SrrjrVs rX __aenter__zResponse.__aenter__Ns  rZc K|jdurS|jLtj|jjst d|jd{Vt |jdd}| |dSdS)NFz@Attempted to use a synchronous response in an awaitable context.r)rnrqr"r#rr r)rWexc_typeexc_valexc_tbrs rX __aexit__zResponse.__aexit__Qs  !U * *tx/C.tx~>> b`aaa(.."" " " " " " " "tx>>  # LNNNNN $ #rZrW)r[ru)r[rrer)r[r)r[r)r[r..)rr8rrr[r.)rr8rrr[r)rr8rrr[r)rr8r[r...)rr8rrrrr[r)rr8rrrrr[r)rr8rrrrr[rrr[rr[rprrr[r)r[r )r[r[),rfrgrhrrrrXrYrirwr~rr{rrrrrdrrrbrhrjrcrrtypingoverloadrirrrgrrrfrdrrerrrrr __classcell__r}s@rXr[r[rs   IN<[[[[5?5?5?5?n   X ,     X ..... LLLLL$''' B B B B2222   X QQQXQ    X XX X  _FI2222_2 _}}}}_}!0TTTTTl*9LGLGLGLGLG\ _),(+ 2222_2 _0 ), 00000_0*$(, '''''R&&&X&('''X'X@$B$B$BX$BL1?1?1?1?fX 666X6<&        rZr[c~eZdZUded<ded<hdZed.dZd/d Zd0d Zd Z fd Z d1dZ e j d2d3dZe j d4d5dZedfd6dZefd7dZe j d8d9d!Ze j d4dd"d:d#Zedd$fd;d%Zedd,Zd1d-ZxZS)? AsyncResponsezBaseAsyncHTTPResponse | NonerqzVtyping.Callable[[Response, PreparedRequest], typing.Awaitable[PreparedRequest | None]]rl> rbrorcrer`r{rarqr\r_rhr]rjr[BAsyncWebSocketExtensionFromHTTP | AsyncRawExtensionFromHTTP | NonecV|j!t|jdr |jjndS)aAccess the I/O after an Upgraded connection. E.g. for a WebSocket handler. If the server opened a WebSocket, then the extension will be of type AsyncWebSocketExtensionFromHTTP. Otherwise, on unknown protocol, it will be AsyncRawExtensionFromHTTP.NrwrxrVs rXrwzAsyncResponse.extensionzs2x#+(F(F# H   rZc|SrrjrVs rXrzAsyncResponse.__aenter__rrZtyping.AsyncIterator[bytes]cfK|td{V23d{V}|WV 6dSrr)rWrs rXrzAsyncResponse.__aiter__sg!%!2!2?!C!CCCCCCC       %KKKKKDCCs0c>K|d{VdSrr)rWrrrs rXrzAsyncResponse.__aexit__s,jjllrZc|tjvr|jrtdt t ||S)NzAccessing a lazy async response produced by an AsyncSession is forbidden this way. Either call await session.gather() or await one of (text, json, content, iter_content, iter_line, etc..) that are awaitable.)r'rr~r*rzr[r{rs rXr{zAsyncResponse.__getattribute__sO =/ / /DI /#&  Xt$$55d;;;rZrcKt|dr2t|dr$|j|d{VdSdSdSr)rrrrVs rXrzAsyncResponse._gathersk 4 $ $ /|)D)D //((.. . . . . . . . . . / / / /rZ.rr8rr"typing.AsyncGenerator[bytes, None]c KdSrrjrs rXrizAsyncResponse.iter_contents .1SrZr typing.AsyncGenerator[str, None]c KdSrrjrs rXrizAsyncResponse.iter_contents ,/3rZFr(typing.AsyncGenerator[bytes | str, None]cbKjrd{Vdfd }jr(tjt rt 5tts tdtd|}|rt|S|S)Nr[r0c>KjJtjdotjjd}|rYjRdjvrIt _ t jdj_n#t$rYnwxYw j dd{V}jjjj j_ nu#t$r}t|d}~wt$r}t|d}~wt $r}t#|d}~wt$$r}t'|d}~wwxYw|sn|WVĉj3tjdrt)jj_d_dS)NrrrTrrprqrrrtrqrPr8rSrrrrRr;r$r9r&r<r%r-rrBrprnrs rXrz,AsyncResponse.iter_content..generates8'''!(5!9!9!dgdhlTc>d>d ! d&<&D#t|33-=-?-?D*@CDLQaDb@c@c.==%  ."&(-- 4-"P"PPPPPPPE-97;x|7Q.4$222.q111"222.q111'---)!,,,...*1---. % (x#*(E(E# 3DH4E F F %)D " " "O"$B BBAC E(C77 ED E D// E<E  Errr[r0) r~rrnrr\rr+r8rr rC)rWrrrrs`` rXrizAsyncResponse.iter_contents 9 !,,.. ' *' *' *' *' *' *' *R  ! _j&E&E _%'' '  #Jz3,G,G #]$zJZJZ]]]^^ ^   H2=$GG GrZc:Kjrd{Vdfd }jr(tjt rt 5tts tdtd|S)Nr[r0c>KjJtjdotjjd}|rYjRdjvrIt _ t jdj_n#t$rYnwxYw j dd{V}jjjj j_ nu#t$r}t|d}~wt$r}t|d}~wt $r}t#|d}~wt$$r}t'|d}~wwxYw|sn|WVĉj3tjdrt)jj_d_dS)NrrrTFrrpr7rs rXrz(AsyncResponse.iter_raw..generates8'''!(5!9!9!dgdhlTc>d>d ! d&<&D#t|33-=-?-?D*@CDLQaDb@c@c.==%  ."&(-- 5-"Q"QQQQQQQE-97;x|7Q.4$222.q111"222.q111'---)!,,,...*1---. % (x#*(E(E# 3DH4E F F %)D " " "r8rrr9) r~rrnrr\rr+r8rr )rWrrs`` rXrzAsyncResponse.iter_raws 9 !,,.. ' *' *' *' *' *' *' *R  ! _j&E&E _%'' '  #Jz3,G,G #]$zJZJZ]]]^^ ^xzzrZrrc KdSrrjrs rXrgzAsyncResponse.iter_liness .1SrZrc KdSrrjrs rXrgzAsyncResponse.iter_lines"s ,/3rZNcK|(|dur$t|trtdd}|||d{V23d{V}|||z}|r||}n|}|r7|dr/|r-|dd|dkr|}nd}|D]}|WV6||WVdSdS)NFrrrNr)rWrrrrrrlines rXrgzAsyncResponse.iter_lines+sm  ^u%<%<IWZA[A[%<x  !%!2!2!."3" "              %"% + I..((** r u r2%)1K1K))++    ! &  MMMMMM  s C rcK|jr|d{V|jdur|jrt d|jdks|jd|_n t|jtr'|j dd{V|_ntnu#t$r}t|d}~wt$r}t|d}~wt$r}t!|d}~wt"$r}t%|d}~wwxYw|j3t'|jdrt)|jj|_d|_|jS)NFrrTrrp)r~rr\rnrr]rqrBaseAsyncHTTPResponserr r;r$r9r&r<r%r-rrrBrprs rXrfzAsyncResponse.contentOs 9 !,,.. =E ! !% Y"#WXXX1$$(8 $  .!$(,ABB&.2hmm4m.P.P(P(P(P(P(P(P % &%222.q111"222.q111'---)!,,,...*1---. 8 GDHj$A$A /0ABBDM!%}s=AB'' D1C D C D)C88 DDDrpcK|jd{V}|sdS|jM tj|j}t |dr |jdurdSn#t $r d|_YnwxYw|j>t|}|r|j|_t|S|jdSt||jdS)NrrFrrr)rWrfrrs rXrdzAsyncResponse.textrs $$$$$$ 2 = $ %}T]334!455 $:PTY:Y:Y4 % % % $  % = '005577N + . 7 >*** = 47DM)<<<':':EEfEEE,GGG1!%FFFG!( "i  )*WY[]^__ _ ?;}7777 7$ ? ? ?*!%>> > ?s0A==B1 B,,B1C..D"= DD"cK|jr|d{V|jdur&|j|jd{Vt |jdd}| |dSdS)NFr)r~rrnrqrrrs rXrzAsyncResponse.closes 9 !,,..  !U * *tx/C(.."" " " " " " " "tx>>  # LNNNNN $ #rZ)r[r()r[r')r[r+rWr)rr8rrr[r0r)rr8rrr[r2)rr8rrr[r4)rr8r[r0r)rr8rrrrr[r0)rr8rrrrr[r2)rr8rrrrr[r4rr r!)rfrgrhrXrrirwrrrr{rr"r#rirrrgrfrdrrr$r%s@rXr'r']sf%%%%N.    X  <<<<<////  _FI1111_1 _ #////_/ !099999x!044444l _),(+ 1111_1 _/ ), /////_/*$(, """""H   X D===X=<,?,?,?,?\        rZr')r __future__rr"rrrencodings.idna encodingsrrr ImportErrorrr" TYPE_CHECKINGtyping_extensionsrcollections.abcrrrr)http.cookiejarrior urllib.parser r r charset_normalizerr _typingrrrrrrrrrrrrrr_vendor.kiss_headersrrryrrr{r r!r"r# exceptionsr$r%r&r'r(r)r*r+r,rr-rr}r.packages.urllib3r/rAr0r1r2&packages.urllib3.contrib.webextensionsr3r4r5-packages.urllib3.contrib.webextensions._asyncr6r7r8packages.urllib3.exceptionsr9r:r;r<packages.urllib3.fieldsr=packages.urllib3.filepostr>r?packages.urllib3.utilr@ status_codesrA structuresrButilsrCrDrErFrGrHrIrJrKrLmovedfoundothertemporary_redirectrrDEFAULT_REDIRECT_LIMITCONTENT_CHUNK_SIZErrPrlrr[r'rjrZrXrcs#"""""    *))))))######''''''$$$$$$######8888888888)))))) 4333333300000000                    CBBBBB444444    211111QQQQQQQQ,,,,,,++++++                        " K K K   vvvvvvvv(ssssssssl[ "[ "[ "[ "[ "[ "[ "[ "|h h h h h h h h VkkkkkHkkkkks # //