merge fg flexidag

Cargo.toml

@@ -1,7 +1,6 @@
 [workspace]
 resolver = "2"
 members = [
-    "consensus/dag",
     "benchmarks",
     "commons/stest",
     "commons/bcs_ext",
@@ -112,10 +111,11 @@ members = [
     "cmd/miner_client/api",
     "cmd/db-exporter",
     "cmd/genesis-nft-miner",
+    "flexidag",
+    "flexidag/dag",
 ]
 
 default-members = [
-    "consensus/dag",
     "benchmarks",
     "commons/stest",
     "commons/bcs_ext",
@@ -219,6 +219,8 @@ default-members = [
     "stratum",
     "cmd/miner_client/api",
     "cmd/db-exporter",
+    "flexidag",
+    "flexidag/dag",
 ]
 
 [profile.dev]
@@ -248,7 +250,7 @@ api-limiter = { path = "commons/api-limiter" }
 arc-swap = "1.5.1"
 arrayref = "0.3"
 ascii = "1.0.0"
-async-std = "1.12"
+async-std = { version = "1.12", features = ["attributes", "tokio1"] }
 async-trait = "0.1.53"
 asynchronous-codec = "0.5"
 atomic-counter = "1.0.1"
@@ -259,6 +261,9 @@ bcs-ext = { path = "commons/bcs_ext" }
 bech32 = "0.9"
 bencher = "0.1.5"
 bitflags = "1.3.2"
+faster-hex = "0.6"
+indexmap = "1.9.1"
+bincode = { version = "1", default-features = false }
 bs58 = "0.3.1"
 byteorder = "1.3.4"
 bytes = "1"
@@ -500,7 +505,8 @@ starcoin-parallel-executor = { path = "vm/parallel-executor" }
 starcoin-transaction-benchmarks = { path = "vm/transaction-benchmarks" }
 starcoin-language-e2e-tests = { path = "vm/e2e-tests" }
 starcoin-proptest-helpers = { path = "vm/proptest-helpers" }
-
+starcoin-flexidag = { path = "flexidag" }
+starcoin-dag = {path = "flexidag/dag"}
 syn = { version = "1.0.107", features = [
     "full",
     "extra-traits",
@@ -535,7 +541,7 @@ walkdir = "2.3.1"
 wasm-timer = "0.2"
 which = "4.1.0"
 zeroize = "1.3.0"
-starcoin-dag = {path = "consensus/dag"}
+
 [profile.release.package]
 starcoin-service-registry.debug = 1
 starcoin-chain.debug = 1

account/src/account_test.rs

@@ -224,7 +224,7 @@ pub fn test_wallet_account() -> Result<()> {
     );
     //println!("verify result is {:?}", sign.verify(&raw_txn, &public_key)?);
     println!("public key is {:?}", public_key.to_bytes().as_ref());
-    println!("hash value is {:?}", &hash_value);
+    println!("hash value is {:?}", hash_value);
     println!("key is {:?}", key.derived_address());
     println!("address is {:?},result is {:?}", address, result);
 

benchmarks/src/chain.rs

@@ -9,6 +9,7 @@ use starcoin_chain::BlockChain;
 use starcoin_chain::{ChainReader, ChainWriter};
 use starcoin_config::{temp_dir, ChainNetwork, DataDirPath, RocksdbConfig};
 use starcoin_consensus::Consensus;
+use starcoin_dag::blockdag::BlockDAG;
 use starcoin_genesis::Genesis;
 use starcoin_storage::cache_storage::CacheStorage;
 use starcoin_storage::db_storage::DBStorage;

block-relayer/src/block_relayer.rs

@@ -203,7 +203,9 @@ impl BlockRelayer {
         ctx: &mut ServiceContext<BlockRelayer>,
     ) -> Result<()> {
         let network = ctx.get_shared::<NetworkServiceRef>()?;
-        let block_connector_service = ctx.service_ref::<BlockConnectorService>()?.clone();
+        let block_connector_service = ctx
+            .service_ref::<BlockConnectorService<TxPoolService>>()?
+            .clone();
         let txpool = self.txpool.clone();
         let metrics = self.metrics.clone();
         let fut = async move {
@@ -277,7 +279,7 @@ impl EventHandler<Self, NewHeadBlock> for BlockRelayer {
     fn handle_event(&mut self, event: NewHeadBlock, ctx: &mut ServiceContext<BlockRelayer>) {
         debug!(
             "[block-relay] Handle new head block event, block_id: {:?}",
-            event.0.block().id()
+            event.executed_block.block().id()
         );
         let network = match ctx.get_shared::<NetworkServiceRef>() {
             Ok(network) => network,
@@ -286,7 +288,7 @@ impl EventHandler<Self, NewHeadBlock> for BlockRelayer {
                 return;
             }
         };
-        self.broadcast_compact_block(network, event.0);
+        self.broadcast_compact_block(network, event.executed_block);
     }
 }
 

chain/Cargo.toml

@@ -24,7 +24,10 @@ starcoin-vm-types = { workspace = true }
 starcoin-storage = { workspace = true }
 thiserror = { workspace = true }
 starcoin-network-rpc-api = { workspace = true }
-starcoin-dag = {workspace = true}
+async-std = { workspace = true }
+starcoin-flexidag ={ workspace = true }
+starcoin-dag ={ workspace = true }
+
 [dev-dependencies]
 proptest = { workspace = true }
 proptest-derive = { workspace = true }

chain/api/Cargo.toml

@@ -18,7 +18,6 @@ thiserror = { workspace = true }
 starcoin-network-rpc-api = { workspace = true }
 starcoin-config = { workspace = true }
 
-
 [dev-dependencies]
 
 [features]

chain/api/src/chain.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2
 
 use anyhow::Result;
+use starcoin_config::ChainNetworkID;
 use starcoin_crypto::HashValue;
 use starcoin_state_api::ChainStateReader;
 use starcoin_statedb::ChainStateDB;
@@ -102,6 +103,7 @@ pub trait ChainReader {
     ) -> Result<Option<TransactionInfoWithProof>>;
 
     fn current_tips_hash(&self) -> Result<Option<Vec<HashValue>>>;
+     fn has_dag_block(&self, hash: HashValue) -> Result<bool>;
 }
 
 pub trait ChainWriter {

chain/api/src/message.rs

@@ -60,6 +60,9 @@ pub enum ChainRequest {
         access_path: Option<AccessPath>,
     },
     GetBlockInfos(Vec<HashValue>),
+    GetDagBlockChildren {
+        block_ids: Vec<HashValue>,
+    }
 }
 
 impl ServiceRequest for ChainRequest {

chain/api/src/service.rs

@@ -72,6 +72,7 @@ pub trait ReadableChainService {
     ) -> Result<Option<TransactionInfoWithProof>>;
 
     fn get_block_infos(&self, ids: Vec<HashValue>) -> Result<Vec<Option<BlockInfo>>>;
+    fn get_dag_block_children(&self, ids: Vec<HashValue>) -> Result<Vec<HashValue>>;
 }
 
 /// Writeable block chain service trait
@@ -139,6 +140,7 @@ pub trait ChainAsyncService:
     ) -> Result<Option<TransactionInfoWithProof>>;
 
     async fn get_block_infos(&self, hashes: Vec<HashValue>) -> Result<Vec<Option<BlockInfo>>>;
+    async fn get_dag_block_children(&self, hashes: Vec<HashValue>) -> Result<Vec<HashValue>>;
 }
 
 #[async_trait::async_trait]
@@ -436,4 +438,15 @@ where
             bail!("get block_infos error")
         }
     }
+
+    async fn get_dag_block_children(&self, hashes: Vec<HashValue>) -> Result<Vec<HashValue>> {
+        let response = self.send(ChainRequest::GetDagBlockChildren {
+            block_ids: hashes,
+        }).await??;
+        if let ChainResponse::HashVec(children) = response {
+            Ok(children)
+        } else {
+            bail!("get dag block children error")
+        }
+    }
 }

