[{"_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_lb.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_lb.ts","extension","id","e4565823-1f32-4293-8cdb-4db0483f10bf","fileId","dfb8ff88-a28f-11f1-a685-1607ee4eb77e","parentId","branchId","2f8d3a04-8992-41d7-bc26-0ad8163eadcf","branchVersion",25,"latest",true,"createdAt",["D",1788546432057],"version",6,"fileType","script","content","// 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","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"]