o @Bi:@sDddlmZmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z z dZdd lmZdd lmZmZmZdd lmZdd lmZWn eyWd ZYnwddlZddlZddlmZddlmZddlmZddl m!Z!ddl"m#Z#m$Z$dZ%ddZ&ddZ'ddZ(ddZ)Gdddej*Z*d"d d!Z+dS)#)absolute_importprint_function)wraps)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/html/Trade-python/venv/lib/python3.10/site-packages/autobahn/twisted/component.py Ds"z _unique_list..)set)seqrrr _unique_list?sr"cCs.|d}|dddd|ddDS)N_rcSsg|]}|qSr) capitalize)rsrrrrIsz/_camel_case_from_snake_case..)splitjoin)snakepartsrrr_camel_case_from_snake_caseGs $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.r0rr/roptionsitemssetProtocolOptions TypeErrorKeyErrorr, ValueErrorformat)reactor transportsession_factoryr/factoryr2kvrrr_create_transport_factoryLs8     rBcCst|r t|}|S|ddkrS|dd}|dvr#td||d}t|tjkr7tdt||d }t|tjvrKtd t||d d }t|tjvratd t||dd}|rt sot dt |ryt |}net |t r|D] } | dvrtd| q|d|} t| tjkrtd| d} |dd} | durttt| 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|dkrOzd d"lm}Wn tyDt d#w|||||d}|SJd|dd$kro|d%}t|d d }t|||d}|SJd)&zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r4tcpversion)rEz6invalid 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)protorz)rx)ryron_connect_success%s z8Component._connect_transport..on_connect_successcsjd7_t|dS)Nr')connect_failuresrsru)errrxr=rron_connect_failure7sz8Component._connect_transport..on_connect_failureN)rBr0rkrhconnectrs add_callbacks) rmr<r=r>rxtransport_factorytransport_endpointdr}rrrr_connect_transports   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)rmr<rrrstart@s   zComponent.startrr) __name__ __module__ __qualname____doc__rs make_loggerrrr>rorqrrrrrrrs 1rinfocsHddlm}|durtj|dtfdd}|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 :type components: instance or list of :class:`autobahn.twisted.component.Component` :param log_level: a valid log-level (or None to avoid calling start_logging) :type log_level: string r)reactN)levelcs<t|tr jd|dz|WdStyYdSw)Nz#Something went wrong: {log_failure})failure)rZrerrorstopr )r<argrrr done_callbackts  zrun..done_callback)twisted.internet.taskrrs start_loggingrr_run) components log_levelrrrrrrTs   r)r), __future__rr functoolsrtwisted.internet.interfacesrrerrtwisted.python.failurertwisted.internet.errorr rXr twisted.internet.sslr r r rOpenSSLrrdrUrsautobahn.twisted.websocketrautobahn.twisted.rawsocketr autobahn.wamprautobahn.twisted.wamprautobahn.wamp.serializerrr__all__r"r,rBrkrrrrrrs<             'ix