Method connect

src/mcp/client/MCPClient.ts:38–76

* 连接到 MCP 服务器

(config: MCPConnectionConfig)

   * 连接到 MCP 服务器
   */
  async connect(config: MCPConnectionConfig): Promise<MCPSession> {
    const sessionId = `${config.name}-${Date.now()}`;

    try {
      let connection: WebSocket | any;

      switch (config.transport) {
        case 'ws':
          connection = await this.connectWebSocket(config);
          break;
        case 'stdio':
          connection = await this.connectStdio(config);
          break;
        case 'sse':
          throw new Error('SSE transport not implemented yet');
        default:
          throw new Error(`Unsupported transport: ${config.transport}`);
      }

      const session: MCPSession = {
        id: sessionId,
        config,
        connected: true,
        lastActivity: new Date(),
      };

      this.sessions.set(sessionId, session);
      this.connections.set(sessionId, connection);

      // 执行初始化握手
      await this.performHandshake(sessionId);

      this.emit('connected', session);
      return session;
    } catch (error) {
      this.emit('error', error);
      throw error;
    }
  }

  /**
   * 断开连接