hSSKrSSKrSSKrSSKJrJrJrJrJr SSK r SSK J r \ R"5 SSK JrJrJr SSKJr SSKJrJr SSKJr SSKJr SS KJr SS KJr SS K J!r! SS K"J#r# SS K$J%r%J&r&J'r' SS K(J)r)J*r* SSK+J,r,J-r-J.r.J/r/ SSK0J1r1 /SQr2\"SS\)Rf55r3\,Rh"\35 \-Rj"\35 "SS\)Rl5r6\"SS\755r8"SS\35r9"SS\75r:"SS\Rv5r<"SS\)Rz5r>"SS \75r?\.Rh"\?5 "S!S"\75r@\.Rh"\@5 g!\a \rGN/f=f)#N)OptionalDictAnyListUnion)WebSocketProtocol)inlineCallbackssucceedDeferred)service) IReactorCoreIStreamClientEndpoint)CertificateOptions)public) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)protocolauth)ITransportHandlerISessionIAuthenticator ISerializer)ComponentConfig)ApplicationSessionApplicationSessionFactoryApplicationRunner ApplicationServiceSessionc:\rSrSrSr\R "5rSrg)rKz WAMP application session for Twisted-based applications. Implements: * :class:`autobahn.wamp.interfaces.ITransportHandler` * :class:`autobahn.wamp.interfaces.ISession` N) __name__ __module__ __qualname____firstlineno____doc__txaio make_loggerlog__static_attributes__r&YC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/twisted/wamp.pyrrKs    Cr0rcL\rSrSr%Sr\r\\S'\R"5r Sr g)r_zB WAMP application session factory for Twisted-based applications. sessionr&N) r'r(r)r*r+rr4__annotations__r,r-r.r/r&r0r1rr_s)#5G 4    Cr0rcr\rSrSrSr\R "5rSS\S\ \S\ \ \\ 4S\ \ \ S\ \S \ \ \\ 4S \ \ \\ 4S \ \ \\ 4S \ \S \ \S\ \S\ \S\ \4Sjjr\S5r\SS\S\S\S\ \S\ \S\\"S5\44 Sjj5rSrg)r lz 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. Nurlrealmextra serializerssslproxyheaderswebsocket_options max_retriesinitial_retry_delaymax_retry_delayretry_delay_growthretry_delay_jittercUb[U5[:XdeXlX lU=(d [5UlX@lXPlX`lXplXl Xl Xl Xl Xl XlSUlSUlg)a :param url: The WebSocket URL of the WAMP router to connect to (e.g. `ws://example.com:8080/mypath`) :param realm: The WAMP realm to join the application session to. :param extra: Optional extra configuration to forward to the application component. :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: (Optional). If specified this should be an instance suitable to pass as ``sslContextFactory`` to :class:`twisted.internet.endpoints.SSL4ClientEndpoint`` such as :class:`twisted.internet.ssl.CertificateOptions`. Leaving it as ``None`` will use the result of calling Twisted :meth:`twisted.internet.ssl.platformTrust` which tries to use your distribution's CA certificates. :param proxy: Explicit proxy server to use; a dict with ``host`` and ``port`` keys. :param headers: Additional headers to send (only applies to WAMP-over-WebSocket). :param websocket_options: Specific WebSocket options to set (only applies to WAMP-over-WebSocket). If not provided, conservative and practical default are chosen. :param max_retries: Maximum number of reconnection attempts. Unlimited if set to -1. :param initial_retry_delay: Initial delay for reconnection attempt in seconds (Default: 1.0s). :param max_retry_delay: Maximum delay for reconnection attempts in seconds (Default: 60s). :param retry_delay_growth: The growth factor applied to the retry delay between reconnection attempts (Default 1.5). :param retry_delay_jitter: A 0-argument callable that introduces noise into the delay (Default ``random.random``). Nr)typedictr8r9r:r;r<r=r>r?r@rArBrCrD_client_service_connect_successes)selfr8r9r:r;r<r=r>r?r@rArBrCrDs r1__init__ApplicationRunner.__init__xs}V e!454 _df &  !2&#6 ."4"4 $"#r0cURRSURRS9 UR(aURR 5$[ S5$)z6 Stop reconnecting, if auto-reconnecting was enabled. z{klass}.stop()klassN)r.debug __class__r'rH stopServicer rJs r1stopApplicationRunner.stopsK 't~~/F/FG   ''335 54= r0 start_reactorauto_reconnect log_levelendpointreactorreturnc ^^^^^#^$^%TRRSTRRS9 T(aDSSKJm [ R"5 T[ Rl [ R"US9 [T5(a UUUU4SjnOTnTRRS5(aD[TR5upn TR(aTRSOSn [!X{S 9n O[#TR5uppp[%UTRTRTR&TR(S 9n [+5/nS n0S [,R._S S_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_S U_S!U_S"S#_S$S%SS&.EnTR0(aUR3TR05 U R4"S>0UD6 SU lU(aUnOSnTR8b6U(d"[;S'TRR-5eTR8nOU(aSS(KJn U"U 5nSSKJm TR&b2SS)K J!n U"TTR&S*TR&S+5nUU l"O,U(aSS,K J#n UceU"TXU5nOSS)K J!n U"TX5nS-m$U$UU4S.jnSnU(aSS/K$J%n SS0K$J&m# SnU(Ga TRRS15 TRPc4TRRc'TRTcTRVc TRXbeTRTS:aQ0m%U4S2jnS3TRR4S4TRT4S5TRV4S6U44HunnUcM UT%U'M U#U%U4S7jnO S8nOT#"5nW"UU US99Tl-TRZR]5 TRZR_5nO,TRRS:5 URaU 5nURcU5 T(a}"U4S;jS<[d5n U "5n!URgU!5 TRi5 TRjRmS=S5n"U!Rn(a U!RneU"(aU"egU$![Na SnGNf=f)?aC Run the application component. :param make: A factory that produces instances of :class:`autobahn.twisted.wamp.ApplicationSession` when called with an instance of :class:`autobahn.wamp.types.ComponentConfig`. :param start_reactor: When ``True`` (the default) this method starts the Twisted reactor and doesn't return until the reactor stops. If there are any problems starting the reactor or connect()-ing, we stop the reactor and raise the exception back to the caller. :param auto_reconnect: :param log_level: :param endpoint: :param reactor: :return: None is returned, unless you specify ``start_reactor=False`` in which case the Deferred that connect() returns is returned; this will callback() with an IProtocol instance, which will actually be an instance of :class:`WampWebSocketClientProtocol` z {klass}.run()rNrrZ)levelc>[TRTRTS9nT"U5nU$![aE TRR S5 T(a!TR (aTR5 ef=f)N)runnerzAApplicationSession could not be instantiated: {log_failure.value})rr9r: Exceptionr.failurerunningrT)cfgr4makerZrJrVs r1create%ApplicationRunner.run..createsg%djj$**TJ#"3iG#N !HH$$%hi$  s ,AA;rsN) serializer)r8r;r=r>cD[U[5(a [U5$gN) isinstancerr)responses r1accept%ApplicationRunner.run..accepts!h(ABB:8DDCr0versionutf8validateIncomingTacceptMaskedServerFramesFmaskClientFrames applyMaskmaxFramePayloadSizeimaxMessagePayloadSizeautoFragmentSizei failByDropechoCloseCodeReasonserverConnectionDropTimeoutg?openHandshakeTimeoutg@closeHandshakeTimeout tcpNoDelayperMessageCompressionOffersperMessageCompressionAcceptautoPingIntervalg$@g@ )autoPingTimeout autoPingSizeautoPingRestartOnAnyTrafficzqssl= argument value passed to %s conflicts with the "ws:" prefix of the url argument. Did you mean to use "wss:"?optionsForClientTLS)TCP4ClientEndpointhostport)SSL4ClientEndpointc([US5(aURbsURR5(aURR5$URR 5(aURR 5$ggg)N_session)hasattrr is_attachedleave is_connected disconnect)protos r1cleanup&ApplicationRunner.run..cleanup[sruj))enn.H>>--// >>//11^^0022 >>44663/I)r0cZ>T=RS- slTRSSTU5 U$)Nbeforeshutdown)rIaddSystemEventTrigger)rrrZrJs r1 init_proto)ApplicationRunner.run..init_protods-  # #q ( #  ) )(J OLr0) ClientService) backoffPolicyzusing t.a.i.ClientServicecj>TRcSO TRn[R"5U-$)Nr)rDrandom)jrJs r1_jitter&ApplicationRunner.run.._jitter|s,!%!8!8!@AdF]F]%}}22r0 initialDelaymaxDelayfactorjitterc>TRS:a.TRS:XdUTR:aT"S0TD6"U5$[S5 TR5 g)Nrzhit stopl@ kr&)rIr@printrT)failed_attemptsrkwargsrJs r1retry$ApplicationRunner.run..retrysU22Q6D\rSrSrSrU4SjrSrg)-ApplicationRunner.run..ErrorCollectoriNcH>URUlTR5 grk)value exceptionrT)rJrbrZs r1__call__6ApplicationRunner.run..ErrorCollector.__call__s%,]]DNLLNr0)r)r'r(r)r*rrr/r]sr1ErrorCollectorrs ##r0rerrorr&)8r.rPrQr'twisted.internetrZr, use_twistedconfigloop start_loggingcallabler8 startswith parse_rs_urlr;r parse_ws_urlrr=r>rrDEFAULT_SPEC_VERSIONr?updatesetProtocolOptionsnoisyr< RuntimeErrortwisted.internet.sslrtwisted.internet.endpointsrcontextFactoryrtwisted.application.internetrr ImportErrorr@rArBrCrDrH startService whenConnectedconnect addCallbackobject addErrbackrunr:getr)&rJrerVrWrXrYrZrfisSecurerrritransport_factoryresourcepathparamsoffersrnprotocol_optionsclientcontext_factoryrrrr use_servicerrkeyvalrdr connect_error app_errorrrrs&``` ` @@@r1rApplicationRunner.runs0 dnn.E.EF  1     'ELL    i 0 D>> # #F 88  t $ $#/#9 HD150@0@))!,dJ!;6 Y (>?  0 0 D3C D#( F#Oxx#&R//011#'((D"5d"; 0zz%I+GTZZ5GTZI[\3B!0I&222+GTQI+GT@  7    $FF"   HHNN6 7  ,0H0H0TX\XlXlXx}A}T}T}`dhd{d{dG''!+F3'5d6N6N%O&0$2F2F%G&.0G0G%H&.%8%:S?*-F3K %:33!&$19JX]#^D  - - /$$224A HHNN2 301A j!   # # +,M LL ' KKM  w5I&&#--- Hm $#  $sR88 SS)rHrIr:r>rAr@rBr=r9rCrDr;r<r8r?) NNNNNNNNNNNN)TFinfoNN)r'r(r)r*r+r,r-r.strrrrrrrintfloatrKrrTboolrr rrFr rr/r&r0r1r r ls    C)-37<@593759?C.28<487;7;>$>$  >$!c3h0>$'tK'89 >$ 12 >$ !c3h0 >$#4S>2>$%-T#s(^$<>$'sm>$'/uo>$#+5/>$&.e_>$&.e_>$@  !  ! KPQU.2AtADAA/78M/NAl+A7 Implements :meth:`autobahn.wamp.interfaces.ISession.onLeave` onleaveN)rrrrJrs r1onLeave_ApplicationSession.onLeaves& hh##I.. s/1c#F# URRS5v g7f)zC Implements :meth:`autobahn.wamp.interfaces.ISession.onDisconnect` ondisconnectN)rrrSs r1 onDisconnect _ApplicationSession.onDisconnects hh##N33s!)rN) r'r(r)r*r+rKr rrrrr/r&r0r1rrs\ %% 0 044r0rc~\rSrSrSr\R "5rS SjrSr S Sjr S Sjr S Sjr S r \S 5rS rg)r!iz A WAMP application. The application object provides a simple way of creating, debugging and running WAMP application components. NcHXl/Ul/Ul0UlSUlg)z :param prefix: The application URI prefix to use for procedures and topics, e.g. ``"com.example.myapp"``. :type prefix: unicode N)_prefixrr_signalsr4)rJprefixs r1rKApplication.__init__s-    r0cXURbe[X5UlUR$)a Factory creating a WAMP application session for the application. :param config: Component configuration. :type config: Instance of :class:`autobahn.wamp.types.ComponentConfig` :returns: obj -- An object that derives of :class:`autobahn.twisted.wamp.ApplicationSession` )r4r)rJrs r1rApplication.__call__s*||#$#*68 ||r0cP[X5nURURU5$)z Run the application. :param url: The URL of the WAMP router to connect to. :type url: unicode :param realm: The realm on the WAMP router to join. :type realm: unicode )r rr)rJr8r9rVr`s r1rApplication.run*s##3.zz$--77r0c^^UU4SjnU$)ab Decorator exposing a function as a remote callable procedure. The first argument of the decorator should be the URI of the procedure to register under. :Example: .. code-block:: python @app.register('com.myapp.add2') def add2(a, b): return a + b Above function can then be called remotely over WAMP using the URI `com.myapp.add2` the function was registered under. If no URI is given, the URI is constructed from the application URI prefix and the Python function name. :Example: .. code-block:: python app = Application('com.myapp') # implicit URI will be 'com.myapp.add2' @app.register() def add2(a, b): return a + b If the function `yields` (is a co-routine), the `@inlineCallbacks` decorator will be applied automatically to it. In that case, if you wish to return something, you should use `returnValue`: :Example: .. code-block:: python from twisted.internet.defer import returnValue @app.register('com.myapp.add2') def add2(a, b): res = yield stuff(a, b) returnValue(res) :param uri: The URI of the procedure to register under. :type uri: unicode c >T(aTnO5TRceSRTRUR5n[R"U5(a [ U5nTR RX45 U$Nz{0}.{1})r formatr'inspectisgeneratorfunctionr rappendfunc_urirJrs r1 decorator'Application.register..decoratorhsi||/0/ '' dmmD**400&t, KK  | ,Kr0r&rJrrs`` r1rApplication.register6sd r0c^^UU4SjnU$)a; Decorator attaching a function as an event handler. The first argument of the decorator should be the URI of the topic to subscribe to. If no URI is given, the URI is constructed from the application URI prefix and the Python function name. If the function yield, it will be assumed that it's an asynchronous process and inlineCallbacks will be applied to it. :Example: .. code-block:: python @app.subscribe('com.myapp.topic1') def onevent1(x, y): print("got event on topic1", x, y) :param uri: The URI of the topic to subscribe to. :type uri: unicode c >T(aTnO5TRceSRTRUR5n[R"U5(a [ U5nTR RX45 U$r)r rr'rrr rrrs r1r(Application.subscribe..decoratorsi||/0/ '' dmmD**400&t, NN ! !4, /Kr0r&r s`` r1rApplication.subscribevs, r0c^^UU4SjnU$)a  Decorator attaching a function as handler for application signals. Signals are local events triggered internally and exposed to the developer to be able to react to the application lifecycle. If the function yield, it will be assumed that it's an asynchronous coroutine and inlineCallbacks will be applied to it. Current signals : - `onjoined`: Triggered after the application session has joined the realm on the router and registered/subscribed all procedures and event handlers that were setup via decorators. - `onleave`: Triggered when the application session leaves the realm. .. code-block:: python @app.signal('onjoined') def _(): # do after the app has join a realm :param name: The name of the signal to watch. :type name: unicode c>[R"U5(a [U5nTRR T/5R U5 U$rk)rrr r  setdefaultr)rnamerJs r1r%Application.signal..decoratorsB**400&t, MM $ $T2 . 5 5d ;Kr0r&)rJr)rs`` r1signalApplication.signals4  r0c/# URRU/5HnU"U0UD6v M g![a%nURR SUS9 SnAM=SnAff=f7f)zo Utility method to call all signal handlers for a given signal. :param name: The signal name. :type name: str z5Warning: exception in signal handler swallowed: {err})errN)r rrar.r)rJr)argsrres r1rApplication._fire_signalsc}}((r2G ^t.v.. 3  ^ U[\ ] ^s* A$ 2A$ A!AA$A!!A$)rr rr r4rk)zws://localhost:8080/wsrealm1T)r'r(r)r*r+r,r-r.rKrrrrr+r rr/r&r0r1r!r!sN    C*  8>@"HB^^r0r!c,\rSrSrSr\rSSjrSrSr g)r"ia A WAMP application as a twisted service. The application object provides a simple way of creating, debugging and running WAMP application components inside a traditional twisted application This manages application lifecycle of the wamp connection using startService and stopService Using services also allows to create integration tests that properly terminates their connections It can host a WAMP application component in a WAMP-over-WebSocket client connecting to a WAMP router. NcXlX lU=(d [5UlX0lXPl[ RRU5 UR5 g)a :param url: The WebSocket URL of the WAMP router to connect to (e.g. `ws://somehost.com:8090/somepath`) :type url: unicode :param realm: The WAMP realm to join the application session to. :type realm: unicode :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 extra: Optional extra configuration to forward to the application component. :type extra: dict :param context_factory: optional, only for secure connections. Passed as contextFactory to the ``listenSSL()`` call; see https://twistedmatrix.com/documents/current/api/twisted.internet.interfaces.IReactorSSL.connectSSL.html :type context_factory: twisted.internet.ssl.ClientContextFactory or None You can replace the attribute factory in order to change connectionLost or connectionFailed behaviour. The factory attribute must return a WampWebSocketClientFactory object N) r8r9rGr:rerr MultiServicerK setupService)rJr8r9rer:rs r1rKService.__init__sF. _df  .%%d+ r0cL^[TR5upp4pVU4SjnTRUTRS9nU(a+SSKJn TR n U cSSKJn U "U5n U "X#XS9n O'TR b [S5eSS KJ n U "X#U5n U RT5 g) z" Setup the application component. cj>[TRTR5nTRU5nU$rk)rr9r:re)rdr4rJs r1rf$Service.setupService..creates)!$**djj9CiinGNr0)r8r) SSLClientNr)rz+context_factory specified on non-secure URI) TCPClient) rr8factoryrr;rrrrar<setServiceParent)rJ is_securerrrrrrfrr;ctxrrr<s` r1r6Service.setupServices9ETXX8N5   !LLTXXL>  >&&C{D)$/t+<QF##/ MNN >t+<=F%r0)rr:rer9r8)NN) r'r(r)r*r+rr=rKr6r/r&r0r1r"r"s )G>&r0r"c2\rSrSrSrSrSrSrSrSr g) r#icgrkr&)rJ welcome_msgs r1 on_welcomeSession.on_welcome  r0cgrkr&rs r1on_joinSession.on_join#rGr0c$UR5 grk)rrs r1on_leaveSession.on_leave&s  r0cNURURR5 grk)rrr9rSs r1 on_connectSession.on_connect)s $++##$r0cgrkr&rSs r1 on_disconnectSession.on_disconnect,rGr0r&N) r'r(r)r*rErIrLrOrRr/r&r0r1r#r#s  % r0r#c \rSrSrSrSrSrg)AuthCryptoSigni1c UR5H7nUS;dM [SRX RR55e SH"nX!;dM [SRU55e UR S[ 55H#nUS;dM [SRU55e SS KJn UR[R"US 55Ul S UR S[ 55;a1USS nX@RR5:wa [S 5eO=UR S[ 55US'URR5USS 'Xlg) N) authextraauthidauthroleprivkeyUnexpected key '{}' for {})rZz Must provide '{}' for cryptosignrW)pubkeychannel_binding trustroot challengez"Unexpected key '{}' in 'authextra'r) CryptosignKeyrZr\z,Public key doesn't correspond to private key)keys ValueErrorrrQr'rrGautobahn.wamp.cryptosignr` from_bytesbinasciia2b_hex_privkey public_key_args)rJkwrr`r\s r1rKAuthCryptoSign.__init__3sW779CHH 077^^=T=TU C} 6==cB 66+tv.CQQ 8??D/ ;%00   R ] +   rvvk462 2 _X.F1133 B4 !ff[$&9B{O(, (@(@(BB{OH % r0cURSRSS5nURRRRUS5nUR R X$US9nU$)NrWr]) channel_idchannel_id_type)rir transporttransport_detailsrmrgsign_challenge)rJr4r_rnrmsigned_challenges r1 on_challengeAuthCryptoSign.on_challengeUsg**[1556GN^^55@@DD_VZ[ ==77 HW8Yr0)rirgNr'r(r)r*rKrsr/r&r0r1rUrU1s  D r0rUc \rSrSrSrSrSrg) AuthWampCraiac UR5H7nUS;dM [SRX RR55e SH"nX!;dM [SRU55e XlUR S5Ul[UR[5(d!URRS5Ulgg)N)rWrXrYsecretr[)ryrXzMust provide '{}' for wampcraryutf8) rarbrrQr'ripop_secretrlrdecode)rJrjrs r1rKAuthWampCra.__init__cs779CGG 077^^=T=TU (C} 3::3?(  vvh' $,,,,<<..v6DL-r0c`URRS5nSUR;a@[R"UURSURSURS5n[R "UURSRS55nUR S5$)Nrzsalt iterationskeylenr_ascii)r|encoder:r derive_key compute_wcsr})rJr4r_r signatures r1rsAuthWampCra.on_challengeusll!!&) Y__ $//' -) C$$  OOK ( / / 7 ((r0)rir|Nrur&r0r1rwrwas 7$)r0rw)Arrertypingrrrrrr,autobahn.websocket.protocolrrtwisted.internet.deferr r r twisted.applicationr twisted.internet.interfacesr rrrr autobahn.utilrautobahn.websocket.utilrrautobahn.rawsocket.utilrautobahn.twisted.websocketrautobahn.twisted.rawsocketrautobahn.websocket.compressrrr autobahn.wamprrautobahn.wamp.interfacesrrrrautobahn.wamp.typesr__all__rr abc_registerrrr rr!r5r" _SessionShimr#rUrwr&r0r1rsx6 33 9EE'K7 !==AA??)]]/  44  -. ()  B B YYYx 34,34lK^&K^\K&g""K&^ h## ** V* Z'")&")J $wsE99FF