checkpoint

Author: clabby

Cargo.lock

@@ -30,24 +30,25 @@ hashbrown = "0.14.5"
 # Alloy Dependencies
 op-alloy-rpc-types = "0.1.4"
 op-alloy-consensus = "0.1.4"
+op-alloy-network = "0.1.5"
+alloy-rlp = { version = "0.3.8" }
 alloy-primitives = { version = "0.7" }
 alloy-consensus = { version = "0.2" }
 alloy-eips = { version = "0.2" }
 alloy-rpc-types = { version = "0.2" }
 
-# Foundry Dependencies
-foundry-common = { git = "https://github.com/foundry-rs/foundry", default-features = true, rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-foundry-compilers = { git = "https://github.com/foundry-rs/foundry", default-features = true, rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-anvil = { git = "https://github.com/foundry-rs/foundry", default-features = true, rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-anvil-core = { git = "https://github.com/foundry-rs/foundry", default-features = true, rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-cast = { git = "https://github.com/foundry-rs/foundry", rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-forge-script = { git = "https://github.com/foundry-rs/foundry", rev = "c600237f3e54604274bfdcba627f347493fd21d2" }
-revm = { version = "12.1", features = ["alloydb", "optimism"] }
+# revm + reth
+revm = { version = "13.0", features = ["optimism", "serde"] }
+reth-primitives = { git = "https://github.com/paradigmxyz/reth", tag = "v1.0.5" }
+reth-evm = { git = "https://github.com/paradigmxyz/reth", tag = "v1.0.5" }
+reth-evm-optimism = { git = "https://github.com/paradigmxyz/reth", tag = "v1.0.5", features = ["optimism"] }
+reth-chainspec = { git = "https://github.com/paradigmxyz/reth", tag = "v1.0.5", features = ["optimism"] }
 
 # Kona + OP Types
 superchain-registry = "0.2.6"
-kona-primitives = { git = "https://github.com/ethereum-optimism/kona", version = "0.0.2", features = ["online"] }
-kona-derive = { git = "https://github.com/ethereum-optimism/kona", version = "0.0.3", features = ["online"] }
+kona-primitives = { git = "https://github.com/ethereum-optimism/kona", version = "0.0.1", features = ["online"] }
+kona-derive = { git = "https://github.com/ethereum-optimism/kona", version = "0.0.2", features = ["online"] }
+kona-mpt = { git = "https://github.com/ethereum-optimism/kona", version = "0.0.2" }
 
 # Internal
 op-test-vectors = { path = "crates/op-test-vectors" }

Cargo.toml

@@ -10,36 +10,44 @@ publish = false
 
 [dependencies]
 # Core
+hashbrown.workspace = true
 serde.workspace = true
-serde_json.workspace = true
 tracing.workspace = true
+serde_json.workspace = true
 tokio.workspace = true
+reqwest.workspace = true
 futures.workspace = true
 color-eyre.workspace = true
-axum = "0.7.5"
-http-body-util = "0.1.2"
+tracing-subscriber.workspace = true
 
 # CLI
 clap.workspace = true
-shellwords.workspace = true
+inquire = { version = "0.7.5", features = ["editor"] }
+axum = "0.7"
+ctrlc = "3.4"
 
 # Alloy
-alloy-eips.workspace = true
-alloy-rpc-types.workspace = true
 alloy-primitives.workspace = true
+alloy-rlp.workspace = true
+alloy-consensus.workspace = true
+alloy-eips.workspace = true
+alloy-transport = "0.2"
+alloy-provider = "0.2"
+alloy-transport-http = "0.2"
+op-alloy-consensus.workspace = true
+op-alloy-network.workspace = true
 
-# Foundry
-foundry-common.workspace = true
-anvil.workspace = true
-anvil-core.workspace = true
-cast.workspace = true
-forge-script.workspace = true
-revm.workspace = true
-
-# OP Types
+# OP Types + Kona
 op-test-vectors.workspace = true
-op-alloy-rpc-types.workspace = true
-op-alloy-consensus.workspace = true
-thiserror.workspace = true
-reqwest.workspace = true
-hyper = "1.4.1"
+kona-primitives.workspace = true
+kona-mpt.workspace = true
+superchain-registry.workspace = true
+
+# reth
+reth-primitives = { workspace = true, features = ["optimism"] }
+reth-evm.workspace = true
+reth-evm-optimism.workspace = true
+reth-chainspec.workspace = true
+
+# revm
+revm = { workspace = true, features = ["optimism", "alloydb"] }

bin/opt8n/Cargo.toml

@@ -0,0 +1,3 @@
+# `opt8n`
+
+A CLI-tool for creating execution test fixtures.

bin/opt8n/README.md

@@ -0,0 +1,130 @@
+//! Deposit capture tool for `opt8n`.
+
+use super::Cli;
+use alloy_consensus::{Eip658Value, Receipt};
+use alloy_primitives::{b256, keccak256, Address, Bytes, Log, B256};
+use alloy_provider::{network::Ethereum, Provider, ReqwestProvider, RootProvider};
+use color_eyre::eyre::{eyre, Result};
+use kona_primitives::{decode_deposit, DEPOSIT_EVENT_ABI_HASH};
+use reqwest::Url;
+use tokio::sync::broadcast::Sender;
+use tracing::info;
+
+/// keccak256("t8n")
+const T8N_L1_SOURCE_HASH: B256 =
+    b256!("60b82a553424b66356596123f87f40cc9a453c02816a147e9418b49a373fa41a");
+
+/// The deposit capture proxy for `opt8n`.
+#[derive(Debug)]
+pub struct DepositCapture<'a> {
+    /// The CLI configuration for `opt8n`
+    pub(crate) cli: &'a Cli,
+    /// The interrupt receiver for the deposit configurator.
+    pub(crate) interrupt: Sender<()>,
+    /// The RLP-encoded transactions to apply to the genesis state to create the deposit.
+    pub(crate) transactions: Vec<Bytes>,
+}
+
+impl<'a> DepositCapture<'a> {
+    /// Create a new deposit configurator.
+    pub(crate) fn new(cli: &'a Cli, interrupt: Sender<()>) -> Self {
+        Self {
+            cli,
+            interrupt,
+            transactions: Vec::new(),
+        }
+    }
+
+    /// Opens a proxy to the L1 chain and captures the deposit transactions.
+    pub(crate) async fn capture_deposits(&mut self) -> Result<()> {
+        info!(
+            target: "opt8n", "Capturing deposit transactions sent to the L1 chain's `OptimismPortal`..."
+        );
+
+        // Capture the deposit transactions sent to the L1 node.
+        let transactions =
+            crate::proxy::capture_transactions(3000, self.cli.l1_port, self.interrupt.subscribe())
+                .await?;
+
+        // Fetch all receipts for the deposit transactions from the L1.
+        let l1_rpc_url = format!("http://localhost:{}", self.cli.l1_port);
+        let l1_provider: RootProvider<_, Ethereum> =
+            ReqwestProvider::new_http(Url::parse(&l1_rpc_url)?);
+        let mut receipts = Vec::new();
+        for tx in transactions {
+            let tx_hash = keccak256(tx.as_ref());
+
+            // Fetch RPC receipt.
+            let rpc_receipt = l1_provider
+                .get_transaction_receipt(tx_hash)
+                .await?
+                .ok_or(eyre!(
+                    "Transaction receipt not found for transaction hash: {:?}",
+                    tx_hash
+                ))?;
+            let receipt_rpc_logs = rpc_receipt.inner.as_receipt().ok_or(eyre!(
+                "Receipt not found for transaction hash: {:?}",
+                tx_hash
+            ))?;
+
+            // Convert to consensus receipt.
+            let receipt: Receipt<Log> = Receipt {
+                status: receipt_rpc_logs.status,
+                cumulative_gas_used: receipt_rpc_logs.cumulative_gas_used,
+                logs: receipt_rpc_logs
+                    .logs
+                    .iter()
+                    .map(|l| Log {
+                        address: l.address(),
+                        data: l.data().clone(),
+                    })
+                    .collect(),
+            };
+
+            receipts.push(receipt);
+        }
+
+        // Derive the deposit transactions from the OptimismPortal `depositTransaction` receipts.
+        let deposits = Self::derive_deposits(
+            T8N_L1_SOURCE_HASH,
+            receipts,
+            self.cli.optimism_portal_address,
+        )?;
+
+        self.transactions = deposits;
+        Ok(())
+    }
+
+    /// Derive the deposit transactions from the OptimismPortal `depositTransaction` receipts.
+    fn derive_deposits(
+        block_hash: B256,
+        receipts: Vec<Receipt>,
+        deposit_contract: Address,
+    ) -> Result<Vec<Bytes>> {
+        let mut global_index = 0;
+        let mut res = Vec::new();
+        for r in receipts.iter() {
+            if Eip658Value::Eip658(false) == r.status {
+                continue;
+            }
+            for l in r.logs.iter() {
+                let curr_index = global_index;
+                global_index += 1;
+                if !l
+                    .data
+                    .topics()
+                    .first()
+                    .map_or(false, |i| *i == DEPOSIT_EVENT_ABI_HASH)
+                {
+                    continue;
+                }
+                if l.address != deposit_contract {
+                    continue;
+                }
+                let decoded = decode_deposit(block_hash, curr_index, l).map_err(|e| eyre!(e))?;
+                res.push(decoded.0);
+            }
+        }
+        Ok(res)
+    }
+}

bin/opt8n/src/cli/deposits.rs

@@ -0,0 +1,120 @@
+//! L1 info transaction configuration tool for `opt8n`.
+
+use color_eyre::{eyre::Result, owo_colors::OwoColorize};
+use inquire::{Editor, Select};
+use kona_primitives::{L1BlockInfoBedrock, L1BlockInfoEcotone, L1BlockInfoTx};
+use std::{ffi::OsStr, fmt::Display};
+
+/// The L1 info transaction configurator for `opt8n`.
+#[derive(Debug)]
+pub struct L1InfoConfigurator {
+    /// The L1 info transaction data.
+    pub(crate) tx: L1BlockInfoTx,
+}
+
+impl Default for L1InfoConfigurator {
+    fn default() -> Self {
+        Self {
+            tx: L1BlockInfoTx::Ecotone(L1BlockInfoEcotone::default()),
+        }
+    }
+}
+
+impl L1InfoConfigurator {
+    /// Show the configuration menu for the prestate.
+    pub(crate) fn show_configuration_menu(&mut self) -> Result<()> {
+        let select = Select::new(
+            "What would you like to configure?",
+            [L1InfoConfigOption::TxKind, L1InfoConfigOption::Tx].to_vec(),
+        )
+        .prompt()?;
+
+        match select {
+            L1InfoConfigOption::TxKind => self.configure_tx_kind(),
+            L1InfoConfigOption::Tx => self.configure_tx(),
+        }
+    }
+
+    /// Opens a prompt to configure the chain state.
+    pub(crate) fn configure_tx_kind(&mut self) -> Result<()> {
+        let select = Select::new(
+            "Which version of the L1 info transaction are you sending?",
+            [L1InfoTxKind::Bedrock, L1InfoTxKind::Ecotone].to_vec(),
+        )
+        .prompt()?;
+
+        // Update the tx kind.
+        match select {
+            L1InfoTxKind::Bedrock => {
+                self.tx = L1BlockInfoTx::Bedrock(L1BlockInfoBedrock::default())
+            }
+            L1InfoTxKind::Ecotone => {
+                self.tx = L1BlockInfoTx::Ecotone(L1BlockInfoEcotone::default())
+            }
+        }
+
+        // Return to the L1 info tx configuration menu.
+        self.show_configuration_menu()
+    }
+
+    /// Opens a prompt to configure the L1 info transaction data.
+    pub(crate) fn configure_tx(&mut self) -> Result<()> {
+        // Serialize the tx data to a JSON string.
+        let serialized_tx_data = serde_json::to_string_pretty(&self.tx)?;
+
+        // Prompt the user to edit the block environment.
+        let editor_command = option_env!("EDITOR").unwrap_or("vim");
+        let editor = Editor::new("Edit the L1 info transaction data")
+            .with_file_extension(".json")
+            .with_editor_command(OsStr::new(editor_command))
+            .with_predefined_text(serialized_tx_data.as_str())
+            .prompt()?;
+
+        // Deserialize the block environment from the editor.
+        let deserialized_tx_data = serde_json::from_str(&editor);
+        if let Ok(tx_data) = deserialized_tx_data {
+            self.tx = tx_data;
+        } else {
+            eprintln!("Failed to deserialize L1 info transaction data. Using previous value.");
+        }
+
+        Ok(())
+    }
+}
+
+/// The L1 info transaction configuration options.
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
+enum L1InfoConfigOption {
+    TxKind,
+    Tx,
+}
+
+impl Display for L1InfoConfigOption {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            L1InfoConfigOption::TxKind => write!(
+                f,
+                "L1 info transaction kind ({} | {})",
+                "BEDROCK".green(),
+                "ECOTONE".green()
+            ),
+            L1InfoConfigOption::Tx => write!(f, "Modify L1 info transaction"),
+        }
+    }
+}
+
+/// The L1 info transaction kinds.
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
+enum L1InfoTxKind {
+    Bedrock,
+    Ecotone,
+}
+
+impl Display for L1InfoTxKind {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            L1InfoTxKind::Bedrock => write!(f, "Bedrock"),
+            L1InfoTxKind::Ecotone => write!(f, "Ecotone"),
+        }
+    }
+}