@bull-board/api - npm Package Compare versions

Comparing version 7.0.0 to 7.1.3

bullMQProAdapter.d.ts

+export { BullMQProAdapter } from './dist/queueAdapters/bullMQPro';
+export type {
+  GroupStatusName,
+  GroupSummary,
+  GroupSummaryWithCount,
+  GroupsCountByStatus,
+  JobProLike,
+  QueueProLike,
+} from './dist/queueAdapters/bullMQProTypes';

bullMQProAdapter.js

+module.exports = require('./dist/queueAdapters/bullMQPro');

dist/queueAdapters/bullMQPro.d.ts

+import type { Job } from 'bullmq';
+import { JobCleanStatus, JobCounts, JobStatus, QueueAdapterOptions, QueueJobOptions } from '../../typings/app';
+import { BullMQAdapter } from './bullMQ';
+import type { QueueProLike } from './bullMQProTypes';
+export declare class BullMQProAdapter extends BullMQAdapter {
+    readonly isPro = true;
+    private readonly proQueue;
+    private groupCountsCache;
+    constructor(queue: QueueProLike, options?: Partial<QueueAdapterOptions>);
+    getJobCounts(): Promise<JobCounts>;
+    getJobs(jobStatuses: JobStatus[], start?: number, end?: number): Promise<Job[]>;
+    addJob(name: string, data: any, options: QueueJobOptions): Promise<Job<any, any, string>>;
+    clean(jobStatus: JobCleanStatus, graceTimeMs: number): Promise<void>;
+    empty(): Promise<void>;
+    obliterate(): Promise<void>;
+    pause(): Promise<void>;
+    resume(): Promise<void>;
+    promoteAll(): Promise<void>;
+    private invalidateGroupCounts;
+    private getGroupCounts;
+    private getRelevantGroupStatuses;
+    private fetchJobsFromGroups;
+}
+export type { JobProLike, QueueProLike } from './bullMQProTypes';

