Function computeSmartMoney

src/lib/sync.ts:382–461

Compute smart money flow for all markets with recent whale trades

(db: ReturnType<typeof getDb>)

/** Compute smart money flow for all markets with recent whale trades */
function computeSmartMoney(db: ReturnType<typeof getDb>): Map<string, SmartMoneyFlow> {
  const result = new Map<string, SmartMoneyFlow>();
  const cutoff24h = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString();
  const trades = db
    .prepare(
      `SELECT wallet, condition_id, event_id, side, size, price, usdc_size, outcome,
              title, slug, timestamp, is_smart_wallet
       FROM whale_trades WHERE timestamp >= ?
       ORDER BY timestamp DESC`
    )
    .all(cutoff24h) as WhaleTradeRow[];

  const byEvent = new Map<string, WhaleTradeRow[]>();
  for (const t of trades) {
    const eid = t.event_id;
    if (!eid) continue;
    if (!byEvent.has(eid)) byEvent.set(eid, []);
    byEvent.get(eid)!.push(t);
  }

  const walletNames = new Map<string, string | null>();
  try {
    const wallets = db
      .prepare(`SELECT address, username FROM smart_wallets`)
      .all() as Array<{ address: string; username: string | null }>;
    for (const w of wallets) walletNames.set(w.address.toLowerCase(), w.username);
  } catch { /* smart_wallets table may not exist yet */ }

  for (const [eventId, eventTrades] of byEvent) {
    let smartBuys = 0, smartSells = 0, whaleBuys = 0, whaleSells = 0;
    const topWallets: SmartMoneyFlow["topWallets"] = [];
    const seenWallets = new Set<string>();

    for (const t of eventTrades) {
      const side = t.side;
      const isSmart = t.is_smart_wallet === 1;
      if (side === "BUY") {
        whaleBuys++;
        if (isSmart) smartBuys++;
      } else {
        whaleSells++;
        if (isSmart) smartSells++;
      }
      const addr = t.wallet.toLowerCase();
      if (isSmart && !seenWallets.has(addr) && topWallets.length < 5) {
        seenWallets.add(addr);
        topWallets.push({
          address: t.wallet,
          username: walletNames.get(addr) || null,
          side: side as "BUY" | "SELL",
          size: t.usdc_size || t.size,
        });
      }
    }

    const buyRatio = whaleBuys / (whaleBuys + whaleSells || 1);
    const netFlow: SmartMoneyFlow["netFlow"] =
      buyRatio > 0.6 ? "bullish" : buyRatio < 0.4 ? "bearish" : "neutral";