[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_379":380,"_381":382},"routes/_app.x.$handle.$name",{"_101":100,"_33":47,"_109":91,"_28":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":27,"_124":125,"_126":25,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_45":46,"_33":47,"_40":48,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":-5,"_18":57,"_58":59,"_60":25,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":27},"version",3,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":34,"_35":36,"_37":39,"_40":41,"_42":14,"_43":44,"_24":27},"previous",{"_31":32,"_33":34,"_35":36,"_37":38},"deleted",true,"deletedHere",false,"path","tools/egress-probe.ts","latestPath","fileId","7da3abe4-aaf6-11f1-855f-1607ee4eb77e","name","egress-probe.ts","fileType","script","content","// Throwaway: does Val Town's egress reach ESPN's scoreboard API?\nconst url = \"https://site.api.espn.com/apis/site/v2/sports/basketball/fiba/scoreboard?dates=20260905\";\ntry {\n const res = await fetch(url);\n const text = await res.text();\n console.log(\"status\", res.status, \"bytes\", text.length);\n console.log(\"head\", text.slice(0, 120));\n} catch (err) {\n console.log(\"threw\", String(err));\n}\n","// Throwaway: does Val Town's egress reach ESPN's scoreboard API?\nconst url = \"https://site.api.espn.com/apis/site/v2/sports/basketball/fiba/scoreboard?dates=20260905\";\nfor (const [name, init] of [\n [\"bare\", {}],\n [\"browser-ua\", { headers: {\n \"user-agent\": \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/140.0 Safari/537.36\",\n \"accept\": \"application/json,text/plain,*/*\",\n } }],\n] as [string, RequestInit][]) {\n try {\n const res = await fetch(url, init);\n const text = await res.text();\n console.log(name, \"status\", res.status, \"bytes\", text.length);\n } catch (err) {\n console.log(name, \"threw\", String(err));\n }\n}\n","createdAt",["D",1788811211556],"branchVersion","branchId","20967dcf-9eb1-4cbf-a721-cf05b71b776a","id","8cd67c66-1c13-4d59-a550-efcd693c834b","source-wfiba",["D",1788811087002],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Women's FIBA World Cup source val","imageUrl","b0a8da26-58e7-4d19-8b5c-eedf487df9a9","pinnedFileId","01a07d73-0d02-703f-be73-09449008031e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","5a10edca-919b-4a78-babb-71908f69af93","tursoName","8cd67c661c134d59a550efcd693c834b","tursoHostname","8cd67c661c134d59a550efcd693c834b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509043237],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_101":100,"_108":104},"org",{"_101":100,"_102":-5,"_103":104,"_18":57,"_105":106,"_107":27},"branch",{"_13":90,"_33":91,"_45":44,"_92":46,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":47,"_99":100},"isOwned",53,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","plusjade","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yVHpab25kTlBTM3M3WmpCa3NMSTd5akVwWksuanBlZyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_45":46,"_33":47,"_40":374,"_49":-5,"_50":27,"_51":52,"_53":52,"_54":55,"_56":-5,"_18":57,"_58":59,"_60":25,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":375,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":376,"_85":377,"_87":378,"_89":27},"tree",[180,194,200,205,206],"files",[180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206],"counts",{"_168":64,"_169":170,"_171":64,"_172":173,"_174":175},"contents",[131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_45":163,"_33":164,"_31":165,"_139":-5,"_43":44,"_42":140,"_141":25,"_40":166,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_28":167},{"_45":158,"_33":159,"_31":160,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":161,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_28":162},{"_45":152,"_33":153,"_31":154,"_139":-5,"_43":44,"_42":140,"_141":25,"_40":155,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_28":157},{"_45":146,"_33":147,"_31":59,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":148,"_13":64,"_35":149,"_37":150,"_24":27,"_144":-5,"_28":151},{"_45":136,"_33":137,"_31":138,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":142,"_13":64,"_35":36,"_37":143,"_24":27,"_144":-5,"_28":145},"c7a751a0-dd53-487f-81b4-bf795b4d14ba","sportsSource.ts","01a07d73-0d02-703f-be73-0d85906ac07b","parentId",1,"latest",["D",1788811087002],"// What makes this val a sports source, and nothing else. Everything the\n// protocol does with this object lives in sdk/ and is the same for every\n// source; everything this object does lives in lib/ and is about games.\n//\n// This file is the seam between them, and it should stay short enough to read\n// in one screen. If it grows a Response, a status code or a protocol field, it\n// has taken on work that belongs to sdk/serve.ts.\n\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { sportsItems } from \"./lib/sportsFeed.ts\";\nimport { saveSourcePayload } from \"./lib/sourceCache.ts\";\nimport { ingestSleeperWindow } from \"./lib/sleeperIngest.ts\";\nimport type { Catalog } from \"./lib/catalog.ts\";\nimport { accept, reject } from \"./sdk/contract.ts\";\nimport { defineSource } from \"./sdk/defineSource.ts\";\n\n// parseSettings' output, not the wire shape. It carries the catalog snapshot\n// it validated against so the read doesn't go back to SQLite for a second\n// copy — and so selection is resolved against exactly the catalog the request\n// was checked against, even if someone edits a team mid-request.\ntype SportsRead = {\n teams: string[];\n intradayFilter: boolean;\n catalog: Catalog;\n};\n\nasync function settingsSchema() {\n const catalog = await readCatalog();\n return {\n type: \"object\",\n properties: {\n teams: {\n type: \"array\", title: \"Teams\", default: [], uniqueItems: true,\n description: \"Choose teams to follow. No selection produces an empty feed.\",\n items: { type: \"string\", oneOf: catalog.competitions.flatMap((competition) =>\n catalog.teams.filter((team) => team.competitionCode === competition.code).map((team) => ({\n const: team.slug, title: team.displayName, \"x-group\": competition.displayName,\n }))) },\n },\n intradayFilter: {\n type: \"boolean\", title: \"Hide a game as soon as it ends\", default: false,\n description: \"When unchecked, keep showing ended games for the rest of the day.\",\n },\n },\n required: [\"teams\"],\n additionalProperties: false,\n };\n}\n\nconst SETTING_KEYS = [\"teams\", \"intradayFilter\"];\n\nexport default defineSource({\n key: \"sports\",\n temporal: true,\n settingsSchema,\n\n // Hand-written rather than driven off settingsSchema above: the schema is\n // published for the parent's UI, and running a JSON Schema validator here to\n // re-derive checks this function states in four lines would add a dependency\n // to save nothing. They are two audiences, not one mechanism — if they ever\n // drift, this one is the one that decides.\n //\n // `unknown_team` is a distinct code from `invalid_settings` on purpose: the\n // parent can tell \"this caller's saved selection references a team we\n // dropped from the catalog\" from \"this request is malformed\".\n parseSettings: async (raw) => {\n if (\n !Array.isArray(raw.teams) || !raw.teams.every((t) => typeof t === \"string\")\n || new Set(raw.teams).size !== raw.teams.length\n || (raw.intradayFilter !== undefined && typeof raw.intradayFilter !== \"boolean\")\n || Object.keys(raw).some((k) => !SETTING_KEYS.includes(k))\n ) return reject(\"invalid_settings\");\n\n const catalog = await readCatalog();\n const teams = raw.teams as string[];\n if (teams.some((slug) => !catalog.teams.some((team) => team.slug === slug))) {\n return reject(\"unknown_team\");\n }\n\n return accept({ teams, intradayFilter: raw.intradayFilter === true, catalog });\n },\n\n read: ({ teams, intradayFilter, catalog }, { utcOffsetSeconds }) =>\n sportsItems({ teams, intradayFilter }, utcOffsetSeconds, catalog),\n\n writes: {\n // Ingest for the one adapter that can't fetch at request time: ESPN blocks\n // Val Town's egress, so an external process fetches FIBA and posts the\n // slate here. `source` is pinned to \"fiba\" rather than taken on trust —\n // this route would otherwise let any caller write any key into a table\n // other adapters read from.\n \"cache.put\": async (payload) => {\n if (\n payload.source !== \"fiba\"\n || typeof payload.dateKey !== \"string\" || !/^\\d{4}-\\d{2}-\\d{2}$/.test(payload.dateKey)\n || !Object.hasOwn(payload, \"payload\")\n ) return reject(\"invalid_cache_payload\");\n await saveSourcePayload(\"fiba\", payload.dateKey, payload.payload);\n return accept({ source: payload.source, dateKey: payload.dateKey });\n },\n\n // Pull the next N days of Sleeper's slate into cached_games. Bounded at 31\n // because each day is a separate upstream request.\n \"sleeper.refresh\": async (payload) => {\n const days = payload.days;\n if (typeof days !== \"number\" || !Number.isInteger(days) || days < 1 || days > 31) {\n return reject(\"invalid_days\");\n }\n return accept(await ingestSleeperWindow(days));\n },\n },\n});\n","label",[137],"1c5de4cb-db35-4d2e-980d-9242a8d1cad0","rpc.ts",["D",1788811087002],"http","// Public val with authenticated sports-source operations.\n//\n// The mount point, and the only file that knows both halves: the SDK serves\n// the protocol (sdk/serve.ts), sportsSource.ts is what it serves, and the\n// bearer check below is this deployment's own business — deliberately outside\n// the SDK, since a source shouldn't have an opinion about how it is fronted.\n// The routes under /v1/ are the contract; the rest are this val's operational\n// surface.\nimport { serveSource } from \"./sdk/serve.ts\";\nimport sportsSource from \"./sportsSource.ts\";\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { cachedGamesCoverage } from \"./lib/cachedGames.ts\";\nimport { fetchCachedFibaScoreboard } from \"./lib/fiba.ts\";\nexport default async function handler(req:Request):Promise {\n const expected=Deno.env.get(\"SOURCE_SPORTS_V1_TOKEN\");\n if(!expected) return Response.json({error:\"RPC token not configured\"},{status:503});\n if(req.headers.get(\"authorization\") !== `Bearer ${expected}`) return Response.json({error:\"unauthorized\"},{status:401});\n const url=new URL(req.url);\n if(url.pathname.startsWith(\"/v1/\")) return serveSource(sportsSource,req);\n if(req.method===\"GET\"&&url.pathname===\"/health\") return Response.json({ok:true});\n if(req.method===\"GET\"&&url.pathname===\"/catalog\") return Response.json(await readCatalog());\n if(req.method===\"GET\"&&url.pathname===\"/cached-games/coverage\") return Response.json(await cachedGamesCoverage());\n const fiba=url.pathname.match(/^\\/fiba\\/([^/]+)$/);\n if(req.method===\"GET\"&&fiba) return Response.json(await fetchCachedFibaScoreboard(decodeURIComponent(fiba[1])));\n return new Response(\"Not found\",{status:404});\n}\n",[147],"84870638-3c4a-4a7e-9a04-c18e15640bb4","tools","01a07d73-0d02-703f-be73-04aa080ac006",["D",1788811087002],"directory",[153],"c160be52-4215-44ff-9047-6073036102bc","sdk","01a07d73-0d02-703f-be72-f58a8508ba6a",["D",1788811087002],[159],"45a775c3-2e6a-4f66-8d72-d23a6624c336","lib","01a07d73-0d02-703f-be72-dcc2eeee9850",["D",1788811087002],[164],"pulls","branches",5,"forks","envVars",{"_176":178,"_179":64},"connections",{"_176":64,"_177":64},"count","unfilledCount",4,"emptyCount",{"_45":163,"_33":164,"_31":165,"_139":-5,"_43":44,"_42":140,"_141":25,"_40":371,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_208":372,"_28":373},{"_45":364,"_33":365,"_31":366,"_139":165,"_43":44,"_42":140,"_141":27,"_40":367,"_13":64,"_35":36,"_37":368,"_24":27,"_144":-5,"_208":369,"_28":370},{"_45":357,"_33":358,"_31":359,"_139":165,"_43":44,"_42":140,"_141":27,"_40":360,"_13":64,"_35":36,"_37":361,"_24":27,"_144":-5,"_208":362,"_28":363},{"_45":350,"_33":351,"_31":352,"_139":165,"_43":44,"_42":140,"_141":27,"_40":353,"_13":64,"_35":36,"_37":354,"_24":27,"_144":-5,"_208":355,"_28":356},{"_45":343,"_33":344,"_31":345,"_139":165,"_43":44,"_42":140,"_141":25,"_40":346,"_13":64,"_35":36,"_37":347,"_24":27,"_144":-5,"_208":348,"_28":349},{"_45":336,"_33":337,"_31":338,"_139":165,"_43":44,"_42":140,"_141":27,"_40":339,"_13":64,"_35":36,"_37":340,"_24":27,"_144":-5,"_208":341,"_28":342},{"_45":329,"_33":330,"_31":331,"_139":165,"_43":44,"_42":140,"_141":27,"_40":332,"_13":64,"_35":36,"_37":333,"_24":27,"_144":-5,"_208":334,"_28":335},{"_45":322,"_33":323,"_31":324,"_139":165,"_43":44,"_42":140,"_141":27,"_40":325,"_13":64,"_35":36,"_37":326,"_24":27,"_144":-5,"_208":327,"_28":328},{"_45":315,"_33":316,"_31":317,"_139":165,"_43":44,"_42":140,"_141":27,"_40":318,"_13":64,"_35":36,"_37":319,"_24":27,"_144":-5,"_208":320,"_28":321},{"_45":308,"_33":309,"_31":310,"_139":165,"_43":44,"_42":140,"_141":27,"_40":311,"_13":64,"_35":36,"_37":312,"_24":27,"_144":-5,"_208":313,"_28":314},{"_45":301,"_33":302,"_31":303,"_139":165,"_43":44,"_42":140,"_141":27,"_40":304,"_13":64,"_35":36,"_37":305,"_24":27,"_144":-5,"_208":306,"_28":307},{"_45":294,"_33":295,"_31":296,"_139":165,"_43":44,"_42":140,"_141":27,"_40":297,"_13":64,"_35":36,"_37":298,"_24":27,"_144":-5,"_208":299,"_28":300},{"_45":287,"_33":288,"_31":289,"_139":165,"_43":44,"_42":140,"_141":27,"_40":290,"_13":64,"_35":36,"_37":291,"_24":27,"_144":-5,"_208":292,"_28":293},{"_45":280,"_33":281,"_31":282,"_139":165,"_43":44,"_42":140,"_141":27,"_40":283,"_13":64,"_35":36,"_37":284,"_24":27,"_144":-5,"_208":285,"_28":286},{"_45":158,"_33":159,"_31":160,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":277,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_208":278,"_28":279},{"_45":270,"_33":271,"_31":272,"_139":160,"_43":44,"_42":140,"_141":27,"_40":273,"_13":64,"_35":20,"_37":274,"_24":27,"_144":-5,"_208":275,"_28":276},{"_45":263,"_33":264,"_31":265,"_139":160,"_43":44,"_42":140,"_141":27,"_40":266,"_13":64,"_35":36,"_37":267,"_24":27,"_144":-5,"_208":268,"_28":269},{"_45":256,"_33":257,"_31":258,"_139":160,"_43":44,"_42":140,"_141":27,"_40":259,"_13":64,"_35":36,"_37":260,"_24":27,"_144":-5,"_208":261,"_28":262},{"_45":249,"_33":250,"_31":251,"_139":160,"_43":44,"_42":140,"_141":27,"_40":252,"_13":64,"_35":36,"_37":253,"_24":27,"_144":-5,"_208":254,"_28":255},{"_45":242,"_33":243,"_31":244,"_139":160,"_43":44,"_42":140,"_141":27,"_40":245,"_13":64,"_35":20,"_37":246,"_24":27,"_144":-5,"_208":247,"_28":248},{"_45":152,"_33":153,"_31":154,"_139":-5,"_43":44,"_42":140,"_141":25,"_40":239,"_13":64,"_35":156,"_37":-5,"_24":27,"_144":-5,"_208":240,"_28":241},{"_45":232,"_33":233,"_31":234,"_139":154,"_43":44,"_42":140,"_141":27,"_40":235,"_13":64,"_35":36,"_37":236,"_24":27,"_144":-5,"_208":237,"_28":238},{"_45":228,"_33":34,"_31":32,"_139":154,"_43":44,"_42":14,"_141":27,"_40":229,"_13":140,"_35":36,"_37":39,"_24":27,"_144":-5,"_208":230,"_28":231},{"_45":221,"_33":222,"_31":223,"_139":154,"_43":44,"_42":140,"_141":27,"_40":224,"_13":64,"_35":36,"_37":225,"_24":27,"_144":-5,"_208":226,"_28":227},{"_45":214,"_33":215,"_31":216,"_139":154,"_43":44,"_42":140,"_141":27,"_40":217,"_13":64,"_35":36,"_37":218,"_24":27,"_144":-5,"_208":219,"_28":220},{"_45":146,"_33":147,"_31":59,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":211,"_13":64,"_35":149,"_37":150,"_24":27,"_144":-5,"_208":212,"_28":213},{"_45":136,"_33":137,"_31":138,"_139":-5,"_43":44,"_42":140,"_141":27,"_40":207,"_13":64,"_35":36,"_37":143,"_24":27,"_144":-5,"_208":209,"_28":210},["D",1788811087002],"children",[],[137],["D",1788811087002],[],[147],"4a7d4410-ecdc-4414-a696-1e0e13ac4c8f","source-contract-check.ts","01a07d73-0d02-703f-be73-038945c8ba0f",["D",1788811087002],"// Contract check for this val's whole HTTP surface. Reads production data and\n// exercises one disposable source_cache row, which it always removes.\nimport handler from \"../rpc.ts\";\nimport {sqlite} from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {items} from \"../sdk/contract.ts\";\nfunction assert(ok:unknown,msg:string){if(!ok)throw new Error(msg);}\nconst token=Deno.env.get(\"SOURCE_SPORTS_V1_TOKEN\");\nasync function call(path:string,body?:unknown,auth=true){return handler(new Request(\"https://source.invalid\"+path,{method:body?\"POST\":\"GET\",headers:auth?{authorization:`Bearer ${token}`}: {},body:body?JSON.stringify(body):undefined}));}\nassert((await call(\"/v1/descriptor\",undefined,false)).status===401,\"auth\");\nconst d=await (await call(\"/v1/descriptor\")).json();\nassert(d.sourceKey===\"sports\"&&d.temporal&&d.capabilities.publish===false,\"descriptor\");\nassert(d.settingsSchema.properties.teams.items.oneOf.length===67&&d.settingsSchema.required[0]===\"teams\",\"descriptor options\");\nconst base={protocolVersion:1,sourceKey:\"sports\",settings:{teams:[\"united-states\"],intradayFilter:false},context:{utcOffsetSeconds:-25200}};\nconst good=await call(\"/v1/read\",base);const data=await good.json();assert(good.ok&&items(data.items),\"read contract\");\n// A null offset is the documented \"parent had nothing to forward\" case; it\n// must resolve to this source's own default zone, not fail and not shift to UTC.\nassert((await call(\"/v1/read\",{...base,context:{utcOffsetSeconds:null}})).ok,\"null offset\");\nassert((await call(\"/v1/read\",{...base,settings:{teams:[\"not-a-team\"]}})).status===400,\"invalid team\");\nassert((await call(\"/v1/read\",{...base,settings:{teams:[],unexpected:1}})).status===400,\"unknown setting\");\nassert((await call(\"/v1/read\",{...base,sourceKey:\"moon\"})).status===404,\"source identity\");\nassert((await call(\"/v1/read\",{...base,protocolVersion:2})).status===400,\"protocol\");\nassert((await call(\"/v1/publish\",base)).status===501,\"publish stub\");\nassert((await call(\"/v1/write\",{...base,operation:\"sql\",payload:{}})).status===422,\"unsupported write\");\nassert((await call(\"/v1/write\",{...base,operation:\"cache.put\",payload:{source:\"moon\",dateKey:\"2026-01-01\",payload:{}}})).status===400,\"foreign cache source\");\nconst item={id:\"a\",mainText:\"Main\",subText:\"Sub\",caption:null,emphasized:false,timestamp:1788764400};\nassert(!items([{...item,timestamp:NaN}])&&!items([item,item]),\"item guard\");\nconst dateKey=\"1900-01-01\";\nconst existing=await sqlite.execute({sql:\"SELECT count(*) AS n FROM source_cache WHERE source='fiba' AND date_key=?\",args:[dateKey]});assert(Number(existing.rows[0].n)===0,\"fixture occupied\");\ntry {\n const w=await call(\"/v1/write\",{protocolVersion:1,sourceKey:\"sports\",operation:\"cache.put\",payload:{source:\"fiba\",dateKey,payload:{boundaryFixture:true}}});assert(w.ok,\"write\");\n const found=await sqlite.execute({sql:\"SELECT count(*) AS n FROM source_cache WHERE source='fiba' AND date_key=?\",args:[dateKey]});assert(Number(found.rows[0].n)===1,\"write storage\");\n console.log(JSON.stringify({ok:true,sportsItems:data.items.length,checks:14,fixtureDate:dateKey}));\n} finally {await sqlite.execute({sql:\"DELETE FROM source_cache WHERE source='fiba' AND date_key=?\",args:[dateKey]});}\n",[],[153,215],"e7df3fbc-0b36-4eff-b915-183e31994450","sdk-check.ts","01a07d73-0d02-703f-be72-fd329a3d0647",["D",1788811087002],"// Two things, both about the SDK rather than about sports:\n//\n// 1. The boundary lint. sdk/ must not import anything outside sdk/, and must\n// not mention this val's domain. That is what makes the directory liftable\n// into its own published val, and it is the kind of rule that decays\n// silently under a hurry, so it is checked rather than asked for.\n//\n// 2. A conformance suite run against a FIXTURE source defined right here —\n// no database, no network, no games. If this passes, serveSource\n// implements the protocol for any source, not just this val's.\n//\n// The fixture below doubles as the reference implementation: it is the\n// smallest thing that is a complete source, and copying it is a reasonable way\n// to start a new one.\n//\n// Touches no storage and no production data. Safe to run anywhere.\n\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { accept, type Item, reject } from \"../sdk/contract.ts\";\nimport { defineSource, type SourceDefinition } from \"../sdk/defineSource.ts\";\nimport { serveSource } from \"../sdk/serve.ts\";\n\nfunction check(value: unknown, message: string): asserts value {\n if (!value) throw new Error(message);\n}\n\n// ---------------------------------------------------------------- boundary --\n\nconst SDK_FILES = [\"/sdk/contract.ts\", \"/sdk/defineSource.ts\", \"/sdk/serve.ts\"];\n\n// Words that mean this val in particular. The SDK may not know any of them.\n// (Checked against code only — sdk/README.md uses them in its examples, which\n// is exactly where domain vocabulary belongs.)\nconst DOMAIN_WORDS = [\"sport\", \"team\", \"game\", \"sleeper\", \"fiba\", \"catalog\", \"widget\", \"channel\"];\n\nfor (const path of SDK_FILES) {\n const code = await readFile(path, import.meta.url);\n\n // Every import must be relative and stay inside sdk/. This also rules out\n // remote imports, so the published SDK has zero dependencies — including on\n // Val Town's own std, which is what lets a source run somewhere else.\n for (const [, specifier] of code.matchAll(/(?:^|\\n)\\s*(?:import|export)[^;]*?from\\s+[\"']([^\"']+)[\"']/g)) {\n check(\n specifier.startsWith(\"./\") && !specifier.includes(\"..\"),\n `${path} imports outside sdk/: ${specifier}`,\n );\n }\n\n // Strip comments before the vocabulary scan: prose may say \"a catalog, say\"\n // while explaining what `options` is for. Identifiers may not.\n const source = code.replace(/\\/\\/[^\\n]*/g, \"\").replace(/\\/\\*[\\s\\S]*?\\*\\//g, \"\").toLowerCase();\n for (const word of DOMAIN_WORDS) {\n check(!source.includes(word), `${path} names this val's domain in code: \"${word}\"`);\n }\n}\n\n// ------------------------------------------------------------- conformance --\n\nconst fixture = defineSource<{ count: number }>({\n key: \"fixture\",\n // `temporal` deliberately omitted, to prove the descriptor defaults it.\n settingsSchema: {\n type: \"object\",\n properties: { count: { type: \"integer\" } },\n required: [\"count\"],\n additionalProperties: false,\n },\n parseSettings: (raw) =>\n typeof raw.count === \"number\" && Number.isInteger(raw.count) && raw.count >= 0\n ? accept({ count: raw.count })\n : reject(\"invalid_settings\"),\n read: ({ count }, context) =>\n Promise.resolve(Array.from({ length: count }, (_, i): Item => ({\n id: `fixture-${i}`,\n mainText: `Item ${i}`,\n // Echoed so the assertions below can prove the context reached the\n // source rather than being swallowed by the protocol layer.\n subText: String(context.utcOffsetSeconds),\n caption: null,\n emphasized: false,\n timestamp: 1788739200 + i,\n }))),\n writes: {\n echo: (payload) =>\n typeof payload.value === \"string\"\n ? accept({ echoed: payload.value })\n : reject(\"invalid_value\"),\n },\n});\n\n// A source that breaks the item contract, to prove the SDK catches it rather\n// than passing it to the parent: two items with the same id.\nconst brokenSource = defineSource({\n key: \"broken\",\n settingsSchema: {},\n parseSettings: () => accept(null),\n read: () =>\n Promise.resolve([0, 0].map((): Item => ({\n id: \"duplicate\",\n mainText: \"\",\n subText: \"\",\n caption: null,\n emphasized: false,\n timestamp: 1788739200,\n }))),\n});\n\nconst BASE = { protocolVersion: 1, sourceKey: \"fixture\" };\n// deno-lint-ignore no-explicit-any -- the harness drives two differently-typed\n// definitions through one helper; serveSource's own generic is what's under test.\ntype Definition = SourceDefinition;\n\nfunction call(definition: Definition, path: string, body?: unknown, rawBody?: string) {\n const init: RequestInit = body !== undefined || rawBody !== undefined\n ? { method: \"POST\", body: rawBody ?? JSON.stringify(body) }\n : {};\n return serveSource(definition, new Request(\"https://fixture.invalid\" + path, init));\n}\nasync function status(definition: Definition, path: string, body?: unknown, rawBody?: string) {\n const response = await call(definition, path, body, rawBody);\n return { code: response.status, json: await response.json() };\n}\n\n// Descriptor: derived capabilities, defaulted temporal, absent options.\nconst descriptor = await (await call(fixture, \"/v1/descriptor\")).json();\ncheck(descriptor.sourceKey === \"fixture\" && descriptor.protocolVersion === 1, \"descriptor identity\");\ncheck(descriptor.temporal === true, \"temporal did not default to true\");\ncheck(!(\"options\" in descriptor), \"options published by a source that declares none\");\ncheck(\n JSON.stringify(descriptor.capabilities) === JSON.stringify({ read: true, validateSettings: true, write: [\"echo\"], publish: false }),\n \"capabilities not derived from the definition\",\n);\ncheck((await status(fixture, \"/v1/descriptor?sourceKey=other\")).code === 404, \"wrong key reached the descriptor\");\n\n// Validation does not read, write, or leak parseSettings' internal output.\nlet readCalls = 0;\nconst validationFixture = defineSource({\n key:\"validation\",\n settingsSchema: async () => ({type:\"object\",properties:{},additionalProperties:false}),\n parseSettings: (raw) => Object.keys(raw).length === 0 ? accept({privateContext:\"secret\"}) : reject(\"invalid_settings\"),\n read: async () => { readCalls++; return []; },\n});\nconst valid = await status(validationFixture,\"/v1/validate-settings\",{\n protocolVersion:1,sourceKey:\"validation\",settings:{},\n});\ncheck(valid.code === 200 && valid.json.ok === true && !(\"privateContext\" in valid.json) &&\n Object.keys(valid.json).length === 3 && readCalls === 0, \"validation-only boundary\");\ncheck((await status(validationFixture,\"/v1/validate-settings\",{\n protocolVersion:1,sourceKey:\"validation\",settings:{unknown:true},\n})).code === 400,\"validation rejected unknown settings\");\ncheck((await status(validationFixture,\"/v1/descriptor\")).json.settingsSchema.type === \"object\",\"dynamic schema\");\n\n// Read: the happy path, and that context and settings both arrive intact.\nconst read = await status(fixture, \"/v1/read\", {\n ...BASE,\n settings: { count: 3 },\n context: { utcOffsetSeconds: -25200 },\n});\ncheck(read.code === 200 && read.json.items.length === 3, \"read did not return the source's items\");\ncheck(read.json.items[0].subText === \"-25200\", \"context.utcOffsetSeconds did not reach the source\");\ncheck(read.json.sourceKey === \"fixture\", \"read envelope identity\");\n\nconst nullOffset = await status(fixture, \"/v1/read\", {\n ...BASE,\n settings: { count: 1 },\n context: { utcOffsetSeconds: null },\n});\n// null must arrive AS null. Coercing it to 0 here would silently move every\n// day boundary to UTC for callers the parent couldn't resolve.\ncheck(nullOffset.json.items[0].subText === \"null\", \"null offset was coerced before the source saw it\");\n\n// Read: the ways it is refused.\nconst badSettings = await status(fixture, \"/v1/read\", {\n ...BASE,\n settings: { count: \"x\" },\n context: { utcOffsetSeconds: 0 },\n});\ncheck(badSettings.code === 400 && badSettings.json.error === \"invalid_settings\", \"parseSettings rejection not surfaced\");\n// The offset guard runs BEFORE parseSettings, so an absent utcOffsetSeconds is\n// invalid_timezone and not the source's business. The parent always sends the\n// key (null when it has no value), so this only bites a hand-written request.\ncheck(\n (await status(fixture, \"/v1/read\", { ...BASE, settings: { count: 1 }, context: {} })).json.error === \"invalid_timezone\",\n \"absent offset silently accepted\",\n);\ncheck((await status(fixture, \"/v1/read\", { ...BASE, settings: { count: 1 } })).code === 400, \"missing context accepted\");\ncheck(\n (await status(fixture, \"/v1/read\", { ...BASE, settings: { count: 1 }, context: { utcOffsetSeconds: 86401 } }))\n .json.error === \"invalid_timezone\",\n \"out-of-range offset accepted\",\n);\ncheck((await status(fixture, \"/v1/read\", { ...BASE, protocolVersion: 2 })).json.error === \"unsupported_protocol\", \"protocol version\");\ncheck((await status(fixture, \"/v1/read\", undefined, \"{not json\")).json.error === \"invalid_json\", \"malformed json\");\ncheck((await status(fixture, \"/v1/read\", [])).json.error === \"invalid_body\", \"array body accepted\");\ncheck((await status(fixture, \"/v1/read\", { ...BASE, sourceKey: \"other\" })).code === 404, \"foreign sourceKey\");\n\n// The output guard: a source that breaks the contract fails here, not at the\n// parent.\nconst broken = await status(\n brokenSource,\n \"/v1/read\",\n { protocolVersion: 1, sourceKey: \"broken\", settings: {}, context: { utcOffsetSeconds: 0 } },\n);\ncheck(broken.code === 502 && broken.json.error === \"invalid_source_output\", \"duplicate ids escaped the source\");\n\n// Writes.\nconst echo = await status(fixture, \"/v1/write\", { ...BASE, operation: \"echo\", payload: { value: \"hi\" } });\ncheck(echo.code === 200 && echo.json.ok === true && echo.json.result.echoed === \"hi\", \"write did not run\");\ncheck(\n (await status(fixture, \"/v1/write\", { ...BASE, operation: \"echo\", payload: { value: 1 } })).json.error === \"invalid_value\",\n \"write rejection not surfaced\",\n);\ncheck((await status(fixture, \"/v1/write\", { ...BASE, operation: \"nope\", payload: {} })).code === 422, \"unknown operation\");\n// Object.prototype must not be reachable as an operation.\ncheck((await status(fixture, \"/v1/write\", { ...BASE, operation: \"toString\", payload: {} })).code === 422, \"prototype method invoked as an operation\");\ncheck((await status(fixture, \"/v1/write\", { ...BASE, operation: \"echo\", payload: \"x\" })).json.error === \"invalid_payload\", \"non-object payload accepted\");\ncheck(\n (await status(brokenSource, \"/v1/write\", { protocolVersion: 1, sourceKey: \"broken\", operation: \"echo\", payload: {} })).code === 422,\n \"a source with no writes accepted one\",\n);\n\n// Reserved and unknown routes.\ncheck((await status(fixture, \"/v1/publish\", BASE)).code === 501, \"publish stub\");\ncheck((await status(fixture, \"/v1/nope\", BASE)).json.error === \"not_found\", \"unknown route\");\n\nconsole.log(`PASS: sdk/ imports nothing outside itself and names no domain concept; serveSource conforms for a fixture source with no storage.`);\n",[],[153,222],"cacca41a-0dd6-4c76-bead-bb95a8c89b46",["D",1788811211556],[],[153,34],"30e6b522-7980-4f24-a258-dd103f4419a6","catalog-check.ts","01a07d73-0d02-703f-be72-f9654eed5802",["D",1788811087002],"// Catalog migration regression check. Reads production catalog; never writes data.\nimport { readCatalog } from \"../lib/catalogStore.ts\";\nimport { teamLabel } from \"../lib/catalog.ts\";\nimport { resolveTeams } from \"../lib/params.ts\";\nimport { pickNextPerTeam } from \"../lib/games.ts\";\nimport { widgetItems } from \"../lib/widgetItems.ts\";\nimport { sportsItems } from \"../lib/sportsFeed.ts\";\nimport handler from \"../rpc.ts\";\n\nfunction check(value: unknown, message: string): asserts value {\n if (!value) throw new Error(message);\n}\nconst catalog = await readCatalog();\nconst expected = [[\"dream\",\"wnba\",\"ATL\"],[\"sky\",\"wnba\",\"CHI\"],[\"sun\",\"wnba\",\"CON\"],[\"wings\",\"wnba\",\"DAL\"],[\"valkyries\",\"wnba\",\"GSV\"],[\"fever\",\"wnba\",\"IND\"],[\"sparks\",\"wnba\",\"LAS\"],[\"aces\",\"wnba\",\"LVA\"],[\"lynx\",\"wnba\",\"MIN\"],[\"liberty\",\"wnba\",\"NYL\"],[\"fire\",\"wnba\",\"PDX\"],[\"mercury\",\"wnba\",\"PHO\"],[\"storm\",\"wnba\",\"SEA\"],[\"tempo\",\"wnba\",\"TOR\"],[\"mystics\",\"wnba\",\"WAS\"],[\"cardinals\",\"nfl\",\"ARI\"],[\"falcons\",\"nfl\",\"ATL\"],[\"ravens\",\"nfl\",\"BAL\"],[\"bills\",\"nfl\",\"BUF\"],[\"panthers\",\"nfl\",\"CAR\"],[\"bears\",\"nfl\",\"CHI\"],[\"bengals\",\"nfl\",\"CIN\"],[\"browns\",\"nfl\",\"CLE\"],[\"cowboys\",\"nfl\",\"DAL\"],[\"broncos\",\"nfl\",\"DEN\"],[\"lions\",\"nfl\",\"DET\"],[\"packers\",\"nfl\",\"GB\"],[\"texans\",\"nfl\",\"HOU\"],[\"colts\",\"nfl\",\"IND\"],[\"jaguars\",\"nfl\",\"JAX\"],[\"chiefs\",\"nfl\",\"KC\"],[\"chargers\",\"nfl\",\"LAC\"],[\"rams\",\"nfl\",\"LAR\"],[\"raiders\",\"nfl\",\"LV\"],[\"dolphins\",\"nfl\",\"MIA\"],[\"vikings\",\"nfl\",\"MIN\"],[\"patriots\",\"nfl\",\"NE\"],[\"saints\",\"nfl\",\"NO\"],[\"giants\",\"nfl\",\"NYG\"],[\"jets\",\"nfl\",\"NYJ\"],[\"eagles\",\"nfl\",\"PHI\"],[\"steelers\",\"nfl\",\"PIT\"],[\"seahawks\",\"nfl\",\"SEA\"],[\"49ers\",\"nfl\",\"SF\"],[\"buccaneers\",\"nfl\",\"TB\"],[\"titans\",\"nfl\",\"TEN\"],[\"commanders\",\"nfl\",\"WAS\"],[\"trojans\",\"cfb\",\"USC\"],[\"bruins\",\"cfb\",\"UCLA\"],[\"lakers\",\"nba\",\"LAL\"],[\"warriors\",\"nba\",\"GSW\"],[\"australia\",\"fiba\",\"AUS\"],[\"belgium\",\"fiba\",\"BEL\"],[\"china\",\"fiba\",\"CHN\"],[\"czechia\",\"fiba\",\"CZE\"],[\"spain\",\"fiba\",\"ESP\"],[\"france\",\"fiba\",\"FRA\"],[\"germany\",\"fiba\",\"GER\"],[\"hungary\",\"fiba\",\"HUN\"],[\"italy\",\"fiba\",\"ITA\"],[\"japan\",\"fiba\",\"JPN\"],[\"south-korea\",\"fiba\",\"KOR\"],[\"mali\",\"fiba\",\"MLI\"],[\"nigeria\",\"fiba\",\"NGR\"],[\"puerto-rico\",\"fiba\",\"PUR\"],[\"turkey\",\"fiba\",\"TUR\"],[\"united-states\",\"fiba\",\"USA\"]];\nfor (const [slug, competitionCode, providerCode] of expected) {\n check(catalog.teams.some((team) => team.slug === slug &&\n team.competitionCode === competitionCode && team.providerCode === providerCode),\n \"Missing or changed seed mapping: \" + slug);\n}\ncheck(catalog.competitions.map((c) => c.code).join(\",\") === \"nfl,cfb,wnba,nba,fiba\", \"Competition order changed\");\n// Scoped codes: \"fever\" and \"colts\" are both IND, in different competitions.\nconst selected = resolveTeams([\"fever\", \"colts\", \"fever\", \"not-a-team\"], catalog);\ncheck(JSON.stringify(selected.teams) === JSON.stringify([\n { sport: \"wnba\", code: \"IND\" }, { sport: \"nfl\", code: \"IND\" },\n]), \"Scoped codes or deduplication changed\");\ncheck(selected.sports.join(\",\") === \"nfl,wnba\", \"Selection order changed\");\ncheck(resolveTeams([], catalog).teams.length === 0, \"Empty selection widened\");\ncheck(teamLabel(\"wnba\", \"IND\", catalog) === \"Fever\", \"Fever mislabeled\");\ncheck(teamLabel(\"nfl\", \"IND\", catalog) === \"Colts\", \"Colts mislabeled\");\ncheck(teamLabel(\"nba\", \"UNMAPPED\", catalog) === \"UNMAPPED\", \"Unknown opponent invented\");\nconst custom = { ...catalog, teams: catalog.teams.map((team) =>\n team.slug === \"fever\" ? { ...team, displayName: \"Indiana Fever\" } : team) };\n// The nested wnba away_team shape teamCode resolves, kept as the fixture so a\n// regression there fails here rather than only against live Sleeper data.\nconst picked = pickNextPerTeam([{\n sport: \"wnba\", start_time: 1788739200000, game_id: \"catalog-fixture\",\n status: \"in_game\", metadata: { away_team: { team: \"IND\" }, home_team: \"LAS\", channel: \"ESPN\" },\n}], [{ sport: \"wnba\", code: \"IND\" }], [\"wnba\"]);\ncheck(picked !== null, \"Fixture game not selected\");\nconst rendered = widgetItems(picked!.bySport, custom);\ncheck(rendered.length === 1, \"Widget item count changed\");\ncheck(rendered[0].mainText === \"🏀 Indiana Fever @ Sparks\", \"Explicit display names not rendered\");\ncheck(rendered[0].subText === \"ESPN · 206\", \"Channel text changed\");\ncheck(rendered[0].timestamp === 1788739200 && rendered[0].caption === \"LIVE\" && rendered[0].emphasized,\n \"Time/status contract changed\");\ncheck(Object.keys(rendered[0]).sort().join(\",\") === \"caption,emphasized,id,mainText,subText,timestamp\",\n \"Item wire keys changed\");\n// A live game is exactly what intradayFilter must NOT drop.\ncheck(widgetItems(picked!.bySport, custom, true).length === 1, \"intradayFilter dropped a live game\");\nconst empty = await sportsItems({ teams: [\"not-a-team\"], intradayFilter: false }, -25200, catalog);\ncheck(empty.length === 0, \"Empty sports feed failed\");\nconst unauthorized = await handler(new Request(\"https://fixture.invalid/catalog\"));\ncheck(unauthorized.status === 401, \"Catalog RPC exposed without auth\");\nconst authorized = await handler(new Request(\"https://fixture.invalid/catalog\", {\n headers: { authorization: \"Bearer \" + Deno.env.get(\"SOURCE_SPORTS_V1_TOKEN\") },\n}));\ncheck(authorized.ok && (await authorized.json()).teams.length >= expected.length, \"Catalog RPC failed\");\nconsole.log(\"PASS: preserved 67 mappings; ordering, deduplication, scoped codes, display names, item contract, database reader, and authenticated RPC.\");\n",[],[153,233],["D",1788811087002],[201,202,203,204],[153],"c6af8893-cf6e-45fa-b1a0-e0d95d0d6fca","settings-form.md","01a07d73-0d02-703f-be72-f37ada841e12",["D",1788811087002],"# Source settings form contract\n\nThe parent renders source settings from authenticated `GET /v1/descriptor?sourceKey=...`.\nIt checks protocol/source identity, `temporal:true`, and\n`capabilities.validateSettings:true`. The live schema is authoritative for the\nform; stored registry schema snapshots are not used for editing.\n\n## Supported JSON Schema subset\n\nThe root is `{type:\"object\",properties:{...},additionalProperties:false}`.\nAn optional `required` array names declared properties. Each property has a\n`title`, optional `description`, and one of these shapes:\n\n- Boolean: `{type:\"boolean\",title:\"Show alerts\",default:false}`.\n- Multiple choices: `{type:\"array\",title:\"Locations\",default:[],uniqueItems:true,\n items:{type:\"string\",oneOf:[{const:\"west\",title:\"West\",\"x-group\":\"Regions\"}]}}`.\n\n`x-group` is the only UI extension. Choice values are stable strings;\ntitles and optional groups are display text. Declaration order determines form\norder. Defaults apply when displaying a field with no saved value. Empty\n`properties` means no settings. Field names start with a letter and contain\nonly letters, digits, and underscores; prototype-related names are rejected.\n\nUnsupported property types or constraints fail closed, with no save form.\nThis is deliberately not a general JSON Schema renderer. No nested objects,\nfree text, numbers, conditional fields, pagination, or source-supplied HTML/JS.\nAll labels are escaped by React. Legacy descriptor `options` is not consumed:\nthe choice-to-property binding is inside `settingsSchema`.\n\nA source may provide a static schema or an async `settingsSchema()` function.\nSports builds choices from its catalog in one descriptor request. Moon publishes\nthe empty object schema. No source data tables need changing.\n\n## Saving\n\nThe form includes a fingerprint of the rendered fields. The parent reloads the\ndescriptor on POST and rejects a changed fingerprint with 409; it does not\nsilently interpret an old form against new controls or choices.\n\nThe parent decodes only declared fields. Unchecked booleans become false and\nunselected arrays become []; defaults do not override an intentional clearing.\nUnknown fields, duplicate values, and unavailable choices are rejected.\nPreviously saved choices that disappear remain visible as checked unavailable\nvalues, requiring explicit removal.\n\nBefore persisting, the parent sends\n`POST /v1/validate-settings` with\n`{protocolVersion:1,sourceKey,settings}`.\nThe SDK invokes the same `parseSettings` used by reads and returns only\n`{protocolVersion:1,sourceKey,ok:true}`. It does not call `read`, perform writes,\nor expose parsed internal context. Implementers must keep `parseSettings`\nfree of mutation. Validation remains source-authoritative on every feed read,\nsince data/choices may change after a settings save.\n\nSource validation errors retain their stable error code. Unavailability returns\n502, invalid settings 422, and stale forms 409. None changes the assignment.\nSuccessful saves persist the original wire settings, then use the existing\ndevice notification path.\n\n## Scope and remaining coupling\n\nDevice settings routes and rendering have no source-kind dispatch, field-name\nknowledge, or sports catalog import. Another source supporting this profile\nneeds only a registered pointer and its descriptor/validation/read implementation.\n\nPrototype starter-feed defaults and operator ingestion/catalog/coverage adapters\nstill refer to Sports/Moon instance IDs. Removing those is separate from settings\nforms. Immutable releases, descriptor caching, schema migrations, and agent ACLs\nremain deferred.\n",[],[159,243],"0b664426-5a69-487e-89ae-927838c9e55d","serve.ts","01a07d73-0d02-703f-be72-ed2fce78ab35",["D",1788811087002],"// Version 1 of the source protocol, as a function of a SourceDefinition.\n// Everything here is the same for every source, which is exactly why it is\n// here and not in the source: an implementer who writes this by hand writes\n// the envelopes, the status codes and the output guard slightly differently\n// each time, and the parent is the one that finds out.\n//\n// The routes:\n// GET /v1/descriptor what this source is, and what settings it takes\n// POST /v1/read settings + context in, items out\n// POST /v1/write a named side effect from `writes`\n// POST /v1/publish 501; reserved, no source implements it yet\n//\n// Auth is NOT here. It belongs to whatever mounts this (rpc.ts), because the\n// credential is a deployment concern and a source shouldn't have an opinion\n// about how it is fronted.\n//\n// Part of the SDK — see sdk/contract.ts's header for the import rule.\n\nimport { items, PROTOCOL_VERSION, record } from \"./contract.ts\";\nimport type { SourceDefinition } from \"./defineSource.ts\";\n\n// Every response the protocol emits carries protocolVersion, and every\n// failure carries `ok:false` plus a code. Kept as two helpers so no route can\n// invent a third envelope shape.\nfunction fail(error: string, status = 400): Response {\n return Response.json({ protocolVersion: PROTOCOL_VERSION, ok: false, error }, { status });\n}\n\nexport async function serveSource(\n definition: SourceDefinition,\n req: Request,\n): Promise {\n const url = new URL(req.url);\n\n let body: Record = {};\n if (req.method === \"POST\") {\n try {\n const raw = await req.json();\n if (!record(raw)) return fail(\"invalid_body\");\n body = raw;\n } catch {\n return fail(\"invalid_json\");\n }\n if (body.protocolVersion !== PROTOCOL_VERSION) return fail(\"unsupported_protocol\");\n }\n\n // Identity is checked before routing, so a request addressed to the wrong\n // source is a 404 on every path — including /v1/publish. A val that mounts\n // several definitions dispatches on this key.\n const key = req.method === \"GET\" ? url.searchParams.get(\"sourceKey\") ?? definition.key : body.sourceKey;\n if (key !== definition.key) return fail(\"unknown_source\", 404);\n\n if (req.method === \"GET\" && url.pathname === \"/v1/descriptor\") {\n return Response.json({\n protocolVersion: PROTOCOL_VERSION,\n sourceKey: definition.key,\n temporal: definition.temporal ?? true,\n settingsSchema: typeof definition.settingsSchema === \"function\"\n ? await definition.settingsSchema() : definition.settingsSchema,\n ...(definition.options ? { options: await definition.options() } : {}),\n // Derived, never declared: capabilities are read off the definition, so\n // a source cannot advertise a write it doesn't implement or hide one it\n // does.\n capabilities: {\n read: true,\n validateSettings: true,\n write: Object.keys(definition.writes ?? {}),\n publish: false,\n },\n });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/v1/validate-settings\") {\n if (!record(body.settings)) return fail(\"invalid_settings\");\n const parsed = await definition.parseSettings(body.settings);\n if (!parsed.ok) return fail(parsed.error, parsed.status ?? 400);\n // Parsed values can contain private implementation context. Never export them.\n return Response.json({ protocolVersion: PROTOCOL_VERSION, sourceKey: definition.key, ok: true },\n { headers: { \"cache-control\": \"no-store\" } });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/v1/read\") {\n if (!record(body.settings) || !record(body.context)) return fail(\"settings_and_context_required\");\n // The offset is protocol-level, so it is checked here rather than by each\n // source. This is the wide guard — a source's own fallback narrows it\n // further (see ReadContext).\n const tz = body.context.utcOffsetSeconds;\n if (tz !== null && (typeof tz !== \"number\" || !Number.isInteger(tz) || Math.abs(tz) > 86400)) {\n return fail(\"invalid_timezone\");\n }\n const parsed = await definition.parseSettings(body.settings);\n if (!parsed.ok) return fail(parsed.error, parsed.status ?? 400);\n\n const produced = await definition.read(parsed.value, { utcOffsetSeconds: tz as number | null });\n // Guarding the source's own output, not a remote's: a duplicate id or a\n // non-finite timestamp is rejected here rather than at the parent, where\n // the whole composition would fail without naming which source produced\n // it. 502 and not 500 — the source answered, the answer was unusable.\n if (!items(produced)) return fail(\"invalid_source_output\", 502);\n return Response.json(\n { protocolVersion: PROTOCOL_VERSION, sourceKey: definition.key, items: produced },\n { headers: { \"cache-control\": \"no-store\" } },\n );\n }\n\n if (req.method === \"POST\" && url.pathname === \"/v1/write\") {\n if (!record(body.payload)) return fail(\"invalid_payload\");\n // Object.hasOwn, not a plain lookup: `writes` is an object literal, so\n // `operation: \"toString\"` would otherwise resolve to Object.prototype's\n // method and get called with the payload.\n const writes = definition.writes ?? {};\n const operation = typeof body.operation === \"string\" ? body.operation : \"\";\n if (!Object.hasOwn(writes, operation)) return fail(\"unsupported_operation\", 422);\n const handler = writes[operation];\n const outcome = await handler(body.payload);\n if (!outcome.ok) return fail(outcome.error, outcome.status ?? 400);\n return Response.json({\n protocolVersion: PROTOCOL_VERSION,\n sourceKey: definition.key,\n ok: true,\n result: outcome.value,\n });\n }\n\n // Reserved rather than absent: the parent already knows the route, and a\n // 501 tells it \"not yet\" where a 404 would say \"never\".\n if (url.pathname === \"/v1/publish\") return fail(\"not_implemented\", 501);\n return fail(\"not_found\", 404);\n}\n",[],[159,250],"4095f45e-b529-4dea-b4be-9eef7b0e1469","defineSource.ts","01a07d73-0d02-703f-be72-e85ee4c5bb06",["D",1788811087002],"// The author-facing surface: everything an implementer writes, and nothing\n// they don't. A source is one object. serveSource turns it into the protocol.\n//\n// Part of the SDK — see sdk/contract.ts's header for the import rule.\n\nimport type { Item, Result } from \"./contract.ts\";\n\n// Everything the parent forwards about the caller, which is deliberately\n// almost nothing: no device identity, no user id, no presentation. A source\n// gets a timezone offset and the settings that caller chose, and that is the\n// whole input surface.\n//\n// `utcOffsetSeconds: null` means the parent had no offset to forward. It does\n// NOT mean UTC, and treating it as UTC is a bug: it silently shifts every\n// day boundary to Greenwich for callers the parent couldn't resolve. Fall\n// back to a default the source picks.\nexport type ReadContext = { utcOffsetSeconds: number | null };\n\n// A write handler. The SDK has already checked that `payload` is a JSON\n// object; validating its contents is the operation's own job, because only it\n// knows the shape. Return `reject(\"...\")` for bad input rather than throwing.\nexport type WriteHandler = (\n payload: Record,\n) => Promise> | Result;\n\nexport type SourceDefinition = {\n // The protocol `sourceKey`. The parent addresses this source by it and the\n // SDK rejects any request naming a different one.\n key: string;\n\n // Whether items carry meaningful times. Advertised in the descriptor;\n // defaults to true, which is the only shape v1's Item can express.\n temporal?: boolean;\n\n // JSON Schema for `settings`, published in the descriptor so the parent can\n // build a settings UI without knowing what this source is. It is\n // DOCUMENTATION, not enforcement — the SDK does not validate against it.\n // parseSettings is what actually decides.\n settingsSchema: Record | (() => Promise> | Record);\n\n // The choices a caller can pick from, published alongside the schema — a\n // catalog, a list of channels, whatever this source's settings reference.\n // Called on every descriptor request, so it may hit storage. Omit it for a\n // source whose settings are free-form.\n options?: () => Promise | unknown;\n\n // Raw `settings` in, whatever `read` needs out. This is the ONLY place a\n // source validates caller input, and it must be total: reject anything not\n // recognized, including unknown keys.\n //\n // It may do I/O, and that is a feature — it is where to load a snapshot\n // that both validation and the read itself need (a catalog, say), so the\n // request pays for it once. Whatever it returns is handed to `read`\n // verbatim, so the returned type is free to be richer than the wire\n // settings.\n parseSettings: (\n raw: Record,\n ) => Promise> | Result;\n\n // The source itself. Parsed settings in, items out. Anything it returns is\n // validated against the item contract before it leaves the val, so this can\n // return its natural output and let the SDK be the gate.\n read: (settings: Settings, context: ReadContext) => Promise;\n\n // Named side effects the parent can invoke, if this source has any. The\n // keys become the protocol's `operation` values and the descriptor's\n // advertised write capabilities — declared once, so what a source says it\n // can do cannot drift from what it does.\n writes?: Record;\n};\n\n// Identity function. It exists purely so `Settings` is inferred from\n// parseSettings and checked against read's parameter at the definition site,\n// where the mismatch is legible, instead of at the serveSource call.\nexport function defineSource(\n definition: SourceDefinition,\n): SourceDefinition {\n return definition;\n}\n",[],[159,257],"c1b52ebd-03e9-42fb-a8f7-5c0862124831","contract.ts","01a07d73-0d02-703f-be72-e4b5574cb596",["D",1788811087002],"// What a source is held to: version 1 of the temporal item contract.\n//\n// This directory is the SDK. It is the half of this val that knows nothing\n// about sports, and the boundary is structural, not stylistic: NOTHING under\n// sdk/ may import anything outside sdk/. tools/sdk-boundary-check.ts fails if\n// that is ever violated, which is what keeps this directory extractable into\n// its own published val without a rewrite. See sdk/README.md before editing.\n\nexport const PROTOCOL_VERSION = 1;\n\n// The one payload shape every source produces, whatever it is a source of.\n// There is no away/home, no score, no sport — a source decides what to *say*\n// and the client renders these six fields blind.\n//\n// `caption: null` is a protocol value, not an absent field: it tells the\n// client to format `timestamp` itself as a local time. A source that wants\n// no caption at all still sends null.\n//\n// `timestamp` is Unix EPOCH SECONDS, not milliseconds. This is the single\n// most common implementation mistake: sending ms decodes on the client as a\n// date ~57,000 years out, and no type-level check catches it because both are\n// numbers. `items()` below cannot catch it either — it can only reject values\n// too large to be a plausible second-precision timestamp.\nexport type Item = {\n id: string;\n mainText: string;\n subText: string;\n caption: string | null;\n emphasized: boolean;\n timestamp: number;\n};\n\nexport function record(value: unknown): value is Record {\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\n}\n\n// The gate every source's output passes through before it leaves the val.\n// serveSource applies this automatically, so an implementer cannot ship a\n// malformed item by forgetting to check: a failing read returns 502\n// invalid_source_output from this source rather than failing composition at\n// the parent, where nothing would name which source produced the bad item.\n//\n// `id` must be unique within one response and stable across polls of the same\n// underlying thing; the parent namespaces it per source, so it only has to be\n// unique here.\nexport function items(value: unknown): value is Item[] {\n return Array.isArray(value) && value.every(v => record(v)\n && typeof v.id === \"string\" && v.id.length > 0\n && typeof v.mainText === \"string\" && typeof v.subText === \"string\"\n && (v.caption === null || typeof v.caption === \"string\")\n && typeof v.emphasized === \"boolean\" && typeof v.timestamp === \"number\"\n && Number.isFinite(v.timestamp) && Math.abs(v.timestamp) <= 8640000000000)\n && new Set(value.map(v => v.id)).size === value.length;\n}\n\n// How a source hands a rejection back to the SDK instead of throwing. One\n// type for both settings parsing and write operations, so there is a single\n// failure idiom to learn.\n//\n// `error` becomes the protocol's error code verbatim, so it should be a\n// stable snake_case token the parent can branch on (\"unknown_team\"), not a\n// sentence. `status` defaults to 400 — the codes worth overriding are 404 for\n// a thing that does not exist and 422 for a well-formed request this source\n// will not perform.\n//\n// Returning a rejection is not the same as throwing: a throw is a bug and\n// surfaces as a 500, while a rejection is this source correctly refusing.\nexport type Result =\n | { ok: true; value: T }\n | { ok: false; error: string; status?: number };\n\nexport function accept(value: T): Result {\n return { ok: true, value };\n}\n\nexport function reject(error: string, status = 400): Result {\n return { ok: false, error, status };\n}\n",[],[159,264],"e9d99da0-b99c-4cb1-bcff-dd9727a4e43d","README.md","01a07d73-0d02-703f-be72-e0e1032733f8",["D",1788811087002],"# Source SDK (protocol v1)\n\nA **source** answers one question: *given these settings and this caller's\ntimezone, what are the next few things worth showing?* It returns a flat list\nof items. It does not know who is asking, what else is on the screen, or how\nany of it is rendered.\n\nThis directory is everything that is true of every source. It has **no\ndependencies** — not on npm, not on Val Town's `std`, not on the val around it.\nThree files:\n\n| File | What's in it |\n| --- | --- |\n| `contract.ts` | `Item`, the validator that enforces it, and `accept`/`reject` |\n| `defineSource.ts` | `SourceDefinition` — the whole author-facing surface |\n| `serve.ts` | `serveSource()` — the protocol, as a function of a definition |\n\n## Write a source\n\nFor the parent’s supported browser forms, see [the settings form contract](settings-form.md).\nThe protocol permits broader schemas; the parent deliberately rejects forms outside\nits small supported subset. The example below illustrates the broader protocol,\nnot a browser-renderable form.\n\nOne object, one mount. That is the entire API.\n\n```ts\nimport { accept, reject } from \"./sdk/contract.ts\";\nimport { defineSource } from \"./sdk/defineSource.ts\";\n\nexport default defineSource<{ city: string }>({\n key: \"weather\",\n\n settingsSchema: {\n type: \"object\",\n properties: { city: { type: \"string\" } },\n required: [\"city\"],\n additionalProperties: false,\n },\n\n // Optional legacy metadata. The parent does not render this; browser choices\n // must be bound to properties in settingsSchema (see settings-form.md).\n options: () => listCities(),\n\n // The only place caller input is validated. Must be total — reject anything\n // you don't recognize, unknown keys included. May do I/O.\n parseSettings: (raw) =>\n typeof raw.city === \"string\" && known(raw.city)\n ? accept({ city: raw.city })\n : reject(\"unknown_city\"),\n\n // The source itself. Timestamps are Unix SECONDS.\n read: async ({ city }, { utcOffsetSeconds }) => [{\n id: `weather:${city}:tomorrow`,\n mainText: \"Rain expected\",\n subText: \"Portland\",\n caption: null,\n emphasized: false,\n timestamp: 1788739200,\n }],\n\n // Optional: named side effects. The keys become the protocol's `operation`\n // values and the descriptor's advertised capabilities.\n writes: {\n \"cache.put\": async (payload) =>\n typeof payload.dateKey === \"string\"\n ? accept(await store(payload))\n : reject(\"invalid_cache_payload\"),\n },\n});\n```\n\nThen mount it behind whatever auth the deployment wants:\n\n```ts\n// rpc.ts — an HTTP val\nexport default (req: Request) =>\n authorized(req) ? serveSource(mySource, req) : unauthorized();\n```\n\n`tools/sdk-check.ts` in this val defines a complete fixture source in ~30\nlines and asserts the protocol against it. It is the shortest working example;\ncopying it is a reasonable way to start.\n\n## What the SDK does, so you don't\n\n- Routes `/v1/descriptor`, `/v1/validate-settings`, `/v1/read`, `/v1/write`, `/v1/publish`.\n- Validation-only requests call `parseSettings` without calling `read` or returning\n the parsed internal value. Keep `parseSettings` free of mutations.\n- `settingsSchema` may be an object or an async function returning one.\n- Parses and shape-checks the request body; rejects a wrong `protocolVersion`\n or a `sourceKey` that isn't yours.\n- Validates `context.utcOffsetSeconds` before your code sees it.\n- **Validates your output.** Items that break the contract — a duplicate `id`,\n a non-finite timestamp — never leave the val; the request fails 502\n `invalid_source_output` instead of failing composition at the parent, where\n nothing would say which source produced the bad item.\n- Derives `capabilities` from the definition, so what a source advertises\n cannot drift from what it implements.\n- Writes every response envelope, so no route can invent a new one.\n\n## What is yours\n\n- **Validating settings.** `settingsSchema` is published for the parent's UI;\n the SDK does not enforce it. The parent checks its supported form subset and\n posted values, then asks `parseSettings` to decide before saving. Reads also\n call `parseSettings` independently.\n- **Being total.** Reject unknown keys. A setting you silently ignore is a\n setting a caller thinks is working.\n- **Failing by returning, not throwing.** `reject(\"code\")` is this source\n correctly refusing, and the code reaches the parent verbatim — make it a\n stable snake_case token it can branch on, not a sentence. A throw is a bug\n and surfaces as a 500.\n- **Deciding what `null` means.** `utcOffsetSeconds: null` means the parent had\n no offset to forward. It does **not** mean UTC. Fall back to a zone you pick;\n treating it as 0 quietly moves every day boundary to Greenwich.\n\n## What is nobody's job here\n\nThese belong to the parent, and a source that does them will conflict with it:\n\n- Composition across sources, and namespacing ids (the parent prefixes yours).\n- Presentation: envelopes, eyebrows, section headers, empty-state copy.\n- Device or user identity — a source never learns who is asking.\n- Auth. That is the mount's business, not the source's.\n\n## Three things that go wrong\n\n1. **Milliseconds in `timestamp`.** It is Unix *seconds*. Sending ms decodes on\n the client as a date ~57,000 years out, and nothing catches it: both are\n numbers, and the contract validator can only reject values too large to be a\n plausible timestamp — a real ms value is not. Pin it in a test.\n2. **An `id` that isn't stable.** It must be the same across polls of the same\n underlying thing, and unique within one response. An id containing \"now\"\n makes every poll look like new content.\n3. **Re-reading storage in `read`.** `parseSettings` may do I/O and hands its\n return value to `read` verbatim — load the snapshot there once, and pass it\n along. As a bonus the request is then resolved against one consistent\n snapshot rather than two.\n\n## The one structural rule\n\n**Nothing under `sdk/` may import anything outside `sdk/`.**\n\nThat is what makes this directory liftable into its own published val without a\nrewrite, and it is the kind of rule that decays quietly, so it is enforced\nrather than asked for: `tools/sdk-check.ts` fails if an import escapes the\ndirectory, or if SDK *code* so much as names one of the host val's domain\nconcepts. Run it after touching anything in here.\n\nDomain vocabulary belongs on the other side of the seam — in this val, that is\n`sportsSource.ts` (the definition) and `lib/` (how it gets its data).\n",[],[159,271],["D",1788811087002],[195,196,197,198,199],[159],"a166d09b-9afd-4772-9fc0-c59afdf5f27a","widgetItems.ts","01a07d73-0d02-703f-be72-d9f1a5f93f83",["D",1788811087002],"// The games-data -> temporal-item boundary: EnrichedGame in, the widget's view\n// shape out. Every field here is a *view* decision — the server decides exactly\n// what text to show and the client is a dumb template with no knowledge of\n// \"teams\", \"scores\" or \"games\". There is deliberately no away/home object and\n// no score field.\n//\n// The wire keys (`id`, `mainText`, `subText`, `caption`, `emphasized`,\n// Unix-second `timestamp`) are mirrored by the Codable types at\n// Shared/WidgetPayload.swift in the iOS repo. Only add fields, never\n// remove/repurpose one, without a coordinated schemaVersion bump.\n//\n// The item text used to be assembled through a WidgetItemTemplate value —\n// `{{sportEmoji}}{{away}} @ {{home}}` fed to a small interpolator — so that a\n// seasonal or personalized presentation could be a new template rather than a\n// new code path. That never happened: there was one template value, no lookup,\n// and no caller that passed a second one, so the indirection only made the two\n// strings below harder to find. It is gone. Per-caller presentation, when it is\n// actually wanted, is a stored record on the source's own settings, not a\n// string-interpolation layer compiled into this val.\n\nimport type { Catalog } from \"./catalog.ts\";\nimport { teamLabel } from \"./catalog.ts\";\nimport { type ChannelInfo } from \"./channels.ts\";\nimport { flattenByStartTime, type EnrichedGame, type GamesBySport } from \"./games.ts\";\nimport type { Item } from \"../sdk/contract.ts\";\n\ntype Status = \"scheduled\" | \"live\" | \"final\";\n\n// Sleeper's own vocabulary is inconsistent across sports and even across\n// captures of the same sport (nfl games have shown up as both \"scheduled\"\n// and \"pre_game\" for the same not-yet-started state). This maps every value\n// seen live to the three states the widget cares about; anything else falls\n// back to \"scheduled\", which is never fatal — an item the client can't parse\n// is worse than one that's guessed wrong.\nconst STATUS_MAP: Record = {\n scheduled: \"scheduled\",\n pre_game: \"scheduled\",\n postponed: \"scheduled\",\n delayed: \"scheduled\",\n in_game: \"live\",\n in_progress: \"live\",\n live: \"live\",\n halftime: \"live\",\n complete: \"final\",\n final: \"final\",\n closed: \"final\",\n // lib/fiba.ts's adapter sets game.status to ESPN's already-3-valued\n // status.type.state (\"pre\"/\"in\"/\"post\") rather than its noisier\n // status.type.name (\"STATUS_SCHEDULED\" etc.) — exact and free to map,\n // unlike Sleeper's vocabulary above. Live/final accuracy for fiba still\n // depends on how recently source_cache was re-ingested, since nothing\n // fetches it live; presence (a game is on the slate at all) is this\n // source's real contract, not intraday state freshness.\n pre: \"scheduled\",\n in: \"live\",\n post: \"final\",\n};\n\nfunction normalizeStatus(raw: string | null): Status {\n return (raw && STATUS_MAP[raw]) || \"scheduled\";\n}\n\n// `caption: null` is a protocol value, not just \"no status\" — it tells the\n// client to format `timestamp` itself as a local start time, which is right\n// for a game that hasn't started. Only the live case is emphasized; final\n// gets the dim treatment.\nfunction captionFor(status: Status): { caption: string | null; emphasized: boolean } {\n if (status === \"live\") return { caption: \"LIVE\", emphasized: true };\n if (status === \"final\") return { caption: \"END\", emphasized: false };\n return { caption: null, emphasized: false };\n}\n\n// subText's channel metadata, built from exactly what channelInfo already\n// gives — nothing invented for this format. A national channel's\n// directv_channel is the differentiator; a streaming channel has no\n// directv_channel but does carry a device note (\"computer only\"). \"TBD\" is the\n// fallback for the one case channelInfo can't fill in at all: no channel\n// string sent.\nfunction channelText(channel: ChannelInfo): string {\n if (!channel.label) return \"TBD\";\n if (channel.directv_channel) return `${channel.label} · ${channel.directv_channel}`;\n if (channel.note) return `${channel.label} · ${channel.note}`;\n return channel.label;\n}\n\nfunction widgetItem(game: EnrichedGame, catalog: Catalog): { item: Item; status: Status } {\n const status = normalizeStatus(game.statusRaw);\n const away = teamLabel(game.sport, game.away, catalog) ?? game.away ?? \"\";\n const home = teamLabel(game.sport, game.home, catalog) ?? game.home ?? \"\";\n const emoji = catalog.competitions.find((competition) => competition.code === game.sport)?.emoji;\n return {\n item: {\n // Falls back to a value that's at least stable across polls of the\n // same game (the contract's actual requirement) on the rare chance\n // Sleeper omits game_id — real captures always carry it. The parent\n // namespaces this with its own source id before it reaches the widget.\n id: game.id ?? `${game.sport}:${game.away}-${game.home}:${game.start_time}`,\n mainText: `${emoji ? `${emoji} ` : \"\"}${away} @ ${home}`,\n subText: channelText(game.channel),\n ...captionFor(status),\n // Unix epoch seconds, UTC — game.start_time is Sleeper's own\n // milliseconds. Getting this wrong (sending ms) decodes on the client\n // as a timestamp ~57,000 years out; nothing in a passing TS-side test\n // would catch that, only a pinned integer does.\n timestamp: Math.floor(game.start_time / 1000),\n },\n status,\n };\n}\n\n// `hideCompleted` is the assignment's `intradayFilter` setting. Filtering on\n// the status this function already computes, not on caption text: \"END\" is a\n// display string, while `status` is the actual classification.\nexport function widgetItems(\n bySport: GamesBySport,\n catalog: Catalog,\n hideCompleted = false,\n): Item[] {\n const built = flattenByStartTime(bySport).map((game) => widgetItem(game, catalog));\n return (hideCompleted ? built.filter((b) => b.status !== \"final\") : built).map((b) => b.item);\n}\n",[],[164,281],"7bebdceb-1a09-40cb-b043-22407e1664ed","sportsFeed.ts","01a07d73-0d02-703f-be72-d42e400cd77d",["D",1788811087002],"// The sports pipeline: selected team slugs and a client offset in, temporal\n// widget items out. `games` remains the internal adapter name for sports\n// competitions; `sports` is the protocol key the parent addresses.\n\nimport type { Catalog, TeamRef } from \"./catalog.ts\";\nimport { readCatalog } from \"./catalogStore.ts\";\nimport { nextGamesForTeams } from \"./cachedGames.ts\";\nimport { clientOffsetSeconds, dateAtOffset, dayStartMsAtOffset } from \"./dates.ts\";\nimport { fibaGamesForDate, listFutureFibaDateKeys } from \"./fiba.ts\";\nimport { type Game, pickNextPerTeam } from \"./games.ts\";\nimport { resolveTeams } from \"./params.ts\";\nimport { widgetItems } from \"./widgetItems.ts\";\nimport type { Item } from \"../sdk/contract.ts\";\n\n// Exactly the settings sportsSource.ts's parseSettings has already validated\n// against the catalog. Nothing here re-checks them: an unknown slug is simply not found\n// and contributes no candidate.\nexport type SportsSettings = { teams: string[]; intradayFilter: boolean };\n\n// Every game that could answer \"what's next\" for the selected teams, from\n// both sources, as one flat list for pickNextPerTeam to reduce.\n//\n// There is no date window here. Sleeper answers from lib/cachedGames.ts with\n// one indexed seek per team and no upper bound at all, so a weekly sport's\n// next game is found however far out it sits.\n//\n// fiba deliberately still reads source_cache: its payload is a whole\n// tournament slate keyed by date, which is a shape a date-keyed blob serves\n// perfectly well (nobody asks \"when does Spain next play\" without wanting\n// the tournament anyway). What it does not bring is its own selection logic —\n// it contributes candidates and pickNextPerTeam decides, same as Sleeper.\n// Normalizing fiba into cached_games too is the obvious next step, and would\n// delete this branch.\n//\n// Both sources are held to the same `fromMs` lower bound. fiba's used to be\n// a date-string comparison against its UTC date_key, which quietly included\n// a game that had already fallen into the client's previous day; filtering\n// on the absolute instant is what the \"rest of the client's day\" rule\n// actually means.\nexport async function candidateGames(\n teams: TeamRef[],\n fromMs: number,\n clientOffset: number,\n catalog: Catalog,\n): Promise {\n const adapters = new Map(catalog.competitions.map((competition) => [competition.code, competition.adapter]));\n const sleeperTeams = teams.filter((team) => adapters.get(team.sport) === \"sleeper\");\n const wantsFiba = teams.some((team) => adapters.get(team.sport) === \"fiba\");\n\n const [sleeperGames, fibaGames] = await Promise.all([\n nextGamesForTeams(sleeperTeams, fromMs),\n wantsFiba\n ? listFutureFibaDateKeys(dateAtOffset(clientOffset, new Date(fromMs)))\n .then((dates) => Promise.all(dates.map(fibaGamesForDate)))\n .then((byDate) => byDate.flat())\n : Promise.resolve([] as Game[]),\n ]);\n\n return [...sleeperGames, ...fibaGames].filter((game) => game.start_time >= fromMs);\n}\n\n// `utcOffsetSeconds: null` means the parent had no client offset to pass on,\n// not \"UTC\" — it falls back to this source's own default zone rather than\n// silently shifting every selected day boundary to Greenwich.\n//\n// The lower bound is the START of the client's day, not `now`, and that is\n// deliberate: it is what keeps a finished game on the card for the rest of\n// the day. `intradayFilter` is the opt-out.\nexport async function sportsItems(\n settings: SportsSettings,\n utcOffsetSeconds: number | null,\n catalog?: Catalog,\n): Promise {\n const resolvedCatalog = catalog ?? await readCatalog();\n const { teams, sports } = resolveTeams(settings.teams, resolvedCatalog);\n const offsetSeconds = clientOffsetSeconds(utcOffsetSeconds);\n const fromMs = dayStartMsAtOffset(offsetSeconds);\n const candidates = await candidateGames(teams, fromMs, offsetSeconds, resolvedCatalog);\n const picked = pickNextPerTeam(candidates, teams, sports);\n return widgetItems(picked?.bySport ?? [], resolvedCatalog, settings.intradayFilter);\n}\n",[],[164,288],"fa984eb4-fc06-497b-96e1-f7fa68b0c824","sourceCache.ts","01a07d73-0d02-703f-be72-d3eee9892689",["D",1788811087002],"// Storage boundary for payloads this val can't fetch live at request time.\n// An external process fetches FIBA data from an unblocked network and POSTs\n// it to the parent val's central /ingest route; that route imports this\n// module's write function, so the payload lands in this val's database.\n//\n// Deliberately source-agnostic: `source` and `dateKey` are opaque strings\n// this table doesn't interpret, so a second source that needs the same\n// fetch-elsewhere/serve-from-cache split reuses this table instead of\n// growing a parallel one. Shaping the cached payload into this project's\n// Game type is reconciliation-service work this file doesn't do — it only\n// stores and returns whatever JSON it was handed.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nlet schemaReady: Promise | null = null;\n\n// Idempotent and memoized: cheap on a warm val, with the memo cleared on\n// failure so one\n// transient sqlite hiccup doesn't wedge every later request in this process.\nexport function ensureSourceCacheSchema(): Promise {\n if (!schemaReady) {\n schemaReady = sqlite\n .execute(`\n CREATE TABLE IF NOT EXISTS source_cache (\n source TEXT NOT NULL,\n date_key TEXT NOT NULL,\n payload TEXT NOT NULL,\n fetched_at TEXT NOT NULL,\n PRIMARY KEY (source, date_key)\n )\n `)\n .then(() => undefined)\n .catch((err) => {\n schemaReady = null;\n throw err;\n });\n }\n return schemaReady;\n}\n\n// Upsert, not insert: re-ingesting the same source/dateKey (a live game's\n// score changing, a re-run of a backfill) is the expected steady state, not\n// an error.\nexport async function saveSourcePayload(source: string, dateKey: string, payload: unknown): Promise {\n await ensureSourceCacheSchema();\n await sqlite.execute({\n sql: `INSERT INTO source_cache (source, date_key, payload, fetched_at) VALUES (?, ?, ?, ?)\n ON CONFLICT(source, date_key) DO UPDATE SET payload = excluded.payload, fetched_at = excluded.fetched_at`,\n args: [source, dateKey, JSON.stringify(payload), new Date().toISOString()],\n });\n}\n\n// The other half of the \"sqlite-backed sources aren't cost-bound the way a\n// per-date live fetch is\" decision: instead of scanning a fixed N-day\n// window like lib/dates.ts's windowDatesFor (justified there by Sleeper's\n// one-request-per-date cost, which doesn't apply to a local table scan),\n// a cache-backed source's window is whatever it actually has ingested from\n// `fromDateKey` forward — no day count to keep in sync with how far out a\n// tournament's schedule happens to be published.\nexport async function listFutureDateKeys(source: string, fromDateKey: string): Promise {\n await ensureSourceCacheSchema();\n const result = await sqlite.execute({\n sql: \"SELECT date_key FROM source_cache WHERE source = ? AND date_key >= ? ORDER BY date_key\",\n args: [source, fromDateKey],\n });\n return (result.rows as { date_key: string }[]).map((row) => row.date_key);\n}\n\nexport type CachedSourcePayload = { payload: unknown; fetchedAt: string };\n\nexport async function getSourcePayload(source: string, dateKey: string): Promise {\n await ensureSourceCacheSchema();\n const result = await sqlite.execute({\n sql: \"SELECT payload, fetched_at FROM source_cache WHERE source = ? AND date_key = ?\",\n args: [source, dateKey],\n });\n const row = result.rows[0] as { payload: string; fetched_at: string } | undefined;\n if (!row) return null;\n return { payload: JSON.parse(row.payload), fetchedAt: row.fetched_at };\n}\n",[],[164,295],"5feb44bf-cd4a-48f8-969c-4033d01e5213","sleeperIngest.ts","01a07d73-0d02-703f-be72-ce24ada1e658",["D",1788811087002],"// The write side of lib/cachedGames.ts: fetch Sleeper's per-date slate and\n// normalize it into rows.\n//\n// This is the reconciliation step, and it is the reason the read path can be\n// a plain indexed query. Sleeper's payload varies by sport — away_team is a\n// string for nfl/cfb but an object for wnba — so *somebody* has to resolve\n// that. Doing it once here, at write time, is what lets rowToGame hand back a\n// single flat shape and keeps that hazard out of SQL, where it could not be\n// tested. teamCode is imported rather than reimplemented for the same reason:\n// two readings of Sleeper's shape in one codebase is how they drift.\n//\n// Separate from the parent val's operator-facing runner on purpose. This\n// module is importable with no side effects, so scripts or a future interval\n// can call ingestSleeperWindow() without reimplementing storage behavior.\n\nimport { readCatalog } from \"./catalogStore.ts\";\nimport { saveCachedGames, type CachedGameRow } from \"./cachedGames.ts\";\nimport { addDays, todaySlateDate } from \"./dates.ts\";\nimport { teamCode, type Game } from \"./games.ts\";\nimport { fetchScores } from \"./sleeper.ts\";\n\n\nexport type IngestReport = {\n dates: string[];\n fetched: number;\n stored: number;\n skipped: number;\n bySport: Record;\n};\n\n// A row needs a stable id and a real start instant; without either it cannot\n// be upserted or ordered, which is all this table does. Everything else is a\n// progressive enhancement and degrades to null, the same way the pipeline\n// already tolerates a Sleeper game missing a channel or a score.\nexport function normalizeGame(game: Game): CachedGameRow | null {\n const gameId = game.game_id;\n const id = typeof gameId === \"string\" || typeof gameId === \"number\" ? String(gameId) : null;\n const startTimeMs = typeof game.start_time === \"number\" ? game.start_time : NaN;\n if (!id || !game.sport || !Number.isFinite(startTimeMs) || startTimeMs <= 0) return null;\n\n return {\n sport: game.sport,\n game_id: id,\n away_code: teamCode(game.metadata?.away_team),\n home_code: teamCode(game.metadata?.home_team),\n // Sleeper's own milliseconds, stored unconverted — see CachedGameRow.\n start_time_ms: startTimeMs,\n status: typeof game.status === \"string\" ? game.status : null,\n channel: game.metadata?.channel ?? null,\n };\n}\n\n// `days` forward from today, in Sleeper's own Eastern calendar — that is the\n// bucket /scores keys on, so iterating it is the only way to be sure a day\n// isn't half-fetched. Note this is the LAST place Sleeper's Eastern\n// bucketing matters: rows carry absolute instants, so the read path never\n// has to reason about it again.\n//\n// `backfillDays` is why the window starts BEFORE today, and it is not\n// padding. A client west of Eastern is still inside its own \"today\" while\n// Eastern has already rolled over, so a game that is live right now for a\n// Pacific viewer can sit in yesterday's Eastern bucket. Starting at today\n// dropped exactly that game — observed on the first run, which fetched a\n// Friday-night slate whose 9pm Pacific kickoffs were all filed under\n// Saturday. One extra request removes the whole class of edge.\n//\n// One request per date covers every sport at once, so the cost is\n// days + backfillDays + 1 requests total, not that times sports.\nexport async function ingestSleeperWindow(\n days = 7,\n now = new Date(),\n backfillDays = 1,\n): Promise {\n const start = addDays(todaySlateDate(now), -backfillDays);\n const dates = Array.from(\n { length: days + backfillDays + 1 },\n (_, i) => addDays(start, i),\n );\n\n const catalog = await readCatalog();\n const competitions = catalog.competitions.filter((competition) => competition.adapter === \"sleeper\");\n const codes = new Map(competitions.map((competition) => [competition.providerKey, competition.code]));\n const perDate = await Promise.all(\n codes.size > 0 ? dates.map((date) => fetchScores(date, [...codes.keys()])) : [],\n );\n\n const fetched = perDate.flat();\n const rows: CachedGameRow[] = [];\n let skipped = 0;\n for (const game of fetched) {\n const sport = codes.get(game.sport);\n const row = sport ? normalizeGame({ ...game, sport }) : null;\n if (row) rows.push(row);\n else skipped++;\n }\n\n // Two dates can return the same game (Sleeper's own bucketing around\n // midnight), and saveCachedGames chunks — so collapse duplicates here\n // rather than relying on two upserts inside one batch resolving in order.\n const byKey = new Map();\n for (const row of rows) byKey.set(`${row.sport}:${row.game_id}`, row);\n const deduped = [...byKey.values()];\n\n const stored = await saveCachedGames(deduped);\n\n const bySport: Record = {};\n for (const row of deduped) bySport[row.sport] = (bySport[row.sport] ?? 0) + 1;\n\n return { dates, fetched: fetched.length, stored, skipped, bySport };\n}\n",[],[164,302],"f9a51cb0-0a1b-42ab-9587-9b7362028888","sleeper.ts","01a07d73-0d02-703f-be72-c8ed0bd02d8b",["D",1788811087002],"// Sleeper's outbound I/O. Everything else under lib/ is pure or SQLite,\n// which is what lets tests/ run the whole slate pipeline against captured\n// fixtures with no network — this file is the seam they stop at, and the\n// deployed endpoint is what covers it (see docs/HANDOFF.md).\n//\n// No longer on the request path. Until cached_games arrived this was called\n// live, once per date in the scan window, on every widget request; it is now\n// reached only from lib/sleeperIngest.ts. That is the whole point of the\n// move — a request answers from an index instead of from N third-party\n// round trips whose cost is what forced the window to be narrow.\n\nimport { type Game } from \"./games.ts\";\n\nexport async function fetchScores(date: string, sports: string[]): Promise {\n const url = new URL(\"https://api.sleeper.app/scores\");\n for (const sport of sports) url.searchParams.append(\"sports[]\", sport);\n url.searchParams.set(\"date\", date);\n\n const res = await fetch(url);\n if (!res.ok) throw new Error(`Sleeper /scores returned ${res.status}`);\n return (await res.json()) ?? [];\n}\n",[],[164,309],"5196e9f6-b8a2-4592-8d00-80ca5c3f9a76","params.ts","01a07d73-0d02-703f-be72-c64e91d179dc",["D",1788811087002],"// Selection: assignment team slugs in, a resolved fetch-and-filter plan out.\n// Pure — no I/O.\n\nimport type { Catalog, TeamRef } from \"./catalog.ts\";\n\n// Input abuse limit, independent of the catalog size.\nconst MAX_TEAMS = 120;\n\nexport type ResolvedTeams = {\n // Derived from the resolved teams, never requested directly. It exists\n // only to tell candidateGames which adapters to hit and groupBySport\n // which order to emit groups in — it is not a filter of its own.\n sports: string[];\n teams: TeamRef[];\n};\n\n// Teams are the only selector. This product shows a handful of events\n// someone actually cares about, and a whole-league request is the opposite\n// of that — it produced exactly the laundry-list card the team filter\n// exists to avoid. There is no \"sports mode\" to fall through to, so no\n// selection can widen itself: an empty or fully-unknown list resolves to\n// zero teams, zero derived sports, and an empty slate. An empty card is the\n// honest answer to \"show me nothing in particular\".\n//\n// Nothing here rejects or throws. sportsSource.ts's parseSettings has already\n// validated every slug against the catalog and rejected an unknown one, so\n// the drift echo this function used to carry (`rejected`) had no remaining\n// reader; a slug that somehow isn't found here is simply skipped.\nexport function resolveTeams(slugs: string[], catalog: Catalog): ResolvedTeams {\n const bySlug = new Map(catalog.teams.map((team) => [team.slug, team]));\n const teams: TeamRef[] = [];\n for (const slug of new Set(slugs)) {\n const team = bySlug.get(slug);\n if (team && teams.length < MAX_TEAMS) {\n teams.push({ sport: team.competitionCode, code: team.providerCode });\n }\n }\n\n return {\n sports: catalog.competitions.map((competition) => competition.code)\n .filter((sport) => teams.some((team) => team.sport === sport)),\n teams,\n };\n}\n",[],[164,316],"ca0bd06d-d74c-4ec7-8c2a-28e0a5d49349","games.ts","01a07d73-0d02-703f-be72-c070e5f35e3f",["D",1788811087002],"// The game slate: Sleeper's raw /scores payload in, enriched and grouped\n// games out. Pure — the fetch that produces the input lives in sleeper.ts.\n\nimport { type TeamRef } from \"./catalog.ts\";\nimport { channelInfo, type ChannelInfo } from \"./channels.ts\";\n\n// away_team/home_team ships as a plain string for nfl but as\n// { record, team } for wnba (and mlb) — same shape hazard the Rails view\n// papers over with `dig(...) rescue metadata[\"away_team\"]`.\n//\n// Named for what it returns: Sleeper's abbreviation (\"IND\"), not a name.\n// `teamLabel` in teams.ts is the one that turns that into \"Fever\".\n// Exported for lib/sleeperIngest.ts, which resolves this hazard once at\n// write time so lib/cachedGames.ts can store the flat variant. Duplicating\n// the logic there instead would put two readings of Sleeper's shape in the\n// codebase — exactly the drift this file's header warns about. It is now the\n// only such reading left; see the note on scores below.\nexport function teamCode(value: unknown): string | null {\n if (value && typeof value === \"object\") return (value as { team: string }).team;\n return (value as string) ?? null;\n}\n\n// Scores are deliberately absent from this model. The product shows no score\n// and no game clock, so nothing ever read the fields that used to be here\n// (`teamScore`, `awayScore`/`homeScore`, `metadata.away_score`/`home_score`)\n// or the `cached_games` columns behind them — they were carried purely because\n// Sleeper sends them. Reinstating them means re-reading Sleeper's shape, which\n// is two hazards deep and worth recording: wnba/mlb nest the score inside the\n// away_team/home_team object while nfl uses sibling flat fields, and among the\n// nesting sports mlb calls it `score` while wnba calls it `points`.\nexport type Game = {\n sport: string;\n start_time: number;\n status?: unknown;\n game_id?: unknown;\n metadata: {\n away_team?: unknown;\n home_team?: unknown;\n channel?: string | null;\n };\n};\n\nexport type EnrichedGame = Game & {\n away: string | null;\n home: string | null;\n channel: ChannelInfo;\n id: string | null;\n statusRaw: string | null;\n};\n\nexport type GamesBySport = { sport: string; games: EnrichedGame[] }[];\n\n// The three steps transformScores used to do inline, split out so\n// pickNextSlate can filter the same enriched date by one team at a time\n// instead of re-deriving away/home/channel/id/etc. per team.\nfunction enrichGames(games: Game[]): EnrichedGame[] {\n return (games ?? []).map((game) => ({\n ...game,\n away: teamCode(game.metadata?.away_team),\n home: teamCode(game.metadata?.home_team),\n channel: channelInfo(game.metadata?.channel),\n id: typeof game.game_id === \"string\" || typeof game.game_id === \"number\" ? String(game.game_id) : null,\n statusRaw: typeof game.status === \"string\" ? game.status : null,\n }));\n}\n\n// Matched on the (sport, code) pair, never the bare code — `IND` is three\n// different franchises across wnba/nfl/nba, so a code-only match makes\n// \"fever\" quietly include Colts and Pacers games.\nfunction filterByTeams(enriched: EnrichedGame[], teams: TeamRef[]): EnrichedGame[] {\n if (!teams.length) return enriched;\n return enriched.filter((game) =>\n teams.some((t) => t.sport === game.sport && (game.away === t.code || game.home === t.code)),\n );\n}\n\nfunction groupBySport(enriched: EnrichedGame[], sports: string[]): GamesBySport {\n const bySport = Object.groupBy(enriched, (g) => g.sport) as Record;\n return sports\n .filter((sport) => bySport[sport]?.length)\n .map((sport) => ({ sport, games: bySport[sport].toSorted((a, b) => a.start_time - b.start_time) }));\n}\n\n// Flattens the sport groups into one chronological list. The item contract\n// has no sport headings, so grouping is an internal ordering detail only.\n//\n// Flattening in competition order instead produced a list that looked\n// time-sorted but wasn't (a 4:30pm wnba game above a 9:35am mlb one, with\n// nothing on the card explaining the jump), and — worse — made truncation\n// sport-biased: whichever sport sorts first claims the visible rows, so a\n// medium widget showing 2 of 17 gave both slots to wnba. With four sports\n// that can make a whole sport structurally unreachable.\nexport function flattenByStartTime(bySport: GamesBySport): EnrichedGame[] {\n return bySport.flatMap((group) => group.games).toSorted((a, b) => a.start_time - b.start_time);\n}\n\n// Each favorite's own next game, unioned — the one selection rule, applied\n// to a flat list of candidate games regardless of which source produced\n// them.\n//\n// This replaces pickNextSlate, which took (dates, gamesByDate) and walked\n// the date axis because that was the only axis its inputs had. Sleeper's\n// candidates now arrive already reduced to one row per team by an indexed\n// query (lib/cachedGames.ts), and fiba's arrive as a flat list read from\n// source_cache. Neither needs a walk, and both need the same three closing\n// steps — pick per team, dedupe, group — so those live here once instead of\n// being re-derived per source.\n//\n// Resolving each team independently is the load-bearing part, kept verbatim\n// from pickNextSlate: one shared \"earliest\" across the set silently drops\n// every OTHER favorite whose next game lands later.\n// `teams[]=sparks&teams[]=fever&teams[]=trojans` with the Trojans playing\n// tonight but Sparks/Fever not until Sunday must return all three, not just\n// the Trojans game. Two favorites in the same game are deduped rather than\n// shown twice.\n//\n// `candidates` is expected to be pre-filtered to games at or after the\n// caller's lower bound; this function picks the earliest of what it is\n// handed and does not know what \"now\" means.\n//\n// `null` means no candidate matched ANY selected team. With the range\n// window gone that reads differently than it used to: it is far more likely\n// to mean the ingest hasn't covered this team yet than that the team has no\n// scheduled game — see cachedGamesCoverage.\nexport function pickNextPerTeam(\n candidates: Game[],\n teams: TeamRef[],\n sports: string[],\n): { earliestStartMs: number; bySport: GamesBySport } | null {\n if (!teams.length) return null;\n\n const enriched = enrichGames(candidates).toSorted((a, b) => a.start_time - b.start_time);\n\n const matched: EnrichedGame[] = [];\n for (const team of teams) {\n const next = enriched.find((game) => filterByTeams([game], [team]).length > 0);\n if (next) matched.push(next);\n }\n if (!matched.length) return null;\n\n const seen = new Set();\n const deduped = matched.filter((g) => {\n const key = g.id ?? `${g.sport}:${g.away}-${g.home}:${g.start_time}`;\n if (seen.has(key)) return false;\n seen.add(key);\n return true;\n });\n\n return {\n earliestStartMs: Math.min(...deduped.map((g) => g.start_time)),\n bySport: groupBySport(deduped, sports),\n };\n}\n",[],[164,323],"6aaeecde-28a7-43db-84c0-e48148ff2585","fiba.ts","01a07d73-0d02-703f-be72-bc8d9c820174",["D",1788811087002],"// FIBA's read-side seam is backed by lib/sourceCache.ts instead of a live\n// fetch. ESPN blocks Val Town's shared egress, so an external process seeds\n// rows through the parent val's central /ingest route before this reads them.\n//\n// mapEventToGame is the reconciliation step: ESPN's raw scoreboard shape,\n// translated into this project's Game type so the existing pure pipeline\n// (lib/games.ts's enrichGames/filterByTeams/groupBySport/pickNextPerTeam)\n// needs zero changes to treat a fiba game like any other. It targets Game's\n// flat/string variant (away_team/home_team as plain code strings) — the nfl\n// shape, not wnba/mlb's nested-object one — since that's the variant teamCode\n// in games.ts already reads without any fiba-specific branching.\n//\n// Treat every field here as a progressive enhancement, not a guarantee:\n// a missing team code or broadcast renders as the same \"TBD\"/blank the\n// pipeline already shows for a Sleeper game missing that field, rather\n// than failing the whole game. Broadcasts in particular are best-effort —\n// ESPN's broadcasts[] is itself sparse/region-dependent, and this file\n// makes no attempt to backfill or guess one when absent.\n\nimport { type Game } from \"./games.ts\";\nimport { getSourcePayload, listFutureDateKeys } from \"./sourceCache.ts\";\n\nexport const FIBA_SOURCE = \"fiba\";\n\nexport async function fetchCachedFibaScoreboard(dateKey: string): Promise {\n const cached = await getSourcePayload(FIBA_SOURCE, dateKey);\n return cached?.payload ?? null;\n}\n\n// The cache-backed counterpart to lib/dates.ts's windowDatesFor: every date\n// this source actually has ingested data for, from `fromDateKey` on. See\n// sourceCache.ts's listFutureDateKeys header for why this isn't a fixed-N\n// scan the way Sleeper's window is.\nexport function listFutureFibaDateKeys(fromDateKey: string): Promise {\n return listFutureDateKeys(FIBA_SOURCE, fromDateKey);\n}\n\ntype EspnTeam = { abbreviation?: string };\ntype EspnCompetitor = { homeAway?: string; team?: EspnTeam };\ntype EspnBroadcast = { names?: string[] };\ntype EspnCompetition = {\n competitors?: EspnCompetitor[];\n status?: { type?: { state?: string } };\n broadcasts?: EspnBroadcast[];\n};\ntype EspnEvent = { id?: string; date?: string; competitions?: EspnCompetition[] };\ntype EspnScoreboard = { events?: EspnEvent[] };\n\n// ESPN's status.type.state is already the 3-value vocabulary\n// (pre/in/post) lib/widgetItems.ts's STATUS_MAP maps directly — no guessing\n// needed the way Sleeper's inconsistent vocabulary requires there.\nfunction mapEventToGame(event: EspnEvent): Game {\n const competition = event.competitions?.[0];\n const competitors = competition?.competitors ?? [];\n const home = competitors.find((c) => c.homeAway === \"home\");\n const away = competitors.find((c) => c.homeAway === \"away\");\n const broadcast = competition?.broadcasts?.[0]?.names?.[0] ?? null;\n\n return {\n sport: FIBA_SOURCE,\n start_time: event.date ? Date.parse(event.date) : 0,\n status: competition?.status?.type?.state ?? null,\n game_id: event.id ?? null,\n metadata: {\n away_team: away?.team?.abbreviation ?? null,\n home_team: home?.team?.abbreviation ?? null,\n channel: broadcast,\n },\n };\n}\n\nexport async function fibaGamesForDate(dateKey: string): Promise {\n const payload = (await fetchCachedFibaScoreboard(dateKey)) as EspnScoreboard | null;\n return (payload?.events ?? []).map(mapEventToGame);\n}\n",[],[164,330],"c45ab739-5fce-49db-9763-28aabe9a2226","dates.ts","01a07d73-0d02-703f-be72-bb1a6d27dcfe",["D",1788811087002],"// Pure date math for the sports slate. No formatting of games, no I/O —\n// every function here takes an explicit `now`, which is what lets tests pin\n// behaviour without freezing the clock.\n//\n// Two halves that must not be confused, which is why they never share a\n// function: Sleeper's ingest half speaks IANA zone names (DST needs a real\n// zone), and the client-facing half speaks offset seconds that already have\n// DST folded in by iOS.\n\n// Sleeper buckets /scores by Eastern day, not UTC. This is a server-side\n// fact about Sleeper, never client-supplied.\nconst SLEEPER_TIME_ZONE = \"America/New_York\";\n\n// The client's timezone when the parent has no offset to pass on. Resolved\n// to a live, DST-correct offset via offsetSecondsForZone rather than being\n// stored as a constant number of seconds, so it does not go stale twice a\n// year.\nconst DEFAULT_CLIENT_TIME_ZONE = \"America/Los_Angeles\";\n\n// Eastern's calendar date for `now` — the bucket Sleeper's /scores keys on.\n// Anchored off real UTC \"now\", not any app-local notion of \"today\". en-CA\n// gives YYYY-MM-DD directly, sorted the way ISO date math wants it.\n//\n// This is Sleeper's half of the pipeline, and it takes an IANA zone name;\n// the client's half is dateAtOffset below, which takes offset seconds. Kept\n// as separate functions on purpose so the two kinds of timezone value can't\n// be swapped for each other by mistake.\nexport function todaySlateDate(now = new Date()): string {\n return now.toLocaleDateString(\"en-CA\", { timeZone: SLEEPER_TIME_ZONE });\n}\n\nexport function addDays(isoDate: string, days: number): string {\n const [y, m, d] = isoDate.split(\"-\").map(Number);\n const date = new Date(Date.UTC(y, m - 1, d));\n date.setUTCDate(date.getUTCDate() + days);\n return date.toISOString().slice(0, 10);\n}\n\n// The calendar date `now` falls on at a fixed UTC offset — the client-offset\n// counterpart to todaySlateDate's IANA version. No DST table lookup, because\n// the offset it's given has already had DST folded into it (by the iOS\n// client, or by offsetSecondsForZone's live Intl lookup for the fallback\n// case), so adding seconds is all that's left to do.\nexport function dateAtOffset(offsetSeconds: number, now = new Date()): string {\n return new Date(now.getTime() + offsetSeconds * 1000).toISOString().slice(0, 10);\n}\n\n// The lower bound on candidate games, as an absolute instant: UTC midnight\n// of the client's current calendar day.\n//\n// The bound is the day's START, not `now`, and that is deliberate — it is\n// what implements the \"keep showing a game for the rest of the day once it\n// ends\" assignment setting. A game that finished at noon stays a candidate\n// until the client's day rolls over, and `intradayFilter` is the opt-out.\n//\n// There is no `day=today|tomorrow|next` term any more. The source protocol\n// has no such parameter: every read means \"from the start of the client's\n// today\", which is what all three terms resolved to on this path anyway\n// (`tomorrow` was the only distinct offset, and nothing ever sent it).\nexport function dayStartMsAtOffset(offsetSeconds: number, now = new Date()): number {\n const localDate = dateAtOffset(offsetSeconds, now);\n return Date.parse(`${localDate}T00:00:00.000Z`) - offsetSeconds * 1000;\n}\n\n// The live GMT offset for an IANA zone at `now`, via Intl's own tables — so\n// the fallback path stays DST-correct without this file carrying a DST table\n// of its own. \"longOffset\" is the Intl.DateTimeFormat mode that always\n// renders as \"GMT±HH:MM\", never a zone abbreviation, which is what makes it\n// parseable here.\nfunction offsetSecondsForZone(timeZone: string, now: Date): number {\n const part = new Intl.DateTimeFormat(\"en-US\", { timeZone, timeZoneName: \"longOffset\" })\n .formatToParts(now)\n .find((p) => p.type === \"timeZoneName\")?.value;\n const match = part && /^GMT([+-])(\\d{1,2}):(\\d{2})$/.exec(part);\n if (!match) return 0;\n const sign = match[1] === \"-\" ? -1 : 1;\n return sign * (Number(match[2]) * 3600 + Number(match[3]) * 60);\n}\n\n// The protocol's `context.utcOffsetSeconds`, resolved to a usable offset.\n// iOS sends TimeZone.current.secondsFromGMT(), an integer seconds-east-of-GMT\n// that already has DST folded in, so there is no DST table to consult on this\n// side — just range-check it.\n//\n// `null` means the parent had no client offset to forward, not \"UTC\": it\n// falls back to DEFAULT_CLIENT_TIME_ZONE's live offset. An out-of-range value\n// takes the same fallback rather than throwing — a failed source fails the\n// whole composition, which is worse than a slightly-off day boundary. The\n// range [-12:00, +14:00] is every real-world UTC offset (Baker Island to\n// Kiribati); the protocol's own guard is wider, so this is the narrower of\n// the two checks and the one that decides.\n//\n// One trade this accepts, deliberately not engineered around: a WidgetKit\n// timeline entry built before a DST transition and rendered after it still\n// carries the pre-transition offset until iOS refreshes the timeline. The\n// client owns DST now; this file no longer has the information to catch it.\nexport function clientOffsetSeconds(raw: number | null, now = new Date()): number {\n return raw !== null && Number.isInteger(raw) && raw >= -43200 && raw <= 50400\n ? raw\n : offsetSecondsForZone(DEFAULT_CLIENT_TIME_ZONE, now);\n}\n",[],[164,337],"08f71cb6-2169-423c-94b2-13ea8c99c328","channels.ts","01a07d73-0d02-703f-be72-b6e5a71c80ba",["D",1788811087002],"// Turns Sleeper's raw channel string into the shape the item builder reads.\n// Pure; broadcaster display rules are independent of the team catalog.\n\n// Existing broadcaster presentation rules; these are outside the selection catalog.\n// A blunt chop rather than a width measurement: this is a fallback label for a\n// regional broadcaster nobody has mapped, not a layout decision.\nconst MAX_CHANNEL_LABEL = 10;\nfunction chop(text: string, max: number): string {\n return text.length <= max ? text : `${text.slice(0, max - 1)}…`;\n}\nconst NATIONAL_CHANNELS: Record = {\n \"abc\": {\n \"label\": \"ABC\",\n \"directv_channel\": 4,\n \"note\": null\n },\n \"cbs\": {\n \"label\": \"CBS\",\n \"directv_channel\": 2,\n \"note\": null\n },\n \"espn\": {\n \"label\": \"ESPN\",\n \"directv_channel\": 206,\n \"note\": null\n },\n \"ion\": {\n \"label\": \"ION\",\n \"directv_channel\": 305,\n \"note\": null\n },\n \"nbatv\": {\n \"label\": \"NBATV\",\n \"directv_channel\": 216,\n \"note\": null\n },\n \"nbc\": {\n \"label\": \"NBC\",\n \"directv_channel\": 4,\n \"note\": null\n },\n \"tbs\": {\n \"label\": \"TBS\",\n \"directv_channel\": 247,\n \"note\": null\n },\n \"usa\": {\n \"label\": \"USA\",\n \"directv_channel\": 242,\n \"note\": null\n },\n \"sportsnet\": {\n \"label\": \"SportsNet\",\n \"directv_channel\": 691,\n \"note\": null\n }\n};\nconst STREAMING_CHANNELS: Record = {\n \"amzn\": {\n \"label\": \"AMZN\",\n \"note\": \"computer only\"\n },\n \"amazon\": {\n \"label\": \"AMZN\",\n \"note\": \"computer only\"\n },\n \"peacock\": {\n \"label\": \"Peacock\",\n \"note\": \"computer only\"\n },\n \"hbo max\": {\n \"label\": \"HBO Max\",\n \"note\": \"computer only\"\n }\n};\n\n\n// `name` stays the raw string Sleeper sent — it is the drift-detection\n// value, and the json format has to keep reporting what actually arrived.\n// `label` is the display form: dictionary-mapped where there is a mapping,\n// chopped raw text where there isn't.\nexport type ChannelInfo = {\n category: string;\n name: string | null;\n label: string | null;\n directv_channel: number | null;\n note: string | null;\n};\n\nfunction channelMatches(rawChannel: string, key: string) {\n return new RegExp(`\\\\b${key.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\")}\\\\b`, \"i\").test(rawChannel);\n}\n\nexport function channelInfo(rawChannel: string | null | undefined): ChannelInfo {\n if (!rawChannel) return { category: \"unknown\", name: null, label: null, directv_channel: null, note: null };\n\n const nationalKey = Object.keys(NATIONAL_CHANNELS).find((key) => channelMatches(rawChannel, key));\n if (nationalKey) return { category: \"national\", name: rawChannel, ...NATIONAL_CHANNELS[nationalKey] };\n\n const streamingKey = Object.keys(STREAMING_CHANNELS).find((key) => channelMatches(rawChannel, key));\n if (streamingKey) {\n return { category: \"streaming\", name: rawChannel, directv_channel: null, ...STREAMING_CHANNELS[streamingKey] };\n }\n\n return {\n category: \"regional\",\n name: rawChannel,\n label: chop(rawChannel, MAX_CHANNEL_LABEL),\n directv_channel: null,\n note: null,\n };\n}\n",[],[164,344],"7040f25d-91ba-42d6-bc0f-30c6de19c155","catalogStore.ts","01a07d73-0d02-703f-be72-b3ffee7d3891",["D",1788811087002],"// Canonical selection catalog in this val's SQLite. Read once at the I/O edge\n// and pass the snapshot through the pure pipeline; edits are visible next request.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { Catalog, CatalogCompetition, CatalogTeam } from \"./catalog.ts\";\n\nexport async function readCatalog(): Promise {\n const [competitions, teams] = await sqlite.batch([\n { sql: `SELECT code, display_name AS displayName, adapter,\n provider_competition_key AS providerKey, emoji, coverage_note AS coverageNote\n FROM catalog_competitions ORDER BY display_order, code`, args: [] },\n { sql: `SELECT t.slug, t.competition_code AS competitionCode,\n t.display_name AS displayName, t.provider_team_code AS providerCode\n FROM catalog_teams t JOIN catalog_competitions c ON c.code = t.competition_code\n ORDER BY c.display_order, c.code, t.display_order, t.slug`, args: [] },\n ], \"read\");\n return {\n competitions: competitions.rows as CatalogCompetition[],\n teams: teams.rows as CatalogTeam[],\n };\n}\n",[],[164,351],"79cd7ac5-c34e-4bd9-b7ae-f106710ef519","catalog.ts","01a07d73-0d02-703f-be72-ad141fa295c7",["D",1788811087002],"// Request-scoped catalog values shared by pure selection and rendering helpers.\n// SQLite belongs to catalogStore.ts; import this module without I/O.\n\nexport type TeamRef = { sport: string; code: string };\n\nexport type CatalogCompetition = {\n code: string;\n displayName: string;\n adapter: \"sleeper\" | \"fiba\";\n providerKey: string;\n emoji: string;\n coverageNote: string;\n};\n\nexport type CatalogTeam = {\n slug: string;\n competitionCode: string;\n displayName: string;\n providerCode: string;\n};\n\nexport type Catalog = {\n competitions: CatalogCompetition[];\n teams: CatalogTeam[];\n};\n\n// Competition-scoped, never code-only: `IND` is the Fever in wnba and the\n// Colts in nfl. An opponent outside the curated catalog keeps its provider\n// code rather than having a name invented for it.\nexport function teamLabel(sport: string, code: string | null, catalog: Catalog): string | null {\n if (!code) return code;\n return catalog.teams.find((team) =>\n team.competitionCode === sport && team.providerCode === code\n )?.displayName ?? code;\n}\n",[],[164,358],"2c2b1eba-2775-455a-89ee-fa40cbb51a8d","cachedGames.ts","01a07d73-0d02-703f-be72-a9039587f84f",["D",1788811087002],"// One row per game, indexed by (sport, team code, start time) — the storage\n// shape that makes \"when does this team next play\" an index seek instead of\n// a scan.\n//\n// This is deliberately NOT lib/sourceCache.ts. That table is\n// (source, date_key) -> opaque payload, which is the right shape for a\n// source with no filter dimension (moon: one event, ask by date) or one\n// where the whole day is the answer (fiba: a tournament's slate). Games have\n// a second axis — team — that a date-keyed blob does not expose, so every\n// team question there has to brute-force the date axis. That is exactly what\n// lib/dates.ts's windowDatesFor was: a fixed 3-day scan, sized by what a\n// per-date live fetch could afford rather than by how far away the answer\n// might be. Moving Sleeper into source_cache unchanged would have kept that\n// scan and only made it local; normalizing removes it.\n//\n// What that buys, beyond speed:\n// - No range window. \"Next\" is ORDER BY start_time_ms LIMIT 1, however far\n// out it lands, so a weekly sport (nfl, cfb) stops falling through the\n// gap between its games and a fixed scan width.\n// - No Sleeper-day skew. windowDatesFor handed Sleeper a *client* calendar\n// date while Sleeper buckets by Eastern day, an accepted few-hour error\n// documented at slateDateFor. Rows here carry the absolute instant, so\n// that whole class of error is gone rather than bounded.\n//\n// The cost is liveness: status is only as fresh as the last ingest, where it\n// used to be fetched per request. That is the same trade fiba already makes\n// (presence is the contract, not intraday state) and is why re-ingest is an\n// upsert on (sport, game_id) — updating a live game in place is the steady\n// state, not an error.\n//\n// No score columns: the product shows no score, so `away_score`/`home_score`\n// were written on every ingest and read by nothing. See lib/games.ts.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { type TeamRef } from \"./catalog.ts\";\nimport { type Game } from \"./games.ts\";\n\n// Milliseconds, and the column name says so on purpose. Game.start_time is\n// Sleeper's own milliseconds and render/json.ts is the single place that\n// divides to the seconds the widget contract wants; a column called\n// `start_time` would have been the obvious place to silently store the\n// other unit, which decodes on the client as a date ~57,000 years out with\n// nothing failing in between.\nexport type CachedGameRow = {\n sport: string;\n game_id: string;\n away_code: string | null;\n home_code: string | null;\n start_time_ms: number;\n status: string | null;\n channel: string | null;\n};\n\nlet schemaReady: Promise | null = null;\n\n// Same memoize-and-clear-on-failure shape as sourceCache.ts's: cheap on a\n// warm val, and one transient sqlite error doesn't wedge every later request\n// in the process.\nexport function ensureCachedGamesSchema(): Promise {\n if (!schemaReady) {\n schemaReady = sqlite\n .batch([\n `CREATE TABLE IF NOT EXISTS cached_games (\n sport TEXT NOT NULL,\n game_id TEXT NOT NULL,\n away_code TEXT,\n home_code TEXT,\n start_time_ms INTEGER NOT NULL,\n status TEXT,\n channel TEXT,\n ingested_at TEXT NOT NULL,\n PRIMARY KEY (sport, game_id)\n )`,\n // Two indexes, not one: a team is the away side of some games and\n // the home side of others, and SQLite's OR optimization can use both\n // arms of `away_code = ? OR home_code = ?` only if each has its own.\n // start_time_ms is the trailing column so the ORDER BY ... LIMIT 1\n // below is satisfied by the index rather than a sort.\n `CREATE INDEX IF NOT EXISTS ix_cached_games_away\n ON cached_games (sport, away_code, start_time_ms)`,\n `CREATE INDEX IF NOT EXISTS ix_cached_games_home\n ON cached_games (sport, home_code, start_time_ms)`,\n ])\n .then(() => undefined)\n .catch((err) => {\n schemaReady = null;\n throw err;\n });\n }\n return schemaReady;\n}\n\n// Rows come back as Game's flat/string variant — away_team/home_team as\n// plain code strings. That is the nfl shape, which games.ts's teamCode\n// already reads without any branching, so nothing downstream knows a game\n// arrived from SQLite rather than from a live fetch. The nesting hazard\n// (wnba's { team, ... }) is resolved once, at ingest, instead of on every read.\nfunction rowToGame(row: CachedGameRow): Game {\n return {\n sport: row.sport,\n start_time: Number(row.start_time_ms),\n status: row.status,\n game_id: row.game_id,\n metadata: {\n away_team: row.away_code,\n home_team: row.home_code,\n channel: row.channel,\n },\n };\n}\n\nconst SELECT_COLUMNS =\n \"sport, game_id, away_code, home_code, start_time_ms, status, channel\";\n\n// One indexed seek per team, all in a single round trip.\n//\n// N queries rather than one clever join because the answer wanted is N\n// answers: each favorite's own next game, unioned. That is not the same as\n// the single earliest game across the set — resolving them together used to\n// silently drop every favorite whose next game fell later than the first\n// team's, which is the bug pickNextSlate's per-team walk was written to fix.\n// Keeping one statement per team maps 1:1 onto that rule and stays legible;\n// MAX_TEAMS bounds N, and a realistic selection is a handful.\nexport async function nextGamesForTeams(teams: TeamRef[], fromMs: number): Promise {\n if (!teams.length) return [];\n await ensureCachedGamesSchema();\n\n const results = await sqlite.batch(\n teams.map((team) => ({\n sql: `SELECT ${SELECT_COLUMNS} FROM cached_games\n WHERE sport = ? AND (away_code = ? OR home_code = ?) AND start_time_ms >= ?\n ORDER BY start_time_ms ASC\n LIMIT 1`,\n args: [team.sport, team.code, team.code, fromMs],\n })),\n );\n\n return results.flatMap((result) => (result.rows as CachedGameRow[]).map(rowToGame));\n}\n\n// Upsert keyed on (sport, game_id): re-ingesting is the steady state — a\n// score or status changing mid-game, or a plain backfill re-run — not a\n// conflict. Chunked because a batch is one statement per row and a full\n// window is several hundred.\nexport async function saveCachedGames(rows: CachedGameRow[]): Promise {\n if (!rows.length) return 0;\n await ensureCachedGamesSchema();\n\n const ingestedAt = new Date().toISOString();\n const CHUNK = 50;\n let written = 0;\n\n for (let i = 0; i < rows.length; i += CHUNK) {\n const chunk = rows.slice(i, i + CHUNK);\n await sqlite.batch(\n chunk.map((row) => ({\n sql: `INSERT INTO cached_games\n (sport, game_id, away_code, home_code, start_time_ms,\n status, channel, ingested_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(sport, game_id) DO UPDATE SET\n away_code = excluded.away_code,\n home_code = excluded.home_code,\n start_time_ms = excluded.start_time_ms,\n status = excluded.status,\n channel = excluded.channel,\n ingested_at = excluded.ingested_at`,\n args: [\n row.sport, row.game_id, row.away_code, row.home_code, row.start_time_ms,\n row.status, row.channel, ingestedAt,\n ],\n })),\n );\n written += chunk.length;\n }\n\n return written;\n}\n\n// Coverage, not content: what the table actually holds per sport and how\n// far forward it reaches. This is the question to ask when a feed is empty,\n// because with the range window gone an empty card means \"nothing ingested\"\n// far more often than it means \"nothing scheduled\".\nexport async function cachedGamesCoverage(): Promise<\n { sport: string; games: number; firstStartMs: number; lastStartMs: number; ingestedAt: string }[]\n> {\n await ensureCachedGamesSchema();\n const result = await sqlite.execute(`\n SELECT sport,\n COUNT(*) AS games,\n MIN(start_time_ms) AS first_start_ms,\n MAX(start_time_ms) AS last_start_ms,\n MAX(ingested_at) AS ingested_at\n FROM cached_games\n GROUP BY sport\n ORDER BY sport\n `);\n return (result.rows as {\n sport: string; games: number; first_start_ms: number;\n last_start_ms: number; ingested_at: string;\n }[]).map((row) => ({\n sport: row.sport,\n games: Number(row.games),\n firstStartMs: Number(row.first_start_ms),\n lastStartMs: Number(row.last_start_ms),\n ingestedAt: row.ingested_at,\n }));\n}\n",[],[164,365],["D",1788811087002],[181,182,183,184,185,186,187,188,189,190,191,192,193],[164],["D",1788811087002],["D",1789509043237],{"_101":100,"_108":104},{"_101":100,"_102":-5,"_103":104,"_18":57,"_105":106,"_107":27},{"_13":90,"_33":91,"_45":44,"_92":46,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":47,"_99":100},"ctx",{"_83":-5,"_128":412,"_413":414,"_415":416,"_417":27,"_418":27,"_419":27,"_420":25,"_421":-5,"_422":-7,"_423":-7,"_424":64,"_425":27,"_426":27,"_427":-5,"_428":27,"_429":27,"_430":27,"_431":-5},"ENV",{"_383":384,"_385":386,"_387":91,"_388":389,"_390":391,"_392":393,"_394":395,"_396":397,"_398":399,"_400":401,"_402":403,"_404":405,"_406":407,"_408":409,"_410":411},"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 · v3