85 lines
2.0 KiB
Go
85 lines
2.0 KiB
Go
package rest
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strconv"
|
|
|
|
"github.com/gorilla/mux"
|
|
"github.com/spf13/viper"
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk"
|
|
"github.com/cosmos/cosmos-sdk/client"
|
|
"github.com/cosmos/cosmos-sdk/client/commands"
|
|
"github.com/cosmos/cosmos-sdk/client/commands/query"
|
|
"github.com/cosmos/cosmos-sdk/errors"
|
|
"github.com/cosmos/cosmos-sdk/modules/coin"
|
|
"github.com/cosmos/cosmos-sdk/modules/nonce"
|
|
"github.com/cosmos/cosmos-sdk/stack"
|
|
wire "github.com/tendermint/go-wire"
|
|
"github.com/tendermint/tmlibs/common"
|
|
)
|
|
|
|
// doQueryNonce is the HTTP handlerfunc to query a nonce
|
|
func doQueryNonce(w http.ResponseWriter, r *http.Request) {
|
|
args := mux.Vars(r)
|
|
signature := args["signature"]
|
|
actor, err := commands.ParseActor(signature)
|
|
if err != nil {
|
|
common.WriteError(w, err)
|
|
return
|
|
}
|
|
|
|
var h int
|
|
qHeight := r.URL.Query().Get("height")
|
|
if qHeight != "" {
|
|
h, err = strconv.Atoi(qHeight)
|
|
if err != nil {
|
|
common.WriteError(w, err)
|
|
return
|
|
}
|
|
}
|
|
|
|
actor = coin.ChainAddr(actor)
|
|
key := nonce.GetSeqKey([]sdk.Actor{actor})
|
|
key = stack.PrefixedKey(nonce.NameNonce, key)
|
|
|
|
prove := !viper.GetBool(commands.FlagTrustNode)
|
|
|
|
// query sequence number
|
|
data, height, err := query.Get(key, h, prove)
|
|
if client.IsNoDataErr(err) {
|
|
err = fmt.Errorf("nonce empty for address: %q", signature)
|
|
common.WriteError(w, err)
|
|
return
|
|
} else if err != nil {
|
|
common.WriteError(w, err)
|
|
return
|
|
}
|
|
|
|
// unmarshal sequence number
|
|
var seq uint32
|
|
err = wire.ReadBinaryBytes(data, &seq)
|
|
if err != nil {
|
|
msg := fmt.Sprintf("Error reading sequence for %X", key)
|
|
common.WriteError(w, errors.ErrInternal(msg))
|
|
return
|
|
}
|
|
|
|
// write result to client
|
|
if err := query.FoutputProof(w, seq, height); err != nil {
|
|
common.WriteError(w, err)
|
|
}
|
|
}
|
|
|
|
// mux.Router registrars
|
|
|
|
// RegisterQueryNonce is a mux.Router handler that exposes GET
|
|
// method access on route /query/nonce/{signature} to query nonces
|
|
func RegisterQueryNonce(r *mux.Router) error {
|
|
r.HandleFunc("/query/nonce/{signature}", doQueryNonce).Methods("GET")
|
|
return nil
|
|
}
|
|
|
|
// End of mux.Router registrars
|