Brand Pulse — Gydline

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_27":99,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":58,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",6,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","brandPulse.ts","latestPath","fileId","54cc879c-8ac4-11f1-b1bd-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst MODEL = Deno.env.get(\"LLM_MODEL\") || \"gpt-5.6-luna\";\nconst OPENROUTER_KEY = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst ADMIN_KEY = Deno.env.get(\"BRANDPULSE_ADMIN_KEY\") || \"\";\n\ntype Item = { id?: number; url: string; source: string; title: string; excerpt?: string; image?: string; published_at?: string; category?: string; sector?: string; summary?: string; score?: number; read?: number; saved?: number; created_at?: string };\ntype Source = { name: string; url: string; kind: \"rss\" | \"reddit\" };\n\nconst SOURCES: Source[] = [\n { name: \"Brand New\", url: \"https://www.underconsideration.com/brandnew/atom.xml\", kind: \"rss\" },\n { name: \"Design Week\", url: \"https://www.designweek.co.uk/feed/\", kind: \"rss\" },\n { name: \"Creative Review\", url: \"https://www.creativereview.co.uk/feed/\", kind: \"rss\" },\n { name: \"BP&O\", url: \"https://bpando.org/feed/\", kind: \"rss\" },\n { name: \"It's Nice That\", url: \"https://www.itsnicethat.com/rss\", kind: \"rss\" },\n { name: \"Awwwards\", url: \"https://www.awwwards.com/blog/feed/\", kind: \"rss\" },\n { name: \"FWA\", url: \"https://thefwa.com/rss\", kind: \"rss\" },\n { name: \"SiteInspire\", url: \"https://www.siteinspire.com/feed\", kind: \"rss\" },\n { name: \"Adweek\", url: \"https://www.adweek.com/feed/\", kind: \"rss\" },\n { name: \"Design Taxi\", url: \"https://designtaxi.com/feed/\", kind: \"rss\" },\n { name: \"Fast Company Design\", url: \"https://www.fastcompany.com/section/design/rss\", kind: \"rss\" },\n { name: \"Campaign\", url: \"https://www.campaignlive.com/rss\", kind: \"rss\" },\n { name: \"r/design\", url: \"https://www.reddit.com/r/design/top.json?t=day&limit=25\", kind: \"reddit\" },\n { name: \"r/branding\", url: \"https://www.reddit.com/r/branding/top.json?t=day&limit=25\", kind: \"reddit\" },\n { name: \"r/graphic_design\", url: \"https://www.reddit.com/r/graphic_design/top.json?t=day&limit=25\", kind: \"reddit\" },\n];\n\nconst CATEGORIES = [\"Rebrand/Visual Identity\", \"Design Trend\", \"Packaging\", \"Strategy/Positioning\", \"UI/UX\", \"Typography\", \"Agency Business\"];\nconst SECTORS = [\"Tech\", \"FMCG\", \"Fashion\", \"Hospitality\", \"B2B\", \"Finance\", \"Healthcare\", \"Culture\", \"Retail\", \"Other\"];\n\nfunction esc(v: unknown) { return String(v ?? \"\").replace(/[&<>'\"]/g, c => ({\"&\":\"&\",\"<\":\"<\",\">\":\">\",\"'\":\"'\",'\"':\""\"}[c]!)); }\nfunction sql(s: string, args: unknown[] = []) { return sqlite.execute({ sql: s, args }); }\nfunction objects(result: any): any[] {\n const rows = result?.rows || [];\n if (!rows.length || !Array.isArray(rows[0])) return rows;\n const columns = result?.columns || [];\n return rows.map((row: any[]) => Object.fromEntries(row.map((value, index) => [columns[index], value])));\n}\nasync function init() {\n await sqlite.batch([\n \"CREATE TABLE IF NOT EXISTS bp_items (id INTEGER PRIMARY KEY AUTOINCREMENT,url TEXT NOT NULL UNIQUE,canonical TEXT,title TEXT NOT NULL,source TEXT NOT NULL,excerpt TEXT,image TEXT,published_at TEXT,category TEXT,sector TEXT,summary TEXT,score INTEGER DEFAULT 0,read INTEGER DEFAULT 0,saved INTEGER DEFAULT 0,created_at TEXT DEFAULT CURRENT_TIMESTAMP)\",\n \"CREATE INDEX IF NOT EXISTS idx_bp_items_recent ON bp_items(created_at DESC)\",\n \"CREATE TABLE IF NOT EXISTS bp_runs (id INTEGER PRIMARY KEY AUTOINCREMENT,started_at TEXT DEFAULT CURRENT_TIMESTAMP,added INTEGER DEFAULT 0,failed INTEGER DEFAULT 0,notes TEXT)\"\n ]);\n}\nfunction strip(html: string) { return html.replace(//g, \"\").replace(/<[^>]*>/g, \" \").replace(/\\s+/g, \" \").trim(); }\nfunction unescapeXml(v: string) { return v.replace(/&#(x[0-9a-f]+|\\d+);/gi, (_, n) => String.fromCodePoint(n[0].toLowerCase() === \"x\" ? parseInt(n.slice(1), 16) : parseInt(n, 10))).replace(/&/g,\"&\").replace(/</g,\"<\").replace(/>/g,\">\").replace(/"/g,'\"').replace(/'/g,\"'\"); }\nasync function enrichImage(item: Item) {\n if (item.image || !/^https?:\\/\\//.test(item.url)) return item;\n try {\n const r = await fetch(item.url, { headers: { \"user-agent\": \"BrandPulse/1.0 (+https://brandpulse.gydline.com)\" } });\n const html = await r.text();\n const image = html.match(/]+(?:property|name)=[\"'](?:og:image|twitter:image)[\"'][^>]+content=[\"']([^\"']+)[\"']/i)?.[1] || html.match(/]+content=[\"']([^\"']+)[\"'][^>]+(?:property|name)=[\"'](?:og:image|twitter:image)[\"']/i)?.[1] || \"\";\n return { ...item, image };\n } catch { return item; }\n}\nfunction between(s: string, re: RegExp) { return (s.match(re)?.[1] || \"\").trim(); }\nfunction parseRss(xml: string, source: string): Item[] {\n const blocks = xml.match(/<(?:item|entry)\\b[\\s\\S]*?<\\/(?:item|entry)>/gi) || [];\n return blocks.slice(0, 20).map(b => {\n const title = unescapeXml(strip(between(b, /]*>([\\s\\S]*?)<\\/title>/i)));\n let url = unescapeXml(strip(between(b, /]*>([\\s\\S]*?)<\\/link>/i)));\n if (!url) url = b.match(/]+href=[\"']([^\"']+)[\"']/i)?.[1] || \"\";\n const excerpt = unescapeXml(strip(between(b, /<(?:description|summary|content:encoded)[^>]*>([\\s\\S]*?)<\\/(?:description|summary|content:encoded)>/i))).slice(0, 1600);\n const image = b.match(/<(?:media:content|media:thumbnail)[^>]+url=[\"']([^\"']+)[\"']/i)?.[1] || b.match(/]+url=[\"']([^\"']+)[\"']/i)?.[1] || \"\";\n const published_at = between(b, /<(?:pubDate|published|updated)[^>]*>([\\s\\S]*?)<\\/(?:pubDate|published|updated)>/i);\n return { url, title, excerpt, image, published_at, source };\n }).filter(x => x.title && /^https?:\\/\\//.test(x.url));\n}\nasync function fetchSource(s: Source): Promise {\n const r = await fetch(s.url, { headers: { \"user-agent\": \"BrandPulse/1.0 (+https://brandpulse.gydline.com)\", \"accept\": \"application/rss+xml, application/atom+xml, application/json, text/xml, text/html\" } });\n if (!r.ok) throw new Error(`${s.name}: ${r.status}`);\n if (s.kind === \"reddit\") {\n const j = await r.json();\n return (j.data?.children || []).map((x: any) => x.data).filter((x: any) => !x.stickied).map((x: any) => ({\n source: s.name, title: x.title, url: x.url_overridden_by_dest || `https://www.reddit.com${x.permalink}`, excerpt: x.selftext || `Reddit score: ${x.score}. ${x.num_comments} comments.`, image: x.thumbnail?.startsWith(\"http\") ? x.thumbnail : \"\", published_at: new Date(x.created_utc * 1000).toISOString(), score: Math.min(100, Math.round(Math.log10(Math.max(x.score, 1)) * 25 + x.num_comments / 8))\n })).filter((x: Item) => /^https?:\\/\\//.test(x.url));\n }\n return parseRss(await r.text(), s.name);\n}\nfunction guess(text: string) {\n const t = text.toLowerCase();\n const category = /rebrand|identity|logo|brand refresh|visual identity/.test(t) ? \"Rebrand/Visual Identity\" : /package|label|unbox/.test(t) ? \"Packaging\" : /typeface|typography|font/.test(t) ? \"Typography\" : /website|web design|digital|interface|ux|ui\\b/.test(t) ? \"UI/UX\" : /positioning|strategy|brand platform/.test(t) ? \"Strategy/Positioning\" : /agency|studio|pitch|client|business/.test(t) ? \"Agency Business\" : \"Design Trend\";\n const sector = /saas|software|ai\\b|tech/.test(t) ? \"Tech\" : /food|drink|beauty|consumer|fmcg/.test(t) ? \"FMCG\" : /fashion|apparel/.test(t) ? \"Fashion\" : /hotel|restaurant|travel|hospital/.test(t) ? \"Hospitality\" : /bank|finance|insurance/.test(t) ? \"Finance\" : /b2b|enterprise/.test(t) ? \"B2B\" : \"Other\";\n return { category, sector };\n}\nasync function ai(item: Item) {\n const fallback = guess(`${item.title} ${item.excerpt || \"\"}`);\n const clean = (item.excerpt || \"\").slice(0, 5000);\n const fallbackSummary = `${item.title} signals a relevant ${fallback.category.toLowerCase()} development. It can inform how Gydline frames distinctive, commercially useful brand work for similar teams.`;\n if (!OPENROUTER_KEY) return { ...fallback, summary: fallbackSummary };\n try {\n const body = { model: MODEL, temperature: 0.2, max_tokens: 240, messages: [{ role: \"system\", content: \"You are a brand-intelligence editor. Return only valid JSON with category, sector, summary. category must be one of: \" + CATEGORIES.join(\" | \") + \". sector must be one of: \" + SECTORS.join(\" | \") + \". summary is exactly two concise sentences, focused on why this matters to a high-end branding and design consultancy. Do not invent facts.\" }, { role: \"user\", content: `Title: ${item.title}\\nSource: ${item.source}\\nExcerpt: ${clean}` }] };\n const r = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", { method: \"POST\", headers: { \"Authorization\": `Bearer ${OPENROUTER_KEY}`, \"Content-Type\": \"application/json\", \"HTTP-Referer\": \"https://brandpulse.gydline.com\", \"X-Title\": \"Gydline Brand Pulse\" }, body: JSON.stringify(body) });\n if (!r.ok) throw new Error(String(r.status));\n const raw = (await r.json()).choices?.[0]?.message?.content || \"{}\";\n const parsed = JSON.parse(raw.match(/\\{[\\s\\S]*\\}/)?.[0] || \"{}\");\n return { category: CATEGORIES.includes(parsed.category) ? parsed.category : fallback.category, sector: SECTORS.includes(parsed.sector) ? parsed.sector : fallback.sector, summary: String(parsed.summary || fallbackSummary).slice(0, 800) };\n } catch { return { ...fallback, summary: fallbackSummary }; }\n}\nasync function ingest() {\n await init(); let added = 0, failed = 0; const notes: string[] = [];\n const collected = await Promise.all(SOURCES.map(async source => {\n try { return await fetchSource(source); }\n catch (e) { failed++; notes.push(`${source.name}: ${String(e).slice(0,80)}`); return []; }\n }));\n const candidates: Item[] = [];\n for (const item of collected.flat()) {\n const exists: any = await sql(\"SELECT id FROM bp_items WHERE url = ? LIMIT 1\", [item.url]);\n if (!exists.rows?.length) candidates.push(item);\n }\n // Keep each scheduled run predictable: 30 fresh signals, processed in six parallel lanes.\n const queue = candidates.slice(0, 30);\n for (let start = 0; start < queue.length; start += 6) {\n await Promise.all(queue.slice(start, start + 6).map(async original => {\n const item = await enrichImage(original);\n const a = await ai(item);\n const score = item.score || Math.min(99, 35 + (/rebrand|identity|branding|packaging/i.test(item.title) ? 30 : 0) + (a.category === \"Strategy/Positioning\" ? 12 : 0));\n try { await sql(\"INSERT INTO bp_items (url,canonical,title,source,excerpt,image,published_at,category,sector,summary,score) VALUES (?,?,?,?,?,?,?,?,?,?,?)\", [item.url, item.url.replace(/[?#].*$/, \"\"), item.title.slice(0, 500), item.source, (item.excerpt || \"\").slice(0, 4000), item.image || \"\", item.published_at || \"\", a.category, a.sector, a.summary, score]); added++; } catch { /* duplicate canonical item or malformed feed item */ }\n }));\n }\n await sql(\"INSERT INTO bp_runs (added,failed,notes) VALUES (?,?,?)\", [added, failed, notes.join(\"; \")]);\n return { added, failed, sources: SOURCES.length, processed: queue.length, notes };\n}\nasync function rows(query: URLSearchParams) {\n await init(); const where: string[] = []; const args: unknown[] = [];\n const search = query.get(\"q\")?.trim(); const category = query.get(\"category\"); const source = query.get(\"source\"); const saved = query.get(\"saved\"); const unread = query.get(\"unread\");\n if (search) { where.push(\"(title LIKE ? OR excerpt LIKE ? OR summary LIKE ?)\"); args.push(`%${search}%`, `%${search}%`, `%${search}%`); }\n if (category) { where.push(\"category = ?\"); args.push(category); }\n if (source) { where.push(\"source = ?\"); args.push(source); }\n if (saved === \"1\") where.push(\"saved = 1\"); if (unread === \"1\") where.push(\"read = 0\");\n const order = query.get(\"view\") === \"trending\" ? \"score DESC, created_at DESC\" : \"created_at DESC\";\n const data: any = await sql(`SELECT * FROM bp_items ${where.length ? \"WHERE \" + where.join(\" AND \") : \"\"} ORDER BY ${order} LIMIT 100`, args);\n return objects(data);\n}\nfunction card(x: Item, view: string) { const img = x.image && /^https?:/.test(x.image) ? `

` : \"\"; return `

${img}${esc(x.score)}

${esc(x.source)}${esc(x.category || \"Design Trend\")}

${esc(x.title)}

${esc(x.summary || x.excerpt || \"No summary yet.\")}

${esc(x.sector || \"Other\")}${esc((x.published_at || x.created_at || \"\").slice(0,10))}

`; }\nfunction page(items: Item[], q: URLSearchParams) {\n const view = q.get(\"view\") || \"grid\"; const selected = q.get(\"category\") || \"\"; const sources = [...new Set(items.map(x => x.source))].sort();\n return `Brand Pulse — Gydline

Gydline Intelligence System

Brand Pulse

Signal, not noise
Curated for brand leadership

${items.length ? \"\" : '

No items match this view. Run a refresh to load the latest source signals.

Grid List Saved Unread

${items.map(x=>card(x,view)).join(\"\") || '

The archive is ready. Select “Refresh intelligence” to begin ingestion.

`;\n}\nasync function digest() { const result: any = await sql(\"SELECT title,source,category,sector,summary,url,score FROM bp_items WHERE created_at >= datetime('now','-2 days') ORDER BY score DESC, created_at DESC LIMIT 10\"); const a = objects(result); return { count: a.length, text: a.length ? `**Brand Pulse — Daily Intelligence**\\n${a.map((x:any,i:number)=>`${i+1}. **${x.title}** — ${x.source} · ${x.category}\\n${x.summary}\\n<${x.url}>`).join(\"\\n\\n\")}` : \"**Brand Pulse — Daily Intelligence**\\nNo new items are available. Run the ingestion endpoint first.\" }; }\n\nexport default async function brandPulse(req: Request): Promise {\n try {\n const url = new URL(req.url); const path = url.pathname; await init();\n const secure = (req.headers.get(\"x-brandpulse-key\") || \"\") === ADMIN_KEY;\n if (path === \"/api/health\") return Response.json({ ok: true, model: MODEL, llmConfigured: Boolean(OPENROUTER_KEY), time: new Date().toISOString() });\n if (path === \"/api/ingest\" && req.method === \"POST\") { if (ADMIN_KEY && !secure) return Response.json({ error: \"Unauthorized\" }, { status: 401 }); return Response.json(await ingest()); }\n if (path === \"/api/digest\") { if (ADMIN_KEY && !secure) return Response.json({ error: \"Unauthorized\" }, { status: 401 }); return Response.json(await digest()); }\n const match = path.match(/^\\/api\\/items\\/(\\d+)\\/(read|save)$/); if (match && req.method === \"POST\") { const field = match[2] === \"read\" ? \"read\" : \"saved\"; await sql(`UPDATE bp_items SET ${field} = CASE ${field} WHEN 1 THEN 0 ELSE 1 END WHERE id = ?`, [Number(match[1])]); return Response.json({ ok: true }); }\n if (path === \"/api/items\") return Response.json(await rows(url.searchParams));\n return new Response(page(await rows(url.searchParams), url.searchParams), { headers: { \"content-type\": \"text/html; charset=utf-8\", \"cache-control\": \"no-store\" } });\n } catch (e) { return new Response(`Brand Pulse error: ${esc(String(e))}`, { status: 500 }); }\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst MODEL = Deno.env.get(\"LLM_MODEL\") || \"gpt-5.6-luna\";\nconst OPENROUTER_KEY = Deno.env.get(\"OPENROUTER_API_KEY\");\nconst ADMIN_KEY = Deno.env.get(\"BRANDPULSE_ADMIN_KEY\") || \"\";\n\ntype Item = { id?: number; url: string; source: string; title: string; excerpt?: string; image?: string; published_at?: string; category?: string; sector?: string; summary?: string; score?: number; read?: number; saved?: number; created_at?: string };\ntype Source = { name: string; url: string; kind: \"rss\" | \"reddit\" };\n\nconst SOURCES: Source[] = [\n { name: \"Brand New\", url: \"https://www.underconsideration.com/brandnew/atom.xml\", kind: \"rss\" },\n { name: \"Design Week\", url: \"https://www.designweek.co.uk/feed/\", kind: \"rss\" },\n { name: \"Creative Review\", url: \"https://www.creativereview.co.uk/feed/\", kind: \"rss\" },\n { name: \"BP&O\", url: \"https://bpando.org/feed/\", kind: \"rss\" },\n { name: \"It's Nice That\", url: \"https://www.itsnicethat.com/rss\", kind: \"rss\" },\n { name: \"Awwwards\", url: \"https://www.awwwards.com/blog/feed/\", kind: \"rss\" },\n { name: \"FWA\", url: \"https://thefwa.com/rss\", kind: \"rss\" },\n { name: \"SiteInspire\", url: \"https://www.siteinspire.com/feed\", kind: \"rss\" },\n { name: \"Adweek\", url: \"https://www.adweek.com/feed/\", kind: \"rss\" },\n { name: \"Design Taxi\", url: \"https://designtaxi.com/feed/\", kind: \"rss\" },\n { name: \"Fast Company Design\", url: \"https://www.fastcompany.com/section/design/rss\", kind: \"rss\" },\n { name: \"Campaign\", url: \"https://www.campaignlive.com/rss\", kind: \"rss\" },\n { name: \"r/design\", url: \"https://www.reddit.com/r/design/top.json?t=day&limit=25\", kind: \"reddit\" },\n { name: \"r/branding\", url: \"https://www.reddit.com/r/branding/top.json?t=day&limit=25\", kind: \"reddit\" },\n { name: \"r/graphic_design\", url: \"https://www.reddit.com/r/graphic_design/top.json?t=day&limit=25\", kind: \"reddit\" },\n];\n\nconst CATEGORIES = [\"Rebrand/Visual Identity\", \"Design Trend\", \"Packaging\", \"Strategy/Positioning\", \"UI/UX\", \"Typography\", \"Agency Business\"];\nconst SECTORS = [\"Tech\", \"FMCG\", \"Fashion\", \"Hospitality\", \"B2B\", \"Finance\", \"Healthcare\", \"Culture\", \"Retail\", \"Other\"];\n\nfunction esc(v: unknown) { return String(v ?? \"\").replace(/[&<>'\"]/g, c => ({\"&\":\"&\",\"<\":\"<\",\">\":\">\",\"'\":\"'\",'\"':\""\"}[c]!)); }\nfunction sql(s: string, args: unknown[] = []) { return sqlite.execute({ sql: s, args }); }\nfunction objects(result: any): any[] {\n const rows = result?.rows || [];\n if (!rows.length || !Array.isArray(rows[0])) return rows;\n const columns = result?.columns || [];\n return rows.map((row: any[]) => Object.fromEntries(row.map((value, index) => [columns[index], value])));\n}\nasync function init() {\n await sqlite.batch([\n \"CREATE TABLE IF NOT EXISTS bp_items (id INTEGER PRIMARY KEY AUTOINCREMENT,url TEXT NOT NULL UNIQUE,canonical TEXT,title TEXT NOT NULL,source TEXT NOT NULL,excerpt TEXT,image TEXT,published_at TEXT,category TEXT,sector TEXT,summary TEXT,score INTEGER DEFAULT 0,read INTEGER DEFAULT 0,saved INTEGER DEFAULT 0,created_at TEXT DEFAULT CURRENT_TIMESTAMP)\",\n \"CREATE INDEX IF NOT EXISTS idx_bp_items_recent ON bp_items(created_at DESC)\",\n \"CREATE TABLE IF NOT EXISTS bp_runs (id INTEGER PRIMARY KEY AUTOINCREMENT,started_at TEXT DEFAULT CURRENT_TIMESTAMP,added INTEGER DEFAULT 0,failed INTEGER DEFAULT 0,notes TEXT)\"\n ]);\n}\nfunction strip(html: string) { return html.replace(//g, \"\").replace(/<[^>]*>/g, \" \").replace(/\\s+/g, \" \").trim(); }\nfunction unescapeXml(v: string) { return v.replace(/&#(x[0-9a-f]+|\\d+);/gi, (_, n) => String.fromCodePoint(n[0].toLowerCase() === \"x\" ? parseInt(n.slice(1), 16) : parseInt(n, 10))).replace(/&/g,\"&\").replace(/</g,\"<\").replace(/>/g,\">\").replace(/"/g,'\"').replace(/'/g,\"'\"); }\nasync function enrichImage(item: Item) {\n if (item.image || !/^https?:\\/\\//.test(item.url)) return item;\n try {\n const r = await fetch(item.url, { headers: { \"user-agent\": \"BrandPulse/1.0 (+https://brandpulse.gydline.com)\" } });\n const html = await r.text();\n const image = html.match(/]+(?:property|name)=[\"'](?:og:image|twitter:image)[\"'][^>]+content=[\"']([^\"']+)[\"']/i)?.[1] || html.match(/]+content=[\"']([^\"']+)[\"'][^>]+(?:property|name)=[\"'](?:og:image|twitter:image)[\"']/i)?.[1] || \"\";\n return { ...item, image };\n } catch { return item; }\n}\nfunction between(s: string, re: RegExp) { return (s.match(re)?.[1] || \"\").trim(); }\nfunction parseRss(xml: string, source: string): Item[] {\n const blocks = xml.match(/<(?:item|entry)\\b[\\s\\S]*?<\\/(?:item|entry)>/gi) || [];\n return blocks.slice(0, 20).map(b => {\n const title = unescapeXml(strip(between(b, /]*>([\\s\\S]*?)<\\/title>/i)));\n let url = unescapeXml(strip(between(b, /]*>([\\s\\S]*?)<\\/link>/i)));\n if (!url) url = b.match(/]+href=[\"']([^\"']+)[\"']/i)?.[1] || \"\";\n const excerpt = unescapeXml(strip(between(b, /<(?:description|summary|content:encoded)[^>]*>([\\s\\S]*?)<\\/(?:description|summary|content:encoded)>/i))).slice(0, 1600);\n const image = b.match(/<(?:media:content|media:thumbnail)[^>]+url=[\"']([^\"']+)[\"']/i)?.[1] || b.match(/]+url=[\"']([^\"']+)[\"']/i)?.[1] || \"\";\n const published_at = between(b, /<(?:pubDate|published|updated)[^>]*>([\\s\\S]*?)<\\/(?:pubDate|published|updated)>/i);\n return { url, title, excerpt, image, published_at, source };\n }).filter(x => x.title && /^https?:\\/\\//.test(x.url));\n}\nasync function fetchSource(s: Source): Promise {\n const r = await fetch(s.url, { headers: { \"user-agent\": \"BrandPulse/1.0 (+https://brandpulse.gydline.com)\", \"accept\": \"application/rss+xml, application/atom+xml, application/json, text/xml, text/html\" } });\n if (!r.ok) throw new Error(`${s.name}: ${r.status}`);\n if (s.kind === \"reddit\") {\n const j = await r.json();\n return (j.data?.children || []).map((x: any) => x.data).filter((x: any) => !x.stickied).map((x: any) => ({\n source: s.name, title: x.title, url: x.url_overridden_by_dest || `https://www.reddit.com${x.permalink}`, excerpt: x.selftext || `Reddit score: ${x.score}. ${x.num_comments} comments.`, image: x.thumbnail?.startsWith(\"http\") ? x.thumbnail : \"\", published_at: new Date(x.created_utc * 1000).toISOString(), score: Math.min(100, Math.round(Math.log10(Math.max(x.score, 1)) * 25 + x.num_comments / 8))\n })).filter((x: Item) => /^https?:\\/\\//.test(x.url));\n }\n return parseRss(await r.text(), s.name);\n}\nfunction guess(text: string) {\n const t = text.toLowerCase();\n const category = /rebrand|identity|logo|brand refresh|visual identity/.test(t) ? \"Rebrand/Visual Identity\" : /package|label|unbox/.test(t) ? \"Packaging\" : /typeface|typography|font/.test(t) ? \"Typography\" : /website|web design|digital|interface|ux|ui\\b/.test(t) ? \"UI/UX\" : /positioning|strategy|brand platform/.test(t) ? \"Strategy/Positioning\" : /agency|studio|pitch|client|business/.test(t) ? \"Agency Business\" : \"Design Trend\";\n const sector = /saas|software|ai\\b|tech/.test(t) ? \"Tech\" : /food|drink|beauty|consumer|fmcg/.test(t) ? \"FMCG\" : /fashion|apparel/.test(t) ? \"Fashion\" : /hotel|restaurant|travel|hospital/.test(t) ? \"Hospitality\" : /bank|finance|insurance/.test(t) ? \"Finance\" : /b2b|enterprise/.test(t) ? \"B2B\" : \"Other\";\n return { category, sector };\n}\nasync function ai(item: Item) {\n const fallback = guess(`${item.title} ${item.excerpt || \"\"}`);\n const clean = (item.excerpt || \"\").slice(0, 5000);\n const fallbackSummary = `${item.title} signals a relevant ${fallback.category.toLowerCase()} development. It can inform how Gydline frames distinctive, commercially useful brand work for similar teams.`;\n if (!OPENROUTER_KEY) return { ...fallback, summary: fallbackSummary };\n try {\n const body = { model: MODEL, temperature: 0.2, max_tokens: 240, messages: [{ role: \"system\", content: \"You are a brand-intelligence editor. Return only valid JSON with category, sector, summary. category must be one of: \" + CATEGORIES.join(\" | \") + \". sector must be one of: \" + SECTORS.join(\" | \") + \". summary is exactly two concise sentences, focused on why this matters to a high-end branding and design consultancy. Do not invent facts.\" }, { role: \"user\", content: `Title: ${item.title}\\nSource: ${item.source}\\nExcerpt: ${clean}` }] };\n const r = await fetch(\"https://openrouter.ai/api/v1/chat/completions\", { method: \"POST\", headers: { \"Authorization\": `Bearer ${OPENROUTER_KEY}`, \"Content-Type\": \"application/json\", \"HTTP-Referer\": \"https://brandpulse.gydline.com\", \"X-Title\": \"Gydline Brand Pulse\" }, body: JSON.stringify(body) });\n if (!r.ok) throw new Error(String(r.status));\n const raw = (await r.json()).choices?.[0]?.message?.content || \"{}\";\n const parsed = JSON.parse(raw.match(/\\{[\\s\\S]*\\}/)?.[0] || \"{}\");\n return { category: CATEGORIES.includes(parsed.category) ? parsed.category : fallback.category, sector: SECTORS.includes(parsed.sector) ? parsed.sector : fallback.sector, summary: String(parsed.summary || fallbackSummary).slice(0, 800) };\n } catch { return { ...fallback, summary: fallbackSummary }; }\n}\nasync function ingest() {\n await init(); let added = 0, failed = 0; const notes: string[] = [];\n const collected = await Promise.all(SOURCES.map(async source => {\n try { return await fetchSource(source); }\n catch (e) { failed++; notes.push(`${source.name}: ${String(e).slice(0,80)}`); return []; }\n }));\n const candidates: Item[] = [];\n for (const item of collected.flat()) {\n const exists: any = await sql(\"SELECT id FROM bp_items WHERE url = ? LIMIT 1\", [item.url]);\n if (!exists.rows?.length) candidates.push(item);\n }\n // Keep each scheduled run predictable: 30 fresh signals, processed in six parallel lanes.\n const queue = candidates.slice(0, 30);\n for (let start = 0; start < queue.length; start += 6) {\n await Promise.all(queue.slice(start, start + 6).map(async original => {\n const item = await enrichImage(original);\n const a = await ai(item);\n const score = item.score || Math.min(99, 35 + (/rebrand|identity|branding|packaging/i.test(item.title) ? 30 : 0) + (a.category === \"Strategy/Positioning\" ? 12 : 0));\n try { await sql(\"INSERT INTO bp_items (url,canonical,title,source,excerpt,image,published_at,category,sector,summary,score) VALUES (?,?,?,?,?,?,?,?,?,?,?)\", [item.url, item.url.replace(/[?#].*$/, \"\"), item.title.slice(0, 500), item.source, (item.excerpt || \"\").slice(0, 4000), item.image || \"\", item.published_at || \"\", a.category, a.sector, a.summary, score]); added++; } catch { /* duplicate canonical item or malformed feed item */ }\n }));\n }\n await sql(\"INSERT INTO bp_runs (added,failed,notes) VALUES (?,?,?)\", [added, failed, notes.join(\"; \")]);\n return { added, failed, sources: SOURCES.length, processed: queue.length, notes };\n}\nasync function rows(query: URLSearchParams) {\n await init(); const where: string[] = []; const args: unknown[] = [];\n const search = query.get(\"q\")?.trim(); const category = query.get(\"category\"); const source = query.get(\"source\"); const saved = query.get(\"saved\"); const unread = query.get(\"unread\");\n if (search) { where.push(\"(title LIKE ? OR excerpt LIKE ? OR summary LIKE ?)\"); args.push(`%${search}%`, `%${search}%`, `%${search}%`); }\n if (category) { where.push(\"category = ?\"); args.push(category); }\n if (source) { where.push(\"source = ?\"); args.push(source); }\n if (saved === \"1\") where.push(\"saved = 1\"); if (unread === \"1\") where.push(\"read = 0\");\n const order = query.get(\"view\") === \"trending\" ? \"score DESC, created_at DESC\" : \"created_at DESC\";\n const data: any = await sql(`SELECT * FROM bp_items ${where.length ? \"WHERE \" + where.join(\" AND \") : \"\"} ORDER BY ${order} LIMIT 100`, args);\n return objects(data);\n}\nfunction card(x: Item, view: string) { const img = x.image && /^https?:/.test(x.image) ? `

` : \"\"; return `

${img}${esc(x.score)}

${esc(x.source)}${esc(x.category || \"Design Trend\")}

${esc(x.title)}

${esc(x.summary || x.excerpt || \"No summary yet.\")}

${esc(x.sector || \"Other\")}${esc((x.published_at || x.created_at || \"\").slice(0,10))}

Gydline Intelligence System

Brand Pulse

Signal, not noise
Curated for brand leadership

${items.length ? \"\" : '

No items match this view. Run a refresh to load the latest source signals.

Grid List Saved Unread

${items.map(x=>card(x,view)).join(\"\") || '

The archive is ready. Select “Refresh intelligence” to begin ingestion.

Diff · v6