[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_229":-5,"_232":233,"_234":235},"routes/shell",{"_42":43,"_228":-5,"_229":-5,"_230":231},"routes/repo",{"_33":-7,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":31,"_45":31,"_46":31,"_47":31,"_48":31,"_49":31,"_50":51,"_52":51,"_53":31,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":14,"_22":23,"_24":-5,"_25":26,"_27":28,"_28":29,"_30":31,"_32":14},"ref","6d30eb305e40836056ec6ec7dcb041d1816a00b3","path","apps/server/src/chat/service.ts","oid","3a88de737f570f2688f3134bd1510545d8e7e547","size",13635,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * The conversation.\n *\n * One transcript per room, shared by everyone in it, and one turn at a time.\n * Messages that address the agent are queued rather than refused while it is\n * working: the plan belongs to the agent for the length of a turn, but the\n * conversation does not, and silencing somebody because a colleague prompted\n * first is a poor way to run a room with two people in it.\n *\n * Messages that do not address it are ordinary conversation. They are carried\n * into the next turn as context rather than starting one, so people can decide\n * something between themselves and the agent turns up already knowing.\n *\n * Every message reaching the model is prefixed with its author's handle. The\n * agent is planning with a group, and \"Alice prefers X, but Bob raised Y\" is\n * the kind of thing it has to be able to say back.\n */\n\nimport { ulid } from \"@chopin/dialect\";\n\nimport * as Agent from \"../agent/client\";\nimport { toolbox } from \"../agent/tools\";\nimport * as Service from \"../plan/service\";\nimport { addressed } from \"@chopin/protocol/address\";\n\nimport { compose, remember } from \"./address\";\nimport { broadcast, tell } from \"../wire\";\n\nimport type { Server } from \"bun\";\nimport type { SessionEvent } from \"@github/copilot-sdk\";\nimport type { Chat as Wire, Request } from \"@chopin/protocol\";\nimport type { Config } from \"../config\";\nimport type { Plan } from \"../plan/service\";\nimport type { Said } from \"./address\";\nimport type { Socket, SocketData } from \"../wire\";\n\n/** Beyond this the queue is a backlog nobody is going to read. */\nconst MAX_QUEUE = 20;\n\nexport type Chat = {\n\tentries: Wire.Entry[];\n\twaiting: Wire.Waiting[];\n\t/** The Copilot session, once somebody has prompted. */\n\tagent?: Agent.Agent;\n\t/** In flight while the session is being opened, so a second prompt waits. */\n\topening?: Promise;\n\tbusy: boolean;\n\t/** Whose message the running turn is answering. */\n\tturn?: string;\n\t/** The entry the agent is currently writing into. */\n\twriting?: string;\n\t/** Detaches the event handler when a turn ends. */\n\trelease?: () => void;\n\t/** When each running tool call started, for its duration. */\n\ttimings: Map;\n\t/** Session id, persisted so a restart resumes the conversation. */\n\tresume?: string;\n\t/**\n\t * What the room has said since the agent last ran.\n\t *\n\t * Deliberately not persisted: a conversation the agent never saw has no\n\t * claim on surviving a restart, and replaying it later would be stranger\n\t * than losing it.\n\t */\n\tbackscroll: Said[];\n};\n\nexport function create(): Chat {\n\treturn { entries: [], waiting: [], busy: false, timings: new Map(), backscroll: [] };\n}\n\n/**\n * Come back with what was said before.\n *\n * An entry that was still streaming when the process went away never finished,\n * so the flag is cleared: it is as complete as it is ever going to be, and\n * leaving it set would show a spinner nothing will ever stop.\n */\nexport function restore(entries: Wire.Entry[], resume?: string): Chat {\n\treturn {\n\t\tentries: entries.map(entry => {\n\t\t\tlet { streaming: _streaming, ...rest } = entry;\n\t\t\treturn rest;\n\t\t}),\n\t\twaiting: [],\n\t\tbusy: false,\n\t\ttimings: new Map(),\n\t\tbackscroll: [],\n\t\t...(resume ? { resume } : {}),\n\t};\n}\n\nfunction now(): number {\n\treturn Math.floor(Date.now() / 1000);\n}\n\nfunction state(chat: Chat, server: Server, room: string): void {\n\tbroadcast(server, room, {\n\t\tkind: \"chat:state\",\n\t\tts: 0,\n\t\tbusy: chat.busy,\n\t\t...(chat.turn ? { turn: chat.turn } : {}),\n\t});\n}\n\nfunction queued(chat: Chat, server: Server, room: string): void {\n\tbroadcast(server, room, { kind: \"chat:queue\", ts: 0, waiting: chat.waiting });\n}\n\nfunction say(\n\tchat: Chat,\n\tserver: Server,\n\troom: string,\n\tentry: Wire.Entry,\n): Wire.Entry {\n\tchat.entries.push(entry);\n\tbroadcast(server, room, { kind: \"chat:message\", ts: 0, entry });\n\treturn entry;\n}\n\n/** Everything said so far, for somebody who has just arrived. */\nexport function greet(chat: Chat, ws: Socket): void {\n\ttell(ws, {\n\t\tkind: \"chat:history\",\n\t\tts: 0,\n\t\tentries: chat.entries,\n\t\tbusy: chat.busy,\n\t\tqueued: chat.waiting,\n\t});\n}\n\nexport type Room = {\n\tchat: Chat;\n\tplan: Plan;\n\tserver: Server;\n\troom: string;\n\tconfig: Config;\n};\n\n/**\n * Take a message.\n *\n * It appears in the transcript either way — what somebody said is not\n * contingent on the agent being ready to hear it, or on it being for the agent\n * at all. What differs is whether it starts a turn.\n */\nexport function send(context: Room, ws: Socket, msg: Request): void {\n\tlet text = msg.text.trim();\n\tif (!text) return;\n\n\tlet { chat, room, server } = context;\n\tlet handle = ws.data.handle;\n\n\tsay(chat, server, room, {\n\t\tid: ulid(),\n\t\tauthor: { kind: \"member\", handle },\n\t\ttext,\n\t\tts: now(),\n\t});\n\n\t// Not for the agent: remembered, so the next turn arrives knowing it, but\n\t// nothing runs and nothing queues. Nobody asked for anything.\n\tif (!addressed(text)) {\n\t\tchat.backscroll = remember(chat.backscroll, { handle, text });\n\t\treturn;\n\t}\n\n\tif (chat.busy) {\n\t\tif (chat.waiting.length >= MAX_QUEUE) {\n\t\t\treturn void say(chat, server, room, {\n\t\t\t\tid: ulid(),\n\t\t\t\tauthor: { kind: \"system\" },\n\t\t\t\ttext: \"The queue is full. Wait for the current turn to finish.\",\n\t\t\t\tts: now(),\n\t\t\t});\n\t\t}\n\t\tchat.waiting.push({ id: ulid(), handle, text });\n\t\treturn queued(chat, server, room);\n\t}\n\n\tvoid run(context, handle, text);\n}\n\n/** Withdraw a queued message. Only whoever wrote it may. */\nexport function unqueue(context: Room, ws: Socket, msg: Request): void {\n\tlet { chat, room, server } = context;\n\tlet found = chat.waiting.find(item => item.id === msg.id);\n\tif (!found || found.handle !== ws.data.handle) return;\n\tchat.waiting = chat.waiting.filter(item => item.id !== msg.id);\n\tqueued(chat, server, room);\n}\n\n/** Stop the running turn. Anyone may, and the transcript says who did. */\nexport async function abort(context: Room, ws: Socket): Promise {\n\tlet { chat, room, server } = context;\n\tif (!chat.busy || !chat.agent) return;\n\n\tawait chat.agent.session.abort().catch(() => {});\n\tsay(chat, server, room, {\n\t\tid: ulid(),\n\t\tauthor: { kind: \"system\" },\n\t\ttext: `@${ws.data.handle} stopped the turn.`,\n\t\tts: now(),\n\t});\n}\n\nasync function session(context: Room): Promise {\n\tlet { chat, config, plan, room, server } = context;\n\tif (chat.agent) return chat.agent;\n\n\t// Captured before it is overwritten: the question is whether there *was* a\n\t// conversation to resume, not whether there is one now.\n\tlet previous = chat.resume;\n\n\treturn chat.opening ??= (async () => {\n\t\tlet tools = toolbox({\n\t\t\tplan,\n\t\t\tserver,\n\t\t\troom,\n\t\t\tpublish: mutation => Service.publish(plan, server, room, mutation),\n\t\t});\n\n\t\tlet { agent, resumed } = await Agent.open(config, { tools }, chat.resume);\n\t\tchat.agent = agent;\n\t\tchat.resume = agent.id;\n\t\tchat.opening = undefined;\n\t\tplan.sink.touch();\n\n\t\t// A transcript that survived while the conversation did not would\n\t\t// silently overstate what the agent remembers.\n\t\tif (previous && !resumed) {\n\t\t\tsay(chat, server, room, {\n\t\t\t\tid: ulid(),\n\t\t\t\tauthor: { kind: \"system\" },\n\t\t\t\ttext: \"The previous conversation could not be resumed; the agent does not \"\n\t\t\t\t\t+ \"remember what is above this line.\",\n\t\t\t\tts: now(),\n\t\t\t});\n\t\t}\n\n\t\treturn agent;\n\t})().catch(err => {\n\t\tchat.opening = undefined;\n\t\tthrow err;\n\t});\n}\n\n/** Run one turn, then drain whatever queued up behind it. */\nasync function run(context: Room, handle: string, text: string): Promise {\n\tlet { chat, room, server } = context;\n\n\tchat.busy = true;\n\tchat.turn = handle;\n\tstate(chat, server, room);\n\n\ttry {\n\t\tlet agent = await session(context);\n\n\t\t/*\n\t\t * `send` resolves when the message is accepted, not when the turn is\n\t\t * over — the work happens afterwards, over events. Waiting on `send`\n\t\t * alone tears the handler down before the agent has said anything.\n\t\t *\n\t\t * `session.idle` is the turn actually ending. `session.error` resolves\n\t\t * it too: a turn that has failed is not going to reach idle, and\n\t\t * leaving the room busy forever is worse than ending early.\n\t\t */\n\t\tlet finished = Promise.withResolvers();\n\t\tchat.release = agent.session.on(event => {\n\t\t\ttranslate(context, event);\n\t\t\tif (event.type === \"session.idle\" || event.type === \"session.error\") {\n\t\t\t\tfinished.resolve();\n\t\t\t}\n\t\t});\n\n\t\t// Drained rather than copied: what the agent has been told once should\n\t\t// not arrive again on the next turn.\n\t\tlet prompt = compose(chat.backscroll, handle, text);\n\t\tchat.backscroll = [];\n\n\t\t// The handle travels to the model, because a position belongs to\n\t\t// whoever holds it.\n\t\tawait agent.session.send({ prompt });\n\t\tawait finished.promise;\n\t} catch (err) {\n\t\tconsole.error(\"[chat] turn failed:\", err);\n\t\tsay(chat, server, room, {\n\t\t\tid: ulid(),\n\t\t\tauthor: { kind: \"system\" },\n\t\t\ttext: err instanceof Error ? err.message : \"The agent could not be reached.\",\n\t\t\tts: now(),\n\t\t});\n\t} finally {\n\t\tchat.release?.();\n\t\tchat.release = undefined;\n\t\tchat.writing = undefined;\n\t\tchat.busy = false;\n\t\tchat.turn = undefined;\n\t\tstate(chat, server, room);\n\t}\n\n\tlet next = chat.waiting.shift();\n\tif (next) {\n\t\tqueued(chat, server, room);\n\t\tawait run(context, next.handle, next.text);\n\t}\n}\n\n/**\n * Turn what the SDK reports into what the room sees.\n *\n * Only the events a reader needs: what the agent said, what it is doing, and\n * when something failed. The rest is diagnostic noise that belongs in a log.\n */\nfunction translate(context: Room, event: SessionEvent): void {\n\tlet { chat, room, server } = context;\n\n\tswitch (event.type) {\n\t\t// One entry per assistant message, identified by the id the deltas\n\t\t// carry, so two messages in a turn do not run together.\n\t\tcase \"assistant.message_delta\": {\n\t\t\tlet { deltaContent, messageId } = event.data;\n\t\t\tlet entry = chat.entries.find(item => item.id === messageId);\n\t\t\tif (!entry) {\n\t\t\t\tchat.writing = messageId;\n\t\t\t\tsay(chat, server, room, {\n\t\t\t\t\tid: messageId,\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext: deltaContent,\n\t\t\t\t\tts: now(),\n\t\t\t\t\tstreaming: true,\n\t\t\t\t});\n\t\t\t\treturn;\n\t\t\t}\n\t\t\tentry.text += deltaContent;\n\t\t\tbroadcast(server, room, { kind: \"chat:delta\", ts: 0, id: messageId, text: deltaContent });\n\t\t\treturn;\n\t\t}\n\n\t\tcase \"assistant.message\": {\n\t\t\tlet text = event.data.content;\n\t\t\tlet entry = chat.entries.find(item => item.id === event.id);\n\t\t\tif (entry) {\n\t\t\t\tentry.text = text || entry.text;\n\t\t\t\tdelete entry.streaming;\n\t\t\t\tbroadcast(server, room, { kind: \"chat:message\", ts: 0, entry });\n\t\t\t} else if (text.trim()) {\n\t\t\t\tsay(chat, server, room, {\n\t\t\t\t\tid: event.id,\n\t\t\t\t\tauthor: { kind: \"agent\" },\n\t\t\t\t\ttext,\n\t\t\t\t\tts: now(),\n\t\t\t\t});\n\t\t\t}\n\t\t\tchat.writing = undefined;\n\t\t\treturn;\n\t\t}\n\n\t\tcase \"tool.execution_start\": {\n\t\t\tlet { arguments: args, toolCallId, toolName } = event.data;\n\t\t\tchat.timings.set(toolCallId, Date.now());\n\t\t\tlet activity: Wire.Activity = {\n\t\t\t\tid: toolCallId,\n\t\t\t\tname: toolName,\n\t\t\t\tstatus: \"running\",\n\t\t\t\t...(args ? { args: JSON.stringify(args, null, 2) } : {}),\n\t\t\t};\n\t\t\tbroadcast(server, room, {\n\t\t\t\tkind: \"chat:tool\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: attach(chat, activity),\n\t\t\t\tactivity,\n\t\t\t});\n\t\t\treturn;\n\t\t}\n\n\t\tcase \"tool.execution_complete\": {\n\t\t\tlet { error, result, success, toolCallId } = event.data;\n\t\t\tlet started = chat.timings.get(toolCallId);\n\t\t\tchat.timings.delete(toolCallId);\n\n\t\t\tlet detail = result?.content ?? (error ? JSON.stringify(error) : undefined);\n\t\t\t// The completion does not repeat the tool's name; the start did, and\n\t\t\t// the entry it was filed under still has it.\n\t\t\tlet activity: Wire.Activity = {\n\t\t\t\tid: toolCallId,\n\t\t\t\tname: named(chat, toolCallId),\n\t\t\t\tstatus: success ? \"done\" : \"failed\",\n\t\t\t\t...(started ? { took: Date.now() - started } : {}),\n\t\t\t\t// Bounded: a `grep` across a repository is not a thing anybody\n\t\t\t\t// wants delivered to every browser in the room.\n\t\t\t\t...(detail ? { result: detail.slice(0, 4_000) } : {}),\n\t\t\t};\n\t\t\tbroadcast(server, room, {\n\t\t\t\tkind: \"chat:tool\",\n\t\t\t\tts: 0,\n\t\t\t\tentry: attach(chat, activity),\n\t\t\t\tactivity,\n\t\t\t});\n\t\t\treturn;\n\t\t}\n\n\t\tcase \"session.error\": {\n\t\t\tsay(chat, server, room, {\n\t\t\t\tid: ulid(),\n\t\t\t\tauthor: { kind: \"system\" },\n\t\t\t\ttext: event.data.message || \"The agent stopped unexpectedly.\",\n\t\t\t\tts: now(),\n\t\t\t});\n\t\t\treturn;\n\t\t}\n\t}\n}\n\n/** What a running tool call was called, from where it was filed. */\nfunction named(chat: Chat, id: string): string {\n\tfor (let entry of chat.entries) {\n\t\tlet found = entry.tools?.find(activity => activity.id === id);\n\t\tif (found) return found.name;\n\t}\n\treturn \"tool\";\n}\n\n/**\n * File a tool call under the message that made it, and say which that was.\n *\n * A tool call that arrives before the agent has said anything — which is most\n * of them, since reading precedes writing — has no message to attach to yet.\n * It gets an entry of its own so the work is visible while it happens rather\n * than appearing retrospectively once the agent finishes talking.\n */\nfunction attach(chat: Chat, activity: Wire.Activity): string {\n\tlet entry = chat.entries.find(item => item.id === chat.writing)\n\t\t?? chat.entries.findLast(item => item.author.kind === \"agent\");\n\n\tif (!entry) {\n\t\tentry = { id: ulid(), author: { kind: \"agent\" }, text: \"\", ts: now(), tools: [] };\n\t\tchat.entries.push(entry);\n\t}\n\n\tentry.tools ??= [];\n\tlet existing = entry.tools.findIndex(item => item.id === activity.id);\n\tif (existing >= 0) entry.tools[existing] = { ...entry.tools[existing], ...activity };\n\telse entry.tools.push(activity);\n\treturn entry.id;\n}\n\n/** Let go of the session. The conversation is resumable by id. */\nexport async function close(chat: Chat): Promise {\n\tchat.release?.();\n\tawait chat.agent?.session.disconnect().catch(() => {});\n\tchat.agent = undefined;\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","organization",true,"site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[184,185,186,187,188,189,190,191,192,193,194,195,196],"navigation",{"_56":57,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150,"_151":152},"sources",[],"viewer","meta",{"_133":134,"_135":136,"_137":138,"_44":31,"_139":128,"_140":31,"_50":51,"_52":51},"branches",[75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132],"tags",[71,72,73,74],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[167,168,169],"documents",{"_162":163,"_164":165},"code",{"_158":159,"_160":161},"automations",{"_155":156,"_157":-5},"delivery",{"_153":51,"_154":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_166":165},"total",11,"issue",{"_170":160,"_172":182,"_15":160,"_174":183,"_54":41,"_176":31,"_177":41,"_178":161},{"_170":179,"_172":180,"_15":179,"_174":181,"_54":41,"_176":31,"_177":41,"_178":51},{"_170":171,"_172":173,"_15":171,"_174":175,"_54":41,"_176":31,"_177":41,"_178":165},"id","issues","name","Issues","filters",{},"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_170":160,"_172":182,"_15":160,"_174":227,"_54":41,"_176":31,"_177":41},{"_170":179,"_172":180,"_15":179,"_174":226,"_54":41,"_176":31,"_177":41},{"_170":171,"_172":173,"_15":171,"_174":225,"_54":41,"_176":31,"_177":41},{"_170":222,"_172":223,"_15":222,"_174":224,"_54":31,"_176":31,"_177":41},{"_170":219,"_172":220,"_15":219,"_174":221,"_54":31,"_176":31,"_177":41},{"_170":155,"_172":217,"_15":147,"_174":218,"_54":31,"_176":31,"_177":41},{"_170":157,"_172":214,"_15":215,"_174":216,"_54":31,"_176":31,"_177":41},{"_170":153,"_172":212,"_15":153,"_174":213,"_54":31,"_176":31,"_177":41},{"_170":208,"_172":209,"_15":210,"_174":211,"_54":31,"_176":31,"_177":41},{"_170":143,"_172":206,"_15":143,"_174":207,"_54":31,"_176":31,"_177":31},{"_170":203,"_172":204,"_15":203,"_174":205,"_54":31,"_176":31,"_177":31},{"_170":200,"_172":201,"_15":200,"_174":202,"_54":31,"_176":31,"_177":31},{"_170":197,"_172":198,"_15":197,"_174":199,"_54":31,"_176":31,"_177":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794668903324,"sidebar","expanded"]