[{"_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","584e50fc45fc5defbf392fb39e1ca3d9edd8a421","path","apps/server/src/chat/queue.test.ts","oid","cb023f3a077b290577556ee665866586351a8aab","size",25666,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Turns that something other than a message started.\n *\n * Accepting a comment is an instruction, so it starts a turn the same way a\n * message does — through the same queue, with the same ceiling. What differs is\n * that a button press is not a thing anybody said, so the transcript has to be\n * told why the agent began moving, and that the work may already be done by the\n * time the turn comes up.\n */\n\nimport { describe, expect, it } from \"bun:test\";\nimport { ulid } from \"@chopin/dialect\";\n\nimport * as Chat from \"./service\";\n\nimport type { Server } from \"bun\";\nimport type { Chat as Wire, Request } from \"@chopin/protocol\";\nimport type { Config } from \"../config\";\nimport type { Plan } from \"../plan/service\";\nimport type { Socket } from \"../wire\";\nimport type { SocketData } from \"../wire\";\nimport type { ReferenceService } from \"./references\";\n\ntype Sent = {\n\tkind: string;\n\tid?: string;\n\tmessage?: string;\n\tqueued?: boolean;\n\trid?: string;\n\t[key: string]: unknown;\n};\n\nfunction room(options: { agent?: boolean; busy?: boolean } = {}) {\n\tlet sent: Sent[] = [];\n\tlet chat = Chat.create();\n\tchat.busy = options.busy ?? false;\n\n\tlet server = {\n\t\tpublish(_topic: string, data: string) {\n\t\t\tsent.push(JSON.parse(data) as Sent);\n\t\t},\n\t} as unknown as Server;\n\n\tlet context: Chat.Room = {\n\t\tchat,\n\t\tconfig: { agent: options.agent ?? true } as Config,\n\t\tplan: { chat } as Plan,\n\t\troom: \"test\",\n\t\tserver,\n\t\tauth: {} as Chat.Room[\"auth\"],\n\t\tclaimantSessionId: \"session\",\n\t\trepository: { id: \"repo\", owner: \"owner\", name: \"repo\", defaultBranch: \"main\" },\n\t\tpersist: async () => {},\n\t};\n\n\treturn { chat, context, sent };\n}\n\n/** What the transcript gained, in order. */\nfunction said(sent: Sent[]): string[] {\n\treturn sent\n\t\t.filter(frame => frame.kind === \"chat:message\")\n\t\t.map(frame => (frame.entry as { text: string }).text);\n}\n\nfunction sender(handle = \"ana\", userId = `U_${handle}`, frames: Sent[] = []): Socket {\n\treturn {\n\t\tdata: { handle, principalId: userId },\n\t\tsend(value: string) {\n\t\t\tframes.push(JSON.parse(value) as Sent);\n\t\t},\n\t} as unknown as Socket;\n}\n\nfunction message(\n\ttext: string,\n\tto: Wire.Destination,\n\treferences?: Wire.ReferenceRequest[],\n\trid = \"request\",\n\trequestId: string = crypto.randomUUID(),\n): Request {\n\treturn {\n\t\tkind: \"chat:send\",\n\t\trid,\n\t\trequestId,\n\t\ttext,\n\t\tto,\n\t\tts: 0,\n\t\t...(references ? { references } : {}),\n\t};\n}\n\nfunction resolvedReference(text = \"#release\"): Wire.DocumentReference {\n\treturn {\n\t\tid: ulid(),\n\t\tkind: \"document\",\n\t\tstart: 0,\n\t\tend: text.length,\n\t\tlabel: \"#Release\",\n\t\thref: \"/documents/owner/repo/release\",\n\t\trepositoryId: \"repo\",\n\t\tobservedRevision: 1,\n\t\tchannelId: crypto.randomUUID(),\n\t\tobservedSourceHash: `sha256:${\"0\".repeat(64)}`,\n\t};\n}\n\nfunction referenceResolver(reference: Wire.Reference): ReferenceService {\n\treturn {\n\t\tresolve: async () => ({\n\t\t\ttext: reference.label,\n\t\t\treferences: [reference],\n\t\t}),\n\t} as unknown as ReferenceService;\n}\n\ndescribe(\"sending to a named destination\", () => {\n\tit(\"keeps a planner message in the queue until its turn begins\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\n\t\tawait Chat.send(context, sender(), message(\"draft the migration\", \"planner\"));\n\n\t\texpect(chat.entries).toHaveLength(0);\n\t\texpect(chat.waiting).toMatchObject([{\n\t\t\thandle: \"ana\",\n\t\t\ttext: \"draft the migration\",\n\t\t\tuserId: \"U_ana\",\n\t\t}]);\n\t});\n\n\tit(\"sends to the room even when the prose contains the typing shortcut\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\n\t\tawait Chat.send(context, sender(), message(\"ask @chopin about this later\", \"room\"));\n\n\t\texpect(chat.waiting).toHaveLength(0);\n\t\texpect(chat.entries[0]).toMatchObject({\n\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\ttext: \"ask @chopin about this later\",\n\t\t});\n\t});\n\n\tit(\"persists room references and retains them in Planner backscroll\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet reference = resolvedReference();\n\t\tcontext.references = referenceResolver(reference);\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(),\n\t\t\tmessage(\"#release\", \"room\", [{\n\t\t\t\tkind: \"document\",\n\t\t\t\tchannelId: reference.channelId,\n\t\t\t\tstart: 0,\n\t\t\t\tend: 8,\n\t\t\t}]),\n\t\t);\n\t\texpect(chat.entries[0]?.references).toEqual([reference]);\n\t\texpect(chat.backscroll[0]?.references).toEqual([reference]);\n\t});\n\n\tit(\"persists references on an immediate Planner member entry\", async () => {\n\t\tlet { chat, context } = room({ agent: false });\n\t\tlet reference = resolvedReference();\n\t\tlet replies: Sent[] = [];\n\t\tcontext.references = referenceResolver(reference);\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", replies),\n\t\t\tmessage(\"#release\", \"planner\", [{\n\t\t\t\tkind: \"document\",\n\t\t\t\tchannelId: reference.channelId,\n\t\t\t\tstart: 0,\n\t\t\t\tend: 8,\n\t\t\t}]),\n\t\t);\n\t\texpect(chat.entries[0]).toMatchObject({\n\t\t\tauthor: { kind: \"member\" },\n\t\t\treferences: [reference],\n\t\t});\n\t\texpect(replies[0]).toMatchObject({\n\t\t\tkind: \"chat:send\",\n\t\t\tid: chat.entries[0]?.id,\n\t\t\tqueued: false,\n\t\t});\n\t});\n\n\tit(\"carries references on the visible queue and persists them when the turn starts\", async () => {\n\t\tlet { chat, context, sent } = room({ busy: true });\n\t\tlet reference = resolvedReference();\n\t\tcontext.references = referenceResolver(reference);\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(),\n\t\t\tmessage(\"#release\", \"planner\", [{\n\t\t\t\tkind: \"document\",\n\t\t\t\tchannelId: reference.channelId,\n\t\t\t\tstart: 0,\n\t\t\t\tend: 8,\n\t\t\t}]),\n\t\t);\n\t\texpect(chat.entries).toEqual([]);\n\t\texpect(chat.waiting[0]?.references).toEqual([reference]);\n\t\texpect(sent.findLast(frame => frame.kind === \"chat:queue\")?.waiting).toEqual([\n\t\t\texpect.objectContaining({ references: [reference] }),\n\t\t]);\n\t\tChat.pending(chat);\n\t\texpect(chat.entries[0]?.references).toEqual([reference]);\n\t});\n\n\tit(\"rejects an unresolvable reference before changing transcript, queue, or backscroll\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet replies: Sent[] = [];\n\t\tcontext.references = {\n\t\t\tresolve: async () => {\n\t\t\t\tthrow new Error(\"target moved\");\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", replies),\n\t\t\tmessage(\"#release\", \"planner\", [{\n\t\t\t\tkind: \"document\",\n\t\t\t\tchannelId: crypto.randomUUID(),\n\t\t\t\tstart: 0,\n\t\t\t\tend: 8,\n\t\t\t}]),\n\t\t);\n\t\texpect(chat.entries).toEqual([]);\n\t\texpect(chat.waiting).toEqual([]);\n\t\texpect(chat.backscroll).toEqual([]);\n\t\texpect(replies).toEqual([\n\t\t\texpect.objectContaining({\n\t\t\t\tkind: \"session:error\",\n\t\t\t\tmessage: \"invalid or unavailable chat reference\",\n\t\t\t}),\n\t\t]);\n\t});\n\n\tit(\"removes the typing shortcut from a queued planner message\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\n\t\tawait Chat.send(context, sender(), message(\"@chopin draft the migration\", \"planner\"));\n\n\t\texpect(chat.waiting[0]?.text).toBe(\"draft the migration\");\n\t});\n\n\tit(\"keeps queued member identity and session provenance off the wire\", async () => {\n\t\tlet { context, sent } = room({ busy: true });\n\t\tawait Chat.send(context, sender(\"ana\", \"U_private\"), message(\"research this\", \"planner\"));\n\n\t\tlet queue = sent.findLast(frame => frame.kind === \"chat:queue\");\n\t\texpect(queue?.waiting).toEqual([{\n\t\t\tid: expect.any(String),\n\t\t\thandle: \"ana\",\n\t\t\ttext: \"research this\",\n\t\t}]);\n\t});\n\n\tit(\"moves a queued message into the transcript when it becomes pending\", () => {\n\t\tlet { chat } = room();\n\t\tchat.waiting.push({\n\t\t\tid: \"w1\",\n\t\t\thandle: \"ana\",\n\t\t\ttext: \"draft the migration\",\n\t\t\tmessage: true,\n\t\t\tuserId: \"U_ana\",\n\t\t});\n\n\t\tlet pending = Chat.pending(chat);\n\n\t\texpect(pending?.userId).toBe(\"U_ana\");\n\t\texpect(chat.entries).toMatchObject([{\n\t\t\tid: \"w1\",\n\t\t\tauthor: { kind: \"member\", handle: \"ana\" },\n\t\t\ttext: \"draft the migration\",\n\t\t}]);\n\t});\n\n\tit(\"ignores a destination the protocol does not name\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\n\t\tawait Chat.send(context, sender(), message(\"draft the migration\", \"later\" as Wire.Destination));\n\n\t\texpect(chat.entries).toHaveLength(0);\n\t\texpect(chat.waiting).toHaveLength(0);\n\t});\n\n\tit(\"keeps planner requests out of a queue when the agent is off\", async () => {\n\t\tlet { chat, context, sent } = room({ agent: false });\n\n\t\tawait Chat.send(context, sender(), message(\"draft the migration\", \"planner\"));\n\n\t\texpect(chat.busy).toBe(false);\n\t\texpect(chat.waiting).toHaveLength(0);\n\t\texpect(said(sent)).toEqual([\n\t\t\t\"draft the migration\",\n\t\t\t\"The agent is not running, so the plan has not been revised.\",\n\t\t]);\n\t});\n\n\tit(\"replies only after a room message is durably persisted\", async () => {\n\t\tlet { chat, context, sent } = room({ busy: true });\n\t\tlet entered = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\tcontext.persist = async () => {\n\t\t\tentered.resolve();\n\t\t\tawait release.promise;\n\t\t};\n\t\tlet replies: Sent[] = [];\n\t\tlet sending = Chat.send(context, sender(\"ana\", \"U_ana\", replies), message(\"first\", \"room\"));\n\t\tawait entered.promise;\n\t\texpect(replies).toEqual([]);\n\t\texpect(sent).toEqual([]);\n\t\trelease.resolve();\n\t\tawait sending;\n\t\texpect(replies).toEqual([\n\t\t\texpect.objectContaining({ kind: \"chat:send\", rid: \"request\", queued: false }),\n\t\t]);\n\t\texpect(replies[0]?.id).toBe(chat.entries[0]?.id);\n\t\texpect(sent[0]).toMatchObject({ kind: \"chat:message\", entry: { id: replies[0]?.id } });\n\t\texpect(sent[0]?.entry).not.toHaveProperty(\"delivery\");\n\t\texpect(chat.entries[0]).toHaveProperty(\"delivery\");\n\t});\n\n\tit(\"accepts a legacy send without a request id during rollout\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet replies: Sent[] = [];\n\t\tlet legacy = { ...message(\"legacy\", \"room\") } as\n\t\t\t& Omit<\n\t\t\t\tRequest,\n\t\t\t\t\"requestId\"\n\t\t\t>\n\t\t\t& { requestId?: string };\n\t\tdelete legacy.requestId;\n\n\t\tawait Chat.send(context, sender(\"ana\", \"U_ana\", replies), legacy as Request);\n\n\t\texpect(replies[0]).toMatchObject({ kind: \"chat:send\", queued: false });\n\t\texpect(chat.entries[0]?.text).toBe(\"legacy\");\n\t\texpect(chat.entries[0]?.id).toMatch(\n\t\t\t/^[0-9a-f]{8}-[0-9a-f]{4}-4[0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/,\n\t\t);\n\t});\n\n\tit(\"acknowledges a queued entry with its durable future entry id\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet replies: Sent[] = [];\n\t\tawait Chat.send(context, sender(\"ana\", \"U_ana\", replies), message(\"next\", \"planner\"));\n\t\texpect(replies).toEqual([\n\t\t\texpect.objectContaining({ kind: \"chat:send\", rid: \"request\", queued: true }),\n\t\t]);\n\t\tlet id = replies[0]?.id;\n\t\tif (!id) throw new Error(\"queued send reply has no id\");\n\t\texpect(id).toBe(chat.waiting[0]?.id);\n\t\tChat.pending(chat);\n\t\texpect(chat.entries[0]?.id).toBe(id);\n\t});\n\n\tit(\"serializes resolution and acceptance in arrival order\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet entered = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\tlet resolving: string[] = [];\n\t\tcontext.references = {\n\t\t\tresolve: async (input: { text: string }) => {\n\t\t\t\tresolving.push(input.text);\n\t\t\t\tif (input.text === \"first\") {\n\t\t\t\t\tentered.resolve();\n\t\t\t\t\tawait release.promise;\n\t\t\t\t}\n\t\t\t\treturn { text: input.text };\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tlet firstReplies: Sent[] = [];\n\t\tlet secondReplies: Sent[] = [];\n\t\tlet first = Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", firstReplies),\n\t\t\tmessage(\"first\", \"room\", undefined, \"first-rid\"),\n\t\t);\n\t\tlet second = Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"bob\", \"U_bob\", secondReplies),\n\t\t\tmessage(\"second\", \"room\", undefined, \"second-rid\"),\n\t\t);\n\t\tawait entered.promise;\n\t\texpect(resolving).toEqual([\"first\"]);\n\t\texpect(chat.entries).toEqual([]);\n\t\trelease.resolve();\n\t\tawait Promise.all([first, second]);\n\t\texpect(resolving).toEqual([\"first\", \"second\"]);\n\t\texpect(chat.entries.map(entry => entry.text)).toEqual([\"first\", \"second\"]);\n\t\texpect(firstReplies[0]).toMatchObject({ rid: \"first-rid\", queued: false });\n\t\texpect(secondReplies[0]).toMatchObject({ rid: \"second-rid\", queued: false });\n\t});\n\n\tit(\"fails closed, full, and persistence-rejected sends without success replies\", async () => {\n\t\tlet closed = room({ busy: true });\n\t\tclosed.chat.closed = true;\n\t\tlet closedReplies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tclosed.context,\n\t\t\tsender(\"ana\", \"U_ana\", closedReplies),\n\t\t\tmessage(\"closed\", \"room\"),\n\t\t);\n\t\texpect(closedReplies).toEqual([\n\t\t\texpect.objectContaining({ kind: \"session:error\", message: \"chat is closed\" }),\n\t\t]);\n\n\t\tlet full = room({ busy: true });\n\t\tfor (let index = 0; index < 20; index++) {\n\t\t\tfull.chat.waiting.push({ id: `waiting-${index}`, handle: \"ana\", text: `${index}` });\n\t\t}\n\t\tlet fullReplies: Sent[] = [];\n\t\tawait Chat.send(full.context, sender(\"ana\", \"U_ana\", fullReplies), message(\"full\", \"planner\"));\n\t\texpect(fullReplies).toEqual([\n\t\t\texpect.objectContaining({ kind: \"session:error\", message: \"the Planner queue is full\" }),\n\t\t]);\n\t\texpect(full.chat.waiting).toHaveLength(20);\n\n\t\tlet failed = room({ busy: true });\n\t\tfailed.context.persist = async () => {\n\t\t\tthrow new Error(\"storage unavailable\");\n\t\t};\n\t\tlet failedReplies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tfailed.context,\n\t\t\tsender(\"ana\", \"U_ana\", failedReplies),\n\t\t\tmessage(\"not saved\", \"room\"),\n\t\t);\n\t\texpect(failedReplies).toEqual([\n\t\t\texpect.objectContaining({ kind: \"session:error\", message: \"could not save message\" }),\n\t\t]);\n\t\texpect(failed.chat.entries).toEqual([]);\n\t});\n\n\tit(\"replays a lost room acknowledgement without resolving or persisting twice\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet resolutions = 0;\n\t\tlet persists = 0;\n\t\tcontext.references = {\n\t\t\tresolve: async (input: { text: string }) => {\n\t\t\t\tresolutions++;\n\t\t\t\treturn { text: input.text };\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tcontext.persist = async () => {\n\t\t\tpersists++;\n\t\t};\n\t\tlet requestId = crypto.randomUUID();\n\t\tlet firstReplies: Sent[] = [];\n\t\tlet retryReplies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", firstReplies),\n\t\t\tmessage(\"durable once\", \"room\", undefined, \"first\", requestId),\n\t\t);\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", retryReplies),\n\t\t\tmessage(\"durable once\", \"room\", undefined, \"retry\", requestId),\n\t\t);\n\t\texpect(chat.entries).toHaveLength(1);\n\t\texpect(chat.entries[0]?.id).toBe(requestId);\n\t\texpect(resolutions).toBe(1);\n\t\texpect(persists).toBe(1);\n\t\texpect(firstReplies[0]).toMatchObject({ id: requestId, queued: false });\n\t\texpect(retryReplies[0]).toMatchObject({ id: requestId, queued: false, rid: \"retry\" });\n\t});\n\n\tit(\"replays a lost immediate Planner acknowledgement without starting a duplicate entry\", async () => {\n\t\tlet { chat, context } = room({ agent: false });\n\t\tlet persists = 0;\n\t\tcontext.persist = async () => {\n\t\t\tpersists++;\n\t\t};\n\t\tlet requestId = crypto.randomUUID();\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(),\n\t\t\tmessage(\"plan once\", \"planner\", undefined, \"first\", requestId),\n\t\t);\n\t\tlet replies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", replies),\n\t\t\tmessage(\"plan once\", \"planner\", undefined, \"retry\", requestId),\n\t\t);\n\t\texpect(chat.entries).toHaveLength(2);\n\t\texpect(chat.entries.filter(entry => entry.id === requestId)).toHaveLength(1);\n\t\texpect(persists).toBe(1);\n\t\texpect(replies[0]).toMatchObject({ id: requestId, queued: false });\n\t});\n\n\tit(\"replays a process-local queued request and preserves its id when it becomes an entry\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet requestId = crypto.randomUUID();\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(),\n\t\t\tmessage(\"queue once\", \"planner\", undefined, \"first\", requestId),\n\t\t);\n\t\tlet replies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", replies),\n\t\t\tmessage(\"queue once\", \"planner\", undefined, \"retry\", requestId),\n\t\t);\n\t\texpect(chat.waiting).toHaveLength(1);\n\t\texpect(replies[0]).toMatchObject({ id: requestId, queued: true });\n\t\tChat.pending(chat);\n\t\texpect(chat.entries).toHaveLength(1);\n\t\texpect(chat.entries[0]?.id).toBe(requestId);\n\t\tlet startedReplies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", startedReplies),\n\t\t\tmessage(\"queue once\", \"planner\", undefined, \"started-retry\", requestId),\n\t\t);\n\t\texpect(chat.entries).toHaveLength(1);\n\t\texpect(startedReplies[0]).toMatchObject({ id: requestId, queued: false });\n\t});\n\n\tit(\"rejects conflicting reuse of a request id before another resolution\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tlet resolutions = 0;\n\t\tcontext.references = {\n\t\t\tresolve: async (input: { text: string }) => {\n\t\t\t\tresolutions++;\n\t\t\t\treturn { text: input.text };\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tlet requestId = crypto.randomUUID();\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(),\n\t\t\tmessage(\"first payload\", \"room\", undefined, \"first\", requestId),\n\t\t);\n\t\tlet replies: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", replies),\n\t\t\tmessage(\"different payload\", \"room\", undefined, \"conflict\", requestId),\n\t\t);\n\t\texpect(chat.entries).toHaveLength(1);\n\t\texpect(resolutions).toBe(1);\n\t\texpect(replies[0]).toMatchObject({\n\t\t\tkind: \"session:error\",\n\t\t\tmessage: \"chat request id was reused with different content\",\n\t\t});\n\t\tlet referenceConflict: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", referenceConflict),\n\t\t\tmessage(\n\t\t\t\t\"first payload\",\n\t\t\t\t\"room\",\n\t\t\t\t[{\n\t\t\t\t\tkind: \"document\",\n\t\t\t\t\tchannelId: crypto.randomUUID(),\n\t\t\t\t\tstart: 0,\n\t\t\t\t\tend: 1,\n\t\t\t\t}],\n\t\t\t\t\"reference-conflict\",\n\t\t\t\trequestId,\n\t\t\t),\n\t\t);\n\t\texpect(referenceConflict[0]).toMatchObject({\n\t\t\tkind: \"session:error\",\n\t\t\tmessage: \"chat request id was reused with different content\",\n\t\t});\n\t\texpect(resolutions).toBe(1);\n\t});\n\n\tit(\"bounds pending FIFO work while a resolver is slow\", async () => {\n\t\tlet { context } = room({ busy: true });\n\t\tlet entered = Promise.withResolvers();\n\t\tlet release = Promise.withResolvers();\n\t\tlet resolutions = 0;\n\t\tcontext.references = {\n\t\t\tresolve: async (input: { text: string }) => {\n\t\t\t\tresolutions++;\n\t\t\t\tif (resolutions === 1) {\n\t\t\t\t\tentered.resolve();\n\t\t\t\t\tawait release.promise;\n\t\t\t\t}\n\t\t\t\treturn { text: input.text };\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tlet accepted = Array.from(\n\t\t\t{ length: 20 },\n\t\t\t(_, index) => Chat.send(context, sender(), message(`message ${index}`, \"room\")),\n\t\t);\n\t\tawait entered.promise;\n\t\tlet overflow: Sent[] = [];\n\t\tawait Chat.send(context, sender(\"ana\", \"U_ana\", overflow), message(\"overflow\", \"room\"));\n\t\texpect(overflow[0]).toMatchObject({\n\t\t\tkind: \"session:error\",\n\t\t\tmessage: \"too many chat messages are waiting to be processed\",\n\t\t});\n\t\texpect(context.chat.pendingSends).toBe(20);\n\t\trelease.resolve();\n\t\tawait Promise.all(accepted);\n\t\texpect(resolutions).toBe(20);\n\t\texpect(context.chat.pendingSends).toBe(0);\n\t});\n\n\tit(\"rejects invalid request ids and UTF-8 messages above 64 KiB before resolution\", async () => {\n\t\tlet { context } = room({ busy: true });\n\t\tlet resolutions = 0;\n\t\tcontext.references = {\n\t\t\tresolve: async (input: { text: string }) => {\n\t\t\t\tresolutions++;\n\t\t\t\treturn { text: input.text };\n\t\t\t},\n\t\t} as unknown as ReferenceService;\n\t\tlet invalid: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", invalid),\n\t\t\tmessage(\"text\", \"room\", undefined, \"invalid\", \"not-a-uuid\"),\n\t\t);\n\t\texpect(invalid[0]).toMatchObject({\n\t\t\tkind: \"session:error\",\n\t\t\tmessage: \"chat request id must be a UUIDv4\",\n\t\t});\n\t\tlet oversized: Sent[] = [];\n\t\tawait Chat.send(\n\t\t\tcontext,\n\t\t\tsender(\"ana\", \"U_ana\", oversized),\n\t\t\tmessage(\"😀\".repeat(16_385), \"room\"),\n\t\t);\n\t\texpect(oversized[0]).toMatchObject({\n\t\t\tkind: \"session:error\",\n\t\t\tmessage: \"chat message exceeds the 64 KiB limit\",\n\t\t});\n\t\texpect(resolutions).toBe(0);\n\t});\n});\n\ndescribe(\"instructing the agent without a message\", () => {\n\t/**\n\t * An agent that starts editing for no visible reason is worse than a noisy\n\t * log, so the reason goes in the one place the room reads chronologically.\n\t */\n\tit(\"says why the turn started\", async () => {\n\t\tlet { context, sent } = room({ busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", '@ana accepted a comment on \"x\".');\n\n\t\texpect(said(sent)[0]).toBe('@ana accepted a comment on \"x\".');\n\t});\n\n\tit(\"queues behind a running turn rather than interrupting it\", async () => {\n\t\tlet { chat, context, sent } = room({ busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"@ana accepted a comment.\");\n\n\t\texpect(chat.waiting).toHaveLength(1);\n\t\texpect(chat.waiting[0]).toMatchObject({ handle: \"ana\", text: \"do the thing\" });\n\t\texpect(sent.some(frame => frame.kind === \"chat:queue\")).toBe(true);\n\t});\n\n\tit(\"refuses to grow a queue nobody is going to read\", async () => {\n\t\tlet { chat, context, sent } = room({ busy: true });\n\t\tfor (let i = 0; i < 25; i++) {\n\t\t\tawait Chat.instruct(context, \"ana\", `turn ${i}`, `notice ${i}`);\n\t\t}\n\n\t\texpect(chat.waiting.length).toBeLessThanOrEqual(20);\n\t\texpect(said(sent)).toContain(\"The queue is full. Wait for the current turn to finish.\");\n\t});\n\n\t/**\n\t * `AGENT=off` runs the room without one. The decision that got here is\n\t * already recorded; only the turn is impossible. Saying so beats a session\n\t * failing to open — which is what happened before this check existed,\n\t * because `chat:send` was gated and a button press was not.\n\t */\n\tit(\"records the decision but does not reach for an agent that is off\", async () => {\n\t\tlet { chat, context, sent } = room({ agent: false, busy: false });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"@ana accepted a comment.\");\n\n\t\texpect(chat.busy).toBe(false);\n\t\texpect(chat.waiting).toHaveLength(0);\n\t\texpect(said(sent)).toEqual([\n\t\t\t\"@ana accepted a comment.\",\n\t\t\t\"The agent is not running, so the plan has not been revised.\",\n\t\t]);\n\t});\n\n\tit(\"still says nothing was revised when the agent is off and busy\", async () => {\n\t\tlet { chat, context, sent } = room({ agent: false, busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"@ana accepted a comment.\");\n\n\t\t// The gate comes before the queue: queueing a turn that can never run\n\t\t// would leave it there until someone withdrew it.\n\t\texpect(chat.waiting).toHaveLength(0);\n\t\texpect(said(sent)).toHaveLength(2);\n\t});\n});\n\n/** Queue some turns, as `instruct` would have while another was running. */\nfunction waiting(chat: Chat.Chat, entries: Array<{ text: string; spent?: () => boolean }>): void {\n\tfor (let [index, entry] of entries.entries()) {\n\t\tchat.waiting.push({ id: `w${index}`, handle: \"ana\", ...entry });\n\t}\n}\n\ndescribe(\"what a turn is acting on\", () => {\n\t/**\n\t * `edit_plan` reads this to record the prose a turn wrote as what the\n\t * decision that started it produced. A turn nobody started by accepting a\n\t * comment is acting on nothing, and must attribute nothing.\n\t */\n\tit(\"carries the thread through the queue to the turn\", async () => {\n\t\tlet { chat, context } = room({ busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"notice\", { thread: \"t1\" });\n\n\t\texpect(chat.waiting[0]).toMatchObject({ thread: \"t1\" });\n\t});\n\n\tit(\"keeps the thread off the wire\", async () => {\n\t\tlet { context, sent } = room({ busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"notice\", { thread: \"t1\" });\n\n\t\tlet queue = sent.findLast(frame => frame.kind === \"chat:queue\");\n\t\texpect(queue?.waiting).toEqual([{\n\t\t\tid: expect.any(String),\n\t\t\thandle: \"ana\",\n\t\t\ttext: \"do the thing\",\n\t\t}]);\n\t});\n\n\tit(\"says a room with no turn running is acting on nothing\", () => {\n\t\tlet { chat } = room();\n\t\texpect(chat.acting).toBeUndefined();\n\t});\n});\n\ndescribe(\"draining the queue\", () => {\n\tit(\"takes them in the order they arrived\", () => {\n\t\tlet { chat } = room();\n\t\twaiting(chat, [{ text: \"first\" }, { text: \"second\" }]);\n\n\t\texpect(Chat.pending(chat)?.text).toBe(\"first\");\n\t\texpect(Chat.pending(chat)?.text).toBe(\"second\");\n\t\texpect(Chat.pending(chat)).toBeUndefined();\n\t});\n\n\t/**\n\t * Four accepted comments should not cost four passes over the plan when the\n\t * agent dealt with all of them in the first. Only something that queued\n\t * behind a turn can be spent, which is why the question is asked here.\n\t */\n\tit(\"drops a turn whose work another one already did\", () => {\n\t\tlet { chat } = room();\n\t\twaiting(chat, [\n\t\t\t{ text: \"thread one\", spent: () => true },\n\t\t\t{ text: \"thread two\", spent: () => true },\n\t\t\t{ text: \"thread three\", spent: () => false },\n\t\t]);\n\n\t\texpect(Chat.pending(chat)?.text).toBe(\"thread three\");\n\t\texpect(chat.waiting).toHaveLength(0);\n\t});\n\n\tit(\"drops the whole queue when everything in it is spent\", () => {\n\t\tlet { chat } = room();\n\t\twaiting(chat, [{ text: \"one\", spent: () => true }, { text: \"two\", spent: () => true }]);\n\n\t\texpect(Chat.pending(chat)).toBeUndefined();\n\t});\n\n\t/** An ordinary message is never spent: nobody else can have said it for you. */\n\tit(\"keeps a message, which has no work anybody else could have done\", () => {\n\t\tlet { chat } = room();\n\t\twaiting(chat, [{ text: \"what about auth?\" }]);\n\n\t\texpect(Chat.pending(chat)?.text).toBe(\"what about auth?\");\n\t});\n\n\t/**\n\t * `spent` is a function, so it is asked at the moment the turn would run\n\t * rather than when it was queued — which is the only moment the answer is\n\t * knowable. It also means `JSON.stringify` drops it, keeping the wire shape\n\t * exactly what clients expect.\n\t */\n\tit(\"asks when the turn would run, not when it was queued\", () => {\n\t\tlet { chat } = room();\n\t\tlet done = false;\n\t\twaiting(chat, [{ text: \"thread\", spent: () => done }]);\n\n\t\tdone = true;\n\t\texpect(Chat.pending(chat)).toBeUndefined();\n\t});\n\n\tit(\"keeps `spent` off the wire\", async () => {\n\t\tlet { context, sent } = room({ busy: true });\n\t\tawait Chat.instruct(context, \"ana\", \"do the thing\", \"notice\", { spent: () => false });\n\n\t\tlet queue = sent.findLast(frame => frame.kind === \"chat:queue\");\n\t\texpect(queue?.waiting).toEqual([{\n\t\t\tid: expect.any(String),\n\t\t\thandle: \"ana\",\n\t\t\ttext: \"do the thing\",\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",1794438306101,"sidebar","expanded"]