@bull-monitor/root - npm Package Compare versions

Comparing version 0.31.0 to 1.0.0

CHANGELOG.md

@@ -6,2 +6,21 @@ # Change Log
 
+# [1.0.0](https://github.com/s-r-x/bull-monitor/compare/v0.31.0...v1.0.0) (2021-08-03)
+
+
+### Features
+
+* **gql:** id field inside Queue(concatenated prefix and name then converted ([18bc332](https://github.com/s-r-x/bull-monitor/commit/18bc332d4a3e9a942d2a0ba65d8ec573a1c884eb))
+
+
+### BREAKING CHANGES
+
+* **gql:** all mutations and queries that have the "queue"
+argument now should use queue's id instead of name as a unique queue
+identifier
+BREAKING_CHANGE: since this version all the existing old metrics will be removed. they have been stored in redis assuming that queue names are unique, so queues with the same name did override metrics of each other
+
+
+
+
+
 # [0.31.0](https://github.com/s-r-x/bull-monitor/compare/v0.30.0...v0.31.0) (2021-07-29)
@@ -8,0 +27,0 @@

dist/gql/data-sources/bull/index.d.ts

 import { DataSource } from 'apollo-datasource';
-import type { Queue as BullQueue, JobCounts, JobStatus, JobId, Job } from 'bull';
+import type { JobCounts, JobStatus, JobId, Job } from 'bull';
 import { CreateJobInput, JobDataSearchInput, MutationCleanQueueArgs, MutationCloseQueueArgs, MutationDiscardJobArgs, MutationEmptyQueueArgs, MutationLogArgs, MutationMoveJobToCompletedArgs, MutationMoveJobToFailedArgs, MutationPromoteJobArgs, MutationRemoveJobArgs, MutationRemoveJobsArgs, MutationRemoveJobsByPatternArgs, MutationResumeQueueArgs, MutationRetryJobArgs, MutationRetryJobsArgs, MutationUpdateJobDataArgs, OrderEnum } from '../../../typings/gql';
 import { Maybe } from '../../../typings/utils';
 import redisInfo from 'redis-info';
+import { BullMonitorQueue as Queue } from '../../../queue';
 declare type Config = {
@@ -20,3 +21,3 @@ textSearchScanCount?: number;
     private _queuesMap;
-    constructor(_queues: BullQueue[], _config: Config);
+    constructor(_queues: Queue[], _config: Config);
     private _convertQueuesToMap;
@@ -26,4 +27,5 @@ private _throwInternalError;
     private _throwJobNotFound;
-    getQueueByName(name: string, throwIfNotFound?: boolean): BullQueue<any> | undefined;
-    getQueues(): BullQueue[];
+    getQueueByName(name: string, throwIfNotFound?: boolean): Queue | undefined;
+    getQueueById(id: string, throwIfNotFound?: boolean): Queue | undefined;
+    getQueues(): Queue[];
     getQueueJobs({ queue, limit, offset, status, id, ids, order, dataSearch, }: {
@@ -40,24 +42,20 @@ limit?: number;
     private _filterJobs;
-    getJob(queueName: string, id: JobId, throwIfNotFound?: boolean): Promise<Job<any> | null | undefined>;
+    getJob(queueId: string, id: JobId, throwIfNotFound?: boolean): Promise<Job<any> | null | undefined>;
     extractJobProcessingTime(job: Job): number;
-    getJobLogs(queueName: string, id: number): Promise<{
-        logs: string[];
-        count: number;
-    } | undefined>;
-    getQueueJobsCounts(name: string): Promise<Maybe<JobCounts>>;
-    getQueueFailedCount(name: string): Promise<Maybe<number>>;
-    getQueueCompletedCount(name: string): Promise<Maybe<number>>;
-    getQueueDelayedCount(name: string): Promise<Maybe<number>>;
-    getQueueActiveCount(name: string): Promise<Maybe<number>>;
-    getQueueWaitingCount(name: string): Promise<Maybe<number>>;
-    getQueuePausedCount(name: string): Promise<Maybe<number>>;
-    getQueueWaitingOrDelayedJobsCount(name: string): Promise<Maybe<number>>;
+    getQueueJobsCounts(id: string): Promise<Maybe<JobCounts>>;
+    getQueueFailedCount(id: string): Promise<Maybe<number>>;
+    getQueueCompletedCount(id: string): Promise<Maybe<number>>;
+    getQueueDelayedCount(id: string): Promise<Maybe<number>>;
+    getQueueActiveCount(id: string): Promise<Maybe<number>>;
+    getQueueWaitingCount(id: string): Promise<Maybe<number>>;
+    getQueuePausedCount(id: string): Promise<Maybe<number>>;
+    getQueueWaitingOrDelayedJobsCount(id: string): Promise<Maybe<number>>;
     getRedisInfo(): Promise<redisInfo.RedisInfo | null>;
-    createJob({ queue: queueName, name, data, options, }: CreateJobInput): Promise<Job<any> | undefined>;
+    createJob({ queue: queueId, name, data, options, }: CreateJobInput): Promise<Job<any> | undefined>;
     removeJobsByPattern(args: MutationRemoveJobsByPatternArgs): Promise<boolean>;
-    pauseQueue(name: string): Promise<BullQueue<any> | undefined>;
+    pauseQueue(id: string): Promise<Queue | undefined>;
     cleanQueue(args: MutationCleanQueueArgs): Promise<Job<any>[] | undefined>;
-    emptyQueue(args: MutationEmptyQueueArgs): Promise<BullQueue<any> | undefined>;
-    closeQueue(args: MutationCloseQueueArgs): Promise<BullQueue<any> | undefined>;
-    resumeQueue(args: MutationResumeQueueArgs): Promise<BullQueue<any> | undefined>;
+    emptyQueue(args: MutationEmptyQueueArgs): Promise<Queue | undefined>;
+    closeQueue(args: MutationCloseQueueArgs): Promise<Queue | undefined>;
+    resumeQueue(args: MutationResumeQueueArgs): Promise<Queue | undefined>;
     promoteJob(args: MutationPromoteJobArgs): Promise<Job<any> | null | undefined>;
@@ -64,0 +62,0 @@ discardJob(args: MutationDiscardJobArgs): Promise<Job<any> | null | undefined>;

dist/gql/data-sources/bull/index.js

@@ -41,3 +41,3 @@ "use strict";
         queues.forEach(queue => {
-            this._queuesMap.set(queue.name, queue);
+            this._queuesMap.set(queue.id, queue);
         });
@@ -62,2 +62,10 @@ }
     }
+    // queries
+    getQueueById(id, throwIfNotFound) {
+        const queue = this._queuesMap.get(id);
+        if (!queue && throwIfNotFound) {
+            this._throwQueueNotFound();
+        }
+        return queue;
+    }
     getQueues() {
@@ -74,3 +82,3 @@ return this._queues;
             }
-            const bullQueue = this.getQueueByName(queue, true);
+            const bullQueue = this.getQueueById(queue, true);
             if (ids) {
@@ -114,5 +122,5 @@ return yield Promise.all(ids.map(id => bullQueue.getJob(id))).then(this._filterJobs);
     }
-    getJob(queueName, id, throwIfNotFound) {
+    getJob(queueId, id, throwIfNotFound) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(queueName, true);
+            const queue = this.getQueueById(queueId, true);
             const job = yield (queue === null || queue === void 0 ? void 0 : queue.getJob(id));
@@ -130,53 +138,47 @@ if (!job && throwIfNotFound) {
     }
-    getJobLogs(queueName, id) {
+    getQueueJobsCounts(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(queueName, true);
-            return yield (queue === null || queue === void 0 ? void 0 : queue.getJobLogs(id));
-        });
-    }
-    getQueueJobsCounts(name) {
-        return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getJobCounts());
         });
     }
-    getQueueFailedCount(name) {
+    getQueueFailedCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getFailedCount());
         });
     }
