o @Biz,@sddlmZddlZddlZddlmZddlmZddlm Z ddl m Z m Z m Z dZGdd d eZe ed d ZGd d d eZGdddeZGdddeZGdddeZGdddeZdS))absolute_importN)protocol)ConnectionDeny) ITransport) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryc@sVeZdZdZdZdddZddZddZd d Zd d Z d dZ ddZ ddZ dS)WampWebSocketProtocolz> Base class for WAMP-over-WebSocket transport mixins. NcCs"|jjd||d|||dS)NzEFailing WAMP-over-WebSocket transport: code={code}, reason="{reason}")codereason)logdebug_fail_connection)selfrrrW/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/wamp/websocket.py_bailout2szWampWebSocketProtocol._bailoutc Csvz|j|_|j|WdSty:}z|jjdtdd |}|j t j j |dWYd}~dSd}~ww)z^ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onOpen` {tb}tbWAMP Internal Error ({0})rN)factory_factory_sessiononOpen Exceptionrcritical traceback format_excformatrrWebSocketProtocol CLOSE_STATUS_CODE_INTERNAL_ERROR)rerrrrr6s   zWampWebSocketProtocol.onOpencCsj||_|jdur3z|jjd|||d|j|Wnty-|jjdtdYnwd|_dSdS)z_ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onClose` NzWWAMP-over-WebSocket transport lost: wasClean={wasClean}, code={code}, reason="{reason}")wasCleanrrrr) _onclose_reasonrrronCloser r!r"r#)rr(rrrrrr*Ds   zWampWebSocketProtocol.onClosec Csz!|j||D]}|jjd|jj|jj|d|j|qWdStyL}z|jj dt dd |}|j tjj|dWYd}~dSd}~wtyv}z|jj dt dd |}|j tjj|dWYd}~dSd}~ww) za Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onMessage` z@WAMP RECV: message={message}, session={session}, authid={authid}authidsessionmessagerrzWAMP Protocol Error ({0})rNr) _serializer unserializertracer_authid _session_id onMessagerr!r"r#r$rrr% CLOSE_STATUS_CODE_PROTOCOL_ERRORr r&)rpayloadisBinarymsgr'rrrrr4Us*     zWampWebSocketProtocol.onMessagec Cs|rAz|jjd|jj|jj|d|j|\}}Wnty8}z|j d |t d |d}~ww| ||dSt )zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` z@WAMP SEND: message={message}, session={session}, authid={authid}r+z$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrr1rr2r3r/ serializer errorr$r sendMessager)rr8r6r7r'rrrsendms zWampWebSocketProtocol.sendcCs |jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)rrrrrr9s zWampWebSocketProtocol.isOpencC |r |tjjdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)r9 sendCloserr%CLOSE_STATUS_CODE_NORMALrr>rrrclosezWampWebSocketProtocol.closecCr?)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)r9rrr%CLOSE_STATUS_CODE_GOING_AWAYrr>rrrabortrCzWampWebSocketProtocol.abortN) __name__ __module__ __qualname____doc__rrrr*r4r=r9rBrErrrrr +s  r cCs^z(|d}|ddkrtd|dt|d}d|dd}||fWSYdS)N.rwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr r$intjoin) subprotocolsversion serializerIdrrrparseSubprotocolIdentifiers    rVc@eZdZdZdZddZdS)r z: Mixin for WAMP-over-WebSocket server transports. TcCsi}|jD]$}t|\}}|dkr)||jjvr)t|jj||_||fSq|jr;ttj d d |jjt|jjd|_d|fS)a Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onConnect` rNz1This server only speaks WebSocket subprotocols {}, jsonN) protocolsrVr _serializerskeyscopyr/STRICT_PROTOCOL_NEGOTIATIONr BAD_REQUESTr$rQ)rrequestheadersrRrTrUrrr onConnects   z%WampWebSocketServerProtocol.onConnectNrGrHrIrJr_rcrrrrr  r c@rW)r z: Mixin for WAMP-over-WebSocket client transports. TcCsX|j|jjvr|jrtdd|jjd}nt|j\}}t|jj ||_ dS)rXzLThe server does not speak any of the WebSocket subprotocols {} we requested.rYrZN) rrr[r_r r$rQrVr^r\r/)rresponserUrTrrrrcs z%WampWebSocketClientProtocol.onConnectNrdrrrrr rer c@seZdZdZdddZdS)WampWebSocketFactoryzF Base class for WAMP-over-WebSocket transport factory mixins. Ncsftr|_nfdd|_|durg}zddlm}||dd||Wn ty4Ynwzddlm}||dd||Wn tyTYnwzdd lm}||dd||Wn tytYnwzdd lm}||dd||Wn tyYnw|st d i|_ |D]}||j |j <qd d |D|_ dS)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 default serializers). Serializers must implement :class:`autobahn.wamp.interfaces.ISerializer`. :type serializers: list csSrFrrrrrsz/WampWebSocketFactory.__init__..Nr)CBORSerializerT)batched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializercSsg|]}d|jqS)z wamp.2.{})r$ SERIALIZER_ID).0serrrr sz1WampWebSocketFactory.__init__..) callablerautobahn.wamp.serializerrjappend ImportErrorrlrmrnr r\ro _protocols)rr serializersrjrlrmrnrqrrhr__init__sN         zWampWebSocketFactory.__init__rF)rGrHrIrJryrrrrrgsrgc@eZdZdZdS)r zC Mixin for WAMP-over-WebSocket server transport factories. NrGrHrIrJrrrrr #r c@rz)r zC Mixin for WAMP-over-WebSocket client transport factories. Nr{rrrrr )r|r ) __future__rr^r"autobahn.websocketrautobahn.websocket.typesrautobahn.wamp.interfacesrautobahn.wamp.exceptionrrr__all__objectr registerrVr r rgr r rrrrs     q C