feat: add inbound metrics for quotes and transfers (combined)

Author: devarsh10

.yarn/releases/yarn-4.9.2.cjs

@@ -4,4 +4,4 @@ enableGlobalCache: false
 
 nodeLinker: node-modules
 
-yarnPath: .yarn/releases/yarn-4.9.4.cjs
+yarnPath: .yarn/releases/yarn-4.9.2.cjs

.yarnrc.yml

@@ -1,16 +1,4 @@
 # Changelog: [mojaloop/sdk-scheme-adapter](https://github.com/mojaloop/sdk-scheme-adapter)
-### [24.10.10](https://github.com/mojaloop/sdk-scheme-adapter/compare/v24.10.9...v24.10.10) (2025-08-27)
-
-
-### Bug Fixes
-
-* **csi-1708:** updated deps ([#607](https://github.com/mojaloop/sdk-scheme-adapter/issues/607)) ([42f7baf](https://github.com/mojaloop/sdk-scheme-adapter/commit/42f7baf2e828e4eea2eb4edc41cd847d4e15651c))
-
-
-### Chore
-
-* **sbom:** update sbom [skip ci] ([c05eac1](https://github.com/mojaloop/sdk-scheme-adapter/commit/c05eac19196b19b1b3ff3c6cafc0744207e4b43d))
-
 ### [24.10.9](https://github.com/mojaloop/sdk-scheme-adapter/compare/v24.10.8...v24.10.9) (2025-08-18)
 
 

CHANGELOG.md

@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/sdk-scheme-adapter-api-svc",
-  "version": "21.0.0-snapshot.57",
+  "version": "21.0.0-snapshot.56",
   "description": "An adapter for connecting to Mojaloop API enabled switches.",
   "main": "src/index.js",
   "types": "src/index.d.ts",
@@ -68,7 +68,7 @@
     "@mojaloop/central-services-error-handling": "13.1.0",
     "@mojaloop/central-services-logger": "11.9.1",
     "@mojaloop/central-services-metrics": "12.6.0",
-    "@mojaloop/central-services-shared": "18.30.7",
+    "@mojaloop/central-services-shared": "18.30.8",
     "@mojaloop/event-sdk": "14.6.1",
     "@mojaloop/logging-bc-client-lib": "0.5.8",
     "@mojaloop/ml-schema-transformer-lib": "2.7.7",
@@ -78,7 +78,7 @@
     "axios": "1.11.0",
     "body-parser": "2.2.0",
     "co-body": "6.2.0",
-    "dotenv": "17.2.1",
+    "dotenv": "17.2.2",
     "env-var": "7.5.0",
     "express": "4.21.2",
     "fast-json-patch": "3.1.1",
@@ -106,7 +106,7 @@
     "@redocly/openapi-cli": "1.0.0-beta.95",
     "@types/jest": "30.0.0",
     "axios-mock-adapter": "2.1.0",
-    "babel-jest": "30.1.1",
+    "babel-jest": "30.1.2",
     "eslint": "9.15.0",
     "eslint-config-airbnb-base": "15.0.0",
     "eslint-plugin-import": "2.32.0",

modules/api-svc/package.json

@@ -52,7 +52,7 @@ class InboundApi extends EventEmitter {
         super({ captureExceptions: true });
         this._conf = conf;
         this._cache = cache;
-        this._metricsClient = metricsClient;
+        this._logger = logger;
         _initialize ||= _validator.initialise(apiSpecs, conf);
 
         if (conf.validateInboundJws) {

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

@@ -259,12 +259,17 @@ class InboundTransfersModel {
                 }
             }
 
+            this.metrics.quoteRequests.inc();
+            const endTimer = this.metrics.quoteRequestLatency.startTimer();
+            this._quoteTimers.set(quoteRequest.quoteId, endTimer);
+
             // make a call to the backend to ask for a quote response
             const response = await this._backendRequests.postQuoteRequests(internalForm);
 
             if(!response) {
                 // make an error callback to the source fsp
-                return 'No response from backend';            }
+                return 'No response from backend';            
+            }
 
             if(!response.expiration) {
                 const expiration = new Date().getTime() + (this._expirySeconds * 1000);
@@ -293,6 +298,11 @@ class InboundTransfersModel {
             if (headers.tracestate && headers.traceparent) {
                 headers.tracestate += `,${TRACESTATE_KEY_CALLBACK_START_TS}=${Date.now()}`;
             }
+
+            this.metrics.quoteResponses.inc();
+            const end = this._quoteTimers.get(quoteRequest.quoteId);
+            if (end) { end(); this._quoteTimers.delete(quoteRequest.quoteId); }
+
             const res = await this._mojaloopRequests.putQuotes(quoteRequest.quoteId, mojaloopResponse, sourceFspId, headers, { isoPostQuote: request.isoPostQuote });
 
             this.data.quoteResponse = {
@@ -310,6 +320,11 @@ class InboundTransfersModel {
             const mojaloopError = await this._handleError(err);
             log.isInfoEnabled && log.push({ mojaloopError }).info(`Sending error response to ${sourceFspId}`);
             this.metrics.quoteGetResponseErrors.inc();
+
+            this.metrics.quoteResponses.inc();
+            const end = this._quoteTimers.get(quoteRequest.quoteId);
+            if (end) { end(); this._quoteTimers.delete(quoteRequest.quoteId); }
+
             return this._mojaloopRequests.putQuotesError(quoteRequest.quoteId, mojaloopError, sourceFspId, headers);
         }
     }
@@ -596,6 +611,12 @@ class InboundTransfersModel {
             this._logger.isErrorEnabled && this._logger.push({ err, transferId }).error('Error in getTransfers');
             const mojaloopError = await this._handleError(err);
             this._logger.isInfoEnabled && this._logger.push({ mojaloopError }).info(`Sending error response to ${sourceFspId}`);
+
+            const end = this._transferTimers.get(transferId);
+            if (end) {
+                end(); // still stop latency timer, even for errors
+                this._transferTimers.delete(transferId);
+            }
             return this._mojaloopRequests.putTransfersError(transferId, mojaloopError, sourceFspId, headers);
         }
     }

modules/api-svc/src/lib/model/InboundTransfersModel.js

@@ -1473,7 +1473,7 @@ class OutboundTransfersModel {
             log.isVerboseEnabled && log.verbose(`Transfer model state machine transition completed in state: ${this.stateMachine.state}. Recursing to handle next transition.`);
             return this.run();
         } catch (err) {
-            log.error('error running outbound transfer model: ', err);
+            log.isErrorEnabled && log.push({ err }).error(`error running outbound transfer model: ${err?.message}`);
 
             // as this function is recursive, we dont want to error the state machine multiple times
             if (this.data.currentState !== States.ERRORED) {

modules/api-svc/src/lib/model/OutboundTransfersModel.js

@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/sdk-scheme-adapter-outbound-command-event-handler",
-  "version": "0.3.0-snapshot.53",
+  "version": "0.3.0-snapshot.52",
   "description": "Mojaloop sdk scheme adapter command event handler",
   "license": "Apache-2.0",
   "homepage": "https://github.com/mojaloop/sdk-scheme-adapter/",
@@ -42,7 +42,7 @@
   },
   "dependencies": {
     "@mojaloop/api-snippets": "18.1.1",
-    "@mojaloop/central-services-shared": "18.30.7",
+    "@mojaloop/central-services-shared": "18.30.8",
     "@mojaloop/logging-bc-client-lib": "0.5.8",
     "@mojaloop/logging-bc-public-types-lib": "0.5.6",
     "@mojaloop/sdk-scheme-adapter-private-shared-lib": "workspace:^",
@@ -65,8 +65,8 @@
     "@types/supertest": "6.0.3",
     "@types/swagger-ui-express": "4.1.8",
     "@types/yamljs": "0.2.34",
-    "@typescript-eslint/eslint-plugin": "8.41.0",
-    "@typescript-eslint/parser": "8.41.0",
+    "@typescript-eslint/eslint-plugin": "8.42.0",
+    "@typescript-eslint/parser": "8.42.0",
     "copyfiles": "2.4.1",
     "eslint": "9.15.0",
     "jest": "29.7.0",

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

@@ -1,6 +1,6 @@
 {
     "name": "@mojaloop/sdk-scheme-adapter-outbound-domain-event-handler",
-    "version": "0.3.0-snapshot.53",
+    "version": "0.3.0-snapshot.52",
     "description": "mojaloop sdk scheme adapter outbound domain event handler",
     "license": "Apache-2.0",
     "homepage": "https://github.com/mojaloop/sdk-scheme-adapter/",
@@ -62,8 +62,8 @@
         "@types/supertest": "6.0.3",
         "@types/swagger-ui-express": "4.1.8",
         "@types/yamljs": "0.2.34",
-        "@typescript-eslint/eslint-plugin": "8.41.0",
-        "@typescript-eslint/parser": "8.41.0",
+        "@typescript-eslint/eslint-plugin": "8.42.0",
+        "@typescript-eslint/parser": "8.42.0",
         "copyfiles": "2.4.1",
         "eslint": "9.15.0",
         "jest": "29.7.0",

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

@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/sdk-scheme-adapter-private-shared-lib",
-  "version": "0.4.0-snapshot.53",
+  "version": "0.4.0-snapshot.52",
   "description": "SDK Scheme Adapter private shared library.",
   "license": "Apache-2.0",
   "homepage": "https://github.com/mojaloop/accounts-and-balances-bc/tree/main/modules/private-types",
@@ -30,7 +30,7 @@
   },
   "dependencies": {
     "@mojaloop/api-snippets": "18.1.1",
-    "@mojaloop/central-services-shared": "18.30.7",
+    "@mojaloop/central-services-shared": "18.30.8",
     "@mojaloop/logging-bc-public-types-lib": "0.5.6",
     "@mojaloop/platform-shared-lib-messaging-types-lib": "0.7.3",
     "@mojaloop/platform-shared-lib-nodejs-kafka-client-lib": "0.5.18",
@@ -42,8 +42,8 @@
     "@eslint/compat": "1.3.2",
     "@types/node": "24.3.0",
     "@types/uuid": "10.0.0",
-    "@typescript-eslint/eslint-plugin": "8.41.0",
-    "@typescript-eslint/parser": "8.41.0",
+    "@typescript-eslint/eslint-plugin": "8.42.0",
+    "@typescript-eslint/parser": "8.42.0",
     "eslint": "9.15.0",
     "jest": "29.7.0",
     "npm-check-updates": "16.7.10",