@nestjs/bull - npm Package Compare versions

Comparing version 11.0.2 to 11.0.3

dist/bull.module.d.ts

 import { DynamicModule } from '@nestjs/common';
 import { SharedBullAsyncConfiguration } from './interfaces';
 import { BullModuleAsyncOptions, BullModuleOptions, BullRootModuleOptions } from './interfaces/bull-module-options.interface';
+/**
+ * @publicApi
+ */
 export declare class BullModule {
@@ -5,0 +8,0 @@ private static coreModuleDefinition;

dist/bull.module.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"bull.module.d.ts","sourceRoot":"","sources":["../lib/bull.module.ts"],"names":[],"mappings":"AAIA,OAAO,EAAE,aAAa,EAA0B,MAAM,gBAAgB,CAAC;AAQvE,OAAO,EACL,4BAA4B,EAE7B,MAAM,cAAc,CAAC;AACtB,OAAO,EACL,sBAAsB,EACtB,iBAAiB,EAEjB,qBAAqB,EACtB,MAAM,4CAA4C,CAAC;AAOpD,qBACa,UAAU;IACrB,OAAO,CAAC,MAAM,CAAC,oBAAoB,CAKjC;IAEF;;;;OAIG;IACH,MAAM,CAAC,OAAO,CAAC,UAAU,EAAE,qBAAqB,GAAG,aAAa;IAChE;;;;;OAKG;IACH,MAAM,CAAC,OAAO,CACZ,SAAS,EAAE,MAAM,EACjB,UAAU,EAAE,qBAAqB,GAChC,aAAa;IA8BhB;;;;OAIG;IACH,MAAM,CAAC,YAAY,CACjB,eAAe,EAAE,4BAA4B,GAC5C,aAAa;IAChB;;;;;OAKG;IACH,MAAM,CAAC,YAAY,CACjB,SAAS,EAAE,MAAM,EACjB,eAAe,EAAE,4BAA4B,GAC5C,aAAa;IAkChB,MAAM,CAAC,aAAa,CAAC,GAAG,OAAO,EAAE,iBAAiB,EAAE,GAAG,aAAa;IAWpE,MAAM,CAAC,kBAAkB,CACvB,GAAG,OAAO,EAAE,sBAAsB,EAAE,GACnC,aAAa;IAwBhB,OAAO,CAAC,MAAM,CAAC,oBAAoB;IA6BnC,OAAO,CAAC,MAAM,CAAC,0BAA0B;IAsCzC,OAAO,CAAC,MAAM,CAAC,uCAAuC;IAiBtD,OAAO,CAAC,MAAM,CAAC,sCAAsC;IAqBrD,OAAO,CAAC,MAAM,CAAC,cAAc;CAU9B"}
+{"version":3,"file":"bull.module.d.ts","sourceRoot":"","sources":["../lib/bull.module.ts"],"names":[],"mappings":"AAIA,OAAO,EAAE,aAAa,EAA0B,MAAM,gBAAgB,CAAC;AAQvE,OAAO,EACL,4BAA4B,EAE7B,MAAM,cAAc,CAAC;AACtB,OAAO,EACL,sBAAsB,EACtB,iBAAiB,EAEjB,qBAAqB,EACtB,MAAM,4CAA4C,CAAC;AAOpD;;GAEG;AACH,qBACa,UAAU;IACrB,OAAO,CAAC,MAAM,CAAC,oBAAoB,CAKjC;IAEF;;;;OAIG;IACH,MAAM,CAAC,OAAO,CAAC,UAAU,EAAE,qBAAqB,GAAG,aAAa;IAChE;;;;;OAKG;IACH,MAAM,CAAC,OAAO,CACZ,SAAS,EAAE,MAAM,EACjB,UAAU,EAAE,qBAAqB,GAChC,aAAa;IA8BhB;;;;OAIG;IACH,MAAM,CAAC,YAAY,CACjB,eAAe,EAAE,4BAA4B,GAC5C,aAAa;IAChB;;;;;OAKG;IACH,MAAM,CAAC,YAAY,CACjB,SAAS,EAAE,MAAM,EACjB,eAAe,EAAE,4BAA4B,GAC5C,aAAa;IAkChB,MAAM,CAAC,aAAa,CAAC,GAAG,OAAO,EAAE,iBAAiB,EAAE,GAAG,aAAa;IAWpE,MAAM,CAAC,kBAAkB,CACvB,GAAG,OAAO,EAAE,sBAAsB,EAAE,GACnC,aAAa;IAwBhB,OAAO,CAAC,MAAM,CAAC,oBAAoB;IA6BnC,OAAO,CAAC,MAAM,CAAC,0BAA0B;IAsCzC,OAAO,CAAC,MAAM,CAAC,uCAAuC;IAiBtD,OAAO,CAAC,MAAM,CAAC,sCAAsC;IAqBrD,OAAO,CAAC,MAAM,CAAC,cAAc;CAU9B"}

