o >h^@sddlZddlZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl mZmZddlmZmZdd lmZdd lmZmZmZmZdd lmZd ZGd ddeZeGdddeZeGdddeZGdddeZ eGddde Z!eGddde Z"dS)N)Optional)Factory)Int32StringReceiver)ConnectionDone)CancelledError)public_LazyHexFormatter)create_transport_detailstransport_channel_id)TransportDetails) ProtocolErrorSerializationError TransportLostInvalidUriError)PayloadExceededError)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryc@seZdZUdZeZdZee e d<dZ ee e d<ddZ edeefdd Zd d Zd d ZddZddZddZddZddZddZddZdS)WampRawSocketProtocolzE Base class for Twisted-based WAMP-over-RawSocket protocols. Npeer is_servercCsd|_d|_dSN)_max_message_size_transport_detailsselfrz/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/twisted/rawsocket.py__init__=s zWampRawSocketProtocol.__init__returncCs|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rrrrrtransport_detailsBsz'WampRawSocketProtocol.transport_detailscCsd||j}t|)NzqRawSocket connection: length of received message exceeded (message was {} bytes, but current maximum is {} bytes))format MAX_LENGTHr)rlengthemsgrrrlengthLimitExceededIsz)WampRawSocketProtocol.lengthLimitExceededcCsPt|j|j|_tj|j_|jj|_t |_ d|_ d|_ d|_ d|_d|_dS)NF)r transportrrr CHANNEL_FRAMING_RAWSOCKETchannel_framingrtxaio create_future is_closed_session _serializer_handshake_complete_handshake_bytes _max_len_sendrrrrconnectionMadeOs    z$WampRawSocketProtocol.connectionMadec Csz0|jjrdt|j|jjdi}||j_|j|_|j j d|j|j j |jj d|j |}Wn"tyR}z|j jd|j j |d|WYd}~dSd}~ww|j j d|j j |j|ddS)Nz tls-uniquez2{klass}._on_handshake_complete(): calling {method})sessionklassmethodzX{klass}._on_handshake_complete(): ApplicationSession constructor / onOpen raised ({err})r6errz@{klass}._on_handshake_complete(): {session} started (res={res}).)r6r5res)r is_securer r)r channel_idfactory_factoryr/logdebug __class____name__onOpen Exceptionwarnabort)rr<r:errr_on_handshake_completess(    z,WampRawSocketProtocol._on_handshake_completec Cs|jjd|jj|dt|j|zt|jt }|j r"|j |Wnt y@}z|jj d|jj|dWYd}~nd}~wwd|_ dS)Nz({klass}.connectionLost(reason="{reason}")r6reasonzC{klass}.connectionLost(): ApplicationSession.onClose raised "{err}"r8)r?r@rArBr,resolver. isinstancevaluerr/onCloserDrE)rrIwasCleanrGrrrconnectionLosts   z$WampRawSocketProtocol.connectionLostc Cs|jjd|jjt|dz|j|D]}|jjd|jj|d|j|qWdSt yH}z|jj d|jj|dWYd}~dSd}~wt yi}z|jj d|jj|d| WYd}~dSd}~wty}z|jj d|jj|d| WYd}~dSd}~wty}z|jj d |jj|d| WYd}~dSd}~wty}z|jj d |jj|d| WYd}~dSd}~wty}z|j|jj d |jj|d| WYd}~dSd}~ww) Nz,{klass}.stringReceived(): RX {octets} octetsr6octetsz.{klass}.stringReceived: RX WAMP message: {msg})r6msgzM{klass}.stringReceived: WAMP CancelledError - connection will continue! {err}r8zI{klass}.stringReceived: WAMP InvalidUriError - aborting connection! {err}zG{klass}.stringReceived: WAMP ProtocolError - aborting connection! {err}zN{klass}.stringReceived: WAMP PayloadExceededError - aborting connection! {err}zL{klass}.stringReceived: WAMP SerializationError - aborting connection! {err}zC{klass}.stringReceived: WAMP Exception - aborting connection! {err})r?tracerArBrr0 unserializer/ onMessagerr@rrErFr rr rDfailure)rpayloadrRrGrrrstringReceivedsj  z$WampRawSocketProtocol.stringReceivedc Cs|re|jjd|jj||jdz |j|\}}Wnty.}ztd|d}~wwt |}d|j kr>|krQnnd||j }|j |t || ||jjd|jjt|ddSt) zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` zB{klass}.send() (serializer={serializer}): TX WAMP message: "{msg}")r6rR serializerzIWampRawSocketProtocol: unable to serialize WAMP application payload ({0})NrzQtried to send RawSocket message with size {} exceeding payload limit of {} octetsz"{klass}.send(): TX {octets} octetsrP)isOpenr?rSrArBr0 serializer r#lenr3rEr sendStringrr)rrRrW_rG payload_lenr&rrrsends,     zWampRawSocketProtocol.sendcCs |jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r/rrrrrZs zWampRawSocketProtocol.isOpencCs|r |jdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rZr)loseConnectionrrrrrcloseszWampRawSocketProtocol.closecCs6|rt|jdr|jdS|jdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` abortConnectionN)rZhasattrr)rcrarrrrrrFs  zWampRawSocketProtocol.abort)rB __module__ __qualname____doc__r, make_loggerr?rrstr__annotations__rboolr propertyr r"r'r4rHrOrXr`rZrbrFrrrrr4s" $ - rc@seZdZdZddZdS)rz Twisted-based WAMP-over-RawSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` cCs|jr t||dSdt|j}|j|d|7_t|jdkr|jjdt|jdt|jdd}|dkrI|jj d|d| n|jd d d t|jdd d?|_ |jjd |j d t|jdd d@}||j j vrt|j j ||_|jjd|dn|jj d||j j d| ttt|jd }d ||_tt|d d>|jjBg}|jd|j||jdd|_||jjd|jd||d}|r||dSdS)NzDWampRawSocketServerProtocol: opening handshake received - 0x{octets})rQrzmWampRawSocketServerProtocol: invalid magic byte (octet 1) in opening handshake: was {magic}, but expected 127magicz8WampRawSocketServerProtocol: correct magic byte received z^WampRawSocketServerProtocol: client requests us to send out most {max_bytes} bytes per message) max_byteszJWampRawSocketServerProtocol: client wants to use serializer '{serializer}'rYzWampRawSocketServerProtocol: opening handshake - no suitable serializer found (client requested {serializer}, and we have {serializers}rY serializersTzFWampRawSocketServerProtocol: opening handshake completed: {serializer})r1r dataReceivedr\r2r?r@rordrErFr3r= _serializerscopyr0keysintmathceilrr$bytes bytearrayRAWSOCKET_SERIALIZER_IDr)writerH)rdata remaining_magicser_idreply_max_len_exp reply_octet2rrrr{sj          z(WampRawSocketServerProtocol.dataReceivedN)rBrerfrgr{rrrrrs rc@s eZdZdZddZddZdS)rz Twisted-based WAMP-over-RawSocket client protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` cCst|t|jj|_ttt|j d}d||_ t t |dd>|jj Bg}|jd|j||jddS)Nrrrsrmryrz)rr4r~r=r0rrrr?rr$rrrr)r)rrequest_max_len_exprequest_octet2rrrr4fs    z*WampRawSocketClientProtocol.connectionMadecCsJ|jr t||dSdt|j}|j|d|7_t|jdkr|jjdt|jdt|jdddkrK|jjdt|jdd| d d t|jdd d?|_ |jjd |j d t|jdd d @}||j j kr|jj d||j j d| d|_||jjd|j d||d}|r||dSdS)NrmzEWampRawSocketClientProtocol: opening handshake received - {handshake}) handshakerrnrozpWampRawSocketClientProtocol: invalid magic byte (octet 1) in opening handshake: was 0x{magic}, but expected 0x7frprrrszXWampRawSocketClientProtocol: server requests us to send out most {max} bytes per message)maxruzWampRawSocketClientProtocol: opening handshake - no suitable serializer found (server replied {serializer}, and we requested {serializers})rwTzXWampRawSocketClientProtocol: opening handshake completed (using serializer {serializer})rv)r1rr{r\r2r?r@rr|rFr3r0rerrorrH)rrrrrrrr{ysL    z(WampRawSocketClientProtocol.dataReceivedN)rBrerfrgr4r{rrrrr\s rc@s:eZdZdZeZddZddZd ddZ d d Z dS) WampRawSocketFactoryzE Base class for Twisted-based WAMP-over-RawSocket factories. cs(tr|_nfdd|_d|_dS)z :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable csSNrrr=rrsz/WampRawSocketFactory.__init__..rN)callabler>r)rr=rrrr s zWampRawSocketFactory.__init__cCs d|_dSr)rrrrrresetProtocolOptionss z)WampRawSocketFactory.resetProtocolOptionsNcCsb|jjd|jj|d|dust|tkr|dkr|dksJ|dur-||jkr/||_dSdSdS)NzI{klass}.setProtocolOptions(maxMessagePayloadSize={maxMessagePayloadSize}))r6maxMessagePayloadSizeir)r?r@rArBtyperr)rrrrrsetProtocolOptionss( z'WampRawSocketFactory.setProtocolOptionscCsV|jjd|jj|d|}||_|j|_|j|_|jjd|jj||j|jd|S)Nz"{klass}.buildProtocol(addr={addr}))r6addrzf{klass}.buildProtocol() -> proto={proto}, max_message_size={max_message_size}, MAX_LENGTH={MAX_LENGTH})r6protomax_message_sizer$)r?r@rArBprotocolr=rr$)rrprrr buildProtocolsz"WampRawSocketFactory.buildProtocolr) rBrerfrgr,rhr?r rrrrrrrrs  rc@eZdZdZeZdddZdS)rzD Twisted-based WAMP-over-RawSocket server protocol factory. NcCsDt|||durg}zddlm}||dd||Wn ty+Ynwzddlm}||dd||Wn tyKYnwzddlm}||dd||Wn tykYnwzddlm}||dd||Wn tyYnw|st d i|_ |D]}||j |j <qdS) a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializers: A list of WAMP serializers to use (or ``None`` for all available serializers). :type serializers: list of objects implementing :class:`autobahn.wamp.interfaces.ISerializer` NrCBORSerializerT)batchedMsgPackSerializerUBJSONSerializerJsonSerializerz%could not import any WAMP serializers) rr autobahn.wamp.serializerrappend ImportErrorrrrrDr}r)rr=rxrrrrserrrrr sJ         z#WampRawSocketServerFactory.__init__r)rBrerfrgrrr rrrrrrc@r)rzD Twisted-based WAMP-over-RawSocket client protocol factory. NcCst||d|_|dur"z ddlm}|}Wn ty!Ynw|dur;z ddlm}|}Wn ty:Ynw|durTz ddlm}|}Wn tySYnw|durmz ddlm}|}Wn tylYnw|durut d||_ dS) a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializer: The WAMP serializer to use (or ``None`` for "best" serializer, chosen as the first serializer available from this list: CBOR, MessagePack, UBJSON, JSON). :type serializer: object implementing :class:`autobahn.wamp.interfaces.ISerializer` FNrrrrrz$could not import any WAMP serializer) rr noisyrrrrrrrDr0)rr=rYrrrrrrrr %sB              z#WampRawSocketClientFactory.__init__r)rBrerfrgrrr rrrrrrr)#r~rtypingrr,twisted.internet.protocolrtwisted.protocols.basicrtwisted.internet.errorrtwisted.internet.deferr autobahn.utilrrautobahn.twisted.utilr r autobahn.wamp.typesr autobahn.wamp.exceptionr r rrautobahn.exceptionr__all__rrrrrrrrrrs2       J^U*@