Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
storage-based-queue
Advanced tools
storage-based-queue - npm Package Compare versions
Comparing version 1.2.4 to 1.2.5
@@ -5,42 +5,58 @@ # Release Notes: | ||
| * Async support added to many processes. | ||
| * All test cases has been re-writen for async calls. | ||
| * Localforage library added to dependencies for will support the three type (localstorage, indexeddb, websql) storages. | ||
| * In memory database adapter added. | ||
| * Channel logic moved to Channel class from queue class. | ||
| * Worker registration way has been changed slightly. | ||
| * Worker dependencies management moved to another method. | ||
| * Plugin infrastructure added. After which different storage modules can be used (AsyncStorage (React Native) supported from now). | ||
| * ESLint integrated. | ||
| * Network activities check removed. This control left to developer because there is different development environments (Browser, React Native etc.). | ||
| * Added new `merge()` method to container class for some configuration objects to be merge. | ||
| * debug npm package removed from dependencies. | ||
| - Async support added to many processes. | ||
| - All test cases has been re-writen for async calls. | ||
| - Localforage library added to dependencies for will support the three type (localstorage, indexeddb, websql) storages. | ||
| - In memory database adapter added. | ||
| - Channel logic moved to Channel class from queue class. | ||
| - Worker registration way has been changed slightly. | ||
| - Worker dependencies management moved to another method. | ||
| - Plugin infrastructure added. After which different storage modules can be used (AsyncStorage (React Native) supported from now). | ||
| - ESLint integrated. | ||
| - Network activities check removed. This control left to developer because there is different development environments (Browser, React Native etc.). | ||
| - Added new `merge()` method to container class for some configuration objects to be merge. | ||
| - debug npm package removed from dependencies. | ||
| ## Changes for v1.0.1: | ||
| * Container class removed from channel class and the workers were taken directly from the Queue class. | ||
| * Emojis replaced with ascii characters in console. | ||
| * Console outputs improved. | ||
| - Container class removed from channel class and the workers were taken directly from the Queue class. | ||
| - Emojis replaced with ascii characters in console. | ||
| - Console outputs improved. | ||
| ## Changes for v1.0.2: | ||
| * Removed old tests | ||
| - Removed old tests | ||
| ## Changes for v1.1.1: | ||
| * Some unused declarations has been deleted [(#80e26ee)](https://github.com/atayahmet/storage-based-queue/commit/80e26ee) | ||
| * Flowtype interfaces folder moved to src folder. [(#e1630c8)](https://github.com/atayahmet/storage-based-queue/commit/e1630c8) | ||
| * InMemory adapter default storage was made. | ||
| * Removed LocalForage library from dependencies. Just supported the `localstorage` and `inmemory` storage. [(#5694a6e)](https://github.com/atayahmet/storage-based-queue/commit/5694a6e) | ||
| * Status method added to channel class for check if channel working. [(#38f4e92)](https://github.com/atayahmet/storage-based-queue/commit/38f4e92) | ||
| - Some unused declarations has been deleted [(#80e26ee)](https://github.com/atayahmet/storage-based-queue/commit/80e26ee) | ||
| - Flowtype interfaces folder moved to src folder. [(#e1630c8)](https://github.com/atayahmet/storage-based-queue/commit/e1630c8) | ||
| - InMemory adapter default storage was made. | ||
| - Removed LocalForage library from dependencies. Just supported the `localstorage` and `inmemory` storage. [(#5694a6e)](https://github.com/atayahmet/storage-based-queue/commit/5694a6e) | ||
| - Status method added to channel class for check if channel working. [(#38f4e92)](https://github.com/atayahmet/storage-based-queue/commit/38f4e92) | ||
| ## Changes for v1.2.0: | ||
| * Added native browser worker support. (with polyfill) [(#bce43fa)](https://github.com/atayahmet/storage-based-queue/commit/bce43fa) | ||
| - Added native browser worker support. (with polyfill) [(#bce43fa)](https://github.com/atayahmet/storage-based-queue/commit/bce43fa) | ||
| ## Changes for v1.2.1: | ||
| * `"job not found"` message color changed [(#350c978)](https://github.com/atayahmet/storage-based-queue/commit/350c978) | ||
| * index.js file added to adapters folder [(#13f2efa)](https://github.com/atayahmet/storage-based-queue/commit/13f2efa) | ||
| * .babelrc deleted for avoid "Unknown plugin "transform-runtime" error. | ||
| * Main file path in package.json has been changed as `lib/index.js`. | ||
| - `"job not found"` message color changed [(#350c978)](https://github.com/atayahmet/storage-based-queue/commit/350c978) | ||
| - index.js file added to adapters folder [(#13f2efa)](https://github.com/atayahmet/storage-based-queue/commit/13f2efa) | ||
| - .babelrc deleted for avoid "Unknown plugin "transform-runtime" error. | ||
| - Main file path in package.json has been changed as `lib/index.js`. | ||
| ## Changes for v1.2.2: | ||
| - Version upgraded for npm publish. | ||
| ## Changes for v1.2.3: | ||
| - Version upgraded for npm publish. | ||
| ## Changes for v1.2.4: | ||
| - dev environment fix [(#822851c)](https://github.com/atayahmet/storage-based-queue/commit/822851c) | ||
| ## Changes for v1.2.5: | ||
| - Bug fix: status() method at channel class. |
@@ -1,1 +0,1 @@ | ||
| !function i(a,u,c){function s(t,e){if(!u[t]){if(!a[t]){var r="function"==typeof require&&require;if(!e&&r)return r(t,!0);if(f)return f(t,!0);var n=new Error("Cannot find module '"+t+"'");throw n.code="MODULE_NOT_FOUND",n}var o=u[t]={exports:{}};a[t][0].call(o.exports,function(e){return s(a[t][1][e]||e)},o,o.exports,i,a,u,c)}return u[t].exports}for(var f="function"==typeof require&&require,e=0;e<c.length;e++)s(c[e]);return s}({1:[function(e,t,r){t.exports=e("regenerator-runtime")},{"regenerator-runtime":7}],2:[function(e,t,r){var a=/\b(Array|Date|Object|Math|JSON)\b/g;t.exports=function(e,t){var r,n,o,i=function(e){for(var t=[],r=0;r<e.length;r++)~t.indexOf(e[r])||t.push(e[r]);return t}(e.replace(/\.\w+|\w+ *\(|"[^"]*"|'[^']*'|\/([^/]+)\//g,"").replace(a,"").match(/[a-zA-Z_]\w*/g)||[]);return t&&"string"==typeof t&&(r=t,t=function(e){return r+e}),t?(n=i,o=t,e.replace(/\.\w+|\w+ *\(|"[^"]*"|'[^']*'|\/([^/]+)\/|[a-zA-Z_]\w*/g,function(e){return"("==e[e.length-1]?o(e):~n.indexOf(e)?o(e):e})):i}},{}],3:[function(e,t,r){var i=e("to-function");t.exports=function(e,t){var r,n={};t=i(t);for(var o=0;o<e.length;++o)n[r=t(e[o],o)]=n[r]||[],n[r].push(e[o]);return n}},{"to-function":9}],4:[function(e,r,t){!function(e,t){"use strict";"object"==typeof r&&"object"==typeof r.exports?r.exports=t():"function"==typeof define&&define.amd?define([],t):e.objectPath=t()}(this,function(){"use strict";var t=Object.prototype.toString;function i(e,t){return null!=e&&Object.prototype.hasOwnProperty.call(e,t)}function f(e){if(!e)return!0;if(p(e)&&0===e.length)return!0;if("string"!=typeof e){for(var t in e)if(i(e,t))return!1;return!0}return!1}function l(e){return t.call(e)}var p=Array.isArray||function(e){return"[object Array]"===t.call(e)};function h(e){var t=parseInt(e);return t.toString()===e?t:e}function e(o){o=o||{};var a=function(r){return Object.keys(a).reduce(function(e,t){return"create"===t||"function"==typeof a[t]&&(e[t]=a[t].bind(a,r)),e},{})};function u(e,t){return o.includeInheritedProps||"number"==typeof t&&Array.isArray(e)||i(e,t)}function c(e,t){if(u(e,t))return e[t]}function s(e,t,r,n){if("number"==typeof t&&(t=[t]),!t||0===t.length)return e;if("string"==typeof t)return s(e,t.split(".").map(h),r,n);var o=t[0],i=c(e,o);return 1===t.length?(void 0!==i&&n||(e[o]=r),i):(void 0===i&&("number"==typeof t[1]?e[o]=[]:e[o]={}),s(e[o],t.slice(1),r,n))}return a.has=function(e,t){if("number"==typeof t?t=[t]:"string"==typeof t&&(t=t.split(".")),!t||0===t.length)return!!e;for(var r=0;r<t.length;r++){var n=h(t[r]);if(!("number"==typeof n&&p(e)&&n<e.length||(o.includeInheritedProps?n in Object(e):i(e,n))))return!1;e=e[n]}return!0},a.ensureExists=function(e,t,r){return s(e,t,r,!0)},a.set=function(e,t,r,n){return s(e,t,r,n)},a.insert=function(e,t,r,n){var o=a.get(e,t);n=~~n,p(o)||(o=[],a.set(e,t,o)),o.splice(n,0,r)},a.empty=function(e,t){var r,n;if(!f(t)&&(null!=e&&(r=a.get(e,t)))){if("string"==typeof r)return a.set(e,t,"");if("boolean"==typeof(i=r)||"[object Boolean]"===l(i))return a.set(e,t,!1);if("number"==typeof r)return a.set(e,t,0);if(p(r))r.length=0;else{if("object"!=typeof(o=r)||"[object Object]"!==l(o))return a.set(e,t,null);for(n in r)u(r,n)&&delete r[n]}var o,i}},a.push=function(e,t){var r=a.get(e,t);p(r)||(r=[],a.set(e,t,r)),r.push.apply(r,Array.prototype.slice.call(arguments,2))},a.coalesce=function(e,t,r){for(var n,o=0,i=t.length;o<i;o++)if(void 0!==(n=a.get(e,t[o])))return n;return r},a.get=function(e,t,r){if("number"==typeof t&&(t=[t]),!t||0===t.length)return e;if(null==e)return r;if("string"==typeof t)return a.get(e,t.split("."),r);var n=h(t[0]),o=c(e,n);return void 0===o?r:1===t.length?o:a.get(e[n],t.slice(1),r)},a.del=function(e,t){if("number"==typeof t&&(t=[t]),null==e)return e;if(f(t))return e;if("string"==typeof t)return a.del(e,t.split("."));var r=h(t[0]);return u(e,r)?1!==t.length?a.del(e[r],t.slice(1)):(p(e)?e.splice(r,1):delete e[r],e):e},a}var r=e();return r.create=e,r.withInheritedProps=e({includeInheritedProps:!0}),r})},{}],5:[function(require,module,exports){(function(global){"use strict";function doEval(self,__pseudoworker_script){(function(){eval(__pseudoworker_script)}).call(global)}function PseudoWorker(r){var n,o,i=[],a=[],u=[],c=[],s=[],t=!1,f=this;function l(e,t){for(var r=-1;++r<e.length;)e[r]&&t(e[r])}function p(e){var t,r=(t=e,function(e){e({type:"error",error:t,message:t.message})});"function"==typeof f.onerror&&r(f.onerror),o&&"function"==typeof o.onerror&&r(o.onerror),l(a,r),l(c,r)}function h(t){function e(e){try{e({data:t})}catch(e){p(e)}}o&&"function"==typeof o.onmessage&&e(o.onmessage),l(u,e)}function d(t){function e(e){e({data:t})}"function"==typeof f.onmessage&&e(f.onmessage),l(i,e)}function y(e,t){"message"===e?u.push(t):"error"===e&&c.push(t)}var v=new XMLHttpRequest;return v.open("GET",r),v.onreadystatechange=function(){if(4===v.readyState)if(200<=v.status&&v.status<400){n=v.responseText,doEval(o={postMessage:d,addEventListener:y},n);var e=s;s=[];for(var t=0;t<e.length;t++)h(e[t])}else p(new Error("cannot find script "+r))},v.send(),f.postMessage=function(e){if(void 0===e)throw new Error("postMessage() requires an argument");t||(n?h(e):s.push(e))},f.addEventListener=function(e,t){"message"===e?i.push(t):"error"===e&&a.push(t)},f.removeEventListener=function(e,t){var r;if("message"===e)r=i;else{if("error"!==e)return;r=a}for(var n=-1;++n<r.length;)if(r[n]===t){delete r[n];break}},f.terminate=function(){t=!0},f}module.exports=PseudoWorker}).call(this,"undefined"!=typeof global?global:"undefined"!=typeof self?self:"undefined"!=typeof window?window:{})},{}],6:[function(r,n,e){(function(e){"use strict";var t=r("./");"undefined"==typeof Worker&&(e.Worker=t),n.exports=t}).call(this,"undefined"!=typeof global?global:"undefined"!=typeof self?self:"undefined"!=typeof window?window:{})},{"./":5}],7:[function(e,t,r){var n=function(){return this}()||Function("return this")(),o=n.regeneratorRuntime&&0<=Object.getOwnPropertyNames(n).indexOf("regeneratorRuntime"),i=o&&n.regeneratorRuntime;if(n.regeneratorRuntime=void 0,t.exports=e("./runtime"),o)n.regeneratorRuntime=i;else try{delete n.regeneratorRuntime}catch(e){n.regeneratorRuntime=void 0}},{"./runtime":8}],8:[function(e,C,t){!function(e){"use strict";var c,t=Object.prototype,s=t.hasOwnProperty,r="function"==typeof Symbol?Symbol:{},o=r.iterator||"@@iterator",n=r.asyncIterator||"@@asyncIterator",i=r.toStringTag||"@@toStringTag",a="object"==typeof C,u=e.regeneratorRuntime;if(u)a&&(C.exports=u);else{(u=e.regeneratorRuntime=a?C.exports:{}).wrap=m;var l="suspendedStart",p="suspendedYield",h="executing",d="completed",y={},f={};f[o]=function(){return this};var v=Object.getPrototypeOf,g=v&&v(v(E([])));g&&g!==t&&s.call(g,o)&&(f=g);var b=_.prototype=x.prototype=Object.create(f);k.prototype=b.constructor=_,_.constructor=k,_[i]=k.displayName="GeneratorFunction",u.isGeneratorFunction=function(e){var t="function"==typeof e&&e.constructor;return!!t&&(t===k||"GeneratorFunction"===(t.displayName||t.name))},u.mark=function(e){return Object.setPrototypeOf?Object.setPrototypeOf(e,_):(e.__proto__=_,i in e||(e[i]="GeneratorFunction")),e.prototype=Object.create(b),e},u.awrap=function(e){return{__await:e}},O(j.prototype),j.prototype[n]=function(){return this},u.AsyncIterator=j,u.async=function(e,t,r,n){var o=new j(m(e,t,r,n));return u.isGeneratorFunction(t)?o:o.next().then(function(e){return e.done?e.value:o.next()})},O(b),b[i]="Generator",b[o]=function(){return this},b.toString=function(){return"[object Generator]"},u.keys=function(r){var n=[];for(var e in r)n.push(e);return n.reverse(),function e(){for(;n.length;){var t=n.pop();if(t in r)return e.value=t,e.done=!1,e}return e.done=!0,e}},u.values=E,L.prototype={constructor:L,reset:function(e){if(this.prev=0,this.next=0,this.sent=this._sent=c,this.done=!1,this.delegate=null,this.method="next",this.arg=c,this.tryEntries.forEach(T),!e)for(var t in this)"t"===t.charAt(0)&&s.call(this,t)&&!isNaN(+t.slice(1))&&(this[t]=c)},stop:function(){this.done=!0;var e=this.tryEntries[0].completion;if("throw"===e.type)throw e.arg;return this.rval},dispatchException:function(r){if(this.done)throw r;var n=this;function e(e,t){return i.type="throw",i.arg=r,n.next=e,t&&(n.method="next",n.arg=c),!!t}for(var t=this.tryEntries.length-1;0<=t;--t){var o=this.tryEntries[t],i=o.completion;if("root"===o.tryLoc)return e("end");if(o.tryLoc<=this.prev){var a=s.call(o,"catchLoc"),u=s.call(o,"finallyLoc");if(a&&u){if(this.prev<o.catchLoc)return e(o.catchLoc,!0);if(this.prev<o.finallyLoc)return e(o.finallyLoc)}else if(a){if(this.prev<o.catchLoc)return e(o.catchLoc,!0)}else{if(!u)throw new Error("try statement without catch or finally");if(this.prev<o.finallyLoc)return e(o.finallyLoc)}}}},abrupt:function(e,t){for(var r=this.tryEntries.length-1;0<=r;--r){var n=this.tryEntries[r];if(n.tryLoc<=this.prev&&s.call(n,"finallyLoc")&&this.prev<n.finallyLoc){var o=n;break}}o&&("break"===e||"continue"===e)&&o.tryLoc<=t&&t<=o.finallyLoc&&(o=null);var i=o?o.completion:{};return i.type=e,i.arg=t,o?(this.method="next",this.next=o.finallyLoc,y):this.complete(i)},complete:function(e,t){if("throw"===e.type)throw e.arg;return"break"===e.type||"continue"===e.type?this.next=e.arg:"return"===e.type?(this.rval=this.arg=e.arg,this.method="return",this.next="end"):"normal"===e.type&&t&&(this.next=t),y},finish:function(e){for(var t=this.tryEntries.length-1;0<=t;--t){var r=this.tryEntries[t];if(r.finallyLoc===e)return this.complete(r.completion,r.afterLoc),T(r),y}},catch:function(e){for(var t=this.tryEntries.length-1;0<=t;--t){var r=this.tryEntries[t];if(r.tryLoc===e){var n=r.completion;if("throw"===n.type){var o=n.arg;T(r)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(e,t,r){return this.delegate={iterator:E(e),resultName:t,nextLoc:r},"next"===this.method&&(this.arg=c),y}}}function m(e,t,r,n){var i,a,u,c,o=t&&t.prototype instanceof x?t:x,s=Object.create(o.prototype),f=new L(n||[]);return s._invoke=(i=e,a=r,u=f,c=l,function(e,t){if(c===h)throw new Error("Generator is already running");if(c===d){if("throw"===e)throw t;return A()}for(u.method=e,u.arg=t;;){var r=u.delegate;if(r){var n=P(r,u);if(n){if(n===y)continue;return n}}if("next"===u.method)u.sent=u._sent=u.arg;else if("throw"===u.method){if(c===l)throw c=d,u.arg;u.dispatchException(u.arg)}else"return"===u.method&&u.abrupt("return",u.arg);c=h;var o=w(i,a,u);if("normal"===o.type){if(c=u.done?d:p,o.arg===y)continue;return{value:o.arg,done:u.done}}"throw"===o.type&&(c=d,u.method="throw",u.arg=o.arg)}}),s}function w(e,t,r){try{return{type:"normal",arg:e.call(t,r)}}catch(e){return{type:"throw",arg:e}}}function x(){}function k(){}function _(){}function O(e){["next","throw","return"].forEach(function(t){e[t]=function(e){return this._invoke(t,e)}})}function j(c){var t;this._invoke=function(r,n){function e(){return new Promise(function(e,t){!function t(e,r,n,o){var i=w(c[e],c,r);if("throw"!==i.type){var a=i.arg,u=a.value;return u&&"object"==typeof u&&s.call(u,"__await")?Promise.resolve(u.__await).then(function(e){t("next",e,n,o)},function(e){t("throw",e,n,o)}):Promise.resolve(u).then(function(e){a.value=e,n(a)},o)}o(i.arg)}(r,n,e,t)})}return t=t?t.then(e,e):e()}}function P(e,t){var r=e.iterator[t.method];if(r===c){if(t.delegate=null,"throw"===t.method){if(e.iterator.return&&(t.method="return",t.arg=c,P(e,t),"throw"===t.method))return y;t.method="throw",t.arg=new TypeError("The iterator does not provide a 'throw' method")}return y}var n=w(r,e.iterator,t.arg);if("throw"===n.type)return t.method="throw",t.arg=n.arg,t.delegate=null,y;var o=n.arg;return o?o.done?(t[e.resultName]=o.value,t.next=e.nextLoc,"return"!==t.method&&(t.method="next",t.arg=c),t.delegate=null,y):o:(t.method="throw",t.arg=new TypeError("iterator result is not an object"),t.delegate=null,y)}function S(e){var t={tryLoc:e[0]};1 in e&&(t.catchLoc=e[1]),2 in e&&(t.finallyLoc=e[2],t.afterLoc=e[3]),this.tryEntries.push(t)}function T(e){var t=e.completion||{};t.type="normal",delete t.arg,e.completion=t}function L(e){this.tryEntries=[{tryLoc:"root"}],e.forEach(S,this),this.reset(!0)}function E(t){if(t){var e=t[o];if(e)return e.call(t);if("function"==typeof t.next)return t;if(!isNaN(t.length)){var r=-1,n=function e(){for(;++r<t.length;)if(s.call(t,r))return e.value=t[r],e.done=!1,e;return e.value=c,e.done=!0,e};return n.next=n}}return{next:A}}function A(){return{value:c,done:!0}}}(function(){return this}()||Function("return this")())},{}],9:[function(t,e,r){var i;try{i=t("props")}catch(e){i=t("component-props")}function n(e){switch({}.toString.call(e)){case"[object Object]":return function(e){var r={};for(var t in e)r[t]="string"==typeof e[t]?o(e[t]):n(e[t]);return function(e){if("object"!=typeof e)return!1;for(var t in r){if(!(t in e))return!1;if(!r[t](e[t]))return!1}return!0}}(e);case"[object Function]":return e;case"[object String]":return/^ *\W+/.test(r=e)?new Function("_","return _ "+r):new Function("_","return "+function(e){var t,r,n,o=i(e);if(!o.length)return"_."+e;for(r=0;r<o.length;r++)n=o[r],e=a(n,e,t="('function' == typeof "+(t="_."+n)+" ? "+t+"() : "+t+")");return e}(r));case"[object RegExp]":return t=e,function(e){return t.test(e)};default:return o(e)}var t,r}function o(t){return function(e){return t===e}}function a(e,t,r){return t.replace(new RegExp("(\\.)?"+e,"g"),function(e,t){return t?e:r})}e.exports=n},{"component-props":2,props:2}],10:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.LocalStorageAdapter=r.InMemoryAdapter=void 0;var n=i(e("./inmemory")),o=i(e("./localstorage"));function i(e){return e&&e.__esModule?e:{default:e}}r.InMemoryAdapter=n.default,r.LocalStorageAdapter=o.default},{"./inmemory":11,"./localstorage":12}],11:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=e("babel-runtime/regenerator"),a=(n=o)&&n.__esModule?n:{default:n},u=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},c=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();function s(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function f(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function t(e){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.store={},this.config=e,this.prefix=this.config.get("prefix")}var r,n,o,i;return c(t,[{key:"get",value:(i=f(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return r=this.storageName(t),e.abrupt("return",[].concat(s(this.getCollection(r))));case 2:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"set",value:(o=f(a.default.mark(function e(t,r){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return this.store[this.storageName(t)]=[].concat(s(r)),e.abrupt("return",r);case 2:case"end":return e.stop()}},e,this)})),function(e,t){return o.apply(this,arguments)})},{key:"has",value:(n=f(a.default.mark(function e(t){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",Object.prototype.hasOwnProperty.call(this.store,this.storageName(t)));case 1:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"clear",value:(r=f(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.has(t);case 2:if(!e.sent){e.next=6;break}e.t0=delete this.store[this.storageName(t)],e.next=7;break;case 6:e.t0=!1;case 7:return r=e.t0,this.store=u({},this.store),e.abrupt("return",r);case 10:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"storageName",value:function(e){return e.startsWith(this.getPrefix())?e:this.getPrefix()+"_"+e}},{key:"getPrefix",value:function(){return this.config.get("prefix")}},{key:"getCollection",value:function(e){return Object.prototype.hasOwnProperty.call(this.store,e)||(this.store[e]=[]),this.store[e]}}]),t}();r.default=i},{"babel-runtime/regenerator":1}],12:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=e("babel-runtime/regenerator"),a=(n=o)&&n.__esModule?n:{default:n},u=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();function c(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function t(e){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.config=e,this.prefix=this.config.get("prefix")}var r,n,o,i;return u(t,[{key:"get",value:(i=c(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return r=localStorage.getItem(this.storageName(t)),e.abrupt("return",JSON.parse(r)||[]);case 2:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"set",value:(o=c(a.default.mark(function e(t,r){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return localStorage.setItem(this.storageName(t),JSON.stringify(r)),e.abrupt("return",r);case 2:case"end":return e.stop()}},e,this)})),function(e,t){return o.apply(this,arguments)})},{key:"has",value:(n=c(a.default.mark(function e(t){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",Object.prototype.hasOwnProperty.call(localStorage,this.storageName(t)));case 1:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"clear",value:(r=c(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.has(t);case 2:if(!e.sent){e.next=6;break}e.t0=delete localStorage[this.storageName(t)],e.next=7;break;case 6:e.t0=!1;case 7:return r=e.t0,e.abrupt("return",r);case 9:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"storageName",value:function(e){return e.startsWith(this.getPrefix())?e:this.getPrefix()+"_"+e}},{key:"getPrefix",value:function(){return this.config.get("prefix")}}]),t}();r.default=i},{"babel-runtime/regenerator":1}],13:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var l=n(e("babel-runtime/regenerator")),p=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),h=n(e("./event")),d=n(e("./storage-capsule")),y=n(e("./queue")),v=e("./utils"),g=e("./helpers"),b=e("./console");function n(e){return e&&e.__esModule?e:{default:e}}function m(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var w=Symbol("channel-name"),o=function(){function o(e,t){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,o),this.stopped=!0,this.running=!1,this.event=new h.default,this.config=t,this[w]=e;var r=y.default.drivers,n=new d.default(t,r.storage);this.storage=n.channel(e)}var t,r,n,e,i,a,u,c,s,f;return p(o,[{key:"name",value:function(){return this[w]}},{key:"add",value:(f=m(l.default.mark(function e(t){var r;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.canMultiple.call(this,t);case 2:if(e.sent){e.next=4;break}return e.abrupt("return",!1);case 4:return e.next=6,g.saveTask.call(this,t);case 6:if(!(r=e.sent)||!this.stopped||!0!==this.running){e.next=10;break}return e.next=10,this.start();case 10:return g.logProxy.call(this,b.taskAddedLog,t),e.abrupt("return",r);case 12:case"end":return e.stop()}},e,this)})),function(e){return f.apply(this,arguments)})},{key:"next",value:(s=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(!this.stopped){e.next=3;break}return g.statusOff.call(this),e.abrupt("return",g.stopQueue.call(this));case 3:return g.logProxy.call(this,b.nextTaskLog,"next"),e.next=6,this.start();case 6:return e.abrupt("return",!0);case 7:case"end":return e.stop()}},e,this)})),function(){return s.apply(this,arguments)})},{key:"start",value:(c=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return this.stopped=!1,g.logProxy.call(this,b.queueStartLog,"start"),e.next=4,g.createTimeout.call(this);case 4:return e.t0=e.sent,this.running=0<e.t0,e.abrupt("return",this.running);case 7:case"end":return e.stop()}},e,this)})),function(){return c.apply(this,arguments)})},{key:"stop",value:function(){g.logProxy.call(this,b.queueStoppingLog,"stop"),this.stopped=!0}},{key:"forceStop",value:function(){g.stopQueue.call(this)}},{key:"status",value:function(){return this.running}},{key:"isEmpty",value:(u=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.count();case 2:return e.t0=e.sent,e.abrupt("return",e.t0<1);case 4:case"end":return e.stop()}},e,this)})),function(){return u.apply(this,arguments)})},{key:"count",value:(a=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.abrupt("return",e.sent.length);case 3:case"end":return e.stop()}},e,this)})),function(){return a.apply(this,arguments)})},{key:"countByTag",value:(i=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e.tag===t},e.abrupt("return",e.sent.filter(e.t0).length);case 4:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"clear",value:(e=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(this.name()){e.next=2;break}return e.abrupt("return",!1);case 2:return e.next=4,this.storage.clear(this.name());case 4:return e.abrupt("return",!0);case 5:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)})},{key:"clearByTag",value:(n=m(l.default.mark(function e(t){var n,r,o,i=this;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return n=this,e.next=3,g.db.call(n).all();case 3:return r=e.sent,o=r.filter(v.utilClearByTag.bind(t)).map(function(){var t=m(l.default.mark(function e(t){var r;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.db.call(n).delete(t._id);case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,i)}));return function(e){return t.apply(this,arguments)}}()),e.next=7,Promise.all(o);case 7:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"has",value:(r=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e._id===t},e.t1=e.sent.findIndex(e.t0),e.t2=-1,e.abrupt("return",e.t1>e.t2);case 6:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"hasByTag",value:(t=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e.tag===t},e.t1=e.sent.findIndex(e.t0),e.t2=-1,e.abrupt("return",e.t1>e.t2);case 6:case"end":return e.stop()}},e,this)})),function(e){return t.apply(this,arguments)})},{key:"on",value:function(e,t){var r;(r=this.event).on.apply(r,[e,t]),g.logProxy.call(this,b.eventCreatedLog,e)}}]),o}();r.default=o},{"./console":15,"./event":19,"./helpers":20,"./queue":22,"./storage-capsule":23,"./utils":24,"babel-runtime/regenerator":1}],14:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),i=e("./enum/config.data"),a=(n=i)&&n.__esModule?n:{default:n};var u=function(){function t(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.config=a.default,this.merge(e)}return o(t,[{key:"set",value:function(e,t){this.config[e]=t}},{key:"get",value:function(e){return this.config[e]}},{key:"has",value:function(e){return Object.prototype.hasOwnProperty.call(this.config,e)}},{key:"merge",value:function(e){this.config=Object.assign({},this.config,e)}},{key:"remove",value:function(e){return delete this.config[e]}},{key:"all",value:function(){return this.config}}]),t}();r.default=u},{"./enum/config.data":17}],15:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var u=function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return function(e,t){var r=[],n=!0,o=!1,i=void 0;try{for(var a,u=e[Symbol.iterator]();!(n=(a=u.next()).done)&&(r.push(a.value),!t||r.length!==t);n=!0);}catch(e){o=!0,i=e}finally{try{!n&&u.return&&u.return()}finally{if(o)throw i}}return r}(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")};r.log=c,r.taskAddedLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(43)+" ("+t.handler+") -> "+o.default.get(i.default,"queue.created"),"color: green;font-weight: bold;")},r.queueStartLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8211)+" ("+t+") -> "+o.default.get(i.default,"queue.starting"),"color: #3fa5f3;font-weight: bold;")},r.nextTaskLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(187)+" ("+t+") -> "+o.default.get(i.default,"queue.next"),"color: #3fa5f3;font-weight: bold;")},r.queueStoppingLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8226)+" ("+t+") -> "+o.default.get(i.default,"queue.stopping"),"color: #ff7f94;font-weight: bold;")},r.queueStoppedLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8226)+" ("+t+") -> "+o.default.get(i.default,"queue.stopped"),"color: #ff7f94;font-weight: bold;")},r.queueEmptyLog=function(e){c("%c"+u(e,1)[0]+" "+o.default.get(i.default,"queue.empty"),"color: #ff7f94;font-weight: bold;")},r.eventCreatedLog=function(e){c("%c("+u(e,1)[0]+") -> "+o.default.get(i.default,"event.created"),"color: #66cee3;font-weight: bold;")},r.eventFiredLog=function(e){var t=u(e,2),r=t[0],n=t[1];c("%c("+r+") -> "+o.default.get(i.default,"event."+n),"color: #a0dc3c;font-weight: bold;")},r.notFoundLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(215)+" ("+t+") -> "+o.default.get(i.default,"queue.not-found"),"color: #b92e2e;font-weight: bold;")},r.workerRunninLog=function(e){var t=u(e,5),r=t[0],n=t[1],o=t[2],i=t[3],a=t[4];console.groupCollapsed((r.name||o.handler)+" - "+o.label),c("%cchannel: "+i,"color: blue;"),c("%clabel: "+(o.label||""),"color: blue;"),c("%chandler: "+o.handler,"color: blue;"),c("%cpriority: "+o.priority,"color: blue;"),c("%cunique: "+(o.unique||"false"),"color: blue;"),c("%cretry: "+(n.retry||"1"),"color: blue;"),c("%ctried: "+(o.tried?o.tried+1:"1"),"color: blue;"),c("%ctag: "+(o.tag||""),"color: blue;"),c("%cargs:","color: blue;"),c(o.args||""),console.groupCollapsed("dependencies"),c.apply(void 0,function(e){{if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}}(a[r.name]||[])),console.groupEnd()},r.workerDoneLog=function(e){var t=u(e,3),r=t[0],n=t[1],o=t[2];!0===r?c("%c"+String.fromCharCode(10003)+" Task completed!","color: green;"):!r&&n.tried<o.retry?c("%cTask will be retried!","color: #d8410c;"):c("%c"+String.fromCharCode(10005)+" Task failed and freezed!","color: #ef6363;");console.groupEnd()},r.workerFailedLog=function(){c("%c"+String.fromCharCode(10005)+" Task failed!","color: red;"),console.groupEnd()};var o=n(e("object-path")),i=n(e("./enum/log.events"));function n(e){return e&&e.__esModule?e:{default:e}}function c(){var e;(e=console).log.apply(e,arguments)}},{"./enum/log.events":18,"object-path":4}],16:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();var o=function(){function e(){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,e),this.store={}}return n(e,[{key:"has",value:function(e){return Object.prototype.hasOwnProperty.call(this.store,e)}},{key:"get",value:function(e){return this.store[e]}},{key:"all",value:function(){return this.store}},{key:"bind",value:function(e,t){this.store[e]=t}},{key:"merge",value:function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};this.store=Object.assign({},this.store,e)}},{key:"remove",value:function(e){return!!this.has(e)&&delete this.store[e]}},{key:"removeAll",value:function(){this.store={}}}]),e}();r.default=o},{}],17:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.default={defaultStorage:"localstorage",prefix:"sq_jobs",timeout:1e3,limit:-1,principle:"fifo",debug:!0}},{}],18:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.default={queue:{created:"New task created.",next:"Next task processing.",starting:"Queue listener starting.",stopping:"Queue listener stopping.",stopped:"Queue listener stopped.",empty:"channel is empty...","not-found":"worker not found",offline:"Disconnected",online:"Connected"},event:{created:"New event created",fired:"Event fired.","wildcard-fired":"Wildcard event fired."}}},{}],19:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();var o=function(){function e(){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,e),this.store={},this.verifierPattern=/^[a-z0-9-_]+:before$|after$|retry$|\*$/,this.wildcards=["*","error"],this.emptyFunc=function(){},this.store.before={},this.store.after={},this.store.retry={},this.store.wildcard={},this.store.error=this.emptyFunc,this.store["*"]=this.emptyFunc}return n(e,[{key:"on",value:function(e,t){if("function"!=typeof t)throw new Error("Event should be an function");this.isValid(e)&&this.add(e,t)}},{key:"emit",value:function(e,t){if(-1<this.wildcards.indexOf(e))this.wildcard.apply(this,[e].concat([e,t]));else{var r=this.getType(e),n=this.getName(e);if(this.store[r])(this.store[r][n]||this.emptyFunc).call(null,t)}this.wildcard("*",e,t)}},{key:"wildcard",value:function(e,t,r){this.store.wildcard[e]&&this.store.wildcard[e].call(null,t,r)}},{key:"add",value:function(e,t){if(-1<this.wildcards.indexOf(e))this.store.wildcard[e]=t;else{var r=this.getType(e),n=this.getName(e);this.store[r][n]=t}}},{key:"has",value:function(e){try{var t=e.split(":");return 1<t.length?!!this.store[t[1]][t[0]]:!!this.store.wildcard[t[0]]}catch(e){return!1}}},{key:"getName",value:function(e){return e.match(/(.*):.*/)[1]}},{key:"getType",value:function(e){return e.match(/^[a-z0-9-_]+:(.*)/)[1]}},{key:"isValid",value:function(e){return this.verifierPattern.test(e)||-1<this.wildcards.indexOf(e)}}]),e}();r.default=o},{}],20:[function(e,t,r){"use strict";var n="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};Object.defineProperty(r,"__esModule",{value:!0}),r.canMultiple=r.createTimeout=r.successJobHandler=r.retryProcess=r.lockTask=r.failedJobHandler=r.removeTask=r.saveTask=r.getTasksWithoutFreezed=void 0;var o,i,a,u,c,s,f,l,p,h=_(e("babel-runtime/regenerator")),d="function"==typeof Symbol&&"symbol"===n(Symbol.iterator)?function(e){return void 0===e?"undefined":n(e)}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":void 0===e?"undefined":n(e)},y=(r.getTasksWithoutFreezed=(o=j(h.default.mark(function e(){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).all();case 2:return e.t0=x.excludeSpecificTasks.bind(["freezed"]),e.abrupt("return",e.sent.filter(e.t0));case 4:case"end":return e.stop()}},e,this)})),function(){return o.apply(this,arguments)}),r.saveTask=(i=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).save(P(t));case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)}),r.removeTask=(a=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).delete(t);case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return a.apply(this,arguments)})),v=r.failedJobHandler=(u=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",function(){var e=j(h.default.mark(function e(){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return y.call(this,t._id),this.event.emit("error",t),T.call(this,k.workerFailedLog),e.next=5,this.next();case 5:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}());case 1:case"end":return e.stop()}},e,this)})),function(e){return u.apply(this,arguments)}),g=r.lockTask=(c=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).update(t._id,{locked:!0});case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return c.apply(this,arguments)}),b=r.retryProcess=(s=j(h.default.mark(function e(t,r){var n,o;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return L.call(this,t,"retry"),(n=M.call(this,t,r)).locked=!1,e.next=5,S.call(this).update(t._id,n);case 5:return o=e.sent,e.abrupt("return",o);case 7:case"end":return e.stop()}},e,this)})),function(e,t){return s.apply(this,arguments)}),m=r.successJobHandler=(f=j(h.default.mark(function e(r,n){var o;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return o=this,e.abrupt("return",function(){var t=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(!t){e.next=4;break}C.call(o,r),e.next=6;break;case 4:return e.next=6,b.call(o,r,n);case 6:return A.call(o,"after",n,r.args),L.call(o,r,"after"),T.call(o,k.workerDoneLog,t,r,n),e.next=11,o.next();case 11:case"end":return e.stop()}},e,this)}));return function(e){return t.apply(this,arguments)}}());case 2:case"end":return e.stop()}},e,this)})),function(e,t){return f.apply(this,arguments)});r.createTimeout=(l=j(h.default.mark(function e(){var t,r,n,o,i,a;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return clearTimeout(this.currentTimeout),e.next=3,S.call(this).fetch();case 3:if(void 0!==(t=e.sent.shift())){e.next=8;break}return T.call(this,k.queueEmptyLog,this.name()),E.call(this),e.abrupt("return",1);case 8:if(w.default.worker.has(t.handler)){e.next=16;break}return T.call(this,k.notFoundLog,t.handler),e.next=12,v.call(this,t);case 12:return e.t0=this,e.next=15,e.sent.call(e.t0);case 15:return e.abrupt("return",1);case 16:return r=w.default.worker.get(t.handler),n="object"===(void 0===r?"undefined":d(r))?new Worker(r.uri):new r,o=this.config.get("timeout"),i=[t,r,n],e.next=22,q.call.apply(q,[this].concat(i));case 22:return e.t1=this,a=e.sent.bind(e.t1),this.currentTimeout=setTimeout(a,o),e.abrupt("return",this.currentTimeout);case 26:case"end":return e.stop()}},e,this)})),function(){return l.apply(this,arguments)}),r.canMultiple=(p=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if("object"===(void 0===t?"undefined":d(t))&&!0===t.unique){e.next=2;break}return e.abrupt("return",!0);case 2:return e.next=4,this.hasByTag(t.tag);case 4:return e.t0=e.sent,e.abrupt("return",!1===e.t0);case 6:case"end":return e.stop()}},e,this)})),function(e){return p.apply(this,arguments)});r.checkPriority=P,r.db=S,r.logProxy=T,r.dispatchEvents=L,r.stopQueue=E,r.fireJobInlineEvent=A,r.successProcess=C,r.updateRetry=M,r.loopHandler=q,r.statusOff=function(){this.running=!1};var w=_(e("./queue")),x=(_(e("./channel")),_(e("./storage-capsule")),e("./utils")),k=e("./console");function _(e){return e&&e.__esModule?e:{default:e}}function O(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function j(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}function P(e){return e.priority=e.priority||0,"number"!=typeof e.priority&&(e.priority=0),e}function S(){return this.storage.channel(this.name())}function T(e){if(this.config.get("debug")&&"function"==typeof e){for(var t=arguments.length,r=Array(1<t?t-1:0),n=1;n<t;n++)r[n-1]=arguments[n];e(r)}}function L(t,e){var r=this;return"tag"in t&&([[t.tag+":"+e,"fired"],[t.tag+":*","wildcard-fired"]].forEach(function(e){r.event.emit(e[0],t),T.call.apply(T,[r,k.eventFiredLog].concat(O(e)))}),!0)}function E(){this.stop(),clearTimeout(this.currentTimeout),T.call(this,k.queueStoppedLog,"stop")}function A(e,t,r){return!(!(0,x.hasMethod)(t,e)||!(0,x.isFunction)(t[e]))&&(t[e].call(t,r),!0)}function C(e){y.call(this,e._id)}function M(e,t){return"retry"in t||(t.retry=1),"tried"in e||(e.tried=0,e.retry=t.retry),e.tried+=1,e.tried>=t.retry&&(e.freezed=!0),e}function q(a,u,c){return e=j(h.default.mark(function e(){var t,r,n,o,i;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=void 0,r=this,e.next=4,g.call(r,a);case 4:return A.call(this,"before",c,a.args),L.call(this,a,"before"),n=w.default.workerDeps[a.handler],o=Object.values(n||{}),T.call(this,k.workerRunninLog,u,c,a,r.name(),w.default.workerDeps),c instanceof Worker?(c.postMessage({args:a.args,dependencies:o}),t=new Promise(function(t){c.onmessage=function(e){t(u.handler(e)),c.terminate()}})):t=(i=c.handle).call.apply(i,[c,a.args].concat(O(o))),e.t1=t,e.next=13,m.call(r,a,c);case 13:return e.t2=r,e.t3=e.sent.bind(e.t2),e.t0=e.t1.then.call(e.t1,e.t3),e.next=18,v.call(r,a);case 18:e.t4=r,e.t5=e.sent.bind(e.t4),e.t0.catch.call(e.t0,e.t5);case 21:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)};var e}},{"./channel":13,"./console":15,"./queue":22,"./storage-capsule":23,"./utils":24,"babel-runtime/regenerator":1}],21:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),e("pseudo-worker/polyfill");var n,o=e("./queue"),i=(n=o)&&n.__esModule?n:{default:n};"undefined"!=typeof window&&(window.Queue=i.default),r.default=i.default},{"./queue":22,"pseudo-worker/polyfill":6}],22:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e};r.default=c;var o=u(e("./channel")),i=u(e("./container")),a=u(e("./config"));function u(e){return e&&e.__esModule?e:{default:e}}function c(e){this.config=new a.default(e)}c.FIFO="fifo",c.LIFO="lifo",c.drivers={},c.workerDeps={},c.worker=new i.default,c.prototype.container=new i.default,c.prototype.create=function(e){return this.container.has(e)||this.container.bind(e,new o.default(e,this.config)),this.container.get(e)},c.prototype.channel=function(e){if(!this.container.has(e))throw new Error('"'+e+'" channel not found');return this.container.get(e)},c.prototype.setTimeout=function(e){this.config.set("timeout",e)},c.prototype.setLimit=function(e){this.config.set("limit",e)},c.prototype.setPrefix=function(e){this.config.set("prefix",e)},c.prototype.setPrinciple=function(e){this.config.set("principle",e)},c.prototype.setDebug=function(e){this.config.set("debug",e)},c.prototype.setStorage=function(e){this.config.set("storage",e)},c.workers=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};if(!(e instanceof Object))throw new Error("The parameters should be object.");c.worker.merge(e)},c.deps=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};if(!(e instanceof Object))throw new Error("The parameters should be object.");c.workerDeps=e},c.use=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};c.drivers=n({},c.drivers,e)}},{"./channel":13,"./config":14,"./container":16}],23:[function(e,t,r){"use strict";var n="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};Object.defineProperty(r,"__esModule",{value:!0});var c=o(e("babel-runtime/regenerator")),s=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},f="function"==typeof Symbol&&"symbol"===n(Symbol.iterator)?function(e){return void 0===e?"undefined":n(e)}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":void 0===e?"undefined":n(e)},l=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),p=o(e("group-by")),h=e("./adapters"),d=e("./utils");function o(e){return e&&e.__esModule?e:{default:e}}function y(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function r(e,t){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,r),this.config=e,this.storage=this.initialize(t)}var t,e,n,o,i,a,u;return l(r,[{key:"initialize",value:function(e){return"object"===(void 0===e?"undefined":f(e))?e:"function"==typeof e?new e(this.config):"localstorage"===this.config.get("storage")?new h.LocalStorageAdapter(this.config):new h.InMemoryAdapter(this.config)}},{key:"channel",value:function(e){return this.storageChannel=e,this}},{key:"fetch",value:(u=y(c.default.mark(function e(){var t,r;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:return e.t0=d.excludeSpecificTasks,t=e.sent.filter(e.t0),r=(0,p.default)(t,"priority"),e.abrupt("return",Object.keys(r).map(function(e){return parseInt(e,10)}).sort(function(e,t){return t-e}).reduce(this.reduceTasks(r),[]));case 6:case"end":return e.stop()}},e,this)})),function(){return u.apply(this,arguments)})},{key:"save",value:(a=y(c.default.mark(function e(t){var r,n;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if("object"===(void 0===t?"undefined":f(t))){e.next=2;break}return e.abrupt("return",!1);case 2:return e.next=4,this.storage.get(this.storageChannel);case 4:return r=e.sent,e.next=7,this.isExceeded();case 7:if(!e.sent){e.next=10;break}return console.warn("Task limit exceeded: The '"+this.storageChannel+"' channel limit is "+this.config.get("limit")),e.abrupt("return",!1);case 10:return n=this.prepareTask(t),r.push(n),e.next=14,this.storage.set(this.storageChannel,r);case 14:return e.abrupt("return",n._id);case 15:case"end":return e.stop()}},e,this)})),function(e){return a.apply(this,arguments)})},{key:"update",value:(i=y(c.default.mark(function e(t,r){var n,o;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:if(n=e.sent,!((o=n.findIndex(function(e){return e._id===t}))<0)){e.next=6;break}return e.abrupt("return",!1);case 6:return n[o]=Object.assign({},n[o],r),e.next=9,this.storage.set(this.storageChannel,n);case 9:return e.abrupt("return",!0);case 10:case"end":return e.stop()}},e,this)})),function(e,t){return i.apply(this,arguments)})},{key:"delete",value:(o=y(c.default.mark(function e(t){var r,n;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:if(r=e.sent,!((n=r.findIndex(function(e){return e._id===t}))<0)){e.next=6;break}return e.abrupt("return",!1);case 6:return delete r[n],e.next=9,this.storage.set(this.storageChannel,r.filter(function(e){return e}));case 9:return e.abrupt("return",!0);case 10:case"end":return e.stop()}},e,this)})),function(e){return o.apply(this,arguments)})},{key:"all",value:(n=y(c.default.mark(function e(){var t;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.storage.get(this.storageChannel);case 2:return t=e.sent,e.abrupt("return",t);case 4:case"end":return e.stop()}},e,this)})),function(){return n.apply(this,arguments)})},{key:"generateId",value:function(){return(65536*(1+Math.random())).toString(16)}},{key:"prepareTask",value:function(e){var t=s({},e);return t.createdAt=Date.now(),t._id=this.generateId(),t}},{key:"reduceTasks",value:function(r){var n=this;return function(e,t){return"lifo"===n.config.get("principle")?e.concat(r[t].sort(d.lifo)):e.concat(r[t].sort(d.fifo))}.bind(this)}},{key:"isExceeded",value:(e=y(c.default.mark(function e(){var t,r;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=this.config.get("limit"),e.next=3,this.all();case 3:return e.t0=d.excludeSpecificTasks,r=e.sent.filter(e.t0),e.abrupt("return",!(-1===t||t>r.length));case 6:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)})},{key:"clear",value:(t=y(c.default.mark(function e(t){return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.storage.clear(t);case 2:case"end":return e.stop()}},e,this)})),function(e){return t.apply(this,arguments)})}]),r}();r.default=i},{"./adapters":10,"./utils":24,"babel-runtime/regenerator":1,"group-by":3}],24:[function(e,t,r){"use strict";function n(e,t){return Object.prototype.hasOwnProperty.call(e,t)}function o(t){var e=Array.isArray(this)?this:["freezed","locked"],r=[];return e.forEach(function(e){r.push(!1===n(t,e)||!1===t[e])}),!(-1<r.indexOf(!1))}Object.defineProperty(r,"__esModule",{value:!0}),r.hasProperty=n,r.hasMethod=function(e,t){return e instanceof Object&&t in e},r.isFunction=function(e){return e instanceof Function},r.excludeSpecificTasks=o,r.utilClearByTag=function(e){if(!o.call(["locked"],e))return!1;return e.tag===this},r.fifo=function(e,t){return e.createdAt-t.createdAt},r.lifo=function(e,t){return t.createdAt-e.createdAt}},{}]},{},[21]); | ||
| !function i(a,u,c){function s(t,e){if(!u[t]){if(!a[t]){var r="function"==typeof require&&require;if(!e&&r)return r(t,!0);if(f)return f(t,!0);var n=new Error("Cannot find module '"+t+"'");throw n.code="MODULE_NOT_FOUND",n}var o=u[t]={exports:{}};a[t][0].call(o.exports,function(e){return s(a[t][1][e]||e)},o,o.exports,i,a,u,c)}return u[t].exports}for(var f="function"==typeof require&&require,e=0;e<c.length;e++)s(c[e]);return s}({1:[function(e,t,r){t.exports=e("regenerator-runtime")},{"regenerator-runtime":7}],2:[function(e,t,r){var a=/\b(Array|Date|Object|Math|JSON)\b/g;t.exports=function(e,t){var r,n,o,i=function(e){for(var t=[],r=0;r<e.length;r++)~t.indexOf(e[r])||t.push(e[r]);return t}(e.replace(/\.\w+|\w+ *\(|"[^"]*"|'[^']*'|\/([^/]+)\//g,"").replace(a,"").match(/[a-zA-Z_]\w*/g)||[]);return t&&"string"==typeof t&&(r=t,t=function(e){return r+e}),t?(n=i,o=t,e.replace(/\.\w+|\w+ *\(|"[^"]*"|'[^']*'|\/([^/]+)\/|[a-zA-Z_]\w*/g,function(e){return"("==e[e.length-1]?o(e):~n.indexOf(e)?o(e):e})):i}},{}],3:[function(e,t,r){var i=e("to-function");t.exports=function(e,t){var r,n={};t=i(t);for(var o=0;o<e.length;++o)n[r=t(e[o],o)]=n[r]||[],n[r].push(e[o]);return n}},{"to-function":9}],4:[function(e,r,t){!function(e,t){"use strict";"object"==typeof r&&"object"==typeof r.exports?r.exports=t():"function"==typeof define&&define.amd?define([],t):e.objectPath=t()}(this,function(){"use strict";var t=Object.prototype.toString;function i(e,t){return null!=e&&Object.prototype.hasOwnProperty.call(e,t)}function f(e){if(!e)return!0;if(p(e)&&0===e.length)return!0;if("string"!=typeof e){for(var t in e)if(i(e,t))return!1;return!0}return!1}function l(e){return t.call(e)}var p=Array.isArray||function(e){return"[object Array]"===t.call(e)};function h(e){var t=parseInt(e);return t.toString()===e?t:e}function e(o){o=o||{};var a=function(r){return Object.keys(a).reduce(function(e,t){return"create"===t||"function"==typeof a[t]&&(e[t]=a[t].bind(a,r)),e},{})};function u(e,t){return o.includeInheritedProps||"number"==typeof t&&Array.isArray(e)||i(e,t)}function c(e,t){if(u(e,t))return e[t]}function s(e,t,r,n){if("number"==typeof t&&(t=[t]),!t||0===t.length)return e;if("string"==typeof t)return s(e,t.split(".").map(h),r,n);var o=t[0],i=c(e,o);return 1===t.length?(void 0!==i&&n||(e[o]=r),i):(void 0===i&&("number"==typeof t[1]?e[o]=[]:e[o]={}),s(e[o],t.slice(1),r,n))}return a.has=function(e,t){if("number"==typeof t?t=[t]:"string"==typeof t&&(t=t.split(".")),!t||0===t.length)return!!e;for(var r=0;r<t.length;r++){var n=h(t[r]);if(!("number"==typeof n&&p(e)&&n<e.length||(o.includeInheritedProps?n in Object(e):i(e,n))))return!1;e=e[n]}return!0},a.ensureExists=function(e,t,r){return s(e,t,r,!0)},a.set=function(e,t,r,n){return s(e,t,r,n)},a.insert=function(e,t,r,n){var o=a.get(e,t);n=~~n,p(o)||(o=[],a.set(e,t,o)),o.splice(n,0,r)},a.empty=function(e,t){var r,n;if(!f(t)&&(null!=e&&(r=a.get(e,t)))){if("string"==typeof r)return a.set(e,t,"");if("boolean"==typeof(i=r)||"[object Boolean]"===l(i))return a.set(e,t,!1);if("number"==typeof r)return a.set(e,t,0);if(p(r))r.length=0;else{if("object"!=typeof(o=r)||"[object Object]"!==l(o))return a.set(e,t,null);for(n in r)u(r,n)&&delete r[n]}var o,i}},a.push=function(e,t){var r=a.get(e,t);p(r)||(r=[],a.set(e,t,r)),r.push.apply(r,Array.prototype.slice.call(arguments,2))},a.coalesce=function(e,t,r){for(var n,o=0,i=t.length;o<i;o++)if(void 0!==(n=a.get(e,t[o])))return n;return r},a.get=function(e,t,r){if("number"==typeof t&&(t=[t]),!t||0===t.length)return e;if(null==e)return r;if("string"==typeof t)return a.get(e,t.split("."),r);var n=h(t[0]),o=c(e,n);return void 0===o?r:1===t.length?o:a.get(e[n],t.slice(1),r)},a.del=function(e,t){if("number"==typeof t&&(t=[t]),null==e)return e;if(f(t))return e;if("string"==typeof t)return a.del(e,t.split("."));var r=h(t[0]);return u(e,r)?1!==t.length?a.del(e[r],t.slice(1)):(p(e)?e.splice(r,1):delete e[r],e):e},a}var r=e();return r.create=e,r.withInheritedProps=e({includeInheritedProps:!0}),r})},{}],5:[function(require,module,exports){(function(global){"use strict";function doEval(self,__pseudoworker_script){(function(){eval(__pseudoworker_script)}).call(global)}function PseudoWorker(r){var n,o,i=[],a=[],u=[],c=[],s=[],f=!1,l=this;function p(e,t){for(var r=-1;++r<e.length;)e[r]&&t(e[r])}function h(e){var t,r=(t=e,function(e){e({type:"error",error:t,message:t.message})});"function"==typeof l.onerror&&r(l.onerror),o&&"function"==typeof o.onerror&&r(o.onerror),p(a,r),p(c,r)}function d(t){function e(e){try{e({data:t})}catch(e){h(e)}}o&&"function"==typeof o.onmessage&&e(o.onmessage),p(u,e)}function y(){f=!0}function v(t){function e(e){e({data:t})}f||("function"==typeof l.onmessage&&e(l.onmessage),p(i,e))}function g(e,t){"message"===e?u.push(t):"error"===e&&c.push(t)}var b=new XMLHttpRequest;return b.open("GET",r),b.onreadystatechange=function(){if(4===b.readyState)if(200<=b.status&&b.status<400){n=b.responseText,doEval(o={postMessage:v,addEventListener:g,close:y},n);var e=s;s=[];for(var t=0;t<e.length;t++)d(e[t])}else h(new Error("cannot find script "+r))},b.send(),l.postMessage=function(e){if(void 0===e)throw new Error("postMessage() requires an argument");f||(n?d(e):s.push(e))},l.addEventListener=function(e,t){"message"===e?i.push(t):"error"===e&&a.push(t)},l.removeEventListener=function(e,t){var r;if("message"===e)r=i;else{if("error"!==e)return;r=a}for(var n=-1;++n<r.length;)if(r[n]===t){delete r[n];break}},l.terminate=y,l}module.exports=PseudoWorker}).call(this,"undefined"!=typeof global?global:"undefined"!=typeof self?self:"undefined"!=typeof window?window:{})},{}],6:[function(r,n,e){(function(e){"use strict";var t=r("./");"undefined"==typeof Worker&&(e.Worker=t),n.exports=t}).call(this,"undefined"!=typeof global?global:"undefined"!=typeof self?self:"undefined"!=typeof window?window:{})},{"./":5}],7:[function(e,t,r){var n=function(){return this}()||Function("return this")(),o=n.regeneratorRuntime&&0<=Object.getOwnPropertyNames(n).indexOf("regeneratorRuntime"),i=o&&n.regeneratorRuntime;if(n.regeneratorRuntime=void 0,t.exports=e("./runtime"),o)n.regeneratorRuntime=i;else try{delete n.regeneratorRuntime}catch(e){n.regeneratorRuntime=void 0}},{"./runtime":8}],8:[function(e,C,t){!function(e){"use strict";var c,t=Object.prototype,s=t.hasOwnProperty,r="function"==typeof Symbol?Symbol:{},o=r.iterator||"@@iterator",n=r.asyncIterator||"@@asyncIterator",i=r.toStringTag||"@@toStringTag",a="object"==typeof C,u=e.regeneratorRuntime;if(u)a&&(C.exports=u);else{(u=e.regeneratorRuntime=a?C.exports:{}).wrap=m;var l="suspendedStart",p="suspendedYield",h="executing",d="completed",y={},f={};f[o]=function(){return this};var v=Object.getPrototypeOf,g=v&&v(v(E([])));g&&g!==t&&s.call(g,o)&&(f=g);var b=_.prototype=x.prototype=Object.create(f);k.prototype=b.constructor=_,_.constructor=k,_[i]=k.displayName="GeneratorFunction",u.isGeneratorFunction=function(e){var t="function"==typeof e&&e.constructor;return!!t&&(t===k||"GeneratorFunction"===(t.displayName||t.name))},u.mark=function(e){return Object.setPrototypeOf?Object.setPrototypeOf(e,_):(e.__proto__=_,i in e||(e[i]="GeneratorFunction")),e.prototype=Object.create(b),e},u.awrap=function(e){return{__await:e}},O(j.prototype),j.prototype[n]=function(){return this},u.AsyncIterator=j,u.async=function(e,t,r,n){var o=new j(m(e,t,r,n));return u.isGeneratorFunction(t)?o:o.next().then(function(e){return e.done?e.value:o.next()})},O(b),b[i]="Generator",b[o]=function(){return this},b.toString=function(){return"[object Generator]"},u.keys=function(r){var n=[];for(var e in r)n.push(e);return n.reverse(),function e(){for(;n.length;){var t=n.pop();if(t in r)return e.value=t,e.done=!1,e}return e.done=!0,e}},u.values=E,L.prototype={constructor:L,reset:function(e){if(this.prev=0,this.next=0,this.sent=this._sent=c,this.done=!1,this.delegate=null,this.method="next",this.arg=c,this.tryEntries.forEach(T),!e)for(var t in this)"t"===t.charAt(0)&&s.call(this,t)&&!isNaN(+t.slice(1))&&(this[t]=c)},stop:function(){this.done=!0;var e=this.tryEntries[0].completion;if("throw"===e.type)throw e.arg;return this.rval},dispatchException:function(r){if(this.done)throw r;var n=this;function e(e,t){return i.type="throw",i.arg=r,n.next=e,t&&(n.method="next",n.arg=c),!!t}for(var t=this.tryEntries.length-1;0<=t;--t){var o=this.tryEntries[t],i=o.completion;if("root"===o.tryLoc)return e("end");if(o.tryLoc<=this.prev){var a=s.call(o,"catchLoc"),u=s.call(o,"finallyLoc");if(a&&u){if(this.prev<o.catchLoc)return e(o.catchLoc,!0);if(this.prev<o.finallyLoc)return e(o.finallyLoc)}else if(a){if(this.prev<o.catchLoc)return e(o.catchLoc,!0)}else{if(!u)throw new Error("try statement without catch or finally");if(this.prev<o.finallyLoc)return e(o.finallyLoc)}}}},abrupt:function(e,t){for(var r=this.tryEntries.length-1;0<=r;--r){var n=this.tryEntries[r];if(n.tryLoc<=this.prev&&s.call(n,"finallyLoc")&&this.prev<n.finallyLoc){var o=n;break}}o&&("break"===e||"continue"===e)&&o.tryLoc<=t&&t<=o.finallyLoc&&(o=null);var i=o?o.completion:{};return i.type=e,i.arg=t,o?(this.method="next",this.next=o.finallyLoc,y):this.complete(i)},complete:function(e,t){if("throw"===e.type)throw e.arg;return"break"===e.type||"continue"===e.type?this.next=e.arg:"return"===e.type?(this.rval=this.arg=e.arg,this.method="return",this.next="end"):"normal"===e.type&&t&&(this.next=t),y},finish:function(e){for(var t=this.tryEntries.length-1;0<=t;--t){var r=this.tryEntries[t];if(r.finallyLoc===e)return this.complete(r.completion,r.afterLoc),T(r),y}},catch:function(e){for(var t=this.tryEntries.length-1;0<=t;--t){var r=this.tryEntries[t];if(r.tryLoc===e){var n=r.completion;if("throw"===n.type){var o=n.arg;T(r)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(e,t,r){return this.delegate={iterator:E(e),resultName:t,nextLoc:r},"next"===this.method&&(this.arg=c),y}}}function m(e,t,r,n){var i,a,u,c,o=t&&t.prototype instanceof x?t:x,s=Object.create(o.prototype),f=new L(n||[]);return s._invoke=(i=e,a=r,u=f,c=l,function(e,t){if(c===h)throw new Error("Generator is already running");if(c===d){if("throw"===e)throw t;return A()}for(u.method=e,u.arg=t;;){var r=u.delegate;if(r){var n=P(r,u);if(n){if(n===y)continue;return n}}if("next"===u.method)u.sent=u._sent=u.arg;else if("throw"===u.method){if(c===l)throw c=d,u.arg;u.dispatchException(u.arg)}else"return"===u.method&&u.abrupt("return",u.arg);c=h;var o=w(i,a,u);if("normal"===o.type){if(c=u.done?d:p,o.arg===y)continue;return{value:o.arg,done:u.done}}"throw"===o.type&&(c=d,u.method="throw",u.arg=o.arg)}}),s}function w(e,t,r){try{return{type:"normal",arg:e.call(t,r)}}catch(e){return{type:"throw",arg:e}}}function x(){}function k(){}function _(){}function O(e){["next","throw","return"].forEach(function(t){e[t]=function(e){return this._invoke(t,e)}})}function j(c){var t;this._invoke=function(r,n){function e(){return new Promise(function(e,t){!function t(e,r,n,o){var i=w(c[e],c,r);if("throw"!==i.type){var a=i.arg,u=a.value;return u&&"object"==typeof u&&s.call(u,"__await")?Promise.resolve(u.__await).then(function(e){t("next",e,n,o)},function(e){t("throw",e,n,o)}):Promise.resolve(u).then(function(e){a.value=e,n(a)},o)}o(i.arg)}(r,n,e,t)})}return t=t?t.then(e,e):e()}}function P(e,t){var r=e.iterator[t.method];if(r===c){if(t.delegate=null,"throw"===t.method){if(e.iterator.return&&(t.method="return",t.arg=c,P(e,t),"throw"===t.method))return y;t.method="throw",t.arg=new TypeError("The iterator does not provide a 'throw' method")}return y}var n=w(r,e.iterator,t.arg);if("throw"===n.type)return t.method="throw",t.arg=n.arg,t.delegate=null,y;var o=n.arg;return o?o.done?(t[e.resultName]=o.value,t.next=e.nextLoc,"return"!==t.method&&(t.method="next",t.arg=c),t.delegate=null,y):o:(t.method="throw",t.arg=new TypeError("iterator result is not an object"),t.delegate=null,y)}function S(e){var t={tryLoc:e[0]};1 in e&&(t.catchLoc=e[1]),2 in e&&(t.finallyLoc=e[2],t.afterLoc=e[3]),this.tryEntries.push(t)}function T(e){var t=e.completion||{};t.type="normal",delete t.arg,e.completion=t}function L(e){this.tryEntries=[{tryLoc:"root"}],e.forEach(S,this),this.reset(!0)}function E(t){if(t){var e=t[o];if(e)return e.call(t);if("function"==typeof t.next)return t;if(!isNaN(t.length)){var r=-1,n=function e(){for(;++r<t.length;)if(s.call(t,r))return e.value=t[r],e.done=!1,e;return e.value=c,e.done=!0,e};return n.next=n}}return{next:A}}function A(){return{value:c,done:!0}}}(function(){return this}()||Function("return this")())},{}],9:[function(t,e,r){var i;try{i=t("props")}catch(e){i=t("component-props")}function n(e){switch({}.toString.call(e)){case"[object Object]":return function(e){var r={};for(var t in e)r[t]="string"==typeof e[t]?o(e[t]):n(e[t]);return function(e){if("object"!=typeof e)return!1;for(var t in r){if(!(t in e))return!1;if(!r[t](e[t]))return!1}return!0}}(e);case"[object Function]":return e;case"[object String]":return/^ *\W+/.test(r=e)?new Function("_","return _ "+r):new Function("_","return "+function(e){var t,r,n,o=i(e);if(!o.length)return"_."+e;for(r=0;r<o.length;r++)n=o[r],e=a(n,e,t="('function' == typeof "+(t="_."+n)+" ? "+t+"() : "+t+")");return e}(r));case"[object RegExp]":return t=e,function(e){return t.test(e)};default:return o(e)}var t,r}function o(t){return function(e){return t===e}}function a(e,t,r){return t.replace(new RegExp("(\\.)?"+e,"g"),function(e,t){return t?e:r})}e.exports=n},{"component-props":2,props:2}],10:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.LocalStorageAdapter=r.InMemoryAdapter=void 0;var n=i(e("./inmemory")),o=i(e("./localstorage"));function i(e){return e&&e.__esModule?e:{default:e}}r.InMemoryAdapter=n.default,r.LocalStorageAdapter=o.default},{"./inmemory":11,"./localstorage":12}],11:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=e("babel-runtime/regenerator"),a=(n=o)&&n.__esModule?n:{default:n},u=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},c=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();function s(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function f(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function t(e){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.store={},this.config=e,this.prefix=this.config.get("prefix")}var r,n,o,i;return c(t,[{key:"get",value:(i=f(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return r=this.storageName(t),e.abrupt("return",[].concat(s(this.getCollection(r))));case 2:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"set",value:(o=f(a.default.mark(function e(t,r){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return this.store[this.storageName(t)]=[].concat(s(r)),e.abrupt("return",r);case 2:case"end":return e.stop()}},e,this)})),function(e,t){return o.apply(this,arguments)})},{key:"has",value:(n=f(a.default.mark(function e(t){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",Object.prototype.hasOwnProperty.call(this.store,this.storageName(t)));case 1:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"clear",value:(r=f(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.has(t);case 2:if(!e.sent){e.next=6;break}e.t0=delete this.store[this.storageName(t)],e.next=7;break;case 6:e.t0=!1;case 7:return r=e.t0,this.store=u({},this.store),e.abrupt("return",r);case 10:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"storageName",value:function(e){return e.startsWith(this.getPrefix())?e:this.getPrefix()+"_"+e}},{key:"getPrefix",value:function(){return this.config.get("prefix")}},{key:"getCollection",value:function(e){return Object.prototype.hasOwnProperty.call(this.store,e)||(this.store[e]=[]),this.store[e]}}]),t}();r.default=i},{"babel-runtime/regenerator":1}],12:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=e("babel-runtime/regenerator"),a=(n=o)&&n.__esModule?n:{default:n},u=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();function c(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function t(e){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.config=e,this.prefix=this.config.get("prefix")}var r,n,o,i;return u(t,[{key:"get",value:(i=c(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return r=localStorage.getItem(this.storageName(t)),e.abrupt("return",JSON.parse(r)||[]);case 2:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"set",value:(o=c(a.default.mark(function e(t,r){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return localStorage.setItem(this.storageName(t),JSON.stringify(r)),e.abrupt("return",r);case 2:case"end":return e.stop()}},e,this)})),function(e,t){return o.apply(this,arguments)})},{key:"has",value:(n=c(a.default.mark(function e(t){return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",Object.prototype.hasOwnProperty.call(localStorage,this.storageName(t)));case 1:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"clear",value:(r=c(a.default.mark(function e(t){var r;return a.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.has(t);case 2:if(!e.sent){e.next=6;break}e.t0=delete localStorage[this.storageName(t)],e.next=7;break;case 6:e.t0=!1;case 7:return r=e.t0,e.abrupt("return",r);case 9:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"storageName",value:function(e){return e.startsWith(this.getPrefix())?e:this.getPrefix()+"_"+e}},{key:"getPrefix",value:function(){return this.config.get("prefix")}}]),t}();r.default=i},{"babel-runtime/regenerator":1}],13:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var l=n(e("babel-runtime/regenerator")),p=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),h=n(e("./event")),d=n(e("./storage-capsule")),y=n(e("./queue")),v=e("./utils"),g=e("./helpers"),b=e("./console");function n(e){return e&&e.__esModule?e:{default:e}}function m(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var w=Symbol("channel-name"),o=function(){function o(e,t){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,o),this.stopped=!0,this.running=!1,this.event=new h.default,this.config=t,this[w]=e;var r=y.default.drivers,n=new d.default(t,r.storage);this.storage=n.channel(e)}var t,r,n,e,i,a,u,c,s,f;return p(o,[{key:"name",value:function(){return this[w]}},{key:"add",value:(f=m(l.default.mark(function e(t){var r;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.canMultiple.call(this,t);case 2:if(e.sent){e.next=4;break}return e.abrupt("return",!1);case 4:return e.next=6,g.saveTask.call(this,t);case 6:if(!(r=e.sent)||!this.stopped||!0!==this.running){e.next=10;break}return e.next=10,this.start();case 10:return g.logProxy.call(this,b.taskAddedLog,t),e.abrupt("return",r);case 12:case"end":return e.stop()}},e,this)})),function(e){return f.apply(this,arguments)})},{key:"next",value:(s=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(!this.stopped){e.next=3;break}return g.statusOff.call(this),e.abrupt("return",g.stopQueue.call(this));case 3:return g.logProxy.call(this,b.nextTaskLog,"next"),e.next=6,this.start();case 6:return e.abrupt("return",!0);case 7:case"end":return e.stop()}},e,this)})),function(){return s.apply(this,arguments)})},{key:"start",value:(c=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return this.stopped=!1,g.logProxy.call(this,b.queueStartLog,"start"),e.next=4,g.createTimeout.call(this);case 4:return e.t0=e.sent,this.running=0<e.t0,e.abrupt("return",this.running);case 7:case"end":return e.stop()}},e,this)})),function(){return c.apply(this,arguments)})},{key:"stop",value:function(){g.logProxy.call(this,b.queueStoppingLog,"stop"),this.stopped=!0}},{key:"forceStop",value:function(){g.stopQueue.call(this)}},{key:"status",value:function(){return this.running}},{key:"isEmpty",value:(u=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.count();case 2:return e.t0=e.sent,e.abrupt("return",e.t0<1);case 4:case"end":return e.stop()}},e,this)})),function(){return u.apply(this,arguments)})},{key:"count",value:(a=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.abrupt("return",e.sent.length);case 3:case"end":return e.stop()}},e,this)})),function(){return a.apply(this,arguments)})},{key:"countByTag",value:(i=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e.tag===t},e.abrupt("return",e.sent.filter(e.t0).length);case 4:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)})},{key:"clear",value:(e=m(l.default.mark(function e(){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(this.name()){e.next=2;break}return e.abrupt("return",!1);case 2:return e.next=4,this.storage.clear(this.name());case 4:return e.abrupt("return",!0);case 5:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)})},{key:"clearByTag",value:(n=m(l.default.mark(function e(t){var n,r,o,i=this;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return n=this,e.next=3,g.db.call(n).all();case 3:return r=e.sent,o=r.filter(v.utilClearByTag.bind(t)).map(function(){var t=m(l.default.mark(function e(t){var r;return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.db.call(n).delete(t._id);case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,i)}));return function(e){return t.apply(this,arguments)}}()),e.next=7,Promise.all(o);case 7:case"end":return e.stop()}},e,this)})),function(e){return n.apply(this,arguments)})},{key:"has",value:(r=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e._id===t},e.t1=e.sent.findIndex(e.t0),e.t2=-1,e.abrupt("return",e.t1>e.t2);case 6:case"end":return e.stop()}},e,this)})),function(e){return r.apply(this,arguments)})},{key:"hasByTag",value:(t=m(l.default.mark(function e(t){return l.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,g.getTasksWithoutFreezed.call(this);case 2:return e.t0=function(e){return e.tag===t},e.t1=e.sent.findIndex(e.t0),e.t2=-1,e.abrupt("return",e.t1>e.t2);case 6:case"end":return e.stop()}},e,this)})),function(e){return t.apply(this,arguments)})},{key:"on",value:function(e,t){var r;(r=this.event).on.apply(r,[e,t]),g.logProxy.call(this,b.eventCreatedLog,e)}}]),o}();r.default=o},{"./console":15,"./event":19,"./helpers":20,"./queue":22,"./storage-capsule":23,"./utils":24,"babel-runtime/regenerator":1}],14:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n,o=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),i=e("./enum/config.data"),a=(n=i)&&n.__esModule?n:{default:n};var u=function(){function t(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,t),this.config=a.default,this.merge(e)}return o(t,[{key:"set",value:function(e,t){this.config[e]=t}},{key:"get",value:function(e){return this.config[e]}},{key:"has",value:function(e){return Object.prototype.hasOwnProperty.call(this.config,e)}},{key:"merge",value:function(e){this.config=Object.assign({},this.config,e)}},{key:"remove",value:function(e){return delete this.config[e]}},{key:"all",value:function(){return this.config}}]),t}();r.default=u},{"./enum/config.data":17}],15:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var u=function(e,t){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return function(e,t){var r=[],n=!0,o=!1,i=void 0;try{for(var a,u=e[Symbol.iterator]();!(n=(a=u.next()).done)&&(r.push(a.value),!t||r.length!==t);n=!0);}catch(e){o=!0,i=e}finally{try{!n&&u.return&&u.return()}finally{if(o)throw i}}return r}(e,t);throw new TypeError("Invalid attempt to destructure non-iterable instance")};r.log=c,r.taskAddedLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(43)+" ("+t.handler+") -> "+o.default.get(i.default,"queue.created"),"color: green;font-weight: bold;")},r.queueStartLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8211)+" ("+t+") -> "+o.default.get(i.default,"queue.starting"),"color: #3fa5f3;font-weight: bold;")},r.nextTaskLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(187)+" ("+t+") -> "+o.default.get(i.default,"queue.next"),"color: #3fa5f3;font-weight: bold;")},r.queueStoppingLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8226)+" ("+t+") -> "+o.default.get(i.default,"queue.stopping"),"color: #ff7f94;font-weight: bold;")},r.queueStoppedLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(8226)+" ("+t+") -> "+o.default.get(i.default,"queue.stopped"),"color: #ff7f94;font-weight: bold;")},r.queueEmptyLog=function(e){c("%c"+u(e,1)[0]+" "+o.default.get(i.default,"queue.empty"),"color: #ff7f94;font-weight: bold;")},r.eventCreatedLog=function(e){c("%c("+u(e,1)[0]+") -> "+o.default.get(i.default,"event.created"),"color: #66cee3;font-weight: bold;")},r.eventFiredLog=function(e){var t=u(e,2),r=t[0],n=t[1];c("%c("+r+") -> "+o.default.get(i.default,"event."+n),"color: #a0dc3c;font-weight: bold;")},r.notFoundLog=function(e){var t=u(e,1)[0];c("%c"+String.fromCharCode(215)+" ("+t+") -> "+o.default.get(i.default,"queue.not-found"),"color: #b92e2e;font-weight: bold;")},r.workerRunninLog=function(e){var t=u(e,5),r=t[0],n=t[1],o=t[2],i=t[3],a=t[4];console.groupCollapsed((r.name||o.handler)+" - "+o.label),c("%cchannel: "+i,"color: blue;"),c("%clabel: "+(o.label||""),"color: blue;"),c("%chandler: "+o.handler,"color: blue;"),c("%cpriority: "+o.priority,"color: blue;"),c("%cunique: "+(o.unique||"false"),"color: blue;"),c("%cretry: "+(n.retry||"1"),"color: blue;"),c("%ctried: "+(o.tried?o.tried+1:"1"),"color: blue;"),c("%ctag: "+(o.tag||""),"color: blue;"),c("%cargs:","color: blue;"),c(o.args||""),console.groupCollapsed("dependencies"),c.apply(void 0,function(e){{if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}}(a[r.name]||[])),console.groupEnd()},r.workerDoneLog=function(e){var t=u(e,3),r=t[0],n=t[1],o=t[2];!0===r?c("%c"+String.fromCharCode(10003)+" Task completed!","color: green;"):!r&&n.tried<o.retry?c("%cTask will be retried!","color: #d8410c;"):c("%c"+String.fromCharCode(10005)+" Task failed and freezed!","color: #ef6363;");console.groupEnd()},r.workerFailedLog=function(){c("%c"+String.fromCharCode(10005)+" Task failed!","color: red;"),console.groupEnd()};var o=n(e("object-path")),i=n(e("./enum/log.events"));function n(e){return e&&e.__esModule?e:{default:e}}function c(){var e;(e=console).log.apply(e,arguments)}},{"./enum/log.events":18,"object-path":4}],16:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();var o=function(){function e(){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,e),this.store={}}return n(e,[{key:"has",value:function(e){return Object.prototype.hasOwnProperty.call(this.store,e)}},{key:"get",value:function(e){return this.store[e]}},{key:"all",value:function(){return this.store}},{key:"bind",value:function(e,t){this.store[e]=t}},{key:"merge",value:function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};this.store=Object.assign({},this.store,e)}},{key:"remove",value:function(e){return!!this.has(e)&&delete this.store[e]}},{key:"removeAll",value:function(){this.store={}}}]),e}();r.default=o},{}],17:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.default={defaultStorage:"localstorage",prefix:"sq_jobs",timeout:1e3,limit:-1,principle:"fifo",debug:!0}},{}],18:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),r.default={queue:{created:"New task created.",next:"Next task processing.",starting:"Queue listener starting.",stopping:"Queue listener stopping.",stopped:"Queue listener stopped.",empty:"channel is empty...","not-found":"worker not found",offline:"Disconnected",online:"Connected"},event:{created:"New event created",fired:"Event fired.","wildcard-fired":"Wildcard event fired."}}},{}],19:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}();var o=function(){function e(){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,e),this.store={},this.verifierPattern=/^[a-z0-9-_]+:before$|after$|retry$|\*$/,this.wildcards=["*","error"],this.emptyFunc=function(){},this.store.before={},this.store.after={},this.store.retry={},this.store.wildcard={},this.store.error=this.emptyFunc,this.store["*"]=this.emptyFunc}return n(e,[{key:"on",value:function(e,t){if("function"!=typeof t)throw new Error("Event should be an function");this.isValid(e)&&this.add(e,t)}},{key:"emit",value:function(e,t){if(-1<this.wildcards.indexOf(e))this.wildcard.apply(this,[e].concat([e,t]));else{var r=this.getType(e),n=this.getName(e);if(this.store[r])(this.store[r][n]||this.emptyFunc).call(null,t)}this.wildcard("*",e,t)}},{key:"wildcard",value:function(e,t,r){this.store.wildcard[e]&&this.store.wildcard[e].call(null,t,r)}},{key:"add",value:function(e,t){if(-1<this.wildcards.indexOf(e))this.store.wildcard[e]=t;else{var r=this.getType(e),n=this.getName(e);this.store[r][n]=t}}},{key:"has",value:function(e){try{var t=e.split(":");return 1<t.length?!!this.store[t[1]][t[0]]:!!this.store.wildcard[t[0]]}catch(e){return!1}}},{key:"getName",value:function(e){return e.match(/(.*):.*/)[1]}},{key:"getType",value:function(e){return e.match(/^[a-z0-9-_]+:(.*)/)[1]}},{key:"isValid",value:function(e){return this.verifierPattern.test(e)||-1<this.wildcards.indexOf(e)}}]),e}();r.default=o},{}],20:[function(e,t,r){"use strict";var n="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};Object.defineProperty(r,"__esModule",{value:!0}),r.canMultiple=r.createTimeout=r.successJobHandler=r.retryProcess=r.lockTask=r.failedJobHandler=r.removeTask=r.saveTask=r.getTasksWithoutFreezed=void 0;var o,i,a,u,c,s,f,l,p,h=_(e("babel-runtime/regenerator")),d="function"==typeof Symbol&&"symbol"===n(Symbol.iterator)?function(e){return void 0===e?"undefined":n(e)}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":void 0===e?"undefined":n(e)},y=(r.getTasksWithoutFreezed=(o=j(h.default.mark(function e(){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).all();case 2:return e.t0=x.excludeSpecificTasks.bind(["freezed"]),e.abrupt("return",e.sent.filter(e.t0));case 4:case"end":return e.stop()}},e,this)})),function(){return o.apply(this,arguments)}),r.saveTask=(i=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).save(P(t));case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return i.apply(this,arguments)}),r.removeTask=(a=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).delete(t);case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return a.apply(this,arguments)})),v=r.failedJobHandler=(u=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.abrupt("return",function(){var e=j(h.default.mark(function e(){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return y.call(this,t._id),this.event.emit("error",t),T.call(this,k.workerFailedLog),e.next=5,this.next();case 5:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}());case 1:case"end":return e.stop()}},e,this)})),function(e){return u.apply(this,arguments)}),g=r.lockTask=(c=j(h.default.mark(function e(t){var r;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,S.call(this).update(t._id,{locked:!0});case 2:return r=e.sent,e.abrupt("return",r);case 4:case"end":return e.stop()}},e,this)})),function(e){return c.apply(this,arguments)}),b=r.retryProcess=(s=j(h.default.mark(function e(t,r){var n,o;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return L.call(this,t,"retry"),(n=M.call(this,t,r)).locked=!1,e.next=5,S.call(this).update(t._id,n);case 5:return o=e.sent,e.abrupt("return",o);case 7:case"end":return e.stop()}},e,this)})),function(e,t){return s.apply(this,arguments)}),m=r.successJobHandler=(f=j(h.default.mark(function e(r,n){var o;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return o=this,e.abrupt("return",function(){var t=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(!t){e.next=4;break}C.call(o,r),e.next=6;break;case 4:return e.next=6,b.call(o,r,n);case 6:return A.call(o,"after",n,r.args),L.call(o,r,"after"),T.call(o,k.workerDoneLog,t,r,n),e.next=11,o.next();case 11:case"end":return e.stop()}},e,this)}));return function(e){return t.apply(this,arguments)}}());case 2:case"end":return e.stop()}},e,this)})),function(e,t){return f.apply(this,arguments)});r.createTimeout=(l=j(h.default.mark(function e(){var t,r,n,o,i,a;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return clearTimeout(this.currentTimeout),e.next=3,S.call(this).fetch();case 3:if(void 0!==(t=e.sent.shift())){e.next=8;break}return T.call(this,k.queueEmptyLog,this.name()),E.call(this),e.abrupt("return",1);case 8:if(w.default.worker.has(t.handler)){e.next=16;break}return T.call(this,k.notFoundLog,t.handler),e.next=12,v.call(this,t);case 12:return e.t0=this,e.next=15,e.sent.call(e.t0);case 15:return e.abrupt("return",1);case 16:return r=w.default.worker.get(t.handler),n="object"===(void 0===r?"undefined":d(r))?new Worker(r.uri):new r,o=this.config.get("timeout"),i=[t,r,n],e.next=22,q.call.apply(q,[this].concat(i));case 22:return e.t1=this,a=e.sent.bind(e.t1),this.currentTimeout=setTimeout(a,o),e.abrupt("return",this.currentTimeout);case 26:case"end":return e.stop()}},e,this)})),function(){return l.apply(this,arguments)}),r.canMultiple=(p=j(h.default.mark(function e(t){return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if("object"===(void 0===t?"undefined":d(t))&&!0===t.unique){e.next=2;break}return e.abrupt("return",!0);case 2:return e.next=4,this.hasByTag(t.tag);case 4:return e.t0=e.sent,e.abrupt("return",!1===e.t0);case 6:case"end":return e.stop()}},e,this)})),function(e){return p.apply(this,arguments)});r.checkPriority=P,r.db=S,r.logProxy=T,r.dispatchEvents=L,r.stopQueue=E,r.fireJobInlineEvent=A,r.successProcess=C,r.updateRetry=M,r.loopHandler=q,r.statusOff=function(){this.running=!1};var w=_(e("./queue")),x=(_(e("./channel")),_(e("./storage-capsule")),e("./utils")),k=e("./console");function _(e){return e&&e.__esModule?e:{default:e}}function O(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function j(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}function P(e){return e.priority=e.priority||0,"number"!=typeof e.priority&&(e.priority=0),e}function S(){return this.storage.channel(this.name())}function T(e){if(this.config.get("debug")&&"function"==typeof e){for(var t=arguments.length,r=Array(1<t?t-1:0),n=1;n<t;n++)r[n-1]=arguments[n];e(r)}}function L(t,e){var r=this;return"tag"in t&&([[t.tag+":"+e,"fired"],[t.tag+":*","wildcard-fired"]].forEach(function(e){r.event.emit(e[0],t),T.call.apply(T,[r,k.eventFiredLog].concat(O(e)))}),!0)}function E(){this.stop(),this.running=!1,clearTimeout(this.currentTimeout),T.call(this,k.queueStoppedLog,"stop")}function A(e,t,r){return!(!(0,x.hasMethod)(t,e)||!(0,x.isFunction)(t[e]))&&(t[e].call(t,r),!0)}function C(e){y.call(this,e._id)}function M(e,t){return"retry"in t||(t.retry=1),"tried"in e||(e.tried=0,e.retry=t.retry),e.tried+=1,e.tried>=t.retry&&(e.freezed=!0),e}function q(a,u,c){return e=j(h.default.mark(function e(){var t,r,n,o,i;return h.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=void 0,r=this,e.next=4,g.call(r,a);case 4:return A.call(this,"before",c,a.args),L.call(this,a,"before"),n=w.default.workerDeps[a.handler],o=Object.values(n||{}),T.call(this,k.workerRunninLog,u,c,a,r.name(),w.default.workerDeps),c instanceof Worker?(c.postMessage({args:a.args,dependencies:o}),t=new Promise(function(t){c.onmessage=function(e){t(u.handler(e)),c.terminate()}})):t=(i=c.handle).call.apply(i,[c,a.args].concat(O(o))),e.t1=t,e.next=13,m.call(r,a,c);case 13:return e.t2=r,e.t3=e.sent.bind(e.t2),e.t0=e.t1.then.call(e.t1,e.t3),e.next=18,v.call(r,a);case 18:e.t4=r,e.t5=e.sent.bind(e.t4),e.t0.catch.call(e.t0,e.t5);case 21:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)};var e}},{"./channel":13,"./console":15,"./queue":22,"./storage-capsule":23,"./utils":24,"babel-runtime/regenerator":1}],21:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0}),e("pseudo-worker/polyfill");var n,o=e("./queue"),i=(n=o)&&n.__esModule?n:{default:n};"undefined"!=typeof window&&(window.Queue=i.default),r.default=i.default},{"./queue":22,"pseudo-worker/polyfill":6}],22:[function(e,t,r){"use strict";Object.defineProperty(r,"__esModule",{value:!0});var n=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e};r.default=c;var o=u(e("./channel")),i=u(e("./container")),a=u(e("./config"));function u(e){return e&&e.__esModule?e:{default:e}}function c(e){this.config=new a.default(e)}c.FIFO="fifo",c.LIFO="lifo",c.drivers={},c.workerDeps={},c.worker=new i.default,c.prototype.container=new i.default,c.prototype.create=function(e){return this.container.has(e)||this.container.bind(e,new o.default(e,this.config)),this.container.get(e)},c.prototype.channel=function(e){if(!this.container.has(e))throw new Error('"'+e+'" channel not found');return this.container.get(e)},c.prototype.setTimeout=function(e){this.config.set("timeout",e)},c.prototype.setLimit=function(e){this.config.set("limit",e)},c.prototype.setPrefix=function(e){this.config.set("prefix",e)},c.prototype.setPrinciple=function(e){this.config.set("principle",e)},c.prototype.setDebug=function(e){this.config.set("debug",e)},c.prototype.setStorage=function(e){this.config.set("storage",e)},c.workers=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};if(!(e instanceof Object))throw new Error("The parameters should be object.");c.worker.merge(e)},c.deps=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};if(!(e instanceof Object))throw new Error("The parameters should be object.");c.workerDeps=e},c.use=function(){var e=0<arguments.length&&void 0!==arguments[0]?arguments[0]:{};c.drivers=n({},c.drivers,e)}},{"./channel":13,"./config":14,"./container":16}],23:[function(e,t,r){"use strict";var n="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};Object.defineProperty(r,"__esModule",{value:!0});var c=o(e("babel-runtime/regenerator")),s=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},f="function"==typeof Symbol&&"symbol"===n(Symbol.iterator)?function(e){return void 0===e?"undefined":n(e)}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":void 0===e?"undefined":n(e)},l=function(){function n(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(e,t,r){return t&&n(e.prototype,t),r&&n(e,r),e}}(),p=o(e("group-by")),h=e("./adapters"),d=e("./utils");function o(e){return e&&e.__esModule?e:{default:e}}function y(e){return function(){var u=e.apply(this,arguments);return new Promise(function(i,a){return function t(e,r){try{var n=u[e](r),o=n.value}catch(e){return void a(e)}if(!n.done)return Promise.resolve(o).then(function(e){t("next",e)},function(e){t("throw",e)});i(o)}("next")})}}var i=function(){function r(e,t){!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,r),this.config=e,this.storage=this.initialize(t)}var t,e,n,o,i,a,u;return l(r,[{key:"initialize",value:function(e){return"object"===(void 0===e?"undefined":f(e))?e:"function"==typeof e?new e(this.config):"localstorage"===this.config.get("storage")?new h.LocalStorageAdapter(this.config):new h.InMemoryAdapter(this.config)}},{key:"channel",value:function(e){return this.storageChannel=e,this}},{key:"fetch",value:(u=y(c.default.mark(function e(){var t,r;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:return e.t0=d.excludeSpecificTasks,t=e.sent.filter(e.t0),r=(0,p.default)(t,"priority"),e.abrupt("return",Object.keys(r).map(function(e){return parseInt(e,10)}).sort(function(e,t){return t-e}).reduce(this.reduceTasks(r),[]));case 6:case"end":return e.stop()}},e,this)})),function(){return u.apply(this,arguments)})},{key:"save",value:(a=y(c.default.mark(function e(t){var r,n;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if("object"===(void 0===t?"undefined":f(t))){e.next=2;break}return e.abrupt("return",!1);case 2:return e.next=4,this.storage.get(this.storageChannel);case 4:return r=e.sent,e.next=7,this.isExceeded();case 7:if(!e.sent){e.next=10;break}return console.warn("Task limit exceeded: The '"+this.storageChannel+"' channel limit is "+this.config.get("limit")),e.abrupt("return",!1);case 10:return n=this.prepareTask(t),r.push(n),e.next=14,this.storage.set(this.storageChannel,r);case 14:return e.abrupt("return",n._id);case 15:case"end":return e.stop()}},e,this)})),function(e){return a.apply(this,arguments)})},{key:"update",value:(i=y(c.default.mark(function e(t,r){var n,o;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:if(n=e.sent,!((o=n.findIndex(function(e){return e._id===t}))<0)){e.next=6;break}return e.abrupt("return",!1);case 6:return n[o]=Object.assign({},n[o],r),e.next=9,this.storage.set(this.storageChannel,n);case 9:return e.abrupt("return",!0);case 10:case"end":return e.stop()}},e,this)})),function(e,t){return i.apply(this,arguments)})},{key:"delete",value:(o=y(c.default.mark(function e(t){var r,n;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.all();case 2:if(r=e.sent,!((n=r.findIndex(function(e){return e._id===t}))<0)){e.next=6;break}return e.abrupt("return",!1);case 6:return delete r[n],e.next=9,this.storage.set(this.storageChannel,r.filter(function(e){return e}));case 9:return e.abrupt("return",!0);case 10:case"end":return e.stop()}},e,this)})),function(e){return o.apply(this,arguments)})},{key:"all",value:(n=y(c.default.mark(function e(){var t;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.storage.get(this.storageChannel);case 2:return t=e.sent,e.abrupt("return",t);case 4:case"end":return e.stop()}},e,this)})),function(){return n.apply(this,arguments)})},{key:"generateId",value:function(){return(65536*(1+Math.random())).toString(16)}},{key:"prepareTask",value:function(e){var t=s({},e);return t.createdAt=Date.now(),t._id=this.generateId(),t}},{key:"reduceTasks",value:function(r){var n=this;return function(e,t){return"lifo"===n.config.get("principle")?e.concat(r[t].sort(d.lifo)):e.concat(r[t].sort(d.fifo))}.bind(this)}},{key:"isExceeded",value:(e=y(c.default.mark(function e(){var t,r;return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=this.config.get("limit"),e.next=3,this.all();case 3:return e.t0=d.excludeSpecificTasks,r=e.sent.filter(e.t0),e.abrupt("return",!(-1===t||t>r.length));case 6:case"end":return e.stop()}},e,this)})),function(){return e.apply(this,arguments)})},{key:"clear",value:(t=y(c.default.mark(function e(t){return c.default.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.storage.clear(t);case 2:case"end":return e.stop()}},e,this)})),function(e){return t.apply(this,arguments)})}]),r}();r.default=i},{"./adapters":10,"./utils":24,"babel-runtime/regenerator":1,"group-by":3}],24:[function(e,t,r){"use strict";function n(e,t){return Object.prototype.hasOwnProperty.call(e,t)}function o(t){var e=Array.isArray(this)?this:["freezed","locked"],r=[];return e.forEach(function(e){r.push(!1===n(t,e)||!1===t[e])}),!(-1<r.indexOf(!1))}Object.defineProperty(r,"__esModule",{value:!0}),r.hasProperty=n,r.hasMethod=function(e,t){return e instanceof Object&&t in e},r.isFunction=function(e){return e instanceof Function},r.excludeSpecificTasks=o,r.utilClearByTag=function(e){if(!o.call(["locked"],e))return!1;return e.tag===this},r.fifo=function(e,t){return e.createdAt-t.createdAt},r.lifo=function(e,t){return t.createdAt-e.createdAt}},{}]},{},[21]); |
@@ -199,2 +199,4 @@ function _asyncToGenerator(fn) { | ||
| this.running = false; | ||
| clearTimeout(this.currentTimeout); | ||
@@ -201,0 +203,0 @@ |
| { | ||
| "name": "storage-based-queue", | ||
| "version": "1.2.4", | ||
| "description": | ||
| "Simple client queue mechanism. Create it and run asynchronously with worker class in browser.", | ||
| "version": "1.2.5", | ||
| "description": "Simple client queue mechanism. Create it and run asynchronously with worker class in browser.", | ||
| "homepage": "https://github.com/atayahmet/storage-based-queue", | ||
@@ -67,3 +66,5 @@ "main": "lib/index.js", | ||
| { | ||
| "presets": ["es2015"] | ||
| "presets": [ | ||
| "es2015" | ||
| ] | ||
| } | ||
@@ -70,0 +71,0 @@ ] |
@@ -143,2 +143,4 @@ /* @flow */ | ||
| this.running = false; | ||
| clearTimeout(this.currentTimeout); | ||
@@ -145,0 +147,0 @@ |
@@ -40,7 +40,17 @@ import Config from '../src/config'; | ||
| it('should return channel status, ->status()', async () => { | ||
| const channel = new Channel('channe-status', config); | ||
| it('should return channel status, ->status()', async (done) => { | ||
| const channel = new Channel('channe-status', config); | ||
| expect(channel.status()).toBeFalsy(); | ||
| expect(await channel.start()).toBeTruthy(); | ||
| expect(channel.status()).toBeTruthy(); | ||
| channel.forceStop(); | ||
| expect(channel.status()).toBeFalsy(); | ||
| await channel.start(); | ||
| channel.stop(); | ||
| channel.next(); | ||
| setTimeout(() => { | ||
| expect(channel.status()).toBeFalsy(); | ||
| done(); | ||
| }, defaultTimeout + 1); | ||
| }); | ||
@@ -47,0 +57,0 @@ |
Sorry, the diff of this file is too big to display
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Uses eval
Supply chain riskPackage uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by34.98%
742810
- Number of package files
- increased by1.56%
65
- Number of medium supply chain risk alerts
- decreased by-7.14%
13
Worsened metrics
- Lines of code
- decreased by-24.23%
8271
No dependency changes