darkfi/script/research/nodes-tool/src/main.rs

use std::{fs::File, io::Write};

use darkfi::{
    consensus::{
        block::{Block, BlockOrderStore, BlockProposal, BlockStore},
        blockchain::{Blockchain, ProposalsChain},
        metadata::{Metadata, OuroborosMetadata, StreamletMetadata, StreamletMetadataStore},
        participant::Participant,
        state::{ConsensusState, ValidatorState},
        tx::{Tx, TxStore},
        util::Timestamp,
        vote::Vote,
    },
    util::expand_path,
    Result,
};

#[derive(Debug)]
struct ParticipantInfo {
    _id: u64,
    _joined: u64,
    _voted: Option<u64>,
}

impl ParticipantInfo {
    pub fn new(participant: &Participant) -> ParticipantInfo {
        let _id = participant.id;
        let _joined = participant.joined;
        let _voted = participant.voted;
        ParticipantInfo { _id, _joined, _voted }
    }
}

#[derive(Debug)]
struct VoteInfo {
    _proposal: blake3::Hash,
    _sl: u64,
    _id: u64,
}

impl VoteInfo {
    pub fn new(vote: &Vote) -> VoteInfo {
        let _proposal = vote.proposal;
        let _sl = vote.sl;
        let _id = vote.id;
        VoteInfo { _proposal, _sl, _id }
    }
}

#[derive(Debug)]
struct StreamletMetadataInfo {
    _votes: Vec<VoteInfo>,
    _notarized: bool,
    _finalized: bool,
    _participants: Vec<ParticipantInfo>,
}

impl StreamletMetadataInfo {
    pub fn new(metadata: &StreamletMetadata) -> StreamletMetadataInfo {
        let mut _votes = Vec::new();
        for vote in &metadata.votes {
            _votes.push(VoteInfo::new(&vote));
        }
        let _notarized = metadata.notarized;
        let _finalized = metadata.finalized;
        let mut _participants = Vec::new();
        for participant in &metadata.participants {
            _participants.push(ParticipantInfo::new(&participant));
        }
        StreamletMetadataInfo { _votes, _notarized, _finalized, _participants }
    }
}

#[derive(Debug)]
struct OuroborosMetadataInfo {
    _proof: String,
    _r: String,
    _s: String,
}

impl OuroborosMetadataInfo {
    pub fn new(metadata: &OuroborosMetadata) -> OuroborosMetadataInfo {
        let _proof = metadata.proof.clone();
        let _r = metadata.r.clone();
        let _s = metadata.s.clone();
        OuroborosMetadataInfo { _proof, _r, _s }
    }
}

#[derive(Debug)]
struct MetadataInfo {
    _timestamp: Timestamp,
    _om: OuroborosMetadataInfo,
}

impl MetadataInfo {
    pub fn new(metadata: &Metadata) -> MetadataInfo {
        let _timestamp = metadata.timestamp.clone();
        let _om = OuroborosMetadataInfo::new(&metadata.om);
        MetadataInfo { _timestamp, _om }
    }
}

#[derive(Debug)]
struct ProposalInfo {
    _id: u64,
    _st: blake3::Hash,
    _sl: u64,
    _txs: Vec<Tx>,
    _metadata: MetadataInfo,
    _sm: StreamletMetadataInfo,
}

impl ProposalInfo {
    pub fn new(proposal: &BlockProposal) -> ProposalInfo {
        let _id = proposal.id;
        let _st = proposal.st;
        let _sl = proposal.sl;
        let _txs = proposal.txs.clone();
        let _metadata = MetadataInfo::new(&proposal.metadata);
        let _sm = StreamletMetadataInfo::new(&proposal.sm);
        ProposalInfo { _id, _st, _sl, _txs, _metadata, _sm }
    }
}

#[derive(Debug)]
struct ProposalsInfoChain {
    _proposals: Vec<ProposalInfo>,
}

impl ProposalsInfoChain {
    pub fn new(proposals: &ProposalsChain) -> ProposalsInfoChain {
        let mut _proposals = Vec::new();
        for proposal in &proposals.proposals {
            _proposals.push(ProposalInfo::new(&proposal));
        }
        ProposalsInfoChain { _proposals }
    }
}

#[derive(Debug)]
struct ConsensusInfo {
    _genesis: Timestamp,
    _proposals: Vec<ProposalsInfoChain>,
}

impl ConsensusInfo {
    pub fn new(consensus: &ConsensusState) -> ConsensusInfo {
        let _genesis = consensus.genesis.clone();
        let mut _proposals = Vec::new();
        for proposal in &consensus.proposals {
            _proposals.push(ProposalsInfoChain::new(&proposal));
        }
        ConsensusInfo { _genesis, _proposals }
    }
}

#[derive(Debug)]
struct BlockInfo {
    _hash: blake3::Hash,
    _st: blake3::Hash,
    _sl: u64,
    _txs: Vec<blake3::Hash>,
}

impl BlockInfo {
    pub fn new(_hash: blake3::Hash, block: &Block) -> BlockInfo {
        let _st = block.st;
        let _sl = block.sl;
        let _txs = block.txs.clone();
        BlockInfo { _hash, _st, _sl, _txs }
    }
}

#[derive(Debug)]
struct BlockInfoChain {
    _blocks: Vec<BlockInfo>,
}

