tf;`ddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z  dZ dd lmZdd lmZmZmZdd lmZdd lmZn #e$rd Z YnwxYwddlZddlmZddlmZddlmZddlmZddl m!Z!m"Z"dZ#dZ$dZ%dZ&dZ'Gddej(Z(d dee(de)de*fdZ+dS)!)wraps)List)IStreamClientEndpoint)UNIXClientEndpoint)TCP4ClientEndpoint)Failure)ReactorNotRunningT)SSL4ClientEndpoint)optionsForClientTLSCertificateOptions Certificate)IOpenSSLClientConnectionCreator)SSLFN)WampWebSocketClientFactory)WampRawSocketClientFactory) component)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/twisted/component.py z _unique_list..Bs, @ @ @!atmmDHHQKKmAmmm)set)seqrs @r _unique_listr$=s( 55D @ @ @ @s @ @ @@r!c|d}|ddd|ddDzS)N_rc3>K|]}|VdSN) capitalize)rss r z._camel_case_from_snake_case..Gs*@@allnn@@@@@@r!)splitjoin)snakepartss r_camel_case_from_snake_caser2EsE KK  E 8bgg@@eABBi@@@@@ @@r!c <|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)typerrr5r7rr6roptionsitemssetProtocolOptions TypeErrorKeyErrorr2 ValueErrorformat)reactor transportsession_factoryr6factoryr9kvs r_create_transport_factoryrIJs~$$29== ,  #/     ; & &01Fq1IJJ ,_TTT 0////!''))1  &G & 0 0!Q 0 0 0 08$    **2155q9x(    8?? PQSTUU   Ns*B))D;CD;DDDctj|rt|}nD|ddkr|dd}|dvr"td||d}t |t kr/tdt ||d }t |tkr/td t ||d d }t |tkr/td t ||dd}|rtstdtj|rt|}n]t|tr| D](} | dvr"td| )|d|} t | t kr"td| d} |dd} | 4tjt!| d} t%| | }n[t|t&r|}nC|durt%|}n/tdt ||dkrt)|||||}n3|dkrtdJd|drL d dl} | ||}n#t0$r#td!|wxYw|dkrt3||||}n|dkr5 d d"lm}n#t0$rtd#wxYw|||||}n^Jd|dd$kr>|d%}t|d d }t9|||}n Jd|S)&zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r;tcpversion)rMz6invalid IP version {} in client endpoint configurationhostz9invalid type {} for host in client endpoint configurationportz9invalid type {} for port in client endpoint configurationtimeout z <v&'tuuu3=cBBq=cBBGGT**q XXZZ[[$>>>",-O-V-VWX-Y-Y"Z"ZZ?"wwz488HH~~,,()l)s)st|)})}~~~!%J!$t!.on_connect_success..lost-s9d4jjt,,-Lt,,, r!)connectionLostr)protorrrs @ron_connect_successz8Component._connect_transport..on_connect_success#sL'D 4[[     [  $(E r!cRxjdz c_tj|dS)Nr-)connect_failuresr}r)errrrDs ron_connect_failurez8Component._connect_transport..on_connect_failure5s/  & &! + & & Ls # # # # #r!N)rIr7rprmconnectr} add_callbacks) rtrCrDrErtransport_factorytransport_endpointdrrs ` ` r_connect_transportzComponent._connect_transport s6gy/ZZ ? Y!;!%OF3%OF3""  "sD ? HMM1 2 2 2 0 0 0 0 0 0{{{(((r!r)) __name__ __module__ __qualname____doc__r} make_loggerrrrErvryrrrr!rrrs| %   CO   .///b))))))r!rinfo components log_level stop_at_closecddlm}|tj|tj|rfd}nd}|t j||fdS)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 :meth:`twisted.internet.reactor.run` -- if you wish to manage the reactor loop yourself, use the :meth:`autobahn.twisted.component.Component.start` method to start each component yourself. :param components: the Component(s) you wish to run :param log_level: a valid log-level (or None to avoid calling start_logging) :param stop_at_close: Flag to control whether to stop the reactor when done. r)reactN)levelct|trTd| d|dS#t $rYdSwxYwdS)Nz#Something went wrong: {log_failure})failurezStopping reactor ..)rarerrorrstopr )rCargrs r done_callbackzrun..done_callbackqs#w''  ? MMMHH2333LLNNNNN(DD   s)A A('A()twisted.internet.taskrr} start_loggingrr_run)rrrrrrs @rrrRs(,+++++  ),,,,    C         E).:}566666r!)rT), functoolsrtypingrtwisted.internet.interfacesrrkrrtwisted.python.failurertwisted.internet.errorr r_r twisted.internet.sslr r r rOpenSSLrrjr}autobahn.twisted.websocketrautobahn.twisted.rawsocketr autobahn.wamprautobahn.twisted.wamprautobahn.wamp.serializerrr__all__r$r2rIrprr]rxrrr!rrs38======999999999999******444444 D======YYYYYYYYYYKKKKKK DDD  AAAAAAAAAAAA######))))))^^^^^^^^ AAAAAA $$$NfffRu)u)u)u)u) #u)u)u)p*7*7DO*7*7T*7*7*7*7*7*7sA AA