Add requestLogger middleware

src/config.ts

@@ -66,6 +66,7 @@ type Config = {
   adaptiveRejection: boolean
   filterDeadNodesFromArchiver: boolean
   verbose: boolean
+  enableRequestLogger: boolean
   firstLineLogs: boolean
   verboseRequestWithRetry: boolean
   verboseAALG: boolean
@@ -165,6 +166,7 @@ export const CONFIG: Config = {
   adaptiveRejection: true,
   filterDeadNodesFromArchiver: false,
   verbose: false,
+  enableRequestLogger: true,
   verboseRequestWithRetry: false,
   verboseAALG: false,
   firstLineLogs: true, // default is true and turn off for prod for perf

src/middlewares/requestLogger.ts

@@ -0,0 +1,86 @@
+import { Request, Response, NextFunction } from 'express'
+import { CONFIG as config } from '../config'
+
+const requestLogger = (req: Request, res: Response, next: NextFunction): void => {
+  if (config.enableRequestLogger) {
+    const reqTime = Date.now()
+    const senderIp = req.ip
+    const userAgent = req.headers['user-agent'] || 'Unknown'
+
+    const responseChunks: Buffer[] = []
+
+    const originalWrite = res.write.bind(res)
+    res.write = function (
+      chunk: any,
+      encodingOrCallback?: BufferEncoding | ((error: Error | null | undefined) => void),
+      callback?: (error: Error | null | undefined) => void
+    ) {
+      responseChunks.push(Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk))
+
+      if (typeof encodingOrCallback === 'function') {
+        return originalWrite(chunk, encodingOrCallback)
+      } else {
+        return originalWrite(chunk, encodingOrCallback as BufferEncoding, callback)
+      }
+    }
+
+    const originalEnd = res.end.bind(res)
+    res.end = function (chunk?: any, ...args: any[]) {
+      const responseBody = Buffer.concat(responseChunks).toString('utf8')
+      res.locals.responseBody = responseBody
+      return originalEnd(chunk, ...args)
+    }
+
+    const originalJson = res.json.bind(res)
+    res.json = function (body) {
+      res.locals.responseBody = body
+      return originalJson(body)
+    }
+
+    const originalSend = res.send.bind(res)
+    res.send = function (body) {
+      res.locals.responseBody = body
+      return originalSend(body)
+    }
+
+    res.on('finish', () => {
+      const resTime = Date.now()
+
+      console.log(
+        `Request URL: ${req.originalUrl} ||` +
+          ` Response Status Code: ${res.statusCode} ||` +
+          ` Sender IP: ${senderIp} ||` +
+          ` Request Timestamp: ${new Date(reqTime).toISOString()} ||` +
+          ` Response Timestamp: ${new Date(resTime).toISOString()} ||` +
+          ` Request Method: ${req.method} ||` +
+          ` Response Time: ${resTime - reqTime}ms ||` +
+          ` User Agent: ${userAgent}`
+      )
+
+      const responseBody = res.locals.responseBody
+      if (res.statusCode !== 200) {
+        console.log(
+          `Request Failed with ${res.statusCode} ||` +
+            `Request Body: ${JSON.stringify(req.body)} ||` +
+            ` Response Body: ${res.locals.responseBody}`
+        )
+      } else if (responseBody) {
+        try {
+          const parsedBody = JSON.parse(responseBody)
+          if (parsedBody && 'error' in parsedBody) {
+            console.log(
+              `RPC Request Failed with Error ||` +
+                ` Request Body: ${JSON.stringify(req.body)} ||` +
+                ` Response Body: ${res.locals.responseBody}`
+            )
+          }
+        } catch (e) {
+          // Silently fail if parsing fails, no logging here
+        }
+      }
+    })
+  }
+  next()
+}
+
+export default requestLogger

src/server.ts

@@ -35,6 +35,7 @@ import { nestedCountersInstance } from './utils/nestedCounters'
 import { methodWhitelist } from './middlewares/methodWhitelist'
 import { isDebugModeMiddlewareLow, rateLimitedDebugAuth } from './middlewares/debugMiddleware'
 import { isIPv4 } from 'net'; 
+import requestLogger from './middlewares/requestLogger'
 
 setDefaultResultOrder('ipv4first')
 
@@ -90,6 +91,7 @@ app.set('trust proxy', false)
 app.use(cors({ methods: ['POST'] }))
 app.use(express.json())
 app.use(cookieParser())
+app.use(requestLogger)
 app.use(function (req, res, next) {
   res.setHeader('X-Content-Type-Options', 'nosniff')
   res.setHeader(