Function appendTranscriptEvent

notfair-cmo/src/server/sessions/index.ts:123–153

(
  session_id: string,
  kind: TranscriptEvent["kind"],
  payload: unknown,
)

}

export function appendTranscriptEvent(
  session_id: string,
  kind: TranscriptEvent["kind"],
  payload: unknown,
): void {
  const db = getDb();
  const seqRow = db
    .prepare("SELECT COALESCE(MAX(seq), 0) + 1 AS next FROM transcript_events WHERE session_id = ?")
    .get(session_id) as { next: number };
  const id = randomUUID();
  const seq = seqRow.next;
  const created_at = new Date().toISOString();
  const payload_json = JSON.stringify(payload);
  db.prepare(
    "INSERT INTO transcript_events (id, session_id, seq, kind, payload_json, created_at) VALUES (?, ?, ?, ?, ?, ?)",
  ).run(id, session_id, seq, kind, payload_json, created_at);
  // Push to live subscribers AFTER the INSERT commits. Inline import to
  // keep this module free of the live-events dependency at module load —
  // matters for the migration tests that don't want EventEmitter eagerness.
  // eslint-disable-next-line @typescript-eslint/no-require-imports
  const { publishSessionEvent } =
    require("@/server/live-events/emitter") as typeof import("@/server/live-events/emitter");
  publishSessionEvent(session_id, {
    id,
    session_id,
    seq,
    kind,
    payload_json,
    created_at,
  });
}

export function listTranscriptEvents(
  session_id: string,