amwebexpert
diff --git a/‎.claude/hooks/block-force-push.gate.ts‎
Lines changed: 1 addition & 0 deletions b/‎.claude/hooks/block-force-push.gate.ts‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎ai-orchestrator/orchestrator.ts‎
Lines changed: 22 additions & 19 deletions b/‎ai-orchestrator/orchestrator.ts‎
Lines changed: 22 additions & 19 deletions
diff --git a/‎ai-orchestrator/plan.json‎
Lines changed: 78 additions & 22 deletions b/‎ai-orchestrator/plan.json‎
Lines changed: 78 additions & 22 deletions
diff --git a/‎ai-orchestrator/utils/agent-logger.utils.ts‎
Lines changed: 55 additions & 2 deletions b/‎ai-orchestrator/utils/agent-logger.utils.ts‎
Lines changed: 55 additions & 2 deletions
@@ -3,6 +3,7 @@
  */
 
 import { execSync } from "node:child_process";
+
 import { deny, PreToolUseInput, readStdinJson } from "./hooks-common.ts";
 
 const PROTECTED_BRANCHES = ["main", "master", "develop"];
 
@@ -1,12 +1,12 @@
+import { isNotBlank } from "@lichens-innovation/ts-common";
 import { logger } from "@lichens-innovation/ts-common/logger";
 import { z } from "zod";
 
-import { isNotBlank } from "@lichens-innovation/ts-common";
 import { setAgentLogDir } from "./utils/agent-logger.utils.ts";
 import { loadPrompt, runAgent, runTypedAgent } from "./utils/agent.utils.ts";
 import type { Issue, IssueWorktreeResult, OrchestratorOptions } from "./utils/orchestrator.types.ts";
 import { Plan } from "./utils/plan.ts";