dist/queueAdapters/bullMQPro.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.BullMQProAdapter = void 0;
+const statuses_1 = require("../constants/statuses");
+const bullMQ_1 = require("./bullMQ");
+const GROUP_COUNTS_TTL_MS = 5000;
+const BUCKET_TO_GROUP_STATUSES = {
+    [statuses_1.STATUSES.waiting]: ['waiting'],
+    [statuses_1.STATUSES.delayed]: ['limited', 'maxed'],
+    [statuses_1.STATUSES.paused]: ['paused'],
+};
+class BullMQProAdapter extends bullMQ_1.BullMQAdapter {
+    constructor(queue, options = {}) {
+        super(queue, options);
+        this.isPro = true;
+        this.groupCountsCache = null;
+        this.proQueue = queue;
+        this.setFormatter('name', (jobProps) => {
+            var _a, _b, _c;
+            const gid = (_b = (_a = jobProps === null || jobProps === void 0 ? void 0 : jobProps.opts) === null || _a === void 0 ? void 0 : _a.group) === null || _b === void 0 ? void 0 : _b.id;
+            const baseName = (_c = jobProps === null || jobProps === void 0 ? void 0 : jobProps.name) !== null && _c !== void 0 ? _c : '';
+            return gid != null ? `${baseName} (group: ${gid})` : baseName;
+        });
+    }
+    async getJobCounts() {
+        var _a, _b, _c;
+        const [base, groups] = await Promise.all([super.getJobCounts(), this.getGroupCounts()]);
+        return {
+            ...base,
+            [statuses_1.STATUSES.waiting]: ((_a = base[statuses_1.STATUSES.waiting]) !== null && _a !== void 0 ? _a : 0) + groups.waiting,
+            [statuses_1.STATUSES.delayed]: ((_b = base[statuses_1.STATUSES.delayed]) !== null && _b !== void 0 ? _b : 0) + groups.limited + groups.maxed,
+            [statuses_1.STATUSES.paused]: ((_c = base[statuses_1.STATUSES.paused]) !== null && _c !== void 0 ? _c : 0) + groups.paused,
+        };
+    }
+    async getJobs(jobStatuses, start = 0, end = -1) {
+        const requestedEnd = end;
+        const normalizedEnd = end === -1 ? Number.MAX_SAFE_INTEGER : end;
+        const pageSize = normalizedEnd - start + 1;
+        const groupStatuses = this.getRelevantGroupStatuses(jobStatuses);
+        if (groupStatuses.length === 0) {
+            return super.getJobs(jobStatuses, start, requestedEnd);
+        }
+        const counts = await super.getJobCounts();
+        const regularCount = jobStatuses.reduce((sum, status) => { var _a; return sum + ((_a = counts[status]) !== null && _a !== void 0 ? _a : 0); }, 0);
+        const regularJobs = start < regularCount
+            ? await super.getJobs(jobStatuses, start, Math.min(normalizedEnd, regularCount - 1))
+            : [];
+        const groupSkip = Math.max(0, start - regularCount);
+        const groupTake = pageSize - regularJobs.length;
+        if (groupTake <= 0) {
+            return regularJobs;
+        }
+        const groupJobs = await this.fetchJobsFromGroups(groupStatuses, groupSkip, groupTake);
+        return [...regularJobs, ...groupJobs];
+    }
+    addJob(name, data, options) {
+        this.invalidateGroupCounts();
+        return super.addJob(name, data, options);
+    }
+    async clean(jobStatus, graceTimeMs) {
+        this.invalidateGroupCounts();
+        return super.clean(jobStatus, graceTimeMs);
+    }
+    async empty() {
+        this.invalidateGroupCounts();
+        return super.empty();
+    }
+    async obliterate() {
+        this.invalidateGroupCounts();
+        return super.obliterate();
+    }
+    async pause() {
+        this.invalidateGroupCounts();
+        return super.pause();
+    }
+    async resume() {
+        this.invalidateGroupCounts();
+        return super.resume();
+    }
+    async promoteAll() {
+        this.invalidateGroupCounts();
+        return super.promoteAll();
+    }
+    invalidateGroupCounts() {
+        this.groupCountsCache = null;
+    }
+    async getGroupCounts() {
+        const now = Date.now();
+        if (this.groupCountsCache && now - this.groupCountsCache.fetchedAt < GROUP_COUNTS_TTL_MS) {
+            return this.groupCountsCache.value;
+        }
+        const value = await this.proQueue.getGroupsCountByStatus();
+        this.groupCountsCache = { fetchedAt: now, value };
+        return value;
+    }
+    getRelevantGroupStatuses(jobStatuses) {
+        const result = new Set();
+        for (const status of jobStatuses) {
+            const mapped = BUCKET_TO_GROUP_STATUSES[status];
+            if (mapped) {
+                for (const groupStatus of mapped) {
+                    result.add(groupStatus);
+                }
+            }
+        }
+        return [...result];
+    }
+    async fetchJobsFromGroups(groupStatuses, skip, take) {
+        const collected = [];
+        let remainingSkip = skip;
+        let remainingTake = take;
+        for (const groupStatus of groupStatuses) {
+            if (remainingTake <= 0)
+                break;
+            const groups = await this.proQueue.getGroupsByStatus(groupStatus);
+            for (const group of groups) {
+                if (remainingTake <= 0)
+                    break;
+                if (remainingSkip >= group.count) {
+                    remainingSkip -= group.count;
+                    continue;
+                }
+                const groupStart = remainingSkip;
+                const groupEnd = Math.min(group.count - 1, groupStart + remainingTake - 1);
+                const jobs = await this.proQueue.getGroupJobs(group.id, groupStart, groupEnd);
+                collected.push(...jobs);
+                remainingSkip = 0;
+                remainingTake -= jobs.length;
+            }
+        }
+        return collected;
+    }
+}
+exports.BullMQProAdapter = BullMQProAdapter;
+//# sourceMappingURL=bullMQPro.js.map

dist/queueAdapters/bullMQPro.js.map

