qkc/types: add token balances

qkc/types/token.go

@@ -0,0 +1,319 @@
+// Copyright 2026-2027, QuarkChain.
+
+// Token balance encoding follows pyquarkchain-compatible QKC wire bytes.
+
+package types
+
+import (
+	"bytes"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"math/big"
+	"sort"
+	"strconv"
+	"strings"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/qkc/serialize"
+	"github.com/ethereum/go-ethereum/rlp"
+	"github.com/holiman/uint256"
+)
+
+type TokenBalancePair struct {
+	TokenID uint64
+	Balance *uint256.Int
+}
+
+type TokenBalances struct {
+	balances map[uint64]*uint256.Int
+}
+
+type TokenBalancesAlias TokenBalances
+
+func (t *TokenBalances) MarshalJSON() ([]byte, error) {
+	keys := make([]uint64, 0, len(t.balances))
+	for key := range t.balances {
+		keys = append(keys, key)
+	}
+	sort.Slice(keys, func(i, j int) bool { return keys[i] < keys[j] })
+	balances := make([]string, 0, len(keys))
+	for _, key := range keys {
+		val := t.balances[key]
+		balance := "0"
+		if val != nil {
+			balance = val.Dec()
+		}
+		balances = append(balances, strconv.FormatUint(key, 10)+":"+balance)
+	}
+	jsoncfg := struct {
+		TokenBalancesAlias
+		Balances string `json:"balances"`
+	}{TokenBalancesAlias: TokenBalancesAlias(*t), Balances: strings.Join(balances, ",")}
+	return json.Marshal(jsoncfg)
+}
+
+func (t *TokenBalances) UnmarshalJSON(input []byte) error {
+	var jsoncfg struct {
+		TokenBalancesAlias
+		Balances string `json:"balances"`
+	}
+	if err := json.Unmarshal(input, &jsoncfg); err != nil {
+		return err
+	}
+	*t = TokenBalances(jsoncfg.TokenBalancesAlias)
+	t.balances = make(map[uint64]*uint256.Int)
+	if jsoncfg.Balances == "" {
+		return nil
+	}
+	balList := strings.Split(jsoncfg.Balances, ",")
+	for _, val := range balList {
+		parts := strings.SplitN(val, ":", 2)
+		if len(parts) != 2 {
+			return fmt.Errorf("invalid token balance entry: %q", val)
+		}
+		key, err := strconv.ParseUint(parts[0], 10, 64)
+		if err != nil {
+			return fmt.Errorf("invalid token id %q: %w", parts[0], err)
+		}
+		balance, err := uint256.FromDecimal(parts[1])
+		if err != nil {
+			return fmt.Errorf("invalid token balance %q: %w", parts[1], err)
+		}
+		t.balances[key] = balance
+	}
+	return nil
+}
+
+func NewEmptyTokenBalances() *TokenBalances {
+	return &TokenBalances{
+		balances: make(map[uint64]*uint256.Int),
+	}
+}
+
+func NewTokenBalancesWithMap(data map[uint64]*uint256.Int) *TokenBalances {
+	t := &TokenBalances{
+		balances: make(map[uint64]*uint256.Int, len(data)),
+	}
+	for tokenID, balance := range data {
+		if balance == nil {
+			continue
+		}
+		t.balances[tokenID] = new(uint256.Int).Set(balance)
+	}
+	return t
+}
+
+func NewTokenBalances(data []byte) (*TokenBalances, error) {
+	tokenBalances := NewEmptyTokenBalances()
+	if len(data) == 0 {
+		return tokenBalances, nil
+	}
+
+	switch data[0] {
+	case byte(0):
+		balanceList := make([]*TokenBalancePair, 0)
+		if err := rlp.DecodeBytes(data[1:], &balanceList); err != nil {
+			return nil, err
+		}
+		for _, v := range balanceList {
+			if v == nil || v.Balance == nil {
+				continue
+			}
+			tokenBalances.balances[v.TokenID] = new(uint256.Int).Set(v.Balance)
+		}
+	case byte(1):
+		return nil, errors.New("token balance trie encoding is unsupported")
+	default:
+		return nil, fmt.Errorf("Unknown enum byte in token_balances:%v", data[0])
+
+	}
+	return tokenBalances, nil
+}
+
+func (t *TokenBalances) Commit() {
+	// TokenBalances is map-backed. Commit is kept as a no-op for callers that
+	// share code with older trie-backed implementations.
+}
+
+func (t *TokenBalances) Add(other map[uint64]*uint256.Int) {
+	for k, v := range other {
+		if v == nil {
+			continue
+		}
+		if data, ok := t.balances[k]; ok {
+			t.balances[k] = new(uint256.Int).Add(v, data)
+		} else {
+			t.balances[k] = new(uint256.Int).Set(v)
+		}
+	}
+}
+
+func (t *TokenBalances) SetValue(amount *uint256.Int, tokenID uint64) {
+	if amount == nil {
+		amount = new(uint256.Int)
+	}
+	t.balances[tokenID] = new(uint256.Int).Set(amount)
+}
+
+func (t *TokenBalances) GetTokenBalance(tokenID uint64) *uint256.Int {
+	data, ok := t.balances[tokenID]
+	if ok {
+		return new(uint256.Int).Set(data)
+	}
+
+	return new(uint256.Int)
+}
+
+func (t *TokenBalances) GetBalanceMap() map[uint64]*uint256.Int {
+	data := t.Copy()
+	return data.balances
+}
+
+func (t *TokenBalances) Len() int {
+	return len(t.balances)
+}
+
+func (t *TokenBalances) nonZeroEntriesInBalancesCache() int {
+	sum := 0
+	for _, v := range t.balances {
+		if v != nil && !v.IsZero() {
+			sum++
+		}
+	}
+	return sum
+}
+
+func (t *TokenBalances) IsBlank() bool {
+	return t.nonZeroEntriesInBalancesCache() == 0
+}
+
+func (t *TokenBalances) Copy() *TokenBalances {
+	balancesCopy := make(map[uint64]*uint256.Int)
+	for k, v := range t.balances {
+		if v == nil {
+			continue
+		}
+		balancesCopy[k] = new(uint256.Int).Set(v)
+	}
+	return &TokenBalances{
+		balances: balancesCopy,
+	}
+}
+
+func (t *TokenBalances) SerializeToBytes() ([]byte, error) {
+	if t.Len() == 0 {
+		return nil, nil
+	}
+	list := make([]*TokenBalancePair, 0)
+	for k, v := range t.balances {
+		if v == nil || v.IsZero() {
+			continue
+		}
+		list = append(list, &TokenBalancePair{
+			TokenID: k,
+			Balance: v,
+		})
+	}
+	if len(list) == 0 {
+		return nil, nil
+	}
+	sort.Slice(list, func(i, j int) bool { return list[i].TokenID < (list[j].TokenID) })
+	rlpData := new(bytes.Buffer)
+	rlpData.WriteByte(byte(0))
+	err := rlp.Encode(rlpData, list)
+	if err != nil {
+		return nil, err
+	}
+	return rlpData.Bytes(), nil
+}
+
+func (t *TokenBalances) EncodeRLP(w io.Writer) error {
+	dataSer, err := t.SerializeToBytes()
+	if err != nil {
+		return err
+	}
+	dataRlp, err := rlp.EncodeToBytes(dataSer)
+	if err != nil {
+		return err
+	}
+	_, err = w.Write(dataRlp)
+	return err
+}
+
+func (t *TokenBalances) DecodeRLP(s *rlp.Stream) error {
+	dataRawBytes, err := s.Raw()
+	if err != nil {
+		return err
+	}
+	dataRlp := new([]byte)
+	err = rlp.DecodeBytes(dataRawBytes, dataRlp)
+	if err != nil {
+		return err
+	}
+	b, err := NewTokenBalances(*dataRlp)
+	if err != nil {
+		return err
+	}
+	(*t).balances = (*b).balances
+	return err
+}
+
+func (t *TokenBalances) Serialize(w *[]byte) error {
+	// Follow pyquarkchain (TokenBalanceMap's PrependedSizeMapSerializer skip_func):
+	// omit zero-balance entries from both the count and the body. This keeps
+	// Serialize/Deserialize symmetric and preserves pyquarkchain-compatible bytes.
+	keys := make([]uint64, 0, t.Len())
+	for k, v := range t.balances {
+		if v == nil || v.IsZero() {
+			continue
+		}
+		keys = append(keys, k)
+	}
+	sort.Slice(keys, func(i, j int) bool { return keys[i] < keys[j] })
+	if err := serialize.Serialize(w, uint32(len(keys))); err != nil {
+		return err
+	}
+	for _, key := range keys {
+		v := t.balances[key]
+		if err := serialize.Serialize(w, new(big.Int).SetUint64(key)); err != nil {
+			return err
+		}
+		if err := serialize.Serialize(w, v.ToBig()); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (t *TokenBalances) Deserialize(bb *serialize.ByteBuffer) error {
+	t.balances = make(map[uint64]*uint256.Int)
+	num, err := bb.GetUInt32()
+	if err != nil {
+		return err
+	}
+	for index := uint32(0); index < num; index++ {
+		k := new(big.Int)
+		if err := serialize.Deserialize(bb, k); err != nil {
+			return err
+		}
+		v := new(big.Int)
+
+		if err := serialize.Deserialize(bb, v); err != nil {
+			return err
+		}
+		if v.Cmp(common.Big0) == 0 {
+			continue
+		}
+		if !k.IsUint64() {
+			return fmt.Errorf("token id overflows uint64: %v", k)
+		}
+		balance, overflow := uint256.FromBig(v)
+		if overflow {
+			return fmt.Errorf("token balance overflows uint256: %v", v)
+		}
+		t.balances[k.Uint64()] = balance
+	}
+	return nil
+}