[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"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",2,"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_lb.ts","latestPath","fileId","dfb8ff88-a28f-11f1-a685-1607ee4eb77e","name","fileType","interval","content","// Hourly: leaderboard snapshot + verified list. Schedule: every 1 hour.\nimport { BROAD, CANDIDATE, clearinghouse, d1, bulkInsert, isReadable, LbRow, LIST_SIZE, logRun, normalizeLbRow, steadiness, streamObjects, LEADERBOARD_URL } from \"./lib.ts\";\n\nconst MAX_PROBES = 80;\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 return `rows=${total} candidates=${candidates.length} probes=${probed.length} verified=${list.length}${isDaily ? \" +daily\" : \"\"}`;\n}\n\nexport default async function () {\n await logRun(\"leaderboard\", collect);\n}\n","createdAt",["D",1787887424252],"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":159,"_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":160,"_77":161,"_79":162,"_81":24},"tree",[150,151],"files",[150,151],"counts",{"_140":59,"_141":130,"_142":59,"_143":144,"_145":146},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":137,"_31":27,"_29":30,"_129":-5,"_39":40,"_38":14,"_131":24,"_36":138,"_13":59,"_32":33,"_34":35,"_23":24,"_135":-5,"_26":139},{"_41":126,"_31":127,"_29":128,"_129":-5,"_39":40,"_38":130,"_131":24,"_36":132,"_13":59,"_32":133,"_34":134,"_23":24,"_135":-5,"_26":136},"4c63fe34-a8b0-465a-84e0-6989476b765f","lib.ts","df72ade4-a28f-11f1-be32-1607ee4eb77e","parentId",1,"latest",["D",1787887423778],"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/* ---- 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 = 30;\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",[127],"6c6cdfb7-97ed-48bb-a840-5ad20793bde8",["D",1787887424252],[27],"pulls","branches","forks","envVars",{"_147":14,"_149":59},"connections",{"_147":59,"_148":59},"count","unfilledCount","emptyCount",{"_41":137,"_31":27,"_29":30,"_129":-5,"_39":40,"_38":14,"_131":24,"_36":156,"_13":59,"_32":33,"_34":35,"_23":24,"_135":-5,"_153":157,"_26":158},{"_41":126,"_31":127,"_29":128,"_129":-5,"_39":40,"_38":130,"_131":24,"_36":152,"_13":59,"_32":133,"_34":134,"_23":24,"_135":-5,"_153":154,"_26":155},["D",1787887423778],"children",[],[127],["D",1787887424252],[],[27],["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":196,"_197":198,"_199":200,"_201":24,"_202":24,"_203":24,"_204":205,"_206":-5,"_207":-7,"_208":-7,"_209":59,"_210":24,"_211":24,"_212":-5,"_213":24,"_214":24,"_215":24,"_216":-5},"ENV",{"_167":168,"_169":170,"_171":83,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v2