opossum - npm Package Compare versions

Comparing version 8.1.0 to 8.1.1

dist/opossum.min.js

@@ -1,2 +0,2 @@
-!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):"object"==typeof exports?exports.circuitBreaker=t():e.circuitBreaker=t()}(self,(()=>{return e={187:e=>{"use strict";var t,n="object"==typeof Reflect?Reflect:null,r=n&&"function"==typeof n.apply?n.apply:function(e,t,n){return Function.prototype.apply.call(e,t,n)};t=n&&"function"==typeof n.ownKeys?n.ownKeys:Object.getOwnPropertySymbols?function(e){return Object.getOwnPropertyNames(e).concat(Object.getOwnPropertySymbols(e))}:function(e){return Object.getOwnPropertyNames(e)};var o=Number.isNaN||function(e){return e!=e};function i(){i.init.call(this)}e.exports=i,e.exports.once=function(e,t){return new Promise((function(n,r){function o(n){e.removeListener(t,i),r(n)}function i(){"function"==typeof e.removeListener&&e.removeListener("error",o),n([].slice.call(arguments))}m(e,t,i,{once:!0}),"error"!==t&&function(e,t,n){"function"==typeof e.on&&m(e,"error",t,{once:!0})}(e,o)}))},i.EventEmitter=i,i.prototype._events=void 0,i.prototype._eventsCount=0,i.prototype._maxListeners=void 0;var s=10;function u(e){if("function"!=typeof e)throw new TypeError('The "listener" argument must be of type Function. Received type '+typeof e)}function c(e){return void 0===e._maxListeners?i.defaultMaxListeners:e._maxListeners}function a(e,t,n,r){var o,i,s,a;if(u(n),void 0===(i=e._events)?(i=e._events=Object.create(null),e._eventsCount=0):(void 0!==i.newListener&&(e.emit("newListener",t,n.listener?n.listener:n),i=e._events),s=i[t]),void 0===s)s=i[t]=n,++e._eventsCount;else if("function"==typeof s?s=i[t]=r?[n,s]:[s,n]:r?s.unshift(n):s.push(n),(o=c(e))>0&&s.length>o&&!s.warned){s.warned=!0;var l=new Error("Possible EventEmitter memory leak detected. "+s.length+" "+String(t)+" listeners added. Use emitter.setMaxListeners() to increase limit");l.name="MaxListenersExceededWarning",l.emitter=e,l.type=t,l.count=s.length,a=l,console&&console.warn&&console.warn(a)}return e}function l(){if(!this.fired)return this.target.removeListener(this.type,this.wrapFn),this.fired=!0,0===arguments.length?this.listener.call(this.target):this.listener.apply(this.target,arguments)}function f(e,t,n){var r={fired:!1,wrapFn:void 0,target:e,type:t,listener:n},o=l.bind(r);return o.listener=n,r.wrapFn=o,o}function p(e,t,n){var r=e._events;if(void 0===r)return[];var o=r[t];return void 0===o?[]:"function"==typeof o?n?[o.listener||o]:[o]:n?function(e){for(var t=new Array(e.length),n=0;n<t.length;++n)t[n]=e[n].listener||e[n];return t}(o):y(o,o.length)}function h(e){var t=this._events;if(void 0!==t){var n=t[e];if("function"==typeof n)return 1;if(void 0!==n)return n.length}return 0}function y(e,t){for(var n=new Array(t),r=0;r<t;++r)n[r]=e[r];return n}function m(e,t,n,r){if("function"==typeof e.on)r.once?e.once(t,n):e.on(t,n);else{if("function"!=typeof e.addEventListener)throw new TypeError('The "emitter" argument must be of type EventEmitter. Received type '+typeof e);e.addEventListener(t,(function o(i){r.once&&e.removeEventListener(t,o),n(i)}))}}Object.defineProperty(i,"defaultMaxListeners",{enumerable:!0,get:function(){return s},set:function(e){if("number"!=typeof e||e<0||o(e))throw new RangeError('The value of "defaultMaxListeners" is out of range. It must be a non-negative number. Received '+e+".");s=e}}),i.init=function(){void 0!==this._events&&this._events!==Object.getPrototypeOf(this)._events||(this._events=Object.create(null),this._eventsCount=0),this._maxListeners=this._maxListeners||void 0},i.prototype.setMaxListeners=function(e){if("number"!=typeof e||e<0||o(e))throw new RangeError('The value of "n" is out of range. It must be a non-negative number. Received '+e+".");return this._maxListeners=e,this},i.prototype.getMaxListeners=function(){return c(this)},i.prototype.emit=function(e){for(var t=[],n=1;n<arguments.length;n++)t.push(arguments[n]);var o="error"===e,i=this._events;if(void 0!==i)o=o&&void 0===i.error;else if(!o)return!1;if(o){var s;if(t.length>0&&(s=t[0]),s instanceof Error)throw s;var u=new Error("Unhandled error."+(s?" ("+s.message+")":""));throw u.context=s,u}var c=i[e];if(void 0===c)return!1;if("function"==typeof c)r(c,this,t);else{var a=c.length,l=y(c,a);for(n=0;n<a;++n)r(l[n],this,t)}return!0},i.prototype.addListener=function(e,t){return a(this,e,t,!1)},i.prototype.on=i.prototype.addListener,i.prototype.prependListener=function(e,t){return a(this,e,t,!0)},i.prototype.once=function(e,t){return u(t),this.on(e,f(this,e,t)),this},i.prototype.prependOnceListener=function(e,t){return u(t),this.prependListener(e,f(this,e,t)),this},i.prototype.removeListener=function(e,t){var n,r,o,i,s;if(u(t),void 0===(r=this._events))return this;if(void 0===(n=r[e]))return this;if(n===t||n.listener===t)0==--this._eventsCount?this._events=Object.create(null):(delete r[e],r.removeListener&&this.emit("removeListener",e,n.listener||t));else if("function"!=typeof n){for(o=-1,i=n.length-1;i>=0;i--)if(n[i]===t||n[i].listener===t){s=n[i].listener,o=i;break}if(o<0)return this;0===o?n.shift():function(e,t){for(;t+1<e.length;t++)e[t]=e[t+1];e.pop()}(n,o),1===n.length&&(r[e]=n[0]),void 0!==r.removeListener&&this.emit("removeListener",e,s||t)}return this},i.prototype.off=i.prototype.removeListener,i.prototype.removeAllListeners=function(e){var t,n,r;if(void 0===(n=this._events))return this;if(void 0===n.removeListener)return 0===arguments.length?(this._events=Object.create(null),this._eventsCount=0):void 0!==n[e]&&(0==--this._eventsCount?this._events=Object.create(null):delete n[e]),this;if(0===arguments.length){var o,i=Object.keys(n);for(r=0;r<i.length;++r)"removeListener"!==(o=i[r])&&this.removeAllListeners(o);return this.removeAllListeners("removeListener"),this._events=Object.create(null),this._eventsCount=0,this}if("function"==typeof(t=n[e]))this.removeListener(e,t);else if(void 0!==t)for(r=t.length-1;r>=0;r--)this.removeListener(e,t[r]);return this},i.prototype.listeners=function(e){return p(this,e,!0)},i.prototype.rawListeners=function(e){return p(this,e,!1)},i.listenerCount=function(e,t){return"function"==typeof e.listenerCount?e.listenerCount(t):h.call(e,t)},i.prototype.listenerCount=h,i.prototype.eventNames=function(){return this._eventsCount>0?t(this._events):[]}},524:(e,t,n)=>{"use strict";e.exports=n(269)},235:(e,t)=>{function n(e){return 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},n(e)}function r(e,t){for(var r=0;r<t.length;r++){var o=t[r];o.enumerable=o.enumerable||!1,o.configurable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(e,(void 0,i=function(e,t){if("object"!==n(e)||null===e)return e;var r=e[Symbol.toPrimitive];if(void 0!==r){var o=r.call(e,"string");if("object"!==n(o))return o;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(o.key),"symbol"===n(i)?i:String(i)),o)}var i}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.cache=new Map}var t,n;return t=e,(n=[{key:"get",value:function(e){var t=this.cache.get(e);if(t){if(t.expiresAt>Date.now()||0===t.expiresAt)return t.value;this.cache.delete(e)}}},{key:"set",value:function(e,t,n){this.cache.set(e,{expiresAt:n,value:t})}},{key:"flush",value:function(){this.cache.clear()}}])&&r(t.prototype,n),Object.defineProperty(t,"prototype",{writable:!1}),e}();e.exports=o},269:(e,t,n)=>{"use strict";function r(e){return function(e){if(Array.isArray(e))return o(e)}(e)||function(e){if("undefined"!=typeof Symbol&&null!=e[Symbol.iterator]||null!=e["@@iterator"])return Array.from(e)}(e)||function(e,t){if(e){if("string"==typeof e)return o(e,t);var n=Object.prototype.toString.call(e).slice(8,-1);return"Object"===n&&e.constructor&&(n=e.constructor.name),"Map"===n||"Set"===n?Array.from(e):"Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)?o(e,t):void 0}}(e)||function(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function o(e,t){(null==t||t>e.length)&&(t=e.length);for(var n=0,r=new Array(t);n<t;n++)r[n]=e[n];return r}function i(e){return i="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},i(e)}function s(e,t){for(var n=0;n<t.length;n++){var r=t[n];r.enumerable=r.enumerable||!1,r.configurable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,(void 0,o=function(e,t){if("object"!==i(e)||null===e)return e;var n=e[Symbol.toPrimitive];if(void 0!==n){var r=n.call(e,"string");if("object"!==i(r))return r;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(r.key),"symbol"===i(o)?o:String(o)),r)}var o}function u(e,t){return u=Object.setPrototypeOf?Object.setPrototypeOf.bind():function(e,t){return e.__proto__=t,e},u(e,t)}function c(e){if(void 0===e)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return e}function a(e){return a=Object.setPrototypeOf?Object.getPrototypeOf.bind():function(e){return e.__proto__||Object.getPrototypeOf(e)},a(e)}var l=n(187),f=n(741),p=n(384),h=n(235),y=Symbol("state"),m=Symbol("open"),v=Symbol("closed"),b=Symbol("half-open"),d=Symbol("pending-close"),w=Symbol("shutdown"),g=Symbol("fallback"),O=Symbol("status"),T=Symbol("name"),S=Symbol("group"),j=Symbol("Enabled"),x=Symbol("warming-up"),k=Symbol("volume-threshold"),E=Symbol("our-error"),P=Symbol("reset-timeout"),L=Symbol("warmup-timeout"),_=Symbol("last-timer-at"),C=function(e){!function(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Super expression must either be null or a function");e.prototype=Object.create(t&&t.prototype,{constructor:{value:e,writable:!0,configurable:!0}}),Object.defineProperty(e,"prototype",{writable:!1}),t&&u(e,t)}(N,e);var t,n,r,o,l,C=(o=N,l=function(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Boolean.prototype.valueOf.call(Reflect.construct(Boolean,[],(function(){}))),!0}catch(e){return!1}}(),function(){var e,t=a(o);if(l){var n=a(this).constructor;e=Reflect.construct(t,arguments,n)}else e=t.apply(this,arguments);return function(e,t){if(t&&("object"===i(t)||"function"==typeof t))return t;if(void 0!==t)throw new TypeError("Derived constructors may only return object or undefined");return c(e)}(this,e)});function N(e){var t,n,r,o=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{};if(function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,N),(r=C.call(this)).options=o,r.options.timeout=!1!==o.timeout&&(o.timeout||1e4),r.options.resetTimeout=o.resetTimeout||3e4,r.options.errorThresholdPercentage=o.errorThresholdPercentage||50,r.options.rollingCountTimeout=o.rollingCountTimeout||1e4,r.options.rollingCountBuckets=o.rollingCountBuckets||10,r.options.rollingPercentilesEnabled=!1!==o.rollingPercentilesEnabled,r.options.capacity=Number.isInteger(o.capacity)?o.capacity:Number.MAX_SAFE_INTEGER,r.options.errorFilter=o.errorFilter||function(e){return!1},r.options.cacheTTL=null!==(t=o.cacheTTL)&&void 0!==t?t:0,r.options.cacheGetKey=null!==(n=o.cacheGetKey)&&void 0!==n?n:function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return JSON.stringify(t)},r.options.enableSnapshots=!1!==o.enableSnapshots,r.options.cache)if(void 0===r.options.cacheTransport)r.options.cacheTransport=new h;else if("object"!==i(r.options.cacheTransport)||!r.options.cacheTransport.get||!r.options.cacheTransport.set||!r.options.cacheTransport.flush)throw new TypeError("options.cacheTransport should be an object with `get`, `set` and `flush` methods");if(r.semaphore=new p(r.options.capacity),!e)throw new TypeError("No action provided. Cannot construct a CircuitBreaker without an invocable action.");if(o.abortController&&"function"!=typeof o.abortController.abort)throw new TypeError("AbortController does not contain `abort()` method");if(r[k]=Number.isInteger(o.volumeThreshold)?o.volumeThreshold:0,r[x]=!0===o.allowWarmUp,r.options.status?r.options.status instanceof f?r[O]=r.options.status:r[O]=new f({stats:r.options.status}):r[O]=new f(r.options),r[y]=v,o.state?(r[j]=!1!==o.state.enabled,r[x]=o.state.warmUp||r[x],r[v]=!1!==o.state.closed,r[b]=r[d]=o.state.halfOpen||!1,r[m]=!r[v]&&!r[b],r[w]=o.state.shutdown||!1):(r[d]=!1,r[j]=!1!==o.enabled),r[g]=null,r[T]=o.name||e.name||D(),r[S]=o.group||r[T],r[x]){var s=r[L]=setTimeout((function(e){return r[x]=!1}),r.options.rollingCountTimeout);"function"==typeof s.unref&&s.unref()}r.action="function"!=typeof e?function(t){return Promise.resolve(e)}:e,o.maxFailures&&console.error("options.maxFailures is deprecated. Please use options.errorThresholdPercentage");var u,a=function(e){return function(t,n){return r[O].increment(e,n)}};function l(e){e[y]=b,e[d]=!0,e.emit("halfOpen",e.options.resetTimeout)}return r.on("success",a("successes")),r.on("failure",a("failures")),r.on("fallback",a("fallbacks")),r.on("timeout",a("timeouts")),r.on("fire",a("fires")),r.on("reject",a("rejects")),r.on("cacheHit",a("cacheHits")),r.on("cacheMiss",a("cacheMisses")),r.on("open",(function(e){return r[O].open()})),r.on("close",(function(e){return r[O].close()})),r.on("semaphoreLocked",a("semaphoreRejections")),r.on("open",((u=c(r))[_]=Date.now(),function(e){var t=u[P]=setTimeout((function(){l(u)}),u.options.resetTimeout);"function"==typeof t.unref&&t.unref()})),r.on("success",(function(e){r.halfOpen&&r.close()})),r[w]?(r[y]=w,r.shutdown()):r[v]?r.close():r[m]?void 0!==r.options.state.lastTimerAt&&Date.now()-r.options.state.lastTimerAt>r.options.resetTimeout?l(c(r)):r.open():r[b]&&(r[y]=b),r}return t=N,n=[{key:"close",value:function(){this[y]!==v&&(this[P]&&clearTimeout(this[P]),this[y]=v,this[d]=!1,this.emit("close"))}},{key:"open",value:function(){this[y]!==m&&(this[y]=m,this[d]=!1,this.emit("open"))}},{key:"shutdown",value:function(){this.emit("shutdown"),this.disable(),this.removeAllListeners(),this[P]&&clearTimeout(this[P]),this[L]&&clearTimeout(this[L]),this.status.shutdown(),this[y]=w,this.clearCache()}},{key:"isShutdown",get:function(){return this[y]===w}},{key:"name",get:function(){return this[T]}},{key:"group",get:function(){return this[S]}},{key:"pendingClose",get:function(){return this[d]}},{key:"closed",get:function(){return this[y]===v}},{key:"opened",get:function(){return this[y]===m}},{key:"halfOpen",get:function(){return this[y]===b}},{key:"status",get:function(){return this[O]}},{key:"stats",get:function(){return this[O].stats}},{key:"toJSON",value:function(){return{state:{name:this.name,enabled:this.enabled,closed:this.closed,open:this.opened,halfOpen:this.halfOpen,warmUp:this.warmUp,shutdown:this.isShutdown,lastTimerAt:this[_]},status:this.status.stats}}},{key:"enabled",get:function(){return this[j]}},{key:"warmUp",get:function(){return this[x]}},{key:"volumeThreshold",get:function(){return this[k]}},{key:"fallback",value:function(e){var t=e;return e instanceof N&&(t=function(){return e.fire.apply(e,arguments)}),this[g]=t,this}},{key:"fire",value:function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return this.call.apply(this,[this.action].concat(t))}},{key:"call",value:function(e){var t=this;if(this.isShutdown){var n=M("The circuit has been shutdown.","ESHUTDOWN");return Promise.reject(n)}for(var r=arguments.length,o=new Array(r>1?r-1:0),i=1;i<r;i++)o[i-1]=arguments[i];var s,u=o.slice(),c="";if(this.emit("fire",u),this.options.cache){c=this.options.cacheGetKey.apply(this,o);var a=this.options.cacheTransport.get(c);if(a)return this.emit("cacheHit"),a;this.emit("cacheMiss")}if(!this[j]){var l=this.action.apply(e,u);return"function"==typeof l.then?l:Promise.resolve(l)}if(!this.closed&&!this.pendingClose){var f=M("Breaker is open","EOPENBREAKER");return this.emit("reject",f),R(this,f,u)||Promise.reject(f)}this[d]=!1;var p=!1;return new Promise((function(n,r){var o=Date.now();if(t.semaphore.test()){t.options.timeout&&(s=setTimeout((function(){p=!0;var e=M("Timed out after ".concat(t.options.timeout,"ms"),"ETIMEDOUT"),i=Date.now()-o;t.semaphore.release(),t.emit("timeout",e,i,u),A(e,t,s,u,i,n,r),t.options.abortController&&t.options.abortController.abort()}),t.options.timeout));try{var i=t.action.apply(e,u),a="function"==typeof i.then?i:Promise.resolve(i);a.then((function(e){p||(clearTimeout(s),t.emit("success",e,Date.now()-o),t.semaphore.release(),n(e),t.options.cache&&t.options.cacheTransport.set(c,a,t.options.cacheTTL>0?Date.now()+t.options.cacheTTL:0))})).catch((function(e){if(!p){t.semaphore.release();var i=Date.now()-o;A(e,t,s,u,i,n,r)}}))}catch(e){t.semaphore.release();var l=Date.now()-o;A(e,t,s,u,l,n,r)}}else{var f=Date.now()-o,h=M("Semaphore locked","ESEMLOCKED");t.emit("semaphoreLocked",h,f),A(h,t,s,u,f,n,r)}}))}},{key:"clearCache",value:function(){this.options.cache&&this.options.cacheTransport.flush()}},{key:"healthCheck",value:function(e,t){var n=this;if(t=t||5e3,"function"!=typeof e)throw new TypeError("Health check function must be a function");if(isNaN(t))throw new TypeError("Health check interval must be a number");var r=function(t){e.apply(n).catch((function(e){n.emit("healthCheckFailed",e),n.open()}))},o=setInterval(r,t);"function"==typeof o.unref&&o.unref(),r()}},{key:"enable",value:function(){this[j]=!0}},{key:"disable",value:function(){this[j]=!1}}],r=[{key:"isOurError",value:function(e){return!!e[E]}},{key:"newStatus",value:function(e){return new f(e)}}],n&&s(t.prototype,n),r&&s(t,r),Object.defineProperty(t,"prototype",{writable:!1}),N}(l);function A(e,t,n,o,i,s,u){var c;if(clearTimeout(n),(c=t.options).errorFilter.apply(c,[e].concat(r(o))))t.emit("success",e,i);else{!function(e,t,n,r){if(e.emit("failure",t,r,n),!e.warmUp){var o=e.stats;o.fires<e.volumeThreshold&&!e.halfOpen||(o.failures/o.fires*100>e.options.errorThresholdPercentage||e.halfOpen)&&e.open()}}(t,e,o,i);var a=R(t,e,o);if(a)return s(a)}u(e)}function R(e,t,n){if(e[g])try{var o=e[g].apply(e[g],[].concat(r(n),[t]));return e.emit("fallback",o,t),o instanceof Promise?o:Promise.resolve(o)}catch(e){return Promise.reject(e)}}function M(e,t){var n=new Error(e);return n.code=t,n[E]=!0,n}var D=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(function(e){var t=16*Math.random()|0;return("x"===e?t:3&t|8).toString(16)}))};e.exports=C},384:(e,t)=>{"use strict";e.exports=function(e){var t=[],n=e,r={take:o,release:i,test:function(){return!(n<1)&&o()&&!0}};return Object.defineProperty(r,"count",{get:function(e){return n},enumerable:!0}),r;function o(e){return n>0?(--n,Promise.resolve(i)):new Promise((function(r,o){t.push((function(e){--n,r(i)})),e&&setTimeout((function(n){t.shift();var r=new Error("Timed out after ".concat(e,"ms"));r.code="ETIMEDOUT",o(r)}),e)}))}function i(){n++,t.length>0&&t.shift()()}}},741:(e,t,n)=>{"use strict";function r(e){return r="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},r(e)}function o(e,t){var n=Object.keys(e);if(Object.getOwnPropertySymbols){var r=Object.getOwnPropertySymbols(e);t&&(r=r.filter((function(t){return Object.getOwnPropertyDescriptor(e,t).enumerable}))),n.push.apply(n,r)}return n}function i(e){for(var t=1;t<arguments.length;t++){var n=null!=arguments[t]?arguments[t]:{};t%2?o(Object(n),!0).forEach((function(t){s(e,t,n[t])})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(n)):o(Object(n)).forEach((function(t){Object.defineProperty(e,t,Object.getOwnPropertyDescriptor(n,t))}))}return e}function s(e,t,n){return(t=c(t))in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function u(e,t){for(var n=0;n<t.length;n++){var r=t[n];r.enumerable=r.enumerable||!1,r.configurable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,c(r.key),r)}}function c(e){var t=function(e,t){if("object"!==r(e)||null===e)return e;var n=e[Symbol.toPrimitive];if(void 0!==n){var o=n.call(e,"string");if("object"!==r(o))return o;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(e);return"symbol"===r(t)?t:String(t)}function a(e,t){return a=Object.setPrototypeOf?Object.setPrototypeOf.bind():function(e,t){return e.__proto__=t,e},a(e,t)}function l(e){return l=Object.setPrototypeOf?Object.getPrototypeOf.bind():function(e){return e.__proto__||Object.getPrototypeOf(e)},l(e)}var f=Symbol("window"),p=Symbol("buckets"),h=Symbol("timeout"),y=Symbol("percentiles"),m=Symbol("bucket-interval"),v=Symbol("snapshot-interval"),b=function(e){!function(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Super expression must either be null or a function");e.prototype=Object.create(t&&t.prototype,{constructor:{value:e,writable:!0,configurable:!0}}),Object.defineProperty(e,"prototype",{writable:!1}),t&&a(e,t)}(b,e);var t,n,o,s,c=(o=b,s=function(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Boolean.prototype.valueOf.call(Reflect.construct(Boolean,[],(function(){}))),!0}catch(e){return!1}}(),function(){var e,t=l(o);if(s){var n=l(this).constructor;e=Reflect.construct(t,arguments,n)}else e=t.apply(this,arguments);return function(e,t){if(t&&("object"===r(t)||"function"==typeof t))return t;if(void 0!==t)throw new TypeError("Derived constructors may only return object or undefined");return function(e){if(void 0===e)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return e}(e)}(this,e)});function b(e){var t;!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,b),(t=c.call(this))[p]=e.rollingCountBuckets||10,t[h]=e.rollingCountTimeout||1e4,t[f]=new Array(t[p]),t[y]=[0,.25,.5,.75,.9,.95,.99,.995,1],t.rollingPercentilesEnabled=!1!==e.rollingPercentilesEnabled,t.enableSnapshots=!1!==e.enableSnapshots;for(var n=0;n<t[p];n++)t[f][n]=w();var r=Math.floor(t[h]/t[p]);return t[m]=setInterval(d(t[f]),r),"function"==typeof t[m].unref&&t[m].unref(),t.enableSnapshots&&(t[v]=setInterval((function(e){return t.emit("snapshot",t.stats)}),r),"function"==typeof t[v].unref&&t[v].unref()),e.stats&&(t[f][0]=i(i({},w()),e.stats)),t}return t=b,(n=[{key:"stats",get:function(){var e=this,t=this[f].reduce((function(t,n){return n?(Object.keys(t).forEach((function(e){"latencyTimes"!==e&&"percentiles"!==e&&(t[e]+=n[e]||0)})),e.rollingPercentilesEnabled&&t.latencyTimes.push.apply(t.latencyTimes,n.latencyTimes||[]),t):t}),w());return this.rollingPercentilesEnabled?(t.latencyTimes.sort((function(e,t){return e-t})),t.latencyTimes.length?t.latencyMean=t.latencyTimes.reduce((function(e,t){return e+t}),0)/t.latencyTimes.length:t.latencyMean=0,this[y].forEach((function(e){t.percentiles[e]=function(e,t){return 0===e?t[0]||0:t[Math.ceil(e*t.length)-1]||0}(e,t.latencyTimes)}))):(t.latencyMean=-1,this[y].forEach((function(e){t.percentiles[e]=-1}))),t}},{key:"window",get:function(){return this[f].slice()}},{key:"increment",value:function(e,t){this[f][0][e]++,"successes"!==e&&"failures"!==e&&"timeouts"!==e||this[f][0].latencyTimes.push(t||0)}},{key:"open",value:function(){this[f][0].isCircuitBreakerOpen=!0}},{key:"close",value:function(){this[f][0].isCircuitBreakerOpen=!1}},{key:"shutdown",value:function(){this.removeAllListeners(),clearInterval(this[m]),this.enableSnapshots&&clearInterval(this[v])}}])&&u(t.prototype,n),Object.defineProperty(t,"prototype",{writable:!1}),b}(n(187).EventEmitter),d=function(e){return function(t){e.pop(),e.unshift(w())}},w=function(e){return{failures:0,fallbacks:0,successes:0,rejects:0,fires:0,timeouts:0,cacheHits:0,cacheMisses:0,semaphoreRejections:0,percentiles:{},latencyTimes:[]}};e.exports=b}},t={},function n(r){var o=t[r];if(void 0!==o)return o.exports;var i=t[r]={exports:{}};return e[r](i,i.exports,n),i.exports}(524);var e,t}));
+!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):"object"==typeof exports?exports.circuitBreaker=t():e.circuitBreaker=t()}(self,(()=>{return e={187:e=>{"use strict";var t,n="object"==typeof Reflect?Reflect:null,r=n&&"function"==typeof n.apply?n.apply:function(e,t,n){return Function.prototype.apply.call(e,t,n)};t=n&&"function"==typeof n.ownKeys?n.ownKeys:Object.getOwnPropertySymbols?function(e){return Object.getOwnPropertyNames(e).concat(Object.getOwnPropertySymbols(e))}:function(e){return Object.getOwnPropertyNames(e)};var o=Number.isNaN||function(e){return e!=e};function i(){i.init.call(this)}e.exports=i,e.exports.once=function(e,t){return new Promise((function(n,r){function o(n){e.removeListener(t,i),r(n)}function i(){"function"==typeof e.removeListener&&e.removeListener("error",o),n([].slice.call(arguments))}m(e,t,i,{once:!0}),"error"!==t&&function(e,t,n){"function"==typeof e.on&&m(e,"error",t,{once:!0})}(e,o)}))},i.EventEmitter=i,i.prototype._events=void 0,i.prototype._eventsCount=0,i.prototype._maxListeners=void 0;var s=10;function u(e){if("function"!=typeof e)throw new TypeError('The "listener" argument must be of type Function. Received type '+typeof e)}function c(e){return void 0===e._maxListeners?i.defaultMaxListeners:e._maxListeners}function a(e,t,n,r){var o,i,s,a;if(u(n),void 0===(i=e._events)?(i=e._events=Object.create(null),e._eventsCount=0):(void 0!==i.newListener&&(e.emit("newListener",t,n.listener?n.listener:n),i=e._events),s=i[t]),void 0===s)s=i[t]=n,++e._eventsCount;else if("function"==typeof s?s=i[t]=r?[n,s]:[s,n]:r?s.unshift(n):s.push(n),(o=c(e))>0&&s.length>o&&!s.warned){s.warned=!0;var l=new Error("Possible EventEmitter memory leak detected. "+s.length+" "+String(t)+" listeners added. Use emitter.setMaxListeners() to increase limit");l.name="MaxListenersExceededWarning",l.emitter=e,l.type=t,l.count=s.length,a=l,console&&console.warn&&console.warn(a)}return e}function l(){if(!this.fired)return this.target.removeListener(this.type,this.wrapFn),this.fired=!0,0===arguments.length?this.listener.call(this.target):this.listener.apply(this.target,arguments)}function f(e,t,n){var r={fired:!1,wrapFn:void 0,target:e,type:t,listener:n},o=l.bind(r);return o.listener=n,r.wrapFn=o,o}function p(e,t,n){var r=e._events;if(void 0===r)return[];var o=r[t];return void 0===o?[]:"function"==typeof o?n?[o.listener||o]:[o]:n?function(e){for(var t=new Array(e.length),n=0;n<t.length;++n)t[n]=e[n].listener||e[n];return t}(o):y(o,o.length)}function h(e){var t=this._events;if(void 0!==t){var n=t[e];if("function"==typeof n)return 1;if(void 0!==n)return n.length}return 0}function y(e,t){for(var n=new Array(t),r=0;r<t;++r)n[r]=e[r];return n}function m(e,t,n,r){if("function"==typeof e.on)r.once?e.once(t,n):e.on(t,n);else{if("function"!=typeof e.addEventListener)throw new TypeError('The "emitter" argument must be of type EventEmitter. Received type '+typeof e);e.addEventListener(t,(function o(i){r.once&&e.removeEventListener(t,o),n(i)}))}}Object.defineProperty(i,"defaultMaxListeners",{enumerable:!0,get:function(){return s},set:function(e){if("number"!=typeof e||e<0||o(e))throw new RangeError('The value of "defaultMaxListeners" is out of range. It must be a non-negative number. Received '+e+".");s=e}}),i.init=function(){void 0!==this._events&&this._events!==Object.getPrototypeOf(this)._events||(this._events=Object.create(null),this._eventsCount=0),this._maxListeners=this._maxListeners||void 0},i.prototype.setMaxListeners=function(e){if("number"!=typeof e||e<0||o(e))throw new RangeError('The value of "n" is out of range. It must be a non-negative number. Received '+e+".");return this._maxListeners=e,this},i.prototype.getMaxListeners=function(){return c(this)},i.prototype.emit=function(e){for(var t=[],n=1;n<arguments.length;n++)t.push(arguments[n]);var o="error"===e,i=this._events;if(void 0!==i)o=o&&void 0===i.error;else if(!o)return!1;if(o){var s;if(t.length>0&&(s=t[0]),s instanceof Error)throw s;var u=new Error("Unhandled error."+(s?" ("+s.message+")":""));throw u.context=s,u}var c=i[e];if(void 0===c)return!1;if("function"==typeof c)r(c,this,t);else{var a=c.length,l=y(c,a);for(n=0;n<a;++n)r(l[n],this,t)}return!0},i.prototype.addListener=function(e,t){return a(this,e,t,!1)},i.prototype.on=i.prototype.addListener,i.prototype.prependListener=function(e,t){return a(this,e,t,!0)},i.prototype.once=function(e,t){return u(t),this.on(e,f(this,e,t)),this},i.prototype.prependOnceListener=function(e,t){return u(t),this.prependListener(e,f(this,e,t)),this},i.prototype.removeListener=function(e,t){var n,r,o,i,s;if(u(t),void 0===(r=this._events))return this;if(void 0===(n=r[e]))return this;if(n===t||n.listener===t)0==--this._eventsCount?this._events=Object.create(null):(delete r[e],r.removeListener&&this.emit("removeListener",e,n.listener||t));else if("function"!=typeof n){for(o=-1,i=n.length-1;i>=0;i--)if(n[i]===t||n[i].listener===t){s=n[i].listener,o=i;break}if(o<0)return this;0===o?n.shift():function(e,t){for(;t+1<e.length;t++)e[t]=e[t+1];e.pop()}(n,o),1===n.length&&(r[e]=n[0]),void 0!==r.removeListener&&this.emit("removeListener",e,s||t)}return this},i.prototype.off=i.prototype.removeListener,i.prototype.removeAllListeners=function(e){var t,n,r;if(void 0===(n=this._events))return this;if(void 0===n.removeListener)return 0===arguments.length?(this._events=Object.create(null),this._eventsCount=0):void 0!==n[e]&&(0==--this._eventsCount?this._events=Object.create(null):delete n[e]),this;if(0===arguments.length){var o,i=Object.keys(n);for(r=0;r<i.length;++r)"removeListener"!==(o=i[r])&&this.removeAllListeners(o);return this.removeAllListeners("removeListener"),this._events=Object.create(null),this._eventsCount=0,this}if("function"==typeof(t=n[e]))this.removeListener(e,t);else if(void 0!==t)for(r=t.length-1;r>=0;r--)this.removeListener(e,t[r]);return this},i.prototype.listeners=function(e){return p(this,e,!0)},i.prototype.rawListeners=function(e){return p(this,e,!1)},i.listenerCount=function(e,t){return"function"==typeof e.listenerCount?e.listenerCount(t):h.call(e,t)},i.prototype.listenerCount=h,i.prototype.eventNames=function(){return this._eventsCount>0?t(this._events):[]}},524:(e,t,n)=>{"use strict";e.exports=n(269)},235:(e,t)=>{function n(e){return 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},n(e)}function r(e,t){for(var r=0;r<t.length;r++){var o=t[r];o.enumerable=o.enumerable||!1,o.configurable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(e,(void 0,i=function(e,t){if("object"!==n(e)||null===e)return e;var r=e[Symbol.toPrimitive];if(void 0!==r){var o=r.call(e,"string");if("object"!==n(o))return o;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(o.key),"symbol"===n(i)?i:String(i)),o)}var i}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.cache=new Map}var t,n;return t=e,(n=[{key:"get",value:function(e){var t=this.cache.get(e);if(t){if(t.expiresAt>Date.now()||0===t.expiresAt)return t.value;this.cache.delete(e)}}},{key:"set",value:function(e,t,n){this.cache.set(e,{expiresAt:n,value:t})}},{key:"flush",value:function(){this.cache.clear()}}])&&r(t.prototype,n),Object.defineProperty(t,"prototype",{writable:!1}),e}();e.exports=o},269:(e,t,n)=>{"use strict";function r(e){return function(e){if(Array.isArray(e))return o(e)}(e)||function(e){if("undefined"!=typeof Symbol&&null!=e[Symbol.iterator]||null!=e["@@iterator"])return Array.from(e)}(e)||function(e,t){if(e){if("string"==typeof e)return o(e,t);var n=Object.prototype.toString.call(e).slice(8,-1);return"Object"===n&&e.constructor&&(n=e.constructor.name),"Map"===n||"Set"===n?Array.from(e):"Arguments"===n||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)?o(e,t):void 0}}(e)||function(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function o(e,t){(null==t||t>e.length)&&(t=e.length);for(var n=0,r=new Array(t);n<t;n++)r[n]=e[n];return r}function i(e){return i="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},i(e)}function s(e,t){for(var n=0;n<t.length;n++){var r=t[n];r.enumerable=r.enumerable||!1,r.configurable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,(void 0,o=function(e,t){if("object"!==i(e)||null===e)return e;var n=e[Symbol.toPrimitive];if(void 0!==n){var r=n.call(e,"string");if("object"!==i(r))return r;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(r.key),"symbol"===i(o)?o:String(o)),r)}var o}function u(e,t){return u=Object.setPrototypeOf?Object.setPrototypeOf.bind():function(e,t){return e.__proto__=t,e},u(e,t)}function c(e){if(void 0===e)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return e}function a(e){return a=Object.setPrototypeOf?Object.getPrototypeOf.bind():function(e){return e.__proto__||Object.getPrototypeOf(e)},a(e)}var l=n(187),f=n(741),p=n(384),h=n(235),y=Symbol("state"),m=Symbol("open"),v=Symbol("closed"),b=Symbol("half-open"),d=Symbol("pending-close"),w=Symbol("shutdown"),g=Symbol("fallback"),O=Symbol("status"),T=Symbol("name"),k=Symbol("group"),S=Symbol("Enabled"),j=Symbol("warming-up"),x=Symbol("volume-threshold"),E=Symbol("our-error"),P=Symbol("reset-timeout"),L=Symbol("warmup-timeout"),C=Symbol("last-timer-at"),_=function(e){!function(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Super expression must either be null or a function");e.prototype=Object.create(t&&t.prototype,{constructor:{value:e,writable:!0,configurable:!0}}),Object.defineProperty(e,"prototype",{writable:!1}),t&&u(e,t)}(D,e);var t,n,r,o,l,_=(o=D,l=function(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Boolean.prototype.valueOf.call(Reflect.construct(Boolean,[],(function(){}))),!0}catch(e){return!1}}(),function(){var e,t=a(o);if(l){var n=a(this).constructor;e=Reflect.construct(t,arguments,n)}else e=t.apply(this,arguments);return function(e,t){if(t&&("object"===i(t)||"function"==typeof t))return t;if(void 0!==t)throw new TypeError("Derived constructors may only return object or undefined");return c(e)}(this,e)});function D(e){var t,n,r,o=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{};if(function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,D),(r=_.call(this)).options=o,r.options.timeout=!1!==o.timeout&&(o.timeout||1e4),r.options.resetTimeout=o.resetTimeout||3e4,r.options.errorThresholdPercentage=o.errorThresholdPercentage||50,r.options.rollingCountTimeout=o.rollingCountTimeout||1e4,r.options.rollingCountBuckets=o.rollingCountBuckets||10,r.options.rollingPercentilesEnabled=!1!==o.rollingPercentilesEnabled,r.options.capacity=Number.isInteger(o.capacity)?o.capacity:Number.MAX_SAFE_INTEGER,r.options.errorFilter=o.errorFilter||function(e){return!1},r.options.cacheTTL=null!==(t=o.cacheTTL)&&void 0!==t?t:0,r.options.cacheGetKey=null!==(n=o.cacheGetKey)&&void 0!==n?n:function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return JSON.stringify(t)},r.options.enableSnapshots=!1!==o.enableSnapshots,r.options.rotateBucketController=o.rotateBucketController,r.options.cache)if(void 0===r.options.cacheTransport)r.options.cacheTransport=new h;else if("object"!==i(r.options.cacheTransport)||!r.options.cacheTransport.get||!r.options.cacheTransport.set||!r.options.cacheTransport.flush)throw new TypeError("options.cacheTransport should be an object with `get`, `set` and `flush` methods");if(r.semaphore=new p(r.options.capacity),!e)throw new TypeError("No action provided. Cannot construct a CircuitBreaker without an invocable action.");if(o.abortController&&"function"!=typeof o.abortController.abort)throw new TypeError("AbortController does not contain `abort()` method");if(r[x]=Number.isInteger(o.volumeThreshold)?o.volumeThreshold:0,r[j]=!0===o.allowWarmUp,r.options.status?r.options.status instanceof f?r[O]=r.options.status:r[O]=new f({stats:r.options.status}):r[O]=new f(r.options),r[y]=v,o.state?(r[S]=!1!==o.state.enabled,r[j]=o.state.warmUp||r[j],r[v]=!1!==o.state.closed,r[b]=r[d]=o.state.halfOpen||!1,r[m]=!r[v]&&!r[b],r[w]=o.state.shutdown||!1):(r[d]=!1,r[S]=!1!==o.enabled),r[g]=null,r[T]=o.name||e.name||M(),r[k]=o.group||r[T],r[j]){var s=r[L]=setTimeout((function(e){return r[j]=!1}),r.options.rollingCountTimeout);"function"==typeof s.unref&&s.unref()}r.action="function"!=typeof e?function(t){return Promise.resolve(e)}:e,o.maxFailures&&console.error("options.maxFailures is deprecated. Please use options.errorThresholdPercentage");var u,a=function(e){return function(t,n){return r[O].increment(e,n)}};function l(e){e[y]=b,e[d]=!0,e.emit("halfOpen",e.options.resetTimeout)}return r.on("success",a("successes")),r.on("failure",a("failures")),r.on("fallback",a("fallbacks")),r.on("timeout",a("timeouts")),r.on("fire",a("fires")),r.on("reject",a("rejects")),r.on("cacheHit",a("cacheHits")),r.on("cacheMiss",a("cacheMisses")),r.on("open",(function(e){return r[O].open()})),r.on("close",(function(e){return r[O].close()})),r.on("semaphoreLocked",a("semaphoreRejections")),r.on("open",((u=c(r))[C]=Date.now(),function(e){var t=u[P]=setTimeout((function(){l(u)}),u.options.resetTimeout);"function"==typeof t.unref&&t.unref()})),r.on("success",(function(e){r.halfOpen&&r.close()})),r[w]?(r[y]=w,r.shutdown()):r[v]?r.close():r[m]?void 0!==r.options.state.lastTimerAt&&Date.now()-r.options.state.lastTimerAt>r.options.resetTimeout?l(c(r)):r.open():r[b]&&(r[y]=b),r}return t=D,n=[{key:"close",value:function(){this[y]!==v&&(this[P]&&clearTimeout(this[P]),this[y]=v,this[d]=!1,this.emit("close"))}},{key:"open",value:function(){this[y]!==m&&(this[y]=m,this[d]=!1,this.emit("open"))}},{key:"shutdown",value:function(){this.emit("shutdown"),this.disable(),this.removeAllListeners(),this[P]&&clearTimeout(this[P]),this[L]&&clearTimeout(this[L]),this.status.shutdown(),this[y]=w,this.clearCache()}},{key:"isShutdown",get:function(){return this[y]===w}},{key:"name",get:function(){return this[T]}},{key:"group",get:function(){return this[k]}},{key:"pendingClose",get:function(){return this[d]}},{key:"closed",get:function(){return this[y]===v}},{key:"opened",get:function(){return this[y]===m}},{key:"halfOpen",get:function(){return this[y]===b}},{key:"status",get:function(){return this[O]}},{key:"stats",get:function(){return this[O].stats}},{key:"toJSON",value:function(){return{state:{name:this.name,enabled:this.enabled,closed:this.closed,open:this.opened,halfOpen:this.halfOpen,warmUp:this.warmUp,shutdown:this.isShutdown,lastTimerAt:this[C]},status:this.status.stats}}},{key:"enabled",get:function(){return this[S]}},{key:"warmUp",get:function(){return this[j]}},{key:"volumeThreshold",get:function(){return this[x]}},{key:"fallback",value:function(e){var t=e;return e instanceof D&&(t=function(){return e.fire.apply(e,arguments)}),this[g]=t,this}},{key:"fire",value:function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return this.call.apply(this,[this.action].concat(t))}},{key:"call",value:function(e){var t=this;if(this.isShutdown){var n=A("The circuit has been shutdown.","ESHUTDOWN");return Promise.reject(n)}for(var r=arguments.length,o=new Array(r>1?r-1:0),i=1;i<r;i++)o[i-1]=arguments[i];var s,u=o.slice(),c="";if(this.emit("fire",u),this.options.cache){c=this.options.cacheGetKey.apply(this,o);var a=this.options.cacheTransport.get(c);if(a)return this.emit("cacheHit"),a;this.emit("cacheMiss")}if(!this[S]){var l=this.action.apply(e,u);return"function"==typeof l.then?l:Promise.resolve(l)}if(!this.closed&&!this.pendingClose){var f=A("Breaker is open","EOPENBREAKER");return this.emit("reject",f),R(this,f,u)||Promise.reject(f)}this[d]=!1;var p=!1;return new Promise((function(n,r){var o=Date.now();if(t.semaphore.test()){t.options.timeout&&(s=setTimeout((function(){p=!0;var e=A("Timed out after ".concat(t.options.timeout,"ms"),"ETIMEDOUT"),i=Date.now()-o;t.semaphore.release(),t.emit("timeout",e,i,u),B(e,t,s,u,i,n,r),t.options.abortController&&t.options.abortController.abort()}),t.options.timeout));try{var i=t.action.apply(e,u),a="function"==typeof i.then?i:Promise.resolve(i);a.then((function(e){p||(clearTimeout(s),t.emit("success",e,Date.now()-o),t.semaphore.release(),n(e),t.options.cache&&t.options.cacheTransport.set(c,a,t.options.cacheTTL>0?Date.now()+t.options.cacheTTL:0))})).catch((function(e){if(!p){t.semaphore.release();var i=Date.now()-o;B(e,t,s,u,i,n,r)}}))}catch(e){t.semaphore.release();var l=Date.now()-o;B(e,t,s,u,l,n,r)}}else{var f=Date.now()-o,h=A("Semaphore locked","ESEMLOCKED");t.emit("semaphoreLocked",h,f),B(h,t,s,u,f,n,r)}}))}},{key:"clearCache",value:function(){this.options.cache&&this.options.cacheTransport.flush()}},{key:"healthCheck",value:function(e,t){var n=this;if(t=t||5e3,"function"!=typeof e)throw new TypeError("Health check function must be a function");if(isNaN(t))throw new TypeError("Health check interval must be a number");var r=function(t){e.apply(n).catch((function(e){n.emit("healthCheckFailed",e),n.open()}))},o=setInterval(r,t);"function"==typeof o.unref&&o.unref(),r()}},{key:"enable",value:function(){this[S]=!0,this.status.startListeneningForRotateEvent()}},{key:"disable",value:function(){this[S]=!1,this.status.removeRotateBucketControllerListener()}}],r=[{key:"isOurError",value:function(e){return!!e[E]}},{key:"newStatus",value:function(e){return new f(e)}}],n&&s(t.prototype,n),r&&s(t,r),Object.defineProperty(t,"prototype",{writable:!1}),D}(l);function B(e,t,n,o,i,s,u){var c;if(clearTimeout(n),(c=t.options).errorFilter.apply(c,[e].concat(r(o))))t.emit("success",e,i);else{!function(e,t,n,r){if(e.emit("failure",t,r,n),!e.warmUp){var o=e.stats;o.fires<e.volumeThreshold&&!e.halfOpen||(o.failures/o.fires*100>e.options.errorThresholdPercentage||e.halfOpen)&&e.open()}}(t,e,o,i);var a=R(t,e,o);if(a)return s(a)}u(e)}function R(e,t,n){if(e[g])try{var o=e[g].apply(e[g],[].concat(r(n),[t]));return e.emit("fallback",o,t),o instanceof Promise?o:Promise.resolve(o)}catch(e){return Promise.reject(e)}}function A(e,t){var n=new Error(e);return n.code=t,n[E]=!0,n}var M=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(function(e){var t=16*Math.random()|0;return("x"===e?t:3&t|8).toString(16)}))};e.exports=_},384:(e,t)=>{"use strict";e.exports=function(e){var t=[],n=e,r={take:o,release:i,test:function(){return!(n<1)&&o()&&!0}};return Object.defineProperty(r,"count",{get:function(e){return n},enumerable:!0}),r;function o(e){return n>0?(--n,Promise.resolve(i)):new Promise((function(r,o){t.push((function(e){--n,r(i)})),e&&setTimeout((function(n){t.shift();var r=new Error("Timed out after ".concat(e,"ms"));r.code="ETIMEDOUT",o(r)}),e)}))}function i(){n++,t.length>0&&t.shift()()}}},741:(e,t,n)=>{"use strict";function r(e){return r="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},r(e)}function o(e,t){var n=Object.keys(e);if(Object.getOwnPropertySymbols){var r=Object.getOwnPropertySymbols(e);t&&(r=r.filter((function(t){return Object.getOwnPropertyDescriptor(e,t).enumerable}))),n.push.apply(n,r)}return n}function i(e){for(var t=1;t<arguments.length;t++){var n=null!=arguments[t]?arguments[t]:{};t%2?o(Object(n),!0).forEach((function(t){s(e,t,n[t])})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(n)):o(Object(n)).forEach((function(t){Object.defineProperty(e,t,Object.getOwnPropertyDescriptor(n,t))}))}return e}function s(e,t,n){return(t=c(t))in e?Object.defineProperty(e,t,{value:n,enumerable:!0,configurable:!0,writable:!0}):e[t]=n,e}function u(e,t){for(var n=0;n<t.length;n++){var r=t[n];r.enumerable=r.enumerable||!1,r.configurable=!0,"value"in r&&(r.writable=!0),Object.defineProperty(e,c(r.key),r)}}function c(e){var t=function(e,t){if("object"!==r(e)||null===e)return e;var n=e[Symbol.toPrimitive];if(void 0!==n){var o=n.call(e,"string");if("object"!==r(o))return o;throw new TypeError("@@toPrimitive must return a primitive value.")}return String(e)}(e);return"symbol"===r(t)?t:String(t)}function a(e,t){return a=Object.setPrototypeOf?Object.setPrototypeOf.bind():function(e,t){return e.__proto__=t,e},a(e,t)}function l(e){return l=Object.setPrototypeOf?Object.getPrototypeOf.bind():function(e){return e.__proto__||Object.getPrototypeOf(e)},l(e)}var f=Symbol("window"),p=Symbol("buckets"),h=Symbol("timeout"),y=Symbol("percentiles"),m=Symbol("bucket-interval"),v=Symbol("snapshot-interval"),b=Symbol("rotate-event-name"),d=function(e){!function(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Super expression must either be null or a function");e.prototype=Object.create(t&&t.prototype,{constructor:{value:e,writable:!0,configurable:!0}}),Object.defineProperty(e,"prototype",{writable:!1}),t&&a(e,t)}(d,e);var t,n,o,s,c=(o=d,s=function(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Boolean.prototype.valueOf.call(Reflect.construct(Boolean,[],(function(){}))),!0}catch(e){return!1}}(),function(){var e,t=l(o);if(s){var n=l(this).constructor;e=Reflect.construct(t,arguments,n)}else e=t.apply(this,arguments);return function(e,t){if(t&&("object"===r(t)||"function"==typeof t))return t;if(void 0!==t)throw new TypeError("Derived constructors may only return object or undefined");return function(e){if(void 0===e)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return e}(e)}(this,e)});function d(e){var t;!function(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}(this,d),(t=c.call(this))[p]=e.rollingCountBuckets||10,t[h]=e.rollingCountTimeout||1e4,t[f]=new Array(t[p]),t[y]=[0,.25,.5,.75,.9,.95,.99,.995,1],t[b]="rotate",t.rollingPercentilesEnabled=!1!==e.rollingPercentilesEnabled,t.enableSnapshots=!1!==e.enableSnapshots,t.rotateBucketController=e.rotateBucketController,t.rotateBucket=w(t[f]);for(var n=0;n<t[p];n++)t[f][n]=g();var r=Math.floor(t[h]/t[p]);return t.rotateBucketController?t.startListeneningForRotateEvent():(t[m]=setInterval(t.rotateBucket,r),"function"==typeof t[m].unref&&t[m].unref()),t.enableSnapshots&&(t[v]=setInterval((function(e){return t.emit("snapshot",t.stats)}),r),"function"==typeof t[v].unref&&t[v].unref()),e.stats&&(t[f][0]=i(i({},g()),e.stats)),t}return t=d,(n=[{key:"stats",get:function(){var e=this,t=this[f].reduce((function(t,n){return n?(Object.keys(t).forEach((function(e){"latencyTimes"!==e&&"percentiles"!==e&&(t[e]+=n[e]||0)})),e.rollingPercentilesEnabled&&t.latencyTimes.push.apply(t.latencyTimes,n.latencyTimes||[]),t):t}),g());return this.rollingPercentilesEnabled?(t.latencyTimes.sort((function(e,t){return e-t})),t.latencyTimes.length?t.latencyMean=t.latencyTimes.reduce((function(e,t){return e+t}),0)/t.latencyTimes.length:t.latencyMean=0,this[y].forEach((function(e){t.percentiles[e]=function(e,t){return 0===e?t[0]||0:t[Math.ceil(e*t.length)-1]||0}(e,t.latencyTimes)}))):(t.latencyMean=-1,this[y].forEach((function(e){t.percentiles[e]=-1}))),t}},{key:"window",get:function(){return this[f].slice()}},{key:"increment",value:function(e,t){this[f][0][e]++,"successes"!==e&&"failures"!==e&&"timeouts"!==e||this[f][0].latencyTimes.push(t||0)}},{key:"open",value:function(){this[f][0].isCircuitBreakerOpen=!0}},{key:"close",value:function(){this[f][0].isCircuitBreakerOpen=!1}},{key:"shutdown",value:function(){this.removeAllListeners(),void 0===this.rotateBucketController?clearInterval(this[m]):this.removeRotateBucketControllerListener(),this.enableSnapshots&&clearInterval(this[v])}},{key:"removeRotateBucketControllerListener",value:function(){this.rotateBucketController&&this.rotateBucketController.removeListener(this[b],this.rotateBucket)}},{key:"startListeneningForRotateEvent",value:function(){this.rotateBucketController&&0===this.rotateBucketController.listenerCount(this[b],this.rotateBucket)&&this.rotateBucketController.on(this[b],this.rotateBucket)}}])&&u(t.prototype,n),Object.defineProperty(t,"prototype",{writable:!1}),d}(n(187).EventEmitter),w=function(e){return function(t){e.pop(),e.unshift(g())}},g=function(e){return{failures:0,fallbacks:0,successes:0,rejects:0,fires:0,timeouts:0,cacheHits:0,cacheMisses:0,semaphoreRejections:0,percentiles:{},latencyTimes:[]}};e.exports=d}},t={},function n(r){var o=t[r];if(void 0!==o)return o.exports;var i=t[r]={exports:{}};return e[r](i,i.exports,n),i.exports}(524);var e,t}));
 //# sourceMappingURL=opossum.min.map

