Function runTelemetryTest

tests/e2e/telemetry.test.ts:161–234

(
    killFn: (ctx: TestContext) => void,
    spawnOptions?: SpawnOptions,
  )

describe('Telemetry E2E', () => {
  async function runTelemetryTest(
    killFn: (ctx: TestContext) => void,
    spawnOptions?: SpawnOptions,
  ): Promise<void> {
    const mockContext = await startMockServer();
    const ctx: TestContext = {
      mockServer: mockContext,
    };

    try {
      ctx.process = spawn(
        process.execPath,
        [
          SERVER_PATH,
          '--usage-statistics',
          '--headless',
          `--clearcutEndpoint=http://127.0.0.1:${mockContext.port}`,
          '--clearcutForceFlushIntervalMs=10',
          '--clearcutIncludePidHeader',
        ],
        {
          stdio: ['pipe', 'pipe', 'pipe'],
          env: {
            ...process.env,
            CI: undefined,
            CHROME_DEVTOOLS_MCP_NO_USAGE_STATISTICS: undefined,
          },
          ...spawnOptions,
        },
      );

      const startEvent = await Promise.race([
        mockContext.waitForEvent(e => e.server_start !== undefined),
        new Promise((_, reject) =>
          setTimeout(
            () => reject(new Error('Timeout waiting for server_start')),
            10000,
          ),
        ),
      ]);
      assert.ok(startEvent, 'server_start event not received');

      // Now that we received an event, we should have the Watchdog PID
      const watchdogPid = mockContext.watchdogPid;
      assert.ok(watchdogPid, 'Watchdog PID not captured from headers');

      // Assert Watchdog is actually running
      assert.strictEqual(
        isProcessAlive(watchdogPid),
        true,
        'Watchdog process should be running',
      );

      // Trigger shutdown
      killFn(ctx);

      // Verify shutdown event
      const shutdownEvent = await Promise.race([