import { ponder } from "ponder:registry";
import schema from "ponder:schema";
import { parseAbi } from "viem";

ponder.on("ChainlinkPriceOracle:block", async ({ event, context }) => {
  const price = await context.client.readContract({
    address: "0xD10aBbC76679a20055E167BB80A24ac851b37056",
    abi: parseAbi(["function latestAnswer() external view returns (int256)"]),
    functionName: "latestAnswer",
  });

  await context.db.insert(schema.chainlinkPrice).values({
    timestamp: event.block.timestamp,
    price: Number(price) / 10 ** 8,
  });
});