Optimize encodeEventTopics by precomputing event topics (#16)

* Initial plan

* Optimize encodeEventTopics by precomputing event topics

Co-authored-by: NicoSerranoP <38594836+NicoSerranoP@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: NicoSerranoP <38594836+NicoSerranoP@users.noreply.github.com>

Author: Copilot

gas-benchmarks/.env.example

@@ -1,3 +1,5 @@
 ETH_RPC_URL=https://mainnet.gateway.tenderly.co
 
 NUMBER_OF_TRANSACTIONS=100
+
+MAX_NUMBER_OF_RPC_TRIES=50

gas-benchmarks/src/railgun/constants.ts

@@ -6,7 +6,7 @@ import { NUMBER_OF_TRANSACTIONS } from "../utils/constants.js";
  * Maximum number of logs with a Shield event to be searched.
  * Depends on the ratio of how many AA txs - EOA txs
  */
-export const MAX_OF_LOGS = NUMBER_OF_TRANSACTIONS * 5;
+export const MAX_OF_LOGS = NUMBER_OF_TRANSACTIONS * 10;
 
 /**
  * Proxy contract that points to the RailgunSmartWallet contract:

gas-benchmarks/src/utils/constants.ts

@@ -6,7 +6,7 @@ export const ETH_RPC_URL = String(process.env.ETH_RPC_URL);
 
 export const BLOCK_RANGE = 1_000n;
 
-export const MAX_NUMBER_OF_RPC_TRIES = 10;
+export const MAX_NUMBER_OF_RPC_TRIES = Number(process.env.MAX_NUMBER_OF_RPC_TRIES);
 
 export const NUMBER_OF_TRANSACTIONS = Number(process.env.NUMBER_OF_TRANSACTIONS);
 

gas-benchmarks/src/utils/rpc.ts

@@ -19,10 +19,15 @@ export const publicClient = createPublicClient({
   chain: mainnet,
 });
 
-export const getEventLogs = async ({ contractAddress, event, maxLogs }: GetEventLogs): Promise<Log[]> => {
+export const getEventLogs = async ({
+  contractAddress,
+  event,
+  maxLogs,
+  fromBlock: initialFromBlock,
+}: GetEventLogs): Promise<Log[]> => {
   const latestBlock = await publicClient.getBlockNumber();
   let toBlock = latestBlock;
-  let fromBlock = getBlockInRange(toBlock);
+  let fromBlock = initialFromBlock ?? getBlockInRange(toBlock);
 
   let tries = 0;
   const logs: Log[] = [];
@@ -79,8 +84,10 @@ export const getUniqueLogs = (logs: Log[]): Log[] => {
 export const getTransactionsWithEvents = async (
   logs: Log[],
   events: readonly AbiEvent[],
-): Promise<TransactionReceipt[]> =>
-  logs.reduce<Promise<TransactionReceipt[]>>(async (accumulatorPromise, log) => {
+): Promise<TransactionReceipt[]> => {
+  const eventTopics = events.map((event) => encodeEventTopics({ abi: [event] })[0]);
+
+  return logs.reduce<Promise<TransactionReceipt[]>>(async (accumulatorPromise, log) => {
     const accumulator = await accumulatorPromise;
 
     if (accumulator.length >= NUMBER_OF_TRANSACTIONS) {
@@ -93,9 +100,8 @@ export const getTransactionsWithEvents = async (
       return accumulator;
     }
 
-    const hasAllEvents = events.every((event, index) => {
+    const hasAllEvents = eventTopics.every((eventTopic, index) => {
       const logTopic = receipt.logs[index]!.topics[0];
-      const eventTopic = encodeEventTopics({ abi: [event] })[0];
 
       return logTopic === eventTopic;
     });
@@ -108,3 +114,4 @@ export const getTransactionsWithEvents = async (
 
     return accumulator;
   }, Promise.resolve([]));
+};

gas-benchmarks/src/utils/types.ts

@@ -10,4 +10,5 @@ export interface GetEventLogs {
   contractAddress: Hex;
   event: AbiEvent;
   maxLogs: number;
+  fromBlock?: bigint;
 }