scripts/verify-engines-ui.ts
Rama main · réplica de lectura del repositorio original.
// Real engine screens with synthetic statuses and a disposable app server.
// No install/auth request can reach a provider or the user's configuration.
import { fileURLToPath } from "node:url";
import { createServer as createHttpServer, type IncomingMessage } from "node:http";
import { createServer } from "vite";
import type { InstanceInfo } from "../src/state/store.tsx";
import { launchVerificationServer } from "./control-omb.ts";
import { providerIconError, type ProviderIcon } from "../shared/provider-icon.ts";
async function requestJson(req: IncomingMessage): Promise<unknown> {
const chunks: Buffer[] = [];
let bytes = 0;
for await (const chunk of req) {
const value = Buffer.from(chunk);
bytes += value.length;
if (bytes > 192 * 1024) throw new Error("Preview request is too large.");
chunks.push(value);
}
return JSON.parse(Buffer.concat(chunks).toString("utf8"));
}
const instances: InstanceInfo[] = [
["claude", "claudeAgent", "Claude", true, "2.1.8"],
["codex", "codex", "Codex", true, "0.122.0"],
["grok", "grokAgent", "Grok", true, "grok"],
["opencode", "opencodeGo", "OpenCode", true, "1.18.25"],
["antigravity", "antigravityAgent", "Antigravity", false, "0.1.0"],
["kimi", "kimiAgent", "Kimi", false, ""],
["droid", "droidAgent", "Droid", false, ""],
["cursor", "cursorAgent", "Cursor", false, ""],
["hermes", "hermesAgent", "Hermes", false, ""],
["qwen", "qwenAgent", "Qwen", false, ""],
["pi", "piAgent", "Pi", false, ""],
["deepseek", "deepseekAgent", "DeepSeek Harness", false, ""],
["githubCopilot", "copilotAgent", "GitHub Copilot", true, "1.0.103"],
["commandCode", "commandCodeAgent", "Command Code", true, "1.88.4"],
["kiro", "kiroAgent", "Kiro", true, "3.1.0"],
].map(([id, driver, name, ready, version]) => ({
instanceId: String(id), driverKind: String(driver), displayName: String(name),
cliDefault: String(id),
snapshot: { state: ready || version ? "available" : "unavailable", authenticated: Boolean(ready), version: String(version), ...(!ready && !version ? { reason: "Not installed in this isolated preview." } : {}) },
models: { default: "fixture", options: [] },
install: { command: { darwin: "echo 'Isolated preview — no installation'", linux: "echo 'Isolated preview — no installation'", win32: "echo Isolated preview — no installation" } },
}));
instances[0].snapshot.account = { email: "personal@example.test" };
instances[0].claudeAccount = { configDir: "", isDefault: true, signInCommand: "echo 'Preview only'", signInShell: "sh" };
instances[1].authentication = { method: "device-code", signOut: true };
instances[1].snapshot.account = { email: "work@example.test" };
instances[4].install = { managed: { label: "Install Antigravity", downloadBytes: 200_000_000 } };
instances[5].install!.server = { package: "kimi-fixture" };
instances[3].install!.server = { package: "opencode-fixture" };
instances[3].snapshot.update = { title: "OpenCode update available", message: "A sample update for this isolated preview.", command: "echo 'Preview only'" };
instances.push({ ...instances[0], instanceId: "claude-local", displayName: "Claude · Local", access: "custom", claudeAccount: undefined, snapshot: { state: "available", authenticated: false } });
const chatgptPlan: InstanceInfo = {
instanceId: "chatgpt", driverKind: "codex", displayName: "ChatGPT plan", cliDefault: "codex", access: "subscription",
snapshot: { state: "available", authenticated: false, chatgptPlan: true },
models: { default: "", options: [] }, authentication: { method: "browser-pkce", signOut: true },
install: { docsUrl: "https://developers.openai.com/siwc/token-sharing-open-source" },
};
instances.push(chatgptPlan);
instances.push({
instanceId: "cline", driverKind: "clineAgent", displayName: "Cline", cliDefault: "cline",
snapshot: { state: "available", authenticated: true, version: "3.0.70" },
models: { default: "cline-default", options: [{ id: "cline-default", label: "Cline default (configured)" }] },
install: { command: { darwin: "echo 'Preview only'", linux: "echo 'Preview only'", win32: "echo Preview only" },
needsNode: true, signInCommand: "echo 'Preview only'", docsUrl: "https://docs.cline.bot/usage/acp" },
});
const controller = new AbortController();
const cancel = () => controller.abort();
process.once("SIGINT", cancel);
process.once("SIGTERM", cancel);
let fixture: Awaited<ReturnType<typeof launchVerificationServer>> | undefined;
let ui: Awaited<ReturnType<typeof createServer>> | undefined;
const httpServer = createHttpServer();
try {
fixture = await launchVerificationServer(process.env, controller.signal);
controller.signal.throwIfAborted();
ui = await createServer({
root: fileURLToPath(new URL("..", import.meta.url)),
cacheDir: fileURLToPath(new URL("../.omb-scratch/engine-preview-vite", import.meta.url)),
// Own the HTTP listener so Vite never installs a process-exit handler.
server: { middlewareMode: { server: httpServer }, hmr: { server: httpServer }, proxy: { "/api": { target: fixture.info.url } } },
plugins: [{ name: "isolated-engines", configureServer(server) {
server.middlewares.use((req, res, next) => {
const path = req.url?.split("?")[0];
const json = (value: unknown, status = 200) => { res.statusCode = status; res.setHeader("content-type", "application/json"); res.end(JSON.stringify(value)); };
if (path === "/api/instances" && req.method === "GET") return json({ instances });
const iconPatch = /^\/api\/instances\/([\w.-]+)\/icon$/.exec(path ?? "");
if (iconPatch && req.method === "PATCH") {
void requestJson(req).then((value) => {
const icon = (value as { icon?: unknown } | null)?.icon;
const validShape = icon === null || (typeof icon === "object" && icon !== null &&
((icon as ProviderIcon).kind === "preset" || (icon as ProviderIcon).kind === "custom"));
if (!validShape) return json({ error: "Invalid provider icon." }, 400);
if (icon) {
const error = providerIconError(icon as ProviderIcon);
if (error) return json({ error }, 400);
}
const instance = instances.find((candidate) => candidate.instanceId === iconPatch[1]);
if (!instance) return json({ error: "Unknown preview instance." }, 404);
if (icon) instance.icon = icon as ProviderIcon;
else delete instance.icon;
return json({ instances });
}).catch((error) => json({ error: error instanceof Error ? error.message : String(error) }, 400));
return;
}
if (path === "/__fixture/connect" && req.method === "POST") {
instances[4].snapshot.authenticated = !instances[4].snapshot.authenticated;
instances[4].snapshot.account = instances[4].snapshot.authenticated ? { email: "google@example.test", method: "login" } : undefined;
return json({ ok: true });
}
if (path === "/__fixture/chatgpt" && req.method === "POST") {
const connected = !chatgptPlan.snapshot.authenticated;
chatgptPlan.snapshot.authenticated = connected;
chatgptPlan.snapshot.account = connected ? { email: "preview@example.test", method: "login" } : undefined;
chatgptPlan.models = connected ? { default: "gpt-6.1-sol", options: [{ id: "gpt-6.1-sol", label: "GPT-6.1 Sol" }] } : { default: "", options: [] };
return json({ ok: true });
}
if (path === "/api/cli-candidates") return json({ candidates: ["/preview/bin/claude"] });
if (path?.startsWith("/api/instances/") || path === "/api/cli-test") {
return json({ error: "Preview only: no real account or installation is changed." }, 400);
}
if (path !== "/__engines.html") return next();
void server.transformIndexHtml(req.url!, '<html><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1"><title>OpenMaus · Engine preview</title></head><body><div id="root"></div><script type="module" src="/scripts/testing/engines-preview.tsx"></script></body></html>')
.then((html) => { res.setHeader("content-type", "text/html"); res.end(html); }).catch(next);
});
} }],
});
controller.signal.throwIfAborted();
httpServer.on("request", ui.middlewares);
await new Promise<void>((resolve, reject) => {
httpServer.once("error", reject);
httpServer.listen(0, "127.0.0.1", () => {
httpServer.removeListener("error", reject);
resolve();
});
});
const address = httpServer.address();
if (!address || typeof address === "string") throw new Error("Preview server has no TCP address");
console.log(JSON.stringify({ ...fixture.info, previewUrl: `http://127.0.0.1:${address.port}/__engines.html` }));
await new Promise<void>((resolve) => {
if (controller.signal.aborted) return resolve();
controller.signal.addEventListener("abort", () => resolve(), { once: true });
});
} finally {
const httpClosed = new Promise<void>((resolve) => {
// Closing an unstarted listener is harmless; active preview requests
// must not hold shutdown open. Vite closes its own upgraded HMR sockets.
httpServer.close(() => resolve());
httpServer.closeAllConnections();
});
try {
// Stop the app before waiting on Vite: unfinished import transforms can
// delay Vite shutdown, but its cache no longer lives in fixture data.
await fixture?.close();
} finally {
try {
await ui?.close();
} finally {
try {
await httpClosed;
} finally {
process.removeListener("SIGINT", cancel);
process.removeListener("SIGTERM", cancel);
}
}
}
}