[{"_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","a9c593e970d62f6ee545630e5d4cdddea73828ec","path","apps/server/src/main.ts","oid","f5440091555c794aeb9e5667815446c145ed2ef9","size",27858,"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\";\n\nimport * as Agent from \"./agent/client\";\nimport { ActiveOwnerBindings } from \"./agent/active-owner\";\nimport { registerAuthRoutes } from \"./auth/routes\";\nimport * as Chat from \"./chat/service\";\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 { JobRegistry } from \"./jobs/registry\";\nimport * as JobBrowser from \"./jobs/browser\";\nimport { documentSummaryDefinition } from \"./jobs/document-summary\";\nimport { JobRunner } from \"./jobs/runner\";\nimport { researchQuestionDefinition, researchQuestionSnapshot } from \"./jobs/research-question\";\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 * as Rooms from \"./rooms\";\nimport { admit } from \"./socket/admission\";\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 { Incoming } from \"@chopin/protocol\";\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();\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;\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 summaryCoordinator: DocumentSummaryCoordinator | undefined;\nlet documentLocks = new Map>();\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 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\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 */\nfunction plan(room: Rooms.Room, server: Server): Promise {\n\tif (room.plan) return Promise.resolve(room.plan);\n\tlet backend: Service.Backend = {\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\treturn room.opening ??= withDocumentLock(room.id, () => Service.open(room.id, backend, server))\n\t\t.then(async opened => {\n\t\t\troom.plan = opened;\n\t\t\troom.opening = undefined;\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\treturn opened;\n\t\t})\n\t\t.catch(err => {\n\t\t\troom.opening = undefined;\n\t\t\tthrow err;\n\t\t});\n}\n\n/** A room's conversation, with everything it needs to run a turn. */\nfunction conversation(room: Rooms.Room, ws: Socket): Chat.Room {\n\treturn {\n\t\tchat: room.plan!.chat,\n\t\tplan: room.plan!,\n\t\tserver,\n\t\troom: room.id,\n\t\tconfig,\n\t\tauth: hostedAuth,\n\t\tclaimantSessionId: ws.data.sessionId,\n\t\trepository: {\n\t\t\tid: ws.data.repositoryId,\n\t\t\towner: ws.data.repositoryOwner,\n\t\t\tname: ws.data.repositoryName,\n\t\t\tdefaultBranch: ws.data.repositoryDefaultBranch,\n\t\t},\n\t\tpersist: () => Service.persist(room.plan!),\n\t\townerAvailable: () => jobRunner?.ownerAvailable(room.id) ?? Promise.resolve(),\n\t\tjobs: config.backgroundJobs ? jobService : undefined,\n\t};\n}\n\nfunction evict(room: Rooms.Room): void {\n\tif (room.eviction || room.members.size > 0) return;\n\troom.eviction = setTimeout(() => {\n\t\tif (room.members.size > 0) return;\n\t\tlet held = room.plan;\n\t\tRooms.forget(room);\n\t\tif (held) void Service.close(held);\n\t}, EVICT_MS);\n}\n\nasync function receive(ws: Socket, raw: string): Promise {\n\tlet frame: Incoming;\n\ttry {\n\t\tframe = JSON.parse(raw) as Incoming;\n\t} catch {\n\t\treturn;\n\t}\n\n\tlet room = Rooms.get(ws.data.room);\n\tif (!room) return;\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\tService.greet(opened, ws, frame);\n\t\t\t\t// Anything still unanswered, so a joiner sees the sidecar the\n\t\t\t\t// others are already looking at, and everything said so far.\n\t\t\t\tQuestions.greet(opened, ws);\n\t\t\t\tComments.greet(opened, ws);\n\t\t\t\tChat.greet(opened.chat, ws);\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\tif (room.plan) await Chat.send(conversation(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"chat:abort\":\n\t\t\tif (room.plan) await Chat.abort(conversation(room, ws), ws);\n\t\t\treturn;\n\n\t\tcase \"chat:unqueue\":\n\t\t\tif (room.plan) Chat.unqueue(conversation(room, ws), ws, frame);\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: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) await Questions.submit(room.plan, server, room.id, ws, frame);\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 \"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(conversation(room, ws), ws, frame);\n\t\t\treturn;\n\n\t\tcase \"comment:dismiss\":\n\t\t\tif (room.plan) await Comments.dismiss(conversation(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:assign\":\n\t\t\ttry {\n\t\t\t\tif (!config.webResearch) throw new Error(\"web research is disabled\");\n\t\t\t\tif (!room.plan) throw new Error(\"document is not open\");\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.assignResearchQuestion(\n\t\t\t\t\t\tjobService,\n\t\t\t\t\t\troom.plan,\n\t\t\t\t\t\tframe.questionId,\n\t\t\t\t\t\tframe.requestId,\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 assign research\");\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.cancelResearchJob(\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\tframe.expectedRevision,\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([\"session:ping\", \"plan:open\", \"plan:close\", \"job:list\", \"job:get\"]);\n\nasync function refreshAccess(ws: Socket, forceGitHub = false): Promise {\n\tlet data = ws.data;\n\tif (data.closed) return \"denied\";\n\tif (data.authorizationRefresh) {\n\t\tlet result = await data.authorizationRefresh;\n\t\tif (\n\t\t\tresult !== \"allowed\"\n\t\t\t|| !forceGitHub\n\t\t\t|| Date.now() - (data.accessCheckedAt ?? 0) < ACCESS_RECHECK_MS\n\t\t) {\n\t\t\treturn result;\n\t\t}\n\t}\n\tlet refresh = checkAccess(ws, forceGitHub);\n\tdata.authorizationRefresh = refresh;\n\ttry {\n\t\treturn await refresh;\n\t} finally {\n\t\tif (data.authorizationRefresh === refresh) data.authorizationRefresh = undefined;\n\t}\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\tif (!forceGitHub && Date.now() - (data.accessCheckedAt ?? 0) < ACCESS_RECHECK_MS) {\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\tlet canEdit = repository.permissions.push || repository.permissions.admin;\n\t\tif (canEdit !== data.canEdit && !data.closed) {\n\t\t\ttell(ws, { kind: \"session:access\", ts: 0, canEdit });\n\t\t}\n\t\tdata.canEdit = canEdit;\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 refreshChannelMetadata(ws: Socket, room: Rooms.Room): Promise {\n\ttry {\n\t\tlet channel = await storage.channels.get(room.id);\n\t\tif (!channel || channel.updatedAt <= new Date(ws.data.channelUpdatedAt)) return;\n\t\tif (ws.data.closed) return;\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});\n\t} catch {\n\t\t// Hello already carried the admission snapshot; a later rename event can supersede it.\n\t}\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\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\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\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\tbackgroundJobs: config.backgroundJobs,\n\t\t\t\t\twebResearch: config.webResearch,\n\t\t\t\t});\n\t\t\t\tvoid refreshChannelMetadata(ws, room);\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},\n\n\t\t\tmessage(ws: Socket, raw) {\n\t\t\t\tif (typeof raw === \"string\") void receive(ws, raw);\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\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 (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(room => room.plan && Service.close(room.plan)),\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(() => Agent.shutdown());\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 announceChannelRename(channel: ChannelRecord): void {\n\tbroadcast(server, channel.id, {\n\t\tkind: \"session:channel\",\n\t\tts: 0,\n\t\tchannelId: channel.id,\n\t\ttitle: channel.title,\n\t\tslug: channel.slug,\n\t\tupdatedAt: channel.updatedAt.toISOString(),\n\t});\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\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 commitCurrentResearch(\n\tchannelId: string,\n\tquestionId: string,\n\tquestionHash: string,\n\tdocumentRevision: number,\n\tdocumentSourceHash: string,\n\tcommit: () => Promise,\n): Promise {\n\treturn withDocumentLock(channelId, async () => {\n\t\tlet active = Rooms.get(channelId);\n\t\tlet source: string;\n\t\tif (active?.plan) {\n\t\t\tlet plan = active.plan;\n\t\t\treturn Service.exclusive(plan, async () => {\n\t\t\t\tsource = Service.source(plan);\n\t\t\t\tlet question = researchQuestionSnapshot(source, questionId);\n\t\t\t\tif (\n\t\t\t\t\tplan.revision !== documentRevision\n\t\t\t\t\t|| Service.sourceHash(source) !== documentSourceHash\n\t\t\t\t\t|| question?.questionHash !== questionHash\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\tsource = projected.source;\n\t\tlet question = researchQuestionSnapshot(source, questionId);\n\t\tif (\n\t\t\tprojected.revision !== documentRevision\n\t\t\t|| Service.sourceHash(source) !== documentSourceHash\n\t\t\t|| question?.questionHash !== questionHash\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(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.webResearch) {\n\tdefinitions.push(researchQuestionDefinition({\n\t\tconfig,\n\t\tcurrent: currentDocumentTarget,\n\t\tcommitCurrent: commitCurrentResearch,\n\t}));\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 => jobRunner?.notify(job),\n\tpublish: announceJobsChanged,\n});\nif (config.agent && config.backgroundJobs) {\n\tsummaryCoordinator = new DocumentSummaryCoordinator({\n\t\tservice: jobService,\n\t\tcurrent: currentDocumentTarget,\n\t\terror: err => console.error(\"chopin: document summary 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\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\tonChannelRenamed: announceChannelRename,\n\tonDocumentPersisted: target => {\n\t\tif (summaryCoordinator) void summaryCoordinator.enqueueNow(target).catch(() => {});\n\t},\n});\nregisterChannelRoutes(router, hostedAuth, {\n\tonAgentReset: channelOwnerReset,\n\tonChannelRenamed: announceChannelRename,\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 Agent.shutdown();\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\ntry {\n\tserver = listen();\n\tjobRunner.start();\n} catch (err) {\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 Agent.shutdown();\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","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",1794501277714,"sidebar","expanded"]