Merge pull request #358 from pendulum-chain/polygon-prototype-staging

Create new production release
pendulum-chain · Jan 9, 2025 · bd0010d · bd0010d
2 parents 8aa829d + 6fc62c7
commit bd0010d
Show file tree

Hide file tree

Showing 100 changed files with 2,381 additions and 1,221 deletions.
diff --git a/.prettierignore b/.prettierignore
@@ -9,6 +9,7 @@ docs/
 .lighthouseci/
 **/coins/*
 *.yml
+*.sol
 
 package-lock.json
 package.json

diff --git a/_redirects b/_redirects
@@ -1,3 +1,3 @@
 /api/production/*  https://prototype-signer-service-polygon.pendulumchain.tech/:splat  200
 /api/staging/*  https://prototype-signer-service-polygon-staging.pendulumchain.tech/:splat  200
-/* /index.html 200
+/* /index.html 200
diff --git a/index.html b/index.html
@@ -1,12 +1,13 @@
 <!DOCTYPE html>
-<html lang="en">
+<html lang="en" class="notranslate" translate="no">
   <head>
     <meta charset="UTF-8" />
     <link rel="icon" type="image/png" href="/favicon.png" />
     <meta name="viewport" content="width=device-width, initial-scale=1.0" />
     <title>Vortex</title>
     <link rel="preconnect" href="https://fonts.googleapis.com" />
     <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <meta name="google" content="notranslate" />
 
     <!-- Google Tag Manager -->
     <script>
@@ -35,14 +36,14 @@
 
   <body style="background-color: #fff">
     <!-- Google Tag Manager (noscript) -->
-    <noscript
-      ><iframe
+    <noscript>
+      <iframe
         src="https://www.googletagmanager.com/ns.html?id=GTM-T8JZSLD8"
         height="0"
         width="0"
         style="display: none; visibility: hidden"
-      ></iframe
-    ></noscript>
+      ></iframe>
+    </noscript>
     <!-- End Google Tag Manager (noscript) -->
 
     <div id="app"></div>

diff --git a/package.json b/package.json
@@ -38,7 +38,9 @@
     "@reown/appkit-adapter-wagmi": "^1.3.1",
     "@sentry/react": "^8.36.0",
     "@sentry/vite-plugin": "^2.22.6",
+    "@slack/web-api": "^7.7.0",
     "@talismn/connect-components": "^1.1.9",
+    "@talismn/connect-wallets": "^1.2.5",
     "@tanstack/react-query": "^5.61.0",
     "@walletconnect/modal": "^2.6.2",
     "@walletconnect/universal-provider": "^2.12.2",
@@ -63,7 +65,8 @@
     "viem": "^2.21.43",
     "wagmi": "^2.12.29",
     "web3": "^4.10.0",
-    "yup": "^1.4.0"
+    "yup": "^1.4.0",
+    "zustand": "^5.0.2"
   },
   "devDependencies": {
     "@babel/core": "^7.20.12",

diff --git a/signer-service/README.md b/signer-service/README.md
@@ -25,6 +25,7 @@ The following environment variables are available to configure the service.
 - `FUNDING_SECRET`: Secret key to sign the funding transactions on Stellar.
 - `PENDULUM_FUNDING_SEED`: Seed phrase to sign the funding transactions on Pendulum.
 - `MOONBEAM_EXECUTOR_PRIVATE_KEY`: Private key to sign the transactions on Moonbeam.
+- `SLACK_WEB_HOOK_TOKEN` - Slack web hook token for error reporting.
 
 ### Optional
 

diff --git a/signer-service/src/api/controllers/moonbeam.controller.js b/signer-service/src/api/controllers/moonbeam.controller.js
@@ -8,6 +8,7 @@ const {
   MOONBEAM_RECEIVER_CONTRACT_ADDRESS,
   MOONBEAM_FUNDING_AMOUNT_UNITS,
 } = require('../../constants/constants');
+const { SlackNotifier } = require('../services/slack.service');
 const splitReceiverABI = require('../../../../mooncontracts/splitReceiverABI.json');
 
 exports.executeXcmController = async (req, res) => {
@@ -54,6 +55,7 @@ exports.executeXcmController = async (req, res) => {
 };
 
 exports.sendStatusWithPk = async () => {
+  const slackService = new SlackNotifier();
   let moonbeamExecutorAccount;
 
   try {
@@ -66,12 +68,16 @@ exports.sendStatusWithPk = async () => {
     const balance = await publicClient.getBalance({ address: moonbeamExecutorAccount.address });
 
     // We are checking if the balance is less than 10 GLMR
-    const minimum_balance = Big(MOONBEAM_FUNDING_AMOUNT_UNITS).times(Big(10).pow(18));
-    if (balance < minimum_balance) {
+    const minimumBalance = Big(MOONBEAM_FUNDING_AMOUNT_UNITS).times(Big(10).pow(18));
+
+    if (balance < minimumBalance) {
+      slackService.sendMessage({
+        text: `Current balance of funding account is ${balance} GLMR please charge the account ${moonbeamExecutorAccount.address}.`,
+      });
       return { status: false, public: moonbeamExecutorAccount.address };
-    } else {
-      return { status: true, public: moonbeamExecutorAccount.address };
     }
+
+    return { status: true, public: moonbeamExecutorAccount.address };
   } catch (error) {
     console.error('Error fetching Moonbeam executor balance:', error);
     return { status: false, public: moonbeamExecutorAccount?.address };

diff --git a/signer-service/src/api/routes/v1/index.js b/signer-service/src/api/routes/v1/index.js
@@ -15,7 +15,7 @@ const { sendStatusWithPk: sendStellarStatusWithPk } = require('../../services/st
 const { sendStatusWithPk: sendPendulumStatusWithPk } = require('../../services/pendulum.service');
 const { sendStatusWithPk: sendMoonbeamStatusWithPk } = require('../../controllers/moonbeam.controller');
 
-async function sendStatusWithPk(req, res, next) {
+async function sendStatusWithPk(_, res) {
   const stellar = await sendStellarStatusWithPk();
   const pendulum = await sendPendulumStatusWithPk();
   const moonbeam = await sendMoonbeamStatusWithPk();

diff --git a/signer-service/src/api/services/alchemypay.service.js b/signer-service/src/api/services/alchemypay.service.js
@@ -190,6 +190,14 @@ function getAlchemyPayNetworkCode(network) {
   switch (network.toUpperCase()) {
     case 'POLYGON':
       return 'MATIC';
+    case 'BSC':
+      return 'BSC';
+    case 'ARBITRUM':
+      return 'ARBITRUM';
+    case 'AVALANCHE':
+      return 'AVAX';
+    case 'ETHEREUM':
+      return 'ETH';
     default:
       return network;
   }

diff --git a/signer-service/src/api/services/pendulum.service.js b/signer-service/src/api/services/pendulum.service.js
@@ -8,6 +8,7 @@ const {
   PENDULUM_EPHEMERAL_STARTING_BALANCE_UNITS,
 } = require('../../constants/constants');
 const { TOKEN_CONFIG } = require('../../constants/tokenConfig');
+const { SlackNotifier } = require('./slack.service');
 
 require('dotenv').config();
 
@@ -21,6 +22,14 @@ function multiplyByPowerOfTen(bigDecimal, power) {
   return newBigDecimal;
 }
 
+function divideByPowerOfTen(bigDecimal, power) {
+  const newBigDecimal = new Big(bigDecimal);
+  if (newBigDecimal.c[0] === 0) return newBigDecimal;
+
+  newBigDecimal.e -= power;
+  return newBigDecimal;
+}
+
 let api;
 let previousSpecVersion;
 
@@ -82,7 +91,16 @@ exports.fundEphemeralAccount = async (ephemeralAddress) => {
   }
 };
 
+const ChainDecimals = 12;
+
+const nativeToDecimal = (value, decimals = ChainDecimals) => {
+  const divisor = new Big(10).pow(decimals);
+
+  return value.div(divisor);
+};
+
 exports.sendStatusWithPk = async () => {
+  const slackNotifier = new SlackNotifier();
   const apiData = await createPolkadotApi();
   const { fundingAccountKeypair } = getFundingData(apiData.ss58Format, apiData.decimals);
   const { data: balance } = await apiData.api.query.system.account(fundingAccountKeypair.address);
@@ -109,14 +127,28 @@ exports.sendStatusWithPk = async () => {
       if (remainingMaxSubsidiesAvailable.lt(SUBSIDY_MINIMUM_RATIO_FUND_UNITS)) {
         isTokensSufficient = false;
         console.log(`Token ${token} balance is insufficient.`);
+
+        slackNotifier.sendMessage({
+          text: `Current balance of funding account is ${nativeToDecimal(
+            tokenBalance,
+          ).toString()} ${token} please charge the account ${fundingAccountKeypair.address}.`,
+        });
       }
     }),
   );
 
   const minimumBalanceFundingAccount = multiplyByPowerOfTen(Big(PENDULUM_FUNDING_AMOUNT_UNITS), apiData.decimals);
   const nativeBalance = Big(balance?.free?.toString() ?? '0');
+
   if (nativeBalance.gte(minimumBalanceFundingAccount) && isTokensSufficient) {
     return { status: true, public: fundingAccountKeypair.address };
   }
+  if (nativeBalance.lt(minimumBalanceFundingAccount)) {
+    slackNotifier.sendMessage({
+      text: `Current balance of funding account is ${nativeToDecimal(
+        nativeBalance,
+      ).toString()} PEN please charge the account ${fundingAccountKeypair.address}.`,
+    });
+  }
   return { status: false, public: fundingAccountKeypair.address };
 };
diff --git a/signer-service/src/api/services/slack.service.js b/signer-service/src/api/services/slack.service.js
@@ -0,0 +1,56 @@
+// Store last message timestamps with their message signatures
+const messageHistory = new Map();
+// 6 hours in milliseconds
+const cooldownPeriod = 6 * 60 * 60 * 1000;
+
+class SlackNotifier {
+  constructor() {
+    if (process.env.SLACK_WEB_HOOK_TOKEN) {
+      this.webhookUrl = `https://hooks.slack.com/services/${process.env.SLACK_WEB_HOOK_TOKEN}`;
+    } else {
+      throw new Error('SLACK_WEB_HOOK_TOKEN is not defined');
+    }
+  }
+
+  generateMessageSignature(message) {
+    // Create a unique signature for the message
+    return JSON.stringify(message);
+  }
+
+  isMessageAllowed(signature) {
+    const now = Date.now();
+    const lastSent = messageHistory.get(signature);
+
+    if (!lastSent) return true;
+
+    return now - lastSent >= cooldownPeriod;
+  }
+
+  async sendMessage(message) {
+    const signature = this.generateMessageSignature(message);
+
+    if (!this.isMessageAllowed(signature)) {
+      // Message is still in cooldown period, skip sending
+      return;
+    }
+
+    const payload = JSON.stringify(message);
+
+    const response = await fetch(this.webhookUrl, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      body: payload,
+    });
+
+    if (!response.ok) {
+      throw new Error(`Failed to send message. Status: ${response.status}`);
+    }
+
+    // Update the timestamp for this message
+    messageHistory.set(signature, Date.now());
+  }
+}
+
+exports.SlackNotifier = SlackNotifier;
diff --git a/signer-service/src/api/services/stellar.service.js b/signer-service/src/api/services/stellar.service.js
@@ -6,6 +6,8 @@ const {
   STELLAR_EPHEMERAL_STARTING_BALANCE_UNITS,
 } = require('../../constants/constants');
 const { TOKEN_CONFIG, getTokenConfigByAssetCode } = require('../../constants/tokenConfig');
+const { SlackNotifier } = require('./slack.service');
+
 // Derive funding pk
 const FUNDING_PUBLIC_KEY = Keypair.fromSecret(FUNDING_SECRET).publicKey();
 const horizonServer = new Horizon.Server(HORIZON_URL);
@@ -132,14 +134,19 @@ async function buildPaymentAndMergeTx(
 }
 
 async function sendStatusWithPk() {
+  const slackNotifier = new SlackNotifier();
+  let stellarBalance = null;
+
   try {
     // ensure the funding account exists
-    const horizonServer = new Horizon.Server(HORIZON_URL);
-    let account = await horizonServer.loadAccount(FUNDING_PUBLIC_KEY);
-    let stellarBalance = account.balances.find((balance) => balance.asset_type === 'native');
+    const account = await horizonServer.loadAccount(FUNDING_PUBLIC_KEY);
+    stellarBalance = account.balances.find((balance) => balance.asset_type === 'native');
 
     // ensure we have at the very least 10 XLM in the account
     if (Number(stellarBalance.balance) < STELLAR_FUNDING_AMOUNT_UNITS) {
+      slackNotifier.sendMessage({
+        text: `Current balance of funding account is ${stellarBalance.balance} XLM please charge the account ${FUNDING_PUBLIC_KEY}.`,
+      });
       return { status: false, public: FUNDING_PUBLIC_KEY };
     }
 

diff --git a/signer-service/src/api/services/transak.service.js b/signer-service/src/api/services/transak.service.js
@@ -45,12 +45,7 @@ async function priceQuery(cryptoCurrency, fiatCurrency, cryptoAmount, network, i
 // Helper function to get the network code for Transak. It seems like Transak just uses the commonly known network names
 // as the code for the network parameter in their API so we just return the network as is.
 function getTransakNetworkCode(network) {
-  switch (network.toUpperCase()) {
-    case 'POLYGON':
-      return 'polygon';
-    default:
-      return network;
-  }
+  return network.toLowerCase();
 }
 
 function getCryptoCode(fromCrypto) {

diff --git a/signer-service/src/index.js b/signer-service/src/index.js
@@ -1,4 +1,3 @@
-const { Keypair } = require('stellar-sdk');
 const { port, env } = require('./config/vars');
 const logger = require('./config/logger');
 const app = require('./config/express');

diff --git a/src/assets/chains/arbitrum.svg b/src/assets/chains/arbitrum.svg
diff --git a/src/assets/chains/avalanche.svg b/src/assets/chains/avalanche.svg
diff --git a/src/assets/chains/base.svg b/src/assets/chains/base.svg
diff --git a/src/assets/chains/bsc.svg b/src/assets/chains/bsc.svg
diff --git a/src/assets/chains/ethereum.svg b/src/assets/chains/ethereum.svg