[pull] main from immich-app:main

server/package.json

@@ -45,7 +45,7 @@
     "@nestjs/swagger": "^11.0.2",
     "@nestjs/typeorm": "^11.0.0",
     "@nestjs/websockets": "^11.0.4",
-    "@opentelemetry/auto-instrumentations-node": "^0.55.0",
+    "@opentelemetry/auto-instrumentations-node": "^0.56.0",
     "@opentelemetry/context-async-hooks": "^1.24.0",
     "@opentelemetry/exporter-prometheus": "^0.57.0",
     "@opentelemetry/sdk-node": "^0.57.0",

server/src/app.module.ts

@@ -13,22 +13,23 @@ import { IWorker } from 'src/constants';
 import { controllers } from 'src/controllers';
 import { entities } from 'src/entities';
 import { ImmichWorker } from 'src/enum';
-import { IEventRepository } from 'src/interfaces/event.interface';
-import { IJobRepository } from 'src/interfaces/job.interface';
 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 { providers, repositories } from 'src/repositories';
+import { repositories } from 'src/repositories';
 import { ConfigRepository } from 'src/repositories/config.repository';
+import { EventRepository } from 'src/repositories/event.repository';
+import { JobRepository } from 'src/repositories/job.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
 import { teardownTelemetry, TelemetryRepository } from 'src/repositories/telemetry.repository';
 import { services } from 'src/services';
+import { AuthService } from 'src/services/auth.service';
 import { CliService } from 'src/services/cli.service';
 import { DatabaseService } from 'src/services/database.service';
 
