add logging

Author: dglowinski

src/api/routes/swap/swapRouter.ts

@@ -10,7 +10,12 @@ import {
 } from "@/common/utils/httpHandlers"
 import { findSwaps } from "@/swapService/runner"
 import type { SwapParams } from "@/swapService/types"
-import { ApiError, findToken, getSwapper } from "@/swapService/utils"
+import {
+  ApiError,
+  findToken,
+  getSwapper,
+  parseHrtimeToSeconds,
+} from "@/swapService/utils"
 import { StatusCodes } from "http-status-codes"
 import { InvalidAddressError } from "viem"
 import { z } from "zod"
@@ -66,7 +71,28 @@ swapRouter.get(
   validateRequest(getSwapSchema),
   async (req: Request, res: Response) => {
     try {
-      const swaps = await findSwaps(parseRequest(req))
+      const startTime = process.hrtime()
+      const swapParams = parseRequest(req)
+      const swaps = await findSwaps(swapParams)
+      const elapsedSeconds = parseHrtimeToSeconds(process.hrtime(startTime))
+      console.log("ROUTE EXECUTING")
+      if (elapsedSeconds > 10) {
+        console.log(
+          `SLOW ROUTE [10]: ${swapParams.swapperMode} ${elapsedSeconds}s`,
+        )
+      } else if (elapsedSeconds > 5) {
+        console.log(
+          `SLOW ROUTE [5]: ${swapParams.swapperMode} ${elapsedSeconds}s`,
+        )
+      } else if (elapsedSeconds > 3) {
+        console.log(
+          `SLOW ROUTE [3]: ${swapParams.swapperMode} ${elapsedSeconds}s`,
+        )
+      } else if (elapsedSeconds > 1) {
+        console.log(
+          `SLOW ROUTE [1]: ${swapParams.swapperMode} ${elapsedSeconds}s`,
+        )
+      }
       return handleServiceResponse(
         ServiceResponse.success<SwapResponse>(swaps),
         res,

src/swapService/strategies/balmySDK/customSourceList.ts

@@ -1,4 +1,5 @@
 import { LOG_SLOW_QUERY_TIMEOUT_SECONDS } from "@/swapService/config/constants"
+import { parseHrtimeToSeconds } from "@/swapService/utils"
 import type {
   IFetchService,
   IProviderService,
@@ -7,6 +8,7 @@ import type {
   SourceListQuoteResponse,
 } from "@balmy/sdk"
 import { LocalSourceList } from "@balmy/sdk/dist/services/quotes/source-lists/local-source-list"
+import { stringify } from "viem"
 import { CustomKyberswapQuoteSource } from "./sources/kyberswapQuoteSource"
 import { CustomLiFiQuoteSource } from "./sources/lifiQuoteSource"
 import { CustomMagpieQuoteSource } from "./sources/magpieQuoteSource"
@@ -107,13 +109,3 @@ export class CustomSourceList extends LocalSourceList {
     }
   }
 }
-
-function parseHrtimeToSeconds(hrtime: [number, number]) {
-  return Number((hrtime[0] + hrtime[1] / 1e9).toFixed(3))
-}
-
-function stringify(obj: object) {
-  return JSON.stringify(obj, (_, v) =>
-    typeof v === "bigint" ? v.toString() : v,
-  )
-}

src/swapService/utils.ts

@@ -583,3 +583,7 @@ export function promiseWithTimeout(fn: any, timeoutSeconds: number) {
     ),
   ])
 }
+
+export function parseHrtimeToSeconds(hrtime: [number, number]) {
+  return Number((hrtime[0] + hrtime[1] / 1e9).toFixed(3))
+}