Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

Adapter that exposes the existing rusqlite-backed TransactionStore through the async AuditStore trait. Each method runs the underlying blocking work on tokio::task::spawn_blocking so the executor stays responsive even when the SQLite write takes a millisecond on a slow disk.

Implementations

impl SqliteStore

pub fn new(inner: TransactionStore) -> Self

pub fn inner(&self) -> &TransactionStore

Borrow the wrapped sync TransactionStore. Used by call sites that genuinely need the blocking handle (test helpers, the audit-verify CLI subcommand which is itself sync over the result).

Trait Implementations

impl AuditStore for SqliteStore

fn record<'life0, 'async_trait>( &'life0 self, transaction: NewTransaction, ) -> Pin<Box<dyn Future<Output = Result<TransactionRecord, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn record_previewed<'life0, 'async_trait>( &'life0 self, transaction: NewTransaction, preview: PreviewEnvelope, ) -> Pin<Box<dyn Future<Output = Result<RecordedPreviewedTransaction, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TransactionRecord>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_preview<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<PreviewEnvelope>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, new_status: JobState, ) -> Pin<Box<dyn Future<Output = Result<(), TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn approve_transaction<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, approver: CallerPrincipal, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn revoke_unconsumed_approval<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, revoker: CallerPrincipal, ) -> Pin<Box<dyn Future<Output = Result<bool, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn claim_approved_for_execution<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, transaction_id: &'life1 str, receipt_digest: &'life2 str, executor: CallerPrincipal, ) -> Pin<Box<dyn Future<Output = Result<bool, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn cleanup_stale_queued<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn cancel_queued<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, canceller: CallerPrincipal, ) -> Pin<Box<dyn Future<Output = Result<bool, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Cancel one still-Queued transaction (Queued → Canceled). Returns true iff a queued row was transitioned; a Running (in-flight) or terminal transaction is never cancelled. See crate::transactions::TransactionStore::cancel_queued.

fn list_transactions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, limit: u32, status_filter: Option<&'life1 str>, action_filter: Option<&'life2 str>, since: Option<HistorySince>, ) -> Pin<Box<dyn Future<Output = Result<Vec<TransactionRecord>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn list_history<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, limit: u32, status_filter: Option<&'life1 str>, action_filter: Option<&'life2 str>, since: Option<HistorySince>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JobHistoryEntry>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Structured history rows (with created_at and typed risk_level) for programmatic clients. See crate::transactions::JobHistoryEntry.

fn fetch_chain_row<'life0, 'life1, 'async_trait>( &'life0 self, transaction_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ChainRow>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn fetch_chain_rows<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ChainRow>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn fetch_event_rows<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventRow>, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Every approval event, in seq order. Backs the second chain that records grant/consume/revoke — see audit_chain::AuditEventKind.

fn verify_audit_chain<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 AuditKey, ) -> Pin<Box<dyn Future<Output = Result<VerifyOutcome, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn reconcile_interrupted_running<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reconcile transactions orphaned by a daemon crash or restart.

fn verify_event_chain<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 AuditKey, ) -> Pin<Box<dyn Future<Output = Result<VerifyOutcome, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Walk the approval-event chain.

fn verify_event_binding<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<BindingOutcome, TransactionStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check that every event tip committed by a transaction row still exists in the event chain. See audit_chain::verify_event_binding.

impl Clone for SqliteStore

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.