+ Wj;Rt^RIHt^RIt^RIt^RIt^RIHt]P!] 4t Rt ^4rrc]tRt^-tRt]R4tRtRtRR/Rlt Rt R t R t R t R tR tRt]3RltRtRR/RltRRltRtR#)GatewayProcessViewc WnVPVn.VnRVn^VnRVn\ P!4Vn.Vn RVn RVn \ P!4Vn RVn RVnR#)Tr N)agent connectionrowsdirty delegations_polled threadingLock_lock subagents_subagents_polled_subagents_seen_subagents_lock_tail_subagents_watch_until)rr's&&rrGatewayProcessView.__init__.st **   ^^% !!$"(~~/ &)#rc .VPP#N)r'rrs&rrGatewayProcessView.session_id=szz$$$rc RVnR#)TN)r*r9s&r mark_dirtyGatewayProcessView.mark_dirtyBs  rc a\;QJd)V3RlVP4F 'gK R# R#!V3RlVP44#)c3<"TFKqP'*;'g/VP;'dSVP, \8*xKM R#5ir8)rr _RETAIN_SECONDS).0pnows& r 2GatewayProcessView._interesting..Fs=mcl^_xx<YYAKK$X$XC!++4E4XYclsAA#ATF)anyr))rrCs&fr _interestingGatewayProcessView._interestingEs:smcgclclmssmsmsmcgclclmmmrforceFc \P!4pV'gGW P, \8g*VP'gVP V4'gR#VP P RR7'gR#W nRVnVPPRVP^R7pT;'g/PR4;'g.Uu.uFp\V4NK upVn VP P#4R#uupi \\3d!p\P!RT4Rp?LMRp?ii;i TP P#4i;i)NFblockingz process.listrtimeout processeszprocess.list failed: %s)timer, _POLL_SECONDSr*rGr/acquirer(callrrrr)r RuntimeErrorloggerdebugrelease)rrIrCresultrexcs&$ rrefreshGatewayProcessView.refreshHsiik# ,}.bs@ 1TTZ-?QQ s$ $N)nextr))rres&frrGatewayProcessView.getas@ @$GGrc :\RVP44#)z7Cached (the status bar repaints off the render thread).c3L"TFqP'dK^xK R#5i)N)r)rArBs& rrD3GatewayProcessView.count_running..fs8ixx11is$ $)sumr)r9s&r count_running GatewayProcessView.count_runningds8dii888rc VPPRVPVR7pTP RR7T# \dpRRR\ T4/uRp?#Rp?ii;i)z process.kill)rrererrorNTrI)r(rSrrstrrZ)rre_kwrXrYs&&, r kill_processGatewayProcessView.kill_processhsa :__)).T__ak)lF 4   " :gwC9 9 :s(> A" AA"A"c "VPPRVPR7;'g/p\VP R4;'g^4VnVP RR7\VP R4;'g^4#)zZ``/stop``: the session's own processes plus its background delegations (``process.stop``).z process.stoprr+Trrkilled)r(rSrr`rr+rZ)rrtrXs&, rkill_allGatewayProcessView.kill_allpsp%%n%QWWUWvzz-8==A> 4  6::h',,1--rc VP'dVP^uqnV#VP4VP^uqnV#)zXThe delegation half of ``/stop`` (``kill_all`` already ran it when processes were live).)r+rz)rcounts& rinterrupt_delegations(GatewayProcessView.interrupt_delegationswsG    &*&6&6 #E#L "&"2"2A rc VPPVP4P;'g/pTP R4p\ T\4'dT#^# \d^#i;i)zPRunning background subagents (the gateway's ``session.usage.active_subagents``).active_subagents)r(staterusage Exceptionr isinstancer`)rrvalues& ractive_delegations%GatewayProcessView.active_delegationssi OO))$//:@@FFBE ,-"5#..u5A5  s5A&A&& A54A5c V\P!4V,VnRVnR#)zPoll ``subagent.list`` for a while even with no turn running: an off-turn spawn (``/review``) moves neither ``busy`` nor the usage count the gate below reads.r N)rPr5r1)rsecondss&&rwatch_subagents"GatewayProcessView.watch_subagentss'+iikG&;#!$rc \P!4pT;'g;VP;'g'W P8;'gVP4pV'dW P, \ 8dVP PRR7'dW nVPPRVP^R7p\T;'g/PR4;'g.4VnW n VP P'4VPUu.uFp\)V4NK up# \\3dCp\ P#RT4Y P, \$8d.TnRp?LRp?ii;i TP P'4i;iuupi)zThe session's live children (``subagent.list``). Asks at most once a second, and only while a turn runs (``busy``), children were listed last time, the gateway counts some, or an off-turn spawn asked to be watched.FrKz subagent.listrMr0zsubagent.list failed: %sN)rPr0r5rr1rQr3rRr(rSrlistrr2rrTrUrVr@rWdict)rbusyrCwantedrXrYrs&$ r subagent_rows GatewayProcessView.subagent_rowss\iik//$..//C2M2M,M//,,.  c222mCH\H\HdHdnsHdHtHt /),&--o$//cd-e!%v||&8&8&E&K&K!L'*$ $$,,.%)^^4^cS ^44 ' 5 ( 7=---?%'DN ( $$,,.4s7 AE5E/F;F8FFFFF8fetchc \P!4pVP'd%VP^,V8Xd VPMRpV'd!V'd,W4^,, \8dV'd V^,#R#VPP RVP V^R7;'g/pVP R4'dVP R4MRpVeRPRV44pYT3TnT# \\3d#p\PRT4RpRp?L9Rp?ii;i) aThe child's live transcript tail (``subagent.tail``); None when the gateway has none. The detail view repaints every frame and reads only the cache; ``fetch`` (the monitor's tick, on the spinner thread) asks the gateway at most once a second, failures included.Nz subagent.tailr subagent_idrN availabletextrc3b"TF%qP4'g VR9gK!VxK' R#5i)z N) isprintable)rAcs& rrD3GatewayProcessView.subagent_tail..s Q$Q--//Q&[qq$s/ /zsubagent.tail failed: %s) rPr4rQr(rSrrjoinrrTrUrV)rrrrCcachedrXrrYs&&$ r subagent_tail GatewayProcessView.subagent_tails iik#zzzdjjm{.JPTC)Om$C &6!9 0D 0 __))/doo6A1*NTTQS )/K)@)@6::f%dDwwQ$QQ"-  #L1  LL3S 9D s$ /D:D/DED<<ENc ^RIHpWA,wrVpVR8XdIVPPRVPW#^R7;'g/pVP R4R8Hp MNVPPRVPV^R7;'g/p\ VP R 44p R Vn V 'd R VRVRVRV/#R VPVR7/# \dp R \T 4/uR p ? #R p ? ii;i)zSteer (``subagent.steer``) or stop (``subagent.interrupt``) one child of this session, in the shape ``delegate_tool_registry._handle_control_action`` answers: ``note`` or ``error``.)_CONTROL_OUTCOMESsteerzsubagent.steer)rrrrNrqueuedzsubagent.interruptrfoundrqNr actionrnote)sid) tools.delegate_tool_registryrr(rSrrboolrrsr1format) rrrmessagerrrfailurerXokrYs &&&& rsubagent_control#GatewayProcessView.subagent_controls C 1 9g ' --.>4??:E]^.`ffceZZ)X5--.Bt:Eq.RXXUW&**W-."% fm[(FTZ\`a aK899 " 'SX& & 's/6C C"/CC C?( C:4C?:C?) r/r,r3r1r2r5r4r'r(r+r*r)r0r8)rrrr rpropertyrr<rGrZrarrnrurzr~rr@rrrrr"r#rrr%r%-s| *%%n!u!"gH9.6'6% 5*%(::rr%c>]tRt^tRtRtRtRR/RltR RltR t R#) LocalSubagentszThis process's own subagent registry behind the view's ``subagent_*`` surface, for a CLI that runs its agent in-process: the dock and monitor talk to one backend shape either way.c Wn/VnR#r8)cli_paths)rrs&&rrLocalSubagents.__init__s rc ^RIHpHp\VPRR4pVeV!V4R,M.pV'dV!4Uu/uF qfR,VbK upM/pVFOpVP VR,/4p V P R4V P R4;'gRuVR&VR&KQ VUu/uFqR,VP R 4bK upVnV#uupiuupi) ) _list_payloadlist_active_subagentsr'Nr0rr last_toolrlive_transcript)rrrgetattrrrr) rrrrparententriesrliverrecords &$ rrLocalSubagents.subagent_rowssU7D18>8J-' 4PRJQ-B-DE-D- !#-DEVXCXXc-0"5F28**\2JFJJWbLcLiLigi /C s;/RYYQX#=)3773D+EEQXY  FZs C!6!C&rFc P^RIHpV!VPPV44#)r) read_tail)hermes_cli.cli_subagent_monitorrrr)rrrrs&&$ rrLocalSubagents.subagent_tails=566rNc  r^RIp^RIHpVPV!WV\ VP RR444#)rN)_handle_control_actionr')jsonrrloadsrr)rrrrrrs&&&& rrLocalSubagents.subagent_controls3Gzz0gwW[W_W_ahjnOopqqr)rrr8) rrrr r!rrrrr"r#rrrrs*] 7%7rrrrc0]tRt^tRtRt]R4tRtR#)_OpenedSessionzThe CLI's open gateway session before any chat agent exists (``_init_agent`` builds that on the first turn): the view's ``connection`` and ``session_id``, following the CLI's id.c "WuVnVnR#r8rr()rrr(s&&&rr_OpenedSession.__init__s$'!$/rc .VPP#r8)rrr9s&rr_OpenedSession.session_idsxx"""rrN) rrrr r!rrrr"r#rrrrs!Z4##rrcR\VRR4e\V4s\#Rs\#)z4Called when the CLI's gateway-backed agent is built.r(N)rr%_view)r's&rbindrs0*1 d)K)W u %E L^bE Lrc*\\W44#)zCalled when the CLI opens its gateway session, so ``/agents``, ``/stop``, the dock and the status bar read the session's processes before the first turn (a resumed session's work keeps running).)rrrs&&r bind_sessionrs s/ 00rcB\e\P4R#R#r8)rr<r#rrr<r<s  rcV\pVeVPP'gV#R#)zThe gateway-backed registry, or None when this process runs its own tools (not rewired) or its gateway connection is final (a hang-up keeps the view; its next call redials).N)rr(final)views r process_viewr s( D#DOO,A,A,A4KtKrc2\4pVeV#^RIHpV#)zV``tools.process_registry.process_registry`` for main's dock, status bar and ``/stop``.process_registry)rtools.process_registryr)rlocals rrrs >D  @ Lrc\4pVe#RVP4RVP4/#^RIHp^RIHpRVP4RV!4/#)uWThe status bar's ``⚙ N`` processes and running background subagents (cached, no RPC).active_background_processesactive_background_subagents) active_countr)rrnrtools.async_delegationrrr)rrrs rbackground_countsrsZ >D -t/A/A/C-t/F/F/HJ J3@ )5+>+>+@B_amao pprc \4pVfR#VPPRVPR7;'g/p./r2VP R4;'g.FxpVP R4;'g.FVpVP R4W5R,&TP RRRRVR,R VP R 4;'gR //4KX Kz W#P3#) z``/tools``: the gateway session's tool catalog (``tools.show``) as ``(tools, toolset_of)``: ``get_tool_definitions``-shaped rows (first description sentence) and a name -> toolset lookup. None when the CLI is not gateway-backed.Nz tools.showrxsectionstoolsnametypefunction descriptionr)rr(rSrrappend)rrXr toolset_ofsectionrs r session_toolsr(s >D | __ ! !,4?? ! K Q QrFB:::j)//R/;;w'--2-C&-kk&&9J6{ # LL&*j63v;;H#''R_J`JfJfdf;hi j.0 ..  rc\4pVfR#VPPRVPR7;'g/P R4# \ d"p\ PRT4Rp?R#Rp?ii;i)zRescan skills in the gateway session too (its skill-command map serves this session's ``/`` and bundle invocations); the CLI's own rescan still drives main's output.Nz skills.reloadrxrXzskills.reload failed: %s)rr(rSrrrrUrV)rrYs rreload_gateway_skillsr9sm >D |$$_$QWWUW\\]eff  /5s-AA A>A99A>c^^RIHpV!W4\4Ve^RIHpV!V4R#R#)zMain's ``/skills`` (hub search / install / uninstall write the local skills tree), then the gateway's rescan so an install reaches the skill map the session's turns use, and ``cli``'s copy of the gateway's skill list is read again.)handle_skills_slashN) invalidate)hermes_cli.skills_hubrr"hermes_cli.gateway_plugin_commandsr)cmdconsolerrrs&&& rrrFs*C # A3rr8)r! __future__rloggingr-rPhermes_cli.gateway_clientr getLoggerrrUrQr@rrr%rrrrr<rrrrrrr#rrrs # 8   8 $   4 4`:`:Frr> # #1  Lq!"  r