[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_220":221,"_222":223},"routes/_app.x.$handle.$name",{"_97":96,"_32":44,"_106":87,"_27":101,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":26,"_120":121,"_122":26,"_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",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":26},"version",55,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","purge.ts","latestPath","fileId","d17ae7a8-b1bf-11f1-8177-1607ee4eb77e","name","fileType","script","content","// One-off: delete the old test alerts (sent before message ids were tracked) + measure Arctic Shift ingest lag.\nconst T = Deno.env.get(\"TELEGRAM_BOT_TOKEN\"), C = Deno.env.get(\"TELEGRAM_CHAT_ID\");\nconst api = async (m: string, b: unknown) => (await fetch(`https://api.telegram.org/bot${T}/${m}`, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify(b) })).json();\nconst probe = await api(\"sendMessage\", { chat_id: C, text: \"cleanup...\" });\nconst top = probe.result.message_id;\nconst ids = Array.from({ length: Math.min(top, 100) }, (_, i) => top - i);\nconsole.log(\"delete\", JSON.stringify(await api(\"deleteMessages\", { chat_id: C, message_ids: ids })));\n\nconst now = Date.now() / 1000;\nconst lags: number[] = [];\nfor (const s of [\"ClaudeAI\", \"AI_Agents\", \"n8n\"]) {\n const j = await (await fetch(`https://arctic-shift.photon-reddit.com/api/posts/search?subreddit=${s}&after=${Math.floor(now - 3 * 3600)}&limit=50`)).json();\n for (const p of j.data ?? []) if (p.retrieved_on) lags.push(p.retrieved_on - p.created_utc);\n}\nlags.sort((a, b) => a - b);\nconsole.log(\"now\", new Date().toISOString(), \"lag sec n\", lags.length, \"p50\", lags[Math.floor(lags.length / 2)], \"p90\", lags[Math.floor(lags.length * 0.9)], \"max\", lags.at(-1));\n","createdAt",["D",1789557283646],"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",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":26},"branch",{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned",58,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","stuartt","handle","displayName","Stuart","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":215,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":216,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":217,"_81":218,"_83":219,"_85":26},"tree",[190,191,192,193,194,195],"files",[190,191,192,193,194,195],"counts",{"_178":60,"_179":180,"_181":60,"_182":183,"_184":185},"contents",[127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":170,"_32":171,"_30":172,"_136":-5,"_40":41,"_39":173,"_138":26,"_37":174,"_13":175,"_33":34,"_35":176,"_23":26,"_142":-5,"_27":177},{"_42":162,"_32":163,"_30":164,"_136":-5,"_40":41,"_39":165,"_138":24,"_37":166,"_13":60,"_33":167,"_35":168,"_23":26,"_142":-5,"_27":169},{"_42":159,"_32":28,"_30":31,"_136":-5,"_40":41,"_39":14,"_138":26,"_37":160,"_13":60,"_33":34,"_35":36,"_23":26,"_142":-5,"_27":161},{"_42":151,"_32":152,"_30":153,"_136":-5,"_40":41,"_39":154,"_138":24,"_37":155,"_13":156,"_33":34,"_35":157,"_23":26,"_142":-5,"_27":158},{"_42":144,"_32":145,"_30":146,"_136":-5,"_40":41,"_39":147,"_138":24,"_37":148,"_13":60,"_33":34,"_35":149,"_23":26,"_142":-5,"_27":150},{"_42":133,"_32":134,"_30":135,"_136":-5,"_40":41,"_39":137,"_138":26,"_37":139,"_13":140,"_33":34,"_35":141,"_23":26,"_142":-5,"_27":143},"3297a002-8c4b-4db0-90bb-10e8fab4dc7d","test.ts","32164f6c-b19d-11f1-8f3c-1607ee4eb77e","parentId",38,"latest",["D",1789556420580],3,"import { run } from \"./radar.ts\";\n\n// Manual test on real posts: ignores hours, looks back 8h, sends real Telegram alerts,\n// does NOT write to the db (so live runs are unaffected). Prints a full report.\nconst r: any = await run({ ignoreHours: true, maxAgeMin: 480, skipSeen: true, noDb: true, maxDrafts: 5 });\nconsole.log(JSON.stringify({ ...r, titleRejects: r.titleRejects?.length }, null, 1));\n","label",[134],"36e8c628-9207-4ac7-83d0-e201f22e619d","test-alert.ts","8076b9ce-b19f-11f1-abb5-1607ee4eb77e",23,["D",1789543403818],"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",[145],"5a7a3b7f-509c-4e4c-beed-f4fa1262344d","radar.ts","2cdfb542-b19d-11f1-aef9-1607ee4eb77e",54,["D",1789557273126],31,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Business context lives in the ABOUT_ME env var (private). This file is public.\nconst env = (k: string, d = \"\") => Deno.env.get(k) ?? d;\n// Phase 1 (karma warm-up, from 2026-09-16): tool subs only. Big subs auto-remove low-karma comments.\nconst TOOL_SUBS = \"n8n,ClaudeAI,AI_Agents,automation,nocode,zapier,hubspot,CRM\";\n// Phase 2 (add back once karma allows, review ~2026-09-30):\nexport const BUYER_SUBS = \"msp,agency,marketingagency,consulting,recruiting,sales,B2BSales,salesops,SalesOperations,RevOps,coldemail,LeadGeneration,smallbusiness,Entrepreneur,EntrepreneurRideAlong,sweatystartup\";\nconst SUBS = env(\"SUBS\", TOOL_SUBS).split(\",\").map((s) => s.trim()).filter(Boolean);\n// Only alert on posts this fresh: the poster is still in the thread. Cron is 15 min, so lookback 20 gives overlap.\nconst MAX_AGE_MIN = 20;\nconst TRIAGE_MODEL = env(\"TRIAGE_MODEL\", \"claude-haiku-4-5-20251001\");\nconst WRITER_MODEL = env(\"WRITER_MODEL\", \"claude-sonnet-5\");\nconst MAX_DRAFTS = 3;\n\nexport type Post = { id: string; sub: string; title: string; body: string; author: string; url: string; created: number };\ntype Opts = { ignoreHours?: boolean; maxAgeMin?: number; dryRun?: boolean; skipSeen?: boolean; noDb?: boolean; maxDrafts?: number };\nconst USAGE: Record = {};\nconst PRICE: Record = { \"claude-haiku-4-5-20251001\": [1, 5], \"claude-sonnet-5\": [2, 10] }; // $/MTok in, out\nconst usageReport = () => {\n let usd = 0;\n for (const [m, u] of Object.entries(USAGE)) { const p = PRICE[m] ?? [0, 0]; usd += (u.in * p[0] + u.out * p[1]) / 1e6; }\n return { byModel: USAGE, usd: Number(usd.toFixed(4)) };\n};\n\nexport function activeNow(d = new Date()) {\n const p = new Intl.DateTimeFormat(\"en-GB\", { timeZone: \"Europe/Amsterdam\", weekday: \"short\", hour: \"numeric\", hour12: false }).formatToParts(d);\n const wd = p.find((x) => x.type === \"weekday\")!.value;\n const h = Number(p.find((x) => x.type === \"hour\")!.value) % 24;\n if (wd === \"Sat\" || wd === \"Sun\") return h >= 8 && h < 23;\n return (h >= 7 && h < 9) || (h >= 17 && h < 23);\n}\n\nasync function initDb() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_posts (\n id TEXT PRIMARY KEY, sub TEXT, title TEXT, url TEXT, created INTEGER, seen_at INTEGER,\n stage TEXT, reason TEXT, draft TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS radar_kv (k TEXT PRIMARY KEY, v TEXT)`);\n 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}\n\n// ---------- llm ----------\nasync function claude(model: string, system: string, user: string, maxTokens = 800): Promise {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": env(\"ANTHROPIC_API_KEY\"), \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: JSON.stringify({ model, max_tokens: maxTokens, system, messages: [{ role: \"user\", content: user }] }),\n });\n if (!r.ok) throw new Error(`anthropic ${r.status} ${await r.text()}`);\n const j = await r.json();\n const u = (USAGE[model] ??= { calls: 0, in: 0, out: 0 });\n u.calls++; u.in += j.usage?.input_tokens ?? 0; u.out += j.usage?.output_tokens ?? 0;\n return j.content.filter((c: any) => c.type === \"text\").map((c: any) => c.text).join(\"\");\n}\nconst json = (s: string) => JSON.parse(s.slice(s.indexOf(\"{\"), s.lastIndexOf(\"}\") + 1));\n\nconst GATE_RULES = `\nThe goal is being genuinely useful to the poster and earning karma on a new account. Never an angle to sell. A comment that looks like it's fishing for clients gets downvoted and hurts the account.\n\nA post is worth replying to ONLY if ALL are true:\n1. The poster wants help: a real question, a request for a tool/approach, or a specific problem they're stuck on (\"what do you use for\", \"how do you handle\", \"is there a tool that\", \"how would I\", \"has anyone solved\", \"why does X keep doing Y\"). A question tacked onto the end of an essay, a poll, or a \"curious what you all think\" discussion prompt does not count.\n2. He can give a genuinely useful, specific answer from real experience in ABOUT: the automation tools he's used, the systems he built, OR sales craft from his own job. It does NOT have to be about something he sells. A plain n8n bug, a crm workflow question or a stalled-deal question all count if his answer would actually help.\n3. It is NOT: self-promotion or a disguised pitch (\"feedback on my app\", \"we help businesses with X\"), a launch/showcase/write-up/victory lap, hiring or looking for work, a rant, a mental-health/personal-life post, job-hunting or career switching, taxes/legal/payroll/accounting, B2C product questions with no sales or automation angle, deep software engineering, or tools in his NEVER USED list.\nJudge the question, not the subreddit: a tool-agnostic automation question in r/zapier is fine even though he doesn't use zapier.\nIf a good answer needs experience he doesn't have (hiring and comp plans, fundraising, pricing a SaaS, B2C marketing, a tool he's never used), it fails. When genuinely torn, say no.`;\n\nasync function triageTitles(posts: Post[], about: string): Promise {\n const list = posts.map((p, i) => `${i} | r/${p.sub} | ${p.title} | ${p.body.slice(0, 200).replace(/\\s+/g, \" \")}`).join(\"\\n\");\n const out = await claude(TRIAGE_MODEL,\n `You pre-screen Reddit posts for a solo automation builder. From title + opening only, pick posts that COULD pass the gates below and deserve a full read. Include every post whose title/opening is a genuine help question in his areas, even if you're unsure; the full read does the strict filtering. Skip showcases, write-ups, framework essays, opinion pieces, discussion prompts and anything clearly off-topic.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nReturn ONLY JSON: {\"read\":[indices]}`,\n list, 300);\n const idx: number[] = json(out).read ?? [];\n return idx.map((i) => posts[i]).filter(Boolean);\n}\n\nasync function decide(p: Post, about: string): Promise<{ reply: boolean; reason: string; angle: string; buyer: boolean }> {\n const out = await claude(TRIAGE_MODEL,\n `You decide whether a solo automation builder should answer this Reddit post with a helpful comment.\\n\\nABOUT:\\n${about}\\n${GATE_RULES}\\n\\nAlso judge \"buyer\": true if the poster reads like an owner/decision-maker of a real B2B service business (not a hobbyist, student, or individual rep).\\nReturn ONLY JSON: {\"reply\":true|false,\"reason\":\"one short sentence\",\"angle\":\"what from his proven ground he'd draw on, or empty\",\"buyer\":true|false}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}`, 200);\n return json(out);\n}\n\n// Voice = the my-voice skill's Reddit register, compressed. Few-shot examples carry the style cheaper than rules.\nconst VOICE = `You're a guy who builds sales automations, scrolling reddit on his phone. You know the answer, so you drop a quick note and move on.\n\nLENGTH: 1 to 3 sentences. Usually 20-50 words. Never over 70. No paragraphs unless it's two short lines.\n\nHOW IT READS:\n- straight into the advice. no intro, no framing the problem, no \"the real issue is\", no wrap-up line.\n- one or two concrete things: a tool, a node, a setting, the order to do it in, or the thing that'll break.\n- lazy reddit typing. lowercase is fine, crm / ai / api / n8n / hubspot always lowercase. contractions. plain small words.\n- \"i\", never \"we\". no company, no link, no \"dm me\", no \"happy to help\", no offer of any kind.\n- mention your own build only if it's the point, in half a sentence, and only what ABOUT literally says. anything else is advice (\"i'd...\", \"usually...\"), never a story, number, routine or result you made up.\n- a small imperfection is fine. a run-on is fine.\n\nNEVER (ai tells): em or en dashes, colons that set up a reveal, \"it's not X, it's Y\" / \"isn't about X, it's about Y\", lists of three, bullet points, bold, headers, rhetorical questions, \"honestly\", \"great question\", \"the key is\", \"game-changer\", \"leverage\", \"robust\", \"seamless\", \"crucial\", \"essentially\", \"ultimately\", \"delve\", \"worth noting\", \"that said\", \"hope this helps\", \"in my experience\", restating their question, a closing summary.\n\nSTYLE EXAMPLES (style only, never reuse their facts):\nQ: how do you get call notes into the crm without typing them up\nA: fireflies has a hubspot sync but it just dumps the whole summary as a note. i run the transcript through claude and have it fill the actual deal fields instead, way more useful\n\nQ: n8n webhook keeps triggering twice?\nA: check you haven't got the test url and the production url both registered somewhere, that's almost always it\n\nQ: is there a tool that writes follow ups after sales calls\nA: most call recorders do a generic one now. if you want it to sound like you, feed it a few of your old emails as examples, the defaults read like a robot`;\n\nasync function draft(p: Post, angle: string, about: string): Promise {\n const out = await claude(WRITER_MODEL,\n `${VOICE}\\n\\nABOUT (the only experience you may claim):\\n${about}`,\n `r/${p.sub}\\nTITLE: ${p.title}\\n\\n${p.body.slice(0, 3000)}\\n\\n---\\nangle: ${angle}\\nwrite the comment. output only the comment.`, 250);\n let text = out;\n if (text.split(/\\s+/).length > 75) {\n text = await claude(WRITER_MODEL, VOICE, `this reddit comment is too long. cut it to under 50 words, keep only the single most useful bit, same casual voice. output only the comment.\\n\\n${out}`, 150);\n }\n return text\n .replace(/\\s*[—–]\\s*/g, \", \")\n .replace(/^(honestly|great question)[,.!]?\\s+/i, \"\")\n .trim();\n}\n\n// ---------- telegram ----------\nconst esc = (s: string) => s.replace(/&/g, \"&\").replace(//g, \">\");\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 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",[152],"26c5b02f-ba38-4833-b94f-be0034f4b6f7",["D",1789557283646],[28],"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",[163],"0b42aba9-807c-42e2-8e00-7baccdb97ee9","audit.ts","5ca52a5c-b1be-11f1-b434-1607ee4eb77e",49,["D",1789556903796],2,"import { run } from \"./radar.ts\";\n\n// Filter audit: 12h lookback, no drafts sent (dryRun + maxDrafts 0), no db writes. Dumps every post and its fate.\nconst r: any = await run({ ignoreHours: true, maxAgeMin: 540, skipSeen: true, noDb: true, dryRun: true, maxDrafts: 0 });\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 \"} ${f.buyer ? \"B\" : \" \"} r/${f.sub}: ${f.title.slice(0, 90)} -- ${f.reason}`);\n",[171],"pulls","branches",1,"forks","envVars",{"_186":188,"_189":60},"connections",{"_186":60,"_187":60},"count","unfilledCount",5,"emptyCount",{"_42":170,"_32":171,"_30":172,"_136":-5,"_40":41,"_39":173,"_138":26,"_37":212,"_13":175,"_33":34,"_35":176,"_23":26,"_142":-5,"_197":213,"_27":214},{"_42":162,"_32":163,"_30":164,"_136":-5,"_40":41,"_39":165,"_138":24,"_37":209,"_13":60,"_33":167,"_35":168,"_23":26,"_142":-5,"_197":210,"_27":211},{"_42":159,"_32":28,"_30":31,"_136":-5,"_40":41,"_39":14,"_138":26,"_37":206,"_13":60,"_33":34,"_35":36,"_23":26,"_142":-5,"_197":207,"_27":208},{"_42":151,"_32":152,"_30":153,"_136":-5,"_40":41,"_39":154,"_138":24,"_37":203,"_13":156,"_33":34,"_35":157,"_23":26,"_142":-5,"_197":204,"_27":205},{"_42":144,"_32":145,"_30":146,"_136":-5,"_40":41,"_39":147,"_138":24,"_37":200,"_13":60,"_33":34,"_35":149,"_23":26,"_142":-5,"_197":201,"_27":202},{"_42":133,"_32":134,"_30":135,"_136":-5,"_40":41,"_39":137,"_138":26,"_37":196,"_13":140,"_33":34,"_35":141,"_23":26,"_142":-5,"_197":198,"_27":199},["D",1789556420580],"children",[],[134],["D",1789543403818],[],[145],["D",1789557273126],[],[152],["D",1789557283646],[],[28],["D",1789542411025],[],[163],["D",1789556903796],[],[171],["D",1789541880491],["D",1789542643120],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":26},{"_13":86,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_79":-5,"_124":253,"_254":255,"_256":257,"_258":26,"_259":26,"_260":26,"_261":24,"_262":-5,"_263":-7,"_264":-7,"_265":60,"_266":26,"_267":26,"_268":-5,"_269":26,"_270":26,"_271":26,"_272":-5},"ENV",{"_224":225,"_226":227,"_228":87,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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 · v55