Struct FakeStores 

pub struct FakeStores { /* private fields */ }

The in-memory stores, wrapped for turn tests.

Cheap to build and self-contained: one MemoryStores on a frozen ManualClock, a CountingStores in front of it, and a Stores built from the counting layer — which is the value the runtime takes.

Implementations

impl FakeStores

pub fn new() -> Self

Empty stores on a clock frozen at the Unix epoch.

pub fn at(start: DateTime<Utc>) -> Self

Empty stores on a clock frozen at start.

pub fn stores(&self) -> &Stores

The set of stores to hand to the code under test.

pub fn memory(&self) -> &Arc<MemoryStores>

The underlying store, for the few things only it can do.

pub fn clock(&self) -> &Arc<ManualClock>

The clock the store stamps its own columns from.

pub fn now(&self) -> DateTime<Utc>

The instant the store would stamp a write with right now.

pub fn advance(&self, delta: TimeDelta)

Moves the clock forward.

pub fn set_time(&self, instant: DateTime<Utc>)

Moves the clock to instant.

pub fn fail_at( &self, point: FailurePoint, error: StoreError, ) -> Result<(), StoreError>

Arms one failure at point: the next call reaching it returns error.

Whether the write before the boundary survives is part of the point’s meaning; see FailurePoint.

Errors

• Corrupt when the store’s internal lock is poisoned.

pub fn fail_at_boundary( &self, name: &str, error: StoreError, ) -> Result<(), UnknownBoundary>

Arms one failure at the boundary with this name (see CRASH_BOUNDARIES).

Errors

• UnknownBoundary when no boundary carries that name.

pub fn armed_failures(&self) -> Vec<FailurePoint>

The boundaries still armed, in arming order.

pub fn clear_failures(&self)

Disarms every pending failure.

pub fn call_count(&self, method: &str) -> usize

How many times method was called, as "<role>.<method>".

pub fn calls(&self) -> Vec<(&'static str, usize)>

Every method called at least once, in key order.

pub fn total_calls(&self) -> usize

Total calls across every store method.

pub fn reset_calls(&self)

Forgets the tally, keeping the data. Use it between the arrange and act phases of a test.

pub async fn events_for( &self, account: &AccountId, case_key: &CaseKey, ) -> Result<Vec<StoredEvent>, StoreError>

Every event of a case, in append order.

Errors

• Whatever the store returns; NotFound is never one of them, an unknown case simply has no events.

pub async fn event_types( &self, account: &AccountId, case_key: &CaseKey, ) -> Result<Vec<String>, StoreError>

The event types of a case, in append order: the shortest assertion about what a turn actually committed.

Errors

• Whatever the store returns.

pub async fn events_by_ids( &self, account: &AccountId, ids: &[EventId], ) -> Result<Vec<StoredEvent>, StoreError>

The events with these identifiers, for checking a receipt’s citations.

Errors

• Whatever the store returns.

pub async fn journal_entry( &self, account: &AccountId, command_id: &CommandId, ) -> Result<CommandJournalEntry, StoreError>

The journal entry of a command.

Errors

• NotFound when the command was never admitted for this account.

pub async fn journal_for_turn( &self, account: &AccountId, turn_id: &TurnId, ) -> Result<Vec<CommandJournalEntry>, StoreError>

Every journal entry of a turn, in admission order.

Errors

• Whatever the store returns.

pub async fn open_interactions( &self, account: &AccountId, case_key: &CaseKey, ) -> Result<Vec<Interaction>, StoreError>

The open cards of a case.

Errors

• Whatever the store returns.

pub async fn interaction( &self, account: &AccountId, id: &InteractionId, ) -> Result<InteractionRecord, StoreError>

One card, whatever its status.

Errors

• NotFound when it does not exist for this account.

pub async fn turn( &self, account: &AccountId, turn_id: &TurnId, ) -> Result<StoredTurn, StoreError>

A stored turn, user side and assistant side.

Errors

• NotFound when the turn does not exist for this account.

pub async fn turn_phase( &self, account: &AccountId, turn_id: &TurnId, ) -> Result<TurnPhaseMarker, StoreError>

The phase marker of a turn.

Errors

• NotFound when the turn does not exist for this account.

pub async fn replay_record( &self, account: &AccountId, turn_id: &TurnId, ) -> Result<ReplayRecord, StoreError>

The replay record of a turn.

Errors

• NotFound when no record was written for this account and turn.

pub async fn outbox_for_command( &self, command_id: &CommandId, ) -> Result<Vec<OutboxRecord>, StoreError>

The outbox rows a command produced.

Errors

• Whatever the store returns.

pub async fn replay_records_for( &self, account: &AccountId, conversation: &ConversationId, limit: usize, ) -> Result<Vec<ReplayRecord>, StoreError>

Every conversation-scoped replay record, most recent first.

Errors

• Whatever the store returns.

Trait Implementations

impl Debug for FakeStores

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

Formats the value using the given formatter.

impl Default for FakeStores

fn default() -> Self

Returns the “default value” for a type.