storage-kit 0.0.1

Portable database and transactional state-store Kit.
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

use crate::StateStoreError;

use super::{codec::RECORDS, error::RedbErrorContext};

pub(super) struct RedbSchemaInitializer<'db> {
    db: &'db redb::Database,
    quick_repair: bool,
}

impl<'db> RedbSchemaInitializer<'db> {
    pub(super) fn new(db: &'db redb::Database, quick_repair: bool) -> Self {
        Self { db, quick_repair }
    }

    pub(super) fn initialize(&self) -> Result<(), StateStoreError> {
        let context = RedbErrorContext::new("schema");
        let mut tx = self.db.begin_write().map_err(|err| context.backend(err))?;
        {
            let _table = tx.open_table(RECORDS).map_err(|err| context.backend(err))?;
        }
        if self.quick_repair {
            tx.set_quick_repair(true);
        }
        tx.commit().map_err(|err| context.backend(err))
    }
}