dist/bull.module.js

@@ -13,2 +13,5 @@ "use strict";
 const utils_1 = require("./utils");
+/**
+ * @publicApi
+ */
 let BullModule = BullModule_1 = class BullModule {
@@ -15,0 +18,0 @@ /**

dist/decorators/inject-queue.decorator.d.ts

@@ -5,4 +5,6 @@ import { Inject } from '@nestjs/common';
  * @param name queue name
+ *
+ * @publicApi
  */
 export declare const InjectQueue: (name?: string) => ReturnType<typeof Inject>;
 //# sourceMappingURL=inject-queue.decorator.d.ts.map

dist/decorators/inject-queue.decorator.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"inject-queue.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/inject-queue.decorator.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAC;AAExC;;;GAGG;AACH,eAAO,MAAM,WAAW,UAAW,MAAM,KAAG,UAAU,CAAC,OAAO,MAAM,CACvC,CAAC"}
+{"version":3,"file":"inject-queue.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/inject-queue.decorator.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,MAAM,EAAE,MAAM,gBAAgB,CAAC;AAExC;;;;;GAKG;AACH,eAAO,MAAM,WAAW,UAAW,MAAM,KAAG,UAAU,CAAC,OAAO,MAAM,CACvC,CAAC"}

dist/decorators/inject-queue.decorator.js

@@ -9,4 +9,6 @@ "use strict";
  * @param name queue name
+ *
+ * @publicApi
  */
 const InjectQueue = (name) => (0, common_1.Inject)((0, bull_shared_1.getQueueToken)(name));
 exports.InjectQueue = InjectQueue;

dist/decorators/process.decorator.d.ts

@@ -0,1 +1,4 @@
+/**
+ * @publicApi
+ */
 export interface ProcessOptions {
@@ -5,2 +8,5 @@ name?: string;
 }
+/**
+ * @publicApi
+ */
 export declare function Process(): MethodDecorator;
@@ -7,0 +13,0 @@ export declare function Process(name: string): MethodDecorator;

dist/decorators/process.decorator.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"process.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/process.decorator.ts"],"names":[],"mappings":"AAIA,MAAM,WAAW,cAAc;IAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,wBAAgB,OAAO,IAAI,eAAe,CAAC;AAC3C,wBAAgB,OAAO,CAAC,IAAI,EAAE,MAAM,GAAG,eAAe,CAAC;AACvD,wBAAgB,OAAO,CAAC,OAAO,EAAE,cAAc,GAAG,eAAe,CAAC"}
+{"version":3,"file":"process.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/process.decorator.ts"],"names":[],"mappings":"AAIA;;GAEG;AACH,MAAM,WAAW,cAAc;IAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED;;GAEG;AACH,wBAAgB,OAAO,IAAI,eAAe,CAAC;AAC3C,wBAAgB,OAAO,CAAC,IAAI,EAAE,MAAM,GAAG,eAAe,CAAC;AACvD,wBAAgB,OAAO,CAAC,OAAO,EAAE,cAAc,GAAG,eAAe,CAAC"}

dist/decorators/processor.decorator.d.ts

 import { Scope } from '@nestjs/common';
