Function parseXcodeDatabases

src/core/parser-xcode.ts:306–352

(xcodeBase: string)

}

export function parseXcodeDatabases(xcodeBase: string): Session[] {
  const sessions: Session[] = [];
  const dbFiles = findXcodeDbFiles(xcodeBase);

  // Check sqlite3 is available (neutral cwd so the bare name can't resolve
  // against an attacker-controlled workspace dir — see the query calls above).
  try { execFileSync('sqlite3', ['--version'], { encoding: 'utf-8', ...SQLITE_PROBE_OPTS }); }
  catch (e) {
    console.debug('sqlite3 not available, skipping Xcode parsing:', e instanceof Error ? e.message : e);
    return sessions;
  }

  for (const dbPath of dbFiles) {
    let conversations: XcodeConversationRow[];
    try {
      const raw = sqliteQuery(dbPath, 'SELECT id, title, createdAt, updatedAt FROM Conversation');
      if (!raw.trim()) continue;
      conversations = JSON.parse(raw) as XcodeConversationRow[];
    } catch (e) {
      console.debug(`Failed to parse conversations from ${dbPath}:`, e instanceof Error ? e.message : e);
      continue;
    }

    for (const conv of conversations) {
      // Validate conversation ID to prevent SQL injection
      if (!/^[\w-]+$/.test(conv.id)) continue;

      let turns: XcodeTurnRow[];
      try {
        const raw = sqliteQuery(dbPath,
          `SELECT rowID, id, role, data, createdAt FROM Turn WHERE conversationID = ${sqlQuote(conv.id)} ORDER BY rowID`);
        if (!raw.trim()) continue;
        turns = JSON.parse(raw) as XcodeTurnRow[];
      } catch (e) {
        console.debug(`Failed to parse turns for conversation ${conv.id}:`, e instanceof Error ? e.message : e);
        continue;
      }

      const session = buildXcodeSession(conv, turns, (turnId, error) => {
        console.debug(`Failed to parse turn data for turn ${turnId}:`, error instanceof Error ? error.message : error);
      });
      if (session) sessions.push(session);
    }
  }

  return sessions;
}

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