feat: include support for metrics

package.json

@@ -69,13 +69,15 @@
     "express": "^4.17.1",
     "express-fileupload": "^1.4.0",
     "express-openapi-validator": "^5.0.4",
+    "express-prom-bundle": "^7.0.0",
     "express-session": "^1.17.1",
     "http-status-codes": "^2.1.4",
     "ipfs-http-client": "^56.0.3",
     "ipfs-http-gateway": "0.9.3",
     "json-refs": "^3.0.15",
     "memorystore": "^1.6.7",
     "node-fetch": "2.6.6",
+    "prom-client": "^15.1.0",
     "puppeteer": "^20.7.4",
     "serve-index": "^1.9.1",
     "solc": "^0.8.17",
@@ -131,4 +133,4 @@
       "text-summary"
     ]
   }
-}
+}

src/server/server.ts

@@ -28,6 +28,12 @@ import { initDeprecatedRoutes } from "./deprecated.routes";
 import { getAddress } from "ethers";
 import { logger } from "../common/loggerLoki";
 import { setLibSourcifyLogger } from "@ethereum-sourcify/lib-sourcify";
+
+import promBundle from "express-prom-bundle";
+import { SourcifyEventManager } from "../common/SourcifyEventManager/SourcifyEventManager";
+
+import client from "prom-client";
+
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const fileUpload = require("express-fileupload");
 
@@ -175,6 +181,35 @@ export class Server {
       next();
     });
 
+    // Add the options to the prometheus middleware most option are for http_request_duration_seconds histogram metric
+    const metricsMiddleware = promBundle({
+      includeMethod: true,
+      includePath: true,
+      includeStatusCode: true,
+      includeUp: true,
+      httpDurationMetricName: "sourcify_http_request_duration_seconds",
+      promClient: {
+        collectDefaultMetrics: {
+          prefix: "sourcify_",
+        }
+      }
+    });
+    // add the prometheus middleware to all routes
+    this.app.use(metricsMiddleware);
+
+    const counter = new client.Counter({
+      name: "sourcify_event_count",
+      help: "events that happened during verification labeled with: event and chainId",
+      labelNames: ["event", "chainId"],
+    });
+
+    SourcifyEventManager.on("*", [
+      (event: string, argument: any) => {
+        const chainId = argument.chainId;
+        counter.labels({ event, chainId }).inc(1);
+      },
+    ]);
+
     // Session API endpoints require non "*" origins because of the session cookies
     const sessionPaths = [
       "/session", // all paths /session/verify /session/input-files etc.