dejadb-store 1.0.1

Content-addressed embedded store with hybrid recall (Turso/SQLite) for DejaDB.
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
96
97
98
99
100
101
102
103
104

//! File-carried declarations (meta table): settings travel with the file,
//! explicit opens re-stamp them, mismatches warn instead of silently
//! degrading indexes.

use dejadb_core::error::Result;
use dejadb_core::types::Fact;
use dejadb_store::{DejaDB, DejaDbOptions, EmbedBackend};
use tempfile::TempDir;

fn opts(index_text: bool) -> DejaDbOptions {
    DejaDbOptions { index_text, ..Default::default() }
}

struct FakeEmbed {
    name: &'static str,
    dim: usize,
}
impl EmbedBackend for FakeEmbed {
    fn dim(&self) -> usize {
        self.dim
    }
    fn embed(&self, _text: &str) -> Result<Vec<f32>> {
        Ok(vec![0.5; self.dim])
    }
    fn model(&self) -> &str {
        self.name
    }
}

#[test]
fn declarations_persist_across_bare_reopen() {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("m.db");
    let path = path.to_str().unwrap();

    // create with text index off (voice/edge profile)
    {
        let mut m = DejaDB::open_with(path, opts(false)).unwrap();
        assert!(!m.index_text_enabled());
        assert!(m.open_warnings().is_empty(), "{:?}", m.open_warnings());
        m.add(&Fact::new("john", "prefers", "tea")).unwrap();
    }

    // a bare open honors the file's declaration — no host config needed
    {
        let m = DejaDB::open(path).unwrap();
        assert!(!m.index_text_enabled(), "file declared text_index=off");
        assert!(m.open_warnings().is_empty(), "{:?}", m.open_warnings());
    }
}

#[test]
fn explicit_open_restamps_and_warns() {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("m.db");
    let path = path.to_str().unwrap();

    DejaDB::open_with(path, opts(false)).unwrap();

    // deliberate change: explicit options win, but the change is loud
    {
        let m = DejaDB::open_with(path, opts(true)).unwrap();
        assert!(m.index_text_enabled());
        assert!(
            m.open_warnings().iter().any(|w| w.contains("text_index")),
            "{:?}",
            m.open_warnings()
        );
    }

    // ... and the file now declares the new setting
    {
        let m = DejaDB::open(path).unwrap();
        assert!(m.index_text_enabled());
        assert!(m.open_warnings().is_empty(), "{:?}", m.open_warnings());
    }
}

#[test]
fn embedding_provenance_recorded_and_mismatch_warns() {
    let dir = TempDir::new().unwrap();
    let path = dir.path().join("m.db");
    let path = path.to_str().unwrap();

    // first backend stamps provenance
    {
        let mut m = DejaDB::open(path).unwrap();
        m.set_embedder(Box::new(FakeEmbed { name: "fake-a", dim: 4 }));
        assert_eq!(m.declared_embedding(), Some(("fake-a", 4)));
        m.add(&Fact::new("john", "prefers", "tea")).unwrap();
    }

    // provenance survives reopen; a different-dim backend warns
    {
        let mut m = DejaDB::open(path).unwrap();
        assert_eq!(m.declared_embedding(), Some(("fake-a", 4)));
        m.set_embedder(Box::new(FakeEmbed { name: "fake-b", dim: 8 }));
        assert!(
            m.open_warnings().iter().any(|w| w.contains("mismatch")),
            "{:?}",
            m.open_warnings()
        );
    }
}