o i.@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 N) isinstancerr)valuer`C:\Users\psant\Downloads\PAF backend\school\venv\Lib\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&|||dur|jd|_dSN)Z_connectionLostrclose)r$excrrrconnection_lostZs   z(WebSocketAdapterProtocol.connection_lostcs4tjjptjjd_fdd}j|dS)N)loopcs2jrj}jr|jsdSr%)r"popleftrZ _dataReceivedr#)_datar$rrprocesses    z2WebSocketAdapterProtocol._consume..process)rfactoryr)txaioconfigwaiteradd_done_callback)r$r.rr-rr#bs z!WebSocketAdapterProtocol._consumecCs*|j||js|jddSdSr%)r"appendr2done set_result)r$r,rrr data_receivedns  z&WebSocketAdapterProtocol.data_receivedFcCs,|rt|jdr|jdS|jdS)Nabort)hasattrrr8r&)r$r8rrr_closeConnectionssz)WebSocketAdapterProtocol._closeConnectioncCsH|jjrdt|j|jjdi}||j_|}t|r"t |dSdS)Nz tls-unique) r!Z is_securer rr channel_idZonOpenrasyncio ensure_future)r$r;resrrr_onOpenysz WebSocketAdapterProtocol._onOpencC$||}t|rt|dSdSr%)ZonMessageBeginrr<r=)r$isBinaryr>rrr_onMessageBegin z(WebSocketAdapterProtocol._onMessageBegincCr@r%)ZonMessageFrameBeginrr<r=)r$lengthr>rrr_onMessageFrameBeginrCz-WebSocketAdapterProtocol._onMessageFrameBegincCr@r%)ZonMessageFrameDatarr<r=r$payloadr>rrr_onMessageFrameDatarCz,WebSocketAdapterProtocol._onMessageFrameDatacC"|}t|rt|dSdSr%)ZonMessageFrameEndrr<r=r$r>rrr_onMessageFrameEndz+WebSocketAdapterProtocol._onMessageFrameEndcCr@r%)ZonMessageFramerr<r=rFrrr_onMessageFramerCz(WebSocketAdapterProtocol._onMessageFramecCrIr%)Z onMessageEndrr<r=rJrrr _onMessageEndrLz&WebSocketAdapterProtocol._onMessageEndcCs&|||}t|rt|dSdSr%)Z onMessagerr<r=)r$rGrAr>rrr _onMessages z#WebSocketAdapterProtocol._onMessagecCr@r%)ZonPingrr<r=rFrrr_onPingrCz WebSocketAdapterProtocol._onPingcCr@r%)ZonPongrr<r=rFrrr_onPongrCz WebSocketAdapterProtocol._onPongcCs(||||}t|rt|dSdSr%)ZonCloserr<r=)r$ZwasCleancodereasonr>rrr_onClosesz!WebSocketAdapterProtocol._onClosecCtd)Nznot implemented Exception)r$ZproducerZ streamingrrrregisterProducerz)WebSocketAdapterProtocol.registerProducercCsdSr%rr-rrrunregisterProducersz+WebSocketAdapterProtocol.unregisterProducer)F)__name__ __module__ __qualname____doc__r0 make_loggerrrrstr__annotations__rboolr r(r#r7r:r?rBrErHrKrMrNrOrPrQrTrXrZrrrrr>s.    rc@eZdZdZeZdS)r z Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` Nr[r\r]r^r0r_rrrrrr  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})rr>)Z onConnectrrr _onConnectrr<r=)r$responser>rrrrfs z"WebSocketClientProtocol._onConnectcCrU)Nz)WSS over explicit proxies not implementedrVr-rrrstartTLSrYz WebSocketClientProtocol.startTLSN) r[r\r]r^r0r_rrfrhrrrrr s  r c@ eZdZdZeZddZdS)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. cCs|}||_|Sr%)r r/)r$protorrr__call__sz WebSocketAdapterFactory.__call__N)r[r\r]r^r0r_rrlrrrrrjs rjc@$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)popr<get_event_loopr)r r__init__r$argskwargsr)rrrrqs zWebSocketServerFactory.__init__N) r[r\r]r^r0r_rr r rqrrrrrs  rc@ri)rz Base class for asyncio-based WebSocket client factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory` cOrn)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)ror<rpr)r rrqrrrrrrqs zWebSocketClientFactory.__init__N)r[r\r]r^r0r_rrqrrrrrs rc@rc)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrdrrrrr*rerc@rm)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)ror rrq _protocolsrr$r/rsrtrvrrrrqAs  z#WampWebSocketServerFactory.__init__N) r[r\r]r^r0r_rrr rqrrrrr7  rc@rc)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` NrdrrrrrXrerc@rm)rz; asyncio-based WAMP-over-WebSocket client factory. cOru)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` rvNrw)ror rrqrxrryrrrrqos  z#WampWebSocketClientFactory.__init__N) r[r\r]r^r0r_rrr rqrrrrrerzr)!r<rr collectionsrtypingrr0Z use_asyncioZ autobahn.utilrrZautobahn.asyncio.utilrr Z autobahn.wampr Zautobahn.websocketr __all__rProtocolrr r objectrjrrrrrrrrrrs@