Method callTool

src/tools/mcp_client.js:103–141

* Execute a tool call on the appropriate MCP server. * @param {string} fullName - Tool name in format mcp__serverName__toolName * @param {object} args - Tool arguments * @returns {object} { result, error }

(fullName, args)

   * @returns {object} { result, error }
   */
  async callTool(fullName, args) {
    // Parse mcp__serverName__toolName
    const parts = fullName.split('__');
    if (parts.length < 3 || parts[0] !== 'mcp') {
      return { error: `Invalid MCP tool name: ${fullName}` };
    }
    const serverName = parts[1];
    const toolName = parts.slice(2).join('__'); // Handle tools with __ in name

    const server = this.servers.get(serverName);
    if (!server || !server.connected) {
      return { error: `MCP server '${serverName}' is not connected` };
    }

    try {
      const response = await this._sendRequest(server, 'tools/call', {
        name: toolName,
        arguments: args,
      });

      if (!response) return { error: `No response from ${serverName}` };

      const content = response.content || [];
      const text = content
        .filter(c => c.type === 'text')
        .map(c => c.text || '')
        .join('\n');

      if (response.isError) {
        return { error: text || 'MCP tool returned error' };
      }
      // Sanitize MCP server output before returning — external servers can
      // return ANSI escapes, secrets from their own env, or binary garbage.
      const { sanitizeToolOutput } = require('../security/sanitize');
      return { result: sanitizeToolOutput(text) || '(no output)' };
    } catch (err) {
      return { error: `MCP call failed: ${err.message}` };
    }
  }

  /**
   * Check if a tool name belongs to an MCP server.