Method start

electron/main/services/SocketService.ts:46–102

* 启动 WebSocket 服务 * @param portOverride 可选端口 * @param forceRestart 是否强制重启

(
    portOverride?: number,
    forceRestart: boolean = false,
  )

   * @param forceRestart 是否强制重启
   */
  public async start(
    portOverride?: number,
    forceRestart: boolean = false,
  ): Promise<{ port: number }> {
    const store = useStore();
    const websocketConfig = store.get("websocket");
    const portFromStore = websocketConfig?.port;
    const port = portOverride ?? portFromStore ?? 25885;

    // 如果服务已在运行
    if (this.wss && this.currentPort !== null) {
      // 如果端口相同，直接返回
      if (this.currentPort === port) {
        return { port: this.currentPort };
      }
      // 如果端口不同且需要强制重启，先停止再启动
      if (forceRestart) {
        await this.stop();
      } else {
        // 否则返回当前端口
        return { port: this.currentPort };
      }
    }

    socketLog.info(`🔌 Trying to start WebSocket server on port ${port}`);

    // 先验证端口是否可用
    const isAvailable = await this.testPort(port);
    if (!isAvailable) throw new Error(`端口 ${port} 不可用`);

    return new Promise<{ port: number }>((resolve, reject) => {
      try {
        const wss = new WebSocketServer({ port });
        this.wss = wss;
        this.currentPort = port;

        wss.on("connection", (socket: WebSocket) => {
          this.handleClientConnection(socket);
        });

        wss.once("listening", () => {
          socketLog.info(`✅ WebSocket server started on port ${port}`);
          resolve({ port });
        });

        wss.once("error", (error: Error) => {
          socketLog.error("❌ WebSocket server failed to start:", error);
          this.cleanupServer();
          reject(error);
        });
      } catch (error) {
        socketLog.error("❌ WebSocket server creation error:", error);
        this.cleanupServer();
        reject(error instanceof Error ? error : new Error(String(error)));
      }
    });
  }