-    getQueueCompletedCount(name) {
+    getQueueCompletedCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getCompletedCount());
         });
     }
-    getQueueDelayedCount(name) {
+    getQueueDelayedCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getDelayedCount());
         });
     }
-    getQueueActiveCount(name) {
+    getQueueActiveCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getActiveCount());
         });
     }
-    getQueueWaitingCount(name) {
+    getQueueWaitingCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getWaitingCount());
         });
     }
-    getQueuePausedCount(name) {
+    getQueuePausedCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.getPausedCount());
         });
     }
-    getQueueWaitingOrDelayedJobsCount(name) {
+    getQueueWaitingOrDelayedJobsCount(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name);
+            const queue = this.getQueueById(id);
             return yield (queue === null || queue === void 0 ? void 0 : queue.count());
@@ -196,5 +198,5 @@ });
     // mutations
-    createJob({ queue: queueName, name = null, data = {}, options = {}, }) {
+    createJob({ queue: queueId, name = null, data = {}, options = {}, }) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(queueName, true);
+            const queue = this.getQueueById(queueId, true);
             return yield (queue === null || queue === void 0 ? void 0 : queue.add(name, json_1.JsonService.maybeParse(data), json_1.JsonService.maybeParse(options)));
@@ -205,3 +207,3 @@ });
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(args.queue, true);
+            const queue = this.getQueueById(args.queue, true);
             yield (queue === null || queue === void 0 ? void 0 : queue.removeJobs(args.pattern));
