#tj=pUddlmZdZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZmZmZd d lmZmZmZmZmZd d lmZmZd d lmZmZmZm Z m!Z!m"Z"ej#d kr ddlm$Z$m%Z%nddl&m$Z$m%Z%ej#dkrddlm'Z'nddl&m'Z'edZ(e$dZ)e*e*e+e+fdfZ,de-d<e*e,dfZ.de-d<GddeZ/e dGddeZ0e dGdde!e0Z1Gdd e Z2dS)!) 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@eZdZUdZeZded<eZded<eZded<eZ ded <eZ d ed <eZ d ed <eZ ded<eZ ded<eZd ed<eZded<dS)rz5Contains 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____doc__rr*__annotations__r,r-r.r/r1r2r4r5r7O/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/anyio/streams/tls.pyrr5s!??!0 1 1M1111(7(9(99999#2?#4#4F4444FU_EVEVVVVV,;O,=,====='))K))))9H8I8INIIII / 1 1J1111!0 1 11111&((K((((((r>rF)eqceZdZUdZded<ded<ded<ded <ded <ed d d d d d*dZd+dZd,dZd-dZ d.d/d$Z d0d&Z d-d'Z e d1d)Zd S)2ra 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_streamr0r5r3 _ssl_objectz ssl.MemoryBIO _read_bio _write_bioNT)r1hostname ssl_contextr5r1 bool | NonerFr)rGssl.SSLContext | NonereturncrK|| }|sh|rtjjntjj}tj|}t tdr|xjtjzc_tj}tj}|ddl m } | |} nd} t|tj ur| |||| } n$tj|j |||| dd{V} |||| ||} | | jd{V| S)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_EOFr)idna2008_resolve)r1server_hostname)rBr5rCrDrE)sslPurpose CLIENT_AUTH SERVER_AUTHcreate_default_contexthasattroptionsrL MemoryBIO_core._socketsrMtyper wrap_biorrun_sync_call_sslobject_method do_handshake) clsrBr1rFrGr5purposebio_inbio_outrMrNr4wrappers r?wrapzTLSStream.wrapcs:  &,K E+6S ''CKfunc&Callable[[Unpack[PosArgsT]], T_Retval]argsUnpack[PosArgsT]r$cK ||}|jjr7|j|jd{V|S#t j$r |jjr7|j|jd{V|jd{V}|j |np#t$r|j YnKt$r?}|j |j t|d}~wwxYwYnt j$r:|j|jd{VYnt j$r?}|j |j t|d}~wt j$ry}|j |j t#|t js|jr d|jvr|jrt|tdd}~wwxYwj)NTUNEXPECTED_EOF_WHILE_READING)rEpendingrBsendreadrOSSLWantReadErrorreceiverDwriter write_eofOSErrorrSSLWantWriteErrorSSLSyscallErrorSSLError isinstance SSLEOFErrorstrerrorr5)selfrcreresultdataexcs r?r[z TLSStream._call_sslobject_methods) ( tH?*M/44T_5I5I5K5KLLLLLLLLL M' / / / /.Q"3889M9M9O9OPPPPPPPPP!%!6!>!>!@!@@@@@@@DN((....#///N,,.....777N,,...O--///-367 ( I I I+001E1E1G1GHHHHHHHHHHH& 3 3 3((***))+++)s2<   ((***))+++c3?334L4%Cs|%S%S/41s:)t3 1) sbAI)A"CI)#E ?I) E  :EE  I)AI)I)$:GI)0A4I$$I)tuple[AnyByteStream, bytes]cK||jjd{V|j|j|j|jfS)z Does the TLS closing handshake. :return: a tuple of (wrapped byte stream, bytes left in the read buffer) N)r[rCunwraprDrorErBrkrws r?r}zTLSStream.unwrapsx))$*:*ABBBBBBBBB   """ !!###$dn&9&9&;&;;;r>NonecK|jrE |d{Vn)#t$rt|jd{VwxYw|jd{VdSN)r5r} BaseExceptionrrBacloser~s r?rzTLSStream.acloses  #  kkmm########    '(=>>>>>>>>> #**,,,,,,,,,,,s &&A  max_bytesintr+cK|dkrtd||jj|d{V}|st|S)Nz$max_bytes must be a positive integer) ValueErrorr[rCrkr)rwrrys r?rmzTLSStream.receives^ q==CDD D001A1F RRRRRRRR   r>itemcVK||jj|d{VdSr)r[rCrn)rwrs r?rjzTLSStream.sends:))$*:*@$GGGGGGGGGGGr>cPK|tj}tjd|}|r`t |dt |dpd}}||fdkrtd|td)NzTLSv(\d+)(?:\.(\d+))?rrr)rrz;send_eof() requires at least TLSv1.3; current session uses z7send_eof() has not yet been implemented for TLS streams)extrarr7rematchrgroupNotImplementedError)rwr7rmajorminors r?send_eofzTLSStream.send_eofsjj!9:: 1;??  u{{1~~..EKKNN4Ga0H0H5Eu~&&)2$/22 " E   r>Mapping[Any, Callable[[], Any]]cijjtjjjtjjjtjjjtj fdtj fdtj fdtj fdtj fdtjfdtjjji S)Nc8jdS)NFrC getpeercertr~sr?z,TLSStream.extra_attributes..s43C3O3OPU3V3Vr>c8jdS)NTrr~sr?rz,TLSStream.extra_attributes.. s$:J:V:V;;r>cjjSr)rCr1r~sr?rz,TLSStream.extra_attributes..#s d.>.Jr>cRjjrjndSr)rCr1r2r~sr?rz,TLSStream.extra_attributes..$s-#/ //111r>cjSrr5r~sr?rz,TLSStream.extra_attributes..) d6Nr>cjSr)rCr~sr?rz,TLSStream.extra_attributes..*s T-=r>)rBextra_attributesrr*rCselected_alpn_protocolr,get_channel_bindingr-r.r/r1r2r5r4r7versionr~s`r?rzTLSStream.extra_attributess #4  &(8(O  3 4  !1!8  )+V+V+V+V  03333  $&J&J&J&J  '****  ,.N.N.N.N  #%=%=%=%=  $d&6&>'   r>) rBrr1rHrFr)rGrIr5r0rJr)rcrdrerfrJr$)rJr{rJr)r)rrrJr+)rr+rJrrJr)r8r9r:r;r< classmethodrbr[r}rrmrjrpropertyrr=r>r?rrQs=$### $(#-1$(PPPPP[Pd,,,,\ < < < <----HHHH        X   r>rceZdZUdZded<ded<dZded<d Zd ed <eddZ dddZ ddZ e d dZ dS)!ra 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.SSLContextrGTr0r5floathandshake_timeoutrzrstreamrrJrc,Kt|d{Vt|ts.tjt d|t|trt|trdS)a 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)rrtrlogging getLoggerr8 exception Exception)rzrs r?handle_handshake_errorz"TLSListener.handle_handshake_errorGs  '''''''''#68899   h ' ' 1 1,s 2    #y)) Z=T=V=V-W-W    r>NhandlerCallable[[TLSStream], Any] task_groupTaskGroup | NonecKtdfd }j||d{VdS)NrrrJrcNKddlm} |j5t|jjd{V}dddn #1swxYwY|d{VdS#t$r'}||d{VYd}~dSd}~wwxYw)Nr) fail_after)rGr5) rrrrbrGr5rr)rrwrapped_streamrzrrws r?handler_wrapperz*TLSListener.serve..handler_wrapperlsP % % % % % % .Z 677+4>>$($4,0,D,:,,&&&&&&Ngn-----------! ? ? ?11#v>>>>>>>>>>>>>>> ?s:A3.A A3AA3AA33 B$=BB$)rrrJr)r rserve)rwrrrs`` r?rzTLSListener.servegso w . . . . . .  .m!!/:>>>>>>>>>>>r>cHK|jd{VdSr)rrr~s r?rzTLSListener.aclose~s2m""$$$$$$$$$$$r>rc&tjfdiS)NcjSrrr~sr?rz.TLSListener.extra_attributes..rr>)rr5r~s`r?rzTLSListener.extra_attributess!  ,.N.N.N.N  r>)rzrrrrJrr)rrrrrJrrr) r8r9r:r;r<r5r staticmethodrrrrrr=r>r?rr/s" $$$$$!!!!!\D(,?????.%%%%   X   r>rc<eZdZdZddddddZeddZdS)ra 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 NTrFrGr5 connectablerrFr)rGrIr5r0rJrc||_|p"tjtjj|_t |jtjs)tdt|jj ||_ ||_ dS)Nz7ssl_context must be an instance of ssl.SSLContext, not ) rrOrSrPrRrGrtr TypeErrorrXr8rFr5)rwrrFrGr5s r?__init__zTLSConnectable.__init__s''2( c6P K #7 7 $*CN;; 5())255 ! #6   r>rcK|jd{V} t||j|j|jd{VS#t$rt|d{VwxYw)Nr) rconnectrrbrFrGr5rr)rwrs r?rzTLSConnectable.connects'//11111111 " ,$($< (     #F++ + + + + + + +  s 2A!A7) rrrFr)rGrIr5r0rJr)rJr)r8r9r:r;rr#rr=r>r?rrsg   $-1$( 777777(   X   r>r)3 __future__r__all__rrrOsyscollections.abcrr dataclassesr functoolsr r typingr rrrrrrrr_core._typedattrrrabcrrrrrr version_infor r!typing_extensionsr#r$r%tupler6r&r<r'rrrrr=r>r?rs6"""""""  --------!!!!!!**********BAAAAAAAw+++++++++66666666w****** 7:   < # #5c?C/00000GSL))))))))))$)))8 eZ Z Z Z Z Z Z Z z eU U U U U (9%U U U p,,,,,*,,,,,r>