RotoBombs Model Uploader

\\n

One-time (and reusable) tool to push rotobombs-data.js into this store's blob storage, since the file itself is too large to paste into a Val Town val's own code editor. Bookmark this page — run it again any time the model file changes. This page is served by the store itself, so it always talks to the right place.

\\n\\n Secret (ROTOBOMBS_SNAPSHOT_SECRET)\\n \\n\\n rotobombs-data.js file\\n \\n

\\n\\n \\n \\n\\n

\\n\\n

\\n

Sportsbook Logos

\\n

Upload all 12 sportsbook logo PNGs at once. Each file's name (without extension) becomes its lookup key - e.g. novig.png is served at /logo/novig.png. Select all 12 files together; they upload one at a time.

\\n\\n Secret (ROTOBOMBS_SNAPSHOT_SECRET)\\n \\n\\n Logo image files (select all at once)\\n \\n

\\n\\n \\n\\n

\\n\\n \\n\\n\\n\";\n\n// ---- request handler ------------------------------------------------------\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS_HEADERS });\n }\n\n // ---- GET /snapshot : what the CMS embed fetches on every page load ----\n if (req.method === \"GET\" && (path === \"/snapshot\" || path === \"/data\")) {\n const snapshot = await blob.getJSON(KEY_SNAPSHOT);\n if (!snapshot) {\n return json({ error: \"no snapshot has been published yet\" }, 404);\n }\n const meta = await getMeta();\n const age = msAgo(meta.lastSnapshotAt);\n return json(\n {\n ...snapshot,\n _meta: {\n lastSnapshotAt: meta.lastSnapshotAt,\n modelVersion: meta.modelVersion,\n stale: age != null && age > STALE_AFTER_MS,\n },\n },\n 200,\n { \"Cache-Control\": \"public, max-age=60\" }, // light client/CDN caching; the hourly job refreshes this anyway\n );\n }\n\n // ---- GET /article-feed : compact, article-writing-friendly view of the latest snapshot ----\n // Full /snapshot is enormous (every hitter's full matchup/pitch-mix/event detail) and has\n // repeatedly overflowed size limits in tools that fetch-and-summarize it. This endpoint reads\n // the SAME stored snapshot but returns only the fields the daily HR-props article actually\n // needs, trimmed to two tiers so the payload stays small and reliable to fetch every morning:\n // - the top `detail` candidates (by score) get full detail: matchup prose, best/worst pitch,\n // weather/park, signals — enough to write the headline picks and pivots.\n // - the next `lean` candidates get numbers only (score, tier, odds, +EV fields) — enough to\n // scan the WHOLE slate for the widest usual-vs-tonight gaps and full-lineup stacks without\n // the bulk of per-player prose for bench bats.\n // ?detail=N (default 30) and ?lean=N (default 150) override the two caps; ?min=X filters out\n // candidates below score X entirely (useful once counts grow later in the season).\n if (req.method === \"GET\" && path === \"/article-feed\") {\n const snapshot: any = await blob.getJSON(KEY_SNAPSHOT);\n if (!snapshot) {\n return json({ error: \"no snapshot has been published yet\" }, 404);\n }\n const meta = await getMeta();\n\n // NOTE: \"?? default\" not \"|| default\" — an explicit ?detail=0 or ?lean=0 must mean zero,\n // not fall back to the default (0 is falsy but perfectly valid here).\n const parseIntParam = (name: string, fallback: number) => {\n if (!url.searchParams.has(name)) return fallback;\n const n = Number(url.searchParams.get(name));\n return Number.isFinite(n) ? Math.max(0, n) : fallback;\n };\n const detailN = parseIntParam(\"detail\", 30);\n const leanN = parseIntParam(\"lean\", 150);\n const minScore = url.searchParams.has(\"min\")\n ? Number(url.searchParams.get(\"min\"))\n : null;\n\n const games: any[] = Array.isArray(snapshot.games) ? snapshot.games : [];\n const gameByPk: Record = {};\n games.forEach((g) => {\n if (g.gamePk != null) gameByPk[String(g.gamePk)] = g;\n });\n\n // Doubleheader detection: two games today between the same two teams.\n const pairCounts: Record = {};\n games.forEach((g) => {\n const codes = [g.away?.code, g.home?.code].filter(Boolean).sort();\n const key = codes.join(\"|\");\n if (!key) return;\n (pairCounts[key] = pairCounts[key] || []).push(g.gamePk);\n });\n const doubleheaders = Object.entries(pairCounts)\n .filter(([, pks]) => pks.length > 1)\n .map(([key, pks]) => ({ teams: key.split(\"|\"), gamePks: pks }));\n const dhGameSet = new Set(doubleheaders.flatMap((d) => d.gamePks));\n\n // Candidates carry the DISPLAY abbreviation (c.team, e.g. \"NYY\"/\"LAD\"), not the model's\n // internal team code (e.g. \"NY-A\"/\"LA\") — those differ for the Yankees/Mets, Dodgers/Angels,\n // and both Chicago teams. Match and display on abbr everywhere below so \"vs (NYY)\"\n // never comes out blank for exactly the teams where code !== abbr.\n const trimmedGames = games.map((g) => ({\n gamePk: g.gamePk,\n time: g.time,\n away: {\n abbr: g.away?.abbr || g.away?.code,\n pitcher: g.away?.sp?.name || \"TBD\",\n },\n home: {\n abbr: g.home?.abbr || g.home?.code,\n pitcher: g.home?.sp?.name || \"TBD\",\n },\n venue: g.venue,\n official: !!g.official,\n doubleheader: dhGameSet.has(g.gamePk),\n }));\n\n const oppTeamFor = (c: any) => {\n const g = gameByPk[String(c.gamePk)];\n if (!g) return null;\n const awayAbbr = g.away?.abbr || g.away?.code,\n homeAbbr = g.home?.abbr || g.home?.code;\n if (awayAbbr === c.team) return homeAbbr || null;\n if (homeAbbr === c.team) return awayAbbr || null;\n return null;\n };\n\n let candidates: any[] = Array.isArray(snapshot.candidates)\n ? snapshot.candidates.slice()\n : [];\n candidates.sort((a, b) => (b.score ?? -1) - (a.score ?? -1));\n if (minScore != null && !Number.isNaN(minScore)) {\n candidates = candidates.filter((c) => (c.score ?? -1) >= minScore);\n }\n const totalCandidates = candidates.length;\n\n const leanFields = (c: any, rank: number) => ({\n rank,\n name: c.name,\n team: c.team,\n oppTeam: oppTeamFor(c),\n pitcher: c.pitcher || null,\n gamePk: c.gamePk,\n order: c.order ?? null,\n confirmed: !!c.confirmed,\n score: c.score ?? null,\n tier: c.tier ?? null,\n probGamePct: c.probGame != null\n ? Math.round(c.probGame * 1000) / 10\n : null,\n fairOdds: c.fairOdds ?? null,\n usualOdds: c.usualOdds ?? null,\n oddsGap: c.oddsGap ?? null,\n bookOdds: c.bookOdds ?? null,\n bookName: c.bookName ?? null,\n oddsStatus: c.oddsStatus ?? null,\n // The app's ACTUAL +EV filter (consensusOk in rotobombs-data.js) compares model probability\n // against the real book CONSENSUS probability, not usual-vs-tonight — these three fields are\n // what that comparison needs, kept in the lean tier too so a full-slate scan for real +EV\n // plays doesn't require the detail tier.\n bookConsensusProb: c.bookConsensusProb ?? null,\n consensusEdgePts: c.consensusEdgePts ?? null,\n bookEV: c.bookEV ?? null,\n consensusOk: c.bookConsensusProb == null\n ? null\n : (c.consensusEdgePts != null ? c.consensusEdgePts > 0 : null),\n });\n\n const fullFields = (c: any, rank: number) => ({\n ...leanFields(c, rank),\n venue: c.venue ?? null,\n bookLink: c.bookLink ?? null,\n bookLinkReady: c.bookLinkReady ?? null,\n bestPitch: c.bestPitch\n ? {\n name: c.bestPitch.name,\n usage: c.bestPitch.usage,\n residH: c.bestPitch.residH,\n residP: c.bestPitch.residP,\n }\n : null,\n worstPitch: c.worstPitch\n ? {\n name: c.worstPitch.name,\n usage: c.worstPitch.usage,\n residH: c.worstPitch.residH,\n residP: c.worstPitch.residP,\n }\n : null,\n metricsBase: c.metricsBase\n ? { brl_pct: c.metricsBase.brl_pct, ev_avg: c.metricsBase.ev_avg }\n : null,\n metricsRecent: c.metrics\n ? { brl_pct: c.metrics.brl_pct, ev_avg: c.metrics.ev_avg }\n : null,\n carryFt: c.carryFt ?? null,\n parkAdj: c.parkAdj ?? null,\n wx: c.wx\n ? {\n temp: c.wx.temp,\n dome: c.wx.dome,\n dir: c.wx.dir,\n boost: c.wx.boost,\n summary: c.wx.summary,\n }\n : null,\n signals: Array.isArray(c.signals) ? c.signals : [],\n confidence: c.confidence ?? null,\n explanation: c.explanation ?? null,\n // Zone-overlap check: compares the hitter's own in-zone power grid (\"Zone Power\" — his\n // brl_pct/ev_avg across the 3x3 in-zone grid) against tonight's starter's own in-zone\n // location tendencies (\"Zone Mix\" — his loc_pct across that same grid), weighted so cells\n // he never actually throws to don't move the number. zoneAdjPts is the net, already-applied\n // probability-point nudge (±4 cap); zoneAdjConf is 0-1 sample-size confidence in that number\n // (thin per-cell BBE counts shrink both toward 0). See zoneOverlapAdj() in rotobombs-data.js.\n zoneAdjPts: c.zoneAdjPts ?? null,\n zoneAdjConf: c.zoneAdjConf ?? null,\n });\n\n const detailSlice = candidates.slice(0, detailN).map((c, i) =>\n fullFields(c, i + 1)\n );\n const leanSlice = candidates.slice(detailN, detailN + leanN).map((c, i) =>\n leanFields(c, detailN + i + 1)\n );\n\n const teamsPlaying = Array.from(\n new Set(\n games.flatMap((\n g,\n ) => [g.away?.abbr || g.away?.code, g.home?.abbr || g.home?.code])\n .filter(Boolean),\n ),\n );\n\n return json(\n {\n date: snapshot.date ?? null,\n modelVersion: meta.modelVersion,\n updatedAt: meta.lastSnapshotAt,\n bbeThroughDate: meta.bbeThroughDate,\n slate: {\n teamsPlaying: teamsPlaying.length,\n gameCount: games.length,\n officialGameCount: games.filter((g) => g.official).length,\n doubleheaders,\n },\n games: trimmedGames,\n candidateCount: {\n total: totalCandidates,\n detail: detailSlice.length,\n lean: leanSlice.length,\n },\n candidatesDetail: detailSlice,\n candidatesLean: leanSlice,\n },\n 200,\n { \"Cache-Control\": \"no-store\" },\n );\n }\n\n // ---- GET /state : what the hourly job reads before deciding to recompute ----\n if (req.method === \"GET\" && path === \"/state\") {\n const meta = await getMeta();\n const snapshotAge = msAgo(meta.lastSnapshotAt);\n return json({\n ...meta,\n snapshotAgeMs: snapshotAge,\n stale: snapshotAge != null && snapshotAge > STALE_AFTER_MS,\n });\n }\n\n // ---- GET /model-source : what the cron val fetches and executes each run ----\n if (req.method === \"GET\" && path === \"/model-source\") {\n const code = await blob.get(KEY_MODEL_SOURCE).then((r) => r.text()).catch(\n () => null\n );\n if (!code) {\n return json({\n error:\n \"no model source uploaded yet — use the uploader tool to POST /model-source first\",\n }, 404);\n }\n return new Response(code, {\n headers: {\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n ...CORS_HEADERS,\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n\n // ---- POST /model-source : uploader tool pushes a new copy of rotobombs-data.js ----\n if (req.method === \"POST\" && path === \"/model-source\") {\n const body = await req.json().catch(() => null);\n if (!checkSecret(body)) return unauthorized();\n if (typeof body.code !== \"string\" || !body.code.trim()) {\n return json({ error: \"missing 'code' field\" }, 400);\n }\n await blob.set(KEY_MODEL_SOURCE, body.code);\n const meta = await setMeta({ modelSourceUpdatedAt: nowIso() });\n return json({ ok: true, bytes: body.code.length, meta });\n }\n\n // ---- GET /logo/:name : serves a stored sportsbook logo image (binary, long-cached) ----\n // :name may be given with or without a .png suffix, e.g. /logo/novig or /logo/novig.png\n if (req.method === \"GET\" && path.startsWith(\"/logo/\")) {\n const name = path.slice(\"/logo/\".length).replace(/\\.png$/i, \"\");\n if (!name) return json({ error: \"missing logo name\" }, 400);\n const b64 = await blob.get(`rotobombs:logo:${name}`).then((r) => r.text())\n .catch(() => null);\n if (!b64) return json({ error: `no logo stored for '${name}'` }, 404);\n const bytes = Uint8Array.from(atob(b64), (c) => c.charCodeAt(0));\n return new Response(bytes, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\", // logos essentially never change\n ...CORS_HEADERS,\n },\n });\n }\n\n // ---- POST /logo : uploads/replaces a stored sportsbook logo ----\n // body: { secret, name, dataBase64 } — dataBase64 is the raw base64 (no data: URI prefix)\n if (req.method === \"POST\" && path === \"/logo\") {\n const body = await req.json().catch(() => null);\n if (!checkSecret(body)) return unauthorized();\n if (typeof body.name !== \"string\" || !body.name.trim()) {\n return json({ error: \"missing 'name' field\" }, 400);\n }\n if (typeof body.dataBase64 !== \"string\" || !body.dataBase64.trim()) {\n return json({ error: \"missing 'dataBase64' field\" }, 400);\n }\n const name = body.name.trim().replace(/\\.png$/i, \"\");\n await blob.set(`rotobombs:logo:${name}`, body.dataBase64.trim());\n return json({ ok: true, name, url: `/logo/${name}.png` });\n }\n\n // ---- POST /snapshot : hourly job publishes a freshly computed slate ----\n if (req.method === \"POST\" && path === \"/snapshot\") {\n const body = await req.json().catch(() => null);\n if (!checkSecret(body)) return unauthorized();\n if (!body.snapshot) return json({ error: \"missing 'snapshot' field\" }, 400);\n\n await blob.setJSON(KEY_SNAPSHOT, body.snapshot);\n const meta = await setMeta({\n lastSnapshotAt: nowIso(),\n lastCheckedAt: nowIso(),\n fingerprint: body.fingerprint ?? null,\n modelVersion: body.modelVersion ?? null,\n lastError: null,\n lastErrorAt: null,\n bbeThroughDate: body.snapshot?.meta?.bbeThroughDate ?? null,\n });\n return json({ ok: true, meta });\n }\n\n // ---- POST /heartbeat : hourly job ran, checked, nothing changed ----\n if (req.method === \"POST\" && path === \"/heartbeat\") {\n const body = await req.json().catch(() => null);\n if (!checkSecret(body)) return unauthorized();\n\n const meta = await setMeta({\n lastCheckedAt: nowIso(),\n fingerprint: body.fingerprint ?? undefined,\n lastError: null,\n lastErrorAt: null,\n });\n return json({ ok: true, meta });\n }\n\n // ---- POST /error : hourly job run failed — log it instead of vanishing ----\n if (req.method === \"POST\" && path === \"/error\") {\n const body = await req.json().catch(() => null);\n if (!checkSecret(body)) return unauthorized();\n\n const meta = await setMeta({\n lastCheckedAt: nowIso(),\n lastError: typeof body.message === \"string\"\n ? body.message\n : \"unknown error\",\n lastErrorAt: nowIso(),\n });\n return json({ ok: true, meta });\n }\n\n // ---- GET /uploader : the model-source upload page ----\n if (req.method === \"GET\" && path === \"/uploader\") {\n return new Response(UPLOADER_HTML, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\", ...CORS_HEADERS },\n });\n }\n\n // ---- GET / : tiny human status page ----\n if (req.method === \"GET\" && path === \"/\") {\n const meta = await getMeta();\n const snapshotAge = msAgo(meta.lastSnapshotAt);\n const checkedAge = msAgo(meta.lastCheckedAt);\n const stale = snapshotAge != null && snapshotAge > STALE_AFTER_MS;\n const fmt = (\n ms: number | null,\n ) => (ms == null ? \"never\" : `${Math.round(ms / 60000)} min ago`);\n // How many days old is the batted-ball data behind \"today\" (UTC)? Baseball Savant's own\n // pipeline lag, not anything this job controls — flagged only as a heads-up, not an error.\n const bbeLagDays = meta.bbeThroughDate\n ? Math.round(\n (Date.now() - new Date(meta.bbeThroughDate + \"T00:00:00Z\").getTime()) /\n 86400000,\n )\n : null;\n const bbeLagClass = bbeLagDays == null\n ? \"\"\n : bbeLagDays >= 2\n ? \"warn\"\n : \"ok\";\n const bbeLagNote = bbeLagDays == null\n ? \"\"\n : bbeLagDays <= 0\n ? \" (current)\"\n : ` (${bbeLagDays}d behind — normal overnight lag on Savant's end)`;\n const html =\n `RotoBombs Snapshot Store\n\n\n

