105 lines
3.1 KiB
TypeScript
105 lines
3.1 KiB
TypeScript
import type { Server } from "node:http";
|
|
import express from "express";
|
|
|
|
import { loadConfig } from "../config/config.js";
|
|
import { createSubsystemLogger } from "../logging.js";
|
|
import { resolveBrowserConfig, resolveProfile, shouldStartLocalBrowserServer } from "./config.js";
|
|
import { ensureChromeExtensionRelayServer } from "./extension-relay.js";
|
|
import { registerBrowserRoutes } from "./routes/index.js";
|
|
import { type BrowserServerState, createBrowserRouteContext } from "./server-context.js";
|
|
|
|
let state: BrowserServerState | null = null;
|
|
const log = createSubsystemLogger("browser");
|
|
const logServer = log.child("server");
|
|
|
|
export async function startBrowserControlServerFromConfig(): Promise<BrowserServerState | null> {
|
|
if (state) return state;
|
|
|
|
const cfg = loadConfig();
|
|
const resolved = resolveBrowserConfig(cfg.browser);
|
|
if (!resolved.enabled) return null;
|
|
|
|
if (!shouldStartLocalBrowserServer(resolved)) {
|
|
logServer.info(
|
|
`browser control URL is non-loopback (${resolved.controlUrl}); skipping local server start`,
|
|
);
|
|
return null;
|
|
}
|
|
|
|
const app = express();
|
|
app.use(express.json({ limit: "1mb" }));
|
|
|
|
const ctx = createBrowserRouteContext({
|
|
getState: () => state,
|
|
});
|
|
registerBrowserRoutes(app, ctx);
|
|
|
|
const port = resolved.controlPort;
|
|
const server = await new Promise<Server>((resolve, reject) => {
|
|
const s = app.listen(port, "127.0.0.1", () => resolve(s));
|
|
s.once("error", reject);
|
|
}).catch((err) => {
|
|
logServer.error(`clawd browser server failed to bind 127.0.0.1:${port}: ${String(err)}`);
|
|
return null;
|
|
});
|
|
|
|
if (!server) return null;
|
|
|
|
state = {
|
|
server,
|
|
port,
|
|
resolved,
|
|
profiles: new Map(),
|
|
};
|
|
|
|
// If any profile uses the Chrome extension relay, start the local relay server eagerly
|
|
// so the extension can connect before the first browser action.
|
|
for (const name of Object.keys(resolved.profiles)) {
|
|
const profile = resolveProfile(resolved, name);
|
|
if (!profile || profile.driver !== "extension") continue;
|
|
await ensureChromeExtensionRelayServer({ cdpUrl: profile.cdpUrl }).catch((err) => {
|
|
logServer.warn(`Chrome extension relay init failed for profile "${name}": ${String(err)}`);
|
|
});
|
|
}
|
|
|
|
logServer.info(`Browser control listening on http://127.0.0.1:${port}/`);
|
|
return state;
|
|
}
|
|
|
|
export async function stopBrowserControlServer(): Promise<void> {
|
|
const current = state;
|
|
if (!current) return;
|
|
|
|
const ctx = createBrowserRouteContext({
|
|
getState: () => state,
|
|
});
|
|
|
|
try {
|
|
const current = state;
|
|
if (current) {
|
|
for (const name of Object.keys(current.resolved.profiles)) {
|
|
try {
|
|
await ctx.forProfile(name).stopRunningBrowser();
|
|
} catch {
|
|
// ignore
|
|
}
|
|
}
|
|
}
|
|
} catch (err) {
|
|
logServer.warn(`clawd browser stop failed: ${String(err)}`);
|
|
}
|
|
|
|
await new Promise<void>((resolve) => {
|
|
current.server.close(() => resolve());
|
|
});
|
|
state = null;
|
|
|
|
// Optional: Playwright is not always available (e.g. embedded gateway builds).
|
|
try {
|
|
const mod = await import("./pw-ai.js");
|
|
await mod.closePlaywrightBrowserConnection();
|
|
} catch {
|
|
// ignore
|
|
}
|
|
}
|