tf.ddlZddlmZddlmZddlmZddlmZddlZejddl m Z m Z ddl m Z mZddlmZdd lmZd Zd ZGd d ejZe GddeejZe GddeejZGddeZe GddeejZe GddeejZe GddejeZe GddejeZe GddejeZe Gddej eZ dS) N) iscoroutine)Future)deque)Optional)publichltype)create_transport_detailstransport_channel_id) websocket)protocol)WebSocketServerProtocolWebSocketClientProtocolWebSocketServerFactoryWebSocketClientFactoryWampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactorycJt|tpt|S)z Returns ``True`` iff the value yields. .. seealso:: http://stackoverflow.com/questions/20730248/maybedeferred-analog-with-asyncio ) isinstancerr)values Y/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/asyncio/websocket.pyyieldsr5s! eV $ $ : E(:(::ceZdZUdZejZdZee e d<dZ ee e d<dZ dZdZdZdd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdS)WebSocketAdapterProtocolzP Adapter class for asyncio-based WebSocket client and server protocols. Npeer is_servercH|jdt|j|||_t |j|j|_|jj|_t|_ | | dS)Nz{func}(transport={transport}))func transport) logdebugrconnection_mader!r r_transport_detailsrr receive_queue_consume_connectionMade)selfr!s rr$z(WebSocketAdapterProtocol.connection_madeGs 6VDDX=Y=Y!*  , , ,##;4>4>"Z"Z+0 "WW  rct||||jd|_dSN)_connectionLostr!close)r)excs rconnection_lostz(WebSocketAdapterProtocol.connection_lostZs< S!!! ? N " " "rctjjptjj_fd}j|dS)N)loopcjr<j}jr|j<dSr+)r&popleftr! _dataReceivedr')_datar)s rprocessz2WebSocketAdapterProtocol._consume..processes`$ -)1133>-&&t,,,$ - MMOOOOOr)rfactoryr1txaioconfigwaiteradd_done_callback)r)r7s` rr'z!WebSocketAdapterProtocol._consumebs[$,"3"Hu|7HIII       %%g.....rc|j||js|jddSdSr+)r&appendr;done set_result)r)r6s r data_receivedz&WebSocketAdapterProtocol.data_receivednsU !!$'''{!! ) K " "4 ( ( ( ( ( ) )rFc|r0t|jdr|jdS|jdS)Nabort)hasattrr!rCr-)r)rCs r_closeConnectionz)WebSocketAdapterProtocol._closeConnectionssQ  #WT^W55 # N " " " " " N " " " " "rc|jjr.dt|j|jjdi}||j_|}t|rtj |dSdS)Nz tls-unique) r% is_securer r!r channel_idonOpenrasyncio ensure_future)r)rHress r_onOpenz WebSocketAdapterProtocol._onOpenys}  " , <24>4CZCdfrssJ2sm %   CD(3- $Ix~$$$& / / /))) #### ' ' '''' ''' ''' ''' ''' ''' ''' ''' ''' ''' +++     rrc0eZdZdZejZdS)r z Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` Nrrrrr9rr"r|rrr r * %   CCCrr c<eZdZdZejZdZdZdS)rz Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` c||}|jdt|j|t |rt j|dSdS)Nz {func}: {res})r rL) onConnectr"r#r _onConnectrrJrK)r)responserLs rrz"WebSocketClientProtocol._onConnectsfnnX&& VDO-D-D#NNN #;; '  !# & & & & & ' 'rc td)Nz)WSS over explicit proxies not implementedrvr}s rstartTLSz WebSocketClientProtocol.startTLSsCDDDrN) rrrrr9rr"rrr|rrrrsS %   C''' EEEEErrc6eZdZdZejZdZdS)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. c<|}||_|Sr+)r r8)r)protos r__call__z WebSocketAdapterFactory.__call__s   rN)rrrrr9rr"rr|rrrrs? %   Crrc:eZdZdZejZeZdZ dS)rz Base class for asyncio-based WebSocket server factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketServerChannelFactory` c|dd}|ptj|_t jj|g|Ri|dS)a .. note:: In addition to all arguments to the constructor of :meth:`autobahn.websocket.interfaces.IWebSocketServerChannelFactory`, you can supply a ``loop`` keyword argument to specify the asyncio event loop to be used. r1N)poprJget_event_loopr1r r__init__r)argskwargsr1s rrzWebSocketServerFactory.__init__sVzz&$''4G244 '0GGGGGGGGGrN) rrrrr9rr"r r rr|rrrrsI %   C&H H H H H Hrrc6eZdZdZejZdZdS)rz Base class for asyncio-based WebSocket client factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory` c|dd}|ptj|_t jj|g|Ri|dS)a .. note:: In addition to all arguments to the constructor of :meth:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory`, you can supply a ``loop`` keyword argument to specify the asyncio event loop to be used. r1N)rrJrr1r rrrs rrzWebSocketClientFactory.__init__sVzz&$''4G244 '0GGGGGGGGGrN)rrrrr9rr"rr|rrrrsD %   C H H H H Hrrc0eZdZdZejZdS)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrr|rrrr*rrrc:eZdZdZejZeZdZ dS)rz; asyncio-based WAMP-over-WebSocket server factory. c|dd}tj||||j|d<t j|g|Ri|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 all available serializers). :type serializers: list of objects implementing :class:`autobahn.wamp.interfaces.ISerializer` serializersN protocols)rr rr _protocolsrr)r8rrrs rrz#WampWebSocketServerFactory.__init__Asgjj55 ,55dG[QQQ"o{ '>t>>>v>>>>>rN) rrrrr9rr"rr rr|rrrr7sD %   C*H?????rrc0eZdZdZejZdS)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrr|rrrrXrrrc:eZdZdZejZeZdZ dS)rz; asyncio-based WAMP-over-WebSocket client factory. c|dd}tj||||j|d<t j|g|Ri|dS)a :param factory: A callable that produces instances that implement :class:`autobahn.wamp.interfaces.ITransportHandler` :type factory: callable :param serializer: The WAMP serializer to use (or ``None`` for "best" serializer, chosen as the first serializer available from this list: CBOR, MessagePack, UBJSON, JSON). :type serializer: object implementing :class:`autobahn.wamp.interfaces.ISerializer` rNr)rr rrrrrs rrz#WampWebSocketClientFactory.__init__osejj55 ,55dG[QQQ"o{'>t>>>v>>>>>rN) rrrrr9rr"rr rr|rrrresD %   C*H?????rr)!rJrr collectionsrtypingrr9 use_asyncio autobahn.utilrrautobahn.asyncio.utilr r autobahn.wampr autobahn.websocketr __all__rProtocolrr robjectrrrrrrrr|rrrs?6 ((((((((PPPPPPPP######'''''' ;;;C C C C C w/C C C L     68X   EEEEE68XEEE*     f   HHHHH4h6UHHH6HHHHH4h6UHHH4     )"GI`   ?????!EG]???@     )"GI`   ?????!EG]?????r