Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

A handle wrapping a sqlx::SqlitePool that implements all three codlet store traits.

Clone is cheap (the pool is reference-counted internally).

Implementations

impl SqliteStore

pub fn new(pool: SqlitePool) -> Self

Construct from an existing pool. The caller must have already run run_migrations on the pool before issuing any store operations.

pub fn pool(&self) -> &SqlitePool

Borrow the underlying pool (e.g. to run custom queries alongside codlet).

Trait Implementations

impl Clone for SqliteStore

fn clone(&self) -> SqliteStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CodeStore for SqliteStore

async fn find_redeemable( &self, candidates: &[LookupKey], now: u64, scope: Option<&str>, ) -> Result<Option<RedeemableCode>, StoreError>

Look up a redeemable code by its HMAC lookup key candidates.

async fn claim_code( &self, req: &ClaimRequest<'_>, ) -> Result<ClaimOutcome, StoreError>

Attempt to atomically claim a code record.

async fn insert_code(&self, record: CodeRecord) -> Result<(), StoreError>

Insert a new code record. Returns StoreError if the lookup key already exists (unique constraint violation on the HMAC column).

async fn revoke_code( &self, code_id: &CodeId, scope: Option<&str>, now: u64, ) -> Result<(), StoreError>

Revoke a code by its record ID, scoped to scope when provided. Only affects records that are not yet used or revoked.

impl Debug for SqliteStore

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

Formats the value using the given formatter.

impl FormTokenStore for SqliteStore

async fn insert_form_token( &self, record: FormTokenRecord, ) -> Result<(), StoreError>

Insert a new form token record.

async fn consume_form_token( &self, lookup_key: &LookupKey, subject: &TokenSubject, purpose: &str, bound_resource: Option<&str>, now: u64, ) -> Result<(TokenConsumeOutcome, Option<String>), StoreError>

Attempt to atomically consume a form token.

async fn set_token_result( &self, lookup_key: &LookupKey, result_ref: &str, ) -> Result<(), StoreError>

Store a result reference on a consumed token for idempotency replay.

impl SessionStore for SqliteStore

async fn find_active_session( &self, candidates: &[LookupKey], now: u64, ) -> Result<Option<ActiveSessionRecord>, StoreError>

Look up an active session by HMAC lookup key candidates.

async fn insert_session(&self, record: SessionRecord) -> Result<(), StoreError>

Insert a new session record.

async fn revoke_session( &self, session_id: &SessionId, now: u64, ) -> Result<(), StoreError>

Revoke a session by its record ID (logout / incident response). Revocation is monotonic: a revoked session cannot be unrevoked.