diff --git a/crates/config/src/lib.rs b/crates/config/src/lib.rs index 7814d48..f7a4651 100644 --- a/crates/config/src/lib.rs +++ b/crates/config/src/lib.rs @@ -602,10 +602,6 @@ pub struct KitchensinkConfiguration { value_parser = parse_duration )] pub start_timeout_ms: Duration, - - /// This configures the tool to use Kitchensink instead of using the revive-dev-node. - #[clap(long = "kitchensink.dont-use-dev-node")] - pub use_kitchensink: bool, } /// A set of configuration parameters for the revive dev node. diff --git a/crates/core/src/helpers/pool.rs b/crates/core/src/helpers/pool.rs index afaa791..66b1736 100644 --- a/crates/core/src/helpers/pool.rs +++ b/crates/core/src/helpers/pool.rs @@ -33,7 +33,6 @@ impl NodePool { .join() .map_err(|error| anyhow::anyhow!("failed to spawn node: {:?}", error)) .context("Failed to join node spawn thread")? - .map_err(|error| anyhow::anyhow!("node failed to spawn: {error}")) .context("Node failed to spawn")?, ); } diff --git a/crates/node/src/node_implementations/substrate.rs b/crates/node/src/node_implementations/substrate.rs index a2d3d24..8fd4721 100644 --- a/crates/node/src/node_implementations/substrate.rs +++ b/crates/node/src/node_implementations/substrate.rs @@ -149,6 +149,7 @@ impl SubstrateNode { .arg(self.export_chainspec_command.as_str()) .arg("--chain") .arg("dev") + .env_remove("RUST_LOG") .output() .context("Failed to export the chain-spec")?; @@ -520,11 +521,13 @@ impl EthereumNode for SubstrateNode { .provider() .await .context("Failed to create the provider for block subscription")?; - let block_subscription = provider.subscribe_full_blocks(); - let block_stream = block_subscription - .into_stream() + let mut block_subscription = provider + .watch_full_blocks() .await - .context("Failed to create the block stream")?; + .context("Failed to create the blocks stream")?; + block_subscription.set_channel_size(0xFFFF); + block_subscription.set_poll_interval(Duration::from_secs(1)); + let block_stream = block_subscription.into_stream(); let mined_block_information_stream = block_stream.filter_map(|block| async { let block = block.ok()?; @@ -1149,9 +1152,7 @@ mod tests { use crate::Node; fn test_config() -> TestExecutionContext { - let mut context = TestExecutionContext::default(); - context.kitchensink_configuration.use_kitchensink = true; - context + TestExecutionContext::default() } fn new_node() -> (TestExecutionContext, SubstrateNode) {