${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 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",[70],"118ec6d2-092b-4aa7-ba1f-59b363af0190","probe.ts","a764fa1e-b1e5-11f1-81d2-1607ee4eb77e",59,["D",1789573533914],"// Size the net: posts per sub in last 24h via Arctic (cap 100), plus coverage check vs Reddit RSS for r/n8n.\nconsole.log(\"now\", new Date().toISOString());\nconst subs = \"n8n,ClaudeAI,AI_Agents,automation,nocode,zapier,hubspot,CRM,ClaudeCode,claude,AgentsOfAI,Automate,Notion,webscraping,GoogleAppsScript,PromptEngineering,ChatGPTPro,sales,smallbusiness,Entrepreneur\".split(\",\");\nconst after = Math.floor(Date.now() / 1000 - 86400);\nconst out: string[] = [];\nconst arcticIds = new Set();\nfor (let i = 0; i < subs.length; i += 3) {\n const res = await Promise.all(subs.slice(i, i + 3).map(async (s) => {\n for (let k = 0; k < 3; k++) {\n const r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${after}&limit=100`);\n if (r.status === 429) { await new Promise((o) => setTimeout(o, 2500)); continue; }\n const j = await r.json();\n if (s === \"n8n\") for (const p of j.data ?? []) arcticIds.add(p.id);\n return `${s}:${j.data?.length ?? r.status}`;\n }\n return `${s}:429`;\n }));\n out.push(...res);\n}\nconsole.log(out.join(\" \"));\nconst rss = await fetch(\"https://www.reddit.com/r/n8n/new/.rss?limit=25\", { headers: { \"User-Agent\": \"web:reddit-radar:0.1\" } });\nconst t = await rss.text();\nconst ids = [...t.matchAll(/t3_(\\w+)<\\/id>/g)].map((m) => m[1]);\nconsole.log(\"rss\", rss.status, \"n8n rss ids\", ids.length, \"missing from arctic\", ids.filter((x) => !arcticIds.has(x)).length);\n",[78],"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",[85],"8ed1237f-decb-4229-905f-38ae9a89c76b","audit.ts","5ca52a5c-b1be-11f1-b434-1607ee4eb77e",58,["D",1789557309831],3,"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",[93],{"_38":92,"_13":93,"_41":94,"_43":-5,"_44":45,"_46":95,"_48":49,"_50":122,"_17":97,"_53":54,"_55":98,"_57":58,"_59":-5,"_107":123,"_18":124},{"_38":84,"_13":85,"_41":86,"_43":-5,"_44":45,"_46":87,"_48":49,"_50":119,"_17":66,"_53":89,"_55":90,"_57":58,"_59":-5,"_107":120,"_18":121},{"_38":77,"_13":78,"_41":79,"_43":-5,"_44":45,"_46":80,"_48":49,"_50":116,"_17":66,"_53":54,"_55":82,"_57":58,"_59":-5,"_107":117,"_18":118},{"_38":69,"_13":70,"_41":71,"_43":-5,"_44":45,"_46":72,"_48":49,"_50":113,"_17":74,"_53":54,"_55":75,"_57":58,"_59":-5,"_107":114,"_18":115},{"_38":61,"_13":62,"_41":63,"_43":-5,"_44":45,"_46":64,"_48":49,"_50":110,"_17":66,"_53":54,"_55":67,"_57":58,"_59":-5,"_107":111,"_18":112},{"_38":39,"_13":40,"_41":42,"_43":-5,"_44":45,"_46":47,"_48":49,"_50":106,"_17":52,"_53":54,"_55":56,"_57":58,"_59":-5,"_107":108,"_18":109},["D",1789557298520],"children",[],[40],["D",1789543403818],[],[62],["D",1789557273126],[],[70],["D",1789573533914],[],[78],["D",1789542411025],[],[85],["D",1789557309831],[],[93],"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,"_181":19},"org",{"_11":12,"_175":176,"_177":19,"_135":136,"_178":179,"_180":58},"branch",{"_17":80,"_13":16,"_38":45,"_167":125,"_168":-5,"_169":-5,"_170":-5,"_171":-5,"_172":-5,"_173":14,"_174":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Stuart","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_38":125,"_13":14,"_50":241,"_127":-5,"_128":58,"_129":130,"_131":130,"_132":133,"_134":-5,"_135":136,"_137":-5,"_138":58,"_139":-5,"_140":-5,"_141":66,"_142":143,"_144":145,"_146":147,"_148":242,"_150":-5,"_151":152,"_153":152,"_154":155,"_156":155,"_157":155,"_158":152,"_159":152,"_160":243,"_162":244,"_164":245,"_166":58},[223,224,225,226,227,228],"files",[223,224,225,226,227,228],"counts",{"_212":66,"_213":214,"_215":66,"_31":216,"_217":218},[200,201,202,203,204,205],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_38":92,"_13":93,"_41":94,"_43":-5,"_44":45,"_46":95,"_48":49,"_50":96,"_17":97,"_53":54,"_55":98,"_57":58,"_59":-5,"_18":211},{"_38":84,"_13":85,"_41":86,"_43":-5,"_44":45,"_46":87,"_48":49,"_50":88,"_17":66,"_53":89,"_55":90,"_57":58,"_59":-5,"_18":210},{"_38":77,"_13":78,"_41":79,"_43":-5,"_44":45,"_46":80,"_48":49,"_50":81,"_17":66,"_53":54,"_55":82,"_57":58,"_59":-5,"_18":209},{"_38":69,"_13":70,"_41":71,"_43":-5,"_44":45,"_46":72,"_48":49,"_50":73,"_17":74,"_53":54,"_55":75,"_57":58,"_59":-5,"_18":208},{"_38":61,"_13":62,"_41":63,"_43":-5,"_44":45,"_46":64,"_48":49,"_50":65,"_17":66,"_53":54,"_55":67,"_57":58,"_59":-5,"_18":207},{"_38":39,"_13":40,"_41":42,"_43":-5,"_44":45,"_46":47,"_48":49,"_50":51,"_17":52,"_53":54,"_55":56,"_57":58,"_59":-5,"_18":206},[40],[62],[70],[78],[85],[93],"pulls","branches",1,"forks",{"_219":221,"_222":66},"connections",{"_219":66,"_220":66},"count","unfilledCount",5,"emptyCount",{"_38":92,"_13":93,"_41":94,"_43":-5,"_44":45,"_46":95,"_48":49,"_50":122,"_17":97,"_53":54,"_55":98,"_57":58,"_59":-5,"_107":239,"_18":240},{"_38":84,"_13":85,"_41":86,"_43":-5,"_44":45,"_46":87,"_48":49,"_50":119,"_17":66,"_53":89,"_55":90,"_57":58,"_59":-5,"_107":237,"_18":238},{"_38":77,"_13":78,"_41":79,"_43":-5,"_44":45,"_46":80,"_48":49,"_50":116,"_17":66,"_53":54,"_55":82,"_57":58,"_59":-5,"_107":235,"_18":236},{"_38":69,"_13":70,"_41":71,"_43":-5,"_44":45,"_46":72,"_48":49,"_50":113,"_17":74,"_53":54,"_55":75,"_57":58,"_59":-5,"_107":233,"_18":234},{"_38":61,"_13":62,"_41":63,"_43":-5,"_44":45,"_46":64,"_48":49,"_50":110,"_17":66,"_53":54,"_55":67,"_57":58,"_59":-5,"_107":231,"_18":232},{"_38":39,"_13":40,"_41":42,"_43":-5,"_44":45,"_46":47,"_48":49,"_50":106,"_17":52,"_53":54,"_55":56,"_57":58,"_59":-5,"_107":229,"_18":230},[],[40],[],[62],[],[70],[],[78],[],[85],[],[93],["D",1789541880491],["D",1789542643120],{"_11":12,"_181":19},{"_11":12,"_175":176,"_177":19,"_135":136,"_178":179,"_180":58},{"_17":80,"_13":16,"_38":45,"_167":125,"_168":-5,"_169":-5,"_170":-5,"_171":-5,"_172":-5,"_173":14,"_174":12},"ctx",{"_160":-5,"_197":279,"_280":281,"_282":283,"_284":58,"_285":58,"_286":58,"_287":49,"_288":-5,"_289":-7,"_290":-7,"_291":66,"_292":58,"_293":58,"_294":-5,"_295":58,"_296":58,"_297":58,"_298":-5},"ENV",{"_250":251,"_252":253,"_254":16,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","9e167d8120a57de5d747867e0b686da51bcc19a4","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"]