[pallet-revive] make subscription task panic on error

Cargo.toml

@@ -1380,9 +1380,9 @@ substrate-test-runtime-client = { path = "substrate/test-utils/runtime/client" }
 substrate-test-runtime-transaction-pool = { path = "substrate/test-utils/runtime/transaction-pool" }
 substrate-test-utils = { path = "substrate/test-utils" }
 substrate-wasm-builder = { path = "substrate/utils/wasm-builder", default-features = false }
-subxt = { version = "0.38.1", default-features = false }
-subxt-metadata = { version = "0.38.0", default-features = false }
-subxt-signer = { version = "0.38" }
+subxt = { version = "0.41", default-features = false }
+subxt-metadata = { version = "0.41", default-features = false }
+subxt-signer = { version = "0.41" }
 syn = { version = "2.0.87" }
 sysinfo = { version = "0.30" }
 tar = { version = "0.4" }

cumulus/zombienet/zombienet-sdk-helpers/Cargo.toml

@@ -12,6 +12,5 @@ anyhow = { workspace = true, default-features = true }
 codec = { workspace = true, features = ["derive"] }
 log = { workspace = true }
 polkadot-primitives = { workspace = true, default-features = true }
-subxt = { workspace = true, features = ["native"] }
 tokio = { workspace = true, features = ["rt-multi-thread", "macros", "time"] }
-
+zombienet-sdk = { workspace = true }

cumulus/zombienet/zombienet-sdk-helpers/src/lib.rs

@@ -8,14 +8,14 @@ use std::{
 	collections::{HashMap, HashSet},
 	ops::Range,
 };
-use subxt::{
-	blocks::Block, events::Events, ext::scale_value::value, tx::DynamicPayload, utils::H256,
-	OnlineClient, PolkadotConfig,
-};
 use tokio::{
 	join,
 	time::{sleep, Duration},
 };
+use zombienet_sdk::subxt::{
+	blocks::Block, events::Events, ext::scale_value::value, tx::DynamicPayload, utils::H256,
+	OnlineClient, PolkadotConfig,
+};
 
 // Maximum number of blocks to wait for a session change.
 // If it does not arrive for whatever reason, we should not wait forever.
@@ -30,7 +30,7 @@ pub fn create_assign_core_call(core_and_para: &[(u32, u32)]) -> DynamicPayload {
 		});
 	}
 
