U ucD>@sddlZddlZddlZddlmZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZd Zd d Zd d ZddZGddde jZdddZdS)N)wraps)WampWebSocketClientFactory)WampRawSocketClientFactory) component) TransportLost)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).0xseenr ^/var/www/html/CISBACKEND/school/venv/lib/python3.8/site-packages/autobahn/asyncio/component.py 3s z _unique_list..)set)seqr rr _unique_list.srcCs.|d}|dddd|ddDS)N_rcss|]}|VqdSN) capitalize)rsr r r 8sz._camel_case_from_snake_case..)splitjoin)Zsnakepartsr r r_camel_case_from_snake_case6s 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$r r#rAssertionErroroptionsitemsZsetProtocolOptions TypeErrorKeyErrorr! ValueErrorformat)loop transportsession_factoryr#factoryr%kvr r r_create_transport_factory;s2    r5c@sFeZdZdZeZeZddZ ddZ ddZ dd Z d d d Z d S)r z 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. cCs t|tjS)z" Internal helper. ) isinstancesslSSLError)selfer r r _is_ssl_errorrszComponent._is_ssl_errorcCsNt|trBd|krJ|d}t|ttfr*qJt|tjr8qJtdntddS)Ntlsz?'tls' configuration must be a dict, bool or SSLContext instancezI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)r6dictboolr7 SSLContextr-)r9endpointr<r r r_check_native_endpointxs  z Component._check_native_endpointcCst|||}|jr||jdd}t|tkr>tdt||j||jd|jdd}t t j ||d}| |||S|jdd krH|jd d } | d krtd | |jd} t| t krtdt| |jd} t| tkrtdt| |jdd}t|tkr0tdt||jdd} d} | rt| tr| D]}|dkr\td|q\| d| }t|t krtd|| dd}|} d} |dk rtjtjj|d} n.on_connect_success..lost) is_closingrbrcgetattrrdrconnection_lostr)resultr0protoreasonrg)r_)rfron_connect_successs    z=Component._wrap_connection_future..on_connect_successcsjd7_t|dS)Nr)Zconnect_failuresrbrd)errr_r0r ron_connect_failuresz=Component._wrap_connection_future..on_connect_failure)rbZ add_callbacks)r9r0r_Zconn_frnrqr rprrWs  (z!Component._wrap_connection_futureNcCs(|dkr|jdt}|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 Future which will resolve (to ``None``) when we are "done" or with an error if something went wrong. NzUsing default loop)r/)logwarnrTget_event_loop_start)r9r/r r rstart$s zComponent.start)N)__name__ __module__ __qualname____doc__rb make_loggerrrrr1r;rArarWrvr r r rr bsb6r Tinfocs|dk rtj|dtrBttttj_t fddz0 t j fdd t j fddWntk rYnXdd }t|||rz Wntjk rYnXdS) 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 XXX fixme for asyncio -- if you wish to manage the loop yourself, use the :meth:`autobahn.asyncio.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.asyncio.component.Component` :param start_loop: When ``True`` (the default) this method start a new asyncio loop. :type start_loop: bool :param log_level: a valid log-level (or None to avoid calling start_logging) :type log_level: string N)levelc sjd|dztj}Wntk r8t}YnX|D]@}ztj}Wntk rlt}YnX||k r>|q>fdd}tj|}||dS)NzShutting down due to {signal})signalc spz`z |WnNtjk r.dYn0tk r\}zjd|dW5d}~XYnXW5XdS)NzAll task cancelledz&Error while shutting down: {exception}) exception)stoprkrTCancelledErrordebug Exceptionerror)futr:rrr/r rcancel_all_callbackys $z5run..nicely_exit..cancel_all_callback) r|rTTask all_tasksAttributeError current_taskcancelgatheradd_done_callback)r~taskstaskrrrrr r nicely_exites  zrun..nicely_exitcstdS)NSIGINTrTrUr rr rzrun..cstdS)NSIGTERMrr rr rrrcSs |dSr)r)r/argr r r done_callbackszrun..done_callback)rbZ start_loggingrTrt is_closedset_event_loopnew_event_loopconfigr/r{add_signal_handlerr~rrNotImplementedErrorr_run run_foreverrclose) componentsZ start_loopZ log_levelrr )rrr/rrr 9s,  ! r )Tr|)rTr7r~ functoolsrrbZautobahn.asyncio.websocketrZautobahn.asyncio.rawsocketrZ autobahn.wamprZautobahn.wamp.exceptionrZautobahn.asyncio.wamprZautobahn.wamp.serializerrr __all__rr!r5r r r r r rs"      'X