Function applyArtifactsCommand

src/clawsweeper.ts:18042–18096

(args: Args)

}

function applyArtifactsCommand(args: Args): void {
  repoFromArgs(args);
  const artifactDir = resolve(stringArg(args.artifact_dir, "artifacts"));
  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 skipReconcile = boolArg(args.skip_reconcile);
  const replayClosedArtifacts = boolArg(args.replay_closed_artifacts);
  const maxPages = numberArg(args.max_pages, 250);
  const openNumbers = skipReconcile ? null : fetchOpenItemNumbers(maxPages).numbers;
  let appliedArtifacts = 0;
  let skippedClosedArtifacts = 0;
  ensureDir(itemsDir);
  ensureDir(closedDir);
  if (existsSync(artifactDir)) {
    for (const entry of readdirSync(artifactDir, { recursive: true })) {
      const name = String(entry);
      if (!name.endsWith(".md")) continue;
      const source = join(artifactDir, name);
      if (!parseReportFileName(basename(source))) continue;
      const number = numberForMarkdownFile(basename(source));
      const markdown = readFileSync(source, "utf8");
      if (!isMarkdownForActiveRepo(markdown, basename(source))) continue;
      const destinationFile = reportFileName(
        markdownRepository(markdown, basename(source)),
        number,
      );
      const action = frontMatterValue(markdown, "action_taken") ?? "unknown";
      const destination = reviewArtifactDestination(
        action,
        replayClosedArtifacts || artifactTargetIsOpen(number, openNumbers),
      );
      if (destination === "skip_closed") {
        skippedClosedArtifacts += 1;
        continue;
      }
      const destinationDir = destination === "closed" ? closedDir : itemsDir;
      const stalePath = join(destinationDir === itemsDir ? closedDir : itemsDir, destinationFile);
      if (existsSync(stalePath)) unlinkSync(stalePath);
      const reportPath = join(destinationDir, destinationFile);
      writeFileSync(reportPath, markdown, "utf8");
      if (destination === "closed") {
        const planPath = workPlanPathForReport(reportPath, plansDir);
        if (existsSync(planPath)) unlinkSync(planPath);
      } else {
        syncWorkPlanFromReport({ markdown, reportPath, plansDir });
      }
      appliedArtifacts += 1;
    }
  }
  console.error(
    `[apply-artifacts] applied=${appliedArtifacts} skipped_closed=${skippedClosedArtifacts}`,
  );
  if (!skipReconcile) reconcileFolders({ itemsDir, closedDir, plansDir });
}

function artifactTargetIsOpen(number: number, openNumbers: Set<number> | null): boolean {
  if (openNumbers) return openNumbers.has(number);