feat: add queue drain mutation

Author: Boris

example/src/schema/mutation/index.ts

@@ -1,5 +1,6 @@
 import { SchemaComposer } from 'graphql-compose';
 import { createQueueCleanFC } from './queueClean';
+import { createQueueDrainFC } from './queueDrain';
 import { createQueuePauseFC } from './queuePause';
 import { createQueueResumeFC } from './queueResume';
 
@@ -26,6 +27,7 @@ export function createMutationFields({
   //TODO: пропустить через map это
   return {
     queueClean: generateHelper(createQueueCleanFC({ schemaComposer })),
+    queueDrain: generateHelper(createQueueDrainFC({ schemaComposer })),
     queuePause: generateHelper(createQueuePauseFC()),
     queueResume: generateHelper(createQueueResumeFC()),
     queueRemoveRepeatable: generateHelper(createRemoveRepeatableFC()),

example/src/schema/mutation/jobMoveToCompleted.ts

@@ -0,0 +1,30 @@
+import { getQueue } from './_helpers';
+import { SchemaComposer } from 'graphql-compose';
+import { getJobTC } from '../types/job';
+
+export function jobMoveToCompletedFC(schemaComposer: SchemaComposer<any>) {
+  return {
+    type: {
+      name: 'JobMoveToCompletedPayload',
+      fields: {
+        id: 'String',
+        job: getJobTC(schemaComposer),
+      },
+    },
+    args: {
+      queueName: 'String!',
+      id: 'String!',
+    },
+    resolve: async (_, { queueName, id }, context) => {
+      const queue = getQueue(queueName, context);
+      const job = await queue.getJob(id);
+      if (job) {
+        await job.moveToCompleted({}, 'tokenmustbehere'); //TODO: нати где брать токен
+      }
+      return {
+        id,
+        job,
+      };
+    },
+  };
+}

example/src/schema/mutation/queueDrain.ts

@@ -0,0 +1,24 @@
+import { getQueue } from './_helpers';
+
+export function createQueueDrainFC({ schemaComposer }) {
+  return {
+    type: {
+      name: 'QueueDrainPayload',
+      fields: {
+        jobsId: '[String!]',
+      },
+    },
+    args: {
+      queueName: 'String!',
+      delayed: {
+        type: 'Boolean',
+        defaultValue: false,
+      },
+    },
+    resolve: async (_, { queueName, delayed }, context) => {
+      const queue = getQueue(queueName, context);
+      await queue.drain(delayed);
+      return {};
+    },
+  };
+}