feat: add claude conversation streaming

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: centdix

backend/src/__tests__/agent-service.test.ts

@@ -118,6 +118,23 @@ describe("agent-service command builders", () => {
     expect(command).toContain("claude --dangerously-skip-permissions --continue -- 'fix the tests'");
   });
 
+  it("uses an explicit Claude session id when refreshing a terminal", () => {
+    const command = buildAgentPaneCommand({
+      agent: builtInAgent("claude"),
+      runtimeEnvPath: "/tmp/gitdir/webmux/runtime.env",
+      repoRoot: "/repo",
+      worktreePath: "/repo/__worktrees/feature",
+      branch: "feature",
+      profileName: "default",
+      yolo: true,
+      launchMode: "resume",
+      resumeConversationId: "session-123",
+    });
+
+    expect(command).toContain("claude --dangerously-skip-permissions --resume 'session-123'");
+    expect(command).not.toContain("--continue");
+  });
+
   it("builds docker commands that exec inside the container", () => {
     const shell = buildDockerShellCommand(
       "wm-feature-container",

backend/src/__tests__/claude-cli.test.ts

@@ -1,11 +1,89 @@
 import { describe, expect, it } from "bun:test";
-import { buildClaudeSessionFromText, encodeClaudeProjectDir } from "../adapters/claude-cli";
+import { buildClaudeSessionFromText, encodeClaudeProjectDir, parseClaudeStreamLine } from "../adapters/claude-cli";
 
 describe("claude-cli adapter", () => {
   it("encodes Claude project directories from cwd", () => {
     expect(encodeClaudeProjectDir("/tmp/worktrees/feature.one")).toBe("-tmp-worktrees-feature-one");
   });
 
+  it("parses text deltas from Claude stream-json output", () => {
+    expect(parseClaudeStreamLine(JSON.stringify({
+      type: "stream_event",
+      session_id: "session-1",
+      event: {
+        type: "content_block_delta",
+        index: 2,
+        delta: {
+          type: "text_delta",
+          text: "hello",
+        },
+      },
+    }))).toEqual({
+      sessionId: "session-1",
+      assistantDelta: {
+        delta: "hello",
+        blockIndex: 2,
+      },
+      messages: [],
+      completeSessionId: null,
+      error: null,
+    });
+  });
+
+  it("parses finalized text and tool messages from Claude stream-json output", () => {
+    expect(parseClaudeStreamLine(JSON.stringify({
+      type: "assistant",
+      session_id: "session-1",
+      uuid: "assistant-1",
+      message: {
+        role: "assistant",
+        content: [
+          { type: "text", text: "Reading the file." },
+          { type: "tool_use", id: "tool-1", name: "Read", input: { file_path: "/tmp/foo.txt" } },
+        ],
+      },
+    }))?.messages).toEqual([
+      {
+        uuid: "assistant-1",
+        role: "assistant",
+        kind: "text",
+        text: "Reading the file.",
+        createdAt: null,
+      },
+      {
+        uuid: "assistant-1",
+        role: "assistant",
+        kind: "toolUse",
+        toolName: "Read",
+        toolCallId: "tool-1",
+        text: `{"file_path":"/tmp/foo.txt"}`,
+        createdAt: null,
+      },
+    ]);
+
+    expect(parseClaudeStreamLine(JSON.stringify({
+      type: "user",
+      session_id: "session-1",
+      uuid: "tool-result-1",
+      timestamp: "2026-04-14T15:00:02.000Z",
+      message: {
+        role: "user",
+        content: [
+          { type: "tool_result", tool_use_id: "tool-1", content: "hello world" },
+        ],
+      },
+    }))?.messages).toEqual([
+      {
+        uuid: "tool-result-1",
+        role: "user",
+        kind: "toolResult",
+        toolCallId: "tool-1",
+        text: "hello world",
+        createdAt: "2026-04-14T15:00:02.000Z",
+      },
+    ]);
+  });
+
   it("builds a transcript from Claude session jsonl text", () => {
     const session = buildClaudeSessionFromText({
       path: "/tmp/session.jsonl",
@@ -153,6 +231,7 @@ describe("claude-cli adapter", () => {
         role: "assistant",
         kind: "toolUse",
         toolName: "Read",
+        toolCallId: "tool-1",
         text: `{"file_path":"/tmp/foo.txt"}`,
         createdAt: "2026-04-14T15:00:01.000Z",
       },
@@ -161,6 +240,7 @@ describe("claude-cli adapter", () => {
         turnId: "user-1",
         role: "user",
         kind: "toolResult",
+        toolCallId: "tool-1",
         text: "hello world",
         createdAt: "2026-04-14T15:00:02.000Z",
       },

backend/src/__tests__/claude-conversation-service.test.ts

@@ -148,4 +148,76 @@ describe("ClaudeConversationService", () => {
       lastSeenAt: "2026-04-14T12:00:00.000Z",
     });
   });
+
+  it("keeps a saved session id even before Claude has written the jsonl", async () => {
+    const metaStore = new Map<string, WorktreeMeta>();
+    const worktree = makeWorktree();
+    const gitDir = `${worktree.path}/.git`;
+    metaStore.set(gitDir, {
+      ...makeMeta(),
+      conversation: {
+        provider: "claudeCode",
+        conversationId: "session-pending",
+        sessionId: "session-pending",
+        cwd: worktree.path,
+        lastSeenAt: "2026-04-14T11:00:00.000Z",
+      },
+    });
+
+    const claude = new FakeClaudeCliGateway();
+    const service = new ClaudeConversationService({
+      claude,
+      git: new FakeGitGateway(),
+      now: () => new Date("2026-04-14T12:00:00.000Z"),
+      readMeta: async (path) => structuredClone(metaStore.get(path) ?? null),
+      writeMeta: async (path, meta) => {
+        metaStore.set(path, structuredClone(meta));
+      },
+    });
+
+    const result = await service.readWorktreeConversation(worktree);
+    expect(result.ok).toBe(true);
+    if (!result.ok) return;
+
+    expect(result.data.conversation.conversationId).toBe("session-pending");
+    expect(result.data.conversation.messages).toEqual([]);
+    expect(result.data.worktree.conversation).toEqual({
+      provider: "claudeCode",
+      conversationId: "session-pending",
+      sessionId: "session-pending",
+      cwd: worktree.path,
+      lastSeenAt: "2026-04-14T11:00:00.000Z",
+    });
+  });
+
+  it("persists a generated Claude session id before the session file exists", async () => {
+    const metaStore = new Map<string, WorktreeMeta>();
+    const worktree = makeWorktree();
+    const gitDir = `${worktree.path}/.git`;
+    metaStore.set(gitDir, makeMeta());
+
+    const claude = new FakeClaudeCliGateway();
+    const service = new ClaudeConversationService({
+      claude,
+      git: new FakeGitGateway(),
+      now: () => new Date("2026-04-14T12:00:00.000Z"),
+      readMeta: async (path) => structuredClone(metaStore.get(path) ?? null),
+      writeMeta: async (path, meta) => {
+        metaStore.set(path, structuredClone(meta));
+      },
+    });
+
+    const result = await service.setWorktreeConversationSession(worktree, "session-new");
+    expect(result.ok).toBe(true);
+    if (!result.ok) return;
+
+    expect(result.data).toEqual({
+      provider: "claudeCode",
+      conversationId: "session-new",
+      sessionId: "session-new",
+      cwd: worktree.path,
+      lastSeenAt: "2026-04-14T12:00:00.000Z",
+    });
+    expect(metaStore.get(gitDir)?.conversation).toEqual(result.data);
+  });
 });