o @Bif/@sddlmZddlmZddlZeddlmZddlm Z m Z ddl m Z ddl mZddlmZzddlZdd lmZdd lmZWney_ddlZdd lmZdd lmZYnweed riejZneed Zd ZddZGdddejZeGdddeejZeGdddeejZGdddeZ eGddde ej!Z!eGddde ej"Z"eGddde j#eZ#eGddde j$e!Z$eGd d!d!e j%eZ%eGd"d#d#e j&e"Z&dS)$)absolute_import)dequeN)public)transport_channel_idpeer2str) websocket)protocol)TransportDetails) iscoroutine)Future ensure_futureasync)WebSocketServerProtocolWebSocketClientProtocolWebSocketServerFactoryWebSocketClientFactoryWampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactorycCst|tpt|S)z Returns ``True`` iff the value yields. .. seealso:: http://stackoverflow.com/questions/20730248/maybedeferred-analog-with-asyncio ) isinstancer r )valuerZ/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/asyncio/websocket.pyyieldsDsrc@seZdZdZddZddZddZdd Zd(d d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'S))WebSocketAdapterProtocolzP Adapter class for asyncio-based WebSocket client and server protocols. cCsF||_t|_|z t|d|_Wnd|_Y|dS)Npeername?) transportr receive_queue_consumerget_extra_infopeer_connectionMade)selfrrrrconnection_madeRs z(WebSocketAdapterProtocol.connection_madecCs&|||dur|jd|_dSN)_connectionLostrclose)r$excrrrconnection_lost_s   z(WebSocketAdapterProtocol.connection_lostcs4tjjptjjd_fdd}j|dS)N)loopcs:tjrj}jr|tjsdSr&)lenrpopleftr _dataReceivedr )_datar$rrprocessjs    z2WebSocketAdapterProtocol._consume..process)r factoryr+txaioconfigwaiteradd_done_callback)r$r2rr1rr gs z!WebSocketAdapterProtocol._consumecCs*|j||js|jddSdSr&)rappendr6done set_result)r$r0rrr data_receivedss  z&WebSocketAdapterProtocol.data_receivedFcCs,|rt|jdr|jdS|jdS)Nabort)hasattrrr<r()r$r<rrr_closeConnectionxsz)WebSocketAdapterProtocol._closeConnectioncC |}t|rt|dSdSr&)onOpenrr r$resrrr_onOpen~ z WebSocketAdapterProtocol._onOpencC"||}t|rt|dSdSr&)onMessageBeginrr )r$isBinaryrBrrr_onMessageBegin  z(WebSocketAdapterProtocol._onMessageBegincCrEr&)onMessageFrameBeginrr )r$lengthrBrrr_onMessageFrameBeginrIz-WebSocketAdapterProtocol._onMessageFrameBegincCrEr&)onMessageFrameDatarr r$payloadrBrrr_onMessageFrameDatarIz,WebSocketAdapterProtocol._onMessageFrameDatacCr?r&)onMessageFrameEndrr rArrr_onMessageFrameEndrDz+WebSocketAdapterProtocol._onMessageFrameEndcCrEr&)onMessageFramerr rNrrr_onMessageFramerIz(WebSocketAdapterProtocol._onMessageFramecCr?r&) onMessageEndrr rArrr _onMessageEndrDz&WebSocketAdapterProtocol._onMessageEndcCs$|||}t|rt|dSdSr&) onMessagerr )r$rOrGrBrrr _onMessages  z#WebSocketAdapterProtocol._onMessagecCrEr&)onPingrr rNrrr_onPingrIz WebSocketAdapterProtocol._onPingcCrEr&)onPongrr rNrrr_onPongrIz WebSocketAdapterProtocol._onPongcCs&||||}t|rt|dSdSr&)onCloserr )r$wasCleancodereasonrBrrr_onCloses z!WebSocketAdapterProtocol._onClosecCtd)Nznot implemented Exception)r$producer streamingrrrregisterProducerz)WebSocketAdapterProtocol.registerProducercCsdSr&rr1rrrunregisterProducersz+WebSocketAdapterProtocol.unregisterProducerN)F)__name__ __module__ __qualname____doc__r%r*r r;r>rCrHrLrPrRrTrVrXrZr\rargrirrrrrMs(   rc@s"eZdZdZeZdddZdS)rz Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` tls-uniquecCt|jd|S)W Implements :func:`autobahn.wamp.interfaces.ITransport.get_channel_id` Trrr$channel_id_typerrrget_channel_idz&WebSocketServerProtocol.get_channel_idNrn)rjrkrlrmr4 make_loggerlogrtrrrrrsrc@s:eZdZdZeZddZddZd ddZ d d Z d S) rz Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` cCrEr&) onConnectrr )r$responserBrrr _onConnectrIz"WebSocketClientProtocol._onConnectcCrb)Nz)WSS over explicit proxies not implementedrcr1rrrstartTLSrhz WebSocketClientProtocol.startTLSrncCro)rpFrqrrrrrrtruz&WebSocketClientProtocol.get_channel_idcCs>|jdddu}|rdt|jddi}ni}t|j||dS)z] Internal helper. Base class calls this to create a TransportDetails peercertNrnF)r" is_securesecure_channel_id)rr!rr r")r$r~rrrr_create_transport_detailss z1WebSocketClientProtocol._create_transport_detailsNrv) rjrkrlrmr4rwrxr{r|rtrrrrrrs  rc@s eZdZdZeZddZdS)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. cCs|}||_|Sr&)rr3)r$protorrr__call__sz WebSocketAdapterFactory.__call__N)rjrkrlrmr4rwrxrrrrrrs rc@eZdZdZeZddZdS)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)popasyncioget_event_loopr+rr__init__r$argskwargsr+rrrrs zWebSocketServerFactory.__init__N)rjrkrlrmrrrrrrrr s rc@seZdZdZddZdS)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)rrrr+rrrrrrrr-s zWebSocketClientFactory.__init__N)rjrkrlrmrrrrrr#s rc@eZdZdZdS)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrjrkrlrmrrrrr<rc@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)rrrr _protocolsrr$r3rrrrrrrOs  z#WampWebSocketServerFactory.__init__N)rjrkrlrmrrrrrrrrG rc@r)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrrrrrrfrrc@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)rrrrrrrrrrrys  z#WampWebSocketClientFactory.__init__N)rjrkrlrmrrrrrrrrqrr)' __future__r collectionsrr4 use_asyncio autobahn.utilrautobahn.asyncio.utilrr autobahn.wamprautobahn.websocketrautobahn.websocket.typesr rr r ImportErrortrolliusr=r getattr__all__rProtocolrrrobjectrrrrrrrrrrrsR             t(