o Tj&@sddlmZddlZddlZddlZddlZddlZddlZddlm 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@mAZAmBZBmCZCmDZDddlEmFZFmGZGddlHmIZImJZJejKrddlLZLddlMmNZNmOZOgdZPejQdddZRejQdddZSd4d d!ZTGd"d#d#ZUeUZVeWd$ZXd%eZYd&Zd'd(e"[DZ\Gd)d*d*ej]Z^Gd+d,d,eCZ_Gd-d.d.e8Z`ejad/ejbfZcGd0d1d1ZdGd2ddedZeGd3ddedZfdS)5) 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;urlr4locationreturnboolcCs@|j}|j}|j|jko|jdko|jdko|jdko|jdkS)zA Return 'True' if 'location' is a HTTPS upgrade of 'url' httpPhttpsi)originhostschemeport)r@rArGlocation_originrLQ/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/httpx2/_client.py_is_https_redirectGs rNc@seZdZdZdS)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__rLrLrLrMrOWsrOhttpx2zpython-httpx2/z, cCsg|]}|dkr|qS)identityrL).0keyrLrLrM qsrXc@seZdZdZdZdZdS) ClientStaterN)rPrQrRUNOPENEDOPENEDCLOSEDrLrLrLrMrYtsrYc@.eZdZdZddd Zdd d Zdd dZdS)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`. streamr2startfloatrBNonecC||_||_d|_dSN_stream_startelapsedselfrarbrLrLrM__init__ zBoundSyncStream.__init__typing.Iterator[bytes]ccs|jEdHdSrf)rhrlrLrLrM__iter__szBoundSyncStream.__iter__cCs&tjt|jd|_|jdSN)seconds)datetime timedeltatime perf_counterrirjrhcloserprLrLrMrxszBoundSyncStream.closeN)rar2rbrcrBrd)rBrorBrd)rPrQrRrSrmrqrxrLrLrLrMr`s   r`c@r_)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`. rar'rbrcrBrdcCrerfrgrkrLrLrMrmrnzBoundAsyncStream.__init__typing.AsyncIterator[bytes]c Csf|j}z|2z 3dHW}|Vq 6Wt|tr#|IdHdSdSt|tr2|IdHwwrf)rh __aiter__ isinstanceraclose)rlrachunkrLrLrMr|s  zBoundAsyncStream.__aiter__cs.tjt|jd|_|jIdHdSrr)rtrurvrwrirjrhr~rprLrLrMr~szBoundAsyncStream.acloseN)rar'rbrcrBrd)rBr{ry)rPrQrRrSrmr|r~rLrLrLrMrzs    rz.c @seZdZddddededdddd d|ddZed}d d!Zed}d"d#Zd~d&d'Z dd,d-Z edd/d0Z e j dd1d0Z edd3d4Z e j dd5d4Z edd7d8Zej dd:d8Zedd;d<Zej dd=d<Zedd?d@Zej ddBd@ZeddDdEZej ddGdEZeddIdJZej ddLdJZdddddddeddM dd\d]Zdd^d_Zddd`daZdddbdcZdddddeZddfdgZefddkdlZddodpZddqdrZddsdtZddudvZddxdyZddzd{Z dS) BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingrAuthTypes | NonerQueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr3rrCrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrr*str | typing.Callable[[bytes], str | None]rBrdc Cs|durin|}|t| |_|||_t||_t||_t ||_ t ||_ ||_ ||_t|dgt|dgd|_| |_| |_tj|_dSNrequestresponse)rr)_enforce_trailing_slashr4 _base_url _build_auth_authr5_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingrYr\_state) rlrrrrrrrrrrrrLrLrMrms      zBaseClient.__init__cCs |jtjkS)z2 Check if the client being closed )rrYr^rprLrLrM is_closeds zBaseClient.is_closedcC|jSrf)rrprLrLrMrzBaseClient.trust_envr@r4cCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withrlr@rLrLrMrs z"BaseClient._enforce_trailing_slashproxyProxyTypes | Noneallow_env_proxiesdict[str, Proxy | None]cCsH|dur|rddtDSiSt|ttfrt|dn|}d|iS)NcSs(i|]\}}||dur dnt|dqS)Nr@)r)rVrWr@rLrLrM s(z-BaseClient._get_proxy_map..rzall://)r7itemsr}strr4r)rlrrrLrLrM_get_proxy_maps zBaseClient._get_proxy_maprcCrrf)rrprLrLrMrrzBaseClient.timeoutcCt||_dSrf)rr)rlrrLrLrMrdict[str, list[EventHook]]cCrrf)rrprLrLrMrrzBaseClient.event_hookscCs(t|dgt|dgd|_dSr)rrr)rlrrLrLrMrs Auth | NonecCr)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: quickstart.md#authentication )rrprLrLrMrs zBaseClient.authr(cCs|||_dSrf)rrrlrrLrLrMr scCr)zK Base URL to use when sending requests with relative URLs. )rrprLrLrMrzBaseClient.base_urlcCs|t||_dSrf)rr4rrrLrLrMrsrcCr)z@ HTTP headers to include when sending requests. )_headersrprLrLrMrrzBaseClient.headersr+cCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rlrclient_headersrLrLrMr#s  rcCr)zA Cookie values to include when sending requests. )rrprLrLrMr0rzBaseClient.cookiesr*cCrrf)rr)rlrrLrLrMr7rr5cCr)zO Query parameters to include in the URL when sending requests. )rrprLrLrMr;rzBaseClient.paramsr-cCrrf)r5r)rlrrLrLrMrBr) contentdatafilesjsonrrrr extensionsmethodrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | NoneTimeoutTypes | UseClientDefaultrRequestExtensions | Nonerc Cs||}||}|| } ||}| durin| } d| vr9t| tr(|jnt| } tdi| d| i} t ||||||||| | d 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 Nr)rrrrrrrrrL) _merge_url_merge_headers_merge_cookies_merge_queryparamsr}rOrrdictas_dictr) rlrr@rrrrrrrrrrLrLrM build_requestFs(    zBaseClient.build_requestcCs4t|}|jr|jj|jd}|jj|dS|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)rlr@ merge_urlmerge_raw_pathrLrLrMrus  zBaseClient._merge_urlcCs&|s|jrt|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)rlrmerged_cookiesrLrLrMrs   zBaseClient._merge_cookiescCst|j}|||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rlrmerged_headersrLrLrMrs  zBaseClient._merge_headerscCs"|s|jrt|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)rlrmerged_queryparamsrLrLrMrs   zBaseClient._merge_queryparamscCsX|durdSt|trt|d|ddSt|tr|St|r%t|dStd|)Nrrusernamepassword)funczInvalid "auth" argument: )r}tupler r callabler TypeErrorrrLrLrMrs   zBaseClient._build_authr#AuthTypes | UseClientDefault | Noner cCsRt|tr|jn||}|dur|S|jj|jj}}|s |r&t||dStS)Nr) r}rOrrr@rrr r )rlrrrrrLrLrM_build_request_auths zBaseClient._build_request_authrr cCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rr@rrrar)_redirect_method _redirect_url_redirect_headers_redirect_streamrrrr)rlrrrr@rrarrLrLrM_build_redirect_requests    z"BaseClient._build_redirect_requestcCsR|j}|jtjkr|dkrd}|jtjkr|dvrd}|jtjkr'|dkr'd}|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)rlrrrrLrLrMrszBaseClient._redirect_methodc Cs|jd}zt|}Wnty"}z td|d|ddd}~ww|jr1|js1|j|jjd}|jr:|j |}|jj rI|j sI|j|jj d}|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)rH)fragment) rr4rrrIrHrr@rjoinr)rlrrrAr@excrLrLrMrs    zBaseClient._redirect_urlcCszt|j}|j|jjkr t|j|s|dd|jd|d<||jkr5|dkr5|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrrGr@rNpopnetlocdecoder)rlrr@rrrLrLrMr s      zBaseClient._redirect_headers'SyncByteStream | AsyncByteStream | NonecCs||jkr |dkr dS|jS)zO Return the body that should be used for the redirect request. rN)rra)rlrrrLrLrMr'szBaseClient._redirect_streamcCsLd|jvr$t|jtr|jnt|j}tdi|jd|i|_dSdS)NrrL)rr}rrOrrr)rlrrrLrLrM _set_timeout0s "zBaseClient._set_timeout)rrrrrrrrrr3rrCrrrrrrrrCrrrBrd)rBrC)r@r4rBr4)rrrrCrBr)rBr)rr3rBrd)rBr)rrrBrd)rBr)rr(rBrd)rBr4)r@rrBrd)rBr)rr+rBrd)rBr)rr*rBrd)rBr5)rr-rBrd)rrr@rrrrrrrrrrrrrrrrrrrrBr)r@rrBr4rf)rrrBr)rrrBr)rrrBr)rrrBr)rrrrrBr )rrrr rBr)rrrr rBr)rrrr rBr4)rrr@r4rrrBr)rrrrrBr)rrrBrd)!rPrQrRrrrmpropertyrrrrrsetterrrrrrrr:rrrrrrrrrrrrrrLrLrLrMrs"                   /        rcseZdZdZdddddddddddedeeddddddfd-d.Zdddddedfdd0d1Zdddddefdd3d4Z dd7d8Z ddddddde e e dd9 ddJdKZ e ddddddde e e dd9 ddMdNZe dOddddddde e e dedP ddTdUZe eeeedddde e e ddV dd_d`Zde e daddedfZddjdkZddldmZddndoZddde e e ddpddqdrZddde e e ddpddtduZddde e e ddpddvdwZddddddde e e dd9 ddxdyZddddddde e e dd9 ddzd{Zddddddde e e dd9 dd|d}Zddde e e ddpdd~dZ ddddddde e e dd9 dddZ!dddZ"dddZ#   ddddZ$Z%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 transportrrrrrrrrrrssl.SSLContext | str | boolrCertTypes | NonerrCr r rrr 0None | typing.Mapping[str, BaseTransport | None]rr3rr rrrrrrrr BaseTransport | NonerrrBrdc stj||||| | ||||d r&zddl}Wn ty%tddwo+|du}| |}j|d_fdd|D_| durbj dd| Dt t j_dS)NrruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrr r r r c :i|]\}}t||durdn j|dqSN)rrrr r r r6_init_proxy_transportrVrWrrr r r rlrrrLrMr z#Client.__init__..cSi|] \}}t||qSrLr6rVrWr rLrLrMr superrmh2 ImportErrorr_init_transport _transportr_mountsrrsorted)rlrrrrrrrr r rr rrr rrrr rr!r proxy_map __class__rrMrmesP      zClient.__init__r&cC |dur|St||||||dSrr$rlrrrr r r r rLrLrMr# zClient._init_transportrc Ct|||||||dSN)rrrr r r rr+rlrrrrr r r rLrLrMr zClient._init_proxy_transportr@r4cC>|jD]\}}||r|dur|jS|Sq|jSz Returns the transport instance that should be used for a given URL. This will either be the standard connection pool, or a proxy. Nr%rmatchesr$rlr@patternr rLrLrM_transport_for_url  zClient._transport_for_url rrrrrrrrrrrrrrrrrrrrrrbool | UseClientDefaultrrrr c  CsL| durd}tj|tdd|j||||||||| | | d }|j|| | dS)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 NSetting 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 rr@rrrrrrrrrrrwarningswarnDeprecationWarningrsendrlrr@rrrrrrrrrrrmessagerrLrLrMrs$! zClient.requestGenerator[Response]c  csT|j||||||||| | | d }|j|| | dd}z |VW|dS|wa 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 r?T)rrrraN)rrErxrlrr@rrrrrrrrrrrrrrLrLrMras. z Client.streamr rrrrrrrrrrrrmax_event_sizerL int | NoneGenerator[EventSource]c csh|j|||||||dddt|B| | | | | d }t||dVWddS1s-wYdS) 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-Controlr:rLNrarr!rlr@rrrrrrrrrrrrrLrrLrLrMsseSs&"z Client.sse max_message_size_bytes queue_sizekeepalive_ping_interval_secondskeepalive_ping_timeout_seconds subprotocolsrrrrrrrrYrZr[ float | Noner\r]list[str] | NoneGenerator[WebSocketSession]c cs~zddlm}Wn tytdw|t|||||||||| | | | | d }|VWddS1s8wYdS)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]`.rXN)websockets._apirar"r)rlr@rYrZr[r\r]rrrrrrrrasessionrLrLrM websocket~s6 "zClient.websocketrarrrrrac Cs|jtjkr tdtj|_t|tr|jn|}||| ||}|j |||gd}z |s3| |WSt yG}z| |d}~ww)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]r}rOrrr_send_handling_authread BaseExceptionrxrlrrarrrrrLrLrMrEs*   z Client.sendr rilist[Response]c Cs||}zLt|} |j|||d}z+z||}Wnty,|YWW|Swt||_||}| |Wnt yP}z||d}~wwq |wNT)rri) sync_auth_flownext_send_handling_redirectsrE StopIterationrxrrirlappendrm rlrrrri auth_flowr next_requestrrLrLrMrks6      zClient._send_handling_authc Cs t||jkrtd|d|jdD]}||q||}z1|jdD]}||q%t||_|js7|WS|||}||g}|rI| n||_ |WSWnt yb}z| |d}~wwqNTz#Exceeded maximum allowed redirects.rrr) lenrrr_send_single_requestrrihas_redirect_locationrrlrxrmrxrlrrrihookrrrLrLrMrss2        zClient._send_handling_redirectscCs||j}t}t|jtstdt|d | |}Wdn1s)wYt|jts6J||_ t |j|d|_|j ||j|_td|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.rNrbHTTP Request: %s %s "%s %d %s")r8r@rvrwr}rar2rjrhandle_requestrr`rextract_cookiesrrloggerinfor http_versionr reason_phraserlrr rbrrLrLrMr{)s*      zClient._send_single_requestrrrrrrrc C|jd||||||||d S)V Send a `GET` request. **Parameters**: See `httpx2.request`. rrr rlr@rrrrrrrrLrLrMrHz Client.getAuthTypes | UseClientDefaultc Cr)[ Send an `OPTIONS` request. **Parameters**: See `httpx2.request`. OPTIONSrrrrLrLrMoptionserzClient.optionsc Cr)W Send a `HEAD` request. **Parameters**: See `httpx2.request`. rrrrrLrLrMheadrz Client.headc C$|jd||||||||| | | | d S)W Send a `POST` request. **Parameters**: See `httpx2.request`. rr:r rlr@rrrrrrrrrrrrLrLrMpostz Client.postc Cr)V Send a `PUT` request. **Parameters**: See `httpx2.request`. PUTr:rrrLrLrMputrz Client.putc Cr)X Send a `PATCH` request. **Parameters**: See `httpx2.request`. PATCHr:rrrLrLrMpatchrz Client.patchc Cr)Y Send a `DELETE` request. **Parameters**: See `httpx2.request`. DELETErrrrLrLrMdeleterz Client.deletec Cr)X Send a `QUERY` request. **Parameters**: See `httpx2.request`. rr:rrrLrLrMquery+rz Client.querycCsF|jtjkrtj|_|j|jD] }|dur|qdSdSz. Close transport and proxies. N)rrYr^r$rxr%values)rlr rLrLrMrxPs  z Client.closerlr=cCs`|jtjkrtjdtjdi|j}t|tj|_|j|j D] }|dur-|q#|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrYr\r]r^rjr$ __enter__r%r)rlmsgr rLrLrMr\s  zClient.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCsBtj|_|j||||jD] }|dur||||qdSrf)rYr^rr$__exit__r%r)rlrrrr rLrLrMrlszClient.__exit__)(rrrrrrrrrrrrrrCr rCr rCrrr rrr3rrCr rrrrrrrr rrrrBrd)rrrrrrCr rCr rCr rr rrBr&)rrrrrrrrCr rCr rCr rrBr&)r@r4rBr&rrr@rrrrrrrrrrrrrrrrrrr;rrrrrBr )rrr@rrrrrrrrrrrrrrrrrrr;rrrrrBrH)r@rrrrrrrrrrrrrrrrrrrrr;rrrrrLrMrBrN)r@rrYrrZrr[r^r\r^r]r_rrrrrrrrrr;rrrrrBr` rrrarCrrrr;rBr rrrr rrCrirorBr rrrrCrirorBr rrrBr r@rrrrrrrrrrr;rrrrrBr r@rrrrrrrrrrr;rrrrrBr r@rrrrrrrrrrrrrrrrrrr;rrrrrBr ry)rlr=rBr=NNNrrrrrrrBrd)&rPrQrRrSrrrrmr#rr8r:rrrarrWrrr rrerErkrsr{rrrrrrrrrxrr __classcell__rLrLr(rMr<6sr1O  83*: / " ##!!!)))! % cseZdZdZddddddddddedeedddddddfd-d.Zdddddedfdd0d1Zdddddefdd3d4Z dd7d8Z ddddddde e e dd9 ddJdKZ e ddddddde e e dd9 ddMdNZe dOddddddde e e dedP ddTdUZe eeeedddde e e ddV dd_d`Zde e daddedfZddjdkZddldmZddndoZddde e e ddpddqdrZddde e e ddpddtduZddde e e ddpddvdwZddddddde e e dd9 ddxdyZddddddde e e dd9 ddzd{Zddddddde e e dd9 dd|d}Zddde e e ddpdd~dZ ddddddde e e dd9 dddZ!dddZ"dddZ#   ddddZ$Z%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)rrrrrrr r rr rrr rrrr rrrrrrrrrrrrrrr rCr rrr 5None | typing.Mapping[str, AsyncBaseTransport | None]rr3rr rrrrrrrr AsyncBaseTransport | NonerrrrBrdc stj||||| | ||||d r&zddl}Wn ty%tddwo+|du}| |}j|d_fdd|D_| durbj dd| Dt t j_dS)Nrrrrc rrrrrrLrMrrz(AsyncClient.__init__..cSrrLrrrLrLrMrrr)rlrrrrrrr r rr rrr rrrr rrr!rr'r(rrMrmsP      zAsyncClient.__init__r%cCr*rr#r,rLrLrMr#r-zAsyncClient._init_transportrc Cr.r/rr0rLrLrMr r1z!AsyncClient._init_proxy_transportr@r4cCr2r3r4r6rLrLrMr8!r9zAsyncClient._transport_for_urlr:rrrrrrrrrrrr;rrrr c  sT| durd}tj|tdd|j||||||||| | | d }|j|| | dIdHS)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 Nr<rZr=r?r@rArFrLrLrMr,s&" zAsyncClient.requestAsyncGenerator[Response]c  Csf|j||||||||| | | d }|j|| | ddIdH}z |VW|IdHdS|IdHwrI)rrEr~rJrLrLrMraes.  "zAsyncClient.streamrrKrLrMAsyncGenerator[EventSource]c Cs||j|||||||dddt|B| | | | | d 4IdH}t||dVWdIdHdS1IdHs7wYdS)rOrPrQrRr:NrTrUrVrLrLrMrWs&.zAsyncClient.sserXrYrZr[r^r\r]r_%AsyncGenerator[AsyncWebSocketSession]c Cszddlm}Wn tytdw|t|||||||||| | | | | d4IdH}|VWdIdHdS1IdHsBwYdS)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_wsrbrXN)rcrr"r)rlr@rYrZr[r\r]rrrrrrrrrdrLrLrMres6 .zAsyncClient.websocketrfrrrac s|jtjkr tdtj|_t|tr|jn|}||| ||}|j |||gdIdH}z |s:| IdH|WSt yQ}z | IdH|d}~ww)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 rgrhN)rrYr^rjr]r}rOrrrrkareadrmr~rnrLrLrMrEs,    zAsyncClient.sendr riroc s||}z^|IdH} |j|||dIdH}z4z ||IdH}Wnty9|YWW|IdHSwt||_|IdH|}| |Wnt yc}z |IdH|d}~wwq|IdHwrp) async_auth_flow __anext__rsasendStopAsyncIterationr~rrirrurmrvrLrLrMrk*s8      zAsyncClient._send_handling_authc s t||jkrtd|d|jdD] }||IdHq||IdH}z7|jdD] }||IdHq,t||_|jsA|WS|||}||g}|rV| IdHn||_ |WSWnt yr}z | IdH|d}~wwqry) rzrrrr{rrir|rrrxrmr~r}rLrLrMrsLs4    z$AsyncClient._send_handling_redirectscs||j}t}t|jtstdt|d| |IdH}Wdn1s-wYt|jts:J||_ t |j|d|_|j ||j|_td|j|j|j|j|j|S)rz>Attempted to send a sync request with an AsyncClient instance.rNrr)r8r@rvrwr}rar'rjrhandle_async_requestrrzrrrrrrrrrrrrLrLrMr{ps,     z AsyncClient._send_single_requestrc $|jd||||||||d IdHS)rrrNrrrLrLrMr zAsyncClient.getrc r)rrrNrrrLrLrMrrzAsyncClient.optionsc r)rrrNrrrLrLrMrrzAsyncClient.headc ,|jd||||||||| | | | d IdHS)rrr:NrrrLrLrMr  zAsyncClient.postc r)rrr:NrrrLrLrMr rzAsyncClient.putc r)rrr:NrrrLrLrMr/rzAsyncClient.patchc r)rrrNrrrLrLrMrTrzAsyncClient.deletec r)rrr:NrrrLrLrMrqrzAsyncClient.querycsT|jtjkr&tj|_|jIdH|jD]}|dur%|IdHqdSdSr)rrYr^r$r~r%r)rlrrLrLrMr~s zAsyncClient.acloserlr?csn|jtjkrtjdtjdi|j}t|tj|_|jIdH|j D] }|dur4|IdHq'|Sr) rrYr\r]r^rjr$ __aenter__r%r)rlrrrLrLrMrs zAsyncClient.__aenter__rrrrrrcsPtj|_|j|||IdH|jD]}|dur%||||IdHqdSrf)rYr^rr$ __aexit__r%r)rlrrrrrLrLrMrszAsyncClient.__aexit__)(rrrrrrrrrrrrr rCr rCrrr rrr3rrCr rrrrrrrr rrrCrrrBrd)rrrrrrCr rCr rCr rr rrBr%)rrrrrrrrCr rCr rCr rrBr%)r@r4rBr%r)rrr@rrrrrrrrrrrrrrrrrrr;rrrrrBr)r@rrrrrrrrrrrrrrrrrrrrr;rrrrrLrMrBr)r@rrYrrZrr[r^r\r^r]r_rrrrrrrrrr;rrrrrBrrrrrrrrry)rlr?rBr?rr)&rPrQrRrSrrrrmr#rr8r:rrrarrWrrr rrerErkrsr{rrrrrrrrr~rrrrLrLr(rMr;zsr2O  93*: / " $"!!!)))! % )r@r4rAr4rBrC)g __future__rrtenumloggingrvtypingrBcollections.abcrr contextlibrrtypesrr rr r r _configr rrrrrrrrrr _decodersr _exceptionsrrrr_modelsrrrr _sser! _status_codesr" _transportsr#r$_transports.baser%r&_typesr'r(r)r*r+r,r-r.r/r0r1r2r3_urlsr4r5_utilsr6r7 TYPE_CHECKINGsslrcr8r9__all__TypeVarr=r?rNrOr: getLoggerrrrkeysrEnumrYr`rzCallableAny EventHookrr<r;rLrLrLrMsf   4   <   J