hhddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl m Z ddlmZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd l m!Z!m"Z"m#Z#m$Z$dd l%m&Z&dd l'm(Z(m)Z)ddl*m+Z+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mm?Z?m@Z@ejArddlBZBgdZCejDddZEejDddZFd3dZGd4dZHd5d!ZIGd"d#ZJeJZKejLd$ZMd%e ZNd&Od'ejPDZQGd(d)ejRZSGd*d+e9ZTGd,d-e.ZUejVd.ejWfZXGd/d0ZYGd1deYZZGd2deYZ[dS)6) annotationsN)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypes)URL QueryParams) URLPatternget_environment_proxies)USE_CLIENT_DEFAULT AsyncClientClientTr3)boundUr2urlr-locationreturnboolc|j|jkrdS|jdko0t|dko|jdkot|dkS)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' FhttpPhttps)hostscheme_port_or_default)r7r8s O/var/www/html/prod/cognitive/venv/lib/python3.11/site-packages/httpx/_client.py_is_https_redirectrD>sd x8=  u f . S ! !R ' . Ow & . X & &# -  int | NonecX|j|jSddd|jS)Nr=r?)r<r>)portgetrAr7s rCrBrBMs/ xx % % ) )#* 5 55rEotherc|j|jko/|j|jkot|t|kS)z@ Return 'True' if the given URLs share the same origin. )rAr@rB)r7rKs rC _same_originrMSsD el" = H " = S ! !%5e%<%< <rEceZdZdZdS)UseClientDefaulta< For some parameters such as `auth=...` and `timeout=...` we need to be able to indicate the default "unset" state, in a way that is distinctly different to using `None`. The default "unset" state indicates that whatever default is set on the client should be used. This is different to setting `None`, which explicitly disables the parameter, possibly overriding a client default. For example we use `timeout=USE_CLIENT_DEFAULT` in the `request()` signature. Omitting the `timeout` parameter will send a request using whatever default timeout has been configured on the client. Including `timeout=None` will ensure no timeout is used. Note that user code shouldn't need to use the `USE_CLIENT_DEFAULT` constant, but it is used internally when a parameter is not included. N)__name__ __module__ __qualname____doc__rErCrOrO^srErOhttpxz python-httpx/z, cg|] }|dk| S)identityrT).0keys rC rZys"CCCS 1B1BS1B1B1BrEceZdZdZdZdZdS) ClientStaterN)rPrQrRUNOPENEDOPENEDCLOSEDrTrErCr\r\}s#HFFFFrEr\c*eZdZdZdd Zdd Zdd ZdS)BoundSyncStreamz A byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. streamr+responserstartfloatr9Nonec0||_||_||_dSN_stream _response_startselfrdrerfs rC__init__zBoundSyncStream.__init__ ! rEtyping.Iterator[bytes]c#&K|jD]}|VdSrjrlrpchunks rC__iter__zBoundSyncStream.__iter__s,\  EKKKK  rEctj|jz }tj||j_|jdSN)seconds) time perf_counterrndatetime timedeltarmelapsedrlcloserprs rCrzBoundSyncStream.closesI#%% 3!)!3G!D!D!D rEN)rdr+rerrfrgr9rh)r9rsr9rh)rPrQrRrSrqrxrrTrErCrcrcsZ rErcc*eZdZdZdd Zdd Zdd ZdS)BoundAsyncStreamz An async byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. rdr rerrfrgr9rhc0||_||_||_dSrjrkros rCrqzBoundAsyncStream.__init__rrrEtyping.AsyncIterator[bytes]c4K|j23d{V}|WV 6dSrjrurvs rC __aiter__zBoundAsyncStream.__aiter__sF<       %KKKKK(<Zej dtd@ZdddddddeddA dudPZdvdQZdwdxdRZdwdydSZ dwdzdTZd{dUZefd|dYZd}d\Zd~d]Zdd^Zdd_ZddaZddbZ dS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr,rr:rintr+None | typing.Mapping[str, list[EventHook]]r URL | strrr#str | typing.Callable[[bytes], str]r9rhc &|in|}|t| |_|||_t ||_t||_t||_ t||_ ||_ ||_t|dgt|dgd|_| |_| |_t(j|_dSNrequestre)rre)_enforce_trailing_slashr- _base_url _build_auth_authr._paramsrrr_cookiesr_timeoutrrlistrI _event_hooks _trust_env_default_encodingr\r__state) rprrrrrrrrrrrs rCrqzBaseClient.__init__s(/bb[ 55c(mmDD%%d++ "6** w'' (( (( 0*KOOIr::;;[__Z<<==  $!1!* rEc,|jtjkS)z2 Check if the client being closed )rr\rarps rC is_closedzBaseClient.is_closeds {k000rEc|jSrj)rrs rCrzBaseClient.trust_envs rEr7r-cv|jdr|S||jdzS)N/raw_path)rendswith copy_withrpr7s rCrz"BaseClient._enforce_trailing_slashs: <  & & J}}clT&9}:::rEproxyProxyTypes | Noneallow_env_proxiesdict[str, Proxy | None]c|.|r*dtDSiSt|ttfrt |n|}d|iS)Nc>i|]\}}||dnt|S)NrJ)r)rXrYr7s rC z-BaseClient._get_proxy_map..s> S%C...rErJzall://)r0items isinstancestrr-r)rprrs rC_get_proxy_mapzBaseClient._get_proxy_maps~ =  $;$=$=$C$C$E$EI(253*(E(EPEe$$$$5Ee$ $rErc|jSrj)rrs rCrzBaseClient.timeouts }rEc.t||_dSrj)rr)rprs rCrzBaseClient.timeout(( rEdict[str, list[EventHook]]c|jSrj)rrs rCrzBaseClient.event_hookss   rEct|dgt|dgd|_dSr)rrIr)rprs rCrzBaseClient.event_hooks sKKOOIr::;;[__Z<<==  rE Auth | Nonec|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrs rCrzBaseClient.auths zrEr!c:|||_dSrj)rrrprs rCrzBaseClient.auths%%d++ rEc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rCrzBaseClient.base_urls ~rEcT|t||_dSrj)rr-rrs rCrzBaseClient.base_url&s!55c#hh??rErc|jS)z@ HTTP headers to include when sending requests. )_headersrs rCrzBaseClient.headers* }rEr$ctdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rprclient_headerss rCrzBaseClient.headers1sd !$3$:$:7$C$C,)0099      g&&&& rErc|jS)zA Cookie values to include when sending requests. )rrs rCrzBaseClient.cookies>rrEr#c.t||_dSrj)rr)rprs rCrzBaseClient.cookiesErrEr.c|jS)zO Query parameters to include in the URL when sending requests. )rrs rCrzBaseClient.paramsIs |rEr&c.t||_dSrj)r.r)rprs rCrzBaseClient.paramsPs"6** rE) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc ||}||}|| } ||}| in| } d| vrMt | t r|jnt| } tdi| d| i} t||||||||| |  S)aR Build and return a request instance. * The `params`, `headers` and `cookies` arguments are merged with any values set on the client. * The `url` argument is merged with any `base_url` set on the client. See also: [Request instances][0] [0]: /advanced/clients/#request-instances Nr)rrrrrrrrrT) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrOrrdictas_dictr) rprr7rrrrrrrrrs rC build_requestzBaseClient.build_requestTs4ooc""%%g..%%g..((00%-RR: J & &g'788& W%%  FF FFGOO4E4EFFFJ  !    rEct|}|jrB|jj|jdz}|j|S|S)z Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request. rr)r-is_relative_urlrrlstripr)rpr7 merge_urlmerge_raw_paths rCrzBaseClient._merge_urls] HH  $ D"]3i6H6O6OPT6U6UUN=**N*CC CrEcn|s|jr+t|j}|||S|S)z Merge a cookies argument together with any cookies on the client, to create the cookies used for the outgoing request. )rrr)rprmerged_cookiess rCrzBaseClient._merge_cookiessC  "dl "$T\22N  ! !' * * *! !rEcXt|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rprmerged_headerss rCrzBaseClient._merge_headerss- !..g&&&rEcj|s|jr)t|j}||S|S)z Merge a queryparams argument together with any queryparams on the client, to create the queryparams used for the outgoing request. )rr.merge)rprmerged_queryparamss rCrzBaseClient._merge_queryparamss>  4T[ 4!,T[!9!9 %++F33 3 rEc|dSt|trt|d|dSt|tr|St |rt |St d|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rCrzBaseClient._build_auths <4 e $ $ Bd1gQ@@@ @ d # # BK d^^ BT*** *@@@AA ArEr#AuthTypes | UseClientDefault | Noner ct|tr|jn||}||S|jj|jj}}|s|rt||StS)Nr) rrOrrr7rrr r )rprrrrs rC_build_request_authzBaseClient._build_request_auths~ %T+;<< XDJJ$BRBRSWBXBX   K$[17;3G(  Cx ChBBB Bvv rErerc|||}|||}||||}|||}t |j}t ||||||jS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rr7rrrdr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rprrerr7rrdrs rC_build_redirect_requestz"BaseClient._build_redirect_requests &&w99  (33((#v>>&&w77$,'')     rEc|j}|jtjkr|dkrd}|jtjkr|dkrd}|jtjkr|dkrd}|S)z When being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOST)r status_coder SEE_OTHERFOUNDMOVED_PERMANENTLY)rprrers rCrzBaseClient._redirect_methodst   5? 2 2v7G7GF  5; . .6V3C3CF  5#: : :v?O?OF rEc|jd} t|}n(#t$r}td|d|dd}~wwxYw|jr'|js ||jj}|jr|j |}|jj r'|j s ||jj }|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)r@)fragment) rr-rrrAr@rr7rjoinr )rprrer8r7excs rCrzBaseClient._redirect_urls#J/ h--CC   %939997   : 7ch 7--W[%5-66C   (+""3''C ;  ?  ?--)=->>C s A?Act|j}t||jsHt |j|s|dd|jd|d<||jkr2|dkr,|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrrMr7rDpopnetlocdecoder)rprr7rrs rCrzBaseClient._redirect_headers"s'/**C-- 9%gk377 3 OT222"j//88GFO W^ # #% KK($ / / / KK+T 2 2 2  Hd###rE'SyncByteStream | AsyncByteStream | Nonec6||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrd)rprrs rCrzBaseClient._redirect_stream=s& W^ # #%4~rEcd|jvrct|jtr|jnt |j}t di|jd|i|_dSdS)NrrT)rrrrOrrr)rprrs rC _set_timeoutzBaseClient._set_timeoutHs} G. . .dl,<==+ T\**  "&!V!V(:!V!VGOODUDU!V!V!VG    / .rE)rrrrrrrrrr,rr:rrrrrrrr:rrr9rh)r9r:)r7r-r9r-)rrrr:r9r)r9r)rr,r9rh)r9r)rrr9rh)r9r)rr!r9rh)r9r-)r7rr9rh)r9r)rr$r9rh)r9r)rr#r9rh)r9r.)rr&r9rh)rrr7rrrrrrrrrrrrrrrrrrrr9r)r7rr9r-rj)rrr9r)rrr9r)rrr9r)rrr9r)rrrr r9r )rrrerr9r)rrrerr9r)rrrerr9r-)rrr7r-rrr9r)rrrrr9r*)rrr9rh)!rPrQrRrr rqpropertyrrrrrsetterrrrrrrr1rrrrrrr rrrrrr-rTrErCrrs"&)-&*&* 6!&2EI @G + + + + + +D111X1 X;;;; % % % %X ^)))^)!!!X!    X [,,,[,X _@@@_@X  ^ ' ' '^ 'X  ^)))^)X  ]+++]+*.#'%)"&)-&*&*3E/31 1 1 1 1 1 f,     04      B B B B5G$    &.:6    WWWWWWrErceZdZdZdddddddddddedeeddddddhfd-Zdddddedfdid/Zdddddefdjd1Z dkd4Z ddddddde e e dd5 dldFZ e ddddddde e e dd5 dmdHZde e dIdndMZdodQZdpdRZdqdSZddde e e ddTdrdUZddde e e ddTdsdWZddde e e ddTdsdXZddddddde e e dd5 dtdYZddddddde e e dd5 dtdZZddddddde e e dd5 dtd[Zddde e e ddTdsd\Zdud]Zdvd`Z dwdxdgZxZS)yr3av An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between threads. Usage: ```python >>> client = httpx.Client() >>> response = client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* Either `True` to use an SSL context with the default CA bundle, `False` to disable verification, or an instance of `ssl.SSLContext` to use a custom context. * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrr)rrrrverifycertrhttp1http2rmountsrrlimitsrrr transportrrrrrrrrrr1ssl.SSLContext | str | boolr2CertTypes | Nonerr:r3r4rrr50None | typing.Mapping[str, BaseTransport | None]rr,rr6rrrrrrrr7BaseTransport | Nonerrr9rhc j t||||| | ||||  r$ ddl}n#t$rtddwxYwo|du}| |} |_ fd|D_| 6j d| Dttj_dS)NrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.r1r2rr3r4r6r7c ri|]3\}}t||dn| 4SN)r1r2rr3r4r6r/_init_proxy_transport rXrYrr2r3r4r6rprr1s rCrz#Client.__init__..st @ @ @ U sOO}"T++#, @ @ @ rEc4i|]\}}t||SrTr/rXrYr7s rCrz#Client.__init__..$QQQYC)QQQrE superrqh2 ImportErrorr_init_transport _transportr_mountsrrsorted)rprrrrr1r2rr3r4rr5rrr6rrrr7rrJr proxy_map __class__s` ````` ` rCrqzClient.__init__s. -'#-         !S  &;)t*;''/@AA ../   @ @ @ @ @ @ @ @ @ @ (oo// @ @ @     L  QQ&,,..QQQ   F4<#5#5#7#78899 =Arc4||St||||||Sr@rrpr1r2rr3r4r6r7s rCrLzClient._init_transports9        rErc .t|||||||SN)r1r2rr3r4r6rrTrprr1r2rr3r4r6s rCrBzClient._init_proxy_transports0    rEr7r-c|jD]'\}}||r ||jn|cS(|jSz Returns the transport instance that should be used for a given URL. This will either be the standard connection pool, or a proxy. rNrmatchesrMrpr7patternr7s rC_transport_for_urlzClient._transport_for_urld #',"4"4"6"6 K K GYs## K*3*;tJJJ KrE rrrrrrrrrrrrrrrrrrrrrr bool | UseClientDefaultrrrrc | d}tj|td|||||||||| | |  }||| | S)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = client.send(request, ...) ``` See `Client.build_request()`, `Client.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration NSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead.r] stacklevel rr7rrrrrrrrrrrwarningswarnDeprecationWarningrsendrprr7rrrrrrrrrrrmessagers rCrzClient.requestsB  C  M'#5! D D D D$$!%   yyt>NyOOOrEtyping.Iterator[Response]c #K|||||||||| | |  }||| | d} |V|dS#|wxYwa  Alternative to `httpx.request()` that streams the response body instead of loading it into memory at once. **Parameters**: See `httpx.request`. See also: [Streaming Responses][0] [0]: /quickstart#streaming-responses rgT)rrrrdN)rrmrrprr7rrrrrrrrrrrrres rCrdz Client.stream;s8$$!%   99-     NNN NN     HNN    s AA-rdrrrrrdc|jtjkrtdtj|_t |t r|jn|}||| ||}| |||g} |s| |S#t$r}| |d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances 5Cannot send a request, as the client has been closed.rrhistoryN)rr\ra RuntimeErrorr`rrOrr-r _send_handling_authread BaseExceptionrrprrdrrrer"s rCrmz Client.sendos* ;+, , ,VWW W!( *,<== "D ! !!  '"""''66++ - ,      O    NN   I sB11 C;CCr rxlist[Response]c||} t|} ||||} ||}n&#t$r|cY|SwxYwt ||_||}| |n(#t$r}||d}~wwxYw#|wxYwNT)rrx) sync_auth_flownext_send_handling_redirectsrm StopIterationrrrxr{appendr| rprrrrx auth_flowre next_requestr"s rCrzzClient._send_handling_auths,''00  9ooG 88%5#9 ('0~~h'?'? ((((' OO    ((,G}}H$MMOOO*GNN8,,,,$NN$$$I# * OO    sN(C&AB= A:#B=9A::AB=<C&= C"CC""C&&C<c t||jkrtd||jdD] }||||} |jdD] }||t ||_|js|S|||}||gz}|r| n ||_ |Sn(#t$r}| |d}~wwxYwNTz#Exceeded maximum allowed redirects.rrre) lenrrr_send_single_requestrrxhas_redirect_locationrr{rr|rrprrrxhookrer"s rCrzClient._send_handling_redirectss@  7||d000&97))4  W 0099H  -j9##DDNNNN#'== 5$#O66wII!XJ.#$MMOOOO,3H)#O$ !        7 s7C;C C6C11C6cf||j}tj}t |jt stdt|5| |}dddn #1swxYwYt |jt sJ||_ t|j|||_|j ||j|_t d|j|j|j|j|j|S)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rNrerfHTTP Request: %s %s "%s %d %s")r_r7r|r}rrdr+ryrhandle_requestrrcrextract_cookiesrrloggerinfor http_versionr reason_phraserprr7rfres rCrzClient._send_single_requestsk++GK88 !##'..99 Q W - - - 9 9 //88H 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9(/>:::::") Ohe    $$X...$($:! , N K  !   "    s'B  B B rrrrrrrc >|d|||||||| S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrr rpr7rrrrrrrs rCrIz Client.get s:"||  -!   rEAuthTypes | UseClientDefaultc >|d|||||||| S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rCoptionszClient.options)s:"||  -!   rEc >|d|||||||| S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrrrs rCheadz Client.headFs:"||  -!   rEc F|d||||||||| | | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrar rpr7rrrrrrrrrrrs rCpostz Client.postcsF*||  -!   rEc F|d||||||||| | | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrarrs rCputz Client.putsF*||  -!   rEc F|d||||||||| | | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrarrs rCpatchz Client.patchsF*||  -!   rEc >|d|||||||| S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rCdeletez Client.deletes:"||  -!   rEc|jtjkr\tj|_|j|jD]}||dSdSz. Close transport and proxies. N)rr\rarMrrNvalues)rpr7s rCrz Client.closesx ;+, , ,%,DK O ! ! # # #!\0022 & & (OO%%% - , & &rErpr4cP|jtjkr4tjdtjdi|j}t |tj|_|j|j D]}|||SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rr\r_r`raryrM __enter__rNr)rpmsgr7s rCrzClient.__enter__s ;+. . ."$S"O k C s## #!(  !!###,,.. & &I$##%%% rEexc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonectj|_|j||||jD]}|||||dSrj)r\rarrM__exit__rNr)rprrrr7s rCrzClient.__exit__ sr "(    9i@@@,,.. C CI$""8Y BBB C CrE)(rrrrrrrrr1r8r2r9rr:r3r:r4r:rrr5r:rr,rr:r6rrrrrrrr7r;rrr9rh)r1r8r2r9rr:r3r:r4r:r6rr7r;r9r)rrr1r8r2r9rr:r3r:r4r:r6rr9r)r7r-r9rrrr7rrrrrrrrrrrrrrrrr rrbrrrrr9r)rrr7rrrrrrrrrrrrrrrrr rrbrrrrr9rp rrrdr:rr rrbr9r rrrr rr:rxr~r9rrrrr:rxr~r9rrrr9rr7rrrrrrrrr rrbrrrrr9rr7rrrrrrrrrrrbrrrrr9rr7rrrrrrrrrrrrrrrrrrrbrrrrr9rr)rpr4r9r4NNNrrrrrrr9rh)rPrQrRrSrr r rqrLrBr_r1rrrdrmrzrrrIrrrrrrrrr __classcell__rQs@rCr3r3Rs**^"&)-&*&*.2!%#'EI 6!&'2EI *.@G+M:M:M:M:M:M:M:M:b/3!%'*.     2/3!%'     (     *.#'%)"&)-&*&*4F4F3E/36P6P6P6P6P6Pp *.#'%)"&)-&*&*4F4F3E/311111^1n4F4F 111111f    D####J!!!!N*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      : & & & &(04*.*. C C C C C C C C CrEceZdZdZddddddddddedeedddddddhfd-Zdddddedfdid/Zdddddefdjd1Z dkd4Z ddddddde e e dd5 dldFZ e ddddddde e e dd5 dmdHZde e dIdndMZdodQZdpdRZdqdSZddde e e ddTdrdUZddde e e ddTdsdWZddde e e ddTdsdXZddddddde e e dd5 dtdYZddddddde e e dd5 dtdZZddddddde e e dd5 dtd[Zddde e e ddTdsd\Zdud]Zdvd`Z dwdxdgZxZS)yr2a An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. Usage: ```python >>> async with httpx.AsyncClient() as client: >>> response = await client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* Either `True` to use an SSL context with the default CA bundle, `False` to disable verification, or an instance of `ssl.SSLContext` to use a custom context. * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrr)rrrrr1r2r3r4rr5rrr6rrrr7rrrrrrrrrrr1r8r2r9r3r:r4rrr55None | typing.Mapping[str, AsyncBaseTransport | None]rr,rr6rrrrrrrr7AsyncBaseTransport | Nonerrrr9rhc j t||||| | |||| r$ ddl}n#t$rtddwxYwo|du}| |} |_ fd|D_| 6j d| Dttj_dS)Nrrr=r>c ri|]3\}}t||dn| 4Sr@rArCs rCrz(AsyncClient.__init__..st E E E U sOO}"T++#, E E E rEc4i|]\}}t||SrTrErFs rCrz(AsyncClient.__init__..rGrErH)rprrrrr1r2r3r4rr5rrr6rrrr7rrrJrrPrQs` ```` ` ` rCrqzAsyncClient.__init__Is. -'#-         !S  &;)t*;''/@AA ../   E E E E E E E E E E (oo// E E E     L  QQ&,,..QQQ   F4<#5#5#7#78899 rRrc4||St||||||Sr@rrUs rCrLzAsyncClient._init_transports9   !     rErc .t|||||||SrWrrXs rCrBz!AsyncClient._init_proxy_transports0"    rEr7r-c|jD]'\}}||r ||jn|cS(|jSrZr[r]s rCr_zAsyncClient._transport_for_urlr`rErarrrrrrrrrrr rbrrrrc K| d}tj|td|||||||||| | |  }||| | d{VS)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = await client.send(request, ...) ``` See `AsyncClient.build_request()`, `AsyncClient.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration Nrdr]rergrhrirns rCrzAsyncClient.requestsD  C  M'#5! D D D D$$!%   YYwTDTYUUUUUUUUUrEtyping.AsyncIterator[Response]c K|||||||||| | |  }||| | dd{V} |WV|d{VdS#|d{VwxYwrr)rrmrrss rCrdzAsyncClient.streams8$$!%   - #          $NNNN//## # # # # # # # # #(//## # # # # # # # #s A$$BrtrrrdcK|jtjkrtdtj|_t |t r|jn|}||| ||}| |||gd{V} |s| d{V|S#t$r!}| d{V|d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances rvrwN)rr\raryr`rrOrr-r rzareadr|rr}s rCrmzAsyncClient.send:s@* ;+, , ,VWW W!( *,<== "D ! !!  '"""''6611 - 2           'nn&&&&&&&&&O   //## # # # # # # #I s!B?? C* C%%C*r rxr~c`K||} |d{V} ||||d{V} ||d{V}n,#t$r|cY|d{VSwxYwt ||_|d{V|}| |n.#t$r!}|d{V|d}~wwxYw#|d{VwxYwr) async_auth_flow __anext__rasendStopAsyncIterationrrrxrrr|rs rCrzzAsyncClient._send_handling_authms((11  %%//11111111G !%!>!>%5#"?"" (-6__X-F-F'F'F'F'F'F'F -((('""$$ $ $ $ $ $ $ $ $((,G}}H$"..**********GNN8,,,,$"//+++++++++I# *""$$ $ $ $ $ $ $ $ $sN9DA0/C"0 B<C"BAC"!D" D ,DD  DD-c6K t||jkrtd||jdD]}||d{V||d{V} |jdD]}||d{Vt ||_|js|S|||}||gz}|r| d{Vn ||_ |Sn.#t$r!}| d{V|d}~wwxYwr) rrrrrrrxrrrrr|rrs rCrz$AsyncClient._send_handling_redirectss  7||d000&97))4 $ $d7mm########!66w????????H  -j9))D$x..((((((((#'== 5$#O66wII!XJ.#$"..**********,3H)#O+ !   oo'''''''''  9 s*=C+(AC++ D5DDcvK||j}tj}t |jt stdt|5| |d{V}dddn #1swxYwYt |jt sJ||_ t|j|||_|j ||j|_t d|j|j|j|j|j|S)rz?Attempted to send an sync request with an AsyncClient instance.rNrr)r_r7r|r}rrdr ryrhandle_async_requestrrrrrrrrrrrrrs rCrz AsyncClient._send_single_requests++GK88 !##'./:: Q W - - - E E&;;GDDDDDDDDH E E E E E E E E E E E E E E E(/?;;;;;"* Ohe    $$X...$($:! , N K  !   "    s)BBBrc NK|d|||||||| d{VS)rrrNrrs rCrIzAsyncClient.gets\"\\  -!"         rErc NK|d|||||||| d{VS)rrrNrrs rCrzAsyncClient.optionss\"\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rCrzAsyncClient.heads\"\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrraNrrs rCrzAsyncClient.post.sh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrraNrrs rCrzAsyncClient.putSsh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrraNrrs rCrzAsyncClient.patchxsh*\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rCrzAsyncClient.deletes\"\\  -!"         rEcK|jtjkrhtj|_|jd{V|jD] }||d{VdSdSr)rr\rarMrrNr)rprs rCrzAsyncClient.acloses ;+, , ,%,DK/((** * * * * * * *,,.. ) )$,,..((((((( - , ) )rErpr6clK|jtjkr4tjdtjdi|j}t |tj|_|jd{V|j D]}||d{V|Sr) rr\r_r`raryrM __aenter__rNr)rprrs rCrzAsyncClient.__aenter__s ;+. . ."$S"O k C s## #!( o((*********\((** ) )E &&((((((((( rErrrrrrcKtj|_|j|||d{V|jD]!}|||||d{V"dSrj)r\rarrM __aexit__rNr)rprrrrs rCrzAsyncClient.__aexit__s "( o'')YGGGGGGGGG\((** F FE ooh 9EEEEEEEEE F FrE)(rrrrrrrrr1r8r2r9r3r:r4r:rrr5rrr,rr:r6rrrrrrrr7rrr:rrr9rh)r1r8r2r9rr:r3r:r4r:r6rr7rr9r)rrr1r8r2r9rr:r3r:r4r:r6rr9r)r7r-r9rr)rrr7rrrrrrrrrrrrrrrrr rrbrrrrr9rrrrrrrrr)rpr6r9r6rr)rPrQrRrSrr r rqrLrBr_r1rrrdrmrzrrrIrrrrrrrrrrrs@rCr2r2s++`"&)-&*&*.2!%#'JN 6!&'2EI /3@G+M:M:M:M:M:M:M:M:b/3!%'/3     2/3!%'     (     *.#'%)"&)-&*&*4F4F3E/37V7V7V7V7V7Vr *.#'%)"&)-&*&*4F4F3E/31$1$1$1$1$1$n4F4F 111111f % % % %D$$$$L    L*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      : ) ) ) )(04*.*. F F F F F F F F FrE)r7r-r8r-r9r:)r7r-r9rF)r7r-rKr-r9r:)\ __future__rr~enumloggingr|typingrj contextlibrrtypesrrrr r r _configr r rrrr _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.baserr_transports.defaultrr_typesr r!r"r#r$r%r&r'r(r)r*r+r,_urlsr-r._utilsr/r0 TYPE_CHECKINGssl__all__TypeVarr4r6rDrBrMrOr1 getLoggerrrr!keysrEnumr\rcrCallableAny EventHookrr3r2rTrErCrs""""""  ::::::::$$$$$$0000000000*))))) 988888888888 ????????BBBBBBBB$#######77777777 JJJ 9 9 9FN3h'''FN3m,,,    6666 (&%''  7 # # *[ * * ))CC+&+--CCC     $)   n.$$$$$$$$. OCO , SWSWSWSWSWSWSWSWl F CF CF CF CF CZF CF CF CRH FH FH FH FH F*H FH FH FH FH FrE