1 | "use strict";
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | exports.BullMetadataAccessor = void 0;
|
4 | const tslib_1 = require("tslib");
|
5 | const common_1 = require("@nestjs/common");
|
6 | const core_1 = require("@nestjs/core");
|
7 | const bull_constants_1 = require("./bull.constants");
|
8 | let BullMetadataAccessor = class BullMetadataAccessor {
|
9 | constructor(reflector) {
|
10 | this.reflector = reflector;
|
11 | }
|
12 | isQueueComponent(target) {
|
13 | if (!target) {
|
14 | return false;
|
15 | }
|
16 | return !!this.reflector.get(bull_constants_1.BULL_MODULE_QUEUE, target);
|
17 | }
|
18 | isProcessor(target) {
|
19 | if (!target) {
|
20 | return false;
|
21 | }
|
22 | return !!this.reflector.get(bull_constants_1.BULL_MODULE_QUEUE_PROCESS, target);
|
23 | }
|
24 | isListener(target) {
|
25 | if (!target) {
|
26 | return false;
|
27 | }
|
28 | return !!this.reflector.get(bull_constants_1.BULL_MODULE_ON_QUEUE_EVENT, target);
|
29 | }
|
30 | getQueueComponentMetadata(target) {
|
31 | return this.reflector.get(bull_constants_1.BULL_MODULE_QUEUE, target);
|
32 | }
|
33 | getProcessMetadata(target) {
|
34 | return this.reflector.get(bull_constants_1.BULL_MODULE_QUEUE_PROCESS, target);
|
35 | }
|
36 | getListenerMetadata(target) {
|
37 | return this.reflector.get(bull_constants_1.BULL_MODULE_ON_QUEUE_EVENT, target);
|
38 | }
|
39 | };
|
40 | BullMetadataAccessor = tslib_1.__decorate([
|
41 | (0, common_1.Injectable)(),
|
42 | tslib_1.__metadata("design:paramtypes", [core_1.Reflector])
|
43 | ], BullMetadataAccessor);
|
44 | exports.BullMetadataAccessor = BullMetadataAccessor;
|