feat(csi-110): adding iso20022 api translation capability

.gitignore

@@ -23,3 +23,5 @@ devspace*
 **/dist/*
 .DS_Store
 dist
+
+.rush

.husky/pre-commit

@@ -1,2 +1 @@
-yarn dep:check
 yarn lint

.husky/pre-push

@@ -0,0 +1,3 @@
+yarn test:unit:affected
+yarn dep:check
+yarn audit:check

.ncurc.yaml

@@ -9,8 +9,6 @@ reject: [
   'npm-check-updates',
   ## TODO: The new version of nx causes submodules to be broken.
   "nx",
-  ## TODO: The new version of eslint requires migration of configuration files.
-  "eslint",
-  "@typescript-eslint/eslint-plugin",
-  "@typescript-eslint/parser"
+  ## esLint 9.15.0 caused the error: TypeError: Error while loading rule '@typescript-eslint/no-unused-expressions': Cannot read properties of undefined (reading 'allowShortCircuit')
+  "eslint"
 ]

Dockerfile

@@ -11,7 +11,7 @@ ARG NODE_VERSION=lts-alpine
 #
 
 # Build Image
-FROM node:${NODE_VERSION} as builder
+FROM node:${NODE_VERSION} AS builder
 
 ## Install tool dependencies
 RUN apk add --no-cache -t build-dependencies make gcc g++ python3 libtool openssl-dev autoconf automake yarn bash

LICENSE.md

@@ -1,10 +1,9 @@
 # LICENSE
 
-Copyright © 2017 Bill & Melinda Gates Foundation
+Copyright © 2020-2024 Mojaloop Foundation
 
-The Mojaloop files are made available by the Bill & Melinda Gates Foundation under the Apache License, Version 2.0
-(the "License") and you may not use these files except in compliance with the [License](http://www.apache.org/licenses/LICENSE-2.0). You may obtain a copy of the License at
+The Mojaloop files are made available by the Mojaloop Foundation under the Apache License, Version 2.0 (the "License") and you may not use these files except in compliance with the License.
 
-[http://www.apache.org/licenses/LICENSE-2.0](http://www.apache.org/licenses/LICENSE-2.0)
+You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
 
-Unless required by applicable law or agreed to in writing, the Mojaloop files are distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the [License](http://www.apache.org/licenses/LICENSE-2.0).
+Unless required by applicable law or agreed to in writing, the Mojaloop files are distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

audit-ci.jsonc

@@ -34,9 +34,23 @@
         "GHSA-78xj-cgh5-2h22",
         // https://github.com/advisories/GHSA-rm97-x556-q36h
         "GHSA-rm97-x556-q36h",
-        "GHSA-wf5p-g6vw-rhxx", // https://github.com/advisories/GHSA-wf5p-g6vw-rhxx
-        "GHSA-2p57-rm9w-gvfp", // https://github.com/advisories/GHSA-2p57-rm9w-gvfp
-        "GHSA-8hc4-vh64-cxmj", // https://github.com/advisories/GHSA-8hc4-vh64-cxmj
-        "GHSA-952p-6rrq-rcjv"  // https://github.com/advisories/GHSA-952p-6rrq-rcjv
+        "GHSA-wf5p-g6vw-rhxx", // https://github.com/advisories/GHSA-wf5p-g6vw-rhxx,
+        "GHSA-2p57-rm9w-gvfp",
+        "GHSA-8hc4-vh64-cxmj",
+        "GHSA-952p-6rrq-rcjv",
+        "GHSA-9wv6-86v2-598j",
+        "GHSA-cgfm-xwp7-2cvr",
+        "GHSA-cm22-4g7w-348p",
+        "GHSA-ghr5-ch3p-vcr6",
+        "GHSA-grv7-fg5c-xmjg",
+        "GHSA-m6fv-jmcg-4jfg",
+        "GHSA-m95q-7qp3-xv42",
+        "GHSA-qw6h-vgh9-j6wx",
+        "GHSA-qwcr-r2fm-qrc7",
+        "GHSA-rv95-896h-c2vc",
+        "GHSA-3xgq-45jj-v275", // https://github.com/advisories/GHSA-3xgq-45jj-v275
+        "GHSA-7q7g-4xm8-89cq", // https://github.com/advisories/GHSA-7q7g-4xm8-89cq
+        "GHSA-mwcw-c2x4-8c55",
+        "GHSA-rhx6-c78j-4q9w"
     ]
 }

docker-compose.pm4ml.yml

@@ -5,7 +5,10 @@ services:
   sdk-scheme-adapter-api-svc:
     env_file: ./modules/api-svc/test/config/integration-pm4ml.env
     depends_on:
-      - mock-management-svc
+      mock-management-svc:
+        condition: service_healthy
+      init-kafka:
+        condition: service_completed_successfully
     command: yarn nx run modules-api-svc:start
 
   mock-management-svc:

modules/api-svc/.env.example

@@ -164,7 +164,7 @@ ALLOW_TRANSFER_WITHOUT_QUOTE=false
 RESERVE_NOTIFICATION=true
 
 # resources API versions should be string in format: "resourceOneName=1.0,resourceTwoName=1.1"
-RESOURCE_VERSIONS="transfers=1.1,participants=1.1"
+#RESOURCE_VERSIONS="transfers=1.1,participants=1.1"
 
 # Management API websocket connection settings.
 # The Management API uses this for exchanging connector management messages.

modules/api-svc/eslint.config.mjs

@@ -0,0 +1,41 @@
+import jest from "eslint-plugin-jest";
+import globals from "globals";
+import path from "node:path";
+import { fileURLToPath } from "node:url";
+import js from "@eslint/js";
+import { FlatCompat } from "@eslint/eslintrc";
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+const compat = new FlatCompat({
+    baseDirectory: __dirname,
+    recommendedConfig: js.configs.recommended,
+    allConfig: js.configs.all
+});
+
+export default [...compat.extends("eslint:recommended"), {
+    plugins: {
+        jest,
+    },
+
+    languageOptions: {
+        ecmaVersion: 'latest',
+        globals: {
+            ...globals.node,
+            ...globals.jest,
+            structuredClone: 'readonly',
+        },
+    },
+
+    rules: {
+        indent: ["error", 4, {
+            SwitchCase: 1,
+        }],
+
+        "linebreak-style": [2, "unix"],
+        quotes: [2, "single"],
+        semi: [2, "always"],
+        "no-console": 2,
+        "no-prototype-builtins": "off",
+    },
+}];

modules/api-svc/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/sdk-scheme-adapter-api-svc",
-  "version": "20.8.0-snapshot.18",
+  "version": "20.8.0-snapshot.41",
   "description": "An adapter for connecting to Mojaloop API enabled switches.",
   "main": "src/index.js",
   "types": "src/index.d.ts",
@@ -26,7 +26,8 @@
     "lint": "eslint ./src/",
     "lint:fix": "eslint ./src/ --fix",
     "test": "yarn run test:unit",
-    "test:unit": "jest --runInBand --ci --reporters=default --reporters=jest-junit --env=node test/unit/",
+    "test:unit": "jest --runInBand --ci --reporters=default --reporters=jest-junit --env=node test/unit/ --setupFilesAfterEnv=./test/unit/setup.js",
+    "test:xunit": "JEST_JUNIT_OUTPUT_DIR=../test/reports/ JEST_JUNIT_OUTPUT_NAME=xunit-api-svc.xml yarn run test:unit -- --reporters=jest-junit",
     "test:integration": "jest --ci --reporters=default --reporters=jest-junit --env=node test/integration/",
     "test:integration-pm4ml": "jest --ci --reporters=default --reporters=jest-junit --env=node test/integration-pm4ml/",
     "test:pm4ml-run-mock-servers": "node test/integration-pm4ml/mockServers/index.js",
@@ -63,20 +64,23 @@
   },
   "dependencies": {
     "@koa/cors": "^5.0.0",
-    "@mojaloop/api-snippets": "17.7.2",
-    "@mojaloop/central-services-error-handling": "^13.0.2",
-    "@mojaloop/central-services-logger": "^11.5.1",
-    "@mojaloop/central-services-metrics": "^12.0.8",
-    "@mojaloop/central-services-shared": "18.11.0",
-    "@mojaloop/event-sdk": "^14.1.1",
+    "@mojaloop/api-snippets": "17.7.8",
+    "@mojaloop/central-services-error-handling": "^13.0.3",
+    "@mojaloop/central-services-logger": "^11.5.2",
+    "@mojaloop/central-services-metrics": "^12.4.3",
+    "@mojaloop/central-services-shared": "^18.15.2",
+    "@mojaloop/event-sdk": "^14.1.2",
+    "@mojaloop/logging-bc-client-lib": "0.5.8",
+    "@mojaloop/ml-schema-transformer-lib": "^2.5.1",
     "@mojaloop/sdk-scheme-adapter-private-shared-lib": "workspace:^",
-    "@mojaloop/sdk-standard-components": "19.2.0",
+    "@mojaloop/sdk-standard-components": "^19.6.3",
     "ajv": "8.17.1",
-    "axios": "^1.7.7",
+    "axios": "^1.7.9",
+    "body-parser": "^1.20.3",
     "co-body": "^6.2.0",
-    "dotenv": "^16.4.5",
+    "dotenv": "^16.4.7",
     "env-var": "^7.5.0",
-    "express": "^4.21.1",
+    "express": "^4.21.2",
     "fast-json-patch": "^3.1.1",
     "fast-safe-stringify": "^2.1.1",
     "javascript-state-machine": "^3.1.0",
@@ -92,24 +96,25 @@
     "promise-timeout": "^1.3.0",
     "random-word-slugs": "^0.1.7",
     "redis": "^4.7.0",
+    "uuidv4": "^6.2.13",
     "ws": "^8.18.0"
   },
   "devDependencies": {
     "@babel/core": "^7.26.0",
     "@babel/preset-env": "^7.26.0",
-    "@redocly/openapi-cli": "^1.0.0-beta.94",
+    "@redocly/openapi-cli": "^1.0.0-beta.95",
     "@types/jest": "^29.5.14",
+    "axios-mock-adapter": "^2.1.0",
     "babel-jest": "^29.7.0",
-    "eslint": "^8.57.0",
+    "eslint": "^9.15.0",
     "eslint-config-airbnb-base": "^15.0.0",
     "eslint-plugin-import": "^2.31.0",
-    "eslint-plugin-jest": "^28.8.3",
+    "eslint-plugin-jest": "^28.11.0",
     "jest": "^29.7.0",
     "jest-junit": "^16.0.0",
-    "nock": "^13.5.5",
     "npm-check-updates": "^16.7.10",
     "openapi-response-validator": "^12.1.3",
-    "openapi-typescript": "^7.4.2",
+    "openapi-typescript": "^7.5.2",
     "redis-mock": "^0.56.3",
     "replace": "^1.2.2",
     "standard-version": "^9.5.0",

modules/api-svc/src/ControlAgent/index.js

@@ -191,7 +191,7 @@ class Client extends ws {
         let msg;
         try {
             msg = deserialise(data);
-        } catch (err) {
+        } catch {
             this._logger.isErrorEnabled && this._logger.push({ data }).console.error();('Couldn\'t parse received message');
             this.send(build.ERROR.NOTIFY.JSON_PARSE_ERROR());
         }

modules/api-svc/src/InboundServer/api.yaml

@@ -58,6 +58,55 @@ paths:
       responses:
         '200':
           description: Ok
+  /participants/{ID}/error:
+    put:
+      description: >-
+        If there is an error during FSP information creation in the server, the
+        error callback `PUT /participants/{ID}/error` is used. The `{ID}` in the
+        URI should contain the requestId that was used for the creation of the
+        participant information.
+      summary: Return bulk participant information error
+      tags:
+        - participants
+      operationId: ParticipantsByIDAndError
+      parameters:
+        - $ref: '#/components/parameters/ID'
+        - $ref: '#/components/parameters/Content-Length'
+        - $ref: '#/components/parameters/Content-Type'
+        - $ref: '#/components/parameters/Date'
+        - $ref: '#/components/parameters/X-Forwarded-For'
+        - $ref: '#/components/parameters/FSPIOP-Source'
+        - $ref: '#/components/parameters/FSPIOP-Destination'
+        - $ref: '#/components/parameters/FSPIOP-Encryption'
+        - $ref: '#/components/parameters/FSPIOP-Signature'
+        - $ref: '#/components/parameters/FSPIOP-URI'
+        - $ref: '#/components/parameters/FSPIOP-HTTP-Method'
+      requestBody:
+        description: Details of the error returned.
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/ErrorInformationObject'
+      responses:
+        '200':
+          $ref: '#/components/responses/200'
+        '400':
+          $ref: '#/components/responses/400'
+        '401':
+          $ref: '#/components/responses/401'
+        '403':
+          $ref: '#/components/responses/403'
+        '404':
+          $ref: '#/components/responses/404'
+        '405':
+          $ref: '#/components/responses/405'
+        '406':
+          $ref: '#/components/responses/406'
+        '501':
+          $ref: '#/components/responses/501'
+        '503':
+          $ref: '#/components/responses/503'
   /participants/{Type}/{ID}:
     parameters:
       - $ref: '#/components/parameters/Type'
@@ -595,55 +644,6 @@ paths:
           $ref: '#/components/responses/501'
         '503':
           $ref: '#/components/responses/503'
-  /participants/{ID}/error:
-    put:
-      description: >-
-        If there is an error during FSP information creation in the server, the
-        error callback `PUT /participants/{ID}/error` is used. The `{ID}` in the
-        URI should contain the requestId that was used for the creation of the
-        participant information.
-      summary: Return bulk participant information error
-      tags:
-        - participants
-      operationId: ParticipantsByIDAndError
-      parameters:
-        - $ref: '#/components/parameters/ID'
-        - $ref: '#/components/parameters/Content-Length'
-        - $ref: '#/components/parameters/Content-Type'
-        - $ref: '#/components/parameters/Date'
-        - $ref: '#/components/parameters/X-Forwarded-For'
-        - $ref: '#/components/parameters/FSPIOP-Source'
-        - $ref: '#/components/parameters/FSPIOP-Destination'
-        - $ref: '#/components/parameters/FSPIOP-Encryption'
-        - $ref: '#/components/parameters/FSPIOP-Signature'
-        - $ref: '#/components/parameters/FSPIOP-URI'
-        - $ref: '#/components/parameters/FSPIOP-HTTP-Method'
-      requestBody:
-        description: Details of the error returned.
-        required: true
-        content:
-          application/json:
-            schema:
-              $ref: '#/components/schemas/ErrorInformationObject'
-      responses:
-        '200':
-          $ref: '#/components/responses/200'
-        '400':
-          $ref: '#/components/responses/400'
-        '401':
-          $ref: '#/components/responses/401'
-        '403':
-          $ref: '#/components/responses/403'
-        '404':
-          $ref: '#/components/responses/404'
-        '405':
-          $ref: '#/components/responses/405'
-        '406':
-          $ref: '#/components/responses/406'
-        '501':
-          $ref: '#/components/responses/501'
-        '503':
-          $ref: '#/components/responses/503'
   /parties/{Type}/{ID}:
     parameters:
       - $ref: '#/components/parameters/Type'