github-mirrors/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2026-05-18 03:10:24 +03:00
Code Issues Packages Projects Releases Wiki Activity

chore: fmt

Browse Source
This commit is contained in:
izzy
2026-01-06 14:25:38 +00:00
parent c4c5358ef7
commit 06ee275202
1 changed files with 77 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files
e2e/src/api/specs/integrity.e2e-spec.ts
+77 -79
View File
@@ -4,7 +4,7 @@ import {
LoginResponseDto, LoginResponseDto,
ManualJobName, ManualJobName,
QueueCommand, QueueCommand,
QueueName QueueName,
} from '@immich/sdk'; } from '@immich/sdk';
import { readFile } from 'node:fs/promises'; import { readFile } from 'node:fs/promises';
import { app, testAssetDir, utils } from 'src/utils'; import { app, testAssetDir, utils } from 'src/utils';
@@ -28,17 +28,17 @@ describe('/admin/integrity', () => {
beforeAll(async () => { beforeAll(async () => {
await utils.resetDatabase(); await utils.resetDatabase();
admin = await utils.adminSetup(); admin = await utils.adminSetup();
user1 = await utils.userSetup(admin.accessToken, { user1 = await utils.userSetup(admin.accessToken, {
email: '1@example.com', email: '1@example.com',
name: '1', name: '1',
password: '1' password: '1',
}); });
user2 = await utils.userSetup(admin.accessToken, { user2 = await utils.userSetup(admin.accessToken, {
email: '2@example.com', email: '2@example.com',
name: '2', name: '2',
password: '2' password: '2',
}); });
for (const queue of Object.values(QueueName)) { for (const queue of Object.values(QueueName)) {
@@ -46,9 +46,9 @@ describe('/admin/integrity', () => {
continue; continue;
} }
await utils.queueCommand(admin.accessToken, queue, { await utils.queueCommand(admin.accessToken, queue, {
command: QueueCommand.Pause command: QueueCommand.Pause,
}); });
} }
}); });
@@ -76,19 +76,19 @@ describe('/admin/integrity', () => {
await utils.mkFolder('/data/bak'); await utils.mkFolder('/data/bak');
await utils.copyFolder(`/data/upload/${admin.userId}`, `/data/bak/${admin.userId}`); await utils.copyFolder(`/data/upload/${admin.userId}`, `/data/bak/${admin.userId}`);
for (const queue of Object.values(QueueName)) { for (const queue of Object.values(QueueName)) {
if (queue === QueueName.IntegrityCheck) { if (queue === QueueName.IntegrityCheck) {
continue; continue;
} }
await utils.queueCommand(admin.accessToken, queue, { await utils.queueCommand(admin.accessToken, queue, {
command: QueueCommand.Empty command: QueueCommand.Empty,
}); });
await utils.queueCommand(admin.accessToken, queue, { await utils.queueCommand(admin.accessToken, queue, {
command: QueueCommand.Resume command: QueueCommand.Resume,
}); });
} }
}); });
@@ -176,36 +176,33 @@ describe('/admin/integrity', () => {
); );
}); });
it.sequential( it.sequential('should delete orphan files (job: delete all orphan file reports)', async () => {
'should delete orphan files (job: delete all orphan file reports)', await utils.putTextFile('orphan', `/data/upload/${admin.userId}/orphan1.png`);
async () => {
await utils.putTextFile('orphan', `/data/upload/${admin.userId}/orphan1.png`);
await utils.createJob(admin.accessToken, { await utils.createJob(admin.accessToken, {
name: ManualJobName.IntegrityOrphanFiles, name: ManualJobName.IntegrityOrphanFiles,
}); });
await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck); await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck);
await utils.createJob(admin.accessToken, { await utils.createJob(admin.accessToken, {
name: ManualJobName.IntegrityOrphanFilesDeleteAll, name: ManualJobName.IntegrityOrphanFilesDeleteAll,
}); });
await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck); await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck);
const { status, body } = await request(app) const { status, body } = await request(app)
.get('/admin/integrity/summary') .get('/admin/integrity/summary')
.set('Authorization', `Bearer ${admin.accessToken}`) .set('Authorization', `Bearer ${admin.accessToken}`)
.send(); .send();
expect(status).toBe(200); expect(status).toBe(200);
expect(body).toEqual( expect(body).toEqual(
expect.objectContaining({ expect.objectContaining({
orphan_file: 0, orphan_file: 0,
}), }),
); );
}, });
);
it.sequential('should detect a missing file and not a checksum mismatch (job: check missing files)', async () => { it.sequential('should detect a missing file and not a checksum mismatch (job: check missing files)', async () => {
await utils.deleteFolder(`/data/upload/${admin.userId}`); await utils.deleteFolder(`/data/upload/${admin.userId}`);
@@ -251,52 +248,51 @@ describe('/admin/integrity', () => {
); );
}); });
it.sequential( it.sequential('should delete assets with missing files (job: delete all missing file reports)', async () => {
'should delete assets with missing files (job: delete all missing file reports)', await utils.deleteFolder(`/data/upload/${user1.userId}`);
async () => {
await utils.deleteFolder(`/data/upload/${user1.userId}`);
await utils.createJob(admin.accessToken, { await utils.createJob(admin.accessToken, {
name: ManualJobName.IntegrityMissingFiles, name: ManualJobName.IntegrityMissingFiles,
}); });
await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck); await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck);
const { status: listStatus, body: listBody } = await request(app) const { status: listStatus, body: listBody } = await request(app)
.get('/admin/integrity/summary') .get('/admin/integrity/summary')
.set('Authorization', `Bearer ${admin.accessToken}`) .set('Authorization', `Bearer ${admin.accessToken}`)
.send(); .send();
expect(listStatus).toBe(200); expect(listStatus).toBe(200);
expect(listBody).toEqual( expect(listBody).toEqual(
expect.objectContaining({ expect.objectContaining({
missing_file: 1, missing_file: 1,
}), }),
); );
await utils.createJob(admin.accessToken, { await utils.createJob(admin.accessToken, {
name: ManualJobName.IntegrityMissingFilesDeleteAll, name: ManualJobName.IntegrityMissingFilesDeleteAll,
}); });
await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck); await utils.waitForQueueFinish(admin.accessToken, QueueName.IntegrityCheck);
const { status, body } = await request(app) const { status, body } = await request(app)
.get('/admin/integrity/summary') .get('/admin/integrity/summary')
.set('Authorization', `Bearer ${admin.accessToken}`) .set('Authorization', `Bearer ${admin.accessToken}`)
.send(); .send();
expect(status).toBe(200); expect(status).toBe(200);
expect(body).toEqual( expect(body).toEqual(
expect.objectContaining({ expect.objectContaining({
missing_file: 0, missing_file: 0,
}), }),
); );
await expect(utils.getAssetInfo(user1.accessToken, asset1.id)).resolves.toEqual(expect.objectContaining({ await expect(utils.getAssetInfo(user1.accessToken, asset1.id)).resolves.toEqual(
isTrashed: true expect.objectContaining({
})); isTrashed: true,
}, }),
); );
});
it.sequential('should detect a checksum mismatch (job: check file checksums)', async () => { it.sequential('should detect a checksum mismatch (job: check file checksums)', async () => {
await utils.truncateFolder(`/data/upload/${admin.userId}`); await utils.truncateFolder(`/data/upload/${admin.userId}`);
@@ -381,9 +377,11 @@ describe('/admin/integrity', () => {
}), }),
); );
await expect(utils.getAssetInfo(user2.accessToken, asset2.id)).resolves.toEqual(expect.objectContaining({ await expect(utils.getAssetInfo(user2.accessToken, asset2.id)).resolves.toEqual(
isTrashed: true expect.objectContaining({
})); isTrashed: true,
}),
);
}, },
); );
}); });