From 5d268e8a5d3be1166e7bda1afb1ee23228d4b559 Mon Sep 17 00:00:00 2001
From: jos3duardo <jos3duardolopes@gmail.com>
Date: Tue, 12 Aug 2025 09:09:43 -0400
Subject: [PATCH] Refactor payment processing services to use CreatePaymentDto
 and simplify job handling

---
 src/modules/queue/queue.service.ts | 14 +++++---------
 1 file changed, 5 insertions(+), 9 deletions(-)

diff --git a/src/modules/queue/queue.service.ts b/src/modules/queue/queue.service.ts
index b391be5..a10e358 100644
--- a/src/modules/queue/queue.service.ts
+++ b/src/modules/queue/queue.service.ts
@@ -4,24 +4,20 @@ import { Queue } from 'bullmq';
 import { CreatePaymentDto } from '../payments/dto/create-payment.dto';
 import { PAYMENT_QUEUE } from './constants/queue.constants';
 
-export interface PaymentJobData {
-  paymentData: CreatePaymentDto;
-  createdAt: Date;
-}
-
 @Injectable()
 export class QueueService {
   constructor(@InjectQueue(PAYMENT_QUEUE) private paymentQueue: Queue) {}
 
-  async addPaymentJob(data: PaymentJobData): Promise<void> {
+  async addPaymentJob(data: CreatePaymentDto): Promise<void> {
     await this.paymentQueue.add(PAYMENT_QUEUE, data, {
-      attempts: 2,
+      jobId: data.correlationId,
+      attempts: 5,
       backoff: {
         type: 'exponential',
         delay: 2000,
       },
-      removeOnComplete: 3,
-      removeOnFail: 2,
+      removeOnComplete: 100,
+      removeOnFail: 50,
     });
   }
 }