[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_353":354,"_355":356},"routes/_app.x.$handle.$name",{"_143":142,"_37":90,"_151":133,"_32":152,"_13":14,"_153":-5,"_11":154,"_155":156,"_157":158,"_159":160,"_161":162,"_25":-5,"_163":-5,"_164":-5,"_165":30,"_166":167,"_168":169,"_170":-5,"_171":-5,"_172":173},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_88":89,"_37":90,"_43":91,"_92":-5,"_93":30,"_94":95,"_96":95,"_97":98,"_99":-5,"_18":100,"_101":102,"_103":30,"_104":-5,"_105":-5,"_106":107,"_108":109,"_110":111,"_112":113,"_114":115,"_116":-5,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_126":127,"_128":129,"_130":131,"_132":30},"version",18,"changes",[19,20,21,22,23,24],"aiChatInfo","userId",{"_25":80,"_27":81,"_29":30,"_31":30,"_32":82,"_34":82},{"_25":72,"_27":73,"_29":30,"_31":30,"_32":74,"_34":74},{"_25":64,"_27":65,"_29":30,"_31":30,"_32":66,"_34":66},{"_25":56,"_27":57,"_29":30,"_31":30,"_32":58,"_34":58},{"_25":48,"_27":49,"_29":30,"_31":30,"_32":50,"_34":50},{"_25":26,"_27":28,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous",{"_35":36,"_37":33,"_38":39,"_40":41},"deleted",false,"deletedHere","path","nflSource.ts","latestPath","fileId","ecef8016-aafd-11f1-811d-1607ee4eb77e","name","fileType","script","content","// NFL settings and operations exported through the shared source SDK.\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { nflItems } from \"./lib/nflFeed.ts\";\nimport { ingestSleeperWindow } from \"./lib/sleeperIngest.ts\";\nimport type { Catalog } from \"./lib/catalog.ts\";\nimport { accept, defineSource, reject } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.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 NFLRead = {\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: \"nfl\",\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 nflItems({ teams, intradayFilter }, utcOffsetSeconds, catalog),\n\n writes: {\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","// NFL settings and operations exported through the shared source SDK.\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { nflItems } from \"./lib/nflFeed.ts\";\nimport { ingestSleeperWindow } from \"./lib/sleeperIngest.ts\";\nimport type { Catalog } from \"./lib/catalog.ts\";\nimport { accept, defineSource, reject } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.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 NFLRead = {\n teams: string[];\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 },\n required: [\"teams\"],\n additionalProperties: false,\n };\n}\n\nconst SETTING_KEYS = [\"teams\"];\n\nexport default defineSource({\n key: \"nfl\",\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 || 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, catalog });\n },\n\n read: ({ teams, catalog }, { utcOffsetSeconds }) =>\n nflItems({ teams }, utcOffsetSeconds, catalog),\n\n writes: {\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","createdAt",["D",1789502858592],"branchVersion","branchId","61c73600-56ab-40cd-815a-59f4fefa923a",{"_35":51,"_37":52,"_38":39,"_40":54,"_43":55,"_45":14,"_46":47,"_29":30},{"_35":51,"_37":52,"_38":39,"_40":53},"lib/nflFeed.ts","ecef4ac4-aafd-11f1-811d-1607ee4eb77e","nflFeed.ts","// Each selected NFL team's next cached game, unioned into temporal items.\nimport type { Catalog } from \"./catalog.ts\";\nimport { nextGamesForTeams } from \"./cachedGames.ts\";\nimport { clientOffsetSeconds, dayStartMsAtOffset } from \"./dates.ts\";\nimport { pickNextPerTeam } from \"./games.ts\";\nimport { widgetItems } from \"./widgetItems.ts\";\n\nexport async function nflItems(\n settings: { teams: string[]; intradayFilter: boolean },\n utcOffsetSeconds: number | null,\n catalog: Catalog,\n) {\n const teams = settings.teams.map((slug) => ({\n sport: \"nfl\", code: catalog.teams.find((team) => team.slug === slug)!.providerCode,\n }));\n const fromMs = dayStartMsAtOffset(clientOffsetSeconds(utcOffsetSeconds));\n const candidates = await nextGamesForTeams(teams, fromMs);\n const picked = pickNextPerTeam(candidates, teams, [\"nfl\"]);\n return widgetItems(picked?.bySport ?? [], catalog, settings.intradayFilter);\n}\n","// Each selected NFL team's next cached game, unioned into temporal items.\nimport type { Catalog } from \"./catalog.ts\";\nimport { nextGamesForTeams } from \"./cachedGames.ts\";\nimport { clientOffsetSeconds, dayStartMsAtOffset } from \"./dates.ts\";\nimport { pickNextPerTeam } from \"./games.ts\";\nimport { widgetItems } from \"./widgetItems.ts\";\n\nexport async function nflItems(\n settings: { teams: string[] },\n utcOffsetSeconds: number | null,\n catalog: Catalog,\n) {\n const teams = settings.teams.map((slug) => ({\n sport: \"nfl\", code: catalog.teams.find((team) => team.slug === slug)!.providerCode,\n }));\n const fromMs = dayStartMsAtOffset(clientOffsetSeconds(utcOffsetSeconds));\n const candidates = await nextGamesForTeams(teams, fromMs);\n const picked = pickNextPerTeam(candidates, teams, [\"nfl\"]);\n return widgetItems(picked?.bySport ?? [], catalog);\n}\n",["D",1789502858592],{"_35":59,"_37":60,"_38":39,"_40":62,"_43":63,"_45":14,"_46":47,"_29":30},{"_35":59,"_37":60,"_38":39,"_40":61},"tools/source-contract-check.ts","01a07d9f-d1a7-75dc-86db-e146fbf3c174","source-contract-check.ts","// NFL contract and deterministic selection checks. No production writes.\nimport handler from \"../rpc.ts\";\nimport { items, phase } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\nimport { readCatalog } from \"../lib/catalogStore.ts\";\nimport { pickNextPerTeam } from \"../lib/games.ts\";\nimport { widgetItems } from \"../lib/widgetItems.ts\";\nimport { normalizeGame } from \"../lib/sleeperIngest.ts\";\nimport { dayStartMsAtOffset } from \"../lib/dates.ts\";\nlet checks=0;\nfunction check(ok:unknown,msg:string){if(!ok)throw new Error(msg);checks++;}\nconst token=Deno.env.get(\"SOURCE_NFL_V1_TOKEN\");\nasync function call(path:string,body?:unknown,auth=true){\n const r=await handler(new Request(\"https://fixture.invalid\"+path,{method:body?\"POST\":\"GET\",headers:auth?{authorization:`Bearer ${token}`}:{},body:body?JSON.stringify(body):undefined}));\n return {status:r.status,body:await r.json().catch(()=>null)};\n}\nconst base={protocolVersion:1,sourceKey:\"nfl\",settings:{teams:[\"rams\"],intradayFilter:false},context:{utcOffsetSeconds:0}};\ncheck((await call(\"/v1/descriptor\",undefined,false)).status===401,\"auth\");\nconst d=(await call(\"/v1/descriptor?sourceKey=nfl\")).body;\ncheck(d.sourceKey===\"nfl\"&&d.protocolVersion===1&&d.temporal,\"identity\");\ncheck(d.capabilities.validateSettings&&JSON.stringify(d.capabilities.write)==='[\"sleeper.refresh\"]'&&!d.capabilities.publish,\"capabilities\");\nconst s=d.settingsSchema;\ncheck(s.additionalProperties===false&&s.required.includes(\"teams\"),\"closed settings\");\ncheck(s.properties.teams.uniqueItems&&s.properties.teams.items.type===\"string\"&&s.properties.teams.items.oneOf.length===32,\"32 choices\");\ncheck(s.properties.teams.items.oneOf.every((x:any)=>typeof x.const===\"string\"&&typeof x.title===\"string\"&&x[\"x-group\"]===\"NFL\"),\"choice labels\");\ncheck(s.properties.intradayFilter.type===\"boolean\"&&s.properties.intradayFilter.default===false,\"boolean settings\");\nfor(const offset of [-43200,-25200,0,50400,null]){\n const r=await call(\"/v1/read\",{...base,context:{utcOffsetSeconds:offset}});\n check(r.status===200&&items(r.body.items),\"read \"+offset);\n}\nconst valid=await call(\"/v1/validate-settings\",base);\ncheck(valid.status===200&&Object.keys(valid.body).length===3&&valid.body.ok,\"validation isolation\");\nfor(const settings of [{teams:[\"rams\",\"rams\"]},{teams:[],unexpected:true},{teams:[],intradayFilter:\"true\"},{teams:\"rams\"}]){\n check((await call(\"/v1/validate-settings\",{...base,settings})).body.error===\"invalid_settings\",\"invalid settings\");\n}\nfor(const slug of [\"fever\",\"united-states\",\"trojans\",\"missing\"]){\n check((await call(\"/v1/read\",{...base,settings:{teams:[slug]}})).body.error===\"unknown_team\",\"non NFL \"+slug);\n}\ncheck((await call(\"/v1/read\",{...base,settings:{teams:[]}})).body.items.length===0,\"empty\");\ncheck((await call(\"/v1/read\",{...base,sourceKey:\"sports\"})).status===404,\"old key\");\ncheck((await call(\"/v1/read\",{...base,protocolVersion:2})).status===400,\"protocol\");\ncheck((await call(\"/v1/publish\",base)).status===501,\"publish\");\nfor(const operation of [\"cache.put\",\"toString\",\"sql\"]){\n check((await call(\"/v1/write\",{...base,operation,payload:{}})).status===422,\"write guard\");\n}\nfor(const days of [0,32,1.5,\"1\"]){\n check((await call(\"/v1/write\",{...base,operation:\"sleeper.refresh\",payload:{days}})).body.error===\"invalid_days\",\"days\");\n}\nconst catalog=await readCatalog();\nconst game={sport:\"nfl\",game_id:\"fixture\",start_time:1788739200000,status:\"final\",metadata:{away_team:\"LAR\",home_team:\"SEA\",channel:\"NBC\"}};\nconst picked=pickNextPerTeam([game],[{sport:\"nfl\",code:\"LAR\"},{sport:\"nfl\",code:\"SEA\"}],[\"nfl\"])!;\nconst built=widgetItems(picked.bySport,catalog);\ncheck(built.length===1&&built[0].startsAt===1788739200&&built[0].mainText===\"🏈 Rams @ Seahawks\",\"union and seconds\");\ncheck(built[0].timestamp===1788739200,\"the transitional timestamp still mirrors startsAt\");\ncheck(built[0].expiresAt===1788739200+10800,\"the window is this source's own typical duration\");\ncheck(built[0].caption===\"END\"&&!built[0].emphasized&&widgetItems(picked.bySport,catalog,true).length===0,\"final filter\");\n// Lifecycle from the clock, with no ingest between these calls: a stale\n// `scheduled` on a kicked-off game still reads LIVE.\nconst stale=pickNextPerTeam([{...game,status:\"scheduled\"}],[{sport:\"nfl\",code:\"LAR\"}],[\"nfl\"])!;\nconst kickoff=1788739200;\ncheck(widgetItems(stale.bySport,catalog,false,kickoff-1)[0].caption===null,\"before kickoff the client formats the time\");\ncheck(widgetItems(stale.bySport,catalog,false,kickoff+60)[0].caption===\"LIVE\",\"a stale scheduled status still reads live\");\ncheck(widgetItems(stale.bySport,catalog,false,kickoff+10800)[0].caption===\"END\",\"expired by the clock alone\");\ncheck(widgetItems(picked.bySport,catalog,false,kickoff+60)[0].caption===\"END\",\"an ingested final is never live\");\ncheck(phase(widgetItems(stale.bySport,catalog,false,kickoff)[0],kickoff)===\"current\",\"phase agrees with the caption\");\ncheck(normalizeGame({...game,sport:\"cfb\"})===null,\"ingest league guard\");\ncheck(normalizeGame(game)?.away_code===\"LAR\",\"flat NFL shape\");\ncheck(dayStartMsAtOffset(50400,new Date(\"2026-09-07T20:00:00Z\"))===Date.parse(\"2026-09-07T10:00:00Z\"),\"UTC+14 boundary\");\nconsole.log(\"PASS: \"+checks+\" NFL assertions\");\n","// NFL contract and deterministic selection checks. No production writes.\nimport handler from \"../rpc.ts\";\nimport { items, phase } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\nimport { readCatalog } from \"../lib/catalogStore.ts\";\nimport { pickNextPerTeam } from \"../lib/games.ts\";\nimport { widgetItems } from \"../lib/widgetItems.ts\";\nimport { normalizeGame } from \"../lib/sleeperIngest.ts\";\nimport { dayStartMsAtOffset } from \"../lib/dates.ts\";\nlet checks=0;\nfunction check(ok:unknown,msg:string){if(!ok)throw new Error(msg);checks++;}\nconst token=Deno.env.get(\"SOURCE_NFL_V1_TOKEN\");\nasync function call(path:string,body?:unknown,auth=true){\n const r=await handler(new Request(\"https://fixture.invalid\"+path,{method:body?\"POST\":\"GET\",headers:auth?{authorization:`Bearer ${token}`}:{},body:body?JSON.stringify(body):undefined}));\n return {status:r.status,body:await r.json().catch(()=>null)};\n}\nconst base={protocolVersion:1,sourceKey:\"nfl\",settings:{teams:[\"rams\"]},context:{utcOffsetSeconds:0}};\ncheck((await call(\"/v1/descriptor\",undefined,false)).status===401,\"auth\");\nconst d=(await call(\"/v1/descriptor?sourceKey=nfl\")).body;\ncheck(d.sourceKey===\"nfl\"&&d.protocolVersion===1&&d.temporal,\"identity\");\ncheck(d.capabilities.validateSettings&&JSON.stringify(d.capabilities.write)==='[\"sleeper.refresh\"]'&&!d.capabilities.publish,\"capabilities\");\nconst s=d.settingsSchema;\ncheck(s.additionalProperties===false&&s.required.includes(\"teams\"),\"closed settings\");\ncheck(s.properties.teams.uniqueItems&&s.properties.teams.items.type===\"string\"&&s.properties.teams.items.oneOf.length===32,\"32 choices\");\ncheck(s.properties.teams.items.oneOf.every((x:any)=>typeof x.const===\"string\"&&typeof x.title===\"string\"&&x[\"x-group\"]===\"NFL\"),\"choice labels\");\ncheck(JSON.stringify(Object.keys(s.properties))==='[\"teams\"]',\"teams-only settings\");\nfor(const offset of [-43200,-25200,0,50400,null]){\n const r=await call(\"/v1/read\",{...base,context:{utcOffsetSeconds:offset}});\n check(r.status===200&&items(r.body.items),\"read \"+offset);\n}\nconst valid=await call(\"/v1/validate-settings\",base);\ncheck(valid.status===200&&Object.keys(valid.body).length===3&&valid.body.ok,\"validation isolation\");\nfor(const settings of [{teams:[\"rams\",\"rams\"]},{teams:[],unexpected:true},{teams:\"rams\"}]){\n check((await call(\"/v1/validate-settings\",{...base,settings})).body.error===\"invalid_settings\",\"invalid settings\");\n}\nfor(const slug of [\"fever\",\"united-states\",\"trojans\",\"missing\"]){\n check((await call(\"/v1/read\",{...base,settings:{teams:[slug]}})).body.error===\"unknown_team\",\"non NFL \"+slug);\n}\ncheck((await call(\"/v1/read\",{...base,settings:{teams:[]}})).body.items.length===0,\"empty\");\ncheck((await call(\"/v1/read\",{...base,sourceKey:\"sports\"})).status===404,\"old key\");\ncheck((await call(\"/v1/read\",{...base,protocolVersion:2})).status===400,\"protocol\");\ncheck((await call(\"/v1/publish\",base)).status===501,\"publish\");\nfor(const operation of [\"cache.put\",\"toString\",\"sql\"]){\n check((await call(\"/v1/write\",{...base,operation,payload:{}})).status===422,\"write guard\");\n}\nfor(const days of [0,32,1.5,\"1\"]){\n check((await call(\"/v1/write\",{...base,operation:\"sleeper.refresh\",payload:{days}})).body.error===\"invalid_days\",\"days\");\n}\nconst catalog=await readCatalog();\nconst game={sport:\"nfl\",game_id:\"fixture\",start_time:1788739200000,status:\"final\",metadata:{away_team:\"LAR\",home_team:\"SEA\",channel:\"NBC\"}};\nconst picked=pickNextPerTeam([game],[{sport:\"nfl\",code:\"LAR\"},{sport:\"nfl\",code:\"SEA\"}],[\"nfl\"])!;\nconst built=widgetItems(picked.bySport,catalog);\ncheck(built.length===1&&built[0].startsAt===1788739200&&built[0].mainText===\"🏈 Rams @ Seahawks\",\"union and seconds\");\ncheck(built[0].timestamp===1788739200,\"the transitional timestamp still mirrors startsAt\");\ncheck(built[0].expiresAt===1788739200+10800,\"the window is this source's own typical duration\");\ncheck(built[0].caption===\"END\"&&!built[0].emphasized,\"expired items remain candidates\");\n// Lifecycle from the clock, with no ingest between these calls: a stale\n// `scheduled` on a kicked-off game still reads LIVE.\nconst stale=pickNextPerTeam([{...game,status:\"scheduled\"}],[{sport:\"nfl\",code:\"LAR\"}],[\"nfl\"])!;\nconst kickoff=1788739200;\ncheck(widgetItems(stale.bySport,catalog,kickoff-1)[0].caption===null,\"before kickoff the client formats the time\");\ncheck(widgetItems(stale.bySport,catalog,kickoff+60)[0].caption===\"LIVE\",\"a stale scheduled status still reads live\");\ncheck(widgetItems(stale.bySport,catalog,kickoff+10800)[0].caption===\"END\",\"expired by the clock alone\");\ncheck(widgetItems(picked.bySport,catalog,kickoff+60)[0].caption===\"LIVE\",\"stored final does not override the published window\");\ncheck(phase(widgetItems(stale.bySport,catalog,kickoff)[0],kickoff)===\"current\",\"phase agrees with the caption\");\ncheck(normalizeGame({...game,sport:\"cfb\"})===null,\"ingest league guard\");\ncheck(normalizeGame(game)?.away_code===\"LAR\",\"flat NFL shape\");\ncheck(dayStartMsAtOffset(50400,new Date(\"2026-09-07T20:00:00Z\"))===Date.parse(\"2026-09-07T10:00:00Z\"),\"UTC+14 boundary\");\nfor (const value of [true, false]) {\n for (const path of [\"/v1/read\", \"/v1/validate-settings\"]) {\n const rejected = await call(path, {...base, settings: {...base.settings, intradayFilter: value}});\n check(rejected.status===400 && rejected.body.error===\"invalid_settings\", \"retired key rejected\");\n }\n}\nconsole.log(\"PASS: \"+checks+\" NFL assertions\");\n",["D",1789502858592],{"_35":67,"_37":68,"_38":39,"_40":70,"_43":71,"_45":14,"_46":47,"_29":30},{"_35":67,"_37":68,"_38":39,"_40":69},"lib/widgetItems.ts","01a07d9f-d1a6-714a-87c0-f88e12b4e04f","widgetItems.ts","// Stored rows → the widget's item shape. Every field here is a VIEW decision;\n// the client renders it blind. Pure: the clock arrives as an argument.\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 { phase, type Item, type Phase, windowFrom } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\n\n// An NFL broadcast window: 60 minutes of game clock runs about three hours of\n// wall clock, and overtime or a long weather delay runs past it. It is an\n// ESTIMATE — this val has no live ingest, so lifecycle is derived from the\n// clock rather than from a stored status that only moves when someone ingests.\n// A four-hour game reading as ended an hour early is the bounded cost of that;\n// narrow this if live ingest lands.\nconst NFL_TYPICAL_GAME_SECONDS = 3 * 60 * 60;\n\ntype Status = \"scheduled\" | \"live\" | \"final\";\n\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};\n\nfunction normalizeStatus(raw: string | null): Status {\n return (raw && STATUS_MAP[raw]) || \"scheduled\";\n}\n\n// The protocol says `current`; this is where that becomes \"LIVE\". Phase is\n// state and belongs to the protocol, the wording belongs to this source.\n// `caption: null` is a protocol value telling the client to format `startsAt`\n// itself as a local start time.\nfunction captionFor(current: Phase): { caption: string | null; emphasized: boolean } {\n if (current === \"current\") return { caption: \"LIVE\", emphasized: true };\n if (current === \"expired\") return { caption: \"END\", emphasized: false };\n return { caption: null, emphasized: false };\n}\n\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, now: number): { item: Item; current: Phase } {\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 // Unix epoch SECONDS on the wire; the stored start is milliseconds.\n const window = windowFrom(Math.floor(game.start_time / 1000), NFL_TYPICAL_GAME_SECONDS);\n // The clock decides, with one exception: a stored `final` is knowledge that\n // the game ended, while the window is only an estimate that it did. Known\n // beats estimated. The reverse does not hold — a stored `scheduled` on a\n // game whose start has passed is a stale ingest, which is exactly what the\n // window exists to route around.\n const current = status === \"final\" ? \"expired\" : phase(window, now);\n return {\n item: {\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(current),\n ...window,\n // Transitional: consumers that predate the window still read `timestamp`.\n timestamp: window.startsAt,\n },\n current,\n };\n}\n\n// `hideCompleted` is the assignment's `intradayFilter` setting. It filters on\n// the phase above, not on caption text, so the filter agrees with what the\n// item says rather than with whenever the last ingest ran.\nexport function widgetItems(\n bySport: GamesBySport,\n catalog: Catalog,\n hideCompleted = false,\n now = Math.floor(Date.now() / 1000),\n): Item[] {\n const built = flattenByStartTime(bySport).map((game) => widgetItem(game, catalog, now));\n return (hideCompleted ? built.filter((b) => b.current !== \"expired\") : built).map((b) => b.item);\n}\n","// Stored rows → the widget's item shape. Every field here is a VIEW decision;\n// the client renders it blind. Pure: the clock arrives as an argument.\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 { phase, type Item, type Phase, windowFrom } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\n\n// An NFL broadcast window: 60 minutes of game clock runs about three hours of\n// wall clock, and overtime or a long weather delay runs past it. It is an\n// ESTIMATE — this val has no live ingest, so lifecycle is derived from the\n// clock rather than from a stored status that only moves when someone ingests.\n// A four-hour game reading as ended an hour early is the bounded cost of that;\n// narrow this if live ingest lands.\nconst NFL_TYPICAL_GAME_SECONDS = 3 * 60 * 60;\n\n// The protocol says `current`; this is where that becomes \"LIVE\". Phase is\n// state and belongs to the protocol, the wording belongs to this source.\n// `caption: null` is a protocol value telling the client to format `startsAt`\n// itself as a local start time.\nfunction captionFor(current: Phase): { caption: string | null; emphasized: boolean } {\n if (current === \"current\") return { caption: \"LIVE\", emphasized: true };\n if (current === \"expired\") return { caption: \"END\", emphasized: false };\n return { caption: null, emphasized: false };\n}\n\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, now: number): Item {\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 // Unix epoch SECONDS on the wire; the stored start is milliseconds.\n const window = windowFrom(Math.floor(game.start_time / 1000), NFL_TYPICAL_GAME_SECONDS);\n const current = phase(window, now);\n return {\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(current),\n ...window,\n // Transitional: consumers that predate the window still read `timestamp`.\n timestamp: window.startsAt,\n };\n}\n\nexport function widgetItems(\n bySport: GamesBySport,\n catalog: Catalog,\n now = Math.floor(Date.now() / 1000),\n): Item[] {\n return flattenByStartTime(bySport).map((game) => widgetItem(game, catalog, now));\n}\n",["D",1789502858592],{"_35":75,"_37":76,"_38":39,"_40":78,"_43":79,"_45":14,"_46":47,"_29":30},{"_35":75,"_37":76,"_38":39,"_40":77},"lib/games.ts","01a07d9f-d1a6-714a-87c0-e08858a9a7e1","games.ts","\nimport { type TeamRef } from \"./catalog.ts\";\nimport { channelInfo, type ChannelInfo } from \"./channels.ts\";\n\nexport function teamCode(value: unknown): string | null {\n return typeof value === \"string\" ? value : null;\n}\n\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\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\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\nexport function flattenByStartTime(bySport: GamesBySport): EnrichedGame[] {\n return bySport.flatMap((group) => group.games).toSorted((a, b) => a.start_time - b.start_time);\n}\n\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","\nimport { type TeamRef } from \"./catalog.ts\";\nimport { channelInfo, type ChannelInfo } from \"./channels.ts\";\n\nexport function teamCode(value: unknown): string | null {\n return typeof value === \"string\" ? value : null;\n}\n\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};\n\nexport type GamesBySport = { sport: string; games: EnrichedGame[] }[];\n\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 }));\n}\n\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\nexport function flattenByStartTime(bySport: GamesBySport): EnrichedGame[] {\n return bySport.flatMap((group) => group.games).toSorted((a, b) => a.start_time - b.start_time);\n}\n\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",["D",1789502858592],{"_35":83,"_37":84,"_38":39,"_40":86,"_43":87,"_45":14,"_46":47,"_29":30},{"_35":83,"_37":84,"_38":39,"_40":85},"lib/dates.ts","01a07d9f-d1a6-714a-87c0-d9145aa5102a","dates.ts","// 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","// 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// Candidate coverage starts at the client's local midnight, expressed as an\n// absolute instant. Ended games remain candidates; device presentation owns\n// whether expired items are displayed.\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",["D",1789502858592],"id","244bcafd-364b-4df7-8955-55f2c3f7da2c","source-nfl",["D",1788814020921],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","NFL schedules and widget items via the source SDK","imageUrl","b0a8da26-58e7-4d19-8b5c-eedf487df9a9","pinnedFileId","01a07d9f-d1a7-75dc-86db-eb178f2b25b1","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","5a10edca-919b-4a78-babb-71908f69af93","tursoName","244bcafd364b4df7895555f2c3f7da2c","tursoHostname","244bcafd364b4df7895555f2c3f7da2c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789512044203],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_143":142,"_150":146},"org",{"_143":142,"_144":-5,"_145":146,"_18":100,"_147":148,"_149":30},"branch",{"_13":14,"_37":133,"_88":47,"_134":89,"_135":-5,"_136":-5,"_137":-5,"_138":-5,"_139":-5,"_140":90,"_141":142},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","plusjade","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yVHpab25kTlBTM3M3WmpCa3NMSTd5akVwWksuanBlZyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_88":89,"_37":90,"_43":348,"_92":-5,"_93":30,"_94":95,"_96":95,"_97":98,"_99":-5,"_18":100,"_101":102,"_103":30,"_104":-5,"_105":-5,"_106":107,"_108":109,"_110":111,"_112":113,"_114":349,"_116":-5,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_126":350,"_128":351,"_130":352,"_132":30},"tree",[237,248,250,252,253,254,255],"files",[237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255],"counts",{"_226":107,"_227":228,"_229":212,"_230":231,"_232":233},"contents",[174,175,176,177,178,179,180],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_88":221,"_37":222,"_35":223,"_183":-5,"_46":47,"_45":212,"_185":169,"_43":224,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_32":225},{"_88":216,"_37":217,"_35":218,"_183":-5,"_46":47,"_45":187,"_185":169,"_43":219,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_32":220},{"_88":209,"_37":210,"_35":211,"_183":-5,"_46":47,"_45":212,"_185":169,"_43":213,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_32":215},{"_88":203,"_37":204,"_35":205,"_183":-5,"_46":47,"_45":199,"_185":169,"_43":206,"_13":107,"_38":39,"_40":207,"_29":30,"_190":-5,"_32":208},{"_88":196,"_37":197,"_35":198,"_183":-5,"_46":47,"_45":199,"_185":169,"_43":200,"_13":107,"_38":39,"_40":201,"_29":30,"_190":-5,"_32":202},{"_88":192,"_37":33,"_35":36,"_183":-5,"_46":47,"_45":14,"_185":169,"_43":193,"_13":194,"_38":39,"_40":42,"_29":30,"_190":-5,"_32":195},{"_88":181,"_37":182,"_35":102,"_183":-5,"_46":47,"_45":184,"_185":169,"_43":186,"_13":187,"_38":188,"_40":189,"_29":30,"_190":-5,"_32":191},"23e72d3b-6fcd-4419-863b-6d2fbdfd4ef9","rpc.ts","parentId",17,"latest",["D",1789077594284],4,"http","// Authenticated NFL source protocol and cache coverage diagnostics.\nimport { diagnostics } from \"./diagnostics.ts\";\nimport { serveSource } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\nimport nflSource from \"./nflSource.ts\";\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { cachedGamesCoverage } from \"./lib/cachedGames.ts\";\nexport default async function handler(req:Request):Promise {\n const expected=Deno.env.get(\"SOURCE_NFL_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 (req.method === \"GET\" && url.pathname === \"/diagnostics\") return Response.json(await diagnostics(), { headers: { \"cache-control\": \"no-store\" } });\n if(url.pathname.startsWith(\"/v1/\")) return serveSource(nflSource,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 return new Response(\"Not found\",{status:404});\n}\n","label",[182],"050c2e40-c9f9-468e-9382-93ca7d7e46bd",["D",1789502858592],3,[33],"bc93c612-4456-4592-a939-e4fd9b64f074","diagnostics.ts","5cb22a48-ac07-11f1-ba1b-1607ee4eb77e",6,["D",1788928304467],"// Source-owned storage projection; the parent never interprets these tables.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function diagnostics() {\n const result = await sqlite.execute(`SELECT COUNT(*) AS total,\n MIN(start_time_ms / 1000.0) AS earliest, MAX(start_time_ms / 1000.0) AS latest,\n MAX(ingested_at) AS updated FROM cached_games WHERE sport = 'nfl'`);\n const row = result.rows[0];\n return {\n diagnosticsVersion: 1, sourceKey: \"nfl\", scope: \"stored\",\n totalItems: Number(row.total),\n earliestTimestamp: row.earliest === null ? null : Number(row.earliest),\n latestTimestamp: row.latest === null ? null : Number(row.latest),\n lastIngestedAt: row.updated === null ? null : String(row.updated),\n };\n}\n",[197],"ee986965-c73d-4324-aacf-64bad7e83b72","diagnostics-check.ts","5cb20342-ac07-11f1-ba1b-1607ee4eb77e",["D",1788928304467],"// Read-only verification of the diagnostics mount and existing descriptor.\nimport handler from \"./rpc.ts\";\nconst headers = { authorization: `Bearer ${Deno.env.get(\"SOURCE_NFL_V1_TOKEN\")}` };\nfunction check(ok: unknown, label: string) { if (!ok) throw new Error(label); }\nconst denied = await handler(new Request(\"https://check.invalid/diagnostics\"));\ncheck(denied.status === 401, \"diagnostics requires authentication\");\nconst response = await handler(new Request(\"https://check.invalid/diagnostics\", { headers }));\ncheck(response.status === 200, \"diagnostics status\");\ncheck(response.headers.get(\"cache-control\") === \"no-store\", \"uncached diagnostics\");\nconst value = await response.json();\ncheck(value.diagnosticsVersion === 1 && value.sourceKey === \"nfl\" && value.scope === \"stored\", \"identity\");\ncheck(Number.isSafeInteger(value.totalItems) && value.totalItems >= 0, \"total\");\ncheck(value.totalItems === 0\n ? value.earliestTimestamp === null && value.latestTimestamp === null\n : Number.isFinite(value.earliestTimestamp) && Number.isFinite(value.latestTimestamp)\n && value.earliestTimestamp <= value.latestTimestamp, \"bounds\");\nconst descriptor = await handler(new Request(\"https://check.invalid/v1/descriptor?sourceKey=nfl\", { headers }));\ncheck(descriptor.status === 200, \"descriptor preserved\");\nconsole.log({ source: value.sourceKey, totalItems: value.totalItems,\n earliest: value.earliestTimestamp, latest: value.latestTimestamp, checks: \"passed\" });\n",[204],"62110488-4512-4aea-8e95-2e3bc07138a1","tools","01a07d9f-d1a7-75dc-86db-e7225a35582d",1,["D",1788814020921],"directory",[210],"5141126e-5a7d-4e0e-a8ab-634afe4d87aa","scripts","362b6958-4aab-42ac-a75a-1954152b9280",["D",1788911604254],[217],"b8702dc3-7e2a-45ad-9141-b0e75e2edf8f","lib","01a07d9f-d1a6-714a-87c0-fdae5cc2ef18",["D",1788814020921],[222],"pulls","branches",5,"forks","envVars",{"_234":187,"_236":107},"connections",{"_234":107,"_235":107},"count","unfilledCount","emptyCount",{"_88":221,"_37":222,"_35":223,"_183":-5,"_46":47,"_45":212,"_185":169,"_43":345,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_257":346,"_32":347},{"_88":338,"_37":339,"_35":340,"_183":223,"_46":47,"_45":294,"_185":169,"_43":341,"_13":212,"_38":39,"_40":342,"_29":30,"_190":-5,"_257":343,"_32":344},{"_88":331,"_37":332,"_35":333,"_183":223,"_46":47,"_45":294,"_185":169,"_43":334,"_13":212,"_38":39,"_40":335,"_29":30,"_190":-5,"_257":336,"_32":337},{"_88":324,"_37":325,"_35":326,"_183":223,"_46":47,"_45":294,"_185":169,"_43":327,"_13":212,"_38":39,"_40":328,"_29":30,"_190":-5,"_257":329,"_32":330},{"_88":317,"_37":318,"_35":319,"_183":223,"_46":47,"_45":212,"_185":169,"_43":320,"_13":107,"_38":39,"_40":321,"_29":30,"_190":-5,"_257":322,"_32":323},{"_88":313,"_37":84,"_35":83,"_183":223,"_46":47,"_45":14,"_185":169,"_43":314,"_13":212,"_38":39,"_40":86,"_29":30,"_190":-5,"_257":315,"_32":316},{"_88":309,"_37":76,"_35":75,"_183":223,"_46":47,"_45":14,"_185":169,"_43":310,"_13":294,"_38":39,"_40":78,"_29":30,"_190":-5,"_257":311,"_32":312},{"_88":305,"_37":52,"_35":51,"_183":223,"_46":47,"_45":14,"_185":169,"_43":306,"_13":212,"_38":39,"_40":54,"_29":30,"_190":-5,"_257":307,"_32":308},{"_88":298,"_37":299,"_35":300,"_183":223,"_46":47,"_45":212,"_185":169,"_43":301,"_13":107,"_38":39,"_40":302,"_29":30,"_190":-5,"_257":303,"_32":304},{"_88":290,"_37":291,"_35":292,"_183":223,"_46":47,"_45":194,"_185":169,"_43":293,"_13":294,"_38":39,"_40":295,"_29":30,"_190":-5,"_257":296,"_32":297},{"_88":286,"_37":68,"_35":67,"_183":223,"_46":47,"_45":14,"_185":169,"_43":287,"_13":194,"_38":39,"_40":70,"_29":30,"_190":-5,"_257":288,"_32":289},{"_88":216,"_37":217,"_35":218,"_183":-5,"_46":47,"_45":187,"_185":169,"_43":283,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_257":284,"_32":285},{"_88":276,"_37":277,"_35":278,"_183":218,"_46":47,"_45":228,"_185":169,"_43":279,"_13":212,"_38":39,"_40":280,"_29":30,"_190":-5,"_257":281,"_32":282},{"_88":209,"_37":210,"_35":211,"_183":-5,"_46":47,"_45":212,"_185":169,"_43":273,"_13":107,"_38":214,"_40":-5,"_29":30,"_190":-5,"_257":274,"_32":275},{"_88":269,"_37":60,"_35":59,"_183":211,"_46":47,"_45":14,"_185":169,"_43":270,"_13":187,"_38":39,"_40":62,"_29":30,"_190":-5,"_257":271,"_32":272},{"_88":203,"_37":204,"_35":205,"_183":-5,"_46":47,"_45":199,"_185":169,"_43":266,"_13":107,"_38":39,"_40":207,"_29":30,"_190":-5,"_257":267,"_32":268},{"_88":196,"_37":197,"_35":198,"_183":-5,"_46":47,"_45":199,"_185":169,"_43":263,"_13":107,"_38":39,"_40":201,"_29":30,"_190":-5,"_257":264,"_32":265},{"_88":192,"_37":33,"_35":36,"_183":-5,"_46":47,"_45":14,"_185":169,"_43":260,"_13":194,"_38":39,"_40":42,"_29":30,"_190":-5,"_257":261,"_32":262},{"_88":181,"_37":182,"_35":102,"_183":-5,"_46":47,"_45":184,"_185":169,"_43":256,"_13":187,"_38":188,"_40":189,"_29":30,"_190":-5,"_257":258,"_32":259},["D",1789077594284],"children",[],[182],["D",1789502858592],[],[33],["D",1788928304467],[],[197],["D",1788928304467],[],[204],"7c980e04-2f28-4755-9240-0c76b9fa3784",["D",1789502858592],[],[210,60],["D",1788814020921],[251],[210],"2a2c9561-476b-44ba-bd81-c09123bfc494","ingestSeason.ts","7a92a73a-abe0-11f1-855e-1607ee4eb77e",["D",1788911630101],"// One-off backfill: pull a whole season's slate into cached_games.\n//\n// The `sleeper.refresh` write is a rolling window anchored on today and capped\n// at 31 days, which is right for keeping the cache warm and useless for\n// reaching Week 18. This names the range instead. Run it by hand; it is not on\n// any schedule and nothing imports it.\n//\n// Bounds are Eastern slate dates — the bucket Sleeper's /scores keys on.\nimport { datesBetween, ingestDates } from \"../lib/sleeperIngest.ts\";\n\nconst SEASON_START = \"2026-09-01\";\nconst SEASON_END = \"2027-01-12\"; // through the end of Week 18 (Jan 9-10)\n\nconst dates = datesBetween(SEASON_START, SEASON_END);\nconst report = await ingestDates(dates);\n\nconsole.log(JSON.stringify({\n range: [SEASON_START, SEASON_END],\n days: dates.length,\n fetched: report.fetched,\n stored: report.stored,\n skipped: report.skipped,\n bySport: report.bySport,\n}, null, 2));\n",[],[217,277],["D",1788911604254],[249],[217],"f68a3835-ff81-4483-9b45-253a0c321884",["D",1789502858592],[],[222,68],"5d3557a3-9d75-43de-9cda-e76b6eb71154","sleeperIngest.ts","01a07d9f-d1a6-714a-87c0-ee09505829a6",["D",1788911593738],2,"\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\nexport type IngestReport = {\n dates: string[];\n fetched: number;\n stored: number;\n skipped: number;\n bySport: Record;\n};\n\n// Sleeper's /scores is keyed by a single Eastern day, so a season-length\n// ingest is one upstream request per date. Fired in bounded waves rather than\n// all at once: 130 simultaneous fetches is a good way to get rate-limited by\n// a public endpoint that owes us nothing.\nconst FETCH_CONCURRENCY = 12;\n\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 !== \"nfl\" || !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 start_time_ms: startTimeMs,\n status: typeof game.status === \"string\" ? game.status : null,\n channel: game.metadata?.channel ?? null,\n };\n}\n\n// Inclusive on both ends. Both bounds are Eastern slate dates (YYYY-MM-DD),\n// the same bucket Sleeper keys on — not client days.\nexport function datesBetween(from: string, to: string): string[] {\n const dates: string[] = [];\n for (let date = from; date <= to; date = addDays(date, 1)) dates.push(date);\n return dates;\n}\n\n// The ingest itself, over an explicit list of slate dates. Split out from\n// ingestSleeperWindow so a backfill can name a season's date range directly\n// instead of being expressed as an offset from today — the rolling window is\n// one caller of this, not the only shape an ingest comes in.\nexport async function ingestDates(dates: string[]): Promise {\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 if (codes.size === 0) return { dates, fetched: 0, stored: 0, skipped: 0, bySport: {} };\n\n const providerKeys = [...codes.keys()];\n const fetched: Game[] = [];\n for (let i = 0; i < dates.length; i += FETCH_CONCURRENCY) {\n const wave = await Promise.all(\n dates.slice(i, i + FETCH_CONCURRENCY).map((date) => fetchScores(date, providerKeys)),\n );\n for (const games of wave) fetched.push(...games);\n }\n\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 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\nexport async function ingestSleeperWindow(\n days = 7,\n now = new Date(),\n backfillDays = 1,\n): Promise {\n const start = addDays(todaySlateDate(now), -backfillDays);\n return ingestDates(\n Array.from({ length: days + backfillDays + 1 }, (_, i) => addDays(start, i)),\n );\n}\n",[],[222,291],"dae9bd2b-9c21-44a8-894d-7cfb9b1c00b5","sleeper.ts","01a07d9f-d1a6-714a-87c0-e93a3e2b55fc",["D",1788814020921],"// 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",[],[222,299],"a3282192-887d-4e91-8b74-dfaf874ab85f",["D",1789502858592],[],[222,52],"bf1c163b-18e2-45d8-bebd-654701dd7d7e",["D",1789502858592],[],[222,76],"712873b2-91f7-45b5-b0b7-c33abbe39976",["D",1789502858592],[],[222,84],"8585cf35-9f34-4e33-a6e7-e790408794d3","channels.ts","01a07d9f-d1a6-714a-87c0-d58c7798fab8",["D",1788814020921],"// 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",[],[222,318],"23cb2f38-a163-4dde-ae02-cbfd7948a457","catalogStore.ts","01a07d9f-d1a6-714a-87c0-d0e5a63183cc",["D",1788814300348],"// 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 WHERE code = 'nfl' 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 WHERE t.competition_code = 'nfl'\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",[],[222,325],"0a9827bb-b1d6-4089-9b91-bf63ffee8173","catalog.ts","01a07d9f-d1a6-714a-87c0-cfe4241be89f",["D",1788814300348],"\nexport type TeamRef = { sport: string; code: string };\n\nexport type CatalogCompetition = {\n code: string;\n displayName: string;\n adapter: \"sleeper\";\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\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",[],[222,332],"38484dbd-0c94-4c24-a220-941d5d68cbc8","cachedGames.ts","01a07d9f-d1a6-714a-87c0-c8c5a1f52977",["D",1788814300348],"\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { type TeamRef } from \"./catalog.ts\";\nimport { type Game } from \"./games.ts\";\n\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\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\nexport async function nextGamesForTeams(teams: TeamRef[], fromMs: number): Promise {\n if (!teams.length) return [];\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: [\"nfl\", team.code, team.code, fromMs],\n })),\n );\n\n return results.flatMap((result) => (result.rows as CachedGameRow[]).map(rowToGame));\n}\n\nexport async function saveCachedGames(rows: CachedGameRow[]): Promise {\n if (rows.some((row) => row.sport !== \"nfl\")) throw new Error(\"NFL rows required\");\n if (!rows.length) return 0;\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\nexport async function cachedGamesCoverage(): Promise<\n { sport: string; games: number; firstStartMs: number; lastStartMs: number; ingestedAt: string }[]\n> {\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 WHERE sport = 'nfl'\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",[],[222,339],["D",1788814020921],[238,239,240,241,242,243,244,245,246,247],[222],["D",1788814020921],["D",1789512044203],{"_143":142,"_150":146},{"_143":142,"_144":-5,"_145":146,"_18":100,"_147":148,"_149":30},{"_13":14,"_37":133,"_88":47,"_134":89,"_135":-5,"_136":-5,"_137":-5,"_138":-5,"_139":-5,"_140":90,"_141":142},"ctx",{"_126":-5,"_171":386,"_387":388,"_389":390,"_391":30,"_392":30,"_393":30,"_394":169,"_395":-5,"_396":-7,"_397":-7,"_398":107,"_399":30,"_400":30,"_401":-5,"_402":30,"_403":30,"_404":30,"_405":-5},"ENV",{"_357":358,"_359":360,"_361":133,"_362":363,"_364":365,"_366":367,"_368":369,"_370":371,"_372":373,"_374":375,"_376":377,"_378":379,"_380":381,"_382":383,"_384":385},"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 · v18