Ai9lddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl Z ddl m Z ddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZmZddl m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&e!r'dd l'm(Z( dd l)m*Z+ dd l-m.Z/dd l-m0Z1 dd l2m3Z4ddl2m5Z6dZ7dededdfdZ8dededdfdZ9Gdde:Z;Gdde;Z<Gdde;Z=Gdde$Z>Gdde;Z?Gdd e;Z@Gd!d"e;ZAGd#d$e;ZBGd%d&e;ZCy#e,$rYwxYw#e,$rYwxYw#e,$rYwxYw)')BytesION) HTTPResponse)_util)RequestMetrics)APIConnectionError) AnyDictIterableListMappingMutableMappingOptionalTupleClassVarUnioncastoverload AsyncIterable) TYPE_CHECKINGLiteralNoReturn TypedDict AwaitableNever) ParseResult)Session)Timeout)Client) ClientTimeout) StreamReadercTtttjdzS)Ni)introundtimeF/var/www/html/immo/lib/python3.12/site-packages/stripe/_http_client.py_now_msr(?s uTYY[4'( ))r&argskwargsreturn HTTPClientc ddlm}t|i|S#t$rYnwxYw ddl}t |i|S#t$rYnwxYw ddl}t|i|S#t$rYnwxYwt|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/UrlFetchClient ImportErrorrequestsRequestsClientpycurl PycurlClient UrllibClient)r)r*r/r3r5s r'new_default_http_clientr8Cs/1t.v..    /t.v..    -T,V,,     ( ((s* 2 >>A AAc ddl}ddl}t|i|S#t$rYnwxYw ddl}t |i|S#t$rYnwxYwt |i|S)z~ Similar to `new_default_http_client` above, this returns a client that can handle async HTTP requests, if available. rN)httpxanyio HTTPXClientr2aiohttp AIOHTTPClientNoImportFoundAsyncClient)r)r*r:r;r=s r'new_http_client_async_fallbackr@fss ,D+F++    .d-f--    $T 4V 44s !!4 AAceZdZUdZeeed<GddeZdZ dZ dZ e eed<e ed < d4d e d e eeefde dfdZde eeee eeeffde edede efdZ d5de eeeeeefffdZ d5dede eeeeeeffdefdZdedefdZdeeefdeeeffdZdZ d6d ddededeeefd ede ed!e eedeeeeeefffd"Z d6d ddededeeefd!e eedeeeeeefff d#Zd ddededeeefd ed$e de ed!e eedeeeeeefffd%Z d5d ddedede eeefd ed!e eedeeeeeefff d&Z d5d ddedede eeefd ed!e eedeeeeeefff d'Z!d(Z" d6d ddededeeefde ed!e eedeeeeff d)Z# d6d ddededeeefd!e eedee$e%eeff d*Z&e'd ddededeeefd$e(d+de ed!e eedeeeeeefffd,Z)e'd ddededeeefd$e(d de ed!e eedee$e%eeeefffd-Z)d ddededeeefd$e de ed!e eedeeeeeefffd.Z) d5dededeeefdee%eeeefffd/Z* d5dededeeefdee$e%eeeefffd0Z+d1Z,d2ede-d fd3Z.y )7r,z@ Base HTTP client that custom clients can inherit from. namec.eZdZUeeed<eeed<y)HTTPClient._ProxyhttphttpsN)__name__ __module__ __qualname__rstr__annotations__r%r&r'_ProxyrDssm}r&rL?<_proxy_verify_ssl_certsTNverify_ssl_certsproxyasync_fallback_clientc||_|r0t|tr||d}t|ts t d|r|j nd|_||_tj|_ y)N)rErFzqProxy(ies) must be specified as either a string URL or a dict() with string URL under the https and/or http keys.) rQ isinstancerJdict ValueErrorcopyrP_async_fallback_client threadinglocal _thread_local)selfrRrSrT_libs r'__init__zHTTPClient.__init__si"2 %%!&7eT* ',ejjl &;#&__.r&responseapi_connection_error num_retriesmax_network_retriesc||nd}||k\ry||J|jS|\}}}|d|vr|ddk(ry|ddk(ry|dk(ry|dk\ryy) NrFzstripe-should-retryfalsetrueTii should_retry)r^rarbrcrd_ status_coderheaderss r' _should_retryzHTTPClient._should_retrys$7#B   - -   (3 33'44 4#+ ;  $9X$E-.'9-.&8 #  # r&c\|y|\}}} t|dS#ttf$rYywxYw)Nz retry-after)r"KeyErrorrX)r^rarjrls r'_retry_after_headerzHTTPClient._retry_after_headersD  !1h x ./ /*%  s ++r+c&ttjd|dz zztj}|j |}t tj|}|j |xsd}|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_timemaxrpMAX_RETRY_AFTER)r^rcra sleep_seconds retry_afters r'_sleep_time_secondszHTTPClient._sleep_time_secondss  $ $kAo(> ?   --m< J44mD ..x8=A *44 4 ];Mr&rzcD|ddtjddzzz}|S)z Randomize the value in `[(sleep_seconds/ 2) to (sleep_seconds)]`. Also separated method here to isolate randomness for tests rNrsr)randomuniform)r^rzs r'rwzHTTPClient._add_jitter_times) FNN1a$8 899 r&headersct|jdd}tjr9|r7d|j i}t |}t j||d<|S|S)Nlast_request_metricszX-Stripe-Client-Telemetry)getattrr]stripeenable_telemetrypayloadrWjsondumps)r^rr telemetryrets r'_add_telemetry_headerz HTTPClient._add_telemetry_headersj '    6   " "';&(<(D(D(FIw-C/3zz)/DC+ ,Jr&c|\}}}d|vrAtjr0|d}t|z }t||||j_yyy)Nz Request-Idusage)rrr(rr]r)r^ra request_startrrjrl request_idrequest_duration_mss r'_record_request_metricsz"HTTPClient._record_request_metricssX!1h 8 #(?(?!,/J"))m"; 6D/u7D   3)@ #r&)_usagemethodurl post_datarc 2|j||||d||SNF is_streamingrdr_request_with_retries_internalr^rrrrrdrs r'request_with_retrieszHTTPClient.request_with_retriess122     33  r&c 2|j||||d||SNTrrrs r'request_stream_with_retriesz&HTTPClient.request_stream_with_retries1s122     33  r&rc|j|}d} t} |r|j||||} n|j||||} d} |j | | ||rm| r"t jd| jz|dz }|j|| } t jd|||| fztj| n| |j| | || S| J| #t$r} | } d} Yd} ~ d} ~ wwxYwNrz Encountered a retryable error %srszBInitiating retry %i for request %s %s after sleeping %.2f seconds.r) rr(request_streamrequestrrmrlog_info user_messager|r$sleeprr^rrrrrrdrrcrraconnection_errore sleep_times r'rz)HTTPClient._request_with_retries_internalEsH,,W5 #IM #22Wi H $||FC)LH#' !!*K9L$NN:*778q !55k8L 1&Z@A :&'00 -v1$O+777**U& #$  s-C-- D6C??Dctd)Nz.HTTPClient subclasses must implement `request`NotImplementedErrorr^rrrrrs r'rzHTTPClient.requests" <  r&ctd)Nz5HTTPClient subclasses must implement `request_stream`rrs r'rzHTTPClient.request_streams" C  r&ctd)Nz,HTTPClient subclasses must implement `close`rr^s r'closezHTTPClient.closes! :  r&c NK|j||||d||d{S7wr$_request_with_retries_internal_asyncrs r'request_with_retries_asyncz%HTTPClient.request_with_retries_asyncs?>>     3?    %#%c NK|j||||d||d{S7wrrrs r'!request_stream_with_retries_asyncz,HTTPClient.request_stream_with_retries_asyncs?>>     3?    rFc KywNr%r^rrrrrrdrs r'rz/HTTPClient._request_with_retries_internal_asyncs .1c Kywrr%rs r'rz/HTTPClient._request_with_retries_internal_asyncs ?BrcJK|j|}d} t} |r|j||||d{} n|j||||d{} d} |j | | ||rq| r"t jd| jz|dz }|j|| } t jd|||| fz|j| d{n| |j| | || S| J| 77#t$r} | } d} Yd} ~ d} ~ wwxYw7Bwr) rr(request_stream_async request_asyncrrmrrrr| sleep_asyncrrs r'rz/HTTPClient._request_with_retries_internal_asyncsu,,W5 #IM %)%>%>Wi& H&*%7%7Wi& H$( !!*K9L$NN:*778q !55k8L 1&Z@A&&z222'00 -v1$O+777**Y   & #$  *3s]D#DDDDDA?D#D!$D#DD DDD#DD#cK|j&|jj||||d{Std7w)Nz4HTTPClient subclasses must implement `request_async`)rZrrr^rrrrs r'rzHTTPClient.request_asyncsR  & & 244BBWi " B  .AAAcK|j&|jj||||d{Std7w)Nz;HTTPClient subclasses must implement `request_stream_async`)rZrrrs r'rzHTTPClient.request_stream_async)sR  & & 244IIWi " I  rcK|j"|jjd{Std7w)Nz2HTTPClient subclasses must implement `close_async`)rZ close_asyncrrs r'rzHTTPClient.close_async4s@  & & 244@@BB B! @  Cs *><>secscf|j|jj|Std)Nz,HTTPClient subclasses must implement `sleep`)rZrrr^rs r'rzHTTPClient.sleep_async;s5  & & 2..::4@ @! :  r&TNNNr)NN)/rGrHrI__doc__rrJrKrrLrvruryrboolrr`rrr"r rrmrpfloatr|rwrrr rrrrrrrrbytesrrrrrrrrrr%r&r'r,r,}s) 3-IMO V "&.28<  //c6k*+/ ( 5 /4-5c8GCH4E+F!FGH-''9:- - &c] -`HL  sCc1B'B!CD BF5c738+  4e sCx(  c  -1  '+   c"    &c]  c#  sCc** + 2  '+   c"  c#  sCc** + :'+9+9+9+c" 9+  9+  9+&c]9+c#9+ sCc** +9+@  '+      '#s(+,    c#   sCc** +  $  '+      '#s(+,    c#   sCc** +   -1  '+   c"  &c]  c#  sC}  2  '+   c"  c#  }U#S#- . ('+ 1 1 1c" 1 en 1&c] 1c# 1 sCc** + 1 1'+ B B Bc" B dm B&c] Bc# B }U#S'#s(*;; < B B*'+;+;+;+c" ;+  ;+&c];+c#;+ sCc** +;+|LP    #  .5c3h.?  uc738,, -  LP    #  .5c3h.?  }U#S'#s(*;; <     )D/ r&ceZdZdZ ddeeeeeffdeddedeee e jfdee f fd Z dd e d e d ee e e fd eeee e e fffdZ dd e d e d ee e e fd eeee e e fffdZed e d e d ee e e fdedd eeee e e fff dZed e d e d ee e e fdedd eeee e e fff dZd e d e d ee e e fded eeeefee e e fff dZded efdZdZxZS)r4r3TtimeoutsessionRequestsSessionrRrSrTc ltt| |||||_||_|ddl}|}||_yNrRrSrTr)superr4r`_session_timeoutr3) r^rrrRrSrTr_r*r3 __class__s r'r`zRequestsClient.__init__FsF nd,-"7 -    < D r&rrrr+c.|j||||dSNFr_request_internalrs r'rzRequestsClient.request_s'%% C)%&  r&c.|j||||dSNTrrrs r'rzRequestsClient.request_streamjs'%% C)$&  r&rcyrr%r^rrrrrs r'rz RequestsClient._request_internalu.1r&Fcyrr%rs r'rz RequestsClient._request_internals03r&ci}|jrtj|d<nd|d<|jr|j|d<|rd|d<t |j dd7|j xs|jj|j _ td|j jj||f|||jd|}|r |j} n |j} |j }   j&fS#t$r}td |d}~wwxYw#t"$r}|j%|Yd}~Md}~wwxYw) NverifyFproxiesTstreamrr)rdataraWarning: 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: )rQrca_bundle_pathrPrr]rr3rrrrr TypeErrorrawcontentrk Exception_handle_request_errorr) r^rrrrrr*resultrrrks r'rz RequestsClient._request_internalse  ! !%44F8 $F8  ;; $ F9  #F8  4%%y$ 7 ? 8!6!6!8    &" * %t'9'9'A'A'  $" MM  ( ** !.. ,,K  V^^331  34 6 & *  & &q ) ) *s7AD'D/ D,D''D,,D// E8EErct||jjjr)d}t |j dt |}d}nt||jjj|jjjfr(d}t |j dt |}d}nt||jjjr(d}t |j dt |}d}n?d}dt |j d}t |r|d t |z }n|d z }d}tj|d |d z}t|| |)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.: FziUnexpected 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 was raisedz with error message z with no error message (Network error: )rh) rVr3 exceptionsSSLErrortyperGrJrConnectionErrorRequestExceptiontextwrapfillrr^rmsgerrris r'rz$RequestsClient._handle_request_errorsT a11:: ;&  #1g..A7C L   ((00 ((88  &  #1g..A7CL 4==33DD E&  #1g..A7C L.  (,Aw'7'79C1v3q6;;// LmmC #EE <@aGr&c|t|jdd%|jjjyy)Nr)rr]rrrs r'rzRequestsClient.closes5 4%%y$ 7 C    & & , , . Dr&)PNTNNNr)rGrHrIrBrrrrrrJr,rLr`r rr"rrrrrrrrrr __classcell__rs@r'r4r4Cs~ D68/3!%9=6: ueE5L112+,  c:#4#4456  ( 3 <      '#s(+,  uc738,, -        '#s(+,  sCc** +  111'#s(+, 1 dm 1 sCc** +11333'#s(+, 3 en 3 uc738,, -33=4=4=4'#s(+, =4  =4 uUCZ #wsCx'88 9=4~3Hy3HX3Hj/r&r4ceZdZdZ ddedeejdedeeffd Z dde d e d e e e fd e e ee e e fffd Z dde d e d e e e fd e eee e e fffd Zede d e d e e e fdedd e eeeff dZede d e d e e e fdedd e e eeff dZde d e d e e e ffdZded e d efdZdZxZS)r1r/TrRrSdeadlinerTctt| ||||r td||_||_|ddlm}|}||_y)NrzNo proxy support in urlfetch library. Set stripe.default_http_client to either RequestsClient, PycurlClient, or UrllibClient instance to use a proxy.rr.)rr1r`rXrQ _deadliner0r/)r^rRrSr rTr_r/rs r'r`zUrlFetchClient.__init__sa nd,-"7 -  I  "2" < 5D r&rrrr+c.|j||||dSrrrs r'rzUrlFetchClient.request('%% C)%&  r&c.|j||||dSrrrs r'rzUrlFetchClient.request_stream/'%% C)$&  r&rcyrr%rs r'rz UrlFetchClient._request_internal6$'r&Fcyrr%rs r'rz UrlFetchClient._request_internal@ #r&c~ |jj||||j|j|}|r)t tjj}n j}||j|jfS#|jj$r}|j ||Yd}~d}~wwxYw)N)rrrvalidate_certificater r) r/fetchrQr ErrorrrrJencoderrkr) r^rrrrrrrrs r'rz UrlFetchClient._request_internalJs /]]((&*%;%;!) F cjj89GnnG**FNN::}}"" /  & &q# . . /s5BB< B77B<rcFt||jjrd|d}nHt||jjrd}n%t||jjrd}nd}t j |dzt|zdz}t||)Nz6The Stripe library attempted to fetch an invalid URL (zg). 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.rr) rVr/InvalidURLError DownloadErrorResponseTooLargeErrorrrrJr)r^rrrs r'rz$UrlFetchClient._handle_request_erroris a66 7 -02  4==66 7DC 4==>> ?< G  mmC #99CFBSH %1,r&cyrr%rs r'rzUrlFetchClient.close r&)TN7NNr)rGrHrIrBrrr,rLr"r`rJr rrrrrrrrrrrrrr s@r'r1r1s D"&-16:  !! ))*! ! ( 3 !HLP  # .5c3h.? sCc** + LP  # .5c3h.? wWS#X.. / '''c" ' dm ' wS !''###c" # en # sC} ##;;;c" ;>-y-s-x-2 r&r1c.eZdZUeded<eded<y)rLrrErFNrGrHrIrrKr%r&r'rLrLs = !! M ""r&rLceZdZUGddedZdZeeed< dded ee jd ee ffd Z d Z dd e eefdeeee eefffdZ dd e eefdeeee eefffdZededed e eefdeddeeeeff dZededed e eefdeddeeee eefff dZdeded e eefdeeeefee eefffdZdedefdZdedfdZdZxZS)r6c.eZdZUeded<eded<y)PycurlClient._ParsedProxyrrErFNr$r%r&r' _ParsedProxyr's}%% &&r&r(F)totalr5 _parsed_proxyTrRrSrTc<tt| ||||ddl}|}||_|j |_i|_|jrNddlm }|j}|jD](\}} |tt| |j |<*yy)Nrr)urlparse) rr6r`r5Curl_curlr*rP urllib.parser,itemsrrJ) r^rRrSrTr_r5r,proxy_schemevaluers r'r`zPycurlClient.__init__s lD*-"7 + < D YY[  ;; -[[F!' H .6d36F-G""6* H r&cd|vriS|jddd}tj|}tdt|j DS)Nz rsc3FK|]\}}|j|fywrlower.0kvs r' z-PycurlClient.parse_headers..sEtq!QWWYNE!)splitemailmessage_from_stringrWr0)r^r raw_headersrs r' parse_headerszPycurlClient.parse_headerssR  Ijj+A. ++K8EtG}/B/B/DEEEr&rr+c.|j||||dSrrrs r'rzPycurlClient.requestrr&c.|j||||dSrrrs r'rzPycurlClient.request_streamrr&rrrcyrr%rs r'rzPycurlClient._request_internalrr&cyrr%rs r'rzPycurlClient._request_internalrr&c  t}t}|jj|j|}|r|jr:|jj |j j|j|jr:|jj |j j|j|js |jrI|jj |j j|jd|j|dk(r1|jj |j jdn|dk(ra|jj |j jd|jj |j j|n>|jj |j j |j#|jj |j j$||jj |j j&|j(|jj |j j*|j(|jj |j j,d|jj |j j.d|jj |j j0d|jj |j j2t5|j7D cgc] \} } | d| c} } |j8r?|jj |j j:t<j>n0|jj |j j@d |jjC|r|jId |} n|jKjMd } |jjO|j jP} |jS|jKjMd }| | |fScc} } w#|j jD$r} |jG| Yd} ~ d} ~ wwxYw) N:getrspostrrFrutf-8)*rr.reset _get_proxyhostnamesetoptr5PROXYport PROXYPORTusernamepassword PROXYUSERPWDHTTPGETPOST POSTFIELDS CUSTOMREQUESTupperURL WRITEFUNCTIONwriteHEADERFUNCTIONNOSIGNALCONNECTTIMEOUTTIMEOUT HTTPHEADERrWr0rQCAINFOrrSSL_VERIFYHOSTperformerrorrseekgetvaluedecodegetinfo RESPONSE_CODErB)r^rrrrrbrlrSr:r;rrcontentrcodes r'rzPycurlClient._request_internals` I9 $ ~~ !!$++"3"3U^^Dzz !!$++"7"7D~~ !!KK,,$~~u~~> U? JJ  dkk111 5 v  JJ  dkk.. 2 JJ  dkk44i @ JJ  dkk77 H $++//3/ $++33QWW= $++44hnnE $++..2 $++44b9 $++--r2  KK " "+/=+>+>+@ A41aA  A   ! ! JJ  dkk00&2G2G H JJ  dkk88% @ * JJ     FF1IHzz|**73H ""4;;#<#<=$$X%6%6%8%?%?%HI''+ B{{   *  & &q ) ) *sS ST(S>>Trc|jd|jj|jj|jjfvrd}d}nD|jd|jj |jj fvrd}d}nd}d}tj|dz|jdzd z}t|| |) 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.TrFrrrsrrh) r)r5E_COULDNT_CONNECTE_COULDNT_RESOLVE_HOSTE_OPERATION_TIMEOUTED E_SSL_CACERTE_SSL_PEER_CERTIFICATErrr)r^rrris r'rz"PycurlClient._handle_request_error&s 66!9 KK ) ) KK . . KK - -  &  L VVAY KK $ $ KK . .  &  !LG !LmmC #99AFF1IEK <@aGr&rc|jrJ|j}|r|jddnd}|r$|j||j|ddSy)NrHr)r*r>rI)r^rrSr2s r'rNzPycurlClient._get_proxyIsR   &&E*-SYYs^A&4Fyy6!B<)@AAr&cyrr%rs r'rzPycurlClient.closeQr!r&rr)rGrHrIrr(rBrrKrr,rLr`rBr rJrr"rrrrrrrrrrrrNrrr s@r'r6r6s)'y' DL))"&-16:  H H ))* H ( 3 HDFBF $+CH$5 sCc** + BF $+CH$5 wWS#X.. / '''c" ' dm ' wS !''111c" 1 en 1 sCc** +11F(F(F(c" F( uS'\"Cc):: ;F(P!Hy!HX!HF-!8 r&r6ceZdZdZ ddedeejdeeffd Z dde de d e e e fd e e e e e e fffd Z dde de d e e e fd e ee e e e fffd Zede de d e e e fd edd e e e eff dZede de d e e e fd edd e ee eff dZde de d e e e ffdZded efdZdZxZS)r7zurllib.requestTrRrSrTcVtt| ||||ddlm}|}||_ddlm}||_d|_ |jra|j jttttf|j}|j j||_ yyr)rr7r`urllib.requestr urllibrequest urllib.errorrg urlliberror_openerrP ProxyHandlerrr rJ build_opener) r^rRrSrTr_r|r~ proxy_handlerrs r'r`zUrllibClient.__init__Xs lD*-"7 + < 2 D!*& ;;!..;;T#s(^T[[1M --::=IDL r&rrrr+c.|j||||dSrrrs r'rzUrllibClient.requestyrr&c.|j||||dSrrrs r'rzUrllibClient.request_streamrr&rFcyrr%rs r'rzUrllibClient._request_internalrr&cyrr%rs r'rzUrllibClient._request_internals),r&c `t|tr|jd}|jj ||t t ttf|}dvr fd|_ |jr|jj|n|jj|}|r|}n|j}|j} t|j}tdt)t|j+D}  | fS#|jj $r?} | j} | j}t| j}Yd} ~ d} ~ w|jj"t$f$r} |j'| Yd} ~ d} ~ wwxYw)NrL)rIrJc$jSr)r[)rsr'z0UrllibClient._request_internal..s V\\^r&c3FK|]\}}|j|fywrr6r8s r'r<z1UrllibClient._request_internal..sITQ1779a.Ir=)rVrJrr|Requestrr get_methodropenurlopenreadcoderWinfor~ HTTPErrorURLErrorrXriterr0) r^rrrrrreqrarnrorlhs ` r'rzUrllibClient._request_internalsc i %!((1I  (( DS!97C   (3CN * << !!#&''//4  ##==?MME8==?+GIT$w-2E2E2G-HI I"")) %FFEvvxH1668nG  )):6 *  & &q ) ) *s%*A K mmC #99CFBSH %1,r&cyrr%rs r'rzUrllibClient.closer!r&rr)rGrHrIrBrrr,rLr`rJr rr"rrrrrrrrrrrrr s@r'r7r7Us D"&-16:  JJ ))*J ( 3 JDLP  # .5c3h.? sCc** + LP  # .5c3h.? |S'#s("33 4 ###c" # en # sC} ##,,,c" , dm , |S#% &,,)#)#)#c" )#V-y-X- r&r7ceZdZUdZeded< ddeeedfffd ZdZ de d e d e e e ffd Z dde d e d e e e fd e eee e e fffd Z dde d e d e e e fd e eee e e fffdZded efdZ dde d e d e e e fd e eeee e e fffdZ dde d e d e e e fd e eeee e e fffdZdZdZxZS)r<r:HTTPXClientType_clientr HTTPXTimeoutc ztt| di||ddl}|}||_ddl}||_i}|j r(t jtj|d<nd|d<|jjdi||_ d|_ |r!|jjdi||_ ||_y)NrcafilerFr%)rr<r`r:r;rQsslcreate_default_contextrr AsyncClient _client_asyncrrr)r^rallow_sync_methodsr_r*r:r;rs r'r`zHTTPXClient.__init__s k4)3F3 < D    ! !"99,, F8  %F8 3TZZ33=f= ,4::,,6v6DL r&c8|jj|Sr)r;rrs r'rzHTTPXClient.sleep_asyncszz%%r&rrrci}|jr|j|d<|jr|j|d<||f||xsid|gS)Nrr)rr)rPr)r^rrrrr*s r'_get_request_args_kwargsz$HTTPXClient._get_request_args_kwargssU ;; $ F9  == $ F9  SMb CF C  r&r+c8|j td|j||||\}} |jj|i|}j } |j} |j} | | | fS#t$r}|j |Yd}~Hd}~wwxYw)NzqStripe: HTTPXClient was initialized with allow_sync_methods=False, so it cannot be used for synchronous requests.) r RuntimeErrorrrrrrrkr r^rrrrr)r*rarrrkresponse_headerss r'rzHTTPXClient.request s << A 44 C) f *+t||++TBBc&K|j||||\}} |jj|i|d{}j } |j } |j} | | | fS7-#t$r}|j |Yd}~Jd}~wwxYwwr)rrrrrrrkrrs r'rzHTTPXClient.request_async#s44 C) f *7T//77HHHH""** #++ %555I *  & &q ) ) *=BA*A(A*)B(A** B3B B BBrcd}dt|jd}d}tj|d|dz}t |||NrrrTrrrhrrGrrrrs r'rz!HTTPXClient._handle_request_error7K C $(7#3#35 mmC #EE <@aGr&cv|j td|j||||\}} |jj|jj |i|d}j} |j} |j}| | |fS#t $r}|j|Yd}~Ld}~wwxYw)NztStripe: HTTPXClient was not initialized with allow_sync_methods=True, so it cannot be used for synchronous requests.Trr) rrrsendr build_requestrr iter_bytesrkr r^rrrrr)r*rarrrks r'rzHTTPXClient.request_streamBs << A 44 C) f *||((8**88$I&I)H %%'** "" W,,  *  & &q ) ) *s7B B8B33B8cdK|j||||\}} |jj|jj|i|dd{}j } |j} |j}| | |fS71#t$r}|j |Yd}~Nd}~wwxYww)NTr) rrrrrr aiter_bytesrkrrs r'rz HTTPXClient.request_stream_asyncZs44 C) f *!//448**88$I&I5H &&(** "" W,, *  & &q ) ) *s@B0:B BB -B0B B-B(#B0(B--B0cR|j|jjyyr)rrrs r'rzHTTPXClient.closems! << # LL    $r&cTK|jjd{y7wr)raclosers r'rzHTTPXClient.close_asyncqs  ''))) (&()rFNr)rGrHrIrBrrKrrr`rrJr rrrr"rrrrrr rrrrrrr s@r'r<r<s D ' ((;=   %~ 567 B&    #  .5c3h.?  ( 666c" 6 uc738,, - 6< 666c" 6 uc738,, - 6( Hy HX HLP-- #-.5c3h.?- xWS#X%66 7-2LP-- #-.5c3h.?- }U#S'#s(*;; <-&!*r&r<cPeZdZdZ ddeeedfffd ZedZ dZ de e e eeefffdZd ed ed eeeffd Z dd ed ed eeefde e e eeefffd ZdedefdZde ee e eeefffdZ dd ed ed eeefde de eeefffdZdZdZxZS)r>r=rAIOHTTPTimeoutc ftt| di||ddl}|}||_||_d|_y)Nrr%)rr>r`r=r_cached_session)r^rr_r*r=rs r'r`zAIOHTTPClient.__init__xs: mT+5f5 < D  #r&cV|ji}|jrDtjtj }|j j||d<n|j jd|d<|j jdi||_|jS)Nr)r connectorF) verify_sslr%) rrQrrrrr= TCPConnector ClientSession)r^r* ssl_contexts r'rzAIOHTTPClient._sessions    'F%%!88!00 '+ll&?&?#'@'{#'+ll&?&?$'@'{#$>4<<#=#=#G#GD ###r&c,tj|Sr)asynciorrs r'rzAIOHTTPClient.sleep_asyncs}}T""r&r+ctdNz4AIOHTTPClient does not support synchronous requests.rrs r'rzAIOHTTPClient.request! B  r&rrrc||f}i}|jr<|jd|jdk7r td|jd|d<|jr|j|d<||d<||d<||fS)NrErFzDAIOHTTPClient does not support different proxies for HTTP and HTTPS.rSrrr)rPrXr)r^rrrrr)r*s r'rz&AIOHTTPClient._get_request_args_kwargss} ;;{{6"dkk'&:: Z#kk'2F7O == $ F9 #y"vV|r&cK|j||||d{\}}}|jd{||fS7#7 w)N)r)rr)r^rrrrrrkrs r'rzAIOHTTPClient.request_asyncs[++ CI,      lln${4DDD  %sA?AAAArcd}dt|jd}d}tj|d|dz}t |||rrrs r'rz#AIOHTTPClient._handle_request_errorrr&ctdrrrs r'rzAIOHTTPClient.request_streamrr&AIOHTTPStreamReaderc&K|j||||\}} |jj|i|d{}j } |j } |j} | | | fS7-#t$r}|j |Yd}~Jd}~wwxYwwr)rrrrrrstatusrrs r'rz"AIOHTTPClient.request_stream_asyncs44 C) f *2T]]22DCFCCH""oo #++ %555D *  & &q ) ) *rcyrr%rs r'rzAIOHTTPClient.closer!r&cTK|jjd{y7wr)rrrs r'rzAIOHTTPClient.close_asyncsmm!!###r)rNr)rGrHrIrBrrrr`propertyrrrrr"r rJrrrrrrr rrrrrr s@r'r>r>usp D=? $%'7 789$$$$&# uc738+<<=  #.5c3h.?. EEEc" E uc738,, - E" Hy HX H huosGCHceZdZfdZedefdZ d dededeeefde e e eeefffdZ d dededeeeffdZ d ZxZS) r?c ,tt| di|y)Nr%)rr?r`)r^r*rs r'r`z!NoImportFoundAsyncClient.__init__s &6@@r&r+ctd)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.)r2r%r&r'raise_async_client_import_errorz8NoImportFoundAsyncClient.raise_async_client_import_errorsO  r&rrrc,K|jywrrrs r'rz&NoImportFoundAsyncClient.request_async ,,.c,K|jywrrrs r'rz-NoImportFoundAsyncClient.request_stream_asyncrrc,K|jywrrrs r'rz$NoImportFoundAsyncClient.close_async s ,,.rr)rGrHrIr` staticmethodrrrJr rrr"rrrrr s@r'r?r?sA U  LP// #/.5c3h.?/ uc738,, -/ LP// #/.5c3h.?/ /r&r?)Diorrr?r$r~r[rrr http.clientrrrstripe._request_metricsr stripe._errorrtypingrr r r r r rrrrrrrtyping_extensionsrrrrrrr/rr3rrr2r:rrrrr=rrr rr(r8r@objectr,r4r1rLr6r7r<r>r?r%r&r'rsk   $2,( 7 13 ;? * )3 )# ), )F5#555.C C L|/Z|/~A ZA H#Y# G :G Tz :z z`**`*Fx$Jx$v/z/C.          s6:D D  D+DD D('D(+D32D3