chore: add instrumentation

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

Author: shikanime

apps/server-nestjs/package.json

@@ -40,6 +40,16 @@
     "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/platform-express": "^11.0.1",
+    "@nestjs/schedule": "^5.0.1",
+    "@opentelemetry/api": "^1.9.0",
+    "@opentelemetry/auto-instrumentations-node": "^0.70.1",
+    "@opentelemetry/exporter-metrics-otlp-proto": "^0.213.0",
+    "@opentelemetry/exporter-trace-otlp-proto": "^0.213.0",
+    "@opentelemetry/instrumentation-nestjs-core": "^0.58.0",
+    "@opentelemetry/instrumentation-pino": "^0.59.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,30 @@
+import { NodeSDK } from '@opentelemetry/sdk-node'
+import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node'
+import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics'
+import { NestInstrumentation } from '@opentelemetry/instrumentation-nestjs-core'
+import { PinoInstrumentation } from '@opentelemetry/instrumentation-pino'
+import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-proto'
+import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-proto'
+
+function createSdk() {
+  return new NodeSDK({
+    traceExporter: new OTLPTraceExporter({}),
+    metricReader: new PeriodicExportingMetricReader({
+      exporter: new OTLPMetricExporter(),
+    }),
+    instrumentations: [
+      getNodeAutoInstrumentations(),
+      new NestInstrumentation(),
+      new PinoInstrumentation(),
+    ],
+    serviceName: 'cloud-pi-native-console',
+  })
+}
+
+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()

docker/docker-compose.local.yml

@@ -96,6 +96,24 @@ services:
       - dso-network
     attach: false
 
+  jaeger:
+    restart: unless-stopped
+    image: jaegertracing/all-in-one:1.76.0
+    container_name: dso-console_jaeger
+    environment:
+      COLLECTOR_ZIPKIN_HOST_PORT: :9411
+    ports:
+      - 16686:16686
+      - 4317:4317
+      - 4318:4318
+      - 14250:14250
+      - 14268:14268
+      - 14269:14269
+      - 9411:9411
+    networks:
+      - dso-network
+    attach: false
+
 networks:
   dso-network:
     driver: bridge