Method sendRequest

src/mcp/client/MCPClient.ts:170–234

* 发送请求到 MCP 服务器

(sessionId: string, request: Partial<MCPMessage>)

   * 发送请求到 MCP 服务器
   */
  private async sendRequest(sessionId: string, request: Partial<MCPMessage>): Promise<any> {
    const connection = this.connections.get(sessionId);
    const session = this.sessions.get(sessionId);

    if (!connection || !session?.connected) {
      throw new Error(`Session ${sessionId} is not connected`);
    }

    const message: MCPMessage = {
      jsonrpc: '2.0',
      id: ++this.messageId,
      ...request,
    };

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

      const handleMessage = (data: any) => {
        try {
          const response = typeof data === 'string' ? JSON.parse(data) : data;

          if (response.id === message.id) {
            clearTimeout(timeout);
            connection.off?.('message', handleMessage);

            if (response.error) {
              reject(new Error(response.error.message));
            } else {
              resolve(response.result);
            }
          }
        } catch (error) {
          reject(error);
        }
      };

      if (connection instanceof WebSocket) {
        connection.on('message', handleMessage);
        connection.send(JSON.stringify(message));
      } else {
        // Handle stdio connection
        const responseHandler = (data: Buffer) => {
          try {
            const response = JSON.parse(data.toString().trim());
            if (response.id === message.id) {
              clearTimeout(timeout);
              connection.stdout?.off('data', responseHandler);

              if (response.error) {
                reject(new Error(response.error.message));
              } else {
                resolve(response.result);
              }
            }
          } catch (error) {
            // Ignore JSON parse errors for partial messages