tari_core 5.3.1

Core Tari protocol components
Documentation
// Copyright 2019. The Tari Project
//
// Redistribution and use in source and binary forms, with or without modification, are permitted provided that the
// following conditions are met:
//
// 1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following
// disclaimer.
//
// 2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the
// following disclaimer in the documentation and/or other materials provided with the distribution.
//
// 3. Neither the name of the copyright holder nor the names of its contributors may be used to endorse or promote
// products derived from this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
// INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
// SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
// USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//

#![allow(clippy::indexing_slicing)]
use tari_common::configuration::Network;
use tari_core::{
    chain_storage::{BlockchainDatabase, BlockchainDatabaseConfig, Validators},
    consensus::{BaseNodeConsensusManager, BaseNodeConsensusManagerBuilder},
    test_helpers::blockchain::{TempDatabase, create_store_with_consensus},
    validation::DifficultyCalculator,
};
use tari_node_components::blocks::ChainBlock;
use tari_transaction_components::{
    consensus::{ConsensusConstants, ConsensusConstantsBuilder},
    key_manager::KeyManager,
    tari_amount::{T, uT},
    transaction_components::WalletOutput,
    txn_schema,
};

use crate::helpers::block_builders::{create_genesis_block, generate_new_block};

static EMISSION: [u64; 2] = [10, 10];

/// Create a simple 6 block memory-backed database.
/// Genesis block:
///    100_000_000 -> utxo_0 (0.0)
/// Block 1:
///   0.0    -> 60_000_000 (1.0)
///          -> change     (1.1)
///          -> 100 fee/g
/// Block 2:
///   (1.0)  -> 20_000_000 (2.0)
///              5_000_000 (2.1)
///              1_000_000 (2.2)
///              change    (2.3)
///              120 fee/g
///   (1.1)  -> 15_000_000  (2.4)
///             change
///             75 fee/g
/// Block 3:
///  (2.1) + (2.2)  -> 6_000_000 - fee  (3.0)
///                    25 uT fee/g
///  (2.4) + (2.3)  -> 40_000_000       (3.1)
///                    change           (3.2)
///                    100 fee/g
/// Block 4:
///  (2.0) -> 1_000_000 (4.0)
///        -> 2_000_000 (4.1)
///        -> 3_000_000 (4.2)
///        -> 4_000_000 (4.3)
///        -> change    (4.4)
/// Block 5:
///  (4.3 + 3.1)-> 20_000_000 (5.0)
///             -> 21_000_000 (5.1)
///             -> change     (5.2)
///  (4.1)      -> 500_000    (5.3)
///             -> 1_300_00   (5.4)
///             -> change     (5.5)
/// (3.2)       -> 500_000    (5.6)
///             -> change     (5.7)
#[allow(clippy::identity_op)]
#[allow(dead_code)]
pub fn create_blockchain_db_no_cut_through() -> (
    BlockchainDatabase<TempDatabase>,
    Vec<ChainBlock>,
    Vec<Vec<WalletOutput>>,
    BaseNodeConsensusManager,
    KeyManager,
) {
    let network = Network::LocalNet;
    let (mut db, mut blocks, mut outputs, consensus_manager, key_manager) = create_new_blockchain(network);
    // Block 1
    let txs = vec![txn_schema!(from: vec![outputs[0][0].clone()], to: vec![60*T], fee: 100*uT)];
    generate_new_block(
        &mut db,
        &mut blocks,
        &mut outputs,
        txs,
        &consensus_manager,
        &key_manager,
    )
    .unwrap();
    // Block 2
    let txs = vec![
        txn_schema!(from: vec![outputs[1][0].clone()], to: vec![20*T, 5*T, 1*T], fee: 120*uT),
        txn_schema!(from: vec![outputs[1][1].clone()], to: vec![15*T], fee: 75*uT),
    ];
    generate_new_block(
        &mut db,
        &mut blocks,
        &mut outputs,
        txs,
        &consensus_manager,
        &key_manager,
    )
    .unwrap();
    // Block 3
    let txs = vec![
        txn_schema!(from: vec![outputs[2][1].clone(), outputs[2][2].clone()], to: vec![outputs[2][2].value()/2]),
        txn_schema!(from: vec![outputs[2][4].clone(), outputs[2][3].clone()], to: vec![40*T], fee: 100*uT),
    ];
    generate_new_block(
        &mut db,
        &mut blocks,
        &mut outputs,
        txs,
        &consensus_manager,
        &key_manager,
    )
    .unwrap();
    // Block 4
    let txs = vec![txn_schema!(
        from: vec![outputs[2][0].clone()],
        to: vec![1 * T, 2 * T, 3 * T, 4 * T]
    )];
    generate_new_block(
        &mut db,
        &mut blocks,
        &mut outputs,
        txs,
        &consensus_manager,
        &key_manager,
    )
    .unwrap();
    // Block 5
    let txs = vec![
        txn_schema!(
            from: vec![outputs[4][3].clone(), outputs[3][2].clone()],
            to: vec![20 * T, 21 * T]
        ),
        txn_schema!(
            from: vec![outputs[4][1].clone()],
            to: vec![500_000 * uT, 1_300_000 * uT]
        ),
        txn_schema!(from: vec![outputs[3][3].clone()], to: vec![500_000 * uT]),
    ];
    generate_new_block(
        &mut db,
        &mut blocks,
        &mut outputs,
        txs,
        &consensus_manager,
        &key_manager,
    )
    .unwrap();
    (db, blocks, outputs, consensus_manager, key_manager)
}

