tfՖddlZddlZddlmZddlZddlmZddlmZ ddl mZ ddl m Z mZmZddlmZmZddlmZmZddlmZd Zdd Zdd ZGd d eZGdd eZddZdS)N)partial)ObservableMixin) parse_url)ComponentConfigSubscribeOptionsRegisterOptions)SessionNotReadyApplicationError)create_authenticatorIAuthenticator) SERID_TO_SER Componentc>|r ||n$t|tstdt|trTd|vrtd|ddvr(td|d|D](}|dvr"td|)|ddkrXd D](}||vr"td |)d D](}||vr"td |)dS|dd krXd D](}||vr"td|)dD](}||vr"td|)dSJddS)z9 Check a WAMP connecting endpoint configuration. z'endpoint' must be a dicttypez)'type' required in endpoint configuration)tcpunixzinvalid type "{}" in endpoint)rhostportpathtlstimeoutversionz*Invalid key '{}' in endpoint configurationrrrz&'{}' required in 'tcp' endpoint config)rz''{}' not valid in 'tcp' endpoint configrz('{}' required for 'unix' endpoint config)rrrz('{}' not valid in 'unix' endpoint configFshould not arrive hereN) isinstancedict ValueErrorformatkeys)endpointcheck_native_endpointks V/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/wamp/component.py_validate_endpointr$1sQ h'''' $ ' '  '   (D!!&3  ! !HII I F ? 2 2<CCHVDTUUVV V  AUUU @GGJJV F u $ $%  H$$$@GGJJ%  ==$AHHKK!   f  ' '  H$$$BII!LL%-  ==$BII!LL!   32 2 2 2M&3&3c  t|tkr/tdt|gd}|D](}||vr"td|)d}d|vr;|ddvr(td|d|d}nd|d<d|vr|dkrtd |dd }|h|D](}|d vr"td |)d D](}||vr"td |)t}d|vrL|d}t|ts/tdt||d}|dkr]dD](} | |vr"td| )d|vr$t|d\} } } } }}d| | | d}n|d}t||d|vrtdd|vrt|dttfstdtd|dDstdtj}|dD]F}||vr@td|dd|DG|ddd g}n|d!krd|vr|dd"rt!|d\}} } nF|dd#rt|d\}} } } }}nt#| d$krd$| d%}nd| | d&}n|d}d|vrtd'|td(d|vr;t|dt$t$fstd)|dg}ndg}n Jd+i}d,D]} | |vr || || <t'|f||dd |||||d-|S).a Internal helper to insert defaults and create _Transport instances. :param transport: a (possibly valid) transport configuration :type transport: dict :returns: a _Transport instance :raises: ValueError on invalid configuration zz%_create_transport..s6777q3*--777r%z-Invalid serializer '{}' (expected one of: {})z, c,g|]}t|Sr5)reprr7s r#r:z%_create_transport..s&J&J&J1tAww&J&J&Jr%cborjsonr3rswsr)rr)rrrz5'serializers' is only for websocket; use 'serializer'z/'headers' not supported for rawsocket transportz'serializer' must be a stringFr)r+r,r-r.r/)kindr'r r)r0r*r1)rrrrrgetformaTr parse_ws_urlr$listtupleallr join startswith parse_rs_url RuntimeErrorr6 _Transport)index transportr!valid_transport_keysr"rAr0r*r1key is_securerrresourcerparamsendpoint_configvalid_serializersserialserializer_configisSecurekws r#_create_transportrZjs I$W^^_cdm_n_nooppp ^^   ( ( (8??BB  ) D  V $> > >8?? &@QRRSS S ' &) 3 3 A    MM'4 ( (E   A((( 6==a@@)"  A~~ 077:: ffGII&'4(( 077W FF mmI&&G { L LC)## !>!E!Ec!J!JKKK$ Y & &s #'r%cT|jrdS|jdkrdS|j|jdzkS)NFr\Tra)rdr+rirms r# can_reconnectz_Transport.can_reconnectFs;  " 5  r ! !4$t'7!';;;r%c<|jdkrdS|jdkr"|j|jdzkrtd|j|jz|_t j|j|j|jz|_|j|jkr |j|_|jS)Nrr\razmax reconnects reached) rir+rKrlr.random normalvariater/r,rms r# next_delayz_Transport.next_delayMs  A % %1   # #(=AQTUAU(U(U788 8#/$2IID %3D4DdFVY]YpFpqqD $"666#'#7 # #r%cxt|jtr |jdSt|jS)zF returns a human-readable description of the endpoint r)rr rr<rms r#describe_endpointz_Transport.describe_endpointZs5 dmT * * )=( (DM"""r%)r\r]r^r^r_NNN) __name__ __module__ __qualname____doc__rgrerorqrurwr5r%r#rLrLs  !$%($'$'&&&&P444'''<<< $ $ $#####r%rLcreZdZdZdZ ddZddZ ddZdZdd Z d Z d Z d Z d Z dZdZdZdZdS)rz A WAMP application component. A component holds configuration for (and knows how to create) transports and sessions. NFcPttsJfd}|S)a[ A decorator as a shortcut for subscribing during on-join For example:: @component.subscribe( "some.topic", options=SubscribeOptions(match='prefix'), ) def topic(*args, **kw): print("some.topic({}, {}): event received".format(args, kw)) NcFfd}d|S)Nc6|S)N)topicr* check_types) subscribe)sessiondetailsrfnr*rs r#do_subscriptionz?Component.subscribe..decorator..do_subscriptions!((5'Wb(cccr%rHon)rrrr*rfrs` r# decoratorz&Component.subscribe..decoratorsM d d d d d d d d GGFO , , ,Ir%)rr)rfrr*rrs```` r#rzComponent.subscribersP*W6F"G"G         r%cPttsJfd}|S)aZ A decorator as a shortcut for registering during on-join For example:: @component.register( "com.example.add", options=RegisterOptions(invoke='roundrobin'), ) def add(*args, **kw): print("add({}, {}): event received".format(args, kw)) NcFfd}d|S)Nc6|S)N) procedurer*r)register)rrrrr*uris r#do_registrationz>Component.register..decorator..do_registrations!''c7Xc'dddr%rHr)rrrr*rfrs` r#rz%Component.register..decoratorsM e e e e e e e e GGFO , , ,Ir%)rr)rfrr*rrs```` r#rzComponent.registersO*Wo"F"F         r%realm1c |gd|t|std||_|t|std||_|d}t |t t fr |} d| d} | g}nt |tr|g}g|_t|D]S\} } t| t krd| d} n| } |j t| | |j T|pi|_|r||_||_||_d|_d|_d|_d|_dS) a :param main: After a transport has been connected and a session has been established and joined to a realm, this (async) procedure will be run until it finishes -- which signals that the component has run to completion. In this case, it usually doesn't make sense to use the ``on_*`` kwargs. If you do not pass a main() procedure, the session will not be closed (unless you arrange for .leave() to be called). :type main: callable taking two args ``reactor`` and ``ISession`` :param transports: Transport configurations for creating transports. Each transport can be a WAMP URL, or a dict containing the following configuration keys: - ``type`` (optional): ``websocket`` (default) or ``rawsocket`` - ``url``: the router URL - ``endpoint`` (optional, derived from URL if not provided): - ``type``: "tcp" or "unix" - ``host``, ``port``: only for TCP - ``path``: only for unix - ``timeout``: in seconds - ``tls``: ``True`` or (under Twisted) an ``twisted.internet.ssl.IOpenSSLClientComponentCreator`` instance (such as returned from ``twisted.internet.ssl.optionsForClientTLS``) or ``CertificateOptions`` instance. - ``max_retries``: Maximum number of reconnection attempts. Unlimited if set to -1. - ``initial_retry_delay``: Initial delay for reconnection attempt in seconds (Default: 1.0s). - ``max_retry_delay``: Maximum delay for reconnection attempts in seconds (Default: 60s). - ``retry_delay_growth``: The growth factor applied to the retry delay between reconnection attempts (Default 1.5). - ``retry_delay_jitter``: A 0-argument callable that introduces nose into the delay. (Default random.random) - ``serializer`` (only for raw socket): Specify an accepted serializer (e.g. 'json', 'msgpack', 'cbor', 'ubjson', 'flatbuffers') - ``serializers``: Specify list of accepted serializers - ``options``: tbd - ``proxy``: tbd :type transports: None or str or list :param realm: the realm to join :type realm: str :param authentication: configuration of authenticators :type authentication: dict :param session_factory: if None, ``ApplicationSession`` is used, otherwise a callable taking a single ``config`` argument that is used to create a new `ApplicationSession` instance. :param is_fatal: a callable taking a single argument, an ``Exception`` instance. The callable should return ``True`` if this error is "fatal", meaning we should not try connecting to the current transport again. The default behavior (on None) is to always return ``False`` )startconnectrHreadyleave disconnectconnectfailureNz%"is_fatal" must be a callable or Nonez""main" must be a callable if givenzws://127.0.0.1:8080/wsr2)rr'F)set_valid_eventscallabler _is_fatal_entryrr6r _transports enumeraterappendrZ_check_native_endpoint_authenticationsession_factory_realm_extra_delay_f_done_f_session _stopping) rfmain transportsconfigrealmextraauthenticationris_fatalr'rNrb _transports r#rgzComponent.__init__sr       (:(: DEE E!  HTNN ABB B   1J j3* - - &C$I$JJ D ) ) &$J' 33  NCI#%%'$ '   # #!#z43NOO     .3  3#2D      r%cH|jD]}|rdSdS)NTF)rrq)rfrNs r#_can_reconnectzComponent._can_reconnects9)  I&&(( tt ur%c j5tjfd}tjj||Stj_fd}tjj||t jj dgfd fd fd d}tj| jS) a This starts the Component, which means it will start connecting (and re-connecting) to its configured transports. A Component runs until it is "done", which means one of: - There was a "main" function defined, and it completed successfully; - Something called ``.leave()`` on our session, and we left successfully; - ``.stop()`` was called, and completed successfully; - none of our transports were able to connect successfully (failure); :returns: a Future/Deferred which will resolve (to ``None``) when we are "done" or with an error if something went wrong. Nc2tj|dSN)txaioresolve)argds r#_cbzComponent._start.._cb;s a%%%%%r%cd_|S)z} if the _done_f future is resolved (good or bad), we want to set it to None in our class N)r)rrfs r#_resetz Component._start.._resetEs  DLJr%rcHd_jrtjjddSjdtj|jdtj |tj j|dS)NzInternal error {msg}msg{tb}tb) rrrrrloginfofailure_messagedebugfailure_format_tracebackreject)failrfs r#errorzComponent._start..errorUs DM~ 1  dlD11111 4%:OPT:U:U VVVv%*H*N*NOOO T\400000r%cd_ fdfdfd}fd}tjjd}tj|||dS)Ncjdtj|jdtj|t |jtr4jd|j nt |jtr/j dtj|n |jr9|jj dd\}}}jd | n.jd tj|jd }n|j}|r4j d dtjdddS)Nzcomponent failed: {error})rrrz{msg}rz&Connection failed with OS error: {msg}rzTLS failure: {reason})reasonzConnection failed: {error}Fz"Error was fatal; failing transport)rrrrrrvaluer r error_messageOSErrorr _is_ssl_errorargsrro call_later)rssl_libssl_func ssl_reasonrrftransport_candidatetransport_checks r#handle_connect_errorzGComponent._start..attempt_connect..handle_connect_errores :%BWX\B]B]^^^v%*H*N*NOOOdj*:;;HNN7 0H0H0J0JNKKKK G44HMM"JPUPefjPkPkMllll'' 3359JOA4Fq4I1GXzHNN#::NNNNNHNN4#3D99# >)$HH#~~dj99H4HMM"FGGG'*11333 OT:::r%ctjdj}tj|fdfdS)Nrc.tjSrrr_chain_frs r#zYComponent._start..attempt_connect..notify_connect_error..el7D99r%c.tjSrrrs r#rzYComponent._start..attempt_connect..notify_connect_error..rr%)r create_futurefirer add_callbacks)r handler_frrfs` @r#notify_connect_errorzGComponent._start..attempt_connect..notify_connect_errorsj-// !II&6djII #9999999999 r%cJ|}tj|ddSr)rr)rnotify_frrs r# connect_errorz@Component._start..attempt_connect..connect_errors///55#Hd4HIIIIIr%c<tjjddSr)rrr)xrfs r# session_donez?Component._start..attempt_connect..session_dones dlD11111r%r)rr as_future _connect_oncer) rrr connect_frrlooprfrrs @@r#attempt_connectz)Component._start..attempt_connectbs DM. . . . . . . `      J J J J J J 2 2 2 2 2")!,I   < G G G G Gr%cVjds^d}j| t |#t$r%}t jj|Yd}~dSd}~wwxYw t }| r|d<n*| }j d|j |j |t j|_t jjdS)NzEntering re-connect loopz:Component failed: Exhausted all transport connect attemptsTrzZtrying transport {transport_idx} ("{transport_url}") using connect delay {transport_delay}) transport_idx transport_urltransport_delay)rrrrrKrrrnextrqruwarnrbr'sleeprr) rerr_msgerNdelayrrrfr transport_gens r#rz)Component._start..transport_checksA HNN5 6 6 6&&(( V g&&&&w///#Lq111FFFFF  // **,,-6'*  ((**E HMMl'm'm %    "K..DM    F F F F Fs A B &BB r)rrrr itertoolscyclerr) rfrrrstart_frrrrrrs `` @@@@@@r#_startzComponent._start&sx$ < ##%%A & & & & &   c3 7 7 7H*,,       DL&&999"(899  !c 1 1 1 1 1L HL HL HL HL HL HL HL H\ G G G G G G G G G@))GT400 G_e<<<|r%cfd|_|jr2|jr|jS|jr$t jt j|jSt j|j st j |j dt j dS)NT) rr is_attachedrrrrcancel is_calledrrcreate_future_successrms r#stopzComponent.stops = @T]6688 @=&&(( ( ] @?5<?? ? t|,, . M$, - - -*4000r%c>jdjt jfd}xjdz c_t jj|}fd}t j |d|S)NzWconnecting once using transport type "{transport_type}" over endpoint "{endpoint_desc}")transport_type endpoint_descct j j} |x _} jD]R\}}t|tr| |0t|fi|}| |S |_ fd}| d| fd} j | d| fd}| d||S#t$r/}tj|} tj | d}~wwxYw)Nc.jd|tjsc|jdvrtjddStjt|j|j}tj |dSdS)Nz"session leaving '{details.reason}'r)zwamp.close.normalzwamp.close.goodbye_and_out) rrrrrrcreate_failurer messager)rrfdonerfs r#on_leavezAComponent._connect_once..create_session..on_leave sHMM< '"!?4002">-```!M$55555 % 4 0 Q Q!!A"Lq1111122r%rcxjdz c_jd|t jj}fd}fd}t j|||dS)Nrazsession on_join: {details}r cpjdfd}tjd|dS)N main_successcT dS#t$rYdSwxYwr)rr )rsr#rzeComponent._connect_once..create_session..on_join..main_success..leave's=% ' #2%%%!%%s  ''r)rrrr)rrrfrs r#rzVComponent._connect_once..create_session..on_join..main_success$sK~666%%%%%(E22222r%cjd|tj|dS)Nzmain_error: {err})err)rrrrr)rrrfrs r# main_errorzTComponent._connect_once..create_session..on_join..main_error0sF':DDD T3///**,,,,,r%)rerjrrrrrr) rrrrrrreactorrfrNs ` r#on_joinz@Component._connect_once..create_session..on_joinsOO%%%..!3..HNN#?NQQQ WgFFA 3 3 3 3 3 3-------'<DDDDDr%rHcjd|tjs5|sjddStjddSdS)Nz,session on_disconnect: was_clean={was_clean}) was_cleanzSession disconnected uncleanly)rrrrrr)rrrrfs r# on_disconnectzFComponent._connect_once..create_session..on_disconnect;sHNNF"+#!?4006(6 HMM @ "M$5555566r%r)rrrrrritemsrr add_authenticatorr _parentrr Exceptionrrr)cfgr auth_name auth_config authenticatorrrrrrrrrfrNs r#create_sessionz/Component._connect_once..create_sessions!$+t{;;CZ *.*>*>s*C*CC .2.B.H.H.J.JAA*I{!+~>>A11+>>>>(.on_errorUsO  & &! + & &?4(( ( T3''''' ( (r%) rrrrwrrrir_connect_transportr)rfrrNr'rr)rs``` @r#rzComponent._connect_onces   .$>#5577    "$$\ \ \ \ \ \ \ \ | ""a'"" O  # Y   ( ( ( ( ( ( AtX... r%c2|d|dS)z A decorator as a shortcut for listening for 'join' events. For example:: @component.on_join def joined(session, details): print("Session {} joined: {}".format(session, details)) rHNrrfrs r#rzComponent.on_joines r%c2|d|dS)zM A decorator as a shortcut for listening for 'leave' events. rNrr,s r#rzComponent.on_leaveq r%c2|d|dS)zO A decorator as a shortcut for listening for 'connect' events. rNrr,s r# on_connectzComponent.on_connectws  2r%c2|d|dS)zR A decorator as a shortcut for listening for 'disconnect' events. rNrr,s r#rzComponent.on_disconnect}s  b!!!!!r%c2|d|dS)zM A decorator as a shortcut for listening for 'ready' events. rNrr,s r#on_readyzComponent.on_readyr.r%c2|d|dS)zV A decorator as a shortcut for listening for 'connectfailure' events. rNrr,s r#on_connectfailurezComponent.on_connectfailures  "%%%%%r%)NF)NNNrNNNNr)rxryrzr{rrrrgrrrrrrr0rr3r5r5r%r#rrgs O..W[EI}}}}~llll\111 B     """  &&&&&r%c` t|tr|g}t|tkr/t dt||D]F}t|ts/t dt|Gt j fd fd fd}g}|D]"}||}||#t j |d}r fd} t j || | |S) a Internal helper. Use "run" method from autobahn.twisted.wamp or autobahn.asyncio.wamp This is the generic parts of the run() method so that there's very little code in the twisted/asyncio specific run() methods. This is called by react() (or run_until_complete() so any errors coming out of this should be handled properly. Logging will already be started. zB"components" must be a list of Component objects - encountered {0}zN"components" must be a list of Component objects - encountereditem of type {0}c8d|||S)Nz-Component '{c}' successfully completed: {arg})crr)comprrs r#component_successz_run..component_successs! ATs SSS r%cd|tj|dtj|dS)NzComponent '{c}' error: {msg})r8rzComponent error: {tb}r)rrrrr)r:rrs r#component_failurez_run..component_failuresQ 0De>STU>V>V WWW )e.LQ.O.O PPPtr%ctj|j}tj|t |t ||Sr)rrrrr)r:rr=r;rs r#component_startz_run..component_startsS ODJ 0 0  %t , , %t , ,   r%F)consume_exceptionscJd|dS)Nz&All components ended; stopping reactorr9)r done_callbackrrs r#all_donez_run..all_dones. II> ? ? ? M'3 ' ' ' ' 'r%) rrrrErrr make_loggerrgatherr) r componentsrBr8r?dlr:rdone_drCr=r;rs ` ` @@@r#_runrIs*i((" \  J4 6$z**++   !Y'' ##)6$q''??      C        B OD ! ! ! \" 7 7 7F8 ( ( ( ( ( ( ( FHh777 Mr%r)rrs functoolsrr autobahn.utilrautobahn.websocket.utilrrDautobahn.rawsocket.utilrJautobahn.wamp.typesrrrautobahn.wamp.exceptionr r autobahn.wamp.authr r autobahn.wamp.serializerr __all__r$rZobjectrLrrIr5r%r#rTs8  ))))))============RRRRRRRRRREEEEEEEECCCCCCCC111111 63636363r[[[[|X#X#X#X#X#X#X#X#~f&f&f&f&f&f&f&f&RGGGGGGr%