Function fetchTraderActivity

src/lib/smartMoney.ts:398–429

(wallet: string, limit = 100)

}

export async function fetchTraderActivity(wallet: string, limit = 100): Promise<TraderActivity[]> {
  try {
    const res = await rateLimitedFetch(
      `${DATA_API_BASE}/activity?user=${wallet}&limit=${limit}`
    );
    if (!res.ok) return [];
    const data = await res.json();
    const items = Array.isArray(data) ? data : data.activity || data.data || [];
    return items.map((a: ActivityApiEntry) => {
      let ts = a.timestamp;
      if (typeof ts === "number") {
        ts = ts < 1e12 ? new Date(ts * 1000).toISOString() : new Date(ts).toISOString();
      }
      const rawType = String(a.type || a.action || "TRADE").toUpperCase();
      const type = (["TRADE", "SPLIT", "MERGE", "REDEEM"].includes(rawType) ? rawType : "TRADE") as TraderActivity["type"];
      return {
        timestamp: String(ts || new Date().toISOString()),
        type,
        title: String(a.title || a.marketTitle || a.question || ""),
        outcome: String(a.outcome || ""),
        side: String(a.side || "BUY").toUpperCase() === "SELL" ? "SELL" : "BUY",
        size: parseFloat(String(a.size || a.shares || 0)),
        usdcSize: parseFloat(String(a.usdcSize || a.amount || 0)) || parseFloat(String(a.size || 0)) * parseFloat(String(a.price || 0)),
        price: parseFloat(String(a.price || 0)),
        transactionHash: String(a.transactionHash || a.txHash || a.hash || ""),
      };
    });
  } catch (err) {
    console.error(`[smartMoney] Trader activity fetch error for ${wallet}:`, err);
    return [];
  }
}

export async function fetchTraderValue(wallet: string): Promise<number> {
  try {