chore(server-nestjs): migrate monitoring probes

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

Author: shikanime

.vscode/launch.json

@@ -155,6 +155,24 @@
       "request": "launch",
       "url": "http://localhost:8080",
       "webRoot": "${workspaceFolder}/apps/client"
+    },
+
+    {
+      "name": "Launch Server NestJS",
+      "type": "node",
+      "request": "launch",
+      "runtimeExecutable": "pnpm",
+      "runtimeArgs": [
+        "run",
+        "start:debug"
+      ],
+      "cwd": "${workspaceFolder}/apps/server-nestjs",
+      "console": "internalConsole",
+      "restart": true,
+      "skipFiles": [
+        "<node_internals>/**",
+        "${workspaceFolder}/node_modules/**/*.js"
+      ]
     }
   ],
   "compounds": [

apps/server-nestjs/src/cpin-module/infrastructure/configuration/configuration.service.ts

@@ -19,6 +19,7 @@ export class ConfigurationService {
 
   // keycloak
   sessionSecret = process.env.SESSION_SECRET
+  keycloakUrl = process.env.KEYCLOAK_URL
   keycloakProtocol = process.env.KEYCLOAK_PROTOCOL
   keycloakDomain = process.env.KEYCLOAK_DOMAIN
   keycloakRealm = process.env.KEYCLOAK_REALM

apps/server-nestjs/src/modules/keycloak/keycloack.controller.ts

@@ -0,0 +1,41 @@
+import { Controller, Get } from '@nestjs/common'
+import { Monitor, MonitorStatus } from '@cpn-console/shared'
+import type { MonitorInfos } from '@cpn-console/shared'
+import type { ConfigurationService } from '../../cpin-module/infrastructure/configuration/configuration.service'
+
+@Controller('keycloak')
+export class KeycloakController {
+  private monitor: Monitor
+
+  constructor(
+    private readonly configService: ConfigurationService,
+  ) {
+    this.monitor = new Monitor(async (instance): Promise<MonitorInfos> => {
+      instance.lastStatus.lastUpdateTimestamp = Date.now()
+      try {
+        if (!this.configService.keycloakUrl) {
+          throw new Error('keycloakUrl is not defined')
+        }
+        const res = await fetch(this.configService.keycloakUrl)
+        if (res.status === 200) {
+          instance.lastStatus.status = MonitorStatus.OK
+          instance.lastStatus.message = MonitorStatus.OK
+          return instance.lastStatus
+        }
+        instance.lastStatus.status = MonitorStatus.ERROR
+        instance.lastStatus.message = 'Service en erreur'
+        return instance.lastStatus
+      } catch (error) {
+        instance.lastStatus.message = 'Erreur lors la requête'
+        instance.lastStatus.status = MonitorStatus.UNKNOW
+        instance.lastStatus.cause = error
+      }
+      return instance.lastStatus
+    })
+  }
+
+  @Get('status')
+  async status(): Promise<MonitorInfos> {
+    return this.monitor.lastStatus
+  }
+}