test(worker): gate test utility diagnostic logs

worker/src/testing/__tests__/test-utils.test.ts

@@ -0,0 +1,47 @@
+import { describe, expect, it, vi } from 'bun:test';
+import { createMockLogCollector, createMockTrace } from '../test-utils';
+
+describe('worker test utilities', () => {
+  it('only mirrors trace and log events to console when test diagnostics are enabled', async () => {
+    const previousDebugValue = process.env.SENTRIS_DEBUG_TESTS;
+    const logSpy = vi.spyOn(console, 'log').mockImplementation(() => {});
+
+    try {
+      delete process.env.SENTRIS_DEBUG_TESTS;
+
+      createMockTrace().record({
+        type: 'NODE_STARTED',
+        nodeRef: 'node-1',
+        message: 'started',
+      });
+      await createMockLogCollector().append({
+        level: 'info',
+        message: 'hello',
+      });
+
+      expect(logSpy).not.toHaveBeenCalled();
+
+      process.env.SENTRIS_DEBUG_TESTS = '1';
+
+      createMockTrace().record({
+        type: 'NODE_COMPLETED',
+        nodeRef: 'node-2',
+        message: 'finished',
+      });
+      await createMockLogCollector().append({
+        level: 'warn',
+        message: 'careful',
+      });
+
+      expect(logSpy).toHaveBeenCalledWith('TRACE:', 'NODE_COMPLETED', 'node-2', 'finished');
+      expect(logSpy).toHaveBeenCalledWith('LOG:', 'warn', 'careful');
+    } finally {
+      logSpy.mockRestore();
+      if (previousDebugValue === undefined) {
+        delete process.env.SENTRIS_DEBUG_TESTS;
+      } else {
+        process.env.SENTRIS_DEBUG_TESTS = previousDebugValue;
+      }
+    }
+  });
+});

worker/src/testing/test-utils.ts

@@ -1,6 +1,10 @@
 import { vi } from 'bun:test';
 import { ExecutionContext, ISecretsService } from '@sentris/component-sdk';
 
+function shouldMirrorTestDiagnostics(): boolean {
+  return process.env.SENTRIS_DEBUG_TESTS === '1';
+}
+
 export function createMockExecutionContext(
   overrides: Partial<ExecutionContext> = {},
 ): ExecutionContext {
@@ -49,7 +53,9 @@ export function createMockTrace(): any {
   return {
     record: vi.fn().mockImplementation((event) => {
       events.push(event);
-      console.log('TRACE:', event.type, event.nodeRef, event.message);
+      if (shouldMirrorTestDiagnostics()) {
+        console.log('TRACE:', event.type, event.nodeRef, event.message);
+      }
     }),
     flush: vi.fn().mockResolvedValue(undefined),
     setRunMetadata: vi.fn(),
@@ -63,7 +69,9 @@ export function createMockLogCollector(): any {
   return {
     append: vi.fn().mockImplementation((log) => {
       logs.push(log);
-      console.log('LOG:', log.level, log.message);
+      if (shouldMirrorTestDiagnostics()) {
+        console.log('LOG:', log.level, log.message);
+      }
       return Promise.resolve();
     }),
     flush: vi.fn().mockResolvedValue(undefined),