indexer/services/indexes/avax/reader_list_ctrans.go

package avax

import (
	"context"
	"encoding/hex"
	"encoding/json"
	"math/big"
	"strings"

	"github.com/ava-labs/coreth/core/types"
	"github.com/ava-labs/ortelius/cfg"
	"github.com/ava-labs/ortelius/db"
	"github.com/ava-labs/ortelius/models"
	"github.com/ava-labs/ortelius/modelsc"
	"github.com/ava-labs/ortelius/services/indexes/params"
	"github.com/ava-labs/ortelius/utils"
	"github.com/ethereum/go-ethereum/accounts/abi"
	"github.com/gocraft/dbr/v2"
)

func (r *Reader) ListCTransactions(ctx context.Context, p *params.ListCTransactionsParams) (*models.CTransactionList, error) {
	toCTransactionData := func(t *types.Transaction) *models.CTransactionData {
		res := &models.CTransactionData{}
		res.Type = int(t.Type())
		res.Hash = t.Hash().Hex()
		if !strings.HasPrefix(res.Hash, "0x") {
			res.Hash = "0x" + res.Hash
		}
		res.Nonce = t.Nonce()
		if t.GasPrice() != nil {
			str := t.GasPrice().String()
			res.GasPrice = &str
		}
		res.GasLimit = t.Gas()
		if t.GasFeeCap() != nil {
			str := t.GasFeeCap().String()
			res.GasFeeCap = &str
		}
		if t.GasTipCap() != nil {
			str := t.GasTipCap().String()
			res.GasTipCap = &str
		}
		if t.To() != nil {
			str := utils.CommonAddressHexRepair(t.To())
			res.Recipient = &str
		}
		if t.Value() != nil {
			str := t.Value().String()
			res.Amount = &str
		}
		if len(t.Data()) != 0 {
			hexdata := "0x" + hex.EncodeToString(t.Data())
			res.Payload = &hexdata
		}
		v, s, r := t.RawSignatureValues()
		if v != nil {
			str := v.String()
			res.V = &str
		}
		if s != nil {
			str := s.String()
			res.S = &str
		}
		if r != nil {
			str := r.String()
			res.R = &str
		}
		return res
	}

	dbRunner, err := r.conns.DB().NewSession("list_ctransactions", cfg.RequestTimeout)
	if err != nil {
		return nil, err
	}

	var dataList []*db.CvmTransactionsTxdata

	sq := dbRunner.Select(
		"hash",
		"block",
		"idx",
		"rcpt",
		"nonce",
		"serialization",
		"created_at",
	).From(db.TableCvmTransactionsTxdata)

	r.listCTransFilter(p, dbRunner, sq)
	if len(p.Hashes) > 0 {
		sq.
			Where(db.TableCvmTransactionsTxdata+".hash in ?", p.Hashes)
	}

	_, err = p.Apply(sq).
		OrderDesc("created_at").
		LoadContext(ctx, &dataList)
	if err != nil {
		return nil, err
	}

	trItemsByHash := make(map[string]*models.CTransactionData)

	trItems := make([]*models.CTransactionData, 0, len(dataList))
	hashes := make([]string, 0, len(dataList))

	blocksMap := make(map[string]struct{})
	blocks := make([]string, 0, len(dataList))

	for _, txdata := range dataList {
		var tr types.Transaction
		err := tr.UnmarshalJSON(txdata.Serialization)
		if err != nil {
			return nil, err
		}
		ctr := toCTransactionData(&tr)
		ctr.Block = txdata.Block
		ctr.CreatedAt = txdata.CreatedAt
		trItems = append(trItems, ctr)

		trItemsByHash[ctr.Hash] = ctr
		hashes = append(hashes, ctr.Hash)

		if _, ok := blocksMap[txdata.Block]; !ok {
			blocksMap[txdata.Block] = struct{}{}
			blocks = append(blocks, txdata.Block)
		}
	}

	cblocksMap, err := r.fetchAndDecodeCBlocks(ctx, dbRunner, blocks)
	if err != nil {
		return nil, err
	}

	err = r.handleDressTraces(ctx, dbRunner, hashes, trItemsByHash)
	if err != nil {
		return nil, err
	}

	for _, trItem := range trItemsByHash {
		if cblockv, ok := cblocksMap[trItem.Block]; ok {
			trItem.BlockGasUsed = cblockv.Header.GasUsed
			trItem.BlockGasLimit = cblockv.Header.GasLimit
			trItem.BlockNonce = cblockv.Header.Nonce.Uint64()
			trItem.BlockHash = cblockv.Header.Hash().String()
		}
		if trItem.TracesMax != 0 {
			trItem.Traces = make([]*models.CvmTransactionsTxDataTrace, trItem.TracesMax)
			for k, v := range trItem.TracesMap {
				v.Idx = nil
				trItem.Traces[k] = v
			}
		}
	}

	listParamsOriginal := p.ListParams

	return &models.CTransactionList{
		Transactions: trItems,
		StartTime:    listParamsOriginal.StartTime,
		EndTime:      listParamsOriginal.EndTime,
	}, nil
}

