Function createReviewCheckpointManager

src/review-checkpoints.ts:49–112

()

const REVIEW_REF_PREFIX = "refs/devspace/review";

export function createReviewCheckpointManager(): ReviewCheckpointManager {
  const states = new Map<string, WorkspaceReviewState>();

  return {
    async initializeWorkspace({ workspaceId, root }) {
      const refs = reviewRefs(workspaceId);
      const state: WorkspaceReviewState = { root, ...refs };
      states.set(workspaceId, state);

      try {
        const eligibility = await getGitEligibility(root);
        if (!eligibility.ok || !eligibility.gitRoot) {
          state.diagnostic = eligibility.message ?? "show_changes requires a Git workspace in this version.";
          return;
        }

        state.gitRoot = eligibility.gitRoot;
        const commit = await createWorkingTreeSnapshot(eligibility.gitRoot);
        await git(eligibility.gitRoot, ["update-ref", state.openRef, commit]);
        await git(eligibility.gitRoot, ["update-ref", state.baselineRef, commit]);
      } catch (error) {
        state.diagnostic = error instanceof Error ? error.message : String(error);
      }
    },

    async reviewChanges({ workspaceId, root, since = "last_shown", markReviewed = true }) {
      let state = states.get(workspaceId);
      if (!state) {
        await this.initializeWorkspace({ workspaceId, root });
        state = states.get(workspaceId);
      }

      if (!state?.gitRoot) {
        throw new Error(state?.diagnostic ?? "show_changes requires a Git workspace in this version.");
      }

      const baselineRef = since === "workspace_open" ? state.openRef : state.baselineRef;
      const baseline = (await git(state.gitRoot, ["rev-parse", "--verify", `${baselineRef}^{commit}`])).stdout.trim();
      const current = await createWorkingTreeSnapshot(state.gitRoot);
      const patch = (await git(state.gitRoot, ["diff", "--binary", "--no-color", baseline, current], {
        maxBuffer: 50 * 1024 * 1024,
      })).stdout;
      const numstat = (await git(state.gitRoot, ["diff", "--numstat", "-z", baseline, current], {
        maxBuffer: 50 * 1024 * 1024,
      })).stdout;
      const files = parseNumstat(numstat);
      const summary = summarizeFiles(files);

      if (markReviewed) {
        await git(state.gitRoot, ["update-ref", state.baselineRef, current]);
      }

      return {
        result:
          summary.files === 0
            ? `No changes since ${since === "workspace_open" ? "workspace open" : "last shown changes"}.`
            : `Changed ${summary.files} ${summary.files === 1 ? "file" : "files"} (+${summary.additions} -${summary.removals}).`,
        summary,