Implement RPC subcommands

Turned out the tendermint rpc was broken in the refactor and
had to fix that first...

client/rpc/block.go

@@ -0,0 +1,63 @@
+package rpc
+
+import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+const (
+	flagSelect = "select"
+)
+
+func blockCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "block [height]",
+		Short: "Get verified data for a the block at given height",
+		RunE:  getBlock,
+	}
+	cmd.Flags().StringP(client.FlagNode, "n", "tcp://localhost:46657", "Node to connect to")
+	// TODO: change this to false when we can
+	cmd.Flags().Bool(client.FlagTrustNode, true, "Don't verify proofs for responses")
+	cmd.Flags().StringSlice(flagSelect, []string{"header", "tx"}, "Fields to return (header|txs|results)")
+	return cmd
+}
+
+func getBlock(cmd *cobra.Command, args []string) error {
+	var height *int64
+	// optional height
+	if len(args) > 0 {
+		h, err := strconv.Atoi(args[0])
+		if err != nil {
+			return err
+		}
+		if h > 0 {
+			tmp := int64(h)
+			height = &tmp
+		}
+	}
+
+	// get the node
+	uri := viper.GetString(client.FlagNode)
+	node := client.GetNode(uri)
+
+	// TODO: actually honor the --select flag!
+	// header -> BlockchainInfo
+	// header, tx -> Block
+	// results -> BlockResults
+	res, err := node.Block(height)
+	if err != nil {
+		return err
+	}
+
+	output, err := json.MarshalIndent(res, "  ", "")
+	if err != nil {
+		return err
+	}
+	fmt.Println(string(output))
+	return nil
+}

client/rpc/root.go

@@ -7,33 +7,23 @@ import (
 	"github.com/cosmos/cosmos-sdk/client"
 )
 
-// XXX: remove this when not needed
-func todoNotImplemented(_ *cobra.Command, _ []string) error {
-	return errors.New("TODO: Command not yet implemented")
-}
-
 const (
 	// one of the following should be provided to verify the connection
 	flagGenesis = "genesis"
 	flagCommit  = "commit"
 	flagValHash = "validator-set"
-
-	flagSelect = "select"
 )
 
-var (
-	statusCmd = &cobra.Command{
-		Use:   "status",
-		Short: "Query remote node for status",
-		RunE:  todoNotImplemented,
-	}
-)
+// XXX: remove this when not needed
+func todoNotImplemented(_ *cobra.Command, _ []string) error {
+	return errors.New("TODO: Command not yet implemented")
+}
 
 // AddCommands adds a number of rpc-related subcommands
 func AddCommands(cmd *cobra.Command) {
 	cmd.AddCommand(
 		initClientCommand(),
-		statusCmd,
+		statusCommand(),
 		blockCommand(),
 		validatorCommand(),
 	)
@@ -52,22 +42,3 @@ func initClientCommand() *cobra.Command {
 	cmd.Flags().String(flagValHash, "", "Hash of trusted validator set (hex-encoded)")
 	return cmd
 }
-
-func blockCommand() *cobra.Command {
-	cmd := &cobra.Command{
-		Use:   "block <height>",
-		Short: "Get verified data for a the block at given height",
-		RunE:  todoNotImplemented,
-	}
-	cmd.Flags().StringSlice(flagSelect, []string{"header", "tx"}, "Fields to return (header|txs|results)")
-	return cmd
-}
-
-func validatorCommand() *cobra.Command {
-	cmd := &cobra.Command{
-		Use:   "validatorset <height>",
-		Short: "Get the full validator set at given height",
-		RunE:  todoNotImplemented,
-	}
-	return cmd
-}

client/rpc/status.go

@@ -0,0 +1,38 @@
+package rpc
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+
+	"github.com/cosmos/cosmos-sdk/client"
+)
+
+func statusCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "status",
+		Short: "Query remote node for status",
+		RunE:  checkStatus,
+	}
+	cmd.Flags().StringP(client.FlagNode, "n", "tcp://localhost:46657", "Node to connect to")
+	return cmd
+}
+
+func checkStatus(cmd *cobra.Command, args []string) error {
+	// get the node
+	uri := viper.GetString(client.FlagNode)
+	node := client.GetNode(uri)
+	res, err := node.Status()
+	if err != nil {
+		return err
+	}
+
+	output, err := json.MarshalIndent(res, "  ", "")
+	if err != nil {
+		return err
+	}
+	fmt.Println(string(output))
+	return nil
+}

client/rpc/validators.go

@@ -0,0 +1,55 @@
+package rpc
+
+import (
+	"encoding/json"
+	"fmt"
+	"strconv"
+
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+
+	"github.com/cosmos/cosmos-sdk/client"
+)
+
+func validatorCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "validatorset <height>",
+		Short: "Get the full validator set at given height",
+		RunE:  getValidators,
+	}
+	cmd.Flags().StringP(client.FlagNode, "n", "tcp://localhost:46657", "Node to connect to")
+	// TODO: change this to false when we can
+	cmd.Flags().Bool(client.FlagTrustNode, true, "Don't verify proofs for responses")
+	return cmd
+}
+
+func getValidators(cmd *cobra.Command, args []string) error {
+	var height *int64
+	// optional height
+	if len(args) > 0 {
+		h, err := strconv.Atoi(args[0])
+		if err != nil {
+			return err
+		}
+		if h > 0 {
+			tmp := int64(h)
+			height = &tmp
+		}
+	}
+
+	// get the node
+	uri := viper.GetString(client.FlagNode)
+	node := client.GetNode(uri)
+
+	res, err := node.Validators(height)
+	if err != nil {
+		return err
+	}
+
+	output, err := json.MarshalIndent(res, "  ", "")
+	if err != nil {
+		return err
+	}
+	fmt.Println(string(output))
+	return nil
+}