Function buildEffectiveMessageRecords

src/storage/transcript.ts:77–89

(sessionId: string)

}

function buildEffectiveMessageRecords(sessionId: string): EffectiveMessageRecord[] {
  const rows = loadMessageRows(sessionId);
  const messages = rows.map((row) => JSON.parse(row.message_json) as ModelMessage);
  const seqs = rows.map((row) => row.seq);
  const timestamps = rows.map((row) => new Date(row.created_at));
  const transcript = buildEffectiveTranscript(messages, seqs, timestamps, loadLatestCompaction(sessionId));

  return transcript.messages.map((message, index) => ({
    message,
    seq: transcript.seqs[index],
    timestamp: transcript.timestamps[index],
  }));
}

export function loadRawTranscript(sessionId: string): ModelMessage[] {
  return loadMessageRows(sessionId).map((row) => JSON.parse(row.message_json) as ModelMessage);