pagedb 0.1.0-beta.6

Encrypted, portable, embedded page store with B+ tree and segment-file surfaces.
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

/// Verify that pages written under one cipher can be read back correctly, and
/// that each cipher variant works independently. The per-page epoch+cipher
/// dispatch reads the `cipher_id` from the on-disk header byte rather than
/// from the pager's current configuration, so old pages remain readable after
/// the configured cipher changes.
use pagedb::vfs::memory::MemVfs;
use pagedb::{CipherId, Db, OpenOptions, RealmId};

const PAGE: usize = 4096;
const KEK: [u8; 32] = [5u8; 32];
const REALM: RealmId = RealmId::new([2u8; 16]);

#[tokio::test(flavor = "current_thread")]
async fn aes256gcm_write_read_round_trip() {
    let db = Db::open(
        MemVfs::new(),
        KEK,
        PAGE,
        REALM,
        OpenOptions::default().with_cipher(CipherId::Aes256Gcm),
    )
    .await
    .unwrap();
    let mut w = db.begin_write().await.unwrap();
    w.put(b"aes_key", b"aes_val").await.unwrap();
    w.commit().await.unwrap();
    let r = db.begin_read().await.unwrap();
    assert_eq!(
        r.get(b"aes_key").await.unwrap().as_deref(),
        Some(b"aes_val".as_ref())
    );
}

#[tokio::test(flavor = "current_thread")]
async fn chacha20poly1305_write_read_round_trip() {
    let db = Db::open(
        MemVfs::new(),
        KEK,
        PAGE,
        REALM,
        OpenOptions::default().with_cipher(CipherId::ChaCha20Poly1305),
    )
    .await
    .unwrap();
    let mut w = db.begin_write().await.unwrap();
    w.put(b"cc_key", b"cc_val").await.unwrap();
    w.commit().await.unwrap();
    let r = db.begin_read().await.unwrap();
    assert_eq!(
        r.get(b"cc_key").await.unwrap().as_deref(),
        Some(b"cc_val".as_ref())
    );
}

#[tokio::test(flavor = "current_thread")]
async fn plaintextmac_write_read_round_trip() {
    let db = Db::open(
        MemVfs::new(),
        KEK,
        PAGE,
        REALM,
        OpenOptions::default().with_cipher(CipherId::PlaintextMac),
    )
    .await
    .unwrap();
    let mut w = db.begin_write().await.unwrap();
    w.put(b"pt_key", b"pt_val").await.unwrap();
    w.commit().await.unwrap();
    let r = db.begin_read().await.unwrap();
    assert_eq!(
        r.get(b"pt_key").await.unwrap().as_deref(),
        Some(b"pt_val".as_ref())
    );
}