Merge pull request #64 from irisnet/hotfix/0.2.0

Hotfix/0.2.0

Author: zhangyelong

.gitignore

@@ -1,2 +1,5 @@
 vendor
-.idea
+.idea
+build/
+*.out
+iris*

cmd/iriscli/lcd.go

@@ -81,5 +81,6 @@ func createHandler(cdc *wire.Codec) http.Handler {
 	ibc.RegisterRoutes(ctx.GetCosmosCtx(), r, cdc, kb)
 	stake.RegisterRoutes(ctx.GetCosmosCtx(), r, cdc, kb)
 	RegisterRoutes(ctx, r, cdc, kb)
+	RegisterStakeExRate(ctx.GetCosmosCtx(), r, cdc)
 	return r
 }

cmd/iriscli/shares.go

@@ -0,0 +1,132 @@
+package main
+
+import (
+	"github.com/gorilla/mux"
+	"net/http"
+	"github.com/cosmos/cosmos-sdk/x/stake"
+	"github.com/cosmos/cosmos-sdk/client/context"
+	cmn "github.com/tendermint/tmlibs/common"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/wire"
+	"encoding/json"
+)
+
+type ExRateResponse struct {
+	ExRate float64 `json:"token_shares_rate"`
+}
+
+
+func RegisterStakeExRate(ctx context.CoreContext, r *mux.Router, cdc *wire.Codec) {
+	r.HandleFunc("/stake/validator/{valAddr}/exRate", GetValidatorExRate(ctx, cdc)).Methods("GET")
+}
+
+func GetValidatorExRate(ctx context.CoreContext, cdc *wire.Codec) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		vars := mux.Vars(r)
+		valAddr := vars["valAddr"]
+		validatorAddr, err := sdk.GetAccAddressBech32(valAddr)
+
+		// get validator
+		validator, err := getValidator(validatorAddr, ctx, cdc)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte(err.Error()))
+			return
+		}
+		if validator.Owner == nil {
+			w.WriteHeader(http.StatusBadRequest)
+			w.Write([]byte("validator not exist"))
+			return
+		}
+
+		//poolShares, _ := validator.PoolShares.Amount.Float64()
+		//delegatorShares, _ := validator.DelegatorShares.Float64()
+		//fmt.Printf("validator address is %v, poolShares is %v, delegator shares is %v\n",
+		//	validator.Owner.String(), poolShares, delegatorShares)
+
+		// get pool
+		pool, err := getPool(ctx, cdc)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte(err.Error()))
+			return
+		}
+
+		// validator exRate
+		valExRate := validator.DelegatorShareExRate(pool)
+
+		// pool exRate
+		poolExRate := bondedShareExRate(pool)
+
+
+		exRate := poolExRate.Mul(valExRate)
+
+
+
+		//floatValRate, _ := valExRate.Float64()
+		//floatPoolExRate, _ := poolExRate.Float64()
+		//fmt.Printf("valRate is %v, poolRate is %v\n", floatValRate, floatPoolExRate)
+
+
+		floatExRate, _ := exRate.Float64()
+		res := ExRateResponse{
+			ExRate: floatExRate,
+		}
+
+		//fmt.Printf("exRate is %v\n", floatExRate)
+
+		resRaw, err := json.Marshal(res)
+
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte(err.Error()))
+			return
+		}
+
+		w.Write(resRaw)
+	}
+}
+
+func getPool(ctx context.CoreContext, cdc *wire.Codec) (stake.Pool, error) {
+	var (
+		res []byte
+		pool stake.Pool
+	)
+	res, err := query(ctx, stake.PoolKey)
+	if err != nil {
+		return pool, err
+	}
+
+	cdc.MustUnmarshalBinary(res, &pool)
+
+	return pool, err
+}
+
+func getValidator(address sdk.Address, ctx context.CoreContext, cdc *wire.Codec) (stake.Validator, error)  {
+	var (
+		res []byte
+		validator stake.Validator
+	)
+	res, err := query(ctx, stake.GetValidatorKey(address))
+	if err != nil {
+		return validator, err
+	}
+
+	cdc.MustUnmarshalBinary(res, &validator)
+
+	return validator, err
+}
+
+// get the exchange rate of bonded token per issued share
+func bondedShareExRate(p stake.Pool) sdk.Rat {
+	if p.BondedShares.IsZero() {
+		return sdk.OneRat()
+	}
+	return sdk.NewRat(p.BondedTokens).Quo(p.BondedShares)
+}
+
+func query(ctx context.CoreContext, key cmn.HexBytes) ([]byte, error) {
+	res, err := ctx.Query(key, "stake")
+	return res, err
+}
+