refactor: enhance startAllNodesWithoutDeduplication method to accept delay parameter

Author: kastov

src/modules/users/users.service.ts

@@ -986,9 +986,12 @@ export class UsersService {
             await this.resetUserTrafficQueueService.resetWeeklyUserTraffic();
             await this.resetUserTrafficQueueService.resetNoResetUserTraffic();
 
-            await this.startAllNodesQueue.startAllNodesWithoutDeduplication({
-                emitter: 'bulkAllResetUserTraffic',
-            });
+            await this.startAllNodesQueue.startAllNodesWithoutDeduplication(
+                {
+                    emitter: 'bulkAllResetUserTraffic',
+                },
+                20_000,
+            );
 
             return {
                 isOk: true,

src/queue/start-all-nodes/start-all-nodes.service.ts

@@ -40,7 +40,9 @@ export class StartAllNodesQueueService
         });
     }
 
-    public async startAllNodesWithoutDeduplication(payload: { emitter: string }) {
-        return this.addJob(StartAllNodesJobNames.startAllNodes, payload, {});
+    public async startAllNodesWithoutDeduplication(payload: { emitter: string }, delay?: number) {
+        return this.addJob(StartAllNodesJobNames.startAllNodes, payload, {
+            delay,
+        });
     }
 }