From 4c8d3804340874389518b7767ec7981ad5c2fff6 Mon Sep 17 00:00:00 2001
From: Teknium <127238744+teknium1@users.noreply.github.com>
Date: Mon, 7 Sep 2026 21:17:24 -0700
Subject: [PATCH] test(cli): synchronize monitor inputs on rendered frames

---
 tests/cli/test_subagent_monitor_ui.py | 33 +++++++++++++++------------
 1 file changed, 18 insertions(+), 15 deletions(-)

diff --git a/tests/cli/test_subagent_monitor_ui.py b/tests/cli/test_subagent_monitor_ui.py
index 33f0be6f8b..3fe154dab0 100644
--- a/tests/cli/test_subagent_monitor_ui.py
+++ b/tests/cli/test_subagent_monitor_ui.py
@@ -1,11 +1,11 @@
-"""Monitor navigation and controls run without borrowing the chat composer."""
+"""Monitor navigation keeps controls pinned while live children finish."""
 import asyncio
 from types import SimpleNamespace
 
 
-def test_monitor_keys_navigate_steer_and_preserve_chat_draft(monkeypatch):
+def test_monitor_keys_pin_controls_across_roster_changes(monkeypatch):
     from hermes_cli.cli_subagent_monitor import SubagentMonitor, build_monitor_application
-    from prompt_toolkit.buffer import Buffer
+
     from prompt_toolkit.input import create_pipe_input
     from prompt_toolkit.output import DummyOutput
     from tools import delegate_tool_registry as registry
@@ -16,8 +16,7 @@ def test_monitor_keys_navigate_steer_and_preserve_chat_draft(monkeypatch):
     for sid in ['first', 'second']:
         registry._register_subagent(dict(subagent_id=sid, goal=sid, owner_agent_session_id='owner',
             started_at=1, status='running', agent=child))
-    composer = Buffer()
-    composer.text = 'my unfinished draft'
+
     dock = SubagentMonitor(SimpleNamespace(agent=SimpleNamespace(session_id='owner')))
     dock.refresh()
 
@@ -29,24 +28,28 @@ def test_monitor_keys_navigate_steer_and_preserve_chat_draft(monkeypatch):
             app = build_monitor_application(dock, input=pipe, output=output)
             footer = app.layout.container.children[-1].content.text()
             assert 'F6' in footer and len(footer) <= 32
+            rendered = asyncio.Event()
+            app.after_render += lambda app: rendered.set()
             task = asyncio.create_task(app.run_async())
-            await asyncio.sleep(0.1)
-            pipe.send_text('\x1b[B\rsFocus on tests\r')
-            await asyncio.sleep(0.2)
-            pipe.send_text('x')
-            await asyncio.sleep(0.1)
+            await asyncio.wait_for(rendered.wait(), 3)
+
+            async def send(text):
+                rendered.clear()
+                pipe.send_text(text)
+                await asyncio.wait_for(rendered.wait(), 3)
+
+            await send('\x1b[B\rsFocus on tests\r')
+            await send('x')
             registry._active_subagents.pop('second')
             dock.refresh()
-            pipe.send_text('y')
-            await asyncio.sleep(0.1)
-            pipe.send_text('\x1b')
-            await asyncio.sleep(0.6)
+            await send('y')
+            await send('\x1b')
             pipe.send_text('q')
             await asyncio.wait_for(task, 3)
     asyncio.run(run())
     assert dock.selected_id == 'first'
     assert received == ['Focus on tests']
-    assert composer.text == 'my unfinished draft'
+
 
 
 def test_extended_tail_is_bounded_and_literal(tmp_path):