cmd/loopout: add asset flags

Author: sputn1ck

cmd/loop/loopout.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"context"
+	"encoding/hex"
 	"fmt"
 	"math"
 	"strconv"
@@ -101,6 +102,20 @@ var loopOutCommand = cli.Command{
 				"payment might be retried, the actual total " +
 				"time may be longer",
 		},
+		cli.StringFlag{
+			Name: "asset_id",
+			Usage: "the asset ID of the asset to loop out, " +
+				"if this is set, the loop daemon will " +
+				"require a connection to a taproot assets " +
+				"daemon",
+		},
+		cli.StringFlag{
+			Name: "asset_edge_node",
+			Usage: "the pubkey of the edge node of the asset to " +
+				"loop out, this is required if the taproot " +
+				"assets daemon has multiple channels of the " +
+				"given asset id with different edge nodes",
+		},
 		forceFlag,
 		labelFlag,
 		verboseFlag,
@@ -186,6 +201,33 @@ func loopOut(ctx *cli.Context) error {
 		}
 	}
 
+	var assetLoopOutInfo *looprpc.AssetLoopOutInfo
+
+	var assetId []byte
+	if ctx.IsSet("asset_id") {
+		if !ctx.IsSet("asset_edge_node") {
+			return fmt.Errorf("asset edge node is required when " +
+				"assetid is set")
+		}
+
+		assetId, err = hex.DecodeString(ctx.String("asset_id"))
+		if err != nil {
+			return err
+		}
+
+		assetEdgeNode, err := hex.DecodeString(
+			ctx.String("asset_edge_node"),
+		)
+		if err != nil {
+			return err
+		}
+
+		assetLoopOutInfo = &looprpc.AssetLoopOutInfo{
+			AssetId:       assetId,
+			AssetEdgeNode: assetEdgeNode,
+		}
+	}
+
 	client, cleanup, err := getClient(ctx)
 	if err != nil {
 		return err
@@ -210,6 +252,7 @@ func loopOut(ctx *cli.Context) error {
 		Amt:                     int64(amt),
 		ConfTarget:              sweepConfTarget,
 		SwapPublicationDeadline: uint64(swapDeadline.Unix()),
+		AssetInfo:               assetLoopOutInfo,
 	}
 	quote, err := client.LoopOutQuote(context.Background(), quoteReq)
 	if err != nil {
@@ -281,6 +324,7 @@ func loopOut(ctx *cli.Context) error {
 		Label:                   label,
 		Initiator:               defaultInitiator,
 		PaymentTimeout:          uint32(paymentTimeout),
+		AssetInfo:               assetLoopOutInfo,
 	})
 	if err != nil {
 		return err

cmd/loop/quote.go

@@ -267,8 +267,15 @@ func printQuoteOutResp(req *looprpc.QuoteRequest,
 
 	totalFee := resp.HtlcSweepFeeSat + resp.SwapFeeSat
 
-	fmt.Printf(satAmtFmt, "Send off-chain:", req.Amt)
-	fmt.Printf(satAmtFmt, "Receive on-chain:", req.Amt-totalFee)
+	if req.AssetInfo != nil {
+		fmt.Printf("%-36s %12d assets\n",
+			"Assets Send off-chain:", req.Amt)
+		fmt.Printf(satAmtFmt, "Sats Send off-chain:",
+			resp.InvoiceAmtSat)
+	} else {
+		fmt.Printf(satAmtFmt, "Send off-chain:", resp.InvoiceAmtSat)
+	}
+	fmt.Printf(satAmtFmt, "Receive on-chain:", resp.InvoiceAmtSat-totalFee)
 
 	if !verbose {
 		fmt.Printf(satAmtFmt, "Estimated total fee:", totalFee)