Struct DynamoStateStore 

pub struct DynamoStateStore { /* private fields */ }

DynamoDB-backed state store

Implementations

impl DynamoStateStore

pub async fn new() -> Result<Self, StateError>

Create new state store with default config

pub async fn with_config(config: DynamoConfig) -> Result<Self, StateError>

Create with custom config

pub async fn lookup_user_by_card( &self, fingerprint: &str, ) -> Result<Option<CardMapping>, StateError>

Look up user by card fingerprint This is the “glue” that connects POS webhooks to user vaults

pub async fn link_card( &self, fingerprint: &str, user_pubkey: &str, card_last4: &str, ) -> Result<(), StateError>

Link a card fingerprint to a user

pub async fn unlink_card(&self, fingerprint: &str) -> Result<(), StateError>

Unlink a card fingerprint

pub async fn get_user_cards( &self, user_pubkey: &str, ) -> Result<Vec<CardMapping>, StateError>

Get all cards linked to a user

pub async fn is_transaction_processed( &self, txn_id: &str, ) -> Result<bool, StateError>

Check if a transaction has already been processed

pub async fn mark_transaction_processed( &self, txn_id: &str, user_pubkey: &str, cred_amount: u64, ) -> Result<(), StateError>

Mark a transaction as processed

pub async fn store_session_key( &self, user_pubkey: &str, session: &SessionKeyData, ) -> Result<(), StateError>

Store a session key with TTL

pub async fn get_session_key( &self, user_pubkey: &str, ) -> Result<Option<SessionKeyData>, StateError>

Get active session key for user

pub async fn invalidate_session( &self, user_pubkey: &str, ) -> Result<(), StateError>

Invalidate session key

pub async fn add_pending_capture( &self, user_pubkey: &str, capture: &PendingCapture, ) -> Result<(), StateError>

Add a pending capture (limited to max_pending_captures per user)

pub async fn get_pending_captures( &self, user_pubkey: &str, ) -> Result<Vec<PendingCapture>, StateError>

Get all pending captures for user

pub async fn remove_pending_capture( &self, user_pubkey: &str, timestamp: i64, ) -> Result<(), StateError>

Remove a pending capture (after it’s been processed)

pub async fn cache_current_merchant( &self, user_pubkey: &str, merchant_id: &str, ) -> Result<(), StateError>

Cache current merchant for user (geofence)

pub async fn get_current_merchant( &self, user_pubkey: &str, ) -> Result<Option<String>, StateError>

Get cached merchant location

pub async fn clear_current_merchant( &self, user_pubkey: &str, ) -> Result<(), StateError>

Clear cached merchant location

impl DynamoStateStore

pub async fn context_fetch_async( &self, user_pubkey: &str, ) -> Result<UserContext, StateError>

Async context fetch

pub async fn context_push_async( &self, context: UserContext, ) -> Result<(), StateError>

Async context push with optimistic locking

pub async fn context_patch_async( &self, user_pubkey: &str, path: &str, value: Value, ) -> Result<(), StateError>

Async context patch

pub async fn push_event_async( &self, user_pubkey: &str, event: ContextEvent, ) -> Result<(), StateError>

Async push event

Trait Implementations

impl StateStore for DynamoStateStore

fn context_fetch(&self, user_pubkey: &str) -> Result<UserContext, StateError>

Fetch user context (<100ms target)

fn context_push(&self, context: UserContext) -> Result<(), StateError>

Push updated context (with optimistic locking)

fn context_batch_fetch( &self, user_pubkeys: &[String], ) -> Result<Vec<UserContext>, StateError>

Fetch multiple users (for batch operations)

fn context_patch( &self, user_pubkey: &str, path: &str, value: Value, ) -> Result<(), StateError>

Update specific field without full fetch/push

fn push_event( &self, user_pubkey: &str, event: ContextEvent, ) -> Result<(), StateError>

Add event to recent events (ring buffer)

fn get_or_init(&self, user_pubkey: &str) -> Result<UserContext, StateError>

Get or initialize context for new user