import { processDueVideoUploads } from "@/lib/video/video-platforms";

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);
	}
}

await processScheduledUploads();

Bun.cron("* * * * *", processScheduledUploads);
console.log("Video upload worker scheduled every minute with Bun.cron.");