pub fn consensus_constants(network: Network) -> ConsensusConstantsBuilder {
    ConsensusConstantsBuilder::new(network)
        .with_emission_amounts(100_000_000.into(), EMISSION.to_vec(), 10, 1000)
        .with_coinbase_lockheight(1)
}

/// Create a new blockchain database containing only the Genesis block
#[allow(dead_code)]
pub fn create_new_blockchain(
    network: Network,
) -> (
    BlockchainDatabase<TempDatabase>,
    Vec<ChainBlock>,
    Vec<Vec<WalletOutput>>,
    BaseNodeConsensusManager,
    KeyManager,
) {
    let key_manager = KeyManager::new_random().unwrap();
    let consensus_constants = consensus_constants(network).build();
    let (block0, output) = create_genesis_block(&consensus_constants, &key_manager);
    let consensus_manager = BaseNodeConsensusManagerBuilder::new(network)
        .add_consensus_constants(consensus_constants)
        .with_block(block0.clone())
        .build()
        .unwrap();
    (
        create_store_with_consensus(consensus_manager.clone()),
        vec![block0],
        vec![vec![output]],
        consensus_manager,
        key_manager,
    )
}

/// Create a new blockchain database containing only the Genesis block
#[allow(dead_code)]
pub fn create_new_blockchain_with_constants(
    network: Network,
    constants: ConsensusConstants,
) -> (
    BlockchainDatabase<TempDatabase>,
    Vec<ChainBlock>,
    Vec<Vec<WalletOutput>>,
    BaseNodeConsensusManager,
    KeyManager,
) {
    let key_manager = KeyManager::new_random().unwrap();
    let (block0, output) = create_genesis_block(&constants, &key_manager);
    let consensus_manager = BaseNodeConsensusManagerBuilder::new(network)
        .add_consensus_constants(constants)
        .with_block(block0.clone())
        .build()
        .unwrap();
    (
        create_store_with_consensus(consensus_manager.clone()),
        vec![block0],
        vec![vec![output]],
        consensus_manager,
        key_manager,
    )
}

/// Create a new blockchain database containing only the Genesis block
#[allow(dead_code)]
pub fn create_new_blockchain_lmdb(
    network: Network,
    validators: Validators<TempDatabase>,
    config: BlockchainDatabaseConfig,
) -> (
    BlockchainDatabase<TempDatabase>,
    Vec<ChainBlock>,
    Vec<Vec<WalletOutput>>,
    BaseNodeConsensusManager,
    KeyManager,
) {
    let key_manager = KeyManager::new_random().unwrap();
    let consensus_constants = consensus_constants(network).build();
    let (block0, output) = create_genesis_block(&consensus_constants, &key_manager);
    let consensus_manager = BaseNodeConsensusManagerBuilder::new(network)
        .add_consensus_constants(consensus_constants)
        .with_block(block0.clone())
        .build()
        .unwrap();
    let db = TempDatabase::new();
    let db = BlockchainDatabase::start_new(
        db,
        consensus_manager.clone(),
        validators,
        config,
        DifficultyCalculator::new(consensus_manager.clone(), Default::default()),
    )
    .unwrap();
    (db, vec![block0], vec![vec![output]], consensus_manager, key_manager)
}