mirror of
https://github.com/hl-archive-node/nanoreth.git
synced 2025-12-06 10:59:55 +00:00
chore: move eip7002 impl (#10998)
This commit is contained in:
143
crates/evm/src/system_calls/eip7002.rs
Normal file
143
crates/evm/src/system_calls/eip7002.rs
Normal file
@ -0,0 +1,143 @@
|
||||
//! [EIP-7002](https://eips.ethereum.org/EIPS/eip-7002) system call implementation.
|
||||
use alloc::{boxed::Box, format, string::ToString, vec::Vec};
|
||||
use core::fmt::Display;
|
||||
|
||||
use crate::ConfigureEvm;
|
||||
use alloy_eips::eip7002::{WithdrawalRequest, WITHDRAWAL_REQUEST_PREDEPLOY_ADDRESS};
|
||||
use reth_execution_errors::{BlockExecutionError, BlockValidationError};
|
||||
use reth_primitives::{Buf, Header, Request};
|
||||
use revm::{interpreter::Host, Database, DatabaseCommit, Evm};
|
||||
use revm_primitives::{
|
||||
Address, BlockEnv, Bytes, CfgEnvWithHandlerCfg, EnvWithHandlerCfg, ExecutionResult, FixedBytes,
|
||||
ResultAndState,
|
||||
};
|
||||
|
||||
/// Apply the [EIP-7002](https://eips.ethereum.org/EIPS/eip-7002) post block contract call.
|
||||
///
|
||||
/// This constructs a new [Evm] with the given DB, and environment
|
||||
/// ([`CfgEnvWithHandlerCfg`] and [`BlockEnv`]) to execute the post block contract call.
|
||||
///
|
||||
/// This uses [`apply_withdrawal_requests_contract_call`] to ultimately calculate the
|
||||
/// [requests](Request).
|
||||
pub fn post_block_withdrawal_requests_contract_call<EvmConfig, DB>(
|
||||
evm_config: &EvmConfig,
|
||||
db: &mut DB,
|
||||
initialized_cfg: &CfgEnvWithHandlerCfg,
|
||||
initialized_block_env: &BlockEnv,
|
||||
) -> Result<Vec<Request>, BlockExecutionError>
|
||||
where
|
||||
DB: Database + DatabaseCommit,
|
||||
DB::Error: Display,
|
||||
EvmConfig: ConfigureEvm<Header = Header>,
|
||||
{
|
||||
// apply post-block EIP-7002 contract call
|
||||
let mut evm_post_block = Evm::builder()
|
||||
.with_db(db)
|
||||
.with_env_with_handler_cfg(EnvWithHandlerCfg::new_with_cfg_env(
|
||||
initialized_cfg.clone(),
|
||||
initialized_block_env.clone(),
|
||||
Default::default(),
|
||||
))
|
||||
.build();
|
||||
|
||||
// initialize a block from the env, because the post block call needs the block itself
|
||||
apply_withdrawal_requests_contract_call(evm_config, &mut evm_post_block)
|
||||
}
|
||||
|
||||
/// Applies the post-block call to the EIP-7002 withdrawal requests contract.
|
||||
///
|
||||
/// If Prague is not active at the given timestamp, then this is a no-op, and an empty vector is
|
||||
/// returned. Otherwise, the withdrawal requests are returned.
|
||||
#[inline]
|
||||
pub fn apply_withdrawal_requests_contract_call<EvmConfig, EXT, DB>(
|
||||
evm_config: &EvmConfig,
|
||||
evm: &mut Evm<'_, EXT, DB>,
|
||||
) -> Result<Vec<Request>, BlockExecutionError>
|
||||
where
|
||||
DB: Database + DatabaseCommit,
|
||||
DB::Error: core::fmt::Display,
|
||||
EvmConfig: ConfigureEvm<Header = Header>,
|
||||
{
|
||||
// get previous env
|
||||
let previous_env = Box::new(evm.context.env().clone());
|
||||
|
||||
// Fill transaction environment with the EIP-7002 withdrawal requests contract message data.
|
||||
//
|
||||
// This requirement for the withdrawal requests contract call defined by
|
||||
// [EIP-7002](https://eips.ethereum.org/EIPS/eip-7002) is:
|
||||
//
|
||||
// At the end of processing any execution block where `block.timestamp >= FORK_TIMESTAMP` (i.e.
|
||||
// after processing all transactions and after performing the block body withdrawal requests
|
||||
// validations), call the contract as `SYSTEM_ADDRESS`.
|
||||
evm_config.fill_tx_env_system_contract_call(
|
||||
&mut evm.context.evm.env,
|
||||
alloy_eips::eip7002::SYSTEM_ADDRESS,
|
||||
WITHDRAWAL_REQUEST_PREDEPLOY_ADDRESS,
|
||||
Bytes::new(),
|
||||
);
|
||||
|
||||
let ResultAndState { result, mut state } = match evm.transact() {
|
||||
Ok(res) => res,
|
||||
Err(e) => {
|
||||
evm.context.evm.env = previous_env;
|
||||
return Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution failed: {e}"),
|
||||
}
|
||||
.into())
|
||||
}
|
||||
};
|
||||
|
||||
// cleanup the state
|
||||
state.remove(&alloy_eips::eip7002::SYSTEM_ADDRESS);
|
||||
state.remove(&evm.block().coinbase);
|
||||
evm.context.evm.db.commit(state);
|
||||
|
||||
// re-set the previous env
|
||||
evm.context.evm.env = previous_env;
|
||||
|
||||
let mut data = match result {
|
||||
ExecutionResult::Success { output, .. } => Ok(output.into_data()),
|
||||
ExecutionResult::Revert { output, .. } => {
|
||||
Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution reverted: {output}"),
|
||||
})
|
||||
}
|
||||
ExecutionResult::Halt { reason, .. } => {
|
||||
Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution halted: {reason:?}"),
|
||||
})
|
||||
}
|
||||
}?;
|
||||
|
||||
// Withdrawals are encoded as a series of withdrawal requests, each with the following
|
||||
// format:
|
||||
//
|
||||
// +------+--------+--------+
|
||||
// | addr | pubkey | amount |
|
||||
// +------+--------+--------+
|
||||
// 20 48 8
|
||||
|
||||
const WITHDRAWAL_REQUEST_SIZE: usize = 20 + 48 + 8;
|
||||
let mut withdrawal_requests = Vec::with_capacity(data.len() / WITHDRAWAL_REQUEST_SIZE);
|
||||
while data.has_remaining() {
|
||||
if data.remaining() < WITHDRAWAL_REQUEST_SIZE {
|
||||
return Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: "invalid withdrawal request length".to_string(),
|
||||
}
|
||||
.into())
|
||||
}
|
||||
|
||||
let mut source_address = Address::ZERO;
|
||||
data.copy_to_slice(source_address.as_mut_slice());
|
||||
|
||||
let mut validator_pubkey = FixedBytes::<48>::ZERO;
|
||||
data.copy_to_slice(validator_pubkey.as_mut_slice());
|
||||
|
||||
let amount = data.get_u64();
|
||||
|
||||
withdrawal_requests
|
||||
.push(WithdrawalRequest { source_address, validator_pubkey, amount }.into());
|
||||
}
|
||||
|
||||
Ok(withdrawal_requests)
|
||||
}
|
||||
@ -4,10 +4,7 @@ use alloc::{boxed::Box, format, string::ToString, vec::Vec};
|
||||
use core::fmt::Display;
|
||||
|
||||
use crate::ConfigureEvm;
|
||||
use alloy_eips::{
|
||||
eip7002::{WithdrawalRequest, WITHDRAWAL_REQUEST_PREDEPLOY_ADDRESS},
|
||||
eip7251::{ConsolidationRequest, CONSOLIDATION_REQUEST_PREDEPLOY_ADDRESS},
|
||||
};
|
||||
use alloy_eips::eip7251::{ConsolidationRequest, CONSOLIDATION_REQUEST_PREDEPLOY_ADDRESS};
|
||||
use reth_execution_errors::{BlockExecutionError, BlockValidationError};
|
||||
use reth_primitives::{Buf, Header, Request};
|
||||
use revm::{interpreter::Host, Database, DatabaseCommit, Evm};
|
||||
@ -22,135 +19,8 @@ pub use eip2935::*;
|
||||
mod eip4788;
|
||||
pub use eip4788::*;
|
||||
|
||||
/// Apply the [EIP-7002](https://eips.ethereum.org/EIPS/eip-7002) post block contract call.
|
||||
///
|
||||
/// This constructs a new [Evm] with the given DB, and environment
|
||||
/// ([`CfgEnvWithHandlerCfg`] and [`BlockEnv`]) to execute the post block contract call.
|
||||
///
|
||||
/// This uses [`apply_withdrawal_requests_contract_call`] to ultimately calculate the
|
||||
/// [requests](Request).
|
||||
pub fn post_block_withdrawal_requests_contract_call<EvmConfig, DB>(
|
||||
evm_config: &EvmConfig,
|
||||
db: &mut DB,
|
||||
initialized_cfg: &CfgEnvWithHandlerCfg,
|
||||
initialized_block_env: &BlockEnv,
|
||||
) -> Result<Vec<Request>, BlockExecutionError>
|
||||
where
|
||||
DB: Database + DatabaseCommit,
|
||||
DB::Error: Display,
|
||||
EvmConfig: ConfigureEvm<Header = Header>,
|
||||
{
|
||||
// apply post-block EIP-7002 contract call
|
||||
let mut evm_post_block = Evm::builder()
|
||||
.with_db(db)
|
||||
.with_env_with_handler_cfg(EnvWithHandlerCfg::new_with_cfg_env(
|
||||
initialized_cfg.clone(),
|
||||
initialized_block_env.clone(),
|
||||
Default::default(),
|
||||
))
|
||||
.build();
|
||||
|
||||
// initialize a block from the env, because the post block call needs the block itself
|
||||
apply_withdrawal_requests_contract_call(evm_config, &mut evm_post_block)
|
||||
}
|
||||
|
||||
/// Applies the post-block call to the EIP-7002 withdrawal requests contract.
|
||||
///
|
||||
/// If Prague is not active at the given timestamp, then this is a no-op, and an empty vector is
|
||||
/// returned. Otherwise, the withdrawal requests are returned.
|
||||
#[inline]
|
||||
pub fn apply_withdrawal_requests_contract_call<EvmConfig, EXT, DB>(
|
||||
evm_config: &EvmConfig,
|
||||
evm: &mut Evm<'_, EXT, DB>,
|
||||
) -> Result<Vec<Request>, BlockExecutionError>
|
||||
where
|
||||
DB: Database + DatabaseCommit,
|
||||
DB::Error: core::fmt::Display,
|
||||
EvmConfig: ConfigureEvm<Header = Header>,
|
||||
{
|
||||
// get previous env
|
||||
let previous_env = Box::new(evm.context.env().clone());
|
||||
|
||||
// Fill transaction environment with the EIP-7002 withdrawal requests contract message data.
|
||||
//
|
||||
// This requirement for the withdrawal requests contract call defined by
|
||||
// [EIP-7002](https://eips.ethereum.org/EIPS/eip-7002) is:
|
||||
//
|
||||
// At the end of processing any execution block where `block.timestamp >= FORK_TIMESTAMP` (i.e.
|
||||
// after processing all transactions and after performing the block body withdrawal requests
|
||||
// validations), call the contract as `SYSTEM_ADDRESS`.
|
||||
evm_config.fill_tx_env_system_contract_call(
|
||||
&mut evm.context.evm.env,
|
||||
alloy_eips::eip7002::SYSTEM_ADDRESS,
|
||||
WITHDRAWAL_REQUEST_PREDEPLOY_ADDRESS,
|
||||
Bytes::new(),
|
||||
);
|
||||
|
||||
let ResultAndState { result, mut state } = match evm.transact() {
|
||||
Ok(res) => res,
|
||||
Err(e) => {
|
||||
evm.context.evm.env = previous_env;
|
||||
return Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution failed: {e}"),
|
||||
}
|
||||
.into())
|
||||
}
|
||||
};
|
||||
|
||||
// cleanup the state
|
||||
state.remove(&alloy_eips::eip7002::SYSTEM_ADDRESS);
|
||||
state.remove(&evm.block().coinbase);
|
||||
evm.context.evm.db.commit(state);
|
||||
|
||||
// re-set the previous env
|
||||
evm.context.evm.env = previous_env;
|
||||
|
||||
let mut data = match result {
|
||||
ExecutionResult::Success { output, .. } => Ok(output.into_data()),
|
||||
ExecutionResult::Revert { output, .. } => {
|
||||
Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution reverted: {output}"),
|
||||
})
|
||||
}
|
||||
ExecutionResult::Halt { reason, .. } => {
|
||||
Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: format!("execution halted: {reason:?}"),
|
||||
})
|
||||
}
|
||||
}?;
|
||||
|
||||
// Withdrawals are encoded as a series of withdrawal requests, each with the following
|
||||
// format:
|
||||
//
|
||||
// +------+--------+--------+
|
||||
// | addr | pubkey | amount |
|
||||
// +------+--------+--------+
|
||||
// 20 48 8
|
||||
|
||||
const WITHDRAWAL_REQUEST_SIZE: usize = 20 + 48 + 8;
|
||||
let mut withdrawal_requests = Vec::with_capacity(data.len() / WITHDRAWAL_REQUEST_SIZE);
|
||||
while data.has_remaining() {
|
||||
if data.remaining() < WITHDRAWAL_REQUEST_SIZE {
|
||||
return Err(BlockValidationError::WithdrawalRequestsContractCall {
|
||||
message: "invalid withdrawal request length".to_string(),
|
||||
}
|
||||
.into())
|
||||
}
|
||||
|
||||
let mut source_address = Address::ZERO;
|
||||
data.copy_to_slice(source_address.as_mut_slice());
|
||||
|
||||
let mut validator_pubkey = FixedBytes::<48>::ZERO;
|
||||
data.copy_to_slice(validator_pubkey.as_mut_slice());
|
||||
|
||||
let amount = data.get_u64();
|
||||
|
||||
withdrawal_requests
|
||||
.push(WithdrawalRequest { source_address, validator_pubkey, amount }.into());
|
||||
}
|
||||
|
||||
Ok(withdrawal_requests)
|
||||
}
|
||||
mod eip7002;
|
||||
pub use eip7002::*;
|
||||
|
||||
/// Apply the [EIP-7251](https://eips.ethereum.org/EIPS/eip-7251) post block contract call.
|
||||
///
|
||||
|
||||
Reference in New Issue
Block a user