Skip to content

Commit d7fe4d3

Browse files
committed
remove unused pool
1 parent e071202 commit d7fe4d3

5 files changed

Lines changed: 23 additions & 39 deletions

File tree

bin/ev-reth/src/main.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -50,11 +50,11 @@ fn main() {
5050
}
5151
}
5252

53-
if let Err(err) = Cli::<EthereumChainSpecParser, EvolveArgs>::parse().run(
54-
async move |builder, evolve_args| {
55-
log_startup(&evolve_args);
53+
if let Err(err) = Cli::<EthereumChainSpecParser, EvolveArgs>::parse()
54+
.run(|builder, _evolve_args| async move {
55+
log_startup();
5656
let handle = builder
57-
.node(EvolveNode::new(evolve_args))
57+
.node(EvolveNode::new())
5858
.extend_rpc_modules(move |ctx| {
5959
// Build custom txpool RPC with config + optional CLI/env override
6060
let evolve_cfg = EvolveConfig::default();
@@ -70,8 +70,8 @@ fn main() {
7070

7171
info!("=== EV-RETH: Node launched successfully with ev-reth payload builder ===");
7272
handle.node_exit_future.await
73-
},
74-
) {
73+
})
74+
{
7575
eprintln!("Error: {err:?}");
7676
std::process::exit(1);
7777
}

crates/node/src/args.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
use clap::Parser;
1+
use clap::Args;
22

33
/// Evolve CLI arguments (currently empty; reserved for future toggles).
4-
#[derive(Debug, Clone, Parser, PartialEq, Eq, Default)]
4+
#[derive(Debug, Clone, Default, Args)]
55
pub struct EvolveArgs {}

crates/node/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,6 @@ pub use builder::{create_payload_builder_service, EvolvePayloadBuilder};
3131
pub use config::{ConfigError, EvolvePayloadBuilderConfig};
3232
pub use error::EvolveEngineError;
3333
pub use executor::{build_evm_config, EvolveEvmConfig, EvolveExecutorBuilder};
34-
pub use node::{log_startup, parse_args, EvolveEngineTypes, EvolveNode, EvolveNodeAddOns};
34+
pub use node::{log_startup, EvolveEngineTypes, EvolveNode, EvolveNodeAddOns};
3535
pub use payload_service::{EvolveEnginePayloadBuilder, EvolvePayloadBuilderBuilder};
3636
pub use validator::{EvolveEngineValidator, EvolveEngineValidatorBuilder};

crates/node/src/node.rs

Lines changed: 5 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ use alloy_rpc_types::engine::{
44
ExecutionData, ExecutionPayloadEnvelopeV2, ExecutionPayloadEnvelopeV3,
55
ExecutionPayloadEnvelopeV4, ExecutionPayloadEnvelopeV5, ExecutionPayloadV1,
66
};
7-
use clap::Parser;
87
use reth_ethereum::{
98
chainspec::ChainSpec,
109
node::{
@@ -24,7 +23,6 @@ use serde::{Deserialize, Serialize};
2423
use tracing::info;
2524

2625
use crate::{
27-
args::EvolveArgs,
2826
attributes::{EvolveEnginePayloadAttributes, EvolveEnginePayloadBuilderAttributes},
2927
executor::EvolveExecutorBuilder,
3028
payload_service::EvolvePayloadBuilderBuilder,
@@ -67,15 +65,12 @@ impl EngineTypes for EvolveEngineTypes {
6765
/// Evolve node type.
6866
#[derive(Debug, Clone, Default)]
6967
#[non_exhaustive]
70-
pub struct EvolveNode {
71-
/// Evolve-specific arguments.
72-
pub args: EvolveArgs,
73-
}
68+
pub struct EvolveNode {}
7469

7570
impl EvolveNode {
7671
/// Create a new evolve node with the given arguments.
77-
pub const fn new(args: EvolveArgs) -> Self {
78-
Self { args }
72+
pub const fn new() -> Self {
73+
Self {}
7974
}
8075
}
8176

@@ -109,7 +104,7 @@ where
109104
.pool(EthereumPoolBuilder::default())
110105
.executor(EvolveExecutorBuilder::default())
111106
.payload(BasicPayloadServiceBuilder::new(
112-
EvolvePayloadBuilderBuilder::new(&self.args),
107+
EvolvePayloadBuilderBuilder::new(),
113108
))
114109
.network(EthereumNetworkBuilder::default())
115110
.consensus(evolve_ev_reth::consensus::EvolveConsensusBuilder::default())
@@ -121,13 +116,7 @@ where
121116
}
122117

123118
/// Helper logging to announce node startup with args.
124-
pub fn log_startup(args: &EvolveArgs) {
125-
info!("=== EV-RETH: Starting with args: {:?} ===", args);
119+
pub fn log_startup() {
126120
info!("=== EV-RETH: Evolve node mode enabled ===");
127121
info!("=== EV-RETH: Using custom payload builder with transaction support ===");
128122
}
129-
130-
/// Ensure Clap derives are linked when this crate is used without the binary.
131-
pub fn parse_args() -> EvolveArgs {
132-
EvolveArgs::parse()
133-
}

crates/node/src/payload_service.rs

Lines changed: 9 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,8 @@ use tokio::runtime::Handle;
2424
use tracing::info;
2525

2626
use crate::{
27-
args::EvolveArgs, attributes::EvolveEnginePayloadBuilderAttributes,
28-
builder::EvolvePayloadBuilder, config::EvolvePayloadBuilderConfig, executor::EvolveEvmConfig,
29-
node::EvolveEngineTypes,
27+
attributes::EvolveEnginePayloadBuilderAttributes, builder::EvolvePayloadBuilder,
28+
config::EvolvePayloadBuilderConfig, executor::EvolveEvmConfig, node::EvolveEngineTypes,
3029
};
3130

3231
use evolve_ev_reth::config::set_current_block_gas_limit;
@@ -40,7 +39,7 @@ pub struct EvolvePayloadBuilderBuilder {
4039

4140
impl EvolvePayloadBuilderBuilder {
4241
/// Create a new builder with evolve args.
43-
pub fn new(_args: &EvolveArgs) -> Self {
42+
pub fn new() -> Self {
4443
let config = EvolvePayloadBuilderConfig::new();
4544
info!("Created Evolve payload builder with config: {:?}", config);
4645
Self { config }
@@ -49,21 +48,17 @@ impl EvolvePayloadBuilderBuilder {
4948

5049
impl Default for EvolvePayloadBuilderBuilder {
5150
fn default() -> Self {
52-
Self::new(&EvolveArgs::default())
51+
Self::new()
5352
}
5453
}
5554

5655
/// The evolve engine payload builder that integrates with the evolve payload builder.
5756
#[derive(Debug, Clone)]
58-
pub struct EvolveEnginePayloadBuilder<Pool, Client>
57+
pub struct EvolveEnginePayloadBuilder<Client>
5958
where
60-
Pool: Clone,
6159
Client: Clone,
6260
{
6361
pub(crate) evolve_builder: Arc<EvolvePayloadBuilder<Client>>,
64-
#[allow(dead_code)]
65-
pub(crate) pool: Pool,
66-
#[allow(dead_code)]
6762
pub(crate) config: EvolvePayloadBuilderConfig,
6863
}
6964

@@ -80,7 +75,7 @@ where
8075
+ Unpin
8176
+ 'static,
8277
{
83-
type PayloadBuilder = EvolveEnginePayloadBuilder<Pool, Node::Provider>;
78+
type PayloadBuilder = EvolveEnginePayloadBuilder<Node::Provider>;
8479

8580
async fn build_payload_builder(
8681
self,
@@ -98,6 +93,8 @@ where
9893

9994
config.validate()?;
10095

96+
let _ = pool;
97+
10198
let evolve_builder = Arc::new(EvolvePayloadBuilder::new(
10299
Arc::new(ctx.provider().clone()),
103100
evm_config,
@@ -106,13 +103,12 @@ where
106103

107104
Ok(EvolveEnginePayloadBuilder {
108105
evolve_builder,
109-
pool,
110106
config,
111107
})
112108
}
113109
}
114110

115-
impl<Pool, Client> PayloadBuilder for EvolveEnginePayloadBuilder<Pool, Client>
111+
impl<Client> PayloadBuilder for EvolveEnginePayloadBuilder<Client>
116112
where
117113
Client: reth_ethereum::provider::StateProviderFactory
118114
+ ChainSpecProvider<ChainSpec = ChainSpec>
@@ -121,7 +117,6 @@ where
121117
+ Send
122118
+ Sync
123119
+ 'static,
124-
Pool: TransactionPool<Transaction: PoolTransaction<Consensus = TransactionSigned>>,
125120
{
126121
type Attributes = EvolveEnginePayloadBuilderAttributes;
127122
type BuiltPayload = EthBuiltPayload;

0 commit comments

Comments
 (0)