Trait UnacknowledgedTicketProcessor 

pub trait UnacknowledgedTicketProcessor {
    type Error: Error + Send + Sync + 'static;

    // Required methods
    fn insert_unacknowledged_ticket(
        &self,
        next_hop: &OffchainPublicKey,
        challenge: HalfKeyChallenge,
        ticket: UnacknowledgedTicket,
    ) -> Result<(), Self::Error>;
    fn acknowledge_tickets(
        &self,
        peer: OffchainPublicKey,
        acks: Vec<Acknowledgement>,
    ) -> Result<Vec<ResolvedAcknowledgement>, TicketAcknowledgementError<Self::Error>>;
}

Performs necessary processing of unacknowledged tickets in the HOPR packet processing pipeline.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn insert_unacknowledged_ticket( &self, next_hop: &OffchainPublicKey, challenge: HalfKeyChallenge, ticket: UnacknowledgedTicket, ) -> Result<(), Self::Error>

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

The ticket corresponds to the given challenge and awaits to be acknowledged once an [Acknowledgement] is received from the next_hop.

This operation should be reasonably fast and should not block the main processing pipeline.

fn acknowledge_tickets( &self, peer: OffchainPublicKey, acks: Vec<Acknowledgement>, ) -> Result<Vec<ResolvedAcknowledgement>, TicketAcknowledgementError<Self::Error>>

Finds and acknowledges previously inserted tickets, using incoming Acknowledgements from the upstream peer.

Function should first check if any acknowledgements are expected from the given peer.

Furthermore, the function must verify each given acknowledgement and find if it evaluates to any solutions to challenges of previously inserted tickets.

On success, the resolutions contain decisions whether the previously stored ticket with a matching challenge was found, and whether it is winning (and thus also redeemable) or losing. Challenges for which tickets were not found are skipped.

Must return TicketAcknowledgementError::UnexpectedAcknowledgement if no Acknowledgements from the given peer was expected.

This operation is expected to be somewhat long-running and significantly blocking.

Implementations on Foreign Types

impl<'a, T: 'a + UnacknowledgedTicketProcessor + ?Sized> UnacknowledgedTicketProcessor for &'a T

type Error = <T as UnacknowledgedTicketProcessor>::Error

fn insert_unacknowledged_ticket( &self, next_hop: &OffchainPublicKey, challenge: HalfKeyChallenge, ticket: UnacknowledgedTicket, ) -> Result<(), Self::Error>

fn acknowledge_tickets( &self, peer: OffchainPublicKey, acks: Vec<Acknowledgement>, ) -> Result<Vec<ResolvedAcknowledgement>, TicketAcknowledgementError<Self::Error>>

impl<T: UnacknowledgedTicketProcessor + ?Sized> UnacknowledgedTicketProcessor for Box<T>

type Error = <T as UnacknowledgedTicketProcessor>::Error

fn insert_unacknowledged_ticket( &self, next_hop: &OffchainPublicKey, challenge: HalfKeyChallenge, ticket: UnacknowledgedTicket, ) -> Result<(), Self::Error>

fn acknowledge_tickets( &self, peer: OffchainPublicKey, acks: Vec<Acknowledgement>, ) -> Result<Vec<ResolvedAcknowledgement>, TicketAcknowledgementError<Self::Error>>

impl<T: UnacknowledgedTicketProcessor + ?Sized> UnacknowledgedTicketProcessor for Arc<T>

type Error = <T as UnacknowledgedTicketProcessor>::Error

fn insert_unacknowledged_ticket( &self, next_hop: &OffchainPublicKey, challenge: HalfKeyChallenge, ticket: UnacknowledgedTicket, ) -> Result<(), Self::Error>

fn acknowledge_tickets( &self, peer: OffchainPublicKey, acks: Vec<Acknowledgement>, ) -> Result<Vec<ResolvedAcknowledgement>, TicketAcknowledgementError<Self::Error>>

Implementors

impl<Chain> UnacknowledgedTicketProcessor for HoprUnacknowledgedTicketProcessor<Chain>

where Chain: ChainReadChannelOperations + Send + Sync,

type Error = HoprProtocolError