head

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
+  }
+}

apps/server-nestjs/src/modules/keycloak/keycloak-datastore.service.ts

@@ -1,5 +1,5 @@
 import { Inject, Injectable } from '@nestjs/common'
-import type { Prisma } from '@prisma/client'
+import type { Prisma, ProjectSelect } from '@prisma/client'
 import { PrismaService } from '@/cpin-module/infrastructure/database/prisma.service'
 
 export const projectSelect = {
@@ -32,11 +32,13 @@ export const projectSelect = {
       name: true,
     },
   },
-} satisfies Prisma.ProjectSelect
+} satisfies ProjectSelect
 
-export type ProjectWithDetails = Prisma.ProjectGetPayload<{
-  select: typeof projectSelect
-}>
+export type ProjectWithDetails = Prisma.Result<
+  PrismaService['project'],
+  { select: typeof projectSelect },
+  'findMany'
+>[number]
 
 @Injectable()
 export class KeycloakDatastoreService {

apps/server-nestjs/src/modules/nexus/nexus-client.service.ts

@@ -0,0 +1,33 @@
+import { ConfigurationService } from '@/cpin-module/infrastructure/configuration/configuration.service'
+import { Inject, Injectable } from '@nestjs/common'
+import axios from 'axios'
+import type { AxiosInstance } from 'axios'
+import { removeTrailingSlash } from './nexus.utils'
+
+@Injectable()
+export class NexusClientService {
+  readonly axios: AxiosInstance
+
+  constructor(
+    @Inject(ConfigurationService) private readonly config: ConfigurationService,
+  ) {
+    this.axios = axios.create({
+      baseURL: `${removeTrailingSlash(this.config.nexusInternalUrl!)}/service/rest/v1/`,
+      auth: {
+        username: this.config.nexusAdmin!,
+        password: this.config.nexusAdminPassword!,
+      },
+      headers: {
+        Accept: 'application/json',
+      },
+    })
+  }
+
+  async deleteIfExists(path: string) {
+    return this.axios({
+      method: 'delete',
+      url: path,
+      validateStatus: code => code === 404 || code < 300,
+    })
+  }
+}

apps/server-nestjs/src/modules/nexus/nexus.module.ts

@@ -0,0 +1,13 @@
+import { Module } from '@nestjs/common'
+import { ConfigurationModule } from '@/cpin-module/infrastructure/configuration/configuration.module'
+import { InfrastructureModule } from '@/cpin-module/infrastructure/infrastructure.module'
+import { VaultModule } from '../vault/vault.module'
+import { NexusClientService } from './nexus-client.service'
+import { NexusService } from './nexus.service'
+
+@Module({
+  imports: [ConfigurationModule, InfrastructureModule, VaultModule],
+  providers: [NexusService, NexusClientService],
+  exports: [NexusService],
+})
+export class NexusModule {}

apps/server-nestjs/src/modules/nexus/nexus.service.spec.ts

@@ -0,0 +1,49 @@
+import { Test } from '@nestjs/testing'
+import type { TestingModule } from '@nestjs/testing'
+import { describe, it, expect, beforeEach } from 'vitest'
+import { mockDeep, mockReset } from 'vitest-mock-extended'
+import { NexusService } from './nexus.service'
+import { NexusClientService } from './nexus-client.service'
+import { VaultService } from '../vault/vault.service'
+import { ConfigurationService } from '@/cpin-module/infrastructure/configuration/configuration.service'
+
+const nexusClientMock = mockDeep<NexusClientService>()
+const vaultMock = mockDeep<VaultService>()
+
+function createNexusServiceTestingModule() {
+  return Test.createTestingModule({
+    providers: [
+      NexusService,
+      {
+        provide: NexusClientService,
+        useValue: nexusClientMock,
+      },
+      {
+        provide: VaultService,
+        useValue: vaultMock,
+      },
+      {
+        provide: ConfigurationService,
+        useValue: {
+          nexusSecretExposedUrl: 'https://nexus.example',
+          projectRootPath: 'forge',
+        } satisfies Partial<ConfigurationService>,
+      },
+    ],
+  })
+}
+
+describe('nexusService', () => {
+  let service: NexusService
+
+  beforeEach(async () => {
+    mockReset(nexusClientMock)
+    mockReset(vaultMock)
+    const module: TestingModule = await createNexusServiceTestingModule().compile()
+    service = module.get(NexusService)
+  })
+
+  it('should be defined', () => {
+    expect(service).toBeDefined()
+  })
+})