import { Job } from "bullmq";

import { prisma } from "@app/lib/prisma";

import { sendPushNotification } from "@app/lib/sendPushNotification";

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

import { logger } from "@app/lib/logger";

export async function medicineReminderProcessor(job: Job): Promise<void> {

  const { userId, regimenId, medicineName, dosage } =

    job.data as MedicineReminderPayload;

  logger.info(

    { jobId: job.id, userId, regimenId, medicine: medicineName },

    "[medicine-reminder] job started",

  );

  const user = await prisma.user.findUnique({

    where: { id: userId },

    select: { pushToken: true },

  });

  if (!user) {

    logger.warn({ userId }, "[medicine-reminder] user not found, skipping");

    return;

  }

  if (!user.pushToken) {

    logger.warn({ userId }, "[medicine-reminder] no pushToken, skipping");

    return;

  }

  await sendPushNotification({

    token: user.pushToken,

    title: `Hora de tomar ${medicineName}`,

    body: dosage,

    data: { screen: "medicine-regimens", regimenId },

  });

  logger.info({ userId }, "[medicine-reminder] push sent");

}