[{"_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","b4e3a6b06448cbb453ea2e8dca2167e5e03f46f8","path","apps/host/src/browser.ts","oid","8949e368337daeccf75ae8c9708f70120d6c5fd0","size",20893,"commit","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { readFile } from \"node:fs/promises\";\nimport { join } from \"node:path\";\n\nimport type {\n\tBrowser,\n\tBrowserNavigate,\n\tBrowserRequest,\n\tBrowserResult,\n\tBrowserTarget,\n} from \"@ace/channel/browser\";\n\nimport { config } from \"./config\";\n\nconst DEADLINE = 30_000;\nconst SCREENSHOT_DEADLINE = 10_000;\n// Larger DevTools messages are neither parsed nor retained; only their command fails.\nconst MAX_MESSAGE = 16 * 1024 * 1024;\nconst MAX_TREE = 32_000;\nconst MAX_FIELD = 400;\nconst MAX_TABS_TEXT = 32_000;\n// A result must fit the hosted channel's 2 MB SQLite row after JSON encoding.\nconst MAX_RESULT = 1_900_000;\n\n/** The dedicated profile; Chrome writes its loopback port and browser path here. */\nconst profile = () => join(config.home, \"browser\");\n\nclass Refusal extends Error {}\n\ntype Endpoint = { id: string; port: number; url: string };\n\nfunction launch(): string {\n\tconst [chrome, note] = process.platform === \"darwin\"\n\t\t? [`open -na \"Google Chrome\" --args`, \"\"]\n\t\t: [\n\t\t\t\"chromium\",\n\t\t\t\" Use google-chrome or another Chromium executable in place of chromium if needed.\",\n\t\t];\n\treturn `Launch Ace's dedicated development browser with its own profile, for example: \\`${chrome} --user-data-dir=\"${profile()}\" --remote-debugging-port=0 --no-first-run --no-default-browser-check\\`.${note}`;\n}\n\nasync function endpoint(): Promise {\n\tlet text: string;\n\ttry {\n\t\ttext = await readFile(join(profile(), \"DevToolsActivePort\"), \"utf8\");\n\t} catch {\n\t\tthrow new Refusal(`No dedicated development browser is running. ${launch()}`);\n\t}\n\tconst [port, path] = text.split(\"\\n\");\n\tconst id = /^\\/devtools\\/browser\\/([0-9a-f-]{36})$/.exec(path || \"\")?.[1];\n\tconst number = Number(port);\n\tif (!/^\\d{1,5}$/.test(port || \"\") || number < 1 || number > 65_535 || !id) {\n\t\tthrow new Refusal(\n\t\t\t`The dedicated browser profile has an unreadable DevToolsActivePort file. ${launch()}`,\n\t\t);\n\t}\n\treturn { id, port: number, url: `ws://127.0.0.1:${number}${path}` };\n}\n\ntype Pending = { resolve(value: Record): void; reject(error: Error): void };\n\nclass CdpError extends Error {}\n\n/** One loopback DevTools connection; closing or aborting fails every pending command. */\nclass Cdp {\n\t#socket: WebSocket;\n\t#next = 1;\n\t#pending = new Map();\n\t#closed?: Error;\n\n\tprivate constructor(socket: WebSocket, signal: AbortSignal) {\n\t\tthis.#socket = socket;\n\t\tsocket.addEventListener(\"message\", ({ data }) => {\n\t\t\tif (typeof data !== \"string\") {\n\t\t\t\treturn this.close(new Error(\"The browser sent a binary DevTools message.\"));\n\t\t\t}\n\t\t\tif (data.length > MAX_MESSAGE || Buffer.byteLength(data) > MAX_MESSAGE) {\n\t\t\t\t// Chrome serializes the command id first, so only that command fails and its payload is dropped.\n\t\t\t\tconst id = Number(/^\\{\"id\":(\\d+),/.exec(data.slice(0, 32))?.[1]);\n\t\t\t\tconst pending = this.#pending.get(id);\n\t\t\t\tthis.#pending.delete(id);\n\t\t\t\treturn pending?.reject(\n\t\t\t\t\tnew Error(\"The browser's answer exceeded the 16 MB DevTools message limit.\"),\n\t\t\t\t);\n\t\t\t}\n\t\t\tconst message = JSON.parse(data) as {\n\t\t\t\tid?: number;\n\t\t\t\tresult?: Record;\n\t\t\t\terror?: { message: string };\n\t\t\t};\n\t\t\tif (message.id === undefined) return;\n\t\t\tconst pending = this.#pending.get(message.id);\n\t\t\tif (!pending) return;\n\t\t\tthis.#pending.delete(message.id);\n\t\t\tif (message.error) return pending.reject(new CdpError(message.error.message.slice(0, 500)));\n\t\t\tpending.resolve(message.result || {});\n\t\t});\n\t\tsocket.addEventListener(\"close\", () => this.close(new Error(\"The browser connection closed.\")));\n\t\tsignal.addEventListener(\"abort\", () => this.close(abortError(signal)), { once: true });\n\t}\n\n\tstatic async open(url: string, signal: AbortSignal): Promise {\n\t\tsignal.throwIfAborted();\n\t\tconst socket = new WebSocket(url);\n\t\tconst { promise, resolve, reject } = Promise.withResolvers();\n\t\tconst abort = () => reject(abortError(signal));\n\t\tsignal.addEventListener(\"abort\", abort, { once: true });\n\t\tsocket.addEventListener(\"open\", () => resolve(), { once: true });\n\t\tsocket.addEventListener(\"error\", () => reject(new Error(\"Cannot connect\")), { once: true });\n\t\tsocket.addEventListener(\"close\", () => reject(new Error(\"Cannot connect\")), { once: true });\n\t\ttry {\n\t\t\tawait promise;\n\t\t} catch (error) {\n\t\t\tsocket.close();\n\t\t\tif (signal.aborted) throw error;\n\t\t\tthrow new Refusal(`The dedicated development browser is not reachable. ${launch()}`);\n\t\t} finally {\n\t\t\tsignal.removeEventListener(\"abort\", abort);\n\t\t}\n\t\treturn new Cdp(socket, signal);\n\t}\n\n\t/** `sent` runs once the command has been handed to the socket. */\n\tsend(\n\t\tmethod: string,\n\t\tparams: Record = {},\n\t\toptions: { session?: string; timeout?: number; sent?(): void } = {},\n\t): Promise> {\n\t\tif (this.#closed) return Promise.reject(this.#closed);\n\t\tconst id = this.#next++;\n\t\tconst { promise, resolve, reject } = Promise.withResolvers>();\n\t\tconst timer = options.timeout\n\t\t\t? setTimeout(() => {\n\t\t\t\tthis.#pending.delete(id);\n\t\t\t\treject(new Error(`${method} timed out after ${options.timeout! / 1000} seconds.`));\n\t\t\t}, options.timeout)\n\t\t\t: undefined;\n\t\tthis.#pending.set(id, {\n\t\t\tresolve: (value) => {\n\t\t\t\tclearTimeout(timer);\n\t\t\t\tresolve(value);\n\t\t\t},\n\t\t\treject: (error) => {\n\t\t\t\tclearTimeout(timer);\n\t\t\t\treject(error);\n\t\t\t},\n\t\t});\n\t\ttry {\n\t\t\tthis.#socket.send(JSON.stringify({\n\t\t\t\tid,\n\t\t\t\tmethod,\n\t\t\t\tparams,\n\t\t\t\t...(options.session ? { sessionId: options.session } : {}),\n\t\t\t}));\n\t\t} catch (error) {\n\t\t\tthis.#pending.get(id)?.reject(error as Error);\n\t\t\tthis.#pending.delete(id);\n\t\t\treturn promise;\n\t\t}\n\t\toptions.sent?.();\n\t\treturn promise;\n\t}\n\n\tclose(error = new Error(\"The browser connection closed.\")): void {\n\t\tif (this.#closed) return;\n\t\tthis.#closed = error;\n\t\tfor (const pending of this.#pending.values()) pending.reject(error);\n\t\tthis.#pending.clear();\n\t\tthis.#socket.close();\n\t}\n}\n\nfunction abortError(signal: AbortSignal): Error {\n\treturn signal.reason instanceof Error\n\t\t? signal.reason\n\t\t: new Error(\"The browser operation was cancelled.\");\n}\n\nconst encoder = new TextEncoder();\n\nfunction bytes(text: string): number {\n\treturn encoder.encode(text).length;\n}\n\n/** Truncate to whole code points within a UTF-8 byte budget. */\nfunction clip(text: string, max: number): string {\n\tif (text.length * 3 <= max) return text;\n\tconst { read } = encoder.encodeInto(text, new Uint8Array(max));\n\treturn read === text.length\n\t\t? text\n\t\t: text.slice(0, encoder.encodeInto(text, new Uint8Array(max - 3)).read) + \"…\";\n}\n\nfunction field(value: unknown): string {\n\treturn clip(typeof value === \"string\" ? value : String(value ?? \"\"), MAX_FIELD);\n}\n\ntype TargetInfo = {\n\ttargetId: string;\n\ttype: string;\n\tsubtype?: string;\n\turl: string;\n\ttitle: string;\n\tattached: boolean;\n};\n\nfunction isTab(info: TargetInfo): boolean {\n\treturn info.type === \"page\" && info.subtype !== \"prerender\";\n}\n\nasync function connect(signal: AbortSignal, target?: BrowserTarget) {\n\tconst found = await endpoint();\n\tif (target && target.browser !== found.id) {\n\t\tthrow new Refusal(\n\t\t\t\"The dedicated browser was restarted or replaced since this target was listed. Call browser_tabs and choose a target from the current browser.\",\n\t\t);\n\t}\n\tconst cdp = await Cdp.open(found.url, signal);\n\treturn { cdp, endpoint: found };\n}\n\nasync function attach(\n\tcdp: Cdp,\n\ttarget: BrowserTarget,\n): Promise<{ session: string; info: TargetInfo }> {\n\tlet info: TargetInfo;\n\ttry {\n\t\t({ targetInfo: info } = await cdp.send(\"Target.getTargetInfo\", {\n\t\t\ttargetId: target.target_id,\n\t\t}) as {\n\t\t\ttargetInfo: TargetInfo;\n\t\t});\n\t} catch (error) {\n\t\tif (!(error instanceof CdpError)) throw error;\n\t\tthrow new Refusal(\n\t\t\t\"The target tab no longer exists. Call browser_tabs and choose a current target.\",\n\t\t);\n\t}\n\tif (!isTab(info)) {\n\t\tthrow new Refusal(\"The target is not a page tab. Choose a tab from browser_tabs.\");\n\t}\n\tconst { sessionId } = await cdp.send(\"Target.attachToTarget\", {\n\t\ttargetId: target.target_id,\n\t\tflatten: true,\n\t}) as { sessionId: string };\n\treturn { session: sessionId, info };\n}\n\nasync function tabs(signal: AbortSignal): Promise {\n\tconst { cdp, endpoint } = await connect(signal);\n\ttry {\n\t\tconst { product } = await cdp.send(\"Browser.getVersion\") as { product: string };\n\t\tconst { targetInfos } = await cdp.send(\"Target.getTargets\") as { targetInfos: TargetInfo[] };\n\t\tconst all = targetInfos.filter(isTab);\n\t\tconst listed = all.map((info) => ({\n\t\t\ttarget: { browser: endpoint.id, target_id: info.targetId },\n\t\t\turl: field(info.url),\n\t\t\ttitle: field(info.title),\n\t\t\tattached: info.attached,\n\t\t}));\n\t\tconst value = {\n\t\t\tbrowser: {\n\t\t\t\tid: endpoint.id,\n\t\t\t\tproduct,\n\t\t\t\tprofile: profile(),\n\t\t\t\tendpoint: `127.0.0.1:${endpoint.port}`,\n\t\t\t},\n\t\t\ttabs: listed,\n\t\t};\n\t\tlet text = JSON.stringify(value);\n\t\twhile (bytes(text) > MAX_TABS_TEXT) {\n\t\t\tlisted.pop();\n\t\t\ttext = JSON.stringify({ ...value, truncated: { total: all.length, shown: listed.length } });\n\t\t}\n\t\treturn { text };\n\t} finally {\n\t\tcdp.close();\n\t}\n}\n\ntype AXValue = { value?: unknown };\ntype AXNode = {\n\tnodeId: string;\n\tignored: boolean;\n\trole?: AXValue;\n\tname?: AXValue;\n\tvalue?: AXValue;\n\tdescription?: AXValue;\n\tproperties?: { name: string; value: AXValue }[];\n\tchildIds?: string[];\n\tparentId?: string;\n};\n\nconst STATES = new Set([\n\t\"focused\",\n\t\"disabled\",\n\t\"checked\",\n\t\"pressed\",\n\t\"expanded\",\n\t\"selected\",\n\t\"required\",\n\t\"invalid\",\n\t\"level\",\n\t\"url\",\n]);\n\n/** Render the tree depth-first within a byte budget; ignored and unnamed generic nodes pass through. */\nfunction tree(nodes: AXNode[]): { text: string; shown: number; total: number } {\n\tconst byId = new Map(nodes.map((node) => [node.nodeId, node]));\n\tconst root = nodes.find((node) => !node.parentId || !byId.has(node.parentId));\n\tconst lines: string[] = [];\n\tlet size = 0, shown = 0, total = 0, full = false;\n\tconst stack: [AXNode, number][] = root ? [[root, 0]] : [];\n\tconst seen = new Set();\n\twhile (stack.length) {\n\t\tconst [node, depth] = stack.pop()!;\n\t\tif (seen.has(node.nodeId)) continue;\n\t\tseen.add(node.nodeId);\n\t\tconst role = field(node.role?.value);\n\t\tconst name = field(node.name?.value);\n\t\tconst rendered = !node.ignored && role !== \"InlineTextBox\"\n\t\t\t&& !((role === \"generic\" || role === \"none\") && !name);\n\t\tconst children = (node.childIds || []).map((id) => byId.get(id)).filter((child) => !!child);\n\t\tconst next = rendered ? depth + 1 : depth;\n\t\tfor (let i = children.length - 1; i >= 0; i--) stack.push([children[i]!, next]);\n\t\tif (!rendered) continue;\n\t\ttotal++;\n\t\tif (full) continue;\n\t\tconst parts = [role];\n\t\tif (name) parts.push(JSON.stringify(name));\n\t\tconst value = node.value?.value;\n\t\tif (value !== undefined && value !== \"\") parts.push(`value=${JSON.stringify(field(value))}`);\n\t\tconst description = node.description?.value;\n\t\tif (description) parts.push(`description=${JSON.stringify(field(description))}`);\n\t\tfor (const property of node.properties || []) {\n\t\t\tif (!STATES.has(property.name)) continue;\n\t\t\tconst state = property.value.value;\n\t\t\tif (state === false || state === undefined || state === \"false\") continue;\n\t\t\tparts.push(\n\t\t\t\tstate === true ? property.name : `${property.name}=${JSON.stringify(field(state))}`,\n\t\t\t);\n\t\t}\n\t\tconst line = `${\" \".repeat(Math.min(depth, 24))}${depth > 24 ? `[${depth}] ` : \"\"}${\n\t\t\tparts.join(\" \")\n\t\t}`;\n\t\tconst cost = bytes(line) + 1;\n\t\tif (size + cost > MAX_TREE) {\n\t\t\tfull = true;\n\t\t\tcontinue;\n\t\t}\n\t\tsize += cost;\n\t\tshown++;\n\t\tlines.push(line);\n\t}\n\treturn { text: lines.join(\"\\n\"), shown, total };\n}\n\ntype Frame = { id: string; loaderId: string; url: string };\n\nasync function frame(cdp: Cdp, session: string): Promise {\n\tconst { frameTree } = await cdp.send(\"Page.getFrameTree\", {}, { session }) as {\n\t\tframeTree: { frame: Frame };\n\t};\n\treturn frameTree.frame;\n}\n\nfunction message(error: unknown): string {\n\treturn clip(error instanceof Error ? error.message : String(error), 2000);\n}\n\nconst MAX_IMAGE = 900_000;\nconst MAX_SIDE = 4096;\n\n/** Dimensions of a complete JPEG, or undefined when it is malformed. */\nfunction jpeg(data: Buffer): { width: number; height: number } | undefined {\n\tif (data[0] !== 0xff || data[1] !== 0xd8 || data.at(-2) !== 0xff || data.at(-1) !== 0xd9) return;\n\tlet at = 2;\n\twhile (at + 9 < data.length) {\n\t\tif (data[at] !== 0xff) return;\n\t\tconst marker = data[at + 1]!;\n\t\tif (marker === 0xff) {\n\t\t\tat++;\n\t\t\tcontinue;\n\t\t}\n\t\tif (marker >= 0xc0 && marker <= 0xcf && marker !== 0xc4 && marker !== 0xc8 && marker !== 0xcc) {\n\t\t\treturn { height: data.readUInt16BE(at + 5), width: data.readUInt16BE(at + 7) };\n\t\t}\n\t\tat += 2 + data.readUInt16BE(at + 2);\n\t}\n}\n\nasync function capture(cdp: Cdp, session: string) {\n\tconst { cssVisualViewport: viewport } = await cdp.send(\"Page.getLayoutMetrics\", {}, {\n\t\tsession,\n\t}) as { cssVisualViewport: Record };\n\t// Without a clip Chrome captures the visible viewport at device resolution; a clip's DIP space\n\t// differs from CSS layout metrics under browser zoom, and resizing would need a platform tool.\n\tfor (const quality of [80, 60, 40]) {\n\t\tconst { data } = await cdp.send(\"Page.captureScreenshot\", {\n\t\t\tformat: \"jpeg\",\n\t\t\tquality,\n\t\t\tcaptureBeyondViewport: false,\n\t\t}, { session, timeout: SCREENSHOT_DEADLINE }) as { data: string };\n\t\tif (typeof data !== \"string\" || data.length > Math.ceil(MAX_IMAGE / 3) * 4) continue;\n\t\tconst image = Buffer.from(data, \"base64\");\n\t\tconst size = jpeg(image);\n\t\tif (!size || image.toString(\"base64\") !== data) {\n\t\t\tthrow new Error(\"The browser returned a malformed JPEG screenshot.\");\n\t\t}\n\t\tif (size.width > MAX_SIDE || size.height > MAX_SIDE) {\n\t\t\tthrow new Error(\n\t\t\t\t`The viewport screenshot is ${size.width}x${size.height} device pixels, above the ${MAX_SIDE}-pixel limit.`,\n\t\t\t);\n\t\t}\n\t\treturn {\n\t\t\timage: { mimeType: \"image/jpeg\", data },\n\t\t\tmetadata: {\n\t\t\t\t...size,\n\t\t\t\tbytes: image.length,\n\t\t\t\tquality,\n\t\t\t\tviewport: {\n\t\t\t\t\tpage_x: viewport.pageX,\n\t\t\t\t\tpage_y: viewport.pageY,\n\t\t\t\t\twidth: viewport.clientWidth,\n\t\t\t\t\theight: viewport.clientHeight,\n\t\t\t\t\tscale: viewport.scale,\n\t\t\t\t\tzoom: viewport.zoom,\n\t\t\t\t},\n\t\t\t\tnote:\n\t\t\t\t\t\"The visible viewport at its scroll position in device pixels, captured after the accessibility read. Viewport metrics are CSS pixels; content outside the viewport is not shown.\",\n\t\t\t},\n\t\t};\n\t}\n\tthrow new Error(\"The viewport screenshot exceeds 900 KB even at JPEG quality 40.\");\n}\n\nasync function inspect(\n\trequest: Extract,\n\tsignal: AbortSignal,\n): Promise {\n\tconst { cdp } = await connect(signal, request.target);\n\ttry {\n\t\tconst { session, info } = await attach(cdp, request.target);\n\t\tconst before = await frame(cdp, session);\n\t\t// From here, failures and the deadline keep whatever evidence was already observed.\n\t\tlet accessibility: Record;\n\t\tlet body = \"\";\n\t\ttry {\n\t\t\tconst { nodes } = await cdp.send(\"Accessibility.getFullAXTree\", {}, { session }) as {\n\t\t\t\tnodes: AXNode[];\n\t\t\t};\n\t\t\tconst rendered = tree(nodes);\n\t\t\tbody = rendered.text;\n\t\t\taccessibility = {\n\t\t\t\tcoverage:\n\t\t\t\t\t\"Main frame document only; iframe documents are not included. Ignored nodes, inline text boxes, and unnamed generic containers are folded into their parents.\",\n\t\t\t\tnodes: rendered.total,\n\t\t\t\tshown: rendered.shown,\n\t\t\t\ttruncated: rendered.shown < rendered.total,\n\t\t\t\tlimit_bytes: MAX_TREE,\n\t\t\t\tfield_limit_bytes: MAX_FIELD,\n\t\t\t};\n\t\t} catch (error) {\n\t\t\taccessibility = { error: message(error) };\n\t\t}\n\t\tlet image: BrowserResult[\"image\"];\n\t\tlet shot: Record | undefined;\n\t\tif (request.screenshot !== false) {\n\t\t\ttry {\n\t\t\t\tconst captured = await capture(cdp, session);\n\t\t\t\timage = captured.image;\n\t\t\t\tshot = captured.metadata;\n\t\t\t} catch (error) {\n\t\t\t\tshot = {\n\t\t\t\t\terror: message(error),\n\t\t\t\t\tnote:\n\t\t\t\t\t\t\"No screenshot was returned; background tabs may not produce frames. Any accessibility evidence is retained; see verification for whether the document changed.\",\n\t\t\t\t};\n\t\t\t}\n\t\t}\n\t\tlet verification: Record;\n\t\ttry {\n\t\t\tconst after = await frame(cdp, session);\n\t\t\tverification = before.loaderId === after.loaderId && before.url === after.url\n\t\t\t\t? { document: \"unchanged\" }\n\t\t\t\t: {\n\t\t\t\t\tdocument: \"changed\",\n\t\t\t\t\tloader_id: after.loaderId,\n\t\t\t\t\turl: field(after.url),\n\t\t\t\t\twarning:\n\t\t\t\t\t\t\"The main document changed during inspection. The accessibility tree and screenshot may describe different documents; inspect again for coherent evidence.\",\n\t\t\t\t};\n\t\t} catch (error) {\n\t\t\tverification = {\n\t\t\t\tdocument: \"unverified\",\n\t\t\t\terror: message(error),\n\t\t\t\twarning:\n\t\t\t\t\t\"Whether the main document changed during inspection is unknown; the evidence may not describe one document.\",\n\t\t\t};\n\t\t}\n\t\tconst header = {\n\t\t\ttarget: request.target,\n\t\t\ttitle: field(info.title),\n\t\t\tdocument: { frame_id: before.id, loader_id: before.loaderId, url: field(before.url) },\n\t\t\taccessibility,\n\t\t\t...(shot ? { screenshot: shot } : {}),\n\t\t\tverification,\n\t\t};\n\t\tconst isError = !body && !image;\n\t\tconst text = `${JSON.stringify(header)}\\n${body}`;\n\t\tconst value: BrowserResult = {\n\t\t\ttext,\n\t\t\t...(image ? { image } : {}),\n\t\t\t...(isError ? { isError } : {}),\n\t\t};\n\t\tif (bytes(JSON.stringify(value)) <= MAX_RESULT) return value;\n\t\tconst omitted = { error: \"The screenshot was omitted to keep the result under 2 MB.\" };\n\t\treturn { text: `${JSON.stringify({ ...header, screenshot: omitted })}\\n${body}` };\n\t} finally {\n\t\tcdp.close();\n\t}\n}\n\nfunction refused(reason: string): BrowserResult {\n\treturn {\n\t\toutcome: \"refused\",\n\t\tisError: true,\n\t\ttext: JSON.stringify({\n\t\t\toutcome: \"refused\",\n\t\t\treason,\n\t\t\tmessage: \"The navigation was not sent to the browser.\",\n\t\t}),\n\t};\n}\n\nfunction validateUrl(url: unknown): string | undefined {\n\tif (typeof url !== \"string\" || url.length > 4096) {\n\t\treturn \"Choose an absolute http or https URL of at most 4096 characters.\";\n\t}\n\tlet parsed: URL;\n\ttry {\n\t\tparsed = new URL(url);\n\t} catch {\n\t\treturn \"Choose an absolute http or https URL.\";\n\t}\n\tif (parsed.protocol !== \"http:\" && parsed.protocol !== \"https:\") {\n\t\treturn \"browser_navigate supports only http and https URLs.\";\n\t}\n}\n\nasync function navigate(request: BrowserNavigate, signal: AbortSignal): Promise {\n\tconst invalid = validateUrl(request.url);\n\tif (invalid) return refused(invalid);\n\tlet sent = false;\n\tlet cdp: Cdp | undefined;\n\ttry {\n\t\t({ cdp } = await connect(signal, request.target));\n\t\tconst { session } = await attach(cdp, request.target);\n\t\tsignal.throwIfAborted();\n\t\tconst reply = await cdp.send(\"Page.navigate\", { url: request.url }, {\n\t\t\tsession,\n\t\t\tsent: () => sent = true,\n\t\t}) as { frameId: string; loaderId?: string; errorText?: string; isDownload?: boolean };\n\t\t// Chrome reports a navigation that became a download with net::ERR_ABORTED.\n\t\tconst status = reply.isDownload\n\t\t\t? \"download\"\n\t\t\t: reply.errorText\n\t\t\t? \"failed\"\n\t\t\t: reply.loaderId\n\t\t\t? \"started\"\n\t\t\t: \"same_document\";\n\t\tconst text = JSON.stringify({\n\t\t\toutcome: \"completed\",\n\t\t\tnavigation: {\n\t\t\t\tstatus,\n\t\t\t\tframe_id: reply.frameId,\n\t\t\t\t...(reply.loaderId ? { loader_id: reply.loaderId } : {}),\n\t\t\t\t...(reply.errorText ? { error_text: field(reply.errorText) } : {}),\n\t\t\t\t...(reply.isDownload ? { is_download: true } : {}),\n\t\t\t},\n\t\t\ttarget: request.target,\n\t\t\turl: field(request.url),\n\t\t\tmessage: status === \"failed\"\n\t\t\t\t? \"Chrome reported a failed navigation. Inspect the tab to see what it shows now.\"\n\t\t\t\t: status === \"download\"\n\t\t\t\t? \"Chrome handled the URL as a download in the dedicated profile; the tab's document was not replaced. Inspect the tab before drawing conclusions.\"\n\t\t\t\t: \"Chrome answered the navigation request. This does not mean the page finished loading or rendered; inspect the tab before drawing conclusions.\",\n\t\t});\n\t\treturn { outcome: \"completed\", text, ...(status === \"failed\" ? { isError: true } : {}) };\n\t} catch (error) {\n\t\tif (error instanceof Refusal) return refused(error.message);\n\t\tif (!sent) {\n\t\t\treturn refused(\n\t\t\t\tsignal.aborted ? \"The navigation was cancelled before dispatch.\" : message(error),\n\t\t\t);\n\t\t}\n\t\t// Even a protocol error reply cannot prove that no navigation began.\n\t\treturn {\n\t\t\toutcome: \"unknown\",\n\t\t\tisError: true,\n\t\t\ttext: JSON.stringify({\n\t\t\t\toutcome: \"unknown\",\n\t\t\t\treason: message(error),\n\t\t\t\tmessage:\n\t\t\t\t\t\"The navigation was sent without a usable answer. It may have happened or may still happen; inspect the tab before navigating again.\",\n\t\t\t}),\n\t\t};\n\t} finally {\n\t\tcdp?.close();\n\t}\n}\n\nexport const browser: Browser = async (request, context) => {\n\tif (!request || ![\"tabs\", \"inspect\", \"navigate\"].includes(request.op)) {\n\t\tthrow new Error(\"Unknown browser request.\");\n\t}\n\tconst deadline = AbortSignal.timeout(DEADLINE);\n\tconst signal = context.abortSignal ? AbortSignal.any([context.abortSignal, deadline]) : deadline;\n\tif (request.op === \"navigate\") return navigate(request, signal);\n\ttry {\n\t\tif (request.op === \"tabs\") return await tabs(signal);\n\t\treturn await inspect(request, signal);\n\t} catch (error) {\n\t\tif (error instanceof Refusal) throw new Error(error.message, { cause: error });\n\t\tthrow error;\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",1794440226951,"sidebar","expanded"]