scripts/verify-server-connection.mjs
Rama main · réplica de lectura del repositorio original.
// Real Settings component + production preload, offline IPC responses only.
// Run: node scripts/verify-server-connection.mjs
import assert from "node:assert/strict";
import { spawn } from "node:child_process";
import { appendFileSync, mkdirSync, mkdtempSync, rmSync, writeFileSync } from "node:fs";
import { createRequire } from "node:module";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { fileURLToPath } from "node:url";
const root = fileURLToPath(new URL("..", import.meta.url));
const fixtureFlag = "--omb-server-connection-fixture";
if (process.versions.electron && process.argv.includes(fixtureFlag)) {
const { app, BrowserWindow, ipcMain, Menu, session } = await import("electron");
const { parseServerInput } = await import("../electron/server-address.mjs");
const { withEnvironment, withActive, withoutEnvironment, workspaceSummary, workspaceMenuTemplate } = createRequire(import.meta.url)("../electron/environments.cjs");
const [url, output, serverUrl] = process.argv.slice(process.argv.indexOf(fixtureFlag) + 1);
app.setPath("userData", join(output, "user-data"));
app.setPath("sessionData", join(output, "user-data"));
app.commandLine.appendSwitch("disable-background-networking");
const calls = [];
let pending;
let saved = { activeId: "local", environments: [{ id: "cloud", name: "My cloud team", origin: "https://bots.fixture.example" }] };
let menuChoice = "workspace-connect";
let forgetConfirmed = false;
let shared = { enabled: false, folders: [], terminal: false, computer: false, connected: false };
let sharingConfirmed = false;
ipcMain.handle("sharing:state", () => shared);
ipcMain.handle("sharing:folder", () => ({ id: "fixture-folder", name: "Invoices", path: "/fixture/Invoices", write: false }));
ipcMain.handle("sharing:save", (_event, id, grant) => {
calls.push({ kind: "sharing", id, ...grant, confirmed: sharingConfirmed });
if (!sharingConfirmed) return null;
shared = { ...grant, enabled: true, connected: true }; return shared;
});
ipcMain.handle("sharing:revoke", () => { shared = { ...shared, enabled: false, connected: false }; return shared; });
ipcMain.handle("update:get-state", () => ({ status: "idle" }));
ipcMain.handle("companion:state", () => ({ running: false, enabled: false, devices: [], bind: null, publicUrl: null }));
ipcMain.handle("desktop:capabilities", () => createRequire(import.meta.url)("../electron/capabilities.cjs").desktopCapabilities({ platform: process.platform }));
const chooseWorkspace = (id) => { calls.push({ kind: "switch", id }); saved = withActive(saved, id); };
ipcMain.handle("environments:state", () => ({ ...saved, localOrigin: new URL(url).origin, remote: false }));
ipcMain.handle("environments:switch", (_event, id) => chooseWorkspace(id));
ipcMain.handle("environments:forget", (_event, id) => {
calls.push({ kind: "forget", id, confirmed: forgetConfirmed });
if (forgetConfirmed) saved = withoutEnvironment(saved, id);
});
ipcMain.handle("workspaces:state", () => workspaceSummary(saved));
ipcMain.handle("workspaces:menu", (event) => {
const menu = Menu.buildFromTemplate(workspaceMenuTemplate(saved, {
onSwitch: chooseWorkspace,
onConnect: () => event.sender.send("workspaces:open-settings"),
onForget: () => {},
}));
// Select the production native MenuItem; no fixture-only renderer dropdown.
menu.getMenuItemById(menuChoice).click();
});
ipcMain.handle("desktop-remote:state", () => ({ active: false }));
ipcMain.handle("desktop-remote:pair", (_event, endpoint, code) => {
calls.push({ kind: "companion", endpoint, code });
throw new Error("Fixture companion pairing rejected");
});
ipcMain.handle("environments:add-from-link", (_event, link, name) => {
const read = parseServerInput(link);
if (!read.ok) throw new Error("Enter the server's address or its pairing link.");
const parsed = { origin: read.candidates[0] };
calls.push({ kind: "server", link, ...(name === undefined ? {} : { name }) });
return new Promise((resolve, reject) => { pending = { reject, resolve: (confirmed) => {
if (confirmed) saved = withEnvironment(saved, { origin: parsed.origin, name }, () => "new-cloud");
resolve(confirmed);
} }; });
});
app.whenReady().then(async () => {
const blockedRequests = [];
session.defaultSession.webRequest.onBeforeRequest((request, callback) => {
const target = new URL(request.url);
const allowed = target.host === new URL(url).host || target.origin === serverUrl;
if (!allowed) blockedRequests.push(target.origin);
callback({ cancel: !allowed });
});
const open = async (local) => {
const win = new BrowserWindow({
show: false, width: 720, height: 650,
webPreferences: {
preload: join(root, "electron/preload.cjs"), contextIsolation: true,
sandbox: true, nodeIntegration: false,
additionalArguments: [`--omb-local-origin=${local ? new URL(url).origin : "https://remote-fixture.invalid"}`],
},
});
win.webContents.on("console-message", (event) => { if (event.level === "error") console.error(event.message, event.sourceId, event.lineNumber); });
await win.loadURL(url);
return win;
};
const win = await open(true);
const evaluate = (code) => win.webContents.executeJavaScript(code);
const until = async (check, description) => {
for (let attempt = 0; attempt < 300; attempt++) {
if (await check()) return;
await new Promise((resolve) => setTimeout(resolve, 30));
}
writeFileSync(join(output, "failure.png"), (await win.webContents.capturePage()).toPNG());
console.error(await evaluate("document.body.innerText"));
throw new Error(`Timed out: ${description}`);
};
const button = (label) => `[...document.querySelectorAll('button')].find(el => el.textContent.trim() === ${JSON.stringify(label)})`;
const input = (label) => `[...document.querySelectorAll('label')].find(el => el.textContent.trim() === ${JSON.stringify(label)})?.querySelector('input')`;
const fill = async (label, value) => {
await evaluate(`(() => { const el = ${input(label)}; if (!el) throw new Error('Missing input'); Object.getOwnPropertyDescriptor(HTMLInputElement.prototype, 'value').set.call(el, ${JSON.stringify(value)}); el.dispatchEvent(new Event('input', { bubbles: true })); })()`);
};
const selectMode = (value) => evaluate(`(() => { const el = document.querySelector('select'); el.value = ${JSON.stringify(value)}; el.dispatchEvent(new Event('change', { bubbles: true })); })()`);
const connect = button("Connect to server");
await until(() => evaluate(`Boolean(${connect})`), "server form rendered");
assert.equal(await evaluate(`${connect}.disabled`), true);
const link = "https://bots.fixture.example/pair#code=ABCD-EFGH-JKLM";
await fill("Server pairing link", link);
await until(() => evaluate(`!${connect}.disabled`), "server form enabled");
await evaluate(`(() => { const form = ${connect}.form; form.requestSubmit(); form.requestSubmit(); })()`);
await until(() => calls.length === 1, "server IPC received");
assert.deepEqual(calls, [{ kind: "server", link }]);
assert.equal(await evaluate(`${connect}.disabled`), true);
await evaluate(`${connect}.click()`);
assert.equal(calls.length, 1, "pending submission is disabled");
pending.resolve(); // Production native dialog cancellation resolves void.
await until(() => evaluate(`!${connect}.disabled`), "cancelled confirmation reset");
assert.equal(await evaluate(`${input("Server pairing link")}.value`), link);
await evaluate(`${connect}.click()`);
await until(() => calls.length === 2, "second server IPC received");
pending.reject(new Error("Fixture pairing link rejected"));
await until(() => evaluate(`document.querySelector('[role=alert]')?.textContent === 'Fixture pairing link rejected'`), "readable IPC error");
assert.equal(await evaluate(`${connect}.disabled`), false);
await evaluate(`${connect}.click()`);
await until(() => calls.length === 3, "server retry received");
pending.resolve();
await until(() => evaluate(`!${connect}.disabled && !document.querySelector('[role=alert]')`), "successful response reset");
writeFileSync(join(output, "server-form.png"), (await win.webContents.capturePage()).toPNG());
await selectMode("companion");
await until(() => evaluate(`Boolean(${input("Companion address")})`), "companion form rendered");
await fill("Companion address", "computer.tailnet.ts.net");
await fill("Six-digit companion code", "12a34567");
await until(() => evaluate(`${input("Six-digit companion code")}.value === '123456'`), "six-digit companion normalization");
await evaluate(`${button("Pair and switch to client mode")}.click()`);
await until(() => calls.length === 4, "companion IPC received");
assert.deepEqual(calls[3], { kind: "companion", endpoint: "computer.tailnet.ts.net", code: "123456" });
await until(() => evaluate(`document.querySelector('[role=alert]')?.textContent === 'Fixture companion pairing rejected'`), "companion error rendered");
win.setSize(390, 700);
await selectMode("server");
await until(() => evaluate(`Boolean(${connect})`), "server mode restored");
assert.equal(await evaluate("document.documentElement.scrollWidth <= innerWidth"), true, "narrow layout overflow");
writeFileSync(join(output, "server-form-narrow.png"), (await win.webContents.capturePage()).toPNG());
win.setSize(780, 800);
await win.loadURL(`${url}?workspaces=1`);
const hostedConnect = button("Connect");
const addressLabel = "Server address or pairing link";
await until(() => evaluate(`Boolean(${hostedConnect}) && document.body.textContent.includes('My cloud team')`), "hosted workspace settings rendered");
await evaluate("void window.ogb.environments.onOpenSettings(() => { document.body.dataset.settingsRequested = 'yes'; })");
await evaluate("document.querySelector('[aria-label=\"Switch server: This computer\"]').click()");
await until(() => evaluate("document.body.dataset.settingsRequested === 'yes'"), "native connect item requested Settings");
assert.equal(saved.activeId, "local", "opening connection settings did not select a server");
await fill(addressLabel, "http://unsafe.fixture.example");
await evaluate(`${hostedConnect}.click()`);
await until(() => evaluate("document.querySelector('[role=alert]')?.textContent === 'Enter the server\\'s address or its pairing link.'"), "invalid workspace input rejected visibly");
await fill(addressLabel, "other.fixture.example");
await fill("Name (optional)", "Research team");
const beforeHosted = calls.length;
await evaluate(`(() => { ${hostedConnect}.form.requestSubmit(); ${hostedConnect}.form.requestSubmit(); })()`);
await until(() => calls.length === beforeHosted + 1, "one hosted submission in flight");
assert.deepEqual(calls.at(-1), { kind: "server", link: "other.fixture.example", name: "Research team" });
pending.resolve(false);
await until(() => evaluate(`!${hostedConnect}.disabled`), "cancelled hosted confirmation reset");
assert.equal(saved.environments.length, 1);
assert.equal(await evaluate(`${input(addressLabel)}.value`), "other.fixture.example");
await fill(addressLabel, "https://other.fixture.example/pair#code=MNOP-QRST-UVWX");
await evaluate(`${hostedConnect}.click()`);
await until(() => calls.length === beforeHosted + 2, "hosted retry received");
pending.resolve(true);
await until(() => saved.environments.length === 2, "named workspace saved");
// Production navigates away after confirmation. Reload our local preview
// instead, to inspect the saved list without contacting a public server.
await win.loadURL(`${url}?workspaces=1`);
await until(() => evaluate("document.body.textContent.includes('Research team') && !document.querySelector('input').disabled"), "saved named workspace rendered");
assert.deepEqual(saved.environments.map(({ origin }) => origin), ["https://bots.fixture.example", "https://other.fixture.example"]);
assert.equal(JSON.stringify(saved).includes("MNOP"), false, "pairing secret not saved with workspace");
await fill(addressLabel, "");
await fill("Name (optional)", "");
writeFileSync(join(output, "connected-workspaces.png"), (await win.webContents.capturePage()).toPNG());
assert.equal(await evaluate("document.querySelector('[aria-label^=\"Computer access for \"]') === null"), true, "feature-off workspace offers no computer access");
await win.loadURL(`${url}?workspaces=1&share-computer=cloud`);
await until(() => evaluate("document.body.textContent.includes('My cloud team')"), "feature-off saved workspace rendered");
assert.equal(await evaluate("document.body.textContent.includes('Computer access · My cloud team')"), false, "stale sharing deep link cannot bypass disabled feature");
assert.equal(await evaluate(`${button("Choose folder")} === undefined`), true);
writeFileSync(join(output, "computer-sharing-disabled.png"), (await win.webContents.capturePage()).toPNG());
// Explicitly opt this disposable server in for the unfinished feature's
// existing enabled-path regression coverage. Shipped defaults stay off.
const enabled = await session.defaultSession.fetch(`${serverUrl}/api/config`, { method: "PATCH", headers: { "content-type": "application/json", origin: serverUrl }, body: JSON.stringify({ features: { sharedComputers: true } }) });
assert.equal(enabled.status, 200);
await win.loadURL(`${url}?workspaces=1`);
await until(() => evaluate("Boolean(document.querySelector('[aria-label=\"Computer access for My cloud team\"]'))"), "explicit fixture opt-in exposes computer access");
await evaluate("document.querySelector('[aria-label=\"Computer access for My cloud team\"]').click()");
await until(() => evaluate("document.body.textContent.includes('Not shared')"), "computer sharing defaults off");
assert.equal(await evaluate("[...document.querySelectorAll('input[type=checkbox]')].every(el => !el.checked)"), true);
await evaluate(`${button("Choose folder")}.click()`);
await until(() => evaluate("document.body.textContent.includes('/fixture/Invoices')"), "native folder picker populates read-only draft");
await evaluate(`${button("Share selected access")}.click()`);
await until(() => calls.at(-1)?.kind === "sharing", "native consent requested");
assert.equal(shared.enabled, false, "cancel native consent grants nothing");
assert.equal(calls.at(-1).folders[0].write, false);
assert.equal(calls.at(-1).terminal, false); assert.equal(calls.at(-1).computer, false);
sharingConfirmed = true;
await until(() => evaluate(`!${button("Share selected access")}.disabled`), "cancel sharing reset");
await evaluate(`${button("Share selected access")}.click()`);
await until(() => evaluate("document.body.textContent.includes('Sharing while this desktop is open')"), "saved sharing status rendered");
writeFileSync(join(output, "computer-access.png"), (await win.webContents.capturePage()).toPNG());
await evaluate(`${button("Stop sharing")}.click()`);
await until(() => evaluate("document.body.textContent.includes('Not shared')"), "stop sharing applies immediately");
await evaluate("document.querySelector('[aria-label=\"Close computer access\"]').click()");
await evaluate("document.querySelector('[aria-label=\"Switch to My cloud team\"]').click()");
await until(() => saved.activeId === "cloud", "Settings switch selected saved workspace");
menuChoice = "workspace-local";
await evaluate("document.querySelector('[aria-label^=\"Switch server:\"]').click()");
await until(() => saved.activeId === "local", "native menu switched back to local");
await evaluate("document.querySelector('[aria-label=\"Forget Research team\"]').click()");
await until(() => calls.at(-1)?.kind === "forget", "forget requested");
assert.equal(saved.environments.length, 2, "cancel forget retains saved workspace");
await until(() => evaluate("!document.querySelector('[aria-label=\"Forget Research team\"]').disabled"), "forget cancellation reset");
forgetConfirmed = true;
await evaluate("document.querySelector('[aria-label=\"Forget Research team\"]').click()");
await until(() => evaluate("!document.body.textContent.includes('Research team')"), "confirmed forget removed only selected entry");
assert.deepEqual(saved.environments.map(({ id }) => id), ["cloud"]);
assert.equal(saved.activeId, "local");
win.setSize(390, 800);
await until(() => evaluate("innerWidth === 390"), "narrow workspace viewport");
assert.equal(await evaluate("document.documentElement.scrollWidth <= innerWidth"), true, "workspace narrow layout overflow");
writeFileSync(join(output, "connected-workspaces-narrow.png"), (await win.webContents.capturePage()).toPNG());
// Real app shell, Settings navigation and onboarding against a disposable
// fake-engine server. Opening the page must not require local AI setup.
win.setSize(1180, 850);
await win.loadURL(`${url}?app=1&desktop-settings=workspaces&share-computer=cloud`);
await until(() => evaluate("document.querySelector('[role=dialog]')?.textContent.includes('Connect to a server')"), "app opens top-level workspace Settings");
assert.equal(await evaluate("location.search.includes('desktop-settings')"), false, "Settings deep link consumed");
await until(() => evaluate("document.body.textContent.includes('My cloud team')"), "app Settings loaded connections");
await until(() => evaluate("document.body.textContent.includes('Computer access · My cloud team')"), "post-pair target opens its access controls");
assert.equal(await evaluate("location.search.includes('share-computer')"), false);
await evaluate("document.querySelector('[aria-label=\"Close computer access\"]').click()");
assert.equal(await evaluate("document.querySelector('[aria-label=\"Server address or pairing link\"]') !== null || [...document.querySelectorAll('label')].some(el => el.textContent.includes('Server address or pairing link'))"), true);
writeFileSync(join(output, "workspace-settings-in-app.png"), (await win.webContents.capturePage()).toPNG());
await evaluate("window.dispatchEvent(new KeyboardEvent('keydown', { key: 'Escape', bubbles: true }))");
await until(() => evaluate("!document.body.textContent.includes('Connect to a server')"), "Settings closes normally");
win.webContents.send("workspaces:open-settings");
await until(() => evaluate("document.querySelector('[role=dialog]')?.textContent.includes('Connect to a server')"), "native request reopens workspace Settings");
await evaluate("(() => { const el = document.querySelector('input[aria-label=\"Search settings\"]'); Object.getOwnPropertyDescriptor(HTMLInputElement.prototype, 'value').set.call(el, 'appearance'); el.dispatchEvent(new Event('input', { bubbles: true })); })()");
await until(() => evaluate("!document.body.textContent.includes('Connect to a server')"), "Settings search changes section");
win.webContents.send("workspaces:open-settings");
await until(() => evaluate("document.body.textContent.includes('Connect to a server') && document.querySelector('input[aria-label=\"Search settings\"]').value === ''"), "native connection request clears Settings search");
const remote = await open(false);
assert.deepEqual(await remote.webContents.executeJavaScript("({ server: typeof window.ogb?.environments, companion: typeof window.ogb?.remoteClient, sharing: typeof window.ogb?.computerSharing, node: typeof window.require, workspaceMethods: Object.keys(window.ogb?.workspaces ?? {}) })"),
{ server: "undefined", companion: "undefined", sharing: "undefined", node: "undefined", workspaceMethods: ["state", "menu"] });
assert.deepEqual(blockedRequests, [], "unexpected external request attempted");
// Exercise Chromium's actual HttpOnly cookie jar and main-process fetch.
// The server is the isolated fake-engine fixture, never the user's app.
const opened = await fetch(`${serverUrl}/api/auth/pairing`, { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ label: "Electron fixture", scopes: ["client"] }) }).then(response => response.json());
const paired = await session.defaultSession.fetch(`${serverUrl}/api/auth/pair`, { method: "POST", credentials: "include", headers: { "content-type": "application/json", origin: serverUrl }, body: JSON.stringify({ code: opened.code, cookie: true }) });
assert.equal(paired.status, 200);
const { createComputerSharing } = await import("../electron/computer-sharing.mjs");
const { randomUUID } = await import("node:crypto");
const nativeEnv = { id: "cookie-fixture", name: "Cookie fixture", origin: serverUrl };
const sharing = createComputerSharing({ file: join(output, "native-profile", "sharing.json"), fetch: (...args) => session.defaultSession.fetch(...args), environments: () => [nativeEnv], enabled: async () => true, cuaConnection: async () => null });
try {
const identity = await sharing.observe(nativeEnv);
assert.ok(identity?.sessionId, "main fetch sees real paired session cookie");
const folder = join(output, "shared-folder"); mkdirSync(folder);
await sharing.save(nativeEnv, { folders: [{ id: randomUUID(), path: folder, write: false }], terminal: false, computer: false }, identity);
await until(() => sharing.state(nativeEnv.id).connected === true, "native connector registered using paired cookie");
sharing.revoke(nativeEnv);
assert.equal(sharing.state(nativeEnv.id).enabled, false);
} finally { sharing.close(); }
const receipt = { passed: true, renderer: ["RemoteComputerSection", "ConnectedWorkspacesSettings", "DesktopWorkspaceSwitcher"], preload: "electron/preload.cjs", calls,
checks: ["full custom HTTPS link unchanged", "pending submit disabled", "cancel reset", "rejection and retry", "companion six-digit routing", "390px overflow", "remote-safe bridge", "native connect menu item requests Settings", "hosted URL validation", "optional name", "pairing code excluded from saved list", "switch local/cloud", "cancel/confirm forget", "real app Settings deep link", "native Settings event and search reset", "feature-off hides sharing controls and stale deep link", "explicit opt-in enables fixture sharing", "sharing off by default", "read-only folder selection", "cancel/save sharing", "immediate revoke", "post-pair access deep link", "no sharing bridge in remote renderer"],
nativeConnector: "Real HttpOnly pairing cookie → session.defaultSession.fetch → real fixture registration → revoke",
limitation: "UI IPC replaces native dialogs, workspace persistence and navigation. Native sharing authentication tested against isolated HTTP server; no public DNS/TLS or live screen control tested." };
writeFileSync(join(output, "receipt.json"), `${JSON.stringify(receipt, null, 2)}\n`);
console.log(JSON.stringify(receipt));
app.exit(0);
}).catch((error) => {
console.error(error);
app.exit(1);
});
} else {
const { createServer } = await import("vite");
const { default: react } = await import("@vitejs/plugin-react");
const { default: tailwindcss } = await import("@tailwindcss/vite");
const { launchVerificationServer } = await import("./control-omb.ts");
const fixture = await launchVerificationServer();
const output = mkdtempSync(join(tmpdir(), "omb-server-connection-"));
for (const dir of ["home", "user-data"]) mkdirSync(join(output, dir));
const ui = await createServer({
configFile: false, root, resolve: { alias: { "@": join(root, "src") } },
server: { host: "127.0.0.1", port: 0, proxy: { "/api": { target: fixture.info.url } } },
plugins: [react(), tailwindcss(), {
name: "server-connection-fixture",
resolveId(id) { if (id === "virtual:server-connection") return `\0${id}`; },
load(id) {
if (id === "\0virtual:server-connection") return `import React from 'react'; import { createRoot } from 'react-dom/client'; import { setLocale } from '/src/lib/i18n.ts'; import { StoreProvider } from '/src/state/store.tsx'; import { RemoteComputerSection } from '/src/components/RemoteComputerSection.tsx'; import { ConnectedWorkspacesSettings } from '/src/components/ConnectedWorkspacesSettings.tsx'; import { DesktopWorkspaceSwitcher } from '/src/components/DesktopWorkspaceSwitcher.tsx'; import '/src/styles.css'; setLocale('en'); localStorage.setItem('omb-analytics-opt-out', '1'); const root = createRoot(document.getElementById('root')); if (location.search.includes('app=1')) { document.body.classList.remove('p-4'); import('/src/App.tsx').then(({default: App}) => root.render(React.createElement(App))); } else root.render(React.createElement(StoreProvider, null, location.search.includes('workspaces=1') ? React.createElement('div', { className: 'flex flex-col gap-5 max-w-2xl mx-auto' }, React.createElement(DesktopWorkspaceSwitcher), React.createElement('h1', { className: 'text-lg font-semibold text-ink' }, 'Servers'), React.createElement(ConnectedWorkspacesSettings)) : React.createElement(RemoteComputerSection)));`;
},
configureServer(server) {
server.middlewares.use((req, res, next) => {
if (req.url?.split("?")[0] !== "/__server-connection.html") return next();
void server.transformIndexHtml(req.url, '<html><head><meta name="viewport" content="width=device-width, initial-scale=1"><title>Isolated server connection verification</title></head><body class="bg-app p-4"><div id="root"></div><script type="module" src="/@id/virtual:server-connection"></script></body></html>')
.then((html) => { res.setHeader("content-type", "text/html"); res.end(html); }).catch(next);
});
},
}],
});
try {
await ui.listen();
const url = `${ui.resolvedUrls.local[0]}__server-connection.html`;
console.log(JSON.stringify({ previewUrl: url, evidence: output }));
const electron = createRequire(import.meta.url)("electron");
const child = spawn(electron, [fileURLToPath(import.meta.url), fixtureFlag, url, output, fixture.info.url], {
env: { PATH: process.env.PATH, HOME: join(output, "home"), XDG_CONFIG_HOME: join(output, "home"),
TMPDIR: output, TEMP: output, TMP: output, DISPLAY: process.env.DISPLAY, SystemRoot: process.env.SystemRoot },
stdio: ["ignore", "pipe", "pipe"],
});
for (const stream of [child.stdout, child.stderr]) stream.on("data", (data) => {
appendFileSync(join(output, "electron.log"), data);
process.stdout.write(data);
});
const stop = () => child.kill("SIGTERM");
process.once("SIGINT", stop);
process.once("SIGTERM", stop);
const timeout = setTimeout(stop, 60_000);
const code = await new Promise((resolve, reject) => { child.once("error", reject); child.once("close", resolve); })
.finally(() => { clearTimeout(timeout); process.off("SIGINT", stop); process.off("SIGTERM", stop); });
assert.equal(code, 0, `Electron smoke failed; inspect ${join(output, "electron.log")}`);
} finally {
await ui.close();
await fixture.close();
for (const dir of ["home", "user-data", "native-profile", "shared-folder"]) rmSync(join(output, dir), { recursive: true, force: true });
}
}