osjf&ddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ddlmZddlmZddlmZmZmZdd lmZmZmZmZmZmZmZmZmZmZdd l m!Z!dd l"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(m)Z)m*Z*m+Z+dd l,m-Z-ddl.m/Z/ddl0m1Z1m2Z2ddl3m4Z4m5Z5ddl6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCddlDmEZEmFZFddlGmHZHmIZIejr ddlKZKddlLmMZMmNZNgdZOejddZQejddZRd/dZSd0dZTd1dZUGddZVeVZWejd ZYd!eZZd"je!jDcgc] }|d#k7s | c}Z]Gd$d%ejZ_Gd&d'eBZ`Gd(d)e7Zaejd*ejfZdGd+d,ZeGd-deeZfGd.deeZgycc}w)2) annotationsN)AsyncGenerator Generator)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth) 'DEFAULT_KEEPALIVE_PING_INTERVAL_SECONDS&DEFAULT_KEEPALIVE_PING_TIMEOUT_SECONDSDEFAULT_LIMITSDEFAULT_MAX_MESSAGE_SIZE_BYTESDEFAULT_MAX_REDIRECTSDEFAULT_QUEUE_SIZEDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse) EventSource)codes)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypes)URL QueryParams) URLPatternget_environment_proxies)AsyncWebSocketSessionWebSocketSession)USE_CLIENT_DEFAULT AsyncClientClientTr<)boundUr;c|j|jk7ry|jdk(xr/t|dk(xr|jdk(xrt|dk(S)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' FhttpPhttps)hostscheme_port_or_default)urllocations A/root/.hermes/venv/lib/python3.12/site-packages/httpx2/_client.py_is_https_redirectrKFsa xx8==  f . S !R ' . OOw & . X &# - cn|j |jSdddj|jS)NrBrD)rArC)portgetrFrHs rJrGrGUs/ xxxx % ) )#** 55rLc|j|jk(xr2|j|jk(xrt|t|k(S)z@ Return 'True' if the given URLs share the same origin. )rFrErG)rHothers rJ _same_originrS[sA :: % u#((ejj*@ uEUVYEZ^not^uEuurLceZdZdZy)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__rLrJrUrUbsrLrUhttpx2zpython-httpx2/z, identityceZdZdZdZdZy) ClientStater N)rVrWrXUNOPENEDOPENEDCLOSEDrZrLrJr^r^sHFFrLr^c(eZdZdZddZddZddZy) BoundSyncStreamz A byte stream that tracks elapsed time for a response. Once closed, the elapsed time is available via the `elapsed` attribute, and the response can read it back from `response.stream.elapsed`. c.||_||_d|_yN_stream_startelapsedselfstreamstarts rJ__init__zBoundSyncStream.__init__  26 rLc#8K|jEd{y7wrgrirms rJ__iter__zBoundSyncStream.__iter__s<<s ctjtj|jz |_|j jyN)seconds)datetime timedeltatime perf_counterrjrkricloserts rJr}zBoundSyncStream.closes6))$2C2C2E 2ST  rLN)rnr2rofloatreturnNone)rztyping.Iterator[bytes]rr)rVrWrXrYrprur}rZrLrJreres 7  rLrec(eZdZdZddZddZddZy) BoundAsyncStreamz An async byte stream that tracks elapsed time for a response. Once closed, the elapsed time is available via the `elapsed` attribute, and the response can read it back from `response.stream.elapsed`. c.||_||_d|_yrgrhrls rJrpzBoundAsyncStream.__init__rqrLcHK|j23d{}|7 6ywrgrs)rmchunks rJ __aiter__zBoundAsyncStream.__aiter__s&<<  %K dZd|r:tjDcic]\}}||dn t|c}}SiSt|tt fr t|n|}d|iScc}}w)NrPzall://)r7itemsr isinstancestrr4)rmproxyallow_env_proxieskeyrHs rJ_get_proxy_mapzBaseClient._get_proxy_mapsi = UlUnUtUtUvwcS[TenDwwI(253*(EEe$5Ee$ $ xsA)c|jSrg)rrts rJrzBaseClient.timeouts }}rLc$t||_yrg)rr)rmrs rJrzBaseClient.timeout( rLc|jSrg)rrts rJrzBaseClient.event_hookss   rLc|t|jdgt|jdgd|_yr)rrOr)rmrs rJrzBaseClient.event_hookss4KOOIr:;[__Z<= rLc|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrts rJrzBaseClient.authszzrLc0|j||_yrg)rrrmrs rJrzBaseClient.auths%%d+ rLc|jS)zK Base URL to use when sending requests with relative URLs. )rrts rJrzBaseClient.base_urls ~~rLcB|jt||_yrg)rr4rrs rJrzBaseClient.base_urls55c#h?rLc|jS)z@ HTTP headers to include when sending requests. )_headersrts rJrzBaseClient.headers" }}rLctdtjddtjdd}|j |||_y)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rmrclient_headerss rJrzBaseClient.headers)sJ !$3$:$:7$C,)009    g&& rLc|jS)zA Cookie values to include when sending requests. )rrts rJrzBaseClient.cookies6rrLc$t||_yrg)rr)rmrs rJrzBaseClient.cookies=rrLc|jS)zO Query parameters to include in the URL when sending requests. )rrts rJrzBaseClient.paramsAs ||rLc$t||_yrg)r5r)rmrs rJrzBaseClient.paramsHs"6* rL) contentdatafilesjsonrrrr extensionsc P|j|}|j|}|j| } |j|}| in| } d| vrDt | t r |j n t| } tdi| d| ji} 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 r)rrrrrrrrrZ) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrUrrdictas_dictr) rmmethodrHrrrrrrrrrs rJ build_requestzBaseClient.build_requestLs4ooc"%%g.%%g.((0%-R: J &&0:J&KdllQXY`QaGF FGOO4EFJ  !  rLct|}|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)r4is_relative_urlrrlstripr)rmrH merge_urlmerge_raw_paths rJrzBaseClient._merge_url{s\ H  $ $"]]33i6H6H6O6OPT6UUN==**N*C CrLcr|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)rmrmerged_cookiess rJrzBaseClient._merge_cookiess4 dll$T\\2N  ! !' *! !rLcRt|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)rmrmerged_headerss rJrzBaseClient._merge_headerss& !.g&rLcn|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. )rr5merge)rmrmerged_queryparamss rJrzBaseClient._merge_queryparamss2 T[[!,T[[!9 %++F3 3 rLc|yt|trt|d|dSt|tr|St |r t |St d|)Nrr usernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rJrzBaseClient._build_auths] < e $d1gQ@ @ d #K d^T* *7x@A ArLct|tr |jn|j|}||S|jj |jj }}|s|r t||StS)Nr) rrUrrrHrrr r )rmrrrrs rJ_build_request_authzBaseClient._build_request_authsf (.>?tzzTEUEUVZE[  K$[[117;;3G3G( xhB Bv rLc|j||}|j||}|j|||}|j||}t |j }t ||||||jS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrHrrrnr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rmrrrrHrrnrs rJ_build_redirect_requestz"BaseClient._build_redirect_requests &&w9  (3((#v>&&w7$,,'))   rLc|j}|jtjk(r|dk7rd}|jtjk(r|dvrd}|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. HEADGET)rQUERYPOST)r status_coder" SEE_OTHERFOUNDMOVED_PERMANENTLY)rmrrrs rJrzBaseClient._redirect_methodsu    5?? 2v7GF   5;; .6AR3RF   5#:#: :v?OF rLc|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)rE)fragment) rr4rrrFrErrHrjoinr )rmrrrIrHexcs rJrzBaseClient._redirect_urls##J/ lh-C ::chh--W[[%5%5-6C   ++""3'C ;;   --)=)=->C # l%(HQ&OY`agk k ls 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) rrrSrHrKpopnetlocdecoder)rmrrHrrs rJrzBaseClient._redirect_headerss'//*C-%gkk37 OT2"jj//8GFO W^^ #% KK($ / KK+T 2  Hd#rLcD||jk7r|dk(ry|jS)zO Return the body that should be used for the redirect request. rN)rrn)rmrrs rJrzBaseClient._redirect_stream-s# W^^ #%~~rLcd|jvrht|jtr |jnt |j}t di|jd|j i|_yy)NrrZ)rrrrUrrr)rmrrs rJ _set_timeoutzBaseClient._set_timeout6s] G.. .&0?O&PdllV]^b^j^jVkG!%!V(:(:!VGOODU!VG  /rL)rAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr3rboolrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrrr*str | typing.Callable[[bytes], str | None]rr)rr)rHr4rr4)rProxyTypes | Nonerrrzdict[str, Proxy | None])rr)rr3rr)rdict[str, list[EventHook]])rr"rr)r Auth | None)rr(rr)rr4)rHrrr)rr)rr+rr)rr)rr*rr)rr5)rr-rr)rrrHrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NonerrrrrrrTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerr)rHrrr4rg)rrrr)rrrr)rrrr)rrrr#)rrr#AuthTypes | UseClientDefault | Nonerr )rrrr rr)rrrr rr)rrrr rr4)rrrHr4rrrr)rrrrrz'SyncByteStream | AsyncByteStream | None)rrrr)!rVrWrXrrrppropertyrrrrrsetterrrrrrrr:rrrrrrrrrrrrrrZrLrJrrs"&)-&*&* 6!&2EI GN + +' + $ + $ + + + +C + + +E +  +D11 ; % ^^))!!   [[,, __@@  ^^ ' '  ^^))  ]]++*.#'%)"&)-&*&*3E/3- - - ' - ! - #-  - '- $- $- 1- --  - ^,  B5G2    &266WrLrc^eZdZdZdddddddddddedeeddddd d%fdZdddddedf d&d Zdddddef d'd Z d(d Z ddddddde e e dd d)d Z e ddddddde e e dd d*dZe dddddddde e e dd d+dZe eeeedddde e e dd d,dZde e d d-dZ d.dZ d/dZd0dZddde e e dd d1dZddde e e dd d2dZddde e e dd d2dZddddddde e e dd d3dZddddddde e e dd d3dZddddddde e e dd d3dZddde e e dd d2d Zddddddde e e dd d3d!Z d4d"Z!d5d#Z" d6 d7d$Z#xZ$S)8r<a An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between threads. Usage: ```python >>> client = httpx2.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. * **mounts** - *(optional)* A dictionary mapping URL patterns to transports, used to route requests through specific transports based on the URL. * **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 transportrct|||||| | ||||| | r ddl}|xr|du}|j | |}|j ||||| |||_|jD cic]+\}} t|| dn|j| ||||| |-c} }|_ | F|jj| jDcic]\}}t||c}}tt|jj|_ y#t$r tddwxYwcc} }wcc}}wNrrzuUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.)r.r/rr0r1r3r4r.r/rr0r1r3superrph2 ImportErrorr_init_transport _transportrr6_init_proxy_transport_mountsrrsorted)rmrrrrr.r/rr0r1rr2rrr3rrrr4rr:r proxy_mapr __class__s rJrpzClient.__init__ks. -'#-    &;)t*;''/@A ../ *(oo/ @ U sO}"++#,  @     LL  RXR^R^R` aYC)!; a bF4<<#5#5#789 G !S $ @ !bD -0D9D? D6c,||St||||||SNr7r&rmr.r/rr0r1r3r4s rJr<zClient._init_transports/      rLc &t|||||||SN)r.r/rr0r1r3rrFrmrr.r/rr0r1r3s rJr>zClient._init_proxy_transports&  rLc|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?rmatchesr=rmrHpatternr4s rJ_transport_for_urlzClient._transport_for_urlS #',,"4"4"6 K GYs#*3*;tJJ KrL rrrrrrrrrrrc | d}tj|td|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/clients/#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.r_ stacklevel rrHrrrrrrrrrrrwarningswarnDeprecationWarningrsendrmrrHrrrrrrrrrrrmessagers rJrzClient.requestswB  C  MM'#5! D$$!%  yyt>NyOOrLc #K|j||||||||| | |  }|j|| | d} ||jy#|jwxYwwa Alternative to `httpx2.request()` that streams the response body instead of loading it into memory at once. **Parameters**: See `httpx2.request`. See also: [Streaming Responses][0] [0]: /quickstart#streaming-responses rXT)rrrrnN)rr^r}rmrrHrrrrrrrrrrrrrs rJrnz Client.stream%s}8$$!%  99-    N NN HNN s2AA A AAr rrrrrrrrrrrrc #K|j|||||||dddt|z| | | | |  5}t|dddy#1swYyxYwwz Connect to a server-sent events endpoint and yield an `EventSource`. Iterating the `EventSource` yields `ServerSentEvent` instances. **Parameters**: See `httpx2.request`. ztext/event-streamzno-store)Acceptz Cache-ControlrSNrnrr!rmrHrrrrrrrrrrrrrs rJssez Client.sseYsu2[[  2ZPSZ[bScc-!  (h' ' ( ( (s.AA AA A max_message_size_bytes queue_sizekeepalive_ping_interval_secondskeepalive_ping_timeout_seconds subprotocolsrrrrrrrc #K ddlm}|t|||||||||| | | | | 5}|dddy#t$r tdwxYw#1swYyxYww)az Open a WebSocket session, using this client's configuration. The session is closed automatically when exiting the context manager. ```python with httpx2.Client() as client: with client.websocket("ws://localhost:8000/ws") as ws: ws.send_text("Hello!") message = ws.receive_text() ``` r ) connect_ws[WebSocket support requires the `wsproto` package. Install it with `pip install httpx2[ws]`.rkN)websockets._apirrr;r)rmrHrlrmrnrorprrrrrrrrrsessions rJ websocketzClient.websockets<  3  H #9!,K+I%-!  M!    m     s/A7AA AA  AAArnrrc|jtjk(r tdtj|_t |t r |jn|}|j||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 `httpx2.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^rc RuntimeErrorrbrrUrrr_send_handling_authread BaseExceptionr}rmrrnrrrr s rJr^z Client.sends* ;;+,, ,VW W!(( 4>?OQa4b400hx '"''6++ - ,    O  NN I sB)) C 2CC c|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_redirectsr^ StopIterationr}rr{r~appendr rmrrrr{ auth_flowr next_requestr s rJr}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.r rr) lenrrr_send_single_requestrr{has_redirect_locationrr~rrr}rmrrr{hookrr s rJrzClient._send_handling_redirects s 7|d000&'LV]^^)))4 W  009H  --j9#DN##'= 55#O66wI!XJ.#MMO,3H)#O$)2!    s9C3C C%C  C%c|j|j}tj}t |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.r NroHTTP Request: %s %s "%s %d %s")rQrHr{r|rrnr2r|rhandle_requestrrerextract_cookiesrrloggerinfor http_versionr reason_phrasermrr4rors rJrzClient._send_single_request.s++GKK8 !!#'...9`a a W - 9 //8H 9(//>:::")(//G $$X.$($:$:! , NN KK  ! !   " "  ' 9 9s !D44D=rrrrrrrc 6|jd|||||||| S)V Send a `GET` request. **Parameters**: See `httpx2.request`. rrr  rmrHrrrrrrrs rJrOz Client.getMs5"||  -!  rLc 6|jd|||||||| S)[ Send an `OPTIONS` request. **Parameters**: See `httpx2.request`. OPTIONSrr rs rJoptionszClient.optionsjs5"||  -!  rLc 6|jd|||||||| S)W Send a `HEAD` request. **Parameters**: See `httpx2.request`. rrr rs rJheadz Client.heads5"||  -!  rLc >|jd||||||||| | | |  S)W Send a `POST` request. **Parameters**: See `httpx2.request`. rrSr  rmrHrrrrrrrrrrrs rJpostz Client.postsA*||  -!  rLc >|jd||||||||| | | |  S)V Send a `PUT` request. **Parameters**: See `httpx2.request`. PUTrSr rs rJputz Client.putsA*||  -!  rLc >|jd||||||||| | | |  S)X Send a `PATCH` request. **Parameters**: See `httpx2.request`. PATCHrSr rs rJpatchz Client.patchA*||  -!  rLc 6|jd|||||||| S)Y Send a `DELETE` request. **Parameters**: See `httpx2.request`. DELETErr rs rJdeletez Client.deletes5"||  -!  rLc >|jd||||||||| | | |  S)X Send a `QUERY` request. **Parameters**: See `httpx2.request`. rrSr rs rJqueryz Client.query0rrLc|jtjk7rbtj|_|jj |j j D]}||j yyz. Close transport and proxies. N)rr^rcr=r}r?values)rmr4s rJr}z Client.closeUsd ;;+,, ,%,,DK OO ! ! #!\\002 & (OO% & -rLcv|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.) rr^rarbrcr|r= __enter__r?r)rmmsgr4s rJrzClient.__enter__as ;;+.. .""$S""%`kkCs# #!((  !!#,,. &I$##% & rLctj|_|jj ||||j j D]}||j |||yrg)r^rcrr=__exit__r?r)rmexc_type exc_value tracebackr4s rJrzClient.__exit__qs] "((    9i@,,. CI$""8Y B CrL)(rrrrrrrrr.ssl.SSLContext | str | boolr/CertTypes | Nonerrr0rr1rrr!r2z0None | typing.Mapping[str, BaseTransport | None]rr3rrr3rrrrrrrr4BaseTransport | Nonerr rr)r.rr/rrrr0rr1rr3rr4rrr$)rrr.rr/rrrr0rr1rr3rrr$)rHr4rr$rrrHrrr$rr%rr&rr'rrrrrrrr*rbool | UseClientDefaultrr(rr)rr )rrrHrrr$rr%rr&rr'rrrrrrrr*rrrr(rr)rzGenerator[Response])rHrrrrr$rr%rr&rr'rrrrrrrr*rrrr(rr)rzGenerator[EventSource])rHrrlrrmrrn float | Nonerorrplist[str] | Nonerrrrrrrr*rrrr(rr)rzGenerator[WebSocketSession] rrrnrrr*rrrr rrrr rrr{list[Response]rr rrrrr{rrr rrrr rHrrrrrrrrr*rrrr(rr)rr rHrrrrrrrrAuthTypes | UseClientDefaultrrrr(rr)rr rHrrr$rr%rr&rr'rrrrrrrrrrrr(rr)rr r)rmr=rr=NNNrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonerr)%rVrWrXrYrrrrpr<r>rQr:rrrnrjrrrrrvr^r}rrrOrrrrrrrr}rr __classcell__rBs@rJr<r<<su ,b"&)-&*&*.2!%#'EI 6!&'2EI *.GN+K:K:' K: $ K: $ K:,K:K:K:K:K:!K:CK:K:K: !K:"#K:$C%K:&'K:(()K:*E+K:, -K:^/3!%'*. +         (   2/3!%'  ,           (  *.#'%)"&)-&*&*4F4F3E/36P6P6P ' 6P ! 6P#6P 6P'6P$6P$6P26P26P16P-6P !6Pp *.#'%)"&)-&*&*4F4F3E/3111 ' 1 ! 1#1 1'1$1$1212111-1 !11f )-#'%)"&)-&*&*4F4F3E/3'( '( '( ' '( ! '(#'( '(''($'($'(2'(2'(1'(-'( !'('(R 'E,8_7])-)-&*&*4F4F3E/34 4!$ 4  4 *6 4)54'4'4$4$4242414-4 %!44t4F4F -- - 2 - 2 - -^        D!!! !  !FF*.&*&*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 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # J &$04*.*. C, C( C( C  CrLc^eZdZdZddddddddddedeedddddd d%fdZdddddedf d&d Zdddddef d'd Z d(d Z ddddddde e e dd d)d Z e ddddddde e e dd d*dZe dddddddde e e dd d+dZe eeeedddde e e dd d,dZde e d d-dZ d.dZ d/dZd0dZddde e e dd d1dZddde e e dd d2dZddde e e dd d2dZddddddde e e dd d3dZddddddde e e dd d3dZddddddde e e dd d3dZddde e e dd d2d Zddddddde e e dd d3d!Z d4d"Z!d5d#Z" d6 d7d$Z#xZ$S)8r;a< An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. Usage: ```python >>> async with httpx2.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. * **mounts** - *(optional)* A dictionary mapping URL patterns to transports, used to route requests through specific transports based on the URL. * **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)rrrrr.r/r0r1rr2rrr3rrrr4rrct|||||| | ||||| |r ddl}|xr|du}|j | |}|j |||||| ||_|jD cic]+\}} t|| dn|j| |||||| -c} }|_ | F|jj| jDcic]\}}t||c}}tt|jj|_ y#t$r tddwxYwcc} }wcc}}wr6r8)rmrrrrr.r/r0r1rr2rrr3rrrr4rrr:rrArrBs rJrpzAsyncClient.__init__s. -'#-    &;)t*;''/@A ../ ,(oo/ E U sO}"++#,  E     LL  RXR^R^R` aYC)!; a bF4<<#5#5#789 G !S & E !brCc,||St||||||SrEr%rGs rJr<zAsyncClient._init_transports/   !   rLc &t|||||||SrIrrJs rJr>z!AsyncClient._init_proxy_transports&"  rLc|jjD]*\}}|j|s||jcS|cS|jSrLrMrOs rJrQzAsyncClient._transport_for_url&rRrLrSc K| d}tj|td|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/clients/#merging-of-configuration NrUr_rVrXrYrZr_s rJrzAsyncClient.request1sD  C  MM'#5! D$$!%  YYwTDTYUUUUsAAAAc K|j||||||||| | |  }|j|| | dd{} ||jd{y7#7#|jd{7wxYwwrb)rr^rrcs rJrnzAsyncClient.streamjs8$$!%  - #    $N//# # #  $(//# # #sD5A=AA=AA=AA=A=A:3A64A::A=rrdc K|j|||||||dddt|z| | | | |  4d{}t|dddd{y7#7#1d{7swYyxYwwrfrhris rJrjzAsyncClient.sses2;;  2ZPSZ[bScc-!  ( (h' ' ( ( ( ( ( ( (sD2A1AA1A A1AA1A1A."A% #A.*A1rkc K ddlm}|t|||||||||| | | | | 4d{}|dddd{y#t$r tdwxYw727#1d{7swYyxYww)a Open a WebSocket session, using this client's configuration. The session is closed automatically when exiting the context manager. ```python async with httpx2.AsyncClient() as client: async with client.websocket("ws://localhost:8000/ws") as ws: await ws.send_text("Hello!") message = await ws.receive_text() ``` r ) aconnect_wsrsrkN)rtrr;r)rmrHrlrmrnrorprrrrrrrrrus rJrvzAsyncClient.websockets<  4  H #9!,K+I%-!   M!     m        sYA9A#A9A A9A$ A9A"A9AA9"A9$A6*A- +A62A9rwcK|jtjk(r tdtj|_t |t r |jn|}|j||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 `httpx2.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances ryrzN)rr^rcr|rbrrUrrrr}areadrrrs rJr^zAsyncClient.sends* ;;+,, ,VW W!(( 4>?OQa4b400hx '"''611 - 2    nn&&&O ' //# # #I sTBC+B;C+B?4B=5B?:C+=B?? C(C#CC##C((C+c>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{7wxYwwr) async_auth_flow __anext__rasendStopAsyncIterationrrr{rrrrs rJr}zAsyncClient._send_handling_auth.s((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}~wwxYwwr) rrrrrrr{rrrrrrrs rJrz$AsyncClient._send_handling_redirectsPs3 7|d000&'LV]^^)))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}tj}t |j t s tdt|5|j|d{}dddt j t sJ||_ t|j ||_|jj||j|_t j#d|j$|j|j&|j(|j*|S7#1swYxYww)rz>Attempted to send a sync request with an AsyncClient instance.r Nrr)rQrHr{r|rrnr'r|rhandle_async_requestrrrrrrrrrrrrrs rJrz AsyncClient._send_single_requestts ++GKK8 !!#'../:_` ` W - E&;;GDDH E(//?;;;"*8??%H $$X.$($:$:! , NN KK  ! !   " "  #E E Es1A!E #E8D>9E=CE >EE E rc RK|jd|||||||| d{S7w)rrrNr rs rJrOzAsyncClient.getsC"\\  -!"    '%'c RK|jd|||||||| d{S7w)rrrNr rs rJrzAsyncClient.optionssC"\\  -!"    rc RK|jd|||||||| d{S7w)rrrNr rs rJrzAsyncClient.headsC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrSNr rs rJrzAsyncClient.postsO*\\  -!"    "+)+c ZK|jd||||||||| | | |  d{S7w)rrrSNr rs rJrzAsyncClient.putsO*\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrSNr rs rJrzAsyncClient.patch3O*\\  -!"    rc RK|jd|||||||| d{S7w)rrrNr rs rJrzAsyncClient.deleteXsC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrSNr rs rJrzAsyncClient.queryurrc2K|jtjk7rrtj|_|jj d{|j j D]}||j d{yy7@7 wr)rr^rcr=rr?r)rmrs rJrzAsyncClient.acloses~ ;;+,, ,%,,DK//((* * *,,. )$,,.(( ) - +)s*ABB#B7B B BBcK|jtjk7r:tjdtjdi|j}t |tj|_|j jd{|jjD]}||jd{|S7@7 wr) rr^rarbrcr|r= __aenter__r?r)rmrrs rJrzAsyncClient.__aenter__s ;;+.. .""$S""%`kkCs# #!(( oo((***\\((* )E &&((( ) +)s*B C C  #C1CC CCcKtj|_|jj |||d{|j j D] }||j |||d{"y7B7 wrg)r^rcrr= __aexit__r?r)rmrrrrs rJrzAsyncClient.__aexit__sx "(( oo'')YGGG\\((* FE ooh 9EEE F HFs'6A?A;#A?A?3A=4A?=A?)(rrrrrrrrr.rr/rr0rr1rrr!r2z5None | typing.Mapping[str, AsyncBaseTransport | None]rr3rrr3rrrrrrrr4AsyncBaseTransport | Nonerrrr rr)r.rr/rrrr0rr1rr3rr4rrr#)rrr.rr/rrrr0rr1rr3rrr#)rHr4rr#r)rrrHrrr$rr%rr&rr'rrrrrrrr*rrrr(rr)rzAsyncGenerator[Response])rHrrrrr$rr%rr&rr'rrrrrrrr*rrrr(rr)rzAsyncGenerator[EventSource])rHrrlrrmrrnrrorrprrrrrrrrr*rrrr(rr)rz%AsyncGenerator[AsyncWebSocketSession]rrrrrrrr)rmr?rr?rr)%rVrWrXrYrrrrpr<r>rQr:rrrnrjrrrrrvr^r}rrrOrrrrrrrrrrrrs@rJr;r;su -d"&)-&*&*.2!%#'JN 6!&'2EI /3GN+K:K:' K: $ K: $ K:,K:K:K:K:!K:HK:K:K:K: !K:"C#K:$%K:&-'K:()K:*E+K:, -K:^/3!%'/3 +         -   2/3!%'  ,           (  *.#'%)"&)-&*&*4F4F3E/37V7V7V ' 7V ! 7V#7V 7V'7V$7V$7V27V27V17V-7V !7Vr *.#'%)"&)-&*&*4F4F3E/31$1$1$ ' 1$ ! 1$#1$ 1$'1$$1$$1$21$21$11$-1$ "!1$1$f )-#'%)"&)-&*&*4F4F3E/3'( '( '( ' '( ! '(#'( '(''($'($'(2'(2'(1'(-'( %!'('(R 'E,8_7])-)-&*&*4F4F3E/34 4!$ 4  4 *6 4)54'4'4$4$4242414-4 /!44t4F4F -- - 2 - 2 - -^ % % % %  %  %D""" "  "HD*.&*&*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 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # J )$04*.*. F, F( F( F  FrL)rHr4rIr4rr)rHr4rz int | None)rHr4rRr4rr)h __future__rryenumloggingr{typingr[collections.abcrr contextlibrrtypesrr rr r r _configrrrrrrrrrr _decodersr _exceptionsrrrr_modelsrrrr _sser! _status_codesr"_transports.baser#r$_transports.defaultr%r&_typesr'r(r)r*r+r,r-r.r/r0r1r2r3_urlsr4r5_utilsr6r7 TYPE_CHECKINGsslrtr8r9__all__TypeVarr=r?rKrGrSrUr: getLoggerrrr keysrEnumr^rerCallableAny EventHookrr<r;)rs0rJrs"  5:$00   * 98 ?B$7 H 9FNN3h'FNN3m, 6 v(&'   8 $k] + )),C,>,C,C,E[SPZIZS[\ $)) n($$* OOCO , @W@WF @ CZ@ CFB F*B FG(\s  G&G