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, 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.

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, projects_dir: &Path)

Scan for existing subagent JSONL files in a projects directory.

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

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