Struct ChainActions 

pub struct ChainActions<Db> { /* private fields */ }

Contains all actions that a node can execute on-chain.

Implementations

impl<Db> ChainActions<Db>

pub fn new( me: &ChainKeypair, index_db: HoprIndexerDb, node_db: Db, tx_sender: ActionSender, ) -> Self

Creates a new instance.

pub fn self_address(&self) -> Address

On-chain address of this node

Trait Implementations

impl<Db: Sync> ChannelActions for ChainActions<Db>

fn open_channel<'life0, 'async_trait>( &'life0 self, destination: Address, amount: HoprBalance, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

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

Opens a channel to the given destination with the given amount staked.

fn fund_channel<'life0, 'async_trait>( &'life0 self, channel_id: Hash, amount: HoprBalance, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

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

Funds the given channel with the given amount

fn close_channel<'life0, 'async_trait>( &'life0 self, channel: ChannelEntry, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

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

Closes the channel to counterparty in the given direction. Optionally can issue redeeming of all tickets in that channel, in case the direction is ChannelDirection::Incoming.

impl<Db: Clone> Clone for ChainActions<Db>

fn clone(&self) -> ChainActions<Db>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Db: Sync> NodeActions for ChainActions<Db>

fn withdraw<'life0, 'async_trait, C>( &'life0 self, recipient: Address, amount: Balance<C>, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

where C: 'async_trait + Currency + Send, Self: 'async_trait, 'life0: 'async_trait,

Withdraws the specified amount of tokens or native coins to the given recipient.

fn announce<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, multiaddrs: &'life1 [Multiaddr], offchain_key: &'life2 OffchainKeypair, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Announces node on-chain with key binding. The operation should also check if such an announcement has not been already made on-chain.

fn register_safe_by_node<'life0, 'async_trait>( &'life0 self, safe_address: Address, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

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

Registers the safe address with the node

impl<Db> TicketRedeemActions for ChainActions<Db>

where Db: HoprDbTicketOperations + Sync + 'static,

fn redeem_tickets<'life0, 'async_trait>( &'life0 self, selector: TicketSelector, ) -> Pin<Box<dyn Future<Output = Result<Vec<PendingAction>>> + Send + 'async_trait>>

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

Redeems all tickets based on the given TicketSelector.

fn redeem_ticket<'life0, 'async_trait>( &'life0 self, ack_ticket: AcknowledgedTicket, ) -> Pin<Box<dyn Future<Output = Result<PendingAction>> + Send + 'async_trait>>

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

Tries to redeem the given ticket. If the ticket is not redeemable, returns an error. Otherwise, the transaction hash of the on-chain redemption is returned.