import { Worker, type Job } from 'bullmq'; import type { ConnectionOptions } from 'bullmq'; import { logger } from '@/lib/logger'; import { QUEUE_CONFIGS } from '@/lib/queue'; export const emailWorker = new Worker( 'email', async (job: Job) => { logger.info({ jobId: job.id, jobName: job.name }, 'Processing email job'); switch (job.name) { case 'inbox-sync': { const { accountId } = job.data as { accountId: string }; const { syncInbox } = await import('@/lib/services/email-threads.service'); await syncInbox(accountId); break; } default: logger.warn({ jobName: job.name }, 'Unknown email job'); } }, { connection: { url: process.env.REDIS_URL! } as ConnectionOptions, concurrency: QUEUE_CONFIGS.email.concurrency, }, ); emailWorker.on('failed', (job, err) => { logger.error({ jobId: job?.id, jobName: job?.name, err }, 'Email job failed'); });