loop: add reservation cli commands

Author: sputn1ck

cmd/loop/main.go

@@ -153,7 +153,7 @@ func main() {
 		monitorCommand, quoteCommand, listAuthCommand,
 		listSwapsCommand, swapInfoCommand, getLiquidityParamsCommand,
 		setLiquidityRuleCommand, suggestSwapCommand, setParamsCommand,
-		getInfoCommand,
+		getInfoCommand, reservationsCommands,
 	}
 
 	err := app.Run(os.Args)

cmd/loop/reservations.go

@@ -0,0 +1,146 @@
+package main
+
+import (
+	"context"
+
+	"github.com/lightninglabs/loop/looprpc"
+	"github.com/urfave/cli"
+)
+
+var reservationsCommands = cli.Command{
+
+	Name:      "reservations",
+	ShortName: "r",
+	Usage:     "manage reservations",
+	Subcommands: []cli.Command{
+		newReservationCommand,
+		listReservationsCommand,
+		getReservationTermsCommand,
+	},
+}
+
+var (
+	newReservationCommand = cli.Command{
+		Name:      "new",
+		Usage:     "create a new reservation",
+		ArgsUsage: "amt",
+		Description: `
+		Create a new reservation for the amount in satoshis specified by the amt argument.
+	`,
+		Flags: []cli.Flag{
+			cli.StringFlag{
+				Name:  "amt",
+				Usage: "the amount to reserve",
+			},
+		},
+		Action: newReservation,
+	}
+	listReservationsCommand = cli.Command{
+		Name:      "list",
+		Usage:     "list all reservations",
+		ArgsUsage: "",
+		Description: `
+		List all reservations.
+	`,
+		Action: listReservations,
+	}
+	getReservationTermsCommand = cli.Command{
+		Name:      "terms",
+		Usage:     "get the terms for reservations",
+		ArgsUsage: "",
+		Description: `
+		Get the terms for reservations.
+	`,
+		Action: getReservationTerms,
+	}
+)
+
+func newReservation(ctx *cli.Context) error {
+	args := ctx.Args()
+
+	var amtStr string
+	switch {
+	case ctx.IsSet("amt"):
+		amtStr = ctx.String("amt")
+	case ctx.NArg() > 0:
+		amtStr = args[0]
+	default:
+		// Show command help if no arguments and flags were provided.
+		return cli.ShowCommandHelp(ctx, "new")
+	}
+
+	amt, err := parseAmt(amtStr)
+	if err != nil {
+		return err
+	}
+
+	client, cleanup, err := getReservationClient(ctx)
+	if err != nil {
+		return err
+	}
+	defer cleanup()
+
+	resp, err := client.OpenReservation(
+		context.Background(), &looprpc.OpenReservationRequest{
+			Amount: uint64(amt),
+		},
+	)
+	if err != nil {
+		return err
+	}
+
+	printRespJSON(resp)
+	return nil
+}
+
+func listReservations(ctx *cli.Context) error {
+	client, cleanup, err := getReservationClient(ctx)
+	if err != nil {
+		return err
+	}
+	defer cleanup()
+
+	resp, err := client.ListReservations(
+		context.Background(), &looprpc.ListReservationsRequest{},
+	)
+	if err != nil {
+		return err
+	}
+
+	printRespJSON(resp)
+	return nil
+}
+
+func getReservationTerms(ctx *cli.Context) error {
+	client, cleanup, err := getReservationClient(ctx)
+	if err != nil {
+		return err
+	}
+	defer cleanup()
+
+	resp, err := client.GetReservationTerms(
+		context.Background(), &looprpc.GetReservationTermsRequest{},
+	)
+	if err != nil {
+		return err
+	}
+
+	printRespJSON(resp)
+	return nil
+}
+
+func getReservationClient(ctx *cli.Context) (looprpc.ReservationClientClient, func(), error) {
+	rpcServer := ctx.GlobalString("rpcserver")
+	tlsCertPath, macaroonPath, err := extractPathArgs(ctx)
+	if err != nil {
+		return nil, nil, err
+	}
+	conn, err := getClientConn(rpcServer, tlsCertPath, macaroonPath)
+	if err != nil {
+		return nil, nil, err
+	}
+	cleanup := func() { conn.Close() }
+
+	reservationClient := looprpc.NewReservationClientClient(conn)
+	return reservationClient, cleanup, nil
+}