khive-db 0.10.0

SQLite storage backend: entities, edges, notes, events, FTS5, sqlite-vec vectors.
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

#[test]
fn resolve_blob_root_prefers_env_var() {
    if crate::test_process::run_in_child(|command| {
        command.env("KHIVE_BLOB_ROOT", "/tmp/env-override-root");
    }) {
        return;
    }
    let _guard = ENV_LOCK.lock().unwrap();
    let resolved = resolve_blob_root(Some(Path::new("/db/dir")), Some(Path::new("/cfg/root")));
    assert_eq!(resolved.unwrap(), PathBuf::from("/tmp/env-override-root"));
}

#[test]
fn resolve_blob_root_prefers_config_over_default() {
    if crate::test_process::run_in_child(|command| {
        command.env_remove("KHIVE_BLOB_ROOT");
    }) {
        return;
    }
    let _guard = ENV_LOCK.lock().unwrap();
    let resolved = resolve_blob_root(Some(Path::new("/db/dir")), Some(Path::new("/cfg/root")));
    assert_eq!(resolved.unwrap(), PathBuf::from("/cfg/root"));
}

#[test]
fn resolve_blob_root_defaults_beside_db_dir() {
    if crate::test_process::run_in_child(|command| {
        command.env_remove("KHIVE_BLOB_ROOT");
    }) {
        return;
    }
    let _guard = ENV_LOCK.lock().unwrap();
    let resolved = resolve_blob_root(Some(Path::new("/db/dir")), None);
    assert_eq!(resolved.unwrap(), PathBuf::from("/db/dir/blobs"));
}

#[test]
fn resolve_blob_root_errors_with_no_env_config_or_db_dir() {
    if crate::test_process::run_in_child(|command| {
        command.env_remove("KHIVE_BLOB_ROOT");
    }) {
        return;
    }
    let _guard = ENV_LOCK.lock().unwrap();
    let resolved = resolve_blob_root(None, None);
    assert!(resolved.is_err());
}

// Retain the original fixture lock within each isolated child.
static ENV_LOCK: std::sync::Mutex<()> = std::sync::Mutex::new(());