a |f; @sDddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z ddl m Z m Z mZddlmZmZmZmZmZmZddlmZdd lmZmZmZmZdd lmZmZm Z m!Z!dd l"m#Z#dd l$m%Z%dd l&m'Z'm(Z(ddl)m*Z*m+Z+ddl,m-Z-ddl.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mm?Z?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFejGdddZHejGdddZIGdddZJeJZKeLdZMde ZNdOddePDZQGdd d ejRZSGd!d"d"e:ZTGd#d$d$e/ZUejVd%ejWfZXGd&d'd'ZYGd(ddeYZZGd)ddeYZ[dS)*N)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 ProxiesTypesQueryParamTypesRequestContent 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__r@r@GD:\Projects\storyit_web\backend\venv\Lib\site-packages\httpx/_client.pyr;@sr;Zhttpxz python-httpx/z, cCsg|]}|dkr|qS)identityr@).0keyr@r@rA [rEc@seZdZdZdZdZdS) ClientStaterN)r<r=r>UNOPENEDOPENEDCLOSEDr@r@r@rArG_srGc@sFeZdZdZeeeddddZej e dddZ ddd d Z dS) 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. NstreamresponsetimerreturncCs||_||_||_dSN_stream _response_timerselfrOrPrQr@r@rA__init__sszBoundSyncStream.__init__rRccs|jD] }|VqdSrSrUrYchunkr@r@rA__iter__zs zBoundSyncStream.__iter__cCs(|j}tj|d|j_|jdSN)seconds)rWZ sync_elapseddatetime timedeltarVelapsedrUcloserYrar@r@rAre~s zBoundSyncStream.close) r<r=r>r?r+rr1rZtypingIteratorbytesr_rer@r@r@rArMms  rMc@sFeZdZdZeeeddddZej e dddZ ddd d Z dS) 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. NrNcCs||_||_||_dSrSrTrXr@r@rArZszBoundAsyncStream.__init__r[cCs |j2z3dHW}|Vq6dSrSr\r]r@r@rA __aiter__szBoundAsyncStream.__aiter__cs4|jIdH}tj|d|j_|jIdHdSr`)rWZ async_elapsedrbrcrVrdrUacloserfr@r@rArlszBoundAsyncStream.aclose) r<r=r>r?r rr1rZrg AsyncIteratorrirkrlr@r@r@rArjs  rj.c@seZdZddddededdddd ejeejeeje eje e e e ejejeejefee ejeejegeffdd dd Zee d d d Zee d d dZeedddZejee ejeejefdddZee d ddZ!e!j"e ddddZ!eejeejefd ddZ#e#j"ejeejefddddZ#eeje$d ddZ%e%j"eddd dZ%eed d!d"Z&e&j"eddd#d"Z&ee'd d$d%Z(e(j"e dd&d'd%Z(ee)d d(d)Z*e*j"e dd*d+d)Z*ee+d d,d-Z,e,j"edd.d/d-Z,ddddddde-dd0 eeeje.eje/eje0ejej1ejeeje eje eje e2feje3e4d1 d2d3Z5eedd4d5Z6dNeje eje d*d6d7Z7dOeje eje d&d8d9Z8dPejeejed.d:d;Z9ejeeje$ddd?d@Z;e4ee4esz-BaseClient._get_proxy_map..rzall://)r3items isinstancedictstrr/r)rYrr new_proxiesrDvalueproxyr@r@rA_get_proxy_maps zBaseClient._get_proxy_mapcCs|jSrS)rrr@r@rArvszBaseClient.timeout)rvrRcCst||_dSrS)rr)rYrvr@r@rArvscCs|jSrS)rrr@r@rAryszBaseClient.event_hooks)ryrRcCs(t|dgt|dgd|_dSr})rrr)rYryr@r@rAryscCs|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrr@r@rArrs zBaseClient.auth)rrrRcCs|||_dSrS)rrrYrrr@r@rArrscCs|jS)zK Base URL to use when sending requests with relative URLs. )rrr@r@rArz szBaseClient.base_urlcCs|t||_dSrS)rr/rrr@r@rArzscCs|jS)z@ HTTP headers to include when sending requests. )_headersrr@r@rArtszBaseClient.headers)rtrRcCs2tdtddtdd}||||_dS)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rYrtZclient_headersr@r@rArts cCs|jS)zA Cookie values to include when sending requests. )rrr@r@rAru*szBaseClient.cookies)rurRcCst||_dSrS)rr)rYrur@r@rAru1scCs|jS)zO Query parameters to include in the URL when sending requests. )rrr@r@rArs5szBaseClient.params)rsrRcCst||_dSrS)r0r)rYrsr@r@rArs<s) contentdatafilesjsonrsrtrurv extensions) methodrrrrrrsrtrurvrrRc Cs||}||}|| } ||}| dur4in| } d| vrrt| trP|jnt| } tfi| 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 Nrv)rrrrrsrtrur) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr;rvrras_dictr) rYrrrrrrrsrtrurvrr@r@rA 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)r/is_relative_urlrzrlstripr)rYrZ merge_urlZmerge_raw_pathr@r@rArss  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. )rurr)rYrumerged_cookiesr@r@rArs    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. )rrtr)rYrtZmerged_headersr@r@rArs  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. )rsr0merge)rYrsZmerged_queryparamsr@r@rArs   zBaseClient._merge_queryparamscCs\|dur dSt|tr*t|d|ddSt|tr8|St|rJt|dStd|dS)Nrrusernamepassword)funczInvalid "auth" argument: )rtuplerrcallabler TypeErrorrr@r@rArs   zBaseClient._build_auth)r~rrrRcCsRt|tr|jn||}|dur&|S|jj|jj}}|s@|rLt||dStS)Nr) rr;rrrrrrr)rYr~rrrrr@r@rA_build_request_auths zBaseClient._build_request_auth)r~rPrRcCsR|||}|||}||||}|||}t|j}t||||||jdS)z Given a request and a redirect response, return a new request that should be used to effect the redirect. )rrrtrurOr)_redirect_method _redirect_url_redirect_headers_redirect_streamrrurr)rYr~rPrrrtrOrur@r@rA_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)rYr~rPrr@r@rArszBaseClient._redirect_methodc Cs|jd}z t|}Wn:tyP}z"td|d|ddWYd}~n d}~00|jrn|jsn|j|jjd}|jr|j |}|jj r|j s|j|jj d}|S)z< Return the URL for the redirect to follow. ZLocationz Invalid URL in location header: .r~N)host)fragment) rtr/rrschemerrrrjoinr)rYr~rPlocationrexcr@r@rArs      zBaseClient._redirect_url)r~rrrRcCsxt|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) rrtr5rr4popnetlocdecoder)rYr~rrrtr@r@rArs       zBaseClient._redirect_headers)r~rrRcCs||jkr|dkrdS|jS)zO Return the body that should be used for the redirect request. rN)rrO)rYr~rr@r@rAr-szBaseClient._redirect_stream)N)N)N)Dr<r=r>r r rgOptionalr!r&r$r#r,boolintMappingrList EventHookr-UnionCallablerirZpropertyrr{r/rr%Dictrrrrvsetterryrrrrzrrtrrur0rsUSE_CLIENT_DEFAULTr'r(r*Anyr;r)rrrrrrrrrrrrrr+r rr@r@r@rArns $        3    rncseZdZdZddddddddddedeedddddddeje eje eje eje e ejeeeejeejejeefeeeeejejeejefeejeejejdejfeejeejegeffdd fd d Zddddedddfe ejeeeeejeejejdejfeed d dZddddedfe e ejeeeeeedddZ!e"edddZ#ddddddde$e$e$dd eeeje%eje&eje'ejejeje eje eje eje e(dfejee(fejee(feje)e*dddZ+e,ddddddde$e$e$dd eeeje%eje&eje'ejejeje eje eje eje e(dfejee(fejee(feje)ej-e*dddZ.de$e$de/eeje e(dfejee(fe*dddZ0e/e1eeje*e*dd d!Z2e/eeje*e*d"d#d$Z3e/e*d%d&d'Z4ddde$e$e$dd(eeje eje eje eje e(fejee(fejee(feje)e*d) d*d+Z5ddde$e$e$dd(eeje eje eje eje e(fejee(fejee(feje)e*d) d,d-Z6ddde$e$e$dd(eeje eje eje eje e(fejee(fejee(feje)e*d) d.d/Z7ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d0 d1d2Z8ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d0 d3d4Z9ddddddde$e$e$dd eeje%eje&eje'ejejeje eje eje eje e(fejee(fejee(feje)e*d0 d5d6Z:ddde$e$e$dd(eeje eje eje eje e(fejee(fejee(feje)e*d) d7d8Z;dd9d:d;ZZ>dBejej?e@eje@ejeAdd?d@dAZBZCS)Cr7a An HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. It can be shared between threads. Usage: ```python >>> 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). * **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". NTFrorprrrsrtruverifycerthttp1http2rmountsrvrwlimitsrxryrz transportappr{r|.rrrsrtrurrrrrrrvrwrrxryrzrrr{r|rRc stj||||| | ||||d rPz ddl}WntyNtddYn0ob|duob|du}| |}j||d_fdd|D_| dur҈j dd| Dt t j_dS)NrqruUsing http2=True, but the 'h2' package is not installed. Make sure to install httpx using `pip install httpx[http2]`.rrrrrrrr{c s:i|]2\}}t||durdnj|dqSNrrrrrr{r2_init_proxy_transportrCrDrrrrrrYr{rr@rArs z#Client.__init__..cSsi|]\}}t||qSr@r2rCrDrr@r@rArrF superrZh2 ImportErrorr_init_transport _transportr_mountsrrsortedrYrrrsrtrurrrrrrrvrwrrxryrzrrr{r|rrZ proxy_map __class__rrArZlsT     zClient.__init__ rrrrrrrr{rRc Cs2|dur |S|durt|dSt||||||dSN)rr)rr rYrrrrrrrr{r@r@rArs  zClient._init_transportrrrrrrr{rRc Cst|||||||dS)N)rrrrrr{r)rrYrrrrrrr{r@r@rArs zClient._init_proxy_transportrcCs:|jD](\}}||r |dur*|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. NrrmatchesrrYrpatternrr@r@rA_transport_for_urls zClient._transport_for_url rrrrrsrtrurrrwrvrrrrrrrrsrtrurrrwrvrrRc  CsH| durd}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 NzSetting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrrsrtrurvrrrrw)warningswarnDeprecationWarningrsend)rYrrrrrrrsrtrurrrwrvrmessager~r@r@rAr~s$!  zClient.requestc  csT|j||||||||| | | d }|j|| | dd}z|VW|n |0dSa  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 rT)r~rrrwrON)rrrerYrrrrrrrsrtrurrrwrvrr~rPr@r@rArO0s, z Client.streamrOrrrwr~rOrrrwrRc Cs|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gd}z|s\| |WSt y}z| |WYd}~n d}~00dS)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.rrrwhistoryN) rrGrL RuntimeErrorrKrr;rwr_send_handling_authread BaseExceptionrerYr~rOrrrwrPrr@r@rArds*  z Client.sendr~rrrwr!rRc Cs||}zt|}|j|||d}zVz||}Wn"tyV|YWW|S0t||_||}| |Wqt y}z||WYd}~qd}~00qW|n |0dSN)rwr!) Zsync_auth_flownext_send_handling_redirectsr StopIterationrerr!r$appendr% rYr~rrrwr!Z auth_flowrP next_requestrr@r@rAr#s.    zClient._send_handling_authr~rwr!rRc Cst||jkrtd|d|jdD] }||q$||}zb|jdD] }||qHt||_|jsl|WS|||}||g}|r| n ||_ |WSWqt y}z| |WYd}~qd}~00qdSNz#Exceeded maximum allowed redirects.rr~rP) lenrxrr_send_single_requestrr!has_redirect_locationrr$r.r%rerYr~rwr!hookrPrr@r@rAr*s,        zClient._send_handling_redirectsr~rRcCs||j}t}|t|jts.tdt|d| |}Wdn1sX0Yt|jtsrJ||_ 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.rNrPrQHTTP Request: %s %s "%s %d %s")rrr1Z sync_startrrOr+r"rhandle_requestr~rMruextract_cookiesrr|loggerinfor http_versionr reason_phraserYr~rrQrPr@r@rAr2s2   (  zClient._send_single_requestrsrtrurrrwrvr rrsrtrurrrwrvrrRc Cs|jd||||||||d S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrAr rYrrsrtrurrrwrvrr@r@rArsz Client.getc Cs|jd||||||||d S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrArrDr@r@rAoptionsszClient.optionsc Cs|jd||||||||d S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrArrDr@r@rAhead:sz Client.head rrrrrrsrtrurrrwrvrrRc Cs$|jd||||||||| | | | d S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrr rYrrrrrrsrtrurrrwrvrr@r@rApostWsz Client.postc Cs$|jd||||||||| | | | d S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrrrLr@r@rAput|sz Client.putc Cs$|jd||||||||| | | | d S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrrrLr@r@rApatchsz Client.patchc Cs|jd||||||||d S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErArrDr@r@rAdeletesz Client.deleter[cCsB|jtjkr>tj|_|j|jD]}|dur(|q(dSz. Close transport and proxies. N)rrGrLrrervalues)rYrr@r@rAres   z Client.closerYrRcCs`|jtjkr*tjdtjdi|j}t|tj|_|j|j D]}|durF|qF|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrGrJrKrLr"r __enter__rrX)rYmsgrr@r@rAr[s   zClient.__enter__exc_type exc_value tracebackrRcCsBtj|_|j||||jD]}|dur"||||q"dSrS)rGrLrr__exit__rrX)rYr^r_r`rr@r@rAras zClient.__exit__)NNN)Dr<r=r>r?r r r rgrr!r&r$r#r.r"rr%rrrr,r rrrr-rrrrirZrrrr/rrr'r(r*r;r)rr~rrhrOrrrr#r*r2rrGrIrMrPrSrVrer6r[Typer%rra __classcell__r@r@rrAr79s5U      8   7  3 $ %(    !    !    !     )     )     )     cseZdZdZddddddddddedeedddddddeje eje eje eje e ejeeeejeejejeefeeeeejejeejejdejffeejeejejdejfeejeejegeffdd fd d Zddddedddfe ejeeeeejeejejdejfeed d dZddddedfee ejeeeeeedddZ e!edddZ"ddddddde#e#e#dd eeeje$eje%eje&ejejeje eje eje eje e'dfejee'fejee'feje(e)dddZ*e+ddddddde#e#e#dd eeeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(ej,e)dddZ-de#e#de.eeje e'dfejee'fe)dddZ/e.e0eeje)e)dd d!Z1e.eeje)e)d"d#d$Z2e.e)d%d&d'Z3ddde#e#e#dd(eeje eje eje eje e'dfejee'fejee'feje(e)d) d*d+Z4ddde#e#e#dd(eeje eje eje eje e'fejee'fejee'feje(e)d) d,d-Z5ddde#e#e#dd(eeje eje eje eje e'fejee'fejee'feje(e)d) d.d/Z6ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d0 d1d2Z7ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d0 d3d4Z8ddddddde#e#e#dd eeje$eje%eje&ejejeje eje eje eje e'fejee'fejee'feje(e)d0 d5d6Z9ddde#e#e#dd(eeje eje eje eje e'fejee'fejee'feje(e)d) d7d8Z:dd9d:d;Z;eZ=dBejej>e?eje?eje@dd?d@dAZAZBS)Cr:aC An asynchronous HTTP client, with connection pooling, HTTP/2, redirects, cookie persistence, etc. 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`. * **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". NTFrorpr.rc stj||||| | ||||d rPz ddl}WntyNtddYn0ob|duob|du}| |}j||d_fdd|D_| dur҈j dd| Dt t j_dS)Nrqrrrc s:i|]2\}}t||durdnj|dqSrrrrr@rArs z(AsyncClient.__init__..cSsi|]\}}t||qSr@rrr@r@rArrFrrrrrArZAsT     zAsyncClient.__init__rc Cs2|dur |S|durt|dSt||||||dSr)rrr r@r@rArs  zAsyncClient._init_transportr cCst||||||dS)N)rrrrr{r)rr r@r@rArs z!AsyncClient._init_proxy_transportrcCs:|jD](\}}||r |dur*|jn|Sq |jSr r rr@r@rArs zAsyncClient._transport_for_urlrrc  s6|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 rrN)rr)rYrrrrrrrsrtrurrrwrvrr~r@r@rAr~s! zAsyncClient.requestc  Csf|j||||||||| | | d }|j|| | ddIdH}z|VW|IdHn|IdH0dSr)rrrlrr@r@rArOs,  zAsyncClient.streamrrc s|jtjkrtdtj|_t|tr,|jn|}|||}|j |||gdIdH}z|sh| IdH|WSt y}z| IdH|WYd}~n d}~00dS)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 rr N) rrGrLr"rKrr;rwrr#areadr%rlr&r@r@rAr0s*   zAsyncClient.sendr'c s||}z|IdH}|j|||dIdH}zhz||IdH}Wn(tyn|YWW|IdHS0t||_|IdH|}| |Wqt y}z|IdH|WYd}~qd}~00qW|IdHn|IdH0dSr() Zasync_auth_flow __anext__r*asendStopAsyncIterationrlrr!rdr,r%r-r@r@rAr#as.     zAsyncClient._send_handling_authr/c st||jkrtd|d|jdD]}||IdHq$||IdH}zn|jdD]}||IdHqTt||_|js~|WS|||}||g}|r| IdHn ||_ |WSWqt y}z| IdH|WYd}~qd}~00qdSr0) r1rxrrr2rr!r3rrdr.r%rlr4r@r@rAr*s,    z$AsyncClient._send_handling_redirectsr6cs||j}t}|IdHt|jts4tdt|d | |IdH}Wdn1sd0Yt|jts~J||_ t |j||d|_|j ||j|_td|j|j|j|j|j|S)r7Nz?Attempted to send an sync request with an AsyncClient instance.rr8r9)rrr1Z async_startrrOr r"rZhandle_async_requestr~rjrur;rr|r<r=rr>rr?r@r@r@rAr2s2   .  z AsyncClient._send_single_requestrArBc s"|jd||||||||d IdHS)rCrrANrrDr@r@rArszAsyncClient.getc s"|jd||||||||d IdHS)rErFrANrrDr@r@rArGszAsyncClient.optionsc s"|jd||||||||d IdHS)rHrrANrrDr@r@rArIszAsyncClient.headrJc s*|jd||||||||| | | | d IdHS)rKrrNrrLr@r@rArM#szAsyncClient.postc s*|jd||||||||| | | | d IdHS)rNrOrNrrLr@r@rArPHszAsyncClient.putc s*|jd||||||||| | | | d IdHS)rQrRrNrrLr@r@rArSmszAsyncClient.patchc s"|jd||||||||d IdHS)rTrUrANrrDr@r@rArVszAsyncClient.deleter[csN|jtjkrJtj|_|jIdH|jD]}|dur.|IdHq.dSrW)rrGrLrrlrrX)rYrr@r@rArls  zAsyncClient.acloserYcsl|jtjkr*tjdtjdi|j}t|tj|_|jIdH|j D]}|durL|IdHqL|SrZ) rrGrJrKrLr"r __aenter__rrX)rYr\rr@r@rArhs zAsyncClient.__aenter__r]csNtj|_|j|||IdH|jD] }|dur(||||IdHq(dSrS)rGrLrr __aexit__rrX)rYr^r_r`rr@r@rAris zAsyncClient.__aexit__)NNN)Cr<r=r>r?r r r rgrr!r&r$r#r.r"rr%rrrr,r rrrrr-rrirZrrrr/rrr'r(r*r;r)rr~rrmrOrrrr#r*r2rrGrIrMrPrSrVrlr9rhrbr%rrircr@r@rrAr: s6U      0    7  3 $ &'   !    !    !     )     )     )     )\rbenumloggingrgr contextlibrrtypesrrrrrr _configr r r r rr _decodersr _exceptionsrrrrZ_modelsrrrrZ _status_codesrZ_transports.asgirZ_transports.baserrZ_transports.defaultrrZ_transports.wsgir_typesr r!r"r#r$r%r&r'r(r)r*r+r,r-r.Z_urlsr/r0Z_utilsr1r2r3r4r5TypeVarr6r9r;r getLoggerr<rrkeysrEnumrGrMrjrrrrnr7r:r@r@r@rAsX       D   Y