Binance Cryptocurrency MCP

Implementation Reference

• src/index.ts:73-103 (handler)

  Complete implementation of get_historical_trades tool. This is the handler function that makes an HTTP GET request to Binance's /api/v3/historicalTrades endpoint with the provided symbol, limit, and fromId parameters. It includes error handling and uses proxy configuration. The tool requires a BINANCE_API_KEY environment variable for authentication.

  server.tool(
      "get_historical_trades",
      {
          symbol: z.string().describe("Trading pair symbol, e.g. BTCUSDT"),
          limit: z.number().optional().describe("Number of trades to return, default 500, max 1000"),
          fromId: z.number().optional().describe("Trade ID to start from, default returns the most recent trades")
      },
      async (args: { symbol: string; limit?: number; fromId?: number }) => {
          try {
              const response = await axios.get(`${BASE_URL}/api/v3/historicalTrades`, {
                  params: {
                      symbol: args.symbol,
                      limit: args.limit,
                      fromId: args.fromId
                  },
                  headers: {
                      "X-MBX-APIKEY": process.env.BINANCE_API_KEY || ""
                  },
                  ...getProxyConfig(),
              });
              return {
                  content: [{ type: "text", text: JSON.stringify(response.data, null, 2) }]
              };
          } catch (error: any) {
              return {
                  content: [{ type: "text", text: `Failed to get historical trades: ${error.message}` }],
                  isError: true
              };
          }
      }
  );

• src/index.ts:75-79 (schema)

  Zod schema definition for get_historical_trades tool parameters. Defines three optional parameters: symbol (trading pair), limit (number of trades to return, max 1000), and fromId (trade ID to start from).

  {
      symbol: z.string().describe("Trading pair symbol, e.g. BTCUSDT"),
      limit: z.number().optional().describe("Number of trades to return, default 500, max 1000"),
      fromId: z.number().optional().describe("Trade ID to start from, default returns the most recent trades")
  },

• src/index.ts:73-103 (registration)

  Registration of get_historical_trades tool with the MCP server using server.tool() method. This includes the tool name, parameter schema, and the handler function.

  server.tool(
      "get_historical_trades",
      {
          symbol: z.string().describe("Trading pair symbol, e.g. BTCUSDT"),
          limit: z.number().optional().describe("Number of trades to return, default 500, max 1000"),
          fromId: z.number().optional().describe("Trade ID to start from, default returns the most recent trades")
      },
      async (args: { symbol: string; limit?: number; fromId?: number }) => {
          try {
              const response = await axios.get(`${BASE_URL}/api/v3/historicalTrades`, {
                  params: {
                      symbol: args.symbol,
                      limit: args.limit,
                      fromId: args.fromId
                  },
                  headers: {
                      "X-MBX-APIKEY": process.env.BINANCE_API_KEY || ""
                  },
                  ...getProxyConfig(),
              });
              return {
                  content: [{ type: "text", text: JSON.stringify(response.data, null, 2) }]
              };
          } catch (error: any) {
              return {
                  content: [{ type: "text", text: `Failed to get historical trades: ${error.message}` }],
                  isError: true
              };
          }
      }
  );

• src/index.ts:406-434 (helper)

  getProxyConfig() helper function used by the get_historical_trades handler. Supports both SOCKS5 and HTTP proxy configuration for making API requests through proxies.

  function getProxyConfig(): any {
      // 优先使用SOCKS5代理
      if (socksProxyURL) {
          try {
              const agent = new SocksProxyAgent(socksProxyURL);
              return { httpsAgent: agent, httpAgent: agent };
          } catch (error) {
              console.error(`Failed to create SOCKS proxy agent: ${error}`);
          }
      }
      
      // 回退到HTTP代理
      if (httpProxyURL) {
          try {
              const urlInfo = new URL(httpProxyURL);
              return {
                  proxy: {
                      host: urlInfo.hostname,
                      port: parseInt(urlInfo.port) || (urlInfo.protocol === 'https:' ? 443 : 80),
                      protocol: urlInfo.protocol.replace(":", "")
                  }
              };
          } catch (error) {
              console.error(`Failed to parse HTTP proxy URL: ${error}`);
          }
      }
      
      return {};
  }