Explicitly specify Latest block for RPC calls (#81)

Author: joaquim-verges

executors/src/eoa/worker/transaction.rs

@@ -4,6 +4,7 @@ use alloy::{
     consensus::{
         SignableTransaction, Signed, TxEip4844Variant, TxEip4844WithSidecar, TypedTransaction,
     },
+    eips::BlockNumberOrTag,
     network::{TransactionBuilder, TransactionBuilder7702},
     primitives::{Bytes, U256},
     providers::Provider,
@@ -20,11 +21,16 @@ use engine_core::{
 };
 
 use crate::eoa::{
+    EoaTransactionRequest,
     store::{
         BorrowedTransaction, BorrowedTransactionData, PendingTransaction, SubmittedNoopTransaction,
-    }, worker::{
-        error::{is_retryable_preparation_error, is_unsupported_eip1559_error, EoaExecutorWorkerError}, EoaExecutorWorker
-    }, EoaTransactionRequest
+    },
+    worker::{
+        EoaExecutorWorker,
+        error::{
+            EoaExecutorWorkerError, is_retryable_preparation_error, is_unsupported_eip1559_error,
+        },
+    },
 };
 
 // Retry constants for preparation phase
@@ -303,7 +309,13 @@ impl<C: Chain> EoaExecutorWorker<C> {
 
         // Estimate gas if needed
         if tx_request.gas.is_none() {
-            match self.chain.provider().estimate_gas(tx_request.clone()).await {
+            match self
+                .chain
+                .provider()
+                .estimate_gas(tx_request.clone())
+                .block(BlockNumberOrTag::Latest.into())
+                .await
+            {
                 Ok(gas_limit) => {
                     tx_request = tx_request.with_gas_limit(gas_limit * 110 / 100); // 10% buffer
                 }
@@ -397,10 +409,13 @@ impl<C: Chain> EoaExecutorWorker<C> {
         nonce: u64,
     ) -> Result<Signed<TypedTransaction>, EoaExecutorWorkerError> {
         let typed_tx = self.build_typed_transaction(request, nonce).await?;
-        
+
         // Inject KMS cache into the signing credential (after deserialization from Redis)
-        let credential_with_cache = request.signing_credential.clone().with_aws_kms_cache(&self.kms_client_cache);
-        
+        let credential_with_cache = request
+            .signing_credential
+            .clone()
+            .with_aws_kms_cache(&self.kms_client_cache);
+
         self.sign_transaction(typed_tx, &credential_with_cache)
             .await
     }

server/src/http/routes/contract_read.rs

@@ -454,7 +454,11 @@ async fn execute_direct_contract_calls<C: engine_core::chain::Chain>(
                     call_request = call_request.from(*from_address);
                 }
 
-                match provider.call(call_request).await {
+                match provider
+                    .call(call_request)
+                    .block(BlockNumberOrTag::Latest.into())
+                    .await
+                {
                     Ok(result) => {
                         // Decode the result
                         match prepared_call.function.abi_decode_output(&result) {
@@ -511,9 +515,13 @@ async fn execute_multicall(
         .to(*multicall_address)
         .input(multicall_call.abi_encode().into());
 
-    let result = provider.call(call_request).await.map_err(|e| {
-        EngineError::contract_multicall_error(chain_id, format!("Multicall failed: {e}"))
-    })?;
+    let result = provider
+        .call(call_request)
+        .block(BlockNumberOrTag::Latest.into())
+        .await
+        .map_err(|e| {
+            EngineError::contract_multicall_error(chain_id, format!("Multicall failed: {e}"))
+        })?;
 
     let decoded = aggregate3Call::abi_decode_returns(&result).map_err(|e| {
         EngineError::contract_multicall_error(