fork-aware-tx-pool: add heavy load tests based on zombienet

Cargo.toml

@@ -1392,7 +1392,8 @@ xcm-procedural = { path = "polkadot/xcm/procedural", default-features = false }
 xcm-runtime-apis = { path = "polkadot/xcm/xcm-runtime-apis", default-features = false }
 xcm-simulator = { path = "polkadot/xcm/xcm-simulator", default-features = false }
 zeroize = { version = "1.7.0", default-features = false }
-zombienet-sdk = { version = "0.2.20" }
+zombienet-configuration = { version = "0.2.22" }
+zombienet-sdk = { version = "0.2.22" }
 zstd = { version = "0.12.4", default-features = false }
 
 [profile.release]

substrate/client/transaction-pool/Cargo.toml

@@ -43,14 +43,27 @@ tokio-stream = { workspace = true }
 tracing = { workspace = true, default-features = true }
 
 [dev-dependencies]
+anyhow = { workspace = true }
 array-bytes = { workspace = true, default-features = true }
 assert_matches = { workspace = true }
+async-trait = { workspace = true }
+chrono = { workspace = true }
+cmd_lib = { workspace = true }
 criterion = { workspace = true, default-features = true }
+cumulus-client-cli = { workspace = true, default-features = true }
+env_logger = { workspace = true }
+log = { workspace = true }
+polkadot-cli = { workspace = true, default-features = true }
 sc-block-builder = { workspace = true, default-features = true }
 sp-consensus = { workspace = true, default-features = true }
+strum = { workspace = true, features = ["derive"] }
 substrate-test-runtime = { workspace = true }
 substrate-test-runtime-client = { workspace = true }
 substrate-test-runtime-transaction-pool = { workspace = true }
+thiserror = { workspace = true }
+tokio = { workspace = true, features = ["rt-multi-thread"] }
+zombienet-configuration = { workspace = true }
+zombienet-sdk = { workspace = true }
 
 [[bench]]
 name = "basics"

substrate/client/transaction-pool/tests/integration.rs

@@ -0,0 +1,55 @@
+// This file is part of Substrate.
+
+// Copyright (C) Parity Technologies (UK) Ltd.
+// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0
+
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with this program. If not, see <https://www.gnu.org/licenses/>.
+
+// Testsuite of fatp integration tests.
+
+pub mod zombienet;
+
+use std::time::Duration;
+
+use tokio::join;
+use zombienet::NetworkSpawner;
+use zombienet_sdk::subxt::OnlineClient;
+
+#[tokio::test(flavor = "multi_thread")]
+async fn send_future_and_then_ready_from_single_account() {
+	let _ = env_logger::try_init_from_env(
+		env_logger::Env::default().filter_or(env_logger::DEFAULT_FILTER_ENV, "info"),
+	);
+	let net = NetworkSpawner::init_from_asset_hub_fatp_low_pool_limit_spec().await.unwrap();
+	let collator = net.get_node("charlie").unwrap();
+	let _client: OnlineClient<zombienet_sdk::subxt::SubstrateConfig> =
+		collator.wait_client_with_timeout(120u64).await.unwrap();
+	let ws = "ws://127.0.0.1:9933";
+	let mut nonce = 0;
+	for _ in 0..3 {
+		// Spawn future TXs.
+		let future_start = nonce + 5;
+		let handle1 = tokio::spawn(async move {
+			cmd_lib::run_cmd!(RUST_LOG=info ttxt tx --chain=sub --ws=$ws from-single-account --account 0 --count 5 --from $future_start)
+		});
+		tokio::time::sleep(Duration::from_secs(5)).await;
+		let handle2 = tokio::spawn(async move {
+			cmd_lib::run_cmd!(RUST_LOG=info ttxt tx --chain=sub --ws=$ws from-single-account --account 0  --count 5 --from $nonce)
+		});
+		nonce = future_start + 5;
+		let (res1, res2) = join!(handle1, handle2);
+		assert!(res1.is_ok());
+		assert!(res2.is_ok());
+	}
+}