count getLogs

Author: vrtnd

src/adapters/interport-finance/processTransactionsCustom.ts

@@ -8,6 +8,7 @@ import { getProvider } from "@defillama/sdk/build/general";
 import { PromisePool } from "@supercharge/promise-pool";
 import { getConnection } from "../../helpers/solana";
 import web3, { Connection, PartiallyDecodedInstruction, PublicKey } from "@solana/web3.js";
+import { incrementGetLogsCount } from "../../utils/cache";
 
 const EventKeyTypes = {
     blockNumber: "number",
@@ -128,7 +129,7 @@ export const getTxDataFromEVMEventLogsCustom = async (
                             chain: overriddenChain,
                         })
                     ).output;
-                    //console.log(logs)
+                    incrementGetLogsCount(adapterName, overriddenChain);
                     break;
                 } catch (e) {
                     if (i >= 4) {

src/adapters/train/index.ts

@@ -5,6 +5,7 @@ import { EventData } from "../../utils/types";
 import { BigNumber } from "ethers";
 import { getLogs, GetLogsOptions } from "@defillama/sdk/build/util/logs";
 import { getTxDataFromEVMEventLogs } from "../../helpers/processTransactions";
+import { incrementGetLogsCount } from "../../utils/cache";
 
 const contractsByChain: Record<string, string[]> = {
   ethereum: ["0x7E6f983f93fd12114DaFE0C69d1e55023EE0abCB"],
@@ -44,6 +45,7 @@ const constructParams = (chain: string) => {
               entireLog: true,
             };
             const logs = await getLogs(options);
+            incrementGetLogsCount("train", chain);
             return logs;
           })
         );
@@ -76,6 +78,7 @@ const constructParams = (chain: string) => {
               entireLog: true,
             };
             const logs = await getLogs(options);
+            incrementGetLogsCount("train", chain);
             return logs;
           })
         );
@@ -109,6 +112,7 @@ const constructParams = (chain: string) => {
               entireLog: true,
             };
             const logs = await getLogs(options);
+            incrementGetLogsCount("train", chain);
             return logs;
           })
         );

src/helpers/processTransactions.ts

@@ -6,6 +6,7 @@ import { ContractEventParams, PartialContractEventParams } from "../helpers/brid
 import { EventData } from "../utils/types";
 import { PromisePool } from "@supercharge/promise-pool";
 import { getProvider } from "../utils/provider";
+import { incrementGetLogsCount } from "../utils/cache";
 
 const EventKeyTypes = {
   blockNumber: "number",
@@ -125,6 +126,7 @@ export const getTxDataFromEVMEventLogs = async (
       let logs = [] as any[];
       for (let i = 0; i < 5; i++) {
         try {
+          incrementGetLogsCount(adapterName, overriddenChain);
           logs = (
             await getLogs({
               target: target!,
@@ -136,7 +138,6 @@ export const getTxDataFromEVMEventLogs = async (
               chain: overriddenChain,
             })
           ).output;
-          //console.log(logs)
           break;
         } catch (e) {
           if (i >= 4) {

src/server/cron.ts

@@ -17,6 +17,7 @@ import runHyperlane from "../handlers/runHyperlane";
 import runTeleswap from "../handlers/runTeleswap";
 import { handler as runRelay } from "../handlers/runRelay";
 import { handler as runCashmere } from "../handlers/runCashmere";
+import { getAllGetLogsCounts } from "../utils/cache";
 
 const createTimeout = (minutes: number) =>
   new Promise((_, reject) =>
@@ -40,9 +41,20 @@ const withTimeout = async (jobName: string, promise: Promise<any>, timeoutMinute
   }
 };
 
+const printGetLogsSummary = async () => {
+  const counts = await getAllGetLogsCounts();
+  const sorted = Object.entries(counts).sort((a, b) => b[1] - a[1]);
+  console.log("[GETLOGS SUMMARY] Top callers today:");
+  for (const [key, count] of sorted.slice(0, 30)) {
+    console.log(`  ${key}: ${count} calls`);
+  }
+  console.log(`[GETLOGS SUMMARY] Total unique adapter:chain combinations: ${sorted.length}`);
+};
+
 const exit = () => {
   setTimeout(async () => {
     console.log("[INFO] Timeout! Shutting down. Bye bye!");
+    await printGetLogsSummary();
     await sql.end();
     await querySql.end();
     process.exit(0);

src/utils/cache.ts

@@ -112,3 +112,35 @@ export const deleteCache = async (key: string): Promise<void> => {
     console.error(`[CACHE] deleteCache error for ${key}:`, e);
   }
 };
+
+const GETLOGS_COUNT_TTL = 60 * 60 * 24 * 7;
+
+export const incrementGetLogsCount = async (adapterName: string, chain: string): Promise<void> => {
+  if (!redis) return;
+  try {
+    const today = new Date().toISOString().split("T")[0];
+    const key = `getlogs_count:${today}:${adapterName.toLowerCase()}:${chain.toLowerCase()}`;
+    await redis.incr(key);
+    await redis.expire(key, GETLOGS_COUNT_TTL);
+  } catch (e) {}
+};
+
+export const getAllGetLogsCounts = async (): Promise<Record<string, number>> => {
+  if (!redis) return {};
+  try {
+    const today = new Date().toISOString().split("T")[0];
+    const keys = await redis.keys(`getlogs_count:${today}:*`);
+    if (keys.length === 0) return {};
+
+    const counts: Record<string, number> = {};
+    for (const key of keys) {
+      const val = await redis.get(key);
+      const parts = key.replace(`getlogs_count:${today}:`, "");
+      counts[parts] = parseInt(val || "0", 10);
+    }
+    return counts;
+  } catch (e) {
+    console.error("[CACHE] getAllGetLogsCounts error:", e);
+    return {};
+  }
+};