Struct Data 

pub(super) struct Data {
    registrationtoken_info: Arc<Map>,
}

Provides database operations for registration tokens.

Each token maps directly to its serialized DatabaseTokenInfo. Expired or exhausted tokens are removed by validation and iteration paths.

Fields

registrationtoken_info: Arc<Map>

Implementations

impl Data

pub(super) fn new(db: &Arc<Database>) -> Self

Opens the registration token metadata map.

The returned handle shares the caller’s database instance.

pub(super) async fn save_token( &self, token: &str, expires: TokenExpires, ) -> Result<DatabaseTokenInfo>

Stores a new registration token and its expiration policy.

The token begins with zero uses. A token already present in the database is rejected.

pub(super) async fn revoke_token(&self, token: &str) -> Result

Deletes a registration token from persistent storage.

Unknown tokens produce a not-found request error.

pub(super) async fn check_token(&self, token: &str, consume: bool) -> bool

Checks a stored token and optionally consumes one use.

Invalid tokens are deleted. A successful consumption writes an incremented count or removes the token when the updated count reaches its threshold. Concurrent checks are not serialized.

pub(super) async fn get_token_info( &self, token: &str, ) -> Result<DatabaseTokenInfo>

Loads a database token’s stored metadata.

The metadata is returned without checking expiration. Missing or undecodable rows produce a not-found request error.

pub(super) async fn update_token( &self, token: &str, expires: TokenExpires, ) -> Result<DatabaseTokenInfo>

Replaces a token’s expiration policy while preserving its use count.

The token must already exist. The updated metadata is persisted and returned.

pub(super) fn iterate_and_clean_tokens( &self, ) -> impl Stream<Item = (&str, DatabaseTokenInfo)> + Send + '_

Streams every valid database token and removes invalid entries.

Unreadable rows are skipped before validation. Expired or exhausted tokens are deleted as the stream is consumed.