Function writeDryRun

scripts/migration/service-split-postgres-cli.ts:490–553

(planInput: MigrationInput)

};

const writeDryRun = (planInput: MigrationInput): void => {
  const plan = planMigration({
    ...planInput,
    collectPolicyErrors: true,
    orphanPolicyMode: "retarget_all",
  });
  const neverWiden = verifyPolicyRewriteNeverWidens(plan, planInput);
  const r2Copies = plan.orgs
    .filter((org) => !org.completed && org.hardErrors.length === 0)
    .flatMap((org) =>
      org.blobCopies
        .filter((copy) => copy.backend === "external")
        .map((copy) => ({
          tenantHash: org.tenantHash,
          tenant: org.tenant,
          sourceKey: copy.sourceObjectName,
          destKey: copy.targetObjectName,
        })),
    );
  mkdirSync(outputDir, { recursive: true });
  for (const org of plan.orgs) {
    writeFileSync(`${outputDir}/org-${org.tenantHash}.md`, renderOrgDiff(org));
  }
  writeFileSync(`${outputDir}/r2-copy-manifest.json`, `${JSON.stringify(r2Copies, null, 2)}\n`);
  writeFileSync(
    `${outputDir}/summary.md`,
    `${renderSummary(plan)}\npolicy_never_widen=${neverWiden.ok}\npolicy_never_widen_checked=${neverWiden.checkedPolicies}\nr2_copy_manifest=${outputDir}/r2-copy-manifest.json\nr2_copy_count=${r2Copies.length}\nr2_copy_command=wrangler r2 object get <bucket>/<sourceKey> | wrangler r2 object put <bucket>/<destKey> --pipe\n`,
  );
  console.log(renderSummary(plan));
  console.log(`policy_never_widen=${neverWiden.ok}`);
  console.log(`policy_never_widen_checked=${neverWiden.checkedPolicies}`);
  console.log(`r2_copy_manifest=${outputDir}/r2-copy-manifest.json`);
  console.log(`r2_copy_count=${r2Copies.length}`);
  console.log(
    "r2_copy_command=wrangler r2 object get <bucket>/<sourceKey> | wrangler r2 object put <bucket>/<destKey> --pipe",
  );
  console.log(`diff_dir=${outputDir}`);
  if (!neverWiden.ok) {
    throw new Error(
      `Policy rewrite failed coverage checks: widened=${neverWiden.widened.length}, narrowed=${neverWiden.narrowed.length}`,
    );
  }
  if (
    plan.summary.integrationsMissingSpecBlob > 0 ||
    plan.summary.integrationsMissingDefsBlob > 0
  ) {
    throw new Error(
      `Serving blob check failed: missing spec=${plan.summary.integrationsMissingSpecBlob}, missing defs=${plan.summary.integrationsMissingDefsBlob}`,
    );
  }
  const zeroOperationIntegrations = plan.orgs
    .filter((org) => !org.completed && org.hardErrors.length === 0)
    .flatMap((org) => org.integrations)
    .filter(
      (integration) =>
        integration.servingState.operationsToBuild === 0 &&
        !integration.servingState.expectedZeroOperations,
    );