DeFi Trading Agent MCP Server

Instructions

Implementation Reference

• src/services/coinGeckoApiService.js:162-186 (handler)

  Core implementation of getTopPoolsByDex: makes HTTP request to CoinGecko API /networks/{network}/dexes/{dex}/pools endpoint with query params

  async getTopPoolsByDex(network, dex, options = {}) {
    try {
      const queryParams = new URLSearchParams();
      
      if (options.include) queryParams.append('include', options.include);
      if (options.page) queryParams.append('page', options.page);
      if (options.sort) queryParams.append('sort', options.sort);
  
      const url = `${this.baseUrl}/networks/${network}/dexes/${dex}/pools${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 top pools by DEX: ${error.message}`);
    }
  }

• src/index.js:354-384 (schema)

  MCP tool schema definition including input validation for network, dex, include, page, sort parameters

  name: TOOL_NAMES.GET_TOP_POOLS_BY_DEX,
  description: "Get top pools on a specific DEX",
  inputSchema: {
    type: "object",
    properties: {
      network: {
        type: "string",
        description: "Network ID (e.g., 'eth', 'bsc', 'polygon_pos')",
      },
      dex: {
        type: "string",
        description: "DEX ID (e.g., 'uniswap_v3', 'sushiswap')",
      },
      include: {
        type: "string",
        description:
          "Attributes to include: 'base_token', 'quote_token', 'dex' (comma-separated)",
      },
      page: {
        type: "integer",
        description: "Page number for pagination (optional, default: 1)",
      },
      sort: {
        type: "string",
        description:
          "Sort by: 'h24_tx_count_desc', 'h24_volume_usd_desc' (optional, default: 'h24_tx_count_desc')",
        enum: ["h24_tx_count_desc", "h24_volume_usd_desc"],
      },
    },
    required: ["network", "dex"],
  },

• src/index.js:1049-1055 (registration)

  Registration in MCP CallToolRequestHandler: switch case dispatches to toolService.getTopPoolsByDex

  case TOOL_NAMES.GET_TOP_POOLS_BY_DEX:
    result = await toolService.getTopPoolsByDex(args.network, args.dex, {
      include: args.include,
      page: args.page,
      sort: args.sort,
    });
    break;

• src/toolService.js:229-246 (helper)

  ToolService wrapper that validates params, calls CoinGeckoApiService, and formats response

  async getTopPoolsByDex(network, dex, options = {}) {
    if (!network || !dex) {
      throw new Error("Missing required parameters: network, dex");
    }
  
    const result = await this.coinGeckoApi.getTopPoolsByDex(
      network,
      dex,
      options
    );
  
    return {
      message: `Top pools for ${dex} on ${network} retrieved successfully`,
      data: result,
      summary: `Found ${result.data?.length || 0} pools on ${dex}`,
      sort: options.sort || "h24_tx_count_desc",
    };
  }

• src/constants.js:25-25 (registration)

  TOOL_NAMES constant defining the tool name string"get_top_pools_by_dex"

  GET_TOP_POOLS_BY_DEX: "get_top_pools_by_dex",