o i;@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).0xseenr`C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\autobahn/twisted/component.py Bs"z _unique_list..N)set)seqrrr _unique_list=sr!cCs.|d}|dddd|ddDS)N_rcss|]}|VqdSN) capitalize)rsrrr Gsz._camel_case_from_snake_case..)splitjoin)Zsnakepartsrrr_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. Z websocket)url serializersproxyZ rawsocketr) serializerFshould not arrive herez"Unknown {} transport option: {}={}Nr)typerrr-r/rr.roptionsitemsZsetProtocolOptions TypeErrorKeyErrorr, ValueErrorformat)reactor transportsession_factoryr.factoryr0kvrrr_create_transport_factoryJs8     r?cCst|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. r2tcpversion)rBz6invalid 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)ZconnectionLostr)protork)ri)rjron_connect_success#s z8Component._connect_transport..on_connect_successcsjd7_t|dS)Nr()Zconnect_failuresrgrh)errrir:rron_connect_failure5sz8Component._connect_transport..on_connect_failureN)r?r/r`r^connectrgZ add_callbacks) rbr9r:r;riZtransport_factoryZtransport_endpointdrmrprror_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)r9)loop)logwarnZtwisted.internetr9_start)rbr9rrrstart>s   zComponent.startr$) __name__ __module__ __qualname____doc__rg make_loggerrurr;rdrfrsrxrrrrrs 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})ZfailurezStopping reactor ..)rUrerrorrvstopr)r9argrurr done_callbackqs   zrun..done_callback)Ztwisted.internet.taskrrgZ start_loggingr}r_run)rrrrrrrrrRs   r)r~T), functoolsrtypingrZtwisted.internet.interfacesrr]rrZtwisted.python.failurerZtwisted.internet.errorrrSr Ztwisted.internet.sslr r r r ZOpenSSLrr\rgZautobahn.twisted.websocketrZautobahn.twisted.rawsocketrZ autobahn.wamprZautobahn.twisted.wamprZautobahn.wamp.serializerrr__all__r!r,r?r`rrQrerrrrrs:              'i x