dig-capsule 0.5.0

The DIG Network .dig capsule data plane — one crate over the DIGS format, capsule read-crypto, compiler, staging, and the guest/host serve triad.
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

use crate::imp::core::{Bytes32, StoreConfig, Visibility};
use crate::imp::store::{FixedClock, Store};
use tempfile::tempdir;

fn config(dir: &std::path::Path) -> StoreConfig {
    StoreConfig {
        store_id: Bytes32([0x33u8; 32]),
        data_dir: dir.to_string_lossy().to_string(),
        max_size: 10_000_000,
        visibility: Visibility::Public,
        label: None,
        description: None,
    }
}

#[test]
fn init_creates_exact_layout() {
    let dir = tempdir().unwrap();
    let clock = FixedClock::new(1_717_000_000);
    let store = Store::init(config(dir.path()), clock).unwrap();

    let sid_hex = "33".repeat(32);
    assert!(dir.path().join("config.toml").exists(), "config.toml");
    assert!(
        dir.path().join(format!("{sid_hex}.staging.bin")).exists(),
        "staging"
    );
    assert!(dir.path().join("roots.log").exists(), "roots.log");
    assert!(dir.path().join("generations").is_dir(), "generations dir");
    assert!(dir.path().join("modules").is_dir(), "modules dir");

    assert_eq!(store.store_id(), Bytes32([0x33u8; 32]));
    assert!(store.root_history().unwrap().is_empty());
}

#[test]
fn init_refuses_to_clobber_existing_store() {
    let dir = tempdir().unwrap();
    Store::init(config(dir.path()), FixedClock::new(1)).unwrap();
    let err = Store::init(config(dir.path()), FixedClock::new(1)).unwrap_err();
    assert!(matches!(
        err,
        crate::imp::store::StoreError::AlreadyExists(_)
    ));
}

#[test]
fn open_reloads_an_existing_store() {
    let dir = tempdir().unwrap();
    Store::init(config(dir.path()), FixedClock::new(1)).unwrap();
    let reopened = Store::open(dir.path(), FixedClock::new(99)).unwrap();
    assert_eq!(reopened.store_id(), Bytes32([0x33u8; 32]));
    assert!(matches!(reopened.config().visibility, Visibility::Public));
}

#[test]
fn open_missing_store_errors() {
    let dir = tempdir().unwrap();
    let err = Store::open(dir.path(), FixedClock::new(1)).unwrap_err();
    assert!(matches!(err, crate::imp::store::StoreError::NotFound(_)));
}