Function main

scripts/live-github-steward-proof.js:283–351

()

}

async function main() {
  const args = parseArgs(process.argv.slice(2));
  if (args.help) {
    console.log(usage());
    return;
  }

  const owner = gh(['api', 'user', '--jq', '.login']);
  const workDir = path.join(os.tmpdir(), args.repoName);
  fs.rmSync(workDir, { recursive: true, force: true });
  fs.mkdirSync(workDir, { recursive: true });

  console.log(`workDir=${workDir}`);
  setupInitialRepo(workDir, args);
  const repoUrl = createGitHubRepo(workDir, owner, args.repoName, args.visibility);
  console.log(`repo=${repoUrl}`);
  protectMain(owner, args.repoName);
  console.log('protected main with strict ci status checks');

  const createdPrs = [];
  for (let number = 1; number <= args.firstReady; number += 1) {
    const pr = createAgentPr(workDir, owner, args.repoName, number);
    createdPrs.push(pr);
    console.log(`created PR ${number}: ${pr.prUrl}`);
  }

  const transcript = [];
  for (let cycle = 1; cycle <= args.maxCycles; cycle += 1) {
    if (cycle === 3) {
      for (let number = args.firstReady + 1; number <= args.totalPrs; number += 1) {
        const pr = createAgentPr(workDir, owner, args.repoName, number);
        createdPrs.push(pr);
        console.log(`created PR ${number}: ${pr.prUrl}`);
      }
    }

    let result;
    try {
      result = runStewardCycle(workDir, cycle);
    } catch (error) {
      transcript.push({ cycle, error: error.message });
      throw error;
    }
    const entry = {
      cycle,
      outcome: result.outcome,
      statuses: result.queue.map((item) => ({ id: item.id, status: item.status, reason: item.reason || null })),
    };
    transcript.push(entry);
    console.log(`cycle ${cycle}: ${result.outcome.action}${result.outcome.item ? ` ${result.outcome.item}` : ''}`);

    const landed = result.queue.filter((item) => item.status === 'landed').length;
    if (result.queue.length === args.totalPrs && landed === args.totalPrs) {
      console.log(`all ${args.totalPrs} PRs landed at cycle ${cycle}`);
      break;
    }
    await sleep(args.pollMs);
  }