8'h+ddlmZddlZddlZ ddlZddlZejddl m Z ddl m Z ddl mZddlmZddlmZddlmZddlmZdd lmZmZmZd Ze Gd d e j:ZGd de j<Ze GddeZ Gdde jBZ"y#e$rddlZYwxYw))absolute_importN)public)protocol)ComponentConfig) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)ApplicationSessionApplicationSessionFactoryApplicationRunnerc2eZdZdZej Zy)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_loggerlogQ/var/www/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/asyncio/wamp.pyr r >s %   Crr c8eZdZdZeZ ejZy)rzJ WAMP application session factory for asyncio-based applications. N) rrrrr sessionrrrrrrrrLs%!G %   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. Nc~t|tjk(sJ|t|tjk(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) typesix text_typedicturlrealmextra serializerssslproxyheaders)selfr#r$r%r&r'r(r)s r__init__zApplicationRunner.__init__fsFCyCMM)*)}U s}} <=<}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/j0|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_runningr/)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:)r')level)'callabler# startswith parse_rs_urlr&r parse_ws_urlrr(r)r setProtocolOptionsr' RuntimeError __class__rr5r6 is_closedset_event_loopnew_event_loophasattrr:r use_asyncioconfigcreate_connectionrun_until_complete start_loggingadd_signal_handlersignalSIGTERMr/r- run_foreverKeyboardInterrupt_sessionleaveclose)r*r; start_loop log_levelr<isSecurehostportr>transport_factoryresourcepathparamsoffersrCr'r:coro transportrs`` rrunzApplicationRunner.runs( D> #F 88  u %#/#9 HdD150@0@))!,dJ!;6j Y ?MSMS 1 U 88 Cxx"NNN++,--((C%%' >>   " "7#9#9#; <))+D(&1)-!&   %%&7t%MK$($;$;D$A !Y   i 0 '' B    "  ''(9(9(?(?(AB JJL#'  %  s$!*J" J1" J.-J.1 J=<J=)NNNNNN)Tinfo) rrrrrrrr+rr/rvrrrrrZs] %   C!.` $ $   rrc*eZdZdZdZdZdZdZy)Sessioncyr@r)r* welcome_msgs r on_welcomezSession.on_welcome$ rcyr@rr*detailss ron_joinzSession.on_join'r}rc$|jyr@) disconnectrs ron_leavezSession.on_leave*s  rcN|j|jjyr@)joinr^r$r.s r on_connectzSession.on_connect-s $++##$rcyr@rr.s r on_disconnectzSession.on_disconnect0r}rN)rrrr|rrrrrrrryry s  % rry)# __future__rrcr r5 ImportErrortrolliusrr] autobahn.utilr autobahn.wamprautobahn.wamp.typesrautobahn.websocket.utilrrUautobahn.rawsocket.utilrTautobahn.asyncio.websocketrautobahn.asyncio.rawsocketr autobahn.websocket.compressr r r __all__r robjectr _SessionShimryrrrrs6'    "/==AA??  44    B B BBBJ h## }sB44 C?C