strip down core

server/src/app.module.ts

@@ -5,35 +5,22 @@ import { ScheduleModule, SchedulerRegistry } from '@nestjs/schedule';
 import { ClsModule } from 'nestjs-cls';
 import { KyselyModule } from 'nestjs-kysely';
 import { OpenTelemetryModule } from 'nestjs-otel';
-import { commandsAndQuestions } from 'src/commands';
 import { IWorker } from 'src/constants';
 import { controllers } from 'src/controllers';
 import { ImmichWorker } from 'src/enum';
-import { MaintenanceAuthGuard } from 'src/maintenance/maintenance-auth.guard';
-import { MaintenanceHealthRepository } from 'src/maintenance/maintenance-health.repository';
-import { MaintenanceWebsocketRepository } from 'src/maintenance/maintenance-websocket.repository';
-import { MaintenanceWorkerController } from 'src/maintenance/maintenance-worker.controller';
-import { MaintenanceWorkerService } from 'src/maintenance/maintenance-worker.service';
 import { AuthGuard } from 'src/middleware/auth.guard';
 import { ErrorInterceptor } from 'src/middleware/error.interceptor';
-import { FileUploadInterceptor } from 'src/middleware/file-upload.interceptor';
 import { GlobalExceptionFilter } from 'src/middleware/global-exception.filter';
 import { LoggingInterceptor } from 'src/middleware/logging.interceptor';
 import { repositories } from 'src/repositories';
-import { AppRepository } from 'src/repositories/app.repository';
 import { ConfigRepository } from 'src/repositories/config.repository';
-import { DatabaseRepository } from 'src/repositories/database.repository';
 import { EventRepository } from 'src/repositories/event.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
-import { ProcessRepository } from 'src/repositories/process.repository';
-import { StorageRepository } from 'src/repositories/storage.repository';
-import { SystemMetadataRepository } from 'src/repositories/system-metadata.repository';
 import { teardownTelemetry, TelemetryRepository } from 'src/repositories/telemetry.repository';
 import { WebsocketRepository } from 'src/repositories/websocket.repository';
 import { services } from 'src/services';
 import { AuthService } from 'src/services/auth.service';
-import { CliService } from 'src/services/cli.service';
-import { QueueService } from 'src/services/queue.service';
+
 import { getKyselyConfig } from 'src/utils/database';
 
 const common = [...repositories, ...services, GlobalExceptionFilter];
@@ -45,7 +32,7 @@ const commonMiddleware = [
   { provide: APP_INTERCEPTOR, useClass: ErrorInterceptor },
 ];
 
-const apiMiddleware = [FileUploadInterceptor, ...commonMiddleware, { provide: APP_GUARD, useClass: AuthGuard }];
+const apiMiddleware = [...commonMiddleware, { provide: APP_GUARD, useClass: AuthGuard }];
 
 const configRepository = new ConfigRepository();
 const { bull, cls, database, otel } = configRepository.getEnv();
@@ -64,7 +51,7 @@ export class BaseModule implements OnModuleInit, OnModuleDestroy {
     logger: LoggingRepository,
     private authService: AuthService,
     private eventRepository: EventRepository,
-    private queueService: QueueService,
+
     private telemetryRepository: TelemetryRepository,
     private websocketRepository: WebsocketRepository,
   ) {
@@ -74,22 +61,20 @@ export class BaseModule implements OnModuleInit, OnModuleDestroy {
   async onModuleInit() {
     this.telemetryRepository.setup({ repositories });
 
-    this.queueService.setServices(services);
-
     this.websocketRepository.setAuthFn(async (client) =>
       this.authService.authenticate({
         headers: client.request.headers,
         queryParams: {},
-        metadata: { adminRoute: false, sharedLinkRoute: false, uri: '/api/socket.io' },
+        metadata: { adminRoute: false, uri: '/api/socket.io' },
       }),
     );
 
     this.eventRepository.setup({ services });
-    await this.eventRepository.emit('AppBootstrap');
+    await this.eventRepository.emit('app.bootstrap');
   }
 
   async onModuleDestroy() {
-    await this.eventRepository.emit('AppShutdown');
+    await this.eventRepository.emit('app.shutdown');
     await teardownTelemetry();
   }
 }
@@ -101,53 +86,8 @@ export class BaseModule implements OnModuleInit, OnModuleDestroy {
 })
 export class ApiModule extends BaseModule {}
 
-@Module({
-  imports: [...commonImports],
-  controllers: [MaintenanceWorkerController],
-  providers: [
-    ConfigRepository,
-    LoggingRepository,
-    StorageRepository,
-    ProcessRepository,
-    DatabaseRepository,
-    SystemMetadataRepository,
-    AppRepository,
-    MaintenanceHealthRepository,
-    MaintenanceWebsocketRepository,
-    MaintenanceWorkerService,
-    ...commonMiddleware,
-    { provide: APP_GUARD, useClass: MaintenanceAuthGuard },
-    { provide: IWorker, useValue: ImmichWorker.Maintenance },
-  ],
-})
-export class MaintenanceModule {
-  constructor(
-    @Inject(IWorker) private worker: ImmichWorker,
-    logger: LoggingRepository,
-    private maintenanceWorkerService: MaintenanceWorkerService,
-  ) {
-    logger.setAppName(this.worker);
-  }
-
-  async onModuleInit() {
-    await this.maintenanceWorkerService.init();
-  }
-}
-
 @Module({
   imports: [...bullImports, ...commonImports],
   providers: [...common, { provide: IWorker, useValue: ImmichWorker.Microservices }, SchedulerRegistry],
 })
 export class MicroservicesModule extends BaseModule {}
-
-@Module({
-  imports: [...bullImports, ...commonImports],
-  providers: [...common, ...commandsAndQuestions, SchedulerRegistry],
-})
-export class ImmichAdminModule implements OnModuleDestroy {
-  constructor(private service: CliService) {}
-
-  async onModuleDestroy() {
-    await this.service.cleanup();
-  }
-}