-import { deleteBranch, hasCommits, withWorktree } from "./utils/worktree.utils.ts";
+import { deleteBranch, getCurrentHead, hasCommits, withWorktree } from "./utils/worktree.utils.ts";
 
 const plannerOutputSchema = z.object({
   issues: z.array(z.object({ id: z.string(), blockedBy: z.array(z.string()) })),
@@ -29,6 +29,9 @@ interface DeleteImplementationBranchesResult {
   failed: string[];
 }
 
+// parallelization limit since this is getting costly to run in parallel
+const MAX_PARALLEL_UNBLOCKED_IMPLEMENTERS = 2;
+
 export class Orchestrator {
   private readonly repoDir: string;
   private readonly maxIterations: number;
@@ -42,12 +45,14 @@ export class Orchestrator {
   }
 
   async run(): Promise<void> {
+    const initialHead = getCurrentHead({ repoDir: this.repoDir });
+
     for (let iteration = 1; iteration <= this.maxIterations; iteration++) {
       logger.info(`\n=== Iteration ${iteration}/${this.maxIterations} ===\n`);
 
       this.plan.load();
       await this.runPlanningPhase();
-      const unblockedIssues = this.plan.getUnblocked();
+      const unblockedIssues = this.plan.getUnblocked(MAX_PARALLEL_UNBLOCKED_IMPLEMENTERS);
 
       if (unblockedIssues.length === 0) {
         this.logNoUnblockedIssuesStatus();
@@ -66,6 +71,7 @@ export class Orchestrator {
     }
 
     if (this.plan.remainingAfkIssues.length === 0) {
+      await this.runReviewPhase(initialHead);
       await this.cleanupImplementationBranches();
     }
 
@@ -107,7 +113,7 @@ export class Orchestrator {
       options: {
         cwd: this.repoDir,
         model: "claude-opus-4-7",
-        maxTurns: 5,
+        maxTurns: 20,
         permissionMode: "bypassPermissions",
       },
     });
@@ -119,7 +125,7 @@ export class Orchestrator {
     logger.info("Planning complete.");
   }
 
-  private async implementAndReviewIssue(issue: Issue): Promise<IssueWorktreeResult> {
+  private async implementIssue(issue: Issue): Promise<IssueWorktreeResult> {
     const branch = this.getBranchName(issue.id);
 
     return withWorktree({
@@ -129,12 +135,9 @@ export class Orchestrator {
         await this.runImplementAgent({ issue, branch, worktreePath });
 
         if (!hasCommits({ branch, repoDir: this.repoDir })) {
-          logger.info(`  ${issue.id}: no commits produced, skipping review`);
           return { issue, hasProducedCommits: false };
         }
 
-        await this.runReviewAgent({ issue, branch, worktreePath });
-
         return { issue, hasProducedCommits: true };
       },
     });
@@ -162,26 +165,26 @@ export class Orchestrator {
     });
   }
 
-  private async runReviewAgent({ issue, branch, worktreePath }: IssueWorktreeParams): Promise<void> {
-    logger.info(`  ${issue.id}: reviewing code changes`);
+  private async runReviewPhase(initialHead: string): Promise<void> {
+    logger.info("Running review phase...");
 
     await runAgent({
       prompt: loadPrompt({
         name: "review.md",
-        substitutions: { BRANCH: branch, SOURCE_BRANCH: "HEAD" },
+        substitutions: { BRANCH: "HEAD", SOURCE_BRANCH: initialHead },
       }),
-      label: `review:${issue.id}`,
+      label: "review",
       options: {
-        cwd: worktreePath,
+        cwd: this.repoDir,
         model: "claude-sonnet-4-6",
-        maxTurns: 10,
+        maxTurns: 100,
         permissionMode: "bypassPermissions",
       },
     });
   }
 
   private async runImplementationPhase(unblockedIssues: Issue[]): Promise<Issue[]> {
-    const settled = await Promise.allSettled(unblockedIssues.map((issue) => this.implementAndReviewIssue(issue)));
+    const settled = await Promise.allSettled(unblockedIssues.map((issue) => this.implementIssue(issue)));
 
     for (const [index, outcome] of settled.entries()) {
       if (outcome.status === "rejected") {
@@ -200,7 +203,7 @@ export class Orchestrator {
 
   private async runMergePhase(completedIssues: Issue[]): Promise<void> {
     const completedBranches = completedIssues.map((issue) => this.getBranchName(issue.id));
-    logger.info(`\n${completedBranches.length} branch(es) ready to merge.`);
+    logger.info(`${completedBranches.length} branch(es) ready to merge.`);
 
     const { merged, failed } = await runTypedAgent({
       prompt: loadPrompt({
@@ -215,7 +218,7 @@ export class Orchestrator {
       options: {
         cwd: this.repoDir,
         model: "claude-sonnet-4-6",
-        maxTurns: 20,
+        maxTurns: 100,
         permissionMode: "bypassPermissions",
       },
     });
@@ -225,9 +228,9 @@ export class Orchestrator {
     }
     this.plan.save();
 
-    logger.info(`Merged: ${merged.length === 0 ? "none" : merged.join(", ")}`);
+    logger.info(`\tMerged: ${merged.length === 0 ? "none" : merged.join(", ")}`);
     if (failed.length > 0) {
-      logger.info(`Failed to merge: ${failed.join(", ")}`);
+      logger.info(`\tFailed to merge: ${failed.join(", ")}`);
     }
   }
 
 
@@ -1,47 +1,103 @@
 [
   {
-    "id": "scaffold_route",
-    "title": "Scaffold /diff route, sidebar entry, and home card",
-    "whatToBuild": "Add a /diff route to the router, a sidebar menu item, and a home screen card. The screen renders a placeholder (empty div or 'Coming soon' text). Navigation to /diff works end-to-end.",
+    "id": "route_and_tab_shell",
+    "title": "Register /base64/image route and Image URI tab entry",
+    "whatToBuild": "Add a /base64/image child route to the router and a { key: '/base64/image', label: 'Image URI' } entry to TAB_ITEMS in the base64 tab container. The route renders a placeholder component. Navigating to /#/base64/image works end-to-end and the tab is visible in the tab bar.",
     "acceptanceCriteria": [
-      "Navigating to /#/diff renders the diff-viewer screen without errors",
-      "Sidebar shows a Diff Viewer entry that links to /diff",
-      "Home screen shows a Diff Viewer card that navigates to /diff"
+      "Navigating to /#/base64/image renders without errors",
+      "An 'Image URI' tab appears in the /base64 tab bar alongside String and File",
+      "Clicking the tab navigates to /base64/image",
+      "The /base64 index redirect to /base64/string is unchanged"
     ],
     "blockedBy": [],
     "type": "AFK",
     "passes": true,
     "isPlanned": true
   },
   {
-    "id": "core_diff_view",
-    "title": "Two-panel text input with live side-by-side diff",
-    "whatToBuild": "Install react-diff-viewer-continued. Create the Zustand store (original, modified text). Render two labeled textareas ('Original' / 'Modified') and a live side-by-side diff below using useDeferredValue for performance. Diff updates on every keystroke. Line numbers are shown in both panels.",
+    "id": "data_uri_parsing_utils",
+    "title": "Pure data URI parsing utilities and unit tests",
+    "whatToBuild": "Implement base64-image.utils.ts with three pure functions: parseDataUri (regex-extracts mimeType, base64, ext from a raw string, returns null for non-matching input), isImageMimeType (checks against VALID_IMAGE_TYPES from image.utils.ts), and mimeToExt (maps MIME type to file extension, falls back to the MIME subtype segment). Co-locate base64-image.utils.test.ts with parametrised vitest cases for all three functions.",
     "acceptanceCriteria": [
-      "Typing in either textarea updates the diff output live",
-      "Diff renders side-by-side with 'Original' on the left and 'Modified' on the right",
-      "Line numbers are visible in both panels",
-      "Added lines are highlighted green, removed lines red"
+      "parseDataUri returns { mimeType, base64, ext } for a well-formed image data URI",
+      "parseDataUri returns null for empty string, plain text, and malformed data URIs",
+      "isImageMimeType returns true for all VALID_IMAGE_TYPES entries and false for application/pdf and audio/mp3",
+      "mimeToExt returns the correct extension for all mapped MIME types and a sensible fallback for unknown ones",
+      "All test cases use it.each and follow the AAA pattern",
+      "npx vitest run passes with no failures"
+    ],
+    "blockedBy": [],
+    "type": "AFK",
+    "passes": true,
+    "isPlanned": true
+  },
+  {
+    "id": "persisted_textarea_input",
+    "title": "Textarea wired to persisted Zustand store",
+    "whatToBuild": "Implement base64-image.store.ts with a single inputText field persisted to localStorage via zustand/middleware, mirroring the base64-string store pattern. Render a full-width textarea in base64-image.tsx bound to the store. The input survives page navigation and browser refresh.",
+    "acceptanceCriteria": [
+      "Pasting text into the textarea updates inputText in the store",
+      "Navigating away and back to /base64/image restores the previously pasted text",
+      "Refreshing the page restores the previously pasted text",
+      "The textarea is full-width with monospace font, consistent with other base64 tab inputs"
+    ],
+    "blockedBy": [
+      "route_and_tab_shell"
+    ],
+    "type": "AFK",
+    "passes": true,
+    "isPlanned": true
+  },
+  {
+    "id": "live_image_preview",
+    "title": "Constrained image rendered live from a valid image data URI",
+    "whatToBuild": "Wire parseDataUri and isImageMimeType into base64-image.tsx. When the input is a valid image data URI, render an <img> element with max-width: 100% and max-height: 60vh. The image updates immediately on every input change with no button press required. When the input is empty or not a valid image data URI, no image is shown.",
+    "acceptanceCriteria": [
+      "Pasting a valid image data URI renders the decoded image immediately",
+      "The image is constrained to the viewport (max-width 100%, max-height 60vh)",
+      "Clearing the textarea removes the image from the view",
+      "Pasting non-image or malformed text shows no image and no error"
+    ],
+    "blockedBy": [
+      "data_uri_parsing_utils",
+      "persisted_textarea_input"
+    ],
+    "type": "AFK",
+    "passes": true,
+    "isPlanned": true
+  },
+  {
+    "id": "metadata_card_and_download",
+    "title": "Metadata card (resolution, MIME, size) with download and clear toolbar",
+    "whatToBuild": "Below the image, display a metadata description list: Resolution (width x height via async HTMLImageElement load, with a spinner until resolved), MIME type, Extension, Size (getBase64ApproxSize + pretty-bytes), and a Download link (downloadDataUrl with filename image.{ext}). Add a toolbar with a Clear button (resets inputText to '') and a Download button. Show a dash fallback for resolution if the image fails to load.",
+    "acceptanceCriteria": [
+      "Resolution shows the correct pixel dimensions once the image loads",
+      "A spinner is shown in place of resolution while dimensions are loading",
+      "Resolution shows a dash if the image element fails to load",
+      "MIME type, Extension, and Size display correct values for the pasted URI",
+      "Clicking the Download link saves the file as image.{ext}",
+      "Clicking Clear resets the input and removes the image and metadata",
+      "The Download toolbar button triggers the same download as the metadata link"
     ],
     "blockedBy": [
-      "scaffold_route"
+      "live_image_preview"
     ],
     "type": "AFK",
     "passes": true,
     "isPlanned": true
   },
   {
-    "id": "diff_controls",
-    "title": "Ignore-whitespace toggle, swap button, and +/- summary",
-    "whatToBuild": "Add an 'Ignore whitespace' checkbox (stored in Zustand) that suppresses whitespace-only diff lines. Add a Swap button that exchanges Original and Modified values. Add a summary bar showing '+X lines, −Y lines' computed from the diff result.",
+    "id": "non_image_uri_link",
+    "title": "Open-in-new-tab link for non-image data URIs",
+    "whatToBuild": "When parseDataUri succeeds but isImageMimeType returns false, render an Ant Design Alert (type info) containing an anchor tag with href set to the full data URI and target='_blank'. No image, no metadata, and no download button are shown in this case.",
     "acceptanceCriteria": [
-      "Checking 'Ignore whitespace' removes whitespace-only changes from the diff",
-      "Clicking Swap exchanges the content of the two textareas",
-      "Summary bar shows the correct count of added and removed lines",
-      "Summary bar updates live as text changes"
+      "Pasting a data:application/pdf;base64,... URI shows the info alert and 'Open in new tab' link",
+      "Clicking the link opens the decoded content in a new browser tab",
+      "No image preview or metadata is shown for non-image URIs",
+      "Switching back to a valid image URI removes the alert and shows the image preview"
     ],
     "blockedBy": [
-      "core_diff_view"
+      "live_image_preview"
     ],
     "type": "AFK",
     "passes": true,
 
@@ -1,11 +1,64 @@
 // Per-agent log files: logs/implementer-{issueId}.log, logs/reviewer-{issueId}.log, logs/planner.log, logs/merger.log
 import { isNullish } from "@lichens-innovation/ts-common";
-import { createLogger, type Logger } from "@lichens-innovation/ts-common/logger";
+import type { Logger } from "@lichens-innovation/ts-common/logger";
+import { mkdirSync } from "node:fs";
 import path from "node:path";
 import { fileURLToPath } from "node:url";
+import pino from "pino";
 
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
 
+const MESSAGE_KEY = "msg";
+
+const basePinoOptions: pino.LoggerOptions = {
+  timestamp: pino.stdTimeFunctions.isoTime,
+  messageKey: MESSAGE_KEY,
+};
+
+const createPrettyFileTransport = (logFile: string): pino.DestinationStream => {
+  try {
+    return pino.transport({
+      target: "pino-pretty",
+      options: {
+        colorize: false,
+        destination: logFile,
+        append: true,
+        mkdir: true,
+        translateTime: "SYS:standard",
+        messageKey: MESSAGE_KEY,
+      },
+    });
+  } catch (error) {
+    console.warn(`pino-pretty unavailable for "${logFile}", falling back to JSON`, error);
+    mkdirSync(path.dirname(logFile), { recursive: true });
+    return pino.destination({ dest: logFile, append: true, mkdir: true });
+  }
+};
+
+const buildLoggerApi = (pinoInstance: pino.Logger): Logger => {
+  const logAtLevel =
+    (level: "trace" | "debug" | "info" | "warn" | "error" | "fatal") =>
+    (message: string, payload?: Record<string, unknown>): void => {
+      if (isNullish(payload)) {
+        pinoInstance[level](message);
+      } else {
+        pinoInstance[level](payload, message);
+      }
+    };
+
+  return {
+    trace: logAtLevel("trace"),
+    debug: logAtLevel("debug"),
+    info: logAtLevel("info"),
+    warn: logAtLevel("warn"),
+    error: logAtLevel("error"),
+    fatal: logAtLevel("fatal"),
+    log: logAtLevel("info"),
+  };
+};
+
+const createFileLogger = (logFile: string): Logger => buildLoggerApi(pino(basePinoOptions, createPrettyFileTransport(logFile)));
+
 let logDir = path.join(__dirname, "..", "logs");
 
 export const setAgentLogDir = (dir: string): void => {
@@ -40,7 +93,7 @@ export const getLoggerForLabel = (label: string): Logger => {
     return cached;
   }
 
-  const instance = createLogger({ logFile: file });
+  const instance = createFileLogger(file);
   loggerCache.set(file, instance);
   return instance;
 };