feat: reminder bot cron job

Author: benbaessler

api/cron.ts

@@ -0,0 +1,23 @@
+import { sendDirectMessage, getPendingReminders, markReminderAsProcessed } from "../lib/db.js";
+
+export default async function handler(req: Request) {
+	if (req.headers.get("Authorization") !== `Bearer ${process.env.CRON_SECRET}`) {
+		return new Response("Unauthorized", { status: 401 });
+	}
+
+	console.log("Running reminder cron job...");
+	try {
+		const pendingReminders = await getPendingReminders();
+
+		for (const reminder of pendingReminders) {
+			await sendDirectMessage(reminder.castId, reminder.userFid, reminder.authorUsername);
+			await markReminderAsProcessed(reminder.id);
+			console.log(`Processed reminder ${reminder.id} for cast ${reminder.castId}`);
+		}
+
+		return new Response("Success", { status: 200 });
+	} catch (error) {
+		console.error('Error processing reminders:', error);
+		return new Response("Error processing reminders", { status: 500 });
+	}
+}

api/index.tsx

@@ -3,7 +3,7 @@ import { devtools } from 'frog/dev'
 import { handle } from 'frog/next'
 import { serveStatic } from 'frog/serve-static'
 import { isValidDuration, parseDurationToTimestamp } from '../lib/utils.js'
-import { addReminder, startReminderService } from '../lib/db.js';
+import { addReminder } from '../lib/db.js';
 import { neynar as neynarHub } from 'frog/hubs'
 import { neynar } from 'frog/middlewares'
 import { shareComposeUrl } from '../lib/constants.js';
@@ -192,7 +192,7 @@ const isEdgeFunction = typeof EdgeFunction !== 'undefined'
 const isProduction = isEdgeFunction || import.meta.env?.MODE !== 'development'
 devtools(app, isProduction ? { assetsPath: '/.frog' } : { serveStatic })
 
-startReminderService();
+// startReminderService();
 
 export const GET = handle(app)
 export const POST = handle(app)

lib/db.ts

@@ -35,7 +35,7 @@ export const markReminderAsProcessed = async (id: number) => {
 	})
 }
 
-async function sendDirectMessage(castId: string, userFid: string, authorUsername: string) {
+export const sendDirectMessage = async (castId: string, userFid: string, authorUsername: string) => {
 	try {
 		const response = await fetch('https://api.warpcast.com/v2/ext-send-direct-cast', {
 			method: 'PUT',
@@ -58,22 +58,22 @@ async function sendDirectMessage(castId: string, userFid: string, authorUsername
 	}
 }
 
-export async function startReminderService() {
-	console.log('Starting reminder service...');
+// export async function startReminderService() {
+// 	console.log('Starting reminder service...');
 
-	// Check for due reminders every minute
-	setInterval(async () => {
-		console.log("Checking for pending reminders...")
-		try {
-			const pendingReminders = await getPendingReminders();
+// 	// Check for due reminders every minute
+// 	setInterval(async () => {
+// 		console.log("Checking for pending reminders...")
+// 		try {
+// 			const pendingReminders = await getPendingReminders();
 
-			for (const reminder of pendingReminders) {
-				await sendDirectMessage(reminder.castId, reminder.userFid, reminder.authorUsername);
-				await markReminderAsProcessed(reminder.id);
-				console.log(`Processed reminder ${reminder.id} for cast ${reminder.castId}`);
-			}
-		} catch (error) {
-			console.error('Error processing reminders:', error);
-		}
-	}, 60000); // 60000ms = 1 minute
-}
+// 			for (const reminder of pendingReminders) {
+// 				await sendDirectMessage(reminder.castId, reminder.userFid, reminder.authorUsername);
+// 				await markReminderAsProcessed(reminder.id);
+// 				console.log(`Processed reminder ${reminder.id} for cast ${reminder.castId}`);
+// 			}
+// 		} catch (error) {
+// 			console.error('Error processing reminders:', error);
+// 		}
+// 	}, 60000); // 60000ms = 1 minute
+// }

vercel.json

@@ -0,0 +1,6 @@
+{
+  "crons": [{
+    "path": "/api/cron",
+    "schedule": "* * * * *"
+  }]
+}