{"version":3,"file":"bullMQ.js","sourceRoot":"","sources":["../../../src/queueAdapters/bullMQ.ts"],"names":[],"mappings":";;;AASA,oDAAiD;AACjD,iCAAqC;AAErC,MAAa,aAAc,SAAQ,kBAAW;IAC5C,YAAoB,KAAY,EAAE,UAAwC,EAAE;;QAC1E,MAAM,OAAO,GAAG,QAAQ,CAAC;QACzB,KAAK,CAAC,OAAO,EAAE,OAAO,CAAC,CAAC;QAFN,UAAK,GAAL,KAAK,CAAO;QAG9B,IAAI,CAAC,CAAC,MAAA,KAAK,CAAC,UAAU,0CAAE,OAAkB,CAAA,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE,CAAC;YAC/D,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,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,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,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;CACF;AA9FD,sCA8FC"}