o >hk2@sddlZddlZddlmZmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZmZmZd ZGd d d eZeed ed eeeeeffddZGdddeZGdddeZGdddeZ Gddde Z!Gddde Z"dS)N)OptionalDictTuple)hlval)protocol)ConnectionDenyConnectionRequestConnectionResponse)TransportDetails) ITransportISession) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryc@seZdZUdZdZeeed<dZee ed<dde dee fddZ d d Z d ede dee fd d ZdedefddZddZddZedee fddZddZddZdS)WampWebSocketProtocolz> Base class for WAMP-over-WebSocket transport mixins. N_session_transport_detailscodereasoncCs"|jjd||d|||dS)NzEFailing WAMP-over-WebSocket transport: code={code}, reason="{reason}")rr)logdebug_fail_connection)selfrrrw/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/wamp/websocket.py_bailout5s zWampWebSocketProtocol._bailoutc Cs~z|j|_||j_|j|WdSty>}z|jjdt dd |}|j t j j|dWYd}~dSd}~ww)z^ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onOpen` {tb}tbWAMP Internal Error ({0})rN)factory_factoryr _transportonOpen Exceptionrcritical traceback format_excformatrrWebSocketProtocol CLOSE_STATUS_CODE_INTERNAL_ERROR)rerrrrr(:s   zWampWebSocketProtocol.onOpenwasCleancCsj||_|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}")r1rrr r!) _onclose_reasonrrronCloser)r*r+r,)rr1rrrrrr3Js   zWampWebSocketProtocol.onClosepayloadisBinaryc Cs>zI|j||D]>}|jjdtdddd|jjr!t|jjdddnd|jjr/t|jjdddndtddddtd ddd|d |j|qWdSt yt}z|jj d t d d |}|jtjj|dWYd}~dSd}~wty}z|jj d t d d |}|jtjj|dWYd}~dSd}~ww)za Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onMessage` < {action1}{session}, {authid}{action2} {message} {action3}z WAMP-Receive(greenTcolorboldF-z) <>z>>r<z$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrrErrrFrGrC serializer)errorr-r sendMessager)rrJr4r5r0rrrsendvs$   zWampWebSocketProtocol.sendcCs |jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)rrrrrrLs zWampWebSocketProtocol.isOpenreturncCs|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rrQrrrtransport_detailssz'WampWebSocketProtocol.transport_detailscC |r |tjjdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rL sendCloserr.CLOSE_STATUS_CODE_NORMALrrQrrrclosezWampWebSocketProtocol.closecCrT)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)rLrrr.CLOSE_STATUS_CODE_GOING_AWAYrrQrrrabortrXzWampWebSocketProtocol.abortN)__name__ __module__ __qualname____doc__rrr __annotations__rr intstrrr(boolr3bytesrHrPrLpropertyrSrWrZrrrrr-s  r subprotocolrRcCs^z(|d}|ddkrtd|dt|d}d|dd}||fWSYdS)N.rwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr)r-rajoin)rfsversion serializer_idrrrparseSubprotocolIdentifiers    rpc@s:eZdZdZdZdedeeee eefffddZ dS)rz: Mixin for WAMP-over-WebSocket server transports. TrequestrRcCsi}|jD]$}t|\}}|dkr)||jjvr)t|jj||_||fSq|jr;ttj d d |jjt|jjd|_d|fS)a Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onConnect` rjz1This server only speaks WebSocket subprotocols {}, jsonN) protocolsrpr% _serializerskeyscopyrCSTRICT_PROTOCOL_NEGOTIATIONr BAD_REQUESTr-rl)rrqheadersrfrn serializerIdrrr onConnects     z%WampWebSocketServerProtocol.onConnectN) r\r]r^r_ryrrrrbrr}rrrrrs*rc@s"eZdZdZdZdefddZdS)rz: Mixin for WAMP-over-WebSocket client transports. TresponsecCsX|j|jjvr|jrtdd|jjd}nt|j\}}t|jj ||_ dS)rrzLThe server does not speak any of the WebSocket subprotocols {} we requested.rsrtN) rr%ruryr)r-rlrprxrvrC)rr~rornrrrr}s z%WampWebSocketClientProtocol.onConnectN)r\r]r^r_ryr r}rrrrrsrc@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 csSr[rrr%rrsz/WampWebSocketFactory.__init__..Nr)CBORSerializerT)batched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializercSsg|]}d|jqS)z wamp.2.{})r- SERIALIZER_ID).0serrrr 2sz1WampWebSocketFactory.__init__..) callabler&autobahn.wamp.serializerrappend ImportErrorrrrr)rvr _protocols)rr% serializersrrrrrrrr__init__sN         zWampWebSocketFactory.__init__r[)r\r]r^r_rrrrrrsrc@eZdZdZdS)rzC Mixin for WAMP-over-WebSocket server transport factories. Nr\r]r^r_rrrrr5rc@r)rzC Mixin for WAMP-over-WebSocket client transport factories. Nrrrrrr;rr)#rxr+typingrrr autobahn.utilrautobahn.websocketrautobahn.websocket.typesrrr autobahn.wamp.typesr autobahn.wamp.interfacesr r autobahn.wamp.exceptionr rr__all__objectrregisterrbrarprrrrrrrrrs&    " C