[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_228":-5,"_231":232,"_233":234},"routes/shell",{"_40":41,"_227":-5,"_228":-5,"_229":230},"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","7c690cbcfdf23f1e1925f493bd4e10949afcb76d","path","scripts/conversation-plan-worker.ts","oid","4d2342217a4a6ddd0a775cb46f56f241e7a6d70e","size",19254,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { SQL } from \"bun\";\nimport { createHash } from \"node:crypto\";\nimport { closeSync, openSync } from \"node:fs\";\nimport { cp, lstat, readdir, readFile, realpath, writeFile } from \"node:fs/promises\";\nimport { connect, createServer } from \"node:net\";\nimport { join } from \"node:path\";\nimport { networkInterfaces } from \"node:os\";\n\nconst ROOT = \"/work\";\nconst OMIT = new Set([\"node_modules\", \"dist\", \"test-results\", \".conversation-plan-build.json\"]);\n\nexport function sourcePath(path: string): boolean {\n\tlet reserved =\n\t\t/^(?:node_modules|dist|test-results|playwright-report|\\.conversation-plan-build\\.json|\\.codex|\\.agents|\\.claude|\\.opencode|\\.ssh|\\.aws|\\.npmrc|\\.netrc|credentials(?:\\.json)?|secrets(?:\\.json)?|data|artifacts|evals?|evaluations?|corpus|datasets?|\\.scratch)$/;\n\treturn !path.split(\"/\").some(name =>\n\t\treserved.test(name)\n\t\t|| /^(?:\\.env|\\.git|id_rsa|id_ed25519)/.test(name)\n\t\t|| /\\.(?:pem|key|p12|pfx|log|tsbuildinfo)$/.test(name)\n\t)\n\t\t&& path !== \"e2e/design/snapshots\" && !path.startsWith(\"e2e/design/snapshots/\");\n}\n\nexport function sourceHash(root: string): Promise {\n\treturn treeHash(\n\t\troot,\n\t\t[\n\t\t\t\"apps/server\",\n\t\t\t\"apps/web\",\n\t\t\t\"packages\",\n\t\t\t\"e2e\",\n\t\t\t\"patches\",\n\t\t\t\"scripts/conversation-plan.ts\",\n\t\t\t\"scripts/conversation-plan-worker.ts\",\n\t\t\t\"package.json\",\n\t\t\t\"bun.lock\",\n\t\t\t\"tsconfig.json\",\n\t\t],\n\t\tOMIT,\n\t\tsourcePath,\n\t);\n}\n\nexport async function treeHash(\n\troot: string,\n\tpaths: string[],\n\tomit = OMIT,\n\tinclude = (_path: string) => true,\n): Promise {\n\tlet files: string[] = [];\n\tasync function visit(path: string): Promise {\n\t\tif (!include(path)) return;\n\t\tlet entry = await lstat(join(root, path));\n\t\tif (entry.isFile()) files.push(path);\n\t\telse if (entry.isDirectory()) {\n\t\t\tfor (let name of await readdir(join(root, path))) {\n\t\t\t\tif (!omit.has(name)) await visit(`${path}/${name}`);\n\t\t\t}\n\t\t} else throw new Error(\"hash tree contains a nonregular entry\");\n\t}\n\tfor (let path of paths) await visit(path);\n\tlet hash = createHash(\"sha256\");\n\tfor (let path of files.sort((a, b) => Buffer.compare(Buffer.from(a), Buffer.from(b)))) {\n\t\tlet digest = createHash(\"sha256\").update(await readFile(join(root, path))).digest(\"hex\");\n\t\thash.update(`${path}\\0${digest}\\n`);\n\t}\n\treturn hash.digest(\"hex\");\n}\n\nexport function inputs(env: Record) {\n\tlet nonce = env.CHOPIN_RUN_NONCE ?? \"\";\n\tlet key = env.SESSION_SIGNING_KEY ?? \"\";\n\tlet commit = env.CHOPIN_SOURCE_COMMIT ?? \"\";\n\tif (\n\t\t!/^[a-f0-9]{32}$/.test(nonce) || !/^[a-f0-9]{64}$/.test(key)\n\t\t|| !/^[a-f0-9]{40}$/.test(commit)\n\t) throw new Error(\"invalid ownership inputs\");\n\tlet database = new URL(env.DATABASE_URL ?? \"\");\n\tlet port = Number(database.port);\n\tif (\n\t\tdatabase.protocol !== \"postgres:\" || database.hostname !== \"127.0.0.1\"\n\t\t|| port < 20000 || port > 60999 || database.username !== `cp_${nonce}`\n\t\t|| database.pathname !== `/cp_${nonce}` || !/^[a-f0-9]{64}$/.test(database.password)\n\t\t|| database.search !== \"?sslmode=disable\" || database.hash\n\t) {\n\t\tthrow new Error(\"database does not match generated ownership\");\n\t}\n\treturn { nonce, key, commit, database: database.href };\n}\n\nasync function stamp(commit: string): Promise {\n\tlet built = JSON.parse(await readFile(`${ROOT}/e2e/.conversation-plan-build.json`, \"utf8\"));\n\tlet lockSha256 = createHash(\"sha256\").update(await readFile(`${ROOT}/bun.lock`)).digest(\"hex\");\n\tlet sourceSha256 = await sourceHash(ROOT);\n\tlet buildSha256 = await treeHash(ROOT, [\"apps/web/dist\"], new Set());\n\tif (\n\t\tbuilt.commit !== commit || built.lockSha256 !== lockSha256\n\t\t|| built.sourceSha256 !== sourceSha256 || built.buildSha256 !== buildSha256\n\t) {\n\t\tthrow new Error(\"image build stamp does not match source and client\");\n\t}\n\tawait readFile(`${ROOT}/apps/web/dist/index.html`);\n}\n\nexport type NamespaceLink = {\n\tflags: string;\n\toperstate: string;\n\ttype: string;\n\tpath: string;\n\tindex: string;\n\tlink: string;\n\taddresses: { address: string; family: string; internal: boolean }[];\n};\n\nconst FALLBACK_TYPES: Record = {\n\ttunl0: \"768\",\n\tgre0: \"778\",\n\tgretap0: \"1\",\n\terspan0: \"1\",\n\tip_vti0: \"768\",\n\tip6_vti0: \"769\",\n\tsit0: \"776\",\n\tip6tnl0: \"769\",\n\tip6gre0: \"823\",\n};\n\nexport function checkNamespace(\n\tdev: string,\n\troute: string,\n\tipv6Route: string,\n\tlinks: Record,\n): void {\n\tlet rows = dev.trim().split(\"\\n\");\n\tlet headers = rows.slice(0, 2).map(line =>\n\t\tline.trim().replace(/\\s+/g, \" \").split(\"|\").map(part => part.trim()).join(\"|\")\n\t);\n\tif (\n\t\theaders[0] !== \"Inter-|Receive|Transmit\" || headers[1]\n\t\t\t!== \"face|bytes packets errs drop fifo frame compressed multicast|bytes packets errs drop fifo colls carrier compressed\"\n\t) {\n\t\tthrow new Error(\"invalid device headers\");\n\t}\n\tlet devices = rows.slice(2).map(line => {\n\t\tlet parts = line.trim().split(\":\");\n\t\tlet counters = parts[1]?.trim().split(/\\s+/);\n\t\tif (\n\t\t\tparts.length !== 2 || !/^[A-Za-z0-9_]+$/.test(parts[0]!)\n\t\t\t|| counters?.length !== 16 || counters.some(value => !/^[0-9]+$/.test(value))\n\t\t) {\n\t\t\tthrow new Error(\"invalid device counters\");\n\t\t}\n\t\treturn parts[0]!;\n\t});\n\tif (\n\t\t!devices.includes(\"lo\") || new Set(devices).size !== devices.length\n\t\t|| !links || Object.keys(links).length !== devices.length\n\t\t|| Object.keys(links).some(name => !devices.includes(name))\n\t) {\n\t\tthrow new Error(\"interface inventory mismatch\");\n\t}\n\tlet indices = new Set();\n\tfor (let name of devices) {\n\t\tlet entry = links[name];\n\t\tif (\n\t\t\t!entry || [entry.flags, entry.operstate, entry.type, entry.path, entry.index, entry.link]\n\t\t\t\t.some(value => typeof value !== \"string\")\n\t\t\t|| !/^0x[0-9a-f]{1,8}$/.test(entry.flags)\n\t\t\t|| !/^[1-9][0-9]{0,9}$/.test(entry.index) || Number(entry.index) > 2147483647\n\t\t\t|| !/^(?:0|[1-9][0-9]{0,9})$/.test(entry.link) || Number(entry.link) > 2147483647\n\t\t\t|| !/^(?:0|[1-9][0-9]{0,4})$/.test(entry.type) || Number(entry.type) > 65535\n\t\t\t|| indices.has(entry.index)\n\t\t\t|| !Array.isArray(entry.addresses) || entry.path !== `/sys/devices/virtual/net/${name}`\n\t\t) {\n\t\t\tthrow new Error(\"invalid interface evidence\");\n\t\t}\n\t\tindices.add(entry.index);\n\t\tlet flags = Number.parseInt(entry.flags.slice(2), 16);\n\t\tif (name === \"lo\") {\n\t\t\tif (\n\t\t\t\t(flags & 9) !== 9 || entry.type !== \"772\" || entry.link !== entry.index\n\t\t\t\t|| ![\"unknown\", \"up\"].includes(entry.operstate) || !entry.addresses.length\n\t\t\t\t|| entry.addresses.some(address =>\n\t\t\t\t\t!address || address.internal !== true\n\t\t\t\t\t|| !((address.family === \"IPv4\" && address.address === \"127.0.0.1\")\n\t\t\t\t\t\t|| (address.family === \"IPv6\" && address.address === \"::1\"))\n\t\t\t\t)\n\t\t\t) {\n\t\t\t\tthrow new Error(\"invalid loopback interface\");\n\t\t\t}\n\t\t} else if (\n\t\t\t!Object.hasOwn(FALLBACK_TYPES, name) || entry.type !== FALLBACK_TYPES[name]\n\t\t\t|| entry.link !== \"0\" || flags & 1 || entry.operstate !== \"down\"\n\t\t\t|| entry.addresses.length\n\t\t) {\n\t\t\tthrow new Error(\"active or unknown non-loopback interface\");\n\t\t}\n\t}\n\n\tlet routes = route.trim().split(\"\\n\");\n\tif (\n\t\troutes.shift()?.trim().split(/\\s+/).join(\" \")\n\t\t\t!== \"Iface Destination Gateway Flags RefCnt Use Metric Mask MTU Window IRTT\"\n\t) {\n\t\tthrow new Error(\"invalid IPv4 route header\");\n\t}\n\tif (routes.length) throw new Error(\"IPv4 route outside empty namespace\");\n\tlet ipv6 = ipv6Route.trim().split(\"\\n\").filter(Boolean);\n\tfor (let route of ipv6) {\n\t\tlet fields = route.trim().split(/\\s+/);\n\t\tlet zero = \"00000000000000000000000000000000\";\n\t\tlet local = fields[0] === `${zero.slice(0, -1)}1` && fields[1] === \"80\";\n\t\tlet reject = fields[0] === zero && fields[1] === \"00\"\n\t\t\t&& (Number.parseInt(fields[8] ?? \"\", 16) & 0x200) !== 0;\n\t\tif (\n\t\t\tfields.length !== 10 || fields.slice(5, 9).some(value => !/^[0-9a-f]{8}$/.test(value))\n\t\t\t|| fields[9] !== \"lo\" || !(local || reject)\n\t\t\t|| fields[2] !== zero || fields[3] !== \"00\" || fields[4] !== zero\n\t\t) {\n\t\t\tthrow new Error(\"non-loopback IPv6 route\");\n\t\t}\n\t}\n}\n\nexport type SysfsEntry = { name: string; kind: \"symlink\" | \"file\" | \"other\"; content?: string };\n\nexport function sysfsInterfaces(entries: SysfsEntry[], addressKeys: string[]): string[] {\n\tlet names: string[] = [];\n\tif (new Set(entries.map(entry => entry.name)).size !== entries.length) {\n\t\tthrow new Error(\"duplicate sysfs entry\");\n\t}\n\tfor (let entry of entries) {\n\t\tif (entry.kind === \"symlink\") names.push(entry.name);\n\t\telse if (entry.name === \"bonding_masters\" && entry.kind === \"file\") {\n\t\t\tif (entry.content !== \"\" || addressKeys.includes(entry.name)) {\n\t\t\t\tthrow new Error(\"invalid bonding control\");\n\t\t\t}\n\t\t} else throw new Error(\"unknown non-interface sysfs entry\");\n\t}\n\tif (addressKeys.some(name => !names.includes(name))) {\n\t\tthrow new Error(\"address inventory mismatch\");\n\t}\n\treturn names;\n}\n\nasync function namespaceLinks(): Promise> {\n\tlet entries = await Promise.all((await readdir(\"/sys/class/net\")).map(async name => {\n\t\tlet path = `/sys/class/net/${name}`;\n\t\tlet stat = await lstat(path);\n\t\tlet entry: SysfsEntry = {\n\t\t\tname,\n\t\t\tkind: stat.isSymbolicLink() ? \"symlink\" : stat.isFile() ? \"file\" : \"other\",\n\t\t\tcontent: name === \"bonding_masters\" && stat.isFile()\n\t\t\t\t? await readFile(path, \"utf8\")\n\t\t\t\t: undefined,\n\t\t};\n\t\treturn entry;\n\t}));\n\tlet addresses = networkInterfaces();\n\tlet names = sysfsInterfaces(entries, Object.keys(addresses));\n\tlet links = await Promise.all(names.map(async name => {\n\t\tlet path = `/sys/class/net/${name}`;\n\t\tlet [flags, operstate, type, index, link, resolved] = await Promise.all([\n\t\t\t...[\"flags\", \"operstate\", \"type\", \"ifindex\", \"iflink\"].map(field =>\n\t\t\t\treadFile(`${path}/${field}`, \"utf8\").then(value => value.trim())\n\t\t\t),\n\t\t\trealpath(path),\n\t\t]);\n\t\tlet entry: NamespaceLink = {\n\t\t\tflags: flags!,\n\t\t\toperstate: operstate!,\n\t\t\ttype: type!,\n\t\t\tindex: index!,\n\t\t\tlink: link!,\n\t\t\tpath: resolved!,\n\t\t\taddresses: (addresses[name] ?? []).map(({ address, family, internal }) => ({\n\t\t\t\taddress,\n\t\t\t\tfamily,\n\t\t\t\tinternal,\n\t\t\t})),\n\t\t};\n\t\tlet pair: [string, NamespaceLink] = [name, entry];\n\t\treturn pair;\n\t}));\n\treturn Object.fromEntries(links);\n}\n\nasync function namespace(report: Record): Promise {\n\treport.namespaceStep = \"proc\";\n\tlet [dev, route, ipv6Route] = await Promise.all([\n\t\treadFile(\"/proc/net/dev\", \"utf8\"),\n\t\treadFile(\"/proc/net/route\", \"utf8\"),\n\t\treadFile(\"/proc/net/ipv6_route\", \"utf8\"),\n\t]);\n\treport.namespaceStep = \"links\";\n\tlet links = await namespaceLinks();\n\treport.namespaceEvidence = { links, dev, route, ipv6Route };\n\treport.namespaceStep = \"interfaces-and-routes\";\n\tcheckNamespace(dev, route, ipv6Route, links);\n\treport.namespaceStep = \"socket\";\n\tawait new Promise((resolve, reject) => {\n\t\tlet socket = connect({ host: \"1.1.1.1\", port: 443 });\n\t\tlet timer = setTimeout(() => {\n\t\t\tsocket.destroy();\n\t\t\treject(new Error(\"egress probe timed out\"));\n\t\t}, 2000);\n\t\tsocket.once(\"connect\", () => {\n\t\t\tclearTimeout(timer);\n\t\t\tsocket.destroy();\n\t\t\treject(new Error(\"socket egress allowed\"));\n\t\t});\n\t\tsocket.once(\"error\", (error: NodeJS.ErrnoException) => {\n\t\t\tclearTimeout(timer);\n\t\t\t// Bun 1.4.2 maps kernel ENETUNREACH to ECONNREFUSED in this verified route-free namespace.\n\t\t\tlet mapped = Bun.version === \"1.4.2\" && error.code === \"ECONNREFUSED\";\n\t\t\tif (mapped || [\"ENETUNREACH\", \"EHOSTUNREACH\", \"EACCES\", \"EPERM\"].includes(error.code ?? \"\")) {\n\t\t\t\treport.socketDenial = mapped ? \"bun-mapped-unreachable\" : \"routing-denial\";\n\t\t\t\tresolve();\n\t\t\t} else reject(new Error(\"socket denial could not be attested\"));\n\t\t});\n\t});\n\treport.namespaceStep = \"fetch\";\n\ttry {\n\t\tlet response = await fetch(\"http://1.1.1.1/\", {\n\t\t\tredirect: \"error\",\n\t\t\tsignal: AbortSignal.timeout(2000),\n\t\t});\n\t\tawait response.body?.cancel();\n\t\tthrow new Error(\"fetch egress allowed\");\n\t} catch (error) {\n\t\tif (!(error instanceof TypeError)) {\n\t\t\tthrow new Error(\"fetch denial could not be attested\", { cause: error });\n\t\t}\n\t}\n\treport.namespaceStep = \"complete\";\n}\n\nasync function freePort(port: number): Promise {\n\tawait new Promise((resolve, reject) => {\n\t\tlet server = createServer();\n\t\tserver.once(\"error\", () => reject(new Error(`owned namespace port ${port} is occupied`)));\n\t\tserver.listen(\n\t\t\t{ host: \"127.0.0.1\", port, exclusive: true },\n\t\t\t() =>\n\t\t\t\tserver.close(error => error ? reject(new Error(\"port preflight close failed\")) : resolve()),\n\t\t);\n\t});\n}\n\nfunction restartDatabase(url: string): string {\n\tlet database = new URL(url);\n\tdatabase.pathname += \"_restart\";\n\treturn database.href;\n}\n\nexport function environment(owned: ReturnType): Record {\n\treturn {\n\t\tPATH: \"/usr/local/bin:/usr/bin:/bin\",\n\t\tHOME: \"/tmp\",\n\t\tCI: \"1\",\n\t\tPLAYWRIGHT_BROWSERS_PATH: \"/ms-playwright\",\n\t\tE2E_CONVERSATION_PLAN: \"1\",\n\t\tE2E_DATABASE_URL_0: owned.database,\n\t\tE2E_DATABASE_URL_1: restartDatabase(owned.database),\n\t\tDATABASE_URL: owned.database,\n\t\tSESSION_ENCRYPTION_KEY: owned.key,\n\t\tSTORAGE_DRIVER: \"postgres\",\n\t\tPORT: \"8788\",\n\t\tSERVER_HOST: \"127.0.0.1\",\n\t\tAPP_ORIGIN: \"http://127.0.0.1:8788\",\n\t\tAGENT: \"on\",\n\t\tCONVERSATION_PLAN: \"on\",\n\t\tHARNESS: \"e2e-prompt-scripted\",\n\t\tHARNESS_AUTH: \"direct\",\n\t\tMODEL: \"e2e-prompt-scripted-model\",\n\t\tJEV_API_KEY: \"e2e-jev-only\",\n\t\tJEV_MODEL: \"jev-e2e\",\n\t\tTYPESAFE_API_KEY: \"\",\n\t\tHTTP_PROXY: \"\",\n\t\tHTTPS_PROXY: \"\",\n\t\tALL_PROXY: \"\",\n\t\thttp_proxy: \"\",\n\t\thttps_proxy: \"\",\n\t\tall_proxy: \"\",\n\t\tNO_PROXY: \"*\",\n\t\tno_proxy: \"*\",\n\t\tE2E_PLANNER_JOBS_DIR: `${ROOT}/e2e/test-results/planner-jobs`,\n\t\tE2E_JEV_CONTROL_DIR: `${ROOT}/e2e/test-results/jev-control`,\n\t\tBACKGROUND_JOBS: \"off\",\n\t\tWEB_RESEARCH: \"off\",\n\t\tGITHUB_APP_SLUG: \"chopin-e2e\",\n\t\tGITHUB_APP_CLIENT_ID: \"e2e\",\n\t\tGITHUB_APP_CLIENT_SECRET: \"e2e\",\n\t\tGITHUB_ALLOWED_USERS: \"\",\n\t\tGITHUB_ALLOWED_ORGANIZATIONS: \"githubnext\",\n\t\tDEV_QUESTIONS: \"\",\n\t\tDEV_COMMENTS: \"\",\n\t};\n}\n\nasync function database(url: string): Promise {\n\tlet sql = new SQL(url, { max: 1, connectionTimeout: 2, idleTimeout: 2 });\n\ttry {\n\t\tlet ready = false;\n\t\tfor (let attempt = 0; attempt < 30 && !ready; attempt++) {\n\t\t\ttry {\n\t\t\t\tlet rows = await sql`SELECT current_database() AS db, current_user AS owner,\n\t\t\t\t\tcurrent_setting('server_version_num')::integer AS version`;\n\t\t\t\tlet expected = new URL(url);\n\t\t\t\tif (\n\t\t\t\t\trows[0]?.db !== expected.pathname.slice(1) || rows[0]?.owner !== expected.username\n\t\t\t\t\t|| rows[0]?.version < 170000 || rows[0]?.version >= 180000\n\t\t\t\t) {\n\t\t\t\t\tthrow new Error(\"owned database identity mismatch\");\n\t\t\t\t}\n\t\t\t\tready = true;\n\t\t\t} catch {\n\t\t\t\tif (attempt === 29) throw new Error(\"owned PostgreSQL readiness failed\");\n\t\t\t}\n\t\t\tif (!ready) await Bun.sleep(500);\n\t\t}\n\t\tawait sql`SET statement_timeout = '5s'`;\n\t\tlet tables = await sql`SELECT 1 FROM information_schema.tables WHERE table_schema = 'public'`;\n\t\tif (tables.length) throw new Error(\"owned database is not fresh\");\n\t\tlet { migrate } = await import(\"../apps/server/src/storage/postgres/migrations\");\n\t\tawait migrate(sql);\n\t\tlet restart = restartDatabase(url);\n\t\t// The database name comes from the validated, per-run nonce, inside the owned container.\n\t\tawait sql.unsafe(`CREATE DATABASE \"${new URL(restart).pathname.slice(1)}\"`);\n\t\tlet auxiliary = new SQL(restart, { max: 1, connectionTimeout: 2, idleTimeout: 2 });\n\t\ttry {\n\t\t\tawait migrate(auxiliary);\n\t\t} finally {\n\t\t\tawait auxiliary.close();\n\t\t}\n\t} finally {\n\t\tawait sql.close();\n\t}\n}\n\nasync function artifacts(report: Record): Promise {\n\tlet path = `${ROOT}/e2e/test-results/conversation-plan`;\n\ttry {\n\t\tawait lstat(path);\n\t} catch (error) {\n\t\tif ((error as NodeJS.ErrnoException).code === \"ENOENT\") return;\n\t\tthrow error;\n\t}\n\tawait cp(path, \"/reports/playwright-results\", {\n\t\trecursive: true,\n\t\tfilter: async source => {\n\t\t\tlet info = await lstat(source);\n\t\t\tif (!info.isFile() && !info.isDirectory()) throw new Error(\"nonregular test artifact\");\n\t\t\treturn true;\n\t\t},\n\t});\n\treport.artifactsCopied = true;\n}\n\nasync function cleanup(pid: number, exited: Promise, report: Record) {\n\tfor (let name of [\"SIGTERM\", \"SIGKILL\"] as const) {\n\t\ttry {\n\t\t\tprocess.kill(-pid, name);\n\t\t} catch (error) {\n\t\t\tif ((error as NodeJS.ErrnoException).code !== \"ESRCH\") report.signalFailed = true;\n\t\t}\n\t\tif (name === \"SIGTERM\") await Bun.sleep(2500);\n\t}\n\treport.cliExit = await Promise.race([exited, Bun.sleep(2500).then(() => null)]);\n\ttry {\n\t\tprocess.kill(-pid, 0);\n\t\treport.groupGone = false;\n\t} catch (error) {\n\t\treport.groupGone = (error as NodeJS.ErrnoException).code === \"ESRCH\";\n\t}\n\tif (report.cliExit === null || !report.groupGone || report.signalFailed) {\n\t\tthrow new Error(\"CLI cleanup was not verified\");\n\t}\n}\n\nasync function run(report: Record, env: Record): Promise {\n\tlet log = openSync(\"/reports/cli.log\", \"wx\");\n\tlet child;\n\ttry {\n\t\tchild = Bun.spawn([\n\t\t\t\"bun\",\n\t\t\t\"node_modules/@playwright/test/cli.js\",\n\t\t\t\"test\",\n\t\t\t\"--config\",\n\t\t\t\"e2e/conversation-plan.playwright.config.ts\",\n\t\t], { cwd: ROOT, env, detached: true, stdin: \"ignore\", stdout: log, stderr: log });\n\t} finally {\n\t\tcloseSync(log);\n\t}\n\tlet { promise: interrupted, resolve: wake } = Promise.withResolvers();\n\tlet stop = () => {\n\t\treport.interrupted = true;\n\t\twake();\n\t};\n\tprocess.on(\"SIGINT\", stop);\n\tprocess.on(\"SIGTERM\", stop);\n\tlet timer = setTimeout(() => {\n\t\treport.deadline = true;\n\t\twake();\n\t}, 600_000);\n\tlet failure = await Promise.race([child.exited, interrupted]).then(\n\t\t() => undefined,\n\t\terror => error,\n\t);\n\tclearTimeout(timer);\n\tlet cleanupFailure = await cleanup(child.pid, child.exited, report).then(\n\t\t() => undefined,\n\t\terror => error,\n\t);\n\treport.cliSignal = child.signalCode;\n\tprocess.off(\"SIGINT\", stop);\n\tprocess.off(\"SIGTERM\", stop);\n\tlet artifactFailure = await artifacts(report).then(() => undefined, error => error);\n\tif (cleanupFailure) report.cleanupFailed = true;\n\tif (artifactFailure) report.artifactCopyFailed = true;\n\tif (failure || cleanupFailure || artifactFailure) {\n\t\tthrow failure ?? cleanupFailure ?? artifactFailure;\n\t}\n\treturn report.interrupted || report.deadline ? 1 : Number(report.cliExit);\n}\n\nexport async function main(): Promise {\n\tlet report: Record = { phase: \"inputs\", success: false };\n\tlet preflightDeadline = setTimeout(() => {\n\t\treport.preflightDeadline = true;\n\t\tvoid writeFile(\"/reports/worker.json\", `${JSON.stringify(report, null, 2)}\\n`)\n\t\t\t.finally(() => process.exit(124));\n\t}, 60_000);\n\ttry {\n\t\tif (process.argv.length !== 2 || process.cwd() !== ROOT) {\n\t\t\tthrow new Error(\"fixed worker invocation required\");\n\t\t}\n\t\tlet owned = inputs(process.env);\n\t\treport.nonce = owned.nonce;\n\t\treport.commit = owned.commit;\n\t\treport.phase = \"stamp\";\n\t\tawait stamp(owned.commit);\n\t\treport.phase = \"namespace\";\n\t\tawait namespace(report);\n\t\treport.egressDenied = true;\n\t\treport.phase = \"ports\";\n\t\tawait freePort(8788);\n\t\tawait freePort(8789);\n\t\tawait freePort(8797);\n\t\treport.phase = \"database\";\n\t\tawait database(owned.database);\n\t\treport.migrated = true;\n\t\tclearTimeout(preflightDeadline);\n\t\treport.phase = \"test\";\n\t\tlet exit = await run(report, environment(owned));\n\t\treport.phase = \"cleanup\";\n\t\tawait freePort(8788);\n\t\tawait freePort(8789);\n\t\tawait freePort(8797);\n\t\treport.listenersGone = true;\n\t\treport.success = exit === 0;\n\t\treport.phase = \"complete\";\n\t\treturn exit;\n\t} catch {\n\t\treport.failed = true;\n\t\treturn 1;\n\t} finally {\n\t\tclearTimeout(preflightDeadline);\n\t\tawait writeFile(\"/reports/worker.json\", `${JSON.stringify(report, null, 2)}\\n`);\n\t}\n}\n\nif (import.meta.main) process.exitCode = await main();\n","editable",false,"branch","documentNavigation","repo","githubnext/chopin","repoId","7d1a8ac3-35b0-4dea-85d4-06a980f3bada","ownerId","org:89615882","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers","watching","pinned","notify","views",[183,184,185,186,187,188,189,190,191,192,193,194,195],"navigation",{"_54":55,"_139":140,"_141":142,"_143":144,"_145":146,"_147":148,"_149":150},"sources",[],"viewer","meta",{"_131":132,"_133":134,"_135":136,"_42":31,"_137":126,"_138":31,"_48":49,"_50":49},"branches",[73,74,75,76,77,78,79,80,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],"tags",[69,70,71,72],"cloneUrl","https://git.nexthub.sh/githubnext/chopin.git","color-controls-slice-1","color-controls-slice-2","color-controls-slice-3","color-controls-slice-4","Krzysztof-Cieslak-patch-1","Krzysztof-Cieslak-patch-2","Maggie/app-preview-toolkit","Maggie/ci-playwright-install-timeout","Maggie/collaborative-visual-decision","Maggie/design-audit","Maggie/generic-visual-decision-runtime","Maggie/impeccable-chopin-metadata","Maggie/jev-chat-product","Maggie/jev-composed-assessment","Maggie/native-document-layouts","Maggie/openui-composition-product","Maggie/openui-composition-trial","Maggie/planner-visual-authoring","Maggie/planner-visual-requests","Maggie/visual-selection-eval","artifacts/pr-419-live-preview-20261009","automation/pr-maintenance-state","automation/use-effect/callout-disabled-picker-8cf9e49ba5c09471","automation/use-effect/collaboration-options-ref-4e3a5a08a879a5ae","automation/use-effect/room-workspace-effective-access-a57d40866c71bed0","chore/bun-1.4.2","color-controls","color-controls-plan","comments","design-pr-assets","design/archived-decisions-badge","design/channel-route-remount","design/chat-decision-entry","design/conversation-analysis-markers","design/decision-evidence","design/settled-line-icon","dev/integration","diagram-step-controls","feat/liveapp-frontend-pilot","feat/local-experiments","feat/local-launcher-tracer","fix/autolink-mdx-crash","github-pills/2-pills","github-pills/3-hover-card","maggie/app-preview-toolkit","maggie/ci-playwright-install-timeout","maggie/collaborative-visual-decision","maggie/design-audit","maggie/generic-visual-decision-runtime","maggie/impeccable-chopin-metadata","maggie/jev-composed-assessment","maggie/native-document-layouts","maggie/openui-composition-product","maggie/openui-composition-trial","maggie/planner-visual-authoring","maggie/planner-visual-requests","maggie/visual-selection-eval","main","plain-text-fence-chrome","tokens/09-copy","wireframes/2-renderer","wireframes/3-planner","description","Let's compose rich plans together","owner","githubnext","section","","head","empty","pins",[165,166,167],"documents",{"_160":161,"_162":163},"code",{"_156":157,"_158":159},"automations",{"_153":154,"_155":-5},"delivery",{"_151":49,"_152":-5},"tag","04zvKQ8QOrDUF8TO1Ovz0Zy8_TT","releases","applications","workflows",3,"deployments","commits",1000,"changes",13,"counts",{"_164":163},"total",11,"issue",{"_168":158,"_170":181,"_15":158,"_172":182,"_52":174,"_175":31,"_176":174,"_177":159},{"_168":178,"_170":179,"_15":178,"_172":180,"_52":174,"_175":31,"_176":174,"_177":49},{"_168":169,"_170":171,"_15":169,"_172":173,"_52":174,"_175":31,"_176":174,"_177":163},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_168":158,"_170":181,"_15":158,"_172":226,"_52":174,"_175":31,"_176":174},{"_168":178,"_170":179,"_15":178,"_172":225,"_52":174,"_175":31,"_176":174},{"_168":169,"_170":171,"_15":169,"_172":224,"_52":174,"_175":31,"_176":174},{"_168":221,"_170":222,"_15":221,"_172":223,"_52":31,"_175":31,"_176":174},{"_168":218,"_170":219,"_15":218,"_172":220,"_52":31,"_175":31,"_176":174},{"_168":153,"_170":216,"_15":145,"_172":217,"_52":31,"_175":31,"_176":174},{"_168":155,"_170":213,"_15":214,"_172":215,"_52":31,"_175":31,"_176":174},{"_168":151,"_170":211,"_15":151,"_172":212,"_52":31,"_175":31,"_176":174},{"_168":207,"_170":208,"_15":209,"_172":210,"_52":31,"_175":31,"_176":174},{"_168":141,"_170":205,"_15":141,"_172":206,"_52":31,"_175":31,"_176":31},{"_168":202,"_170":203,"_15":202,"_172":204,"_52":31,"_175":31,"_176":31},{"_168":199,"_170":200,"_15":199,"_172":201,"_52":31,"_175":31,"_176":31},{"_168":196,"_170":197,"_15":196,"_172":198,"_52":31,"_175":31,"_176":31},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794435685766,"sidebar","expanded"]