o @Bi+@sddlmZddlZddlZzddlZWn ey!ddlZYnwddlZeddl m Z ddl m Z ddl mZddlmZddlmZddlmZddlmZdd lmZmZmZd Ze Gd d d e jZGd dde jZe GdddeZ Gddde j!Z"dS))absolute_importN)public)protocol)ComponentConfig) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)ApplicationSessionApplicationSessionFactoryApplicationRunnerc@seZdZdZeZdS)r z WAMP application session for asyncio-based applications. Implements: * :class:`autobahn.wamp.interfaces.ITransportHandler` * :class:`autobahn.wamp.interfaces.ISession` N)__name__ __module__ __qualname____doc__txaio make_loggerlogrrU/var/www/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/asyncio/wamp.pyr >s r c@seZdZdZeZ eZdS)r zJ WAMP application session factory for asyncio-based applications. N) rrrrr sessionrrrrrrrr Ls  r c@sHeZdZdZeZ      d ddZeddZ ed d d Z dS) rz This class is a convenience tool mainly for development and quick hosting of WAMP application components. It can host a WAMP application component in a WAMP-over-WebSocket client connecting to a WAMP router. NcCst|tjks J|dust|tjksJ|dus"t|tks"J|dus.t|tks.J|dus:t|tks:J||_||_|pDt|_||_||_||_ ||_ dS)aU :param url: The WebSocket URL of the WAMP router to connect to (e.g. `ws://somehost.com:8090/somepath`) :type url: str :param realm: The WAMP realm to join the application session to. :type realm: str :param extra: Optional extra configuration to forward to the application component. :type extra: dict :param serializers: A list of WAMP serializers to use (or None for default serializers). Serializers must implement :class:`autobahn.wamp.interfaces.ISerializer`. :type serializers: list :param ssl: An (optional) SSL context instance or a bool. See the documentation for the `loop.create_connection` asyncio method, to which this value is passed as the ``ssl`` keyword parameter. :type ssl: :class:`ssl.SSLContext` or bool :param proxy: Explicit proxy server to use; a dict with ``host`` and ``port`` keys :type proxy: dict or None :param headers: Additional headers to send (only applies to WAMP-over-WebSocket). :type headers: dict N) typesix text_typedicturlrealmextra serializerssslproxyheaders)selfrrrr r!r"r#rrr__init__fs#  zApplicationRunner.__init__cCst)zF Stop reconnecting, if auto-reconnecting was enabled. )NotImplementedErrorr$rrrstopszApplicationRunner.stopTinfocstr fdd}n}jdr-tj\}}}jr$jdnd}t||d} n1tj\}}}} } } t|jjjj d} t g} dd }| j d d d d d ddddd| |d j durf|}nj rs|sst djjj }t}|r|rttt}t| dr|| _t|tj_|j| |||d}|s|S||\}}tj|dz |tj|j Wn t!yYnwz|"Wn t#yYnw|j$r||j$%|&dS)a Run the application component. Under the hood, this runs the event loop (unless `start_loop=False` is passed) so won't return until the program is done. :param make: A factory that produces instances of :class:`autobahn.asyncio.wamp.ApplicationSession` when called with an instance of :class:`autobahn.wamp.types.ComponentConfig`. :type make: callable :param start_loop: When ``True`` (the default) this method start a new asyncio loop. :type start_loop: bool :returns: None is returned, unless you specify `start_loop=False` in which case the coroutine from calling `loop.create_connection()` is returned. This will yield the (transport, protocol) pair. c sbtjj}z|}W|Sty0}zjd|t}| r+| d}~ww)Nz0ApplicationSession could not be instantiated: {}) rrr Exceptionrerrorformatasyncioget_event_loop is_runningr()cfgreloopmaker$rrcreates z%ApplicationRunner.run..creatersrN) serializer)rr r"r#cSst|tr t|SdSN) isinstancer r )responserrraccepts z%ApplicationRunner.run..acceptiiFg@g?Tg$@g@) maxFramePayloadSizemaxMessagePayloadSizeautoFragmentSize failByDropopenHandshakeTimeoutcloseHandshakeTimeout tcpNoDelayautoPingIntervalautoPingTimeout autoPingSizeperMessageCompressionOffersperMessageCompressionAcceptzpssl argument value passed to %s conflicts with the "ws:" prefix of the url argument. Did you mean to use "wss:"?r2)r!)level)'callabler startswith parse_rs_urlr r parse_ws_urlrr"r#r setProtocolOptionsr! RuntimeError __class__rr-r. is_closedset_event_loopnew_event_loophasattrr2r use_asyncioconfigcreate_connectionrun_until_complete start_loggingadd_signal_handlersignalSIGTERMr(r& run_foreverKeyboardInterrupt_sessionleaveclose)r$r4 start_loop log_levelr5isSecurehostportr7transport_factoryresourcepathparamsoffersr;r!r2coro transportrrr3rrunsv          zApplicationRunner.run)NNNNNN)Tr)) rrrrrrrr%rr(rnrrrrrZs 0 rc@s4eZdZddZddZddZddZd d Zd S) SessioncCdSr8r)r$ welcome_msgrrr on_welcome$zSession.on_welcomecCrpr8rr$detailsrrron_join'rszSession.on_joincCs |dSr8) disconnectrtrrron_leave*s zSession.on_leavecCs||jjdSr8)joinrVrr'rrr on_connect-szSession.on_connectcCrpr8rr'rrr on_disconnect0rszSession.on_disconnectN)rrrrrrvrxrzr{rrrrro s  ro)# __future__rr[rr- ImportErrortrolliusrrU autobahn.utilr autobahn.wamprautobahn.wamp.typesrautobahn.websocket.utilrrMautobahn.rawsocket.utilrLautobahn.asyncio.websocketrautobahn.asyncio.rawsocketrautobahn.websocket.compressr r r __all__r r objectr _SessionShimrorrrrs4            F