Struct MockRuntime 

pub struct MockRuntime {

    pub sessions: Vec<SessionSnapshot>,
    pub gate_mode: Mutex<Option<BrainGateMode>>,
    pub decisions: Vec<DecisionSummary>,
    pub review_queue: Vec<ReviewItemSummary>,
    pub leases: Vec<LeaseSummary>,
    pub handoffs: Vec<HandoffSummary>,
    pub interrupts: Vec<InterruptSummary>,
    pub tasks: Vec<TaskSummary>,
    pub agents: Vec<AgentDirectoryEntry>,
    pub roles: Vec<RoleBinding>,
    pub peers: Vec<(String, Option<String>)>,
    pub discovered: Vec<DiscoveredMachine>,
    pub discovery_unavailable: bool,
    pub actions_log: Mutex<Vec<MockAction>>,
}

In-memory runtime backed by Vecs and interior-mutable counters. Used by tests in this crate to verify the trait shapes compile and roundtrip cleanly, and by the future claudectl-tui crate’s tests to render the TUI against fixtures without dragging in brain / coord / bus.

Actions impls record their calls in actions_log so tests can assert “the TUI invoked the right side-effect” without spying on real I/O.

Fields

sessions: Vec<SessionSnapshot>

gate_mode: Mutex<Option<BrainGateMode>>

decisions: Vec<DecisionSummary>

review_queue: Vec<ReviewItemSummary>

leases: Vec<LeaseSummary>

handoffs: Vec<HandoffSummary>

interrupts: Vec<InterruptSummary>

tasks: Vec<TaskSummary>

agents: Vec<AgentDirectoryEntry>

roles: Vec<RoleBinding>

peers: Vec<(String, Option<String>)>

Paired peers hive_view_snapshot reports, so a test can exercise the peer picker without a relay on the machine running the suite.

discovered: Vec<DiscoveredMachine>

Machines start_discovery reports, so a test can drive the Hive tab’s nearby listing without a network.

discovery_unavailable: bool

When set, start_discovery answers None, the way a build without the relay feature does, so the tab’s “cannot listen” path has a test.

actions_log: Mutex<Vec<MockAction>>

Implementations

impl MockRuntime

pub fn into_runtime(self) -> Runtime

pub fn into_runtime_shared(self) -> (Arc<Self>, Runtime)

Like into_runtime, but hands back the Arc as well so a test can read actions() after the TUI has driven the runtime. into_runtime alone moves the mock out of reach.

pub fn actions(&self) -> Vec<MockAction>

Trait Implementations

impl Actions for MockRuntime

fn terminate_session(&self, pid: u32) -> Result<(), String>

Terminate the OS process with the given PID. The TUI uses this for “kill session” hotkeys.

fn inject_text(&self, session_id: &str, text: &str) -> Result<(), String>

Inject text into the session’s terminal. Implementations pick the right backend (tmux, Kitty, etc.) from the session metadata.

fn set_gate_mode(&self, mode: BrainGateMode) -> Result<(), String>

Update the persisted brain gate mode. Reflected back through BrainView::gate_mode on the next call.

fn log_observation(&self, observation: ObservationInput) -> Result<(), String>

Record an observation about a user action — non-LLM “the user did X.” Drives the brain’s outcome telemetry and preference distillation.

fn log_decision(&self, input: LogDecisionInput) -> Result<(), String>

Record a user’s accept/reject decision on a brain suggestion. The distinction from log_observation is that log_decision carries the actual suggestion that was on screen — the brain pairs it with the user’s response for outcome telemetry, counterfactual analysis, and few-shot retrieval.

fn mark_canonical( &self, decision_id: &str, note: Option<String>, ) -> Result<(), String>

Mark a past brain decision as canonical for teaching. Optional note is the operator’s annotation. Used by the Brain Review surface.

fn bind_bus_role(&self, name: &str, cwd: &str, pid: u32) -> Result<(), String>

Bind an agent-bus role to a (cwd, pid) pair. The TUI calls this from the new role-bind key (Ctrl+R) so the operator can attach a role to a specific running Claude session without dropping to another terminal. Returns Err when the bus feature is compiled out or the DB write fails. See issue #307.

fn cancel_task(&self, task_id: &str) -> Result<(), String>

