feat: pass queue names as options param

relates: #81
graphql-compose · Aug 24, 2023 · de890b9 · de890b9
1 parent 432ad5a
commit de890b9
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 5 deletions.
diff --git a/src/definitions.ts b/src/definitions.ts
@@ -6,6 +6,7 @@ export type Options = {
   jobDataTC?: string | ObjectTypeComposer<any, any>;
   queue?: {
     name?: string;
+    names?: string[];
     prefix?: string;
   };
   redis?: RedisOptions | Redis;

diff --git a/src/helpers/wrapQueueArgs.ts b/src/helpers/wrapQueueArgs.ts
@@ -10,14 +10,18 @@ export function wrapQueueArgs(
   if (opts?.queue?.name && fieldConfig.args?.queueName) {
     delete fieldConfig.args.queueName;
   }
+  if (opts?.queue?.names && fieldConfig.args?.queueNames) {
+    delete fieldConfig.args.queueNames;
+  }
   if (opts?.queue?.prefix && fieldConfig.args?.prefix) {
     delete fieldConfig.args.prefix;
   }
 
   // pass config props to sub resolve issue
-  if (opts?.queue?.name || opts?.queue?.prefix) {
+  if (opts?.queue?.name || opts?.queue?.names || opts?.queue?.prefix) {
     const predifinedArgs = {} as Record<string, any>;
     if (opts?.queue?.name) predifinedArgs.queueName = opts.queue?.name;
+    if (opts?.queue?.names) predifinedArgs.queueNames = opts.queue?.names;
     if (opts?.queue?.prefix) predifinedArgs.prefix = opts.queue?.prefix;
 
     const subResolve = fieldConfig.resolve || (() => ({}));

diff --git a/src/query/queues.ts b/src/query/queues.ts
@@ -14,14 +14,14 @@ export function createQueuesFC(
         type: 'String',
         defaultValue: 'bull',
       },
-      names: {
+      queueNames: {
         type: '[String!]',
       },
     },
-    resolve: async (_, { prefix, names }) => {
+    resolve: async (_, { prefix, queueNames }) => {
       //Если передали имена, значит они согласованы с префиксом (bull.[имя проекта]).
-      const titles = names
-        ? names.map((name: string) => ({ prefix, queueName: name }))
+      const titles = queueNames
+        ? queueNames.map((name: string) => ({ prefix, queueName: name }))
         : await scanQueueTitles(prefix, opts);
       return getQueues(titles, opts);
     },