khive-db 0.11.0

SQLite storage backend: entities, edges, notes, events, FTS5, sqlite-vec vectors.
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

use super::*;

/// Run `op` under a manual `BEGIN IMMEDIATE`/`COMMIT`/`ROLLBACK` on `writer`
/// — the pre-ADR-067 shape, used by [`SqlBridge::atomic_unit`] whenever no
/// writer task applies to a file-backed pool.
pub(super) async fn run_manual_atomic_unit(
    writer: &mut dyn khive_storage::SqlWriter,
    op: AtomicUnitOp,
    origin: khive_storage::tx_registry::TxOrigin,
) -> khive_storage::types::StorageResult<Box<dyn Any + Send>> {
    khive_storage::SqlWriter::execute(
        writer,
        SqlStatement::new("BEGIN IMMEDIATE", vec![]).labelled("begin"),
    )
    .await?;
    let _tx_handle =
        khive_storage::tx_registry::register_scoped(Some("atomic_unit".to_string()), origin);

    let result = op(writer).await;

    match result {
        Ok(value) => {
            match khive_storage::SqlWriter::execute(
                writer,
                SqlStatement::new("COMMIT", vec![]).labelled("commit"),
            )
            .await
            {
                Ok(_) => Ok(value),
                Err(e) => {
                    let _ = khive_storage::SqlWriter::execute(
                        writer,
                        SqlStatement::new("ROLLBACK", vec![]).labelled("rollback"),
                    )
                    .await;
                    Err(e)
                }
            }
        }
        Err(e) => {
            let _ = khive_storage::SqlWriter::execute(
                writer,
                SqlStatement::new("ROLLBACK", vec![]).labelled("rollback"),
            )
            .await;
            Err(e)
        }
    }
}