Feat: Create liquidation address when updating account if currency ch…

…anged
JoinColony · Aug 1, 2024 · 722b1bd · 722b1bd
1 parent 1c1dd10
commit 722b1bd
Show file tree

Hide file tree

Showing 3 changed files with 36 additions and 8 deletions.
diff --git a/amplify/backend/function/bridgeXYZMutation/src/handlers/checkKyc.js b/amplify/backend/function/bridgeXYZMutation/src/handlers/checkKyc.js
@@ -122,7 +122,7 @@ const checkKYCHandler = async (
     if (!firstAccount) {
       return {
         kycStatus,
-        kyc_link: kycLink,
+        kycLink,
         bankAccount: null,
       };
     }
@@ -193,7 +193,7 @@ const checkKYCHandler = async (
 
     return {
       kycStatus,
-      kyc_link: kycLink,
+      kycLink,
       bankAccount: mappedAccount,
       liquidationAddress: externalAccountLiquidationAddress,
     };

diff --git a/amplify/backend/function/bridgeXYZMutation/src/handlers/updateExternalAccount.js b/amplify/backend/function/bridgeXYZMutation/src/handlers/updateExternalAccount.js
@@ -43,8 +43,9 @@ const updateExternalAccountHandler = async (
   );
 
   if (deleteAccountRes.status !== 200) {
-    console.error(await deleteAccountRes.json());
-    throw Error('Error deleting external account');
+    throw Error(
+      `Error deleting external account: ${await deleteAccountRes.text()}`,
+    );
   }
 
   const newAccount = await createExternalAccount(
@@ -85,8 +86,35 @@ const updateExternalAccountHandler = async (
     );
 
     if (updateAddressRes.status !== 200) {
-      console.error(await updateAddressRes.json());
-      throw Error('Error updating liquidation address');
+      throw Error(
+        `Error updating liquidation address: ${await updateAddressRes.text()}`,
+      );
+    }
+  } else {
+    const createAddressRes = await fetch(
+      `${apiUrl}/v0/customers/${bridgeCustomerId}/liquidation_addresses`,
+      {
+        headers: {
+          'Content-Type': 'application/json',
+          'Idempotency-Key': newAccount.id,
+          'Api-Key': apiKey,
+        },
+        method: 'POST',
+        body: JSON.stringify({
+          chain: 'arbitrum',
+          currency: 'usdc',
+          external_account_id: newAccount.id,
+          destination_payment_rail:
+            newAccount.currency === 'usd' ? 'ach' : 'sepa',
+          destination_currency: newAccount.currency,
+        }),
+      },
+    );
+
+    if (createAddressRes.status !== 201) {
+      throw Error(
+        `Error creating liquidation address: ${await createAddressRes.text()}`,
+      );
     }
   }
 

diff --git a/amplify/backend/function/bridgeXYZMutation/src/index.js b/amplify/backend/function/bridgeXYZMutation/src/index.js
@@ -12,8 +12,8 @@ const isDev = process.env.ENV === 'dev';
 
 let graphqlURL = 'http://localhost:20002/graphql';
 let appSyncApiKey = 'da2-fakeApiId123456';
-let apiUrl = 'https://api.bridge.xyz';
-let apiKey = 'sk-live-47c8b97f6d9f7e4d1c13e6a541d49b98';
+let apiUrl = 'https://api.sandbox.bridge.xyz';
+let apiKey = 'xx';
 
 const setEnvVariables = async () => {
   if (!isDev) {