2018-08-06 11:11:30 -07:00
|
|
|
package context
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
|
|
"github.com/cosmos/cosmos-sdk/x/auth"
|
|
|
|
|
|
|
|
"github.com/pkg/errors"
|
|
|
|
|
2018-08-31 15:22:37 -07:00
|
|
|
"strings"
|
|
|
|
|
2018-09-13 11:17:32 -07:00
|
|
|
"github.com/cosmos/cosmos-sdk/codec"
|
2018-08-30 00:52:17 -07:00
|
|
|
"github.com/cosmos/cosmos-sdk/store"
|
|
|
|
abci "github.com/tendermint/tendermint/abci/types"
|
2018-08-06 11:11:30 -07:00
|
|
|
cmn "github.com/tendermint/tendermint/libs/common"
|
2018-09-14 11:41:21 -07:00
|
|
|
tmliteErr "github.com/tendermint/tendermint/lite/errors"
|
2018-08-30 19:03:48 -07:00
|
|
|
tmliteProxy "github.com/tendermint/tendermint/lite/proxy"
|
2018-08-06 11:11:30 -07:00
|
|
|
rpcclient "github.com/tendermint/tendermint/rpc/client"
|
2018-10-03 08:48:23 -07:00
|
|
|
tmtypes "github.com/tendermint/tendermint/types"
|
2018-08-06 11:11:30 -07:00
|
|
|
)
|
|
|
|
|
|
|
|
// GetNode returns an RPC client. If the context's client is not defined, an
|
|
|
|
// error is returned.
|
|
|
|
func (ctx CLIContext) GetNode() (rpcclient.Client, error) {
|
|
|
|
if ctx.Client == nil {
|
|
|
|
return nil, errors.New("no RPC client defined")
|
|
|
|
}
|
|
|
|
|
|
|
|
return ctx.Client, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// Query performs a query for information about the connected node.
|
2018-08-22 04:38:55 -07:00
|
|
|
func (ctx CLIContext) Query(path string, data cmn.HexBytes) (res []byte, err error) {
|
|
|
|
return ctx.query(path, data)
|
2018-08-06 11:11:30 -07:00
|
|
|
}
|
|
|
|
|
2018-08-04 22:56:48 -07:00
|
|
|
// Query information about the connected node with a data payload
|
|
|
|
func (ctx CLIContext) QueryWithData(path string, data []byte) (res []byte, err error) {
|
|
|
|
return ctx.query(path, data)
|
|
|
|
}
|
|
|
|
|
2018-08-06 11:11:30 -07:00
|
|
|
// QueryStore performs a query from a Tendermint node with the provided key and
|
|
|
|
// store name.
|
|
|
|
func (ctx CLIContext) QueryStore(key cmn.HexBytes, storeName string) (res []byte, err error) {
|
|
|
|
return ctx.queryStore(key, storeName, "key")
|
|
|
|
}
|
|
|
|
|
|
|
|
// QuerySubspace performs a query from a Tendermint node with the provided
|
|
|
|
// store name and subspace.
|
|
|
|
func (ctx CLIContext) QuerySubspace(subspace []byte, storeName string) (res []sdk.KVPair, err error) {
|
|
|
|
resRaw, err := ctx.queryStore(subspace, storeName, "subspace")
|
|
|
|
if err != nil {
|
|
|
|
return res, err
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Codec.MustUnmarshalBinary(resRaw, &res)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
// GetAccount queries for an account given an address and a block height. An
|
|
|
|
// error is returned if the query or decoding fails.
|
|
|
|
func (ctx CLIContext) GetAccount(address []byte) (auth.Account, error) {
|
|
|
|
if ctx.AccDecoder == nil {
|
|
|
|
return nil, errors.New("account decoder required but not provided")
|
|
|
|
}
|
|
|
|
|
|
|
|
res, err := ctx.QueryStore(auth.AddressStoreKey(address), ctx.AccountStore)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
} else if len(res) == 0 {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
account, err := ctx.AccDecoder(res)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return account, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// GetFromAddress returns the from address from the context's name.
|
2018-09-25 13:48:38 -07:00
|
|
|
func (ctx CLIContext) GetFromAddress() (sdk.AccAddress, error) {
|
|
|
|
return ctx.fromAddress, nil
|
|
|
|
}
|
2018-08-06 11:11:30 -07:00
|
|
|
|
2018-09-25 13:48:38 -07:00
|
|
|
// GetFromName returns the key name for the current context.
|
|
|
|
func (ctx CLIContext) GetFromName() (string, error) {
|
|
|
|
return ctx.fromName, nil
|
2018-08-06 11:11:30 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
// GetAccountNumber returns the next account number for the given account
|
|
|
|
// address.
|
|
|
|
func (ctx CLIContext) GetAccountNumber(address []byte) (int64, error) {
|
|
|
|
account, err := ctx.GetAccount(address)
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return account.GetAccountNumber(), nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// GetAccountSequence returns the sequence number for the given account
|
|
|
|
// address.
|
|
|
|
func (ctx CLIContext) GetAccountSequence(address []byte) (int64, error) {
|
|
|
|
account, err := ctx.GetAccount(address)
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return account.GetSequence(), nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// EnsureAccountExists ensures that an account exists for a given context. An
|
|
|
|
// error is returned if it does not.
|
|
|
|
func (ctx CLIContext) EnsureAccountExists() error {
|
|
|
|
addr, err := ctx.GetFromAddress()
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
accountBytes, err := ctx.QueryStore(auth.AddressStoreKey(addr), ctx.AccountStore)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(accountBytes) == 0 {
|
|
|
|
return ErrInvalidAccount(addr)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// EnsureAccountExistsFromAddr ensures that an account exists for a given
|
|
|
|
// address. Instead of using the context's from name, a direct address is
|
|
|
|
// given. An error is returned if it does not.
|
|
|
|
func (ctx CLIContext) EnsureAccountExistsFromAddr(addr sdk.AccAddress) error {
|
|
|
|
accountBytes, err := ctx.QueryStore(auth.AddressStoreKey(addr), ctx.AccountStore)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(accountBytes) == 0 {
|
|
|
|
return ErrInvalidAccount(addr)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// query performs a query from a Tendermint node with the provided store name
|
|
|
|
// and path.
|
2018-08-22 04:38:55 -07:00
|
|
|
func (ctx CLIContext) query(path string, key cmn.HexBytes) (res []byte, err error) {
|
2018-08-06 11:11:30 -07:00
|
|
|
node, err := ctx.GetNode()
|
|
|
|
if err != nil {
|
|
|
|
return res, err
|
|
|
|
}
|
|
|
|
|
|
|
|
opts := rpcclient.ABCIQueryOptions{
|
|
|
|
Height: ctx.Height,
|
|
|
|
Trusted: ctx.TrustNode,
|
|
|
|
}
|
|
|
|
|
|
|
|
result, err := node.ABCIQueryWithOptions(path, key, opts)
|
|
|
|
if err != nil {
|
|
|
|
return res, err
|
|
|
|
}
|
|
|
|
|
|
|
|
resp := result.Response
|
|
|
|
if !resp.IsOK() {
|
2018-10-19 09:55:20 -07:00
|
|
|
return res, errors.Errorf(resp.Log)
|
2018-08-06 11:11:30 -07:00
|
|
|
}
|
|
|
|
|
2018-09-26 06:29:39 -07:00
|
|
|
// data from trusted node or subspace query doesn't need verification
|
2018-08-29 21:50:41 -07:00
|
|
|
if ctx.TrustNode || !isQueryStoreWithProof(path) {
|
|
|
|
return resp.Value, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
err = ctx.verifyProof(path, resp)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
2018-08-06 11:11:30 -07:00
|
|
|
return resp.Value, nil
|
|
|
|
}
|
|
|
|
|
2018-10-03 08:48:23 -07:00
|
|
|
// Verify verifies the consensus proof at given height.
|
|
|
|
func (ctx CLIContext) Verify(height int64) (tmtypes.SignedHeader, error) {
|
|
|
|
check, err := tmliteProxy.GetCertifiedCommit(height, ctx.Client, ctx.Verifier)
|
2018-09-26 06:29:39 -07:00
|
|
|
switch {
|
2018-10-03 08:48:23 -07:00
|
|
|
case tmliteErr.IsErrCommitNotFound(err):
|
|
|
|
return tmtypes.SignedHeader{}, ErrVerifyCommit(height)
|
2018-09-26 06:29:39 -07:00
|
|
|
case err != nil:
|
2018-10-03 08:48:23 -07:00
|
|
|
return tmtypes.SignedHeader{}, err
|
2018-09-14 11:41:21 -07:00
|
|
|
}
|
2018-09-26 06:29:39 -07:00
|
|
|
|
2018-09-14 11:41:21 -07:00
|
|
|
return check, nil
|
|
|
|
}
|
|
|
|
|
2018-09-26 06:29:39 -07:00
|
|
|
// verifyProof perform response proof verification.
|
|
|
|
func (ctx CLIContext) verifyProof(_ string, resp abci.ResponseQuery) error {
|
2018-10-03 08:48:23 -07:00
|
|
|
if ctx.Verifier == nil {
|
2018-09-26 06:29:39 -07:00
|
|
|
return fmt.Errorf("missing valid certifier to verify data from distrusted node")
|
2018-08-29 21:50:41 -07:00
|
|
|
}
|
|
|
|
|
2018-09-26 06:29:39 -07:00
|
|
|
// the AppHash for height H is in header H+1
|
2018-10-03 08:48:23 -07:00
|
|
|
commit, err := ctx.Verify(resp.Height + 1)
|
2018-08-29 21:50:41 -07:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
var multiStoreProof store.MultiStoreProof
|
2018-09-13 11:17:32 -07:00
|
|
|
cdc := codec.New()
|
2018-09-26 06:29:39 -07:00
|
|
|
|
2018-08-29 21:50:41 -07:00
|
|
|
err = cdc.UnmarshalBinary(resp.Proof, &multiStoreProof)
|
|
|
|
if err != nil {
|
2018-08-30 00:52:17 -07:00
|
|
|
return errors.Wrap(err, "failed to unmarshalBinary rangeProof")
|
2018-08-29 21:50:41 -07:00
|
|
|
}
|
|
|
|
|
2018-09-26 06:29:39 -07:00
|
|
|
// verify the substore commit hash against trusted appHash
|
2018-09-14 11:41:21 -07:00
|
|
|
substoreCommitHash, err := store.VerifyMultiStoreCommitInfo(
|
2018-09-26 06:29:39 -07:00
|
|
|
multiStoreProof.StoreName, multiStoreProof.StoreInfos, commit.Header.AppHash,
|
|
|
|
)
|
2018-08-29 21:50:41 -07:00
|
|
|
if err != nil {
|
2018-08-30 00:52:17 -07:00
|
|
|
return errors.Wrap(err, "failed in verifying the proof against appHash")
|
2018-08-29 21:50:41 -07:00
|
|
|
}
|
2018-09-14 11:41:21 -07:00
|
|
|
|
2018-08-29 21:50:41 -07:00
|
|
|
err = store.VerifyRangeProof(resp.Key, resp.Value, substoreCommitHash, &multiStoreProof.RangeProof)
|
|
|
|
if err != nil {
|
2018-08-30 00:52:17 -07:00
|
|
|
return errors.Wrap(err, "failed in the range proof verification")
|
2018-08-29 21:50:41 -07:00
|
|
|
}
|
2018-09-14 11:41:21 -07:00
|
|
|
|
2018-08-29 21:50:41 -07:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2018-08-06 11:11:30 -07:00
|
|
|
// queryStore performs a query from a Tendermint node with the provided a store
|
|
|
|
// name and path.
|
|
|
|
func (ctx CLIContext) queryStore(key cmn.HexBytes, storeName, endPath string) ([]byte, error) {
|
|
|
|
path := fmt.Sprintf("/store/%s/%s", storeName, endPath)
|
|
|
|
return ctx.query(path, key)
|
|
|
|
}
|
2018-08-29 21:50:41 -07:00
|
|
|
|
|
|
|
// isQueryStoreWithProof expects a format like /<queryType>/<storeName>/<subpath>
|
2018-09-26 06:29:39 -07:00
|
|
|
// queryType can be app or store.
|
2018-08-30 00:52:17 -07:00
|
|
|
func isQueryStoreWithProof(path string) bool {
|
2018-08-29 21:50:41 -07:00
|
|
|
if !strings.HasPrefix(path, "/") {
|
|
|
|
return false
|
|
|
|
}
|
2018-09-26 06:29:39 -07:00
|
|
|
|
2018-08-29 21:50:41 -07:00
|
|
|
paths := strings.SplitN(path[1:], "/", 3)
|
|
|
|
if len(paths) != 3 {
|
|
|
|
return false
|
|
|
|
}
|
2018-08-30 19:03:48 -07:00
|
|
|
|
2018-08-30 19:15:37 -07:00
|
|
|
if store.RequireProof("/" + paths[2]) {
|
2018-08-29 21:50:41 -07:00
|
|
|
return true
|
|
|
|
}
|
2018-09-26 06:29:39 -07:00
|
|
|
|
2018-08-29 21:50:41 -07:00
|
|
|
return false
|
|
|
|
}
|