Struct FileInviteStore 

pub struct FileInviteStore { /* private fields */ }

Invite store persisted at <root>/.server/invites.json.

Implementations

impl FileInviteStore

pub fn new(root: impl AsRef<Path>) -> Self

Store rooted at the pod data directory root.

pub fn path(&self) -> &Path

Location of the backing file.

pub async fn list(&self) -> Result<Vec<InviteRow>, InviteStoreError>

Every stored invite, oldest first.

pub async fn revoke(&self, token: &str) -> Result<bool, InviteStoreError>

Delete an invite by its token, or by the unique id prefix shown in invite list (8 or more hex characters). Ok(true) if it existed (JSS revokeInvite).

pub async fn consume(&self, token: &str) -> Result<Consume, InviteStoreError>

Redeem one use of token: checks expiry and the max_uses cap and records the use, all under the store lock, so two concurrent redemptions of a single-use invite cannot both succeed. A redemption path must call this and proceed only on Consume::Granted.

use solid_pod_rs_idp::{Invite, InviteStore};
use solid_pod_rs_server::cli::{Consume, FileInviteStore};

let store = FileInviteStore::new("/var/lib/pod");
store
    .insert(Invite { token: "t".into(), max_uses: Some(1), expires_at: None })
    .await?;
assert_eq!(store.consume("t").await?, Consume::Granted);
assert_eq!(store.consume("t").await?, Consume::Exhausted);

Trait Implementations

impl InviteStore for FileInviteStore

fn insert<'life0, 'async_trait>( &'life0 self, invite: Invite, ) -> Pin<Box<dyn Future<Output = Result<(), InviteStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert an invite. Idempotent on the token: if the token already exists the call is a no-op that returns Ok(()). The token is caller-supplied so the CLI can echo it back to the operator without a second round-trip.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Invite>, InviteStoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch an invite by its token.