openagents_sdk::chats::wire

What the chat API sends and takes (/v1/threads, its messages, and its event stream), with the rules every client applies to it. Nothing here makes a request, so the desktop and phone apps (through [crate::chats]'s calls) and the website's GPUI chat (through the browser's fetch and EventSource) read the same values the same way.

Rows are read leniently: a field the service adds later is ignored, and one it leaves out, or sends as null, takes its default.

pub struct BadEvent;

pub struct Change {
    pub title: Option<String>,
    pub pinned: Option<bool>,
    pub archived: Option<bool>,
    pub project: Option<Option<String>>,
}

pub struct Content {
    pub kind: String,
    pub text: String,
}

pub enum Event {
    Text {
        request_id: String,
        index: usize,
        role: crate::MessageRole,
        text: String,
        replace: bool,
    },
    Tool {
        request_id: String,
        index: usize,
        role: crate::MessageRole,
        text: String,
        replace: bool,
    },
    Cards { request_id: String, cards: Value },
    Done { request_id: String, outcome: String, revision: u64 },
    Error { request_id: String, error: Refusal },
}

pub fn request_id(&self) -> &str

pub fn read(data: &str, request_id: &str) -> Result<Self, BadEvent>

pub fn ends(&self) -> bool

pub fn card_list(&self) -> Vec<Value>

pub struct FileRef {
    pub id: String,
    pub name: String,
    pub kind: String,
    pub size: u64,
}

pub struct Filing {
    pub pinned: bool,
    pub archived: bool,
}

pub struct Frames {}

pub fn push(&mut self, chunk: &[u8]) -> Result<(), TooLarge>

pub fn next(&mut self) -> Result<Option<String>, BadEvent>

pub struct MessageBody<'a> {
    pub request_id: &'a str,
    pub text: &'a str,
    pub project: Option<&'a str>,
}

pub struct MessageRow {
    pub id: String,
    pub role: String,
    pub content: Vec<Content>,
}

pub fn index(&self) -> Option<usize>

pub fn text(&self) -> String

pub struct Page<T> {
    pub data: Vec<T>,
    pub next: Option<String>,
}

pub struct Refusal {
    pub code: RefusalCode,
    pub message: String,
    pub retry_after_ms: Option<u64>,
}

pub enum RefusalCode {
    QuotaExhausted,
    RateLimited,
    Busy,
    Unavailable,
    Timeout,
    AccessLost,
    StreamTimeout,
    Other(String),
}

pub struct Started {
    pub id: String,
    pub answering: bool,
}

pub struct Stopped {
    pub request_id: String,
    pub stopped: bool,
    pub finished: bool,
}

pub struct Thread {
    pub id: String,
    pub request_id: Option<String>,
    pub outcome: Option<String>,
    pub title: String,
    pub line: String,
    pub surface: String,
    pub computer: Option<String>,
    pub updated_unix: u64,
    pub working: bool,
    pub online: bool,
    pub can_reply: bool,
    pub pinned: bool,
    pub project: Option<String>,
    pub messages: usize,
}

pub fn pending(&self) -> bool

pub fn synced(&self) -> bool

pub struct ThreadDetail {
    pub thread: Thread,
    pub messages: Vec<ThreadMessage>,
    pub earlier: usize,
}

pub struct ThreadList {
    pub threads: Vec<Thread>,
    pub total: usize,
    pub more: bool,
    pub next_offset: Option<usize>,
}

pub struct ThreadMessage {
    pub role: String,
    pub text: String,
    pub files: Vec<FileRef>,
}

pub struct TooLarge;

pub fn is_request_id(id: &str) -> bool

pub fn message_ok(text: &str) -> bool

pub fn title(title: &str) -> Option<&str>

pub const MAX_EVENT_INDEX: usize = 4000;

pub const MAX_MESSAGE_CHARS: usize = 4000;

pub const MAX_TITLE_CHARS: usize = 120;