8'hz, ddlmZddlZddlZddlmZddlmZddlm Z ddl m Z m Z m Z dZGdd eZe j"ed ZGd d eZGd deZGddeZGddeZGddeZy))absolute_importN)protocol)ConnectionDeny) ITransport) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactorycFeZdZdZdZd dZdZdZdZdZ dZ d Z d Z y) WampWebSocketProtocolz> Base class for WAMP-over-WebSocket transport mixins. Ncd|jjd|||j||y)NzEFailing WAMP-over-WebSocket transport: code={code}, reason="{reason}")codereason)logdebug_fail_connection)selfrrs S/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/wamp/websocket.py_bailoutzWampWebSocketProtocol._bailout2s+ ^eirxy dF+c| |jj|_|jj|y#t$ru}|j j dtjdj|}|jtjj|Yd}~yd}~wwxYw)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)rers rr#zWampWebSocketProtocol.onOpen6s  f LL113DM MM  & f HH  f)=)=)?  @188;F MM(44UU^dM e e fs:= B;A+B66B;c,||_|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}")wasCleanrrrr) _onclose_reasonr"rronCloser$r%r&r')rr-rrs rr/zWampWebSocketProtocol.onCloseDs & == $ ExDLSW`fg %%h/!DM % E!!&Y-A-A-C!D Es:A8BBc |jj||D]d}|jjd|jj |jj ||jj|fy#t$ru}|jjdtjdj|}|jtjj |Yd}~yd}~wt"$ru}|jjdtjdj|}|jtjj$|Yd}~yd}~wwxYw) 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+rs rr:zWampWebSocketProtocol.onMessageUs1 f''33GXF -V==00 MM55   '', - f HH  f)=)=)?  @188;F MM(44UU^dM e e f HH  f)=)=)?  @188;F MM(44UU^dM e e fs&BB FA+C?? F A+E;;Fc|jry |jjd|jj|jj ||j j|\}}|j||yt#t$rI}|jjdj|tdj|d}~wwxYw)zM Implements :func:`autobahn.wamp.interfaces.ITransport.send` z@WAMP SEND: message={message}, session={session}, authid={authid}r1z$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrr7r"r8r9r5 serialize sendMessager$errorr(rr )rr>r<r=r+s rsendzWampWebSocketProtocol.sendms ;;= 4V==00 MM55  %)$4$4$>$>s$C!   (3/ ! ]ELLQOP()Q)X)XYZ)[\\ ]sA%B C&AC!!C&c|jduS)zO Implements :func:`autobahn.wamp.interfaces.ITransport.isOpen` N)r"rs rr@zWampWebSocketProtocol.isOpens}}D((rc|jr*|jtjjyt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)r@ sendCloserr)CLOSE_STATUS_CODE_NORMALr rFs rclosezWampWebSocketProtocol.closes- ;;= NN855NN O/ !rc|jr*|jtjjyt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)r@rrr)CLOSE_STATUS_CODE_GOING_AWAYr rFs rabortzWampWebSocketProtocol.aborts- ;;= MM(44QQ R/ !rN) __name__ __module__ __qualname____doc__r"rr#r/r:rDr@rJrMrrrr+s8H, f!"f0",) ""rrc |jd}|ddk7rtdj|dt|d}dj |dd}||fS#YyxYw)N.rwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr$r(intjoin) subprotocolsversion serializerIds rparseSubprotocolIdentifierr`sv   d # Q47?ellmnopmqrs sad)yy12'  $$s AAA"ceZdZdZdZdZy)r z: Mixin for WAMP-over-WebSocket server transports. Tc$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` rXz1This server only speaks WebSocket subprotocols {}, jsonN) protocolsr`r _serializerskeyscopyr5STRICT_PROTOCOL_NEGOTIATIONr BAD_REQUESTr(r[)rrequestheadersr\r^r_s r onConnectz%WampWebSocketServerProtocol.onConnects",, ,K$>{$K !G\!|  0I0I0N0N0P P$(99T\\-F-F|-T#U "G++ ,  + + !;!;=q=x=xy~zDzDEIEQEQE[E[z\>]^ ^ $yy)B)B7)KLD = rNrOrPrQrRrjrnrSrrr r s#'!rr ceZdZdZdZdZy)r z: Mixin for WAMP-over-WebSocket client transports. Tcr|j|jjvrL|jr=t dj dj |jjd}nt|j\}}tj|jj||_ y)rczLThe server does not speak any of the WebSocket subprotocols {} we requested.rdreN) rr rfrjr$r(r[r`rirgr5)rresponser_r^s rrnz%WampWebSocketClientProtocol.onConnects   DLL$:$: :// o v vw|xBxBCGCOCOCYCYxZ![\\ ' $>x?P?P$Q !G\ 99T\\%>%>|%LMrNrorSrrr r s#'Nrr ceZdZdZddZy)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 cSrNrS)r srz/WampWebSocketFactory.__init__..sGrNr)CBORSerializerT)batched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializerz wamp.2.{})callabler!autobahn.wamp.serializerrxappend ImportErrorrzr{r|r$rg SERIALIZER_IDr( _protocols)rr serializersrxrzr{r|sers ` r__init__zWampWebSocketFactory.__init__s G #DM+DM  K C"">$#?@"">#34  F""#4T#BC""#4#67  E""#3D#AB""#3#56  C"">$#?@"">#34 GHH 7C36D  c// 0 7NYYc<..s/@/@AYE        ZsM4E4E*4E94F/"F E'&E'* E65E69 FF FFrN)rOrPrQrRrrSrrrtrts ;ZrrtceZdZdZy)r zC Mixin for WAMP-over-WebSocket server transport factories. NrOrPrQrRrSrrr r #rr ceZdZdZy)r zC Mixin for WAMP-over-WebSocket client transport factories. NrrSrrr r )rrr ) __future__rrir&autobahn.websocketrautobahn.websocket.typesrautobahn.wamp.interfacesrautobahn.wamp.exceptionrrr __all__objectrregisterr`r r rtr r rSrrrs6' '3/TT ) n"Fn"b )* !"7!:N"7N0@Z6@ZF!5 !5r