[{"_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","93daad40b3f86079e1e828236eff99d2e6529b2a","path","apps/server/src/questions.service.test.ts","oid","69560b4d262573bf2e2d3c7751fd719ec104d47a","size",10017,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { afterEach, expect, test } from \"bun:test\";\n\nimport * as Question from \"@chopin/question\";\n\nimport * as Questions from \"./questions/service\";\nimport * as Store from \"./questions/store\";\nimport * as room from \"./plan/room\";\nimport * as Service from \"./plan/service\";\nimport { openPlan } from \"./testing/plan\";\n\nimport type { Server } from \"bun\";\nimport type { Plan } from \"./plan/service\";\nimport type { Socket, SocketData } from \"./wire\";\n\nlet plans: Plan[] = [];\n\nafterEach(async () => {\n\tfor (let plan of plans) await Service.close(plan);\n\tplans = [];\n});\n\nasync function opened(source = \"\"): Promise {\n\tlet { plan } = await openPlan(source);\n\tplans.push(plan);\n\treturn plan;\n}\n\nfunction definition(count = 1) {\n\treturn Questions.identify({\n\t\tquestions: Array.from({ length: count }, (_, index) => ({\n\t\t\theader: `Decision ${index + 1}`,\n\t\t\tquestion: `What should decision ${index + 1} be?`,\n\t\t\tmultiple: false,\n\t\t\toptions: [{ label: \"Choose this\", description: \"The selected option.\" }],\n\t\t})),\n\t});\n}\n\nfunction asking(\n\tplan: Plan,\n\tserver: Server,\n\tvalue: ReturnType,\n\tplacement?: Parameters[4],\n) {\n\tlet created = Promise.withResolvers();\n\tlet waiting = Questions.ask(plan, server, \"test\", value, placement, created.resolve);\n\treturn { created: created.promise, waiting };\n}\n\nasync function answer(plan: Plan): Promise {\n\tfor (let record of [...plan.records.values()].toReversed()) {\n\t\tlet item = record.definition.questions[0]!;\n\t\tlet opened = Store.snapshot(plan.questions, record.id);\n\t\tif (!opened.open) throw new Error(\"question was not open\");\n\t\tlet model = Question.crdt.Model.fromBinary(new Uint8Array(opened.model))\n\t\t\t.fork() as unknown as Question.Model;\n\t\tmodel.api.val([item.id, \"mode\"]).set(\"choices\");\n\t\tmodel.api.val([item.id, \"choice\"]).set(item.options[0]!.id);\n\t\tlet patch = model.api.flush();\n\t\tif (!patch) throw new Error(\"answer produced no patch\");\n\t\tlet edited = Store.edit(plan.questions, record.id, [...patch.toBinary()]);\n\t\tif (!edited.open || !edited.accepted) throw new Error(\"could not save answer\");\n\t\tlet claimed = Store.claimSubmit(plan.questions, record.id, edited.revision, item.header);\n\t\tif (!claimed.ok) throw new Error(\"could not settle question\");\n\t\tStore.commit(plan.questions, claimed.claim);\n\t}\n}\n\ntest(\"a batched ask creates independently addressed decision records and nodes\", async () => {\n\tlet plan = await opened();\n\tlet definition = Questions.identify({\n\t\tquestions: [\n\t\t\t{\n\t\t\t\theader: \"Storage\",\n\t\t\t\tquestion: \"Where should room state live?\",\n\t\t\t\tmultiple: false,\n\t\t\t\toptions: [{ label: \"MDX on disk\", description: \"Readable.\" }],\n\t\t\t},\n\t\t\t{\n\t\t\t\theader: \"Scope\",\n\t\t\t\tquestion: \"What belongs in the first cut?\",\n\t\t\t\tmultiple: true,\n\t\t\t\toptions: [{ label: \"Anchors\", description: \"Link prose.\" }],\n\t\t\t},\n\t\t],\n\t});\n\n\tlet server = { publish() {} } as unknown as Server;\n\tlet asked = asking(plan, server, definition);\n\tawait asked.created;\n\tlet records = [...plan.records.values()];\n\n\texpect(records).toHaveLength(2);\n\texpect(records.map(record => record.definition.questions)).toEqual([\n\t\t[definition.questions[0]],\n\t\t[definition.questions[1]],\n\t]);\n\texpect(room.project(plan.document).match(/ {\n\tlet plan = await opened(\"Related prose.\\n\");\n\tlet questions = definition();\n\tlet digest = room.digests(plan.document)[0]!;\n\tlet server = { publish() {} } as unknown as Server;\n\tlet asked = asking(plan, server, questions, {\n\t\trevision: plan.revision,\n\t\tblocks: [[{ index: 0, digest }]],\n\t});\n\tawait asked.created;\n\n\tlet anchors = Questions.anchors(plan)[0]!.questions[questions.questions[0]!.id]!;\n\tlet source = room.project(plan.document);\n\texpect(source.indexOf(\"Related prose.\")).toBeLessThan(source.indexOf(\" {\n\tlet plan = await opened(\"Related prose.\\n\");\n\tlet questions = definition(2);\n\tlet digest = room.digests(plan.document)[0]!;\n\tlet server = { publish() {} } as unknown as Server;\n\tlet asked = asking(plan, server, questions, {\n\t\trevision: plan.revision,\n\t\tblocks: [[{ index: 0, digest }], [{ index: 0, digest }]],\n\t});\n\tawait asked.created;\n\n\tlet source = room.project(plan.document);\n\texpect(source.indexOf(\"Related prose.\")).toBeLessThan(source.indexOf(\"Decision 1\"));\n\texpect(source.indexOf(\"Decision 1\")).toBeLessThan(source.indexOf(\"Decision 2\"));\n\n\tawait answer(plan);\n\tawait asked.waiting;\n});\n\ntest(\"a stale placement does not create records or questionnaire nodes\", async () => {\n\tlet plan = await opened(\"Related prose.\\n\");\n\tlet questions = definition();\n\tlet digest = room.digests(plan.document)[0]!;\n\tlet server = { publish() {} } as unknown as Server;\n\tlet waiting = Questions.ask(plan, server, \"test\", questions, {\n\t\trevision: plan.revision + 1,\n\t\tblocks: [[{ index: 0, digest }]],\n\t});\n\n\tawait expect(waiting).rejects.toThrow(/changed.*read/i);\n\texpect(plan.records.size).toBe(0);\n\texpect(room.project(plan.document)).not.toContain(\" {\n\tlet plan = await opened(\"Related prose.\\n\");\n\tlet questions = definition();\n\tlet server = { publish() {} } as unknown as Server;\n\tlet waiting = Questions.ask(plan, server, \"test\", questions, {\n\t\trevision: plan.revision,\n\t\tblocks: [[{ index: 0, digest: room.digest(\"different\") }]],\n\t});\n\n\tawait expect(waiting).rejects.toThrow(/changed.*read/i);\n\texpect(plan.records.size).toBe(0);\n\texpect(room.project(plan.document)).not.toContain(\" {\n\tlet plan = await opened(\"Related prose.\\n\");\n\tlet questions = definition();\n\tlet server = { publish() {} } as unknown as Server;\n\tlet waiting = Questions.ask(plan, server, \"test\", questions, {\n\t\trevision: plan.revision,\n\t\tblocks: [[]],\n\t});\n\n\tawait expect(waiting).rejects.toThrow(/relate.*write/i);\n\texpect(plan.records.size).toBe(0);\n\texpect(room.project(plan.document)).not.toContain(\" {\n\tlet plan = await opened();\n\tlet server = { publish() {} } as unknown as Server;\n\tlet first = asking(plan, server, definition(), {\n\t\trevision: plan.revision,\n\t\tblocks: [[]],\n\t});\n\tawait first.created;\n\tlet second = asking(plan, server, definition(), {\n\t\trevision: plan.revision,\n\t\tblocks: [[]],\n\t});\n\tawait second.created;\n\n\texpect(plan.records.size).toBe(2);\n\texpect(room.project(plan.document).match(/ {\n\tlet plan = await opened();\n\tlet server = { publish() {} } as unknown as Server;\n\tlet asked = asking(plan, server, definition());\n\tawait asked.created;\n\tlet id = [...plan.records.keys()][0]!;\n\tlet replies: Array<{ kind: string; message?: string; rid?: string; ts?: number }> = [];\n\tlet ws = {\n\t\tdata: { handle: \"ana\", client: \"client-ana\", room: \"test\" },\n\t\tsend(raw: string) {\n\t\t\treplies.push(JSON.parse(raw));\n\t\t},\n\t} as unknown as Socket;\n\tplan.execution = { id: \"run-1\" } as never;\n\n\tawait Questions.cancel(plan, server, \"test\", ws, {\n\t\tkind: \"question:cancel\",\n\t\tts: 0,\n\t\trid: \"cancel\",\n\t\tid,\n\t});\n\n\texpect(replies).toEqual([{\n\t\tkind: \"session:error\",\n\t\tmessage: \"implementation is active\",\n\t\tts: expect.any(Number),\n\t\trid: \"cancel\",\n\t}]);\n\texpect(plan.records.get(id)?.status).toBe(\"open\");\n\texpect(room.project(plan.document)).toContain(\" {\n\tlet plan = await opened();\n\tlet server = { publish() {} } as unknown as Server;\n\tlet revision = plan.revision;\n\tplan.execution = { id: \"run-1\" } as never;\n\n\tawait expect(Questions.ask(plan, server, \"test\", definition()))\n\t\t.rejects.toThrow(\"implementation is active\");\n\n\texpect(plan.revision).toBe(revision);\n\texpect(plan.records.size).toBe(0);\n\texpect(room.project(plan.document)).not.toContain(\"