Skip adding XDM to the tx pool during major sync

Signed-off-by: linning <[email protected]>

crates/subspace-malicious-operator/src/bin/subspace-malicious-operator.rs

@@ -316,6 +316,7 @@ fn main() -> Result<(), Error> {
 
             let consensus_network_service = consensus_chain_node.network_service.clone();
             let consensus_task_spawn_essential_handler = consensus_chain_node.task_manager.spawn_essential_handle();
+            let consensus_sync_service = consensus_chain_node.sync_service.clone();
             consensus_chain_node
                 .task_manager
                 .spawn_essential_handle()
@@ -352,14 +353,16 @@ fn main() -> Result<(), Error> {
                                         _,
                                         DomainBlock,
                                         _,
+                                        _,
                                     >(
                                         ChainId::Consensus,
                                         consensus_chain_node.client.clone(),
                                         consensus_chain_node.client.clone(),
                                         consensus_chain_node.transaction_pool.clone(),
                                         consensus_network_service,
                                         consensus_msg_receiver,
-                                        domain_code_executor
+                                        domain_code_executor,
+                                        consensus_sync_service,
                                     );
 
                                 consensus_task_spawn_essential_handler

crates/subspace-node/src/commands/run.rs

@@ -234,6 +234,7 @@ pub async fn run(run_options: RunOptions) -> Result<(), Error> {
                                 _,
                                 DomainBlock,
                                 _,
+                                _,
                             >(
                                 ChainId::Consensus,
                                 consensus_chain_node.client.clone(),
@@ -242,6 +243,7 @@ pub async fn run(run_options: RunOptions) -> Result<(), Error> {
                                 consensus_chain_node.network_service.clone(),
                                 consensus_msg_receiver,
                                 domain_code_executor.into(),
+                                consensus_chain_node.sync_service.clone(),
                             ),
                         ),
                     );

domains/client/cross-domain-message-gossip/Cargo.toml

@@ -25,6 +25,7 @@ sc-transaction-pool-api = { git = "https://github.com/subspace/polkadot-sdk", re
 sc-utils = { git = "https://github.com/subspace/polkadot-sdk", rev = "5626154d0781ac9a6ffd5a6207ed237f425ae631" }
 sp-api = { git = "https://github.com/subspace/polkadot-sdk", rev = "5626154d0781ac9a6ffd5a6207ed237f425ae631" }
 sp-blockchain = { git = "https://github.com/subspace/polkadot-sdk", rev = "5626154d0781ac9a6ffd5a6207ed237f425ae631" }
+sp-consensus = { git = "https://github.com/subspace/polkadot-sdk", rev = "5626154d0781ac9a6ffd5a6207ed237f425ae631" }
 sp-core = { git = "https://github.com/subspace/polkadot-sdk", rev = "5626154d0781ac9a6ffd5a6207ed237f425ae631" }
 sp-domains = { version = "0.1.0", path = "../../../crates/sp-domains" }
 sp-messenger = { version = "0.1.0", default-features = false, path = "../../primitives/messenger" }

domains/client/cross-domain-message-gossip/src/message_listener.rs

@@ -10,6 +10,7 @@ use sc_network::NetworkPeers;
 use sc_transaction_pool_api::{TransactionPool, TransactionSource};
 use sp_api::{ApiError, ApiExt, ProvideRuntimeApi, StorageProof};
 use sp_blockchain::HeaderBackend;
+use sp_consensus::SyncOracle;
 use sp_core::crypto::AccountId32;
 use sp_core::storage::StorageKey;
 use sp_core::traits::CodeExecutor;
@@ -80,6 +81,7 @@ impl From<VerificationError> for Error {
     }
 }
 
+#[allow(clippy::too_many_arguments)]
 pub async fn start_cross_chain_message_listener<
     Client,
     TxPool,
@@ -88,6 +90,7 @@ pub async fn start_cross_chain_message_listener<
     CBlock,
     Block,
     Executor,
+    SO,
 >(
     chain_id: ChainId,
     consensus_client: Arc<CClient>,
@@ -96,6 +99,7 @@ pub async fn start_cross_chain_message_listener<
     network: Arc<dyn NetworkPeers + Send + Sync>,
     mut listener: TxnListener,
     domain_executor: Arc<Executor>,
+    sync_oracle: SO,
 ) where
     TxPool: TransactionPool + 'static,
     Client: ProvideRuntimeApi<BlockOf<TxPool>> + HeaderBackend<BlockOf<TxPool>>,
@@ -106,6 +110,7 @@ pub async fn start_cross_chain_message_listener<
         + RelayerApi<CBlock, NumberFor<CBlock>, NumberFor<CBlock>, CBlock::Hash>,
     TxnListener: Stream<Item = ChainMsg> + Unpin,
     Executor: CodeExecutor + RuntimeVersionOf,
+    SO: SyncOracle + Send,
 {
     tracing::info!(
         target: LOG_TARGET,
@@ -116,6 +121,11 @@ pub async fn start_cross_chain_message_listener<
     let mut domain_storage_key_cache = BTreeMap::<(H256, ChainId, ChannelId), StorageKey>::new();
 
     while let Some(msg) = listener.next().await {
+        // If the client is in major sync, wait until sync is complete
+        if sync_oracle.is_major_syncing() {
+            continue;
+        }
+
         tracing::debug!(
             target: LOG_TARGET,
             "Message received for Chain: {:?}",

domains/service/src/domain.rs

@@ -500,7 +500,7 @@ where
                 client.clone(),
                 // domain will use consensus chain sync oracle instead of domain sync oracle
                 // since domain sync oracle will always return `synced` due to force sync being set.
-                consensus_network_sync_oracle,
+                consensus_network_sync_oracle.clone(),
                 gossip_message_sink,
             );
 
@@ -512,16 +512,25 @@ where
     }
 
     // Start cross domain message listener for domain
-    let domain_listener =
-        cross_domain_message_gossip::start_cross_chain_message_listener::<_, _, _, _, _, Block, _>(
-            ChainId::Domain(domain_id),
-            consensus_client.clone(),
-            client.clone(),
-            params.transaction_pool.clone(),
-            consensus_network,
-            domain_message_receiver,
-            code_executor.clone(),
-        );
+    let domain_listener = cross_domain_message_gossip::start_cross_chain_message_listener::<
+        _,
+        _,
+        _,
+        _,
+        _,
+        Block,
+        _,
+        _,
+    >(
+        ChainId::Domain(domain_id),
+        consensus_client.clone(),
+        client.clone(),
+        params.transaction_pool.clone(),
+        consensus_network,
+        domain_message_receiver,
+        code_executor.clone(),
+        consensus_network_sync_oracle,
+    );
 
     spawn_essential.spawn_essential_blocking(
         "domain-message-listener",

test/subspace-test-service/src/lib.rs

@@ -524,6 +524,7 @@ impl MockConsensusNode {
             _,
             DomainBlock,
             _,
+            _,
         >(
             ChainId::Consensus,
             client.clone(),
@@ -532,6 +533,7 @@ impl MockConsensusNode {
             network_service.clone(),
             consensus_msg_receiver,
             domain_executor,
+            sync_service.clone(),
         );
 
         task_manager