h.ddlZddlmZddlmZddlmZddlmZddlZejddl m Z m Z ddl m Z mZddlmZdd lmZd Zd ZGd d ej*Ze Gddeej.Ze Gddeej0ZGddeZe Gddeej6Ze Gddeej8Ze Gddej:eZe Gddej<eZe Gddej>eZe Gddej@eZ y) N) iscoroutine)Future)deque)Optional)publichltype)create_transport_detailstransport_channel_id) websocket)protocol)WebSocketServerProtocolWebSocketClientProtocolWebSocketServerFactoryWebSocketClientFactoryWampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryc<t|txs t|S)z Returns ``True`` iff the value yields. .. seealso:: http://stackoverflow.com/questions/20730248/maybedeferred-analog-with-asyncio ) isinstancerr)values V/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/asyncio/websocket.pyyieldsr5s eV $ : E(::ceZdZUdZej ZdZee e d<dZ ee e d<dZ dZdZdZdd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZy)WebSocketAdapterProtocolzP Adapter class for asyncio-based WebSocket client and server protocols. Npeer is_servercR|jjdt|j|||_t |j|j |_|jj|_t|_ |j|jy)Nz{func}(transport={transport}))func transport) logdebugrconnection_mader!r r_transport_detailsrr receive_queue_consume_connectionMade)selfr!s rr$z(WebSocketAdapterProtocol.connection_madeGs 6VDDXDX=Y!*  ,##;4>>4>>"Z++00 "W  rcl|j|||jjd|_yN)_connectionLostr!close)r)excs rconnection_lostz(WebSocketAdapterProtocol.connection_lostZs. S! ? NN "rctjjxstjj_fd}j j |y)N)loopcjrDjj}jrj|jrDj yr+)r&popleftr! _dataReceivedr')_datar)s rprocessz2WebSocketAdapterProtocol._consume..processesK$$))113>>&&t,$$ MMOr)rfactoryr1txaioconfigwaiteradd_done_callback)r)r7s` rr'z!WebSocketAdapterProtocol._consumebsA$,,"3"3"Hu||7H7HI   %%g.rc|jj||jjs|jj dyyr+)r&appendr;done set_result)r)r6s r data_receivedz&WebSocketAdapterProtocol.data_receivedns= !!$'{{! KK " "4 ("rc|r1t|jdr|jjy|jjy)Nabort)hasattrr!rCr-)r)rCs r_closeConnectionz)WebSocketAdapterProtocol._closeConnectionss2 WT^^W5 NN " NN "rc|jjr>dt|j|jjdi}||j_|j }t|rtj|yy)Nz tls-unique) r% is_securer r!r channel_idonOpenrasyncio ensure_future)r)rHress r_onOpenz WebSocketAdapterProtocol._onOpenyso  " " , ,24>>4CZCZCdCdfrsJ2s %   CD(3- $Ix~$& /) # '' ' ' ' ' ' ' ' ' ' + rrc2eZdZdZej Zy)r z Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` Nrrrrr9rr"r|rrr r  %   Crr c>eZdZdZej ZdZdZy)rz Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` c|j|}|jjdt|j|t |rt j|yy)Nz {func}: {res})r rL) onConnectr"r#r _onConnectrrJrK)r)responserLs rrz"WebSocketClientProtocol._onConnectsInnX& VDOO-D#N #;  ! !# & rctd)Nz)WSS over explicit proxies not implementedrvr}s rstartTLSz WebSocketClientProtocol.startTLSsCDDrN) rrrrr9rr"rrr|rrrrs$ %   C' Errc8eZdZdZej ZdZy)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. c4|j}||_|Sr+)r r8)r)protos r__call__z WebSocketAdapterFactory.__call__s   rN)rrrrr9rr"rr|rrrrs %   Crrc<eZdZdZej ZeZdZ y)rz Base class for asyncio-based WebSocket server factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketServerChannelFactory` c|jdd}|xstj|_t j j |g|i|y)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__sGzz&$'4G224 ''00GGGrN) rrrrr9rr"r r rr|rrrrs$ %   C&H Hrrc8eZdZdZej ZdZy)rz Base class for asyncio-based WebSocket client factories. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketClientChannelFactory` c|jdd}|xstj|_t j j |g|i|y)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__sGzz&$'4G224 ''00GGGrN)rrrrr9rr"rr|rrrrs %   C Hrrc2eZdZdZej Zy)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrr|rrrr*rrrc<eZdZdZej ZeZdZ y)rz; asyncio-based WAMP-over-WebSocket server factory. c|jdd}tjj||||j|d<t j|g|i|y)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__AsTjj5 ,,55dG[Q"oo{ ''>t>v>rN) rrrrr9rr"rr rr|rrrr7s# %   C*H?rrc2eZdZdZej Zy)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nrr|rrrrXrrrc<eZdZdZej ZeZdZ y)rz; asyncio-based WAMP-over-WebSocket client factory. c|jdd}tjj||||j|d<t j|g|i|y)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__osRjj5 ,,55dG[Q"oo{''>t>v>rN) rrrrr9rr"rr rr|rrrres# %   C*H?rr)!rJrr collectionsrtypingrr9 use_asyncio autobahn.utilrrautobahn.asyncio.utilr r autobahn.wampr autobahn.websocketr __all__rProtocolrr robjectrrrrrrrr|rrrs6 (P#' ;C w//C L 68X8X  E68X8XEE* f H4h6U6UHH6H4h6U6UHH4 )"G"GI`  ?!E!EG]??@ )"G"GI`  ?!E!EG]??r