X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fjob-queue%2Fhandlers%2Femail.ts;h=567bcc076b62eed662b7ac7f45855315d847aa05;hb=849f0fd3b2d00056a2c6252230814d6c2e3e3919;hp=3157731e2ea5e5afe4474f301b45c5e597c96059;hpb=8dc8a34ee8428e7657414115d1c137592efa174d;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/job-queue/handlers/email.ts b/server/lib/job-queue/handlers/email.ts index 3157731e2..567bcc076 100644 --- a/server/lib/job-queue/handlers/email.ts +++ b/server/lib/job-queue/handlers/email.ts @@ -1,11 +1,11 @@ -import * as Bull from 'bull' +import { Job } from 'bullmq' +import { EmailPayload } from '@shared/models' import { logger } from '../../../helpers/logger' import { Emailer } from '../../emailer' -import { EmailPayload } from '@shared/models' -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) }