[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_229":-5,"_232":233,"_234":235},"routes/shell",{"_42":43,"_228":-5,"_229":-5,"_230":231},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":31,"_45":31,"_46":31,"_47":31,"_48":31,"_49":31,"_50":51,"_52":51,"_53":31,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","7aa1c12e585d65ebe40ee9d3f27d41d65f37af4e","path","e2e/smoke.e2e.ts","oid","4342d5ab3547791d1e88dddf2664f05cc518be02","size",37745,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { chatInput, expectChatValue, fillChat } from \"./chat-input\";\n/**\n * The harness proving itself.\n *\n * Everything else in this directory assumes GitHub sign-in opens an authorized\n * channel and leaves an editable plan on screen. If that is not true the rest of\n * the suite fails in six different ways with six different explanations, so it\n * is worth one file that fails in one.\n */\n\nimport { content, expect, ready, roomPath, test } from \"./room\";\nimport { storedQuestion } from \"../apps/server/src/testing/plan\";\n\nimport type { Chat } from \"../packages/protocol/index\";\nimport type { Page, WebSocketRoute } from \"@playwright/test\";\n\nfunction chatPane(page: Page) {\n\treturn page.getByRole(\"complementary\", { includeHidden: true, name: \"Chat\" });\n}\n\nasync function injectChatHistory(\n\tpage: Page,\n\tchange: (frame: Chat.History) => Chat.History,\n) {\n\tlet send: ((frame: Record) => void) | undefined;\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\tlet server = route.connectToServer();\n\t\tsend = frame => route.send(JSON.stringify(frame));\n\t\troute.onMessage(message => server.send(message));\n\t\tserver.onMessage(message => {\n\t\t\tif (typeof message !== \"string\") return route.send(message);\n\t\t\ttry {\n\t\t\t\tlet frame = JSON.parse(message) as { kind?: string };\n\t\t\t\troute.send(\n\t\t\t\t\tframe.kind === \"chat:history\" ? JSON.stringify(change(frame as Chat.History)) : message,\n\t\t\t\t);\n\t\t\t} catch {\n\t\t\t\troute.send(message);\n\t\t\t}\n\t\t});\n\t});\n\n\treturn { send: (frame: Record) => send?.(frame) };\n}\n\nasync function scriptPlanner(page: Page) {\n\tlet started = Promise.withResolvers();\n\tlet send: ((frame: Record) => void) | undefined;\n\tlet sends: { text: string; to: Chat.Destination }[] = [];\n\tlet turn = 0;\n\tlet busy = false;\n\tlet queued: Chat.Waiting[] = [];\n\tlet toolCount = 0;\n\tlet toolEntry = \"\";\n\tlet toolEntrySent = false;\n\tlet toolNames = new Map();\n\tlet toolEntries = new Map();\n\tlet sentEntryIds = new Set();\n\tlet active = () => ({\n\t\tid: `turn-${++turn}`,\n\t\thandle: \"ana\",\n\t\tstarted: 1_700_000_001,\n\t\tentryOffset: sentEntryIds.size,\n\t\tresponded: false,\n\t});\n\tlet announce = (id: string, text: string) =>\n\t\tsend?.({\n\t\t\tkind: \"chat:message\",\n\t\t\tts: 0,\n\t\t\tentry: {\n\t\t\t\tid,\n\t\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\t\ttext,\n\t\t\t\tts: 1_700_000_000,\n\t\t\t},\n\t\t});\n\tlet start = () => {\n\t\tbusy = true;\n\t\tlet state = active();\n\t\ttoolEntry = `tools-${turn}`;\n\t\ttoolEntrySent = false;\n\t\tsend?.({ kind: \"chat:state\", ts: 0, busy: true, turn: state });\n\t};\n\tawait page.route(\"**/api/session\", async route => {\n\t\tlet response = await route.fetch();\n\t\tlet session = await response.json() as Record;\n\t\tawait route.fulfill({ response, json: { ...session, agent: true } });\n\t});\n\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\tlet server = route.connectToServer();\n\t\tsend = frame => {\n\t\t\tlet entry = frame.entry as { id?: string } | undefined;\n\t\t\tif (frame.kind === \"chat:message\" && entry?.id) sentEntryIds.add(entry.id);\n\t\t\troute.send(JSON.stringify(frame));\n\t\t};\n\t\troute.onMessage(message => {\n\t\t\tif (typeof message !== \"string\") return server.send(message);\n\t\t\ttry {\n\t\t\t\tlet frame = JSON.parse(message) as {\n\t\t\t\t\tkind?: string;\n\t\t\t\t\trid?: string;\n\t\t\t\t\ttext?: string;\n\t\t\t\t\tto?: Chat.Destination;\n\t\t\t\t};\n\t\t\t\tif (frame.kind === \"chat:send\") {\n\t\t\t\t\tsends.push({ text: frame.text ?? \"\", to: frame.to! });\n\t\t\t\t\tlet id = `accepted-${sends.length}`;\n\t\t\t\t\tlet waiting = frame.to === \"planner\" && busy;\n\t\t\t\t\tsend?.({ kind: \"chat:send\", ts: 0, rid: frame.rid, id, queued: waiting });\n\t\t\t\t\tif (frame.to === \"planner\") {\n\t\t\t\t\t\tif (busy) {\n\t\t\t\t\t\t\tqueued = [...queued, {\n\t\t\t\t\t\t\t\tid,\n\t\t\t\t\t\t\t\thandle: \"ana\",\n\t\t\t\t\t\t\t\ttext: frame.text ?? \"\",\n\t\t\t\t\t\t\t}];\n\t\t\t\t\t\t\tsend?.({ kind: \"chat:queue\", ts: 0, waiting: queued });\n\t\t\t\t\t\t\treturn;\n\t\t\t\t\t\t}\n\t\t\t\t\t\tannounce(id, frame.text ?? \"\");\n\t\t\t\t\t\tstart();\n\t\t\t\t\t\tstarted.resolve();\n\t\t\t\t\t\treturn;\n\t\t\t\t\t}\n\t\t\t\t\tannounce(id, frame.text ?? \"\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tif (frame.kind === \"chat:abort\") {\n\t\t\t\t\tlet next = queued.shift();\n\t\t\t\t\tif (next) {\n\t\t\t\t\t\tsend?.({ kind: \"chat:queue\", ts: 0, waiting: queued });\n\t\t\t\t\t\tannounce(next.id, next.text);\n\t\t\t\t\t\tstart();\n\t\t\t\t\t} else {\n\t\t\t\t\t\tbusy = false;\n\t\t\t\t\t\tsend?.({ kind: \"chat:state\", ts: 0, busy: false });\n\t\t\t\t\t}\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t} catch {\n\t\t\t\t// Frames the test does not script still belong to the server.\n\t\t\t}\n\t\t\tserver.send(message);\n\t\t});\n\t\tserver.onMessage(message => route.send(message));\n\t});\n\n\treturn {\n\t\tstarted: started.promise,\n\t\tsends: () => sends,\n\t\tanswer() {\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:message\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: {\n\t\t\t\t\tid: \"answer\",\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: \"The migration is ready.\",\n\t\t\t\t\tts: 1_700_000_001,\n\t\t\t\t},\n\t\t\t});\n\t\t\tbusy = false;\n\t\t\tsend?.({ kind: \"chat:state\", ts: 0, busy: false });\n\t\t},\n\t\ttool(name = \"read_plan\", args = '{ \"path\": \"src/store.ts\" }', separateEntry = false) {\n\t\t\tif (separateEntry) {\n\t\t\t\ttoolEntry = `tools-${turn}-${toolCount + 1}`;\n\t\t\t\ttoolEntrySent = false;\n\t\t\t}\n\t\t\tif (!toolEntrySent) {\n\t\t\t\tsend?.({\n\t\t\t\t\tkind: \"chat:message\",\n\t\t\t\t\tts: 0,\n\t\t\t\t\tentry: {\n\t\t\t\t\t\tid: toolEntry,\n\t\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\t\ttext: \"\",\n\t\t\t\t\t\tts: 1_700_000_001,\n\t\t\t\t\t},\n\t\t\t\t});\n\t\t\t\ttoolEntrySent = true;\n\t\t\t}\n\t\t\tlet id = `tool-${++toolCount}`;\n\t\t\ttoolNames.set(id, name);\n\t\t\ttoolEntries.set(id, toolEntry);\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:tool\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: toolEntry,\n\t\t\t\tactivity: { id, name, status: \"running\", args },\n\t\t\t});\n\t\t\treturn id;\n\t\t},\n\t\tfinishTool(id: string, status: \"done\" | \"failed\", result: string) {\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:tool\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: toolEntries.get(id),\n\t\t\t\tactivity: { id, name: toolNames.get(id), status, result, took: 38 },\n\t\t\t});\n\t\t},\n\t\tcomplete() {\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:message\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: {\n\t\t\t\t\tid: \"answer\",\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: \"I found it.\",\n\t\t\t\t\tts: 1_700_000_002,\n\t\t\t\t},\n\t\t\t});\n\t\t\tbusy = false;\n\t\t\tsend?.({ kind: \"chat:state\", ts: 0, busy: false });\n\t\t},\n\t\tstream() {\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:message\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: {\n\t\t\t\t\tid: \"answer\",\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: \"I found it.\",\n\t\t\t\t\tts: 1_700_000_002,\n\t\t\t\t\tstreaming: true,\n\t\t\t\t},\n\t\t\t});\n\t\t},\n\t\tfail() {\n\t\t\tsend?.({\n\t\t\t\tkind: \"chat:message\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: {\n\t\t\t\t\tid: \"failure\",\n\t\t\t\t\tauthor: { kind: \"system\" },\n\t\t\t\t\ttext: \"Planner unavailable.\",\n\t\t\t\t\tts: 1_700_000_001,\n\t\t\t\t},\n\t\t\t});\n\t\t\tbusy = false;\n\t\t\tsend?.({ kind: \"chat:state\", ts: 0, busy: false });\n\t\t},\n\t};\n}\n\ntest(\"a GitHub session joins its authorized channel\", async ({ join, room }) => {\n\tlet page = await join(\"ana\");\n\tlet projects = page.getByRole(\"complementary\", { name: \"Projects\" });\n\tlet repository = projects.getByRole(\"button\", { name: \"score\", exact: true });\n\n\tawait expect(page).toHaveURL(roomPath(room));\n\tawait expect(repository).toHaveAttribute(\"aria-expanded\", \"true\");\n\tawait expect(page.getByRole(\"banner\").getByRole(\"img\", { name: \"ana\" })).toHaveCount(1);\n});\n\ntest(\"an unauthenticated visitor is asked to sign in\", async ({ page }) => {\n\tawait page.goto(\"/\");\n\n\tawait expect(page.getByRole(\"link\", { name: \"Continue with GitHub\" })).toBeVisible();\n\tawait expect(content(page)).toHaveCount(0);\n});\n\ntest(\"an empty plan puts its muted prompt at the first writing position\", async ({ join }) => {\n\tlet page = await join(\"ana\");\n\tawait page.setViewportSize({ width: 1800, height: 900 });\n\tlet editor = content(page);\n\tlet paragraph = editor.locator(\":scope > p\");\n\tlet prompt = page.getByText(\"Start writing, or ask Chopin to plan\", { exact: true });\n\n\t// The prompt is a sibling overlay. The editable tree needs its own empty\n\t// block, and the two must share one stable first writing position.\n\tawait expect(paragraph).toHaveCount(1);\n\t// Read both positions in one frame: separate calls can straddle the resize layout.\n\tawait expect.poll(() =>\n\t\teditor.evaluate(element => {\n\t\t\tlet paragraph = element.querySelector(\"p\")!;\n\t\t\tlet placeholder = element.closest(\".mdxeditor-root-contenteditable\")!\n\t\t\t\t.querySelector(\":scope > .plan-content p\")!;\n\t\t\treturn Math.abs(\n\t\t\t\tparagraph.getBoundingClientRect().x - placeholder.getBoundingClientRect().x,\n\t\t\t);\n\t\t})\n\t).toBeLessThan(0.05);\n\tlet paragraphBox = await paragraph.boundingBox();\n\tlet colors = await prompt.evaluate(element => {\n\t\tlet reference = document.createElement(\"span\");\n\t\treference.style.color = \"var(--color-text-quaternary)\";\n\t\tdocument.body.append(reference);\n\t\tlet muted = getComputedStyle(reference).color;\n\t\treference.remove();\n\n\t\treturn { actual: getComputedStyle(element).color, muted };\n\t});\n\n\texpect(paragraphBox).not.toBeNull();\n\tawait page.mouse.click(paragraphBox!.x + 120, paragraphBox!.y + paragraphBox!.height / 2);\n\n\tlet selection = await editor.evaluate(element => {\n\t\tlet value = window.getSelection();\n\t\tlet paragraph = element.querySelector(\"p\")!;\n\n\t\treturn {\n\t\t\tanchorIsParagraph: value!.anchorNode === paragraph,\n\t\t\tanchorOffset: value!.anchorOffset,\n\t\t};\n\t});\n\n\texpect(selection.anchorIsParagraph).toBe(true);\n\texpect(selection.anchorOffset).toBe(0);\n\texpect(colors.actual).toBe(colors.muted);\n\tawait page.keyboard.type(\"x\");\n\tlet text = await editor.evaluate(element => {\n\t\tlet paragraph = element.querySelector(\"p\")!;\n\t\tlet range = document.createRange();\n\t\trange.selectNodeContents(paragraph);\n\n\t\treturn {\n\t\t\tleft: range.getBoundingClientRect().left,\n\t\t\tparagraphLeft: paragraph.getBoundingClientRect().left,\n\t\t};\n\t});\n\n\texpect(text.left).toBeCloseTo(text.paragraphLeft, 1);\n});\n\ntest(\"chat uses one room-message composer when the planner is off\", async ({ join }) => {\n\tlet page = await join(\"ana\");\n\tlet chat = chatPane(page);\n\tlet draft = chatInput(chat);\n\tlet send = chat.getByRole(\"button\", { name: \"Send message\" });\n\n\tawait expect(chat.locator(\"header\")).toHaveCount(0);\n\tawait expect(draft).toBeVisible();\n\tawait expect(send).toBeDisabled();\n\tawait expect(chat.getByRole(\"button\", { name: \"Send message\" })).toHaveCount(1);\n\tawait expect(send).toHaveAttribute(\"title\", \"Send message\");\n\tawait expect(chat.getByRole(\"button\", { name: \"Send message\" })).toHaveCount(1);\n\tawait expect(chat.getByRole(\"button\", { name: \"Send to room\" })).toHaveCount(0);\n\tawait expect(chat.getByRole(\"button\", { name: \"Ask Chopin\" })).toHaveCount(0);\n\tawait expect(chat.getByRole(\"button\", { name: \"Stop Chopin\" })).toHaveCount(0);\n\n\tawait draft.fill(\"A room message\");\n\tawait expect(send).toBeEnabled();\n\tawait send.click();\n\tawait expect(chat.getByText(\"A room message\")).toBeVisible();\n\n\tawait draft.fill(\"@chopin Do not start a turn here.\");\n\tawait send.click();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\tawait expect(chat.getByRole(\"button\", { name: \"Stop Chopin\" })).toHaveCount(0);\n});\n\ntest(\"chat keeps both ends of a tall transcript clear across layouts\", async ({ join, page }) => {\n\tawait injectChatHistory(page, frame => ({\n\t\t...frame,\n\t\tentries: Array.from({ length: 24 }, (_, index) => ({\n\t\t\tauthor: index % 2 === 0\n\t\t\t\t? { kind: \"member\" as const, handle: \"ana\" }\n\t\t\t\t: { kind: \"agent\" as const },\n\t\t\tid: `history-${index}`,\n\t\t\ttext: index === 0\n\t\t\t\t? \"The first message in a deliberately tall transcript.\"\n\t\t\t\t: `Transcript message ${index} with enough text to occupy a complete line.`,\n\t\t\tts: 1_700_000_000 + index,\n\t\t})),\n\t}));\n\n\tlet chat = chatPane(await join(\"ana\"));\n\tlet stack = chat.locator(\"[data-chat-stack]\");\n\tlet scroller = stack.locator(\"..\");\n\tlet composer = chatInput(chat).locator(\"..\");\n\tlet lastMessageGap = async () => {\n\t\tawait scroller.evaluate(element => element.scrollTop = element.scrollHeight);\n\t\treturn chat.getByText(\"Transcript message 23\", { exact: false })\n\t\t\t.evaluate(\n\t\t\t\t(message, field) =>\n\t\t\t\t\t(field as Element).getBoundingClientRect().top - message.getBoundingClientRect().bottom,\n\t\t\t\tawait composer.elementHandle(),\n\t\t\t);\n\t};\n\tlet firstMessagePosition = async () => {\n\t\tawait scroller.evaluate(element => element.scrollTop = 0);\n\t\treturn chat.getByText(\"The first message in a deliberately tall transcript.\")\n\t\t\t.evaluate((message, scrollRoot) => {\n\t\t\t\tlet messageBox = message.getBoundingClientRect();\n\t\t\t\tlet scroller = scrollRoot as Element;\n\t\t\t\tlet scrollerBox = scroller.getBoundingClientRect();\n\t\t\t\treturn {\n\t\t\t\t\tclientHeight: scroller.clientHeight,\n\t\t\t\t\tmessageBottom: messageBox.bottom,\n\t\t\t\t\tmessageTop: messageBox.top,\n\t\t\t\t\tscrollerBottom: scrollerBox.bottom,\n\t\t\t\t\tscrollerTop: scrollerBox.top,\n\t\t\t\t\tscrollHeight: scroller.scrollHeight,\n\t\t\t\t};\n\t\t\t}, await scroller.elementHandle());\n\t};\n\tawait expect(chat.getByText(\"Transcript message 23\", { exact: false })).toBeVisible();\n\texpect(await lastMessageGap()).toBeGreaterThanOrEqual(32);\n\tlet position = await firstMessagePosition();\n\texpect(position.scrollHeight).toBeGreaterThan(position.clientHeight);\n\texpect(position.messageTop).toBeGreaterThanOrEqual(position.scrollerTop);\n\texpect(position.messageBottom).toBeLessThanOrEqual(position.scrollerBottom);\n\n\tawait page.setViewportSize({ width: 390, height: 844 });\n\tawait page.getByRole(\"navigation\", { name: \"Workspace view\" })\n\t\t.getByRole(\"button\", { name: /^Chat/ }).click();\n\tawait expect(chat).toBeVisible();\n\texpect(await lastMessageGap()).toBeGreaterThanOrEqual(32);\n\tposition = await firstMessagePosition();\n\texpect(position.scrollHeight).toBeGreaterThan(position.clientHeight);\n\texpect(position.messageTop).toBeGreaterThanOrEqual(position.scrollerTop);\n\texpect(position.messageBottom).toBeLessThanOrEqual(position.scrollerBottom);\n});\n\ntest(\"chat disables Send when its socket disconnects\", async ({ join, page }) => {\n\tlet sockets: WebSocketRoute[] = [];\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\troute.connectToServer();\n\t\tsockets.push(route);\n\t});\n\n\tlet chat = chatPane(await join(\"ana\"));\n\tlet draft = chatInput(chat);\n\tlet send = chat.getByRole(\"button\", { name: \"Send message\" });\n\tawait draft.fill(\"A draft left during reconnect.\");\n\tawait expect(send).toBeEnabled();\n\n\tawait sockets.at(-1)!.close();\n\tawait expect(send).toBeDisabled();\n});\n\ntest(\"chat routes one Send action by @chopin without blocking room messages or its queue\", async ({ join, page }) => {\n\tlet planner = await scriptPlanner(page);\n\tlet chat = chatPane(await join(\"ana\"));\n\tlet draft = chatInput(chat);\n\tlet send = chat.getByRole(\"button\", { name: \"Send message\" });\n\n\tawait draft.fill(\"@chopin Start the migration.\");\n\tawait draft.press(\"Enter\");\n\tawait planner.started;\n\tawait expect(chat.getByRole(\"button\", { name: \"Stop Chopin\" })).toBeVisible();\n\tawait expect(chat.getByRole(\"button\", { name: \"Stop Chopin\" })).toHaveAttribute(\n\t\t\"title\",\n\t\t\"Stop Chopin\",\n\t);\n\n\tawait expectChatValue(draft, \"\");\n\tif (\n\t\tawait chat.getByRole(\"button\", { name: \"Talk to Chopin\", exact: true }).getAttribute(\n\t\t\t\"aria-pressed\",\n\t\t) === \"true\"\n\t) {\n\t\tawait draft.press(\"Shift+Tab\");\n\t}\n\tawait draft.fill(\"Keep the release notes brief.\");\n\tawait expect(send).toBeEnabled();\n\tawait send.click();\n\tawait draft.fill(\"@chopin Queue the rollback checks.\");\n\tawait send.click();\n\tawait expect.poll(planner.sends).toEqual([\n\t\t{ text: \"@chopin Start the migration.\", to: \"planner\" },\n\t\t{ text: \"Keep the release notes brief.\", to: \"room\" },\n\t\t{ text: \"@chopin Queue the rollback checks.\", to: \"planner\" },\n\t]);\n\tawait expect(chat.locator('[data-chat-state=\"queued\"]')).toBeVisible();\n\n\tawait fillChat(draft, \"@chopin Keep\\nthe new line.\");\n\tawait draft.press(\"Shift+Enter\");\n\tawait expectChatValue(draft, \"@chopin Keep\\nthe new line.\\n\");\n\tawait draft.press(\"Enter\");\n\tawait expect.poll(planner.sends).toContainEqual({\n\t\ttext: \"@chopin Keep\\nthe new line.\",\n\t\tto: \"planner\",\n\t});\n\n\tawait chat.getByRole(\"button\", { name: \"Stop Chopin\" }).click();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toBeVisible();\n\tlet next = chat.locator(\"[data-chat-entry]\").filter({ hasText: \"Queue the rollback checks.\" });\n\tlet later = chat.locator(\"[data-chat-entry]\").filter({ hasText: /Keep\\s+the new line/ });\n\tawait expect(next).toHaveCount(1);\n\tawait expect(next).not.toHaveAttribute(\"data-chat-state\", \"queued\");\n\tawait expect(later).toHaveCount(1);\n\tawait expect(later).toHaveAttribute(\"data-chat-state\", \"queued\");\n});\n\ntest(\"chat replaces the Planner working row with its response\", async ({ join, page }) => {\n\tlet planner = await scriptPlanner(page);\n\tlet chat = chatPane(await join(\"ana\"));\n\n\tawait chatInput(chat).fill(\n\t\t\"@chopin Draft the migration.\",\n\t);\n\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\tawait planner.started;\n\n\tlet working = chat.locator('[data-chat-state=\"working\"]');\n\tawait expect(working).toBeVisible();\n\tawait expect(working.getByText(\"Getting oriented\")).toBeVisible();\n\tlet timestamp = await page.evaluate(() =>\n\t\tnew Date(1_700_000_001 * 1000).toLocaleTimeString([], { hour: \"2-digit\", minute: \"2-digit\" })\n\t);\n\tawait expect(\n\t\tworking.locator(\"xpath=ancestor::*[@data-chat-entry][1]\").getByText(\n\t\t\t`Started at ${timestamp}`,\n\t\t\t{ exact: true },\n\t\t),\n\t).toBeVisible();\n\tawait page.emulateMedia({ reducedMotion: \"reduce\" });\n\tawait expect(working).toBeVisible();\n\tawait expect.poll(() =>\n\t\tworking.evaluate(node =>\n\t\t\tnode.getAnimations({ subtree: true }).some(animation => animation.playState === \"running\")\n\t\t)\n\t).toBe(false);\n\n\tplanner.answer();\n\tawait expect(working).toHaveCount(0);\n\tawait expect(chat.getByText(\"The migration is ready.\")).toBeVisible();\n\tawait expect(chat.getByText(/^Started at /)).toHaveCount(0);\n\tawait expect(chat.locator(\"[data-chat-entry]\")).toHaveCount(2);\n});\n\ntest(\"chat clears the Planner working row when a turn stops or fails\", async ({ join, page }) => {\n\tlet planner = await scriptPlanner(page);\n\tlet chat = chatPane(await join(\"ana\"));\n\n\tawait chatInput(chat).fill(\n\t\t\"@chopin Draft the migration.\",\n\t);\n\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\tawait planner.started;\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toBeVisible();\n\n\tawait chat.getByRole(\"button\", { name: \"Stop Chopin\" }).click();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\n\tawait chatInput(chat).fill(\"@chopin Try again.\");\n\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toBeVisible();\n\tplanner.tool();\n\tawait expect(chat.getByText(\"Gathering context\")).toBeVisible();\n\tplanner.fail();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\tawait expect(chat.getByText(\"Planner unavailable.\")).toBeVisible();\n\tawait chat.getByRole(\"button\", { name: /Work details.*1 action.*1 interrupted/ }).click();\n\tawait expect(chat.getByRole(\"button\", { name: /Read plan.*Interrupted/ })).toBeVisible();\n\n\tawait page.reload();\n\tawait ready(page);\n\tawait expect(chatPane(page).locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n});\n\ntest(\n\t\"chat progresses through real work and reveals tool input and results\",\n\tasync ({ join, page }, testInfo) => {\n\t\tlet planner = await scriptPlanner(page);\n\t\tlet chat = chatPane(await join(\"ana\"));\n\n\t\tawait chatInput(chat).fill(\n\t\t\t\"@chopin Check the current plan.\",\n\t\t);\n\t\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\t\tawait planner.started;\n\t\tawait expect(chat.getByText(\"Getting oriented\")).toBeVisible();\n\t\tlet live = chat.locator(\"[data-chat-work-announcer]\");\n\t\tawait expect(live).toHaveText(\"Chopin has started.\");\n\t\tawait live.evaluate(element => element.setAttribute(\"data-live-node\", \"retained\"));\n\n\t\tlet read = planner.tool(\"read_plan\", '{ \"path\": \"\" }');\n\t\tlet work = chat.locator('[data-chat-state=\"working\"]');\n\t\tlet disclosure = work.getByRole(\"button\", { name: /Gathering context/ });\n\t\tawait expect(disclosure).toBeVisible();\n\t\tawait expect(disclosure).toHaveAttribute(\"aria-expanded\", \"false\");\n\t\tawait expect(live).toHaveText(\"Chopin is gathering context.\");\n\t\tawait expect(live).toHaveAttribute(\"data-live-node\", \"retained\");\n\t\tlet controlled = await disclosure.getAttribute(\"aria-controls\");\n\t\tawait expect(chat.locator(`[id=\"${controlled}\"]`)).toHaveCount(1);\n\t\tawait expect(work.getByText(\"Read plan\", { exact: true })).toHaveCount(0);\n\t\tawait chat.screenshot({ path: testInfo.outputPath(\"work-active.png\") });\n\n\t\tawait disclosure.focus();\n\t\tawait page.keyboard.press(\"Enter\");\n\t\tawait expect(disclosure).toHaveAttribute(\"aria-expanded\", \"true\");\n\t\tlet tool = work.getByRole(\"button\", { name: /Read plan.*Running/ });\n\t\tawait expect(tool).toBeVisible();\n\t\tawait expect(tool).toHaveAttribute(\"aria-expanded\", \"false\");\n\t\tawait tool.click();\n\t\tawait expect(tool).toHaveAttribute(\"aria-expanded\", \"true\");\n\t\tawait expect(work.getByText('\"path\": \"\"', { exact: false })).toBeVisible();\n\t\tawait chat.screenshot({ path: testInfo.outputPath(\"work-expanded.png\") });\n\n\t\tplanner.finishTool(read, \"done\", \"Found the storage adapter.\");\n\t\tawait expect(work.getByText(\"Reviewing the next step\")).toBeVisible();\n\t\tawait expect(live).toHaveText(\"Chopin is preparing to continue.\");\n\t\tawait expect(live).toHaveAttribute(\"data-live-node\", \"retained\");\n\t\tawait expect(work.getByText(\"1 finished\")).toBeVisible();\n\t\tawait expect(work.getByText(\"Found the storage adapter.\")).toBeVisible();\n\t\tawait expect(work.getByRole(\"button\", { name: /Reviewing the next step/ })).toHaveAttribute(\n\t\t\t\"aria-expanded\",\n\t\t\t\"true\",\n\t\t);\n\n\t\tlet edit = planner.tool(\"edit_plan\", '{ \"block\": \"persistence\" }');\n\t\tawait expect(work.getByText(\"Making changes\")).toBeVisible();\n\t\tawait expect(live).toHaveText(\"Chopin is making changes.\");\n\t\tawait expect(live).toHaveAttribute(\"data-live-node\", \"retained\");\n\t\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(1);\n\t\tplanner.finishTool(edit, \"done\", \"Document updated.\");\n\t\tplanner.stream();\n\t\tawait expect(work.getByText(\"Writing a response\")).toBeVisible();\n\t\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(1);\n\t\tawait expect(chat.getByText(\"I found it.\")).toBeVisible();\n\n\t\tplanner.complete();\n\t\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\t\tlet finished = chat.getByRole(\"button\", { name: /Work details.*2 actions/ });\n\t\tawait expect(finished).toHaveAttribute(\"aria-expanded\", \"true\");\n\t\tawait expect(live).toHaveText(\"Chopin turn ended. Work details remain available.\");\n\t\tawait expect(live).toHaveAttribute(\"data-live-node\", \"retained\");\n\t\tawait expect(chat.getByText(\"Document updated.\")).not.toBeVisible();\n\t\tawait chat.screenshot({ path: testInfo.outputPath(\"work-completed.png\") });\n\t},\n);\n\ntest(\"chat anchors active work when later tools arrive on another message\", async ({ join, page }) => {\n\tlet planner = await scriptPlanner(page);\n\tlet chat = chatPane(await join(\"ana\"));\n\tawait chatInput(chat).fill(\"@chopin Inspect and edit.\");\n\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\tawait planner.started;\n\n\tlet first = planner.tool();\n\tlet work = chat.locator('[data-chat-state=\"working\"]');\n\tawait expect(work.getByText(\"Gathering context\")).toBeVisible();\n\tlet anchor = await work.getAttribute(\"data-chat-message-id\");\n\tplanner.finishTool(first, \"done\", \"Read the document.\");\n\tplanner.tool(\"edit_plan\", '{ \"block\": \"persistence\" }', true);\n\tawait expect(work.getByText(\"Making changes\")).toBeVisible();\n\tawait expect(work).toHaveAttribute(\"data-chat-message-id\", anchor!);\n\tawait expect(work).toContainText(\"1 finished\");\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(1);\n\tawait work.getByRole(\"button\", { name: /Making changes/ }).click();\n\tawait expect(work.getByText(\"Read plan\", { exact: true })).toBeVisible();\n\tawait expect(work.getByText(\"Edit plan\", { exact: true })).toBeVisible();\n\n\tawait chat.getByRole(\"button\", { name: \"Stop Chopin\" }).click();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\tlet completed = chat.locator(`[data-chat-message-id=\"${anchor}\"]`);\n\tawait expect(completed.getByRole(\"button\", { name: /Work details.*2 actions/ })).toHaveAttribute(\n\t\t\"aria-expanded\",\n\t\t\"true\",\n\t);\n\tawait expect(completed.getByText(\"Read plan\", { exact: true })).toBeVisible();\n\tawait expect(completed.getByText(\"Edit plan\", { exact: true })).toBeVisible();\n});\n\ntest(\"chat keeps an opened disclosure when prose precedes a separate tool entry\", async ({ join, page }) => {\n\tlet planner = await scriptPlanner(page);\n\tlet chat = chatPane(await join(\"ana\"));\n\tawait chatInput(chat).fill(\"@chopin Inspect this.\");\n\tawait chat.getByRole(\"button\", { name: \"Send message\" }).click();\n\tawait planner.started;\n\tplanner.stream();\n\tlet prose = chat.locator('[data-chat-message-id=\"answer\"]');\n\tawait expect(prose.getByText(\"Writing a response\")).toBeVisible();\n\tlet tool = planner.tool(\"read_plan\", '{ \"path\": \"src/store.ts\" }', true);\n\tawait expect(prose.getByText(\"Gathering context\")).toBeVisible();\n\tlet disclosure = prose.getByRole(\"button\", { name: /Gathering context/ });\n\tawait disclosure.click();\n\tawait expect(disclosure).toHaveAttribute(\"aria-expanded\", \"true\");\n\tawait disclosure.evaluate(element => element.setAttribute(\"data-open-node\", \"retained\"));\n\tplanner.finishTool(tool, \"done\", \"Read the document.\");\n\tplanner.complete();\n\tlet finished = prose.getByRole(\"button\", { name: /Work details.*1 action/ });\n\tawait expect(finished).toHaveAttribute(\"aria-expanded\", \"true\");\n\tawait expect(finished).toHaveAttribute(\"data-open-node\", \"retained\");\n\tawait expect(prose.getByText(\"Read plan\", { exact: true })).toBeVisible();\n\tawait expect(chat.getByRole(\"button\", { name: /Work details.*1 action/ })).toHaveCount(1);\n});\n\ntest(\"chat keeps opened work details on their prose anchor through a disconnect\", async ({ join, page }) => {\n\tlet sockets: WebSocketRoute[] = [];\n\tlet reconnecting = Promise.withResolvers();\n\tlet releaseHistory: (() => void) | undefined;\n\tlet turn: Chat.Turn = {\n\t\tid: \"turn-offline\",\n\t\thandle: \"ana\",\n\t\tstarted: 1_700_000_001,\n\t\tentryOffset: 1,\n\t\tresponded: true,\n\t};\n\tlet entries: Chat.Entry[] = [\n\t\t{\n\t\t\tid: \"prompt\",\n\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\ttext: \"@chopin Inspect this.\",\n\t\t\tts: 1_700_000_000,\n\t\t},\n\t\t{ id: \"prose\", author: { kind: \"agent\" }, text: \"I will inspect this.\", ts: 1_700_000_001 },\n\t\t{\n\t\t\tid: \"read-entry\",\n\t\t\tauthor: { kind: \"agent\" },\n\t\t\ttext: \"\",\n\t\t\tts: 1_700_000_001,\n\t\t\ttools: [{ id: \"read\", name: \"read_plan\", status: \"done\", result: \"Read it.\" }],\n\t\t},\n\t\t{\n\t\t\tid: \"edit-entry\",\n\t\t\tauthor: { kind: \"agent\" },\n\t\t\ttext: \"\",\n\t\t\tts: 1_700_000_001,\n\t\t\ttools: [{ id: \"edit\", name: \"edit_plan\", status: \"running\", args: \"{}\" }],\n\t\t},\n\t];\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\tlet server = route.connectToServer();\n\t\tsockets.push(route);\n\t\troute.onMessage(message => server.send(message));\n\t\tserver.onMessage(message => {\n\t\t\tif (typeof message !== \"string\") return route.send(message);\n\t\t\tlet frame = JSON.parse(message) as Chat.History;\n\t\t\tif (frame.kind !== \"chat:history\") return route.send(message);\n\t\t\tlet history = JSON.stringify({ ...frame, busy: true, turn, entries });\n\t\t\tif (sockets.length === 2) {\n\t\t\t\treleaseHistory = () => route.send(history);\n\t\t\t\treconnecting.resolve();\n\t\t\t\treturn;\n\t\t\t}\n\t\t\troute.send(history);\n\t\t});\n\t});\n\n\tlet chat = chatPane(await join(\"ana\"));\n\tlet prose = chat.locator('[data-chat-message-id=\"prose\"]');\n\tlet disclosure = prose.getByRole(\"button\", { name: /Making changes/ });\n\tawait disclosure.click();\n\tawait disclosure.evaluate(element => element.setAttribute(\"data-open-node\", \"retained\"));\n\tawait expect(disclosure).toHaveAttribute(\"aria-expanded\", \"true\");\n\tawait sockets[0]!.close();\n\tawait reconnecting.promise;\n\tawait expect(prose).toHaveAttribute(\"data-chat-state\", \"disconnected\");\n\tlet offline = prose.getByRole(\"button\", { name: /Work details.*2 actions.*Connection lost/ });\n\tawait expect(offline).toHaveAttribute(\"data-open-node\", \"retained\");\n\tawait expect(offline).toHaveAttribute(\"aria-expanded\", \"true\");\n\tawait expect(prose.locator('[data-work-active=\"false\"][data-work-disconnected=\"true\"]'))\n\t\t.toHaveCount(1);\n\tawait expect(prose.getByRole(\"button\", { name: /Edit plan.*Last seen running/ })).toBeVisible();\n\treleaseHistory?.();\n\tawait expect(prose).toHaveAttribute(\"data-chat-state\", \"working\");\n\tawait expect(prose.getByRole(\"button\", { name: /Making changes/ })).toHaveAttribute(\n\t\t\"data-open-node\",\n\t\t\"retained\",\n\t);\n});\n\ntest(\"chat history keeps one active work row after Planner prose and a later room message\", async ({ join, page }) => {\n\tawait injectChatHistory(page, frame => ({\n\t\t...frame,\n\t\tbusy: true,\n\t\tturn: { id: \"turn-1\", handle: \"ana\", started: 1_700_000_000, entryOffset: 1, responded: true },\n\t\tentries: [\n\t\t\t{\n\t\t\t\tid: \"prompt\",\n\t\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\t\ttext: \"@chopin Check the current plan.\",\n\t\t\t\tts: 1_700_000_000,\n\t\t\t},\n\t\t\t{\n\t\t\t\tid: \"answer\",\n\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\ttext: \"I found the issue.\",\n\t\t\t\tts: 1_700_000_001,\n\t\t\t},\n\t\t\t{\n\t\t\t\tid: \"room\",\n\t\t\t\tauthor: { kind: \"member\", handle: \"sam\" },\n\t\t\t\ttext: \"Please include the examples.\",\n\t\t\t\tts: 1_700_000_002,\n\t\t\t},\n\t\t],\n\t}));\n\n\tlet chat = chatPane(await join(\"ana\"));\n\tawait expect(chat.getByText(\"I found the issue.\")).toBeVisible();\n\tawait expect(chat.getByText(\"Please include the examples.\")).toBeVisible();\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(1);\n\tawait expect(chat.getByText(\"Reviewing the next step\")).toBeVisible();\n});\n\ntest(\"chat waits for fresh history after reconnect before projecting a stale turn\", async ({ join, page }) => {\n\tlet sockets: WebSocketRoute[] = [];\n\tlet historyHeld = Promise.withResolvers();\n\tlet releaseHistory: (() => void) | undefined;\n\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\tlet server = route.connectToServer();\n\t\tsockets.push(route);\n\t\troute.onMessage(message => server.send(message));\n\t\tserver.onMessage(message => {\n\t\t\tif (typeof message !== \"string\") return route.send(message);\n\t\t\tlet frame = JSON.parse(message) as { kind?: string };\n\t\t\tif (sockets.length === 2 && frame.kind === \"chat:history\") {\n\t\t\t\troute.send(JSON.stringify({\n\t\t\t\t\tkind: \"chat:state\",\n\t\t\t\t\tts: 0,\n\t\t\t\t\tbusy: true,\n\t\t\t\t\tturn: {\n\t\t\t\t\t\tid: \"stale\",\n\t\t\t\t\t\thandle: \"ana\",\n\t\t\t\t\t\tstarted: 1_700_000_000,\n\t\t\t\t\t\tentryOffset: 0,\n\t\t\t\t\t\tresponded: false,\n\t\t\t\t\t},\n\t\t\t\t}));\n\t\t\t\treleaseHistory = () => route.send(message);\n\t\t\t\thistoryHeld.resolve();\n\t\t\t\treturn;\n\t\t\t}\n\t\t\troute.send(message);\n\t\t});\n\t});\n\n\tlet chat = chatPane(await join(\"ana\"));\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\tawait sockets[0]!.close();\n\tawait historyHeld.promise;\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n\n\treleaseHistory?.();\n\tawait ready(page);\n\tawait expect(chat.locator('[data-chat-state=\"working\"]')).toHaveCount(0);\n});\n\ntest(\n\t\"chat keeps a running turn and its queue readable together\",\n\tasync ({ join, page }, testInfo) => {\n\t\tawait injectChatHistory(page, frame => ({\n\t\t\t...frame,\n\t\t\tbusy: true,\n\t\t\tturn: {\n\t\t\t\tid: \"turn-1\",\n\t\t\t\thandle: \"maggie\",\n\t\t\t\tstarted: 1_700_000_001,\n\t\t\t\tentryOffset: 1,\n\t\t\t\tresponded: true,\n\t\t\t},\n\t\t\tentries: [\n\t\t\t\t{\n\t\t\t\t\tid: \"m1\",\n\t\t\t\t\tauthor: { kind: \"member\", handle: \"maggie\" },\n\t\t\t\t\ttext: \"@chopin Draft the migration plan.\",\n\t\t\t\t\tts: 1_700_000_000,\n\t\t\t\t},\n\t\t\t\t{\n\t\t\t\t\tid: \"a1\",\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: \"I’m checking the implementation before I edit.\",\n\t\t\t\t\tts: 1_700_000_001,\n\t\t\t\t\tstreaming: true,\n\t\t\t\t\ttools: [\n\t\t\t\t\t\t...Array.from({ length: 7 }, (_, index) => ({\n\t\t\t\t\t\t\tid: `t${index}`,\n\t\t\t\t\t\t\tname: \"read_file\",\n\t\t\t\t\t\t\tstatus: \"done\" as const,\n\t\t\t\t\t\t\ttook: 20,\n\t\t\t\t\t\t})),\n\t\t\t\t\t\t{ id: \"t7\", name: \"edit_plan\", status: \"running\" },\n\t\t\t\t\t],\n\t\t\t\t},\n\t\t\t],\n\t\t\tqueued: [\n\t\t\t\t{ id: \"q1\", handle: \"ana\", text: \"@chopin\" },\n\t\t\t\t{ id: \"q2\", handle: \"sam\", text: \"Check the rollback path too.\" },\n\t\t\t],\n\t\t}));\n\n\t\tawait join(\"ana\");\n\t\tlet chat = chatPane(page);\n\t\tlet live = chat.getByRole(\"button\", { name: /Making changes/ });\n\n\t\tawait expect(live).toContainText(\"7 finished\");\n\t\tawait expect(chat.getByText(\"Edit plan\", { exact: true })).toHaveCount(0);\n\t\tawait expect(chat.getByRole(\"button\", { name: \"Stop Chopin\" })).toHaveCount(0);\n\n\t\tlet mine = chat.locator(\"[data-chat-entry]\").filter({ hasText: \"Ask Chopin\" });\n\t\tlet theirs = chat.locator(\"[data-chat-entry]\").filter({\n\t\t\thasText: \"Check the rollback path too.\",\n\t\t});\n\t\tawait expect(mine).toHaveAttribute(\"data-chat-state\", \"queued\");\n\t\tawait expect(mine.getByRole(\"button\", { name: \"Withdraw queued message\" })).toBeVisible();\n\t\tawait expect(theirs.getByRole(\"button\", { name: \"Withdraw queued message\" })).toHaveCount(0);\n\n\t\tawait testInfo.attach(\"running-turn-with-queue\", {\n\t\t\tbody: await chat.screenshot(),\n\t\t\tcontentType: \"image/png\",\n\t\t});\n\t},\n);\n\ntest(\"a Planner question waits on people and opens its card\", async ({ join, page, seed }) => {\n\tlet widget = \"01K0N700000000000000000001\";\n\tlet question = {\n\t\tid: \"01K0N700000000000000000002\",\n\t\theader: \"Rollout\",\n\t\tquestion: \"Should we ship a small pilot?\",\n\t\tmultiple: false,\n\t\toptions: [{ id: \"01K0N700000000000000000003\", label: \"Start small\", description: \"\" }],\n\t};\n\tlet definition = { questions: [question] };\n\tawait seed(\n\t\t`# Migration\n\n\n`,\n\t\t{\n\t\t\trevision: 1,\n\t\t\tquestions: [{\n\t\t\t\tid: widget,\n\t\t\t\tdefinition,\n\t\t\t\tstatus: \"open\",\n\t\t\t\torigin: \"planner\",\n\t\t\t\thistory: [],\n\t\t\t\toptionOrigins: {},\n\t\t\t\teditors: [],\n\t\t\t}],\n\t\t\topenQuestions: [{\n\t\t\t\tdefinition,\n\t\t\t\tid: widget,\n\t\t\t\tmodel: storedQuestion(definition),\n\t\t\t\trevision: 0,\n\t\t\t\twidget,\n\t\t\t}],\n\t\t},\n\t);\n\tlet wire = await injectChatHistory(page, frame => ({\n\t\t...frame,\n\t\tentries: [{\n\t\t\tid: \"a1\",\n\t\t\tauthor: { kind: \"agent\" },\n\t\t\ttext: \"I need a decision before I edit.\",\n\t\t\tts: 1_700_000_001,\n\t\t\ttools: [\n\t\t\t\t{ id: \"t1\", name: \"read_plan\", status: \"done\", took: 20 },\n\t\t\t\t{\n\t\t\t\t\tid: \"t2\",\n\t\t\t\t\tname: \"ask\",\n\t\t\t\t\tstatus: \"running\",\n\t\t\t\t\targs: JSON.stringify({ revision: 1, questions: [{ question: question.question }] }),\n\t\t\t\t},\n\t\t\t],\n\t\t}],\n\t}));\n\n\tawait join(\"ana\");\n\tlet chat = chatPane(page);\n\tlet waiting = chat.locator(\"[data-tool-waiting]\");\n\tawait expect(waiting).toHaveText(/Waiting on your decision/);\n\tawait expect(chat.locator(\".chat-tool-loader\")).toHaveCount(0);\n\tawait waiting.getByRole(\"button\", { name: \"Open decision\" }).click();\n\tawait expect(\n\t\tpage.locator(\n\t\t\t`[data-document-view=\"plan\"] article[data-plan-sidecar-questionnaire=\"${widget}\"]`,\n\t\t),\n\t).toBeFocused();\n\n\twire.send({\n\t\tkind: \"chat:tool\",\n\t\tts: 0,\n\t\tentry: \"a1\",\n\t\tactivity: { id: \"t2\", name: \"ask\", status: \"done\", took: 4_000 },\n\t});\n\tawait expect(waiting).toHaveCount(0);\n\tawait expect(chat.getByRole(\"button\", { name: /2 tools/ })).toBeVisible();\n});\n\ntest(\n\t\"chat groups authors and collapses a finished tool run\",\n\tasync ({ join, seed }, testInfo) => {\n\t\tawait seed(\"# Migration\\n\", {\n\t\t\ttranscript: [\n\t\t\t\t{\n\t\t\t\t\tid: \"m1\",\n\t\t\t\t\tauthor: { kind: \"member\", handle: \"maggie\" },\n\t\t\t\t\ttext: \"@chopin Can you draft the migration?\",\n\t\t\t\t\tts: 1_700_000_000,\n\t\t\t\t},\n\t\t\t\t{\n\t\t\t\t\tid: \"m2\",\n\t\t\t\t\tauthor: { kind: \"member\", handle: \"maggie\" },\n\t\t\t\t\ttext: \"Focus on rollback.\",\n\t\t\t\t\tts: 1_700_000_001,\n\t\t\t\t},\n\t\t\t\t{\n\t\t\t\t\tid: \"a1\",\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: \"Drafted it.\",\n\t\t\t\t\tts: 1_700_000_002,\n\t\t\t\t\ttools: [\n\t\t\t\t\t\t{ id: \"t1\", name: \"read_file\", status: \"done\", took: 38 },\n\t\t\t\t\t\t{ id: \"t2\", name: \"grep\", status: \"done\", took: 12 },\n\t\t\t\t\t\t{ id: \"t3\", name: \"edit_plan\", status: \"done\", took: 1_200 },\n\t\t\t\t\t\t{ id: \"t4\", name: \"run_tests\", status: \"failed\" },\n\t\t\t\t\t],\n\t\t\t\t},\n\t\t\t\t{\n\t\t\t\t\tid: \"s1\",\n\t\t\t\t\tauthor: { kind: \"system\" },\n\t\t\t\t\ttext: \"@sam joined\",\n\t\t\t\t\tts: 1_700_000_003,\n\t\t\t\t},\n\t\t\t],\n\t\t});\n\n\t\tlet page = await join(\"ana\");\n\t\tlet chat = chatPane(page);\n\n\t\tawait expect(chat.getByText(\"Maggie\", { exact: true })).toHaveCount(1);\n\t\tawait expect(chat).toContainText(\"Can you draft the migration?\");\n\t\tawait expect(chat).not.toContainText(\"@\");\n\t\tawait expect(chat.getByText(\"Read file\", { exact: true })).toHaveCount(0);\n\n\t\tlet run = chat.getByRole(\"button\", {\n\t\t\tname: /Work details.*4 actions.*1 failed.*1\\.3s tool time/,\n\t\t});\n\t\tawait expect(run).toBeVisible();\n\t\tlet controlled = await run.getAttribute(\"aria-controls\");\n\t\texpect(controlled).toBeTruthy();\n\t\tawait expect(chat.locator(`[id=\"${controlled}\"]`)).toHaveCount(1);\n\t\tawait run.click();\n\t\tlet toolLog = chat.locator('[data-motion-disclosure=\"chat-tools\"]');\n\t\tlet icon = run.locator(\"[data-feedback-icon]\");\n\t\tawait expect(run).toHaveAttribute(\"aria-controls\", controlled!);\n\t\tawait expect(icon).toHaveAttribute(\"data-feedback-icon\", \"open\");\n\t\tawait expect(chat.getByText(\"Read file\", { exact: true })).toBeVisible();\n\t\tawait expect(chat.getByText(\"Run tests\", { exact: true })).toBeVisible();\n\t\tlet failed = chat.getByRole(\"listitem\").filter({ hasText: \"Run tests\" });\n\t\tawait expect(failed).toHaveAttribute(\"data-tool-status\", \"failed\");\n\t\tawait run.click();\n\t\tawait expect(run).toHaveAttribute(\"aria-controls\", controlled!);\n\t\tawait expect(toolLog).toHaveAttribute(\"aria-hidden\", \"true\");\n\t\tawait expect(toolLog).toHaveAttribute(\"inert\", \"\");\n\t\tawait run.click();\n\t\tawait expect(run).toHaveAttribute(\"aria-controls\", controlled!);\n\t\tawait expect(toolLog).toHaveCount(1);\n\t\tawait expect(toolLog).not.toHaveAttribute(\"aria-hidden\", \"true\");\n\t\tawait expect(toolLog).not.toHaveAttribute(\"inert\", \"\");\n\t\tawait expect(icon).toHaveAttribute(\"data-feedback-icon\", \"open\");\n\n\t\tawait expect(chat.locator(\"[data-chat-system]\")).toContainText(\"Sam joined\");\n\n\t\tawait testInfo.attach(\"finished-turn-with-failure-open\", {\n\t\t\tbody: await chat.screenshot(),\n\t\t\tcontentType: \"image/png\",\n\t\t});\n\t},\n);\n\ntest(\"an empty room settles rather than loading forever\", async ({ join }) => {\n\tlet page = await join(\"ana\");\n\n\tawait expect(page.locator('[aria-live=\"polite\"][data-level]')).toHaveAttribute(\n\t\t\"data-level\",\n\t\t\"hidden\",\n\t);\n});\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132],"tags",[71,72,73,74],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794627262167,"sidebar","expanded"]