tfD>ddlZddlZddlZddlmZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZd Zd Zd Zd ZGd de jZddZdS)N)wraps)WampWebSocketClientFactory)WampRawSocketClientFactory) component) TransportLost)Session)create_transport_serializerscreate_transport_serializer) Componentrunc<tfd|DS)zM Return a list with unique elements from sequence, preserving order. cFg|]}|v||S)add).0xseens Y/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/autobahn/asyncio/component.py z _unique_list..3s, @ @ @!atmmDHHQKKmAmmm)set)seqrs @r _unique_listr.s( 55D @ @ @ @s @ @ @@rc|d}|ddd|ddDzS)N_rc3>K|]}|VdSN) capitalize)rss r z._camel_case_from_snake_case..8s*@@allnn@@@@@@r)splitjoin)snakepartss r_camel_case_from_snake_caser'6sE KK  E 8bgg@@eABBi@@@@@ @@rc <|jdkr-t|}t||j||j}nA|jdkr,t |jd}t||}n Jd|j D]\}} |j d i||i#ttf$r_ |j d it||in>#ttf$r*td|j||wxYwYwxYw|S) z3 Create a WAMP-over-XXX transport factory. websocket)url serializersproxy rawsocketr) serializerFshould not arrive herez"Unknown {} transport option: {}={}r)typer rr*r,r r+roptionsitemssetProtocolOptions TypeErrorKeyErrorr' ValueErrorformat)loop transportsession_factoryr+factoryr.kvs r_create_transport_factoryr>;s~$$29== ,  #/     ; & &01Fq1IJJ ,_TTT 0////!''))1  &G & 0 0!Q 0 0 0 08$    **2155q9x(    8?? PQSTUU   Ns*B))D;CD;DDDcVeZdZdZejZeZ dZ dZ dZ dZ ddZ dS) r z A component establishes a transport and attached a session to a realm using the transport for communication. The transports a component tries to use can be configured, as well as the auto-reconnect strategy. c6t|tjS)z" Internal helper. ) isinstancesslSSLError)selfes r _is_ssl_errorzComponent._is_ssl_errorrs!S\***rct|trWd|vrQ|d}t|ttfrdSt|tjrdSt ddSt d)Ntlsz?'tls' configuration must be a dict, bool or SSLContext instancezI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)rAdictboolrB SSLContextr6)rDendpointrHs r_check_native_endpointz Component._check_native_endpointxs h % %   uocD$<00DS^44D$.!  rc: t|||}|jr|jdd}t |t kr/t dt ||||jd|jd}tj tj ||}| |||S|jdd kr|jd d } | d vr"t d | |jd} t | tkr/t dt | |jd} t | t kr/t dt | |jdd}t |t kr/t dt ||jdd} d} | r9t| tr| D](}|dvr"t d|)| d| }t |tkr"t d|| dd}|} d} |%t#jt"jj|} nUt| t"jr| } n8| dvr| r| } n/t-dt | ||| | | | }tj tj ||}| |||S|jddkr|jd}t |jdd}|||}tj tj ||}| |||SJd )!z? Create and connect a WAMP-over-XXX transport. timeout zr,rLgetr0intr6r7create_connectionasyncio ensure_futurewait_for_wrap_connection_futurestrrArIkeysrBcreate_default_contextPurpose SERVER_AUTHrK RuntimeErrorcreate_unix_connection)rDr8r9r:doner;rOftime_frUrQrRrH tls_hostnamer<rX cert_fnamer^s r_connect_transportzComponent._connect_transports,D)_MM ?W 4(,,Y;;GG}}## !_!f!fgklsgtgt!u!uvvv&&!(_V,_V,'A *7+;Aw+O+O+OPPF// 4HH H   '5 0 0(,,Y::Gf$$ !Y!`!`ah!i!ijjj%f-DDzzS   !\!c!cdhimdndn!o!oppp%f-DDzzS   !\!c!cdhimdndn!o!oppp(,,Y;;GG}}## !_!f!fgklsgtgt!u!uvvv$((55CL qc4((q XXZZ[[$>>>",-O-V-VWX-Y-Y"Z"ZZ?"wwz488HH~~,,()l)s)st|)})}~~~!$t!.on_connect_success..lost sNd4jjt,,-|,-LMMLt,,, r) is_closingrwrxgetattrryrconnection_lostr)resultr9protoreasonr}r|rms @ron_connect_successz=Component._wrap_connection_future..on_connect_successs% Iu##%% t,,>$U,=?Z[[FL}V'<'<===(D 4[[     [ %)E ! ! !rcRxjdz c_tj|dS)Nr")connect_failuresrwry)errrmr9s ron_connect_failurez=Component._wrap_connection_future..on_connect_failures/  & &! + & & Ls # # # # #r)rw add_callbacks)rDr9rmconn_frrs `` rrez!Component._wrap_connection_futuresq& )& )& )& )& )P $ $ $ $ $ $ F$6=== FD*<=== rNc|-|jdtj}||S)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 which will resolve (to ``None``) when we are "done" or with an error if something went wrong. NzUsing default loop)r8)logwarnrbget_event_loop_start)rDr8s rstartzComponent.start$s@ < HMM. / / /)++D{{{%%%rr)__name__ __module__ __qualname____doc__rw make_loggerrrr:rFrMrrrerrrrr r bs %   CO+++ (`4`4`4D333l&&&&&&rr Tinfoc|tj|tjrItjtjtjtj_tj fd  tj fd tj fdn#t$rYnwxYwd}tj|||rA n#tj$rYnwxYwdSdS)a. High-level API to run a series of components. This will only return once all the components have stopped (including, possibly, after all re-connections have failed if you have re-connections enabled). Under the hood, this calls XXX fixme for asyncio -- if you wish to manage the loop yourself, use the :meth:`autobahn.asyncio.component.Component.start` method to start each component yourself. :param components: the Component(s) you wish to run :type components: instance or list of :class:`autobahn.asyncio.component.Component` :param start_loop: When ``True`` (the default) this method start a new asyncio loop. :type start_loop: bool :param log_level: a valid log-level (or None to avoid calling start_logging) :type log_level: string N)levelcKd| tj}n##t$rtj}YnwxYw|D]]} tj}n##t$rtj}YnwxYw||ur|^fd}tj|}||dS)NzShutting down due to {signal})signalc4 |nS#tj$rdYn-t$r!}d|Yd}~nd}~wwxYwdS#wxYw)NzAll task cancelledz&Error while shutting down: {exception}) exception)rrbCancelledErrordebug Exceptionerrorstop)futrErr8s rcancel_all_callbackz5run..nicely_exit..cancel_all_callbackys  ) 0 0 0 .///// Q Q Q Ba PPPPPPPP Q  s6B$A(B A(A#B#A((BB) rrbTask all_tasksAttributeError current_taskcancelgatheradd_done_callback)rtaskstaskrrrrr8s r nicely_exitzrun..nicely_exites 0@@@ (L**,,EE ( ( (%''EEE (  D 6&|88:: ! 6 6 6&355  6<''       ne$ 122222s!;AA#BB"!B"c>tjdS)NSIGINTrbrcrsrzrun..sw7L[[YaMbMb7c7crc>tjdS)NSIGTERMrrsrrzrun..s8MkkZcNdNd8e8erc.|dSr)r)r8args r done_callbackzrun..done_callbacks r)rw start_loggingrbr is_closedset_event_loopnew_event_loopconfigr8radd_signal_handlerrrrNotImplementedErrorr_run run_foreverrclose) components start_loop log_levelrrr8rs @@@rr r 9s8 ),,,,  ! # #D ~~!w577888%''      C333333B   /c/c/c/cddd 0e0e0e0effff      N4]333        %    D  s%%AC,, C98C9D--D?>D?)Tr)rbrBr functoolsrrwautobahn.asyncio.websocketrautobahn.asyncio.rawsocketr autobahn.wamprautobahn.wamp.exceptionrautobahn.asyncio.wamprautobahn.wamp.serializerr r __all__rr'r>r r rrrrsD6  AAAAAAAAAAAA######111111))))))^^^^^^^^ AAAAAA $$$NT&T&T&T&T& #T&T&T&nhhhhhhr