loadtest+itest: add sync mode option to SyncUniverses

Author: GeorgeTsagk

itest/loadtest/mint_batch_test.go

@@ -167,7 +167,10 @@ func mintTest(t *testing.T, ctx context.Context, cfg *Config) {
 	})
 	require.True(t, correctOp)
 
-	itest.SyncUniverses(ctx, t, bob, alice, aliceHost, cfg.TestTimeout)
+	itest.SyncUniverses(
+		ctx, t, bob, alice, aliceHost, itest.SyncModeIssuance,
+		cfg.TestTimeout,
+	)
 }
 
 // mintTestV2 checks that we can mint a batch of assets. It is a more

itest/mint_fund_seal_test.go

@@ -19,6 +19,7 @@ import (
 	"github.com/lightninglabs/taproot-assets/asset"
 	"github.com/lightninglabs/taproot-assets/fn"
 	"github.com/lightninglabs/taproot-assets/internal/test"
+	"github.com/lightninglabs/taproot-assets/itest"
 	"github.com/lightninglabs/taproot-assets/proof"
 	"github.com/lightninglabs/taproot-assets/tappsbt"
 	"github.com/lightninglabs/taproot-assets/taprpc"
@@ -343,7 +344,7 @@ func testMintFundSealAssets(t *harnessTest) {
 	// verify that he syncs the assets correctly.
 	SyncUniverses(
 		ctxt, t.t, bobTapd, aliceTapd, aliceTapd.rpcHost(),
-		defaultTimeout,
+		itest.SyncModeIssuance, defaultTimeout,
 	)
 
 	// If we fetch issuance leaves for the collectible asset group, we

itest/multisig.go

@@ -75,7 +75,10 @@ func MultiSigTest(t *testing.T, ctx context.Context, aliceTapd,
 
 	var firstBatchGenesis = firstBatch.AssetGenesis
 
-	SyncUniverses(ctx, t, bobTapd, aliceTapd, universeHostPort, testTimeout)
+	SyncUniverses(
+		ctx, t, bobTapd, aliceTapd, universeHostPort, SyncModeIssuance,
+		testTimeout,
+	)
 
 	// And now we prepare the multisig addresses for both levels. On the
 	// BTC level we are going to do a Tapscript based 2-of-2 multisig using

itest/utils.go

@@ -42,6 +42,11 @@ var (
 	regtestParams     = &chaincfg.RegressionNetParams
 )
 
+const (
+	SyncModeIssuance = universerpc.UniverseSyncMode_SYNC_ISSUANCE_ONLY
+	SyncModeFull     = universerpc.UniverseSyncMode_SYNC_FULL
+)
+
 // ClientEventStream is a generic interface for a client stream that allows us
 // to receive events from a server.
 type ClientEventStream[T any] interface {
@@ -838,7 +843,7 @@ func MintAssetExternalSigner(t *harnessTest, tapNode *tapdHarness,
 // are in sync.
 func SyncUniverses(ctx context.Context, t *testing.T, clientTapd,
 	universeTapd commands.RpcClientsBundle, universeHost string,
-	timeout time.Duration) {
+	syncMode universerpc.UniverseSyncMode, timeout time.Duration) {
 
 	ctxt, cancel := context.WithTimeout(ctx, timeout)
 	defer cancel()
@@ -863,10 +868,9 @@ func SyncUniverses(ctx context.Context, t *testing.T, clientTapd,
 		// If we've already added the server in a previous run, we'll
 		// just need to kick off a sync (as that would otherwise be done
 		// by adding the server request already).
-		mode := universerpc.UniverseSyncMode_SYNC_ISSUANCE_ONLY
 		_, err := clientTapd.SyncUniverse(ctxt, &universerpc.SyncRequest{
 			UniverseHost: universeHost,
-			SyncMode:     mode,
+			SyncMode:     syncMode,
 		})
 		require.NoError(t, err)
 	}