Saves validator to right address

internal/indexer/logs.go

@@ -1,11 +1,14 @@
 package indexer
 
 import (
+	"math/big"
 	"strings"
 
 	"github.com/Taraxa-project/taraxa-indexer/internal/chain"
 	"github.com/Taraxa-project/taraxa-indexer/internal/storage"
 	"github.com/Taraxa-project/taraxa-indexer/models"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/common/hexutil"
 )
 
 func (bc *blockContext) processTransactionLogs(tx chain.Transaction) (err error) {
@@ -34,18 +37,36 @@ func (bc *blockContext) handleValidatorRegistrations(logs []models.EventLog) (er
 		if strings.Compare(log.Topics[0], registerValidatorTopic) != 0 && strings.Compare(log.Address, "0x00000000000000000000000000000000000000fe") != 0 {
 			continue
 		}
-		addressStats := bc.addressStats[log.Address]
+		address, err := decodePaddedAddress(log.Topics[1])
+		if err != nil {
+			return err
+		}
+		addressStats := bc.addressStats[address.Hex()]
 		if addressStats == nil {
 			addressStats = &storage.AddressStats{
-				Address: log.Address,
+				Address: address.Hex(),
 				StatsResponse: models.StatsResponse{
 					ValidatorRegisteredBlock: &bc.block.Number,
 				},
 			}
 		} else {
 			addressStats.ValidatorRegisteredBlock = &bc.block.Number
 		}
-		bc.addressStats[log.Address] = addressStats
+		bc.addressStats[address.Hex()] = addressStats
 	}
 	return nil
 }
+
+func decodePaddedAddress(hexStr string) (common.Address, error) {
+	// Decode the hex string to bytes.
+	bytes, err := hexutil.Decode(hexStr)
+	if err != nil {
+		return common.Address{}, err
+	}
+
+	// Convert bytes to big.Int.
+	bigInt := new(big.Int).SetBytes(bytes)
+	// convert to uint64
+	address := common.BigToAddress(bigInt)
+	return address, nil
+}