[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_149":150,"_151":152},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_86":-7,"_87":88,"_29":-7,"_89":-5,"_15":90,"_91":92,"_93":94,"_95":96,"_97":98,"_99":-5,"_100":-5,"_101":-5,"_102":38,"_103":104,"_105":38,"_106":-5,"_107":-5,"_108":109},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","momoney60","name","untitled-974","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":68,"_69":70,"_71":72,"_73":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","09994e88-173b-11f1-b08b-42dde27851f2","createdAt",["D",1772567775665],"updatedAt",["D",1775420268548],"main","projectId","0998c88c-173b-11f1-b08b-42dde27851f2","version",20,"forkedBranchId","forkedBranchVersion","lockfileKey","1775420269233-esm.town_v_momoney60_untitled-974@20-main","deletedAt",["D",1772567775665],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","019cb543-7927-777e-bc8a-6ac400a43302","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019cb543-7928-75b4-8e38-0cd9eadaa3a8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_85":81},"org",{"_11":12,"_79":-5,"_80":81,"_44":45,"_82":83,"_84":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQVJ1STNIZUpOTFFPaWIxR0lUb0tzZlVIMncifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":145,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_60":59,"_61":62,"_63":62,"_64":62,"_65":59,"_66":59,"_67":146,"_69":147,"_71":148,"_73":38},"tree",[140],"files",[140],"counts",{"_129":51,"_17":130,"_131":51,"_132":133,"_134":135},"contents",[110],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_20":111,"_13":112,"_113":114,"_115":-5,"_116":21,"_117":30,"_118":119,"_22":120,"_29":121,"_122":123,"_124":125,"_126":38,"_127":-5,"_87":128},"83d9a016-312c-11f1-96c9-42dde27851f2","main.ts","fileId","099d1b6c-173b-11f1-b08b-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1775420268548],19,"fileType","interval","content","import Parser from \"npm:rss-parser\";\nimport { createClient } from \"npm:@supabase/supabase-js\";\nimport { GoogleGenerativeAI } from \"npm:@google/generative-ai\";\n\nexport default async function (interval: Interval) {\n console.log(\"🚀 READONLY v9.2:\", new Date().toISOString());\n const startTime = Date.now();\n const TIME_LIMIT = 8.5 * 60 * 1000; // 8.5 min guard\n\n const supabase = createClient(process.env.SUPABASE_URL, process.env.SUPABASE_SECRET_KEY);\n const genAI = new GoogleGenerativeAI(process.env.GEMINI_API_KEY);\n const model = genAI.getGenerativeModel({ model: \"gemini-2.5-flash\" });\n const parser = new Parser({ timeout: 15000, headers: { \"User-Agent\": \"Mozilla/5.0 (compatible; ReadOnly/1.0; +https://readonly.news)\", Accept: \"application/rss+xml, application/xml, text/xml, */*\" } });\n const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n const elapsed = () => Math.round((Date.now() - startTime) / 1000);\n\n // ── URL builders ──\n const gnewsTopic = (t: string) => `https://news.google.com/rss/headlines/section/topic/${encodeURIComponent(t)}?hl=en-US&gl=US&ceid=US:en`;\n const gnewsSearch = (q: string) => `https://news.google.com/rss/search?q=${encodeURIComponent(q)}&hl=en-US&gl=US&ceid=US:en`;\n\n // ── Text helpers ──\n const normalizeTitle = (t: string) => (t || \"\").toLowerCase().replace(/['']/g, \"\").replace(/[^a-z0-9 ]/g, \" \").replace(/\\s+/g, \" \").trim();\n\n const jaccard = (a: string, b: string) => {\n const A = new Set(normalizeTitle(a).split(\" \").filter(Boolean));\n const B = new Set(normalizeTitle(b).split(\" \").filter(Boolean));\n if (!A.size || !B.size) return 0;\n let i = 0; for (const w of A) if (B.has(w)) i++;\n return i / (A.size + B.size - i);\n };\n\n const topicKeyFromTitle = (title: string) => {\n const stop = new Set([\"the\",\"a\",\"an\",\"and\",\"or\",\"to\",\"of\",\"in\",\"on\",\"for\",\"with\",\"as\",\"at\",\"by\",\"from\",\"into\",\"amid\",\"after\",\"before\",\"over\",\"up\",\"down\",\"new\",\"live\",\"update\",\"updates\",\"breaking\",\"says\",\"say\",\"report\",\"reports\",\"reported\"]);\n return normalizeTitle(title).split(\" \").filter(t => t && t.length > 2 && !stop.has(t)).slice(0, 8).join(\"-\");\n };\n\n const makeDedupeKey = (f: any) => {\n const ch = (f?.ch || \"\").toString().trim().toLowerCase();\n const title = normalizeTitle((f?.title || \"\").toString());\n const src = (Array.isArray(f?.src) ? f.src : []).map((s: any) => (s || \"\").toString().trim().toLowerCase()).filter(Boolean).sort().join(\",\");\n return `${ch}|${title}|${src}`.slice(0, 900);\n };\n\n // ── v9.1 resilience helpers ──\n function safeParseJSON(raw: string): any[] {\n let c = raw.replace(/```json/gi, \"\").replace(/```/g, \"\").trim();\n c = c.replace(/,\\s*([}\\]])/g, \"$1\");\n try { const r = JSON.parse(c); return Array.isArray(r) ? r : []; } catch {}\n const m = c.match(/\\[[\\s\\S]*\\]/);\n if (m) { try { const r = JSON.parse(m[0]); return Array.isArray(r) ? r : []; } catch {} }\n try { let f = c; if (!f.endsWith(\"]\")) f += '\"}]'; const r = JSON.parse(f); return Array.isArray(r) ? r : []; } catch {}\n return [];\n }\n\n function validateFact(f: any): any | null {\n if (!f || typeof f !== \"object\") return null;\n const title = (f.title || \"\").toString().trim();\n if (!title || title.length < 10) return null;\n return {\n ...f,\n ch: (f.ch || \"\").toString().trim(),\n st: (f.st === \"Confirmed\" || f.st === \"Developing\") ? f.st : \"Developing\",\n co: Math.min(99, Math.max(50, parseInt(f.co) || 75)),\n ht: Math.min(99, Math.max(40, parseInt(f.ht) || 70)),\n title,\n facts: Array.isArray(f.facts) ? f.facts.map((x: any) => (x || \"\").toString()).filter(Boolean).slice(0, 7) : [],\n ctx: (f.ctx || \"\").toString().slice(0, 500),\n src: sanitizeSrc(f.src),\n links: sanitizeLinks(f.links),\n upd: f.upd || \"Just now\",\n pub: f.pub || \"Just now\",\n clog: Array.isArray(f.clog) ? f.clog : [],\n agent: (f.agent || \"\").toString().slice(0, 40),\n };\n }\n\n function sanitizeSrc(src: any[]): string[] {\n if (!Array.isArray(src)) return [\"Unknown\"];\n const cleaned = src.map((s: any) => (s || \"\").toString().replace(/\\s*\\(http.*$/, \"\").replace(/\\s*\\[.*$/, \"\").replace(/^\\[.*?\\]\\s*/, \"\").trim().slice(0, 30)).filter(Boolean);\n return cleaned.length > 0 ? cleaned : [\"Unknown\"];\n }\n\n function sanitizeLinks(links: any[]): string[] {\n if (!Array.isArray(links)) return [];\n return links.map((l: any) => { const u = (l || \"\").toString().trim(); return (u.startsWith(\"http://\") || u.startsWith(\"https://\")) ? u : \"\"; }).filter(Boolean);\n }\n\n function isMultiStoryTitle(title: string): boolean {\n if (title.includes(\";\") && title.length > 80) return true;\n if (title.split(/[;]|,\\s*and\\s+/i).length >= 3 && title.length > 90) return true;\n return false;\n }\n\n async function upsertWithRetry(rows: any[], retries = 2): Promise {\n for (let a = 0; a <= retries; a++) {\n try {\n const { error } = await supabase.from(\"Facts\").upsert(rows, { onConflict: \"dedupe_key\", ignoreDuplicates: true });\n if (error) throw error;\n return true;\n } catch (e: any) { if (a < retries) { await sleep(500); continue; } throw e; }\n }\n return false;\n }\n\n // ── Phase 0: Load existing titles ──\n console.log(\"🔍 Phase 0: Loading existing titles...\");\n let existingTitles = new Set();\n try {\n const { data } = await supabase.from(\"Facts\").select(\"title\").order(\"id\", { ascending: false }).limit(1200);\n if (data) existingTitles = new Set(data.map((r: any) => normalizeTitle(r.title)));\n console.log(` 📋 ${existingTitles.size} titles loaded`);\n } catch (e: any) { console.warn(` ⚠️ ${e?.message}`); }\n\n function isDuplicateTitle(t: string) {\n const n = normalizeTitle(t); if (!n) return false;\n if (existingTitles.has(n)) return true;\n const w = n.split(\" \").slice(0, 7).join(\" \");\n for (const e of existingTitles) { const e7 = e.split(\" \").slice(0, 7).join(\" \"); if (e.startsWith(w) || w.startsWith(e7)) return true; }\n return false;\n }\n\n function isSimilarToExisting(t: string): boolean {\n const nw = new Set(normalizeTitle(t).split(\" \").filter(Boolean));\n if (nw.size < 3) return false;\n for (const e of existingTitles) {\n const ew = new Set(e.split(\" \").filter(Boolean));\n let i = 0; for (const w of nw) if (ew.has(w)) i++;\n const u = nw.size + ew.size - i;\n if (u > 0 && i / u >= 0.42) return true;\n }\n return false;\n }\n\n // ── Phase 0b: Cleanup (keep 15 per channel) ──\n console.log(\"🧹 Cleaning...\");\n try {\n for (const ch of [\"world\",\"us\",\"politics\",\"business\",\"markets\",\"economy\",\"tech\",\"ai\",\"cyber\",\"science\",\"real-estate\",\"sports\",\"nhl\",\"climate\",\"bright\",\"live-event\"]) {\n const { data: old } = await supabase.from(\"Facts\").select(\"id\").eq(\"ch\", ch).order(\"id\", { ascending: false }).range(15, 9999);\n if (old?.length) {\n for (let i = 0; i < old.length; i += 100) await supabase.from(\"Facts\").delete().in(\"id\", old.slice(i, i + 100).map((r: any) => r.id));\n console.log(` 🧹 ${ch}: ${old.length}`);\n }\n }\n } catch (e: any) { console.warn(` ⚠️ ${e?.message}`); }\n\n // ══════════════════════════════════════════════\n // FEEDS — comprehensive source lists restored\n // Dropped: law, energy, health\n // Boosted: real-estate\n // ══════════════════════════════════════════════\n const topIngestOnly = { ch: \"_top_ingest\", sources: [\n { url: gnewsTopic(\"WORLD\"), name: \"Google News\" },\n { url: \"https://feeds.bbci.co.uk/news/rss.xml\", name: \"BBC\" },\n { url: \"https://feeds.feedburner.com/reuters/topNews\", name: \"Reuters\" },\n ]};\n\n const stapleFeeds = [\n // ── WORLD (7 sources) ──\n { ch: \"world\", sources: [\n { url: \"http://feeds.bbci.co.uk/news/world/rss.xml\", name: \"BBC\" },\n { url: \"https://www.aljazeera.com/xml/rss/all.xml\", name: \"Al Jazeera\" },\n { url: \"https://www.theguardian.com/world/rss\", name: \"The Guardian\" },\n { url: \"https://rss.nytimes.com/services/xml/rss/nyt/World.xml\", name: \"NYT\" },\n { url: \"https://www.france24.com/en/rss\", name: \"France 24\" },\n { url: \"https://rss.dw.com/rdf/rss-en-all\", name: \"DW\" },\n { url: gnewsTopic(\"WORLD\"), name: \"Google News\" },\n ]},\n\n // ── US (6 sources) ──\n { ch: \"us\", sources: [\n { url: \"https://feeds.npr.org/1001/rss.xml\", name: \"NPR\" },\n { url: \"https://rss.nytimes.com/services/xml/rss/nyt/US.xml\", name: \"NYT\" },\n { url: \"https://feeds.bbci.co.uk/news/world/us_and_canada/rss.xml\", name: \"BBC\" },\n { url: \"https://www.theguardian.com/world/usa/rss\", name: \"The Guardian\" },\n { url: gnewsTopic(\"NATION\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:apnews.com (U.S. OR US OR Washington) when:3d\"), name: \"Google News\" },\n ]},\n\n // ── POLITICS (3 sources) ──\n { ch: \"politics\", sources: [\n { url: gnewsSearch('(election OR congress OR senate OR \"White House\" OR parliament OR \"Supreme Court\") when:2d'), name: \"Google News\" },\n { url: gnewsSearch(\"site:apnews.com hub/politics when:7d\"), name: \"Google News\" },\n { url: \"https://feeds.bbci.co.uk/news/politics/rss.xml\", name: \"BBC\" },\n ]},\n\n // ── BUSINESS (8 sources) ──\n { ch: \"business\", sources: [\n { url: \"https://feeds.bbci.co.uk/news/business/rss.xml\", name: \"BBC\" },\n { url: \"https://finance.yahoo.com/news/rssindex\", name: \"Yahoo Finance\" },\n { url: \"https://rss.nytimes.com/services/xml/rss/nyt/Business.xml\", name: \"NYT\" },\n { url: \"https://feeds.feedburner.com/reuters/businessNews\", name: \"Reuters\" },\n { url: gnewsTopic(\"BUSINESS\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:ft.com (earnings OR merger OR acquisition) when:7d\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:wsj.com (earnings OR deal OR merger) when:7d\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:bloomberg.com (earnings OR deal OR merger) when:7d\"), name: \"Google News\" },\n ]},\n\n // ── MARKETS (4 sources) ──\n { ch: \"markets\", sources: [\n { url: \"https://finance.yahoo.com/news/rssindex\", name: \"Yahoo Finance\" },\n { url: \"https://feeds.bbci.co.uk/news/business/rss.xml\", name: \"BBC\" },\n { url: \"https://feeds.feedburner.com/reuters/businessNews\", name: \"Reuters\" },\n { url: gnewsSearch('(stocks OR bonds OR yields OR \"Fed\" OR inflation OR CPI OR payrolls) when:2d'), name: \"Google News\" },\n ]},\n\n // ── ECONOMY (2 sources) ──\n { ch: \"economy\", sources: [\n { url: gnewsSearch('(\"Federal Reserve\" OR ECB OR BOE OR inflation OR GDP OR unemployment OR payrolls) when:7d'), name: \"Google News\" },\n { url: \"https://feeds.bbci.co.uk/news/business/economy/rss.xml\", name: \"BBC\" },\n ]},\n\n // ── TECH (5 sources) ──\n { ch: \"tech\", sources: [\n { url: \"https://techcrunch.com/feed/\", name: \"TechCrunch\" },\n { url: \"https://feeds.arstechnica.com/arstechnica/index\", name: \"Ars Technica\" },\n { url: \"https://www.theverge.com/rss/index.xml\", name: \"The Verge\" },\n { url: \"https://www.wired.com/feed/rss\", name: \"WIRED\" },\n { url: gnewsTopic(\"TECHNOLOGY\"), name: \"Google News\" },\n ]},\n\n // ── AI (2 sources) ──\n { ch: \"ai\", sources: [\n { url: gnewsSearch('(AI OR \"artificial intelligence\" OR model) (OpenAI OR Google OR Anthropic OR Microsoft) when:7d'), name: \"Google News\" },\n { url: gnewsSearch(\"site:arxiv.org (LLM OR transformer) when:14d\"), name: \"Google News\" },\n ]},\n\n // ── CYBER (3 sources) ──\n { ch: \"cyber\", sources: [\n { url: gnewsSearch(\"(ransomware OR breach OR hacked OR cybersecurity) when:7d\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:bleepingcomputer.com (breach OR ransomware) when:14d\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:krebsonsecurity.com when:60d\"), name: \"Google News\" },\n ]},\n\n // ── SCIENCE (4 sources) ──\n { ch: \"science\", sources: [\n { url: \"https://www.nasa.gov/rss/dyn/breaking_news.rss\", name: \"NASA\" },\n { url: \"https://www.sciencedaily.com/rss/all.xml\", name: \"ScienceDaily\" },\n { url: \"https://phys.org/rss-feed/\", name: \"Phys.org\" },\n { url: gnewsTopic(\"SCIENCE\"), name: \"Google News\" },\n ]},\n\n // ── REAL ESTATE (8 sources — BOOSTED) ──\n { ch: \"real-estate\", sources: [\n { url: gnewsSearch('(housing OR \"mortgage rates\" OR rents OR \"commercial real estate\" OR CRE) when:14d'), name: \"Google News\" },\n { url: gnewsSearch(\"site:bisnow.com when:30d\"), name: \"Google News\" },\n { url: gnewsSearch(\"site:therealdeal.com when:30d\"), name: \"Google News\" },\n { url: gnewsSearch('(multifamily OR apartment OR \"cap rate\" OR REIT OR \"rent growth\") when:14d'), name: \"Google News\" },\n { url: gnewsSearch('(\"housing starts\" OR \"building permits\" OR \"Case-Shiller\" OR \"home sales\") when:14d'), name: \"Google News\" },\n { url: gnewsSearch('site:globest.com (multifamily OR office OR industrial OR retail) when:30d'), name: \"Google News\" },\n { url: gnewsSearch('(\"bridge loan\" OR \"loan maturity\" OR \"distressed\" OR foreclosure) commercial when:30d'), name: \"Google News\" },\n { url: gnewsSearch('(CBRE OR JLL OR Cushman OR \"Marcus Millichap\" OR Newmark) real estate when:14d'), name: \"Google News\" },\n ]},\n\n // ── SPORTS (4 sources) ──\n { ch: \"sports\", sources: [\n { url: \"https://www.espn.com/espn/rss/nfl/news\", name: \"ESPN\" },\n { url: \"https://feeds.bbci.co.uk/sport/rss.xml\", name: \"BBC\" },\n { url: \"https://www.sportsnet.ca/feed\", name: \"Sportsnet\" },\n { url: gnewsTopic(\"SPORTS\"), name: \"Google News\" },\n ]},\n\n // ── NHL (5 sources — trimmed but solid) ──\n { ch: \"nhl\", sources: [\n { url: \"https://sports.yahoo.com/nhl/rss/\", name: \"Yahoo NHL\" },\n { url: \"https://www.sportsnet.ca/hockey/nhl/feed\", name: \"Sportsnet\" },\n { url: \"https://thehockeywriters.com/feed/\", name: \"Hockey Writers\" },\n { url: gnewsSearch('(nhl trade OR injury OR playoff OR waivers OR \"cap hit\" OR extension) when:3d'), name: \"Google News\" },\n { url: gnewsSearch('(\"Maple Leafs\" OR \"Rangers\" OR \"Canadiens\" OR \"Oilers\" OR \"Avalanche\" OR \"Golden Knights\" OR \"Stars\") nhl when:3d'), name: \"Google News\" },\n ]},\n\n // ── CLIMATE (4 sources) ──\n { ch: \"climate\", sources: [\n { url: \"https://rss.nytimes.com/services/xml/rss/nyt/Climate.xml\", name: \"NYT\" },\n { url: \"https://www.theguardian.com/environment/rss\", name: \"The Guardian\" },\n { url: \"https://feeds.bbci.co.uk/news/science_and_environment/rss.xml\", name: \"BBC\" },\n { url: gnewsSearch(\"(climate OR wildfire OR drought OR flood OR heatwave) when:7d\"), name: \"Google News\" },\n ]},\n\n // ── BRIGHT SIDE (5 sources) ──\n { ch: \"bright\", sources: [\n { url: \"https://www.goodnewsnetwork.org/feed/\", name: \"Good News Network\" },\n { url: \"https://www.positive.news/feed/\", name: \"Positive News\" },\n { url: gnewsSearch('(breakthrough OR discovery OR rescued OR \"conservation success\") when:30d'), name: \"Google News\" },\n { url: \"https://feeds.bbci.co.uk/news/rss.xml\", name: \"BBC\" },\n { url: \"https://rss.nytimes.com/services/xml/rss/nyt/Science.xml\", name: \"NYT\" },\n ]},\n ];\n\n // ── Phase 1: Ingest ──\n console.log(\"📡 Phase 1: Ingesting...\");\n const channelHeadlines: Record = {};\n let globalHeadlineDump = \"\";\n let totalIngested = 0;\n const allFeedConfigs = [topIngestOnly, ...stapleFeeds];\n\n for (const channel of allFeedConfigs) {\n channelHeadlines[channel.ch] = [];\n for (const src of channel.sources) {\n try {\n const feed = await parser.parseURL(src.url);\n const pull = channel.ch === \"nhl\" ? 10 : channel.ch === \"_top_ingest\" ? 10 : 7;\n for (const item of (feed.items || []).slice(0, pull)) {\n const entry = {\n title: item.title || \"Untitled\",\n snippet: (item.contentSnippet || item.content || \"\").toString().slice(0, 300),\n link: (item as any).link || \"\",\n pubDate: (item as any).pubDate || (item as any).isoDate || \"\",\n source: src.name,\n };\n channelHeadlines[channel.ch].push(entry);\n globalHeadlineDump += `[${src.name}] ${entry.title}\\n`;\n totalIngested++;\n }\n } catch (e: any) { console.warn(` ⚠️ ${src.name}: ${(e?.message || \"\").toString().slice(0, 60)}`); }\n }\n console.log(` 📊 ${channel.ch}: ${channelHeadlines[channel.ch].length}`);\n }\n\n // ── Cluster ──\n function clusterHeadlines(headlines: any[], threshold = 0.46) {\n const clusters: any[] = [];\n for (const h of headlines) {\n let placed = false;\n for (const c of clusters) { if (jaccard(h.title, c.rep.title) >= threshold) { c.items.push(h); placed = true; break; } }\n if (!placed) clusters.push({ rep: h, items: [h] });\n }\n return clusters;\n }\n\n // ── Quality rules ──\n const QUALITY_RULES = `\nSTRICT RULES:\n1. ONE STORY PER ITEM. Never combine unrelated events. Titles with semicolons joining different subjects = WRONG.\n2. Headlines MUST include specific names, numbers, dates, or places. No vague headlines.\n3. Each facts bullet must contain a verifiable claim with specifics. No filler.\n4. ctx must provide BACKGROUND the headline does not contain. Never restate the headline.\n5. \"src\" = short publisher names only (max 20 chars). Never put URLs in src.\n6. \"links\" = one URL per source, same order as \"src\". Extract from evidence URLs.\n7. co and ht MUST be integer numbers, not strings.\n8. 1 source: st=\"Developing\", co 70-85. 2+ sources: st=\"Confirmed\", co 90-99.\n`;\n\n // ── Phase 2: Analyze + insert ──\n console.log(\"🧠 Phase 2: Analyzing...\");\n const allFacts: any[] = [];\n\n for (const channel of stapleFeeds) {\n if (Date.now() - startTime > TIME_LIMIT) {\n console.log(`⏰ Time guard at ${elapsed()}s — skipping ${channel.ch}`);\n continue;\n }\n\n const headlines = channelHeadlines[channel.ch];\n if (!headlines?.length) { console.log(`⚠️ ${channel.ch}: no headlines`); continue; }\n\n const clusters = clusterHeadlines(headlines, channel.ch === \"nhl\" ? 0.42 : 0.46);\n const sortedClusters = clusters\n .map(c => ({ ...c, sourceCount: [...new Set(c.items.map((x: any) => x.source))].length, sources: [...new Set(c.items.map((x: any) => x.source))] }))\n .sort((a, b) => b.sourceCount - a.sourceCount);\n\n const evidenceBlock = sortedClusters.slice(0, channel.ch === \"nhl\" ? 30 : 22).map((c, i) => {\n const lines = c.items.slice(0, 4).map((h: any) => {\n const snip = (h.snippet || \"\").replace(/\\s+/g, \" \").slice(0, 200);\n return `- [${h.source}] ${h.title}${h.link ? ` URL: ${h.link}` : \"\"}\\n ${snip}`;\n }).join(\"\\n\");\n return `CLUSTER ${i + 1} (${c.sources.join(\", \")}):\\n${lines}`;\n }).join(\"\\n\\n\");\n\n const sourceNames = [...new Set(headlines.map(h => h.source))];\n const itemCount = channel.ch === \"nhl\" ? 8 : channel.ch === \"real-estate\" ? 6 : 5;\n\n let channelInstr = \"\";\n if (channel.ch === \"bright\") channelInstr = \"You are ReadOnly-BRIGHT. Find genuinely uplifting stories. No politics. No doom with silver lining.\";\n else if (channel.ch === \"nhl\") channelInstr = \"You are ReadOnly-NHL. Hockey intelligence. Label rumors explicitly.\";\n else if (channel.ch === \"real-estate\") channelInstr = \"You are ReadOnly-REALESTATE. Cover commercial real estate, multifamily, housing data, REIT performance, capital markets, and CRE transactions. Prioritize deal-level specifics: prices, cap rates, unit counts, square footage, lender names.\";\n else channelInstr = `You are ReadOnly. Channel: ${channel.ch.toUpperCase()}. Sources: ${sourceNames.join(\", \")}.`;\n\n const prompt = `${channelInstr}\nStay grounded in evidence. Do not invent details.\n\nEVIDENCE (clustered headlines with sources and URLs):\n${evidenceBlock}\n\nAVOID similar to: ${[...existingTitles].slice(0, 150).join(\" | \").slice(0, 800)}\n\nReturn ONLY a JSON array of exactly ${itemCount} objects.\nSchema: {\"ch\":\"${channel.ch}\",\"st\":\"Confirmed\",\"co\":95,\"ht\":90,\"title\":\"Specific headline\",\"facts\":[\"Fact 1\",\"Fact 2\",\"Fact 3\"],\"ctx\":\"Background.\",\"src\":[\"Publisher1\"],\"links\":[\"https://url-1\"],\"upd\":\"Just now\",\"pub\":\"Just now\",\"clog\":[],\"agent\":\"ReadOnly-${channel.ch.toUpperCase()}\"}\n\n${QUALITY_RULES}\nRAW JSON only. No markdown. No backticks.`;\n\n try {\n const result = await model.generateContent(prompt);\n const facts = safeParseJSON(result.response.text());\n\n if (facts.length === 0) { console.log(`⚠️ ${channel.ch}: unparseable JSON`); continue; }\n\n const now = Date.now();\n const rows: any[] = [];\n\n for (const rawFact of facts) {\n const fact = validateFact(rawFact);\n if (!fact) continue;\n fact.ch = channel.ch;\n\n if (isMultiStoryTitle(fact.title)) { console.log(` 🚫 REJECTED: \"${fact.title.slice(0, 80)}\"`); continue; }\n if (isDuplicateTitle(fact.title) || isSimilarToExisting(fact.title)) { console.log(` 🔁 SKIPPED: \"${fact.title.slice(0, 80)}\"`); continue; }\n\n fact.id = `f_${channel.ch}_${now}_${Math.random().toString(36).slice(2, 6)}`;\n fact.dedupe_key = makeDedupeKey(fact);\n fact.created_at = new Date().toISOString();\n rows.push(fact);\n existingTitles.add(normalizeTitle(fact.title));\n }\n\n if (!rows.length) { console.log(`⏭️ ${channel.ch}: nothing new`); }\n else {\n await upsertWithRetry(rows);\n allFacts.push(...rows);\n console.log(`✅ ${channel.ch}: ${rows.length} new (${elapsed()}s)`);\n }\n } catch (e: any) { console.error(`❌ ${channel.ch}: ${(e?.message || \"\").slice(0, 120)}`); }\n\n await sleep(300);\n }\n\n // ── Phase 3: Live events ──\n if (Date.now() - startTime < 9 * 60 * 1000) {\n console.log(\"🔴 Phase 3: Live events...\");\n try {\n const liveResult = await model.generateContent(`You are ReadOnly-LIVE. Identify dominant BREAKING events covered by 3+ sources. Return [] if none. Max 2. ONE event per item.\n\nHEADLINES:\\n${globalHeadlineDump.slice(0, 6000)}\n\nSchema: {\"ch\":\"live-event\",\"live_tag\":\"kebab-id\",\"st\":\"Confirmed\",\"co\":95,\"ht\":99,\"title\":\"Specific headline\",\"facts\":[\"F1\",\"F2\",\"F3\"],\"ctx\":\"Context.\",\"src\":[\"S1\",\"S2\",\"S3\"],\"links\":[\"url1\",\"url2\",\"url3\"],\"upd\":\"Just now\",\"pub\":\"Just now\",\"clog\":[],\"agent\":\"ReadOnly-LIVE\"}\n${QUALITY_RULES}\nRAW JSON only.`);\n\n const liveEvents = safeParseJSON(liveResult.response.text());\n const now = Date.now();\n const rows: any[] = [];\n for (const ev of liveEvents) {\n const fact = validateFact(ev);\n if (!fact) continue;\n fact.ch = \"live-event\";\n if (isMultiStoryTitle(fact.title) || isDuplicateTitle(fact.title) || isSimilarToExisting(fact.title)) continue;\n fact.id = `f_live_${now}_${Math.random().toString(36).slice(2, 6)}`;\n fact.dedupe_key = makeDedupeKey(fact);\n fact.created_at = new Date().toISOString();\n rows.push(fact); existingTitles.add(normalizeTitle(fact.title));\n }\n if (rows.length) { await upsertWithRetry(rows); allFacts.push(...rows); console.log(`🔴 live: ${rows.length}`); }\n else console.log(\"🟢 No live events.\");\n } catch (e: any) { console.error(`❌ Live: ${(e?.message || \"\").slice(0, 100)}`); }\n }\n\n // ── Phase 4: Explore ──\n if (Date.now() - startTime < 9.5 * 60 * 1000) {\n console.log(\"🗺️ Phase 4: Top stories...\");\n try {\n const { data: pool } = await supabase.from(\"Facts\").select(\"*\").not(\"ch\", \"in\", '(\"bright\",\"live-event\")').order(\"ht\", { ascending: false }).limit(60);\n if (pool?.length) {\n const sorted = [...pool].sort((a: any, b: any) => (b.ht || 0) - (a.ht || 0) || (b.co || 0) - (a.co || 0));\n const seenT = new Set(), seenN = new Set(), picks: any[] = [], chC: Record = {};\n\n for (const f of sorted) {\n const k = topicKeyFromTitle(f.title), n = normalizeTitle(f.title);\n if (!k || seenT.has(k) || seenN.has(n)) continue;\n const ch = (f.ch || \"\").toString(); chC[ch] = chC[ch] || 0;\n if (chC[ch] >= 2) continue;\n seenT.add(k); seenN.add(n); chC[ch]++; picks.push(f);\n if (picks.length >= 6) break;\n }\n if (picks.length < 6) {\n for (const f of sorted) {\n const k = topicKeyFromTitle(f.title), n = normalizeTitle(f.title);\n if (!k || seenT.has(k) || seenN.has(n)) continue;\n seenT.add(k); seenN.add(n); picks.push(f);\n if (picks.length >= 6) break;\n }\n }\n\n const top = picks.slice(0, 6).map((f: any, i: number) => ({\n id: `explore_${Date.now()}_${i}`, rank: i + 1, fact_id: f.id, ch: f.ch,\n live_tag: f.live_tag || null, title: f.title, ht: f.ht, co: f.co, st: f.st,\n src: sanitizeSrc(f.src), links: sanitizeLinks(f.links || []),\n updated_at: new Date().toISOString(),\n }));\n await supabase.from(\"Explore\").delete().neq(\"id\", \"\");\n await supabase.from(\"Explore\").insert(top);\n console.log(`🗺️ Explore: ${top.length} ranked`);\n }\n } catch (e: any) { console.error(`❌ Explore: ${(e?.message || \"\").slice(0, 100)}`); }\n }\n\n console.log(`\\n✨ v9.2 DONE in ${elapsed()}s — ${totalIngested} headlines, ${allFacts.length} new facts.`);\n}","deleted","label",[112],"pulls",1,"forks","envVars",{"_136":138,"_139":51},"connections",{"_136":51,"_137":51},"count","unfilledCount",3,"emptyCount",{"_20":111,"_13":112,"_113":114,"_115":-5,"_116":21,"_117":30,"_118":119,"_22":141,"_29":121,"_122":123,"_124":125,"_126":38,"_127":-5,"_142":143,"_87":144},["D",1775420268548],"children",[],[112],["D",1772567775665],{"_11":12,"_85":81},{"_11":12,"_79":-5,"_80":81,"_44":45,"_82":83,"_84":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"ctx",{"_67":-5,"_107":182,"_183":184,"_185":186,"_187":38,"_188":38,"_189":38,"_190":119,"_191":-5,"_192":-7,"_193":-7,"_194":51,"_195":38,"_196":38,"_197":-5,"_198":38,"_199":38,"_200":38,"_201":-5},"ENV",{"_153":154,"_155":156,"_157":26,"_158":159,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181},"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"]

Branches1

Branches
1