<@g.UddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl Z ddl mZddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZmZm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z& ddl'm(Z)ddl*m+Z, ddl.Z. ddl/Z/ddl0Z0dd l/m1Z2dd l/m3Z4 ddl5Z5dd l5m6Z7dd l5m8Z9 ddl:Z:dd l:m;Z< e=e>d<e:j~Z@eAe>d<eAe>d<eAe>d<e@jdDcgc] }eA| c}\ZCZDZEeCeDeEfdkr"ejjde@ddZ: ddlImJZJddlKmLZLmMZMdZNdededdfdZOdededdfdZPGddeQZRGd d!eRZSGd"d#eRZTGd$d%e$ZUGd&d'eRZVGd(d)eRZWGd*d+eRZXGd,d-eRZYGd.d/eRZZy#e-$rYxs/      r-cRtrt}ntrt}nt}||i|Sr5)httpx HTTPXClientaiohttp AIOHTTPClientNoImportFoundAsyncClientr<s r.new_http_client_async_fallbackrEs'  '    r-ceZdZUeeed<GddeZdZdZ dZ e eed<e ed< d3d e d e e eefd e dfdZde eeee eeeffde edede efdZ d4de eeeeeefffdZ d4dede eeeeeeffdefdZdedefdZdeeefdeeeffdZdZ d5d ddededeeefdede ed e eedeeeeeefffd!Z d5d ddededeeefd e eedeeeeeefff d"Zd ddededeeefded#e de ed e eedeeeeeefffd$Z d4d ddedede eeefded e eedeeeeeefff d%Z d4d ddedede eeefded e eedeeeeeefff d&Z d'Z! d5d ddededeeefde ed e eedeeeeff d(Z" d5d 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( d4dededeeefdee$eeeefffd.Z) d4dededeeefdee#e$eeeefffd/Z*d0Z+d1ede,d fd2Z-y )6r3namec.eZdZUeeed<eeed<y)HTTPClient._ProxyhttphttpsN)__name__ __module__ __qualname__rstr__annotations__r,r-r._ProxyrIssm}r-rQ?<_proxy_verify_ssl_certsTNverify_ssl_certsproxyasync_fallback_clientc||_|r0t|tr||d}t|ts t d|r|j nd|_||_tj|_ y)N)rJrKzqProxy(ies) must be specified as either a string URL or a dict() with string URL under the https and/or http keys.) rV isinstancerOdict ValueErrorcopyrU_async_fallback_client threadinglocal _thread_local)selfrWrXrYs 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)rcrerfrgrh_ 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)KeyErrorr])rcrernrps r._retry_after_headerzHTTPClient._retry_after_headersD  !1h x ./ /*%  s ++r2c&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)minr3 INITIAL_DELAY MAX_DELAY_add_jitter_timemaxrtMAX_RETRY_AFTER)rcrgre sleep_seconds retry_afters r._sleep_time_secondszHTTPClient._sleep_time_secondss  $ $kAo(> ?   --m< J44mD ..x8=A *44 4 ];Mr-r~cD|ddtjddzzz}|S)z Randomize the value in `[(sleep_seconds/ 2) to (sleep_seconds)]`. Also separated method here to isolate randomness for tests rSrwr)randomuniform)rcr~s r.r{zHTTPClient._add_jitter_time s) FNN1a$8 899 r-headersct|jdd}tjr9|r7d|j i}t |}t j||d<|S|S)Nlast_request_metricszX-Stripe-Client-Telemetry)getattrrbstripeenable_telemetrypayloadr\jsondumps)rcrr 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/rrbr)rcre request_startrrnrp request_idrequest_duration_mss r._record_request_metricsz"HTTPClient._record_request_metrics"sX!1h 8 #(?(?!,/J"))m"; 6D/u7D   3)@ #r-)_usagemethodurl post_datarc 2|j||||d||SNF is_streamingrhr_request_with_retries_internalrcrrrrrhrs r.request_with_retrieszHTTPClient.request_with_retries+s122     33  r-c 2|j||||d||SNTrrrs r.request_stream_with_retriesz&HTTPClient.request_stream_with_retries?s122     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 %srwzBInitiating retry %i for request %s %s after sleeping %.2f seconds.r) rr/request_streamrequestrrqrlog_info user_messagerr+sleeprrcrrrrrrhrrgrreconnection_errore sleep_times r.rz)HTTPClient._request_with_retries_internalSsH,,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`NotImplementedErrorrcrrrrrs 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`rrcs 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 Kywr5r,rcrrrrrrhrs r.rz/HTTPClient._request_with_retries_internal_asyncs .1c Kywr5r,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_asyncrrqrrrr 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`)r_rrrcrrrrs r.rzHTTPClient.request_async,sR  & & 244BBWi " B  .AAAcK|j&|jj||||d{Std7w)Nz;HTTPClient subclasses must implement `request_stream_async`)r_rrrs r.rzHTTPClient.request_stream_async7sR  & & 244IIWi " I  rcK|j"|jjd{Std7w)Nz2HTTPClient subclasses must implement `close_async`)r_ close_asyncrrs r.rzHTTPClient.close_asyncBs@  & & 244@@BB B! @  Cs *><>secscf|j|jj|Std)Nz,HTTPClient subclasses must implement `sleep`)r_rrrcrs r.rzHTTPClient.sleep_asyncIs5  & & 2..::4@ @! :  r-TNNr5)NN).rLrMrNrrOrPrrQrzryr}rboolrrdrrr)r rrqrtfloatrr{rrr rrrrrrrrbytesrrrrrrrrrr,r-r.r3r3s 3-IMO V "&.28< //c6k*+/ ( 5 /2-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 ddededdedeeee jfdee f fd Z dd ed ed ee eefd e eee eefffdZ dd ed ed ee eefd e eee eefffdZed ed ed ee eefdedd e eee eefff dZed ed ed ee eefdedd e eee eefff dZd ed ed ee eefded e eeefee eefff dZded efdZdZxZS)r8r7TtimeoutsessionRequestsSessionrWrXrYc ttt| |||||_||_t Jt |_yNrWrXrY)superr8rd_session_timeoutr7)rcrrrWrXrYr1 __class__s r.rdzRequestsClient.__init__TsE nd,-"7 -    ###  r-rrrr2c.|j||||dSNFr_request_internalrs r.rzRequestsClient.requesths'%% C)%&  r-c.|j||||dSNTrrrs r.rzRequestsClient.request_streamss'%% C)$&  r-rcyr5r,rcrrrrrs r.rz RequestsClient._request_internal~.1r-Fcyr5r,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: )rVrca_bundle_pathrUrrbrr7rrrrr TypeErrorrawcontentro Exception_handle_request_errorr) rcrrrrrr1resultrrros 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: )rl) r[r7 exceptionsSSLErrortyperLrOrConnectionErrorRequestExceptiontextwrapfillrrcrmsgerrrms 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)rrbrrrs r.rzRequestsClient.closes5 4%%y$ 7 C    & & , , . Dr-)PNTNNr5)rLrMrNrGr)rrrrOr3rQrdr rrrrrrrrrrrr __classcell__rs@r.r8r8Qsh D/3!%9=6: !!+,! ! c:#4#4456 ! ( 3 !2      '#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-r8ceZdZdZ 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)r6r%TrWrXdeadlinerYctt| ||||r td||_||_t Jt |_y)NrzNo proxy support in urlfetch library. Set stripe.default_http_client to either RequestsClient, PycurlClient, or Urllib2Client instance to use a proxy.)rr6rdr]rV _deadliner%)rcrWrXr rYrs r.rdzUrlFetchClient.__init__s` nd,-"7 -  J  "2"###  r-rrrr2c.|j||||dSrrrs r.rzUrlFetchClient.request,'%% C)%&  r-c.|j||||dSrrrs r.rzUrlFetchClient.request_stream3'%% C)$&  r-rcyr5r,rs r.rz UrlFetchClient._request_internal:$'r-Fcyr5r,rs r.rz UrlFetchClient._request_internalD #r-c |jj||||j|j|}|r=t jjtjj}n j}||j|jfS#|jj$r}|j ||Yd}~d}~wwxYw)N)rrrvalidate_certificater r)r%fetchrVrErrorrriorrOencoderror) rcrrrrrrrrs r.rz UrlFetchClient._request_internalNs /]]((&*%;%;!) F hh&&szz&..'ABGnnG**FNN::}}"" /  & &q# . . /s5BC4C  CrcFt||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) r[r%InvalidURLError DownloadErrorResponseTooLargeErrorrrrOr)rcrrrs r.rz$UrlFetchClient._handle_request_errorms a66 7 -02  4==66 7DC 4==>> ?< G  mmC #99CFBSH %1,r-cyr5r,rs r.rzUrlFetchClient.close r-)TN7Nr5)rLrMrNrGrrr3rQr)rdrOr rrrrrrrrrrrrr r s@r.r6r6 s D"&-16: !! ))*! ! ( 3 !>LP  # .5c3h.? sCc** + LP  # .5c3h.? wWS#X.. / '''c" ' dm ' wS !''###c" # en # sC} ##;;;c" ;>-y-s-x-2 r-r6c.eZdZUeeed<eeed<y)rQrJrKNrLrMrNrr'rPr,r-r.rQrQs ;  K  r-rQceZdZUGddedZdZeeed< 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 eefffdZdedefdZdeefdZdZxZS)r:c.eZdZUeeed<eeed<y)PycurlClient._ParsedProxyrJrKNr'r,r-r. _ParsedProxyr*s{## $$r-r+F)totalr9 _parsed_proxyTrWrXrYcFtt| |||tJt|_tj|_i|_|jrK|j}|jD]+\}}ttt||j |<-yyr) rr:rdr9Curl_curlr-rUitemsr&rrO)rcrWrXrYproxy_schemevaluers r.rdzPycurlClient.__init__s lD*-"7 + !!! [[]  ;;[[F!' H .6d36F-G""6* H r-cd|vriS|jddd}tj|}tdt|j DS)Nz rwc3FK|]\}}|j|fywr5lower.0kvs r. z-PycurlClient.parse_headers..sEtq!QWWYNE!)splitemailmessage_from_stringr\r1)rcr raw_headersrs r. parse_headerszPycurlClient.parse_headerssR  Ijj+A. ++K8EtG}/B/B/DEEEr-rr2c.|j||||dSrrrs r.rzPycurlClient.requestrr-c.|j||||dSrrrs r.rzPycurlClient.request_streamrr-rrrcyr5r,rs r.rzPycurlClient._request_internalrr-cyr5r,rs r.rzPycurlClient._request_internalrr-c \ tjj}tjj}|jj |j |}|r|j r:|jj|jj|j |jr:|jj|jj|j|js |jrI|jj|jj|jd|j|dk(r1|jj|jjdn|dk(ra|jj|jj d|jj|jj"|n>|jj|jj$|j'|jj|jj(||jj|jj*|j,|jj|jj.|j,|jj|jj0d|jj|jj2d|jj|jj4d|jj|jj6t9|j;D cgc] \} } | d| c} } |j<r?|jj|jj>t@jBn0|jj|jjDd |jjG|r|jMd |} n|jOjQd } |jjS|jjT} |jW|jOjQd }| | |fScc} } w#|jjH$r} |jK| Yd} ~ d} ~ wwxYw) N:getrwpostr rFrutf-8),rrrr0reset _get_proxyhostnamesetoptr9PROXYport PROXYPORTusernamepassword PROXYUSERPWDHTTPGETPOST POSTFIELDS CUSTOMREQUESTupperURL WRITEFUNCTIONwriteHEADERFUNCTIONNOSIGNALCONNECTTIMEOUTTIMEOUT HTTPHEADERr\r1rVCAINFOrrSSL_VERIFYHOSTperformerrorrseekgetvaluedecodegetinfo RESPONSE_CODErC)rcrrrrrbrprXr;r<rrcontentrcodes r.rzPycurlClient._request_internalsv HH   88##% $ ~~ !!$++"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 ) ) *s+S1 S77T+T&&T+rc|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.TrFrrrwrrl) r0r9E_COULDNT_CONNECTE_COULDNT_RESOLVE_HOSTE_OPERATION_TIMEOUTED E_SSL_CACERTE_SSL_PEER_CERTIFICATErrr)rcrrrms r.rz"PycurlClient._handle_request_error#s 66!9 KK ) ) KK . . KK - -  &  L VVAY KK $ $ KK . .  &  !LG !LmmC #99AFF1IEK <@aGr-c|jrJ|j}|r|jddnd}|r$|j||j|ddSy)NrIr)r-r?rJ)rcrrXr3s r.rOzPycurlClient._get_proxyFsR   &&E*-SYYs^A&4Fyy6!B<)@AAr-cyr5r,rs r.rzPycurlClient.closeNr$r-rr5) rLrMrNrr+rGrrPrr3rQrdrCr rOrr)rrrrrrrrrrrr'rOrr r s@r.r:r:s%%y% DL))"&-16: HH ))*H ( 3 H6FBF $+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+!6 r-r:ceZdZdZ 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)r;zurllib.requestTrWrXrYctt| |||d|_|jrUt j ttttf|j}t j||_yyr) rr;rd_openerrU urllibrequest ProxyHandlerrr rO build_opener)rcrWrXrY proxy_handlerrs r.rdzUrllib2Client.__init__Uss mT+-"7 ,  ;;*66T#s(^T[[1M)55mDDL r-rrrr2c.|j||||dSrrrs r.rzUrllib2Client.requestjrr-c.|j||||dSrrrs r.rzUrllib2Client.request_streamqrr-rFcyr5r,rs r.rzUrllib2Client._request_internalxrr-cyr5r,rs r.rzUrllib2Client._request_internals),r-c 0t|tr|jd}tj||t t ttf|}dvr fd|_ |jr|jj|ntj|}|r|}n|j}|j} t|j}tdt)t|j+D}  | fS#tj $r?} | j} | j}t| j}Yd} ~ d} ~ wtj"t$f$r} |j'| Yd} ~ d} ~ wwxYw)NrM)rJrKc$jSr5)r\)rsr.z1Urllib2Client._request_internal..s V\\^r-c3FK|]\}}|j|fywr5r7r9s r.r=z2Urllib2Client._request_internal..sITQ1779a.Ir>)r[rOrr}Requestrr get_methodr|openurlopenreadcoder\info urlliberror HTTPErrorURLErrorr]riterr1) rcrrrrrreqrerorprlhs ` r.rzUrllib2Client._request_internalsK i %!((1I## DS!97C   (3CN * << !!#&"**3/  ##==?MME8==?+GIT$w-2E2E2G-HI I""$$ %FFEvvxH1668nG$$j1 *  & &q ) ) *s%$A6DF$5EF:FFrcld}tj|dzt|zdz}t||)Nrrr)rrrOr)rcrrs r.rz#Urllib2Client._handle_request_errors> K mmC #99CFBSH %1,r-cyr5r,rs r.rzUrllib2Client.closer$r-rr5)rLrMrNrGrrr3rQrdrOr rr)rrrrrrrrrrrr r s@r.r;r;Rs D"&-16: EE ))*E ( 3 E,LP  # .5c3h.? sCc** + LP  # .5c3h.? |S'#s("33 4 ###c" # en # sC} ##,,,c" , dm , |S#% &,,)#)#)#c" )#V-y-X- r-r;ceZdZUdZeded< 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)rAr@HTTPXClientType_clientr HTTPXTimeoutc tt| di|t t dt t dt|_t |_i}|j r(tjtj|d<nd|d<tjdi||_ d|_ |rtjdi||_ ||_y)NzPUnexpected: tried to initialize HTTPXClient but the httpx module is not present.zPUnexpected: tried to initialize HTTPXClient but the anyio module is not present.cafilerFr,)rrArdr@ ImportErroranyiorVsslcreate_default_contextrr AsyncClient _client_asyncrrr)rcrallow_sync_methodsr1rs r.rdzHTTPXClient.__init__s k4)3F3 =b  =b     ! !"99,, F8  %F8 "..88  <<1&1DL r-c8|jj|Sr5)rrrs r.rzHTTPXClient.sleep_asyncszz%%r-rrrci}|jr|j|d<|jr|j|d<||f||xsid|gS)Nrr)rr)rUr)rcrrrrr1s r._get_request_args_kwargsz$HTTPXClient._get_request_args_kwargssU ;; $ F9  == $ F9  SMb CF C  r-r2c8|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 RuntimeErrorrrrrrror rcrrrrr0r1rerrroresponse_headerss r.rzHTTPXClient.requests << A 44 C) f *+t||++TBBc&K|j||||\}} |jj|i|d{}j } |j } |j} | | | fS7-#t$r}|j |Yd}~Jd}~wwxYwwr5)rrrrrrrorrs r.rzHTTPXClient.request_asyncs44 C) f *7T//77HHHH""** #++ %555I *  & &q ) ) *=BA*A(A*)B(A** B3B B BBrcd}dt|jd}d}tj|d|dz}t |||NrrrTrrrlrrLrrrrs r.rz!HTTPXClient._handle_request_error*K 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_bytesror rcrrrrr0r1rerrros r.rzHTTPXClient.request_stream5s << 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_bytesrorrs r.rz HTTPXClient.request_stream_asyncMs44 C) f *!//448**88$I&I5H &&(** "" W,, *  & &q ) ) *s@B0:B BB -B0B B-B(#B0(B--B0cR|j|jjyyr5)rrrs r.rzHTTPXClient.close`s! << # LL    $r-cTK|jjd{y7wr5)raclosers r.rzHTTPXClient.close_asyncds  ''))) (&()r Fr5)rLrMrNrGrrPrrrdrrOr rrrr)rrrrrr rrrrrr r s@r.rArAs D ' ((;= ! %~ 567! F&    #  .5c3h.?  ( 666c" 6 uc738,, - 6< 666c" 6 uc738,, - 6( Hy HX HLP-- #-.5c3h.?- xWS#X%66 7-2LP-- #-.5c3h.?- }U#S'#s(*;; <-&!*r-rAcNeZdZdZ 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)rCrBrAIOHTTPTimeoutc jtt| di|t t d||_d|_y)NzTUnexpected: tried to initialize AIOHTTPClient but the aiohttp module is not present.r,)rrCrdrBrr_cached_session)rcrr1rs r.rdzAIOHTTPClient.__init__ks= mT+5f5 ?f   #r-c@tJ|ji}|jr>tjt j }tj||d<ntjd|d<tjdi||_|jS)Nr)r connectorF) verify_sslr,) rBrrVrrrr TCPConnector ClientSession)rcr1 ssl_contexts r.rzAIOHTTPClient._sessionxs"""    'F%%!88!00 '.&:&:{&K{#&-&:&:e&L{##*#8#8#B6#BD ###r-c,tj|Sr5)asynciorrs r.rzAIOHTTPClient.sleep_asyncs}}T""r-r2ctdNz4AIOHTTPClient 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)NrJrKzDAIOHTTPClient does not support different proxies for HTTP and HTTPS.rXrrr)rUr]r)rcrrrrr0r1s 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)rcrrrrrrors 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}~wwxYwwr5)rrrrrrstatusrrs r.rz"AIOHTTPClient.request_stream_asyncs44 C) f *2T]]22DCFCCH""oo #++ %555D *  & &q ) ) *rcyr5r,rs r.rzAIOHTTPClient.closer$r-cTK|jjd{y7wr5)rrrs r.rzAIOHTTPClient.close_asyncsmm!!###r)r r5)rLrMrNrGrrrrdpropertyrrrrr)r rOrrrrrrr rrrrr r s@r.rCrChso DCE $e-=&= >? $$$"# uc738+<<=  #.5c3h.?. EEEc" E uc738,, - E" Hy HX H huosGCHrEobjectr3r8r6rQr:r;rArCrD)is0r.rsl    $2, *& -/ 7;3 &&   /6}}S/AB!s1vBue 5% 9 , JJ  6=? H- /* !3 !# !, !!#!!!~ ~ Bw/Zw/t| Z| ~!Y! @ :@ Fn Jn bb**b*Jq$Jq$h/z/S-   F E EG C    H<Hs5 F5GGG- G=83G2+G-:G2,H 5F>=F>G  G  GGG*)G*-G22G:9G:=HH HH