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

refactor: use makeStream instead of inline generator

Browse Source 
Signed-off-by: izzy <me@insrt.uk>
This commit is contained in:
izzy
2026-02-06 17:28:24 +00:00
parent 08fb19b5b7
commit bbcb6b8247
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/integrity.service.spec.ts
+5 -5
View File
@@ -3,7 +3,7 @@ import { Readable } from 'node:stream';
import { text } from 'node:stream/consumers'; import { text } from 'node:stream/consumers';
import { AssetStatus, IntegrityReportType, JobName, JobStatus } from 'src/enum'; import { AssetStatus, IntegrityReportType, JobName, JobStatus } from 'src/enum';
import { IntegrityService } from 'src/services/integrity.service'; import { IntegrityService } from 'src/services/integrity.service';
import { newTestService, ServiceMocks } from 'test/utils'; import { makeStream, newTestService, ServiceMocks } from 'test/utils';
describe(IntegrityService.name, () => { describe(IntegrityService.name, () => {
let sut: IntegrityService; let sut: IntegrityService;
@@ -46,16 +46,16 @@ describe(IntegrityService.name, () => {
describe('getIntegrityReportCsv', () => { describe('getIntegrityReportCsv', () => {
it('gets report as csv', async () => { it('gets report as csv', async () => {
mocks.integrityReport.streamIntegrityReports.mockReturnValue( mocks.integrityReport.streamIntegrityReports.mockReturnValue(
(function* () { makeStream([
yield { {
id: 'id', id: 'id',
createdAt: new Date(0), createdAt: new Date(0),
path: '/path/to/file', path: '/path/to/file',
type: IntegrityReportType.ChecksumFail, type: IntegrityReportType.ChecksumFail,
assetId: null, assetId: null,
fileAssetId: null, fileAssetId: null,
}; },
})() as never, ]),
); );
await expect(text(sut.getIntegrityReportCsv(IntegrityReportType.ChecksumFail))).resolves.toMatchInlineSnapshot(` await expect(text(sut.getIntegrityReportCsv(IntegrityReportType.ChecksumFail))).resolves.toMatchInlineSnapshot(`