feat: id field for queue

Author: Boris Dorofeev

example/src/demo_queues/fetchMetrics.ts

@@ -11,7 +11,6 @@ const prefix = queueSettings.prefix;
 const metricsScheduler = new QueueScheduler(queueSettings.name, {
   prefix,
   connection: createBullConnection('scheduler'), // BULL_REDIS_URI,
-  stalledInterval: 900000,
 });
 
 export const metricsQueue = new Queue(queueSettings.name, {
@@ -51,7 +50,6 @@ const metricsWorker = new Worker(
     // });
   },
   {
-    lockDuration: 900000,
     prefix,
     connection: createBullConnection('worker'), // BULL_REDIS_URI,
   }

src/definitions.ts

@@ -9,5 +9,4 @@ export type Options = {
     prefix?: string;
   };
   redis?: RedisOptions | IORedis.Redis;
-  redisEvents?: RedisOptions | IORedis.Redis;
 };

src/types/queue/Queue.id.ts

@@ -0,0 +1,11 @@
+import { Queue } from 'bullmq';
+import { ObjectTypeComposerFieldConfigDefinition } from 'graphql-compose';
+
+export function createIdFC(): ObjectTypeComposerFieldConfigDefinition<any, any> {
+  return {
+    type: 'String!',
+    resolve: async (queue: Queue) => {
+      return queue.name;
+    },
+  };
+}

src/types/queue/Queue.ts

@@ -1,4 +1,5 @@
 import { createIsPausedFC } from './Queue.isPaused';
+import { createIdFC } from './Queue.id';
 import { createJobCountFC } from './Queue.jobCounts';
 import { createRepeatablesFC } from './Queue.repeatables';
 import { createJobsFC } from './Queue.jobs';
@@ -18,6 +19,7 @@ export function getQueueTC(sc: SchemaComposer<any>, opts: Options) {
 
   return sc.getOrCreateOTC(`${typePrefix}Queue`, (etc) => {
     etc.addFields({
+      id: createIdFC(),
       name: 'String!',
       isPaused: createIsPausedFC(),
       jobCounts: createJobCountFC(sc, opts),