pT:i<X%SSKJr SrSSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK J r SSKJr SSKJrJr S S KJrJrJrJrJr S S KJrJr S S KJrJrJrJrJ r J!r! \RDS :aSSKJ#r# OSSK$J#r# \RDS:a SSKJ%r%J&r& OSSK$J%r%J&r& \RDS:aSSKJ'r' OSSK$J'r' \"S5r(\%"S5r)\*\*\+\+4S4r,S\-S'\*\,S4r.S\-S'"SS\5r/\ "SS9"SS\55r0\ "SS9"SS \ \055r1"S!S"\5r2g)#) annotations) TLSAttributeTLSConnectable TLSListener TLSStreamN)CallableMapping) dataclass)wraps) SSLContext)AnyTypeVar)BrokenResourceError EndOfStreamaclose_forcefullyget_cancelled_exc_class to_thread)TypedAttributeSettyped_attribute) AnyByteStreamAnyByteStreamConnectable ByteStreamByteStreamConnectableListener TaskGroup) ) TypeAlias)r ) 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)r: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/r0r1r3r4r6r7r9__static_attributes__r:U/var/www/html/aadhar_voter_ocr/venv/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(rBrF)eqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S '\S S S S S.SSjj5rSSjrSSjr SSjr SSSjjr SSjr SSjr \SSj5rSrg ) rVa 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_streamr2r7r5 _ssl_objectz ssl.MemoryBIO _read_bio _write_bioNT)r3hostname ssl_contextr7c# 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)r3server_hostname)rGr7rHrIrJ)sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsrN MemoryBIOtyper wrap_biorrun_sync_call_sslobject_method do_handshake) clsrGr3rKrLr7purposebio_inbio_outr6wrappers rCwrapTLSStream.wraphs,:  &,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)r[rHunwraprIrlrJrGrhrts rCr|TLSStream.unwrapsk))$*:*:*A*ABBB   " !!#$$dnn&9&9&;;; Cs)B B AB c# UR(aUR5IShvN URR 5IShvN gN'![a [UR5IShvN ef=fN47fN)r7r| BaseExceptionrrGacloser}s rCrTLSStream.aclosesl  # # kkm## ##**,,, $  '(=(=>>>  -sCBAAAB A? BA"A<4A75A<<Bc# URURRU5IShvN nU(d[eU$N7fr)r[rHrhr)rt max_bytesrxs rCrjTLSStream.receives:001A1A1F1F RR  Ss*AAAcl# URURRU5IShvN gN7fr)r[rHrk)rtitems rCrgTLSStream.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)extrarr9rematchintgroupNotImplementedError)rtr9rmajorminors rCsend_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$)NFrH getpeercertr}srC,TLSStream.extra_attributes..s43C3C3O3OPU3VrBc:>TRRS5$)NTrr}srCrrs$:J:J:V:V;rBc0>TRR$r)rHr3r}srCrrsd.>.>.J.JrBcr>TRR(aTRR5$S$r)rHr3r4r}srCrrs3++261A1A1P1P1R22rBc>TR$rr7r}srCrr d6N6NrBc>TR$r)rHr}srCrrs T-=-=rB)rGextra_attributesrr,rHselected_alpn_protocolr.get_channel_bindingr/r0r1r3r4r7r6r9versionr}s`rCrTLSStream.extra_attributes s ##44  & &(8(8(O(O  3 3  44   !1!1!8!8  ) )+V  0 03  $ $&J  ' '*  , ,.N  # #%=  $ $d&6&6&>&>#  rBr:) rGrr3z bool | NonerKr+rLssl.SSLContext | Noner7r2returnr)ruz&Callable[[Unpack[PosArgsT]], T_Retval]rvzUnpack[PosArgsT]rr%)rztuple[AnyByteStream, bytes]rNone)i)rrrr-)rr-rrrzMapping[Any, Callable[[], Any]])r;r<r=r>r?r@ classmethodrbr[r|rrjrgrpropertyrrAr:rBrCrrVs$# $(#-1$(D'D! D  D + D"D DDL,:,CS, ,\ <-H    rBrc\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.SSLContextrLTr2r7floathandshake_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)rrqrlogging getLoggerr; exception Exception)rystreams rChandle_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)rLr7) rrrrbrLr7rr)rrwrapped_streamryhandlerrts rChandler_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)rtr task_grouprs`` rCrTLSListener.serve[s8 w .  .mm!!/>>>s6AAAcT# URR5IShvN gN7fr)rrr}s rCrTLSListener.aclosersmm""$$$s (&(c0^[RU4Sj0$)Nc>TR$rrr}srCr.TLSListener.extra_attributes..xrrB)rr7r}s`rCrTLSListener.extra_attributesus  , ,.N  rBr:)ryrrrrrr)rzCallable[[TLSStream], Any]rzTaskGroup | Nonerrrr)r;r<r=r>r?r@r7r staticmethodrrrrrrAr:rBrCrr#s}" $$!u!D(,?+?%?  ?.%  rBrcT\rSrSrSrSSSS.S Sjjr\S Sj5rSrg) ri|a 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 NTrKrLr7cHXlU=(d. [R"[RR5Ul[ UR [R5(d+[S[UR 5R35eX l X@l g)Nz7ssl_context must be an instance of ssl.SSLContext, not ) connectablerPrTrQrSrLrqr TypeErrorrXr;rKr7)rtrrKrLr7s rC__init__TLSConnectable.__init__s''2( c6P6P KK # #7 $**CNN;;I(()2235 ! #6 rBc# URR5IShvN n[RUURUR UR S9IShvN $NAN![a [U5IShvN ef=f7f)Nr) rconnectrrbrKrLr7rr)rtrs rCrTLSConnectable.connects''//11 " ,,$($<$< ( 2  #F+ + +  sDB A"B 7A&A$A&!B $A&&B>B?BB )rrKrLr7) rrrKr+rLrr7r2rr)rr) r;r<r=r>r?rr$rrAr:rBrCrr|s[  $-1$( 7-7 7 + 7 " 7 7(  rBr)3 __future__r__all__rrrPsyscollections.abcrr dataclassesr functoolsr r typingr rrrrrrr_core._typedattrrrabcrrrrrr version_infortyping_extensionsr!r"r$r%r&tupler8r'r@r(rrrrr:rBrCrs1"  -!Bw +w++6w* :   #5c?C/00GSL))))$)8 eI I I X eU (9%U U p,*,rB