[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_191":192,"_193":194},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","lib.ts","latestPath","fileId","df72ade4-a28f-11f1-be32-1607ee4eb77e","name","fileType","script","content","// 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","// 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, 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 = 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","createdAt",["D",1787889741411],"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",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"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",{"_43":44,"_32":45,"_38":187,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":188,"_79":189,"_81":190,"_83":25},"tree",[170,171,172,173],"files",[170,171,172,173],"counts",{"_159":61,"_160":134,"_161":61,"_162":163,"_164":165},"contents",[126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":152,"_32":153,"_30":154,"_131":-5,"_41":42,"_40":155,"_132":25,"_38":156,"_13":134,"_33":142,"_35":157,"_24":25,"_135":-5,"_27":158},{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_132":25,"_38":149,"_13":134,"_33":142,"_35":150,"_24":25,"_135":-5,"_27":151},{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":25,"_38":141,"_13":61,"_33":142,"_35":143,"_24":25,"_135":-5,"_27":144},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"4191a57d-d5ba-4f05-8c64-dc502f592e08","parentId","latest",["D",1787889741411],1,"label",[28],"c48b3f71-b14f-49b7-b341-4b48781b59e5","collect_vaults.ts","e026874c-a28f-11f1-9829-1607ee4eb77e",4,["D",1787887424962],"interval","// 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",[138],"92ea6f61-0bf0-443d-9266-91de151029a4","collect_positions.ts","dfeee1ac-a28f-11f1-b625-1607ee4eb77e",6,["D",1787888922715],"// Positions + fresh fills of the current verified list. Schedule: every 15 minutes.\nimport { bulkInsert, clearinghouse, d1, info, logRun } from \"./lib.ts\";\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 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: 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 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 return `wallets=${addrs.length} positions=${rows.length} fills=${fillRows.length} errors=${errors}`;\n}\n\nexport default async function () {\n await logRun(\"positions\", collect);\n}\n",[146],"bc782220-2f36-4fa7-983e-a018672db02b","collect_lb.ts","dfb8ff88-a28f-11f1-a685-1607ee4eb77e",5,["D",1787887496505],"// Hourly: leaderboard snapshot + verified list. Schedule: every 1 hour.\nimport { BROAD, CANDIDATE, clearinghouse, d1, bulkInsert, isReadable, LIST_SIZE, logRun, normalizeLbRow, steadiness, streamObjects, LEADERBOARD_URL } from \"./lib.ts\";\nimport type { LbRow } 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",[153],"pulls","branches","forks","envVars",{"_166":168,"_169":61},"connections",{"_166":61,"_167":61},"count","unfilledCount",2,"emptyCount",{"_43":152,"_32":153,"_30":154,"_131":-5,"_41":42,"_40":155,"_132":25,"_38":184,"_13":134,"_33":142,"_35":157,"_24":25,"_135":-5,"_175":185,"_27":186},{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_132":25,"_38":181,"_13":134,"_33":142,"_35":150,"_24":25,"_135":-5,"_175":182,"_27":183},{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":25,"_38":178,"_13":61,"_33":142,"_35":143,"_24":25,"_135":-5,"_175":179,"_27":180},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":174,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_175":176,"_27":177},["D",1787889741411],"children",[],[28],["D",1787887424962],[],[138],["D",1787888922715],[],[146],["D",1787887496505],[],[153],["D",1787887423155],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":224,"_225":226,"_227":228,"_229":25,"_230":25,"_231":25,"_232":233,"_234":-5,"_235":-7,"_236":-7,"_237":61,"_238":25,"_239":25,"_240":-5,"_241":25,"_242":25,"_243":25,"_244":-5},"ENV",{"_195":196,"_197":198,"_199":85,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"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 · v7