[{"_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","422922ce4be3dcef70abe83487f39c97a21de2bc","path","apps/server/src/research/service.test.ts","oid","0b671ba4ad662351757eae437fa5e4a1d443eb9e","size",45128,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { describe, expect, it, spyOn } from \"bun:test\";\n\nimport { parse } from \"@chopin/dialect\";\nimport { parseResearchAnswerInput, parseResearchEvidenceInput } from \"../jobs/research-workspace\";\nimport { StorageError } from \"../storage/errors\";\nimport * as Plan from \"../plan/service\";\nimport { boundedResearchEvidence, ResearchWorkspaceError } from \"./service\";\nimport {\n\tanswerArtifact,\n\tcreateAndConfirm,\n\tevidenceArtifact,\n\tfinishInitial,\n\tPUBLIC_SOURCE,\n\treconciledRequest,\n\treconciledWorkspace,\n\tREPORT,\n\tREPOSITORY_ID,\n\trequestId,\n\tsettle,\n\tsetup,\n\tUSER_ID,\n} from \"./test-support\";\n\nimport type { ResearchReport } from \"../jobs/research-workspace\";\nimport type { JsonValue } from \"../storage/model\";\n\nasync function failInitialEvidence(context: Awaited>) {\n\tlet [claimed] = await context.storage.jobs.claim({\n\t\tchannelId: context.channelId,\n\t\tclaimOwner: \"failing-worker\",\n\t\tcount: 1,\n\t\tttlMs: 30_000,\n\t\tnow: context.advance(),\n\t\tlease: context.lease,\n\t});\n\tif (!claimed) throw new Error(\"initial evidence job was not claimable\");\n\tawait context.storage.jobs.fail({\n\t\tchannelId: context.channelId,\n\t\tjobId: claimed.id,\n\t\tclaimOwner: \"failing-worker\",\n\t\tclaimGeneration: claimed.claimGeneration,\n\t\treason: \"internal-provider-detail\",\n\t\tnow: context.advance(),\n\t\tlease: context.lease,\n\t});\n\treturn claimed.id;\n}\n\ndescribe(\"research workspace service\", () => {\n\tit(\"starts one inline request and schedules its initial turn immediately\", async () => {\n\t\tlet context = await setup();\n\t\tlet brief = \" Compare API v2 with v3.\\nExplain migration risks. \";\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: brief,\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t});\n\n\t\texpect(started).toMatchObject({\n\t\t\trepeated: false,\n\t\t\trequest: {\n\t\t\t\tquestion: brief,\n\t\t\t\tstate: \"pending\",\n\t\t\t\tstage: \"queued\",\n\t\t\t\tsources: [],\n\t\t\t},\n\t\t});\n\t\tlet stored = await context.storage.research.get(\n\t\t\tcontext.channelId,\n\t\t\tstarted.request.id,\n\t\t);\n\t\texpect(stored).toMatchObject({\n\t\t\tworkspace: {\n\t\t\t\torigin: \"inline\",\n\t\t\t\tproposedQuestion: brief,\n\t\t\t\tconfirmedQuery: brief,\n\t\t\t\tcreatedBy: USER_ID,\n\t\t\t\tconfirmedBy: USER_ID,\n\t\t\t},\n\t\t\tturns: [{ kind: \"initial\", question: brief, requestedBy: USER_ID }],\n\t\t\tmessages: [{ authorKind: \"member\", text: brief, userHandle: \"octocat\" }],\n\t\t});\n\t\texpect(stored?.turns[0]?.evidenceJobId).toBeDefined();\n\n\t\tlet repeated = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: brief,\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t});\n\t\texpect(repeated).toEqual({ ...started, repeated: true });\n\t\tawait expect(context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"A different brief\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t})).rejects.toBeInstanceOf(StorageError);\n\t});\n\n\tit(\"starts Planner research immediately and replays its member message identity\", async () => {\n\t\tlet context = await setup();\n\t\tlet owners = 0;\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which public evidence supports version 3?\",\n\t\t\toriginMessageId: \"01K39QZG000000000000000001\",\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t};\n\t\tlet started = await context.service.startPlanner(input);\n\t\texpect(started).toMatchObject({\n\t\t\trepeated: false,\n\t\t\trequest: { state: \"pending\", stage: \"queued\" },\n\t\t});\n\t\tlet stored = await context.storage.research.get(context.channelId, started.request.id);\n\t\texpect(stored).toMatchObject({\n\t\t\tworkspace: {\n\t\t\t\torigin: \"planner\",\n\t\t\t\toriginMessageId: input.originMessageId,\n\t\t\t\tconfirmedQuery: input.question,\n\t\t\t},\n\t\t\tturns: [{ kind: \"initial\", question: input.question }],\n\t\t});\n\t\texpect(stored?.turns[0]?.evidenceJobId).toBeDefined();\n\n\t\tlet repeated = await context.service.startPlanner({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\tthrow new Error(\"an active replay must not reacquire an owner\");\n\t\t\t},\n\t\t});\n\t\texpect(repeated.repeated).toBe(true);\n\t\texpect(repeated.request.id).toBe(started.request.id);\n\t\texpect(owners).toBe(1);\n\t});\n\n\tit(\"refuses child Planner research before owner setup or durable work\", async () => {\n\t\tlet context = await setup();\n\t\tlet child = await context.storage.channels.create({\n\t\t\tid: crypto.randomUUID(),\n\t\t\trepositoryId: REPOSITORY_ID,\n\t\t\trepositoryOwner: \"octo-org\",\n\t\t\trepositoryName: \"score\",\n\t\t\tparentChannelId: context.channelId,\n\t\t\ttitle: \"Published research child\",\n\t\t\tcreatedBy: context.userId,\n\t\t\tnow: context.advance(),\n\t\t});\n\t\tlet owners = 0;\n\t\tlet failure: unknown;\n\t\ttry {\n\t\t\tawait context.service.startPlanner({\n\t\t\t\tchannelId: child.id,\n\t\t\t\tquestion: \"Create a grandchild\",\n\t\t\t\toriginMessageId: \"01K39QZG000000000000000002\",\n\t\t\t\trequestedBy: context.userId,\n\t\t\t\trequestedByHandle: \"octocat\",\n\t\t\t\tbeforeStart: () => {\n\t\t\t\t\towners++;\n\t\t\t\t},\n\t\t\t});\n\t\t} catch (err) {\n\t\t\tfailure = err;\n\t\t}\n\t\tlet durable = await context.storage.research.list(child.id, 100);\n\t\tlet jobs = (await context.jobs.list(child.id, 100))?.jobs ?? [];\n\n\t\texpect({\n\t\t\tcode: failure instanceof ResearchWorkspaceError ? failure.code : undefined,\n\t\t\towners,\n\t\t\trequests: durable.length,\n\t\t\tjobs: jobs.length,\n\t\t}).toEqual({ code: \"invalid-request\", owners: 0, requests: 0, jobs: 0 });\n\t});\n\n\tit(\"checks durable work before owner setup and recovers setup failure before enqueue\", async () => {\n\t\tlet context = await setup();\n\t\tlet brief = \"Which API contracts changed?\";\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: brief,\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t};\n\t\tlet owners = 0;\n\t\tlet active = await context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t});\n\t\tawait context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\tthrow new Error(\"an active replay must not reacquire an owner\");\n\t\t\t},\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, active.request.id);\n\t\tawait settle(context, \"research-answer\", answerArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, active.request.id);\n\t\tawait context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\tthrow new Error(\"a completed replay must not reacquire an owner\");\n\t\t\t},\n\t\t});\n\t\texpect(owners).toBe(1);\n\n\t\tlet recovery = await setup();\n\t\tlet attempts = 0;\n\t\tlet recoveryInput = {\n\t\t\tchannelId: recovery.channelId,\n\t\t\tquestion: brief,\n\t\t\trequestId: requestId(2),\n\t\t\trequestedBy: recovery.userId,\n\t\t};\n\t\tawait expect(recovery.service.start({\n\t\t\t...recoveryInput,\n\t\t\tbeforeStart: () => {\n\t\t\t\tattempts++;\n\t\t\t\tthrow new Error(\"owner setup failed\");\n\t\t\t},\n\t\t})).rejects.toThrow(\"owner setup failed\");\n\t\tlet durable = await recovery.storage.research.list(recovery.channelId, 100);\n\t\texpect(durable).toHaveLength(1);\n\t\texpect((await recovery.storage.research.get(recovery.channelId, durable[0]!.id))?.turns[0])\n\t\t\t.toMatchObject({ kind: \"initial\", evidenceJobId: undefined });\n\t\texpect(recovery.publications).toEqual([]);\n\t\tlet recovered = await recovery.service.start({\n\t\t\t...recoveryInput,\n\t\t\tbeforeStart: () => {\n\t\t\t\tattempts++;\n\t\t\t},\n\t\t});\n\t\texpect(recovered.repeated).toBe(true);\n\t\texpect(recovered.request.stage).toBe(\"queued\");\n\t\texpect(attempts).toBe(2);\n\t});\n\n\tit(\"runs owner setup once across concurrent exact starts\", async () => {\n\t\tlet context = await setup();\n\t\tlet ownerStarted = Promise.withResolvers();\n\t\tlet releaseOwner = Promise.withResolvers();\n\t\tlet owners = 0;\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t};\n\t\tlet first = context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: async () => {\n\t\t\t\towners++;\n\t\t\t\townerStarted.resolve();\n\t\t\t\tawait releaseOwner.promise;\n\t\t\t},\n\t\t});\n\t\tawait ownerStarted.promise;\n\t\tlet second = context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t});\n\t\tawait Promise.resolve();\n\t\treleaseOwner.resolve();\n\t\tlet [created, repeated] = await Promise.all([first, second]);\n\t\texpect(created.repeated).toBe(false);\n\t\texpect(repeated.repeated).toBe(true);\n\t\texpect(repeated.request.id).toBe(created.request.id);\n\t\texpect(owners).toBe(1);\n\t});\n\n\tit(\"exposes owner setup recovery without starting work on read\", async () => {\n\t\tlet context = await setup();\n\t\tlet owners = 0;\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t};\n\t\tawait expect(context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t\tthrow new Error(\"owner setup failed\");\n\t\t\t},\n\t\t})).rejects.toThrow(\"owner setup failed\");\n\t\tlet [workspace] = await context.storage.research.list(context.channelId, 100);\n\t\tif (!workspace) throw new Error(\"durable research request is unavailable\");\n\n\t\tlet observed = await context.restart().request(context.channelId, workspace.id);\n\t\texpect(observed).toMatchObject({ state: \"failed\", stage: \"failed\" });\n\t\texpect(\n\t\t\t(await context.storage.research.get(context.channelId, workspace.id))?.turns[0]\n\t\t\t\t?.evidenceJobId,\n\t\t).toBeUndefined();\n\t\texpect((await context.jobs.list(context.channelId, 100))?.jobs).toEqual([]);\n\n\t\tlet recovered = await context.restart().start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t});\n\t\texpect(recovered.repeated).toBe(true);\n\t\texpect(recovered.request.stage).toBe(\"queued\");\n\t\texpect(owners).toBe(2);\n\t\texpect((await context.jobs.list(context.channelId, 100))?.jobs).toHaveLength(1);\n\t});\n\n\tit(\"adopts orphan first evidence only after an owner-checked exact retry\", async () => {\n\t\tlet context = await setup();\n\t\tlet owners = 0;\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t};\n\t\tawait expect(context.service.start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t\tthrow new Error(\"simulate a crash before first enqueue\");\n\t\t\t},\n\t\t})).rejects.toThrow(\"simulate a crash before first enqueue\");\n\t\tlet [workspace] = await context.storage.research.list(context.channelId, 100);\n\t\tif (!workspace) throw new Error(\"durable research request is unavailable\");\n\t\tlet detail = await context.storage.research.get(context.channelId, workspace.id);\n\t\tlet initial = detail?.turns[0];\n\t\tif (!initial) throw new Error(\"initial research turn is unavailable\");\n\t\tlet existing = await context.jobs.enqueueUser({\n\t\t\tchannelId: context.channelId,\n\t\t\ttype: \"research-evidence\",\n\t\t\ttargetKey: `workspace:${workspace.id}:turn:${initial.id}:evidence`,\n\t\t\tidempotencyKey: `research-evidence:${initial.id}`,\n\t\t\tinput: {\n\t\t\t\tworkspaceId: workspace.id,\n\t\t\t\tturnId: initial.id,\n\t\t\t\tquery: initial.question,\n\t\t\t},\n\t\t});\n\n\t\tlet reader = context.restart();\n\t\tlet before = await reader.request(context.channelId, workspace.id);\n\t\texpect(before).toMatchObject({ state: \"failed\", stage: \"failed\" });\n\t\texpect(\n\t\t\t(await context.storage.research.get(context.channelId, workspace.id))?.turns[0]\n\t\t\t\t?.evidenceJobId,\n\t\t).toBeUndefined();\n\n\t\tlet observed = await reconciledRequest(\n\t\t\treader,\n\t\t\tcontext.channelId,\n\t\t\tworkspace.id,\n\t\t);\n\t\texpect(observed).toMatchObject({ state: \"failed\", stage: \"failed\" });\n\t\texpect(\n\t\t\t(await context.storage.research.get(context.channelId, workspace.id))?.turns[0]\n\t\t\t\t?.evidenceJobId,\n\t\t).toBeUndefined();\n\t\texpect((await context.jobs.list(context.channelId, 100))?.jobs).toHaveLength(1);\n\n\t\tlet recovered = await context.restart().start({\n\t\t\t...input,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t});\n\t\texpect(recovered.repeated).toBe(true);\n\t\texpect(\n\t\t\t(await context.storage.research.get(context.channelId, workspace.id))?.turns[0]\n\t\t\t\t?.evidenceJobId,\n\t\t).toBe(existing.job.id);\n\t\texpect(owners).toBe(2);\n\t\texpect((await context.jobs.list(context.channelId, 100))?.jobs).toHaveLength(1);\n\t});\n\n\tit(\"publishes one canonical child while reconciling a completed initial answer after restart\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.restart(), context.channelId, started.request.id);\n\t\tawait settle(context, \"research-answer\", answerArtifact);\n\n\t\tlet recovered = await reconciledRequest(\n\t\t\tcontext.restart(),\n\t\t\tcontext.channelId,\n\t\t\tstarted.request.id,\n\t\t);\n\t\texpect(recovered).toMatchObject({\n\t\t\tid: started.request.id,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\tstate: \"completed\",\n\t\t\tstage: \"ready\",\n\t\t\tsources: [PUBLIC_SOURCE],\n\t\t\tchild: {\n\t\t\t\ttitle: REPORT.title,\n\t\t\t\tsummary: REPORT.summary,\n\t\t\t\tsourceCount: 1,\n\t\t\t},\n\t\t});\n\t\tlet childId = recovered?.child?.id;\n\t\tif (!childId) throw new Error(\"research child was not published\");\n\t\tlet child = await context.storage.channels.get(childId);\n\t\texpect(child).toMatchObject({ parentChannelId: context.channelId, title: REPORT.title });\n\t\tlet stored = await context.storage.collaboration.load(childId, context.advance());\n\t\tif (!stored) throw new Error(\"research child document was not initialized\");\n\t\tlet document = await Plan.readStored(stored);\n\t\texpect(document.source).toContain(\"# Compatibility report\");\n\t\texpect(document.source).toContain(REPORT.summary);\n\t\texpect(document.source).toContain(PUBLIC_SOURCE.url);\n\n\t\tlet replayed = await context.restart().request(context.channelId, started.request.id);\n\t\texpect(replayed?.child?.id).toBe(childId);\n\t\tlet listed = await context.storage.channels.list(REPOSITORY_ID, 100);\n\t\texpect(listed.channels.filter(value => value.parentChannelId === context.channelId))\n\t\t\t.toHaveLength(1);\n\t});\n\n\tit(\"keeps transient publication failure readable and retries once on later reconciliation\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet answer = await settle(context, \"research-answer\", answerArtifact);\n\t\tlet available = false;\n\t\tlet attempts = 0;\n\t\tlet publish = context.storage.research.publishInitialReport.bind(context.storage.research);\n\t\tlet publication = spyOn(context.storage.research, \"publishInitialReport\")\n\t\t\t.mockImplementation(input => {\n\t\t\t\tattempts++;\n\t\t\t\tif (!available) {\n\t\t\t\t\tthrow new StorageError(\"unavailable\", \"temporary publication outage\");\n\t\t\t\t}\n\t\t\t\treturn publish(input);\n\t\t\t});\n\t\ttry {\n\t\t\tawait context.service.jobChanged(answer.job);\n\t\t\tlet retrying = await reconciledRequest(\n\t\t\t\tcontext.service,\n\t\t\t\tcontext.channelId,\n\t\t\t\tstarted.request.id,\n\t\t\t);\n\t\t\texpect(retrying).toMatchObject({ state: \"completed\", stage: \"publishing\" });\n\t\t\texpect(retrying?.child).toBeUndefined();\n\t\t\texpect(attempts).toBe(2);\n\t\t\tavailable = true;\n\t\t\tlet ready = await reconciledRequest(\n\t\t\t\tcontext.service,\n\t\t\t\tcontext.channelId,\n\t\t\t\tstarted.request.id,\n\t\t\t);\n\t\t\texpect(ready).toMatchObject({ state: \"completed\", stage: \"ready\" });\n\t\t\texpect(attempts).toBe(3);\n\t\t} finally {\n\t\t\tpublication.mockRestore();\n\t\t}\n\t});\n\n\tit(\"reserves a title collision atomically during publication\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet answer = await settle(context, \"research-answer\", answerArtifact);\n\t\tlet publish = context.storage.research.publishInitialReport.bind(context.storage.research);\n\t\tlet raced = false;\n\t\tlet publication = spyOn(context.storage.research, \"publishInitialReport\")\n\t\t\t.mockImplementation(async input => {\n\t\t\t\tif (!raced) {\n\t\t\t\t\traced = true;\n\t\t\t\t\tawait context.storage.channels.create({\n\t\t\t\t\t\tid: crypto.randomUUID(),\n\t\t\t\t\t\trepositoryId: REPOSITORY_ID,\n\t\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\t\ttitle: input.title,\n\t\t\t\t\t\tcreatedBy: context.userId,\n\t\t\t\t\t\tnow: context.advance(),\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\treturn publish(input);\n\t\t\t});\n\t\ttry {\n\t\t\tawait expect(context.service.jobChanged(answer.job)).resolves.toBeUndefined();\n\t\t\tlet ready = await context.service.request(context.channelId, started.request.id);\n\t\t\texpect(ready?.child?.title).toBe(`${REPORT.title} (2)`);\n\t\t} finally {\n\t\t\tpublication.mockRestore();\n\t\t}\n\t});\n\n\tit(\"does not classify corrupt publication state as retryable\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet answer = await settle(context, \"research-answer\", answerArtifact);\n\t\tlet publication = spyOn(context.storage.research, \"publishInitialReport\")\n\t\t\t.mockRejectedValue(new StorageError(\"corrupt\", \"invalid publication state\"));\n\t\ttry {\n\t\t\tawait expect(context.service.jobChanged(answer.job)).rejects.toMatchObject({\n\t\t\t\tfailure: \"corrupt\",\n\t\t\t});\n\t\t} finally {\n\t\t\tpublication.mockRestore();\n\t\t}\n\t});\n\n\tit(\"rejects a superseded answer instead of retrying publication indefinitely\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet answer = await settle(context, \"research-answer\", answerArtifact);\n\t\tlet storedAnswer = await context.storage.jobs.get(context.channelId, answer.job.id);\n\t\tif (!storedAnswer) throw new Error(\"completed answer job is unavailable\");\n\t\tlet replacement = await context.jobs.enqueueUser({\n\t\t\tchannelId: context.channelId,\n\t\t\ttype: \"research-answer\",\n\t\t\ttargetKey: answer.job.targetKey.replace(/^research-answer:/, \"\"),\n\t\t\tidempotencyKey: \"superseding-answer\",\n\t\t\tinput: { ...(storedAnswer.job.input as Record), question: \"Superseded\" },\n\t\t});\n\t\texpect(replacement.repeated).toBe(false);\n\t\texpect(replacement.job.targetGeneration).toBeGreaterThan(answer.job.targetGeneration);\n\n\t\tawait expect(context.service.jobChanged(answer.job)).rejects.toMatchObject({\n\t\t\tcode: \"invalid-state\",\n\t\t});\n\t});\n\n\tit(\"publishes hostile report text as plain prose with explicit HTTPS links\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet hostileSource = {\n\t\t\ttitle: \"[Release] > # notes\",\n\t\t\turl: \"https://example.com/releases/v3?view=full\",\n\t\t};\n\t\tlet hostileReport: ResearchReport = {\n\t\t\ttitle: \"# Heading > [not a link]\",\n\t\t\tsummary: \"> quoted\\n- listed # not heading\",\n\t\t\tfindings: [{\n\t\t\t\ttext: \"# finding [fake](https://evil.example) {expression}\",\n\t\t\t\tsourceUrls: [hostileSource.url],\n\t\t\t}],\n\t\t\tcaveats: [\"1. caveat > quote - item [label]\"],\n\t\t};\n\t\tawait settle(context, \"research-answer\", job => {\n\t\t\tlet artifact = answerArtifact(job) as Record;\n\t\t\treturn { ...artifact, report: hostileReport, sources: [hostileSource] };\n\t\t});\n\t\tlet ready = await reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet stored = await context.storage.collaboration.load(ready!.child!.id, context.advance());\n\t\tif (!stored) throw new Error(\"research child document was not initialized\");\n\t\tlet document = await Plan.readStored(stored);\n\t\tlet tree = parse(document.source);\n\t\texpect(tree.children.map(node => node.type)).toEqual([\n\t\t\t\"heading\",\n\t\t\t\"paragraph\",\n\t\t\t\"heading\",\n\t\t\t\"list\",\n\t\t\t\"heading\",\n\t\t\t\"list\",\n\t\t\t\"heading\",\n\t\t\t\"list\",\n\t\t]);\n\t\tlet nodes: Array> = [];\n\t\tlet visit = (value: unknown): void => {\n\t\t\tif (!value || typeof value !== \"object\") return;\n\t\t\tlet node = value as Record;\n\t\t\tnodes.push(node);\n\t\t\tfor (let child of Array.isArray(node.children) ? node.children : []) visit(child);\n\t\t};\n\t\tvisit(tree);\n\t\tlet links = nodes.filter(node => node.type === \"link\");\n\t\texpect(links.map(node => node.url)).toEqual([\n\t\t\thostileSource.url,\n\t\t\thostileSource.url,\n\t\t]);\n\t\texpect(links.map(node => (node.children as Array<{ value: string }>)[0]?.value)).toEqual([\n\t\t\t\"1\",\n\t\t\thostileSource.title,\n\t\t]);\n\t\texpect(nodes.filter(node => node.type === \"blockquote\")).toEqual([]);\n\t\texpect(nodes.filter(node => node.type === \"mdxJsxTextElement\")).toEqual([]);\n\t\texpect(nodes.filter(node => node.type === \"mdxTextExpression\")).toEqual([]);\n\t\texpect(document.source).not.toContain(\"[fake](https://evil.example)\");\n\t});\n\n\tit(\"does not publish children for failed or cancelled initial work\", async () => {\n\t\tlet failed = await setup();\n\t\tlet failedRequest = await failed.service.start({\n\t\t\tchannelId: failed.channelId,\n\t\t\tquestion: \"Research a failing source\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: failed.userId,\n\t\t});\n\t\tlet claimed = await failed.storage.jobs.claim({\n\t\t\tchannelId: failed.channelId,\n\t\t\tclaimOwner: \"failing-worker\",\n\t\t\tcount: 1,\n\t\t\tttlMs: 30_000,\n\t\t\tnow: failed.advance(),\n\t\t\tlease: failed.lease,\n\t\t});\n\t\tawait failed.storage.jobs.fail({\n\t\t\tchannelId: failed.channelId,\n\t\t\tjobId: claimed[0]!.id,\n\t\t\tclaimOwner: \"failing-worker\",\n\t\t\tclaimGeneration: claimed[0]!.claimGeneration,\n\t\t\treason: \"internal-provider-detail\",\n\t\t\tnow: failed.advance(),\n\t\t\tlease: failed.lease,\n\t\t});\n\t\tlet failure = await failed.restart().request(failed.channelId, failedRequest.request.id);\n\t\texpect(failure).toMatchObject({\n\t\t\tstate: \"failed\",\n\t\t\tstage: \"failed\",\n\t\t\terror: \"Research could not be completed.\",\n\t\t});\n\t\texpect(JSON.stringify(failure)).not.toContain(\"internal-provider-detail\");\n\t\texpect(\n\t\t\t(await failed.storage.research.get(failed.channelId, failedRequest.request.id))\n\t\t\t\t?.workspace.publishedChannelId,\n\t\t).toBeUndefined();\n\n\t\tlet cancelled = await setup();\n\t\tlet cancelledRequest = await cancelled.service.start({\n\t\t\tchannelId: cancelled.channelId,\n\t\t\tquestion: \"Research a cancelled source\",\n\t\t\trequestId: requestId(2),\n\t\t\trequestedBy: cancelled.userId,\n\t\t});\n\t\tlet stored = await cancelled.storage.research.get(\n\t\t\tcancelled.channelId,\n\t\t\tcancelledRequest.request.id,\n\t\t);\n\t\tlet cancelledView = await cancelled.service.cancelTurn({\n\t\t\tchannelId: cancelled.channelId,\n\t\t\tworkspaceId: cancelledRequest.request.id,\n\t\t\tturnId: stored!.turns[0]!.id,\n\t\t});\n\t\texpect(cancelledView.turns[0]?.evidence?.job.state).toBe(\"cancelled\");\n\t\tlet cancellation = await cancelled.restart().request(\n\t\t\tcancelled.channelId,\n\t\t\tcancelledRequest.request.id,\n\t\t);\n\t\texpect(cancellation).toMatchObject({ state: \"cancelled\", stage: \"cancelled\" });\n\t\texpect(\n\t\t\t(await cancelled.storage.research.get(\n\t\t\t\tcancelled.channelId,\n\t\t\t\tcancelledRequest.request.id,\n\t\t\t))?.workspace.publishedChannelId,\n\t\t).toBeUndefined();\n\t});\n\n\tit(\"retries failed and cancelled work on the same immutable request\", async () => {\n\t\tfor (let terminal of [\"failed\", \"cancelled\"] as const) {\n\t\t\tlet context = await setup();\n\t\t\tlet started = await context.service.start({\n\t\t\t\tchannelId: context.channelId,\n\t\t\t\tquestion: ` Preserve the ${terminal} brief exactly. `,\n\t\t\t\trequestId: requestId(31),\n\t\t\t\trequestedBy: context.userId,\n\t\t\t});\n\t\t\tlet before = await context.storage.research.get(context.channelId, started.request.id);\n\t\t\tlet oldJobId = before!.turns[0]!.evidenceJobId!;\n\t\t\tif (terminal === \"failed\") await failInitialEvidence(context);\n\t\t\telse {\n\t\t\t\tawait context.service.cancelRequest({\n\t\t\t\t\tchannelId: context.channelId,\n\t\t\t\t\tworkspaceId: started.request.id,\n\t\t\t\t});\n\t\t\t}\n\t\t\tlet owners = 0;\n\n\t\t\tlet retried = await context.service.retryRequest({\n\t\t\t\tchannelId: context.channelId,\n\t\t\t\tworkspaceId: started.request.id,\n\t\t\t\tbeforeStart: () => {\n\t\t\t\t\towners++;\n\t\t\t\t},\n\t\t\t});\n\n\t\t\texpect(retried).toMatchObject({\n\t\t\t\tid: started.request.id,\n\t\t\t\tquestion: started.request.question,\n\t\t\t\tstage: \"queued\",\n\t\t\t});\n\t\t\tlet after = await context.storage.research.get(context.channelId, started.request.id);\n\t\t\texpect(after!.turns).toHaveLength(1);\n\t\t\texpect(after!.turns[0]!.evidenceJobId).not.toBe(oldJobId);\n\t\t\texpect(await context.storage.research.findTurnByJob(context.channelId, oldJobId))\n\t\t\t\t.toBeUndefined();\n\t\t\texpect(owners).toBe(1);\n\t\t}\n\t});\n\n\tit(\"replaces terminal answer attempts before publishing the retried request\", async () => {\n\t\tfor (let terminal of [\"failed\", \"cancelled\"] as const) {\n\t\t\tlet context = await setup();\n\t\t\tlet started = await context.service.start({\n\t\t\t\tchannelId: context.channelId,\n\t\t\t\tquestion: `Retry a ${terminal} answer`,\n\t\t\t\trequestId: requestId(36),\n\t\t\t\trequestedBy: context.userId,\n\t\t\t});\n\t\t\tlet firstEvidence = await settle(context, \"research-evidence\", evidenceArtifact);\n\t\t\tawait context.service.jobChanged(firstEvidence.job);\n\t\t\tlet before = await context.storage.research.get(context.channelId, started.request.id);\n\t\t\tlet oldAnswerId = before!.turns[0]!.answerJobId!;\n\t\t\tif (terminal === \"failed\") {\n\t\t\t\tlet [answer] = await context.storage.jobs.claim({\n\t\t\t\t\tchannelId: context.channelId,\n\t\t\t\t\tclaimOwner: \"failing-answer-worker\",\n\t\t\t\t\tcount: 100,\n\t\t\t\t\tttlMs: 30_000,\n\t\t\t\t\tnow: context.advance(),\n\t\t\t\t\tlease: context.lease,\n\t\t\t\t});\n\t\t\t\tawait context.storage.jobs.fail({\n\t\t\t\t\tchannelId: context.channelId,\n\t\t\t\t\tjobId: answer!.id,\n\t\t\t\t\tclaimOwner: \"failing-answer-worker\",\n\t\t\t\t\tclaimGeneration: answer!.claimGeneration,\n\t\t\t\t\treason: \"answer failed\",\n\t\t\t\t\tnow: context.advance(),\n\t\t\t\t\tlease: context.lease,\n\t\t\t\t});\n\t\t\t} else {\n\t\t\t\tawait context.service.cancelRequest({\n\t\t\t\t\tchannelId: context.channelId,\n\t\t\t\t\tworkspaceId: started.request.id,\n\t\t\t\t});\n\t\t\t}\n\n\t\t\tawait context.service.retryRequest({\n\t\t\t\tchannelId: context.channelId,\n\t\t\t\tworkspaceId: started.request.id,\n\t\t\t});\n\t\t\texpect(await context.storage.research.findTurnByJob(context.channelId, oldAnswerId))\n\t\t\t\t.toBeUndefined();\n\t\t\tlet nextEvidence = await settle(context, \"research-evidence\", evidenceArtifact);\n\t\t\tawait context.service.jobChanged(nextEvidence.job);\n\t\t\tlet retried = await context.storage.research.get(context.channelId, started.request.id);\n\t\t\tlet nextAnswerId = retried!.turns[0]!.answerJobId;\n\t\t\texpect(nextAnswerId).toBeDefined();\n\t\t\tif (!nextAnswerId) throw new Error(\"retried answer was not linked\");\n\t\t\texpect(nextAnswerId).not.toBe(oldAnswerId);\n\t\t\tlet nextAnswer = await settle(context, \"research-answer\", answerArtifact);\n\t\t\texpect(nextAnswer.job.id).toBe(nextAnswerId);\n\t\t\tawait context.service.jobChanged(nextAnswer.job);\n\t\t\texpect(await context.service.request(context.channelId, started.request.id))\n\t\t\t\t.toMatchObject({ id: started.request.id, stage: \"ready\" });\n\t\t}\n\t});\n\n\tit(\"rejects retry for active and ready requests\", async () => {\n\t\tlet active = await setup();\n\t\tlet activeRequest = await active.service.start({\n\t\t\tchannelId: active.channelId,\n\t\t\tquestion: \"Active request\",\n\t\t\trequestId: requestId(32),\n\t\t\trequestedBy: active.userId,\n\t\t});\n\t\tawait expect(active.service.retryRequest({\n\t\t\tchannelId: active.channelId,\n\t\t\tworkspaceId: activeRequest.request.id,\n\t\t})).rejects.toMatchObject({ code: \"active-turn\" });\n\n\t\tlet ready = await setup();\n\t\tlet readyRequest = await ready.service.start({\n\t\t\tchannelId: ready.channelId,\n\t\t\tquestion: \"Ready request\",\n\t\t\trequestId: requestId(33),\n\t\t\trequestedBy: ready.userId,\n\t\t});\n\t\tlet evidence = await settle(ready, \"research-evidence\", evidenceArtifact);\n\t\tawait ready.service.jobChanged(evidence.job);\n\t\tlet answer = await settle(ready, \"research-answer\", answerArtifact);\n\t\tawait ready.service.jobChanged(answer.job);\n\t\texpect((await ready.service.request(ready.channelId, readyRequest.request.id))?.stage)\n\t\t\t.toBe(\"ready\");\n\t\tawait expect(ready.service.retryRequest({\n\t\t\tchannelId: ready.channelId,\n\t\t\tworkspaceId: readyRequest.request.id,\n\t\t})).rejects.toMatchObject({ code: \"not-ready\" });\n\t});\n\n\tit(\"creates at most one new evidence job across concurrent retries\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Retry concurrently\",\n\t\t\trequestId: requestId(34),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait failInitialEvidence(context);\n\t\tlet owners = 0;\n\t\tlet retry = () =>\n\t\t\tcontext.service.retryRequest({\n\t\t\t\tchannelId: context.channelId,\n\t\t\t\tworkspaceId: started.request.id,\n\t\t\t\tbeforeStart: () => {\n\t\t\t\t\towners++;\n\t\t\t\t},\n\t\t\t});\n\n\t\tlet results = await Promise.allSettled([retry(), retry()]);\n\n\t\texpect(results.filter(result => result.status === \"fulfilled\")).toHaveLength(1);\n\t\texpect(results.filter(result => result.status === \"rejected\")).toHaveLength(1);\n\t\tlet jobs = await context.storage.jobs.list(context.channelId, 100);\n\t\texpect(jobs!.jobs.filter(job => job.type === \"research-evidence\")).toHaveLength(2);\n\t\texpect(owners).toBe(1);\n\t});\n\n\tit(\"requires an explicit retry to recover after links were durably cleared\", async () => {\n\t\tlet context = await setup();\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Recover a cleared retry\",\n\t\t\trequestId: requestId(35),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tlet oldJobId = await failInitialEvidence(context);\n\t\tawait context.storage.research.resetInitialAttempt({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: started.request.id,\n\t\t\texpectedEvidenceJobId: oldJobId,\n\t\t\texpectedAnswerJobId: undefined,\n\t\t\tnow: context.advance(),\n\t\t\tlease: context.lease,\n\t\t});\n\t\tlet beforeRead = await context.storage.jobs.list(context.channelId, 100);\n\n\t\tlet observed = await context.restart().request(context.channelId, started.request.id);\n\n\t\texpect(observed).toMatchObject({\n\t\t\tstate: \"failed\",\n\t\t\tstage: \"failed\",\n\t\t\terror: \"Research could not be completed.\",\n\t\t\tquestion: started.request.question,\n\t\t});\n\t\texpect((await context.storage.jobs.list(context.channelId, 100))!.jobs)\n\t\t\t.toHaveLength(beforeRead!.jobs.length);\n\t\tawait context.restart().retryRequest({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: started.request.id,\n\t\t});\n\t\tlet recovered = await context.storage.research.get(context.channelId, started.request.id);\n\t\texpect(recovered!.turns[0]!.evidenceJobId).toBeDefined();\n\t\texpect(recovered!.turns[0]!.evidenceJobId).not.toBe(oldJobId);\n\t});\n\n\tit(\"publishes a deterministic available child title when the report title already exists\", async () => {\n\t\tlet context = await setup();\n\t\tawait context.storage.channels.create({\n\t\t\tid: crypto.randomUUID(),\n\t\t\trepositoryId: REPOSITORY_ID,\n\t\t\trepositoryOwner: \"octo-org\",\n\t\t\trepositoryName: \"score\",\n\t\t\ttitle: REPORT.title,\n\t\t\tcreatedBy: context.userId,\n\t\t\tnow: context.advance(),\n\t\t});\n\t\tlet started = await context.service.start({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\trequestedBy: context.userId,\n\t\t});\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tawait reconciledRequest(context.service, context.channelId, started.request.id);\n\t\tlet answer = await settle(context, \"research-answer\", answerArtifact);\n\t\tawait context.service.jobChanged(answer.job);\n\n\t\tlet ready = await context.service.request(context.channelId, started.request.id);\n\t\texpect(ready?.child?.title).toBe(`${REPORT.title} (2)`);\n\t});\n\n\tit(\"bounds long evidence history while retaining the initial and newest batches\", () => {\n\t\tlet evidence = Array.from({ length: 10 }, (_, batch) => ({\n\t\t\tfindings: Array.from({ length: 10 }, (_, item) => `finding-${batch}-${item}`),\n\t\t\tsources: Array.from({ length: 10 }, (_, item) => ({\n\t\t\t\ttitle: `source-${batch}-${item}`,\n\t\t\t\turl: `https://source-${batch}-${item}.example/item`,\n\t\t\t})),\n\t\t}));\n\t\tlet bounded = boundedResearchEvidence(evidence);\n\t\texpect(bounded.reduce((total, batch) => total + batch.findings.length, 0)).toBe(64);\n\t\texpect(bounded.reduce((total, batch) => total + batch.sources.length, 0)).toBe(64);\n\t\texpect(bounded[0]).toEqual(evidence[0]);\n\t\texpect(bounded[1]).toEqual(evidence[9]);\n\t});\n\n\tit(\"creates bounded idempotent drafts without scheduling model work\", async () => {\n\t\tlet context = await setup();\n\t\tlet input = {\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: ` ${\"Question \".repeat(30)} `,\n\t\t\trequestId: requestId(1),\n\t\t\torigin: \"sidebar\" as const,\n\t\t\tcreatedBy: context.userId,\n\t\t};\n\t\tlet first = await context.service.createDraft(input);\n\t\tlet repeated = await context.service.createDraft(input);\n\t\texpect(first.repeated).toBe(false);\n\t\texpect(repeated).toEqual({ ...first, repeated: true });\n\t\texpect(first.workspace.title.length).toBeLessThanOrEqual(120);\n\t\texpect(first.workspace.createdBy).toBe(USER_ID);\n\n\t\tawait expect(context.service.createDraft({ ...input, question: \"A different question\" }))\n\t\t\t.rejects.toBeInstanceOf(StorageError);\n\t\tlet planner = await context.service.createDraft({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Review public release evidence\",\n\t\t\torigin: \"planner\",\n\t\t\toriginMessageId: \"01K39QZG000000000000000001\",\n\t\t\tcreatedBy: context.userId,\n\t\t});\n\t\tlet repeatedPlanner = await context.service.createDraft({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Review public release evidence\",\n\t\t\torigin: \"planner\",\n\t\t\toriginMessageId: \"01K39QZG000000000000000001\",\n\t\t\tcreatedBy: context.userId,\n\t\t\trequestId: requestId(9),\n\t\t});\n\t\texpect(repeatedPlanner).toEqual({ ...planner, repeated: true });\n\t\texpect(planner.workspace).toMatchObject({\n\t\t\torigin: \"planner\",\n\t\t\toriginMessageId: \"01K39QZG000000000000000001\",\n\t\t\tcreatedBy: USER_ID,\n\t\t});\n\t\tawait expect(context.service.createDraft({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Invalid internal message identity\",\n\t\t\torigin: \"planner\",\n\t\t\toriginMessageId: \"message=\",\n\t\t\tcreatedBy: context.userId,\n\t\t})).rejects.toMatchObject({ code: \"invalid-request\" });\n\t\texpect((await context.jobs.list(context.channelId, 100))!.jobs).toEqual([]);\n\t\texpect(context.publications).toHaveLength(2);\n\t\tlet stored = await context.storage.research.get(context.channelId, first.workspace.id);\n\t\texpect(stored?.turns).toEqual([]);\n\t});\n\n\tit(\"refuses child research drafts before durable work\", async () => {\n\t\tlet context = await setup();\n\t\tlet child = await context.storage.channels.create({\n\t\t\tid: crypto.randomUUID(),\n\t\t\trepositoryId: REPOSITORY_ID,\n\t\t\trepositoryOwner: \"octo-org\",\n\t\t\trepositoryName: \"score\",\n\t\t\tparentChannelId: context.channelId,\n\t\t\ttitle: \"Published research child\",\n\t\t\tcreatedBy: context.userId,\n\t\t\tnow: context.advance(),\n\t\t});\n\n\t\tawait expect(context.service.createDraft({\n\t\t\tchannelId: child.id,\n\t\t\tquestion: \"Create a grandchild\",\n\t\t\trequestId: requestId(1),\n\t\t\torigin: \"sidebar\",\n\t\t\tcreatedBy: context.userId,\n\t\t})).rejects.toMatchObject({ code: \"invalid-request\" });\n\t\texpect(await context.storage.research.list(child.id, 100)).toEqual([]);\n\t});\n\n\tit(\"refuses confirming legacy child research before owner setup or jobs\", async () => {\n\t\tlet context = await setup();\n\t\tlet child = await context.storage.channels.create({\n\t\t\tid: crypto.randomUUID(),\n\t\t\trepositoryId: REPOSITORY_ID,\n\t\t\trepositoryOwner: \"octo-org\",\n\t\t\trepositoryName: \"score\",\n\t\t\tparentChannelId: context.channelId,\n\t\t\ttitle: \"Published research child\",\n\t\t\tcreatedBy: context.userId,\n\t\t\tnow: context.advance(),\n\t\t});\n\t\tlet legacy = await context.storage.research.create({\n\t\t\tid: crypto.randomUUID(),\n\t\t\tchannelId: child.id,\n\t\t\ttitle: \"Legacy child research\",\n\t\t\tproposedQuestion: \"Create a grandchild\",\n\t\t\torigin: \"sidebar\",\n\t\t\tcreatedBy: context.userId,\n\t\t\tidempotencyKey: \"legacy-child-draft\",\n\t\t\tfingerprint: \"legacy-child-draft\",\n\t\t\tnow: context.advance(),\n\t\t\tlease: context.lease,\n\t\t});\n\t\tlet owners = 0;\n\n\t\tawait expect(context.service.confirm({\n\t\t\tchannelId: child.id,\n\t\t\tworkspaceId: legacy.workspace.id,\n\t\t\tquery: \"Create a grandchild\",\n\t\t\trequestId: requestId(2),\n\t\t\tconfirmedBy: context.userId,\n\t\t\tbeforeStart: () => {\n\t\t\t\towners++;\n\t\t\t},\n\t\t})).rejects.toMatchObject({ code: \"invalid-request\" });\n\t\texpect(owners).toBe(0);\n\t\texpect(await context.storage.research.get(child.id, legacy.workspace.id))\n\t\t\t.toMatchObject({ workspace: { confirmedQuery: undefined }, turns: [] });\n\t\texpect((await context.jobs.list(child.id, 100))!.jobs).toEqual([]);\n\t});\n\n\tit(\"rejects unavailable execution before confirmation and claims an owner only for new work\", async () => {\n\t\tlet unavailable = await setup({ evidence: false });\n\t\tlet draft = await unavailable.service.createDraft({\n\t\t\tchannelId: unavailable.channelId,\n\t\t\tquestion: \"What changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\torigin: \"sidebar\",\n\t\t\tcreatedBy: unavailable.userId,\n\t\t});\n\t\tlet started = 0;\n\t\tawait expect(unavailable.service.confirm({\n\t\t\tchannelId: unavailable.channelId,\n\t\t\tworkspaceId: draft.workspace.id,\n\t\t\tquery: \"What changed?\",\n\t\t\trequestId: requestId(2),\n\t\t\tconfirmedBy: unavailable.userId,\n\t\t\tbeforeStart: () => {\n\t\t\t\tstarted++;\n\t\t\t},\n\t\t})).rejects.toMatchObject({ code: \"not-ready\" });\n\t\texpect(started).toBe(0);\n\t\texpect(await unavailable.storage.research.get(unavailable.channelId, draft.workspace.id))\n\t\t\t.toMatchObject({ workspace: { confirmedQuery: undefined }, turns: [], messages: [] });\n\n\t\tlet context = await setup();\n\t\tlet created = await context.service.createDraft({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"What changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\torigin: \"sidebar\",\n\t\t\tcreatedBy: context.userId,\n\t\t});\n\t\tlet confirmation = {\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tquery: \"What changed?\",\n\t\t\trequestId: requestId(2),\n\t\t\tconfirmedBy: context.userId,\n\t\t\tbeforeStart: () => {\n\t\t\t\tstarted++;\n\t\t\t},\n\t\t};\n\t\tawait context.service.confirm(confirmation);\n\t\tawait context.service.confirm({\n\t\t\t...confirmation,\n\t\t\tbeforeStart: () => {\n\t\t\t\tthrow new Error(\"a durable replay must not reacquire an owner\");\n\t\t\t},\n\t\t});\n\t\texpect(started).toBe(1);\n\t});\n\n\tit(\"reconciles completed evidence and never exposes durable request fingerprints\", async () => {\n\t\tlet context = await setup();\n\t\tlet { created } = await createAndConfirm(context);\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\n\t\tlet recovered = await reconciledWorkspace(\n\t\t\tcontext.service,\n\t\t\tcontext.channelId,\n\t\t\tcreated.workspace.id,\n\t\t);\n\t\texpect(recovered?.turns[0]).toMatchObject({\n\t\t\tkind: \"initial\",\n\t\t\tevidence: { job: { state: \"completed\" } },\n\t\t\tanswer: { job: { state: \"pending\", type: \"research-answer\" } },\n\t\t});\n\t\tlet source = JSON.stringify(recovered);\n\t\texpect(source).not.toContain(\"idempotencyKey\");\n\t\texpect(source).not.toContain(\"fingerprint\");\n\t\texpect(source).not.toContain(\"requestId\");\n\n\t\tlet stored = await context.storage.research.get(context.channelId, created.workspace.id);\n\t\texpect(stored?.turns[0]?.answerJobId).toBeDefined();\n\t});\n\n\tit(\"cancels the active job linked to a turn\", async () => {\n\t\tlet context = await setup();\n\t\tlet { created, confirmed } = await createAndConfirm(context);\n\t\tlet cancelled = await context.service.cancelTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tturnId: confirmed.turns[0]!.id,\n\t\t});\n\t\texpect(cancelled.turns[0]?.evidence?.job.state).toBe(\"cancelled\");\n\t\tlet repeated = await context.service.cancelTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tturnId: confirmed.turns[0]!.id,\n\t\t});\n\t\texpect(repeated.turns[0]?.evidence?.job.state).toBe(\"cancelled\");\n\t});\n\n\tit(\"preserves opaque GitHub actor and repository node ids\", async () => {\n\t\tlet context = await setup();\n\t\tlet { created } = await finishInitial(context);\n\t\tlet followUp = await context.service.appendTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tkind: \"follow-up\",\n\t\t\tquestion: \"Which actor requested this?\",\n\t\t\trequestId: requestId(8),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t});\n\t\tlet requested = followUp.turns.at(-1)!;\n\t\tlet member = followUp.messages.find(value => value.turnId === requested.id);\n\t\texpect(followUp.workspace).toMatchObject({\n\t\t\tcreatedBy: USER_ID,\n\t\t\tconfirmedBy: USER_ID,\n\t\t});\n\t\texpect(requested.requestedBy).toBe(USER_ID);\n\t\texpect(member?.userId).toBe(USER_ID);\n\t\texpect(await context.service.listRepository(REPOSITORY_ID)).toMatchObject({\n\t\t\tchannels: [{\n\t\t\t\tchannel: { id: context.channelId },\n\t\t\t\tworkspaces: [{ id: created.workspace.id }],\n\t\t\t}],\n\t\t});\n\t});\n\n\tit(\"uses one repository store operation without scanning or listing each channel\", async () => {\n\t\tlet context = await setup();\n\t\tlet created = await context.service.createDraft({\n\t\t\tchannelId: context.channelId,\n\t\t\tquestion: \"Which API contracts changed?\",\n\t\t\trequestId: requestId(1),\n\t\t\torigin: \"sidebar\",\n\t\t\tcreatedBy: context.userId,\n\t\t});\n\t\tlet listRepository = context.storage.research.listRepository;\n\t\tlet calls: Array<{ repositoryId: string; limit: number }> = [];\n\t\tcontext.storage.research.listRepository = async (repositoryId, limit) => {\n\t\t\tcalls.push({ repositoryId, limit });\n\t\t\tlet listed = await listRepository(repositoryId, limit);\n\t\t\treturn { ...listed, truncated: true };\n\t\t};\n\t\tcontext.storage.research.list = async () => {\n\t\t\tthrow new Error(\"repository listing must not list one channel at a time\");\n\t\t};\n\t\tcontext.storage.channels.scan = async () => {\n\t\t\tthrow new Error(\"repository listing must not scan channels in the service\");\n\t\t};\n\n\t\tlet listed = await context.service.listRepository(REPOSITORY_ID);\n\t\texpect(calls).toEqual([{ repositoryId: REPOSITORY_ID, limit: 500 }]);\n\t\texpect(listed).toMatchObject({\n\t\t\tchannels: [{\n\t\t\t\tchannel: { id: context.channelId },\n\t\t\t\tworkspaces: [{ id: created.workspace.id }],\n\t\t\t}],\n\t\t\ttruncated: true,\n\t\t});\n\t\texpect(listed.channels[0]!.workspaces[0]!.createdAt).toBe(\"2026-08-23T12:00:00.000Z\");\n\t});\n\n\tit(\"keeps follow-ups private, searches only explicit turns, and freezes the original report\", async () => {\n\t\tlet context = await setup();\n\t\tlet { created } = await finishInitial(context);\n\t\tlet followUp = await context.service.appendTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tkind: \"follow-up\",\n\t\t\tquestion: \" Was the old client tested? \",\n\t\t\trequestId: requestId(3),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t});\n\t\tlet followUpTurn = followUp.turns.at(-1)!;\n\t\texpect(followUpTurn.evidenceJobId).toBeUndefined();\n\t\texpect(followUpTurn.answer?.job.type).toBe(\"research-answer\");\n\t\tlet followUpJob = await context.storage.jobs.get(\n\t\t\tcontext.channelId,\n\t\t\tfollowUpTurn.answerJobId!,\n\t\t);\n\t\tlet followUpInput = parseResearchAnswerInput(followUpJob!.job.input);\n\t\texpect(followUpInput.kind).toBe(\"follow-up\");\n\t\tif (followUpInput.kind === \"initial\") throw new Error(\"expected continuation\");\n\t\texpect(followUpInput.originalReport).toEqual(REPORT);\n\n\t\tawait expect(context.service.appendTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tkind: \"search-more\",\n\t\t\tquestion: \"Search while the answer is active\",\n\t\t\trequestId: requestId(4),\n\t\t\trequestedBy: context.userId,\n\t\t})).rejects.toMatchObject({ code: \"active-turn\" });\n\n\t\tlet completedFollowUp = await settle(\n\t\t\tcontext,\n\t\t\t\"research-answer\",\n\t\t\tjob => answerArtifact(job, \"The old client was tested.\"),\n\t\t);\n\t\tawait context.service.jobChanged(completedFollowUp.job);\n\t\tlet search = await context.service.appendTurn({\n\t\t\tchannelId: context.channelId,\n\t\t\tworkspaceId: created.workspace.id,\n\t\t\tkind: \"search-more\",\n\t\t\tquestion: \" Find newer compatibility evidence. \",\n\t\t\trequestId: requestId(5),\n\t\t\trequestedBy: context.userId,\n\t\t\trequestedByHandle: \"octocat\",\n\t\t});\n\t\tlet searchTurn = search.turns.at(-1)!;\n\t\texpect(searchTurn.evidence?.job.type).toBe(\"research-evidence\");\n\t\texpect(searchTurn.answerJobId).toBeUndefined();\n\t\tlet evidenceJob = await context.storage.jobs.get(\n\t\t\tcontext.channelId,\n\t\t\tsearchTurn.evidenceJobId!,\n\t\t);\n\t\texpect(parseResearchEvidenceInput(evidenceJob!.job.input).query)\n\t\t\t.toBe(\"Find newer compatibility evidence.\");\n\n\t\tawait settle(context, \"research-evidence\", evidenceArtifact);\n\t\tlet reconciled = await reconciledWorkspace(\n\t\t\tcontext.service,\n\t\t\tcontext.channelId,\n\t\t\tcreated.workspace.id,\n\t\t);\n\t\tlet answerJobId = reconciled!.turns.at(-1)!.answerJobId!;\n\t\tlet storedAnswer = await context.storage.jobs.get(context.channelId, answerJobId);\n\t\tlet searchInput = parseResearchAnswerInput(storedAnswer!.job.input);\n\t\texpect(searchInput.kind).toBe(\"search-more\");\n\t\tif (searchInput.kind === \"initial\") throw new Error(\"expected continuation\");\n\t\texpect(searchInput.originalReport).toEqual(REPORT);\n\t\texpect(searchInput.evidence).toHaveLength(2);\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",1794626630034,"sidebar","expanded"]