[{"_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","5119f5aa57b916717e57e5bb62ade10cda460f7d","path","packages/editor/src/research-draft.test.ts","oid","9c862059da45788d5f9a160e5942b4e9308c9595","size",9039,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { describe, expect, it } from \"bun:test\";\nimport * as Y from \"yjs\";\n\nimport type { Research } from \"@chopin/protocol\";\n\nconst REQUEST: Research.RequestView = {\n\tid: \"07aeae6d-073d-4560-a9f4-bb8e4d954a46\",\n\tchannelId: \"document-one\",\n\tquestion: \" Keep this brief exactly. \",\n\tstate: \"running\",\n\tstage: \"queued\",\n\tsources: [],\n\tcreatedAt: \"2026-08-24T09:00:00.000Z\",\n\tupdatedAt: \"2026-08-24T09:00:00.000Z\",\n};\n\ntype DraftStore = {\n\tattachPlacement(place: (position: Y.RelativePosition, id: string) => boolean): () => void;\n\tcanOpen(): boolean;\n\tcancelCreated(\n\t\tcancel: (id: string) => Promise,\n\t\twritable?: boolean,\n\t): Promise;\n\tchange(question: string): void;\n\tdismiss(): boolean;\n\tget(): {\n\t\tcreated?: Research.RequestView;\n\t\tcancelling?: boolean;\n\t\terror?: string;\n\t\tposition?: Y.RelativePosition;\n\t\tquestion: string;\n\t\tsubmitted?: { question: string; requestId: string };\n\t\tsubmitting?: boolean;\n\t} | undefined;\n\topen(\n\t\tanchor: {\n\t\t\ttop: number;\n\t\t\tright: number;\n\t\t\tbottom: number;\n\t\t\tleft: number;\n\t\t\twidth: number;\n\t\t\theight: number;\n\t\t},\n\t\tposition?: Y.RelativePosition,\n\t): boolean;\n\tplace(position: Y.RelativePosition, writable?: boolean): boolean;\n\trestoreRejected(now?: number): boolean;\n\tstart(\n\t\tcreate: (question: string, requestId: string) => Promise,\n\t): Promise;\n};\n\nasync function draftStore(): Promise<{ new(): DraftStore } | undefined> {\n\tlet module = await import(\"./research-draft\").catch(() => ({}));\n\tlet Store = (module as { ResearchDraftStore?: { new(): DraftStore } }).ResearchDraftStore;\n\texpect(typeof Store).toBe(\"function\");\n\treturn Store;\n}\n\nfunction position(name: string): Y.RelativePosition {\n\tlet doc = new Y.Doc();\n\treturn Y.createRelativePositionFromTypeIndex(doc.getText(name), 0);\n}\n\nconst ANCHOR = { top: 1, right: 2, bottom: 3, left: 4, width: 5, height: 6 };\n\ndescribe(\"research draft lifecycle\", () => {\n\tit(\"refuses a second research draft during submission and created recovery\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tlet original = position(\"original\");\n\t\tlet replacement = position(\"replacement\");\n\t\texpect(store.open(ANCHOR, original)).toBe(true);\n\t\tstore.change(REQUEST.question);\n\t\tlet resolve!: (request: Research.RequestView) => void;\n\t\tlet create = new Promise(done => resolve = done);\n\t\tlet submitted: [string, string] | undefined;\n\t\tlet running = store.start((question, requestId) => {\n\t\t\tsubmitted = [question, requestId];\n\t\t\treturn create;\n\t\t});\n\t\tlet requestId = store.get()?.submitted?.requestId;\n\n\t\texpect(store.canOpen()).toBe(false);\n\t\texpect(store.open({ ...ANCHOR, top: 20 }, replacement)).toBe(false);\n\t\texpect(store.get()?.question).toBe(REQUEST.question);\n\t\texpect(store.get()?.submitted?.requestId).toBe(requestId);\n\t\texpect(store.get()?.position).toBe(original);\n\n\t\tresolve(REQUEST);\n\t\tawait running;\n\t\texpect(store.get()?.created).toEqual(REQUEST);\n\t\texpect(store.open({ ...ANCHOR, top: 30 }, replacement)).toBe(false);\n\t\texpect(store.get()?.created).toEqual(REQUEST);\n\t\texpect(store.get()?.submitted?.requestId).toBe(requestId);\n\t\texpect(store.get()?.position).toBe(original);\n\t\texpect(submitted).toEqual([REQUEST.question, requestId!]);\n\t});\n\n\tit(\"keeps an in-flight create through disconnect or read-only placement loss\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tlet original = position(\"original\");\n\t\tstore.open(ANCHOR, original);\n\t\tstore.change(REQUEST.question);\n\t\tlet resolve!: (request: Research.RequestView) => void;\n\t\tlet create = new Promise(done => resolve = done);\n\t\tlet detachedCalls = 0;\n\t\tlet detach = store.attachPlacement(() => {\n\t\t\tdetachedCalls++;\n\t\t\treturn true;\n\t\t});\n\t\tlet running = store.start(() => create);\n\t\texpect(store.get()?.submitting).toBe(true);\n\t\texpect(store.dismiss()).toBe(false);\n\t\tdetach();\n\t\tresolve(REQUEST);\n\t\tawait running;\n\n\t\texpect(detachedCalls).toBe(0);\n\t\texpect(store.get()?.created).toEqual(REQUEST);\n\t\tlet reconnected: [Y.RelativePosition, string] | undefined;\n\t\tstore.attachPlacement((saved, id) => {\n\t\t\treconnected = [saved, id];\n\t\t\treturn true;\n\t\t});\n\t\texpect(reconnected).toEqual([original, REQUEST.id]);\n\t\texpect(store.get()).toBeUndefined();\n\t});\n\n\tit(\"keeps durable recovery through a keyed editor remount during the POST\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tlet oldPosition = position(\"old-epoch\");\n\t\tlet newPosition = position(\"new-epoch\");\n\t\tstore.open(ANCHOR, oldPosition);\n\t\tstore.change(REQUEST.question);\n\t\tlet resolve!: (request: Research.RequestView) => void;\n\t\tlet create = new Promise(done => resolve = done);\n\t\tlet oldCalls = 0;\n\t\tlet detach = store.attachPlacement(() => {\n\t\t\toldCalls++;\n\t\t\treturn true;\n\t\t});\n\t\tlet running = store.start(() => create);\n\t\tdetach();\n\t\tlet newCalls: Y.RelativePosition[] = [];\n\t\tstore.attachPlacement(saved => {\n\t\t\tnewCalls.push(saved);\n\t\t\treturn saved === newPosition;\n\t\t});\n\t\tresolve(REQUEST);\n\t\tawait running;\n\n\t\texpect(oldCalls).toBe(0);\n\t\texpect(newCalls).toEqual([oldPosition]);\n\t\texpect(store.get()?.created?.id).toBe(REQUEST.id);\n\t\texpect(store.place(newPosition)).toBe(true);\n\t\texpect(store.get()).toBeUndefined();\n\t});\n\n\tit(\"retains one exact idempotency identity after a failed create and remount\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tstore.open(ANCHOR, position(\"brief\"));\n\t\tstore.change(REQUEST.question);\n\t\tlet attempts: Array<[string, string]> = [];\n\t\tawait store.start(async (question, requestId) => {\n\t\t\tattempts.push([question, requestId]);\n\t\t\tthrow new Error(\"offline\");\n\t\t});\n\t\tlet saved = store.get()?.submitted;\n\t\texpect(saved?.question).toBe(REQUEST.question);\n\n\t\tawait store.start(async (question, requestId) => {\n\t\t\tattempts.push([question, requestId]);\n\t\t\treturn REQUEST;\n\t\t});\n\t\texpect(attempts).toEqual([\n\t\t\t[REQUEST.question, saved!.requestId],\n\t\t\t[REQUEST.question, saved!.requestId],\n\t\t]);\n\t});\n\n\tit(\"cannot dismiss created recovery and clears it only after durable cancellation\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tstore.open(ANCHOR, position(\"cancel\"));\n\t\tstore.change(REQUEST.question);\n\t\tawait store.start(async () => REQUEST);\n\t\texpect(store.dismiss()).toBe(false);\n\t\texpect(store.get()?.created?.id).toBe(REQUEST.id);\n\n\t\tlet cancelled: string | undefined;\n\t\tlet finish!: (request: Research.RequestView) => void;\n\t\tlet waiting = new Promise(done => finish = done);\n\t\tlet cancellation = store.cancelCreated(async id => {\n\t\t\tcancelled = id;\n\t\t\treturn waiting;\n\t\t});\n\t\texpect(store.get()?.cancelling).toBe(true);\n\t\texpect(store.dismiss()).toBe(false);\n\t\tlet placements = 0;\n\t\tstore.attachPlacement(() => {\n\t\t\tplacements++;\n\t\t\treturn true;\n\t\t});\n\t\texpect(placements).toBe(0);\n\t\tfinish({ ...REQUEST, state: \"cancelled\", stage: \"cancelled\" });\n\t\texpect(await cancellation).toBe(true);\n\t\texpect(cancelled).toBe(REQUEST.id);\n\t\texpect(store.get()).toBeUndefined();\n\t});\n\n\tit(\"preserves created recovery without mutation while read-only\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tlet original = position(\"read-only-original\");\n\t\tstore.open(ANCHOR, original);\n\t\tstore.change(REQUEST.question);\n\t\tawait store.start(async () => REQUEST);\n\t\tlet snapshot = store.get();\n\t\tlet cancellations = 0;\n\n\t\texpect(\n\t\t\tawait store.cancelCreated(async () => {\n\t\t\t\tcancellations++;\n\t\t\t\treturn { ...REQUEST, state: \"cancelled\", stage: \"cancelled\" };\n\t\t\t}, false),\n\t\t).toBe(false);\n\t\texpect(store.place(position(\"read-only-new\"), false)).toBe(false);\n\t\texpect(cancellations).toBe(0);\n\t\texpect(store.get()).toBe(snapshot);\n\t\texpect(store.get()?.created).toEqual(REQUEST);\n\t\texpect(store.get()?.position).toBe(original);\n\t});\n\n\tit(\"reopens a placed draft when the document is rebuilt soon after\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tstore.attachPlacement(() => true);\n\t\tstore.open(ANCHOR, position(\"rejected\"));\n\t\tstore.change(REQUEST.question);\n\t\tawait store.start(async () => REQUEST);\n\t\texpect(store.get()).toBeUndefined();\n\n\t\texpect(store.restoreRejected()).toBe(true);\n\t\tlet draft = store.get();\n\t\texpect(draft?.created).toEqual(REQUEST);\n\t\texpect(draft?.position).toBeUndefined();\n\t\texpect(draft?.error).toContain(\"place it again\");\n\t\texpect(store.dismiss()).toBe(false);\n\t\texpect(store.restoreRejected()).toBe(false);\n\t});\n\n\tit(\"does not reopen a placement that outlived its confirmation window\", async () => {\n\t\tlet Store = await draftStore();\n\t\tif (!Store) return;\n\t\tlet store = new Store();\n\t\tstore.attachPlacement(() => true);\n\t\tstore.open(ANCHOR, position(\"accepted\"));\n\t\tstore.change(REQUEST.question);\n\t\tawait store.start(async () => REQUEST);\n\n\t\texpect(store.restoreRejected(Date.now() + 60_000)).toBe(false);\n\t\texpect(store.get()).toBeUndefined();\n\t});\n});\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132],"tags",[71,72,73,74],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794728432557,"sidebar","expanded"]