@@ -211,5 +213,5 @@ return true;
     }
-    pauseQueue(name) {
+    pauseQueue(id) {
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(name, true);
+            const queue = this.getQueueById(id, true);
             yield (queue === null || queue === void 0 ? void 0 : queue.pause());
@@ -221,3 +223,3 @@ return queue;
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(args.queue, true);
+            const queue = this.getQueueById(args.queue, true);
             return yield (queue === null || queue === void 0 ? void 0 : queue.clean(args.grace, args.status, args.limit || undefined));
@@ -228,3 +230,3 @@ });
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(args.queue, true);
+            const queue = this.getQueueById(args.queue, true);
             yield (queue === null || queue === void 0 ? void 0 : queue.empty());
@@ -236,3 +238,3 @@ return queue;
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(args.queue, true);
+            const queue = this.getQueueById(args.queue, true);
             yield (queue === null || queue === void 0 ? void 0 : queue.close());
@@ -244,3 +246,3 @@ return queue;
         return __awaiter(this, void 0, void 0, function* () {
-            const queue = this.getQueueByName(args.queue, true);
+            const queue = this.getQueueById(args.queue, true);
             yield (queue === null || queue === void 0 ? void 0 : queue.resume());
@@ -247,0 +249,0 @@ return queue;

dist/gql/data-sources/metrics/index.d.ts

@@ -5,3 +5,3 @@ /// <reference types="bull" />
 export declare enum ErrorEnum {
-    NO_COLLECTOR = "Metrics is not enabled"
+    NO_COLLECTOR = "Metrics are not enabled"
 }
@@ -8,0 +8,0 @@ export declare class MetricsDataSource extends DataSource {

dist/gql/data-sources/metrics/index.js

@@ -17,3 +17,3 @@ "use strict";
 (function (ErrorEnum) {
-    ErrorEnum["NO_COLLECTOR"] = "Metrics is not enabled";
+    ErrorEnum["NO_COLLECTOR"] = "Metrics are not enabled";
 })(ErrorEnum = exports.ErrorEnum || (exports.ErrorEnum = {}));
@@ -20,0 +20,0 @@ class MetricsDataSource extends apollo_datasource_1.DataSource {

dist/gql/resolvers/job.js

@@ -24,4 +24,4 @@ "use strict";
         },
-        logs(job, _vars, { dataSources: { bull } }) {
-            return bull.getJobLogs(job.queue.name, job.id);
+        logs(job, _vars) {
+            return job.queue.getJobLogs(job.id);
         },
@@ -28,0 +28,0 @@ returnValue(job) {

dist/gql/resolvers/query.js

@@ -29,3 +29,3 @@ "use strict";
         queue(_, args, { dataSources: { bull } }) {
-            return bull.getQueueByName(args.name);
+            return bull.getQueueById(args.id);
         },
@@ -32,0 +32,0 @@ jobs(_, args, { dataSources: { bull } }) {

dist/gql/resolvers/queue.js

@@ -17,3 +17,3 @@ "use strict";
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueWaitingOrDelayedJobsCount(parent.name);
+                return yield bull.getQueueWaitingOrDelayedJobsCount(parent.id);
             });
@@ -23,3 +23,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueFailedCount(parent.name);
+                return yield bull.getQueueFailedCount(parent.id);
             });
@@ -29,3 +29,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueCompletedCount(parent.name);
+                return yield bull.getQueueCompletedCount(parent.id);
             });
