jE/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@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZImJZJejKr ddlLZLddlMmNZNmOZOgdZPejQddZRejQddZSd2d ZTGd!d"ZUeUZVejWd#ZXd$eZYd%Zd&e"j[DZ\Gd'd(ej]Z^Gd)d*eCZ_Gd+d,e8Z`ejad-ejbfZcGd.d/ZdGd0dedZeGd1dedZfdS)3) 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<urlr5locationreturnboolc|j}|j}|j|jko+|jdko |jdko|jdko |jdkS)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' httpPhttpsi)originhostschemeport)rArBrIlocation_origins r]qs#[[[SPZIZIZSIZIZIZrPceZdZdZdZdZdS) ClientStater N)rSrTrUUNOPENEDOPENEDCLOSEDrWrPrNr_r_ts#HFFFFrPr_c*eZdZdZd dZdd Zdd Zd S)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`. streamr3startfloatrCNonec0||_||_d|_dSN_stream_startelapsedselfrgrhs rN__init__zBoundSyncStream.__init__  26 rPtyping.Iterator[bytes]c#$K|jEd{VdSrl)rnrrs rN__iter__zBoundSyncStream.__iter__s&<rPctjtj|jz |_|jdSN)seconds)datetime timedeltatime perf_counterrorprncloserws rNrzBoundSyncStream.closesA)$2C2E2E 2STTT  rPN)rgr3rhrirCrj)rCrurCrj)rSrTrUrVrsrxrrWrPrNrfrfsZ 7777     rPrfc*eZdZdZd dZdd Zdd Zd S)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`. rgr(rhrirCrjc0||_||_d|_dSrlrmrqs rNrszBoundAsyncStream.__init__rtrPtyping.AsyncIterator[bytes]c,K|j} |23d{V}|WV 6 t|tr|d{VdSdS#t|tr|d{VwwxYwrl)rn __aiter__ isinstanceraclose)rrrgchunks rNrzBoundAsyncStream.__aiter__s'')) &%       e  &v&.11 &mmoo%%%%%%%%% & &z&.11 &mmoo%%%%%%%% &sA!,A!!2BcKtjtj|jz |_|jd{VdSrz)r|r}r~rrorprnrrws rNrzBoundAsyncStream.aclosesW)$2C2E2E 2STTT l!!###########rPN)rgr(rhrirCrj)rCrr)rSrTrUrVrsrrrWrPrNrrsZ 7777 &&&&$$$$$$rPr.c eZdZddddededdddd dcdZedddZeddd Zded#Z dfd(Z edgd*Z e j dhd+Z edid-Z e j djd.Z edkd0Zej dld2Zedmd3Zej dnd4Zedod6Zej dpd8Zedqd:Zej drd<Zedsd>Zej dtd@ZdddddddeddA dudPZdvdQZdwdxdRZdwdydSZdwdzdTZd{dUZefd|dYZd}d\Zd~d]Zdd^Zdd_ZddaZddbZ dS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr4rrDrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrr*str | typing.Callable[[bytes], str | None]rCrjc &|in|}|t| |_|||_t ||_t||_t||_ t||_ ||_ ||_t|dgt|dgd|_| |_| |_t(j|_dSNrequestresponse)rr)_enforce_trailing_slashr5 _base_url _build_auth_authr6_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingr_rb_state) rrrrrrrrrrrrrs rNrszBaseClient.__init__s(/bb[ 55c(mmDD%%d++ "6** w'' (( (( 0*KOOIr::;;[__Z<<==  $!1!* rPc,|jtjkS)z2 Check if the client being closed )rr_rdrws rN is_closedzBaseClient.is_closeds {k000rPc|jSrl)rrws rNrzBaseClient.trust_envs rPrAr5cv|jdr|S||jdzS)N/raw_path)rendswith copy_withrrrAs rNrz"BaseClient._enforce_trailing_slashs: <  & & J}}clT&9}:::rPproxyProxyTypes | Noneallow_env_proxiesdict[str, Proxy | None]c|.|r*dtDSiSt|ttfrt |n|}d|iS)Nc>i|]\}}||dnt|S)NrA)r)r[r\rAs rN z-BaseClient._get_proxy_map..s.wwwcS[TTennnwwwrPrzall://)r8itemsrstrr5r)rrrrs rN_get_proxy_mapzBaseClient._get_proxy_mapso =  xwwUlUnUnUtUtUvUvwwwwI(253*(E(EPEe$$$$5Ee$ $rPrc|jSrl)rrws rNrzBaseClient.timeouts }rPc.t||_dSrl)rr)rrrs rNrzBaseClient.timeout(( rPdict[str, list[EventHook]]c|jSrl)rrws rNrzBaseClient.event_hookss   rPct|dgt|dgd|_dSr)rrr)rrrs rNrzBaseClient.event_hookssKKOOIr::;;[__Z<<==  rP Auth | Nonec|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrws rNrzBaseClient.auths zrPr)c:|||_dSrl)rrrrrs rNrzBaseClient.auth s%%d++ rPc|jS)zK Base URL to use when sending requests with relative URLs. )rrws rNrzBaseClient.base_urls ~rPcT|t||_dSrl)rr5rrs rNrzBaseClient.base_urls!55c#hh??rPrc|jS)z@ HTTP headers to include when sending requests. )_headersrws rNrzBaseClient.headers }rPr,ctdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rrrclient_headerss rNrzBaseClient.headers#sd !$3$:$:7$C$C,)0099      g&&&& rPrc|jS)zA Cookie values to include when sending requests. )rrws rNrzBaseClient.cookies0rrPr+c.t||_dSrl)rr)rrrs rNrzBaseClient.cookies7rrPr6c|jS)zO Query parameters to include in the URL when sending requests. )rrws rNrzBaseClient.params;s |rPr.c.t||_dSrl)r6r)rrrs rNrzBaseClient.paramsBs"6** rP) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Noner c ||}||}|| } ||}| in| } d| vrMt | t r|jnt| } tdi| d| i} 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 Nr)rrrrrrrrrW) _merge_url_merge_headers_merge_cookies_merge_queryparamsrrRrrdictas_dictr ) rrrrArrrrrrrrrs rN build_requestzBaseClient.build_requestFs4ooc""%%g..%%g..((00%-RR: J & &&0:J&K&KadllQXY`QaQaGFF FFGOO4E4EFFFJ  !    rPct|}|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)r5is_relative_urlrrlstripr)rrrA merge_urlmerge_raw_paths rNrzBaseClient._merge_urlus] HH  $ D"]3i6H6O6OPT6U6UUN=**N*CC CrPcn|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)rrrmerged_cookiess rNrzBaseClient._merge_cookiessC  "dl "$T\22N  ! !' * * *! !rPcXt|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rrrmerged_headerss rNrzBaseClient._merge_headerss- !..g&&&rPcj|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. )rr6merge)rrrmerged_queryparamss rNrzBaseClient._merge_queryparamss>  4T[ 4!,T[!9!9 %++F33 3 rPc|dSt|trt|d|dSt|tr|St |rt |St d|)Nrr usernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rNrzBaseClient._build_auths <4 e $ $ Bd1gQ@@@ @ d # # BK d^^ BT*** *@@@AA ArPr#AuthTypes | UseClientDefault | Noner ct|tr|jn||}||S|jj|jj}}|s|rt||StS)Nr) rrRrrrArrr r )rrrrrrs rN_build_request_authzBaseClient._build_request_authsy (.>??[tzzTEUEUVZE[E[  K$[17;3G(  Cx ChBBB Bvv rPrr!c|||}|||}||||}|||}t |j}t ||||||jS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrArrrgr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrr r)rrrrrrArrgrs rN_build_redirect_requestz"BaseClient._build_redirect_requests &&w99  (33((#v>>&&w77$,'')     rPc|j}|jtjkr|dkrd}|jtjkr|dvrd}|jtjkr|dkrd}|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)rrrrrs rNrzBaseClient._redirect_methodsu   5? 2 2v7G7GF  5; . .6AR3R3RF  5#: : :v?O?OF rPc|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)rJ)fragment) rr5rrrKrJrrArjoinr")rrrrrBrAexcs rNrzBaseClient._redirect_urls#J/ lh--CC l l l%&O&O&O&OY`aaagk k l : 7ch 7--W[%5-66C   (+""3''C ;  ?  ?--)=->>C s A?Act|j}|j|jjkrHt |j|s|dd|jd|d<||jkr2|dkr,|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrrIrArOpopnetlocdecoder)rrrrArrs rNrzBaseClient._redirect_headers s'/** :+ + +%gk377 3 OT222"j//88GFO W^ # #% KK($ / / / KK+T 2 2 2  Hd###rP'SyncByteStream | AsyncByteStream | Nonec6||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrg)rrrrs rNrzBaseClient._redirect_stream's& W^ # #%4~rPcd|jvrct|jtr|jnt |j}t di|jd|i|_dSdS)NrrW)rrrrRrrr)rrrrs rN _set_timeoutzBaseClient._set_timeout0sv G. . .&0?O&P&PkdllV]^b^jVkVkG!%!V!V(:!V!VGOODUDU!V!V!VG    / .rP)rrrrrrrrrr4rrDrrrrrrrrDrrrCrj)rCrD)rAr5rCr5)rrrrDrCr)rCr)rr4rCrj)rCr)rrrCrj)rCr)rr)rCrj)rCr5)rArrCrj)rCr)rr,rCrj)rCr)rr+rCrj)rCr6)rr.rCrj)rrrArrrrrrrrrrrrrrrrrrrrCr )rArrCr5rl)rrrCr)rrrCr)rrrCr)rrrCr)rr rr rCr )rr rr!rCr )rr rr!rCr)rr rr!rCr5)rr rAr5rrrCr)rr rrrCr,)rr rCrj)!rSrTrUrrrspropertyrrrrrsetterrrrrrrr;rrrrrrrrrrrrr/rWrPrNrrs"&)-&*&* 6!&2EI GN + + + + + +D111X1 X;;;; %%%%X ^)))^)!!!X!    X [,,,[,X _@@@_@X  ^ ' ' '^ 'X  ^)))^)X  ]+++]+*.#'%)"&)-&*&*3E/3- - - - - - ^,      B B B B5G     &266WWWWWWrPrc|eZdZdZdddddddddddedeeddddddyfd-Zdddddedfdzd/Zdddddefd{d1Z d|d4Z ddddddde e e dd5 d}dFZ e ddddddde e e dd5 d~dHZe dIddddddde e e dedJ ddNZe eeeedddde e e ddO ddXZde e dYdd]ZddaZddbZddcZddde e e dddddeZddde e e dddddgZddde e e dddddhZddddddde e e dd5 ddiZddddddde e e dd5 ddjZddddddde e e dd5 ddkZddde e e dddddlZ ddddddde e e dd5 ddmZ!ddnZ"ddqZ# dddxZ$xZ%S)r=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 transportrrrrrrrrrr3ssl.SSLContext | str | boolr4CertTypes | NonerrDr5r6rrr70None | typing.Mapping[str, BaseTransport | None]rr4rr8rrrrrrrr9BaseTransport | NonerrrCrjc j t||||| | ||||  r$ ddl}n#t$rtddwxYwo|du}| |} |_ fd|D_| 6j d| Dttj_dS)NrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.r3r4rr5r6r8r9c ri|]3\}}t||dn| 4SN)r3r4rr5r6r8r7_init_proxy_transport r[r\rr4r5r6r8rrrr3s rNrz#Client.__init__..st @ @ @ U sOO}"T++#, @ @ @ rPc4i|]\}}t||SrWr7r[r\r9s rNrz#Client.__init__..$ a a aYC) a a arP superrsh2 ImportErrorr_init_transport _transportr_mountsrrsorted)rrrrrrr3r4rr5r6rr7rrr8rrrr9rrLr proxy_map __class__s` ````` ` rNrszClient.__init__es. -'#-         !S  &;)t*;''/@AA ../   @ @ @ @ @ @ @ @ @ @ (oo// @ @ @     L   a aRXR^R^R`R` a a a b b bF4<#5#5#7#78899 =Ar'c4||St||||||SrBr%rrr3r4rr5r6r8r9s rNrNzClient._init_transports9        rPrc .t|||||||SN)r3r4rr5r6r8rrVrrrr3r4rr5r6r8s rNrDzClient._init_proxy_transports0    rPrAr5c|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. rPrmatchesrOrrrApatternr9s rN_transport_for_urlzClient._transport_for_urld #',"4"4"6"6 K K GYs## K*3*;tJJJ KrP rrrrrrrrrrrrrrrrrrrrrr bool | UseClientDefaultrrrr!c | d}tj|td|||||||||| | |  }||| | 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 NSetting 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 rrArrrrrrrrrrrwarningswarnDeprecationWarningrsendrrrrArrrrrrrrrrrmessagers rNrzClient.requestsB  C  M'#5! D D D D$$!%   yyt>NyOOOrPGenerator[Response]c #K|||||||||| | |  }||| | d} |V|dS#|wxYwa 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 riT)rrrrgN)rrorrrrrArrrrrrrrrrrrrs rNrgz Client.streams8$$!%   99-     NNN NN     HNN    s AA-r rrrrrrrrrrrrmax_event_sizerw int | NoneGenerator[EventSource]c #K||||||||dddt|z| | | | |  5}t||VddddS#1swxYwYdS) 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-ControlrcrwNrgrr"rrrArrrrrrrrrrrrrwrs rNssez Client.sseSs4[[  2ZPPSZ[bScScc-!   Gh~FFF F F F G G G G G G G G G G G G G G G G G GsAA A max_message_size_bytes queue_sizekeepalive_ping_interval_secondskeepalive_ping_timeout_seconds subprotocolsrrrrrrrrrr float | Nonerrlist[str] | NoneGenerator[WebSocketSession]c #K ddlm}n#t$rtdwxYw|t|||||||||| | | | | 5}|VddddS#1swxYwYdS)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]`.rN)websockets._apirrMr)rrrArrrrrrrrrrrrrsessions rN websocketzClient.websocket~s<  3 3 3 3 3 3 3   m   Z HH #9!,K+I%-!    MMM!                  s %A  A$'A$rgrrrr rgc|jtjkrtdtj|_t |t r|jn|}||| ||}| |||g} |s| |S#t$r}| |d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `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_rd RuntimeErrorrcrrRrr/r_send_handling_authread BaseExceptionrrrrrgrrrr$s rNroz Client.sends* ;+, , ,VWW W!( 4>?OQa4b4bx400hx '"""''66++ - ,      O    NN   I sB11 C;CCr rlist[Response]c||} t|} ||||} ||}n&#t$r|cY|SwxYwt ||_||}| |n(#t$r}||d}~wwxYw#|wxYwNT)rr) sync_auth_flownext_send_handling_redirectsro StopIterationrrrrappendr rrrrrr auth_flowr next_requestr$s rNrzClient._send_handling_auths,''00  9ooG 88%5#9 ('0~~h'?'? ((((' OO    ((,G}}H$MMOOO*GNN8,,,,$NN$$$I# * OO    sN(C&AB= A:#B=9A::AB=<C&= C"CC""C&&C<c t||jkrtd||jdD] }||||} |jdD] }||t ||_|js|S|||}||gz}|r| n ||_ |Sn(#t$r}| |d}~wwxYwNTz#Exceeded maximum allowed redirects.r!rr) lenrrr_send_single_requestrrhas_redirect_locationrrrrrrrrrrhookrr$s rNrzClient._send_handling_redirectss7  7||d000&'LV]^^^^))4  W 0099H  -j9##DDNNNN#'== 5$#O66wII!XJ.#$MMOOOO,3H)#O$ !        3 s7C;C C6C11C6cd||j}tj}t |jt stdt|5| |}dddn #1swxYwYt |jt sJ||_ t|j||_|j ||j|_t d|j|j|j|j|j|S)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.r!NrhHTTP Request: %s %s "%s %d %s")rarAr~rrrgr3rrhandle_requestrrfrextract_cookiesrrloggerinfor http_versionr reason_phraserrrr9rhrs rNrzClient._send_single_request)sY++GK88 !##'..99 b`aa a W - - - 9 9 //88H 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9(/>:::::")(/GGG $$X...$($:! , N K  !   "    s'B  B B rrrrrrrc >|d|||||||| S)V Send a `GET` request. **Parameters**: See `httpx2.request`. rrr! rrrArrrrrrrs rNrz Client.getHs:"||  -!   rPAuthTypes | UseClientDefaultc >|d|||||||| S)[ Send an `OPTIONS` request. **Parameters**: See `httpx2.request`. OPTIONSrr!rs rNoptionszClient.optionses:"||  -!   rPc >|d|||||||| S)W Send a `HEAD` request. **Parameters**: See `httpx2.request`. rrr!rs rNheadz Client.heads:"||  -!   rPc F|d||||||||| | | |  S)W Send a `POST` request. **Parameters**: See `httpx2.request`. rrcr! rrrArrrrrrrrrrrs rNpostz Client.postsF*||  -!   rPc F|d||||||||| | | |  S)V Send a `PUT` request. **Parameters**: See `httpx2.request`. PUTrcr!rs rNputz Client.putsF*||  -!   rPc F|d||||||||| | | |  S)X Send a `PATCH` request. **Parameters**: See `httpx2.request`. PATCHrcr!rs rNpatchz Client.patchF*||  -!   rPc >|d|||||||| S)Y Send a `DELETE` request. **Parameters**: See `httpx2.request`. DELETErr!rs rNdeletez Client.deletes:"||  -!   rPc F|d||||||||| | | |  S)X Send a `QUERY` request. **Parameters**: See `httpx2.request`. rrcr!rs rNqueryz Client.query+rrPc|jtjkr\tj|_|j|jD]}||dSdSz. Close transport and proxies. N)rr_rdrOrrPvalues)rrr9s rNrz Client.closePsx ;+, , ,%,DK O ! ! # # #!\0022 & & (OO%%% - , & &rPrrr>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.) rr_rbrcrdrrO __enter__rPr)rrmsgr9s rNrzClient.__enter__\s ;+. . ."$S"%`kCs## #!(  !!###,,.. & &I$##%%% rPexc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonectj|_|j||||jD]}|||||dSrl)r_rdrrO__exit__rPr)rrrrrr9s rNrzClient.__exit__lsr "(    9i@@@,,.. C CI$""8Y BBB C CrP)(rrrrrrrrr3r:r4r;rrDr5rDr6rDrrr7r<rr4rrDr8rrrrrrrr9r=rrrCrj)r3r:r4r;rrDr5rDr6rDr8rr9r=rCr')rrr3r:r4r;rrDr5rDr6rDr8rrCr')rAr5rCr'rrrArrrrrrrrrrrrrrrrr rrdrrrrrCr!)rrrArrrrrrrrrrrrrrrrr rrdrrrrrCrr)rArrrrrrrrrrrrrrrrrrr rrdrrrrrwrxrCry)rArrrrrrrrrrrrrrrrrrr rrdrrrrrCr rr rgrDrr rrdrCr! rr rr rrDrrrCr!rr rrDrrrCr!rr rCr!rArrrrrrrrr rrdrrrrrCr!rArrrrrrrrrrrdrrrrrCr!rArrrrrrrrrrrrrrrrrrrdrrrrrCr!r)rrr>rCr>NNNrrrrrrrCrj)&rSrTrUrVrrrrsrNrDrar;rrrgrrrrrrrrorrrrrrrrrrrrrr __classcell__rSs@rNr=r=6s,,b"&)-&*&*.2!%#'EI 6!&'2EI *.GN+K:K:K:K:K:K:K:K:^/3!%'*.     2/3!%'     (     *.#'%)"&)-&*&*4F4F3E/36P6P6P6P6P6Pp *.#'%)"&)-&*&*4F4F3E/311111^1f )-#'%)"&)-&*&*4F4F3E/3%A!(G(G(G(G(G^(GT 'E,8_7])-)-&*&*4F4F3E/344444^4t4F4F ------^    D!!!!FF*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # J & & & &$04*.*. C C C C C C C C CrPc|eZdZdZddddddddddedeedddddddyfd-Zdddddedfdzd/Zdddddefd{d1Z d|d4Z ddddddde e e dd5 d}dFZ e ddddddde e e dd5 d~dHZe dIddddddde e e dedJ ddNZe eeeedddde e e ddO ddXZde e dYdd]ZddaZddbZddcZddde e e dddddeZddde e e dddddgZddde e e dddddhZddddddde e e dd5 ddiZddddddde e e dd5 ddjZddddddde e e dd5 ddkZddde e e dddddlZ ddddddde e e dd5 ddmZ!ddnZ"ddqZ# dddxZ$xZ%S)r<a< An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. Usage: ```python >>> async with 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)rrrrr3r4r5r6rr7rrr8rrrr9rrrrrrrrrrr3r:r4r;r5rDr6rrr75None | typing.Mapping[str, AsyncBaseTransport | None]rr4rr8rrrrrrrr9AsyncBaseTransport | NonerrrrCrjc j t||||| | |||| r$ ddl}n#t$rtddwxYwo|du}| |} |_ fd|D_| 6j d| Dttj_dS)Nrrr?r@c ri|]3\}}t||dn| 4SrBrCrEs rNrz(AsyncClient.__init__..st E E E U sOO}"T++#, E E E rPc4i|]\}}t||SrWrGrHs rNrz(AsyncClient.__init__..rIrPrJ)rrrrrrr3r4r5r6rr7rrr8rrrr9rrrLrrRrSs` ```` ` ` rNrszAsyncClient.__init__s. -'#-         !S  &;)t*;''/@AA ../   E E E E E E E E E E (oo// E E E     L   a aRXR^R^R`R` a a a b b bF4<#5#5#7#78899 rTr&c4||St||||||SrBr$rWs rNrNzAsyncClient._init_transports9   !     rPrc .t|||||||SrYrrZs rNrDz!AsyncClient._init_proxy_transport s0"    rPrAr5c|jD]'\}}||r ||jn|cS(|jSr\r]r_s rNrazAsyncClient._transport_for_url!rbrPrcrrrrrrrrrrr rdrrrr!c K| d}tj|td|||||||||| | |  }||| | d{VS)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = await client.send(request, ...) ``` See `AsyncClient.build_request()`, `AsyncClient.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration Nrfr`rgrirjrkrps rNrzAsyncClient.request,sD  C  M'#5! D D D D$$!%   YYwTDTYUUUUUUUUUrPAsyncGenerator[Response]c K|||||||||| | |  }||| | dd{V} |WV|d{VdS#|d{VwxYwrt)rrorrus rNrgzAsyncClient.streames8$$!%   - #          $NNNN//## # # # # # # # # #(//## # # # # # # # #s A$$BrrvrwrxAsyncGenerator[EventSource]c K||||||||dddt|z| | | | |  4d{V }t||WVdddd{VdS#1d{VswxYwYdS)r{r|r}r~rcNrrrs rNrzAsyncClient.ssesd4;;  2ZPPSZ[bScScc-!   G G G G G G G Gh~FFF F F F F G G G G G G G G G G G G G G G G G G G G G G G G G G G G G GsA'' A14A1rrrrrrrr%AsyncGenerator[AsyncWebSocketSession]c K ddlm}n#t$rtdwxYw|t|||||||||| | | | | 4d{V }|WVdddd{VdS#1d{VswxYwYdS)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_wsrrN)rrrMr)rrrArrrrrrrrrrrrrrs rNrzAsyncClient.websocketsg<  4 4 4 4 4 4 4   m   ; HH #9!,K+I%-!           MMMM!                              s %A.. A8;A8rrr rgcK|jtjkrtdtj|_t |t r|jn|}||| ||}| |||gd{V} |s| d{V|S#t$r!}| d{V|d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx2.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances rrN)rr_rdrrcrrRrr/rrareadrrrs rNrozAsyncClient.sends8* ;+, , ,VWW W!( 4>?OQa4b4bx400hx '"""''6611 - 2           'nn&&&&&&&&&O   //## # # # # # # #I s!B?? C* C%%C*r rrc`K||} |d{V} ||||d{V} ||d{V}n,#t$r|cY|d{VSwxYwt ||_|d{V|}| |n.#t$r!}|d{V|d}~wwxYw#|d{VwxYwr) async_auth_flow __anext__rasendStopAsyncIterationrrrrrrrs rNrzAsyncClient._send_handling_auth*s((11  %%//11111111G !%!>!>%5#"?"" (-6__X-F-F'F'F'F'F'F'F -((('""$$ $ $ $ $ $ $ $ $((,G}}H$"..**********GNN8,,,,$"//+++++++++I# *""$$ $ $ $ $ $ $ $ $sN9DA0/C"0 B<C"BAC"!D" D ,DD  DD-c6K t||jkrtd||jdD]}||d{V||d{V} |jdD]}||d{Vt ||_|js|S|||}||gz}|r| d{Vn ||_ |Sn.#t$r!}| d{V|d}~wwxYwr) rrrrrrrrrrrrrrs rNrz$AsyncClient._send_handling_redirectsLs  7||d000&'LV]^^^^))4 $ $d7mm########!66w????????H  -j9))D$x..((((((((#'== 5$#O66wII!XJ.#$"..**********,3H)#O+ !   oo'''''''''  5 s*=C+(AC++ D5DDctK||j}tj}t |jt stdt|5| |d{V}dddn #1swxYwYt |jt sJ||_ t|j||_|j ||j|_t d|j|j|j|j|j|S)rz>Attempted to send a sync request with an AsyncClient instance.r!Nrr)rarAr~rrrgr(rrhandle_async_requestrrrrrrrrrrrrrs rNrz AsyncClient._send_single_requestps++GK88 !##'./:: a_`` ` W - - - E E&;;GDDDDDDDDH E E E E E E E E E E E E E E E(/?;;;;;"*8?%HHH $$X...$($:! , N K  !   "    s)BBBrc NK|d|||||||| d{VS)rrrNr!rs rNrzAsyncClient.gets\"\\  -!"         rPrc NK|d|||||||| d{VS)rrrNr!rs rNrzAsyncClient.optionss\"\\  -!"         rPc NK|d|||||||| d{VS)rrrNr!rs rNrzAsyncClient.heads\"\\  -!"         rPc VK|d||||||||| | | |  d{VS)rrrcNr!rs rNrzAsyncClient.postsh*\\  -!"         rPc VK|d||||||||| | | |  d{VS)rrrcNr!rs rNrzAsyncClient.put sh*\\  -!"         rPc VK|d||||||||| | | |  d{VS)rrrcNr!rs rNrzAsyncClient.patch/h*\\  -!"         rPc NK|d|||||||| d{VS)rrrNr!rs rNrzAsyncClient.deleteTs\"\\  -!"         rPc VK|d||||||||| | | |  d{VS)rrrcNr!rs rNrzAsyncClient.queryqrrPcK|jtjkrhtj|_|jd{V|jD] }||d{VdSdSr)rr_rdrOrrPr)rrrs rNrzAsyncClient.acloses ;+, , ,%,DK/((** * * * * * * *,,.. ) )$,,..((((((( - , ) )rPrrr@clK|jtjkr4tjdtjdi|j}t |tj|_|jd{V|j D]}||d{V|Sr) rr_rbrcrdrrO __aenter__rPr)rrrrs rNrzAsyncClient.__aenter__s ;+. . ."$S"%`kCs## #!( o((*********\((** ) )E &&((((((((( rPrrrrrrcKtj|_|j|||d{V|jD]!}|||||d{V"dSrl)r_rdrrO __aexit__rPr)rrrrrrs rNrzAsyncClient.__aexit__s "( o'')YGGGGGGGGG\((** F FE ooh 9EEEEEEEEE F FrP)(rrrrrrrrr3r:r4r;r5rDr6rDrrr7rrr4rrDr8rrrrrrrr9rrrDrrrCrj)r3r:r4r;rrDr5rDr6rDr8rr9rrCr&)rrr3r:r4r;rrDr5rDr6rDr8rrCr&)rAr5rCr&r)rrrArrrrrrrrrrrrrrrrr rrdrrrrrCr)rArrrrrrrrrrrrrrrrrrr rrdrrrrrwrxrCr)rArrrrrrrrrrrrrrrrrrr rrdrrrrrCrrrrrrrrr)rrr@rCr@rr)&rSrTrUrVrrrrsrNrDrar;rrrgrrrrrrrrorrrrrrrrrrrrrrrrs@rNr<r<zs--d"&)-&*&*.2!%#'JN 6!&'2EI /3GN+K:K:K:K:K:K:K:K:^/3!%'/3     2/3!%'     (     *.#'%)"&)-&*&*4F4F3E/37V7V7V7V7V7Vr *.#'%)"&)-&*&*4F4F3E/31$1$1$1$1$1$f )-#'%)"&)-&*&*4F4F3E/3%A!(G(G(G(G(G(GT 'E,8_7])-)-&*&*4F4F3E/3444444t4F4F ------^ % % % %D""""HD*.&*&*4F4F3E/3      B*.&*&*-?4F3E/3      B*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.#'%)"&)-&*&*-?4F3E/3# # # # # # R*.&*&*-?4F3E/3      B*.#'%)"&)-&*&*-?4F3E/3# # # # # # J ) ) ) )$04*.*. F F F F F F F F FrP)rAr5rBr5rCrD)g __future__rr|enumloggingr~typingrlcollections.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_CHECKINGsslrr9r:__all__TypeVarr>r@rOrRr; getLoggerrrr#keysrEnumr_rfrCallableAny EventHookrr=r<rWrPrNr;s$""""""  55555555::::::::$$$$$$0000000000                          *))))) 988888888888 ::::::::????????$#######77777777 IJJJHHHHHHHH 9 9 9FN3h'''FN3m,,,     (&%''  8 $ $ +k + + ))[[,C,>,C,E,E[[[\\     $)   n($$$$$$$$4 OCO , @W@W@W@W@W@W@W@WF A CA CA CA CA CZA CA CA CHC FC FC FC FC F*C FC FC FC FC FrP