nbi,ddlmZddlZddlZddlZddlZddlZddlZddlmZm Z ddlm Z ej r(ddl mZddlmZdd lmZmZmZmZmZmZdd lmZdd lmZdd lmZmZdd lm Z m!Z!ddl"m#Z# ddl$Z$n#e%e&f$rdZ$YnwxYwddl'm(Z(m)Z)m*Z*ddl+m,Z,ddl-m.Z.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4m5Z5ddl6m7Z7m8Z8ddl9m:Z:m;Z;mddl9m?Z?m@Z@mAZAddlBmCZCmDZDddlEmFZFddlGmHZHddlImJZKddlImLZLmMZMmNZNmOZOmPZPddlQmRZRddlSmTZTeUZUeVZVejWeXZYGdde,ZZGd d!eZZ[Gd"d#ej\Z]d$ddddd%dHdEZ^GdFdGZ_e$se_Z[e[Z`dS)I) annotationsN)datetime timedelta)timeout)LiteralAsyncHTTPResponse) _TYPE_BODY_TYPE_PEER_CERT_RET_DICT_TYPE_SOCKET_OPTIONS_TYPE_TIMEOUT_INTERNAL ProxyConfig_TYPE_ASYNC_BODY)AsyncTrafficPolice)AsyncLowLevelResponse)DEFAULT_BLOCKSIZEDEFAULT_KEEPALIVE_DELAY)_DEFAULT_TIMEOUTTimeout)to_str) HttpVersionQuicPreemptiveCacheTypeResponsePromise)AsyncHfaceBackend)_CONTAINS_CONTROL_CHAR_RE_get_default_user_agent_match_hostname_ResponseOptionsport_by_scheme)AsyncBaseResolverAsyncResolverDescription) AsyncSocketSSLAsyncSocket) BaseSSLErrorConnectTimeoutError EarlyResponse) HTTPError)NameResolutionErrorNewConnectionErrorResponseNotReady) SKIP_HEADERSKIPPABLE_HEADERS)ssl_wrap_socket)body_to_chunks)assert_fingerprint)is_capable_for_quic is_ipaddressresolve_cert_reqsresolve_ssl_versionHAS_NEVER_CHECK_COMMON_NAME)Url)is_establishedc eZdZUdZdZeeZded<ded<ded<d ed <d ed <d ed<ded<ded<ded< dZede e j ddddde j ed d[fd+Zed\d,Zejd]d.Zd^fd0 Z d_d`fd4 Zdad5Zedbd6Zedbd7Zedbd8Zedbd9Zedbd:Zdafd; Z dcddfdA ZdefdD Z dfdrBproxy proxy_config disabled_svnpreemptive_quic_cacheresolver socket_familykeepalive_delayhoststrportrrrK Url | NonerLProxyConfig | NonerMset[HttpVersion] | NonerNQuicPreemptiveCacheType | NonerOAsyncBaseResolver | NonerPsocket.AddressFamilyrQfloat | int | NonereturnNonec t||tj||||| | |  ||_||_d|_| &tjd } | |_ d|_ | tj tjtjfvrt!d| |_dS)N) rRrTrr@r>rBrMrNrQFz system://zqUnsupported socket_family argument value. Supported values are: socket.AF_UNSPEC, socket.AF_INET, socket.AF_INET6)super__init__rresolve_default_timeoutrKrLrDr#from_urlnew _resolver_connect_timingssocket AF_UNSPECAF_INETAF_INET6 ValueError_socket_family)selfrRrTrr@r>rBrKrLrMrNrOrPrQ __class__s p/var/www/html/mdtn/previsions/meteo_cartes/venv/lib/python3.11/site-packages/urllib3_future/_async/connection.pyr`zAsyncHTTPConnection.__init__ts$ 3G<<))%"7+   (',$  /8EEIIKKH,4OS !16>6? S S SD  ,c6|jdS)a Getter method to remove any trailing dots that indicate the hostname is an FQDN. In general, SSL certificates don't include the trailing dot indicating a fully-qualified domain name, and thus, they don't validate properly when checked against a domain name that includes the dot. In addition, some servers may not expect to receive the trailing dot when provided. However, the hostname with trailing dot is critical to DNS resolution; doing a lookup with the trailing dot will properly only resolve the appropriate FQDN, whereas a lookup without a trailing dot will search the system's search domain list. Thus, it's important to keep the original host around for use only in those cases where it's appropriate (i.e., when doing DNS lookup to establish the actual TCP connection across which we're going to send HTTP requests). .) _dns_hostrstriprls rnrRzAsyncHTTPConnection.hosts"~$$S)))rovaluec||_dS)z Setter for the `host` property. We assume that only urllib3 uses the _dns_host attribute; httplib itself only uses `host`, and it seems reasonable that other libraries follow suit. N)rr)rlrus rnrRzAsyncHTTPConnection.hostsror$c |Ktd{Vd}jj}j_ jjjpjfjj j j j dko'tjjvoj t jkfdjd{V}n~#t j$r}t)j||d}~wt,$r'}t/djdjd|d}~wt0$r}t3d ||d}~wwxYw |d kr|_n#|d kr|_wxYw|jt jkr7j t jkr"t j_ tj_|S) zoEstablish a socket connection and set nodelay settings on it. :return: New socket connection. Nghttpsc&td|S)Nre)setattr)_rls rnz/AsyncHTTPConnection._new_conn..sgd4F&J&Jro)r@rB socket_kindquic_upgrade_via_dns_rr timing_hookdefault_socket_familyzConnection to z timed out. (connect timeout=)z&Failed to establish a new connection: )r_ _new_conn _max_tolerable_delay_for_upgraderrdcreate_connectionrrrTr<r@rBr}schemerh3 _disabled_svnrf SOCK_DGRAMrkgaierrorr*rR SocketTimeoutr'OSErrorr+type SOCK_STREAM_svn)rlbackup_timeoutsockerms` rnrzAsyncHTTPConnection._new_conns7 gg!!!!!!!!!'+  0 <!\N@DL .99!?d.?@ #2#2 ,(, w(>):N$*<<):$(99JJJJ&*&9:        DD A A A%diq99q @   %XXXXXX     $BqBB  ) 2##- ##- ---- 9) ) )d.>&BT.T.T%0D #DI sCBCEE  C77 E "D&& E 3EE  EE-headerstyping.Mapping[str, str] | Nonerc|dvrtd|dt|||||_dS)N)r;rxz$Invalid proxy scheme for tunneling: z", must be either 'http' or 'https')rTr)rjr_ set_tunnelrJ)rlrRrTrrrms rnrzAsyncHTTPConnection.set_tunnels` * * *cvccc  4dG<<<$rocRK|d{V|_|jr;|d{Vd|_|d{V|d{Vt |j|_|jr d|_dSdS)NTF) rrrG _post_connrD_tunnelrCrKproxy_is_verifiedrts rnconnectzAsyncHTTPConnection.connects..********   !//## # # # # # # #+/D (,,.. oo(,DJ'7'7$  ' +%*D " " " + +roc|jduSN)rrts rn is_closedzAsyncHTTPConnection.is_closedsyD  rocF|jdS|jdks|jdS|js|jrdS|j-|j&tj|jz |jkrdS|j rdSt|jS)NFrT) rfileno _protocol _promises_pending_responses_keepalive_delay connected_attime monotonic has_expiredr8rts rn is_connectedz AsyncHTTPConnection.is_connecteds 9 5 9     # #t~'=5 > T4 4  ! -!-  4#448MMM5 > % % ' ' 5di(((roc|jSr)rDrts rnhas_connected_to_proxyz*AsyncHTTPConnection.has_connected_to_proxy5s ++roc<t|jo|jduS)zT Return True if a forwarding proxy is configured, else return False N)rCrKrGrts rnproxy_is_forwardingz'AsyncHTTPConnection.proxy_is_forwarding9s! DJ=D$5$==roc|jduS)zS Return True if a tunneling proxy is configured, else return False N)rGrts rnproxy_is_tunnelingz&AsyncHTTPConnection.proxy_is_tunneling@s  ,,rocDK td{Vd|_d|_d|_d|_d|_d|_d|_d|_ dS#d|_d|_d|_d|_d|_d|_d|_d|_ wxYw)NF) r_closer is_verifiedrrDrErGrIrJ)rlrms rnrzAsyncHTTPConnection.closeGs '''--// ! ! ! ! ! ! !DI$D %)D "+0D (%)D " $D  $D "&D   DI$D %)D "+0D (%)D " $D  $D "&D  & & & &s &A%%:BFmethodurl skip_hostskip_accept_encodingctj|}|r(td|d|dt ||||S)z+Method cannot contain non-token characters z (found at least r)rr)rsearchrjgroupr_ putrequest)rlrrrrmatchrms rnrzAsyncHTTPConnection.putrequestVs*088  kfkkY^YdYdYfYfkkk ww!! C9CW"   roheadervaluescJtd|Dstj|g|RdSt|t vrDddtt D}td|ddS)rc3VK|]$}t|to |tkV%dSr) isinstancerSr-).0vs rn z0AsyncHTTPConnection.putheader..ls6KKq:a%%:!{*:KKKKKKroz', 'cBg|]}t|S)rStitle)rrs rn z1AsyncHTTPConnection.putheader..ps$KKKv6""KKKroz(urllib3.util.SKIP_HEADER only supports ''N) anyr_ putheaderrlowerr.joinsortedrj)rlrrskippable_headersrms rnrzAsyncHTTPConnection.putheaderjsKKFKKKKK  EGG f .v . . . . . . FLLNN # #+< < < & KK8I1J1JKKK!! O;LOOO  = |||ddn#|dt|d| vr"|dt%|D]\}}|r'|dkrt|}|r|d kr|}t|t*r(|}|}d|vr,d|vr(d|vr$d|vr t/jd|dt2d||| ||dud{V}n5#t6$r(}|j}|J|d| |d}~wwxYw|r|d| |Sd} |ot=|dr||23d{V}|s t|tr|d}| |d{V|t!|z }| | ||ddd{Vx6nu|D]r}|st|tr|d}| |d{V|t!|z }| | ||ddd{Vs | dd d{V}n9#tB$r,tE dd d{V}YnwxYw| | ||d dd{Vn#tF$r'}|j}| | ||dd d{VYd}~nVd}~wt6$rF}| | ||||k||kd{V|j}|J|d| |d}~wwxYw|J|d| |S)!N)request_method request_urlrrrc3XK|]%}t|V&dSr)rr)rks rnrz.AsyncHTTPConnection.request..s2CCaqwwyy 1 1CCCCCCrozaccept-encodingrR)rr)rr>forceFzcontent-lengthTz content-typez Content-Typeztext/plain; charset=utf-8ztransfer-encodingzTransfer-EncodingrzContent-Lengthz user-agentz User-Agentcharsetzutf-8utf_8utf8zA conflicting charset has been set in Content-Type while sending a 'string' as the body. Beware that urllib3.future always encode a string to unicode. Expected 'charset=utf-8', got: zD Either encode your string to bytes or open your file in bytes mode.r ) stacklevel)expect_body_afterwardresponse_optionsr __aiter__ro)eot)$r settimeoutrr frozensetrr0max_frame_sizerrh11 is_stringchunkscontent_lengthrrSlenrritemsrbytesdecodewarningswarn UserWarning endheadersBrokenPipeErrorpromise set_parameterhasattrencodesend TypeErrorr_r()rlrrrrrrrrrr header_keysrr chunks_and_clis_sending_stringrroverrule_content_lengthenforce_charset_transparencyrru value_lowerrpr total_sentchunkrms rnrequestzAsyncHTTPConnection.requestvsJ$ 9 I  . . .,!+)#9     ?GCC7CCCCC 0K?k)   C.Bi    ' )){.    *3%&5(--2$ tS ! ! + K//D ^++&* #  L,,/3,,~/JKKK  J"+552I>>>! 33'{::!))':IFFFNN#3S5H5HIII { * * NN<)@)B)B C C C$]]__ * *MFE& ,6<<>>=M+M+MN+++  .0P0P#kkmm k511+"-"4"4"6"6K!LLNNE ++{22#;66"+55 b>Cbbb('(  NN65 ) ) ) ) V4=OPPPPPPPPBB   B>>>   /1A B B BG       /1A B B BI 7 !6;//'-       e$%$%eS11:$)LL$9$9E"ii........."c%jj0 )5"0. *NE5##(.v"(   %%$%eS11:$)LL$9$9E"ii........."c%jj0 )5"0. *NE5##;#yy$y77777777BB ;;; %ww||CT|::::::::BBB ;"-(.^T5QQQQQQQQQ N N NB)$nZMMMMMMMMM   )$n".0.0  B>>>   /1A B B BG ~~~ +-=>>> sn J** K4#KK<Q/N C)Q/PQ/3QQ/QQ// S.9R S.(AS))S.)rpolice_officerearly_response_callbackrResponsePromise | Noner.AsyncTrafficPolice[AsyncHTTPConnection] | NonerCtyping.Callable[[AsyncHTTPResponse], typing.Awaitable[None]] | Noner c K|jt|j|jd fd }ddlm t | d{V}|jt d }|j } |||j |j |j|j|j||j|j|j|| }|jr&||j d{V|_|S)a Get the response from the server. If the HTTPConnection is in the correct state, returns an instance of HTTPResponse or of whatever object is returned by the response_class variable. If a request has not been sent or if a previous response has not be handled, ResponseNotReady is raised. If the HTTP response indicates that the connection should be closed, then it will be closed before the response is returned. When the connection is closed, the underlying socket is closed. Nearly_low_responserr\r]c2Kd}|j}n}|t|ddS|d}||j|j|j|jd|j|d|j|j dd }|d{VdS)z9Handle unexpected early response. Notify the upper stack!Non_early_responserF rrstatusversionreasonrroriginal_responserrr connectionr) from_promiser get_parametermsgrrrrrr)r _promiseearly_resp_optionsearly_responser rrs rnearly_response_handlerz?AsyncHTTPConnection.getresponse..early_response_handlerYs H-:" &.*2*@*@AT*U*U'&.3;3I3I"44 /.'*.)0*2)0 %1@"4',1@.:#N *).99 9 9 9 9 9 9 9 9 9rorr )rrrr)r)r rr\r])rr,rrresponser r_ getresponserrrrrrrrrrrrread_body) rlrrrr low_response resp_optionsrrr rms ` ` @rnrzAsyncHTTPConnection.getresponse@s$ 9 "$$ $ T\**** :* :* :* :* :* :* :* :Z 0/////#WW00$:1        ?"/G ?M)0)>)>?Q)R)R "$$& (&(8'6*#/#F'6$0)     ' #+==+:$1$$HNror)rRrSrTrHrrr@r?r>r=rBrArKrUrLrVrMrWrNrXrOrYrPrZrQr[r\r])r\rS)rurSr\r])r\r$)NNr;) rRrSrTrHrrrrSr\r]r\r])r\rC)FF) rrSrrSrrCrrCr\r])rrSrrSr\r])NN)rrSrrSrrrrrrCrrCrrCrrCrrr\r)rrrr rr r\r )!__name__ __module__ __qualname____doc__rr!r<__annotations__rrrdefault_socket_optionsrfrgrr`propertyrRsetterrrrrrrrrrrrrr __classcell__rms@rnr:r:Ns>0F)7)?L????NNN****////!!!!....  0, +;15*"9 +/04@D-1.4.>.E!0,0,0,0,0,0,0,0,d***X*$ [[333333p 37 % % % % % % %++++&!!!X!)))X).,,,X,>>>X> ---X- ' ' ' ' ' '& %*        (       6:37 H $#'+HHHHHHHHZ+/IMllllllllllllror:cfeZdZUdZdZeeZdZded<dZ ded<dZ ded<dZ d ed <dZ ded <dZ d ed <dZd ed<dZded<dZded<dZded<dZded<dZded<dZded<dZded< dAedeejdddejedddddddddddddddddddddBfd8ZdCd9Z dAdDd@ZxZ S)EAsyncHTTPSConnectionz Many of the parameters to this constructor are passed to the underlying SSL socket by means of :py:func:`urllib3.util.ssl_wrap_socket`. rxNint | str | None cert_reqsrFca_certs ca_cert_dirNone | str | bytes ca_cert_data ssl_versionrHssl_minimum_versionssl_maximum_versionr1 cert_filekey_file key_passwordstr | bytes | None cert_datakey_dataciphers)rr@r>rBrMrNrOrPrQrKrLr0assert_hostnamer1server_hostname ssl_contextr1r2r4r6r7r5r8r9r:r<r=r>rRrSrTrrr@r?r>r=rBrArMrWrNrXrOrYrPrZrQr[rKrUrLrVr?None | str | Literal[False]r@rAssl.SSLContext | Noner\r]ct||s/|t}|tjt ||||||| | ||| | |  ||_||_||_ ||_ ||_ ||_ ||_ ||_||_||_||_||_|ot&j||_|ot&j||_||_||_|#|j |j j}nt7d}||_d|_dS)N) rTrr@r>rBrKrLrMrNrOrPrQ)r2setaddrrr_r`r9r8r<r=r:rAr@r?r1r5r6r7ospath expanduserr1r2r4r> verify_moder4r0 _upgrade_ctx) rlrRrTrr@r>rBrMrNrOrPrQrKrLr0r?r1r@rAr1r2r4r6r7r5r8r9r:r<r=r>rms rnr`zAsyncHTTPSConnection.__init__snF#;0CDD -#"uu   [^ , , ,  ))%%"7'+    ! ""  (&.."4&#6 #6  ARW%7%7%A%A &J27+=+=k+J+J(   + ,8 -d33 "48rocK|d{Vx|_}||jp|j|j|j|j|j|j |j p|j |j p|j |j|j|j|j t$urT|j}d}g}t)t*jD]W}||jvr |t0jkr|d2|t0jkr|dX|jr|jdkr-||j|dgd{Vx|_}d}n|jdkrd|_| d{Vd|_!|"d{V|j#}|j$|j$}tKdid|d|jd |j&d |jd |j d |jd |jd|jd|j d|j d|jd|d|jd|d|jd|jd|pdd|j d|j d|j'd{V}tQ|j)dr|j)j*|_|j)|_tW|j,|_!|j-rd|_.n |j.|_.tW|j,|_!|j!r|j |j.|_| d{VdS)NFzhttp/1.1h2rxTr;rr0r5r6r7r1r2r4r8r9r:r@rA tls_in_tlsr?r1alpn_protocolsr<r=r>contextr)/rr _custom_tlsrArKr1r2r4r6r7r8r<r9r=r:r1r?r0NotImplementedrRreversedr. supported_svnrMrrappendrMrrJ_connect_tls_proxyrrrDrrGr@#_ssl_wrap_socket_and_match_hostnamer5r>rrfrPrCrKrr)rlrr@rNrOsvnsock_and_verifieds rnrzAsyncHTTPSConnection.connects4!%!1!11111111 D    5D$5  !((0$. .!'$     $(9OJ(*N 4 BCC 0 0$++++/))"))*5555KN**"))$///& 4&'11-1-D-D 4*..((((((DI"&JJ(F22-2D*oo'''''''''04,llnn$$$$$$$"&"3#/"&"6&I'''T'..'!,,'%)$<$< ' %)$<$< '  '!,,'"..'..''"..'!0'!,,'&:'!% 4 4' $(#:#:!'" .5#'$..%'&''( )'!!!!!! 6(/;; E$5$<$D!)0DI ,0 +;+;D ( ' A#(  #4#@ ,0 +;+;D (+ G0F0N):)F&oorohostnamerr$rOlist[str] | Noner%cRK|jJ|j}|j}t|fid|jd|jd|jd|jd|jd|jd|j d |d |d |j d |j d |j ddddddddd|ddddd{V}|j |_|jS)zY Establish a TLS connection to the proxy using the provided SSL context. Nr0r5r6r7r1r2r4r@rAr?r1r>r8r9r:rNFrOr<r=)rLrArWr0r5r6r7r1r2r4r?r1r>rrrf)rlrZrrOrLrArYs rnrVz'AsyncHTTPSConnection._connect_tls_proxysw ,,,( ". "E # # # nn# ((# !% 8 8 # !% 8 8 # ]] # ((# **# %H# $ # )88#  ,>># LL# d# T!# "## $u%# &*>'# (d)# *T+#       ."3!> ''ror)>rRrSrTrHrrr@r?r>r=rBrArMrWrNrXrOrYrPrZrQr[rKrUrLrVr0r/r?rBr1rFr@rFrArCr1rFr2rFr4r3r6rHr7rHr5r/r8rFr9rFr:rFr<r;r=r;r>rFr\r]r")rZrSrr$rOr[r\r%)!r#r$r%r&rr!r<r0r'r1r2r4r5r6r7r1r8r9r:r<r=r>rrr:r(rfrgrr`rrVr+r,s@rnr.r.s F!&)L"&I&&&&H"K""""'+L++++$(K((((&*****&*****%))))) I    H#L####$(I((((#'H''''G  S8 +;15*$;04@D-1.4.>.E +/&*7;)-&*-1#"&+/*.*.(, $##'(,'+"CS8S8S8S8S8S8S8S8js s s s r,0 %(%(%(%(%(%(%(%(%(ror.c(eZdZUdZded<ded<dS)_WrappedAndVerifiedSocketz[ Wrapped socket and whether the connection is verified after the TLS handshake r%rfrCrN)r#r$r%r&r'rrornr^r^s6 ror^F)rNrOr<r=r>rr$r0None | str | intr5r6rHr7r8rFr9r:r1r2r4r3r?rBr1r@rArCrNrCrOr[r<r;r=r>r\c Kd}|d}d}n|}d}| s | s | dustsd}| G| d}d|vr|d|d}t|r|} t did|d|d|d |d |d | d | d | d|d|d|d|d|d|dt |dt |dd|d|d|d{V}|j} | r%t| d| n_|j tj krJ|j sC| dur?| }|rd}nt|ddpd}t|| p| |t!||j tjkpt%| S#t&$rB| |d{Vn#t,$rYnwxYwwxYw)a2Logic for constructing an SSLContext from all TLS parameters, passing that down into ssl_wrap_socket, and then doing certificate verification either via hostname or fingerprint. This function exists to guarantee that both proxies and targets have the same behavior when connecting via TLS. FNTz[]%rkeyfilecertfiler:r1r2r4r@rArNrOcertdatakeydatar>r0r5)mitigate_tls_versionr6r7check_hostname) binary_formhostname_checks_common_name)rfrr)r6striprfindr3r/r4r5rP_assert_fingerprint getpeercertrJssl CERT_NONErggetattrrr^ CERT_REQUIREDrC BaseExceptionrwait_for_closer)rr0r5r6r7r8r9r:r1r2r4r?r1r@rArNrOr<r=r>default_ssl_contextrPrg normalizedssl_sockcertris rnrWrWse8 ""&N   e # #* $ "$**400 *  #$;j&6&6s&;&;$;rFr\r^)a __future__rloggingrGrfrtypingrrrrr TYPE_CHECKINGtyping_extensionsrrr _typingr r rrrrutil._async.traffic_policerbackend._async._baser _constantrr util.timeoutrr util.utilrrn ImportErrorAttributeErrorbackendrrrbackend._asyncrrrrrr r!contrib.resolver._asyncr"r# contrib.ssar$r% exceptionsr&r'r(r) HTTPExceptionr*r+r,utilr-r.util._async.ssl_r/ util.requestr0 util.ssl_r1rlr2r3r4r5r6util.urlr7util.socket_stater8ConnectionErrorr getLoggerr#logr:r. NamedTupler^rWryVerifiedAsyncHTTPSConnectionrrornrs"""""" ((((((((++++++  =))))))++++++@?????<<<<<<BBBBBBBB44444444JJJJ^$ CCCLKKKKKKKKK......RQQQQQQQ55555555IIIIIIIIII333333 21111111......))))))AAAAAA......"!g!!^ ^ ^ ^ ^ +^ ^ ^ BG(G(G(G(G(.G(G(G(T 16'+$(#'+zzzzzzz88888888 +* 4s3A88 BB