import { createIndexer, createHttpRpcClient } from "chainsauce";
import { erc20ABI } from "./erc20ABI.ts";

// -- Define contracts
const MyContracts = {
  ERC20: erc20ABI,
};

// -- Create an indexer:

const indexer = createIndexer({
  chain: {
    id: 1,
    rpcClient: createHttpRpcClient({
      url: "https://mainnet.infura.io/v3/...",
    }),
  },
  contracts: MyContracts,
});

// -- Attach event listeners:

// subscribe to a specific event
indexer.on("ERC20:Approval", async ({ event }) => {
  console.log("Approval event:", event.params);
});

// subscribe to all events
indexer.on("event", async ({ event }) => {
  console.log("Event:", event.params);
});

// -- Subscribe to deployed contracts:

indexer.subscribeToContract({
  contract: "ERC20",
  address: "0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48",

  // optional
  fromBlock: 18363594n,
  toBlock: "latest"
});

// -- One off indexing:

// one off indexing, this will resolve when finished or reject if any error happens
await indexer.indexToBlock("latest");

// -- Continous indexing:

// indexes to the latest block and watches the chain for new events
// until stopped with `indexer.stop()`
// errors will be emitted and will not stop indexing
indexer.on("error", (error) => {
   console.error("whoops", error);
});
indexer.watch();

indexer.on("ERC20:Approval", async ({ event, context }) => {
  // event is inferred to be an Approval event
  // context is inferred to be the context passed into `createIndexer`
});

import { Indexer as ChainsauceIndexer } from "chainsauce";

type MyContext = {
  db: DatabaseConnection
};

const MyContracts = {
  ERC20: erc20ABI,
};

type Indexer = ChainsauceIndexer<typeof MyContracts, MyContext>;

const indexer: Indexer = createIndexer({
   ...
   context: { db: new DatabaseConnection() }
});

async function handleTransfer({
  event, context: { db }
}: EventHandlerArgs<Indexer, "ERC20", "Transfer">) {
  // event is a Transfer event
  // context is a MyContext type
}

indexer.on("ERC20:Transfer", handleTransfer);

const myAbi = [
  ...
] as const;

indexer.on("FactoryContract:ContractCreated", async ({ event, context, subscribeToContract }) => {
  subscribeToContract({
    contract: "MyContract",
    address: event.params.contractAddress,

    // optional
    toBlock: "latest"
  });
});

import { createIndexer, createSqliteCache } from "chainsauce";

const indexer = createIndexer({
  cache: createSqliteCache("./chainsauce.db"),
});