[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_161":162,"_163":164},"routes/_app.x.$handle.$name",{"_97":96,"_32":44,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":48,"_120":121,"_122":25,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":48},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","Cron.ts","latestPath","fileId","bfdfd478-3027-11f1-825b-42dde27851f2","name","fileType","interval","content","/**\n * Curve/Yearn vesting escrow tracker — Cron val\n *\n * Runs every hour to pull new Deposit events and write them to SQLite.\n * The HTTP val reads from the same DB without triggering any sync.\n *\n * Replace \"YOUR_USERNAME/escrow-http\" below with the actual import path\n * of your HTTP val once it's deployed.\n */\n\nimport { syncAll } from \"https://mud2monarch--2e759c62302611f1b09a42dde27851f2.web.val.run\";\n\nexport const cron = \"0 * * * *\";\n\nexport default async function () {\n const result = await syncAll();\n console.log(\n `[cron] synced — ${result.newRows} new rows, head: ${result.lastBlock}`,\n );\n}","createdAt",["D",1775308477376],"branchVersion","branchId","2e738788-3026-11f1-b09a-42dde27851f2","id","2e72e08a-3026-11f1-b09a-42dde27851f2","banteg-demo",["D",1775307597135],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","019d5893-f4ab-70ab-aed3-3e998c8b0313","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d5893-f4ab-70ab-aed3-435519a2c1dc","tursoName","2e72e08a302611f1b09a42dde27851f2","tursoHostname","2e72e08a302611f1b09a42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500689328],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},"branch",{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",29,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mud2monarch","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCdFR0RWg2WUk2YUx0bTdHYkJCMlpXWEIwaSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":156,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":48,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":157,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":158,"_81":159,"_83":160,"_85":48},"tree",[151],"files",[151],"counts",{"_140":60,"_141":142,"_143":60,"_144":145,"_146":147},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":128,"_32":129,"_30":130,"_131":-5,"_40":41,"_39":132,"_133":48,"_37":134,"_13":135,"_33":136,"_35":137,"_24":48,"_138":-5,"_27":139},"b0969736-3027-11f1-8490-42dde27851f2","main.ts","2e759c62-3026-11f1-b09a-42dde27851f2","parentId",8,"latest",["D",1775308244955],7,"http","/**\n * Curve/Yearn vesting escrow tracker — HTTP val\n *\n * Tracks Deposit events from:\n * veCRV 0x5f3b5DfEb7B28CDbD7FAba78963EE202a494e2A2\n * veYFI 0x90c1f9220d90d3966FbeE24045EDd73E1d588aD5\n *\n * Routes:\n * GET / — server-rendered HTML table (reads from DB, fast)\n * GET /data — JSON snapshot from SQLite\n *\n * Sync is handled by the companion cron val.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ─── Config ───────────────────────────────────────────────────────────────────\n\nexport const CONTRACTS = {\n veCRV: \"0x5f3b5DfEb7B28CDbD7FAba78963EE202a494e2A2\",\n veYFI: \"0x90c1f9220d90d3966FbeE24045EDd73E1d588aD5\",\n} as const;\n\n// Deposit(address indexed provider, uint256 value, uint256 indexed locktime, int128 type, uint256 ts)\n// keccak256(\"Deposit(address,uint256,uint256,int128,uint256)\")\nexport const DEPOSIT_TOPIC =\n \"0x4566dfc29f6f11d13a418c26a02bef7c28bae749d4de47e4e6a7cddea6730d59\";\n\n// Sliding window of 4 RPCs, tried in order from the top of the list.\n// Promise.any() races them; first to resolve wins.\nexport const RPCS = [\n \"https://eth.llamarpc.com\",\n \"https://eth.drpc.org\",\n \"https://singapore.rpc.blxrbdn.com\",\n \"https://uk.rpc.blxrbdn.com\",\n \"https://virginia.rpc.blxrbdn.com\",\n \"https://eth.rpc.blxrbdn.com\",\n \"https://eth.blockrazor.xyz\",\n \"https://eth-mainnet.public.blastapi.io\",\n \"https://eth-mainnet.nodereal.io\",\n \"https://eth.merkle.io\",\n \"https://gateway.tenderly.co/public/mainnet\",\n \"https://mainnet.gateway.tenderly.co\",\n \"https://eth.api.onfinality.io/public\",\n \"https://public-eth.nownodes.io\",\n \"https://rpc.fullsend.to\",\n \"https://rpc.flashbots.net\",\n \"https://rpc.flashbots.net/fast\",\n \"https://ethereum.public.blockpi.network\",\n \"https://0xrpc.io/eth\",\n \"https://rpc.sentio.xyz/mainnet\",\n \"https://eth.meowrpc.com\",\n \"https://rpc.owlracle.info\",\n \"https://ethereum-json-rpc.stakely.io\",\n \"https://eth.api.pocket.network\",\n \"https://eth1.lava.build\",\n \"https://rpc.eth.gateway.fm\",\n \"https://rpc.mevblocker.io\",\n \"https://rpc.mevblocker.io/fast\",\n \"https://api-ethereum-mainnet-reth.n.dwellir.com\",\n \"https://ethereum-rpc.publicnode.com\",\n];\n\nexport const WINDOW = 4; // how many RPCs to race at once\nexport const CHUNK = 2000; // max blocks per eth_getLogs call\nexport const EARLIEST_BLOCK = 24_800_000; // Starting block\n\n// ─── DB init ──────────────────────────────────────────────────────────────────\n\nexport async function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS escrow_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n contract TEXT NOT NULL,\n provider TEXT NOT NULL,\n value TEXT NOT NULL,\n locktime INTEGER NOT NULL,\n type INTEGER NOT NULL,\n block INTEGER NOT NULL,\n tx_hash TEXT NOT NULL,\n log_index INTEGER NOT NULL,\n ts INTEGER NOT NULL,\n UNIQUE(tx_hash, log_index)\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sync_state (\n contract TEXT PRIMARY KEY,\n last_block INTEGER NOT NULL\n )\n `);\n // Seed sync_state if missing\n for (const [name, addr] of Object.entries(CONTRACTS)) {\n await sqlite.execute(\n `INSERT OR IGNORE INTO sync_state(contract, last_block) VALUES(?, ?)`,\n [addr, EARLIEST_BLOCK],\n );\n }\n}\n\n// ─── RPC helpers ──────────────────────────────────────────────────────────────\n\n/** Race the first WINDOW RPCs; on failure slide the window forward */\nexport async function raceRpc(\n method: string,\n params: unknown[],\n rpcOffset = 0,\n): Promise {\n const slice = RPCS.slice(rpcOffset, rpcOffset + WINDOW);\n if (slice.length === 0) throw new Error(\"All RPCs exhausted\");\n\n const races = slice.map((url) =>\n fetch(url, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ jsonrpc: \"2.0\", id: 1, method, params }),\n })\n .then((r) => r.json())\n .then((j: any) => {\n if (j.error) throw new Error(j.error.message);\n return j.result;\n })\n );\n\n try {\n return await Promise.any(races);\n } catch {\n // all in this window failed — slide forward\n return raceRpc(method, params, rpcOffset + WINDOW);\n }\n}\n\nexport async function getBlockNumber(): Promise {\n const hex = (await raceRpc(\"eth_blockNumber\", [])) as string;\n return parseInt(hex, 16);\n}\n\nexport async function getLogs(\n address: string,\n topic: string,\n fromBlock: number,\n toBlock: number,\n): Promise {\n return (await raceRpc(\"eth_getLogs\", [\n {\n address,\n topics: [topic],\n fromBlock: \"0x\" + fromBlock.toString(16),\n toBlock: \"0x\" + toBlock.toString(16),\n },\n ])) as any[];\n}\n\n// ─── ABI decoding ─────────────────────────────────────────────────────────────\n\n/**\n * Deposit(address indexed provider, uint256 value, uint256 indexed locktime, int128 type, uint256 ts)\n *\n * Topics:\n * [0] = event signature hash\n * [1] = provider (indexed)\n * [2] = locktime (indexed)\n *\n * Non-indexed data (3 × 32 bytes):\n * [0..64] value (uint256)\n * [64..128] type (int128, right-padded to 32 bytes)\n * [128..192] ts (uint256)\n */\nexport function decodeDeposit(log: any) {\n const provider = \"0x\" + log.topics[1].slice(26);\n const locktime = parseInt(log.topics[2], 16);\n\n const data = log.data.slice(2); // strip 0x\n const value = BigInt(\"0x\" + data.slice(0, 64)).toString();\n const type_ = parseInt(data.slice(64, 128), 16);\n const ts = parseInt(data.slice(128, 192), 16);\n\n return { provider, value, locktime, type: type_, ts };\n}\n\n// ─── Sync ─────────────────────────────────────────────────────────────────────\n\nexport async function syncContract(\n name: keyof typeof CONTRACTS,\n addr: string,\n currentBlock: number,\n): Promise {\n const rows = await sqlite.execute(\n `SELECT last_block FROM sync_state WHERE contract = ?`,\n [addr],\n );\n const fromBlock = (rows.rows[0][0] as number) + 1;\n if (fromBlock > currentBlock) return 0;\n\n let inserted = 0;\n for (let b = fromBlock; b <= currentBlock; b += CHUNK) {\n const toBlock = Math.min(b + CHUNK - 1, currentBlock);\n const logs = await getLogs(addr, DEPOSIT_TOPIC, b, toBlock);\n\n for (const log of logs) {\n const { provider, value, locktime, type: t, ts } = decodeDeposit(log);\n const block = parseInt(log.blockNumber, 16);\n const logIndex = parseInt(log.logIndex, 16);\n try {\n await sqlite.execute(\n `INSERT OR IGNORE INTO escrow_events\n (contract, provider, value, locktime, type, block, tx_hash, log_index, ts)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n addr,\n provider,\n value,\n locktime,\n t,\n block,\n log.transactionHash,\n logIndex,\n ts,\n ],\n );\n inserted++;\n } catch {\n // UNIQUE constraint — already indexed\n }\n }\n\n await sqlite.execute(\n `UPDATE sync_state SET last_block = ? WHERE contract = ?`,\n [toBlock, addr],\n );\n }\n return inserted;\n}\n\nexport async function syncAll(): Promise<\n { newRows: number; lastBlock: number }\n> {\n await initDb();\n const currentBlock = await getBlockNumber();\n let newRows = 0;\n for (const [name, addr] of Object.entries(CONTRACTS)) {\n newRows += await syncContract(\n name as keyof typeof CONTRACTS,\n addr,\n currentBlock,\n );\n }\n return { newRows, lastBlock: currentBlock };\n}\n\n// ─── Data query ───────────────────────────────────────────────────────────────\n\nasync function queryData() {\n await initDb();\n const events = await sqlite.execute(`\n SELECT contract, provider, value, locktime, type, block, tx_hash, ts\n FROM escrow_events\n ORDER BY block DESC\n LIMIT 500\n `);\n const syncRows = await sqlite.execute(\n `SELECT contract, last_block FROM sync_state`,\n );\n const syncState: Record = {};\n for (const [contract, lastBlock] of syncRows.rows as [string, number][]) {\n syncState[contract] = lastBlock;\n }\n\n // label contract address → name\n const addrToName: Record = {};\n for (const [name, addr] of Object.entries(CONTRACTS)) {\n addrToName[addr.toLowerCase()] = name;\n }\n\n return {\n events: events.rows.map(\n ([contract, provider, value, locktime, type_, block, tx_hash, ts]) => ({\n contract: addrToName[String(contract).toLowerCase()] ?? contract,\n provider,\n value: (BigInt(value as string) / 10n ** 18n).toString(), // convert from wei\n locktime,\n type: type_,\n block,\n tx_hash,\n ts,\n }),\n ),\n syncState,\n };\n}\n\n// ─── HTML render ──────────────────────────────────────────────────────────────\n\nfunction formatDate(ts: number) {\n return new Date(ts * 1000).toISOString().slice(0, 10);\n}\n\nfunction shortAddr(addr: string) {\n return addr.slice(0, 6) + \"…\" + addr.slice(-4);\n}\n\nfunction renderHtml(\n data: Awaited>,\n lastBlock: number,\n) {\n const rows = data.events\n .map(\n (e) =>\n `\n ${e.contract}\n ${\n shortAddr(String(e.provider))\n }\n ${Number(e.value).toLocaleString()}\n ${formatDate(Number(e.locktime))}\n ${formatDate(Number(e.ts))}\n ${Number(e.block).toLocaleString()}\n ${\n String(e.tx_hash).slice(0, 10)\n }…\n `,\n )\n .join(\"\");\n\n const syncLines = Object.entries(data.syncState)\n .map(([addr, block]) => {\n const name = addr.toLowerCase() === CONTRACTS.veCRV.toLowerCase()\n ? \"veCRV\"\n : \"veYFI\";\n return `${name}: ${Number(block).toLocaleString()}`;\n })\n .join(\" · \");\n\n return `\n\n\n\n\nVesting escrows — veCRV / veYFI\n\n\n\n

