fix: change prefix discovery

Author: Boris Dorofeev

example/src/demo_queues/fetchMetrics.ts

@@ -3,7 +3,7 @@ import { createBullConnection } from '../connectRedis';
 
 export const queueSettings = {
   name: 'fetch_metrics',
-  prefix: 'bull.demo',
+  prefix: 'bull:demo',
 };
 
 const prefix = queueSettings.prefix;

example/src/schema.ts

@@ -8,7 +8,7 @@ const { queryFields, mutationFields } = composeBull({
   jobDataTC: `type MyJobData { fieldA: String! fieldB: String}`,
   queue: {
     name: 'fetch_metrics',
-    prefix: 'bull.demo',
+    prefix: 'bull:demo:*',
   },
   redis: createBullConnection('queue'),
 });

src/helpers/queueTitles.ts

@@ -11,8 +11,8 @@ export async function fetchQueueTitles(prefix: string, opts: Options): Promise<A
   return keys.map((key) => {
     const parts = key.split(':');
     return {
-      prefix: parts[0],
-      queueName: parts[1],
+      prefix: parts.slice(0, -2).join(':'),
+      queueName: parts[parts.length - 2],
     };
   });
 }

src/query/queueKeys.ts

@@ -1,5 +1,5 @@
 import { SchemaComposer, ObjectTypeComposerFieldConfigAsObjectDefinition } from 'graphql-compose';
-import { normalizePrefixGlob, fetchQueueTitles } from '../helpers';
+import { fetchQueueTitles } from '../helpers';
 import { Options } from '../definitions';
 
 export function createQueueKeysFC(
@@ -24,7 +24,7 @@ export function createQueueKeysFC(
       },
     },
     resolve: async (_, { prefixGlob }) => {
-      return fetchQueueTitles(normalizePrefixGlob(prefixGlob), opts);
+      return fetchQueueTitles(prefixGlob, opts);
     },
   };
 }