[{"_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","2e417e7dfb37dcdcdeecc0569e5ecefecf247518","path","apps/server/src/comments.test.ts","oid","bdd3912172c12f070ffbf2808038669e6340aa77","size",23735,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Commenting on the plan, and deciding about it.\n *\n * The properties worth holding onto: a thread is frozen the moment it resolves,\n * only one resolution wins, accepting reaches both the record that owns the\n * decision and the plan that shows it — or neither — and dismissing changes the\n * plan not at all.\n */\n\nimport { afterEach, describe, expect, it } from \"bun:test\";\nimport { mkdtemp, rm, writeFile } from \"node:fs/promises\";\nimport { tmpdir } from \"node:os\";\nimport { join } from \"node:path\";\n\nimport * as Comments from \"./comments/service\";\nimport * as room from \"./plan/room\";\nimport * as Service from \"./plan/service\";\nimport * as Store from \"./comments/store\";\nimport { compose } from \"./comments/prompt\";\n\nimport type { Server } from \"bun\";\nimport type * as Chat from \"./chat/service\";\nimport type { Document } from \"./plan/room\";\nimport type { Record } from \"./comments/service\";\nimport type { Plan } from \"./plan/service\";\nimport type { Socket, SocketData } from \"./wire\";\n\nconst SOURCE = `# Title\n\nThe renderer caches tiles for 60 seconds.\n\nThe second paragraph.\n`;\n\nconst QUOTE = \"caches tiles for 60 seconds\";\n\nasync function document(source = SOURCE): Promise {\n\treturn room.create(source);\n}\n\n/** A thread on a real passage, the way `comment:start` builds one. */\nfunction thread(doc: Document, handle = \"ana\"): { records: Store.Records; record: Record } {\n\tlet passage = room.passageAt(doc, [1], QUOTE, 0, QUOTE.length);\n\n\tlet record: Record = {\n\t\tid: \"01K0N4TR8K7JGM4R1J7PW4R8YJ\",\n\t\tstatus: \"open\",\n\t\tpassage,\n\t\tnotes: [Store.note(handle, \"60s is too long.\")],\n\t};\n\n\treturn { records: new Map([[record.id, record]]), record };\n}\n\n// -- a room, for the parts that need the service rather than the store -------\n\nlet rooms: string[] = [];\nlet opens: Plan[] = [];\n\nafterEach(async () => {\n\t// Sinks are on a timer. Left running they write, and log, after the test\n\t// that made them has finished and put `console.error` back.\n\tfor (let plan of opens) await Service.close(plan);\n\topens = [];\n\tfor (let dir of rooms) await rm(dir, { recursive: true, force: true });\n\trooms = [];\n});\n\n/** Frames the room sent, and to whom. */\ntype Sent = { kind: string; [key: string]: unknown };\n\n/**\n * A room with a plan on disk.\n *\n * Built through `Service.open` rather than by hand: restoring, rebasing on\n * open and the snapshot sink are all part of what the service does, and a\n * stubbed plan would test the parts around them instead of them.\n */\nasync function opened(source = SOURCE, state?: object) {\n\tlet dir = await mkdtemp(join(tmpdir(), \"chopin-comments-\"));\n\trooms.push(dir);\n\tawait writeFile(join(dir, \"plan.mdx\"), source);\n\tif (state) await writeFile(join(dir, \"state.json\"), JSON.stringify(state));\n\n\tlet broadcasts: Sent[] = [];\n\tlet broken: string | undefined;\n\tlet server = {\n\t\tpublish(_topic: string, data: string) {\n\t\t\tlet frame = JSON.parse(data) as Sent;\n\t\t\tif (frame.kind === broken) throw new Error(\"nobody is listening\");\n\t\t\tbroadcasts.push(frame);\n\t\t},\n\t} as unknown as Server;\n\n\tlet plan = await Service.open(\"test\", dir, server);\n\topens.push(plan);\n\treturn {\n\t\tbroadcasts,\n\t\tdir,\n\t\tplan,\n\t\tserver,\n\t\t/**\n\t\t * Make one kind of frame fail to relay.\n\t\t *\n\t\t * One kind rather than all of them: Bun's pub/sub does not throw for a\n\t\t * topic nobody is on, so breaking everything would be simulating a\n\t\t * failure that cannot happen and armouring the code against it. What\n\t\t * can be reasoned about is what happens if a particular relay is lost.\n\t\t */\n\t\tbreakRelay: (kind: string) => {\n\t\t\tbroken = kind;\n\t\t},\n\t};\n}\n\n/** A socket that records what was said to it, and what was said past it. */\nfunction member(handle: string) {\n\tlet replies: Sent[] = [];\n\tlet relayed: Sent[] = [];\n\n\tlet socket = {\n\t\tdata: { handle, client: `client-${handle}`, room: \"test\" },\n\t\tsend(raw: string) {\n\t\t\treplies.push(JSON.parse(raw) as Sent);\n\t\t},\n\t\tpublish(_topic: string, raw: string) {\n\t\t\trelayed.push(JSON.parse(raw) as Sent);\n\t\t},\n\t} as unknown as Socket;\n\n\treturn { relayed, replies, socket };\n}\n\nlet rid = 0;\nfunction ask(payload: T) {\n\treturn { ts: 0, rid: `r${++rid}`, ...payload } as T & { ts: number; rid: string };\n}\n\n/** Enough of a room for the handlers that start a turn. `AGENT=off` throughout. */\nfunction context(plan: Plan, server: Server): Chat.Room {\n\treturn { chat: plan.chat, config: { agent: false }, plan, room: \"test\", server } as Chat.Room;\n}\n\n/** Mark the sentence, the way a client's `comment:start` does. */\nfunction mark(\n\tplan: Plan,\n\tserver: Server,\n\twho: ReturnType,\n\ttext = \"Too long.\",\n): string {\n\tComments.start(\n\t\tplan,\n\t\tserver,\n\t\t\"test\",\n\t\twho.socket,\n\t\task({\n\t\t\tkind: \"comment:start\" as const,\n\t\t\tblocks: [1],\n\t\t\tquote: QUOTE,\n\t\t\toffset: 0,\n\t\t\tlength: QUOTE.length,\n\t\t\ttext,\n\t\t}),\n\t);\n\n\tlet reply = who.replies.findLast(frame => frame.kind === \"comment:start\");\n\tlet thread = reply?.thread as { id: string } | undefined;\n\tif (!thread) throw new Error(`no thread was started: ${JSON.stringify(reply)}`);\n\treturn thread.id;\n}\n\ndescribe(\"a thread while it is open\", () => {\n\tit(\"collects what people say, in order\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\texpect(Store.reply(threads, records, record.id, \"kris\", \"Agreed.\").ok).toBe(true);\n\n\t\texpect(records.get(record.id)!.notes.map(note => note.handle)).toEqual([\"ana\", \"kris\"]);\n\t});\n\n\tit(\"refuses a thread nobody started\", async () => {\n\t\tlet { records } = thread(await document());\n\t\tlet outcome = Store.reply(Store.create(), records, \"nope\", \"kris\", \"Hello?\");\n\n\t\texpect(outcome.ok).toBe(false);\n\t\tif (!outcome.ok) expect(outcome.reason).toBe(\"missing\");\n\t});\n\n\tit(\"stops taking comments once a thread is long enough to be a conversation\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\tfor (let i = record.notes.length; i < Store.MAX_NOTES; i++) {\n\t\t\tStore.reply(threads, records, record.id, \"kris\", `note ${i}`);\n\t\t}\n\t\tlet outcome = Store.reply(threads, records, record.id, \"kris\", \"one more\");\n\n\t\texpect(outcome.ok).toBe(false);\n\t\tif (!outcome.ok) expect(outcome.reason).toBe(\"full\");\n\t});\n\n\t/** Fifty unresolved threads says the room has stopped resolving things. */\n\tit(\"refuses a new thread once too many are unresolved\", async () => {\n\t\tlet { records } = thread(await document());\n\t\tlet sample = records.values().next().value!;\n\t\t// One short of the cap, counting the thread already there.\n\t\tfor (let i = 1; i < Store.MAX_OPEN - 1; i++) {\n\t\t\trecords.set(`extra-${i}`, { ...sample, id: `extra-${i}` });\n\t\t}\n\n\t\texpect(Store.room(records)).toBeUndefined();\n\t\trecords.set(\"one-more\", { ...sample, id: \"one-more\" });\n\t\texpect(Store.room(records)?.reason).toBe(\"full\");\n\t});\n});\n\ndescribe(\"resolving a thread\", () => {\n\tit(\"freezes it, and refuses anything said afterwards\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\tlet claimed = Store.claim(threads, records, record.id, \"accept\", \"kris\", QUOTE);\n\t\texpect(claimed.ok).toBe(true);\n\t\tif (!claimed.ok) return;\n\t\tStore.commit(threads, records, claimed.claim);\n\n\t\texpect(records.get(record.id)!.status).toBe(\"accepted\");\n\t\texpect(records.get(record.id)!.quote).toBe(QUOTE);\n\n\t\tlet late = Store.reply(threads, records, record.id, \"ana\", \"Actually…\");\n\t\texpect(late.ok).toBe(false);\n\t\tif (!late.ok) expect(late.reason).toBe(\"resolved\");\n\t});\n\n\t/**\n\t * Arriving second is not a failure. The thing the caller wanted to know is\n\t * already decided, so they are told the outcome rather than an error.\n\t */\n\tit(\"tells the loser of a race what happened, not that it failed\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\tlet first = Store.claim(threads, records, record.id, \"accept\", \"kris\", QUOTE);\n\t\tif (!first.ok) throw new Error(\"expected a claim\");\n\t\tStore.commit(threads, records, first.claim);\n\n\t\tlet second = Store.claim(threads, records, record.id, \"dismiss\", \"ana\", QUOTE);\n\t\texpect(second.ok).toBe(false);\n\t\tif (!second.ok && second.reason === \"resolved\") {\n\t\t\texpect(second.status).toBe(\"accepted\");\n\t\t\texpect(second.resolver).toBe(\"kris\");\n\t\t} else {\n\t\t\tthrow new Error(\"expected the outcome, not an error\");\n\t\t}\n\t});\n\n\tit(\"refuses a rival while a resolution is in flight\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\tStore.claim(threads, records, record.id, \"accept\", \"kris\", QUOTE);\n\t\tlet rival = Store.claim(threads, records, record.id, \"dismiss\", \"ana\", QUOTE);\n\n\t\texpect(rival.ok).toBe(false);\n\t\tif (!rival.ok) expect(rival.reason).toBe(\"resolving\");\n\t});\n\n\t/**\n\t * The durable half is the `` node. If it cannot be written the\n\t * decision is not final, and the thread has to be left in a state every\n\t * client already knows how to render — which is the one it was in.\n\t */\n\tit(\"leaves the thread open when the plan could not be told\", async () => {\n\t\tlet { records, record } = thread(await document());\n\t\tlet threads = Store.create();\n\n\t\tlet claimed = Store.claim(threads, records, record.id, \"accept\", \"kris\", QUOTE);\n\t\tif (!claimed.ok) throw new Error(\"expected a claim\");\n\t\tStore.rollback(threads, claimed.claim);\n\n\t\texpect(records.get(record.id)!.status).toBe(\"open\");\n\t\texpect(Store.reply(threads, records, record.id, \"ana\", \"Still talking.\").ok).toBe(true);\n\t});\n});\n\ndescribe(\"projecting a decision\", () => {\n\tit(\"puts an accepted thread into the plan, and leaves a dismissed one out\", async () => {\n\t\tlet doc = await document();\n\t\tlet { record } = thread(doc);\n\n\t\troom.insertDecision(doc, {\n\t\t\tid: record.id,\n\t\t\tquote: QUOTE,\n\t\t\tby: \"kris\",\n\t\t\tat: \"2026-07-28T10:14:00Z\",\n\t\t\tnotes: record.notes.map(note => ({ by: note.handle, text: note.text })),\n\t\t});\n\n\t\tlet source = room.project(doc);\n\t\texpect(source).toContain(` {\n\t\tlet doc = await document();\n\t\tlet { record } = thread(doc);\n\n\t\troom.insertDecision(doc, {\n\t\t\tid: record.id,\n\t\t\tquote: QUOTE,\n\t\t\tby: \"kris\",\n\t\t\tat: \"2026-07-28T10:14:00Z\",\n\t\t\tnotes: [{ by: \"ana\", text: \"Line one.\\nLine two.\" }],\n\t\t});\n\n\t\t// What `plan.mdx` would hold, read back as the server reads it on boot.\n\t\texpect(() => room.validate(room.project(doc))).not.toThrow();\n\t});\n});\n\ndescribe(\"opening a room whose sidecar is damaged\", () => {\n\t/**\n\t * `plan.mdx` is a file a person can edit between runs, and `state.json` sits\n\t * beside it. A record that cannot be carried onto the rebuilt document is a\n\t * decision nobody can point at — not a room nobody can open. Letting it\n\t * throw would fail `plan:open`, and a client whose open is refused sits\n\t * there locked with the chrome saying it is still loading.\n\t */\n\tit(\"still opens when a thread record cannot be carried forward\", async () => {\n\t\tlet damaged = {\n\t\t\trevision: 1,\n\t\t\tquestions: [],\n\t\t\tthreads: [{\n\t\t\t\tid: \"01K0N4TR8K7JGM4R1J7PW4R8YJ\",\n\t\t\t\tstatus: \"accepted\",\n\t\t\t\t// No blocks, no positions: whatever wrote this, it is not a passage.\n\t\t\t\tpassage: null,\n\t\t\t\tnotes: [{ id: \"n1\", handle: \"ana\", text: \"Too long.\", ts: 1 }],\n\t\t\t\tquote: QUOTE,\n\t\t\t\tresolver: \"ana\",\n\t\t\t\tat: 2,\n\t\t\t}],\n\t\t};\n\n\t\tlet complain = console.error;\n\t\tconsole.error = () => {};\n\t\ttry {\n\t\t\tlet { plan, server } = await opened(SOURCE, damaged);\n\n\t\t\t// The room is open and usable: a new thread can still be marked.\n\t\t\tlet ana = member(\"ana\");\n\t\t\texpect(() => mark(plan, server, ana)).not.toThrow();\n\t\t\texpect(room.project(plan.document)).toContain(QUOTE);\n\n\t\t\t// The damaged record would be carried forward again on the way out,\n\t\t\t// logging after this test has put `console.error` back.\n\t\t\tplan.sink.cancel();\n\t\t} finally {\n\t\t\tconsole.error = complain;\n\t\t}\n\t});\n});\n\ndescribe(\"a thread across a restart\", () => {\n\t/**\n\t * A restart is an epoch rotation: every stored position was expressed in a\n\t * history the new document does not have. The quote is the only way back,\n\t * and it has to happen before anybody joins — a client that resolves\n\t * nothing shows a thread with no highlight and no way to tell why.\n\t */\n\tit(\"recovers its passage against a document it has never seen\", async () => {\n\t\tlet doc = await document();\n\t\tlet { record } = thread(doc);\n\n\t\t// The same source, under a fresh epoch, as `open` rebuilds it on boot.\n\t\tlet restarted = await room.replace(room.project(doc));\n\t\texpect(room.locate(restarted, record.passage)).toBeUndefined();\n\n\t\tlet carried = room.rebasePassage(restarted, record.passage);\n\t\texpect(carried.drifted).toBeUndefined();\n\t\texpect(room.locate(restarted, carried)).toBeDefined();\n\t\texpect(carried.quote).toBe(QUOTE);\n\t});\n});\n\ndescribe(\"marking a passage over the wire\", () => {\n\tit(\"mints the thread and tells the rest of the room where it points\", async () => {\n\t\tlet { broadcasts, plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\n\t\texpect(ana.replies[0]).toMatchObject({ kind: \"comment:start\", ok: true });\n\t\texpect(ana.relayed[0]).toMatchObject({ kind: \"comment:opened\" });\n\n\t\t// The passage never rides with the thread; it comes on plan:anchors,\n\t\t// which has to follow immediately or the card has nothing to highlight.\n\t\texpect(ana.replies[0]?.thread).not.toHaveProperty(\"passage\");\n\t\tlet anchors = broadcasts.findLast(frame => frame.kind === \"plan:anchors\");\n\t\tlet pointed = (anchors?.threads as Array<{ thread: string }> | undefined)\n\t\t\t?.find(each => each.thread === id);\n\t\texpect(pointed).toMatchObject({ subject: { quote: QUOTE } });\n\t});\n\n\t/**\n\t * Finding the quote is the concurrency check. Naming a block that no longer\n\t * holds the phrase has to be refused rather than marking whatever is there.\n\t */\n\tit(\"refuses a selection the plan has moved out from under\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\n\t\tComments.start(\n\t\t\tplan,\n\t\t\tserver,\n\t\t\t\"test\",\n\t\t\tana.socket,\n\t\t\task({\n\t\t\t\tkind: \"comment:start\" as const,\n\t\t\t\tblocks: [0],\n\t\t\t\tquote: QUOTE,\n\t\t\t\toffset: 0,\n\t\t\t\tlength: QUOTE.length,\n\t\t\t\ttext: \"Too long.\",\n\t\t\t}),\n\t\t);\n\n\t\texpect(ana.replies[0]).toMatchObject({ ok: false, reason: \"invalid\" });\n\t\texpect(plan.threads.size).toBe(0);\n\t});\n\n\tit(\"refuses a comment with nothing in it\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\n\t\tComments.start(\n\t\t\tplan,\n\t\t\tserver,\n\t\t\t\"test\",\n\t\t\tana.socket,\n\t\t\task({\n\t\t\t\tkind: \"comment:start\" as const,\n\t\t\t\tblocks: [1],\n\t\t\t\tquote: QUOTE,\n\t\t\t\toffset: 0,\n\t\t\t\tlength: QUOTE.length,\n\t\t\t\ttext: \" \",\n\t\t\t}),\n\t\t);\n\n\t\texpect(ana.replies[0]).toMatchObject({ ok: false, reason: \"invalid\" });\n\t\texpect(plan.threads.size).toBe(0);\n\t});\n\n\tit(\"keeps a dismissed thread off the wire for whoever joins next\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\t\tawait Comments.dismiss(\n\t\t\tcontext(plan, server),\n\t\t\tana.socket,\n\t\t\task({ kind: \"comment:dismiss\" as const, id }),\n\t\t);\n\n\t\tlet joiner = member(\"kris\");\n\t\tComments.greet(plan, joiner.socket);\n\n\t\tlet sync = joiner.replies.find(frame => frame.kind === \"comment:sync\");\n\t\texpect(sync?.threads).toEqual([]);\n\t\t// The record survives; it is only hidden.\n\t\texpect(plan.threads.get(id)?.status).toBe(\"dismissed\");\n\t});\n});\n\ndescribe(\"accepting, as the service orders it\", () => {\n\tasync function accepted(options: { failPublish?: boolean } = {}) {\n\t\tlet { breakRelay, broadcasts, plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\t\tana.replies.length = 0;\n\n\t\t// The document delta, which is what carries the new node to clients.\n\t\tif (options.failPublish) breakRelay(\"plan:update\");\n\t\tawait Comments.accept(\n\t\t\tcontext(plan, server),\n\t\t\tana.socket,\n\t\t\task({ kind: \"comment:accept\" as const, id }),\n\t\t);\n\t\treturn { ana, broadcasts, id, plan };\n\t}\n\n\tit(\"reaches the record and the plan together\", async () => {\n\t\tlet { ana, id, plan } = await accepted();\n\n\t\texpect(ana.replies.at(-1)).toMatchObject({ kind: \"comment:accept\", ok: true, resolver: \"ana\" });\n\t\texpect(plan.threads.get(id)?.status).toBe(\"accepted\");\n\t\texpect(plan.threads.get(id)?.quote).toBe(QUOTE);\n\t\texpect(room.project(plan.document)).toContain(`` in a plan whose\n\t * record says the thread is open — and the next accept would append a\n\t * second node carrying the same id. A relay nobody received is recoverable.\n\t */\n\tit(\"stands even when the room could not be told\", async () => {\n\t\t// The relay failing is the point, and it logs. Quietened so the run\n\t\t// does not print a stack trace that reads like a real one.\n\t\tlet complain = console.error;\n\t\tconsole.error = () => {};\n\t\tlet { id, plan } = await accepted({ failPublish: true }).finally(() => {\n\t\t\tconsole.error = complain;\n\t\t});\n\n\t\texpect(plan.threads.get(id)?.status).toBe(\"accepted\");\n\t\tlet source = room.project(plan.document);\n\t\texpect(source.split(`id=\"${id}\"`)).toHaveLength(2);\n\t});\n\n\tit(\"says nothing more can be added, and nobody can resolve it twice\", async () => {\n\t\tlet { id, plan } = await accepted();\n\t\tlet kris = member(\"kris\");\n\n\t\tComments.respond(plan, kris.socket, ask({ kind: \"comment:reply\" as const, id, text: \"Wait.\" }));\n\t\texpect(kris.replies.at(-1)).toMatchObject({ ok: false, reason: \"resolved\" });\n\n\t\tlet after = context(plan, {} as Server);\n\t\tawait Comments.dismiss(after, kris.socket, ask({ kind: \"comment:dismiss\" as const, id }));\n\t\texpect(kris.replies.at(-1)).toMatchObject({\n\t\t\tok: false,\n\t\t\treason: \"resolved\",\n\t\t\tstatus: \"accepted\",\n\t\t\tresolver: \"ana\",\n\t\t});\n\t});\n\n\tit(\"leaves the plan alone when the thread is dismissed instead\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\t\tawait Comments.dismiss(\n\t\t\tcontext(plan, server),\n\t\t\tana.socket,\n\t\t\task({ kind: \"comment:dismiss\" as const, id }),\n\t\t);\n\n\t\texpect(plan.threads.get(id)?.status).toBe(\"dismissed\");\n\t\texpect(room.project(plan.document)).not.toContain(\" {\n\tasync function accepted() {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\t\tawait Comments.accept(\n\t\t\tcontext(plan, server),\n\t\t\tana.socket,\n\t\t\task({ kind: \"comment:accept\" as const, id }),\n\t\t);\n\t\treturn { id, plan };\n\t}\n\n\t/** An open thread asks nothing of the agent; there is no decision yet. */\n\tit(\"owes nothing while it is still being discussed\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tmark(plan, server, ana);\n\n\t\texpect(Comments.outstanding(plan)).toEqual([]);\n\t\texpect(Comments.anchors(plan)[0]?.result.pending).toBe(false);\n\t});\n\n\tit(\"owes a review the moment it is accepted, and stops when it is anchored\", async () => {\n\t\tlet { id, plan } = await accepted();\n\n\t\texpect(Comments.outstanding(plan)).toEqual([{ thread: id, reason: \"missing\" }]);\n\t\texpect(Comments.applied(plan, id)).toBe(false);\n\n\t\tlet digest = room.digests(plan.document)[1]!;\n\t\texpect(Comments.relate(plan, id, [{ index: 1, digest }])).toBeUndefined();\n\n\t\texpect(Comments.outstanding(plan)).toEqual([]);\n\t\texpect(Comments.applied(plan, id)).toBe(true);\n\t});\n\n\t/** An empty list is a real answer: reviewed, deliberately related to nothing. */\n\tit(\"accepts that a revision produced nothing worth pointing at\", async () => {\n\t\tlet { id, plan } = await accepted();\n\n\t\texpect(Comments.relate(plan, id, [])).toBeUndefined();\n\t\texpect(Comments.applied(plan, id)).toBe(true);\n\t});\n\n\tit(\"refuses to anchor against a block that has changed\", async () => {\n\t\tlet { id, plan } = await accepted();\n\n\t\texpect(Comments.relate(plan, id, [{ index: 1, digest: \"sha256:stale\" }]))\n\t\t\t.toContain(\"has changed\");\n\t});\n\n\tit(\"refuses to anchor a thread nobody accepted\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\n\t\texpect(Comments.relate(plan, id, [])).toContain(\"was not accepted\");\n\t});\n\n\t/**\n\t * The agent is told to say what its revision produced, and when it does\n\t * that answer is the better one. But a thread whose result is never\n\t * anchored points at nothing for good — and by then the prose it was about\n\t * is gone, because rewriting it is what acceptance asked for.\n\t */\n\tit(\"takes the blocks a turn wrote when the agent does not say\", async () => {\n\t\tlet { id, plan } = await accepted();\n\t\texpect(Comments.applied(plan, id)).toBe(false);\n\n\t\tComments.attribute(plan, id, [1, 2]);\n\n\t\texpect(Comments.applied(plan, id)).toBe(true);\n\t\texpect(plan.threads.get(id)?.result?.anchors).toHaveLength(2);\n\t});\n\n\tit(\"does not coarsen an answer the agent already gave\", async () => {\n\t\tlet { id, plan } = await accepted();\n\t\tlet digest = room.digests(plan.document)[1]!;\n\t\tComments.relate(plan, id, [{ index: 1, digest }]);\n\n\t\t// The agent picked one block; a later guess must not widen it to two.\n\t\tComments.attribute(plan, id, [1, 2]);\n\n\t\texpect(plan.threads.get(id)?.result?.anchors).toHaveLength(1);\n\t});\n\n\t/** Once an edit has invalidated it, there is nothing left to preserve. */\n\tit(\"takes over again once the plan has moved under the agent's answer\", async () => {\n\t\tlet { id, plan } = await accepted();\n\t\tlet digest = room.digests(plan.document)[1]!;\n\t\tComments.relate(plan, id, [{ index: 1, digest }]);\n\t\tComments.invalidate(plan, \"plan_changed\");\n\n\t\tComments.attribute(plan, id, [1, 2]);\n\n\t\texpect(Comments.applied(plan, id)).toBe(true);\n\t\texpect(plan.threads.get(id)?.result?.anchors).toHaveLength(2);\n\t});\n\n\tit(\"attributes nothing to a thread nobody accepted\", async () => {\n\t\tlet { plan, server } = await opened();\n\t\tlet ana = member(\"ana\");\n\t\tlet id = mark(plan, server, ana);\n\n\t\tComments.attribute(plan, id, [1]);\n\n\t\texpect(plan.threads.get(id)?.result).toBeUndefined();\n\t});\n\n\tit(\"attributes nothing when a turn wrote nothing\", async () => {\n\t\tlet { id, plan } = await accepted();\n\n\t\tComments.attribute(plan, id, []);\n\n\t\texpect(plan.threads.get(id)?.result).toBeUndefined();\n\t});\n\n\t/**\n\t * The prose a decision produced is the thing most likely to have been\n\t * rewritten, so an edit puts it back on the agent's list rather than\n\t * leaving a link to where it used to be.\n\t */\n\tit(\"owes it again once the plan moves underneath\", async () => {\n\t\tlet { id, plan } = await accepted();\n\t\tlet digest = room.digests(plan.document)[1]!;\n\t\tComments.relate(plan, id, [{ index: 1, digest }]);\n\n\t\tComments.invalidate(plan, \"plan_changed\");\n\n\t\texpect(Comments.outstanding(plan)).toEqual([{ thread: id, reason: \"plan_changed\" }]);\n\t});\n});\n\ndescribe(\"what the agent is told\", () => {\n\tit(\"quotes the passage and the whole thread\", async () => {\n\t\tlet { record } = thread(await document());\n\t\tlet prompt = compose(record, QUOTE);\n\n\t\texpect(prompt.startsWith(\"accepted a comment\")).toBe(true);\n\t\texpect(prompt).toContain(`> ${QUOTE}`);\n\t\texpect(prompt).toContain(\"@ana: 60s is too long.\");\n\t\texpect(prompt).toContain(record.id);\n\t});\n\n\t/** A rewritten passage is more information, not less. */\n\tit(\"says so when the prose has moved on, and quotes both\", async () => {\n\t\tlet { record } = thread(await document());\n\t\tlet prompt = compose(record, QUOTE, \"caches tiles for 10 seconds\");\n\n\t\texpect(prompt).toContain(\"has since been rewritten\");\n\t\texpect(prompt).toContain(\"> caches tiles for 10 seconds\");\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",1794440978516,"sidebar","expanded"]