RPffddlmZddlZddlZddlZddlZddlZddlmZm 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@ddlAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIejddZKejddZLGddZMeMZNejdZPde ZQdjejDcgc] }|dk7s | c}ZTGdd ejZVGd!d"e=ZWGd#d$e1ZXejd%ejfZ[Gd&d'Z\Gd(de\Z]Gd)de\Z^ycc}w)*) 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 AsyncClientceZdZdZy)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__G/var/www/fastapitest/venv/lib/python3.12/site-packages/httpx/_client.pyr?r?CsrEr?httpxz python-httpx/z, identityceZdZdZdZdZy) ClientStaterN)r@rArBUNOPENEDOPENEDCLOSEDrDrErFrJrJbsHFFrErJc8eZdZdZ ddZddZddZy) 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. c.||_||_||_yN_stream _response_timerselfstreamresponsetimers rF__init__zBoundSyncStream.__init__v ! rEc#6K|jD]}|ywrSrUrYchunks rF__iter__zBoundSyncStream.__iter__}s\\ EK sc|jj}tj||j_|j jyN)seconds)rW sync_elapseddatetime timedeltarVelapsedrUcloserYrfs rFrkzBoundSyncStream.closes;++**,!)!3!3G!D rEN)rZr.r[rr\r4returnNone)rmztyping.Iterator[bytes]rmrn)r@rArBrCr]rcrkrDrErFrQrQps6 $08AF rErQc8eZdZdZ ddZddZddZy) 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. c.||_||_||_yrSrTrXs rFr]zBoundAsyncStream.__init__r^rEcHK|j23d{}|7 6ywrSr`ras rF __aiter__zBoundAsyncStream.__aiter__s&<<  %K dZd?d Zef d@d!ZdAd"ZdBd#ZdCd$ZdDd%Z dEd&Zy)F BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingc |in|}|jt| |_|j||_t ||_t||_t||_ t||_ ||_ ||_t|j!dgt|j!dgd|_| |_| |_t(j*|_yNrequestr[)rr[)_enforce_trailing_slashr2 _base_url _build_auth_authr3_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingrJrM_state) rYr}r~rrrrrrrrrs rFr]zBaseClient.__init__s(/b[ 55c(mD%%d+ "6* w' ( ( 0*KOOIr:;[__Z<= $!1!** rEc<|jtjk(S)z2 Check if the client being closed )rrJrOrYs rF is_closedzBaseClient.is_closeds {{k0000rEc|jSrS)rrs rFrzBaseClient.trust_envs rEcz|jjdr|S|j|jdzS)N/raw_path)rendswith copy_withrYurls rFrz"BaseClient._enforce_trailing_slashs3 <<  &J}}cllT&9}::rEc|>|r:tjDcic]\}}||dn t|c}}SiSt|trNi}|jD]7\}}t|t t fr t|n|}||t |<9|St|t t fr t|n|}d|iScc}}w)N)rzall://)r6itemsr isinstancedictstrr2)rYproxiesallow_env_proxieskeyr new_proxiesvalueproxys rF_get_proxy_mapzBaseClient._get_proxy_maps ? %<$=$C$C$E S%C.@I gt $K%mmo . U,6usCj,I%(u(- CH% . *4WsCj*IEg&wEe$ $sCc|jSrS)rrs rFrzBaseClient.timeouts }}rEc$t||_yrS)rr)rYrs rFrzBaseClient.timeout( rEc|jSrS)rrs rFrzBaseClient.event_hookss   rEc|t|jdgt|jdgd|_yr)rrr)rYrs rFrzBaseClient.event_hookss4KOOIr:;[__Z<= rEc|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrs rFr}zBaseClient.authszzrEc0|j||_yrS)rrrYr}s rFr}zBaseClient.auths%%d+ rEc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rFrzBaseClient.base_url s ~~rEcB|jt||_yrS)rr2rrs rFrzBaseClient.base_urls55c#h?rEc|jS)z@ HTTP headers to include when sending requests. )_headersrs rFrzBaseClient.headers }}rEctdtjddtjdd}|j |||_y)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rYrclient_headerss rFrzBaseClient.headerssJ !$3$:$:7$C,)009    g&& rEc|jS)zA Cookie values to include when sending requests. )rrs rFrzBaseClient.cookies)rrEc$t||_yrS)rr)rYrs rFrzBaseClient.cookies0rrEc|jS)zO Query parameters to include in the URL when sending requests. )rrs rFr~zBaseClient.params4s ||rEc$t||_yrS)r3r)rYr~s rFr~zBaseClient.params;s"6* rE) contentdatafilesjsonr~rrr extensionsc P|j|}|j|}|j| } |j|}| in| } d| vrDt | t r |j n t| } tdi| d| ji} 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)rrrrr~rrrrD) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr?rrras_dictr) rYmethodrrrrrr~rrrrs rF build_requestzBaseClient.build_request?s4ooc"%%g.%%g.((0%-R: J &g'78 W%  F FGOO4EFJ  !  rEct|}|jrN|jj|jj dz}|jj |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)rYr merge_urlmerge_raw_paths rFrzBaseClient._merge_urlrs\ H  $ $"]]33i6H6H6O6OPT6UUN==**N*C CrEcr|s |jr(t|j}|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)rYrmerged_cookiess rFrzBaseClient._merge_cookiess4 dll$T\\2N  ! !' *! !rEcRt|j}|j||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rYrmerged_headerss rFrzBaseClient._merge_headerss& !.g&rEcn|s |jr&t|j}|j|S|S)z Merge a queryparams argument together with any queryparams on the client, to create the queryparams used for the outgoing request. )r~r3merge)rYr~merged_queryparamss rFrzBaseClient._merge_queryparamss2 T[[!,T[[!9 %++F3 3 rEc|yt|trt|d|dSt|tr|St |r t |St d|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rFrzBaseClient._build_auths] < e $d1gQ@ @ d #K d^T* *7x@A ArEct|tr |jn|j|}||S|jj |jj }}|s|r t||StS)Nr) rr?rrrrrr r )rYrr}rrs rF_build_request_authzBaseClient._build_request_authsk %T+;&&w7$,,'))   rEc|j}|jtjk(r|dk7rd}|jtjk(r|dk7rd}|jtj k(r|dk(rd}|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)rYrr[rs rFrzBaseClient._redirect_methodst    5?? 2v7GF   5;; .6V3CF   5#:#: :v?OF rEc|jd} t|}|jr2|j s&|j |jj }|jr|jj|}|jjr2|js&|j |jj}|S#t$r}td|d|dd}~wwxYw)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)host)fragment) rr2rrschemerrrrjoinr)rYrr[locationrexcs rFrzBaseClient._redirect_urls##J/ h-C ::chh--W[[%5%5-6C   ++""3'C ;;   --)=)=->C ' %23%q97  s C C+C&&C+c|t|j}t||jsFt |j|s|j dd|j jd|d<||jk7r)|dk(r$|j dd|j dd|j dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrr8rr7popnetlocdecoder)rYrrrrs rFrzBaseClient._redirect_headers s'//*3 ,$W[[#6 OT2"jj//8GFO W^^ #% KK($ / KK+T 2  Hd#rEcD||jk7r|dk(ry|jS)zO Return the body that should be used for the redirect request. rN)rrZ)rYrrs rFrzBaseClient._redirect_stream(s# W^^ #%~~rE)r}AuthTypes | Noner~QueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr/rboolrintr+None | typing.Mapping[str, list[EventHook]]rr0rrr#str | typing.Callable[[bytes], str]rmrn)rmr)rr2rmr2)rProxiesTypes | Nonerrrmzdict[str, Proxy | None])rmr)rr/rmrn)rmdict[str, list[EventHook]])rrrmrn)rm Auth | None)r}r#rmrn)rmr2)rr0rmrn)rmr)rr&rmrn)rmr)rr%rmrn)rmr3)r~r)rmrn)rrrr0rRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | Noner~r rr rrrTimeoutTypes | UseClientDefaultrRequestExtensions | Nonermr)rr0rmr2rS)rrrmr)rr rmr )r~r rmr )r}r rmr)rrr}#AuthTypes | UseClientDefault | Nonermr )rrr[rrmr)rrr[rrmr)rrr[rrmr2)rrrr2rrrmr)rrrrrmz'SyncByteStream | AsyncByteStream | None) r@rArBrr r]propertyrrrrrsetterrr}rrrr~USE_CLIENT_DEFAULTrrrrrrrrrrrrrDrErFryrysF"&)-&*&* 6!&2EI@G + +' + $ + $ + + + +C + + +> +  +D11 ; %*%?C% %( ^^))!!   [[,, __@@  ^^ ' '  ^^))  ]]++*.#'%)"&)-&*&*3E/31 1 1 ' 1 ! 1 #1  1 '1 $1 $1 11 -1  1 f, 04 ,    B5G2  $ &.:6  (+  0 rErycTeZdZdZdddddddddddedeeddddddd dfdZddddedddf d d Zddddedf d!d Z d"d Z ddddddde e e dd d#d Z e ddddddde e e dd d$dZde e d d%dZ d&dZ d'dZd(dZddde e e dd d)dZddde e e dd d)dZddde e e dd d)dZddddddde e e dd d*dZddddddde e e dd d*dZddddddde e e dd d*dZddde e e dd d)dZd+dZd,dZ d- d.dZxZS)/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". NTFrzr{r}r~rrverifycerthttp1http2rrmountsrrlimitsrrr transportapprrc2t|||||| | ||||| |r ddl}| r)d}t j |t | r td|rd}t j |t |xr |duxr|du}|j| xs| |}|j|||||||||_ |jD cic]+\}} t|| dn|j| ||||||-c} }|_| F|jj| jDcic]\}}t||c}}t!t#|jj|_y#t$r tddwxYwcc} }wcc}}w) Nr|ruUsing 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%r'r(r)rr"r#r$r%r'rsuperr]h2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportrr5_init_proxy_transport_mountsrrsortedrYr}r~rrr"r#r$r%rrr&rrr'rrrr(r)rrr2messager proxy_mapr __class__s rFr]zClient.__init__js2 -'#-     4  MM'#5 6"#OPP V  MM'#5 6%K#+K)t:K''(85:KL ../  ,(oo/ @ U sO}"++#,  @     LL  BH,,.QYC)+Q F4<<#5#5#789 m !S F @ RsE40F $F 4F c H||S| t|St||||||SN)r)r/)r!r rYr"r#r$r%r'r(r)rs rFr8zClient._init_transports?    ? S) )   rEc &t|||||||SN)r"r#r$r%r'rr)r rYrr"r#r$r%r'rs rFr:zClient._init_proxy_transports&  rEc|jjD]*\}}|j|s||jcS|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. r;rmatchesr9rYrpatternr(s rF_transport_for_urlzClient._transport_for_urlS #',,"4"4"6 K GYs#*3*;tJJ KrE rrrrr~rrr}rrrc | d}tj|t|j||||||||| | |  }|j || | 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 Setting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrr~rrrrr}rr4r5r6rsendrYrrrrrrr~rrr}rrrr>rs rFrzClient.requestsuB  C  MM'#5 6$$!%  yyt>NyOOrEc #K|j||||||||| | |  }|j|| | d} ||jy#|jwxYwwa  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 rRT)rr}rrZN)rrUrkrYrrrrrrr~rrr}rrrrr[s rFrZz Client.stream=s}8$$!%  99-    N NN HNN s2AA A AArZr}rcv|jtjk(r tdtj|_t |t r |jn|}|j||}|j|||g} |s|j|S#t$r}|j|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.r}rhistoryN) rrJrOr7rNrr?rr_send_handling_authread BaseExceptionrkrYrrZr}rr[rs rFrUz Client.sendqs* ;;+,, ,VW W!(( *,<=  ! !!  ''6++ - ,    O  NN I sB B8!B33B8c|j|} t|} |j|||} |j|}t ||_|j|}|j|[#t$r|cY|j SwxYw#t$r}|j |d}~wwxYw#|j wxYwN)rr^) sync_auth_flownext_send_handling_redirectsrU StopIterationrkrr^r`appendra rYrr}rr^ auth_flowr[ next_requestrs rFr_zClient._send_handling_auths''0  9oG88%5#9 ('0~~h'? (,G}H$MMO*GNN8,)(' OO (%NN$I OO sL B>A:3B9B>: BBBB B;$B66B;;B>>Cc t||jkDr td||jdD] }|| |j |} |jdD] }|| t ||_|js|S|j||}||gz}|r|jn ||_ |S #t$r}|j|d}~wwxYwNz#Exceeded maximum allowed redirects.rrr[) lenrrr_send_single_requestrr^has_redirect_locationrr`rlrarkrYrrr^hookr[rs rFrgzClient._send_handling_redirectss 7|d000&97)))4 W  009H  --j9#DN##'= 55#O66wI!XJ.#MMO,3H)#O$-6!    s9C3C C%C  C%c|j|j}t}|jt |j t s tdt|5|j|}dddt j t sJ||_ t|j |||_|jj||j|_t j#d|j$|j|j&|j(|j*|S#1swYxYw)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rNr[r\HTTP Request: %s %s "%s %d %s")rMrr4 sync_startrrZr.r7rhandle_requestrrQrextract_cookiesrrloggerinfor http_versionr reason_phraserYrr(r\r[s rFrpzClient._send_single_requests++GKK8  '...9Q W - 9 //8H 9(//>:::") OOhe  $$X.$($:$:! , NN KK  ! !   " "  + 9 9s 'D;;Er~rrr}rrrc 6|jd|||||||| S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrr rYrr~rrr}rrrs rFrz Client.get s5"||  -!  rEc 6|jd|||||||| S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rFoptionszClient.options*s5"||  -!  rEc 6|jd|||||||| S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrrrs rFheadz Client.headGs5"||  -!  rEc >|jd||||||||| | | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrOr rYrrrrrr~rrr}rrrs rFpostz Client.postdsA*||  -!  rEc >|jd||||||||| | | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrOrrs rFputz Client.putsA*||  -!  rEc >|jd||||||||| | | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrOrrs rFpatchz Client.patchsA*||  -!  rEc 6|jd|||||||| S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rFdeletez Client.deletes5"||  -!  rEc|jtjk7rbtj|_|jj |j j D]}||j yyz. Close transport and proxies. N)rrJrOr9rkr;values)rYr(s rFrkz Client.closesd ;;+,, ,%,,DK OO ! ! #!\\002 & (OO% & -rEcv|jtjk7r:tjdtjdi|j}t |tj|_|j j|jjD]}||j|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrJrMrNrOr7r9 __enter__r;r)rYmsgr(s rFrzClient.__enter__s ;;+.. .""$S""O kk C s# #!((  !!#,,. &I$##% & rEctj|_|jj ||||j j D]}||j |||yrS)rJrOrr9__exit__r;r)rYexc_type exc_value tracebackr(s rFrzClient.__exit__s] "((    9i@,,. CI$""8Y B CrE),r}r r~r rr rrr"r1r#CertTypes | Noner$rr%rrProxyTypes | Nonerrr&z0None | typing.Mapping[str, BaseTransport | None]rr/rrr'rrrrrrr0r(BaseTransport | Noner)'typing.Callable[..., typing.Any] | Nonerrrrrmrn)r"r1r#rr$rr%rr'rr(rr)rrrrmr)rrr"r1r#rr$rr%rr'rrrrmr)rr2rmrrrrr0rrrrrrrrr~r rr rrr}rrbool | UseClientDefaultrrrrrmr)rrrr0rrrrrrrrr~r rr rrr}rrrrrrrrmztyping.Iterator[Response] rrrZrr}rrrrmr rrr}r rrr^list[Response]rmrrrrrr^rrmrrrrmrrr0r~r rr rrr}AuthTypes | UseClientDefaultrrrrrrrmrrr0rrrrrrrrr~r rr rrr}rrrrrrrrmrro)rYr9rmr9NNNrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonermrn)r@rArBrCrr r r]r8r:rMrrrrZrUr_rgrprrrrrrrrkrr __classcell__r@s@rFr:r:4sh3p"&)-&*&*"!%#''+EI 6!&'2EI*.7;@G/`:`:' `: $ `: $ `:`:`:`:`:!`:%`:C`:`:`: !`:"#`:$C%`:&'`:(()`:*5+`:,-`:.>/`:0 1`:H#!%'*.7;         ( 5    :#!%'             (  *.#'%)"&)-&*&*4F4F3E/36P6P6P ' 6P ! 6P#6P 6P'6P$6P$6P26P26P16P-6P !6Pp *.#'%)"&)-&*&*4F4F3E/3111 ' 1 ! 1#1 1'1$1$1212111-1 #!11n4F4F // / 2 / 2 / /b        D### #  #J"P*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.&*&*-?4F3E/3  '  $  $  + 2 1 -   : &(04*.*. C, C( C( C  CrEcTeZdZdZdddddddddddedeeddddddd dfdZddddedddf d d Zddddedf d!d Z d"d Z ddddddde e e dd d#d Z e ddddddde e e dd d$dZde e d d%dZ d&dZ d'dZd(dZddde e e dd d)dZddde e e dd d*dZddde e e dd d*dZddddddde e e dd d+dZddddddde e e dd d+dZddddddde e e dd d+dZddde e e dd d*dZd,dZd-dZ d. d/dZxZS)0r=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". NTFrzr{r!c&t|||||| | ||||| |r ddl}| r)d}t j |t | r td|rd}t j |t |xr|du}|j| xs| |}|j|||||||||_ |jD cic]+\}} t|| dn|j| ||||||-c} }|_| F|jj| jDcic]\}}t||c}}t!t#|jj|_y#t$r tddwxYwcc} }wcc}}w) Nr|rr+r,r-zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.r.r/r0r=s rFr]zAsyncClient.__init__Ss4 -'#-     4  MM'#5 6"#OPP V  MM'#5 6%;)t*;''(85:KL ../  .(oo/ E U sO}"++#,  E     LL  BH,,.QYC)+Q F4<<#5#5#789 m !S H E RsE.;0FF .Fc H||S| t|St||||||SrB)rrrCs rFr8zAsyncClient._init_transports?    ? S) )!   rEc &t|||||||SrE)rrFs rFr:z!AsyncClient._init_proxy_transports&"  rEc|jjD]*\}}|j|s||jcS|cS|jSrHrIrKs rFrMzAsyncClient._transport_for_urlrNrErOc K| d}tj|t|j||||||||| | |  }|j || | d{S7w)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 NrQrRrSrTrVs rFrzAsyncClient.requestsD  C  MM'#5 6$$!%  YYwTDTYUUUUsAAAAc K|j||||||||| | |  }|j|| | dd{} ||jd{y7#7#|jd{7wxYwwrX)rrUrwrYs rFrZzAsyncClient.stream(s8$$!%  - #    $N//# # #  $(//# # #sD5A=AA=AA=AA=A=A:3A64A::A=rZcK|jtjk(r tdtj|_t |t r |jn|}|j||}|j|||gd{} |s|jd{|S7!7#t$r }|jd{7|d}~wwxYww)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 r\r]N) rrJrOr7rNrr?rrr_areadrarwrbs rFrUzAsyncClient.send\s* ;;+,, ,VW W!(( *,<=  ! !!  ''611 - 2    nn&&&O ' //# # #I sTBCB* CB.#B,$B.)C,B.. C7C C  CCCc>K|j|} |jd{} |j|||d{} |j|d{}t ||_|jd{|}|j|s7x7]7D#t$r|cY|j d{7SwxYw7H#t$r }|j d{7|d}~wwxYw#|j d{7wxYwwrd) async_auth_flow __anext__rgasendStopAsyncIterationrwrr^rrirarjs rFr_zAsyncClient._send_handling_auths((1  %%//11G!%!>!>%5#"?" (-6__X-F'F (,G}H$"..****GNN8,2(G-('""$ $ $(+%"//+++I""$ $ $sDC?B!C?B#C? B' B%!B'%#CC C C?#C?%B'' C2C3DC D CC C<C7/C20C77C<<C??DDDDc:K t||jkDr td||jdD]}||d{|j |d{} |jdD]}||d{t ||_|js|S|j||}||gz}|r|jd{n ||_ |S 777f7#t$r }|jd{7|d}~wwxYwwrn) rorrrrprr^rqrrrlrarwrrs rFrgz$AsyncClient._send_handling_redirectss8 7|d000&97)))4 $7m## $"66w??H  --j9)Dx.(()$(= 55#O66wI!XJ.#"..***,3H)#O+/$?)+ ! oo'''  sADC'D!C)"D'C/C+#C/(D)-C/C- C/$D)D+C/-C// D8D D DDDcK|j|j}t}|jd{t |j t s tdt|5|j|d{}dddt j t sJ||_ t|j |||_|jj||j|_t j#d|j$|j|j&|j(|j*|S77#1swYxYww)ruNz?Attempted to send an sync request with an AsyncClient instance.rrvrw)rMrr4 async_startrrZr"r7rhandle_async_requestrrqrrzrrr{r|rr}rr~rs rFrpz AsyncClient._send_single_requests+++GKK8 !!!'../:Q W - E&;;GDDH E(//?;;;"* OOhe  $$X.$($:$:! , NN KK  ! !   " "  7 "E E Es:9EE 5E1EEE CEEEErc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.getsC"\\  -!"    '%'c RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.optionssC"\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.head2sC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrONrrs rFrzAsyncClient.postOsO*\\  -!"    "+)+c ZK|jd||||||||| | | |  d{S7w)rrrONrrs rFrzAsyncClient.puttsO*\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrONrrs rFrzAsyncClient.patchsO*\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.deletesC"\\  -!"    rc2K|jtjk7rrtj|_|jj d{|j j D]}||j d{yy7@7 wr)rrJrOr9rwr;r)rYrs rFrwzAsyncClient.acloses~ ;;+,, ,%,,DK//((* * *,,. )$,,.(( ) - +)s*ABB#B7B B BBcK|jtjk7r:tjdtjdi|j}t |tj|_|j jd{|jjD]}||jd{|S7@7 wr) rrJrMrNrOr7r9 __aenter__r;r)rYrrs rFrzAsyncClient.__aenter__s ;;+.. .""$S""O kk C s# #!(( oo((***\\((* )E &&((( ) +)s*B C C  #C1CC CCcKtj|_|jj |||d{|j j D] }||j |||d{"y7B7 wrS)rJrOrr9 __aexit__r;r)rYrrrrs rFrzAsyncClient.__aexit__sx "(( oo'')YGGG\\((* FE ooh 9EEE F HFs'6A?A;#A?A?3A=4A?=A?),r}r r~r rr rrr"r1r#rr$rr%rrrrrr&z5None | typing.Mapping[str, AsyncBaseTransport | None]rr/rrr'rrrrzBNone | typing.Mapping[str, list[typing.Callable[..., typing.Any]]]rr0r(AsyncBaseTransport | Noner)rrrrrrmrn)r"r1r#rr$rr%rr'rr(rr)rrrrmr)rrr"r1r#rr$rr%rr'rrrrmr)rr2rmrr)rrrr0rrrrrrrrr~r rr rrr}rrrrrrrrmztyping.AsyncIterator[Response]rrrr)rr0r~r rr rrr}rrrrrrrrmrrrro)rYr<rmr<rr)r@rArBrCrr r r]r8r:rMrrrrZrUr_rgrprrrrrrrrwrrrrs@rFr=r=sh4r"&)-&*&*"!%#''+JN 6!&'2JN/37;@G1a:a:' a: $ a: $ a:a:a:a:a:!a:%a:Ha:a:a: !a:"#a:$H%a:()a:*-+a:,5-a:./a:0>1a:2 3a:J#!%'/37;         - 5    :#!%'             (  *.#'%)"&)-&*&*4F4F3E/37V7V7V ' 7V ! 7V#7V 7V'7V$7V$7V27V27V17V-7V !7Vr *.#'%)"&)-&*&*-?4F3E/31$1$1$ ' 1$ ! 1$#1$ 1$'1$$1$$1$+1$21$11$-1$ (!1$1$n4F4F // / 2 / 2 / /b % % % %  %  %D$$$ $  $L!N*.&*&*4F4F3E/3  '  $  $  2 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.&*&*-?4F3E/3  '  $  $  + 2 1 -   : )(04*.*. F, F( F( F  FrE)_ __future__rrhenumloggingtypingr4 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 getLoggerr{rrkeysrEnumrJrQrqCallableAny EventHookryr:r=)rs0rFrs}"  :$00* 98 +?B+$$FNN3h'FNN3m,(&'   7 #[M * ))+&++-CS 1BSC $)) n.$$. OOCO , PPf e CZe CPh F*h F}%Ds 1 F.<F.