resolve-eventstore-base - npm Package Compare versions

Comparing version 0.24.3 to 0.24.4

es/create-adapter.js

@@ -22,3 +22,3 @@ import getSecretsManagerFallback from './get-secrets-manager-fallback';
   dispose,
-  saveEventOnly,
+  injectEvent,
   isFrozen,
@@ -46,3 +46,3 @@ freeze,
   Object.assign(pool, {
-    saveEventOnly: wrapMethod(pool, saveEventOnly),
+    injectEvent: wrapMethod(pool, injectEvent),
     loadEventsByCursor: wrapMethod(pool, loadEventsByCursor),
@@ -49,0 +49,0 @@ loadEventsByTimestamp: wrapMethod(pool, loadEventsByTimestamp),

es/import.js

@@ -47,3 +47,3 @@ import stream from 'stream';
       freeze,
-      saveEventOnly
+      injectEvent
     } = this.pool;
@@ -112,3 +112,3 @@
       this.timestamp = Math.max(this.timestamp, event.timestamp);
-      const saveEventPromise = saveEventOnly(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
+      const saveEventPromise = injectEvent(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
       void saveEventPromise.then(this.saveEventPromiseSet.delete.bind(this.saveEventPromiseSet, saveEventPromise));
@@ -146,3 +146,3 @@ this.saveEventPromiseSet.add(saveEventPromise);
       unfreeze,
-      saveEventOnly
+      injectEvent
     } = this.pool;
@@ -172,3 +172,3 @@
         this.byteOffset += eventByteLength;
-        const saveEventPromise = saveEventOnly(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
+        const saveEventPromise = injectEvent(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
         void saveEventPromise.then(this.saveEventPromiseSet.delete.bind(this.saveEventPromiseSet, saveEventPromise));
@@ -187,3 +187,9 @@ this.saveEventPromiseSet.add(saveEventPromise);
     if (this.saveEventErrors.length > 0) {
-      throw new Error(this.saveEventErrors.join(EOL));
+      const error = new Error(this.saveEventErrors.map(({
+        message
+      }) => message).join(EOL));
+      error.stack = this.saveEventErrors.map(({
+        stack
+      }) => stack).join(EOL);
+      throw error;
     }
@@ -190,0 +196,0 @@

index.d.ts

@@ -16,3 +16,3 @@ declare class EventStoreError {
   dispose: Function
-  saveEventOnly: Function
+  injectEvent: Function
   isFrozen?: Function
@@ -19,0 +19,0 @@ freeze: Function

lib/create-adapter.js

@@ -31,3 +31,3 @@ "use strict";
   dispose,
-  saveEventOnly,
+  injectEvent,
   isFrozen,
@@ -55,3 +55,3 @@ freeze,
   Object.assign(pool, {
-    saveEventOnly: wrapMethod(pool, saveEventOnly),
+    injectEvent: wrapMethod(pool, injectEvent),
     loadEventsByCursor: wrapMethod(pool, loadEventsByCursor),
@@ -58,0 +58,0 @@ loadEventsByTimestamp: wrapMethod(pool, loadEventsByTimestamp),

lib/import.js

@@ -59,3 +59,3 @@ "use strict";
       freeze,
-      saveEventOnly
+      injectEvent
     } = this.pool;
@@ -124,3 +124,3 @@
       this.timestamp = Math.max(this.timestamp, event.timestamp);
-      const saveEventPromise = saveEventOnly(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
+      const saveEventPromise = injectEvent(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
       void saveEventPromise.then(this.saveEventPromiseSet.delete.bind(this.saveEventPromiseSet, saveEventPromise));
@@ -158,3 +158,3 @@ this.saveEventPromiseSet.add(saveEventPromise);
       unfreeze,
-      saveEventOnly
+      injectEvent
     } = this.pool;
@@ -184,3 +184,3 @@
         this.byteOffset += eventByteLength;
-        const saveEventPromise = saveEventOnly(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
+        const saveEventPromise = injectEvent(event).catch(this.saveEventErrors.push.bind(this.saveEventErrors));
         void saveEventPromise.then(this.saveEventPromiseSet.delete.bind(this.saveEventPromiseSet, saveEventPromise));
@@ -199,3 +199,9 @@ this.saveEventPromiseSet.add(saveEventPromise);
     if (this.saveEventErrors.length > 0) {
-      throw new Error(this.saveEventErrors.join(_os.EOL));
+      const error = new Error(this.saveEventErrors.map(({
+        message
+      }) => message).join(_os.EOL));
+      error.stack = this.saveEventErrors.map(({
+        stack
+      }) => stack).join(_os.EOL);
+      throw error;
     }
@@ -202,0 +208,0 @@

package.json

 {
   "name": "resolve-eventstore-base",
-  "version": "0.24.3",
+  "version": "0.24.4",
   "description": "A base for reSolve eventstore adapters",
@@ -5,0 +5,0 @@ "engines": {

No alert changes

Improved metrics

Total package byte prevSize

136894

increased by0.78%

Lines of code

1260

increased by0.96%

No dependency changes