o i9@s<ddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl Z ddl m Z ddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZddl m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&e!rdd l'm(Z(zdd l)m*Z+Wn e,yYnwzdd l-m.Z/dd l-m0Z1Wn e,yYnwzdd l2m3Z4ddl2m5Z6Wn e,yYnwddZ7dededdfddZ8dededdfddZ9Gddde:Z;Gddde;ZGd d!d!e;Z?Gd"d#d#e;Z@Gd$d%d%e;ZAGd&d'd'e;ZBGd(d)d)e;ZCdS)*)BytesION) HTTPResponse)_util)RequestMetrics)APIConnectionError) AnyDictIterableListMappingMutableMappingOptionalTupleClassVarUnioncastoverload AsyncIterable) TYPE_CHECKINGLiteralNoReturn TypedDict AwaitableNever) ParseResult)Session)Timeout)Client) ClientTimeout) StreamReadercCstttdS)Ni)introundtimer#r#s/var/www/snowflake_co_dev_github/snow_flake_back_end_deploy/env/lib/python3.10/site-packages/stripe/_http_client.py_now_ms?sr%argskwargsreturn HTTPClientcOszddlm}Wn tyYnwt|i|Szddl}Wn ty(Ynwt|i|Szddl}Wn ty?Ynwt|i|St|i|S)a This method creates and returns a new HTTPClient based on what libraries are available. It uses the following precedence rules: 1. Urlfetch (this is provided by Google App Engine, so if it's present you probably want it) 2. Requests (popular library, the top priority for all environments outside Google App Engine, but not always present) 3. Pycurl (another library, not always present, not as preferred as Requests but at least it verifies SSL certs) 4. urllib with a warning (basically always present, a reasonable final default) For performance, it only imports what it's actually going to use. But, it re-calculates every time its called, so probably save its result instead of calling it multiple times. rurlfetchN) google.appengine.apir+ ImportErrorUrlFetchClientrequestsRequestsClientpycurl PycurlClient UrllibClient)r&r'r+r/r1r#r#r$new_default_http_clientCs&      r4cOsrz ddl}ddl}Wn tyYnwt|i|Szddl}Wn ty*Ynwt|i|St|i|S)z~ Similar to `new_default_http_client` above, this returns a client that can handle async HTTP requests, if available. rN)httpxanyior- HTTPXClientaiohttp AIOHTTPClientNoImportFoundAsyncClient)r&r'r5r6r8r#r#r$new_http_client_async_fallbackfs    r;c@s$eZdZUdZeeed<GdddeZdZ dZ dZ e eed<e ed < dHd e d e eeefde dfddZde eeee eeeffde edede efddZ dIde eeeeeefffddZ dIdede eeeeeeffdefddZdedefddZdeeefdeeeffd d!Zd"d#Z dJd d$d%ed&edeeefd'ede ed(e eedeeeeeefffd)d*Z dJd d$d%ed&edeeefd(e eedeeeeeefff d+d,Zd d$d%ed&edeeefd'ed-e de ed(e eedeeeeeefffd.d/Z dId d$d%ed&ede eeefd'ed(e eedeeeeeefff d0d1Z dId d$d%ed&ede eeefd'ed(e eedeeeeeefff d2d3Z!d4d5Z" dJd d$d%ed&edeeefde ed(e eedeeeeff d6d7Z# dJd d$d%ed&edeeefd(e eedee$e%eeff d8d9Z&e'd d$d%ed&edeeefd-e(d:de ed(e eedeeeeeefffd;d<Z)e'd d$d%ed&edeeefd-e(d de ed(e eedee$e%eeeefffd=d<Z)d d$d%ed&edeeefd-e de ed(e eedeeeeeefffd>d<Z) dId%ed&edeeefdee%eeeefffd?d@Z* dId%ed&edeeefdee$e%eeeefffdAdBZ+dCdDZ,dEede-d fdFdGZ.d S)Kr)z@ Base HTTP client that custom clients can inherit from. namec@s&eZdZUeeed<eeed<dS)zHTTPClient._ProxyhttphttpsN)__name__ __module__ __qualname__r str__annotations__r#r#r#r$_Proxy rD?<_proxy_verify_ssl_certsTNverify_ssl_certsproxyasync_fallback_clientcCsV||_|rt|tr||d}t|tstd|r|nd|_||_t |_ dS)N)r=r>zqProxy(ies) must be specified as either a string URL or a dict() with string URL under the https and/or http keys.) rJ isinstancerBdict ValueErrorcopyrI_async_fallback_client threadinglocal _thread_local)selfrKrLrM_libr#r#r$__init__s    zHTTPClient.__init__responseapi_connection_error num_retriesmax_network_retriescCs|dur|nd}||krdS|dur|dusJ|jS|\}}}|dur8d|vr8|ddkr0dS|ddkr8dS|dkr>dS|dkrDdSdS) NrFzstripe-should-retryfalsetrueTii should_retry)rVrYrZr[r\_ status_coderheadersr#r#r$ _should_retrys$    zHTTPClient._should_retryc Cs>|durdS|\}}}zt|dWSttfyYdSw)Nz retry-after)r KeyErrorrP)rVrYrarcr#r#r$_retry_after_headers zHTTPClient._retry_after_headerr(cCsVttjd|dtj}||}ttj|}||pd}|tjkr)t||}|S)z Apply exponential backoff with initial_network_retry_delay on the number of num_retries so far as inputs. Do not allow the number to exceed `max_network_retry_delay`. r)minr) INITIAL_DELAY MAX_DELAY_add_jitter_timemaxrfMAX_RETRY_AFTER)rVr[rY sleep_seconds retry_afterr#r#r$_sleep_time_secondss     zHTTPClient._sleep_time_secondsrocCs|ddtdd9}|S)z Randomize the value in `[(sleep_seconds/ 2) to (sleep_seconds)]`. Also separated method here to isolate randomness for tests rGrhr)randomuniform)rVror#r#r$rlszHTTPClient._add_jitter_timeheaderscCsBt|jdd}tjr|rd|i}t|}t||d<|S|S)Nlast_request_metricszX-Stripe-Client-Telemetry)getattrrUstripeenable_telemetrypayloadrOjsondumps)rVrtru telemetryretr#r#r$_add_telemetry_headers z HTTPClient._add_telemetry_headercCsH|\}}}d|vr tjr"|d}t|}t|||d|j_dSdSdS)Nz Request-Idusage)rwrxr%rrUru)rVrY request_startrrarc request_idrequest_duration_msr#r#r$_record_request_metricss  z"HTTPClient._record_request_metrics)_usagemethodurl post_datarc C|j||||d||dSNF is_streamingr\r_request_with_retries_internalrVrrrtrr\rr#r#r$request_with_retries zHTTPClient.request_with_retriesc CrNTrrrr#r#r$request_stream_with_retries1rz&HTTPClient.request_stream_with_retriesrc Cs||}d} t} z|r|||||} n|||||} d} Wnty8} z | } d} WYd} ~ nd} ~ ww|| | ||rf| rKtd| j|d7}| || } td|||| ft | n| durt|j | | |d| S| duszJ| qNrTz Encountered a retryable error %srhzBInitiating retry %i for request %s %s after sleeping %.2f seconds.r) r~r%request_streamrequestrrdrlog_info user_messagerqr"sleeprrVrrrtrrr\rr[rrYconnection_errore sleep_timer#r#r$rEsR     z)HTTPClient._request_with_retries_internalcCtd)Nz.HTTPClient subclasses must implement `request`NotImplementedErrorrVrrrtrrr#r#r$r zHTTPClient.requestcCr)Nz5HTTPClient subclasses must implement `request_stream`rrr#r#r$rrzHTTPClient.request_streamcCr)Nz,HTTPClient subclasses must implement `close`rrVr#r#r$closezHTTPClient.closec |j||||d||dIdHSr$_request_with_retries_internal_asyncrr#r#r$request_with_retries_async  z%HTTPClient.request_with_retries_asyncc rrrrr#r#r$!request_stream_with_retries_asyncrz,HTTPClient.request_stream_with_retries_asyncFcdSNr#rVrrrtrrr\rr#r#r$r z/HTTPClient._request_with_retries_internal_asynccrrr#rr#r#r$rrc s||}d} t} z|r|||||IdH} n |||||IdH} d} Wnty?} z | } d} WYd} ~ nd} ~ ww|| | ||rp| rRtd| j|d7}| || } td|||| f| | IdHn| dur~|j | | |d| S| dusJ| q r) r~r%request_stream_async request_asyncrrdrrrrq sleep_asyncrrr#r#r$rsX      c,|jdur|j||||IdHStd)Nz4HTTPClient subclasses must implement `request_async`)rRrrrVrrrtrr#r#r$r  zHTTPClient.request_asynccr)Nz;HTTPClient subclasses must implement `request_stream_async`)rRrrrr#r#r$r)rzHTTPClient.request_stream_asynccs$|jdur|jIdHStd)Nz2HTTPClient subclasses must implement `close_async`)rR close_asyncrrr#r#r$r4s  zHTTPClient.close_asyncsecscCs|jdur |j|Std)Nz,HTTPClient subclasses must implement `sleep`)rRrrrVrr#r#r$r;s  zHTTPClient.sleep_asyncTNNNr)NN)/r?r@rA__doc__rrBrCrrDrkrjrnr boolrrXrrr r rrdrffloatrqrlr~rr rrrrrrrrbytesrrrrrrrrrr#r#r#r$r)}s     0              @                        >      cseZdZdZ      d deeeeeffdedded eee e j fd ee f fd d Z d!d e de dee e e fdeeee e e fffddZ d!d e de dee e e fdeeee e e fffddZed e de dee e e fdeddeeee e e fff ddZed e de dee e e fdeddeeee e e fff ddZd e de dee e e fdedeeeefee e e fff ddZdedefddZddZZS)"r0r/PNTtimeoutsessionRequestsSessionrKrLrMc  s@tt|j|||d||_||_|durddl}|}||_dSNrKrLrMr)superr0rX_session_timeoutr/) rVrrrKrLrMrWr'r/ __class__r#r$rXFs  zRequestsClient.__init__rrrtr(cC|j||||ddSNFr_request_internalrr#r#r$r_ zRequestsClient.requestcCrNTrrrr#r#r$rjrzRequestsClient.request_streamrcCdSrr#rVrrrtrrr#r#r$ruz RequestsClient._request_internalFcCrrr#rr#r#r$rrc Cs i}|jr tj|d<nd|d<|jr|j|d<|rd|d<t|jdddur0|jp-|j|j_ z8zt d|jj j ||f|||j d|}Wnt yZ}zt d |fd}~ww|ra|j} n|j} |j} Wnty}z ||WYd}~nd}~ww| | |jfS) NverifyFproxiesTstreamrr)rtdataraWarning: It looks like your installed version of the "requests" library is not compatible with Stripe's usage thereof. (HINT: The most likely cause is that your "requests" library is out of date. You can fix that by running "pip install -U requests".) The underlying error was: %s)rJrwca_bundle_pathrIrvrUrr/rrrrr TypeErrorrawcontentrb Exception_handle_request_errorrt) rVrrrtrrr'resultrrrbr#r#r$rsV       rcCst||jjjrd}dt|jt|f}d}nSt||jjj|jjjfr5d}dt|jt|f}d}n6t||jjj rMd}dt|jt|f}d}nd}dt|jf}t|re|dt|f7}n|d 7}d}t |d |f}t ||d |) NCould not verify Stripe's SSL certificate. Please make sure that your network is not intercepting certificates. If this problem persists, let us know at support@stripe.com.%s: %sFziUnexpected error communicating with Stripe. If this problem persists, let us know at support@stripe.com.TzUnexpected error communicating with Stripe. It looks like there's probably a configuration issue locally. If this problem persists, let us know at support@stripe.com.A %s was raisedz with error message %sz with no error message (Network error: %s)r_) rNr/ exceptionsSSLErrortyper?rBrConnectionErrorRequestExceptiontextwrapfillrrVrmsgerrr`r#r#r$rs:z$RequestsClient._handle_request_errorcCs&t|jdddur|jjdSdS)Nr)rvrUrrrr#r#r$rszRequestsClient.close)rNTNNNr)r?r@rAr<rrrr rrBr)rDrXr rr rrrrrrrrrr __classcell__r#r#rr$r0Cs        ?5r0csdeZdZdZ     ddedeejdedeeffd d Z dd e d e d e e e fde e ee e e fffddZ dd e d e d e e e fde eee e e fffddZed e d e d e e e fdedde eeeff ddZed e d e d e e e fdedde e eeff ddZd e d e d e e e ffddZded e defddZddZZS) r.r+TN7rKrLdeadlinerMcsPtt|j|||d|rtd||_||_|dur#ddlm}|}||_dS)NrzNo proxy support in urlfetch library. Set stripe.default_http_client to either RequestsClient, PycurlClient, or UrllibClient instance to use a proxy.rr*)rr.rXrPrJ _deadliner,r+)rVrKrLrrMrWr+rr#r$rXs   zUrlFetchClient.__init__rrrtr(cCrrrrr#r#r$r( zUrlFetchClient.requestcCrrrrr#r#r$r/rzUrlFetchClient.request_streamrcCrrr#rr#r#r$r6rz UrlFetchClient._request_internalFcCrrr#rr#r#r$r@rc Csz|jj||||j|j|d}Wn|jjy*}z |||WYd}~nd}~ww|r6tt|j }n|j }||j |j fS)N)rrrtvalidate_certificaterry) r+fetchrJrErrorrrrBencoderrbrt) rVrrrtrrrrrr#r#r$rJs"  rcCsjt||jjr d|f}nt||jjrd}n t||jjr!d}nd}t|dt|d}t||)NzThe Stripe library attempted to fetch an invalid URL (%r). This is likely due to a bug in the Stripe Python bindings. Please let us know at support@stripe.com.z0There was a problem retrieving data from Stripe.zThere was a problem receiving all of your data from Stripe. This is likely due to a bug in Stripe. Please let us know at support@stripe.com.hUnexpected error communicating with Stripe. If this problem persists, let us know at support@stripe.com. (Network error: )) rNr+InvalidURLError DownloadErrorResponseTooLargeErrorrrrBr)rVrrrr#r#r$ris z$UrlFetchClient._handle_request_errorcCrrr#rr#r#r$rzUrlFetchClient.close)TNrNNr)r?r@rAr<rr r)rDr rXrBr rrrrrrrrrrrrrr#r#rr$r.s$              r.c@&eZdZUeded<eded<dS)rDrr=r>Nr?r@rAr rCr#r#r#r$rDrErDcseZdZUGdddeddZdZeeed<    d%d ed ee j d ee ffd d Z ddZ d&de eefdeeee eefffddZ d&de eefdeeee eefffddZededede eefdeddeeeeff ddZededede eefdeddeeee eefff ddZdedede eefdeeeefee eefffddZdedefddZded fd!d"Zd#d$ZZS)'r2c@r)zPycurlClient._ParsedProxyrr=r>Nrr#r#r#r$ _ParsedProxyrErF)totalr1 _parsed_proxyTNrKrLrMc stt|j|||d|durddl}|}||_||_i|_|jr?ddlm }|j}| D]\}} |t t | |j|<q0dSdS)Nrr)urlparse) rr2rXr1Curl_curlrrI urllib.parseritemsrrB) rVrKrLrMrWr1rproxy_schemevaluerr#r$rXs$   zPycurlClient.__init__cCs@d|vriS|ddd}t|}tddt|DS)Nz rhcs |] \}}||fVqdSrlower.0kvr#r#r$ z-PycurlClient.parse_headers..)splitemailmessage_from_stringrOr)rVr raw_headersrtr#r#r$ parse_headerss  zPycurlClient.parse_headersrtr(cCrrrrr#r#r$rrzPycurlClient.requestcCrrrrr#r#r$rrzPycurlClient.request_streamrrrcCrrr#rr#r#r$rrzPycurlClient._request_internalcCrrr#rr#r#r$rrc Cs6t}t}|j||}|rA|jr|j|jj|j|jr,|j|jj |j|j s2|j rA|j|jj d|j |j f|dkrO|j|jj dn"|dkrf|j|jjd|j|jj|n |j|jj||j|jj||j|jj|j|j|jj|j|j|jjd|j|jjd|j|jjd|j|jjddt|D|jr|j|jjtjn |j|jj d z|j!Wn|jj"y} z |#| WYd} ~ nd} ~ ww|r|$d |} n|%&d } |j'|jj(} |)|%&d }| | |fS) Nz%s:%sgetrhpostrcSsg|] \}}d||fqS)rr#r r#r#r$ sz2PycurlClient._request_internal..Frutf-8)*rrreset _get_proxyhostnamesetoptr1PROXYport PROXYPORTusernamepassword PROXYUSERPWDHTTPGETPOST POSTFIELDS CUSTOMREQUESTupperURL WRITEFUNCTIONwriteHEADERFUNCTIONNOSIGNALCONNECTTIMEOUTTIMEOUT HTTPHEADERrOrrJCAINFOrwrSSL_VERIFYHOSTperformerrorrseekgetvaluedecodegetinfo RESPONSE_CODEr) rVrrrtrrbrcrLrrcontentrcoder#r#r$rs\     rcCs|jd|jj|jj|jjfvrd}d}n|jd|jj|jjfvr'd}d}nd}d}t|d|jdd }t ||d |) NrzCould not connect to Stripe. Please check your internet connection and try again. If this problem persists, you should check Stripe's service status at https://twitter.com/stripestatus, or let us know at support@stripe.com.TrFrrrhrr_) r&r1E_COULDNT_CONNECTE_COULDNT_RESOLVE_HOSTE_OPERATION_TIMEOUTED E_SSL_CACERTE_SSL_PEER_CERTIFICATErrr)rVrrr`r#r#r$r&s(z"PycurlClient._handle_request_errorrcCsD|jr |j}|r|ddnd}|r ||||ddSdS)N:r)rrr)rVrrLrr#r#r$rIs zPycurlClient._get_proxycCrrr#rr#r#r$rQrzPycurlClient.closerr)r?r@rArrr<r rCrr)rDrXrr rBrr rrrrrrrrrrrrrrr#r#rr$r2s  "             H#r2csZeZdZdZ    ddedeejdeeffdd Z dd e d e d e e e fd e e e e e e fffd dZ dd e d e d e e e fd e ee e e e fffddZed e d e d e e e fdedd e e e eff ddZed e d e d e e e fdedd e ee eff ddZd e d e d e e e ffddZded efddZddZZS)r3zurllib.requestTNrKrLrMcstt|j|||d|durddlm}|}||_ddlm}||_d|_ |j r@|j t t ttf|j }|j||_ dSdSr)rr3rXurllib.requestr urllibrequest urllib.errorr6 urlliberror_openerrI ProxyHandlerrrrB build_opener)rVrKrLrMrWrGrI proxy_handlerrr#r$rXXs$   zUrllibClient.__init__rrrtr(cCrrrrr#r#r$ryrzUrllibClient.requestcCrrrrr#r#r$rrzUrllibClient.request_streamrFcCrrr#rr#r#r$rrzUrllibClient._request_internalcCrrr#rr#r#r$rrc s.t|tr |d}|j||ttttf|}dvr$fdd|_z#|jr.|j |n|j |}|r9|}n| }|j } t |}Wn;|jjyh} z| j } | }t | }WYd} ~ nd} ~ w|jjtfy} z || WYd} ~ nd} ~ wwt ddtt |D} || | fS)Nr)rrcsSr)r*r#rr#r$sz0UrllibClient._request_internal..csr rr r r#r#r$rrz1UrllibClient._request_internal..)rNrBrrGRequestrr get_methodrJopenurlopenreadcoderOinforI HTTPErrorURLErrorrPriterr) rVrrrtrrreqrYr=r>rlhr#rNr$rs8    rcCs(d}t|dt|d}t||)Nrrr)rrrBr)rVrrr#r#r$rs z"UrllibClient._handle_request_errorcCrrr#rr#r#r$rrzUrllibClient.closerr)r?r@rAr<rr r)rDrXrBr rr rrrrrrrrrrrrr#r#rr$r3Us"              +r3csxeZdZUdZeded<   d"deeedfffd d Zd d Z d e de de e e ffddZ d#d e de de e e fde eee e e fffddZ d#d e de de e e fde eee e e fffddZdedefddZ d#d e de de e e fde eeee e e fffddZ d#d e de de e e fde eeee e e fffddZddZd d!ZZS)$r7r5HTTPXClientType_clientrFNr HTTPXTimeoutc stt|jdi||durddl}|}||_ddl}||_i}|jr.tjtj d|d<nd|d<|jj di||_ d|_ |rK|jj di||_ ||_dS)NrcafilerFr#)rr7rXr5r6rJsslcreate_default_contextrwr AsyncClient _client_asyncr]rr)rVrallow_sync_methodsrWr'r5r6rr#r$rXs$  zHTTPXClient.__init__cCs |j|Sr)r6rrr#r#r$rs zHTTPXClient.sleep_asyncrrrtcCs>i}|jr |j|d<|jr|j|d<||f||pid|gS)Nrr)rtr)rIr)rVrrrtrr'r#r#r$_get_request_args_kwargss  z$HTTPXClient._get_request_args_kwargsr(c Cs|jdur td|||||\}}z |jj|i|}Wnty5}z ||WYd}~nd}~ww|j} |j} |j} | | | fS)NzqStripe: HTTPXClient was initialized with allow_sync_methods=False, so it cannot be used for synchronous requests.) r] RuntimeErrorrfrrrrrbrt rVrrrtrr&r'rYrrrbresponse_headersr#r#r$r s"  zHTTPXClient.requestc ~|||||\}}z|jj|i|IdH}Wnty0}z ||WYd}~nd}~ww|j} |j} |j} | | | fSr)rfrdrrrrrbrtrhr#r#r$r#s zHTTPXClient.request_asyncrcC:d}dt|jf}d}t|d|f}t||d|NrrTrr_rr?rrrrr#r#r$r7 z!HTTPXClient._handle_request_errorc Cs|jdur td|||||\}}z|jj|jj|i|dd}Wnty;}z ||WYd}~nd}~ww|} |j } |j }| | |fS)NztStripe: HTTPXClient was not initialized with allow_sync_methods=True, so it cannot be used for synchronous requests.Trr) r]rgrfsendrd build_requestrr iter_bytesrbrt rVrrrtrr&r'rYrrrbr#r#r$rBs(   zHTTPXClient.request_streamc s|||||\}}z|jj|jj|i|ddIdH}Wnty6}z ||WYd}~nd}~ww|} |j} |j}| | |fS)NTro) rfrdrprqrr aiter_bytesrbrtrsr#r#r$rZs" z HTTPXClient.request_stream_asynccCs|jdur |jdSdSr)r]rrr#r#r$rms zHTTPXClient.closec|jIdHdSr)rdacloserr#r#r$rqzHTTPXClient.close_async)rFNr)r?r@rAr<r rCrrrXrrBr rfrrr rrrrrr rrrrrrr#r#rr$r7sx  !           r7cs@eZdZdZ  d"deeedfffdd Zedd Z d d Z d e e e eeefffd dZdededeeeffddZ d#dededeeefd e e e eeefffddZded efddZd e ee e eeefffddZ d#dededeeefd e de eeefffddZddZd d!ZZS)$r9r8rNrAIOHTTPTimeoutc s@tt|jdi||durddl}|}||_||_d|_dS)Nrr#)rr9rXr8r_cached_session)rVrrWr'r8rr#r$rXxs zAIOHTTPClient.__init__cCsb|jdur.i}|jrtjtjd}|jj|d|d<n |jjdd|d<|jjdi||_|jS)Nr_)ra connectorF) verify_sslr#) ryrJrarbrwrr8 TCPConnector ClientSession)rVr' ssl_contextr#r#r$rs   zAIOHTTPClient._sessioncCs t|Sr)asynciorrr#r#r$rs zAIOHTTPClient.sleep_asyncr(cCrNz4AIOHTTPClient does not support synchronous requests.rrr#r#r$rrzAIOHTTPClient.requestrrrtcCsd||f}i}|jr|jd|jdkrtd|jd|d<|jr&|j|d<||d<||d<||fS)Nr=r>zDAIOHTTPClient does not support different proxies for HTTP and HTTPS.rLrrtr)rIrPr)rVrrrtrr&r'r#r#r$rfs z&AIOHTTPClient._get_request_args_kwargscs4|j||||dIdH\}}}|IdH||fS)N)r)rrT)rVrrrtrrrbrir#r#r$rs  zAIOHTTPClient.request_asyncrcCrkrlrmrr#r#r$rrnz#AIOHTTPClient._handle_request_errorcCrrrrr#r#r$rrzAIOHTTPClient.request_streamAIOHTTPStreamReaderc rjr)rfrrrrrstatusrtrhr#r#r$rs z"AIOHTTPClient.request_stream_asynccCrrr#rr#r#r$rrzAIOHTTPClient.closecrur)rrrr#r#r$rrwzAIOHTTPClient.close_async)rNr)r?r@rAr<r rrrXpropertyrrrrr r rBrrfrrrrr rrrrrr#r#rr$r9usT      $   r9cseZdZfddZedefddZ ddeded eeefde e e eeefffd d Z ddeded eeeffd d Z ddZZS)r:c stt|jdi|dS)Nr#)rr:rX)rVr'rr#r$rXsz!NoImportFoundAsyncClient.__init__r(cCr)NzImport httpx not found. To make async http requests,You must either install httpx or define your ownasync http client by subclassing stripe.HTTPClientand setting stripe.default_http_client to an instance of it.)r-r#r#r#r$raise_async_client_import_errorsz8NoImportFoundAsyncClient.raise_async_client_import_errorNrrrtc|dSrrrr#r#r$r z&NoImportFoundAsyncClient.request_asynccrrrrr#r#r$rrz-NoImportFoundAsyncClient.request_stream_asynccrrrrr#r#r$r s z$NoImportFoundAsyncClient.close_asyncr)r?r@rArX staticmethodrrrBr rrr rrrrr#r#rr$r:s.      r:)Diorrrr"rrrSrzrra http.clientrrwrstripe._request_metricsr stripe._errorrtypingrrr r r r r rrrrrrtyping_extensionsrrrrrrrrr/rrr-r5rr^rr\r8rrxrrr%r4r;objectr)r0r.rDr2r3r7r9r:r#r#r#r$sl     <       #I@K}${