U uc.@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)valuer^/var/www/html/CISBACKEND/school/venv/lib/python3.8/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_consumeZ_connectionMade)selfrrrrr Gs z(WebSocketAdapterProtocol.connection_madecCs&|||dk r|jd|_dSN)Z_connectionLostrclose)r$excrrrconnection_lostZs  z(WebSocketAdapterProtocol.connection_lostcs4tjjptjjd_fdd}j|dS)N)loopcs.jr"j}jr|qdSr%)r"popleftrZ _dataReceivedr#)_datar$rrprocesses   z2WebSocketAdapterProtocol._consume..process)rfactoryr)txaioconfigwaiteradd_done_callback)r$r.rr-rr#bs z!WebSocketAdapterProtocol._consumecCs&|j||js"|jddSr%)r"appendr2done set_result)r$r,rrr data_receivedns  z&WebSocketAdapterProtocol.data_receivedFcCs*|rt|jdr|jn |jdS)Nabort)hasattrrr8r&)r$r8rrr_closeConnectionss z)WebSocketAdapterProtocol._closeConnectioncCsD|jjr&dt|j|jjdi}||j_|}t|r@t |dS)Nz tls-unique) r!Z is_securer rr channel_idZonOpenrasyncio ensure_future)r$r;resrrr_onOpenysz WebSocketAdapterProtocol._onOpencCs ||}t|rt|dSr%)ZonMessageBeginrr<r=)r$isBinaryr>rrr_onMessageBegins z(WebSocketAdapterProtocol._onMessageBegincCs ||}t|rt|dSr%)ZonMessageFrameBeginrr<r=)r$lengthr>rrr_onMessageFrameBegins z-WebSocketAdapterProtocol._onMessageFrameBegincCs ||}t|rt|dSr%)ZonMessageFrameDatarr<r=r$payloadr>rrr_onMessageFrameDatas z,WebSocketAdapterProtocol._onMessageFrameDatacCs|}t|rt|dSr%)ZonMessageFrameEndrr<r=r$r>rrr_onMessageFrameEndsz+WebSocketAdapterProtocol._onMessageFrameEndcCs ||}t|rt|dSr%)ZonMessageFramerr<r=rDrrr_onMessageFrames z(WebSocketAdapterProtocol._onMessageFramecCs|}t|rt|dSr%)Z onMessageEndrr<r=rGrrr _onMessageEndsz&WebSocketAdapterProtocol._onMessageEndcCs"|||}t|rt|dSr%)Z onMessagerr<r=)r$rEr@r>rrr _onMessages z#WebSocketAdapterProtocol._onMessagecCs ||}t|rt|dSr%)ZonPingrr<r=rDrrr_onPings z WebSocketAdapterProtocol._onPingcCs ||}t|rt|dSr%)ZonPongrr<r=rDrrr_onPongs z WebSocketAdapterProtocol._onPongcCs$||||}t|r t|dSr%)ZonCloserr<r=)r$ZwasCleancodereasonr>rrr_onClosesz!WebSocketAdapterProtocol._onClosecCs tddS)Nznot implemented Exception)r$ZproducerZ streamingrrrregisterProducersz)WebSocketAdapterProtocol.registerProducercCsdSr%rr-rrrunregisterProducersz+WebSocketAdapterProtocol.unregisterProducer)F)__name__ __module__ __qualname____doc__r0 make_loggerrrrstr__annotations__rboolr r(r#r7r:r?rArCrFrHrIrJrKrLrMrPrSrTrrrrr>s,    rc@seZdZdZeZdS)r z Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` NrUrVrWrXr0rYrrrrrr sr c@s(eZdZdZeZddZddZdS)r z Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` cCs8||}|jjdt|j|dt|r4t|dS)Nz {func}: {res})rr>)Z onConnectrrr _onConnectrr<r=)r$responser>rrrr^s z"WebSocketClientProtocol._onConnectcCs tddS)Nz)WSS over explicit proxies not implementedrQr-rrrstartTLSsz WebSocketClientProtocol.startTLSN) rUrVrWrXr0rYrr^r`rrrrr sr c@s eZdZdZeZddZdS)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. cCs|}||_|Sr%)r r/)r$protorrr__call__sz WebSocketAdapterFactory.__call__N)rUrVrWrXr0rYrrcrrrrrasrac@s$eZdZdZeZeZddZ dS)rz Base class for asyncio-based WebSocket server factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketServerChannelFactory` cOs2|dd}|pt|_tjj|f||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)popr<get_event_loopr)r r__init__r$argskwargsr)rrrrfs zWebSocketServerFactory.__init__N) rUrVrWrXr0rYrr r rfrrrrrsrc@s eZdZdZeZddZdS)rz Base class for asyncio-based WebSocket client factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory` cOs2|dd}|pt|_tjj|f||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. r)N)rdr<rer)r rrfrgrrrrfs zWebSocketClientFactory.__init__N)rUrVrWrXr0rYrrfrrrrrsrc@seZdZdZeZdS)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nr]rrrrr*src@s$eZdZdZeZeZddZ dS)rz; asyncio-based WAMP-over-WebSocket server factory. cOs<|dd}tj||||j|d<tj|f||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)rdr rrf _protocolsrr$r/rhrirjrrrrfAs  z#WampWebSocketServerFactory.__init__N) rUrVrWrXr0rYrrr rfrrrrr7src@seZdZdZeZdS)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nr]rrrrrXsrc@s$eZdZdZeZeZddZ dS)rz; asyncio-based WAMP-over-WebSocket client factory. cOs<|dd}tj||||j|d<tj|f||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` rjNrk)rdr rrfrlrrmrrrrfos  z#WampWebSocketClientFactory.__init__N) rUrVrWrXr0rYrrr rfrrrrresr)!r<rr collectionsrtypingrr0Z use_asyncioZ autobahn.utilrrZautobahn.asyncio.utilrr Z autobahn.wampr Zautobahn.websocketr __all__rProtocolrr r objectrarrrrrrrrrrs>