U uc;@sHddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z z@dZ dd lmZdd lmZmZmZdd lmZdd lmZWnek rd Z YnXddlZddlmZddlmZddlmZddlmZddl m!Z!m"Z"dZ#ddZ$ddZ%ddZ&ddZ'Gdddej(Z(d#ee(e)e*d d!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|]}|kr|s|qS)add).0xseenrZ/var/www/html/SARATH/school/venv/lib/python3.8/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)Zsnakepartsrrr_camel_case_from_snake_caseEs r,c Cs|jdkr(t|}t||j||jd}n2|jdkrNt|jd}t||d}n dsZtd|j D]|\}}z|j f||iWqdt t fk rz|j ft||iWn,t t fk rtd|j||YnXYqdXqd|S) z3 Create a WAMP-over-XXX transport factory. Z websocket)url serializersproxyZ rawsocketr) serializerFshould not arrive herez"Unknown {} transport option: {}={})typerrr-r/rr.rAssertionErroroptionsitemsZsetProtocolOptions TypeErrorKeyErrorr, ValueErrorformat)reactor transportsession_factoryr.factoryr0kvrrr_create_transport_factoryJs2    r@cCs t|rt|}n|ddkr|dd}|dkrFtd||d}t|tkrltdt||d }t|tkrtd t||d d }t|tkrtd t||dd}|rtst dt |rt |}nt |t r| D]} | dkrtd| q|d|} t| tkrJtd| d} |dd} | dk rxtt| d} t| | d}n8t |tr|}n&|dkrt|}nt dt||dkrt|||||d}n"|dkrt dndstdn|drLzd dl} | ||}Wn$tk rHt d!|YnXnv|dkrht||||d}nZ|dkrzd d"lm}Wntk rt d#YnX|||||d}ndstdnD|dd$kr|d%}t|d d }t|||d}ndstd|S)&zI Create a Twisted client endpoint for a WAMP-over-XXX transport. r2tcpversion)rCz6invalid IP version {} in client endpoint configurationhostz9invalid type {} for host in client endpoint configurationportz9invalid type {} for port in client endpoint configurationtimeout zrJrKZ cert_fnamer\rMrOrrr_create_transport_endpointqs                          rac@s>eZdZdZeZeZddZ ddZ ddZ d d d Z dS) rz A component establishes a transport and attached a session to a realm using the transport for communication. The transports a component tries to use can be configured, as well as the auto-reconnect strategy. cCstrt|tjSdS)z Internal helper. This is so we can just return False if we didn't import any TLS/SSL libraries. Otherwise, returns True if this is an OpenSSL.SSL.Error F)rTrVrError)selferrr _is_ssl_errors zComponent._is_ssl_errorcCsdt|r nTt|trXd|kr`|d}t|ttfr6q`t|rBq`t|trNq`tdntddS)NrIzb'tls' configuration must be a dict, CertificateOptions or IOpenSSLClientConnectionCreator providerzI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)rrPrVrWboolr r r8)rcr_rIrrr_check_native_endpoints"    z Component._check_native_endpointc st||}jr2t|djdjdd}n t|j}||}fdd}fdd} t||d t|d | |S) z Create and connect a WAMP-over-XXX transport. :param done: is a Deferred/Future from the parent which we should signal upon error if it is not done yet (XXX maybe an "on_error" callable instead?) rArErF)r2rErFcs&|jtfdd}||_dS)Ncs"|}tst||Sr$)txaioZ is_calledreject)failZrtn)doneorigrrlost-s  zFComponent._connect_transport..on_connect_success..lost)ZconnectionLostr)protorm)rk)rlron_connect_success#sz8Component._connect_transport..on_connect_successcsjd7_t|dS)Nr()Zconnect_failuresrhri)errrkr;rron_connect_failure5sz8Component._connect_transport..on_connect_failureN)r@r/rar_connectrhZ add_callbacks) rcr:r;r<rkZtransport_factoryZtransport_endpointdrorrrrqr_connect_transport s     zComponent._connect_transportNcCs,|dkr |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)rcr:rrrstart>s   zComponent.start)N) __name__ __module__ __qualname____doc__rh make_loggerrwrr<rergrur{rrrrrs 1rinfo) components log_level stop_at_closecsRddlm}|dk r tj|dt|r:fdd}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)levelcsHt|trDjd|dzd|Wntk rBYnXdS)Nz#Something went wrong: {log_failure})ZfailurezStopping reactor ..)rVrerrorrxstopr)r:argrwrr done_callbackqs   zrun..done_callback)Ztwisted.internet.taskrrhZ start_loggingrr_run)rrrrrrrrrRs   r)rT), functoolsrtypingrZtwisted.internet.interfacesrr^rrZtwisted.python.failurerZtwisted.internet.errorrrTr Ztwisted.internet.sslr r r r ZOpenSSLrr]rhZautobahn.twisted.websocketrZautobahn.twisted.rawsocketrZ autobahn.wamprZautobahn.twisted.wamprZautobahn.wamp.serializerrr__all__r!r,r@rarrRrfrrrrrs6              'ix