index.js

const axios = require("axios");
const express = require("express");
const cors = require('cors')
const { Decimal } = require("@cosmjs/math");
const { QueryClient, setupAuthExtension } = require("@cosmjs/stargate");
const { Tendermint34Client } = require("@cosmjs/tendermint-rpc");
const {
  ContinuousVestingAccount,
  DelayedVestingAccount,
  PeriodicVestingAccount,
} = require("cosmjs-types/cosmos/vesting/v1beta1/vesting");

require("dotenv").config();

const denom = process.env.DENOM || "uflix";
const interval = process.env.INTERVAL || 7200000;

const vestingAccounts = process.env.VESTING_ACCOUNTS
  ? process.env.VESTING_ACCOUNTS.split(",")
  : [];

const app = express();
app.use(cors());
const port = process.env.PORT || 3000;

async function makeClientWithAuth(rpcUrl) {
  const tmClient = await Tendermint34Client.connect(rpcUrl);
  return [QueryClient.withExtensions(tmClient, setupAuthExtension), tmClient];
}

// Declare variables
let totalSupply,
  communityPool,
  communityPoolMainDenomTotal,
  circulatingSupply,
  tmpCirculatingSupply,
  apr,
  bondedRatio,
  totalStaked;

// Gets supply info from chain
async function updateData() {
  try {
    // Create Tendermint RPC Client
    const [client, tmClient] = await makeClientWithAuth(
      process.env.RPC_ENDPOINT
    );

    console.log("Updating supply info", new Date());

    // Get total supply
    totalSupply = await axios({
      method: "get",
      url: `${process.env.REST_API_ENDPOINT}/cosmos/bank/v1beta1/supply/${denom}`,
    });
    console.log("Total supply: ", totalSupply.data.amount.amount);

    // Get community pool
    communityPool = await axios({
      method: "get",
      url: `${process.env.REST_API_ENDPOINT}/cosmos/distribution/v1beta1/community_pool`,
    });

    // Get staking info
    stakingInfo = await axios({
      method: "get",
      url: `${process.env.REST_API_ENDPOINT}/cosmos/staking/v1beta1/pool`,
    });

    totalStaked = stakingInfo.data.pool.bonded_tokens;
    totalUnbonding = stakingInfo.data.pool.not_bonded_tokens;

    console.log("Total Staked: ", totalStaked);
    console.log("Total Unbonding: ", totalUnbonding)

    // Loop through pool balances to find denom
    for (let i in communityPool.data.pool) {
      if (communityPool.data.pool[i].denom === denom) {
        console.log("Community pool: ", communityPool.data.pool[i].amount);

        communityPoolMainDenomTotal = communityPool.data.pool[i].amount;

        // Subtract community pool from total supply
        tmpCirculatingSupply =
          totalSupply.data.amount.amount - communityPool.data.pool[i].amount;
      }
    }

    // Iterate through vesting accounts and subtract vesting balance from total
    for (let i = 0; i < vestingAccounts.length; i++) {
      const account = await client.auth.account(vestingAccounts[i]);
      let accountInfo = PeriodicVestingAccount.decode(account.value);
      let originalVesting =
        accountInfo.baseVestingAccount.originalVesting[0].amount;
      let delegatedFree =
        accountInfo.baseVestingAccount.delegatedFree.length > 0
          ? accountInfo.baseVestingAccount.delegatedFree[0].amount
          : 0;

      tmpCirculatingSupply -= originalVesting - delegatedFree;
    }
    circulatingSupply = tmpCirculatingSupply;
    console.log("Circulating supply: ", circulatingSupply);
  } catch (e) {
    console.error(e);
  }
}

// Get initial data
updateData();

// Update data on an interval (2 hours)
setInterval(updateData, interval);

app.get("/", async (req, res) => {
  res.json({
    apr,
    bondedRatio,
    circulatingSupply: Decimal.fromAtomics(circulatingSupply, 6).toString(),
    communityPool: Decimal.fromAtomics(
      communityPoolMainDenomTotal.split(".")[0],
      6
    ).toString(),
    denom: denom.substring(1).toUpperCase(),
    totalStaked: Decimal.fromAtomics(totalStaked, 6).toString(),
    totalSupply: Decimal.fromAtomics(
      totalSupply.data.amount.amount,
      6
    ).toString(),
  });
});

app.get("/apr", async (req, res) => {
  res.send(apr.toString());
});

app.get("/bonded-ratio", async (req, res) => {
  res.send(bondedRatio.toString());
});

app.get("/circulating-supply", async (req, res) => {
  res.send(Decimal.fromAtomics(circulatingSupply, 6).toString());
});

app.get("/total-staked", async (req, res) => {
  res.send(Decimal.fromAtomics(totalStaked, 6).toString());
});

app.get("/total-supply", async (req, res) => {
  res.send(Decimal.fromAtomics(totalSupply.data.amount.amount, 6).toString());
});

app.get("/community-pool", async (req, res) => {
  res.send(
    Decimal.fromAtomics(communityPoolMainDenomTotal.split(".")[0], 6).toString()
  );
});

app.get("/denom", async (req, res) => {
  res.send(denom.substring(1).toUpperCase());
});

app.listen(port, () => {
  console.log(`Example app listening at http://localhost:${port}`);
});