Struct SubagentWatcher 

pub struct SubagentWatcher {
    event_bus: Arc<EventBus>,
    sessions: Mutex<HashMap<String, SessionWatch>>,
    watched_agents: Mutex<Vec<WatchedAgent>>,
}

Fields

event_bus: Arc<EventBus>

sessions: Mutex<HashMap<String, SessionWatch>>

watched_agents: Mutex<Vec<WatchedAgent>>

Implementations

impl SubagentWatcher

pub fn new(event_bus: Arc<EventBus>) -> Self

pub fn spawn(event_bus: Arc<EventBus>) -> Arc<Self>

Create a new SubagentWatcher and return it wrapped in Arc.

pub fn watch_agent( self: &Arc<Self>, agent_id: &str, parent_block_id: &str, config_dir: PathBuf, )

Start watching a Claude Code agent’s session directory for subagent files. Spawns a background tokio task for debounced file event processing.

parent_block_id is the pane/block that owns this Claude instance (from the reactive register request). It is stamped onto every emitted subagent event so the frontend can route the ⚡ panel to the originating pane only, instead of every agent pane rendering every subagent globally.

Note: the watcher dedupes by agent_id, so if the same agent_id is registered from two blocks, events carry the first registrant’s block id. That edge case (same instance name in two panes) is rare; the common leak — a terminal Claude’s subagents showing up in unrelated agent panes — is fully fixed because the terminal block id never matches an agent pane.

pub fn unwatch_agent(&self, agent_id: &str)

Stop watching an agent: drop its filesystem watcher, which closes the debounce channel — so the processing task self-terminates on the next rx.recv() returning None. Idempotent: a no-op if the agent isn’t currently watched.

Without this, watched_agents was push-only: every distinct agent that ever ran leaked one OS watch handle + channel + idle task for the rest of the process lifetime, even after its pane/agent was deleted. (Session records in sessions are plain data, not handles, and are left as-is.)

pub fn list_active(&self) -> Vec<SubagentInfo>

List all subagents across all sessions (sync — safe to call from RPC dispatch).

pub fn get_history(&self, agent_id: &str, limit: usize) -> Vec<SubagentEvent>

Get recent events for a specific subagent (sync — safe to call from RPC dispatch).

fn scan_existing_subagents( &self, parent_agent: &str, parent_block_id: &str, projects_dir: &Path, )

Scan for existing subagent JSONL files in a projects directory.

fn process_jsonl_change( &self, parent_agent: &str, parent_block_id: &str, jsonl_path: &Path, )

Process a changed/new JSONL subagent file. Reads new lines, updates state, and broadcasts events via EventBus.