cmd/lncli: update action func to new upstream signature

The upstream cli repo has changed the signature for the ‘Action’ to
return an additional error. Thankfully this was done in a backwards
compatible manner.

This commit updates all the command action functions to adhere to the
new function signature.

In the future we’ll have proper dependency management so cases like
this will be avoided all together.
This commit is contained in:
Olaoluwa Osuntokun 2016-06-29 13:01:08 -07:00
parent f7543b39a4
commit 96667cbc4a
No known key found for this signature in database
GPG Key ID: 9CC5B105D03521A2

@ -43,7 +43,7 @@ var NewAddressCommand = cli.Command{
Action: newAddress,
}
func newAddress(ctx *cli.Context) {
func newAddress(ctx *cli.Context) error {
client := getClient(ctx)
stringAddrType := ctx.Args().Get(0)
@ -59,8 +59,8 @@ func newAddress(ctx *cli.Context) {
case "p2pkh":
addrType = lnrpc.NewAddressRequest_PUBKEY_HASH
default:
fatal(fmt.Errorf("invalid address type %v, support address type "+
"are: p2wkh, np2wkh, p2pkh", stringAddrType))
return fmt.Errorf("invalid address type %v, support address type "+
"are: p2wkh, np2wkh, p2pkh", stringAddrType)
}
ctxb := context.Background()
@ -68,10 +68,11 @@ func newAddress(ctx *cli.Context) {
Type: addrType,
})
if err != nil {
fatal(err)
return err
}
printRespJson(addr)
return nil
}
var SendCoinsCommand = cli.Command{
@ -92,7 +93,7 @@ var SendCoinsCommand = cli.Command{
Action: sendCoins,
}
func sendCoins(ctx *cli.Context) {
func sendCoins(ctx *cli.Context) error {
ctxb := context.Background()
client := getClient(ctx)
@ -102,10 +103,11 @@ func sendCoins(ctx *cli.Context) {
}
txid, err := client.SendCoins(ctxb, req)
if err != nil {
fatal(err)
return err
}
printRespJson(txid)
return nil
}
var SendManyCommand = cli.Command{
@ -116,12 +118,12 @@ var SendManyCommand = cli.Command{
Action: sendMany,
}
func sendMany(ctx *cli.Context) {
func sendMany(ctx *cli.Context) error {
var amountToAddr map[string]int64
jsonMap := ctx.Args().Get(0)
if err := json.Unmarshal([]byte(jsonMap), &amountToAddr); err != nil {
fatal(err)
return err
}
ctxb := context.Background()
@ -129,10 +131,11 @@ func sendMany(ctx *cli.Context) {
txid, err := client.SendMany(ctxb, &lnrpc.SendManyRequest{amountToAddr})
if err != nil {
fatal(err)
return err
}
printRespJson(txid)
return nil
}
var ConnectCommand = cli.Command{
@ -141,7 +144,7 @@ var ConnectCommand = cli.Command{
Action: connectPeer,
}
func connectPeer(ctx *cli.Context) {
func connectPeer(ctx *cli.Context) error {
ctxb := context.Background()
client := getClient(ctx)
@ -155,10 +158,11 @@ func connectPeer(ctx *cli.Context) {
lnid, err := client.ConnectPeer(ctxb, req)
if err != nil {
fatal(err)
return err
}
printRespJson(lnid)
return nil
}
// TODO(roasbeef): default number of confirmations
@ -191,7 +195,7 @@ var OpenChannelCommand = cli.Command{
Action: openChannel,
}
func openChannel(ctx *cli.Context) {
func openChannel(ctx *cli.Context) error {
// TODO(roasbeef): add deadline to context
ctxb := context.Background()
client := getClient(ctx)
@ -205,12 +209,12 @@ func openChannel(ctx *cli.Context) {
resp, err := client.OpenChannel(ctxb, req)
if err != nil {
fatal(err)
return err
}
txid, err := wire.NewShaHash(resp.ChannelPoint.FundingTxid)
if err != nil {
fatal(err)
return err
}
index := resp.ChannelPoint.OutputIndex
@ -220,6 +224,7 @@ func openChannel(ctx *cli.Context) {
ChannelPoint: fmt.Sprintf("%v:%v", txid, index),
},
)
return nil
}
// TODO(roasbeef): also allow short relative channel ID.
@ -252,13 +257,13 @@ var CloseChannelCommand = cli.Command{
Action: closeChannel,
}
func closeChannel(ctx *cli.Context) {
func closeChannel(ctx *cli.Context) error {
ctxb := context.Background()
client := getClient(ctx)
txid, err := wire.NewShaHashFromStr(ctx.String("funding_txid"))
if err != nil {
fatal(err)
return err
}
req := &lnrpc.CloseChannelRequest{
@ -270,10 +275,11 @@ func closeChannel(ctx *cli.Context) {
resp, err := client.CloseChannel(ctxb, req)
if err != nil {
fatal(err)
return err
}
printRespJson(resp)
return nil
}
var ListPeersCommand = cli.Command{
@ -282,17 +288,18 @@ var ListPeersCommand = cli.Command{
Action: listPeers,
}
func listPeers(ctx *cli.Context) {
func listPeers(ctx *cli.Context) error {
ctxb := context.Background()
client := getClient(ctx)
req := &lnrpc.ListPeersRequest{}
resp, err := client.ListPeers(ctxb, req)
if err != nil {
fatal(err)
return err
}
printRespJson(resp)
return nil
}
var WalletBalanceCommand = cli.Command{
@ -309,7 +316,7 @@ var WalletBalanceCommand = cli.Command{
Action: walletBalance,
}
func walletBalance(ctx *cli.Context) {
func walletBalance(ctx *cli.Context) error {
ctxb := context.Background()
client := getClient(ctx)
@ -318,8 +325,9 @@ func walletBalance(ctx *cli.Context) {
}
resp, err := client.WalletBalance(ctxb, req)
if err != nil {
fatal(err)
return err
}
printRespJson(resp)
return nil
}