[{"_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",{"_40":41,"_227":-5,"_228":-5,"_229":230},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":31,"_43":31,"_44":31,"_45":31,"_46":31,"_47":31,"_48":49,"_50":49,"_51":31,"_52":-7,"_53":-7,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68},"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","6dcf8326df3f80f90ffb061dc1005dce10ffa5da","path","apps/server/src/questions.service.test.ts","oid","95914521ff55853aa8870fe3638aa2039a07c31c","size",8472,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { 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\";\n\nimport type { Server } from \"bun\";\nimport type { Plan } from \"./plan/service\";\nimport type { Socket, SocketData } from \"./wire\";\n\nimport { createQuestionServiceFixture } from \"./question-service.test-fixtures\";\nlet plans: Plan[];\nlet fixture = createQuestionServiceFixture(() => plans, value => {\n\tplans = value;\n});\nplans = fixture.plans;\nlet { opened, definition, asking, answer } = fixture;\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(\"