loop+loopd+liquidity: use isWalletAddr flag

cmd/loop/loopout.go

@@ -147,9 +147,11 @@ func loopOut(ctx *cli.Context) error {
 
 	var destAddr string
 	var account string
+	isWalletAddr := true
 	switch {
 	case ctx.IsSet("addr"):
 		destAddr = ctx.String("addr")
+		isWalletAddr = false
 
 	case ctx.IsSet("account"):
 		account = ctx.String("account")
@@ -235,6 +237,7 @@ func loopOut(ctx *cli.Context) error {
 	resp, err := client.LoopOut(context.Background(), &looprpc.LoopOutRequest{
 		Amt:                     int64(amt),
 		Dest:                    destAddr,
+		IsWalletAddr:            isWalletAddr,
 		Account:                 account,
 		AccountAddrType:         accountAddrType,
 		MaxMinerFee:             int64(limits.maxMinerFee),

interface.go

@@ -20,6 +20,11 @@ type OutRequest struct {
 	// Destination address for the swap.
 	DestAddr btcutil.Address
 
+	// IsWalletAddr indicates whether the provided destination address
+	// belongs to the underlying wallet. This helps indicate whether the
+	// sweep of this swap can be batched or not.
+	IsWalletAddr bool
+
 	// MaxSwapRoutingFee is the maximum off-chain fee in msat that may be
 	// paid for payment to the server. This limit is applied during path
 	// finding. Typically this value is taken from the response of the

liquidity/liquidity.go

@@ -454,6 +454,7 @@ func (m *Manager) autoloop(ctx context.Context) error {
 		// outs.
 		if m.params.DestAddr != nil {
 			swap.DestAddr = m.params.DestAddr
+			swap.IsWalletAddr = false
 		}
 
 		go m.dispatchStickyLoopOut(

liquidity/loopout_builder.go

@@ -138,6 +138,7 @@ func (b *loopOutBuilder) buildSwap(ctx context.Context, pubkey route.Vertex,
 	// already validated them.
 	request := loop.OutRequest{
 		Amount:              amount,
+		IsWalletAddr:        true,
 		OutgoingChanSet:     chanSet,
 		MaxPrepayRoutingFee: prepayMaxFee,
 		MaxSwapRoutingFee:   routeMaxFee,
@@ -160,6 +161,7 @@ func (b *loopOutBuilder) buildSwap(ctx context.Context, pubkey route.Vertex,
 		if len(params.Account) > 0 {
 			account = params.Account
 			addrType = params.AccountAddrType
+			request.IsWalletAddr = false
 		}
 
 		addr, err := b.cfg.Lnd.WalletKit.NextAddr(

loopd/swapclient_server.go

@@ -96,6 +96,7 @@ func (s *swapClientServer) LoopOut(ctx context.Context,
 	log.Infof("Loop out request received")
 
 	var sweepAddr btcutil.Address
+	var isWalletAddr bool
 	var err error
 	//nolint:lll
 	switch {
@@ -146,6 +147,8 @@ func (s *swapClientServer) LoopOut(ctx context.Context,
 		if err != nil {
 			return nil, fmt.Errorf("NextAddr error: %v", err)
 		}
+
+		isWalletAddr = true
 	}
 
 	sweepConfTarget, err := validateLoopOutRequest(
@@ -162,6 +165,7 @@ func (s *swapClientServer) LoopOut(ctx context.Context,
 	req := &loop.OutRequest{
 		Amount:                  btcutil.Amount(in.Amt),
 		DestAddr:                sweepAddr,
+		IsWalletAddr:            isWalletAddr,
 		MaxMinerFee:             btcutil.Amount(in.MaxMinerFee),
 		MaxPrepayAmount:         btcutil.Amount(in.MaxPrepayAmt),
 		MaxPrepayRoutingFee:     btcutil.Amount(in.MaxPrepayRoutingFee),

loopout.go

@@ -174,6 +174,7 @@ func newLoopOutSwap(globalCtx context.Context, cfg *swapConfig,
 	contract := loopdb.LoopOutContract{
 		SwapInvoice:             swapResp.swapInvoice,
 		DestAddr:                request.DestAddr,
+		IsWalletAddr:            request.IsWalletAddr,
 		MaxSwapRoutingFee:       request.MaxSwapRoutingFee,
 		SweepConfTarget:         request.SweepConfTarget,
 		HtlcConfirmations:       confs,
@@ -1654,9 +1655,6 @@ func (s *loopOutSwap) sweep(ctx context.Context, htlcOutpoint wire.OutPoint,
 		return nil
 	}
 
-	s.executeConfig.batcher.SweepReqs <- sweep
-	return nil
-
 	confTarget, canSweep := s.sweepConfTarget()
 	if !canSweep {
 		return nil