afddlZddlZddlZddlmZmZmZmZmZddl Z ddl m Z e j ddl mZmZmZddlmZddlmZmZ ddlmZn #e$reZYnwxYwddlmZdd lmZdd lmZdd l m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1gdZ2eGdde)j3Z3e,j4e3e-j5e3Gdde)j6Z6eGdde7Z8Gdde3Z9Gdde7Z:Gddej;Z<Gdde)j=Z>Gdd e7Z?e.j4e?Gd!d"e7Z@e.j4e@dS)#N)OptionalDictAnyListUnion)WebSocketProtocol)inlineCallbackssucceedDeferred)service) IReactorCoreIStreamClientEndpoint)CertificateOptions)public) parse_url)WampWebSocketClientFactory)WampRawSocketClientFactory)PerMessageDeflateOfferPerMessageDeflateResponsePerMessageDeflateResponseAccept)protocolauth)ITransportHandlerISessionIAuthenticator ISerializer)ComponentConfig)ApplicationSessionApplicationSessionFactoryApplicationRunner ApplicationServiceSessionc0eZdZdZejZdS)rz WAMP application session for Twisted-based applications. Implements: * :class:`autobahn.wamp.interfaces.ITransportHandler` * :class:`autobahn.wamp.interfaces.ISession` N)__name__ __module__ __qualname____doc__txaio make_loggerlogG/var/www/html/env/lib/python3.11/site-packages/autobahn/twisted/wamp.pyrrKs* %   CCCr-rcBeZdZUdZeZeed< ejZ dS)rzJ WAMP application session factory for Twisted-based applications. sessionN) r%r&r'r(rr0__annotations__r)r*r+r,r-r.rr_sD#5G 444 %   CCCr-rceZdZdZejZ ddedeedee ee fdee e dee dee ee fd ee ee fd ee ee fd eed eed eedeedeefdZedZe ddedededeedeedeedeff dZdS)r z 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_jitterc,|t|tksJ||_||_|p t|_||_||_||_||_||_ | |_ | |_ | |_ | |_ | |_d|_d|_dS)af :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)typedictr3r4r5r6r7r8r9r:r;r<r=r>r?_client_service_connect_successes)selfr3r4r5r6r7r8r9r:r;r<r=r>r?s r.__init__zApplicationRunner.__init__xsV e!4!4!44 _dff &  !2&#6 ."4"4 $"#r-c|jd|jj|jr|jSt dS)zF Stop reconnecting, if auto-reconnecting was enabled. z{klass}.stop()klassN)r+debug __class__r%rC stopServicer rEs r.stopzApplicationRunner.stopsN 't~/FGGG   !'3355 54== r-TFinfo start_reactorauto_reconnect log_levelendpointreactorreturncV#$%jdjjr?ddlmt jt j_ t j |tr fd}n}j dr@tj \}} } jr jdnd} t!|| } nt#j \}} } } }}t%|j jjj } t+g}d }id t,jd dddddddddddddddddddddddddd |d!|d"d#d$d%dd&}jr|j| jd>i|d| _|r|}nd}j&|st;d'jjzj}n|rdd(lm}|| }ddlmj1dd)l m!}|jd*jd+}|| _"n.|rdd,l m#}|J|| | |}ndd)l m!}|| | }d-$$fd.}d}|r" dd/l$m%}dd0l$m&#d}n#tN$rd}YnwxYw|rՉjd1j(j)j*j+j,Hj*dkr9i%fd2}d3j)fd4j*fd5j+fd6|ffD] \}}||%|< #%fd7}nd8}n #}||| |9_-j-.j-/}n/jd:|0| }|1|rwGfd;d.creates%dj$*TJJJ#"d3iiG#N !H$$%hiii$''  s ,AA/rsN) serializer)r3r6r8r9cNt|trt|SdSN) isinstancerr)responses r.acceptz%ApplicationRunner.run..accepts0h(ABBE:8DDDEEr-versionutf8validateIncomingTacceptMaskedServerFramesFmaskClientFrames 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)SSL4ClientEndpointct|drk|jf|jr|jS|jr|jSdSdSdS)N_session)hasattrr is_attachedleave is_connected disconnect)protos r.cleanupz&ApplicationRunner.run..cleanup[suj)) 7en.H>--//7 >//111^00227 >44666  7 7.H.H77r-cXxjdz c_dd||S)Nbeforeshutdown)rDaddSystemEventTrigger)rrrTrEs r. init_protoz)ApplicationRunner.run..init_protods6  # #q ( # #  ) )(J O O OLr-) ClientService) backoffPolicyzusing t.a.i.ClientServicecPjdnj}tj|zS)Nr)r?random)jrEs r._jitterz&ApplicationRunner.run.._jitter|s(!%!8!@AAdF]%}22r- initialDelaymaxDelayfactorjittercjdkr'jdks |jkrdi|StddS)Nrzhit stopl@ kr,)rDr;printrN)failed_attemptsrkwargsrEs r.retryz$ApplicationRunner.run..retrysn2Q66D.retrys qr-) retryPolicyzusing t.i.e.connect()ceZdZdZfdZdS)-ApplicationRunner.run..ErrorCollectorNcH|j|_dSrd)value exceptionrN)rEr\rTs r.__call__z6ApplicationRunner.run..ErrorCollector.__call__s%,]DNLLNNNNNr-)r%r&r'rrrWsr.ErrorCollectorrs3 #######r-rerrorr,)8r+rJrKr%twisted.internetrTr) use_twistedconfigloop start_loggingcallabler3 startswith parse_rs_urlr6r parse_ws_urlrr8r9rrDEFAULT_SPEC_VERSIONr:updatesetProtocolOptionsnoisyr7 RuntimeErrortwisted.internet.sslr~twisted.internet.endpointsrcontextFactoryrtwisted.application.internetrr ImportErrorr;r<r=r>r?rC startService whenConnectedconnect addCallbackobject addErrbackrunr5getr)&rEr_rPrQrRrSrTr`isSecurerrrbtransport_factoryresourcepathparamsoffersrgprotocol_optionsclientcontext_factoryr~rrr use_servicerrkeyvalrdr connect_error app_errorrrrs&``` ` @@@r.rzApplicationRunner.runs 0 dn.EFFF  1 1 0 0 0 0 0      'EL   i 0 0 0 0 D>>  # # # # # # # # #F 8  t $ $> E#/#9#9 HdD150@J)!,,dJ!;6j Y Y Y  ??? 1  0 D D3C D D D#(  AFF#Ox#1&R/0111#'( <DDDDDD"5"5d";"; 0 0 0 0 0 0z%IIIIII++GTZ5GTZI[\\3B!00 AIIIIII&222++GT4QQIIIIII++GT4@@  7 7 7          $ $FFFFFFFFFFFF"  $ $ $#  $ . 2 HNN6 7 7 7 ,0H0TX\XlXx}A}T}`dhd{dG'!++F33333'5d6N%O&0$2F%G&.0G%H&.%8%:..S?*-F3K33333333!!!!& $1=9JX]#^#^#^D  - - / / /$2244AA HNN2 3 3 3011A j!!!    # # # # # # # # # # +N,,M LL ' ' ' KKMMM  w55I& #--   Hs4J JJ) NNNNNNNNNNNN)TFrONN)r%r&r'r(r)r*r+strrrrrrrintfloatrFrrNboolrr rrAr rr,r-r.r r ls %   C)-37<@593759?C.28<487;7;>$>$>$  >$!c3h0>$'tK'89 >$ 12 >$ !c3h0 >$#4S>2>$%-T#s(^$<>$'sm>$'/uo>$#+5/>$&.e_>$&.e_>$>$>$>$@  ! ! V ! KPQU.2AAtADAA/78M/NAl+A7.decoratorhsy E|/// '' dmDD*400 -&t,, K  d| , , ,Kr-r,rErr s`` r.rzApplication.register6s+d      r-cfd}|S)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 cr}n)jJdj|j}tj|rt |}j||f|Sr)rrr%rrr rrrs r.r z(Application.subscribe..decoratorsy E|/// '' dmDD*400 -&t,, N ! !4, / / /Kr-r,r s`` r.rzApplication.subscribevs*,      r-cfd}|S)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 ctj|rt|}jg||Srd)rrr r setdefaultr)rnamerEs r.r z%Application.signal..decoratorsN*400 -&t,, M $ $T2 . . 5 5d ; ; ;Kr-r,)rErr s`` r.signalzApplication.signals*4       r-c/K|j|gD]@} ||i|V#t$r&}|jd|Yd}~9d}~wwxYwdS)z 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)rrr[r+rO)rErargsrres r.rzApplication._fire_signals}((r22 ^ ^G ^gt.v...... ^ ^ ^ U[\ ]]]]]]]] ^  ^ ^s , AAArd)rrT)r%r&r'r(r)r*r+rFrrrrrr rr,r-r.r!r!s %   C*    8 8 8 8>>>>@""""HB^^_^^^r-r!c$eZdZdZeZddZdZdS)r"a 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. Nc||_||_|p t|_||_||_t j|| dS)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) r3r4rBr5r_rr MultiServicerF setupService)rEr3r4r_r5rs r.rFzService.__init__s_. _dff  .%%d+++ r-c`tj\}}}}}}fd}|j}|r0ddlm} j} | ddlm} | |} | |||| } n)jtddd lm } | |||} | dS) z2 Setup the application component. cftjj}|}|Srd)rr4r5r_)r^r0rEs r.r`z$Service.setupService..creates*!$*dj99CiinnGNr-)r3r) SSLClientNr})rz+context_factory specified on non-secure URI) TCPClient) rr3factoryrrrrr~r[rsetServiceParent)rE is_securerrrrrr`rrctxr~rrs` r.rzService.setupServices9ETX8N8N5 4xv      !LLTXL>>  > > > > > > >&C{DDDDDD))$//YtT+ > > > > >YtT+<==F%%%%%r-)NN)r%r&r'r(rrrFrr,r-r.r"r"sH  )G>&&&&&r-r"c,eZdZdZdZdZdZdZdS)r#cdSrdr,)rE welcome_msgs r. on_welcomezSession.on_welcome  r-cdSrdr,rs r.on_joinzSession.on_join#r&r-c.|dSrd)rrs r.on_leavezSession.on_leave&s r-cD||jjdSrd)rrr4rMs r. on_connectzSession.on_connect)s $+#$$$$$r-cdSrdr,rMs r. on_disconnectzSession.on_disconnect,r&r-N)r%r&r'r%r(r*r,r.r,r-r.r#r#s_      %%%     r-r#ceZdZdZdZdS)AuthCryptoSignc L|D]3}|dvr-td||jj4dD](}||vr"td|)|dt D](}|dvr"td|)dd lm}| tj |d |_ d |dt vr;|dd }||j krtd nG|dt |d<|j |dd <||_dS) N) authextraauthidauthroleprivkeyUnexpected key '{}' for {})r5z Must provide '{}' for cryptosignr2)pubkeychannel_binding trustroot challengez"Unexpected key '{}' in 'authextra'r) CryptosignKeyr5r7z,Public key doesn't correspond to private key)keys ValueErrorrrKr%rrBautobahn.wamp.cryptosignr; from_bytesbinasciia2b_hex_privkey public_key_args)rEkwrr;r7s r.rFzAuthCryptoSign.__init__3s7799  CHHH 077T^=TUUI  C"}} 6==cBB66+tvv..  CQQQ 8??DDR ;:::::%00  R ] + +    rvvk46622 2 2 _X.F113333 B4 !ff[$&&99B{O(, (@(@(B(BB{OH % r-c|jddd}|jjj|d}|j|||}|S)Nr2r8) channel_idchannel_id_type)rDr transporttransport_detailsrGrBsign_challenge)rEr0r:rHrGsigned_challenges r. on_challengezAuthCryptoSign.on_challengeUsi*[1556GNN^5@DD_VZ[[ =77 jHW8YYr-Nr%r&r'rFrMr,r-r.r0r01s3   D     r-r0ceZdZdZdZdS) AuthWampCrac |D]3}|dvr-td||jj4dD](}||vr"td|)||_|d|_t|jts!|j d|_dSdS)N)r2r3r4secretr6)rRr3zMust provide '{}' for wampcrarRutf8) r<r=rrKr%rDpop_secretrerdecode)rErErs r.rFzAuthWampCra.__init__cs7799  CGGG 077T^=TUUH(  C"}} 3::3??  vvh'' $,,, 7<..v66DLLL 7 7r-cH|jd}d|jvr8tj||jd|jd|jd}tj||jdd}|dS)NrSsalt iterationskeylenr:ascii)rUencoder5r derive_key compute_wcsrV)rEr0r:r signatures r.rMzAuthWampCra.on_challengeusl!!&)) Y_ $ $/' -) C$  OK ( / / 7 7  (((r-NrNr,r-r.rPrPas2777$)))))r-rP)Arr@rtypingrrrrrr)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!rr" _SessionShimr#r0rPr,r-r.rqs6 33333333333333 999999EEEEEEEEEE''''''KKKKKKKK7777777! ============AAAAAAAAAAAA??????????)(((((((]]]]]]]]]]]]//////        4   -...()))      B   YYYYYYYYx 3434343434,343434lK^K^K^K^K^&K^K^K^\K&K&K&K&K&g"K&K&K&^     h#   ** * * * * V* * * Z'''")")")")")&")")")J $$$$$s AAA