+ jHjgRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIH t H t H t H t ]P!]4tRtRt]!RR04t]R0,t]!R R04t!R R ] 4tR tR Rlt!RR4t!RR4tR#)u5One gateway connection per classic-CLI process (CALLMAP §3.1, §4). A daemon thread owns an asyncio loop and one ``GatewayClient``. It never calls a HermesCLI method and never blocks: every event frame goes into a thread-safe ``queue.Queue`` that the agent thread drains (``GatewayAgent.run_conversation``), and ``session.info``-class frames also update the plain-attribute ``SessionState`` caches the status bar reads. Callers on any other thread use ``call()``, which blocks on the loop's future; calling it on the loop thread itself is a deadlock and raises. ) annotationsN)DEFAULT_RPC_TIMEOUTRESUME_KEY_MISMATCHGatewayClientErrorGatewayRPCErrorzGateway disconnected; turn outcome is unknown. Resume the printed session ID to check whether it completed or was interrupted; do not resend the work.zCGateway disconnected before the request was sent; nothing was sent. not_foundpermission_deniedprofile_mismatchadmission_conflictc]tRt^'tRtRtR#) CallStoppedzXThe caller stopped waiting (:meth:`GatewayConnection.call_until`); the request was sent.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r B/home/ubuntu/.hermes/hermes-agent/hermes_cli/gateway_connection.pyr r 'sbrr cV'd!\V4R8Xd\\4RhV'g\V4\9dVh\P RW4R#)aA keyed ``session.resume`` the owner refused with ``exc``: returns when the caller resumes plain, else raises. Only a refusal in ``_KEY_NOT_TAKEN`` resumes plain (a keyed startup alias on a Desktop/TUI session); any other is raised, not hidden by a keyless attach whose first turn fails. ``typed`` (a typed ``--api-key`` the user resumes with) never resumes plain: ``admission_conflict`` is the thin client's refusal.r NzAsession.resume %s: launch key not taken (%s); resuming without it)strrr_KEY_NOT_TAKENloggerdebug)exc session_idtypeds&&&r _resume_plainr+sD  S11 !454? C.  LLTV`frcV^8dQhRR/#returnboolr )formats"r __annotate__r%8sdddrc\VRR4p\V\4;'dVRJ;'dVRJ;'dW!8#)z``frame`` is a transport error from a connection older than ``epoch``: a reconnect replaced it, so it is no outcome of anything submitted on ``epoch``.connection_epochN)getattr isinstance Exception)frameepochlosts&& r lost_beforer.8sF 5,d 3D eY ' c cD,< c cdAR c cW[Wccrc<]tRt^?tRtRtRtR RltRtRt Rt R#) SessionStatezWhat the gateway last told this viewer about one session (plain attributes, GIL-atomic reads from the prompt_toolkit render thread; never an RPC per paint).c HWn/VnRVnRVnRVnRVnRVn.Vn/Vn.Vn .Vn RVn .Vn /Vn /VnRVn^Vn/Vn^Vn\'4Vn^;VnVnR#N)rinfotitle todo_staterevisionsubscription_idexecution_generationmessagesusageusage_listenersrequest_listeners admitted_turnpending queued_inputsadoptedarmed_admission pending_seq queued_at recovered_seqsetmissedgaps attached_gaps)selfrs&&r__init__SessionState.__init__Cs$ !% '+ #$(!   &((**.  #%  +/ "5 *+* D&rc \VPR4;'g/4VnVPRVP4VnVPRVP4VnVPRVP 4Vn\ VPR4;'g.4VnRV9d2VR,p\V\4'd \V4MRVn \VPR4\ 4'd1\ VR,4Vn V;P^, un VPPR4'dVPR,Vn R#R#) r3r6r7r8r9r5Nr>r4) dictgetr3r6r7r8listr9r)r5r>rBr4)rIsnapshotr5s&& radopt_snapshotSessionState.adopt_snapshotksf-334  Z? '||,=t?S?ST$,LL1GIbIb$c!X\\*5;;< 8 #!,/J2r4z todo.updatedtodosr6z session.usager: api_callszrequest.cancelzsession.replay_gapN)r[zsession.updated)r)rMr3updateitemsrNrOr>rBr4r5int apply_usager<rG)rIkindpayloadkvnestedflatlisteners&&& r apply_eventSessionState.apply_events 6 6:gt;T;T II  w}}Ttq!|BSdadT U'++i0$77#GI$67   A% {{7##$W- $ ^ # 7D(A(A&W[[-A-G-GR(H*V]VaVablVmnDO _ $GT)B)B[[)Fgkk+6<\\JvW[D\@\D   W& 9 % %*Wd*C*C !7!78!9 ) ) IINI*#Us  H+ H+ c \V\4'gR#\V4Vn\VP4FpV!VP4K R#)zZOne session-cumulative usage dict (``session.usage`` payload or ``session.stats`` result).N)r)rMr:rOr;)rIr:rhs&& rraSessionState.apply_usages>%&& %[ T112H TZZ 3r)r=r@rArHr8rGr3r9rFr>rBrCr?rDr<r6rr7r4r5r:r;N)) rrrrrrJrQrXrirarr rrr0r0?s#M&+P ,L ,!rr0c]tRt^tRt]P !4tR!Rlt] R4t ] RRl4t RRlt R"RltR tR tR tR tR R/RltRtRtRtRRltRtRtRtRRRR/RltR!RltRtRtRtRRRR/Rlt R t!R#)#GatewayConnectionNc Wn\P!4Vn/VnRVnRVnRVnRVn\P!4Vn RVn RVn \P!4VnRVnRVn^Vn/Vn\P!4Vn\+4VnRVnRVnR#)NF)_connectqueueQueueeventsstatesclient_liveloop_thread threadingEvent_ready_error_stopLock _start_lockclosed _detachedr,_side _side_lockrE _commandslaunch_api_keylaunch_api_key_typed)rIconnects&&rrJGatewayConnection.__init__s #(;;= /1     oo'   $>>+  .0 #..*/2u#%*!rc VP;_uu_4VPeVPP'd V!4VnVPuuRRR4# +'giR#;ir2) _shared_lock_sharedfinal)clss&rsharedGatewayConnection.sharedsF    {{"ckk&7&7&7!e ;;   s*A"A"" A3 cV^8dQhRR/#r r )r$s"rr%GatewayConnection.__annotate__sNNtNrc xVP;'g(VPRJ;'dVP'*#)zNo call dials again: the viewer closed it, or its first connect failed. ``closed`` is also true while the gateway is hung up, which the next ``call()``/``start()`` redials.N)rr}r,)rIs&rrGatewayConnection.finals-~~MM$++T"9"L"L$**nMrcV^8dQhRR/#)r!r"r0r )r$s"rr%rs<rc vVPPV4pVf\V4;q PV&V#r2)rurNr0)rIrstates&& rrGatewayConnection.states4  + =.::.F FEKK + rc  \P!4V,pVP;_uu_4VP'd&VPe VPhRRR4R#VP pVewVP 'deVP4'dOV\P!4Jd6VP\V\P!4, ^44VeVP4'g]^RI H pVe)RVnVPP4RVnV!VP RR7;q0nVP#4RRR4VPP%\V\P!4, ^44'g \'R4hVPe VPhVP(fVP'dR#XP\V\P!4, ^44\P!4V8gEK/\'R4h +'giL;i)TNspawn_context_threadFzhermes-gateway-loopnamez/Gateway connection timed out; no local fallback)time monotonicrrr}ryris_aliverzcurrent_threadjoinmaxagent.memory_providerrr|clear_runstartwaitrrv)rItimeoutdeadlinethreadrs&& rrGatewayConnection.starts>>#g-!!!:::{{."kk) "! %$+++&//:K:KPV^g^v^v^xPxKKHt~~/?$? CD>):):J)'+  ))+&+ ,@Qf,ggF\LLN)",;;##C4>>3C(CQ$GHH()Z[[{{&kk!{{&$*** KKHt~~'77; <~~8+()Z[[?"!s%.I*!I I"A'I AI I' c z\P!VP44RVnVPP4R# \dApTPf)\ T\ 4'dTM \ R4TnRp?LiRp?ii;i RTnTPP4i;i)Nz,Gateway connection failed; no local fallbackT) asynciorun_main BaseExceptionr}r)rrr|rE)rIrs& rrGatewayConnection._runs  KK % DK KKOO   D{{"%/5G%H%HcN`BOD  D DK KKOO s)$A B6B BBB#B:c "\P!4Vn\P!4VnVP pVf ^RIHpTpV!4;_uu_4GRjxL pVP'dVPV4GRjxL V;P^, unW0n W0P3Vn VPP4\P!VPV44p\P!VPP!44p\P !WE0\P"R7GRjxL VP%4VP%4RRR4GRjxL RTn RTn R#EL=ELLJL +GRjxL 'giL3;i \&dpTPP)4'gE\+T\,4'dTM!\-R\/T4P0 R24TnRp?LTP5\-\644Rp?LRp?ii;i RTn RTn i;i5i)Nconnect_gateway) return_whenz.Gateway connection failed; no local fallback ())rget_running_looprxr{r~rqhermes_cli.gateway_clientrr, _resubscribervrwr|rE create_task_pumprFIRST_COMPLETEDcancelr*is_setr)rtyperr} _put_loss DISCONNECTED)rIrrrvpumpstoprs& rrGatewayConnection._mains,,. ]]_ -- ? A%G yyyF:::++F333 a $ $jj1  !**4::f+=>**4::??+<=llDGI G IAI0I 5II II I00I3c ^VPVnVPPV4R#r2)r,r'rtput)rIerrors&&rrGatewayConnection._put_loss$s!% rc r"\VPP44F>wr#VPfKTP VP W4GRjxL 4K@ R#L \ d>p\T4\9dh\PRY$4RTnRp?KRp?ii;i5i)aiA new socket is a new viewer: the gateway streams a session's frames only to connections that resumed it. Resume each session this viewer had open; one gone meanwhile is dropped. Any other failure fails the reconnect: ready without the subscription, every prompt is refused on a live socket that never redials, while a failed redial is retried by the next call.Nz%session.resume %s after reconnect: %s) rOrur_r7rQ_resumerr RESUME_GONErr)rIrvrrrs&& rrGatewayConnection._resubscribe(s "&dkk&7&7&9!: J$$, -$$4<<+K%KL ";&L% -s8;. DjV(,%%  -s@9B7A,A* A,$B7*A,, B472B/)B7/B44B7rFc VPpV'd V!RW$R7#V!RVR7# \dp\YRT4Rp?L&Rp?ii;i)z``session.resume`` through ``call`` (the store's attach), re-supplying :attr:`launch_api_key`; a refusal of the keyed resume is :func:`_resume_plain`'s to decide. ``typed``: the user resumes with a typed ``--api-key``.session.resumerapi_keyNr)rrr)rIcallrrkeyrs&&&$ rresumeGatewayConnection.resume8sT!!  6,QQ$<<# 6cu55 6s * A  AA c "VPpV'dVPRW#R7GRjxL #VPRVR7GRjxL #L \dp\YBRR7Rp?L:Rp?ii;iL+5i)z:meth:`resume` for :meth:`_resubscribe`, awaited on this loop so a cancelled reconnect cancels its request. A reconnect types nothing: never ``typed``.rrNF)rr)rrpcrr)rIrvrrrs&&& rrGatewayConnection._resumeDsp!!  <#ZZ(8ZZ]]]ZZ 0ZZHHH^" <cU;; <HsIA7AAAA7 A5 A7A A2 A-(A7-A22A7c "VPP4GRjxL p\V\4'dVP V4R#\V\ 4'dVPR4MRp\V\ 4'dVP V4'dK\V\ 4'ddVPR4pW@P9dCVPV,PVPR4VPR44VPPV4EK;EL \d\PRRR7LEi;i5i)TNparamsrrrczsession state update failed)exc_info) rtrNr)r*rrM _take_siderurirrr)rIrvr+rsids&& rrGatewayConnection._pumpOs --++--E%++u%,6ud,C,CUYYx(F&$''DOOF,C,C&$''jj.++%S C(44VZZ5GT]I^_ KKOOE ".%S %BT RSs;E)D>BE)%9E)AE E)"E&#E)%E&&E)c ^RIHpVPR4pVPR4V9g.\V\4'dVPR4'gR#VP VR,4P V4R#)) SIDE_EVENTSrcrtask_idFT)hermes_cli.gateway_siderrNr)rM side_waiterr)rIrrrcs&& rrGatewayConnection._take_sideasf7**Y' ::f [ 0 7D8Q8QY`YdYdenYoYo +,009rcV^8dQhRR/#)r!r"z queue.Queuer )r$s"rr%risAAkArc VP;_uu_4VPPV\P!44uuRRR4# +'giR#;ir2)rr setdefaultrrrsrIrs&&rrGatewayConnection.side_waiteris1 ___::((%++-@___s /A A c VP;_uu_4VPPVR4RRR4R# +'giR#;ir2)rrpoprs&&rdrop_side_waiter"GatewayConnection.drop_side_waiterms) ___ JJNN7D )___s < A c RVnVP;_uu_4VPFpVP4K RRR4VPVP r2Ve3Ve/VP 'gVPVP4VPe?VP\P!4JdVPP^4RVnR# +'giL;i \dLui;i)TN) rrrrErxr~rcall_soon_threadsafe RuntimeErrorryrzrr)rIwakerxrs& rcloseGatewayConnection.closeqs ___ 'YY d   0 ))$((3 << # IT\ IudJ&QR   , ,V-=-=-B-B5-I4 P W WXZ [  LL:C @ s?A?? B+ B&&B+rabandonc >VP!V3RVRV/VB^,#)rr) call_tagged)rImethodrrrs&&$$,rrGatewayConnection.calls(SSSFSTUVVrc VPV4pVPpVPRWR7pVPV4WCnV#)zU``session.resume`` after a replay gap; its snapshot names the subscription to detach.r)rr)rrGrrQrH)rIrrrrGrPs&&& rreattachGatewayConnection.reattachsE :&zz99-*9V X&"rc VVPe/\P!4VPJd \R4hVP 4VP VP rTVeVf\\4hVwrg\P!VP!V3RV/VBV4V3#)zU``(future, epoch)`` of one request sent on the live socket (see :meth:`call_tagged`).zBGatewayConnection.call() on the gateway loop thread would deadlock_timeout) ryrzrrrrwrxrNOT_SENTrrr)rIrbudgetrliverxrvr,s&&&& r_sendGatewayConnection._sends << # (@(@(Bdll(Rcd d ZZd <4<$X. . // 60]F0]V\0]_cdfkkkrc aaaaaa^RIp^RIHpSPe/\P !4SPJd \ R4hSP4SP'd\\4hVPP4\P!4uooSPV3Rl4V!VVVVVV3RlRR7pSP;_uu_4SP P#S4RRR4VP4SP%4SP'4VP)^ 4SP;_uu_4SP P+S4RRR4SP-4'dSP/4#SP14'd \3S4h\\4h +'giL;i +'giLy;i SP'4TP)^ 4SP;_uu_4SP P+S4RRR4i +'gii;i;i)a``call`` with no answer deadline, for a verb that lasts as long as the work it runs (a plugin command's handler), on a socket of its own to this connection's gateway: the gateway answers a socket's requests one at a time, in arrival order (``tui_gateway/ws.py``), so a handler still running never holds this connection's reads, prompts and interrupts. One dial and one send, never retried. Waits for the answer or the transport's error, unless *wake* (a ``threading.Event``, set by Ctrl+C or :meth:`close`) is set first: then raises :class:`CallStopped`; the request was sent and its work goes on, but its answer is dropped. The socket closes on any of these, and its thread is gone before this returns.NrzHGatewayConnection.call_until() on the gateway loop thread would deadlockc$<SP4#r2)rE)_doners&r.GatewayConnection.call_until..s txxzrc V<\P!SPSSSSS44#r2)rr_command)answerrrrIsentrsrrrs#gkk$--PVX\^dfj:k.lrzhermes-gateway-commandr)concurrent.futuresrrryrzrrrrrr futuresFuturer{add_done_callbackrraddrrErdiscarddonerrr ) rIrrr concurrentrrrrs fffl @@r call_untilGatewayConnection.call_untils "> << # (@(@(Bdll(Rij j :::$X. .!))002IOO4E   !9:%&l&l+CE ___ NN  t $  - IIK HHJ KKO&&t,! ;;====? " ;;==f% % **_! HHJ KKO&&t,!s<*GH$G1 G. 1 H 6I2:I  I2 I/ *I2c aa "VPpVf ^RIHpTp\P!4o \P !\P !VP44pVPVV 3Rl4V!4;_uu_4GRjxL p VP4SPV P!V3R\R4/VBGRjxL 4RRR4GRjxL TP4\P*!TRR7GRjxL R#LLLL: +GRjxL 'giLQ;i \PdLk\d]p \T \ 4'g,\!TP#4'd\$M\&4p SP)T 4Rp ? LRp ? ii;iL TP4\P*!TRR7GRjxL i;i5i)zThe command socket of :meth:`call_until`: dial, send once, settle ``answer`` with the reply or the transport's error; a set ``wake`` without an answer cancels the dial or the wait.NrcT<SP4;'gSP4#r2)r r)r~rtasks&rr,GatewayConnection._command..sV[[]-K-Kdkkm-Krr infT)return_exceptions)rqrrr current_task ensure_future to_threadrrrE set_resultrfloatCancelledErrorr*r)rrrr  set_exceptiongather) rIrrrrrrrrrvrr&s &&&&f& @rrGatewayConnection._commandsR-- ? A%G##%$$W%6%6tyy%AB KL ?yyyF !! 6([E%L([TZ(["[\!y HHJ..> > >!"[!yyy%%   &c#566(HU   % % & ? HHJ..> > >sA8G6=D>DD>=D"D D" D>%D &D>*+G6F>G6D>D" D>"D; (D+) D; 4D; 6D>:G;D>>F;GF;F;AF61G6F;;G>G6,G3,G/-G33G6c D^RIHpVf\MTpVeV!4'd \V4hVP WV4wrx\ P !4V,^,p VeOV!V.R4P'g5\ P !4V 8dV!4'gKG\V4hVP\V \ P !4, ^44V3# \d%p TP4\RT 24T hRp ? ii;i)a``(result, epoch)``: the epoch of the socket that carried the request, so work it admitted is tied to that gateway life even if another caller redials before this one reads ``epoch``. ``abandon`` (polled) true stops the wait with :class:`CallStopped`; the answer is dropped.)rNg?zGateway did not answer ) rrrr rrrr rr TimeoutErrorrr) rIrrrrrr futurer,rrs &&$$, rrGatewayConnection.call_taggeds ,(/$W  799f% % 66: >>#f,q0 R%dF8S.A.F.F.F4>>K[^fKf99%f--==X0@%@!!DEuL L R MMO$'>vh%GHc Q Rs%'C0$C0.AC00 D;DD)rrqrr}rwr|rrrr~ryrvrr,rtrrrxrur2)Z)"rrrrrrzrrrJ classmethodrpropertyrrrrrrrrrrrrrrrrrrr"rrrr rrrorosG>>#L*@ NN "\H <- = = I#$A*  WdWDW l"+H?0RTR4RRrro)r __future__rrloggingrrrzrrrrrr getLoggerrrrr  frozensetRESUME_REFUSALSrrr rr.r0ror rrr?s #  ss   8 $S  Q[*=>?!3 44 02EFGc$c gd]!]!@URURr