Struct SessionProvider 

pub struct SessionProvider {
    signer: PrivateKeySigner,
    signing_mode: TempoSigningMode,
    authorized_signer: Option<Address>,
    default_deposit: Option<u128>,
    channels: Arc<Mutex<HashMap<String, ChannelEntry>>>,
    key_provisioned: Arc<Mutex<bool>>,
    persisted: Arc<Mutex<HashMap<String, Channel>>>,
    pending: Arc<Mutex<Option<PendingAction>>>,
    key_chain_id: Option<u64>,
    key_currencies: Vec<Address>,
    origin: String,
}

Tempo session provider using expiring nonces.

Unlike mpp-rs’s TempoSessionProvider which fetches sequential nonces (requiring a non-gated RPC), this provider uses expiring nonces for channel open transactions — matching how tempoxyz/wallet works.

Fields

signer: PrivateKeySigner

signing_mode: TempoSigningMode

authorized_signer: Option<Address>

default_deposit: Option<u128>

channels: Arc<Mutex<HashMap<String, ChannelEntry>>>

key_provisioned: Arc<Mutex<bool>>

persisted: Arc<Mutex<HashMap<String, Channel>>>

pending: Arc<Mutex<Option<PendingAction>>>

Tracks uncommitted open/top-up state for deferred persistence.

key_chain_id: Option<u64>

Chain ID from the key entry in keys.toml that was used to initialize this provider. Used to reject challenges for a different chain.

key_currencies: Vec<Address>

Currencies from the key’s spending limits. Used to reject challenges for currencies the key cannot pay with.

origin: String

Implementations

impl SessionProvider

pub fn new(signer: PrivateKeySigner, origin: String) -> Self

Create a new session provider with the given signer and RPC origin URL.

Channel state is shared process-wide: all SessionProvider instances share the same in-memory channels and persisted state. This prevents concurrent providers (e.g. multiple forge script providers for the same URL) from reading stale cumulative_amount values from disk and producing duplicate vouchers.

pub fn with_signing_mode(self, mode: TempoSigningMode) -> Self

Set the signing mode (direct or keychain).

pub const fn with_authorized_signer(self, addr: Address) -> Self

Set the authorized signer address for keychain mode.

pub const fn with_default_deposit(self, deposit: u128) -> Self

Set the default deposit amount.

pub fn with_key_filters( self, chain_id: Option<u64>, currencies: Vec<Address>, ) -> Self

Set the chain ID and currencies from the key entry used to initialize this provider. Used to reject challenges for incompatible chains/currencies. When chain_id is None (e.g. env var key), chain filtering is skipped.

pub fn matches_challenge( &self, chain_id: Option<u64>, currency: Option<Address>, ) -> bool

Check whether this provider’s key is compatible with the given chain ID and currency from a 402 challenge.

pub fn clear_channels(&self)

Clear channels belonging to this origin (e.g. after server 410).

Only removes channels whose origin matches self.origin, preserving channels for other RPC endpoints.

pub fn set_key_provisioned(&self, provisioned: bool)

Mark whether the access key has been provisioned on-chain.

pub fn is_key_provisioned(&self) -> bool

Check whether the access key has been provisioned on-chain.

pub fn flush_pending(&self)

Persist any pending open/top-up/voucher state to disk.

Called by the transport after the server confirms acceptance.

pub fn commit_topup_and_track_voucher(&self)

Commit a pending top-up (deposit increase) without flushing to disk.

Called by the transport when the server returns 204 (top-up accepted). The deposit increase is now committed, but the follow-up voucher is tracked as a new pending action.

pub fn rollback_pending(&self)

Roll back pending open/top-up/voucher state on failure.

Called by the transport when the server rejects the payment or times out.

fn channel_key( origin: &str, payer: &Address, authorized_signer: Option<Address>, payee: &Address, currency: &Address, escrow: &Address, chain_id: u64, ) -> String

fn resolve_deposit(&self, suggested: Option<&str>) -> Result<u128, MppError>

async fn create_open_tx( &self, payer: Address, options: OpenPayloadOptions, ) -> Result<(ChannelEntry, SessionCredentialPayload), MppError>

async fn create_topup_tx( &self, entry: &ChannelEntry, additional_deposit: u128, currency: Address, fee_payer: bool, ) -> Result<SessionCredentialPayload, MppError>

impl SessionProvider

async fn pay_charge( &self, challenge: &PaymentChallenge, ) -> Result<PaymentCredential, MppError>

Handle a charge intent by building and signing a TIP-20 transfer transaction.

impl SessionProvider

async fn pay_session( &self, challenge: &PaymentChallenge, ) -> Result<PaymentCredential, MppError>

Trait Implementations

impl Clone for SessionProvider

fn clone(&self) -> SessionProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionProvider

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

Formats the value using the given formatter.

impl PaymentProvider for SessionProvider

fn supports(&self, method: &str, intent: &str) -> bool

Check if this provider supports the given method and intent combination.

async fn pay( &self, challenge: &PaymentChallenge, ) -> Result<PaymentCredential, MppError>

Execute payment for the given challenge and return a credential.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 368 bytes