Function buildChannelReleasePlan

packages/bumpy/src/core/prerelease.ts:125–185

(
  stablePlan: ReleasePlan,
  channel: ResolvedChannel,
  packages: Map<string, WorkspacePackage>,
  rootDir: string,
  opts: {
    /**
     * Display mode (release PR titles/bodies, status output): compute counters but
     * skip the published-from-HEAD checks — the numbers are advisory narrative and
     * the registry wins at actual publish time.
     */
    forDisplay?: boolean;
  } = {},
)

 * gitHead equal to HEAD (or, for non-npm packages, its tag points at HEAD), the package
 * was already published from this exact commit — it is skipped rather than re-counted.
 */
export async function buildChannelReleasePlan(
  stablePlan: ReleasePlan,
  channel: ResolvedChannel,
  packages: Map<string, WorkspacePackage>,
  rootDir: string,
  opts: {
    /**
     * Display mode (release PR titles/bodies, status output): compute counters but
     * skip the published-from-HEAD checks — the numbers are advisory narrative and
     * the registry wins at actual publish time.
     */
    forDisplay?: boolean;
  } = {},
): Promise<ChannelReleasePlanResult> {
  const headSha = tryRunArgs(['git', 'rev-parse', 'HEAD'], { cwd: rootDir });
  const warnings: string[] = [...stablePlan.warnings];
  const alreadyPublished: Array<{ name: string; version: string }> = [];
  const releases: PlannedRelease[] = [];

  await Promise.all(
    stablePlan.releases.map(async (release) => {
      const pkg = packages.get(release.name);
      if (!pkg) return;
      // Unpublishable packages can't participate in a registry-consumable cycle
      if (pkg.private && !pkg.bumpy?.publishCommand) return;

      const target = release.newVersion; // stable target from the bump files
      const state = await getPublishedPrereleaseState(pkg, target, channel.preid, rootDir);

      if (state.stablePublished) {
        warnings.push(
          `${release.name}@${target} is already published as a stable release — ` +
            `merge ${target}'s release into the "${channel.branch}" branch so the cycle retargets.`,
        );
      }

      if (!opts.forDisplay && state.counters.length > 0 && headSha) {
        const latest = `${target}-${channel.preid}.${Math.max(...state.counters)}`;
        const publishedFromHead = usesNpmRegistry(pkg)
          ? (await fetchGitHead(pkg.name, latest, pkg.bumpy?.registry)) === headSha
          : tryRunArgs(['git', 'rev-parse', `refs/tags/${pkg.name}@${latest}`], { cwd: rootDir }) === headSha;
        if (publishedFromHead) {
          alreadyPublished.push({ name: release.name, version: latest });
          return;
        }
      }

      releases.push({
        ...release,
        newVersion: nextPrereleaseVersion(target, channel.preid, state.counters),
      });
    }),
  );

  releases.sort((a, b) => a.name.localeCompare(b.name));
  return {
    plan: { bumpFiles: stablePlan.bumpFiles, releases, warnings },