`;\n \n // Story header\n const storyTitle = storyItem.story_title || storyItem.title || 'Untitled';\n const storyUrl = storyItem.story_url || storyItem.url;\n \n content += `

${storyTitle}

`;\n \n if (storyUrl) {\n content += `

URL: ${storyUrl}

`;\n }\n \n content += `

HN Discussion: View on Hacker News

`;\n \n // Show story text if it mentions our keywords\n if (storyItem.text && COMPETITORS.some(c => storyItem.text!.toLowerCase().includes(c))) {\n content += `

Story text: ${storyItem.text.slice(0, 300)}${storyItem.text.length > 300 ? '...' : ''}

`;\n }\n \n // Show relevant comments\n if (comments.length > 0) {\n content += `

Relevant comments (${comments.length}):

`;\n comments.forEach(comment => {\n const commentText = comment.text || comment.comment_text || '';\n content += `

\n
by ${comment.author}:
\n
${commentText.slice(0, 250)}${commentText.length > 250 ? '...' : ''}
\n

`;\n });\n }\n \n content += `

`;\n });\n \n return { content, totalItems };\n}\n\nasync function sendAlert(relevantItems: HNItem[]): Promise {\n const storyGroups = groupItemsByStory(relevantItems);\n const { content, totalItems } = formatEmailContent(storyGroups);\n \n const subject = `HN Alert: ${totalItems} new mentions of Patreon, Buy Me A Coffee, or Ko-fi (${storyGroups.size} discussions)`;\n \n await email({\n subject,\n html: `\n

New Hacker News Mentions

Found ${totalItems} relevant mentions across ${storyGroups.size} discussions:

\n ${content}\n

Monitored terms: Patreon, Buy Me A Coffee, Ko-fi | AI-filtered for relevance

\n `\n });\n}\n\nexport default async function(interval?: { lastRunAt?: Date }) {\n console.log(`Starting HN check at ${new Date().toISOString()}`);\n \n try {\n // TESTING: Always use 24 hours ago for now\n const sinceTimestamp = Math.floor((Date.now() - 24 * 60 * 60 * 1000) / 1000);\n console.log(\"TESTING MODE: Always using 24 hour window\");\n \n // TODO: Uncomment for production\n // const lastSuccessfulRun = await getLastSuccessfulRun();\n // const intervalLastRun = interval?.lastRunAt ? Math.floor(interval.lastRunAt.getTime() / 1000) : 0;\n // let sinceTimestamp = Math.max(lastSuccessfulRun, intervalLastRun);\n // if (sinceTimestamp === 0) {\n // sinceTimestamp = Math.floor((Date.now() - 24 * 60 * 60 * 1000) / 1000);\n // console.log(\"First run detected - using 24 hour fallback\");\n // }\n \n console.log(`Searching for items since ${new Date(sinceTimestamp * 1000).toISOString()}`);\n \n // Get recently processed IDs for deduplication\n const processedIds = await getRecentlyProcessed();\n \n // Search Algolia API\n const allItems = await getAllNewItems(sinceTimestamp);\n console.log(`Found ${allItems.length} items from Algolia`);\n \n if (allItems.length === 0) {\n console.log(\"No new items found - heartbeat log\");\n await setLastSuccessfulRun(Math.floor(Date.now() / 1000));\n return;\n }\n \n // Remove duplicates based on objectID\n const newItems = allItems.filter(item => !processedIds.has(item.objectID));\n console.log(`${newItems.length} items after deduplication`);\n \n if (newItems.length === 0) {\n console.log(\"No new unique items after deduplication\");\n await setLastSuccessfulRun(Math.floor(Date.now() / 1000));\n return;\n }\n \n // Apply heuristic filtering\n const heuristicallyFiltered = await heuristicFilter(newItems);\n console.log(`${heuristicallyFiltered.length} items after heuristic filtering`);\n \n if (heuristicallyFiltered.length === 0) {\n // Update processed IDs even if no relevant items\n newItems.forEach(item => processedIds.add(item.objectID));\n await updateRecentlyProcessed(processedIds);\n await setLastSuccessfulRun(Math.floor(Date.now() / 1000));\n console.log(\"No items passed heuristic filter\");\n return;\n }\n \n // Apply AI relevance filtering\n const relevantItems = await batchCheckRelevance(heuristicallyFiltered);\n console.log(`${relevantItems.length} items after AI relevance filtering`);\n \n // Update processed IDs\n newItems.forEach(item => processedIds.add(item.objectID));\n await updateRecentlyProcessed(processedIds);\n \n // Send alert if we have relevant items\n if (relevantItems.length > 0) {\n await sendAlert(relevantItems);\n console.log(`Sent email alert for ${relevantItems.length} relevant items`);\n } else {\n console.log(\"No items deemed relevant by AI filter\");\n }\n \n // Mark as successful only after everything completes\n await setLastSuccessfulRun(Math.floor(Date.now() / 1000));\n console.log(\"HN check completed successfully\");\n \n } catch (error) {\n console.error(`HN check failed: ${error.message}`);\n console.error(error.stack);\n \n // Send error notification\n try {\n await email({\n subject: \"HN Monitor Error\",\n text: `HN monitoring failed: ${error.message}\\n\\nStack trace:\\n${error.stack}`\n });\n } catch (emailError) {\n console.error(`Failed to send error email: ${emailError.message}`);\n }\n \n // Re-throw to prevent updating lastSuccessfulRun\n throw error;\n }\n}\n","deleted","label",[98],"permalink","https://www.val.town/x/mikker/checkHackerNewsForPatreon/code/main.cron.tsx","extension","actionData","errors"]