chore: Reduce RPC calls for EVM by using eth_getLogs (#221)

* test: Add tests

* docs: Update documentation

* docs: Update docs

* docs: Update docs

* chore: Use transaction's transaction_index

* chore: Remove unused From implementation

Author: shahnami

docs/modules/ROOT/pages/rpc.adoc

@@ -250,7 +250,8 @@ graph TD
         B[Network Init] -->|net_version| D
         D -->|eth_blockNumber| E[For every block in range]
         E -->|eth_getBlockByNumber| G1[Process Block]
-        G1 -->|For every transaction| J[Get Transaction Receipt]
+        G1 -->|eth_getLogs| H[Get Block Logs]
+        H -->|Only when needed| J[Get Transaction Receipt]
         J -->|eth_getTransactionReceipt| I[Complete]
     end
 
@@ -275,7 +276,10 @@ graph TD
 * RPC Client initialization (per active network): `net_version`
 * Fetching the latest block number (per cron iteration): `eth_blockNumber`
 * Fetching block data (per block): `eth_getBlockByNumber`
-* Fetching transaction receipt (per transaction in block): `eth_getTransactionReceipt`
+* Fetching block logs (per block): `eth_getLogs`
+* Fetching transaction receipt (only when needed):
+** When monitor condition requires receipt-specific fields (e.g., `gas_used`)
+** When monitoring transaction status and no logs are present to validate status
 
 *Stellar*
 

docs/modules/ROOT/pages/scripts.adoc

@@ -120,6 +120,23 @@ Custom filter scripts allow you to apply additional conditions to matches detect
         "transactionIndex": "0x1fc",
         "type": "0x2"
       },