+/**
+ * @publicApi
+ */
 export interface ProcessorOptions {
@@ -3,0 +6,0 @@ /**

dist/decorators/processor.decorator.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"processor.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/processor.decorator.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,KAAK,EAAe,MAAM,gBAAgB,CAAC;AAIpD,MAAM,WAAW,gBAAgB;IAC/B;;OAEG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IACd;;OAEG;IACH,KAAK,CAAC,EAAE,KAAK,CAAC;CACf;AAED;;GAEG;AACH,wBAAgB,SAAS,IAAI,cAAc,CAAC;AAC5C;;;GAGG;AACH,wBAAgB,SAAS,CAAC,SAAS,EAAE,MAAM,GAAG,cAAc,CAAC;AAC7D;;;GAGG;AACH,wBAAgB,SAAS,CAAC,gBAAgB,EAAE,gBAAgB,GAAG,cAAc,CAAC"}
+{"version":3,"file":"processor.decorator.d.ts","sourceRoot":"","sources":["../../lib/decorators/processor.decorator.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,KAAK,EAAe,MAAM,gBAAgB,CAAC;AAIpD;;GAEG;AACH,MAAM,WAAW,gBAAgB;IAC/B;;OAEG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IACd;;OAEG;IACH,KAAK,CAAC,EAAE,KAAK,CAAC;CACf;AAED;;GAEG;AACH,wBAAgB,SAAS,IAAI,cAAc,CAAC;AAC5C;;;GAGG;AACH,wBAAgB,SAAS,CAAC,SAAS,EAAE,MAAM,GAAG,cAAc,CAAC;AAC7D;;;GAGG;AACH,wBAAgB,SAAS,CAAC,gBAAgB,EAAE,gBAAgB,GAAG,cAAc,CAAC"}

dist/decorators/queue-hooks.decorators.d.ts

 import { BullQueueEvent, BullQueueEventOptions, QueueEventDecoratorOptions } from '../bull.types';
+/**
+ * @publicApi
+ */
 export declare const OnQueueEvent: (eventNameOrOptions: BullQueueEvent | BullQueueEventOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueError: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueWaiting: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueActive: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueStalled: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueProgress: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueCompleted: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueFailed: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueuePaused: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueResumed: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueCleaned: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueDrained: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnQueueRemoved: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueError: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueWaiting: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueActive: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueStalled: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueProgress: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueCompleted: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueFailed: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueuePaused: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueResumed: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueCleaned: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueDrained: (options?: QueueEventDecoratorOptions) => MethodDecorator;
+/**
+ * @publicApi
+ */
 export declare const OnGlobalQueueRemoved: (options?: QueueEventDecoratorOptions) => MethodDecorator;
 //# sourceMappingURL=queue-hooks.decorators.d.ts.map

dist/decorators/queue-hooks.decorators.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"queue-hooks.decorators.d.ts","sourceRoot":"","sources":["../../lib/decorators/queue-hooks.decorators.ts"],"names":[],"mappings":"AAEA,OAAO,EACL,cAAc,EACd,qBAAqB,EACrB,0BAA0B,EAC3B,MAAM,eAAe,CAAC;AAGvB,eAAO,MAAM,YAAY,uBACH,cAAc,GAAG,qBAAqB,KACzD,eAMA,CAAC;AAEJ,eAAO,MAAM,YAAY,aAAc,0BAA0B,oBACD,CAAC;AAEjE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,eAAe,aAAc,0BAA0B,oBACD,CAAC;AAEpE,eAAO,MAAM,gBAAgB,aAAc,0BAA0B,oBACD,CAAC;AAErE,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE,eAAO,MAAM,kBAAkB,aAAc,0BAA0B,oBACD,CAAC;AAEvE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE,eAAO,MAAM,qBAAqB,aAAc,0BAA0B,oBACD,CAAC;AAE1E,eAAO,MAAM,sBAAsB,aAAc,0BAA0B,oBACD,CAAC;AAE3E,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC"}
+{"version":3,"file":"queue-hooks.decorators.d.ts","sourceRoot":"","sources":["../../lib/decorators/queue-hooks.decorators.ts"],"names":[],"mappings":"AAEA,OAAO,EACL,cAAc,EACd,qBAAqB,EACrB,0BAA0B,EAC3B,MAAM,eAAe,CAAC;AAGvB;;GAEG;AACH,eAAO,MAAM,YAAY,uBACH,cAAc,GAAG,qBAAqB,KACzD,eAMA,CAAC;AAEJ;;GAEG;AACH,eAAO,MAAM,YAAY,aAAc,0BAA0B,oBACD,CAAC;AAEjE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,eAAe,aAAc,0BAA0B,oBACD,CAAC;AAEpE;;GAEG;AACH,eAAO,MAAM,gBAAgB,aAAc,0BAA0B,oBACD,CAAC;AAErE;;GAEG;AACH,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE;;GAEG;AACH,eAAO,MAAM,aAAa,aAAc,0BAA0B,oBACD,CAAC;AAElE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,cAAc,aAAc,0BAA0B,oBACD,CAAC;AAEnE;;GAEG;AACH,eAAO,MAAM,kBAAkB,aAAc,0BAA0B,oBACD,CAAC;AAEvE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE;;GAEG;AACH,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE;;GAEG;AACH,eAAO,MAAM,qBAAqB,aAAc,0BAA0B,oBACD,CAAC;AAE1E;;GAEG;AACH,eAAO,MAAM,sBAAsB,aAAc,0BAA0B,oBACD,CAAC;AAE3E;;GAEG;AACH,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE;;GAEG;AACH,eAAO,MAAM,mBAAmB,aAAc,0BAA0B,oBACD,CAAC;AAExE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC;AAEzE;;GAEG;AACH,eAAO,MAAM,oBAAoB,aAAc,0BAA0B,oBACD,CAAC"}

dist/decorators/queue-hooks.decorators.js

@@ -7,2 +7,5 @@ "use strict";
 const enums_1 = require("../enums");
+/**
+ * @publicApi
+ */
 const OnQueueEvent = (eventNameOrOptions) => (0, common_1.SetMetadata)(bull_constants_1.BULL_MODULE_ON_QUEUE_EVENT, typeof eventNameOrOptions === 'string'
@@ -12,49 +15,121 @@ ? { eventName: eventNameOrOptions }
 exports.OnQueueEvent = OnQueueEvent;
+/**
+ * @publicApi
+ */
 const OnQueueError = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.ERROR });
 exports.OnQueueError = OnQueueError;
