Method connectWebSocket

src/mcp/client/MCPClient.ts:239–265

* WebSocket 连接

(config: MCPConnectionConfig)

   * WebSocket 连接
   */
  private async connectWebSocket(config: MCPConnectionConfig): Promise<WebSocket> {
    if (!config.endpoint) {
      throw new Error('WebSocket endpoint is required');
    }

    const ws = new WebSocket(config.endpoint);

    return new Promise((resolve, reject) => {
      const timeout = setTimeout(() => {
        reject(new Error('Connection timeout'));
      }, config.timeout || 10000);

      ws.on('open', () => {
        clearTimeout(timeout);
        resolve(ws);
      });

      ws.on('error', (error: Error) => {
        clearTimeout(timeout);
        reject(error);
      });

      ws.on('message', (data: Buffer) => {
        this.handleMessage(data.toString());
      });
    });
  }

  /**
   * Stdio 连接