hD>SSKrSSKrSSKrSSKJr SSKrSSKJr SSKJ r SSK J r SSK J r SSKJr SSKJrJr S rS rS rS r"S S\ R.5rSSjrg)N)wraps)WampWebSocketClientFactory)WampRawSocketClientFactory) component) TransportLost)Session)create_transport_serializerscreate_transport_serializer) Componentrunc[5nUVs/sH$o"U;dM URU5(aM"UPM& sn$s snf)zE Return a list with unique elements from sequence, preserving order. )setadd)seqseenxs ^C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\autobahn/asyncio/component.py _unique_listr.s3 5D @s!tmADHHQKAs @@ @s ===cfURS5nUSSRSUSS55-$)N_rc3@# UHoR5v M g7fN) capitalize).0ss r ._camel_case_from_snake_case..8s@illnnis)splitjoin)snakepartss r_camel_case_from_snake_caser$6s4 KK E 8bgg@eABi@@ @@c :URS:Xa,[U5n[UURUURS9nO9URS:Xa"[ UR S5n[X%S9nOS5eURR5HupgUR"S0Xg0D6 M U$![[4a[ UR"S0[U5U0D6 MP![[4a& [SRURXg55ef=ff=f) z+ 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=;s!~~$29= ,  #//   ; &01F1Fq1IJ ,_T 0//u!!'')   & & 0! 0* N8$  **215q9x(  8?? PQU  sB//DC  6DDcb\rSrSrSr\R "5r\r Sr Sr Sr Sr S SjrS rg) r bz 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. c6[U[R5$)z Internal helper. ) isinstancesslSSLError)selfes r _is_ssl_errorComponent._is_ssl_errorrs!S\\**r%c[U[5(aSSU;aLUSn[U[[45(ag[U[R5(ag[ S5eg[ S5e)Ntlsz?'tls' configuration must be a dict, bool or SSLContext instancezI'endpoint' configuration must be a dict or IStreamClientEndpoint provider)rAdictboolrB SSLContextr5)rDendpointrIs r_check_native_endpoint Component._check_native_endpointxss h % % uocD$<00S^^44$.! r%cf[XU5nUR(aURRSS5n[ U5[ :wa#[ SR[ U555eURUURSURSS9n[R"[R"XvS95nURX$U5$URSS :XGaURRS S 5n U S ;a[ S RU 55eURSn [ U 5[:wa#[ SR[ U 555eURSn [ U 5[ :wa#[ SR[ U 555eURRSS5n[ U5[ :wa#[ SR[ U555eURRSS5n Sn U (Ga'[U [5(aU R!5H#nUS;dM [ SRU55e U RSU 5n[ U5[:wa[ SRU55eU RSS5nUn Sn Ub-["R$"["R&R(US9n OU[U ["R*5(aU n O3U S;a U (aU n O#[-SR[ U 555eURUU U U U S9n[R"[R"XvS95nURX$U5$URSS:Xa~URSn[ URRSS55nUR/UUS9n[R"[R"XvS95nURX$U5$S5e) z/ Create and connect a WAMP-over-XXX transport. timeout z>",-O-V-VWX-Y"ZZ( #wwz48HH~,()l)s)st|)}~~!$t!^UupUR5(aI[R"T5(d-[USS5n[R"T[ U55 gUR m[T5UU4Sj5nXBlg)N_onclose_reasonzConnection already closedc>T"U5n[R"T5(d%Uc [S5n[R"TU5 U$)Nzfailed to complete connection)txaio is_calledrreject)failrtnroorigs rlostKComponent._wrap_connection_future..on_connect_success..lost s@4jt,,|,-LMLLt, r%) is_closingrzr{getattrr|rconnection_lostr)resultr8protoreasonrrros @ron_connect_success=Component._wrap_connection_future..on_connect_successs|% I##%%t,,$U,=?Z[FLL}V'<=((D 4[  %) !r%c^>T=RS- sl[R"TU5 g)Nr)connect_failuresrzr|)errror8s ron_connect_failure=Component._wrap_connection_future..on_connect_failures"  & &! + & LLs #r%)rz add_callbacks)rDr8roconn_frrs `` rrg!Component._wrap_connection_futures:& )P $ F= FD*<= r%NcUc0URRS5 [R"5nUR US9$)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)r7)logwarnrdget_event_loop_start)rDr7s rstartComponent.start$s9 < HHMM. /))+D{{{%%r%r.r)__name__ __module__ __qualname____firstlineno____doc__rz make_loggerrrr9rFrNrtrgr__static_attributes__r.r%rr r bs=    CO+ (`4D3l&r%r c^^^Ub[R"US9 [R"5mTR 5(aS[R "[R "55 [R"5mT[Rl[R"5mUU4SjmTR[RU4Sj5 TR[RU4Sj5 Sn[R "TX5 U(a"TR#5 TR'5 gg![a NPf=f![R$a N8f=f)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># TRSUS9 [RR5nUH8n[RR 5nX#LdM(UR 5 M: UU4Sjn[R"U6nURU5 g![a [R"5nNf=f![a [R "5nNf=f7f)NzShutting down due to {signal})signalc >UR5 TR 5 g![Ra TRS5 N8[anTR SUS9 SnANVSnAff=f!TR 5 f=f)NzAll task cancelledz&Error while shutting down: {exception}) exception)rrdCancelledErrordebug Exceptionerrorstop)futrErr7s rcancel_all_callback5run..nicely_exit..cancel_all_callbackysh   )) 0 ./ Q Ba P Q s3$%A. A1 A.A)$A1)A..A11B) infordTask all_tasksAttributeError current_taskcancelgatheradd_done_callback)rtaskstaskrrrrr7s r nicely_exitrun..nicely_exites 0@ (LL**,E D 6&||88: '  nne$ 125 (%%'E (" 6&335  6sQC'BC'CC'AC'B?<C'>B??C'C$!C'#C$$C'c<>[R"T"S55$)NSIGINTrdrersrrun..sw7L7L[YaMb7cr%c<>[R"T"S55$)NSIGTERMrrsrrrs8M8MkZcNd8er%c$UR5 gr)r)r7args r done_callbackrun..done_callbacks  r%)rz start_loggingrdr is_closedset_event_loopnew_event_loopconfigr7radd_signal_handlerrrrNotImplementedErrorr_run run_foreverrclose) components start_loop log_levelrrr7rs @@@rr r 9s8 ),  ! ! #D ~~w5578%%'      C3B   /cd 0ef NN43          %%   s%5AEE E EE('E()Tr)rdrBr functoolsrrzautobahn.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%