rushai-protocol 0.1.0

Wire types for rushai: ops, events, and message parts
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use serde::{Deserialize, Serialize};

use crate::ids::{CallId, MessageId, SessionId};
use crate::parts::{FinishReason, Part, PartDelta, Role};
use crate::permission::PermissionRequest;
use crate::usage::TokenUsage;

/// A state change emitted by the engine.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(tag = "type", rename_all = "snake_case")]
pub enum Event {
    /// A prompt was accepted and stamped with a monotonic sequence number.
    /// Cancellation reasons about these sequence numbers.
    RunAccepted {
        session: SessionId,
        seq: u64,
    },
    MessageStarted {
        message: MessageId,
        role: Role,
    },
    PartDelta {
        message: MessageId,
        index: usize,
        delta: PartDelta,
    },
    PartDone {
        message: MessageId,
        index: usize,
        part: Part,
    },
    ToolStarted {
        call: CallId,
        name: String,
        input: serde_json::Value,
    },
    ToolDone {
        call: CallId,
        output: String,
        is_error: bool,
    },
    PermissionRequested {
        request: PermissionRequest,
    },
    Usage {
        session: SessionId,
        usage: TokenUsage,
    },
    RunFinished {
        session: SessionId,
        seq: u64,
        reason: FinishReason,
    },
    Error {
        message: String,
    },
}