feat(mojaloop/2949): [sdk-scheme-adapter][private-shared-lib] Update …

…private-shared-lib to use v0.2 (#414)

feat(mojaloop/2949): [sdk-scheme-adapter][private-shared-lib] Update private-shared-lib to use v0.2.0 of @mojaloop/platform-shared-lib - mojaloop/project#2949
- upgraded @mojaloop/platform-shared-lib-nodejs-kafka-client-lib & @mojaloop/platform-shared-lib-messaging-types-lib dependencies, and re-factored messaging/kafka consumers/producers to use the raw Producers/Consumers
- removed dependencies from ncurc since we can now upgrade them as normal
- created iRawMessageHeader alias as iMessageHeaders to reduce the re-factoring required

.ncurc.yaml

@@ -1,10 +1,3 @@
 ## Add a TODO comment indicating the reason for each rejected dependency upgrade added to this list, and what should be done to resolve it (i.e. handle it through a story, etc).
 reject: [
-  ## v0.2.0 of the these libraries introduces various changes to base classes used in `private-shared-lib`.
-  ## https://github.com/mojaloop/platform-shared-lib.
-  ## Story to resolve issue: https://github.com/mojaloop/project/issues/2949
-  '@mojaloop/platform-shared-lib-nodejs-kafka-client-lib',
-  '@mojaloop/platform-shared-lib-messaging-types-lib',
-  ## This should be removed and upgraded as part of this PR: https://github.com/mojaloop/sdk-scheme-adapter/pull/391
-  '@mojaloop/api-snippets'
 ]

modules/api-svc/package.json

@@ -60,7 +60,7 @@
   },
   "dependencies": {
     "@koa/cors": "^4.0.0",
-    "@mojaloop/api-snippets": "^16.0.4",
+    "@mojaloop/api-snippets": "^16.0.5",
     "@mojaloop/central-services-error-handling": "^12.0.5",
     "@mojaloop/central-services-logger": "^11.0.1",
     "@mojaloop/central-services-metrics": "^12.0.5",

modules/outbound-command-event-handler/package.json

@@ -39,7 +39,7 @@
     "snapshot": "standard-version --no-verify --skip.changelog --prerelease snapshot --releaseCommitMessageFormat 'chore(snapshot): {{currentTag}}'"
   },
   "dependencies": {
-    "@mojaloop/api-snippets": "^16.0.4",
+    "@mojaloop/api-snippets": "^16.0.5",
     "@mojaloop/central-services-shared": "^17.3.1",
     "@mojaloop/logging-bc-client-lib": "^0.1.15",
     "@mojaloop/logging-bc-public-types-lib": "^0.1.12",

modules/outbound-domain-event-handler/package.json

@@ -39,7 +39,7 @@
         "snapshot": "standard-version --no-verify --skip.changelog --prerelease snapshot --releaseCommitMessageFormat 'chore(snapshot): {{currentTag}}'"
     },
     "dependencies": {
-        "@mojaloop/api-snippets": "^16.0.4",
+        "@mojaloop/api-snippets": "^16.0.5",
         "@mojaloop/logging-bc-client-lib": "^0.1.15",
         "@mojaloop/logging-bc-public-types-lib": "^0.1.12",
         "@mojaloop/sdk-scheme-adapter-private-shared-lib": "workspace:^",

modules/private-shared-lib/package.json

@@ -27,11 +27,11 @@
     "snapshot": "standard-version --no-verify --skip.changelog --prerelease snapshot --releaseCommitMessageFormat 'chore(snapshot): {{currentTag}}'"
   },
   "dependencies": {
-    "@mojaloop/api-snippets": "^16.0.4",
+    "@mojaloop/api-snippets": "^16.0.5",
     "@mojaloop/central-services-shared": "^17.3.1",
     "@mojaloop/logging-bc-public-types-lib": "^0.1.12",
-    "@mojaloop/platform-shared-lib-messaging-types-lib": "^0.1.1",
-    "@mojaloop/platform-shared-lib-nodejs-kafka-client-lib": "^0.1.1",
+    "@mojaloop/platform-shared-lib-messaging-types-lib": "^0.2.16",
+    "@mojaloop/platform-shared-lib-nodejs-kafka-client-lib": "^0.2.13",
     "ajv": "^8.11.0",
     "redis": "^4.4.0",
     "uuid": "^9.0.0"

modules/private-shared-lib/src/events/base_event.ts

@@ -24,7 +24,7 @@
 
 'use strict';
 // import { v4 as uuidv4 } from 'uuid'
-import { IMessage, IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessage, IMessageHeader } from '@module-types';
 import { getEnumValues } from '../utils';
 
 export enum EventType {
@@ -121,6 +121,8 @@ export class BaseEvent {
             key: this._data.key,
             timestamp: this._data.timestamp,
             headers: this._data.headers,
+            partition: null,
+            offset: null,
         };
         return message;
     }

modules/private-shared-lib/src/events/command_event.ts

@@ -24,7 +24,7 @@
 
 'use strict';
 
-import { IMessage } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessage } from '@module-types';
 import { IEventData, EventType, BaseEvent, IEventValue } from './base_event';
 
 export type ICommandEventData = Omit<IEventData, 'type'>;

modules/private-shared-lib/src/events/domain_event.ts

