Fj jddlmZddlZddlZddlZddlZddlZddlmZm 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?ddl@mAZAmBZBddlCmDZDmEZEmFZFmGZGmHZHgdZIejddZKejddZLGddZMeMZNejdZPde ZQdjejDcgc] }|dk7s | c}ZTGd d!ejZVGd"d#e=ZWGd$d%e1ZXejd&ejfZ[Gd'd(Z\Gd)de\Z]Gd*de\Z^ycc}w)+) 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 TimeoutTypes VerifyTypes)URL QueryParams)Timer URLPatternget_environment_proxiesis_https_redirect same_origin)USE_CLIENT_DEFAULT AsyncClientClientTr:)boundUr9ceZdZdZy)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__[/var/www/html/ai-video-generator/backend/venv/lib/python3.12/site-packages/httpx/_client.pyr?r?DsrEr?httpxz python-httpx/z, identityceZdZdZdZdZy) ClientStaterN)r@rArBUNOPENEDOPENEDCLOSEDrDrErFrJrJcsHFFrErJc8eZdZdZ ddZddZddZy) 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. c.||_||_||_yN_stream _response_timerselfstreamresponsetimers rF__init__zBoundSyncStream.__init__w ! rEc#6K|jD]}|ywrSrUrYchunks rF__iter__zBoundSyncStream.__iter__~s\\ EK sc|jj}tj||j_|j jyN)seconds)rW sync_elapseddatetime timedeltarVelapsedrUcloserYrfs rFrkzBoundSyncStream.closes;++**,!)!3!3G!D rEN)rZr.r[rr\r3returnNone)rmztyping.Iterator[bytes]rmrn)r@rArBrCr]rcrkrDrErFrQrQqs6 $08AF rErQc8eZdZdZ ddZddZddZy) 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. c.||_||_||_yrSrTrXs rFr]zBoundAsyncStream.__init__r^rEcHK|j23d{}|7 6ywrSr`ras rF __aiter__zBoundAsyncStream.__aiter__s&<<  %K dZ d< d?dZd@d Zef dAd!ZdBd"ZdCd#ZdDd$ZdEd%Z dFd&ZdGd'Z y)H BaseClientNFTutf-8 authparamsheaderscookiestimeoutfollow_redirects max_redirects event_hooksbase_url trust_envdefault_encodingc |in|}|jt| |_|j||_t ||_t||_t||_ t||_ ||_ ||_t|j!dgt|j!dgd|_| |_| |_t(j*|_yNrequestr[)rr[)_enforce_trailing_slashr1 _base_url _build_auth_authr2_paramsrrr_cookiesr_timeoutrrlistget _event_hooks _trust_env_default_encodingrJrM_state) rYr}r~rrrrrrrrrs rFr]zBaseClient.__init__s(/b[ 55c(mD%%d+ "6* w' ( ( 0*KOOIr:;[__Z<= $!1!** rEc<|jtjk(S)z2 Check if the client being closed )rrJrOrYs rF is_closedzBaseClient.is_closeds {{k0000rEc|jSrS)rrs rFrzBaseClient.trust_envs rEcz|jjdr|S|j|jdzS)N/raw_path)rendswith copy_withrYurls rFrz"BaseClient._enforce_trailing_slashs3 <<  &J}}cllT&9}::rEc|>|r:tjDcic]\}}||dn t|c}}SiSt|trNi}|jD]7\}}t|t t fr t|n|}||t |<9|St|t t fr t|n|}d|iScc}}w)N)rzall://)r5itemsr isinstancedictstrr1)rYproxiesallow_env_proxieskeyr new_proxiesvalueproxys rF_get_proxy_mapzBaseClient._get_proxy_maps ? %<$=$C$C$E S%C.@I gt $K%mmo . U,6usCj,I%(u(- CH% . *4WsCj*IEg&wEe$ $sCc|jSrS)rrs rFrzBaseClient.timeouts }}rEc$t||_yrS)rr)rYrs rFrzBaseClient.timeout( rEc|jSrS)rrs rFrzBaseClient.event_hookss   rEc|t|jdgt|jdgd|_yr)rrr)rYrs rFrzBaseClient.event_hookss4KOOIr:;[__Z<= rEc|jS)z Authentication class used when none is passed at the request-level. See also [Authentication][0]. [0]: /quickstart/#authentication )rrs rFr}zBaseClient.authszzrEc0|j||_yrS)rrrYr}s rFr}zBaseClient.auths%%d+ rEc|jS)zK Base URL to use when sending requests with relative URLs. )rrs rFrzBaseClient.base_url s ~~rEcB|jt||_yrS)rr1rrs rFrzBaseClient.base_urls55c#h?rEc|jS)z@ HTTP headers to include when sending requests. )_headersrs rFrzBaseClient.headers }}rEctdtjddtjdd}|j |||_y)Ns*/*asciis keep-alive)sAcceptsAccept-Encodings Connections User-Agent)rACCEPT_ENCODINGencode USER_AGENTupdater)rYrclient_headerss rFrzBaseClient.headerssJ !$3$:$:7$C,)009    g&& rEc|jS)zA Cookie values to include when sending requests. )rrs rFrzBaseClient.cookies*rrEc$t||_yrS)rr)rYrs rFrzBaseClient.cookies1rrEc|jS)zO Query parameters to include in the URL when sending requests. )rrs rFr~zBaseClient.params5s ||rEc$t||_yrS)r2r)rYr~s rFr~zBaseClient.params<s"6* rE) contentdatafilesjsonr~rrr extensionsc P|j|}|j|}|j| } |j|}| in| } d| vrDt | t r |j n t| } tdi| d| ji} 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 r)rrrrr~rrrrD) _merge_url_merge_headers_merge_cookies_merge_queryparamsrr?rrras_dictr) rYmethodrrrrrr~rrrrs rF build_requestzBaseClient.build_request@s4ooc"%%g.%%g.((0%-R: J &g'78 W%  F FGOO4EFJ  !  rEct|}|jrN|jj|jj dz}|jj |S|S)z Merge a URL argument together with any 'base_url' on the client, to create the URL used for the outgoing request. rr)r1is_relative_urlrrlstripr)rYr merge_urlmerge_raw_paths rFrzBaseClient._merge_urlss\ H  $ $"]]33i6H6H6O6OPT6UUN==**N*C CrEcr|s |jr(t|j}|j||S|S)z Merge a cookies argument together with any cookies on the client, to create the cookies used for the outgoing request. )rrr)rYrmerged_cookiess rFrzBaseClient._merge_cookiess4 dll$T\\2N  ! !' *! !rEcRt|j}|j||S)z Merge a headers argument together with any headers on the client, to create the headers used for the outgoing request. )rrr)rYrmerged_headerss rFrzBaseClient._merge_headerss& !.g&rEcn|s |jr&t|j}|j|S|S)z Merge a queryparams argument together with any queryparams on the client, to create the queryparams used for the outgoing request. )r~r2merge)rYr~merged_queryparamss rFrzBaseClient._merge_queryparamss2 T[[!,T[[!9 %++F3 3 rEc|yt|trt|d|dSt|tr|St |r t |St d|)Nrrusernamepassword)funczInvalid "auth" argument: )rtupler r callabler TypeErrorrs rFrzBaseClient._build_auths] < e $d1gQ@ @ d #K d^T* *7x@A ArEct|tr |jn|j|}||S|jj |jj }}|s|r t||StS)Nr) rr?rrrrrr r )rYrr}rrs rF_build_request_authzBaseClient._build_request_authsk %T+;&&w7$,,'))   rEc|j}|jtjk(r|dk7rd}|jtjk(r|dk7rd}|jtj k(r|dk(rd}|S)z When being redirected we may want to change the method of the request based on certain specs or browser behavior. HEADGETPOST)r status_coder SEE_OTHERFOUNDMOVED_PERMANENTLY)rYrr[rs rFrzBaseClient._redirect_methodst    5?? 2v7GF   5;; .6V3CF   5#:#: :v?OF rEc|jd} t|}|jr2|j s&|j |jj }|jr|jj|}|jjr2|js&|j |jj}|S#t$r}td|d|dd}~wwxYw)z< Return the URL for the redirect to follow. Locationz Invalid URL in location header: .rN)host)fragment) rr1rrschemerrrrjoinr)rYrr[locationrexcs rFrzBaseClient._redirect_urls##J/ h-C ::chh--W[[%5%5-6C   ++""3'C ;;   --)=)=->C ' %23%q97  s C C+C&&C+c|t|j}t||jsFt |j|s|j dd|j jd|d<||jk7r)|dk(r$|j dd|j dd|j dd|S) zR Return the headers that should be used for the redirect request. AuthorizationNrHostrzContent-LengthzTransfer-EncodingCookie) rrr7rr6popnetlocdecoder)rYrrrrs rFrzBaseClient._redirect_headerss'//*3 ,$W[[#6 OT2"jj//8GFO W^^ #% KK($ / KK+T 2  Hd#rEcD||jk7r|dk(ry|jS)zO Return the body that should be used for the redirect request. rN)rrZ)rYrrs rFrzBaseClient._redirect_stream)s# W^^ #%~~rEcd|jvrht|jtr |jnt |j}t di|jd|j i|_yy)NrrD)rrrr?rrr)rYrrs rF _set_timeoutzBaseClient._set_timeout4sd G.. .dll,<= T\\*  "&!V(:(:!VGOODU!VG  /rE)r}AuthTypes | Noner~QueryParamTypes | NonerHeaderTypes | NonerCookieTypes | Nonerr/rboolrintr+None | typing.Mapping[str, list[EventHook]]r URL | strrrr#str | typing.Callable[[bytes], str]rmrn)rmr)rr1rmr1)rProxiesTypes | Nonerrrmzdict[str, Proxy | None])rmr)rr/rmrn)rmdict[str, list[EventHook]])rrrmrn)rm Auth | None)r}r#rmrn)rmr1)rrrmrn)rmr)rr&rmrn)rmr)rr%rmrn)rmr2)r~r)rmrn)rrrrrRequestContent | NonerRequestData | NonerRequestFiles | Nonertyping.Any | Noner~rrrrrrTimeoutTypes | UseClientDefaultrRequestExtensions | Nonermr)rrrmr1rS)rrrmr)rrrmr)r~rrmr)r}r rmr)rrr}#AuthTypes | UseClientDefault | Nonermr )rrr[rrmr)rrr[rrmr)rrr[rrmr1)rrrr1rrrmr)rrrrrmz'SyncByteStream | AsyncByteStream | None)rrrmrn)!r@rArBrr r]propertyrrrrrsetterrr}rrrr~r8rrrrrrrrrrrrr rDrErFryrysL"&)-&*&* 6!&2EI @G + +' + $ + $ + + + +C + + +> +  +D11 ; %*%?C% %( ^^))!!   [[,, __@@  ^^ ' '  ^^))  ]]++*.#'%)"&)-&*&*3E/31 1 1 ' 1 ! 1 #1  1 '1 $1 $1 11 -1  1 f, 04 ,    B5G2  $ &.:6  (+  0 WrErycTeZdZdZdddddddddddedeeddddddd dfdZddddedddf d d Zddddedf d!d Z d"d Z ddddddde e e dd d#d Z e ddddddde e e dd d$dZde e d d%dZ d&dZ d'dZd(dZddde e e dd d)dZddde e e dd d*dZddde e e dd d*dZddddddde e e dd d+dZddddddde e e dd d+dZddddddde e e dd d+dZddde e e dd d*dZd,dZd-dZ d. d/dZxZS)0r:a 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). * **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". NTFrzr{r}r~rrverifycerthttp1http2rrmountsrrlimitsrrr transportapprrc2t|||||| | ||||| |r ddl}| r)d}t j |t | r td|rd}t j |t |xr |duxr|du}|j| xs| |}|j|||||||||_ |jD cic]+\}} t|| dn|j| ||||||-c} }|_| F|jj| jDcic]\}}t||c}}t!t#|jj|_y#t$r tddwxYwcc} }wcc}}w) Nr|ruUsing 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.r$r%r&r'r)r*r+rr$r%r&r'r)rsuperr]h2 ImportErrorwarningswarnDeprecationWarning RuntimeErrorr_init_transport _transportrr4_init_proxy_transport_mountsrrsortedrYr}r~rrr$r%r&r'rrr(rrr)rrrr*r+rrr4messager proxy_mapr __class__s rFr]zClient.__init__ts2 -'#-     4  MM'#5 6"#OPP V  MM'#5 6%K#+K)t:K''(85:KL ../  ,(oo/ @ U sO}"++#,  @     LL  BH,,.QYC)+Q F4<<#5#5#789 m !S F @ RE40F $F 4F c H||S| t|St||||||SN)r+r1)r!r rYr$r%r&r'r)r*r+rs rFr:zClient._init_transports?    ? S) )   rEc &t|||||||SN)r$r%r&r'r)rr)r rYrr$r%r&r'r)rs rFr<zClient._init_proxy_transports&  rEc|jjD]*\}}|j|s||jcS|cS|jSz Returns the transport instance that should be used for a given URL. This will either be the standard connection pool, or a proxy. r=rmatchesr;rYrpatternr*s rF_transport_for_urlzClient._transport_for_urlS #',,"4"4"6 K GYs#*3*;tJJ KrE rrrrr~rrr}rrrc | d}tj|t|j||||||||| | |  }|j || | S)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = client.send(request, ...) ``` See `Client.build_request()`, `Client.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration Setting per-request cookies=<...> is being deprecated, because the expected behaviour on cookie persistence is ambiguous. Set cookies directly on the client instance instead. rrrrrrr~rrrrr}rr6r7r8rsendrYrrrrrrr~rrr}rrrr@rs rFrzClient.requestsuB  C  MM'#5 6$$!%  yyt>NyOOrEc #K|j||||||||| | |  }|j|| | d} ||jy#|jwxYwwa  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 rUT)rr}rrZN)rrXrkrYrrrrrrr~rrr}rrrrr[s rFrZz Client.streamGs}8$$!%  99-    N NN HNN s2AA A AArZr}rc|jtjk(r tdtj|_t |t r |jn|}|j||j||}|j|||g} |s|j|S#t$r}|j|d}~wwxYw)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `Client.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.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.r}rhistoryN)rrJrOr9rNrr?rr r_send_handling_authread BaseExceptionrkrYrrZr}rr[rs rFrXz Client.send{s* ;;+,, ,VW W!(( *,<=  ! !!  '"''6++ - ,    O  NN I sB)) C 2CC c|j|} t|} |j|||} |j|}t ||_|j|}|j|[#t$r|cY|j SwxYw#t$r}|j |d}~wwxYw#|j wxYwN)rra) sync_auth_flownext_send_handling_redirectsrX StopIterationrkrrarcappendrd rYrr}rra auth_flowr[ next_requestrs rFrbzClient._send_handling_auths''0  9oG88%5#9 ('0~~h'? (,G}H$MMO*GNN8,)(' OO (%NN$I OO sL B>A:3B9B>: BBBB B;$B66B;;B>>Cc t||jkDr td||jdD] }|| |j |} |jdD] }|| t ||_|js|S|j||}||gz}|r|jn ||_ |S #t$r}|j|d}~wwxYwNz#Exceeded maximum allowed redirects.rrr[) lenrrr_send_single_requestrrahas_redirect_locationrrcrordrkrYrrrahookr[rs rFrjzClient._send_handling_redirectss 7|d000&97)))4 W  009H  --j9#DN##'= 55#O66wI!XJ.#MMO,3H)#O$-6!    s9C3C C%C  C%c|j|j}t}|jt |j t s tdt|5|j|}dddt j t sJ||_ t|j |||_|jj||j|_t j#d|j$|j|j&|j(|j*|S#1swYxYw)L Sends a single request, without handling any redirections. z?Attempted to send an async request with a sync Client instance.rNr[r\HTTP Request: %s %s "%s %d %s")rPrr3 sync_startrrZr.r9rhandle_requestrrQrextract_cookiesrrloggerinfor http_versionr reason_phraserYrr*r\r[s rFrszClient._send_single_requests++GKK8  '...9Q W - 9 //8H 9(//>:::") OOhe  $$X.$($:$:! , NN KK  ! !   " "  + 9 9s 'D;;Er~rrr}rrrc 6|jd|||||||| S)U Send a `GET` request. **Parameters**: See `httpx.request`. rrr rYrr~rrr}rrrs rFrz Client.gets5"||  -!  rEc 6|jd|||||||| S)Z Send an `OPTIONS` request. **Parameters**: See `httpx.request`. OPTIONSrrrs rFoptionszClient.options6s5"||  -!  rEc 6|jd|||||||| S)V Send a `HEAD` request. **Parameters**: See `httpx.request`. rrrrs rFheadz Client.headSs5"||  -!  rEc >|jd||||||||| | | |  S)V Send a `POST` request. **Parameters**: See `httpx.request`. rrRr rYrrrrrr~rrr}rrrs rFpostz Client.postpsA*||  -!  rEc >|jd||||||||| | | |  S)U Send a `PUT` request. **Parameters**: See `httpx.request`. PUTrRrrs rFputz Client.putsA*||  -!  rEc >|jd||||||||| | | |  S)W Send a `PATCH` request. **Parameters**: See `httpx.request`. PATCHrRrrs rFpatchz Client.patchsA*||  -!  rEc 6|jd|||||||| S)X Send a `DELETE` request. **Parameters**: See `httpx.request`. DELETErrrs rFdeletez Client.deletes5"||  -!  rEc|jtjk7rbtj|_|jj |j j D]}||j yyz. Close transport and proxies. N)rrJrOr;rkr=values)rYr*s rFrkz Client.closesd ;;+,, ,%,,DK OO ! ! #!\\002 & (OO% & -rEcv|jtjk7r:tjdtjdi|j}t |tj|_|j j|jjD]}||j|SNz-Cannot open a client instance more than once.z9Cannot reopen a client instance, once it has been closed.) rrJrMrNrOr9r; __enter__r=r)rYmsgr*s rFrzClient.__enter__s ;;+.. .""$S""O kk C s# #!((  !!#,,. &I$##% & rEctj|_|jj ||||j j D]}||j |||yrS)rJrOrr;__exit__r=r)rYexc_type exc_value tracebackr*s rFrzClient.__exit__s] "((    9i@,,. CI$""8Y B CrE),r}r r~rrrrrr$r0r%CertTypes | Noner&rr'rrProxyTypes | Nonerrr(z0None | typing.Mapping[str, BaseTransport | None]rr/rrr)rrrrrrrr*BaseTransport | Noner+'typing.Callable[..., typing.Any] | Nonerrrrrmrn)r$r0r%rr&rr'rr)rr*rr+rrrrmr)rrr$r0r%rr&rr'rr)rrrrmr)rr1rmrrrrrrrrrrrrrr~rrrrrr}rrbool | UseClientDefaultrrrrrmr)rrrrrrrrrrrrr~rrrrrr}rrrrrrrrmztyping.Iterator[Response] rrrZrr}rrrrmr rrr}r rrralist[Response]rmrrrrrrarrmrrrrmrrrr~rrrrrr}rrrrrrrrmrrrr~rrrrrr}AuthTypes | UseClientDefaultrrrrrrrmrrrrrrrrrrrr~rrrrrr}rrrrrrrrmrro)rYr;rmr;NNNrztype[BaseException] | NonerzBaseException | NonerzTracebackType | Nonermrn)r@rArBrCrr r r]r:r<rPr8rrrZrXrbrjrsrrrrrrrrkrr __classcell__rBs@rFr:r:>sh3p"&)-&*&*"!%#''+EI 6!&'2EI *.7;@G/`:`:' `: $ `: $ `:`:`:`:`:!`:%`:C`:`:`: !`:"#`:$C%`:&'`:(()`:*5+`:,-`:.>/`:0 1`:H#!%'*.7;         ( 5    :#!%'             (  *.#'%)"&)-&*&*4F4F3E/36P6P6P ' 6P ! 6P#6P 6P'6P$6P$6P26P26P16P-6P !6Pp *.#'%)"&)-&*&*4F4F3E/3111 ' 1 ! 1#1 1'1$1$1212111-1 #!11n4F4F 11 1 2 1 2 1 1f        D### #  #J"P*.&*&*4F4F3E/3  '  $  $  2 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.&*&*-?4F3E/3  '  $  $  + 2 1 -   : &(04*.*. C, C( C( C  CrEcTeZdZdZdddddddddddedeeddddddd dfdZddddedddf d d Zddddedf d!d Z d"d Z ddddddde e e dd d#d Z e ddddddde e e dd d$dZde e d d%dZ d&dZ d'dZd(dZddde e e dd d)dZddde e e dd d*dZddde e e dd d*dZddddddde e e dd d+dZddddddde e e dd d+dZddddddde e e dd d+dZddde e e dd d*dZd,dZd-dZ d. d/dZxZS)0r9a 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". NTFrzr{r#c2t|||||| | ||||| |r ddl}| r)d}t j |t | r td|rd}t j |t |xr |duxr|du}|j| xs| |}|j|||||||||_ |jD cic]+\}} t|| dn|j| ||||||-c} }|_| F|jj| jDcic]\}}t||c}}t!t#|jj|_y#t$r tddwxYwcc} }wcc}}w) Nr|rr-r.r/zhThe 'app' shortcut is now deprecated. Use the explicit style 'transport=ASGITransport(app=...)' instead.r0r1r2r?s rFr]zAsyncClient.__init___s2 -'#-     4  MM'#5 6"#OPP V  MM'#5 6%K#+K)t:K''(85:KL ../  .(oo/ E U sO}"++#,  E     LL  BH,,.QYC)+Q F4<<#5#5#789 m !S H E RrCc H||S| t|St||||||SrE)rrrFs rFr:zAsyncClient._init_transports?    ? S) )!   rEc &t|||||||SrH)rrIs rFr<z!AsyncClient._init_proxy_transports&"  rEc|jjD]*\}}|j|s||jcS|cS|jSrKrLrNs rFrPzAsyncClient._transport_for_urlrQrErRc K| d}tj|t|j||||||||| | |  }|j || | d{S7w)a Build and send a request. Equivalent to: ```python request = client.build_request(...) response = await client.send(request, ...) ``` See `AsyncClient.build_request()`, `AsyncClient.send()` and [Merging of configuration][0] for how the various parameters are merged with client-level configuration. [0]: /advanced/clients/#merging-of-configuration NrTrUrVrWrYs rFrzAsyncClient.requestsD  C  MM'#5 6$$!%  YYwTDTYUUUUsAAAAc K|j||||||||| | |  }|j|| | dd{} ||jd{y7#7#|jd{7wxYwwr[)rrXrwr\s rFrZzAsyncClient.stream3s8$$!%  - #    $N//# # #  $(//# # #sD5A=AA=AA=AA=A=A:3A64A::A=r]cK|jtjk(r tdtj|_t |t r |jn|}|j||j||}|j|||gd{} |s|jd{|S7!7#t$r }|jd{7|d}~wwxYww)a Send a request. The request is sent as-is, unmodified. Typically you'll want to build one with `AsyncClient.build_request()` so that any client-level configuration is merged into the request, but passing an explicit `httpx.Request()` is supported as well. See also: [Request instances][0] [0]: /advanced/clients/#request-instances r_r`N)rrJrOr9rNrr?rr rrbareadrdrwres rFrXzAsyncClient.sendgs* ;;+,, ,VW W!(( *,<=  ! !!  '"''611 - 2    nn&&&O ' //# # #I sTBC+B;C+B?4B=5B?:C+=B?? C(C#CC##C((C+c>K|j|} |jd{} |j|||d{} |j|d{}t ||_|jd{|}|j|s7x7]7D#t$r|cY|j d{7SwxYw7H#t$r }|j d{7|d}~wwxYw#|j d{7wxYwwrg) async_auth_flow __anext__rjasendStopAsyncIterationrwrrarrlrdrms rFrbzAsyncClient._send_handling_auths((1  %%//11G!%!>!>%5#"?" (-6__X-F'F (,G}H$"..****GNN8,2(G-('""$ $ $(+%"//+++I""$ $ $sDC?B!C?B#C? B' B%!B'%#CC C C?#C?%B'' C2C3DC D CC C<C7/C20C77C<<C??DDDDc:K t||jkDr td||jdD]}||d{|j |d{} |jdD]}||d{t ||_|js|S|j||}||gz}|r|jd{n ||_ |S 777f7#t$r }|jd{7|d}~wwxYwwrq) rrrrrrsrrartrrrordrwrus rFrjz$AsyncClient._send_handling_redirectss8 7|d000&97)))4 $7m## $"66w??H  --j9)Dx.(()$(= 55#O66wI!XJ.#"..***,3H)#O+/$?)+ ! oo'''  sADC'D!C)"D'C/C+#C/(D)-C/C- C/$D)D+C/-C// D8D D DDDcK|j|j}t}|jd{t |j t s tdt|5|j|d{}dddt j t sJ||_ t|j |||_|jj||j|_t j#d|j$|j|j&|j(|j*|S77#1swYxYww)rxNz?Attempted to send an sync request with an AsyncClient instance.rryrz)rPrr3 async_startrrZr"r9rhandle_async_requestrrqrr}rrr~rrrrrrs rFrsz AsyncClient._send_single_requests+++GKK8 !!!'../:Q W - E&;;GDDH E(//?;;;"* OOhe  $$X.$($:$:! , NN KK  ! !   " "  7 "E E Es:9EE 5E1EEE CEEEErc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.getsC"\\  -!"    '%'c RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.options"sC"\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.head?sC"\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrRNrrs rFrzAsyncClient.post\sO*\\  -!"    "+)+c ZK|jd||||||||| | | |  d{S7w)rrrRNrrs rFrzAsyncClient.putsO*\\  -!"    rc ZK|jd||||||||| | | |  d{S7w)rrrRNrrs rFrzAsyncClient.patchsO*\\  -!"    rc RK|jd|||||||| d{S7w)rrrNrrs rFrzAsyncClient.deletesC"\\  -!"    rc2K|jtjk7rrtj|_|jj d{|j j D]}||j d{yy7@7 wr)rrJrOr;rwr=r)rYrs rFrwzAsyncClient.acloses~ ;;+,, ,%,,DK//((* * *,,. )$,,.(( ) - +)s*ABB#B7B B BBcK|jtjk7r:tjdtjdi|j}t |tj|_|j jd{|jjD]}||jd{|S7@7 wr) rrJrMrNrOr9r; __aenter__r=r)rYrrs rFrzAsyncClient.__aenter__s ;;+.. .""$S""O kk C s# #!(( oo((***\\((* )E &&((( ) +)s*B C C  #C1CC CCcKtj|_|jj |||d{|j j D] }||j |||d{"y7B7 wrS)rJrOrr; __aexit__r=r)rYrrrrs rFrzAsyncClient.__aexit__sx "(( oo'')YGGG\\((* FE ooh 9EEE F HFs'6A?A;#A?A?3A=4A?=A?),r}r r~rrrrrr$r0r%rr&rr'rrrrrr(z5None | typing.Mapping[str, AsyncBaseTransport | None]rr/rrr)rrrrrrrr*AsyncBaseTransport | Noner+rrrrrrmrn)r$r0r%rr&rr'rr)rr*rr+rrrrmr)rrr$r0r%rr&rr'rr)rrrrmr)rr1rmrr)rrrrrrrrrrrrr~rrrrrr}rrrrrrrrmztyping.AsyncIterator[Response]rrrrrrrro)rYr=rmr=rr)r@rArBrCrr r r]r:r<rPr8rrrZrXrbrjrsrrrrrrrrwrrrrs@rFr9r9(sh4r"&)-&*&*"!%#''+JN 6!&'2EI /37;@G/`:`:' `: $ `: $ `:`:`:`:`:!`:%`:H`:`:`: !`:"#`:$C%`:&'`:(-)`:*5+`:,-`:.>/`:0 1`:H#!%'/37;         - 5    :#!%'             (  *.#'%)"&)-&*&*4F4F3E/37V7V7V ' 7V ! 7V#7V 7V'7V$7V$7V27V27V17V-7V !7Vr *.#'%)"&)-&*&*4F4F3E/31$1$1$ ' 1$ ! 1$#1$ 1$'1$$1$$1$21$21$11$-1$ (!1$1$n4F4F 11 1 2 1 2 1 1f % % % %  %  %D$$$ $  $L!N*.&*&*4F4F3E/3  '  $  $  2 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.&*&*-?4F3E/3  '  $  $  + 2 1 -   B*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.#'%)"&)-&*&*-?4F3E/3# # ' # ! # # #  # '# $# $# +# 2# 1# -#  # R*.&*&*-?4F3E/3  '  $  $  + 2 1 -   : )(04*.*. F, F( F( F  FrE)_ __future__rrhenumloggingtypingr6 contextlibrrtypesrrrr r r _configr r rrrr _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/r0_urlsr1r2_utilsr3r4r5r6r7__all__TypeVarr;r=r?r8 getLoggerr~rrkeysrEnumrJrQrqCallableAny EventHookryr:r9)rs0rFrs"  :$00* 98 +?B+"$ :FNN3h'FNN3m,(&'   7 #[M * ))+&++-CS 1BSC $)) n.$$. OOCO , YWYWx g CZg CTi F*i FS&Ds 3 F0>F0