fix: add metrics

Author: naman22a

apps/auth-service/src/main.ts

@@ -3,6 +3,8 @@ import { AppModule } from './app.module';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { ConfigService } from '@nestjs/config';
 import { Configuration } from '@leetcode/config';
+import { startMetricsServer } from './metrics-server';
+import { register } from 'prom-client';
 
 async function bootstrap() {
     const appContext = await NestFactory.createApplicationContext(AppModule);
@@ -15,6 +17,9 @@ async function bootstrap() {
             port: configService.get('auth_service_port'),
         },
     });
+
+    startMetricsServer(register, configService.get('auth_service_port')!);
+
     await app.listen();
 }
 bootstrap();

apps/auth-service/src/metrics-server.ts

@@ -0,0 +1,15 @@
+import express from 'express';
+import { Registry } from 'prom-client';
+
+export function startMetricsServer(registry: Registry, port: number) {
+    const app = express();
+
+    app.get('/metrics', async (_req, res) => {
+        res.set('Content-Type', registry.contentType);
+        res.send(await registry.metrics());
+    });
+
+    app.listen(port, () => {
+        console.log(`Prometheus metrics on port ${port}/metrics`);
+    });
+}

apps/companies-service/src/main.ts

@@ -3,6 +3,8 @@ import { AppModule } from './app.module';
 import { ConfigService } from '@nestjs/config';
 import { Configuration } from '@leetcode/config';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
+import { register } from 'prom-client';
+import { startMetricsServer } from './metrics-server';
 
 async function bootstrap() {
     const appContext = await NestFactory.createApplicationContext(AppModule);
@@ -15,6 +17,9 @@ async function bootstrap() {
             port: configService.get('companies_service_port'),
         },
     });
+
+    startMetricsServer(register, configService.get('companies_service_port')!);
+
     await app.listen();
 }
 bootstrap();

apps/companies-service/src/metrics-server.ts

@@ -0,0 +1,15 @@
+import express from 'express';
+import { Registry } from 'prom-client';
+
+export function startMetricsServer(registry: Registry, port: number) {
+    const app = express();
+
+    app.get('/metrics', async (_req, res) => {
+        res.set('Content-Type', registry.contentType);
+        res.send(await registry.metrics());
+    });
+
+    app.listen(port, () => {
+        console.log(`Prometheus metrics on port ${port}/metrics`);
+    });
+}

apps/execution-service/src/main.ts

@@ -3,6 +3,8 @@ import { AppModule } from './app.module';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { ConfigService } from '@nestjs/config';
 import { Configuration } from '@leetcode/config';
+import { register } from 'prom-client';
+import { startMetricsServer } from './metrics-server';
 
 async function bootstrap() {
     const appContext = await NestFactory.createApplicationContext(AppModule);
@@ -15,6 +17,9 @@ async function bootstrap() {
             port: configService.get('execution_service_port'),
         },
     });
+
+    startMetricsServer(register, configService.get('execution_service_port')!);
+
     await app.listen();
 }
 bootstrap();

apps/execution-service/src/metrics-server.ts

@@ -0,0 +1,15 @@
+import express from 'express';
+import { Registry } from 'prom-client';
+
+export function startMetricsServer(registry: Registry, port: number) {
+    const app = express();
+
+    app.get('/metrics', async (_req, res) => {
+        res.set('Content-Type', registry.contentType);
+        res.send(await registry.metrics());
+    });
+
+    app.listen(port, () => {
+        console.log(`Prometheus metrics on port ${port}/metrics`);
+    });
+}

apps/problems-service/src/main.ts

@@ -3,6 +3,8 @@ import { AppModule } from './app.module';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { ConfigService } from '@nestjs/config';
 import { Configuration } from '@leetcode/config';
+import { startMetricsServer } from './metrics-server';
+import { register } from 'prom-client';
 
 async function bootstrap() {
     const appContext = await NestFactory.createApplicationContext(AppModule);
@@ -15,6 +17,7 @@ async function bootstrap() {
             port: configService.get('problems_service_port'),
         },
     });
+    startMetricsServer(register, configService.get('problems_service_port')!);
     await app.listen();
 }
 bootstrap();

apps/problems-service/src/metrics-server.ts

@@ -0,0 +1,15 @@
+import express from 'express';
+import { Registry } from 'prom-client';
+
+export function startMetricsServer(registry: Registry, port: number) {
+    const app = express();
+
+    app.get('/metrics', async (_req, res) => {
+        res.set('Content-Type', registry.contentType);
+        res.send(await registry.metrics());
+    });
+
+    app.listen(port, () => {
+        console.log(`Prometheus metrics on port ${port}/metrics`);
+    });
+}

apps/submissions-service/src/main.ts

@@ -3,6 +3,8 @@ import { AppModule } from './app.module';
 import { MicroserviceOptions, Transport } from '@nestjs/microservices';
 import { ConfigService } from '@nestjs/config';
 import { Configuration } from '@leetcode/config';
+import { register } from 'prom-client';
+import { startMetricsServer } from './metrics-server';
 
 async function bootstrap() {
     const appContext = await NestFactory.createApplicationContext(AppModule);
@@ -15,6 +17,7 @@ async function bootstrap() {
             port: configService.get('submissions_service_port'),
         },
     });
+    startMetricsServer(register, configService.get('submissions_service_port')!);
     await app.listen();
 }
 bootstrap();

apps/submissions-service/src/metrics-server.ts

@@ -0,0 +1,15 @@
+import express from 'express';
+import { Registry } from 'prom-client';
+
+export function startMetricsServer(registry: Registry, port: number) {
+    const app = express();
+
+    app.get('/metrics', async (_req, res) => {
+        res.set('Content-Type', registry.contentType);
+        res.send(await registry.metrics());
+    });
+
+    app.listen(port, () => {
+        console.log(`Prometheus metrics on port ${port}/metrics`);
+    });
+}