@@ -24,7 +24,7 @@
 
 'use strict';
 
-import { IMessage } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessage } from '@module-types';
 import { IEventData, EventType, BaseEvent, IEventValue } from './base_event';
 
 export type IDomainEventData = Omit<IEventData, 'type'>;

modules/private-shared-lib/src/events/outbound_command_event/prepare_sdk_outbound_bulk_response.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IPrepareSDKOutboundBulkResponseCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_command_event/process_bulk_quotes_callback.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { BulkQuoteErrorResponse, BulkQuoteResponse } from '../../types';
 
 export interface IProcessBulkQuotesCallbackCmdEvtData {

modules/private-shared-lib/src/events/outbound_command_event/process_bulk_transfers_callback.ts

@@ -1,7 +1,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { BulkTransferErrorResponse, BulkTransferResponse } from '../../types';
 
 export interface IProcessBulkTransfersCallbackCmdEvtData {

modules/private-shared-lib/src/events/outbound_command_event/process_party_info_callback.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { PartyErrorResponse, PartyResponse } from '@module-types';
 
 export interface IProcessPartyInfoCallbackCmdEvtData {

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_accept_party_info.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 import { randomUUID } from 'crypto';
 

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_accept_quote.ts

@@ -26,7 +26,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export interface IProcessSDKOutboundBulkAcceptQuoteCmdEvtData {

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_party_info_request.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IProcessSDKOutboundBulkPartyInfoRequestCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_quotes_request.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IProcessSDKOutboundBulkQuotesRequestCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_request.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 import { randomUUID } from 'crypto';
 

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_response_sent.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IProcessSDKOutboundBulkResponseSentCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_tranfers_request_complete.ts

@@ -1,7 +1,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IProcessSDKOutboundBulkTransfersRequestCompleteCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_command_event/process_sdk_outbound_bulk_transfers_request.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { CommandEvent } from '../command_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IProcessSDKOutboundBulkTransfersRequestCmdEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/bulk_quotes_callback_processed.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export type IBulkQuotesCallbackProcessedDmEvtData = {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/bulk_quotes_callback_received.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { BulkQuoteErrorResponse, BulkQuoteResponse } from '@module-types';
 
 export interface IBulkQuotesCallbackReceivedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/bulk_quotes_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export type IBulkQuotesRequestedDmEvtData = {

modules/private-shared-lib/src/events/outbound_domain_event/bulk_transfers_callback_processed.ts

@@ -1,7 +1,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export type IBulkTransfersCallbackProcessedDmEvtData = {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/bulk_transfers_callback_received.ts

@@ -1,7 +1,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { BulkTransferErrorResponse, BulkTransferResponse } from '@module-types';
 
 export type IBulkTransfersCallbackReceivedDmEvtData = {

modules/private-shared-lib/src/events/outbound_domain_event/bulk_transfers_processed.ts

@@ -1,7 +1,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export type IBulkTransfersProcessedDmEvtData = {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/bulk_transfers_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export type IBulkTransfersRequestedDmEvtData = {

modules/private-shared-lib/src/events/outbound_domain_event/party_info_callback_processed.ts

@@ -26,7 +26,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface IPartyInfoCallbackProcessedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/party_info_callback_received.ts

@@ -26,7 +26,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { PartyErrorResponse, PartyResponse } from '@module-types';
 
 export interface IPartyInfoCallbackReceivedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/party_info_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { PartyInfoRequest } from '@module-types';
 
 export interface IPartyInfoRequestedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_party_info_processed.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface ISDKOutboundBulkAcceptPartyInfoProcessedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_party_info_received.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export interface ISDKOutboundBulkAcceptPartyInfoReceivedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_party_info_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export type CoreConnectorBulkAcceptPartyInfoRequestIndividualTransferResult = {

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_quote_processed.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export type ISDKOutboundBulkAcceptQuoteProcessedDmEvtData = {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_quote_received.ts

@@ -26,7 +26,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 export interface ISDKOutboundBulkAcceptQuoteReceivedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_accept_quote_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 
 // TODO: Current dfspInboundAPI is outdated and its better to add the core connector API to the API snippets library as single source of truth.

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_auto_accept_party_info_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface ISDKOutboundBulkAutoAcceptPartyInfoRequestedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_auto_accept_quote_completed.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface ISDKOutboundBulkAutoAcceptQuoteCompletedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_party_info_request_processed.ts

@@ -24,7 +24,7 @@
 
 'use strict';
 
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { DomainEvent } from '../domain_event';
 
 export interface ISDKOutboundBulkPartyInfoRequestProcessedDmEvtData {

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_party_info_requested.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface ISDKOutboundBulkPartyInfoRequestedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_quotes_request_processed.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 
 export interface ISDKOutboundBulkQuotesRequestProcessedDmEvtData {
     bulkId: string;

modules/private-shared-lib/src/events/outbound_domain_event/sdk_outbound_bulk_request_received.ts

@@ -25,7 +25,7 @@
 'use strict';
 
 import { DomainEvent } from '../domain_event';
-import { IMessageHeader } from '@mojaloop/platform-shared-lib-messaging-types-lib';
+import { IMessageHeader } from '@module-types';
 import { SDKSchemeAdapter } from '@mojaloop/api-snippets';
 import { randomUUID } from 'crypto';