Struct StubChainApi 

pub struct StubChainApi {
    pub(crate) me: Address,
    pub(crate) key_addr_map: BiMap<OffchainPublicKey, Address>,
    pub(crate) channels: Vec<ChannelEntry>,
    pub(crate) id_mapper: StubKeyIdMapper,
    pub(crate) ticket_price: HoprBalance,
    pub(crate) win_prob: WinningProbability,
}

Lightweight in-memory stub implementing the chain-API traits needed by HoprEncoder / HoprDecoder / HoprTicketProcessor.

All lookups are simple BiMap or Vec scans — no async I/O, no database.

Fields

me: Address

key_addr_map: BiMap<OffchainPublicKey, Address>

channels: Vec<ChannelEntry>

id_mapper: StubKeyIdMapper

ticket_price: HoprBalance

win_prob: WinningProbability

Implementations

impl StubChainApi

pub fn builder() -> StubChainApiBuilder

Returns a new StubChainApiBuilder.

pub fn key_addr_map(&self) -> &BiMap<OffchainPublicKey, Address>

Returns the key-address mapping.

pub fn channels(&self) -> &[ChannelEntry]

Returns the registered channels.

Trait Implementations

impl ChainKeyOperations for StubChainApi

type Error = StubError

type Mapper = StubKeyIdMapper

Mapping between [HoprKeyIdent] and [OffchainPublicKey].

fn chain_key_to_packet_key( &self, chain: &Address, ) -> Result<Option<OffchainPublicKey>, Self::Error>

Translates [Address] into [OffchainPublicKey].

fn packet_key_to_chain_key( &self, packet: &OffchainPublicKey, ) -> Result<Option<Address>, Self::Error>

Translates [OffchainPublicKey] into [Address].

fn key_id_mapper_ref(&self) -> &Self::Mapper

Returns a reference to [KeyIdMapping] for offchain key IDs.

impl ChainReadChannelOperations for StubChainApi

type Error = StubError

fn me(&self) -> &Address

Returns on-chain [Address] of the current node.

fn channel_by_id( &self, channel_id: &ChannelId, ) -> Result<Option<ChannelEntry>, Self::Error>

Returns a single channel given channel_id.

fn stream_channels<'a>( &'a self, _selector: ChannelSelector, ) -> Result<BoxStream<'a, ChannelEntry>, Self::Error>

Returns a stream of channels given the [ChannelSelector].

fn channel_by_parties( &self, src: &Address, dst: &Address, ) -> Result<Option<ChannelEntry>, Self::Error>

Returns a single channel given src and dst.

impl ChainReadTicketOperations for StubChainApi

type Error = StubError

fn outgoing_ticket_values( &self, configured_wp: Option<WinningProbability>, configured_price: Option<HoprBalance>, ) -> Result<(WinningProbability, HoprBalance), Self::Error>

Retrieves the winning probability and ticket price for outgoing tickets, with respect to the optionally pre-configured values.

fn incoming_ticket_values( &self, ) -> Result<(WinningProbability, HoprBalance), Self::Error>

Retrieves the expected minimum winning probability and ticket price for incoming tickets.

impl ChainValues for StubChainApi

type Error = StubError

fn balance<'life0, 'async_trait, C, A>( &'life0 self, _address: A, ) -> Pin<Box<dyn Future<Output = Result<Balance<C>, Self::Error>> + Send + 'async_trait>>

where C: 'async_trait + Currency, A: 'async_trait + Into<Address> + Send, Self: 'async_trait, 'life0: 'async_trait,

Returns the native or token currency balance of the given on-chain account.

fn domain_separators<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<DomainSeparators, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the domain separators of HOPR smart contracts.

fn minimum_incoming_ticket_win_prob<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<WinningProbability, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the network-set minimum incoming ticket winning probability.

fn minimum_ticket_price<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the network-set minimum ticket price.

fn key_binding_fee<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the current key binding fee used for new key-binding announcements.

fn channel_closure_notice_period<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Duration, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the grace period for channel closure finalization.

fn chain_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ChainInfo, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the information about the HOPR network on-chain deployment.

fn redemption_stats<'life0, 'async_trait, A>( &'life0 self, __arg1: A, ) -> Pin<Box<dyn Future<Output = Result<RedemptionStats, Self::Error>> + Send + 'async_trait>>

where A: 'async_trait + Into<Address> + Send, Self: 'async_trait, 'life0: 'async_trait,

Gets the ticket redemption stats for the given safe address.

fn typical_resolution_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Duration, Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the expected time for on-chain events to be resolved.

impl Clone for StubChainApi

fn clone(&self) -> StubChainApi

Returns a duplicate of the value.

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

Performs copy-assignment from source.