refactor(server): system config (#1353)

* refactor(server): system config

* fix: jest circular import

* chore: ignore migrations in coverage report

* chore: tests

* chore: tests

* chore: todo note

* chore: remove vite config backup

* chore: fix redis hostname

server/libs/infra/src/db/repository/system-config.repository.ts

@@ -0,0 +1,23 @@
+import { ISystemConfigRepository } from '@app/domain';
+import { InjectRepository } from '@nestjs/typeorm';
+import { In, Repository } from 'typeorm';
+import { SystemConfigEntity } from '../entities';
+
+export class SystemConfigRepository implements ISystemConfigRepository {
+  constructor(
+    @InjectRepository(SystemConfigEntity)
+    private repository: Repository<SystemConfigEntity>,
+  ) {}
+
+  load(): Promise<SystemConfigEntity<string | boolean>[]> {
+    return this.repository.find();
+  }
+
+  saveAll(items: SystemConfigEntity[]): Promise<SystemConfigEntity[]> {
+    return this.repository.save(items);
+  }
+
+  async deleteKeys(keys: string[]): Promise<void> {
+    await this.repository.delete({ key: In(keys) });
+  }
+}

server/libs/infra/src/infra.module.ts

@@ -1,26 +1,65 @@
-import { ICryptoRepository, IKeyRepository, IUserRepository } from '@app/domain';
+import {
+  ICryptoRepository,
+  IJobRepository,
+  IKeyRepository,
+  ISystemConfigRepository,
+  IUserRepository,
+  QueueName,
+} from '@app/domain';
 import { databaseConfig, UserEntity } from '@app/infra';
+import { BullModule } from '@nestjs/bull';
 import { Global, Module, Provider } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
 import { cryptoRepository } from './auth/crypto.repository';
-import { APIKeyEntity, UserRepository } from './db';
+import { APIKeyEntity, SystemConfigEntity, UserRepository } from './db';
 import { APIKeyRepository } from './db/repository';
+import { SystemConfigRepository } from './db/repository/system-config.repository';
+import { JobRepository } from './job';
 
 const providers: Provider[] = [
   //
   { provide: ICryptoRepository, useValue: cryptoRepository },
   { provide: IKeyRepository, useClass: APIKeyRepository },
+  { provide: IJobRepository, useClass: JobRepository },
+  { provide: ISystemConfigRepository, useClass: SystemConfigRepository },
   { provide: IUserRepository, useClass: UserRepository },
 ];
 
 @Global()
 @Module({
   imports: [
-    //
     TypeOrmModule.forRoot(databaseConfig),
-    TypeOrmModule.forFeature([APIKeyEntity, UserEntity]),
+    TypeOrmModule.forFeature([APIKeyEntity, UserEntity, SystemConfigEntity]),
+    BullModule.forRootAsync({
+      useFactory: async () => ({
+        prefix: 'immich_bull',
+        redis: {
+          host: process.env.REDIS_HOSTNAME || 'immich_redis',
+          port: parseInt(process.env.REDIS_PORT || '6379'),
+          db: parseInt(process.env.REDIS_DBINDEX || '0'),
+          password: process.env.REDIS_PASSWORD || undefined,
+          path: process.env.REDIS_SOCKET || undefined,
+        },
+        defaultJobOptions: {
+          attempts: 3,
+          removeOnComplete: true,
+          removeOnFail: false,
+        },
+      }),
+    }),
+    BullModule.registerQueue(
+      { name: QueueName.USER_DELETION },
+      { name: QueueName.THUMBNAIL_GENERATION },
+      { name: QueueName.ASSET_UPLOADED },
+      { name: QueueName.METADATA_EXTRACTION },
+      { name: QueueName.VIDEO_CONVERSION },
+      { name: QueueName.CHECKSUM_GENERATION },
+      { name: QueueName.MACHINE_LEARNING },
+      { name: QueueName.CONFIG },
+      { name: QueueName.BACKGROUND_TASK },
+    ),
   ],
   providers: [...providers],
-  exports: [...providers],
+  exports: [...providers, BullModule],
 })
 export class InfraModule {}

server/libs/infra/src/job/index.ts

@@ -0,0 +1 @@
+export * from './job.repository';

server/libs/infra/src/job/job.repository.ts

@@ -0,0 +1,21 @@
+import { IJobRepository, JobItem, JobName, QueueName } from '@app/domain';
+import { InjectQueue } from '@nestjs/bull';
+import { Logger } from '@nestjs/common';
+import { Queue } from 'bull';
+
+export class JobRepository implements IJobRepository {
+  private logger = new Logger(JobRepository.name);
+
+  constructor(@InjectQueue(QueueName.CONFIG) private configQueue: Queue) {}
+
+  async add(item: JobItem): Promise<void> {
+    switch (item.name) {
+      case JobName.CONFIG_CHANGE:
+        await this.configQueue.add(JobName.CONFIG_CHANGE, {});
+        break;
+      default:
+        // TODO inject remaining queues and map job to queue
+        this.logger.error('Invalid job', item);
+    }
+  }
+}