impl BlockInfoChain {
    pub fn new(blockstore: &BlockStore) -> BlockInfoChain {
        let mut _blocks = Vec::new();
        let result = blockstore.get_all();
        match result {
            Ok(iter) => {
                for item in iter.iter() {
                    match item {
                        Some((hash, block)) => _blocks.push(BlockInfo::new(hash.clone(), &block)),
                        None => (),
                    };
                }
            }
            Err(e) => println!("Error: {:?}", e),
        }
        BlockInfoChain { _blocks }
    }
}

#[derive(Debug)]
struct OrderInfo {
    _sl: u64,
    _hash: blake3::Hash,
}

impl OrderInfo {
    pub fn new(_sl: u64, _hash: blake3::Hash) -> OrderInfo {
        OrderInfo { _sl, _hash }
    }
}

#[derive(Debug)]
struct BlockOrderStoreInfo {
    _order: Vec<OrderInfo>,
}

impl BlockOrderStoreInfo {
    pub fn new(orderstore: &BlockOrderStore) -> BlockOrderStoreInfo {
        let mut _order = Vec::new();
        let result = orderstore.get_all();
        match result {
            Ok(iter) => {
                for item in iter.iter() {
                    match item {
                        Some((slot, hash)) => {
                            _order.push(OrderInfo::new(slot.clone(), hash.clone()))
                        }
                        None => (),
                    };
                }
            }
            Err(e) => println!("Error: {:?}", e),
        }
        BlockOrderStoreInfo { _order }
    }
}

#[derive(Debug)]
struct TxInfo {
    _hash: blake3::Hash,
    _payload: String,
}

impl TxInfo {
    pub fn new(_hash: blake3::Hash, tx: &Tx) -> TxInfo {
        let _payload = tx.payload.clone();
        TxInfo { _hash, _payload }
    }
}

#[derive(Debug)]
struct TxStoreInfo {
    _transactions: Vec<TxInfo>,
}

impl TxStoreInfo {
    pub fn new(txstore: &TxStore) -> TxStoreInfo {
        let mut _transactions = Vec::new();
        let result = txstore.get_all();
        match result {
            Ok(iter) => {
                for item in iter.iter() {
                    match item {
                        Some((hash, tx)) => _transactions.push(TxInfo::new(hash.clone(), &tx)),
                        None => (),
                    };
                }
            }
            Err(e) => println!("Error: {:?}", e),
        }
        TxStoreInfo { _transactions }
    }
}

#[derive(Debug)]
struct HashedMetadataInfo {
    _block: blake3::Hash,
    _metadata: StreamletMetadataInfo,
}

impl HashedMetadataInfo {
    pub fn new(_block: blake3::Hash, metadata: &StreamletMetadata) -> HashedMetadataInfo {
        let _metadata = StreamletMetadataInfo::new(&metadata);
        HashedMetadataInfo { _block, _metadata }
    }
}

#[derive(Debug)]
struct MetadataStoreInfo {
    _metadata: Vec<HashedMetadataInfo>,
}

impl MetadataStoreInfo {
    pub fn new(metadatastore: &StreamletMetadataStore) -> MetadataStoreInfo {
        let mut _metadata = Vec::new();
        let result = metadatastore.get_all();
        match result {
            Ok(iter) => {
                for item in iter.iter() {
                    match item {
                        Some((hash, m)) => {
                            _metadata.push(HashedMetadataInfo::new(hash.clone(), &m))
                        }
                        None => (),
                    };
                }
            }
            Err(e) => println!("Error: {:?}", e),
        }
        MetadataStoreInfo { _metadata }
    }
}

#[derive(Debug)]
struct BlockchainInfo {
    _blocks: BlockInfoChain,
    _order: BlockOrderStoreInfo,
    _transactions: TxStoreInfo,
    _metadata: MetadataStoreInfo,
}

impl BlockchainInfo {
    pub fn new(blockchain: &Blockchain) -> BlockchainInfo {
        let _blocks = BlockInfoChain::new(&blockchain.blocks);
        let _order = BlockOrderStoreInfo::new(&blockchain.order);
        let _transactions = TxStoreInfo::new(&blockchain.transactions);
        let _metadata = MetadataStoreInfo::new(&blockchain.streamlet_metadata);
        BlockchainInfo { _blocks, _order, _transactions, _metadata }
    }
}

#[derive(Debug)]
struct StateInfo {
    _id: u64,
    _consensus: ConsensusInfo,
    _blockchain: BlockchainInfo,
}

impl StateInfo {
    pub fn new(state: &ValidatorState) -> StateInfo {
        let _id = state.id;
        let _consensus = ConsensusInfo::new(&state.consensus);
        let _blockchain = BlockchainInfo::new(&state.blockchain);
        StateInfo { _id, _consensus, _blockchain }
    }
}

fn main() -> Result<()> {
    let nodes = 4;
    let genesis = 1648383795;
    for i in 0..nodes {
        let path = format!("~/.config/darkfi/validatord_db_{:?}", i);
        let database_path = expand_path(&path).unwrap();
        println!("Export data from sled database: {:?}", database_path);
        let state = ValidatorState::new(database_path, i, genesis).unwrap();
        let info = StateInfo::new(&*state.read().unwrap());
        let info_string = format!("{:#?}", info);
        let path = format!("validatord_state_{:?}", i);
        let mut file = File::create(path)?;
        file.write(info_string.as_bytes())?;
    }

    Ok(())
}