fix: activity check

Author: intpro

src/mutation/queueDelete.ts

@@ -1,4 +1,6 @@
+import { MutationError, ErrorCodeEnum } from './../helpers/MutationError';
 import { SchemaComposer, ObjectTypeComposerFieldConfigAsObjectDefinition } from 'graphql-compose';
+import { findQueue } from '../helpers';
 import { deleteQueue } from '../helpers';
 import { Options } from '../definitions';
 
@@ -25,8 +27,34 @@ export function createQueueDeleteFC(
         type: 'Boolean',
         defaultValue: true,
       },
+      checkActivity: {
+        type: 'Boolean',
+        defaultValue: true,
+      },
     },
-    resolve: async (_, { prefix, queueName, checkExistence }) => {
+    resolve: async (_, { prefix, queueName, checkExistence, checkActivity }) => {
+      if (checkActivity) {
+        const queue = await findQueue(prefix, queueName, opts);
+        const actives = await queue.getActiveCount();
+        const workers = (await queue.getWorkers()).length;
+
+        const messages: string[] = [];
+
+        if (actives > 0) {
+          messages.push(`Queue have ${actives} active jobs.`);
+        }
+
+        if (workers > 0) {
+          messages.push(`Queue have ${workers} workers.`);
+        }
+
+        if (messages.length > 0) {
+          throw new MutationError(
+            ['Queue is active!', ...messages].join(' '),
+            ErrorCodeEnum.OTHER_ERROR
+          );
+        }
+      }
       const total = await deleteQueue(prefix, queueName, opts, checkExistence);
       return { total };
     },

src/types/queue/Queue.durationAvg.ts

@@ -16,16 +16,17 @@ export function createDurationAvgFC(
     },
     resolve: async (queue: Queue, { limit }) => {
       const jobs = await queue.getCompleted(0, limit);
-
-      const amount = jobs.reduce((acc, job) => {
-        if (job?.finishedOn && job?.processedOn) {
-          return acc + job.finishedOn - job?.processedOn;
+      let amount = 0;
+      if (jobs.length === 0) {
+        return 0;
+      } else {
+        for (const job of jobs) {
+          if (job.finishedOn && job.processedOn) {
+            amount += job.finishedOn - job?.processedOn;
+          }
         }
-
-        return acc;
-      }, 0);
-
-      return (amount / jobs.length).toFixed(0);
+        return (amount / jobs.length).toFixed(0);
+      }
     },
   };
 }