Módulo BullMQ

O módulo BullMQ de @grupodiariodaregiao/bunstone fornece uma forma de processar tarefas em segundo plano usando BullMQ.

Instalação

Primeiro, garanta que você tenha as dependências necessárias:

bun add bullmq ioredis

Configuração

Para usar BullMQ, você precisa registrar o BullMqModule no seu AppModule.

import { Module } from "@grupodiariodaregiao/bunstone";
import { BullMqModule } from "@grupodiariodaregiao/bunstone/lib/bullmq/bullmq-module";

@Module({
  imports: [
    BullMqModule.register({
      host: 'localhost',
      port: 6379,
    }),
  ],
})
export class AppModule {}

Criando um processor

Um processor é uma classe decorada com @Processor(). Ela contém métodos decorados com @Process() que lidam com jobs de uma fila específica.

import { Processor, Process } from "@grupodiariodaregiao/bunstone/lib/bullmq/decorators";
import { Job } from "bullmq";

@Processor('email-queue')
export class EmailProcessor {
  @Process('send-welcome')
  async handleSendWelcome(job: Job) {
    console.log('Enviando e-mail de boas-vindas para:', job.data.email);
    // Simula trabalho
    await new Promise(resolve => setTimeout(resolve, 1000));
    return { sent: true };
  }

  @Process()
  async handleDefault(job: Job) {
    console.log('Processando tipo de job desconhecido:', job.name);
  }
}

Não se esqueça de adicionar seu processor aos providers de um módulo.

Produzindo jobs

Você pode injetar o QueueService nos seus controllers ou services para adicionar jobs a uma fila.

import { Controller, Get, Query } from "@grupodiariodaregiao/bunstone/lib/controller";
import { QueueService } from "@grupodiariodaregiao/bunstone/lib/bullmq/queue.service";

@Controller('/email')
export class EmailController {
  constructor(private readonly queueService: QueueService) {}

  @Get('/send')
  async sendEmail(@Query('email') email: string) {
    await this.queueService.add('email-queue', 'send-welcome', { email });
    return { status: 'Job adicionado à fila' };
  }
}

Opções do processor

O decorator @Processor aceita um objeto de opções:

@Processor({
  queueName: 'heavy-tasks',
  concurrency: 5,
})
export class HeavyTaskProcessor {
  // ...
}