import { Job } from 'bullmq';
import {
  MailJobName, MailJobData,
  WelcomeEmailPayload,
  PasswordResetPayload,
  ActivateAccountEmailPayload
} from '@app/lib/queue/types';

import {
  sendWelcomeEmail,
  sendResetPasswordEmail,
  sendActivateAccountEmail
} from '@app/services/mail'

export async function mailProcessor(job: Job<MailJobData['data']>): Promise<void> {
  // job.name is the discriminant
  switch (job.name as MailJobName) {
    case MailJobName.WelcomeEmail: {
      const data = job.data as WelcomeEmailPayload;
      console.log("Dispatching an welcome email", data);

      sendWelcomeEmail(Number(data.userId), data.code);

      break;
    }

    case MailJobName.ActivateAccountEmail: {
      const data = job.data as ActivateAccountEmailPayload;
      console.log("Dispatching an activate account email", data);

      sendActivateAccountEmail(Number(data.userId), data.code);

      break;
    }

    case MailJobName.PasswordReset: {
      const data = job.data as PasswordResetPayload;
      console.log("Dispatching an welcome email", data);

      await sendResetPasswordEmail(data.userId, data.token);

      break;
    }

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