import { User } from "@prisma/client";
import { getQueue } from "@app/lib/queue/QueueRegistry";
import { DailyReminderJobName } from "@app/lib/queue/types";
import { logger } from "@app/lib/logger";

// 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> {
  logger.info({ userId: user.id }, "[daily-sync] syncing user");

  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) {
    logger.info(
      {
        userId: user.id,
        enabled: user.notificationsEnabled,
        time: user.dailyReminderTime,
      },
      "[daily-sync] user skipped",
    );

    return;
  }

  const cron = timeToCron(user.dailyReminderTime);

  await queue.add(
    DailyReminderJobName.Send,
    { userId: user.id, scheduledTime: user.dailyReminderTime },
    {
      repeat: { pattern: cron, tz: "America/Sao_Paulo" },
      jobId: `daily-reminder-user-${user.id}`,
    }
  );

  logger.info(
    { userId: user.id, time: user.dailyReminderTime, cron },
    "[daily-sync] scheduled daily reminder",
  );
}