All files / src/modules/quick-rent/workers reminders.processor.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
11x
 
11x
 
 
 
 
 
11x
 
 
 
 
 
 
 
 
 
 
import { Processor, WorkerHost } from '@nestjs/bullmq';
import { Job } from 'bullmq';
import { Injectable, Logger } from '@nestjs/common';
 
interface RemindPayload { requestId: number }
 
@Processor('quick-rent:reminders')
@Injectable()
export class QuickRentRemindersProcessor extends WorkerHost {
  private readonly logger = new Logger(QuickRentRemindersProcessor.name);
  async process(job: Job<RemindPayload>): Promise<void> {
    const { requestId } = job.data;
    // TODO: send reminders to bidders/owner via NotificationService
    this.logger.debug(`Reminder for quick-rent request ${requestId}`);
  }
}