X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fjob-queue%2Fhandlers%2Femail.ts;h=567bcc076b62eed662b7ac7f45855315d847aa05;hb=26818a73ba0d7fd53ca69eba0c8e525f3670b5a8;hp=62701222cb2b872a578738e614684565a5c24801;hpb=97567dd81f508dd6295ac4d73d849aa2ce0a6549;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/job-queue/handlers/email.ts b/server/lib/job-queue/handlers/email.ts index 62701222c..567bcc076 100644 --- a/server/lib/job-queue/handlers/email.ts +++ b/server/lib/job-queue/handlers/email.ts @@ -1,12 +1,11 @@ -import * as Bull from 'bull' +import { Job } from 'bullmq' +import { EmailPayload } from '@shared/models' import { logger } from '../../../helpers/logger' -import { Emailer, SendEmailOptions } from '../../emailer' +import { Emailer } from '../../emailer' -export type EmailPayload = SendEmailOptions - -async function processEmail (job: Bull.Job) { +async function processEmail (job: Job) { const payload = job.data as EmailPayload - logger.info('Processing email in job %d.', job.id) + logger.info('Processing email in job %s.', job.id) return Emailer.Instance.sendMail(payload) }