| 1 | "use strict";
|
| 2 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 3 | exports.BullQueueInject = exports.BullQueueEventGlobalRemoved = exports.BullQueueEventGlobalDrained = exports.BullQueueEventGlobalCleaned = exports.BullQueueEventGlobalResumed = exports.BullQueueEventGlobalPaused = exports.BullQueueEventGlobalFailed = exports.BullQueueEventGlobalCompleted = exports.BullQueueEventGlobalProgress = exports.BullQueueEventGlobalStalled = exports.BullQueueEventGlobalActive = exports.BullQueueEventGlobalWaiting = exports.BullQueueEventGlobalError = exports.BullQueueEventRemoved = exports.BullQueueEventDrained = exports.BullQueueEventCleaned = exports.BullQueueEventResumed = exports.BullQueueEventPaused = exports.BullQueueEventFailed = exports.BullQueueEventCompleted = exports.BullQueueEventProgress = exports.BullQueueEventStalled = exports.BullQueueEventActive = exports.BullQueueEventWaiting = exports.BullQueueEventError = exports.EventHandler = exports.BullQueueProcess = exports.BullQueue = void 0;
|
| 4 | const common_1 = require("@nestjs/common");
|
| 5 | const deepmerge = require("deepmerge");
|
| 6 | require("reflect-metadata");
|
| 7 | const bull_constants_1 = require("./bull.constants");
|
| 8 | const bull_utils_1 = require("./bull.utils");
|
| 9 | exports.BullQueue = (options) => {
|
| 10 | return (target) => {
|
| 11 | Reflect.defineMetadata(bull_constants_1.BULL_QUEUE_DECORATOR, deepmerge({ name: target.name }, options || {}), target);
|
| 12 | };
|
| 13 | };
|
| 14 | exports.BullQueueProcess = (options) => {
|
| 15 | return (target, propertyName) => {
|
| 16 | Reflect.defineMetadata(bull_constants_1.BULL_QUEUE_PROCESSOR_DECORATOR, options, target, propertyName);
|
| 17 | };
|
| 18 | };
|
| 19 | exports.EventHandler = (type, isGlobal) => {
|
| 20 | return (target, propertyName) => {
|
| 21 | const eventName = `${isGlobal ? "global:" : ""}${type}`;
|
| 22 | const options = deepmerge({ eventNames: [] }, Reflect.getMetadata(bull_constants_1.BULL_QUEUE_EVENT_DECORATOR, target, propertyName) || {});
|
| 23 | if (options.eventNames.indexOf(eventName) !== -1) {
|
| 24 | common_1.Logger.warn(`Not allowed multiple event on same function. ${eventName} on ${propertyName.toString()}`, bull_constants_1.BULL_MODULE, false);
|
| 25 | return;
|
| 26 | }
|
| 27 | options.eventNames.push(eventName);
|
| 28 | Reflect.defineMetadata(bull_constants_1.BULL_QUEUE_EVENT_DECORATOR, options, target, propertyName);
|
| 29 | };
|
| 30 | };
|
| 31 | exports.BullQueueEventError = () => exports.EventHandler("error", false);
|
| 32 | exports.BullQueueEventWaiting = () => exports.EventHandler("waiting", false);
|
| 33 | exports.BullQueueEventActive = () => exports.EventHandler("active", false);
|
| 34 | exports.BullQueueEventStalled = () => exports.EventHandler("stalled", false);
|
| 35 | exports.BullQueueEventProgress = () => exports.EventHandler("progress", false);
|
| 36 | exports.BullQueueEventCompleted = () => exports.EventHandler("completed", false);
|
| 37 | exports.BullQueueEventFailed = () => exports.EventHandler("failed", false);
|
| 38 | exports.BullQueueEventPaused = () => exports.EventHandler("paused", false);
|
| 39 | exports.BullQueueEventResumed = () => exports.EventHandler("resumed", false);
|
| 40 | exports.BullQueueEventCleaned = () => exports.EventHandler("cleaned", false);
|
| 41 | exports.BullQueueEventDrained = () => exports.EventHandler("drained", false);
|
| 42 | exports.BullQueueEventRemoved = () => exports.EventHandler("removed", false);
|
| 43 | exports.BullQueueEventGlobalError = () => exports.EventHandler("error", true);
|
| 44 | exports.BullQueueEventGlobalWaiting = () => exports.EventHandler("waiting", true);
|
| 45 | exports.BullQueueEventGlobalActive = () => exports.EventHandler("active", true);
|
| 46 | exports.BullQueueEventGlobalStalled = () => exports.EventHandler("stalled", true);
|
| 47 | exports.BullQueueEventGlobalProgress = () => exports.EventHandler("progress", true);
|
| 48 | exports.BullQueueEventGlobalCompleted = () => exports.EventHandler("completed", true);
|
| 49 | exports.BullQueueEventGlobalFailed = () => exports.EventHandler("failed", true);
|
| 50 | exports.BullQueueEventGlobalPaused = () => exports.EventHandler("paused", true);
|
| 51 | exports.BullQueueEventGlobalResumed = () => exports.EventHandler("resumed", true);
|
| 52 | exports.BullQueueEventGlobalCleaned = () => exports.EventHandler("cleaned", true);
|
| 53 | exports.BullQueueEventGlobalDrained = () => exports.EventHandler("drained", true);
|
| 54 | exports.BullQueueEventGlobalRemoved = () => exports.EventHandler("removed", true);
|
| 55 | exports.BullQueueInject = (name) => common_1.Inject(bull_utils_1.getBullQueueToken(name));
|