[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_360":361,"_362":363},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_39":-7,"_143":-5,"_19":144,"_145":146,"_147":148,"_149":150,"_151":152,"_21":153,"_154":155,"_156":157,"_158":24,"_159":160,"_161":162,"_163":-5,"_164":-5,"_165":166},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","plusjade","name","source-wnba","branchName","main","path","lib/sleeper.ts","project",{"_33":91,"_13":14,"_37":92,"_67":-5,"_93":24,"_94":95,"_96":95,"_97":98,"_99":-5,"_30":74,"_100":101,"_102":24,"_103":-5,"_104":-5,"_105":26,"_41":42,"_106":107,"_108":109,"_110":111,"_112":-5,"_113":114,"_115":114,"_116":117,"_118":117,"_119":117,"_120":114,"_121":114,"_54":122,"_123":124,"_125":126,"_127":24},"file",{"_68":69,"_13":70,"_71":72,"_73":24,"_90":-5},"isDirectory",false,"page",0,"history",[31,32],"hasNext","userId",{"_33":77,"_35":36,"_37":78,"_39":79,"_41":42,"_43":80,"_44":81,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":82,"_21":83,"_57":-5,"_58":84,"_60":-5,"_61":-5,"_62":85},{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":59,"_60":-5,"_61":-5,"_62":63},"id","b1e6da11-ae75-4bc7-9ac7-6f950726a57a","branchId","e48487c1-8c7d-4a71-8497-20fa5e49852d","createdAt",["D",1788818616931],"version",1,"orgId","5a10edca-919b-4a78-babb-71908f69af93","parentId","incomingCommitId","4041c877-3168-4dfd-bacc-166bd1660ff8","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_33":74,"_41":42,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},"pull","merge",{"_35":65,"_13":16,"_39":66,"_67":-5},"revert","multiple","commits",[64],{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_44":45,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":59,"_60":-5},"72e0d709-5cf3-4bb8-91f0-b616d4c49f98",16,"deletedAt","fileId","01a07de5-f2ca-7358-a26f-ee56d394f595","sleeper.ts","fileType","script","deleted","b0a8da26-58e7-4d19-8b5c-eedf487df9a9","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yVHpab25kTlBTM3M3WmpCa3NMSTd5akVwWksuanBlZyJ9","1a8bdb0c-2f1d-43bd-bcaf-ac33b4206a47",["D",1789587548973],17,"4cbc1e82-732d-428c-a9a9-7bb3c6a8d75c","91a89443-3438-4b9d-8946-edd4c5440784",{"_33":74,"_41":42,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},{"_35":87,"_13":88,"_39":89,"_67":-5},[86],{"_33":77,"_35":36,"_37":78,"_39":79,"_41":42,"_43":80,"_44":81,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":82,"_21":83,"_57":-5,"_58":84,"_60":-5},"c171bc7a-83e0-4ecc-b3b5-349bc7a67bd7","starts-at-expires-at-weekly",12,"deletedAtVersion","c0bf06b0-4d38-49ff-aa56-54d81db775bb",["D",1788818616931],"legacyEnvVars","privacy","public","httpPrivacy","description","WNBA schedules and upcoming games","imageUrl","pinnedFileId","01a07de5-f2ca-7358-a270-26c8bacce23f","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","c0bf06b04d3849ffaa5654d81db775bb","tursoHostname","c0bf06b04d3849ffaa5654d81db775bb-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789516253896],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_142":76},"org",{"_11":12,"_138":-5,"_75":76,"_30":74,"_139":140,"_141":24},"branch",{"_39":79,"_13":16,"_33":36,"_128":91,"_129":65,"_130":131,"_132":95,"_133":134,"_135":42,"_136":14,"_137":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion",2,"forkedProjectPrivacy","forkedProjectId","c6b65c42-8367-4edb-bb37-e9eb4a828295","forkedProjectOrgId","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":91,"_13":14,"_37":355,"_67":-5,"_93":24,"_94":95,"_96":95,"_97":98,"_99":-5,"_30":74,"_100":101,"_102":24,"_103":-5,"_104":-5,"_105":26,"_41":42,"_106":107,"_108":109,"_110":356,"_112":-5,"_113":114,"_115":114,"_116":117,"_118":117,"_119":117,"_120":114,"_121":114,"_54":357,"_123":358,"_125":359,"_127":24},"tree",[197,208,209,212,213,214,215,216],"files",[197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214,215,216],"counts",{"_186":26,"_187":188,"_189":26,"_190":191,"_192":193},"contents",[],{"_33":176,"_13":70,"_68":69,"_43":177,"_35":36,"_178":79,"_179":162,"_37":180,"_39":40,"_71":72,"_181":182,"_73":24,"_183":-5,"_17":184},"upstreamProject",{"_33":134,"_13":173,"_97":174,"_99":-5,"_94":95,"_54":175},"upstreamBranch",{"_33":65,"_37":167,"_168":169,"_13":16,"_128":134,"_39":66,"_129":170,"_130":131,"_171":172,"_67":-5,"_127":24,"_94":95,"_137":12,"_41":42,"_136":173},"emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},["D",1788817734356],"updatedAt",["D",1789583999015],"61c73600-56ab-40cd-815a-59f4fefa923a","lockfileKey","1789583999587-esm.town_v_plusjade_source-cfb@16-main","source-cfb","College football schedules and upcoming games",{"_11":12,"_142":76},"c3c8df6f-e788-448b-9587-ca715fab3761","01a07de5-f2ca-7358-a26f-fa67776ff52f","branchVersion","latest",["D",1789587548973],"content","// Sleeper-specific outbound I/O. Its millisecond, snake_case response and\n// nested WNBA team values are normalized at the adapter boundary.\n\nexport type SleeperGame = {\n sport?: unknown;\n start_time?: unknown;\n status?: unknown;\n game_id?: unknown;\n metadata?: {\n away_team?: unknown;\n home_team?: unknown;\n channel?: unknown;\n };\n};\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 response = await fetch(url, { signal: AbortSignal.timeout(15_000) });\n if (!response.ok) throw new Error(`Sleeper /scores returned ${response.status}`);\n const payload: unknown = await response.json();\n if (!Array.isArray(payload)) throw new Error(\"Sleeper /scores returned a non-array payload\");\n return payload as SleeperGame[];\n}\n","label",[185,70],"lib","pulls","branches",6,"forks","envVars",{"_194":188,"_196":26},"connections",{"_194":26,"_195":26},"count","unfilledCount","emptyCount",{"_33":351,"_13":185,"_68":177,"_43":-5,"_35":36,"_178":40,"_179":162,"_37":352,"_39":26,"_71":275,"_181":-5,"_73":24,"_183":-5,"_223":353,"_17":354},{"_33":344,"_13":345,"_68":346,"_43":177,"_35":36,"_178":79,"_179":162,"_37":347,"_39":131,"_71":72,"_181":348,"_73":24,"_183":-5,"_223":349,"_17":350},{"_33":337,"_13":338,"_68":339,"_43":177,"_35":36,"_178":40,"_179":162,"_37":340,"_39":26,"_71":72,"_181":341,"_73":24,"_183":-5,"_223":342,"_17":343},{"_33":330,"_13":331,"_68":332,"_43":177,"_35":36,"_178":131,"_179":162,"_37":333,"_39":40,"_71":72,"_181":334,"_73":24,"_183":-5,"_223":335,"_17":336},{"_33":323,"_13":324,"_68":325,"_43":177,"_35":36,"_178":40,"_179":162,"_37":326,"_39":26,"_71":72,"_181":327,"_73":24,"_183":-5,"_223":328,"_17":329},{"_33":316,"_13":317,"_68":318,"_43":177,"_35":36,"_178":66,"_179":162,"_37":319,"_39":40,"_71":72,"_181":320,"_73":24,"_183":-5,"_223":321,"_17":322},{"_33":309,"_13":310,"_68":311,"_43":177,"_35":36,"_178":79,"_179":162,"_37":312,"_39":295,"_71":72,"_181":313,"_73":24,"_183":-5,"_223":314,"_17":315},{"_33":176,"_13":70,"_68":69,"_43":177,"_35":36,"_178":79,"_179":162,"_37":306,"_39":40,"_71":72,"_181":182,"_73":24,"_183":-5,"_223":307,"_17":308},{"_33":299,"_13":300,"_68":301,"_43":177,"_35":36,"_178":79,"_179":162,"_37":302,"_39":131,"_71":72,"_181":303,"_73":24,"_183":-5,"_223":304,"_17":305},{"_33":291,"_13":292,"_68":293,"_43":177,"_35":36,"_178":79,"_179":162,"_37":294,"_39":295,"_71":72,"_181":296,"_73":24,"_183":-5,"_223":297,"_17":298},{"_33":284,"_13":285,"_68":286,"_43":177,"_35":36,"_178":79,"_179":162,"_37":287,"_39":131,"_71":72,"_181":288,"_73":24,"_183":-5,"_223":289,"_17":290},{"_33":278,"_13":279,"_68":280,"_43":-5,"_35":36,"_178":40,"_179":162,"_37":281,"_39":26,"_71":275,"_181":-5,"_73":24,"_183":-5,"_223":282,"_17":283},{"_33":273,"_13":265,"_68":260,"_43":-5,"_35":36,"_178":40,"_179":162,"_37":274,"_39":26,"_71":275,"_181":-5,"_73":24,"_183":-5,"_223":276,"_17":277},{"_33":266,"_13":267,"_68":268,"_43":260,"_35":36,"_178":79,"_179":162,"_37":269,"_39":40,"_71":72,"_181":270,"_73":24,"_183":-5,"_223":271,"_17":272},{"_33":257,"_13":258,"_68":259,"_43":260,"_35":36,"_178":79,"_179":162,"_37":261,"_39":252,"_71":72,"_181":262,"_73":24,"_183":-5,"_223":263,"_17":264},{"_33":249,"_13":250,"_68":251,"_43":-5,"_35":36,"_178":252,"_179":162,"_37":253,"_39":26,"_71":72,"_181":254,"_73":24,"_183":-5,"_223":255,"_17":256},{"_33":242,"_13":243,"_68":244,"_43":-5,"_35":36,"_178":79,"_179":162,"_37":245,"_39":40,"_71":72,"_181":246,"_73":24,"_183":-5,"_223":247,"_17":248},{"_33":234,"_13":235,"_68":236,"_43":-5,"_35":36,"_178":79,"_179":162,"_37":237,"_39":131,"_71":238,"_181":239,"_73":24,"_183":-5,"_223":240,"_17":241},{"_33":226,"_13":227,"_68":101,"_43":-5,"_35":36,"_178":228,"_179":162,"_37":229,"_39":221,"_71":230,"_181":231,"_73":24,"_183":-5,"_223":232,"_17":233},{"_33":217,"_13":218,"_68":219,"_43":-5,"_35":36,"_178":79,"_179":162,"_37":220,"_39":221,"_71":72,"_181":222,"_73":24,"_183":-5,"_223":224,"_17":225},"8ec5b57a-9d41-4746-8896-13675b2e5b60","wnbaSource.ts","7c4b2b0c-ab08-11f1-8976-1607ee4eb77e",["D",1789587548973],4,"// WNBA settings and operations exported through the shared source SDK.\nimport { readCatalog } from \"./lib/catalogStore.ts\";\nimport { wnbaItems } from \"./lib/wnbaFeed.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 WNBARead = {\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: \"wnba\",\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 wnbaItems({ teams }, utcOffsetSeconds, catalog),\n\n writes: {\n // Pull the next N days of Sleeper's slate into wnba_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","children",[],[218],"7977c403-35f2-4afe-83a3-3f0088537f27","rpc.ts",15,["D",1789077705493],"http","// Authenticated WNBA 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 wnbaSource from \"./wnbaSource.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_WNBA_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(wnbaSource,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",[],[227],"42c225d6-c3cb-4391-8346-3974771aba83","refresh.ts","2e975f5c-ab2b-11f1-9caa-1607ee4eb77e",["D",1789587548973],"interval","// Weekly rolling refresh of WNBA event windows from Sleeper.\nimport { ingestSleeperWindow } from \"./lib/sleeperIngest.ts\";\n\nconst DAYS = 7;\n\nexport default async function (_interval: Interval) {\n const report = await ingestSleeperWindow(DAYS);\n console.log(JSON.stringify(report));\n return report;\n}\n",[],[235],"0465b1ec-64a0-48b7-8315-98a695e0ff2c","diagnostics.ts","60f4be2c-ac07-11f1-a6ce-1607ee4eb77e",["D",1789587548973],"// 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(starts_at) AS earliest, MAX(expires_at) AS latest,\n MAX(ingested_at) AS updated FROM wnba_games`);\n const row = result.rows[0];\n return {\n diagnosticsVersion: 1, sourceKey: \"wnba\", 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",[],[243],"e5ae2f73-a30a-47eb-bf71-b8ccb8d1a2d6","diagnostics-check.ts","60f49604-ac07-11f1-a6ce-1607ee4eb77e",5,["D",1788928311632],"// Read-only verification of the diagnostics mount and existing descriptor.\nimport handler from \"./rpc.ts\";\nconst headers = { authorization: `Bearer ${Deno.env.get(\"SOURCE_WNBA_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 === \"wnba\" && 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=wnba\", { 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",[],[250],"0e5e473b-4fa9-4144-9b75-bb65e687681a","source-contract-check.ts","01a07de5-f2ca-7358-a270-1bc131204eca","01a07de5-f2ca-7358-a270-1c653f2b1361",["D",1789587548973],"// WNBA 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, type Game } 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_WNBA_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:\"wnba\",settings:{teams:[\"fever\"]},context:{utcOffsetSeconds:0}};\ncheck((await call(\"/v1/descriptor\",undefined,false)).status===401,\"auth\");\nconst d=(await call(\"/v1/descriptor?sourceKey=wnba\")).body;\ncheck(d.sourceKey===\"wnba\"&&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===15,\"15 choices\");\ncheck(s.properties.teams.items.oneOf.every((x:any)=>typeof x.const===\"string\"&&typeof x.title===\"string\"&&x[\"x-group\"]===\"WNBA\"),\"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:[\"fever\",\"fever\"]},{teams:[],unexpected:true},{teams:\"fever\"}]){\n check((await call(\"/v1/validate-settings\",{...base,settings})).body.error===\"invalid_settings\",\"invalid settings\");\n}\nfor(const slug of [\"trojans\",\"united-states\",\"rams\",\"missing\"]){\n check((await call(\"/v1/read\",{...base,settings:{teams:[slug]}})).body.error===\"unknown_team\",\"non WNBA \"+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 tipoff=1788739200;\nconst game:Game={\n sport:\"wnba\",gameId:\"fixture\",startsAt:tipoff,expiresAt:tipoff+7200,status:\"final\",\n metadata:{awayTeam:\"IND\",homeTeam:\"LAS\",channel:\"NBC\"},\n};\nconst picked=pickNextPerTeam([game],[{sport:\"wnba\",code:\"IND\"},{sport:\"wnba\",code:\"LAS\"}],[\"wnba\"])!;\nconst built=widgetItems(picked.bySport,catalog);\ncheck(built.length===1&&built[0].startsAt===tipoff&&built[0].mainText===\"🏀 Fever @ Sparks\",\"union and seconds\");\ncheck(built[0].timestamp===tipoff,\"the transitional timestamp still mirrors startsAt\");\ncheck(built[0].expiresAt===tipoff+7200,\"the stored expiry survives to the wire\");\ncheck(built[0].caption===\"END\"&&!built[0].emphasized,\"expired items remain candidates\");\nconst stale={...game,status:\"scheduled\"};\nconst stalePicked=pickNextPerTeam([stale],[{sport:\"wnba\",code:\"IND\"}],[\"wnba\"])!;\ncheck(widgetItems(stalePicked.bySport,catalog,tipoff-1)[0].caption===null,\"before tipoff the client formats the time\");\ncheck(widgetItems(stalePicked.bySport,catalog,tipoff+60)[0].caption===\"LIVE\",\"a stale scheduled status still reads live\");\ncheck(widgetItems(stalePicked.bySport,catalog,tipoff+7200)[0].caption===\"END\",\"expired by the clock alone\");\ncheck(widgetItems(picked.bySport,catalog,tipoff+60)[0].caption===\"LIVE\",\"stored final does not override the published window\");\ncheck(phase(widgetItems(stalePicked.bySport,catalog,tipoff)[0],tipoff)===\"current\",\"phase agrees with the caption\");\nconst sleeperGame={\n sport:\"wnba\",game_id:\"fixture\",start_time:1788739200123,status:\"pre_game\",\n metadata:{away_team:{team:\"IND\",record:\"0-0\"},home_team:{team:\"LAS\"},channel:\"NBC\"},\n};\nconst normalized=normalizeGame(sleeperGame);\ncheck(normalizeGame({...sleeperGame,sport:\"nfl\"})===null,\"ingest league guard\");\ncheck(normalized?.away_code===\"IND\"&&normalized?.home_code===\"LAS\",\"nested WNBA shape\");\ncheck(normalized?.starts_at===1788739200&&normalized?.expires_at===1788746400,\"milliseconds normalize to an explicit seconds window\");\ncheck(normalizeGame({...sleeperGame,metadata:{away_team:\"IND\",home_team:\"LAS\"}})?.away_code===\"IND\",\"flat WNBA shape\");\ncheck(normalizeGame({...sleeperGame,metadata:{away_team:{team:42}}})?.away_code===null,\"malformed team\");\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+\" WNBA assertions\");\n",[],[265,258],"tools","c22223c4-26e3-4c4a-abca-2adc486d5650","sleeper-ingest.ts","554fcbbc-ab2a-11f1-a8fe-1607ee4eb77e",["D",1789587548973],"// Operator entry point for a seven-day WNBA refresh through the authenticated\n// source write boundary, followed by source-owned coverage diagnostics.\nimport handler from \"../rpc.ts\";\nimport { cachedGamesCoverage } from \"../lib/cachedGames.ts\";\n\nconst DAYS = 7;\nconst token = Deno.env.get(\"SOURCE_WNBA_V1_TOKEN\");\nif (!token) throw new Error(\"SOURCE_WNBA_V1_TOKEN is not configured\");\n\nconst response = await handler(\n new Request(\"https://fixture.invalid/v1/write\", {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json\" },\n body: JSON.stringify({\n protocolVersion: 1,\n sourceKey: \"wnba\",\n operation: \"sleeper.refresh\",\n payload: { days: DAYS },\n }),\n }),\n);\n\nconst body = await response.json();\nif (!response.ok) throw new Error(`ingest failed (${response.status}): ${JSON.stringify(body)}`);\nconsole.log(JSON.stringify({ report: body.result, coverage: await cachedGamesCoverage() }, null, 2));\n",[],[265,267],"01e1a938-bc23-4b01-a225-abdc627b36bf",["D",1788818616931],"directory",[210,211],[265],"f24ce634-e3d3-4461-9e8a-37d8e1460628","sdk","01a07de5-f2ca-7358-a270-127c5b7f25c2",["D",1788818616931],[],[279],"d099f268-13e1-4df7-971f-7eeb39354694","wnbaFeed.ts","7c4b023a-ab08-11f1-8976-1607ee4eb77e",["D",1789587548973],"// Each selected WNBA 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 wnbaItems(\n settings: { teams: string[] },\n utcOffsetSeconds: number | null,\n catalog: Catalog,\n) {\n const teams = settings.teams.map((slug) => ({\n sport: \"wnba\", code: catalog.teams.find((team) => team.slug === slug)!.providerCode,\n }));\n const fromSeconds = Math.floor(\n dayStartMsAtOffset(clientOffsetSeconds(utcOffsetSeconds)) / 1000,\n );\n const candidates = await nextGamesForTeams(teams, fromSeconds);\n const picked = pickNextPerTeam(candidates, teams, [\"wnba\"]);\n return widgetItems(picked?.bySport ?? [], catalog);\n}\n",[],[185,285],"d1c063fa-754b-42b7-a973-58f6f31b97e2","widgetItems.ts","01a07de5-f2ca-7358-a26f-f6225156bcdf",["D",1789587548973],3,"// Stored event windows → the widget's item shape. Every field here is a view\n// decision; the clock arrives as an argument so lifecycle stays deterministic.\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 } from \"https://esm.town/v/plusjade/source-sdk@12-main/mod.ts\";\n\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 const window = { startsAt: game.startsAt, expiresAt: game.expiresAt };\n return {\n id: game.gameId,\n mainText: `${emoji ? `${emoji} ` : \"\"}${away} @ ${home}`,\n subText: channelText(game.channel),\n ...captionFor(phase(window, now)),\n ...window,\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",[],[185,292],"7849cae9-d8d9-4109-ab79-43a2b65d86e9","sleeperIngest.ts","01a07de5-f2ca-7358-a26f-f03b8f3e6408",["D",1789587548973],"\nimport { readCatalog } from \"./catalogStore.ts\";\nimport { saveCachedGames, type CachedGameRow } from \"./cachedGames.ts\";\nimport { addDays, todaySlateDate } from \"./dates.ts\";\nimport { fetchScores, type SleeperGame } from \"./sleeper.ts\";\n\nexport type IngestReport = {\n dates: string[];\n fetched: number;\n stored: number;\n skipped: number;\n bySport: Record;\n};\n\nconst WNBA_TYPICAL_GAME_SECONDS = 2 * 60 * 60;\nconst FETCH_CONCURRENCY = 3;\n\nfunction teamCode(value: unknown): string | null {\n const code = value && typeof value === \"object\" ? (value as { team?: unknown }).team : value;\n return typeof code === \"string\" ? code : null;\n}\n\nexport function normalizeGame(game: SleeperGame): CachedGameRow | null {\n const id = typeof game.game_id === \"string\" || typeof game.game_id === \"number\"\n ? String(game.game_id)\n : null;\n const startTimeMs = typeof game.start_time === \"number\" ? game.start_time : NaN;\n if (!id || game.sport !== \"wnba\" || !Number.isFinite(startTimeMs) || startTimeMs <= 0) {\n return null;\n }\n\n const startsAt = Math.floor(startTimeMs / 1000);\n return {\n game_id: id,\n away_code: teamCode(game.metadata?.away_team),\n home_code: teamCode(game.metadata?.home_team),\n starts_at: startsAt,\n expires_at: startsAt + WNBA_TYPICAL_GAME_SECONDS,\n status: typeof game.status === \"string\" ? game.status : null,\n channel: typeof game.metadata?.channel === \"string\" ? game.metadata.channel : null,\n };\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 const dates = Array.from(\n { length: days + backfillDays + 1 },\n (_, index) => addDays(start, index),\n );\n\n const catalog = await readCatalog();\n const competitions = catalog.competitions.filter((competition) => competition.adapter === \"sleeper\");\n const providerKeys = competitions.map((competition) => competition.providerKey);\n if (!providerKeys.length) return { dates, fetched: 0, stored: 0, skipped: 0, bySport: {} };\n\n const fetched: SleeperGame[] = [];\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 row = normalizeGame(game);\n if (row) rows.push(row);\n else skipped++;\n }\n\n const byId = new Map();\n for (const row of rows) byId.set(row.game_id, row);\n const deduped = [...byId.values()];\n const stored = await saveCachedGames(deduped);\n\n return {\n dates,\n fetched: fetched.length,\n stored,\n skipped,\n bySport: { wnba: deduped.length },\n };\n}\n",[],[185,300],["D",1789587548973],[],[185,70],"9ed05cb1-5a32-41d0-9b10-136a60aca947","games.ts","01a07de5-f2ca-7358-a26f-e80de26522a9",["D",1789587548973],"\nimport { type TeamRef } from \"./catalog.ts\";\nimport { channelInfo, type ChannelInfo } from \"./channels.ts\";\n\nexport type Game = {\n sport: \"wnba\";\n startsAt: number;\n expiresAt: number;\n status?: unknown;\n gameId: string;\n metadata: {\n awayTeam: string | null;\n homeTeam: string | null;\n channel: string | null;\n };\n};\n\nexport type EnrichedGame = Game & {\n away: string | null;\n home: string | null;\n channel: ChannelInfo;\n};\n\nexport type GamesBySport = { sport: string; games: EnrichedGame[] }[];\n\nfunction enrichGames(games: Game[]): EnrichedGame[] {\n return games.map((game) => ({\n ...game,\n away: game.metadata.awayTeam,\n home: game.metadata.homeTeam,\n channel: channelInfo(game.metadata.channel),\n }));\n}\n\nfunction matchesTeam(game: EnrichedGame, team: TeamRef): boolean {\n return team.sport === game.sport && (game.away === team.code || game.home === team.code);\n}\n\nfunction groupBySport(enriched: EnrichedGame[], sports: string[]): GamesBySport {\n const bySport = Object.groupBy(enriched, (game) => game.sport) as Record;\n return sports\n .filter((sport) => bySport[sport]?.length)\n .map((sport) => ({\n sport,\n games: bySport[sport].toSorted((a, b) => a.startsAt - b.startsAt),\n }));\n}\n\nexport function flattenByStartTime(bySport: GamesBySport): EnrichedGame[] {\n return bySport.flatMap((group) => group.games).toSorted((a, b) => a.startsAt - b.startsAt);\n}\n\nexport function pickNextPerTeam(\n candidates: Game[],\n teams: TeamRef[],\n sports: string[],\n): { earliestStartsAt: number; bySport: GamesBySport } | null {\n if (!teams.length) return null;\n\n const enriched = enrichGames(candidates).toSorted((a, b) => a.startsAt - b.startsAt);\n const matched = teams.flatMap((team) => {\n const next = enriched.find((game) => matchesTeam(game, team));\n return next ? [next] : [];\n });\n if (!matched.length) return null;\n\n const seen = new Set();\n const deduped = matched.filter((game) => {\n if (seen.has(game.gameId)) return false;\n seen.add(game.gameId);\n return true;\n });\n\n return {\n earliestStartsAt: Math.min(...deduped.map((game) => game.startsAt)),\n bySport: groupBySport(deduped, sports),\n };\n}\n",[],[185,310],"c59bc85e-1a5b-4119-96f1-5cb1a3caa0f1","dates.ts","01a07de5-f2ca-7358-a26f-e5727ea9fb6e",["D",1789502865626],"// 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",[],[185,317],"224fa5f2-fce6-40d5-b553-7f316b59700d","channels.ts","01a07de5-f2ca-7358-a26f-e0a372e2d022",["D",1788818616931],"// 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",[],[185,324],"585b843d-bdb2-4744-82ec-5d4a9aa43f77","catalogStore.ts","01a07de5-f2ca-7358-a26f-da1594aec136",["D",1788818835834],"// 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 = 'wnba' 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 = 'wnba'\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",[],[185,331],"1abf0fac-11e5-4133-a415-6fbfc68bc3c4","catalog.ts","01a07de5-f2ca-7358-a26f-d72894d087a9",["D",1788818616931],"\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",[],[185,338],"fde92654-e600-4d51-934d-0e4454374c1c","cachedGames.ts","01a07de5-f2ca-7358-a26f-d3cf509a2ccf",["D",1789587548973],"\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 game_id: string;\n away_code: string | null;\n home_code: string | null;\n starts_at: number;\n expires_at: number;\n status: string | null;\n channel: string | null;\n};\n\nfunction rowToGame(row: CachedGameRow): Game {\n return {\n sport: \"wnba\",\n gameId: row.game_id,\n startsAt: Number(row.starts_at),\n expiresAt: Number(row.expires_at),\n status: row.status,\n metadata: {\n awayTeam: row.away_code,\n homeTeam: row.home_code,\n channel: row.channel,\n },\n };\n}\n\nconst SELECT_COLUMNS =\n \"game_id, away_code, home_code, starts_at, expires_at, status, channel\";\n\nexport async function nextGamesForTeams(teams: TeamRef[], fromSeconds: number): Promise {\n if (!teams.length) return [];\n\n const results = await sqlite.batch(\n teams.map((team) => ({\n sql: `SELECT ${SELECT_COLUMNS} FROM wnba_games\n WHERE (away_code = ? OR home_code = ?) AND starts_at >= ?\n ORDER BY starts_at ASC\n LIMIT 1`,\n args: [team.code, team.code, fromSeconds],\n })),\n \"read\",\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.length) return 0;\n\n const ingestedAt = new Date().toISOString();\n const chunkSize = 50;\n let written = 0;\n\n for (let i = 0; i < rows.length; i += chunkSize) {\n const chunk = rows.slice(i, i + chunkSize);\n await sqlite.batch(\n chunk.map((row) => ({\n sql: `INSERT INTO wnba_games\n (game_id, away_code, home_code, starts_at, expires_at,\n status, channel, ingested_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(game_id) DO UPDATE SET\n away_code = excluded.away_code,\n home_code = excluded.home_code,\n starts_at = excluded.starts_at,\n expires_at = excluded.expires_at,\n status = excluded.status,\n channel = excluded.channel,\n ingested_at = excluded.ingested_at`,\n args: [\n row.game_id, row.away_code, row.home_code, row.starts_at, row.expires_at,\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 { games: number; firstStartsAt: number; lastExpiresAt: number; ingestedAt: string }[]\n> {\n const result = await sqlite.execute(`\n SELECT COUNT(*) AS games,\n MIN(starts_at) AS first_starts_at,\n MAX(expires_at) AS last_expires_at,\n MAX(ingested_at) AS ingested_at\n FROM wnba_games\n `);\n const row = result.rows[0];\n if (Number(row.games) === 0) return [];\n return [{\n games: Number(row.games),\n firstStartsAt: Number(row.first_starts_at),\n lastExpiresAt: Number(row.last_expires_at),\n ingestedAt: String(row.ingested_at),\n }];\n}\n",[],[185,345],"7d7826b5-a9bc-4309-a22c-bfa16daa9e59",["D",1788818616931],[198,199,200,201,202,203,204,205,206,207],[185],["D",1788818616931],["D",1789516253896],{"_11":12,"_142":76},{"_11":12,"_138":-5,"_75":76,"_30":74,"_139":140,"_141":24},{"_39":79,"_13":16,"_33":36,"_128":91,"_129":65,"_130":131,"_132":95,"_133":134,"_135":42,"_136":14,"_137":12},"ctx",{"_54":-5,"_164":393,"_394":395,"_396":397,"_398":24,"_399":24,"_400":24,"_401":162,"_402":-5,"_403":-7,"_404":-7,"_405":26,"_406":24,"_407":24,"_408":-5,"_409":24,"_410":24,"_411":24,"_412":-5},"ENV",{"_364":365,"_366":367,"_368":16,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

History · sleeper.ts