[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_205":206,"_207":208},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_155":-5,"_20":156,"_22":157,"_158":159,"_160":161,"_26":162,"_24":163,"_164":-5,"_165":-5,"_166":66,"_167":168,"_169":66,"_170":-5,"_171":-5,"_172":173},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","emozh","name","hypercharted-collectors","branchName","main","version","path","collect_positions.ts","project",{"_33":99,"_13":14,"_45":100,"_101":-5,"_102":66,"_103":104,"_105":104,"_106":107,"_108":-5,"_109":110,"_111":-5,"_112":66,"_113":-5,"_114":-5,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_132":133,"_134":135,"_136":137,"_138":66},"tree",[51,52,53,54,55],"file",{"_33":34,"_35":36,"_37":38,"_13":19,"_39":40,"_41":42,"_17":43,"_44":-5,"_45":46,"_47":48,"_49":-5,"_18":50},"contents",[],"upstream","pull","ahead","behind","envVars","id","7a0e7f9d-c22e-46cd-a6fd-b8837ade34a2","branchId","2f8d3a04-8992-41d7-bc26-0ad8163eadcf","fileId","dfeee1ac-a28f-11f1-b625-1607ee4eb77e","content","// Positions + fresh fills of the current verified list; Telegram alerts to subscribers.\n// Schedule: every 15 minutes.\nimport { bulkInsert, callsign, clearinghouse, d1, info, logRun, tgSend } from \"./lib.ts\";\n\nconst SITE = \"https://hypercharted.tsegelnyk.workers.dev\";\n\nconst usd = (n: number) => {\n const a = Math.abs(n);\n const f = a >= 1e9 ? (a / 1e9).toFixed(2) + \"B\" : a >= 1e6 ? (a / 1e6).toFixed(2) + \"M\" : a >= 1e3 ? (a / 1e3).toFixed(0) + \"k\" : a.toFixed(0);\n return (n < 0 ? \"−$\" : \"$\") + f;\n};\n\n// Compare the two latest snapshots for subscribed wallets and message the followers.\nasync function notifySubs(ts: number) {\n const subs = await d1(\"SELECT s.chat_id, s.addr FROM tg_subs s\");\n if (!subs.length) return 0;\n const watched = [...new Set(subs.map((s: any) => s.addr as string))];\n const prevRow = await d1(\"SELECT MAX(ts) AS ts FROM positions WHERE ts < ?\", [ts]);\n const prevTs = prevRow[0]?.ts;\n if (!prevTs) return 0;\n const inList = watched.map((a) => `'${a}'`).join(\",\");\n const curAll = await d1(`SELECT addr, coin, szi, notional, entry FROM positions WHERE ts=${ts} AND addr IN (${inList})`);\n const prevAll = await d1(`SELECT addr, coin, szi, notional, entry FROM positions WHERE ts=${prevTs} AND addr IN (${inList})`);\n // only diff wallets that were successfully polled in BOTH snapshots (see \"__OK__\" sentinel)\n const okCur = new Set(curAll.filter((p: any) => p.coin === \"__OK__\").map((p: any) => p.addr));\n const okPrev = new Set(prevAll.filter((p: any) => p.coin === \"__OK__\").map((p: any) => p.addr));\n // require presence in BOTH snapshots (fetch failure ≠ closed; new list member ≠ opened);\n // legacy pre-sentinel snapshots fall back to \"had any position row\"\n const prevAddrs = new Set(prevAll.map((p: any) => p.addr));\n const ok = (a: string) => okCur.has(a) && (okPrev.size > 0 ? okPrev.has(a) : prevAddrs.has(a));\n const cur = curAll.filter((p: any) => p.coin !== \"__OK__\" && ok(p.addr));\n const prev = prevAll.filter((p: any) => p.coin !== \"__OK__\" && ok(p.addr));\n const k = (p: any) => `${p.addr}|${p.coin}`;\n const pk = new Map(prev.map((p: any) => [k(p), p]));\n const ck = new Map(cur.map((p: any) => [k(p), p]));\n const events = new Map(); // addr -> lines\n const add = (addr: string, line: string) => { (events.get(addr) ?? events.set(addr, []).get(addr))!.push(line); };\n const amt = (n: number) => { const a = Math.abs(n); return a >= 1000 ? Math.round(a).toLocaleString(\"en-US\") : a >= 1 ? a.toFixed(2) : a.toFixed(4); };\n const pxf = (n: number) => \"$\" + (n >= 1000 ? Math.round(n).toLocaleString(\"en-US\") : n >= 1 ? n.toFixed(2) : n.toFixed(4));\n for (const [key, p] of ck) {\n const q: any = pk.get(key);\n const side = p.szi > 0 ? \"long\" : \"short\";\n if (!q) add(p.addr, `🟩 opened ${side} ${p.coin}: ${amt(p.szi)} ${p.coin} @ ${pxf(p.entry)} · ${usd(p.notional)}`);\n else if (Math.abs(p.szi) > Math.abs(q.szi) * 1.15) add(p.addr, `🟦 added to ${side} ${p.coin}: ${amt(q.szi)} → ${amt(p.szi)} ${p.coin} · now ${usd(p.notional)} · avg entry ${pxf(p.entry)}`);\n else if (Math.abs(p.szi) < Math.abs(q.szi) * 0.85) add(p.addr, `🟧 reduced ${side} ${p.coin}: ${amt(q.szi)} → ${amt(p.szi)} ${p.coin} · now ${usd(p.notional)}`);\n }\n for (const [key, q] of pk) {\n if (!ck.has(key)) add((q as any).addr, `🟨 closed ${(q as any).szi > 0 ? \"long\" : \"short\"} ${(q as any).coin}: was ${amt((q as any).szi)} ${(q as any).coin} @ entry ${pxf((q as any).entry)} · ${usd((q as any).notional)}`);\n }\n let sent = 0;\n const hhmm = new Date(ts).toISOString().slice(11, 16);\n for (const [addr, lines] of events) {\n const text = `${callsign(addr)} · ${hhmm} UTC\\n${lines.join(\"\\n\")}`;\n for (const s of subs.filter((x: any) => x.addr === addr)) { await tgSend(s.chat_id, text); sent++; }\n }\n\n // near-liquidation warnings: followed wallet's position within 10% of its forced close\n try {\n const mids = await info({ type: \"allMids\" }) as Record;\n const withLiq = await d1(`SELECT addr, coin, szi, notional, liq FROM positions WHERE ts=${ts} AND coin != '__OK__' AND liq IS NOT NULL AND addr IN (${inCohortList(watched)})`);\n const recent = new Map((await d1(\"SELECT chat_id, addr, coin, alerted_at FROM liq_alerts\")).map((r: any) => [`${r.chat_id}|${r.addr}|${r.coin}`, r.alerted_at as number]));\n for (const p of withLiq) {\n const mid = parseFloat(mids[p.coin] ?? \"\");\n if (!Number.isFinite(mid) || mid <= 0 || p.notional < 50_000) continue;\n const dist = Math.abs((p.liq - mid) / mid);\n if (dist > 0.10) continue;\n const side = p.szi > 0 ? \"long\" : \"short\";\n for (const s of subs.filter((x: any) => x.addr === p.addr)) {\n const key = `${s.chat_id}|${p.addr}|${p.coin}`;\n if ((recent.get(key) ?? 0) > ts - 6 * 3600_000) continue;\n await tgSend(s.chat_id,\n `${callsign(p.addr)} is ${(dist * 100).toFixed(1)}% from liquidation\\n` +\n `🟥 ${side} ${p.coin}, ${usd(p.notional)} — force-close at ${p.liq.toFixed(p.liq >= 100 ? 0 : 2)} (now ${mid.toFixed(mid >= 100 ? 0 : 2)}).\\n` +\n `If you copied this position, decide before the market does.`);\n await d1(\"INSERT OR REPLACE INTO liq_alerts (chat_id, addr, coin, alerted_at) VALUES (?, ?, ?, ?)\", [s.chat_id, p.addr, p.coin, ts]);\n sent++;\n }\n }\n } catch (e) { console.error(\"liq alerts:\", e); }\n return sent;\n}\n\nconst inCohortList = (addrs: string[]) => addrs.map((a) => `'${a}'`).join(\",\") || \"''\";\n\n// Shadow trades exit by themselves: primarily when the whale we copy leaves the position\n// (that is what actually measures \"does copying this trader work\"), plus a wide safety stop.\nasync function settlePaper(ts: number): Promise {\n const open = await d1(\"SELECT id, coin, long, entry, src_addr, mirror, stop_pct, tp_pct FROM paper WHERE closed IS NULL\");\n if (!open.length) return 0;\n const mids = await info({ type: \"allMids\" }) as Record;\n const cur = await d1(`SELECT addr, coin FROM positions WHERE ts=${ts}`);\n const polled = new Set(cur.filter((p: any) => p.coin === \"__OK__\").map((p: any) => p.addr));\n const held = new Set(cur.filter((p: any) => p.coin !== \"__OK__\").map((p: any) => `${p.addr}|${p.coin}`));\n let closed = 0;\n for (const t of open) {\n const mark = parseFloat(mids[t.coin] ?? \"\");\n if (!Number.isFinite(mark) || !t.entry) continue;\n const move = ((mark - t.entry) / t.entry) * (t.long ? 1 : -1); // positive = trade in profit\n let reason: string | null = null;\n // only trust \"the whale exited\" when that wallet was actually polled this cycle\n if (t.mirror && t.src_addr && polled.has(t.src_addr) && !held.has(`${t.src_addr}|${t.coin}`)) reason = \"whale exited\";\n else if (t.stop_pct != null && move <= -t.stop_pct) reason = \"stop\";\n else if (t.tp_pct != null && move >= t.tp_pct) reason = \"target\";\n if (!reason) continue;\n await d1(\"UPDATE paper SET closed=?, close_px=?, close_reason=? WHERE id=?\", [Date.now(), mark, reason, t.id]);\n closed++;\n }\n return closed;\n}\n\n// A surge = several verified wallets moving the same way on the same coin inside one cycle.\n// Thresholds are deliberately conservative: this must stay rare enough to be worth a push.\nconst SURGE_MIN_WALLETS = 3;\nconst SURGE_MIN_NOTIONAL = 1_000_000;\n\nasync function detectSurges(ts: number): Promise {\n const prevRow = await d1(\"SELECT MAX(ts) AS ts FROM positions WHERE ts < ?\", [ts]);\n const prevTs = prevRow[0]?.ts;\n if (!prevTs) return 0;\n const cur = await d1(`SELECT addr, coin, szi, notional FROM positions WHERE ts=${ts}`);\n const prev = await d1(`SELECT addr, coin, szi, notional FROM positions WHERE ts=${prevTs}`);\n const okCur = new Set(cur.filter((p: any) => p.coin === \"__OK__\").map((p: any) => p.addr));\n const okPrev = new Set(prev.filter((p: any) => p.coin === \"__OK__\").map((p: any) => p.addr));\n const ok = (a: string) => okCur.has(a) && okPrev.has(a);\n const k = (p: any) => `${p.addr}|${p.coin}`;\n const ck = new Map(cur.filter((p: any) => p.coin !== \"__OK__\" && ok(p.addr)).map((p: any) => [k(p), p]));\n const pk = new Map(prev.filter((p: any) => p.coin !== \"__OK__\" && ok(p.addr)).map((p: any) => [k(p), p]));\n\n type Bucket = { wallets: Set; notional: number };\n const buckets = new Map(); // `${coin}|${side}|${kind}`\n const bump = (coin: string, side: string, kind: string, addr: string, delta: number) => {\n const key = `${coin}|${side}|${kind}`;\n const b = buckets.get(key) ?? { wallets: new Set(), notional: 0 };\n b.wallets.add(addr);\n b.notional += Math.abs(delta);\n buckets.set(key, b);\n };\n for (const [key, p] of ck) {\n const q: any = pk.get(key);\n const sideName = p.szi > 0 ? \"long\" : \"short\";\n if (!q) bump(p.coin, sideName, \"build\", p.addr, p.notional);\n else if (Math.abs(p.szi) > Math.abs(q.szi) * 1.15) bump(p.coin, sideName, \"build\", p.addr, p.notional - q.notional);\n else if (Math.abs(p.szi) < Math.abs(q.szi) * 0.85) bump(p.coin, sideName, \"unwind\", p.addr, q.notional - p.notional);\n }\n for (const [key, q] of pk) {\n if (!ck.has(key)) bump((q as any).coin, (q as any).szi > 0 ? \"long\" : \"short\", \"unwind\", (q as any).addr, (q as any).notional);\n }\n\n const hits = [...buckets.entries()]\n .map(([key, b]) => { const [coin, sideName, kind] = key.split(\"|\"); return { coin, side: sideName, kind, wallets: b.wallets, notional: b.notional }; })\n .filter((h) => h.wallets.size >= SURGE_MIN_WALLETS && h.notional >= SURGE_MIN_NOTIONAL)\n .sort((a, b) => b.notional - a.notional);\n if (!hits.length) return 0;\n\n await bulkInsert(\"INSERT OR IGNORE INTO surges (ts,coin,side,kind,wallets,notional,detail)\",\n hits.map((h) => [ts, h.coin, h.side, h.kind, h.wallets.size, h.notional, [...h.wallets].map(callsign).join(\", \")]));\n\n // broadcast to chats that did not opt out\n const chats = await d1(`SELECT DISTINCT s.chat_id FROM tg_subs s\n LEFT JOIN tg_prefs p ON p.chat_id = s.chat_id WHERE COALESCE(p.surges, 1) = 1`);\n for (const h of hits.slice(0, 3)) {\n const verb = h.kind === \"build\" ? (h.side === \"long\" ? \"piling into longs\" : \"piling into shorts\") : (h.side === \"long\" ? \"unwinding longs\" : \"covering shorts\");\n const mark = h.kind === \"build\" ? (h.side === \"long\" ? \"🟩\" : \"🟥\") : \"🟨\";\n const text = `Cohort surge: ${h.coin}\\n${mark} ${h.wallets.size} verified wallets ${verb} — ${usd(h.notional)} in 15 minutes.\\n${[...h.wallets].slice(0, 5).map(callsign).join(\", \")}${h.wallets.size > 5 ? ` +${h.wallets.size - 5} more` : \"\"}\\n${SITE}/#/now`;\n for (const c of chats) await tgSend(c.chat_id, text);\n }\n return hits.length;\n}\n\nconst FILLS_CAP_PER_WALLET = 80;\n// perp coins are plain tickers; spot fills look like \"@123\" or \"PURR/USDC\" — skip those\nconst isPerpCoin = (c: string) => !c.startsWith(\"@\") && !c.includes(\"/\");\n\nasync function collect(): Promise {\n const last = await d1(\"SELECT MAX(ts) AS ts FROM verified_list\");\n const listTs = last[0]?.ts;\n if (!listTs) return \"no verified list yet\";\n const addrs = (await d1(\"SELECT addr FROM verified_list WHERE ts=? ORDER BY rank\", [listTs])).map((r) => r.addr as string);\n const fillsAddrs = new Set(addrs.slice(0, 30)); // fills (weight 20/call) only for the top-30\n const ts = Date.now();\n const sinceRows = await d1(\"SELECT addr, MAX(time) AS t FROM fills GROUP BY addr\");\n const since = new Map(sinceRows.map((r: any) => [r.addr, r.t as number]));\n const rows: unknown[][] = [];\n const fillRows: unknown[][] = [];\n let errors = 0;\n for (let i = 0; i < addrs.length; i += 10) {\n const chunk = addrs.slice(i, i + 10);\n const res = await Promise.allSettled(chunk.map(async (a) => ({\n state: await clearinghouse(a),\n fills: fillsAddrs.has(a) ? await info({ type: \"userFills\", user: a }) as any[] : [],\n })));\n res.forEach((r, j) => {\n const addr = chunk[j];\n if (r.status !== \"fulfilled\") { errors++; return; }\n // sentinel row: this wallet WAS successfully polled in this snapshot (even if flat).\n // Without it a failed fetch is indistinguishable from \"closed everything\".\n rows.push([ts, addr, \"__OK__\", 0, null, 0, 0, 0, null]);\n for (const p of r.value.state.positions) rows.push([ts, addr, p.coin, p.szi, p.lev, p.notional, p.entry, p.upnl, p.liq]);\n const cutoff = since.get(addr) ?? ts - 24 * 3600_000; // first sight: last 24 h only\n const fresh = r.value.fills\n .filter((f) => f.time > cutoff && isPerpCoin(f.coin) && f.tid)\n .sort((a, b) => b.time - a.time)\n .slice(0, FILLS_CAP_PER_WALLET);\n for (const f of fresh) fillRows.push([f.tid, addr, f.time, f.coin, f.dir ?? null, parseFloat(f.px), parseFloat(f.sz), parseFloat(f.closedPnl ?? \"0\"), f.hash ?? null]);\n });\n }\n await bulkInsert(\"INSERT OR IGNORE INTO positions (ts,addr,coin,szi,lev,notional,entry,upnl,liq)\", rows);\n await bulkInsert(\"INSERT OR IGNORE INTO fills (tid,addr,time,coin,dir,px,sz,closed_pnl,hash)\", fillRows);\n let alerts = 0;\n try { alerts = await notifySubs(ts); } catch (e) { console.error(\"notify:\", e); }\n let surges = 0;\n try { surges = await detectSurges(ts); } catch (e) { console.error(\"surges:\", e); }\n let settled = 0;\n try { settled = await settlePaper(ts); } catch (e) { console.error(\"paper:\", e); }\n return `wallets=${addrs.length} positions=${rows.length} fills=${fillRows.length} alerts=${alerts} surges=${surges} paperClosed=${settled} errors=${errors}`;\n}\n\nexport default async function () {\n await logRun(\"positions\", collect);\n}\n","fileType","script",12,"parentId","createdAt",["D",1788546432353],"branchVersion",26,"label",[19],{"_33":90,"_13":91,"_37":92,"_44":-5,"_35":36,"_47":93,"_60":61,"_45":94,"_17":95,"_41":42,"_39":96,"_65":66,"_49":-5,"_67":97,"_18":98},{"_33":82,"_13":83,"_37":84,"_44":-5,"_35":36,"_47":85,"_60":61,"_45":86,"_17":75,"_41":42,"_39":87,"_65":66,"_49":-5,"_67":88,"_18":89},{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_60":61,"_45":79,"_17":43,"_41":42,"_39":40,"_65":66,"_49":-5,"_67":80,"_18":81},{"_33":70,"_13":71,"_37":72,"_44":-5,"_35":36,"_47":73,"_60":61,"_45":74,"_17":75,"_41":42,"_39":76,"_65":66,"_49":-5,"_67":77,"_18":78},{"_33":56,"_13":57,"_37":58,"_44":-5,"_35":36,"_47":59,"_60":61,"_45":62,"_17":63,"_41":42,"_39":64,"_65":66,"_49":-5,"_67":68,"_18":69},"12dbe11d-55c5-4ad5-82ed-02c57a05c31b","lib.ts","df72ade4-a28f-11f1-be32-1607ee4eb77e",17,"latest",true,["D",1787895284036],3,"// Shared code for Hypercharted collectors running on val.town (Deno runtime).\n// They write into the Cloudflare D1 database of the `whalewatch` Worker through the REST API,\n// because the Workers Free plan cannot run the heavy collection itself (see docs/deployment.md).\n// Mirrors src/hl.ts + src/collect.ts of the main repo — keep the logic in sync.\n\nconst CF_ACCOUNT = \"05dc8e29d1a49d6a09477b6be9d8dc41\";\nconst D1_ID = \"952de6d8-031d-4b69-a180-9f3569c59f82\";\nconst D1_URL = `https://api.cloudflare.com/client/v4/accounts/${CF_ACCOUNT}/d1/database/${D1_ID}/query`;\n\nexport async function d1(sql: string, params: unknown[] = []): Promise {\n const token = Deno.env.get(\"CF_D1_TOKEN\");\n if (!token) throw new Error(\"CF_D1_TOKEN env var is not set on this val\");\n const r = await fetch(D1_URL, {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json\" },\n body: JSON.stringify({ sql, params }),\n });\n const j = await r.json();\n if (!j.success) throw new Error(\"D1: \" + JSON.stringify(j.errors).slice(0, 300));\n return j.result?.[0]?.results ?? [];\n}\n\n// Bulk inserts inline SQL literals so one REST call carries hundreds of rows.\nexport const lit = (v: unknown): string => {\n if (v === null || v === undefined) return \"NULL\";\n if (typeof v === \"number\") return Number.isFinite(v) ? String(v) : \"NULL\";\n if (typeof v === \"boolean\") return v ? \"1\" : \"0\";\n return `'${String(v).replace(/'/g, \"''\")}'`;\n};\nexport async function bulkInsert(prefix: string, rows: unknown[][], per = 300) {\n for (let i = 0; i < rows.length; i += per) {\n const values = rows.slice(i, i + per).map((r) => `(${r.map(lit).join(\",\")})`).join(\",\");\n await d1(`${prefix} VALUES ${values}`);\n }\n}\n\nexport async function logRun(task: string, fn: () => Promise) {\n const started = Date.now();\n const ins = await d1(\"INSERT INTO runs (task, started_at) VALUES (?, ?) RETURNING id\", [task, started]);\n const id = ins[0]?.id;\n try {\n const info = await fn();\n await d1(\"UPDATE runs SET finished_at=?, ok=1, info=? WHERE id=?\", [Date.now(), `[val.town] ${info}`, id]);\n console.log(task, \"ok\", Date.now() - started, \"ms:\", info);\n } catch (e) {\n const msg = e instanceof Error ? e.message : String(e);\n await d1(\"UPDATE runs SET finished_at=?, ok=0, info=? WHERE id=?\", [Date.now(), `[val.town] ${msg}`, id]);\n console.error(task, \"FAILED:\", msg);\n throw e;\n }\n}\n\n/* ---- Hyperliquid ---- */\nexport const INFO_URL = \"https://api.hyperliquid.xyz/info\";\nexport const LEADERBOARD_URL = \"https://stats-data.hyperliquid.xyz/Mainnet/leaderboard\";\nexport const VAULTS_URL = \"https://stats-data.hyperliquid.xyz/Mainnet/vaults\";\n\nexport type Window = { pnl: number; roi: number; vlm: number };\nexport type LbRow = { addr: string; name: string | null; acct: number; day: Window; week: Window; month: Window; all: Window };\n\nexport async function info(body: Record): Promise {\n const r = await fetch(INFO_URL, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify(body) });\n if (!r.ok) throw new Error(`info ${body.type}: HTTP ${r.status}`);\n return r.json();\n}\n\nexport async function clearinghouse(addr: string) {\n const s = await info({ type: \"clearinghouseState\", user: addr });\n const positions = (s.assetPositions ?? [])\n .map((x: any) => x.position)\n .filter((p: any) => parseFloat(p.szi) !== 0)\n .map((p: any) => ({\n coin: p.coin as string,\n szi: parseFloat(p.szi),\n lev: p.leverage ? p.leverage.value as number : null,\n notional: Math.abs(parseFloat(p.positionValue)),\n entry: parseFloat(p.entryPx),\n upnl: parseFloat(p.unrealizedPnl),\n liq: p.liquidationPx ? parseFloat(p.liquidationPx) : null,\n }));\n return { equity: parseFloat(s.marginSummary.accountValue), positions };\n}\n\nexport function normalizeLbRow(r: any): LbRow | null {\n try {\n const wp = Object.fromEntries(r.windowPerformances);\n const w = (k: string): Window => ({ pnl: +wp[k].pnl, roi: +wp[k].roi, vlm: +wp[k].vlm });\n const row = { addr: String(r.ethAddress).toLowerCase(), name: r.displayName || null, acct: parseFloat(r.accountValue),\n day: w(\"day\"), week: w(\"week\"), month: w(\"month\"), all: w(\"allTime\") };\n return Number.isFinite(row.acct) && /^0x[0-9a-f]{40}$/.test(row.addr) ? row : null;\n } catch { return null; }\n}\n\n// The stats-data documents are pretty-printed JSON of 14–37 MB. Stream and cut per element:\n// `mark` is a key that starts every element; the element begins at the `{` before it.\nexport async function streamObjects(url: string, mark: string, onObject: (o: any) => void): Promise {\n const r = await fetch(url);\n if (!r.ok || !r.body) throw new Error(`${url}: HTTP ${r.status}`);\n const reader = r.body.getReader();\n const dec = new TextDecoder();\n const key = `\"${mark}\"`;\n let buf = \"\";\n let total = 0;\n const flush = (final: boolean) => {\n let m = buf.indexOf(key);\n while (m !== -1) {\n const start = buf.lastIndexOf(\"{\", m);\n const next = buf.indexOf(key, m + key.length);\n let end: number;\n if (next !== -1) end = buf.lastIndexOf(\"}\", buf.lastIndexOf(\"{\", next)) + 1;\n else if (final) end = buf.lastIndexOf(\"}\", buf.lastIndexOf(\"]\")) + 1;\n else break;\n if (start === -1 || end <= start) break;\n total++;\n try { onObject(JSON.parse(buf.slice(start, end))); } catch { /* skip malformed */ }\n m = next;\n if (next === -1) buf = \"\";\n }\n if (m !== -1) buf = buf.slice(buf.lastIndexOf(\"{\", m));\n };\n for (;;) {\n const { value, done } = await reader.read();\n if (done) break;\n buf += dec.decode(value, { stream: true });\n if (buf.length > 1_000_000) flush(false);\n }\n buf += dec.decode();\n flush(true);\n return total;\n}\n\n/* ---- callsigns (keep identical to src/callsign.ts) ---- */\nconst ADJ = [\"QUIET\", \"DISTANT\", \"DEEP\", \"POLAR\", \"GREY\", \"OUTER\", \"STORMY\", \"NIGHT\", \"COLD\", \"STEEL\", \"NORTHERN\", \"STEADY\", \"HEAVY\", \"SALT\", \"DARK\", \"EARLY\"];\nconst NOUN = [\"HARPOON\", \"SEXTANT\", \"COMPASS\", \"BEACON\", \"SURF\", \"FAIRWAY\", \"TRAWL\", \"SQUALL\", \"BAROMETER\", \"ANCHOR\", \"BEARING\", \"REEF\", \"HELM\", \"CYCLONE\", \"TIDE\", \"KEEL\"];\nexport function callsign(addr: string): string {\n let h = 0;\n for (const c of addr.toLowerCase()) h = (h * 31 + c.charCodeAt(0)) >>> 0;\n return `${ADJ[h % ADJ.length]} ${NOUN[(h >>> 5) % NOUN.length]}`;\n}\n\n/* ---- Telegram ---- */\nexport async function tgSend(chatId: number, text: string) {\n const token = Deno.env.get(\"TG_TOKEN\");\n if (!token) return;\n const r = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n if (!r.ok) console.error(\"tgSend\", r.status, (await r.text()).slice(0, 150));\n}\n\n/* ---- cohort rules (keep identical to src/collect.ts) ---- */\nexport const CANDIDATE = (r: LbRow) => r.all.pnl >= 500_000 && r.acct >= 100_000;\nexport const BROAD = (r: LbRow) => r.all.pnl >= 100_000 || r.acct >= 100_000;\nexport const LIST_SIZE = 100; // ranked verified list; fills/style stats only for the top FILLS_TOP\nexport const FILLS_TOP = 30; // userFills is rate-limit-heavy (weight 20/call) — cap it\nexport const steadiness = (r: LbRow) => ([\"day\", \"week\", \"month\", \"all\"] as const).filter((w) => r[w].pnl > 0).length;\nexport const isReadable = (equity: number, acct: number) => equity > 0 && equity >= acct * 0.2;\n","deleted",false,"children",[],[57],"7495ac79-e530-44ed-bd62-9ef0ffff4be2","collect_vaults.ts","e026874c-a28f-11f1-9829-1607ee4eb77e",28,["D",1788546432943],1,"// Vault registry + daily snapshot. Schedule: once a day.\nimport { bulkInsert, logRun, streamObjects, VAULTS_URL } from \"./lib.ts\";\n\nfunction maxDrawdown(series: number[]): number {\n let peak = -Infinity, dd = 0;\n for (const v of series) {\n if (v > peak) peak = v;\n if (peak > 0) dd = Math.max(dd, (peak - v) / peak);\n }\n return Math.min(1, dd);\n}\n\n// v0 score — keep identical to vaultScore() in src/collect.ts\nfunction score(ageDays: number, maxDd: number, tvl: number, apr: number): number {\n const age = Math.min(1, ageDays / 365) * 30;\n const dd = Math.max(0, 1 - maxDd / 0.5) * 30;\n const depth = Math.max(0, Math.min(1, (Math.log10(Math.max(tvl, 1)) - 3) / 4)) * 20;\n const aprScore = apr <= 0 ? 0 : apr <= 1 ? 20 : apr <= 3 ? 20 * (1 - (apr - 1) / 2) : 0;\n return Math.round(age + dd + depth + aprScore);\n}\n\nasync function collect(): Promise {\n const ts = Date.now();\n const day = new Date(ts).toISOString().slice(0, 10);\n const upserts: unknown[][] = [];\n const daily: unknown[][] = [];\n const total = await streamObjects(VAULTS_URL, \"apr\", (v) => {\n const s = v.summary;\n if (!s || !/^0x[0-9a-fA-F]{40}$/.test(String(s.vaultAddress))) return;\n const tvl = parseFloat(s.tvl);\n if (s.isClosed || !(tvl >= 1_000)) return;\n const allSeries = ((v.pnls?.find((p: [string, string[]]) => p[0] === \"allTime\")?.[1]) ?? []).map(Number);\n const allPnl = allSeries.length ? allSeries[allSeries.length - 1] : 0;\n const dd = maxDrawdown(allSeries);\n const ageDays = (ts - s.createTimeMillis) / 864e5;\n const addr = String(s.vaultAddress).toLowerCase();\n upserts.push([addr, s.name, s.leader ? String(s.leader).toLowerCase() : null, s.createTimeMillis, 0, tvl, v.apr, dd, allPnl, score(ageDays, dd, tvl, v.apr), ts]);\n daily.push([day, addr, tvl, v.apr, allPnl]);\n });\n await bulkInsert(\"INSERT OR REPLACE INTO vaults (addr,name,leader,created_ms,is_closed,tvl,apr,max_dd,all_pnl,score,updated_at)\", upserts);\n await bulkInsert(\"INSERT OR IGNORE INTO vault_daily (day,addr,tvl,apr,all_pnl)\", daily);\n return `vaults=${total} kept=${upserts.length}`;\n}\n\nexport default async function () {\n await logRun(\"vaults\", collect);\n}\n",[],[71],["D",1788546432353],[],[19],"2958c67e-1580-4492-8855-125cddc354b9","collect_market.ts","407a18a2-a2a9-11f1-be21-1607ee4eb77e",27,["D",1788546432615],"// CEX comparison layer: Binance top-trader vs crowd positioning for the coins our cohort holds.\n// Public endpoints, no API key. Schedule: every 15 minutes (Binance itself updates every 5 min).\nimport { bulkInsert, d1, logRun } from \"./lib.ts\";\n\nconst FD = \"https://fapi.binance.com/futures/data\";\nconst FAPI = \"https://fapi.binance.com/fapi/v1\";\n\nasync function j(url: string): Promise {\n const r = await fetch(url);\n if (!r.ok) throw new Error(`${r.status}`);\n return r.json();\n}\n\n// Which coins matter: whatever the verified cohort currently holds, plus the majors.\nasync function coinsOfInterest(): Promise {\n const posTs = (await d1(\"SELECT MAX(ts) AS ts FROM positions\"))[0]?.ts;\n const held = posTs\n ? (await d1(`SELECT coin, COUNT(*) n FROM positions WHERE ts=${posTs} AND coin != '__OK__' GROUP BY coin ORDER BY n DESC LIMIT 20`)).map((r: any) => r.coin as string)\n : [];\n const set = new Set([\"BTC\", \"ETH\", \"SOL\", \"HYPE\"]);\n for (const c of held) if (/^[A-Z0-9]{2,12}$/.test(c)) set.add(c);\n return [...set];\n}\n\nasync function collect(): Promise {\n const ts = Date.now();\n const coins = await coinsOfInterest();\n const rows: unknown[][] = [];\n let missing = 0;\n for (const coin of coins) {\n const sym = `${coin}USDT`;\n try {\n // top traders by position is the closest CEX analogue of \"big money stance\"\n const [top, crowd, oi, prem] = await Promise.all([\n j(`${FD}/topLongShortPositionRatio?symbol=${sym}&period=15m&limit=1`),\n j(`${FD}/globalLongShortAccountRatio?symbol=${sym}&period=15m&limit=1`).catch(() => []),\n j(`${FD}/openInterestHist?symbol=${sym}&period=15m&limit=1`).catch(() => []),\n j(`${FAPI}/premiumIndex?symbol=${sym}`).catch(() => null),\n ]);\n if (!top?.[0]) { missing++; continue; }\n rows.push([\n ts, coin,\n parseFloat(top[0].longAccount),\n crowd?.[0] ? parseFloat(crowd[0].longAccount) : null,\n oi?.[0] ? parseFloat(oi[0].sumOpenInterestValue) : null,\n prem ? parseFloat(prem.lastFundingRate) : null,\n prem ? parseFloat(prem.markPrice) : null,\n ]);\n } catch {\n missing++; // coin not listed on Binance futures (PURR, small caps) — expected\n }\n }\n await bulkInsert(\"INSERT OR IGNORE INTO market (ts,coin,top_long,crowd_long,oi_usd,funding,mark)\", rows);\n return `coins=${coins.length} stored=${rows.length} unlisted=${missing}`;\n}\n\nexport default async function () {\n await logRun(\"market\", collect);\n}\n",[],[83],"e4565823-1f32-4293-8cdb-4db0483f10bf","collect_lb.ts","dfb8ff88-a28f-11f1-a685-1607ee4eb77e",25,["D",1788546432057],6,"// Hourly: leaderboard snapshot + verified list. Schedule: every 1 hour.\nimport { BROAD, CANDIDATE, clearinghouse, d1, bulkInsert, info, isReadable, LIST_SIZE, logRun, normalizeLbRow, steadiness, streamObjects, LEADERBOARD_URL } from \"./lib.ts\";\nimport type { LbRow } from \"./lib.ts\";\n\nconst MAX_PROBES = 150; // clearinghouseState is cheap (weight 2); readability deep in the list is ~8%, so we need volume\nconst READABLE_TTL = 24 * 3600 * 1000;\n\nasync function collect(): Promise {\n const ts = Date.now();\n const day = new Date(ts).toISOString().slice(0, 10);\n const isDaily = new Date(ts).getUTCHours() === 0;\n const candidates: LbRow[] = [];\n const broad: LbRow[] = [];\n const total = await streamObjects(LEADERBOARD_URL, \"ethAddress\", (o) => {\n const r = normalizeLbRow(o);\n if (!r) return;\n if (CANDIDATE(r)) candidates.push(r);\n else if (isDaily && BROAD(r)) broad.push(r);\n });\n if (candidates.length < 50) throw new Error(`leaderboard suspiciously small: ${candidates.length} of ${total}`);\n\n await bulkInsert(\"INSERT OR IGNORE INTO lb_snapshots (ts,addr,acct,day_pnl,day_roi,week_pnl,week_roi,month_pnl,month_roi,all_pnl,all_roi,all_vlm)\",\n candidates.map((r) => [ts, r.addr, r.acct, r.day.pnl, r.day.roi, r.week.pnl, r.week.roi, r.month.pnl, r.month.roi, r.all.pnl, r.all.roi, r.all.vlm]));\n await bulkInsert(\"INSERT OR IGNORE INTO wallets (addr,display_name,first_seen,last_seen)\",\n candidates.map((r) => [r.addr, r.name, ts, ts]));\n if (isDaily) {\n await bulkInsert(\"INSERT OR IGNORE INTO lb_daily (day,addr,acct,month_pnl,all_pnl,all_roi,all_vlm)\",\n candidates.concat(broad).map((r) => [day, r.addr, r.acct, r.month.pnl, r.all.pnl, r.all.roi, r.all.vlm]));\n }\n\n // rank + readability (cached in wallets, probe at most MAX_PROBES fresh ones per run)\n const ranked = candidates.filter((r) => r.month.pnl > 0).sort((a, b) => b.month.pnl - a.month.pnl);\n const known = new Map();\n const top = ranked.slice(0, 600);\n for (let i = 0; i < top.length; i += 150) {\n const chunk = top.slice(i, i + 150);\n const rows = await d1(`SELECT addr, readable, readable_checked_at AS at FROM wallets WHERE addr IN (${chunk.map((r) => `'${r.addr}'`).join(\",\")})`);\n for (const w of rows) known.set(w.addr, w);\n }\n const verified: LbRow[] = [];\n const probed: [string, number][] = [];\n const toProbe: LbRow[] = [];\n const fresh = new Map();\n for (const r of ranked) {\n const k = known.get(r.addr);\n if (k && k.at && ts - k.at < READABLE_TTL) { if (k.readable === 1) verified.push(r); }\n else if (toProbe.length < MAX_PROBES) toProbe.push(r);\n if (verified.length >= LIST_SIZE && toProbe.length === 0) break;\n if (verified.length + toProbe.length >= LIST_SIZE + MAX_PROBES) break;\n }\n for (let i = 0; i < toProbe.length; i += 10) {\n const chunk = toProbe.slice(i, i + 10);\n const res = await Promise.allSettled(chunk.map((r) => clearinghouse(r.addr)));\n res.forEach((x, j) => {\n const r = chunk[j];\n const readable = x.status === \"fulfilled\" && isReadable(x.value.equity, r.acct) ? 1 : 0;\n probed.push([r.addr, readable]);\n fresh.set(r.addr, readable);\n });\n }\n // (bulkInsert can't append ON CONFLICT after VALUES — one manual statement)\n if (probed.length) {\n const values = probed.map(([a, rd]) => `('${a}',${ts},${ts},${rd},${ts})`).join(\",\");\n await d1(`INSERT INTO wallets (addr,first_seen,last_seen,readable,readable_checked_at) VALUES ${values}\n ON CONFLICT(addr) DO UPDATE SET readable=excluded.readable, readable_checked_at=excluded.readable_checked_at`);\n }\n // final list: walk ranked again with fresh probe results merged in\n const list: LbRow[] = [];\n for (const r of ranked) {\n if (list.length >= LIST_SIZE) break;\n const k = known.get(r.addr);\n const readable = fresh.has(r.addr) ? fresh.get(r.addr) : (k && k.at && ts - k.at < READABLE_TTL ? k.readable : null);\n if (readable === 1) list.push(r);\n }\n await bulkInsert(\"INSERT INTO verified_list (ts,rank,addr,acct,month_pnl,month_roi,all_pnl,steady)\",\n list.map((r, i) => [ts, i + 1, r.addr, r.acct, r.month.pnl, r.month.roi, r.all.pnl, steadiness(r)]));\n if (list.length) {\n await d1(`UPDATE wallets SET listed_at=COALESCE(listed_at, ${ts}), last_seen=${ts} WHERE addr IN (${list.map((r) => `'${r.addr}'`).join(\",\")})`);\n }\n\n // 30-day style stats: userFills is rate-limit-heavy (weight 20/call), so refresh 30 wallets\n // per hourly run, oldest stats first — the whole list cycles every ~N/30 hours.\n const monthAgo = ts - 30 * 864e5;\n const statUpdates: string[] = [];\n const statAges = new Map();\n for (let i = 0; i < list.length; i += 90) {\n const chunk = list.slice(i, i + 90);\n const rows = await d1(`SELECT addr, stats_at FROM wallets WHERE addr IN (${chunk.map((r) => `'${r.addr}'`).join(\",\")})`);\n for (const w of rows) statAges.set(w.addr, w.stats_at ?? 0);\n }\n const statList = [...list].sort((a, b) => (statAges.get(a.addr) ?? 0) - (statAges.get(b.addr) ?? 0)).slice(0, 30);\n for (let i = 0; i < statList.length; i += 10) {\n const chunk = statList.slice(i, i + 10);\n const res = await Promise.allSettled(chunk.map((r) => info({ type: \"userFills\", user: r.addr }) as Promise));\n res.forEach((x, j) => {\n if (x.status !== \"fulfilled\") return;\n const groups = new Map();\n let realized = 0;\n for (const f of x.value) {\n if (f.time < monthAgo) continue;\n const pnl = parseFloat(f.closedPnl ?? \"0\");\n realized += pnl;\n if (!f.dir || !f.dir.startsWith(\"Close\") || !pnl) continue;\n const key = `${f.coin}|${f.dir.includes(\"Long\") ? \"L\" : \"S\"}|${new Date(f.time).toISOString().slice(0, 10)}`;\n groups.set(key, (groups.get(key) ?? 0) + pnl);\n }\n const wins = [...groups.values()].filter((p) => p > 0).length;\n statUpdates.push(`UPDATE wallets SET closes30=${groups.size}, wins30=${wins}, losses30=${groups.size - wins}, realized30=${realized}, stats_at=${ts} WHERE addr='${chunk[j].addr}'`);\n });\n }\n for (const sql of statUpdates) await d1(sql);\n\n return `rows=${total} candidates=${candidates.length} probes=${probed.length} verified=${list.length} stats=${statUpdates.length}${isDaily ? \" +daily\" : \"\"}`;\n}\n\nexport default async function () {\n await logRun(\"leaderboard\", collect);\n}\n",[],[91],"1e9eece3-0c7d-4195-84a8-504336199267",["D",1787887423155],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hyperliquid collectors writing to Cloudflare D1","imageUrl","userId","159ec370-beca-4817-8fff-86948c62b68c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0465b-a310-7790-a32f-8b6426eb6648","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_154":150},"org",{"_11":12,"_147":148,"_149":150,"_109":110,"_151":152,"_153":66},"branch",{"_17":73,"_13":16,"_33":36,"_139":99,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":14,"_146":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":99,"_13":14,"_45":201,"_101":-5,"_102":66,"_103":104,"_105":104,"_106":107,"_108":-5,"_109":110,"_111":-5,"_112":66,"_113":-5,"_114":-5,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_132":202,"_134":203,"_136":204,"_138":66},[186,187,188,189,190],"files",[186,187,188,189,190],"counts",{"_176":116,"_177":75,"_178":116,"_32":179,"_180":181},[],{"_33":34,"_35":36,"_37":38,"_13":19,"_39":40,"_41":42,"_17":43,"_44":-5,"_45":174,"_47":48,"_49":-5,"_18":175},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788546432353],[19],"pulls","branches","forks",{"_182":184,"_185":116},"connections",{"_182":116,"_183":116},"count","unfilledCount",2,"emptyCount",{"_33":90,"_13":91,"_37":92,"_44":-5,"_35":36,"_47":93,"_60":61,"_45":94,"_17":95,"_41":42,"_39":96,"_65":66,"_49":-5,"_67":199,"_18":200},{"_33":82,"_13":83,"_37":84,"_44":-5,"_35":36,"_47":85,"_60":61,"_45":86,"_17":75,"_41":42,"_39":87,"_65":66,"_49":-5,"_67":197,"_18":198},{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_60":61,"_45":79,"_17":43,"_41":42,"_39":40,"_65":66,"_49":-5,"_67":195,"_18":196},{"_33":70,"_13":71,"_37":72,"_44":-5,"_35":36,"_47":73,"_60":61,"_45":74,"_17":75,"_41":42,"_39":76,"_65":66,"_49":-5,"_67":193,"_18":194},{"_33":56,"_13":57,"_37":58,"_44":-5,"_35":36,"_47":59,"_60":61,"_45":62,"_17":63,"_41":42,"_39":64,"_65":66,"_49":-5,"_67":191,"_18":192},[],[57],[],[71],[],[19],[],[83],[],[91],["D",1787887423155],{"_11":12,"_154":150},{"_11":12,"_147":148,"_149":150,"_109":110,"_151":152,"_153":66},{"_17":73,"_13":16,"_33":36,"_139":99,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":14,"_146":12},"ctx",{"_132":-5,"_171":238,"_239":240,"_241":242,"_243":66,"_244":66,"_245":66,"_246":61,"_247":-5,"_248":-7,"_249":-7,"_250":116,"_251":66,"_252":66,"_253":-5,"_254":66,"_255":66,"_256":66,"_257":-5},"ENV",{"_209":210,"_211":212,"_213":16,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]