novasymph 0.1.4

Implementation of Streamlet consensus used in Themelio
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use std::{
    net::SocketAddr,
    time::{Duration, SystemTime},
};

use env_logger::Env;
use novasmt::ContentAddrStore;
use novasymph::{BlockBuilder, EpochConfig, EpochProtocol};
use once_cell::sync::Lazy;
use themelio_stf::{melvm::Covenant, GenesisConfig, SealedState};
use themelio_structs::{Block, CoinData, Denom, NetID, ProposerAction, StakeDoc};
use tmelcrypt::{Ed25519PK, Ed25519SK, HashVal};

const COUNT: usize = 1;

/// Bunch of secret keys for testing
static TEST_SKK: Lazy<Vec<Ed25519SK>> =
    Lazy::new(|| (0..COUNT).map(|_| tmelcrypt::ed25519_keygen().1).collect());

fn main() {
    env_logger::Builder::from_env(Env::default().default_filter_or("novasymph")).init();
    let forest = novasmt::Database::new(novasmt::InMemoryCas::default());
    let genesis = GenesisConfig {
        network: NetID::Testnet,
        init_coindata: CoinData {
            denom: Denom::Mel,
            value: (1 << 64).into(),
            additional_data: vec![],
            covhash: HashVal::default().into(),
        },
        init_fee_pool: (1 << 64).into(),
        stakes: TEST_SKK
            .iter()
            .map(|v| {
                (
                    tmelcrypt::hash_single(&v.to_public().0).into(),
                    StakeDoc {
                        pubkey: v.to_public(),
                        e_start: 0,
                        e_post_end: 100000,
                        syms_staked: 1.into(),
                    },
                )
            })
            .collect(),
    }
    .realize(&forest)
    .seal(None);
    smol::future::block_on(async move {
        for i in 0..COUNT {
            // if i < 9 {
            smol::spawn(run_staker(i, genesis.clone())).detach();
            // }
        }
        smol::future::pending().await
    })
}

fn idx_to_addr(idx: usize) -> SocketAddr {
    format!("127.0.0.1:{}", idx + 20000).parse().unwrap()
}

async fn run_staker<C: ContentAddrStore>(
    idx: usize,
    genesis: SealedState<C>,
    //forest: novasmt::Database<C>,
) {
    let protocol = EpochProtocol::new(EpochConfig {
        listen: idx_to_addr(idx),
        bootstrap: (0..COUNT).map(idx_to_addr).collect(),
        genesis,
        //forest,
        start_time: SystemTime::now(),
        interval: Duration::from_secs(5),
        signing_sk: TEST_SKK[idx],
        builder: TrivialBlockBuilder {
            pk: TEST_SKK[idx].to_public(),
        }
        .into(),
        get_confirmed: Box::new(|_| None),
    });
    loop {
        let blk = protocol.next_confirmed().await;
        log::warn!("CONFIRMED {:?}", blk.inner().header().height);
        protocol.reset_genesis(blk.inner().clone());
    }
}

struct TrivialBlockBuilder {
    pk: Ed25519PK,
}

impl<C: ContentAddrStore> BlockBuilder<C> for TrivialBlockBuilder {
    fn build_block(&self, tip: SealedState<C>) -> Block {
        tip.next_state()
            .seal(Some(ProposerAction {
                fee_multiplier_delta: 0,
                reward_dest: Covenant::std_ed25519_pk_legacy(self.pk).hash(),
            }))
            .to_block()
    }
}