Struct EnvelopeStore 

pub struct EnvelopeStore { /* private fields */ }

Implementations

impl EnvelopeStore

pub fn new(pool: SqlitePool) -> Self

pub async fn create_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, envelope_id: &str, spec: &EnvelopeSpec, parent_envelope_id: Option<&str>, ) -> KernelResult<EnvelopeRecord>

Create a new envelope within an existing transaction.

pub async fn get_active_for_actor( &self, actor_id: &str, ) -> KernelResult<Option<EnvelopeRecord>>

Get the active envelope for an actor. Returns None if no active envelope exists.

pub async fn get( &self, envelope_id: &str, ) -> KernelResult<Option<EnvelopeRecord>>

Get an envelope by ID.

pub async fn get_hold_request( &self, hold_id: &str, ) -> KernelResult<Option<Value>>

PIP-001 §11b: Get a hold_request record by hold_id.

pub async fn list_pending_holds( &self, agent_id: Option<&str>, ) -> KernelResult<Vec<Value>>

PIP-001 §11b: List pending hold_requests, optionally filtered by agent_id.

Returns records ordered by triggered_at ascending (oldest first). If agent_id is None, all pending holds are returned regardless of agent.

pub async fn list_pending_holds_for_envelope( &self, envelope_id: &str, ) -> KernelResult<Vec<Value>>

PIP-001 §11e: List pending hold_requests for a specific envelope.

pub async fn create_hold_request_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, req: &NewHoldRequest<'_>, ) -> KernelResult<()>

PIP-001 §11b: Create a hold_request record within a transaction.

pub async fn resolve_hold_request_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, hold_id: &str, decision: &str, instruction: Option<&str>, ) -> KernelResult<()>

PIP-001 §11d: Resolve a hold_request (approve or reject) within a transaction.

decision is “approve” or “reject” (PIP-001 §11d HoldResponse). The DB status column uses the past-tense forms “approved”/“rejected”.

pub async fn consume_budget_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, envelope_id: &str, amount: i64, ) -> KernelResult<i64>

Consume budget from an envelope within a transaction. Returns the new total consumed amount.

pub async fn set_status_in_tx( &self, tx: &mut Transaction<'_, Sqlite>, envelope_id: &str, status: &EnvelopeStatus, ) -> KernelResult<()>

Set envelope status within a transaction.

pub async fn set_status( &self, envelope_id: &str, status: &EnvelopeStatus, ) -> KernelResult<()>

Set envelope status without a transaction (convenience method).

pub async fn check_and_expire(&self, envelope_id: &str) -> KernelResult<bool>

Lazy expiry check: if envelope is time-expired, mark as expired and return true.

pub async fn update_checkpoint_tracking( &self, envelope_id: &str, last_report_at: i64, ) -> KernelResult<()>

Update checkpoint tracking fields.

Trait Implementations

impl Clone for EnvelopeStore

fn clone(&self) -> EnvelopeStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.