Enum SessionCommand 

pub enum SessionCommand {
    Submit {
        text: String,
        attachments: Vec<Value>,
    },
    Steer {
        text: String,
    },
    SubagentSteer {
        handle_id: String,
        text: String,
    },
    Cancel,
    Answer {
        prompt_id: u64,
        value: Option<String>,
    },
    Set {
        id: u64,
        setting: SessionSetting,
    },
    Compact {
        instructions: Option<String>,
    },
    NewSession,
    Save,
    Query {
        id: u64,
        query: SessionQuery,
    },
    Attach {
        client: ClientMeta,
        mode: AttachMode,
    },
    Detach {
        client: ClientId,
    },
    End {
        reason: EndReason,
    },
    Resync {
        client: ClientId,
        since_seq: u64,
    },
    EngineCommand {
        id: u64,
        name: String,
        arg: String,
    },
    SubmitPrepared {
        messages: Vec<SharedMessage>,
        user_text: Option<String>,
    },
    PluginCommand {
        id: u64,
        plugin: String,
        name: String,
        arg: String,
    },
    Resume {
        id: u64,
        query: String,
    },
    Checkpoint {
        reason: CheckpointReason,
    },
    KeepWarm {
        on: bool,
    },
    TakeInput,
    Park,
    AdoptWorkers {
        workers: Vec<CarriedWorker>,
    },
    RestoreToolActivations {
        activations: Vec<CarriedActivation>,
    },
    ArmPark,
    ReloadAborted,
    HostEvent(HostEvent),
    DriverStart {
        plugin: String,
        command: String,
        arg: String,
    },
}

The entire client→session control surface (SEAMS §5.2/§5.3).

Debug is manual: Submit/Steer/SubmitPrepared/Answer/Resume print <redacted> (no lengths) so a command can be traced by type.

Variants

Submit

User-authored prompt. Actor: reset auto-turn counter, push user msg verbatim, start turn.

Fields

text: String

attachments: Vec<Value>

Pre-built canonical user content blocks (images, documents) produced by PendingAttachments::build_content on the client. Empty ⇔ text-only (backward compatible).

Steer

Text typed while streaming. Actor: steer if a steer_tx is live else queue; ALWAYS also sets queued_message.

Fields

text: String

SubagentSteer

Steer one of this session’s running subagents (sa_N) from its watch view. Owner-only like Steer. The note also enters the MAIN conversation as an event (no auto-turn), so the main agent knows the user redirected its worker. Failure → Refused.

Fields

handle_id: String

text: String

Cancel

Esc. Cancel, adopt the turn’s partial history + append the interruption marker (engine::interrupt), dequeue, flush pending events, cancel subagents, save.

Answer

Answer to a PromptRequest. None = cancelled. NEVER journaled, NEVER replayed, NEVER traced.

Fields

prompt_id: u64

value: Option<String>

Set

id is client-chosen and echoed in SettingChanged.id.

Fields

id: u64

setting: SessionSetting

Compact

Fields

instructions: Option<String>

NewSession

/new: ConversationState::clear.

Save

Query

Reply = SessionEventWire::QueryResult { id, value }.

Fields

id: u64

query: SessionQuery

Attach

Reply = Attached { client_id, … } on THIS client’s channel only.

Fields

client: ClientMeta

mode: AttachMode

Detach

Fields

client: ClientId

End

Host shutdown of this session: save → on_session_end → leases → Ended.

Fields

reason: EndReason

Resync

Resync after Lagged (B, day 3): actor re-sends history + turn_replay.

Fields

client: ClientId

since_seq: u64

EngineCommand

Runtime-backed slash command (engine::commands::handle_engine_command: /model /thinking /context /trace /memory /compact …). Reply = QueryResult { id, value: {"kind": .., "text": ..} }.

Fields

id: u64

name: String

arg: String

SubmitPrepared

(A3) dispatch.rs LoadSkill — pre-built tool_use/tool_result pair (+ optional user text) then a turn. Does NOT reset consecutive_auto_turns.

Fields

messages: Vec<SharedMessage>

user_text: Option<String>

PluginCommand

(A3) tools-backed (non-interactive) plugin command on THE runtime’s tool set. Reply = QueryResult{id, {kind:"plugin_output", ..}}.

Fields

id: u64

plugin: String

name: String

arg: String

Resume

(A3) /resume: save current, load query, restore model/reasoning/ system prompt, swap conversation. Reply = Resumed{id, ..}.

Fields

id: u64

query: String

Checkpoint

(B1, used by C3 reload) cancel any turn (partial history + marker), abort compaction, save, close PTYs, emit Notice. Never ends the session. Reply = QueryResult{id: CHECKPOINT_QUERY_ID, {ok:true}}.

Fields

reason: CheckpointReason

KeepWarm

(B3) pin/unpin (/pin on|off, --keep-warm, /keep-warm on|off, synaps daemon pin). Published on SessionHandle::pinned().

Fields

on: bool

TakeInput

(B1) /takeover: the sending client takes input ownership in place, like an --takeover attach without re-attaching. Not an input command (a read-only client sends it); refused from an Observe client, a no-op from the owner. Emits InputOwnerChanged{Takeover} (Attach when nobody owned input).

Park

Host-only (never wire): park now if can_park() (reload rehydrates a Parked session Parked). A no-op otherwise.

AdoptWorkers

Host-only (never wire): reload’s rehydrate hands the new image the workers the old image stopped or still owed a wake (SessionReloadRecord::workers). The actor re-registers their ids against their archives and wakes the parent once per worker.

Fields

workers: Vec<CarriedWorker>

RestoreToolActivations

Host-only (never wire): reload’s rehydrate hands the new image the exact tool activations the session held in the previous image (SessionReloadRecord::tool_activations). The runtime re-validates and restores them at its first turn start; a parked session keeps them for its unpark. Sent before anything can start a turn.

Fields

activations: Vec<CarriedActivation>

ArmPark

Host-only (never wire): reload’s rehydrate, last, for a session that comes back Live. The old image’s park timer did not survive the exec and only an attach or detach arms a new one, so a session no client reconnects to stayed Live with zero clients forever. Arms the park grace as a detach does; a client reconnecting within it clears it. A no-op on a parked session.

ReloadAborted

Host-only (never wire): the reload this session checkpointed for did not exec (the exec failed, or the reload stopped after the checkpoints). The checkpoint’s reload fence lifts, and the workers the reload stopped are announced to this same image.

HostEvent(HostEvent)

Host→session (never wire): the actor re-emits as SessionEventWire.

DriverStart

(E-P0) Start or re-arm the session driver for plugin. command is the interactive command name (e.g. “auto”); arg is everything after the command (“start – do X”). No DriverStop — Cancel handles that (§2).

Fields

plugin: String

command: String

arg: String

Implementations

impl SessionCommand

pub fn refused_while_reloading(&self) -> bool

Refused while a daemon reload has checkpointed the session (its reload fence is up) until the exec, or until the daemon reports the exec failed: anything that starts a turn (a Steer with no turn running is a Submit), changes the conversation or journal the record points at, launches or steers work, or changes a setting the record already carries. Cancel, answers, queries, saves and attach/detach stay open.

Trait Implementations

impl Debug for SessionCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SessionCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SessionCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.