🚀. Socket Launch Week Day 2:Introducing Manifest Alerts.Learn more
Sign In

@bull-board/api

Package Overview
Dependencies
Maintainers
1
Versions
237
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@bull-board/api - npm Package Compare versions

Comparing version
7.2.0
to
7.2.1
+1
-1
dist/handlers/addJob.js.map

@@ -1,1 +0,1 @@

{"version":3,"file":"addJob.js","sourceRoot":"","sources":["../../src/handlers/addJob.ts"],"names":[],"mappings":";;;AAEA,8CAAmD;AACnD,qCAAqC;AAErC,KAAK,UAAU,MAAM,CACnB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,GAAG,CAAC,IAAI,CAAC;IAEzC,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAEpD,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE;YACJ,GAAG,EAAE,IAAA,kBAAS,EAAC,GAAG,EAAE,KAAK,CAAC;YAC1B,MAAM,EAAE,GAAG,CAAC,QAAQ,EAAE;SACvB;KACF,CAAC;AACJ,CAAC;AAEY,QAAA,aAAa,GAAG,IAAA,qBAAa,EAAC,MAAM,CAAC,CAAC"}
{"version":3,"file":"addJob.js","sourceRoot":"","sources":["../../src/handlers/addJob.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AAEnD,qCAAqC;AAErC,KAAK,UAAU,MAAM,CACnB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,GAAG,CAAC,IAAI,CAAC;IAEzC,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAEpD,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE;YACJ,GAAG,EAAE,IAAA,kBAAS,EAAC,GAAG,EAAE,KAAK,CAAC;YAC1B,MAAM,EAAE,GAAG,CAAC,QAAQ,EAAE;SACvB;KACF,CAAC;AACJ,CAAC;AAEY,QAAA,aAAa,GAAG,IAAA,qBAAa,EAAC,MAAM,CAAC,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"cleanAll.js","sourceRoot":"","sources":["../../src/handlers/cleanAll.ts"],"names":[],"mappings":";;;AAKA,8CAAmD;AAEnD,KAAK,UAAU,QAAQ,CACrB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,WAAW,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAEnC,MAAM,aAAa,GAAG,IAAI,CAAC;IAE3B,MAAM,KAAK,CAAC,KAAK,CAAC,WAAkB,EAAE,aAAa,CAAC,CAAC;IAErD,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE;KACT,CAAC;AACJ,CAAC;AAEY,QAAA,eAAe,GAAG,IAAA,qBAAa,EAAC,QAAQ,CAAC,CAAC"}
{"version":3,"file":"cleanAll.js","sourceRoot":"","sources":["../../src/handlers/cleanAll.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AAGnD,KAAK,UAAU,QAAQ,CACrB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,WAAW,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAEnC,MAAM,aAAa,GAAG,IAAI,CAAC;IAE3B,MAAM,KAAK,CAAC,KAAK,CAAC,WAAkB,EAAE,aAAa,CAAC,CAAC;IAErD,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE;KACT,CAAC;AACJ,CAAC;AAEY,QAAA,eAAe,GAAG,IAAA,qBAAa,EAAC,QAAQ,CAAC,CAAC"}
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.jobHandler = void 0;
const job_1 = require("../providers/job");
const queue_1 = require("../providers/queue");
const job_1 = require("../providers/job");
const queues_1 = require("./queues");

@@ -7,0 +7,0 @@ async function getJobState(_req, job, queue) {

@@ -1,1 +0,1 @@

{"version":3,"file":"job.js","sourceRoot":"","sources":["../../src/handlers/job.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AACnD,0CAA+C;AAE/C,qCAAqC;AAErC,KAAK,UAAU,WAAW,CACxB,IAAsB,EACtB,GAAa,EACb,KAAkB;IAElB,MAAM,MAAM,GAAG,MAAM,GAAG,CAAC,QAAQ,EAAE,CAAC;IAEpC,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE;YACJ,GAAG,EAAE,IAAA,kBAAS,EAAC,GAAG,EAAE,KAAK,CAAC;YAC1B,MAAM;SACP;KACF,CAAC;AACJ,CAAC;AAEY,QAAA,UAAU,GAAG,IAAA,qBAAa,EAAC,IAAA,iBAAW,EAAC,WAAW,CAAC,EAAE;IAChE,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}
{"version":3,"file":"job.js","sourceRoot":"","sources":["../../src/handlers/job.ts"],"names":[],"mappings":";;;AACA,0CAA+C;AAC/C,8CAAmD;AAEnD,qCAAqC;AAErC,KAAK,UAAU,WAAW,CACxB,IAAsB,EACtB,GAAa,EACb,KAAkB;IAElB,MAAM,MAAM,GAAG,MAAM,GAAG,CAAC,QAAQ,EAAE,CAAC;IAEpC,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE;YACJ,GAAG,EAAE,IAAA,kBAAS,EAAC,GAAG,EAAE,KAAK,CAAC;YAC1B,MAAM;SACP;KACF,CAAC;AACJ,CAAC;AAEY,QAAA,UAAU,GAAG,IAAA,qBAAa,EAAC,IAAA,iBAAW,EAAC,WAAW,CAAC,EAAE;IAChE,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"jobLogs.js","sourceRoot":"","sources":["../../src/handlers/jobLogs.ts"],"names":[],"mappings":";;;AAKA,8CAAmD;AAEnD,KAAK,UAAU,OAAO,CACpB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,KAAK,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAC7B,MAAM,IAAI,GAAG,MAAM,KAAK,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAE3C,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,IAAI;KACX,CAAC;AACJ,CAAC;AAEY,QAAA,cAAc,GAAG,IAAA,qBAAa,EAAC,OAAO,EAAE;IACnD,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}
{"version":3,"file":"jobLogs.js","sourceRoot":"","sources":["../../src/handlers/jobLogs.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AAGnD,KAAK,UAAU,OAAO,CACpB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,KAAK,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAC7B,MAAM,IAAI,GAAG,MAAM,KAAK,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAE3C,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,IAAI;KACX,CAAC;AACJ,CAAC;AAEY,QAAA,cAAc,GAAG,IAAA,qBAAa,EAAC,OAAO,EAAE;IACnD,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"metrics.js","sourceRoot":"","sources":["../../src/handlers/metrics.ts"],"names":[],"mappings":";;;AAEA,8CAAmD;AAEnD,KAAK,UAAU,UAAU,CACvB,IAAsB,EACtB,KAAkB;IAElB,MAAM,CAAC,SAAS,EAAE,MAAM,CAAC,GAAG,MAAM,OAAO,CAAC,GAAG,CAAC;QAC5C,KAAK,CAAC,UAAU,CAAC,WAAW,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;QAC/C,KAAK,CAAC,UAAU,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;KAC7C,CAAC,CAAC;IAEH,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE,SAAS,EAAE,MAAM,EAAE;KAC5B,CAAC;AACJ,CAAC;AAEY,QAAA,cAAc,GAAG,IAAA,qBAAa,EAAC,UAAU,EAAE;IACtD,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}
{"version":3,"file":"metrics.js","sourceRoot":"","sources":["../../src/handlers/metrics.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AAGnD,KAAK,UAAU,UAAU,CACvB,IAAsB,EACtB,KAAkB;IAElB,MAAM,CAAC,SAAS,EAAE,MAAM,CAAC,GAAG,MAAM,OAAO,CAAC,GAAG,CAAC;QAC5C,KAAK,CAAC,UAAU,CAAC,WAAW,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;QAC/C,KAAK,CAAC,UAAU,CAAC,QAAQ,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC;KAC7C,CAAC,CAAC;IAEH,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE,SAAS,EAAE,MAAM,EAAE;KAC5B,CAAC;AACJ,CAAC;AAEY,QAAA,cAAc,GAAG,IAAA,qBAAa,EAAC,UAAU,EAAE;IACtD,qBAAqB,EAAE,IAAI;CAC5B,CAAC,CAAC"}
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.promoteJobHandler = void 0;
const job_1 = require("../providers/job");
const queue_1 = require("../providers/queue");
const job_1 = require("../providers/job");
async function promoteJob(_req, job) {

@@ -7,0 +7,0 @@ await job.promote();

@@ -1,1 +0,1 @@

{"version":3,"file":"promotJob.js","sourceRoot":"","sources":["../../src/handlers/promotJob.ts"],"names":[],"mappings":";;;AAKA,8CAAmD;AACnD,0CAA+C;AAE/C,KAAK,UAAU,UAAU,CACvB,IAAsB,EACtB,GAAa;IAEb,MAAM,GAAG,CAAC,OAAO,EAAE,CAAC;IAEpB,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE;KACT,CAAC;AACJ,CAAC;AAEY,QAAA,iBAAiB,GAAG,IAAA,qBAAa,EAAC,IAAA,iBAAW,EAAC,UAAU,CAAC,CAAC,CAAC"}
{"version":3,"file":"promotJob.js","sourceRoot":"","sources":["../../src/handlers/promotJob.ts"],"names":[],"mappings":";;;AACA,0CAA+C;AAC/C,8CAAmD;AAEnD,KAAK,UAAU,UAAU,CACvB,IAAsB,EACtB,GAAa;IAEb,MAAM,GAAG,CAAC,OAAO,EAAE,CAAC;IAEpB,OAAO;QACL,MAAM,EAAE,GAAG;QACX,IAAI,EAAE,EAAE;KACT,CAAC;AACJ,CAAC;AAEY,QAAA,iBAAiB,GAAG,IAAA,qBAAa,EAAC,IAAA,iBAAW,EAAC,UAAU,CAAC,CAAC,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"retryAll.js","sourceRoot":"","sources":["../../src/handlers/retryAll.ts"],"names":[],"mappings":";;;AAEA,8CAAmD;AAEnD,SAAS,gBAAgB,CAAC,KAAa;IACrC,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,WAAW,CAAC;AACrD,CAAC;AAED,KAAK,UAAU,QAAQ,CACrB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,WAAW,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAEnC,IAAI,CAAC,gBAAgB,CAAC,WAAW,CAAC,EAAE,CAAC;QACnC,OAAO;YACL,MAAM,EAAE,GAAG;YACX,IAAI,EAAE,EAAE,KAAK,EAAE,IAAI,WAAW,6BAA6B,EAAE;SAC9D,CAAC;IACJ,CAAC;IAED,MAAM,IAAI,GAAG,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;IAChD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;IAE7D,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC;AACnC,CAAC;AAEY,QAAA,eAAe,GAAG,IAAA,qBAAa,EAAC,QAAQ,CAAC,CAAC"}
{"version":3,"file":"retryAll.js","sourceRoot":"","sources":["../../src/handlers/retryAll.ts"],"names":[],"mappings":";;;AACA,8CAAmD;AAGnD,SAAS,gBAAgB,CAAC,KAAa;IACrC,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,WAAW,CAAC;AACrD,CAAC;AAED,KAAK,UAAU,QAAQ,CACrB,GAAqB,EACrB,KAAkB;IAElB,MAAM,EAAE,WAAW,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC;IAEnC,IAAI,CAAC,gBAAgB,CAAC,WAAW,CAAC,EAAE,CAAC;QACnC,OAAO;YACL,MAAM,EAAE,GAAG;YACX,IAAI,EAAE,EAAE,KAAK,EAAE,IAAI,WAAW,6BAA6B,EAAE;SAC9D,CAAC;IACJ,CAAC;IAED,MAAM,IAAI,GAAG,MAAM,KAAK,CAAC,OAAO,CAAC,CAAC,WAAW,CAAC,CAAC,CAAC;IAChD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,KAAK,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC;IAE7D,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC;AACnC,CAAC;AAEY,QAAA,eAAe,GAAG,IAAA,qBAAa,EAAC,QAAQ,CAAC,CAAC"}

@@ -1,1 +0,1 @@

{"version":3,"file":"bull.js","sourceRoot":"","sources":["../../src/queueAdapters/bull.ts"],"names":[],"mappings":";;;;;;AAAA,gDAA6C;AAY7C,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,WAAY,SAAQ,kBAAW;IAC1C,YACS,KAAY,EACnB,UAAwC,EAAE;QAE1C,KAAK,CAAC,MAAM,EAAE,EAAE,GAAG,OAAO,EAAE,qBAAqB,EAAE,KAAK,EAAE,CAAC,CAAC;QAHrD,UAAK,GAAL,KAAK,CAAO;QAKnB,IAAI,CAAC,CAAC,KAAK,YAAY,cAAS,CAAC,EAAE,CAAC;YAClC,MAAM,IAAI,KAAK,CAAC,qDAAqD,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,CAAC;IAClC,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,SAAyB,EAAE,WAAmB;QACzD,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,SAAgB,CAAC,CAAC;IACzD,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,KAAK,CAAC,MAAM,CAAC,EAAU;QAC5B,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QACxC,OAAO,GAAG,IAAI,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;IACvC,CAAC;IAEM,KAAK,CAAC,OAAO,CAClB,WAAgC,EAChC,KAAc,EACd,GAAY;QAEZ,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC/D,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;IACrC,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,KAAK,CAAC,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QACrE,MAAM,OAAO,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC9D,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,KAAK,IAAI,CAAC,CAAC,EAAE,CAAC;IACxE,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;IACtD,CAAC;IAEM,KAAK,CAAC,kBAAkB,CAAC,GAAW;QACzC,OAAO,KAAK,CAAC;IACf,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,KAAK,CAAC,oBAAoB;QAC/B,OAAO,IAAI,CAAC;IACd,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,YAAoB;QACpD,2CAA2C;IAC7C,CAAC;IAEO,YAAY,CAAC,GAAQ;QAC3B,IAAI,OAAO,CAAA,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,YAAY,CAAA,KAAK,QAAQ,EAAE,CAAC;YAC1C,GAAG,CAAC,YAAY,EAAE,CAAC;QACrB,CAAC;QACD,OAAO,GAAG,CAAC;IACb,CAAC;CACF;AAzHD,kCAyHC"}
{"version":3,"file":"bull.js","sourceRoot":"","sources":["../../src/queueAdapters/bull.ts"],"names":[],"mappings":";;;;;;AAAA,gDAA6C;AAW7C,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,WAAY,SAAQ,kBAAW;IAC1C,YACS,KAAY,EACnB,UAAwC,EAAE;QAE1C,KAAK,CAAC,MAAM,EAAE,EAAE,GAAG,OAAO,EAAE,qBAAqB,EAAE,KAAK,EAAE,CAAC,CAAC;QAHrD,UAAK,GAAL,KAAK,CAAO;QAKnB,IAAI,CAAC,CAAC,KAAK,YAAY,cAAS,CAAC,EAAE,CAAC;YAClC,MAAM,IAAI,KAAK,CAAC,qDAAqD,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,IAAI,EAAE,CAAC;IAClC,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,SAAyB,EAAE,WAAmB;QACzD,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,SAAgB,CAAC,CAAC;IACzD,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,KAAK,CAAC,MAAM,CAAC,EAAU;QAC5B,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QACxC,OAAO,GAAG,IAAI,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;IACvC,CAAC;IAEM,KAAK,CAAC,OAAO,CAClB,WAAgC,EAChC,KAAc,EACd,GAAY;QAEZ,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC/D,OAAO,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC;IACrC,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,KAAK,CAAC,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QACrE,MAAM,OAAO,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;QAC9D,OAAO,EAAE,GAAG,OAAO,EAAE,IAAI,EAAE,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,KAAK,IAAI,CAAC,CAAC,EAAE,CAAC;IACxE,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;QACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;IACtD,CAAC;IAEM,KAAK,CAAC,kBAAkB,CAAC,GAAW;QACzC,OAAO,KAAK,CAAC;IACf,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,KAAK,CAAC,oBAAoB;QAC/B,OAAO,IAAI,CAAC;IACd,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,YAAoB;QACpD,2CAA2C;IAC7C,CAAC;IAEO,YAAY,CAAC,GAAQ;QAC3B,IAAI,OAAO,CAAA,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,YAAY,CAAA,KAAK,QAAQ,EAAE,CAAC;YAC1C,GAAG,CAAC,YAAY,EAAE,CAAC;QACrB,CAAC;QACD,OAAO,GAAG,CAAC;IACb,CAAC;CACF;AAzHD,kCAyHC"}

@@ -25,5 +25,5 @@ import { Job, Queue } from 'bullmq';

getJobStatuses(): JobStatus[];
getClient(): Promise<import("bullmq").RedisClient>;
getClient(): Promise<import("bullmq").IRedisClient>;
getGlobalConcurrency(): Promise<number | null>;
setGlobalConcurrency(concurrency: number): Promise<void>;
}

@@ -1,1 +0,1 @@

{"version":3,"file":"bullMQ.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQ.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AAYpC,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,aAAc,SAAQ,kBAAW;IAC5C,YACU,KAAY,EACpB,UAAwC,EAAE;;QAE1C,MAAM,OAAO,GAAG,QAAQ,CAAC;QACzB,KAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;QAJhB,UAAK,GAAL,KAAK,CAAO;QAKpB,IACE,CAAC,CAAC,KAAK,YAAY,cAAK,KAAI,MAAA,GAAG,MAAC,KAAe,CAAC,UAAU,0CAAE,OAAO,EAAE,0CAAE,UAAU,CAAC,OAAO,CAAC,CAAA,CAAC,EAC3F,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;QAC7E,CAAC;IACH,CAAC;IAEM,KAAK,CAAC,YAAY;QACvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;QACvC,OAAO,MAAM,CAAC,IAAI,EAAE,CAAC;IACvB,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,KAAK,CAAC,SAAyB,EAAE,WAAmB;QAC/D,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,MAAM,CAAC,gBAAgB,EAAE,SAAS,CAAC,CAAC;IAC1E,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,MAAM,CAAC,EAAU;QACtB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IAC/B,CAAC;IAEM,OAAO,CAAC,WAAwB,EAAE,KAAc,EAAE,GAAY;QACnE,OAAO,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACrD,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QAC/D,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACjD,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,qBAAqB;QACrB,IAAI,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,KAAK,UAAU,EAAE,CAAC;YACjD,MAAM,IAAI,CAAC,KAAK,CAAC,WAAW,EAAE,CAAC;QACjC,CAAC;aAAM,CAAC;YACN,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;YACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACtD,CAAC;IACH,CAAC;IAEM,kBAAkB,CAAC,EAAU;QAClC,OAAO,IAAI,CAAC,KAAK,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;IAC3B,CAAC;IAEM,oBAAoB;;QACzB,OAAO,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,kDAAI,KAAI,IAAI,CAAC;IACrD,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,WAAmB;;QACnD,IAAI,WAAW,IAAI,CAAC,EAAE,CAAC;YACrB,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,uBAAuB,kDAAI,CAAA,CAAC;QAC/C,CAAC;aAAM,CAAC;YACN,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,mDAAG,WAAW,CAAC,CAAA,CAAC;QACvD,CAAC;IACH,CAAC;CACF;AA/HD,sCA+HC"}
{"version":3,"file":"bullMQ.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQ.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AAWpC,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,aAAc,SAAQ,kBAAW;IAC5C,YACU,KAAY,EACpB,UAAwC,EAAE;;QAE1C,MAAM,OAAO,GAAG,QAAQ,CAAC;QACzB,KAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;QAJhB,UAAK,GAAL,KAAK,CAAO;QAKpB,IACE,CAAC,CAAC,KAAK,YAAY,cAAK,KAAI,MAAA,GAAG,MAAC,KAAe,CAAC,UAAU,0CAAE,OAAO,EAAE,0CAAE,UAAU,CAAC,OAAO,CAAC,CAAA,CAAC,EAC3F,CAAC;YACD,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;QAC7E,CAAC;IACH,CAAC;IAEM,KAAK,CAAC,YAAY;QACvB,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;QACvC,OAAO,MAAM,CAAC,IAAI,EAAE,CAAC;IACvB,CAAC;IAEM,OAAO;QACZ,OAAO,GAAG,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,CAAC;IAC5C,CAAC;IAEM,KAAK,CAAC,KAAK,CAAC,SAAyB,EAAE,WAAmB;QAC/D,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,WAAW,EAAE,MAAM,CAAC,gBAAgB,EAAE,SAAS,CAAC,CAAC;IAC1E,CAAC;IAEM,MAAM,CAAC,IAAY,EAAE,IAAS,EAAE,OAAwB;QAC7D,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;IAC7C,CAAC;IAEM,MAAM,CAAC,EAAU;QACtB,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IAC/B,CAAC;IAEM,OAAO,CAAC,WAAwB,EAAE,KAAc,EAAE,GAAY;QACnE,OAAO,IAAI,CAAC,KAAK,CAAC,OAAO,CAAC,WAAW,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACrD,CAAC;IAEM,YAAY;QACjB,OAAO,IAAI,CAAC,KAAK,CAAC,YAAY,EAAmC,CAAC;IACpE,CAAC;IAEM,UAAU,CAAC,EAAU;QAC1B,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,CAAC;IAC5D,CAAC;IAEM,UAAU,CAAC,IAAiB,EAAE,KAAc,EAAE,GAAY;QAC/D,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,IAAI,EAAE,KAAK,EAAE,GAAG,CAAC,CAAC;IACjD,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;IAC/B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,MAAM;QACX,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC;IAC7B,CAAC;IAEM,KAAK;QACV,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;IAC5B,CAAC;IAEM,UAAU;QACf,OAAO,IAAI,CAAC,KAAK,CAAC,UAAU,CAAC,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;IACjD,CAAC;IAEM,KAAK,CAAC,UAAU;QACrB,qBAAqB;QACrB,IAAI,OAAO,IAAI,CAAC,KAAK,CAAC,WAAW,KAAK,UAAU,EAAE,CAAC;YACjD,MAAM,IAAI,CAAC,KAAK,CAAC,WAAW,EAAE,CAAC;QACjC,CAAC;aAAM,CAAC;YACN,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,CAAC,mBAAQ,CAAC,OAAO,CAAC,CAAC,CAAC;YACpD,MAAM,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACtD,CAAC;IACH,CAAC;IAEM,kBAAkB,CAAC,EAAU;QAClC,OAAO,IAAI,CAAC,KAAK,CAAC,kBAAkB,CAAC,EAAE,CAAC,CAAC;IAC3C,CAAC;IAEM,WAAW;QAChB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,cAAc;QACnB,OAAO;YACL,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,eAAe;YACxB,mBAAQ,CAAC,WAAW;YACpB,mBAAQ,CAAC,SAAS;YAClB,mBAAQ,CAAC,MAAM;YACf,mBAAQ,CAAC,OAAO;YAChB,mBAAQ,CAAC,MAAM;SAChB,CAAC;IACJ,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC;IAC3B,CAAC;IAEM,oBAAoB;;QACzB,OAAO,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,kDAAI,KAAI,IAAI,CAAC;IACrD,CAAC;IAEM,KAAK,CAAC,oBAAoB,CAAC,WAAmB;;QACnD,IAAI,WAAW,IAAI,CAAC,EAAE,CAAC;YACrB,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,uBAAuB,kDAAI,CAAA,CAAC;QAC/C,CAAC;aAAM,CAAC;YACN,MAAM,CAAA,MAAA,MAAA,IAAI,CAAC,KAAK,EAAC,oBAAoB,mDAAG,WAAW,CAAC,CAAA,CAAC;QACvD,CAAC;IACH,CAAC;CACF;AA/HD,sCA+HC"}

@@ -1,1 +0,1 @@

{"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"}
{"version":3,"file":"bullMQPro.js","sourceRoot":"","sources":["../../src/queueAdapters/bullMQPro.ts"],"names":[],"mappings":";;;AAQA,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,CAAC,WAAwB,EAAE,KAAK,GAAG,CAAC,EAAE,GAAG,GAAG,CAAC,CAAC;QAChE,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;AAxJD,4CAwJC"}

@@ -0,3 +1,3 @@

import { BullBoardQueues } from '../typings/app';
import { BaseAdapter } from './queueAdapters/base';
import { BullBoardQueues } from '../typings/app';
export declare function getQueuesApi(queues: ReadonlyArray<BaseAdapter>): {

@@ -4,0 +4,0 @@ bullBoardQueues: BullBoardQueues;

@@ -8,20 +8,20 @@ "use strict";

const emptyQueue_1 = require("./handlers/emptyQueue");
const obliterateQueue_1 = require("./handlers/obliterateQueue");
const entryPoint_1 = require("./handlers/entryPoint");
const job_1 = require("./handlers/job");
const jobFlow_1 = require("./handlers/jobFlow");
const jobLogs_1 = require("./handlers/jobLogs");
const metrics_1 = require("./handlers/metrics");
const job_1 = require("./handlers/job");
const jobFlow_1 = require("./handlers/jobFlow");
const obliterateQueue_1 = require("./handlers/obliterateQueue");
const pauseAll_1 = require("./handlers/pauseAll");
const pauseQueue_1 = require("./handlers/pauseQueue");
const promoteAll_1 = require("./handlers/promoteAll");
const promotJob_1 = require("./handlers/promotJob");
const queues_1 = require("./handlers/queues");
const redisStats_1 = require("./handlers/redisStats");
const resumeAll_1 = require("./handlers/resumeAll");
const resumeQueue_1 = require("./handlers/resumeQueue");
const retryAll_1 = require("./handlers/retryAll");
const retryJob_1 = require("./handlers/retryJob");
const promoteAll_1 = require("./handlers/promoteAll");
const setGlobalConcurrency_1 = require("./handlers/setGlobalConcurrency");
const updateJobData_1 = require("./handlers/updateJobData");
const pauseAll_1 = require("./handlers/pauseAll");
const resumeAll_1 = require("./handlers/resumeAll");
const setGlobalConcurrency_1 = require("./handlers/setGlobalConcurrency");
exports.appRoutes = {

@@ -28,0 +28,0 @@ entryPoint: {

@@ -1,1 +0,1 @@

{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;AACA,8CAAkD;AAClD,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,gEAAoE;AACpE,sDAAmD;AACnD,gDAAoD;AACpD,gDAAoD;AACpD,wCAA4C;AAC5C,gDAAoD;AACpD,sDAA0D;AAC1D,oDAAyD;AACzD,8CAAkD;AAClD,sDAA0D;AAC1D,wDAA4D;AAC5D,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,4DAAgE;AAChE,kDAAsD;AACtD,oDAAwD;AACxD,0EAA8E;AAEjE,QAAA,SAAS,GAAiB;IACrC,UAAU,EAAE;QACV,MAAM,EAAE,KAAK;QACb,KAAK,EAAE,CAAC,GAAG,EAAE,mBAAmB,EAAE,0BAA0B,CAAC;QAC7D,OAAO,EAAE,uBAAU;KACpB;IACD,GAAG,EAAE;QACH,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,kBAAkB,EAAE,OAAO,EAAE,8BAAiB,EAAE;QACxE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,aAAa,EAAE,OAAO,EAAE,sBAAa,EAAE;QAC/D;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,wBAAc;SACxB;QACD,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,mBAAmB,EAAE,OAAO,EAAE,0BAAe,EAAE;QACvE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,oBAAoB,EAAE,OAAO,EAAE,4BAAgB,EAAE;QACzE;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gBAAU;SACpB;QACD;YACE,MAAM,EAAE,MAAM;YACd,KAAK,EAAE,4BAA4B;YACnC,OAAO,EAAE,sBAAa;SACvB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gCAAkB;SAC5B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,kDAA2B;SACrC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,mCAAmC;YAC1C,OAAO,EAAE,wCAAsB;SAChC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,uCAAuC;YAC9C,OAAO,EAAE,6BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,OAAO;YACf,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,oCAAoB;SAC9B;KACF;CACF,CAAC"}
{"version":3,"file":"routes.js","sourceRoot":"","sources":["../src/routes.ts"],"names":[],"mappings":";;;AACA,8CAAkD;AAClD,kDAAsD;AACtD,kDAAsD;AACtD,sDAA0D;AAC1D,sDAAmD;AACnD,wCAA4C;AAC5C,gDAAoD;AACpD,gDAAoD;AACpD,gDAAoD;AACpD,gEAAoE;AACpE,kDAAsD;AACtD,sDAA0D;AAC1D,sDAA0D;AAC1D,oDAAyD;AACzD,8CAAkD;AAClD,sDAA0D;AAC1D,oDAAwD;AACxD,wDAA4D;AAC5D,kDAAsD;AACtD,kDAAsD;AACtD,0EAA8E;AAC9E,4DAAgE;AAEnD,QAAA,SAAS,GAAiB;IACrC,UAAU,EAAE;QACV,MAAM,EAAE,KAAK;QACb,KAAK,EAAE,CAAC,GAAG,EAAE,mBAAmB,EAAE,0BAA0B,CAAC;QAC7D,OAAO,EAAE,uBAAU;KACpB;IACD,GAAG,EAAE;QACH,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,kBAAkB,EAAE,OAAO,EAAE,8BAAiB,EAAE;QACxE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,aAAa,EAAE,OAAO,EAAE,sBAAa,EAAE;QAC/D;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,wBAAc;SACxB;QACD,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,mBAAmB,EAAE,OAAO,EAAE,0BAAe,EAAE;QACvE,EAAE,MAAM,EAAE,KAAK,EAAE,KAAK,EAAE,oBAAoB,EAAE,OAAO,EAAE,4BAAgB,EAAE;QACzE;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,wBAAc;SACxB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gBAAU;SACpB;QACD;YACE,MAAM,EAAE,MAAM;YACd,KAAK,EAAE,4BAA4B;YACnC,OAAO,EAAE,sBAAa;SACvB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,gCAAgC;YACvC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,+BAA+B;YACtC,OAAO,EAAE,gCAAkB;SAC5B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,oCAAoC;YAC3C,OAAO,EAAE,kDAA2B;SACrC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,8BAA8B;YACrC,OAAO,EAAE,8BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,mCAAmC;YAC1C,OAAO,EAAE,wCAAsB;SAChC;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,qCAAqC;YAC5C,OAAO,EAAE,0BAAe;SACzB;QACD;YACE,MAAM,EAAE,KAAK;YACb,KAAK,EAAE,uCAAuC;YAC9C,OAAO,EAAE,6BAAiB;SAC3B;QACD;YACE,MAAM,EAAE,OAAO;YACf,KAAK,EAAE,2CAA2C;YAClD,OAAO,EAAE,oCAAoB;SAC9B;KACF;CACF,CAAC"}
{
"name": "@bull-board/api",
"version": "7.2.0",
"version": "7.2.1",
"description": "A Dashboard server API built on top of bull or bullmq.",

@@ -8,7 +8,9 @@ "keywords": [

"bullmq",
"redis",
"dashboard",
"monitoring",
"queue",
"monitoring",
"dashboard"
"redis"
],
"license": "MIT",
"author": "felixmosh",
"repository": {

@@ -19,5 +21,2 @@ "type": "git",

},
"license": "MIT",
"author": "felixmosh",
"main": "dist/index.js",
"files": [

@@ -28,2 +27,3 @@ "dist",

],
"main": "dist/index.js",
"exports": {

@@ -39,2 +39,5 @@ ".": "./dist/index.js",

},
"publishConfig": {
"access": "public"
},
"scripts": {

@@ -49,16 +52,15 @@ "build": "yarn clean && tsc",

"devDependencies": {
"@types/jest": "^30.0.0",
"@types/redis-info": "^3.0.3",
"@types/supertest": "^2.0.16",
"bull": "^4.16.5",
"bullmq": "^5.73.5",
"ioredis": "^5.10.1",
"jest": "^30.3.0",
"supertest": "^7.2.2"
"bullmq": "^5.78.0",
"ioredis": "^5.11.1",
"jest": "^30.4.2",
"supertest": "^7.2.2",
"ts-jest": "^29.4.11"
},
"peerDependencies": {
"@bull-board/ui": "7.2.0"
},
"publishConfig": {
"access": "public"
"@bull-board/ui": "7.2.1"
}
}