[{"_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","aff8d54e95c93c117efe1d3682d8d89c4a208bcc","path","apps/host/src/client.ts","oid","05191fb256ad749f7ac48cf08739ff0f832cb29c","size",6370,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { spawn } from \"node:child_process\";\nimport { closeSync, openSync } from \"node:fs\";\nimport { connect as dial, type Socket } from \"node:net\";\n\nimport type { Frame, Request } from \"@ace/channel/protocol\";\n\nimport * as catalog from \"./catalog\";\nimport { config } from \"./config\";\nimport type { Watch } from \"./gateway-client\";\nimport { key, workerEnv } from \"./keys\";\nimport { lines } from \"./lines\";\nimport { failure, log } from \"./log\";\nimport type { WorkerRequest } from \"./protocol\";\n\nfunction start(id: string): void {\n\t// Output the worker didn't log itself, such as a crash before its log opens.\n\tconst out = openSync(catalog.paths(id).log, \"a\");\n\tconst [executable, ...args] = config.worker;\n\ttry {\n\t\tconst child = spawn(executable, [...args, id], {\n\t\t\tdetached: true,\n\t\t\tstdio: [\"ignore\", out, out],\n\t\t\tenv: workerEnv(),\n\t\t});\n\t\tchild.on(\n\t\t\t\"error\",\n\t\t\t(error) => log(\"error\", \"worker.spawn.failed\", { channel: id, ...failure(error) }),\n\t\t);\n\t\tchild.unref();\n\t\tlog(\"info\", \"worker.spawn\", { channel: id, pid: child.pid });\n\t} finally {\n\t\tcloseSync(out);\n\t}\n}\n\nfunction attempt(path: string): Promise {\n\treturn new Promise((resolve, reject) => {\n\t\tconst socket = dial(path);\n\t\tsocket.once(\"connect\", () => resolve(socket));\n\t\tsocket.once(\"error\", reject);\n\t});\n}\n\ntype Transport = {\n\twrite(text: string): void;\n\tend(): void;\n\tclosed: Promise;\n};\n\nfunction local(socket: Socket, receive: (text: string) => void): Transport {\n\tlines(socket, receive);\n\treturn {\n\t\twrite: (text) => socket.write(`${text}\\n`),\n\t\tend: () => socket.end(),\n\t\tclosed: new Promise((resolve) => socket.once(\"close\", () => resolve())),\n\t};\n}\n\n/** Hosts hold the team's secret for its services: hosted channels and the directory. */\nexport async function hostedAuth(): Promise> {\n\tconst secret = await key(\"ACE_SECRET\");\n\tif (!secret) throw new Error(\"The team's services need ACE_SECRET; see ace key set\");\n\treturn { authorization: `Bearer ${secret}` };\n}\n\nexport async function hostedSocket(base: string, path: string): Promise {\n\tconst socket = new WebSocket(`${base.replace(/^http/, \"ws\")}${path}`, {\n\t\theaders: await hostedAuth(),\n\t} as unknown as string[]);\n\tawait new Promise((resolve, reject) => {\n\t\tsocket.addEventListener(\"open\", resolve, { once: true });\n\t\tsocket.addEventListener(\"error\", () => {\n\t\t\tlog(\"warn\", \"hosted.unreachable\", { base, path });\n\t\t\treject(new Error(`Cannot reach ${base}`));\n\t\t}, { once: true });\n\t});\n\treturn socket;\n}\n\nasync function hosted(\n\tbase: string,\n\tid: string,\n\treceive: (text: string) => void,\n): Promise {\n\tconst socket = await hostedSocket(base, `/channels/${id}`);\n\tsocket.addEventListener(\"message\", ({ data }) => receive(String(data)));\n\treturn {\n\t\twrite: (text) => socket.send(text),\n\t\tend: () => socket.close(),\n\t\tclosed: new Promise((resolve) => socket.addEventListener(\"close\", () => resolve())),\n\t};\n}\n\n/** A connection to a channel: its local worker, started if dormant, or its hosting service. */\nexport class Connection {\n\t#transport!: Transport;\n\t#next = 1;\n\t#pending = new Map();\n\t#watchers = new Map();\n\t#released = false;\n\tclosed!: Promise;\n\n\tprivate constructor() {}\n\n\tstatic async #connect(open: (receive: (text: string) => void) => Promise) {\n\t\tconst connection = new Connection();\n\t\tconnection.#transport = await open((text) => connection.#receive(JSON.parse(text)));\n\t\tconnection.closed = connection.#transport.closed;\n\t\tconnection.closed.then(() => {\n\t\t\tconst error = \"The channel closed the connection\";\n\t\t\t// Every accepted watch ends here, so relays can drop it; its owner decides whether to watch again.\n\t\t\tfor (const [id, watch] of connection.#watchers) {\n\t\t\t\tif (connection.#pending.has(id)) continue;\n\t\t\t\twatch.closed?.(connection.#released ? \"The watch was released\" : error);\n\t\t\t}\n\t\t\tconnection.#watchers.clear();\n\t\t\tfor (const { reject } of connection.#pending.values()) reject(new Error(error));\n\t\t\tconnection.#pending.clear();\n\t\t});\n\t\treturn connection;\n\t}\n\n\t/** A hosted channel, which need not be in this host's catalog. */\n\tstatic hosted(base: string, id: string): Promise {\n\t\treturn Connection.#connect((receive) => hosted(base, id, receive));\n\t}\n\n\t/** Shutdown must never start a dormant worker. */\n\tstatic async running(id: string): Promise {\n\t\ttry {\n\t\t\tconst socket = await attempt(catalog.paths(id).socket);\n\t\t\treturn Connection.#connect(async (receive) => local(socket, receive));\n\t\t} catch (error) {\n\t\t\tconst code = (error as NodeJS.ErrnoException).code;\n\t\t\tif (code !== \"ENOENT\" && code !== \"ECONNREFUSED\") throw error;\n\t\t}\n\t}\n\n\tstatic async open(id: string): Promise {\n\t\tconst record = catalog.read(id);\n\t\tif (record.hosted) return Connection.hosted(record.hosted, id);\n\t\tconst { socket } = catalog.paths(id);\n\t\tlet started = false;\n\t\tfor (let wait = 50; wait < 10_000; wait *= 1.5) {\n\t\t\ttry {\n\t\t\t\tconst connected = await attempt(socket);\n\t\t\t\treturn Connection.#connect(async (receive) => local(connected, receive));\n\t\t\t} catch {\n\t\t\t\tif (!started) start(id);\n\t\t\t\tstarted = true;\n\t\t\t\tawait Bun.sleep(wait);\n\t\t\t}\n\t\t}\n\t\tlog(\"error\", \"worker.unreachable\", { channel: id });\n\t\tthrow new Error(`The channel worker did not start; see ace logs --channel ${id}`);\n\t}\n\n\trequest(\n\t\trequest: Request | WorkerRequest,\n\t\twatch?: Watch,\n\t\ttrace?: string,\n\t): Promise {\n\t\tconst id = this.#next++;\n\t\tif (watch) this.#watchers.set(id, watch);\n\t\tthis.#transport.write(JSON.stringify({ id, ...(trace ? { trace } : {}), ...request }));\n\t\treturn new Promise((resolve, reject) =>\n\t\t\tthis.#pending.set(id, { resolve: resolve as (value: unknown) => void, reject })\n\t\t);\n\t}\n\n\tclose(): void {\n\t\tthis.#released = true;\n\t\tthis.#transport.end();\n\t}\n\n\t#receive(frame: Frame) {\n\t\tif (\"event\" in frame) return this.#watchers.get(frame.id)?.event(frame.event);\n\t\tconst pending = this.#pending.get(frame.id);\n\t\tthis.#pending.delete(frame.id);\n\t\tif (frame.ok) return pending?.resolve(frame.value);\n\t\tthis.#watchers.delete(frame.id);\n\t\tpending?.reject(new Error(frame.error));\n\t}\n}\n\nexport async function request(id: string, body: Request): Promise {\n\tconst connection = await Connection.open(id);\n\ttry {\n\t\treturn await connection.request(body);\n\t} finally {\n\t\tconnection.close();\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",1794436112328,"sidebar","expanded"]