+/**
+ * @publicApi
+ */
 const OnQueueWaiting = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.WAITING });
 exports.OnQueueWaiting = OnQueueWaiting;
+/**
+ * @publicApi
+ */
 const OnQueueActive = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.ACTIVE });
 exports.OnQueueActive = OnQueueActive;
+/**
+ * @publicApi
+ */
 const OnQueueStalled = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.STALLED });
 exports.OnQueueStalled = OnQueueStalled;
+/**
+ * @publicApi
+ */
 const OnQueueProgress = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.PROGRESS });
 exports.OnQueueProgress = OnQueueProgress;
+/**
+ * @publicApi
+ */
 const OnQueueCompleted = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.COMPLETED });
 exports.OnQueueCompleted = OnQueueCompleted;
+/**
+ * @publicApi
+ */
 const OnQueueFailed = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.FAILED });
 exports.OnQueueFailed = OnQueueFailed;
+/**
+ * @publicApi
+ */
 const OnQueuePaused = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.PAUSED });
 exports.OnQueuePaused = OnQueuePaused;
+/**
+ * @publicApi
+ */
 const OnQueueResumed = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.RESUMED });
 exports.OnQueueResumed = OnQueueResumed;
+/**
+ * @publicApi
+ */
 const OnQueueCleaned = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.CLEANED });
 exports.OnQueueCleaned = OnQueueCleaned;
+/**
+ * @publicApi
+ */
 const OnQueueDrained = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.DRAINED });
 exports.OnQueueDrained = OnQueueDrained;
+/**
+ * @publicApi
+ */
 const OnQueueRemoved = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueEvents.REMOVED });
 exports.OnQueueRemoved = OnQueueRemoved;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueError = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.ERROR });
 exports.OnGlobalQueueError = OnGlobalQueueError;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueWaiting = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.WAITING });
 exports.OnGlobalQueueWaiting = OnGlobalQueueWaiting;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueActive = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.ACTIVE });
 exports.OnGlobalQueueActive = OnGlobalQueueActive;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueStalled = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.STALLED });
 exports.OnGlobalQueueStalled = OnGlobalQueueStalled;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueProgress = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.PROGRESS });
 exports.OnGlobalQueueProgress = OnGlobalQueueProgress;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueCompleted = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.COMPLETED });
 exports.OnGlobalQueueCompleted = OnGlobalQueueCompleted;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueFailed = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.FAILED });
 exports.OnGlobalQueueFailed = OnGlobalQueueFailed;
+/**
+ * @publicApi
+ */
 const OnGlobalQueuePaused = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.PAUSED });
 exports.OnGlobalQueuePaused = OnGlobalQueuePaused;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueResumed = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.RESUMED });
 exports.OnGlobalQueueResumed = OnGlobalQueueResumed;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueCleaned = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.CLEANED });
 exports.OnGlobalQueueCleaned = OnGlobalQueueCleaned;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueDrained = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.DRAINED });
 exports.OnGlobalQueueDrained = OnGlobalQueueDrained;
