Function fetchAdapters

scripts/fetch-adapters.js:101–279

()

}

export function fetchAdapters() {
  const currentVersion = getPackageVersion();
  const oldManifest = readManifest();

  // Skip if already installed at the same version (unless forced via OPENCLI_FETCH=1)
  const isForced = process.env.OPENCLI_FETCH === '1';
  if (!isForced && currentVersion !== 'unknown' && oldManifest?.version === currentVersion) {
    log(`Adapters already up to date (v${currentVersion})`);
    return;
  }

  if (!existsSync(BUILTIN_CLIS)) {
    log('Warning: clis/ not found in package — skipping adapter copy');
    return;
  }

  const newOfficialFiles = new Set(walkFiles(BUILTIN_CLIS));
  const oldOfficialFiles = new Set(oldManifest?.files ?? []);
  const rawHashes = oldManifest?.hashes;
  // Guard against corrupted manifest: if hashes is a non-object type (string, number,
  // array), skip sync to avoid false-positive "changed" detection that deletes overrides.
  // null/undefined are treated as empty (old manifests may lack the field).
  if (rawHashes != null && (typeof rawHashes !== 'object' || Array.isArray(rawHashes))) {
    log('Warning: adapter-manifest.json has corrupted hashes — skipping sync. Will fix on next run.');
    return;
  }
  const oldHashes = rawHashes ?? {};
  mkdirSync(USER_CLIS_DIR, { recursive: true });

  // 1. Compute new hashes and detect which sites have changes
  const newHashes = {};
  const siteFiles = new Map(); // site -> [relPath, ...]
  for (const relPath of newOfficialFiles) {
    const src = join(BUILTIN_CLIS, relPath);
    const srcHash = fileHash(src);
    newHashes[relPath] = srcHash;

    const site = relPath.split('/')[0];
    if (!siteFiles.has(site)) siteFiles.set(site, []);
    siteFiles.get(site).push(relPath);
  }

  // Determine which sites have any changed/new/removed files
  const changedSites = new Set();
  for (const [site, files] of siteFiles) {
    for (const relPath of files) {
      if (oldHashes[relPath] !== newHashes[relPath]) {
        changedSites.add(site);
        break;
      }
    }
  }
  // Also mark sites that had files removed
  for (const relPath of oldOfficialFiles) {
    if (!newOfficialFiles.has(relPath)) {
      changedSites.add(relPath.split('/')[0]);
    }
  }