8'hf/ddlmZddlmZddlZej ddlmZddlm Z m Z ddl m Z ddl mZddlmZ ddlZdd lmZdd lmZeed r ej.Zn eed Zd ZdZGddej6ZeGddeej:ZeGddeej<ZGddeZ eGdde ejBZ!eGdde ejDZ"eGdde jFeZ#eGdde jHe!Z$eGdd e jJeZ%eGd!d"e jLe"Z&y#e$rddlZdd lmZdd lmZY5wxYw)#)absolute_import)dequeN)public)transport_channel_idpeer2str) websocket)protocol)TransportDetails) iscoroutine)Future ensure_futureasync)WebSocketServerProtocolWebSocketClientProtocolWebSocketServerFactoryWebSocketClientFactoryWampWebSocketServerProtocolWampWebSocketClientProtocolWampWebSocketServerFactoryWampWebSocketClientFactoryc<t|txs t|S)z Returns ``True`` iff the value yields. .. seealso:: http://stackoverflow.com/questions/20730248/maybedeferred-analog-with-asyncio ) isinstancer r )values V/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/asyncio/websocket.pyyieldsrDs eV $ : E(::c~eZdZdZdZdZdZdZddZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZy)WebSocketAdapterProtocolzP Adapter class for asyncio-based WebSocket client and server protocols. c||_t|_|j t |j d|_|jy#d|_YxYw)Npeername?) transportr receive_queue_consumerget_extra_infopeer_connectionMade)selfr"s rconnection_madez(WebSocketAdapterProtocol.connection_madeRsT""W   !9!9*!EFDI  DIs A A#cl|j|||jjd|_yN)_connectionLostr"close)r(excs rconnection_lostz(WebSocketAdapterProtocol.connection_lost_s. S! ? NN "rctjjxstjj_fd}j j |y)N)loopctjrMjj}jrj |tjrMj yr+)lenr#popleftr" _dataReceivedr$)_datar(s rprocessz2WebSocketAdapterProtocol._consume..processjsUd(()))113>>&&t,d(() MMOr)r factoryr1txaioconfigwaiteradd_done_callback)r(r8s` rr$z!WebSocketAdapterProtocol._consumegsA$,,"3"3"Hu||7H7HI   %%g.rc|jj||jjs|jj dyyr+)r#appendr<done set_result)r(r7s r data_receivedz&WebSocketAdapterProtocol.data_receivedss= !!$'{{! KK " "4 ("rc|r1t|jdr|jjy|jjy)Nabort)hasattrr"rDr-)r(rDs r_closeConnectionz)WebSocketAdapterProtocol._closeConnectionxs2 WT^^W5 NN " NN "rcR|j}t|r t|yyr+)onOpenrr r(ress r_onOpenz WebSocketAdapterProtocol._onOpen~s!kkm #; #  rcT|j|}t|r t|yyr+)onMessageBeginrr )r(isBinaryrJs r_onMessageBeginz(WebSocketAdapterProtocol._onMessageBegins&!!(+ #; #  rcT|j|}t|r t|yyr+)onMessageFrameBeginrr )r(lengthrJs r_onMessageFrameBeginz-WebSocketAdapterProtocol._onMessageFrameBegins&&&v. #; #  rcT|j|}t|r t|yyr+)onMessageFrameDatarr r(payloadrJs r_onMessageFrameDataz,WebSocketAdapterProtocol._onMessageFrameDatas&%%g. #; #  rcR|j}t|r t|yyr+)onMessageFrameEndrr rIs r_onMessageFrameEndz+WebSocketAdapterProtocol._onMessageFrameEnds$$$& #; #  rcT|j|}t|r t|yyr+)onMessageFramerr rVs r_onMessageFramez(WebSocketAdapterProtocol._onMessageFrames&!!'* #; #  rcR|j}t|r t|yyr+) onMessageEndrr rIs r _onMessageEndz&WebSocketAdapterProtocol._onMessageEnds$! #; #  rcV|j||}t|r t|yyr+) onMessagerr )r(rWrNrJs r _onMessagez#WebSocketAdapterProtocol._onMessages&nnWh/ #; #  rcT|j|}t|r t|yyr+)onPingrr rVs r_onPingz WebSocketAdapterProtocol._onPing$kk'" #; #  rcT|j|}t|r t|yyr+)onPongrr rVs r_onPongz WebSocketAdapterProtocol._onPongrhrcX|j|||}t|r t|yyr+)onCloserr )r(wasCleancodereasonrJs r_onClosez!WebSocketAdapterProtocol._onCloses(ll8T62 #; #  rctd)Nznot implemented Exception)r(producer streamings rregisterProducerz)WebSocketAdapterProtocol.registerProducers)**rcyr+r(s runregisterProducerz+WebSocketAdapterProtocol.unregisterProducers rN)F)__name__ __module__ __qualname____doc__r)r/r$rBrFrKrOrSrXr[r^rardrgrkrqrwr{ryrrrrMsa  /) #            + rrc:eZdZdZej ZddZy)rz Base class for asyncio-based WebSocket server protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` c0t|jd|S)W Implements :func:`autobahn.wamp.interfaces.ITransport.get_channel_id` Trr"r(channel_id_types rget_channel_idz&WebSocketServerProtocol.get_channel_ids$DNND/JJrN tls-unique)r|r}r~rr: make_loggerlogrryrrrrs %   CKrrcLeZdZdZej ZdZdZddZ dZ y)rz Base class for asyncio-based WebSocket client protocols. Implements: * :class:`autobahn.websocket.interfaces.IWebSocketChannel` cT|j|}t|r t|yyr+) onConnectrr )r(responserJs r _onConnectz"WebSocketClientProtocol._onConnects$nnX& #; #  rctd)Nz)WSS over explicit proxies not implementedrsrzs rstartTLSz WebSocketClientProtocol.startTLSsCDDrc0t|jd|S)rFrrs rrz&WebSocketClientProtocol.get_channel_ids$DNNE?KKrc|jjdddu}|rdt|jddi}ni}t|j||S)z] Internal helper. Base class calls this to create a TransportDetails peercertNrF)r& is_securesecure_channel_id)r"r%rr r&)r(rrs r_create_transport_detailsz1WebSocketClientProtocol._create_transport_detailssY NN11*dC4O 3DNNE<X! !# TYY)WhiirNr) r|r}r~rr:rrrrrrryrrrrs0 %   C EL jrrc8eZdZdZej ZdZy)WebSocketAdapterFactoryzP Adapter class for asyncio-based WebSocket client and server factories. c4|j}||_|Sr+)r r9)r(protos r__call__z WebSocketAdapterFactory.__call__s   rN)r|r}r~rr:rrrryrrrrs %   CrrceZdZdZeZdZy)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)popasyncioget_event_loopr1r r__init__r(argskwargsr1s rrzWebSocketServerFactory.__init__sGzz&$'4G224 ''00GGGrN)r|r}r~rrr rryrrrr s'H HrrceZdZdZdZy)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)rrrr1r rrrs rrzWebSocketClientFactory.__init__-sGzz&$'4G224 ''00GGGrN)r|r}r~rrryrrrr#s  HrrceZdZdZy)rz asyncio-based WAMP-over-WebSocket server protocol. Implements: * :class:`autobahn.wamp.interfaces.ITransport` Nr|r}r~rryrrrr<rrceZdZdZeZdZy)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)rrrr _protocolsrr(r9rrrs rrz#WampWebSocketServerFactory.__init__OsTjj5 ,,55dG[Q"oo{ ''>t>v>rN)r|r}r~rrr rryrrrrGs+H?rrceZdZdZy)rz asyncio-based WAMP-over-WebSocket client protocols. Implements: * :class:`autobahn.wamp.interfaces.ITransport` NrryrrrrfrrrceZdZdZeZdZy)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)rrrrrrrs rrz#WampWebSocketClientFactory.__init__ysRjj5 ,,55dG[Q"oo{''>t>v>rN)r|r}r~rrr rryrrrrqs+H?rr)' __future__r collectionsrr: use_asyncio autobahn.utilrautobahn.asyncio.utilrr autobahn.wamprautobahn.websocketr autobahn.websocket.typesr rr r ImportErrortrolliusrEr getattr__all__rProtocolrrrobjectrrrrrrrryrrrs6'  @#'5  # 7O$))MGW-M ;q w//q hK68X8XKK$%j68X8X%j%jP f H4h6U6UHH2H4h6U6UHH0)"G"GI`?!E!EG]??<)"G"GI`?!E!EG]??M  $  sE00F F