[{"_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","6dc0f1c881983718d00b042f4018f3ad6e535bdd","path","packages/channel/src/workspace.ts","oid","63b7d1b61aeec7e3c5f5e8f6cae4f8a05138f982","size",10581,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * A hosted channel has no file system or shell of its own. Its tools run on a workspace: a host\n * that connects out to the channel and serves each chat's file and shell calls from its own disk.\n */\nimport type { Context } from \"@earendil-works/chord\";\nimport { BACKGROUND_CONTEXT, withAbortSignal } from \"@earendil-works/chord/context\";\nimport {\n\terr,\n\ttype ExecutionEnv,\n\tExecutionError,\n\tFileError,\n\tok,\n\ttype Result,\n\ttype TextLineReader,\n} from \"@earendil-works/pi-durable/env\";\n\nimport { type Desktop, type DesktopRequest, type DesktopResult, isDesktopAction } from \"./desktop\";\nimport type { Metadata } from \"./protocol\";\n\ndeclare function btoa(data: string): string;\ndeclare function atob(data: string): string;\n\n// Numeric IDs remain accepted from hosts running an older version.\ntype CallId = string | number;\n\n/** Channel to workspace. */\nexport type Call =\n\t| { call: CallId; method: Method | \"desktop\"; cwd: string; args: unknown[] }\n\t| { cancel: CallId };\n\n/** Metadata and activity are projected by the workspace host even when no client watches the channel. */\nexport type WorkspaceMessage = Call | { metadata: Metadata } | { active: number } | {\n\tbusy: boolean;\n};\n\n/** Workspace to channel. */\nexport type Reply =\n\t| { call: CallId; output: string }\n\t| { call: CallId; result: Result };\n\ntype Failure = {\n\tname: \"FileError\" | \"ExecutionError\";\n\tcode: string;\n\tmessage: string;\n\tpath?: string;\n};\n\nconst METHODS = [\n\t\"absolutePath\",\n\t\"joinPath\",\n\t\"readTextFile\",\n\t\"readTextLines\",\n\t\"readBinaryFile\",\n\t\"writeFile\",\n\t\"appendFile\",\n\t\"truncateFile\",\n\t\"flushFile\",\n\t\"renameFile\",\n\t\"fileInfo\",\n\t\"listDir\",\n\t\"canonicalPath\",\n\t\"exists\",\n\t\"createDir\",\n\t\"remove\",\n\t\"createTempDir\",\n\t\"createTempFile\",\n\t\"exec\",\n] as const;\ntype Method = (typeof METHODS)[number];\n\n/** JSON cannot carry bytes; file contents cross as tagged base64. */\nfunction encode(value: unknown): unknown {\n\tif (!(value instanceof Uint8Array)) return value;\n\tlet binary = \"\";\n\tfor (let i = 0; i < value.length; i += 0x8000) {\n\t\tbinary += String.fromCharCode(...value.subarray(i, i + 0x8000));\n\t}\n\treturn { $bytes: btoa(binary) };\n}\n\nfunction decode(value: unknown): unknown {\n\tif (typeof value !== \"object\" || value === null || !(\"$bytes\" in value)) return value;\n\treturn Uint8Array.from(atob((value as { $bytes: string }).$bytes), (c) => c.charCodeAt(0));\n}\n\nfunction failure(error: unknown): Failure {\n\tif (error instanceof FileError) {\n\t\treturn { name: \"FileError\", code: error.code, message: error.message, path: error.path };\n\t}\n\tconst code = error instanceof ExecutionError ? error.code : \"unknown\";\n\treturn {\n\t\tname: \"ExecutionError\",\n\t\tcode,\n\t\tmessage: error instanceof Error ? error.message : String(error),\n\t};\n}\n\nfunction rebuild(f: Failure): Error {\n\treturn f.name === \"FileError\"\n\t\t? new FileError(f.code as FileError[\"code\"], f.message, f.path)\n\t\t: new ExecutionError(f.code as ExecutionError[\"code\"], f.message);\n}\n\nfunction desktopFailure(outcome: \"refused\" | \"unknown\", reason: string): DesktopResult {\n\treturn {\n\t\toutcome,\n\t\tisError: true,\n\t\ttext: JSON.stringify({\n\t\t\toutcome,\n\t\t\treason,\n\t\t\tmessage: outcome === \"unknown\"\n\t\t\t\t? \"The desktop action may have partially run. Inspect the target's current state before retrying. Stopping does not undo input already delivered.\"\n\t\t\t\t: \"The desktop action was not sent to the native desktop.\",\n\t\t}),\n\t};\n}\n\n/** The channel's side: one connection to the workspace, shared by every chat's environment. */\nexport class Link {\n\t#send?: (call: Call) => void;\n\t#generation: string;\n\t#next = 1;\n\t#pending = new Map<\n\t\tCallId,\n\t\t{ resolve(result: Result): void; output?(text: string): void }\n\t>();\n\n\tconstructor(generation: string) {\n\t\t// A workspace socket can survive the runtime that issued its previous calls.\n\t\tthis.#generation = generation;\n\t}\n\n\t/** Attach the workspace's connection, replacing any earlier one. */\n\tattach(send: (call: Call) => void): void {\n\t\tthis.detach();\n\t\tthis.#send = send;\n\t}\n\n\t/** Calls in flight fail; pi reports interrupted tools to the model. */\n\tdetach(): void {\n\t\tthis.#send = undefined;\n\t\tfor (const pending of this.#pending.values()) {\n\t\t\tpending.resolve(err(new FileError(\"unknown\", \"The workspace disconnected\")));\n\t\t}\n\t\tthis.#pending.clear();\n\t}\n\n\tget attached(): boolean {\n\t\treturn !!this.#send;\n\t}\n\n\treceive(reply: Reply): void {\n\t\tconst pending = this.#pending.get(reply.call);\n\t\tif (!pending) return;\n\t\tif (\"output\" in reply) return pending.output?.(reply.output);\n\t\tthis.#pending.delete(reply.call);\n\t\tconst { result } = reply;\n\t\tpending.resolve(result.ok ? ok(decode(result.value)) : err(rebuild(result.error)));\n\t}\n\n\trequest(\n\t\tmethod: Method | \"desktop\",\n\t\tcwd: string,\n\t\targs: unknown[],\n\t\tcontext: Context,\n\t\toutput?: (text: string) => void,\n\t): Promise> {\n\t\tconst send = this.#send;\n\t\tif (!send) {\n\t\t\tconst error = method === \"exec\" || method === \"desktop\"\n\t\t\t\t? new ExecutionError(\"unknown\", \"The workspace is offline\")\n\t\t\t\t: new FileError(\"unknown\", \"The workspace is offline\");\n\t\t\treturn Promise.resolve(err(error));\n\t\t}\n\t\tconst call = `${this.#generation}:${this.#next++}`;\n\t\tconst signal = context.abortSignal;\n\t\tif (signal?.aborted) return Promise.resolve(err(new ExecutionError(\"aborted\", \"Aborted\")));\n\t\treturn new Promise((resolve) => {\n\t\t\tconst failed = (error: unknown) => {\n\t\t\t\tconst pending = this.#pending.get(call);\n\t\t\t\tthis.#pending.delete(call);\n\t\t\t\tpending?.resolve(err(\n\t\t\t\t\tnew ExecutionError(\n\t\t\t\t\t\t\"unknown\",\n\t\t\t\t\t\terror instanceof Error ? error.message : String(error),\n\t\t\t\t\t),\n\t\t\t\t));\n\t\t\t};\n\t\t\tconst abort = () => {\n\t\t\t\ttry {\n\t\t\t\t\tsend({ cancel: call });\n\t\t\t\t} catch (error) {\n\t\t\t\t\tfailed(error);\n\t\t\t\t}\n\t\t\t};\n\t\t\tsignal?.addEventListener(\"abort\", abort, { once: true });\n\t\t\tthis.#pending.set(call, {\n\t\t\t\tresolve(result) {\n\t\t\t\t\tsignal?.removeEventListener(\"abort\", abort);\n\t\t\t\t\tresolve(result);\n\t\t\t\t},\n\t\t\t\toutput,\n\t\t\t});\n\t\t\ttry {\n\t\t\t\tsend({ call, method, cwd, args: args.map(encode) });\n\t\t\t} catch (error) {\n\t\t\t\tfailed(error);\n\t\t\t}\n\t\t});\n\t}\n\n\tasync desktop(request: DesktopRequest, context: Context): Promise {\n\t\tconst action = isDesktopAction(request);\n\t\tif (action && !this.#send) return desktopFailure(\"refused\", \"The workspace is offline\");\n\t\tif (action && context.abortSignal?.aborted) {\n\t\t\treturn desktopFailure(\"refused\", \"The desktop action was cancelled before dispatch\");\n\t\t}\n\t\tconst result = await this.request(\"desktop\", \"\", [request], context);\n\t\tif (!result.ok && action) return desktopFailure(\"unknown\", result.error.message);\n\t\tif (!result.ok) throw result.error;\n\t\treturn result.value as DesktopResult;\n\t}\n\n\t/** An execution environment at `cwd` on the workspace. `id` names the workspace's file namespace. */\n\tenv(id: string, cwd: string): ExecutionEnv {\n\t\tconst forward = (method: Method) => (...params: unknown[]) => {\n\t\t\tconst context = params.pop() as Context;\n\t\t\treturn this.request(method, cwd, params, context);\n\t\t};\n\t\tconst env = Object.fromEntries(\n\t\t\tMETHODS.map((method) => [method, forward(method)]),\n\t\t) as unknown as ExecutionEnv;\n\t\treturn Object.assign(env, {\n\t\t\tid,\n\t\t\tcwd,\n\t\t\texec: (command: string, options: Parameters[1], context: Context) => {\n\t\t\t\tconst { onOutput, ...rest } = options ?? {};\n\t\t\t\treturn this.request(\n\t\t\t\t\t\"exec\",\n\t\t\t\t\tcwd,\n\t\t\t\t\t[command, rest],\n\t\t\t\t\tcontext,\n\t\t\t\t\tonOutput && ((text) => onOutput(text, context)),\n\t\t\t\t);\n\t\t\t},\n\t\t\tasync openTextLineReader(path: string, context: Context) {\n\t\t\t\tconst text = await env.readTextFile(path, context);\n\t\t\t\tif (!text.ok) return text;\n\t\t\t\tconst lines = text.value.split(\"\\n\");\n\t\t\t\tconst last = lines.pop();\n\t\t\t\tconst queue = [\n\t\t\t\t\t...lines.map((line) => ({ text: line, terminated: true })),\n\t\t\t\t\t...(last ? [{ text: last, terminated: false }] : []),\n\t\t\t\t];\n\t\t\t\tconst reader: TextLineReader = {\n\t\t\t\t\treadLine: async () => ok(queue.shift()),\n\t\t\t\t\tclose: async () => {},\n\t\t\t\t};\n\t\t\t\treturn ok(reader);\n\t\t\t},\n\t\t\tasync cleanup() {},\n\t\t}) as ExecutionEnv;\n\t}\n}\n\n/** The workspace's side: run each call on a local environment and send back its outcome. */\nexport function serve(\n\tenv: (cwd: string) => ExecutionEnv,\n\tsend: (reply: Reply) => void,\n\tdesktop?: Desktop,\n) {\n\tconst running = new Map }>();\n\tlet closed = false;\n\tconst handle = async (call: Call) => {\n\t\tif (\"cancel\" in call) return running.get(call.cancel)?.abort.abort();\n\t\tif (closed) {\n\t\t\tif (call.method === \"desktop\" && isDesktopAction(call.args[0] as DesktopRequest)) {\n\t\t\t\treturn send({\n\t\t\t\t\tcall: call.call,\n\t\t\t\t\tresult: ok(desktopFailure(\"refused\", \"The workspace disconnected before dispatch\")),\n\t\t\t\t});\n\t\t\t}\n\t\t\treturn send({\n\t\t\t\tcall: call.call,\n\t\t\t\tresult: err(failure(new Error(\"The workspace disconnected\"))),\n\t\t\t});\n\t\t}\n\t\tif (call.method !== \"desktop\" && !METHODS.includes(call.method)) {\n\t\t\treturn send({\n\t\t\t\tcall: call.call,\n\t\t\t\tresult: err(failure(new Error(`Unknown method ${call.method}`))),\n\t\t\t});\n\t\t}\n\t\tconst abort = new AbortController();\n\t\tconst { promise: done, resolve: finish } = Promise.withResolvers();\n\t\trunning.set(call.call, { abort, done });\n\t\tconst context = withAbortSignal(abort.signal, BACKGROUND_CONTEXT);\n\t\ttry {\n\t\t\tconst args = call.args.map(decode);\n\t\t\tif (call.method === \"desktop\") {\n\t\t\t\tconst request = args[0] as DesktopRequest;\n\t\t\t\tif (!desktop) {\n\t\t\t\t\tif (!isDesktopAction(request)) {\n\t\t\t\t\t\tthrow new Error(\"Native desktop inspection is unavailable on this workspace\");\n\t\t\t\t\t}\n\t\t\t\t\treturn send({\n\t\t\t\t\t\tcall: call.call,\n\t\t\t\t\t\tresult: ok(\n\t\t\t\t\t\t\tdesktopFailure(\"refused\", \"Native desktop actions are unavailable on this workspace\"),\n\t\t\t\t\t\t),\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t\tconst value = await desktop(request, context);\n\t\t\t\treturn send({ call: call.call, result: ok(value) });\n\t\t\t}\n\t\t\tconst target = env(call.cwd);\n\t\t\tconst result = call.method === \"exec\"\n\t\t\t\t? await target.exec(args[0] as string, {\n\t\t\t\t\t...(args[1] as object),\n\t\t\t\t\tonOutput: (output) => send({ call: call.call, output }),\n\t\t\t\t}, context)\n\t\t\t\t: await (target[call.method] as (...a: unknown[]) => Promise>).call(\n\t\t\t\t\ttarget,\n\t\t\t\t\t...args,\n\t\t\t\t\tcontext,\n\t\t\t\t);\n\t\t\tsend({\n\t\t\t\tcall: call.call,\n\t\t\t\tresult: result.ok ? ok(encode(result.value)) : err(failure(result.error)),\n\t\t\t});\n\t\t} catch (error) {\n\t\t\tsend({ call: call.call, result: err(failure(error)) });\n\t\t} finally {\n\t\t\trunning.delete(call.call);\n\t\t\tfinish();\n\t\t}\n\t};\n\treturn Object.assign(handle, {\n\t\tasync close() {\n\t\t\tclosed = true;\n\t\t\tconst calls = [...running.values()];\n\t\t\tfor (const { abort } of calls) abort.abort();\n\t\t\tawait Promise.all(calls.map(({ done }) => done));\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",1794435383708,"sidebar","expanded"]