+{"version":3,"file":"bullMQPro.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQPro.ts"],"names":[],"mappings":";;;AASA,oDAAiD;AACjD,qCAAyC;AAQzC,MAAM,mBAAmB,GAAG,IAAK,CAAC;AAElC,MAAM,wBAAwB,GAAkD;IAC9E,CAAC,mBAAQ,CAAC,OAAO,CAAC,EAAE,CAAC,SAAS,CAAC;IAC/B,CAAC,mBAAQ,CAAC,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,OAAO,CAAC;IACxC,CAAC,mBAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,QAAQ,CAAC;CAC9B,CAAC;AAOF,MAAa,gBAAiB,SAAQ,sBAAa;IAKjD,YAAY,KAAmB,EAAE,UAAwC,EAAE;QACzE,KAAK,CAAC,KAAyB,EAAE,OAAO,CAAC,CAAC;QAL5B,UAAK,GAAG,IAAI,CAAC;QAErB,qBAAgB,GAA6B,IAAI,CAAC;QAIxD,IAAI,CAAC,QAAQ,GAAG,KAAK,CAAC;QAEtB,IAAI,CAAC,YAAY,CAAC,MAAM,EAAE,CAAC,QAAa,EAAE,EAAE;;YAC1C,MAAM,GAAG,GAAG,MAAA,MAAA,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,IAAI,0CAAE,KAAK,0CAAE,EAAE,CAAC;YACtC,MAAM,QAAQ,GAAG,MAAA,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,IAAI,mCAAI,EAAE,CAAC;YACtC,OAAO,GAAG,IAAI,IAAI,CAAC,CAAC,CAAC,GAAG,QAAQ,YAAY,GAAG,GAAG,CAAC,CAAC,CAAC,QAAQ,CAAC;QAChE,CAAC,CAAC,CAAC;IACL,CAAC;IAEM,KAAK,CAAC,YAAY;;QACvB,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,MAAM,OAAO,CAAC,GAAG,CAAC,CAAC,KAAK,CAAC,YAAY,EAAE,EAAE,IAAI,CAAC,cAAc,EAAE,CAAC,CAAC,CAAC;QACxF,OAAO;YACL,GAAG,IAAI;YACP,CAAC,mBAAQ,CAAC,OAAO,CAAC,EAAE,CAAC,MAAA,IAAI,CAAC,mBAAQ,CAAC,OAAO,CAAC,mCAAI,CAAC,CAAC,GAAG,MAAM,CAAC,OAAO;YAClE,CAAC,mBAAQ,CAAC,OAAO,CAAC,EAAE,CAAC,MAAA,IAAI,CAAC,mBAAQ,CAAC,OAAO,CAAC,mCAAI,CAAC,CAAC,GAAG,MAAM,CAAC,OAAO,GAAG,MAAM,CAAC,KAAK;YACjF,CAAC,mBAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,MAAA,IAAI,CAAC,mBAAQ,CAAC,MAAM,CAAC,mCAAI,CAAC,CAAC,GAAG,MAAM,CAAC,MAAM;SAChE,CAAC;IACJ,CAAC;IAEM,KAAK,CAAC,OAAO,CAClB,WAAwB,EACxB,KAAK,GAAG,CAAC,EACT,GAAG,GAAG,CAAC,CAAC;QAER,MAAM,YAAY,GAAG,GAAG,CAAC;QACzB,MAAM,aAAa,GAAG,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,gBAAgB,CAAC,CAAC,CAAC,GAAG,CAAC;QACjE,MAAM,QAAQ,GAAG,aAAa,GAAG,KAAK,GAAG,CAAC,CAAC;QAE3C,MAAM,aAAa,GAAG,IAAI,CAAC,wBAAwB,CAAC,WAAW,CAAC,CAAC;QAEjE,IAAI,aAAa,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;YAC/B,OAAO,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,YAAY,CAAC,CAAC;QACzD,CAAC;QAED,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;QAC1C,MAAM,YAAY,GAAG,WAAW,CAAC,MAAM,CAAC,CAAC,GAAG,EAAE,MAAM,EAAE,EAAE,WAAC,OAAA,GAAG,GAAG,CAAC,MAAA,MAAM,CAAC,MAAM,CAAC,mCAAI,CAAC,CAAC,CAAA,EAAA,EAAE,CAAC,CAAC,CAAC;QAEzF,MAAM,WAAW,GACf,KAAK,GAAG,YAAY;YAClB,CAAC,CAAC,MAAM,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,IAAI,CAAC,GAAG,CAAC,aAAa,EAAE,YAAY,GAAG,CAAC,CAAC,CAAC;YACpF,CAAC,CAAC,EAAE,CAAC;QAET,MAAM,SAAS,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,EAAE,KAAK,GAAG,YAAY,CAAC,CAAC;QACpD,MAAM,SAAS,GAAG,QAAQ,GAAG,WAAW,CAAC,MAAM,CAAC;QAEhD,IAAI,SAAS,IAAI,CAAC,EAAE,CAAC;YACnB,OAAO,WAAW,CAAC;QACrB,CAAC;QAED,MAAM,SAAS,GAAG,MAAM,IAAI,CAAC,mBAAmB,CAAC,aAAa,EAAE,SAAS,EAAE,SAAS,CAAC,CAAC;QACtF,OAAO,CAAC,GAAG,WAAW,EAAE,GAAG,SAAS,CAAC,CAAC;IACxC,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC3C,CAAC;IAEM,KAAK,CAAC,KAAK,CAAC,SAAyB,EAAE,WAAmB;QAC/D,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,KAAK,CAAC,SAAS,EAAE,WAAW,CAAC,CAAC;IAC7C,CAAC;IAEM,KAAK,CAAC,KAAK;QAChB,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,KAAK,EAAE,CAAC;IACvB,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,UAAU,EAAE,CAAC;IAC5B,CAAC;IAEM,KAAK,CAAC,KAAK;QAChB,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,KAAK,EAAE,CAAC;IACvB,CAAC;IAEM,KAAK,CAAC,MAAM;QACjB,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,MAAM,EAAE,CAAC;IACxB,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,IAAI,CAAC,qBAAqB,EAAE,CAAC;QAC7B,OAAO,KAAK,CAAC,UAAU,EAAE,CAAC;IAC5B,CAAC;IAEO,qBAAqB;QAC3B,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;IAC/B,CAAC;IAEO,KAAK,CAAC,cAAc;QAC1B,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;QACvB,IAAI,IAAI,CAAC,gBAAgB,IAAI,GAAG,GAAG,IAAI,CAAC,gBAAgB,CAAC,SAAS,GAAG,mBAAmB,EAAE,CAAC;YACzF,OAAO,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC;QACrC,CAAC;QACD,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,QAAQ,CAAC,sBAAsB,EAAE,CAAC;QAC3D,IAAI,CAAC,gBAAgB,GAAG,EAAE,SAAS,EAAE,GAAG,EAAE,KAAK,EAAE,CAAC;QAClD,OAAO,KAAK,CAAC;IACf,CAAC;IAEO,wBAAwB,CAAC,WAAwB;QACvD,MAAM,MAAM,GAAG,IAAI,GAAG,EAAmB,CAAC;QAC1C,KAAK,MAAM,MAAM,IAAI,WAAW,EAAE,CAAC;YACjC,MAAM,MAAM,GAAG,wBAAwB,CAAC,MAAM,CAAC,CAAC;YAChD,IAAI,MAAM,EAAE,CAAC;gBACX,KAAK,MAAM,WAAW,IAAI,MAAM,EAAE,CAAC;oBACjC,MAAM,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC;gBAC1B,CAAC;YACH,CAAC;QACH,CAAC;QACD,OAAO,CAAC,GAAG,MAAM,CAAC,CAAC;IACrB,CAAC;IAEO,KAAK,CAAC,mBAAmB,CAC/B,aAAgC,EAChC,IAAY,EACZ,IAAY;QAEZ,MAAM,SAAS,GAAiB,EAAE,CAAC;QACnC,IAAI,aAAa,GAAG,IAAI,CAAC;QACzB,IAAI,aAAa,GAAG,IAAI,CAAC;QAEzB,KAAK,MAAM,WAAW,IAAI,aAAa,EAAE,CAAC;YACxC,IAAI,aAAa,IAAI,CAAC;gBAAE,MAAM;YAE9B,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,QAAQ,CAAC,iBAAiB,CAAC,WAAW,CAAC,CAAC;YAElE,KAAK,MAAM,KAAK,IAAI,MAAM,EAAE,CAAC;gBAC3B,IAAI,aAAa,IAAI,CAAC;oBAAE,MAAM;gBAE9B,IAAI,aAAa,IAAI,KAAK,CAAC,KAAK,EAAE,CAAC;oBACjC,aAAa,IAAI,KAAK,CAAC,KAAK,CAAC;oBAC7B,SAAS;gBACX,CAAC;gBAED,MAAM,UAAU,GAAG,aAAa,CAAC;gBACjC,MAAM,QAAQ,GAAG,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,KAAK,GAAG,CAAC,EAAE,UAAU,GAAG,aAAa,GAAG,CAAC,CAAC,CAAC;gBAC3E,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,QAAQ,CAAC,YAAY,CAAC,KAAK,CAAC,EAAE,EAAE,UAAU,EAAE,QAAQ,CAAC,CAAC;gBAE9E,SAAS,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,CAAC;gBACxB,aAAa,GAAG,CAAC,CAAC;gBAClB,aAAa,IAAI,IAAI,CAAC,MAAM,CAAC;YAC/B,CAAC;QACH,CAAC;QAED,OAAO,SAAS,CAAC;IACnB,CAAC;CACF;AA5JD,4CA4JC"}

