import \{ FuelBatchProcessor \} from '@subsquid/fuel-processor'
import \{ TypeormDatabase \} from '@subsquid/typeorm-store'

const processor = new FuelBatchProcessor()
  .setGateway('https://v2.archive.subsquid.io/network/fuel-mainnet')
  .setRpcEndpoint('https://mainnet.fuel.network/v1/graphql')
  .addReceipt({
    type: ['TRANSFER', 'LOG_DATA', 'CALL']
  })
  .setFields({
    receipt: {
      receiptType: true,
      data: true,
      amount: true,
      assetId: true
    },
    transaction: {
      id: true,
      gasUsed: true,
      status: true
    },
    block: {
      height: true,
      timestamp: true
    }
  })

const db = new TypeormDatabase()

processor.run(db, async (ctx) => {
  for (let block of ctx.blocks) {
    for (let receipt of block.receipts) {
      // Process Fuel receipts
console.log(`Receipt type: "$\{receipt.receiptType\}`)"
    }
  }
})

processor.addReceipt({
  type: ['TRANSFER'],
  assetId: ['0x...'] // Specific asset ID
})

processor.addReceipt({
  type: ['LOG_DATA'],
  contractId: ['0x...'] // Specific contract
})

processor.addReceipt({
  type: ['CALL'],
  contractId: ['0x...']
})

interface Receipt {
  receiptType: 'TRANSFER' | 'LOG_DATA' | 'CALL' | 'RETURN' | 'REVERT'
  data?: string
  amount?: bigint
  assetId?: string
  contractId?: string
  to?: string
  from?: string
}

interface Transaction {
  id: string
  gasUsed: bigint
  gasPrice: bigint
  status: 'SUCCESS' | 'FAILURE'
  receipts: Receipt[]
}

// Index native asset transfers
processor.addReceipt({
  type: ['TRANSFER'],
  assetId: ['0x0000000000000000000000000000000000000000000000000000000000000000'] // ETH
})

// Monitor specific contract calls
processor.addReceipt({
  type: ['CALL', 'LOG_DATA'],
  contractId: ['0x...']
})

// Track custom token transfers
processor.addReceipt({
  type: ['TRANSFER'],
  assetId: ['0x...'] // Custom token asset ID
})