[{"_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",14,"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","collect_positions.ts","latestPath","fileId","dfeee1ac-a28f-11f1-b625-1607ee4eb77e","name","fileType","interval","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 FROM positions WHERE ts=${ts} AND addr IN (${inList})`);\n const prevAll = await d1(`SELECT addr, coin, szi, notional 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 const ok = (a: string) => okCur.has(a) && (okPrev.size === 0 || okPrev.has(a)); // old snapshots predate sentinels\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 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} — ${usd(p.notional)}`);\n else if (Math.abs(p.szi) > Math.abs(q.szi) * 1.15) add(p.addr, `added to ${side} ${p.coin} — now ${usd(p.notional)}`);\n else if (Math.abs(p.szi) < Math.abs(q.szi) * 0.85) add(p.addr, `reduced ${side} ${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 ${usd((q as any).notional)}`);\n }\n let sent = 0;\n for (const [addr, lines] of events) {\n const text = `🔔 ${callsign(addr)}\\n${lines.map((l) => \"• \" + l).join(\"\\n\")}\\n${SITE}/#/t/${addr}`;\n for (const s of subs.filter((x: any) => x.addr === addr)) { await tgSend(s.chat_id, text); sent++; }\n }\n return sent;\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 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 // 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","// 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 FROM positions WHERE ts=${ts} AND addr IN (${inList})`);\n const prevAll = await d1(`SELECT addr, coin, szi, notional 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 const ok = (a: string) => okCur.has(a) && (okPrev.size === 0 || okPrev.has(a)); // old snapshots predate sentinels\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 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} — ${usd(p.notional)}`);\n else if (Math.abs(p.szi) > Math.abs(q.szi) * 1.15) add(p.addr, `added to ${side} ${p.coin} — now ${usd(p.notional)}`);\n else if (Math.abs(p.szi) < Math.abs(q.szi) * 0.85) add(p.addr, `reduced ${side} ${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 ${usd((q as any).notional)}`);\n }\n let sent = 0;\n for (const [addr, lines] of events) {\n const text = `🔔 ${callsign(addr)}\\n${lines.map((l) => \"• \" + l).join(\"\\n\")}\\n${SITE}/#/t/${addr}`;\n for (const s of subs.filter((x: any) => x.addr === addr)) { await tgSend(s.chat_id, text); sent++; }\n }\n return sent;\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 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","createdAt",["D",1787891837631],"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":161,"_162":61,"_163":164,"_165":166},"contents",[126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":152,"_32":153,"_30":154,"_133":-5,"_41":42,"_40":155,"_135":25,"_38":156,"_13":145,"_33":34,"_35":157,"_24":25,"_140":-5,"_27":158},{"_43":149,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":150,"_13":145,"_33":34,"_35":37,"_24":25,"_140":-5,"_27":151},{"_43":142,"_32":143,"_30":144,"_133":-5,"_41":42,"_40":145,"_135":25,"_38":146,"_13":61,"_33":34,"_35":147,"_24":25,"_140":-5,"_27":148},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":136,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_27":141},"f761cfa4-595b-4e1f-9a92-b88a78cf3f2d","lib.ts","df72ade4-a28f-11f1-be32-1607ee4eb77e","parentId",12,"latest",["D",1787891836850],2,"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, 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",[131],"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],"0469c9dc-0a03-4407-9b0e-f7a2e29ce3be",["D",1787891837631],[28],"4335f953-bfac-40fd-b4b9-021db8a39e4a","collect_lb.ts","dfb8ff88-a28f-11f1-a685-1607ee4eb77e",13,["D",1787891837209],"// 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 = 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\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",[153],"pulls","branches",1,"forks","envVars",{"_167":137,"_169":61},"connections",{"_167":61,"_168":61},"count","unfilledCount","emptyCount",{"_43":152,"_32":153,"_30":154,"_133":-5,"_41":42,"_40":155,"_135":25,"_38":184,"_13":145,"_33":34,"_35":157,"_24":25,"_140":-5,"_175":185,"_27":186},{"_43":149,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":25,"_38":181,"_13":145,"_33":34,"_35":37,"_24":25,"_140":-5,"_175":182,"_27":183},{"_43":142,"_32":143,"_30":144,"_133":-5,"_41":42,"_40":145,"_135":25,"_38":178,"_13":61,"_33":34,"_35":147,"_24":25,"_140":-5,"_175":179,"_27":180},{"_43":130,"_32":131,"_30":132,"_133":-5,"_41":42,"_40":134,"_135":25,"_38":174,"_13":137,"_33":138,"_35":139,"_24":25,"_140":-5,"_175":176,"_27":177},["D",1787891836850],"children",[],[131],["D",1787887424962],[],[143],["D",1787891837631],[],[28],["D",1787891837209],[],[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 · v14