Merge pull request #3432 from JoinColony/feat/liquidation-address-overrides

Feat: Allow overriding user's liquidation address

Author: jakubcolony

amplify/backend/function/bridgeXYZMutation/src/handlers/getUserLiquidationAddress.js

@@ -1,15 +1,29 @@
-const fetch = require('cross-fetch');
 const { graphqlRequest } = require('../utils');
 const { getLiquidationAddresses, getExternalAccounts } = require('./utils');
 
 const { getUser } = require('../graphql');
 
 const getUserLiquidationAddressHandler = async (
   event,
-  { appSyncApiKey, apiKey, apiUrl, graphqlURL },
+  {
+    appSyncApiKey,
+    apiKey,
+    apiUrl,
+    graphqlURL,
+    temp_liquidationAddressOverrides,
+  },
 ) => {
   const userAddress = event.arguments.userAddress;
 
+  try {
+    const overrides = JSON.parse(temp_liquidationAddressOverrides);
+    if (overrides[userAddress]) {
+      return overrides[userAddress];
+    }
+  } catch (e) {
+    console.log('Error parsing liquidation address overrides: ', e);
+  }
+
   const { data: graphQlData } = await graphqlRequest(
     getUser,
     {
@@ -25,7 +39,11 @@ const getUserLiquidationAddressHandler = async (
     return null;
   }
 
-  const externalAccounts = await getExternalAccounts(apiUrl, apiKey, bridgeCustomerId);
+  const externalAccounts = await getExternalAccounts(
+    apiUrl,
+    apiKey,
+    bridgeCustomerId,
+  );
   const firstAccount = externalAccounts?.[0];
 
   if (!firstAccount) {

amplify/backend/function/bridgeXYZMutation/src/index.js

@@ -18,15 +18,24 @@ let graphqlURL = 'http://localhost:20002/graphql';
 let appSyncApiKey = 'da2-fakeApiId123456';
 let apiUrl = process.env.BRIDGE_API_URL;
 let apiKey = process.env.BRIDGE_API_KEY;
+let temp_liquidationAddressOverrides =
+  process.env.LIQUIDATION_ADDRESS_OVERRIDES;
 
 const setEnvVariables = async () => {
   if (!isDev) {
     const { getParams } = require('/opt/nodejs/getParams');
-    [appSyncApiKey, apiKey, apiUrl, graphqlURL] = await getParams([
+    [
+      appSyncApiKey,
+      apiKey,
+      apiUrl,
+      graphqlURL,
+      temp_liquidationAddressOverrides,
+    ] = await getParams([
       'appsyncApiKey',
       'bridgeXYZApiKey',
       'bridgeXYZApiUrl',
       'graphqlUrl',
+      'liquidationAddressOverrides',
     ]);
   }
 };
@@ -68,7 +77,13 @@ exports.handler = async (event) => {
     handlers[path] || handlers[event.fieldName] || handlers.default;
 
   try {
-    return await handler(event, { appSyncApiKey, apiKey, apiUrl, graphqlURL });
+    return await handler(event, {
+      appSyncApiKey,
+      apiKey,
+      apiUrl,
+      graphqlURL,
+      temp_liquidationAddressOverrides,
+    });
   } catch (error) {
     console.error(
       `bridgeXYZMutation handler ${handler.name} failed with error: ${error}`,

amplify/backend/function/colonycdappSSMAccess/lib/nodejs/getParams.js

@@ -16,6 +16,7 @@ const ParamNames = {
   etherscanApiKey: `%2Famplify%2Fcdapp%2F${ENV}%2FETHERSCAN_API_KEY`,
   bridgeXYZApiKey: `%2Famplify%2Fcdapp%2F${ENV}%2FBRIDGEXYZ_API_KEY`,
   bridgeXYZApiUrl: `%2Famplify%2Fcdapp%2F${ENV}%2FBRIDGEXYZ_API_URL`,
+  liquidationAddressOverrides: `%2Famplify%2Fcdapp%2F${ENV}%2FLIQUIDATION_ADDRESS_OVERRIDES`,
 };
 
 const getParam = async (paramName) => {