[{"_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","b6e09da47a0710eed2deaad643adf8d287c2da81","path","apps/host/src/move.ts","oid","22e1b4f1eeba915be197071461f0a117285f3d72","size",8498,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * Moving an idle channel between this host and a hosting service. The channel keeps its ID, lanes,\n * and workspace; its pi store travels as one verified snapshot. A `moving` fence on the record keeps\n * both copies from running while the move is under way, and an unknown activation keeps it.\n */\nimport { existsSync, readFileSync, renameSync, rmSync, writeFileSync } from \"node:fs\";\nimport { hostname } from \"node:os\";\nimport { join } from \"node:path\";\n\nimport { openNodeSqliteDatabase } from \"@earendil-works/pi-durable/storage/sqlite/node\";\n\nimport { exportSnapshot, importSnapshot, MAX_SNAPSHOT, type Snapshot } from \"@ace/channel/transfer\";\nimport type { ChannelInfo } from \"@ace/channel/protocol\";\n\nimport * as catalog from \"./catalog\";\nimport { Connection, hostedAuth } from \"./client\";\nimport { log } from \"./log\";\nimport { hostedConfig, isWorkerAlive } from \"./manage\";\nimport type { MoveTarget } from \"./protocol\";\n\n/** Services this host has moved channels to, so a channel that came back can leave again. */\nconst services = join(catalog.home, \"services.json\");\n\nfunction known(): string[] {\n\treturn existsSync(services) ? JSON.parse(readFileSync(services, \"utf8\")).hosted : [];\n}\n\nfunction remember(url: string): void {\n\tconst hosted = known();\n\tif (!hosted.includes(url)) writeFileSync(services, JSON.stringify({ hosted: [...hosted, url] }));\n}\n\n/** A service base URL without a trailing slash, as hosted records store it. */\nexport function canonical(url: string): string {\n\tconst parsed = new URL(url);\n\tif (parsed.protocol !== \"https:\" && parsed.protocol !== \"http:\") {\n\t\tthrow new Error(\"A hosting service URL starts with https://\");\n\t}\n\treturn `${parsed.origin}${parsed.pathname.replace(/\\/+$/, \"\")}`;\n}\n\nfunction movable(record: catalog.Listing): void {\n\tif (record.owner !== catalog.user) throw new Error(\"Only this host's owner can move channels\");\n\tif (record.archived) throw new Error(\"Unarchive the channel before moving it\");\n\tif (record.moving?.digest) {\n\t\tthrow new Error(\n\t\t\t`The channel's move to ${record.moving.to} may have finished there; run the same move to ${record.moving.to} again to complete it`,\n\t\t);\n\t}\n\tif (record.moving) {\n\t\tthrow new Error(\n\t\t\t`The channel is fenced by an unfinished move to ${record.moving.to}; find where it is active before lifting the fence`,\n\t\t);\n\t}\n\tif (record.busy) throw new Error(\"The channel is busy; stop its work before moving it\");\n}\n\nexport function targets(id: string): MoveTarget[] {\n\tconst record = catalog.read(id);\n\ttry {\n\t\tmovable(record);\n\t} catch {\n\t\treturn [];\n\t}\n\tif (record.hosted) return [{ target: \"local\", label: `This host (${hostname()})` }];\n\tconst hosted = new Set([\n\t\t...catalog.list().flatMap((r) => r.hosted ? [r.hosted] : []),\n\t\t...known(),\n\t]);\n\treturn [...hosted].map((url) => ({ target: url, label: new URL(url).host }));\n}\n\n/** A transfer whose answer never arrived may still have taken effect at the service. */\nclass Unknown extends Error {}\n\nasync function transfer(url: string, id: string, body: object): Promise {\n\tlet response: Response;\n\ttry {\n\t\tresponse = await fetch(`${url}/channels/${id}/transfer`, {\n\t\t\tmethod: \"POST\",\n\t\t\theaders: { ...await hostedAuth(), \"content-type\": \"application/json\" },\n\t\t\tbody: JSON.stringify(body),\n\t\t});\n\t} catch (error) {\n\t\tthrow new Unknown(`Cannot reach ${url}: ${(error as Error).message}`);\n\t}\n\tif (response.ok) {\n\t\ttry {\n\t\t\treturn await response.json() as T;\n\t\t} catch (error) {\n\t\t\tthrow new Unknown(`${url} answered without a readable result: ${(error as Error).message}`);\n\t\t}\n\t}\n\tconst message = `${url} refused: ${(await response.text().catch(() => \"\")).slice(0, 500)}`;\n\tthrow response.status >= 500 ? new Unknown(message) : new Error(message);\n}\n\n/** Worker startup checks the fence after taking this lock, so holding it keeps storage still. */\nasync function park(id: string): Promise {\n\tif (isWorkerAlive(id)) {\n\t\tconst connection = await Connection.running(id);\n\t\tif (connection) {\n\t\t\ttry {\n\t\t\t\tawait connection.request({ op: \"freeze\" });\n\t\t\t\tawait connection.closed;\n\t\t\t} finally {\n\t\t\t\tconnection.close();\n\t\t\t}\n\t\t}\n\t}\n\tfor (let wait = 50; wait < 5000; wait *= 2) {\n\t\tif (catalog.lock(id)) return;\n\t\tawait Bun.sleep(wait);\n\t}\n\tthrow new Error(\"The channel's worker did not stop\");\n}\n\n/** Only the lock this process took; a refused freeze leaves the running worker's lock alone. */\nfunction release(id: string): void {\n\tconst { pid } = catalog.paths(id);\n\tif (existsSync(pid) && readFileSync(pid, \"utf8\") === String(process.pid)) rmSync(pid);\n}\n\nasync function readLocal(id: string): Promise {\n\tconst db = await openNodeSqliteDatabase(catalog.paths(id).storage);\n\ttry {\n\t\treturn await exportSnapshot(db, id);\n\t} finally {\n\t\tawait db.close();\n\t}\n}\n\nasync function toHosted(record: catalog.Listing, url: string): Promise {\n\tconst { id } = record;\n\tlet digest = record.moving?.digest;\n\tif (!digest) {\n\t\tcatalog.write({ ...record, moving: { to: url } });\n\t\ttry {\n\t\t\tawait park(id);\n\t\t\tconst snapshot = await readLocal(id);\n\t\t\tif (Buffer.byteLength(JSON.stringify(snapshot)) > MAX_SNAPSHOT) {\n\t\t\t\tthrow new Error(\"The channel is too large to move yet\");\n\t\t\t}\n\t\t\t// An import, answered or not, leaves the service inactive, so the local copy stays usable.\n\t\t\tawait transfer(url, id, { action: \"import\", config: hostedConfig(record), snapshot });\n\t\t\tdigest = snapshot.digest;\n\t\t} catch (error) {\n\t\t\tcatalog.write({ ...catalog.read(id), moving: undefined });\n\t\t\trelease(id);\n\t\t\tthrow error;\n\t\t}\n\t\tcatalog.write({ ...catalog.read(id), moving: { to: url, digest } });\n\t}\n\ttry {\n\t\tawait transfer(url, id, { action: \"activate\", digest });\n\t} catch (error) {\n\t\tif (error instanceof Unknown) {\n\t\t\tthrow new Error(\n\t\t\t\t`${error.message}. The channel may now be active there, so this copy stays fenced; run the same move again to finish it.`,\n\t\t\t\t{ cause: error },\n\t\t\t);\n\t\t}\n\t\tcatalog.write({ ...catalog.read(id), moving: undefined });\n\t\trelease(id);\n\t\tthrow error;\n\t}\n\tcatalog.write({ ...catalog.read(id), hosted: url, moving: undefined, busy: false });\n\trelease(id);\n\tremember(url);\n}\n\nasync function toLocal(record: catalog.Listing): Promise {\n\tconst { id } = record;\n\tconst url = record.hosted!;\n\tconst { storage } = catalog.paths(id);\n\tconst incoming = `${storage}.incoming`;\n\tcatalog.write({ ...record, moving: { to: \"local\" } });\n\t// A refused or unanswered freeze may still have frozen the service; thawing an active one is refused.\n\tlet freezing = false;\n\ttry {\n\t\tawait park(id);\n\t\tfreezing = true;\n\t\tconst { digest } = await transfer<{ digest: string }>(url, id, { action: \"freeze\" });\n\t\tconst snapshot = await transfer(url, id, { action: \"export\" });\n\t\tif (snapshot.digest !== digest) {\n\t\t\tthrow new Error(\"The exported snapshot does not match the frozen channel\");\n\t\t}\n\t\tfor (const path of [incoming, `${incoming}-wal`, `${incoming}-shm`]) {\n\t\t\trmSync(path, { force: true });\n\t\t}\n\t\tconst db = await openNodeSqliteDatabase(incoming);\n\t\ttry {\n\t\t\tawait importSnapshot(db, snapshot);\n\t\t} finally {\n\t\t\tawait db.close();\n\t\t}\n\t\t// The parked copy's journal belongs to older history; it must not replay over the new store.\n\t\tfor (const path of [`${storage}-wal`, `${storage}-shm`]) rmSync(path, { force: true });\n\t\trenameSync(incoming, storage);\n\t} catch (error) {\n\t\tif (freezing) {\n\t\t\tawait transfer(url, id, { action: \"thaw\" }).catch((cause: Error) =>\n\t\t\t\tlog(\"warn\", \"move.thaw.failed\", { channel: id, error: cause.message })\n\t\t\t);\n\t\t}\n\t\tcatalog.write({ ...catalog.read(id), moving: undefined });\n\t\trelease(id);\n\t\tthrow error;\n\t}\n\tcatalog.write({ ...catalog.read(id), hosted: undefined, moving: undefined, busy: false });\n\trelease(id);\n}\n\n/** Move a channel to `target`: \"local\" or a hosting service URL. The frozen source is kept, not deleted. */\nexport async function move(id: string, target: string): Promise {\n\tconst record = catalog.read(id);\n\tconst to = target === \"local\" ? target : canonical(target);\n\t// Only an outbound move whose activation went unanswered resumes; anything else starts fresh.\n\tconst retrying = !!record.moving?.digest && record.moving.to === to;\n\tif (!retrying) movable(record);\n\tlog(\"info\", \"move.start\", { channel: id, from: record.hosted || \"local\", to });\n\tif (to === \"local\") {\n\t\tif (!record.hosted) throw new Error(\"The channel is already on this host\");\n\t\tawait toLocal(record);\n\t} else {\n\t\tif (record.hosted) throw new Error(\"Move the channel to this host first\");\n\t\tawait toHosted(record, to);\n\t}\n\tlog(\"info\", \"move.done\", { channel: id, to });\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",1794439147015,"sidebar","expanded"]