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