@bull-board/api
Advanced tools
@@ -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; |
+7
-7
@@ -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"} |
+17
-15
| { | ||
| "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" | ||
| } | ||
| } |
110634
0.05%9
28.57%