Enum PiMsg 

pub enum PiMsg {
    AgentStart,
    RunPending,
    EnqueuePendingInput(PendingInput),
    UiShutdown,
    AutocompleteRefresh,
    TextDelta(String),
    ThinkingDelta(String),
    ToolStart {
        name: String,
        tool_id: String,
    },
    ToolUpdate {
        name: String,
        tool_id: String,
        content: Vec<ContentBlock>,
        details: Option<Value>,
    },
    ToolEnd {
        name: String,
        tool_id: String,
        is_error: bool,
    },
    AgentDone {
        usage: Option<Usage>,
        stop_reason: StopReason,
        error_message: Option<String>,
    },
    AgentError(String),
    CredentialUpdated {
        provider: String,
    },
    System(String),
    SystemNote(String),
    UpdateLastUserMessage(String),
    BashResult {
        display: String,
        content_for_agent: Option<Vec<ContentBlock>>,
    },
    OAuthDeviceFlowStarted {
        provider: String,
        device_code: String,
        user_code: String,
        verification_uri: String,
        expires_in: u64,
    },
    ConversationReset {
        messages: Vec<ConversationMessage>,
        usage: Usage,
        status: Option<String>,
    },
    SetEditorText(String),
    OpenTree {
        initial_selected_id: Option<String>,
        label: Option<String>,
    },
    ResourcesReloaded {
        resources: ResourceLoader,
        status: String,
        diagnostics: Option<String>,
    },
    ExtensionUiRequest(ExtensionUiRequest),
    ExtensionCommandDone {
        command: String,
        display: String,
        is_error: bool,
    },
    OAuthCallbackReceived(String),
}

Custom message types for async agent events.

Variants

AgentStart

Agent started processing.

RunPending

Trigger processing of the next queued input (CLI startup messages).

EnqueuePendingInput(PendingInput)

Enqueue a pending input (extensions may inject while idle).

UiShutdown

Internal: shut down the async→UI message bridge (used for clean exit).

AutocompleteRefresh

Periodic autocomplete refresh tick (background file index).

TextDelta(String)

Text delta from assistant.

ThinkingDelta(String)

Thinking delta from assistant.

ToolStart

Tool execution started.

Fields

name: String

tool_id: String

ToolUpdate

Tool execution update (streaming output).

Fields

name: String

tool_id: String

content: Vec<ContentBlock>

details: Option<Value>

ToolEnd

Tool execution ended.

Fields

name: String

tool_id: String

is_error: bool

AgentDone

Agent finished with final message.

Fields

usage: Option<Usage>

stop_reason: StopReason

error_message: Option<String>

AgentError(String)

Agent error.

CredentialUpdated

Credentials changed for a provider; refresh in-memory provider auth state.

Fields

provider: String

System(String)

Non-error system message.

SystemNote(String)

System note that does not mutate agent state (safe during streaming).

UpdateLastUserMessage(String)

Update last user message content (input transform/redaction).

BashResult

Bash command result (non-agent).

Fields

display: String

content_for_agent: Option<Vec<ContentBlock>>

OAuthDeviceFlowStarted

Async OAuth device flow start

Fields

provider: String

device_code: String

user_code: String

verification_uri: String

expires_in: u64

ConversationReset

Replace conversation state from session (compaction/fork).

Fields

messages: Vec<ConversationMessage>

usage: Usage

status: Option<String>

SetEditorText(String)

Set the editor contents (used by /tree selection of user/custom messages).

OpenTree

Open the session tree selector (async from extension hooks).

Fields

initial_selected_id: Option<String>

label: Option<String>

ResourcesReloaded

Reloaded skills/prompts/themes/extensions.

Fields

resources: ResourceLoader

status: String

diagnostics: Option<String>

ExtensionUiRequest(ExtensionUiRequest)

Extension UI request (select/confirm/input/editor/custom/notify).

ExtensionCommandDone

Extension command finished execution.

Fields

command: String

display: String

is_error: bool

OAuthCallbackReceived(String)

OAuth callback server received the browser redirect. The string is the full callback URL (e.g. http://localhost:1455/auth/callback?code=abc&state=xyz).

Trait Implementations

impl Clone for PiMsg

fn clone(&self) -> PiMsg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PiMsg

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

Formats the value using the given formatter.