[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_271":-5,"_274":275,"_276":277},"routes/shell",{"_40":41,"_270":-5,"_271":-5,"_272":273},"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","ce1bd9bde77955b15521a5cbeee1236bdc14fa13","path","services/channel/src/object.ts","oid","611fc223b7eba909a13bc499c164234f4d42769d","size",6912,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { DurableObject } from \"cloudflare:workers\";\nimport { SqliteStorage } from \"@earendil-works/pi-durable/storage/sqlite\";\nimport { builtinModels } from \"@earendil-works/pi-ai/providers/all\";\n\nimport {\n\tChannel,\n\ttype Envelope,\n\ttype Frame,\n\ttype Log,\n\ttype Metadata,\n\ttype ModelRef,\n} from \"@ace/channel\";\nimport { type Call, Link, type Reply, type WorkspaceMessage } from \"@ace/channel/workspace\";\n\nimport { DurableSqlite } from \"./storage\";\n\nexport type Env = {\n\tCHANNEL: DurableObjectNamespace;\n\t/** Bearer secret shared by the team's hosts. */\n\tACE_SECRET?: string;\n};\n\n/** Paths are on the workspace host, whose file namespace is `workspace`. */\nexport type Config = {\n\tversion: 2;\n\tid: string;\n\tname: string;\n\tprefix: string;\n\tnamed: boolean;\n\towner: string;\n\tproject: string;\n\tlanes: string;\n\tmodel?: ModelRef;\n\tworkspace: string;\n};\n\nconst KEEPALIVE = 30_000;\n\n/** Workers Logs indexes JSON fields, so lines search by the same ids as hosts' log files. */\nconst log: Log = (level, event, fields) => {\n\tconst line = { level, event, ...fields };\n\tif (level === \"error\") console.error(line);\n\telse if (level === \"warn\") console.warn(line);\n\telse console.log(line);\n};\n\n/**\n * One hosted channel. Its history and agents live here; its tools run on the workspace host that\n * holds the `workspace` socket. That socket hibernates, so an idle channel costs nothing while the\n * host stays connected. Client sockets stream live pi events and keep the object awake.\n */\nexport class HostedChannel extends DurableObject {\n\t#link = new Link();\n\t#channel?: Promise;\n\n\t#config(): Config | undefined {\n\t\tconst config = this.ctx.storage.kv.get<\n\t\t\tOmit & Partial> & {\n\t\t\t\tversion?: number;\n\t\t\t}\n\t\t>(\n\t\t\t\"config\",\n\t\t);\n\t\tif (!config) return;\n\t\tif (config.version !== undefined && config.version !== 1 && config.version !== 2) {\n\t\t\tthrow new Error(`Unsupported channel config version ${config.version}`);\n\t\t}\n\t\tif (config.version === 2) return config as Config;\n\t\treturn { ...config, version: 2, prefix: config.name, named: true };\n\t}\n\n\t#metadata(metadata: Metadata) {\n\t\tconst frame = JSON.stringify({ metadata } satisfies WorkspaceMessage);\n\t\tfor (const socket of this.ctx.getWebSockets(\"workspace\")) {\n\t\t\tif (socket.readyState === WebSocket.OPEN) socket.send(frame);\n\t\t}\n\t}\n\n\t#attach(socket: WebSocket) {\n\t\tthis.#link.attach((call: Call) => socket.send(JSON.stringify(call)));\n\t}\n\n\t#open(config: Config): Promise {\n\t\tthis.#channel ??= (async () => {\n\t\t\tconst [socket] = this.ctx.getWebSockets(\"workspace\");\n\t\t\tif (socket && !this.#link.attached) this.#attach(socket);\n\t\t\tconst env = this.env as unknown as Record;\n\t\t\tconst envs = new Map>();\n\t\t\treturn Channel.open({\n\t\t\t\t...config,\n\t\t\t\tonMetadata: (metadata) => this.#metadata(metadata),\n\t\t\t\tstorage: await SqliteStorage.open(new DurableSqlite(this.ctx.storage)),\n\t\t\t\tmodels: builtinModels({\n\t\t\t\t\tauthContext: {\n\t\t\t\t\t\tenv: async (name) => typeof env[name] === \"string\" ? env[name] : undefined,\n\t\t\t\t\t\tfileExists: async () => false,\n\t\t\t\t\t},\n\t\t\t\t}),\n\t\t\t\tdesktop: (request, context) => this.#link.desktop(request, context),\n\t\t\t\tenv: (cwd) => {\n\t\t\t\t\tlet found = envs.get(cwd);\n\t\t\t\t\tif (!found) envs.set(cwd, found = this.#link.env(config.workspace, cwd));\n\t\t\t\t\treturn found;\n\t\t\t\t},\n\t\t\t\tdirectory: {\n\t\t\t\t\tself: { id: config.id, name: config.prefix },\n\t\t\t\t\tlist: async () => [],\n\t\t\t\t\tdeliver: async () => {\n\t\t\t\t\t\tthrow new Error(\"Hosted channels cannot message other channels yet\");\n\t\t\t\t\t},\n\t\t\t\t},\n\t\t\t\tlog,\n\t\t\t});\n\t\t})();\n\t\treturn this.#channel;\n\t}\n\n\t/** Pi resumes interrupted work when it opens, so an alarm during a run brings an evicted object back. */\n\tasync #keepalive() {\n\t\tif (!(await this.ctx.storage.getAlarm())) {\n\t\t\tawait this.ctx.storage.setAlarm(Date.now() + KEEPALIVE);\n\t\t}\n\t}\n\n\toverride async alarm() {\n\t\tconst config = this.#config();\n\t\tif (!config) return;\n\t\tconst channel = await this.#open(config);\n\t\tif (!(await channel.isIdle())) await this.#keepalive();\n\t}\n\n\toverride async fetch(request: Request): Promise {\n\t\tconst url = new URL(request.url);\n\t\tconst workspace = url.pathname.endsWith(\"/workspace\");\n\t\tif (request.method === \"POST\") {\n\t\t\tif (!this.#config()) this.ctx.storage.kv.put(\"config\", await request.json());\n\t\t\treturn Response.json(await (await this.#open(this.#config()!)).info());\n\t\t}\n\t\tconst config = this.#config();\n\t\tif (!config) return new Response(\"No such channel\", { status: 404 });\n\t\tif (request.method === \"DELETE\") {\n\t\t\tconst channel = await this.#open(config);\n\t\t\tawait channel.kill();\n\t\t\tawait channel.close();\n\t\t\tthis.#channel = undefined;\n\t\t\tfor (const socket of this.ctx.getWebSockets()) socket.close(1000, \"deleted\");\n\t\t\tawait this.ctx.storage.deleteAll();\n\t\t\treturn new Response(null, { status: 204 });\n\t\t}\n\t\tif (request.headers.get(\"upgrade\") !== \"websocket\") {\n\t\t\treturn Response.json(await (await this.#open(config)).info());\n\t\t}\n\t\tconst { 0: client, 1: server } = new WebSocketPair();\n\t\tif (workspace) {\n\t\t\tfor (const old of this.ctx.getWebSockets(\"workspace\")) old.close(1000, \"replaced\");\n\t\t\tlog(\"info\", \"workspace.connect\", { channel: config.id, workspace: config.workspace });\n\t\t\tthis.ctx.acceptWebSocket(server, [\"workspace\"]);\n\t\t\tthis.#attach(server);\n\t\t\tconst { name, summary, revision } = await (await this.#open(config)).info();\n\t\t\tthis.#metadata({ name, summary, revision });\n\t\t} else {\n\t\t\tserver.accept();\n\t\t\tthis.#serve(server, await this.#open(config));\n\t\t}\n\t\treturn new Response(null, { status: 101, webSocket: client });\n\t}\n\n\toverride async webSocketMessage(socket: WebSocket, message: string | ArrayBuffer) {\n\t\tif (!this.#link.attached) this.#attach(socket);\n\t\tthis.#link.receive(JSON.parse(message as string) as Reply);\n\t}\n\n\toverride async webSocketClose(socket: WebSocket, code: number, reason: string) {\n\t\tlog(\"warn\", \"workspace.drop\", { channel: this.#config()?.id, code, reason });\n\t\tif (this.ctx.getWebSockets(\"workspace\").every((open) => open === socket)) this.#link.detach();\n\t}\n\n\t#serve(socket: WebSocket, channel: Channel) {\n\t\tconst watches: { stop(): Promise }[] = [];\n\t\tconst send = (frame: Frame) => socket.send(JSON.stringify(frame));\n\t\tsocket.addEventListener(\"close\", () => {\n\t\t\tfor (const watch of watches) watch.stop();\n\t\t});\n\t\tsocket.addEventListener(\"message\", async ({ data }) => {\n\t\t\tconst { id, trace, ...body } = JSON.parse(data as string) as Envelope;\n\t\t\ttry {\n\t\t\t\tconst value = await channel.handle(body, (event) => send({ id, event }), trace);\n\t\t\t\tif (body.op === \"watch\") watches.push(value as { stop(): Promise });\n\t\t\t\tif (body.op === \"ask\") await this.#keepalive();\n\t\t\t\tsend({ id, ok: true, value: body.op === \"watch\" ? null : value ?? null });\n\t\t\t} catch (error) {\n\t\t\t\tsend({ id, ok: false, error: error instanceof Error ? error.message : String(error) });\n\t\t\t}\n\t\t});\n\t}\n}\n","editable",false,"branch","documentNavigation","repo","githubnext/ace2","repoId","938fe4cd-5320-4e4f-ac7c-87d4dad8490c","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[226,227,228,229,230,231,232,233,234,235,236,237,238],"navigation",{"_54":55,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"sources",[],"viewer","meta",{"_174":175,"_176":177,"_178":179,"_42":31,"_180":166,"_181":31,"_48":49,"_50":49},"branches",[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,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150,151,152,153,154,155,156,157,158,159,160,161,162,163,164,165,166,167,168,169,170,171,172,173],"tags",[69,70,71,72,73,74,75,76,77,78,79,80],"cloneUrl","https://git.nexthub.sh/githubnext/ace2.git","desktop-canary-v0.0.10","desktop-canary-v0.0.11","desktop-canary-v0.0.12","desktop-canary-v0.0.13","desktop-canary-v0.0.14","desktop-canary-v0.0.15","desktop-canary-v0.0.16","desktop-canary-v0.0.18","desktop-canary-v0.0.21","desktop-canary-v0.0.7","desktop-canary-v0.0.8","desktop-canary-v0.0.9","amber-beacon/composer-effort","brisk-ember/github-avatars","brisk-grove/image-paste-91","calm-anchor/fix-streaming-draft-overlap","calm-grove/composer-agent-mode","cloud-pilot-ops/canary-0-0-17","cloud-pilot-ops/cloud-move","cloud-pilot-ops/cloud-pilot","codex/agentation-shortcut","codex/annotation-polish","codex/browser-pages","codex/canary-0-0-21","codex/canary-0.0.11","codex/channel-delete-close","codex/channel-watch-recovery","codex/clipboard-files-write","codex/composer-coordinate-check","codex/computer-use-validation","codex/desktop-actions","codex/desktop-app-search","codex/desktop-app-state","codex/desktop-availability","codex/desktop-click-variants","codex/desktop-clipboard","codex/desktop-clipboard-files","codex/desktop-clipboard-image","codex/desktop-clipboard-image-write","codex/desktop-clipboard-text","codex/desktop-drag","codex/desktop-keyboard","codex/desktop-launch","codex/desktop-locked-feedback","codex/desktop-menu-command","codex/desktop-menu-inventory","codex/desktop-minimize","codex/desktop-open","codex/desktop-pointer","codex/desktop-quit","codex/desktop-selection-keys","codex/desktop-tool-guidance","codex/desktop-tools-extraction","codex/desktop-window-close","codex/desktop-window-geometry","codex/desktop-windows","codex/dev-permission-identity","codex/durable-composer-drafts","codex/fix-message-clipping","codex/lane-base-96","codex/native-patch-prefix","codex/peekaboo","codex/peer-channel-messaging","codex/pixel-snapshot-authority","codex/publish-canary-0-0-21","codex/readme-security","codex/settings-refresh","codex/stale-click-refusal","codex/tab-renaming-api","codex/team-agent-access","codex/team-channel-sections","codex/team-dogfood-integration","codex/webkit-coordinate-window","codex/webkit-desktop-focus","deft-beacon/helper-isolation","deft-grove/align-avatar-byline","deft-grove/build-canary-0-0-18","deft-grove/canary-github-releases","deft-grove/ship-canary-0-0-18","deft-meadow/details-sidebar","fair-ember/canary-0-0-13","fair-ember/canary-0-0-14","fair-fjord/all-projects","feat/github-cache","feat/rebuild","fix/channel-credentials","glad-anchor/restore-message-queue","glad-ember/archive-inactive-channels","glad-fjord/project-identity","glad-orbit/channel-progress","glad-ridge/terminal-replay-input","hazy-anchor/github-row-actions","hazy-ember/channel-access-toggles","hazy-grove/all-projects-add-channel","local-project-setup/build-canary-0-0-20","local-project-setup/canary-0-0-20","local-project-setup/local-project-setup","main","mellow-ridge/canary-0-0-16","mellow-ridge/top-bar-drag-area","nimble-cedar/modal-top-offset","nimble-meadow/canary-0-0-15","remote-channel-load/build-canary-0-0-19","remote-channel-load/canary-0-0-19","remote-channel-load/fix-remote-channel-load","description","Ace: a collaborative coding environment on the team's own machines","owner","githubnext","section","","head","empty","pins",[208,209,210],"documents",{"_203":204,"_205":206},"code",{"_199":200,"_201":202},"automations",{"_196":197,"_198":-5},"delivery",{"_194":49,"_195":-5},"tag","9Rn62lcgXCFfpmCuooTjLxGyUf8","releases","applications","workflows",2,"deployments","commits",215,"changes",1,"counts",{"_207":206},"total",86,"issue",{"_211":201,"_213":224,"_15":201,"_215":225,"_52":217,"_218":31,"_219":217,"_220":202},{"_211":221,"_213":222,"_15":221,"_215":223,"_52":217,"_218":31,"_219":217,"_220":49},{"_211":212,"_213":214,"_15":212,"_215":216,"_52":217,"_218":31,"_219":217,"_220":206},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_211":201,"_213":224,"_15":201,"_215":269,"_52":217,"_218":31,"_219":217},{"_211":221,"_213":222,"_15":221,"_215":268,"_52":217,"_218":31,"_219":217},{"_211":212,"_213":214,"_15":212,"_215":267,"_52":217,"_218":31,"_219":217},{"_211":264,"_213":265,"_15":264,"_215":266,"_52":31,"_218":31,"_219":217},{"_211":261,"_213":262,"_15":261,"_215":263,"_52":31,"_218":31,"_219":217},{"_211":196,"_213":259,"_15":188,"_215":260,"_52":31,"_218":31,"_219":217},{"_211":198,"_213":256,"_15":257,"_215":258,"_52":31,"_218":31,"_219":217},{"_211":194,"_213":254,"_15":194,"_215":255,"_52":31,"_218":31,"_219":217},{"_211":250,"_213":251,"_15":252,"_215":253,"_52":31,"_218":31,"_219":217},{"_211":184,"_213":248,"_15":184,"_215":249,"_52":31,"_218":31,"_219":31},{"_211":245,"_213":246,"_15":245,"_215":247,"_52":31,"_218":31,"_219":31},{"_211":242,"_213":243,"_15":242,"_215":244,"_52":31,"_218":31,"_219":31},{"_211":239,"_213":240,"_15":239,"_215":241,"_52":31,"_218":31,"_219":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794435316314,"sidebar","expanded"]