Struct DiffStore 

pub struct DiffStore {
    inner: RwLock<HashMap<DiffId, DiffRecord>>,
    ttl_secs: i64,
}

In-memory store for pending diff records.

Backed by a RwLock<HashMap> so reads (polling, rendering the modal) are non-blocking. Mutations take a write lock.

The store is intentionally not persisted to disk — if the app restarts, pending diffs are lost and the user must start the flow again.

Fields

inner: RwLock<HashMap<DiffId, DiffRecord>>

ttl_secs: i64

Implementations

impl DiffStore

pub fn new() -> Self

Create a new store with the default 5-minute TTL.

pub fn with_ttl(ttl_secs: i64) -> Self

Create a store with a custom TTL (useful in tests with a mock clock).

fn now_secs() -> i64

Return current Unix time in seconds.

Using SystemTime directly. Test overrides pass explicit timestamps through the create_at parameter variant.

pub fn create(&self, payload: DiffPayload) -> DiffId

Create a new diff record and return its DiffId.

The record starts in DiffStatus::Pending.

pub fn create_at(&self, payload: DiffPayload, now: i64) -> DiffId

Create a diff record at an explicit timestamp (test helper).

pub fn cancel(&self, id: &DiffId) -> Result<(), AppError>

Set the status of a diff record to DiffStatus::Cancelled.

A cancelled record’s consume will subsequently return None (the Validation error path in object_set_storage_class).

Returns AppError::NotFound when the id does not exist.

pub fn consume(&self, id: &DiffId) -> Option<DiffPayload>

Consume a diff record on confirmation.

Returns Some(payload) exactly once for a record in Pending state that has not yet expired. Sets the status to Confirmed.

Returns None when:

• The record does not exist.
• The record was cancelled.
• The record is expired (checked against wall clock).
• The record was already consumed (double-confirm rejection).

pub fn consume_at(&self, id: &DiffId, now: i64) -> Option<DiffPayload>

Consume at an explicit timestamp (test helper).

pub fn get(&self, id: &DiffId) -> Option<DiffRecord>

Read a diff record without consuming it.

Returns None when the id does not exist. Does not expire the record.

pub fn gc(&self)

Sweep expired records from the store.

Called periodically by a background task (or on demand in tests). Records whose expires_at has elapsed are removed rather than merely flagged so the map does not grow unbounded.

pub fn gc_at(&self, now: i64)

GC at an explicit timestamp (test helper).

Trait Implementations

impl Debug for DiffStore

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

Formats the value using the given formatter.

impl Default for DiffStore

fn default() -> DiffStore

Returns the “default value” for a type.