[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_198":199,"_200":201},"routes/_app.x.$handle.$name",{"_104":103,"_37":49,"_112":94,"_32":113,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":63,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",4,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","a3f0ee82-f896-45b0-af7a-02e8d6934a49","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","cron-est.ts","latestPath","fileId","688d0762-9fea-11f1-a410-1607ee4eb77e","name","fileType","interval","content","/**\n * Daily 2:40 PM America/Toronto (DST-aware) — EST half of the year.\n *\n * Val Town runs cron expressions in UTC, and Toronto jumps between\n * UTC-5 (EST) and UTC-4 (EDT). To handle DST correctly we schedule TWO\n * cron jobs:\n * - this one at 19:40 UTC -> 14:40 EST (winter)\n * - cron-edt at 18:40 UTC -> 14:40 EDT (summer)\n *\n * Each one double-checks the current Toronto hour is 14 before running,\n * so exactly one of them ever fires for real on any given day.\n */\nimport { runSchedule, torontoHour } from \"./lib.ts\";\n\nconst CRON = \"40 19 * * *\"; // 19:40 UTC\n\nexport default async function cron() {\n if (torontoHour() !== 14) return; // safety guard so only the correct slot fires\n await runSchedule();\n}\n","createdAt",["D",1787596455033],"branchVersion","branchId","3b4a83a8-9434-44f5-b5e7-a7127b558263","id","180f623d-1ef3-45f9-8a53-412862ed8292","cbc-ai-news-alert",["D",1787596371751],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Daily CBC AI news email alert with dashboard","imageUrl","d2a7cd60-d259-4295-bcac-e35f8e3a6da0","pinnedFileId","6884ac48-9fea-11f1-a410-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03507-8fe6-731e-916a-115dc8cc0566","tursoName","180f623d1ef345f98a53412862ed8292","tursoHostname","180f623d1ef345f98a53412862ed8292-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789509672838],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_111":-5},"org",{"_104":103,"_105":106,"_107":-5,"_19":-5,"_108":109,"_110":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",24,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","carlos12","handle","displayName","carlos1","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":193,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":194,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":195,"_88":196,"_90":197,"_92":30},"tree",[176,177,178,179],"files",[176,177,178,179],"counts",{"_166":67,"_167":151,"_168":151,"_169":170,"_171":172},"contents",[134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":163,"_37":33,"_35":36,"_140":-5,"_45":46,"_44":14,"_142":63,"_42":164,"_13":67,"_38":39,"_40":41,"_29":30,"_146":-5,"_32":165},{"_47":156,"_37":157,"_35":158,"_140":-5,"_45":46,"_44":159,"_142":63,"_42":160,"_13":67,"_38":26,"_40":161,"_29":30,"_146":-5,"_32":162},{"_47":148,"_37":149,"_35":150,"_140":-5,"_45":46,"_44":151,"_142":30,"_42":152,"_13":67,"_38":153,"_40":154,"_29":30,"_146":-5,"_32":155},{"_47":138,"_37":139,"_35":61,"_140":-5,"_45":46,"_44":141,"_142":30,"_42":143,"_13":67,"_38":144,"_40":145,"_29":30,"_146":-5,"_32":147},"6f3d2fa0-7e8c-46e6-8327-5b9b95a69d73","main.ts","parentId",3,"latest",["D",1787596454976],"http","/**\n * Web dashboard.\n * GET / -> the dashboard UI\n * GET /api -> stats + recent matched articles (JSON)\n * POST /run -> manually trigger a check (fetch + store, no email)\n */\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { runDailyCheck, getStats, getRecentArticles, initDb } from \"./lib.ts\";\n\nexport default async function handler(req: Request): Promise {\n initDb();\n const url = new URL(req.url);\n\n if (url.pathname === \"/\" || url.pathname === \"\") {\n const html = await readFile(\"dashboard.html\");\n return new Response(html, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n }\n\n if (url.pathname === \"/api\") {\n return Response.json({\n stats: getStats(),\n articles: getRecentArticles(30),\n });\n }\n\n if (url.pathname === \"/run\" && req.method === \"POST\") {\n try {\n const result = await runDailyCheck();\n return Response.json(result);\n } catch (e) {\n return Response.json({ error: (e as Error).message }, { status: 500 });\n }\n }\n\n return new Response(\"Not found\", { status: 404 });\n}\n","label",[139],"26072ba9-4ab8-4669-982d-31e3093079bd","lib.ts","68713938-9fea-11f1-a410-1607ee4eb77e",1,["D",1787596454847],"script","/**\n * Shared core logic for the CBC AI News Alert.\n * - Fetches CBC RSS feeds (each feed isolated so one failure can't kill the job)\n * - Filters titles by AI keywords (\"AI\" matched as a whole word)\n * - Stores matched articles in project-scoped SQLite (URL = unique key)\n * - Builds and sends the daily summary email (Resend, free tier)\n */\n\nimport { SQLite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { XMLParser } from \"npm:fast-xml-parser@4\";\n\n// Project-scoped databases\nexport const DB = new SQLite(\"cbc_ai_news\");\n\n// Destination for alerts\nexport const TO_EMAIL = \"flashcodingcompany2@gmail.com\";\n\n// Selected CBC RSS feeds (technology + general news sections)\nexport const FEEDS = [\n \"https://www.cbc.ca/cmlink/rss-technology\",\n \"https://www.cbc.ca/cmlink/rss-topstories\",\n \"https://www.cbc.ca/cmlink/rss-canada\",\n \"https://www.cbc.ca/cmlink/rss-world\",\n];\n\nexport interface Article {\n title: string;\n url: string;\n published_at: string | null;\n}\n\n// Case-insensitive keyword test.\n// \"AI\" and \"LLM\" are matched as whole words so e.g. \"brain\", \"mail\" don't false-positive.\nconst KEYWORD_PATTERNS = [\n /\\bAI\\b/i,\n /artificial intelligence/i,\n /generative AI/i,\n /ChatGPT/i,\n /OpenAI/i,\n /Claude/i,\n /Gemini/i,\n /large language model/i,\n /\\bLLM\\b/i,\n];\n\nexport function matchesAi(title: string): boolean {\n return KEYWORD_PATTERNS.some((re) => re.test(title));\n}\n\nexport function initDb() {\n DB.execute(`CREATE TABLE IF NOT EXISTS articles (\n url TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n published_at TEXT,\n first_seen_at TEXT NOT NULL,\n emailed_at TEXT\n )`);\n DB.execute(`CREATE TABLE IF NOT EXISTS meta (\n key TEXT PRIMARY KEY,\n value TEXT\n )`);\n}\n\n// Fetch all feeds. Each feed is wrapped in its own try/catch so a single\n// failing feed is logged and skipped rather than aborting the whole run.\nexport async function fetchFeeds(): Promise<{ items: Article[]; errors: string[] }> {\n const parser = new XMLParser();\n const items: Article[] = [];\n const errors: string[] = [];\n\n for (const url of FEEDS) {\n try {\n const res = await fetch(url, { headers: { \"user-agent\": \"cbc-ai-alert\" } });\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n const doc = parser.parse(await res.text());\n const channelItems = doc?.rss?.channel?.item ?? [];\n const list = Array.isArray(channelItems) ? channelItems : [channelItems];\n for (const it of list) {\n const title = (it.title ?? \"\").toString().trim();\n const link = (it.link ?? \"\").toString().trim();\n const published = (it.pubDate ?? \"\") ? new Date(it.pubDate).toISOString() : null;\n if (title && link) items.push({ title, url: link, published_at: published });\n }\n } catch (e) {\n errors.push(`Feed ${url}: ${(e as Error).message}`);\n console.error(`[CBC AI] Feed failed - ${url}`, (e as Error).message);\n }\n }\n return { items, errors };\n}\n\n// --- SQLite helpers ------------------------------------------------\n\nfunction getMeta(key: string): string | null {\n const rows = DB.sql`SELECT value FROM meta WHERE key = ${key}`;\n return rows.length ? rows[0].value : null;\n}\n\nfunction setMeta(key: string, value: string) {\n DB.execute(\n `INSERT INTO meta (key, value) VALUES (?, ?)\n ON CONFLICT(key) DO UPDATE SET value = excluded.value`,\n [key, value],\n );\n}\n\nexport function saveArticle(a: Article): boolean {\n // INSERT OR IGNORE: URL is the unique key, so the same article is never stored twice.\n const r = DB.execute(\n `INSERT OR IGNORE INTO articles (url, title, published_at, first_seen_at)\n VALUES (?, ?, ?, ?)`,\n [a.url, a.title, a.published_at, new Date().toISOString()],\n );\n // changes count: 1 = newly inserted, 0 = already seen\n return (r as unknown as { changes: number }).changes === 1;\n}\n\nexport function getUnemailed(): Article[] {\n const rows = DB.sql`\n SELECT url, title, published_at FROM articles\n WHERE emailed_at IS NULL\n ORDER BY first_seen_at DESC\n `;\n return rows as unknown as Article[];\n}\n\nexport function markEmailed(urls: string[]) {\n for (const u of urls) {\n DB.execute(`UPDATE articles SET emailed_at = ? WHERE url = ?`, [new Date().toISOString(), u]);\n }\n}\n\nexport function getStats() {\n return {\n lastCheck: getMeta(\"last_check_iso\"),\n checkedCount: getMeta(\"last_checked_count\") ?? \"0\",\n aiFound: getMeta(\"last_ai_found\") ?? \"0\",\n totalChecked: getMeta(\"total_checked\") ?? \"0\",\n totalAi: getMeta(\"total_ai\") ?? \"0\",\n totalEmailed: getMeta(\"total_emailed\") ?? \"0\",\n lastErrors: getMeta(\"last_errors\") ?? \"[]\",\n };\n}\n\nexport function getRecentArticles(days = 30): Article[] {\n const since = new Date(Date.now() - days * 86400000).toISOString();\n const rows = DB.sql`\n SELECT url, title, published_at, first_seen_at, emailed_at\n FROM articles\n WHERE first_seen_at >= ${since}\n ORDER BY first_seen_at DESC\n LIMIT 200\n `;\n return rows as unknown as Article[];\n}\n\n// --- Run / schedule logic -----------------------------------------\n\n// One full check: fetch all feeds, store matched articles, update stats.\n// Does NOT email. Returns match counts.\nexport async function runDailyCheck() {\n initDb();\n const now = new Date().toISOString();\n const { items, errors } = await fetchFeeds();\n const matched = items.filter((a) => matchesAi(a.title));\n\n for (const a of matched) saveArticle(a);\n\n const totalChecked = Number(getMeta(\"total_checked\") ?? 0) + items.length;\n const totalAi = Number(getMeta(\"total_ai\") ?? 0) + matched.length;\n const totalEmailed = Number(getMeta(\"total_emailed\") ?? 0);\n\n setMeta(\"last_check_iso\", now);\n setMeta(\"last_checked_count\", String(items.length));\n setMeta(\"last_ai_found\", String(matched.length));\n setMeta(\"total_checked\", String(totalChecked));\n setMeta(\"total_ai\", String(totalAi));\n setMeta(\"total_emailed\", String(totalEmailed));\n setMeta(\"last_errors\", JSON.stringify(errors));\n\n return { checked: items.length, matched: matched.length, errors };\n}\n\n// Send an email via Resend (free tier). If RESEND_API_KEY is not set,\n// the message is logged instead of sent so the flow is safe to run.\nexport async function sendEmail(subject: string, textBody: string): Promise {\n const apiKey = Deno.env.get(\"RESEND_API_KEY\");\n if (!apiKey) {\n console.log(\"[CBC AI] No RESEND_API_KEY set - message NOT sent.\\n\" + textBody);\n return false;\n }\n const res = await fetch(\"https://api.resend.com/emails\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n from: \"CBC AI Alert \",\n to: TO_EMAIL,\n subject,\n text: textBody,\n }),\n });\n if (!res.ok) {\n console.error(\"[CBC AI] Email send failed\", res.status, await res.text());\n return false;\n }\n return true;\n}\n\nfunction formatArticleBlock(articles: Article[]): string {\n return articles\n .map((a, i) => {\n const date = a.published_at\n ? new Date(a.published_at).toLocaleString(\"en-CA\", { timeZone: \"America/Toronto\" })\n : \"unknown date\";\n return `${i + 1}. ${a.title}\\n Published: ${date}\\n Link: ${a.url}`;\n })\n .join(\"\\n\\n\");\n}\n\n// The full scheduled job: check + email anything never emailed before.\nexport async function runSchedule(): Promise<{ emailed: number }> {\n const { matched, errors } = await runDailyCheck();\n\n const unemailed = getUnemailed();\n if (unemailed.length === 0) {\n console.log(`[CBC AI] No new AI articles to email. matched=${matched} errors=${errors.length}.`);\n return { emailed: 0 };\n }\n\n const today = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"America/Toronto\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n })\n .format(new Date())\n .replace(/\\//g, \"-\");\n\n const subject = `CBC AI News Alert - ${today}`;\n const body = `CBC AI News Alert\\n\\nFound ${unemailed.length} new AI-related articles today:\\n\\n${formatArticleBlock(unemailed)}`;\n\n const ok = await sendEmail(subject, body);\n if (ok) {\n markEmailed(unemailed.map((a) => a.url));\n const totalEmailed = Number(getMeta(\"total_emailed\") ?? 0) + unemailed.length;\n setMeta(\"total_emailed\", String(totalEmailed));\n }\n\n console.log(\n `[CBC AI] Schedule: matched=${matched}, not-yet-emailed=${unemailed.length}, emailed=${ok ? unemailed.length : 0}, errors=${errors.length}`,\n );\n return { emailed: ok ? unemailed.length : 0 };\n}\n\n// Toronto hour (0-23) for DST-safe scheduling guards.\nexport function torontoHour(): number {\n const parts = new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"America/Toronto\",\n hour: \"2-digit\",\n hour12: false,\n }).formatToParts(new Date());\n return Number(parts.find((p) => p.type === \"hour\")?.value ?? 0) % 24;\n}\n",[149],"115ea726-144c-4e0b-885e-598e99f75ef1","dashboard.html","687a6184-9fea-11f1-a410-1607ee4eb77e",2,["D",1787596454911],"\n\n\n\n\nCBC AI News Alert\n\n\n\n

🗞️ CBC AI News Alert

–

Last check

–

Articles checked (last run)

–

AI articles found (last run)

–

Total checked

–

Total AI articles

\n\n \n

\n \n\n

Matched AI articles (last 30 days)

Loading…

\n\n\n\n\n",[157],"50ff3a07-0056-4ae3-a59a-63a878bca407",["D",1787596455033],[33],"pulls","branches","forks","envVars",{"_173":67,"_175":67},"connections",{"_173":67,"_174":67},"count","unfilledCount","emptyCount",{"_47":163,"_37":33,"_35":36,"_140":-5,"_45":46,"_44":14,"_142":63,"_42":190,"_13":67,"_38":39,"_40":41,"_29":30,"_146":-5,"_181":191,"_32":192},{"_47":156,"_37":157,"_35":158,"_140":-5,"_45":46,"_44":159,"_142":63,"_42":187,"_13":67,"_38":26,"_40":161,"_29":30,"_146":-5,"_181":188,"_32":189},{"_47":148,"_37":149,"_35":150,"_140":-5,"_45":46,"_44":151,"_142":30,"_42":184,"_13":67,"_38":153,"_40":154,"_29":30,"_146":-5,"_181":185,"_32":186},{"_47":138,"_37":139,"_35":61,"_140":-5,"_45":46,"_44":141,"_142":30,"_42":180,"_13":67,"_38":144,"_40":145,"_29":30,"_146":-5,"_181":182,"_32":183},["D",1787596454976],"children",[],[139],["D",1787596454847],[],[149],["D",1787596454911],[],[157],["D",1787596455033],[],[33],["D",1787596371751],["D",1789509672838],{"_104":103,"_111":-5},{"_104":103,"_105":106,"_107":-5,"_19":-5,"_108":109,"_110":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_131":231,"_232":233,"_234":235,"_236":30,"_237":30,"_238":30,"_239":63,"_240":-5,"_241":-7,"_242":-7,"_243":67,"_244":30,"_245":30,"_246":-5,"_247":30,"_248":30,"_249":30,"_250":-5},"ENV",{"_202":203,"_204":205,"_206":94,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230},"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 · v4