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

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

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

function timeToCron(time: string): string {

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

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

}

export async function syncMedicineReminderJobs(

  regimen: MedicineRegimen

): Promise<void> {

  console.log(`[medicine-sync] syncing regimen ${regimen.id} (active=${regimen.active}, times=[${regimen.scheduledAt}])`);

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

  const existing = await queue.getRepeatableJobs();

  let removedCount = 0;

  for (const job of existing) {

    if (job.id?.startsWith(`regimen-${regimen.id}-`)) {

      await queue.removeRepeatableByKey(job.key);

      removedCount++;

    }

  }

  console.log(`[medicine-sync] removed ${removedCount} existing jobs for regimen ${regimen.id}`);

  if (!regimen.active) {

    console.log(`[medicine-sync] regimen ${regimen.id} inactive, no jobs scheduled`);

    return;

  }

  if (regimen.scheduledAt.length === 0) {

    console.log(`[medicine-sync] regimen ${regimen.id} has no scheduledAt times, skipping`);

    return;

  }

  for (const time of regimen.scheduledAt) {

    const cron = timeToCron(time);

    await queue.add(

      MedicineReminderJobName.Send,

      {

        userId: regimen.userId,

        regimenId: regimen.id,

        medicineName: regimen.name,

        dosage: regimen.dosage,

        scheduledTime: time,

      },

      {

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

        jobId: `regimen-${regimen.id}-${time}`,

      }

    );

    console.log(`[medicine-sync] scheduled job for regimen ${regimen.id} at ${time} => cron ${cron}`);

  }

}