Ei;"%SSKJr SrSSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK J r SSKJr SSKJrJrJr S S KJrJrJrJrJr S S KJrJr S S KJrJrJrJ r J!r!J"r" \RFS :a SSKJ$r$J%r% OSSK&J$r$J%r% \RFS:aSSKJ'r' OSSK&J'r' \"S5r(\$"S5r)\*\*\+\+4S4r,S\-S'\*\,S4r.S\-S'"SS\5r/\ "SS9"SS\55r0\ "SS9"SS\!\055r1"SS \ 5r2g)!) annotations) TLSAttributeTLSConnectable TLSListener TLSStreamN)CallableMapping) dataclass)wraps) SSLContext)Any TypeAliasTypeVar)BrokenResourceError EndOfStreamaclose_forcefullyget_cancelled_exc_class to_thread)TypedAttributeSettyped_attribute) AnyByteStreamAnyByteStreamConnectable ByteStreamByteStreamConnectableListener TaskGroup) ) TypeVarTupleUnpack)r )overrideT_RetvalPosArgsT.r_PCTRTT_PCTRTTTc \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)r5z5Contains 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/r0r2r3r5r6r8__static_attributes__r9N/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anyio/streams/tls.pyrr5s?!0 1M:1(7(99#2#4F 4FUEVBV,;,=\=')K)9H8IN5I / 1J 1!0 11&(K(rArF)eqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S '\S S S S S.SSjj5rSSjrSSjr SSjr SSSjjr SSjr SSjr \SSj5rSrg ) rQa 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_streamr1r6r4 _ssl_objectz ssl.MemoryBIO _read_bio _write_bioNT)r2hostname ssl_contextr6c# 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)r2server_hostname)rFr6rGrHrI)sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsrM MemoryBIOtyper wrap_biorrun_sync_call_sslobject_method do_handshake) clsrFr2rJrKr6purposebio_inbio_outr5wrappers rBwrapTLSStream.wrapcs,:  &,K+6 ''CKK!>!@@@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)rZrGunwraprHrkrIrFrgrss rBr{TLSStream.unwrapsk))$*:*:*A*ABBB   " !!#$$dnn&9&9&;;; Cs)B B AB c# UR(aUR5IShvN URR 5IShvN gN'![a [UR5IShvN ef=fN47fN)r6r{ BaseExceptionrrFacloser|s rBrTLSStream.aclosesl  # # kkm## ##**,,, $  '(=(=>>>  -sCBAAAB A? BA"A<4A75A<<Bc# URURRU5IShvN nU(d[eU$N7fr)rZrGrgr)rs max_bytesrws rBriTLSStream.receives:001A1A1F1F RR  Ss*AAAcl# URURRU5IShvN gN7fr)rZrGrj)rsitems rBrfTLSStream.sends'))$*:*:*@*@$GGGs *424c<# UR[R5n[R"SU5nU(aQ[ UR S55[ UR S5=(d S5pCX44S:a[SU35e[S5e7f)NzTLSv(\d+)(?:\.(\d+))?rr)rrz;send_eof() requires at least TLSv1.3; current session uses z7send_eof() has not yet been implemented for TLS streams)extrarr8rematchintgroupNotImplementedError)rsr8rmajorminors rBsend_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$)NFrG getpeercertr|srB,TLSStream.extra_attributes..s43C3C3O3OPU3VrAc:>TRRS5$)NTrr|srBrrs$:J:J:V:V;rAc0>TRR$r)rGr2r|srBrrsd.>.>.J.JrAcr>TRR(aTRR5$S$r)rGr2r3r|srBrrs3##//  //1rAc>TR$rr6r|srBrr d6N6NrAc>TR$r)rGr|srBrrs T-=-=rA)rFextra_attributesrr+rGselected_alpn_protocolr-get_channel_bindingr.r/r0r2r3r6r5r8versionr|s`rBrTLSStream.extra_attributess ##44  & &(8(8(O(O  3 3  44   !1!1!8!8  ) )+V  0 03  $ $&J  ' '*  , ,.N  # #%=  $ $d&6&6&>&>'  rAr9) rFrr2z bool | NonerJr*rKssl.SSLContext | Noner6r1returnr)rtz&Callable[[Unpack[PosArgsT]], T_Retval]ruzUnpack[PosArgsT]rr$)rztuple[AnyByteStream, bytes]rNone)i)rrrr,)rr,rrrzMapping[Any, Callable[[], Any]])r:r;r<r=r>r? classmethodrarZr{rrirfrpropertyrr@r9rArBrrQs$# $(#-1$(D'D! D  D + D"D DDL,:,CS, ,\ <-H    rArc\rSrSr%SrS\S'S\S'SrS\S 'S rS \S '\SS j5r SSSjjr SSjr \ SSj5r Srg)ri 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.SSLContextrKTr1r6floathandshake_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)rrprlogging getLoggerr: exception Exception)rxstreams rBhandle_handshake_error"TLSListener.handle_handshake_error8sz  '''#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)rKr6) rrrrarKr6rr)rrwrapped_streamrxhandlerrss rBhandler_wrapper*TLSListener.serve..handler_wrapper]s % . 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)r rserve)rsr task_grouprs`` rBrTLSListener.serveXs8 w .  .mm!!/>>>s6AAAcT# URR5IShvN gN7fr)rrr|s rBrTLSListener.acloseosmm""$$$s (&(c0^[RU4Sj0$)Nc>TR$rrr|srBr.TLSListener.extra_attributes..urrA)rr6r|s`rBrTLSListener.extra_attributesrs  , ,.N  rAr9)rxrrrrrr)rzCallable[[TLSStream], Any]rzTaskGroup | Nonerrrr)r:r;r<r=r>r?r6r staticmethodrrrrrr@r9rArBrr s}" $$!u!D(,?+?%?  ?.%  rArcT\rSrSrSrSSSS.S Sjjr\S Sj5rSrg) riya Wraps another connectable and does TLS negotiation after a successful connection. :param connectable: the connectable to wrap :param hostname: host name of the server (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 server does the same NTrJrKr6cHXlU=(d. [R"[RR5Ul[ UR [R5(d+[S[UR 5R35eX l X@l g)Nz7ssl_context must be an instance of ssl.SSLContext, not ) connectablerOrSrPrRrKrpr TypeErrorrWr:rJr6)rsrrJrKr6s rB__init__TLSConnectable.__init__s''2( c6P6P KK # #7 $**CNN;;I(()2235 ! #6 rAc# URR5IShvN n[RUURUR UR S9IShvN $NAN![a [U5IShvN ef=f7f)Nr) rconnectrrarJrKr6rr)rsrs rBrTLSConnectable.connects''//11 " ,,$($<$< ( 2  #F+ + +  sDB A"B 7A&A$A&!B $A&&B>B?BB )rrJrKr6) rrrJr*rKrr6r1rr)rr) r:r;r<r=r>rr#rr@r9rArBrrys[  $-1$( 7-7 7 + 7 " 7 7(  rAr)3 __future__r__all__rrrOsyscollections.abcrr dataclassesr functoolsr r typingr rrrrrrrr_core._typedattrrrabcrrrrrr version_infor r!typing_extensionsr#r$r%tupler7r&r?r'rrrrr9rArBrs "  -!**Bw++6w* :   #5c?C/00GSL))))$)8 eK K K \ eU (9%U U p,*,rA