[{"_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","apps/server/src/harness/atomic/human-input.test.ts","oid","e967640680a45f9a14ccd92c2fe826f54ee3b453","size",42627,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { afterEach, expect, test } from \"bun:test\";\nimport { $createParagraphNode, $createTextNode, $getRoot, $nodesOfType } from \"lexical\";\nimport * as Y from \"yjs\";\nimport { cardStatus, limits, QuestionnaireNode, ulid } from \"@chopin/dialect\";\nimport { limits as questionLimits } from \"@chopin/question\";\nimport * as QuestionModel from \"@chopin/question\";\nimport * as Questions from \"../../questions/service\";\nimport * as Store from \"../../questions/store\";\nimport * as Plan from \"../../plan/service\";\nimport * as Room from \"../../plan/room\";\nimport * as Edit from \"../../plan/edit\";\nimport * as Comments from \"../../comments/service\";\nimport { hostInputRoom } from \"../../testing/decisions\";\nimport { peer } from \"../../testing/peer\";\nimport type { QuestionParams } from \"@bastani/atomic\";\n\nlet cleanups: Array<() => Promise> = [];\nafterEach(async () => {\n\tfor (let cleanup of cleanups.splice(0)) await cleanup();\n});\n\nasync function fixture(expiresInMs?: number) {\n\tlet f = await hostInputRoom(expiresInMs);\n\tcleanups.push(f.close);\n\treturn f;\n}\n\nlet params: QuestionParams = {\n\tquestions: [\n\t\t{\n\t\t\theader: \"Choice\",\n\t\t\tquestion: \" Which? \",\n\t\t\toptions: [\n\t\t\t\t{ label: \" A \", description: \" first \", preview: \"preview A\" },\n\t\t\t\t{ label: \"B\", description: \"second\" },\n\t\t\t],\n\t\t},\n\t\t{\n\t\t\theader: \"Multiple\",\n\t\t\tquestion: \"Select several\",\n\t\t\tmultiSelect: true,\n\t\t\toptions: [\n\t\t\t\t{ label: \"C\", description: \"\" },\n\t\t\t\t{ label: \"D\", description: \"\" },\n\t\t\t],\n\t\t},\n\t\t{\n\t\t\theader: \"Custom\",\n\t\t\tquestion: \"Or free text?\",\n\t\t\toptions: [\n\t\t\t\t{ label: \"E\", description: \"\" },\n\t\t\t\t{ label: \"F\", description: \"\" },\n\t\t\t],\n\t\t},\n\t],\n};\n\ntest(\"HostInput appends one ordered questionnaire batch and returns typed answers verbatim\", async () => {\n\tlet f = await fixture();\n\tlet edited = Edit.apply(f.plan, f.plan.revision, [{\n\t\top: \"replace_root\",\n\t\tsource: \"# Existing document\\n\\nLast paragraph.\\n\",\n\t}]);\n\tif (!edited.ok) throw new Error(\"fixture edit failed\");\n\tif (edited.mutation) await Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\tlet response = f.input.questionnaire(params, f.options);\n\tlet cards = await f.cards(3);\n\texpect(cards.map(card => card.definition.questions[0].header)).toEqual([\n\t\t\"Choice\",\n\t\t\"Multiple\",\n\t\t\"Custom\",\n\t]);\n\texpect(cards[0]!.definition.questions[0].options[0]).toMatchObject({\n\t\tlabel: \" A \",\n\t\tdescription: \" first \\n\\npreview A\",\n\t});\n\texpect(cards[0]!.definition.questions[0].options[1]).toMatchObject({\n\t\tlabel: \"B\",\n\t\tdescription: \"second\",\n\t});\n\tlet source = Plan.source(f.plan);\n\texpect(source.indexOf(\"Last paragraph.\")).toBeLessThan(source.indexOf(\" {\n\tlet { HostInputBridge, getHostQuestionnaire } = await import(\n\t\tnew URL(\"./core/extensions/host-input.js\", import.meta.resolve(\"@bastani/atomic\")).href\n\t);\n\tlet f = await fixture();\n\tlet bridge = new HostInputBridge(() => \"session\", () => undefined);\n\tbridge.bind(f.input, \"chopin\");\n\tlet questionnaire = getHostQuestionnaire(bridge.wrap({}));\n\tlet [preview, multiple, plain] = params.questions;\n\tfor (\n\t\tlet [question, value, expected] of [\n\t\t\t[preview!, [1], { kind: \"option\", answer: \"B\" }],\n\t\t\t[preview!, [0], { kind: \"option\", answer: \" A \", preview: \"preview A\" }],\n\t\t\t[preview!, \" typed\\n\", { kind: \"chat\", answer: \" typed\\n\" }],\n\t\t\t[multiple!, [1, 0], { kind: \"multi\", answer: null, selected: [\"C\", \"D\"] }],\n\t\t\t[multiple!, \"several\\n\", { kind: \"chat\", answer: \"several\\n\" }],\n\t\t\t[plain!, [1], { kind: \"option\", answer: \"F\" }],\n\t\t\t[plain!, \" own \", { kind: \"custom\", answer: \" own \" }],\n\t\t] as const\n\t) {\n\t\tlet response = questionnaire({ questions: [question] }, new AbortController().signal);\n\t\tlet [card] = await f.cards(1);\n\t\tawait f.answer(card!.id, typeof value === \"string\" ? value : [...value]);\n\t\texpect(await response).toEqual({\n\t\t\tcancelled: false,\n\t\t\tanswers: [{ questionIndex: 0, question: question.question, ...expected }],\n\t\t});\n\t}\n});\n\ntest(\"maps confirm/select dialogs without treating custom text as approval or a selection\", async () => {\n\tlet f = await fixture();\n\tfor (let [value, approved] of [[[0], true], [[1], false], [\"Yes\", false]] as const) {\n\t\tlet result = f.input.confirm(\"Proceed?\", \"This changes files.\", f.options);\n\t\tlet [card] = await f.cards(1);\n\t\texpect(card!.definition.questions[0].question).toBe(\"Proceed?\\n\\nThis changes files.\");\n\t\tawait f.answer(card!.id, typeof value === \"string\" ? value : [...value]);\n\t\texpect(await result).toBe(approved);\n\t}\n\tlet selected = f.input.select(\"Pick\", [\" second \", \"first\", \"first\"], f.options);\n\tlet [card] = await f.cards(1);\n\texpect(card!.definition.questions[0].options.map(option => option.label)).toEqual([\n\t\t\" second \",\n\t\t\"first\",\n\t\t\"first\",\n\t]);\n\tawait f.answer(card!.id, [0]);\n\texpect(await selected).toBe(\" second \");\n\tlet custom = f.input.select(\"Pick\", [\"yes\", \"no\"], f.options);\n\tawait f.answer((await f.cards(1))[0]!.id, \"yes\");\n\texpect(await custom).toBeUndefined();\n});\n\ntest(\"input and editor are cards with no options, answered by an option a member adds\", async () => {\n\tlet f = await fixture();\n\tfor (let method of [\"input\", \"editor\"] as const) {\n\t\tlet response = f.input[method](\"Title\", \" initial or hint\\n\", f.options);\n\t\tlet [card] = await f.cards(1);\n\t\tlet question = card!.definition.questions[0];\n\t\texpect(question.options).toEqual([]);\n\t\texpect(question.question).toBe(\"Title\\n\\n initial or hint\\n\");\n\t\tlet source = Plan.source(f.plan);\n\t\tlet roundTrip = await Room.create(source);\n\t\texpect(Room.project(roundTrip)).toContain(\n\t\t\t`header=\"${method === \"input\" ? \"Input\" : \"Editor\"}\"`,\n\t\t);\n\t\tlet projected = Room.project(roundTrip);\n\t\tlet own = projected.slice(projected.indexOf(`\"))).not.toContain(\" {\n\tlet f = await fixture();\n\tlet response = f.input.questionnaire(params, f.options);\n\tlet cards = await f.cards(3);\n\tawait f.answer(cards[0]!.id, [await f.addOption(cards[0]!.id, \"Neither\")]);\n\tawait f.answer(cards[1]!.id, [0, await f.addOption(cards[1]!.id, \"G\")]);\n\tawait f.answer(cards[2]!.id, [await f.addOption(cards[2]!.id, \"Something else\")]);\n\texpect((await response).answers).toEqual([\n\t\t{ questionIndex: 0, question: \" Which? \", kind: \"chat\", answer: \"Neither\" },\n\t\t{ questionIndex: 1, question: \"Select several\", kind: \"chat\", answer: \"C, G\" },\n\t\t{ questionIndex: 2, question: \"Or free text?\", kind: \"custom\", answer: \"Something else\" },\n\t]);\n});\n\ntest(\"member cancellation retains answered questions and marks the batch cancelled\", async () => {\n\tlet f = await fixture();\n\tlet response = f.input.questionnaire(params, f.options);\n\tlet cards = await f.cards(3);\n\tawait f.answer(cards[0]!.id, [1]);\n\tfor (let card of cards.slice(1)) {\n\t\tawait Questions.cancel(f.plan, f.server, f.room.id, f.ws, {\n\t\t\tkind: \"question:cancel\",\n\t\t\tts: 0,\n\t\t\trid: \"cancel\",\n\t\t\tid: card.id,\n\t\t});\n\t}\n\texpect(await response).toEqual({\n\t\tcancelled: true,\n\t\tanswers: [\n\t\t\t{ questionIndex: 0, question: \" Which? \", kind: \"option\", answer: \"B\" },\n\t\t],\n\t});\n});\n\ntest(\"abort withdraws only its request's open cards, persists cancellation, and ignores late submission\", async () => {\n\tlet f = await fixture();\n\tlet response = f.input.questionnaire(params, f.options);\n\tlet cards = await f.cards(3);\n\tawait f.answer(cards[0]!.id, [1]);\n\tf.controller.abort();\n\texpect(await response).toEqual({ answers: [], cancelled: true });\n\texpect(Store.outstanding(f.plan.questions)).toHaveLength(0);\n\texpect(f.plan.records.get(cards[0]!.id)?.status).toBe(\"answered\");\n\tfor (let card of cards.slice(1)) {\n\t\texpect(f.plan.records.get(card.id)).toMatchObject({ status: \"cancelled\", resolver: \"chopin\" });\n\t\texpect(Plan.source(f.plan)).not.toContain(card.id);\n\t\texpect(f.frames).toContainEqual(\n\t\t\texpect.objectContaining({\n\t\t\t\tkind: \"question:resolved\",\n\t\t\t\tid: card.id,\n\t\t\t\tstatus: \"cancelled\",\n\t\t\t\tresolver: \"chopin\",\n\t\t\t}),\n\t\t);\n\t\tawait Questions.submit(f.plan, f.server, f.room.id, f.ws, {\n\t\t\tkind: \"question:submit\",\n\t\t\tts: 0,\n\t\t\trid: \"late\",\n\t\t\tid: card.id,\n\t\t\trevision: 0,\n\t\t});\n\t\texpect(f.plan.records.get(card.id)?.status).toBe(\"cancelled\");\n\t}\n\tlet saved = await Plan.readStored((await f.storage.collaboration.load(f.room.id, new Date()))!);\n\texpect(saved.source).not.toContain(cards[1]!.id);\n});\n\ntest(\"expiry keeps every unanswered card in Decisions, marked expired, and answers no HostInput method\", async () => {\n\tlet f = await fixture(30);\n\tfor (\n\t\tlet [invoke, expected] of [\n\t\t\t[() => f.input.questionnaire(params, f.options), { answers: [], cancelled: true }],\n\t\t\t[() => f.input.confirm(\"Confirm\", \"Proceed?\", f.options), false],\n\t\t\t[() => f.input.select(\"Select\", [\"A\", \"B\"], f.options), undefined],\n\t\t\t[() => f.input.input(\"Input\", undefined, f.options), undefined],\n\t\t\t[() => f.input.editor(\"Editor\", undefined, f.options), undefined],\n\t\t] as Array<[() => Promise, unknown]>\n\t) {\n\t\texpect(await invoke()).toEqual(expected);\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(0);\n\t}\n\tlet records = [...f.plan.records.values()];\n\texpect(records).toHaveLength(7);\n\tfor (let record of records) {\n\t\texpect(record).toMatchObject({ status: \"expired\", resolver: \"chopin\" });\n\t\texpect(record.at).toBeNumber();\n\t\texpect(f.frames).toContainEqual(\n\t\t\texpect.objectContaining({\n\t\t\t\tkind: \"question:resolved\",\n\t\t\t\tid: record.id,\n\t\t\t\tstatus: \"expired\",\n\t\t\t\tresolver: \"chopin\",\n\t\t\t}),\n\t\t);\n\t}\n\tlet saved = await Plan.readStored((await f.storage.collaboration.load(f.room.id, new Date()))!);\n\tlet cards = await documentCards(saved.source);\n\texpect(cards.map(card => card.id)).toEqual(records.map(record => record.id));\n\tfor (let card of cards) {\n\t\texpect(card.status).toBe(\"expired\");\n\t\texpect(card.at).toBeString();\n\t\texpect(card.by).toBeUndefined();\n\t\texpect(cardStatus(card)).toBe(\"expired\");\n\t}\n\tawait Questions.submit(f.plan, f.server, f.room.id, f.ws, {\n\t\tkind: \"question:submit\",\n\t\tts: 0,\n\t\trid: \"late\",\n\t\tid: records[0]!.id,\n\t\trevision: 0,\n\t});\n\texpect(f.frames.findLast(frame => frame.rid === \"late\")).toMatchObject({\n\t\tok: false,\n\t\treason: \"resolved\",\n\t\tstatus: \"expired\",\n\t\tresolver: \"chopin\",\n\t});\n\texpect(f.plan.records.get(records[0]!.id)?.status).toBe(\"expired\");\n});\n\ntest(\"an abort still withdraws its cards rather than expiring them\", async () => {\n\tlet f = await fixture(60_000);\n\tlet response = f.input.confirm(\"Confirm\", \"Proceed?\", f.options);\n\tlet [card] = await f.cards(1);\n\tf.controller.abort();\n\texpect(await response).toBe(false);\n\texpect(f.plan.records.get(card!.id)).toMatchObject({ status: \"cancelled\", resolver: \"chopin\" });\n\texpect(Plan.source(f.plan)).not.toContain(card!.id);\n\texpect(f.frames.filter(frame => frame.kind === \"question:resolved\")).toMatchObject([\n\t\t{ kind: \"question:resolved\", id: card!.id, status: \"cancelled\", resolver: \"chopin\" },\n\t]);\n});\n\ntest(\"host input waits the shared 30-minute limit before expiring by default\", async () => {\n\tlet f = await fixture();\n\tlet delays: number[] = [];\n\tlet original = globalThis.setTimeout;\n\tglobalThis.setTimeout = ((handler: () => void, delay?: number, ...rest: unknown[]) => {\n\t\tif (delay !== undefined) delays.push(delay);\n\t\treturn original(handler, delay, ...rest);\n\t}) as typeof setTimeout;\n\ttry {\n\t\tlet response = f.input.confirm(\"Confirm\", \"Proceed?\", f.options);\n\t\tawait f.cards(1);\n\t\texpect(questionLimits.INPUT_EXPIRY_MS).toBe(30 * 60 * 1_000);\n\t\texpect(delays).toContain(questionLimits.INPUT_EXPIRY_MS);\n\t\tf.controller.abort();\n\t\texpect(await response).toBe(false);\n\t} finally {\n\t\tglobalThis.setTimeout = original;\n\t}\n});\n\ntest(\"a workflow card shows its question as asked, without run or stage ids\", async () => {\n\tlet f = await fixture();\n\tlet response = f.input.questionnaire(params, {\n\t\t...f.options,\n\t\tworkflowRunId: \"run-123\",\n\t\tworkflowStageId: \"review\",\n\t});\n\tlet cards = await f.cards(3);\n\tfor (let card of cards) {\n\t\texpect(params.questions.map(question => question.question)).toContain(\n\t\t\tcard.definition.questions[0].question,\n\t\t);\n\t\texpect(card.definition.questions[0].question).not.toContain(\"run-123\");\n\t\tawait f.answer(card.id, [0]);\n\t}\n\texpect((await response).answers.map(answer => answer.question)).toEqual(\n\t\tparams.questions.map(question => question.question),\n\t);\n});\n\ntest(\"abort before presentation creates no card and cancellation waits for durable storage\", async () => {\n\tlet f = await fixture();\n\tlet cancelled = new AbortController();\n\tcancelled.abort();\n\texpect(await f.input.confirm(\"Confirm\", \"Proceed?\", { ...f.options, signal: cancelled.signal }))\n\t\t.toBe(false);\n\texpect(f.plan.records.size).toBe(0);\n\tlet settled = false;\n\tlet result = f.input.confirm(\"Confirm\", \"Proceed?\", f.options).then(value => {\n\t\tsettled = true;\n\t\treturn value;\n\t});\n\tawait f.cards(1);\n\tlet gate = Promise.withResolvers();\n\tlet original = f.storage.collaboration.commit;\n\tf.storage.collaboration.commit = async input => {\n\t\tawait gate.promise;\n\t\treturn original(input);\n\t};\n\tf.controller.abort();\n\tawait Bun.sleep(15);\n\texpect(settled).toBe(false);\n\texpect(f.frames.filter(frame => frame.kind === \"question:resolved\")).toHaveLength(0);\n\tgate.resolve();\n\texpect(await result).toBe(false);\n\texpect(f.frames.filter(frame => frame.kind === \"question:resolved\")).toHaveLength(1);\n});\n\ntest(\"blank dialog titles and supplied empty choices remain valid verbatim inputs\", async () => {\n\tlet f = await fixture();\n\tlet result = f.input.select(\"\", [\"\", \" \"], f.options);\n\tlet [card] = await f.cards(1);\n\tawait f.answer(card!.id, [0]);\n\texpect(await result).toBe(\"\");\n\tlet source = Plan.source(f.plan);\n\tlet restored = await Room.create(source);\n\texpect(Room.project(restored)).toContain('label=\"\"');\n\texpect(Room.project(restored)).toContain('value=\"\"');\n\trestored.doc.destroy();\n});\n\n/** Re-import the canonical document, proving the dialect accepts every card it holds. */\nasync function documentCards(source: string) {\n\tlet document = await Room.create(source);\n\ttry {\n\t\treturn document.editor.getEditorState().read(() =>\n\t\t\t$nodesOfType(QuestionnaireNode).map(node => node.getQuestionnaire())\n\t\t);\n\t} finally {\n\t\tdocument.doc.destroy();\n\t}\n}\n\nasync function documentQuestionnaires(source: string) {\n\treturn (await documentCards(source)).map(card => card.questions[0]!);\n}\n\ntest(\"dialogs beyond the Planner's per-field limits become verbatim cards and answers\", async () => {\n\tlet f = await fixture();\n\tlet initial = \"Keep this line of the plan.\\n\".repeat(180);\n\tlet edited = `${initial}${\"Add this reviewed line.\\n\".repeat(60)}`;\n\tlet editor = f.input.editor(\"Edit plan\", initial, f.options);\n\tlet [card] = await f.cards(1);\n\texpect(initial.length).toBeGreaterThan(5_000);\n\texpect(card!.definition.questions[0].question).toBe(`Edit plan\\n\\n${initial}`);\n\tawait f.answer(card!.id, edited);\n\texpect(edited.length).toBeGreaterThan(6_000);\n\texpect(await editor).toBe(edited);\n\n\tlet message = \"This workflow step rewrites generated files. \".repeat(30);\n\tlet confirmed = f.input.confirm(\"Proceed?\", message, f.options);\n\t[card] = await f.cards(1);\n\tawait f.answer(card!.id, [0]);\n\texpect(await confirmed).toBe(true);\n\n\tlet choices = Array.from({ length: 25 }, (_, index) => `Choice ${index}`);\n\tchoices[24] = `The long choice ${\"x\".repeat(250)}`;\n\tlet selected = f.input.select(\"Pick one\", choices, f.options);\n\t[card] = await f.cards(1);\n\texpect(card!.definition.questions[0].options.map(option => option.label)).toEqual(choices);\n\tawait f.answer(card!.id, [24]);\n\texpect(await selected).toBe(choices[24]);\n\n\tlet rollout = \"Explain the rollout, its owners, and its checks. \".repeat(40);\n\tlet asked = f.input.questionnaire({\n\t\tquestions: [{\n\t\t\theader: \"Rollout\",\n\t\t\tquestion: \"Which rollout?\",\n\t\t\toptions: [{ label: \"Staged\", description: rollout }, { label: \"All\", description: \"\" }],\n\t\t}],\n\t}, f.options);\n\t[card] = await f.cards(1);\n\tawait f.answer(card!.id, [0]);\n\texpect((await asked).answers[0]).toMatchObject({ kind: \"option\", answer: \"Staged\" });\n\n\texpect(await documentQuestionnaires(Plan.source(f.plan))).toMatchObject([\n\t\t{ header: \"Editor\", prompt: `Edit plan\\n\\n${initial}`, options: [], answer: edited },\n\t\t{ header: \"Confirm\", prompt: `Proceed?\\n\\n${message}`, answer: \"Yes\" },\n\t\t{\n\t\t\theader: \"Select\",\n\t\t\tprompt: \"Pick one\",\n\t\t\toptions: choices.map(label => ({ label })),\n\t\t\tanswer: choices[24],\n\t\t},\n\t\t{\n\t\t\theader: \"Rollout\",\n\t\t\toptions: [{ label: \"Staged\", description: rollout }, { label: \"All\" }],\n\t\t\tanswer: \"Staged\",\n\t\t},\n\t]);\n});\n\ntest(\"a workflow question at the length limit is stored verbatim\", async () => {\n\tlet f = await fixture();\n\tlet question = \"Should the review stage accept this change? \".repeat(23).slice(0, 990);\n\tlet long: QuestionParams = {\n\t\tquestions: [{\n\t\t\theader: \"Review\",\n\t\t\tquestion,\n\t\t\toptions: [{ label: \"Ship\", description: \"\" }, { label: \"Hold\", description: \"\" }],\n\t\t}],\n\t};\n\tlet response = f.input.questionnaire(long, {\n\t\t...f.options,\n\t\tworkflowRunId: \"run-123\",\n\t\tworkflowStageId: \"review\",\n\t});\n\tlet [card] = await f.cards(1);\n\texpect(card!.definition.questions[0].question).toBe(question);\n\texpect(await documentQuestionnaires(Plan.source(f.plan))).toMatchObject([{ prompt: question }]);\n\tawait f.answer(card!.id, [0]);\n\texpect(await response).toEqual({\n\t\tcancelled: false,\n\t\tanswers: [{ questionIndex: 0, question, kind: \"option\", answer: \"Ship\" }],\n\t});\n});\n\ntest(\"a dialog that cannot fit in the document fails loudly without leaving a card\", async () => {\n\tlet f = await fixture();\n\tlet edited = Edit.apply(f.plan, f.plan.revision, [{\n\t\top: \"replace_root\",\n\t\tsource: `${\"Existing prose in the document. \".repeat(3_000)}\\n`,\n\t}]);\n\tif (!edited.ok || !edited.mutation) throw new Error(\"fixture edit failed\");\n\tawait Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\tlet before = Plan.source(f.plan);\n\tawait expect(\n\t\tf.input.editor(\"Too large\", \"x\".repeat(limits.MAX_SOURCE_BYTES - 90_000), f.options),\n\t).rejects.toThrow(`${limits.MAX_SOURCE_BYTES / 1024} KiB`);\n\texpect(Store.outstanding(f.plan.questions)).toHaveLength(0);\n\texpect(f.plan.records.size).toBe(0);\n\texpect(Plan.source(f.plan)).toBe(before);\n});\n\ntest(\"an answer that would make the document too large leaves it unchanged and the question open\", async () => {\n\tlet f = await fixture();\n\tlet edited = Edit.apply(f.plan, f.plan.revision, [{\n\t\top: \"replace_root\",\n\t\tsource: \"# Plan\\n\\n\" + (\"Prose paragraph. \".repeat(60) + \"\\n\\n\").repeat(100),\n\t}]);\n\tif (!edited.ok) throw new Error(\"fixture edit failed\");\n\tif (edited.mutation) await Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\tlet response = f.input.questionnaire({\n\t\tquestions: [{ header: \"Input\", question: \"Write the brief\", options: [] }],\n\t}, f.options);\n\tlet [card] = await f.cards(1);\n\tlet question = card!.definition.questions[0]!;\n\t// Each edit stays under the per-edit limit; together they outgrow the document.\n\tfor (let chunk = 0; chunk < 4; chunk++) {\n\t\tlet opened = Store.snapshot(f.plan.questions, card!.id);\n\t\tif (!opened.open) throw new Error(\"question closed\");\n\t\tlet model = QuestionModel.restore(\n\t\t\topened.model,\n\t\t\tStore.get(f.plan.questions, card!.id)!.definition,\n\t\t);\n\t\tif (chunk === 0) model.api.val([question.id, \"mode\"]).set(\"custom\");\n\t\tlet text = model.api.str([question.id, \"custom\"]);\n\t\ttext.ins(text.length(), \"x\".repeat(50_000));\n\t\tawait Questions.edit(f.plan, f.ws, {\n\t\t\tkind: \"question:edit\",\n\t\t\trid: `edit-${chunk}`,\n\t\t\tts: 0,\n\t\t\tid: card!.id,\n\t\t\tpatch: [...model.api.flush()!.toBinary()],\n\t\t});\n\t}\n\tlet before = Plan.source(f.plan);\n\tlet current = Store.snapshot(f.plan.questions, card!.id);\n\tif (!current.open) throw new Error(\"question closed\");\n\tawait Questions.submit(f.plan, f.server, f.room.id, f.ws, {\n\t\tkind: \"question:submit\",\n\t\trid: \"submit\",\n\t\tts: 0,\n\t\tid: card!.id,\n\t\trevision: current.revision,\n\t});\n\texpect(Plan.source(f.plan)).toBe(before);\n\texpect(new TextEncoder().encode(Plan.source(f.plan)).length).toBeLessThanOrEqual(\n\t\tlimits.MAX_SOURCE_BYTES,\n\t);\n\texpect(Store.outstanding(f.plan.questions).map(open => open.id)).toEqual([card!.id]);\n\tf.controller.abort();\n\texpect((await response).cancelled).toBe(true);\n});\n\ntest(\n\t\"accepting a comment cannot leave too little room for an open question to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tlet size = () => new TextEncoder().encode(Plan.source(f.plan)).length;\n\t\tlet quote = \"caches tiles for 60 seconds\";\n\t\tlet seeded = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"replace_root\",\n\t\t\tsource: `# Plan\\n\\nThe renderer ${quote}.\\n`,\n\t\t}]);\n\t\tif (!seeded.ok || !seeded.mutation) throw new Error(\"fixture edit failed\");\n\t\tawait Plan.publish(f.plan, f.server, f.room.id, seeded.mutation);\n\n\t\tlet response = f.input.questionnaire({\n\t\t\tquestions: [{\n\t\t\t\theader: \"Choice\",\n\t\t\t\tquestion: \"Which?\",\n\t\t\t\toptions: [{ label: \"A\", description: \"\" }, { label: \"B\", description: \"\" }],\n\t\t\t}],\n\t\t}, f.options);\n\t\tawait f.cards(1);\n\n\t\tlet replies: any[] = [];\n\t\tlet ana = {\n\t\t\tdata: { handle: \"ana\", client: \"client-ana\", room: f.room.id },\n\t\t\tsend: (raw: string) => replies.push(JSON.parse(raw)),\n\t\t\tpublish() {},\n\t\t} as unknown as Parameters[3];\n\t\tawait Comments.start(f.plan, f.server, f.room.id, ana, {\n\t\t\tkind: \"comment:start\",\n\t\t\trid: \"start\",\n\t\t\tts: 0,\n\t\t\tblocks: [1],\n\t\t\tquote,\n\t\t\toffset: 0,\n\t\t\tlength: quote.length,\n\t\t\ttext: \"Too long.\",\n\t\t});\n\t\tlet id = replies.findLast(frame => frame.kind === \"comment:start\")?.thread?.id as string;\n\t\texpect(id).toBeString();\n\n\t\tlet scratch = await Room.create(Plan.source(f.plan));\n\t\tlet before = size();\n\t\tRoom.insertDecision(scratch, {\n\t\t\tid,\n\t\t\tquote,\n\t\t\tby: \"ana\",\n\t\t\tat: new Date().toISOString(),\n\t\t\tnotes: [{ by: \"ana\", text: \"Too long.\" }],\n\t\t});\n\t\tlet decision = new TextEncoder().encode(Room.project(scratch)).length - before;\n\t\tscratch.doc.destroy();\n\n\t\tlet target = limits.MAX_SOURCE_BYTES - decision - 10;\n\t\tfor (let fill = 1; fill > 0;) {\n\t\t\tfill = Math.min(40_000, target - size() - 2);\n\t\t\tif (fill < 1) break;\n\t\t\tlet edited = Edit.replace(\n\t\t\t\tf.plan,\n\t\t\t\tf.plan.revision,\n\t\t\t\t`${Plan.source(f.plan)}\\n${\"x\".repeat(fill)}\\n`,\n\t\t\t);\n\t\t\tif (!edited.ok) throw new Error(`edit refused: ${edited.reason}`);\n\t\t\tif (edited.mutation) await Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\t\t}\n\n\t\tlet context = {\n\t\t\tchat: f.plan.chat,\n\t\t\tconfig: { agent: false },\n\t\t\tplan: f.plan,\n\t\t\troom: f.room.id,\n\t\t\tserver: f.server,\n\t\t\tauth: {},\n\t\t\tclaimantSessionId: \"session\",\n\t\t\trepository: { id: \"repo\", owner: \"owner\", name: \"repo\", defaultBranch: \"main\" },\n\t\t\tpersist: () => Plan.persist(f.plan),\n\t\t} as unknown as Parameters[0];\n\t\tlet complain = console.error;\n\t\tconsole.error = () => {};\n\t\ttry {\n\t\t\tawait Comments.accept(context, ana, { kind: \"comment:accept\", rid: \"accept\", ts: 0, id });\n\t\t} finally {\n\t\t\tconsole.error = complain;\n\t\t}\n\t\texpect(replies.findLast(frame => frame.kind === \"comment:accept\")).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"invalid\",\n\t\t});\n\t\texpect(f.plan.threads.get(id)?.status).toBe(\"open\");\n\n\t\tfor (let { id: open } of Store.outstanding(f.plan.questions)) {\n\t\t\tawait Questions.expire(f.plan, f.server, f.room.id, open);\n\t\t}\n\t\tawait response;\n\n\t\texpect(size()).toBeLessThanOrEqual(limits.MAX_SOURCE_BYTES);\n\t\tlet retitled = Edit.replace(\n\t\t\tf.plan,\n\t\t\tf.plan.revision,\n\t\t\tPlan.source(f.plan).replace(\"# Plan\", \"# Pla2\"),\n\t\t);\n\t\texpect(retitled.ok).toBe(true);\n\t},\n\t30_000,\n);\n\ntype Fixture = Awaited>;\n\nasync function seedDocument(f: Fixture) {\n\tlet seeded = Edit.apply(f.plan, f.plan.revision, [{\n\t\top: \"replace_root\",\n\t\tsource: \"# Plan\\n\\nStart.\\n\",\n\t}]);\n\tif (!seeded.ok || !seeded.mutation) throw new Error(\"fixture edit failed\");\n\tawait Plan.publish(f.plan, f.server, f.room.id, seeded.mutation);\n}\n\n/** Fill the document until `fits` just holds, leaving a margin smaller than one card's expiry. */\nasync function crowd(f: Fixture, fits: (scratch: Room.Document) => boolean) {\n\tlet size = () => new TextEncoder().encode(Plan.source(f.plan)).length;\n\tlet base = Plan.source(f.plan);\n\tlet low = 0;\n\tfor (let high = limits.MAX_SOURCE_BYTES; low < high;) {\n\t\tlet mid = Math.ceil((low + high) / 2);\n\t\tlet scratch = await Room.create(`${base}\\n${\"x\".repeat(mid)}\\n`).catch(() => undefined);\n\t\tlet ok = scratch ? fits(scratch) : false;\n\t\tscratch?.doc.destroy();\n\t\tif (ok) low = mid;\n\t\telse high = mid - 1;\n\t}\n\tlet target = size() + low - 10;\n\tfor (let fill = 1; fill > 0;) {\n\t\tfill = Math.min(40_000, target - size() - 2);\n\t\tif (fill < 1) break;\n\t\tlet edited = Edit.replace(\n\t\t\tf.plan,\n\t\t\tf.plan.revision,\n\t\t\t`${Plan.source(f.plan)}\\n${\"x\".repeat(fill)}\\n`,\n\t\t);\n\t\tif (!edited.ok) throw new Error(`edit refused: ${edited.reason}`);\n\t\tif (edited.mutation) await Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\t}\n}\n\nconst single = (header: string): QuestionParams => ({\n\tquestions: [{\n\t\theader,\n\t\tquestion: \"Which?\",\n\t\toptions: [{ label: \"A\", description: \"\" }, { label: \"B\", description: \"\" }],\n\t}],\n});\n\nconst bytes = (value: string) => new TextEncoder().encode(value).length;\nconst FILLER = /\\n\\nq{10,}(?=\\n)/g;\n\n/** Resize the Planner's filler paragraphs until the document is exactly `target` bytes. */\nasync function fillTo(f: Fixture, target: number) {\n\tlet size = () => bytes(Plan.source(f.plan));\n\tlet aim = target;\n\tfor (let pass = 0; pass < 3 && size() !== target; pass++) {\n\t\tlet base = Plan.source(f.plan).replace(FILLER, \"\");\n\t\tlet paragraphs: string[] = [];\n\t\tlet room = aim - bytes(base);\n\t\tfor (; room > 40_002; room -= 40_002) paragraphs.push(\"q\".repeat(40_000));\n\t\tif (room > 0) {\n\t\t\tif (room < 12) throw new Error(\"filler would be too small\");\n\t\t\tparagraphs.push(\"q\".repeat(room - 2));\n\t\t}\n\t\tlet edited = Edit.replace(\n\t\t\tf.plan,\n\t\t\tf.plan.revision,\n\t\t\tbase + paragraphs.map(text => `\\n${text}\\n`).join(\"\"),\n\t\t);\n\t\tif (!edited.ok) {\n\t\t\tthrow new Error(`fill refused: ${\"message\" in edited ? edited.message : edited.reason}`);\n\t\t}\n\t\tif (edited.mutation) await Plan.publish(f.plan, f.server, f.room.id, edited.mutation);\n\t\taim += target - size();\n\t}\n\texpect(size()).toBe(target);\n}\n\n/** What one step adds to the document, measured on a copy without the filler. */\nasync function growth(f: Fixture, step: (scratch: Room.Document) => void) {\n\tlet scratch = await Room.create(Plan.source(f.plan).replace(FILLER, \"\"));\n\tlet before = bytes(Room.project(scratch));\n\tstep(scratch);\n\tlet after = bytes(Room.project(scratch));\n\tscratch.doc.destroy();\n\treturn after - before;\n}\n\ntest(\n\t\"questions that fit when asked still fit when they expire, however the document changed since\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tlet max = limits.MAX_SOURCE_BYTES;\n\t\tlet low = 0;\n\t\tfor (let high = max; low < high;) {\n\t\t\tlet mid = Math.ceil((low + high) / 2);\n\t\t\tif (Room.fitsExpiry(\"a\".repeat(mid), 1)) low = mid;\n\t\t\telse high = mid - 1;\n\t\t}\n\t\tlet expiry = max - low;\n\t\tlet quote = \"caches tiles for 60 seconds\";\n\t\tlet seeded = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"replace_root\",\n\t\t\tsource: `# Plan\\n\\nThe renderer ${quote}.\\n`,\n\t\t}]);\n\t\tif (!seeded.ok || !seeded.mutation) throw new Error(\"fixture edit failed\");\n\t\tawait Plan.publish(f.plan, f.server, f.room.id, seeded.mutation);\n\n\t\tlet responses = [\n\t\t\tf.input.questionnaire(single(\"First\"), f.options),\n\t\t\tf.input.questionnaire(single(\"Second\"), { ...f.options, requestId: \"second\" }),\n\t\t];\n\t\tlet [first, second] = await f.cards(2);\n\n\t\tlet replies: any[] = [];\n\t\tlet ana = {\n\t\t\tdata: { handle: \"ana\", client: \"client-ana\", room: f.room.id },\n\t\t\tsend: (raw: string) => replies.push(JSON.parse(raw)),\n\t\t\tpublish() {},\n\t\t} as unknown as Parameters[3];\n\t\tawait Comments.start(f.plan, f.server, f.room.id, ana, {\n\t\t\tkind: \"comment:start\",\n\t\t\trid: \"start\",\n\t\t\tts: 0,\n\t\t\tblocks: [1],\n\t\t\tquote,\n\t\t\toffset: 0,\n\t\t\tlength: quote.length,\n\t\t\ttext: \"Too long.\",\n\t\t});\n\t\tlet thread = replies.findLast(frame => frame.kind === \"comment:start\")?.thread?.id as string;\n\t\texpect(thread).toBeString();\n\t\tlet context = {\n\t\t\tchat: f.plan.chat,\n\t\t\tconfig: { agent: false },\n\t\t\tplan: f.plan,\n\t\t\troom: f.room.id,\n\t\t\tserver: f.server,\n\t\t\tauth: {},\n\t\t\tclaimantSessionId: \"session\",\n\t\t\trepository: { id: \"repo\", owner: \"owner\", name: \"repo\", defaultBranch: \"main\" },\n\t\t\tpersist: () => Plan.persist(f.plan),\n\t\t} as unknown as Parameters[0];\n\t\tlet accept = async () => {\n\t\t\tlet complain = console.error;\n\t\t\tconsole.error = () => {};\n\t\t\ttry {\n\t\t\t\tawait Comments.accept(context, ana, {\n\t\t\t\t\tkind: \"comment:accept\",\n\t\t\t\t\trid: `accept-${replies.length}`,\n\t\t\t\t\tts: 0,\n\t\t\t\t\tid: thread,\n\t\t\t\t});\n\t\t\t} finally {\n\t\t\t\tconsole.error = complain;\n\t\t\t}\n\t\t\treturn replies.findLast(frame => frame.kind === \"comment:accept\");\n\t\t};\n\n\t\t// Planner text edits: two questions are open, so growth stops at their reserve.\n\t\tawait fillTo(f, max - 2 * expiry);\n\t\tlet source = Plan.source(f.plan);\n\t\texpect(Edit.apply(f.plan, f.plan.revision, [{ op: \"insert\", index: 0, source: \"y\" }]))\n\t\t\t.toMatchObject({ ok: false, message: expect.stringContaining(\"expire\") });\n\t\texpect(Edit.replace(f.plan, f.plan.revision, `${source}\\ny\\n`))\n\t\t\t.toMatchObject({ ok: false, message: expect.stringContaining(\"expire\") });\n\t\texpect(Plan.source(f.plan)).toBe(source);\n\n\t\t// An option that would take the document into the reserve.\n\t\tlet label = \"Written \".repeat(25);\n\t\tlet question = first!.definition.questions[0]!;\n\t\tlet option = await growth(\n\t\t\tf,\n\t\t\tscratch =>\n\t\t\t\tRoom.appendQuestionOption(scratch, first!.id, question.id, {\n\t\t\t\t\tid: ulid(),\n\t\t\t\t\tlabel,\n\t\t\t\t\tdescription: \"\",\n\t\t\t\t}),\n\t\t);\n\t\tawait fillTo(f, max - 10 - option);\n\t\tawait expect(f.addOption(first!.id, label)).rejects.toThrow(\"no room\");\n\t\tawait fillTo(f, max - option - 2 * expiry - 100);\n\t\tawait f.addOption(first!.id, label);\n\n\t\t// An answer that would do the same, then one that fits.\n\t\tlet text = \"a\".repeat(1_500);\n\t\tlet answered = await growth(\n\t\t\tf,\n\t\t\tscratch =>\n\t\t\t\tRoom.projectAnswer(scratch, first!.id, { [question.id]: text }, {\n\t\t\t\t\tby: \"reader\",\n\t\t\t\t\tat: new Date().toISOString(),\n\t\t\t\t}),\n\t\t);\n\t\tawait fillTo(f, max - 10 - answered);\n\t\tawait expect(f.answer(first!.id, text)).rejects.toThrow(\"no room\");\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(2);\n\t\tawait fillTo(f, max - answered - expiry - 100);\n\t\tawait f.answer(first!.id, \"\");\n\t\texpect(Store.outstanding(f.plan.questions).map(open => open.id)).toEqual([second!.id]);\n\n\t\t// An accepted comment becomes a Decision in the document.\n\t\tlet decision = await growth(f, scratch =>\n\t\t\tRoom.insertDecision(scratch, {\n\t\t\t\tid: thread,\n\t\t\t\tquote,\n\t\t\t\tby: \"ana\",\n\t\t\t\tat: new Date().toISOString(),\n\t\t\t\tnotes: [{ by: \"ana\", text: \"Too long.\" }],\n\t\t\t}));\n\t\tawait fillTo(f, max - 10 - decision);\n\t\texpect(await accept()).toMatchObject({ ok: false, reason: \"invalid\" });\n\t\texpect(f.plan.threads.get(thread)?.status).toBe(\"open\");\n\t\tawait fillTo(f, max - decision - expiry - 100);\n\t\texpect(await accept()).toMatchObject({ ok: true });\n\t\texpect(f.plan.threads.get(thread)?.status).not.toBe(\"open\");\n\n\t\t// A question that would take the document into the reserve, then one that fits.\n\t\tlet probe = {\n\t\t\tid: ulid(),\n\t\t\tquestions: [{\n\t\t\t\tid: ulid(),\n\t\t\t\theader: \"Third\",\n\t\t\t\tprompt: \"Which?\",\n\t\t\t\tmultiple: false,\n\t\t\t\toptions: [{ id: ulid(), label: \"A\" }, { id: ulid(), label: \"B\" }],\n\t\t\t}],\n\t\t};\n\t\tlet asked = await growth(f, scratch =>\n\t\t\tRoom.insertQuestionnaire(scratch, {\n\t\t\t\t...probe,\n\t\t\t\tstatus: \"expired\",\n\t\t\t\tat: new Date().toISOString(),\n\t\t\t}));\n\t\tawait fillTo(f, max - 10 - asked);\n\t\tlet refused = f.input.questionnaire(single(\"Third\"), { ...f.options, requestId: \"third\" });\n\t\texpect(\n\t\t\tawait Promise.race([\n\t\t\t\trefused.then(() => \"asked\", (err: Error) => err.message),\n\t\t\t\tBun.sleep(300).then(() => \"asked\"),\n\t\t\t]),\n\t\t).toContain(\"KiB limit\");\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(1);\n\t\tawait fillTo(f, max - asked - expiry - 100);\n\t\tresponses.push(\n\t\t\tf.input.questionnaire(single(\"Third\"), { ...f.options, requestId: \"third-again\" }),\n\t\t);\n\t\tawait f.cards(2);\n\n\t\t// A person's text edit: growth into the reserve is refused, shrinking or fitting is not.\n\t\tawait fillTo(f, max - 2 * expiry);\n\t\tlet sent: any[] = [];\n\t\tlet ben = {\n\t\t\tdata: { handle: \"ben\", client: \"client-ben\", room: f.room.id },\n\t\t\tsend: (raw: string) => sent.push(JSON.parse(raw)),\n\t\t\tclose() {},\n\t\t\tpublish() {},\n\t\t} as unknown as Parameters[1];\n\t\tlet type = async (client: ReturnType, change: () => void) => {\n\t\t\tlet before = Y.encodeStateVector(client.doc);\n\t\t\tclient.editor.update(change, { discrete: true });\n\t\t\tlet rid = `ben-${sent.length}`;\n\t\t\tPlan.submit(\n\t\t\t\tf.plan,\n\t\t\t\tben,\n\t\t\t\t{\n\t\t\t\t\tkind: \"plan:update\",\n\t\t\t\t\trid,\n\t\t\t\t\tts: 0,\n\t\t\t\t\tepoch: f.plan.document.epoch,\n\t\t\t\t\tid: rid,\n\t\t\t\t\tupdate: Buffer.from(Y.encodeStateAsUpdate(client.doc, before)).toString(\"base64\"),\n\t\t\t\t} as Parameters[2],\n\t\t\t);\n\t\t\tawait Bun.sleep(30);\n\t\t\tawait Plan.drain(f.plan);\n\t\t\treturn sent.findLast(frame => frame.kind === \"plan:ack\" && frame.id === rid);\n\t\t};\n\t\tlet grow = () => {\n\t\t\tlet paragraph = $createParagraphNode();\n\t\t\tparagraph.append($createTextNode(\"More text.\"));\n\t\t\t$getRoot().append(paragraph);\n\t\t};\n\t\tlet epoch = f.plan.document.epoch;\n\t\tlet before = Plan.source(f.plan);\n\t\tlet ben1 = peer();\n\t\tY.applyUpdate(ben1.doc, Room.sync(f.plan.document), \"remote\");\n\t\tawait Room.settle();\n\t\texpect(await type(ben1, grow)).toBeUndefined();\n\t\texpect(Plan.source(f.plan)).toBe(before);\n\t\texpect(f.plan.document.epoch).not.toBe(epoch);\n\n\t\tlet ben2 = peer();\n\t\tY.applyUpdate(ben2.doc, Room.sync(f.plan.document), \"remote\");\n\t\tawait Room.settle();\n\t\tlet shrunk = await type(ben2, () => {\n\t\t\t$getRoot().getChildren().find(node => node.getTextContent().startsWith(\"qq\"))?.remove();\n\t\t});\n\t\texpect(shrunk).toBeDefined();\n\t\texpect(bytes(Plan.source(f.plan))).toBeLessThan(bytes(before));\n\t\tlet fitted = await type(ben2, grow);\n\t\texpect(fitted).toBeDefined();\n\t\texpect(Plan.source(f.plan)).toContain(\"More text.\");\n\n\t\t// Both questions expire from a document with exactly their reserve left.\n\t\tawait fillTo(f, max - 2 * expiry);\n\t\tfor (let { id } of Store.outstanding(f.plan.questions)) {\n\t\t\tawait Questions.expire(f.plan, f.server, f.room.id, id);\n\t\t}\n\t\tawait Promise.allSettled(responses);\n\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(0);\n\t\texpect(bytes(Plan.source(f.plan))).toBeLessThanOrEqual(max);\n\t\tlet retitled = Edit.replace(\n\t\t\tf.plan,\n\t\t\tf.plan.revision,\n\t\t\tPlan.source(f.plan).replace(\"# Plan\", \"# Pla2\"),\n\t\t);\n\t\texpect(retitled.ok).toBe(true);\n\t},\n\t30_000,\n);\n\ntest(\n\t\"a new question is refused when the questions already open would no longer have room to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tawait seedDocument(f);\n\t\tlet first = f.input.questionnaire(single(\"First\"), f.options);\n\t\tawait f.cards(1);\n\t\tlet probe = {\n\t\t\tid: ulid(),\n\t\t\tquestions: [{\n\t\t\t\tid: ulid(),\n\t\t\t\theader: \"Second\",\n\t\t\t\tprompt: \"Which?\",\n\t\t\t\tmultiple: false,\n\t\t\t\toptions: [{ id: ulid(), label: \"A\" }, { id: ulid(), label: \"B\" }],\n\t\t\t}],\n\t\t};\n\t\tawait crowd(f, scratch => Room.fitsQuestionnaires(scratch, [probe], 0));\n\n\t\tlet second = f.input.questionnaire(single(\"Second\"), { ...f.options, requestId: \"second\" });\n\t\tlet outcome = await Promise.race([\n\t\t\tsecond.then(() => \"asked\", (err: Error) => err.message),\n\t\t\tBun.sleep(500).then(() => \"asked\"),\n\t\t]);\n\t\texpect(outcome).toContain(\"KiB limit\");\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(1);\n\t\tf.controller.abort();\n\t\tawait first;\n\t},\n\t30_000,\n);\n\ntest(\n\t\"an option is refused when the questions open would no longer have room to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tawait seedDocument(f);\n\t\tlet response = f.input.questionnaire({\n\t\t\tquestions: [{\n\t\t\t\theader: \"Choice\",\n\t\t\t\tquestion: \"Which?\",\n\t\t\t\toptions: [{ label: \"A\", description: \"\" }, { label: \"B\", description: \"\" }],\n\t\t\t}],\n\t\t}, f.options);\n\t\tlet [card] = await f.cards(1);\n\t\tlet question = card!.definition.questions[0]!;\n\t\tawait crowd(f, scratch => {\n\t\t\tRoom.appendQuestionOption(scratch, card!.id, question.id, {\n\t\t\t\tid: ulid(),\n\t\t\t\tlabel: \"Another\",\n\t\t\t\tdescription: \"\",\n\t\t\t});\n\t\t\treturn Room.fitsExpiry(Room.project(scratch), 0);\n\t\t});\n\n\t\tawait expect(f.addOption(card!.id, \"Another\")).rejects.toThrow(\"no room\");\n\t\texpect(Store.get(f.plan.questions, card!.id)!.definition.questions[0]!.options).toHaveLength(2);\n\t\tf.controller.abort();\n\t\tawait response;\n\t},\n\t30_000,\n);\n\ntest(\n\t\"an answer is refused when the questions still open would no longer have room to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tawait seedDocument(f);\n\t\tlet first = f.input.questionnaire(single(\"First\"), f.options);\n\t\tlet second = f.input.questionnaire(single(\"Second\"), { ...f.options, requestId: \"second\" });\n\t\tlet [card] = await f.cards(2);\n\t\tlet answer = \"x\".repeat(300);\n\t\tlet question = card!.definition.questions[0]!;\n\t\tawait crowd(f, scratch => {\n\t\t\tRoom.projectAnswer(scratch, card!.id, { [question.id]: answer }, {\n\t\t\t\tby: \"reader\",\n\t\t\t\tat: new Date().toISOString(),\n\t\t\t});\n\t\t\treturn Room.fitsExpiry(Room.project(scratch), 0);\n\t\t});\n\n\t\tlet before = Plan.source(f.plan);\n\t\tawait expect(f.answer(card!.id, answer)).rejects.toThrow(\"no room\");\n\t\texpect(Plan.source(f.plan)).toBe(before);\n\t\texpect(Store.outstanding(f.plan.questions)).toHaveLength(2);\n\t\tf.controller.abort();\n\t\tawait Promise.allSettled([first, second]);\n\t},\n\t30_000,\n);\n\ntest(\n\t\"a Planner edit is refused when the open question would no longer have room to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tawait seedDocument(f);\n\t\tlet response = f.input.questionnaire(single(\"First\"), f.options);\n\t\tawait f.cards(1);\n\t\tawait crowd(f, scratch => Room.fitsExpiry(Room.project(scratch), 1));\n\n\t\tlet before = Plan.source(f.plan);\n\t\tlet grown = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"insert\",\n\t\t\tindex: 0,\n\t\t\tsource: \"y\".repeat(30),\n\t\t}]);\n\t\texpect(grown).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"invalid\",\n\t\t\tmessage: expect.stringContaining(\"expire\"),\n\t\t});\n\t\texpect(Plan.source(f.plan)).toBe(before);\n\n\t\tlet retitled = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"replace\",\n\t\t\tindex: 0,\n\t\t\tsource: \"# Pla2\",\n\t\t}]);\n\t\texpect(retitled.ok).toBe(true);\n\t\tf.controller.abort();\n\t\tawait response;\n\t},\n\t30_000,\n);\n\ntest(\n\t\"a replaced plan is refused when the open question would no longer have room to expire\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tawait seedDocument(f);\n\t\tlet response = f.input.questionnaire(single(\"First\"), f.options);\n\t\tawait f.cards(1);\n\t\tawait crowd(f, scratch => Room.fitsExpiry(Room.project(scratch), 1));\n\n\t\tlet before = Plan.source(f.plan);\n\t\tlet grown = Edit.replace(f.plan, f.plan.revision, `${before}\\n${\"y\".repeat(30)}\\n`);\n\t\texpect(grown).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"invalid\",\n\t\t\tmessage: expect.stringContaining(\"expire\"),\n\t\t});\n\t\texpect(Plan.source(f.plan)).toBe(before);\n\n\t\tlet retitled = Edit.replace(f.plan, f.plan.revision, before.replace(\"# Plan\", \"# Pla2\"));\n\t\texpect(retitled.ok).toBe(true);\n\t\tf.controller.abort();\n\t\tawait response;\n\t},\n\t30_000,\n);\n\n/** A document already inside the reserve of its open questions, as one that has two open but room for one. */\nasync function overcommitted(f: Fixture) {\n\tawait seedDocument(f);\n\tlet response = f.input.questionnaire(single(\"First\"), f.options);\n\tlet [card] = await f.cards(1);\n\tawait crowd(f, scratch => Room.fitsExpiry(Room.project(scratch), 1));\n\tvoid Store.ask(f.plan.questions, ulid(), Store.get(f.plan.questions, card!.id)!.definition);\n\texpect(Room.fitsExpiry(Plan.source(f.plan), f.plan.questions.open.size)).toBe(false);\n\treturn { response };\n}\n\ntest(\n\t\"a Planner block edit that shrinks the document is accepted even inside the expiry reserve\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tlet { response } = await overcommitted(f);\n\t\tlet before = new TextEncoder().encode(Plan.source(f.plan)).length;\n\n\t\tlet grown = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"insert\",\n\t\t\tindex: 0,\n\t\t\tsource: \"y\".repeat(30),\n\t\t}]);\n\t\texpect(grown).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"invalid\",\n\t\t\tmessage: expect.stringContaining(\"expire\"),\n\t\t});\n\n\t\tlet shrunk = Edit.apply(f.plan, f.plan.revision, [{ op: \"delete\", index: 1 }]);\n\t\texpect(shrunk.ok).toBe(true);\n\t\tlet trimmed = Edit.apply(f.plan, f.plan.revision, [{\n\t\t\top: \"replace\",\n\t\t\tindex: 0,\n\t\t\tsource: \"# P\",\n\t\t}]);\n\t\texpect(trimmed.ok).toBe(true);\n\t\tif (trimmed.ok && trimmed.mutation) {\n\t\t\tawait Plan.publish(f.plan, f.server, f.room.id, trimmed.mutation);\n\t\t}\n\t\texpect(new TextEncoder().encode(Plan.source(f.plan)).length).toBeLessThan(before);\n\t\tf.controller.abort();\n\t\tawait response;\n\t},\n\t30_000,\n);\n\ntest(\n\t\"a replaced plan that shrinks the document is accepted even inside the expiry reserve\",\n\tasync () => {\n\t\tlet f = await fixture();\n\t\tlet { response } = await overcommitted(f);\n\t\tlet before = Plan.source(f.plan);\n\n\t\tlet grown = Edit.replace(f.plan, f.plan.revision, `${before}\\n${\"y\".repeat(30)}\\n`);\n\t\texpect(grown).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"invalid\",\n\t\t\tmessage: expect.stringContaining(\"expire\"),\n\t\t});\n\n\t\tlet shrunk = Edit.replace(f.plan, f.plan.revision, before.replace(\"Start.\", \"S\"));\n\t\texpect(shrunk.ok).toBe(true);\n\t\tf.controller.abort();\n\t\tawait response;\n\t},\n\t30_000,\n);\n\ntest(\"a workflow question's answer is returned only after its paused run is released\", async () => {\n\tlet release!: () => void;\n\tlet gate = new Promise(resolve => {\n\t\trelease = resolve;\n\t});\n\tlet held: string[] = [];\n\tlet f = await hostInputRoom(undefined, async runId => {\n\t\theld.push(runId);\n\t\tawait gate;\n\t});\n\tcleanups.push(f.close);\n\tlet settled = false;\n\tlet response = f.input.questionnaire(\n\t\t{ questions: [params.questions[0]!] },\n\t\t{ ...f.options, workflowRunId: \"run-1\", workflowStageId: \"stage-1\" },\n\t).then(result => {\n\t\tsettled = true;\n\t\treturn result;\n\t});\n\tlet [card] = await f.cards(1);\n\tawait f.answer(card!.id, [0]);\n\tawait Bun.sleep(20);\n\texpect(held).toEqual([\"run-1\"]);\n\texpect(settled).toBe(false);\n\trelease();\n\texpect((await response).answers).toMatchObject([{ kind: \"option\", answer: \" A \" }]);\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",1794437208638,"sidebar","expanded"]