[{"_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","11e4f40534865a5200344f31b04bf0be139047fa","path","packages/channel/src/transfer.ts","oid","10dff66a523d4aed8f754b29b718138a3407d464","size",10898,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","/**\n * A channel's complete pi state as one JSON value, for moving it between a host and a hosted cell.\n * pi's SQLite schema stays authoritative: snapshots carry exactly its current tables and refuse any\n * other schema version, so a move never translates or migrates data.\n */\nimport {\n\tapplySqliteMigrations,\n\tCURRENT_SQLITE_SCHEMA_VERSION,\n\ttype SqliteDatabase,\n\ttype SqliteExecutor,\n\ttype SqliteValue,\n} from \"@earendil-works/pi-durable/storage/sqlite\";\n\ndeclare function btoa(data: string): string;\ndeclare function atob(data: string): string;\ndeclare const crypto: {\n\tsubtle: { digest(algorithm: string, data: Uint8Array): Promise };\n};\ndeclare class TextEncoder {\n\tencode(input: string): Uint8Array;\n}\n\n/** JSON carries bytes as base64 and integers beyond 2^53 as decimal strings. */\nexport type Cell = null | number | string | { b64: string } | { int: string };\n\nexport type Snapshot = {\n\tformat: \"ace-channel-snapshot\";\n\tversion: 1;\n\tchannel: string;\n\tschema: number;\n\ttables: Record;\n\t/** SHA-256 hex of the canonical encoding of everything above. */\n\tdigest: string;\n};\n\n/** Requests and responses carry the whole snapshot in one body. */\nexport const MAX_SNAPSHOT = 32 * 1024 * 1024;\n\n/**\n * The pi schema version `TABLES` describes. A newer pi may add columns this list would silently\n * drop, so moves refuse until it is updated for that version.\n */\nconst SCHEMA = 1;\n\nfunction pinned(): void {\n\tif (CURRENT_SQLITE_SCHEMA_VERSION !== SCHEMA) {\n\t\tthrow new Error(\n\t\t\t`Channel moves support pi schema ${SCHEMA}; this runtime has ${CURRENT_SQLITE_SCHEMA_VERSION}`,\n\t\t);\n\t}\n}\n\n/** pi schema version 1, in insertion order; `key` orders rows without relying on rowid. */\nconst TABLES: Record = {\n\tdurable_schema: { columns: [\"singleton\", \"version\"], key: [\"singleton\"] },\n\tdurable_metadata: { columns: [\"singleton\", \"next_id\", \"next_seq\"], key: [\"singleton\"] },\n\trecord_ids: { columns: [\"id\", \"record_type\"], key: [\"id\"] },\n\tconversations: {\n\t\tcolumns: [\"id\", \"owner_conversation_id\", \"owner_task_id\", \"record\"],\n\t\tkey: [\"id\"],\n\t},\n\tentries: { columns: [\"id\", \"conversation_id\", \"head\", \"commit_seq\", \"record\"], key: [\"id\"] },\n\ttasks: {\n\t\tcolumns: [\"id\", \"conversation_id\", \"kind\", \"status\", \"abort_requested\", \"background\", \"record\"],\n\t\tkey: [\"id\"],\n\t},\n\tsubmissions: {\n\t\tcolumns: [\"id\", \"conversation_id\", \"request_id\", \"status\", \"record\"],\n\t\tkey: [\"id\"],\n\t},\n\tdocuments: {\n\t\tcolumns: [\n\t\t\t\"id\",\n\t\t\t\"kind\",\n\t\t\t\"family\",\n\t\t\t\"key_value\",\n\t\t\t\"scope_kind\",\n\t\t\t\"owner_id\",\n\t\t\t\"created_at\",\n\t\t\t\"retired_at\",\n\t\t\t\"record\",\n\t\t],\n\t\tkey: [\"id\"],\n\t},\n\tdocument_revisions: {\n\t\tcolumns: [\"document_id\", \"seq\", \"kind\", \"version\", \"content\"],\n\t\tkey: [\"document_id\", \"seq\"],\n\t},\n};\nconst NAMES = Object.keys(TABLES);\n/** What `applySqliteMigrations` seeds into a new database. */\nconst SEED = JSON.stringify({\n\tdurable_schema: [[1, SCHEMA]],\n\tdurable_metadata: [[1, \"2\", 1]],\n});\n// Durable Objects keep their KV API in `__cf_kv`; SQLite keeps its own `sqlite_*` tables.\nconst INTERNAL = /^(sqlite_|_cf_|__cf_)/i;\n\nfunction encode(value: unknown): Cell {\n\tif (value === null || typeof value === \"string\") return value;\n\tif (typeof value === \"number\") {\n\t\tif (!Number.isFinite(value)) throw new Error(`Unsupported SQLite number ${value}`);\n\t\treturn value;\n\t}\n\tif (typeof value === \"bigint\") {\n\t\treturn Number.isSafeInteger(Number(value)) ? Number(value) : { int: value.toString() };\n\t}\n\tif (value instanceof Uint8Array) {\n\t\tlet binary = \"\";\n\t\tfor (let i = 0; i < value.length; i += 0x8000) {\n\t\t\tbinary += String.fromCharCode(...value.subarray(i, i + 0x8000));\n\t\t}\n\t\treturn { b64: btoa(binary) };\n\t}\n\tthrow new Error(`Unsupported SQLite value ${typeof value}`);\n}\n\nfunction decode(cell: unknown): SqliteValue {\n\tif (cell === null || typeof cell === \"string\") return cell;\n\tif (typeof cell === \"number\" && Number.isFinite(cell)) return cell;\n\tif (typeof cell === \"object\") {\n\t\tconst keys = Object.keys(cell);\n\t\tif (keys.length === 1 && \"b64\" in cell && typeof cell.b64 === \"string\") {\n\t\t\treturn Uint8Array.from(atob(cell.b64), (c) => c.charCodeAt(0));\n\t\t}\n\t\tif (\n\t\t\tkeys.length === 1 && \"int\" in cell && typeof cell.int === \"string\" && /^-?\\d+$/.test(cell.int)\n\t\t) {\n\t\t\treturn BigInt(cell.int);\n\t\t}\n\t}\n\tthrow new Error(`Snapshot has an unsupported cell ${JSON.stringify(cell)}`);\n}\n\n/** Canonical encoding: fixed field and table order, rows in primary-key order. */\nfunction canonical(snapshot: Omit): string {\n\treturn JSON.stringify([\n\t\tsnapshot.format,\n\t\tsnapshot.version,\n\t\tsnapshot.channel,\n\t\tsnapshot.schema,\n\t\tNAMES.map((name) => [name, snapshot.tables[name]!.columns, snapshot.tables[name]!.rows]),\n\t]);\n}\n\nasync function sha256(bytes: Uint8Array): Promise {\n\tconst hash = new Uint8Array(await crypto.subtle.digest(\"SHA-256\", bytes));\n\treturn Array.from(hash, (byte) => byte.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function seal(body: Omit): Promise {\n\tconst bytes = new TextEncoder().encode(canonical(body));\n\tif (bytes.byteLength > MAX_SNAPSHOT) {\n\t\tthrow new Error(`Channel snapshot exceeds ${MAX_SNAPSHOT} bytes; moving it is not supported`);\n\t}\n\treturn { ...body, digest: await sha256(bytes) };\n}\n\n/** Refuses databases holding anything but pi's tables, or another pi schema version. */\nasync function check(db: SqliteExecutor): Promise {\n\tconst tables = await db.all<{ name: string }>(\n\t\t\"SELECT name FROM sqlite_master WHERE type = 'table'\",\n\t);\n\tconst found = new Set(tables.map(({ name }) => name).filter((name) => !INTERNAL.test(name)));\n\tconst extra = [...found].filter((name) => !(name in TABLES));\n\tif (extra.length) throw new Error(`Channel database has unknown tables: ${extra.join(\", \")}`);\n\tconst missing = NAMES.filter((name) => !found.has(name));\n\tif (missing.length) throw new Error(`Channel database lacks pi tables: ${missing.join(\", \")}`);\n\tconst row = await db.get<{ version: number | bigint }>(\n\t\t\"SELECT version FROM durable_schema WHERE singleton = 1\",\n\t);\n\tif (Number(row?.version) !== SCHEMA) {\n\t\tthrow new Error(\n\t\t\t`Channel database has pi schema ${row?.version}; moves support ${SCHEMA}`,\n\t\t);\n\t}\n}\n\nasync function read(db: SqliteExecutor, channel: string): Promise {\n\tawait check(db);\n\tconst tables: Snapshot[\"tables\"] = {};\n\tfor (const name of NAMES) {\n\t\tconst { columns, key } = TABLES[name]!;\n\t\tconst rows = await db.all>(\n\t\t\t`SELECT ${columns.join(\", \")} FROM ${name} ORDER BY ${key.join(\", \")}`,\n\t\t);\n\t\ttables[name] = {\n\t\t\tcolumns,\n\t\t\trows: rows.map((row) => columns.map((column) => encode(row[column]))),\n\t\t};\n\t}\n\treturn seal({\n\t\tformat: \"ace-channel-snapshot\",\n\t\tversion: 1,\n\t\tchannel,\n\t\tschema: SCHEMA,\n\t\ttables,\n\t});\n}\n\n/**\n * Whether pi still holds queued or running work. Moves carry only settled channels; a snapshot\n * with live tasks would resume them at the destination.\n */\nexport async function isUnsettled(db: SqliteExecutor): Promise {\n\tconst task = await db.get(\"SELECT id FROM tasks WHERE status != 'terminal' LIMIT 1\");\n\tconst submission = await db.get(\n\t\t\"SELECT id FROM submissions WHERE status IN ('queued', 'placed') LIMIT 1\",\n\t);\n\treturn !!(task || submission);\n}\n\n/** One consistent read of a closed, settled channel database. */\nexport async function exportSnapshot(db: SqliteDatabase, channel: string): Promise {\n\tpinned();\n\treturn db.transaction(async (tx) => {\n\t\tif (await isUnsettled(tx)) {\n\t\t\tthrow new Error(\"Channel has unfinished work; wait until it is idle\");\n\t\t}\n\t\treturn read(tx, channel);\n\t});\n}\n\nfunction validate(snapshot: Snapshot): void {\n\tif (snapshot?.format !== \"ace-channel-snapshot\" || snapshot.version !== 1) {\n\t\tthrow new Error(\"Not a version 1 Ace channel snapshot\");\n\t}\n\tif (snapshot.schema !== SCHEMA) {\n\t\tthrow new Error(\n\t\t\t`Snapshot has pi schema ${snapshot.schema}; moves support ${SCHEMA}`,\n\t\t);\n\t}\n\tif (typeof snapshot.channel !== \"string\" || typeof snapshot.digest !== \"string\") {\n\t\tthrow new Error(\"Snapshot lacks its channel or digest\");\n\t}\n\tconst names = Object.keys(snapshot.tables || {});\n\tif (names.length !== NAMES.length || names.some((name) => !(name in TABLES))) {\n\t\tthrow new Error(\"Snapshot tables do not match pi's schema\");\n\t}\n\tfor (const name of NAMES) {\n\t\tconst { columns, rows } = snapshot.tables[name]!;\n\t\tif (JSON.stringify(columns) !== JSON.stringify(TABLES[name]!.columns) || !Array.isArray(rows)) {\n\t\t\tthrow new Error(`Snapshot table ${name} does not match pi's schema`);\n\t\t}\n\t\tfor (const row of rows) {\n\t\t\tif (!Array.isArray(row) || row.length !== columns.length) {\n\t\t\t\tthrow new Error(`Snapshot table ${name} has a malformed row`);\n\t\t\t}\n\t\t}\n\t}\n}\n\n/**\n * Writes a snapshot into a database in one transaction, then re-reads it and refuses unless the\n * stored state hashes to the snapshot's digest. The destination must hold no pi records beyond\n * the schema seed, unless `replace` is set by a caller that has already established the\n * destination is a frozen or inactive copy of this same channel. `install` runs inside the same\n * transaction after verification, so callers can record the import atomically with it.\n */\nexport async function importSnapshot(\n\tdb: SqliteDatabase,\n\tsnapshot: Snapshot,\n\toptions: { replace?: boolean; install?: (tx: SqliteExecutor) => Promise } = {},\n): Promise<{ digest: string; counts: Record }> {\n\tpinned();\n\tvalidate(snapshot);\n\tconst { digest, ...body } = snapshot;\n\tconst sealed = await seal(body);\n\tif (sealed.digest !== digest) throw new Error(\"Snapshot digest does not match its contents\");\n\tconst rows = NAMES.map((name) => snapshot.tables[name]!.rows.map((row) => row.map(decode)));\n\tawait applySqliteMigrations(db);\n\treturn db.transaction(async (tx) => {\n\t\tconst current = await read(tx, snapshot.channel);\n\t\tif (!options.replace) {\n\t\t\tconst seeded = JSON.stringify({\n\t\t\t\tdurable_schema: current.tables.durable_schema!.rows,\n\t\t\t\tdurable_metadata: current.tables.durable_metadata!.rows,\n\t\t\t});\n\t\t\tconst empty = NAMES.every((name) =>\n\t\t\t\tname.startsWith(\"durable_\") || !current.tables[name]!.rows.length\n\t\t\t);\n\t\t\tif (!empty || seeded !== SEED) throw new Error(\"Destination channel database is not empty\");\n\t\t}\n\t\tfor (const name of NAMES.toReversed()) await tx.run(`DELETE FROM ${name}`);\n\t\tfor (const [index, name] of NAMES.entries()) {\n\t\t\tconst { columns } = TABLES[name]!;\n\t\t\tconst sql = `INSERT INTO ${name} (${columns.join(\", \")}) VALUES (${\n\t\t\t\tcolumns.map(() => \"?\").join(\", \")\n\t\t\t})`;\n\t\t\tfor (const row of rows[index]!) await tx.run(sql, ...row);\n\t\t}\n\t\tconst stored = await read(tx, snapshot.channel);\n\t\tif (stored.digest !== digest) {\n\t\t\tthrow new Error(\"Imported channel does not match the snapshot digest\");\n\t\t}\n\t\tawait options.install?.(tx);\n\t\treturn {\n\t\t\tdigest,\n\t\t\tcounts: Object.fromEntries(NAMES.map((name) => [name, snapshot.tables[name]!.rows.length])),\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",1794435413917,"sidebar","expanded"]