import { Job } from "bullmq";
import { NotificationKind } from "@prisma/client";

import { createNotification } from "@app/services/notification.service";
import { MedicineReminderPayload } from "@app/lib/queue/types";
import { appTimeToday } from "@app/lib/appTime";
import { logger } from "@app/lib/logger";

export async function medicineReminderProcessor(job: Job): Promise<void> {
  const { userId, regimenId, medicineName, dosage, scheduledTime } =
    job.data as MedicineReminderPayload;

  logger.info(
    { jobId: job.id, userId, regimenId, medicine: medicineName },
    "[medicine-reminder] job started",
  );

  await createNotification({
    userId,
    kind: NotificationKind.MEDICINE_REMINDER,
    title: `Hora de tomar ${medicineName}`,
    body: dosage,
    scheduledFor: appTimeToday(scheduledTime),
    regimenId,
  });

  logger.info({ userId, regimenId }, "[medicine-reminder] notification stored");
}