feat(admin): implement protocol administration service (BE-037)

src/admin/admin.module.ts

@@ -1,5 +1,6 @@
 import { Module } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
+import { BullModule } from '@nestjs/bullmq';
 import { Admin } from './entities/admin.entity';
 import { Incident } from './entities/incident.entity';
 import { ModerationReport } from './entities/moderation-report.entity';
@@ -14,15 +15,31 @@ import { DashboardService } from './dashboard/dashboard.service';
 import { DashboardController } from './dashboard/dashboard.controller';
 import { RolesGuard } from './guards/roles.guard';
 import { AdminGuard } from './guards/admin.guard';
+import { ProtocolAdminService } from './protocol/protocol-admin.service';
+import { ProtocolAdminController } from './protocol/protocol-admin.controller';
+import { FeatureFlagsModule } from '../feature-flags/feature-flags.module';
+import { JobsModule } from '../jobs/jobs.module';
+import { RedisModule } from '../redis/redis.module';
+import { QueueName } from '../jobs/jobs.types';
 @Module({
   imports: [
     TypeOrmModule.forFeature([Admin, Incident, ModerationReport, AuditLog]),
+    FeatureFlagsModule,
+    JobsModule,
+    RedisModule,
+    BullModule.registerQueue(
+      { name: QueueName.DEFAULT },
+      { name: QueueName.NOTIFICATIONS },
+      { name: QueueName.BLOCKCHAIN },
+      { name: QueueName.ANALYTICS },
+    ),
   ],
   controllers: [
     AdminController,
     ModerationController,
     IncidentController,
     DashboardController,
+    ProtocolAdminController,
   ],
   providers: [
     AdminService,
@@ -31,6 +48,7 @@ import { AdminGuard } from './guards/admin.guard';
     DashboardService,
     RolesGuard,
     AdminGuard,
+    ProtocolAdminService,
   ],
   exports: [
     AdminService,
@@ -39,6 +57,7 @@ import { AdminGuard } from './guards/admin.guard';
     DashboardService,
     RolesGuard,
     AdminGuard,
+    ProtocolAdminService,
   ],
 })
 export class AdminModule {}

src/admin/protocol/dto/config.dto.ts

@@ -0,0 +1,93 @@
+import { IsString, IsOptional, IsNotEmpty, IsObject } from 'class-validator';
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+
+export class ProtocolConfigDto {
+  @ApiProperty({ description: 'Configuration key' })
+  @IsString()
+  @IsNotEmpty()
+  key: string;
+
+  @ApiProperty({ description: 'Configuration value (JSON)' })
+  @IsObject()
+  @IsNotEmpty()
+  value: Record<string, unknown>;
+
+  @ApiPropertyOptional({ description: 'Environment scope' })
+  @IsString()
+  @IsOptional()
+  environment?: string;
+
+  @ApiPropertyOptional({ description: 'Reason for change' })
+  @IsString()
+  @IsOptional()
+  changeReason?: string;
+}
+
+export class ProtocolConfigResponse {
+  @ApiProperty()
+  id: string;
+
+  @ApiProperty()
+  key: string;
+
+  @ApiProperty()
+  value: unknown;
+
+  @ApiProperty()
+  environment: string;
+
+  @ApiProperty()
+  version: number;
+
+  @ApiPropertyOptional()
+  createdBy?: string;
+
+  @ApiProperty()
+  createdAt: Date;
+
+  @ApiProperty()
+  updatedAt: Date;
+}
+
+export class OperationalStatsResponse {
+  @ApiProperty()
+  totalUsers: number;
+
+  @ApiProperty()
+  totalClaims: number;
+
+  @ApiProperty()
+  totalDisputes: number;
+
+  @ApiProperty()
+  totalAdmins: number;
+
+  @ApiProperty()
+  activeAdmins: number;
+
+  @ApiProperty()
+  pendingClaims: number;
+
+  @ApiProperty()
+  finalizedClaims: number;
+
+  @ApiProperty()
+  auditLogCount: number;
+
+  @ApiProperty()
+  queueMetrics: {
+    totalWaiting: number;
+    totalActive: number;
+    totalFailed: number;
+    totalCompleted: number;
+  };
+
+  @ApiProperty()
+  systemUptime: number;
+
+  @ApiProperty()
+  environment: string;
+
+  @ApiProperty()
+  timestamp: string;
+}

src/admin/protocol/dto/emergency.dto.ts

