1#!/usr/bin/env node
2// query-token-info CLI — self-contained, zero-dep, Node >= 22
3// Usage: node cli.mjs <command> '<json_params>'
4//
5// Commands:
6//   search   token search by keyword
7//   meta     static token metadata
8//   dynamic  real-time market data (price, volume, holders)
9//   kline    candlestick data
10//
11// All 4 commands use the SAME parameter shape: { chainId, contractAddress, ... }.
12// Internally, kline hits a different host and uses different upstream field names
13// (platform/address) — this CLI handles the translation so the LLM caller sees
14// one consistent interface.
15 
16// ---- inline HTTP helper (self-contained, zero dependency) ----
17const TIMEOUT_MS = 10_000;
18const UA = { 'Accept-Encoding': 'identity', 'User-Agent': 'binance-web3/2.0 (Skill)' };
19 
20// ---- chainId → upstream kline platform name ----
21// Single source of truth for chain identity. Used only by kline (other commands
22// pass chainId through as-is to the Binance Web3 API which accepts chainId directly).
23const CHAIN_ID_TO_PLATFORM = {
24  '1':      'ethereum',
25  '56':     'bsc',
26  '8453':   'base',
27  'CT_501': 'solana',
28};
29 
30const qs = (p) => Object.entries(p)
31  .filter(([, v]) => v != null)
32  .map(([k, v]) => `${encodeURIComponent(k)}=${encodeURIComponent(v)}`)
33  .join('&');
34 
35async function call({ url, method = 'GET', body, headers = {} }) {
36  const ctrl = new AbortController();
37  const timer = setTimeout(() => ctrl.abort(), TIMEOUT_MS);
38  const opts = { method, headers: { ...UA, ...headers }, signal: ctrl.signal };
39  if (method === 'POST') { opts.headers['content-type'] = 'application/json'; opts.body = JSON.stringify(body || {}); }
40  let res;
41  try { res = await fetch(url, opts); }
42  catch { clearTimeout(timer); throw Object.assign(new Error('Network request failed'), { exitCode: 3 }); }
43  clearTimeout(timer);
44  const data = await res.json();
45  if (res.status >= 400) throw Object.assign(new Error(`HTTP ${res.status}`), { exitCode: 1, body: data });
46  return data;
47}
48 
49// ---- commands: (params) => { url, method?, body?, headers? } ----
50const COMMANDS = {
51  search: (p) => ({
52    url: `https://web3.binance.com/bapi/defi/v5/public/wallet-direct/buw/wallet/market/token/search/ai?${qs(p)}`,
53  }),
54  meta: (p) => ({
55    url: `https://web3.binance.com/bapi/defi/v1/public/wallet-direct/buw/wallet/dex/market/token/meta/info/ai?${qs(p)}`,
56  }),
57  dynamic: (p) => ({
58    url: `https://web3.binance.com/bapi/defi/v4/public/wallet-direct/buw/wallet/market/token/dynamic/info/ai?${qs(p)}`,
59  }),
60  kline: (p) => {
61    // Translate unified interface → upstream kline field names.
62    // { chainId, contractAddress, interval, ... } → { platform, address, interval, ... }
63    const { chainId, contractAddress, ...rest } = p;
64    const platform = chainId == null ? undefined : CHAIN_ID_TO_PLATFORM[chainId];
65    if (chainId != null && platform === undefined) {
66      const supported = Object.keys(CHAIN_ID_TO_PLATFORM).map((k) => `"${k}"`).join(', ');
67      throw Object.assign(
68        new Error(`kline: unsupported chainId "${chainId}". Supported: ${supported}`),
69        { exitCode: 1 },
70      );
71    }
72    const upstream = { ...rest };
73    if (platform !== undefined) upstream.platform = platform;
74    if (contractAddress !== undefined) upstream.address = contractAddress;
75    return {
76      url: `https://dquery.sintral.io/u-kline/v1/k-line/candles?${qs(upstream)}`,
77    };
78  },
79};
80 
81// ---- exports (for unit testing; direct execution still works — see dispatch below) ----
82export { COMMANDS, call, qs, UA, TIMEOUT_MS, CHAIN_ID_TO_PLATFORM };
83 
84// ---- CLI dispatch (only runs when executed directly, not when imported) ----
85if (import.meta.url === `file://${process.argv[1]}`) {
86  const [cmd, paramsStr] = process.argv.slice(2);
87 
88  if (!cmd || cmd === '--help' || cmd === '-h') {
89    console.log("Usage: node cli.mjs <command> '<json_params>'\n\nCommands:");
90    for (const name of Object.keys(COMMANDS)) console.log(`  ${name}`);
91    process.exit(0);
92  }
93 
94  const builder = COMMANDS[cmd];
95  if (!builder) { console.error(`Unknown command: ${cmd}\nRun with --help to see available commands.`); process.exit(1); }
96 
97  let params = {};
98  if (paramsStr) {
99    try { params = JSON.parse(paramsStr); }
100    catch { console.error('Invalid JSON params'); process.exit(1); }
101  }
102 
103  try {
104    const result = await call(builder(params));
105    console.log(JSON.stringify(result, null, 2));
106  } catch (err) {
107    console.error(err.message);
108    if (err.body) console.log(JSON.stringify(err.body, null, 2));
109    process.exit(err.exitCode || 1);
110  }
111}
112