[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_210":211,"_212":213},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_159":-5,"_20":160,"_22":161,"_162":163,"_164":165,"_26":166,"_24":167,"_168":-5,"_169":-5,"_170":52,"_171":172,"_173":52,"_174":-5,"_175":-5,"_176":177},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","stuartt","name","reddit-radar","branchName","main","version","path","audit.ts","project",{"_33":100,"_13":14,"_44":101,"_102":-5,"_103":52,"_104":105,"_106":105,"_107":108,"_109":-5,"_110":111,"_112":-5,"_113":52,"_114":-5,"_115":-5,"_116":75,"_117":118,"_119":120,"_121":122,"_123":124,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":136,"_137":138,"_139":140,"_141":52},"tree",[55,56,57,58,59],"file",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":54},"contents",[],"upstream","pull","ahead","behind","envVars","id","8ed1237f-decb-4229-905f-38ae9a89c76b","fileId","5ca52a5c-b1be-11f1-b434-1607ee4eb77e","parentId","branchId","6f2df423-0c15-4914-b3b6-d32d5b050af7","branchVersion",58,"latest",true,"createdAt",["D",1789557309831],3,"fileType","script","content","import { run } from \"./radar.ts\";\n\n// Filter audit on the live sub list with a wider window. Drafts are printed, NOT sent. No db writes.\nconst r: any = await run({ ignoreHours: true, maxAgeMin: 360, skipSeen: true, noDb: true, dryRun: true, maxDrafts: 3 });\nconsole.log(`fetched ${r.fetched} | read ${r.readInFull} | passed ${r.passed} | $${r.usage.usd}`);\nfor (const f of r.fullReads) console.log(`${f.reply ? \"PASS\" : \"no \"} r/${f.sub}: ${f.title.slice(0, 90)} -- ${f.reason}`);\nfor (const d of r.drafts) console.log(`\\nDRAFT (${d.title.slice(0, 60)}):\\n${d.text}`);\n","deleted",false,"label",[19],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":97,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_67":98,"_18":99},{"_33":88,"_13":89,"_35":90,"_37":-5,"_38":39,"_40":91,"_42":43,"_44":92,"_17":75,"_47":93,"_49":94,"_51":52,"_53":-5,"_67":95,"_18":96},{"_33":79,"_13":80,"_35":81,"_37":-5,"_38":39,"_40":82,"_42":43,"_44":83,"_17":84,"_47":48,"_49":85,"_51":52,"_53":-5,"_67":86,"_18":87},{"_33":70,"_13":71,"_35":72,"_37":-5,"_38":39,"_40":73,"_42":43,"_44":74,"_17":75,"_47":48,"_49":76,"_51":52,"_53":-5,"_67":77,"_18":78},{"_33":60,"_13":61,"_35":62,"_37":-5,"_38":39,"_40":63,"_42":43,"_44":64,"_17":65,"_47":48,"_49":66,"_51":52,"_53":-5,"_67":68,"_18":69},"1476d8a1-0907-4510-93a2-b7acca418d59","test.ts","32164f6c-b19d-11f1-8f3c-1607ee4eb77e",57,["D",1789557298520],4,"import { run } from \"./radar.ts\";\n\n// Test with exact live settings (tool subs, posts <20 min old), ignoring hours and the seen-table.\n// Sends real Telegram alerts, doesn't write posts to the db.\nconst r: any = await run({ ignoreHours: true, skipSeen: true, noDb: true });\nconsole.log(`fetched ${r.fetched ?? r.new} | read ${r.readInFull} | passed ${r.passed} | drafted ${r.drafted} | $${r.usage?.usd}`);\nfor (const f of r.fullReads ?? []) console.log(`${f.reply ? \"PASS\" : \"no \"} r/${f.sub}: ${f.title.slice(0, 90)} -- ${f.reason}`);\nfor (const d of r.drafts ?? []) console.log(`\\nDRAFT (${d.title.slice(0, 60)}):\\n${d.text}`);\n","children",[],[61],"36e8c628-9207-4ac7-83d0-e201f22e619d","test-alert.ts","8076b9ce-b19f-11f1-abb5-1607ee4eb77e",23,["D",1789543403818],0,"import { testAlert } from \"./radar.ts\";\n\n// Sends one real Telegram alert to check formatting + draft quality.\nconst after = Math.floor(Date.now() / 1000 - 6 * 3600);\nconst r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=AI_Agents&after=${after}&limit=100`);\nconst p = (await r.json()).data.find((x: any) => /stop double checking/i.test(x.title));\nif (!p) throw new Error(\"sample post not found\");\nconsole.log(await testAlert({\n id: p.id, sub: p.subreddit, title: p.title, body: p.selftext ?? \"\", author: p.author,\n url: `https://www.reddit.com${p.permalink}`, created: p.created_utc,\n}, \"an llm needs a strict allow-list of claims or it overclaims; the post-call agent silently wrote duplicate crm notes\"));\n",[],[71],"6bf1012b-7af0-4dd5-903e-9f8155b09d79","radar.ts","2cdfb542-b19d-11f1-aef9-1607ee4eb77e",65,["D",1789573632328],36,"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,ClaudeCode,claude,AI_Agents,AgentsOfAI,automation,Automate,nocode,zapier,hubspot,CRM,Notion,webscraping\";\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 await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_msgs (id INTEGER PRIMARY KEY, sent_at INTEGER)`);\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}\nasync function fromRssRetry(afterSec: number): Promise {\n // Reddit allows ~1 unauthenticated RSS request/min per IP; Val Town IPs are shared, so retry with backoff.\n let last: unknown;\n for (const wait of [0, 4000, 9000]) {\n if (wait) await new Promise((ok) => setTimeout(ok, wait));\n try { return await fromRss(afterSec); } catch (e) { last = e; }\n }\n throw last;\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.\nEveryday how-to questions about tools he uses hands-on (n8n nodes and credentials, claude / claude code / cowork / mcp, hubspot, notion, apify, google workspace) count when a competent daily user of that tool would know the answer; he doesn't need to have built that exact thing.\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, \">\");\nconst tgApi = async (method: string, body: unknown) => {\n const r = await fetch(`https://api.telegram.org/bot${env(\"TELEGRAM_BOT_TOKEN\")}/${method}`, {\n method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify(body),\n });\n const j = await r.json();\n if (!j.ok) throw new Error(`telegram ${method} ${JSON.stringify(j)}`);\n return j.result;\n};\nasync function tg(text: string, html = false) {\n const m = await tgApi(\"sendMessage\", { chat_id: env(\"TELEGRAM_CHAT_ID\"), text, ...(html ? { parse_mode: \"HTML\" } : {}), link_preview_options: { is_disabled: true } });\n await initDb();\n await sqlite.execute({ sql: `INSERT OR IGNORE INTO radar_msgs VALUES (?, ?)`, args: [m.message_id, Math.floor(Date.now() / 1000)] });\n return m.message_id as number;\n}\n\n// Deletes alerts older than 1 hour: too late to reply by then, and it keeps the chat clean.\nexport async function cleanupTelegram(olderThanSec = 3600) {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT id FROM radar_msgs WHERE sent_at < ?`, args: [Math.floor(Date.now() / 1000) - olderThanSec] });\n const ids = r.rows.map((x: any) => Number(x.id));\n for (let i = 0; i < ids.length; i += 100) {\n await tgApi(\"deleteMessages\", { chat_id: env(\"TELEGRAM_CHAT_ID\"), message_ids: ids.slice(i, i + 100) }).catch((e) => console.log(String(e)));\n }\n if (ids.length) await sqlite.execute({ sql: `DELETE FROM radar_msgs WHERE id IN (${ids.map(() => \"?\").join(\",\")})`, args: ids });\n return ids.length;\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 await initDb();\n const deleted = await cleanupTelegram().catch((e) => { console.log(\"cleanup failed\", String(e)); return 0; });\n if (deleted) console.log(`deleted ${deleted} old telegram alerts`);\n if (!opts.ignoreHours && !activeNow()) return { skipped: \"outside hours\" };\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 ?? MAX_AGE_MIN) * 60);\n\n // Both sources, merged. Arctic Shift is primary (verified complete vs Reddit RSS for r/n8n, 16 Sep).\n // RSS is a backup for Arctic outages; it's often 429 on Val Town's shared IPs, which is fine.\n const [rssRes, arcRes] = await Promise.allSettled([fromRssRetry(after), fromArctic(after)]);\n const rssPosts = rssRes.status === \"fulfilled\" ? rssRes.value : [];\n const arcPosts = arcRes.status === \"fulfilled\" ? arcRes.value : [];\n if (rssRes.status === \"rejected\") console.log(\"rss failed\", String(rssRes.reason));\n if (arcRes.status === \"rejected\") console.log(\"arctic failed\", String(arcRes.reason));\n if (rssRes.status === \"rejected\" && arcRes.status === \"rejected\") { await health(false, opts); return { error: \"all sources failed\" }; }\n await health(true, opts);\n const rssIds = new Set(rssPosts.map((p) => p.id));\n let posts: Post[] = [...rssPosts, ...arcPosts.filter((p) => !rssIds.has(p.id))];\n const source = `rss ${rssRes.status === \"fulfilled\" ? rssPosts.length : \"FAIL\"} / arctic ${arcRes.status === \"fulfilled\" ? arcPosts.length : \"FAIL\"} / arctic-only ${arcPosts.filter((p) => !rssIds.has(p.id)).length}`;\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",[],[80],"80648020-ed7c-479f-b4ff-eec38238559c","main.ts","30b5c350-b19d-11f1-820c-1607ee4eb77e",12,["D",1789542411025],"interval","import { run } from \"./radar.ts\";\n\n// Runs every 15 min; radar.ts skips outside 07-09/17-23 weekdays, 08-23 weekends (Amsterdam).\nexport default async function () {\n console.log(JSON.stringify(await run()));\n}\n",[],[89],["D",1789557309831],[],[19],"7f8d756d-5c8f-4e20-9196-f02915d019c0",["D",1789541880491],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Reddit question finder -> AI triage -> Telegram","imageUrl","userId","79b9d53a-8825-4412-935a-27ced02397d3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019da1c9-6902-715f-ad4b-36202c4b5352","tursoName","7f8d756d5c8f4e209196f02915d019c0","tursoHostname","7f8d756d5c8f4e209196f02915d019c0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542643120],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_158":154},"org",{"_11":12,"_151":152,"_153":154,"_110":111,"_155":156,"_157":52},"branch",{"_17":142,"_13":16,"_33":39,"_143":100,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":14,"_150":12},"isOwned",66,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Stuart","avatar","","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":100,"_13":14,"_44":205,"_102":-5,"_103":52,"_104":105,"_106":105,"_107":108,"_109":-5,"_110":111,"_112":-5,"_113":52,"_114":-5,"_115":-5,"_116":75,"_117":118,"_119":120,"_121":122,"_123":206,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_135":207,"_137":208,"_139":209,"_141":52},[190,191,192,193,194],"files",[190,191,192,193,194],"counts",{"_179":75,"_180":181,"_182":75,"_32":183,"_184":185},[],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":178},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],"pulls","branches",1,"forks",{"_186":188,"_189":75},"connections",{"_186":75,"_187":75},"count","unfilledCount",5,"emptyCount",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":97,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_67":203,"_18":204},{"_33":88,"_13":89,"_35":90,"_37":-5,"_38":39,"_40":91,"_42":43,"_44":92,"_17":75,"_47":93,"_49":94,"_51":52,"_53":-5,"_67":201,"_18":202},{"_33":79,"_13":80,"_35":81,"_37":-5,"_38":39,"_40":82,"_42":43,"_44":83,"_17":84,"_47":48,"_49":85,"_51":52,"_53":-5,"_67":199,"_18":200},{"_33":70,"_13":71,"_35":72,"_37":-5,"_38":39,"_40":73,"_42":43,"_44":74,"_17":75,"_47":48,"_49":76,"_51":52,"_53":-5,"_67":197,"_18":198},{"_33":60,"_13":61,"_35":62,"_37":-5,"_38":39,"_40":63,"_42":43,"_44":64,"_17":65,"_47":48,"_49":66,"_51":52,"_53":-5,"_67":195,"_18":196},[],[61],[],[71],[],[80],[],[89],[],[19],["D",1789541880491],["D",1789542643120],{"_11":12,"_158":154},{"_11":12,"_151":152,"_153":154,"_110":111,"_155":156,"_157":52},{"_17":142,"_13":16,"_33":39,"_143":100,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":-5,"_149":14,"_150":12},"ctx",{"_135":-5,"_175":243,"_244":245,"_246":247,"_248":52,"_249":52,"_250":52,"_251":43,"_252":-5,"_253":-7,"_254":-7,"_255":75,"_256":52,"_257":52,"_258":-5,"_259":52,"_260":52,"_261":52,"_262":-5},"ENV",{"_214":215,"_216":217,"_218":16,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]