afk2ddlZddlZddlmZmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZmZmZd ZGd d eZejed ed eeeeeffdZGddeZGddeZGddeZ Gdde Z!Gdde Z"dS)N)OptionalDictTuple)hlval)protocol)ConnectionDenyConnectionRequestConnectionResponse)TransportDetails) ITransportISession) ProtocolErrorSerializationError TransportLost)WampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryceZdZUdZdZeeed<dZee ed<dde dee fdZ dZ d ede dee fd Zd ed efd ZdZdZedee fdZdZdZdS)WampWebSocketProtocolz> Base class for WAMP-over-WebSocket transport mixins. N_session_transport_detailscodereasoncl|jd|||||dS)NzEFailing WAMP-over-WebSocket transport: code={code}, reason="{reason}")rr)logdebug_fail_connection)selfrrs I/var/www/html/env/lib/python3.11/site-packages/autobahn/wamp/websocket.py_bailoutzWampWebSocketProtocol._bailout5sD ^ei$  & & & dF+++++c |j|_||j_|j|dS#t $rs}|jdtj d |}| tj j|Yd}~dSd}~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 L1133DM'+DM $ M  & & & & & f f f H  f)=)?)?  @ @ @077::F MM(4U^dM e e e e e e e e e fsAA CA(CCwasCleanc"||_|j |jd||||j|n=#t $r0|jdtjYnwxYwd|_dSdS)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%DAAA %%h//// E E E!!&Y-A-C-C!DDDDD E DMMM % $s8A 7BBpayloadisBinaryc  |j||D]}|jdt ddd|jjrt |jjddnd|jjrt |jjddndt dddt d dd| |j|dS#t$rs}|j d tj d |}|tjj|Yd}~dSd}~wt$$rs}|j d tj d |}|tjj|Yd}~dSd}~wwxYw)za Callback from :func:`autobahn.websocket.interfaces.IWebSocketChannel.onMessage` < {action1}{session}, {authid}{action2} {message} {action3}z WAMP-Receive(greenTcolorboldF-z) <FrAz) >>z>>rBz$WAMP message serialization error: {}z%WAMP message serialization error: {0}N)isOpenrrKrrrLrMrI serialize sendMessager-errorr1rr)rrPr9r:r4s r sendzWampWebSocketProtocol.sendvsz ;;== " 4`',-=UQU'V'V'V_c_l_t&}eDM,AUZ&[&[&[&[z}dhdqd}(GuT]-FeZ_'`'`'`'`DG',V5t'L'L'L',TT'J'J'J'* ,,,%)$4$>$>s$C$C!   (33333  \ \ \ELLQOOPPP()P)W)WXY)Z)Z[[[ \ // !sB>C-- E 7AEE c|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|r&|tjjdSt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.close` N)rS sendCloserr2CLOSE_STATUS_CODE_NORMALrrYs r closezWampWebSocketProtocol.closes< ;;== " NN85N O O O O O// !r"c|r&|tjjdSt )zN Implements :func:`autobahn.wamp.interfaces.ITransport.abort` N)rSr!rr2CLOSE_STATUS_CODE_GOING_AWAYrrYs r abortzWampWebSocketProtocol.aborts< ;;== " MM(4Q R R R R R// !r"N)__name__ __module__ __qualname____doc__rrr __annotations__rr intstrr!r,boolr8bytesrNrWrSpropertyr\r`rcr"r rr-sI$(Hhx '''59!12999,,S,(3-,,,, fff !!C!#!!!!&ff$ffff2""".))) '8,<#='''X' """"""""r"r subprotocolrZc |d}|ddkr(td|dt|d}d|dd}||fS#YdSxYw)N.rwampzFWAMP WebSocket subprotocol identifier must start with "wamp", not "{}")NN)splitr-r1rjjoin)rpsversion serializer_ids r parseSubprotocolIdentifierr{s   c " " Q46>>dkklmnolpqqrr rad))122  %%zzs A>BBcReZdZdZdZdedeeee eefffdZ dS)rz: Mixin for WAMP-over-WebSocket server transports. TrequestrZci}|jD]i}t|\}}|dkrO||jjvr/t j|jj||_||fcSj|jrJttj d d |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$K !G\!||  0I0N0N0P0P P P#'9T\-F|-T#U#U "G++++  + ! !;=p=w=w $,011>3>344 4 $y)B6)JKKD = r"N) rerfrgrhrr rrrkrrror"r rrsb#'!!2!uXc]DQTVYQYN=Z7[!!!!!!r"rc"eZdZdZdZdefdZdS)rz: Mixin for WAMP-over-WebSocket client transports. Tresponsec>|j|jjvrI|jr?t dd|jjd}nt|j\}}tj|jj ||_ dS)rzLThe server does not speak any of the WebSocket subprotocols {} we requested.rrN) rr)rrr-r1rwr{rrrI)rrrzrys r rz%WampWebSocketClientProtocol.onConnects  DL$: : :/ ' n u uIIdl455!7!7888!' %?@Q%R%R "G] 9T\%>}%MNNr"N)rerfrgrhrr rror"r rrsI#'O"4OOOOOOr"rceZdZdZddZdS)WampWebSocketFactoryzF Base class for WAMP-over-WebSocket transport factory mixins. Ncntr|_n fd|_|cg} ddlm}||d||n#t $rYnwxYw ddlm}||d||n#t $rYnwxYw ddlm}||d||n#t $rYnwxYw dd lm}||d||n#t $rYnwxYw|std i|_ |D]}||j |j <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 cSrdro)r)sr z/WampWebSocketFactory.__init__..sGr"Nr)CBORSerializerT)batched)MsgPackSerializer)UBJSONSerializer)JsonSerializerz$Could not import any WAMP serializercBg|]}d|jS)z wamp.2.{})r1 SERIALIZER_ID).0sers r z1WampWebSocketFactory.__init__..2s)XXXS;--c.?@@XXXr") callabler*autobahn.wamp.serializerrappend ImportErrorrrrr-rr _protocols)rr) serializersrrrrrs ` r __init__zWampWebSocketFactory.__init__sw G   ,#DMM+OOODM  K CCCCCC"">>$#?#?#?@@@"">>#3#34444     FFFFFF""#4#4T#B#B#BCCC""#4#4#6#67777     EEEEEE""#3#3D#A#A#ABBB""#3#3#5#56666     CCCCCC"">>$#?#?#?@@@"">>#3#34444     H FGGG 7 7C36D c/ 0 0XXKXXXsKAA,, A98A9=AC C  C AD D! D!%AE(( E54E5rd)rerfrgrhrror"r rrs8;Y;Y;Y;Y;Y;Yr"rceZdZdZdS)rzC Mixin for WAMP-over-WebSocket server transport factories. Nrerfrgrhror"r rr5r"rceZdZdZdS)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 rsB6 ((((((((((''''''ZZZZZZZZZZ00000099999999TTTTTTTTTT ) }"}"}"}"}"F}"}"}"@ )*** C E(3-RU:V4W    !!!!!"7!!!:OOOOO"7OOO2@Y@Y@Y@Y@Y6@Y@Y@YF!5 !5r"