hk2VddlZddlZddlmZmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZmZmZd ZGd d eZej4ed ed eeeeeffdZGddeZGddeZGddeZ Gdde Z!Gdde Z"y)N)OptionalDictTuple)hlval)protocol)ConnectionDenyConnectionRequestConnectionResponse)TransportDetails) ITransportISession) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryceZdZUdZdZeeed<dZee ed<dde dee fdZ dZ d ede dee fd Zd ed efd ZdZdZedee fdZdZdZy)WampWebSocketProtocolz> Base class for WAMP-over-WebSocket transport mixins. N_session_transport_detailscodereasoncd|jjd|||j||y)NzEFailing WAMP-over-WebSocket transport: code={code}, reason="{reason}")rr)logdebug_fail_connection)selfrrs S/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/wamp/websocket.py_bailoutzWampWebSocketProtocol._bailout5s0 ^ei$  & dF+c |jj|_||j_|jj |y#t $ru}|j jdtjdj|}|jtjj|Yd}~yd}~wwxYw)z^ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onOpen` {tb}tbWAMP Internal Error ({0})rN)factory_factoryr _transportonOpen Exceptionrcritical traceback format_excformatr!rWebSocketProtocol CLOSE_STATUS_CODE_INTERNAL_ERROR)rers r r,zWampWebSocketProtocol.onOpen:s  f LL113DM'+DMM $ MM  & f HH  f)=)=)?  @077:F MM(44UU^dM e e fsA A C A+CC wasCleanc,||_|jC |jjd||||jj |d|_yy#t $r2|jj dtjYCwxYw)z_ Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onClose` NzWWAMP-over-WebSocket transport lost: wasClean={wasClean}, code={code}, reason="{reason}")r5rrr$r%) _onclose_reasonrrronCloser-r.r/r0)rr5rrs r r8zWampWebSocketProtocol.onCloseJs & == $ Em%DA %%h/!DM % E!!&Y-A-A-C!D Es:A8BBpayloadisBinaryc  |jj||D]}|jjdt ddd|j j r"t |j j ddnd|j jr"t |j jddndt dddt d dd| |j j|y#t$ru}|jjd tj d j|}|jtj j"|Yd}~yd}~wt$$ru}|jjd tj dj|}|jtj j&|Yd}~yd}~wwxYw)za Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onMessage` < {action1}{session}, {authid}{action2} {message} {action3}z WAMP-Receive(greenTcolorboldF-z) <A+E.. G/:A+G**G/c |jr |jjdtddd|jj r"t|jj ddnd|jj r"t|jj ddndtdddtd dd| |jj|\}}|j||y t#t$rI}|jjd j|td j|d }~wwxYw)zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` r<zWAMP-Transmit(redTr>FrAz) >>z>>rBz$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrrKrrrLrMrI serialize sendMessager-errorr1rr)rrPr9r:r4s r sendzWampWebSocketProtocol.sendvs& ;;= 4`',-=UQU'V_c_l_l_t_teDMM,A,AUZ&[z}dhdqdqd}d}uT]]-F-FeZ_'`DG',V5t'L',TT'J'* ,%)$4$4$>$>s$C!   (3/ ! \ELLQOP()P)W)WXY)Z[[ \sCD E AEEc|jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)rrs r rSzWampWebSocketProtocol.isOpens}}D((r"returnc|jS)zZ Implements :func:`autobahn.wamp.interfaces.ITransport.transport_details` )rrYs r transport_detailsz'WampWebSocketProtocol.transport_detailss &&&r"c|jr*|jtjjyt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rS sendCloserr2CLOSE_STATUS_CODE_NORMALrrYs r closezWampWebSocketProtocol.closes- ;;= NN855NN O/ !r"c|jr*|jtjjyt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)rSr!rr2CLOSE_STATUS_CODE_GOING_AWAYrrYs r abortzWampWebSocketProtocol.aborts- ;;= MM(44QQ R/ !r"N)__name__ __module__ __qualname____doc__rrr __annotations__rr intstrr!r,boolr8bytesrNrWrSpropertyr\r`rcr"r rr-s$(Hhx '59!129,S,(3-, f !!C!#!&ff$f2".) '8,<#='' ""r"r subprotocolrZc |jd}|ddk7rtdj|dt|d}dj |dd}||fS#YyxYw)N.rwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr-r1rjjoin)rpsversion serializer_ids r parseSubprotocolIdentifierr{su   c " Q46>dkklmnolpqr rad)12  %%s AAA"c>eZdZdZdZdedeeee eefffdZ y)rz: Mixin for WAMP-over-WebSocket server transports. TrequestrZc$i}|jD]s}t|\}}|dk(s||jjj vs>t j |jj||_||fcS|jrLttjdjdj|jjt j |jjd|_d|fS)a Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onConnect` ruz1This server only speaks WebSocket subprotocols {}, jsonN) protocolsr{r) _serializerskeyscopyrISTRICT_PROTOCOL_NEGOTIATIONr BAD_REQUESTr1rw)rr}headersrpry serializerIds r onConnectz%WampWebSocketServerProtocol.onConnects",,K$>{$K !G\!|  0I0I0N0N0P P#'99T\\-F-F|-T#U "G++ -  + + !;!;=p=w=w $,,001>34 4 $yy)B)B6)JKD = r"N) rerfrgrhrr rrrkrrror"r rrs<#'!!2!uXc]DQTVYQYN=Z7[!r"rc eZdZdZdZdefdZy)rz: Mixin for WAMP-over-WebSocket client transports. Tresponsecr|j|jjvrL|jr=t dj dj |jjd}nt|j\}}tj|jj||_ y)rzLThe server does not speak any of the WebSocket subprotocols {} we requested.rrN) rr)rrr-r1rwr{rrrI)rrrzrys r rz%WampWebSocketClientProtocol.onConnects   DLL$:$: :// n u uIIdll445!788!' %?@Q@Q%R "G] 99T\\%>%>}%MNr"N)rerfrgrhrr rror"r rrs#'O"4Or"rceZdZdZddZy)WampWebSocketFactoryzF Base class for WAMP-over-WebSocket transport factory mixins. Nc8tr|_n fd|_|g} ddlm}|j |d|j | ddlm}|j |d|j | ddlm}|j |d|j | dd lm}|j |d|j ||s td i|_ |D]}||j|j<|Dcgc]}d j|jc}|_ y#t $rYwxYw#t $rYwxYw#t $rYwxYw#t $rYwxYwcc}w) 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 cSrdro)r)sr z/WampWebSocketFactory.__init__..sGr"Nr)CBORSerializerT)batched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializerz wamp.2.{})callabler*autobahn.wamp.serializerrappend ImportErrorrrrr-r SERIALIZER_IDr1 _protocols)rr) serializersrrrrsers ` r __init__zWampWebSocketFactory.__init__s G #DM+DM  K C"">$#?@"">#34  F""#4T#BC""#4#67  E""#3D#AB""#3#56  C"">$#?@"">#34 FGGC36D  c// 0MXXS;--c.?.?@XE        YsM4E4E*4E94F/"F E'&E'* E65E69 FF FFrd)rerfrgrhrror"r rrs ;Yr"rceZdZdZy)rzC Mixin for WAMP-over-WebSocket server transport factories. Nrerfrgrhror"r rr5r"rceZdZdZy)rzC Mixin for WAMP-over-WebSocket client transport factories. Nrror"r rr;rr"r)#rr/typingrrr autobahn.utilrautobahn.websocketrautobahn.websocket.typesrr r autobahn.wamp.typesr autobahn.wamp.interfacesr r autobahn.wamp.exceptionrrr__all__objectrregisterrkrjr{rrrrrror"r rs6 (('ZZ09TT ) }"F}"@ )* C E(3-RU:V4W !"7!:O"7O2@Y6@YF!5 !5r"