h;ZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z  dZ dd lmZdd lmZmZmZdd lmZdd lmZddlZddlmZddlmZddlmZddlmZddl m!Z!m"Z"dZ#dZ$dZ%dZ&dZ'GddejPZ(ddee(de)de*fdZ+y#e$rd Z Y_wxYw) )wraps)List)IStreamClientEndpoint)UNIXClientEndpoint)TCP4ClientEndpoint)Failure)ReactorNotRunningT)SSL4ClientEndpoint)optionsForClientTLSCertificateOptions Certificate)IOpenSSLClientConnectionCreator)SSLFN)WampWebSocketClientFactory)WampRawSocketClientFactory) component)Session)create_transport_serializerscreate_transport_serializer) Componentruncnt}|Dcgc]}||vs|j|r|c}Scc}w)zM Return a list with unique elements from sequence, preserving order. )setadd)seqseenxs V/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/twisted/component.py _unique_listr=s/ 5D @!atmDHHQKA @@ @s 222cf|jd}|ddjd|ddDzS)N_rc3<K|]}|jywN) capitalize).0ss r z._camel_case_from_snake_case..Gs@alln@s)splitjoin)snakepartss r_camel_case_from_snake_caser.Es4 KK E 8bgg@eABi@@ @@c B|jdk(r/t|}t||j||j}n<|jdk(r&t |j d}t||}nJd|jjD]\}} |jdi||i|S#ttf$r[ |jdit||in9#ttf$r'tdj|j||wxYwYwxYw) z3 Create a WAMP-over-XXX transport factory. websocket)url serializersproxy rawsocketr) serializershould not arrive herez"Unknown {} transport option: {}={})typerrr2r4rr3roptionsitemssetProtocolOptions TypeErrorKeyErrorr. ValueErrorformat)reactor transportsession_factoryr3factoryr6kvs r_create_transport_factoryrGJs3~~$29= ,  #//   ; &01F1Fq1IJ ,_T 0//u!!'')1  &G & & 0!Q 0* N8$  ***215q9x(  8?? PQSTU  s*B44DC"!D"6DDDctj|r t|}|S|ddk(r|jdd}|dvrtdj ||d}t |t k7r#tdj t ||d }t |tk7r#td j t ||jd d }t |tk7r#td j t ||jdd}|ryts tdtj|r t|}nt|tr|jD] } | dvstdj | |jd|} t | t k7rtdj | d} |jdd} | -tjt!| dj#} t%| | }nFt|t&r|}n3|dur t%|}n#tdj t ||dk(rt)|||||}|S|dk(r tdJd|j+dr ddl} | j/||}|S|dk(rt3||||}|S|dk(r dd!lm}|||||}|SJd|dd#k(r0|d$}t|jd d }t9|||}|SJd#t0$rtd j |wxYw#t0$r td"wxYw)%zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r9tcpversion)rKz6invalid IP version {} in client endpoint configurationhostz9invalid type {} for host in client endpoint configurationportz9invalid type {} for port in client endpoint configurationtimeout z>",-O-V-VWX-Y"ZZ( #wwz48HH~,()l)s)st|)}~~!%J!$t!.on_connect_success..lost-s+4jt,LLt, r/)connectionLostr)protorrrs @ron_connect_successz8Component._connect_transport..on_connect_success#s0''D 4[   $(E r/c\xjdz c_tj|y)Nr))connect_failuresr{r})errrrBs ron_connect_failurez8Component._connect_transport..on_connect_failure5s"  & &! + & LLs #r/N)rGr4rnrkconnectr{ add_callbacks) rrrArBrCrtransport_factorytransport_endpointdrrs ` ` r_connect_transportzComponent._connect_transport s6gy/Z ??!;!%OOF3%OOF3" "s. ? HHMM1 2 0{{{((r/r$) __name__ __module__ __qualname____doc__r{ make_loggerrrrCrtrwrrr8r/rrrs8 %   CO ./b)r/r components log_level stop_at_closecddlm}|tj|tj|rfd}nd}|t j ||fy)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|tr6jd| jd|j yy#t $rYywxYw)Nz#Something went wrong: {log_failure})failurezStopping reactor ..)r_rerrorrstopr )rAargrs r done_callbackzrun..done_callbackqsR#w' ? MHH23LLN ( )s!A AA)twisted.internet.taskrr{ start_loggingrr_run)rrrrrrs @rrrRsN(,  ),    C   )..:}56r/)infoT), functoolsrtypingrtwisted.internet.interfacesrrirrtwisted.python.failurertwisted.internet.errorr r]r twisted.internet.sslr r r rOpenSSLrrhr{autobahn.twisted.websocketrautobahn.twisted.rawsocketr autobahn.wamprautobahn.twisted.wamprautobahn.wamp.serializerrr__all__rr.rGrnrr[rvrr8r/rrs8=99*4 D=YYK  AA#)^ AA $NfRu) ##u)p*7DO*7*7T*7O  DsB B*)B*