[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_196":197,"_198":199},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":101,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":25,"_123":-5,"_124":-5,"_125":126},"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",39,"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 = `\nA post is worth replying to ONLY if ALL are true:\n1. It is a genuine question or request for help/advice (patterns: \"what do you use for\", \"how do you handle\", \"is there a tool that\", \"is AI any good at\", \"worth automating?\", \"how would I build\", \"has anyone done X\").\n2. The subject is squarely inside the builder's proven ground (see ABOUT). He must be able to answer from something he actually built or used. If answering would need tools or experience outside that list, it fails.\n3. It is NOT: self-promotion, a launch/\"I built this\"/showcase post, a case study or victory lap, a hiring/job/freelancer post, a pure rant with no question, karma-bait discussion (\"what's everyone struggling with\"), a personal career question, a B2C/consumer niche with no sales/ops automation angle, or deep software engineering (devops, infra, model training, coding bugs unrelated to automation workflows).\nWhen torn, say no. A missed post costs nothing; a bad pass wastes his evening.`;\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. Be selective: expect roughly 1 in 10 at most. Skip anything that reads like a showcase, write-up, framework essay, opinion piece or discussion prompt even if it ends with a question.\\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 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|^how (i|we) |^\\[?(hiring|for hire|offer|promo)|looking for (beta|testers)|^(meet|introducing)\\b/i;\n posts = posts.filter((p) => !junk.test(p.title.trim()) && !/^https?:\\/\\/\\S+$/.test(p.body.trim()));\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 const passes = decisions.filter((x) => x.d.reply).sort((a, b) => Number(b.d.buyer) - Number(a.d.buyer)).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}`),\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;\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 = `\nA post is worth replying to ONLY if ALL are true:\n1. It is a genuine question or request for help/advice (patterns: \"what do you use for\", \"how do you handle\", \"is there a tool that\", \"is AI any good at\", \"worth automating?\", \"how would I build\", \"has anyone done X\").\n2. The subject is squarely inside the builder's proven ground (see ABOUT). He must be able to answer from something he actually built or used. If answering would need tools or experience outside that list, it fails.\n3. It is NOT: self-promotion, a launch/\"I built this\"/showcase post, a case study or victory lap, a hiring/job/freelancer post, a pure rant with no question, karma-bait discussion (\"what's everyone struggling with\"), a personal career question, a B2C/consumer niche with no sales/ops automation angle, or deep software engineering (devops, infra, model training, coding bugs unrelated to automation workflows).\nWhen torn, say no. A missed post costs nothing; a bad pass wastes his evening.`;\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. Be selective: expect roughly 1 in 10 at most. Skip anything that reads like a showcase, write-up, framework essay, opinion piece or discussion prompt even if it ends with a question.\\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 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|^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 const passes = decisions.filter((x) => x.d.reply).sort((a, b) => Number(b.d.buyer) - Number(a.d.buyer)).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)}

Diff · v39