@@ -35,3 +35,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueDelayedCount(parent.name);
+                return yield bull.getQueueDelayedCount(parent.id);
             });
@@ -41,3 +41,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueActiveCount(parent.name);
+                return yield bull.getQueueActiveCount(parent.id);
             });
@@ -47,3 +47,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueWaitingCount(parent.name);
+                return yield bull.getQueueWaitingCount(parent.id);
             });
@@ -53,3 +53,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueWaitingCount(parent.name);
+                return yield bull.getQueueWaitingCount(parent.id);
             });
@@ -59,3 +59,3 @@ },
             return __awaiter(this, void 0, void 0, function* () {
-                return yield bull.getQueueJobsCounts(parent.name);
+                return yield bull.getQueueJobsCounts(parent.id);
             });
@@ -71,3 +71,3 @@ },
                 return yield bull.getQueueJobs({
-                    queue: parent.name,
+                    queue: parent.id,
                 });
@@ -78,3 +78,3 @@ });
             return __awaiter(this, void 0, void 0, function* () {
-                return yield metrics.getMetrics(parent.name);
+                return yield metrics.getMetrics(parent.id);
             });
@@ -81,0 +81,0 @@ },

dist/gql/type-defs/mutations.js

@@ -22,11 +22,11 @@ "use strict";
     """
-    pauseQueue(queue: String!): Queue
+    pauseQueue(queue: ID!): Queue
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queueresume
     """
-    resumeQueue(queue: String!): Queue
+    resumeQueue(queue: ID!): Queue
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queueclose
     """
-    closeQueue(queue: String!): Queue
+    closeQueue(queue: ID!): Queue
     """
