import { SolanaBatchProcessor } from "@subsquid/solana-processor";
import { TypeormDatabase } from "@subsquid/typeorm-store";

const processor = new SolanaBatchProcessor()
  .setGateway("https://v2.archive.subsquid.io/network/solana-mainnet")
  .setRpcEndpoint("<RPC_ENDPOINT_URL>")
  .setBlockRange({ from: 150000000 })
  .addInstruction({
    programId: ["<PROGRAM_ID>"],
    isCommitted: true,
  });

processor.run(new TypeormDatabase(), async (ctx) => {
  for (let block of ctx.blocks) {
    for (let instruction of block.instructions) {
      // Process instruction data
    }
  }
});