import { User } from "@prisma/client";

import { getQueue } from "@app/lib/queue/QueueRegistry";

import { DailyReminderJobName } from "@app/lib/queue/types";

// XXX: Might be moved to the utilities?

function timeToCron(time: string): string {

  const [hour, minute] = time.split(":").map(Number);

  return `${minute} ${hour} * * *`;

}

export async function syncDailyReminderJob(user: User): Promise<void> {

  console.log(`[daily-sync] syncing user ${user.id}`);

  const queue = getQueue("daily-reminders");

  const existing = await queue.getRepeatableJobs();

  for (const job of existing) {

    if (job.id?.includes(`daily-reminder-user-${user.id}`)) {

      await queue.removeRepeatableByKey(job.key);

    }

  }

  if (!user.notificationsEnabled || !user.dailyReminderTime) {

    console.log(`[daily-sync] user ${user.id} skipped (enabled=${user.notificationsEnabled}, time=${user.dailyReminderTime})`);

    return;

  }

  const cron = timeToCron(user.dailyReminderTime);

  await queue.add(

    DailyReminderJobName.Send,

    { userId: user.id },

    {

      repeat: { pattern: cron, tz: "America/Sao_Paulo" },

      jobId: `daily-reminder-user-${user.id}`,

    }

  );

  console.log(`[daily-sync] scheduled daily reminder for user ${user.id} at ${user.dailyReminderTime} => cron ${cron}`);

}