feat: add remove bulk mutation

Author: Boris Dorofeev

src/composeBull.ts

@@ -16,6 +16,7 @@ import {
   createJobDiscardFC,
   createjobPromoteFC,
   createJobRremoveFC,
+  createJobRremoveBulkFC,
   createJobRetryFC,
   createJobUpdateFC,
   createJobLogAddFC,
@@ -52,6 +53,7 @@ export function composeBull(opts: Options & { schemaComposer?: SchemaComposer<an
       jobDiscard: wrapMutation(createJobDiscardFC),
       jobPromote: wrapMutation(createjobPromoteFC),
       jobRemove: wrapMutation(createJobRremoveFC),
+      jobRemoveBulk: wrapMutation(createJobRremoveBulkFC),
       jobRetry: wrapMutation(createJobRetryFC),
       jobUpdate: wrapMutation(createJobUpdateFC),
       jobLogAdd: wrapMutation(createJobLogAddFC),

src/mutation/index.ts

@@ -11,6 +11,7 @@ export { createJobAddEveryFC } from './jobAddEvery';
 export { createJobDiscardFC } from './jobDiscard';
 export { createjobPromoteFC } from './jobPromote';
 export { createJobRremoveFC } from './jobRemove';
+export { createJobRremoveBulkFC } from './jobRemoveBulk';
 export { createJobRetryFC } from './jobRetry';
 export { createJobUpdateFC } from './jobUpdate';
 export { createJobLogAddFC } from './jobLogAdd';

src/mutation/jobRemoveBulk.ts

@@ -0,0 +1,42 @@
+import { findQueue } from '../helpers';
+import { SchemaComposer, ObjectTypeComposerFieldConfigAsObjectDefinition } from 'graphql-compose';
+import { Options } from '../definitions';
+
+export function createJobRremoveBulkFC(
+  sc: SchemaComposer<any>,
+  opts: Options
+): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
+  const { typePrefix } = opts;
+
+  return {
+    type: sc.createObjectTC({
+      name: `${typePrefix}JobRemoveBulkPayload`,
+      fields: {
+        jobIds: '[String!]',
+      },
+    }),
+    args: {
+      prefix: {
+        type: 'String!',
+        defaultValue: 'bull',
+      },
+      queueName: 'String!',
+      jobIds: '[String!]!',
+    },
+    resolve: async (_, { prefix, queueName, jobIds }) => {
+      const queue = await findQueue(prefix, queueName, opts);
+      const deletedIds: string[] = [];
+      for (let i = 0; i < jobIds.length; i++) {
+        const job = await queue.getJob(jobIds[i]);
+        if (job) {
+          await job.remove();
+          deletedIds.push(jobIds[i]);
+        }
+      }
+
+      return {
+        jobIds: deletedIds,
+      };
+    },
+  };
+}