refactor: move node-core/engine to standalone crate

Cargo.toml

@@ -26,6 +26,7 @@ members = [
     "crates/ethereum-forks/",
     "crates/e2e-test-utils/",
     "crates/engine-primitives/",
+    "crates/engine/util/",
     "crates/errors/",
     "crates/ethereum-forks/",
     "crates/ethereum/consensus/",
@@ -279,6 +280,7 @@ reth-downloaders = { path = "crates/net/downloaders" }
 reth-e2e-test-utils = { path = "crates/e2e-test-utils" }
 reth-ecies = { path = "crates/net/ecies" }
 reth-engine-primitives = { path = "crates/engine-primitives" }
+reth-engine-util = { path = "crates/engine/util" }
 reth-errors = { path = "crates/errors" }
 reth-eth-wire = { path = "crates/net/eth-wire" }
 reth-eth-wire-types = { path = "crates/net/eth-wire-types" }

bin/reth/Cargo.toml

@@ -66,6 +66,8 @@ reth-node-builder.workspace = true
 reth-node-events.workspace = true
 reth-consensus.workspace = true
 reth-optimism-primitives.workspace = true
+reth-prune-types.workspace = true
+reth-engine-util.workspace = true
 reth-prune.workspace = true
 
 # crypto

bin/reth/src/commands/debug_cmd/replay_engine.rs

@@ -14,10 +14,10 @@ use reth_cli_runner::CliContext;
 use reth_config::Config;
 use reth_consensus::Consensus;
 use reth_db::DatabaseEnv;
+use reth_engine_util::engine_store::{EngineMessageStore, StoredEngineApiMessage};
 use reth_fs_util as fs;
 use reth_network::NetworkHandle;
 use reth_network_api::NetworkInfo;
-use reth_node_core::engine::engine_store::{EngineMessageStore, StoredEngineApiMessage};
 use reth_payload_builder::{PayloadBuilderHandle, PayloadBuilderService};
 use reth_provider::{
     providers::BlockchainProvider, CanonStateSubscriptions, ChainSpecProvider, ProviderFactory,

crates/engine/util/Cargo.toml

@@ -0,0 +1,42 @@
+[package]
+name = "reth-engine-util"
+version.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+license.workspace = true
+homepage.workspace = true
+repository.workspace = true
+
+[lints]
+workspace = true
+
+[dependencies]
+# reth
+reth-fs-util.workspace = true
+reth-rpc.workspace = true
+reth-rpc-types.workspace = true
+reth-engine-primitives.workspace = true
+reth-beacon-consensus.workspace = true
+
+# async
+tokio-util.workspace = true
+pin-project.workspace = true
+
+# misc
+eyre.workspace = true
+
+# io
+serde.workspace = true
+serde_json.workspace = true
+
+# tracing
+tracing.workspace = true
+
+# async
+futures.workspace = true
+
+[features]
+optimism = [
+    "reth-rpc/optimism",
+    "reth-beacon-consensus/optimism",
+]

crates/node-core/Cargo.toml

@@ -33,7 +33,6 @@ reth-discv4.workspace = true
 reth-discv5.workspace = true
 reth-net-nat.workspace = true
 reth-network-peers.workspace = true
-reth-engine-primitives.workspace = true
 reth-tasks.workspace = true
 reth-consensus-common.workspace = true
 reth-beacon-consensus.workspace = true
@@ -46,8 +45,6 @@ alloy-rpc-types-engine.workspace = true
 
 # async
 tokio.workspace = true
-tokio-util.workspace = true
-pin-project.workspace = true
 
 # metrics
 reth-metrics.workspace = true
@@ -69,7 +66,6 @@ once_cell.workspace = true
 # io
 dirs-next = "2.0.0"
 shellexpand = "3.0.0"
-serde.workspace = true
 serde_json.workspace = true
 
 # http/rpc

crates/node-core/src/lib.rs

@@ -11,7 +11,6 @@
 pub mod args;
 pub mod cli;
 pub mod dirs;
-pub mod engine;
 pub mod exit;
 pub mod metrics;
 pub mod node_config;

crates/node/builder/Cargo.toml

@@ -45,6 +45,7 @@ reth-node-events.workspace = true
 reth-consensus.workspace = true
 reth-consensus-debug-client.workspace = true
 reth-rpc-types.workspace = true
+reth-engine-util.workspace = true
 
 ## async
 futures.workspace = true

crates/node/builder/src/launch/mod.rs

@@ -13,17 +13,16 @@ use reth_beacon_consensus::{
     BeaconConsensusEngine,
 };
 use reth_consensus_debug_client::{DebugConsensusClient, EtherscanBlockProvider, RpcBlockProvider};
+use reth_engine_util::EngineMessageStreamExt;
 use reth_exex::ExExManagerHandle;
 use reth_network::NetworkEvents;
 use reth_node_api::FullNodeTypes;
 use reth_node_core::{
     dirs::{ChainPath, DataDirPath},
-    engine::EngineMessageStreamExt,
     exit::NodeExitFuture,
     version::{CARGO_PKG_VERSION, CLIENT_CODE, NAME_CLIENT, VERGEN_GIT_SHA},
 };
 use reth_node_events::{cl::ConsensusLayerHealthEvents, node};
-
 use reth_primitives::format_ether;
 use reth_provider::providers::BlockchainProvider;
 use reth_rpc_engine_api::EngineApi;