@@ -36,3 +36,3 @@ https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queueclean
     cleanQueue(
-      queue: String!
+      queue: ID!
       grace: Int = 1000
@@ -45,43 +45,43 @@ status: JobStatusClean!
     """
-    emptyQueue(queue: String!): Queue
+    emptyQueue(queue: ID!): Queue
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobremove
     """
-    removeJob(queue: String!, id: ID!): Job
+    removeJob(queue: ID!, id: ID!): Job
     """
     calls https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobremove on every passed job
     """
-    removeJobs(queue: String!, jobs: [ID!]!): [Job]!
+    removeJobs(queue: ID!, jobs: [ID!]!): [Job]!
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobmovetocompleted
     """
-    moveJobToCompleted(queue: String!, id: ID!): Job
+    moveJobToCompleted(queue: ID!, id: ID!): Job
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobmovetofailed
     """
-    moveJobToFailed(queue: String!, id: ID!): Job
+    moveJobToFailed(queue: ID!, id: ID!): Job
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobdiscard
     """
-    discardJob(queue: String!, id: ID!): Job
+    discardJob(queue: ID!, id: ID!): Job
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobpromote
     """
-    promoteJob(queue: String!, id: ID!): Job
+    promoteJob(queue: ID!, id: ID!): Job
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobupdate
     """
-    updateJobData(queue: String!, id: ID!, data: JSON): Job
+    updateJobData(queue: ID!, id: ID!, data: JSON): Job
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobretry
     """
-    retryJob(queue: String!, id: ID!): Job
+    retryJob(queue: ID!, id: ID!): Job
     """
     calls https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#jobretry on every passed job
     """
-    retryJobs(queue: String!, jobs: [ID!]!): [Job]!
+    retryJobs(queue: ID!, jobs: [ID!]!): [Job]!
     """
     https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#joblog
     """
-    log(queue: String!, id: ID!, row: String!): Job
+    log(queue: ID!, id: ID!, row: String!): Job
     """
@@ -94,5 +94,5 @@ https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queueadd
     """
-    removeJobsByPattern(queue: String!, pattern: String!): Boolean
+    removeJobsByPattern(queue: ID!, pattern: String!): Boolean
 
-    clearMetrics(queue: String!): Boolean
+    clearMetrics(queue: ID!): Boolean
     clearAllMetrics: Boolean
@@ -99,0 +99,0 @@ }

dist/gql/type-defs/queue.js

@@ -15,2 +15,3 @@ "use strict";
   type Queue {
+    id: String!
     name: String!
@@ -17,0 +18,0 @@ keyPrefix: String

dist/gql/type-defs/root-query.js

@@ -16,6 +16,6 @@ "use strict";
     queues: [Queue!]
-    queue(name: String!): Queue
-    metrics(queue: String!, start: Int = 0, end: Int = -1): [QueueMetrics!]
+    queue(id: ID!): Queue
+    metrics(queue: ID!, start: Int = 0, end: Int = -1): [QueueMetrics!]
     jobs(
-      queue: String!
+      queue: ID!
       offset: Int
@@ -29,3 +29,3 @@ limit: Int
     ): [Job!]!
-    job(queue: String!, id: ID!): Job
+    job(queue: ID!, id: ID!): Job
     redisInfo: RedisInfo
@@ -32,0 +32,0 @@ }

dist/index.d.ts

@@ -6,2 +6,3 @@ import type { ApolloServerBase, Config as ApolloConfig } from 'apollo-server-core';
     abstract init(...args: any): Promise<any>;
+    private queues;
     private ui;
@@ -8,0 +9,0 @@ private metricsCollector?;

dist/index.js

@@ -19,2 +19,3 @@ "use strict";
 const metrics_collector_1 = require("./metrics-collector");
