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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
11x
 
11x
11x
 
 
 
 
 
11x
 
 
 
 
 
 
 
 
 
 
 
import { Processor, WorkerHost } from '@nestjs/bullmq';
import { Job } from 'bullmq';
import { Injectable, Logger } from '@nestjs/common';
import { PrismaService } from '@app/modules/prisma/prisma.service';
 
interface MatchPayload { requestId: number }
 
@Processor('quick-rent:match')
@Injectable()
export class QuickRentMatchProcessor extends WorkerHost {
  private readonly logger = new Logger(QuickRentMatchProcessor.name);
  constructor(private readonly prisma: PrismaService) { super(); }
  async process(job: Job<MatchPayload>): Promise<void> {
    const { requestId } = job.data;
    // TODO: find matching agents/agencies by geo/specs and enqueue notifications
    this.logger.debug(`QuickRent match fanout for request ${requestId}`);
  }
}