feat(pager): commit-by-commit review with streaming git log -p

src/core/cli.ts

@@ -72,6 +72,10 @@ function buildCommonOptions(
     wrapLines: resolveBooleanFlag(argv, "--wrap", "--no-wrap"),
     hunkHeaders: resolveBooleanFlag(argv, "--hunk-headers", "--no-hunk-headers"),
     agentNotes: resolveBooleanFlag(argv, "--agent-notes", "--no-agent-notes"),
+    // --no-review forces the timeline-scrolling streaming pager (no daemon, no agent
+    // surface). --review forces the legacy buffered path with full review. Default is
+    // undefined, which lets the pager startup auto-detect log-style input.
+    noReview: resolveBooleanFlag(argv, "--no-review", "--review"),
   };
 }
 
@@ -157,6 +161,10 @@ function renderCliHelp() {
     "  --staged, --cached                      review staged changes",
     "  --exclude-untracked                     hide untracked files in working tree reviews",
     "",
+    "Pager options:",
+    "  --no-review                             scroll-only timeline mode for `git log -p` style input",
+    "  --review                                force the buffered review path with daemon registration",
+    "",
     "Notes:",
     "  Run `hunk <command> --help` for command-specific syntax and options.",
     '  "target" refers to a generic set of changes; it can be a ref (git) or revset (jj)',
@@ -505,7 +513,12 @@ async function parsePagerCommand(
   tokens: string[],
   argv: string[],
 ): Promise<PagerCommandInput | HelpCommandInput> {
-  const command = createCommand("pager", "general Git pager wrapper with diff detection");
+  const command = createCommand("pager", "general Git pager wrapper with diff detection")
+    .option(
+      "--no-review",
+      "scroll-only timeline mode: streaming, no daemon registration, no agent surface",
+    )
+    .option("--review", "force the legacy buffered path with full review surface");
   let parsedOptions: Record<string, unknown> = {};
 
   command.action((options: Record<string, unknown>) => {

src/core/config.ts

@@ -15,6 +15,7 @@ const DEFAULT_VIEW_PREFERENCES: PersistedViewPreferences = {
   wrapLines: false,
   showHunkHeaders: true,
   showAgentNotes: false,
+  commitDetailsMode: "full",
 };
 
 interface ConfigResolutionOptions {
@@ -52,6 +53,11 @@ function normalizeString(value: unknown) {
   return typeof value === "string" && value.length > 0 ? value : undefined;
 }
 
+/** Accept only the three valid commit-details modes. */
+function normalizeCommitDetailsMode(value: unknown): "full" | "compact" | "hidden" | undefined {
+  return value === "full" || value === "compact" || value === "hidden" ? value : undefined;
+}
+
 /** Read the view preferences stored at one TOML object level. */
 function readConfigPreferences(source: Record<string, unknown>): CommonOptions {
   return {
@@ -63,6 +69,7 @@ function readConfigPreferences(source: Record<string, unknown>): CommonOptions {
     wrapLines: normalizeBoolean(source.wrap_lines),
     hunkHeaders: normalizeBoolean(source.hunk_headers),
     agentNotes: normalizeBoolean(source.agent_notes),
+    commitDetailsMode: normalizeCommitDetailsMode(source.commit_details_mode),
   };
 }
 
@@ -81,6 +88,7 @@ function mergeOptions(base: CommonOptions, overrides: CommonOptions): CommonOpti
     wrapLines: overrides.wrapLines ?? base.wrapLines,
     hunkHeaders: overrides.hunkHeaders ?? base.hunkHeaders,
     agentNotes: overrides.agentNotes ?? base.agentNotes,
+    commitDetailsMode: overrides.commitDetailsMode ?? base.commitDetailsMode,
   };
 }
 
@@ -156,6 +164,7 @@ export function resolveConfiguredCliInput(
     wrapLines: DEFAULT_VIEW_PREFERENCES.wrapLines,
     hunkHeaders: DEFAULT_VIEW_PREFERENCES.showHunkHeaders,
     agentNotes: DEFAULT_VIEW_PREFERENCES.showAgentNotes,
+    commitDetailsMode: DEFAULT_VIEW_PREFERENCES.commitDetailsMode,
   };
 
   if (userConfigPath) {
@@ -185,6 +194,8 @@ export function resolveConfiguredCliInput(
     wrapLines: resolvedOptions.wrapLines ?? DEFAULT_VIEW_PREFERENCES.wrapLines,
     hunkHeaders: resolvedOptions.hunkHeaders ?? DEFAULT_VIEW_PREFERENCES.showHunkHeaders,
     agentNotes: resolvedOptions.agentNotes ?? DEFAULT_VIEW_PREFERENCES.showAgentNotes,
+    commitDetailsMode:
+      resolvedOptions.commitDetailsMode ?? DEFAULT_VIEW_PREFERENCES.commitDetailsMode,
   };
 
   return {

src/core/loaders.ts

@@ -11,6 +11,7 @@ import { findAgentFileContext, loadAgentContext } from "./agent";
 import { createSkippedBinaryMetadata, isProbablyBinaryFile, patchLooksBinary } from "./binary";
 import { normalizeDiffMetadataPaths, normalizeDiffPath } from "./diffPaths";
 import { HunkUserError } from "./errors";
+import { stripTerminalControl } from "./streaming/ansi";
 import {
   buildGitDiffArgs,
   buildGitShowArgs,
@@ -55,15 +56,6 @@ function stripPrefixes(path: string) {
   return path.replace(/^[ab]\//, "");
 }
 
-/** Remove terminal escape sequences so Git-colored pager input still parses as plain patch text. */
-function stripTerminalControl(text: string) {
-  return text
-    .replace(/\x1bP[\s\S]*?\x1b\\/g, "")
-    .replace(/\x1b\][\s\S]*?(?:\x07|\x1b\\)/g, "")
-    .replace(/\x1b\[[0-?]*[ -/]*[@-~]/g, "")
-    .replace(/\x1b[@-_]/g, "");
-}
-
 /**
  * Strip `git log -p` / `git show -p` commit metadata so the surviving text
  * is a plain patch stream that `@pierre/diffs` can parse without spamming
@@ -122,6 +114,7 @@ export function stripGitLogMetadata(text: string) {
   return out.join("\n");
 }
 
+
 /** Split a multi-file patch into per-file chunks so each diff file keeps its original patch text. */
 function splitPatchIntoFileChunks(rawPatch: string) {
   const patch = rawPatch.replaceAll("\r\n", "\n");
@@ -208,7 +201,7 @@ interface BuildDiffFileOptions {
 }
 
 /** Build the normalized per-file model used by the UI regardless of input mode. */
-function buildDiffFile(
+export function buildDiffFile(
   metadata: FileDiffMetadata,
   patch: string,
   index: number,
@@ -709,5 +702,6 @@ export async function loadAppBootstrap(
     initialWrapLines: input.options.wrapLines ?? false,
     initialShowHunkHeaders: input.options.hunkHeaders ?? true,
     initialShowAgentNotes: input.options.agentNotes ?? false,
+    initialCommitDetailsMode: input.options.commitDetailsMode ?? "full",
   };
 }

src/core/pager.ts

@@ -1,14 +1,6 @@
 import { spawn, type ChildProcess, type SpawnOptions } from "node:child_process";
 import { once } from "node:events";
-
-/** Remove terminal escape sequences before deciding whether stdin looks like a patch. */
-function stripTerminalControl(text: string) {
-  return text
-    .replace(/\x1bP[\s\S]*?\x1b\\/g, "")
-    .replace(/\x1b\][\s\S]*?(?:\x07|\x1b\\)/g, "")
-    .replace(/\x1b\[[0-?]*[ -/]*[@-~]/g, "")
-    .replace(/\x1b[@-_]/g, "");
-}
+import { stripTerminalControl } from "./streaming/ansi";
 
 /** Detect whether generic pager stdin looks like a diff/patch that Hunk should review. */
 export function looksLikePatchInput(text: string) {

src/core/startup.test.ts

@@ -1,8 +1,21 @@
 import { describe, expect, test } from "bun:test";
 import { HunkUserError } from "./errors";
 import { prepareStartupPlan } from "./startup";
+import type { LineSource } from "./streaming/stdinLines";
 import type { AppBootstrap, CliInput, ParsedCliInput } from "./types";
 
+function lineSourceFromString(text: string): LineSource {
+  // Mirror real stdinLines: split on \n and drop a trailing empty line so a final newline
+  // does not produce a phantom empty line.
+  const lines = text.split("\n");
+  if (lines.length > 0 && lines[lines.length - 1] === "") lines.pop();
+  return {
+    async *[Symbol.asyncIterator]() {
+      for (const line of lines) yield line;
+    },
+  };
+}
+
 function createBootstrap(input: CliInput): AppBootstrap {
   return {
     input,
@@ -70,8 +83,7 @@ describe("startup planning", () => {
 
     const plan = await prepareStartupPlan(["bun", "hunk", "pager"], {
       parseCliImpl: async () => ({ kind: "pager", options: { theme: "paper" } }),
-      readStdinText: async () => "* main\n  feature/demo\n",
-      looksLikePatchInputImpl: () => false,
+      readStdinLines: () => lineSourceFromString("* main\n  feature/demo\n"),
       loadAppBootstrapImpl: async () => {
         loaded = true;
         throw new Error("unreachable");
@@ -82,21 +94,18 @@ describe("startup planning", () => {
     expect(loaded).toBe(false);
   });
 
-  test("normalizes diff-like pager stdin into patch app startup", async () => {
+  test("routes single-changeset pager input through the buffered review path", async () => {
+    // Plain `diff --git` input with no commit headers: auto-detect should NOT trigger,
+    // so the pager runs the legacy buffered path and registers with the daemon as
+    // before. This preserves the agent review surface for `git diff | hunk pager`.
     const seenInputs: CliInput[] = [];
 
     const plan = await prepareStartupPlan(["bun", "hunk", "pager"], {
       parseCliImpl: async () => ({ kind: "pager", options: { theme: "paper" } }),
-      readStdinText: async () => "diff --git a/a.ts b/a.ts\n@@ -1 +1 @@\n-old\n+new\n",
-      looksLikePatchInputImpl: () => true,
-      resolveRuntimeCliInputImpl(input) {
-        seenInputs.push(input);
-        return input;
-      },
-      resolveConfiguredCliInputImpl(input) {
-        seenInputs.push(input);
-        return { input } as never;
-      },
+      readStdinLines: () =>
+        lineSourceFromString("diff --git a/a.ts b/a.ts\n@@ -1 +1 @@\n-old\n+new\n"),
+      resolveRuntimeCliInputImpl: (input) => input,
+      resolveConfiguredCliInputImpl: (input) => ({ input }) as never,
       loadAppBootstrapImpl: async (input) => {
         seenInputs.push(input);
         return createBootstrap(input);
@@ -105,20 +114,115 @@ describe("startup planning", () => {
     });
 
     expect(plan.kind).toBe("app");
-    if (plan.kind !== "app") {
-      throw new Error("Expected app startup plan.");
-    }
+    if (plan.kind !== "app") throw new Error("Expected app startup plan.");
 
     expect(plan.cliInput).toMatchObject({
       kind: "patch",
       file: "-",
       text: "diff --git a/a.ts b/a.ts\n@@ -1 +1 @@\n-old\n+new\n",
-      options: {
-        theme: "paper",
-        pager: true,
+      options: { theme: "paper", pager: true, noReview: undefined },
+    });
+    expect(plan.bootstrap.stream).toBeUndefined();
+    expect(seenInputs).toHaveLength(1);
+  });
+
+  test("auto-routes log-style pager input to commit-by-commit review mode", async () => {
+    // Presence of a `commit <sha>` header in the prefix flips auto-detect to commit-
+    // review: streaming pipeline, daemon-registered, one commit at a time. The agent
+    // surface stays alive on the active commit.
+    const stdin = [
+      "commit abc1234567",
+      "Author: Alice <alice@example.com>",
+      "Date:   2026-01-01",
+      "",
+      "    first commit",
+      "",
+      "diff --git a/a.ts b/a.ts",
+      "@@ -1 +1 @@",
+      "-old",
+      "+new",
+      "",
+    ].join("\n");
+
+    const plan = await prepareStartupPlan(["bun", "hunk", "pager"], {
+      parseCliImpl: async () => ({ kind: "pager", options: {} }),
+      readStdinLines: () => lineSourceFromString(stdin),
+      resolveRuntimeCliInputImpl: (input) => input,
+      resolveConfiguredCliInputImpl: (input) => ({ input }) as never,
+      // Streaming pager bypasses loadAppBootstrap.
+      loadAppBootstrapImpl: async () => {
+        throw new Error("loadAppBootstrap should not be called for log-style pager input");
       },
+      usesPipedPatchInputImpl: () => false,
     });
-    expect(seenInputs).toHaveLength(3);
+
+    expect(plan.kind).toBe("app");
+    if (plan.kind !== "app") throw new Error("Expected app startup plan.");
+
+    // Commit-review default: NOT noReview; review surface stays alive.
+    expect(plan.cliInput.options.noReview).toBeUndefined();
+    expect(plan.cliInput.options.pager).toBe(true);
+    expect(plan.bootstrap.commitReviewStream).toBeDefined();
+    expect(plan.bootstrap.stream).toBeUndefined();
+    expect(plan.bootstrap.changeset.files).toEqual([]);
+    expect(plan.bootstrap.changeset.isStreaming).toBe(true);
+
+    plan.bootstrap.commitReviewStream?.abort();
+  });
+
+  test("--no-review flag forces streaming even on non-log-style input", async () => {
+    const plan = await prepareStartupPlan(["bun", "hunk", "pager"], {
+      parseCliImpl: async () => ({ kind: "pager", options: { noReview: true } }),
+      readStdinLines: () =>
+        lineSourceFromString("diff --git a/a.ts b/a.ts\n@@ -1 +1 @@\n-old\n+new\n"),
+      resolveRuntimeCliInputImpl: (input) => input,
+      resolveConfiguredCliInputImpl: (input) => ({ input }) as never,
+      loadAppBootstrapImpl: async () => {
+        throw new Error("loadAppBootstrap should not be called when --no-review is set");
+      },
+      usesPipedPatchInputImpl: () => false,
+    });
+
+    expect(plan.kind).toBe("app");
+    if (plan.kind !== "app") throw new Error("Expected app startup plan.");
+    expect(plan.cliInput.options.noReview).toBe(true);
+    expect(plan.bootstrap.stream).toBeDefined();
+
+    plan.bootstrap.stream?.abort();
+  });
+
+  test("--review flag forces buffered review path on log-style input", async () => {
+    const stdin = [
+      "commit abc1234567",
+      "Author: A <a@a>",
+      "",
+      "    msg",
+      "",
+      "diff --git a/a.ts b/a.ts",
+      "@@ -1 +1 @@",
+      "-old",
+      "+new",
+      "",
+    ].join("\n");
+
+    const seenInputs: CliInput[] = [];
+    const plan = await prepareStartupPlan(["bun", "hunk", "pager"], {
+      parseCliImpl: async () => ({ kind: "pager", options: { noReview: false } }),
+      readStdinLines: () => lineSourceFromString(stdin),
+      resolveRuntimeCliInputImpl: (input) => input,
+      resolveConfiguredCliInputImpl: (input) => ({ input }) as never,
+      loadAppBootstrapImpl: async (input) => {
+        seenInputs.push(input);
+        return createBootstrap(input);
+      },
+      usesPipedPatchInputImpl: () => false,
+    });
+
+    expect(plan.kind).toBe("app");
+    if (plan.kind !== "app") throw new Error("Expected app startup plan.");
+    expect(plan.cliInput.options.noReview).toBeUndefined();
+    expect(plan.bootstrap.stream).toBeUndefined();
+    expect(seenInputs).toHaveLength(1);
   });
 
   test("rejects watch mode for stdin-backed patch inputs", async () => {