fix: allow prefixes with multiple semicolons & add test

Author: nodkz

src/helpers/__tests__/normalizePrefixGlob-test.ts

@@ -0,0 +1,20 @@
+import { normalizePrefixGlob } from '../normalizePrefixGlob';
+
+describe('normalizePrefixGlob', () => {
+  it('check simple mask', () => {
+    expect(normalizePrefixGlob('bull*')).toBe('bull*:*:meta');
+    expect(normalizePrefixGlob('bull')).toBe('bull:*:meta');
+  });
+
+  it('check mask with queue name prefix', () => {
+    expect(normalizePrefixGlob('bull:metrics*')).toBe('bull:metrics*:meta');
+  });
+
+  it('check mask with queue name', () => {
+    expect(normalizePrefixGlob('bull:metrics')).toBe('bull:metrics:meta');
+  });
+
+  it('check mask with prefix which contains semicolons', () => {
+    expect(normalizePrefixGlob('my:service:bull:metrics')).toBe('my:service:bull:metrics:meta');
+  });
+});

src/helpers/normalizePrefixGlob.ts

@@ -1,9 +1,9 @@
 export function normalizePrefixGlob(prefixGlob: string): string {
   let prefixGlobNorm = prefixGlob;
-  const nameCase = prefixGlobNorm.split(':').length - 1;
-  if (nameCase >= 2) {
-    prefixGlobNorm = prefixGlobNorm.split(':').slice(0, 2).join(':') + ':';
-  } else if (nameCase === 1) {
+  const nameCase = prefixGlobNorm.split(':');
+  if (nameCase.length >= 3) {
+    prefixGlobNorm = nameCase.filter((s) => s !== '').join(':') + ':';
+  } else if (nameCase.length === 2) {
     prefixGlobNorm += prefixGlobNorm.endsWith(':') ? '*:' : ':';
   } else {
     prefixGlobNorm += ':*:';