func (r *Reader) listCTransFilter(p *params.ListCTransactionsParams, dbRunner *dbr.Session, sq *dbr.SelectStmt) {
	createdatefilter := func(tbl string, b *dbr.SelectStmt) *dbr.SelectStmt {
		if p.ListParams.StartTimeProvided && !p.ListParams.StartTime.IsZero() {
			b.Where(tbl+".created_at >= ?", p.ListParams.StartTime)
		}
		if p.ListParams.EndTimeProvided && !p.ListParams.EndTime.IsZero() {
			b.Where(tbl+".created_at < ?", p.ListParams.EndTime)
		}
		return b
	}

	blockfilter := func(b *dbr.SelectStmt) *dbr.SelectStmt {
		if p.BlockStart == nil && p.BlockEnd == nil {
			return b
		}
		b.Join(db.TableCvmTransactionsTxdata,
			db.TableCvmTransactionsTxdataTrace+".hash = "+db.TableCvmTransactionsTxdata+".hash")
		if p.BlockStart != nil {
			b.Where(db.TableCvmTransactionsTxdata + ".block >= " + p.BlockStart.String())
		}
		if p.BlockEnd != nil {
			b.Where(db.TableCvmTransactionsTxdata + ".block < " + p.BlockEnd.String())
		}
		return b
	}

	blockrcptfilter := func(b *dbr.SelectStmt) *dbr.SelectStmt {
		if p.BlockStart == nil && p.BlockEnd == nil {
			return b
		}
		if p.BlockStart != nil {
			b.Where(db.TableCvmTransactionsTxdata + ".block >= " + p.BlockStart.String())
		}
		if p.BlockEnd != nil {
			b.Where(db.TableCvmTransactionsTxdata + ".block < " + p.BlockEnd.String())
		}
		return b
	}

	if len(p.CAddressesTo) > 0 {
		subq := createdatefilter(db.TableCvmTransactionsTxdataTrace,
			blockfilter(dbRunner.Select(db.TableCvmTransactionsTxdataTrace+".hash").From(db.TableCvmTransactionsTxdataTrace).
				Where(db.TableCvmTransactionsTxdataTrace+".to_addr in ?", p.CAddressesTo)),
		)
		sq.
			Where("hash in ?",
				dbRunner.Select("hash").From(subq.As("to_sq")),
			)
	}

	if len(p.CAddressesFrom) > 0 {
		subq := createdatefilter(db.TableCvmTransactionsTxdataTrace,
			blockfilter(dbRunner.Select(db.TableCvmTransactionsTxdataTrace+".hash").From(db.TableCvmTransactionsTxdataTrace).
				Where(db.TableCvmTransactionsTxdataTrace+".from_addr in ?", p.CAddressesFrom)),
		)
		sq.
			Where("hash in ?",
				dbRunner.Select("hash").From(subq.As("from_sq")),
			)
	}

	if len(p.CAddresses) > 0 {
		subqto := createdatefilter(db.TableCvmTransactionsTxdataTrace,
			blockfilter(dbRunner.Select(db.TableCvmTransactionsTxdataTrace+".hash").From(db.TableCvmTransactionsTxdataTrace).
				Where(db.TableCvmTransactionsTxdataTrace+".to_addr in ?", p.CAddresses)),
		)
		subqfrom := createdatefilter(db.TableCvmTransactionsTxdataTrace,
			blockfilter(dbRunner.Select(db.TableCvmTransactionsTxdataTrace+".hash").From(db.TableCvmTransactionsTxdataTrace).
				Where(db.TableCvmTransactionsTxdataTrace+".from_addr in ?", p.CAddresses)),
		)
		subqrcpt := createdatefilter(db.TableCvmTransactionsTxdata,
			blockrcptfilter(dbRunner.Select(db.TableCvmTransactionsTxdata+".hash").From(db.TableCvmTransactionsTxdata).
				Where("rcpt in ?", p.CAddresses)),
		)
		sq.
			Where("hash in ?",
				dbRunner.Select("hash").From(dbr.Union(subqto, subqfrom, subqrcpt).As("to_from_sq")),
			)
	}

	blockrcptfilter(sq)
}

