Lf[,ddlZddlZddlZejddlmZddlmZddlm Z ddl m Z ddl m ZddlmZddlmZddlmZmZmZdd lmZmZd ZeGd d ej6Zej8eej:eGd dej<ZeGddeZ GddejBZ"y)N)public)protocol)ComponentConfig) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)ITransportHandlerISession)ApplicationSessionApplicationSessionFactoryApplicationRunnerc2eZdZdZej Zy)rz WAMP application session for asyncio-based applications. Implements: * ``autobahn.wamp.interfaces.ITransportHandler`` * ``autobahn.wamp.interfaces.ISession`` N)__name__ __module__ __qualname____doc__txaio make_loggerlogP/var/www/cs2snipe.com/venv/lib/python3.12/site-packages/autobahn/asyncio/wamp.pyrr7s %   CrrcDeZdZUdZeZeed< ejZ y)rzJ WAMP application session factory for asyncio-based applications. sessionN) rrrrrr__annotations__rrrrrrrrKs+#5G 4 %   CrrcheZdZdZej Z ddZedZ eddZ y)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. NcVt|tk(sJ|t|tk(sJ|t|tk(sJ|t|tk(sJ|t|tk(sJ||_||_|xs t|_||_||_||_||_ y)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)selfr$r%r&r'r(r)r*s r__init__zApplicationRunner.__init__esFCyC }U s 232}U t 343$w-4"787}U t 343 _df &  rct)zF Stop reconnecting, if auto-reconnecting was enabled. )NotImplementedErrorr+s rstopzApplicationRunner.stops "##rctrfd}n}jjdrDtj\}}}jrjdnd}t ||} nt j\}}}} } } t|jjjj} tg} d}| jddd d d d d ddd| | j|}n<jr$|s"tdjjzj}t!j"}|j%rP|rNt!j&t!j(t!j"}t+| dr|| _t.j0dk(sJ|t.j2_|j5| |||}|s|S|j7|\}}t/j8| |j;t<j>|j@ |jE|jHr)|j7|jHjK|jMy#tB$rYbwxYw#tF$rY`wxYw)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:tjj} |}|S#t$rd}jj dj |tj}|jr|jd}~wwxYw)Nz0ApplicationSession could not be instantiated: {}) rr%r& Exceptionrerrorformatasyncioget_event_loop is_runningr0)cfgreloopmaker+s rcreatez%ApplicationRunner.run..creates%djj$**= #"3iG#N!HHNN#U#\#\]^#_`"113D(  s- BABBrsrN) serializer)r$r'r)r*c:t|tr t|SyN) isinstancer r )responses racceptz%ApplicationRunner.run..acceptsh(AB:8DDCriiFg@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:"?r;r6)r()level)'callabler$ startswith parse_rs_urlr'r parse_ws_urlrr)r*r setProtocolOptionsr( RuntimeError __class__rr6r7 is_closedset_event_loopnew_event_loophasattrr;r_explicit_frameworkconfigcreate_connectionrun_until_complete start_loggingadd_signal_handlersignalSIGTERMr0r. run_foreverKeyboardInterrupt_sessionleaveclose)r+r< start_loop log_levelr=isSecurehostportr?transport_factoryresourcepathparamsoffersrDr(r;coro transportrs`` rrunzApplicationRunner.runs( D> #F 88  t $#/#9 HdD150@0@))!,dJ!;6j Y @MSMS 1 U 88 Cxx"NNN++,--((C%%' >>   " "7#9#9#; <))+D(&1)-!&((I555  %%&7t%MK$($;$;D$A !Y   i 0 '' B    "  ''(9(9(?(?(AB JJL#'  %  s$"*J# J2# J/.J/2 J>=J>)NNNNNN)Tinfo) rrrrrrrr,rr0rwrrrrrYs] %   C!.` $ $  C Crrc*eZdZdZdZdZdZdZy)SessioncyrAr)r+ welcome_msgs r on_welcomezSession.on_welcome( rcyrArr+detailss ron_joinzSession.on_join+r~rc$|jyrA) disconnectrs ron_leavezSession.on_leave.s  rcN|j|jjyrA)joinr_r%r/s r on_connectzSession.on_connect1s $++##$rcyrArr/s r on_disconnectzSession.on_disconnect4r~rN)rrrr}rrrrrrrrzrz$s  % rrz)#r6rdr use_asyncio autobahn.utilr autobahn.wamprautobahn.wamp.typesrautobahn.websocket.utilrrVautobahn.rawsocket.utilrUautobahn.asyncio.websocketrautobahn.asyncio.rawsocketrautobahn.websocket.compressr r r autobahn.wamp.interfacesr r __all__rregister abc_registerrobjectr _SessionShimrzrrrrs6  "/==AA??A  44  -.()  B B FFFT h## r