lib/circuit.js

@@ -101,2 +101,11 @@ 'use strict';
  * leaving it in the background
+ * @param {boolean} options.enableSnapshots whether to enable the rolling
+ * stats snapshots that opossum emits at the bucketInterval. Disable this
+ * as an optimization if you don't listen to the 'snapshot' event to reduce
+ * the number of timers opossum initiates.
+ * @param {EventEmitter} options.rotateBucketController if you have multiple
+ * breakers in your app, the number of timers across breakers can get costly.
+ * This option allows you to provide an EventEmitter that rotates the buckets
+ * so you can have one global timer in your app. Make sure that you are
+ * emitting a 'rotate' event from this EventEmitter
  *
@@ -163,2 +172,3 @@ *
     this.options.enableSnapshots = options.enableSnapshots !== false;
+    this.options.rotateBucketController = options.rotateBucketController;
 
@@ -794,2 +804,3 @@ // Set default cache transport if not provided
     this[ENABLED] = true;
+    this.status.startListeneningForRotateEvent();
   }
@@ -804,2 +815,3 @@
     this[ENABLED] = false;
+    this.status.removeRotateBucketControllerListener();
   }
@@ -806,0 +818,0 @@ }

lib/status.js

@@ -9,2 +9,3 @@ 'use strict';
 const SNAPSHOT_INTERVAL = Symbol('snapshot-interval');
