feat(exex): backfill executor (paradigmxyz#9123)

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

@@ -28,9 +28,8 @@ use reth_provider::{
 };
 use reth_prune::PruneModes;
 use reth_stages::{
-    sets::DefaultStages,
-    stages::{ExecutionStage, ExecutionStageThresholds},
-    Pipeline, StageId, StageSet,
+    sets::DefaultStages, stages::ExecutionStage, ExecutionStageThresholds, Pipeline, StageId,
+    StageSet,
 };
 use reth_static_file::StaticFileProducer;
 use reth_tasks::TaskExecutor;

bin/reth/src/commands/stage/dump/merkle.rs

@@ -12,10 +12,10 @@ use reth_provider::{providers::StaticFileProvider, ProviderFactory};
 use reth_prune::PruneModes;
 use reth_stages::{
     stages::{
-        AccountHashingStage, ExecutionStage, ExecutionStageThresholds, MerkleStage,
-        StorageHashingStage, MERKLE_STAGE_DEFAULT_CLEAN_THRESHOLD,
+        AccountHashingStage, ExecutionStage, MerkleStage, StorageHashingStage,
+        MERKLE_STAGE_DEFAULT_CLEAN_THRESHOLD,
     },
-    Stage, StageCheckpoint, UnwindInput,
+    ExecutionStageThresholds, Stage, StageCheckpoint, UnwindInput,
 };
 use tracing::info;
 

bin/reth/src/commands/stage/run.rs

@@ -20,11 +20,11 @@ use reth_provider::{
 };
 use reth_stages::{
     stages::{
-        AccountHashingStage, BodyStage, ExecutionStage, ExecutionStageThresholds,
-        IndexAccountHistoryStage, IndexStorageHistoryStage, MerkleStage, SenderRecoveryStage,
-        StorageHashingStage, TransactionLookupStage,
+        AccountHashingStage, BodyStage, ExecutionStage, IndexAccountHistoryStage,
+        IndexStorageHistoryStage, MerkleStage, SenderRecoveryStage, StorageHashingStage,
+        TransactionLookupStage,
     },
-    ExecInput, ExecOutput, Stage, StageExt, UnwindInput, UnwindOutput,
+    ExecInput, ExecOutput, ExecutionStageThresholds, Stage, StageExt, UnwindInput, UnwindOutput,
 };
 use std::{any::Any, net::SocketAddr, sync::Arc, time::Instant};
 use tracing::*;

bin/reth/src/commands/stage/unwind.rs

@@ -16,8 +16,8 @@ use reth_provider::{
 use reth_prune::PruneModes;
 use reth_stages::{
     sets::{DefaultStages, OfflineStages},
-    stages::{ExecutionStage, ExecutionStageThresholds},
-    Pipeline, StageSet,
+    stages::ExecutionStage,
+    ExecutionStageThresholds, Pipeline, StageSet,
 };
 use reth_static_file::StaticFileProducer;
 use std::{ops::RangeInclusive, sync::Arc};

crates/config/Cargo.toml

@@ -14,6 +14,7 @@ workspace = true
 # reth
 reth-network-types = { workspace = true, features = ["serde"] }
 reth-prune-types.workspace = true
+reth-stages-types.workspace = true
 
 # serde
 serde.workspace = true

crates/config/src/config.rs

@@ -2,6 +2,7 @@
 
 use reth_network_types::{PeersConfig, SessionsConfig};
 use reth_prune_types::PruneModes;
+use reth_stages_types::ExecutionStageThresholds;
 use serde::{Deserialize, Deserializer, Serialize};
 use std::{
     ffi::OsStr,
@@ -216,6 +217,17 @@ impl Default for ExecutionConfig {
     }
 }
 
+impl From<ExecutionConfig> for ExecutionStageThresholds {
+    fn from(config: ExecutionConfig) -> Self {
+        Self {
+            max_blocks: config.max_blocks,
+            max_changes: config.max_changes,
+            max_cumulative_gas: config.max_cumulative_gas,
+            max_duration: config.max_duration,
+        }
+    }
+}
+
 /// Hashing stage configuration.
 #[derive(Debug, Clone, Copy, Deserialize, PartialEq, Eq, Serialize)]
 #[serde(default)]

crates/evm/execution-types/src/chain.rs

@@ -94,6 +94,11 @@ impl Chain {
         &self.execution_outcome
     }
 
+    /// Get mutable execution outcome of this chain
+    pub fn execution_outcome_mut(&mut self) -> &mut ExecutionOutcome {
+        &mut self.execution_outcome
+    }
+
     /// Prepends the given state to the current state.
     pub fn prepend_state(&mut self, state: BundleState) {
         self.execution_outcome.prepend_state(state);

crates/exex/exex/Cargo.toml

@@ -24,6 +24,11 @@ reth-tasks.workspace = true
 reth-tracing.workspace = true
 reth-network.workspace = true
 reth-payload-builder.workspace = true
+reth-evm.workspace = true
+reth-prune-types.workspace = true
+reth-revm.workspace = true
+reth-stages-api.workspace = true
+reth-db-api.workspace = true
 
 ## async
 tokio.workspace = true
@@ -34,6 +39,17 @@ eyre.workspace = true
 metrics.workspace = true
 serde = { workspace = true, optional = true }
 
+[dev-dependencies]
+reth-chainspec.workspace = true
+reth-evm-ethereum.workspace = true
+reth-testing-utils.workspace = true
+reth-blockchain-tree.workspace = true
+reth-db-common.workspace = true
+reth-node-api.workspace = true
+reth-provider = { workspace = true, features = ["test-utils"] }
+
+secp256k1.workspace = true
+
 [features]
 default = []
 serde = ["dep:serde", "reth-provider/serde"]