Comparing version 0.0.7 to 0.0.8
@@ -508,8 +508,8 @@ (function (global, factory) { | ||
return __awaiter(this, void 0, void 0, function () { | ||
var result, value, _a; | ||
return __generator(this, function (_b) { | ||
switch (_b.label) { | ||
var result, payload, _a, _b; | ||
return __generator(this, function (_c) { | ||
switch (_c.label) { | ||
case 0: return [4 /*yield*/, this.loader.load(query)]; | ||
case 1: | ||
_b.sent(); | ||
_c.sent(); | ||
if (!this.loader.hasHandler(query)) { | ||
@@ -521,14 +521,16 @@ throw new QueryHandlerNotFoundException("QueryHandler not found for command \"" + getActionTypeFromInstance(query) + "\""); | ||
if (!this.enableLogging) return [3 /*break*/, 5]; | ||
payload = { query: query }; | ||
this.logger.logQuery(getActionTypeFromInstance(query), payload); | ||
_a = payload; | ||
if (!(result instanceof Promise)) return [3 /*break*/, 3]; | ||
return [4 /*yield*/, result]; | ||
case 2: | ||
_a = (_b.sent()); | ||
_b = (_c.sent()); | ||
return [3 /*break*/, 4]; | ||
case 3: | ||
_a = result; | ||
_b.label = 4; | ||
_b = result; | ||
_c.label = 4; | ||
case 4: | ||
value = _a; | ||
this.logger.logQuery(getActionTypeFromInstance(query), { query: query, result: value }); | ||
return [2 /*return*/, Promise.resolve(value)]; | ||
_a.result = _b; | ||
return [2 /*return*/, Promise.resolve(payload.result)]; | ||
case 5: return [2 /*return*/, this.loader.execute(query)]; | ||
@@ -582,2 +584,3 @@ } | ||
if (!this.enableLogging) return [3 /*break*/, 5]; | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
if (!(result instanceof Promise)) return [3 /*break*/, 3]; | ||
@@ -593,3 +596,2 @@ return [4 /*yield*/, result]; | ||
value = _a; | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
return [2 /*return*/, Promise.resolve(value)]; | ||
@@ -596,0 +598,0 @@ case 5: return [2 /*return*/, result]; |
@@ -15,3 +15,3 @@ !function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports,require("reflect-metadata"),require("rxjs"),require("@angular/core"),require("rxjs/operators")):"function"==typeof define&&define.amd?define("ng-cqrs",["exports","reflect-metadata","rxjs","@angular/core","rxjs/operators"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self)["ng-cqrs"]={},null,e.rxjs,e.ng.core,e.rxjs.operators)}(this,(function(e,t,r,n,o){"use strict"; | ||
PERFORMANCE OF THIS SOFTWARE. | ||
***************************************************************************** */var a=function(e,t){return(a=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,t){e.__proto__=t}||function(e,t){for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(e[r]=t[r])})(e,t)};function i(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Class extends value "+String(t)+" is not a constructor or null");function r(){this.constructor=e}a(e,t),e.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}function c(e,t,r,n){return new(r||(r=Promise))((function(o,a){function i(e){try{u(n.next(e))}catch(e){a(e)}}function c(e){try{u(n.throw(e))}catch(e){a(e)}}function u(e){var t;e.done?o(e.value):(t=e.value,t instanceof r?t:new r((function(e){e(t)}))).then(i,c)}u((n=n.apply(e,t||[])).next())}))}function u(e,t){var r,n,o,a,i={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return a={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(a[Symbol.iterator]=function(){return this}),a;function c(a){return function(c){return function(a){if(r)throw new TypeError("Generator is already executing.");for(;i;)try{if(r=1,n&&(o=2&a[0]?n.return:a[0]?n.throw||((o=n.return)&&o.call(n),0):n.next)&&!(o=o.call(n,a[1])).done)return o;switch(n=0,o&&(a=[2&a[0],o.value]),a[0]){case 0:case 1:o=a;break;case 4:return i.label++,{value:a[1],done:!1};case 5:i.label++,n=a[1],a=[0];continue;case 7:a=i.ops.pop(),i.trys.pop();continue;default:if(!(o=i.trys,(o=o.length>0&&o[o.length-1])||6!==a[0]&&2!==a[0])){i=0;continue}if(3===a[0]&&(!o||a[1]>o[0]&&a[1]<o[3])){i.label=a[1];break}if(6===a[0]&&i.label<o[1]){i.label=o[1],o=a;break}if(o&&i.label<o[2]){i.label=o[2],i.ops.push(a);break}o[2]&&i.ops.pop(),i.trys.pop();continue}a=t.call(e,i)}catch(e){a=[6,e],n=0}finally{r=o=0}if(5&a[0])throw a[1];return{value:a[0]?a[1]:void 0,done:!0}}([a,c])}}}Object.create;function s(e,t){var r="function"==typeof Symbol&&e[Symbol.iterator];if(!r)return e;var n,o,a=r.call(e),i=[];try{for(;(void 0===t||t-- >0)&&!(n=a.next()).done;)i.push(n.value)}catch(e){o={error:e}}finally{try{n&&!n.done&&(r=a.return)&&r.call(a)}finally{if(o)throw o.error}}return i}function l(){for(var e=[],t=0;t<arguments.length;t++)e=e.concat(s(arguments[t]));return e}Object.create;var f="__saga__";var d=function(e){function t(t){return e.call(this,'The action handler for the "'+t+'" action was not found!')||this}return i(t,e),t}(Error),p=function(e){function t(t){return e.call(this,'The query handler for the "'+t+'" query was not found!')||this}return i(t,e),t}(Error),h=function(e){function t(){return e.call(this,"Invalid saga exception. Each saga should return an Observable object")||this}return i(t,e),t}(Error),y=function(e){function t(){var t=e.call(this)||this;return t.subject$=new r.Subject,t.source=t.subject$,t}return i(t,e),t}(r.Observable);function g(e){return e.constructor&&e.constructor.type?e.constructor.type:e.type}var v=new n.InjectionToken("CQRS_MODULE_REGISTRY"),b=new n.InjectionToken("CQRS_MODULE_SAGAS"),j=new n.InjectionToken("CQRS_MODULE_LOGGING"),m=function(){function e(){}return e.prototype.execute=function(){return c(this,void 0,void 0,(function(){return u(this,(function(e){return[2,void 0]}))}))},e}();m.decorators=[{type:n.NgModule}];var w=function(){function e(e,t,r){var n=this;this.moduleRef=e,this.compiler=t,this.registry=r,this.handlersToLoad=new Map,this.handlersLoading=new Map,this.handlersLoaded=new Map,r.forEach((function(e){var t=e.handler;t||(t=function(){return Promise.resolve(m)}),n.handlersToLoad.set(g(e.impl),t)}))}return e.prototype.hasHandler=function(e){return this.handlersLoaded.has(g(e))},e.prototype.execute=function(e){return this.handlersLoaded.get(g(e)).execute(e)},e.prototype.load=function(e){var t=this,r=g(e),o=this.handlersToLoad.get(r);if(this.handlersLoading.has(r))return this.handlersLoading.get(r);if(this.handlersToLoad.has(r)){var a=o().then((function(e){return e instanceof n.NgModuleFactory?e:t.compiler.compileModuleAsync(e)})).then((function(e){return e.create(t.moduleRef.injector).instance})).then((function(e){return t.handlersLoaded.set(r,e),Promise.resolve()})).then((function(){t.handlersLoading.delete(r),t.handlersToLoad.delete(r)})).catch((function(e){return t.handlersLoading.delete(r),Promise.reject(e)}));return this.handlersLoading.set(r,a),a}return Promise.resolve()},e}();function x(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];var r=function(t){return!!e.find((function(e){return"string"==typeof e?g(t)===e:g(t)===g(e)}))};return function(e){return e.pipe(o.filter(r))}}w.decorators=[{type:n.Injectable}],w.ctorParameters=function(){return[{type:n.NgModuleRef},{type:n.Compiler},{type:Array,decorators:[{type:n.Inject,args:[v]}]}]};var L=function(){function e(){}return e.prototype.logAction=function(e,t){console.log("%c["+e+"]","color: #0077cc",t)},e.prototype.logQuery=function(e,t){console.log("%c["+e+"]","color: #439a00",t)},e}();L.decorators=[{type:n.Injectable}];var S=function(e){function t(t,r,n){var o=e.call(this)||this;return o.loader=t,o.logger=r,o.enableLogging=n,o}return i(t,e),t.prototype.execute=function(e){return c(this,void 0,void 0,(function(){var t,r,n;return u(this,(function(o){switch(o.label){case 0:return[4,this.loader.load(e)];case 1:if(o.sent(),!this.loader.hasHandler(e))throw new p('QueryHandler not found for command "'+g(e)+'"');return this.subject$.next(e),t=this.loader.execute(e),this.enableLogging?t instanceof Promise?[4,t]:[3,3]:[3,5];case 2:return n=o.sent(),[3,4];case 3:n=t,o.label=4;case 4:return r=n,this.logger.logQuery(g(e),{query:e,result:r}),[2,Promise.resolve(r)];case 5:return[2,this.loader.execute(e)]}}))}))},t.prototype.ofType=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return this.subject$.pipe(x.apply(void 0,l(e)),o.share())},t}(y);S.decorators=[{type:n.Injectable}],S.ctorParameters=function(){return[{type:w},{type:L},{type:Boolean,decorators:[{type:n.Inject,args:[j]}]}]};var _=function(e){function t(t,r,n,o){var a=e.call(this)||this;return a.loader=t,a.logger=r,a.sagas=n,a.enableLogging=o,a.registerSagas(n),a}return i(t,e),t.prototype.execute=function(e){return c(this,void 0,void 0,(function(){var t,r,n;return u(this,(function(o){switch(o.label){case 0:return[4,this.loader.load(e)];case 1:if(o.sent(),!this.loader.hasHandler(e))throw new d('ActionHandler not found for command "'+g(e)+'"');return this.subject$.next(e),t=this.loader.execute(e),this.enableLogging?t instanceof Promise?[4,t]:[3,3]:[3,5];case 2:return n=o.sent(),[3,4];case 3:n=t,o.label=4;case 4:return r=n,this.logger.logAction(g(e),e),[2,Promise.resolve(r)];case 5:return[2,t]}}))}))},t.prototype.ofType=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return this.subject$.pipe(x.apply(void 0,l(e)),o.share())},t.prototype.registerSagas=function(e){var t=this;void 0===e&&(e=[]),e.map((function(e){return(Reflect.getMetadata(f,e.constructor)||[]).map((function(t){return e[t]}))})).reduce((function(e,t){return e.concat(t)}),[]).forEach((function(e){return t.registerSaga(e)}))},t.prototype.registerSaga=function(e){var t=this;if("function"!=typeof e)throw new h;var n=e(this.subject$);if(!(n instanceof r.Observable))throw new h;n.pipe(o.filter((function(e){return!!e}))).subscribe((function(e){Array.isArray(e)?e.forEach((function(e){return t.execute(e)})):t.execute(e)}))},t}(y);_.decorators=[{type:n.Injectable}],_.ctorParameters=function(){return[{type:w},{type:L},{type:Array,decorators:[{type:n.Inject,args:[b]}]},{type:Boolean,decorators:[{type:n.Inject,args:[j]}]}]};var E=function(){function e(){}return e.forRoot=function(t){return{ngModule:e,providers:l([S,_,w,L],(t=t||{sagas:[],registry:[]}).sagas,[{provide:j,useValue:!!t.enableLogging},{provide:v,useValue:t.registry||[]},{provide:b,deps:t.sagas,useFactory:e.createSourceInstances}])}},e.createSourceInstances=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return e},e}();E.decorators=[{type:n.NgModule}],e.ActionBus=_,e.ActionHandlerNotFoundException=d,e.CQRS_MODULE_LOGGING=j,e.CQRS_MODULE_REGISTRY=v,e.CQRS_MODULE_SAGAS=b,e.CqrsModule=E,e.InvalidSagaException=h,e.ObservableBus=y,e.QueryBus=S,e.QueryHandlerNotFoundException=p,e.Saga=function(){return function(e,t){var r=Reflect.getMetadata(f,e.constructor)||[];Reflect.defineMetadata(f,l(r,[t]),e.constructor)}},e.getActionTypeFromInstance=g,e.ofType=x,e.ɵa=y,e.ɵb=w,e.ɵd=L,Object.defineProperty(e,"__esModule",{value:!0})})); | ||
***************************************************************************** */var a=function(e,t){return(a=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(e,t){e.__proto__=t}||function(e,t){for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&(e[r]=t[r])})(e,t)};function i(e,t){if("function"!=typeof t&&null!==t)throw new TypeError("Class extends value "+String(t)+" is not a constructor or null");function r(){this.constructor=e}a(e,t),e.prototype=null===t?Object.create(t):(r.prototype=t.prototype,new r)}function c(e,t,r,n){return new(r||(r=Promise))((function(o,a){function i(e){try{u(n.next(e))}catch(e){a(e)}}function c(e){try{u(n.throw(e))}catch(e){a(e)}}function u(e){var t;e.done?o(e.value):(t=e.value,t instanceof r?t:new r((function(e){e(t)}))).then(i,c)}u((n=n.apply(e,t||[])).next())}))}function u(e,t){var r,n,o,a,i={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return a={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(a[Symbol.iterator]=function(){return this}),a;function c(a){return function(c){return function(a){if(r)throw new TypeError("Generator is already executing.");for(;i;)try{if(r=1,n&&(o=2&a[0]?n.return:a[0]?n.throw||((o=n.return)&&o.call(n),0):n.next)&&!(o=o.call(n,a[1])).done)return o;switch(n=0,o&&(a=[2&a[0],o.value]),a[0]){case 0:case 1:o=a;break;case 4:return i.label++,{value:a[1],done:!1};case 5:i.label++,n=a[1],a=[0];continue;case 7:a=i.ops.pop(),i.trys.pop();continue;default:if(!(o=i.trys,(o=o.length>0&&o[o.length-1])||6!==a[0]&&2!==a[0])){i=0;continue}if(3===a[0]&&(!o||a[1]>o[0]&&a[1]<o[3])){i.label=a[1];break}if(6===a[0]&&i.label<o[1]){i.label=o[1],o=a;break}if(o&&i.label<o[2]){i.label=o[2],i.ops.push(a);break}o[2]&&i.ops.pop(),i.trys.pop();continue}a=t.call(e,i)}catch(e){a=[6,e],n=0}finally{r=o=0}if(5&a[0])throw a[1];return{value:a[0]?a[1]:void 0,done:!0}}([a,c])}}}Object.create;function s(e,t){var r="function"==typeof Symbol&&e[Symbol.iterator];if(!r)return e;var n,o,a=r.call(e),i=[];try{for(;(void 0===t||t-- >0)&&!(n=a.next()).done;)i.push(n.value)}catch(e){o={error:e}}finally{try{n&&!n.done&&(r=a.return)&&r.call(a)}finally{if(o)throw o.error}}return i}function l(){for(var e=[],t=0;t<arguments.length;t++)e=e.concat(s(arguments[t]));return e}Object.create;var f="__saga__";var d=function(e){function t(t){return e.call(this,'The action handler for the "'+t+'" action was not found!')||this}return i(t,e),t}(Error),p=function(e){function t(t){return e.call(this,'The query handler for the "'+t+'" query was not found!')||this}return i(t,e),t}(Error),h=function(e){function t(){return e.call(this,"Invalid saga exception. Each saga should return an Observable object")||this}return i(t,e),t}(Error),y=function(e){function t(){var t=e.call(this)||this;return t.subject$=new r.Subject,t.source=t.subject$,t}return i(t,e),t}(r.Observable);function g(e){return e.constructor&&e.constructor.type?e.constructor.type:e.type}var v=new n.InjectionToken("CQRS_MODULE_REGISTRY"),b=new n.InjectionToken("CQRS_MODULE_SAGAS"),j=new n.InjectionToken("CQRS_MODULE_LOGGING"),m=function(){function e(){}return e.prototype.execute=function(){return c(this,void 0,void 0,(function(){return u(this,(function(e){return[2,void 0]}))}))},e}();m.decorators=[{type:n.NgModule}];var w=function(){function e(e,t,r){var n=this;this.moduleRef=e,this.compiler=t,this.registry=r,this.handlersToLoad=new Map,this.handlersLoading=new Map,this.handlersLoaded=new Map,r.forEach((function(e){var t=e.handler;t||(t=function(){return Promise.resolve(m)}),n.handlersToLoad.set(g(e.impl),t)}))}return e.prototype.hasHandler=function(e){return this.handlersLoaded.has(g(e))},e.prototype.execute=function(e){return this.handlersLoaded.get(g(e)).execute(e)},e.prototype.load=function(e){var t=this,r=g(e),o=this.handlersToLoad.get(r);if(this.handlersLoading.has(r))return this.handlersLoading.get(r);if(this.handlersToLoad.has(r)){var a=o().then((function(e){return e instanceof n.NgModuleFactory?e:t.compiler.compileModuleAsync(e)})).then((function(e){return e.create(t.moduleRef.injector).instance})).then((function(e){return t.handlersLoaded.set(r,e),Promise.resolve()})).then((function(){t.handlersLoading.delete(r),t.handlersToLoad.delete(r)})).catch((function(e){return t.handlersLoading.delete(r),Promise.reject(e)}));return this.handlersLoading.set(r,a),a}return Promise.resolve()},e}();function x(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];var r=function(t){return!!e.find((function(e){return"string"==typeof e?g(t)===e:g(t)===g(e)}))};return function(e){return e.pipe(o.filter(r))}}w.decorators=[{type:n.Injectable}],w.ctorParameters=function(){return[{type:n.NgModuleRef},{type:n.Compiler},{type:Array,decorators:[{type:n.Inject,args:[v]}]}]};var L=function(){function e(){}return e.prototype.logAction=function(e,t){console.log("%c["+e+"]","color: #0077cc",t)},e.prototype.logQuery=function(e,t){console.log("%c["+e+"]","color: #439a00",t)},e}();L.decorators=[{type:n.Injectable}];var S=function(e){function t(t,r,n){var o=e.call(this)||this;return o.loader=t,o.logger=r,o.enableLogging=n,o}return i(t,e),t.prototype.execute=function(e){return c(this,void 0,void 0,(function(){var t,r,n,o;return u(this,(function(a){switch(a.label){case 0:return[4,this.loader.load(e)];case 1:if(a.sent(),!this.loader.hasHandler(e))throw new p('QueryHandler not found for command "'+g(e)+'"');return this.subject$.next(e),t=this.loader.execute(e),this.enableLogging?(r={query:e},this.logger.logQuery(g(e),r),n=r,t instanceof Promise?[4,t]:[3,3]):[3,5];case 2:return o=a.sent(),[3,4];case 3:o=t,a.label=4;case 4:return n.result=o,[2,Promise.resolve(r.result)];case 5:return[2,this.loader.execute(e)]}}))}))},t.prototype.ofType=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return this.subject$.pipe(x.apply(void 0,l(e)),o.share())},t}(y);S.decorators=[{type:n.Injectable}],S.ctorParameters=function(){return[{type:w},{type:L},{type:Boolean,decorators:[{type:n.Inject,args:[j]}]}]};var _=function(e){function t(t,r,n,o){var a=e.call(this)||this;return a.loader=t,a.logger=r,a.sagas=n,a.enableLogging=o,a.registerSagas(n),a}return i(t,e),t.prototype.execute=function(e){return c(this,void 0,void 0,(function(){var t,r,n;return u(this,(function(o){switch(o.label){case 0:return[4,this.loader.load(e)];case 1:if(o.sent(),!this.loader.hasHandler(e))throw new d('ActionHandler not found for command "'+g(e)+'"');return this.subject$.next(e),t=this.loader.execute(e),this.enableLogging?(this.logger.logAction(g(e),e),t instanceof Promise?[4,t]:[3,3]):[3,5];case 2:return n=o.sent(),[3,4];case 3:n=t,o.label=4;case 4:return r=n,[2,Promise.resolve(r)];case 5:return[2,t]}}))}))},t.prototype.ofType=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return this.subject$.pipe(x.apply(void 0,l(e)),o.share())},t.prototype.registerSagas=function(e){var t=this;void 0===e&&(e=[]),e.map((function(e){return(Reflect.getMetadata(f,e.constructor)||[]).map((function(t){return e[t]}))})).reduce((function(e,t){return e.concat(t)}),[]).forEach((function(e){return t.registerSaga(e)}))},t.prototype.registerSaga=function(e){var t=this;if("function"!=typeof e)throw new h;var n=e(this.subject$);if(!(n instanceof r.Observable))throw new h;n.pipe(o.filter((function(e){return!!e}))).subscribe((function(e){Array.isArray(e)?e.forEach((function(e){return t.execute(e)})):t.execute(e)}))},t}(y);_.decorators=[{type:n.Injectable}],_.ctorParameters=function(){return[{type:w},{type:L},{type:Array,decorators:[{type:n.Inject,args:[b]}]},{type:Boolean,decorators:[{type:n.Inject,args:[j]}]}]};var E=function(){function e(){}return e.forRoot=function(t){return{ngModule:e,providers:l([S,_,w,L],(t=t||{sagas:[],registry:[]}).sagas,[{provide:j,useValue:!!t.enableLogging},{provide:v,useValue:t.registry||[]},{provide:b,deps:t.sagas,useFactory:e.createSourceInstances}])}},e.createSourceInstances=function(){for(var e=[],t=0;t<arguments.length;t++)e[t]=arguments[t];return e},e}();E.decorators=[{type:n.NgModule}],e.ActionBus=_,e.ActionHandlerNotFoundException=d,e.CQRS_MODULE_LOGGING=j,e.CQRS_MODULE_REGISTRY=v,e.CQRS_MODULE_SAGAS=b,e.CqrsModule=E,e.InvalidSagaException=h,e.ObservableBus=y,e.QueryBus=S,e.QueryHandlerNotFoundException=p,e.Saga=function(){return function(e,t){var r=Reflect.getMetadata(f,e.constructor)||[];Reflect.defineMetadata(f,l(r,[t]),e.constructor)}},e.getActionTypeFromInstance=g,e.ofType=x,e.ɵa=y,e.ɵb=w,e.ɵd=L,Object.defineProperty(e,"__esModule",{value:!0})})); | ||
//# sourceMappingURL=ng-cqrs.umd.min.js.map |
@@ -31,4 +31,4 @@ import { __awaiter } from "tslib"; | ||
if (this.enableLogging) { | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
const value = result instanceof Promise ? (yield result) : result; | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
return Promise.resolve(value); | ||
@@ -80,2 +80,2 @@ } | ||
]; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiYWN0aW9uLWJ1cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uL3Byb2plY3RzL25nLWNxcnMvc3JjL2xpYi9hY3Rpb24tYnVzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxPQUFPLEVBQUUsTUFBTSxFQUFFLFVBQVUsRUFBUSxNQUFNLGVBQWUsQ0FBQztBQUN6RCxPQUFPLGtCQUFrQixDQUFDO0FBRTFCLE9BQU8sRUFBRSx5QkFBeUIsRUFBRSxhQUFhLEVBQUUsTUFBTSxTQUFTLENBQUM7QUFDbkUsT0FBTyxFQUFFLDhCQUE4QixFQUFFLG9CQUFvQixFQUFFLE1BQU0sY0FBYyxDQUFDO0FBQ3BGLE9BQU8sRUFBRSxVQUFVLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFDbEMsT0FBTyxFQUFFLE1BQU0sRUFBRSxLQUFLLEVBQUUsTUFBTSxnQkFBZ0IsQ0FBQztBQUMvQyxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0scUJBQXFCLENBQUM7QUFDN0MsT0FBTyxFQUFFLFVBQVUsRUFBRSxNQUFNLGVBQWUsQ0FBQztBQUMzQyxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sd0JBQXdCLENBQUM7QUFDdkQsT0FBTyxFQUFFLG1CQUFtQixFQUFFLGlCQUFpQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2xFLE9BQU8sRUFBRSxNQUFNLEVBQUUsTUFBTSxtQkFBbUIsQ0FBQztBQUczQyxNQUFNLE9BQU8sU0FBVSxTQUFRLGFBQXNCO0lBRWpELFlBQ3FCLE1BQWtCLEVBQ2xCLE1BQWMsRUFDSyxLQUFrQixFQUNoQixhQUFzQjtRQUc1RCxLQUFLLEVBQUUsQ0FBQztRQU5TLFdBQU0sR0FBTixNQUFNLENBQVk7UUFDbEIsV0FBTSxHQUFOLE1BQU0sQ0FBUTtRQUNLLFVBQUssR0FBTCxLQUFLLENBQWE7UUFDaEIsa0JBQWEsR0FBYixhQUFhLENBQVM7UUFJNUQsSUFBSSxDQUFDLGFBQWEsQ0FBQyxLQUFLLENBQUMsQ0FBQztJQUM5QixDQUFDO0lBRUssT0FBTyxDQUFtRCxNQUFTOztZQUVyRSxNQUFNLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFDO1lBQy9CLElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxNQUFNLENBQUMsRUFDbkM7Z0JBQ0ksTUFBTSxJQUFJLDhCQUE4QixDQUFDLHdDQUF3Qyx5QkFBeUIsQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLENBQUM7YUFDMUg7WUFDRCxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQztZQUMzQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsQ0FBQztZQUMzQyxJQUFJLElBQUksQ0FBQyxhQUFhLEVBQ3RCO2dCQUNJLE1BQU0sS0FBSyxHQUFHLE1BQU0sWUFBWSxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxNQUFNLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDO2dCQUNsRSxJQUFJLENBQUMsTUFBTSxDQUFDLFNBQVMsQ0FBQyx5QkFBeUIsQ0FBQyxNQUFNLENBQUMsRUFBRSxNQUFNLENBQUMsQ0FBQztnQkFDakUsT0FBTyxPQUFPLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO2FBQ2pDO1lBQ0QsT0FBTyxNQUFNLENBQUM7UUFDbEIsQ0FBQztLQUFBO0lBRUQsTUFBTSxDQUNGLEdBQUcsS0FBK0I7UUFHbEMsT0FBTyxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsR0FBRyxLQUFLLENBQUMsRUFBRSxLQUFLLEVBQUUsQ0FBQyxDQUFDO0lBQ3pELENBQUM7SUFFTyxhQUFhLENBQUMsWUFBeUIsRUFBRTtRQUU3QyxNQUFNLEtBQUssR0FBRyxTQUFTO2FBQ2xCLEdBQUcsQ0FBQyxRQUFRLENBQUMsRUFBRTtZQUVaLE1BQU0sUUFBUSxHQUFHLE9BQU8sQ0FBQyxXQUFXLENBQUMsYUFBYSxFQUFFLFFBQVEsQ0FBQyxXQUFXLENBQUMsSUFBSSxFQUFFLENBQUM7WUFFaEYsT0FBTyxRQUFRLENBQUMsR0FBRyxDQUFDLENBQUMsR0FBVyxFQUFFLEVBQUUsQ0FBQyxRQUFRLENBQUMsR0FBRyxDQUFDLENBQUMsQ0FBQztRQUN4RCxDQUFDLENBQUM7YUFDRCxNQUFNLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFDO1FBRXZDLEtBQUssQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLEVBQUUsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7SUFDbkQsQ0FBQztJQUVTLFlBQVksQ0FBQyxJQUFXO1FBRTlCLElBQUksT0FBTyxJQUFJLEtBQUssVUFBVSxFQUM5QjtZQUNJLE1BQU0sSUFBSSxvQkFBb0IsRUFBRSxDQUFDO1NBQ3BDO1FBQ0QsTUFBTSxPQUFPLEdBQUcsSUFBSSxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQztRQUNwQyxJQUFJLENBQUMsQ0FBQyxPQUFPLFlBQVksVUFBVSxDQUFDLEVBQ3BDO1lBQ0ksTUFBTSxJQUFJLG9CQUFvQixFQUFFLENBQUM7U0FDcEM7UUFFRCxPQUFPO2FBQ0YsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFDLENBQUMsRUFBRSxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQzthQUN0QixTQUFTLENBQUMsQ0FBQyxNQUF5QixFQUFFLEVBQUU7WUFFckMsSUFBSSxLQUFLLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxFQUN6QjtnQkFDSSxNQUFNLENBQUMsT0FBTyxDQUFDLENBQUMsQ0FBQyxFQUFFLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDO2FBQ3hDO2lCQUVEO2dCQUNJLElBQUksQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7YUFDeEI7UUFDTCxDQUFDLENBQUMsQ0FBQztJQUNYLENBQUM7OztZQTlFSixVQUFVOzs7WUFMRixVQUFVO1lBR1YsTUFBTTt3Q0FRTixNQUFNLFNBQUMsaUJBQWlCOzBDQUN4QixNQUFNLFNBQUMsbUJBQW1CIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSW5qZWN0LCBJbmplY3RhYmxlLCBUeXBlIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgJ3JlZmxlY3QtbWV0YWRhdGEnO1xuaW1wb3J0IHsgSUFjdGlvbiwgSUFjdGlvbkJ1cywgSUFjdGlvblJlc3VsdCwgSVNhZ2EgfSBmcm9tICcuL2ludGVyZmFjZXMnO1xuaW1wb3J0IHsgZ2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZSwgT2JzZXJ2YWJsZUJ1cyB9IGZyb20gJy4vdXRpbHMnO1xuaW1wb3J0IHsgQWN0aW9uSGFuZGxlck5vdEZvdW5kRXhjZXB0aW9uLCBJbnZhbGlkU2FnYUV4Y2VwdGlvbiB9IGZyb20gJy4vZXhjZXB0aW9ucyc7XG5pbXBvcnQgeyBPYnNlcnZhYmxlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBmaWx0ZXIsIHNoYXJlIH0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuaW1wb3J0IHsgb2ZUeXBlIH0gZnJvbSAnLi9vcGVyYXRvcnMvb2YtdHlwZSc7XG5pbXBvcnQgeyBDcXJzTG9hZGVyIH0gZnJvbSAnLi9jcXJzLWxvYWRlcic7XG5pbXBvcnQgeyBTQUdBX01FVEFEQVRBIH0gZnJvbSAnLi9kZWNvcmF0b3JzL2NvbnN0YW50cyc7XG5pbXBvcnQgeyBDUVJTX01PRFVMRV9MT0dHSU5HLCBDUVJTX01PRFVMRV9TQUdBUyB9IGZyb20gJy4vdG9rZW5zJztcbmltcG9ydCB7IExvZ2dlciB9IGZyb20gJy4vc2VydmljZXMvbG9nZ2VyJztcblxuQEluamVjdGFibGUoKVxuZXhwb3J0IGNsYXNzIEFjdGlvbkJ1cyBleHRlbmRzIE9ic2VydmFibGVCdXM8SUFjdGlvbj4gaW1wbGVtZW50cyBJQWN0aW9uQnVzXG57XG4gICAgY29uc3RydWN0b3IoXG4gICAgICAgIHByaXZhdGUgcmVhZG9ubHkgbG9hZGVyOiBDcXJzTG9hZGVyLFxuICAgICAgICBwcml2YXRlIHJlYWRvbmx5IGxvZ2dlcjogTG9nZ2VyLFxuICAgICAgICBASW5qZWN0KENRUlNfTU9EVUxFX1NBR0FTKSByZWFkb25seSBzYWdhczogVHlwZTxhbnk+W10sXG4gICAgICAgIEBJbmplY3QoQ1FSU19NT0RVTEVfTE9HR0lORykgcmVhZG9ubHkgZW5hYmxlTG9nZ2luZzogYm9vbGVhblxuICAgIClcbiAgICB7XG4gICAgICAgIHN1cGVyKCk7XG4gICAgICAgIHRoaXMucmVnaXN0ZXJTYWdhcyhzYWdhcyk7XG4gICAgfVxuXG4gICAgYXN5bmMgZXhlY3V0ZTxUIGV4dGVuZHMgSUFjdGlvbiwgVFJlc3VsdCBleHRlbmRzIElBY3Rpb25SZXN1bHQ+KGFjdGlvbjogVCk6IFByb21pc2U8VFJlc3VsdD5cbiAgICB7XG4gICAgICAgIGF3YWl0IHRoaXMubG9hZGVyLmxvYWQoYWN0aW9uKTtcbiAgICAgICAgaWYgKCF0aGlzLmxvYWRlci5oYXNIYW5kbGVyKGFjdGlvbikpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBBY3Rpb25IYW5kbGVyTm90Rm91bmRFeGNlcHRpb24oYEFjdGlvbkhhbmRsZXIgbm90IGZvdW5kIGZvciBjb21tYW5kIFwiJHtnZXRBY3Rpb25UeXBlRnJvbUluc3RhbmNlKGFjdGlvbil9XCJgKTtcbiAgICAgICAgfVxuICAgICAgICB0aGlzLnN1YmplY3QkLm5leHQoYWN0aW9uKTtcbiAgICAgICAgY29uc3QgcmVzdWx0ID0gdGhpcy5sb2FkZXIuZXhlY3V0ZShhY3Rpb24pO1xuICAgICAgICBpZiAodGhpcy5lbmFibGVMb2dnaW5nKVxuICAgICAgICB7XG4gICAgICAgICAgICBjb25zdCB2YWx1ZSA9IHJlc3VsdCBpbnN0YW5jZW9mIFByb21pc2UgPyAoYXdhaXQgcmVzdWx0KSA6IHJlc3VsdDtcbiAgICAgICAgICAgIHRoaXMubG9nZ2VyLmxvZ0FjdGlvbihnZXRBY3Rpb25UeXBlRnJvbUluc3RhbmNlKGFjdGlvbiksIGFjdGlvbik7XG4gICAgICAgICAgICByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKHZhbHVlKTtcbiAgICAgICAgfVxuICAgICAgICByZXR1cm4gcmVzdWx0O1xuICAgIH1cblxuICAgIG9mVHlwZTxUSW5wdXQgZXh0ZW5kcyBJQWN0aW9uLCBUT3V0cHV0IGV4dGVuZHMgSUFjdGlvbj4oXG4gICAgICAgIC4uLnR5cGVzOiAoVHlwZTxJQWN0aW9uPnxzdHJpbmcpW11cbiAgICApOiBPYnNlcnZhYmxlPElBY3Rpb24+XG4gICAge1xuICAgICAgICByZXR1cm4gdGhpcy5zdWJqZWN0JC5waXBlKG9mVHlwZSguLi50eXBlcyksIHNoYXJlKCkpO1xuICAgIH1cblxuICAgIHByaXZhdGUgcmVnaXN0ZXJTYWdhcyhpbnN0YW5jZXM6IFR5cGU8YW55PltdID0gW10pOiB2b2lkXG4gICAge1xuICAgICAgICBjb25zdCBzYWdhcyA9IGluc3RhbmNlc1xuICAgICAgICAgICAgLm1hcChpbnN0YW5jZSA9PlxuICAgICAgICAgICAge1xuICAgICAgICAgICAgICAgIGNvbnN0IG1ldGFkYXRhID0gUmVmbGVjdC5nZXRNZXRhZGF0YShTQUdBX01FVEFEQVRBLCBpbnN0YW5jZS5jb25zdHJ1Y3RvcikgfHwgW107XG5cbiAgICAgICAgICAgICAgICByZXR1cm4gbWV0YWRhdGEubWFwKChrZXk6IHN0cmluZykgPT4gaW5zdGFuY2Vba2V5XSk7XG4gICAgICAgICAgICB9KVxuICAgICAgICAgICAgLnJlZHVjZSgoYSwgYikgPT4gYS5jb25jYXQoYiksIFtdKTtcblxuICAgICAgICBzYWdhcy5mb3JFYWNoKHNhZ2EgPT4gdGhpcy5yZWdpc3RlclNhZ2Eoc2FnYSkpO1xuICAgIH1cblxuICAgIHByb3RlY3RlZCByZWdpc3RlclNhZ2Eoc2FnYTogSVNhZ2EpOiB2b2lkXG4gICAge1xuICAgICAgICBpZiAodHlwZW9mIHNhZ2EgIT09ICdmdW5jdGlvbicpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBJbnZhbGlkU2FnYUV4Y2VwdGlvbigpO1xuICAgICAgICB9XG4gICAgICAgIGNvbnN0IHN0cmVhbSQgPSBzYWdhKHRoaXMuc3ViamVjdCQpO1xuICAgICAgICBpZiAoIShzdHJlYW0kIGluc3RhbmNlb2YgT2JzZXJ2YWJsZSkpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBJbnZhbGlkU2FnYUV4Y2VwdGlvbigpO1xuICAgICAgICB9XG5cbiAgICAgICAgc3RyZWFtJFxuICAgICAgICAgICAgLnBpcGUoZmlsdGVyKGUgPT4gISFlKSlcbiAgICAgICAgICAgIC5zdWJzY3JpYmUoKGFjdGlvbjogSUFjdGlvbnxJQWN0aW9uW10pID0+XG4gICAgICAgICAgICB7XG4gICAgICAgICAgICAgICAgaWYgKEFycmF5LmlzQXJyYXkoYWN0aW9uKSlcbiAgICAgICAgICAgICAgICB7XG4gICAgICAgICAgICAgICAgICAgIGFjdGlvbi5mb3JFYWNoKGMgPT4gdGhpcy5leGVjdXRlKGMpKTtcbiAgICAgICAgICAgICAgICB9XG4gICAgICAgICAgICAgICAgZWxzZVxuICAgICAgICAgICAgICAgIHtcbiAgICAgICAgICAgICAgICAgICAgdGhpcy5leGVjdXRlKGFjdGlvbik7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgfSk7XG4gICAgfVxufVxuXG4iXX0= | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiYWN0aW9uLWJ1cy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uLy4uL3Byb2plY3RzL25nLWNxcnMvc3JjL2xpYi9hY3Rpb24tYnVzLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxPQUFPLEVBQUUsTUFBTSxFQUFFLFVBQVUsRUFBUSxNQUFNLGVBQWUsQ0FBQztBQUN6RCxPQUFPLGtCQUFrQixDQUFDO0FBRTFCLE9BQU8sRUFBRSx5QkFBeUIsRUFBRSxhQUFhLEVBQUUsTUFBTSxTQUFTLENBQUM7QUFDbkUsT0FBTyxFQUFFLDhCQUE4QixFQUFFLG9CQUFvQixFQUFFLE1BQU0sY0FBYyxDQUFDO0FBQ3BGLE9BQU8sRUFBRSxVQUFVLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFDbEMsT0FBTyxFQUFFLE1BQU0sRUFBRSxLQUFLLEVBQUUsTUFBTSxnQkFBZ0IsQ0FBQztBQUMvQyxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0scUJBQXFCLENBQUM7QUFDN0MsT0FBTyxFQUFFLFVBQVUsRUFBRSxNQUFNLGVBQWUsQ0FBQztBQUMzQyxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sd0JBQXdCLENBQUM7QUFDdkQsT0FBTyxFQUFFLG1CQUFtQixFQUFFLGlCQUFpQixFQUFFLE1BQU0sVUFBVSxDQUFDO0FBQ2xFLE9BQU8sRUFBRSxNQUFNLEVBQUUsTUFBTSxtQkFBbUIsQ0FBQztBQUczQyxNQUFNLE9BQU8sU0FBVSxTQUFRLGFBQXNCO0lBRWpELFlBQ3FCLE1BQWtCLEVBQ2xCLE1BQWMsRUFDSyxLQUFrQixFQUNoQixhQUFzQjtRQUc1RCxLQUFLLEVBQUUsQ0FBQztRQU5TLFdBQU0sR0FBTixNQUFNLENBQVk7UUFDbEIsV0FBTSxHQUFOLE1BQU0sQ0FBUTtRQUNLLFVBQUssR0FBTCxLQUFLLENBQWE7UUFDaEIsa0JBQWEsR0FBYixhQUFhLENBQVM7UUFJNUQsSUFBSSxDQUFDLGFBQWEsQ0FBQyxLQUFLLENBQUMsQ0FBQztJQUM5QixDQUFDO0lBRUssT0FBTyxDQUFtRCxNQUFTOztZQUVyRSxNQUFNLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFDO1lBQy9CLElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxNQUFNLENBQUMsRUFDbkM7Z0JBQ0ksTUFBTSxJQUFJLDhCQUE4QixDQUFDLHdDQUF3Qyx5QkFBeUIsQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLENBQUM7YUFDMUg7WUFDRCxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQztZQUMzQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsQ0FBQztZQUMzQyxJQUFJLElBQUksQ0FBQyxhQUFhLEVBQ3RCO2dCQUNJLElBQUksQ0FBQyxNQUFNLENBQUMsU0FBUyxDQUFDLHlCQUF5QixDQUFDLE1BQU0sQ0FBQyxFQUFFLE1BQU0sQ0FBQyxDQUFDO2dCQUNqRSxNQUFNLEtBQUssR0FBRyxNQUFNLFlBQVksT0FBTyxDQUFDLENBQUMsQ0FBQyxDQUFDLE1BQU0sTUFBTSxDQUFDLENBQUMsQ0FBQyxDQUFDLE1BQU0sQ0FBQztnQkFDbEUsT0FBTyxPQUFPLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO2FBQ2pDO1lBQ0QsT0FBTyxNQUFNLENBQUM7UUFDbEIsQ0FBQztLQUFBO0lBRUQsTUFBTSxDQUNGLEdBQUcsS0FBK0I7UUFHbEMsT0FBTyxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsR0FBRyxLQUFLLENBQUMsRUFBRSxLQUFLLEVBQUUsQ0FBQyxDQUFDO0lBQ3pELENBQUM7SUFFTyxhQUFhLENBQUMsWUFBeUIsRUFBRTtRQUU3QyxNQUFNLEtBQUssR0FBRyxTQUFTO2FBQ2xCLEdBQUcsQ0FBQyxRQUFRLENBQUMsRUFBRTtZQUVaLE1BQU0sUUFBUSxHQUFHLE9BQU8sQ0FBQyxXQUFXLENBQUMsYUFBYSxFQUFFLFFBQVEsQ0FBQyxXQUFXLENBQUMsSUFBSSxFQUFFLENBQUM7WUFFaEYsT0FBTyxRQUFRLENBQUMsR0FBRyxDQUFDLENBQUMsR0FBVyxFQUFFLEVBQUUsQ0FBQyxRQUFRLENBQUMsR0FBRyxDQUFDLENBQUMsQ0FBQztRQUN4RCxDQUFDLENBQUM7YUFDRCxNQUFNLENBQUMsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFDO1FBRXZDLEtBQUssQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLEVBQUUsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7SUFDbkQsQ0FBQztJQUVTLFlBQVksQ0FBQyxJQUFXO1FBRTlCLElBQUksT0FBTyxJQUFJLEtBQUssVUFBVSxFQUM5QjtZQUNJLE1BQU0sSUFBSSxvQkFBb0IsRUFBRSxDQUFDO1NBQ3BDO1FBQ0QsTUFBTSxPQUFPLEdBQUcsSUFBSSxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQztRQUNwQyxJQUFJLENBQUMsQ0FBQyxPQUFPLFlBQVksVUFBVSxDQUFDLEVBQ3BDO1lBQ0ksTUFBTSxJQUFJLG9CQUFvQixFQUFFLENBQUM7U0FDcEM7UUFFRCxPQUFPO2FBQ0YsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFDLENBQUMsRUFBRSxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQzthQUN0QixTQUFTLENBQUMsQ0FBQyxNQUF5QixFQUFFLEVBQUU7WUFFckMsSUFBSSxLQUFLLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxFQUN6QjtnQkFDSSxNQUFNLENBQUMsT0FBTyxDQUFDLENBQUMsQ0FBQyxFQUFFLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDO2FBQ3hDO2lCQUVEO2dCQUNJLElBQUksQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7YUFDeEI7UUFDTCxDQUFDLENBQUMsQ0FBQztJQUNYLENBQUM7OztZQTlFSixVQUFVOzs7WUFMRixVQUFVO1lBR1YsTUFBTTt3Q0FRTixNQUFNLFNBQUMsaUJBQWlCOzBDQUN4QixNQUFNLFNBQUMsbUJBQW1CIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSW5qZWN0LCBJbmplY3RhYmxlLCBUeXBlIH0gZnJvbSAnQGFuZ3VsYXIvY29yZSc7XG5pbXBvcnQgJ3JlZmxlY3QtbWV0YWRhdGEnO1xuaW1wb3J0IHsgSUFjdGlvbiwgSUFjdGlvbkJ1cywgSUFjdGlvblJlc3VsdCwgSVNhZ2EgfSBmcm9tICcuL2ludGVyZmFjZXMnO1xuaW1wb3J0IHsgZ2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZSwgT2JzZXJ2YWJsZUJ1cyB9IGZyb20gJy4vdXRpbHMnO1xuaW1wb3J0IHsgQWN0aW9uSGFuZGxlck5vdEZvdW5kRXhjZXB0aW9uLCBJbnZhbGlkU2FnYUV4Y2VwdGlvbiB9IGZyb20gJy4vZXhjZXB0aW9ucyc7XG5pbXBvcnQgeyBPYnNlcnZhYmxlIH0gZnJvbSAncnhqcyc7XG5pbXBvcnQgeyBmaWx0ZXIsIHNoYXJlIH0gZnJvbSAncnhqcy9vcGVyYXRvcnMnO1xuaW1wb3J0IHsgb2ZUeXBlIH0gZnJvbSAnLi9vcGVyYXRvcnMvb2YtdHlwZSc7XG5pbXBvcnQgeyBDcXJzTG9hZGVyIH0gZnJvbSAnLi9jcXJzLWxvYWRlcic7XG5pbXBvcnQgeyBTQUdBX01FVEFEQVRBIH0gZnJvbSAnLi9kZWNvcmF0b3JzL2NvbnN0YW50cyc7XG5pbXBvcnQgeyBDUVJTX01PRFVMRV9MT0dHSU5HLCBDUVJTX01PRFVMRV9TQUdBUyB9IGZyb20gJy4vdG9rZW5zJztcbmltcG9ydCB7IExvZ2dlciB9IGZyb20gJy4vc2VydmljZXMvbG9nZ2VyJztcblxuQEluamVjdGFibGUoKVxuZXhwb3J0IGNsYXNzIEFjdGlvbkJ1cyBleHRlbmRzIE9ic2VydmFibGVCdXM8SUFjdGlvbj4gaW1wbGVtZW50cyBJQWN0aW9uQnVzXG57XG4gICAgY29uc3RydWN0b3IoXG4gICAgICAgIHByaXZhdGUgcmVhZG9ubHkgbG9hZGVyOiBDcXJzTG9hZGVyLFxuICAgICAgICBwcml2YXRlIHJlYWRvbmx5IGxvZ2dlcjogTG9nZ2VyLFxuICAgICAgICBASW5qZWN0KENRUlNfTU9EVUxFX1NBR0FTKSByZWFkb25seSBzYWdhczogVHlwZTxhbnk+W10sXG4gICAgICAgIEBJbmplY3QoQ1FSU19NT0RVTEVfTE9HR0lORykgcmVhZG9ubHkgZW5hYmxlTG9nZ2luZzogYm9vbGVhblxuICAgIClcbiAgICB7XG4gICAgICAgIHN1cGVyKCk7XG4gICAgICAgIHRoaXMucmVnaXN0ZXJTYWdhcyhzYWdhcyk7XG4gICAgfVxuXG4gICAgYXN5bmMgZXhlY3V0ZTxUIGV4dGVuZHMgSUFjdGlvbiwgVFJlc3VsdCBleHRlbmRzIElBY3Rpb25SZXN1bHQ+KGFjdGlvbjogVCk6IFByb21pc2U8VFJlc3VsdD5cbiAgICB7XG4gICAgICAgIGF3YWl0IHRoaXMubG9hZGVyLmxvYWQoYWN0aW9uKTtcbiAgICAgICAgaWYgKCF0aGlzLmxvYWRlci5oYXNIYW5kbGVyKGFjdGlvbikpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBBY3Rpb25IYW5kbGVyTm90Rm91bmRFeGNlcHRpb24oYEFjdGlvbkhhbmRsZXIgbm90IGZvdW5kIGZvciBjb21tYW5kIFwiJHtnZXRBY3Rpb25UeXBlRnJvbUluc3RhbmNlKGFjdGlvbil9XCJgKTtcbiAgICAgICAgfVxuICAgICAgICB0aGlzLnN1YmplY3QkLm5leHQoYWN0aW9uKTtcbiAgICAgICAgY29uc3QgcmVzdWx0ID0gdGhpcy5sb2FkZXIuZXhlY3V0ZShhY3Rpb24pO1xuICAgICAgICBpZiAodGhpcy5lbmFibGVMb2dnaW5nKVxuICAgICAgICB7XG4gICAgICAgICAgICB0aGlzLmxvZ2dlci5sb2dBY3Rpb24oZ2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZShhY3Rpb24pLCBhY3Rpb24pO1xuICAgICAgICAgICAgY29uc3QgdmFsdWUgPSByZXN1bHQgaW5zdGFuY2VvZiBQcm9taXNlID8gKGF3YWl0IHJlc3VsdCkgOiByZXN1bHQ7XG4gICAgICAgICAgICByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKHZhbHVlKTtcbiAgICAgICAgfVxuICAgICAgICByZXR1cm4gcmVzdWx0O1xuICAgIH1cblxuICAgIG9mVHlwZTxUSW5wdXQgZXh0ZW5kcyBJQWN0aW9uLCBUT3V0cHV0IGV4dGVuZHMgSUFjdGlvbj4oXG4gICAgICAgIC4uLnR5cGVzOiAoVHlwZTxJQWN0aW9uPnxzdHJpbmcpW11cbiAgICApOiBPYnNlcnZhYmxlPElBY3Rpb24+XG4gICAge1xuICAgICAgICByZXR1cm4gdGhpcy5zdWJqZWN0JC5waXBlKG9mVHlwZSguLi50eXBlcyksIHNoYXJlKCkpO1xuICAgIH1cblxuICAgIHByaXZhdGUgcmVnaXN0ZXJTYWdhcyhpbnN0YW5jZXM6IFR5cGU8YW55PltdID0gW10pOiB2b2lkXG4gICAge1xuICAgICAgICBjb25zdCBzYWdhcyA9IGluc3RhbmNlc1xuICAgICAgICAgICAgLm1hcChpbnN0YW5jZSA9PlxuICAgICAgICAgICAge1xuICAgICAgICAgICAgICAgIGNvbnN0IG1ldGFkYXRhID0gUmVmbGVjdC5nZXRNZXRhZGF0YShTQUdBX01FVEFEQVRBLCBpbnN0YW5jZS5jb25zdHJ1Y3RvcikgfHwgW107XG5cbiAgICAgICAgICAgICAgICByZXR1cm4gbWV0YWRhdGEubWFwKChrZXk6IHN0cmluZykgPT4gaW5zdGFuY2Vba2V5XSk7XG4gICAgICAgICAgICB9KVxuICAgICAgICAgICAgLnJlZHVjZSgoYSwgYikgPT4gYS5jb25jYXQoYiksIFtdKTtcblxuICAgICAgICBzYWdhcy5mb3JFYWNoKHNhZ2EgPT4gdGhpcy5yZWdpc3RlclNhZ2Eoc2FnYSkpO1xuICAgIH1cblxuICAgIHByb3RlY3RlZCByZWdpc3RlclNhZ2Eoc2FnYTogSVNhZ2EpOiB2b2lkXG4gICAge1xuICAgICAgICBpZiAodHlwZW9mIHNhZ2EgIT09ICdmdW5jdGlvbicpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBJbnZhbGlkU2FnYUV4Y2VwdGlvbigpO1xuICAgICAgICB9XG4gICAgICAgIGNvbnN0IHN0cmVhbSQgPSBzYWdhKHRoaXMuc3ViamVjdCQpO1xuICAgICAgICBpZiAoIShzdHJlYW0kIGluc3RhbmNlb2YgT2JzZXJ2YWJsZSkpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBJbnZhbGlkU2FnYUV4Y2VwdGlvbigpO1xuICAgICAgICB9XG5cbiAgICAgICAgc3RyZWFtJFxuICAgICAgICAgICAgLnBpcGUoZmlsdGVyKGUgPT4gISFlKSlcbiAgICAgICAgICAgIC5zdWJzY3JpYmUoKGFjdGlvbjogSUFjdGlvbnxJQWN0aW9uW10pID0+XG4gICAgICAgICAgICB7XG4gICAgICAgICAgICAgICAgaWYgKEFycmF5LmlzQXJyYXkoYWN0aW9uKSlcbiAgICAgICAgICAgICAgICB7XG4gICAgICAgICAgICAgICAgICAgIGFjdGlvbi5mb3JFYWNoKGMgPT4gdGhpcy5leGVjdXRlKGMpKTtcbiAgICAgICAgICAgICAgICB9XG4gICAgICAgICAgICAgICAgZWxzZVxuICAgICAgICAgICAgICAgIHtcbiAgICAgICAgICAgICAgICAgICAgdGhpcy5leGVjdXRlKGFjdGlvbik7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgfSk7XG4gICAgfVxufVxuXG4iXX0= |
@@ -26,5 +26,6 @@ import { __awaiter } from "tslib"; | ||
if (this.enableLogging) { | ||
const value = result instanceof Promise ? (yield result) : result; | ||
this.logger.logQuery(getActionTypeFromInstance(query), { query, result: value }); | ||
return Promise.resolve(value); | ||
const payload = { query }; | ||
this.logger.logQuery(getActionTypeFromInstance(query), payload); | ||
payload.result = result instanceof Promise ? (yield result) : result; | ||
return Promise.resolve(payload.result); | ||
} | ||
@@ -46,2 +47,2 @@ return this.loader.execute(query); | ||
]; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicXVlcnktYnVzLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vcHJvamVjdHMvbmctY3Fycy9zcmMvbGliL3F1ZXJ5LWJ1cy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsT0FBTyxFQUFFLE1BQU0sRUFBRSxVQUFVLEVBQVEsTUFBTSxlQUFlLENBQUM7QUFDekQsT0FBTyxFQUFFLHlCQUF5QixFQUFFLGFBQWEsRUFBRSxNQUFNLFNBQVMsQ0FBQztBQUVuRSxPQUFPLEVBQUUsVUFBVSxFQUFFLE1BQU0sZUFBZSxDQUFDO0FBQzNDLE9BQU8sRUFBRSw2QkFBNkIsRUFBRSxNQUFNLGNBQWMsQ0FBQztBQUU3RCxPQUFPLEVBQUUsS0FBSyxFQUFFLE1BQU0sZ0JBQWdCLENBQUM7QUFDdkMsT0FBTyxFQUFFLE1BQU0sRUFBRSxNQUFNLHFCQUFxQixDQUFDO0FBQzdDLE9BQU8sRUFBRSxtQkFBbUIsRUFBRSxNQUFNLFVBQVUsQ0FBQztBQUMvQyxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sbUJBQW1CLENBQUM7QUFHM0MsTUFBTSxPQUFPLFFBQVMsU0FBUSxhQUFxQjtJQUUvQyxZQUNxQixNQUFrQixFQUNsQixNQUFjLEVBQ08sYUFBc0I7UUFHNUQsS0FBSyxFQUFFLENBQUM7UUFMUyxXQUFNLEdBQU4sTUFBTSxDQUFZO1FBQ2xCLFdBQU0sR0FBTixNQUFNLENBQVE7UUFDTyxrQkFBYSxHQUFiLGFBQWEsQ0FBUztJQUloRSxDQUFDO0lBRUssT0FBTyxDQUFpRCxLQUFROztZQUVsRSxNQUFNLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxDQUFDO1lBQzlCLElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxLQUFLLENBQUMsRUFDbEM7Z0JBQ0ksTUFBTSxJQUFJLDZCQUE2QixDQUFDLHVDQUF1Qyx5QkFBeUIsQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLENBQUM7YUFDdkg7WUFDRCxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUMxQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUMxQyxJQUFJLElBQUksQ0FBQyxhQUFhLEVBQ3RCO2dCQUNJLE1BQU0sS0FBSyxHQUFHLE1BQU0sWUFBWSxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxNQUFNLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDO2dCQUNsRSxJQUFJLENBQUMsTUFBTSxDQUFDLFFBQVEsQ0FBQyx5QkFBeUIsQ0FBQyxLQUFLLENBQUMsRUFBRSxFQUFFLEtBQUssRUFBRSxNQUFNLEVBQUUsS0FBSyxFQUFFLENBQUMsQ0FBQztnQkFDakYsT0FBTyxPQUFPLENBQUMsT0FBTyxDQUFDLEtBQUssQ0FBQyxDQUFDO2FBQ2pDO1lBQ0QsT0FBTyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUN0QyxDQUFDO0tBQUE7SUFFRCxNQUFNLENBQ0YsR0FBRyxLQUE4QjtRQUdqQyxPQUFPLElBQUksQ0FBQyxRQUFRLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxHQUFHLEtBQUssQ0FBQyxFQUFFLEtBQUssRUFBRSxDQUFDLENBQUM7SUFDekQsQ0FBQzs7O1lBbkNKLFVBQVU7OztZQVJGLFVBQVU7WUFNVixNQUFNOzBDQVFOLE1BQU0sU0FBQyxtQkFBbUIiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBJbmplY3QsIEluamVjdGFibGUsIFR5cGUgfSBmcm9tICdAYW5ndWxhci9jb3JlJztcbmltcG9ydCB7IGdldEFjdGlvblR5cGVGcm9tSW5zdGFuY2UsIE9ic2VydmFibGVCdXMgfSBmcm9tICcuL3V0aWxzJztcbmltcG9ydCB7IElRdWVyeSwgSVF1ZXJ5QnVzLCBJUXVlcnlSZXN1bHQgfSBmcm9tICcuL2ludGVyZmFjZXMnO1xuaW1wb3J0IHsgQ3Fyc0xvYWRlciB9IGZyb20gJy4vY3Fycy1sb2FkZXInO1xuaW1wb3J0IHsgUXVlcnlIYW5kbGVyTm90Rm91bmRFeGNlcHRpb24gfSBmcm9tICcuL2V4Y2VwdGlvbnMnO1xuaW1wb3J0IHsgT2JzZXJ2YWJsZSB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgc2hhcmUgfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5pbXBvcnQgeyBvZlR5cGUgfSBmcm9tICcuL29wZXJhdG9ycy9vZi10eXBlJztcbmltcG9ydCB7IENRUlNfTU9EVUxFX0xPR0dJTkcgfSBmcm9tICcuL3Rva2Vucyc7XG5pbXBvcnQgeyBMb2dnZXIgfSBmcm9tICcuL3NlcnZpY2VzL2xvZ2dlcic7XG5cbkBJbmplY3RhYmxlKClcbmV4cG9ydCBjbGFzcyBRdWVyeUJ1cyBleHRlbmRzIE9ic2VydmFibGVCdXM8SVF1ZXJ5PiBpbXBsZW1lbnRzIElRdWVyeUJ1c1xue1xuICAgIGNvbnN0cnVjdG9yKFxuICAgICAgICBwcml2YXRlIHJlYWRvbmx5IGxvYWRlcjogQ3Fyc0xvYWRlcixcbiAgICAgICAgcHJpdmF0ZSByZWFkb25seSBsb2dnZXI6IExvZ2dlcixcbiAgICAgICAgQEluamVjdChDUVJTX01PRFVMRV9MT0dHSU5HKSByZWFkb25seSBlbmFibGVMb2dnaW5nOiBib29sZWFuXG4gICAgKVxuICAgIHtcbiAgICAgICAgc3VwZXIoKTtcbiAgICB9XG5cbiAgICBhc3luYyBleGVjdXRlPFQgZXh0ZW5kcyBJUXVlcnksIFRSZXN1bHQgZXh0ZW5kcyBJUXVlcnlSZXN1bHQ+KHF1ZXJ5OiBUKTogUHJvbWlzZTxUUmVzdWx0PlxuICAgIHtcbiAgICAgICAgYXdhaXQgdGhpcy5sb2FkZXIubG9hZChxdWVyeSk7XG4gICAgICAgIGlmICghdGhpcy5sb2FkZXIuaGFzSGFuZGxlcihxdWVyeSkpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBRdWVyeUhhbmRsZXJOb3RGb3VuZEV4Y2VwdGlvbihgUXVlcnlIYW5kbGVyIG5vdCBmb3VuZCBmb3IgY29tbWFuZCBcIiR7Z2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZShxdWVyeSl9XCJgKTtcbiAgICAgICAgfVxuICAgICAgICB0aGlzLnN1YmplY3QkLm5leHQocXVlcnkpO1xuICAgICAgICBjb25zdCByZXN1bHQgPSB0aGlzLmxvYWRlci5leGVjdXRlKHF1ZXJ5KTtcbiAgICAgICAgaWYgKHRoaXMuZW5hYmxlTG9nZ2luZylcbiAgICAgICAge1xuICAgICAgICAgICAgY29uc3QgdmFsdWUgPSByZXN1bHQgaW5zdGFuY2VvZiBQcm9taXNlID8gKGF3YWl0IHJlc3VsdCkgOiByZXN1bHQ7XG4gICAgICAgICAgICB0aGlzLmxvZ2dlci5sb2dRdWVyeShnZXRBY3Rpb25UeXBlRnJvbUluc3RhbmNlKHF1ZXJ5KSwgeyBxdWVyeSwgcmVzdWx0OiB2YWx1ZSB9KTtcbiAgICAgICAgICAgIHJldHVybiBQcm9taXNlLnJlc29sdmUodmFsdWUpO1xuICAgICAgICB9XG4gICAgICAgIHJldHVybiB0aGlzLmxvYWRlci5leGVjdXRlKHF1ZXJ5KTtcbiAgICB9XG5cbiAgICBvZlR5cGU8VElucHV0IGV4dGVuZHMgSVF1ZXJ5LCBUT3V0cHV0IGV4dGVuZHMgSVF1ZXJ5PihcbiAgICAgICAgLi4udHlwZXM6IChUeXBlPElRdWVyeT58c3RyaW5nKVtdXG4gICAgKTogT2JzZXJ2YWJsZTxJUXVlcnk+XG4gICAge1xuICAgICAgICByZXR1cm4gdGhpcy5zdWJqZWN0JC5waXBlKG9mVHlwZSguLi50eXBlcyksIHNoYXJlKCkpO1xuICAgIH1cbn1cbiJdfQ== | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicXVlcnktYnVzLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vLi4vcHJvamVjdHMvbmctY3Fycy9zcmMvbGliL3F1ZXJ5LWJ1cy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsT0FBTyxFQUFFLE1BQU0sRUFBRSxVQUFVLEVBQVEsTUFBTSxlQUFlLENBQUM7QUFDekQsT0FBTyxFQUFFLHlCQUF5QixFQUFFLGFBQWEsRUFBRSxNQUFNLFNBQVMsQ0FBQztBQUVuRSxPQUFPLEVBQUUsVUFBVSxFQUFFLE1BQU0sZUFBZSxDQUFDO0FBQzNDLE9BQU8sRUFBRSw2QkFBNkIsRUFBRSxNQUFNLGNBQWMsQ0FBQztBQUU3RCxPQUFPLEVBQUUsS0FBSyxFQUFFLE1BQU0sZ0JBQWdCLENBQUM7QUFDdkMsT0FBTyxFQUFFLE1BQU0sRUFBRSxNQUFNLHFCQUFxQixDQUFDO0FBQzdDLE9BQU8sRUFBRSxtQkFBbUIsRUFBRSxNQUFNLFVBQVUsQ0FBQztBQUMvQyxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sbUJBQW1CLENBQUM7QUFHM0MsTUFBTSxPQUFPLFFBQVMsU0FBUSxhQUFxQjtJQUUvQyxZQUNxQixNQUFrQixFQUNsQixNQUFjLEVBQ08sYUFBc0I7UUFHNUQsS0FBSyxFQUFFLENBQUM7UUFMUyxXQUFNLEdBQU4sTUFBTSxDQUFZO1FBQ2xCLFdBQU0sR0FBTixNQUFNLENBQVE7UUFDTyxrQkFBYSxHQUFiLGFBQWEsQ0FBUztJQUloRSxDQUFDO0lBRUssT0FBTyxDQUFpRCxLQUFROztZQUVsRSxNQUFNLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxDQUFDO1lBQzlCLElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxLQUFLLENBQUMsRUFDbEM7Z0JBQ0ksTUFBTSxJQUFJLDZCQUE2QixDQUFDLHVDQUF1Qyx5QkFBeUIsQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLENBQUM7YUFDdkg7WUFDRCxJQUFJLENBQUMsUUFBUSxDQUFDLElBQUksQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUMxQixNQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUMxQyxJQUFJLElBQUksQ0FBQyxhQUFhLEVBQ3RCO2dCQUNJLE1BQU0sT0FBTyxHQUFRLEVBQUUsS0FBSyxFQUFFLENBQUM7Z0JBQy9CLElBQUksQ0FBQyxNQUFNLENBQUMsUUFBUSxDQUFDLHlCQUF5QixDQUFDLEtBQUssQ0FBQyxFQUFFLE9BQU8sQ0FBQyxDQUFDO2dCQUNoRSxPQUFPLENBQUMsTUFBTSxHQUFHLE1BQU0sWUFBWSxPQUFPLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxNQUFNLENBQUMsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDO2dCQUNyRSxPQUFPLE9BQU8sQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFDO2FBQzFDO1lBQ0QsT0FBTyxJQUFJLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztRQUN0QyxDQUFDO0tBQUE7SUFFRCxNQUFNLENBQ0YsR0FBRyxLQUE4QjtRQUdqQyxPQUFPLElBQUksQ0FBQyxRQUFRLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxHQUFHLEtBQUssQ0FBQyxFQUFFLEtBQUssRUFBRSxDQUFDLENBQUM7SUFDekQsQ0FBQzs7O1lBcENKLFVBQVU7OztZQVJGLFVBQVU7WUFNVixNQUFNOzBDQVFOLE1BQU0sU0FBQyxtQkFBbUIiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBJbmplY3QsIEluamVjdGFibGUsIFR5cGUgfSBmcm9tICdAYW5ndWxhci9jb3JlJztcbmltcG9ydCB7IGdldEFjdGlvblR5cGVGcm9tSW5zdGFuY2UsIE9ic2VydmFibGVCdXMgfSBmcm9tICcuL3V0aWxzJztcbmltcG9ydCB7IElRdWVyeSwgSVF1ZXJ5QnVzLCBJUXVlcnlSZXN1bHQgfSBmcm9tICcuL2ludGVyZmFjZXMnO1xuaW1wb3J0IHsgQ3Fyc0xvYWRlciB9IGZyb20gJy4vY3Fycy1sb2FkZXInO1xuaW1wb3J0IHsgUXVlcnlIYW5kbGVyTm90Rm91bmRFeGNlcHRpb24gfSBmcm9tICcuL2V4Y2VwdGlvbnMnO1xuaW1wb3J0IHsgT2JzZXJ2YWJsZSB9IGZyb20gJ3J4anMnO1xuaW1wb3J0IHsgc2hhcmUgfSBmcm9tICdyeGpzL29wZXJhdG9ycyc7XG5pbXBvcnQgeyBvZlR5cGUgfSBmcm9tICcuL29wZXJhdG9ycy9vZi10eXBlJztcbmltcG9ydCB7IENRUlNfTU9EVUxFX0xPR0dJTkcgfSBmcm9tICcuL3Rva2Vucyc7XG5pbXBvcnQgeyBMb2dnZXIgfSBmcm9tICcuL3NlcnZpY2VzL2xvZ2dlcic7XG5cbkBJbmplY3RhYmxlKClcbmV4cG9ydCBjbGFzcyBRdWVyeUJ1cyBleHRlbmRzIE9ic2VydmFibGVCdXM8SVF1ZXJ5PiBpbXBsZW1lbnRzIElRdWVyeUJ1c1xue1xuICAgIGNvbnN0cnVjdG9yKFxuICAgICAgICBwcml2YXRlIHJlYWRvbmx5IGxvYWRlcjogQ3Fyc0xvYWRlcixcbiAgICAgICAgcHJpdmF0ZSByZWFkb25seSBsb2dnZXI6IExvZ2dlcixcbiAgICAgICAgQEluamVjdChDUVJTX01PRFVMRV9MT0dHSU5HKSByZWFkb25seSBlbmFibGVMb2dnaW5nOiBib29sZWFuXG4gICAgKVxuICAgIHtcbiAgICAgICAgc3VwZXIoKTtcbiAgICB9XG5cbiAgICBhc3luYyBleGVjdXRlPFQgZXh0ZW5kcyBJUXVlcnksIFRSZXN1bHQgZXh0ZW5kcyBJUXVlcnlSZXN1bHQ+KHF1ZXJ5OiBUKTogUHJvbWlzZTxUUmVzdWx0PlxuICAgIHtcbiAgICAgICAgYXdhaXQgdGhpcy5sb2FkZXIubG9hZChxdWVyeSk7XG4gICAgICAgIGlmICghdGhpcy5sb2FkZXIuaGFzSGFuZGxlcihxdWVyeSkpXG4gICAgICAgIHtcbiAgICAgICAgICAgIHRocm93IG5ldyBRdWVyeUhhbmRsZXJOb3RGb3VuZEV4Y2VwdGlvbihgUXVlcnlIYW5kbGVyIG5vdCBmb3VuZCBmb3IgY29tbWFuZCBcIiR7Z2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZShxdWVyeSl9XCJgKTtcbiAgICAgICAgfVxuICAgICAgICB0aGlzLnN1YmplY3QkLm5leHQocXVlcnkpO1xuICAgICAgICBjb25zdCByZXN1bHQgPSB0aGlzLmxvYWRlci5leGVjdXRlKHF1ZXJ5KTtcbiAgICAgICAgaWYgKHRoaXMuZW5hYmxlTG9nZ2luZylcbiAgICAgICAge1xuICAgICAgICAgICAgY29uc3QgcGF5bG9hZDogYW55ID0geyBxdWVyeSB9O1xuICAgICAgICAgICAgdGhpcy5sb2dnZXIubG9nUXVlcnkoZ2V0QWN0aW9uVHlwZUZyb21JbnN0YW5jZShxdWVyeSksIHBheWxvYWQpO1xuICAgICAgICAgICAgcGF5bG9hZC5yZXN1bHQgPSByZXN1bHQgaW5zdGFuY2VvZiBQcm9taXNlID8gKGF3YWl0IHJlc3VsdCkgOiByZXN1bHQ7XG4gICAgICAgICAgICByZXR1cm4gUHJvbWlzZS5yZXNvbHZlKHBheWxvYWQucmVzdWx0KTtcbiAgICAgICAgfVxuICAgICAgICByZXR1cm4gdGhpcy5sb2FkZXIuZXhlY3V0ZShxdWVyeSk7XG4gICAgfVxuXG4gICAgb2ZUeXBlPFRJbnB1dCBleHRlbmRzIElRdWVyeSwgVE91dHB1dCBleHRlbmRzIElRdWVyeT4oXG4gICAgICAgIC4uLnR5cGVzOiAoVHlwZTxJUXVlcnk+fHN0cmluZylbXVxuICAgICk6IE9ic2VydmFibGU8SVF1ZXJ5PlxuICAgIHtcbiAgICAgICAgcmV0dXJuIHRoaXMuc3ViamVjdCQucGlwZShvZlR5cGUoLi4udHlwZXMpLCBzaGFyZSgpKTtcbiAgICB9XG59XG4iXX0= |
@@ -180,5 +180,6 @@ import 'reflect-metadata'; | ||
if (this.enableLogging) { | ||
const value = result instanceof Promise ? (yield result) : result; | ||
this.logger.logQuery(getActionTypeFromInstance(query), { query, result: value }); | ||
return Promise.resolve(value); | ||
const payload = { query }; | ||
this.logger.logQuery(getActionTypeFromInstance(query), payload); | ||
payload.result = result instanceof Promise ? (yield result) : result; | ||
return Promise.resolve(payload.result); | ||
} | ||
@@ -219,4 +220,4 @@ return this.loader.execute(query); | ||
if (this.enableLogging) { | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
const value = result instanceof Promise ? (yield result) : result; | ||
this.logger.logAction(getActionTypeFromInstance(action), action); | ||
return Promise.resolve(value); | ||
@@ -223,0 +224,0 @@ } |
{ | ||
"name": "ng-cqrs", | ||
"version": "0.0.7", | ||
"version": "0.0.8", | ||
"peerDependencies": { | ||
@@ -5,0 +5,0 @@ "@angular/common": "^11.0.9", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
297302
1572