o >h.@srddlZddlmZddlmZddlmZddlmZddlZeddl m Z m Z ddl m Z mZddlmZdd lmZd Zd d ZGd ddejZe GdddeejZe GdddeejZGdddeZe GdddeejZe GdddeejZe GdddejeZe GdddejeZe GdddejeZe Gdd d ej eZ dS)!N) iscoroutine)Future)deque)Optional)publichltype)create_transport_detailstransport_channel_id) websocket)protocol)WebSocketServerProtocolWebSocketClientProtocolWebSocketServerFactoryWebSocketClientFactoryWampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactorycCst|tpt|S)z Returns ``True`` iff the value yields. .. seealso:: http://stackoverflow.com/questions/20730248/maybedeferred-analog-with-asyncio ) isinstancerr)valuerz/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/asyncio/websocket.pyyields5src@seZdZUdZeZdZee e d<dZ ee e d<ddZ ddZd d Zd d Zd*ddZddZddZddZddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)ZdS)+WebSocketAdapterProtocolzP Adapter class for asyncio-based WebSocket client and server protocols. Npeer is_servercCsT|jjdt|j|d||_t|j|j|_|jj|_t |_ | | dS)Nz{func}(transport={transport}))func transport) logdebugrconnection_maderrr_transport_detailsrr receive_queue_consume_connectionMade)selfrrrrr Gs  z(WebSocketAdapterProtocol.connection_madecCs&|||dur|jd|_dSN)_connectionLostrclose)r%excrrrconnection_lostZs   z(WebSocketAdapterProtocol.connection_lostcs4tjjptjjd_fdd}j|dS)N)loopcs2jrj}jr|jsdSr&)r"popleftr _dataReceivedr#)_datar%rrprocesses    z2WebSocketAdapterProtocol._consume..process)rfactoryr+txaioconfigwaiteradd_done_callback)r%r1rr0rr#bs z!WebSocketAdapterProtocol._consumecCs*|j||js|jddSdSr&)r"appendr5done set_result)r%r/rrr data_receivedns  z&WebSocketAdapterProtocol.data_receivedFcCs,|rt|jdr|jdS|jdS)Nabort)hasattrrr;r()r%r;rrr_closeConnectionssz)WebSocketAdapterProtocol._closeConnectioncCsH|jjrdt|j|jjdi}||j_|}t|r"t |dSdS)Nz tls-unique) r! is_securer rr channel_idonOpenrasyncio ensure_future)r%r?resrrr_onOpenysz WebSocketAdapterProtocol._onOpencC$||}t|rt|dSdSr&)onMessageBeginrrArB)r%isBinaryrCrrr_onMessageBegin z(WebSocketAdapterProtocol._onMessageBegincCrEr&)onMessageFrameBeginrrArB)r%lengthrCrrr_onMessageFrameBeginrIz-WebSocketAdapterProtocol._onMessageFrameBegincCrEr&)onMessageFrameDatarrArBr%payloadrCrrr_onMessageFrameDatarIz,WebSocketAdapterProtocol._onMessageFrameDatacC"|}t|rt|dSdSr&)onMessageFrameEndrrArBr%rCrrr_onMessageFrameEndz+WebSocketAdapterProtocol._onMessageFrameEndcCrEr&)onMessageFramerrArBrNrrr_onMessageFramerIz(WebSocketAdapterProtocol._onMessageFramecCrQr&) onMessageEndrrArBrSrrr _onMessageEndrUz&WebSocketAdapterProtocol._onMessageEndcCs&|||}t|rt|dSdSr&) onMessagerrArB)r%rOrGrCrrr _onMessages z#WebSocketAdapterProtocol._onMessagecCrEr&)onPingrrArBrNrrr_onPingrIz WebSocketAdapterProtocol._onPingcCrEr&)onPongrrArBrNrrr_onPongrIz WebSocketAdapterProtocol._onPongcCs(||||}t|rt|dSdSr&)onCloserrArB)r%wasCleancodereasonrCrrr_onClosesz!WebSocketAdapterProtocol._onClosecCtd)Nznot implemented Exception)r%producer streamingrrrregisterProducerz)WebSocketAdapterProtocol.registerProducercCsdSr&rr0rrrunregisterProducersz+WebSocketAdapterProtocol.unregisterProducer)F)__name__ __module__ __qualname____doc__r3 make_loggerrrrstr__annotations__rboolr r*r#r:r=rDrHrLrPrTrWrYr[r]r_rdrjrlrrrrr>s.    rc@eZdZdZeZdS)r z Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` Nrmrnrorpr3rqrrrrrr  r c@s(eZdZdZeZddZddZdS)r z Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` cCs<||}|jjdt|j|dt|rt|dSdS)Nz {func}: {res})rrC) onConnectrrr _onConnectrrArB)r%responserCrrrrys z"WebSocketClientProtocol._onConnectcCre)Nz)WSS over explicit proxies not implementedrfr0rrrstartTLSrkz WebSocketClientProtocol.startTLSN) rmrnrorpr3rqrryr{rrrrr s  r c@ eZdZdZeZddZdS)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. cCs|}||_|Sr&)r r2)r%protorrr__call__sz WebSocketAdapterFactory.__call__N)rmrnrorpr3rqrrrrrrr}s r}c@$eZdZdZeZeZddZ dS)rz Base class for asyncio-based WebSocket server factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketServerChannelFactory` cO8|dd}|p t|_tjj|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. r+N)poprAget_event_loopr+r r__init__r%argskwargsr+rrrrs zWebSocketServerFactory.__init__N) rmrnrorpr3rqrr r rrrrrrs  rc@r|)rz Base class for asyncio-based WebSocket client factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory` cOr)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. r+N)rrArr+r rrrrrrrs zWebSocketClientFactory.__init__N)rmrnrorpr3rqrrrrrrrs rc@ru)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrvrrrrr*rwrc@r)rz; asyncio-based WAMP-over-WebSocket server factory. cOB|dd}tj||||j|d<tj|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%r2rrrrrrrAs  z#WampWebSocketServerFactory.__init__N) rmrnrorpr3rqrrr rrrrrr7  rc@ru)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` NrvrrrrrXrwrc@r)rz; asyncio-based WAMP-over-WebSocket client factory. cOr)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 rrrrrrrrros  z#WampWebSocketClientFactory.__init__N) rmrnrorpr3rqrrr rrrrrrerr)!rArr collectionsrtypingrr3 use_asyncio autobahn.utilrrautobahn.asyncio.utilrr autobahn.wampr autobahn.websocketr __all__rProtocolrr r objectr}rrrrrrrrrrs@