+const ROTATE_EVENT_NAME = Symbol('rotate-event-name');
 
@@ -60,2 +61,3 @@ const EventEmitter = require('events').EventEmitter;
     this[PERCENTILES] = [0.0, 0.25, 0.5, 0.75, 0.9, 0.95, 0.99, 0.995, 1];
+    this[ROTATE_EVENT_NAME] = 'rotate';
 
@@ -69,13 +71,21 @@ // Default this value to true
 
+    // can be undefined
+    this.rotateBucketController = options.rotateBucketController;
+    this.rotateBucket = nextBucket(this[WINDOW]);
+
     // prime the window with buckets
     for (let i = 0; i < this[BUCKETS]; i++) this[WINDOW][i] = bucket();
 
-    // rotate the buckets periodically
     const bucketInterval = Math.floor(this[TIMEOUT] / this[BUCKETS]);
-    this[BUCKET_INTERVAL] = setInterval(nextBucket(this[WINDOW]),
-      bucketInterval);
 
-    // No unref() in the browser
-    if (typeof this[BUCKET_INTERVAL].unref === 'function') {
-      this[BUCKET_INTERVAL].unref();
+    if (this.rotateBucketController) {
+      // rotate the buckets based on an optional EventEmitter
+      this.startListeneningForRotateEvent();
+    } else {
+      // or rotate the buckets periodically
+      this[BUCKET_INTERVAL] = setInterval(this.rotateBucket, bucketInterval);
+      // No unref() in the browser
+      if (typeof this[BUCKET_INTERVAL].unref === 'function') {
+        this[BUCKET_INTERVAL].unref();
+      }
     }
@@ -179,3 +189,8 @@
     this.removeAllListeners();
-    clearInterval(this[BUCKET_INTERVAL]);
+    // interval is not set if rotateBucketController is provided
+    if (this.rotateBucketController === undefined) {
+      clearInterval(this[BUCKET_INTERVAL]);
+    } else {
+      this.removeRotateBucketControllerListener();
+    }
     if (this.enableSnapshots) {
@@ -185,2 +200,20 @@ clearInterval(this[SNAPSHOT_INTERVAL]);
   }
+
+  removeRotateBucketControllerListener () {
+    if (this.rotateBucketController) {
+      this.rotateBucketController.removeListener(this[ROTATE_EVENT_NAME],
+        this.rotateBucket);
+    }
+  }
+
+  startListeneningForRotateEvent () {
+    if (
+      this.rotateBucketController &&
+      this.rotateBucketController.listenerCount(this[ROTATE_EVENT_NAME],
+        this.rotateBucket) === 0
+    ) {
+      this.rotateBucketController.on(this[ROTATE_EVENT_NAME],
+        this.rotateBucket);
+    }
+  }
 }
