orchestral-runtime 0.3.1

A runtime for reliable, interactive AI agents.
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

use super::*;

/// The original logical extent is independent of the record that publishes a
/// summary. Keep it derived from the journal rather than accepting a second
/// persisted source identity.
fn source_extent(
    groups: &BTreeMap<u64, MessageGroup>,
    source: &SessionSourceRange,
) -> Option<SessionSourceRange> {
    let mut covered = groups
        .values()
        .filter(|group| source.contains(group.producer_seq));
    let mut extent = covered.next()?.logical_source.clone();
    for group in covered {
        extent.first_session_seq = extent
            .first_session_seq
            .min(group.logical_source.first_session_seq);
        extent.last_session_seq = extent
            .last_session_seq
            .max(group.logical_source.last_session_seq);
    }
    Some(extent)
}

pub(super) fn can_replace_source(
    groups: &BTreeMap<u64, MessageGroup>,
    records: &[AgentSessionRecord],
    source: &SessionSourceRange,
) -> bool {
    let Some(extent) = source_extent(groups, source) else {
        return false;
    };
    // Adjacent producer records need not be adjacent history: a late summary
    // can refer to exchanges before a surviving User/Steer or protected fact.
    // Never move later observations across that fact by merging the producers.
    let crosses_group = groups.values().any(|group| {
        !source.contains(group.producer_seq)
            && group.logical_source.first_session_seq <= extent.last_session_seq
            && extent.first_session_seq <= group.logical_source.last_session_seq
    });
    // Loaded Skills may be absent from this projection because they belong to
    // another Run or its allowed digest set changed. They remain durable
    // barriers, just like retained artifacts and unresolved effects.
    let crosses_protected_record = records.iter().any(|record| {
        extent.contains(record.session_seq)
            && match &record.payload {
                AgentSessionEvent::SkillLoaded { .. }
                | AgentSessionEvent::EffectUncertaintyCommitted { .. } => true,
                AgentSessionEvent::ToolExchangeCommitted {
                    retained_artifacts, ..
                } => !retained_artifacts.is_empty(),
                _ => false,
            }
    });
    !crosses_group && !crosses_protected_record
}

pub(super) fn summary_group(
    groups: &BTreeMap<u64, MessageGroup>,
    source: &SessionSourceRange,
    producer_seq: u64,
    summary: &ModelMessage,
    pinned: bool,
    active_compactable: bool,
) -> Result<MessageGroup, SessionContextError> {
    let logical_source = source_extent(groups, source).ok_or_else(|| {
        SessionContextError::Compaction("summary source has no live Context groups".to_owned())
    })?;
    let mut source_ranges: Vec<SessionSourceRange> = Vec::new();
    for producer in groups
        .values()
        .filter(|group| source.contains(group.producer_seq))
    {
        if let Some(last) = source_ranges
            .last_mut()
            .filter(|last| last.last_session_seq.checked_add(1) == Some(producer.producer_seq))
        {
            last.last_session_seq = producer.producer_seq;
        } else {
            source_ranges.push(single_range(producer.producer_seq));
        }
    }
    Ok(MessageGroup {
        key: producer_seq,
        producer_seq,
        source_ranges,
        logical_source,
        messages: vec![summary.clone()],
        pinned,
        active_compactable,
    })
}

#[cfg(test)]
mod tests;