@pager/event-sourcerer-client - npm Package Compare versions

Comparing version 2.0.0 to 2.1.0

lib/client.js

@@ -13,6 +13,6 @@ 'use strict';
 
-    async publish(stream, streamId, eventType, data, eventId) {
+    async publish(stream, streamId, eventType, data, eventId, asOf) {
 
         eventId = eventId || this.idGenerator();
-        return await this.transport.publish(stream, streamId, eventType, data, eventId);
+        return await this.transport.publish(stream, streamId, eventType, data, eventId, asOf);
     }
@@ -19,0 +19,0 @@ }

lib/transports/multi-key-rabbit.js

@@ -11,3 +11,3 @@ 'use strict';
 
-    async publish(stream, streamId, eventType, data) {
+    async publish(stream, streamId, eventType, data, asOf) {
 
@@ -14,0 +14,0 @@ return await this.publisher.publish(data, {

lib/transports/multi-transport.js

@@ -10,7 +10,7 @@ 'use strict';
 
-    publish(stream, streamId, eventType, data, eventId) {
+    publish(stream, streamId, eventType, data, eventId, asOf) {
 
         return Promise.all(this.transports.map((transport) => {
 
-            return transport.publish(stream, streamId, eventType, data, eventId);
+            return transport.publish(stream, streamId, eventType, data, eventId, asOf);
         }));
@@ -17,0 +17,0 @@ }

lib/transports/single-key-rabbit.js

@@ -14,5 +14,5 @@ 'use strict';
 
-    async publish(stream, streamId, eventType, data, eventId) {
+    async publish(stream, streamId, eventType, data, eventId, asOf) {
 
-        this.logger.info({ msg: 'publishing event', stream, streamId, eventType, eventId });
+        this.logger.info({ msg: 'publishing event', stream, streamId, eventType, eventId, asOf });
 
@@ -31,3 +31,4 @@ const options = { key: `events.${stream}.created` };
                 eventType,
-                eventId
+                eventId,
+                asOf
             }, options);
@@ -34,0 +35,0 @@ }

package.json

 {
   "name": "@pager/event-sourcerer-client",
-  "version": "2.0.0",
+  "version": "2.1.0",
   "description": "event-sourcerer client",
@@ -18,3 +18,3 @@ "main": "lib/index.js",
   "devDependencies": {
-    "@hapi/code": "5.x.x",
+    "@hapi/code": "6.x.x",
     "@hapi/lab": "19.x.x",
@@ -21,0 +21,0 @@ "eslint-config-hapi": "12.x.x",

No alert changes

Improved metrics

Total package byte prevSize

5807

increased by1.11%

Lines of code

73

increased by1.39%

No dependency changes