dist/queueAdapters/bullMQProTypes.d.ts

+import type { Job, Queue } from 'bullmq';
+export type GroupStatusName = 'waiting' | 'limited' | 'maxed' | 'paused';
+export interface GroupSummary {
+    id: string;
+    status: GroupStatusName;
+}
+export interface GroupSummaryWithCount {
+    id: string;
+    count: number;
+}
+export interface GroupsCountByStatus {
+    waiting: number;
+    limited: number;
+    maxed: number;
+    paused: number;
+}
+export interface QueueProLike extends Queue {
+    getGroups(start?: number, end?: number): Promise<GroupSummary[]>;
+    getGroupsByStatus(status: GroupStatusName, start?: number, end?: number): Promise<GroupSummaryWithCount[]>;
+    getGroupsCount(): Promise<number>;
+    getGroupsCountByStatus(): Promise<GroupsCountByStatus>;
+    getGroupJobs(groupId: string | number, start?: number, end?: number): Promise<JobProLike[]>;
+    getGroupJobsCount(groupId: string | number): Promise<number>;
+}
+export interface JobProLike extends Job {
+    gid?: string | number;
+    opts: Job['opts'] & {
+        group?: {
+            id: string | number;
+        };
+    };
+}

dist/queueAdapters/bullMQProTypes.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+//# sourceMappingURL=bullMQProTypes.js.map

