absurder-sql 0.1.23

AbsurderSQL - SQLite + IndexedDB that's absurdly better than absurd-sql
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

// Block metadata tracking tests for BlockStorage

#![cfg(not(target_arch = "wasm32"))]
use absurder_sql::storage::{BLOCK_SIZE, BlockStorage};
use serial_test::serial;
use tempfile::TempDir;
#[path = "common/mod.rs"]
mod common;

#[tokio::test(flavor = "current_thread")]
#[serial]
async fn test_checksum_created_on_write_and_changes_with_data() {
    let tmp = TempDir::new().expect("tempdir");
    common::set_var("ABSURDERSQL_FS_BASE", tmp.path());
    let mut storage = BlockStorage::new_with_capacity("test_meta_checksum", 4)
        .await
        .expect("create storage");

    // Write block 100 with all 7s
    let d1 = vec![7u8; BLOCK_SIZE];
    storage
        .write_block(100, d1.clone())
        .await
        .expect("write 100 d1");
    let c1 = storage
        .get_block_checksum(100)
        .expect("checksum present after write");

    // Write block 100 with different contents
    let mut d2 = vec![0u8; BLOCK_SIZE];
    d2[0] = 1; // small change
    storage
        .write_block(100, d2.clone())
        .await
        .expect("write 100 d2");
    let c2 = storage
        .get_block_checksum(100)
        .expect("checksum present after second write");

    assert_ne!(c1, c2, "checksum should change when data changes");
}

#[tokio::test(flavor = "current_thread")]
#[serial]
async fn test_checksum_removed_on_deallocate() {
    let tmp = TempDir::new().expect("tempdir");
    common::set_var("ABSURDERSQL_FS_BASE", tmp.path());
    let mut storage = BlockStorage::new_with_capacity("test_meta_dealloc", 2)
        .await
        .expect("create storage");

    // Allocate a real block ID before writing and deallocating
    let id = storage.allocate_block().await.expect("allocate block");
    let data = vec![9u8; BLOCK_SIZE];
    storage
        .write_block(id, data)
        .await
        .expect("write to allocated id");
    assert!(storage.get_block_checksum(id).is_some());

    storage
        .deallocate_block(id)
        .await
        .expect("deallocate allocated id");
    assert!(
        storage.get_block_checksum(id).is_none(),
        "checksum should be removed on deallocate"
    );
}

#[tokio::test(flavor = "current_thread")]
#[serial]
async fn test_no_checksum_for_unwritten_block() {
    let tmp = TempDir::new().expect("tempdir");
    common::set_var("ABSURDERSQL_FS_BASE", tmp.path());
    let mut storage = BlockStorage::new_with_capacity("test_meta_unwritten", 2)
        .await
        .expect("create storage");

    // Allocate and read an empty block; no metadata should exist until a write
    let block_id = storage.allocate_block().await.expect("allocate block");
    let _ = storage.read_block(block_id).await.expect("read block");
    assert!(
        storage.get_block_checksum(block_id).is_none(),
        "no checksum tracked for unread/unwritten block"
    );
}