chore: add instrumentation

Signed-off-by: William Phetsinorath <william.phetsinorath-open@interieur.gouv.fr>

Author: shikanime

apps/server-nestjs/package.json

@@ -40,6 +40,12 @@
     "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/platform-express": "^11.0.1",
+    "@nestjs/schedule": "^5.0.1",
+    "@opentelemetry/auto-instrumentations-node": "^0.70.1",
+    "@opentelemetry/instrumentation-nestjs-core": "^0.58.0",
+    "@opentelemetry/sdk-metrics": "^2.5.1",
+    "@opentelemetry/sdk-node": "^0.212.0",
+    "@opentelemetry/sdk-trace-node": "^2.5.1",
     "@prisma/client": "^6.0.1",
     "@ts-rest/core": "^3.52.1",
     "@ts-rest/fastify": "^3.52.1",

apps/server-nestjs/src/instrumentation.ts

@@ -0,0 +1,26 @@
+import { NodeSDK } from '@opentelemetry/sdk-node'
+import { ConsoleSpanExporter } from '@opentelemetry/sdk-trace-node'
+import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node'
+import {
+  PeriodicExportingMetricReader,
+  ConsoleMetricExporter,
+} from '@opentelemetry/sdk-metrics'
+import { NestInstrumentation } from '@opentelemetry/instrumentation-nestjs-core'
+
+function createSdk() {
+  return new NodeSDK({
+    traceExporter: new ConsoleSpanExporter(),
+    metricReader: new PeriodicExportingMetricReader({
+      exporter: new ConsoleMetricExporter(),
+    }),
+    instrumentations: [getNodeAutoInstrumentations(), new NestInstrumentation()],
+  })
+}
+
+export function instrument() {
+  const sdk = createSdk()
+  sdk.start()
+  process.on('SIGTERM', () => {
+    sdk.shutdown()
+  })
+}

apps/server-nestjs/src/main.ts

@@ -1,6 +1,6 @@
 import { NestFactory } from '@nestjs/core'
 import { Logger } from 'nestjs-pino'
-
+import { instrument } from './instrumentation'
 import { MainModule } from './main.module'
 
 async function bootstrap() {
@@ -9,4 +9,6 @@ async function bootstrap() {
   app.flushLogs()
   await app.listen(process.env.PORT ?? 0)
 }
+
+instrument()
 bootstrap()