1#!/usr/bin/env node
2// crypto-market-rank CLI — self-contained, zero-dep, Node >= 22
3// Usage: node cli.mjs <command> '<json_params>'
4//
5// Commands:
6//   social-hype         GET   social buzz leaderboard (sentiment + summary)
7//   token-rank          POST  unified rank (Trending / TopSearch / Alpha / Stock)
8//   smart-money-inflow  POST  token rank by smart money net inflow
9//   meme-rank           GET   top meme tokens from Pulse launchpad (BSC only)
10//   address-pnl-rank    GET   top trader PnL leaderboard
11//
12 
13// ---- inline HTTP helper (self-contained, zero dependency) ----
14const TIMEOUT_MS = 10_000;
15const UA = { 'Accept-Encoding': 'identity', 'User-Agent': 'binance-web3/3.0 (Skill)' };
16 
17const qs = (p) => Object.entries(p)
18  .filter(([, v]) => v != null)
19  .map(([k, v]) => `${encodeURIComponent(k)}=${encodeURIComponent(v)}`)
20  .join('&');
21 
22async function call({ url, method = 'GET', body, headers = {} }) {
23  const ctrl = new AbortController();
24  const timer = setTimeout(() => ctrl.abort(), TIMEOUT_MS);
25  const opts = { method, headers: { ...UA, ...headers }, signal: ctrl.signal };
26  if (method === 'POST') { opts.headers['content-type'] = 'application/json'; opts.body = JSON.stringify(body || {}); }
27  let res;
28  try { res = await fetch(url, opts); }
29  catch { clearTimeout(timer); throw Object.assign(new Error('Network request failed'), { exitCode: 3 }); }
30  clearTimeout(timer);
31  const data = await res.json();
32  if (res.status >= 400) throw Object.assign(new Error(`HTTP ${res.status}`), { exitCode: 1, body: data });
33  return data;
34}
35 
36// ---- per-command supported chains (client-side fail-fast) ----
37const CHAINS = {
38  'social-hype':        new Set(['56', '8453', 'CT_501']),
39  'token-rank':         new Set(['56', '8453', 'CT_501', '1']),
40  'smart-money-inflow': new Set(['56', 'CT_501', '8453']),
41  'meme-rank':          new Set(['56']),
42  'address-pnl-rank':   new Set(['56', 'CT_501', '8453', '1']),
43};
44 
45function validateChainId(cmd, chainId) {
46  const allowed = CHAINS[cmd];
47  if (!allowed) return;
48  const id = String(chainId ?? '');
49  if (!allowed.has(id)) {
50    const supported = [...allowed].map((c) => `"${c}"`).join(', ');
51    throw Object.assign(
52      new Error(`${cmd}: unsupported chainId "${chainId}". Supported: ${supported}`),
53      { exitCode: 1 },
54    );
55  }
56}
57 
58// ---- commands: (params) => { url, method?, body?, headers? } ----
59const COMMANDS = {
60  'social-hype': (p) => {
61    validateChainId('social-hype', p.chainId);
62    return {
63      url: `https://web3.binance.com/bapi/defi/v1/public/wallet-direct/buw/wallet/market/token/pulse/social/hype/rank/leaderboard/ai?${qs(p)}`,
64    };
65  },
66  'token-rank': (p) => {
67    validateChainId('token-rank', p.chainId);
68    const TRENDING_ALPHA_DEFAULTS = {
69      countMin: 10,
70      launchTimeMin: 15,
71      liquidityMin: 5000,
72      uniqueTraderMin: 10,
73      volumeMin: 10000,
74    };
75    const TRENDING_DEFAULTS = {
76      tagFilter: [1, 2, 3],
77    };
78 
79    const rankType = p.rankType ?? 10;
80    let body = { ...p };
81 
82    if (rankType === 10) {
83      // Trending: apply both shared + trending-only defaults (caller params take precedence)
84      body = { ...TRENDING_ALPHA_DEFAULTS, ...TRENDING_DEFAULTS, ...p };
85    } else if (rankType === 20) {
86      // Alpha: apply only shared defaults (caller params take precedence)
87      body = { ...TRENDING_ALPHA_DEFAULTS, ...p };
88    }
89 
90    return {
91      url: 'https://web3.binance.com/bapi/defi/v1/public/wallet-direct/buw/wallet/market/token/pulse/unified/rank/list/ai',
92      method: 'POST',
93      body,
94    };
95  },
96  'smart-money-inflow': (p) => {
97    validateChainId('smart-money-inflow', p.chainId);
98    return {
99      url: 'https://web3.binance.com/bapi/defi/v1/public/wallet-direct/tracker/wallet/token/inflow/rank/query/ai',
100      method: 'POST',
101      body: { ...p, tagType: p.tagType ?? 2 },
102    };
103  },
104  'meme-rank': (p) => {
105    validateChainId('meme-rank', p.chainId);
106    return {
107      url: `https://web3.binance.com/bapi/defi/v1/public/wallet-direct/buw/wallet/market/token/pulse/exclusive/rank/list/ai?${qs(p)}`,
108    };
109  },
110  'address-pnl-rank': (p) => {
111    validateChainId('address-pnl-rank', p.chainId);
112    return {
113      url: `https://web3.binance.com/bapi/defi/v1/public/wallet-direct/market/leaderboard/query/ai?${qs(p)}`,
114    };
115  },
116};
117 
118// ---- exports (for unit testing; direct execution still works — see dispatch below) ----
119export { COMMANDS, call, qs, UA, TIMEOUT_MS, CHAINS, validateChainId };
120 
121// ---- CLI dispatch (only runs when executed directly, not when imported) ----
122if (import.meta.url === `file://${process.argv[1]}`) {
123  const [cmd, paramsStr] = process.argv.slice(2);
124 
125  if (!cmd || cmd === '--help' || cmd === '-h') {
126    console.log("Usage: node cli.mjs <command> '<json_params>'\n\nCommands:");
127    for (const name of Object.keys(COMMANDS)) console.log(`  ${name}`);
128    process.exit(0);
129  }
130 
131  const builder = COMMANDS[cmd];
132  if (!builder) { console.error(`Unknown command: ${cmd}\nRun with --help to see available commands.`); process.exit(1); }
133 
134  let params = {};
135  if (paramsStr) {
136    try { params = JSON.parse(paramsStr); }
137    catch { console.error('Invalid JSON params'); process.exit(1); }
138  }
139 
140  try {
141    const result = await call(builder(params));
142    console.log(JSON.stringify(result, null, 2));
143  } catch (err) {
144    console.error(err.message);
145    if (err.body) console.log(JSON.stringify(err.body, null, 2));
146    process.exit(err.exitCode || 1);
147  }
148}
149