feat: add file sink classes

Author: John Doe

…utils/src/lib/file-sink-json.int.test.ts …tils/src/lib/file-sink-jsonl.int.test.tspackages/utils/src/lib/file-sink-json.int.test.ts renamed to packages/utils/src/lib/file-sink-jsonl.int.test.ts packages/utils/src/lib/file-sink-json.int.test.ts renamed to packages/utils/src/lib/file-sink-jsonl.int.test.ts

@@ -3,7 +3,7 @@ import * as os from 'node:os';
 import * as path from 'node:path';
 import { afterAll, beforeAll, describe, expect, it } from 'vitest';
 import { teardownTestFolder } from '@code-pushup/test-utils';
-import { JsonlFileSink, recoverJsonlFile } from './file-sink-json.js';
+import { JsonlFileSink, recoverJsonlFile } from './file-sink-jsonl.js';
 
 describe('JsonlFileSink integration', () => {
   const baseDir = path.join(os.tmpdir(), 'file-sink-json-int-tests');

packages/utils/src/lib/file-sink-json.ts packages/utils/src/lib/file-sink-jsonl.tspackages/utils/src/lib/file-sink-json.ts renamed to packages/utils/src/lib/file-sink-jsonl.ts

@@ -7,7 +7,7 @@ import {
   jsonlDecode,
   jsonlEncode,
   recoverJsonlFile,
-} from './file-sink-json.js';
+} from './file-sink-jsonl.js';
 
 describe('jsonlEncode', () => {
   it('should encode object to JSON string', () => {
@@ -207,10 +207,36 @@ describe('JsonlFileSink', () => {
       `${records.map(record => JSON.stringify(record)).join('\n')}\n`,
     );
 
+    sink.repack();
+    expect(fs.readFileSync(filePath, 'utf8')).toBe(
+      `${JSON.stringify(records[0])}\n${JSON.stringify(records[1])}\n`,
+    );
+  });
+
+  it('repack() should accept output path', () => {
+    const filePath = '/tmp/jsonl-repack-test.jsonl';
+    const sink = new JsonlFileSink<JsonObj>({ filePath });
+    const records = [
+      { key: 'value', number: 42 },
+      { key: 'value', number: 42 },
+    ];
+
+    fs.writeFileSync(
+      filePath,
+      `${records.map(record => JSON.stringify(record)).join('\n')}\n`,
+    );
+
     const outputPath = '/tmp/jsonl-repack-output.jsonl';
     sink.repack(outputPath);
     expect(fs.readFileSync(outputPath, 'utf8')).toBe(
       `${JSON.stringify(records[0])}\n${JSON.stringify(records[1])}\n`,
     );
   });
+
+  it('should do nothing on finalize()', () => {
+    const sink = new JsonlFileSink<JsonObj>({
+      filePath: '/tmp/jsonl-finalize-test.jsonl',
+    });
+    expect(() => sink.finalize()).not.toThrow();
+  });
 });

…tils/src/lib/file-sink-json.unit.test.ts …ils/src/lib/file-sink-jsonl.unit.test.tspackages/utils/src/lib/file-sink-json.unit.test.ts renamed to packages/utils/src/lib/file-sink-jsonl.unit.test.ts packages/utils/src/lib/file-sink-json.unit.test.ts renamed to packages/utils/src/lib/file-sink-jsonl.unit.test.ts

@@ -251,6 +251,21 @@ describe('FileSink', () => {
   });
 
   it('repack() should recover records and write them to output path', () => {
+    const mockRecover = vi.fn();
+    const filePath = '/tmp/test-file.txt';
+    const sink = new FileSink({
+      filePath,
+      recover: mockRecover,
+    });
+    const records = ['record1', 'record2'];
+    mockRecover.mockReturnValue({ records, errors: [], partialTail: null });
+
+    sink.repack();
+    expect(mockRecover).toHaveBeenCalled();
+    expect(fs.readFileSync(filePath, 'utf8')).toBe('record1\n\nrecord2\n');
+  });
+
+  it('repack() should accept output path', () => {
     const mockRecover = vi.fn();
     const sink = new FileSink({
       filePath: '/tmp/test-file.txt',