DeFi Trading Agent MCP Server

Instructions

Implementation Reference

• src/toolService.js:395-412 (handler)

  Main handler function for the get_pool_trades tool. Validates parameters and delegates to CoinGecko API service, then formats the response.

  async getPoolTrades(network, poolAddress, options = {}) {
    if (!network || !poolAddress) {
      throw new Error("Missing required parameters: network, poolAddress");
    }
  
    const result = await this.coinGeckoApi.getPoolTrades(
      network,
      poolAddress,
      options
    );
  
    return {
      message: `Pool trades for ${poolAddress} on ${network} retrieved successfully`,
      data: result,
      summary: `Found ${result.data?.length || 0} trades for pool`,
      minVolumeFilter: options.trade_volume_in_usd_greater_than || "none",
    };
  }

• src/index.js:611-631 (schema)

  Input schema definition for the get_pool_trades tool, including parameters and validation rules.

  name: TOOL_NAMES.GET_POOL_TRADES,
  description: "Get recent trades for a specific pool",
  inputSchema: {
    type: "object",
    properties: {
      network: {
        type: "string",
        description: "Network ID (e.g., 'eth', 'bsc', 'polygon_pos')",
      },
      poolAddress: {
        type: "string",
        description: "Pool contract address",
      },
      trade_volume_in_usd_greater_than: {
        type: "number",
        description:
          "Filter trades with volume greater than this USD amount (optional)",
      },
    },
    required: ["network", "poolAddress"],
  },

• src/index.js:1127-1136 (registration)

  Registration and dispatch logic in the main switch case that routes tool calls to the handler.

  case TOOL_NAMES.GET_POOL_TRADES:
    result = await toolService.getPoolTrades(
      args.network,
      args.poolAddress,
      {
        trade_volume_in_usd_greater_than:
          args.trade_volume_in_usd_greater_than,
      }
    );
    break;

• src/services/coinGeckoApiService.js:389-411 (helper)

  Core helper function that performs the actual API call to CoinGecko for retrieving pool trades.

  async getPoolTrades(network, poolAddress, options = {}) {
    try {
      const queryParams = new URLSearchParams();
      
      if (options.trade_volume_in_usd_greater_than) queryParams.append('trade_volume_in_usd_greater_than', options.trade_volume_in_usd_greater_than);
  
      const url = `${this.baseUrl}/networks/${network}/pools/${poolAddress}/trades${queryParams.toString() ? '?' + queryParams.toString() : ''}`;
      
      const response = await fetch(url, {
        headers: {
          'x-cg-demo-api-key': this.apiKey
        }
      });
      
      if (!response.ok) {
        throw new Error(`HTTP ${response.status}: ${response.statusText}`);
      }
      
      return await response.json();
    } catch (error) {
      throw new Error(`Failed to get pool trades: ${error.message}`);
    }
  }