Function applyDecisionsCommand

src/clawsweeper.ts:16185–17494

(args: Args)

}

async function applyDecisionsCommand(args: Args): Promise<void> {
  repoFromArgs(args);
  const itemsDir = resolve(stringArg(args.items_dir, defaultItemsDir()));
  const closedDir = resolve(stringArg(args.closed_dir, defaultClosedDir()));
  const plansDir = resolve(stringArg(args.plans_dir, defaultPlansDir()));
  const limit = numberArg(args.limit, 20);
  const processedLimit = numberArg(args.processed_limit, Math.max(limit * 2, 50));
  const minAgeDays = numberArg(args.min_age_days, 0);
  const minAgeMinutes = optionalNumberArg(args.min_age_minutes);
  const minAgeMs = minAgeMinutes === undefined ? minAgeDays * DAY_MS : minAgeMinutes * 60 * 1000;
  const minAgeDescription =
    minAgeMinutes === undefined ? `${minAgeDays} days` : `${minAgeMinutes} minutes`;
  const applyKind = applyKindArg(args.apply_kind);
  const applyCloseReasons = closeReasonsArg(args.apply_close_reasons);
  const staleMinAgeDays = numberArg(args.stale_min_age_days, STALE_INSUFFICIENT_INFO_MIN_AGE_DAYS);
  const closeDelayMs = numberArg(args.close_delay_ms, 2_000);
  const progressEvery = Math.max(1, numberArg(args.progress_every, 10));
  const dryRun = boolArg(args.dry_run);
  const syncCommentsOnly = boolArg(args.sync_comments_only);
  const commentSyncMinAgeDays = numberArg(args.comment_sync_min_age_days, 0);
  const maxRuntimeMs = numberArg(args.max_runtime_ms, 0);
  const reportPath = resolve(stringArg(args.report_path, join(ROOT, "apply-report.json")));
  const artifactDir = resolve(stringArg(args.artifact_dir, join(ROOT, "artifacts", "apply")));
  const prCloseCoverageProofRuntime: PrCloseCoverageProofRuntime = {
    model: stringArg(args.codex_model, DEFAULT_CODEX_MODEL),
    reasoningEffort: stringArg(args.codex_reasoning_effort, DEFAULT_REASONING_EFFORT),
    sandboxMode: stringArg(args.codex_sandbox, "read-only"),
    serviceTier: stringArg(args.codex_service_tier, DEFAULT_SERVICE_TIER),
    timeoutMs: numberArg(args.codex_timeout_ms, 600_000),
    workDir: join(artifactDir, "pr-close-coverage-proof"),
    rootDir: ROOT,
    schemaPath: PR_CLOSE_COVERAGE_PROOF_SCHEMA_PATH,
    promptTemplate: prCloseCoverageProofPromptTemplate(),
    ...(process.env.CLAWSWEEPER_PROOF_INSPECTION_TOKEN
      ? { ghToken: process.env.CLAWSWEEPER_PROOF_INSPECTION_TOKEN }
      : {}),
  };
  const startedAtMs = Date.now();
  const requestedItemNumbers = itemNumbersArg(args.item_numbers, args.item_number);
  const requestedItemNumberSet = new Set(requestedItemNumbers);
  const results: ApplyResult[] = [];
  let closedCount = 0;
  let processedCount = 0;
  throttleHeartbeatContext = () =>
    `Progress: ${closedCount}/${limit} fresh closes, ${processedCount}/${processedLimit} processed records in this apply chunk.`;
  const logProgress = (message: string): void => {
    const counts = results.reduce<Record<string, number>>((accumulator, result) => {
      accumulator[result.action] = (accumulator[result.action] ?? 0) + 1;
      return accumulator;
    }, {});
    console.error(
      [
        `[apply] ${new Date().toISOString()} ${message}`,
        `closed=${closedCount}/${limit}`,
        `processed=${processedCount}/${processedLimit}`,
        `counts=${JSON.stringify(counts)}`,
      ].join(" "),
    );