+/**
+ * @publicApi
+ */
 const OnGlobalQueueRemoved = (options) => (0, exports.OnQueueEvent)({ ...options, eventName: enums_1.BullQueueGlobalEvents.REMOVED });
 exports.OnGlobalQueueRemoved = OnGlobalQueueRemoved;

dist/interfaces/bull-module-options.interface.d.ts

 import { FactoryProvider, ModuleMetadata, Provider, Type } from '@nestjs/common';
 import * as Bull from 'bull';
 import { BullQueueProcessor } from '../bull.types';
+/**
+ * @publicApi
+ */
 export interface BullRootModuleOptions extends Bull.QueueOptions {
@@ -10,2 +13,5 @@ /**
 }
+/**
+ * @publicApi
+ */
 export interface BullModuleOptions extends BullRootModuleOptions {
@@ -29,5 +35,11 @@ /**
 }
+/**
+ * @publicApi
+ */
 export interface BullOptionsFactory {
     createBullOptions(): Promise<BullModuleOptions> | BullModuleOptions;
 }
+/**
+ * @publicApi
+ */
 export interface BullModuleAsyncOptions extends Pick<ModuleMetadata, 'imports'> {
@@ -34,0 +46,0 @@ /**

dist/interfaces/bull-module-options.interface.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"bull-module-options.interface.d.ts","sourceRoot":"","sources":["../../lib/interfaces/bull-module-options.interface.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,eAAe,EACf,cAAc,EACd,QAAQ,EACR,IAAI,EACL,MAAM,gBAAgB,CAAC;AACxB,OAAO,KAAK,IAAI,MAAM,MAAM,CAAC;AAC7B,OAAO,EAAE,kBAAkB,EAAE,MAAM,eAAe,CAAC;AAEnD,MAAM,WAAW,qBAAsB,SAAQ,IAAI,CAAC,YAAY;IAC9D;;OAEG;IACH,GAAG,CAAC,EAAE,MAAM,CAAC;CACd;AAED,MAAM,WAAW,iBAAkB,SAAQ,qBAAqB;IAC9D;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IAEd;;;;OAIG;IACH,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,UAAU,CAAC,EAAE,kBAAkB,EAAE,CAAC;CACnC;AAED,MAAM,WAAW,kBAAkB;IACjC,iBAAiB,IAAI,OAAO,CAAC,iBAAiB,CAAC,GAAG,iBAAiB,CAAC;CACrE;AAED,MAAM,WAAW,sBACf,SAAQ,IAAI,CAAC,cAAc,EAAE,SAAS,CAAC;IACvC;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IAEd;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,WAAW,CAAC,EAAE,IAAI,CAAC,kBAAkB,CAAC,CAAC;IAEvC;;OAEG;IACH,QAAQ,CAAC,EAAE,IAAI,CAAC,kBAAkB,CAAC,CAAC;IAEpC;;OAEG;IACH,UAAU,CAAC,EAAE,CACX,GAAG,IAAI,EAAE,GAAG,EAAE,KACX,OAAO,CAAC,iBAAiB,CAAC,GAAG,iBAAiB,CAAC;IAEpD;;OAEG;IACH,MAAM,CAAC,EAAE,eAAe,CAAC,QAAQ,CAAC,CAAC;IAEnC;;OAEG;IACH,cAAc,CAAC,EAAE,QAAQ,EAAE,CAAC;CAC7B"}
+{"version":3,"file":"bull-module-options.interface.d.ts","sourceRoot":"","sources":["../../lib/interfaces/bull-module-options.interface.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,eAAe,EACf,cAAc,EACd,QAAQ,EACR,IAAI,EACL,MAAM,gBAAgB,CAAC;AACxB,OAAO,KAAK,IAAI,MAAM,MAAM,CAAC;AAC7B,OAAO,EAAE,kBAAkB,EAAE,MAAM,eAAe,CAAC;AAEnD;;GAEG;AACH,MAAM,WAAW,qBAAsB,SAAQ,IAAI,CAAC,YAAY;IAC9D;;OAEG;IACH,GAAG,CAAC,EAAE,MAAM,CAAC;CACd;AAED;;GAEG;AACH,MAAM,WAAW,iBAAkB,SAAQ,qBAAqB;IAC9D;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IAEd;;;;OAIG;IACH,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,UAAU,CAAC,EAAE,kBAAkB,EAAE,CAAC;CACnC;AAED;;GAEG;AACH,MAAM,WAAW,kBAAkB;IACjC,iBAAiB,IAAI,OAAO,CAAC,iBAAiB,CAAC,GAAG,iBAAiB,CAAC;CACrE;AAED;;GAEG;AACH,MAAM,WAAW,sBACf,SAAQ,IAAI,CAAC,cAAc,EAAE,SAAS,CAAC;IACvC;;;;OAIG;IACH,IAAI,CAAC,EAAE,MAAM,CAAC;IAEd;;OAEG;IACH,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,WAAW,CAAC,EAAE,IAAI,CAAC,kBAAkB,CAAC,CAAC;IAEvC;;OAEG;IACH,QAAQ,CAAC,EAAE,IAAI,CAAC,kBAAkB,CAAC,CAAC;IAEpC;;OAEG;IACH,UAAU,CAAC,EAAE,CACX,GAAG,IAAI,EAAE,GAAG,EAAE,KACX,OAAO,CAAC,iBAAiB,CAAC,GAAG,iBAAiB,CAAC;IAEpD;;OAEG;IACH,MAAM,CAAC,EAAE,eAAe,CAAC,QAAQ,CAAC,CAAC;IAEnC;;OAEG;IACH,cAAc,CAAC,EAAE,QAAQ,EAAE,CAAC;CAC7B"}

dist/interfaces/bull.interfaces.d.ts

 import { BullQueueProcessorCallback, BullQueueSeparateProcessor } from '../bull.types';
+/**
+ * @publicApi
+ */
 export interface BullQueueAdvancedProcessor {
@@ -7,2 +10,5 @@ concurrency?: number;
 }
+/**
+ * @publicApi
+ */
 export interface BullQueueAdvancedSeparateProcessor {
@@ -9,0 +15,0 @@ concurrency?: number;

dist/interfaces/bull.interfaces.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"bull.interfaces.d.ts","sourceRoot":"","sources":["../../lib/interfaces/bull.interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,0BAA0B,EAC1B,0BAA0B,EAC3B,MAAM,eAAe,CAAC;AAEvB,MAAM,WAAW,0BAA0B;IACzC,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,QAAQ,EAAE,0BAA0B,CAAC;CACtC;AAED,MAAM,WAAW,kCAAkC;IACjD,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,IAAI,EAAE,0BAA0B,CAAC;CAClC"}
+{"version":3,"file":"bull.interfaces.d.ts","sourceRoot":"","sources":["../../lib/interfaces/bull.interfaces.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,0BAA0B,EAC1B,0BAA0B,EAC3B,MAAM,eAAe,CAAC;AAEvB;;GAEG;AACH,MAAM,WAAW,0BAA0B;IACzC,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,QAAQ,EAAE,0BAA0B,CAAC;CACtC;AAED;;GAEG;AACH,MAAM,WAAW,kCAAkC;IACjD,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,IAAI,CAAC,EAAE,MAAM,CAAC;IACd,IAAI,EAAE,0BAA0B,CAAC;CAClC"}

dist/interfaces/shared-bull-config.interface.d.ts

 import { FactoryProvider, ModuleMetadata, Provider, Type } from '@nestjs/common';
 import { BullRootModuleOptions } from './bull-module-options.interface';
+/**
+ * @publicApi
+ */
 export interface SharedBullConfigurationFactory {
     createSharedConfiguration(): Promise<BullRootModuleOptions> | BullRootModuleOptions;
 }
+/**
+ * @publicApi
+ */
 export interface SharedBullAsyncConfiguration extends Pick<ModuleMetadata, 'imports'> {
@@ -7,0 +13,0 @@ /**

dist/interfaces/shared-bull-config.interface.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"shared-bull-config.interface.d.ts","sourceRoot":"","sources":["../../lib/interfaces/shared-bull-config.interface.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,eAAe,EACf,cAAc,EACd,QAAQ,EACR,IAAI,EACL,MAAM,gBAAgB,CAAC;AACxB,OAAO,EAAE,qBAAqB,EAAE,MAAM,iCAAiC,CAAC;AAExE,MAAM,WAAW,8BAA8B;IAC7C,yBAAyB,IACrB,OAAO,CAAC,qBAAqB,CAAC,GAC9B,qBAAqB,CAAC;CAC3B;AAED,MAAM,WAAW,4BACf,SAAQ,IAAI,CAAC,cAAc,EAAE,SAAS,CAAC;IACvC;;OAEG;IACH,WAAW,CAAC,EAAE,IAAI,CAAC,8BAA8B,CAAC,CAAC;IAEnD;;OAEG;IACH,QAAQ,CAAC,EAAE,IAAI,CAAC,8BAA8B,CAAC,CAAC;IAEhD;;OAEG;IACH,UAAU,CAAC,EAAE,CACX,GAAG,IAAI,EAAE,GAAG,EAAE,KACX,OAAO,CAAC,qBAAqB,CAAC,GAAG,qBAAqB,CAAC;IAE5D;;OAEG;IACH,MAAM,CAAC,EAAE,eAAe,CAAC,QAAQ,CAAC,CAAC;IAEnC;;OAEG;IACH,cAAc,CAAC,EAAE,QAAQ,EAAE,CAAC;CAC7B"}
+{"version":3,"file":"shared-bull-config.interface.d.ts","sourceRoot":"","sources":["../../lib/interfaces/shared-bull-config.interface.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,eAAe,EACf,cAAc,EACd,QAAQ,EACR,IAAI,EACL,MAAM,gBAAgB,CAAC;AACxB,OAAO,EAAE,qBAAqB,EAAE,MAAM,iCAAiC,CAAC;AAExE;;GAEG;AACH,MAAM,WAAW,8BAA8B;IAC7C,yBAAyB,IACrB,OAAO,CAAC,qBAAqB,CAAC,GAC9B,qBAAqB,CAAC;CAC3B;AAED;;GAEG;AACH,MAAM,WAAW,4BACf,SAAQ,IAAI,CAAC,cAAc,EAAE,SAAS,CAAC;IACvC;;OAEG;IACH,WAAW,CAAC,EAAE,IAAI,CAAC,8BAA8B,CAAC,CAAC;IAEnD;;OAEG;IACH,QAAQ,CAAC,EAAE,IAAI,CAAC,8BAA8B,CAAC,CAAC;IAEhD;;OAEG;IACH,UAAU,CAAC,EAAE,CACX,GAAG,IAAI,EAAE,GAAG,EAAE,KACX,OAAO,CAAC,qBAAqB,CAAC,GAAG,qBAAqB,CAAC;IAE5D;;OAEG;IACH,MAAM,CAAC,EAAE,eAAe,CAAC,QAAQ,CAAC,CAAC;IAEnC;;OAEG;IACH,cAAc,CAAC,EAAE,QAAQ,EAAE,CAAC;CAC7B"}

package.json

 {
   "name": "@nestjs/bull",
-  "version": "11.0.2",
+  "version": "11.0.3",
   "description": "Nest - modern, fast, powerful node.js web framework (@bull)",
@@ -25,17 +25,17 @@ "homepage": "https://github.com/nestjs/bull",
   "dependencies": {
-    "@nestjs/bull-shared": "^11.0.2",
+    "@nestjs/bull-shared": "^11.0.3",
     "tslib": "2.8.1"
   },
   "devDependencies": {
-    "@nestjs/common": "11.0.7",
-    "@nestjs/core": "11.0.7",
-    "@nestjs/platform-express": "11.0.7",
-    "@nestjs/testing": "11.0.7",
+    "@nestjs/common": "11.1.5",
+    "@nestjs/core": "11.1.5",
+    "@nestjs/platform-express": "11.1.5",
+    "@nestjs/testing": "11.1.5",
     "@types/bull": "4.10.4",
-    "@types/jest": "29.5.14",
-    "@types/node": "22.13.0",
+    "@types/jest": "30.0.0",
+    "@types/node": "22.16.5",
     "@types/reflect-metadata": "0.1.0",
     "bull": "4.16.5",
     "reflect-metadata": "0.2.2",
-    "rxjs": "7.8.1"
+    "rxjs": "7.8.2"
   },
@@ -50,3 +50,3 @@ "peerDependencies": {
   },
-  "gitHead": "ca7c3911d2bf6ea0adca0391f22b39252b68fd0b"
+  "gitHead": "bce1067da5f49cf431e220f1599cb7287f77a919"
 }

No alert changes

Improved metrics

Total package byte prevSize

76524

2.45%

Lines of code

1269

17.94%

Dependency changes

• Updated

  @nestjs/bull-shared@^11.0.3