FM / waitlist

/opt/mawid/apps/api/src/waitlist

Name	Size	Mode	Actions
waitlist-queue.ts	363	0644	edit dl rm
waitlist-reply.service.ts	805	0644	edit dl rm
waitlist.e2e.spec.ts	14081	0644	edit dl rm
waitlist.module.ts	1056	0644	edit dl rm
waitlist.service.ts	13259	0644	edit dl rm
waitlist.worker.ts	1197	0644	edit dl rm

Edit: /opt/mawid/apps/api/src/waitlist/waitlist.worker.ts (1197B)

@Injectable()
export class WaitlistWorker implements OnModuleInit, OnModuleDestroy {
  private readonly logger = new Logger(WaitlistWorker.name);
  private worker?: Worker<WaitlistQueueJob>;

constructor(
    private readonly config: ConfigService,
    private readonly waitlist: WaitlistService,
  ) {}

onModuleInit() {
    const connection = new IORedis(this.config.getOrThrow<string>('REDIS_URL'), {
      maxRetriesPerRequest: null,
    });
    this.worker = new Worker<WaitlistQueueJob>(
      WAITLIST_QUEUE_NAME,
      (job: Job<WaitlistQueueJob>) => this.waitlist.expireHold(job.data.holdId),
      { connection, concurrency: 5 },
    );
    this.worker.on('failed', (job, err) => {
      this.logger.warn(`hold expiry ${job?.data.holdId} failed: ${err.message}`);
    });
  }

async onModuleDestroy() {
    await this.worker?.close();
  }
}

import { Injectable, Logger, OnModuleDestroy, OnModuleInit } from '@nestjs/common'; import { ConfigService } from '@nestjs/config'; import { Worker, type Job } from 'bullmq'; import IORedis from 'ioredis'; import { WAITLIST_QUEUE_NAME, type WaitlistQueueJob } from './waitlist-queue'; import { WaitlistService } from './waitlist.service'; @Injectable() export class WaitlistWorker implements OnModuleInit, OnModuleDestroy { private readonly logger = new Logger(WaitlistWorker.name); private worker?: Worker; constructor( private readonly config: ConfigService, private readonly waitlist: WaitlistService, ) {} onModuleInit() { const connection = new IORedis(this.config.getOrThrow('REDIS_URL'), { maxRetriesPerRequest: null, }); this.worker = new Worker( WAITLIST_QUEUE_NAME, (job: Job) => this.waitlist.expireHold(job.data.holdId), { connection, concurrency: 5 }, ); this.worker.on('failed', (job, err) => { this.logger.warn(`hold expiry ${job?.data.holdId} failed: ${err.message}`); }); } async onModuleDestroy() { await this.worker?.close(); } }