Struct InteractionEngine 

pub struct InteractionEngine { /* private fields */ }

Reads, writes and settles persisted interactions (spec §15).

Implementations

impl InteractionEngine

pub fn new(store: Arc<dyn InteractionStore>, config: InteractionConfig) -> Self

Builds an engine over store.

pub fn with_observer(self, observer: Arc<dyn Observer>) -> Self

Sends this stage’s signals to observer (spec §26.2).

Orchestrator sets it from its own observer when it is built, so a card settled out of band — the §15.7 free-text channel, an operator tool, a reconciliation job — is counted on the same series as one a turn settled.

pub const fn config(&self) -> &InteractionConfig

The interaction configuration in force.

pub async fn create( &self, spec: InteractionSpec, account: &AccountId, conversation: ConversationId, turn_id: TurnId, now: DateTime<Utc>, ) -> Result<(Interaction, Vec<InteractionId>), InteractionError>

Materializes one specification and writes it (spec §15.5, §15.6).

A blocking card replaces the case’s current blocking occupant and invalidates it; a non-blocking one is inserted next to whatever is there. The identifier is derived from the turn and the specification key, so a replay writes the same card rather than a duplicate.

Errors

• InteractionError::InvalidSpec when the card could not be answered;
• InteractionError::NotPersisted when the store refused the write — after which the response must not mention the card.

pub async fn persist( &self, specs: &[InteractionSpec], account: &AccountId, conversation: ConversationId, turn_id: TurnId, now: DateTime<Utc>, ) -> PersistedInteractions

Writes every specification, stopping at the first failure.

Nothing here is best effort in the sense of “carry on and hope”: the first failure stops the loop and is reported, precisely so the caller cannot describe cards that are not there.

pub async fn accept( &self, context: ResponseContext<'_>, response: &InteractionResponse, ) -> Result<ResponseAdmission, InteractionError>

Validates a client answer and takes the card into Resolving (spec §15.5, §23 step C).

current_revision is the revision the case is actually at, read fresh: a card bound to an older one is Stale whatever the client echoed.

Errors

InteractionError::Rejected carrying the §15.5 rejection. An identifier of another tenant is InteractionRejection::NotFound, exactly like one that never existed (spec §25.4).

pub async fn settle( &self, account: &AccountId, id: &InteractionId, outcome: ResolutionOutcome, ) -> Result<InteractionRecord, InteractionError>

Settles a Resolving card.

Errors

InteractionError::NotPersisted when the store refused, and InteractionError::Rejected with NotFound when the card is not there.

pub async fn mark_resolved( &self, account: &AccountId, id: &InteractionId, event_ids: Vec<EventId>, ) -> Result<InteractionRecord, InteractionError>

Marks a card Resolved — only legitimate once the command its answer authorized has committed, which is why the events are required (§15.5).

Errors

See Self::settle.

pub async fn mark_failed( &self, account: &AccountId, id: &InteractionId, code: impl Into<String>, ) -> Result<InteractionRecord, InteractionError>

Marks a card Failed after the command it authorized did not commit.

Errors

See Self::settle.

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

Puts a card back to Active so the user may answer again.

Errors

See Self::settle.

pub async fn open_for_conversation( &self, account: &AccountId, conversation: &ConversationId, ) -> Result<Vec<Interaction>, InteractionError>

The open cards of a conversation, oldest first.

Errors

InteractionError::NotPersisted when the store could not answer; silently pretending there are none would let a blocking card be bypassed (I19).

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

The open cards of one case, oldest first.

Errors

See Self::open_for_conversation.

pub async fn blocking_answered_at( &self, account: &AccountId, case_key: &CaseKey, revision: CaseRevision, ) -> Result<bool, InteractionError>

Whether the user has already answered a blocking card of this case at this revision.

What stops a declined card going straight back up. See InteractionReader::blocking_answered_at.

Errors

See Self::open_for_conversation.

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

One stored card, whatever its status.

Errors

See Self::open_for_conversation; an identifier of another tenant is InteractionRejection::NotFound.

Trait Implementations

impl Clone for InteractionEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InteractionEngine

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

Formats the value using the given formatter.