Merge pull request #4051 from tutacrypto/add-angle-borrow-liquidations

[Review]: Liquidations - Add angle borrowing module liquidations (mainnet)

liquidations/angle/index.ts

@@ -0,0 +1,112 @@
+import axios from "axios";
+import { gql } from "graphql-request";
+import { ethers } from "ethers";
+import { providers } from "../utils/ethers";
+import BigNumber from "bignumber.js";
+import { getPagedGql } from "../utils/gql";
+import { Liq } from "../utils/binResults";
+
+const subgraphUrl = "https://api.thegraph.com/subgraphs/name/picodes/borrow";
+
+const vaultDataQuery = gql`
+  query vaultDatas($lastId: ID) {
+    vaultDatas(first: 1000, where: { isActive: true, id_gt: $lastId }) {
+      id
+      collateralAmount
+      vaultManager {
+        agToken
+        collateral
+        collateralFactor
+      }
+      owner
+    }
+  }
+`;
+
+type VaultData = {
+  id: string;
+  collateralAmount: string;
+  vaultManager: {
+    agToken: string;
+    collateral: string;
+    collateralFactor: string;
+  };
+  owner: string;
+};
+
+const getVaultData = async () => {
+  const vaultData = (await getPagedGql(subgraphUrl, vaultDataQuery, "vaultDatas")) as VaultData[];
+  return vaultData;
+};
+
+const getTokenInfo = async (tokenId: string) => {
+  const info = (await axios.get("https://coins.llama.fi/prices/current/" + tokenId)).data.coins as {
+    [tokenId: string]: { decimals: number; price: number; symbol: string; timestamp: number; confidence: number };
+  };
+  const price = info[tokenId];
+  return price;
+};
+
+const AGEUR_TOKEN_ID = "ethereum:0x1a7e4e63778B4f12a199C062f3eFdD288afCBce8";
+
+// returns vault agEUR debt in $
+const getVaultDebt = async (id: string) => {
+  const vaultManager = id.split("_")[0];
+  const vaultId = id.split("_")[1];
+  const vaultManagerContract = new ethers.Contract(
+    vaultManager,
+    ["function getVaultDebt(uint256) view returns (uint256)"],
+    providers.ethereum
+  );
+  const vaultDebtRaw = BigNumber((await vaultManagerContract.getVaultDebt(vaultId)).toString());
+  // convert vault debt to $
+  const vaultDebt = vaultDebtRaw.times((await getTokenInfo(AGEUR_TOKEN_ID)).price);
+  return vaultDebt;
+};
+
+const EXPLORER_BASE_URL = "https://etherscan.io/address/";
+
+const positions = async () => {
+  const vaultData = await getVaultData();
+
+  const positions: Liq[] = [];
+  for (const vault of vaultData) {
+    const owner = vault.owner;
+    const collateral = vault.vaultManager.collateral;
+    const collateralAmount = vault.collateralAmount;
+
+    // liquidation price computation
+    const vaultDebt = await getVaultDebt(vault.id);
+    const collateralFactor = BigNumber(vault.vaultManager.collateralFactor).div(10e8);
+    let liqPrice: number;
+
+    const collateralDecimals = (await getTokenInfo(collateral)).decimals;
+    if (collateralDecimals != 18) {
+      // correcting the number of decimals
+      liqPrice = BigNumber(vaultDebt)
+        .div(BigNumber(collateralAmount).times(collateralFactor))
+        .times(10 ** (collateralDecimals - 18))
+        .toNumber();
+    } else {
+      liqPrice = BigNumber(vaultDebt).div(BigNumber(collateralAmount).times(collateralFactor)).toNumber();
+    }
+
+    positions.push({
+      owner,
+      liqPrice,
+      collateral: "ethereum:" + collateral,
+      collateralAmount,
+      extra: {
+        url: EXPLORER_BASE_URL + owner,
+      },
+    });
+  }
+
+  return positions;
+};
+
+module.exports = {
+  ethereum: {
+    liquidations: positions,
+  },
+};