Persistent Terminal MCP Server

import { WebUIServer } from "./web-ui-server.js"; import { WebUIStartOptions, WebUIStartResult } from "./types.js"; import { exec } from "child_process"; import { createServer } from "net"; /** * Web UI 管理器 * 负责管理 Web 服务器的生命周期、端口分配和浏览器打开 */ export class WebUIManager { private server: WebUIServer | null = null; private currentPort: number | null = null; /** * 启动 Web UI */ async start(options: WebUIStartOptions): Promise<WebUIStartResult> { // 如果已经启动，返回现有信息 if (this.server && this.currentPort) { const host = options.host || process.env.WEB_UI_HOST || "localhost"; const displayHost = host === "0.0.0.0" ? "localhost" : host; return { url: `http://${displayHost}:${this.currentPort}`, port: this.currentPort, mode: "existing", autoOpened: false, }; } // 查找可用端口 const port = await this.findAvailablePort( Number(process.env.WEB_UI_PORT || options.port || 3002) ); const host = options.host || process.env.WEB_UI_HOST || "localhost"; // 启动 Web 服务器 this.server = new WebUIServer(options.terminalManager); await this.server.start(port, host); this.currentPort = port; const displayHost = host === "0.0.0.0" ? "localhost" : host; const url = `http://${displayHost}:${port}`; // 自动打开浏览器 let autoOpened = false; if (options.autoOpen !== false) { try { await this.openBrowser(url); autoOpened = true; } catch (error) { // 打开失败不影响功能，只记录日志 if (process.env.MCP_DEBUG === "true") { process.stderr.write( `[MCP-DEBUG] Failed to open browser: ${error}\n` ); } } } return { url, port, mode: "new", autoOpened, }; } /** * 停止 Web UI */ async stop(): Promise<void> { if (this.server) { await this.server.stop(); this.server = null; this.currentPort = null; } } /** * 查找可用端口 */ private async findAvailablePort(startPort: number): Promise<number> { for (let port = startPort; port < startPort + 100; port++) { const available = await this.isPortAvailable(port); if (available) { return port; } } throw new Error( `No available ports found in range ${startPort}-${startPort + 99}` ); } /** * 检查端口是否可用 */ private async isPortAvailable(port: number): Promise<boolean> { return new Promise((resolve) => { const server = createServer(); server.once("error", (err: any) => { if (err.code === "EADDRINUSE") { resolve(false); } else { resolve(false); } }); server.once("listening", () => { server.close(); resolve(true); }); server.listen(port, "127.0.0.1"); }); } /** * 打开浏览器 */ private async openBrowser(url: string): Promise<void> { const commands: Record<string, string> = { darwin: `open "${url}"`, win32: `start "" "${url}"`, linux: `xdg-open "${url}"`, }; const command = commands[process.platform as keyof typeof commands]; if (!command) { throw new Error(`Unsupported platform: ${process.platform}`); } return new Promise((resolve, reject) => { exec(command, (error) => { if (error) { reject(error); } else { resolve(); } }); }); } /** * 获取当前状态 */ getStatus(): { running: boolean; port: number | null; url: string | null } { const host = process.env.WEB_UI_HOST || "localhost"; const displayHost = host === "0.0.0.0" ? "localhost" : host; return { running: this.server !== null, port: this.currentPort, url: this.currentPort ? `http://${displayHost}:${this.currentPort}` : null, }; } }