[{"_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","2cc59d4973b129ceaca2dd5005b6a22e20db9091","path","apps/server/src/main.ts","oid","6ff7522fc3f0b112d646eab62dec751044205558","size",48872,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * The server.\n *\n * One process: the WebSocket every room talks over, and — in production — the\n * built client alongside it. In development Vite serves the client and proxies\n * `/ws` here, so the browser sees one origin either way and the client never\n * needs to know which mode it is in.\n */\n\nimport { join } from \"node:path\";\nimport { ulid } from \"@chopin/dialect\";\n\nimport { harnessFor, shutdownHarnesses } from \"./harness/harnesses\";\nimport { ActiveOwnerBindings } from \"./agent/active-owner\";\nimport { registerAuthRoutes } from \"./auth/routes\";\nimport * as Chat from \"./chat/service\";\nimport { CHAT_CAPABILITIES, incomingFrame } from \"./chat/incoming\";\nimport { ReferenceService } from \"./chat/references\";\nimport { createConversationRuntime } from \"./conversation-plan/runtime\";\nimport { researchBriefDefinition } from \"./jobs/research-brief\";\nimport {\n\tgreetJoinedPlan,\n\tprepareOpenedPlan,\n\treadyPlan,\n\trecoverAttachedPlan,\n} from \"./conversation-plan/service-opening\";\nimport { handleConversationCommand } from \"./conversation-plan/commands\";\nimport { handleResearchCommand } from \"./conversation-plan/research-commands\";\nimport { startAcceptedResearch } from \"./conversation-plan/accepted-research\";\nimport { registerChannelRoutes } from \"./channels/routes\";\nimport * as Comments from \"./comments/service\";\nimport { proxy, serve } from \"./client\";\nimport { describe, load } from \"./config\";\nimport { GitHubError } from \"./github/client\";\nimport { Router } from \"./http/router\";\nimport { JobExecutionError, JobRegistry } from \"./jobs/registry\";\nimport * as JobBrowser from \"./jobs/browser\";\nimport { DocumentDescriptionProjector } from \"./jobs/document-description\";\nimport { documentSummaryDefinition } from \"./jobs/document-summary\";\nimport { JobRunner } from \"./jobs/runner\";\nimport { researchAnswerDefinition, researchEvidenceDefinition } from \"./jobs/research-workspace\";\nimport { JobService } from \"./jobs/service\";\nimport { DocumentSummaryCoordinator } from \"./jobs/summary-coordinator\";\nimport { registerMcpRoutes } from \"./mcp/routes\";\nimport { registerNavigationRoutes } from \"./navigation/routes\";\nimport * as Service from \"./plan/service\";\nimport * as Inject from \"./questions/inject\";\nimport * as Marks from \"./comments/inject\";\nimport * as Questions from \"./questions/service\";\nimport { backfillPlannerAskThreads } from \"./questions/backfill\";\nimport { registerResearchWorkspaceRoutes } from \"./research/routes\";\nimport { ResearchWorkspaceError, ResearchWorkspaceService } from \"./research/service\";\nimport { placeResearchReference as placeResearch } from \"./research/placement\";\nimport * as Rooms from \"./rooms\";\nimport { admit } from \"./socket/admission\";\nimport { refreshAuthorization } from \"./socket/authorization\";\nimport { StorageError } from \"./storage/errors\";\nimport { createStorage } from \"./storage/registry\";\nimport { broadcast, fail, relay, reply, tell, topic } from \"./wire\";\n\nimport type { Server } from \"bun\";\nimport type { DocumentSummaryInput } from \"./jobs/document-summary\";\nimport type { JobDefinition } from \"./jobs/registry\";\nimport type { ChannelRecord, Lease } from \"./storage/model\";\nimport type { AuthorizationResult, Socket, SocketData } from \"./wire\";\n\nconst config = load();\nharnessFor(config);\nconst storage = createStorage(config.storage);\nconst router = new Router();\n\n/** Where the built client lands. Used only when there is no dev client. */\nconst CLIENT = join(import.meta.dir, \"../../web/dist\");\n\n/**\n * How long an empty room is kept before its document is released.\n *\n * A reload is a departure followed by an arrival, and discarding the document\n * in between would cost the epoch and everyone's undo history for a keypress.\n */\nconst EVICT_MS = 30_000;\nconst LEASE_TTL_MS = 30_000;\nconst LEASE_RENEW_MS = 10_000;\nconst LEASE_SAFETY_MS = 5_000;\nconst SESSION_CLEANUP_MS = 5 * 60_000;\nconst ACCESS_RECHECK_MS = 60_000;\nconst RESEARCH_RECOVERY_RETRY_MS = 10_000;\n\nlet server: Server;\nlet heldLease: Lease | undefined;\nlet leaseRenewal: ReturnType | undefined;\nlet leaseWatchdog: ReturnType | undefined;\nlet renewingLease: Promise | undefined;\nlet sessionCleanup: ReturnType | undefined;\nlet cleaningSessions: Promise | undefined;\nlet ownerBindings: ActiveOwnerBindings | undefined;\nlet jobRunner: JobRunner | undefined;\nlet researchService: ResearchWorkspaceService | undefined;\nlet researchRecoveryTimer: ReturnType | undefined;\nlet recoveringResearch: Promise | undefined;\nlet referenceService: ReferenceService | undefined;\nlet summaryCoordinator: DocumentSummaryCoordinator | undefined;\nlet descriptionProjector: DocumentDescriptionProjector | undefined;\nlet researchBriefJobs: JobService | undefined;\nlet documentLocks = new Map>();\nlet documentTransitions = new Map>();\nlet archivingChannels = new Set();\nlet deletingChannels = new Set();\nlet conversationRuntime = createConversationRuntime({\n\tconfig,\n\tserver: () => server,\n\tunavailable: id => archivingChannels.has(id) || deletingChannels.has(id),\n\tresearchJobs: () => researchBriefJobs,\n});\n\nfunction withDocumentLock(channelId: string, action: () => Promise): Promise {\n\tlet previous = documentLocks.get(channelId) ?? Promise.resolve();\n\tlet operation = previous.then(action, action);\n\tlet settled = operation.then(() => {}, () => {});\n\tdocumentLocks.set(channelId, settled);\n\tvoid settled.finally(() => {\n\t\tif (documentLocks.get(channelId) === settled) documentLocks.delete(channelId);\n\t});\n\treturn operation;\n}\n\nfunction withDocumentTransition(channelId: string, action: () => Promise): Promise {\n\tlet previous = documentTransitions.get(channelId) ?? Promise.resolve();\n\tlet operation = previous.then(action, action);\n\tlet settled = operation.then(() => {}, () => {});\n\tdocumentTransitions.set(channelId, settled);\n\tvoid settled.finally(() => {\n\t\tif (documentTransitions.get(channelId) === settled) documentTransitions.delete(channelId);\n\t});\n\treturn operation;\n}\n\nfunction presence(server: Server, room: Rooms.Room): void {\n\tbroadcast(server, room.id, {\n\t\tkind: \"session:presence\",\n\t\tts: 0,\n\t\tmembers: Rooms.members(room),\n\t});\n}\n\nfunction documentBackend(): Service.Backend {\n\treturn {\n\t\tstorage,\n\t\tlease: () => {\n\t\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\t\treturn heldLease;\n\t\t},\n\t\tfatal: err => {\n\t\t\tconsole.error(\"chopin: plan persistence failed -\", err);\n\t\t\tsignal();\n\t\t},\n\t\tonDocumentPersisted: target => summaryCoordinator?.schedule(target),\n\t};\n}\n\nfunction placeResearchReference(\n\tchannelId: string,\n\tworkspaceId: string,\n): Promise<\"placed\" | \"deferred\"> {\n\treturn placeResearch(channelId, workspaceId, {\n\t\tget: Rooms.get,\n\t\texclusive: withDocumentLock,\n\t\tdetached: async (id, action) => {\n\t\t\tlet detached = await Service.open(id, documentBackend(), server);\n\t\t\ttry {\n\t\t\t\treturn await action(detached);\n\t\t\t} finally {\n\t\t\t\tawait Service.close(detached);\n\t\t\t}\n\t\t},\n\t});\n}\n\nfunction scheduleResearchRecovery(deferred: number): void {\n\tif (deferred === 0 || researchRecoveryTimer || draining) return;\n\tresearchRecoveryTimer = setTimeout(() => {\n\t\tresearchRecoveryTimer = undefined;\n\t\tif (draining) return;\n\t\trecoveringResearch = researchService!.recoverPendingPlannerInline(placeResearchReference).then(\n\t\t\tresult => {\n\t\t\t\tscheduleResearchRecovery(result.deferred);\n\t\t\t},\n\t\t\terr => {\n\t\t\t\tconsole.error(\"chopin: research reference recovery failed -\", err);\n\t\t\t\tsignal();\n\t\t\t},\n\t\t).finally(() => {\n\t\t\trecoveringResearch = undefined;\n\t\t});\n\t}, RESEARCH_RECOVERY_RETRY_MS);\n}\n\n/**\n * Attach the document to a room, once.\n *\n * Two clients opening at the same moment must not build two documents, so the\n * first stores its promise and the second waits on it.\n */\nasync function plan(room: Rooms.Room, server: Server): Promise {\n\tif (room.closing) await room.closing;\n\tif (deletingChannels.has(room.id)) throw new Error(\"document is unavailable\");\n\tif (room.opening) {\n\t\tlet opened = await room.opening;\n\t\tconversationRuntime.wake(opened);\n\t\treturn opened;\n\t}\n\tif (room.plan) {\n\t\tconversationRuntime.wake(room.plan);\n\t\treturn room.plan;\n\t}\n\tlet backend = documentBackend();\n\tlet opening = room.opening ??= withDocumentLock(room.id, async () => {\n\t\tif (deletingChannels.has(room.id)) throw new Error(\"document is unavailable\");\n\t\tif (room.plan) return room.plan;\n\t\tlet opened = await Service.open(room.id, backend, server);\n\t\tlet channel: ChannelRecord | undefined;\n\t\tawait prepareOpenedPlan(room, opened, async () => {\n\t\t\tchannel = await storage.channels.get(room.id);\n\t\t\tif (room.closing) throw new Error(\"document is unavailable\");\n\t\t\tif (config.conversationPlan && !channel?.archivedAt) {\n\t\t\t\tawait backfillPlannerAskThreads(opened);\n\t\t\t}\n\t\t});\n\t\tawait conversationRuntime.attach(\n\t\t\troom,\n\t\t\topened,\n\t\t\t!!channel?.archivedAt,\n\t\t\t!!channel && !channel.parentChannelId,\n\t\t);\n\t\tif (!channel?.archivedAt) {\n\t\t\tif (summaryCoordinator) void summaryCoordinator.ensure(room.id).catch(() => {});\n\t\t\tif (Inject.enabled()) Inject.ask(opened, server, room.id);\n\t\t\tif (Marks.enabled()) await Marks.mark(opened);\n\t\t}\n\t\treturn opened;\n\t});\n\ttry {\n\t\tlet opened = await opening;\n\t\tconversationRuntime.wake(opened);\n\t\treturn opened;\n\t} finally {\n\t\tif (room.opening === opening) room.opening = undefined;\n\t}\n}\n\nfunction chat(room: Rooms.Room, ws: Socket): Chat.Room {\n\treturn conversation(room, ws.data.sessionId, {\n\t\tid: ws.data.repositoryId,\n\t\towner: ws.data.repositoryOwner,\n\t\tname: ws.data.repositoryName,\n\t\tdefaultBranch: ws.data.repositoryDefaultBranch,\n\t});\n}\n\n/** A room's Chat, shared by browser messages and MCP handoffs. */\nfunction conversation(\n\troom: Rooms.Room,\n\tclaimantSessionId: string | undefined,\n\trepository: Chat.Room[\"repository\"],\n): Chat.Room {\n\tlet opened = room.plan!;\n\treturn conversationRuntime.bind({\n\t\tchat: opened.chat,\n\t\tplan: opened,\n\t\tserver,\n\t\troom: room.id,\n\t\tconfig,\n\t\tauth: hostedAuth,\n\t\tclaimantSessionId,\n\t\trepository,\n\t\tpersist: chat => Service.persist(opened, chat),\n\t\tactiveOwner: () => ownerBindings!.resolve(room.id),\n\t\townerAvailable: () => jobRunner?.ownerAvailable(room.id) ?? Promise.resolve(),\n\t\tjobs: config.backgroundJobs ? jobService : undefined,\n\t\treferences: referenceService,\n\t\thold: () => {\n\t\t\tlet held = Rooms.hold(room.id);\n\t\t\treturn () => {\n\t\t\t\theld.release();\n\t\t\t\tevict(held.room);\n\t\t\t};\n\t\t},\n\t\tcreateResearch: config.agent\n\t\t\t? async request => {\n\t\t\t\tlet service = researchService;\n\t\t\t\tif (!service) throw new Error(\"research workspaces are unavailable\");\n\t\t\t\tlet created;\n\t\t\t\ttry {\n\t\t\t\t\tcreated = await service.startPlannerInline({\n\t\t\t\t\t\tchannelId: room.id,\n\t\t\t\t\t\tquestion: request.question,\n\t\t\t\t\t\toriginMessageId: request.entryId,\n\t\t\t\t\t\trequestedBy: request.userId,\n\t\t\t\t\t\trequestedByHandle: request.handle,\n\t\t\t\t\t\tbeforeStart: () => jobRunner?.ownerAvailable(room.id) ?? Promise.resolve(),\n\t\t\t\t\t\tplaceReference: id => placeResearchReference(room.id, id),\n\t\t\t\t\t});\n\t\t\t\t} catch (err) {\n\t\t\t\t\tif (err instanceof ResearchWorkspaceError && err.code === \"not-ready\") {\n\t\t\t\t\t\tscheduleResearchRecovery(1);\n\t\t\t\t\t}\n\t\t\t\t\tthrow err;\n\t\t\t\t}\n\t\t\t\treturn {\n\t\t\t\t\tworkspaceId: created.request.id,\n\t\t\t\t\tstate: created.request.state,\n\t\t\t\t\tstage: created.request.stage,\n\t\t\t\t};\n\t\t\t}\n\t\t\t: undefined,\n\t});\n}\n\nasync function closeRoom(room: Rooms.Room, force = false): Promise {\n\tif (room.closing) return room.closing;\n\tlet closing = withDocumentLock(room.id, async () => {\n\t\tif (!force && (room.members.size > 0 || room.holds)) return;\n\t\tlet held = room.plan;\n\t\troom.plan = undefined;\n\t\tif (held) {\n\t\t\tlet stopped = conversationRuntime.stop(held);\n\t\t\tawait stopped;\n\t\t\tawait Service.close(held);\n\t\t}\n\t\tif (force || room.members.size === 0) Rooms.forget(room);\n\t});\n\troom.closing = closing;\n\ttry {\n\t\tawait closing;\n\t} finally {\n\t\tif (room.closing === closing) room.closing = undefined;\n\t}\n}\n\nfunction evict(room: Rooms.Room): void {\n\tif (room.eviction || room.members.size > 0 || room.holds) return;\n\troom.eviction = setTimeout(() => {\n\t\troom.eviction = undefined;\n\t\tif (room.members.size > 0 || room.holds) return;\n\t\tvoid closeRoom(room).catch(err => {\n\t\t\tconsole.error(\"chopin: room close failed -\", err);\n\t\t});\n\t}, EVICT_MS);\n}\n\nasync function receive(ws: Socket, raw: string): Promise {\n\tlet frame = incomingFrame(raw);\n\tif (!frame) return;\n\n\tlet room = Rooms.get(ws.data.room);\n\tif (!room) return;\n\tif (deletingChannels.has(room.id)) {\n\t\tif (frame.rid) fail(ws, frame.rid, \"document is unavailable\");\n\t\treturn;\n\t}\n\tif (!VIEWER_ALLOWED.has(frame.kind)) {\n\t\tlet access = await refreshAccess(ws);\n\t\tif (access === \"unavailable\") {\n\t\t\tif (frame.rid) fail(ws, frame.rid, \"authorization is temporarily unavailable\");\n\t\t\treturn;\n\t\t}\n\t\tif (access === \"denied\") {\n\t\t\tif (frame.rid) fail(ws, frame.rid, \"authorization expired\");\n\t\t\tws.close(4403, \"authorization expired\");\n\t\t\treturn;\n\t\t}\n\t}\n\tif (!ws.data.canEdit && !VIEWER_ALLOWED.has(frame.kind)) {\n\t\tif (frame.rid) fail(ws, frame.rid, \"repository write access is required\");\n\t\treturn;\n\t}\n\n\tswitch (frame.kind) {\n\t\tcase \"session:ping\":\n\t\t\treturn tell(ws, { kind: \"session:ping\", ts: 0, rid: frame.rid });\n\n\t\tcase \"plan:open\": {\n\t\t\ttry {\n\t\t\t\tlet opened = await plan(room, server);\n\t\t\t\tawait greetJoinedPlan(\n\t\t\t\t\topened,\n\t\t\t\t\tws,\n\t\t\t\t\tframe,\n\t\t\t\t\t!!config.conversationPlan,\n\t\t\t\t\t() =>\n\t\t\t\t\t\tRooms.get(room.id) === room && room.plan === opened\n\t\t\t\t\t\t&& !room.closing && !deletingChannels.has(room.id)\n\t\t\t\t\t\t&& !ws.data.closed && ws.data.room === room.id\n\t\t\t\t\t\t&& room.members.get(ws.data.client) === ws,\n\t\t\t\t);\n\t\t\t} catch (err) {\n\t\t\t\tfail(ws, frame.rid, err instanceof Error ? err.message : \"cannot open plan\");\n\t\t\t}\n\t\t\treturn;\n\t\t}\n\n\t\tcase \"plan:update\":\n\t\t\tif (room.plan) Service.submit(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"plan:awareness\":\n\t\t\tif (room.plan) Service.awareness(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"plan:close\":\n\t\t\tif (room.plan) Service.departed(room.plan, ws);\n\t\t\treturn;\n\n\t\tcase \"chat:send\":\n\t\t\ttry {\n\t\t\t\tlet opened = await readyPlan(room);\n\t\t\t\tif (!opened) {\n\t\t\t\t\tfail(ws, frame.rid, \"document is unavailable\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tlet access = await refreshAccess(ws);\n\t\t\t\tif (access === \"unavailable\") {\n\t\t\t\t\tfail(ws, frame.rid, \"authorization is temporarily unavailable\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tif (access === \"denied\") {\n\t\t\t\t\tfail(ws, frame.rid, \"authorization expired\");\n\t\t\t\t\tws.close(4403, \"authorization expired\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tif (!ws.data.canEdit) {\n\t\t\t\t\tfail(ws, frame.rid, \"repository write access is required\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tif (\n\t\t\t\t\tRooms.get(room.id) !== room || room.plan !== opened\n\t\t\t\t\t|| room.closing || archivingChannels.has(room.id) || deletingChannels.has(room.id)\n\t\t\t\t\t|| ws.data.closed || ws.data.room !== room.id\n\t\t\t\t\t|| room.members.get(ws.data.client) !== ws\n\t\t\t\t) {\n\t\t\t\t\tfail(ws, frame.rid, \"document is unavailable\");\n\t\t\t\t\treturn;\n\t\t\t\t}\n\t\t\t\tawait Chat.send(chat(room, ws), ws, frame);\n\t\t\t} catch (error) {\n\t\t\t\tfail(ws, frame.rid, error instanceof Error ? error.message : \"cannot send message\");\n\t\t\t}\n\t\t\treturn;\n\n\t\tcase \"chat:abort\":\n\t\t\tif (room.plan) await Chat.abort(chat(room, ws), ws);\n\t\t\treturn;\n\n\t\tcase \"chat:resume\":\n\t\t\tif (room.plan) await Chat.resume(chat(room, ws), ws);\n\t\t\treturn;\n\n\t\tcase \"chat:pause-run\":\n\t\tcase \"chat:resume-run\":\n\t\t\tif (room.plan) await Chat.controlRun(chat(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"chat:unqueue\":\n\t\t\tif (room.plan) Chat.unqueue(chat(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"conversation-plan:correct\":\n\t\tcase \"conversation-plan:scoped-choice-save\":\n\t\tcase \"conversation-plan:retry\":\n\t\tcase \"conversation-plan:retry-job\":\n\t\t\tawait handleConversationCommand(frame, room, ws, {\n\t\t\t\tenabled: !!config.conversationPlan,\n\t\t\t\truntime: conversationRuntime,\n\t\t\t\tunavailable: id => archivingChannels.has(id) || deletingChannels.has(id),\n\t\t\t\trefreshAccess: () => refreshAccess(ws),\n\t\t\t\tchat: () => chat(room, ws),\n\t\t\t});\n\t\t\treturn;\n\n\t\tcase \"conversation-plan:research\":\n\t\tcase \"conversation-plan:research-link\":\n\t\tcase \"conversation-plan:research-edit\":\n\t\tcase \"conversation-plan:research-presence\":\n\t\t\tawait handleResearchCommand(frame, room, ws, {\n\t\t\t\tenabled: !!config.conversationPlan,\n\t\t\t\truntime: conversationRuntime,\n\t\t\t\tresearch: () => researchService,\n\t\t\t\tunavailable: id => archivingChannels.has(id) || deletingChannels.has(id),\n\t\t\t\trefreshAccess,\n\t\t\t\tstart: (current, socket, opened, offer) =>\n\t\t\t\t\tstartAcceptedResearch(current, socket, opened, offer, {\n\t\t\t\t\t\tresearch: () => researchService,\n\t\t\t\t\t\tauth: hostedAuth,\n\t\t\t\t\t\trefreshAccess,\n\t\t\t\t\t\tunavailable: id => archivingChannels.has(id) || deletingChannels.has(id),\n\t\t\t\t\t\townerAvailable: id => jobRunner?.ownerAvailable(id) ?? Promise.resolve(),\n\t\t\t\t\t\tplaceReference: placeResearchReference,\n\t\t\t\t\t\tscheduleRecovery: scheduleResearchRecovery,\n\t\t\t\t\t}),\n\t\t\t});\n\t\t\treturn;\n\n\t\tcase \"question:open\":\n\t\t\tif (room.plan) Questions.open(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:edit\":\n\t\t\tif (room.plan) await Questions.edit(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:discard\":\n\t\t\tif (room.plan) await Questions.discard(room.plan, server, room.id, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:reopen\":\n\t\t\tif (room.plan) await Questions.reopen(room.plan, server, room.id, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:presence\":\n\t\t\tif (room.plan) Questions.focus(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:submit\":\n\t\t\tif (room.plan) {\n\t\t\t\tlet opened = room.plan;\n\t\t\t\tlet claimant = chat(room, ws);\n\t\t\t\tawait Questions.submit(\n\t\t\t\t\topened,\n\t\t\t\t\tserver,\n\t\t\t\t\troom.id,\n\t\t\t\t\tws,\n\t\t\t\t\tframe,\n\t\t\t\t\tintent => conversationRuntime.contexts.remember(opened, intent.trigger, claimant),\n\t\t\t\t);\n\t\t\t}\n\t\t\treturn;\n\n\t\tcase \"question:cancel\":\n\t\t\tif (room.plan) await Questions.cancel(room.plan, server, room.id, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"question:option\":\n\t\t\tif (room.plan) await Questions.addOption(room.plan, server, room.id, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:start\":\n\t\t\tif (room.plan) await Comments.start(room.plan, server, room.id, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:reply\":\n\t\t\tif (room.plan) await Comments.respond(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:typing\":\n\t\t\tif (room.plan) Comments.typing(room.plan, ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:accept\":\n\t\t\tif (room.plan) await Comments.accept(chat(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:dismiss\":\n\t\t\tif (room.plan) await Comments.dismiss(chat(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"job:list\":\n\t\t\ttry {\n\t\t\t\tif (!config.backgroundJobs) throw new Error(\"background jobs are disabled\");\n\t\t\t\treply(ws, frame.rid, await JobBrowser.listJobs(jobService, room.id));\n\t\t\t} catch (err) {\n\t\t\t\tfail(ws, frame.rid, err instanceof Error ? err.message : \"cannot list jobs\");\n\t\t\t}\n\t\t\treturn;\n\n\t\tcase \"job:get\":\n\t\t\ttry {\n\t\t\t\tif (!config.backgroundJobs) throw new Error(\"background jobs are disabled\");\n\t\t\t\treply(ws, frame.rid, await JobBrowser.getJob(jobService, room.id, frame.id));\n\t\t\t} catch (err) {\n\t\t\t\tfail(ws, frame.rid, err instanceof Error ? err.message : \"cannot read job\");\n\t\t\t}\n\t\t\treturn;\n\n\t\tcase \"job:cancel\":\n\t\t\ttry {\n\t\t\t\tif (!config.backgroundJobs) throw new Error(\"background jobs are disabled\");\n\t\t\t\treply(\n\t\t\t\t\tws,\n\t\t\t\t\tframe.rid,\n\t\t\t\t\tawait JobBrowser.cancelResearchWorkspaceJob(\n\t\t\t\t\t\tjobService,\n\t\t\t\t\t\troom.id,\n\t\t\t\t\t\tframe.id,\n\t\t\t\t\t),\n\t\t\t\t);\n\t\t\t} catch (err) {\n\t\t\t\tfail(ws, frame.rid, err instanceof Error ? err.message : \"cannot cancel job\");\n\t\t\t}\n\t\t\treturn;\n\t}\n}\n\nconst VIEWER_ALLOWED = new Set([\n\t\"session:ping\",\n\t\"plan:open\",\n\t\"plan:close\",\n\t\"job:list\",\n\t\"job:get\",\n\t\"conversation-plan:research-link\",\n]);\n\nasync function refreshAccess(ws: Socket, forceGitHub = false): Promise {\n\treturn refreshAuthorization(ws.data, forceGitHub, forced => checkAccess(ws, forced));\n}\n\nfunction applyChannelAccess(\n\tws: Socket,\n\tchannel: ChannelRecord,\n\tcanManage: boolean,\n\tpublish = true,\n): void {\n\tlet data = ws.data;\n\tlet archivedAt = channel.archivedAt?.toISOString();\n\tlet description = channel.description?.value;\n\tlet descriptionRevision = channel.description?.revision ?? 0;\n\tlet canEdit = canManage && !archivedAt && !archivingChannels.has(data.room);\n\tif (\n\t\t(channel.updatedAt.toISOString() !== data.channelUpdatedAt\n\t\t\t|| archivedAt !== data.channelArchivedAt\n\t\t\t|| descriptionRevision !== data.channelDescriptionRevision)\n\t\t&& !data.closed && publish\n\t) {\n\t\ttell(ws, {\n\t\t\tkind: \"session:channel\",\n\t\t\tts: 0,\n\t\t\tchannelId: channel.id,\n\t\t\ttitle: channel.title,\n\t\t\tslug: channel.slug,\n\t\t\tupdatedAt: channel.updatedAt.toISOString(),\n\t\t\tdescriptionRevision,\n\t\t\t...(description ? { description } : {}),\n\t\t\tcanManage,\n\t\t\t...(archivedAt ? { archivedAt } : {}),\n\t\t});\n\t}\n\tif ((canEdit !== data.canEdit || canManage !== data.canManage) && !data.closed && publish) {\n\t\ttell(ws, { kind: \"session:access\", ts: 0, canEdit, canManage });\n\t}\n\tdata.channelTitle = channel.title;\n\tdata.channelSlug = channel.slug;\n\tdata.channelUpdatedAt = channel.updatedAt.toISOString();\n\tdata.channelDescription = description;\n\tdata.channelDescriptionRevision = descriptionRevision;\n\tdata.channelArchivedAt = archivedAt;\n\tdata.canEdit = canEdit;\n\tdata.canManage = canManage;\n}\n\nasync function checkAccess(ws: Socket, forceGitHub: boolean): Promise {\n\tif (ws.data.closed) return \"denied\";\n\tlet data = ws.data;\n\tif (\n\t\t!data.credential\n\t\t|| !data.principalId\n\t\t|| !data.repositoryId\n\t\t|| !data.repositoryOwner\n\t\t|| !data.repositoryName\n\t\t|| (data.authorizedUntil ?? 0) <= Date.now()\n\t) return \"denied\";\n\ttry {\n\t\tlet request = new Request(hostedAuth.config.origin, { headers: { cookie: data.credential } });\n\t\tlet session = await hostedAuth.sessions.authenticate(request);\n\t\tif (!session || session.user.id !== data.principalId) return \"denied\";\n\t\tlet channel = deletingChannels.has(data.room)\n\t\t\t? undefined\n\t\t\t: await storage.channels.get(data.room);\n\t\tif (!channel || channel.repositoryId !== data.repositoryId) return \"denied\";\n\t\tif (!forceGitHub && Date.now() - (data.accessCheckedAt ?? 0) < ACCESS_RECHECK_MS) {\n\t\t\tapplyChannelAccess(ws, channel, data.canManage);\n\t\t\treturn \"allowed\";\n\t\t}\n\t\tlet access = await hostedAuth.sessions.use(\n\t\t\tsession,\n\t\t\ttoken =>\n\t\t\t\thostedAuth.github.repositoryAccess(\n\t\t\t\t\ttoken,\n\t\t\t\t\tdata.repositoryOwner!,\n\t\t\t\t\tdata.repositoryName!,\n\t\t\t\t),\n\t\t);\n\t\tlet repository = access.value;\n\t\tif (!repository || repository.id !== data.repositoryId || !repository.permissions.pull) {\n\t\t\treturn \"denied\";\n\t\t}\n\t\tif (channel.repositoryId !== repository.id) return \"denied\";\n\t\tlet canManage = repository.permissions.push || repository.permissions.admin;\n\t\tapplyChannelAccess(ws, channel, canManage);\n\t\tdata.accessCheckedAt = Date.now();\n\t\tdata.authorizedUntil = access.authenticated.session.expiresAt.getTime();\n\t\tdata.repositoryDefaultBranch = repository.defaultBranch;\n\t\treturn \"allowed\";\n\t} catch (err) {\n\t\tif (\n\t\t\t(err instanceof GitHubError\n\t\t\t\t&& (err.status === 429 || err.status === 502 || err.status === 503))\n\t\t\t|| (err instanceof StorageError && err.failure === \"unavailable\")\n\t\t) return \"unavailable\";\n\t\treturn \"denied\";\n\t}\n}\n\nfunction scheduleAuthorization(ws: Socket): void {\n\tif (ws.data.closed) return;\n\tws.data.authorizationTimer = setTimeout(() => {\n\t\tvoid refreshAccess(ws, true).then(result => {\n\t\t\tif (ws.data.closed) return;\n\t\t\tif (result === \"denied\") ws.close(4403, \"authorization expired\");\n\t\t\telse scheduleAuthorization(ws);\n\t\t});\n\t}, ACCESS_RECHECK_MS);\n}\n\nasync function validateOpenedSocket(ws: Socket): Promise {\n\tlet channel = deletingChannels.has(ws.data.room)\n\t\t? undefined\n\t\t: await storage.channels.get(ws.data.room);\n\tif (\n\t\t!channel || channel.repositoryId !== ws.data.repositoryId || deletingChannels.has(channel.id)\n\t) {\n\t\ttell(ws, { kind: \"session:deleted\", ts: 0, channelId: ws.data.room });\n\t\tws.close(4404, \"document deleted\");\n\t\treturn;\n\t}\n\tif (ws.data.closed) return;\n\tapplyChannelAccess(ws, channel, ws.data.canManage);\n}\n\nfunction listen(): Server {\n\treturn Bun.serve({\n\t\thostname: config.host,\n\t\tport: config.port,\n\n\t\tasync fetch(req, self) {\n\t\t\tlet url = new URL(req.url);\n\n\t\t\tif (url.pathname === \"/ws\") {\n\t\t\t\tlet outcome = await admit(req, url, hostedAuth, {\n\t\t\t\t\tdeleting: channelId => deletingChannels.has(channelId),\n\t\t\t\t\treadOnly: channelId => archivingChannels.has(channelId),\n\t\t\t\t});\n\t\t\t\tif (\"status\" in outcome) {\n\t\t\t\t\treturn new Response(outcome.reason, { status: outcome.status });\n\t\t\t\t}\n\t\t\t\tif (\n\t\t\t\t\treq.headers.get(\"x-chopin-socket-probe\") === \"1\"\n\t\t\t\t\t&& req.headers.get(\"upgrade\")?.toLowerCase() !== \"websocket\"\n\t\t\t\t) return new Response(null, { status: 204 });\n\t\t\t\tif (self.upgrade(req, { data: outcome.data })) return undefined;\n\t\t\t\treturn new Response(\"upgrade failed\", { status: 400 });\n\t\t\t}\n\t\t\tlet routed = await router.handle(req, url);\n\t\t\tif (routed) return routed;\n\n\t\t\treturn config.devClient ? proxy(req, url, config.devClient) : serve(url, CLIENT);\n\t\t},\n\n\t\twebsocket: {\n\t\t\topen(ws: Socket) {\n\t\t\t\t// Every mutation revalidates document state; the admission snapshot keeps startup stable.\n\t\t\t\tws.data.canEdit = ws.data.canEdit\n\t\t\t\t\t&& !archivingChannels.has(ws.data.room)\n\t\t\t\t\t&& !deletingChannels.has(ws.data.room);\n\t\t\t\tws.subscribe(topic(ws.data.room));\n\t\t\t\tlet room = Rooms.join(ws);\n\t\t\t\ttell(ws, {\n\t\t\t\t\tkind: \"session:hello\",\n\t\t\t\t\tts: 0,\n\t\t\t\t\tchannelId: room.id,\n\t\t\t\t\ttitle: ws.data.channelTitle,\n\t\t\t\t\tslug: ws.data.channelSlug,\n\t\t\t\t\tupdatedAt: ws.data.channelUpdatedAt,\n\t\t\t\t\tdescriptionRevision: ws.data.channelDescriptionRevision,\n\t\t\t\t\t...(ws.data.channelDescription\n\t\t\t\t\t\t? { description: ws.data.channelDescription }\n\t\t\t\t\t\t: {}),\n\t\t\t\t\tyou: { handle: ws.data.handle, client: ws.data.client },\n\t\t\t\t\tmembers: Rooms.members(room),\n\t\t\t\t\tcanEdit: ws.data.canEdit,\n\t\t\t\t\tcanManage: ws.data.canManage,\n\t\t\t\t\t...(ws.data.channelArchivedAt ? { archivedAt: ws.data.channelArchivedAt } : {}),\n\t\t\t\t\tbackgroundJobs: config.backgroundJobs,\n\t\t\t\t\twebResearch: config.webResearch,\n\t\t\t\t\t...CHAT_CAPABILITIES,\n\t\t\t\t});\n\t\t\t\trelay(ws, { kind: \"session:presence\", ts: 0, members: Rooms.members(room) });\n\t\t\t\tscheduleAuthorization(ws);\n\t\t\t\tvoid validateOpenedSocket(ws).catch(err => {\n\t\t\t\t\tconsole.error(\"chopin: WebSocket open failed -\", err);\n\t\t\t\t\tws.close(1011, \"cannot open document\");\n\t\t\t\t});\n\t\t\t},\n\n\t\t\tmessage(ws: Socket, raw) {\n\t\t\t\tif (typeof raw !== \"string\") return;\n\t\t\t\tvoid receive(ws, raw).catch(err => {\n\t\t\t\t\tconsole.error(\"chopin: WebSocket receive failed -\", err);\n\t\t\t\t});\n\t\t\t},\n\n\t\t\tclose(ws: Socket) {\n\t\t\t\tws.data.closed = true;\n\t\t\t\tif (ws.data.authorizationTimer) clearTimeout(ws.data.authorizationTimer);\n\t\t\t\tlet room = Rooms.leave(ws);\n\t\t\t\tws.unsubscribe(topic(ws.data.room));\n\t\t\t\tif (!room) return;\n\t\t\t\tif (room.plan) {\n\t\t\t\t\tService.departed(room.plan, ws);\n\t\t\t\t\tQuestions.away(room.plan, ws);\n\t\t\t\t\tconversationRuntime.processor(room.plan)?.leaveResearch(ws.data.client);\n\t\t\t\t\tComments.away(room.plan, ws);\n\t\t\t\t}\n\t\t\t\tif (room.members.size > 0) presence(server, room);\n\t\t\t\telse evict(room);\n\t\t\t},\n\t\t},\n\t});\n}\n\n/** Nothing in memory is worth losing to a Ctrl-C. */\nlet draining: Promise | undefined;\n\nfunction drain(): Promise {\n\treturn draining ??= (async () => {\n\t\tlet errors: Error[] = [];\n\t\tlet record = (reason: unknown) => {\n\t\t\terrors.push(reason instanceof Error ? reason : new Error(String(reason)));\n\t\t};\n\t\tlet attempt = async (operation: () => Promise) => {\n\t\t\ttry {\n\t\t\t\tawait operation();\n\t\t\t} catch (err) {\n\t\t\t\trecord(err);\n\t\t\t}\n\t\t};\n\t\tawait attempt(() => server.stop(true));\n\t\tif (researchRecoveryTimer) clearTimeout(researchRecoveryTimer);\n\t\tif (recoveringResearch) await attempt(() => recoveringResearch!);\n\t\tif (sessionCleanup) clearInterval(sessionCleanup);\n\t\tfor (let result of await Promise.allSettled([cleaningSessions])) {\n\t\t\tif (result.status === \"rejected\") record(result.reason);\n\t\t}\n\t\tlet rooms = await Promise.allSettled(\n\t\t\tRooms.all().map(async room => {\n\t\t\t\tlet opened = room.plan;\n\t\t\t\tif (!opened) return;\n\t\t\t\tlet stopped = conversationRuntime.stop(opened);\n\t\t\t\tawait stopped;\n\t\t\t\tawait Service.close(opened);\n\t\t\t}),\n\t\t);\n\t\tfor (let result of rooms) {\n\t\t\tif (result.status === \"rejected\") record(result.reason);\n\t\t}\n\t\tif (summaryCoordinator) await attempt(() => summaryCoordinator!.flush());\n\t\tsummaryCoordinator?.close();\n\t\tlet stoppingJobs = jobRunner?.shutdown();\n\t\townerBindings?.revokeAll();\n\t\tfor (let result of await Promise.allSettled([stoppingJobs])) {\n\t\t\tif (result.status === \"rejected\") record(result.reason);\n\t\t}\n\t\tawait attempt(() => shutdownHarnesses());\n\t\tif (leaseRenewal) clearInterval(leaseRenewal);\n\t\tif (leaseWatchdog) clearTimeout(leaseWatchdog);\n\t\tfor (let result of await Promise.allSettled([renewingLease])) {\n\t\t\tif (result.status === \"rejected\") record(result.reason);\n\t\t}\n\t\tlet lease = heldLease;\n\t\tif (lease) await attempt(() => storage.leases.release(lease));\n\t\tawait attempt(() => storage.close());\n\t\tif (errors.length > 0) throw new AggregateError(errors, \"Chopin shutdown failed.\");\n\t})();\n}\n\nfunction signal(): void {\n\tvoid drain().then(\n\t\t() => process.exit(0),\n\t\terr => {\n\t\t\tconsole.error(\"chopin: shutdown failed -\", err);\n\t\t\tprocess.exit(1);\n\t\t},\n\t);\n}\n\nfunction renewLease(): void {\n\tif (!heldLease || renewingLease) return;\n\trenewingLease = storage.leases.renew(heldLease, LEASE_TTL_MS).then(renewed => {\n\t\tif (renewed) {\n\t\t\theldLease = renewed;\n\t\t\tarmLeaseWatchdog();\n\t\t} else {\n\t\t\tconsole.error(\"chopin: lost the storage writer lease\");\n\t\t\theldLease = undefined;\n\t\t\tsignal();\n\t\t}\n\t}, err => {\n\t\tconsole.error(\"chopin: could not renew the storage writer lease -\", err);\n\t\theldLease = undefined;\n\t\tsignal();\n\t}).finally(() => {\n\t\trenewingLease = undefined;\n\t});\n}\n\nfunction armLeaseWatchdog(): void {\n\tif (leaseWatchdog) clearTimeout(leaseWatchdog);\n\tleaseWatchdog = setTimeout(() => {\n\t\tconsole.error(\"chopin: storage writer lease was not renewed before its safety deadline\");\n\t\theldLease = undefined;\n\t\tsignal();\n\t}, LEASE_TTL_MS - LEASE_SAFETY_MS);\n}\n\nfunction cleanSessions(): void {\n\tif (cleaningSessions) return;\n\tcleaningSessions = hostedAuth.sessions.cleanupExpired().then(() => {}, err => {\n\t\tconsole.error(\"chopin: could not delete expired login sessions -\", err);\n\t}).finally(() => {\n\t\tcleaningSessions = undefined;\n\t});\n}\n\nasync function resetOpenAgents(\n\tfilter: (room: Rooms.Room) => boolean,\n\tsessionId?: string,\n\trevision?: number,\n\treason?: string,\n): Promise {\n\tawait Promise.all(\n\t\tRooms.all().filter(filter).map(room =>\n\t\t\troom.plan ? Chat.resetAgent(room.plan.chat, sessionId, revision, reason) : Promise.resolve()\n\t\t),\n\t);\n}\n\nfunction announceChannel(channel: ChannelRecord): void {\n\tlet room = Rooms.get(channel.id);\n\tif (!room) return;\n\tfor (let ws of room.members.values()) {\n\t\tws.data.channelTitle = channel.title;\n\t\tws.data.channelSlug = channel.slug;\n\t\tws.data.channelUpdatedAt = channel.updatedAt.toISOString();\n\t\tws.data.channelDescription = channel.description?.value;\n\t\tws.data.channelDescriptionRevision = channel.description?.revision ?? 0;\n\t\tws.data.channelArchivedAt = channel.archivedAt?.toISOString();\n\t\tws.data.canEdit = ws.data.canManage && !channel.archivedAt;\n\t\ttell(ws, {\n\t\t\tkind: \"session:channel\",\n\t\t\tts: 0,\n\t\t\tchannelId: channel.id,\n\t\t\ttitle: channel.title,\n\t\t\tslug: channel.slug,\n\t\t\tupdatedAt: channel.updatedAt.toISOString(),\n\t\t\tdescriptionRevision: channel.description?.revision ?? 0,\n\t\t\t...(channel.description ? { description: channel.description.value } : {}),\n\t\t\tcanManage: ws.data.canManage,\n\t\t\t...(channel.archivedAt ? { archivedAt: channel.archivedAt.toISOString() } : {}),\n\t\t});\n\t\ttell(ws, {\n\t\t\tkind: \"session:access\",\n\t\t\tts: 0,\n\t\t\tcanEdit: ws.data.canEdit,\n\t\t\tcanManage: ws.data.canManage,\n\t\t});\n\t}\n}\n\nasync function archiveChannelLocked(channelId: string, now: Date) {\n\tif (deletingChannels.has(channelId)) {\n\t\tthrow new StorageError(\"missing\", `channel ${channelId} is being deleted`);\n\t}\n\tarchivingChannels.add(channelId);\n\tlet room = Rooms.get(channelId);\n\tfor (let ws of room?.members.values() ?? []) ws.data.canEdit = false;\n\ttry {\n\t\tawait summaryCoordinator?.suspend(channelId);\n\t\tlet result = await withDocumentLock(channelId, async () => {\n\t\t\tlet active = Rooms.get(channelId)?.plan;\n\t\t\tif (active) {\n\t\t\t\tlet stopped = conversationRuntime.stop(active);\n\t\t\t\tawait Chat.resetAgent(active.chat, undefined, undefined, \"This document was archived.\");\n\t\t\t\tawait stopped;\n\t\t\t\tawait conversationRuntime.interrupt(active);\n\t\t\t\tawait Service.drain(active);\n\t\t\t\tawait Service.persist(active);\n\t\t\t}\n\t\t\treturn storage.channels.archive({ id: channelId, now });\n\t\t});\n\t\tannounceChannel(result.channel);\n\t\treturn result;\n\t} catch (err) {\n\t\tsummaryCoordinator?.resume(channelId);\n\t\tfor (let ws of room?.members.values() ?? []) ws.data.canEdit = ws.data.canManage;\n\t\tthrow err;\n\t} finally {\n\t\tarchivingChannels.delete(channelId);\n\t\tlet current = Rooms.get(channelId);\n\t\tlet opened = await recoverAttachedPlan(current);\n\t\tif (current && opened) {\n\t\t\tlet channel = await storage.channels.get(channelId);\n\t\t\tif (\n\t\t\t\tRooms.get(channelId) === current && current.plan === opened\n\t\t\t\t&& !current.closing && !deletingChannels.has(channelId)\n\t\t\t) {\n\t\t\t\tawait conversationRuntime.attach(\n\t\t\t\t\tcurrent,\n\t\t\t\t\topened,\n\t\t\t\t\t!!channel?.archivedAt,\n\t\t\t\t\t!!channel && !channel.parentChannelId,\n\t\t\t\t);\n\t\t\t}\n\t\t}\n\t}\n}\n\nfunction archiveChannel(channelId: string, now: Date) {\n\treturn withDocumentTransition(channelId, () => archiveChannelLocked(channelId, now));\n}\n\nasync function restoreChannelLocked(channelId: string, now: Date) {\n\tif (deletingChannels.has(channelId)) {\n\t\tthrow new StorageError(\"missing\", `channel ${channelId} is being deleted`);\n\t}\n\tlet result = await withDocumentLock(\n\t\tchannelId,\n\t\t() => storage.channels.restore({ id: channelId, now }),\n\t);\n\tlet recovery = await researchService?.recoverPendingPlannerInline(\n\t\tplaceResearchReference,\n\t\tchannelId,\n\t);\n\tscheduleResearchRecovery(recovery?.deferred ?? 0);\n\tsummaryCoordinator?.resume(channelId);\n\tlet current = Rooms.get(channelId);\n\tif (current?.plan) {\n\t\tawait conversationRuntime.attach(current, current.plan, false, !result.channel.parentChannelId);\n\t}\n\tannounceChannel(result.channel);\n\tif (summaryCoordinator) void summaryCoordinator.ensure(channelId).catch(() => {});\n\treturn result;\n}\n\nfunction restoreChannel(channelId: string, now: Date) {\n\treturn withDocumentTransition(channelId, () => restoreChannelLocked(channelId, now));\n}\n\nasync function deleteChannelLocked(channelId: string): Promise {\n\tif (deletingChannels.has(channelId)) return false;\n\tlet channel = await storage.channels.get(channelId);\n\tif (!channel) return false;\n\tif (!channel.archivedAt) {\n\t\tthrow new StorageError(\"conflict\", `channel ${channelId} must be archived before deletion`);\n\t}\n\tdeletingChannels.add(channelId);\n\tlet room = Rooms.get(channelId);\n\tfor (let ws of room?.members.values() ?? []) ws.data.canEdit = false;\n\ttry {\n\t\tawait summaryCoordinator?.suspend(channelId);\n\t\tawait jobRunner?.cancelChannel(channelId);\n\t\townerBindings?.revokeChannel(channelId);\n\t\tlet deleted = await withDocumentLock(channelId, async () => {\n\t\t\tlet activeRoom = Rooms.get(channelId);\n\t\t\tlet active = activeRoom?.plan;\n\t\t\tif (activeRoom) activeRoom.plan = undefined;\n\t\t\tif (active) {\n\t\t\t\tlet stopped = conversationRuntime.stop(active);\n\t\t\t\tawait stopped;\n\t\t\t\tawait Service.close(active);\n\t\t\t}\n\t\t\treturn storage.channels.delete(channelId);\n\t\t});\n\t\tif (!deleted) throw new StorageError(\"missing\", `channel ${channelId} does not exist`);\n\t\tfor (let ws of room?.members.values() ?? []) {\n\t\t\ttell(ws, { kind: \"session:deleted\", ts: 0, channelId });\n\t\t\tws.close(4404, \"document deleted\");\n\t\t}\n\t\tif (room) Rooms.forget(room);\n\t\tsummaryCoordinator?.resume(channelId);\n\t\treturn true;\n\t} catch (err) {\n\t\tdeletingChannels.delete(channelId);\n\t\tsummaryCoordinator?.resume(channelId);\n\t\tjobRunner?.unblockChannel(channelId);\n\t\tlet channel: ChannelRecord | undefined;\n\t\ttry {\n\t\t\tchannel = await storage.channels.get(channelId);\n\t\t} catch {\n\t\t\tfor (let ws of room?.members.values() ?? []) {\n\t\t\t\tws.close(1012, \"document state is temporarily unavailable\");\n\t\t\t}\n\t\t\tthrow err;\n\t\t}\n\t\tif (channel) {\n\t\t\tlet survivingRoom = Rooms.get(channelId);\n\t\t\tif (survivingRoom?.members.size) {\n\t\t\t\ttry {\n\t\t\t\t\tawait plan(survivingRoom, server);\n\t\t\t\t} catch {\n\t\t\t\t\tfor (let ws of survivingRoom.members.values()) {\n\t\t\t\t\t\tws.close(1012, \"document reload required\");\n\t\t\t\t\t}\n\t\t\t\t}\n\t\t\t}\n\t\t\tannounceChannel(channel);\n\t\t} else {\n\t\t\tfor (let ws of room?.members.values() ?? []) {\n\t\t\t\ttell(ws, { kind: \"session:deleted\", ts: 0, channelId });\n\t\t\t\tws.close(4404, \"document deleted\");\n\t\t\t}\n\t\t\tif (room) Rooms.forget(room);\n\t\t}\n\t\tthrow err;\n\t} finally {\n\t\tdeletingChannels.delete(channelId);\n\t\tjobRunner?.unblockChannel(channelId);\n\t}\n}\n\nfunction deleteChannel(channelId: string): Promise {\n\treturn withDocumentTransition(channelId, () => deleteChannelLocked(channelId));\n}\n\nasync function announceJobsChanged(channelId: string): Promise {\n\tif (draining) return;\n\tlet page = await jobService.list(channelId, 1);\n\tif (!page) return;\n\tbroadcast(server, channelId, { kind: \"job:changed\", ts: 0, revision: page.revision });\n}\n\nfunction announceResearchChanged(channelId: string, workspaceId: string, revision: number): void {\n\tif (draining) return;\n\tbroadcast(server, channelId, {\n\t\tkind: \"research:changed\",\n\t\tts: 0,\n\t\tworkspaceId,\n\t\trevision,\n\t});\n}\n\nfunction announceResearchTerminal(channelId: string, id: string, text: string): Promise {\n\treturn withDocumentLock(channelId, async () => {\n\t\tlet active = Rooms.get(channelId)?.plan;\n\t\tif (active) {\n\t\t\tlet existing = active.chat.entries.find(entry => entry.id === id);\n\t\t\tawait Chat.noticeOnce(\n\t\t\t\t{ chat: active.chat, plan: active, server, room: channelId },\n\t\t\t\tid,\n\t\t\t\texisting?.text ?? text,\n\t\t\t);\n\t\t\treturn;\n\t\t}\n\t\tlet detached = await Service.open(channelId, documentBackend(), server);\n\t\ttry {\n\t\t\tlet existing = detached.chat.entries.find(entry => entry.id === id);\n\t\t\tawait Chat.noticeOnce(\n\t\t\t\t{ chat: detached.chat, plan: detached, server, room: channelId },\n\t\t\t\tid,\n\t\t\t\texisting?.text ?? text,\n\t\t\t);\n\t\t} finally {\n\t\t\tawait Service.close(detached);\n\t\t}\n\t});\n}\n\nasync function currentDocumentTarget(\n\tchannelId: string,\n): Promise {\n\tlet active = Rooms.get(channelId);\n\tif (active?.opening) await active.opening.catch(() => undefined);\n\tif (active?.plan) return Service.readCurrentDocument(active.plan);\n\tlet stored = await storage.collaboration.load(channelId, new Date());\n\tif (!stored) return undefined;\n\tlet projected = await Service.readStored(stored);\n\tactive = Rooms.get(channelId);\n\tif (active?.opening) await active.opening.catch(() => undefined);\n\tif (active?.plan) return Service.readCurrentDocument(active.plan);\n\treturn {\n\t\tchannelId,\n\t\trevision: projected.revision,\n\t\tsource: projected.source,\n\t\tsourceHash: Service.sourceHash(projected.source),\n\t};\n}\n\nasync function commitCurrentSummary(\n\tchannelId: string,\n\texpected: DocumentSummaryInput,\n\tcommit: () => Promise,\n): Promise {\n\treturn withDocumentLock(channelId, async () => {\n\t\tlet active = Rooms.get(channelId);\n\t\tif (active?.plan) {\n\t\t\tlet plan = active.plan;\n\t\t\treturn Service.exclusive(plan, async () => {\n\t\t\t\tlet source = Service.source(plan);\n\t\t\t\tif (\n\t\t\t\t\tplan.revision !== expected.revision\n\t\t\t\t\t|| Service.sourceHash(source) !== expected.sourceHash\n\t\t\t\t) return false;\n\t\t\t\tawait commit();\n\t\t\t\treturn true;\n\t\t\t});\n\t\t}\n\t\tlet stored = await storage.collaboration.load(channelId, new Date());\n\t\tif (!stored) return false;\n\t\tlet projected = await Service.readStored(stored);\n\t\tif (\n\t\t\tprojected.revision !== expected.revision\n\t\t\t|| Service.sourceHash(projected.source) !== expected.sourceHash\n\t\t) return false;\n\t\tawait commit();\n\t\treturn true;\n\t});\n}\n\nasync function sessionRevoked(sessionId: string): Promise {\n\tlet jobs = jobRunner?.ownerRevoked(sessionId);\n\townerBindings?.revokeSession(sessionId);\n\tawait Promise.all([resetOpenAgents(() => true, sessionId), jobs]);\n}\n\nasync function credentialsWillRotate(sessionId: string, revision: number): Promise {\n\tlet jobs = jobRunner?.credentialsWillRotate(sessionId, revision);\n\townerBindings?.revokeCredential(sessionId, revision);\n\tawait Promise.all([\n\t\tresetOpenAgents(\n\t\t\t() => true,\n\t\t\tsessionId,\n\t\t\trevision,\n\t\t\t\"GitHub credentials refreshed, so the Planner session was restarted. Ask it to continue.\",\n\t\t),\n\t\tjobs,\n\t]);\n}\n\nasync function channelOwnerReset(channelId: string): Promise {\n\tlet jobs = jobRunner?.channelOwnerReset(channelId);\n\townerBindings?.revokeChannel(channelId);\n\tawait Promise.all([resetOpenAgents(room => room.id === channelId), jobs]);\n}\n\nlet hostedAuth = registerAuthRoutes(router, {\n\tconfig: config.auth,\n\tstorage,\n\tagent: config.agent,\n\tonSessionRevoked: sessionRevoked,\n\tonCredentialsWillRotate: credentialsWillRotate,\n});\nownerBindings = new ActiveOwnerBindings(hostedAuth);\nlet definitions: JobDefinition[] = [];\nif (config.backgroundJobs) {\n\tdefinitions.push(researchBriefDefinition({ config }));\n\tdefinitions.push(documentSummaryDefinition({\n\t\tconfig,\n\t\tcurrent: currentDocumentTarget,\n\t\trefresh: target => summaryCoordinator?.enqueueNow(target) ?? Promise.resolve(),\n\t\tcommitCurrent: commitCurrentSummary,\n\t}));\n}\nif (config.backgroundJobs && config.agent) {\n\tdefinitions.push(researchAnswerDefinition({ config }));\n}\nif (config.webResearch) {\n\tdefinitions.push(researchEvidenceDefinition({ config }));\n}\nlet jobRegistry = new JobRegistry(definitions);\nlet jobService = new JobService({\n\tstorage,\n\tregistry: jobRegistry,\n\tlease() {\n\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\treturn heldLease;\n\t},\n\tonChange: job => {\n\t\tjobRunner?.notify(job);\n\t\tif (job.type === \"research-brief\") {\n\t\t\tlet opened = Rooms.get(job.channelId)?.plan;\n\t\t\tif (opened) conversationRuntime.wake(opened);\n\t\t}\n\t\tif (job.state === \"completed\") {\n\t\t\tvoid descriptionProjector?.jobChanged(job).catch(err => {\n\t\t\t\tconsole.error(\"chopin: document description reconciliation failed -\", err);\n\t\t\t});\n\t\t\tvoid researchService?.jobChanged(job).catch(err => {\n\t\t\t\tconsole.error(\"chopin: research workspace reconciliation failed -\", err);\n\t\t\t});\n\t\t}\n\t},\n\tpublish: announceJobsChanged,\n});\nif (config.agent && config.backgroundJobs) researchBriefJobs = jobService;\nif (config.backgroundJobs) {\n\tdescriptionProjector = new DocumentDescriptionProjector({\n\t\tstorage,\n\t\tlease() {\n\t\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\t\treturn heldLease;\n\t\t},\n\t\tpublish: announceChannel,\n\t});\n}\nresearchService = new ResearchWorkspaceService({\n\tstorage,\n\tjobs: jobService,\n\tlease() {\n\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\treturn heldLease;\n\t},\n\tcurrent: currentDocumentTarget,\n\tpublish: announceResearchChanged,\n\tterminalNotice: announceResearchTerminal,\n});\nreferenceService = new ReferenceService({\n\tstorage,\n\tcurrent: currentDocumentTarget,\n\tresearch: researchService,\n\tid: ulid,\n});\nif (config.agent && config.backgroundJobs) {\n\tsummaryCoordinator = new DocumentSummaryCoordinator({\n\t\tservice: jobService,\n\t\tcurrent: currentDocumentTarget,\n\t\tcompleted: job => descriptionProjector?.jobChanged(job) ?? Promise.resolve(),\n\t\terror: err => console.error(\"chopin: document description scheduling failed -\", err),\n\t});\n}\njobRunner = new JobRunner({\n\tstorage,\n\tservice: jobService,\n\tregistry: jobRegistry,\n\tlease() {\n\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\treturn heldLease;\n\t},\n\tresolveActivePlanner: async job => {\n\t\tlet binding = await ownerBindings!.resolve(job.channelId);\n\t\tif (!binding) return undefined;\n\t\treturn {\n\t\t\tcredential: {\n\t\t\t\tkind: \"active-planner\",\n\t\t\t\ttoken: binding.token,\n\t\t\t\townerSessionId: binding.ownerSessionId,\n\t\t\t\townerGeneration: binding.ownerGeneration,\n\t\t\t\tcredentialRevision: binding.credentialRevision,\n\t\t\t\texpiresAt: new Date(binding.expiresAt),\n\t\t\t\tsignal: binding.signal,\n\t\t\t\tauthorize: binding.revalidate,\n\t\t\t},\n\t\t\townerKey: binding.ownerSessionId,\n\t\t\tbinding: {\n\t\t\t\tkind: \"active-planner\",\n\t\t\t\townerSessionId: binding.ownerSessionId,\n\t\t\t\townerGeneration: binding.ownerGeneration,\n\t\t\t\tcredentialRevision: binding.credentialRevision,\n\t\t\t\trepositoryId: binding.repository.id,\n\t\t\t},\n\t\t\tsignal: binding.signal,\n\t\t\tactive: binding.revalidate,\n\t\t\trelease: binding.release,\n\t\t};\n\t},\n\tenabled: config.agent && config.backgroundJobs,\n\tglobalConcurrency: 2,\n\townerConcurrency: 1,\n\tchanged: announceJobsChanged,\n\tattemptFailed(job, err) {\n\t\tlet reason = err instanceof Error ? `${err.name}: ${err.message}` : String(err);\n\t\tlet diagnostic = err instanceof JobExecutionError && err.diagnostic\n\t\t\t? ` diagnostic=${JSON.stringify(err.diagnostic)}`\n\t\t\t: \"\";\n\t\tconsole.warn(\n\t\t\t`chopin: background job ${job.type} ${job.id} attempt ${job.attempts} failed - ${reason}${diagnostic}`,\n\t\t);\n\t},\n\tfatal: err => console.error(\"chopin: background job runner failed -\", err),\n});\nregisterMcpRoutes(router, hostedAuth, {\n\tlease() {\n\t\tif (!heldLease) throw new Error(\"storage writer lease is unavailable\");\n\t\treturn heldLease;\n\t},\n}, {\n\tinvokePlanner: input =>\n\t\twithDocumentTransition(input.channel.id, async () => {\n\t\t\tlet channel = await storage.channels.get(input.channel.id);\n\t\t\tif (!channel || deletingChannels.has(channel.id)) return \"document-unavailable\";\n\t\t\tif (channel.archivedAt) return \"document-archived\";\n\t\t\tawait Rooms.get(channel.id)?.closing;\n\t\t\tlet held = Rooms.hold(channel.id);\n\t\t\tlet release = () => {\n\t\t\t\theld.release();\n\t\t\t\tevict(held.room);\n\t\t\t};\n\t\t\tlet running = false;\n\t\t\ttry {\n\t\t\t\tawait plan(held.room, server);\n\t\t\t\tlet context = conversation(held.room, input.session?.session.id, input.repository);\n\t\t\t\tlet code = await Chat.invoke(context, input.user, input.instruction, input.checkout);\n\t\t\t\tif (!code && context.chat.running) {\n\t\t\t\t\trunning = true;\n\t\t\t\t\tvoid context.chat.running.finally(release).catch(() => {});\n\t\t\t\t}\n\t\t\t\treturn code;\n\t\t\t} finally {\n\t\t\t\tif (!running) release();\n\t\t\t}\n\t\t}),\n\tarchiveChannel,\n\tisChannelDeleting: channelId => deletingChannels.has(channelId),\n\tonChannelRenamed: announceChannel,\n\tonDocumentPersisted: target => {\n\t\tif (summaryCoordinator) void summaryCoordinator.enqueueNow(target).catch(() => {});\n\t},\n\trestoreChannel,\n\tserializeDocument: (channelId, action) =>\n\t\twithDocumentTransition(channelId, () => withDocumentLock(channelId, action)),\n});\nregisterChannelRoutes(router, hostedAuth, {\n\tonAgentReset: channelOwnerReset,\n\tonChannelArchived: archiveChannel,\n\tonChannelDeleted: deleteChannel,\n\tonChannelRenamed: announceChannel,\n\tonChannelRestored: restoreChannel,\n});\nregisterResearchWorkspaceRoutes(router, hostedAuth, {\n\tservice: researchService,\n\tasync ensureOwner(channel, session, repository) {\n\t\tawait Chat.resolveOwner(\n\t\t\thostedAuth,\n\t\t\t{\n\t\t\t\tid: channel.repositoryId,\n\t\t\t\towner: channel.repositoryOwner,\n\t\t\t\tname: channel.repositoryName,\n\t\t\t\tdefaultBranch: repository.defaultBranch,\n\t\t\t},\n\t\t\tchannel.id,\n\t\t\tsession.session.id,\n\t\t);\n\t\tawait jobRunner?.ownerAvailable(channel.id);\n\t},\n});\nregisterNavigationRoutes(router, hostedAuth, { storage });\n\ntry {\n\tawait storage.health();\n} catch (err) {\n\tawait storage.close().catch(() => {});\n\tlet reason = err instanceof Error ? err.message : String(err);\n\tconsole.error(`chopin: storage could not start - ${reason}`);\n\tprocess.exit(1);\n}\n\ntry {\n\theldLease = await storage.leases.acquire(\n\t\t\"chopin:writer\",\n\t\tcrypto.randomUUID(),\n\t\tLEASE_TTL_MS,\n\t);\n\tif (!heldLease) throw new Error(\"another Chopin instance owns the database\");\n\tlet reset = await storage.sessions.deleteAll(new Date(), heldLease, LEASE_TTL_MS);\n\theldLease = reset.lease;\n} catch (err) {\n\tawait shutdownHarnesses();\n\tif (heldLease) await storage.leases.release(heldLease).catch(() => {});\n\tawait storage.close().catch(() => {});\n\tlet reason = err instanceof Error ? err.message : String(err);\n\tconsole.error(`chopin: storage writer lease could not start - ${reason}`);\n\tprocess.exit(1);\n}\narmLeaseWatchdog();\nleaseRenewal = setInterval(renewLease, LEASE_RENEW_MS);\ncleanSessions();\nsessionCleanup = setInterval(cleanSessions, SESSION_CLEANUP_MS);\n\nlet listening: Server | undefined;\ntry {\n\tserver = listening = listen();\n\tlet recovery = await researchService.recoverPendingPlannerInline(placeResearchReference);\n\tscheduleResearchRecovery(recovery.deferred);\n\tawait researchService.recoverTerminalPlannerInline();\n\tjobRunner.start();\n} catch (err) {\n\tif (listening) await listening.stop(true).catch(() => {});\n\tif (researchRecoveryTimer) clearTimeout(researchRecoveryTimer);\n\tif (sessionCleanup) clearInterval(sessionCleanup);\n\tif (leaseRenewal) clearInterval(leaseRenewal);\n\tif (leaseWatchdog) clearTimeout(leaseWatchdog);\n\tawait cleaningSessions;\n\tawait renewingLease;\n\tsummaryCoordinator?.close();\n\tlet stoppingJobs = jobRunner.shutdown();\n\townerBindings.revokeAll();\n\tawait stoppingJobs.catch(() => {});\n\tawait shutdownHarnesses();\n\tif (heldLease) await storage.leases.release(heldLease).catch(() => {});\n\tawait storage.close().catch(() => {});\n\tthrow err;\n}\nprocess.on(\"SIGINT\", signal);\nprocess.on(\"SIGTERM\", signal);\n\nconsole.log(describe(config));\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",1794616359871,"sidebar","expanded"]