From e130717951994633beed0cb738ae464eec1eb8d8 Mon Sep 17 00:00:00 2001
From: Nevo David <nevo@notu.co>
Date: Fri, 9 Aug 2024 22:01:39 +0700
Subject: [PATCH] feat: remove job on complete and failed

---
 .../src/bull-mq-transport/client/bull-mq.client.ts             | 2 ++
 .../src/bull-mq-transport/server/bull-mq.server.ts             | 3 +--
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/libraries/nestjs-libraries/src/bull-mq-transport/client/bull-mq.client.ts b/libraries/nestjs-libraries/src/bull-mq-transport/client/bull-mq.client.ts
index 2ea68379..356db032 100644
--- a/libraries/nestjs-libraries/src/bull-mq-transport/client/bull-mq.client.ts
+++ b/libraries/nestjs-libraries/src/bull-mq-transport/client/bull-mq.client.ts
@@ -58,6 +58,8 @@ export class BullMqClient extends ClientProxy {
     queue
       .add(packet.pattern, packet.data, {
         jobId: packet.data.id ?? v4(),
+        removeOnComplete: true,
+        removeOnFail: true,
         ...packet.data.options,
       })
       .then(async (job) => {
diff --git a/libraries/nestjs-libraries/src/bull-mq-transport/server/bull-mq.server.ts b/libraries/nestjs-libraries/src/bull-mq-transport/server/bull-mq.server.ts
index 39c6803e..3aef1bc5 100644
--- a/libraries/nestjs-libraries/src/bull-mq-transport/server/bull-mq.server.ts
+++ b/libraries/nestjs-libraries/src/bull-mq-transport/server/bull-mq.server.ts
@@ -46,10 +46,9 @@ export class BullMqServer extends Server implements CustomTransportStrategy {
               });
             });
           },
-          // @ts-ignore
           {
             ...this.options,
-            ...{ removeOnComplete: true, removeOnFail: true },
+            ...{ removeOnComplete: { count: 0 }, removeOnFail: { count: 0 } },
             ...handler?.extras,
           }
         );