o @BiY@sddlmZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl mZddlmZmZdd l mZdd lmZmZmZmZdd lmZd ZGd ddeZeGdddeZeGdddeZGdddeZeGdddeZeGdddeZ dS))absolute_importN)Factory)Int32StringReceiver)ConnectionDone)CancelledError)public)peer2strtransport_channel_id)_LazyHexFormatter) ProtocolErrorSerializationError TransportLostInvalidUriError)PayloadExceededError)WampRawSocketServerProtocolWampRawSocketClientProtocolWampRawSocketServerFactoryWampRawSocketClientFactoryc@sheZdZdZeZddZddZddZ dd Z d d Z d d Z ddZ ddZddZddZdS)WampRawSocketProtocolzE Base class for Twisted-based WAMP-over-RawSocket protocols. cC d|_dSN_max_message_sizeselfrZ/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/twisted/rawsocket.py__init__:s zWampRawSocketProtocol.__init__cCsd||j}t|)NzqRawSocket connection: length of received message exceeded (message was {} bytes, but current maximum is {} bytes))format MAX_LENGTHr)rlengthemsgrrrlengthLimitExceeded>sz)WampRawSocketProtocol.lengthLimitExceededcCsr|jjd|jjdz|j}Wn tyd|_Ynwt||_t |_ d|_ d|_ d|_d|_d|_dS)Nz{klass}.connectionMade())klass?F)logdebug __class____name__ transportgetPeerAttributeErrorpeerrtxaio create_future is_closed_session _serializer_handshake_complete_handshake_bytes _max_len_send)rr.rrrconnectionMadeDs     z$WampRawSocketProtocol.connectionMadec Csrz|j|_|j|Wn"ty0}z|jjd|jj|d| WYd}~dSd}~ww|j ddS)NzX{klass}._on_handshake_complete(): ApplicationSession constructor / onOpen raised ({err})r$errzApplicationSession started.) factory_factoryr2onOpen Exceptionr'warnr)r*abortr()rerrr_on_handshake_completejs 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}")r$reasonzC{klass}.connectionLost(): ApplicationSession.onClose raised "{err}"r8)r'r(r)r*r/resolver1 isinstancevaluerr2onCloser=r>)rrBwasCleanr@rrrconnectionLostvs   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|jj d |jj|d| WYd}~dSd}~ww) Nz,{klass}.stringReceived(): RX {octets} octetsr$octetsz.{klass}.stringReceived: RX WAMP message: {msg})r$msgzM{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'tracer)r*r r3 unserializer2 onMessagerr(rr>r?r rr r=)rpayloadrKr@rrrstringReceivedsh 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}")r$rK serializerzIWampRawSocketProtocol: unable to serialize WAMP application payload ({0})NrzQtried to send RawSocket message with size {} exceeding payload limit of {} octetsz"{klass}.send(): TX {octets} octetsrI)isOpenr'rLr)r*r3 serializer rlenr6r>r sendStringr r )rrKrO_r@ payload_lenr"rrrsends,     zWampRawSocketProtocol.sendcCs |jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r2rrrrrRs zWampRawSocketProtocol.isOpencCs|r |jdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rRr+loseConnectionr rrrrcloseszWampRawSocketProtocol.closecCs6|rt|jdr|jdS|jdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` abortConnectionN)rRhasattrr+r[rYr rrrrr?s  zWampRawSocketProtocol.abortN)r* __module__ __qualname____doc__r/ make_loggerr'rr#r7rArHrPrXrRrZr?rrrrr4s&  , rc@s"eZdZdZddZdddZdS) 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|jdddkrK|jj dt|jdd| 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)NzBWampRawSocketServerProtocol: opening handshake received - {octets})rJrzpWampRawSocketServerProtocol: invalid magic byte (octet 1) in opening handshake: was 0x{magic}, but expected 0x7fmagic z^WampRawSocketServerProtocol: client requests us to send out most {max_bytes} bytes per message) max_byteszJWampRawSocketServerProtocol: client wants to use serializer '{serializer}'rQzWampRawSocketServerProtocol: opening handshake - no suitable serializer found (client requested {serializer}, and we have {serializers}rQ serializersTzFWampRawSocketServerProtocol: opening handshake completed: {serializer})r4r dataReceivedrTr5r'r(r ordr>r?r6r: _serializerscopyr3keysintmathceilrr bytes bytearrayRAWSOCKET_SERIALIZER_IDr+writerA)rdata remainingser_idreply_max_len_exp reply_octet2rrrrosf         z(WampRawSocketServerProtocol.dataReceived tls-uniquecCt|jd|dS)W Implements :func:`autobahn.wamp.interfaces.ITransport.get_channel_id` T is_serverchannel_id_typer r+rrrrrget_channel_id?z*WampRawSocketServerProtocol.get_channel_idNr)r*r]r^r_rorrrrrrsOrc@s*eZdZdZddZddZd ddZd S) 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)Nrfrgrarmrn)rr7rrr:r3rtrurvr'rr rwrxryr+rz)rrequest_max_len_exprequest_octet2rrrr7Ps    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)NrazEWampRawSocketClientProtocol: opening handshake received - {handshake}) handshakerrbrczpWampRawSocketClientProtocol: invalid magic byte (octet 1) in opening handshake: was 0x{magic}, but expected 0x7frdrfrgzXWampRawSocketClientProtocol: server requests us to send out most {max} bytes per message)maxrizWampRawSocketClientProtocol: opening handshake - no suitable serializer found (server replied {serializer}, and we requested {serializers})rkTzXWampRawSocketClientProtocol: opening handshake completed (using serializer {serializer})rj)r4rrorTr5r'r(r rpr?r6r3ryerrorrA)rr{r|r}rrrrocsL    z(WampRawSocketClientProtocol.dataReceivedrcCr)rFrrrrrrrrz*WampRawSocketClientProtocol.get_channel_idNr)r*r]r^r_r7rorrrrrrFs 8rc@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:rrrrs zWampRawSocketFactory.__init__cCrrrrrrrresetProtocolOptionss z)WampRawSocketFactory.resetProtocolOptionsNcCsb|jjd|jj|d|dust|tkr|dkr|dksJ|dur-||jkr/||_dSdSdS)NzI{klass}.setProtocolOptions(maxMessagePayloadSize={maxMessagePayloadSize}))r$maxMessagePayloadSizeir)r'r(r)r*typertr)rrrrrsetProtocolOptionss( z'WampRawSocketFactory.setProtocolOptionscCsV|jjd|jj|d|}||_|j|_|j|_|jjd|jj||j|jd|S)Nz"{klass}.buildProtocol(addr={addr}))r$addrzf{klass}.buildProtocol() -> proto={proto}, max_message_size={max_message_size}, MAX_LENGTH={MAX_LENGTH})r$protomax_message_sizer )r'r(r)r*protocolr:rr )rrprrr buildProtocolsz"WampRawSocketFactory.buildProtocolr) r*r]r^r_r/r`r'rrrrrrrrrs  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) rrautobahn.wamp.serializerrappend ImportErrorrrrr=rqry)rr:rlrrrrserrrrrsJ         z#WampRawSocketServerFactory.__init__r)r*r]r^r_rrrrrrrrrc@r)rzD Twisted-based WAMP-over-RawSocket client protocol factory. NcCst|||durz ddlm}|}Wn tyYnw|dur8z ddlm}|}Wn ty7Ynw|durQz ddlm}|}Wn tyPYnw|durjz ddlm}|}Wn tyiYnw|durrtd||_ 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` Nrrrrrz$could not import any WAMP serializer) rrrrrrrrr=r3)rr:rQrrrrrrrrs@              z#WampRawSocketClientFactory.__init__r)r*r]r^r_rrrrrrrr rr)! __future__rrrrur/twisted.internet.protocolrtwisted.protocols.basicrtwisted.internet.errorrtwisted.internet.deferr autobahn.utilrautobahn.twisted.utilrr r autobahn.wamp.exceptionr r r rautobahn.exceptionr__all__rrrrrrrrrrs2        3_[*@