+      "logs": [
+         {
+            "address": "0xd1f2586790a5bd6da1e443441df53af6ec213d83",
+            "topics": [
+                "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef",
+                "0x00000000000000000000000060af8cf92e5aa9ead4a592d657cd6debecfbc616",
+                "0x000000000000000000000000d1f2586790a5bd6da1e443441df53af6ec213d83"
+            ],
+            "data": "0x00000000000000000000000000000000000000000000106015728793d21f77ac",
+            "blockNumber": "0x1451aca",
+            "transactionHash": "0xa39d1b9b3edda74414bd6ffaf6596f8ea12cf0012fd9a930f71ed69df6ff34d0",
+            "transactionIndex": "0x0",
+            "blockHash": "0x9432868b7fc57e85f0435ca3047f6a76add86f804b3c1af85647520061e30f80",
+            "logIndex": "0x2",
+            "removed": false
+          },
+      ],
       "transaction": {
         "accessList": [],
         "blockHash": "0x...",

src/bootstrap/mod.rs

@@ -521,16 +521,14 @@ mod tests {
 	use super::*;
 	use crate::{
 		models::{
-			EVMMonitorMatch, EVMTransaction, EVMTransactionReceipt, MatchConditions, Monitor,
-			MonitorMatch, ScriptLanguage, StellarBlock, StellarMonitorMatch, StellarTransaction,
-			StellarTransactionInfo, TriggerConditions,
+			EVMMonitorMatch, EVMReceiptLog, EVMTransaction, EVMTransactionReceipt, MatchConditions,
+			Monitor, MonitorMatch, ScriptLanguage, StellarBlock, StellarMonitorMatch,
+			StellarTransaction, StellarTransactionInfo, TriggerConditions,
 		},
-		utils::tests::builders::evm::monitor::MonitorBuilder,
+		utils::tests::{builders::evm::monitor::MonitorBuilder, evm::receipt::ReceiptBuilder},
 	};
 	use alloy::{
-		consensus::{
-			transaction::Recovered, Receipt, ReceiptEnvelope, ReceiptWithBloom, Signed, TxEnvelope,
-		},
+		consensus::{transaction::Recovered, Signed, TxEnvelope},
 		primitives::{Address, Bytes, TxKind, B256, U256},
 	};
 	use std::io::Write;
@@ -561,23 +559,11 @@ mod tests {
 	}
 
 	fn create_test_evm_transaction_receipt() -> EVMTransactionReceipt {
-		EVMTransactionReceipt::from(alloy::rpc::types::TransactionReceipt {
-			inner: ReceiptEnvelope::Legacy(ReceiptWithBloom {
-				receipt: Receipt::default(),
-				logs_bloom: Default::default(),
-			}),
-			transaction_hash: B256::ZERO,
-			transaction_index: Some(0),
-			block_hash: Some(B256::ZERO),
-			block_number: Some(0),
-			gas_used: 0,
-			effective_gas_price: 0,
-			blob_gas_used: None,
-			blob_gas_price: None,
-			from: Address::ZERO,
-			to: Some(Address::ZERO),
-			contract_address: None,
-		})
+		ReceiptBuilder::new().build()
+	}
+
+	fn create_test_evm_logs() -> Vec<EVMReceiptLog> {
+		ReceiptBuilder::new().build().logs.clone()
 	}
 
 	fn create_test_evm_transaction() -> EVMTransaction {
@@ -628,7 +614,8 @@ mod tests {
 			BlockChainType::EVM => MonitorMatch::EVM(Box::new(EVMMonitorMatch {
 				monitor: create_test_monitor("test", vec![], false, script_path),
 				transaction: create_test_evm_transaction(),
-				receipt: create_test_evm_transaction_receipt(),
+				receipt: Some(create_test_evm_transaction_receipt()),
+				logs: Some(create_test_evm_logs()),
 				network_slug: "ethereum_mainnet".to_string(),
 				matched_on: MatchConditions {
 					functions: vec![],
@@ -662,7 +649,8 @@ mod tests {
 			BlockChainType::EVM => MonitorMatch::EVM(Box::new(EVMMonitorMatch {
 				monitor,
 				transaction: create_test_evm_transaction(),
-				receipt: create_test_evm_transaction_receipt(),
+				receipt: Some(create_test_evm_transaction_receipt()),
+				logs: Some(create_test_evm_logs()),
 				network_slug: "ethereum_mainnet".to_string(),
 				matched_on: MatchConditions {
 					functions: vec![],

src/models/blockchain/evm/monitor.rs

@@ -1,4 +1,6 @@
-use crate::models::{EVMTransaction, EVMTransactionReceipt, MatchConditions, Monitor};
+use crate::models::{
+	EVMReceiptLog, EVMTransaction, EVMTransactionReceipt, MatchConditions, Monitor,
+};
 use serde::{Deserialize, Serialize};
 
 /// Result of a successful monitor match on an EVM chain
@@ -11,7 +13,10 @@ pub struct EVMMonitorMatch {
 	pub transaction: EVMTransaction,
 
 	/// Transaction receipt with execution results
-	pub receipt: EVMTransactionReceipt,
+	pub receipt: Option<EVMTransactionReceipt>,
+
+	/// Transaction logs
+	pub logs: Option<Vec<EVMReceiptLog>>,
 
 	/// Network slug that the transaction was sent from
 	pub network_slug: String,
@@ -180,7 +185,8 @@ mod tests {
 		let monitor_match = EVMMonitorMatch {
 			monitor: monitor.clone(),
 			transaction: transaction.clone(),
-			receipt: receipt.clone(),
+			receipt: Some(receipt.clone()),
+			logs: Some(receipt.logs.clone()),
 			network_slug: "ethereum_mainnet".to_string(),
 			matched_on: MatchConditions {
 				functions: vec![FunctionCondition {
@@ -198,7 +204,10 @@ mod tests {
 
 		assert_eq!(monitor_match.monitor.name, "TestMonitor");
 		assert_eq!(monitor_match.transaction.hash, B256::with_last_byte(1));
-		assert_eq!(monitor_match.receipt.status, Some(U64::from(1)));
+		assert_eq!(
+			monitor_match.receipt.as_ref().unwrap().status,
+			Some(U64::from(1))
+		);
 		assert_eq!(monitor_match.network_slug, "ethereum_mainnet");
 		assert_eq!(monitor_match.matched_on.functions.len(), 1);
 		assert_eq!(

src/services/blockchain/clients/evm/client.rs

@@ -83,13 +83,14 @@ pub trait EvmClientTrait {
 	/// # Arguments
 	/// * `from_block` - Starting block number
 	/// * `to_block` - Ending block number
-	///
+	/// * `addresses` - Optional list of addresses to filter logs by
 	/// # Returns
 	/// * `Result<Vec<Log>, anyhow::Error>` - Collection of matching logs or error
 	async fn get_logs_for_blocks(
 		&self,
 		from_block: u64,
 		to_block: u64,
+		addresses: Option<Vec<String>>,
 	) -> Result<Vec<EVMReceiptLog>, anyhow::Error>;
 }
 
@@ -137,19 +138,21 @@ impl<T: Send + Sync + Clone + BlockchainTransport> EvmClientTrait for EvmClient<
 	/// # Arguments
 	/// * `from_block` - Starting block number
 	/// * `to_block` - Ending block number
-	///
+	/// * `addresses` - Optional list of addresses to filter logs by
 	/// # Returns
 	/// * `Result<Vec<EVMReceiptLog>, anyhow::Error>` - Collection of matching logs or error
 	#[instrument(skip(self), fields(from_block, to_block))]
 	async fn get_logs_for_blocks(
 		&self,
 		from_block: u64,
 		to_block: u64,
+		addresses: Option<Vec<String>>,
 	) -> Result<Vec<EVMReceiptLog>, anyhow::Error> {
 		// Convert parameters to JSON-RPC format
 		let params = json!([{
 			"fromBlock": format!("0x{:x}", from_block),
-			"toBlock": format!("0x{:x}", to_block)
+			"toBlock": format!("0x{:x}", to_block),
+			"address": addresses
 		}])
 		.as_array()
 		.with_context(|| "Failed to create JSON-RPC params array")?