analyze.ts

import { openDb, resolveProjectDir, runAnalysis } from "@procni/core";
import { join } from "node:path";
import { resolveProject } from "../lib/resolveProject.js";
import { resolveProviderOrThrow } from "../lib/resolveProvider.js";

export interface AnalyzeOpportunity {
  id: number;
  title: string;
  summary: string;
  score: number;
}

export interface AnalyzeResult {
  analysisRunId: number;
  opportunities: AnalyzeOpportunity[];
}

/**
 * `procni analyze` — a synchronous, one-shot terminal command distinct from
 * the job-queue path `procni dev`'s web UI uses (see
 * `packages/core/src/pipeline/README.md` for why `runAnalysis` has two
 * callers rather than one). Blocking here is fine: a CLI command is expected
 * to run to completion, unlike an HTTP request.
 */
export async function runAnalyzeCommand(
  cwd: string,
  onStageStart?: (stage: string) => void,
): Promise<AnalyzeResult> {
  const { repoRoot, config } = await resolveProject(cwd);
  const { provider, model } = await resolveProviderOrThrow();

  const db = openDb(join(resolveProjectDir(repoRoot), "procni.db"));
  try {
    const result = await runAnalysis(db, {
      repoRoot,
      projectName: config.name,
      ai: provider,
      model,
      triggeredBy: "cli",
      ...(onStageStart ? { onStageStart: (stage: string) => onStageStart(stage) } : {}),
    });

    return {
      analysisRunId: result.analysisRunId,
      opportunities: result.opportunities.map((o) => ({ id: o.id, title: o.title, summary: o.summary, score: o.score })),
    };
  } finally {
    await db.destroy();
  }
}