RotoBombs Snapshot Store

\n\n\n\n\n\n\n\n\n

Model source uploaded	${\n meta.modelSourceUpdatedAt\n ? fmt(msAgo(meta.modelSourceUpdatedAt))\n : \"never — cron val can't run yet\"\n }
Snapshot published	${\n fmt(snapshotAge)\n }${stale ? \" — STALE (hourly job may be stuck)\" : \"\"}
Last job check-in	${fmt(checkedAge)}
Batted-ball data through	${\n meta.bbeThroughDate ?? \"—\"\n }${bbeLagNote}
Model version	${meta.modelVersion ?? \"—\"}
Fingerprint	`${meta.fingerprint ?? \"—\"}`
Last error	${\n meta.lastError\n ? meta.lastError + \" (\" + fmt(msAgo(meta.lastErrorAt)) + \")\"\n : \"none\"\n }

/snapshot — raw JSON the embed fetches • /state — raw state JSON • /article-feed — compact feed for the daily article

\n`;\n return new Response(html, {\n headers: { \"Content-Type\": \"text/html\", ...CORS_HEADERS },\n });\n }\n\n return json({ error: \"not found\" }, 404);\n}","deleted","label",[109],"pulls","branches",1,"forks","envVars",{"_132":126,"_134":42},"connections",{"_132":42,"_133":42},"count","unfilledCount","emptyCount",{"_18":108,"_20":109,"_110":36,"_111":-5,"_112":68,"_113":66,"_114":38,"_22":136,"_65":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_137":138,"_86":139},["D",1787920360659],"children",[],[109],["D",1787810708580],{"_16":17,"_84":80},{"_16":17,"_77":78,"_79":80,"_33":34,"_81":82,"_83":26},{"_65":66,"_20":67,"_18":68,"_69":19,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":21,"_76":17},"ctx",{"_58":-5,"_104":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":38,"_186":-5,"_187":-7,"_188":-7,"_189":42,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":67,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"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"]

Search