<!\\[CDATA\\[([^\\]]+)\\]\\]><\\/title>/) ||\n item.match(/<title>([^<]+)<\\/title>/);\n const linkMatch = item.match(/<link>([^<]+)<\\/link>/);\n const sourceMatch = item.match(/<source[^>]*><!\\[CDATA\\[([^\\]]+)\\]\\]><\\/source>/) ||\n item.match(/<source[^>]*>([^<]+)<\\/source>/);\n const pubDateMatch = item.match(/<pubDate>([^<]+)<\\/pubDate>/);\n\n if (titleMatch && linkMatch) {\n const pubDate = pubDateMatch\n ? Math.floor(new Date(pubDateMatch[1]).getTime() / 1000)\n : Math.floor(Date.now() / 1000);\n articles.push({\n title: titleMatch[1].trim(),\n url: linkMatch[1].trim(),\n source: sourceMatch ? sourceMatch[1].trim() : \"Google News\",\n pubDate,\n });\n }\n }\n return articles;\n } catch (_e) {\n return [];\n }\n}\n\nasync function fetchFromNewsApi(brandName: string): Promise<ArticleCandidate[]> {\n const newsApiKey = Deno.env.get(\"NEWS_API_KEY\");\n if (!newsApiKey) return [];\n\n try {\n const url =\n `https://newsapi.org/v2/everything?q=${encodeURIComponent(brandName)}&language=en&sortBy=publishedAt&pageSize=20&apiKey=${newsApiKey}`;\n const resp = await fetch(url, {\n headers: { \"User-Agent\": \"PRMonitor/1.0\" },\n });\n if (!resp.ok) return [];\n const data = await resp.json();\n\n if (!data.articles || !Array.isArray(data.articles)) return [];\n\n return data.articles.map((a: {\n title: string;\n url: string;\n source?: { name?: string };\n publishedAt?: string;\n }) => ({\n title: a.title || \"Untitled\",\n url: a.url || \"\",\n source: a.source?.name || \"NewsAPI\",\n pubDate: a.publishedAt\n ? Math.floor(new Date(a.publishedAt).getTime() / 1000)\n : Math.floor(Date.now() / 1000),\n })).filter((a: ArticleCandidate) => a.url);\n } catch (_e) {\n return [];\n }\n}\n\nasync function getSentiment(title: string): Promise<{ sentiment: string; score: number }> {\n // Val.town's OpenAI proxy - correct endpoint\n const apiKey = Deno.env.get(\"valtown\") || Deno.env.get(\"VALTOWN_API_KEY\");\n try {\n const aiResp = await fetch(\n \"https://std-openaiproxy.web.val.run/v1/chat/completions\",\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"system\",\n content:\n 'Classify the sentiment of this news headline as exactly one word: positive, neutral, or negative. Then give a score from -1.0 to 1.0. Respond as JSON: {\"sentiment\": \"...\", \"score\": 0.0}',\n },\n { role: \"user\", content: title },\n ],\n max_tokens: 50,\n }),\n },\n );\n if (aiResp.ok) {\n const aiData = await aiResp.json();\n const content = aiData.choices?.[0]?.message?.content || \"{}\";\n const parsed = JSON.parse(content);\n const sentiment = parsed.sentiment || \"neutral\";\n const score = parsed.score || 0.0;\n if ([\"positive\", \"neutral\", \"negative\"].includes(sentiment)) {\n return { sentiment, score };\n }\n }\n } catch (_e) {\n // Fall through to default\n }\n return { sentiment: \"neutral\", score: 0.0 };\n}\n\nasync function collectArticles(brandId: number): Promise<number> {\n const brandRows = await sqlite.execute({\n sql: `SELECT name FROM brands WHERE id = ?`,\n args: [brandId],\n });\n if (!brandRows.rows.length) return 0;\n const brandName = brandRows.rows[0][0] as string;\n\n // Fetch from both sources in parallel\n const [googleArticles, newsApiArticles] = await Promise.all([\n fetchFromGoogleNews(brandName),\n fetchFromNewsApi(brandName),\n ]);\n\n // Deduplicate by URL\n const seen = new Set<string>();\n const allArticles: ArticleCandidate[] = [];\n for (const article of [...googleArticles, ...newsApiArticles]) {\n if (article.url && !seen.has(article.url)) {\n seen.add(article.url);\n allArticles.push(article);\n }\n }\n\n let collected = 0;\n const today = new Date().toISOString().split(\"T\")[0];\n let posCount = 0, neuCount = 0, negCount = 0;\n\n for (const article of allArticles.slice(0, 20)) {\n const { sentiment, score } = await getSentiment(article.title);\n\n try {\n const insertResult = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO articles (brand_id, title, url, source_name, published_at, sentiment, sentiment_score) VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [brandId, article.title, article.url, article.source, article.pubDate, sentiment, score],\n });\n if (insertResult.rowsAffected > 0) {\n collected++;\n if (sentiment === \"positive\") posCount++;\n else if (sentiment === \"negative\") negCount++;\n else neuCount++;\n }\n } catch (_e) {\n // Skip on error\n }\n }\n\n // Update daily metrics\n if (collected > 0) {\n await sqlite.execute({\n sql: `INSERT INTO daily_metrics (brand_id, date, article_count, positive_count, neutral_count, negative_count)\n VALUES (?, ?, ?, ?, ?, ?)\n ON CONFLICT(brand_id, date) DO UPDATE SET\n article_count = article_count + excluded.article_count,\n positive_count = positive_count + excluded.positive_count,\n neutral_count = neutral_count + excluded.neutral_count,\n negative_count = negative_count + excluded.negative_count`,\n args: [brandId, today, collected, posCount, neuCount, negCount],\n });\n }\n\n return collected;\n}\n\nexport default async function handler(req: Request): Promise<Response> {\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n // GET /api/brands\n if (req.method === \"GET\" && path === \"/api/brands\") {\n const rows = await sqlite.execute(\n `SELECT b.id, b.name, b.created_at, COUNT(a.id) as article_count\n FROM brands b LEFT JOIN articles a ON b.id = a.brand_id\n GROUP BY b.id ORDER BY b.name`,\n );\n const brands = rows.rows.map((r) => ({\n id: r[0],\n name: r[1],\n created_at: r[2],\n article_count: r[3],\n }));\n return jsonResponse(brands);\n }\n\n // POST /api/brands\n if (req.method === \"POST\" && path === \"/api/brands\") {\n const body = await req.json();\n if (!body.name) return jsonResponse({ error: \"name required\" }, 400);\n try {\n const existing = await sqlite.execute({\n sql: `SELECT id, name FROM brands WHERE name = ?`,\n args: [body.name],\n });\n if (existing.rows.length > 0) {\n return jsonResponse({ error: \"Brand already exists\" }, 409);\n }\n await sqlite.execute({\n sql: `INSERT INTO brands (name) VALUES (?)`,\n args: [body.name],\n });\n const newBrand = await sqlite.execute({\n sql: `SELECT id, name FROM brands WHERE name = ?`,\n args: [body.name],\n });\n return jsonResponse({ id: newBrand.rows[0][0], name: newBrand.rows[0][1] }, 201);\n } catch (e) {\n const msg = e instanceof Error ? e.message : String(e);\n if (msg.includes(\"UNIQUE\") || msg.includes(\"unique\")) {\n return jsonResponse({ error: \"Brand already exists\" }, 409);\n }\n return jsonResponse({ error: msg }, 500);\n }\n }\n\n // DELETE /api/brands/:id\n const brandDeleteMatch = path.match(/^\\/api\\/brands\\/(\\d+)$/);\n if (req.method === \"DELETE\" && brandDeleteMatch) {\n const id = parseInt(brandDeleteMatch[1]);\n await sqlite.execute({ sql: `DELETE FROM articles WHERE brand_id = ?`, args: [id] });\n await sqlite.execute({ sql: `DELETE FROM daily_metrics WHERE brand_id = ?`, args: [id] });\n await sqlite.execute({ sql: `DELETE FROM brands WHERE id = ?`, args: [id] });\n return jsonResponse({ deleted: true });\n }\n\n // GET /api/articles?brand_id=1&days=7\n if (req.method === \"GET\" && path === \"/api/articles\") {\n const brandId = url.searchParams.get(\"brand_id\");\n const days = parseInt(url.searchParams.get(\"days\") || \"7\");\n if (!brandId) return jsonResponse({ error: \"brand_id required\" }, 400);\n const cutoff = Math.floor(Date.now() / 1000) - days * 86400;\n const rows = await sqlite.execute({\n sql: `SELECT id, title, url, source_name, published_at, sentiment, sentiment_score, collected_at\n FROM articles WHERE brand_id = ? AND collected_at >= ? ORDER BY collected_at DESC LIMIT 100`,\n args: [parseInt(brandId), cutoff],\n });\n const articles = rows.rows.map((r) => ({\n id: r[0], title: r[1], url: r[2], source_name: r[3],\n published_at: r[4], sentiment: r[5], sentiment_score: r[6], collected_at: r[7],\n }));\n return jsonResponse(articles);\n }\n\n // GET /api/report?brand_id=1&period=week\n if (req.method === \"GET\" && path === \"/api/report\") {\n const brandId = url.searchParams.get(\"brand_id\");\n if (!brandId) return jsonResponse({ error: \"brand_id required\" }, 400);\n const period = url.searchParams.get(\"period\") || \"week\";\n const days = period === \"month\" ? 30 : period === \"day\" ? 1 : 7;\n const cutoff = Math.floor(Date.now() / 1000) - days * 86400;\n\n const brandRows = await sqlite.execute({\n sql: `SELECT id, name FROM brands WHERE id = ?`,\n args: [parseInt(brandId)],\n });\n if (!brandRows.rows.length) return jsonResponse({ error: \"Brand not found\" }, 404);\n const brand = { id: brandRows.rows[0][0], name: brandRows.rows[0][1] };\n\n const articleRows = await sqlite.execute({\n sql: `SELECT id, title, url, source_name, sentiment, sentiment_score, collected_at\n FROM articles WHERE brand_id = ? AND collected_at >= ? ORDER BY collected_at DESC`,\n args: [parseInt(brandId), cutoff],\n });\n const articles = articleRows.rows.map((r) => ({\n id: r[0], title: r[1], url: r[2], source_name: r[3],\n sentiment: r[4], sentiment_score: r[5], collected_at: r[6],\n }));\n\n const sentimentBreakdown = { positive: 0, neutral: 0, negative: 0 };\n const sourceMap: Record<string, number> = {};\n for (const a of articles) {\n const s = a.sentiment as string;\n if (s in sentimentBreakdown) sentimentBreakdown[s as keyof typeof sentimentBreakdown]++;\n const src = (a.source_name as string) || \"Unknown\";\n sourceMap[src] = (sourceMap[src] || 0) + 1;\n }\n const topSources = Object.entries(sourceMap)\n .sort((a, b) => b[1] - a[1])\n .slice(0, 10)\n .map(([name, count]) => ({ name, count }));\n\n return jsonResponse({\n brand,\n period,\n total_articles: articles.length,\n sentiment_breakdown: sentimentBreakdown,\n top_sources: topSources,\n recent_articles: articles.slice(0, 20),\n });\n }\n\n // POST /api/collect\n if (req.method === \"POST\" && path === \"/api/collect\") {\n const body = await req.json();\n if (!body.brand_id) return jsonResponse({ error: \"brand_id required\" }, 400);\n const collected = await collectArticles(body.brand_id);\n return jsonResponse({ collected });\n }\n\n return jsonResponse({ error: \"Not found\", path }, 404);\n}",[],[132,157],["D",1783289363906],[150],[132],["D",1783289313194],{"_93":92,"_100":96},{"_93":92,"_94":-5,"_95":96,"_18":53,"_97":98,"_99":26},{"_13":82,"_32":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_120":206,"_207":208,"_209":210,"_211":26,"_212":26,"_213":26,"_214":24,"_215":-5,"_216":-7,"_217":-7,"_218":59,"_219":26,"_220":26,"_221":-5,"_222":26,"_223":26,"_224":26,"_225":-5},"ENV",{"_177":178,"_179":180,"_181":83,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205},"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"] </article></body></html>

Diff · v6