cache bridgevolume query

Author: vrtnd

src/utils/bridgeVolume.ts

@@ -43,6 +43,13 @@ export const getDailyBridgeVolume = async (
   chain?: string,
   bridgeNetworkId?: number
 ) => {
+  const cacheKey = `daily_bridge_volume_${bridgeNetworkId ?? "all"}_${chain ?? "all"}_${startTimestamp ?? "default"}_${
+    endTimestamp ?? "default"
+  }`;
+  const cachedData = await getCache(cacheKey);
+  if (cachedData) {
+    return cachedData;
+  }
   let bridgeDbName = undefined as any;
   if (bridgeNetworkId) {
     const bridgeNetwork = importBridgeNetwork(undefined, bridgeNetworkId);
@@ -86,9 +93,6 @@ export const getDailyBridgeVolume = async (
     const { bridge_id, ts, total_deposited_usd, total_withdrawn_usd, total_deposit_txs, total_withdrawal_txs } =
       dailyData;
     if (isNaN(parseFloat(total_deposited_usd)) || !isFinite(parseFloat(total_deposited_usd))) {
-      console.error(
-        `Invalid deposited USD value for bridge_id ${bridge_id} at timestamp ${ts}: ${total_deposited_usd}`
-      );
       return;
     }
     const timestamp = convertToUnixTimestamp(ts);
@@ -101,7 +105,6 @@ export const getDailyBridgeVolume = async (
     historicalDailySums[timestamp].withdrawTxs =
       (historicalDailySums[timestamp].withdrawTxs ?? 0) + total_withdrawal_txs;
   });
-  // the deposits and withdrawals are swapped here
   sourceChainsHistoricalDailyData.map((dailyData) => {
     const { ts, total_deposited_usd, total_withdrawn_usd, total_deposit_txs, total_withdrawal_txs } = dailyData;
     const timestamp = convertToUnixTimestamp(ts);
@@ -121,6 +124,7 @@ export const getDailyBridgeVolume = async (
     };
   });
 
+  await setCache(cacheKey, dailyBridgeVolume, 3600);
   return dailyBridgeVolume;
 };
 

src/utils/wrappa/postgres/query.ts

@@ -1,5 +1,6 @@
 import bridgeNetworkData from "../../../data/bridgeNetworkData";
 import { querySql as sql } from "../../db";
+import { getCache, setCache } from "../../cache";
 
 interface IConfig {
   id: string;
@@ -244,11 +245,14 @@ const queryLargeTransactionsTimestampRange = async (
   startTimestamp: number,
   endTimestamp: number
 ) => {
+  const cacheKey = `largeTxs:${chain ?? "all"}:${startTimestamp}:${endTimestamp}`;
+  const cached = await getCache(cacheKey);
+  if (cached) return cached;
   let chainEqual = sql``;
   if (chain) {
     chainEqual = sql`WHERE chain = ${chain} OR destination_chain = ${chain}`;
   }
-  return await sql<ITransaction[]>`
+  const result = await sql<ITransaction[]>`
   SELECT transactions.id, transactions.bridge_id, transactions.ts, transactions.tx_block, transactions.tx_hash, transactions.tx_from, transactions.tx_to, transactions.token, transactions.amount, transactions.is_deposit, transactions.chain, large_transactions.usd_value
   FROM       bridges.transactions
   INNER JOIN bridges.large_transactions
@@ -265,6 +269,8 @@ const queryLargeTransactionsTimestampRange = async (
                     FROM   bridges.config ${chainEqual})
   ORDER BY   ts DESC
   `;
+  await setCache(cacheKey, result, 3600);
+  return result;
 };
 
 const queryTransactionsTimestampRangeByBridgeNetwork = async (