Choosing Your SQD Tool

{"header":{"number":18000000},"logs":[{"address":"0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48","topics":["0xddf252ad..."],"data":"0x..."}]}

import { createTarget } from '@subsquid/pipes'
import { commonAbis, evmDecoder, evmPortalSource } from '@subsquid/pipes/evm'

const transfers = evmDecoder({
  range: { from: 18_000_000, to: 18_000_002 }, // drop `to` to follow the chain head
  contracts: ['0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48'],
  events: { transfer: commonAbis.erc20.events.Transfer },
}).pipe(({ transfer }) =>
  transfer.map((t) => ({
    block: t.block.number,
    from: t.event.from,
    to: t.event.to,
    value: t.event.value,
  })),
)

await evmPortalSource({
  id: 'usdc-transfers', // stable id: targets key their resume cursor by it
  portal: 'https://portal.sqd.dev/datasets/ethereum-mainnet',
  outputs: { transfers },
}).pipeTo(
  createTarget({
    write: async ({ read }) => {
      for await (const { data } of read()) {
        // data.transfers is a typed, decoded array. Write it anywhere
      }
    },
  }),
)

import { run } from '@subsquid/batch-processor'
import { augmentBlock } from '@subsquid/evm-objects'
import { DataSourceBuilder } from '@subsquid/evm-stream'
import { TypeormDatabase } from '@subsquid/typeorm-store'
import * as erc20 from './abi/erc20' // generated by squid-evm-typegen
import { Transfer } from './model' // generated from schema.graphql

const USDC = '0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48'

const dataSource = new DataSourceBuilder()
  .setPortal('https://portal.sqd.dev/datasets/ethereum-mainnet')
  .setBlockRange({ from: 18_000_000, to: 18_000_002 }) // drop `to` to follow the chain head
  .setFields({ log: { address: true, topics: true, data: true } })
  .addLog({ where: { address: [USDC], topic0: [erc20.events.Transfer.topic] } })
  .build()

run(dataSource, new TypeormDatabase(), async (ctx) => {
  const transfers: Transfer[] = []
  for (const block of ctx.blocks) {
    for (const log of augmentBlock(block).logs) {
      const { from, to, value } = erc20.events.Transfer.decode(log)
      transfers.push(new Transfer({ id: log.id, from, to, value }))
    }
  }
  await ctx.store.insert(transfers)
})