func (r *Reader) handleDressTraces(ctx context.Context, dbRunner *dbr.Session, hashes []string, trItemsByHash map[string]*models.CTransactionData) error {
	if len(hashes) == 0 {
		return nil
	}
	var err error
	var txTransactionTraceServices []*db.CvmTransactionsTxdataTrace
	_, err = dbRunner.Select(
		"hash",
		"idx",
		"to_addr",
		"from_addr",
		"call_type",
		"type",
		"serialization",
		"created_at",
	).From(db.TableCvmTransactionsTxdataTrace).
		Where("hash in ?", hashes).
		LoadContext(ctx, &txTransactionTraceServices)
	if err != nil {
		return err
	}

	for _, txTransactionTraceService := range txTransactionTraceServices {
		txTransactionTraceModel := &models.CvmTransactionsTxDataTrace{}
		err = json.Unmarshal(txTransactionTraceService.Serialization, txTransactionTraceModel)
		if err != nil {
			return err
		}
		if txTransactionTraceService.Idx == 0 {
			trItemsByHash[txTransactionTraceService.Hash].ToAddr = txTransactionTraceModel.ToAddr
			trItemsByHash[txTransactionTraceService.Hash].FromAddr = txTransactionTraceModel.FromAddr
		}

		toDecimal := func(v *string) {
			vh := strings.TrimPrefix(*v, "0x")
			vInt, okVInt := big.NewInt(0).SetString(vh, 16)
			if okVInt && vInt != nil {
				*v = vInt.String()
			}
		}
		toDecimal(&txTransactionTraceModel.Value)
		toDecimal(&txTransactionTraceModel.Gas)
		toDecimal(&txTransactionTraceModel.GasUsed)

		nilEmpty := func(v *string, def string) *string {
			if v != nil && *v == def {
				return nil
			}
			return v
		}
		txTransactionTraceModel.CreatedContractAddressHash = nilEmpty(txTransactionTraceModel.CreatedContractAddressHash, "")
		txTransactionTraceModel.Init = nilEmpty(txTransactionTraceModel.Init, "")
		txTransactionTraceModel.CreatedContractCode = nilEmpty(txTransactionTraceModel.CreatedContractCode, "")
		txTransactionTraceModel.Error = nilEmpty(txTransactionTraceModel.Error, "")
		txTransactionTraceModel.Input = nilEmpty(txTransactionTraceModel.Input, "0x")
		txTransactionTraceModel.Output = nilEmpty(txTransactionTraceModel.Output, "0x")

		if trItemsByHash[txTransactionTraceService.Hash].TracesMap == nil {
			trItemsByHash[txTransactionTraceService.Hash].TracesMap = make(map[uint32]*models.CvmTransactionsTxDataTrace)
		}
		if txTransactionTraceService.Idx+1 > trItemsByHash[txTransactionTraceService.Hash].TracesMax {
			trItemsByHash[txTransactionTraceService.Hash].TracesMax = txTransactionTraceService.Idx + 1
		}
		trItemsByHash[txTransactionTraceService.Hash].TracesMap[txTransactionTraceService.Idx] = txTransactionTraceModel

		txTransactionTraceModel.RevertReason = nilEmpty(txTransactionTraceModel.RevertReason, "reverted 0x")
		if txTransactionTraceModel.RevertReason != nil {
			revVal := *txTransactionTraceModel.RevertReason
			if strings.HasPrefix(revVal, "reverted 0x") {
				*txTransactionTraceModel.RevertReason = "0x" + revVal[11:]
				revertReason, err := hex.DecodeString(revVal[11:])
				if err == nil {
					revertReasonString, err := abi.UnpackRevert(revertReason)
					if err == nil {
						txTransactionTraceModel.RevertReasonUnpacked = &revertReasonString
					}
				}
			}
		}
	}

	return nil
}

func (r *Reader) fetchAndDecodeCBlocks(ctx context.Context, dbRunner *dbr.Session, blocks []string) (map[string]*modelsc.Block, error) {
	var err error
	cblocksMap := make(map[string]*modelsc.Block)

	if len(blocks) > 0 {
		var cvmTxs []*db.CvmTransactions
		_, err = dbRunner.Select(
			"cast(block as char) as block",
			"serialization",
		).From(db.TableCvmTransactions).
			Where("block in ("+strings.Join(blocks, ",")+")").
			LoadContext(ctx, &cvmTxs)
		if err != nil {
			return nil, err
		}

		for _, cvmTx := range cvmTxs {
			cblockv, err := modelsc.Unmarshal(cvmTx.Serialization)
			if err != nil {
				return nil, err
			}
			cblocksMap[cvmTx.Block] = cblockv
		}
	}

	return cblocksMap, nil
}