server/lib/job-queue/handlers/email.ts

   1 import * as Bull from 'bull'
   2 import { logger } from '../../../helpers/logger'
   3 import { Emailer, SendEmailOptions } from '../../emailer'
   4
   5 export type EmailPayload = SendEmailOptions
   6
   7 async function processEmail (job: Bull.Job) {
   8   const payload = job.data as EmailPayload
   9   logger.info('Processing email in job %d.', job.id)
  10
  11   return Emailer.Instance.sendMail(payload)
  12 }
  13
  14 // ---------------------------------------------------------------------------
  15
  16 export {
  17   processEmail
  18 }