index.ts

import { ethers } from "ethers";
import { NETWORK_CONFIG, SUPPORTED_CHAINS } from "@smartinvoicexyz/constants";
import { gql, request } from "graphql-request";

const query = gql`
  query {
    invoices(first: 1000) {
      network
      token
      deposits {
        amount
      }
    }
  }
`;

const getChain = (chainId: number) => {
  const chain = SUPPORTED_CHAINS.find(chain => chain.id === chainId);
  if (!chain) {
    throw new Error(`Chain with id ${chainId} not found`);
  }
  return chain;
};

const abi = [
  "function name() view returns (string)",
  "function symbol() view returns (string)",
  "function decimals() view returns (uint8)",
];

const main = async () => {
  const invoices: Record<number, any[]> = {};
  for (const network of Object.keys(NETWORK_CONFIG)) {
    const config = NETWORK_CONFIG[network];
    const data: any = await request(config.SUBGRAPH, query);
    invoices[network] = data.invoices;
  }

  for (const chainId of Object.keys(invoices)) {
    const chain = getChain(Number(chainId));
    if (chain.testnet) {
      continue;
    }
    console.log(`Total for ${chain.name} (${chainId}):`);
    const invoicesForChain = invoices[chainId];
    const totals = {};
    for (const invoice of invoicesForChain) {
      const { deposits, token } = invoice;
      const total = deposits.reduce((acc, deposit) => acc + BigInt(deposit.amount), BigInt(0));
      totals[token] = totals[token] ? totals[token] + total : total;
    }

    const provider = new ethers.JsonRpcProvider(chain.rpcUrls.default.http[0]);
    for (const token of Object.keys(totals)) {
      try {
        const total = totals[token];
        const contract = new ethers.Contract(token, abi, provider);
        const name = await contract.name();
        const symbol = await contract.symbol();
        const decimals = await contract.decimals();
        console.log(`${name} (${token}) => ${ethers.formatUnits(total, decimals)} ${symbol}`);
      } catch (e) {
        console.log(`${token} => ${totals[token]}`);

      }
    }
    console.log(`\n`);
  }






};

main().catch(console.error);