Oj&ddlmZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z m Z ddlmZddlmZddlmZmZmZdd lmZmZmZmZmZmZmZmZmZmZm Z dd 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/m0Z0ddl1m2Z2m3Z3ddl4m5Z5m6Z6ddl7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZImJZJejr ddlLZLddlMmNZNmOZOgdZPejddZRejddZSd-dZTGddZUeUZVejdZXdeZYd je"jDcgc] }|d!k7s | c}Z\Gd"d#ejZ^Gd$d%eCZ_Gd&d'e8Z`ejd(ejfZcGd)d*ZdGd+dedZeGd,dedZfycc}w).) annotationsN)AsyncGenerator Generator)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth) 'DEFAULT_KEEPALIVE_PING_INTERVAL_SECONDS&DEFAULT_KEEPALIVE_PING_TIMEOUT_SECONDSDEFAULT_LIMITSDEFAULT_MAX_EVENT_SIZE_BYTESDEFAULT_MAX_MESSAGE_SIZE_BYTESDEFAULT_MAX_REDIRECTSDEFAULT_QUEUE_SIZEDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse) EventSource)codes)AsyncHTTPTransport HTTPTransport)AsyncBaseTransport BaseTransport) AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypes)URL QueryParams) URLPatternget_environment_proxies)AsyncWebSocketSessionWebSocketSession)USE_CLIENT_DEFAULT AsyncClientClientTr=)boundUr<c|j}|j}|j|jk(xrB|jdk(xr1|jdk(xr |jdk(xr|jdk(S)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' httpPhttpsi)originhostschemeport)urllocationrElocation_origins e/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/httpx2/_client.py_is_https_redirectrMGs{ZZFooO  +++ ( MMV # ( KK2  (  " "g - (  C ' ceZdZdZy)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__rNrLrPrPWsrNrPhttpx2zpython-httpx2/z, identityceZdZdZdZdZy) ClientStater N)rQrRrSUNOPENEDOPENEDCLOSEDrUrNrLrYrYtsHFFrNrYc(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 rL__init__zBoundSyncStream.__init__  26 rNc#8K|jEd{y7wrb)rdrhs rL__iter__zBoundSyncStream.__iter__s<<s ctjtj|jz |_|j jyN)seconds)datetime timedeltatime perf_counterrerfrdcloserns rLrwzBoundSyncStream.closes6))$2C2C2E 2ST  rNN)rir3rjfloatreturnNone)ryztyping.Iterator[bytes]ryrz)rQrRrSrTrkrorwrUrNrLr`r`s 7  rNr`c(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|_yrbrcrgs rLrkzBoundAsyncStream.__init__rlrNcK|jj} |23d{}|7 6 t|tr|j d{7yy#t|tr|j d{7wwxYwwrb)rd __aiter__ isinstanceraclose)rhrichunks rLrzBoundAsyncStream.__aiter__sw'') &%  e  v&.1mmo%%2z&.1mmo%%2sMB A1/1A1A#B AB $B BB  B cKtjtj|jz |_|j jd{y7wrq)rsrtrurvrerfrdrrns rLrzBoundAsyncStream.acloses@))$2C2C2E 2ST ll!!###sAA"A A"N)rir(rjrxryrz)ryztyping.AsyncIterator[bytes]r{)rQrRrSrTrkrrrUrNrLr}r}s 7 &$rNr}.c eZdZddddededdddd d(dZed)dZed)d Zd*d Z d+d Z ed,d Z e jd-d Z ed.dZ e jd/dZ ed0dZejd1dZed2dZejd3dZed4dZejd5dZed6dZejd7dZed8dZejd9dZdddddddedd d:dZd;dZddZd|r:tjDcic]\}}||dn t|c}}SiSt|tt fr t|n|}d|iScc}}w)N)rIzall://)r8itemsrrstrr5)rhproxyallow_env_proxieskeyrIs rL_get_proxy_mapzBaseClient._get_proxy_mapsi = UlUnUtUtUvwcS[TenDwwI(253*(EEe$5Ee$ $ xsA)c|jSrb)rrns rLrzBaseClient.timeouts }}rNc$t||_yrb)rr)rhrs rLrzBaseClient.timeout( rNc|jSrb)rrns rLrzBaseClient.event_hookss   rNc|t|jdgt|jdgd|_yr)rrr)rhrs rLrzBaseClient.event_hookss4KOOIr:;[__Z<= rNc|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: quickstart.md#authentication )rrns rLrzBaseClient.authszzrNc0|j||_yrb)rrrhrs rLrzBaseClient.auth s%%d+ rNc|jS)zK Base URL to use when sending requests with relative URLs. )rrns rLrzBaseClient.base_urls ~~rNcB|jt||_yrb)rr5rrs rLrzBaseClient.base_urls55c#h?rNc|jS)z@ HTTP headers to include when sending requests. )_headersrns rLrzBaseClient.headers }}rNctdtjddtjdd}|j |||_y)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rhrclient_headerss rLrzBaseClient.headers#sJ !$3$:$:7$C,)009    g&& rNc|jS)zA Cookie values to include when sending requests. )rrns rLrzBaseClient.cookies0rrNc$t||_yrb)rr)rhrs rLrzBaseClient.cookies7rrNc|jS)zO Query parameters to include in the URL when sending requests. )rrns rLrzBaseClient.params;s ||rNc$t||_yrb)r6r)rhrs rLrzBaseClient.paramsBs"6* rN) contentdatafilesjsonrrrr extensionsc P|j|}|j|}|j| } |j|}| in| } d| vrDt | t r |j n t| } tdi| d| ji} t||||||||| |  S)aS 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.md#request-instances r)rrrrrrrrrU) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrPrrdictas_dictr ) rhmethodrIrrrrrrrrrs rL build_requestzBaseClient.build_requestFs4ooc"%%g.%%g.((0%-R: J &&0:J&KdllQXY`QaGF FGOO4EFJ  !  rNct|}|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)r5is_relative_urlrrlstripr)rhrI merge_urlmerge_raw_paths rLrzBaseClient._merge_urlus\ H  $ $"]]33i6H6H6O6OPT6UUN==**N*C CrNcr|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)rhrmerged_cookiess rLrzBaseClient._merge_cookiess4 dll$T\\2N  ! !' *! !rNcRt|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)rhrmerged_headerss rLrzBaseClient._merge_headerss& !.g&rNcn|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. )rr6merge)rhrmerged_queryparamss rLrzBaseClient._merge_queryparamss2 T[[!,T[[!9 %++F3 3 rNc|yt|trt|d|dSt|tr|St |r t |St d|)Nrr usernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rLrzBaseClient._build_auths] < e $d1gQ@ @ d #K d^T* *7x@A ArNct|tr |jn|j|}||S|jj |jj }}|s|r t||StS)Nr) rrPrrrIrrr r )rhrrrrs rL_build_request_authzBaseClient._build_request_authsf (.>?tzzTEUEUVZE[  K$[[117;;3G3G( xhB Bv rNc|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. )rrIrrrir)_redirect_method _redirect_url_redirect_headers_redirect_streamrrr r)rhrrrrIrrirs rL_build_redirect_requestz"BaseClient._build_redirect_requests &&w9  (3((#v>&&w7$,,'))   rNc|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)rhrrrs rLrzBaseClient._redirect_methodsu    5?? 2v7GF   5;; .6AR3RF   5#:#: :v?OF rNc|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)rF)fragment) rr5rrrGrFrrIrjoinr)rhrrrJrIexcs rLrzBaseClient._redirect_urls##J/ lh-C ::chh--W[[%5%5-6C   ++""3'C ;;   --)=)=->C # l%(HQ&OY`agk k ls C C+C&&C+ct|j}|j|jjk7rFt |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) rrrErIrMpopnetlocdecoder)rhrrIrrs rLrzBaseClient._redirect_headers s'//* ::++ +%gkk37 OT2"jj//8GFO W^^ #% KK($ / KK+T 2  Hd#rNcD||jk7r|dk(ry|jS)zO Return the body that should be used for the redirect request. rN)rri)rhrrs rLrzBaseClient._redirect_stream's# W^^ #%~~rNcd|jvrht|jtr |jnt |j}t di|jd|j i|_yy)NrrU)rrrrPrrr)rhrrs rL _set_timeoutzBaseClient._set_timeout0s] G.. .&0?O&PdllV]^b^j^jVkG!%!V(:(:!VGOODU!VG  /rN)rAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr4rboolrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrrr*str | typing.Callable[[bytes], str | None]ryrz)ryr)rIr5ryr5)rProxyTypes | Nonerrryzdict[str, Proxy | None])ryr)rr4ryrz)rydict[str, list[EventHook]])rrryrz)ry Auth | None)rr)ryrz)ryr5)rIrryrz)ryr)rr,ryrz)ryr)rr+ryrz)ryr6)rr.ryrz)rrrIrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NonerrrrrrrTimeoutTypes | UseClientDefaultrRequestExtensions | Noneryr )rIrryr5rb)rrryr)rrryr)rrryr)rrryr)rr r#AuthTypes | UseClientDefault | Noneryr )rr rr!ryr )rr rr!ryr)rr rr!ryr5)rr rIr5rrryr)rr rrryz'SyncByteStream | AsyncByteStream | None)rr ryrz)!rQrRrSrrrkpropertyrrrrrsetterrrrrrrr;rrrrrrrrrrrrrrUrNrLrrs"&)-&*&* 6!&2EI GN + +' + $ + $ + + + +C + + +E +  +D11 ; % ^^))!!   [[,, __@@  ^^ ' '  ^^))  ]]++*.#'%)"&)-&*&*3E/3- - - ' - ! - #-  - '- $- $- 1- --  - ^,  B5G2    &266WrNrcdeZdZdZdddddddddddedeeddddd 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 ded 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 Z ddddddde 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*rr+r,r.r/r)r*rr+r,r.superrkh2 ImportErrorr_init_transport _transportrr7_init_proxy_transport_mountsrrsorted)rhrrrrr)r*rr+r,rr-rrr.rrrr/rr5r proxy_mapr __class__s rLrkzClient.__init__es. -'#-    &;)t*;''/@A ../ *(oo/ @ U sO}"++#,  @     LL  RXR^R^R` aYC)!; a bF4<<#5#5#789 G !S $ @ !bD -0D9D? D6c,||St||||||SNr2r%rhr)r*rr+r,r.r/s rLr7zClient._init_transports/      rNc &t|||||||SN)r)r*rr+r,r.rrArhrr)r*rr+r,r.s rLr9zClient._init_proxy_transports&  rNc|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:rmatchesr8rhrIpatternr/s rL_transport_for_urlzClient._transport_for_urlS #',,"4"4"6 K GYs#*3*;tJJ KrN 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.md#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.rZ stacklevel rrIrrrrrrrrrrrwarningswarnDeprecationWarningrsendrhrrIrrrrrrrrrrrmessagers rLrzClient.requestswB  C  MM'#5! D$$!%  yyt>NyOOrNc #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.md#streaming-responses rST)rrrriN)rrYrwrhrrIrrrrrrrrrrrrrs rLriz Client.streams}8$$!%  99-    N NN HNN s2AA A AAr rrrrrrrrrrrrmax_event_sizec #K|j|||||||dddt|z| | | | |  5}t||dddy#1swYyxYww) Connect to a server-sent events endpoint and yield an `EventSource`. Iterating the `EventSource` yields `ServerSentEvent` instances. **Parameters**: See `httpx2.request`. text/event-streamno-storeAcceptz Cache-ControlrNr`Nrirr"rhrIrrrrrrrrrrrrr`rs rLssez Client.sseSs{4[[  2ZPSZ[bScc-!  Gh~F F G G Gs.AA  A AA 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._apirrr6r)rhrIrlrmrnrorprrrrrrrrrsessions rL websocketzClient.websocket~s<  3  H #9!,K+I%-!  M!    m     s/A7AA AA  AAArirrc|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.md#request-instances 5Cannot send a request, as the client has been closed.rrhistoryN)rrYr^ RuntimeErrorr]rrPrrr_send_handling_authread BaseExceptionrwrhrrirrrrs rLrYz 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_redirectsrY StopIterationrwrr{r~appendr rhrrrr{ auth_flowr next_requestrs rLr}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~rrrwrhrrr{hookrrs rLrzClient._send_handling_redirectss 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.rNrjHTTP Request: %s %s "%s %d %s")rLrIrurvrrir3r|rhandle_requestrr`rextract_cookiesrrloggerinfor http_versionr reason_phraserhrr/rjrs rLrzClient._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 rhrIrrrrrrrs rLrz Client.getHs5"||  -!  rNc 6|jd|||||||| S)[ Send an `OPTIONS` request. **Parameters**: See `httpx2.request`. OPTIONSrrrs rLoptionszClient.optionses5"||  -!  rNc 6|jd|||||||| S)W Send a `HEAD` request. **Parameters**: See `httpx2.request`. rrrrs rLheadz Client.heads5"||  -!  rNc >|jd||||||||| | | |  S)W Send a `POST` request. **Parameters**: See `httpx2.request`. rrNr rhrIrrrrrrrrrrrs rLpostz Client.postsA*||  -!  rNc >|jd||||||||| | | |  S)V Send a `PUT` request. **Parameters**: See `httpx2.request`. PUTrNrrs rLputz Client.putsA*||  -!  rNc >|jd||||||||| | | |  S)X Send a `PATCH` request. **Parameters**: See `httpx2.request`. PATCHrNrrs rLpatchz Client.patchA*||  -!  rNc 6|jd|||||||| S)Y Send a `DELETE` request. **Parameters**: See `httpx2.request`. DELETErrrs rLdeletez Client.deletes5"||  -!  rNc >|jd||||||||| | | |  S)X Send a `QUERY` request. **Parameters**: See `httpx2.request`. rrNrrs rLqueryz Client.query+rrNc|jtjk7rbtj|_|jj |j j D]}||j yyz. Close transport and proxies. N)rrYr^r8rwr:values)rhr/s rLrwz Client.closePsd ;;+,, ,%,,DK OO ! ! #!\\002 & (OO% & -rNcv|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.) rrYr\r]r^r|r8 __enter__r:r)rhmsgr/s rLrzClient.__enter__\s ;;+.. .""$S""%`kkCs# #!((  !!#,,. &I$##% & rNctj|_|jj ||||j j D]}||j |||yrb)rYr^rr8__exit__r:r)rhexc_type exc_value tracebackr/s rLrzClient.__exit__ls] "((    9i@,,. CI$""8Y B CrN)(rrrrrrrrr)ssl.SSLContext | str | boolr*CertTypes | Nonerrr+rr,rrrr-z0None | typing.Mapping[str, BaseTransport | None]rr4rrr.rrrrrrrr/BaseTransport | Nonerrryrz)r)rr*rrrr+rr,rr.rr/rryr')rrr)rr*rrrr+rr,rr.rryr')rIr5ryr'rrrIrrrrr rr!rr"rrrrrrrr%rbool | UseClientDefaultrr#rr$ryr!)rrrIrrrrr rr!rr"rrrrrrrr%rrrr#rr$ryzGenerator[Response])rIrrrrrrr rr!rr"rrrrrrrr%rrrr#rr$r` int | NoneryzGenerator[EventSource])rIrrlrrmrrn float | Nonerorrplist[str] | Nonerrrrrrrr%rrrr#rr$ryzGenerator[WebSocketSession] rr rirrr%rrryr! rr rr rrr{list[Response]ryr!rr rrr{rryr!rr ryr!rIrrrrrrrrr%rrrr#rr$ryr!rIrrrrrrrrAuthTypes | UseClientDefaultrrrr#rr$ryr!rIrrrrr rr!rr"rrrrrrrrrrrr#rr$ryr!r{)rhr>ryr>NNNrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Noneryrz)&rQrRrSrTrrrrkr7r9rLr;rrrirrjrrrrrvrYr}rrrrrrrrrrrwrr __classcell__r=s@rLr=r=6s ,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%A!(G (G (G ' (G ! (G#(G (G'(G$(G$(G2(G2(G1(G-(G #!(G" #(G(GT '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  CrNcdeZdZdZddddddddddedeedddddd 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 ded 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 Z ddddddde 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*r+r,rr-rrr.rrrr/rrct|||||| | ||||| |r ddl}|xr|du}|j | |}|j |||||| ||_|jD cic]+\}} t|| dn|j| |||||| -c} }|_ | F|jj| jDcic]\}}t||c}}tt|jj|_ y#t$r tddwxYwcc} }wcc}}wr1r3)rhrrrrr)r*r+r,rr-rrr.rrrr/rrr5rr<rr=s rLrkzAsyncClient.__init__s. -'#-    &;)t*;''/@A ../ ,(oo/ E U sO}"++#,  E     LL  RXR^R^R` aYC)!; a bF4<<#5#5#789 G !S & E !br>c,||St||||||Sr@r$rBs rLr7zAsyncClient._init_transports/   !   rNc &t|||||||SrDrrEs rLr9z!AsyncClient._init_proxy_transport s&"  rNc|jjD]*\}}|j|s||jcS|cS|jSrGrHrJs rLrLzAsyncClient._transport_for_url!rMrNrNc 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.md#merging-of-configuration NrPrZrQrSrTrUrZs rLrzAsyncClient.request,sD  C  MM'#5! D$$!%  YYwTDTYUUUUsAAAAc K|j||||||||| | |  }|j|| | dd{} ||jd{y7#7#|jd{7wxYwwr])rrYrr^s rLrizAsyncClient.streames8$$!%  - #    $N//# # #  $(//# # #sD5A=AA=AA=AA=A=A:3A64A::A=rr_c K|j|||||||dddt|z| | | | |  4d{}t||dddd{y7%7#1d{7swYyxYww)rbrcrdrerNNrgrhris rLrjzAsyncClient.sses4;;  2ZPSZ[bScc-!  G Gh~F F G G G G G G GsD2A3AA3A A3AA3A3A0$A' %A0,A3rkc 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)rtrr6r)rhrIrlrmrnrorprrrrrrrrrus rLrvzAsyncClient.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.md#request-instances ryrzN)rrYr^r|r]rrPrrrr}areadrrrs rLrYzAsyncClient.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 rLr}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 rLrz$AsyncClient._send_handling_redirectsLs3 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.rNrr)rLrIrurvrrir(r|rhandle_async_requestrr}rrrrrrrrrrrs rLrz AsyncClient._send_single_requestps ++GKK8 !!#'../:_` ` W - E&;;GDDH E(//?;;;"*8??%H $$X.$($:$:! , NN KK  ! !   " "  #E E Es1A!E #E8D>9E=CE >EE E rc RK|jd|||||||| d{S7w)rrrNrrs rLrzAsyncClient.getsC"\\  -!"    '%'c RK|jd|||||||| d{S7w)rrrNrrs rLrzAsyncClient.optionssC"\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rLrzAsyncClient.headsC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrNNrrs rLrzAsyncClient.postsO*\\  -!"    "+)+c ZK|jd||||||||| | | |  d{S7w)rrrNNrrs rLrzAsyncClient.put sO*\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrNNrrs rLrzAsyncClient.patch/O*\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rLrzAsyncClient.deleteTsC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrNNrrs rLrzAsyncClient.queryqrrc2K|jtjk7rrtj|_|jj d{|j j D]}||j d{yy7@7 wr)rrYr^r8rr:r)rhrs rLrzAsyncClient.acloses~ ;;+,, ,%,,DK//((* * *,,. )$,,.(( ) - +)s*ABB#B7B B BBcK|jtjk7r:tjdtjdi|j}t |tj|_|j jd{|jjD]}||jd{|S7@7 wr) rrYr\r]r^r|r8 __aenter__r:r)rhrrs rLrzAsyncClient.__aenter__s ;;+.. .""$S""%`kkCs# #!(( oo((***\\((* )E &&((( ) +)s*B C C  #C1CC CCcKtj|_|jj |||d{|j j D] }||j |||d{"y7B7 wrb)rYr^rr8 __aexit__r:r)rhrrrrs rLrzAsyncClient.__aexit__sx "(( oo'')YGGG\\((* FE ooh 9EEE F HFs'6A?A;#A?A?3A=4A?=A?)(rrrrrrrrr)rr*rr+rr,rrrr-z5None | typing.Mapping[str, AsyncBaseTransport | None]rr4rrr.rrrrrrrr/AsyncBaseTransport | Nonerrrrryrz)r)rr*rrrr+rr,rr.rr/rryr&)rrr)rr*rrrr+rr,rr.rryr&)rIr5ryr&r)rrrIrrrrr rr!rr"rrrrrrrr%rrrr#rr$ryzAsyncGenerator[Response])rIrrrrrrr rr!rr"rrrrrrrr%rrrr#rr$r`rryzAsyncGenerator[EventSource])rIrrlrrmrrnrrorrprrrrrrrrr%rrrr#rr$ryz%AsyncGenerator[AsyncWebSocketSession]rrrrrrrr{)rhr@ryr@rr)&rQrRrSrTrrrrkr7r9rLr;rrrirrjrrrrrvrYr}rrrrrrrrrrrrrrrs@rLr<r<zs -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%A!(G (G (G ' (G ! (G#(G (G'(G$(G$(G2(G2(G1(G-(G #!(G" %#(G(GT '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  FrN)rIr5rJr5ryr)g __future__rrsenumloggingrutypingrVcollections.abcrr contextlibrrtypesrr rr r r _configrrrrrrrrrrr _decodersr _exceptionsrrrr_modelsrrr r!_sser" _status_codesr# _transportsr$r%_transports.baser&r'_typesr(r)r*r+r,r-r.r/r0r1r2r3r4_urlsr5r6_utilsr7r8 TYPE_CHECKINGsslrtr9r:__all__TypeVarr>r@rMrPr; getLoggerrrrkeysrEnumrYr`r}CallableAny EventHookrr=r<)rs0rLrs"  5:$00    * 98 :?$7 H 9FNN3h'FNN3m,  (&'   8 $k] + )),C,>,C,C,E[SPZIZS[\ $)) n($$4 OOCO , @W@WF A CZA CHC F*C FS(\s  G G