Keep both subcommand: rest-server and lite-server
This commit is contained in:
parent
5f38b50a85
commit
e704f095bd
|
@ -34,11 +34,84 @@ func ServeCommand(cdc *wire.Codec) *cobra.Command {
|
||||||
flagMaxOpenConnections := "max-open"
|
flagMaxOpenConnections := "max-open"
|
||||||
|
|
||||||
cmd := &cobra.Command{
|
cmd := &cobra.Command{
|
||||||
Use: "lite-server",
|
Use: "rest-server",
|
||||||
Short: "Start Gaia-lite server daemon, a local REST server",
|
Short: "Start LCD (light-client daemon), a local REST server",
|
||||||
RunE: func(cmd *cobra.Command, args []string) error {
|
RunE: func(cmd *cobra.Command, args []string) error {
|
||||||
listenAddr := viper.GetString(flagListenAddr)
|
listenAddr := viper.GetString(flagListenAddr)
|
||||||
router := createHandler(cdc)
|
handler := createHandler(cdc)
|
||||||
|
logger := log.NewTMLogger(log.NewSyncWriter(os.Stdout)).With("module", "rest-server")
|
||||||
|
maxOpen := viper.GetInt(flagMaxOpenConnections)
|
||||||
|
|
||||||
|
listener, err := tmserver.StartHTTPServer(
|
||||||
|
listenAddr, handler, logger,
|
||||||
|
tmserver.Config{MaxOpenConnections: maxOpen},
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.Info("REST server started")
|
||||||
|
|
||||||
|
// wait forever and cleanup
|
||||||
|
cmn.TrapSignal(func() {
|
||||||
|
err := listener.Close()
|
||||||
|
logger.Error("error closing listener", "err", err)
|
||||||
|
})
|
||||||
|
|
||||||
|
return nil
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
cmd.Flags().String(flagListenAddr, "tcp://localhost:1317", "The address for the server to listen on")
|
||||||
|
cmd.Flags().String(flagCORS, "", "Set the domains that can make CORS requests (* for all)")
|
||||||
|
cmd.Flags().String(client.FlagChainID, "", "The chain ID to connect to")
|
||||||
|
cmd.Flags().String(client.FlagNode, "tcp://localhost:26657", "Address of the node to connect to")
|
||||||
|
cmd.Flags().Int(flagMaxOpenConnections, 1000, "The number of maximum open connections")
|
||||||
|
cmd.Flags().Bool(client.FlagTrustNode, false, "Whether trust connected full node")
|
||||||
|
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
func createHandler(cdc *wire.Codec) *mux.Router {
|
||||||
|
r := mux.NewRouter()
|
||||||
|
|
||||||
|
kb, err := keys.GetKeyBase() //XXX
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
cliCtx := context.NewCLIContext().WithCodec(cdc).WithLogger(os.Stdout)
|
||||||
|
|
||||||
|
// TODO: make more functional? aka r = keys.RegisterRoutes(r)
|
||||||
|
r.HandleFunc("/version", CLIVersionRequestHandler).Methods("GET")
|
||||||
|
r.HandleFunc("/node_version", NodeVersionRequestHandler(cliCtx)).Methods("GET")
|
||||||
|
|
||||||
|
keys.RegisterRoutes(r)
|
||||||
|
rpc.RegisterRoutes(cliCtx, r)
|
||||||
|
tx.RegisterRoutes(cliCtx, r, cdc)
|
||||||
|
auth.RegisterRoutes(cliCtx, r, cdc, "acc")
|
||||||
|
bank.RegisterRoutes(cliCtx, r, cdc, kb)
|
||||||
|
ibc.RegisterRoutes(cliCtx, r, cdc, kb)
|
||||||
|
stake.RegisterRoutes(cliCtx, r, cdc, kb)
|
||||||
|
slashing.RegisterRoutes(cliCtx, r, cdc, kb)
|
||||||
|
gov.RegisterRoutes(cliCtx, r, cdc)
|
||||||
|
|
||||||
|
return r
|
||||||
|
}
|
||||||
|
|
||||||
|
// ServeLiteCommand will generate a long-running rest server for gaia-lite
|
||||||
|
func ServeLiteCommand(cdc *wire.Codec) *cobra.Command {
|
||||||
|
flagListenAddr := "laddr"
|
||||||
|
flagCORS := "cors"
|
||||||
|
flagMaxOpenConnections := "max-open"
|
||||||
|
|
||||||
|
cmd := &cobra.Command{
|
||||||
|
Use: "lite-server",
|
||||||
|
Short: "Start Gaia-lite server daemon, a local REST server with swagger-ui, default url: http//localhost:1317/swaggerui/",
|
||||||
|
RunE: func(cmd *cobra.Command, args []string) error {
|
||||||
|
listenAddr := viper.GetString(flagListenAddr)
|
||||||
|
router := createLiteHandler(cdc)
|
||||||
|
|
||||||
statikFS, err := fs.New()
|
statikFS, err := fs.New()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -80,7 +153,7 @@ func ServeCommand(cdc *wire.Codec) *cobra.Command {
|
||||||
return cmd
|
return cmd
|
||||||
}
|
}
|
||||||
|
|
||||||
func createHandler(cdc *wire.Codec) *mux.Router {
|
func createLiteHandler(cdc *wire.Codec) *mux.Router {
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
|
|
||||||
kb, err := keys.GetKeyBase() //XXX
|
kb, err := keys.GetKeyBase() //XXX
|
||||||
|
@ -90,19 +163,11 @@ func createHandler(cdc *wire.Codec) *mux.Router {
|
||||||
|
|
||||||
cliCtx := context.NewCLIContext().WithCodec(cdc).WithLogger(os.Stdout)
|
cliCtx := context.NewCLIContext().WithCodec(cdc).WithLogger(os.Stdout)
|
||||||
|
|
||||||
// TODO: make more functional? aka r = keys.RegisterRoutes(r)
|
|
||||||
r.HandleFunc("/version", CLIVersionRequestHandler).Methods("GET")
|
r.HandleFunc("/version", CLIVersionRequestHandler).Methods("GET")
|
||||||
r.HandleFunc("/node_version", NodeVersionRequestHandler(cliCtx)).Methods("GET")
|
r.HandleFunc("/node_version", NodeVersionRequestHandler(cliCtx)).Methods("GET")
|
||||||
|
|
||||||
keys.RegisterRoutes(r)
|
tx.RegisterLiteRoutes(cliCtx, r, cdc)
|
||||||
rpc.RegisterRoutes(cliCtx, r)
|
bank.RegisterLiteRoutes(cliCtx, r, cdc, kb)
|
||||||
tx.RegisterRoutes(cliCtx, r, cdc)
|
|
||||||
auth.RegisterRoutes(cliCtx, r, cdc, "acc")
|
|
||||||
bank.RegisterRoutes(cliCtx, r, cdc, kb)
|
|
||||||
ibc.RegisterRoutes(cliCtx, r, cdc, kb)
|
|
||||||
stake.RegisterRoutes(cliCtx, r, cdc, kb)
|
|
||||||
slashing.RegisterRoutes(cliCtx, r, cdc, kb)
|
|
||||||
gov.RegisterRoutes(cliCtx, r, cdc)
|
|
||||||
|
|
||||||
return r
|
return r
|
||||||
}
|
}
|
|
@ -21,5 +21,10 @@ func RegisterRoutes(cliCtx context.CLIContext, r *mux.Router, cdc *wire.Codec) {
|
||||||
r.HandleFunc("/txs/{hash}", QueryTxRequestHandlerFn(cdc, cliCtx)).Methods("GET")
|
r.HandleFunc("/txs/{hash}", QueryTxRequestHandlerFn(cdc, cliCtx)).Methods("GET")
|
||||||
r.HandleFunc("/txs", SearchTxRequestHandlerFn(cliCtx, cdc)).Methods("GET")
|
r.HandleFunc("/txs", SearchTxRequestHandlerFn(cliCtx, cdc)).Methods("GET")
|
||||||
// r.HandleFunc("/txs/sign", SignTxRequstHandler).Methods("POST")
|
// r.HandleFunc("/txs/sign", SignTxRequstHandler).Methods("POST")
|
||||||
|
// r.HandleFunc("/txs/broadcast", BroadcastTxRequestHandler).Methods("POST")
|
||||||
|
}
|
||||||
|
|
||||||
|
// RegisterLiteRoutes registers REST routes to gaia-lite
|
||||||
|
func RegisterLiteRoutes(cliCtx context.CLIContext, r *mux.Router, cdc *wire.Codec) {
|
||||||
r.HandleFunc("/txs", BroadcastTxRequestHandlerFn(cdc, cliCtx)).Methods("POST")
|
r.HandleFunc("/txs", BroadcastTxRequestHandlerFn(cdc, cliCtx)).Methods("POST")
|
||||||
}
|
}
|
||||||
|
|
|
@ -67,6 +67,7 @@ func main() {
|
||||||
tendermintCmd,
|
tendermintCmd,
|
||||||
ibcCmd,
|
ibcCmd,
|
||||||
lcd.ServeCommand(cdc),
|
lcd.ServeCommand(cdc),
|
||||||
|
lcd.ServeLiteCommand(cdc),
|
||||||
client.LineBreak,
|
client.LineBreak,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -80,6 +80,7 @@ func main() {
|
||||||
rootCmd.AddCommand(
|
rootCmd.AddCommand(
|
||||||
client.LineBreak,
|
client.LineBreak,
|
||||||
lcd.ServeCommand(cdc),
|
lcd.ServeCommand(cdc),
|
||||||
|
lcd.ServeLiteCommand(cdc),
|
||||||
keys.Commands(),
|
keys.Commands(),
|
||||||
client.LineBreak,
|
client.LineBreak,
|
||||||
version.VersionCmd,
|
version.VersionCmd,
|
||||||
|
|
|
@ -9,6 +9,11 @@ import (
|
||||||
|
|
||||||
// RegisterRoutes registers bank-related REST handlers to a router
|
// RegisterRoutes registers bank-related REST handlers to a router
|
||||||
func RegisterRoutes(cliCtx context.CLIContext, r *mux.Router, cdc *wire.Codec, kb keys.Keybase) {
|
func RegisterRoutes(cliCtx context.CLIContext, r *mux.Router, cdc *wire.Codec, kb keys.Keybase) {
|
||||||
|
registerSendTxRoutes(cliCtx, r, cdc, kb)
|
||||||
|
}
|
||||||
|
|
||||||
|
// RegisterLiteRoutes registers bank REST handlers to gaia-lite
|
||||||
|
func RegisterLiteRoutes(cliCtx context.CLIContext, r *mux.Router, cdc *wire.Codec, kb keys.Keybase) {
|
||||||
registerQueryRoutes(cliCtx, r, cdc, "acc")
|
registerQueryRoutes(cliCtx, r, cdc, "acc")
|
||||||
registerSendTxRoutes(cliCtx, r, cdc, kb)
|
registerSendTxRoutes(cliCtx, r, cdc, kb)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue