fathomdb-engine 0.8.22

FathomDB engine — embedded vector + JSON database core (storage, projection, ingest, query).
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

use fathomdb_engine::{CheckIntegrityOpts, Engine, IntegrityReport, Section};
use fathomdb_schema::SQLITE_SUFFIX;
use std::io::{Read, Seek, SeekFrom, Write};
use tempfile::TempDir;

fn db_path(dir: &TempDir, name: &str) -> std::path::PathBuf {
    dir.path().join(format!("{name}{SQLITE_SUFFIX}"))
}

#[test]
fn ac_043a_three_section_report_on_healthy_db() {
    let dir = TempDir::new().unwrap();
    let path = db_path(&dir, "healthy");
    let opened = Engine::open(&path).expect("open");
    let report =
        opened.engine.check_integrity(CheckIntegrityOpts::default()).expect("check_integrity");
    let IntegrityReport { physical, logical, semantic } = report;
    assert!(matches!(physical, Section::Clean));
    assert!(matches!(logical, Section::Clean));
    assert!(matches!(semantic, Section::Clean));
}

#[test]
fn ac_043b_full_run_keeps_three_sections() {
    let dir = TempDir::new().unwrap();
    let path = db_path(&dir, "healthy_full");
    let opened = Engine::open(&path).expect("open");
    let report = opened
        .engine
        .check_integrity(CheckIntegrityOpts { quick: false, full: true, round_trip: false })
        .expect("check_integrity");
    assert!(matches!(report.physical, Section::Clean));
    assert!(matches!(report.logical, Section::Clean));
    assert!(matches!(report.semantic, Section::Clean));
}

#[test]
fn ac_043c_full_findings_include_integrity_check_code() {
    let dir = TempDir::new().unwrap();
    let path = db_path(&dir, "page_damage");

    {
        let opened = Engine::open(&path).expect("open");
        drop(opened);
    }

    {
        let mut file =
            std::fs::OpenOptions::new().read(true).write(true).open(&path).expect("open db file");
        let mut buffer = vec![0u8; 4096];
        file.seek(SeekFrom::Start(8192)).expect("seek");
        file.read_exact(&mut buffer).expect("read");
        for byte in &mut buffer {
            *byte ^= 0xa5;
        }
        file.seek(SeekFrom::Start(8192)).expect("seek");
        file.write_all(&buffer).expect("write");
        file.sync_all().expect("sync");
    }

    let opened = match Engine::open(&path) {
        Ok(opened) => opened,
        Err(_) => return,
    };

    let report = opened
        .engine
        .check_integrity(CheckIntegrityOpts { quick: false, full: true, round_trip: false })
        .expect("check_integrity");

    let physical = match report.physical {
        Section::Findings(rows) => rows,
        Section::Clean => return,
    };
    assert!(
        physical.iter().any(|finding| finding.code == "E_CORRUPT_INTEGRITY_CHECK"),
        "expected E_CORRUPT_INTEGRITY_CHECK; got {physical:?}"
    );
    assert!(physical.iter().all(|finding| !finding.detail.is_empty()));
    assert!(physical
        .iter()
        .all(|finding| finding.doc_anchor == "design/recovery.md#integrity-check-full-findings"));
}