Function computeDirMetasAsync

src/core/cache.ts:193–236

(logsDirs: string[])

 * Processes workspace directories in parallel batches.
 */
export async function computeDirMetasAsync(logsDirs: string[]): Promise<DirMetas> {
  const metas: DirMetas = {};
  const CONCURRENCY = 64;

  // Collect all workspace paths first
  const wsPaths: string[] = [];
  for (const logsDir of logsDirs) {
    if (logsDir.includes(path.join('.config', 'github-copilot', 'xcode')) ||
        logsDir.includes(path.join('.copilot', 'session-state')) ||
        logsDir.includes(path.join('.copilot', 'history-session-state'))) continue;
    try {
      const entries = await fs.promises.readdir(logsDir, { withFileTypes: true });
      for (const e of entries) {
        if (!e.isDirectory()) continue;
        wsPaths.push(path.join(logsDir, e.name));
      }
    } catch { /* cannot read logsDir */ }
  }

  // Process in parallel batches
  for (let i = 0; i < wsPaths.length; i += CONCURRENCY) {
    const batch = wsPaths.slice(i, i + CONCURRENCY);
    const results = await Promise.allSettled(
      batch.map(async wsPath => {
        const [chat, edit] = await Promise.all([
          dirFingerprintAsync(path.join(wsPath, 'chatSessions')),
          dirFingerprintAsync(path.join(wsPath, 'chatEditingSessions'), true),
        ]);
        return { wsPath, chat, edit };
      })
    );
    for (const r of results) {
      if (r.status === 'fulfilled') {
        metas[r.value.wsPath] = {
          chatCount: r.value.chat.count,
          chatMaxMtime: r.value.chat.mtime,
          editCount: r.value.edit.count,
          editMaxMtime: r.value.edit.mtime,
        };
      }
    }
  }
  return metas;
}

/* ---- Diff helpers ---- */