Struct interledger_service_util::ValidatorService

pub struct ValidatorService<IO, S, A> { /* fields omitted */ }

Validator Service

Incoming or Outgoing Service responsible for rejecting timed out requests and checking that fulfillments received match the execution_condition from the original Prepare packets. Forwards everything else.

Methods

impl<I, S, A> ValidatorService<I, S, A> where
    I: IncomingService<A>,
    S: AddressStore,
    A: Account, 

pub fn incoming(store: S, next: I) -> Self

impl<O, S, A> ValidatorService<O, S, A> where
    O: OutgoingService<A>,
    S: AddressStore,
    A: Account, 

pub fn outgoing(store: S, next: O) -> Self

Trait Implementations

impl<IO: Clone, S: Clone, A: Clone> Clone for ValidatorService<IO, S, A>

fn clone(&self) -> ValidatorService<IO, S, A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<I, S, A> IncomingService<A> for ValidatorService<I, S, A> where
    I: IncomingService<A>,
    S: AddressStore,
    A: Account, 

type Future = BoxedIlpFuture

fn handle_request(&mut self, request: IncomingRequest<A>) -> Self::Future

On receiving a request:

1. If the prepare packet in the request is not expired, forward it, otherwise return a reject

impl<O, S, A> OutgoingService<A> for ValidatorService<O, S, A> where
    O: OutgoingService<A>,
    S: AddressStore,
    A: Account, 

type Future = BoxedIlpFuture

fn send_request(&mut self, request: OutgoingRequest<A>) -> Self::Future

On sending a request:

1. If the outgoing packet has expired, return a reject with the appropriate ErrorCode
2. Tries to forward the request
   • If no response is received before the prepare packet's expiration, it assumes that the outgoing request has timed out.
   • If no timeout occurred, but still errored it will just return the reject
   • If the forwarding is successful, it should receive a fulfill packet. Depending on if the hash of the fulfillment condition inside the fulfill is a preimage of the condition of the prepare:
     • return the fulfill if it matches
     • otherwise reject