mixinnet_number.go

package mixin

import (
	"fmt"
	"math"
	"math/big"
	"strconv"
	"strings"

	"github.com/fox-one/msgpack"
	"github.com/shopspring/decimal"
)

const Precision = 8

var Zero Integer

type (
	Integer struct {
		i big.Int
	}
)

func init() {
	msgpack.RegisterExt(0, (*Integer)(nil))
	Zero = NewInteger(0)
}

func NewInteger(x uint64) (v Integer) {
	p := new(big.Int).SetUint64(x)
	d := big.NewInt(int64(math.Pow(10, Precision)))
	v.i.Mul(p, d)
	return
}

func NewIntegerFromDecimal(d decimal.Decimal) (v Integer) {
	if d.Sign() <= 0 {
		panic(d)
	}
	s := d.Mul(decimal.New(1, Precision)).StringFixed(0)
	v.i.SetString(s, 10)
	return
}

func NewIntegerFromString(x string) (v Integer) {
	d, err := decimal.NewFromString(x)
	if err != nil {
		panic(err)
	}
	if d.Sign() <= 0 {
		panic(x)
	}
	s := d.Mul(decimal.New(1, Precision)).StringFixed(0)
	v.i.SetString(s, 10)
	return
}

func (x Integer) Add(y Integer) (v Integer) {
	if x.Sign() < 0 || y.Sign() <= 0 {
		panic(fmt.Sprint(x, y))
	}

	v.i.Add(&x.i, &y.i)
	if v.Cmp(x) < 0 || v.Cmp(y) < 0 {
		panic(fmt.Sprint(x, y))
	}
	return
}

func (x Integer) Sub(y Integer) (v Integer) {
	if x.Sign() < 0 || y.Sign() <= 0 {
		panic(fmt.Sprint(x, y))
	}
	if x.Cmp(y) < 0 {
		panic(fmt.Sprint(x, y))
	}

	v.i.Sub(&x.i, &y.i)
	return
}

func (x Integer) Mul(y int) (v Integer) {
	if x.Sign() < 0 || y <= 0 {
		panic(fmt.Sprint(x, y))
	}

	v.i.Mul(&x.i, big.NewInt(int64(y)))
	return
}

func (x Integer) Div(y int) (v Integer) {
	if x.Sign() < 0 || y <= 0 {
		panic(fmt.Sprint(x, y))
	}

	v.i.Div(&x.i, big.NewInt(int64(y)))
	return
}

func (x Integer) Count(y Integer) uint64 {
	if x.Sign() <= 0 || y.Sign() <= 0 || x.Cmp(y) < 0 {
		panic(fmt.Sprint(x, y))
	}
	c := new(big.Int).Div(&x.i, &y.i)
	if !c.IsUint64() {
		panic(fmt.Sprint(x, y))
	}
	return c.Uint64()
}

func (x Integer) Cmp(y Integer) int {
	return x.i.Cmp(&y.i)
}

func (x Integer) Sign() int {
	return x.i.Sign()
}

func (x Integer) String() string {
	s := x.i.String()
	p := len(s) - Precision
	if p > 0 {
		return s[:p] + "." + s[p:]
	}
	return "0." + strings.Repeat("0", -p) + s
}

func (x Integer) MarshalMsgpack() ([]byte, error) {
	return x.i.Bytes(), nil
}

func (x *Integer) UnmarshalMsgpack(data []byte) error {
	x.i.SetBytes(data)
	return nil
}

func (x Integer) MarshalJSON() ([]byte, error) {
	s := x.String()
	return []byte(strconv.Quote(s)), nil
}

func (x *Integer) UnmarshalJSON(b []byte) error {
	unquoted, err := strconv.Unquote(string(b))
	if err != nil {
		return err
	}
	i := NewIntegerFromString(unquoted)
	x.i.SetBytes(i.i.Bytes())
	return nil
}