[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_201":202,"_203":204},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_103":86,"_27":37,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":58,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":56,"_57":58,"_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":25},"version",25,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","levels.ts","latestPath","fileId","4fc39b2a-9e72-11f1-827f-1607ee4eb77e","name","new-file-4232.ts","fileType","script","content","","createdAt",["D",1787434925793],"branchVersion","branchId","9501ca55-9d64-4f95-91aa-9fa7ca96c333","id","2119d995-ca04-498c-aa95-f7a73f7c0d10","ivmodule",["D",1787415250732],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","edb0ee8b-6eb5-4033-8065-92fa86e65418","pinnedFileId","0ca60dd2-9e72-11f1-83cf-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f98c4-b792-72f1-83e7-7d98b5b52c8e","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_102":37},"org",{"_96":95,"_97":37,"_98":37,"_18":54,"_99":100,"_101":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",63,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jfkll","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":197,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":37,"_53":-5,"_18":54,"_55":56,"_57":58,"_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":198,"_80":199,"_82":200,"_84":25},"tree",[176,177,178,179,180],"files",[176,177,178,179,180],"counts",{"_166":62,"_167":152,"_168":62,"_169":170,"_171":172},"contents",[124,125,126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":158,"_32":159,"_30":160,"_131":-5,"_41":42,"_40":161,"_133":58,"_38":162,"_13":163,"_34":35,"_36":164,"_24":25,"_138":-5,"_27":165},{"_43":155,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":25,"_38":156,"_13":152,"_34":35,"_36":37,"_24":25,"_138":-5,"_27":157},{"_43":149,"_32":150,"_30":151,"_131":-5,"_41":42,"_40":152,"_133":25,"_38":153,"_13":62,"_34":35,"_36":37,"_24":25,"_138":-5,"_27":154},{"_43":140,"_32":141,"_30":142,"_131":-5,"_41":42,"_40":143,"_133":58,"_38":144,"_13":145,"_34":146,"_36":147,"_24":25,"_138":-5,"_27":148},{"_43":129,"_32":130,"_30":56,"_131":-5,"_41":42,"_40":132,"_133":25,"_38":134,"_13":135,"_34":136,"_36":137,"_24":25,"_138":-5,"_27":139},"79e08f10-f3c0-4f71-8b7b-ef3d5c9a9413","server.ts","parentId",23,"latest",["D",1787434911383],3,"http","/**\n * server.ts — the gated level endpoint. Deploy as an HTTP val.\n *\n * ARCHITECTURE NOTE, because it drives everything else:\n *\n * The options chain is DELAYED 15 minutes (deliberately - that is what keeps\n * this outside OPRA's display and non-display fee schedule). But the ladder is\n * centred on spot, and a 15-minute-old spot would put every rung in the wrong\n * place. So the client sends its own LIVE NQ price with each request and the\n * server recentres on it.\n *\n * That split is exactly right on the merits, not just the licensing: open\n * interest is a positioning measure that only updates after clearing, so a\n * delay costs almost nothing there. Spot is the part that must be live, and\n * the client already has it.\n *\n * The client also sends the realised-vol inputs, because it holds the NQ bar\n * history and the server does not.\n *\n * GET /levels?nq=24218.75&hod=24291.5&lod=24102.25&frac=0.46\n * &ewma=0.0104&onrv=0.0087&dow=2\n * Header: X-Session: \n */\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport {\n type ChainSnapshot,\n computeLevels,\n DEFAULT_CONFIG,\n type MarketState,\n type OptionQuote,\n} from \"./levels.ts\";\nimport { fromColumnar, gunzip, type Snapshot } from \"./codec.ts\";\n\nconst CACHE_KEY = \"levels_chain_cache\";\nconst CACHE_TTL_MS = 10 * 60_000;\nconst NDX_QQQ_RATIO_FALLBACK = 41.09;\n\n// ---------------------------------------------------------------------------\n// Chain source\n// ---------------------------------------------------------------------------\n\ninterface CachedChain {\n at: number;\n qqqSpot: number;\n quotes: OptionQuote[];\n}\n\nasync function freshChain(): Promise {\n const url = \"https://cdn.cboe.com/api/global/delayed_quotes/options/QQQ.json\";\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n if (!res.ok) throw new Error(`CBOE HTTP ${res.status}`);\n const j: any = await res.json();\n const spot = Number(j?.data?.current_price ?? j?.data?.close);\n if (!(spot > 0)) throw new Error(\"no spot in CBOE payload\");\n\n const today = new Date().toISOString().slice(0, 10).replace(/-/g, \"\");\n const rows: OptionQuote[] = [];\n for (const o of (j?.data?.options ?? [])) {\n const m = String(o.option ?? \"\").match(/^([A-Z_]+)(\\d{6})([CP])(\\d{8})$/);\n if (!m) continue;\n const [, , ymd, right, strikeRaw] = m;\n const expiry = `20${ymd}`;\n if (expiry < today) continue; // drop dead expiries\n const strike = parseInt(strikeRaw, 10) / 1000;\n if (Math.abs(strike / spot - 1) > 0.08) continue; // far strikes carry ~0 gamma\n const iv = Number(o.iv ?? 0);\n const oi = Number(o.open_interest ?? 0);\n if (!(iv > 0) || !(oi > 0)) continue;\n\n const y = +`20${ymd.slice(0, 2)}`,\n mo = +ymd.slice(2, 4),\n da = +ymd.slice(4, 6);\n const days = Math.max(0, (Date.UTC(y, mo - 1, da) - Date.now()) / 864e5);\n rows.push({\n strike,\n right: right as \"C\" | \"P\",\n tau: Math.max(1e-6, days / 365 + (6.5 / 24 / 365) * 0.5),\n iv,\n openInterest: oi,\n });\n }\n if (rows.length < 40) throw new Error(`only ${rows.length} usable contracts`);\n return { at: Date.now(), qqqSpot: spot, quotes: rows };\n}\n\nasync function getChain(): Promise<{ chain: CachedChain; cached: boolean }> {\n try {\n const c = await blob.getJSON(CACHE_KEY) as CachedChain | undefined;\n if (c && Date.now() - c.at < CACHE_TTL_MS && c.quotes?.length) {\n return { chain: c, cached: true };\n }\n } catch { /* cache miss is normal */ }\n const fresh = await freshChain();\n try {\n await blob.setJSON(CACHE_KEY, fresh);\n } catch { /* best effort */ }\n return { chain: fresh, cached: false };\n}\n\n// ---------------------------------------------------------------------------\n// Auth — reuse the existing Discord role gate\n// ---------------------------------------------------------------------------\n\nasync function authorised(req: Request): Promise {\n const token = req.headers.get(\"X-Session\") ??\n new URL(req.url).searchParams.get(\"session\");\n if (!token) return false;\n try {\n const rec = await blob.getJSON(`session_${token}`) as\n | { exp?: number }\n | undefined;\n return !!rec && (rec.exp ?? 0) > Date.now();\n } catch {\n return false;\n }\n}\n\n// ---------------------------------------------------------------------------\n\nfunction num(sp: URLSearchParams, k: string, d?: number): number | undefined {\n const v = sp.get(k);\n if (v === null) return d;\n const n = Number(v);\n return Number.isFinite(n) ? n : d;\n}\n\nexport default async function (req: Request): Promise {\n const sp = new URL(req.url).searchParams;\n\n if (!(await authorised(req))) {\n return Response.json({ error: \"unauthorised\" }, { status: 401 });\n }\n\n const nq = num(sp, \"nq\");\n if (!nq || nq <= 0) {\n return Response.json({ error: \"nq (live NQ price) is required\" }, {\n status: 400,\n });\n }\n\n let chain: CachedChain, cached: boolean;\n try {\n ({ chain, cached } = await getChain());\n } catch (e: any) {\n return Response.json({ error: `chain unavailable: ${e?.message ?? e}` }, {\n status: 503,\n });\n }\n\n // QQQ -> NQ mapping. The ratio is measured from the two spots when the client\n // supplies one; otherwise fall back to a constant. This is a RATIO (QQQ to\n // NDX) composed with a BASIS (NDX to NQ carry) - two different conversions,\n // and using a ratio for the second one would drift by tens of NQ points.\n const ratio = num(sp, \"ratio\") ?? NDX_QQQ_RATIO_FALLBACK;\n const basis = num(sp, \"basis\") ?? (nq - chain.qqqSpot * ratio);\n\n const books: ChainSnapshot[] = [{\n symbol: \"QQQ\",\n underlying: chain.qqqSpot,\n multiplier: 100,\n toNqScale: ratio,\n toNqBasis: basis,\n quotes: chain.quotes,\n }];\n\n const mkt: MarketState = {\n nqSpot: nq,\n runningHigh: num(sp, \"hod\") ?? null,\n runningLow: num(sp, \"lod\") ?? null,\n sessionFrac: Math.max(0, Math.min(1, num(sp, \"frac\") ?? 0.5)),\n atmIv: num(sp, \"iv\") ?? 0.20,\n ewmaPastRthRv: num(sp, \"ewma\"),\n overnightRv: num(sp, \"onrv\"),\n dayOfWeek: num(sp, \"dow\"),\n stress: num(sp, \"stress\"),\n };\n\n const t0 = Date.now();\n let out;\n try {\n out = computeLevels(books, mkt, DEFAULT_CONFIG);\n } catch (e: any) {\n return Response.json({ error: `compute failed: ${e?.message ?? e}` }, {\n status: 500,\n });\n }\n\n return Response.json({\n ...out,\n meta: {\n chainAgeSec: Math.round((Date.now() - chain.at) / 1000),\n chainCached: cached,\n contracts: chain.quotes.length,\n qqqSpot: chain.qqqSpot,\n ratio,\n basis,\n computeMs: Date.now() - t0,\n // Stated explicitly so a stale chain can never masquerade as live data.\n chainDelayedMinutes: 15,\n },\n }, { headers: { \"cache-control\": \"no-store\" } });\n}","label",[130],"2fde5d06-aae8-4bd0-9f77-c96ef12e225e","recorder.ts","9694b27e-9e44-11f1-90c3-1607ee4eb77e",18,["D",1787415993679],7,"interval","/**\n * recorder.ts — Val.town scheduled snapshot recorder.\n *\n * PURPOSE: every day this does not run is a day of calibration data you cannot\n * buy back cheaply. Historical intraday chain snapshots are expensive or simply\n * unavailable at retail pricing. Recording your own from a free delayed source\n * costs nothing and starts the clock immediately.\n *\n * LICENSING: this deliberately uses DELAYED data (>=15 min) and stores only\n * what is needed to reconstruct the gamma field. OPRA charges no display or\n * non-display fees on data delayed 15 minutes or more. The derived levels the\n * engine ultimately publishes cannot be reverse-engineered back into a chain,\n * which is the standard test derived-data clauses apply.\n *\n * DEPLOY: paste into a Val.town Val, set type to \"Cron\", schedule below.\n *\n * Recommended cron (UTC, covers the RTH session at 4 points):\n * 35 14,16,18,19 * * 1-5\n * These UTC hours fall inside RTH in BOTH regimes:\n * EDT (UTC-4): 10:35, 12:35, 14:35, 15:35 ET\n * EST (UTC-5): 09:35, 11:35, 13:35, 14:35 ET\n * so no seasonal edit is needed when the US changes clocks.\n *\n * STATUS: the CBOE adapter reached the live endpoint successfully on first\n * run (both QQQ and NDX fetched, parsed, narrowed and written to blob). The\n * only failure was in the index bookkeeping below, now fixed.\n */\n\n// SCOPED blob storage (per-val, Amazon S3). Note the /main.ts suffix - that is\n// what selects scoped over the older global (account-wide, Cloudflare R2)\n// store at \"https://esm.town/v/std/blob\". They are DIFFERENT stores: anything\n// written via the global import will not appear in this val's blob panel.\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport {\n gzip,\n type RecordedQuote,\n type Snapshot,\n toColumnar,\n} from \"./codec.ts\";\n\n// ---------------------------------------------------------------------------\n// Config\n// ---------------------------------------------------------------------------\n\nconst SYMBOLS = [\n { key: \"QQQ\", cboe: \"QQQ\" },\n { key: \"NDX\", cboe: \"_NDX\" }, // CBOE prefixes index symbols with underscore\n];\n\n/** Keep strikes within this many percent of spot. Far strikes carry ~0 gamma. */\nconst STRIKE_WINDOW_PCT = 0.08;\n\n/** Keep this many nearest expiries. 0DTE + next two is plenty. */\nconst MAX_EXPIRIES = 3;\n\n/**\n * Delete snapshots older than this.\n *\n * STORAGE BUDGET - this is the binding constraint, not the cron rate:\n * Val Town free plan = 10 MB total\n * Val Town pro plan = 1024 MB total\n *\n * Uncompressed, one capture round is ~115 KB across both symbols, so 4 runs a\n * day is ~460 KB/day and the FREE TIER FILLS IN ABOUT THREE WEEKS. With\n * columnar layout + gzip below, a round drops to roughly 12-18 KB, so:\n * free tier ~= 5-7 months of history\n * pro tier ~= many years\n *\n * If you stay on free, drop RETAIN_DAYS to ~150 or move to 2 runs/day.\n */\nconst RETAIN_DAYS = 200;\n\n/**\n * Which scheduled run does the retention sweep. MUST be one of the UTC hours\n * in your cron expression or the sweep silently never runs.\n * Cron: 35 14,16,18,19 * * 1-5\n */\nconst RETENTION_SWEEP_UTC_HOUR = 14;\n\n// ---------------------------------------------------------------------------\n// CBOE delayed-quote adapter\n// ---------------------------------------------------------------------------\n\n/**\n * CBOE publishes a free delayed chain as a single JSON document per symbol.\n * Option symbols are OCC-format: ROOT + YYMMDD + C|P + strike*1000 padded to 8.\n */\nfunction parseOccSymbol(\n occ: string,\n): { expiry: string; right: \"C\" | \"P\"; strike: number } | null {\n const m = occ.match(/^([A-Z_]+)(\\d{6})([CP])(\\d{8})$/);\n if (!m) return null;\n const [, , ymd, right, strikeRaw] = m;\n const yy = ymd.slice(0, 2);\n const expiry = `20${yy}-${ymd.slice(2, 4)}-${ymd.slice(4, 6)}`;\n return {\n expiry,\n right: right as \"C\" | \"P\",\n strike: parseInt(strikeRaw, 10) / 1000,\n };\n}\n\nasync function fetchCboe(\n cboeSym: string,\n): Promise<{ spot: number; rows: RecordedQuote[] }> {\n const url =\n `https://cdn.cboe.com/api/global/delayed_quotes/options/${cboeSym}.json`;\n const res = await fetch(url, {\n headers: { \"User-Agent\": \"Mozilla/5.0\", Accept: \"application/json\" },\n });\n if (!res.ok) throw new Error(`CBOE ${cboeSym} HTTP ${res.status}`);\n const j: any = await res.json();\n\n const spot = Number(j?.data?.current_price ?? j?.data?.close);\n if (!(spot > 0)) throw new Error(`CBOE ${cboeSym}: no usable spot`);\n\n const raw: any[] = j?.data?.options ?? [];\n const rows: RecordedQuote[] = [];\n for (const o of raw) {\n const p = parseOccSymbol(String(o.option ?? \"\"));\n if (!p) continue;\n rows.push({\n s: p.strike,\n r: p.right,\n e: p.expiry,\n iv: Number(o.iv ?? 0),\n oi: Number(o.open_interest ?? 0),\n v: Number(o.volume ?? 0),\n b: Number(o.bid ?? 0),\n a: Number(o.ask ?? 0),\n });\n }\n return { spot, rows };\n}\n\n// ---------------------------------------------------------------------------\n// Narrowing\n// ---------------------------------------------------------------------------\n\n/**\n * Narrow hard. A full QQQ chain is ~15k contracts; within +/-8% of spot on the\n * three nearest expiries it is a few hundred. Strikes far from spot contribute\n * essentially zero gamma, so nothing of value is lost and blob storage stays\n * comfortably inside the free tier.\n */\nfunction narrow(\n rows: RecordedQuote[],\n spot: number,\n asof: Date,\n): { kept: RecordedQuote[]; expiries: string[]; droppedExpired: number } {\n const lo = spot * (1 - STRIKE_WINDOW_PCT);\n const hi = spot * (1 + STRIKE_WINDOW_PCT);\n\n // Drop expiries that have already passed. CBOE's delayed feed still lists\n // them after the close, and a dead expiry silently eats one of the\n // MAX_EXPIRIES slots while contributing nothing (tau <= 0 => zero gamma).\n const today = asof.toISOString().slice(0, 10);\n const allExpiries = [...new Set(rows.map((r) => r.e))].sort();\n const live = allExpiries.filter((e) => e >= today);\n const droppedExpired = allExpiries.length - live.length;\n\n const expiries = live.slice(0, MAX_EXPIRIES);\n const keepExp = new Set(expiries);\n\n const kept = rows.filter(\n (r) => keepExp.has(r.e) && r.s >= lo && r.s <= hi && r.oi > 0 && r.iv > 0,\n );\n return { kept, expiries, droppedExpired };\n}\n\n// ---------------------------------------------------------------------------\n// Main\n// ---------------------------------------------------------------------------\n\nexport default async function record(): Promise {\n const started = Date.now();\n const now = new Date();\n const stamp = now.toISOString().replace(/[:.]/g, \"-\");\n const results: any[] = [];\n\n for (const sym of SYMBOLS) {\n const t0 = Date.now();\n try {\n const { spot, rows } = await fetchCboe(sym.cboe);\n const { kept, expiries, droppedExpired } = narrow(rows, spot, now);\n\n if (kept.length < 20) {\n results.push({\n sym: sym.key,\n ok: false,\n error: `only ${kept.length} usable contracts`,\n });\n continue;\n }\n\n const snap: Snapshot = {\n sym: sym.key,\n ts: now.toISOString(),\n spot,\n src: \"cboe_delayed\",\n delayed: true,\n v: 2,\n cols: toColumnar(kept, expiries),\n expiries,\n diag: {\n fetched: rows.length,\n kept: kept.length,\n expiries,\n droppedExpired,\n ms: Date.now() - t0,\n },\n };\n\n const raw = JSON.stringify(snap);\n const packed = await gzip(raw);\n await blob.set(`chain_${sym.key}_${stamp}.json.gz`, packed);\n const bytes = packed.byteLength;\n\n // Maintain a lightweight index so the calibration job can enumerate\n // snapshots without listing the whole blob store every time.\n const idxKey = `chainidx_${now.toISOString().slice(0, 10)}`;\n let idx: string[] = [];\n try {\n const existing = await blob.getJSON(idxKey);\n // Val Town's blob.getJSON returns undefined for a missing key rather\n // than throwing, so a bare try/catch never fires and idx stays\n // undefined. Check the shape, don't rely on the catch.\n if (Array.isArray(existing)) idx = existing as string[];\n } catch { /* key does not exist yet - empty index is correct */ }\n idx.push(`chain_${sym.key}_${stamp}.json.gz`);\n await blob.setJSON(idxKey, idx);\n\n results.push({\n sym: sym.key,\n ok: true,\n spot,\n fetched: rows.length,\n kept: kept.length,\n expiries,\n droppedExpired,\n // NAMING MATTERS HERE: `raw` is ALREADY columnar, so raw/bytes measures\n // only the gzip step (~3x), not the total saving. The columnar layout\n // contributes a further ~2.7x on top. Reporting a single \"ratio\" made\n // the pipeline look 3x effective when it is closer to 8x.\n colKb: +(raw.length / 1024).toFixed(1),\n gzKb: +(bytes / 1024).toFixed(1),\n gzipRatio: +(raw.length / bytes).toFixed(1),\n // vs the v1 row-oriented uncompressed format, for comparison against\n // the legacy blobs still sitting in the global store.\n totalRatio: +((kept.length * 92) / bytes).toFixed(1),\n ms: Date.now() - t0,\n });\n } catch (e: any) {\n results.push({ sym: sym.key, ok: false, error: String(e?.message ?? e) });\n }\n }\n\n // Retention sweep, cheap and only once a day.\n if (now.getUTCHours() === RETENTION_SWEEP_UTC_HOUR) {\n try {\n const cutoff = new Date(Date.now() - RETAIN_DAYS * 864e5).toISOString();\n const all = await blob.list(\"chain_\");\n let purged = 0;\n let totalBytes = 0;\n for (const b of all) {\n const m = b.key.match(/chain_[A-Z]+_(\\d{4}-\\d{2}-\\d{2})/);\n if (m && m[1] < cutoff.slice(0, 10)) {\n await blob.delete(b.key);\n purged++;\n } else totalBytes += (b as any).size ?? 0;\n }\n // Surface storage use every day so the 10 MB free ceiling cannot creep up\n // and start failing writes silently mid-calibration.\n results.push({\n retention: {\n purged,\n cutoff: cutoff.slice(0, 10),\n blobsKept: all.length - purged,\n storageMb: +(totalBytes / 1048576).toFixed(2),\n freeTierPct: +((totalBytes / 1048576 / 10) * 100).toFixed(1),\n },\n });\n } catch (e: any) {\n results.push({ retention: { error: String(e?.message ?? e) } });\n }\n }\n\n const summary = {\n ok: results.every((r) => r.ok !== false),\n at: now.toISOString(),\n totalMs: Date.now() - started,\n results,\n };\n\n // Cron ignores the return value, so log it or you will never see it.\n console.log(JSON.stringify(summary, null, 2));\n\n return Response.json(summary, { headers: { \"cache-control\": \"no-store\" } });\n}",[141],"b5612abf-0b8b-4670-b1fd-c8947681999b","main.ts","82693e5a-9e44-11f1-9111-1607ee4eb77e",1,["D",1787415250788],[150],"6dafd32f-1124-4c6f-ac9a-bf8ba89e72c7",["D",1787434925793],[28],"0f012e38-3569-4162-ae43-464945b956ee","codec.ts","1f0b8eb0-9e46-11f1-93fe-1607ee4eb77e",17,["D",1787415978344],2,"/**\n * codec.ts — pure storage format. No I/O, no blob, no network.\n *\n * Separated from recorder.ts so that BOTH the writer (recorder) and the\n * readers (calibration job, level server, local tests) can use it without\n * pulling in Val Town's blob import, which only resolves inside Val Town.\n */\n\nexport interface RecordedQuote {\n s: number; // strike\n r: \"C\" | \"P\"; // right\n e: string; // expiry YYYY-MM-DD\n iv: number;\n oi: number;\n v: number; // volume\n b: number; // bid\n a: number; // ask\n}\n\n/**\n * COLUMNAR layout, not an array of objects.\n *\n * A row-oriented array repeats every field name ~1,200 times per snapshot.\n * Columnar stores each field name once and puts the values in parallel arrays,\n * which also gives gzip long runs of similar numbers to work with. Between the\n * two, a snapshot shrinks by roughly 8-10x. Against a 10 MB free-tier cap that\n * is the difference between three weeks and most of a year of history.\n */\nexport interface Snapshot {\n sym: string;\n ts: string; // ISO timestamp of capture\n spot: number;\n src: string;\n delayed: true;\n v: 2; // schema version - readers MUST check this\n cols: {\n s: number[]; // strike\n r: number[]; // 0 = call, 1 = put\n e: number[]; // index into `expiries`\n iv: number[];\n oi: number[];\n vol: number[];\n b: number[];\n a: number[];\n };\n expiries: string[];\n diag: {\n fetched: number;\n kept: number;\n expiries: string[];\n droppedExpired: number;\n ms: number;\n };\n}\n\nexport function toColumnar(rows: RecordedQuote[], expiries: string[]) {\n const eIdx = new Map(expiries.map((e, i) => [e, i]));\n const c = {\n s: [] as number[],\n r: [] as number[],\n e: [] as number[],\n iv: [] as number[],\n oi: [] as number[],\n vol: [] as number[],\n b: [] as number[],\n a: [] as number[],\n };\n for (const q of rows) {\n c.s.push(q.s);\n c.r.push(q.r === \"C\" ? 0 : 1);\n c.e.push(eIdx.get(q.e) ?? 0);\n // Round to the precision that actually matters. Trailing float noise costs\n // real bytes and buys nothing: IV to 4dp, prices to 2dp.\n c.iv.push(Math.round(q.iv * 1e4) / 1e4);\n c.oi.push(q.oi);\n c.vol.push(q.v);\n c.b.push(Math.round(q.b * 100) / 100);\n c.a.push(Math.round(q.a * 100) / 100);\n }\n return c;\n}\n\n/** Inverse of toColumnar - what the calibration job uses to read snapshots. */\nexport function fromColumnar(snap: Snapshot): RecordedQuote[] {\n const { cols, expiries } = snap;\n const out: RecordedQuote[] = [];\n for (let i = 0; i < cols.s.length; i++) {\n out.push({\n s: cols.s[i],\n r: cols.r[i] === 0 ? \"C\" : \"P\",\n e: expiries[cols.e[i]],\n iv: cols.iv[i],\n oi: cols.oi[i],\n v: cols.vol[i],\n b: cols.b[i],\n a: cols.a[i],\n });\n }\n return out;\n}\n\n/** gzip a string via the platform CompressionStream. */\nexport async function gzip(text: string): Promise {\n const cs = new CompressionStream(\"gzip\");\n const stream = new Blob([text]).stream().pipeThrough(cs);\n const buf = await new Response(stream).arrayBuffer();\n return new Uint8Array(buf);\n}\n\n/** gunzip back to a string. Pair with fromColumnar to read a snapshot. */\nexport async function gunzip(bytes: Uint8Array): Promise {\n const ds = new DecompressionStream(\"gzip\");\n const stream = new Blob([bytes as BlobPart]).stream().pipeThrough(ds);\n return await new Response(stream).text();\n}",[159],"pulls","branches","forks","envVars",{"_173":62,"_175":62},"connections",{"_173":62,"_174":62},"count","unfilledCount","emptyCount",{"_43":158,"_32":159,"_30":160,"_131":-5,"_41":42,"_40":161,"_133":58,"_38":194,"_13":163,"_34":35,"_36":164,"_24":25,"_138":-5,"_182":195,"_27":196},{"_43":155,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":25,"_38":191,"_13":152,"_34":35,"_36":37,"_24":25,"_138":-5,"_182":192,"_27":193},{"_43":149,"_32":150,"_30":151,"_131":-5,"_41":42,"_40":152,"_133":25,"_38":188,"_13":62,"_34":35,"_36":37,"_24":25,"_138":-5,"_182":189,"_27":190},{"_43":140,"_32":141,"_30":142,"_131":-5,"_41":42,"_40":143,"_133":58,"_38":185,"_13":145,"_34":146,"_36":147,"_24":25,"_138":-5,"_182":186,"_27":187},{"_43":129,"_32":130,"_30":56,"_131":-5,"_41":42,"_40":132,"_133":25,"_38":181,"_13":135,"_34":136,"_36":137,"_24":25,"_138":-5,"_182":183,"_27":184},["D",1787434911383],"children",[],[130],["D",1787415993679],[],[141],["D",1787415250788],[],[150],["D",1787434925793],[],[28],["D",1787415978344],[],[159],["D",1787415250732],{"_96":95,"_102":37},{"_96":95,"_97":37,"_98":37,"_18":54,"_99":100,"_101":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_121":234,"_235":236,"_237":238,"_239":25,"_240":25,"_241":25,"_242":58,"_243":-5,"_244":-7,"_245":-7,"_246":62,"_247":25,"_248":25,"_249":-5,"_250":25,"_251":25,"_252":25,"_253":-5},"ENV",{"_205":206,"_207":208,"_209":86,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233},"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","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v25