@serialized/serialized-client - npm Package Compare versions

Comparing version 3.0.0 to 3.1.0

dist/AggregatesClient.d.ts

@@ -40,2 +40,3 @@ import { BaseClient, DomainEvent, EventEnvelope } from './';
     private readonly initialState;
+    private readonly stateLoader;
     constructor(aggregateTypeConstructor: any, config: any);
@@ -42,0 +43,0 @@ checkExists(request: CheckAggregateExistsRequest): Promise<any>;

dist/AggregatesClient.js

@@ -53,2 +53,3 @@ "use strict";
 var _1 = require("./");
+var StateLoader_1 = require("./StateLoader");
 var AggregatesClient = /** @class */ (function (_super) {
@@ -62,3 +63,3 @@ __extends(AggregatesClient, _super);
         _this.initialState = aggregateTypeInstance.initialState;
-        _this.eventHandlers = aggregateTypeInstance.eventHandlers;
+        _this.stateLoader = new StateLoader_1.StateLoader(aggregateTypeInstance.initialState, aggregateTypeInstance.eventHandlers);
         return _this;
@@ -152,3 +153,2 @@ }
             var url, axiosResponse, data, currentState, aggregate, metadata;
-            var _this = this;
             return __generator(this, function (_a) {
@@ -162,12 +162,3 @@ switch (_a.label) {
                         data = axiosResponse.data;
-                        currentState = this.initialState;
-                        data.events.forEach(function (e) {
-                            var handler = _this.eventHandlers[e.eventType];
-                            if (handler) {
-                                currentState = handler(currentState, e);
-                            }
-                            else {
-                                return Promise.reject("Failed to call handler. No match for event " + e.eventType);
-                            }
-                        });
+                        currentState = this.stateLoader.loadState(data.events);
                         aggregate = new this.aggregateTypeConstructor.prototype.constructor(currentState);
@@ -174,0 +165,0 @@ metadata = { version: data.aggregateVersion };

dist/index.d.ts

@@ -8,2 +8,3 @@ import { SerializedInstance } from "./Serialized";
 export * from "./AggregatesClient";
+export * from "./StateLoader";
 export * from "./ProjectionsClient";
@@ -10,0 +11,0 @@ export * from "./ReactionsClient";

dist/index.js

@@ -11,2 +11,3 @@ "use strict";
 __export(require("./AggregatesClient"));
+__export(require("./StateLoader"));
 __export(require("./ProjectionsClient"));
@@ -13,0 +14,0 @@ __export(require("./ReactionsClient"));

package.json

@@ -6,3 +6,3 @@ {
   "author": "Mattias Holmqvist",
-  "version": "3.0.0",
+  "version": "3.1.0",
   "main": "dist/index.js",
@@ -9,0 +9,0 @@ "types": "dist/index.d.ts",

No alert changes

Improved metrics

Total package byte prevSize

60277

increased by1.47%

Number of package files

23

increased by9.52%

Lines of code

1237

increased by2.23%

No dependency changes