import {HypersyncClient, Decoder, type Query} from "@envio-dev/hypersync-client";

const DAI_ADDRESS = "0x6B175474E89094C44Da98b954EedeAC495271d0F";

async function main() {
    // Create hypersync client using the mainnet hypersync endpoint
    const client = new HypersyncClient({
      url: "https://eth.hypersync.xyz",
      apiToken: process.env.ENVIO_API_TOKEN!,
    });

    const height = await client.getHeight();

    // The query to run
    const query: Query = {
        // start from tip of the chain
        "fromBlock": height,
        "logs": [
          {
            "address": [DAI_ADDRESS],
            // We want the transfers
            "topics": [
              ["0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"],
              [],
              [],
              [],
            ]
          }
        ],
        // Select the fields we are interested in, notice topics are selected as topic0,1,2,3
        "fieldSelection": {
          "log": [
                "Data",
                "Address",
                "Topic0",
                "Topic1",
                "Topic2",
                "Topic3",
          ]
        },
      };

    const decoder = Decoder.fromSignatures([
      "Transfer(address indexed from, address indexed to, uint amount)"
    ]);

    let total_dai_volume = BigInt(0);
 
    while(true) {
      const res = await client.get(query);

      if(res.data.logs.length !== 0) {
        // Decode the log on a background thread so we don't block the event loop.
        // Can also use decoder.decodeLogsSync if it is more convenient.
        const decodedLogs = await decoder.decodeLogs(res.data.logs);

        for (const log of decodedLogs) {
          if (log === null) {
            continue;
          }
          total_dai_volume += log.body[0].val as bigint;
        }
      }

      console.log(`scanned up to ${res.nextBlock} and total DAI transfer volume is ${total_dai_volume / BigInt(1e18)} USD`);

      let height = res.archiveHeight;
      while (height < res.nextBlock) {
        // wait if we are at the head
        console.log(`waiting for chain to advance. Height is ${height}`);
        height = await client.getHeight();
        await new Promise(resolve => setTimeout(resolve, 1000));
      }

      // Continue query from nextBlock
      query.fromBlock = res.nextBlock;
    }
}

main();