Struct EnforcementEventWriter 

pub struct EnforcementEventWriter { /* private fields */ }

The enforcement event writer. Ties together sequence allocation, hash chaining, and store persistence into a single write path.

One writer per store lifetime. Not Clone — the seq counter and prev_hash chain are stateful.

Implementations

impl EnforcementEventWriter

pub async fn new(store: &Store) -> Result<Self>

Initialize the writer from store state.

Loads the current seq counter, installation_id, and the hash of the last event in the stream (for chain continuity).

pub async fn write( &mut self, store: &Store, event_type: EnforcementEventType, subject_kind: SubjectKind, subject_key: String, agent_type: String, receipt_id: Option<String>, decision_reason_code: String, decision_basis_hash: Option<String>, ) -> Result<EnforcementEvent>

Write an enforcement event to the store.

Allocates a seq_no (persisted before event write), computes the hash chain, and writes the event as JSON under enforcement:event:{seq_no}.

Returns the written event (with computed hashes) or an error.

pub fn installation_id(&self) -> &str

Return the current installation ID.

pub fn current_seq(&self) -> u64

Return the current sequence number (last allocated).

pub fn prev_hash(&self) -> &str

Return the hash of the last written event.

pub async fn detect_and_record_gap( &mut self, store: &Store, gap_start_ms: u64, gap_end_ms: u64, cause: GapCause, ) -> Result<EnforcementEvent>

Detect gaps in the event stream and emit a RecordingGap event.

Called on writer initialization when the seq counter is ahead of the last stored event (indicating a crash between seq allocation and event write).