Struct MemoryDecisionStore 

pub struct MemoryDecisionStore {
    inner: RwLock<Inner>,
    per_account: usize,
    total: usize,
    arrivals: Arc<Notify>,
    epoch: String,
}

The in-process decision store.

Fields

inner: RwLock<Inner>

per_account: usize

total: usize

arrivals: Arc<Notify>

epoch: String

Implementations

impl MemoryDecisionStore

pub fn new() -> Self

An empty store with the default bounds.

pub fn with_bounds(per_account: usize, total: usize) -> Self

An empty store with bounds of a deployment’s own choosing; see didbot_config::sections::OAuthSection.

Trait Implementations

impl Debug for MemoryDecisionStore

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

Formats the value using the given formatter.

impl DecisionStore for MemoryDecisionStore

fn put(&self, record: DecisionRecord) -> Result<Stored, DecisionRefused>

Stores a freshly minted record, assigning its sequence and its first_time, and hands back what was stored.

fn check_room(&self) -> Result<(), DecisionRefused>

Whether the server-wide bound has room right now, without writing anything and without checking any account’s own bound — there is no account to check one against here.

fn get(&self, request_uri: &str) -> Option<DecisionRecord>

One record by the pushed request it decides, whatever state it is in.

fn by_token(&self, token: &str) -> Option<DecisionRecord>

One record by the token that approves it, if that token is still the token of a live record.

fn pending_for( &self, account: &str, cursor: Option<&str>, ) -> (Vec<DecisionRecord>, String)

This account’s live records that arrived after cursor, oldest first, and the cursor a caller should send next.

fn settle( &self, request_uri: &str, state: DecisionState, ) -> Option<DecisionRecord>

Moves a live record out of DecisionState::Pending, returning it as it was just before. None if it is unknown, expired or already settled — which is what makes an approval single-use even before the consent reference is consumed.

fn approve( &self, request_uri: &str, redirect: Option<String>, ) -> Option<DecisionRecord>

DecisionStore::settles a live record as DecisionState::Approved and holds redirect for a browser signed in as the account, in one step, so no load of the page finds the approval without it.

fn holds(&self, request_uri: &str) -> bool

Whether an approval holds a redirect for a browser.

fn collect(&self, request_uri: &str) -> Option<String>

Hands over the redirect an approval held for a browser, once.

fn sweep(&self, now: OffsetDateTime)

Drops every record whose pushed request has expired, answered or not, and the redirect it held.

fn arrivals(&self) -> Arc<Notify>

Woken every time a record arrives, so a long poll does not have to spin.

fn epoch(&self) -> String

This store’s arrival-order epoch; see Cursor.

fn remember( &self, account: &str, client_key: &ClientKey, client_id: &str, granted: ScopeSet, now: OffsetDateTime, )

Remembers the account’s approval of client_key at granted, until REMEMBERED_TTL from now. Replaces the one it had, rather than merging scopes into it.

fn remembered( &self, account: &str, client_key: &ClientKey, now: OffsetDateTime, ) -> Option<Remembered>

The account’s live remembered approval of client_key, if any.

fn forget_client(&self, client_id: &str, account: Option<&str>) -> usize

Forgets the remembered approvals of client_id, on account or on every account, and says how many it forgot.

fn forget_account(&self, account: &str)

Forgets every remembered approval the account made.

fn forget_all(&self)

Forgets every remembered approval.

impl Default for MemoryDecisionStore

fn default() -> Self

Returns the “default value” for a type.