1use super::fork::environment;
2use crate::{
3 EvmEnv,
4 constants::DEFAULT_CREATE2_DEPLOYER,
5 fork::{CreateFork, configure_env},
6};
7use alloy_network::Network;
8use alloy_primitives::{Address, B256, U256};
9use alloy_provider::{Provider, network::AnyRpcBlock};
10use eyre::WrapErr;
11use foundry_common::{
12 ALCHEMY_FREE_TIER_CUPS,
13 provider::{ProviderBuilder, RetryProvider},
14};
15use foundry_config::{Chain, Config, GasLimit};
16use foundry_evm_networks::NetworkConfigs;
17use revm::context::{BlockEnv, TxEnv};
18use serde::{Deserialize, Serialize};
19use std::fmt::Write;
20use url::Url;
21
22#[derive(Clone, Debug, Serialize, Deserialize)]
23pub struct EvmOpts {
24 #[serde(flatten)]
26 pub env: Env,
27
28 #[serde(rename = "eth_rpc_url")]
30 pub fork_url: Option<String>,
31
32 pub fork_block_number: Option<u64>,
34
35 pub fork_retries: Option<u32>,
37
38 pub fork_retry_backoff: Option<u64>,
40
41 pub fork_headers: Option<Vec<String>>,
43
44 pub compute_units_per_second: Option<u64>,
48
49 pub no_rpc_rate_limit: bool,
51
52 pub no_storage_caching: bool,
54
55 pub initial_balance: U256,
57
58 pub sender: Address,
60
61 pub ffi: bool,
63
64 pub always_use_create_2_factory: bool,
66
67 pub verbosity: u8,
69
70 pub memory_limit: u64,
73
74 pub isolate: bool,
76
77 pub disable_block_gas_limit: bool,
79
80 pub enable_tx_gas_limit: bool,
82
83 #[serde(flatten)]
84 pub networks: NetworkConfigs,
86
87 pub create2_deployer: Address,
89}
90
91impl Default for EvmOpts {
92 fn default() -> Self {
93 Self {
94 env: Env::default(),
95 fork_url: None,
96 fork_block_number: None,
97 fork_retries: None,
98 fork_retry_backoff: None,
99 fork_headers: None,
100 compute_units_per_second: None,
101 no_rpc_rate_limit: false,
102 no_storage_caching: false,
103 initial_balance: U256::default(),
104 sender: Address::default(),
105 ffi: false,
106 always_use_create_2_factory: false,
107 verbosity: 0,
108 memory_limit: 0,
109 isolate: false,
110 disable_block_gas_limit: false,
111 enable_tx_gas_limit: false,
112 networks: NetworkConfigs::default(),
113 create2_deployer: DEFAULT_CREATE2_DEPLOYER,
114 }
115 }
116}
117
118impl EvmOpts {
119 pub fn fork_provider_with_url(&self, fork_url: &str) -> eyre::Result<RetryProvider> {
121 ProviderBuilder::new(fork_url)
122 .maybe_max_retry(self.fork_retries)
123 .maybe_initial_backoff(self.fork_retry_backoff)
124 .maybe_headers(self.fork_headers.clone())
125 .compute_units_per_second(self.get_compute_units_per_second())
126 .build()
127 }
128
129 pub async fn evm_env(&self) -> eyre::Result<crate::Env> {
134 if let Some(ref fork_url) = self.fork_url {
135 Ok(self.fork_evm_env(fork_url).await?.0)
136 } else {
137 Ok(self.local_evm_env())
138 }
139 }
140
141 pub async fn fork_evm_env(&self, fork_url: &str) -> eyre::Result<(crate::Env, AnyRpcBlock)> {
144 let provider = self.fork_provider_with_url(fork_url)?;
145 self.fork_evm_env_with_provider(fork_url, &provider).await
146 }
147
148 pub async fn fork_evm_env_with_provider<P: Provider<N>, N: Network>(
151 &self,
152 fork_url: &str,
153 provider: &P,
154 ) -> eyre::Result<(crate::Env, N::BlockResponse)> {
155 environment(
156 provider,
157 self.memory_limit,
158 self.env.gas_price.map(|v| v as u128),
159 self.env.chain_id,
160 self.fork_block_number,
161 self.sender,
162 self.disable_block_gas_limit,
163 self.enable_tx_gas_limit,
164 self.networks,
165 )
166 .await
167 .wrap_err_with(|| {
168 let mut msg = "could not instantiate forked environment".to_string();
169 if let Ok(url) = Url::parse(fork_url)
170 && let Some(provider) = url.host()
171 {
172 write!(msg, " with provider {provider}").unwrap();
173 }
174 msg
175 })
176 }
177
178 fn local_evm_env(&self) -> crate::Env {
180 let cfg = configure_env(
181 self.env.chain_id.unwrap_or(foundry_common::DEV_CHAIN_ID),
182 self.memory_limit,
183 self.disable_block_gas_limit,
184 self.enable_tx_gas_limit,
185 );
186
187 crate::Env {
188 evm_env: EvmEnv {
189 cfg_env: cfg,
190 block_env: BlockEnv {
191 number: self.env.block_number,
192 beneficiary: self.env.block_coinbase,
193 timestamp: self.env.block_timestamp,
194 difficulty: U256::from(self.env.block_difficulty),
195 prevrandao: Some(self.env.block_prevrandao),
196 basefee: self.env.block_base_fee_per_gas,
197 gas_limit: self.gas_limit(),
198 ..Default::default()
199 },
200 },
201 tx: TxEnv {
202 gas_price: self.env.gas_price.unwrap_or_default().into(),
203 gas_limit: self.gas_limit(),
204 caller: self.sender,
205 ..Default::default()
206 },
207 }
208 }
209
210 pub fn get_fork(&self, config: &Config, env: crate::Env) -> Option<CreateFork> {
224 let url = self.fork_url.clone()?;
225 let enable_caching = config.enable_caching(&url, env.evm_env.cfg_env.chain_id);
226 Some(CreateFork { url, enable_caching, env, evm_opts: self.clone() })
227 }
228
229 pub fn gas_limit(&self) -> u64 {
231 self.env.block_gas_limit.unwrap_or(self.env.gas_limit).0
232 }
233
234 fn get_compute_units_per_second(&self) -> u64 {
239 if self.no_rpc_rate_limit {
240 u64::MAX
241 } else if let Some(cups) = self.compute_units_per_second {
242 cups
243 } else {
244 ALCHEMY_FREE_TIER_CUPS
245 }
246 }
247
248 pub async fn get_remote_chain_id(&self) -> Option<Chain> {
250 if let Some(url) = &self.fork_url
251 && let Ok(provider) = self.fork_provider_with_url(url)
252 {
253 trace!(?url, "retrieving chain via eth_chainId");
254
255 if let Ok(id) = provider.get_chain_id().await {
256 return Some(Chain::from(id));
257 }
258
259 if url.contains("mainnet") {
263 trace!(?url, "auto detected mainnet chain");
264 return Some(Chain::mainnet());
265 }
266 }
267
268 None
269 }
270}
271
272#[derive(Clone, Debug, Default, Serialize, Deserialize)]
273pub struct Env {
274 pub gas_limit: GasLimit,
276
277 pub chain_id: Option<u64>,
279
280 #[serde(default, skip_serializing_if = "Option::is_none")]
285 pub gas_price: Option<u64>,
286
287 pub block_base_fee_per_gas: u64,
289
290 pub tx_origin: Address,
292
293 pub block_coinbase: Address,
295
296 #[serde(
298 deserialize_with = "foundry_config::deserialize_u64_to_u256",
299 serialize_with = "foundry_config::serialize_u64_or_u256"
300 )]
301 pub block_timestamp: U256,
302
303 #[serde(
305 deserialize_with = "foundry_config::deserialize_u64_to_u256",
306 serialize_with = "foundry_config::serialize_u64_or_u256"
307 )]
308 pub block_number: U256,
309
310 pub block_difficulty: u64,
312
313 pub block_prevrandao: B256,
315
316 #[serde(default, skip_serializing_if = "Option::is_none")]
318 pub block_gas_limit: Option<GasLimit>,
319
320 #[serde(default, skip_serializing_if = "Option::is_none")]
322 pub code_size_limit: Option<usize>,
323}