[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_209":210,"_211":212},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":102,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"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":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",50,"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","radar.ts","latestPath","fileId","2cdfb542-b19d-11f1-aef9-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Business context lives in the ABOUT_ME env var (private). This file is public.\nconst env = (k: string, d = \"\") => Deno.env.get(k) ?? d;\nconst SUBS = env(\"SUBS\",\n // tool/builder subs (karma) + where owners of small b2b service firms ask questions\n \"n8n,ClaudeAI,AI_Agents,automation,nocode,zapier,hubspot,CRM,\" +\n \"msp,agency,marketingagency,consulting,recruiting,\" +\n \"sales,B2BSales,salesops,SalesOperations,RevOps,coldemail,LeadGeneration,\" +\n \"smallbusiness,Entrepreneur,EntrepreneurRideAlong,sweatystartup\",\n).split(\",\").map((s) => s.trim()).filter(Boolean);\nconst TRIAGE_MODEL = env(\"TRIAGE_MODEL\", \"claude-haiku-4-5-20251001\");\nconst WRITER_MODEL = env(\"WRITER_MODEL\", \"claude-sonnet-5\");\nconst MAX_DRAFTS = 3;\n\nexport type Post = { id: string; sub: string; title: string; body: string; author: string; url: string; created: number };\ntype Opts = { ignoreHours?: boolean; maxAgeMin?: number; dryRun?: boolean; skipSeen?: boolean; noDb?: boolean; maxDrafts?: number };\nconst USAGE: Record = {};\nconst PRICE: Record = { \"claude-haiku-4-5-20251001\": [1, 5], \"claude-sonnet-5\": [2, 10] }; // $/MTok in, out\nconst usageReport = () => {\n let usd = 0;\n for (const [m, u] of Object.entries(USAGE)) { const p = PRICE[m] ?? [0, 0]; usd += (u.in * p[0] + u.out * p[1]) / 1e6; }\n return { byModel: USAGE, usd: Number(usd.toFixed(4)) };\n};\n\nexport function activeNow(d = new Date()) {\n const p = new Intl.DateTimeFormat(\"en-GB\", { timeZone: \"Europe/Amsterdam\", weekday: \"short\", hour: \"numeric\", hour12: false }).formatToParts(d);\n const wd = p.find((x) => x.type === \"weekday\")!.value;\n const h = Number(p.find((x) => x.type === \"hour\")!.value) % 24;\n if (wd === \"Sat\" || wd === \"Sun\") return h >= 8 && h < 23;\n return (h >= 7 && h < 9) || (h >= 17 && h < 23);\n}\n\nasync function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_posts (\n id TEXT PRIMARY KEY, sub TEXT, title TEXT, url TEXT, created INTEGER, seen_at INTEGER,\n stage TEXT, reason TEXT, draft TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_kv (k TEXT PRIMARY KEY, v TEXT)`);\n}\n\n// ---------- sources ----------\nasync function fromArctic(afterSec: number): Promise {\n // Arctic Shift 429s on bursts: 3 at a time, one retry per sub, a failed sub doesn't sink the run.\n const one = async (s: string): Promise => {\n let r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${afterSec}&limit=100&sort=desc`);\n if (r.status === 429) {\n await new Promise((ok) => setTimeout(ok, 2000));\n r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${afterSec}&limit=100&sort=desc`);\n }\n if (!r.ok) { failed.push(`${s}:${r.status}`); return []; }\n const j = await r.json();\n return (j.data ?? []).filter((p: any) => !p.removed_by_category && p.selftext !== \"[removed]\" && p.author !== \"AutoModerator\")\n .map((p: any) => ({\n id: p.id, sub: p.subreddit, title: p.title ?? \"\", body: p.selftext ?? \"\", author: p.author ?? \"\",\n url: `https://www.reddit.com${p.permalink ?? `/comments/${p.id}`}`, created: p.created_utc,\n }));\n };\n const failed: string[] = [];\n const out: Post[] = [];\n for (let i = 0; i < SUBS.length; i += 3) out.push(...(await Promise.all(SUBS.slice(i, i + 3).map(one))).flat());\n if (failed.length) console.log(\"arctic failed subs\", failed.join(\" \"));\n if (failed.length > SUBS.length / 2) throw new Error(\"arctic mostly failing\");\n return out;\n}\n\nconst unescape = (s: string) => s.replace(/</g, \"<\").replace(/>/g, \">\").replace(/"/g, '\"').replace(/'/g, \"'\").replace(/&/g, \"&\");\nasync function fromRss(afterSec: number): Promise {\n const r = await fetch(`https://www.reddit.com/r/${SUBS.join(\"+\")}/new/.rss?limit=100`, { headers: { \"User-Agent\": \"web:reddit-radar:0.1\" } });\n if (!r.ok) throw new Error(`rss ${r.status}`);\n const t = await r.text();\n return t.split(\"\").slice(1).map((e) => {\n const g = (re: RegExp) => e.match(re)?.[1] ?? \"\";\n const html = unescape(g(/([\\s\\S]*?)<\\/content>/));\n return {\n id: g(/t3_(\\w+)<\\/id>/), sub: g(/([\\s\\S]*?)<\\/title>/)),\n body: html.replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").replace(/submitted by .*$/, \"\").trim(),\n author: g(/\\/u\\/(.*?)<\\/name>/), url: g(/(.*?)<\\/published>/)) / 1000,\n };\n }).filter((p) => p.id && p.created > afterSec);\n}\n\n// ---------- llm ----------\nasync function claude(model: string, system: string, user: string, maxTokens = 800): Promise {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": env(\"ANTHROPIC_API_KEY\"), \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model, max_tokens: maxTokens, system, messages: [{ role: \"user\", content: user }] }),\n });\n if (!r.ok) throw new Error(`anthropic ${r.status} ${await r.text()}`);\n const j = await r.json();\n const u = (USAGE[model] ??= { calls: 0, in: 0, out: 0 });\n u.calls++; u.in += j.usage?.input_tokens ?? 0; u.out += j.usage?.output_tokens ?? 0;\n return j.content.filter((c: any) => c.type === \"text\").map((c: any) => c.text).join(\"\");\n}\nconst json = (s: string) => JSON.parse(s.slice(s.indexOf(\"{\"), s.lastIndexOf(\"}\") + 1));\n\nconst GATE_RULES = `\nThe goal is being genuinely useful to the poster and earning karma on a new account. Never an angle to sell. A comment that looks like it's fishing for clients gets downvoted and hurts the account.\n\nA post is worth replying to ONLY if ALL are true:\n1. The poster wants help: a real question, a request for a tool/approach, or a specific problem they're stuck on (\"what do you use for\", \"how do you handle\", \"is there a tool that\", \"how would I\", \"has anyone solved\", \"why does X keep doing Y\"). A question tacked onto the end of an essay, a poll, or a \"curious what you all think\" discussion prompt does not count.\n2. He can give a genuinely useful, specific answer from real experience in ABOUT: the automation tools he's used, the systems he built, OR sales craft from his own job. It does NOT have to be about something he sells. A plain n8n bug, a crm workflow question or a stalled-deal question all count if his answer would actually help.\n3. It is NOT: self-promotion or a disguised pitch (\"feedback on my app\", \"we help businesses with X\"), a launch/showcase/write-up/victory lap, hiring or looking for work, a rant, a mental-health/personal-life post, job-hunting or career switching, taxes/legal/payroll/accounting, B2C product questions with no sales or automation angle, deep software engineering, or tools in his NEVER USED list.\nJudge the question, not the subreddit: a tool-agnostic automation question in r/zapier is fine even though he doesn't use zapier.\nIf a good answer needs experience he doesn't have (hiring and comp plans, fundraising, pricing a SaaS, B2C marketing, a tool he's never used), it fails. When genuinely torn, say no.`;\n\nasync function triageTitles(posts: Post[], about: string): Promise {\n const list = posts.map((p, i) => `${i} | r/${p.sub} | ${p.title} | ${p.body.slice(0, 200).replace(/\\s+/g, \" \")}`).join(\"\\n\");\n const out = await claude(TRIAGE_MODEL,\n `You pre-screen Reddit posts for a solo automation builder. From title + opening only, pick posts that COULD pass the gates below and deserve a full read. Include every post whose title/opening is a genuine help question in his areas, even if you're unsure; the full read does the strict filtering. Skip showcases, write-ups, framework essays, opinion pieces, discussion prompts and anything clearly off-topic.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nReturn ONLY JSON: {\"read\":[indices]}`,\n list, 300);\n const idx: number[] = json(out).read ?? [];\n return idx.map((i) => posts[i]).filter(Boolean);\n}\n\nasync function decide(p: Post, about: string): Promise<{ reply: boolean; reason: string; angle: string; buyer: boolean }> {\n const out = await claude(TRIAGE_MODEL,\n `You decide whether a solo automation builder should answer this Reddit post with a helpful comment.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nAlso judge \"buyer\": true if the poster reads like an owner/decision-maker of a real B2B service business (not a hobbyist, student, or individual rep).\\nReturn ONLY JSON: {\"reply\":true|false,\"reason\":\"one short sentence\",\"angle\":\"what from his proven ground he'd draw on, or empty\",\"buyer\":true|false}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}`, 200);\n return json(out);\n}\n\n// Voice = the my-voice skill's Reddit register, compressed. Few-shot examples carry the style cheaper than rules.\nconst VOICE = `You're a guy who builds sales automations, scrolling reddit on his phone. You know the answer, so you drop a quick note and move on.\n\nLENGTH: 1 to 3 sentences. Usually 20-50 words. Never over 70. No paragraphs unless it's two short lines.\n\nHOW IT READS:\n- straight into the advice. no intro, no framing the problem, no \"the real issue is\", no wrap-up line.\n- one or two concrete things: a tool, a node, a setting, the order to do it in, or the thing that'll break.\n- lazy reddit typing. lowercase is fine, crm / ai / api / n8n / hubspot always lowercase. contractions. plain small words.\n- \"i\", never \"we\". no company, no link, no \"dm me\", no \"happy to help\", no offer of any kind.\n- mention your own build only if it's the point, in half a sentence, and only what ABOUT literally says. anything else is advice (\"i'd...\", \"usually...\"), never a story, number, routine or result you made up.\n- a small imperfection is fine. a run-on is fine.\n\nNEVER (ai tells): em or en dashes, colons that set up a reveal, \"it's not X, it's Y\" / \"isn't about X, it's about Y\", lists of three, bullet points, bold, headers, rhetorical questions, \"honestly\", \"great question\", \"the key is\", \"game-changer\", \"leverage\", \"robust\", \"seamless\", \"crucial\", \"essentially\", \"ultimately\", \"delve\", \"worth noting\", \"that said\", \"hope this helps\", \"in my experience\", restating their question, a closing summary.\n\nSTYLE EXAMPLES (style only, never reuse their facts):\nQ: how do you get call notes into the crm without typing them up\nA: fireflies has a hubspot sync but it just dumps the whole summary as a note. i run the transcript through claude and have it fill the actual deal fields instead, way more useful\n\nQ: n8n webhook keeps triggering twice?\nA: check you haven't got the test url and the production url both registered somewhere, that's almost always it\n\nQ: is there a tool that writes follow ups after sales calls\nA: most call recorders do a generic one now. if you want it to sound like you, feed it a few of your old emails as examples, the defaults read like a robot`;\n\nasync function draft(p: Post, angle: string, about: string): Promise {\n const out = await claude(WRITER_MODEL,\n `${VOICE}\\n\\nABOUT (the only experience you may claim):\\n${about}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}\\n\\n---\\nangle: ${angle}\\nwrite the comment. output only the comment.`, 250);\n let text = out;\n if (text.split(/\\s+/).length > 75) {\n text = await claude(WRITER_MODEL, VOICE, `this reddit comment is too long. cut it to under 50 words, keep only the single most useful bit, same casual voice. output only the comment.\\n\\n${out}`, 150);\n }\n return text\n .replace(/\\s*[—–]\\s*/g, \", \")\n .replace(/^(honestly|great question)[,.!]?\\s+/i, \"\")\n .trim();\n}\n\n// ---------- telegram ----------\nconst esc = (s: string) => s.replace(/&/g, \"&\").replace(//g, \">\");\nasync function tg(text: string, html = false) {\n const r = await fetch(`https://api.telegram.org/bot${env(\"TELEGRAM_BOT_TOKEN\")}/sendMessage`, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: env(\"TELEGRAM_CHAT_ID\"), text, ...(html ? { parse_mode: \"HTML\" } : {}), link_preview_options: { is_disabled: true } }),\n });\n if (!r.ok) throw new Error(`telegram ${r.status} ${await r.text()}`);\n}\n\n// Test helper: draft + send one alert for a given post, skipping the gates.\nexport async function testAlert(p: Post, angle: string) {\n const text = await draft(p, angle, env(\"ABOUT_ME\"));\n const msg = `r/${esc(p.sub)} · TEST\\n${esc(p.title)}\\nformat test, gates skipped\\n\\n

${esc(text)}

`;\n await tg(msg, true);\n return text;\n}\n\n// ---------- main ----------\nexport async function run(opts: Opts = {}) {\n if (!opts.ignoreHours && !activeNow()) return { skipped: \"outside hours\" };\n await initDb();\n const about = env(\"ABOUT_ME\") + \"\\n\\n\" + env(\"ABOUT_ME_SALES\");\n if (!about) throw new Error(\"ABOUT_ME env var missing\");\n const now = Date.now() / 1000;\n const after = Math.floor(now - (opts.maxAgeMin ?? 40) * 60);\n\n let posts: Post[] = [], source = \"arctic\";\n try { posts = await fromArctic(after); }\n catch (e) {\n console.log(\"arctic failed\", String(e));\n try { posts = await fromRss(after); source = \"rss\"; }\n catch (e2) { console.log(\"rss failed\", String(e2)); await health(false, opts); return { error: \"all sources failed\" }; }\n }\n await health(true, opts);\n\n // dedupe\n if (!opts.skipSeen && posts.length) {\n const seen = await sqlite.execute({ sql: `SELECT id FROM radar_posts WHERE id IN (${posts.map(() => \"?\").join(\",\")})`, args: posts.map((p) => p.id) });\n const s = new Set(seen.rows.map((r: any) => r.id));\n posts = posts.filter((p) => !s.has(p.id));\n }\n posts = [...new Map(posts.map((p) => [p.id, p])).values()];\n // crossposts: same title in several subs, keep one\n posts = [...new Map(posts.map((p) => [p.title.toLowerCase().replace(/\\W+/g, \"\"), p])).values()];\n // free prefilter for obvious showcases/launches/hiring before any tokens are spent\n const junk = /^((i|we) )?(just )?(built|made|created|launched|shipped|automated)\\b|^finally launched|^feedback (for|on) |^how (i|we) |^\\[?(hiring|for hire|offer|promo)|looking for (beta|testers)|^(meet|introducing)\\b/i;\n const prefiltered = posts.filter((p) => junk.test(p.title.trim()) || /^https?:\\/\\/\\S+$/.test(p.body.trim()));\n posts = posts.filter((p) => !prefiltered.includes(p));\n console.log(`${source}: ${posts.length} new posts`);\n if (!posts.length) return { source, new: 0 };\n\n const candidates = await triageTitles(posts, about);\n const decisions = await Promise.all(candidates.map(async (p) => ({ p, d: await decide(p, about).catch((e) => ({ reply: false, reason: \"decide error \" + e, angle: \"\", buyer: false })) })));\n // account safety: max 2 alerts per sub per day (Amsterdam date), so he never bursts comments in one sub\n const sentToday: Record = {};\n if (!opts.noDb) {\n const r = await sqlite.execute({ sql: `SELECT sub, COUNT(*) n FROM radar_posts WHERE stage='sent' AND seen_at > ? GROUP BY sub`, args: [Math.floor(now - 20 * 3600)] });\n for (const row of r.rows as any[]) sentToday[String(row.sub).toLowerCase()] = Number(row.n);\n }\n const passes = decisions.filter((x) => x.d.reply)\n .sort((a, b) => Number(b.d.buyer) - Number(a.d.buyer))\n .filter((x) => { const k = x.p.sub.toLowerCase(); sentToday[k] = (sentToday[k] ?? 0) + 1; return sentToday[k] <= 2; })\n .slice(0, opts.maxDrafts ?? MAX_DRAFTS);\n const drafted = await Promise.all(passes.map(async (x) => ({ ...x, text: await draft(x.p, x.d.angle, about) })));\n\n for (const x of drafted) {\n const age = Math.round((now - x.p.created) / 60);\n // One message: tap the link to open Reddit, tap the code block to copy the draft.\n const msg = `${x.d.buyer ? \"💼 BUYER · \" : \"\"}r/${esc(x.p.sub)} · ${age} min old\\n` +\n `${esc(x.p.title)}\\n${esc(x.d.reason)}\\n\\n

${esc(x.text)}

`;\n if (opts.dryRun) console.log(\"---\\n\" + msg);\n else await tg(msg, true);\n }\n\n const report = {\n source, fetched: posts.length, readInFull: candidates.length, passed: decisions.filter((x) => x.d.reply).length, drafted: drafted.length,\n usage: usageReport(),\n drafts: drafted.map((x) => ({ title: x.p.title, text: x.text })),\n fullReads: decisions.map((x) => ({ sub: x.p.sub, title: x.p.title, reply: x.d.reply, buyer: x.d.buyer, reason: x.d.reason })),\n titleRejects: posts.filter((p) => !candidates.includes(p)).map((p) => `r/${p.sub} | ${p.title} | ${p.body.slice(0, 280).replace(/\\s+/g, \" \")} | ${p.url}`),\n prefiltered: prefiltered.map((p) => `r/${p.sub}: ${p.title}`),\n };\n console.log(`usage ${JSON.stringify(report.usage)}`);\n if (opts.noDb) return report;\n\n if (!opts.dryRun) {\n const stage = (p: Post) => drafted.find((x) => x.p.id === p.id) ? \"sent\" : decisions.find((x) => x.p.id === p.id) ? \"rejected_full\" : \"rejected_title\";\n await sqlite.batch(posts.map((p) => {\n const dec = decisions.find((x) => x.p.id === p.id);\n return { sql: `INSERT OR IGNORE INTO radar_posts VALUES (?,?,?,?,?,?,?,?,?)`,\n args: [p.id, p.sub, p.title, p.url, Math.floor(p.created), Math.floor(now), stage(p), dec?.d.reason ?? null, drafted.find((x) => x.p.id === p.id)?.text ?? null] };\n }));\n }\n return { source, new: posts.length, read: candidates.length, passed: passes.length };\n}\n\nasync function health(ok: boolean, opts: Opts) {\n const r = await sqlite.execute(`SELECT v FROM radar_kv WHERE k='fails'`);\n const fails = ok ? 0 : Number(r.rows[0]?.v ?? 0) + 1;\n await sqlite.execute({ sql: `INSERT OR REPLACE INTO radar_kv VALUES ('fails', ?)`, args: [String(fails)] });\n if (fails === 4 && !opts.dryRun) await tg(\"Reddit radar: both sources failing for 4 runs in a row. Check Val Town logs.\");\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Business context lives in the ABOUT_ME env var (private). This file is public.\nconst env = (k: string, d = \"\") => Deno.env.get(k) ?? d;\n// Phase 1 (karma warm-up, from 2026-09-16): tool subs only. Big subs auto-remove low-karma comments.\nconst TOOL_SUBS = \"n8n,ClaudeAI,AI_Agents,automation,nocode,zapier,hubspot,CRM\";\n// Phase 2 (add back once karma allows, review ~2026-09-30):\nexport const BUYER_SUBS = \"msp,agency,marketingagency,consulting,recruiting,sales,B2BSales,salesops,SalesOperations,RevOps,coldemail,LeadGeneration,smallbusiness,Entrepreneur,EntrepreneurRideAlong,sweatystartup\";\nconst SUBS = env(\"SUBS\", TOOL_SUBS).split(\",\").map((s) => s.trim()).filter(Boolean);\n// Only alert on posts this fresh: the poster is still in the thread. Cron is 15 min, so lookback 20 gives overlap.\nconst MAX_AGE_MIN = 20;\nconst TRIAGE_MODEL = env(\"TRIAGE_MODEL\", \"claude-haiku-4-5-20251001\");\nconst WRITER_MODEL = env(\"WRITER_MODEL\", \"claude-sonnet-5\");\nconst MAX_DRAFTS = 3;\n\nexport type Post = { id: string; sub: string; title: string; body: string; author: string; url: string; created: number };\ntype Opts = { ignoreHours?: boolean; maxAgeMin?: number; dryRun?: boolean; skipSeen?: boolean; noDb?: boolean; maxDrafts?: number };\nconst USAGE: Record = {};\nconst PRICE: Record = { \"claude-haiku-4-5-20251001\": [1, 5], \"claude-sonnet-5\": [2, 10] }; // $/MTok in, out\nconst usageReport = () => {\n let usd = 0;\n for (const [m, u] of Object.entries(USAGE)) { const p = PRICE[m] ?? [0, 0]; usd += (u.in * p[0] + u.out * p[1]) / 1e6; }\n return { byModel: USAGE, usd: Number(usd.toFixed(4)) };\n};\n\nexport function activeNow(d = new Date()) {\n const p = new Intl.DateTimeFormat(\"en-GB\", { timeZone: \"Europe/Amsterdam\", weekday: \"short\", hour: \"numeric\", hour12: false }).formatToParts(d);\n const wd = p.find((x) => x.type === \"weekday\")!.value;\n const h = Number(p.find((x) => x.type === \"hour\")!.value) % 24;\n if (wd === \"Sat\" || wd === \"Sun\") return h >= 8 && h < 23;\n return (h >= 7 && h < 9) || (h >= 17 && h < 23);\n}\n\nasync function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_posts (\n id TEXT PRIMARY KEY, sub TEXT, title TEXT, url TEXT, created INTEGER, seen_at INTEGER,\n stage TEXT, reason TEXT, draft TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_kv (k TEXT PRIMARY KEY, v TEXT)`);\n}\n\n// ---------- sources ----------\nasync function fromArctic(afterSec: number): Promise {\n // Arctic Shift 429s on bursts: 3 at a time, one retry per sub, a failed sub doesn't sink the run.\n const one = async (s: string): Promise => {\n let r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${afterSec}&limit=100&sort=desc`);\n if (r.status === 429) {\n await new Promise((ok) => setTimeout(ok, 2000));\n r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${afterSec}&limit=100&sort=desc`);\n }\n if (!r.ok) { failed.push(`${s}:${r.status}`); return []; }\n const j = await r.json();\n return (j.data ?? []).filter((p: any) => !p.removed_by_category && p.selftext !== \"[removed]\" && p.author !== \"AutoModerator\")\n .map((p: any) => ({\n id: p.id, sub: p.subreddit, title: p.title ?? \"\", body: p.selftext ?? \"\", author: p.author ?? \"\",\n url: `https://www.reddit.com${p.permalink ?? `/comments/${p.id}`}`, created: p.created_utc,\n }));\n };\n const failed: string[] = [];\n const out: Post[] = [];\n for (let i = 0; i < SUBS.length; i += 3) out.push(...(await Promise.all(SUBS.slice(i, i + 3).map(one))).flat());\n if (failed.length) console.log(\"arctic failed subs\", failed.join(\" \"));\n if (failed.length > SUBS.length / 2) throw new Error(\"arctic mostly failing\");\n return out;\n}\n\nconst unescape = (s: string) => s.replace(/</g, \"<\").replace(/>/g, \">\").replace(/"/g, '\"').replace(/'/g, \"'\").replace(/&/g, \"&\");\nasync function fromRss(afterSec: number): Promise {\n const r = await fetch(`https://www.reddit.com/r/${SUBS.join(\"+\")}/new/.rss?limit=100`, { headers: { \"User-Agent\": \"web:reddit-radar:0.1\" } });\n if (!r.ok) throw new Error(`rss ${r.status}`);\n const t = await r.text();\n return t.split(\"\").slice(1).map((e) => {\n const g = (re: RegExp) => e.match(re)?.[1] ?? \"\";\n const html = unescape(g(/([\\s\\S]*?)<\\/content>/));\n return {\n id: g(/t3_(\\w+)<\\/id>/), sub: g(/([\\s\\S]*?)<\\/title>/)),\n body: html.replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").replace(/submitted by .*$/, \"\").trim(),\n author: g(/\\/u\\/(.*?)<\\/name>/), url: g(/(.*?)<\\/published>/)) / 1000,\n };\n }).filter((p) => p.id && p.created > afterSec);\n}\n\n// ---------- llm ----------\nasync function claude(model: string, system: string, user: string, maxTokens = 800): Promise {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": env(\"ANTHROPIC_API_KEY\"), \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model, max_tokens: maxTokens, system, messages: [{ role: \"user\", content: user }] }),\n });\n if (!r.ok) throw new Error(`anthropic ${r.status} ${await r.text()}`);\n const j = await r.json();\n const u = (USAGE[model] ??= { calls: 0, in: 0, out: 0 });\n u.calls++; u.in += j.usage?.input_tokens ?? 0; u.out += j.usage?.output_tokens ?? 0;\n return j.content.filter((c: any) => c.type === \"text\").map((c: any) => c.text).join(\"\");\n}\nconst json = (s: string) => JSON.parse(s.slice(s.indexOf(\"{\"), s.lastIndexOf(\"}\") + 1));\n\nconst GATE_RULES = `\nThe goal is being genuinely useful to the poster and earning karma on a new account. Never an angle to sell. A comment that looks like it's fishing for clients gets downvoted and hurts the account.\n\nA post is worth replying to ONLY if ALL are true:\n1. The poster wants help: a real question, a request for a tool/approach, or a specific problem they're stuck on (\"what do you use for\", \"how do you handle\", \"is there a tool that\", \"how would I\", \"has anyone solved\", \"why does X keep doing Y\"). A question tacked onto the end of an essay, a poll, or a \"curious what you all think\" discussion prompt does not count.\n2. He can give a genuinely useful, specific answer from real experience in ABOUT: the automation tools he's used, the systems he built, OR sales craft from his own job. It does NOT have to be about something he sells. A plain n8n bug, a crm workflow question or a stalled-deal question all count if his answer would actually help.\n3. It is NOT: self-promotion or a disguised pitch (\"feedback on my app\", \"we help businesses with X\"), a launch/showcase/write-up/victory lap, hiring or looking for work, a rant, a mental-health/personal-life post, job-hunting or career switching, taxes/legal/payroll/accounting, B2C product questions with no sales or automation angle, deep software engineering, or tools in his NEVER USED list.\nJudge the question, not the subreddit: a tool-agnostic automation question in r/zapier is fine even though he doesn't use zapier.\nIf a good answer needs experience he doesn't have (hiring and comp plans, fundraising, pricing a SaaS, B2C marketing, a tool he's never used), it fails. When genuinely torn, say no.`;\n\nasync function triageTitles(posts: Post[], about: string): Promise {\n const list = posts.map((p, i) => `${i} | r/${p.sub} | ${p.title} | ${p.body.slice(0, 200).replace(/\\s+/g, \" \")}`).join(\"\\n\");\n const out = await claude(TRIAGE_MODEL,\n `You pre-screen Reddit posts for a solo automation builder. From title + opening only, pick posts that COULD pass the gates below and deserve a full read. Include every post whose title/opening is a genuine help question in his areas, even if you're unsure; the full read does the strict filtering. Skip showcases, write-ups, framework essays, opinion pieces, discussion prompts and anything clearly off-topic.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nReturn ONLY JSON: {\"read\":[indices]}`,\n list, 300);\n const idx: number[] = json(out).read ?? [];\n return idx.map((i) => posts[i]).filter(Boolean);\n}\n\nasync function decide(p: Post, about: string): Promise<{ reply: boolean; reason: string; angle: string; buyer: boolean }> {\n const out = await claude(TRIAGE_MODEL,\n `You decide whether a solo automation builder should answer this Reddit post with a helpful comment.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nAlso judge \"buyer\": true if the poster reads like an owner/decision-maker of a real B2B service business (not a hobbyist, student, or individual rep).\\nReturn ONLY JSON: {\"reply\":true|false,\"reason\":\"one short sentence\",\"angle\":\"what from his proven ground he'd draw on, or empty\",\"buyer\":true|false}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}`, 200);\n return json(out);\n}\n\n// Voice = the my-voice skill's Reddit register, compressed. Few-shot examples carry the style cheaper than rules.\nconst VOICE = `You're a guy who builds sales automations, scrolling reddit on his phone. You know the answer, so you drop a quick note and move on.\n\nLENGTH: 1 to 3 sentences. Usually 20-50 words. Never over 70. No paragraphs unless it's two short lines.\n\nHOW IT READS:\n- straight into the advice. no intro, no framing the problem, no \"the real issue is\", no wrap-up line.\n- one or two concrete things: a tool, a node, a setting, the order to do it in, or the thing that'll break.\n- lazy reddit typing. lowercase is fine, crm / ai / api / n8n / hubspot always lowercase. contractions. plain small words.\n- \"i\", never \"we\". no company, no link, no \"dm me\", no \"happy to help\", no offer of any kind.\n- mention your own build only if it's the point, in half a sentence, and only what ABOUT literally says. anything else is advice (\"i'd...\", \"usually...\"), never a story, number, routine or result you made up.\n- a small imperfection is fine. a run-on is fine.\n\nNEVER (ai tells): em or en dashes, colons that set up a reveal, \"it's not X, it's Y\" / \"isn't about X, it's about Y\", lists of three, bullet points, bold, headers, rhetorical questions, \"honestly\", \"great question\", \"the key is\", \"game-changer\", \"leverage\", \"robust\", \"seamless\", \"crucial\", \"essentially\", \"ultimately\", \"delve\", \"worth noting\", \"that said\", \"hope this helps\", \"in my experience\", restating their question, a closing summary.\n\nSTYLE EXAMPLES (style only, never reuse their facts):\nQ: how do you get call notes into the crm without typing them up\nA: fireflies has a hubspot sync but it just dumps the whole summary as a note. i run the transcript through claude and have it fill the actual deal fields instead, way more useful\n\nQ: n8n webhook keeps triggering twice?\nA: check you haven't got the test url and the production url both registered somewhere, that's almost always it\n\nQ: is there a tool that writes follow ups after sales calls\nA: most call recorders do a generic one now. if you want it to sound like you, feed it a few of your old emails as examples, the defaults read like a robot`;\n\nasync function draft(p: Post, angle: string, about: string): Promise {\n const out = await claude(WRITER_MODEL,\n `${VOICE}\\n\\nABOUT (the only experience you may claim):\\n${about}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}\\n\\n---\\nangle: ${angle}\\nwrite the comment. output only the comment.`, 250);\n let text = out;\n if (text.split(/\\s+/).length > 75) {\n text = await claude(WRITER_MODEL, VOICE, `this reddit comment is too long. cut it to under 50 words, keep only the single most useful bit, same casual voice. output only the comment.\\n\\n${out}`, 150);\n }\n return text\n .replace(/\\s*[—–]\\s*/g, \", \")\n .replace(/^(honestly|great question)[,.!]?\\s+/i, \"\")\n .trim();\n}\n\n// ---------- telegram ----------\nconst esc = (s: string) => s.replace(/&/g, \"&\").replace(//g, \">\");\nasync function tg(text: string, html = false) {\n const r = await fetch(`https://api.telegram.org/bot${env(\"TELEGRAM_BOT_TOKEN\")}/sendMessage`, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: env(\"TELEGRAM_CHAT_ID\"), text, ...(html ? { parse_mode: \"HTML\" } : {}), link_preview_options: { is_disabled: true } }),\n });\n if (!r.ok) throw new Error(`telegram ${r.status} ${await r.text()}`);\n}\n\n// Test helper: draft + send one alert for a given post, skipping the gates.\nexport async function testAlert(p: Post, angle: string) {\n const text = await draft(p, angle, env(\"ABOUT_ME\"));\n const msg = `r/${esc(p.sub)} · TEST\\n${esc(p.title)}\\nformat test, gates skipped\\n\\n

${esc(text)}

${esc(x.text)}

Diff · v50