Compare commits

...

2 Commits

Author SHA1 Message Date
Omar Abdulla 93d3388739 Add timing information to the CLI report 2025-08-06 19:51:36 +03:00
Omar Abdulla 63850fce9e Remove the provider cache 2025-08-06 18:38:20 +03:00
4 changed files with 9 additions and 7 deletions
+7 -1
View File
@@ -2,6 +2,7 @@ use std::{
collections::HashMap, collections::HashMap,
path::Path, path::Path,
sync::{Arc, LazyLock}, sync::{Arc, LazyLock},
time::Instant,
}; };
use alloy::{ use alloy::{
@@ -189,6 +190,7 @@ where
))); )));
let status_reporter_task = { let status_reporter_task = {
let metadata_case_status = metadata_case_status.clone(); let metadata_case_status = metadata_case_status.clone();
let start = Instant::now();
async move { async move {
const GREEN: &str = "\x1B[32m"; const GREEN: &str = "\x1B[32m";
const RED: &str = "\x1B[31m"; const RED: &str = "\x1B[31m";
@@ -281,8 +283,12 @@ where
tokio::time::sleep(std::time::Duration::from_secs(3)).await; tokio::time::sleep(std::time::Duration::from_secs(3)).await;
} }
let elapsed = start.elapsed();
eprintln!( eprintln!(
"{GREEN}{number_of_successes}{RESET} cases succeeded, {RED}{number_of_failures}{RESET} cases failed" "{GREEN}{}{RESET} cases succeeded, {RED}{}{RESET} cases failed in {} seconds",
number_of_successes,
number_of_failures,
elapsed.as_secs()
); );
} }
}; };
+2 -2
View File
@@ -599,7 +599,7 @@ impl<T: AsRef<str>> CalldataToken<T> {
Some(block_number) => *block_number, Some(block_number) => *block_number,
None => resolver.last_block_number().await?, None => resolver.last_block_number().await?,
}; };
let desired_block_number = current_block_number - offset; let desired_block_number = current_block_number.saturating_sub(offset);
let block_hash = resolver.block_hash(desired_block_number.into()).await?; let block_hash = resolver.block_hash(desired_block_number.into()).await?;
@@ -612,7 +612,7 @@ impl<T: AsRef<str>> CalldataToken<T> {
Ok(U256::from(current_block_number)) Ok(U256::from(current_block_number))
} else if item == Self::BLOCK_TIMESTAMP_VARIABLE { } else if item == Self::BLOCK_TIMESTAMP_VARIABLE {
resolver resolver
.block_timestamp(BlockNumberOrTag::Latest) .block_timestamp(context.resolve_block_number(BlockNumberOrTag::Latest))
.await .await
.map(U256::from) .map(U256::from)
} else if let Some(variable_name) = item.strip_prefix(Self::VARIABLE_PREFIX) { } else if let Some(variable_name) = item.strip_prefix(Self::VARIABLE_PREFIX) {
-2
View File
@@ -22,7 +22,6 @@ use alloy::{
Provider, ProviderBuilder, Provider, ProviderBuilder,
ext::DebugApi, ext::DebugApi,
fillers::{CachedNonceManager, ChainIdFiller, FillProvider, NonceFiller, TxFiller}, fillers::{CachedNonceManager, ChainIdFiller, FillProvider, NonceFiller, TxFiller},
layers::CacheLayer,
}, },
rpc::types::{ rpc::types::{
TransactionReceipt, TransactionRequest, TransactionReceipt, TransactionRequest,
@@ -258,7 +257,6 @@ impl GethNode {
.filler(FallbackGasFiller::new(500_000_000, 500_000_000, 1)) .filler(FallbackGasFiller::new(500_000_000, 500_000_000, 1))
.filler(ChainIdFiller::default()) .filler(ChainIdFiller::default())
.filler(NonceFiller::new(nonce_manager)) .filler(NonceFiller::new(nonce_manager))
.layer(CacheLayer::new(10_000))
.wallet(wallet) .wallet(wallet)
.connect(&connection_string) .connect(&connection_string)
.await .await
-2
View File
@@ -23,7 +23,6 @@ use alloy::{
Provider, ProviderBuilder, Provider, ProviderBuilder,
ext::DebugApi, ext::DebugApi,
fillers::{CachedNonceManager, ChainIdFiller, FillProvider, NonceFiller, TxFiller}, fillers::{CachedNonceManager, ChainIdFiller, FillProvider, NonceFiller, TxFiller},
layers::CacheLayer,
}, },
rpc::types::{ rpc::types::{
TransactionReceipt, TransactionReceipt,
@@ -373,7 +372,6 @@ impl KitchensinkNode {
)) ))
.filler(ChainIdFiller::default()) .filler(ChainIdFiller::default())
.filler(NonceFiller::new(nonce_manager)) .filler(NonceFiller::new(nonce_manager))
.layer(CacheLayer::new(10_000))
.wallet(wallet) .wallet(wallet)
.connect(&connection_string) .connect(&connection_string)
.await .await