Wh ddlZddlZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z ddl mZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.m/Z/ddl0m1Z1ddl2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>ddl?m@Z@mAZAmBZBmCZCmDZDmEZEejFddZGejFddZHGddZIeIZJeDeKZLdeZMdNdejODZPGddejQZRGdd e,ZSGd!d"e*ZTGd#d$ZUGd%deUZVGd&deUZWdS)'N)contextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)asynccontextmanager)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)URLCookiesHeaders QueryParamsRequestResponse)codes) ASGITransport)AsyncBaseTransportAsyncByteStream BaseTransportSyncByteStream)AsyncHTTPTransport HTTPTransport) WSGITransport) AuthTypes CertTypes CookieTypes HeaderTypes ProxiesTypesQueryParamTypesRequestContent RequestData RequestFiles TimeoutTypesURLTypes VerifyTypes) NetRCInfoTimer URLPatternget_environment_proxies get_logger 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__S/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/httpx/_client.pyr=r=Bs$ DrCr=z python-httpx/z, cg|] }|dk| S)identityrB).0keys rD rI_s"CCCS 1B1BS1B1B1BrCceZdZdZdZdZdS) ClientStaterN)r>r?r@UNOPENEDOPENEDCLOSEDrBrCrDrKrKcs#HFFFFrCrKcTeZdZdZdedededdfdZdej e fdZ d d Z dS) 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. streamresponsetimerreturnNc0||_||_||_dSN_stream _response_timerselfrSrTrUs rD__init__zBoundSyncStream.__init__w ! rCc#&K|jD]}|VdSrXrZr^chunks rD__iter__zBoundSyncStream.__iter__~s,\  EKKKK  rCc|j}tj||j_|jdSN)seconds)r\ sync_elapseddatetime timedeltar[elapsedrZcloser^rhs rDrmzBoundSyncStream.closesG+**,,!)!3G!D!D!D rCrVN) r>r?r@rAr!rr2r_typingIteratorbytesrermrBrCrDrRrRqs $08AF &/%0rCrRcTeZdZdZdedededdfdZdej e fdZ d d Z dS) 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. rSrTrUrVNc0||_||_||_dSrXrYr]s rDr_zBoundAsyncStream.__init__r`rCc4K|j23d{V}|WV 6dSrXrbrcs rD __aiter__zBoundAsyncStream.__aiter__sF<       %KKKKK(<r?r@rArrr2r_rp AsyncIteratorrrrwrzrBrCrDrtrts %19BG !5e!<$$$$$$rCrtcpeZdZddddededddd dedededed e d e d e d e j ee je jfd ede fdZede fdZede fdZdedefdZde jede de jee jeffdZedefdZejd e ddfdZede jee je jffdZ e jd e jee je jfddfdZ ede je!fdZ"e"jdeddfdZ"edefdZ#e#jdeddfdZ#ede$fd Z%e%jdeddfd!Z%ede&fd"Z'e'jdeddfd#Z'ede(fd$Z)e)jdeddfd%Z)dddddddd&d'eded(e*d)e+d*e,d+e j-dededede.fd,Z/dedefd-Z0 d:dede jefd.Z1 d:dede jefd/Z2 d:dede jefd0Z3dede je!fd1Z4e5fd2e.de j6ee7fde!fd3Z8d2e.d4e9de.fd5Z:d2e.d4e9defd6Z;d2e.d4e9defd7Ze?ffd9Z@dS); BaseClientNT) authparamsheaderscookiestimeoutallow_redirects max_redirects event_hooksbase_url trust_envrrrrrrrrrrc >|in|}|t| |_|||_t ||_t||_t||_ t||_ ||_ ||_t|dgt|dgd|_| |_t'|_t*j|_dSNrequestrT)rrT)_enforce_trailing_slashr _base_url _build_auth_authr_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_envr1_netrcrKrN_state) r^rrrrrrrrrrs rDr_zBaseClient.__init__s(/bb[ 55c(mmDD%%d++ "6** w'' (( (( .*KOOIr::;;[__Z<<==  $kk !* rCrVc,|jtjkS)z2 Check if the client being closed )rrKrPr^s rD is_closedzBaseClient.is_closeds {k000rCc|jSrX)rrs rDrzBaseClient.trust_envs rCurlcv|jdr|S||jdzS)N/raw_path)rendswith copy_withr^rs rDrz"BaseClient._enforce_trailing_slashs: <  & & J}}clT&9}:::rCproxiesallow_env_proxiesc|.|r*dtDSiSt|tr^i}|D]E\}}t|tt frt |n|}||t |<F|St|tt frt |n|}d|iS)Nc>i|]\}}||dnt|S)Nr)r)rGrHrs rD z-BaseClient._get_proxy_map..s> S%C...rCrzall://)r4items isinstancedictstrrr)r^rr new_proxiesrHvalueproxys rD_get_proxy_mapzBaseClient._get_proxy_maps ?  $;$=$=$C$C$E$EI gt $ $ %K%mmoo . . U,6usCj,I,IT%((((u(- CHH%% *4WsCj*I*IVEg&&&&wEe$ $rCc|jSrX)rrs rDrzBaseClient.timeouts }rCc.t||_dSrX)rr)r^rs rDrzBaseClient.timeout(( rCc|jSrX)rrs rDrzBaseClient.event_hookss   rCct|dgt|dgd|_dSr)rrr)r^rs rDrzBaseClient.event_hookssK KOOIr::;;[__Z<<==  rCc|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrs rDrzBaseClient.auths zrCc:|||_dSrX)rrr^rs rDrzBaseClient.auths%%d++ rCc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rDrzBaseClient.base_url s ~rCcT|t||_dSrX)rrrrs rDrzBaseClient.base_urls!55c#hh??rCc|jS)z@ HTTP headers to include when sending requests. )_headersrs rDrzBaseClient.headers }rCctdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)r^rclient_headerss rDrzBaseClient.headerssd !$3$:$:7$C$C,)0099      g&&&& rCc|jS)zA Cookie values to include when sending requests. )rrs rDrzBaseClient.cookies(rrCc.t||_dSrX)rr)r^rs rDrzBaseClient.cookies/rrCc|jS)zO Query parameters to include in the URL when sending requests. )rrs rDrzBaseClient.params3s |rCc.t||_dSrX)rr)r^rs rDrzBaseClient.params:s"6** rCcontentdatafilesjsonrrrmethodrrrrc ||}||}|| } ||}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 r) _merge_url_merge_headers_merge_cookies_merge_queryparamsr) r^rrrrrrrrrs rD build_requestzBaseClient.build_request>s0ooc""%%g..%%g..((00      rCct|}|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)ris_relative_urlrrlstripr)r^r merge_urlmerge_raw_paths rDrzBaseClient._merge_urlfs] HH  $ D"]3i6H6O6OPT6U6UUN=**N*CC CrCcn|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)r^rmerged_cookiess rDrzBaseClient._merge_cookies|sC  "dl "$T\22N  ! !' * * *! !rCcXt|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)r^rmerged_headerss rDrzBaseClient._merge_headerss-!..g&&&rCcn|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. )rrmerge)r^rmerged_queryparamss rDrzBaseClient._merge_queryparamssD  &T[ &!,T[!9!9 !3!9!9&!A!A % % rCc|dSt|trt|d|dSt|tr|St |rt |St d|)Nrrusernamepassword)funczInvalid "auth" argument: )rtuplerrcallabler TypeErrorrs rDrzBaseClient._build_auths <4 e $ $ Bd1gQ@@@ @ d # # BK d^^ BT*** *@@@AA ArCrct|tr|jn||}||S|jj|jj}}|s|rt||S|jrLd|j vrC|j |jj }|t|d|dStS)Nr Authorizationrr)rr=rrrrrrrrrget_credentialshostr)r^rrrr credentialss rD_build_request_authzBaseClient._build_request_auths %T+;<< XDJJ$BRBRSWBXBX   K$[17;3G(  Cx ChBBB B > SoW_DD+55gk6FGGK& +a.;q>RRRRvv rCrTc|||}|||}||||}|||}t |j}t |||||S)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrrrS)_redirect_method _redirect_url_redirect_headers_redirect_streamrrr)r^rrTrrrrSrs rD_build_redirect_requestz"BaseClient._build_redirect_requests &&w99  (33((#v>>&&w77$,''sGWV    rCc|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)r^rrTrs rDrzBaseClient._redirect_methodst   5? 2 2v7G7GF  5; . .6V3C3CF  5#: : :v?O?OF rCc|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) rrrrschemerrrrjoinr)r^rrTlocationrexcs rDrzBaseClient._redirect_urls#J/ h--CC   %939997   : 7ch 7--W[%5-66C   (+""3''C ;  ?  ?--)=->>C s A?Acdt|j}t||js3|dd|jd|d<||jkr2|dkr,|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. rNrHostrzContent-LengthzTransfer-EncodingCookie)rrr6rpopnetlocdecoder)r^rrrrs rDrzBaseClient._redirect_headerss'/**3 ,, 9 KK . . ."j//88GFO W^ # #% KK($ / / / KK+T 2 2 2  Hd###rCc6||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrS)r^rrs rDrzBaseClient._redirect_stream s& W^ # #%4~rCrX)Ar>r?r@r r r%r*r(r'r.boolintrpMappingrListCallabler/r_propertyrrrrOptionalr)Dictrrrrsetterrrrrrrrrrrr+r,r-AnyrrrrrrrUSE_CLIENT_DEFAULTUnionr=rrrrrrr!rrrBrCrDr}r}s"&## 6 $2IM++++ +  +  ++++^CV_)E$EF++++++B14111X1 4X;3;3;;;; %|4%IM% S&/%00 1%%%%(X ^)|))))^)!V[fk&/.J)JK!!!X! !;sFK,H'HI     fod+X [,,t,,,[,#X _@H@@@@_@X  ^ '{ 't ' ' '^ 'X  ^){)t)))^) X  ]+_++++]+#' ""&##& & & & &  &  & & j&  & & &  & & & & Ph3.&*  "   %    &*  "   %    )-  %   )     B Bfod.C B B B B;Ml9&667  .  w  (  w     8.WS:sCG4  (+  no&EF G      rCr}c%ZeZdZdZddddddddddeeedddddddeded e d e d e d e d e de dedejeefdedededejeejejfdededejde f$fdZddddedddfd e d e d e de dededejde defdZddddedfded e d e d e de dede defdZdedefdZdddddddeeed d!eded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd'Z'e(dddddddeeed d!eded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fdej)e&fd(Z*deeed)d*e+d+e dej$ee%fd&ej$e e%fdej$ee%fde&f d,Z,d*e+de-de.d&e d-eje&de&f d.Z/d*e+de.d&e d-eje&de&f d/Z0d*e+de.de&fd0Z1dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd2Z2dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd3Z3dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd4Z4dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd5Z5dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd6Z6dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd7Z7dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd8Z8dAd9Z9d:e:de:fd;Z; dBde>ddfd?Z?dAd@Z@xZAS)Cr8a An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. 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). * **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. NTFr~rrrrverifycerthttp1http2rmountsrlimitsrrr transportapprrrrrrrrr rr!rr"rrrr#r$rc p t||||| | || r$ ddl}n#t$rtddwxYwo|duo|du}| |} ||_ fd|D_| 6j d| Dttj_dS)N rrrrrrrrrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrr r"r#r$rc ri|]3\}}t||dn| 4SNrrrr r"rr3_init_proxy_transport rGrHrrrr r"r^rrs rDrz#Client.__init__..st Q Q Q U sOO}"T++#, Q Q Q rCc4i|]\}}t||SrBr3rGrHr#s rDrz#Client.__init__..$QQQYC)QQQrC superr_h2 ImportErrorr_init_transport _transportr_mountsrrsortedr^rrrrrrrr rr!rr"rrrr#r$rr5r proxy_map __class__s` ```` ` ` rDr_zClient.__init__Zs, '#         !S  &K#+K)t:K''1BCC ../    Q Q Q Q Q Q Q Q Q Q (oo// Q Q Q     L  QQ&,,..QQQ   F4<#5#5#7#78899 ;ArVc X||S|t|St||||||SN)r$r+)r$r# r^rrrr r"r#r$rs rDr7zClient._init_transportsO    ? S))) )     rCrc .t|||||||S)N)rrrr r"rr)r#r^rrrrr r"rs rDr-zClient._init_proxy_transports0    rCrc|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. r9rmatchesr8r^rpatternr#s rD_transport_for_urlzClient._transport_for_urld #',"4"4"6"6 K K GYs## K*3*;tJJJ KrC rrrrrrrrrrrrrrrrc | 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 NzSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrrrrrrr)warningswarnDeprecationWarningrsend)r^rrrrrrrrrrrrmessagers rDrzClient.requests@  C  M'#5 6 6 6$$%   yy $   rCc #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 rNT)rrrrrSN)rrSrmr^rrrrrrrrrrrrrrTs rDrSz Client.streams6$$%   99+    NNN NN     HNN    s AA,rSrrrrrSc|jtjkrtdtj|_t |t r|jnt|}t |t r|j n|}| ||}| ||||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.rrrhistoryN)rrKrP RuntimeErrorrOrr=rrrr_send_handling_authread Exceptionrmr^rrSrrrrTrs rDrSz Client.sendIs , ;+, , ,VWW W!( &w0@AA WDLLwwGWGW  /+;<< !D    ''66++ + ,     O    NN   I s0C C-C((C-r\c||} t|} |||||} ||}n&#t$r|cY|SwxYwt ||_||}| |n(#t$r} || d} ~ wwxYw#|wxYwNT)rrr\) sync_auth_flownext_send_handling_redirectsrS StopIterationrmrr\r_appendr` r^rrrrr\ auth_flowrT next_requestrs rDr^zClient._send_handling_auths/''00  9ooG 88#$3# 9 ('0~~h'?'? ((((' OO    ((,G}}H$MMOOO*GNN8,,,, NN$$$I% , OO    sN)C'AB> A;$B>:A;;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.rrrT) lenrrr_send_single_requestrr\ is_redirectrr_rkr`rmr^rrrr\hookrTrs rDrfzClient._send_handling_redirectssB 7||d000&97))4  W 00'BBH  -j9##DDNNNN#'== +$#O66wII!XJ."$MMOOOO,3H)#O$         7 s7C;C C7C22C7c ||j}t}|t |jt stdt|5| |j |jj |j j |jd|i\}}}}dddn #1swxYwYt|||||} t!|| || _|j| | jd| j} | jd| } t,d |j d|jd | d | S) L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rrrrS extensionsNrrSrvrrTrU HTTP Request:  "")rJrr2 sync_startrrSr!r]rhandle_requestrrrawras_dictrrRrextract_cookiesr reason_phrase http_versionloggerdebug r^rrr#rUrrrSrvrTstatus response_lines rDrozClient._send_single_requests++GK88  '..99 Q W - - -  9B9Q9Q%%'' +~%w'8'89 :R:: 6['6:                !    *&85QQQ $$X...(CC8+ACC#0;;6;;  VgnVVw{VVmVVVWWWs6A$C&&C*-C*rrrrrrc <|d|||||||S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrrr^rrrrrrrs rDrz Client.gets7 ||  +   rCc <|d|||||||S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rDoptionszClient.options s7 ||  +   rCc <|d|||||||S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrrrs rDheadz Client.head&s7 ||  +   rCc D|d||||||||| | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrLr r^rrrrrrrrrrrs rDpostz Client.postAsC(||  +   rCc D|d||||||||| | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrLrrs rDputz Client.putdsC(||  +   rCc D|d||||||||| | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrLrrs rDpatchz Client.patchsC(||  +   rCc <|d|||||||S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rDdeletez Client.deletes7 ||  +   rCc|jtjkr\tj|_|j|jD]}||dSdSz. Close transport and proxies. N)rrKrPr8rmr9values)r^r#s rDrmz Client.closesx ;+, , ,%,DK O ! ! # # #!\0022 & & (OO%%% - , & &rCr^cP|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.) rrKrNrOrPr]r8 __enter__r9r)r^msgr#s rDrzClient.__enter__s ;+. . ."$S"$_kCs## #!(  !!###,,.. & &I$##%%% rCexc_type exc_value tracebackctj|_|j||||jD]}|||||dSrX)rKrPrr8__exit__r9r)r^rrrr#s rDrzClient.__exit__sr "(    9i@@@,,.. C CI$""8Y BBB C CrCcpt|ddtjkr|dSdS)Nr)getattrrKrOrmrs rD__del__zClient.__del__s7 44 ( (K,> > > JJLLLLL ? >rCroNNN)Br>r?r@rAr r r r%r*r(r'r0r&rr)rprrr r.rrrrr/r_r7rr-rrJrr+r,r-rrr=rrrrqrSrrSrrr^rfrorrrrrrrrmr7rType BaseExceptionrrr __classcell__r=s@rDr8r8,s ++`"&##" $59 6'2IM#'#)K:K:K:K: K:  K:  K:K:K:K:K:K:sM12K:K:K:K: ^CV_)E$EF!K:"#K:$!%K:&_'K:()K:K:K:K:K:K:^#'#'#          ! _       :#'                 ( c m     #' ""&##:L@R@R5 5 5 5 5  5  5 5 j5  5 5 5 l9&6675  d,<&<=5 l,<<=5  5 5 5 5 n #' ""&##:L@R@R/////  /  //j/ ///l9&667/ d,<&<=/l,<<=/  "///^/j:L@R@R4444 4 l9&667 4  d,<&<= 4l,<<=4 4444l""" "  " X& " """"H$$$ $ X& $  $$$$L%G%g%(%%%%V#'##:L@R@R          l9&667  d,<&<= l,<<=      >#'##:L@R@R          l9&667  d,<&<= l,<<=      >#'##:L@R@R          l9&667  d,<&<= l,<<=      >#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#'##:L@R@R          l9&667  d,<&<= l,<<=      6 & & & &a$04#'#' C C+m, C! C! C  C C C CrCc%ZeZdZdZddddddddddeeedddddddeded e d e d e d e d e de dedejeefdedededejeejejfdededejde f$fdZddddedddfd e d e d e de dededejde defdZddddedfded e d e d e de dede defdZdedefdZdddddddeeed d!eded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd'Z'e(dddddddeeed d!eded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fdej)e&fd(Z*deeed)d*e+d+e dej$ee%fd&ej$e e%fdej$ee%fde&f d,Z,d*e+de-de.d&e d-eje&de&f d.Z/d*e+de.d&e d-eje&de&f d/Z0d*e+de.de&fd0Z1dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd2Z2dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd3Z3dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd4Z4dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd5Z5dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd6Z6dddddddeeed ded"e d#e!d$e"d%ej#ded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd7Z7dddeeed1deded e d e dej$ee%fd&ej$e e%fdej$ee%fde&fd8Z8dAd9Z9d:e:de:fd;Z; dBde>ddfd?Z?dAd@Z@xZAS)Cr;a! An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. 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, or `False` (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`. * **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. NTFr~rrrrrrrrr rr!rr"rrrr#r$rc p t||||| | || r$ ddl}n#t$rtddwxYwo|duo|du}| |} ||_ fd|D_| 6j d| Dttj_dS)Nr&rr'r(c ri|]3\}}t||dn| 4Sr*r,r.s rDrz(AsyncClient.__init__.._st V V V U sOO}"T++#, V V V rCc4i|]\}}t||SrBr0r1s rDrz(AsyncClient.__init__..or2rCr3r;s` ```` ` ` rDr_zAsyncClient.__init__&s, '#         !S  &K#+K)t:K''1BCC ../    V V V V V V V V V V (oo// V V V     L  QQ&,,..QQQ   F4<#5#5#7#78899 r>rVc X||S|t|St||||||Sr@)rr"rAs rDr7zAsyncClient._init_transportssO    ? S))) )!     rCrc,t||||||S)N)rrr r"rr)r"rCs rDr-z!AsyncClient._init_proxy_transports-"     rCrc|jD]'\}}||r ||jn|cS(|jSrErFrHs rDrJzAsyncClient._transport_for_urlrKrCrLrrrrrrc K||||||||||  } || | | | d{V}|S)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 rNrON)rrSrWs rDrzAsyncClient.requests@$$%    $#        rCc K||||||||||  } || | | | dd{V} |WV|d{VdS#|d{VwxYwrV)rrSrzrWs rDrSzAsyncClient.streams6$$%   + #         $NNNN//## # # # # # # # # #(//## # # # # # # # #s A##A?rXrrScK|jtjkrtdtj|_t |t r|jnt|}t |t r|j n|}| ||}| ||||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 rZr[N)rrKrPr]rOrr=rrrrr^areadr`rzras rDrSzAsyncClient.send sT, ;+, , ,VWW W!( &w0@AA WDLLwwGWGW  /+;<< !D    ''6611 + 2          'nn&&&&&&&&&O   //## # # # # # # #I s8C D C<<Dr\cbK||} |d{V} |||||d{V} ||d{V}n,#t$r|cY|d{VSwxYwt ||_|d{V|}| |n.#t$r!} |d{V| d} ~ wwxYw#|d{VwxYwrc) async_auth_flow __anext__rfasendStopAsyncIterationrzrr\rrhr`ris rDr^zAsyncClient._send_handling_authCs((11  %%//11111111G !%!>!>#$3# "?"" (-6__X-F-F'F'F'F'F'F'F -((('""$$ $ $ $ $ $ $ $ $((,G}}H$"..**********GNN8,,,, "//+++++++++I% ,""$$ $ $ $ $ $ $ $ $sN:DA10C#1 B=C#BAC#"D# D-D  DDD.c8K t||jkrtd||jdD]}||d{V|||d{V} |jdD]}||d{Vt ||_|js|S|||}||gz}|r| d{Vn ||_ |Sn.#t$r!}| d{V|d}~wwxYwrm) rnrrrrorr\rprrrkr`rzrqs rDrfz$AsyncClient._send_handling_redirectsgs 7||d000&97))4 $ $d7mm########!66wHHHHHHHHH  -j9))D$x..((((((((#'== +$#O66wII!XJ."$"..**********,3H)#O+    oo'''''''''  9 s+=C,)AC,, D6DDc "K||j}t}|d{Vt |jt stdt|5| |j |jj |j j |jd|id{V\}}}}dddn #1swxYwYt|||||} t!|| || _|j| | jd| j} | jd| } t,d |j d|jd | d | S) rtNz?Attempted to send an sync request with an AsyncClient instance.rrrurwrxryrzr{r|)rJrr2 async_startrrSrr]rhandle_async_requestrrrrrrrtrrrrrrrrs rDroz AsyncClient._send_single_requests ++GK88 !!!!!!!!!'./:: Q W - - -    44%%'' +~%w'8'89 5                  !    +6HERRR $$X...(CC8+ACC#0;;6;;  VgnVVw{VVmVVVWWWs>A*C44C8;C8rc LK|d|||||||d{VS)rrrNrrs rDrzAsyncClient.getsY \\  +"         rCc LK|d|||||||d{VS)rrrNrrs rDrzAsyncClient.optionssY \\  +"         rCc LK|d|||||||d{VS)rrrNrrs rDrzAsyncClient.headsY \\  +"         rCc TK|d||||||||| | |  d{VS)rrrLNrrs rDrzAsyncClient.post se(\\  +"         rCc TK|d||||||||| | |  d{VS)rrrLNrrs rDrzAsyncClient.put0se(\\  +"         rCc TK|d||||||||| | |  d{VS)rrrLNrrs rDrzAsyncClient.patchSse(\\  +"         rCc LK|d|||||||d{VS)rrrNrrs rDrzAsyncClient.deletevsY \\  +"         rCcK|jtjkrhtj|_|jd{V|jD] }||d{VdSdSr)rrKrPr8rzr9r)r^rs rDrzzAsyncClient.acloses ;+, , ,%,DK/((** * * * * * * *,,.. ) )$,,..((((((( - , ) )rCr^clK|jtjkr4tjdtjdi|j}t |tj|_|jd{V|j D]}||d{V|Sr) rrKrNrOrPr]r8 __aenter__r9r)r^rrs rDrzAsyncClient.__aenter__s ;+. . ."$S"$_kCs## #!( o((*********\((** ) )E &&((((((((( rCrrrcKtj|_|j|||d{V|jD]!}|||||d{V"dSrX)rKrPrr8 __aexit__r9r)r^rrrrs rDrzAsyncClient.__aexit__s "( o'')YGGGGGGGGG\((** F FE ooh 9EEEEEEEEE F FrCcxt|ddtjkrtjd|ddSdS)Nrz Unclosed zR. See https://www.python-httpx.org/async/#opening-and-closing-clients for details.)rrKrOrPrQrs rDrzAsyncClient.__del__s\ 44 ( (K,> > >* MD     + ? >rCror)Br>r?r@rAr r r r%r*r(r'r0r&rr)rprrrr.rrrrr/r_r7rr-rrJrr+r,r-rrr=rrr r{rSrrSrrr^rfrorrrrrrrrzr:rrrrrrrrs@rDr;r;s --d"&##" $:> 6'2IM(,#)K:K:K:K: K:  K:  K:K:K:K:K:K:s$667K:K:K:K: ^CV_)E$EF!K:"#K:$&%K:&_'K:()K:K:K:K:K:K:^#'(,#          & _       :#'                 & c .@     #' ""&##:L@R@R.....  .  ..j. ...l9&667. d,<&<=.l,<<=. ....` #' ""&##:L@R@R/$/$/$/$/$  /$  /$/$j/$ /$/$/$l9&667/$ d,<&<=/$l,<<=/$  h '/$/$/$/$j:L@R@R4444 4 l9&667 4  d,<&<= 4l,<<=4 4444l"%"%"% "%  "% X& "% "%"%"%"%H%%% % X& %  %%%%N,,)0, ,,,,d#'##:L@R@R          l9&667  d,<&<= l,<<=      >#'##:L@R@R          l9&667  d,<&<= l,<<=      >#'##:L@R@R          l9&667  d,<&<= l,<<=      >#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#' ""&##:L@R@R! ! ! !  !  !  ! j!  ! ! ! l9&667!  d,<&<=! l,<<=!  ! ! ! ! N#'##:L@R@R          l9&667  d,<&<= l,<<=      6 ) ) ) )qQ$04#'#' F F+m, F! F! F  F F F FrC)XrjenumrprP contextlibrtypesrrrrrr _compatr _configr r r rrr _decodersr _exceptionsrrrr_modelsrrrrrr _status_codesr_transports.asgir_transports.baserrr r!_transports.defaultr"r#_transports.wsgir$_typesr%r&r'r(r)r*r+r,r-r.r/r0_utilsr1r2r3r4r5r6TypeVarr7r:r=rr>rrrkeysrEnumrKrRrtr}r8r;rBrCrDrs %%%%%%$$$$$$0000000000((((((*))))) KJJJJJJJJJJJJJJJ ++++++ CBBBBBBB++++++                            FN3h'''FN3m,,,        ,&%'' H   *[ * * ))CC+&+--CCC     $)   n.$$$$$$$$.JJJJJJJJZ G G G G G ZG G G Ta a a a a *a a a a a rC