i;T%SSKJr SSKrSSKrSSKrSSKrSSKJrJr SSK J r SSK J r SSKJ r SSKJrJr SS KJrJrJrJrJr SS KJrJr SS KJrJrJrJrJrJ r \RBS :aSS KJ"r" OSS K#J"r" \RBS:a SSKJ$r$J%r% OSSK#J$r$J%r% \RBS:aSSKJ&r& OSSK#J&r& \"S5r'\$"S5r(\)\)\*\*4S4r+S\,S'\)\+S4r-S\,S'"SS\5r.\ "SS9"SS\55r/\ "SS9"SS\\/55r0"S S!\5r1g)") annotationsN)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) TLSAttribute3z5Contains 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.r0r1r3r4r6__static_attributes__r7Y/var/www/html/qgis-automation/mouza_env/lib/python3.13/site-packages/anyio/streams/tls.pyr&r&3s?!0 1M:1(7(99#2#4F 4FUEVBV,;,=\=')K)9H8IN5I / 1J 1!0 11&(K(r?r&F)eqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S '\S S S S S.SSjj5rSSjrSSjr SSjr SSSjjr SSjr SSjr \SSj5rSrg ) TLSStreamOa 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/r4r2 _ssl_objectz ssl.MemoryBIO _read_bio _write_bioNT)r0hostname ssl_contextr4c# 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)r0server_hostname)rEr4rFrGrH)sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsrL MemoryBIOtyperwrap_biorrun_sync_call_sslobject_method do_handshake) clsrEr0rIrJr4purposebio_inbio_outr3wrappers r@wrapTLSStream.wrapas,:  &,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)rYrFunwraprGrjrHrErfrrs r@rzTLSStream.unwrapsk))$*:*:*A*ABBB   " !!#$$dnn&9&9&;;; Cs)B B AB c# UR(aUR5IShvN URR 5IShvN gN'![a [UR5IShvN ef=fN47fN)r4rz BaseExceptionrrEacloser{s r@rTLSStream.aclosesl  # # kkm## ##**,,, $  '(=(=>>>  -sCBAAAB A? BA"A<4A75A<<Bc# URURRU5IShvN nU(d[eU$N7fr~)rYrFrfr )rr max_bytesrvs r@rhTLSStream.receives:001A1A1F1F RR  Ss*AAAcl# URURRU5IShvN gN7fr~)rYrFri)rritems r@reTLSStream.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)extrar&r6rematchintgroupNotImplementedError)rrr6rmajorminors r@send_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$)NFrF getpeercertr{sr@,TLSStream.extra_attributes..s43C3C3O3OPU3Vr?c:>TRRS5$)NTrr{sr@rrs$:J:J:V:V;r?c0>TRR$r~)rFr0r{sr@rrsd.>.>.J.Jr?cr>TRR(aTRR5$S$r~)rFr0r1r{sr@rrs3++261A1A1P1P1R22r?c>TR$r~r4r{sr@rr d6N6Nr?c>TR$r~)rFr{sr@rrs T-=-=r?)rEextra_attributesr&r)rFselected_alpn_protocolr+get_channel_bindingr,r-r.r0r1r4r3r6versionr{s`r@rTLSStream.extra_attributess ##44  & &(8(8(O(O  3 3  44   !1!1!8!8  ) )+V  0 03  $ $&J  ' '*  , ,.N  # #%=  $ $d&6&6&>&>#  r?r7) rErr0z bool | NonerIr(rJssl.SSLContext | Noner4r/returnrC)rsz&Callable[[Unpack[PosArgsT]], T_Retval]rtzUnpack[PosArgsT]rr!)rztuple[AnyByteStream, bytes]rNone)i)rrrr*)rr*rrrzMapping[Any, Callable[[], Any]])r8r9r:r;r<r= classmethodr`rYrzrrhrerpropertyrr>r7r?r@rCrCOs$# $(#-1$(D'D! D  D + D"D DDL,:,CS, ,\ <-H    r?rCc\rSrSr%SrS\S'S\S'SrS\S 'S rS \S '\SS j5r SSSjjr SSjr \ SSj5r Srg) TLSListeneriaj 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.SSLContextrJTr/r4floathandshake_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)rrorlogging getLoggerr8 exception Exception)rwstreams r@handle_handshake_error"TLSListener.handle_handshake_error4sz  '''#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)rJr4) rrrCr`rJr4rr)rrwrapped_streamrwhandlerrrs r@handler_wrapper*TLSListener.serve..handler_wrapperYs % . 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)rrr task_grouprs`` r@rTLSListener.serveTs8 w .  .mm!!/>>>s6AAAcT# URR5IShvN gN7fr~)rrr{s r@rTLSListener.acloseksmm""$$$s (&(c0^[RU4Sj0$)Nc>TR$r~rr{sr@r.TLSListener.extra_attributes..qrr?)r&r4r{s`r@rTLSListener.extra_attributesns  , ,.N  r?r7)rwrrrrrr~)rzCallable[[TLSStream], Any]rzTaskGroup | Nonerrrr)r8r9r:r;r<r=r4r staticmethodrrrrrr>r7r?r@rrs}" $$!u!D(,?+?%?  ?.%  r?rcT\rSrSrSrSSSS.S Sjjr\S Sj5rSrg) TLSConnectableiua 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 NTrIrJr4cHXlU=(d. [R"[RR5Ul[ UR [R5(d+[S[UR 5R35eX l X@l g)Nz7ssl_context must be an instance of ssl.SSLContext, not ) connectablerNrRrOrQrJror TypeErrorrVr8rIr4)rrrrIrJr4s r@__init__TLSConnectable.__init__s''2( c6P6P KK # #7 $**CNN;;I(()2235 ! #6 r?c# URR5IShvN n[RUURUR UR S9IShvN $NAN![a [U5IShvN ef=f7f)Nr) rconnectrCr`rIrJr4rr)rrrs r@rTLSConnectable.connects''//11 " ,,$($<$< ( 2  #F+ + +  sDB A"B 7A&A$A&!B $A&&B>B?BB )rrIrJr4) rrrIr(rJrr4r/rr)rrC) r8r9r:r;r<rr rr>r7r?r@rrus[  $-1$( 7-7 7 + 7 " 7 7(  r?r)2 __future__rrrrNsyscollections.abcrr dataclassesr functoolsrrtypingr r rr r rrr_core._typedattrrrabcrrrrrr version_infortyping_extensionsrrr r!r"tupler5r#r=r$r&rCrrr7r?r@rs(" -!Bw +w++6w* :   #5c?C/00GSL))))$)8 eI I I X eU (9%U U p,*,r?