[{"_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/questions/planner-lifecycle-durability.test.ts","oid","c1436c96de9fa9c859e88cdf07047e54402e6221","size",8902,"commit","2182c95de44a8f63fd86af1c5874ae0ca298f807","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { expect, spyOn, test } from \"bun:test\";\nimport * as Questions from \"./service\";\nimport * as Store from \"./store\";\nimport * as Plan from \"../plan/service\";\nimport * as Room from \"../plan/room\";\nimport { openPlan } from \"../testing/plan\";\nimport { createProcessor } from \"../conversation-plan/service\";\nimport { mirrorCard } from \"../conversation-plan/card-mirror-runner\";\nimport { replay } from \"../conversation-plan/domain\";\nimport { MAX_EVENTS } from \"../conversation-plan/validation\";\nimport type { ConversationPlan } from \"@chopin/protocol\";\nimport type { Socket } from \"../wire\";\n\nfunction definition() {\n\treturn Questions.identify({\n\t\tquestions: [{\n\t\t\theader: \"Hosting\",\n\t\t\tquestion: \"Where should we host?\",\n\t\t\tmultiple: false,\n\t\t\toptions: [{ label: \"Managed service\", description: \"\" }],\n\t\t}],\n\t});\n}\n\nasync function ask(context: Awaited>) {\n\tlet created = Promise.withResolvers();\n\tlet waiting = Questions.ask(\n\t\tcontext.plan,\n\t\tcontext.server,\n\t\tcontext.plan.id,\n\t\tdefinition(),\n\t\tundefined,\n\t\tcreated.resolve,\n\t);\n\tawait Promise.race([created.promise, waiting]);\n\tlet record = [...context.plan.records.values()].at(-1)!;\n\treturn { record, waiting };\n}\n\nfunction member(context: Awaited>) {\n\tlet frames: Array> = [];\n\tlet ws = {\n\t\tdata: { handle: \"ana\", client: \"client-ana\", room: context.plan.id },\n\t\tsend(raw: string) {\n\t\t\tframes.push(JSON.parse(raw));\n\t\t},\n\t\tpublish() {},\n\t} as unknown as Socket;\n\treturn { ws, frames };\n}\n\ntest(\"ordinary Planner asks remain available after conversation thread capacity\", async () => {\n\tlet context = await openPlan();\n\ttry {\n\t\tfor (let index = 0; index < 21; index++) await ask(context);\n\t\texpect(context.plan.records.size).toBe(21);\n\t\texpect(context.plan.questions.open.size).toBe(21);\n\t\texpect(context.plan.conversationPlan.threads).toHaveLength(20);\n\t\tlet last = [...context.plan.records.values()].at(-1)!;\n\t\texpect(last.threadId).toBeUndefined();\n\t\texpect(Room.questionnaireProjections(context.plan.document).find(card => card.id === last.id))\n\t\t\t.not.toHaveProperty(\"thread\");\n\t\tawait Plan.close(context.plan);\n\t\tcontext.plan = await Plan.open(context.plan.id, context.backend, context.server);\n\t\texpect(context.plan.records.size).toBe(21);\n\t\texpect(context.plan.questions.open.size).toBe(21);\n\t} finally {\n\t\tawait Plan.close(context.plan);\n\t}\n});\n\ntest(\"failed Planner ask commits leave no live or durable card or thread\", async () => {\n\tlet context = await openPlan();\n\tlet commit = spyOn(context.storage.collaboration, \"commit\")\n\t\t.mockRejectedValueOnce(new Error(\"storage unavailable\"));\n\ttry {\n\t\tawait expect(Questions.ask(context.plan, context.server, context.plan.id, definition()))\n\t\t\t.rejects.toThrow(\"storage unavailable\");\n\t\texpect(context.plan.records.size).toBe(0);\n\t\texpect(context.plan.questions.open.size).toBe(0);\n\t\texpect(context.plan.conversationPlan.threads).toEqual([]);\n\t\texpect(Room.project(context.plan.document)).toBe(\"\");\n\t\texpect(context.broadcasts).toEqual([]);\n\t\tlet saved = await context.storage.collaboration.load(context.plan.id, new Date());\n\t\texpect(saved?.sidecar ?? saved?.snapshot?.sidecar)\n\t\t\t.toMatchObject({ questions: [], openQuestions: [] });\n\t} finally {\n\t\tcommit.mockRestore();\n\t\tawait Plan.close(context.plan);\n\t}\n});\n\ntest(\"ordinary Planner asks remain available after conversation event capacity\", async () => {\n\tlet context = await openPlan();\n\ttry {\n\t\tawait ask(context);\n\t\tlet thread = context.plan.conversationPlan.threads[0]!;\n\t\tlet remaining = MAX_EVENTS - context.plan.conversationPlan.events.length;\n\t\tlet events: ConversationPlan.Event[] = Array.from({ length: remaining }, (_, index) => ({\n\t\t\tid: `discard-history:${index}`,\n\t\t\ttype: \"thread.discarded\",\n\t\t\tthreadId: thread.id,\n\t\t\tobservedThreadVersion: thread.version + index,\n\t\t\torigin: \"human\",\n\t\t\tactor: { kind: \"member\", handle: \"ana\" },\n\t\t\tat: index,\n\t\t}));\n\t\tcontext.plan.conversationPlan = replay([...context.plan.conversationPlan.events, ...events]);\n\t\tlet state = context.plan.conversationPlan;\n\t\tlet { record } = await ask(context);\n\t\texpect(record.threadId).toBeUndefined();\n\t\texpect(context.plan.conversationPlan).toBe(state);\n\t\texpect(context.plan.conversationPlan.events).toHaveLength(MAX_EVENTS);\n\t\texpect(context.plan.records.size).toBe(2);\n\t\texpect(context.plan.questions.open.size).toBe(2);\n\t} finally {\n\t\tawait Plan.close(context.plan);\n\t}\n}, 20_000);\n\ntest(\"cancellation keeps a linked draft private until commit and mirrors discard after restart\", async () => {\n\tlet context = await openPlan();\n\tlet { record, waiting } = await ask(context);\n\tlet { ws, frames } = member(context);\n\tlet entered = Promise.withResolvers();\n\tlet release = Promise.withResolvers();\n\tlet commit = context.storage.collaboration.commit.bind(context.storage.collaboration);\n\tlet held = spyOn(context.storage.collaboration, \"commit\").mockImplementation(async input => {\n\t\tentered.resolve();\n\t\tawait release.promise;\n\t\treturn commit(input);\n\t});\n\tlet before = Room.project(context.plan.document);\n\tlet events: Questions.CardEvent[] = [];\n\tlet off = Questions.listen(context.plan, event => events.push(event));\n\tlet cancelled = Questions.cancel(context.plan, context.server, context.plan.id, ws, {\n\t\tkind: \"question:cancel\",\n\t\tts: 0,\n\t\trid: \"cancel\",\n\t\tid: record.id,\n\t});\n\ttry {\n\t\tawait entered.promise;\n\t\texpect(context.plan.records.get(record.id)?.status).toBe(\"open\");\n\t\texpect(Store.snapshot(context.plan.questions, record.id).open).toBe(true);\n\t\texpect(Room.project(context.plan.document)).toBe(before);\n\t\texpect(context.plan.pendingCardActions).toEqual([]);\n\t\texpect(events).toEqual([]);\n\t\texpect(frames).toEqual([]);\n\t\trelease.resolve();\n\t\tawait cancelled;\n\t\texpect(await waiting).toEqual([{ status: \"cancelled\", resolver: \"ana\" }]);\n\t\texpect(context.plan.pendingCardActions).toMatchObject([{\n\t\t\tkind: \"discarded\",\n\t\t\tcardId: record.id,\n\t\t\tthreadId: record.threadId,\n\t\t\tactor: \"ana\",\n\t\t}]);\n\t\texpect(events).toMatchObject([{ kind: \"discarded\", id: record.id }]);\n\t\theld.mockRestore();\n\t\tawait Plan.close(context.plan);\n\t\tcontext.plan = await Plan.open(context.plan.id, context.backend, context.server);\n\t\tlet processor = createProcessor({\n\t\t\tplan: context.plan,\n\t\t\tactive: () => true,\n\t\t\texclusive: action => Plan.exclusive(context.plan, action),\n\t\t\tpersist: () => Plan.persistExclusive(context.plan),\n\t\t\tpublish() {},\n\t\t});\n\t\ttry {\n\t\t\tawait mirrorCard(context.plan, processor);\n\t\t\tawait mirrorCard(context.plan, processor);\n\t\t\texpect(context.plan.pendingCardActions).toEqual([]);\n\t\t\texpect(\n\t\t\t\tcontext.plan.conversationPlan.threads.find(thread => thread.id === record.threadId)\n\t\t\t\t\t?.status,\n\t\t\t).toBe(\"discarded\");\n\t\t\texpect(\n\t\t\t\tcontext.plan.conversationPlan.events.filter(event => event.type === \"thread.discarded\"),\n\t\t\t)\n\t\t\t\t.toHaveLength(1);\n\t\t} finally {\n\t\t\tprocessor.stop();\n\t\t\tawait processor.idle();\n\t\t}\n\t} finally {\n\t\trelease.resolve();\n\t\tawait cancelled;\n\t\theld.mockRestore();\n\t\toff();\n\t\tawait Plan.close(context.plan);\n\t}\n});\n\ntest(\"failed cancellation releases its claim and preserves the accepted draft\", async () => {\n\tlet context = await openPlan();\n\tlet { record, waiting } = await ask(context);\n\tlet { ws, frames } = member(context);\n\tlet entry = Store.get(context.plan.questions, record.id)!;\n\tlet model = entry.model.fork();\n\tlet question = entry.definition.questions[0]!;\n\tmodel.api.val([question.id, \"choice\"]).set(question.options[0]!.id);\n\tlet patch = model.api.flush();\n\tif (!patch) throw new Error(\"selection produced no patch\");\n\tawait Questions.edit(context.plan, ws, {\n\t\tkind: \"question:edit\",\n\t\tts: 0,\n\t\trid: \"select\",\n\t\tid: record.id,\n\t\tpatch: [...patch.toBinary()],\n\t});\n\tlet draft = Store.snapshot(context.plan.questions, record.id);\n\tframes.length = 0;\n\tlet source = Room.project(context.plan.document);\n\tlet commit = spyOn(context.storage.collaboration, \"commit\")\n\t\t.mockRejectedValueOnce(new Error(\"storage unavailable\"));\n\ttry {\n\t\tawait Questions.cancel(context.plan, context.server, context.plan.id, ws, {\n\t\t\tkind: \"question:cancel\",\n\t\t\tts: 0,\n\t\t\trid: \"failed-cancel\",\n\t\t\tid: record.id,\n\t\t});\n\t\texpect(context.plan.records.get(record.id)?.status).toBe(\"open\");\n\t\texpect(Store.get(context.plan.questions, record.id)?.claim).toBeUndefined();\n\t\texpect(Store.snapshot(context.plan.questions, record.id)).toEqual(draft);\n\t\texpect(Room.project(context.plan.document)).toBe(source);\n\t\texpect(context.plan.pendingCardActions).toEqual([]);\n\t\texpect(frames).toMatchObject([{ kind: \"session:error\", rid: \"failed-cancel\" }]);\n\t\tawait Questions.cancel(context.plan, context.server, context.plan.id, ws, {\n\t\t\tkind: \"question:cancel\",\n\t\t\tts: 0,\n\t\t\trid: \"retry-cancel\",\n\t\t\tid: record.id,\n\t\t});\n\t\texpect(await waiting).toEqual([{ status: \"cancelled\", resolver: \"ana\" }]);\n\t\texpect(context.plan.pendingCardActions).toHaveLength(1);\n\t} finally {\n\t\tcommit.mockRestore();\n\t\tawait Plan.close(context.plan);\n\t}\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",1794436599500,"sidebar","expanded"]