refactor(worker): use native bun cron

2026-08-02 19:12:58 +07:00
parent a43e99aa10
commit 353cc0528c
3 changed files with 16 additions and 10 deletions
@@ -1,11 +1,19 @@
 import { processDueVideoUploads } from "@/lib/video/video-platforms";

-console.log(`[${new Date().toISOString()}] Checking scheduled video uploads.`);
+async function processScheduledUploads() {
+	console.log(`[${new Date().toISOString()}] Checking scheduled video uploads.`);

-try {
-	await processDueVideoUploads();
-	console.log(`[${new Date().toISOString()}] Scheduled video upload check finished.`);
-} catch (error) {
-	console.error("Scheduled video upload worker failed:", error);
-	process.exitCode = 1;
+	try {
+		await processDueVideoUploads();
+		console.log(
+			`[${new Date().toISOString()}] Scheduled video upload check finished.`,
+		);
+	} catch (error) {
+		console.error("Scheduled video upload worker failed:", error);
+	}
 }
+
+await processScheduledUploads();
+
+Bun.cron("* * * * *", processScheduledUploads);
+console.log("Video upload worker scheduled every minute with Bun.cron.");