vantage-diorama 0.6.13

Cached, composable, reactive surface for Vantage Vistas
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

//! The detail cache persists each record's completeness status so two-pass
//! hydration can resume across restarts and skip already-complete records.

use ciborium::Value as CborValue;
use tempfile::TempDir;
use vantage_diorama::lens::{CacheBackend, CacheStatus, RedbCache};
use vantage_types::Record;

fn rec(v: &str) -> Record<CborValue> {
    let mut r = Record::new();
    r.insert("v".to_string(), CborValue::Text(v.to_string()));
    r
}

#[tokio::test]
async fn status_persists_across_reopen() {
    let tmp = TempDir::new().unwrap();
    let path = tmp.path().join("cache.redb");

    {
        let cache = RedbCache::open(&path).unwrap();
        let table = cache.open_table("items").await.unwrap();
        table
            .insert_value_with_status("a", &rec("a"), CacheStatus::Incomplete)
            .await
            .unwrap();
        // The status-agnostic write defaults to Complete.
        table.insert_value("b", &rec("b")).await.unwrap();

        assert_eq!(
            table.get_value_with_status("a").await.unwrap().unwrap().1,
            CacheStatus::Incomplete
        );
        assert_eq!(
            table.get_value_with_status("b").await.unwrap().unwrap().1,
            CacheStatus::Complete
        );
    }

    // Reopen the same file: the persisted status survives.
    let cache = RedbCache::open(&path).unwrap();
    let table = cache.open_table("items").await.unwrap();

    let (rec_a, status_a) = table.get_value_with_status("a").await.unwrap().unwrap();
    assert_eq!(status_a, CacheStatus::Incomplete);
    assert_eq!(rec_a.get("v"), Some(&CborValue::Text("a".to_string())));
    assert_eq!(
        table.get_value_with_status("b").await.unwrap().unwrap().1,
        CacheStatus::Complete
    );

    // The status-agnostic read still returns the record.
    assert!(table.get_value("a").await.unwrap().is_some());
}