liquidity: add asset swap info to swap builder

Author: sputn1ck

liquidity/interface.go

@@ -62,7 +62,8 @@ type swapBuilder interface {
 	// is just for a dry run.
 	buildSwap(ctx context.Context, peer route.Vertex,
 		channels []lnwire.ShortChannelID, amount btcutil.Amount,
-		params Parameters) (swapSuggestion, error)
+		params Parameters, assetInfo *assetSwapInfo) (swapSuggestion,
+		error)
 }
 
 // swapSuggestion is an interface implemented by suggested swaps for our

liquidity/liquidity.go

@@ -641,6 +641,7 @@ func (m *Manager) dispatchBestEasyAutoloopSwap(ctx context.Context) error {
 
 	suggestion, err := builder.buildSwap(
 		ctx, channel.PubKeyBytes, outgoing, swapAmt, easyParams,
+		nil,
 	)
 	if err != nil {
 		return err
@@ -1004,6 +1005,7 @@ func (m *Manager) suggestSwap(ctx context.Context, traffic *swapTraffic,
 
 	return builder.buildSwap(
 		ctx, balance.pubkey, balance.channels, amount, m.params,
+		nil,
 	)
 }
 

liquidity/loopin_builder.go

@@ -84,7 +84,7 @@ func (b *loopInBuilder) inUse(traffic *swapTraffic, peer route.Vertex,
 // For loop in, we do not add the autoloop label for dry runs.
 func (b *loopInBuilder) buildSwap(ctx context.Context, pubkey route.Vertex,
 	_ []lnwire.ShortChannelID, amount btcutil.Amount,
-	params Parameters) (swapSuggestion, error) {
+	params Parameters, assetInfo *assetSwapInfo) (swapSuggestion, error) {
 
 	quote, err := b.cfg.LoopInQuote(ctx, &loop.LoopInQuoteRequest{
 		Amount:         amount,

liquidity/loopin_builder_test.go

@@ -184,7 +184,7 @@ func TestLoopinBuildSwap(t *testing.T) {
 		swap, err := builder.buildSwap(
 			context.Background(), peer1, []lnwire.ShortChannelID{
 				chan1,
-			}, swapAmt, params,
+			}, swapAmt, params, nil,
 		)
 		assert.Equal(t, testCase.expectedSwap, swap)
 		assert.Equal(t, testCase.expectedErr, err)

liquidity/loopout_builder.go

@@ -2,6 +2,7 @@ package liquidity
 
 import (
 	"context"
+	"encoding/hex"
 
 	"github.com/btcsuite/btcd/btcutil"
 	"github.com/lightninglabs/loop"
@@ -84,6 +85,11 @@ func (b *loopOutBuilder) inUse(traffic *swapTraffic, peer route.Vertex,
 	return nil
 }
 
+type assetSwapInfo struct {
+	assetId    string
+	peerPubkey []byte
+}
+
 // buildSwap creates a swap for the target peer/channels provided. The autoloop
 // boolean indicates whether this swap will actually be executed, because there
 // are some calls we can leave out if this swap is just for a dry run (ie, when
@@ -94,14 +100,35 @@ func (b *loopOutBuilder) inUse(traffic *swapTraffic, peer route.Vertex,
 // dry-run, and we do not add the autoloop label to the recommended swap.
 func (b *loopOutBuilder) buildSwap(ctx context.Context, pubkey route.Vertex,
 	channels []lnwire.ShortChannelID, amount btcutil.Amount,
-	params Parameters) (swapSuggestion, error) {
+	params Parameters, assetSwap *assetSwapInfo) (swapSuggestion, error) {
+
+	var (
+		assetRfqRequest *loop.AssetRFQRequest
+		assetIdBytes    []byte
+		err             error
+	)
+
+	initatior := getInitiator(params)
+
+	if assetSwap != nil {
+		assetIdBytes, err = hex.DecodeString(assetSwap.assetId)
+		if err != nil {
+			return nil, err
+		}
+		assetRfqRequest = &loop.AssetRFQRequest{
+			AssetId:       assetIdBytes,
+			AssetEdgeNode: assetSwap.peerPubkey,
+		}
+		initatior += "-" + assetSwap.assetId
+	}
 
 	quote, err := b.cfg.LoopOutQuote(
 		ctx, &loop.LoopOutQuoteRequest{
 			Amount:                  amount,
 			SweepConfTarget:         params.SweepConfTarget,
 			SwapPublicationDeadline: b.cfg.Clock.Now(),
-			Initiator:               getInitiator(params),
+			Initiator:               initatior,
+			AssetRFQRequest:         assetRfqRequest,
 		},
 	)
 	if err != nil {
@@ -146,7 +173,13 @@ func (b *loopOutBuilder) buildSwap(ctx context.Context, pubkey route.Vertex,
 		MaxSwapFee:          quote.SwapFee,
 		MaxPrepayAmount:     quote.PrepayAmount,
 		SweepConfTarget:     params.SweepConfTarget,
-		Initiator:           getInitiator(params),
+		Initiator:           initatior,
+	}
+
+	if assetSwap != nil {
+		request.AssetId = assetIdBytes
+		request.AssetPrepayRfqId = quote.LoopOutRfq.PrepayRfqId
+		request.AssetSwapRfqId = quote.LoopOutRfq.SwapRfqId
 	}
 
 	if params.Autoloop {