[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_103":104,"_105":106},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","emozh","name","hypercharted-collectors","path","collect_positions.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":-5,"_58":42,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/emozh/hypercharted-collectors/code/collect_positions.ts","extension","id","7a0e7f9d-c22e-46cd-a6fd-b8837ade34a2","fileId","dfeee1ac-a28f-11f1-b625-1607ee4eb77e","parentId","branchId","2f8d3a04-8992-41d7-bc26-0ad8163eadcf","branchVersion",26,"latest",true,"createdAt",["D",1788546432353],"version",12,"fileType","script","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","deleted",false,"label",[14],"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",{"_9":10,"_102":98},"org",{"_9":10,"_95":96,"_97":98,"_55":56,"_99":100,"_101":42},"branch",{"_35":85,"_11":86,"_22":28,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":12,"_94":10},"isOwned",28,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_136":137,"_138":139,"_140":141,"_142":42,"_143":42,"_144":42,"_145":32,"_146":-5,"_147":-7,"_148":-7,"_149":62,"_150":42,"_151":42,"_152":-5,"_153":42,"_154":42,"_155":42,"_156":-5},"ENV",{"_107":108,"_109":110,"_111":86,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]