Function recordDiagnosticEvent

apps/desktop/src/main/snapshots-db.ts:531–578

(
  db: Database,
  input: DiagnosticEventInput,
  now: () => number = Date.now,
)

}

export function recordDiagnosticEvent(
  db: Database,
  input: DiagnosticEventInput,
  now: () => number = Date.now,
): number {
  return mutateStore(db, (data) => {
    const ts = now();
    const recent = data.diagnosticEvents
      .filter(
        (event) =>
          event.fingerprint === input.fingerprint && event.ts > ts - DIAGNOSTIC_DEDUP_WINDOW_MS,
      )
      .sort((a, b) => b.ts - a.ts || b.id - a.id)[0];
    if (recent !== undefined) {
      const idx = data.diagnosticEvents.findIndex((event) => event.id === recent.id);
      if (idx >= 0) {
        const current = data.diagnosticEvents[idx];
        if (current === undefined) return recent.id;
        data.diagnosticEvents[idx] = {
          ...current,
          ts,
          transient: current.transient || input.transient,
          count: current.count + 1,
        };
      }
      return recent.id;
    }

    const id =
      data.diagnosticEvents.reduce((max, event) => (event.id > max ? event.id : max), 0) + 1;
    data.diagnosticEvents.push({
      id,
      schemaVersion: 1,
      ts,
      level: input.level,
      code: input.code,
      scope: input.scope,
      runId: input.runId,
      fingerprint: input.fingerprint,
      message: input.message,
      stack: input.stack,
      transient: input.transient,
      count: 1,
      context: input.context,
    });
    return id;
  });
}

export function getDiagnosticEventById(db: Database, id: number): DiagnosticEventRow | undefined {
  const row = readStore(db).diagnosticEvents.find((event) => event.id === id);