locutus-node 0.0.1

Locutus P2P network main node implementation
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

use tracing::metadata::LevelFilter;
use tracing_subscriber::util::SubscriberInitExt;

type DynError = Box<dyn std::error::Error + Send + Sync + 'static>;

#[cfg(feature = "local")]
const MAX_SIZE: i64 = 10 * 1024 * 1024;
#[cfg(feature = "local")]
const MAX_MEM_CACHE: u32 = 10_000_000;

#[cfg(feature = "local")]
async fn run() -> Result<(), DynError> {
    use locutus_core::{
        locutus_runtime::{ContractStore, StateStore},
        ContractExecutor, SqlitePool,
    };
    let tmp_path = std::env::temp_dir().join("locutus");
    let contract_store = ContractStore::new(tmp_path.join("contracts"), MAX_SIZE);
    let state_store = StateStore::new(SqlitePool::new().await?, MAX_MEM_CACHE).unwrap();
    let executor = ContractExecutor::new(contract_store.clone(), state_store.clone(), || {
        locutus_core::util::set_cleanup_on_exit().unwrap();
    })
    .await?;
    locutus_node::local_node::run_local_node(executor).await
}

#[allow(unreachable_code)]
fn main() -> Result<(), DynError> {
    #[cfg(not(feature = "local"))]
    {
        panic!("only allowed if local feature is enabled");
    }

    let sub = tracing_subscriber::fmt()
        .with_max_level(LevelFilter::DEBUG)
        .with_level(true)
        .finish();
    sub.init();

    #[allow(unused_variables)]
    let rt = tokio::runtime::Builder::new_multi_thread()
        .worker_threads(4)
        .enable_all()
        .build()
        .unwrap();
    #[cfg(feature = "local")]
    {
        rt.block_on(run())?;
    }

    Ok(())
}