+const queue_1 = require("./queue");
 class BullMonitor {
@@ -40,4 +41,5 @@ constructor(config) {
         this.ui = new ui_1.UI();
+        this.queues = this.config.queues.map(queue_1.patchBullQueue);
         if (this.config.metrics) {
-            this.metricsCollector = new metrics_collector_1.MetricsCollector(this.config.queues, this.config.metrics);
+            this.metricsCollector = new metrics_collector_1.MetricsCollector(this.queues, this.config.metrics);
             this.metricsCollector.startCollecting();
@@ -54,3 +56,3 @@ }
             dataSources: () => ({
-                bull: new data_sources_1.BullDataSource(this.config.queues, {
+                bull: new data_sources_1.BullDataSource(this.queues, {
                     textSearchScanCount: this.config.textSearchScanCount,
@@ -57,0 +59,0 @@ }),

dist/metrics-collector.d.ts

@@ -1,3 +0,4 @@
-import type { Queue, JobCounts } from 'bull';
+import type { JobCounts } from 'bull';
 import { MetricsConfig } from './typings/config';
+import { BullMonitorQueue } from './queue';
 declare type TMetrics = {
@@ -10,3 +11,3 @@ queue: string;
     private _config;
-    constructor(queues: Queue[], _config: Required<MetricsConfig>);
+    constructor(queues: BullMonitorQueue[], _config: Required<MetricsConfig>);
     startCollecting(): void;
@@ -13,0 +14,0 @@ stopCollecting(): void;

dist/metrics-collector.js

@@ -48,3 +48,3 @@ "use strict";
             this._queues.forEach(queue => {
-                pipeline.del(this._buildPersistKey(queue.name));
+                pipeline.del(this._buildPersistKey(queue.id));
             });
@@ -66,3 +66,3 @@ yield pipeline.exec();
                     timestamp,
-                    queue: queue.name,
+                    queue: queue.id,
                     counts: yield queue.getJobCounts(),
@@ -69,0 +69,0 @@ });

dist/typings/config.d.ts

@@ -1,2 +0,2 @@
-import type { Queue } from 'bull';
+import { Queue } from 'bull';
 import { SimpleIntervalSchedule } from 'toad-scheduler';
@@ -3,0 +3,0 @@ export declare type MetricsConfig = {

dist/typings/gql.d.ts

@@ -121,12 +121,12 @@ export declare type Maybe<T> = T | null;
 export declare type MutationPauseQueueArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
 };
 export declare type MutationResumeQueueArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
 };
 export declare type MutationCloseQueueArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
 };
 export declare type MutationCleanQueueArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     grace?: Maybe<Scalars['Int']>;
@@ -137,30 +137,30 @@ status: JobStatusClean;
 export declare type MutationEmptyQueueArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
 };
 export declare type MutationRemoveJobArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationRemoveJobsArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     jobs: Array<Scalars['ID']>;
 };
 export declare type MutationMoveJobToCompletedArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationMoveJobToFailedArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationDiscardJobArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationPromoteJobArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationUpdateJobDataArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
@@ -170,11 +170,11 @@ data?: Maybe<Scalars['JSON']>;
 export declare type MutationRetryJobArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type MutationRetryJobsArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     jobs: Array<Scalars['ID']>;
 };
 export declare type MutationLogArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
@@ -187,7 +187,7 @@ row: Scalars['String'];
 export declare type MutationRemoveJobsByPatternArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     pattern: Scalars['String'];
 };
 export declare type MutationClearMetricsArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
 };
@@ -207,6 +207,6 @@ export declare enum OrderEnum {
 export declare type QueryQueueArgs = {
-    name: Scalars['String'];
+    id: Scalars['ID'];
 };
 export declare type QueryMetricsArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     start?: Maybe<Scalars['Int']>;
@@ -216,3 +216,3 @@ end?: Maybe<Scalars['Int']>;
 export declare type QueryJobsArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     offset?: Maybe<Scalars['Int']>;
@@ -227,6 +227,7 @@ limit?: Maybe<Scalars['Int']>;
 export declare type QueryJobArgs = {
-    queue: Scalars['String'];
+    queue: Scalars['ID'];
     id: Scalars['ID'];
 };
 export declare type Queue = {
+    id: Scalars['String'];
     name: Scalars['String'];
@@ -233,0 +234,0 @@ keyPrefix?: Maybe<Scalars['String']>;

package.json

 {
   "name": "@bull-monitor/root",
-  "version": "0.31.0",
+  "version": "1.0.0",
   "repository": {
@@ -38,5 +38,6 @@ "type": "git",
     "apollo-server-core": "^2.23.0",
+    "bull": "^3.27.0",
     "typescript": "^4.2.4"
   },
-  "gitHead": "56060c20da8134cce74efaf278dd63b81cdcab4f"
+  "gitHead": "87ba71e3360979a3cdfa19b33205ca450c8cec4c"
 }

Fixed alerts

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

114545

increased by1.17%

Number of package files

88

increased by3.53%

Lines of code

1941

increased by1.09%

Number of low quality alerts

1

decreased by-50%

Worsened metrics

Dev dependency count

9

increased by12.5%

No dependency changes