Function iterOpenCodeEvents

packages/core/src/adapters/opencode.ts:255–300

(logPath: string)

};

async function* iterOpenCodeEvents(logPath: string): AsyncIterable<TranscriptEvent> {
  const parsed = parseLocator(logPath);
  if (!parsed) return;
  const db = openReadonlyDb(parsed.dbPath);
  if (!db) return;
  try {
    if (!tableExists(db, 'message') || !tableExists(db, 'part')) return;
    const rows = db
      .prepare(
        `
      SELECT
        m.id AS message_id,
        json_extract(m.data, '$.role') AS message_role,
        json_extract(m.data, '$.agent') AS message_agent,
        m.time_created AS message_time,
        p.id AS part_id,
        p.time_created AS part_time,
        p.data AS part_data
      FROM message m
      JOIN part p ON p.message_id = m.id
      WHERE m.session_id = ?
      ORDER BY m.time_created ASC, p.time_created ASC, p.id ASC
    `,
      )
      .all(parsed.sessionId) as OpenCodePartRow[];

    let lastMode: string | undefined;
    let lastMessageId: string | undefined;
    for (const row of rows) {
      if (row.message_id !== lastMessageId) {
        lastMessageId = row.message_id;
        const mode =
          typeof row.message_agent === 'string' && row.message_agent
            ? row.message_agent
            : undefined;
        if (mode && mode !== lastMode) {
          yield { ts: row.message_time, kind: 'mode_change', mode, prevMode: lastMode };
          lastMode = mode;
        }
      }
      yield* extractOpenCodePart(row);
    }
  } finally {
    db.close();
  }
}

function* extractOpenCodePart(row: OpenCodePartRow): Generator<TranscriptEvent> {
  const data = safeJsonParse(row.part_data);