@webqit/observer - npm Package Compare versions

Comparing version 1.3.3 to 1.3.4

dist/main.js

@@ -1,2 +0,2 @@
-!function(e){var t={};function r(n){if(t[n])return t[n].exports;var i=t[n]={i:n,l:!1,exports:{}};return e[n].call(i.exports,i,i.exports,r),i.l=!0,i.exports}r.m=e,r.c=t,r.d=function(e,t,n){r.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:n})},r.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},r.t=function(e,t){if(1&t&&(e=r(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(r.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var i in e)r.d(n,i,function(t){return e[t]}.bind(null,i));return n},r.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return r.d(t,"a",t),t},r.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},r.p="",r(r.s=0)}([function(e,t,r){"use strict";r.r(t);var n=function(e){return Array.isArray(e)},i=function(e){return e instanceof String||"string"==typeof e&&null!==e},s=function(e){return arguments.length&&(void 0===e||void 0===e)},a=function(e){return null===e||""===e},u=function(e){return"function"==typeof e},l=function(e){return Array.isArray(e)||"object"==typeof e&&e||u(e)},o=function(e){return!Array.isArray(e)&&"object"==typeof e&&e},c=function(e,t=!0){return n(e)?e:!t&&o(e)?[e]:!1!==e&&0!==e&&function(e){return a(e)||s(e)||!1===e||0===e||l(e)&&!Object.keys(e).length}(e)?[]:function(e){return!i(e)&&!s(e.length)}(e)?Array.prototype.slice.call(e):o(e)?Object.values(e):[e]},f=function(e){return e instanceof Number||"number"==typeof e},h=function(e){return u(e)||e&&"[object function]"==={}.toString.call(e)},p=function(e){return typeof e},d=function(e,t,r=null){if(!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');var n,i=Symbol.for(t);return!(n=e[i])&&r&&(n=new r(e),Object.defineProperty(e,i,{get:()=>n,enumerable:!1})),n};function b(e){return(g(e)?e:c(e).length?[e]:[]).reduce((e,t)=>e.concat([c(t)]),[])}function g(e){return c(e).reduce((e,t)=>e||n(t),!1)}function v(e){return e.filter(e=>!e&&0!==e).length}function m(e,t){return e.length===t.length&&e.reduce((e,r,n)=>e&&r===t[n],!0)}function y(e,t){return t.reduce((t,r,n)=>t&&r===e[n],!0)}function j(e,t){return e.slice(t.length)}var w=function(e,t,r=null){return n(t)?e.filter(e=>r?t.filter(t=>r(e,t)).length:-1!==t.indexOf(e)):[]},O=class{constructor(e){this.subject=e,this.fireables=[],this.currentlyFiring=[]}add(e){return this.fireables.push(e),e}remove(e){this.fireables=this.fireables.filter(t=>t!==e)}forget(e){this.match(e).forEach(e=>{this.fireables=this.fireables.filter(t=>t!==e)})}match(e){return this.fireables.filter(t=>{var r,n,i,s=b(t.filter),a=c((t.params||{}).tags),u=b(e.filter),l=c((e.params||{}).tags);return(!e.originalHandler||t.handler===e.originalHandler)&&(!u.length||(n=s,(r=u).length===n.length&&(i=(e,t)=>m(e,n[t]),r.reduce((e,t,r)=>e&&i(t,r),!0))))&&(!l.length||l.length===a.length&&w(a,l).length===l.length)})}},E=function(e){return f(e)||!0!==e&&!1!==e&&null!==e&&""!==e&&!isNaN(1*e)},P=function(e,t,r={},n={}){t=c(t).slice();for(var i=e;!s(i)&&!a(i)&&t.length;){var u=t.shift();if(!(r.get?r.get(i,u):l(i)?u in i:i[u]))return void(n.exists=!1);i=r.get?r.get(i,u):i[u]}return n.exists=!0,i},_=function(e,t=null){var r={};return 2===arguments.length&&(n(e)&&n(t)?e.forEach((e,n)=>r[e]=t[n]):r[e]=t),r},x=function(e){return u(e)&&/^class\s?/.test(Function.prototype.toString.call(e))},S=function(e,t){var r=[];return function(e,t){t=(t=t||Object.prototype)&&!n(t)?[t]:t;var r=[];for(e=e;e&&(!t||t.indexOf(e)<0)&&"default"!==e.name;)r.push(e),e=e?Object.getPrototypeOf(e):null;return r}(e,t).forEach(e=>{!function(e,...t){t.forEach(t=>{e.indexOf(t)<0&&e.push(t)})}(r,...Object.getOwnPropertyNames(e))}),r};function D(e,t,r=!1,i=!1,s=!1){var a=0,u=e.shift();if((E(u)||!0===u||!1===u)&&(a=u,u=e.shift()),!e.length)throw new Error("_merge() requires two or more array/objects.");return e.forEach((e,c)=>{(l(e)||h(e))&&(r?S(e):Object.getOwnPropertyNames(e)).forEach(l=>{if(t(l,u,e,c)){var f=u[l],h=e[l];if((n(f)&&n(h)||o(f)&&o(h))&&(!0===a||a>0))u[l]=n(f)&&n(h)?[]:{},D([E(a)?a-1:a,u[l],f,h],t,r,i,s);else if(n(u)&&n(e))i?u[l]=h:u.push(h);else try{s?Object.defineProperty(u,l,Object.getOwnPropertyDescriptor(e,l)):u[l]=e[l]}catch(e){}}})}),u}var V=function(e,t=[],r=!0){var i=0;return E(arguments[0])&&l(arguments[1])&&(i=arguments[0],e=arguments[1],t=arguments[2]||[]),D([i,{},e],(e,r,i)=>h(t)?t(e):!n(t)||!t.length||t.indexOf(e)>-1,!1,!1,r)},F=function(...e){return D(e,(e,t,r)=>!0,!1,!1,!1)},k=function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Observable subjects must be of type object; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),r&&!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i;if(i=$(e,!1))return i.forget({filter:t,originalHandler:r,params:n})},C=function(e,t){var r=void 0;return l(e)&&Object.keys(e).forEach((n,i)=>{!1!==r&&(r=t(E(n)?parseFloat(n):n,e[n],i))}),r},I=class{constructor(e,t){this.subject=e,this.handler=t.handler,this.filter=t.filter,this.params=t.params}disconnect(){this.disconnected=!0}},A=class extends I{fire(e,t,r){return this.disconnected||this.filter&&!w(c(this.filter),[e.type]).length?t(...Array.prototype.slice.call(arguments,2)):this.handler(e,r,t)}},T=class{constructor(e,t){if(this.subject=e,!t.type)throw new Error("Action type must be given in definition!");C(t,(e,t)=>{Object.defineProperty(this,e,{value:t,enumerable:!0})}),Object.seal(this)}},W=class extends O{add(e){return super.add(new A(this.subject,e))}fire(e,t=null){if(e instanceof T||(e=new T(this.subject,e)),this.currentlyFiring.filter(t=>t.type===e.type&&t.name===e.name).length)return t?t():void 0;this.currentlyFiring.push(e);const r=(n,...i)=>{var s=this.fireables[n];return s?s.fire(e,(...e)=>r(n+1,...e),...i):t?t(...i):i[0]};var n=r(0);return this.currentlyFiring.pop(),n}},H=function(e,t=!0){return d(e,".observer.interceptors",t?W:null)},U=function(e){var t;return l(e)&&(t=e[Symbol.for(".observer.proxy.target")])?t():e},q=function(e,t){if(!t||!l(t))throw new Error("Target must be of type object!");t=U(t);var r,n=function(r){return arguments.length?r:e?Object.getOwnPropertyNames(t):Object.keys(t)};return(r=H(t,!1))?r.fire({type:e?"ownKeys":"keys"},n)||[]:n()},N=function(e){return q(!1,...arguments)};function B(e,t=null,r=!1){if(!e||!l(e))throw new Error("Target must be of type object!");var n=$(e);if(n&&!n.build){n.build=r;var i=b(t),s=!i.length||i.filter(e=>!e[0]&&0!==e[0]).length?N(e):i.map(e=>e[0]),a=i.length?i.map(e=>e.slice(1)).filter(e=>e.length):null;n.subBuild=a&&a.length?a:null,s.forEach(t=>{var i=R(e,t);try{l(i)&&(z(e,t,i),(n.subBuild&&M(i)||(_isFunction(r)?r(i):r&&M(i)))&&B(i,n.subBuild,r))}catch(e){}})}}const M=e=>(e instanceof Object||e instanceof Array||e instanceof Function)&&("undefined"==typeof window||e!==window);var K=function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Observable subjects must be of type object; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i,s=$(e),a={filter:t,handler:r,params:n};if((a.filter||!0===a.params.subtree||"auto"===a.params.subtree&&M(e))&&B(e,a.filter,a.params.subtree),a.params.unique&&(i=s.match({filter:t,params:n})).length){if("replace"!==a.params.unique)return i[0];s.remove(i[0])}return s.add(a)},Q=class{constructor(e,t){if(this.subject=e,t.originalSubject||(this.originalSubject=e),!("type"in t))throw new Error("Delta type must be given in definition!");if(!("name"in t))throw new Error("Property name must be given in definition!");C(t,(e,t)=>{Object.defineProperty(this,e,{value:t,enumerable:!0})}),this.path||Object.defineProperty(this,"path",{value:[t.name],enumerable:!0}),Object.seal(this)}},z=function(e,t,r,n=null,i={}){var s;if(e!==r&&(K(r,(r,n)=>{if(s=$(e,!1)){var i=r.map(r=>{var n=r;do{if(n.subject===e)return}while(n=n.src);var i={};return C(r,(e,t)=>{"subject"!==e&&"name"!==e&&"path"!==e&&"src"!==e&&(i[e]=t)}),i.name=t,i.path=[t].concat(r.path),i.originalSubject=r.originalSubject,i.src=r,new Q(e,i)}).filter(e=>e);if(i.length)return s.fire(i,n.cancellable)}},{subtree:"auto",unique:!0,tags:[G,t,e]}),o(n)&&(s=$(e,!1)))){var a=F({name:t,type:"set",value:r,related:[t]},n);let e=s.fire(a,i.cancellable);if(i.responseObject)return e}};const G={};var J=function(e,t,r,n=null,i={}){var s;if(k(r,null,null,{tags:[G,t,e]}),o(n)&&(s=$(e,!1))){var a=F({name:t,type:"del",oldValue:r,related:[t]},n);s.fire(a,i.cancellable)}},L=function(e,...t){var r=t.map(e=>{if(!l(e))throw new Error("Target must be of type object!");return{subject:e,subjectCopy:n(e)?e.slice(0):V(e)}}),i=e(...t);return r.map(e=>{var t,r,n=Object.keys(e.subjectCopy),i=Object.keys(e.subject),s=[],a=(t=n.concat(i),t.filter((e,t,r)=>r.indexOf(e)===t)).map(t=>{if(e.subjectCopy[t]!==e.subject[t]){s.push(t);var r={name:t,related:s,buffered:!0};return i.includes(t)?(r.type="set",r.value=e.subject[t],n.includes(t)&&(r.isUpdate=!0)):r.type="del",n.includes(t)&&(r.oldValue=e.subjectCopy[t]),l(e.subjectCopy[t])&&J(e.subject,t,e.subjectCopy[t]),l(e.subject[t])&&z(e.subject,t,e.subject[t]),r}}).filter(e=>e);if(a.length&&(r=$(e.subject,!1)))return r.fire(a)}),i},R=function(e,t,r=!1){if(!e||!l(e))throw new Error("Target must be of type object!");e=U(e);var i,s,a=function(r){return arguments.length?r:n(t)?_(t,e):e[t]};return i=(s=H(e))?s.fire({type:"get",name:t},a):a(),r&&n(e)&&!E(t)&&h(i)&&!x(i)?function(...t){return L(()=>i.apply(e,t),e)}:i},X=class{constructor(e,t=!1){this._={},this._.target=e,this._.cancellable=t,this._.propagationStopped=!1,this._.defaultPrevented=!1,this._.promisesInstance=null,this._.promises=[]}get target(){return this._.target}get cancellable(){return this._.cancellable}stopPropagation(){this._.propagationStopped=!0}get propagationStopped(){return this._.propagationStopped}preventDefault(){this._.defaultPrevented=!0}get defaultPrevented(){return this._.defaultPrevented}waitUntil(e){e instanceof Promise&&(this._.promises.push(e),this._.promisesInstance=null)}get promises(){return!this._.promisesInstance&&this._.promises.length&&(this._.promisesInstance=Promise.all(this._.promises)),this._.promisesInstance}respondWith(e){var t,r=o(e)&&!s(e.propagationStopped)&&!s(e.defaultPrevented);!1===e||r&&e.propagationStopped?this.stopPropagation():!1===e||r&&e.defaultPrevented?this.preventDefault():(e instanceof Promise&&(t=e)||r&&(t=e.promises))&&this.waitUntil(t)}},Y=class extends I{constructor(e,t){if(super(e,t),this.filters2D=b(this.filter),this.filtersIsOriginally2D=g(this.filter),this.filtersIsDynamic=this.filters2D.filter(e=>v(c(e))).length,this.filtersIsDynamic&&this.filters2D.length>1)throw new Error('Only one "Dynamic Filter" must be observed at a time! "'+this.filters2D.map(e=>"["+e.join(", ")+"]").join(", ")+'" have been bound together.')}fire(e){if(this.disconnected||this.params.type&&(t=e=>this.params.type===e.type,!e.reduce((e,r,n)=>e||t(r,n),!1)))return;var t;const r=e=>["set","def"].includes(e.type)&&(!this.params.diff||(h(this.params.diff)?this.params.diff(e.value,e.oldValue):e.value!==e.oldValue));var n=new X(this.subject);if(this.filters2D.length){var i=[];this.filters2D.filter((t,n)=>(i[n]=[],e.filter(e=>{var s=this.filtersIsDynamic?t.map((t,r)=>t||0===t?t:e.path[r]||""):t;return i[n].filter(e=>m(e,s)).length||i[n].push(s),(m(s,e.path)||!1!==this.params.suptree&&y(s,e.path)&&(!E(this.params.suptree)||j(s,e.path).length<=this.params.suptree)||this.params.subtree&&y(e.path,s)&&(!E(this.params.subtree)||j(e.path,s).length<=this.params.subtree))&&(!this.filtersIsDynamic||!v(s))&&r(e)}).length)).length&&function(e){return e.reduce((e,t)=>{var r=[];return e.forEach(e=>{c(t).forEach(t=>{var n=e.slice();n.push(t),r.push(n)})}),r},[[]])}(i).forEach(t=>{var r=this.formatChanges(t,e);if(this.filtersIsOriginally2D){var i=r;o(this.filter)&&(i={},_each(this.filter,(e,t,n)=>{i[e]=r[n]})),n.respondWith(this.handler(i,n))}else n.respondWith(this.handler(r[0],n))})}else(this.params.subtree||e.filter(e=>m(e.path,[e.name])).length===e.length)&&e.filter(e=>r(e)).length&&n.respondWith(this.handler(e,n));return n}formatChanges(e,t){return!1===this.params.data?[]:e.map(e=>{var r=t.reduce((t,r)=>t||(m(e,r.path)||this.params.suptree&&y(e,r.path)||this.params.subtree&&y(r.path,e)?r:null),null);if(!r){var n=t.reduce((t,r)=>t||y(e,r.path)?r:null,null);if(n){var i=j(e,n.path),s={type:n.type,name:n.name,derived:!0,src:n};("del"===n.type||n.isUpdate)&&(s.oldValue=P(n.oldValue,i,{get:R})),"del"!==n.type&&(s.value=P(n.value,i,{get:R})),r=new Q(n.subject,s)}else r=new Q(this.subject,{type:"get",name:e[0],path:e,value:P(this.subject,e,{get:R}),derived:!0})}return r})}},Z=class extends O{add(e){return super.add(new Y(this.subject,e))}fire(e,t){var r=new X(this.subject,t);return e=c(e,!1).map(e=>e instanceof Q?e:new Q(this.subject,e)),this.currentlyFiring.filter(t=>e.filter(e=>t.type===e.type&&t.name===e.name).length).length,this.currentlyFiring.push(...e),this.fireables.forEach(n=>{if(r.propagationStopped&&t)return r;r.respondWith(n.fire(e))}),e.forEach(e=>function(e,t,r=!1){for(var n=e.indexOf(t);n>-1&&(r||!1===r);)e.splice(n,1),r>0&&r--,n=e.indexOf(t);return e}(this.currentlyFiring,e)),r}},$=function(e,t=!0){return d(e,".observer.observers",t?Z:null)},ee=function(e,t){if(!e||!l(e))throw new Error("Target must be of type object!");e=U(e);var r,n=function(r){return arguments.length?r:t in e};return(r=H(e,!1))?r.fire({type:"has",name:t},n):n()},te=function(e,t,r,s=null,a={}){if(!t||!l(t))throw new Error("Target must be of type object!");o(r)&&(a=s||{},s=null),t=U(t);var u=H(t,!1),h=$(t,!1);const p=(r,n,i,s)=>{var a,o="set";e&&(o="def",n=(a=n||{}).value);var c,f=!1;ee(t,r)&&(f=!0,c=R(t,r));var p={name:r,type:o,value:n,related:i,detail:s,isUpdate:f,oldValue:c},d=function(e){return arguments.length?e:(a?Object.defineProperty(t,r,a):t[r]=n,!0)};if(u){var b=a?{type:"def",name:r,descriptor:a,related:i,detail:s,isUpdate:f,oldValue:c}:{type:"set",name:r,value:n,related:i,detail:s,isUpdate:f,oldValue:c};p.success=u.fire(b,d)}else p.success=d();return p.success&&p.value!==p.oldValue&&(l(p.oldValue)&&J(t,r,p.oldValue),l(p.value)&&(z(t,r,p.value),h&&(h.subBuild||h.build&&M(p.value))&&B(p.value,h.subBuild,h.build))),p};var d,b=[];n(r)||(i(r)||f(r))&&(d=c(r))?b=d.map(e=>p(e,s,d,a.detail)):o(r)&&(d=Object.keys(r))&&(b=d.map(e=>p(e,r[e],d,a.detail)));var g,v=b.filter(e=>e.success);return h?(g=h.fire(v,a.cancellable)).successCount=v.length:a.responseObject&&(g=new X(t)),a.responseObject?g:v.length>0},re=function(e,t,r=null,n=null,i={}){return te(!1,...arguments)},ne=function(e,t,r={}){if(!e||!l(e))throw new Error("Target must be of type object!");e=U(e);var n,i,s=(t=c(t)).map(n=>{var i;ee(e,n)&&(i=R(e,n));var s,a={name:n,type:"del",related:t,detail:r.detail,oldValue:i},u=function(t){return arguments.length?t:(delete e[n],!0)};return(s=H(e,!1))?a.success=s.fire({type:"del",name:n,oldValue:i,related:t},u):a.success=u(),a.success&&l(a.oldValue)&&J(e,n,a.oldValue),a}).filter(e=>e.success);return(n=$(e,!1))?(i=n.fire(s,r.cancellable)).successCount=s.length:r.responseObject&&(i=new X(e)),r.responseObject?i:s.length>0},ie=function(e,t,r=null,n=null){return te(!0,...arguments)},se=function(e){return q(!0,...arguments)};var ae={set:re,get:R,has:ee,deleteProperty:ne,del:ne,defineProperty:ie,def:ie,keys:N,ownKeys:se,intercept:function(e,t,r,n={}){if(!l(e))throw new Error('Object must be of type subject; "'+p(r)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),!h(r))throw new Error('Callback must be a function; "'+p(r)+'" given!');var i,s=H(e),a={filter:t,handler:r,params:n};if(a.params.unique&&(i=s.match(a)).length){if("replace"!==a.params.unique)return i[0];s.remove(i[0])}return s.add(a)},unintercept:function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),r&&!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i;if(i=H(e,!1))return i.forget({filter:t,originalHandler:r,params:n})},proxy:function(e){if(!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');var t=new Proxy(e,{get:(e,r)=>{if(r===Symbol.for(".observer.proxy.target"))return()=>e;var n=R(e,r);return h(n)&&!x(n)?n.bind(t):n},set:(...e)=>(re(...e),!0),has:ee,deleteProperty:(...e)=>(ne(...e),!0),defineProperty:(...e)=>(ie(...e),!0),ownKeys:se});return t},unproxy:U,observe:K,unobserve:k,closure:L,init:function(e,t){c(t).forEach(t=>{var r,n,i=e[t],s=Object.getOwnPropertyDescriptor(e,t)||{enumerable:!(t in e)};"value"in s&&delete s.value,"writable"in s&&delete s.writable,s.get=()=>{if(r)return i;r=!0;var n=R(e,t);return r=!1,n},s.set=r=>{if(n)return i=r,!0;n=!0;re(e,t,r);return n=!1,!0},Object.defineProperty(e,t,s)})},build:B,link:z,unlink:J,getObservers:$};window.WQ||(window.WQ={}),window.WQ.Observer=ae}]);
+!function(e){var t={};function r(n){if(t[n])return t[n].exports;var i=t[n]={i:n,l:!1,exports:{}};return e[n].call(i.exports,i,i.exports,r),i.l=!0,i.exports}r.m=e,r.c=t,r.d=function(e,t,n){r.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:n})},r.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},r.t=function(e,t){if(1&t&&(e=r(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(r.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var i in e)r.d(n,i,function(t){return e[t]}.bind(null,i));return n},r.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return r.d(t,"a",t),t},r.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},r.p="",r(r.s=0)}([function(e,t,r){"use strict";r.r(t);var n=function(e){return Array.isArray(e)},i=function(e){return e instanceof String||"string"==typeof e&&null!==e},s=function(e){return arguments.length&&(void 0===e||void 0===e)},a=function(e){return null===e||""===e},u=function(e){return"function"==typeof e},l=function(e){return Array.isArray(e)||"object"==typeof e&&e||u(e)},o=function(e){return!Array.isArray(e)&&"object"==typeof e&&e},c=function(e,t=!0){return n(e)?e:!t&&o(e)?[e]:!1!==e&&0!==e&&function(e){return a(e)||s(e)||!1===e||0===e||l(e)&&!Object.keys(e).length}(e)?[]:function(e){return!i(e)&&!s(e.length)}(e)?Array.prototype.slice.call(e):o(e)?Object.values(e):[e]},f=function(e){return e instanceof Number||"number"==typeof e},h=function(e){return u(e)||e&&"[object function]"==={}.toString.call(e)},p=function(e){return typeof e},d=function(e,t,r=null){if(!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');var n,i=Symbol.for(t);return!(n=e[i])&&r&&(n=new r(e),Object.defineProperty(e,i,{get:()=>n,enumerable:!1})),n},b=function(e,t=1){var r=0;e.forEach(e=>{r++});var n=e.slice(e.length-r,t);return arguments.length>1?n:n[0]};function g(e){return(v(e)?e:c(e).length?[e]:[]).reduce((e,t)=>e.concat([c(t)]),[])}function v(e){return c(e).reduce((e,t)=>e||n(t),!1)}function m(e){return e.filter(e=>!e&&0!==e).length}function y(e,t){return e.length===t.length&&e.reduce((e,r,n)=>e&&r===t[n],!0)}function j(e,t){return t.reduce((t,r,n)=>t&&r===e[n],!0)}function w(e,t){return e.slice(t.length)}var O=function(e,t,r=null){return n(t)?e.filter(e=>r?t.filter(t=>r(e,t)).length:-1!==t.indexOf(e)):[]},E=class{constructor(e){this.subject=e,this.fireables=[],this.currentlyFiring=[]}add(e){return this.fireables.push(e),e}remove(e){this.fireables=this.fireables.filter(t=>t!==e)}forget(e){this.match(e).forEach(e=>{this.fireables=this.fireables.filter(t=>t!==e)})}match(e){return this.fireables.filter(t=>{var r,n,i,s=g(t.filter),a=c((t.params||{}).tags),u=g(e.filter),l=c((e.params||{}).tags);return(!e.originalHandler||t.handler===e.originalHandler)&&(!u.length||(n=s,(r=u).length===n.length&&(i=(e,t)=>y(e,n[t]),r.reduce((e,t,r)=>e&&i(t,r),!0))))&&(!l.length||l.length===a.length&&O(a,l).length===l.length)})}},P=function(e){return f(e)||!0!==e&&!1!==e&&null!==e&&""!==e&&!isNaN(1*e)},_=function(e,t,r={},n={}){t=c(t).slice();for(var i=e;!s(i)&&!a(i)&&t.length;){var u=t.shift();if(!(r.get?r.get(i,u):l(i)?u in i:i[u]))return void(n.exists=!1);i=r.get?r.get(i,u):i[u]}return n.exists=!0,i},x=function(e,t=null){var r={};return 2===arguments.length&&(n(e)&&n(t)?e.forEach((e,n)=>r[e]=t[n]):r[e]=t),r},S=function(e){return u(e)&&/^class\s?/.test(Function.prototype.toString.call(e))},D=function(e,t){var r=[];return function(e,t){t=(t=t||Object.prototype)&&!n(t)?[t]:t;var r=[];for(e=e;e&&(!t||t.indexOf(e)<0)&&"default"!==e.name;)r.push(e),e=e?Object.getPrototypeOf(e):null;return r}(e,t).forEach(e=>{!function(e,...t){t.forEach(t=>{e.indexOf(t)<0&&e.push(t)})}(r,...Object.getOwnPropertyNames(e))}),r};function V(e,t,r=!1,i=!1,s=!1){var a=0,u=e.shift();if((P(u)||!0===u||!1===u)&&(a=u,u=e.shift()),!e.length)throw new Error("_merge() requires two or more array/objects.");return e.forEach((e,c)=>{(l(e)||h(e))&&(r?D(e):Object.getOwnPropertyNames(e)).forEach(l=>{if(t(l,u,e,c)){var f=u[l],h=e[l];if((n(f)&&n(h)||o(f)&&o(h))&&(!0===a||a>0))u[l]=n(f)&&n(h)?[]:{},V([P(a)?a-1:a,u[l],f,h],t,r,i,s);else if(n(u)&&n(e))i?u[l]=h:u.push(h);else try{s?Object.defineProperty(u,l,Object.getOwnPropertyDescriptor(e,l)):u[l]=e[l]}catch(e){}}})}),u}var F=function(e,t=[],r=!0){var i=0;return P(arguments[0])&&l(arguments[1])&&(i=arguments[0],e=arguments[1],t=arguments[2]||[]),V([i,{},e],(e,r,i)=>h(t)?t(e):!n(t)||!t.length||t.indexOf(e)>-1,!1,!1,r)},k=function(...e){return V(e,(e,t,r)=>!0,!1,!1,!1)},C=function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Observable subjects must be of type object; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),r&&!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i;if(i=ee(e,!1))return i.forget({filter:t,originalHandler:r,params:n})},I=function(e,t){var r=void 0;return l(e)&&Object.keys(e).forEach((n,i)=>{!1!==r&&(r=t(P(n)?parseFloat(n):n,e[n],i))}),r},A=class{constructor(e,t){this.subject=e,this.handler=t.handler,this.filter=t.filter,this.params=t.params}disconnect(){this.disconnected=!0}},T=class extends A{fire(e,t,r){return this.disconnected||this.filter&&!O(c(this.filter),[e.type]).length?t(...Array.prototype.slice.call(arguments,2)):this.handler(e,r,t)}},W=class{constructor(e,t){if(this.subject=e,!t.type)throw new Error("Action type must be given in definition!");I(t,(e,t)=>{Object.defineProperty(this,e,{value:t,enumerable:!0})}),Object.seal(this)}},H=class extends E{add(e){return super.add(new T(this.subject,e))}fire(e,t=null){if(e instanceof W||(e=new W(this.subject,e)),this.currentlyFiring.filter(t=>t.type===e.type&&t.name===e.name).length)return t?t():void 0;this.currentlyFiring.push(e);const r=(n,...i)=>{var s=this.fireables[n];return s?s.fire(e,(...e)=>r(n+1,...e),...i):t?t(...i):i[0]};var n=r(0);return this.currentlyFiring.pop(),n}},U=function(e,t=!0){return d(e,".observer.interceptors",t?H:null)},q=function(e){var t;return l(e)&&(t=e[Symbol.for(".observer.proxy.target")])?t():e},N=function(e,t){if(!t||!l(t))throw new Error("Target must be of type object!");t=q(t);var r,n=function(r){return arguments.length?r:e?Object.getOwnPropertyNames(t):Object.keys(t)};return(r=U(t,!1))?r.fire({type:e?"ownKeys":"keys"},n)||[]:n()},B=function(e){return N(!1,...arguments)};function M(e,t=null,r=!1){if(!e||!l(e))throw new Error("Target must be of type object!");var n=ee(e);if(n&&!n.build){n.build=r;var i=g(t),s=!i.length||i.filter(e=>!e[0]&&0!==e[0]).length?B(e):i.map(e=>e[0]),a=i.length?i.map(e=>e.slice(1)).filter(e=>e.length):null;n.subBuild=a&&a.length?a:null,s.forEach(t=>{var i=X(e,t);try{l(i)&&(G(e,t,i),(n.subBuild&&K(i)||(_isFunction(r)?r(i):r&&K(i)))&&M(i,n.subBuild,r))}catch(e){}})}}const K=e=>(e instanceof Object||e instanceof Array||e instanceof Function)&&("undefined"==typeof window||e!==window);var Q=function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Observable subjects must be of type object; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i,s=ee(e),a={filter:t,handler:r,params:n};if((a.filter||!0===a.params.subtree||"auto"===a.params.subtree&&K(e))&&M(e,a.filter,a.params.subtree),a.params.unique&&(i=s.match({filter:t,params:n})).length){if("replace"!==a.params.unique)return i[0];s.remove(i[0])}return s.add(a)},z=class{constructor(e,t){if(this.subject=e,t.originalSubject||(this.originalSubject=e),!("type"in t))throw new Error("Delta type must be given in definition!");if(!("name"in t))throw new Error("Property name must be given in definition!");I(t,(e,t)=>{Object.defineProperty(this,e,{value:t,enumerable:!0})}),this.path||Object.defineProperty(this,"path",{value:[t.name],enumerable:!0}),Object.seal(this)}},G=function(e,t,r,n=null,i={}){var s;if(e!==r&&(Q(r,(r,n)=>{if(s=ee(e,!1)){var i=r.map(r=>{var n=r;do{if(n.subject===e)return}while(n=n.src);var i={};return I(r,(e,t)=>{"subject"!==e&&"name"!==e&&"path"!==e&&"src"!==e&&(i[e]=t)}),i.name=t,i.path=[t].concat(r.path),i.originalSubject=r.originalSubject,i.src=r,new z(e,i)}).filter(e=>e);if(i.length)return s.fire(i,n.cancellable)}},{subtree:"auto",unique:!0,tags:[J,t,e]}),o(n)&&(s=ee(e,!1)))){var a=k({name:t,type:"set",value:r,related:[t]},n);let e=s.fire(a,i.cancellable);if(i.responseObject)return e}};const J={};var L=function(e,t,r,n=null,i={}){var s;if(C(r,null,null,{tags:[J,t,e]}),o(n)&&(s=ee(e,!1))){var a=k({name:t,type:"del",oldValue:r,related:[t]},n);s.fire(a,i.cancellable)}},R=function(e,...t){var r=t.map(e=>{if(!l(e))throw new Error("Target must be of type object!");return{subject:e,subjectCopy:n(e)?e.slice(0):F(e)}}),i=e(...t);return r.map(e=>{var t,r,n=Object.keys(e.subjectCopy),i=Object.keys(e.subject),s=[],a=(t=n.concat(i),t.filter((e,t,r)=>r.indexOf(e)===t)).map(t=>{if(e.subjectCopy[t]!==e.subject[t]){s.push(t);var r={name:t,related:s,buffered:!0};return i.includes(t)?(r.type="set",r.value=e.subject[t],n.includes(t)&&(r.isUpdate=!0)):r.type="del",n.includes(t)&&(r.oldValue=e.subjectCopy[t]),l(e.subjectCopy[t])&&L(e.subject,t,e.subjectCopy[t]),l(e.subject[t])&&G(e.subject,t,e.subject[t]),r}}).filter(e=>e);if(a.length&&(r=ee(e.subject,!1)))return r.fire(a)}),i},X=function(e,t,r=!1){if(!e||!l(e))throw new Error("Target must be of type object!");e=q(e);var i,s,a=function(r){return arguments.length?r:n(t)?x(t,e):e[t]};return i=(s=U(e))?s.fire({type:"get",name:t},a):a(),r&&n(e)&&!P(t)&&h(i)&&!S(i)?function(...t){return R(()=>i.apply(e,t),e)}:i},Y=class{constructor(e,t=!1){this._={},this._.target=e,this._.cancellable=t,this._.propagationStopped=!1,this._.defaultPrevented=!1,this._.promisesInstance=null,this._.promises=[]}get target(){return this._.target}get cancellable(){return this._.cancellable}stopPropagation(){this._.propagationStopped=!0}get propagationStopped(){return this._.propagationStopped}preventDefault(){this._.defaultPrevented=!0}get defaultPrevented(){return this._.defaultPrevented}waitUntil(e){e instanceof Promise&&(this._.promises.push(e),this._.promisesInstance=null)}get promises(){return!this._.promisesInstance&&this._.promises.length&&(this._.promisesInstance=Promise.all(this._.promises)),this._.promisesInstance}respondWith(e){var t,r=o(e)&&!s(e.propagationStopped)&&!s(e.defaultPrevented);!1===e||r&&e.propagationStopped?this.stopPropagation():!1===e||r&&e.defaultPrevented?this.preventDefault():(e instanceof Promise&&(t=e)||r&&(t=e.promises))&&this.waitUntil(t)}},Z=class extends A{constructor(e,t){if(super(e,t),this.filters2D=g(this.filter),this.filtersIsOriginally2D=v(this.filter),this.filtersIsDynamic=this.filters2D.filter(e=>m(c(e))).length,this.filtersIsDynamic&&this.filters2D.length>1)throw new Error('Only one "Dynamic Filter" must be observed at a time! "'+this.filters2D.map(e=>"["+e.join(", ")+"]").join(", ")+'" have been bound together.')}fire(e){if(this.disconnected||this.params.type&&(t=e=>this.params.type===e.type,!e.reduce((e,r,n)=>e||t(r,n),!1)))return;var t;const r=e=>["set","def"].includes(e.type)&&(!this.params.diff||(h(this.params.diff)?this.params.diff(e.value,e.oldValue):e.value!==e.oldValue));var n=new Y(this.subject);if(this.filters2D.length){var i=[];this.filters2D.filter((t,n)=>(i[n]=[],e.filter(e=>{var s=this.filtersIsDynamic?t.map((t,r)=>t||0===t?t:e.path[r]||""):t;return i[n].filter(e=>y(e,s)).length||i[n].push(s),(y(s,e.path)||!1!==this.params.suptree&&j(s,e.path)&&(!P(this.params.suptree)||w(s,e.path).length<=this.params.suptree)||this.params.subtree&&j(e.path,s)&&(!P(this.params.subtree)||w(e.path,s).length<=this.params.subtree))&&(!this.filtersIsDynamic||!m(s))&&r(e)}).length)).length&&function(e){return e.reduce((e,t)=>{var r=[];return e.forEach(e=>{c(t).forEach(t=>{var n=e.slice();n.push(t),r.push(n)})}),r},[[]])}(i).forEach(t=>{var r=this.formatChanges(t,e);if(this.filtersIsOriginally2D){var i=r;o(this.filter)&&(i={},_each(this.filter,(e,t,n)=>{i[e]=r[n]})),n.respondWith(this.handler(i,n))}else n.respondWith(this.handler(r[0],n))})}else(this.params.subtree||e.filter(e=>y(e.path,[e.name])).length===e.length)&&e.filter(e=>r(e)).length&&n.respondWith(this.handler(e,n));return n}formatChanges(e,t){return!1===this.params.data?[]:e.map(e=>{var r=t.reduce((t,r)=>t||(y(e,r.path)||this.params.suptree&&j(e,r.path)||this.params.subtree&&j(r.path,e)?r:null),null);if(!r){var n=t.reduce((t,r)=>t||j(e,r.path)?r:null,null);if(n){var i=w(e,n.path),s={type:n.type,name:n.name,derived:!0,src:n};("del"===n.type||n.isUpdate)&&(s.oldValue=_(n.oldValue,i,{get:X})),"del"!==n.type&&(s.value=_(n.value,i,{get:X})),r=new z(n.subject,s)}else r=new z(this.subject,{type:"get",name:e[0],path:e,value:_(this.subject,e,{get:X}),derived:!0})}return r})}},$=class extends E{constructor(e){super(e),this.buffers=[]}add(e){return super.add(new Z(this.subject,e))}fire(e,t){var r=new Y(this.subject,t);return e=c(e,!1).map(e=>e instanceof z?e:new z(this.subject,e)),this.buffers.length?(function(e,t=1){return arguments.length>1?b(e.slice().reverse(),t).reverse():b(e.slice().reverse())}(this.buffers)(e),r):(this.currentlyFiring.filter(t=>e.filter(e=>t.type===e.type&&t.name===e.name).length).length,this.currentlyFiring.push(...e),this.fireables.forEach(n=>{if(r.propagationStopped&&t)return r;r.respondWith(n.fire(e))}),e.forEach(e=>function(e,t,r=!1){for(var n=e.indexOf(t);n>-1&&(r||!1===r);)e.splice(n,1),r>0&&r--,n=e.indexOf(t);return e}(this.currentlyFiring,e)),r)}},ee=function(e,t=!0){return d(e,".observer.observers",t?$:null)},te=function(e,t){if(!e||!l(e))throw new Error("Target must be of type object!");e=q(e);var r,n=function(r){return arguments.length?r:t in e};return(r=U(e,!1))?r.fire({type:"has",name:t},n):n()},re=function(e,t,r,s=null,a={}){if(!t||!l(t))throw new Error("Target must be of type object!");o(r)&&(a=s||{},s=null),t=q(t);var u=U(t,!1),h=ee(t,!1);const p=(r,n,i,s)=>{var a,o="set";e&&(o="def",n=(a=n||{}).value);var c,f=!1;te(t,r)&&(f=!0,c=X(t,r));var p={name:r,type:o,value:n,related:i,detail:s,isUpdate:f,oldValue:c},d=function(e){return arguments.length?e:(a?Object.defineProperty(t,r,a):t[r]=n,!0)};if(u){var b=a?{type:"def",name:r,descriptor:a,related:i,detail:s,isUpdate:f,oldValue:c}:{type:"set",name:r,value:n,related:i,detail:s,isUpdate:f,oldValue:c};p.success=u.fire(b,d)}else p.success=d();return p.success&&p.value!==p.oldValue&&(l(p.oldValue)&&L(t,r,p.oldValue),l(p.value)&&(G(t,r,p.value),h&&(h.subBuild||h.build&&K(p.value))&&M(p.value,h.subBuild,h.build))),p};var d,b=[];n(r)||(i(r)||f(r))&&(d=c(r))?b=d.map(e=>p(e,s,d,a.detail)):o(r)&&(d=Object.keys(r))&&(b=d.map(e=>p(e,r[e],d,a.detail)));var g,v=b.filter(e=>e.success);return h?(g=h.fire(v,a.cancellable)).successCount=v.length:a.responseObject&&(g=new Y(t)),a.responseObject?g:v.length>0},ne=function(e,t,r=null,n=null,i={}){return re(!1,...arguments)},ie=function(e,t,r={}){if(!e||!l(e))throw new Error("Target must be of type object!");e=q(e);var n,i,s=(t=c(t)).map(n=>{var i;te(e,n)&&(i=X(e,n));var s,a={name:n,type:"del",related:t,detail:r.detail,oldValue:i},u=function(t){return arguments.length?t:(delete e[n],!0)};return(s=U(e,!1))?a.success=s.fire({type:"del",name:n,oldValue:i,related:t},u):a.success=u(),a.success&&l(a.oldValue)&&L(e,n,a.oldValue),a}).filter(e=>e.success);return(n=ee(e,!1))?(i=n.fire(s,r.cancellable)).successCount=s.length:r.responseObject&&(i=new Y(e)),r.responseObject?i:s.length>0},se=function(e,t,r=null,n=null){return re(!0,...arguments)},ae=function(e){return N(!0,...arguments)};var ue={set:ne,get:X,has:te,deleteProperty:ie,del:ie,defineProperty:se,def:se,keys:B,ownKeys:ae,intercept:function(e,t,r,n={}){if(!l(e))throw new Error('Object must be of type subject; "'+p(r)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),!h(r))throw new Error('Callback must be a function; "'+p(r)+'" given!');var i,s=U(e),a={filter:t,handler:r,params:n};if(a.params.unique&&(i=s.match(a)).length){if("replace"!==a.params.unique)return i[0];s.remove(i[0])}return s.add(a)},unintercept:function(e,t,r=null,n={}){if(!e||!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');if(h(t)&&(n=arguments.length>2?r:{},r=t,t=null),r&&!h(r))throw new Error('Handler must be a function; "'+p(r)+'" given!');var i;if(i=U(e,!1))return i.forget({filter:t,originalHandler:r,params:n})},proxy:function(e){if(!l(e))throw new Error('Object must be of type subject; "'+p(e)+'" given!');var t=new Proxy(e,{get:(e,r)=>{if(r===Symbol.for(".observer.proxy.target"))return()=>e;var n=X(e,r);return h(n)&&!S(n)?n.bind(t):n},set:(...e)=>(ne(...e),!0),has:te,deleteProperty:(...e)=>(ie(...e),!0),defineProperty:(...e)=>(se(...e),!0),ownKeys:ae});return t},unproxy:q,observe:Q,unobserve:C,closure:R,init:function(e,t){c(t).forEach(t=>{var r,n,i=e[t],s=Object.getOwnPropertyDescriptor(e,t)||{enumerable:!(t in e)};"value"in s&&delete s.value,"writable"in s&&delete s.writable,s.get=()=>{if(r)return i;r=!0;var n=X(e,t);return r=!1,n},s.set=r=>{if(n)return i=r,!0;n=!0;ne(e,t,r);return n=!1,!0},Object.defineProperty(e,t,s)})},build:M,link:G,unlink:L,getObservers:ee};window.WQ||(window.WQ={}),window.WQ.Observer=ue}]);
 //# sourceMappingURL=main.js.map

package.json

@@ -15,3 +15,3 @@ {
   "homepage": "https://webqit.io/tooling/observer",
-  "version": "1.3.3",
+  "version": "1.3.4",
   "license": "MIT",
@@ -18,0 +18,0 @@ "repository": {

src/observer/Observers.js

@@ -7,2 +7,3 @@
 import _remove from '@webqit/util/arr/remove.js';
+import _last from '@webqit/util/arr/last.js';
 import Firebase from '../Firebase.js';
@@ -22,2 +23,14 @@ import Observer from './Observer.js';
 	/**
+	 * Initializes the instance.
+	 *
+	 * @param object	subject
+	 * 
+	 * @return void
+	 */
+	constructor(subject) {
+		super(subject);
+		this.buffers = [];
+	}
+	
+	/**
 	 * @inheritdoc
@@ -41,2 +54,6 @@ */
 		changes = _arrFrom(changes, false).map(delta => !(delta instanceof Delta) ? new Delta(this.subject, delta) : delta);
+		if (this.buffers.length) {
+			_last(this.buffers)(changes);
+			return evt;
+		}
 		if (this.currentlyFiring.filter(d => changes.filter(delta => d.type === delta.type && d.name === delta.name).length).length) {
@@ -43,0 +60,0 @@ //return false;

No alert changes

Improved metrics

Total package byte prevSize

170337

increased by1.4%

Lines of code

1697

increased by1.01%

No dependency changes