chain/chain-notify/src/lib.rs

@@ -52,8 +52,7 @@ impl EventHandler<Self, NewHeadBlock> for ChainNotifyHandlerService {
         item: NewHeadBlock,
         ctx: &mut ServiceContext<ChainNotifyHandlerService>,
     ) {
-        let NewHeadBlock(block_detail) = item;
-        let block = block_detail.block();
+        let block = item.executed_block.block();
         // notify header.
         self.notify_new_block(block, ctx);
         // notify events

chain/mock/src/mock_chain.rs

@@ -128,14 +128,9 @@ impl MockChain {
     }
 
     pub fn produce(&self) -> Result<Block> {
-        let (template, _) = self.head.create_block_template(
-            *self.miner.address(),
-            None,
-            vec![],
-            vec![],
-            None,
-            None,
-        )?;
+        let (template, _) =
+            self.head
+                .create_block_template(*self.miner.address(), None, vec![], vec![], None, None)?;
         self.head
             .consensus()
             .create_block(template, self.net.time_service().as_ref())
@@ -149,6 +144,7 @@ impl MockChain {
     pub fn produce_and_apply(&mut self) -> Result<BlockHeader> {
         let block = self.produce()?;
         let header = block.header().clone();
+        println!("jacktest: produce testing block: {:?}, number: {:?}", block.id(), block.header().number());
         self.apply(block)?;
         Ok(header)
     }

chain/service/Cargo.toml

@@ -1,5 +1,6 @@
 [dependencies]
 anyhow = { workspace = true }
+async-std = { workspace = true }
 async-trait = { workspace = true }
 futures = { workspace = true }
 rand = { workspace = true }
@@ -36,7 +37,7 @@ edition = { workspace = true }
 license = { workspace = true }
 name = "starcoin-chain-service"
 publish = { workspace = true }
-version = "1.13.7"
+version = "1.13.8"
 homepage = { workspace = true }
 repository = { workspace = true }
 rust-version = { workspace = true }