U f@sTddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddl mZmZmZddlmZmZmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBmCZCddlDmEZEmFZFmGZGmHZHmIZIejJdddZKejJdddZLGdddZMeMZNeOdZPde ZQdRddeSDZTGd d!d!ejUZVGd"d#d#e=ZWGd$d%d%e1ZXejYd&ejZfZ[Gd'd(d(Z\Gd)dde\Z]Gd*dde\Z^dS)+) annotationsN)asynccontextmanagercontextmanager) TracebackType) __version__)Auth BasicAuth FunctionAuth)DEFAULT_LIMITSDEFAULT_MAX_REDIRECTSDEFAULT_TIMEOUT_CONFIGLimitsProxyTimeout)SUPPORTED_DECODERS) InvalidURLRemoteProtocolErrorTooManyRedirectsrequest_context)CookiesHeadersRequestResponse)codes) ASGITransport)AsyncBaseTransport BaseTransport)AsyncHTTPTransport HTTPTransport) WSGITransport)AsyncByteStream AuthTypes CertTypes CookieTypes HeaderTypes ProxiesTypes ProxyTypesQueryParamTypesRequestContent RequestDataRequestExtensions RequestFilesSyncByteStream TimeoutTypesURLTypes VerifyTypes)URL QueryParams)Timer URLPatternget_environment_proxiesis_https_redirect same_originTClient)boundU AsyncClientc@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__rBrBP/var/www/html/apigroqsegura/apigroq/lib/python3.8/site-packages/httpx/_client.pyr=Csr=httpxz python-httpx/z, cCsg|]}|dkr|qS)identityrB).0keyrBrBrC ^srHc@seZdZdZdZdZdS) ClientStaterN)r>r?r@UNOPENEDOPENEDCLOSEDrBrBrBrCrIbsrIc@s@eZdZdZdddddddZd d d d Zdd d dZdS)BoundSyncStreamz A byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. r-rr3NonestreamresponsetimerreturncCs||_||_||_dSN_stream _response_timerselfrRrSrTrBrBrC__init__vszBoundSyncStream.__init__ztyping.Iterator[bytes]rUccs|jD] }|VqdSrVrXr\chunkrBrBrC__iter__}s zBoundSyncStream.__iter__cCs(|j}tj|d|j_|jdSN)seconds)rZZ sync_elapseddatetime timedeltarYelapsedrXcloser\rdrBrBrCrhs zBoundSyncStream.closeN)r>r?r@rAr]rbrhrBrBrBrCrOpsrOc@s@eZdZdZdddddddZd d d d Zdd d dZdS)BoundAsyncStreamz An async byte stream that is bound to a given response instance, and that ensures the `response.elapsed` is set once the response is closed. r!rr3rPrQcCs||_||_||_dSrVrWr[rBrBrCr]szBoundAsyncStream.__init__ztyping.AsyncIterator[bytes]r^cCs |j2z3dHW}|Vq6dSrVr_r`rBrBrC __aiter__szBoundAsyncStream.__aiter__cs4|jIdH}tj|d|j_|jIdHdSrc)rZZ async_elapsedrerfrYrgrXacloserirBrBrCrlszBoundAsyncStream.acloseN)r>r?r@rAr]rkrlrBrBrBrCrjsrj.c@seZdZddddededdddd ddd d d d d ddd ddd ddZed dddZed dddZdddddZ dd dd d!d"Z ed#dd$d%Z e j d dd&d'd%Z ed(dd)d*Z e j d(dd+d,d*Z ed-dd.d/Zej d0dd1d2d/Zeddd3d4Zej dddd5d4Zed6dd7d8Zej d9dd:d;d8ZedZej d?dd@dAd>ZedBddCdDZej dEddFdGdDZdddddddeddH dIddJdKdLdMdd d dNdOdPdQ dRdSZddddTdUZdrd d d@dVdWZdsd d d:dXdYZdtdddFdZd[Zdd-d1d\d]ZefdPd^d_d`dadbZdPdcdPdddedfZdPdcdIdddgdhZdPdcddddidjZdPddId6dkdldmZdPdIdndodpdqZdS)u BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingAuthTypes | NoneQueryParamTypes | NoneHeaderTypes | NoneCookieTypes | Noner.boolint+None | typing.Mapping[str, list[EventHook]]r/#str | typing.Callable[[bytes], str]rP) rqrrrsrtrurvrwrxryrzr{rUc Cs|dkr in|}|t| |_|||_t||_t||_t ||_ t ||_ ||_ ||_t|dgt|dgd|_| |_| |_tj|_dSNrequestrS)rrS)_enforce_trailing_slashr1 _base_url _build_auth_authr2_paramsrrsr_cookiesr_timeoutrvrwlistget _event_hooks _trust_env_default_encodingrIrL_state) r\rqrrrsrtrurvrwrxryrzr{rBrBrCr]s     zBaseClient.__init__r^cCs |jtjkS)z2 Check if the client being closed )rrIrNr\rBrBrC is_closedszBaseClient.is_closedcCs|jSrV)rrrBrBrCrzszBaseClient.trust_envr1urlrUcCs"|jdr|S|j|jddS)N/raw_path)rendswith copy_withr\rrBrBrCrs z"BaseClient._enforce_trailing_slashProxiesTypes | Nonezdict[str, Proxy | None])proxiesallow_env_proxiesrUcCs|dkr$|r ddtDSiSt|trpi}|D]0\}}t|ttfrZt|dn|}||t|<q:|St|ttfrt|dn|}d|iSdS)NcSs(i|] \}}||dkrdnt|dqS)Nr)r)rFrGrrBrBrC sz-BaseClient._get_proxy_map..rzall://)r5items isinstancedictstrr1r)r\rrZ new_proxiesrGvalueproxyrBrBrC_get_proxy_maps zBaseClient._get_proxy_maprcCs|jSrV)rrrBrBrCruszBaseClient.timeout)rurUcCst||_dSrV)rr)r\rurBrBrCruszdict[str, list[EventHook]]cCs|jSrV)rrrBrBrCrxszBaseClient.event_hooks)rxrUcCs(t|dgt|dgd|_dSr)rrr)r\rxrBrBrCrxsz Auth | NonecCs|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrrBrBrCrqs zBaseClient.authr")rqrUcCs|||_dSrV)rrr\rqrBrBrCrqscCs|jS)zK Base URL to use when sending requests with relative URLs. )rrrBrBrCry szBaseClient.base_urlcCs|t||_dSrV)rr1rrrBrBrCrysrcCs|jS)z@ HTTP headers to include when sending requests. )_headersrrBrBrCrsszBaseClient.headersr%)rsrUcCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)r\rsZclient_headersrBrBrCrss rcCs|jS)zA Cookie values to include when sending requests. )rrrBrBrCrt)szBaseClient.cookiesr$)rtrUcCst||_dSrV)rr)r\rtrBrBrCrt0sr2cCs|jS)zO Query parameters to include in the URL when sending requests. )rrrBrBrCrr4szBaseClient.paramsr()rrrUcCst||_dSrV)r2r)r\rrrBrBrCrr;s) contentdatafilesjsonrrrsrtru extensionsrRequestContent | NoneRequestData | NoneRequestFiles | Nonetyping.Any | NoneTimeoutTypes | UseClientDefaultRequestExtensions | Noner) methodrrrrrrrrsrtrurrUc Cs||}||}|| } ||}| dkr4in| } d| krnt| trP|jnt| } tf| d| i} t ||||||||| | d S)aJ Build and return a request instance. * The `params`, `headers` and `cookies` arguments are merged with any values set on the client. * The `url` argument is merged with any `base_url` set on the client. See also: [Request instances][0] [0]: /advanced/#request-instances Nru)rrrrrrrsrtr) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr=rurras_dictr) r\rrrrrrrrrsrtrurrBrBrC build_request?s.    zBaseClient.build_requestcCs4t|}|jr0|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)r1is_relative_urlryrlstripr)r\rZ merge_urlZmerge_raw_pathrBrBrCrrs  zBaseClient._merge_urlcCs&|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. )rtrr)r\rtZmerged_cookiesrBrBrCrs    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. )rrsr)r\rsZmerged_headersrBrBrCrs  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. )rrr2merge)r\rrZmerged_queryparamsrBrBrCrs   zBaseClient._merge_queryparamscCs\|dkr dSt|tr*t|d|ddSt|tr8|St|rJt|dStd|dS)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler rcallabler TypeErrorrrBrBrCrs   zBaseClient._build_auth#AuthTypes | UseClientDefault | Noner)rrqrUcCsRt|tr|jn||}|dk r&|S|jj|jj}}|s@|rLt||dStS)Nr) rr=rrrrrr r)r\rrqrrrBrBrC_build_request_auths zBaseClient._build_request_authr)rrSrUcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrsrtrRr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrtrr)r\rrSrrrsrRrtrBrBrC_build_redirect_requests    z"BaseClient._build_redirect_requestcCsR|j}|jtjkr|dkrd}|jtjkr6|dkr6d}|jtjkrN|dkrNd}|S)z When being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOST)r status_coder SEE_OTHERFOUNDMOVED_PERMANENTLY)r\rrSrrBrBrCrszBaseClient._redirect_methodc Cs|jd}z t|}Wn8tk rN}ztd|d|ddW5d}~XYnX|jrl|jsl|j|jjd}|jr~|j |}|jj r|j s|j|jj d}|S)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)host)fragment) rsr1rrschemerrrrjoinr)r\rrSlocationrexcrBrBrCrs"     zBaseClient._redirect_url)rrrrUcCsxt|j}t||js>t|j|s.|dd|jd|d<||jkrh|dkrh|dd|dd|dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrsr7rr6popnetlocdecoder)r\rrrrsrBrBrCr s       zBaseClient._redirect_headersz'SyncByteStream | AsyncByteStream | None)rrrUcCs||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrR)r\rrrBrBrCr(szBaseClient._redirect_stream)N)N)N) r>r?r@r r r]propertyrrzrrrusetterrxrqryrsrtrrUSE_CLIENT_DEFAULTrrrrrrrrrrrrrBrBrBrCrms("  (3   rmcs~eZdZdZdddddddddddedeeddddddddd d d d d dddddddddddddddddfddZddddedddfd d dddddddd d d!Zddddedfd"d d dddddd#d$d%Z d&dd'd(d)Z ddddddde e e dd* d+dd,d-d.d/d d d d0d1d2d3d4d5d6d7Z e ddddddde e e dd* d+dd,d-d.d/d d d d0d1d2d3d8d5d9d:Zde e d;dd?Zd>> client = httpx.Client() >>> response = client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **proxies** - *(optional)* A dictionary mapping proxy keys to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An WSGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrnrorqrrrsrtverifycerthttp1http2rrmountsrurvlimitsrwrxry transportapprzr{r|r}r~rr0CertTypes | NonerProxyTypes | Nonerz0None | typing.Mapping[str, BaseTransport | None]r.rrrr/zBaseTransport | None'typing.Callable[..., typing.Any] | NonerrPrqrrrsrtrrrrrrrrurvrrwrxryrrrzr{rUc s&tj||||| | ||||d rRz ddl}Wntk rPtddYnX| rrd}t|t| rrtd|rd}t|to|dko|dk}| p| |}j ||d_ fdd | D_ | dk rj d d | Dttj _ dS) NrpruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.JThe 'proxies' argument is now deprecated. Use 'proxy' or 'mounts' instead.*Use either `proxy` or 'proxies', not both.zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=WSGITransport(app=...)' instead.rrrrrrrrzc s:i|]2\}}t||dkrdnj|dqSNrrrrrrzr4_init_proxy_transportrFrGrrrrrr\rzrrBrCrs z#Client.__init__..cSsi|]\}}t||qSrBr4rFrGrrBrBrCrssuperr]h2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportr_mountsrrsortedr\rqrrrsrtrrrrrrrrurvrrwrxryrrrzr{rmessagerZ proxy_map __class__rrCr]jsh      zClient.__init__r rrrrrrrrzrUc Cs2|dk r |S|dk rt|dSt||||||dSN)rr)r r r\rrrrrrrrzrBrBrCr s  zClient._init_transportrrrrrrrrzrUc Cst|||||||dSN)rrrrrrzr)rr\rrrrrrrzrBrBrCrs zClient._init_proxy_transportr1rcCs:|jD](\}}||r |dkr*|jn|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. Nrrmatchesrr\rpatternrrBrBrC_transport_for_urls zClient._transport_for_url rrrrrrrsrtrqrvrurrrrrrrbool | UseClientDefaultrrrrrrrrrrrrsrtrqrvrurrUc  CsH| dk rd}t|t|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/#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. rrrrrrrrrsrtrurrqrvr r r rsendr\rrrrrrrrrsrtrqrvrurrrrBrBrCrs$!  zClient.requestztyping.Iterator[Response]c  csL|j||||||||| | | d }|j|| | dd}z |VW5|XdSa  Alternative to `httpx.request()` that streams the response body instead of loading it into memory at once. **Parameters**: See `httpx.request`. See also: [Streaming Responses][0] [0]: /quickstart#streaming-responses r%T)rrqrvrRN)rr(rhr\rrrrrrrrrsrtrqrvrurrrSrBrBrCrR=s,  z Client.streamrRrqrvrrrRrqrvrUc Cs|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gd}z|s\| |WSt k r}z| |W5d}~XYnXdS)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/#request-instances 5Cannot send a request, as the client has been closed.rqrvhistoryN) rrIrNr rMrr=rvr_send_handling_authread BaseExceptionrhr\rrRrqrvrSrrBrBrCr(qs*  z Client.sendrlist[Response]rrqrvr0rUc Cs||}zt|}|j|||d}zRz||}Wntk rR|YWW\SXt||_||}| |Wqt k r}z||W5d}~XYqXqW5|XdSN)rvr0) Zsync_auth_flowrhnext_send_handling_redirectsr( StopIterationrr0r2appendr3 r\rrqrvr0Z auth_flowrS next_requestrrBrBrCr1s*  zClient._send_handling_authrrvr0rUc Cst||jkrtd|d|jdD] }||q$||}zb|jdD] }||qHt||_|jsl|WS|||}||g}|r| n ||_ |WSWqt k r}z| |W5d}~XYqXqdSNz#Exceeded maximum allowed redirects.rrrS) lenrwrr_send_single_requestrr0has_redirect_locationrr2r=r3rhr\rrvr0hookrSrrBrBrCr9s.        zClient._send_handling_redirectsrrUc Cs||j}t}|t|jts.tdt|d| |}W5QRXt|jts^t ||_ 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.rrSrTHTTP Request: %s %s "%s %d %s")r rr3Z sync_startrrRr-r rhandle_requestAssertionErrorrrOrtextract_cookiesrr{loggerinfor http_versionr reason_phraser\rrrTrSrBrBrCrAs6     zClient._send_single_requestrrrsrtrqrvrurAuthTypes | UseClientDefault rrrrsrtrqrvrurrUc Cs|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrQr r\rrrrsrtrqrvrurrBrBrCr sz Client.getc Cs|jd||||||||d S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrQrrUrBrBrCoptions*szClient.optionsc Cs|jd||||||||d S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrQrrUrBrBrCheadGsz Client.head rrrrrrrrsrtrqrvrurrUc Cs$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rr!r r\rrrrrrrrsrtrqrvrurrBrBrCpostdsz Client.postc Cs$|jd||||||||| | | | d S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTr!rr]rBrBrCputsz Client.putc Cs$|jd||||||||| | | | d S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHr!rr]rBrBrCpatchsz Client.patchc Cs|jd||||||||d S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErQrrUrBrBrCdeletesz Client.deleter^cCsB|jtjkr>tj|_|j|jD]}|dk r(|q(dSz. Close transport and proxies. N)rrIrNrrhrvalues)r\rrBrBrCrhs   z Client.closer8r\rUcCs`|jtjkr*tjdtjdi|j}t|tj|_|j|j D]}|dk rF|qF|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrIrLrMrNr r __enter__rri)r\msgrrBrBrCrls   zClient.__enter__type[BaseException] | NoneBaseException | NoneTracebackType | Noneexc_type exc_value tracebackrUcCsBtj|_|j||||jD]}|dk r"||||q"dSrV)rIrNrr__exit__rri)r\rrrsrtrrBrBrCrus zClient.__exit__)NNN)r>r?r@rAr r r r]r rr rrrrRr(r1r9rArrXrZr^rardrgrhrlru __classcell__rBrBrrCr94s$8@d ,8.71"%("!"!"!*)*)*)" cs~eZdZdZdddddddddddedeeddddddddd d d d d dddddddddddddddddfddZddddedddfd d dddddddd d d!Zddddedfd"d d dddddd#d$d%Z d&dd'd(d)Z ddddddde e e dd* d+dd,d-d.d/d d d d0d1d2d3d4d5d6d7Z e ddddddde e e dd* d+dd,d-d.d/d d d d8d1d2d3d9d5d:d;Zde e d<d=dd0d1d4d>d?d@Zd=dAddBd4dCdDdEZd=ddBd4dFdGdHZd=d4dIdJdKZddde e e ddLdd d d d0d1d2d3d4dM dNdOZddde e e ddLdd d d d8d1d2d3d4dM dPdQZddde e e ddLdd d d d8d1d2d3d4dM dRdSZddddddde e e dd* dd,d-d.d/d d d d8d1d2d3d4dT dUdVZddddddde e e dd* dd,d-d.d/d d d d8d1d2d3d4dT dWdXZddddddde e e dd* dd,d-d.d/d d d d8d1d2d3d4dT dYdZZddde e e ddLdd d d d8d1d2d3d4dM d[d\Zdd]d^d_Zd`d`dadbdcZdjdddedfddgdhdiZZS)kr<a An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between tasks. Usage: ```python >>> async with httpx.AsyncClient() as client: >>> response = await client.get('https://example.org') ``` **Parameters:** * **auth** - *(optional)* An authentication class to use when sending requests. * **params** - *(optional)* Query parameters to include in request URLs, as a string, dictionary, or sequence of two-tuples. * **headers** - *(optional)* Dictionary of HTTP headers to include when sending requests. * **cookies** - *(optional)* Dictionary of Cookie items to include when sending requests. * **verify** - *(optional)* SSL certificates (a.k.a CA bundle) used to verify the identity of requested hosts. Either `True` (default CA bundle), a path to an SSL certificate file, an `ssl.SSLContext`, or `False` (which will disable verification). * **cert** - *(optional)* An SSL certificate used by the requested host to authenticate the client. Either a path to an SSL certificate file, or two-tuple of (certificate file, key file), or a three-tuple of (certificate file, key file, password). * **http2** - *(optional)* A boolean indicating if HTTP/2 support should be enabled. Defaults to `False`. * **proxy** - *(optional)* A proxy URL where all the traffic should be routed. * **proxies** - *(optional)* A dictionary mapping HTTP protocols to proxy URLs. * **timeout** - *(optional)* The timeout configuration to use when sending requests. * **limits** - *(optional)* The limits configuration to use. * **max_redirects** - *(optional)* The maximum number of redirect responses that should be followed. * **base_url** - *(optional)* A URL to use as the base when building request URLs. * **transport** - *(optional)* A transport class to use for sending requests over the network. * **app** - *(optional)* An ASGI application to send requests to, rather than sending actual network requests. * **trust_env** - *(optional)* Enables or disables usage of environment variables for configuration. * **default_encoding** - *(optional)* The default encoding to use for decoding response text, if no charset information is included in a response Content-Type header. Set to a callable for automatic character set detection. Default: "utf-8". NTFrnrorr|r}r~rr0rrrrz5None | typing.Mapping[str, AsyncBaseTransport | None]r.rrzBNone | typing.Mapping[str, list[typing.Callable[..., typing.Any]]]r/zAsyncBaseTransport | NonerrrPrc stj||||| | ||||d rRz ddl}Wntk rPtddYnX| rrd}t|t| rrtd|rd}t|to|dk}| p| |}j ||d_ fdd | D_ | dk rj d d | Dttj _ dS) NrprrrrzhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.rc s:i|]2\}}t||dkrdnj|dqSrrrrrBrCrs z(AsyncClient.__init__..cSsi|]\}}t||qSrBrrrBrBrCrsrrrrrCr]Ssh       zAsyncClient.__init__rrc Cs2|dk r |S|dk rt|dSt||||||dSr)rrrrBrBrCr s  zAsyncClient._init_transportrrc Cst|||||||dSr)rrrBrBrCrs z!AsyncClient._init_proxy_transportr1rcCs:|jD](\}}||r |dkr*|jn|Sq |jSrrrrBrBrCr s zAsyncClient._transport_for_urlr!rrrrrrr"rrrr#c  sN| dk rd}t|t|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/#merging-of-configuration Nr$r%r&r'r)rBrBrCrs$"  zAsyncClient.requestrRztyping.AsyncIterator[Response]c  CsX|j||||||||| | | d }|j|| | ddIdH}z |VW5|IdHXdSr*)rr(rlr+rBrBrCrR(s,   zAsyncClient.streamr,rr-c s|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gdIdH}z|sh| IdH|WSt k r}z| IdH|W5d}~XYnXdS)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/#request-instances r.r/N) rrIrNr rMrr=rvrr1areadr3rlr4rBrBrCr(\s*   zAsyncClient.sendrr5r6c s||}z|IdH}|j|||dIdH}z^z||IdH}Wntk rd|YWWhSXt||_|IdH|}| |Wqt k r}z|IdH|W5d}~XYqXqW5|IdHXdSr7) Zasync_auth_flowrl __anext__r9asendStopAsyncIterationrr0rwr;r3r<rBrBrCr1s*   zAsyncClient._send_handling_authr>c st||jkrtd|d|jdD]}||IdHq$||IdH}zn|jdD]}||IdHqTt||_|js~|WS|||}||g}|r| IdHn ||_ |WSWqt k r}z| IdH|W5d}~XYqXqdSr?) r@rwrrrArr0rBrrwr=r3rlrCrBrBrCr9s.    z$AsyncClient._send_handling_redirectsrEc s||j}t}|IdHt|jts4tdt|d| |IdH}W5QRXt|jtsjt ||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)rFNz?Attempted to send an sync request with an AsyncClient instance.rrGrH)r rr3Z async_startrrRr!r rZhandle_async_requestrJrrjrtrKrr{rLrMrrNrrOrPrBrBrCrAs6     z AsyncClient._send_single_requestrQrSc s"|jd||||||||d IdHS)rTrrQNrrUrBrBrCrszAsyncClient.getc s"|jd||||||||d IdHS)rVrWrQNrrUrBrBrCrXszAsyncClient.optionsc s"|jd||||||||d IdHS)rYrrQNrrUrBrBrCrZ2szAsyncClient.headr[c s*|jd||||||||| | | | d IdHS)r\rr!Nrr]rBrBrCr^OszAsyncClient.postc s*|jd||||||||| | | | d IdHS)r_r`r!Nrr]rBrBrCratszAsyncClient.putc s*|jd||||||||| | | | d IdHS)rbrcr!Nrr]rBrBrCrdszAsyncClient.patchc s"|jd||||||||d IdHS)rerfrQNrrUrBrBrCrgszAsyncClient.deleter^csN|jtjkrJtj|_|jIdH|jD]}|dk r.|IdHq.dSrh)rrIrNrrlrri)r\rrBrBrCrls  zAsyncClient.acloser;rjcsl|jtjkr*tjdtjdi|j}t|tj|_|jIdH|j D]}|dk rL|IdHqL|Srk) rrIrLrMrNr r __aenter__rri)r\rmrrBrBrCr{s zAsyncClient.__aenter__rnrorprqcsNtj|_|j|||IdH|jD] }|dk r(||||IdHq(dSrV)rIrNrr __aexit__rri)r\rrrsrtrrBrBrCr|s zAsyncClient.__aexit__)NNN)r>r?r@rAr r r r]r rr rrrrRr(r1r9rArrXrZr^rardrgrlr{r|rvrBrBrrCr<s$9@e ,9.71"&'"!"!"!*)*)*)" )_ __future__rreenumloggingtypingr  contextlibrrtypesrrrrr r _configr r r rrrZ _decodersr _exceptionsrrrr_modelsrrrr _status_codesr_transports.asgir_transports.baserr_transports.defaultrr_transports.wsgir _typesr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0_urlsr1r2_utilsr3r4r5r6r7TypeVarr8r;r=r getLoggerrLrrkeysrEnumrIrOrjCallableAnyZ EventHookrmr9r<rBrBrBrCsZ        H   m