[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_151":152,"_153":154},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":97,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":25,"_119":-5,"_120":-5,"_121":122},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",10,"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","main.ts","latestPath","fileId","52186492-3bcf-11f1-b106-42b51c65c3df","name","fileType","interval","content","// NaturPets — Research Feed + Weekly VSL Generator (combined)\n// Single cron val — runs every 12h → 0 */12 * * *\n// Every run: Brave search → Stefan analysis → Discord feed\n// Monday runs only: if strong signals exist → Stefan VSL → Google Doc → Discord\n//\n// Env vars:\n// BRAVE_API_KEY\n// STEFAN_API_KEY\n// STEFAN_HOST\n// DISCORD_WEBHOOK_NATURPETS\n// GOOGLE_SA_JSON (full service account JSON as string)\n// GOOGLE_DRIVE_FOLDER (Drive folder ID)\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ─── CONFIG ──────────────────────────────────────────────────────────────────\n\nconst SEARCH_QUERIES = [\n 'site:reddit.com dog \"yeast infection\" \"nothing works\"',\n 'site:reddit.com dog \"ear infection\" \"keeps coming back\"',\n 'site:reddit.com dog \"yeast\" \"tried everything\"',\n 'site:reddit.com dog \"apoquel\" \"still itching\"',\n 'site:reddit.com dog \"medicated shampoo\" \"came back\"',\n 'site:reddit.com dog \"antibiotics\" \"made it worse\"',\n 'site:reddit.com dog \"paw licking\" \"won\\'t stop\"',\n 'site:reddit.com dog \"frito feet\" OR \"corn chip smell\"',\n 'site:reddit.com dog \"hot spots\" \"relapse\"',\n 'site:reddit.com dog \"itchy skin\" \"vet doesn\\'t know\"',\n 'site:reddit.com dog \"scratching herself bloody\" OR \"scratching until bleeding\"',\n 'site:reddit.com dog \"at my wits end\" itchy',\n 'site:reddit.com dog \"spent thousands\" vet itchy',\n 'site:reddit.com dog yeast \"clears up then comes back\"',\n '\"dog yeast infection\" \"nothing works\" forum',\n '\"dog ear infection keeps coming back\" forum',\n '\"apoquel stopped working\" dog',\n '\"chronic yeast\" dog owner forum',\n '\"dog itching all night\" yeast',\n '\"dog yeast\" \"tried everything\" site:reddit.com OR site:quora.com',\n];\n\nconst RESULTS_PER_QUERY = 5;\n\nconst NATURPETS_CONTEXT = `\nPRODUCT: NaturPets Yeast Control — liquid drops added to dog food. Natural Bacon Flavor.\nMECHANISM: Colony Collapse Protocol — yeast forms biofilm colonies 1000x more resistant than free-floating cells. Every surface treatment (sprays, shampoos, Apoquel, antibiotics) attacks from outside. NaturPets enters via bloodstream — the one direction the colony can't defend against.\nTHREE TEAMS: Colony Killers (Pau D'Arco + Goldenseal) | Environment Shifters (ACV + Ginger) | Rebuilders (Dandelion + Marshmallow Root)\nPRIMARY AVATAR: Dog owner 35–65, cycling through failed treatments for months/years, frustrated, feels like they're failing their dog.\nHOOK TYPES: Colony Reframe | Failed Treatment | Symptom Desperation | Relapse Cycle | Natural Seeker | Guilt/Helplessness\nCOPY RULES: Consequence-first. Call out Apoquel/antibiotics/medicated shampoo by name. Tone: raw, direct, slightly pissed off. NEVER say \"biofilm\" — use ant colony analogy.\nTHE AHA: \"You were never fighting an infection. You were fighting a colony. Every treatment was designed to kill individual cells — while the colony rebuilt behind a fortress wall 1,000x more resistant.\"\n`;\n\nconst VSL_BRIEF = `\nPRODUCT: NaturPets Yeast Control — liquid drops added to dog food. Natural Bacon Flavor.\nPRICE: [INSERT PRICE] | GUARANTEE: [INSERT GUARANTEE]\n\nCORE MECHANISM — COLONY COLLAPSE PROTOCOL:\nDogs don't have a yeast INFECTION. They have a yeast COLONY.\nYeast organizes into biofilms — self-protecting fortresses up to 1,000x more resistant than free-floating cells.\nAnt colony analogy: kill surface ants all day. The colony underground doesn't notice. It just sends more.\nEvery conventional treatment attacks from the OUTSIDE. NaturPets enters via bloodstream — the one direction the colony can't defend.\n\nTHREE TEAMS:\n- Colony Killers (Pau D'Arco + Goldenseal): Penetrate colony from inside, disrupt cellular structure and communication signals.\n- Environment Shifters (ACV + Ginger): Shift internal pH to make gut hostile to yeast. Make recolonization impossible.\n- Rebuilders (Dandelion + Marshmallow Root): Flush mycotoxins when colony collapses. Rebuild gut lining and natural barriers.\n\nPRIMARY AVATAR: Dog owner 35–65, cycling through failed treatments for months/years (Apoquel, antibiotics, medicated shampoos), relapsing over and over. Frustrated, spent significant money, feels like they're failing their dog.\n\nVSL RULES:\n- Hook must work in first 5 seconds — no \"Hi my name is...\" openers\n- NEVER say \"biofilm\" — use ant colony analogy throughout \n- Call out Apoquel, antibiotics, medicated shampoo by name in failure stack\n- Tone: raw, direct, slightly pissed off\n- 3 CTA blocks: soft (~60%), main (after offer), PS (end) — each must restate guarantee\n`;\n\n// ─── BRAVE SEARCH ────────────────────────────────────────────────────────────\n\nasync function runBraveSearch(query: string): Promise {\n const params = new URLSearchParams({\n q: query,\n count: String(RESULTS_PER_QUERY),\n search_lang: \"en\",\n text_decorations: \"false\",\n });\n const res = await fetch(\n `https://api.search.brave.com/res/v1/web/search?${params}`,\n {\n headers: {\n Accept: \"application/json\",\n \"Accept-Encoding\": \"gzip\",\n \"X-Subscription-Token\": Deno.env.get(\"BRAVE_API_KEY\")!,\n },\n },\n );\n if (!res.ok) {\n console.error(`Brave error \"${query}\": ${res.status}`);\n return [];\n }\n const data = await res.json();\n return data?.web?.results ?? [];\n}\n\nasync function fetchAllResults(): Promise {\n console.log(`[1/5] Running ${SEARCH_QUERIES.length} Brave searches...`);\n const seen = new Set();\n const all: any[] = [];\n for (const query of SEARCH_QUERIES) {\n const results = await runBraveSearch(query);\n for (const r of results) {\n const id = btoa(r.url).replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 32);\n if (!seen.has(id) && (r.description?.length ?? 0) > 40) {\n seen.add(id);\n all.push({ ...r, id, query });\n }\n }\n await new Promise((r) => setTimeout(r, 1100));\n }\n console.log(` ✓ ${all.length} unique results`);\n return all;\n}\n\n// ─── SQLITE ───────────────────────────────────────────────────────────────────\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS naturpets_research (\n id TEXT PRIMARY KEY,\n title TEXT, url TEXT, description TEXT, source TEXT, query TEXT,\n hook_type TEXT, pain_sentence TEXT, hook_draft TEXT,\n failed_treatments TEXT, angle_strength TEXT, vsl_worthy INTEGER,\n note TEXT, seen_at INTEGER\n )\n `);\n}\n\nasync function filterUnseen(results: any[]): Promise {\n if (!results.length) return [];\n const ids = results.map((r) => `'${r.id}'`).join(\",\");\n const existing = await sqlite.execute(\n `SELECT id FROM naturpets_research WHERE id IN (${ids})`,\n );\n const seenIds = new Set(existing.rows.map((row: any) => row[0]));\n return results.filter((r) => !seenIds.has(r.id));\n}\n\nasync function saveResults(results: any[], analyses: any[]) {\n if (!results.length) return;\n const now = Math.floor(Date.now() / 1000);\n for (let i = 0; i < results.length; i++) {\n const r = results[i];\n const a = analyses[i] ?? {};\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO naturpets_research\n (id,title,url,description,source,query,hook_type,pain_sentence,hook_draft,\n failed_treatments,angle_strength,vsl_worthy,note,seen_at)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [\n r.id,\n r.title ?? \"\",\n r.url ?? \"\",\n r.description ?? \"\",\n (() => {\n try {\n return new URL(r.url).hostname.replace(\"www.\", \"\");\n } catch {\n return \"\";\n }\n })(),\n r.query,\n a.hook_type ?? \"\",\n a.pain_sentence ?? \"\",\n a.hook_draft ?? \"\",\n JSON.stringify(a.failed_treatments_mentioned ?? []),\n a.angle_strength ?? \"\",\n a.vsl_worthy ? 1 : 0,\n a.note ?? \"\",\n now,\n ],\n });\n }\n await sqlite.execute(\n `DELETE FROM naturpets_research WHERE seen_at < ${\n Math.floor(Date.now() / 1000) - 30 * 86400\n }`,\n );\n}\n\nasync function getWeeklyStrongSignals(): Promise {\n const cutoff = Math.floor(Date.now() / 1000) - 7 * 86400;\n try {\n const result = await sqlite.execute({\n sql:\n `SELECT * FROM naturpets_research WHERE seen_at > ? AND angle_strength = '🔥 Strong' ORDER BY vsl_worthy DESC, seen_at DESC`,\n args: [cutoff],\n });\n return result.rows.map((row: any) => ({\n id: row[0],\n title: row[1],\n url: row[2],\n description: row[3],\n source: row[4],\n query: row[5],\n hook_type: row[6],\n pain_sentence: row[7],\n hook_draft: row[8],\n failed_treatments: JSON.parse(row[9] || \"[]\"),\n angle_strength: row[10],\n vsl_worthy: row[11] === 1,\n note: row[12],\n seen_at: row[13],\n }));\n } catch {\n return [];\n }\n}\n\n// ─── STEFAN — RESEARCH ANALYSIS ──────────────────────────────────────────────\n\nasync function analyzeWithStefan(results: any[]): Promise {\n if (!results.length) return [];\n console.log(`[3/5] Analyzing ${results.length} results with Stefan...`);\n const BATCH_SIZE = 8;\n const all: any[] = [];\n\n for (let i = 0; i < results.length; i += BATCH_SIZE) {\n const batch = results.slice(i, i + BATCH_SIZE);\n const text = batch.map((r, idx) =>\n `RESULT ${idx + 1} [${\n (() => {\n try {\n return new URL(r.url).hostname;\n } catch {\n return \"unknown\";\n }\n })()\n }]\nTitle: ${r.title}\nSnippet: ${r.description}\nQuery: ${r.query}`\n ).join(\"\\n\\n---\\n\\n\");\n\n const prompt =\n `You are a direct response copywriter analyzing web results for NaturPets Yeast Control.\n\n${NATURPETS_CONTEXT}\n\nAnalyze each result. Return a JSON array, one object per result, same order.\n\nEach object:\n{\n \"hook_type\": \"Colony Reframe\"|\"Failed Treatment\"|\"Symptom Desperation\"|\"Relapse Cycle\"|\"Natural Seeker\"|\"Guilt/Helplessness\"|\"General Pain\"|\"Not Useful\",\n \"pain_sentence\": exact words from snippet max 20 words, empty string if none,\n \"hook_draft\": consequence-first hook max 15 words, empty string if not enough signal,\n \"failed_treatments_mentioned\": array e.g. [\"Apoquel\",\"antibiotics\"] or [],\n \"angle_strength\": \"🔥 Strong\"|\"⚡ Moderate\"|\"❄️ Weak\",\n \"vsl_worthy\": true or false,\n \"note\": one copy insight max 12 words\n}\n\nReturn ONLY the JSON array. No markdown, no preamble.\n\nRESULTS:\n${text}`;\n\n try {\n const res = await fetch(\n `${Deno.env.get(\"STEFAN_HOST\")}/api/developers/v1/chat`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${Deno.env.get(\"STEFAN_API_KEY\")}`,\n },\n body: JSON.stringify({ message: prompt, selectedModel: \"sonnet\" }),\n },\n );\n const data = await res.json();\n if (!data.output) throw new Error(\"No output: \" + JSON.stringify(data));\n all.push(...JSON.parse(data.output.replace(/```json|```/g, \"\").trim()));\n } catch (e: any) {\n console.error(`Stefan analysis batch failed:`, e.message);\n batch.forEach(() =>\n all.push({\n hook_type: \"General Pain\",\n pain_sentence: \"\",\n hook_draft: \"\",\n failed_treatments_mentioned: [],\n angle_strength: \"❄️ Weak\",\n vsl_worthy: false,\n note: `Error: ${e.message?.slice(0, 40)}`,\n })\n );\n }\n if (i + BATCH_SIZE < results.length) {\n await new Promise((r) => setTimeout(r, 500));\n }\n }\n return all;\n}\n\n// ─── STEFAN — VSL GENERATION ──────────────────────────────────────────────────\n\nasync function generateVSL(\n signals: any[],\n): Promise<{ script: string; wordCount: number }> {\n console.log(\n `[VSL] Generating script from ${signals.length} strong signals...`,\n );\n\n const painPoints = signals.filter((s) => s.pain_sentence).slice(0, 8)\n .map((s, i) => `${i + 1}. \"${s.pain_sentence}\" [${s.hook_type}]`).join(\n \"\\n\",\n );\n const hookDrafts = signals.filter((s) => s.hook_draft).slice(0, 5)\n .map((s) => `• ${s.hook_draft}`).join(\"\\n\");\n const treatments = [...new Set(signals.flatMap((s) => s.failed_treatments))]\n .filter(Boolean);\n\n const message =\n `You are an expert direct-response copywriter using RMBC framework by Stefan Georgi.\n\n${VSL_BRIEF}\n\nREAL PAIN LANGUAGE from the web this week:\n${painPoints}\n\nHOOK DRAFTS to consider:\n${hookDrafts}\n\nFAILED TREATMENTS mentioned by real dog owners:\n${treatments.join(\", \") || \"Apoquel, antibiotics, medicated shampoo\"}\n\nWrite a complete standard VSL script (~25–35 min) with this exact structure:\n\n### [0:00–0:30] HOOK\n### [0:30–3:00] PROBLEM AGITATION \n### [3:00–5:00] FAILED SOLUTIONS\n### [5:00–10:00] MECHANISM REVEAL\n### [10:00–18:00] PROOF CASCADE\n### [18:00–22:00] PRODUCT INTRODUCTION\n### [22:00–27:00] OFFER STACK\n### [27:00–29:00] RISK REVERSAL\n### [29:00–32:00] CLOSE + URGENCY\n### [32:00–35:00] PS / SECOND CLOSE\n\nEach section: **Screen:** [direction] **Script:** [voiceover] **→ Transition:** [bridge]\n3 CTA blocks (soft ~60%, main after offer, PS at end) — each must restate guarantee.\nFailed Solutions must name Apoquel, antibiotics, medicated shampoo and explain WHY each fails through the colony lens.\nMechanism Reveal must use ant colony analogy — never the word \"biofilm\".\n\nEnd with:\n## Production Notes\n- Word count and runtime\n- CTA timestamps\n- 3–5 key slides to design`;\n\n const res = await fetch(\n `${Deno.env.get(\"STEFAN_HOST\")}/api/developers/v1/chat`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${Deno.env.get(\"STEFAN_API_KEY\")}`,\n },\n body: JSON.stringify({ message, selectedModel: \"sonnet\" }),\n },\n );\n const data = await res.json();\n if (!data.output) {\n throw new Error(\"Stefan VSL failed: \" + JSON.stringify(data));\n }\n\n const wordCount = data.output.split(/\\s+/).length;\n console.log(\n ` ✓ ${wordCount.toLocaleString()} words (~${\n Math.round(wordCount / 150)\n } min)`,\n );\n return { script: data.output, wordCount };\n}\n\n// ─── GOOGLE DOCS ──────────────────────────────────────────────────────────────\n\nasync function getGoogleToken(sa: Record): Promise {\n const now = Math.floor(Date.now() / 1000);\n const enc = (o: object) =>\n btoa(JSON.stringify(o)).replace(/=/g, \"\").replace(/\\+/g, \"-\").replace(\n /\\//g,\n \"_\",\n );\n const sigInput = `${enc({ alg: \"RS256\", typ: \"JWT\" })}.${\n enc({\n iss: sa.client_email,\n scope:\n \"https://www.googleapis.com/auth/drive https://www.googleapis.com/auth/documents\",\n aud: \"https://oauth2.googleapis.com/token\",\n exp: now + 3600,\n iat: now,\n })\n }`;\n const keyBuf = Uint8Array.from(\n atob(\n sa.private_key.replace(\n /-----BEGIN PRIVATE KEY-----|-----END PRIVATE KEY-----|\\n/g,\n \"\",\n ),\n ),\n (c) => c.charCodeAt(0),\n );\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n keyBuf,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n new TextEncoder().encode(sigInput),\n );\n const jwt = `${sigInput}.${\n btoa(String.fromCharCode(...new Uint8Array(sig))).replace(/=/g, \"\").replace(\n /\\+/g,\n \"-\",\n ).replace(/\\//g, \"_\")\n }`;\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n const tokenData = await tokenRes.json();\n if (!tokenData.access_token) {\n throw new Error(\"Google auth failed: \" + JSON.stringify(tokenData));\n }\n return tokenData.access_token;\n}\n\nasync function writeGoogleDoc(\n vsl: { script: string; wordCount: number },\n signals: any[],\n): Promise<{ docUrl: string; docTitle: string }> {\n console.log(\"[VSL] Writing Google Doc...\");\n const sa = JSON.parse(Deno.env.get(\"GOOGLE_SA_JSON\")!);\n const token = await getGoogleToken(sa);\n const today = new Date().toISOString().split(\"T\")[0];\n const docTitle = `NaturPets VSL — ${today}`;\n\n const createRes = await fetch(\"https://docs.googleapis.com/v1/documents\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ title: docTitle }),\n });\n const doc = await createRes.json();\n if (!doc.documentId) {\n throw new Error(\"Doc creation failed: \" + JSON.stringify(doc));\n }\n\n await fetch(\n `https://www.googleapis.com/drive/v3/files/${doc.documentId}?addParents=${\n Deno.env.get(\"GOOGLE_DRIVE_FOLDER\")\n }&fields=id`,\n {\n method: \"PATCH\",\n headers: { Authorization: `Bearer ${token}` },\n },\n );\n\n const header = [\n `NaturPets VSL Script — ${today}`,\n `Generated from ${signals.length} strong signals collected over the past 7 days.`,\n \"\",\n \"TOP PAIN POINTS THIS WEEK:\",\n ...signals.filter((s) => s.pain_sentence).slice(0, 5).map((s, i) =>\n `${i + 1}. \"${s.pain_sentence}\" [${s.hook_type}]`\n ),\n \"\",\n \"SOURCE URLS:\",\n ...signals.slice(0, 5).map((s) => `• ${s.title} — ${s.url}`),\n \"\",\n \"═\".repeat(60),\n \"\",\n ].join(\"\\n\");\n\n await fetch(\n `https://docs.googleapis.com/v1/documents/${doc.documentId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n insertText: { location: { index: 1 }, text: header + vsl.script },\n }],\n }),\n },\n );\n\n const docUrl = `https://docs.google.com/document/d/${doc.documentId}/edit`;\n console.log(` ✓ ${docUrl}`);\n return { docUrl, docTitle };\n}\n\n// ─── DISCORD ──────────────────────────────────────────────────────────────────\n\nconst HOOK_EMOJI: Record = {\n \"Colony Reframe\": \"🐜\",\n \"Failed Treatment\": \"💊\",\n \"Symptom Desperation\": \"😰\",\n \"Relapse Cycle\": \"🔄\",\n \"Natural Seeker\": \"🌿\",\n \"Guilt/Helplessness\": \"💔\",\n \"General Pain\": \"📌\",\n \"Not Useful\": \"⬜\",\n};\n\nasync function postResearchToDiscord(\n results: any[],\n analyses: any[],\n totalScanned: number,\n) {\n const webhook = Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!;\n const strong =\n analyses.filter((a) => a.angle_strength === \"🔥 Strong\").length;\n const vslWorthy = analyses.filter((a) => a.vsl_worthy).length;\n\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: [\n `**🐾 NaturPets Research Feed** — ${new Date().toUTCString()}`,\n `Scanned **${totalScanned}** results → **${results.length} new matches**`,\n `🔥 ${strong} strong | 🎬 ${vslWorthy} VSL-worthy`,\n ].join(\"\\n\"),\n }),\n });\n\n if (!results.length) {\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ content: \"_No new matches this run._\" }),\n });\n return;\n }\n\n const useful = results\n .map((r, i) => ({ r, a: analyses[i] }))\n .filter(({ a }) => a?.hook_type !== \"Not Useful\")\n .sort((x, y) => {\n const s = (a: any) =>\n (a?.vsl_worthy ? 2 : 0) + (a?.angle_strength === \"🔥 Strong\" ? 1 : 0);\n return s(y.a) - s(x.a);\n });\n\n const embeds = useful.map(({ r, a }) => {\n const fields: any[] = [];\n if (a.pain_sentence) {\n fields.push({\n name: \"💬 Pain Language\",\n value: `*\"${a.pain_sentence}\"*`,\n inline: false,\n });\n }\n if (a.hook_draft) {\n fields.push({\n name: \"✍️ Hook Draft\",\n value: `**${a.hook_draft}**`,\n inline: false,\n });\n }\n if (a.failed_treatments_mentioned?.length) {\n fields.push({\n name: \"💊 Treatments\",\n value: a.failed_treatments_mentioned.join(\", \"),\n inline: false,\n });\n }\n if (a.note) fields.push({ name: \"🎯 Note\", value: a.note, inline: false });\n fields.push({\n name: \"Signal\",\n value: `${a.angle_strength}${a.vsl_worthy ? \" | 🎬 VSL\" : \"\"}`,\n inline: true,\n });\n fields.push({\n name: \"Type\",\n value: `${HOOK_EMOJI[a.hook_type] ?? \"📌\"} ${a.hook_type}`,\n inline: true,\n });\n return {\n title: r.title?.slice(0, 250),\n url: r.url,\n description: r.description?.slice(0, 180),\n color: r.url?.includes(\"reddit\") ? 0xe74c3c : 0xe67e22,\n fields,\n footer: {\n text: `${\n (() => {\n try {\n return new URL(r.url).hostname.replace(\"www.\", \"\");\n } catch {\n return \"\";\n }\n })()\n } • \"${r.query?.slice(0, 55)}\"`,\n },\n };\n });\n\n for (let i = 0; i < embeds.length; i += 10) {\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ embeds: embeds.slice(i, i + 10) }),\n });\n if (i + 10 < embeds.length) await new Promise((r) => setTimeout(r, 500));\n }\n}\n\nasync function postVSLToDiscord(\n docResult: { docUrl: string; docTitle: string },\n vsl: { wordCount: number },\n signals: any[],\n) {\n const webhook = Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!;\n const treatments = [...new Set(signals.flatMap((s) => s.failed_treatments))]\n .filter(Boolean);\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: `🎬 **NaturPets VSL Script Ready** — ${\n new Date().toLocaleDateString(\"en-US\", {\n month: \"short\",\n day: \"numeric\",\n year: \"numeric\",\n })\n }\\n${docResult.docUrl}`,\n embeds: [{\n title: docResult.docTitle,\n url: docResult.docUrl,\n color: 0x2ecc71,\n fields: [\n {\n name: \"Script stats\",\n value: `${vsl.wordCount.toLocaleString()} words · ~${\n Math.round(vsl.wordCount / 150)\n } min`,\n inline: true,\n },\n {\n name: \"Signals used\",\n value: `${signals.length} strong matches`,\n inline: true,\n },\n {\n name: \"Treatments called out\",\n value: treatments.length\n ? treatments.join(\", \")\n : \"Apoquel, antibiotics, medicated shampoo\",\n inline: false,\n },\n {\n name: \"Top pain points\",\n value: signals.filter((s) =>\n s.pain_sentence\n ).slice(0, 3).map((s, i) => `${i + 1}. *\"${s.pain_sentence}\"*`)\n .join(\"\\n\") || \"—\",\n inline: false,\n },\n ],\n footer: { text: \"NaturPets Intelligence — auto-generated weekly VSL\" },\n timestamp: new Date().toISOString(),\n }],\n }),\n });\n}\n\n// ─── MAIN ─────────────────────────────────────────────────────────────────────\n\nexport default async function handler() {\n await initDb();\n const isMonday = new Date().getDay() === 1;\n console.log(\n `\\n=== NaturPets | ${\n new Date().toLocaleString()\n } | Monday: ${isMonday} ===\\n`,\n );\n\n // ── RESEARCH (every run) ──────────────────────────────────────────────────\n const allResults = await fetchAllResults();\n\n console.log(\"[2/5] Filtering already-seen results...\");\n const newResults = await filterUnseen(allResults);\n console.log(\n ` ✓ ${newResults.length} new (${\n allResults.length - newResults.length\n } already seen)`,\n );\n\n const analyses = await analyzeWithStefan(newResults);\n await saveResults(newResults, analyses);\n\n console.log(\"[4/5] Posting research feed to Discord...\");\n await postResearchToDiscord(newResults, analyses, allResults.length);\n\n // ── VSL GENERATION (Monday only) ─────────────────────────────────────────\n if (isMonday) {\n console.log(\n \"\\n[5/5] Monday run — checking for strong signals to generate VSL...\",\n );\n const signals = await getWeeklyStrongSignals();\n console.log(` ✓ ${signals.length} strong signals in past 7 days`);\n\n if (!signals.length) {\n await fetch(Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content:\n `📭 **NaturPets VSL** — No strong signals this week. Generation skipped.`,\n }),\n });\n } else {\n try {\n const vsl = await generateVSL(signals);\n const docResult = await writeGoogleDoc(vsl, signals);\n await postVSLToDiscord(docResult, vsl, signals);\n } catch (err: any) {\n console.error(\"VSL generation failed:\", err.message);\n await fetch(Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: `❌ NaturPets VSL generation failed: ${err.message}`,\n }),\n });\n }\n }\n }\n\n return new Response(\n `Done. ${newResults.length} new results. Monday VSL: ${isMonday}`,\n { status: 200 },\n );\n}","// NaturPets — Research Feed + Weekly VSL Generator (combined)\n// Single cron val — runs every 12h → 0 */12 * * *\n// Every run: Brave search → Stefan analysis → Discord feed\n// Monday runs only: if strong signals exist → Stefan VSL → Google Doc → Discord\n//\n// Env vars:\n// BRAVE_API_KEY\n// STEFAN_API_KEY\n// STEFAN_HOST\n// DISCORD_WEBHOOK_NATURPETS\n// GOOGLE_SA_JSON (full service account JSON as string)\n// GOOGLE_DRIVE_FOLDER (Drive folder ID)\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ─── CONFIG ──────────────────────────────────────────────────────────────────\n\nconst SEARCH_QUERIES = [\n 'site:reddit.com dog \"yeast infection\" \"nothing works\"',\n 'site:reddit.com dog \"ear infection\" \"keeps coming back\"',\n 'site:reddit.com dog \"yeast\" \"tried everything\"',\n 'site:reddit.com dog \"apoquel\" \"still itching\"',\n 'site:reddit.com dog \"medicated shampoo\" \"came back\"',\n 'site:reddit.com dog \"antibiotics\" \"made it worse\"',\n 'site:reddit.com dog \"paw licking\" \"won\\'t stop\"',\n 'site:reddit.com dog \"frito feet\" OR \"corn chip smell\"',\n 'site:reddit.com dog \"hot spots\" \"relapse\"',\n 'site:reddit.com dog \"itchy skin\" \"vet doesn\\'t know\"',\n 'site:reddit.com dog \"scratching herself bloody\" OR \"scratching until bleeding\"',\n 'site:reddit.com dog \"at my wits end\" itchy',\n 'site:reddit.com dog \"spent thousands\" vet itchy',\n 'site:reddit.com dog yeast \"clears up then comes back\"',\n '\"dog yeast infection\" \"nothing works\" forum',\n '\"dog ear infection keeps coming back\" forum',\n '\"apoquel stopped working\" dog',\n '\"chronic yeast\" dog owner forum',\n '\"dog itching all night\" yeast',\n '\"dog yeast\" \"tried everything\" site:reddit.com OR site:quora.com',\n];\n\nconst RESULTS_PER_QUERY = 5;\n\nconst NATURPETS_CONTEXT = `\nPRODUCT: NaturPets Yeast Control — liquid drops added to dog food. Natural Bacon Flavor.\nMECHANISM: Colony Collapse Protocol — yeast forms biofilm colonies 1000x more resistant than free-floating cells. Every surface treatment (sprays, shampoos, Apoquel, antibiotics) attacks from outside. NaturPets enters via bloodstream — the one direction the colony can't defend against.\nTHREE TEAMS: Colony Killers (Pau D'Arco + Goldenseal) | Environment Shifters (ACV + Ginger) | Rebuilders (Dandelion + Marshmallow Root)\nPRIMARY AVATAR: Dog owner 35–65, cycling through failed treatments for months/years, frustrated, feels like they're failing their dog.\nHOOK TYPES: Colony Reframe | Failed Treatment | Symptom Desperation | Relapse Cycle | Natural Seeker | Guilt/Helplessness\nCOPY RULES: Consequence-first. Call out Apoquel/antibiotics/medicated shampoo by name. Tone: raw, direct, slightly pissed off. NEVER say \"biofilm\" — use ant colony analogy.\nTHE AHA: \"You were never fighting an infection. You were fighting a colony. Every treatment was designed to kill individual cells — while the colony rebuilt behind a fortress wall 1,000x more resistant.\"\n`;\n\nconst VSL_BRIEF = `\nPRODUCT: NaturPets Yeast Control — liquid drops added to dog food. Natural Bacon Flavor.\nPRICE: [INSERT PRICE] | GUARANTEE: [INSERT GUARANTEE]\n\nCORE MECHANISM — COLONY COLLAPSE PROTOCOL:\nDogs don't have a yeast INFECTION. They have a yeast COLONY.\nYeast organizes into biofilms — self-protecting fortresses up to 1,000x more resistant than free-floating cells.\nAnt colony analogy: kill surface ants all day. The colony underground doesn't notice. It just sends more.\nEvery conventional treatment attacks from the OUTSIDE. NaturPets enters via bloodstream — the one direction the colony can't defend.\n\nTHREE TEAMS:\n- Colony Killers (Pau D'Arco + Goldenseal): Penetrate colony from inside, disrupt cellular structure and communication signals.\n- Environment Shifters (ACV + Ginger): Shift internal pH to make gut hostile to yeast. Make recolonization impossible.\n- Rebuilders (Dandelion + Marshmallow Root): Flush mycotoxins when colony collapses. Rebuild gut lining and natural barriers.\n\nPRIMARY AVATAR: Dog owner 35–65, cycling through failed treatments for months/years (Apoquel, antibiotics, medicated shampoos), relapsing over and over. Frustrated, spent significant money, feels like they're failing their dog.\n\nVSL RULES:\n- Hook must work in first 5 seconds — no \"Hi my name is...\" openers\n- NEVER say \"biofilm\" — use ant colony analogy throughout \n- Call out Apoquel, antibiotics, medicated shampoo by name in failure stack\n- Tone: raw, direct, slightly pissed off\n- 3 CTA blocks: soft (~60%), main (after offer), PS (end) — each must restate guarantee\n`;\n\n// ─── BRAVE SEARCH ────────────────────────────────────────────────────────────\n\nasync function runBraveSearch(query: string): Promise {\n const params = new URLSearchParams({\n q: query,\n count: String(RESULTS_PER_QUERY),\n search_lang: \"en\",\n text_decorations: \"false\",\n });\n const res = await fetch(\n `https://api.search.brave.com/res/v1/web/search?${params}`,\n {\n headers: {\n Accept: \"application/json\",\n \"Accept-Encoding\": \"gzip\",\n \"X-Subscription-Token\": Deno.env.get(\"BRAVE_API_KEY\")!,\n },\n },\n );\n if (!res.ok) {\n console.error(`Brave error \"${query}\": ${res.status}`);\n return [];\n }\n const data = await res.json();\n return data?.web?.results ?? [];\n}\n\nasync function fetchAllResults(): Promise {\n console.log(`[1/5] Running ${SEARCH_QUERIES.length} Brave searches...`);\n const seen = new Set();\n const all: any[] = [];\n for (const query of SEARCH_QUERIES) {\n const results = await runBraveSearch(query);\n for (const r of results) {\n const id = btoa(r.url).replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 32);\n if (!seen.has(id) && (r.description?.length ?? 0) > 40) {\n seen.add(id);\n all.push({ ...r, id, query });\n }\n }\n await new Promise((r) => setTimeout(r, 1100));\n }\n console.log(` ✓ ${all.length} unique results`);\n return all;\n}\n\n// ─── SQLITE ───────────────────────────────────────────────────────────────────\n\nasync function initDb() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS naturpets_research (\n id TEXT PRIMARY KEY,\n title TEXT, url TEXT, description TEXT, source TEXT, query TEXT,\n hook_type TEXT, pain_sentence TEXT, hook_draft TEXT,\n failed_treatments TEXT, angle_strength TEXT, vsl_worthy INTEGER,\n note TEXT, seen_at INTEGER\n )\n `);\n}\n\nasync function filterUnseen(results: any[]): Promise {\n if (!results.length) return [];\n const ids = results.map((r) => `'${r.id}'`).join(\",\");\n const existing = await sqlite.execute(\n `SELECT id FROM naturpets_research WHERE id IN (${ids})`,\n );\n const seenIds = new Set(existing.rows.map((row: any) => row[0]));\n return results.filter((r) => !seenIds.has(r.id));\n}\n\nasync function saveResults(results: any[], analyses: any[]) {\n if (!results.length) return;\n const now = Math.floor(Date.now() / 1000);\n for (let i = 0; i < results.length; i++) {\n const r = results[i];\n const a = analyses[i] ?? {};\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO naturpets_research\n (id,title,url,description,source,query,hook_type,pain_sentence,hook_draft,\n failed_treatments,angle_strength,vsl_worthy,note,seen_at)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [\n r.id,\n r.title ?? \"\",\n r.url ?? \"\",\n r.description ?? \"\",\n (() => {\n try {\n return new URL(r.url).hostname.replace(\"www.\", \"\");\n } catch {\n return \"\";\n }\n })(),\n r.query,\n a.hook_type ?? \"\",\n a.pain_sentence ?? \"\",\n a.hook_draft ?? \"\",\n JSON.stringify(a.failed_treatments_mentioned ?? []),\n a.angle_strength ?? \"\",\n a.vsl_worthy ? 1 : 0,\n a.note ?? \"\",\n now,\n ],\n });\n }\n await sqlite.execute(\n `DELETE FROM naturpets_research WHERE seen_at < ${\n Math.floor(Date.now() / 1000) - 30 * 86400\n }`,\n );\n}\n\nasync function getWeeklyStrongSignals(): Promise {\n const cutoff = Math.floor(Date.now() / 1000) - 7 * 86400;\n try {\n const result = await sqlite.execute({\n sql:\n `SELECT * FROM naturpets_research WHERE seen_at > ? AND angle_strength = '🔥 Strong' ORDER BY vsl_worthy DESC, seen_at DESC`,\n args: [cutoff],\n });\n return result.rows.map((row: any) => ({\n id: row[0],\n title: row[1],\n url: row[2],\n description: row[3],\n source: row[4],\n query: row[5],\n hook_type: row[6],\n pain_sentence: row[7],\n hook_draft: row[8],\n failed_treatments: JSON.parse(row[9] || \"[]\"),\n angle_strength: row[10],\n vsl_worthy: row[11] === 1,\n note: row[12],\n seen_at: row[13],\n }));\n } catch {\n return [];\n }\n}\n\n// ─── STEFAN — RESEARCH ANALYSIS ──────────────────────────────────────────────\n\nasync function analyzeWithStefan(results: any[]): Promise {\n if (!results.length) return [];\n console.log(`[3/5] Analyzing ${results.length} results with Stefan...`);\n const BATCH_SIZE = 8;\n const all: any[] = [];\n\n for (let i = 0; i < results.length; i += BATCH_SIZE) {\n const batch = results.slice(i, i + BATCH_SIZE);\n const text = batch.map((r, idx) =>\n `RESULT ${idx + 1} [${\n (() => {\n try {\n return new URL(r.url).hostname;\n } catch {\n return \"unknown\";\n }\n })()\n }]\nTitle: ${r.title}\nSnippet: ${r.description}\nQuery: ${r.query}`\n ).join(\"\\n\\n---\\n\\n\");\n\n const prompt =\n `You are a direct response copywriter analyzing web results for NaturPets Yeast Control.\n\n${NATURPETS_CONTEXT}\n\nAnalyze each result. Return a JSON array, one object per result, same order.\n\nEach object:\n{\n \"hook_type\": \"Colony Reframe\"|\"Failed Treatment\"|\"Symptom Desperation\"|\"Relapse Cycle\"|\"Natural Seeker\"|\"Guilt/Helplessness\"|\"General Pain\"|\"Not Useful\",\n \"pain_sentence\": exact words from snippet max 20 words, empty string if none,\n \"hook_draft\": consequence-first hook max 15 words, empty string if not enough signal,\n \"failed_treatments_mentioned\": array e.g. [\"Apoquel\",\"antibiotics\"] or [],\n \"angle_strength\": \"🔥 Strong\"|\"⚡ Moderate\"|\"❄️ Weak\",\n \"vsl_worthy\": true or false,\n \"note\": one copy insight max 12 words\n}\n\nReturn ONLY the JSON array. No markdown, no preamble.\n\nRESULTS:\n${text}`;\n\n try {\n const res = await fetch(\n `${Deno.env.get(\"STEFAN_HOST\")}/api/developers/v1/chat`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${Deno.env.get(\"STEFAN_API_KEY\")}`,\n },\n body: JSON.stringify({ message: prompt, selectedModel: \"sonnet\" }),\n },\n );\n const data = await res.json();\n if (!data.output) throw new Error(\"No output: \" + JSON.stringify(data));\n all.push(...JSON.parse(data.output.replace(/```json|```/g, \"\").trim()));\n } catch (e: any) {\n console.error(`Stefan analysis batch failed:`, e.message);\n batch.forEach(() =>\n all.push({\n hook_type: \"General Pain\",\n pain_sentence: \"\",\n hook_draft: \"\",\n failed_treatments_mentioned: [],\n angle_strength: \"❄️ Weak\",\n vsl_worthy: false,\n note: `Error: ${e.message?.slice(0, 40)}`,\n })\n );\n }\n if (i + BATCH_SIZE < results.length) {\n await new Promise((r) => setTimeout(r, 500));\n }\n }\n return all;\n}\n\n// ─── STEFAN — VSL GENERATION ──────────────────────────────────────────────────\n\nasync function generateVSL(\n signals: any[],\n): Promise<{ script: string; wordCount: number }> {\n console.log(\n `[VSL] Generating script from ${signals.length} strong signals...`,\n );\n\n const painPoints = signals.filter((s) => s.pain_sentence).slice(0, 8)\n .map((s, i) => `${i + 1}. \"${s.pain_sentence}\" [${s.hook_type}]`).join(\n \"\\n\",\n );\n const hookDrafts = signals.filter((s) => s.hook_draft).slice(0, 5)\n .map((s) => `• ${s.hook_draft}`).join(\"\\n\");\n const treatments = [...new Set(signals.flatMap((s) => s.failed_treatments))]\n .filter(Boolean);\n\n const message =\n `You are an expert direct-response copywriter using RMBC framework by Stefan Georgi.\n\n${VSL_BRIEF}\n\nREAL PAIN LANGUAGE from the web this week:\n${painPoints}\n\nHOOK DRAFTS to consider:\n${hookDrafts}\n\nFAILED TREATMENTS mentioned by real dog owners:\n${treatments.join(\", \") || \"Apoquel, antibiotics, medicated shampoo\"}\n\nWrite a complete standard VSL script (~25–35 min) with this exact structure:\n\n### [0:00–0:30] HOOK\n### [0:30–3:00] PROBLEM AGITATION \n### [3:00–5:00] FAILED SOLUTIONS\n### [5:00–10:00] MECHANISM REVEAL\n### [10:00–18:00] PROOF CASCADE\n### [18:00–22:00] PRODUCT INTRODUCTION\n### [22:00–27:00] OFFER STACK\n### [27:00–29:00] RISK REVERSAL\n### [29:00–32:00] CLOSE + URGENCY\n### [32:00–35:00] PS / SECOND CLOSE\n\nEach section: **Screen:** [direction] **Script:** [voiceover] **→ Transition:** [bridge]\n3 CTA blocks (soft ~60%, main after offer, PS at end) — each must restate guarantee.\nFailed Solutions must name Apoquel, antibiotics, medicated shampoo and explain WHY each fails through the colony lens.\nMechanism Reveal must use ant colony analogy — never the word \"biofilm\".\n\nEnd with:\n## Production Notes\n- Word count and runtime\n- CTA timestamps\n- 3–5 key slides to design`;\n\n const res = await fetch(\n `${Deno.env.get(\"STEFAN_HOST\")}/api/developers/v1/chat`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${Deno.env.get(\"STEFAN_API_KEY\")}`,\n },\n body: JSON.stringify({ message, selectedModel: \"sonnet\" }),\n },\n );\n const data = await res.json();\n if (!data.output) {\n throw new Error(\"Stefan VSL failed: \" + JSON.stringify(data));\n }\n\n const wordCount = data.output.split(/\\s+/).length;\n console.log(\n ` ✓ ${wordCount.toLocaleString()} words (~${\n Math.round(wordCount / 150)\n } min)`,\n );\n return { script: data.output, wordCount };\n}\n\n// ─── GOOGLE DOCS ──────────────────────────────────────────────────────────────\n\nasync function getGoogleToken(sa: Record): Promise {\n const now = Math.floor(Date.now() / 1000);\n const enc = (o: object) =>\n btoa(JSON.stringify(o)).replace(/=/g, \"\").replace(/\\+/g, \"-\").replace(\n /\\//g,\n \"_\",\n );\n const sigInput = `${enc({ alg: \"RS256\", typ: \"JWT\" })}.${\n enc({\n iss: sa.client_email,\n scope:\n \"https://www.googleapis.com/auth/drive https://www.googleapis.com/auth/documents\",\n aud: \"https://oauth2.googleapis.com/token\",\n exp: now + 3600,\n iat: now,\n })\n }`;\n const keyBuf = Uint8Array.from(\n atob(\n sa.private_key.replace(\n /-----BEGIN PRIVATE KEY-----|-----END PRIVATE KEY-----|\\n/g,\n \"\",\n ),\n ),\n (c) => c.charCodeAt(0),\n );\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n keyBuf,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n new TextEncoder().encode(sigInput),\n );\n const jwt = `${sigInput}.${\n btoa(String.fromCharCode(...new Uint8Array(sig))).replace(/=/g, \"\").replace(\n /\\+/g,\n \"-\",\n ).replace(/\\//g, \"_\")\n }`;\n const tokenRes = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n const tokenData = await tokenRes.json();\n if (!tokenData.access_token) {\n throw new Error(\"Google auth failed: \" + JSON.stringify(tokenData));\n }\n return tokenData.access_token;\n}\n\nasync function writeGoogleDoc(\n vsl: { script: string; wordCount: number },\n signals: any[],\n): Promise<{ docUrl: string; docTitle: string }> {\n console.log(\"[VSL] Writing Google Doc...\");\n const sa = JSON.parse(Deno.env.get(\"GOOGLE_SA_JSON\")!);\n const token = await getGoogleToken(sa);\n const today = new Date().toISOString().split(\"T\")[0];\n const docTitle = `NaturPets VSL — ${today}`;\n\n const createRes = await fetch(\"https://docs.googleapis.com/v1/documents\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ title: docTitle }),\n });\n const doc = await createRes.json();\n if (!doc.documentId) {\n throw new Error(\"Doc creation failed: \" + JSON.stringify(doc));\n }\n\n await fetch(\n `https://www.googleapis.com/drive/v3/files/${doc.documentId}?addParents=${\n Deno.env.get(\"GOOGLE_DRIVE_FOLDER\")\n }&fields=id`,\n {\n method: \"PATCH\",\n headers: { Authorization: `Bearer ${token}` },\n },\n );\n\n const header = [\n `NaturPets VSL Script — ${today}`,\n `Generated from ${signals.length} strong signals collected over the past 7 days.`,\n \"\",\n \"TOP PAIN POINTS THIS WEEK:\",\n ...signals.filter((s) => s.pain_sentence).slice(0, 5).map((s, i) =>\n `${i + 1}. \"${s.pain_sentence}\" [${s.hook_type}]`\n ),\n \"\",\n \"SOURCE URLS:\",\n ...signals.slice(0, 5).map((s) => `• ${s.title} — ${s.url}`),\n \"\",\n \"═\".repeat(60),\n \"\",\n ].join(\"\\n\");\n\n await fetch(\n `https://docs.googleapis.com/v1/documents/${doc.documentId}:batchUpdate`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n requests: [{\n insertText: { location: { index: 1 }, text: header + vsl.script },\n }],\n }),\n },\n );\n\n const docUrl = `https://docs.google.com/document/d/${doc.documentId}/edit`;\n console.log(` ✓ ${docUrl}`);\n return { docUrl, docTitle };\n}\n\n// ─── DISCORD ──────────────────────────────────────────────────────────────────\n\nconst HOOK_EMOJI: Record = {\n \"Colony Reframe\": \"🐜\",\n \"Failed Treatment\": \"💊\",\n \"Symptom Desperation\": \"😰\",\n \"Relapse Cycle\": \"🔄\",\n \"Natural Seeker\": \"🌿\",\n \"Guilt/Helplessness\": \"💔\",\n \"General Pain\": \"📌\",\n \"Not Useful\": \"⬜\",\n};\n\nasync function postResearchToDiscord(\n results: any[],\n analyses: any[],\n totalScanned: number,\n) {\n const webhook = Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!;\n const strong =\n analyses.filter((a) => a.angle_strength === \"🔥 Strong\").length;\n const vslWorthy = analyses.filter((a) => a.vsl_worthy).length;\n\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: [\n `**🐾 NaturPets Research Feed** — ${new Date().toUTCString()}`,\n `Scanned **${totalScanned}** results → **${results.length} new matches**`,\n `🔥 ${strong} strong | 🎬 ${vslWorthy} VSL-worthy`,\n ].join(\"\\n\"),\n }),\n });\n\n if (!results.length) {\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ content: \"_No new matches this run._\" }),\n });\n return;\n }\n\n const useful = results\n .map((r, i) => ({ r, a: analyses[i] }))\n .filter(({ a }) => a?.hook_type !== \"Not Useful\")\n .sort((x, y) => {\n const s = (a: any) =>\n (a?.vsl_worthy ? 2 : 0) + (a?.angle_strength === \"🔥 Strong\" ? 1 : 0);\n return s(y.a) - s(x.a);\n });\n\n const embeds = useful.map(({ r, a }) => {\n const fields: any[] = [];\n if (a.pain_sentence) {\n fields.push({\n name: \"💬 Pain Language\",\n value: `*\"${a.pain_sentence}\"*`,\n inline: false,\n });\n }\n if (a.hook_draft) {\n fields.push({\n name: \"✍️ Hook Draft\",\n value: `**${a.hook_draft}**`,\n inline: false,\n });\n }\n if (a.failed_treatments_mentioned?.length) {\n fields.push({\n name: \"💊 Treatments\",\n value: a.failed_treatments_mentioned.join(\", \"),\n inline: false,\n });\n }\n if (a.note) fields.push({ name: \"🎯 Note\", value: a.note, inline: false });\n fields.push({\n name: \"Signal\",\n value: `${a.angle_strength}${a.vsl_worthy ? \" | 🎬 VSL\" : \"\"}`,\n inline: true,\n });\n fields.push({\n name: \"Type\",\n value: `${HOOK_EMOJI[a.hook_type] ?? \"📌\"} ${a.hook_type}`,\n inline: true,\n });\n return {\n title: r.title?.slice(0, 250),\n url: r.url,\n description: r.description?.slice(0, 180),\n color: r.url?.includes(\"reddit\") ? 0xe74c3c : 0xe67e22,\n fields,\n footer: {\n text: `${\n (() => {\n try {\n return new URL(r.url).hostname.replace(\"www.\", \"\");\n } catch {\n return \"\";\n }\n })()\n } • \"${r.query?.slice(0, 55)}\"`,\n },\n };\n });\n\n for (let i = 0; i < embeds.length; i += 10) {\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ embeds: embeds.slice(i, i + 10) }),\n });\n if (i + 10 < embeds.length) await new Promise((r) => setTimeout(r, 500));\n }\n}\n\nasync function postVSLToDiscord(\n docResult: { docUrl: string; docTitle: string },\n vsl: { wordCount: number },\n signals: any[],\n) {\n const webhook = Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!;\n const treatments = [...new Set(signals.flatMap((s) => s.failed_treatments))]\n .filter(Boolean);\n await fetch(webhook, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: `🎬 **NaturPets VSL Script Ready** — ${\n new Date().toLocaleDateString(\"en-US\", {\n month: \"short\",\n day: \"numeric\",\n year: \"numeric\",\n })\n }\\n${docResult.docUrl}`,\n embeds: [{\n title: docResult.docTitle,\n url: docResult.docUrl,\n color: 0x2ecc71,\n fields: [\n {\n name: \"Script stats\",\n value: `${vsl.wordCount.toLocaleString()} words · ~${\n Math.round(vsl.wordCount / 150)\n } min`,\n inline: true,\n },\n {\n name: \"Signals used\",\n value: `${signals.length} strong matches`,\n inline: true,\n },\n {\n name: \"Treatments called out\",\n value: treatments.length\n ? treatments.join(\", \")\n : \"Apoquel, antibiotics, medicated shampoo\",\n inline: false,\n },\n {\n name: \"Top pain points\",\n value: signals.filter((s) =>\n s.pain_sentence\n ).slice(0, 3).map((s, i) => `${i + 1}. *\"${s.pain_sentence}\"*`)\n .join(\"\\n\") || \"—\",\n inline: false,\n },\n ],\n footer: { text: \"NaturPets Intelligence — auto-generated weekly VSL\" },\n timestamp: new Date().toISOString(),\n }],\n }),\n });\n}\n\n// ─── MAIN ─────────────────────────────────────────────────────────────────────\n\nexport default async function handler() {\n await initDb();\n console.log(`\\n=== NaturPets | ${new Date().toLocaleString()} ===\\n`);\n\n // ── RESEARCH (every run) ──────────────────────────────────────────────────\n const allResults = await fetchAllResults();\n\n console.log(\"[2/5] Filtering already-seen results...\");\n const newResults = await filterUnseen(allResults);\n console.log(\n ` ✓ ${newResults.length} new (${\n allResults.length - newResults.length\n } already seen)`,\n );\n\n const analyses = await analyzeWithStefan(newResults);\n await saveResults(newResults, analyses);\n\n console.log(\"[4/5] Posting research feed to Discord...\");\n await postResearchToDiscord(newResults, analyses, allResults.length);\n\n // ── VSL GENERATION (every run) ───────────────────────────────────────────\n console.log(\"\\n[5/5] Generating daily VSL...\");\n let signals = await getWeeklyStrongSignals();\n if (!signals.length) {\n const cutoff = Math.floor(Date.now() / 1000) - 7 * 86400;\n const result = await sqlite.execute({\n sql:\n `SELECT * FROM naturpets_research WHERE seen_at > ? ORDER BY seen_at DESC LIMIT 20`,\n args: [cutoff],\n });\n signals = result.rows.map((row: any) => ({\n id: row[0],\n title: row[1],\n url: row[2],\n description: row[3],\n source: row[4],\n query: row[5],\n hook_type: row[6],\n pain_sentence: row[7],\n hook_draft: row[8],\n failed_treatments: JSON.parse(row[9] || \"[]\"),\n angle_strength: row[10],\n vsl_worthy: row[11] === 1,\n note: row[12],\n seen_at: row[13],\n }));\n console.log(\n ` ℹ No strong signals yet — using ${signals.length} recent results as context`,\n );\n } else {\n console.log(` ✓ ${signals.length} strong signals found`);\n }\n\n try {\n const vsl = await generateVSL(signals);\n const docResult = await writeGoogleDoc(vsl, signals);\n await postVSLToDiscord(docResult, vsl, signals);\n } catch (err: any) {\n console.error(\"VSL generation failed:\", err.message);\n await fetch(Deno.env.get(\"DISCORD_WEBHOOK_NATURPETS\")!, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n content: `❌ NaturPets VSL generation failed: ${err.message}`,\n }),\n });\n }\n\n return new Response(\n `Done. ${newResults.length} new results. VSL generated.`,\n { status: 200 },\n );\n}","createdAt",["D",1776592213082],"branchVersion","branchId","52165ba2-3bcf-11f1-b106-42b51c65c3df","id","5215bfc6-3bcf-11f1-b106-42b51c65c3df","stefanvslmaker",["D",1776589704661],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","e31d055f-5721-478c-983c-8f41414e87c1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d9bf8-21ac-72be-9b53-f89d3385e88a","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","voxvexus","handle","displayName","avatar","","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":147,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":148,"_78":149,"_80":150,"_82":25},"tree",[142],"files",[142],"counts",{"_131":60,"_132":133,"_134":60,"_135":136,"_137":138},"contents",[123],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":124,"_32":28,"_30":31,"_125":-5,"_41":42,"_40":14,"_126":25,"_38":127,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_27":130},"293a6592-3bd5-11f1-b85a-42b51c65c3df","parentId","latest",["D",1776592213082],9,"label",[28],"pulls","branches",1,"forks","envVars",{"_139":128,"_141":60},"connections",{"_139":133,"_140":60},"count","unfilledCount","emptyCount",{"_43":124,"_32":28,"_30":31,"_125":-5,"_41":42,"_40":14,"_126":25,"_38":143,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_144":145,"_27":146},["D",1776592213082],"children",[],[28],["D",1776589704661],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_120":184,"_185":186,"_187":188,"_189":25,"_190":25,"_191":25,"_192":193,"_194":-5,"_195":-7,"_196":-7,"_197":60,"_198":25,"_199":25,"_200":-5,"_201":25,"_202":25,"_203":25,"_204":-5},"ENV",{"_155":156,"_157":158,"_159":84,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v10