batpak 0.8.2

Event sourcing with causal graphs and caller-defined gates. Sync API, no async runtime.
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

#![cfg(feature = "dangerous-test-hooks")]
// justifies: INV-TEST-PANIC-AS-ASSERTION; dangerous-test-hooks regression in tests/fault_hooks.rs uses panic as the direct assertion surface for injected failure paths.
#![allow(clippy::panic)]

use std::sync::Arc;

use batpak::prelude::StoreError;
use batpak::store::{CountdownAction, FaultInjector, InjectionPoint, ProbabilisticInjector};

#[test]
fn probabilistic_injector_and_maybe_inject_surface_faults() {
    let point = InjectionPoint::BatchItemWritten {
        batch_id: 7,
        item_index: 0,
        total_items: 1,
    };
    let injector: Option<Arc<dyn FaultInjector>> = Some(Arc::new(ProbabilisticInjector::new(
        1.0,
        CountdownAction::Fail("boom"),
    )));

    let err = match batpak::store::fault::maybe_inject(point, &injector) {
        Ok(()) => panic!("PROPERTY: probability=1.0 must force fault injection"),
        Err(err) => err,
    };

    assert!(
        matches!(err, StoreError::FaultInjected(ref message) if message.contains("boom")),
        "PROPERTY: maybe_inject must propagate the ProbabilisticInjector error, got {err:?}"
    );
}