@cheep/transport - npm Package Compare versions

Comparing version 1.0.0-beta.10 to 1.0.0-beta.12

package.json

 {
   "name": "@cheep/transport",
-  "version": "1.0.0-beta.10",
+  "version": "1.0.0-beta.12",
   "main": "src/index.js",
   "typings": "src/index.d.ts"
 }

src/lib/transport.base.d.ts

@@ -7,2 +7,3 @@ import { NormalizedError } from './domain/normalizeError';
     metadataValidator?: MetadataValidator<TMeta>[];
+    errorQueueName?: string;
 }
@@ -60,5 +61,5 @@ export interface TransportUtils {
 export interface PureMessage {
-    data?: unknown;
+    payload?: unknown;
     metadata: MessageMetadata;
     errorData?: NormalizedError;
 }

src/lib/transport.base.js

@@ -64,6 +64,6 @@ "use strict";
         return tslib_1.__awaiter(this, void 0, void 0, function* () {
-            const { route, message, metadata = {}, referrer } = props;
+            const { route, payload: message, metadata = {}, referrer } = props;
             const finalMetadata = this.mergeMetadata({
                 currentRoute: route,
-                currentMessage: message,
+                currentPayload: message,
                 currentMetadata: metadata,
@@ -75,3 +75,3 @@ referrer,
                 message: this.utils.jsonEncode({
-                    data: message,
+                    payload: message,
                     metadata: finalMetadata,
@@ -85,3 +85,3 @@ }),
             const { defaultRpcTimeout = 1000 } = this.options;
-            const { route, message, metadata = {}, referrer, rpcTimeout, } = props;
+            const { route, payload: message, metadata = {}, referrer, rpcTimeout, } = props;
             const correlationId = this.utils.newId();
@@ -94,3 +94,3 @@ const rpcCallTimeout = rpcTimeout !== null && rpcTimeout !== void 0 ? rpcTimeout : defaultRpcTimeout;
                         clearTimeout(timer);
-                        const { data: content, errorData } = this.utils.jsonDecode(item.message);
+                        const { payload: content, errorData, } = this.utils.jsonDecode(item.message);
                         if (errorData) {
@@ -116,3 +116,3 @@ reject(new remote_error_1.RemoteError(errorData.errorMessage, errorData.errorCallStack, errorData.errorClassName));
                 currentRoute: route,
-                currentMessage: message,
+                currentPayload: message,
                 currentMetadata: metadata,
@@ -124,3 +124,3 @@ referrer,
                 message: this.utils.jsonEncode({
-                    data: message,
+                    payload: message,
                     metadata: finalMetadata,
@@ -162,3 +162,3 @@ }),
                             route: msg.route,
-                            message: message.data,
+                            payload: message.payload,
                             metadata: message.metadata,
@@ -196,3 +196,3 @@ });
                                     route: msg.route,
-                                    message: message.data,
+                                    payload: message.payload,
                                     metadata: message.metadata,
@@ -220,3 +220,3 @@ });
                         route: msg.route,
-                        message: message.data,
+                        payload: message.payload,
                         metadata: message.metadata,
@@ -247,3 +247,3 @@ });
                         message: this.utils.jsonEncode({
-                            data: result,
+                            payload: result,
                             metadata: message.metadata,
@@ -257,3 +257,3 @@ }),
                         route: msg.route,
-                        message: message.data,
+                        payload: message.payload,
                         metadata: message.metadata,
@@ -292,8 +292,8 @@ }));
     mergeMetadata(context) {
-        const { metadataReducers: metadataRules = [] } = this.options;
-        const { referrer, currentMetadata, currentRoute, currentMessage, } = context;
-        const merged = metadataRules.reduce((meta, fn) => {
+        const { metadataReducers = [] } = this.options;
+        const { referrer, currentMetadata, currentRoute, currentPayload, } = context;
+        const merged = metadataReducers.reduce((meta, fn) => {
             const x = fn({
                 currentRoute,
-                currentMessage,
+                currentPayload,
                 currentMetadata: meta,
@@ -300,0 +300,0 @@ referrer,

src/lib/transport.d.ts

@@ -43,3 +43,3 @@ export interface Transport {
     route: string;
-    message: unknown;
+    payload: unknown;
     metadata: MessageMetadata;
@@ -53,3 +53,3 @@ }
     route: string;
-    message: unknown;
+    payload: unknown;
     metadata?: Partial<TMetadata>;
@@ -60,3 +60,3 @@ referrer?: Referrer<TMetadata>;
     route: string;
-    message: unknown;
+    payload: unknown;
     metadata?: TMetadata;
@@ -78,3 +78,3 @@ referrer?: Referrer<TMetadata>;
     currentRoute: string;
-    currentMessage: unknown;
+    currentPayload: unknown;
 }) => Partial<TMeta>;
@@ -84,4 +84,4 @@ export declare type MetadataValidator<TMeta extends MessageMetadata = MessageMetadata> = (msg: ValidatorMessage<TMeta>) => void;
     route: string;
-    message: unknown;
+    payload: unknown;
     metadata: TMeta;
 }

Fixed alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

48177

increased by0.16%

Lines of code

795

increased by0.13%

Number of medium supply chain risk alerts

0

decreased by-100%

No dependency changes