@rewaa/event-broker - npm Package Compare versions

Comparing version 6.1.1 to 6.1.2

dist/constants.d.ts

@@ -15,2 +15,3 @@ export declare const DEFAULT_MESSAGE_DELAY = 0;
 export declare const TOPIC_SUBSCRIBE_CHUNK_SIZE = 50;
+export declare const PAYLOAD_STRUCTURE_VERSION_V1 = "v1";
 export declare const PAYLOAD_STRUCTURE_VERSION_V2 = "v2";

dist/constants.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.PAYLOAD_STRUCTURE_VERSION_V2 = exports.TOPIC_SUBSCRIBE_CHUNK_SIZE = exports.DEFAULT_QUEUE_NAME_STANDARD = exports.DEFAULT_QUEUE_NAME_FIFO = exports.CUSTOM_HANDLER_NAME = exports.SOURCE_QUEUE_PREFIX = exports.DLQ_PREFIX = exports.DEFAULT_MAX_RETRIES = exports.DEFAULT_DLQ_MESSAGE_RETENTION_PERIOD = exports.DEFAULT_MESSAGE_RETENTION_PERIOD = exports.DEFAULT_VISIBILITY_TIMEOUT = exports.DEFAULT_BATCH_SIZE = exports.DEFAULT_MAX_PROCESSING_TIME = exports.DEFAULT_RETRY_COUNT = exports.DEFAULT_MESSAGE_DELAY = void 0;
+exports.PAYLOAD_STRUCTURE_VERSION_V2 = exports.PAYLOAD_STRUCTURE_VERSION_V1 = exports.TOPIC_SUBSCRIBE_CHUNK_SIZE = exports.DEFAULT_QUEUE_NAME_STANDARD = exports.DEFAULT_QUEUE_NAME_FIFO = exports.CUSTOM_HANDLER_NAME = exports.SOURCE_QUEUE_PREFIX = exports.DLQ_PREFIX = exports.DEFAULT_MAX_RETRIES = exports.DEFAULT_DLQ_MESSAGE_RETENTION_PERIOD = exports.DEFAULT_MESSAGE_RETENTION_PERIOD = exports.DEFAULT_VISIBILITY_TIMEOUT = exports.DEFAULT_BATCH_SIZE = exports.DEFAULT_MAX_PROCESSING_TIME = exports.DEFAULT_RETRY_COUNT = exports.DEFAULT_MESSAGE_DELAY = void 0;
 exports.DEFAULT_MESSAGE_DELAY = 0;
@@ -18,3 +18,4 @@ exports.DEFAULT_RETRY_COUNT = 0;
 exports.TOPIC_SUBSCRIBE_CHUNK_SIZE = 50;
+exports.PAYLOAD_STRUCTURE_VERSION_V1 = 'v1';
 exports.PAYLOAD_STRUCTURE_VERSION_V2 = 'v2';
 //# sourceMappingURL=constants.js.map

dist/emitters/emitter.sqns.js

@@ -51,3 +51,3 @@ "use strict";
             return {
-                data: [message.data],
+                data: message.data,
                 deduplicationId: message.deduplicationId,
@@ -63,3 +63,3 @@ eventName: topicName,
             return {
-                data: [message.data],
+                data: message.data,
                 deduplicationId: message.deduplicationId,
@@ -66,0 +66,0 @@ eventName: topicName,

dist/producers/producer.sns.js

@@ -76,3 +76,7 @@ "use strict";
         const params = {
-            Message: JSON.stringify(message),
+            Message: JSON.stringify(
+            /**
+             * @todo Un-array this when switching to payload version 2
+             */
+            [message]),
             TargetArn: topicArn,
@@ -90,3 +94,3 @@ };
                 DataType: "String",
-                StringValue: constants_1.PAYLOAD_STRUCTURE_VERSION_V2,
+                StringValue: constants_1.PAYLOAD_STRUCTURE_VERSION_V1,
             } });
@@ -99,3 +103,7 @@ }
             PublishBatchRequestEntries: messages.map((message) => {
-                return Object.assign({ Id: message.id, Message: JSON.stringify(message), MessageAttributes: this.getMessageAttributesForPublish(message.messageAttributes) }, (isFifo && {
+                return Object.assign({ Id: message.id, 
+                    /**
+                     * @todo Un-array this when switching to payload version 2
+                     */
+                    Message: JSON.stringify([message]), MessageAttributes: this.getMessageAttributesForPublish(message.messageAttributes) }, (isFifo && {
                     MessageDeduplicationId: message.deduplicationId || (0, uuid_1.v4)(),
@@ -102,0 +110,0 @@ MessageGroupId: message.messageGroupId,

dist/producers/producer.sqs.js

@@ -127,3 +127,7 @@ "use strict";
         const params = {
-            MessageBody: JSON.stringify(message),
+            MessageBody: JSON.stringify(
+            /**
+             * @todo Un-array this when switching to payload version 2
+             */
+            [message]),
             QueueUrl: queueUrl,
@@ -143,3 +147,7 @@ DelaySeconds: messageOptions.delay,
             Entries: messages.map((message) => {
-                return Object.assign({ Id: message.id, DelaySeconds: message.delay, MessageAttributes: this.getMessageAttributes(queueUrl, message), MessageBody: JSON.stringify(message) }, (isFifo && {
+                return Object.assign({ Id: message.id, DelaySeconds: message.delay, MessageAttributes: this.getMessageAttributes(queueUrl, message), 
+                    /**
+                     * @todo Un-array this when switching to payload version 2
+                     */
+                    MessageBody: JSON.stringify([message]) }, (isFifo && {
                     MessageDeduplicationId: message.deduplicationId || (0, uuid_1.v4)(),
@@ -208,3 +216,3 @@ MessageGroupId: message.messageGroupId,
                 DataType: "String",
-                StringValue: constants_1.PAYLOAD_STRUCTURE_VERSION_V2,
+                StringValue: constants_1.PAYLOAD_STRUCTURE_VERSION_V1,
             } });
@@ -211,0 +219,0 @@ }

package.json

 {
   "name": "@rewaa/event-broker",
-  "version": "6.1.1",
+  "version": "6.1.2",
   "description": "A broker for all the events that Rewaa will ever produce or consume",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

Unpublished package

Supply chain risk

Package version was not found on the registry. It may exist on a different registry and need to be configured to pull from that registry.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

237559

increased by0.33%

Lines of code

1993

increased by0.96%

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes