tapcfg+tapfreighter: configure sweeping with wallet flag

Author: darioAnongba

config.go

@@ -190,6 +190,10 @@ type Config struct {
 
 	ChainPorter tapfreighter.Porter
 
+	// SweepZeroValueAnchorUtxos toggles sweeping zero-value UTXOs into
+	// anchor transactions for sends and burns.
+	SweepZeroValueAnchorUtxos bool
+
 	// FsmDaemonAdapters is a set of adapters that allow a state machine to
 	// interact with external daemons.
 	FsmDaemonAdapters *lndservices.LndFsmDaemonAdapters

docs/release-notes/release-notes-0.8.0.md

@@ -35,7 +35,8 @@
 - [Garbage collection of zero-value UTXOs](https://github.com/lightninglabs/taproot-assets/pull/1832)
   by sweeping tombstones and burn outputs when executing onchain transactions.
   Garbage collection will be executed on every burn, transfer or call to
-  `AnchorVirtualPsbts`.
+  `AnchorVirtualPsbts`. A new configuration is available to control the sweeping 
+  via the flag `wallet.sweep-zero-value-anchor-utxos`.
 
 ## RPC Updates
 

itest/assertions.go

@@ -1276,10 +1276,6 @@ func AssertAssetOutboundTransferWithOutputs(t *testing.T,
 		scripts[string(o.ScriptKey)] = struct{}{}
 	}
 
-	sendRespJSON, err := formatProtoJSON(transfer)
-	require.NoError(t, err)
-	t.Logf("Got response from sending assets: %v", sendRespJSON)
-
 	// Mine a block to force the send event to complete (confirm on-chain).
 	var newBlock *wire.MsgBlock
 	if confirm {
@@ -1325,17 +1321,12 @@ func AssertAssetOutboundTransferWithOutputs(t *testing.T,
 				return slices.Contains(actualInputAssetIDs, id)
 			})
 	}, defaultTimeout, wait.PollInterval)
-	require.NoError(t, err)
 
-	transferResp, err := sender.ListTransfers(
+	_, err := sender.ListTransfers(
 		ctxb, &taprpc.ListTransfersRequest{},
 	)
 	require.NoError(t, err)
 
-	transferRespJSON, err := formatProtoJSON(transferResp)
-	require.NoError(t, err)
-	t.Logf("Got response from list transfers: %v", transferRespJSON)
-
 	return newBlock
 }
 
@@ -2410,7 +2401,7 @@ func AssertBalances(t *testing.T, client taprpc.TaprootAssetsClient,
 			actualBalance := balanceSum(resp, false)
 			if balance != actualBalance {
 				return fmt.Errorf("asset balance, wanted %d, "+
-					"got: %v", balance, toJSON(t, resp))
+					"got: %v", balance, actualBalance)
 			}
 
 			// If we query for grouped asset balances too, it means
@@ -2528,7 +2519,7 @@ func AssertBalances(t *testing.T, client taprpc.TaprootAssetsClient,
 		}
 		if balance != totalBalance {
 			return fmt.Errorf("ListAssets balance, wanted %d, "+
-				"got: %v", balance, toJSON(t, resp))
+				"got: %v", balance, totalBalance)
 		}
 
 		// The number of UTXOs means asset outputs in this case. We
