[{"_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","f533166947cd24ed697c06de5f691efd4287c5dd","path","e2e/research-child-documents.e2e.ts","oid","02550b5facf9d2f9a6b3d7c633a784f1d1a49b3f","size",16891,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { countChildChannels, readSource, seedChildChannel } from \"./database\";\nimport { content, expect, test } from \"./room\";\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\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 created: ScriptedRequest = {\n\t\t\t\tid: body.requestId,\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\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\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\tadvance(\n\t\t\tquestion: string,\n\t\t\tstage: Research.RequestStage,\n\t\t\toverrides: Partial = {},\n\t\t) {\n\t\t\tObject.assign(byQuestion(question), 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\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(\"Meta+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\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 (next && !next.textContent?.trim()) next = next.nextElementSibling;\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(composer).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(\"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\tresearch.advance(brief, \"searching\");\n\tawait expect(card.getByText(\"Searching sources\", { exact: true })).toBeVisible();\n\tresearch.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\t// Progress sits under the card, beside it in the tracked wrapper.\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\tresearch.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).toContainText(/Research\\s*·\\s*1 source/);\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\tresearch.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(/ request.question === failedBrief)!.id;\n\tawait failedCard.getByRole(\"button\", { name: \"Retry research\" }).click();\n\tawait expect(failedCard.getByText(\"Waiting to start\", { exact: true })).toBeVisible();\n\texpect(research.retries).toEqual([failedId]);\n\tresearch.advance(failedBrief, \"writing\", {\n\t\tsources: [{ title: \"Recovery source\", url: \"https://example.com/recovery\" }],\n\t});\n\tawait expect(failedCard.getByText(\"Writing report\", { exact: true })).toBeVisible();\n\tlet recoveredTitle = `Recovered evidence ${room.slice(0, 8)}`;\n\tawait research.publish(failedBrief, recoveredTitle);\n\tawait expect(sidebar.getByRole(\"link\", { name: recoveredTitle, exact: true })).toBeVisible();\n\tawait expect.poll(() => 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(/