[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_41":42,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":50,"_52":32,"_53":-7,"_54":-7,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","e2e/research-child-recovery.e2e.ts","oid","0c4e1be93fe58b0acabf1d2ea132eda247059c38","size",30416,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { countChildChannels, readSource, seedChildChannel } from \"./database\";\nimport {\n\tmarkResearchPublished,\n\tseedCompletedResearchWorkspace,\n\tseedPendingInlineResearchRequest,\n\tupdateResearchJobState,\n} from \"./research-recovery-database\";\nimport { content, expect, test } from \"./room\";\nimport { researchReportSource } from \"../apps/server/src/research/publication\";\n\nimport type { Chat, Research } from \"../packages/protocol/index\";\nimport type { Page } from \"@playwright/test\";\n\nconst PARENT_SOURCE = `# Parent document\n\n${Array.from({ length: 36 }, (_, index) => `Parent passage ${index + 1}.`).join(\"\\n\\n\")}\n`;\n\nconst CHILD_SOURCE = `# Source review\n\nThis ordinary child has its own editable document, Decisions, and inline comments.\n`;\n\nfunction port(baseURL: string): number {\n\treturn Number(new URL(baseURL).port);\n}\n\ntype ScriptedRequest = {\n\tchild?: Research.ReadyChild;\n\terror?: string;\n\tid: string;\n\tjobId: string;\n\tquestion: string;\n\tsources: Research.Source[];\n\tstage: Research.RequestStage;\n};\n\nfunction requestView(room: string, request: ScriptedRequest): Research.RequestView {\n\tlet base: Research.RequestViewBase = {\n\t\tid: request.id,\n\t\tchannelId: room,\n\t\tquestion: request.question,\n\t\tsources: request.sources,\n\t\tcreatedAt: \"2026-08-24T09:00:00.000Z\",\n\t\tupdatedAt: new Date().toISOString(),\n\t};\n\tif (request.stage === \"ready\") {\n\t\tif (!request.child) throw new Error(\"ready scripted research requires a child\");\n\t\treturn { ...base, state: \"completed\", stage: \"ready\", child: request.child };\n\t}\n\tif (request.stage === \"failed\") {\n\t\treturn {\n\t\t\t...base,\n\t\t\tstate: \"failed\",\n\t\t\tstage: \"failed\",\n\t\t\terror: request.error ?? \"Research could not be completed.\",\n\t\t};\n\t}\n\tif (request.stage === \"cancelled\") {\n\t\treturn { ...base, state: \"cancelled\", stage: \"cancelled\" };\n\t}\n\tlet state: Research.ActiveRequestState = request.stage === \"queued\" ? \"pending\" : \"running\";\n\treturn { ...base, state, stage: request.stage };\n}\n\nasync function scriptResearch(\n\tpage: Page,\n\troom: string,\n\tdatabasePort: number,\n\toptions: { planner?: boolean } = {},\n) {\n\tlet requests = new Map();\n\tlet retries: string[] = [];\n\tlet cancellations: string[] = [];\n\tlet reads: string[] = [];\n\tlet chatSends: { channelId: string; text: string; to: Chat.Destination }[] = [];\n\tlet sendToClient: ((frame: Research.Changed) => void) | undefined;\n\tif (options.planner) {\n\t\tawait page.route(\"**/api/session\", async route => {\n\t\t\tlet response = await route.fetch();\n\t\t\tlet session = await response.json() as Record;\n\t\t\tawait route.fulfill({ response, json: { ...session, agent: true } });\n\t\t});\n\t}\n\tawait page.routeWebSocket(\"**/ws?**\", route => {\n\t\tlet server = route.connectToServer();\n\t\tlet channelId = new URL(route.url()).searchParams.get(\"channel\");\n\t\tsendToClient = frame => route.send(JSON.stringify(frame));\n\t\troute.onMessage(message => {\n\t\t\tif (typeof message === \"string\" && channelId) {\n\t\t\t\ttry {\n\t\t\t\t\tlet frame = JSON.parse(message) as Partial;\n\t\t\t\t\tif (\n\t\t\t\t\t\tframe.kind === \"chat:send\"\n\t\t\t\t\t\t&& typeof frame.text === \"string\"\n\t\t\t\t\t\t&& (frame.to === \"room\" || frame.to === \"planner\")\n\t\t\t\t\t) chatSends.push({ channelId, text: frame.text, to: frame.to });\n\t\t\t\t} catch {\n\t\t\t\t\t// The real server remains authoritative for malformed and non-chat frames.\n\t\t\t\t}\n\t\t\t}\n\t\t\tserver.send(message);\n\t\t});\n\t\tserver.onMessage(message => route.send(message));\n\t});\n\tlet prefix = `/api/channels/${room}/research-requests`;\n\tawait page.route(\"**/api/channels/*/research-requests**\", async route => {\n\t\tlet request = route.request();\n\t\tlet path = new URL(request.url()).pathname;\n\t\tif (!path.startsWith(prefix)) {\n\t\t\tawait route.continue();\n\t\t\treturn;\n\t\t}\n\t\tlet suffix = path.slice(prefix.length);\n\t\tif (request.method() === \"POST\" && suffix === \"\") {\n\t\t\tlet body = request.postDataJSON() as { question: string; requestId: string };\n\t\t\tlet { jobId, workspaceId } = await seedPendingInlineResearchRequest(\n\t\t\t\tdatabasePort,\n\t\t\t\troom,\n\t\t\t\tbody.question,\n\t\t\t\tbody.requestId,\n\t\t\t);\n\t\t\tlet created: ScriptedRequest = {\n\t\t\t\tid: workspaceId,\n\t\t\t\tjobId,\n\t\t\t\tquestion: body.question,\n\t\t\t\tsources: [],\n\t\t\t\tstage: \"queued\",\n\t\t\t};\n\t\t\trequests.set(created.id, created);\n\t\t\tawait route.fulfill({\n\t\t\t\tjson: { repeated: false, request: requestView(room, created) },\n\t\t\t\tstatus: 201,\n\t\t\t});\n\t\t\treturn;\n\t\t}\n\t\tlet match = /^\\/([^/]+)(?:\\/(retry|cancel))?$/.exec(suffix);\n\t\tlet current = match ? requests.get(decodeURIComponent(match[1]!)) : undefined;\n\t\tif (!current) {\n\t\t\tawait route.fulfill({ json: { error: \"research workspace not found\" }, status: 404 });\n\t\t\treturn;\n\t\t}\n\t\tif (request.method() === \"POST\" && match?.[2] === \"retry\") {\n\t\t\tretries.push(current.id);\n\t\t\tawait updateResearchJobState(databasePort, room, current.jobId, \"pending\");\n\t\t\tcurrent.stage = \"queued\";\n\t\t\tcurrent.error = undefined;\n\t\t\tcurrent.sources = [];\n\t\t\tcurrent.child = undefined;\n\t\t\tawait route.fulfill({ json: requestView(room, current) });\n\t\t\treturn;\n\t\t}\n\t\tif (request.method() === \"POST\" && match?.[2] === \"cancel\") {\n\t\t\tcancellations.push(current.id);\n\t\t\tawait updateResearchJobState(databasePort, room, current.jobId, \"cancelled\");\n\t\t\tcurrent.stage = \"cancelled\";\n\t\t\tcurrent.error = undefined;\n\t\t\tawait route.fulfill({ json: requestView(room, current) });\n\t\t\treturn;\n\t\t}\n\t\tif (request.method() === \"GET\" && match?.[2] === undefined) {\n\t\t\treads.push(current.id);\n\t\t\tawait route.fulfill({ json: requestView(room, current) });\n\t\t\treturn;\n\t\t}\n\t\tawait route.fulfill({ json: { error: \"unsupported research fixture request\" }, status: 405 });\n\t});\n\n\tlet byQuestion = (question: string) => {\n\t\tlet found = [...requests.values()].find(request => request.question === question);\n\t\tif (!found) throw new Error(`missing scripted research request for ${question}`);\n\t\treturn found;\n\t};\n\treturn {\n\t\tcancellations,\n\t\tchatSends: (): readonly { channelId: string; text: string; to: Chat.Destination }[] =>\n\t\t\tchatSends.map(send => ({ ...send })),\n\t\treads,\n\t\trequests,\n\t\tretries,\n\t\tasync advance(\n\t\t\tquestion: string,\n\t\t\tstage: Research.RequestStage,\n\t\t\toverrides: Partial = {},\n\t\t) {\n\t\t\tlet request = byQuestion(question);\n\t\t\tif (stage === \"failed\") {\n\t\t\t\tawait updateResearchJobState(databasePort, room, request.jobId, \"failed\");\n\t\t\t}\n\t\t\tObject.assign(request, overrides, { stage });\n\t\t},\n\t\tinvalidate(question: string) {\n\t\t\tlet request = byQuestion(question);\n\t\t\tif (!sendToClient) throw new Error(\"research socket is not connected\");\n\t\t\tsendToClient({\n\t\t\t\tkind: \"research:changed\",\n\t\t\t\trevision: 1,\n\t\t\t\tts: 0,\n\t\t\t\tworkspaceId: request.id,\n\t\t\t});\n\t\t},\n\t\tasync publish(question: string, title: string) {\n\t\t\tlet request = byQuestion(question);\n\t\t\tlet child = await seedChildChannel(\n\t\t\t\tdatabasePort,\n\t\t\t\troom,\n\t\t\t\tcrypto.randomUUID(),\n\t\t\t\ttitle,\n\t\t\t\tCHILD_SOURCE,\n\t\t\t);\n\t\t\tawait markResearchPublished(databasePort, room, request.id, child.id);\n\t\t\tawait updateResearchJobState(databasePort, room, request.jobId, \"completed\");\n\t\t\trequest.stage = \"ready\";\n\t\t\trequest.error = undefined;\n\t\t\trequest.child = {\n\t\t\t\tid: child.id,\n\t\t\t\tslug: child.slug,\n\t\t\t\tsourceCount: request.sources.length,\n\t\t\t\tsummary: \"A complete report grounded in the discovered sources.\",\n\t\t\t\ttitle,\n\t\t\t};\n\t\t\treturn child;\n\t\t},\n\t};\n}\n\nasync function startInlineResearch(page: Page, question: string) {\n\tlet editor = content(page);\n\tawait editor.click();\n\tawait page.keyboard.press(\"ControlOrMeta+End\");\n\tawait page.keyboard.press(\"Enter\");\n\tawait page.keyboard.type(\"/research\");\n\tawait page.keyboard.press(\"Enter\");\n\tlet composer = page.getByRole(\"region\", { name: \"Research question\", exact: true });\n\tawait composer.getByRole(\"textbox\", { name: \"Research question\", exact: true }).fill(question);\n\tawait expect(composer).toHaveCSS(\"transform\", \"none\");\n\tlet authoredOrder = await page.locator(\"[data-research-draft-anchor]\").evaluate(anchor => {\n\t\tlet editor = anchor.closest('[role=\"textbox\"][aria-label=\"editable markdown\"]')!;\n\t\tlet block = anchor;\n\t\twhile (block.parentElement !== editor) block = block.parentElement!;\n\t\tlet next = block.nextElementSibling;\n\t\twhile (\n\t\t\tnext && (next.classList.contains(\"plan-research-draft-host\") || !next.textContent?.trim())\n\t\t) {\n\t\t\tnext = next.nextElementSibling;\n\t\t}\n\t\tlet previous: Element | null = block;\n\t\twhile (previous && !previous.textContent?.trim()) previous = previous.previousElementSibling!;\n\t\treturn {\n\t\t\tnext: next?.textContent?.trim() || null,\n\t\t\tprevious: previous?.textContent?.trim() || null,\n\t\t};\n\t});\n\tawait page.keyboard.press(\"Enter\");\n\tawait expect(page.getByRole(\"region\", {\n\t\tname: \"Research question\",\n\t\texact: true,\n\t\tincludeHidden: true,\n\t})).toHaveCount(0);\n\tawait expect(editor.locator(\".plan-research-draft-host\")).toHaveCount(0);\n\tlet card = page.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: question });\n\tawait expect(card).toHaveCount(1);\n\texpect(\n\t\tawait card.evaluate(article => {\n\t\t\tlet editor = article.closest('[role=\"textbox\"][aria-label=\"editable markdown\"]')!;\n\t\t\tlet block = article;\n\t\t\twhile (block.parentElement !== editor) block = block.parentElement!;\n\t\t\tlet neighbor = (direction: \"nextElementSibling\" | \"previousElementSibling\") => {\n\t\t\t\tlet sibling = block[direction];\n\t\t\t\twhile (sibling && !sibling.textContent?.trim()) sibling = sibling[direction];\n\t\t\t\treturn sibling?.textContent?.trim() || null;\n\t\t\t};\n\t\t\treturn { next: neighbor(\"nextElementSibling\"), previous: neighbor(\"previousElementSibling\") };\n\t\t}),\n\t).toEqual(authoredOrder);\n\tawait expect(card.getByText(\"Waiting to start\", { exact: true })).toBeVisible();\n\tawait expect(page.getByRole(\"button\", { name: \"Place research\", exact: true }))\n\t\t.toHaveCount(0);\n\tawait expect(page.getByRole(\"button\", { name: \"Search public web\", exact: true }))\n\t\t.toHaveCount(0);\n\treturn card;\n}\n\ntest(\n\t\"research drafts and lifecycle cards share the prose column and scroll in document flow\",\n\tasync ({ baseURL, join, page, room, seed }, testInfo) => {\n\t\tawait seed(PARENT_SOURCE);\n\t\tlet research = await scriptResearch(page, room, port(baseURL!));\n\t\tlet opened = await join(\"ana\");\n\t\tawait opened.setViewportSize({ width: 1500, height: 895 });\n\t\tlet hideChat = opened.getByRole(\"button\", { name: \"Hide chat\", exact: true });\n\t\tif (await hideChat.isVisible()) await hideChat.click();\n\t\tlet editor = content(opened);\n\t\tawait expect.poll(async () => (await editor.locator(\"p\").first().boundingBox())!.width)\n\t\t\t.toBeCloseTo(650, 0);\n\t\tawait editor.click();\n\t\tawait opened.keyboard.press(\"Enter\");\n\t\tawait opened.keyboard.type(\"/research\");\n\t\tawait opened.keyboard.press(\"Enter\");\n\t\tlet composer = opened.getByRole(\"region\", { name: \"Research question\", exact: true });\n\t\tlet question = \"Compare evidence without moving the research block outside the document.\";\n\t\tawait composer.getByRole(\"textbox\", { name: \"Research question\", exact: true }).fill(question);\n\t\tawait expect(composer).toHaveCSS(\"transform\", \"none\");\n\t\tlet layout = await composer.evaluate(element => {\n\t\t\tlet paragraph = document.querySelector(\"[data-research-draft-anchor]\")!;\n\t\t\tlet prose = paragraph.getBoundingClientRect();\n\t\t\tlet draft = element.getBoundingClientRect();\n\t\t\treturn {\n\t\t\t\tposition: getComputedStyle(element).position,\n\t\t\t\tproseWidth: prose.width,\n\t\t\t\twidth: draft.width,\n\t\t\t\tleft: draft.left,\n\t\t\t\tproseLeft: prose.left,\n\t\t\t\ttop: draft.top,\n\t\t\t\tproseBottom: prose.bottom,\n\t\t\t};\n\t\t});\n\t\texpect(layout.position).toBe(\"static\");\n\t\texpect(layout.proseWidth).toBeCloseTo(650, 0);\n\t\texpect(layout.width).toBeCloseTo(layout.proseWidth, 0);\n\t\texpect(layout.left).toBeCloseTo(layout.proseLeft, 0);\n\t\texpect(layout.top).toBeGreaterThanOrEqual(layout.proseBottom);\n\t\tawait opened.screenshot({ path: testInfo.outputPath(\"research-draft-layout.png\") });\n\t\tlet before = await composer.boundingBox();\n\t\tlet travelled = await editor.evaluate(element => {\n\t\t\tlet scroller = element.closest(\"[data-plan-scroll]\")!;\n\t\t\tlet before = scroller.scrollTop;\n\t\t\tscroller.scrollTop += 80;\n\t\t\treturn scroller.scrollTop - before;\n\t\t});\n\t\texpect(travelled).toBeCloseTo(80, 0);\n\t\tawait expect.poll(async () => (await composer.boundingBox())!.y - before!.y)\n\t\t\t.toBeCloseTo(-travelled, 0);\n\t\tawait expect(composer.getByRole(\"textbox\", { name: \"Research question\", exact: true }))\n\t\t\t.toBeFocused();\n\t\tawait opened.keyboard.press(\"Enter\");\n\t\tawait expect(opened.getByRole(\"region\", {\n\t\t\tname: \"Research question\",\n\t\t\texact: true,\n\t\t\tincludeHidden: true,\n\t\t})).toHaveCount(0);\n\t\tawait expect(editor.locator(\".plan-research-draft-host\")).toHaveCount(0);\n\t\tlet card = opened.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: question });\n\t\tawait expect(card).toBeVisible();\n\t\tfor (let stage of [\"queued\", \"searching\", \"writing\"] as const) {\n\t\t\tif (stage !== \"queued\") await research.advance(question, stage);\n\t\t\tawait expect(card).toHaveAttribute(\"data-stage\", stage);\n\t\t\texpect((await card.boundingBox())!.width).toBeCloseTo(layout.proseWidth, 0);\n\t\t}\n\t\tawait research.publish(question, \"Inline research report\");\n\t\tlet ready = opened.getByRole(\"article\", { name: \"Research\" }).filter({\n\t\t\thas: opened.getByRole(\"button\", { name: \"Open Inline research report\", exact: true }),\n\t\t});\n\t\tawait expect(ready).toHaveAttribute(\"data-stage\", \"ready\");\n\t\texpect((await ready.boundingBox())!.width).toBeCloseTo(layout.proseWidth, 0);\n\t\tawait opened.screenshot({ path: testInfo.outputPath(\"research-ready-layout.png\") });\n\t\tawait opened.setViewportSize({ width: 390, height: 844 });\n\t\tawait expect.poll(async () => {\n\t\t\tlet prose = (await editor.locator(\"p\").first().boundingBox())!.width;\n\t\t\treturn Math.abs((await ready.boundingBox())!.width - prose);\n\t\t}).toBeLessThan(1);\n\t},\n);\n\ntest(\"a submitted /research card stays in the document through reload\", async ({ baseURL, join, page, room, seed }) => {\n\tawait seed(PARENT_SOURCE);\n\tlet databasePort = port(baseURL!);\n\tlet research = await scriptResearch(page, room, databasePort);\n\tlet resets = 0;\n\tpage.on(\"websocket\", socket => {\n\t\tsocket.on(\"framereceived\", frame => {\n\t\t\tif (String(frame.payload).includes('\"kind\":\"plan:reset\"')) resets++;\n\t\t});\n\t});\n\tlet opened = await join(\"ana\");\n\tlet brief = \"Compare evidence for keeping submitted research in place.\";\n\tlet card = await startInlineResearch(opened, brief);\n\tlet id = [...research.requests.values()].find(request => request.question === brief)!.id;\n\tawait expect.poll(async () => readSource(databasePort, room)).toContain(\n\t\t``,\n\t);\n\tawait expect(card).toBeVisible();\n\texpect(resets).toBe(0);\n\n\tawait opened.reload();\n\tawait expect(opened.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: brief }))\n\t\t.toBeVisible();\n});\n\ntest(\"inline research publishes one ordinary child and opens it\", async ({ baseURL, join, page, room, seed }) => {\n\ttest.slow();\n\tawait seed(PARENT_SOURCE);\n\tlet databasePort = port(baseURL!);\n\tlet research = await scriptResearch(page, room, databasePort, { planner: true });\n\tlet catalogueReads = 0;\n\tlet staleCatalogue = Promise.withResolvers();\n\tlet staleCatalogueStarted = Promise.withResolvers();\n\tlet heldCatalogue = false;\n\tawait page.route(\"**/api/repositories/octo-org/score/channels**\", async route => {\n\t\tlet url = new URL(route.request().url());\n\t\tif (heldCatalogue || url.searchParams.get(\"includeArchived\") === \"true\") {\n\t\t\tawait route.continue();\n\t\t\treturn;\n\t\t}\n\t\theldCatalogue = true;\n\t\tlet response = await route.fetch();\n\t\tstaleCatalogueStarted.resolve();\n\t\tawait staleCatalogue.promise;\n\t\tawait route.fulfill({ response });\n\t});\n\tpage.on(\"request\", request => {\n\t\tif (\n\t\t\trequest.method() === \"GET\"\n\t\t\t&& new URL(request.url()).pathname === \"/api/repositories/octo-org/score/channels\"\n\t\t) catalogueReads++;\n\t});\n\tlet opening = join(\"ana\");\n\tawait staleCatalogueStarted.promise;\n\tlet opened = await opening;\n\tlet sidebar = opened.getByRole(\"complementary\", { name: \"Projects\" });\n\tlet childHrefs = () =>\n\t\tsidebar.getByRole(\"link\").evaluateAll(links =>\n\t\t\tlinks\n\t\t\t\t.map(link => (link as HTMLAnchorElement).href)\n\t\t\t\t.filter(href => new URL(href).pathname.includes(\"/children/\"))\n\t\t);\n\tlet brief = \"Compare the public evidence for deterministic child publication.\";\n\tlet childTitle = `Lifecycle evidence ${room.slice(0, 8)}`;\n\tlet card = await startInlineResearch(opened, brief);\n\n\tawait expect(card.getByText(\"Waiting to start\", { exact: true })).toBeVisible();\n\tawait expect(card).toContainText(brief);\n\tawait expect(card.getByRole(\"button\", { name: \"Decisions\", exact: true })).toHaveCount(0);\n\tawait expect(card.getByRole(\"complementary\", { name: \"Chat\" })).toHaveCount(0);\n\tawait expect.poll(childHrefs).toEqual([]);\n\texpect(await countChildChannels(databasePort, room)).toBe(0);\n\tawait expect(opened).toHaveURL(url => !url.pathname.includes(\"/children/\"));\n\n\tawait research.advance(brief, \"searching\");\n\tawait expect(card.getByText(\"Searching sources\", { exact: true })).toBeVisible();\n\tawait research.advance(brief, \"analyzing\", {\n\t\tsources: [{ title: \"Primary public source\", url: \"https://example.com/source\" }],\n\t});\n\tawait expect(card.getByText(\"Reading sources\", { exact: true })).toBeVisible();\n\tawait expect(card.locator(\"xpath=..\")).toContainText(\"1 source found\");\n\tawait expect(card).not.toContainText(\"A complete report grounded in the discovered sources.\");\n\tawait research.advance(brief, \"writing\");\n\tawait expect(card.getByText(\"Writing report\", { exact: true })).toBeVisible();\n\tawait expect.poll(childHrefs).toEqual([]);\n\texpect(await countChildChannels(databasePort, room)).toBe(0);\n\n\tlet readsBeforePublication = catalogueReads;\n\tlet child = await research.publish(brief, childTitle);\n\tlet readyCard = opened.getByRole(\"article\", { name: \"Research\" })\n\t\t.filter({ hasText: childTitle });\n\tawait expect(readyCard).toHaveAttribute(\"data-stage\", \"ready\");\n\tawait expect(readyCard).toContainText(\"A complete report grounded in the discovered sources.\");\n\tawait expect(readyCard).toContainText(\"1 source\");\n\texpect(catalogueReads).toBe(readsBeforePublication);\n\tstaleCatalogue.resolve();\n\tlet childLink = sidebar.getByRole(\"link\", { name: childTitle, exact: true });\n\tawait expect(childLink).toBeVisible();\n\tawait expect(childLink).toHaveAttribute(\"href\", child.path);\n\texpect(catalogueReads).toBe(readsBeforePublication + 1);\n\tawait expect.poll(() => countChildChannels(databasePort, room)).toBe(1);\n\n\tlet open = readyCard.getByRole(\"button\", { name: `Open ${childTitle}`, exact: true });\n\tawait open.focus();\n\tawait open.click();\n\tlet surface = opened.getByRole(\"region\", { name: `Child document: ${childTitle}` });\n\tawait expect(opened).toHaveURL(url => url.pathname === child.path);\n\tawait expect(surface.locator(`[data-workspace-room=\"${child.id}\"]`)).toBeVisible();\n\tawait surface.getByRole(\"button\", { name: `Close ${childTitle}`, exact: true }).click();\n\tawait expect(surface).toHaveCount(0);\n\tawait expect(open).toBeFocused();\n});\n\ntest(\"failed research retries by identity while cancelled research never publishes\", async ({ baseURL, join, page, room, seed }) => {\n\tawait seed(\"# Recovery parent\\n\");\n\tlet databasePort = port(baseURL!);\n\tlet research = await scriptResearch(page, room, databasePort);\n\tlet opened = await join(\"ana\");\n\tlet sidebar = opened.getByRole(\"complementary\", { name: \"Projects\" });\n\tlet failedBrief = \"Retry this exact failed research brief.\";\n\tlet failedCard = await startInlineResearch(opened, failedBrief);\n\tawait expect(failedCard.getByText(\"Waiting to start\", { exact: true })).toBeVisible();\n\tlet failedId =\n\t\t[...research.requests.values()].find(request => request.question === failedBrief)!.id;\n\t// The card can be visible before its initial document placement is durable.\n\tawait expect.poll(async () => readSource(databasePort, room)).toContain(failedId);\n\tawait research.advance(failedBrief, \"failed\", {\n\t\terror: \"Research could not be completed safely.\",\n\t});\n\tawait expect(failedCard.getByText(\"Research failed\", { exact: true })).toBeVisible();\n\tawait expect(failedCard).toContainText(\"Research could not be completed safely.\");\n\tawait expect.poll(() => countChildChannels(databasePort, room)).toBe(0);\n\n\tlet cancelledBrief = \"Cancel this exact research brief.\";\n\tlet cancelledCard = await startInlineResearch(opened, cancelledBrief);\n\tawait expect(cancelledCard.getByText(\"Waiting to start\", { exact: true })).toBeVisible();\n\tlet cancelledId =\n\t\t[...research.requests.values()].find(request => request.question === cancelledBrief)!.id;\n\tawait cancelledCard.getByText(\"Waiting to start\", { exact: true }).click();\n\tawait opened.keyboard.press(\"Backspace\");\n\tawait expect(cancelledCard).toBeVisible();\n\tawait expect.poll(async () =>\n\t\t(await readSource(databasePort, room)).match(/ countChildChannels(databasePort, room)).toBe(1);\n\tlet source = await readSource(databasePort, room);\n\texpect(source.match(/ id === cancelledId).length;\n\tresearch.invalidate(cancelledBrief);\n\tawait expect.poll(() => research.reads.filter(id => id === cancelledId).length)\n\t\t.toBe(readsBeforeInvalidation + 1);\n\tawait expect(cancelledCard.getByText(\"Cancelled\", { exact: true })).toBeVisible();\n\tawait expect(sidebar.getByRole(\"link\", { name: \"Late cancelled child\", exact: true }))\n\t\t.toHaveCount(0);\n\tawait expect.poll(() => countChildChannels(databasePort, room)).toBe(1);\n\tawait expect.poll(async () =>\n\t\t(await readSource(databasePort, room)).match(/\n\t\t(await readSource(databasePort, room)).match(/ {\n\tlet databasePort = port(baseURL!);\n\tlet brief = \"Compare the evidence for a stable research document.\";\n\tlet title = `Persisted research ${room.slice(0, 8)}`;\n\tlet workspaceId = `workspace-${crypto.randomUUID()}`;\n\tlet answerJobId = `job-${crypto.randomUUID()}`;\n\tlet originMessageId = crypto.randomUUID();\n\tlet report = {\n\t\ttitle,\n\t\tsummary: \"A complete report grounded in the discovered sources.\",\n\t\tfindings: [{\n\t\t\ttext: \"The source supports the report.\",\n\t\t\tsourceUrls: [\"https://example.com/source\"],\n\t\t}],\n\t\tcaveats: [\"The evidence has a limited scope.\"],\n\t};\n\tlet sources = [{ title: \"Primary public source\", url: \"https://example.com/source\" }];\n\tlet child = await seedChildChannel(\n\t\tdatabasePort,\n\t\troom,\n\t\tcrypto.randomUUID(),\n\t\ttitle,\n\t\tresearchReportSource(report, sources),\n\t);\n\tlet notice = `Research is ready. [Open the research document](${child.path}).`;\n\tawait seed(`# Parent document\\n\\n\\n`, {\n\t\ttranscript: [{\n\t\t\tid: originMessageId,\n\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\ttext: `@chopin ${brief}`,\n\t\t\tts: 1_700_000_000,\n\t\t}, {\n\t\t\tid: `research-ready:${workspaceId}:${answerJobId}`,\n\t\t\tauthor: { kind: \"system\" },\n\t\t\ttext: notice,\n\t\t\tts: 1_700_000_001,\n\t\t}],\n\t});\n\tawait seedCompletedResearchWorkspace(databasePort, room, {\n\t\tworkspaceId,\n\t\tanswerJobId,\n\t\tplannerOriginMessageId: originMessageId,\n\t\tquestion: brief,\n\t\treport: {\n\t\t\ttitle,\n\t\t\tsummary: report.summary,\n\t\t\tfinding: report.findings[0]!.text,\n\t\t\tcaveat: report.caveats[0]!,\n\t\t\tsource: sources[0]!,\n\t\t},\n\t});\n\tawait markResearchPublished(databasePort, room, workspaceId, child.id);\n\tlet opened = await join(\"ana\");\n\tlet assertRecovered = async () => {\n\t\tlet card = opened.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: title });\n\t\tawait expect(card).toHaveAttribute(\"data-stage\", \"ready\");\n\t\tawait expect(card.getByRole(\"button\", { name: `Open ${title}`, exact: true }))\n\t\t\t.toBeVisible();\n\t\tawait expect(\n\t\t\topened.getByRole(\"complementary\", { name: \"Projects\" })\n\t\t\t\t.getByRole(\"link\", { name: title, exact: true }),\n\t\t).toHaveAttribute(\"href\", child.path);\n\t\tlet chat = opened.getByRole(\"complementary\", { name: \"Chat\" });\n\t\tawait expect(chat.getByRole(\"link\", { name: \"Open the research document\" }))\n\t\t\t.toHaveAttribute(\"href\", child.path);\n\t\tawait expect(chat.getByText(\"Research is ready.\")).toHaveCount(1);\n\t};\n\tawait assertRecovered();\n\tawait opened.reload();\n\tawait assertRecovered();\n\n\tawait opened.getByRole(\"complementary\", { name: \"Projects\" })\n\t\t.getByRole(\"link\", { name: title, exact: true }).click();\n\tlet surface = opened.getByRole(\"region\", { name: `Child document: ${title}` });\n\tlet provenance = surface.locator(\"[data-child-provenance]\");\n\tlet parentTitle = `Test ${room.slice(0, 8)}`;\n\tawait expect(provenance).toContainText(`Research from ${parentTitle}`);\n\tawait expect(provenance).toContainText(\"by e2e\");\n\tawait expect(provenance).toContainText(\"1 source\");\n\tlet briefToggle = provenance.getByRole(\"button\", { name: \"Brief\", exact: true });\n\tawait expect(briefToggle).toHaveAttribute(\"aria-expanded\", \"false\");\n\tawait expect(provenance.getByText(brief, { exact: true })).toBeHidden();\n\tawait briefToggle.click();\n\tawait expect(provenance.getByText(brief, { exact: true })).toBeVisible();\n\tawait expect(surface.getByRole(\"complementary\", { name: \"Chat\" }))\n\t\t.toContainText(\"Discuss this report here.\");\n\tawait provenance.getByRole(\"button\", { name: parentTitle, exact: true }).click();\n\tawait expect(surface).toHaveCount(0);\n\tawait expect(\n\t\topened.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: title }),\n\t).toBeFocused();\n\tlet response = await opened.context().request.get(\n\t\t`/api/channels/${room}/research-requests/${workspaceId}`,\n\t);\n\texpect(response.ok()).toBe(true);\n\texpect(await response.json()).toMatchObject({ stage: \"ready\", child: { id: child.id } });\n\texpect(await countChildChannels(databasePort, room)).toBe(1);\n});\n\ntest(\"a failed research card and its Chat notice survive reconnect once\", async ({ baseURL, join, room, seed }) => {\n\tlet databasePort = port(baseURL!);\n\tlet brief = \"Check evidence that cannot be retrieved.\";\n\tlet originMessageId = crypto.randomUUID();\n\tlet { jobId, workspaceId } = await seedPendingInlineResearchRequest(\n\t\tdatabasePort,\n\t\troom,\n\t\tbrief,\n\t\tcrypto.randomUUID(),\n\t\t\"U_e2e\",\n\t\toriginMessageId,\n\t);\n\tawait updateResearchJobState(databasePort, room, jobId, \"failed\");\n\tlet notice = \"Research could not be completed. You can retry it from the research card.\";\n\tawait seed(`# Parent document\\n\\n\\n`, {\n\t\ttranscript: [{\n\t\t\tid: originMessageId,\n\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\ttext: `@chopin ${brief}`,\n\t\t\tts: 1_700_000_000,\n\t\t}, {\n\t\t\tid: `research-failed:${workspaceId}:${jobId}`,\n\t\t\tauthor: { kind: \"system\" },\n\t\t\ttext: notice,\n\t\t\tts: 1_700_000_001,\n\t\t}],\n\t});\n\tlet opened = await join(\"ana\");\n\tlet assertRecovered = async () => {\n\t\tlet card = opened.getByRole(\"article\", { name: \"Research\" }).filter({ hasText: brief });\n\t\tawait expect(card.getByText(\"Research failed\", { exact: true })).toBeVisible();\n\t\tawait expect(card.getByRole(\"button\", { name: \"Retry research\" })).toBeVisible();\n\t\tlet chat = opened.getByRole(\"complementary\", { name: \"Chat\" });\n\t\tawait expect(chat.getByText(notice, { exact: true })).toHaveCount(1);\n\t};\n\tawait assertRecovered();\n\tawait opened.reload();\n\tawait assertRecovered();\n\tlet response = await opened.context().request.get(\n\t\t`/api/channels/${room}/research-requests/${workspaceId}`,\n\t);\n\texpect(response.ok()).toBe(true);\n\texpect(await response.json()).toMatchObject({ stage: \"failed\" });\n\texpect(await countChildChannels(databasePort, room)).toBe(0);\n});\n\ntest(\"parent metadata keeps a child route while its document is loading\", async ({ baseURL, join, room }) => {\n\tlet childTitle = `Pending child ${room.slice(0, 8)}`;\n\tlet child = await seedChildChannel(\n\t\tport(baseURL!),\n\t\troom,\n\t\tcrypto.randomUUID(),\n\t\tchildTitle,\n\t\tCHILD_SOURCE,\n\t);\n\tlet page = await join(\"ana\");\n\tlet requested!: () => void;\n\tlet childRequested = new Promise(resolve => requested = resolve);\n\tlet release!: () => void;\n\tlet held = new Promise(resolve => release = resolve);\n\tawait page.route(\n\t\turl => url.pathname.endsWith(`/documents/${child.slug}`),\n\t\tasync route => {\n\t\t\trequested();\n\t\t\tawait held;\n\t\t\tawait route.continue().catch(() => {});\n\t\t},\n\t);\n\ttry {\n\t\tawait page.getByRole(\"complementary\", { name: \"Projects\" })\n\t\t\t.getByRole(\"link\", { name: childTitle, exact: true }).click();\n\t\tawait childRequested;\n\t\tawait expect(page).toHaveURL(url => url.pathname === child.path);\n\t\tlet title = `Renamed parent ${room.slice(0, 8)}`;\n\t\tlet response = await page.context().request.patch(`/api/channels/${room}`, {\n\t\t\theaders: { origin: new URL(baseURL!).origin },\n\t\t\tdata: { title },\n\t\t});\n\t\texpect(response.ok()).toBe(true);\n\t\tlet renamed = (await response.json()) as { channel: { slug: string } };\n\t\tawait expect(page.locator(`[data-workspace-room=\"${room}\"] .room-header`))\n\t\t\t.toContainText(title);\n\t\tawait expect(page).toHaveURL(url =>\n\t\t\turl.pathname === `/documents/octo-org/score/${renamed.channel.slug}/children/${child.slug}`\n\t\t);\n\t} finally {\n\t\trelease();\n\t}\n\tawait expect(page.locator(`[data-workspace-room=\"${child.id}\"]`)).toBeVisible();\n});\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[183,184,185,186,187,188,189,190,191,192,193,194,195],"navigation",{"_55":56,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_43":32,"_137":14,"_138":32,"_49":50,"_51":50},"branches",[74,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,14,127,128,129,130],"tags",[70,71,72,73],"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","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",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":50,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_53":174,"_175":32,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_53":174,"_175":32,"_176":174,"_177":50},{"_168":169,"_170":171,"_15":169,"_172":173,"_53":174,"_175":32,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_53":174,"_175":32,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_53":174,"_175":32,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_53":174,"_175":32,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_53":32,"_175":32,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_53":32,"_175":32,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_53":32,"_175":32,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_53":32,"_175":32,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_53":32,"_175":32,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_53":32,"_175":32,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_53":32,"_175":32,"_176":32},{"_168":202,"_170":203,"_15":202,"_172":204,"_53":32,"_175":32,"_176":32},{"_168":199,"_170":200,"_15":199,"_172":201,"_53":32,"_175":32,"_176":32},{"_168":196,"_170":197,"_15":196,"_172":198,"_53":32,"_175":32,"_176":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794434530037,"sidebar","expanded"]