o >h;@sJddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z z dZ dd lmZdd lmZmZmZdd lmZdd lmZWn eyUd Z YnwddlZddlmZddlmZddlmZddlmZddl m!Z!m"Z"dZ#ddZ$ddZ%ddZ&ddZ'Gdddej(Z(d%d ee(d!e)d"e*fd#d$Z+dS)&)wraps)List)IStreamClientEndpoint)UNIXClientEndpoint)TCP4ClientEndpoint)Failure)ReactorNotRunningT)SSL4ClientEndpoint)optionsForClientTLSCertificateOptions Certificate)IOpenSSLClientConnectionCreator)SSLFN)WampWebSocketClientFactory)WampRawSocketClientFactory) component)Session)create_transport_serializerscreate_transport_serializer) Componentruncstfdd|DS)zM Return a list with unique elements from sequence, preserving order. cs"g|] }|vr|s|qS)add).0xseenrz/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/autobahn/twisted/component.py Bs"z _unique_list..)set)seqrrr _unique_list=sr!cCs.|d}|dddd|ddDS)N_rcss|]}|VqdSN) capitalize)rsrrr Gsz._camel_case_from_snake_case..)splitjoin)snakepartsrrr_camel_case_from_snake_caseEs $r-c Cs|jdkrt|}t||j||jd}n|jdkr't|jd}t||d}nJd|j D]=\}}z |j d i||iWq0t t fymz|j d it ||iWnt t fyjtd|j||wYq0w|S) z3 Create a WAMP-over-XXX transport factory. websocket)url serializersproxy rawsocketr) serializerFshould not arrive herez"Unknown {} transport option: {}={}Nr)typerrr/r1rr0roptionsitemssetProtocolOptions TypeErrorKeyErrorr- ValueErrorformat)reactor transportsession_factoryr0factoryr3kvrrr_create_transport_factoryJs8     rCcCst|r t|}|S|ddkrL|dd}|dvr#td||d}t|tkr6tdt||d }t|tkrItd t||d d }t|tkr^td t||dd}|rtslt dt |rvt |}nat |t r| D] } | dvrtd| q|d|} t| tkrtd| d} |dd} | durtt| d} t| | d}nt |tr|}n|durt|}n t dt||dkrt|||||d}|S|dkrt dJd|drz d dl} | ||}W|Styt d!|w|dkr$t||||d}|S|dkrHzd d"lm}Wn ty=t d#w|||||d}|SJd|dd$krh|d%}t|d d }t|||d}|SJd)&zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r5tcpversion)rFz6invalid IP version {} in client endpoint configurationhostz9invalid type {} for host in client endpoint configurationportz9invalid type {} for port in client endpoint configurationtimeout z.on_connect_success..lost)connectionLostr)protorw)ru)rvron_connect_success#s z8Component._connect_transport..on_connect_successcsjd7_t|dS)Nr()connect_failuresrprr)errrur>rron_connect_failure5sz8Component._connect_transport..on_connect_failureN)rCr1rirfconnectrp add_callbacks) rkr=r>r?rutransport_factorytransport_endpointdrzr~rr}r_connect_transport s   zComponent._connect_transportNcCs,|dur|jdddlm}|j|dS)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 Deferred that fires (with ``None``) when we are "done" or with a Failure if something went wrong. NzUsing default reactorr)r=)loop)logwarntwisted.internetr=_start)rkr=rrrstart>s   zComponent.startr$) __name__ __module__ __qualname____doc__rp make_loggerrrr?rmrorrrrrrrs 1rinfo components log_level stop_at_closecsRddlm}|durtj|dt|rfdd}nd}|tj||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)levelcsJt|tr#jd|dz d|WdSty"YdSwdS)Nz#Something went wrong: {log_failure})failurezStopping reactor ..)rZrerrorrstopr)r=argrrr done_callbackqs   zrun..done_callback)twisted.internet.taskrrp start_loggingrr_run)rrrrrrrrrRs   r)rT), functoolsrtypingrtwisted.internet.interfacesrrdrrtwisted.python.failurertwisted.internet.errorrrXr twisted.internet.sslr r r r OpenSSLrrcrpautobahn.twisted.websocketrautobahn.twisted.rawsocketr autobahn.wamprautobahn.twisted.wamprautobahn.wamp.serializerrr__all__r!r-rCrirrVrnrrrrrs:              'i x