Function parseXcodeDatabasesAsync

src/core/parser-xcode.ts:355–388

(xcodeBase: string)

/** Async version with per-conversation yields and non-blocking sqlite3 queries. */
export async function parseXcodeDatabasesAsync(xcodeBase: string): Promise<Session[]> {
  const sessions: Session[] = [];
  const dbFiles = findXcodeDbFiles(xcodeBase);

  // Check sqlite3 is available (neutral cwd — see note on the sync variant).
  try { execFileSync('sqlite3', ['--version'], { encoding: 'utf-8', ...SQLITE_PROBE_OPTS }); }
  catch { return sessions; }

  for (const dbPath of dbFiles) {
    let conversations: XcodeConversationRow[];
    try {
      const raw = await sqliteQueryAsync(dbPath, 'SELECT id, title, createdAt, updatedAt FROM Conversation');
      if (!raw.trim()) continue;
      conversations = JSON.parse(raw) as XcodeConversationRow[];
    } catch { continue; }

    for (const conv of conversations) {
      if (!/^[\w-]+$/.test(conv.id)) continue;

      let turns: XcodeTurnRow[];
      try {
        turns = await sqliteQueryTurnsAsync(dbPath, conv.id);
      } catch { continue; }

      const session = buildXcodeSession(conv, turns);
      if (session) sessions.push(session);

      // Yield between conversations so the event loop stays responsive
      await new Promise<void>(r => setTimeout(r, 0));
    }
  }

  return sessions;
}