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,
    },
    CancelScope(TurnId),
    SaveConversation(ConversationHistory),
    SaveCompactionArchive(CompactionArchive),
    PersistLastModel(String),
    PersistReasoningFor {
        model_id: String,
        level: ReasoningLevel,
    },
    RefreshInstructions,
    LoadConversation(String),
    ListConversations,
    InitMcpServers(HashMap<String, McpServerConfig>),
    StopMcpServer {
        name: String,
    },
    PullOllamaModel {
        model: String,
    },
    OpenInSystem(PathBuf),
    DismissStatusAfter {
        ms: u64,
    },
    WriteImageToTemp {
        path: PathBuf,
        bytes: Vec<u8>,
        format: String,
    },
    ReadClipboard,
    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

CancelScope(TurnId)

Cancel every task in the given turn’s TurnScope. After the scope drains, the runner emits a Msg::StreamDone (with a synthetic “cancelled” marker in usage, or a batch of ToolFinished { outcome: Cancelled } for tools already running) so the reducer can transition back to Idle.

SaveConversation(ConversationHistory)

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

SaveCompactionArchive(CompactionArchive)

Persist the raw messages removed by a compaction.

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

RefreshInstructions

Re-stat MERMAID.md (cheap); emits Msg::InstructionsChanged only when the mtime moved or the file appeared/disappeared.

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.

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.

DismissStatusAfter

Schedule Msg::StatusDismiss after ms milliseconds. Reducer uses this to self-clear transient status lines.

Fields

ms: u64

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.

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