Add cli to basecoind, fix compatability issues

This commit is contained in:
Ethan Frey 2018-02-21 10:57:51 +01:00 committed by rigelrozanski
parent c0f9a6f1cb
commit 4e91a0db89
3 changed files with 62 additions and 20 deletions

View File

@ -1,27 +1,70 @@
package main package main
import ( import (
"encoding/json"
"fmt" "fmt"
"os" "os"
"github.com/spf13/cobra"
"github.com/tendermint/tmlibs/cli"
dbm "github.com/tendermint/tmlibs/db" dbm "github.com/tendermint/tmlibs/db"
"github.com/tendermint/tmlibs/log" "github.com/tendermint/tmlibs/log"
"github.com/cosmos/cosmos-sdk/baseapp"
"github.com/cosmos/cosmos-sdk/examples/basecoin/app" "github.com/cosmos/cosmos-sdk/examples/basecoin/app"
"github.com/cosmos/cosmos-sdk/server"
"github.com/cosmos/cosmos-sdk/version"
) )
func main() { // gaiadCmd is the entry point for this binary
fmt.Println("This is temporary, for unblocking our build process.") var (
return gaiadCmd = &cobra.Command{
Use: "gaiad",
Short: "Gaia Daemon (server)",
}
)
// TODO CREATE CLI // defaultOptions sets up the app_options for the
// default genesis file
func defaultOptions(args []string) (json.RawMessage, error) {
addr, secret, err := server.GenerateCoinKey()
if err != nil {
return nil, err
}
fmt.Println("Secret phrase to access coins:")
fmt.Println(secret)
opts := fmt.Sprintf(`{
"accounts": [{
"address": "%s",
"coins": [
{
"denom": "mycoin",
"amount": 9007199254740992
}
]
}]
}`, addr)
return json.RawMessage(opts), nil
}
func main() {
logger := log.NewTMLogger(log.NewSyncWriter(os.Stdout)).With("module", "main") logger := log.NewTMLogger(log.NewSyncWriter(os.Stdout)).With("module", "main")
db, err := dbm.NewGoLevelDB("basecoind", "data") db, err := dbm.NewGoLevelDB("/tmp/basecoind", "data")
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
os.Exit(1) os.Exit(1)
} }
bapp := app.NewBasecoinApp(logger, db) bapp := app.NewBasecoinApp(logger, db)
baseapp.RunForever(bapp)
gaiadCmd.AddCommand(
server.InitCmd(defaultOptions),
server.StartCmd(bapp, bapp.Logger),
server.UnsafeResetAllCmd(bapp.Logger),
version.VersionCmd,
)
// prepare and add flags
executor := cli.PrepareBaseCmd(gaiadCmd, "GA", os.ExpandEnv("$HOME/.gaiad"))
executor.Execute()
} }

View File

@ -52,7 +52,7 @@ func main() {
gaiadCmd.AddCommand( gaiadCmd.AddCommand(
server.InitCmd(defaultOptions), server.InitCmd(defaultOptions),
server.StartCmd(app), server.StartCmd(app, app.Logger),
server.UnsafeResetAllCmd(app.Logger), server.UnsafeResetAllCmd(app.Logger),
version.VersionCmd, version.VersionCmd,
) )

View File

@ -6,14 +6,14 @@ import (
"github.com/spf13/viper" "github.com/spf13/viper"
"github.com/tendermint/abci/server" "github.com/tendermint/abci/server"
abci "github.com/tendermint/abci/types"
tcmd "github.com/tendermint/tendermint/cmd/tendermint/commands" tcmd "github.com/tendermint/tendermint/cmd/tendermint/commands"
"github.com/tendermint/tendermint/node" "github.com/tendermint/tendermint/node"
"github.com/tendermint/tendermint/proxy" "github.com/tendermint/tendermint/proxy"
"github.com/tendermint/tendermint/types" "github.com/tendermint/tendermint/types"
cmn "github.com/tendermint/tmlibs/common" cmn "github.com/tendermint/tmlibs/common"
"github.com/tendermint/tmlibs/log"
"github.com/cosmos/cosmos-sdk/baseapp"
) )
const ( const (
@ -23,9 +23,10 @@ const (
// StartCmd runs the service passed in, either // StartCmd runs the service passed in, either
// stand-alone, or in-process with tendermint // stand-alone, or in-process with tendermint
func StartCmd(app *baseapp.BaseApp) *cobra.Command { func StartCmd(app abci.Application, logger log.Logger) *cobra.Command {
start := startCmd{ start := startCmd{
app: app, app: app,
logger: logger,
} }
cmd := &cobra.Command{ cmd := &cobra.Command{
Use: "start", Use: "start",
@ -46,28 +47,27 @@ type startCmd struct {
// do this in main: // do this in main:
// rootDir := viper.GetString(cli.HomeFlag) // rootDir := viper.GetString(cli.HomeFlag)
// node.Logger = .... // node.Logger = ....
app *baseapp.BaseApp app abci.Application
logger log.Logger
} }
func (s startCmd) run(cmd *cobra.Command, args []string) error { func (s startCmd) run(cmd *cobra.Command, args []string) error {
logger := s.app.Logger
if !viper.GetBool(flagWithTendermint) { if !viper.GetBool(flagWithTendermint) {
logger.Info("Starting ABCI without Tendermint") s.logger.Info("Starting ABCI without Tendermint")
return s.startStandAlone() return s.startStandAlone()
} }
logger.Info("Starting ABCI with Tendermint") s.logger.Info("Starting ABCI with Tendermint")
return s.startInProcess() return s.startInProcess()
} }
func (s startCmd) startStandAlone() error { func (s startCmd) startStandAlone() error {
logger := s.app.Logger
// Start the ABCI listener // Start the ABCI listener
addr := viper.GetString(flagAddress) addr := viper.GetString(flagAddress)
svr, err := server.NewServer(addr, "socket", s.app) svr, err := server.NewServer(addr, "socket", s.app)
if err != nil { if err != nil {
return errors.Errorf("Error creating listener: %v\n", err) return errors.Errorf("Error creating listener: %v\n", err)
} }
svr.SetLogger(logger.With("module", "abci-server")) svr.SetLogger(s.logger.With("module", "abci-server"))
svr.Start() svr.Start()
// Wait forever // Wait forever
@ -79,7 +79,6 @@ func (s startCmd) startStandAlone() error {
} }
func (s startCmd) startInProcess() error { func (s startCmd) startInProcess() error {
logger := s.app.Logger
cfg, err := tcmd.ParseConfig() cfg, err := tcmd.ParseConfig()
if err != nil { if err != nil {
return err return err
@ -91,7 +90,7 @@ func (s startCmd) startInProcess() error {
proxy.NewLocalClientCreator(s.app), proxy.NewLocalClientCreator(s.app),
node.DefaultGenesisDocProviderFunc(cfg), node.DefaultGenesisDocProviderFunc(cfg),
node.DefaultDBProvider, node.DefaultDBProvider,
logger.With("module", "node")) s.logger.With("module", "node"))
if err != nil { if err != nil {
return err return err
} }