topodb 0.0.3

Embedded, local-first memory engine for AI agents: temporal property graph + scoped recall.
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

use topodb::*;

fn custom_spec() -> IndexSpec {
    IndexSpec {
        equality: vec![PropIndex {
            label: "Person".into(),
            prop: "handle".into(),
        }],
        text: vec![PropIndex {
            label: "Note".into(),
            prop: "body".into(),
        }],
    }
}

#[test]
fn open_stored_uses_persisted_spec_no_reindex() {
    let dir = tempfile::tempdir().unwrap();
    let path = dir.path().join("t.redb");
    let s = ScopeId::new();
    let a = NodeId::new();
    {
        // Create with a custom spec; write an equality-indexed node + a text-indexed node.
        let db = Db::open_with(&path, custom_spec()).unwrap();
        let mut p = Props::new();
        p.insert("handle".into(), PropValue::Str("ada".into()));
        db.submit(vec![Op::CreateNode {
            id: a,
            scope: Scope::Id(s),
            label: "Person".into(),
            props: p,
        }])
        .unwrap();
        let mut n = Props::new();
        n.insert("body".into(), PropValue::Str("first program note".into()));
        db.submit(vec![Op::CreateNode {
            id: NodeId::new(),
            scope: Scope::Id(s),
            label: "Note".into(),
            props: n,
        }])
        .unwrap();
    }
    // Reopen WITHOUT passing a spec — must inherit the custom one.
    let db = Db::open_stored(&path).unwrap();
    let scopes = ScopeSet::of(&[s]);
    // Equality index declared correctly (else this would Rejected or be empty):
    let hits = db
        .nodes_by_prop(&scopes, "Person", "handle", &PropValue::Str("ada".into()))
        .unwrap();
    assert_eq!(hits.len(), 1);
    assert_eq!(hits[0].id, a);
    // Text index intact (no drain/reindex wiped it):
    assert_eq!(db.search_text(&scopes, "program", 10).unwrap().len(), 1);
}

#[test]
fn open_stored_fresh_file_uses_default_spec() {
    let dir = tempfile::tempdir().unwrap();
    let db = Db::open_stored(dir.path().join("fresh.redb")).unwrap();
    let s = ScopeId::new();
    let scopes = ScopeSet::of(&[s]);
    // Default spec declares no equality index → an undeclared lookup is Rejected, not a panic.
    assert!(db
        .nodes_by_prop(&scopes, "X", "y", &PropValue::Int(1))
        .is_err());
    // And the db is writable:
    db.submit(vec![Op::CreateNode {
        id: NodeId::new(),
        scope: Scope::Id(s),
        label: "M".into(),
        props: Default::default(),
    }])
    .unwrap();
    assert_eq!(db.current_seq().unwrap(), 1);
}