tf[,ddlZddlZddlZejddlmZddlmZddlm Z ddl m Z ddl m ZddlmZddlmZddlmZmZmZdd lmZmZd ZeGd d ejZejeejeGd dejZeGddeZ Gddej!Z"dS)N)public)protocol)ComponentConfig) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)ITransportHandlerISession)ApplicationSessionApplicationSessionFactoryApplicationRunnerc0eZdZdZejZdS)rz WAMP application session for asyncio-based applications. Implements: * ``autobahn.wamp.interfaces.ITransportHandler`` * ``autobahn.wamp.interfaces.ISession`` N)__name__ __module__ __qualname____doc__txaio make_loggerlogT/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/asyncio/wamp.pyrr7s* %   CCCrrcBeZdZUdZeZeed< ejZ dS)rzJ WAMP application session factory for asyncio-based applications. sessionN) rrrrrr__annotations__rrrrrrrrKsD#5G 444 %   CCCrrcreZdZdZejZ ddZedZ ed dZ 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. Nct|tksJ|t|tksJ|t|tksJ|t|tksJ|t|tksJ||_||_|p t|_||_||_||_||_ 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)selfr$r%r&r'r(r)r*s r__init__zApplicationRunner.__init__esFCyyC}U s 2 2 2 2}U t 3 3 3 3$w--4"7"7"7"7}U t 3 3 3 3 _dff &  rct)zF Stop reconnecting, if auto-reconnecting was enabled. )NotImplementedErrorr+s rstopzApplicationRunner.stops "###rTinfocXtrfd}n}jdr@tj\}}}jr jdnd}t ||} nvt j\}}}} } } t|jjjj } tg} d}| ddd d d d d ddd| | j |}n,j r|stdjjzj }t!j}|rQ|rOt!jt!jt!j}t+| dr|| _t.jdksJ|t.j_|| |||}|s|S||\}}t/j| |t<j|j n#tB$rYnwxYw |"n#tF$rYnwxYw|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. cJtjj} |}|S#t$rn}jd|tj}| r| d}~wwxYw)Nz0ApplicationSession could not be instantiated: {}) rr%r& Exceptionrerrorformatasyncioget_event_loop is_runningr0)cfgreloopmaker+s rcreatez%ApplicationRunner.run..creates%dj$*== #"d3iiG#N!HNN#U#\#\]^#_#_```"133D(($  s * B"A)BB"rsrN) serializer)r$r'r)r*cNt|trt|SdSN) isinstancer r )responses racceptz%ApplicationRunner.run..accepts0h(ABBE:8DDDEEriiFg@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<r7)r()level)'callabler$ startswith parse_rs_urlr'r parse_ws_urlrr)r*r setProtocolOptionsr( RuntimeError __class__rr7r8 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_factoryresourcepathparamsoffersrEr(r<coro transportrs`` rrunzApplicationRunner.runsX( D>>  # # # # # # #F 8  t $ $) U#/#9#9 HdD150@J)!,,dJ!;6j Y Y Y  @MSMS 1 U U U 8 CCx - -"NN+,---(C%'' >>   .  .  "7#9#;#; < < <)++D(&11 .)-!&(I5555  %%&7t%MM K$($;$;D$A$A !Y  i 0 0 0 0 '' BBBB&        """"$      C''(9(?(?(A(ABBB JJLLLLLs$%H-- H:9H:>I I I )NNNNNN)Tr1) rrrrrrrr,rr0rxrrrrrYs %   C!....` $$ V$  CCC VCCCrrc,eZdZdZdZdZdZdZdS)SessioncdSrBr)r+ welcome_msgs r on_welcomezSession.on_welcome( rcdSrBrr+detailss ron_joinzSession.on_join+r~rc.|dSrB) disconnectrs ron_leavezSession.on_leave.s rcD||jjdSrB)joinr`r%r/s r on_connectzSession.on_connect1s $+#$$$$$rcdSrBrr/s r on_disconnectzSession.on_disconnect4r~rN)rrrr}rrrrrrrrzrz$s_      %%%     rrz)#r7rer use_asyncio autobahn.utilr autobahn.wamprautobahn.wamp.typesrautobahn.websocket.utilrrWautobahn.rawsocket.utilrVautobahn.asyncio.websocketrautobahn.asyncio.rawsocketrautobahn.websocket.compressr r r autobahn.wamp.interfacesr r __all__rregister abc_registerrobjectr _SessionShimrzrrrrs6  """"""//////============AAAAAAAAAAAA??????????A@@@@@@@      4   -...()))      B   FFFFFFFFT     h#     r