Enum SessionEventWire 

pub enum SessionEventWire {
    Stream(StreamEvent),
    TurnStarted {
        turn_baseline: usize,
        trigger: TurnTrigger,
        user_text: Option<String>,
    },
    Conversation(ConversationSnapshot),
    Prompt(PromptRequest),
    PromptResolved {
        prompt_id: u64,
    },
    External(Event),
    AutoTurnCapReached {
        cap: u32,
    },
    Idle,
    Steered {
        text: String,
        delivered: bool,
    },
    Dequeued {
        text: String,
    },
    SystemNotice(String),
    LoaderProgress(ExtensionLoaderEvent),
    ExtensionNotification {
        extension_id: String,
        method: String,
        params: Value,
    },
    SettingChanged(SettingApplied),
    QueryResult {
        id: u64,
        value: Value,
    },
    Attached {
        client: ClientId,
        snapshot: AttachSnapshot,
    },
    ClientJoined {
        client: ClientId,
        kind: ClientKind,
    },
    ClientLeft {
        client: ClientId,
    },
    Ended {
        reason: EndReason,
    },
    Aborted {
        context_saved: bool,
    },
    Cleared {
        session_id: String,
    },
    CompactionStarted {
        source: String,
        disclosure: String,
    },
    CompactionApplied {
        previous_session_id: String,
        session_id: String,
        chains_advanced: Vec<String>,
        queued_restored: Option<String>,
        msg_count: usize,
    },
    CompactionFailed {
        message: String,
        panicked: bool,
    },
    CompactionCancelled,
    SubagentRows(Vec<SubagentDisplayRow>),
    Resumed {
        id: u64,
        old_id: String,
        new_id: String,
        via: Option<String>,
        clamp_notice: Option<String>,
    },
    InputOwnerChanged {
        from: Option<ClientId>,
        to: Option<ClientId>,
        reason: OwnerChangeReason,
    },
    Refused {
        client: ClientId,
        command: String,
        reason: String,
    },
    AttachRefused {
        message: String,
    },
    Lifecycle(SessionLifecycle),
    Reloading {
        generation: u64,
        retry_after_ms: u64,
    },
    DriverArmed {
        plugin_id: String,
        run_id: String,
        models: Vec<Selection>,
        selection: Selection,
        deadline_ms: Option<u64>,
        notice: String,
    },
    DriverRevoked {
        reason: String,
        undelivered_steering: Vec<String>,
    },
    DriverTurnOutcome {
        outcome: Outcome,
        selection: Selection,
        feedback: Option<String>,
    },
    CostCapReached {
        scope: String,
        cost: f64,
        cap: f64,
    },
}

What a session tells its clients. Stream carries the un-serialised StreamEvent in-process (LocalTransport) — that IS the byte-identical contract. The socket boundary converts to wire::WireSessionEvent.

Variants

Stream(StreamEvent)

TurnStarted

Actor bookkeeping the client needs to mirror App fields exactly. user_text = the queued text on QueuedAuto (TUI pushes the User card + scroll); None otherwise.

Fields

turn_baseline: usize

trigger: TurnTrigger

user_text: Option<String>

Conversation(ConversationSnapshot)

Emitted after every MessageHistory / Done / Error / Cancel / Compact so mirrors never diverge: the actor’s api_messages IS the truth.

Prompt(PromptRequest)

PromptResolved

So mirrors dismiss the modal.

Fields

prompt_id: u64

External(Event)

Drained event card — presentation only.

AutoTurnCapReached

Fields

cap: u32

Idle

The turn machine is idle: a stream ended (Done/Error/Cancel) and NO auto-turn followed. Headless hosts gate stdin on this so a queued auto-turn is never raced by the next line.

Steered

“→ steering:” vs “queued:”.

Fields

text: String

delivered: bool

Dequeued

Fields

text: String

SystemNotice(String)

Any ChatMessage::System the actor would have pushed.

LoaderProgress(ExtensionLoaderEvent)

ExtensionNotification

Fields

extension_id: String

method: String

params: Value

SettingChanged(SettingApplied)

QueryResult

Fields

id: u64

value: Value

Attached

Only to the attaching client.

Fields

client: ClientId

snapshot: AttachSnapshot

ClientJoined

Fields

client: ClientId

kind: ClientKind

ClientLeft

Fields

client: ClientId

Ended

Fields

reason: EndReason

Aborted

Cancel landed. TUI: drop_empty_thinking, push Error(abort_msg), subagents.clear(), streaming=false.

Fields

context_saved: bool

Cleared

/clear. TUI: transcript.clear, counters=0, “new session started”.

Fields

session_id: String

CompactionStarted

(B2) disclosure = preview_compaction_disclosure().render_line().

Fields

source: String

disclosure: String

CompactionApplied

Fields

previous_session_id: String

session_id: String

chains_advanced: Vec<String>

queued_restored: Option<String>

msg_count: usize

CompactionFailed

“compaction failed: {e}” vs “compaction task panicked: {e}”.

Fields

message: String

panicked: bool

CompactionCancelled

SubagentRows(Vec<SubagentDisplayRow>)

runtime.subagent_registry().display_rows() — at Done/Error and at 1 Hz while any row is non-terminal.

Resumed

/resume reply (Resume{id}).

Fields

id: u64

old_id: String

new_id: String

via: Option<String>

clamp_notice: Option<String>

InputOwnerChanged

(B1) sent to the previous owner on takeover, and to everyone on any owner change.

Fields

from: Option<ClientId>

to: Option<ClientId>

reason: OwnerChangeReason

Refused

(B1) a non-owner sent an input command. Only the sender renders it.

Fields

client: ClientId

command: String

reason: String

AttachRefused

(B3) targeted like Attached: the attach could not be honoured.

Fields

message: String

Lifecycle(SessionLifecycle)

(B3) lifecycle transitions for mirrors and sessions listings.

Reloading

(C3) daemon is about to exec itself; clients reconnect.

Fields

generation: u64

retry_after_ms: u64

DriverArmed

(E-P0) Driver armed on this session.

Fields

plugin_id: String

run_id: String

models: Vec<Selection>

selection: Selection

deadline_ms: Option<u64>

Remaining ms, not absolute Instant.

notice: String

DriverRevoked

(E-P0) Driver revoked.

Fields

reason: String

undelivered_steering: Vec<String>

DriverTurnOutcome

(E-P0) One driver turn completed.

Fields

outcome: Outcome

selection: Selection

feedback: Option<String>

CostCapReached

(E-P7, §S3) A spend ceiling was breached: the turn was cancelled and any armed driver revoked. scope is “session” (config cap) or “run” (the driver grant’s per-run cap). Additive v3 driver event — old clients skip it via #[serde(other)].

Fields

scope: String

cost: f64

cap: f64

Trait Implementations

impl Clone for SessionEventWire

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionEventWire

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

Formats the value using the given formatter.

impl From<SessionEventWire> for WireSessionEvent

fn from(e: SessionEventWire) -> Self

Converts to this type from the input type.

impl From<WireSessionEvent> for SessionEventWire

fn from(e: WireSessionEvent) -> Self

Converts to this type from the input type.