hD>ddlZddlZddlZddlmZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZd Zd Zd Zd ZGd de j.ZddZy)N)wraps)WampWebSocketClientFactory)WampRawSocketClientFactory) component) TransportLost)Session)create_transport_serializerscreate_transport_serializer) Componentruncnt}|Dcgc]}||vs|j|r|c}Scc}w)zM Return a list with unique elements from sequence, preserving order. )setadd)seqseenxs V/var/www/Befach/backend/env/lib/python3.12/site-packages/autobahn/asyncio/component.py _unique_listr.s/ 5D @!atmDHHQKA @@ @s 222cf|jd}|ddjd|ddDzS)N_rc3<K|]}|jywN) capitalize).0ss r z._camel_case_from_snake_case..8s@alln@s)splitjoin)snakepartss r_camel_case_from_snake_caser#6s4 KK E 8bgg@eABi@@ @@c B|jdk(r/t|}t||j||j}n<|jdk(r&t |j d}t||}nJd|jjD]\}} |jdi||i|S#ttf$r[ |jdit||in9#ttf$r'tdj|j||wxYwYwxYw) z3 Create a WAMP-over-XXX transport factory. websocket)url serializersproxy rawsocketr) serializershould not arrive herez"Unknown {} transport option: {}={})typer rr'r)r r(roptionsitemssetProtocolOptions TypeErrorKeyErrorr# ValueErrorformat)loop transportsession_factoryr(factoryr+kvs r_create_transport_factoryr<;s3~~$29= ,  #//   ; &01F1Fq1IJ ,_T 0//u!!'')1  &G & & 0!Q 0* N8$  ***215q9x(  8?? PQSTU  s*B44DC"!D"6DDDcXeZdZdZej ZeZ dZ dZ dZ dZ ddZ y) 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. c6t|tjS)z" Internal helper. ) isinstancesslSSLError)selfes r _is_ssl_errorzComponent._is_ssl_errorrs!S\\**r$ct|trGd|vrB|d}t|ttfryt|tjryt dyt d)Ntlsz?'tls' configuration must be a dict, bool or SSLContext instancezI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)r?dictboolr@ SSLContextr4)rBendpointrFs r_check_native_endpointz Component._check_native_endpointxsj h % uocD$<0S^^4$.! r$c>t|||}|jr|jjdd}t |t k7r#t djt ||j||jd|jd}tjtj||}|j|||S|jdd k(r|jjd d } | d vrt d j| |jd} t | tk7r#t djt | |jd} t | t k7r#t djt | |jjdd}t |t k7r#t djt ||jjdd} d} | rt| tr| j!D] }|dvst dj|| jd| }t |tk7rt dj|| jdd}|} d} |yt#j$t"j&j(|} nIt| t"j*r| } n,| dvr| r&| } n#t-djt | |j|| | | | }tjtj||}|j|||S|jddk(r|jd}t |jjdd}|j/||}tjtj||}|j|||SJd) z? Create and connect a WAMP-over-XXX transport. timeout z>",-O-V-VWX-Y"ZZ( #wwz48HH~,()l)s)st|)}~~!$t!.on_connect_success..lost s=4jt,|,-LMLLt, r$) is_closingrurvgetattrrwrconnection_lostr)resultr7protoreasonr{rzrks @ron_connect_successz=Component._wrap_connection_future..on_connect_successsz% Iu##%t,$U,=?Z[FLL}V'<=((D 4[  %)E !r$c\xjdz c_tj|y)Nr)connect_failuresrurw)errrkr7s ron_connect_failurez=Component._wrap_connection_future..on_connect_failures"  & &! + & LLs #r$)ru add_callbacks)rBr7rkconn_frrs `` rrcz!Component._wrap_connection_futures=& )P $ F$6= FD*<= r$Nc|/|jjdtj}|j |S)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. zUsing default loop)r6)logwarnr`get_event_loop_start)rBr6s rstartzComponent.start$s9 < HHMM. /))+D{{{%%r$r)__name__ __module__ __qualname____doc__ru make_loggerrrr8rDrKrprcrr-r$rr r bs? %   CO+ (`4D3l&r$r c|tj|tjj rPtj tj tjtj_tjfd jtjfdjtjfdd}tj |||r" j#j'yy#t$rYJwxYw#tj$$rY6wxYw)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)levelcKjd| tjj}|D]6} tjj }||us'|j 8fd}tj|}|j|y#t$rtj}YwxYw#t$rtj }YwxYww)NzShutting down due to {signal})signalc |jj y#tj$rjdY7t$r}j d|Yd}~Wd}~wwxYw#j wxYw)NzAll task cancelledz&Error while shutting down: {exception}) exception)rr`CancelledErrordebug Exceptionerrorstop)futrCrr6s rcancel_all_callbackz5run..nicely_exit..cancel_all_callbackysk   )) 0 ./ Q Ba PP Q s3$$A/A2 A/A*%A2*A//A22B) infor`Task all_tasksAttributeError current_taskcancelgatheradd_done_callback)rtaskstaskrrrrr6s r nicely_exitzrun..nicely_exites 0@ (LL**,E D 6&||88: <'  nne$ 125 (%%'E (" 6&335  6sPC!BC!B>C!CC!CC!c:tjdS)NSIGINTr`rarsrzrun..sw7L7L[YaMb7cr$c:tjdS)NSIGTERMrrsrrzrun..s8M8MkZcNd8er$c$|jyr)r)r6args r done_callbackzrun..done_callbacks  r$)ru start_loggingr`r is_closedset_event_loopnew_event_loopconfigr6radd_signal_handlerrrrNotImplementedErrorr_run run_foreverrclose) components start_loop log_levelrrr6rs @@@rr r 9s 8 ),  ! ! #D ~~w5578%%'      C3B   /cd 0ef NN4]3          %%   s%+AD0D?0 D<;D<?EE)Tr)r`r@r functoolsrruautobahn.asyncio.websocketrautobahn.asyncio.rawsocketr autobahn.wamprautobahn.wamp.exceptionrautobahn.asyncio.wamprautobahn.wamp.serializerr r __all__rr#r<r r r-r$rrs\6  AA#1)^ AA $NT& ##T&nhr$