<!\\[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(`All fetch methods failed for r/${subreddit}: API(${apiError.message}), JSON(${jsonError.message}), RSS(${rssError.message})`);\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 }) => \n formatPostForSlack(post, keywords)\n );\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${matchingPosts.length > 1 ? 's' : ''} 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, ' ').replace(/\\*\\*(.*?)\\*\\*/g, '$1')\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 - HTTP endpoint for manual execution\n */\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get('action') || 'run';\n\n if (action === 'help') {\n return new Response(`\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 `, {\n headers: { 'Content-Type': 'text/plain' }\n });\n }\n\n if (action === 'status') {\n const lastChecked = await getLastChecked();\n return new Response(JSON.stringify({\n config: CONFIG,\n lastChecked: lastChecked ? new Date(lastChecked * 1000).toISOString() : 'Never',\n timestamp: Date.now()\n }, null, 2), {\n headers: { 'Content-Type': 'application/json' }\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 // Default action: run the monitor\n console.log(`🚀 Starting Unified Reddit Monitor`);\n console.log(`📋 Monitoring ${CONFIG.subreddits.length} subreddits: ${CONFIG.subreddits.map(s => `r/${s}`).join(', ')}`);\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(', ')}`);\n console.log(`📱 Notifications: Slack(${CONFIG.useSlack}), Email(${CONFIG.useEmail})`);\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 => \n containsKeywords(post, [keyword])\n );\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${matchedKeywords.join(', ')})`);\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\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...`);\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 } 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 return new Response(JSON.stringify(result, null, 2), {\n headers: { 'Content-Type': 'application/json' }\n });\n\n } catch (error) {\n console.error('❌ Unified Reddit Monitor failed:', error);\n \n // Send error notifications\n await sendErrorNotifications(error);\n\n return new Response(JSON.stringify({\n success: false,\n error: error.message,\n stack: error.stack,\n timestamp: new Date().toISOString()\n }, null, 2), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}","/**\n * Unified Reddit Monitor - Single comprehensive monitoring script\n * \n * This script consolidates all Reddit monitoring functionality into one place:\n * - Monitors multiple subreddits using Reddit's official API (primary method)\n * - Falls back to RSS feeds if API fails\n * - Sends both Slack and email notifications\n * - Tracks keywords across all configured subreddits\n * - Prevents duplicate notifications\n * \n * Run this manually when needed - no more cron jobs!\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\n\ninterface RedditPost {\n id: string;\n title: string;\n selftext: string;\n url: string;\n author: string;\n created_utc: number;\n score: number;\n num_comments: number;\n permalink: string;\n subreddit: string;\n}\n\ninterface RedditResponse {\n data: {\n children: Array<{\n data: RedditPost;\n }>;\n after?: string;\n };\n}\n\ninterface RedditAccessToken {\n access_token: string;\n token_type: string;\n expires_in: number;\n scope: string;\n}\n\ninterface RSSItem {\n title: string;\n link: string;\n description: string;\n pubDate: string;\n author: string;\n guid: string;\n}\n\ninterface MonitorConfig {\n subreddits: string[];\n keywords: string[];\n postLimit: number;\n useSlack: boolean;\n useEmail: boolean;\n useSupabase: boolean;\n}\n\ninterface SupabasePost {\n title: string;\n author: string;\n keywords_found: string;\n comments: string;\n posted: string;\n url: string;\n}\n\n// Consolidated configuration\nconst CONFIG: MonitorConfig = {\n subreddits: [\n \"lovable\",\n \"AppBusiness\", \n \"appdev\",\n \"AppDevelopers\",\n \"ChatGPTCoding\",\n \"indiehackers\",\n \"microsaas\",\n \"replit\",\n \"ReplitBuilders\",\n \"vibecoding\",\n \"ViralApps\"\n ],\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 ],\n postLimit: 25,\n useSlack: true,\n useEmail: true,\n useSupabase: true\n};\n\n// Reddit API credentials\nconst REDDIT_CLIENT_SECRET = 'rX_YGngVjaxRA3Y0F3STl2cuEmgHkQ';\nconst REDDIT_CLIENT_ID = '151sZ8h5TaHVZGZZn0rOhA';\n\n// Slack webhook URL\nconst SLACK_WEBHOOK_URL = 'https://hooks.slack.com/services/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';\n\n// Supabase configuration\nconst SUPABASE_URL = 'https://ffilnpatwtlzjrfbmvxk.supabase.co';\nconst SUPABASE_ANON_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6ImFub24iLCJpYXQiOjE3NDk1MTA1OTAsImV4cCI6MjA2NTA4NjU5MH0.TI5pVzlHxGAcmIX7qlKniKUWxioivYjgajxD-DyhV-Q';\nconst SUPABASE_SERVICE_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImlhdCI6MTc0OTUxMDU5MCwiZXhwIjoyMDY1MDg2NTkwfQ.yGCSs4IWccCrVqYnalV2Ohv8SALGhGbFulJOppOBiok';\n\n/**\n * Gets an access token from Reddit API\n */\nasync function getRedditAccessToken(): Promise<string> {\n try {\n // Check if we have a cached token\n const cachedToken = await blob.getJSON(\"unified_reddit_access_token\");\n if (cachedToken && cachedToken.expires_at > Date.now()) {\n return cachedToken.access_token;\n }\n\n // Get new token using client credentials flow\n const auth = btoa(`${REDDIT_CLIENT_ID}:${REDDIT_CLIENT_SECRET}`);\n \n const response = await fetch('https://www.reddit.com/api/v1/access_token', {\n method: 'POST',\n headers: {\n 'Authorization': `Basic ${auth}`,\n 'Content-Type': 'application/x-www-form-urlencoded',\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n },\n body: 'grant_type=client_credentials'\n });\n\n if (!response.ok) {\n throw new Error(`Reddit auth error: ${response.status} ${response.statusText}`);\n }\n\n const tokenData: RedditAccessToken = await response.json();\n \n // Cache the token\n await blob.setJSON(\"unified_reddit_access_token\", {\n access_token: tokenData.access_token,\n expires_at: Date.now() + (tokenData.expires_in * 1000) - 60000 // 1 minute buffer\n });\n\n return tokenData.access_token;\n } catch (error) {\n console.error('Error getting Reddit access token:', error);\n throw error;\n }\n}\n\n/**\n * Fetches recent posts from a subreddit using Reddit API\n */\nasync function fetchSubredditPostsAPI(subreddit: string, limit: number = 25): Promise<RedditPost[]> {\n try {\n const accessToken = await getRedditAccessToken();\n const url = `https://oauth.reddit.com/r/${subreddit}/new?limit=${limit}`;\n \n const response = await fetch(url, {\n headers: {\n 'Authorization': `Bearer ${accessToken}`,\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via API:`, error);\n throw error;\n }\n}\n\n/**\n * Fallback: Fetches recent posts using Reddit's JSON endpoint\n */\nasync function fetchSubredditPostsJSON(subreddit: string, limit: number = 25): Promise<RedditPost[]> {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/new.json?limit=${limit}`;\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/json',\n 'Accept-Language': 'en-US,en;q=0.9',\n 'Cache-Control': 'no-cache'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit JSON API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via JSON:`, error);\n throw error;\n }\n}\n\n/**\n * Parses RSS/Atom XML and extracts items\n */\nfunction parseRSS(xmlText: string): RSSItem[] {\n const items: RSSItem[] = [];\n \n // Check if it's Atom or RSS format\n const isAtom = xmlText.includes('<feed xmlns=\"http://www.w3.org/2005/Atom\"');\n \n if (isAtom) {\n // Parse Atom feed\n const entryMatches = xmlText.match(/<entry[^>]*>[\\s\\S]*?<\\/entry>/g);\n \n if (!entryMatches) return items;\n \n for (const entryXml of entryMatches) {\n const title = entryXml.match(/<title[^>]*>(.*?)<\\/title>/)?.[1] || '';\n \n const linkMatch = entryXml.match(/<link[^>]*href=\"([^\"]*)\"[^>]*\\/?>/) || \n entryXml.match(/<link[^>]*href='([^']*)'[^>]*\\/?>/);\n const link = linkMatch?.[1] || '';\n \n const content = entryXml.match(/<content[^>]*>([\\s\\S]*?)<\\/content>/)?.[1] || '';\n \n const published = entryXml.match(/<published>(.*?)<\\/published>/)?.[1] || \n entryXml.match(/<updated>(.*?)<\\/updated>/)?.[1] || '';\n \n const authorMatch = entryXml.match(/<author>[\\s\\S]*?<name>(.*?)<\\/name>[\\s\\S]*?<\\/author>/);\n const author = authorMatch?.[1] || '';\n \n const id = entryXml.match(/<id>(.*?)<\\/id>/)?.[1] || link;\n \n items.push({\n title: title.trim(),\n link: link.trim(),\n description: content.trim(),\n pubDate: published.trim(),\n author: author.trim(),\n guid: id.trim()\n });\n }\n } else {\n // Parse RSS feed\n const itemMatches = xmlText.match(/<item[^>]*>[\\s\\S]*?<\\/item>/g);\n \n if (!itemMatches) return items;\n \n for (const itemXml of itemMatches) {\n const title = itemXml.match(/<title><!\\[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(`All fetch methods failed for r/${subreddit}: API(${apiError.message}), JSON(${jsonError.message}), RSS(${rssError.message})`);\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 }) => \n formatPostForSlack(post, keywords)\n );\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${matchingPosts.length > 1 ? 's' : ''} 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, ' ').replace(/\\*\\*(.*?)\\*\\*/g, '$1')\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 - HTTP endpoint for manual execution\n */\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get('action') || 'run';\n\n if (action === 'help') {\n return new Response(`\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 `, {\n headers: { 'Content-Type': 'text/plain' }\n });\n }\n\n if (action === 'status') {\n const lastChecked = await getLastChecked();\n return new Response(JSON.stringify({\n config: CONFIG,\n lastChecked: lastChecked ? new Date(lastChecked * 1000).toISOString() : 'Never',\n timestamp: Date.now()\n }, null, 2), {\n headers: { 'Content-Type': 'application/json' }\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 // Default action: run the monitor\n console.log(`🚀 Starting Unified Reddit Monitor`);\n console.log(`📋 Monitoring ${CONFIG.subreddits.length} subreddits: ${CONFIG.subreddits.map(s => `r/${s}`).join(', ')}`);\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(', ')}`);\n console.log(`📱 Notifications: Slack(${CONFIG.useSlack}), Email(${CONFIG.useEmail})`);\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 => \n containsKeywords(post, [keyword])\n );\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${matchedKeywords.join(', ')})`);\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\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 return new Response(JSON.stringify(result, null, 2), {\n headers: { 'Content-Type': 'application/json' }\n });\n\n } catch (error) {\n console.error('❌ Unified Reddit Monitor failed:', error);\n \n // Send error notifications\n await sendErrorNotifications(error);\n\n return new Response(JSON.stringify({\n success: false,\n error: error.message,\n stack: error.stack,\n timestamp: new Date().toISOString()\n }, null, 2), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}","createdAt",["D",1750781690815],"branchVersion","branchId","7affaaf6-4eb2-11f0-81ba-f69ea79377d9","id","7aff69ce-4eb2-11f0-81ba-f69ea79377d9","reddit-checker",["D",1750518892316],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","36d13ee0-4e48-11f0-babe-cd8177b6b491","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"orgId","0ca4d393-3df3-4cf6-ac8d-69c7934a98f0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",111,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sunnyatlightswitch","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ5bmJOYktLcDcxN1JjVElZSWtvWHFZdmxVSiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":161,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":162,"_78":163,"_80":164,"_82":25},"tree",[152,153],"files",[152,153],"counts",{"_141":142,"_143":60,"_144":60,"_145":146,"_147":148},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":25,"_38":137,"_13":138,"_33":20,"_35":139,"_24":25,"_131":-5,"_27":140},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"5b1d561e-5116-11f0-a145-f69ea79377d9","parentId","latest",["D",1750781690815],7,"label",[28],"6fe0b13c-5115-11f0-84b3-f69ea79377d9","README.md","8b238122-4eb3-11f0-b68d-f69ea79377d9",92,["D",1750781296153],37,"# 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- **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- **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 ✅ CONFIGURED\n\nWhen matches are found, you'll receive notifications via:\n\n### 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### 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## 🔍 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- ✅ **Dual Notifications**: Both Slack and email working\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",[134],"pulls",0,"branches","forks","envVars",{"_149":142,"_151":142},"connections",{"_149":142,"_150":142},"count","unfilledCount","emptyCount",{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":25,"_38":158,"_13":138,"_33":20,"_35":139,"_24":25,"_131":-5,"_155":159,"_27":160},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":154,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_155":156,"_27":157},["D",1750781690815],"children",[],[28],["D",1750781296153],[],[134],["D",1750518892316],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":198,"_199":200,"_201":202,"_203":25,"_204":25,"_205":25,"_206":207,"_208":-5,"_209":-7,"_210":-7,"_211":142,"_212":25,"_213":25,"_214":-5,"_215":25,"_216":25,"_217":25,"_218":-5},"ENV",{"_169":170,"_171":172,"_173":84,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",97,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","unified-reddit-monitor.ts","latestPath","fileId","aa5456ac-5106-11f0-b863-f69ea79377d9","name","fileType","interval","content","/**\n * Unified Reddit Monitor - Single comprehensive monitoring script\n * \n * This script consolidates all Reddit monitoring functionality into one place:\n * - Monitors multiple subreddits using Reddit's official API (primary method)\n * - Falls back to RSS feeds if API fails\n * - Sends both Slack and email notifications\n * - Tracks keywords across all configured subreddits\n * - Prevents duplicate notifications\n * \n * Run this manually when needed - no more cron jobs!\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\n\ninterface RedditPost {\n id: string;\n title: string;\n selftext: string;\n url: string;\n author: string;\n created_utc: number;\n score: number;\n num_comments: number;\n permalink: string;\n subreddit: string;\n}\n\ninterface RedditResponse {\n data: {\n children: Array<{\n data: RedditPost;\n }>;\n after?: string;\n };\n}\n\ninterface RedditAccessToken {\n access_token: string;\n token_type: string;\n expires_in: number;\n scope: string;\n}\n\ninterface RSSItem {\n title: string;\n link: string;\n description: string;\n pubDate: string;\n author: string;\n guid: string;\n}\n\ninterface MonitorConfig {\n subreddits: string[];\n keywords: string[];\n postLimit: number;\n useSlack: boolean;\n useEmail: boolean;\n useSupabase: boolean;\n}\n\ninterface SupabasePost {\n title: string;\n author: string;\n keywords_found: string;\n comments: string;\n posted: string;\n url: string;\n}\n\n// Consolidated configuration\nconst CONFIG: MonitorConfig = {\n subreddits: [\n \"lovable\",\n \"AppBusiness\", \n \"appdev\",\n \"AppDevelopers\",\n \"ChatGPTCoding\",\n \"indiehackers\",\n \"microsaas\",\n \"replit\",\n \"ReplitBuilders\",\n \"vibecoding\",\n \"ViralApps\"\n ],\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 ],\n postLimit: 25,\n useSlack: true,\n useEmail: true,\n useSupabase: true\n};\n\n// Reddit API credentials\nconst REDDIT_CLIENT_SECRET = 'rX_YGngVjaxRA3Y0F3STl2cuEmgHkQ';\nconst REDDIT_CLIENT_ID = '151sZ8h5TaHVZGZZn0rOhA';\n\n// Slack webhook URL\nconst SLACK_WEBHOOK_URL = 'https://hooks.slack.com/services/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';\n\n// Supabase configuration\nconst SUPABASE_URL = 'https://ffilnpatwtlzjrfbmvxk.supabase.co';\nconst SUPABASE_ANON_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6ImFub24iLCJpYXQiOjE3NDk1MTA1OTAsImV4cCI6MjA2NTA4NjU5MH0.TI5pVzlHxGAcmIX7qlKniKUWxioivYjgajxD-DyhV-Q';\nconst SUPABASE_SERVICE_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImlhdCI6MTc0OTUxMDU5MCwiZXhwIjoyMDY1MDg2NTkwfQ.yGCSs4IWccCrVqYnalV2Ohv8SALGhGbFulJOppOBiok';\n\n/**\n * Gets an access token from Reddit API\n */\nasync function getRedditAccessToken(): Promise {\n try {\n // Check if we have a cached token\n const cachedToken = await blob.getJSON(\"unified_reddit_access_token\");\n if (cachedToken && cachedToken.expires_at > Date.now()) {\n return cachedToken.access_token;\n }\n\n // Get new token using client credentials flow\n const auth = btoa(`${REDDIT_CLIENT_ID}:${REDDIT_CLIENT_SECRET}`);\n \n const response = await fetch('https://www.reddit.com/api/v1/access_token', {\n method: 'POST',\n headers: {\n 'Authorization': `Basic ${auth}`,\n 'Content-Type': 'application/x-www-form-urlencoded',\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n },\n body: 'grant_type=client_credentials'\n });\n\n if (!response.ok) {\n throw new Error(`Reddit auth error: ${response.status} ${response.statusText}`);\n }\n\n const tokenData: RedditAccessToken = await response.json();\n \n // Cache the token\n await blob.setJSON(\"unified_reddit_access_token\", {\n access_token: tokenData.access_token,\n expires_at: Date.now() + (tokenData.expires_in * 1000) - 60000 // 1 minute buffer\n });\n\n return tokenData.access_token;\n } catch (error) {\n console.error('Error getting Reddit access token:', error);\n throw error;\n }\n}\n\n/**\n * Fetches recent posts from a subreddit using Reddit API\n */\nasync function fetchSubredditPostsAPI(subreddit: string, limit: number = 25): Promise {\n try {\n const accessToken = await getRedditAccessToken();\n const url = `https://oauth.reddit.com/r/${subreddit}/new?limit=${limit}`;\n \n const response = await fetch(url, {\n headers: {\n 'Authorization': `Bearer ${accessToken}`,\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via API:`, error);\n throw error;\n }\n}\n\n/**\n * Fallback: Fetches recent posts using Reddit's JSON endpoint\n */\nasync function fetchSubredditPostsJSON(subreddit: string, limit: number = 25): Promise {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/new.json?limit=${limit}`;\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/json',\n 'Accept-Language': 'en-US,en;q=0.9',\n 'Cache-Control': 'no-cache'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit JSON API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via JSON:`, error);\n throw error;\n }\n}\n\n/**\n * Parses RSS/Atom XML and extracts items\n */\nfunction parseRSS(xmlText: string): RSSItem[] {\n const items: RSSItem[] = [];\n \n // Check if it's Atom or RSS format\n const isAtom = xmlText.includes(']*>[\\s\\S]*?<\\/entry>/g);\n \n if (!entryMatches) return items;\n \n for (const entryXml of entryMatches) {\n const title = entryXml.match(/]*>(.*?)<\\/title>/)?.[1] || '';\n \n const linkMatch = entryXml.match(/]*href=\"([^\"]*)\"[^>]*\\/?>/) || \n entryXml.match(/]*href='([^']*)'[^>]*\\/?>/);\n const link = linkMatch?.[1] || '';\n \n const content = entryXml.match(/]*>([\\s\\S]*?)<\\/content>/)?.[1] || '';\n \n const published = entryXml.match(/(.*?)<\\/published>/)?.[1] || \n entryXml.match(/(.*?)<\\/updated>/)?.[1] || '';\n \n const authorMatch = entryXml.match(/[\\s\\S]*?(.*?)<\\/name>[\\s\\S]*?<\\/author>/);\n const author = authorMatch?.[1] || '';\n \n const id = entryXml.match(/(.*?)<\\/id>/)?.[1] || link;\n \n items.push({\n title: title.trim(),\n link: link.trim(),\n description: content.trim(),\n pubDate: published.trim(),\n author: author.trim(),\n guid: id.trim()\n });\n }\n } else {\n // Parse RSS feed\n const itemMatches = xmlText.match(/]*>[\\s\\S]*?<\\/item>/g);\n \n if (!itemMatches) return items;\n \n for (const itemXml of itemMatches) {\n const title = itemXml.match(/<!\\[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(`All fetch methods failed for r/${subreddit}: API(${apiError.message}), JSON(${jsonError.message}), RSS(${rssError.message})`);\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 }) => \n formatPostForSlack(post, keywords)\n );\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${matchingPosts.length > 1 ? 's' : ''} 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, ' ').replace(/\\*\\*(.*?)\\*\\*/g, '$1')\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 - HTTP endpoint for manual execution\n */\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get('action') || 'run';\n\n if (action === 'help') {\n return new Response(`\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 `, {\n headers: { 'Content-Type': 'text/plain' }\n });\n }\n\n if (action === 'status') {\n const lastChecked = await getLastChecked();\n return new Response(JSON.stringify({\n config: CONFIG,\n lastChecked: lastChecked ? new Date(lastChecked * 1000).toISOString() : 'Never',\n timestamp: Date.now()\n }, null, 2), {\n headers: { 'Content-Type': 'application/json' }\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 // Default action: run the monitor\n console.log(`🚀 Starting Unified Reddit Monitor`);\n console.log(`📋 Monitoring ${CONFIG.subreddits.length} subreddits: ${CONFIG.subreddits.map(s => `r/${s}`).join(', ')}`);\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(', ')}`);\n console.log(`📱 Notifications: Slack(${CONFIG.useSlack}), Email(${CONFIG.useEmail})`);\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 => \n containsKeywords(post, [keyword])\n );\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${matchedKeywords.join(', ')})`);\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\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...`);\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 } 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 return new Response(JSON.stringify(result, null, 2), {\n headers: { 'Content-Type': 'application/json' }\n });\n\n } catch (error) {\n console.error('❌ Unified Reddit Monitor failed:', error);\n \n // Send error notifications\n await sendErrorNotifications(error);\n\n return new Response(JSON.stringify({\n success: false,\n error: error.message,\n stack: error.stack,\n timestamp: new Date().toISOString()\n }, null, 2), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}","/**\n * Unified Reddit Monitor - Single comprehensive monitoring script\n * \n * This script consolidates all Reddit monitoring functionality into one place:\n * - Monitors multiple subreddits using Reddit's official API (primary method)\n * - Falls back to RSS feeds if API fails\n * - Sends both Slack and email notifications\n * - Tracks keywords across all configured subreddits\n * - Prevents duplicate notifications\n * \n * Run this manually when needed - no more cron jobs!\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\n\ninterface RedditPost {\n id: string;\n title: string;\n selftext: string;\n url: string;\n author: string;\n created_utc: number;\n score: number;\n num_comments: number;\n permalink: string;\n subreddit: string;\n}\n\ninterface RedditResponse {\n data: {\n children: Array<{\n data: RedditPost;\n }>;\n after?: string;\n };\n}\n\ninterface RedditAccessToken {\n access_token: string;\n token_type: string;\n expires_in: number;\n scope: string;\n}\n\ninterface RSSItem {\n title: string;\n link: string;\n description: string;\n pubDate: string;\n author: string;\n guid: string;\n}\n\ninterface MonitorConfig {\n subreddits: string[];\n keywords: string[];\n postLimit: number;\n useSlack: boolean;\n useEmail: boolean;\n useSupabase: boolean;\n}\n\ninterface SupabasePost {\n title: string;\n author: string;\n keywords_found: string;\n comments: string;\n posted: string;\n url: string;\n}\n\n// Consolidated configuration\nconst CONFIG: MonitorConfig = {\n subreddits: [\n \"lovable\",\n \"AppBusiness\", \n \"appdev\",\n \"AppDevelopers\",\n \"ChatGPTCoding\",\n \"indiehackers\",\n \"microsaas\",\n \"replit\",\n \"ReplitBuilders\",\n \"vibecoding\",\n \"ViralApps\"\n ],\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 ],\n postLimit: 25,\n useSlack: true,\n useEmail: true,\n useSupabase: true\n};\n\n// Reddit API credentials\nconst REDDIT_CLIENT_SECRET = 'rX_YGngVjaxRA3Y0F3STl2cuEmgHkQ';\nconst REDDIT_CLIENT_ID = '151sZ8h5TaHVZGZZn0rOhA';\n\n// Slack webhook URL\nconst SLACK_WEBHOOK_URL = 'https://hooks.slack.com/services/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';\n\n// Supabase configuration\nconst SUPABASE_URL = 'https://ffilnpatwtlzjrfbmvxk.supabase.co';\nconst SUPABASE_ANON_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6ImFub24iLCJpYXQiOjE3NDk1MTA1OTAsImV4cCI6MjA2NTA4NjU5MH0.TI5pVzlHxGAcmIX7qlKniKUWxioivYjgajxD-DyhV-Q';\nconst SUPABASE_SERVICE_KEY = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZSIsInJlZiI6ImZmaWxucGF0d3RsempyZmJtdnhrIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImlhdCI6MTc0OTUxMDU5MCwiZXhwIjoyMDY1MDg2NTkwfQ.yGCSs4IWccCrVqYnalV2Ohv8SALGhGbFulJOppOBiok';\n\n/**\n * Gets an access token from Reddit API\n */\nasync function getRedditAccessToken(): Promise<string> {\n try {\n // Check if we have a cached token\n const cachedToken = await blob.getJSON(\"unified_reddit_access_token\");\n if (cachedToken && cachedToken.expires_at > Date.now()) {\n return cachedToken.access_token;\n }\n\n // Get new token using client credentials flow\n const auth = btoa(`${REDDIT_CLIENT_ID}:${REDDIT_CLIENT_SECRET}`);\n \n const response = await fetch('https://www.reddit.com/api/v1/access_token', {\n method: 'POST',\n headers: {\n 'Authorization': `Basic ${auth}`,\n 'Content-Type': 'application/x-www-form-urlencoded',\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n },\n body: 'grant_type=client_credentials'\n });\n\n if (!response.ok) {\n throw new Error(`Reddit auth error: ${response.status} ${response.statusText}`);\n }\n\n const tokenData: RedditAccessToken = await response.json();\n \n // Cache the token\n await blob.setJSON(\"unified_reddit_access_token\", {\n access_token: tokenData.access_token,\n expires_at: Date.now() + (tokenData.expires_in * 1000) - 60000 // 1 minute buffer\n });\n\n return tokenData.access_token;\n } catch (error) {\n console.error('Error getting Reddit access token:', error);\n throw error;\n }\n}\n\n/**\n * Fetches recent posts from a subreddit using Reddit API\n */\nasync function fetchSubredditPostsAPI(subreddit: string, limit: number = 25): Promise<RedditPost[]> {\n try {\n const accessToken = await getRedditAccessToken();\n const url = `https://oauth.reddit.com/r/${subreddit}/new?limit=${limit}`;\n \n const response = await fetch(url, {\n headers: {\n 'Authorization': `Bearer ${accessToken}`,\n 'User-Agent': 'UnifiedRedditMonitor/1.0 by ValTownUser'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via API:`, error);\n throw error;\n }\n}\n\n/**\n * Fallback: Fetches recent posts using Reddit's JSON endpoint\n */\nasync function fetchSubredditPostsJSON(subreddit: string, limit: number = 25): Promise<RedditPost[]> {\n try {\n const url = `https://www.reddit.com/r/${subreddit}/new.json?limit=${limit}`;\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/json',\n 'Accept-Language': 'en-US,en;q=0.9',\n 'Cache-Control': 'no-cache'\n }\n });\n\n if (!response.ok) {\n throw new Error(`Reddit JSON API error: ${response.status} ${response.statusText}`);\n }\n\n const data: RedditResponse = await response.json();\n return data.data.children.map(child => child.data);\n } catch (error) {\n console.error(`Error fetching posts from r/${subreddit} via JSON:`, error);\n throw error;\n }\n}\n\n/**\n * Parses RSS/Atom XML and extracts items\n */\nfunction parseRSS(xmlText: string): RSSItem[] {\n const items: RSSItem[] = [];\n \n // Check if it's Atom or RSS format\n const isAtom = xmlText.includes('<feed xmlns=\"http://www.w3.org/2005/Atom\"');\n \n if (isAtom) {\n // Parse Atom feed\n const entryMatches = xmlText.match(/<entry[^>]*>[\\s\\S]*?<\\/entry>/g);\n \n if (!entryMatches) return items;\n \n for (const entryXml of entryMatches) {\n const title = entryXml.match(/<title[^>]*>(.*?)<\\/title>/)?.[1] || '';\n \n const linkMatch = entryXml.match(/<link[^>]*href=\"([^\"]*)\"[^>]*\\/?>/) || \n entryXml.match(/<link[^>]*href='([^']*)'[^>]*\\/?>/);\n const link = linkMatch?.[1] || '';\n \n const content = entryXml.match(/<content[^>]*>([\\s\\S]*?)<\\/content>/)?.[1] || '';\n \n const published = entryXml.match(/<published>(.*?)<\\/published>/)?.[1] || \n entryXml.match(/<updated>(.*?)<\\/updated>/)?.[1] || '';\n \n const authorMatch = entryXml.match(/<author>[\\s\\S]*?<name>(.*?)<\\/name>[\\s\\S]*?<\\/author>/);\n const author = authorMatch?.[1] || '';\n \n const id = entryXml.match(/<id>(.*?)<\\/id>/)?.[1] || link;\n \n items.push({\n title: title.trim(),\n link: link.trim(),\n description: content.trim(),\n pubDate: published.trim(),\n author: author.trim(),\n guid: id.trim()\n });\n }\n } else {\n // Parse RSS feed\n const itemMatches = xmlText.match(/<item[^>]*>[\\s\\S]*?<\\/item>/g);\n \n if (!itemMatches) return items;\n \n for (const itemXml of itemMatches) {\n const title = itemXml.match(/<title><!\\[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(`All fetch methods failed for r/${subreddit}: API(${apiError.message}), JSON(${jsonError.message}), RSS(${rssError.message})`);\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 }) => \n formatPostForSlack(post, keywords)\n );\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${matchingPosts.length > 1 ? 's' : ''} 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, ' ').replace(/\\*\\*(.*?)\\*\\*/g, '$1')\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 - HTTP endpoint for manual execution\n */\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get('action') || 'run';\n\n if (action === 'help') {\n return new Response(`\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 `, {\n headers: { 'Content-Type': 'text/plain' }\n });\n }\n\n if (action === 'status') {\n const lastChecked = await getLastChecked();\n return new Response(JSON.stringify({\n config: CONFIG,\n lastChecked: lastChecked ? new Date(lastChecked * 1000).toISOString() : 'Never',\n timestamp: Date.now()\n }, null, 2), {\n headers: { 'Content-Type': 'application/json' }\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 // Default action: run the monitor\n console.log(`🚀 Starting Unified Reddit Monitor`);\n console.log(`📋 Monitoring ${CONFIG.subreddits.length} subreddits: ${CONFIG.subreddits.map(s => `r/${s}`).join(', ')}`);\n console.log(`🔍 Keywords: ${CONFIG.keywords.join(', ')}`);\n console.log(`📱 Notifications: Slack(${CONFIG.useSlack}), Email(${CONFIG.useEmail})`);\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 => \n containsKeywords(post, [keyword])\n );\n\n if (matchedKeywords.length > 0) {\n allMatchingPosts.push({ post, keywords: matchedKeywords });\n console.log(` ✅ Match found in r/${subreddit}: \"${post.title}\" (Keywords: ${matchedKeywords.join(', ')})`);\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\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 return new Response(JSON.stringify(result, null, 2), {\n headers: { 'Content-Type': 'application/json' }\n });\n\n } catch (error) {\n console.error('❌ Unified Reddit Monitor failed:', error);\n \n // Send error notifications\n await sendErrorNotifications(error);\n\n return new Response(JSON.stringify({\n success: false,\n error: error.message,\n stack: error.stack,\n timestamp: new Date().toISOString()\n }, null, 2), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}","createdAt",["D",1750781690815],"branchVersion","branchId","7affaaf6-4eb2-11f0-81ba-f69ea79377d9","id","7aff69ce-4eb2-11f0-81ba-f69ea79377d9","reddit-checker",["D",1750518892316],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","36d13ee0-4e48-11f0-babe-cd8177b6b491","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"orgId","0ca4d393-3df3-4cf6-ac8d-69c7934a98f0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",111,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sunnyatlightswitch","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ5bmJOYktLcDcxN1JjVElZSWtvWHFZdmxVSiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":161,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":162,"_78":163,"_80":164,"_82":25},"tree",[152,153],"files",[152,153],"counts",{"_141":142,"_143":60,"_144":60,"_145":146,"_147":148},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":25,"_38":137,"_13":138,"_33":20,"_35":139,"_24":25,"_131":-5,"_27":140},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"5b1d561e-5116-11f0-a145-f69ea79377d9","parentId","latest",["D",1750781690815],7,"label",[28],"6fe0b13c-5115-11f0-84b3-f69ea79377d9","README.md","8b238122-4eb3-11f0-b68d-f69ea79377d9",92,["D",1750781296153],37,"# 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- **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- **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 ✅ CONFIGURED\n\nWhen matches are found, you'll receive notifications via:\n\n### 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### 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## 🔍 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- ✅ **Dual Notifications**: Both Slack and email working\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",[134],"pulls",0,"branches","forks","envVars",{"_149":142,"_151":142},"connections",{"_149":142,"_150":142},"count","unfilledCount","emptyCount",{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":25,"_38":158,"_13":138,"_33":20,"_35":139,"_24":25,"_131":-5,"_155":159,"_27":160},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":154,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_155":156,"_27":157},["D",1750781690815],"children",[],[28],["D",1750781296153],[],[134],["D",1750518892316],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":198,"_199":200,"_201":202,"_203":25,"_204":25,"_205":25,"_206":207,"_208":-5,"_209":-7,"_210":-7,"_211":142,"_212":25,"_213":25,"_214":-5,"_215":25,"_216":25,"_217":25,"_218":-5},"ENV",{"_169":170,"_171":172,"_173":84,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

Diff · v97