batpak 0.7.0

Event sourcing with causal graphs and policy gates. Sync API, zero async.
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

//! Internal helpers shared by deterministic evidence report implementations.

use serde::Serialize;

pub(crate) type EvidenceHash = [u8; 32];

pub(crate) fn report_body_hash<T, E, F>(body: &T, map_error: F) -> Result<EvidenceHash, E>
where
    T: Serialize,
    F: FnOnce(String) -> E,
{
    let bytes = crate::canonical::to_bytes(body).map_err(|error| map_error(error.to_string()))?;
    Ok(content_hash(&bytes))
}

pub(crate) fn content_hash(bytes: &[u8]) -> EvidenceHash {
    content_hash_impl(bytes)
}

pub(crate) fn sort_findings<T: Ord>(findings: &mut [T]) {
    findings.sort();
}

pub(crate) fn sorted_findings<T: Clone + Ord>(findings: &[T]) -> Vec<T> {
    let mut sorted = findings.to_vec();
    sort_findings(&mut sorted);
    sorted
}

#[cfg(feature = "blake3")]
fn content_hash_impl(bytes: &[u8]) -> EvidenceHash {
    crate::event::hash::compute_hash(bytes)
}

#[cfg(not(feature = "blake3"))]
fn content_hash_impl(bytes: &[u8]) -> EvidenceHash {
    let crc = crc32fast::hash(bytes).to_be_bytes();
    let mut out = [0_u8; 32];
    out[..4].copy_from_slice(&crc);
    out
}