bcode_session 0.0.1-alpha.0

Session lifecycle and attachment management for bcode
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

//! Session attachment, subscription, and committed-mutation boundary types.

use bcode_session_models::{
    SessionEvent, SessionId, SessionInputHistoryEntry, SessionLiveEvent, SessionSummary,
    SessionUsageSummary,
};
use tokio::sync::broadcast;

/// Active session attachment with replay history and event receivers.
#[derive(Debug)]
pub struct SessionAttachment {
    pub session: SessionSummary,
    pub history: Vec<SessionEvent>,
    pub input_history: Vec<SessionInputHistoryEntry>,
    pub usage_summary: SessionUsageSummary,
    pub live_checkpoints: Vec<SessionLiveEvent>,
    pub events: broadcast::Receiver<SessionEvent>,
    pub live_events: broadcast::Receiver<SessionLiveEvent>,
}

/// Non-mutating event subscription for a session.
#[derive(Debug)]
pub struct SessionEventSubscription {
    pub session: SessionSummary,
    pub events: broadcast::Receiver<SessionEvent>,
    pub live_events: broadcast::Receiver<SessionLiveEvent>,
}

/// Notification emitted after a durable session mutation is committed.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct SessionMutationCommitted {
    pub session_id: SessionId,
    pub event: SessionEvent,
    pub summary: SessionSummary,
}

/// Active session attachment plus projection-window metadata.
#[derive(Debug)]
pub struct SessionProjectionWindowAttachment {
    pub attachment: SessionAttachment,
    pub projection_window: bcode_session_models::ProjectionWindow,
}