Struct HoprTicketProcessor 

pub struct HoprTicketProcessor<Chain, Db> { /* private fields */ }

HOPR-specific implementation of UnacknowledgedTicketProcessor and TicketTracker.

Implementations

impl<Chain, Db> HoprTicketProcessor<Chain, Db>

pub fn new( chain_api: Chain, db: Db, chain_key: ChainKeypair, channels_dst: Hash, cfg: HoprTicketProcessorConfig, ) -> Self

Creates a new instance of the HOPR ticket processor.

impl<Chain, Db> HoprTicketProcessor<Chain, Db>

where Db: HoprDbTicketOperations + Clone + Send + 'static,

pub fn outgoing_index_sync_task( &self, reg: AbortRegistration, ) -> impl Future<Output = ()> + use<Db, Chain>

Task that performs periodic synchronization of the outgoing ticket index cache to the underlying database.

If this task is not started, the outgoing ticket indices will not survive a node restart and will result in invalid tickets received by the counterparty.

Trait Implementations

impl<Chain: Clone, Db: Clone> Clone for HoprTicketProcessor<Chain, Db>

fn clone(&self) -> HoprTicketProcessor<Chain, Db>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Chain, Db> TicketTracker for HoprTicketProcessor<Chain, Db>

where Chain: Send + Sync, Db: HoprDbTicketOperations + Clone + Send + Sync + 'static,

type Error = Arc<<Db as HoprDbTicketOperations>::Error>

fn next_outgoing_ticket_index<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 ChannelId, epoch: u32, ) -> Pin<Box<dyn Future<Output = Result<u64, Self::Error>> + Send + 'async_trait>>

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

Gets the next ticket index for an outgoing ticket for the given channel.

fn incoming_channel_unrealized_balance<'life0, 'life1, 'async_trait>( &'life0 self, channel_id: &'life1 ChannelId, epoch: u32, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance, Self::Error>> + Send + 'async_trait>>

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

Retrieves the unrealized balance of the given channel.

fn create_multihop_ticket<'life0, 'life1, 'async_trait>( &'life0 self, channel: &'life1 ChannelEntry, current_path_pos: u8, winning_prob: WinningProbability, ticket_price: HoprBalance, ) -> Pin<Box<dyn Future<Output = Result<TicketBuilder, TicketCreationError<Self::Error>>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Convenience function that allows creating multi-hop tickets.

impl<Chain, Db> UnacknowledgedTicketProcessor for HoprTicketProcessor<Chain, Db>

where Chain: ChainReadChannelOperations + Send + Sync, Db: Send + Sync,

type Error = HoprProtocolError

fn insert_unacknowledged_ticket<'life0, 'life1, 'async_trait>( &'life0 self, next_hop: &'life1 OffchainPublicKey, challenge: HalfKeyChallenge, ticket: UnacknowledgedTicket, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Inserts a verified unacknowledged ticket from a delivered packet into the internal storage.

fn acknowledge_ticket<'life0, 'async_trait>( &'life0 self, peer: OffchainPublicKey, ack: Acknowledgement, ) -> Pin<Box<dyn Future<Output = Result<Option<ResolvedAcknowledgement>, Self::Error>> + Send + 'async_trait>>

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

Finds and acknowledges previously inserted ticket, using an Acknowledgement from the upstream peer.