Cancel a supervisor task (move it to CANCELLED). Used by the Supervisor panel’s one-key cancel (#368). Err when the coord feature is compiled out, the task is already terminal, or the store write fails.

fn set_supervisor_drain(&self, draining: bool) -> Result<(), String>

Set or clear the supervisor drain marker. When draining, the reconciler stops issuing new task assignments while letting running tasks finish. Err when the coord feature is compiled out.

fn retry_task(&self, task_id: &str) -> Result<(), String>

Re-queue a failed/cancelled task (move it back to PENDING so the reconciler re-assigns it). Err for a DONE task (nothing to retry), a still-active task, or when the coord feature is compiled out.

fn approve_task(&self, task_id: &str) -> Result<(), String>

Approve a NEEDS_HUMAN task — accept the work as-is and move it to DONE, overriding the verifier that escalated it. Err when the task isn’t in NEEDS_HUMAN, or the coord feature is compiled out.

fn send_session_to_peer( &self, session_id: &str, transcript: Option<&Path>, cwd: &str, peer: &str, ) -> Result<String, String>

Move a conversation to a paired peer, so it can be resumed there (#510). The TUI calls this from the send hotkey; transcript is the path session discovery already resolved, which is more reliable than re-deriving it from cwd and the id.

impl BrainReviewView for MockRuntime

fn all_decisions(&self) -> Vec<DecisionSummary>

Every decision on disk, newest first. Used by the Brain Review screen to render the full history list.

fn review_queue(&self) -> Vec<ReviewItemSummary>

Priority-ordered review queue. Built from all_decisions() plus the brain’s queue-building heuristics (counterfactual hits, Critical-tier safety cases, high-confidence misses).

impl BrainView for MockRuntime

fn gate_mode(&self) -> BrainGateMode

fn recent_decisions(&self, n: usize) -> Vec<DecisionSummary>

Most recent n decisions, newest first.

fn decision_count(&self) -> usize

Total count of brain decisions on disk. Drives the “decisions: N” status line.

impl BusView for MockRuntime

fn list_agents(&self) -> Vec<AgentDirectoryEntry>

fn list_roles(&self) -> Vec<RoleBinding>

impl CoordView for MockRuntime

fn active_leases(&self) -> Vec<LeaseSummary>

fn pending_handoffs(&self) -> Vec<HandoffSummary>

fn pending_interrupts(&self) -> Vec<InterruptSummary>

fn tasks(&self) -> Vec<TaskSummary>

Supervisor task lifecycles, newest first. Empty when the coord feature is off so the TUI can render a “no supervisor” state without cfg.

impl Default for MockRuntime

fn default() -> Self

Returns the “default value” for a type.

impl HiveActions for MockRuntime

fn shared_skill_keys(&self) -> HashSet<String>

Semantic keys (skill:<lowered-name>) of skills already shared into the local hive store. Used by the Skills overlay to mark “already shared” rows.

fn share_skill(&self, _skill: &DiscoveredSkill) -> Result<String, String>

Share a discovered skill into the local hive store. Returns the new unit ID on success.

fn hive_view_snapshot(&self) -> HiveViewSnapshot

Current view of the local relay identity + known peers for the Hive tab.

fn start_discovery(&self) -> Option<Box<dyn DiscoveryListener>>

Begin listening for nearby relays and the hives they name.

impl Orchestrator for MockRuntime

fn deliver_mailbox(&self, _sessions: &[SessionSnapshot]) -> Vec<(u32, String)>

Drain pending mailbox messages addressed to running sessions and deliver them to the live terminals. Used by App::tick to surface "Brain → sess_X: 'go ahead'" style messages.

fn deliver_interrupts( &self, _sessions: &[SessionSnapshot], ) -> Vec<(String, String)>

Deliver pending coordination interrupts (cross-agent signals) to running sessions. Returns (interrupt_id, status_message) tuples.

fn expire_stale(&self, _live_session_ids: &[String])

Expire stale leases and interrupts that have passed their deadline. Bookkeeping side-effect; best-effort, no return. Implementations log failures rather than propagating them.

impl SessionSource for MockRuntime

fn list(&self) -> Vec<SessionSnapshot>

Snapshot of every running Claude Code session. Order is the implementor’s choice; the TUI sorts again client-side.

fn detail(&self, session_id: &str) -> Option<SessionSnapshot>

Fetch a specific session by its ID. None when the session has exited or never existed.