Add post-block gnosis execution (#2)

* Add post-block gnosis execution

* Parse return of call

* Move copied code out

* fix

Cargo.toml

@@ -20,6 +20,8 @@ reth-evm-ethereum = { git = "https://github.com/paradigmxyz/reth", rev = "7b435e
 reth-ethereum-consensus = { git = "https://github.com/paradigmxyz/reth", rev = "7b435e0d6dede497dca211090d95a4cfa387dd1b" }
 eyre = "0.6.12"
 clap = { version = "4.5.6", features = ["derive"] }
+alloy-sol-macro = "0.7.6"
+alloy-sol-types = "0.7.6"
 
 [target.'cfg(unix)'.dependencies]
 tikv-jemallocator = { version = "0.5.0", optional = true }

README.md

@@ -0,0 +1,13 @@
+# Reth @ Gnosis 🍴
+
+Gnosis compatible Reth client. Not a fork, but an extension with the `NodeBuilder` API.
+
+Refer to the Reth's documentation to run a node: https://reth.rs/
+
+## Implementation progress
+
+- [ ] Pre-merge POSDAO / AuRa
+- [ ] [EIP-1559 modifications](https://github.com/gnosischain/specs/blob/master/network-upgrades/london.md)
+- [x] [Post-merge POSDAO](https://github.com/gnosischain/specs/blob/master/execution/posdao-post-merge.md)
+- [x] [Gnosis withdrawals](https://github.com/gnosischain/specs/blob/master/execution/withdrawals.md)
+

src/ethereum.rs

@@ -0,0 +1,141 @@
+//! This module is exactly identical to <https://github.com/paradigmxyz/reth/blob/268e768d822a0d4eb8ed365dc6390862f759a849/crates/ethereum/evm/src/execute.rs>
+
+use reth::{
+    primitives::{BlockWithSenders, ChainSpec, Receipt, Request},
+    providers::ProviderError,
+    revm::{
+        primitives::ResultAndState,
+        state_change::{
+            apply_beacon_root_contract_call, apply_blockhashes_update,
+            apply_withdrawal_requests_contract_call,
+        },
+        Database, DatabaseCommit, Evm, State,
+    },
+};
+use reth_evm::{
+    execute::{BlockExecutionError, BlockValidationError},
+    ConfigureEvm,
+};
+use reth_evm_ethereum::eip6110::parse_deposits_from_receipts;
+use std::sync::Arc;
+
+/// Helper type for the output of executing a block.
+#[derive(Debug, Clone)]
+pub struct EthExecuteOutput {
+    pub receipts: Vec<Receipt>,
+    pub requests: Vec<Request>,
+    pub gas_used: u64,
+}
+
+/// Helper container type for EVM with chain spec.
+#[derive(Debug, Clone)]
+pub struct EthEvmExecutor<EvmConfig> {
+    /// The chainspec
+    pub chain_spec: Arc<ChainSpec>,
+    /// How to create an EVM.
+    pub evm_config: EvmConfig,
+}
+
+impl<EvmConfig> EthEvmExecutor<EvmConfig>
+where
+    EvmConfig: ConfigureEvm,
+{
+    /// Executes the transactions in the block and returns the receipts of the transactions in the
+    /// block, the total gas used and the list of EIP-7685 [requests](Request).
+    ///
+    /// This applies the pre-execution and post-execution changes that require an [EVM](Evm), and
+    /// executes the transactions.
+    pub fn execute_state_transitions<Ext, DB>(
+        &self,
+        block: &BlockWithSenders,
+        mut evm: Evm<'_, Ext, &mut State<DB>>,
+    ) -> Result<EthExecuteOutput, BlockExecutionError>
+    where
+        DB: Database<Error = ProviderError>,
+    {
+        // apply pre execution changes
+        apply_beacon_root_contract_call(
+            &self.chain_spec,
+            block.timestamp,
+            block.number,
+            block.parent_beacon_block_root,
+            &mut evm,
+        )?;
+        apply_blockhashes_update(
+            evm.db_mut(),
+            &self.chain_spec,
+            block.timestamp,
+            block.number,
+            block.parent_hash,
+        )?;
+
+        // execute transactions
+        let mut cumulative_gas_used = 0;
+        let mut receipts = Vec::with_capacity(block.body.len());
+        for (sender, transaction) in block.transactions_with_sender() {
+            // The sum of the transaction’s gas limit, Tg, and the gas utilized in this block prior,
+            // must be no greater than the block’s gasLimit.
+            let block_available_gas = block.header.gas_limit - cumulative_gas_used;
+            if transaction.gas_limit() > block_available_gas {
+                return Err(
+                    BlockValidationError::TransactionGasLimitMoreThanAvailableBlockGas {
+                        transaction_gas_limit: transaction.gas_limit(),
+                        block_available_gas,
+                    }
+                    .into(),
+                );
+            }
+
+            EvmConfig::fill_tx_env(evm.tx_mut(), transaction, *sender);
+
+            // Execute transaction.
+            let ResultAndState { result, state } = evm.transact().map_err(move |err| {
+                // Ensure hash is calculated for error log, if not already done
+                BlockValidationError::EVM {
+                    hash: transaction.recalculate_hash(),
+                    error: err.into(),
+                }
+            })?;
+            evm.db_mut().commit(state);
+
+            // append gas used
+            cumulative_gas_used += result.gas_used();
+
+            // Push transaction changeset and calculate header bloom filter for receipt.
+            receipts.push(
+                #[allow(clippy::needless_update)] // side-effect of optimism fields
+                Receipt {
+                    tx_type: transaction.tx_type(),
+                    // Success flag was added in `EIP-658: Embedding transaction status code in
+                    // receipts`.
+                    success: result.is_success(),
+                    cumulative_gas_used,
+                    // convert to reth log
+                    logs: result.into_logs(),
+                    ..Default::default()
+                },
+            );
+        }
+
+        let requests = if self
+            .chain_spec
+            .is_prague_active_at_timestamp(block.timestamp)
+        {
+            // Collect all EIP-6110 deposits
+            let deposit_requests = parse_deposits_from_receipts(&self.chain_spec, &receipts)?;
+
+            // Collect all EIP-7685 requests
+            let withdrawal_requests = apply_withdrawal_requests_contract_call(&mut evm)?;
+
+            [deposit_requests, withdrawal_requests].concat()
+        } else {
+            vec![]
+        };
+
+        Ok(EthExecuteOutput {
+            receipts,
+            requests,
+            gas_used: cumulative_gas_used,
+        })
+    }
+}