@@ -187,0 +220,0 @@

package.json

 {
   "name": "opossum",
-  "version": "8.1.0",
+  "version": "8.1.1",
   "author": "Red Hat, Inc.",
@@ -39,4 +39,4 @@ "license": "Apache-2.0",
   "devDependencies": {
-    "@babel/core": "^7.21.8",
-    "@babel/preset-env": "^7.21.5",
+    "@babel/core": "^7.22.9",
+    "@babel/preset-env": "^7.22.9",
     "babel-loader": "^9.1.3",
@@ -59,5 +59,5 @@ "buffer": "^6.0.3",
     "stream-browserify": "^3.0.0",
-    "tape": "~5.6.3",
+    "tape": "~5.6.6",
     "util": "^0.12.5",
-    "webpack": "~5.88.0",
+    "webpack": "~5.88.2",
     "webpack-cli": "~5.1.4"
@@ -64,0 +64,0 @@ },

README.md

@@ -59,3 +59,3 @@ # opossum
 const CircuitBreaker = require('opossum');
-const http = require('http);
+const http = require('http');
 
@@ -62,0 +62,0 @@ function asyncFunctionThatCouldFail(abortSignal, x, y) {

New alerts

License Policy Violation

License

This 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

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

357013

increased by3.03%

Lines of code

2995

increased by2.96%

No dependency changes