starweaver-session 0.10.0

Durable session contracts for Starweaver
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

//! Resume snapshots assembled from durable session state.

use serde::{Deserialize, Serialize};
use starweaver_context::{AgentCheckpoint, ResumableState};
use starweaver_stream::AgentStreamRecord;

use crate::{
    approval::{ApprovalRecord, DeferredToolRecord},
    records::{EnvironmentStateRef, RunRecord, SessionRecord, StreamCursorRef},
};

/// Resume package loaded from a durable session store.
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
pub struct SessionResumeSnapshot {
    /// Session record.
    pub session: SessionRecord,
    /// Run record.
    pub run: RunRecord,
    /// Exported context state.
    pub state: ResumableState,
    /// Latest environment state reference.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub environment_state: Option<EnvironmentStateRef>,
    /// Latest checkpoint for the requested run.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub latest_checkpoint: Option<AgentCheckpoint>,
    /// Replayable stream records after the checkpoint cursor.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub stream_records: Vec<AgentStreamRecord>,
    /// Pending approval records.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub approvals: Vec<ApprovalRecord>,
    /// Pending deferred tool records.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub deferred_tools: Vec<DeferredToolRecord>,
    /// Latest stream cursor references.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub stream_cursors: Vec<StreamCursorRef>,
}