@@ -0,0 +1,79 @@
+import {
+  IsBoolean,
+  IsEnum,
+  IsNotEmpty,
+  IsOptional,
+  IsString,
+} from 'class-validator';
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+
+export enum EmergencyAction {
+  SUSPEND_ALL_SERVICES = 'suspend_all_services',
+  DISABLE_NOTIFICATIONS = 'disable_notifications',
+  PAUSE_ALL_QUEUES = 'pause_all_queues',
+  ENABLE_API_THROTTLING = 'enable_api_throttling',
+  SUSPEND_INTEGRATIONS = 'suspend_integrations',
+  EMERGENCY_SHUTDOWN = 'emergency_shutdown',
+}
+
+export class ExecuteEmergencyActionDto {
+  @ApiProperty({ enum: EmergencyAction, description: 'Emergency action to execute' })
+  @IsEnum(EmergencyAction)
+  @IsNotEmpty()
+  action: EmergencyAction;
+
+  @ApiProperty({ description: 'Reason for emergency action' })
+  @IsString()
+  @IsNotEmpty()
+  reason: string;
+
+  @ApiPropertyOptional({ description: 'Duration in minutes (for time-bound actions)' })
+  @IsOptional()
+  durationMinutes?: number;
+}
+
+export class EmergencyActionResponse {
+  @ApiProperty()
+  action: EmergencyAction;
+
+  @ApiProperty()
+  success: boolean;
+
+  @ApiProperty()
+  timestamp: string;
+
+  @ApiPropertyOptional()
+  message?: string;
+
+  @ApiProperty({ type: [Object] })
+  affectedServices: string[];
+}
+
+export class SystemStatusResponse {
+  @ApiProperty()
+  maintenanceMode: boolean;
+
+  @ApiProperty()
+  emergencyActive: boolean;
+
+  @ApiProperty({ type: [String] })
+  activeEmergencies: string[];
+
+  @ApiProperty()
+  queuesOperational: boolean;
+
+  @ApiProperty()
+  notificationsEnabled: boolean;
+
+  @ApiProperty()
+  integrationsOperational: boolean;
+
+  @ApiProperty()
+  apiThrottlingActive: boolean;
+
+  @ApiProperty()
+  uptime: number;
+
+  @ApiProperty()
+  environment: string;
+}

src/admin/protocol/dto/index.ts

@@ -0,0 +1,4 @@
+export * from './maintenance.dto';
+export * from './service-control.dto';
+export * from './emergency.dto';
+export * from './config.dto';

src/admin/protocol/dto/maintenance.dto.ts

@@ -0,0 +1,71 @@
+import {
+  IsBoolean,
+  IsDateString,
+  IsOptional,
+  IsString,
+  IsNotEmpty,
+} from 'class-validator';
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+
+export class SetMaintenanceModeDto {
+  @ApiProperty({ description: 'Enable or disable maintenance mode' })
+  @IsBoolean()
+  @IsNotEmpty()
+  enabled: boolean;
+
+  @ApiPropertyOptional({ description: 'Reason for maintenance mode change' })
+  @IsString()
+  @IsOptional()
+  reason?: string;
+
+  @ApiPropertyOptional({ description: 'Scheduled end time (ISO 8601)' })
+  @IsDateString()
+  @IsOptional()
+  scheduledEnd?: string;
+}
+
+export class ScheduleMaintenanceDto {
+  @ApiProperty({ description: 'Scheduled start time (ISO 8601)' })
+  @IsDateString()
+  @IsNotEmpty()
+  startTime: string;
+
+  @ApiPropertyOptional({ description: 'Scheduled end time (ISO 8601)' })
+  @IsDateString()
+  @IsOptional()
+  endTime?: string;
+
+  @ApiProperty({ description: 'Description of maintenance' })
+  @IsString()
+  @IsNotEmpty()
+  description: string;
+
+  @ApiPropertyOptional({ description: 'Services affected by maintenance' })
+  @IsString({ each: true })
+  @IsOptional()
+  affectedServices?: string[];
+}
+
+export class MaintenanceStatusResponse {
+  @ApiProperty()
+  active: boolean;
+
+  @ApiPropertyOptional()
+  reason?: string;
+
+  @ApiPropertyOptional()
+  startedAt?: string;
+
+  @ApiPropertyOptional()
+  scheduledEnd?: string;
+
+  @ApiProperty({ type: [Object] })
+  scheduledMaintenance: Array<{
+    id: string;
+    description: string;
+    startTime: string;
+    endTime?: string;
+    status: string;
+    affectedServices?: string[];
+  }>;
+}