@mojaloop/platform-shared-lib-messaging-types-lib - npm Package Compare versions

Comparing version 0.6.2 to 0.7.1

dist/messages.d.ts

@@ -30,9 +30,15 @@ /*****
  ******/
-export declare enum MessageTypes {
-    "STATE_EVENT" = 0,
-    "STATE_SNAPSHOT" = 1,
-    "DOMAIN_EVENT" = 2,
-    "COMMAND" = 3,
-    "DOMAIN_ERROR_EVENT" = 4
-}
+export declare const MessageTypes: {
+    readonly STATE_EVENT: "STATE_EVENT";
+    readonly STATE_SNAPSHOT: "STATE_SNAPSHOT";
+    readonly DOMAIN_EVENT: "DOMAIN_EVENT";
+    readonly COMMAND: "COMMAND";
+};
+export type MessageTypes = keyof typeof MessageTypes;
+export declare const MessageInboundProtocol: {
+    readonly FSPIOP_v1_1: "FSPIOP v1.1";
+    readonly ISO20022O: "ISO 20022O";
+    readonly GRPC_SYNC: "GRPC_SYNC";
+};
+export type MessageInboundProtocol = keyof typeof MessageInboundProtocol;
 export interface IMessage {
@@ -48,3 +54,4 @@ msgType: MessageTypes;
     payload: any;
-    fspiopOpaqueState: any;
+    inboundProtocolType: MessageInboundProtocol;
+    inboundProtocolOpaqueState: any;
     tracingInfo?: any;
@@ -68,3 +75,4 @@ }
     abstract payload: any;
-    abstract fspiopOpaqueState: any;
+    abstract inboundProtocolType: MessageInboundProtocol;
+    abstract inboundProtocolOpaqueState: any;
     abstract tracingInfo?: any;
@@ -75,3 +83,4 @@ abstract validatePayload(): void;
     msgType: MessageTypes;
-    fspiopOpaqueState: any;
+    inboundProtocolType: MessageInboundProtocol;
+    inboundProtocolOpaqueState: any;
     tracingInfo: any;
@@ -82,18 +91,15 @@ abstract validatePayload(): void;
     msgType: MessageTypes;
-    fspiopOpaqueState: any;
+    inboundProtocolType: MessageInboundProtocol;
+    inboundProtocolOpaqueState: any;
     tracingInfo: any;
+    isErrorEvent: boolean;
+    sourceMessageName?: string;
     abstract validatePayload(): void;
 }
-export declare abstract class DomainErrorEventMsg extends DomainMsg {
-    msgType: MessageTypes;
-    fspiopOpaqueState: any;
-    tracingInfo: any;
-    sourceMessageName: string;
-    abstract validatePayload(): void;
-}
 export declare abstract class CommandMsg extends DomainMsg {
     msgType: MessageTypes;
-    fspiopOpaqueState: any;
+    inboundProtocolType: MessageInboundProtocol;
+    inboundProtocolOpaqueState: any;
     tracingInfo: any;
     abstract validatePayload(): void;
 }

dist/messages.js

@@ -32,14 +32,17 @@ /*****
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.CommandMsg = exports.DomainErrorEventMsg = exports.DomainEventMsg = exports.StateEventMsg = exports.DomainMsg = exports.MessageTypes = void 0;
+exports.CommandMsg = exports.DomainEventMsg = exports.StateEventMsg = exports.DomainMsg = exports.MessageInboundProtocol = exports.MessageTypes = void 0;
 const tslib_1 = require("tslib");
 /* eslint-disable @typescript-eslint/no-explicit-any */
 const Crypto = tslib_1.__importStar(require("crypto"));
-var MessageTypes;
-(function (MessageTypes) {
-    MessageTypes[MessageTypes["STATE_EVENT"] = 0] = "STATE_EVENT";
-    MessageTypes[MessageTypes["STATE_SNAPSHOT"] = 1] = "STATE_SNAPSHOT";
-    MessageTypes[MessageTypes["DOMAIN_EVENT"] = 2] = "DOMAIN_EVENT";
-    MessageTypes[MessageTypes["COMMAND"] = 3] = "COMMAND";
-    MessageTypes[MessageTypes["DOMAIN_ERROR_EVENT"] = 4] = "DOMAIN_ERROR_EVENT"; // for domain errors, this includes the source message name being processed when the error happened
-})(MessageTypes = exports.MessageTypes || (exports.MessageTypes = {}));
+exports.MessageTypes = {
+    STATE_EVENT: "STATE_EVENT",
+    STATE_SNAPSHOT: "STATE_SNAPSHOT",
+    DOMAIN_EVENT: "DOMAIN_EVENT",
+    COMMAND: "COMMAND" // for internal/private BC commands
+};
+exports.MessageInboundProtocol = {
+    FSPIOP_v1_1: "FSPIOP v1.1",
+    ISO20022O: "ISO 20022O",
+    GRPC_SYNC: "GRPC_SYNC"
+};
 class DomainMsg {
@@ -54,4 +57,5 @@ msgId = Crypto.randomUUID();
 class StateEventMsg extends DomainMsg {
-    msgType = MessageTypes.STATE_EVENT;
-    fspiopOpaqueState = null;
+    msgType = exports.MessageTypes.STATE_EVENT;
+    inboundProtocolType;
+    inboundProtocolOpaqueState = null;
     tracingInfo = undefined;
@@ -61,17 +65,14 @@ }
 class DomainEventMsg extends DomainMsg {
-    msgType = MessageTypes.DOMAIN_EVENT;
-    fspiopOpaqueState = null;
+    msgType = exports.MessageTypes.DOMAIN_EVENT;
+    inboundProtocolType;
+    inboundProtocolOpaqueState = null;
     tracingInfo = undefined;
+    isErrorEvent = false;
+    sourceMessageName = undefined;
 }
 exports.DomainEventMsg = DomainEventMsg;
-class DomainErrorEventMsg extends DomainMsg {
-    msgType = MessageTypes.DOMAIN_ERROR_EVENT;
-    fspiopOpaqueState = null;
-    tracingInfo = undefined;
-    sourceMessageName; // this should include the name of the message being processed when the error happened
-}
-exports.DomainErrorEventMsg = DomainErrorEventMsg;
 class CommandMsg extends DomainMsg {
-    msgType = MessageTypes.COMMAND;
-    fspiopOpaqueState = null;
+    msgType = exports.MessageTypes.COMMAND;
+    inboundProtocolType;
+    inboundProtocolOpaqueState = null;
     tracingInfo = undefined;
@@ -78,0 +79,0 @@ }

package.json

 {
     "name": "@mojaloop/platform-shared-lib-messaging-types-lib",
-    "version": "0.6.2",
+    "version": "0.7.1",
     "description": "mojaloop vnext platform shared libraries - generic messaging types lib",
@@ -5,0 +5,0 @@ "license": "Apache-2.0",

No alert changes

Improved metrics

Total package byte prevSize

26627

increased by0.37%

Lines of code

337

increased by2.12%

No dependency changes