feat: add commune status layer

src/modules/api-depot/api-depot.service.ts

@@ -25,4 +25,12 @@ export class ApiDepotService {
 
     return revision;
   }
+
+  public async getAllCurrentRevisions(): Promise<Revision[]> {
+    const { data: revisions } = await firstValueFrom(
+      this.httpService.get<Revision[]>('/current-revisions'),
+    );
+
+    return revisions;
+  }
 }

src/modules/setting/commune-settings-cache.service.ts

@@ -0,0 +1,71 @@
+import {
+  forwardRef,
+  Inject,
+  Injectable,
+  Logger,
+  OnModuleInit,
+} from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+import { SettingService } from './setting.service';
+import { SignalementSubmissionMode } from './setting.type';
+
+export type CommuneSettingsMap = Record<
+  string,
+  {
+    disabled: boolean;
+    mode?: SignalementSubmissionMode;
+    filteredSources?: string[];
+  }
+>;
+
+@Injectable()
+export class CommuneSettingsCacheService implements OnModuleInit {
+  private cachedSettings: CommuneSettingsMap | null = null;
+  private readonly logger = new Logger(CommuneSettingsCacheService.name);
+
+  constructor(
+    @Inject(forwardRef(() => SettingService))
+    private readonly settingService: SettingService,
+  ) {}
+
+  async onModuleInit() {
+    try {
+      await this.buildCache();
+    } catch (err) {
+      this.logger.error(
+        'Failed to build commune status cache on init',
+        err.message,
+      );
+    }
+  }
+
+  @Cron(CronExpression.EVERY_HOUR)
+  async refreshCache() {
+    try {
+      await this.buildCache();
+    } catch (err) {
+      this.logger.error('Failed to refresh commune status cache', err.message);
+    }
+  }
+
+  private async buildCache() {
+    this.logger.log('Building commune status cache...');
+
+    const statuses = await this.settingService.computeAllCommuneStatuses();
+
+    const result: CommuneSettingsMap = {};
+    for (const [codeCommune, status] of statuses) {
+      result[codeCommune] = status;
+    }
+
+    this.cachedSettings = result;
+
+    this.logger.log(
+      `Commune settings cache ready with ${Object.keys(result).length} communes`,
+    );
+  }
+
+  getCachedSettings(): CommuneSettingsMap | null {
+    return this.cachedSettings;
+  }
+}

src/modules/setting/dto/commune-settings.dto.ts

@@ -1,7 +1,9 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { CommuneStatusDTO } from './commune-status.dto';
+import { IsOptional } from 'class-validator';
 
 export class CommuneSettingsDTO extends CommuneStatusDTO {
   @ApiProperty({ required: false, type: [String] })
+  @IsOptional()
   filteredSources?: string[];
 }

src/modules/setting/dto/commune-status.dto.ts

@@ -1,12 +1,14 @@
 import { ApiProperty } from '@nestjs/swagger';
-import { IsEnum } from 'class-validator';
+import { IsBoolean, IsEnum, IsOptional } from 'class-validator';
 import { SignalementSubmissionMode } from '../setting.type';
 
 export class CommuneStatusDTO {
   @ApiProperty({ required: true, nullable: false })
+  @IsBoolean()
   disabled: boolean;
 
   @ApiProperty({ required: false })
+  @IsOptional()
   message?: string;
 
   @ApiProperty({
@@ -15,5 +17,6 @@ export class CommuneStatusDTO {
     enum: SignalementSubmissionMode,
   })
   @IsEnum(SignalementSubmissionMode)
+  @IsOptional()
   mode?: SignalementSubmissionMode;
 }

src/modules/setting/setting.controller.ts

@@ -26,11 +26,18 @@ import { CommuneStatusDTO } from './dto/commune-status.dto';
 import { CommuneSettingsDTO } from './dto/commune-settings.dto';
 import { EnabledListKeys } from './setting.type';
 import { EnabledListDTO } from './dto/enabled-list.dto';
+import {
+  CommuneSettingsCacheService,
+  CommuneSettingsMap,
+} from './commune-settings-cache.service';
 
 @ApiTags('settings')
 @Controller('settings')
 export class SettingController {
-  constructor(private settingService: SettingService) {}
+  constructor(
+    private settingService: SettingService,
+    private communeSettingsCacheService: CommuneSettingsCacheService,
+  ) {}
 
   @Get('commune-status/:codeCommune')
   @ApiOperation({
@@ -116,6 +123,28 @@ export class SettingController {
     res.status(HttpStatus.OK).json(settings);
   }
 
+  @Get('commune-settings')
+  @ApiOperation({
+    summary: 'Get the settings of all communes',
+    operationId: 'getAllCommuneSettings',
+  })
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Map of commune codes to their settings',
+    schema: {
+      type: 'object',
+      additionalProperties: {
+        $ref: '#/components/schemas/CommuneSettingsDTO',
+      },
+    },
+  })
+  async getAllCommuneSettings(@Res() res: Response) {
+    const settings: CommuneSettingsMap =
+      this.communeSettingsCacheService.getCachedSettings() || {};
+
+    res.status(HttpStatus.OK).json(settings);
+  }
+
   @Get('enabled-list/:listKey/:id')
   @ApiOperation({
     summary:

src/modules/setting/setting.module.ts

@@ -5,6 +5,7 @@ import { SettingService } from './setting.service';
 import { SettingController } from './setting.controller';
 import { ApiDepotModule } from '../api-depot/api-depot.module';
 import { SourceModule } from '../source/source.module';
+import { CommuneSettingsCacheService } from './commune-settings-cache.service';
 
 @Module({
   imports: [
@@ -13,7 +14,7 @@ import { SourceModule } from '../source/source.module';
     forwardRef(() => SourceModule),
   ],
   controllers: [SettingController],
-  providers: [SettingService],
-  exports: [SettingService],
+  providers: [SettingService, CommuneSettingsCacheService],
+  exports: [SettingService, CommuneSettingsCacheService],
 })
 export class SettingModule {}