dist/queueAdapters/bullMQProTypes.js.map

+{"version":3,"file":"bullMQProTypes.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQProTypes.ts"],"names":[],"mappings":""}

dist/handlers/queues.js

@@ -6,2 +6,3 @@ "use strict";
 const formatJob = (job, queue) => {
+    var _a, _b;
     const jobProps = job.toJSON();
@@ -27,2 +28,3 @@ const stacktrace = jobProps.stacktrace ? jobProps.stacktrace.filter(Boolean) : [];
         externalUrl: typeof queue.externalJobUrl === 'function' ? queue.externalJobUrl(jobProps) : undefined,
+        groupId: (_b = (_a = jobProps.opts) === null || _a === void 0 ? void 0 : _a.group) === null || _b === void 0 ? void 0 : _b.id,
     };
@@ -29,0 +31,0 @@ };

dist/handlers/queues.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queues.js","sourceRoot":"","sources":["../../src/handlers/queues.ts"],"names":[],"mappings":";;;AAwGA,sCAgBC;AA3GM,MAAM,SAAS,GAAG,CAAC,GAAa,EAAE,KAAkB,EAAU,EAAE;IACrE,MAAM,QAAQ,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC;IAE9B,MAAM,UAAU,GAAG,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAClF,UAAU,CAAC,OAAO,EAAE,CAAC;IAErB,OAAO;QACL,EAAE,EAAE,QAAQ,CAAC,EAAE;QACf,SAAS,EAAE,QAAQ,CAAC,SAAS;QAC7B,WAAW,EAAE,QAAQ,CAAC,WAAW;QACjC,WAAW,EAAE,QAAQ,CAAC,WAAW;QACjC,UAAU,EAAE,QAAQ,CAAC,UAAU;QAC/B,QAAQ,EAAE,KAAK,CAAC,MAAM,CAAC,UAAU,EAAE,QAAQ,CAAC,QAAQ,CAAC;QACrD,QAAQ,EAAE,QAAQ,CAAC,YAAY;QAC/B,KAAK,EAAE,QAAQ,CAAC,KAAK;QACrB,YAAY,EAAE,QAAQ,CAAC,YAAY;QACnC,UAAU;QACV,IAAI,EAAE,QAAQ,CAAC,IAAI;QACnB,IAAI,EAAE,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC;QACzC,IAAI,EAAE,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,EAAE,QAAQ,CAAC,IAAI,IAAI,EAAE,CAAC;QACzD,WAAW,EAAE,KAAK,CAAC,MAAM,CAAC,aAAa,EAAE,QAAQ,CAAC,WAAW,CAAC;QAC9D,QAAQ,EAAE,CAAC,CAAC,QAAQ,CAAC,YAAY,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,CAAC;QACzF,WAAW,EACT,OAAO,KAAK,CAAC,cAAc,KAAK,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,cAAc,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,SAAS;KAC1F,CAAC;AACJ,CAAC,CAAC;AAzBW,QAAA,SAAS,aAyBpB;AAEF,SAAS,aAAa,CACpB,QAAqB,EACrB,MAAiB,EACjB,WAAmB,EACnB,WAAmB;IAEnB,MAAM,cAAc,GAAG,QAAQ,CAAC,MAAM,GAAG,CAAC,CAAC;IAC3C,MAAM,KAAK,GAAG,cAAc;QAC1B,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,MAAM,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,WAAW,CAAC,EAAE,CAAC,CAAC;QACtF,CAAC,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,CAAC;IAExB,MAAM,KAAK,GAAG,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,WAAW,GAAG,CAAC,CAAC,GAAG,WAAW,CAAC;IACnE,MAAM,SAAS,GAAG,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,GAAG,WAAW,CAAC,CAAC;IAEtE,OAAO;QACL,SAAS;QACT,KAAK,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,GAAG,WAAW,GAAG,CAAC,EAAE;KAC/C,CAAC;AACJ,CAAC;AAED,KAAK,UAAU,YAAY,CACzB,KAA8B,EAC9B,KAA0B;IAE1B,OAAO,OAAO,CAAC,GAAG,CAChB,KAAK,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC,SAAS,EAAE,KAAK,CAAC,EAAE,EAAE;QACrC,MAAM,aAAa,GAAG,kBAAkB,CAAC,KAAK,CAAC,WAAW,CAAC,KAAK,SAAS,CAAC;QAC1E,MAAM,WAAW,GAAG,CAAC,KAAK,CAAC,WAAW,IAAI,EAAE,CAAC;QAE7C,MAAM,WAAW,GAAG,KAAK,CAAC,cAAc,EAAE,CAAC;QAE3C,MAAM,MAAM,GACV,CAAC,aAAa,IAAI,KAAK,CAAC,MAAM,KAAK,QAAQ,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,MAAmB,CAAC,CAAC;QAC1F,MAAM,WAAW,GAAG,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,CAAC;QAErC,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;QAC1C,MAAM,QAAQ,GAAG,MAAM,KAAK,CAAC,QAAQ,EAAE,CAAC;QACxC,MAAM,iBAAiB,GAAG,MAAM,KAAK,CAAC,oBAAoB,EAAE,CAAC;QAE7D,MAAM,UAAU,GAAG,aAAa,CAAC,MAAM,EAAE,MAAM,EAAE,WAAW,EAAE,WAAW,CAAC,CAAC;QAC3E,MAAM,IAAI,GAAG,aAAa;YACxB,CAAC,CAAC,MAAM,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,UAAU,CAAC,KAAK,CAAC,KAAK,EAAE,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC;YAC3E,CAAC,CAAC,EAAE,CAAC;QAEP,OAAO;YACL,IAAI,EAAE,SAAS;YACf,WAAW,EAAE,KAAK,CAAC,cAAc,EAAE,IAAI,SAAS;YAChD,WAAW,EAAE,KAAK,CAAC,cAAc,EAAE,IAAI,SAAS;YAChD,QAAQ,EAAE,KAAK,CAAC,WAAW,EAAE;YAC7B,MAAM,EAAE,MAAgC;YACxC,IAAI,EAAE,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,IAAA,iBAAS,EAAC,GAAG,EAAE,KAAK,CAAC,CAAC;YAC9D,UAAU;YACV,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,qBAAqB,EAAE,KAAK,CAAC,qBAAqB;YAClD,QAAQ;YACR,IAAI,EAAE,KAAK,CAAC,IAAI;YAChB,SAAS,EAAE,KAAK,CAAC,SAAS;YAC1B,iBAAiB;SAClB,CAAC;IACJ,CAAC,CAAC,CACH,CAAC;AACJ,CAAC;AAEM,KAAK,UAAU,aAAa,CAAC,GAAqB;IACvD,MAAM,KAAK,GAA4B,EAAE,CAAC;IAE1C,KAAK,MAAM,CAAC,SAAS,EAAE,KAAK,CAAC,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;QACtD,IAAI,MAAM,KAAK,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC;YAC/B,KAAK,CAAC,IAAI,CAAC,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC,CAAC;QACjC,CAAC;IACH,CAAC;IAED,MAAM,MAAM,GAAG,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,MAAM,YAAY,CAAC,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAE5E,OAAO;QACL,IAAI,EAAE;YACJ,MAAM;SACP;KACF,CAAC;AACJ,CAAC"}
+{"version":3,"file":"queues.js","sourceRoot":"","sources":["../../src/handlers/queues.ts"],"names":[],"mappings":";;;AAyGA,sCAgBC;AA5GM,MAAM,SAAS,GAAG,CAAC,GAAa,EAAE,KAAkB,EAAU,EAAE;;IACrE,MAAM,QAAQ,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC;IAE9B,MAAM,UAAU,GAAG,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAClF,UAAU,CAAC,OAAO,EAAE,CAAC;IAErB,OAAO;QACL,EAAE,EAAE,QAAQ,CAAC,EAAE;QACf,SAAS,EAAE,QAAQ,CAAC,SAAS;QAC7B,WAAW,EAAE,QAAQ,CAAC,WAAW;QACjC,WAAW,EAAE,QAAQ,CAAC,WAAW;QACjC,UAAU,EAAE,QAAQ,CAAC,UAAU;QAC/B,QAAQ,EAAE,KAAK,CAAC,MAAM,CAAC,UAAU,EAAE,QAAQ,CAAC,QAAQ,CAAC;QACrD,QAAQ,EAAE,QAAQ,CAAC,YAAY;QAC/B,KAAK,EAAE,QAAQ,CAAC,KAAK;QACrB,YAAY,EAAE,QAAQ,CAAC,YAAY;QACnC,UAAU;QACV,IAAI,EAAE,QAAQ,CAAC,IAAI;QACnB,IAAI,EAAE,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,CAAC,IAAI,CAAC;QACzC,IAAI,EAAE,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,EAAE,QAAQ,CAAC,IAAI,IAAI,EAAE,CAAC;QACzD,WAAW,EAAE,KAAK,CAAC,MAAM,CAAC,aAAa,EAAE,QAAQ,CAAC,WAAW,CAAC;QAC9D,QAAQ,EAAE,CAAC,CAAC,QAAQ,CAAC,YAAY,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,UAAU,CAAC,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,CAAC;QACzF,WAAW,EACT,OAAO,KAAK,CAAC,cAAc,KAAK,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,cAAc,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,SAAS;QACzF,OAAO,EAAE,MAAA,MAAA,QAAQ,CAAC,IAAI,0CAAE,KAAK,0CAAE,EAAE;KAClC,CAAC;AACJ,CAAC,CAAC;AA1BW,QAAA,SAAS,aA0BpB;AAEF,SAAS,aAAa,CACpB,QAAqB,EACrB,MAAiB,EACjB,WAAmB,EACnB,WAAmB;IAEnB,MAAM,cAAc,GAAG,QAAQ,CAAC,MAAM,GAAG,CAAC,CAAC;IAC3C,MAAM,KAAK,GAAG,cAAc;QAC1B,CAAC,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,KAAK,EAAE,MAAM,EAAE,EAAE,CAAC,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,MAAM,CAAC,EAAE,WAAW,CAAC,EAAE,CAAC,CAAC;QACtF,CAAC,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,CAAC;IAExB,MAAM,KAAK,GAAG,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,WAAW,GAAG,CAAC,CAAC,GAAG,WAAW,CAAC;IACnE,MAAM,SAAS,GAAG,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,GAAG,WAAW,CAAC,CAAC;IAEtE,OAAO;QACL,SAAS;QACT,KAAK,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,GAAG,WAAW,GAAG,CAAC,EAAE;KAC/C,CAAC;AACJ,CAAC;AAED,KAAK,UAAU,YAAY,CACzB,KAA8B,EAC9B,KAA0B;IAE1B,OAAO,OAAO,CAAC,GAAG,CAChB,KAAK,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC,SAAS,EAAE,KAAK,CAAC,EAAE,EAAE;QACrC,MAAM,aAAa,GAAG,kBAAkB,CAAC,KAAK,CAAC,WAAW,CAAC,KAAK,SAAS,CAAC;QAC1E,MAAM,WAAW,GAAG,CAAC,KAAK,CAAC,WAAW,IAAI,EAAE,CAAC;QAE7C,MAAM,WAAW,GAAG,KAAK,CAAC,cAAc,EAAE,CAAC;QAE3C,MAAM,MAAM,GACV,CAAC,aAAa,IAAI,KAAK,CAAC,MAAM,KAAK,QAAQ,CAAC,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,MAAmB,CAAC,CAAC;QAC1F,MAAM,WAAW,GAAG,CAAC,KAAK,CAAC,IAAI,IAAI,CAAC,CAAC;QAErC,MAAM,MAAM,GAAG,MAAM,KAAK,CAAC,YAAY,EAAE,CAAC;QAC1C,MAAM,QAAQ,GAAG,MAAM,KAAK,CAAC,QAAQ,EAAE,CAAC;QACxC,MAAM,iBAAiB,GAAG,MAAM,KAAK,CAAC,oBAAoB,EAAE,CAAC;QAE7D,MAAM,UAAU,GAAG,aAAa,CAAC,MAAM,EAAE,MAAM,EAAE,WAAW,EAAE,WAAW,CAAC,CAAC;QAC3E,MAAM,IAAI,GAAG,aAAa;YACxB,CAAC,CAAC,MAAM,KAAK,CAAC,OAAO,CAAC,MAAM,EAAE,UAAU,CAAC,KAAK,CAAC,KAAK,EAAE,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC;YAC3E,CAAC,CAAC,EAAE,CAAC;QAEP,OAAO;YACL,IAAI,EAAE,SAAS;YACf,WAAW,EAAE,KAAK,CAAC,cAAc,EAAE,IAAI,SAAS;YAChD,WAAW,EAAE,KAAK,CAAC,cAAc,EAAE,IAAI,SAAS;YAChD,QAAQ,EAAE,KAAK,CAAC,WAAW,EAAE;YAC7B,MAAM,EAAE,MAAgC;YACxC,IAAI,EAAE,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,IAAA,iBAAS,EAAC,GAAG,EAAE,KAAK,CAAC,CAAC;YAC9D,UAAU;YACV,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,YAAY,EAAE,KAAK,CAAC,YAAY;YAChC,qBAAqB,EAAE,KAAK,CAAC,qBAAqB;YAClD,QAAQ;YACR,IAAI,EAAE,KAAK,CAAC,IAAI;YAChB,SAAS,EAAE,KAAK,CAAC,SAAS;YAC1B,iBAAiB;SAClB,CAAC;IACJ,CAAC,CAAC,CACH,CAAC;AACJ,CAAC;AAEM,KAAK,UAAU,aAAa,CAAC,GAAqB;IACvD,MAAM,KAAK,GAA4B,EAAE,CAAC;IAE1C,KAAK,MAAM,CAAC,SAAS,EAAE,KAAK,CAAC,IAAI,GAAG,CAAC,MAAM,CAAC,OAAO,EAAE,EAAE,CAAC;QACtD,IAAI,MAAM,KAAK,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC;YAC/B,KAAK,CAAC,IAAI,CAAC,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC,CAAC;QACjC,CAAC;IACH,CAAC;IAED,MAAM,MAAM,GAAG,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,CAAC,MAAM,YAAY,CAAC,KAAK,EAAE,GAAG,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAE5E,OAAO;QACL,IAAI,EAAE;YACJ,MAAM;SACP;KACF,CAAC;AACJ,CAAC"}

package.json

 {
   "name": "@bull-board/api",
-  "version": "7.0.0",
+  "version": "7.1.3",
   "description": "A Dashboard server API built on top of bull or bullmq.",
@@ -31,2 +31,3 @@ "keywords": [
     "./bullMQAdapter": "./bullMQAdapter.js",
+    "./bullMQProAdapter": "./bullMQProAdapter.js",
     "./bullAdapter": "./bullAdapter.js",
@@ -54,3 +55,3 @@ "./baseAdapter": "./baseAdapter.d.ts",
   "peerDependencies": {
-    "@bull-board/ui": "7.0.0"
+    "@bull-board/ui": "7.1.3"
   },
@@ -57,0 +58,0 @@ "publishConfig": {

typings/app.d.ts

@@ -129,2 +129,3 @@ import type { RedisInfo } from 'redis-info';
   };
+  groupId?: string | number;
 }
@@ -131,0 +132,0 @@

No alert changes

Improved metrics

Total package byte prevSize

107513

14.67%

Number of package files

114

7.55%

Lines of code

1747

13.29%

No dependency changes