U uck2@sddlZddlZddlmZmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZmZmZd ZGd d d eZeeeeeeeefd d dZGdddeZGdddeZGdddeZ Gddde Z!Gddde Z"dS)N)OptionalDictTuple)hlval)protocol)ConnectionDenyConnectionRequestConnectionResponse)TransportDetails) ITransportISession) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryc@seZdZUdZdZeeed<dZee ed<de ee dddZ dd Z ee ee d d d Zeed ddZddZddZeee dddZddZddZdS)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}"r)logdebugZ_fail_connection)selfrrrV/var/www/html/VBACK/school/venv/lib/python3.8/site-packages/autobahn/wamp/websocket.py_bailout5s zWampWebSocketProtocol._bailoutc Cs|z$|j|_||j_|j|WnRtk rv}z4|jjdt dd |}|j t j j|dW5d}~XYnXdS)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.onOpenwasCleanrrcCsh||_|jdk rdz$|jjd|||d|j|Wn(tk r\|jjdtdYnXd|_dS)z_ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onClose` NzWWAMP-over-WebSocket transport lost: wasClean={wasClean}, code={code}, reason="{reason}"r1r r!) Z_onclose_reasonrrronCloser)r*r+r,)rr2rrrrrr3Js zWampWebSocketProtocol.onClose)payloadisBinaryc Cs:z|j||D]|}|jjdtdddd|jjrBt|jjdddnd|jjr^t|jjdddndtddddtd ddd|d |j|qWnt k r}z4|jj d t d d |}|jtjj|dW5d}~XYnTtk r4}z4|jj d t d d |}|jtjj|dW5d}~XYnXdS)za Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onMessage` < {action1}{session}, {authid}{action2} {message} {action3}z WAMP-Receive(ZgreenTZcolorZboldF-z) <>z>>r9z$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrr=rrr>r?r< serializer)errorr-rZ sendMessager)rrAr4r5r0rrrsendvs     zWampWebSocketProtocol.sendcCs |jdk S)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)rrrrrrBszWampWebSocketProtocol.isOpen)returncCs|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rrFrrrtransport_detailssz'WampWebSocketProtocol.transport_detailscCs"|r|tjjntdS)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rBZ sendCloserr.ZCLOSE_STATUS_CODE_NORMALrrFrrrcloseszWampWebSocketProtocol.closecCs"|r|tjjntdS)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)rBrrr.ZCLOSE_STATUS_CODE_GOING_AWAYrrFrrrabortszWampWebSocketProtocol.abort)N)__name__ __module__ __qualname____doc__rrr __annotations__rr intstrrr(boolr3bytesr@rErBpropertyrHrIrJrrrrr-s  r) subprotocolrGcCsdzP|d}|ddkr*td|dt|d}d|dd}||fWSYdSXdS)N.rZwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr)r-rPjoin)rUsversion serializer_idrrrparseSubprotocolIdentifiers    r^c@s8eZdZdZdZeeeee eeffdddZ dS)rz: Mixin for WAMP-over-WebSocket server transports. T)requestrGcCsi}|jD]H}t|\}}|dkr ||jjkr t|jj||_||fSq |jrxttj d d |jjnt|jjd|_d|fSdS)a Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onConnect` rXz1This server only speaks WebSocket subprotocols {}, jsonN) protocolsr^r% _serializerskeyscopyr<STRICT_PROTOCOL_NEGOTIATIONrZ BAD_REQUESTr-rZ)rr_headersrUr\Z serializerIdrrr onConnects    z%WampWebSocketServerProtocol.onConnectN) rKrLrMrNrgrrrrQrrirrrrrsrc@s"eZdZdZdZedddZdS)rz: Mixin for WAMP-over-WebSocket client transports. T)responsecCsZ|j|jjkr4|jr.tdd|jjqBd}nt|j\}}t|jj ||_ dS)r`zLThe server does not speak any of the WebSocket subprotocols {} we requested.rarbN) rr%rcrgr)r-rZr^rfrdr<)rrjr]r\rrrris z%WampWebSocketClientProtocol.onConnectN)rKrLrMrNrgr rirrrrrsrc@seZdZdZdddZdS)WampWebSocketFactoryzF Base class for WAMP-over-WebSocket transport factory mixins. Ncsvtr|_nfdd|_|dkrDg}z,ddlm}||dd||Wntk rlYnXz,ddlm}||dd||Wntk rYnXz,dd lm}||dd||Wntk rYnXz,dd lm}||dd||Wntk r4YnX|sDt d i|_ |D]}||j |j <qNd 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 csS)Nrrr%rrz/WampWebSocketFactory.__init__..Nr)CBORSerializerT)Zbatched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializercSsg|]}d|jqS)z wamp.2.{})r- SERIALIZER_ID).0serrrr 2sz1WampWebSocketFactory.__init__..) callabler&Zautobahn.wamp.serializerroappend ImportErrorrprqrrr)rdrsZ _protocols)rr%Z serializersrorprqrrrurrlr__init__sF      zWampWebSocketFactory.__init__)N)rKrLrMrNrzrrrrrksrkc@seZdZdZdS)rzC Mixin for WAMP-over-WebSocket server transport factories. NrKrLrMrNrrrrr5src@seZdZdZdS)rzC Mixin for WAMP-over-WebSocket client transport factories. Nr{rrrrr;sr)#rfr+typingrrrZ autobahn.utilrZautobahn.websocketrZautobahn.websocket.typesrrr Zautobahn.wamp.typesr Zautobahn.wamp.interfacesr r Zautobahn.wamp.exceptionr rr__all__objectrregisterrQrPr^rrrkrrrrrrs$     C