@@ -2605,7 +2596,7 @@ func AssertBalances(t *testing.T, client taprpc.TaprootAssetsClient,
 
 		if balance != totalBalance {
 			return fmt.Errorf("ListUtxos balance, wanted %d, "+
-				"got: %v", balance, toJSON(t, resp))
+				"got: %v", balance, totalBalance)
 		}
 
 		if config.numAnchorUtxos > 0 {

itest/burn_test.go

@@ -246,14 +246,6 @@ func testBurnAssets(t *harnessTest) {
 		WithScriptKeyType(asset.ScriptKeyBurn),
 	)
 
-	resp, err := t.tapd.ListAssets(ctxt, &taprpc.ListAssetRequest{
-		IncludeSpent: true,
-	})
-	require.NoError(t.t, err)
-	assets, err := formatProtoJSON(resp)
-	require.NoError(t.t, err)
-	t.Logf("All assets before last burn: %v", assets)
-
 	// Test case 4: Burn some units of a grouped asset. We start by making
 	// sure we still have the full balance before burning.
 	AssertBalanceByID(
@@ -282,6 +274,7 @@ func testBurnAssets(t *harnessTest) {
 		burnAmt+simpleCollectible.Amount+multiBurnAmt+burnAmt,
 		WithNumUtxos(4), WithNumAnchorUtxos(4),
 		WithScriptKeyType(asset.ScriptKeyBurn),
+		WithIncludeLeased(),
 	)
 
 	burns = AssertNumBurns(t.t, t.tapd, 4, nil)
@@ -337,6 +330,7 @@ func testBurnAssets(t *harnessTest) {
 		burnAmt+simpleCollectible.Amount+multiBurnAmt+burnAmt+1,
 		WithNumUtxos(5), WithNumAnchorUtxos(5),
 		WithScriptKeyType(asset.ScriptKeyBurn),
+		WithIncludeLeased(),
 	)
 
 	// We now perform some queries to test the filters of the ListBurns

itest/integration_test.go

@@ -119,7 +119,7 @@ func TestTaprootAssetsDaemon(t *testing.T) {
 			// assure no state is taken over between runs.
 			tapdHarness, uniHarness, proofCourier := setupHarnesses(
 				t1, ht, lndHarness, uniServerLndHarness,
-				testCase.proofCourierType,
+				testCase.proofCourierType, testCase.tapdOptions...,
 			)
 
 			ht := ht.newHarnessTest(

itest/tapd_harness.go

@@ -139,6 +139,10 @@ type harnessOpts struct {
 	// the local oracle to the counterparty when requesting a quote.
 	sendPriceHint bool
 
+	// sweepZeroValueAnchorUtxos indicates whether zero-value anchor UTXOs
+	// should be swept into anchor transactions.
+	sweepZeroValueAnchorUtxos bool
+
 	// disableSupplyVerifierChainWatch when true prevents the supply
 	// verifier from starting state machines to watch on-chain outputs for
 	// spends. This option is intended for universe servers, where supply
@@ -197,6 +201,8 @@ func newTapdHarness(t *testing.T, ht *harnessTest, cfg tapdConfig,
 	tapCfg.ChainConf.Network = cfg.NetParams.Name
 	tapCfg.TapdDir = cfg.BaseDir
 	tapCfg.DebugLevel = *logLevel
+	tapCfg.Wallet.SweepZeroValueAnchorUtxos =
+		opts.sweepZeroValueAnchorUtxos
 
 	// Enable universe proof courier RPC endpoints. These endpoints are
 	// also used within some tests for transferring proofs.

itest/test_harness.go

@@ -70,6 +70,7 @@ type testCase struct {
 	name             string
 	test             func(t *harnessTest)
 	proofCourierType proof.CourierType
+	tapdOptions      []Option
 }
 
 // harnessTest wraps a regular testing.T providing enhanced error detection
@@ -270,7 +271,7 @@ func (h *harnessTest) addFederationServer(host string, target *tapdHarness) {
 // to each other through an in-memory gRPC connection.
 func setupHarnesses(t *testing.T, ht *harnessTest,
 	lndHarness *lntest.HarnessTest, uniServerLndHarness *node.HarnessNode,
-	proofCourierType proof.CourierType) (*tapdHarness,
+	proofCourierType proof.CourierType, tapdOpts ...Option) (*tapdHarness,
 	*universeServerHarness, proof.CourierHarness) {
 
 	// Create a new universe server harness and start it.
@@ -306,10 +307,11 @@ func setupHarnesses(t *testing.T, ht *harnessTest,
 	alice := lndHarness.NewNodeWithCoins("Alice", nil)
 
 	// Create a tapd that uses Alice and connect it to the universe server.
+	tapdOptions := append(tapdOpts, func(params *tapdHarnessParams) {
+		params.proofCourier = proofCourier
+	})
 	tapdHarness := setupTapdHarness(
-		t, ht, alice, universeServer, func(params *tapdHarnessParams) {
-			params.proofCourier = proofCourier
-		},
+		t, ht, alice, universeServer, tapdOptions...,
 	)
 	return tapdHarness, universeServer, proofCourier
 }
@@ -372,6 +374,10 @@ type tapdHarnessParams struct {
 	// sendPriceHint indicates whether the tapd should send price hints from
 	// the local oracle to the counterparty when requesting a quote.
 	sendPriceHint bool
+
+	// sweepZeroValueAnchorUtxos indicates whether zero-value anchor UTXOs
+	// should be swept into anchor transactions.
+	sweepZeroValueAnchorUtxos bool
 }
 
 // Option is a tapd harness option.
@@ -400,6 +406,14 @@ func WithSendPriceHint() Option {
 	}
 }
 
+// WithSweepZeroValueAnchorUtxos enables sweeping zero-value anchor UTXOs for
+// the tapd harness created with this option.
+func WithSweepZeroValueAnchorUtxos() Option {
+	return func(th *tapdHarnessParams) {
+		th.sweepZeroValueAnchorUtxos = true
+	}
+}
+
 // setupTapdHarness creates a new tapd that connects to the given lnd node
 // and to the given universe server.
 func setupTapdHarness(t *testing.T, ht *harnessTest,
@@ -434,6 +448,7 @@ func setupTapdHarness(t *testing.T, ht *harnessTest,
 		ho.disableSyncCache = params.disableSyncCache
 		ho.oracleServerAddress = params.oracleServerAddress
 		ho.sendPriceHint = params.sendPriceHint
+		ho.sweepZeroValueAnchorUtxos = params.sweepZeroValueAnchorUtxos
 	}
 
 	tapdCfg := tapdConfig{

itest/test_list_on_test.go

@@ -104,6 +104,13 @@ var allTestCases = []*testCase{
 	{
 		name: "zero value anchor sweep",
 		test: testZeroValueAnchorSweep,
+		tapdOptions: []Option{
+			WithSweepZeroValueAnchorUtxos(),
+		},
+	},
+	{
+		name: "zero value anchor accumulation",
+		test: testZeroValueAnchorAccumulation,
 	},
 	{
 		name: "restart receiver check balance",