o >h[,@sddlZddlZddlZeddlmZddlmZddlm Z ddl m Z ddl m ZddlmZddlmZddlmZmZmZdd lmZmZd ZeGd d d ejZeeeeGd ddejZeGdddeZ Gdddej!Z"dS)N)public)protocol)ComponentConfig) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)ITransportHandlerISession)ApplicationSessionApplicationSessionFactoryApplicationRunnerc@seZdZdZeZdS)r z WAMP application session for asyncio-based applications. Implements: * ``autobahn.wamp.interfaces.ITransportHandler`` * ``autobahn.wamp.interfaces.ISession`` N)__name__ __module__ __qualname____doc__txaio make_loggerlogrru/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/asyncio/wamp.pyr 7s r c@s(eZdZUdZeZeed< eZ dS)rzJ WAMP application session factory for asyncio-based applications. sessionN) rrrrr r__annotations__rrrrrrrrKs   rc@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|tksJ|dust|tksJ|dus t|tks J|dus,t|tks,J|dus8t|tks8J||_||_|pBt|_||_||_||_||_ 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) typestrdicturlrealmextra serializerssslproxyheaders)selfrrr r!r"r#r$rrr__init__es#  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|| _tjdksJ|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:"?r3r.)r")level)'callabler startswith parse_rs_urlr!r parse_ws_urlrr#r$rsetProtocolOptionsr" RuntimeError __class__rr.r/ is_closedset_event_loopnew_event_loophasattrr3r_explicit_frameworkconfigcreate_connectionrun_until_complete start_loggingadd_signal_handlersignalSIGTERMr)r' run_foreverKeyboardInterrupt_sessionleaveclose)r%r5 start_loop log_levelr6isSecurehostportr8transport_factoryresourcepathparamsoffersr<r"r3coro transportrrr4rrunsv          zApplicationRunner.run)NNNNNN)Tr*) rrrrrrrr&rr)rorrrrrYs 0 rc@s4eZdZddZddZddZddZd d Zd S) SessioncCdSr9r)r% welcome_msgrrr on_welcome(zSession.on_welcomecCrqr9rr%detailsrrron_join+rtzSession.on_joincCs |dSr9) disconnectrurrron_leave.s zSession.on_leavecCs||jjdSr9)joinrWrr(rrr on_connect1szSession.on_connectcCrqr9rr(rrr on_disconnect4rtzSession.on_disconnectN)rrrrsrwryr{r|rrrrrp$s  rp)#r.r\r use_asyncio autobahn.utilr autobahn.wamprautobahn.wamp.typesrautobahn.websocket.utilrrNautobahn.rawsocket.utilrMautobahn.asyncio.websocketrautobahn.asyncio.rawsocketrautobahn.websocket.compressrr r autobahn.wamp.interfacesr r __all__r register abc_registerrobjectr _SessionShimrprrrrs.        K