o ik2@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)logdebugZ_fail_connection)selfrrr]C:\Users\psant\Downloads\PAF backend\school\venv\Lib\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}")r0rrrr ) Z_onclose_reasonrrronCloser(r)r*r+)rr0rrrrrr1Js   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(greenTcolorZboldF-z) <>z>>r9z$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrr=rrr>r?r< serializer(errorr,rZ sendMessager)rrAr2r3r/rrrsendvs$   zWampWebSocketProtocol.sendcCs |jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)rrrrrrCs zWampWebSocketProtocol.isOpenreturncCs|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` N)rrGrrrtransport_detailssz'WampWebSocketProtocol.transport_detailscC |r |tjjdSt)zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rCZ sendCloserr-ZCLOSE_STATUS_CODE_NORMALrrGrrrclosezWampWebSocketProtocol.closecCrJ)zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)rCrrr-ZCLOSE_STATUS_CODE_GOING_AWAYrrGrrrabortrLzWampWebSocketProtocol.abortN)__name__ __module__ __qualname____doc__rrr __annotations__rr intstrrr'boolr1bytesr@rFrCpropertyrIrKrMrrrrr-s  r subprotocolrHcCs^z(|d}|ddkrtd|dt|d}d|dd}||fWSYdS)N.rZwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr(r,rTjoin)rYsversion serializer_idrrrparseSubprotocolIdentifiers    rbc@s:eZdZdZdZdedeeee eefffddZ dS)rz: Mixin for WAMP-over-WebSocket server transports. TrequestrHcCsi}|jD]$}t|\}}|dkr)||jjvr)t|jj||_||fSq|jr;ttj d d |jjt|jjd|_d|fS)a Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onConnect` r\z1This server only speaks WebSocket subprotocols {}, jsonN) protocolsrbr$ _serializerskeyscopyr<STRICT_PROTOCOL_NEGOTIATIONr BAD_REQUESTr,r^)rrcheadersrYr`Z serializerIdrrr onConnects     z%WampWebSocketServerProtocol.onConnectN) rOrPrQrRrkrrrrUrrnrrrrrs*rc@s"eZdZdZdZdefddZdS)rz: Mixin for WAMP-over-WebSocket client transports. TresponsecCsX|j|jjvr|jrtdd|jjd}nt|j\}}t|jj ||_ dS)rdzLThe server does not speak any of the WebSocket subprotocols {} we requested.rerfN) rr$rgrkr(r,r^rbrjrhr<)rrorar`rrrrns z%WampWebSocketClientProtocol.onConnectN)rOrPrQrRrkr rnrrrrrsrc@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 csSrNrrr$rrsz/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.serializerrsappend ImportErrorrtrurvr(rhrwZ _protocols)rr$Z serializersrsrtrurvryrrqr__init__sN         zWampWebSocketFactory.__init__rN)rOrPrQrRr~rrrrrpsrpc@eZdZdZdS)rzC Mixin for WAMP-over-WebSocket server transport factories. NrOrPrQrRrrrrr5rc@r)rzC Mixin for WAMP-over-WebSocket client transport factories. Nrrrrrr;rr)#rjr*typingrrrZ autobahn.utilrZautobahn.websocketrZautobahn.websocket.typesrrr Zautobahn.wamp.typesr Zautobahn.wamp.interfacesr r Zautobahn.wamp.exceptionr rr__all__objectrregisterrUrTrbrrrprrrrrrs&    " C