Struct MempoolTxVerifier 

pub struct MempoolTxVerifier<ZS, Mempool> {
    network: Network,
    state: Timeout<ZS>,
    mempool: Option<Timeout<Mempool>>,
    script_verifier: Verifier,
    mempool_setup_rx: Receiver<Mempool>,
}

Asynchronous verification of mempool transactions.

Correctness

Transaction verification requests should be wrapped in a timeout, so that out-of-order and invalid requests do not hang indefinitely. See the router module documentation for details.

Fields

network: Network

state: Timeout<ZS>

mempool: Option<Timeout<Mempool>>

script_verifier: Verifier

mempool_setup_rx: Receiver<Mempool>

Implementations

impl<ZS, Mempool> MempoolTxVerifier<ZS, Mempool>

where ZS: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, ZS::Future: Send + 'static, Mempool: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, Mempool::Future: Send + 'static,

pub fn new( network: &Network, state: ZS, mempool_setup_rx: Receiver<Mempool>, ) -> Self

Creates a new mempool transaction verifier.

impl<ZS, Mempool> MempoolTxVerifier<ZS, Mempool>

where ZS: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, ZS::Future: Send + 'static, Mempool: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, Mempool::Future: Send + 'static,

async fn verify_mempool_lock_time( tx: &Transaction, height: Height, state: Timeout<ZS>, ) -> Result<(), TransactionError>

Validates mempool lock-time consensus rules.

Queries state only for time-based lock times.

async fn mempool_best_chain_next_median_time_past( state: Timeout<ZS>, ) -> Result<DateTime32, TransactionError>

Fetches the median-time-past of the next block after the best state tip.

This is used to verify that the lock times of mempool transactions can be included in any valid next block.

async fn mempool_spent_utxos( tx: Arc<Transaction>, height: Height, state: Timeout<ZS>, mempool: Option<Timeout<Mempool>>, ) -> Result<(HashMap<OutPoint, Utxo>, Vec<Output>, Vec<OutPoint>), TransactionError>

Looks up UTXOs spent by a mempool tx, first querying the best chain state and then the mempool for inputs whose outputs are not present in the best chain.

height is the next block height, used to construct Utxo values for outputs sourced from the mempool.

Returns an OutPoint -> Utxo map, a vec of Outputs in the same order as the matching inputs in tx, and a vec of OutPoints that were sourced from the mempool rather than the best chain.

Trait Implementations

impl<ZS, Mempool> Service<MempoolRequest> for MempoolTxVerifier<ZS, Mempool>

where ZS: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, ZS::Future: Send + 'static, Mempool: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, Mempool::Future: Send + 'static,

type Response = MempoolResponse

Responses given by the service.

type Error = TransactionError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<MempoolTxVerifier<ZS, Mempool> as Service<MempoolRequest>>::Response, <MempoolTxVerifier<ZS, Mempool> as Service<MempoolRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: MempoolRequest) -> Self::Future

Process the request and return the response asynchronously.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.