weavatrix-memory 0.3.0

Event-sourced, bitemporal context compiler for coding 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

use super::SnapshotStore;
use crate::{MemoryError, ProjectionSnapshot, Result};
use std::collections::BTreeMap;

#[derive(Debug, Clone, Default)]
pub struct InMemorySnapshotStore<P> {
    snapshots: BTreeMap<u64, ProjectionSnapshot<P>>,
}

impl<P> SnapshotStore<P> for InMemorySnapshotStore<P>
where
    P: Clone + PartialEq,
{
    fn save(&mut self, snapshot: &ProjectionSnapshot<P>) -> Result<()> {
        let position = snapshot
            .cursor
            .global_position
            .ok_or(MemoryError::InvalidValue {
                field: "snapshot.cursor",
                reason: "cannot persist an empty replay cursor",
            })?;
        if let Some(existing) = self.snapshots.get(&position) {
            if existing == snapshot {
                return Ok(());
            }
            return Err(MemoryError::InvalidValue {
                field: "snapshot",
                reason: "different snapshot already exists at this position",
            });
        }
        self.snapshots.insert(position, snapshot.clone());
        Ok(())
    }

    fn load_latest(&self) -> Result<Option<ProjectionSnapshot<P>>> {
        Ok(self
            .snapshots
            .last_key_value()
            .map(|(_, snapshot)| snapshot.clone()))
    }
}