prizeApiToDb.js

// import {ProcessPrizeApiDraw} from "./testApiSort.js"
const { ProcessPrizeApiDraw } = require("./processPrizeApiDraw.js")
const pgp = require("pg-promise")(/* initialization options */);
const dotenv = require("dotenv");
const fetch = require("cross-fetch")

dotenv.config();
const cn = {
  host: "localhost", // server name or IP address;
  port: 5432,
  database: "prizeapi",
  user: "pooltogether",
  password: process.env.PASSWORD,
};
const db = pgp(cn);

// let currentDraw = 281
// let startDraw = 281

async function go() {
  let getCurrentDraw = await fetch("https://poolexplorer.xyz/recent")
  let currentDraw = await getCurrentDraw.json()
  let newDraw = currentDraw.id + 1
  let apiUpdated = false
  try {
    let fetchApiTest = await fetch("https://api.pooltogether.com/prizes/137/0x8141bcfbcee654c5de17c4e2b2af26b67f9b9056/draw/" + newDraw + "/prizes.json")
// console.log(fetchApiTest)    
    if (fetchApiTest.status !== 404 || currentDraw !== undefined) {
fetchApiTest = await fetchApiTest.json()

      let totalPrizeCount = 0
      let totalPrizeCountClaimable = 0
      let totalValueClaimable = 0
      let totalValueDropped = 0
      // for (let draw = startDraw; draw <= currentDraw; draw++) {
        for (let draw = newDraw ; draw <= newDraw; draw++) {

        let result = await ProcessPrizeApiDraw(draw);
        let winners = result.result
        for (let x of winners) {
          let network = ""
          if (x.n == 3) { network = "polygon" }
          if (x.n == 4) { network = "avalanche" }
          if (x.n == 6) { network = "optimism" }

          if (x.n == 1) { network = "ethereum" }

          let address = "\\" + x.a.substring(1)
          let claimable = x.c.map(x => x * 1e14)
          let dropped = x.u.map(x => x * 1e14)
          let newWinner = "INSERT into prizes (network,address,draw_id,claimable_prizes,dropped_prizes) values('" + network + "','" + address + "','" + draw + "','{" + claimable + "}','{" + dropped + "}')";
          // console.log(newWinner)
          await db.any(newWinner);
        }
        totalPrizeCount += result.totalPrizeCount
        totalPrizeCountClaimable += result.totalPrizeCountClaimable
        totalValueClaimable += result.totalValueClaimable
        totalValueDropped += result.totalValueDropped

      }
      console.log("\n\ntotal prize count ", totalPrizeCount,
        "\ntotal prize count claimable ", totalPrizeCountClaimable,
        "\ntotal value claimable ", totalValueClaimable,
        "\ntotal value dropped ", totalValueDropped)
    }
  } catch (error) { console.log(error) }
}
go()