Function flushDiagnosticsToSessionFile

src/utils/diagnostics.ts:175–207

(options: { force?: boolean } = {})

}

export function flushDiagnosticsToSessionFile(options: { force?: boolean } = {}): string | null {
  const scope = diagnosticsStorage.getStore();
  if (!scope) return null;
  if (!options.force && !scope.debug && !scope.flushOnSuccess) return null;
  if (scope.events.length === 0) return null;

  try {
    if (scope.logPath) {
      const pendingEvents = scope.events.slice(scope.liveWrittenEventCount);
      if (pendingEvents.length > 0) {
        const lines = pendingEvents.map((entry) => JSON.stringify(redactDiagnosticData(entry)));
        appendDiagnosticLine(scope.logPath, `${lines.join('\n')}\n`);
      }
      const logPath = scope.logPath;
      scope.events = [];
      scope.liveWrittenEventCount = 0;
      return logPath;
    }

    const sessionDir = sanitizePathPart(scope.session ?? 'default');
    const dayDir = new Date().toISOString().slice(0, 10);
    const baseDir = path.join(os.homedir(), '.agent-device', 'logs', sessionDir, dayDir);
    fs.mkdirSync(baseDir, { recursive: true });
    const timestamp = new Date().toISOString().replace(/[:.]/g, '-');
    const filePath = path.join(baseDir, `${timestamp}-${scope.diagnosticId}.ndjson`);
    const lines = scope.events.map((entry) => JSON.stringify(redactDiagnosticData(entry)));
    fs.writeFileSync(filePath, `${lines.join('\n')}\n`);
    scope.events = [];
    return filePath;
  } catch {
    return null;
  }
}

function sanitizePathPart(value: string): string {
  return value.replace(/[^a-zA-Z0-9._-]/g, '_');