multi: bump deps, use new tapchannelrpc.SendPayment RPC

With this commit we bump to the latest version of taproot assets and
lnd (staging branch), so we can use the new SendPayment RPC that handles
the RFQ part inline.

Author: guggero

cmd/litcli/ln.go

@@ -23,6 +23,7 @@ import (
 	"github.com/lightningnetwork/lnd/lnwire"
 	"github.com/lightningnetwork/lnd/record"
 	"github.com/urfave/cli"
+	"google.golang.org/grpc"
 )
 
 const (
@@ -223,8 +224,61 @@ var (
 		Usage: "the asset ID of the asset to use when sending " +
 			"payments with assets",
 	}
+
+	assetAmountFlag = cli.Uint64Flag{
+		Name: "asset_amount",
+		Usage: "the amount of the asset to send in the asset keysend " +
+			"payment",
+	}
+
+	rfqPeerPubKeyFlag = cli.StringFlag{
+		Name: "rfq_peer_pubkey",
+		Usage: "(optional) the public key of the peer to ask for a " +
+			"quote when converting from assets to sats; must be " +
+			"set if there are multiple channels with the same " +
+			"asset ID present",
+	}
 )
 
+type resultStreamWrapper struct {
+	amountMsat int64
+	stream     tchrpc.TaprootAssetChannels_SendPaymentClient
+}
+
+func (w *resultStreamWrapper) Recv() (*lnrpc.Payment, error) {
+	resp, err := w.stream.Recv()
+	if err != nil {
+		return nil, err
+	}
+
+	res := resp.Result
+	switch r := res.(type) {
+	// The very first response might be an accepted sell order, which we
+	// just print out.
+	case *tchrpc.SendPaymentResponse_AcceptedSellOrder:
+		quote := r.AcceptedSellOrder
+		msatPerUnit := quote.BidPrice
+		numUnits := uint64(w.amountMsat) / msatPerUnit
+
+		fmt.Printf("Got quote for %v asset units at %v msat/unit from "+
+			"peer %s with SCID %d\n", numUnits, msatPerUnit,
+			quote.Peer, quote.Scid)
+
+		resp, err = w.stream.Recv()
+		if err != nil {
+			return nil, err
+		}
+
+		return resp.GetPaymentResult(), nil
+
+	case *tchrpc.SendPaymentResponse_PaymentResult:
+		return r.PaymentResult, nil
+
+	default:
+		return nil, fmt.Errorf("unexpected response type: %T", r)
+	}
+}
+
 var sendPaymentCommand = cli.Command{
 	Name:     "sendpayment",
 	Category: commands.SendPaymentCommand.Category,
@@ -236,14 +290,16 @@ var sendPaymentCommand = cli.Command{
 
 	Note that this will only work in concert with the --keysend argument.
 	`,
-	ArgsUsage: commands.SendPaymentCommand.ArgsUsage + " --asset_id=X",
-	Flags:     append(commands.SendPaymentCommand.Flags, assetIDFlag),
-	Action:    sendPayment,
+	ArgsUsage: commands.SendPaymentCommand.ArgsUsage + " --asset_id=X " +
+		"--asset_amount=Y [--rfq_peer_pubkey=Z]",
+	Flags: append(
+		commands.SendPaymentCommand.Flags, assetIDFlag, assetAmountFlag,
+		rfqPeerPubKeyFlag,
+	),
+	Action: sendPayment,
 }
 
 func sendPayment(ctx *cli.Context) error {
-	ctxb := context.Background()
-
 	// Show command help if no arguments provided
 	if ctx.NArg() == 0 && ctx.NumFlags() == 0 {
 		_ = cli.ShowCommandHelp(ctx, "sendpayment")
@@ -254,67 +310,32 @@ func sendPayment(ctx *cli.Context) error {
 	if err != nil {
 		return fmt.Errorf("unable to make rpc con: %w", err)
 	}
-
 	defer cleanup()
 
-	lndClient := lnrpc.NewLightningClient(lndConn)
+	tapdConn, cleanup, err := connectTapdClient(ctx)
+	if err != nil {
+		return fmt.Errorf("error creating tapd connection: %w", err)
+	}
+	defer cleanup()
 
 	switch {
 	case !ctx.IsSet(assetIDFlag.Name):
 		return fmt.Errorf("the --asset_id flag must be set")
 	case !ctx.IsSet("keysend"):
 		return fmt.Errorf("the --keysend flag must be set")
-	case !ctx.IsSet("amt"):
-		return fmt.Errorf("--amt must be set")
+	case !ctx.IsSet(assetAmountFlag.Name):
+		return fmt.Errorf("--asset_amount must be set")
 	}
 
 	assetIDStr := ctx.String(assetIDFlag.Name)
-	_, err = hex.DecodeString(assetIDStr)
+	assetIDBytes, err := hex.DecodeString(assetIDStr)
 	if err != nil {
 		return fmt.Errorf("unable to decode assetID: %v", err)
 	}
 
-	// First, based on the asset ID and amount, we'll make sure that this
-	// channel even has enough funds to send.
-	assetBalances, err := computeAssetBalances(lndClient)
-	if err != nil {
-		return fmt.Errorf("unable to compute asset balances: %w", err)
-	}
-
-	balance, ok := assetBalances.Assets[assetIDStr]
-	if !ok {
-		return fmt.Errorf("unable to send asset_id=%v, not in "+
-			"channel", assetIDStr)
-	}
-
-	amtToSend := ctx.Uint64("amt")
-	if amtToSend > balance.LocalBalance {
-		return fmt.Errorf("insufficient balance, want to send %v, "+
-			"only have %v", amtToSend, balance.LocalBalance)
-	}
-
-	tapdConn, cleanup, err := connectTapdClient(ctx)
-	if err != nil {
-		return fmt.Errorf("error creating tapd connection: %w", err)
-	}
-	defer cleanup()
-
-	tchrpcClient := tchrpc.NewTaprootAssetChannelsClient(tapdConn)
-
-	encodeReq := &tchrpc.EncodeCustomRecordsRequest_RouterSendPayment{
-		RouterSendPayment: &tchrpc.RouterSendPaymentData{
-			AssetAmounts: map[string]uint64{
-				assetIDStr: amtToSend,
-			},
-		},
-	}
-	encodeResp, err := tchrpcClient.EncodeCustomRecords(
-		ctxb, &tchrpc.EncodeCustomRecordsRequest{
-			Input: encodeReq,
-		},
-	)
-	if err != nil {
-		return fmt.Errorf("error encoding custom records: %w", err)
+	assetAmountToSend := ctx.Uint64(assetAmountFlag.Name)
+	if assetAmountToSend == 0 {
+		return fmt.Errorf("must specify asset amount to send")
 	}
 
 	// With the asset specific work out of the way, we'll parse the rest of
@@ -339,15 +360,20 @@ func sendPayment(ctx *cli.Context) error {
 			"is instead: %v", len(destNode))
 	}
 
+	rfqPeerKey, err := hex.DecodeString(ctx.String(rfqPeerPubKeyFlag.Name))
+	if err != nil {
+		return fmt.Errorf("unable to decode RFQ peer public key: "+
+			"%w", err)
+	}
+
 	// We use a constant amount of 500 to carry the asset HTLCs. In the
 	// future, we can use the double HTLC trick here, though it consumes
 	// more commitment space.
 	const htlcCarrierAmt = 500
 	req := &routerrpc.SendPaymentRequest{
-		Dest:                  destNode,
-		Amt:                   htlcCarrierAmt,
-		DestCustomRecords:     make(map[uint64][]byte),
-		FirstHopCustomRecords: encodeResp.CustomRecords,
+		Dest:              destNode,
+		Amt:               htlcCarrierAmt,
+		DestCustomRecords: make(map[uint64][]byte),
 	}
 
 	if ctx.IsSet("payment_hash") {
@@ -370,7 +396,33 @@ func sendPayment(ctx *cli.Context) error {
 
 	req.PaymentHash = rHash
 
-	return commands.SendPaymentRequest(ctx, req)
+	return commands.SendPaymentRequest(
+		ctx, req, lndConn, tapdConn, func(ctx context.Context,
+			payConn grpc.ClientConnInterface,
+			req *routerrpc.SendPaymentRequest) (
+			commands.PaymentResultStream, error) {
+
+			tchrpcClient := tchrpc.NewTaprootAssetChannelsClient(
+				payConn,
+			)
+
+			stream, err := tchrpcClient.SendPayment(
+				ctx, &tchrpc.SendPaymentRequest{
+					AssetId:        assetIDBytes,
+					AssetAmount:    assetAmountToSend,
+					PeerPubkey:     rfqPeerKey,
+					PaymentRequest: req,
+				},
+			)
+			if err != nil {
+				return nil, err
+			}
+
+			return &resultStreamWrapper{
+				stream: stream,
+			}, nil
+		},
+	)
 }
 
 var payInvoiceCommand = cli.Command{
@@ -434,24 +486,6 @@ func payInvoice(ctx *cli.Context) error {
 		return fmt.Errorf("unable to decode assetID: %v", err)
 	}
 
-	// First, based on the asset ID and amount, we'll make sure that this
-	// channel even has enough funds to send.
-	assetBalances, err := computeAssetBalances(lndClient)
-	if err != nil {
-		return fmt.Errorf("unable to compute asset balances: %w", err)
-	}
-
-	balance, ok := assetBalances.Assets[assetIDStr]
-	if !ok {
-		return fmt.Errorf("unable to send asset_id=%v, not in "+
-			"channel", assetIDStr)
-	}
-
-	if balance.LocalBalance == 0 {
-		return fmt.Errorf("no asset balance available for asset_id=%v",
-			assetIDStr)
-	}
-
 	var assetID asset.ID
 	copy(assetID[:], assetIDBytes)
 
@@ -462,88 +496,35 @@ func payInvoice(ctx *cli.Context) error {
 
 	defer cleanup()
 
-	peerPubKey, err := hex.DecodeString(balance.Channel.RemotePubkey)
-	if err != nil {
-		return fmt.Errorf("unable to decode peer pubkey: %w", err)
+	req := &routerrpc.SendPaymentRequest{
+		PaymentRequest: commands.StripPrefix(payReq),
 	}
 
-	rfqClient := rfqrpc.NewRfqClient(tapdConn)
+	return commands.SendPaymentRequest(
+		ctx, req, lndConn, tapdConn, func(ctx context.Context,
+			payConn grpc.ClientConnInterface,
+			req *routerrpc.SendPaymentRequest) (
+			commands.PaymentResultStream, error) {
 
-	timeoutSeconds := uint32(60)
-	fmt.Printf("Asking peer %x for quote to sell assets to pay for "+
-		"invoice over %d msats; waiting up to %ds\n", peerPubKey,
-		decodeResp.NumMsat, timeoutSeconds)
+			tchrpcClient := tchrpc.NewTaprootAssetChannelsClient(
+				payConn,
+			)
 
-	resp, err := rfqClient.AddAssetSellOrder(
-		ctxb, &rfqrpc.AddAssetSellOrderRequest{
-			AssetSpecifier: &rfqrpc.AssetSpecifier{
-				Id: &rfqrpc.AssetSpecifier_AssetIdStr{
-					AssetIdStr: assetIDStr,
+			stream, err := tchrpcClient.SendPayment(
+				ctx, &tchrpc.SendPaymentRequest{
+					AssetId: assetIDBytes,
 				},
-			},
-			// TODO(guggero): This should actually be the max BTC
-			// amount (invoice amount plus fee limit) in
-			// milli-satoshi, not the asset amount. Need to change
-			// the whole RFQ API to do that though.
-			MaxAssetAmount: balance.LocalBalance,
-			MinAsk:         uint64(decodeResp.NumMsat),
-			Expiry:         uint64(decodeResp.Expiry),
-			PeerPubKey:     peerPubKey,
-			TimeoutSeconds: timeoutSeconds,
-		},
-	)
-	if err != nil {
-		return fmt.Errorf("error adding sell order: %w", err)
-	}
-
-	var acceptedQuote *rfqrpc.PeerAcceptedSellQuote
-	switch r := resp.Response.(type) {
-	case *rfqrpc.AddAssetSellOrderResponse_AcceptedQuote:
-		acceptedQuote = r.AcceptedQuote
-
-	case *rfqrpc.AddAssetSellOrderResponse_InvalidQuote:
-		return fmt.Errorf("peer %v sent back an invalid quote, "+
-			"status: %v", r.InvalidQuote.Peer,
-			r.InvalidQuote.Status.String())
-
-	case *rfqrpc.AddAssetSellOrderResponse_RejectedQuote:
-		return fmt.Errorf("peer %v rejected the quote, code: %v, "+
-			"error message: %v", r.RejectedQuote.Peer,
-			r.RejectedQuote.ErrorCode, r.RejectedQuote.ErrorMessage)
-
-	default:
-		return fmt.Errorf("unexpected response type: %T", r)
-	}
-
-	msatPerUnit := acceptedQuote.BidPrice
-	numUnits := uint64(decodeResp.NumMsat) / msatPerUnit
-
-	fmt.Printf("Got quote for %v asset units at %v msat/unit from peer "+
-		"%x with SCID %d\n", numUnits, msatPerUnit, peerPubKey,
-		acceptedQuote.Scid)
-
-	tchrpcClient := tchrpc.NewTaprootAssetChannelsClient(tapdConn)
+			)
+			if err != nil {
+				return nil, err
+			}
 
-	encodeReq := &tchrpc.EncodeCustomRecordsRequest_RouterSendPayment{
-		RouterSendPayment: &tchrpc.RouterSendPaymentData{
-			RfqId: acceptedQuote.Id,
-		},
-	}
-	encodeResp, err := tchrpcClient.EncodeCustomRecords(
-		ctxb, &tchrpc.EncodeCustomRecordsRequest{
-			Input: encodeReq,
+			return &resultStreamWrapper{
+				amountMsat: decodeResp.NumMsat,
+				stream:     stream,
+			}, nil
 		},
 	)
-	if err != nil {
-		return fmt.Errorf("error encoding custom records: %w", err)
-	}
-
-	req := &routerrpc.SendPaymentRequest{
-		PaymentRequest:        commands.StripPrefix(payReq),
-		FirstHopCustomRecords: encodeResp.CustomRecords,
-	}
-
-	return commands.SendPaymentRequest(ctx, req)
 }
 
 var addInvoiceCommand = cli.Command{

go.mod

@@ -20,8 +20,8 @@ require (
 	github.com/lightninglabs/loop/swapserverrpc v1.0.8
 	github.com/lightninglabs/pool v0.6.5-beta.0.20240604070222-e121aadb3289
 	github.com/lightninglabs/pool/auctioneerrpc v1.1.2
-	github.com/lightninglabs/taproot-assets v0.4.1
-	github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240723043204-f09d4042aee4
+	github.com/lightninglabs/taproot-assets v0.4.2-0.20240730160739-664a6a1bb085
+	github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240730143253-1b353b0bfd58
 	github.com/lightningnetwork/lnd/cert v1.2.2
 	github.com/lightningnetwork/lnd/fn v1.1.0
 	github.com/lightningnetwork/lnd/kvdb v1.4.8

go.sum

@@ -1175,12 +1175,12 @@ github.com/lightninglabs/pool/auctioneerrpc v1.1.2 h1:Dbg+9Z9jXnhimR27EN37foc4aB
 github.com/lightninglabs/pool/auctioneerrpc v1.1.2/go.mod h1:1wKDzN2zEP8srOi0B9iySlEsPdoPhw6oo3Vbm1v4Mhw=
 github.com/lightninglabs/protobuf-go-hex-display v1.30.0-hex-display h1:pRdza2wleRN1L2fJXd6ZoQ9ZegVFTAb2bOQfruJPKcY=
 github.com/lightninglabs/protobuf-go-hex-display v1.30.0-hex-display/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
-github.com/lightninglabs/taproot-assets v0.4.1 h1:XtOIbw2sUl0GkjWKgZXxopU76BCjxXMW1Dqj8Ia9dGI=
-github.com/lightninglabs/taproot-assets v0.4.1/go.mod h1:9ne4bQJkvp9b6Ez0DZhmDzXM/vbBKAHw6v3zc2FqTFQ=
+github.com/lightninglabs/taproot-assets v0.4.2-0.20240730160739-664a6a1bb085 h1:76lG0Le7Jo06u77mG/Zbe7HeMUisfSh8IxLjOzKJ+kw=
+github.com/lightninglabs/taproot-assets v0.4.2-0.20240730160739-664a6a1bb085/go.mod h1:GGL1wvezBV0TdW4V2YD1EN9hElNclwU5HVjIu9Hx38A=
 github.com/lightningnetwork/lightning-onion v1.2.1-0.20230823005744-06182b1d7d2f h1:Pua7+5TcFEJXIIZ1I2YAUapmbcttmLj4TTi786bIi3s=
 github.com/lightningnetwork/lightning-onion v1.2.1-0.20230823005744-06182b1d7d2f/go.mod h1:c0kvRShutpj3l6B9WtTsNTBUtjSmjZXbJd9ZBRQOSKI=
-github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240723043204-f09d4042aee4 h1:LPnz0JxnzXJvCro714eBanzO7FKx5HF0ldU++zIu9yY=
-github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240723043204-f09d4042aee4/go.mod h1:0gen58n0DVnqJJqCMN3AXNtqWRT0KltQanlvehnhCq0=
+github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240730143253-1b353b0bfd58 h1:qmJAHLGfpeYIl1qUKyQViOjNAVRqF4afKuORzeIAwjA=
+github.com/lightningnetwork/lnd v0.18.0-beta.rc4.0.20240730143253-1b353b0bfd58/go.mod h1:0gen58n0DVnqJJqCMN3AXNtqWRT0KltQanlvehnhCq0=
 github.com/lightningnetwork/lnd/cert v1.2.2 h1:71YK6hogeJtxSxw2teq3eGeuy4rHGKcFf0d0Uy4qBjI=
 github.com/lightningnetwork/lnd/cert v1.2.2/go.mod h1:jQmFn/Ez4zhDgq2hnYSw8r35bqGVxViXhX6Cd7HXM6U=
 github.com/lightningnetwork/lnd/clock v1.1.1 h1:OfR3/zcJd2RhH0RU+zX/77c0ZiOnIMsDIBjgjWdZgA0=