[{"_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",{"_93":92,"_31":43,"_102":83,"_26":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":24,"_117":118,"_119":24,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",22,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","collect_market.ts","latestPath","fileId","407a18a2-a2a9-11f1-be21-1607ee4eb77e","name","fileType","interval","content","// 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","createdAt",["D",1787898323999],"branchVersion","branchId","2f8d3a04-8992-41d7-bc26-0ad8163eadcf","id","1e9eece3-0c7d-4195-84a8-504336199267","hypercharted-collectors",["D",1787887423155],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hyperliquid collectors writing to Cloudflare D1","imageUrl","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",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"isOwned",28,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","emozh","handle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":201,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":202,"_77":203,"_79":204,"_81":24},"tree",[180,181,182,183,184],"files",[180,181,182,183,184],"counts",{"_168":59,"_169":170,"_171":59,"_172":173,"_174":175},"contents",[124,125,126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":160,"_31":161,"_29":162,"_132":-5,"_39":40,"_38":163,"_134":24,"_36":164,"_13":165,"_32":33,"_34":166,"_23":24,"_140":-5,"_26":167},{"_41":157,"_31":27,"_29":30,"_132":-5,"_39":40,"_38":14,"_134":24,"_36":158,"_13":59,"_32":33,"_34":35,"_23":24,"_140":-5,"_26":159},{"_41":149,"_31":150,"_29":151,"_132":-5,"_39":40,"_38":152,"_134":24,"_36":153,"_13":154,"_32":33,"_34":155,"_23":24,"_140":-5,"_26":156},{"_41":142,"_31":143,"_29":144,"_132":-5,"_39":40,"_38":145,"_134":24,"_36":146,"_13":59,"_32":33,"_34":147,"_23":24,"_140":-5,"_26":148},{"_41":129,"_31":130,"_29":131,"_132":-5,"_39":40,"_38":133,"_134":135,"_36":136,"_13":137,"_32":138,"_34":139,"_23":24,"_140":-5,"_26":141},"12dbe11d-55c5-4ad5-82ed-02c57a05c31b","lib.ts","df72ade4-a28f-11f1-be32-1607ee4eb77e","parentId",17,"latest",true,["D",1787895284036],3,"script","// 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","label",[130],"c48b3f71-b14f-49b7-b341-4b48781b59e5","collect_vaults.ts","e026874c-a28f-11f1-9829-1607ee4eb77e",4,["D",1787887424962],"// 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",[143],"445fb0ce-3afc-493e-8830-4c5c1eb7f452","collect_positions.ts","dfeee1ac-a28f-11f1-b625-1607ee4eb77e",20,["D",1787895771691],9,"// 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\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 return `wallets=${addrs.length} positions=${rows.length} fills=${fillRows.length} alerts=${alerts} errors=${errors}`;\n}\n\nexport default async function () {\n await logRun(\"positions\", collect);\n}\n",[150],"3aa66f9c-b306-4877-b64b-c2b5250a30a0",["D",1787898323999],[27],"1b6699aa-5b85-41d0-b5c5-c81433c5ec22","collect_lb.ts","dfb8ff88-a28f-11f1-a685-1607ee4eb77e",21,["D",1787896008966],5,"// 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",[161],"pulls","branches",1,"forks","envVars",{"_176":178,"_179":59},"connections",{"_176":59,"_177":59},"count","unfilledCount",2,"emptyCount",{"_41":160,"_31":161,"_29":162,"_132":-5,"_39":40,"_38":163,"_134":24,"_36":198,"_13":165,"_32":33,"_34":166,"_23":24,"_140":-5,"_186":199,"_26":200},{"_41":157,"_31":27,"_29":30,"_132":-5,"_39":40,"_38":14,"_134":24,"_36":195,"_13":59,"_32":33,"_34":35,"_23":24,"_140":-5,"_186":196,"_26":197},{"_41":149,"_31":150,"_29":151,"_132":-5,"_39":40,"_38":152,"_134":24,"_36":192,"_13":154,"_32":33,"_34":155,"_23":24,"_140":-5,"_186":193,"_26":194},{"_41":142,"_31":143,"_29":144,"_132":-5,"_39":40,"_38":145,"_134":24,"_36":189,"_13":59,"_32":33,"_34":147,"_23":24,"_140":-5,"_186":190,"_26":191},{"_41":129,"_31":130,"_29":131,"_132":-5,"_39":40,"_38":133,"_134":135,"_36":185,"_13":137,"_32":138,"_34":139,"_23":24,"_140":-5,"_186":187,"_26":188},["D",1787895284036],"children",[],[130],["D",1787887424962],[],[143],["D",1787895771691],[],[150],["D",1787898323999],[],[27],["D",1787896008966],[],[161],["D",1787887423155],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_121":238,"_239":240,"_241":242,"_243":24,"_244":24,"_245":24,"_246":135,"_247":-5,"_248":-7,"_249":-7,"_250":59,"_251":24,"_252":24,"_253":-5,"_254":24,"_255":24,"_256":24,"_257":-5},"ENV",{"_209":210,"_211":212,"_213":83,"_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"]

Diff · v22