Function emitDiagnostic

src/utils/diagnostics.ts:108–144

(event: {
  level?: DiagnosticLevel;
  phase: string;
  durationMs?: number;
  data?: Record<string, unknown>;
})

}

export function emitDiagnostic(event: {
  level?: DiagnosticLevel;
  phase: string;
  durationMs?: number;
  data?: Record<string, unknown>;
}): void {
  const scope = diagnosticsStorage.getStore();
  if (!scope) return;
  const payload: DiagnosticEvent = {
    ts: new Date().toISOString(),
    level: event.level ?? 'info',
    phase: event.phase,
    session: scope.session,
    requestId: scope.requestId,
    command: scope.command,
    durationMs: event.durationMs,
    data: event.data ? redactDiagnosticData(event.data) : undefined,
  };
  scope.events.push(payload);
  scope.phaseCounts.set(event.phase, (scope.phaseCounts.get(event.phase) ?? 0) + 1);
  if (!scope.debug) return;
  const fileLine = `${JSON.stringify(payload)}\n`;
  try {
    if (scope.logPath) {
      appendDiagnosticLine(scope.logPath, fileLine);
      scope.liveWrittenEventCount = scope.events.length;
    }
    if (scope.traceLogPath) {
      appendDiagnosticLine(scope.traceLogPath, fileLine);
    }
    if (!scope.logPath && !scope.traceLogPath) {
      process.stderr.write(`[agent-device][diag] ${fileLine}`);
    }
  } catch {
    // Best-effort diagnostics should not break request flow.
  }
}

export async function withDiagnosticTimer<T>(
  phase: string,