Revert "Close connections"

This reverts commit a370dc5.

src/handlers/dailyAggregateAllAdapters.ts

@@ -2,7 +2,6 @@ import { wrapScheduledLambda } from "../utils/wrap";
 import { convertToUnixTimestamp } from "../utils/date";
 import { runAggregateDataHistorical } from "../utils/aggregate";
 import bridgeNetworkData from "../data/bridgeNetworkData";
-import { sql } from "../utils/db";
 
 export default wrapScheduledLambda(async (_event) => {
   const currentDate = new Date();
@@ -20,9 +19,4 @@ export default wrapScheduledLambda(async (_event) => {
   for (const adapter of bridgeNetworkData) {
     await runAggregateDataHistorical(startTimestamp, endTimestamp, adapter.id, false);
   }
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
 });

src/handlers/getBridge.ts

@@ -6,7 +6,6 @@ import getAggregatedDataClosestToTimestamp from "../utils/getRecordClosestToTime
 import { importBridgeNetwork } from "../data/importBridgeNetwork";
 import { normalizeChain } from "../utils/normalizeChain";
 import { getLast24HVolume } from "../utils/wrappa/postgres/query";
-import { sql } from "../utils/db";
 
 const getBridge = async (bridgeNetworkId?: number) => {
   const bridgeNetwork = importBridgeNetwork(undefined, bridgeNetworkId);
@@ -161,11 +160,6 @@ const getBridge = async (bridgeNetworkId?: number) => {
 const handler = async (event: AWSLambda.APIGatewayEvent): Promise<IResponse> => {
   const bridgeNetworkId = parseInt(event.pathParameters?.id ?? "0");
   const response = await getBridge(bridgeNetworkId);
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(response, 10 * 60); // 10 mins cache
 };
 

src/handlers/getBridgeChains.ts

@@ -5,7 +5,6 @@ import { getChainDisplayName, chainCoingeckoIds } from "../utils/normalizeChain"
 import { getCurrentUnixTimestamp, secondsInDay } from "../utils/date";
 import bridgeNetworks from "../data/bridgeNetworkData";
 import { normalizeChain } from "../utils/normalizeChain";
-import { sql } from "../utils/db";
 
 export async function craftBridgeChainsResponse() {
   const chainsSet = new Set<string>();
@@ -52,11 +51,6 @@ export async function craftBridgeChainsResponse() {
 
 const handler = async (_event: AWSLambda.APIGatewayEvent): Promise<IResponse> => {
   const chainData = await craftBridgeChainsResponse();
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(chainData, 10 * 60); // 10 mins cache
 };
 

src/handlers/getBridgeVolume.ts

@@ -4,7 +4,6 @@ import { getDailyBridgeVolume, getHourlyBridgeVolume } from "../utils/bridgeVolu
 import { importBridgeNetwork } from "../data/importBridgeNetwork";
 import { secondsInDay, getCurrentUnixTimestamp } from "../utils/date";
 import { normalizeChain } from "../utils/normalizeChain";
-import { sql } from "../utils/db";
 
 const getBridgeVolume = async (chain?: string, bridgeNetworkId?: string) => {
   if (!chain) {
@@ -14,10 +13,11 @@ const getBridgeVolume = async (chain?: string, bridgeNetworkId?: string) => {
   }
   let bridgeNetwork;
   if (bridgeNetworkId) {
-    bridgeNetwork = importBridgeNetwork(undefined, parseInt(bridgeNetworkId));
+
+      bridgeNetwork = importBridgeNetwork(undefined, parseInt(bridgeNetworkId));
   }
   const destinationChain = bridgeNetwork?.destinationChain;
-  if (destinationChain && chain === destinationChain?.toLowerCase()) {
+  if (destinationChain && chain === destinationChain?.toLowerCase()){
     chain = "all";
   }
   const queryChain = chain === "all" ? undefined : normalizeChain(chain);
@@ -95,11 +95,6 @@ const handler = async (event: AWSLambda.APIGatewayEvent): Promise<IResponse> =>
   const chain = event.pathParameters?.chain?.toLowerCase().replace(/%20/g, " ");
   const bridgeNetworkId = event.queryStringParameters?.id;
   const response = await getBridgeVolume(chain, bridgeNetworkId);
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(response, 10 * 60); // 10 mins cache
 };
 

src/handlers/getBridges.ts

@@ -7,7 +7,6 @@ import getAggregatedDataClosestToTimestamp from "../utils/getRecordClosestToTime
 import bridgeNetworks from "../data/bridgeNetworkData";
 import { normalizeChain } from "../utils/normalizeChain";
 import { getLast24HVolume } from "../utils/wrappa/postgres/query";
-import { sql } from "../utils/db";
 
 const getBridges = async () => {
   const response = (
@@ -127,11 +126,6 @@ const handler = async (event: AWSLambda.APIGatewayEvent): Promise<IResponse> =>
     const chainData = await craftBridgeChainsResponse();
     response.chains = chainData;
   }
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(response, 10 * 60); // 10 mins cache
 };
 

src/handlers/getLargeTransactions.ts

@@ -6,7 +6,6 @@ import { getLlamaPrices } from "../utils/prices";
 import { transformTokens } from "../helpers/tokenMappings";
 import { importBridgeNetwork } from "../data/importBridgeNetwork";
 import { normalizeChain } from "../utils/normalizeChain";
-import { sql } from "../utils/db";
 
 const getLargeTransactions = async (
   chain: string = "all",
@@ -72,11 +71,6 @@ const handler = async (event: AWSLambda.APIGatewayEvent): Promise<IResponse> =>
   const startTimestamp = event.queryStringParameters?.starttimestamp;
   const endTimestamp = event.queryStringParameters?.endtimestamp;
   const response = await getLargeTransactions(chain, startTimestamp, endTimestamp);
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(response, 10 * 60); // 10 mins cache
 };
 

src/handlers/getLastBlocks.ts

@@ -1,4 +1,6 @@
 import wrap, { wrapScheduledLambda } from "../utils/wrap";
+import bridgeNetworks from "../data/bridgeNetworkData";
+import { runAdapterToCurrentBlock } from "../utils/adapter";
 import { sql } from "../utils/db";
 import { successResponse } from "../utils/lambda-response";
 
@@ -24,11 +26,6 @@ const handler = async () => {
     acc[`${bridgeConfigById[bridgeId].bridge_name}-${bridgeConfigById[bridgeId].chain}`] = lastRecordedBlocks[bridgeId];
     return acc;
   }, {});
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(lastBlocksByName);
 };
 

src/handlers/getTransactions.ts

@@ -3,7 +3,6 @@ import wrap from "../utils/wrap";
 import { queryTransactionsTimestampRangeByBridgeNetwork } from "../utils/wrappa/postgres/query";
 import { importBridgeNetwork } from "../data/importBridgeNetwork";
 import { normalizeChain } from "../utils/normalizeChain";
-import { sql } from "../utils/db";
 
 const maxResponseTxs = 6000; // maximum number of transactions to return
 
@@ -87,11 +86,6 @@ const handler = async (event: AWSLambda.APIGatewayEvent): Promise<IResponse> =>
   const address = event.queryStringParameters?.address?.toLowerCase();
   const limit = event.queryStringParameters?.limit;
   const response = await getTransactions(startTimestamp, endTimestamp, id, chain, sourceChain, address, limit);
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
   return successResponse(response, 10 * 60); // 10 mins cache
 };
 

src/handlers/runAggregateAllAdapters.ts

@@ -1,7 +1,6 @@
 import { wrapScheduledLambda } from "../utils/wrap";
 import { convertToUnixTimestamp } from "../utils/date";
 import { runAggregateDataAllAdapters } from "../utils/aggregate";
-import { sql } from "../utils/db";
 
 export default wrapScheduledLambda(async (_event) => {
   const currentDate = new Date();
@@ -11,9 +10,4 @@ export default wrapScheduledLambda(async (_event) => {
   if (currentHour === 0) {
     await runAggregateDataAllAdapters(currentTimestamp, false);
   }
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
 });

src/handlers/runAllAdapters.ts

@@ -77,9 +77,4 @@ export default wrapScheduledLambda(async (event) => {
       lastRecordedBlocks: lastRecordedBlocks[0].result,
     });
   }
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
 });

src/handlers/runAllAdaptersHistorical.ts

@@ -1,7 +1,6 @@
 import { wrapScheduledLambda } from "../utils/wrap";
 import bridgeNetworks from "../data/bridgeNetworkData";
 import { LambdaClient, InvokeCommand } from "@aws-sdk/client-lambda";
-import { sql } from "../utils/db";
 
 const lambdaClient = new LambdaClient({});
 
@@ -43,11 +42,6 @@ const handler = async (_event: any) => {
   }
 
   console.log("Initiated historical runs for all adapters");
-  try {
-    await sql.end();
-  } catch (e) {
-    console.error(e);
-  }
 };
 
 export default wrapScheduledLambda(handler);