[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_212":213,"_214":215},"routes/_app.x.$handle.$name",{"_95":94,"_32":44,"_102":85,"_26":36,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":57,"_119":-5,"_120":-5,"_121":122},"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":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":55,"_56":57,"_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":24},"version",27,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":29},"file",{"_30":31,"_32":27,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","new-file-6520.ts","latestPath","numerics.ts","fileId","570981b0-9e72-11f1-8367-1607ee4eb77e","name","fileType","script","content","","createdAt",["D",1787434934878],"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",{"_95":94,"_101":36},"org",{"_95":94,"_96":36,"_97":36,"_18":53,"_98":99,"_100":24},"branch",{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"isOwned",63,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","jfkll","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":208,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":55,"_56":57,"_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":209,"_79":210,"_81":211,"_83":24},"tree",[183,184,185,186,187,188],"files",[183,184,185,186,187,188],"counts",{"_173":61,"_174":155,"_175":61,"_176":177,"_178":179},"contents",[123,124,125,126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":166,"_32":167,"_30":168,"_131":-5,"_40":41,"_39":169,"_133":57,"_37":170,"_13":163,"_33":34,"_35":171,"_23":24,"_138":-5,"_26":172},{"_42":158,"_32":159,"_30":160,"_131":-5,"_40":41,"_39":161,"_133":24,"_37":162,"_13":163,"_33":34,"_35":164,"_23":24,"_138":-5,"_26":165},{"_42":152,"_32":153,"_30":154,"_131":-5,"_40":41,"_39":155,"_133":24,"_37":156,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_26":157},{"_42":149,"_32":27,"_30":31,"_131":-5,"_40":41,"_39":14,"_133":24,"_37":150,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_26":151},{"_42":140,"_32":141,"_30":142,"_131":-5,"_40":41,"_39":143,"_133":57,"_37":144,"_13":145,"_33":146,"_35":147,"_23":24,"_138":-5,"_26":148},{"_42":129,"_32":130,"_30":55,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":134,"_13":135,"_33":136,"_35":137,"_23":24,"_138":-5,"_26":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],"edd060c2-ca76-425f-a7e4-687a8fb2852d",["D",1787434934878],[27],"b5612abf-0b8b-4670-b1fd-c8947681999b","main.ts","82693e5a-9e44-11f1-9111-1607ee4eb77e",1,["D",1787415250788],[153],"8b9a4f20-fe27-4777-a16c-ba46df7259d5","levels.ts","4fc39b2a-9e72-11f1-827f-1607ee4eb77e",26,["D",1787434928980],2,"/**\n * levels.ts — the Phase 0 pure function.\n *\n * computeLevels(chain, market, config) -> LevelSet\n *\n * No I/O. No clock reads. No randomness. Given identical inputs it returns\n * identical output, which is what makes historical replay and calibration\n * possible at all.\n *\n * Design notes that differ from the report, because building it exposed better\n * choices:\n *\n * 1. sigma_eff = sigma0 / (1 + lambda*Ghat) rather than / (1 - lambda*G).\n * The report's form has a pole at lambda*G -> 1. This form is monotone,\n * bounded and needs no ad-hoc clamp to stay physical.\n *\n * 2. Gamma enters BOTH as an OU reversion rate theta(S) AND as a local vol\n * modifier. These are the same mechanism seen from two angles: theta\n * captures the directional pull toward the gamma centroid, sigma_eff\n * captures the reduction in diffusion. Using only one under-reads the\n * effect; the OU-bands framing needs theta, the report's framing needs\n * sigma_eff, and the truth needs both.\n *\n * 3. The ladder is produced by inverting a monotone P(touch) curve rather\n * than by placing bands at fixed sigma multiples. That is what makes the\n * rungs mean what they claim to mean.\n */\n\nimport {\n bsGamma,\n bsVanna,\n expectedRange,\n firstPassageProb,\n reflectionTouchProb,\n} from \"./numerics.ts\";\nimport {\n detectIvWalls,\n dupireLocalVol,\n fitSvi,\n type IvWall,\n type SmilePoint,\n sviIv,\n type SviParams,\n} from \"./surface.ts\";\n\n// ---------------------------------------------------------------------------\n// Inputs\n// ---------------------------------------------------------------------------\n\nexport interface OptionQuote {\n strike: number;\n right: \"C\" | \"P\";\n /** Expiry in YEARS from the snapshot instant. 0DTE at 14:00 ET ~ 0.0008. */\n tau: number;\n /** This strike's own IV. Never substitute ATM IV — it misprices the wings. */\n iv: number;\n openInterest: number;\n /** Change in OI vs prior session close. Used for the cheap sign proxy. */\n deltaOi?: number;\n /** Change in this contract's price vs prior close. Used for the sign proxy. */\n deltaPrice?: number;\n}\n\nexport interface ChainSnapshot {\n /** \"NDX\" | \"QQQ\" | \"NQ\" — used for notional normalisation. */\n symbol: string;\n /** Spot of THIS book's underlying (NDX index, QQQ share price, NQ future). */\n underlying: number;\n /** Contract multiplier: 100 for NDX/QQQ, 20 for NQ. */\n multiplier: number;\n /** Multiply this book's price axis by this to reach NQ points. */\n toNqScale: number;\n /** Additive basis applied AFTER scaling, in NQ points. Carry, not a ratio. */\n toNqBasis: number;\n quotes: OptionQuote[];\n}\n\nexport interface MarketState {\n /** Current NQ price. */\n nqSpot: number;\n /** Session running high in NQ points, or null pre-open. */\n runningHigh: number | null;\n /** Session running low in NQ points, or null pre-open. */\n runningLow: number | null;\n /** Fraction of the RTH session elapsed, 0 = 09:30 ET, 1 = 16:00 ET. */\n sessionFrac: number;\n /** ATM 0DTE implied vol, annualised. Drives the baseline diffusion. */\n atmIv: number;\n /**\n * Optional measured-vol path. When BOTH are supplied, the engine uses\n * forecastSessionSigma() instead of atmIv, because the measured blend\n * out-predicts implied vol for realised session range (13% better OOS RMSE\n * than EWMA alone; IV carries a variance risk premium that biases it high).\n * Units: session log-return sigma, NOT annualised.\n */\n ewmaPastRthRv?: number;\n overnightRv?: number;\n /** JS day-of-week (0=Sun..6=Sat) for the DOW sigma correction. */\n dayOfWeek?: number;\n /**\n * Volatility stress: sigma_exante / rolling_median_sigma - 1, clipped [0,2].\n * Drives calibration shrinkage. 0 if unknown (calibration applied in full).\n */\n stress?: number;\n}\n\nexport interface EngineConfig {\n /** Gamma -> OU reversion coupling. Calibrate; do not assume. */\n lambdaTheta: number;\n /** Gamma -> local vol coupling. Calibrate; do not assume. */\n lambdaSigma: number;\n /** Baseline OU reversion with zero dealer gamma. Usually small. */\n thetaBaseline: number;\n /** Weight on the dOI x dPrice sign proxy vs the structural prior, 0..1. */\n signProxyWeight: number;\n /** Ladder rungs to emit, as P(touch before close). */\n ladderRungs: number[];\n /** Space grid nodes. 241 is ample; cost is linear. */\n gridNodes: number;\n /** Backward time steps. */\n timeSteps: number;\n /** Grid half-width in units of remaining-session sigma. */\n gridWidthSigmas: number;\n /** Isotonic calibration map as (raw, calibrated) knots. Identity if empty. */\n calibration: Array<[number, number]>;\n /** Apply the measured fat-tail correction to touch probabilities. */\n useFatTailAdjust: boolean;\n /**\n * Shrinks the calibration map toward identity as stress rises:\n * w = 1/(1 + k*stress), final = w*calibrated + (1-w)*raw\n * where stress = sigma_exante / rolling_median_sigma - 1, clipped to [0,2].\n * Worth +0.54% OOS Brier over a plain global map. Marginal. Set 0 to disable.\n */\n stressShrinkK: number;\n /** Use the fitted SVI smile for gamma instead of raw quoted IVs. */\n useSviForGamma: boolean;\n /**\n * Use Dupire local vol from the surface for sigma_eff when >=2 expiries are\n * available. When this succeeds, lambdaSigma is NOT used — sigma_eff is READ\n * from the market rather than fitted, removing a free parameter.\n */\n useDupireLocalVol: boolean;\n /** |z| threshold for the IV-wall curvature detector. */\n ivWallZ: number;\n /** Minimum |residual| in vol points for an IV wall. */\n ivWallMinResidual: number;\n}\n\n/**\n * Fat-tail correction, MEASURED on 2,985 NQ sessions.\n *\n * The Gaussian first-passage law materially under-predicts touch at distance.\n * Realised vs an UPPER BOUND on the Gaussian two-sided rate (4*Phi(-z), which\n * over-counts by ignoring the overlap of the two barriers):\n *\n * z=1.5 Gaussian <=26.7% realised 28.2%\n * z=2.0 Gaussian <= 9.1% realised 13.6%\n * z=2.5 Gaussian <= 2.5% realised 6.3%\n * z=3.0 Gaussian <= 0.5% realised 3.2%\n *\n * Realised exceeds even the upper bound from z=2 out, so this is not an\n * artefact of the approximation. It survives switching to a fast EWMA vol\n * estimator, so it is not a slow-estimator artefact either. Excess kurtosis of\n * daily returns is 23.5.\n *\n * Interpretation: genuine jumps. Applied as a distance-dependent inflation of\n * the tail. This is a stopgap - the principled fix is the compound-Poisson\n * jump term, which needs the event calendar to condition intensity on.\n */\nexport function fatTailAdjust(p: number, z: number): number {\n if (!(z > 1.2)) return p;\n const excess = Math.min(0.06, 0.018 * (z - 1.2));\n return Math.min(1, p + excess);\n}\n\n/**\n * MEASURED gamma coupling. Fitted on 1,987 QQQ sessions, 2018-02 to 2026-01,\n * 22,067 forward 30-minute observations.\n *\n * log(rv^2) = a + b*log(expected_var) + TOD fixed effects + d*log(atm_iv)\n * + e*log(prior_rv^2) + c*Ghat\n *\n * c = -0.1044 95% CI [-0.1168, -0.0944]\n *\n * Since rv ~ exp(c*Ghat/2) and sigma_eff = sigma_0/(1 + lambdaSigma*Ghat)\n * ~ sigma_0*exp(-lambdaSigma*Ghat) for small lambda, the mapping is\n * lambdaSigma = -c/2 = 0.052.\n *\n * An OOS sweep on ladder Brier score puts the optimum around 0.10-0.20 - flat\n * across that range, so 0.10 is chosen as the conservative end of the plateau\n * rather than the peak. Note what the sweep says about the demo's illustrative\n * 0.45: it makes the ladder WORSE than no gamma at all (-1.70% OOS). Guessing\n * this parameter would have been actively harmful.\n *\n * HOW MUCH IS IT WORTH: pooled OOS ladder Brier 0.15134 -> 0.15007, about\n * +0.84%. Real, positive in 6 of 7 walk-forward years, and small. Layer 0\n * carries the skill (0.151 vs 0.245 climatology, ~38%); gamma refines it.\n *\n * WHY lambdaTheta STAYS ZERO: a symmetric placebo run on the same panel found\n * gamma predicts PAST variance about twice as strongly as future variance\n * (backward c = -0.208 vs forward -0.105, P(forward stronger) = 0.000). So\n * gamma is predominantly a contemporaneous measure of vol conditions with a\n * real but secondary forecasting component. That supports scaling the\n * DIFFUSION, which is a variance statement. It does not support a directional\n * DRIFT toward the gamma centroid, which would be a much stronger claim than\n * the evidence carries.\n */\nexport const DEFAULT_CONFIG: EngineConfig = {\n lambdaTheta: 0.0, // measured evidence does not support a drift term\n lambdaSigma: 0.10, // MEASURED (see above); demo's 0.45 was illustrative\n thetaBaseline: 0.0,\n signProxyWeight: 0.6,\n ladderRungs: [0.75, 0.55, 0.35, 0.20],\n gridNodes: 241,\n timeSteps: 60,\n gridWidthSigmas: 3.2,\n /**\n * MEASURED isotonic calibration map, P_touch space.\n *\n * Fitted on 47,995 observations across 3,004 NQ sessions (2014-2026), eight\n * intraday checkpoints per session, both sides. Validated under purged\n * walk-forward CV (train on all prior years, test on the next).\n *\n * WHAT IT IS WORTH: pooled OOS Brier 0.1507 raw -> 0.1488 calibrated, about\n * +1.3%. Small. The raw model already scores 0.1507 against a climatology\n * baseline of 0.2391, so the MODEL carries the skill (~37%) and calibration\n * is polish. Do not expect a calibration map to rescue a weak model.\n *\n * PROVISIONAL: these knots were fitted with sigma driven by EWMA realised\n * vol, because that is what 12 years of OHLCV supports. In production sigma\n * comes from 0DTE ATM implied vol, a different input distribution. The map\n * must be refitted once the recorder has accumulated enough chain history.\n * Until then treat this as a sensible prior, not a finished calibration.\n */\n calibration: [\n [0.02, 0.0],\n [0.08, 0.087],\n [0.14, 0.132],\n [0.2, 0.171],\n [0.26, 0.222],\n [0.32, 0.254],\n [0.38, 0.32],\n [0.44, 0.343],\n [0.5, 0.403],\n [0.56, 0.462],\n [0.62, 0.543],\n [0.68, 0.624],\n [0.74, 0.663],\n [0.8, 0.728],\n [0.86, 0.84],\n [0.92, 0.913],\n [0.98, 0.988],\n ],\n useFatTailAdjust: true,\n stressShrinkK: 1.0,\n useSviForGamma: true,\n useDupireLocalVol: true,\n ivWallZ: 2.0,\n ivWallMinResidual: 0.0015,\n};\n\n// ---------------------------------------------------------------------------\n// Outputs\n// ---------------------------------------------------------------------------\n\nexport type Regime = \"suppressive\" | \"neutral\" | \"amplifying\";\nexport type Stance = \"fade\" | \"extreme_in\" | \"breakout\";\n\nexport interface Level {\n nq: number;\n side: \"upper\" | \"lower\";\n /** The rung this level represents. */\n rung: number;\n pTouch: number;\n pTouchNull: number;\n /** Distance in units of remaining-session sigma. All thresholds live here. */\n z: number;\n /** Nearest gamma wall within half a rung spacing, if any. */\n nearestWall: Wall | null;\n /** Nearest IV wall within half a rung spacing, if any. */\n nearestIvWall: IvWallNq | null;\n stanceWeights: Record;\n}\n\nexport interface Wall {\n nq: number;\n /** Dealer $gamma per 1% move, in NQ-point-normalised units. */\n gammaNotional: number;\n /** Positive = dealers long gamma here (suppressive). */\n sign: number;\n /** 0..1 confidence in the sign inference. */\n signConfidence: number;\n source: string;\n}\n\n/** An IV wall mapped onto the NQ price axis. */\nexport interface IvWallNq {\n nq: number;\n book: string;\n expiry: number;\n residual: number;\n z: number;\n kind: \"vol_premium\" | \"vol_discount\";\n}\n\nexport interface LevelSet {\n asofSessionFrac: number;\n nqSpot: number;\n /** Remaining-session sigma in NQ points. The unit everything is measured in. */\n sessionSigmaNq: number;\n expectedRangeNq: number;\n regime: {\n state: Regime;\n /** tanh-squashed. SATURATES at +/-1: see gammaSaturated. */\n netGammaNormalised: number;\n /**\n * True when |netGammaNormalised| > 0.99, i.e. the tanh has saturated and\n * the normalised value has stopped carrying magnitude information. The\n * regime call is still valid (the sign is right) but the depth proxy needs\n * rescaling before lambdaTheta can be calibrated meaningfully.\n */\n gammaSaturated: boolean;\n /** Raw net dealer $gamma per 1% move at spot, pre-normalisation. */\n netGammaRaw: number;\n hhi: number;\n gammaCentroidNq: number | null;\n };\n running: {\n pHighSurvives: number | null;\n pLowSurvives: number | null;\n pHighSurvivesNull: number | null;\n pLowSurvivesNull: number | null;\n };\n walls: Wall[];\n ivWalls: IvWallNq[];\n /**\n * Where a gamma wall and an IV wall sit on the same price. Gamma walls come\n * from OPEN INTEREST (positioning, backward-looking, updates after clearing);\n * IV walls come from PRICES (forward-looking, updates every quote). Agreement\n * is a strong level. Disagreement is itself information.\n */\n confluence: Array<\n { nq: number; gammaSign: number; ivKind: string; agree: boolean }\n >;\n levels: Level[];\n diagnostics: {\n contractsUsed: number;\n contractsDropped: number;\n booksMerged: string[];\n layer0Only: boolean;\n surfacesFitted: number;\n sviRmse: number | null;\n localVolSource: \"dupire\" | \"lambda_sigma\" | \"none\";\n };\n}\n\n// ---------------------------------------------------------------------------\n// Intraday variance profile\n// ---------------------------------------------------------------------------\n\n/**\n * MEASURED intraday variance profile for NQ RTH.\n *\n * 26 x 15-minute buckets, 08:30-15:00 CT, normalised to mean 1.0.\n * Estimated from 3,005 clean RTH sessions, 2014-01-02 to 2026-01-30,\n * roll-adjusted (Panama) 1-minute bars.\n *\n * This REPLACES a parametric guess that was materially wrong in both\n * directions: it understated the opening bucket by ~40% and overstated the\n * closing hour by ~35%. Since the ladder's width is driven by remaining\n * variance, that guess made the ladder too tight at the open and too wide\n * into the close - errors in opposite directions at the two times of day\n * when levels matter most.\n *\n * Note bucket 18 (13:00-13:15 CT = 14:00-14:15 ET). The local bump is the\n * FOMC statement release imprinting itself on a 12-year average. It is a\n * calendar effect, not a time-of-day effect, and on non-FOMC days it should\n * be suppressed. Left in for now because removing it needs an event calendar.\n */\nexport const EMPIRICAL_VAR_PROFILE = [\n 2.7173,\n 1.9100,\n 1.9269,\n 1.4734,\n 1.3247,\n 1.0526,\n 1.0029,\n 0.8668,\n 0.8311,\n 0.7520,\n 0.7205,\n 0.6339,\n 0.6279,\n 0.5752,\n 0.6522,\n 0.6320,\n 0.6341,\n 0.6046,\n 0.9821,\n 0.7359,\n 0.8010,\n 0.7707,\n 0.8865,\n 0.8171,\n 0.9166,\n 1.1522,\n];\n\n/**\n * Instantaneous variance multiplier at session fraction u, linearly\n * interpolated between bucket centres.\n */\nexport function varianceMultiplier(u: number): number {\n const c = Math.max(0, Math.min(1, u));\n const n = EMPIRICAL_VAR_PROFILE.length;\n const x = c * n - 0.5;\n if (x <= 0) return EMPIRICAL_VAR_PROFILE[0];\n if (x >= n - 1) return EMPIRICAL_VAR_PROFILE[n - 1];\n const i = Math.floor(x);\n const w = x - i;\n return EMPIRICAL_VAR_PROFILE[i] * (1 - w) + EMPIRICAL_VAR_PROFILE[i + 1] * w;\n}\n\n/** Remaining variance fraction of a full session, from u to close. */\nexport function remainingVarianceFraction(u: number, nQuad = 64): number {\n const a = Math.max(0, Math.min(1, u));\n if (a >= 1) return 0;\n let acc = 0;\n const h = (1 - a) / nQuad;\n for (let i = 0; i < nQuad; i++) {\n const m0 = varianceMultiplier(a + i * h);\n const m1 = varianceMultiplier(a + (i + 1) * h);\n acc += 0.5 * (m0 + m1) * h;\n }\n return acc;\n}\n\n// ---------------------------------------------------------------------------\n// Session volatility forecast\n// ---------------------------------------------------------------------------\n\n/**\n * MEASURED session-sigma forecast.\n *\n * Sigma sets the width of every rung, so it is the single highest-leverage\n * input in the engine. Fitted on 3,004 NQ sessions (2014-2026):\n *\n * log(RTH_rv) = -0.030 + 0.509*log(EWMA_past_RTH_rv) + 0.455*log(overnight_rv)\n *\n * in-sample R2 0.711 (EWMA alone) -> 0.788 (+ overnight)\n * OOS RMSE 0.3095 -> 0.2692 (13% better)\n *\n * The overnight session carries almost as much weight as five days of RTH\n * history (0.455 vs 0.509). That is a large effect and it is free - the\n * information is sitting in the Globex tape every morning before the open.\n *\n * NOTE ON IMPLIED VOL: once the recorder has chain history, ATM IV should join\n * this blend and the weights be refitted three-way. IV is forward-looking and\n * should carry real weight, but it also embeds a variance risk premium, so it\n * is a biased estimator of realised vol and cannot simply replace this.\n */\n/**\n * MEASURED day-of-week correction to the sigma forecast. Index 0 = Monday.\n *\n * The blend above is BIASED by weekday, strongly and significantly:\n *\n * Mon x0.9016 (t = -8.28) Thu x1.0365 (t = +3.58)\n * Tue x1.0046 (t = +0.45) Fri x0.9838 (t = -1.58)\n * Wed x1.0688 (t = +6.30)\n *\n * WHY Monday is the big one: the Sunday-evening-to-Monday-morning Globex\n * session carries weekend gap risk, so its realised vol runs ~9% hot. But that\n * excess is largely weekend news being repriced BEFORE the open - it does not\n * carry into Monday's RTH session. The regression applies one uniform weight to\n * overnight vol, so on Mondays it over-forecasts by ~10%.\n *\n * This mattered beyond the sigma itself: uncorrected, it made Monday's\n * normalised range look 7.9% below average, when the raw range is only 3.7%\n * below. Roughly half of an apparent \"quiet Monday\" effect was this bug.\n *\n * Worth +1.92% OOS RMSE on the log-sigma error. Small, but free and unbiased.\n */\nexport const DOW_SIGMA_CORRECTION = [0.9016, 1.0046, 1.0688, 1.0365, 0.9838];\n\nexport function forecastSessionSigma(\n /** EWMA (halflife ~5 sessions) of past RTH realised vol, log-return units. */\n ewmaPastRth: number,\n /** Realised vol of the overnight Globex session just ended, same units. */\n overnightRv: number,\n /** JS day-of-week, 0=Sunday..6=Saturday. Omit to skip the correction. */\n jsDayOfWeek?: number,\n): number {\n let base: number;\n if (!(ewmaPastRth > 0)) base = overnightRv > 0 ? overnightRv : 0;\n else if (!(overnightRv > 0)) base = ewmaPastRth;\n else {base = Math.exp(\n -0.030 + 0.509 * Math.log(ewmaPastRth) + 0.455 * Math.log(overnightRv),\n );}\n\n if (jsDayOfWeek === undefined) return base;\n const i = jsDayOfWeek - 1; // Mon(1) -> 0 ... Fri(5) -> 4\n if (i < 0 || i > 4) return base; // weekend: no correction\n return base * DOW_SIGMA_CORRECTION[i];\n}\n\n/**\n * NEGATIVE RESULT: monthly OPEX gamma is NOT detectable in NQ price data.\n *\n * OPEX is a calendar-determined spike in dealer gamma, so if gamma suppressed\n * excursion we should see it without any options data. Once day-of-week is\n * controlled (OPEX day is always a Friday, so it must be compared to other\n * Fridays), over 3,003 sessions:\n *\n * OPEX day vs other Fridays -3.90% t = -1.20 (not significant)\n * OPEX week Mon-Fri -3.58% t = -1.94 (marginal)\n * week before OPEX -3.54% t = -1.42 (not significant)\n *\n * The sign is right - suppression - but the magnitude is small and the\n * evidence weak. Worse for the thesis, the era split runs BACKWARDS: the\n * effect is largest in 2014-2018 (-8.3%) and smallest in 2022-2026 (-2.9%),\n * the 0DTE era when gamma effects should be strongest. None are significant\n * and the per-era samples are 35-59 sessions, so this is suggestive at best.\n *\n * For calibration: this is a WEAK PRIOR on lambdaTheta. It does not refute the\n * gamma thesis - OPEX gamma is a blunt monthly proxy for a continuous\n * intraday field, and NQ is enormous relative to any options book - but it\n * argues against expecting a large effect. Set expectations accordingly when\n * the chain history arrives.\n */\nexport const OPEX_GAMMA_EFFECT_IS_WEAK = true;\n\n/**\n * NEGATIVE RESULT, recorded so it does not get re-proposed.\n *\n * Overnight high/low are NOT attractors for the RTH extreme. Measured over the\n * same 3,004 sessions, hit rate vs a chance baseline at matched tolerance:\n *\n * tol 0.05 sigma HOD near ON high 7.8% chance 7.4%\n * tol 0.10 sigma 14.9% chance 14.8%\n * tol 0.20 sigma 28.8% chance 29.6%\n *\n * Indistinguishable from chance, and slightly BELOW it at the widest band.\n * Supporting evidence: RTH takes out the overnight high 64.8% of sessions and\n * the overnight low 57.9%, and only 4.0% of sessions stay entirely inside the\n * overnight range. The overnight range contains nothing.\n *\n * The overnight session is therefore useful for its VOLATILITY (above), not\n * for its levels. No ON-high/ON-low levels are emitted.\n */\nexport const OVERNIGHT_LEVELS_ARE_NOT_PREDICTIVE = true;\n\n// ---------------------------------------------------------------------------\n// Sign inference\n// ---------------------------------------------------------------------------\n\n/**\n * Under $100/mo there is no exchange open-close data and no OPRA trade+quote\n * feed, so per-trade side classification is off the table. This is the best\n * available EOD proxy:\n *\n * OI rose AND contract price rose -> customers opened longs -> dealers SHORT\n * OI rose AND contract price fell -> customers opened shorts -> dealers LONG\n * OI fell -> closing; weak signal, decay toward prior\n *\n * Noisy per strike, but it aggregates. Blended with a structural prior that\n * encodes the persistent call-overwriting population (dealers long calls).\n */\nfunction inferDealerSign(\n q: OptionQuote,\n proxyWeight: number,\n): { sign: number; conf: number } {\n // Structural prior: dealers long calls (overwriting supply), short puts\n // (protection demand). This is a prior, not a fact.\n const prior = q.right === \"C\" ? +1 : -1;\n\n if (\n q.deltaOi === undefined || q.deltaPrice === undefined || q.openInterest <= 0\n ) {\n return { sign: prior, conf: 0.3 };\n }\n\n const turnover = Math.min(\n 1,\n Math.abs(q.deltaOi) / Math.max(1, q.openInterest),\n );\n if (q.deltaOi <= 0 || turnover < 0.02) {\n return { sign: prior, conf: 0.3 + 0.2 * turnover };\n }\n\n const proxy = q.deltaPrice > 0 ? -1 : +1; // customer bought -> dealer short\n const blended = proxyWeight * proxy * turnover + (1 - proxyWeight) * prior;\n const sign = blended >= 0 ? +1 : -1;\n const conf = Math.min(0.9, 0.3 + 0.6 * turnover * proxyWeight);\n return { sign, conf };\n}\n\n// ---------------------------------------------------------------------------\n// Gamma field\n// ---------------------------------------------------------------------------\n\n// ---------------------------------------------------------------------------\n// Surface layer\n// ---------------------------------------------------------------------------\n\nexport interface BookSurface {\n book: string;\n expiry: number; // tau in years\n fit: SviParams;\n ivWalls: IvWall[];\n forward: number; // this book's forward for that expiry\n toNqScale: number;\n toNqBasis: number;\n}\n\n/**\n * Fit one SVI smile per (book, expiry) and detect IV walls against it.\n *\n * Weighting by open interest matters: a 2-lot quote at a far strike carries\n * the same IV as a 50,000-lot ATM quote but a fraction of the information.\n * Unweighted fits get dragged around by junk at the wings.\n */\nexport function buildSurfaces(\n books: ChainSnapshot[],\n cfg: EngineConfig,\n): BookSurface[] {\n const out: BookSurface[] = [];\n\n for (const book of books) {\n const byTau = new Map();\n for (const q of book.quotes) {\n if (!(q.tau > 0) || !(q.iv > 0) || !(q.openInterest > 0)) continue;\n const key = Math.round(q.tau * 3650000) / 3650000;\n const arr = byTau.get(key);\n if (arr) arr.push(q);\n else byTau.set(key, [q]);\n }\n\n for (const [tau, quotes] of byTau) {\n const F = book.underlying;\n\n // OTM-only smile: use puts below the forward and calls above. ITM quotes\n // are wide and their IVs are noisy, and including both rights at the same\n // strike double-counts the same information at different quality.\n const pts: SmilePoint[] = [];\n for (const q of quotes) {\n const otm = (q.right === \"P\" && q.strike <= F) ||\n (q.right === \"C\" && q.strike > F);\n if (!otm) continue;\n const k = Math.log(q.strike / F);\n if (!Number.isFinite(k) || Math.abs(k) > 0.30) continue;\n pts.push({\n k,\n iv: q.iv,\n weight: Math.max(1, q.openInterest),\n strike: q.strike,\n });\n }\n if (pts.length < 8) continue;\n\n const fit = fitSvi(pts, tau);\n if (!fit) continue;\n\n out.push({\n book: book.symbol,\n expiry: tau,\n fit,\n ivWalls: detectIvWalls(pts, fit, cfg.ivWallZ, cfg.ivWallMinResidual),\n forward: F,\n toNqScale: book.toNqScale,\n toNqBasis: book.toNqBasis,\n });\n }\n }\n\n return out.sort((a, b) => a.expiry - b.expiry);\n}\n\n/** Look up the fitted IV for a strike, falling back to the quoted value. */\nfunction surfaceIv(\n surfaces: BookSurface[],\n bookSym: string,\n tau: number,\n strike: number,\n forward: number,\n fallback: number,\n): number {\n for (const s of surfaces) {\n if (s.book !== bookSym) continue;\n if (Math.abs(s.expiry - tau) > 1e-9) continue;\n const iv = sviIv(s.fit, Math.log(strike / forward));\n return iv > 0.001 && iv < 5 ? iv : fallback;\n }\n return fallback;\n}\n\ninterface StrikeGamma {\n nq: number;\n signedGammaAt: (nqPrice: number) => number;\n peakNotional: number;\n sign: number;\n signConfidence: number;\n source: string;\n}\n\nfunction buildStrikeGammas(\n books: ChainSnapshot[],\n cfg: EngineConfig,\n surfaces: BookSurface[],\n): { strikes: StrikeGamma[]; used: number; dropped: number } {\n const strikes: StrikeGamma[] = [];\n let used = 0;\n let dropped = 0;\n\n for (const book of books) {\n for (const q of book.quotes) {\n if (!(q.iv > 0) || !(q.tau > 0) || !(q.openInterest > 0)) {\n dropped++;\n continue;\n }\n used++;\n\n const { sign, conf } = inferDealerSign(q, cfg.signProxyWeight);\n const strikeNq = q.strike * book.toNqScale + book.toNqBasis;\n\n // Use the FITTED smile IV, not the raw quote. Quoted IVs are noisy and\n // occasionally absent; the fit smooths them while preserving skew. This\n // is the strike-own-IV requirement done properly rather than by\n // substituting a single ATM number across the chain.\n const ivUse = cfg.useSviForGamma\n ? surfaceIv(\n surfaces,\n book.symbol,\n q.tau,\n q.strike,\n book.underlying,\n q.iv,\n )\n : q.iv;\n\n // Notional normalisation: dollar gamma per 1% move, then expressed on a\n // common NQ-point axis. Raw OI is NOT comparable across these books —\n // an NDX contract carries roughly 41x the notional of a QQQ contract.\n const notionalScale = book.multiplier * q.openInterest * book.toNqScale;\n\n const fn = (nqPrice: number) => {\n const bookSpot = (nqPrice - book.toNqBasis) / book.toNqScale;\n if (!(bookSpot > 0)) return 0;\n const g = bsGamma({\n S: bookSpot,\n K: q.strike,\n tau: q.tau,\n sigma: ivUse,\n });\n // dollar gamma per 1% move\n return sign * g * bookSpot * bookSpot * 0.01 * notionalScale;\n };\n\n const peak = Math.abs(fn(strikeNq));\n\n strikes.push({\n nq: strikeNq,\n signedGammaAt: fn,\n peakNotional: peak,\n sign,\n signConfidence: conf,\n source: `${book.symbol}_${q.right}${q.strike}`,\n });\n }\n }\n\n return { strikes, used, dropped };\n}\n\n// ---------------------------------------------------------------------------\n// Calibration map\n// ---------------------------------------------------------------------------\n\nfunction applyCalibration(p: number, knots: Array<[number, number]>): number {\n if (knots.length < 2) return p;\n if (p <= knots[0][0]) return knots[0][1];\n const last = knots[knots.length - 1];\n if (p >= last[0]) return last[1];\n for (let i = 1; i < knots.length; i++) {\n const [x0, y0] = knots[i - 1];\n const [x1, y1] = knots[i];\n if (p <= x1) {\n const w = (p - x0) / Math.max(1e-12, x1 - x0);\n return y0 + w * (y1 - y0);\n }\n }\n return p;\n}\n\n// ---------------------------------------------------------------------------\n// Stance weighting\n// ---------------------------------------------------------------------------\n\nfunction stanceWeights(\n regime: Regime,\n signConf: number,\n): Record {\n const base: Record> = {\n suppressive: { fade: 0.70, extreme_in: 0.25, breakout: 0.05 },\n neutral: { fade: 0.30, extreme_in: 0.50, breakout: 0.20 },\n // Fade weight is exactly ZERO here, not merely small. Fading a level while\n // dealer hedging amplifies moves is where the drawdowns come from.\n amplifying: { fade: 0.00, extreme_in: 0.30, breakout: 0.70 },\n };\n const w = { ...base[regime] };\n // Low sign confidence pulls everything toward the neutral book.\n const k = Math.max(0, Math.min(1, (signConf - 0.3) / 0.5));\n const n = base.neutral;\n return {\n fade: k * w.fade + (1 - k) * n.fade,\n extreme_in: k * w.extreme_in + (1 - k) * n.extreme_in,\n breakout: k * w.breakout + (1 - k) * n.breakout,\n };\n}\n\n// ---------------------------------------------------------------------------\n// Main entry point\n// ---------------------------------------------------------------------------\n\nexport function computeLevels(\n books: ChainSnapshot[],\n mkt: MarketState,\n cfg: EngineConfig = DEFAULT_CONFIG,\n): LevelSet {\n const S0 = mkt.nqSpot;\n\n // --- remaining-session sigma, variance-time scaled -----------------------\n const SESSION_YEARS = 6.5 / 24 / 365;\n const remFrac = remainingVarianceFraction(mkt.sessionFrac);\n const sessionVarYears = SESSION_YEARS * remFrac;\n // Prefer the measured blend when both realised-vol inputs are present;\n // fall back to implied otherwise.\n const measured =\n mkt.ewmaPastRthRv !== undefined && mkt.overnightRv !== undefined\n ? forecastSessionSigma(mkt.ewmaPastRthRv, mkt.overnightRv, mkt.dayOfWeek)\n : null;\n const sigmaLog = measured !== null\n ? measured * Math.sqrt(Math.max(1e-12, remFrac))\n : mkt.atmIv * Math.sqrt(Math.max(1e-12, sessionVarYears));\n const sessionSigmaNq = sigmaLog * S0;\n\n // --- surface layer -------------------------------------------------------\n const surfaces = buildSurfaces(books, cfg);\n\n // Prefer the INDEX book for the volatility surface: it is the direct\n // underlying, so its smile describes NQ dynamics without a ratio conversion\n // in the middle. Fall back to whichever book fitted the most points.\n const indexSurfaces = surfaces.filter((s) => s.toNqScale === 1);\n const surfPool = indexSurfaces.length >= 2 ? indexSurfaces : surfaces;\n\n // --- gamma field ---------------------------------------------------------\n const { strikes, used, dropped } = buildStrikeGammas(books, cfg, surfaces);\n\n const gammaAt = (nqPrice: number): number => {\n let acc = 0;\n for (const s of strikes) acc += s.signedGammaAt(nqPrice);\n return acc;\n };\n\n const netGammaSpot = gammaAt(S0);\n\n // Normalise gamma to a dimensionless scale so lambda is portable across\n // regimes and notional levels. Scale = median |peak gamma| across strikes\n // within the tradeable window, which is a crude depth proxy. With a real\n // depth measure from the Rithmic book this should be replaced.\n const nearby = strikes\n .filter((s) => Math.abs(s.nq - S0) < 2.0 * sessionSigmaNq)\n .map((s) => s.peakNotional)\n .sort((a, b) => a - b);\n const depthProxy = nearby.length\n ? Math.max(\n 1e-9,\n nearby[Math.floor(nearby.length / 2)] * Math.max(4, nearby.length) * 0.25,\n )\n : 1e-9;\n\n const gHat = (nqPrice: number) => Math.tanh(gammaAt(nqPrice) / depthProxy);\n\n // --- walls ---------------------------------------------------------------\n const wallMap = new Map();\n for (const s of strikes) {\n if (Math.abs(s.nq - S0) > 3.0 * sessionSigmaNq) continue;\n const key = Math.round(s.nq * 4) / 4; // NQ tick\n const prev = wallMap.get(key);\n const contrib = s.sign * s.peakNotional;\n if (prev) {\n prev.gammaNotional += contrib;\n prev.signConfidence = Math.max(prev.signConfidence, s.signConfidence);\n } else {\n wallMap.set(key, {\n nq: key,\n gammaNotional: contrib,\n sign: s.sign,\n signConfidence: s.signConfidence,\n source: s.source,\n });\n }\n }\n const walls = [...wallMap.values()]\n .map((w) => ({ ...w, sign: w.gammaNotional >= 0 ? 1 : -1 }))\n .sort((a, b) => Math.abs(b.gammaNotional) - Math.abs(a.gammaNotional))\n .slice(0, 12);\n\n // --- IV walls, mapped onto the NQ axis -----------------------------------\n const ivWalls: IvWallNq[] = [];\n for (const surf of surfaces) {\n for (const w of surf.ivWalls) {\n const nq = w.strike * surf.toNqScale + surf.toNqBasis;\n if (Math.abs(nq - S0) > 3.0 * sessionSigmaNq) continue;\n ivWalls.push({\n nq: Math.round(nq * 4) / 4,\n book: surf.book,\n expiry: surf.expiry,\n residual: w.residual,\n z: w.z,\n kind: w.kind,\n });\n }\n }\n ivWalls.sort((a, b) => Math.abs(b.residual) - Math.abs(a.residual));\n\n // --- concentration (HHI) -------------------------------------------------\n const window = strikes.filter((s) =>\n Math.abs(s.nq - S0) < 1.5 * sessionSigmaNq\n );\n const total = window.reduce((a, s) => a + s.peakNotional, 0);\n const hhi = total > 0\n ? window.reduce((a, s) => a + Math.pow(s.peakNotional / total, 2), 0)\n : 0;\n\n // --- gamma centroid: the OU anchor --------------------------------------\n let wsum = 0;\n let wacc = 0;\n for (const s of window) {\n const w = s.peakNotional * (s.sign > 0 ? 1 : 0); // only long-gamma pins\n wsum += w;\n wacc += w * s.nq;\n }\n const gammaCentroid = wsum > 0 ? wacc / wsum : null;\n\n // --- regime --------------------------------------------------------------\n const netGammaNorm = Math.tanh(netGammaSpot / depthProxy);\n let state: Regime;\n if (netGammaNorm > 0.15 && hhi > 0.06) state = \"suppressive\";\n else if (netGammaNorm < -0.15) state = \"amplifying\";\n else state = \"neutral\";\n\n const layer0Only = cfg.lambdaTheta === 0 && cfg.lambdaSigma === 0;\n\n // --- PDE grid ------------------------------------------------------------\n const halfWidth = cfg.gridWidthSigmas * sigmaLog;\n const n = cfg.gridNodes;\n const x = new Float64Array(n);\n for (let i = 0; i < n; i++) x[i] = -halfWidth + (2 * halfWidth * i) / (n - 1);\n const spotIdx = Math.round((n - 1) / 2);\n\n const anchorLog = gammaCentroid !== null ? Math.log(gammaCentroid / S0) : 0;\n const tauClock = 1; // work in normalised session time; vol already carries scale\n\n // PRECOMPUTED FIELDS.\n //\n // The gamma field is a function of price only, so it is constant across time\n // steps and across barrier solves. Evaluating it inside the PDE inner loop\n // costs O(nodes x steps x barriers x strikes) — measured at 15 SECONDS on a\n // 155-contract chain, which would blow any serverless budget. Precomputing\n // on the grid makes it O(nodes x strikes), a ~1000x reduction.\n const gHatGrid = new Float64Array(n);\n const thetaGrid = new Float64Array(n);\n const volScaleGrid = new Float64Array(n);\n for (let i = 0; i < n; i++) {\n const g = layer0Only ? 0 : gHat(S0 * Math.exp(x[i]));\n gHatGrid[i] = g;\n thetaGrid[i] = layer0Only ? 0 : cfg.thetaBaseline + cfg.lambdaTheta * g;\n // Monotone, bounded, no pole. Long gamma (g>0) suppresses diffusion.\n volScaleGrid[i] = layer0Only ? 1 : 1 / (1 + cfg.lambdaSigma * g);\n }\n\n // Time-step vol multipliers also precompute: they depend only on tIdx.\n const timeVolMult = new Float64Array(cfg.timeSteps + 1);\n for (let s = 0; s <= cfg.timeSteps; s++) {\n const u = mkt.sessionFrac + (1 - mkt.sessionFrac) * (s / cfg.timeSteps);\n const instVar = varianceMultiplier(u) / Math.max(1e-9, remFrac);\n timeVolMult[s] = Math.sqrt(Math.max(1e-9, instVar));\n }\n\n // Dupire local vol, if the surface supports it. When this works, sigma_eff\n // is READ FROM THE MARKET rather than fitted, and lambdaSigma goes unused.\n // One fewer free parameter is one fewer thing to overfit.\n let localVolSource: \"dupire\" | \"lambda_sigma\" | \"none\" = layer0Only\n ? \"none\"\n : \"lambda_sigma\";\n const dupireGrid = new Float64Array(n);\n if (!layer0Only && cfg.useDupireLocalVol && surfPool.length >= 2) {\n const near = surfPool[0];\n const far = surfPool[1];\n let good = 0;\n for (let i = 0; i < n; i++) {\n const lv = dupireLocalVol(near.fit, far.fit, x[i]);\n if (lv !== null && lv > 0.01 && lv < 3.0) {\n dupireGrid[i] = lv;\n good++;\n }\n }\n // Require most of the grid to resolve. A patchy local vol surface is worse\n // than none: it would silently mix two different vol models across price.\n if (good > 0.8 * n) {\n localVolSource = \"dupire\";\n // Fill any gaps by nearest-neighbour so the PDE sees a continuous field.\n for (let i = 0; i < n; i++) {\n if (dupireGrid[i] > 0) continue;\n let j = i;\n while (j >= 0 && dupireGrid[j] <= 0) j--;\n let k2 = i;\n while (k2 < n && dupireGrid[k2] <= 0) k2++;\n dupireGrid[i] = j >= 0 ? dupireGrid[j] : (k2 < n ? dupireGrid[k2] : 0);\n }\n } else if (!layer0Only) {\n localVolSource = \"lambda_sigma\";\n }\n }\n\n // Dupire returns an ANNUALISED vol; convert to the same remaining-session\n // log-sigma units the rest of the solver works in.\n const dupireScale = new Float64Array(n);\n if (localVolSource === \"dupire\") {\n const atmIdxDup = spotIdx;\n const ref = dupireGrid[atmIdxDup] > 0 ? dupireGrid[atmIdxDup] : mkt.atmIv;\n for (let i = 0; i < n; i++) {\n dupireScale[i] = ref > 0\n ? dupireGrid[i] / ref\n : 1;\n }\n }\n\n const dxGrid = x[1] - x[0];\n const idxOf = (xv: number) => {\n let i = Math.round((xv - x[0]) / dxGrid);\n return i < 0 ? 0 : i > n - 1 ? n - 1 : i;\n };\n\n const driftFn = (xv: number, _tIdx: number) => {\n if (layer0Only) return 0;\n const i = idxOf(xv);\n return thetaGrid[i] * (anchorLog - xv);\n };\n\n const volFn = (xv: number, tIdx: number) => {\n const base = sigmaLog * timeVolMult[tIdx];\n if (layer0Only) return base;\n const i = idxOf(xv);\n // Market-read local vol wins over the fitted lambda_sigma path when it is\n // available and clean, because it needs no calibration at all.\n if (localVolSource === \"dupire\") return base * dupireScale[i];\n return base * volScaleGrid[i];\n };\n\n const touchProbAtIdx = (bIdx: number, upper: boolean): number => {\n if (bIdx === spotIdx) return 1;\n const raw = firstPassageProb({\n x,\n spotIdx,\n drift: driftFn,\n vol: volFn,\n nSteps: cfg.timeSteps,\n tau: tauClock,\n barrierIdx: bIdx,\n upper,\n });\n const z = Math.abs(x[bIdx]) / Math.max(1e-12, sigmaLog);\n const adj = cfg.useFatTailAdjust ? fatTailAdjust(raw, z) : raw;\n const cal = applyCalibration(adj, cfg.calibration);\n // Shrink toward the raw model as stress rises. Measured: the calibration\n // map is fitted mostly on calm sessions and actively HURT in 2018, 2020\n // and 2022 (the 48-63%-stressed years) when applied at full strength.\n const stress = Math.max(0, Math.min(2, mkt.stress ?? 0));\n const w = 1 / (1 + cfg.stressShrinkK * stress);\n return w * cal + (1 - w) * adj;\n };\n\n // --- probability curve, then invert to get the ladder --------------------\n const buildSide = (upper: boolean): Level[] => {\n const idxs: number[] = [];\n const step = 3;\n if (upper) {\n for (let i = spotIdx + step; i < n; i += step) idxs.push(i);\n } else {\n for (let i = spotIdx - step; i >= 0; i -= step) idxs.push(i);\n }\n\n const curve = idxs.map((i) => ({\n idx: i,\n nq: S0 * Math.exp(x[i]),\n p: touchProbAtIdx(i, upper),\n }));\n\n // Enforce monotonicity (guards against tiny CN wiggle near the barrier).\n for (let i = 1; i < curve.length; i++) {\n if (curve[i].p > curve[i - 1].p) curve[i].p = curve[i - 1].p;\n }\n\n const out: Level[] = [];\n for (const rung of cfg.ladderRungs) {\n let found: number | null = null;\n for (let i = 1; i < curve.length; i++) {\n const a = curve[i - 1];\n const b = curve[i];\n if (a.p >= rung && b.p <= rung) {\n const w = (a.p - rung) / Math.max(1e-12, a.p - b.p);\n found = a.nq + w * (b.nq - a.nq);\n break;\n }\n }\n if (found === null) continue;\n\n const dist = Math.abs(found - S0);\n const z = dist / Math.max(1e-9, sessionSigmaNq);\n const nullP = reflectionTouchProb(Math.log(1 + dist / S0), sigmaLog, 1);\n\n const spacing = 0.35 * sessionSigmaNq;\n let nearestWall: Wall | null = null;\n let bestD = Infinity;\n for (const w of walls) {\n const d = Math.abs(w.nq - found);\n if (d < spacing && d < bestD) {\n bestD = d;\n nearestWall = w;\n }\n }\n\n let nearestIvWall: IvWallNq | null = null;\n let bestIvD = Infinity;\n for (const w of ivWalls) {\n const d = Math.abs(w.nq - found);\n if (d < spacing && d < bestIvD) {\n bestIvD = d;\n nearestIvWall = w;\n }\n }\n\n out.push({\n nq: Math.round(found * 4) / 4,\n side: upper ? \"upper\" : \"lower\",\n rung,\n pTouch: rung,\n pTouchNull: nullP,\n z,\n nearestWall,\n nearestIvWall,\n stanceWeights: stanceWeights(\n state,\n nearestWall ? nearestWall.signConfidence : 0.3,\n ),\n });\n }\n return out;\n };\n\n const levels = [...buildSide(true), ...buildSide(false)];\n\n // --- survival of the running extremes ------------------------------------\n const survives = (\n extreme: number | null,\n upper: boolean,\n ): [number | null, number | null] => {\n if (extreme === null) return [null, null];\n const logB = Math.log(extreme / S0);\n if ((upper && logB <= 0) || (!upper && logB >= 0)) return [0, 0];\n let bIdx = Math.round(((logB + halfWidth) / (2 * halfWidth)) * (n - 1));\n bIdx = Math.max(0, Math.min(n - 1, bIdx));\n const p = 1 - touchProbAtIdx(bIdx, upper);\n const pNull = 1 - reflectionTouchProb(Math.abs(logB), sigmaLog, 1);\n return [p, pNull];\n };\n\n const [pHigh, pHighNull] = survives(mkt.runningHigh, true);\n const [pLow, pLowNull] = survives(mkt.runningLow, false);\n\n // --- confluence between the two independent wall families ----------------\n //\n // \"Agree\" is not merely co-location. A long-gamma strike (dealers suppress\n // moves) lining up with a vol_discount strike (market prices LESS vol there)\n // is two independent sources saying the same thing: this is a pin. A\n // long-gamma strike sitting on a vol_premium is a contradiction worth seeing\n // rather than averaging away.\n const confluence: LevelSet[\"confluence\"] = [];\n const tol = 0.12 * sessionSigmaNq;\n for (const gw of walls) {\n for (const iw of ivWalls) {\n if (Math.abs(gw.nq - iw.nq) > tol) continue;\n const agree = (gw.sign > 0 && iw.kind === \"vol_discount\") ||\n (gw.sign < 0 && iw.kind === \"vol_premium\");\n confluence.push({\n nq: gw.nq,\n gammaSign: gw.sign,\n ivKind: iw.kind,\n agree,\n });\n break;\n }\n }\n\n return {\n asofSessionFrac: mkt.sessionFrac,\n nqSpot: S0,\n sessionSigmaNq,\n expectedRangeNq: expectedRange(sigmaLog, 1) * S0,\n regime: {\n state,\n netGammaNormalised: netGammaNorm,\n gammaSaturated: Math.abs(netGammaNorm) > 0.99,\n netGammaRaw: netGammaSpot,\n hhi,\n gammaCentroidNq: gammaCentroid,\n },\n running: {\n pHighSurvives: pHigh,\n pLowSurvives: pLow,\n pHighSurvivesNull: pHighNull,\n pLowSurvivesNull: pLowNull,\n },\n walls,\n ivWalls: ivWalls.slice(0, 12),\n confluence,\n levels,\n diagnostics: {\n contractsUsed: used,\n contractsDropped: dropped,\n booksMerged: books.map((b) => b.symbol),\n layer0Only,\n surfacesFitted: surfaces.length,\n sviRmse: surfaces.length\n ? surfaces.reduce((a, s2) => a + s2.fit.rmse, 0) / surfaces.length\n : null,\n localVolSource,\n },\n };\n}",[159],"0f012e38-3569-4162-ae43-464945b956ee","codec.ts","1f0b8eb0-9e46-11f1-93fe-1607ee4eb77e",17,["D",1787415978344],"/**\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}",[167],"pulls","branches","forks","envVars",{"_180":61,"_182":61},"connections",{"_180":61,"_181":61},"count","unfilledCount","emptyCount",{"_42":166,"_32":167,"_30":168,"_131":-5,"_40":41,"_39":169,"_133":57,"_37":205,"_13":163,"_33":34,"_35":171,"_23":24,"_138":-5,"_190":206,"_26":207},{"_42":158,"_32":159,"_30":160,"_131":-5,"_40":41,"_39":161,"_133":24,"_37":202,"_13":163,"_33":34,"_35":164,"_23":24,"_138":-5,"_190":203,"_26":204},{"_42":152,"_32":153,"_30":154,"_131":-5,"_40":41,"_39":155,"_133":24,"_37":199,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_190":200,"_26":201},{"_42":149,"_32":27,"_30":31,"_131":-5,"_40":41,"_39":14,"_133":24,"_37":196,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_190":197,"_26":198},{"_42":140,"_32":141,"_30":142,"_131":-5,"_40":41,"_39":143,"_133":57,"_37":193,"_13":145,"_33":146,"_35":147,"_23":24,"_138":-5,"_190":194,"_26":195},{"_42":129,"_32":130,"_30":55,"_131":-5,"_40":41,"_39":132,"_133":24,"_37":189,"_13":135,"_33":136,"_35":137,"_23":24,"_138":-5,"_190":191,"_26":192},["D",1787434911383],"children",[],[130],["D",1787415993679],[],[141],["D",1787434934878],[],[27],["D",1787415250788],[],[153],["D",1787434928980],[],[159],["D",1787415978344],[],[167],["D",1787415250732],{"_95":94,"_101":36},{"_95":94,"_96":36,"_97":36,"_18":53,"_98":99,"_100":24},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_120":245,"_246":247,"_248":249,"_250":24,"_251":24,"_252":24,"_253":57,"_254":-5,"_255":-7,"_256":-7,"_257":61,"_258":24,"_259":24,"_260":-5,"_261":24,"_262":24,"_263":24,"_264":-5},"ENV",{"_216":217,"_218":219,"_220":85,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244},"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 · v27