[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_180":181,"_182":183},"routes/_app.x.$handle.$name",{"_96":95,"_31":43,"_105":86,"_26":100,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":24,"_119":120,"_121":24,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","test.ts","latestPath","fileId","32164f6c-b19d-11f1-8f3c-1607ee4eb77e","name","fileType","script","content","import { run } from \"./radar.ts\";\n\n// Manual test: ignores hours, looks back 3h, prints drafts instead of sending, doesn't write to the db.\nconsole.log(JSON.stringify(await run({ ignoreHours: true, maxAgeMin: 180, dryRun: true, skipSeen: true })));\n","createdAt",["D",1789542413337],"branchVersion","branchId","6f2df423-0c15-4914-b3b6-d32d5b050af7","id","7f8d756d-5c8f-4e20-9196-f02915d019c0","reddit-radar",["D",1789541880491],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Reddit question finder -> AI triage -> Telegram","imageUrl","79b9d53a-8825-4412-935a-27ced02397d3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"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",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},"branch",{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"isOwned",91,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","stuartt","handle","displayName","Stuart","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":175,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":176,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":177,"_80":178,"_82":179,"_84":24},"tree",[162,163,164],"files",[162,163,164],"counts",{"_151":59,"_152":153,"_154":59,"_155":156,"_157":158},"contents",[126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":142,"_31":143,"_29":144,"_130":-5,"_39":40,"_38":145,"_131":146,"_36":147,"_13":59,"_32":148,"_34":149,"_23":24,"_133":-5,"_26":150},{"_41":135,"_31":136,"_29":137,"_130":-5,"_39":40,"_38":138,"_131":24,"_36":139,"_13":59,"_32":33,"_34":140,"_23":24,"_133":-5,"_26":141},{"_41":129,"_31":27,"_29":30,"_130":-5,"_39":40,"_38":14,"_131":24,"_36":132,"_13":59,"_32":33,"_34":35,"_23":24,"_133":-5,"_26":134},"fb3f1dbf-a60f-4640-9829-b2975d70e06c","parentId","latest",["D",1789542413337],"label",[27],"250e5705-706a-4095-9f67-2471011475e7","radar.ts","2cdfb542-b19d-11f1-aef9-1607ee4eb77e",11,["D",1789542404598],"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\", \"n8n,ClaudeAI,AI_Agents,msp,agency,sales,smallbusiness\").split(\",\").map((s) => s.trim());\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 };\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 const res = await Promise.all(SUBS.map(async (s) => {\n const r = await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${afterSec}&limit=100&sort=desc`);\n if (!r.ok) throw new Error(`arctic ${s} ${r.status}`);\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 return res.flat();\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 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; most posts fail.\\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, 5000)}`, 300);\n return json(out);\n}\n\nasync function draft(p: Post, angle: string, about: string): Promise {\n const out = await claude(WRITER_MODEL,\n `You write a Reddit comment that the builder described in ABOUT will review and post himself.\\n\\nABOUT:\\n${about}\\n\nRules, all hard:\n- First person singular \"I\". Never \"we\". Never mention a company, website, link, DM, or offer to help privately. No pitch of any kind.\n- Only claim experience that is in ABOUT's proven ground. Never invent numbers, results, clients or stories. If a point needs experience he doesn't have, give the reasoning without claiming it.\n- Lead with the specific thing that breaks or the direct answer. No greeting, no \"great question\", no restating their post, no sign-off, no summary closer.\n- Give the whole useful answer. Concrete over general: name the actual steps, tools and the failure mode to watch.\n- Contractions. Lowercase casual acronyms (crm, ai, api, n8n). No em dashes or en dashes. No emojis. No headers. Short paragraphs; a short list only if steps genuinely need it.\n- 60 to 180 words. Sound like a practitioner talking to a peer.\nAngle to use: ${angle}\nOutput only the comment text.`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 6000)}`, 900);\n return out.replace(/\\s*[—–]\\s*/g, \", \").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// ---------- 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 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, 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 const head = `${x.d.buyer ? \"💼 BUYER · \" : \"\"}r/${esc(x.p.sub)} · ${age} min old\\n${esc(x.p.title)}\\n\\n${esc(x.d.reason)}`;\n if (opts.dryRun) console.log(\"---\\n\" + head + \"\\n\\n\" + x.text);\n else { await tg(head, true); await tg(x.text); }\n }\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",[136],"80648020-ed7c-479f-b4ff-eec38238559c","main.ts","30b5c350-b19d-11f1-820c-1607ee4eb77e",12,true,["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",[143],"pulls","branches",1,"forks","envVars",{"_159":145,"_161":59},"connections",{"_159":59,"_160":59},"count","unfilledCount","emptyCount",{"_41":142,"_31":143,"_29":144,"_130":-5,"_39":40,"_38":145,"_131":146,"_36":172,"_13":59,"_32":148,"_34":149,"_23":24,"_133":-5,"_166":173,"_26":174},{"_41":135,"_31":136,"_29":137,"_130":-5,"_39":40,"_38":138,"_131":24,"_36":169,"_13":59,"_32":33,"_34":140,"_23":24,"_133":-5,"_166":170,"_26":171},{"_41":129,"_31":27,"_29":30,"_130":-5,"_39":40,"_38":14,"_131":24,"_36":165,"_13":59,"_32":33,"_34":35,"_23":24,"_133":-5,"_166":167,"_26":168},["D",1789542413337],"children",[],[27],["D",1789542404598],[],[136],["D",1789542411025],[],[143],["D",1789541880491],["D",1789542643120],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"ctx",{"_78":-5,"_123":213,"_214":215,"_216":217,"_218":24,"_219":24,"_220":24,"_221":146,"_222":-5,"_223":-7,"_224":-7,"_225":59,"_226":24,"_227":24,"_228":-5,"_229":24,"_230":24,"_231":24,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":86,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]

Diff · v13