-const common = [...services, ...providers, ...repositories];
+const common = [...repositories, ...services];
 
 const middleware = [
   FileUploadInterceptor,
@@ -78,21 +79,30 @@ class BaseModule implements OnModuleInit, OnModuleDestroy {
   constructor(
     @Inject(IWorker) private worker: ImmichWorker,
     logger: LoggingRepository,
-    @Inject(IEventRepository) private eventRepository: IEventRepository,
-    @Inject(IJobRepository) private jobRepository: IJobRepository,
+    private eventRepository: EventRepository,
+    private jobRepository: JobRepository,
     private telemetryRepository: TelemetryRepository,
+    private authService: AuthService,
   ) {
     logger.setAppName(this.worker);
   }
 
   async onModuleInit() {
-    this.telemetryRepository.setup({ repositories: [...providers.map(({ useClass }) => useClass), ...repositories] });
+    this.telemetryRepository.setup({ repositories });
 
     this.jobRepository.setup({ services });
     if (this.worker === ImmichWorker.MICROSERVICES) {
       this.jobRepository.startWorkers();
     }
 
+    this.eventRepository.setAuthFn(async (client) =>
+      this.authService.authenticate({
+        headers: client.request.headers,
+        queryParams: {},
+        metadata: { adminRoute: false, sharedLinkRoute: false, uri: '/api/socket.io' },
+      }),
+    );
+
     this.eventRepository.setup({ services });
     await this.eventRepository.emit('app.bootstrap');
   }

server/src/bin/sync-sql.ts

@@ -4,6 +4,7 @@ import { Reflector } from '@nestjs/core';
 import { SchedulerRegistry } from '@nestjs/schedule';
 import { Test } from '@nestjs/testing';
 import { TypeOrmModule } from '@nestjs/typeorm';
+import { ClassConstructor } from 'class-transformer';
 import { PostgresJSDialect } from 'kysely-postgres-js';
 import { KyselyModule } from 'nestjs-kysely';
 import { OpenTelemetryModule } from 'nestjs-otel';
@@ -13,7 +14,7 @@ import postgres from 'postgres';
 import { format } from 'sql-formatter';
 import { GENERATE_SQL_KEY, GenerateSqlQueries } from 'src/decorators';
 import { entities } from 'src/entities';
-import { providers, repositories } from 'src/repositories';
+import { repositories } from 'src/repositories';
 import { AccessRepository } from 'src/repositories/access.repository';
 import { ConfigRepository } from 'src/repositories/config.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
@@ -45,8 +46,7 @@ export class SqlLogger implements Logger {
 
 const reflector = new Reflector();
 
-type Repository = (typeof providers)[0]['useClass'];
-type Provider = { provide: any; useClass: Repository };
+type Repository = ClassConstructor<any>;
 type SqlGeneratorOptions = { targetDir: string };
 
 class SqlGenerator {
@@ -59,15 +59,11 @@ class SqlGenerator {
   async run() {
     try {
       await this.setup();
-      const targets = [
-        ...providers,
-        ...repositories.map((repository) => ({ provide: repository, useClass: repository as any })),
-      ];
-      for (const repository of targets) {
-        if (repository.provide === LoggingRepository) {
+      for (const Repository of repositories) {
+        if (Repository === LoggingRepository) {
           continue;
         }
-        await this.process(repository);
+        await this.process(Repository);
       }
       await this.write();
       this.stats();
@@ -105,19 +101,19 @@ class SqlGenerator {
         TypeOrmModule.forFeature(entities),
         OpenTelemetryModule.forRoot(otel),
       ],
-      providers: [...providers, ...repositories, AuthService, SchedulerRegistry],
+      providers: [...repositories, AuthService, SchedulerRegistry],
     }).compile();
 
     this.app = await moduleFixture.createNestApplication().init();
   }
 
-  async process({ provide: token, useClass: Repository }: Provider) {
+  async process(Repository: Repository) {
     if (!this.app) {
       throw new Error('Not initialized');
     }
 
     const data: string[] = [`-- NOTE: This file is auto generated by ./sql-generator`];
-    const instance = this.app.get<Repository>(token);
+    const instance = this.app.get<Repository>(Repository);
 
     // normal repositories
     data.push(...(await this.runTargets(instance, `${Repository.name}`)));

server/src/config.ts

@@ -5,14 +5,14 @@ import {
   CQMode,
   ImageFormat,
   LogLevel,
+  QueueName,
   ToneMapping,
   TranscodeHWAccel,
   TranscodePolicy,
   VideoCodec,
   VideoContainer,
 } from 'src/enum';
-import { ConcurrentQueueName, QueueName } from 'src/interfaces/job.interface';
-import { ImageOptions } from 'src/types';
+import { ConcurrentQueueName, ImageOptions } from 'src/types';
 
 export interface SystemConfig {
   backup: {

server/src/constants.ts

@@ -1,7 +1,7 @@
 import { Duration } from 'luxon';
 import { readFileSync } from 'node:fs';
 import { SemVer } from 'semver';
-import { ExifOrientation } from 'src/enum';
+import { DatabaseExtension, ExifOrientation } from 'src/enum';
 
 export const POSTGRES_VERSION_RANGE = '>=14.0.0';
 export const VECTORS_VERSION_RANGE = '>=0.2 <0.4';
@@ -16,6 +16,16 @@ export const LIFECYCLE_EXTENSION = 'x-immich-lifecycle';
 export const DEPRECATED_IN_PREFIX = 'This property was deprecated in ';
 export const ADDED_IN_PREFIX = 'This property was added in ';
 
+export const JOBS_ASSET_PAGINATION_SIZE = 1000;
+export const JOBS_LIBRARY_PAGINATION_SIZE = 10_000;
+
+export const EXTENSION_NAMES: Record<DatabaseExtension, string> = {
+  cube: 'cube',
+  earthdistance: 'earthdistance',
+  vector: 'pgvector',
+  vectors: 'pgvecto.rs',
+} as const;
+
 export const SALT_ROUNDS = 10;
 
 export const IWorker = 'IWorker';

server/src/controllers/asset-media.controller.ts

@@ -35,9 +35,10 @@ import { AuthDto } from 'src/dtos/auth.dto';
 import { ImmichHeader, RouteKey } from 'src/enum';
 import { AssetUploadInterceptor } from 'src/middleware/asset-upload.interceptor';
 import { Auth, Authenticated, FileResponse } from 'src/middleware/auth.guard';
-import { FileUploadInterceptor, UploadFiles, getFiles } from 'src/middleware/file-upload.interceptor';
+import { FileUploadInterceptor, getFiles } from 'src/middleware/file-upload.interceptor';
 import { LoggingRepository } from 'src/repositories/logging.repository';
 import { AssetMediaService } from 'src/services/asset-media.service';
+import { UploadFiles } from 'src/types';
 import { sendFile } from 'src/utils/file';
 import { FileNotEmptyValidator, UUIDParamDto } from 'src/validation';
 

server/src/cores/storage.core.spec.ts

@@ -5,6 +5,7 @@ vitest.mock('src/constants', () => ({
   APP_MEDIA_LOCATION: '/photos',
   ADDED_IN_PREFIX: 'This property was added in ',
   DEPRECATED_IN_PREFIX: 'This property was deprecated in ',
+  IWorker: 'IWorker',
 }));
 
 describe('StorageCore', () => {

server/src/cores/storage.core.ts

@@ -4,13 +4,13 @@ import { APP_MEDIA_LOCATION } from 'src/constants';
 import { AssetEntity } from 'src/entities/asset.entity';
 import { PersonEntity } from 'src/entities/person.entity';
 import { AssetFileType, AssetPathType, ImageFormat, PathType, PersonPathType, StorageFolder } from 'src/enum';
-import { IAssetRepository } from 'src/interfaces/asset.interface';
-import { IMoveRepository } from 'src/interfaces/move.interface';
-import { IPersonRepository } from 'src/interfaces/person.interface';
-import { IStorageRepository } from 'src/interfaces/storage.interface';
+import { AssetRepository } from 'src/repositories/asset.repository';
 import { ConfigRepository } from 'src/repositories/config.repository';
 import { CryptoRepository } from 'src/repositories/crypto.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
+import { MoveRepository } from 'src/repositories/move.repository';
+import { PersonRepository } from 'src/repositories/person.repository';
+import { StorageRepository } from 'src/repositories/storage.repository';
 import { SystemMetadataRepository } from 'src/repositories/system-metadata.repository';
 import { getAssetFiles } from 'src/utils/asset.util';
 import { getConfig } from 'src/utils/config';
@@ -33,23 +33,23 @@ let instance: StorageCore | null;
 
 export class StorageCore {
   private constructor(
-    private assetRepository: IAssetRepository,
+    private assetRepository: AssetRepository,
     private configRepository: ConfigRepository,
     private cryptoRepository: CryptoRepository,
-    private moveRepository: IMoveRepository,
-    private personRepository: IPersonRepository,
-    private storageRepository: IStorageRepository,
+    private moveRepository: MoveRepository,
+    private personRepository: PersonRepository,
+    private storageRepository: StorageRepository,
     private systemMetadataRepository: SystemMetadataRepository,
     private logger: LoggingRepository,
   ) {}
 
   static create(
-    assetRepository: IAssetRepository,
+    assetRepository: AssetRepository,
     configRepository: ConfigRepository,
     cryptoRepository: CryptoRepository,
-    moveRepository: IMoveRepository,
-    personRepository: IPersonRepository,
-    storageRepository: IStorageRepository,
+    moveRepository: MoveRepository,
+    personRepository: PersonRepository,
+    storageRepository: StorageRepository,
     systemMetadataRepository: SystemMetadataRepository,
     logger: LoggingRepository,
   ) {

server/src/decorators.ts

@@ -2,9 +2,8 @@ import { SetMetadata, applyDecorators } from '@nestjs/common';
 import { ApiExtension, ApiOperation, ApiProperty, ApiTags } from '@nestjs/swagger';
 import _ from 'lodash';
 import { ADDED_IN_PREFIX, DEPRECATED_IN_PREFIX, LIFECYCLE_EXTENSION } from 'src/constants';
-import { ImmichWorker, MetadataKey } from 'src/enum';
-import { EmitEvent } from 'src/interfaces/event.interface';
-import { JobName, QueueName } from 'src/interfaces/job.interface';
+import { ImmichWorker, JobName, MetadataKey, QueueName } from 'src/enum';
+import { EmitEvent } from 'src/repositories/event.repository';
 import { setUnion } from 'src/utils/set';
 
 // PostgreSQL uses a 16-bit integer to indicate the number of bound parameters. This means that the

server/src/dtos/asset.dto.ts

@@ -15,7 +15,7 @@ import {
 } from 'class-validator';
 import { BulkIdsDto } from 'src/dtos/asset-ids.response.dto';
 import { AssetType } from 'src/enum';
-import { AssetStats } from 'src/interfaces/asset.interface';
+import { AssetStats } from 'src/repositories/asset.repository';
 import { Optional, ValidateBoolean, ValidateUUID } from 'src/validation';
 
 export class DeviceIdDto {

server/src/dtos/job.dto.ts

@@ -1,7 +1,6 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { IsEnum, IsNotEmpty } from 'class-validator';
-import { ManualJobName } from 'src/enum';
-import { JobCommand, QueueName } from 'src/interfaces/job.interface';
+import { JobCommand, ManualJobName, QueueName } from 'src/enum';
 import { ValidateBoolean } from 'src/validation';
 
 export class JobIdParamDto {

server/src/dtos/partner.dto.ts

@@ -1,7 +1,7 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { IsEnum, IsNotEmpty } from 'class-validator';
 import { UserResponseDto } from 'src/dtos/user.dto';
-import { PartnerDirection } from 'src/interfaces/partner.interface';
+import { PartnerDirection } from 'src/repositories/partner.repository';
 
 export class UpdatePartnerDto {
   @IsNotEmpty()

server/src/dtos/system-config.dto.ts

@@ -25,13 +25,14 @@ import {
   Colorspace,
   ImageFormat,
   LogLevel,
+  QueueName,
   ToneMapping,
   TranscodeHWAccel,
   TranscodePolicy,
   VideoCodec,
   VideoContainer,
 } from 'src/enum';
-import { ConcurrentQueueName, QueueName } from 'src/interfaces/job.interface';
+import { ConcurrentQueueName } from 'src/types';
 import { IsCronExpression, ValidateBoolean } from 'src/validation';
 
 const isLibraryScanEnabled = (config: SystemConfigLibraryScanDto) => config.enabled;

server/src/dtos/time-bucket.dto.ts

@@ -1,7 +1,7 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { IsEnum, IsNotEmpty, IsString } from 'class-validator';
 import { AssetOrder } from 'src/enum';
-import { TimeBucketSize } from 'src/interfaces/asset.interface';
+import { TimeBucketSize } from 'src/repositories/asset.repository';
 import { Optional, ValidateBoolean, ValidateUUID } from 'src/validation';
 
 export class TimeBucketDto {

server/src/entities/asset.entity.ts

@@ -13,8 +13,8 @@ import { StackEntity } from 'src/entities/stack.entity';
 import { TagEntity } from 'src/entities/tag.entity';
 import { UserEntity } from 'src/entities/user.entity';
 import { AssetFileType, AssetStatus, AssetType } from 'src/enum';
-import { TimeBucketSize } from 'src/interfaces/asset.interface';
-import { AssetSearchBuilderOptions } from 'src/interfaces/search.interface';
+import { TimeBucketSize } from 'src/repositories/asset.repository';
+import { AssetSearchBuilderOptions } from 'src/repositories/search.repository';
 import { anyUuid, asUuid } from 'src/utils/database';
 import {
   Column,