<!\\[CDATA\\[(.*?)\\]\\]><\\/title>/)?.[1] ||\n itemXml.match(/<title>(.*?)<\\/title>/)?.[1] || \"\";\n\n const link = itemXml.match(/<link>(.*?)<\\/link>/)?.[1] || \"\";\n\n const description =\n itemXml.match(/<description><!\\[CDATA\\[(.*?)\\]\\]><\\/description>/)\n ?.[1] ||\n itemXml.match(/<description>(.*?)<\\/description>/)?.[1] || \"\";\n\n const pubDate = itemXml.match(/<pubDate>(.*?)<\\/pubDate>/)?.[1] || \"\";\n\n const author =\n 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(\n subreddit: string,\n): 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\":\n \"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(\n `Reddit RSS error: ${response.status} ${response.statusText}`,\n );\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(\n subreddit: string,\n limit: number = 25,\n): 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 email notification\n */\nfunction formatPostForEmail(\n post: RedditPost,\n matchedKeywords: string[],\n): 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(\n matchingPosts: Array<{ post: RedditPost; keywords: string[] }>,\n): 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 = [\n ...new Set(matchingPosts.map(({ post }) => post.subreddit)),\n ];\n const subredditText = uniqueSubreddits.length === 1\n ? `r/${uniqueSubreddits[0]}`\n : `${uniqueSubreddits.length} subreddits`;\n\n await email({\n to: \"sunny@getlightswitch.com\",\n subject:\n `🚨 Unified Reddit Monitor Alert: ${matchingPosts.length} new matches in ${subredditText}`,\n text: emailBody,\n html: emailBody.replace(/\\n/g, \"<br>\").replace(\n /\\*\\*(.*?)\\*\\*/g,\n \"<strong>$1</strong>\",\n ),\n });\n}\n\n/**\n * Saves matching posts to Notion database\n */\nasync function saveToNotion(\n matchingPosts: Array<{ post: RedditPost; keywords: string[] }>,\n): Promise<void> {\n if (!CONFIG.useNotion || !NOTION_DATABASE_ID) {\n if (!NOTION_DATABASE_ID) {\n console.log(\"⚠️ Notion database ID not configured, skipping Notion save\");\n }\n return;\n }\n\n console.log(`💾 Saving ${matchingPosts.length} posts to Notion...`);\n\n for (const { post, keywords } of matchingPosts) {\n try {\n const notionPost = {\n parent: {\n database_id: NOTION_DATABASE_ID,\n },\n properties: {\n \"Title\": {\n title: [\n {\n text: {\n content: post.title.substring(0, 2000), // Notion title limit\n },\n },\n ],\n },\n \"URL\": {\n url: `https://www.reddit.com${post.permalink}`,\n },\n \"Subreddit\": {\n rich_text: [\n {\n text: {\n content: `r/${post.subreddit}`,\n },\n },\n ],\n },\n \"Author\": {\n rich_text: [\n {\n text: {\n content: `u/${post.author}`,\n },\n },\n ],\n },\n \"Post Body\": {\n rich_text: [\n {\n text: {\n content: post.selftext.substring(0, 2000), // Notion rich text limit\n },\n },\n ],\n },\n \"Matched Keywords\": {\n rich_text: [\n {\n text: {\n content: keywords.join(\", \"),\n },\n },\n ],\n },\n \"Date Found\": {\n rich_text: [\n {\n text: {\n content: new Date().toISOString().split(\"T\")[0], // Today's date as text\n },\n },\n ],\n },\n },\n };\n\n const response = await fetch(\"https://api.notion.com/v1/pages\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${NOTION_SECRET}`,\n \"Content-Type\": \"application/json\",\n \"Notion-Version\": \"2022-06-28\",\n },\n body: JSON.stringify(notionPost),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(\n `Notion API error: ${response.status} ${response.statusText} - ${errorText}`,\n );\n }\n\n console.log(\n `✅ Saved post \"${post.title.substring(0, 50)}...\" to Notion`,\n );\n } catch (error) {\n console.error(\n `❌ Failed to save post \"${post.title.substring(0, 50)}...\" to Notion:`,\n error,\n );\n // Continue with other posts even if one fails\n }\n }\n\n console.log(`✅ Finished saving posts to Notion`);\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 email error notification\n if (CONFIG.useEmail) {\n try {\n await email({\n to: \"sunny@getlightswitch.com\",\n subject: \"🚨 Unified Reddit Monitor Error\",\n text:\n `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=test-notion - Test Notion integration with sample post\n- ?action=help - Show this help\n\nConfiguration:\n- Subreddits: ${CONFIG.subreddits.length} (${\n CONFIG.subreddits.map((s) => `r/${s}`).join(\", \")\n })\n- Keywords: ${CONFIG.keywords.length} (${CONFIG.keywords.join(\", \")})\n- Post limit per subreddit: ${CONFIG.postLimit}\n- Email notifications: ${CONFIG.useEmail ? \"Enabled\" : \"Disabled\"}\n- Notion database: ${CONFIG.useNotion ? \"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\n ? new Date(lastChecked * 1000).toISOString()\n : \"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 if (action === \"test-notion\") {\n // Test Notion integration with a sample post\n if (!NOTION_DATABASE_ID) {\n return new Response(\n \"❌ NOTION_DATABASE_ID environment variable not set\",\n {\n status: 400,\n headers: { \"Content-Type\": \"text/plain\" },\n },\n );\n }\n\n const testPost = {\n post: {\n id: \"test123\",\n title: \"🧪 Test Post - Reddit Monitor Integration Test\",\n selftext:\n \"This is a test post to verify that the Notion integration is working correctly. If you see this in your Notion database, the integration is successful!\",\n url: \"https://reddit.com/test\",\n author: \"reddit-monitor-test\",\n created_utc: Math.floor(Date.now() / 1000),\n score: 42,\n num_comments: 5,\n permalink: \"/r/test/comments/test123/test_post/\",\n subreddit: \"test\",\n },\n keywords: [\"test\", \"integration\"],\n };\n\n try {\n await saveToNotion([testPost]);\n return new Response(\n \"✅ Test post successfully saved to Notion! Check your database.\",\n {\n headers: { \"Content-Type\": \"text/plain\" },\n },\n );\n } catch (error) {\n return new Response(`❌ Notion test failed: ${error.message}`, {\n status: 500,\n headers: { \"Content-Type\": \"text/plain\" },\n });\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: ${\n CONFIG.subreddits.map((s) => `r/${s}`).join(\", \")\n }`,\n );\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(\", \")}`);\n console.log(\n `📱 Notifications: Email(${CONFIG.useEmail}), Notion(${CONFIG.useNotion})`,\n );\n\n try {\n // Get the last checked timestamp\n const lastChecked = await getLastChecked();\n console.log(\n `⏰ Last checked: ${\n lastChecked ? new Date(lastChecked * 1000).toLocaleString() : \"Never\"\n }`,\n );\n\n let totalPosts = 0;\n let totalNewPosts = 0;\n let totalErrors = 0;\n const allMatchingPosts: Array<{ post: RedditPost; keywords: string[] }> =\n [];\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(\n ` 🆕 Found ${newPosts.length} new posts in r/${subreddit} since last check`,\n );\n totalNewPosts += newPosts.length;\n\n // Check for keyword matches\n for (const post of newPosts) {\n const matchedKeywords = CONFIG.keywords.filter((keyword) =>\n containsKeywords(post, [keyword])\n );\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(\n ` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${\n matchedKeywords.join(\", \")\n })`,\n );\n }\n }\n\n // Track the latest post time across all subreddits\n if (posts.length > 0) {\n const subredditLatestTime = Math.max(\n ...posts.map((p) => p.created_utc),\n );\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.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.useNotion) {\n try {\n await saveToNotion(allMatchingPosts);\n console.log(`✅ Posts saved to Notion database`);\n } catch (notionError) {\n console.error(`❌ Notion save failed:`, notionError);\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(\n `💾 Updated last checked timestamp to: ${\n new Date(latestPostTime * 1000).toLocaleString()\n }`,\n );\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",[123],"f34b8fe2-76fe-11f0-85c2-0224a6c84d84","README.md","01989b18-0862-7765-9655-10d536ea46e4",58,["D",1754949782392],21,"# 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 Output**: Email notifications and Notion database storage\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**: Email notifications and Notion database storage enabled\n- **Execution**: Automated cron scheduling + manual override capability\n\n### Notion Database Setup 🔧 REQUIRED\n\nTo enable Notion integration, you need to:\n\n1. **Create a Notion Database** with these exact field names:\n - `Title` (Title field)\n - `URL` (URL field) \n - `Subreddit` (Text field)\n - `Author` (Text field)\n - `Post Body` (Text field)\n - `Matched Keywords` (Text field)\n - `Date Found` (Text field)\n\n2. **Set Environment Variable**: Add `NOTION_DATABASE_ID` environment variable in Val Town with your database ID\n\n3. **Get Database ID**: Copy the database ID from your Notion database URL (the long string after the last `/` and before any `?`)\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 Email Notifications\n- **Recipient**: sunny@getlightswitch.com\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### 2. Save to Notion Database\n- **Fields Stored**:\n - `Title` - Post title\n - `URL` - Full Reddit URL\n - `Subreddit` - Subreddit name (e.g., r/lovable)\n - `Author` - Reddit username (e.g., u/username)\n - `Post Body` - Content of the post\n - `Matched Keywords` - Comma-separated matched keywords\n - `Date Found` - Date when the match was discovered\n- **Integration**: Uses Notion API with secret key authentication\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 useEmail: false, // Enable/disable email notifications\n useNotion: true, // Enable/disable Notion database storage\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 - NOTION INTEGRATION ADDED\n\n- ✅ **Single Script**: One comprehensive monitoring script only\n- ✅ **No Legacy Files**: All unnecessary files removed\n- ✅ **Notion Integration**: Added Notion database storage for matches\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- ✅ **Dual Output**: Email notifications + Notion 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 with email notifications and Notion database storage. All legacy files and test files 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 - Check spam folder for emails\n - Email notifications can be enabled/disabled in config\n - Verify Notion database ID is configured correctly\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 Notion-Integrated 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✅ **Organized Storage**: All matches automatically saved to Notion database\n✅ **Easy Maintenance**: One file to manage and update\n✅ **Reliable Operation**: Multiple fallback methods with robust error handling\n✅ **Structured Data**: Searchable and filterable posts in Notion",[141],"pulls",1,"forks","envVars",{"_155":53,"_157":53},"connections",{"_155":53,"_156":53},"count","unfilledCount","emptyCount",{"_20":140,"_13":141,"_124":142,"_126":-5,"_127":21,"_128":143,"_129":130,"_22":164,"_29":145,"_133":102,"_135":146,"_137":40,"_138":-5,"_161":165,"_90":166},{"_20":122,"_13":123,"_124":125,"_126":-5,"_127":21,"_128":30,"_129":130,"_22":160,"_29":132,"_133":134,"_135":136,"_137":40,"_138":-5,"_161":162,"_90":163},["D",1754949855334],"children",[],[123],["D",1754949782392],[],[141],["D",1754948700109],{"_11":12,"_88":84},{"_11":12,"_82":-5,"_83":84,"_46":47,"_85":86,"_87":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_76":42,"_77":78,"_79":55,"_80":14,"_81":12},"ctx",{"_69":-5,"_112":204,"_205":206,"_207":208,"_209":40,"_210":40,"_211":40,"_212":130,"_213":-5,"_214":-7,"_215":-7,"_216":53,"_217":40,"_218":40,"_219":-5,"_220":40,"_221":40,"_222":40,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":26,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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