bot.ts

require("dotenv").config();

import { MessageBuilder, Webhook } from "discord-webhook-node";

import Fuse from "./fuse.node.commonjs2.js";
const fuse = new Fuse(
  "wss://eth-mainnet.ws.alchemyapi.io/v2/hyzY6NPaP88J5E8UJKYoiUi2i_a4O7l4"
);

console.log("Connecting to Discord Webhook:", process.env.WEBHOOK_URL);

const hook = new Webhook(process.env.WEBHOOK_URL);
hook.setUsername("Fuse Alerts");
hook.setAvatar(
  "https://raw.githubusercontent.com/Rari-Capital/fuse-webhooks-bot/main/fuse.png"
);

const smallFormatter = Intl.NumberFormat("en-US", {
  minimumFractionDigits: 2,
  maximumFractionDigits: 2
});

function formatAmount(amount: any, decimals: any) {
  return smallFormatter.format(amount / 10 ** decimals);
}

export interface FuseAsset {
  cToken: string;

  borrowBalance: number;
  supplyBalance: number;
  liquidity: number;

  membership: boolean;

  underlyingName: string;
  underlyingSymbol: string;
  underlyingToken: string;
  underlyingDecimals: number;
  underlyingPrice: number;

  collateralFactor: number;
  reserveFactor: number;

  adminFee: number;
  fuseFee: number;

  borrowRatePerBlock: number;
  supplyRatePerBlock: number;

  totalBorrow: number;
  totalSupply: number;
}

async function main() {
  const { 1: fusePools } = await fuse.contracts.FusePoolLens.methods
    .getPublicPoolsByVerificationWithData(true)
    .call({ gas: 1e18 });

  for (let i = 0; i < fusePools.length; i++) {
    if (i == 4) {
      // Pool 4 is broken, we'll just skip it for now.
      continue;
    }

    fuse.contracts.FusePoolLens.methods
      .getPoolAssetsWithData(fusePools[i].comptroller)
      .call({
        from: "0x0000000000000000000000000000000000000000",
        gas: 1e18
      })
      .then((assets: FuseAsset[]) => {
        assets.forEach(asset => {
          const cToken = new fuse.web3.eth.Contract(
            JSON.parse(
              fuse.compoundContracts[
                "contracts/CEtherDelegate.sol:CEtherDelegate"
              ].abi
            ),
            asset.cToken
          );

          cToken.events.allEvents({}, function (_, event) {
            console.log("New Event", event.transactionHash);

            const eventName = event.event;

            if (
              eventName != "Transfer" &&
              eventName != "Approval" &&
              eventName != "AccrueInterest" &&
              eventName != "Failure"
            ) {
              let embed = new MessageBuilder()
                .setTitle(eventName)
                .setDescription(`from \`${event.returnValues["0"]}\` \n\u200B`) // Return value '0' is always the from address.
                .addField("Pool", filterPoolName(fusePools[i].name), true)
                .addField("Asset", asset.underlyingSymbol, true)
                .setTimestamp();

              if (eventName === "Mint") {
                embed = embed
                  .addField(
                    "Amount",
                    formatAmount(
                      event.returnValues.mintAmount,
                      asset.underlyingDecimals
                    ),
                    true
                  )
                  .setColor(0x7ea8e8);
              }

              if (eventName === "Redeem") {
                embed = embed
                  .addField(
                    "Amount",
                    formatAmount(
                      event.returnValues.redeemAmount,
                      asset.underlyingDecimals
                    ),
                    true
                  )
                  .setColor(0xf5740d);
              }

              if (eventName === "Borrow") {
                embed = embed
                  .addField(
                    "Amount",
                    formatAmount(
                      event.returnValues.borrowAmount,
                      asset.underlyingDecimals
                    ),
                    true
                  )
                  .setColor(0x90ad6c);
              }

              if (eventName === "RepayBorrow") {
                embed = embed
                  .addField(
                    "Amount",
                    formatAmount(
                      event.returnValues.repayAmount,
                      asset.underlyingDecimals
                    ),
                    true
                  )
                  .setColor(0xdb4152);
              }

              if (eventName === "LiquidateBorrow") {
                embed = embed
                  .addField(
                    "Amount",
                    formatAmount(
                      event.returnValues.repayAmount,
                      asset.underlyingDecimals
                    ),
                    true
                  )
                  .setColor(0xf1c219);
              }

              hook.send(
                embed.addField(
                  "\u200B",
                  "https://etherscan.io/tx/" + event.transactionHash
                )
              );
            }
          });
        });
      });
  }
}

main();

// Prevent node from exiting early.
process.stdin.resume();

// Keep this in sync with the version in https://github.com/Rari-Capital/rari-dApp/blob/master/src/utils/fetchFusePoolData.ts
function filterPoolName(name: string) {
  if (name === "Tetranode's Pool") {
    return "Tetranode's Locker";
  }

  if (name === "state's pool") {
    return "Ribbon Pool";
  }

  if (name === "Stake DAO Pool") {
    return "The Animal Kingdom";
  }

  if (name === "Tetranode's ETH Pool") {
    return "ChainLinkGod's / Tetranode's Up Only Pool";
  }

  if (name === "Tetranode's Flavor of the Month") {
    return "FeiRari (Fei DAO Pool)";
  }

  if (name === "WOO pool") {
    return "Warlord's WOO Pool";
  }

  if (name === "Yearn's Yield") {
    return "Yearn Soup Pot of Yield";
  }

  return name;
}