essential-node-cli 0.9.0

The Essential node CLI
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

use super::*;
use std::time::Duration;

#[tokio::test]
async fn test_args() {
    let args = Args::parse_from(Some(""));
    let r = tokio::time::timeout(Duration::from_millis(100), run(args.clone())).await;
    // Error means the timeout happened thus run was successful.
    assert!(r.is_err(), "{:?}", r);

    // Bad relayer source endpoint.
    let mut a = args.clone();
    a.relayer_source_endpoint = Some("http://0.0.0.0:0".to_string());
    let r = tokio::time::timeout(Duration::from_millis(100), run(a.clone())).await;

    // Error means the timeout happened thus run was successful.
    // Relayer should still run and continue to try to connect to source while
    // logging errors.
    assert!(r.is_err(), "{:?}", r);

    // Good relayer source endpoint.
    let mut a = args.clone();
    let (_api, port) = test_node().await;
    a.relayer_source_endpoint = Some(format!("http://127.0.0.1:{}", port));

    let r = tokio::time::timeout(Duration::from_millis(100), run(a.clone())).await;
    // Error means the timeout happened thus run was successful.
    assert!(r.is_err(), "{:?}", r);

    // Disable all streams
    let mut a = args.clone();
    a.disable_validation = true;
    a.relayer_source_endpoint = None;

    let r = tokio::time::timeout(Duration::from_millis(100), run(a.clone())).await;
    // Error means the timeout happened thus run was successful.
    assert!(r.is_err(), "{:?}", r);
}

async fn test_node() -> (impl std::future::Future<Output = ()>, u16) {
    let block_tx = BlockTx::new();
    let block_rx = block_tx.new_listener();
    let config = node::db::pool::Config {
        source: node::db::pool::Source::Memory(uuid::Uuid::new_v4().to_string()),
        ..Default::default()
    };
    let db = node::db::ConnectionPool::with_tables(&config).unwrap();
    let api_state = node_api::State {
        new_block: Some(block_rx),
        conn_pool: db.clone(),
    };
    let router = node_api::router(api_state);
    let listener = tokio::net::TcpListener::bind("0.0.0.0:0").await.unwrap();
    let port = listener.local_addr().unwrap().port();
    let api = async move {
        node_api::serve(&router, &listener, 2).await;
    };
    (api, port)
}