Indexers for production dApps

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/binance-mainnet'
  )
  .addTransaction({})

const wallets: Set<string> = loadWallets()
// wallets.size can be very large (tested at 1.4M)

processor.run(new TypeormDatabase(), async (ctx) => {
  for (let block of ctx.blocks) {
    for (let txn of block.transactions) {
      if (wallets.has(txn.from)) {
        // process a txn initiated by the wallet
      }
      if (txn.to && wallets.has(txn.to)) {
        // process a txn directed to the wallet
      }
    }
  }
})

export const USDC_CONTRACT_ADDRESS = 
'0xa0b86991c6218b36c1d19d4a2e9eb0ce3606eb48'

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .setRpcEndpoint('<eth_rpc_endpoint_url>')
  .setFinalityConfirmation(75)
  .addLog({
    range: {from: 6_082_465},
    address: [USDC_CONTRACT_ADDRESS],
    topic0: [usdcAbi.events.Transfer.topic],
  })
  .setFields({
    log: {
      transactionHash: true,
    },
  })

Real time data is fetched from a chain node RPC; a Database object with hot blocks support is required to store it .

export const VITALIK_ETH_TOPIC = 
'0x000000000000000000000000d8da6bf26964af9d7eed9e03e53415d37aa96045
'

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .addLog({
    topic0: [erc20abi.events.Transfer.topic],
    topic2: [VITALIK_ETH_TOPIC],
  })

All Transfer (address,address,uint256) will be captured, including ERC20 and ERC721 transfers and possibly events with the same signature made with other protocols.

export const AAVE_CONTRACT = 
'0x7d2768de32b0b80b7a3454c06bdac94a69ddc7a9'
export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .setBlockRange({ from: 11_362_579 })
  .addTransaction({
    to: [AAVE_CONTRACT],
    logs: true,
  })
  .setFields({
    transaction: {
      value: true,
      sighash: true,
    },
    log: {
      transactionHash: true,
    },
  })

Including events emitted by other contracts. Get ETH value involved in each call.

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .addLog({
    topic0: [usdcAbi.events.Mint.topic],
    transaction: true,
  })
  .setFields({
    transaction: {
      gasUsed: true,
    }
  })

export const FACTORY_ADDRESSES = [
  '0xbcfccbde45ce874adcb698cc183debcf17952812',
  '0xca143ce32fe78f1f7019d7d551a6402fc5350c73',
]

const PAIR_CREATED_TOPIC = 
'0x0d3648bd0f6ba80134a33ba9275ac585d9d315f0ad8355cddefde31afa28d0e9'
const SWAP_TOPIC = 
'0xd78ad95fa46c994b6551d0da85fc275fe613ce37657fb8d5e3d130840159d822'

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/binance-mainnet'
  )
  .setBlockRange({ from: 586_851 })
  .addLog({
    address: FACTORY_ADDRESSES,
    topic0: [PAIR_CREATED_TOPIC],
  })
  .addLog({
    topic0: [SWAP_TOPIC],
  })
  .setFields({
    log: {
      transactionHash: true,
    },
  })

const BAYC_ADDRESS = '0xbc4ca0eda7647a8ab7c2061c2e118a18a936f13d'

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .setBlockRange({ from: 12_287_507 })
  .addTrace({
    type: ['call'],
    callTo: [BAYC_ADDRESS],
    transaction: true,
  })
  .addStateDiff({
    address: [BAYC_ADDRESS],
    transaction: true,
  })
  .setFields({
    trace: {
      callTo: true,
      callFrom: true,
      callSighash: true,
    },
 })

Call traces will expose any internal calls to BAYC by other contracts. Also retrieves all changes to contract storage state.

export const processor = new EvmBatchProcessor()
  .setGateway(
     'https://v2.archive.subsquid.io/network/ethereum-mainnet'
  )
  .addTrace({
    type: ['create'],
    transaction: true,
  })
  .addLog({
    topic0: [erc721.events.Transfer.topic],
  })
  .setFields({
    trace: {
      createResultCode: true, // for checking ERC721 compliance
      createResultAddress: true,
    },
  })

All contract creations are scraped; they will be checked for ERC721 compliance in the batch handler. All ERC721 Transfer events are scraped so that they can be filtered and binned by the contract in the batch handler.