feat(bot): Add missing keys of interest to StateRelayerBot

packages/walletkit-bot/src/api/StateRelayerBot.ts

@@ -4,20 +4,53 @@ import { BigNumber } from "bignumber.js";
 
 import { getWhaleClient } from "./DeFiChainCore";
 
+type TokenSymbolStringPair = { [tokenSymbol: string]: string };
+
 type PairData = {
   [pairSymbol: string]: {
     primaryTokenPrice: string;
     volume24H: string;
     totalLiquidity: string;
     apr: string;
+    pooledTokensCount: TokenSymbolStringPair;
+    conversationRate: TokenSymbolStringPair;
+    rewards: string;
+    commission: string;
   };
 };
 
+type VaultData = {
+  totalVaults: string;
+  totalLoanValue: string;
+  totalCollateralValue: string;
+  totalCollateralizationRatio: string;
+  activeAuctions: string;
+};
+
+type MasternodesData = {
+  totalValueLocked: string;
+  zeroYearLocked: string;
+  fiveYearsLocked: string;
+  tenYearsLocked: string;
+};
+
+type BurnData = {
+  address: string;
+  fee: string;
+  auction: string;
+  payback: string;
+  emission: string;
+  total: string;
+};
+
 type DataStore = {
   // /dex
   totalValueLockInPoolPair: string;
   total24HVolume: string;
   pair: PairData;
+  vaults: VaultData;
+  masternodes: MasternodesData;
+  burned: BurnData;
 };
 
 type StateRelayerHandlerProps = {
@@ -33,11 +66,12 @@ export async function handler(
   const { urlNetwork, envNetwork } = props;
   const dataStore = {} as DataStore;
   try {
-    // TODO: Check if Function should run (blockHeight > 30 from previous)
     // Get Data from OCEAN API
     const client = getWhaleClient(urlNetwork, envNetwork);
     const statsData = await client.stats.get();
+
     const rawPoolpairData = await client.poolpairs.list(200);
+
     const dexPriceData = await client.poolpairs.listDexPrices(DENOMINATION);
 
     // sanitise response data
@@ -50,10 +84,10 @@ export async function handler(
     dataStore.totalValueLockInPoolPair = statsData.tvl.dex.toString();
 
     // total24HVolume
-    const total24HVolume = poolpairData.reduce(
-      (acc, currPair) => acc + (currPair.volume?.h24 ?? 0),
-      0
-    );
+    const total24HVolume = poolpairData.reduce((acc, currPair) => {
+      const volume = new BigNumber(currPair.volume?.h24 ?? 0);
+      return acc.plus(volume);
+    }, new BigNumber(0));
     dataStore.total24HVolume = total24HVolume.toString();
 
     // pair
@@ -72,18 +106,68 @@ export async function handler(
       return {
         ...acc,
         [currPair.displaySymbol]: {
+          // Overview
           primaryTokenPrice: tokenPrice.toString(),
           volume24H: currPair?.volume?.h24.toString() ?? "0",
           totalLiquidity: currPair.totalLiquidity.usd ?? "0",
           apr: currPair?.apr?.total.toString(),
+          // Detail
+          pooledTokensCount: {
+            [currPair.tokenA.displaySymbol]: currPair.tokenA.reserve,
+            [currPair.tokenB.displaySymbol]: currPair.tokenB.reserve,
+          },
+          conversionRate: {
+            [currPair.tokenA.displaySymbol]: currPair.priceRatio.ab,
+            [currPair.tokenB.displaySymbol]: currPair.priceRatio.ba,
+          },
+          rewards: (currPair.apr?.reward
+            ? currPair.apr.reward
+            : 0
+          ).toString(),
+          commission: (currPair.apr?.commission
+            ? currPair.apr.commission
+            : 0
+          ).toString(),
         },
       } as PairData;
     }, {} as PairData);
     dataStore.pair = pair;
-    // TODO: Get Data from /dex/[pool-pair]
-    // TODO: Get Data from /vaults
-    // TODO: Get Data from /masternodes
-    // TODO: Get Data from all burns in ecosystem
+
+    const loanData = statsData.loan;
+    // Get Data from /vaults
+    const vaults = {
+      totalVaults: loanData.count.openVaults.toString(),
+      totalLoanValue: loanData.value.loan.toString(),
+      totalCollateralValue: loanData.value.collateral.toString(),
+      totalCollateralizationRatio:
+        ((loanData.value.collateral / loanData.value.loan) * 100).toString(),
+      activeAuctions: loanData.count.openAuctions.toString(),
+    };
+    dataStore.vaults = vaults;
+
+    // Get Data from /masternodes
+    const lockedMasternodes = statsData.masternodes.locked;
+
+    const masternodes = {
+      totalValueLocked: statsData.tvl.masternodes.toString(), // Alternatively, can reduce lockedMasternodes to derive this data
+      zeroYearLocked: (lockedMasternodes.find((m) => m.weeks === 0)?.count ?? 0).toString(), // Can technically access element at 0 index for speed
+      fiveYearsLocked:
+        (lockedMasternodes.find((m) => m.weeks === 260)?.count ?? 0).toString(),
+      tenYearsLocked:
+        (lockedMasternodes.find((m) => m.weeks === 520)?.count ?? 0).toString(),
+    };
+    dataStore.masternodes = masternodes;
+
+    // Get Data from all burns in ecosystem
+    dataStore.burned = {
+      address: statsData.burned.address.toString(),
+      fee: statsData.burned.fee.toString(),
+      auction: statsData.burned.auction.toString(),
+      payback: statsData.burned.address.toString(),
+      emission: statsData.burned.emission.toString(),
+      total: statsData.burned.total.toString(),
+    };
+
     // Interfacing with SC
     // TODO: Connect with SC
     // TODO: Call SC Function to update Collated Data