Traces

{
  // item filters
  where?: {
    type?: string[]
    callTo?: string[]
    callFrom?: string[]
    callSighash?: string[]
    createFrom?: string[]
    suicideRefundAddress?: string[]
    rewardAuthor?: string[]
  }

  // related data retrieval
  include?: {
    transaction?: boolean
    transactionLogs?: boolean
    subtraces?: boolean
    parents?: boolean
  }

  // block range override
  range?: {from: number, to?: number}
}

import {run} from '@subsquid/batch-processor'
import {DataSourceBuilder} from '@subsquid/evm-stream'
import {augmentBlock} from '@subsquid/evm-objects'
import {TypeormDatabase} from '@subsquid/typeorm-store'

const TARGET_TRANSACTION = '0xf178718219151463aa773deaf7d9367b8408e35a624550af975e089ca6e015ca'
const TO_CONTRACT = '0xc36442b4a4522e871399cd717abdd847ab11fe88' // Uniswap v3 Positions NFT
const METHOD_SIGHASH = '0x88316456' // mint

const dataSource = new DataSourceBuilder()
  .setPortal('https://portal.sqd.dev/datasets/ethereum-mainnet')
  .setBlockRange({from: 16962349, to: 16962349})
  .addTransaction({
    where: {
      to: [TO_CONTRACT],
      sighash: [METHOD_SIGHASH]
    },
    include: {
      traces: true
    }
  })
  .setFields({
    transaction: {hash: true},
    trace: {callTo: true}
  })
  .build()

run(dataSource, new TypeormDatabase({supportHotBlocks: true}), async ctx => {
  let involvedContracts = new Set<string>()
  let traceCount = 0

  for (let block of ctx.blocks.map(augmentBlock)) {
    for (let trc of block.traces) {
      if (trc.type === 'call' && trc.transaction?.hash === TARGET_TRANSACTION) {
        involvedContracts.add(trc.action.to)
        traceCount += 1
      }
    }
  }

  console.log(`txn ${TARGET_TRANSACTION} had ${traceCount - 1} internal transactions`)
  console.log(`${involvedContracts.size} contracts were involved in txn ${TARGET_TRANSACTION}:`)
  involvedContracts.forEach(c => { console.log(c) })
})

import {run} from '@subsquid/batch-processor'
import {DataSourceBuilder} from '@subsquid/evm-stream'
import {TypeormDatabase} from '@subsquid/typeorm-store'
import {CreatedContract} from './model'

const dataSource = new DataSourceBuilder()
  .setPortal('https://portal.sqd.dev/datasets/ethereum-mainnet')
  .addTrace({
    where: {type: ['create']}
  })
  .setFields({
    trace: {
      createResultAddress: true,
      error: true
    }
  })
  .build()

run(dataSource, new TypeormDatabase({supportHotBlocks: true}), async (ctx) => {
  const contracts: Map<string, CreatedContract> = new Map()
  for (let block of ctx.blocks) {
    for (let trc of block.traces) {
      if (trc.type === 'create' &&
          trc.error === null &&
          trc.result?.address != null) {
        contracts.set(trc.result.address, new CreatedContract({id: trc.result.address}))
      }
    }
  }
  await ctx.store.upsert([...contracts.values()])
})