[h3SSKJr SSKrSSKrSSKrSSKrSSKJrJr SSK J r SSK J r SSK JrJr SSKJrJrJrJrJr SS KJrJr SS KJrJrJrJr \R<S :a SS K JrJ r OSS K!JrJ r \"S 5r"\"S5r#\$\$\%\%4S4r&\$\&S4r'"SS\5r(\ "SS9"SS\55r)\ "SS9"SS\\)55r*g)) annotationsN)CallableMapping) dataclass)wraps)AnyTypeVar)BrokenResourceError EndOfStreamaclose_forcefullyget_cancelled_exc_class to_thread)TypedAttributeSettyped_attribute) AnyByteStream ByteStreamListener TaskGroup) ) TypeVarTupleUnpackT_RetvalPosArgsT.c \rSrSr%Sr\"5rS\S'\"5rS\S'\"5r S\S'\"5r S \S '\"5r S \S '\"5r S \S'\"5r S\S'\"5rS\S'\"5rS \S'\"5rS\S'Srg) TLSAttribute!z5Contains Transport Layer Security related attributes. str | None alpn_protocolbyteschannel_binding_tls_uniqueztuple[str, str, int]cipherz*None | dict[str, str | _PCTRTTT | _PCTRTT]peer_certificatez bytes | Nonepeer_certificate_binarybool server_sidez!list[tuple[str, str, int]] | Noneshared_ciphers ssl.SSLObject ssl_objectstandard_compatiblestr tls_versionN)__name__ __module__ __qualname____firstlineno____doc__rr __annotations__r"r#r$r%r'r(r*r+r-__static_attributes__r.^/home/gothic/public_html/Fooocus/fooocus_env/lib/python3.13/site-packages/anyio/streams/tls.pyrr!s?!0 1M:1(7(99#2#4F 4FUEVBV,;,=\=')K)9H8IN5I / 1J 1!0 11&(K(r6rF)eqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S '\S S S S S.SSjj5rSSjrSSjr SSjr SSSjjr SSjr SSjr \SSj5rSrg ) TLSStream=a A stream wrapper that encrypts all sent data and decrypts received data. This class has no public initializer; use :meth:`wrap` instead. All extra attributes from :class:`~TLSAttribute` are supported. :var AnyByteStream transport_stream: the wrapped stream rtransport_streamr&r+r) _ssl_objectz ssl.MemoryBIO _read_bio _write_bioNT)r'hostname ssl_contextr+c# UcU(+nU(dU(a[RRO[RRn[R"U5n[ [S5(a$U=R [R)-sl[R"5n[R"5n[U5[RLaURXxX#S9n O-[R"URUUUUS5IShvN n U"UUU UUS9n U RU R5IShvN U $N3N7f)a\ Wrap an existing stream with Transport Layer Security. This performs a TLS handshake with the peer. :param transport_stream: a bytes-transporting stream to wrap :param server_side: ``True`` if this is the server side of the connection, ``False`` if this is the client side (if omitted, will be set to ``False`` if ``hostname`` has been provided, ``False`` otherwise). Used only to create a default context when an explicit context has not been provided. :param hostname: host name of the peer (if host name checking is desired) :param ssl_context: the SSLContext object to use (if not provided, a secure default will be created) :param standard_compatible: if ``False``, skip the closing handshake when closing the connection, and don't raise an exception if the peer does the same :raises ~ssl.SSLError: if the TLS handshake fails NOP_IGNORE_UNEXPECTED_EOF)r'server_hostname)r<r+r=r>r?)sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsrC MemoryBIOtype SSLContextwrap_biorrun_sync_call_sslobject_method do_handshake) clsr<r'r@rAr+purposebio_inbio_outr*wrappers r7wrapTLSStream.wrapOs,:  &,K+6 ''CKKwriter write_eofOSErrorr SSLWantWriteErrorSSLSyscallErrorSSLError isinstance SSLEOFErrorstrerrorr+)selffuncargsresultdataexcs r7rQ TLSStream._call_sslobject_methods( tH??**//44T__5I5I5KLLL MI'' / /.."33889M9M9OPPP!%!6!6!>!>!@@@DNN((.#/NN,,..7NN,,.OO--/-367 (( I++001E1E1GHHH&& 3((*))+)s2<< ((*))+c3??33LL%Cs||%S//1s:)t3 1sKA$AKA"K$K:AD C "D.C1/D4KK$F6K7K: F;E>>FA KGKKK+;H&&K=BKKKc# URURR5IShvN URR 5 UR R 5 UR URR54$N^7f)zl Does the TLS closing handshake. :return: a tuple of (wrapped byte stream, bytes left in the read buffer) N)rQr=unwrapr>rbr?r<r^rjs r7rrTLSStream.unwrapsk))$*:*:*A*ABBB   " !!#$$dnn&9&9&;;; Cs)B B AB c# UR(aUR5IShvN URR 5IShvN gN'![a [UR5IShvN ef=fN47fN)r+rr BaseExceptionr r<acloserss r7rxTLSStream.aclosesl  # # kkm## ##**,,, $  '(=(=>>>  -sCBAAAB A? BA"A<4A75A<<Bc# URURRU5IShvN nU(d[eU$N7frv)rQr=r^r )rj max_bytesrns r7r`TLSStream.receives:001A1A1F1F RR  Ss*AAAcl# URURRU5IShvN gN7frv)rQr=ra)rjitems r7r]TLSStream.sends'))$*:*:*@*@$GGGs *424c<# UR[R5n[R"SU5nU(aQ[ UR S55[ UR S5=(d S5pCX44S:a[SU35e[S5e7f)NzTLSv(\d+)(?:\.(\d+))?r r)rrz;send_eof() requires at least TLSv1.3; current session uses z7send_eof() has not yet been implemented for TLS streams)extrarr-rematchintgroupNotImplementedError)rjr-rmajorminors r7send_eofTLSStream.send_eofsjj!9!9: 1;? u{{1~.EKKN4Ga0H5~&)$$/=2 " E  sBBcH^0TRRE[RTRR [R TRR[RTRR[RU4Sj[RU4Sj[RU4Sj[RU4Sj[RU4Sj[RU4Sj[RTRR 0 E$)Nc:>TRRS5$)NFr= getpeercertrssr7,TLSStream.extra_attributes..s43C3C3O3OPU3Vr6c:>TRRS5$)NTrrssr7rrs$:J:J:V:V;r6c0>TRR$rv)r=r'rssr7rrsd.>.>.J.Jr6cr>TRR(aTRR5$S$rv)r=r'r(rssr7rrs3++261A1A1P1P1R22r6c>TR$rvr+rssr7rr d6N6Nr6c>TR$rv)r=rssr7rrs T-=-=r6)r<extra_attributesrr r=selected_alpn_protocolr"get_channel_bindingr#r$r%r'r(r+r*r-versionrss`r7rTLSStream.extra_attributess ##44  & &(8(8(O(O  3 3  44   !1!1!8!8  ) )+V  0 03  $ $&J  ' '*  , ,.N  # #%=  $ $d&6&6&>&>#  r6r.) r<rr'z bool | Noner@rrAzssl.SSLContext | Noner+r&returnr:)rkz&Callable[[Unpack[PosArgsT]], T_Retval]rlzUnpack[PosArgsT]rr)rztuple[AnyByteStream, bytes]rNone)i)r{rrr!)r~r!rrrzMapping[Any, Callable[[], Any]])r/r0r1r2r3r4 classmethodrXrQrrrxr`r]rpropertyrr5r.r6r7r:r:=s$# $(#-1$(D'D! D  D + D"D DDL,:,CS, ,\ <-H    r6r:c\rSrSr%SrS\S'S\S'SrS\S 'S rS \S '\SS j5r SSSjjr SSjr \ SSj5r Srg) TLSListeneri aj A convenience listener that wraps another listener and auto-negotiates a TLS session on every accepted connection. If the TLS handshake times out or raises an exception, :meth:`handle_handshake_error` is called to do whatever post-mortem processing is deemed necessary. Supports only the :attr:`~TLSAttribute.standard_compatible` extra attribute. :param Listener listener: the listener to wrap :param ssl_context: the SSL context object :param standard_compatible: a flag passed through to :meth:`TLSStream.wrap` :param handshake_timeout: time limit for the TLS handshake (passed to :func:`~anyio.fail_after`) z Listener[Any]listenerzssl.SSLContextrATr&r+floathandshake_timeoutc# [U5IShvN [U[55(d([R"[ 5R SUS9 [U[5(a[U[55(aegNu7f)au Handle an exception raised during the TLS handshake. This method does 3 things: #. Forcefully closes the original stream #. Logs the exception (unless it was a cancellation exception) using the ``anyio.streams.tls`` logger #. Reraises the exception if it was a base exception or a cancellation exception :param exc: the exception :param stream: the original stream NzError during TLS handshake)exc_info)r rgrlogging getLoggerr/ exception Exception)rostreams r7handle_handshake_error"TLSListener.handle_handshake_error"sz  '''#6899   h ' 1 1,s 2  #y))Z=T=V-W-W .X (sB BA6B Nc^^# [T5SUU4Sjj5nTRRX25IShvN gN7f)Nc`># SSKJn U"TR5 [R UTR TR S9IShvN nSSS5 T"W5IShvN gN!,(df  N!=fN![a$nTRX05IShvN SnAgSnAff=f7f)Nr ) fail_after)rAr+) rrr:rXrAr+rwr)rrwrapped_streamrohandlerrjs r7handler_wrapper*TLSListener.serve..handler_wrapperGs % . 6 67+4>>$($4$4,0,D,D,:,&N8n---&87.! ?11#>>> ?suB.A=-A* A( A*A= B."A;#B.(A** A84A=;B.= B+B&BB&!B.&B++B.)rrrr)rrserve)rjr task_grouprs`` r7rTLSListener.serveBs8 w .  .mm!!/>>>s6AAAcT# URR5IShvN gN7frv)rrxrss r7rxTLSListener.acloseYsmm""$$$s (&(c0^[RU4Sj0$)Nc>TR$rvrrssr7r.TLSListener.extra_attributes.._rr6)rr+rss`r7rTLSListener.extra_attributes\s  , ,.N  r6r.)rorwrrrrrv)rzCallable[[TLSStream], Any]rzTaskGroup | Nonerrrr)r/r0r1r2r3r4r+r staticmethodrrrxrrr5r.r6r7rr s}" $$!u!D(,?+?%?  ?.%  r6r)+ __future__rrrrEsyscollections.abcrr dataclassesr functoolsrtypingrr rr r r rr_core._typedattrrrabcrrrr version_inforrtyping_extensionsrrtupler,_PCTRTT_PCTRTTTrr:rr.r6r7rs" -!B@@w++6 :   # c3h$ % # )$)8 eI I I X eU (9%U U r6