Struct SqlitePendingStore 

pub struct SqlitePendingStore { /* private fields */ }

SQLite-backed PendingAdjudicationPort implementation.

Shares the same connection mutex as SqlitePersistenceStore but operates OUTSIDE the claim transaction — reads and writes go directly on the connection (no BEGIN/COMMIT wrapping). The per-agent write lock held by EngineHandle ensures these writes are serialized with the claim txn commit.

Construct via SqlitePendingStore::new(conn_arc) sharing the same connection Arc as the SqlitePersistenceStore.

Implementations

impl SqlitePendingStore

pub fn new(conn: Arc<Mutex<Option<Box<Connection>>>>) -> Self

Create a pending store sharing the connection with a SqlitePersistenceStore.

Trait Implementations

impl PendingAdjudicationPort for SqlitePendingStore

fn list_queued_orphan_claims( &self, ) -> Result<Vec<OrphanedQueuedClaim>, SqliteStoreError>

Detect QueuedForAdjudication claims (by latest ledger disposition) with no matching pending row (status = ‘pending’).

Approach: find claim_ids whose most-recent ledger entry has disposition = ‘QueuedForAdjudication’ via a subquery on max(recorded_at), then check for absence of a matching pending_adjudications row. Returns orphaned claim refs with agent_id, subject, predicate, and best-guess incumbent.

NOTE: The schema uses claim_id (not claim_ref) in ledger_entries and claims.

type Error = SqliteStoreError

fn insert_pending( &self, row: &PendingAdjudicationRow, ) -> Result<(), SqliteStoreError>

Persist a new pending-adjudication row (status = ‘pending’, expires_at = NULL).

fn get_pending( &self, handle_id: Uuid, ) -> Result<Option<PendingAdjudicationRow>, SqliteStoreError>

Lookup a pending row by its handle_id. Returns None if not found.

fn list_pending( &self, agent_id: Option<&AgentId>, ) -> Result<Vec<PendingAdjudicationRow>, SqliteStoreError>

List all pending rows for an agent (or all agents if agent_id is None). Ordered by queued_at ASC.

fn list_expired( &self, now: DateTime<Utc>, ) -> Result<Vec<PendingAdjudicationRow>, SqliteStoreError>

List all rows whose expires_at is not NULL, expires_at <= now, and status = 'pending'. Used by the sweep use-case. Ordered by expires_at ASC.

fn mark_resolved(&self, handle_id: Uuid) -> Result<(), SqliteStoreError>

Mark a pending row as resolved (status = ‘resolved’). Used by the verdict-apply step.

fn mark_expired(&self, handle_id: Uuid) -> Result<(), SqliteStoreError>

Mark a pending row as expired (status = ‘expired’). Used by the sweep and lazy expiry path.

impl Send for SqlitePendingStore

impl Sync for SqlitePendingStore