Function main

packages/scripts/maintenance/sync-metadata.ts:252–370

()

}

async function main() {
  // `--reject` is a bookkeeping operation, not a sync: record and stop.
  if (REJECTED.length) {
    if (!REASON) {
      console.error("--reject requires --reason (an unexplained override is unmaintainable)");
      process.exit(1);
    }
    for (const target of REJECTED) {
      const [slug, field] = target.split(":");
      if (!slug || !field) {
        console.error(`--reject expects <slug>:<field>, got "${target}"`);
        process.exit(1);
      }
      const entry = listStacks("hub", [slug])[0];
      if (!entry) {
        console.error(`unknown app: ${slug}`);
        process.exit(1);
      }
      // Pin the rejection to the value upstream reports right now, so a later,
      // different value is surfaced again instead of being silently swallowed.
      const result = await syncEntry(entry).catch(() => null);
      const upstream = result?.suggestions.find((s) => s.field === field);
      recordRejection(slug, field, String(upstream?.to ?? ""), REASON);
      console.log(`recorded: ${slug}.${field} stays curated (${REASON})`);
    }
    console.log(`updated ${OVERRIDES_FILE}`);
    return;
  }

  const stacks = listStacks("hub", ONLY);
  if (!stacks.length) {
    console.error("no stacks matched");
    process.exit(1);
  }
  console.error(
    `syncing metadata for ${stacks.length} stacks (concurrency ${CONCURRENCY})${
      CHECK ? " [check only]" : ""
    }`
  );

  let done = 0;
  const results = await pool(stacks, CONCURRENCY, async (entry) => {
    let result: Result;
    try {
      result = await syncEntry(entry);
    } catch (e) {
      result = {
        slug: entry.slug,
        changes: [],
        suggestions: [],
        notes: [`error: ${(e as Error).message}`],
      };
    }
    done++;
    if (done % 25 === 0) console.error(`  ${done}/${stacks.length}`);
    return result;
  });