[{"_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","c980963f9a044cdda24cf235875b4f48fd17164b","path","apps/server/src/storage/postgres/adapter.test.ts","oid","437c03956372ce4703132bc76926ce4a487918f3","size",23912,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { SQL } from \"bun\";\nimport { describe, expect, it } from \"bun:test\";\nimport { join } from \"node:path\";\n\nimport { documentSlug } from \"../../channels/slug\";\nimport { storageContract } from \"../contract\";\nimport { StorageError } from \"../errors\";\nimport { ResearchProjectionConflict } from \"../model\";\nimport { contractId, userAndChannel } from \"../contract-support\";\nimport { PostgresStorage } from \"./adapter\";\nimport { migrate, verifyMigrations } from \"./migrations\";\nimport { backfillDocumentSlugs } from \"./migrations/002_document_slugs\";\nimport { sidecarUnansweredDecisions } from \"../../questions/unanswered\";\nimport { UNANSWERED_SIDECARS } from \"../../questions/unanswered.test-fixtures\";\n\nlet url = process.env.TEST_DATABASE_URL;\n\nfunction digest(source: string): string {\n\treturn new Bun.CryptoHasher(\"sha256\").update(source).digest(\"hex\");\n}\n\nif (url) {\n\tstorageContract(\"postgres\", () => new PostgresStorage(url));\n\tit(\"stores only a verifier hash and opaque ciphertext for persistent credentials\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tawait storage.migrate();\n\t\tawait storage.close();\n\t\tlet sql = new SQL(url);\n\t\ttry {\n\t\t\tlet columns = await sql<{ name: string }[]>`\n\t\t\t\tSELECT column_name AS name\n\t\t\t\tFROM information_schema.columns\n\t\t\t\tWHERE table_schema = 'public' AND table_name = 'web_sessions'\n\t\t\t\tORDER BY column_name\n\t\t\t`;\n\t\t\texpect(columns.map(column => column.name)).toEqual([\n\t\t\t\t\"created_at\",\n\t\t\t\t\"credential_ciphertext\",\n\t\t\t\t\"credential_revision\",\n\t\t\t\t\"expires_at\",\n\t\t\t\t\"id\",\n\t\t\t\t\"secret_hash\",\n\t\t\t\t\"user_id\",\n\t\t\t]);\n\t\t} finally {\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"counts unanswered decisions in SQL exactly as the domain does\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tawait storage.migrate();\n\t\tawait storage.close();\n\t\tlet sql = new SQL(url);\n\t\ttry {\n\t\t\tfor (let { name, sidecar, expected } of UNANSWERED_SIDECARS) {\n\t\t\t\tlet source = JSON.stringify(sidecar);\n\t\t\t\tlet [row] = await sql<{ stored: number; parsed: number }[]>`\n\t\t\t\t\tSELECT\n\t\t\t\t\t\tchopin_unanswered_decisions(${source}::jsonb) AS stored,\n\t\t\t\t\t\tchopin_unanswered_decisions(${source}::text::jsonb) AS parsed\n\t\t\t\t`;\n\t\t\t\texpect({ name, ...row }).toEqual({ name, stored: expected, parsed: expected });\n\t\t\t\texpect(sidecarUnansweredDecisions(sidecar)).toBe(expected);\n\t\t\t}\n\t\t} finally {\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"cascades background jobs, artifacts, and research workspaces with their channel\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tlet suffix = crypto.randomUUID();\n\t\tlet channelId = `job-channel-${suffix}`;\n\t\tlet userId = `job-user-${suffix}`;\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet now = new Date();\n\t\t\tawait storage.users.put({ id: userId, login: \"jobs\", avatarUrl: \"\", now });\n\t\t\tawait storage.channels.create({\n\t\t\t\tid: channelId,\n\t\t\t\trepositoryId: `job-repository-${suffix}`,\n\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\trepositoryName: \"score\",\n\t\t\t\ttitle: `Job cascade ${suffix}`,\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet lease = await storage.leases.acquire(`job-writer-${suffix}`, \"test\", 60_000);\n\t\t\tlet queued = await storage.jobs.enqueue({\n\t\t\t\tid: `job-${suffix}`,\n\t\t\t\tchannelId,\n\t\t\t\ttype: \"research-answer\",\n\t\t\t\tversion: 1,\n\t\t\t\torigin: \"user\",\n\t\t\t\ttargetKey: `research-answer:workspace:workspace-${suffix}:turn:turn-${suffix}:answer`,\n\t\t\t\tidempotencyKey: `enqueue-${suffix}`,\n\t\t\t\tfingerprint: `fingerprint-${suffix}`,\n\t\t\t\tinput: { revision: 1 },\n\t\t\t\tavailableAt: now,\n\t\t\t\tnow,\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tlet [claimed] = await storage.jobs.claim({\n\t\t\t\tchannelId,\n\t\t\t\tclaimOwner: \"worker\",\n\t\t\t\tcount: 1,\n\t\t\t\tttlMs: 60_000,\n\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tawait storage.jobs.settle({\n\t\t\t\tchannelId,\n\t\t\t\tjobId: queued.job.id,\n\t\t\t\tclaimOwner: \"worker\",\n\t\t\t\tclaimGeneration: claimed!.claimGeneration,\n\t\t\t\tartifact: { abstract: \"summary\" },\n\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tlet draft = await storage.research.create({\n\t\t\t\tid: `workspace-${suffix}`,\n\t\t\t\tchannelId,\n\t\t\t\ttitle: \"Cascade research\",\n\t\t\t\tproposedQuestion: \"What should be deleted?\",\n\t\t\t\torigin: \"sidebar\",\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tidempotencyKey: `workspace-create-${suffix}`,\n\t\t\t\tfingerprint: `workspace-fingerprint-${suffix}`,\n\t\t\t\tnow: new Date(now.getTime() + 3),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tlet confirmed = await storage.research.confirm({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\tturnId: `turn-${suffix}`,\n\t\t\t\tmessageId: `member-message-${suffix}`,\n\t\t\t\trequestId: `confirm-${suffix}`,\n\t\t\t\tfingerprint: `confirm-fingerprint-${suffix}`,\n\t\t\t\tconfirmedQuery: \"Delete the complete workspace.\",\n\t\t\t\tconfirmedBy: userId,\n\t\t\t\tnow: new Date(now.getTime() + 4),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tawait storage.research.linkJob({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\trole: \"answer\",\n\t\t\t\tjobId: queued.job.id,\n\t\t\t\tnow: new Date(now.getTime() + 5),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tawait storage.research.appendAgentMessage({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId: draft.workspace.id,\n\t\t\t\tid: `agent-message-${suffix}`,\n\t\t\t\tturnId: confirmed.turn.id,\n\t\t\t\ttext: \"Everything is scoped to the parent.\",\n\t\t\t\tsourceJobId: queued.job.id,\n\t\t\t\tnow: new Date(now.getTime() + 6),\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tawait storage.navigation.setLastDocument(userId, channelId, new Date(now.getTime() + 7));\n\t\t\tawait storage.channels.archive({ id: channelId, now: new Date(now.getTime() + 8) });\n\t\t\texpect(await storage.channels.delete(channelId)).toBe(true);\n\t\t} finally {\n\t\t\tawait storage.close();\n\t\t}\n\n\t\tlet sql = new SQL(url);\n\t\ttry {\n\t\t\tlet [counts] = await sql<{\n\t\t\t\tdocuments: number;\n\t\t\t\tslugs: number;\n\t\t\t\tstate: number;\n\t\t\t\tchannels: number;\n\t\t\t\ttargets: number;\n\t\t\t\tjobs: number;\n\t\t\t\tartifacts: number;\n\t\t\t\tworkspaces: number;\n\t\t\t\tturns: number;\n\t\t\t\tmessages: number;\n\t\t\t\tnavigationRows: number;\n\t\t\t}[]>`\n\t\t\t\tSELECT\n\t\t\t\t\t(SELECT count(*)::int FROM channels WHERE id = ${channelId}) AS documents,\n\t\t\t\t\t(SELECT count(*)::int FROM channel_slugs WHERE channel_id = ${channelId}) AS slugs,\n\t\t\t\t\t(SELECT count(*)::int FROM channel_state WHERE channel_id = ${channelId}) AS state,\n\t\t\t\t\t(SELECT count(*)::int FROM background_job_channels WHERE channel_id = ${channelId}) AS channels,\n\t\t\t\t\t(SELECT count(*)::int FROM background_job_targets WHERE channel_id = ${channelId}) AS targets,\n\t\t\t\t\t(SELECT count(*)::int FROM background_jobs WHERE channel_id = ${channelId}) AS jobs,\n\t\t\t\t\t(SELECT count(*)::int FROM background_job_artifacts WHERE job_id = ${`job-${suffix}`}) AS artifacts,\n\t\t\t\t\t(SELECT count(*)::int FROM research_workspaces WHERE channel_id = ${channelId}) AS workspaces,\n\t\t\t\t\t(SELECT count(*)::int FROM research_turns WHERE workspace_id = ${`workspace-${suffix}`}) AS turns,\n\t\t\t\t\t(SELECT count(*)::int FROM research_messages WHERE workspace_id = ${`workspace-${suffix}`}) AS messages,\n\t\t\t\t\t(SELECT count(*)::int FROM user_navigation WHERE user_id = ${userId} AND last_document_id IS NULL) AS \"navigationRows\"\n\t\t\t`;\n\t\t\texpect(counts).toEqual({\n\t\t\t\tdocuments: 0,\n\t\t\t\tslugs: 0,\n\t\t\t\tstate: 0,\n\t\t\t\tchannels: 0,\n\t\t\t\ttargets: 0,\n\t\t\t\tjobs: 0,\n\t\t\t\tartifacts: 0,\n\t\t\t\tworkspaces: 0,\n\t\t\t\tturns: 0,\n\t\t\t\tmessages: 0,\n\t\t\t\tnavigationRows: 1,\n\t\t\t});\n\t\t} finally {\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"rechecks a writer lease after waiting for its row lock\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tlet sql = new SQL(url);\n\t\tlet suffix = crypto.randomUUID();\n\t\tlet locked = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet now = new Date();\n\t\t\tlet userId = `lease-user-${suffix}`;\n\t\t\tlet channelId = `lease-channel-${suffix}`;\n\t\t\tawait storage.users.put({ id: userId, login: \"lease\", avatarUrl: \"\", now });\n\t\t\tawait storage.channels.create({\n\t\t\t\tid: channelId,\n\t\t\t\trepositoryId: `lease-repository-${suffix}`,\n\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\trepositoryName: \"score\",\n\t\t\t\ttitle: `Lease check ${suffix}`,\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet lease = await storage.leases.acquire(`lease-${suffix}`, \"old-writer\", 50);\n\t\t\tlet blocker = sql.begin(async transaction => {\n\t\t\t\tawait transaction`SELECT name FROM storage_leases WHERE name = ${lease!.name} FOR UPDATE`;\n\t\t\t\tlocked.resolve();\n\t\t\t\tawait release.promise;\n\t\t\t});\n\t\t\tawait locked.promise;\n\t\t\tlet enqueue = storage.jobs.enqueue({\n\t\t\t\tid: `lease-job-${suffix}`,\n\t\t\t\tchannelId,\n\t\t\t\ttype: \"document-summary\",\n\t\t\t\tversion: 1,\n\t\t\t\torigin: \"scheduler\",\n\t\t\t\ttargetKey: \"document-summary\",\n\t\t\t\tidempotencyKey: `lease-enqueue-${suffix}`,\n\t\t\t\tfingerprint: `lease-fingerprint-${suffix}`,\n\t\t\t\tinput: { revision: 1 },\n\t\t\t\tavailableAt: now,\n\t\t\t\tnow,\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tlet settled = false;\n\t\t\tvoid enqueue.then(\n\t\t\t\t() => settled = true,\n\t\t\t\t() => settled = true,\n\t\t\t);\n\t\t\tawait Bun.sleep(10);\n\t\t\texpect(settled).toBe(false);\n\t\t\tawait Bun.sleep(75);\n\t\t\trelease.resolve();\n\t\t\tawait blocker;\n\t\t\tawait expect(enqueue).rejects.toMatchObject({ failure: \"conflict\" });\n\t\t\texpect((await storage.jobs.list(channelId, 10))!.jobs).toEqual([]);\n\t\t} finally {\n\t\t\trelease.resolve();\n\t\t\tawait storage.close();\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"replays concurrent idempotent enqueues across independent lease rows\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tlet suffix = crypto.randomUUID();\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet now = new Date();\n\t\t\tlet userId = `idempotency-user-${suffix}`;\n\t\t\tlet channelId = `idempotency-channel-${suffix}`;\n\t\t\tawait storage.users.put({ id: userId, login: \"idempotency\", avatarUrl: \"\", now });\n\t\t\tawait storage.channels.create({\n\t\t\t\tid: channelId,\n\t\t\t\trepositoryId: `idempotency-repository-${suffix}`,\n\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\trepositoryName: \"score\",\n\t\t\t\ttitle: `Idempotency ${suffix}`,\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet firstLease = await storage.leases.acquire(`first-${suffix}`, \"one\", 60_000);\n\t\t\tlet secondLease = await storage.leases.acquire(`second-${suffix}`, \"two\", 60_000);\n\t\t\tlet common = {\n\t\t\t\tchannelId,\n\t\t\t\ttype: \"document-summary\",\n\t\t\t\tversion: 1,\n\t\t\t\torigin: \"scheduler\" as const,\n\t\t\t\ttargetKey: \"document-summary\",\n\t\t\t\tidempotencyKey: `enqueue-${suffix}`,\n\t\t\t\tfingerprint: `fingerprint-${suffix}`,\n\t\t\t\tinput: { revision: 1 },\n\t\t\t\tavailableAt: now,\n\t\t\t\tnow,\n\t\t\t};\n\t\t\tlet results = await Promise.all([\n\t\t\t\tstorage.jobs.enqueue({ ...common, id: `first-job-${suffix}`, lease: firstLease! }),\n\t\t\t\tstorage.jobs.enqueue({ ...common, id: `second-job-${suffix}`, lease: secondLease! }),\n\t\t\t]);\n\t\t\texpect(results.map(result => result.repeated).sort()).toEqual([false, true]);\n\t\t\texpect(new Set(results.map(result => result.job.id)).size).toBe(1);\n\t\t\texpect((await storage.jobs.list(channelId, 10))!.jobs).toHaveLength(1);\n\t\t} finally {\n\t\t\tawait storage.close();\n\t\t}\n\t});\n\n\tit(\"rechecks a writer lease after waiting for the job mutation lock\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tlet sql = new SQL(url);\n\t\tlet suffix = crypto.randomUUID();\n\t\tlet locked = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet now = new Date();\n\t\t\tlet userId = `job-lock-user-${suffix}`;\n\t\t\tlet channelId = `job-lock-channel-${suffix}`;\n\t\t\tawait storage.users.put({ id: userId, login: \"job-lock\", avatarUrl: \"\", now });\n\t\t\tawait storage.channels.create({\n\t\t\t\tid: channelId,\n\t\t\t\trepositoryId: `job-lock-repository-${suffix}`,\n\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\trepositoryName: \"score\",\n\t\t\t\ttitle: `Job lock ${suffix}`,\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet lease = await storage.leases.acquire(`job-lock-${suffix}`, \"old-writer\", 1_000);\n\t\t\tlet blocker = sql.begin(async transaction => {\n\t\t\t\tlet [row] = await transaction<{ pid: number }[]>`\n\t\t\t\t\tSELECT pg_backend_pid() AS pid, pg_advisory_xact_lock(2043237432)\n\t\t\t\t`;\n\t\t\t\tlocked.resolve(row!.pid);\n\t\t\t\tawait release.promise;\n\t\t\t});\n\t\t\tlet blockerPid = await locked.promise;\n\t\t\tlet enqueue = storage.jobs.enqueue({\n\t\t\t\tid: `job-lock-job-${suffix}`,\n\t\t\t\tchannelId,\n\t\t\t\ttype: \"document-summary\",\n\t\t\t\tversion: 1,\n\t\t\t\torigin: \"scheduler\",\n\t\t\t\ttargetKey: \"document-summary\",\n\t\t\t\tidempotencyKey: `job-lock-enqueue-${suffix}`,\n\t\t\t\tfingerprint: `job-lock-fingerprint-${suffix}`,\n\t\t\t\tinput: { revision: 1 },\n\t\t\t\tavailableAt: now,\n\t\t\t\tnow,\n\t\t\t\tlease: lease!,\n\t\t\t});\n\t\t\tlet result = enqueue.then(() => undefined, error => error);\n\t\t\tlet waiting = false;\n\t\t\tfor (let attempt = 0; attempt < 100; attempt++) {\n\t\t\t\tlet [row] = await sql<{ waiting: boolean }[]>`\n\t\t\t\t\tSELECT EXISTS (\n\t\t\t\t\t\tSELECT 1 FROM pg_stat_activity\n\t\t\t\t\t\tWHERE ${blockerPid} = ANY(pg_blocking_pids(pid))\n\t\t\t\t\t) AS waiting\n\t\t\t\t`;\n\t\t\t\tif (row!.waiting) {\n\t\t\t\t\twaiting = true;\n\t\t\t\t\tbreak;\n\t\t\t\t}\n\t\t\t\tawait Bun.sleep(10);\n\t\t\t}\n\t\t\texpect(waiting).toBe(true);\n\t\t\tawait sql`\n\t\t\t\tSELECT pg_sleep(GREATEST(0, EXTRACT(EPOCH FROM (expires_at - clock_timestamp()))))\n\t\t\t\tFROM storage_leases WHERE name = ${lease!.name}\n\t\t\t`;\n\t\t\trelease.resolve();\n\t\t\tawait blocker;\n\t\t\texpect(await result).toMatchObject({ failure: \"conflict\" });\n\t\t\texpect((await storage.jobs.list(channelId, 10))!.jobs).toEqual([]);\n\t\t} finally {\n\t\t\trelease.resolve();\n\t\t\tawait storage.close();\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"serializes a Research projection commit behind a concurrent job failure\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\tlet sql = new SQL(url);\n\t\tlet locked = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\tlet blocker: Promise | undefined;\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet { channelId, userId, lease } = await userAndChannel(storage);\n\t\t\tlet jobLease = await storage.leases.acquire(\n\t\t\t\tcontractId(\"research-job-writer\"),\n\t\t\t\tcontractId(\"research-worker\"),\n\t\t\t\t60_000,\n\t\t\t);\n\t\t\tif (!jobLease) throw new Error(\"test could not acquire a job storage lease\");\n\t\t\tlet now = new Date();\n\t\t\tlet workspaceId = contractId(\"inline-research\");\n\t\t\tlet started = await storage.research.start({\n\t\t\t\tid: workspaceId,\n\t\t\t\tchannelId,\n\t\t\t\ttitle: \"Inline research\",\n\t\t\t\tquestion: \"What changed?\",\n\t\t\t\torigin: \"inline\",\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tturnId: contractId(\"initial-turn\"),\n\t\t\t\tmessageId: contractId(\"initial-message\"),\n\t\t\t\trequestId: contractId(\"initial-request\"),\n\t\t\t\tidempotencyKey: contractId(\"research-start\"),\n\t\t\t\tfingerprint: contractId(\"research-fingerprint\"),\n\t\t\t\tnow,\n\t\t\t\tlease,\n\t\t\t});\n\t\t\tlet job = await storage.jobs.enqueue({\n\t\t\t\tid: contractId(\"research-answer\"),\n\t\t\t\tchannelId,\n\t\t\t\ttype: \"research-answer\",\n\t\t\t\tversion: 1,\n\t\t\t\torigin: \"user\",\n\t\t\t\ttargetKey: `research-answer:workspace:${workspaceId}:turn:${started.turn.id}:answer`,\n\t\t\t\tidempotencyKey: contractId(\"research-enqueue\"),\n\t\t\t\tfingerprint: contractId(\"research-job-fingerprint\"),\n\t\t\t\tinput: { question: \"What changed?\" },\n\t\t\t\tavailableAt: now,\n\t\t\t\tnow,\n\t\t\t\tlease: jobLease,\n\t\t\t});\n\t\t\tawait storage.research.linkJob({\n\t\t\t\tchannelId,\n\t\t\t\tworkspaceId,\n\t\t\t\tturnId: started.turn.id,\n\t\t\t\trole: \"answer\",\n\t\t\t\tjobId: job.job.id,\n\t\t\t\tnow,\n\t\t\t\tlease: jobLease,\n\t\t\t});\n\t\t\tlet [claimed] = await storage.jobs.claim({\n\t\t\t\tchannelId,\n\t\t\t\tclaimOwner: contractId(\"worker\"),\n\t\t\t\tcount: 1,\n\t\t\t\tttlMs: 60_000,\n\t\t\t\tnow: new Date(now.getTime() + 1),\n\t\t\t\tlease: jobLease,\n\t\t\t});\n\t\t\tif (!claimed) throw new Error(\"Research answer job was not claimable\");\n\t\t\tlet initial = await storage.collaboration.load(channelId, now);\n\t\t\tif (!initial) throw new Error(\"Research parent channel could not be loaded\");\n\n\t\t\tblocker = sql.begin(async transaction => {\n\t\t\t\tawait transaction`SELECT id FROM background_jobs WHERE id = ${job.job.id} FOR UPDATE`;\n\t\t\t\tlocked.resolve();\n\t\t\t\tawait release.promise;\n\t\t\t});\n\t\t\tawait locked.promise;\n\n\t\t\tlet failed = storage.jobs.fail({\n\t\t\t\tchannelId,\n\t\t\t\tjobId: job.job.id,\n\t\t\t\tclaimOwner: claimed.claimOwner!,\n\t\t\t\tclaimGeneration: claimed.claimGeneration,\n\t\t\t\treason: \"test failure\",\n\t\t\t\tnow: new Date(now.getTime() + 2),\n\t\t\t\tlease: jobLease,\n\t\t\t});\n\t\t\tlet waitForLockWaiters = async (expected: number) => {\n\t\t\t\tlet deadline = Date.now() + 3_000;\n\t\t\t\twhile (Date.now() < deadline) {\n\t\t\t\t\tlet [row] = await sql<{ count: number }[]>`\n\t\t\t\t\t\tSELECT count(*)::int AS count\n\t\t\t\t\t\tFROM pg_stat_activity\n\t\t\t\t\t\tWHERE datname = current_database()\n\t\t\t\t\t\t\tAND wait_event_type = 'Lock'\n\t\t\t\t\t\t\tAND query ILIKE '%FROM background_jobs%'\n\t\t\t\t\t\t\tAND query ILIKE '%FOR UPDATE%'\n\t\t\t\t\t`;\n\t\t\t\t\tif (row?.count === expected) return;\n\t\t\t\t\tawait Bun.sleep(10);\n\t\t\t\t}\n\t\t\t\tthrow new Error(`expected ${expected} Research row-lock waiters`);\n\t\t\t};\n\t\t\tawait waitForLockWaiters(1);\n\n\t\t\tlet committing = storage.collaboration.commit({\n\t\t\t\tchannelId,\n\t\t\t\tlease,\n\t\t\t\texpectedRevision: initial.channel.revision,\n\t\t\t\toperationId: contractId(\"research-projection-race\"),\n\t\t\t\tepoch: \"research-race-epoch\",\n\t\t\t\tupdate: new Uint8Array([1]),\n\t\t\t\tsidecar: { revision: 1 },\n\t\t\t\tevents: [],\n\t\t\t\tnow,\n\t\t\t\tresearchProjections: [{ id: workspaceId, action: \"add\" }],\n\t\t\t});\n\t\t\tawait waitForLockWaiters(2);\n\t\t\trelease.resolve();\n\t\t\tawait blocker;\n\t\t\texpect((await failed).state).toBe(\"failed\");\n\t\t\tawait expect(committing).rejects.toBeInstanceOf(ResearchProjectionConflict);\n\n\t\t\tlet saved = await storage.collaboration.load(channelId, now);\n\t\t\texpect(saved?.channel.revision).toBe(initial.channel.revision);\n\t\t\texpect(saved?.updates).toHaveLength(0);\n\t\t} finally {\n\t\t\trelease.resolve();\n\t\t\tawait blocker?.catch(() => {});\n\t\t\tawait storage.close();\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"backfills unique readable slugs for channels created before the slug migration\", async () => {\n\t\tlet sql = new SQL(url);\n\t\tlet schema = `slug_migration_${crypto.randomUUID().replaceAll(\"-\", \"\")}`;\n\t\ttry {\n\t\t\tawait sql.unsafe(`CREATE SCHEMA \"${schema}\"`).simple();\n\t\t\tlet initial = await Bun.file(join(import.meta.dir, \"migrations/001_initial.sql\")).text();\n\t\t\tlet slugs = await Bun.file(join(import.meta.dir, \"migrations/002_document_slugs.sql\")).text();\n\t\t\tawait sql.begin(async transaction => {\n\t\t\t\tawait transaction.unsafe(`SET LOCAL search_path TO \"${schema}\"`).simple();\n\t\t\t\tawait transaction.unsafe(initial).simple();\n\t\t\t\tawait transaction`\n\t\t\t\t\tINSERT INTO users (id, login, avatar_url, created_at, updated_at)\n\t\t\t\t\tVALUES ('U_test', 'test', '', now(), now())\n\t\t\t\t`;\n\t\t\t\tlet titles = [\n\t\t\t\t\t\"Release plan\",\n\t\t\t\t\t\"Release-plan!\",\n\t\t\t\t\t\"Résumé 計画\",\n\t\t\t\t\t\"🚀\",\n\t\t\t\t\t\"İstanbul\",\n\t\t\t\t\t\"ΟΣ\",\n\t\t\t\t\t\"\\u0301\",\n\t\t\t\t];\n\t\t\t\tfor (let [index, title] of titles.entries()) {\n\t\t\t\t\tawait transaction`\n\t\t\t\t\t\tINSERT INTO channels (\n\t\t\t\t\t\t\tid, repository_id, repository_owner, repository_name, title,\n\t\t\t\t\t\t\tcreated_by, created_at, updated_at\n\t\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t\t${`channel-${index}`}, 'R_test', 'octo-org', 'score', ${title},\n\t\t\t\t\t\t\t'U_test', ${new Date(1_700_000_000_000 + index)}, now()\n\t\t\t\t\t\t)\n\t\t\t\t\t`;\n\t\t\t\t}\n\t\t\t\tfor (let index = 0; index < 505; index++) {\n\t\t\t\t\tlet punctuation = index.toString(2).replaceAll(\"0\", \"!\").replaceAll(\"1\", \"?\");\n\t\t\t\t\tawait transaction`\n\t\t\t\t\t\tINSERT INTO channels (\n\t\t\t\t\t\t\tid, repository_id, repository_owner, repository_name, title,\n\t\t\t\t\t\t\tcreated_by, created_at, updated_at\n\t\t\t\t\t\t) VALUES (\n\t\t\t\t\t\t\t${`channel-batch-${String(index).padStart(3, \"0\")}`},\n\t\t\t\t\t\t\t'R_test', 'octo-org', 'score', ${`Batch${punctuation}`},\n\t\t\t\t\t\t\t'U_test', ${new Date(1_700_001_000_000 + index)}, now()\n\t\t\t\t\t\t)\n\t\t\t\t\t`;\n\t\t\t\t}\n\t\t\t\tawait transaction.unsafe(slugs).simple();\n\t\t\t\tawait backfillDocumentSlugs(transaction);\n\t\t\t\tlet rows = await transaction<{ channelId: string; slug: string }[]>`\n\t\t\t\t\tSELECT channel_id AS \"channelId\", slug\n\t\t\t\t\tFROM channel_slugs\n\t\t\t\t\tWHERE canonical\n\t\t\t\t\tORDER BY channel_id\n\t\t\t\t`;\n\t\t\t\tlet byId = new Map(rows.map(row => [row.channelId, row.slug]));\n\t\t\t\texpect(titles.map((_, index) => byId.get(`channel-${index}`))).toEqual([\n\t\t\t\t\tdocumentSlug(titles[0]!),\n\t\t\t\t\t`${documentSlug(titles[1]!)}-2`,\n\t\t\t\t\t...titles.slice(2).map(documentSlug),\n\t\t\t\t]);\n\t\t\t\tlet batch = rows.filter(row => row.channelId.startsWith(\"channel-batch-\"));\n\t\t\t\texpect(batch).toHaveLength(505);\n\t\t\t\texpect(new Set(batch.map(row => row.slug)).size).toBe(505);\n\t\t\t\texpect(byId.get(\"channel-batch-000\")).toBe(\"batch\");\n\t\t\t\texpect(byId.get(\"channel-batch-504\")).toBe(\"batch-505\");\n\t\t\t});\n\t\t} finally {\n\t\t\tawait sql.unsafe(`DROP SCHEMA IF EXISTS \"${schema}\" CASCADE`).simple();\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"upgrades a database that recorded user navigation as migration 002 without rewriting history\", async () => {\n\t\tlet sql = new SQL(url, { max: 1 });\n\t\tlet schema = `legacy_navigation_${crypto.randomUUID().replaceAll(\"-\", \"\")}`;\n\t\ttry {\n\t\t\tawait sql.unsafe(`CREATE SCHEMA \"${schema}\"`).simple();\n\t\t\tawait sql.unsafe(`SET search_path TO \"${schema}\"`).simple();\n\t\t\tlet initial = await Bun.file(join(import.meta.dir, \"migrations/001_initial.sql\")).text();\n\t\t\tlet navigation = await Bun.file(\n\t\t\t\tjoin(import.meta.dir, \"migrations/003_user_navigation.sql\"),\n\t\t\t).text();\n\t\t\tawait sql.unsafe(initial).simple();\n\t\t\tawait sql.unsafe(navigation).simple();\n\t\t\tawait sql`\n\t\t\t\tCREATE TABLE chopin_migrations (\n\t\t\t\t\tid text PRIMARY KEY,\n\t\t\t\t\tchecksum text NOT NULL,\n\t\t\t\t\tapplied_at timestamptz NOT NULL DEFAULT now()\n\t\t\t\t)\n\t\t\t`;\n\t\t\tawait sql`\n\t\t\t\tINSERT INTO chopin_migrations (id, checksum)\n\t\t\t\tVALUES\n\t\t\t\t\t('001_initial', ${digest(initial)}),\n\t\t\t\t\t('002_user_navigation', ${digest(navigation)})\n\t\t\t`;\n\n\t\t\tawait migrate(sql);\n\t\t\tawait verifyMigrations(sql);\n\t\t\tlet rows = await sql<{ id: string }[]>`\n\t\t\t\tSELECT id FROM chopin_migrations ORDER BY id\n\t\t\t`;\n\t\t\texpect(rows.map(row => row.id)).toEqual([\n\t\t\t\t\"001_initial\",\n\t\t\t\t\"002_document_slugs\",\n\t\t\t\t\"002_user_navigation\",\n\t\t\t\t\"004_background_jobs\",\n\t\t\t\t\"005_background_job_failures\",\n\t\t\t\t\"006_background_job_progress\",\n\t\t\t\t\"007_research_workspaces\",\n\t\t\t\t\"008_research_repository_listing\",\n\t\t\t\t\"009_navigation_revision\",\n\t\t\t\t\"010_document_archival\",\n\t\t\t\t\"011_document_descriptions\",\n\t\t\t\t\"012_child_channels\",\n\t\t\t\t\"013_research_child_publication\",\n\t\t\t\t\"014_inline_research\",\n\t\t\t\t\"015_planner_inline_reference\",\n\t\t\t\t\"016_persistent_sessions\",\n\t\t\t\t\"017_unanswered_decisions\",\n\t\t\t]);\n\t\t\texpect(await sql<{ table: string | null }[]>`SELECT to_regclass('channel_slugs') AS table`)\n\t\t\t\t.toEqual([\n\t\t\t\t\t{ table: \"channel_slugs\" },\n\t\t\t\t]);\n\t\t\texpect(await sql<{ table: string | null }[]>`SELECT to_regclass('user_navigation') AS table`)\n\t\t\t\t.toEqual([\n\t\t\t\t\t{ table: \"user_navigation\" },\n\t\t\t\t]);\n\t\t\texpect(\n\t\t\t\tawait sql<{ table: string | null }[]>`SELECT to_regclass('research_workspaces') AS table`,\n\t\t\t).toEqual([{ table: \"research_workspaces\" }]);\n\t\t} finally {\n\t\t\tawait sql.unsafe(`DROP SCHEMA IF EXISTS \"${schema}\" CASCADE`).simple();\n\t\t\tawait sql.close();\n\t\t}\n\t});\n\n\tit(\"orders concurrent create and rename slug reservations without deadlocking\", async () => {\n\t\tlet storage = new PostgresStorage(url);\n\t\ttry {\n\t\t\tawait storage.migrate();\n\t\t\tlet suffix = crypto.randomUUID();\n\t\t\tlet now = new Date();\n\t\t\tlet userId = `user-${suffix}`;\n\t\t\tlet repositoryId = `repository-${suffix}`;\n\t\t\tawait storage.users.put({ id: userId, login: \"slug-race\", avatarUrl: \"\", now });\n\t\t\tlet existing = await storage.channels.create({\n\t\t\t\tid: `existing-${suffix}`,\n\t\t\t\trepositoryId,\n\t\t\t\trepositoryOwner: \"octo-org\",\n\t\t\t\trepositoryName: \"score\",\n\t\t\t\ttitle: \"Original title\",\n\t\t\t\tcreatedBy: userId,\n\t\t\t\tnow,\n\t\t\t});\n\t\t\tlet results = await Promise.allSettled([\n\t\t\t\tstorage.channels.rename({ id: existing.id, title: \"Shared title\", now }),\n\t\t\t\tstorage.channels.create({\n\t\t\t\t\tid: `created-${suffix}`,\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: \"Shared title\",\n\t\t\t\t\tcreatedBy: userId,\n\t\t\t\t\tnow,\n\t\t\t\t}),\n\t\t\t]);\n\t\t\texpect(results.filter(result => result.status === \"fulfilled\")).toHaveLength(1);\n\t\t\tlet rejected = results.find(result => result.status === \"rejected\");\n\t\t\texpect(rejected?.status === \"rejected\" && rejected.reason).toBeInstanceOf(StorageError);\n\t\t\tif (rejected?.status === \"rejected\" && rejected.reason instanceof StorageError) {\n\t\t\t\texpect(rejected.reason.failure).toBe(\"conflict\");\n\t\t\t}\n\t\t} finally {\n\t\t\tawait storage.close();\n\t\t}\n\t});\n} else {\n\tdescribe(\"postgres storage\", () => {\n\t\tit.skip(\"needs TEST_DATABASE_URL\", () => {});\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",1794517735590,"sidebar","expanded"]