fix(mojaloop/2941): handled party lookup timeout error (#386)

fix: handled-party-lookup-timeout-error
mojaloop · Sep 22, 2022 · 3ee88b1 · 3ee88b1
1 parent 747f0fe
commit 3ee88b1
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/modules/api-svc/src/FSPIOPEventHandler/handlers/party-info-requested.js b/modules/api-svc/src/FSPIOPEventHandler/handlers/party-info-requested.js
@@ -24,7 +24,9 @@
 
 const { PartyInfoRequestedDmEvt } = require('@mojaloop/sdk-scheme-adapter-private-shared-lib');
 const { PartiesModel } = require('../../lib/model');
+const { SDKStateEnum } = require('../../lib/model/common');
 const { PartyInfoCallbackReceivedDmEvt } = require('@mojaloop/sdk-scheme-adapter-private-shared-lib');
+const { Errors } = require('@mojaloop/sdk-standard-components');
 
 module.exports.handlePartyInfoRequestedDmEvt = async (
     message,
@@ -70,5 +72,22 @@ module.exports.handlePartyInfoRequestedDmEvt = async (
         await options.producer.sendDomainEvent(partyInfoCallbackReceivedDmEvt);
     } catch (err) {
         logger.push({ err }).log('Error in handlePartyInfoRequestedDmEvt');
+        const { code, message } = Errors.MojaloopApiErrorCodes.SERVER_TIMED_OUT
+        const partyInfoCallbackReceivedDmEvt = new PartyInfoCallbackReceivedDmEvt({
+            bulkId: event.getKey(),
+            content: {
+                transferId: event.getTransferId(),
+                partyResult: {
+                    currentState: SDKStateEnum.ERROR_OCCURRED,
+                    errorInformation: {
+                        errorCode: code,
+                        errorDescription: message
+                    }
+                },
+            },
+            timestamp: Date.now(),
+            headers: [],
+        });
+        await options.producer.sendDomainEvent(partyInfoCallbackReceivedDmEvt);
     }
 };