1hC/>SSKJr SSKrSSKrSSKrSSKJr SSKJr SSK J r J r J r J r Jr SSKJrJrJrJr SSKJrJr SS KJrJrJrJr \"S 5r\ \ \\4S 4r\ \S 4r"S S \5r \"SS9"SS\55r!\"SS9"SS\\!55r"g)) annotationsN) dataclass)wraps)AnyCallableMappingTupleTypeVar)BrokenResourceError EndOfStreamaclose_forcefullyget_cancelled_exc_class)TypedAttributeSettyped_attribute) AnyByteStream ByteStreamListener TaskGroupT_Retval.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) TLSAttributez5Contains Transport Layer Security related attributes. str | None alpn_protocolbyteschannel_binding_tls_uniqueztuple[str, str, int]cipherz*dict[str, str | _PCTRTTT | _PCTRTT] | Nonepeer_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__rrrr r"r#r%r&r(__static_attributes__r)I/var/www/auris/envauris/lib/python3.13/site-packages/anyio/streams/tls.pyrrs?!0 1M:1(7(99#2#4F 4DSCT@T,;,=\=')K)9H8IN5I / 1J 1!0 11&(K(r1rF)eqc\rSrSr%SrS\S'S\S'S\S'S \S 'S \S '\S S S S S.SSjj5rSSjrSSjr SSjr SSSjjr SSjr SSjr \SSj5rSrg ) TLSStream4a 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"5nURXxX#S9n U"UUU UUS9n U RU R5IShvN U $N7f)aX 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)r7r&r8r9r:) sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsr> MemoryBIOwrap_bio_call_sslobject_method do_handshake) clsr7r"r;r<r&purposebio_inbio_outr%wrappers r2wrapTLSStream.wrapFs8  &,K+6 ''CKKD DD c# U"U6nURR(a;URRURR 55IShvN U$N![ R Ga URR(a<URRURR 55IShvN URR5IShvN nURRU5 GO![a URR5 GO[a@nURR5 URR5 [UeSnAff=f[ Ra? URRURR 55IShvN O[ Ra@nURR5 URR5 [UeSnAf[ R anURR5 URR5 [#U[ R$5(dSUR&;aUR((a[Ue[SeeSnAff=fGM7f)NUNEXPECTED_EOF_WHILE_READING)r:pendingr7sendreadr@SSLWantReadErrorreceiver9writer write_eofOSErrorr SSLWantWriteErrorSSLSyscallErrorSSLError isinstance SSLEOFErrorstrerrorr&)selffuncargsresultdataexcs r2rI TLSStream._call_sslobject_method~s) tJ??**//44T__5I5I5KLLL MK'' / /.."33889M9M9OPPP!%!6!6!>!>!@@@DNN((.#/NN,,..7NN,,.OO--/-367 (( I++001E1E1GHHH&& 3((*))+)s2<< ((*))+sCOO445E//1s:)t3 1sK A$AK A"K $K:AD C "D.C1/D4KK $F6K7K : F;E>>FA KGKK K*;H%%K>>  -sCBAAAB A? BA"A<4A75A<<Bc# URURRU5IShvN nU(d[eU$N7frn)rIr8rVr )rb max_bytesrfs r2rXTLSStream.receives:001A1A1F1F RR  Ss*AAAcl# URURRU5IShvN gN7frn)rIr8rY)rbitems r2rUTLSStream.sends'))$*:*:*@*@$GGGs *424c<# UR[R5n[R"SU5nU(aQ[ UR S55[ UR S5=(d S5pCX44S:a[SU35e[S5e7f)NzTLSv(\d+)(?:\.(\d+))?r r)ryz;send_eof() requires at least TLSv1.3; current session uses z7send_eof() has not yet been implemented for TLS streams)extrarr(rematchintgroupNotImplementedError)rbr(r}majorminors r2send_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$)NFr8 getpeercertrksr2,TLSStream.extra_attributes..s43C3C3O3OPU3Vr1c:>TRRS5$)NTrrksr2rrs$:J:J:V:V;r1c0>TRR$rn)r8r"rksr2rrsd.>.>.J.Jr1cr>TRR(aTRR5$S$rn)r8r"r#rksr2rrs3++261A1A1P1P1R22r1c>TR$rnr&rksr2rr d6N6Nr1c>TR$rn)r8rksr2rrs T-=-=r1)r7extra_attributesrrr8selected_alpn_protocolrget_channel_bindingrrr r"r#r&r%r(versionrks`r2rTLSStream.extra_attributess ##44  & &(8(8(O(O  3 3T5E5E5Y5Y   !1!1!8!8  ) )+V  0 03  $ $&J  ' '*  , ,.N  # #%=  $ $d&6&6&>&>  r1r)) r7rr"z bool | Noner;rr<zssl.SSLContext | Noner&r!returnr5)rczCallable[..., T_Retval]rdobjectrr)rztuple[AnyByteStream, bytes]rNone)i)rsr~rr)rvrrrrzMapping[Any, Callable[[], Any]])r*r+r,r-r.r/ classmethodrPrIrjrprXrUrpropertyrr0r)r1r2r5r54s$# $(#-1$(5'5! 5  5 + 5"5 55n-+-4:- -^ <-H    r1r5c\rSrSr%SrS\S'S\S'SrS\S 'S rS \S '\SS j5r SSSjjr SSjr \ SSj5r Srg) TLSListeneraj 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.SSLContextr<Tr!r&floathandshake_timeoutc# [U5IShvN [U[55(d)[R"[ 5R S5 [U[5(a[U[55(aegNv7f)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)rr_rlogging getLoggerr* exception Exception)rgstreams r2handle_handshake_error"TLSListener.handle_handshake_errorso  '''#6899   h ' 1 12N O#y))Z=T=V-W-W .X (sB BA7B 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)r<r&) rrr5rPr<r&ror)rrwrapped_streamrghandlerrbs r2handler_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)rrserve)rbr task_grouprs`` r2rTLSListener.serve"s8 w .  .mm!!/>>>s6AAAcT# URR5IShvN gN7frn)rrprks r2rpTLSListener.aclose9smm""$$$s (&(c0^[RU4Sj0$)Nc>TR$rnrrksr2r.TLSListener.extra_attributes..?rr1)rr&rks`r2rTLSListener.extra_attributes<s  , ,.N  r1r))rgrorrrrrn)rzCallable[[TLSStream], Any]rzTaskGroup | Nonerrrr)r*r+r,r-r.r/r&r staticmethodrrrprrr0r)r1r2rrs|  $$!u!8(,?+?%?  ?.%  r1r)# __future__rrr|r@ dataclassesr functoolsrtypingrrrr r rr r rr_core._typedattrrrabcrrrrrr'_PCTRTT_PCTRTTTrr5rr)r1r2rs" !99 B@@ :  c3h$ % # )$)8 ey y y x eN (9%N N r1