35 lines
1.1 KiB
TypeScript
35 lines
1.1 KiB
TypeScript
|
import { Worker, type Job } from 'bullmq';
|
||
|
|
|
||
|
|
import type { ConnectionOptions } from 'bullmq';
|
||
|
|
import { logger } from '@/lib/logger';
|
||
|
|
import { QUEUE_CONFIGS } from '@/lib/queue';
|
||
|
|
|
||
|
|
export const maintenanceWorker = new Worker(
|
||
|
|
'maintenance',
|
||
|
|
async (job: Job) => {
|
||
|
|
logger.info({ jobId: job.id, jobName: job.name }, 'Processing maintenance job');
|
||
|
|
switch (job.name) {
|
||
|
|
case 'currency-refresh': {
|
||
|
|
const { refreshRates } = await import('@/lib/services/currency');
|
||
|
|
await refreshRates();
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
case 'form-expiry-check': {
|
||
|
|
// TODO(L3): mark expired form submissions
|
||
|
|
logger.info('Form expiry check — not yet implemented');
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
default:
|
||
|
|
logger.warn({ jobName: job.name }, 'Unknown maintenance job');
|
||
|
|
}
|
||
|
|
},
|
||
|
|
{
|
||
|
|
connection: { url: process.env.REDIS_URL! } as ConnectionOptions,
|
||
|
|
concurrency: QUEUE_CONFIGS.maintenance.concurrency,
|
||
|
|
},
|
||
|
|
);
|
||
|
|
|
||
|
|
maintenanceWorker.on('failed', (job, err) => {
|
||
|
|
logger.error({ jobId: job?.id, jobName: job?.name, err }, 'Maintenance job failed');
|
||
|
|
});
|