Vesting escrows

veCRV & veYFI · last 500 events · synced to block ${lastBlock.toLocaleString()}

Synced — block ${lastBlock.toLocaleString()} · ${syncLines}

\n\n \n \n \n \n ${rows}\n

Contract	Provider	Amount (tokens)	Unlock date	Event date	Block	Tx

\n\n`;\n}\n\n// ─── HTTP handler ─────────────────────────────────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n // GET /data — JSON snapshot\n if (url.pathname === \"/data\") {\n const data = await queryData();\n const syncRows = await sqlite.execute(\n `SELECT MAX(last_block) FROM sync_state`,\n );\n const lastBlock = (syncRows.rows[0][0] as number) ?? 0;\n return Response.json({ ...data, lastBlock });\n }\n\n // GET / — server-rendered HTML (read-only, no sync)\n await initDb();\n const data = await queryData();\n const syncRows = await sqlite.execute(\n `SELECT MAX(last_block) FROM sync_state`,\n );\n const lastBlock = (syncRows.rows[0][0] as number) ?? 0;\n return new Response(renderHtml(data, lastBlock), {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n}","label",[129],"pulls","branches",1,"forks","envVars",{"_148":60,"_150":60},"connections",{"_148":60,"_149":60},"count","unfilledCount","emptyCount",{"_42":128,"_32":129,"_30":130,"_131":-5,"_40":41,"_39":132,"_133":48,"_37":152,"_13":135,"_33":136,"_35":137,"_24":48,"_138":-5,"_153":154,"_27":155},["D",1775308244955],"children",[],[129],["D",1775307597135],["D",1789500689328],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":48},{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_124":194,"_195":196,"_197":198,"_199":48,"_200":48,"_201":48,"_202":25,"_203":-5,"_204":-7,"_205":-7,"_206":60,"_207":48,"_208":48,"_209":-5,"_210":48,"_211":48,"_212":48,"_213":-5},"ENV",{"_165":166,"_167":168,"_169":87,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v13