<!\\[CDATA\\[(.*?)\\]\\]><\\/title>/)?.[1]\n || itemXml.match(/<title>(.*?)<\\/title>/)?.[1] || \"\";\n\n const link = itemXml.match(/<link>(.*?)<\\/link>/)?.[1] || \"\";\n\n const description = itemXml.match(/<description><!\\[CDATA\\[(.*?)\\]\\]><\\/description>/)?.[1]\n || itemXml.match(/<description>(.*?)<\\/description>/)?.[1] || \"\";\n\n const pubDate = itemXml.match(/<pubDate>(.*?)<\\/pubDate>/)?.[1] || \"\";\n\n const author = itemXml.match(/<dc:creator><!\\[CDATA\\[(.*?)\\]\\]><\\/dc:creator>/)?.[1]\n || itemXml.match(/<author>(.*?)<\\/author>/)?.[1] || \"\";\n\n const guid = itemXml.match(/<guid[^>]*>(.*?)<\\/guid>/)?.[1] || link;\n\n items.push({\n title: title.trim(),\n link: link.trim(),\n description: description.trim(),\n pubDate: pubDate.trim(),\n author: author.trim(),\n guid: guid.trim(),\n });\n }\n }\n\n return items;\n}\n\n/**\n * Fallback: Fetches RSS feed from a subreddit and converts to RedditPost format\n */\nasync function fetchSubredditPostsRSS(subreddit: string): Promise<RedditPost[]> {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/new.rss`;\n\n const response = await fetch(url, {\n headers: {\n \"User-Agent\": \"Mozilla/5.0 (compatible; UnifiedRedditMonitor/1.0; +https://val.town)\",\n \"Accept\": \"application/rss+xml, application/xml, text/xml\",\n \"Accept-Language\": \"en-US,en;q=0.9\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`Reddit RSS error: ${response.status} ${response.statusText}`);\n }\n\n const xmlText = await response.text();\n const rssItems = parseRSS(xmlText);\n\n // Convert RSS items to RedditPost format\n return rssItems.map(item => ({\n id: item.guid.split(\"/\").pop() || item.guid,\n title: item.title,\n selftext: item.description.replace(/<[^>]*>/g, \"\"), // Strip HTML\n url: item.link,\n author: item.author,\n created_utc: Math.floor(new Date(item.pubDate).getTime() / 1000),\n score: 0, // Not available in RSS\n num_comments: 0, // Not available in RSS\n permalink: item.link.replace(\"https://www.reddit.com\", \"\"),\n subreddit: subreddit,\n }));\n } catch (error) {\n console.error(`Error fetching RSS from r/${subreddit}:`, error);\n throw error;\n }\n}\n\n/**\n * Fetches posts from a subreddit with fallback methods\n */\nasync function fetchSubredditPosts(subreddit: string, limit: number = 25): Promise<RedditPost[]> {\n // Try API first\n try {\n console.log(` 📡 Trying Reddit API for r/${subreddit}...`);\n return await fetchSubredditPostsAPI(subreddit, limit);\n } catch (apiError) {\n console.log(` ⚠️ API failed for r/${subreddit}, trying JSON endpoint...`);\n\n // Try JSON endpoint\n try {\n return await fetchSubredditPostsJSON(subreddit, limit);\n } catch (jsonError) {\n console.log(` ⚠️ JSON failed for r/${subreddit}, trying RSS...`);\n\n // Try RSS as last resort\n try {\n return await fetchSubredditPostsRSS(subreddit);\n } catch (rssError) {\n console.error(` ❌ All methods failed for r/${subreddit}`);\n throw new Error(\n `All fetch methods failed for r/${subreddit}: API(${apiError.message}), JSON(${jsonError.message}), RSS(${rssError.message})`,\n );\n }\n }\n }\n}\n\n/**\n * Checks if a post contains any of the specified keywords\n */\nfunction containsKeywords(post: RedditPost, keywords: string[]): boolean {\n const searchText = `${post.title} ${post.selftext}`.toLowerCase();\n return keywords.some(keyword => searchText.includes(keyword.toLowerCase()));\n}\n\n/**\n * Formats a post for Slack notification\n */\nfunction formatPostForSlack(post: RedditPost, matchedKeywords: string[]): any {\n const redditUrl = `https://www.reddit.com${post.permalink}`;\n const createdDate = new Date(post.created_utc * 1000).toLocaleString();\n\n return {\n color: \"good\",\n title: post.title,\n title_link: redditUrl,\n fields: [\n {\n title: \"Keywords Found\",\n value: matchedKeywords.join(\", \"),\n short: true,\n },\n {\n title: \"Author\",\n value: `u/${post.author}`,\n short: true,\n },\n {\n title: \"Score\",\n value: `${post.score} points`,\n short: true,\n },\n {\n title: \"Comments\",\n value: `${post.num_comments} comments`,\n short: true,\n },\n {\n title: \"Posted\",\n value: createdDate,\n short: false,\n },\n ],\n text: post.selftext.substring(0, 300) + (post.selftext.length > 300 ? \"...\" : \"\"),\n footer: `r/${post.subreddit}`,\n ts: post.created_utc,\n };\n}\n\n/**\n * Sends notification to Slack\n */\nasync function sendSlackNotification(matchingPosts: Array<{ post: RedditPost; keywords: string[] }>): Promise<void> {\n if (!CONFIG.useSlack) return;\n\n const attachments = matchingPosts.map(({ post, keywords }) => formatPostForSlack(post, keywords));\n\n // Get unique subreddits from matching posts\n const uniqueSubreddits = [...new Set(matchingPosts.map(({ post }) => post.subreddit))];\n const subredditText = uniqueSubreddits.length === 1\n ? `r/${uniqueSubreddits[0]}`\n : `${uniqueSubreddits.length} subreddits (${uniqueSubreddits.map(s => `r/${s}`).join(\", \")})`;\n\n const message = {\n text: `🚨 *Unified Reddit Monitor Alert*: Found ${matchingPosts.length} new matching post${\n matchingPosts.length > 1 ? \"s\" : \"\"\n } in ${subredditText}`,\n attachments: attachments,\n };\n\n const response = await fetch(SLACK_WEBHOOK_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(message),\n });\n\n if (!response.ok) {\n throw new Error(`Slack notification failed: ${response.status} ${response.statusText}`);\n }\n}\n\n/**\n * Formats a post for email notification\n */\nfunction formatPostForEmail(post: RedditPost, matchedKeywords: string[]): string {\n const redditUrl = `https://www.reddit.com${post.permalink}`;\n const createdDate = new Date(post.created_utc * 1000).toLocaleString();\n\n return `\n📍 **New Match Found in r/${post.subreddit}!**\n🔍 **Keywords:** ${matchedKeywords.join(\", \")}\n📝 **Title:** ${post.title}\n👤 **Author:** u/${post.author}\n📊 **Score:** ${post.score} | 💬 **Comments:** ${post.num_comments}\n🕒 **Posted:** ${createdDate}\n🔗 **Link:** ${redditUrl}\n\n**Content Preview:**\n${post.selftext.substring(0, 300)}${post.selftext.length > 300 ? \"...\" : \"\"}\n\n---\n`;\n}\n\n/**\n * Sends email notification\n */\nasync function sendEmailNotification(matchingPosts: Array<{ post: RedditPost; keywords: string[] }>): Promise<void> {\n if (!CONFIG.useEmail) return;\n\n const emailBody = matchingPosts\n .map(({ post, keywords }) => formatPostForEmail(post, keywords))\n .join(\"\\n\");\n\n const uniqueSubreddits = [...new Set(matchingPosts.map(({ post }) => post.subreddit))];\n const subredditText = uniqueSubreddits.length === 1\n ? `r/${uniqueSubreddits[0]}`\n : `${uniqueSubreddits.length} subreddits`;\n\n await email({\n subject: `🚨 Unified Reddit Monitor Alert: ${matchingPosts.length} new matches in ${subredditText}`,\n text: emailBody,\n html: emailBody.replace(/\\n/g, \"<br>\").replace(/\\*\\*(.*?)\\*\\*/g, \"<strong>$1</strong>\"),\n });\n}\n\n/**\n * Saves matching posts to Supabase database\n */\nasync function saveToSupabase(matchingPosts: Array<{ post: RedditPost; keywords: string[] }>): Promise<void> {\n if (!CONFIG.useSupabase) return;\n\n console.log(`💾 Saving ${matchingPosts.length} posts to Supabase...`);\n\n // Convert posts to Supabase format\n const supabasePosts: SupabasePost[] = matchingPosts.map(({ post, keywords }) => ({\n title: post.title,\n author: post.author,\n keywords_found: keywords.join(\", \"),\n comments: post.num_comments.toString(),\n posted: new Date(post.created_utc * 1000).toISOString(),\n url: `https://www.reddit.com${post.permalink}`,\n }));\n\n try {\n const response = await fetch(`${SUPABASE_URL}/rest/v1/relevant_reddit_posts`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${SUPABASE_SERVICE_KEY}`,\n \"apikey\": SUPABASE_SERVICE_KEY,\n \"Prefer\": \"return=minimal\",\n },\n body: JSON.stringify(supabasePosts),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Supabase insert failed: ${response.status} ${response.statusText} - ${errorText}`);\n }\n\n console.log(`✅ Successfully saved ${supabasePosts.length} posts to Supabase`);\n } catch (error) {\n console.error(\"❌ Failed to save posts to Supabase:\", error);\n throw error;\n }\n}\n\n/**\n * Gets the last checked timestamp from storage\n */\nasync function getLastChecked(): Promise<number> {\n try {\n const data = await blob.getJSON(\"unified_reddit_monitor_last_checked\");\n return data?.timestamp || 0;\n } catch {\n return 0;\n }\n}\n\n/**\n * Saves the last checked timestamp to storage\n */\nasync function saveLastChecked(timestamp: number): Promise<void> {\n await blob.setJSON(\"unified_reddit_monitor_last_checked\", { timestamp });\n}\n\n/**\n * Sends error notifications\n */\nasync function sendErrorNotifications(error: Error): Promise<void> {\n // Send Slack error notification\n if (CONFIG.useSlack) {\n try {\n await fetch(SLACK_WEBHOOK_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n text: `🚨 *Unified Reddit Monitor Error*`,\n attachments: [{\n color: \"danger\",\n title: \"Monitor Failed\",\n text: `Unified Reddit monitor encountered an error: ${error.message}`,\n footer: \"Unified Reddit Monitor\",\n ts: Math.floor(Date.now() / 1000),\n }],\n }),\n });\n } catch (slackError) {\n console.error(\"Failed to send error notification to Slack:\", slackError);\n }\n }\n\n // Send email error notification\n if (CONFIG.useEmail) {\n try {\n await email({\n subject: \"🚨 Unified Reddit Monitor Error\",\n text: `Unified Reddit monitor encountered an error: ${error.message}\\n\\nStack trace:\\n${error.stack}`,\n });\n } catch (emailError) {\n console.error(\"Failed to send error notification via email:\", emailError);\n }\n }\n}\n\n/**\n * Main monitoring function - supports both HTTP endpoint and cron job execution\n */\nexport default async function(req?: Request) {\n // Handle both HTTP requests and cron job executions\n let action = \"run\";\n\n if (req && req.url) {\n const url = new URL(req.url);\n action = url.searchParams.get(\"action\") || \"run\";\n }\n\n // Only handle HTTP-specific actions if we have a request object\n if (req && req.url) {\n if (action === \"help\") {\n return new Response(\n `\n🔍 Unified Reddit Monitor\n\nAvailable actions:\n- ?action=run (default) - Run the monitor\n- ?action=status - Show current configuration\n- ?action=reset - Reset last checked timestamp\n- ?action=help - Show this help\n\nConfiguration:\n- Subreddits: ${CONFIG.subreddits.length} (${CONFIG.subreddits.map(s => `r/${s}`).join(\", \")})\n- Keywords: ${CONFIG.keywords.length} (${CONFIG.keywords.join(\", \")})\n- Post limit per subreddit: ${CONFIG.postLimit}\n- Slack notifications: ${CONFIG.useSlack ? \"Enabled\" : \"Disabled\"}\n- Email notifications: ${CONFIG.useEmail ? \"Enabled\" : \"Disabled\"}\n- Supabase database: ${CONFIG.useSupabase ? \"Enabled\" : \"Disabled\"}\n `,\n {\n headers: { \"Content-Type\": \"text/plain\" },\n },\n );\n }\n\n if (action === \"status\") {\n const lastChecked = await getLastChecked();\n return new Response(\n JSON.stringify(\n {\n config: CONFIG,\n lastChecked: lastChecked ? new Date(lastChecked * 1000).toISOString() : \"Never\",\n timestamp: Date.now(),\n },\n null,\n 2,\n ),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n if (action === \"reset\") {\n await saveLastChecked(0);\n return new Response(\"✅ Last checked timestamp reset to 0\", {\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n }\n\n // Default action: run the monitor\n console.log(`🚀 Starting Unified Reddit Monitor`);\n console.log(\n `📋 Monitoring ${CONFIG.subreddits.length} subreddits: ${CONFIG.subreddits.map(s => `r/${s}`).join(\", \")}`,\n );\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(\", \")}`);\n console.log(\n `📱 Notifications: Slack(${CONFIG.useSlack}), Email(${CONFIG.useEmail}), Supabase(${CONFIG.useSupabase})`,\n );\n\n try {\n // Get the last checked timestamp\n const lastChecked = await getLastChecked();\n console.log(`⏰ Last checked: ${lastChecked ? new Date(lastChecked * 1000).toLocaleString() : \"Never\"}`);\n\n let totalPosts = 0;\n let totalNewPosts = 0;\n let totalErrors = 0;\n const allMatchingPosts: Array<{ post: RedditPost; keywords: string[] }> = [];\n let latestPostTime = lastChecked;\n\n // Process each subreddit\n for (const subreddit of CONFIG.subreddits) {\n console.log(`\\n🔍 Processing r/${subreddit}...`);\n\n try {\n // Fetch recent posts from this subreddit (with fallback methods)\n const posts = await fetchSubredditPosts(subreddit, CONFIG.postLimit);\n console.log(` ✅ Fetched ${posts.length} posts from r/${subreddit}`);\n totalPosts += posts.length;\n\n // Filter posts that are newer than last check\n const newPosts = posts.filter(post => post.created_utc > lastChecked);\n console.log(` 🆕 Found ${newPosts.length} new posts in r/${subreddit} since last check`);\n totalNewPosts += newPosts.length;\n\n // Check for keyword matches\n for (const post of newPosts) {\n const matchedKeywords = CONFIG.keywords.filter(keyword => containsKeywords(post, [keyword]));\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(\n ` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${matchedKeywords.join(\", \")})`,\n );\n }\n }\n\n // Track the latest post time across all subreddits\n if (posts.length > 0) {\n const subredditLatestTime = Math.max(...posts.map(p => p.created_utc));\n latestPostTime = Math.max(latestPostTime, subredditLatestTime);\n }\n } catch (subredditError) {\n console.error(` ❌ Error processing r/${subreddit}:`, subredditError);\n totalErrors++;\n // Continue with other subreddits even if one fails\n }\n }\n\n console.log(`\\n📊 Final Summary:`);\n console.log(`📥 Total posts fetched: ${totalPosts}`);\n console.log(`🆕 Total new posts: ${totalNewPosts}`);\n console.log(`✅ Total matches found: ${allMatchingPosts.length}`);\n console.log(`❌ Subreddits with errors: ${totalErrors}`);\n\n // Send notifications if matches found\n if (allMatchingPosts.length > 0) {\n console.log(`\\n📱 Sending notifications and saving to database...`);\n\n if (CONFIG.useSlack) {\n try {\n await sendSlackNotification(allMatchingPosts);\n console.log(`✅ Slack notification sent`);\n } catch (slackError) {\n console.error(`❌ Slack notification failed:`, slackError);\n }\n }\n\n if (CONFIG.useEmail) {\n try {\n await sendEmailNotification(allMatchingPosts);\n console.log(`✅ Email notification sent`);\n } catch (emailError) {\n console.error(`❌ Email notification failed:`, emailError);\n }\n }\n\n if (CONFIG.useSupabase) {\n try {\n await saveToSupabase(allMatchingPosts);\n console.log(`✅ Posts saved to Supabase database`);\n } catch (supabaseError) {\n console.error(`❌ Supabase save failed:`, supabaseError);\n }\n }\n } else {\n console.log(`✨ No new matches found across all subreddits`);\n }\n\n // Update last checked timestamp to the most recent post time across all subreddits\n if (latestPostTime > lastChecked) {\n await saveLastChecked(latestPostTime);\n console.log(`💾 Updated last checked timestamp to: ${new Date(latestPostTime * 1000).toLocaleString()}`);\n }\n\n console.log(`\\n🎉 Unified Reddit Monitor completed successfully`);\n\n const result = {\n success: true,\n subredditsChecked: CONFIG.subreddits.length,\n subredditsWithErrors: totalErrors,\n postsChecked: totalPosts,\n newPosts: totalNewPosts,\n matches: allMatchingPosts.length,\n lastChecked: new Date(lastChecked * 1000).toISOString(),\n updatedLastChecked: new Date(latestPostTime * 1000).toISOString(),\n matchingPosts: allMatchingPosts.map(({ post, keywords }) => ({\n subreddit: post.subreddit,\n title: post.title,\n author: post.author,\n keywords: keywords,\n url: `https://www.reddit.com${post.permalink}`,\n })),\n };\n\n // Only return HTTP response if this was called via HTTP request\n if (req && req.url) {\n return new Response(JSON.stringify(result, null, 2), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // For cron jobs, just return undefined (no HTTP response needed)\n return;\n } catch (error) {\n console.error(\"❌ Unified Reddit Monitor failed:\", error);\n\n // Send error notifications\n await sendErrorNotifications(error);\n\n // Only return HTTP response if this was called via HTTP request\n if (req && req.url) {\n return new Response(\n JSON.stringify(\n {\n success: false,\n error: error.message,\n stack: error.stack,\n timestamp: new Date().toISOString(),\n },\n null,\n 2,\n ),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n // For cron jobs, just throw the error to be logged\n throw error;\n }\n}","deleted","label",[113],"82617d4a-5116-11f0-ba93-f69ea79377d9","README.md","8b238122-4eb3-11f0-b68d-f69ea79377d9",103,["D",1750781756693],41,"# Unified Reddit Monitor\n\nA simplified, comprehensive Reddit monitoring system that consolidates all monitoring functionality into a single script with automated cron scheduling!\n\n## 🚀 Features\n\n- **Unified Monitoring**: Single script handles all Reddit monitoring\n- **Multiple Methods**: Uses Reddit API with JSON and RSS fallbacks for reliability\n- **Multi-Subreddit Support**: Monitors 11 subreddits simultaneously\n- **Dual Notifications**: Sends both Slack and email notifications\n- **Database Storage**: Automatically saves matching posts to Supabase database\n- **Automated Scheduling**: Runs on cron schedule for consistent monitoring\n- **Manual Override**: Can also be run manually when needed\n- **Robust Error Handling**: Continues monitoring even if some subreddits fail\n- **Comprehensive Logging**: Detailed console output for debugging\n\n## 📁 Clean Project Structure\n\n```\n├── unified-reddit-monitor.ts # 🎯 MAIN SCRIPT - Runs on cron schedule (CRON) ✅ READY\n└── README.md # This file\n```\n\n**All legacy files have been removed!** The project now contains only the essential unified monitoring script.\n\n## 🎯 How to Use\n\n### Automated Monitoring (Primary Usage) ✅ READY\n\nThe monitor runs automatically on a cron schedule. **Set your preferred schedule in the Val Town web UI:**\n\n**Recommended Schedules:**\n- `*/30 * * * *` - Every 30 minutes (active monitoring)\n- `0 * * * *` - Every hour (balanced)\n- `0 */2 * * *` - Every 2 hours (moderate)\n- `0 */4 * * *` - Every 4 hours (conservative)\n- `0 9,21 * * *` - Twice daily at 9 AM and 9 PM\n\n### Manual Override (Optional)\n\nYou can also run the monitor manually anytime by visiting the HTTP endpoint:\n\n```\nGET /unified-reddit-monitor.ts\n```\n\n### Available Actions\n\n```\nGET /unified-reddit-monitor.ts?action=run # Run the monitor (default)\nGET /unified-reddit-monitor.ts?action=status # Show current configuration\nGET /unified-reddit-monitor.ts?action=reset # Reset last checked timestamp\nGET /unified-reddit-monitor.ts?action=help # Show help information\n```\n\n## ⚙️ Configuration\n\n### Current Settings ✅ CONFIGURED\n\n- **Subreddits**: 11 subreddits monitored\n - `r/lovable`, `r/AppBusiness`, `r/appdev`, `r/AppDevelopers`\n - `r/ChatGPTCoding`, `r/indiehackers`, `r/microsaas`, `r/replit`\n - `r/ReplitBuilders`, `r/vibecoding`, `r/ViralApps`\n- **Keywords**: \n - Authentication: `auth`, `authentication`, `login`, `user sessions`\n - Monetization: `stripe`, `subscriptions`, `monetization`, `paywall`, `feature gating`\n - Analytics: `analytics`\n - Business: `how do I make money with my app`\n- **Post Limit**: 25 posts per subreddit per check\n- **Notifications**: Both Slack and Email enabled\n- **Database**: Supabase integration enabled\n- **Execution**: Automated cron scheduling + manual override capability\n\n### Reddit API Credentials ✅ CONFIGURED\n\n- **Client ID**: `151sZ8h5TaHVZGZZn0rOhA`\n- **Client Secret**: `rX_YGngVjaxRA3Y0F3STl2cuEmgHkQ`\n\n## 🔧 Usage\n\n### Primary Usage ✅ READY\n\n**Automated**: The monitor runs automatically on your configured cron schedule.\n\n**Manual Override**: Run the monitor manually anytime:\n\n```\nGET /unified-reddit-monitor.ts\n```\n\n### Configuration Management\n\n```\nGET /unified-reddit-monitor.ts?action=status # View current settings\nGET /unified-reddit-monitor.ts?action=reset # Reset last checked timestamp\nGET /unified-reddit-monitor.ts?action=help # Show help and usage\n```\n\n## 📱 Notifications & Storage ✅ CONFIGURED\n\nWhen matches are found, the system will:\n\n### 1. Send Slack Notifications\n- **Header**: `🚨 Unified Reddit Monitor Alert: X new matching posts in Y subreddits`\n- **Rich Attachments** for each matching post including:\n - Post title (clickable link to Reddit)\n - Matched keywords\n - Author information\n - Score and comment count\n - Publication date\n - Content preview\n - Subreddit footer\n- **Webhook URL**: `https://hooks.slack.com/services/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`\n\n### 2. Send Email Notifications\n- **Subject**: `🚨 Unified Reddit Monitor Alert: X new matches in Y subreddits`\n- **Content**: Formatted text with all post details\n- **Format**: Both plain text and HTML versions\n\n### 3. Save to Supabase Database\n- **Table**: `relevant_reddit_posts`\n- **Fields Stored**:\n - `title` (text) - Post title\n - `author` (text) - Reddit username\n - `keywords_found` (text) - Comma-separated matched keywords\n - `comments` (text) - Number of comments\n - `posted` (text) - ISO timestamp when posted\n - `url` (text) - Full Reddit URL\n- **Project**: `ffilnpatwtlzjrfbmvxk.supabase.co`\n\n## 🔍 Monitoring Details\n\n### What Gets Monitored\n\n- **Post Titles**: Full text search for keywords across all 11 subreddits\n- **Post Content**: Self-text content of posts across all subreddits\n- **Frequency**: Automated cron execution + manual override capability\n- **Scope**: New posts since last check across all monitored subreddits\n- **Methods**: Reddit API (primary), JSON API (fallback), RSS feeds (last resort)\n\n### Keyword Matching ✅ TESTED\n\n- Case-insensitive matching\n- Partial word matching (e.g., \"auth\" matches \"authentication\")\n- Multiple keyword detection per post\n- Configurable keyword list\n\n## 🛠️ Customization\n\nTo modify the configuration, edit the `CONFIG` object in `unified-reddit-monitor.ts`:\n\n### Adding New Keywords\n\n```typescript\nconst CONFIG: MonitorConfig = {\n keywords: [\n 'auth', 'authentication', 'login', 'user sessions',\n 'stripe', 'subscriptions', 'monetization',\n 'paywall', 'feature gating', 'analytics',\n 'how do I make money with my app',\n 'YOUR_NEW_KEYWORD' // Add here\n ],\n // ... other settings\n};\n```\n\n### Adding New Subreddits\n\n```typescript\nconst CONFIG: MonitorConfig = {\n subreddits: [\n \"lovable\", \"AppBusiness\", \"appdev\", \"AppDevelopers\", \n \"ChatGPTCoding\", \"indiehackers\", \"microsaas\", \"replit\", \n \"ReplitBuilders\", \"vibecoding\", \"ViralApps\",\n \"YOUR_NEW_SUBREDDIT\" // Add here\n ],\n // ... other settings\n};\n```\n\n### Adjusting Settings\n\n```typescript\nconst CONFIG: MonitorConfig = {\n postLimit: 50, // Check 50 posts per subreddit instead of 25\n useSlack: true, // Enable/disable Slack notifications\n useEmail: false, // Enable/disable email notifications\n // ... other settings\n};\n```\n\n## 🔐 Security\n\n- Reddit API credentials are configured and working\n- Access tokens are cached and automatically refreshed\n- All API calls use proper authentication headers\n- Fallback methods ensure reliability even if primary API fails\n\n## ✅ System Status\n\n### Current Status: FULLY OPERATIONAL - CLEAN ARCHITECTURE\n\n- ✅ **Single Script**: One comprehensive monitoring script only\n- ✅ **No Legacy Files**: All unnecessary files removed\n- ✅ **Automated Scheduling**: Runs consistently on cron schedule\n- ✅ **Manual Override**: Can still be run manually when needed\n- ✅ **Multi-Method Fetching**: Reddit API → JSON API → RSS fallbacks\n- ✅ **Multi-Subreddit Support**: 11 subreddits monitored simultaneously\n- ✅ **Triple Output**: Slack notifications + Email alerts + Database storage\n- ✅ **Robust Error Handling**: Continues even if some subreddits fail\n- ✅ **Comprehensive Logging**: Detailed execution information\n\n### How to Use\n\n1. **Set Cron Schedule**: Configure your preferred schedule in Val Town web UI\n2. **Monitor Automatically**: The script runs on schedule and sends notifications\n3. **Manual Override**: Visit `/unified-reddit-monitor.ts` to run immediately\n4. **Check Status**: Use `?action=status` to see current configuration\n5. **Reset if Needed**: Use `?action=reset` to clear last checked timestamp\n6. **Get Help**: Use `?action=help` for usage information\n\n### Clean Architecture\n\nThe project now contains only the essential unified monitoring script. All legacy files, test files, and redundant components have been removed for maximum simplicity and maintainability.\n\n## 🐛 Troubleshooting\n\n### Common Issues\n\n1. **No Recent Matches**\n - Check if there are actually new posts with your keywords\n - Use `?action=status` to see when last checked\n - Use `?action=reset` to check all posts again\n\n2. **API Errors**\n - The script automatically falls back to JSON API then RSS\n - Check the response for detailed error information\n\n3. **Notification Issues**\n - Slack and email can be individually enabled/disabled in config\n - Check spam folder for emails\n - Verify Slack webhook URL is working\n\n### Debug Information\n\nThe unified script provides comprehensive logging:\n- Shows which method was used for each subreddit (API/JSON/RSS)\n- Reports errors per subreddit but continues with others\n- Provides detailed match information\n- Shows notification sending status\n\n## 📊 Benefits of Automated Monitoring\n\n✅ **Consistent Coverage**: Never miss new posts with automated scheduling\n✅ **Hands-Free Operation**: Set it once and let it run automatically \n✅ **Flexible Control**: Manual override available when needed\n✅ **Maximum Simplicity**: Single script handles everything\n✅ **Easy Maintenance**: One file to manage and update\n✅ **Reliable Operation**: Multiple fallback methods with robust error handling",[131],"pulls",0,"forks","envVars",{"_145":139,"_147":139},"connections",{"_145":139,"_146":139},"count","unfilledCount","emptyCount",{"_20":130,"_13":131,"_114":132,"_116":-5,"_117":21,"_118":133,"_119":120,"_22":154,"_29":135,"_123":99,"_125":136,"_127":38,"_128":-5,"_151":155,"_87":156},{"_20":112,"_13":113,"_114":115,"_116":-5,"_117":21,"_118":30,"_119":120,"_22":150,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_151":152,"_87":153},["D",1752329700210],"children",[],[113],["D",1750781756693],[],[131],["D",1750518892316],{"_11":12,"_85":81},{"_11":12,"_79":-5,"_80":81,"_44":45,"_82":83,"_84":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_74":-5,"_75":-5,"_76":-5,"_77":14,"_78":12},"ctx",{"_67":-5,"_107":194,"_195":196,"_197":198,"_199":38,"_200":38,"_201":38,"_202":120,"_203":-5,"_204":-7,"_205":-7,"_206":139,"_207":38,"_208":38,"_209":-5,"_210":38,"_211":38,"_212":38,"_213":-5},"ENV",{"_165":166,"_167":168,"_169":26,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"] </article></body></html>

Branches1

Branches
1