import { Job } from "bullmq";

import {

  ExportJobData,

  ExportJobName,

  ExportPayload,

} from "@app/lib/queue/types";

import { buildExportArchive } from "@app/services/export/export.service";

import {

  sendExportFailedEmail,

  sendExportReadyEmail,

} from "@app/services/mail";

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

export async function exportProcessor(

  job: Job<ExportJobData["data"]>,

): Promise<void> {

  switch (job.name as ExportJobName) {

    case ExportJobName.Data: {

      const { userId } = job.data as ExportPayload;

      try {

        const archive = await buildExportArchive(userId);

        await sendExportReadyEmail(userId, archive);

      } catch (err) {

        // Only the last attempt notifies the user; earlier ones are retried

        const attempts = job.opts.attempts ?? 1;

        const isFinalAttempt = job.attemptsMade + 1 >= attempts;

        if (isFinalAttempt) {

          try {

            await sendExportFailedEmail(userId);

          } catch (mailErr) {

            logger.error(

              { err: mailErr, userId },

              "[exports] failed to send the failure email",

            );

          }

        }

        throw err;

      }

      break;

    }

    default:

      throw new Error(`Unknown export job: ${job.name}`);

  }

}