get_rolling_window_ticker

Implementation Reference

• src/index.ts:378-402 (handler)

  The handler function that executes the get_rolling_window_ticker tool logic. It makes an HTTP GET request to Binance's /api/v3/ticker endpoint with the provided parameters (symbol, symbols, windowSize, type) and returns the rolling window price statistics.

  async (args: { symbol?: string; symbols?: string[]; windowSize?: string; type?: "FULL" | "MINI" }) => {
      try {
          let params: any = {};
          if (args.symbol) {
              params.symbol = args.symbol;
          } else if (args.symbols) {
              params.symbols = JSON.stringify(args.symbols);
          }
          if (args.windowSize) params.windowSize = args.windowSize;
          if (args.type) params.type = args.type;
  
          const response = await axios.get(`${BASE_URL}/api/v3/ticker`, {
              params,
              ...getProxyConfig(),
          });
          return {
              content: [{ type: "text", text: JSON.stringify(response.data, null, 2) }]
          };
      } catch (error: any) {
          return {
              content: [{ type: "text", text: `Failed to get rolling window price statistics: ${error.message}` }],
              isError: true
          };
      }
  }

• src/index.ts:372-377 (schema)

  Schema definition for get_rolling_window_ticker tool parameters using zod validation. Defines optional parameters: symbol (string), symbols (array of strings), windowSize (string), and type (enum of 'FULL' or 'MINI').

  {
      symbol: z.string().optional().describe("Trading pair symbol, e.g. BTCUSDT"),
      symbols: z.array(z.string()).optional().describe("Array of multiple trading pair symbols"),
      windowSize: z.string().optional().describe("Window size, e.g. 1m, 4h, 1d"),
      type: z.enum(["FULL", "MINI"]).optional().describe("Return data type, FULL or MINI")
  },

• src/index.ts:370-403 (registration)

  Registration of the get_rolling_window_ticker tool with the MCP server. The tool is registered within the registerTools function using server.tool() with its name, schema, and handler function.

  server.tool(
      "get_rolling_window_ticker",
      {
          symbol: z.string().optional().describe("Trading pair symbol, e.g. BTCUSDT"),
          symbols: z.array(z.string()).optional().describe("Array of multiple trading pair symbols"),
          windowSize: z.string().optional().describe("Window size, e.g. 1m, 4h, 1d"),
          type: z.enum(["FULL", "MINI"]).optional().describe("Return data type, FULL or MINI")
      },
      async (args: { symbol?: string; symbols?: string[]; windowSize?: string; type?: "FULL" | "MINI" }) => {
          try {
              let params: any = {};
              if (args.symbol) {
                  params.symbol = args.symbol;
              } else if (args.symbols) {
                  params.symbols = JSON.stringify(args.symbols);
              }
              if (args.windowSize) params.windowSize = args.windowSize;
              if (args.type) params.type = args.type;
  
              const response = await axios.get(`${BASE_URL}/api/v3/ticker`, {
                  params,
                  ...getProxyConfig(),
              });
              return {
                  content: [{ type: "text", text: JSON.stringify(response.data, null, 2) }]
              };
          } catch (error: any) {
              return {
                  content: [{ type: "text", text: `Failed to get rolling window price statistics: ${error.message}` }],
                  isError: true
              };
          }
      }
  );

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

  Helper function getProxyConfig() that configures proxy settings for HTTP requests. It supports SOCKS5 proxies (via SOCKS_PROXY or SOCKS5_PROXY env vars) and HTTP/HTTPS proxies (via HTTP_PROXY or HTTPS_PROXY env vars). Used by the get_rolling_window_ticker handler.

  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 {};
  }