fix

server/test/db/index.ts

@@ -3,6 +3,7 @@ import { dataSource } from '@app/infra';
 export const db = {
   reset: async () => {
     if (!dataSource.isInitialized) {
+      console.log('Initializing test database...');
       await dataSource.initialize();
     }
 

server/test/e2e/formats.e2e-spec.ts

@@ -1,5 +1,6 @@
 import { JobService, LoginResponseDto } from '@app/domain';
 import { AppModule } from '@app/immich/app.module';
+import { RedisIoAdapter } from '@app/infra';
 import { LibraryType } from '@app/infra/entities';
 import { INestApplication, Logger } from '@nestjs/common';
 import { Test, TestingModule } from '@nestjs/testing';
@@ -31,6 +32,8 @@ describe('File format (e2e)', () => {
 
     app = moduleFixture.createNestApplication();
 
+    app.useWebSocketAdapter(new RedisIoAdapter(app));
+
     await app.init();
     app.enableShutdownHooks();
     server = app.getHttpServer();
@@ -40,6 +43,14 @@ describe('File format (e2e)', () => {
     await moduleFixture.get(MicroAppService).init(true);
   });
 
+  afterAll(async () => {
+    console.log(await jobService.getAllJobsStatus());
+    await jobService.obliterateAll(true);
+    await app.close();
+    await moduleFixture.close();
+    await db.disconnect();
+  });
+
   beforeEach(async () => {
     // We expect https://github.com/etnoy/immich-test-assets to be cloned into the e2e/assets folder
 
@@ -66,13 +77,19 @@ describe('File format (e2e)', () => {
 
     const assets = await api.assetApi.getAllAssets(server, admin.accessToken);
     expect(assets).toHaveLength(1);
+    console.log(assets);
+    const jpgAsset = assets[0];
+    expect(jpgAsset.type).toBe('image/jpeg');
+    expect(jpgAsset.originalFileName).toBe('el_torcal_rocks');
+    expect(jpgAsset.exifInfo?.exifImageHeight).toBe(341);
+    expect(jpgAsset.exifInfo?.exifImageWidth).toBe(512);
   });
 
-  it('should import a heic file', async () => {
+  it('should import a jpeg file', async () => {
     const library = await api.libraryApi.createLibrary(server, admin.accessToken, {
       type: LibraryType.EXTERNAL,
       name: 'Library',
-      importPaths: [`${__dirname}/../assets/formats/heic`],
+      importPaths: [`${__dirname}/../assets/formats/jpeg`],
       exclusionPatterns: [],
     });
 
@@ -85,11 +102,25 @@ describe('File format (e2e)', () => {
     console.log(assets);
   });
 
-  afterAll(async () => {
-    console.log(await jobService.getAllJobsStatus());
-    await jobService.obliterateAll(true);
-    await app.close();
-    await moduleFixture.close();
-    await db.disconnect();
+  it('should import a heic file', async () => {
+    const library = await api.libraryApi.createLibrary(server, admin.accessToken, {
+      type: LibraryType.EXTERNAL,
+      name: 'Library',
+      importPaths: [`${__dirname}/../assets/formats/heic`],
+      exclusionPatterns: [],
+    });
+
+    await api.libraryApi.scanLibrary(server, admin.accessToken, library.id, {});
+
+    await waitForQueues(jobService);
+
+    const assets = await api.assetApi.getAllAssets(server, admin.accessToken);
+    expect(assets).toHaveLength(1);
+    const heicAsset = assets[0];
+    console.log(heicAsset);
+    expect(heicAsset.type).toBe('image/heic');
+    expect(heicAsset.originalFileName).toBe('IMG_2682');
+    expect(heicAsset.duration).toBe(null);
+    expect(heicAsset.fileCreatedAt).toBe('2029-03-21T11:04:00.000Z');
   });
 });

server/test/e2e/library2.e2e-spec.ts

@@ -1,5 +1,6 @@
 import { JobService, LoginResponseDto } from '@app/domain';
 import { AppModule } from '@app/immich/app.module';
+import { RedisIoAdapter } from '@app/infra';
 import { LibraryType } from '@app/infra/entities';
 import { INestApplication, Logger } from '@nestjs/common';
 import { Test, TestingModule } from '@nestjs/testing';
@@ -31,6 +32,8 @@ describe('Library queue e2e', () => {
 
     app = moduleFixture.createNestApplication();
 
+    app.useWebSocketAdapter(new RedisIoAdapter(app));
+
     await app.init();
     app.enableShutdownHooks();
     server = app.getHttpServer();
@@ -40,6 +43,13 @@ describe('Library queue e2e', () => {
     await moduleFixture.get(MicroAppService).init(true);
   });
 
+  afterAll(async () => {
+    await jobService.obliterateAll(true);
+    await app.close();
+    await moduleFixture.close();
+    await db.disconnect();
+  });
+
   describe('can import library', () => {
     beforeEach(async () => {
       // We expect https://github.com/etnoy/immich-test-assets to be cloned into the e2e/assets folder
@@ -87,11 +97,4 @@ describe('Library queue e2e', () => {
       expect(assets[0].originalFileName).toBe('silver_fir');
     });
   });
-
-  afterAll(async () => {
-    await jobService.obliterateAll(true);
-    await app.close();
-    await moduleFixture.close();
-    await db.disconnect();
-  });
 });