[{"_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","086f0f3cc5af34c5e229de2e1908b87d9ff2a4c2","path","apps/server/src/storage/contract.ts","oid","fbaebb2f09993b386e63f6cc47f6996e1de02da5","size",81573,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { describe, expect, it } from \"bun:test\";\n\nimport { StorageError } from \"./errors\";\nimport { BACKGROUND_JOB_PROGRESS_LIMIT } from \"./model\";\n\nimport type { CreateResearchWorkspace, EnqueueBackgroundJob, JsonValue, Lease } from \"./model\";\nimport type { StorageAdapter } from \"./port\";\n\ntype Factory = () => StorageAdapter | Promise;\n\nfunction id(label: string): string {\n\treturn `${label}-${crypto.randomUUID()}`;\n}\n\nasync function opened(factory: Factory): Promise {\n\tlet storage = await factory();\n\tawait storage.migrate();\n\treturn storage;\n}\n\nfunction attempt(action: () => Promise): Promise {\n\treturn Promise.resolve().then(action);\n}\n\nasync function userAndChannel(storage: StorageAdapter): Promise<{\n\tuserId: string;\n\tsessionId: string;\n\tchannelId: string;\n\trepositoryId: string;\n\tlease: Lease;\n}> {\n\tlet now = new Date(\"2026-01-02T03:04:05.000Z\");\n\tlet userId = id(\"user\");\n\tlet sessionId = id(\"session\");\n\tlet channelId = id(\"channel\");\n\tlet repositoryId = id(\"repository\");\n\tawait storage.users.put({\n\t\tid: userId,\n\t\tlogin: \"octocat\",\n\t\tavatarUrl: \"https://example.test/a\",\n\t\tnow,\n\t});\n\tawait storage.sessions.create({\n\t\tid: sessionId,\n\t\tuserId,\n\t\texpiresAt: new Date(\"2026-02-02T03:04:05.000Z\"),\n\t\tcreatedAt: now,\n\t});\n\tawait storage.channels.create({\n\t\tid: channelId,\n\t\trepositoryId,\n\t\trepositoryOwner: \"octo-org\",\n\t\trepositoryName: \"score\",\n\t\ttitle: \"Release plan\",\n\t\tcreatedBy: userId,\n\t\tnow,\n\t});\n\tlet lease = await storage.leases.acquire(\n\t\tid(\"channel-writer\"),\n\t\tid(\"instance\"),\n\t\t60_000,\n\t);\n\tif (!lease) throw new Error(\"test could not acquire its storage lease\");\n\treturn { userId, sessionId, channelId, repositoryId, lease };\n}\n\nfunction backgroundJob(\n\tchannelId: string,\n\tlease: Lease,\n\toverrides: Partial = {},\n): EnqueueBackgroundJob {\n\tlet now = overrides.now ?? new Date();\n\treturn {\n\t\tid: id(\"job\"),\n\t\tchannelId,\n\t\ttype: \"document-summary\",\n\t\tversion: 1,\n\t\torigin: \"scheduler\",\n\t\ttargetKey: \"document-summary\",\n\t\tidempotencyKey: id(\"enqueue\"),\n\t\tfingerprint: id(\"fingerprint\"),\n\t\tinput: { revision: 1 },\n\t\tavailableAt: now,\n\t\tnow,\n\t\tlease,\n\t\t...overrides,\n\t};\n}\n\nfunction researchWorkspace(\n\tchannelId: string,\n\tcreatedBy: string,\n\tlease: Lease,\n\toverrides: Partial = {},\n): CreateResearchWorkspace {\n\treturn {\n\t\tid: id(\"research-workspace\"),\n\t\tchannelId,\n\t\ttitle: \"API compatibility research\",\n\t\tproposedQuestion: \"Which API contracts changed?\",\n\t\torigin: \"sidebar\",\n\t\tcreatedBy,\n\t\tidempotencyKey: id(\"create-research\"),\n\t\tfingerprint: id(\"research-fingerprint\"),\n\t\tnow: new Date(\"2026-01-07T03:04:05.000Z\"),\n\t\tlease,\n\t\t...overrides,\n\t};\n}\n\n/** The behavioral gate every built-in storage adapter must pass. */\nexport function storageContract(name: string, factory: Factory): void {\n\tdescribe(`${name} storage`, () => {\n\t\tit(\"keeps only process-lifetime registry metadata for a login session\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet now = new Date(\"2026-01-02T03:04:05.000Z\");\n\t\t\t\tlet userId = id(\"user\");\n\t\t\t\tlet sessionId = id(\"session\");\n\t\t\t\tawait storage.users.put({\n\t\t\t\t\tid: userId,\n\t\t\t\t\tlogin: \"mona\",\n\t\t\t\t\tavatarUrl: \"https://example.test/mona\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tawait storage.sessions.create({\n\t\t\t\t\tid: sessionId,\n\t\t\t\t\tuserId,\n\t\t\t\t\texpiresAt: new Date(\"2026-01-02T04:04:05.000Z\"),\n\t\t\t\t\tcreatedAt: now,\n\t\t\t\t});\n\n\t\t\t\tlet active = await storage.sessions.get(\n\t\t\t\t\tsessionId,\n\t\t\t\t\tnew Date(\"2026-01-02T03:30:00.000Z\"),\n\t\t\t\t);\n\t\t\t\texpect(active).toMatchObject({ id: sessionId, userId });\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.sessions.get(sessionId, new Date(\"2026-01-02T04:04:05.000Z\")),\n\t\t\t\t).toBeUndefined();\n\t\t\t\texpect(await storage.sessions.deleteExpired(new Date(\"2026-01-02T05:00:00.000Z\")))\n\t\t\t\t\t.toBe(1);\n\t\t\t\texpect(await storage.sessions.get(sessionId, now)).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"deletes all session registries while preserving durable agent context\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { sessionId, channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tlet claimed = await storage.channels.claimAgentOwner(channelId, sessionId, now);\n\t\t\t\tawait storage.channels.updateAgentContext({\n\t\t\t\t\tchannelId,\n\t\t\t\t\townerSessionId: sessionId,\n\t\t\t\t\tgeneration: claimed.generation,\n\t\t\t\t\tsummary: \"durable summary\",\n\t\t\t\t\ttranscriptCursor: 7,\n\t\t\t\t\tstatus: \"ready\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet reset = await storage.sessions.deleteAll(now, lease, 60_000);\n\t\t\t\texpect(reset.deleted).toBeGreaterThan(0);\n\t\t\t\texpect(reset.lease.fencing).toBe(lease.fencing);\n\t\t\t\texpect(await storage.sessions.get(sessionId, now)).toBeUndefined();\n\t\t\t\tlet saved = await storage.collaboration.load(channelId, now);\n\t\t\t\texpect(saved!.agent).toMatchObject({\n\t\t\t\t\tgeneration: claimed.generation,\n\t\t\t\t\tsummary: \"durable summary\",\n\t\t\t\t\ttranscriptCursor: 7,\n\t\t\t\t\tstatus: \"unavailable\",\n\t\t\t\t});\n\t\t\t\texpect(saved!.agent!.ownerSessionId).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"reports whether adding a project changed navigation and keeps its original order\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet now = new Date(\"2026-01-02T03:04:05.000Z\");\n\t\t\t\tlet userId = id(\"user\");\n\t\t\t\tawait storage.users.put({\n\t\t\t\t\tid: userId,\n\t\t\t\t\tlogin: \"mona\",\n\t\t\t\t\tavatarUrl: \"https://example.test/mona\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet first = await storage.navigation.addProject({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId: \"R_first\",\n\t\t\t\t\trepositoryOwner: \"githubnext\",\n\t\t\t\t\trepositoryName: \"chopin\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tlet second = await storage.navigation.addProject({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId: \"R_second\",\n\t\t\t\t\trepositoryOwner: \"githubnext\",\n\t\t\t\t\trepositoryName: \"second\",\n\t\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\t});\n\t\t\t\tlet repeated = await storage.navigation.addProject({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId: \"R_first\",\n\t\t\t\t\trepositoryOwner: \"githubnext\",\n\t\t\t\t\trepositoryName: \"chopin\",\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t});\n\n\t\t\t\texpect(first.added).toBe(true);\n\t\t\t\texpect(second.added).toBe(true);\n\t\t\t\texpect(repeated).toEqual({ project: first.project, added: false });\n\t\t\t\texpect((await storage.navigation.projects(userId)).map(project => project.repositoryId))\n\t\t\t\t\t.toEqual([\"R_first\", \"R_second\"]);\n\t\t\t\texpect(await storage.navigation.snapshot(userId)).toMatchObject({\n\t\t\t\t\tprojects: [{ repositoryId: \"R_first\" }, { repositoryId: \"R_second\" }],\n\t\t\t\t\tnavigation: undefined,\n\t\t\t\t\tlastDocumentRepositoryId: undefined,\n\t\t\t\t});\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"stores the last document with a monotonic navigation revision\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet now = new Date(\"2026-01-02T03:04:05.000Z\");\n\t\t\t\tlet { userId, channelId } = await userAndChannel(storage);\n\t\t\t\tlet first = await storage.navigation.setLastDocument(userId, channelId, now);\n\t\t\t\tlet repeated = await storage.navigation.setLastDocument(userId, channelId, now);\n\n\t\t\t\texpect(first.revision).toBe(0);\n\t\t\t\texpect(repeated).toEqual({ ...first, revision: 1 });\n\t\t\t\texpect(await storage.navigation.get(userId)).toEqual(repeated);\n\t\t\t\texpect(await storage.navigation.snapshot(userId)).toMatchObject({\n\t\t\t\t\tnavigation: repeated,\n\t\t\t\t\tlastDocumentRepositoryId: expect.any(String),\n\t\t\t\t});\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.navigation.setLastDocumentIfCurrent(\n\t\t\t\t\t\tuserId,\n\t\t\t\t\t\trepeated.revision + 1,\n\t\t\t\t\t\tundefined,\n\t\t\t\t\t\tnew Date(now.getTime() + 1),\n\t\t\t\t\t),\n\t\t\t\t).toEqual({ navigation: repeated, updated: false });\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.navigation.setLastDocumentIfCurrent(\n\t\t\t\t\t\tuserId,\n\t\t\t\t\t\trepeated.revision,\n\t\t\t\t\t\tundefined,\n\t\t\t\t\t\tnew Date(now.getTime() + 2),\n\t\t\t\t\t),\n\t\t\t\t).toMatchObject({ navigation: { lastDocumentId: undefined }, updated: true });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"rejects a last document that does not exist\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId } = await userAndChannel(storage);\n\t\t\t\tawait expect(storage.navigation.setLastDocument(\n\t\t\t\t\tuserId,\n\t\t\t\t\tid(\"missing-channel\"),\n\t\t\t\t\tnew Date(\"2026-01-02T03:04:05.000Z\"),\n\t\t\t\t)).rejects.toMatchObject({ failure: \"missing\" });\n\t\t\t\texpect(await storage.navigation.get(userId)).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"records a deep-link visit without adding a project when its document is missing\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId } = await userAndChannel(storage);\n\t\t\t\tawait expect(storage.navigation.recordVisit({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId: \"R_missing\",\n\t\t\t\t\trepositoryOwner: \"githubnext\",\n\t\t\t\t\trepositoryName: \"missing\",\n\t\t\t\t\tdocumentId: id(\"missing-channel\"),\n\t\t\t\t\tnow: new Date(\"2026-01-02T03:04:05.000Z\"),\n\t\t\t\t})).rejects.toMatchObject({ failure: \"missing\" });\n\t\t\t\texpect(await storage.navigation.projects(userId)).toEqual([]);\n\t\t\t\texpect(await storage.navigation.get(userId)).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"rejects a deep-link visit whose document belongs to another repository\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId } = await userAndChannel(storage);\n\t\t\t\tawait expect(storage.navigation.recordVisit({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId: id(\"other-repository\"),\n\t\t\t\t\trepositoryOwner: \"githubnext\",\n\t\t\t\t\trepositoryName: \"other\",\n\t\t\t\t\tdocumentId: channelId,\n\t\t\t\t\tnow: new Date(\"2026-01-02T03:04:05.000Z\"),\n\t\t\t\t})).rejects.toMatchObject({ failure: \"missing\" });\n\t\t\t\texpect(await storage.navigation.projects(userId)).toEqual([]);\n\t\t\t\texpect(await storage.navigation.get(userId)).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"adds a project and records a deep-link visit together\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet saved = await storage.navigation.recordVisit({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\tdocumentId: channelId,\n\t\t\t\t\tnow: new Date(\"2026-01-02T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(saved.lastDocumentId).toBe(channelId);\n\t\t\t\texpect(await storage.navigation.projects(userId)).toMatchObject([{ repositoryId }]);\n\t\t\t\texpect(await storage.navigation.firstDocument(userId, [repositoryId])).toBe(channelId);\n\t\t\t\texpect(await storage.navigation.firstDocument(userId, [\"R_unavailable\"]))\n\t\t\t\t\t.toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"lists only a repository's channels in stable order\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet other = id(\"repository\");\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: id(\"other-channel\"),\n\t\t\t\t\trepositoryId: other,\n\t\t\t\t\trepositoryOwner: \"elsewhere\",\n\t\t\t\t\trepositoryName: \"private\",\n\t\t\t\t\ttitle: \"Not this repository\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-03T03:04:05.000Z\"),\n\t\t\t\t});\n\n\t\t\t\tlet page = await storage.channels.list(repositoryId, 20);\n\t\t\t\texpect(page.channels).toHaveLength(1);\n\t\t\t\texpect(page.channels[0]!.repositoryId).toBe(repositoryId);\n\t\t\t\texpect(page.next).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"archives and restores channels without hiding direct reads\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet original = (await storage.channels.get(channelId))!;\n\t\t\t\tlet fallback = await storage.channels.create({\n\t\t\t\t\tid: id(\"fallback-channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Fallback plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-01T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tawait storage.navigation.recordVisit({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\tdocumentId: channelId,\n\t\t\t\t\tnow: original.updatedAt,\n\t\t\t\t});\n\n\t\t\t\tlet archived = await storage.channels.archive({ id: channelId, now: original.updatedAt });\n\t\t\t\texpect(archived).toMatchObject({\n\t\t\t\t\tchanged: true,\n\t\t\t\t\tchannel: {\n\t\t\t\t\t\tid: channelId,\n\t\t\t\t\t\ttitle: original.title,\n\t\t\t\t\t\tslug: original.slug,\n\t\t\t\t\t\trevision: original.revision,\n\t\t\t\t\t},\n\t\t\t\t});\n\t\t\t\texpect(archived.channel.updatedAt.getTime()).toBeGreaterThan(original.updatedAt.getTime());\n\t\t\t\texpect(archived.channel.archivedAt).toEqual(archived.channel.updatedAt);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.channels.archive({\n\t\t\t\t\t\tid: channelId,\n\t\t\t\t\t\tnow: new Date(\"2026-01-05T03:04:05.000Z\"),\n\t\t\t\t\t}),\n\t\t\t\t).toEqual({ channel: archived.channel, changed: false });\n\n\t\t\t\texpect((await storage.channels.list(repositoryId, 1)).channels.map(value => value.id))\n\t\t\t\t\t.toEqual([fallback.id]);\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.channels.list(repositoryId, 1, undefined, undefined, true)).channels\n\t\t\t\t\t\t.map(value => value.id),\n\t\t\t\t).toEqual([channelId]);\n\t\t\t\texpect((await storage.channels.scan(repositoryId, 1)).channels.map(value => value.id))\n\t\t\t\t\t.toEqual([fallback.id]);\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.channels.scan(repositoryId, 1, undefined, true)).channels\n\t\t\t\t\t\t.map(value => value.id),\n\t\t\t\t).toEqual([channelId]);\n\t\t\t\texpect((await storage.channels.get(channelId))?.archivedAt)\n\t\t\t\t\t.toEqual(archived.channel.archivedAt);\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, original.slug))?.id).toBe(channelId);\n\t\t\t\tawait expect(storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: original.title,\n\t\t\t\t\tnow: new Date(\"2026-01-06T03:04:05.000Z\"),\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(storage.navigation.setLastDocument(\n\t\t\t\t\tuserId,\n\t\t\t\t\tchannelId,\n\t\t\t\t\tnew Date(\"2026-01-06T03:04:05.000Z\"),\n\t\t\t\t)).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(storage.navigation.recordVisit({\n\t\t\t\t\tuserId,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\tdocumentId: channelId,\n\t\t\t\t\tnow: new Date(\"2026-01-06T03:04:05.000Z\"),\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet snapshot = await storage.navigation.snapshot(userId);\n\t\t\t\texpect(snapshot.navigation?.lastDocumentId).toBe(channelId);\n\t\t\t\texpect(snapshot.lastDocumentRepositoryId).toBeUndefined();\n\t\t\t\texpect(await storage.navigation.firstDocument(userId, [repositoryId])).toBe(fallback.id);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.navigation.setLastDocumentIfCurrent(\n\t\t\t\t\t\tuserId,\n\t\t\t\t\t\tsnapshot.navigation?.revision,\n\t\t\t\t\t\tfallback.id,\n\t\t\t\t\t\tnew Date(\"2026-01-06T03:04:05.000Z\"),\n\t\t\t\t\t),\n\t\t\t\t).toMatchObject({ navigation: { lastDocumentId: fallback.id }, updated: true });\n\n\t\t\t\tlet restored = await storage.channels.restore({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\tnow: archived.channel.updatedAt,\n\t\t\t\t});\n\t\t\t\texpect(restored.changed).toBe(true);\n\t\t\t\texpect(restored.channel.archivedAt).toBeUndefined();\n\t\t\t\texpect(restored.channel.revision).toBe(original.revision);\n\t\t\t\texpect(restored.channel.updatedAt.getTime())\n\t\t\t\t\t.toBeGreaterThan(archived.channel.updatedAt.getTime());\n\t\t\t\texpect((await storage.channels.list(repositoryId, 1)).channels[0]?.id).toBe(channelId);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.channels.restore({\n\t\t\t\t\t\tid: channelId,\n\t\t\t\t\t\tnow: new Date(\"2026-01-07T03:04:05.000Z\"),\n\t\t\t\t\t}),\n\t\t\t\t).toEqual({ channel: restored.channel, changed: false });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"deletes only archived channels and permits clean identity reuse\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, sessionId, channelId, repositoryId, lease } = await userAndChannel(storage);\n\t\t\t\tlet operationId = id(\"delete-operation\");\n\t\t\t\tlet workspaceInput = researchWorkspace(channelId, userId, lease, {\n\t\t\t\t\tid: id(\"delete-workspace\"),\n\t\t\t\t\tidempotencyKey: id(\"delete-workspace-request\"),\n\t\t\t\t\tfingerprint: \"sha256:delete-workspace\",\n\t\t\t\t});\n\t\t\t\tlet createdWorkspace = await storage.research.create(workspaceInput);\n\t\t\t\tlet confirmation = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: createdWorkspace.workspace.id,\n\t\t\t\t\tturnId: id(\"delete-turn\"),\n\t\t\t\t\tmessageId: id(\"delete-member-message\"),\n\t\t\t\t\trequestId: id(\"delete-confirmation\"),\n\t\t\t\t\tfingerprint: \"sha256:delete-confirmation\",\n\t\t\t\t\tconfirmedQuery: \"Which state must be deleted?\",\n\t\t\t\t\tconfirmedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:05:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tlet confirmed = await storage.research.confirm(confirmation);\n\t\t\t\tlet jobInput = backgroundJob(channelId, lease, {\n\t\t\t\t\tid: id(\"delete-job\"),\n\t\t\t\t\ttype: \"research-answer\",\n\t\t\t\t\ttargetKey:\n\t\t\t\t\t\t`research-answer:workspace:${workspaceInput.id}:turn:${confirmation.turnId}:answer`,\n\t\t\t\t\tidempotencyKey: id(\"delete-job-request\"),\n\t\t\t\t\tfingerprint: \"sha256:delete-job\",\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:05.000Z\"),\n\t\t\t\t\tavailableAt: new Date(\"2026-01-07T03:06:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tlet queued = await storage.jobs.enqueue(jobInput);\n\t\t\t\tlet [claimed] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"delete-worker\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 60_000,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:06.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tawait storage.jobs.settle({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.job.id,\n\t\t\t\t\tclaimOwner: \"delete-worker\",\n\t\t\t\t\tclaimGeneration: claimed!.claimGeneration,\n\t\t\t\t\tartifact: { answer: \"all channel-owned state\" },\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:07.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tawait storage.research.linkJob({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: workspaceInput.id,\n\t\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\t\trole: \"answer\",\n\t\t\t\t\tjobId: jobInput.id,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:08.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet agentMessage = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: workspaceInput.id,\n\t\t\t\t\tid: id(\"delete-agent-message\"),\n\t\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\t\ttext: \"Delete this transcript with its document.\",\n\t\t\t\t\tsourceJobId: jobInput.id,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:09.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tawait storage.research.appendAgentMessage(agentMessage);\n\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId,\n\t\t\t\t\tepoch: \"delete-epoch\",\n\t\t\t\t\tupdate: new Uint8Array([1, 2, 3]),\n\t\t\t\t\tsidecar: { deletion: \"seeded\" },\n\t\t\t\t\tevents: [{\n\t\t\t\t\t\tid: id(\"delete-event\"),\n\t\t\t\t\t\tkind: \"delete:test\",\n\t\t\t\t\t\tpayload: { seeded: true },\n\t\t\t\t\t\tcreatedAt: new Date(\"2026-01-07T03:07:05.000Z\"),\n\t\t\t\t\t}],\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:07:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tawait storage.collaboration.checkpoint({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\tgeneration: id(\"delete-generation\"),\n\t\t\t\t\trevision: 1,\n\t\t\t\t\tthroughSequence: 1,\n\t\t\t\t\tepoch: \"delete-epoch\",\n\t\t\t\t\tsource: \"# Delete me\\n\",\n\t\t\t\t\tsourceHash: \"sha256:delete-me\",\n\t\t\t\t\tdocument: new Uint8Array([4, 5, 6]),\n\t\t\t\t\tsidecar: { deletion: \"seeded\" },\n\t\t\t\t\tcreatedAt: new Date(\"2026-01-07T03:08:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tawait storage.channels.claimAgentOwner(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tsessionId,\n\t\t\t\t\tnew Date(\"2026-01-07T03:09:05.000Z\"),\n\t\t\t\t);\n\t\t\t\tawait storage.navigation.setLastDocument(\n\t\t\t\t\tuserId,\n\t\t\t\t\tchannelId,\n\t\t\t\t\tnew Date(\"2026-01-07T03:09:05.000Z\"),\n\t\t\t\t);\n\t\t\t\tlet renamed = await storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tnow: new Date(\"2026-01-08T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tawait expect(storage.channels.delete(channelId))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait storage.channels.archive({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\tnow: new Date(\"2026-01-09T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(await storage.channels.delete(channelId)).toBe(true);\n\t\t\t\texpect(await storage.channels.delete(channelId)).toBe(false);\n\n\t\t\t\texpect(await storage.channels.get(channelId)).toBeUndefined();\n\t\t\t\texpect(await storage.channels.resolve(repositoryId, \"release-plan\")).toBeUndefined();\n\t\t\t\texpect(await storage.channels.resolve(repositoryId, renamed.channel.slug)).toBeUndefined();\n\t\t\t\texpect(await storage.collaboration.load(channelId, new Date())).toBeUndefined();\n\t\t\t\texpect(await storage.channels.readAgent(channelId, new Date())).toBeUndefined();\n\t\t\t\texpect(await storage.jobs.list(channelId, 10)).toBeUndefined();\n\t\t\t\texpect(await storage.jobs.get(channelId, jobInput.id)).toBeUndefined();\n\t\t\t\texpect(await storage.research.list(channelId, 10)).toEqual([]);\n\t\t\t\texpect(await storage.research.get(channelId, workspaceInput.id)).toBeUndefined();\n\t\t\t\texpect((await storage.navigation.get(userId))?.lastDocumentId).toBeUndefined();\n\t\t\t\texpect((await storage.navigation.snapshot(userId)).lastDocumentRepositoryId)\n\t\t\t\t\t.toBeUndefined();\n\n\t\t\t\tlet recreated = await storage.channels.create({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Release plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(recreated).toMatchObject({ id: channelId, slug: \"release-plan\", revision: 0 });\n\t\t\t\texpect(recreated.archivedAt).toBeUndefined();\n\t\t\t\tlet aliasReuse = await storage.channels.create({\n\t\t\t\t\tid: id(\"alias-reuse-channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:04:06.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(aliasReuse.slug).toBe(\"launch-plan\");\n\t\t\t\tlet clean = (await storage.collaboration.load(channelId, new Date()))!;\n\t\t\t\texpect(clean).toMatchObject({\n\t\t\t\t\tlatestSequence: 0,\n\t\t\t\t\tsnapshot: undefined,\n\t\t\t\t\tupdates: [],\n\t\t\t\t\tevents: [],\n\t\t\t\t\tsidecar: null,\n\t\t\t\t\tagent: undefined,\n\t\t\t\t});\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease,\n\t\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\t\toperationId,\n\t\t\t\t\t\tepoch: \"recreated-epoch\",\n\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\tnow: new Date(\"2026-01-10T03:05:05.000Z\"),\n\t\t\t\t\t}),\n\t\t\t\t).toEqual({ revision: 1, sequence: 1, repeated: false });\n\n\t\t\t\tlet recreatedWorkspace = await storage.research.create({\n\t\t\t\t\t...workspaceInput,\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:06:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(recreatedWorkspace.repeated).toBe(false);\n\t\t\t\tlet recreatedConfirmation = await storage.research.confirm({\n\t\t\t\t\t...confirmation,\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:06:06.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(recreatedConfirmation.repeated).toBe(false);\n\t\t\t\tlet recreatedJob = await storage.jobs.enqueue({\n\t\t\t\t\t...jobInput,\n\t\t\t\t\tavailableAt: new Date(\"2026-01-10T03:06:07.000Z\"),\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:06:07.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(recreatedJob.repeated).toBe(false);\n\t\t\t\texpect((await storage.jobs.get(channelId, jobInput.id))?.artifact).toBeUndefined();\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.research.linkJob({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tworkspaceId: workspaceInput.id,\n\t\t\t\t\t\tturnId: confirmation.turnId,\n\t\t\t\t\t\trole: \"answer\",\n\t\t\t\t\t\tjobId: jobInput.id,\n\t\t\t\t\t\tnow: new Date(\"2026-01-10T03:06:08.000Z\"),\n\t\t\t\t\t\tlease,\n\t\t\t\t\t})).repeated,\n\t\t\t\t).toBe(false);\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.research.appendAgentMessage({\n\t\t\t\t\t\t...agentMessage,\n\t\t\t\t\t\tnow: new Date(\"2026-01-10T03:06:09.000Z\"),\n\t\t\t\t\t})).repeated,\n\t\t\t\t).toBe(false);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"renames channel metadata without advancing its collaboration revision\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet before = await storage.channels.get(channelId);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tlet renamed = await storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\n\t\t\t\texpect(renamed).toMatchObject({ changed: true, channel: { title: \"Launch plan\" } });\n\t\t\t\texpect(renamed.channel.updatedAt).toEqual(now);\n\t\t\t\texpect(renamed.channel.revision).toBe(before!.revision);\n\t\t\t\texpect((await storage.channels.list(repositoryId, 20, undefined, \"launch\")).channels)\n\t\t\t\t\t.toHaveLength(1);\n\t\t\t\texpect((await storage.channels.list(repositoryId, 20, undefined, \"release\")).channels)\n\t\t\t\t\t.toEqual([]);\n\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId: id(\"operation\"),\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tevents: [],\n\t\t\t\t\tnow: new Date(\"2026-01-02T12:00:00.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect((await storage.channels.get(channelId))!.updatedAt).toEqual(now);\n\n\t\t\t\tlet repeated = await storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(repeated.changed).toBe(false);\n\t\t\t\texpect(repeated.channel.updatedAt).toEqual(now);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"keeps renamed document titles unique within their repository\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tlet other = await storage.channels.create({\n\t\t\t\t\tid: id(\"channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow,\n\t\t\t\t});\n\n\t\t\t\texpect(storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"launch PLAN\",\n\t\t\t\t\tnow,\n\t\t\t\t})).rejects.toBeInstanceOf(StorageError);\n\t\t\t\tlet recased = await storage.channels.rename({\n\t\t\t\t\tid: other.id,\n\t\t\t\t\ttitle: \"LAUNCH PLAN\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\texpect(recased.channel.title).toBe(\"LAUNCH PLAN\");\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"keeps document titles unique within a repository without regard to case\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: id(\"channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Release notes\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\texpect(storage.channels.create({\n\t\t\t\t\tid: id(\"channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"release NOTES\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow,\n\t\t\t\t})).rejects.toBeInstanceOf(StorageError);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"resolves canonical and historical document slugs without rebinding aliases\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet original = await storage.channels.get(channelId);\n\t\t\t\texpect(original?.slug).toBe(\"release-plan\");\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, \"release-plan\"))?.id)\n\t\t\t\t\t.toBe(channelId);\n\n\t\t\t\tlet renamed = await storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Résumé 計画\",\n\t\t\t\t\tnow: new Date(\"2026-01-03T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(renamed.channel.slug).toBe(\"résumé-計画\");\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, \"release-plan\"))?.id)\n\t\t\t\t\t.toBe(channelId);\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, \"résumé-計画\"))?.id)\n\t\t\t\t\t.toBe(channelId);\n\n\t\t\t\tlet restored = await storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Release plan\",\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(restored.channel.slug).toBe(\"release-plan\");\n\t\t\t\tawait storage.channels.rename({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\ttitle: \"Launch plan\",\n\t\t\t\t\tnow: new Date(\"2026-01-05T03:04:05.000Z\"),\n\t\t\t\t});\n\n\t\t\t\tlet replacement = await storage.channels.create({\n\t\t\t\t\tid: id(\"replacement-channel\"),\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Release plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-06T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(replacement.slug).toBe(\"release-plan-2\");\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, \"release-plan\"))?.id)\n\t\t\t\t\t.toBe(channelId);\n\t\t\t\texpect((await storage.channels.resolve(repositoryId, \"release-plan-2\"))?.id)\n\t\t\t\t\t.toBe(replacement.id);\n\t\t\t\texpect(await storage.channels.resolve(repositoryId, \"missing\"))\n\t\t\t\t\t.toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"atomically disambiguates different titles with the same document slug\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tlet create = (channelId: string, title: string) =>\n\t\t\t\t\tstorage.channels.create({\n\t\t\t\t\t\tid: channelId,\n\t\t\t\t\t\trepositoryId,\n\t\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\t\ttitle,\n\t\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t});\n\t\t\t\tlet channels = await Promise.all([\n\t\t\t\t\tcreate(id(\"channel\"), \"Bright road\"),\n\t\t\t\t\tcreate(id(\"channel\"), \"Bright-road!\"),\n\t\t\t\t]);\n\t\t\t\texpect(channels.map(channel => channel.slug).sort()).toEqual([\n\t\t\t\t\t\"bright-road\",\n\t\t\t\t\t\"bright-road-2\",\n\t\t\t\t]);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"atomically reserves one title for concurrent creators\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tlet create = (id: string) =>\n\t\t\t\t\tstorage.channels.create({\n\t\t\t\t\t\tid,\n\t\t\t\t\t\trepositoryId,\n\t\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\t\ttitle: \"bright-road\",\n\t\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t});\n\t\t\t\tlet results = await Promise.allSettled([create(id(\"channel\")), create(id(\"channel\"))]);\n\t\t\t\texpect(results.filter(result => result.status === \"fulfilled\")).toHaveLength(1);\n\t\t\t\texpect(results.filter(result => result.status === \"rejected\")).toHaveLength(1);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"paginates a case-insensitive title search independently from the full list\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tfor (let title of [\"Draft map\", \"Draft release\", \"Roadmap\"]) {\n\t\t\t\t\tawait storage.channels.create({\n\t\t\t\t\t\tid: id(\"channel\"),\n\t\t\t\t\t\trepositoryId,\n\t\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\t\ttitle,\n\t\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\tlet first = await storage.channels.list(repositoryId, 1, undefined, \"DRAFT\");\n\t\t\t\texpect(first.channels.map(channel => channel.title)).toHaveLength(1);\n\t\t\t\texpect(first.channels[0]!.title).toMatch(/^Draft/);\n\t\t\t\tlet second = await storage.channels.list(repositoryId, 1, first.next, \"draft\");\n\t\t\t\texpect(second.channels.map(channel => channel.title)).toHaveLength(1);\n\t\t\t\texpect(second.channels[0]!.title).toMatch(/^Draft/);\n\t\t\t\texpect(second.next).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"treats title-search punctuation as literal text\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, repositoryId } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tfor (let title of [\"Budget 100%_\\\\plan\", \"Budget 100abcplan\"]) {\n\t\t\t\t\tawait storage.channels.create({\n\t\t\t\t\t\tid: id(\"channel\"),\n\t\t\t\t\t\trepositoryId,\n\t\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\t\ttitle,\n\t\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\tlet page = await storage.channels.list(repositoryId, 20, undefined, \"100%_\\\\plan\");\n\t\t\t\texpect(page.channels.map(channel => channel.title)).toEqual([\"Budget 100%_\\\\plan\"]);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"scans repository channels through updates without changing its creation cursor\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId, lease } = await userAndChannel(storage);\n\t\t\t\tlet second = id(\"channel\");\n\t\t\t\tlet third = id(\"channel\");\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: second,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Second plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-03T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: third,\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Third plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t});\n\n\t\t\t\tlet first = await storage.channels.scan(repositoryId, 2);\n\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId: id(\"operation\"),\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tevents: [],\n\t\t\t\t\tnow: new Date(\"2026-01-05T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tlet next = await storage.channels.scan(repositoryId, 2, first.next);\n\n\t\t\t\texpect(first.channels.map(channel => channel.id)).toEqual([third, second]);\n\t\t\t\texpect(next.channels.map(channel => channel.id)).toEqual([channelId]);\n\t\t\t\texpect(next.next).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"publishes an initialized channel and checkpoint atomically\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet now = new Date(\"2026-01-02T03:04:05.000Z\");\n\t\t\t\tlet userId = id(\"user\");\n\t\t\t\tlet channelId = id(\"channel\");\n\t\t\t\tlet sidecar = {\n\t\t\t\t\tversion: 1,\n\t\t\t\t\trevision: 0,\n\t\t\t\t\torigin: { idempotencyKey: \"create-plan-1\", fingerprint: \"request-1\" },\n\t\t\t\t};\n\t\t\t\tawait storage.users.put({\n\t\t\t\t\tid: userId,\n\t\t\t\t\tlogin: \"octocat\",\n\t\t\t\t\tavatarUrl: \"https://example.test/a\",\n\t\t\t\t\tnow,\n\t\t\t\t});\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\trepositoryId: id(\"repository\"),\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\ttitle: \"Created plan\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow,\n\t\t\t\t\tinitial: {\n\t\t\t\t\t\tgeneration: id(\"generation\"),\n\t\t\t\t\t\tepoch: \"epoch-created\",\n\t\t\t\t\t\tsource: \"# Created\\n\",\n\t\t\t\t\t\tsourceHash: \"sha256:created\",\n\t\t\t\t\t\tdocument: new Uint8Array([1, 2, 3]),\n\t\t\t\t\t\tsidecar,\n\t\t\t\t\t},\n\t\t\t\t});\n\n\t\t\t\tlet stored = await storage.collaboration.load(channelId, now);\n\t\t\t\texpect(stored).toBeDefined();\n\t\t\t\texpect(stored!.latestSequence).toBe(0);\n\t\t\t\texpect(stored!.sidecar).toEqual(sidecar);\n\t\t\t\texpect(stored!.snapshot).toMatchObject({\n\t\t\t\t\tchannelId,\n\t\t\t\t\trevision: 0,\n\t\t\t\t\tthroughSequence: 0,\n\t\t\t\t\tepoch: \"epoch-created\",\n\t\t\t\t\tsource: \"# Created\\n\",\n\t\t\t\t\tcreatedAt: now,\n\t\t\t\t});\n\t\t\t\texpect([...stored!.snapshot!.document]).toEqual([1, 2, 3]);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"assigns the first active session as the agent owner\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, sessionId, channelId } = await userAndChannel(storage);\n\t\t\t\tlet second = id(\"session\");\n\t\t\t\tlet now = new Date(\"2026-01-03T03:04:05.000Z\");\n\t\t\t\tawait storage.sessions.create({\n\t\t\t\t\tid: second,\n\t\t\t\t\tuserId,\n\t\t\t\t\texpiresAt: new Date(\"2026-02-03T03:04:05.000Z\"),\n\t\t\t\t\tcreatedAt: now,\n\t\t\t\t});\n\n\t\t\t\tlet first = await storage.channels.claimAgentOwner(channelId, sessionId, now);\n\t\t\t\texpect(first.ownerSessionId).toBe(sessionId);\n\t\t\t\texpect(await storage.channels.readAgent(channelId, now)).toMatchObject({\n\t\t\t\t\tchannel: { id: channelId },\n\t\t\t\t\tagent: { ownerSessionId: sessionId, generation: first.generation },\n\t\t\t\t});\n\t\t\t\texpect(await storage.channels.readAgent(id(\"missing-channel\"), now)).toBeUndefined();\n\t\t\t\texpect((await storage.channels.claimAgentOwner(channelId, second, now)).ownerSessionId)\n\t\t\t\t\t.toBe(sessionId);\n\t\t\t\texpect(await storage.channels.clearAgentOwner(channelId, second, first.generation, now))\n\t\t\t\t\t.toBe(false);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.channels.clearAgentOwner(channelId, sessionId, first.generation, now),\n\t\t\t\t).toBe(true);\n\t\t\t\tlet reclaimed = await storage.channels.claimAgentOwner(channelId, sessionId, now);\n\t\t\t\texpect(reclaimed.generation).toBeGreaterThan(first.generation);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.channels.clearAgentOwner(channelId, sessionId, first.generation, now),\n\t\t\t\t).toBe(false);\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.channels.clearAgentOwner(\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tsessionId,\n\t\t\t\t\t\treclaimed.generation,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t),\n\t\t\t\t).toBe(true);\n\t\t\t\texpect((await storage.channels.claimAgentOwner(channelId, second, now)).ownerSessionId)\n\t\t\t\t\t.toBe(second);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"revokes agent ownership when its login session expires\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { sessionId, channelId } = await userAndChannel(storage);\n\t\t\t\tlet claimed = await storage.channels.claimAgentOwner(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tsessionId,\n\t\t\t\t\tnew Date(\"2026-01-03T03:04:05.000Z\"),\n\t\t\t\t);\n\t\t\t\tawait storage.sessions.deleteExpired(new Date(\"2026-03-03T03:04:05.000Z\"));\n\n\t\t\t\tlet stored = await storage.collaboration.load(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tnew Date(\"2026-03-03T03:04:05.000Z\"),\n\t\t\t\t);\n\t\t\t\texpect(stored!.agent!.ownerSessionId).toBeUndefined();\n\t\t\t\texpect(stored!.agent!.status).toBe(\"unavailable\");\n\t\t\t\ttry {\n\t\t\t\t\tawait storage.channels.updateAgentContext({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\townerSessionId: sessionId,\n\t\t\t\t\t\tgeneration: claimed.generation,\n\t\t\t\t\t\tsummary: \"stale\",\n\t\t\t\t\t\ttranscriptCursor: 1,\n\t\t\t\t\t\tstatus: \"ready\",\n\t\t\t\t\t\tnow: new Date(\"2026-03-03T03:04:05.000Z\"),\n\t\t\t\t\t});\n\t\t\t\t\texpect.unreachable();\n\t\t\t\t} catch (err) {\n\t\t\t\t\texpect(err).toBeInstanceOf(StorageError);\n\t\t\t\t\texpect((err as StorageError).failure).toBe(\"conflict\");\n\t\t\t\t}\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"commits updates, sidecar state and events once\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet operationId = id(\"operation\");\n\t\t\t\tlet sidecar: JsonValue = { questions: [{ id: \"question-1\", status: \"open\" }] };\n\t\t\t\tlet input = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId,\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tupdate: new Uint8Array([99, 100]),\n\t\t\t\t\tsidecar,\n\t\t\t\t\tevents: [{\n\t\t\t\t\t\tid: id(\"event\"),\n\t\t\t\t\t\tkind: \"chat:message\",\n\t\t\t\t\t\tpayload: { text: \"hello\" },\n\t\t\t\t\t\tcreatedAt: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t\t}],\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t};\n\n\t\t\t\tlet committed = await storage.collaboration.commit(input);\n\t\t\t\texpect(committed).toEqual({ revision: 1, sequence: 1, repeated: false });\n\t\t\t\texpect(await storage.collaboration.commit(input)).toEqual({\n\t\t\t\t\trevision: 1,\n\t\t\t\t\tsequence: 1,\n\t\t\t\t\trepeated: true,\n\t\t\t\t});\n\n\t\t\t\tlet stored = await storage.collaboration.load(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tnew Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t);\n\t\t\t\texpect(stored!.channel.revision).toBe(1);\n\t\t\t\texpect([...stored!.updates[0]!.update]).toEqual([99, 100]);\n\t\t\t\texpect(stored!.events).toHaveLength(1);\n\t\t\t\texpect(stored!.sidecar).toEqual(sidecar);\n\n\t\t\t\ttry {\n\t\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\t\t...input,\n\t\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\t\toperationId: id(\"duplicate-event\"),\n\t\t\t\t\t});\n\t\t\t\t\texpect.unreachable();\n\t\t\t\t} catch (err) {\n\t\t\t\t\texpect(err).toBeInstanceOf(StorageError);\n\t\t\t\t\texpect((err as StorageError).failure).toBe(\"conflict\");\n\t\t\t\t}\n\n\t\t\t\ttry {\n\t\t\t\t\tawait storage.collaboration.commit({ ...input, operationId: id(\"stale\") });\n\t\t\t\t\texpect.unreachable();\n\t\t\t\t} catch (err) {\n\t\t\t\t\texpect(err).toBeInstanceOf(StorageError);\n\t\t\t\t\texpect((err as StorageError).failure).toBe(\"conflict\");\n\t\t\t\t}\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"fences archived collaboration writes except sidecar-only maintenance\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet archivedAt = new Date(\"2026-01-04T03:04:05.000Z\");\n\t\t\t\tawait storage.channels.archive({ id: channelId, now: archivedAt });\n\n\t\t\t\tawait expect(attempt(() =>\n\t\t\t\t\tstorage.collaboration.commit({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease,\n\t\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\t\toperationId: id(\"archived-normal-commit\"),\n\t\t\t\t\t\tepoch: \"archived-epoch\",\n\t\t\t\t\t\tsidecar: { maintenance: false },\n\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\tnow: archivedAt,\n\t\t\t\t\t})\n\t\t\t\t)).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet maintenance = await storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId: id(\"archived-sidecar-commit\"),\n\t\t\t\t\tepoch: \"archived-epoch\",\n\t\t\t\t\tsidecar: { maintenance: true },\n\t\t\t\t\tevents: [],\n\t\t\t\t\tnow: new Date(archivedAt.getTime() + 1),\n\t\t\t\t\tallowArchived: true,\n\t\t\t\t});\n\t\t\t\texpect(maintenance).toEqual({ revision: 1, sequence: 1, repeated: false });\n\n\t\t\t\tawait expect(attempt(() =>\n\t\t\t\t\tstorage.collaboration.commit({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease,\n\t\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\t\toperationId: id(\"archived-update-commit\"),\n\t\t\t\t\t\tepoch: \"archived-epoch\",\n\t\t\t\t\t\tupdate: new Uint8Array([1]),\n\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\tnow: new Date(archivedAt.getTime() + 2),\n\t\t\t\t\t\tallowArchived: true,\n\t\t\t\t\t})\n\t\t\t\t)).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(attempt(() =>\n\t\t\t\t\tstorage.collaboration.commit({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease,\n\t\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\t\toperationId: id(\"archived-event-commit\"),\n\t\t\t\t\t\tepoch: \"archived-epoch\",\n\t\t\t\t\t\tevents: [{\n\t\t\t\t\t\t\tid: id(\"archived-event\"),\n\t\t\t\t\t\t\tkind: \"archive:test\",\n\t\t\t\t\t\t\tpayload: { rejected: true },\n\t\t\t\t\t\t\tcreatedAt: new Date(archivedAt.getTime() + 3),\n\t\t\t\t\t\t}],\n\t\t\t\t\t\tnow: new Date(archivedAt.getTime() + 3),\n\t\t\t\t\t\tallowArchived: true,\n\t\t\t\t\t})\n\t\t\t\t)).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tawait expect(attempt(() =>\n\t\t\t\t\tstorage.collaboration.replace({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease,\n\t\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\t\toperationId: id(\"archived-replacement\"),\n\t\t\t\t\t\tgeneration: id(\"archived-generation\"),\n\t\t\t\t\t\tepoch: \"replacement-epoch\",\n\t\t\t\t\t\tsource: \"# Rejected replacement\\n\",\n\t\t\t\t\t\tsourceHash: \"sha256:archived-replacement\",\n\t\t\t\t\t\tdocument: new Uint8Array([2]),\n\t\t\t\t\t\tsidecar: { maintenance: false },\n\t\t\t\t\t\tnow: new Date(archivedAt.getTime() + 4),\n\t\t\t\t\t})\n\t\t\t\t)).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet stored = await storage.collaboration.load(channelId, new Date());\n\t\t\t\texpect(stored).toMatchObject({\n\t\t\t\t\tchannel: { revision: 1, archivedAt },\n\t\t\t\t\tlatestSequence: 1,\n\t\t\t\t\tsidecar: { maintenance: true },\n\t\t\t\t\tupdates: [],\n\t\t\t\t\tevents: [],\n\t\t\t\t});\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"replays only updates newer than the checkpoint\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId: id(\"operation\"),\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tupdate: new Uint8Array([1]),\n\t\t\t\t\tevents: [],\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tlet checkpoint = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\tgeneration: id(\"generation\"),\n\t\t\t\t\trevision: 1,\n\t\t\t\t\tthroughSequence: 1,\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tsource: \"# Plan\\n\",\n\t\t\t\t\tsourceHash: \"hash-1\",\n\t\t\t\t\tdocument: new Uint8Array([2, 3]),\n\t\t\t\t\tsidecar: { questions: [] },\n\t\t\t\t\tcreatedAt: new Date(\"2026-01-04T03:05:05.000Z\"),\n\t\t\t\t};\n\t\t\t\ttry {\n\t\t\t\t\tawait storage.collaboration.checkpoint({ ...checkpoint, throughSequence: 2 });\n\t\t\t\t\texpect.unreachable();\n\t\t\t\t} catch (err) {\n\t\t\t\t\texpect(err).toBeInstanceOf(StorageError);\n\t\t\t\t\texpect((err as StorageError).failure).toBe(\"conflict\");\n\t\t\t\t}\n\t\t\t\tawait storage.collaboration.checkpoint(checkpoint);\n\n\t\t\t\tlet stored = await storage.collaboration.load(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tnew Date(\"2026-01-04T03:05:05.000Z\"),\n\t\t\t\t);\n\t\t\t\texpect(stored!.updates).toEqual([]);\n\t\t\t\texpect(stored!.latestSequence).toBe(1);\n\t\t\t\texpect([...stored!.snapshot!.document]).toEqual([2, 3]);\n\t\t\t\texpect(stored!.snapshot!.source).toBe(\"# Plan\\n\");\n\n\t\t\t\tlet next = await storage.collaboration.commit({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 1,\n\t\t\t\t\toperationId: id(\"operation\"),\n\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\tupdate: new Uint8Array([4]),\n\t\t\t\t\tevents: [],\n\t\t\t\t\tnow: new Date(\"2026-01-04T03:06:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(next.sequence).toBe(2);\n\t\t\t\texpect((await storage.collaboration.load(channelId, new Date()))!.latestSequence).toBe(2);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"replaces an epoch and its sidecar atomically\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet input = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tlease,\n\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\toperationId: id(\"replacement\"),\n\t\t\t\t\tgeneration: id(\"generation\"),\n\t\t\t\t\tepoch: \"epoch-2\",\n\t\t\t\t\tsource: \"# Replacement\\n\",\n\t\t\t\t\tsourceHash: \"sha256:replacement\",\n\t\t\t\t\tdocument: new Uint8Array([7, 8, 9]),\n\t\t\t\t\tsidecar: { version: 1, revision: 4 },\n\t\t\t\t\tnow: new Date(\"2026-01-05T03:04:05.000Z\"),\n\t\t\t\t};\n\t\t\t\texpect(await storage.collaboration.replace(input)).toEqual({\n\t\t\t\t\trevision: 1,\n\t\t\t\t\tsequence: 1,\n\t\t\t\t\trepeated: false,\n\t\t\t\t});\n\t\t\t\tlet stored = await storage.collaboration.load(channelId, input.now);\n\t\t\t\texpect(stored!.snapshot).toMatchObject({ epoch: \"epoch-2\", throughSequence: 1 });\n\t\t\t\texpect([...stored!.snapshot!.document]).toEqual([7, 8, 9]);\n\t\t\t\texpect(stored!.sidecar).toEqual(input.sidecar);\n\t\t\t\texpect(stored!.updates).toEqual([]);\n\t\t\t\texpect(await storage.collaboration.replace(input)).toMatchObject({ repeated: true });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"creates channel-scoped research drafts idempotently and lists recent updates\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet input = researchWorkspace(channelId, userId, lease, {\n\t\t\t\t\tidempotencyKey: id(\"stable-create\"),\n\t\t\t\t\tfingerprint: \"sha256:create-research\",\n\t\t\t\t\torigin: \"planner\",\n\t\t\t\t\toriginMessageId: id(\"origin-message\"),\n\t\t\t\t});\n\t\t\t\tawait expect(storage.research.create({\n\t\t\t\t\t...input,\n\t\t\t\t\tid: id(\"missing-parent-workspace\"),\n\t\t\t\t\tchannelId: id(\"missing-channel\"),\n\t\t\t\t\tidempotencyKey: id(\"missing-parent-request\"),\n\t\t\t\t})).rejects.toMatchObject({ failure: \"missing\" });\n\n\t\t\t\tlet first = await storage.research.create(input);\n\t\t\t\texpect(first).toMatchObject({\n\t\t\t\t\trepeated: false,\n\t\t\t\t\tworkspace: {\n\t\t\t\t\t\tid: input.id,\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tconfirmedQuery: undefined,\n\t\t\t\t\t\trevision: 0,\n\t\t\t\t\t\torigin: \"planner\",\n\t\t\t\t\t},\n\t\t\t\t});\n\t\t\t\tlet repeated = await storage.research.create({\n\t\t\t\t\t...input,\n\t\t\t\t\tid: id(\"ignored-workspace-id\"),\n\t\t\t\t\ttitle: \"Ignored retry title\",\n\t\t\t\t});\n\t\t\t\texpect(repeated).toEqual({ workspace: first.workspace, repeated: true });\n\t\t\t\tawait expect(storage.research.create({\n\t\t\t\t\t...input,\n\t\t\t\t\tid: id(\"conflicting-workspace\"),\n\t\t\t\t\tfingerprint: \"sha256:changed\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet newer = await storage.research.create(researchWorkspace(channelId, userId, lease, {\n\t\t\t\t\ttitle: \"Recent research\",\n\t\t\t\t\tnow: new Date(input.now.getTime() + 1_000),\n\t\t\t\t}));\n\t\t\t\texpect((await storage.research.list(channelId, 1)).map(value => value.id))\n\t\t\t\t\t.toEqual([newer.workspace.id]);\n\t\t\t\texpect(await storage.research.get(id(\"other-channel\"), input.id)).toBeUndefined();\n\t\t\t\tfirst.workspace.createdAt.setUTCFullYear(1999);\n\t\t\t\texpect((await storage.research.get(channelId, input.id))!.workspace.createdAt)\n\t\t\t\t\t.toEqual(input.now);\n\n\t\t\t\texpect(await storage.leases.release(lease)).toBe(true);\n\t\t\t\tawait expect(storage.research.create(researchWorkspace(channelId, userId, lease)))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"lists repository research in channel order with grouped bounded workspaces\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, repositoryId, lease } = await userAndChannel(storage);\n\t\t\t\tlet suffix = crypto.randomUUID();\n\t\t\t\tlet channelA = `repository-channel-a-${suffix}`;\n\t\t\t\tlet channelB = `repository-channel-b-${suffix}`;\n\t\t\t\tlet emptyChannel = `repository-channel-0-empty-${suffix}`;\n\t\t\t\tlet foreignChannel = `repository-channel-foreign-${suffix}`;\n\t\t\t\tlet common = {\n\t\t\t\t\trepositoryId,\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"score\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t};\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\t...common,\n\t\t\t\t\tid: emptyChannel,\n\t\t\t\t\ttitle: `Empty research parent ${suffix}`,\n\t\t\t\t\tnow: new Date(\"2026-01-09T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tfor (let [id, title] of [[channelB, \"B\"], [channelA, \"A\"]] as const) {\n\t\t\t\t\tawait storage.channels.create({\n\t\t\t\t\t\t...common,\n\t\t\t\t\t\tid,\n\t\t\t\t\t\ttitle: `Research parent ${title} ${suffix}`,\n\t\t\t\t\t\tnow: new Date(\"2026-01-08T03:04:05.000Z\"),\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\t...common,\n\t\t\t\t\tid: foreignChannel,\n\t\t\t\t\trepositoryId: `foreign-${repositoryId}`,\n\t\t\t\t\trepositoryName: \"other\",\n\t\t\t\t\ttitle: `Foreign research parent ${suffix}`,\n\t\t\t\t\tnow: new Date(\"2026-01-10T03:04:05.000Z\"),\n\t\t\t\t});\n\n\t\t\t\tlet create = async (parentId: string, workspaceId: string, now: Date) =>\n\t\t\t\t\tstorage.research.create(researchWorkspace(parentId, userId, lease, {\n\t\t\t\t\t\tid: workspaceId,\n\t\t\t\t\t\ttitle: workspaceId,\n\t\t\t\t\t\tidempotencyKey: `create-${workspaceId}`,\n\t\t\t\t\t\tfingerprint: `fingerprint-${workspaceId}`,\n\t\t\t\t\t\tnow,\n\t\t\t\t\t}));\n\t\t\t\tlet newest = `workspace-newest-${suffix}`;\n\t\t\t\tlet tiedA = `workspace-tied-a-${suffix}`;\n\t\t\t\tlet tiedB = `workspace-tied-b-${suffix}`;\n\t\t\t\tawait create(channelA, tiedB, new Date(\"2026-01-11T03:04:05.000Z\"));\n\t\t\t\tawait create(channelA, tiedA, new Date(\"2026-01-11T03:04:05.000Z\"));\n\t\t\t\tawait create(channelA, newest, new Date(\"2026-01-12T03:04:05.000Z\"));\n\t\t\t\tlet channelBWorkspace = `workspace-channel-b-${suffix}`;\n\t\t\t\tlet oldChannelWorkspace = `workspace-old-channel-${suffix}`;\n\t\t\t\tawait create(channelB, channelBWorkspace, new Date(\"2026-01-13T03:04:05.000Z\"));\n\t\t\t\tawait create(channelId, oldChannelWorkspace, new Date(\"2026-01-14T03:04:05.000Z\"));\n\t\t\t\tawait create(\n\t\t\t\t\tforeignChannel,\n\t\t\t\t\t`workspace-foreign-${suffix}`,\n\t\t\t\t\tnew Date(\"2026-01-15T03:04:05.000Z\"),\n\t\t\t\t);\n\n\t\t\t\tlet listed = await storage.research.listRepository(repositoryId, 10);\n\t\t\t\texpect(listed.truncated).toBe(false);\n\t\t\t\texpect(listed.channels.map(group => group.channel.id)).toEqual([\n\t\t\t\t\tchannelA,\n\t\t\t\t\tchannelB,\n\t\t\t\t\tchannelId,\n\t\t\t\t]);\n\t\t\t\texpect(listed.channels[0]!.workspaces.map(value => value.id)).toEqual([\n\t\t\t\t\tnewest,\n\t\t\t\t\ttiedA,\n\t\t\t\t\ttiedB,\n\t\t\t\t]);\n\t\t\t\texpect(listed.channels[1]!.workspaces.map(value => value.id))\n\t\t\t\t\t.toEqual([channelBWorkspace]);\n\t\t\t\texpect(listed.channels[2]!.workspaces.map(value => value.id))\n\t\t\t\t\t.toEqual([oldChannelWorkspace]);\n\t\t\t\tawait storage.channels.archive({\n\t\t\t\t\tid: channelB,\n\t\t\t\t\tnow: new Date(\"2026-01-16T03:04:05.000Z\"),\n\t\t\t\t});\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.research.listRepository(repositoryId, 10)).channels\n\t\t\t\t\t\t.map(group => group.channel.id),\n\t\t\t\t).toEqual([channelA, channelId]);\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.research.listRepository(repositoryId, 10, true)).channels\n\t\t\t\t\t\t.map(group => group.channel.id),\n\t\t\t\t).toEqual([channelA, channelB, channelId]);\n\t\t\t\texpect((await storage.research.list(channelB, 10)).map(value => value.id))\n\t\t\t\t\t.toEqual([channelBWorkspace]);\n\t\t\t\texpect(await storage.research.get(channelB, channelBWorkspace)).toBeDefined();\n\t\t\t\tawait storage.channels.restore({\n\t\t\t\t\tid: channelB,\n\t\t\t\t\tnow: new Date(\"2026-01-16T03:04:06.000Z\"),\n\t\t\t\t});\n\n\t\t\t\tlet bounded = await storage.research.listRepository(repositoryId, 2);\n\t\t\t\texpect(bounded.truncated).toBe(true);\n\t\t\t\texpect(bounded.channels.map(group => ({\n\t\t\t\t\tchannelId: group.channel.id,\n\t\t\t\t\tworkspaceIds: group.workspaces.map(value => value.id),\n\t\t\t\t}))).toEqual([{ channelId: channelA, workspaceIds: [newest, tiedA] }]);\n\n\t\t\t\tfor (let index = 0; index < 98; index++) {\n\t\t\t\t\tlet workspaceId = `workspace-bounded-${String(index).padStart(3, \"0\")}-${suffix}`;\n\t\t\t\t\tawait create(\n\t\t\t\t\t\tchannelA,\n\t\t\t\t\t\tworkspaceId,\n\t\t\t\t\t\tnew Date(`2026-01-10T03:${String(index % 60).padStart(2, \"0\")}:00.000Z`),\n\t\t\t\t\t);\n\t\t\t\t}\n\t\t\t\tlet perChannelBounded = await storage.research.listRepository(repositoryId, 500);\n\t\t\t\texpect(perChannelBounded.truncated).toBe(true);\n\t\t\t\texpect(perChannelBounded.channels[0]).toMatchObject({\n\t\t\t\t\tchannel: { id: channelA },\n\t\t\t\t});\n\t\t\t\texpect(perChannelBounded.channels[0]!.workspaces).toHaveLength(100);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"confirms research and appends ordered turn-message pairs exactly once\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet draft = await storage.research.create(researchWorkspace(channelId, userId, lease));\n\t\t\t\tlet followUp = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\t\tturnId: id(\"follow-up-turn\"),\n\t\t\t\t\tmessageId: id(\"follow-up-message\"),\n\t\t\t\t\tkind: \"follow-up\" as const,\n\t\t\t\t\trequestId: id(\"follow-up-request\"),\n\t\t\t\t\tfingerprint: \"sha256:follow-up\",\n\t\t\t\t\tquestion: \"What changed for existing clients?\",\n\t\t\t\t\trequestedBy: userId,\n\t\t\t\t\trequestedByHandle: \"octocat\",\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tawait expect(storage.research.appendTurn(followUp))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet confirmation = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\t\tturnId: id(\"initial-turn\"),\n\t\t\t\t\tmessageId: id(\"initial-message\"),\n\t\t\t\t\trequestId: id(\"confirmation-request\"),\n\t\t\t\t\tfingerprint: \"sha256:confirmation\",\n\t\t\t\t\tconfirmedQuery: \"Which API contracts changed in version 3?\",\n\t\t\t\t\tconfirmedBy: userId,\n\t\t\t\t\tconfirmedByHandle: \"octocat\",\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:05:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tlet confirmed = await storage.research.confirm(confirmation);\n\t\t\t\texpect(confirmed).toMatchObject({\n\t\t\t\t\trepeated: false,\n\t\t\t\t\tworkspace: { revision: 1, confirmedQuery: confirmation.confirmedQuery },\n\t\t\t\t\tturn: { ordinal: 1, kind: \"initial\", question: confirmation.confirmedQuery },\n\t\t\t\t\tmessage: { sequence: 1, authorKind: \"member\", text: confirmation.confirmedQuery },\n\t\t\t\t});\n\t\t\t\tlet confirmationReplay = await storage.research.confirm({\n\t\t\t\t\t...confirmation,\n\t\t\t\t\tturnId: id(\"ignored-turn\"),\n\t\t\t\t\tmessageId: id(\"ignored-message\"),\n\t\t\t\t\tnow: new Date(confirmation.now.getTime() + 1),\n\t\t\t\t});\n\t\t\t\texpect(confirmationReplay).toEqual({ ...confirmed, repeated: true });\n\t\t\t\tawait expect(storage.research.confirm({\n\t\t\t\t\t...confirmation,\n\t\t\t\t\trequestId: id(\"second-confirmation\"),\n\t\t\t\t\tfingerprint: \"sha256:second-confirmation\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet appended = await storage.research.appendTurn(followUp);\n\t\t\t\texpect(appended).toMatchObject({\n\t\t\t\t\tworkspace: { revision: 2 },\n\t\t\t\t\tturn: { ordinal: 2, kind: \"follow-up\" },\n\t\t\t\t\tmessage: { sequence: 2, authorKind: \"member\" },\n\t\t\t\t});\n\t\t\t\tlet appendReplay = await storage.research.appendTurn({\n\t\t\t\t\t...followUp,\n\t\t\t\t\tturnId: id(\"ignored-follow-up-turn\"),\n\t\t\t\t\tmessageId: id(\"ignored-follow-up-message\"),\n\t\t\t\t\tnow: new Date(followUp.now.getTime() + 1),\n\t\t\t\t});\n\t\t\t\texpect(appendReplay).toEqual({ ...appended, repeated: true });\n\t\t\t\tawait expect(storage.research.appendTurn({\n\t\t\t\t\t...followUp,\n\t\t\t\t\tfingerprint: \"sha256:changed-follow-up\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet searchMore = {\n\t\t\t\t\t...followUp,\n\t\t\t\t\tturnId: id(\"search-more-turn\"),\n\t\t\t\t\tmessageId: id(\"search-more-message\"),\n\t\t\t\t\tkind: \"search-more\" as const,\n\t\t\t\t\trequestId: id(\"search-more-request\"),\n\t\t\t\t\tfingerprint: \"sha256:search-more\",\n\t\t\t\t\tquestion: \"Search for more migration reports.\",\n\t\t\t\t\tnow: new Date(followUp.now.getTime() + 1_000),\n\t\t\t\t};\n\t\t\t\tlet parallelFollowUp = {\n\t\t\t\t\t...followUp,\n\t\t\t\t\tturnId: id(\"parallel-turn\"),\n\t\t\t\t\tmessageId: id(\"parallel-message\"),\n\t\t\t\t\trequestId: id(\"parallel-request\"),\n\t\t\t\t\tfingerprint: \"sha256:parallel-follow-up\",\n\t\t\t\t\tquestion: \"Which clients were tested?\",\n\t\t\t\t\tnow: new Date(followUp.now.getTime() + 1_001),\n\t\t\t\t};\n\t\t\t\tlet parallel = await Promise.all([\n\t\t\t\t\tstorage.research.appendTurn(searchMore),\n\t\t\t\t\tstorage.research.appendTurn(parallelFollowUp),\n\t\t\t\t]);\n\t\t\t\texpect(parallel.map(value => value.turn.ordinal).sort()).toEqual([3, 4]);\n\t\t\t\texpect(parallel.map(value => value.message.sequence).sort()).toEqual([3, 4]);\n\t\t\t\tlet detail = await storage.research.get(channelId, draft.workspace.id);\n\t\t\t\texpect(detail!.turns.map(value => value.ordinal)).toEqual([1, 2, 3, 4]);\n\t\t\t\texpect(detail!.messages.map(value => value.sequence)).toEqual([1, 2, 3, 4]);\n\t\t\t\tdetail!.turns[0]!.createdAt.setUTCFullYear(1999);\n\t\t\t\texpect((await storage.research.get(channelId, draft.workspace.id))!.turns[0]!.createdAt)\n\t\t\t\t\t.toEqual(confirmation.now);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"rejects new archived research mutations but preserves exact replays\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet create = researchWorkspace(channelId, userId, lease, {\n\t\t\t\t\tid: id(\"archive-replay-workspace\"),\n\t\t\t\t\tidempotencyKey: id(\"archive-replay-create\"),\n\t\t\t\t\tfingerprint: \"sha256:archive-replay-create\",\n\t\t\t\t});\n\t\t\t\tlet created = await storage.research.create(create);\n\t\t\t\tlet unconfirmed = await storage.research.create(researchWorkspace(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tuserId,\n\t\t\t\t\tlease,\n\t\t\t\t\t{\n\t\t\t\t\t\tid: id(\"archive-unconfirmed-workspace\"),\n\t\t\t\t\t\tidempotencyKey: id(\"archive-unconfirmed-create\"),\n\t\t\t\t\t\tfingerprint: \"sha256:archive-unconfirmed-create\",\n\t\t\t\t\t},\n\t\t\t\t));\n\t\t\t\tlet confirmation = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: created.workspace.id,\n\t\t\t\t\tturnId: id(\"archive-initial-turn\"),\n\t\t\t\t\tmessageId: id(\"archive-initial-message\"),\n\t\t\t\t\trequestId: id(\"archive-confirmation\"),\n\t\t\t\t\tfingerprint: \"sha256:archive-confirmation\",\n\t\t\t\t\tconfirmedQuery: \"Which archive fences are durable?\",\n\t\t\t\t\tconfirmedBy: userId,\n\t\t\t\t\tconfirmedByHandle: \"octocat\",\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:05:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tlet confirmed = await storage.research.confirm(confirmation);\n\t\t\t\tlet append = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: created.workspace.id,\n\t\t\t\t\tturnId: id(\"archive-follow-up-turn\"),\n\t\t\t\t\tmessageId: id(\"archive-follow-up-message\"),\n\t\t\t\t\tkind: \"follow-up\" as const,\n\t\t\t\t\trequestId: id(\"archive-follow-up\"),\n\t\t\t\t\tfingerprint: \"sha256:archive-follow-up\",\n\t\t\t\t\tquestion: \"Do exact retries remain available?\",\n\t\t\t\t\trequestedBy: userId,\n\t\t\t\t\trequestedByHandle: \"octocat\",\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tlet appended = await storage.research.appendTurn(append);\n\t\t\t\tawait storage.channels.archive({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\tnow: new Date(\"2026-01-08T03:04:05.000Z\"),\n\t\t\t\t});\n\n\t\t\t\texpect(await storage.research.create(create)).toMatchObject({\n\t\t\t\t\trepeated: true,\n\t\t\t\t\tworkspace: { id: created.workspace.id },\n\t\t\t\t});\n\t\t\t\texpect(await storage.research.confirm(confirmation)).toMatchObject({\n\t\t\t\t\trepeated: true,\n\t\t\t\t\tturn: { id: confirmed.turn.id },\n\t\t\t\t\tmessage: { id: confirmed.message.id },\n\t\t\t\t});\n\t\t\t\texpect(await storage.research.appendTurn(append)).toMatchObject({\n\t\t\t\t\trepeated: true,\n\t\t\t\t\tturn: { id: appended.turn.id },\n\t\t\t\t\tmessage: { id: appended.message.id },\n\t\t\t\t});\n\n\t\t\t\tawait expect(storage.research.create(researchWorkspace(\n\t\t\t\t\tchannelId,\n\t\t\t\t\tuserId,\n\t\t\t\t\tlease,\n\t\t\t\t\t{\n\t\t\t\t\t\tid: id(\"archived-new-workspace\"),\n\t\t\t\t\t\tidempotencyKey: id(\"archived-new-create\"),\n\t\t\t\t\t\tfingerprint: \"sha256:archived-new-create\",\n\t\t\t\t\t},\n\t\t\t\t))).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(storage.research.confirm({\n\t\t\t\t\t...confirmation,\n\t\t\t\t\tworkspaceId: unconfirmed.workspace.id,\n\t\t\t\t\tturnId: id(\"archived-new-initial-turn\"),\n\t\t\t\t\tmessageId: id(\"archived-new-initial-message\"),\n\t\t\t\t\trequestId: id(\"archived-new-confirmation\"),\n\t\t\t\t\tfingerprint: \"sha256:archived-new-confirmation\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(storage.research.appendTurn({\n\t\t\t\t\t...append,\n\t\t\t\t\tturnId: id(\"archived-new-follow-up-turn\"),\n\t\t\t\t\tmessageId: id(\"archived-new-follow-up-message\"),\n\t\t\t\t\trequestId: id(\"archived-new-follow-up\"),\n\t\t\t\t\tfingerprint: \"sha256:archived-new-follow-up\",\n\t\t\t\t\tquestion: \"This new request must be fenced.\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\texpect((await storage.research.get(channelId, created.workspace.id))!.turns)\n\t\t\t\t\t.toHaveLength(2);\n\t\t\t\texpect(\n\t\t\t\t\t(await storage.research.get(channelId, unconfirmed.workspace.id))!.workspace\n\t\t\t\t\t\t.confirmedQuery,\n\t\t\t\t).toBeUndefined();\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"links channel jobs once and appends answer messages idempotently\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { userId, channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet draft = await storage.research.create(researchWorkspace(channelId, userId, lease));\n\t\t\t\tlet confirmed = await storage.research.confirm({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\t\tturnId: id(\"initial-turn\"),\n\t\t\t\t\tmessageId: id(\"initial-message\"),\n\t\t\t\t\trequestId: id(\"confirmation-request\"),\n\t\t\t\t\tfingerprint: \"sha256:confirmation\",\n\t\t\t\t\tconfirmedQuery: \"What changed?\",\n\t\t\t\t\tconfirmedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:05:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet evidence = await storage.jobs.enqueue(backgroundJob(channelId, lease, {\n\t\t\t\t\ttype: \"research-evidence\",\n\t\t\t\t\ttargetKey:\n\t\t\t\t\t\t`research-evidence:workspace:${draft.workspace.id}:turn:${confirmed.turn.id}:evidence`,\n\t\t\t\t}));\n\t\t\t\tlet answer = await storage.jobs.enqueue(backgroundJob(channelId, lease, {\n\t\t\t\t\ttype: \"research-answer\",\n\t\t\t\t\ttargetKey:\n\t\t\t\t\t\t`research-answer:workspace:${draft.workspace.id}:turn:${confirmed.turn.id}:answer`,\n\t\t\t\t}));\n\t\t\t\tlet otherChannel = id(\"other-channel\");\n\t\t\t\tawait storage.channels.create({\n\t\t\t\t\tid: otherChannel,\n\t\t\t\t\trepositoryId: id(\"other-repository\"),\n\t\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\t\trepositoryName: \"other\",\n\t\t\t\t\ttitle: \"Other research parent\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:05:05.000Z\"),\n\t\t\t\t});\n\t\t\t\tlet foreign = await storage.jobs.enqueue(backgroundJob(otherChannel, lease, {\n\t\t\t\t\ttype: \"research-answer\",\n\t\t\t\t\ttargetKey: id(\"foreign-target\"),\n\t\t\t\t}));\n\t\t\t\tlet linkBase = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:06:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tawait expect(storage.research.linkJob({\n\t\t\t\t\t...linkBase,\n\t\t\t\t\trole: \"answer\",\n\t\t\t\t\tjobId: foreign.job.id,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"missing\" });\n\n\t\t\t\tlet evidenceLink = await storage.research.linkJob({\n\t\t\t\t\t...linkBase,\n\t\t\t\t\trole: \"evidence\",\n\t\t\t\t\tjobId: evidence.job.id,\n\t\t\t\t});\n\t\t\t\texpect(evidenceLink).toMatchObject({\n\t\t\t\t\trepeated: false,\n\t\t\t\t\tworkspace: { revision: 2 },\n\t\t\t\t\tturn: { evidenceJobId: evidence.job.id },\n\t\t\t\t});\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.research.linkJob({\n\t\t\t\t\t\t...linkBase,\n\t\t\t\t\t\trole: \"evidence\",\n\t\t\t\t\t\tjobId: evidence.job.id,\n\t\t\t\t\t}),\n\t\t\t\t).toEqual({ ...evidenceLink, repeated: true });\n\t\t\t\tawait expect(storage.research.linkJob({\n\t\t\t\t\t...linkBase,\n\t\t\t\t\trole: \"evidence\",\n\t\t\t\t\tjobId: answer.job.id,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tlet answerLink = await storage.research.linkJob({\n\t\t\t\t\t...linkBase,\n\t\t\t\t\trole: \"answer\",\n\t\t\t\t\tjobId: answer.job.id,\n\t\t\t\t\tnow: new Date(linkBase.now.getTime() + 1),\n\t\t\t\t});\n\t\t\t\texpect(answerLink.workspace.revision).toBe(3);\n\t\t\t\texpect((await storage.research.findTurnByJob(channelId, evidence.job.id))?.id)\n\t\t\t\t\t.toBe(confirmed.turn.id);\n\t\t\t\texpect((await storage.research.findTurnByJob(channelId, answer.job.id))?.id)\n\t\t\t\t\t.toBe(confirmed.turn.id);\n\t\t\t\texpect(await storage.research.findTurnByJob(otherChannel, answer.job.id)).toBeUndefined();\n\n\t\t\t\tlet agentMessage = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\t\tid: id(\"agent-message\"),\n\t\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\t\tuserHandle: \"chopin\",\n\t\t\t\t\ttext: \"The API retained wire compatibility.\",\n\t\t\t\t\tsourceJobId: answer.job.id,\n\t\t\t\t\tnow: new Date(\"2026-01-07T03:07:05.000Z\"),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tawait expect(storage.research.appendAgentMessage({\n\t\t\t\t\t...agentMessage,\n\t\t\t\t\tid: id(\"wrong-source-message\"),\n\t\t\t\t\tsourceJobId: evidence.job.id,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tlet appended = await storage.research.appendAgentMessage(agentMessage);\n\t\t\t\texpect(appended).toMatchObject({\n\t\t\t\t\trepeated: false,\n\t\t\t\t\tworkspace: { revision: 4 },\n\t\t\t\t\tmessage: {\n\t\t\t\t\t\tsequence: 2,\n\t\t\t\t\t\tauthorKind: \"agent\",\n\t\t\t\t\t\tsourceJobId: answer.job.id,\n\t\t\t\t\t},\n\t\t\t\t});\n\t\t\t\texpect(\n\t\t\t\t\tawait storage.research.appendAgentMessage({\n\t\t\t\t\t\t...agentMessage,\n\t\t\t\t\t\tid: id(\"replayed-agent-message\"),\n\t\t\t\t\t\tnow: new Date(agentMessage.now.getTime() + 1),\n\t\t\t\t\t}),\n\t\t\t\t).toEqual({ ...appended, repeated: true });\n\t\t\t\tawait expect(storage.research.appendAgentMessage({\n\t\t\t\t\t...agentMessage,\n\t\t\t\t\ttext: \"Changed retry payload\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.get(channelId, answer.job.id))!.job.state).toBe(\"pending\");\n\t\t\t\texpect((await storage.research.get(channelId, draft.workspace.id))!.messages)\n\t\t\t\t\t.toHaveLength(2);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"enqueues background targets idempotently without collaboration side effects\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet beforeChannel = await storage.channels.get(channelId);\n\t\t\t\tlet beforeCollaboration = await storage.collaboration.load(channelId, new Date());\n\t\t\t\texpect(await storage.jobs.list(channelId, 20)).toEqual({ revision: 0, jobs: [] });\n\t\t\t\tawait expect(storage.jobs.enqueue(backgroundJob(channelId, lease, { id: \"\" })))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.list(channelId, 20))!.revision).toBe(0);\n\n\t\t\t\tlet input = backgroundJob(channelId, lease, {\n\t\t\t\t\tid: id(\"first-job\"),\n\t\t\t\t\tidempotencyKey: id(\"first-enqueue\"),\n\t\t\t\t\tfingerprint: \"sha256:first\",\n\t\t\t\t\tinput: { revision: 1, nested: [\"source\"] },\n\t\t\t\t});\n\t\t\t\tlet first = await storage.jobs.enqueue(input);\n\t\t\t\texpect(first.repeated).toBe(false);\n\t\t\t\texpect(first.job).toMatchObject({\n\t\t\t\t\tstate: \"pending\",\n\t\t\t\t\ttargetGeneration: 1,\n\t\t\t\t\trevision: 1,\n\t\t\t\t});\n\t\t\t\tlet repeated = await storage.jobs.enqueue({ ...input, id: id(\"ignored-job\") });\n\t\t\t\texpect(repeated).toEqual({ job: first.job, repeated: true });\n\t\t\t\texpect((await storage.jobs.list(channelId, 20))!.revision).toBe(1);\n\t\t\t\tawait expect(storage.jobs.enqueue({\n\t\t\t\t\t...input,\n\t\t\t\t\tid: id(\"conflicting-job\"),\n\t\t\t\t\tfingerprint: \"sha256:changed\",\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\n\t\t\t\tlet second = await storage.jobs.enqueue(backgroundJob(channelId, lease, {\n\t\t\t\t\tfingerprint: \"sha256:second\",\n\t\t\t\t\ttype: \"research-answer\",\n\t\t\t\t\tinput: { revision: 2, question: \"Which clients were tested?\" },\n\t\t\t\t\tnow: new Date(input.now.getTime() + 1),\n\t\t\t\t}));\n\t\t\t\texpect(second.job).toMatchObject({ targetGeneration: 2, revision: 2 });\n\t\t\t\texpect((await storage.jobs.get(channelId, first.job.id))!.job.state).toBe(\"superseded\");\n\t\t\t\tlet independent = await storage.jobs.enqueue(backgroundJob(channelId, lease, {\n\t\t\t\t\ttargetKey: \"research:evidence-1\",\n\t\t\t\t\ttype: \"research-evidence\",\n\t\t\t\t\torigin: \"user\",\n\t\t\t\t\tinput: { query: \"What changed in the API?\" },\n\t\t\t\t\tnow: new Date(input.now.getTime() + 2),\n\t\t\t\t}));\n\t\t\t\texpect(independent.job).toMatchObject({ targetGeneration: 1, revision: 3 });\n\t\t\t\tlet page = await storage.jobs.list(channelId, 2);\n\t\t\t\texpect(page!.jobs.map(job => job.id)).toEqual([independent.job.id, second.job.id]);\n\t\t\t\texpect(page!.jobs.map(job => job.subject)).toEqual([\n\t\t\t\t\t\"What changed in the API?\",\n\t\t\t\t\t\"Which clients were tested?\",\n\t\t\t\t]);\n\t\t\t\texpect(page!.next).toBeDefined();\n\t\t\t\texpect(\"input\" in page!.jobs[0]!).toBe(false);\n\t\t\t\tlet remainder = await storage.jobs.list(channelId, 2, page!.next);\n\t\t\t\texpect(remainder!.jobs.map(job => job.id)).toEqual([first.job.id]);\n\n\t\t\t\tlet detail = await storage.jobs.get(channelId, second.job.id);\n\t\t\t\t(detail!.job.input as { revision: number }).revision = 99;\n\t\t\t\texpect((await storage.jobs.get(channelId, second.job.id))!.job.input)\n\t\t\t\t\t.toEqual({ question: \"Which clients were tested?\", revision: 2 });\n\t\t\t\texpect(await storage.channels.get(channelId)).toEqual(beforeChannel);\n\t\t\t\texpect(await storage.collaboration.load(channelId, new Date())).toEqual(\n\t\t\t\t\tbeforeCollaboration,\n\t\t\t\t);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"requires an archive allowance to cancel background work\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-07T03:04:05.000Z\");\n\t\t\t\tlet queued = await storage.jobs.enqueue(backgroundJob(channelId, lease, { now }));\n\t\t\t\tawait storage.channels.archive({\n\t\t\t\t\tid: channelId,\n\t\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\t});\n\n\t\t\t\tlet cancellation = {\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.job.id,\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t};\n\t\t\t\tawait expect(storage.jobs.cancel(cancellation))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.get(channelId, queued.job.id))!.job.state).toBe(\"pending\");\n\n\t\t\t\tlet cancelled = await storage.jobs.cancel({ ...cancellation, allowArchived: true });\n\t\t\t\texpect(cancelled.state).toBe(\"cancelled\");\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"fences claims and publishes a background artifact atomically\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date();\n\t\t\t\tlet queued = (await storage.jobs.enqueue(backgroundJob(channelId, lease, { now }))).job;\n\t\t\t\tlet [claimed] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"worker-1\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 10_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(claimed).toMatchObject({\n\t\t\t\t\tid: queued.id,\n\t\t\t\t\tstate: \"running\",\n\t\t\t\t\tattempts: 1,\n\t\t\t\t\tclaimGeneration: 1,\n\t\t\t\t\trevision: 2,\n\t\t\t\t});\n\t\t\t\tlet renewed = await storage.jobs.renew({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: claimed!.id,\n\t\t\t\t\tclaimOwner: \"worker-1\",\n\t\t\t\t\tclaimGeneration: claimed!.claimGeneration,\n\t\t\t\t\texpectedRevision: claimed!.revision,\n\t\t\t\t\tclaimBinding: { ownerSessionId: \"session-1\", ownerGeneration: 3 },\n\t\t\t\t\tttlMs: 10_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(renewed).toMatchObject({\n\t\t\t\t\trevision: 3,\n\t\t\t\t\tclaimBinding: { ownerSessionId: \"session-1\" },\n\t\t\t\t});\n\t\t\t\tawait expect(storage.jobs.renew({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: claimed!.id,\n\t\t\t\t\tclaimOwner: \"worker-1\",\n\t\t\t\t\tclaimGeneration: claimed!.claimGeneration,\n\t\t\t\t\texpectedRevision: claimed!.revision,\n\t\t\t\t\tclaimBinding: { ownerSessionId: \"stale-session\" },\n\t\t\t\t\tttlMs: 20_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tawait expect(storage.jobs.settle({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: claimed!.id,\n\t\t\t\t\tclaimOwner: \"worker-1\",\n\t\t\t\t\tclaimGeneration: claimed!.claimGeneration + 1,\n\t\t\t\t\tartifact: { abstract: \"wrong\" },\n\t\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.get(channelId, claimed!.id))!.artifact).toBeUndefined();\n\n\t\t\t\tlet requeued = await storage.jobs.requeue({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: claimed!.id,\n\t\t\t\t\tclaimOwner: \"worker-1\",\n\t\t\t\t\tclaimGeneration: claimed!.claimGeneration,\n\t\t\t\t\tavailableAt: new Date(now.getTime() + 4),\n\t\t\t\t\treason: \"retry\",\n\t\t\t\t\tcountFailure: true,\n\t\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(requeued).toMatchObject({\n\t\t\t\t\tstate: \"pending\",\n\t\t\t\t\trevision: 4,\n\t\t\t\t\treason: \"retry\",\n\t\t\t\t\tfailures: 1,\n\t\t\t\t});\n\t\t\t\tlet [secondClaim] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"worker-2\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 10_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 5),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(secondClaim).toMatchObject({ attempts: 2, claimGeneration: 2, revision: 5 });\n\t\t\t\tlet paused = await storage.jobs.pause({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: secondClaim!.id,\n\t\t\t\t\texpectedRevision: secondClaim!.revision,\n\t\t\t\t\treason: \"owner-unavailable\",\n\t\t\t\t\tnow: new Date(now.getTime() + 6),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(paused).toMatchObject({ state: \"paused\", revision: 6 });\n\t\t\t\tawait expect(storage.jobs.fail({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: secondClaim!.id,\n\t\t\t\t\tclaimOwner: \"worker-2\",\n\t\t\t\t\tclaimGeneration: secondClaim!.claimGeneration,\n\t\t\t\t\treason: \"late\",\n\t\t\t\t\tnow: new Date(now.getTime() + 7),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tlet resumed = await storage.jobs.resume({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: paused.id,\n\t\t\t\t\texpectedRevision: paused.revision,\n\t\t\t\t\tavailableAt: new Date(now.getTime() + 8),\n\t\t\t\t\tnow: new Date(now.getTime() + 8),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(resumed).toMatchObject({ state: \"pending\", revision: 7 });\n\t\t\t\tlet [finalClaim] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"worker-3\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 10_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 9),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet completed = await storage.jobs.settle({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: finalClaim!.id,\n\t\t\t\t\tclaimOwner: \"worker-3\",\n\t\t\t\t\tclaimGeneration: finalClaim!.claimGeneration,\n\t\t\t\t\tartifact: { abstract: \"Current summary\", sources: [] },\n\t\t\t\t\tnow: new Date(now.getTime() + 10),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(completed.job).toMatchObject({ state: \"completed\", revision: 9 });\n\t\t\t\texpect(completed.artifact).toMatchObject({\n\t\t\t\t\trevision: 9,\n\t\t\t\t\tvalue: { abstract: \"Current summary\", sources: [] },\n\t\t\t\t});\n\t\t\t\t(completed.artifact!.value as { abstract: string }).abstract = \"mutated\";\n\t\t\t\texpect((await storage.jobs.get(channelId, completed.job.id))!.artifact!.value)\n\t\t\t\t\t.toMatchObject({ abstract: \"Current summary\" });\n\t\t\t\tawait expect(storage.jobs.cancel({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: completed.job.id,\n\t\t\t\t\tnow: new Date(now.getTime() + 11),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"reclaims expired background claims and rejects a fenced writer\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date();\n\t\t\t\tlet queued = (await storage.jobs.enqueue(backgroundJob(channelId, lease, { now }))).job;\n\t\t\t\tlet [first] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"old-worker\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 1,\n\t\t\t\t\tnow,\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet [replacement] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"new-worker\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 10_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(replacement).toMatchObject({\n\t\t\t\t\tid: queued.id,\n\t\t\t\t\tattempts: 2,\n\t\t\t\t\tclaimGeneration: 2,\n\t\t\t\t});\n\t\t\t\tawait expect(storage.jobs.fail({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"old-worker\",\n\t\t\t\t\tclaimGeneration: first!.claimGeneration,\n\t\t\t\t\treason: \"stale\",\n\t\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tlet failed = await storage.jobs.fail({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"new-worker\",\n\t\t\t\t\tclaimGeneration: replacement!.claimGeneration,\n\t\t\t\t\treason: \"attempts-exhausted\",\n\t\t\t\t\tnow: new Date(now.getTime() + 4),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(failed.state).toBe(\"failed\");\n\n\t\t\t\texpect(await storage.leases.release(lease)).toBe(true);\n\t\t\t\tlet nextLease = await storage.leases.acquire(lease.name, \"replacement\", 60_000);\n\t\t\t\texpect(nextLease).toBeDefined();\n\t\t\t\tawait expect(storage.jobs.enqueue(backgroundJob(channelId, lease)))\n\t\t\t\t\t.rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"persists bounded progress only for the active background claim\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId, lease } = await userAndChannel(storage);\n\t\t\t\tlet now = new Date(\"2026-01-06T03:04:05.000Z\");\n\t\t\t\tlet queued = (await storage.jobs.enqueue(backgroundJob(channelId, lease, { now }))).job;\n\t\t\t\tlet [firstClaim] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 60_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(firstClaim!.progress).toEqual([]);\n\t\t\t\tlet beforeInvalid = (await storage.jobs.list(channelId, 10))!.revision;\n\t\t\t\tawait expect(storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration,\n\t\t\t\t\tstage: \"invalid stage\",\n\t\t\t\t\tlabel: \"Invalid\",\n\t\t\t\t\tstate: \"started\",\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.list(channelId, 10))!.revision).toBe(beforeInvalid);\n\t\t\t\tawait expect(storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"interrupted\",\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\texpect((await storage.jobs.list(channelId, 10))!.revision).toBe(beforeInvalid);\n\t\t\t\tawait expect(storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration + 1,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"started\",\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t})).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\t\tlet firstProgress = await storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"started\",\n\t\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(firstProgress.progress).toMatchObject([{\n\t\t\t\t\tattempt: 1,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"started\",\n\t\t\t\t}]);\n\t\t\t\tlet interrupted = await storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"interrupted\",\n\t\t\t\t\treason: \"attempt-error\",\n\t\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(interrupted.progress.at(-1)).toMatchObject({\n\t\t\t\t\tstate: \"interrupted\",\n\t\t\t\t\treason: \"attempt-error\",\n\t\t\t\t});\n\t\t\t\tawait storage.jobs.requeue({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-1\",\n\t\t\t\t\tclaimGeneration: firstClaim!.claimGeneration,\n\t\t\t\t\tavailableAt: new Date(now.getTime() + 3),\n\t\t\t\t\treason: \"retry\",\n\t\t\t\t\tcountFailure: true,\n\t\t\t\t\tnow: new Date(now.getTime() + 4),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet [secondClaim] = await storage.jobs.claim({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tclaimOwner: \"progress-worker-2\",\n\t\t\t\t\tcount: 1,\n\t\t\t\t\tttlMs: 60_000,\n\t\t\t\t\tnow: new Date(now.getTime() + 5),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\tlet current = await storage.jobs.appendProgress({\n\t\t\t\t\tchannelId,\n\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\tclaimOwner: \"progress-worker-2\",\n\t\t\t\t\tclaimGeneration: secondClaim!.claimGeneration,\n\t\t\t\t\tstage: \"public-web\",\n\t\t\t\t\tlabel: \"Public web research\",\n\t\t\t\t\tstate: \"started\",\n\t\t\t\t\tnow: new Date(now.getTime() + 6),\n\t\t\t\t\tlease,\n\t\t\t\t});\n\t\t\t\texpect(current.progress.map(entry => entry.attempt)).toEqual([1, 1, 2]);\n\t\t\t\tfor (let index = 0; index < BACKGROUND_JOB_PROGRESS_LIMIT; index++) {\n\t\t\t\t\tcurrent = await storage.jobs.appendProgress({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tjobId: queued.id,\n\t\t\t\t\t\tclaimOwner: \"progress-worker-2\",\n\t\t\t\t\t\tclaimGeneration: secondClaim!.claimGeneration,\n\t\t\t\t\t\tstage: `step-${index}`,\n\t\t\t\t\t\tlabel: `Progress step ${index}`,\n\t\t\t\t\t\tstate: index % 2 === 0 ? \"started\" : \"completed\",\n\t\t\t\t\t\tnow: new Date(now.getTime() + 7 + index),\n\t\t\t\t\t\tlease,\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\texpect(current.progress).toHaveLength(BACKGROUND_JOB_PROGRESS_LIMIT);\n\t\t\t\texpect(current.progress.at(-1)?.stage).toBe(`step-${BACKGROUND_JOB_PROGRESS_LIMIT - 1}`);\n\t\t\t\tlet page = await storage.jobs.list(channelId, 10);\n\t\t\t\texpect(page!.jobs[0]!.progress).toEqual(current.progress);\n\t\t\t\tpage!.jobs[0]!.progress[0]!.label = \"mutated\";\n\t\t\t\texpect((await storage.jobs.get(channelId, queued.id))!.job.progress[0]!.label)\n\t\t\t\t\t.not.toBe(\"mutated\");\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"fences competing lease owners\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet name = id(\"writer\");\n\t\t\t\tlet first = await storage.leases.acquire(name, \"one\", 30_000);\n\t\t\t\texpect(first).toBeDefined();\n\t\t\t\texpect(await storage.leases.acquire(name, \"two\", 30_000)).toBeUndefined();\n\t\t\t\tlet renewed = await storage.leases.renew(first!, 30_000);\n\t\t\t\texpect(renewed!.fencing).toBe(first!.fencing);\n\t\t\t\texpect(await storage.leases.release(renewed!)).toBe(true);\n\t\t\t\tlet second = await storage.leases.acquire(name, \"two\", 30_000);\n\t\t\t\texpect(second!.fencing).toBeGreaterThan(first!.fencing);\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\n\n\t\tit(\"refuses a commit from an expired lease holder\", async () => {\n\t\t\tlet storage = await opened(factory);\n\t\t\ttry {\n\t\t\t\tlet { channelId } = await userAndChannel(storage);\n\t\t\t\tlet name = id(\"short-writer\");\n\t\t\t\tlet first = await storage.leases.acquire(name, \"one\", 5);\n\t\t\t\texpect(first).toBeDefined();\n\t\t\t\tawait Bun.sleep(20);\n\t\t\t\tlet second = await storage.leases.acquire(name, \"two\", 30_000);\n\t\t\t\texpect(second).toBeDefined();\n\n\t\t\t\ttry {\n\t\t\t\t\tawait storage.collaboration.commit({\n\t\t\t\t\t\tchannelId,\n\t\t\t\t\t\tlease: first!,\n\t\t\t\t\t\texpectedRevision: 0,\n\t\t\t\t\t\toperationId: id(\"stale-writer\"),\n\t\t\t\t\t\tepoch: \"epoch-1\",\n\t\t\t\t\t\tupdate: new Uint8Array([1]),\n\t\t\t\t\t\tevents: [],\n\t\t\t\t\t\tnow: new Date(),\n\t\t\t\t\t});\n\t\t\t\t\texpect.unreachable();\n\t\t\t\t} catch (err) {\n\t\t\t\t\texpect(err).toBeInstanceOf(StorageError);\n\t\t\t\t\texpect((err as StorageError).failure).toBe(\"conflict\");\n\t\t\t\t}\n\t\t\t} finally {\n\t\t\t\tawait storage.close();\n\t\t\t}\n\t\t});\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",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,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,127,128,129,130],"tags",[69,70,71,72],"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",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_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,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794436157642,"sidebar","expanded"]