Struct DbVerificationStore 

pub struct DbVerificationStore<'a> { /* private fields */ }

Implementations

impl<'a> DbVerificationStore<'a>

pub fn new(adapter: &'a dyn DbAdapter) -> Self

pub fn from_context(context: &'a AuthContext) -> Result<Self, RustAuthError>

pub fn with_options( adapter: &'a dyn DbAdapter, schema: DbSchema, options: VerificationOptions, ) -> Self

pub fn with_default_schema( adapter: &'a dyn DbAdapter, options: VerificationOptions, ) -> Self

pub async fn create_verification( &self, input: CreateVerificationInput, ) -> Result<Verification, RustAuthError>

pub async fn find_verification( &self, identifier: &str, ) -> Result<Option<Verification>, RustAuthError>

pub async fn find_verification_including_expired( &self, identifier: &str, ) -> Result<Option<Verification>, RustAuthError>

pub async fn consume_verification_including_expired( &self, identifier: &str, ) -> Result<Option<Verification>, RustAuthError>

Atomically consumes a verification record if present.

Parallel callers racing on the same identifier only observe a successful consume once: the delete is keyed by both identifier and row id so later attempts delete zero rows and return None.

pub async fn compare_and_update_verification_value( &self, identifier: &str, verification_id: &str, expected_value: &str, new_value: String, ) -> Result<Option<Verification>, RustAuthError>

Atomically updates a verification row only when its stored value is unchanged.

Parallel callers racing on the same identifier can use this as a compare-and-swap boundary when incrementing attempt counters or other value-encoded state.

pub async fn update_verification( &self, identifier: &str, input: UpdateVerificationInput, ) -> Result<Option<Verification>, RustAuthError>

pub async fn delete_verification( &self, identifier: &str, ) -> Result<(), RustAuthError>

pub async fn take_verification( &self, identifier: &str, ) -> Result<Option<Verification>, RustAuthError>

Remove and return an active verification, if one exists.

This enforces single-use semantics for challenge-like tokens: concurrent callers only observe the stored value once.

pub async fn take_verification_including_expired( &self, identifier: &str, ) -> Result<Option<Verification>, RustAuthError>

pub async fn delete_expired_verifications(&self) -> Result<u64, RustAuthError>

Trait Implementations

impl<'a> Clone for DbVerificationStore<'a>

fn clone(&self) -> DbVerificationStore<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.