8'h>ddlmZmZddlZddlZddlZddlmZ ddlZddl Z e jddl mZddlmZddlmZddlmZddlmZdd lmZmZd Zd Zd Zd ZGddej<ZddZy#e $rddl ZYkwxYw))absolute_importprint_functionN)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/html/trade_iq/venv/lib/python3.12/site-packages/autobahn/asyncio/component.py _unique_listr:s/ 5D @!atmDHHQKA @@ @s 222c|jd}|ddj|ddDcgc]}|jc}zScc}w)N_r)splitjoin capitalize)snakepartsss r_camel_case_from_snake_caser!BsB KK E 8bgguQRyA!q||~AB BBAsA 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_factoryr9Gs8~~%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_error~s!S\\**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= SSLContextr1)r?endpointrDs r_check_native_endpointz Component._check_native_endpointsk h %!v&cD$<0S^^4$." rBct|||}|jr|jjdd}t |t j vr#tdjt ||j||jd|jd}tjtj||}|j|||S|jdd k(r|jjd d } | d vrtd j| |jd} t | t jk7r#tdjt | |jd} t | t j vr#tdjt | |jjdd}t |t j vr#tdjt ||jjdd} d} | rt| t r| j#D] }|dvstdj|| jd| }t |t jk7rtdj|| jdd}|} d} |yt%j&t$j(j*|} nIt| t$j,r| } n,| dvr| r&| } n#t/djt | |j|| | | | }tjtj||}|j|||S|jddk(r|jd}t1|jjdd}|j3||}tjtj||}|j|||SJd) z? Create and connect a WAMP-over-XXX transport. timeout z.on_connect_success..losts=4jt,|,-LMLLt, rB) is_closingrurvgetattrrwr connection_lostr)resultr4protoreasonr{rzrks @ron_connect_successz=Component._wrap_connection_future..on_connect_successsz% Iu##%t,$U,=?Z[FLL}V'<=((D 4[  %)E !rBc\xjdz c_tj|y)Nr)connect_failuresrurw)errrkr4s ron_connect_failurez=Component._wrap_connection_future..on_connect_failure$s"  & &! + & LLs #rB)ru add_callbacks)r?r4rkconn_frrs `` rrbz!Component._wrap_connection_futures=& )P $ F$6= FD*<= rBNc|/|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)r3)logwarnr_get_event_loop_start)r?r3s rstartzComponent.start0s9 < HHMM. /))+D{{{%%rBN)__name__ __module__ __qualname____doc__ru make_loggerrr r5rArIrprbrr*rBrr r ns? %   CO+ (`4D3l&rBr c|tj|tjj rPtj tj tjtj_tjtjfd jtjfdjtjfdd}t!j"|||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)levelc*jd|tjj}|D]3}|tjj us$|j 5fd}tj |}|j|y)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)futr@rr3s rcancel_all_callbackz5run..nicely_exit..cancel_all_callback{sk   )) 0 ./ Q Ba PP Q s3$$A/A2 A/A*%A2*A//A22B)infor_Task all_tasks current_taskcancelgatheradd_done_callback)rtaskstaskrrrr3s r nicely_exitzrun..nicely_exitqsw 0@ &&( D7<<4466    nne$ 12rBc:tjdS)NSIGINTr_r`rsrzrun..sw7L7L[YaMb7crBc:tjdS)NSIGTERMrrsrrzrun..s8M8MkZcNd8erBc$|jyr)r)r3args r done_callbackzrun..done_callbacks  rB)ru start_loggingr_r is_closedset_event_loopnew_event_loopconfigr3r coroutineadd_signal_handlerrrrNotImplementedErrorr_run run_foreverrclose) components start_loop log_levelrrr3rs @@@rrrEs!8 ),  ! ! #D ~~w5578%%'      C 33,   /cd 0ef NN4]3          %%   s%>AE!E EEE('E()Tr) __future__rrr\r=r functoolsrr_ ImportErrortrolliusru use_asyncioautobahn.asyncio.websocketrautobahn.asyncio.rawsocketr autobahn.wamprautobahn.wamp.exceptionr autobahn.asyncio.wampr autobahn.wamp.serializerr r __all__rr!r9r rr*rBrrs87   AA#1)^ AC $NT& ##T&n^A sB B  B