@gZddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddl mZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIejJddZKejJddZLGddZMeMZNejOdZPde ZQdRdejSDZTGdd ejUZVGd!d"e=ZWGd#d$e1ZXejYd%ejZfZ[Gd&d'Z\Gd(de\Z]Gd)de\Z^dS)*) annotationsN)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes) ASGITransport)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) WSGITransport)AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxiesTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypesURLTypes VerifyTypes)URL QueryParams)Timer URLPatternget_environment_proxiesis_https_redirect same_originTClient)boundU AsyncClientceZdZdZdS)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__A/var/www/piapp/venv/lib/python3.11/site-packages/httpx/_client.pyr?r?CsrEr?httpxz python-httpx/z, cg|] }|dk| S)identityrD).0keys rF rL^s"CCCS 1B1BS1B1B1BrEceZdZdZdZdZdS) ClientStaterN)r@rArBUNOPENEDOPENEDCLOSEDrDrErFrNrNbs#HFFFFrErNc*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.responsertimerr4returnNonec0||_||_||_dSN_stream _response_timerselfrVrWrXs rF__init__zBoundSyncStream.__init__v ! rEtyping.Iterator[bytes]c#&K|jD]}|VdSr\r^rbchunks rF__iter__zBoundSyncStream.__iter__}s,\  EKKKK  rEc|j}tj||j_|jdSN)seconds)r` sync_elapseddatetime timedeltar_elapsedr^closerbrms rFrrzBoundSyncStream.closesG+**,,!)!3G!D!D!D rEN)rVr.rWrrXr4rYrZ)rYrerYrZ)r@rArBrCrcrjrrrDrErFrUrUpsZ rErUc*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. rVr"rWrrXr4rYrZc0||_||_||_dSr\r]ras rFrczBoundAsyncStream.__init__rdrEtyping.AsyncIterator[bytes]c4K|j23d{V}|WV 6dSr\rgrhs rF __aiter__zBoundAsyncStream.__aiter__sF<       %KKKKK(<Zej dsd@ZdddddddeddA dtdPZdudQZdvdwdRZdvdxdSZ dvdydTZdzdUZefd{dYZd|d\Zd}d]Zd~d^Zdd_ZddaZdS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr/rboolrintr+None | typing.Mapping[str, list[EventHook]]rr0rr#str | typing.Callable[[bytes], str]rYrZc &|in|}|t| |_|||_t ||_t||_t||_ t||_ ||_ ||_t|dgt|dgd|_| |_| |_t(j|_dSNrequestrW)rrW)_enforce_trailing_slashr2 _base_url _build_auth_authr3_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingrNrQ_state) rbrrrrrrrrrrrs rFrczBaseClient.__init__s(/bb[ 55c(mmDD%%d++ "6** w'' (( (( 0*KOOIr::;;[__Z<<==  $!1!* rEc,|jtjkS)z2 Check if the client being closed )rrNrSrbs rF is_closedzBaseClient.is_closeds {k000rEc|jSr\)rrs rFrzBaseClient.trust_envs rEurlr2cv|jdr|S||jdzS)N/raw_path)rendswith copy_withrbrs rFrz"BaseClient._enforce_trailing_slashs: <  & & J}}clT&9}:::rEproxiesProxiesTypes | Noneallow_env_proxiesdict[str, Proxy | None]c|.|r*dtDSiSt|tr^i}|D]E\}}t|tt frt |n|}||t |<F|St|tt frt |n|}d|iS)Nc>i|]\}}||dnt|S)Nr)r)rJrKrs rF z-BaseClient._get_proxy_map..s> S%C...rErzall://)r6items isinstancedictstrr2r)rbrr new_proxiesrKvalueproxys rF_get_proxy_mapzBaseClient._get_proxy_maps ?  $;$=$=$C$C$E$EI gt $ $ %K%mmoo . . U,6usCj,I,IT%((((u(- CHH%% *4WsCj*I*IVEg&&&&wEe$ $rErc|jSr\)rrs rFrzBaseClient.timeouts }rEc.t||_dSr\)rr)rbrs rFrzBaseClient.timeout(( rEdict[str, list[EventHook]]c|jSr\)rrs rFrzBaseClient.event_hookss   rEct|dgt|dgd|_dSr)rrr)rbrs rFrzBaseClient.event_hookssKKOOIr::;;[__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 rFrzBaseClient.auths zrEr#c:|||_dSr\)rrrbrs rFrzBaseClient.auths%%d++ rEc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rFrzBaseClient.base_url s ~rEcT|t||_dSr\)rr2rrs rFrzBaseClient.base_urls!55c#hh??rErc|jS)z@ HTTP headers to include when sending requests. )_headersrs rFrzBaseClient.headers }rEr&ctdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rbrclient_headerss rFrzBaseClient.headerssd !$3$:$:7$C$C,)0099      g&&&& rErc|jS)zA Cookie values to include when sending requests. )rrs rFrzBaseClient.cookies)rrEr%c.t||_dSr\)rr)rbrs rFrzBaseClient.cookies0rrEr3c|jS)zO Query parameters to include in the URL when sending requests. )rrs rFrzBaseClient.params4s |rEr)c.t||_dSr\)r3r)rbrs rFrzBaseClient.params;s"6** rE) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc ||}||}|| } ||}| in| } d| vrMt | t r|jnt| } tdi| d| i} t||||||||| |  S)aJ 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/#request-instances Nr)rrrrrrrrrD) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr?rrras_dictr) rbrrrrrrrrrrrs rF build_requestzBaseClient.build_request?s4ooc""%%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)r2is_relative_urlrrlstripr)rbr merge_urlmerge_raw_paths rFrzBaseClient._merge_urlrs] 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)rbrmerged_cookiess rFrzBaseClient._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)rbrmerged_headerss rFrzBaseClient._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. )rr3merge)rbrmerged_queryparamss rFrzBaseClient._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 rFrzBaseClient._build_auths <4 e $ $ Bd1gQ@@@ @ d # # BK d^^ BT*** *@@@AA ArEr#AuthTypes | UseClientDefault | Noner ct|tr|jn||}||S|jj|jj}}|s|rt||StS)Nr) rr?rrrrrr r )rbrrrrs rF_build_request_authzBaseClient._build_request_auths~ %T+;<< XDJJ$BRBRSWBXBX   K$[17;3G(  Cx ChBBB Bvv rErWrc|||}|||}||||}|||}t |j}t ||||||jS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrrrVr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rbrrWrrrrVrs rF_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)rbrrWrs rFrzBaseClient._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)host)fragment) rr2rrschemerrrrjoinr)rbrrWlocationrexcs rFrzBaseClient._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) rrr8rr7popnetlocdecoder)rbrrrrs rFr zBaseClient._redirect_headers s'/**3 ,, 9$W[#66 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)rrV)rbrrs rFr zBaseClient._redirect_stream(s& W^ # #%4~rE)rrrrrrrrrr/rrrrrrrr0rrrrrYrZ)rYr)rr2rYr2)rrrrrYr)rYr)rr/rYrZ)rYr)rrrYrZ)rYr)rr#rYrZ)rYr2)rr0rYrZ)rYr)rr&rYrZ)rYr)rr%rYrZ)rYr3)rr)rYrZ)rrrr0rrrrrrrrrrrrrrrrrrrYr)rr0rYr2r\)rrrYr)rrrYr)rrrYr)rrrYr)rrrrrYr )rrrWrrYr)rrrWrrYr)rrrWrrYr2)rrrr2rrrYr)rrrrrYr%) r@rArBrr rcpropertyrrrrrsetterrrrrrrUSE_CLIENT_DEFAULTrrrrrrrr rrr r rDrErFrrs"&)-&*&* 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      rErceZdZdZdddddddddddedeeddddddddlfd1Zddddedddfdmd3Zddddedfdnd5Z dod8Z ddddddde e e dd9 dpdJZ e ddddddde e e dd9 dqdLZde e dMdrdQZdsdUZdtdVZdudWZddde e e ddXdvdZZddde e e ddXdvd[Zddde e e ddXdvd\Zddddddde e e dd9 dwd]Zddddddde e e dd9 dwd^Zddddddde e e dd9 dwd_Zddde e e ddXdvd`ZdxdaZdyddZ dzd{dkZxZS)|r:a 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)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **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. * **proxies** - *(optional)* A dictionary mapping proxy keys to proxy URLs. * **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. * **app** - *(optional)* An WSGI application to send requests to, rather than sending actual network requests. * **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". NTFrrrrrrverifycerthttp1http2rrmountsrrlimitsrrr transportapprrrrrrrrrrr,r1r-CertTypes | Noner.rr/rProxyTypes | Nonerrr00None | typing.Mapping[str, BaseTransport | None]rr/rr1rrrrrrr0r2BaseTransport | Noner3'typing.Callable[..., typing.Any] | NonerrrrYrZc t||||| | |||| r$ ddl}n#t$rtddwxYw| r-d}t j|t | rtd|rd}t j|t o|duo|du}| p| |} ||_ 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]`.JThe 'proxies' argument is now deprecated. Use 'proxy' or 'mounts' instead.*Use either `proxy` or 'proxies', not both.zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=WSGITransport(app=...)' instead.r,r-r.r/r1r2r3rc ri|]3\}}t||dn| 4SNr,r-r.r/r1rr5_init_proxy_transport rJrKrr-r.r/r1rbrr,s rFrz#Client.__init__..st @ @ @ U sOO}"T++#, @ @ @ rEc4i|]\}}t||SrDr5rJrKr2s rFrz#Client.__init__..$QQQYC)QQQrEsuperrch2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportr_mountsrrsortedrbrrrrr,r-r.r/rrr0rrr1rrrr2r3rrrJmessager proxy_map __class__s` ```` ` ` rFrczClient.__init__js92 -'#-         !S   Q4  M'#5 6 6 6 Q"#OPPP  7V  M'#5 6 6 6%K#+K)t:K''(85:KLL ../    @ @ @ @ @ @ @ @ @ @ (oo// @ @ @     L  QQ&,,..QQQ   F4<#5#5#7#78899 =Arc X||S|t|St||||||SN)r3r@)r!r rbr,r-r.r/r1r2r3rs rFrPzClient._init_transportsO    ? S))) )     rErc .t|||||||SN)r,r-r.r/r1rr)r rbrr,r-r.r/r1rs rFrBzClient._init_proxy_transports0    rErr2c|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. rRrmatchesrQrbrpatternr2s rF_transport_for_urlzClient._transport_for_urld #',"4"4"6"6 K K GYs## K*3*;tJJJ KrE rrrrrrrrrrrrrrrrrrrrrrbool | UseClientDefaultrrrrc | d}tj|t|||||||||| | |  }||| | 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/#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. rrrrrrrrrrrrrrLrMrNrsendrbrrrrrrrrrrrrrrUrs rFrzClient.requestsB  C  M'#5 6 6 6$$!%   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 rkT)rrrrVN)rrnrrrbrrrrrrrrrrrrrrrWs rFrVz Client.stream=s8$$!%   99-     NNN NN     HNN    s AA-rVrrrrrVc|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/#request-instances 5Cannot send a request, as the client has been closed.rrhistoryN) rrNrSrOrRrr?rr_send_handling_authread BaseExceptionrrrbrrVrrrWrs rFrnz Client.sendqs* ;+, , ,VWW W!( *,<== "D ! !!  ''66++ - ,      O    NN   I sB C&B<<Cr rxlist[Response]c||} t|} ||||} ||}n&#t$r|cY|SwxYwt ||_||}| |n(#t$r}||d}~wwxYw#|wxYwNT)rrx) sync_auth_flownext_send_handling_redirectsrn StopIterationrrrrxrzappendr{ rbrrrrx auth_flowrW next_requestrs rFryzClient._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.rrrW) lenrrr_send_single_requestrrxhas_redirect_locationr rzrr{rrrbrrrxhookrWrs rFrzClient._send_handling_redirectss@  7||d000&97))4  W 0099H  -j9##DDNNNN#'== 5$#O66wII!XJ.#$MMOOOO,3H)#O$ !        7 s7C;C C6C11C6c||j}t}|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.rNrWrXHTTP Request: %s %s "%s %d %s")rerr4 sync_startrrVr.rOrhandle_requestrrUrextract_cookiesrrloggerinfor http_versionr reason_phraserbrr2rXrWs rFrzClient._send_single_requestsx++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  !   "    s6BBBrrrrrrrAuthTypes | UseClientDefaultc >|d|||||||| S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrr rbrrrrrrrrs rFrz Client.get s:"||  -!   rEc >|d|||||||| S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rFoptionszClient.options*s:"||  -!   rEc >|d|||||||| S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. r rrrs rFheadz Client.headGs:"||  -!   rEc F|d||||||||| | | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrgr rbrrrrrrrrrrrrs rFpostz Client.postdsF*||  -!   rEc F|d||||||||| | | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrgrrs rFputz Client.putsF*||  -!   rEc F|d||||||||| | | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrgrrs rFpatchz Client.patchsF*||  -!   rEc >|d|||||||| S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rFdeletez Client.deletes:"||  -!   rEc|jtjkr\tj|_|j|jD]}||dSdSz. Close transport and proxies. N)rrNrSrQrrrRvalues)rbr2s rFrrz Client.closesx ;+, , ,%,DK O ! ! # # #!\0022 & & (OO%%% - , & &rErbr9cP|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.) rrNrQrRrSrOrQ __enter__rRr)rbmsgr2s rFrzClient.__enter__s ;+. . ."$S"O k C s## #!(  !!###,,.. & &I$##%%% rEexc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonectj|_|j||||jD]}|||||dSr\)rNrSrrQ__exit__rRr)rbrrrr2s rFrzClient.__exit__sr "(    9i@@@,,.. C CI$""8Y BBB C CrE),rrrrrrrrr,r1r-r4r.rr/rrr5rrr0r6rr/rrr1rrrrrrr0r2r7r3r8rrrrrYrZ)r,r1r-r4r.rr/rr1rr2r7r3r8rrrYr)rrr,r1r-r4r.rr/rr1rrrrYr)rr2rYrrrrr0rrrrrrrrrrrrrrrrrrhrrrrrYr)rrrr0rrrrrrrrrrrrrrrrrrhrrrrrYrp rrrVrrrrrhrYr rrrr rrrxr}rYrrrrrrxr}rYrrrrYrrr0rrrrrrrrrrhrrrrrYrrr0rrrrrrrrrrrrrrrrrrhrrrrrYrrt)rbr9rYr9NNNrrrrrrrYrZ)r@rArBrCrr r rcrPrBrer)rrrVrnryrrrrrrrrrrrrr __classcell__rWs@rFr:r:4s33p"&)-&*&*"!%#''+EI 6!&'2EI*.7;@G/`:`:`:`:`:`:`:`:H#!%'*.7;     :#!%'     (     *.#'%)"&)-&*&*4F4F3E/36P6P6P6P6P6Pp *.#'%)"&)-&*&*4F4F3E/311111^1n4F4F //////b    D####J""""P*.&*&*-?4F3E/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 CrEceZdZdZdddddddddddedeeddddddddlfd1Zddddedddfdmd3Zddddedfdnd5Z dod8Z ddddddde e e dd9 dpdJZ e ddddddde e e dd9 dqdMZde e dNdrdRZdsdVZdtdWZdudXZddde e e ddYdvdZZddde e e ddYdwd[Zddde e e ddYdwd\Zddddddde e e dd9 dxd]Zddddddde e e dd9 dxd^Zddddddde e e dd9 dxd_Zddde e e ddYdwd`ZdydaZdzddZ d{d|dkZxZS)}r=a 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)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **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. * **proxies** - *(optional)* A dictionary mapping HTTP protocols to proxy URLs. * **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. * **app** - *(optional)* An ASGI application to send requests to, rather than sending actual network requests. * **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". NTFrrr+rrrrrrrrr,r1r-r4r.rr/rr5rrr05None | typing.Mapping[str, AsyncBaseTransport | None]rr/rr1rrrrBNone | typing.Mapping[str, list[typing.Callable[..., typing.Any]]]rr0r2AsyncBaseTransport | Noner3r8rrrrYrZc  t||||| | |||| r$ ddl}n#t$rtddwxYw| r-d}t j|t | rtd|rd}t j|t o|du}| p| |} ||_ fd| D_ | 6j d | Dttj _ dS) Nrrr:r;r<zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.r=c ri|]3\}}t||dn| 4Sr?rArCs rFrz(AsyncClient.__init__..st E E E U sOO}"T++#, E E E rEc4i|]\}}t||SrDrErFs rFrz(AsyncClient.__init__..rGrErHrTs` ```` ` ` rFrczAsyncClient.__init__Ss04 -'#-         !S   Q4  M'#5 6 6 6 Q"#OPPP  7V  M'#5 6 6 6%;)t*;''(85:KLL ../    E E E E E E E E E E (oo// E E E     L  QQ&,,..QQQ   F4<#5#5#7#78899 rXrc X||S|t|St||||||SrZ)rrr[s rFrPzAsyncClient._init_transportsO    ? S))) )!     rErc .t|||||||Sr])rr^s rFrBz!AsyncClient._init_proxy_transports0"    rErr2c|jD]'\}}||r ||jn|cS(|jSr`rarcs rFrezAsyncClient._transport_for_urlrfrErgrrrrrrrrrrrrhrrrrc K| d}tj|t|||||||||| | |  }||| | 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/#merging-of-configuration Nrjrkrlrmros rFrzAsyncClient.requestsD  C  M'#5 6 6 6$$!%   YYwTDTYUUUUUUUUUrErtyping.AsyncIterator[Response]c K|||||||||| | |  }||| | dd{V} |WV|d{VdS#|d{VwxYwrr)rrnr}rss rFrVzAsyncClient.stream(s8$$!%   - #          $NNNN//## # # # # # # # # #(//## # # # # # # # #s A$$BrtrrrVcK|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/#request-instances rvrwN) rrNrSrOrRrr?rrryareadr{r}r|s rFrnzAsyncClient.send\s,* ;+, , ,VWW W!( *,<== "D ! !!  ''6611 - 2           'nn&&&&&&&&&O   //## # # # # # # #I s B** C4CCr 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__rasendStopAsyncIterationr}rrxrrr{rs rFryzAsyncClient._send_handling_auths((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) rrrrrrrxrr rrr{r}rs rFrz$AsyncClient._send_handling_redirectss  7||d000&97))4 $ $d7mm########!66w????????H  -j9))D$x..((((((((#'== 5$#O66wII!XJ.#$"..**********,3H)#O+ !   oo'''''''''  9 s*=C+(AC++ D5DDcK||j}t}|d{Vt |jt stdt|5| |d{V}dddn #1swxYwYt |jt sJ||_ t|j|||_|j ||j|_t d|j|j|j|j|j|S)rNz?Attempted to send an sync request with an AsyncClient instance.rrr)rerr4 async_startrrVr"rOrhandle_async_requestrrvrrrrrrrrrrrs rFrz 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>B&&B*-B*rc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.gets\"\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.optionss\"\\  -!"         rEc NK|d|||||||| d{VS)rr rNrrs rFrzAsyncClient.head2s\"\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrrgNrrs rFrzAsyncClient.postOsh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrrgNrrs rFrzAsyncClient.puttsh*\\  -!"         rEc VK|d||||||||| | | |  d{VS)rrrgNrrs rFrzAsyncClient.patchsh*\\  -!"         rEc NK|d|||||||| d{VS)rrrNrrs rFrzAsyncClient.deletes\"\\  -!"         rEcK|jtjkrhtj|_|jd{V|jD] }||d{VdSdSr)rrNrSrQr}rRr)rbrs rFr}zAsyncClient.acloses ;+, , ,%,DK/((** * * * * * * *,,.. ) )$,,..((((((( - , ) )rErbr<clK|jtjkr4tjdtjdi|j}t |tj|_|jd{V|j D]}||d{V|Sr) rrNrQrRrSrOrQ __aenter__rRr)rbrrs rFrzAsyncClient.__aenter__s ;+. . ."$S"O k C s## #!( o((*********\((** ) )E &&((((((((( rErrrrrrcKtj|_|j|||d{V|jD]!}|||||d{V"dSr\)rNrSrrQ __aexit__rRr)rbrrrrs rFrzAsyncClient.__aexit__s "( o'')YGGGGGGGGG\((** F FE ooh 9EEEEEEEEE F FrE),rrrrrrrrr,r1r-r4r.rr/rrr5rrr0rrr/rrr1rrrrrrr0r2rr3r8rrrrrYrZ)r,r1r-r4r.rr/rr1rr2rr3r8rrrYr)rrr,r1r-r4r.rr/rr1rrrrYr)rr2rYrr)rrrr0rrrrrrrrrrrrrrrrrrhrrrrrYrrrrr)rr0rrrrrrrrrrhrrrrrYrrrrt)rbr<rYr<rr)r@rArBrCrr r rcrPrBrer)rrrVrnryrrrrrrrrrr}rrrrs@rFr=r=s44r"&)-&*&*"!%#''+JN 6!&'2JN/37;@G1a:a:a:a:a:a:a:a:J#!%'/37;     :#!%'     (     *.#'%)"&)-&*&*4F4F3E/37V7V7V7V7V7Vr *.#'%)"&)-&*&*-?4F3E/31$1$1$1$1$1$n4F4F //////b % % % %D$$$$L!!!!N*.&*&*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)_ __future__rroenumloggingtypingrL contextlibrrtypesrrrr r r _configr r rrrr _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.asgir_transports.baserr_transports.defaultrr _transports.wsgir!_typesr"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1_urlsr2r3_utilsr4r5r6r7r8TypeVarr9r<r?r) getLoggerrrrkeysrEnumrNrUrvCallableAny EventHookrr:r=rDrErFrs""""""  ::::::::$$$$$$0000000000*))))) 988888888888 ++++++????????BBBBBBBB++++++$$#######FN3h'''FN3m,,,(&%''  7 # # *[ * * ))CC+&+--CCC     $)   n.$$$$$$$$. OCO , PPPPPPPPf e Ce Ce Ce Ce CZe Ce Ce CPh Fh Fh Fh Fh F*h Fh Fh Fh Fh FrE