fix: context in position handler (#1116)

* fix: context passing in position handler * chore(snapshot): 17.9.0-snapshot.0 * chore: bump dep * chore(snapshot): 17.9.0-snapshot.1 * chore: dep updates
mojaloop · Oct 23, 2024 · 6947f18 · 6947f18
1 parent 52b49b0
commit 6947f18
Show file tree

Hide file tree

Showing 9 changed files with 48 additions and 110 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@mojaloop/central-ledger",
-  "version": "17.9.0-iso.1",
+  "version": "17.9.0-snapshot.1",
   "description": "Central ledger hosted by a scheme to record and settle transfers",
   "license": "Apache-2.0",
   "author": "ModusBox",
@@ -88,11 +88,11 @@
     "@hapi/inert": "7.1.0",
     "@hapi/joi": "17.1.1",
     "@hapi/vision": "7.0.3",
-    "@mojaloop/central-services-error-handling": "13.0.1",
+    "@mojaloop/central-services-error-handling": "13.0.2",
     "@mojaloop/central-services-health": "15.0.0",
     "@mojaloop/central-services-logger": "11.5.1",
     "@mojaloop/central-services-metrics": "12.0.8",
-    "@mojaloop/central-services-shared": "18.10.0",
+    "@mojaloop/central-services-shared": "18.10.1-snapshot.3",
     "@mojaloop/central-services-stream": "11.3.1",
     "@mojaloop/database-lib": "11.0.6",
     "@mojaloop/event-sdk": "14.1.1",

diff --git a/src/domain/position/abort.js b/src/domain/position/abort.js
@@ -162,7 +162,8 @@ const _constructAbortResultMessage = (binItem, id, from, notifyTo) => {
     binItem.message.value.content.headers, // Headers don't really matter here. ml-api-adapter will ignore them and create their own.
     fspiopError,
     { id },
-    'application/json'
+    'application/json',
+    binItem.message.value.content.context
   )
 
   return resultMessage

diff --git a/src/domain/position/fulfil.js b/src/domain/position/fulfil.js
@@ -168,7 +168,8 @@ const _handleIncorrectTransferState = (binItem, payeeFsp, transferId, accumulate
     headers,
     fspiopError,
     { id: transferId },
-    'application/json'
+    'application/json',
+    binItem.message.value.content.context
   )
 }
 
@@ -197,7 +198,8 @@ const _constructTransferFulfilResultMessage = (binItem, transferId, payerFsp, pa
     headers,
     transfer,
     { id: transferId },
-    'application/json'
+    'application/json',
+    binItem.message.value.content.context
   )
 
   if (binItem.message.value.metadata.event.action === Enum.Events.Event.Action.RESERVE) {
@@ -249,7 +251,8 @@ const _constructPatchNotificationResultMessage = (binItem, cyrilResult) => {
       headers,
       fulfil,
       { id: commitRequestId },
-      'application/json'
+      'application/json',
+      binItem.message.value.content.context
     )
 
     messages.push(resultMessage)

diff --git a/src/domain/position/fx-fulfil.js b/src/domain/position/fx-fulfil.js
@@ -74,7 +74,8 @@ const processPositionFxFulfilBin = async (
           headers,
           fspiopError,
           { id: commitRequestId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
       } else {
         // forward same headers from the prepare message, except the content-length header
@@ -101,7 +102,8 @@ const processPositionFxFulfilBin = async (
           headers,
           fxTransfer,
           { id: commitRequestId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         // No need to change the transfer state here for success case.

diff --git a/src/domain/position/fx-prepare.js b/src/domain/position/fx-prepare.js
@@ -104,7 +104,8 @@ const processFxPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: fxTransfer.commitRequestId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -146,7 +147,8 @@ const processFxPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: fxTransfer.commitRequestId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -188,7 +190,8 @@ const processFxPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: fxTransfer.commitRequestId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -236,7 +239,8 @@ const processFxPositionPrepareBin = async (
           headers,
           fxTransfer,
           {},
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: true }

diff --git a/src/domain/position/fx-timeout-reserved.js b/src/domain/position/fx-timeout-reserved.js
@@ -124,7 +124,8 @@ const _constructFxTimeoutReservedResultMessage = (binItem, commitRequestId, coun
     binItem.message.value.content.headers, // Headers don't really matter here. ml-api-adapter will ignore them and create their own.
     fspiopError,
     { id: commitRequestId },
-    'application/json'
+    'application/json',
+    binItem.message.value.content.context
   )
 
   return resultMessage

diff --git a/src/domain/position/prepare.js b/src/domain/position/prepare.js
@@ -105,7 +105,8 @@ const processPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: transfer.transferId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -147,7 +148,8 @@ const processPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: transfer.transferId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -189,7 +191,8 @@ const processPositionPrepareBin = async (
           headers,
           fspiopError,
           { id: transfer.transferId },
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: false }
@@ -238,7 +241,8 @@ const processPositionPrepareBin = async (
           headers,
           transfer,
           {},
-          'application/json'
+          'application/json',
+          binItem.message.value.content.context
         )
 
         binItem.result = { success: true }

diff --git a/src/domain/position/timeout-reserved.js b/src/domain/position/timeout-reserved.js
@@ -124,7 +124,8 @@ const _constructTimeoutReservedResultMessage = (binItem, transferId, payeeFsp, p
     binItem.message.value.content.headers, // Headers don't really matter here. ml-api-adapter will ignore them and create their own.
     fspiopError,
     { id: transferId },
-    'application/json'
+    'application/json',
+    binItem.message.value.content.context
   )
 
   return resultMessage