Enum Cmd 

pub enum Cmd {
    CallModel {
        turn: TurnId,
        request: ChatRequest,
    },
    CompactConversation {
        turn: TurnId,
        request: CompactionRequest,
    },
    ExecuteTool {
        turn: TurnId,
        call_id: ToolCallId,
        source: ToolCall,
        model_id: String,
        safety_mode: SafetyMode,
        intent: Option<String>,
    },
    CancelScope(TurnId),
    BackgroundScope(TurnId),
    ResolveApproval {
        call_id: ToolCallId,
        decision: ApprovalChoice,
    },
    SaveConversation(ConversationHistory),
    SaveCompactionArchive {
        archive: CompactionArchive,
        record: CompactionRecord,
        conversation: ConversationHistory,
    },
    SaveProcess(ManagedProcess),
    PersistLastModel(String),
    PersistReasoningFor {
        model_id: String,
        level: ReasoningLevel,
    },
    PersistOllamaNumCtxFor {
        model_id: String,
        num_ctx: Option<u32>,
    },
    PersistOllamaOffload(bool),
    ListMemory,
    RememberMemory {
        text: String,
    },
    ForgetMemory {
        id: String,
    },
    ConsolidateMemory {
        model_id: String,
    },
    LoadConversation(String),
    ListConversations,
    ListRuntimeTasks {
        limit: usize,
    },
    LoadRuntimeTask {
        id: String,
    },
    ListRuntimeProcesses {
        limit: usize,
    },
    ShowRuntimeProcessLogs {
        id: String,
    },
    StopRuntimeProcess {
        id: String,
    },
    RestartRuntimeProcess {
        id: String,
    },
    OpenRuntimeTarget {
        target: String,
    },
    ShowRuntimePorts,
    ListRuntimeApprovals,
    DecideRuntimeApproval {
        id: String,
        decision: String,
    },
    ListRuntimeCheckpoints {
        limit: usize,
    },
    ListRuntimePlugins,
    UpdateRuntimeTaskStatus {
        id: String,
        status: TaskStatus,
        final_report: Option<String>,
    },
    CreateRuntimeCheckpoint {
        paths: Vec<PathBuf>,
    },
    RestoreRuntimeCheckpoint {
        id: String,
    },
    ShowRuntimeModelInfo {
        model: String,
    },
    InitMcpServers(HashMap<String, McpServerConfig>),
    StopMcpServer {
        name: String,
    },
    PullOllamaModel {
        model: String,
    },
    OpenInSystem(PathBuf),
    WriteImageToTemp {
        path: PathBuf,
        bytes: Vec<u8>,
        format: String,
    },
    ReadClipboard,
    CopyToClipboard(String),
    Exit,
    SetTerminalTitle(String),
}

A single side-effect request. Most variants are one-shot; CallModel and ExecuteTool spawn long-running tasks inside a per-turn TurnScope.

Variants

CallModel

Dispatch the next chat request. Effect runner maps this onto ModelProvider::chat for the session’s active provider.

Fields

turn: TurnId

request: ChatRequest

CompactConversation

Generate a compact context checkpoint without continuing into a normal assistant turn.

Fields

turn: TurnId

request: CompactionRequest

ExecuteTool

Run one tool in parallel with any other tools in the same turn. The runner wires ExecContext::token to the turn’s scope so Cmd::CancelScope aborts them all at once.

model_id is the active session’s model id at the moment this tool call was emitted. The runner passes it into ExecContext so tools like SubagentTool can spawn children against the same provider the parent is using.

Fields

turn: TurnId

call_id: ToolCallId

source: ToolCall

model_id: String

safety_mode: SafetyMode

Effective live safety mode (from state.session.safety_mode) at the moment this call was emitted. The runner builds the policy gate / Auto classifier from this rather than the static config.

intent: Option<String>

The user’s stated intent for the turn (latest user message), passed to the Auto-mode classifier as alignment context.

CancelScope(TurnId)

Cancel every task in the given turn’s TurnScope. After the scope’s JoinSet drains (bounded by a ~2s timeout), the runner emits a single Msg::TurnCancelled(turn) — that, not Msg::StreamDone, is the terminal event that lets the reducer transition Cancelling → Idle. A same-id Msg::StreamDone that races the drain does NOT end the turn: handle_stream_done only acts on a Generating turn and restores the prior state (Cancelling) otherwise, so TurnCancelled stays the one terminal signal for a cancel.

BackgroundScope(TurnId)

Ctrl+B: signal the turn’s scope to BACKGROUND (not cancel) its running work. The scope’s background token fires; detachable tools (execute_ command) move their child to a background process and return. The scope is left intact (unlike CancelScope).

ResolveApproval

Resolve an inline approval prompt: deliver the user’s decision to the parked tool task via the ApprovalBroker. NOT turn-scoped — it’s a fire-and-forget to the broker (the tool task it unblocks is the turn-scoped work).

Fields

call_id: ToolCallId

decision: ApprovalChoice

SaveConversation(ConversationHistory)

Save the current conversation to disk. No-op if unchanged since last save (effect-side idempotence).

SaveCompactionArchive

Persist the raw messages removed by a compaction, then the compacted (message-stripped) conversation. Both are written by ONE effect task, archive first — only overwriting the conversation if the archive persisted — so a failed/lagging archive can never lose messages while the stripped conversation is saved over the old one.

Fields

archive: CompactionArchive

record: CompactionRecord

conversation: ConversationHistory

SaveProcess(ManagedProcess)

Persist a daemon-visible background process record.

PersistLastModel(String)

Persist the active model ID as last_used_model.

