keepsake 0.5.1

Deterministic lifecycle model for auditable relation assignments
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

//! In-memory audit sink for tests.

use std::sync::{Arc, Mutex};

use crate::audit::{AuditEvent, AuditSink};

/// In-memory audit sink errors.
#[derive(Debug, thiserror::Error, Clone, PartialEq, Eq)]
pub enum InMemoryAuditError {
    /// The shared event buffer was poisoned by a previous panic.
    #[error("in-memory audit sink buffer is poisoned")]
    Poisoned,
}

/// In-memory audit sink for tests.
#[derive(Debug, Clone, Default)]
pub struct InMemoryAuditSink {
    // Test-only shared buffer for asserting emitted audit events. Production
    // audit sinks should write to a durable backend instead of sharing a mutex.
    events: Arc<Mutex<Vec<AuditEvent>>>,
}

impl InMemoryAuditSink {
    /// Returns a snapshot of recorded events.
    pub fn events(&self) -> Result<Vec<AuditEvent>, InMemoryAuditError> {
        self.events
            .lock()
            .map_err(|_| InMemoryAuditError::Poisoned)
            .map(|events| events.clone())
    }
}

impl AuditSink for InMemoryAuditSink {
    type Error = InMemoryAuditError;

    fn record(&self, event: AuditEvent) -> Result<(), Self::Error> {
        self.events
            .lock()
            .map_err(|_| InMemoryAuditError::Poisoned)?
            .push(event);
        Ok(())
    }
}