@arque/core - npm Package Compare versions

Comparing version 0.1.0-alpha.14 to 0.1.0-alpha.16

dist/libs/event-store.d.ts

@@ -6,6 +6,2 @@ /// <reference types="node" />
 }
-type Transaction = {
-    commit(): Promise<void>;
-    abort(): Promise<void>;
-};
 export interface EventStoreStreamAdapter {
@@ -15,3 +11,3 @@ sendEvents(data: {
         event: Event;
-    }[]): Promise<Transaction>;
+    }[]): Promise<void>;
     receiveEvents(stream: string, handler: (event: Event) => Promise<void>): Promise<EventStoreStreamReceiver>;
@@ -27,3 +23,3 @@ }
         events: Pick<Event, 'id' | 'type' | 'body' | 'meta'>[];
-    }): Promise<Transaction>;
+    }): Promise<void>;
     listEvents<TEvent = Event>(params: {
@@ -79,2 +75,1 @@ aggregate: {
 }
-export {};

dist/libs/event-store.js

@@ -28,19 +28,4 @@ "use strict";
         }));
-        let storageAdapterSaveEventsTransaction;
-        let streamAdapterSendEventsTransaction;
-        try {
-            storageAdapterSaveEventsTransaction = await this.storageAdapter.saveEvents(params);
-            streamAdapterSendEventsTransaction = await this.streamAdapter.sendEvents(streamAdapterSendEventsData);
-            await Promise.all([
-                storageAdapterSaveEventsTransaction.commit(),
-                streamAdapterSendEventsTransaction.commit(),
-            ]);
-        }
-        catch (err) {
-            await Promise.all([
-                storageAdapterSaveEventsTransaction === null || storageAdapterSaveEventsTransaction === void 0 ? void 0 : storageAdapterSaveEventsTransaction.abort(),
-                streamAdapterSendEventsTransaction === null || streamAdapterSendEventsTransaction === void 0 ? void 0 : streamAdapterSendEventsTransaction.abort(),
-            ]);
-            throw err;
-        }
+        await this.storageAdapter.saveEvents(params);
+        await this.streamAdapter.sendEvents(streamAdapterSendEventsData);
     }
@@ -47,0 +32,0 @@ }

package.json

 {
   "name": "@arque/core",
-  "version": "0.1.0-alpha.14",
+  "version": "0.1.0-alpha.16",
   "description": "The Event Sourcing library.",
@@ -33,3 +33,3 @@ "author": "ScaleForge",
   },
-  "gitHead": "c3ebe93245e992c4c557d66802a65a3fc345832f"
+  "gitHead": "2091af6df277b13c5599bfc01cc064430d1be911"
 }

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

Worsened metrics

Total package byte prevSize

32396

decreased by-3.88%

Lines of code

532

decreased by-3.62%

No dependency changes