PersistReasoningFor

Persist reasoning level tied to a specific model ID.

Fields

model_id: String

level: ReasoningLevel

PersistOllamaNumCtxFor

Persist (or clear, when num_ctx is None) a per-model Ollama num_ctx override set via /context <n>/max/auto.

Fields

model_id: String

num_ctx: Option<u32>

PersistOllamaOffload(bool)

Persist the Ollama RAM-offload toggle (/context offload on|off).

ListMemory

List saved memories; emits Msg::RuntimeText with the rendered list.

RememberMemory

Save free-text to private memory; emits Msg::MemoryChanged + status.

Fields

text: String

ForgetMemory

Delete a memory by name/id; emits Msg::MemoryChanged + status.

Fields

id: String

ConsolidateMemory

Model-assisted prune of duplicate/obsolete memories, reversible via a checkpoint. Emits Msg::RuntimeText (the report) + Msg::MemoryChanged.

Fields

model_id: String

LoadConversation(String)

Load a specific conversation by ID and emit Msg::ConversationLoaded. Reducer consumes that event to replace the current session.

ListConversations

Scan the conversations directory for the /load picker. Emits Msg::ConversationsListed with one ConversationSummary per saved session (newest first). The reducer transitions to UiMode::ConversationList and the render shows the picker.

ListRuntimeTasks

List durable daemon/runtime tasks.

Fields

limit: usize

LoadRuntimeTask

Load one durable daemon/runtime task and its timeline.

Fields

id: String

ListRuntimeProcesses

List durable daemon/runtime background processes.

Fields

limit: usize

ShowRuntimeProcessLogs

Print one durable process log into the conversation.

Fields

id: String

StopRuntimeProcess

Stop a durable process by pid.

Fields

id: String

RestartRuntimeProcess

Restart a durable process using its recorded command/cwd.

Fields

id: String

OpenRuntimeTarget

Open a URL, path, or process target.

Fields

target: String

ShowRuntimePorts

Show listening ports.

ListRuntimeApprovals

List pending approval records.

DecideRuntimeApproval

Mark one approval as approved or denied.

Fields

id: String

decision: String

ListRuntimeCheckpoints

List restore checkpoints.

Fields

limit: usize

ListRuntimePlugins

List installed plugins.

UpdateRuntimeTaskStatus

Update one durable task’s status.

Fields

id: String

status: TaskStatus

final_report: Option<String>

CreateRuntimeCheckpoint

Create a shadow checkpoint for explicit paths.

Fields

paths: Vec<PathBuf>

RestoreRuntimeCheckpoint

Restore files from a shadow checkpoint.

Fields

id: String

ShowRuntimeModelInfo

Show provider/model capability information.

Fields

model: String

InitMcpServers(HashMap<String, McpServerConfig>)

Start every configured MCP server; each one emits Msg::McpServerReady or Msg::McpServerErrored as it comes up.

StopMcpServer

Stop a running server (e.g. config was removed, or app quit).

Fields

name: String

PullOllamaModel

ollama pull <model> with progress → Msg::ModelPullFinished.

Fields

model: String

OpenInSystem(PathBuf)

xdg-open / open / start on a file path. Used by the image-paste preview and the “open in editor” affordance.

WriteImageToTemp

Persist a pasted image to a temp file so the TUI can open it via OpenInSystem. Emits no follow-up Msg on success; failure is a log-and-drop.

Fields

path: PathBuf

bytes: Vec<u8>

format: String

ReadClipboard

Read the system clipboard on a blocking task. The per-platform dispatch (xclip / wl-paste / pngpaste / PowerShell) can block for hundreds of ms on macOS via osascript, so it never runs on the reducer thread. Emits Msg::Paste(Paste::Image|Text) on success; Msg::TransientStatus when the clipboard is empty or the read fails.

CopyToClipboard(String)

Write text to the system clipboard on a blocking task (mirrors ReadClipboard’s per-platform dispatch). Used by in-app drag-select copy. Emits a Msg::TransientStatus (“Copied N chars” / failure).

Exit

Exit the main loop. No reply message — the loop observes state.should_exit after the reducer returns and breaks out.

SetTerminalTitle(String)

Write the OSC 2 terminal-title sequence. Reducer diffs against ui.last_title_dispatched so this only fires on actual title changes, not every frame.

Implementations

impl Cmd

pub fn tag(&self) -> &'static str

Human-readable tag, for tracing + replay logs. Stable across refactors (tests assert against it).

pub fn is_turn_scoped(&self) -> bool

True iff this command needs to run inside a TurnScope so it can be cancelled by Cmd::CancelScope. The effect runner uses this to decide between “spawn into JoinSet” and “spawn detached”.

pub fn scope_turn(&self) -> Option<TurnId>

The TurnId of the scope this command would spawn fresh work into. Only the scope-spawning variants return Some (the same set as is_turn_scoped); the scope-control variants (CancelScope / BackgroundScope) act on an existing scope rather than populating one with new work, so they return None.

The effect runner uses this to refuse spawning fresh work for a turn it has already cancelled (tombstoned) — a stray post-cancel CallModel/ExecuteTool/CompactConversation would otherwise resurrect an un-cancelled scope via scope_mut’s or_insert_with (F38). CancelScope must keep working on a tombstoned turn, which is exactly why it is excluded here.

pub fn summary(&self) -> String

For traces + the --record file — some Cmd payloads are huge (think ChatRequest::messages). This returns a compact identifier that doesn’t dump the full payload.

Trait Implementations

impl Clone for Cmd

fn clone(&self) -> Cmd

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Cmd

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.