Refactor sync out of block_store.rs

z2/src/converter.rs

@@ -14,18 +14,14 @@ use bitvec::{bitarr, order::Msb0};
 use eth_trie::{EthTrie, MemoryDB, Trie};
 use indicatif::{ProgressBar, ProgressFinish, ProgressIterator, ProgressStyle};
 use itertools::Itertools;
-use libp2p::PeerId;
 use sha2::{Digest, Sha256};
-use tokio::sync::mpsc;
 use tracing::{debug, trace, warn};
 use zilliqa::{
-    block_store::BlockStore,
     cfg::{scilla_ext_libs_path_default, Amount, Config, NodeConfig},
     crypto::{Hash, SecretKey},
     db::Db,
     exec::store_external_libraries,
     message::{Block, QuorumCertificate, Vote, MAX_COMMITTEE_SIZE},
-    node::{MessageSender, RequestId},
     schnorr,
     scilla::{storage_key, CheckOutput, ParamValue, Transition},
     state::{Account, Code, ContractInit, State},
@@ -346,27 +342,15 @@ pub async fn convert_persistence(
         "{msg} {wide_bar} [{per_sec}] {human_pos}/~{human_len} ({elapsed}/~{duration})",
     )?;
 
-    let (outbound_message_sender, _a) = mpsc::unbounded_channel();
-    let (local_message_sender, _b) = mpsc::unbounded_channel();
-    let message_sender = MessageSender {
-        our_shard: 0,
-        our_peer_id: PeerId::random(),
-        outbound_channel: outbound_message_sender,
-        local_channel: local_message_sender,
-        request_id: RequestId::default(),
-    };
+    // let (outbound_message_sender, _a) = mpsc::unbounded_channel();
+    // let (local_message_sender, _b) = mpsc::unbounded_channel();
 
     let zq2_db = Arc::new(zq2_db);
     let node_config = &zq2_config.nodes[0];
-    let block_store = Arc::new(BlockStore::new(
-        node_config,
-        zq2_db.clone(),
-        message_sender.clone(),
-    )?);
     let mut state = State::new_with_genesis(
         zq2_db.clone().state_trie()?,
         node_config.clone(),
-        block_store,
+        zq2_db.clone(),
     )?;
 
     let mut scilla_docker = run_scilla_docker()?;

zilliqa/src/api/zilliqa.rs

@@ -508,7 +508,7 @@ fn get_blockchain_info(_: Params, node: &Arc<Mutex<Node>>) -> Result<BlockchainI
     let num_peers = node.get_peer_num();
     let num_tx_blocks = node.get_chain_tip();
     let num_ds_blocks = (num_tx_blocks / TX_BLOCKS_PER_DS_BLOCK) + 1;
-    let num_transactions = node.consensus.block_store.get_num_transactions()?;
+    let num_transactions = node.consensus.get_num_transactions()?;
     let ds_block_rate = tx_block_rate / TX_BLOCKS_PER_DS_BLOCK as f64;
 
     // num_txns_ds_epoch
@@ -518,7 +518,6 @@ fn get_blockchain_info(_: Params, node: &Arc<Mutex<Node>>) -> Result<BlockchainI
     for i in current_epoch_first..node.get_chain_tip() {
         let block = node
             .consensus
-            .block_store
             .get_canonical_block_by_number(i)?
             .ok_or_else(|| anyhow!("Block not found"))?;
         num_txns_ds_epoch += block.transactions.len();
@@ -527,7 +526,6 @@ fn get_blockchain_info(_: Params, node: &Arc<Mutex<Node>>) -> Result<BlockchainI
     // num_txns_tx_epoch
     let latest_block = node
         .consensus
-        .block_store
         .get_canonical_block_by_number(node.get_chain_tip())?;
     let num_txns_tx_epoch = match latest_block {
         Some(block) => block.transactions.len(),
@@ -1247,11 +1245,7 @@ fn get_recent_transactions(
     let mut txns = Vec::new();
     let mut blocks_searched = 0;
     while block_number > 0 && txns.len() < 100 && blocks_searched < 100 {
-        let block = match node
-            .consensus
-            .block_store
-            .get_canonical_block_by_number(block_number)?
-        {
+        let block = match node.consensus.get_canonical_block_by_number(block_number)? {
             Some(block) => block,
             None => continue,
         };
@@ -1274,7 +1268,7 @@ fn get_recent_transactions(
 // GetNumTransactions
 fn get_num_transactions(_params: Params, node: &Arc<Mutex<Node>>) -> Result<String> {
     let node = node.lock().unwrap();
-    let num_transactions = node.consensus.block_store.get_num_transactions()?;
+    let num_transactions = node.consensus.get_num_transactions()?;
     Ok(num_transactions.to_string())
 }
 
@@ -1283,7 +1277,6 @@ fn get_num_txns_tx_epoch(_params: Params, node: &Arc<Mutex<Node>>) -> Result<Str
     let node = node.lock().unwrap();
     let latest_block = node
         .consensus
-        .block_store
         .get_canonical_block_by_number(node.get_chain_tip())?;
     let num_transactions = match latest_block {
         Some(block) => block.transactions.len(),
@@ -1302,7 +1295,6 @@ fn get_num_txns_ds_epoch(_params: Params, node: &Arc<Mutex<Node>>) -> Result<Str
     for i in current_epoch_first..node.get_chain_tip() {
         let block = node
             .consensus
-            .block_store
             .get_canonical_block_by_number(i)?
             .ok_or_else(|| anyhow!("Block not found"))?;
         num_txns_epoch += block.transactions.len();