uniswap-pools-mcp

Instructions

Query a specific Uniswap pool/pair by version (v2, v3, v4) and ID and return as markdown text.

Parameters:
    version (str): The Uniswap version to query ('v2', 'v3', or 'v4').
    pool_id (str): The Ethereum address of the pool or pair to query (e.g., '0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc').
    ctx (Context): The API context for logging and error handling.

Returns:
    A markdown-formatted string containing details of the pool/pair, including Version, ID, Pair, Token0 Address,
    Token1 Address, Fee Tier, Volume USD, Liquidity/ReserveUSD, and Fees USD.

Implementation Reference

• main.py:588-653 (handler)

  The handler function for the 'get_pool_data' MCP tool. Decorated with @mcp.tool() for automatic registration. It dispatches to version-specific query functions (query_pair_v2_by_id, query_pool_v3_by_id, query_pool_v4_by_id) based on the 'version' parameter and returns formatted markdown output with pool details.

  @mcp.tool()
  async def get_pool_data(version: str, pool_id: str, ctx: Context) -> str:
      """
      Query a specific Uniswap pool/pair by version (v2, v3, v4) and ID and return as markdown text.
  
      Parameters:
          version (str): The Uniswap version to query ('v2', 'v3', or 'v4').
          pool_id (str): The Ethereum address of the pool or pair to query (e.g., '0xb4e16d0168e52d35cacd2c6185b44281ec28c9dc').
          ctx (Context): The API context for logging and error handling.
  
      Returns:
          A markdown-formatted string containing details of the pool/pair, including Version, ID, Pair, Token0 Address,
          Token1 Address, Fee Tier, Volume USD, Liquidity/ReserveUSD, and Fees USD.
      """
      ctx.info(f"Querying {version} pool/pair with ID: {pool_id}")
      
      try:
          if version.lower() == "v2":
              pair = await query_pair_v2_by_id(pool_id)
              result = f"""
  **Uniswap V2 Pair Details**
  - **Version**: v2
  - **ID**: {pair.id}
  - **Pair**: {pair.pair}
  - **Token0 Address**: {pair.token0}
  - **Token1 Address**: {pair.token1}
  - **Fee Tier**: 3000 (0.3%)
  - **Volume USD**: {pair.volumeUSD}
  - **Liquidity/ReserveUSD**: {pair.reserveUSD}
  - **Fees USD**: N/A
  """
          elif version.lower() == "v3":
              pool = await query_pool_v3_by_id(pool_id)
              result = f"""
  **Uniswap V3 Pool Details**
  - **Version**: v3
  - **ID**: {pool.id}
  - **Pair**: {pool.pair}
  - **Token0 Address**: {pool.token0}
  - **Token1 Address**: {pool.token1}
  - **Fee Tier**: {pool.feeTier}
  - **Volume USD**: {pool.volumeUSD}
  - **Liquidity/ReserveUSD**: {pool.liquidity}
  - **Fees USD**: {pool.feesUSD}
  """
          elif version.lower() == "v4":
              pool = await query_pool_v4_by_id(pool_id)
              result = f"""
  **Uniswap V4 Pool Details**
  - **Version**: v4
  - **ID**: {pool.id}
  - **Pair**: {pool.pair}
  - **Token0 Address**: {pool.token0}
  - **Token1 Address**: {pool.token1}
  - **Fee Tier**: {pool.feeTier}
  - **Volume USD**: {pool.volumeUSD}
  - **Liquidity/ReserveUSD**: {pool.liquidity}
  - **Fees USD**: {pool.feesUSD}
  """
          else:
              raise ValueError(f"Invalid version: {version}. Must be 'v2', 'v3', or 'v4'")
          
          return result.strip()
      except Exception as e:
          ctx.error(f"Failed to query {version} pool/pair: {str(e)}")
          raise