refactor: split profiler base/node

Author: BioPhoton

packages/utils/src/lib/profiler/profiler.int.test.ts

@@ -1,7 +1,5 @@
-import { MockTraceEventFileSink } from '../../../mocks/sink.mock.js';
-import type { PerformanceEntryEncoder } from '../performance-observer.js';
 import type { ActionTrackEntryPayload } from '../user-timing-extensibility-api.type.js';
-import { NodejsProfiler, Profiler } from './profiler.js';
+import { Profiler } from './profiler.js';
 
 describe('Profiler Integration', () => {
   let profiler: Profiler<Record<string, ActionTrackEntryPayload>>;
@@ -297,169 +295,3 @@ describe('Profiler Integration', () => {
     expect(performance.getEntriesByType('measure')).toHaveLength(0);
   });
 });
-
-describe('NodeJS Profiler Integration', () => {
-  const simpleEncoder: PerformanceEntryEncoder<string> = entry => {
-    if (entry.entryType === 'measure') {
-      return [`${entry.name}:${entry.duration.toFixed(2)}ms`];
-    }
-    return [];
-  };
-
-  let mockSink: MockTraceEventFileSink;
-  let nodejsProfiler: NodejsProfiler<string>;
-
-  beforeEach(() => {
-    mockSink = new MockTraceEventFileSink();
-
-    nodejsProfiler = new NodejsProfiler({
-      prefix: 'test',
-      track: 'test-track',
-      sink: mockSink,
-      encodePerfEntry: simpleEncoder,
-      enabled: true,
-    });
-  });
-
-  it('should initialize with sink opened when enabled', () => {
-    expect(mockSink.isClosed()).toBeFalse();
-    expect(nodejsProfiler.isEnabled()).toBeTrue();
-    expect(mockSink.open).toHaveBeenCalledOnce();
-  });
-
-  it('should create performance entries and write to sink', () => {
-    expect(nodejsProfiler.measure('test-operation', () => 'success')).toBe(
-      'success',
-    );
-  });
-
-  it('should handle async operations', async () => {
-    await expect(
-      nodejsProfiler.measureAsync('async-test', async () => {
-        await new Promise(resolve => setTimeout(resolve, 1));
-        return 'async-result';
-      }),
-    ).resolves.toBe('async-result');
-  });
-
-  it('should disable profiling and close sink', () => {
-    nodejsProfiler.setEnabled(false);
-    expect(nodejsProfiler.isEnabled()).toBeFalse();
-    expect(mockSink.isClosed()).toBeTrue();
-    expect(mockSink.close).toHaveBeenCalledOnce();
-
-    expect(nodejsProfiler.measure('disabled-test', () => 'success')).toBe(
-      'success',
-    );
-
-    expect(mockSink.getWrittenItems()).toHaveLength(0);
-  });
-
-  it('should re-enable profiling correctly', () => {
-    nodejsProfiler.setEnabled(false);
-    nodejsProfiler.setEnabled(true);
-
-    expect(nodejsProfiler.isEnabled()).toBeTrue();
-    expect(mockSink.isClosed()).toBeFalse();
-    expect(mockSink.open).toHaveBeenCalledTimes(2);
-
-    expect(nodejsProfiler.measure('re-enabled-test', () => 42)).toBe(42);
-  });
-
-  it('should support custom tracks', () => {
-    const profilerWithTracks = new NodejsProfiler({
-      prefix: 'api-server',
-      track: 'HTTP',
-      tracks: {
-        db: { track: 'Database', color: 'secondary' },
-        cache: { track: 'Cache', color: 'primary' },
-      },
-      sink: mockSink,
-      encodePerfEntry: simpleEncoder,
-    });
-
-    expect(
-      profilerWithTracks.measure('user-lookup', () => 'user123', {
-        track: 'cache',
-      }),
-    ).toBe('user123');
-  });
-
-  it('should capture buffered entries when buffered option is enabled', () => {
-    const bufferedProfiler = new NodejsProfiler({
-      prefix: 'buffered-test',
-      track: 'Test',
-      sink: mockSink,
-      encodePerfEntry: simpleEncoder,
-      captureBufferedEntries: true,
-      enabled: true,
-    });
-
-    const bufferedStats = bufferedProfiler.stats;
-    expect(bufferedStats.state).toBe('running');
-    expect(bufferedStats.walOpen).toBeTrue();
-    expect(bufferedStats.isSubscribed).toBeTrue();
-    expect(bufferedStats.queued).toBe(0);
-    expect(bufferedStats.dropped).toBe(0);
-    expect(bufferedStats.written).toBe(0);
-
-    bufferedProfiler.setEnabled(false);
-  });
-
-  it('should return correct getStats with dropped and written counts', () => {
-    const statsProfiler = new NodejsProfiler({
-      prefix: 'stats-test',
-      track: 'Stats',
-      sink: mockSink,
-      encodePerfEntry: simpleEncoder,
-      maxQueueSize: 2,
-      flushThreshold: 2,
-      enabled: true,
-    });
-
-    expect(statsProfiler.measure('test-op', () => 'result')).toBe('result');
-
-    const stats = statsProfiler.stats;
-    expect(stats.state).toBe('running');
-    expect(stats.walOpen).toBeTrue();
-    expect(stats.isSubscribed).toBeTrue();
-    expect(typeof stats.queued).toBe('number');
-    expect(typeof stats.dropped).toBe('number');
-    expect(typeof stats.written).toBe('number');
-
-    statsProfiler.setEnabled(false);
-  });
-
-  it('should provide comprehensive queue statistics via getStats', () => {
-    const profiler = new NodejsProfiler({
-      prefix: 'stats-profiler',
-      track: 'Stats',
-      sink: mockSink,
-      encodePerfEntry: simpleEncoder,
-      maxQueueSize: 3,
-      flushThreshold: 2,
-      enabled: true,
-    });
-
-    const initialStats = profiler.stats;
-    expect(initialStats.state).toBe('running');
-    expect(initialStats.walOpen).toBeTrue();
-    expect(initialStats.isSubscribed).toBeTrue();
-    expect(initialStats.queued).toBe(0);
-    expect(initialStats.dropped).toBe(0);
-    expect(initialStats.written).toBe(0);
-
-    profiler.measure('operation-1', () => 'result1');
-    profiler.measure('operation-2', () => 'result2');
-    profiler.flush();
-    expect(profiler.stats.written).toBe(0);
-
-    profiler.setEnabled(false);
-
-    const finalStats = profiler.stats;
-    expect(finalStats.state).toBe('idle');
-    expect(finalStats.walOpen).toBeFalse();
-    expect(finalStats.isSubscribed).toBeFalse();
-    expect(finalStats.queued).toBe(0);
-  });
-});