-	subxt::tx::dynamic(
+	zombienet_sdk::subxt::tx::dynamic(
 		"Sudo",
 		"sudo",
 		vec![value! {
@@ -238,7 +238,7 @@ pub async fn assert_para_throughput(
 ///
 /// The session change is detected by inspecting the events in the block.
 pub async fn wait_for_first_session_change(
-	blocks_sub: &mut subxt::backend::StreamOfResults<
+	blocks_sub: &mut zombienet_sdk::subxt::backend::StreamOfResults<
 		Block<PolkadotConfig, OnlineClient<PolkadotConfig>>,
 	>,
 ) -> Result<(), anyhow::Error> {
@@ -249,7 +249,7 @@ pub async fn wait_for_first_session_change(
 ///
 /// The session change is detected by inspecting the events in the block.
 pub async fn wait_for_nth_session_change(
-	blocks_sub: &mut subxt::backend::StreamOfResults<
+	blocks_sub: &mut zombienet_sdk::subxt::backend::StreamOfResults<
 		Block<PolkadotConfig, OnlineClient<PolkadotConfig>>,
 	>,
 	mut sessions_to_wait: u32,

cumulus/zombienet/zombienet-sdk/Cargo.toml

@@ -14,8 +14,6 @@ log = { workspace = true }
 polkadot-primitives = { workspace = true, default-features = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
-subxt = { workspace = true }
-subxt-signer = { workspace = true }
 tokio = { workspace = true, features = ["rt-multi-thread"] }
 zombienet-sdk = { workspace = true }
 zombienet-orchestrator = { workspace = true }

cumulus/zombienet/zombienet-sdk/tests/bootnodes/mod.rs

@@ -5,9 +5,11 @@ use anyhow::anyhow;
 use tokio::time::Duration;
 
 use cumulus_zombienet_sdk_helpers::wait_for_nth_session_change;
-use subxt::{OnlineClient, PolkadotConfig};
 use zombienet_orchestrator::network::node::LogLineCountOptions;
-use zombienet_sdk::{NetworkConfig, NetworkConfigBuilder};
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfig, NetworkConfigBuilder,
+};
 
 async fn build_network_config() -> Result<NetworkConfig, anyhow::Error> {
 	let images = zombienet_sdk::environment::get_images_from_env();

cumulus/zombienet/zombienet-sdk/tests/elastic_scaling/elastic_scaling_multiple_blocks_per_slot.rs

@@ -8,9 +8,11 @@ use cumulus_zombienet_sdk_helpers::{
 };
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
-use zombienet_sdk::{NetworkConfig, NetworkConfigBuilder};
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfig, NetworkConfigBuilder,
+};
 
 const PARA_ID: u32 = 2400;
 

cumulus/zombienet/zombienet-sdk/tests/sync_blocks/sync_blocks_from_tip_without_connected_collator.rs

@@ -5,8 +5,10 @@ use anyhow::anyhow;
 
 use cumulus_zombienet_sdk_helpers::assert_para_throughput;
 use polkadot_primitives::Id as ParaId;
-use subxt::{OnlineClient, PolkadotConfig};
-use zombienet_sdk::{LocalFileSystem, Network, NetworkConfigBuilder};
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	LocalFileSystem, Network, NetworkConfigBuilder,
+};
 
 const PARA_ID: u32 = 2000;
 const BEST_BLOCK_METRIC: &str = "block_height{status=\"best\"}";

polkadot/zombienet-sdk-tests/Cargo.toml

@@ -16,8 +16,7 @@ log = { workspace = true }
 polkadot-primitives = { workspace = true, default-features = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
-subxt = { workspace = true }
-subxt-signer = { workspace = true }
+subxt = { version = "0.38.1", default-features = false }
 tokio = { workspace = true, features = ["rt-multi-thread"] }
 tokio-util = { workspace = true, features = ["time"] }
 zombienet-orchestrator = { workspace = true }

polkadot/zombienet-sdk-tests/tests/disabling/slashing.rs

@@ -12,11 +12,13 @@ use cumulus_zombienet_sdk_helpers::{
 };
 use polkadot_primitives::{BlockNumber, CandidateHash, DisputeState, Id as ParaId, SessionIndex};
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
 use tokio::time::Duration;
 use tokio_util::time::FutureExt;
 use zombienet_orchestrator::network::node::LogLineCountOptions;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn dispute_past_session_slashing() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/elastic_scaling/basic_3cores.rs

@@ -8,9 +8,11 @@ use anyhow::anyhow;
 use cumulus_zombienet_sdk_helpers::{assert_finalized_para_throughput, create_assign_core_call};
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn basic_3cores_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/elastic_scaling/doesnt_break_parachains.rs

@@ -11,9 +11,11 @@ use cumulus_zombienet_sdk_helpers::{
 use polkadot_primitives::{CoreIndex, Id as ParaId};
 use serde_json::json;
 use std::collections::{BTreeMap, VecDeque};
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn doesnt_break_parachains_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/elastic_scaling/slot_based_12cores.rs

@@ -11,9 +11,11 @@ use cumulus_zombienet_sdk_helpers::{
 };
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn slot_based_12cores_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/elastic_scaling/slot_based_3cores.rs

@@ -11,9 +11,11 @@ use cumulus_zombienet_sdk_helpers::{
 };
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn slot_based_3cores_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/functional/approval_voting_coalescing.rs

@@ -8,8 +8,10 @@ use anyhow::anyhow;
 use cumulus_zombienet_sdk_helpers::{assert_finality_lag, assert_para_throughput};
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn approval_voting_coalescing_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/functional/approved_peer_mixed_validators.rs

@@ -12,9 +12,11 @@ use tokio::time::Duration;
 use cumulus_zombienet_sdk_helpers::{assert_finality_lag, assert_finalized_para_throughput};
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
 use zombienet_orchestrator::network::node::LogLineCountOptions;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn approved_peer_mixed_validators_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/functional/async_backing_6_seconds_rate.rs

@@ -8,8 +8,10 @@ use anyhow::anyhow;
 use cumulus_zombienet_sdk_helpers::{assert_finality_lag, assert_finalized_para_throughput};
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn async_backing_6_seconds_rate_test() -> Result<(), anyhow::Error> {

polkadot/zombienet-sdk-tests/tests/functional/duplicate_collations.rs

@@ -10,10 +10,12 @@ use tokio::time::Duration;
 use cumulus_zombienet_sdk_helpers::{assert_finalized_para_throughput, create_assign_core_call};
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
-use subxt_signer::sr25519::dev;
 use zombienet_orchestrator::network::node::LogLineCountOptions;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	subxt_signer::sr25519::dev,
+	NetworkConfigBuilder,
+};
 
 const VALIDATOR_COUNT: u8 = 3;
 

polkadot/zombienet-sdk-tests/tests/functional/spam_statement_distribution_requests.rs

@@ -9,9 +9,11 @@ use tokio::time::Duration;
 use cumulus_zombienet_sdk_helpers::assert_para_throughput;
 use polkadot_primitives::Id as ParaId;
 use serde_json::json;
-use subxt::{OnlineClient, PolkadotConfig};
 use zombienet_orchestrator::network::node::LogLineCountOptions;
-use zombienet_sdk::NetworkConfigBuilder;
+use zombienet_sdk::{
+	subxt::{OnlineClient, PolkadotConfig},
+	NetworkConfigBuilder,
+};
 
 #[tokio::test(flavor = "multi_thread")]
 async fn spam_statement_distribution_requests_test() -> Result<(), anyhow::Error> {