Function createFrameAuditLogger

packages/node/src/frameAudit.ts:248–301

(scope: string)

}>;

export function createFrameAuditLogger(scope: string): FrameAuditLogger {
  if (!FRAME_AUDIT_ENABLED) {
    return Object.freeze({
      enabled: false,
      emit: () => {},
    });
  }

  const writeLine = (line: string): void => {
    try {
      if (FRAME_AUDIT_LOG_PATH !== null) {
        appendFileSync(FRAME_AUDIT_LOG_PATH, `${line}\n`, "utf8");
        if (!FRAME_AUDIT_STDERR_MIRROR) {
          return;
        }
      } else if (!FRAME_AUDIT_STDERR_MIRROR) {
        return;
      }
      process.stderr.write(`${line}\n`);
    } catch {
      // Optional diagnostics must never affect runtime behavior.
    }
  };
  const g = globalThis as {
    __reziFrameAuditSink?: (line: string) => void;
    __reziFrameAuditContext?: () => Readonly<Record<string, unknown>>;
  };
  if (typeof g.__reziFrameAuditSink !== "function") {
    g.__reziFrameAuditSink = writeLine;
  }

  return Object.freeze({
    enabled: true,
    emit: (stage: string, fields: AuditRecord = Object.freeze({})) => {
      try {
        const context =
          typeof g.__reziFrameAuditContext === "function" ? g.__reziFrameAuditContext() : null;
        const line = JSON.stringify({
          ts: new Date().toISOString(),
          tUs: nowUs(),
          pid: process.pid,
          layer: "node",
          scope,
          stage,
          ...(context ?? {}),
          ...fields,
        });
        writeLine(line);
      } catch {
        // Optional diagnostics must never affect runtime behavior.
      }
    },
  });
}