Skip to content

Commit 3fe6871

Browse files
committed
refactor: wip arc
1 parent dfb43be commit 3fe6871

File tree

10 files changed

+681
-348
lines changed

10 files changed

+681
-348
lines changed

packages/utils/src/lib/file-sink-json-trace.int.test.ts

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@ import * as os from 'node:os';
33
import * as path from 'node:path';
44
import { afterAll, beforeAll, describe, expect, it } from 'vitest';
55
import { teardownTestFolder } from '@code-pushup/test-utils';
6-
import { TraceFileSink } from './file-sink-json-trace.js';
7-
import type { TraceEvent } from './trace-file.type';
6+
import { FileSinkJsonTrace } from './file-sink-json-trace';
7+
import type { CompleteEvent, TraceEvent } from './trace-file.type';
88

99
describe('TraceFileSink integration', () => {
1010
const baseDir = path.join(os.tmpdir(), 'file-sink-json-trace-int-tests');
@@ -52,7 +52,7 @@ describe('TraceFileSink integration', () => {
5252
];
5353

5454
it('should write and read trace events', async () => {
55-
const sink = new TraceFileSink({
55+
const sink = new FileSinkJsonTrace({
5656
filename: 'test-data',
5757
directory: baseDir,
5858
});
@@ -83,7 +83,7 @@ describe('TraceFileSink integration', () => {
8383
});
8484

8585
it('should recover events from JSONL file', async () => {
86-
const sink = new TraceFileSink({
86+
const sink = new FileSinkJsonTrace({
8787
filename: 'test-data',
8888
directory: baseDir,
8989
});
@@ -98,7 +98,7 @@ describe('TraceFileSink integration', () => {
9898
});
9999

100100
it('should handle empty trace files', async () => {
101-
const sink = new TraceFileSink({
101+
const sink = new FileSinkJsonTrace({
102102
filename: 'empty-test',
103103
directory: baseDir,
104104
});
@@ -123,7 +123,7 @@ describe('TraceFileSink integration', () => {
123123
customData: { key: 'value' },
124124
};
125125

126-
const sink = new TraceFileSink({
126+
const sink = new FileSinkJsonTrace({
127127
filename: 'metadata-test',
128128
directory: baseDir,
129129
metadata,
@@ -151,7 +151,7 @@ describe('TraceFileSink integration', () => {
151151
cat: 'test',
152152
};
153153

154-
const sink = new TraceFileSink({
154+
const sink = new FileSinkJsonTrace({
155155
filename: 'single-event-test',
156156
directory: baseDir,
157157
});
@@ -169,7 +169,7 @@ describe('TraceFileSink integration', () => {
169169
});
170170

171171
it('should handle events with complex args', async () => {
172-
const complexEvent: TraceEvent = {
172+
const complexEvent: CompleteEvent = {
173173
name: 'complexEvent',
174174
ts: 456,
175175
ph: 'X',
@@ -180,7 +180,7 @@ describe('TraceFileSink integration', () => {
180180
},
181181
};
182182

183-
const sink = new TraceFileSink({
183+
const sink = new FileSinkJsonTrace({
184184
filename: 'complex-args-test',
185185
directory: baseDir,
186186
});
@@ -196,15 +196,15 @@ describe('TraceFileSink integration', () => {
196196
(e: any) => e.name === 'complexEvent',
197197
);
198198
expect(eventInTrace).toBeDefined();
199-
expect(eventInTrace.args.detail).toStrictEqual(
200-
'{"nested":{"data":[1,2,3]}}',
201-
);
199+
expect(eventInTrace.args.detail).toStrictEqual({
200+
nested: { data: [1, 2, 3] },
201+
});
202202
expect(eventInTrace.args.data.url).toBe('https://example.com');
203203
});
204204

205205
it('should handle non-existent directories gracefully', async () => {
206206
const nonExistentDir = path.join(baseDir, 'non-existent');
207-
const sink = new TraceFileSink({
207+
const sink = new FileSinkJsonTrace({
208208
filename: 'non-existent-dir-test',
209209
directory: nonExistentDir,
210210
});

0 commit comments

Comments
 (0)