zaino-state 0.3.0

A mempool and chain-fetching service built on top of zebra's ReadStateService and TrustedChainSync.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Zaino-State ChainIndex Finalised State (ZainoDB) unit tests.
mod migrations;
mod v0;
pub(crate) mod v1;

use std::future::Future;
use tempfile::TempDir;

use crate::chain_index::finalised_state::ZainoDB;
use crate::chain_index::source::mockchain_source::MockchainSource;
use crate::chain_index::tests::init_tracing;
use crate::chain_index::tests::vectors::{build_mockchain_source, load_test_vectors};
use crate::error::FinalisedStateError;

/// Regression helper for zingolabs/zaino#1032.
///
/// Spawns a `ZainoDB` with the provided version-specific spawner, waits for
/// ready, then asserts that `shutdown()` returns in well under 5 s — i.e. the
/// background handle is awaited, not padded with an unconditional sleep.
async fn assert_shutdown_returns_promptly<F, Fut>(version_label: &str, spawn_fn: F)
where
    F: FnOnce(MockchainSource) -> Fut,
    Fut: Future<Output = Result<(TempDir, ZainoDB), FinalisedStateError>>,
{
    init_tracing();

    let source = build_mockchain_source(load_test_vectors().unwrap().blocks);
    let (_db_dir, zaino_db) = spawn_fn(source).await.unwrap();
    zaino_db.wait_until_ready().await;

    let start = std::time::Instant::now();
    zaino_db.shutdown().await.unwrap();
    let elapsed = start.elapsed();

    assert!(
        elapsed < std::time::Duration::from_secs(1),
        "{version_label} shutdown took {elapsed:?}, expected < 1 s"
    );
}