itest: universe server harness uses a dedicated LND node

In this commit we ensure that the universe server harness uses a new
dedicated LND node. The universe harness previously used the Bob standby
LND node. This change allows us to use an in-test tapd node with LND
node Bob without conflicting with the universe server tapd node.

This change will be important when passing messages between tapd nodes
(e.g. RFQ system) via LND nodes.

Author: ffranr

itest/integration_test.go

@@ -50,6 +50,13 @@ func TestTaprootAssetsDaemon(t *testing.T) {
 
 	lndHarness.SetupStandbyNodes()
 
+	// Create a new LND node for use with the universe server.
+	t.Log("Starting universe server LND node")
+	uniServerLndHarness := lndHarness.NewNode("uni-server-lnd", nil)
+
+	// Wait for the new LND node to be fully synced to the blockchain.
+	lndHarness.WaitForBlockchainSync(uniServerLndHarness)
+
 	t.Logf("Running %v integration tests", len(testList))
 	for _, testCase := range testList {
 		logLine := fmt.Sprintf("STARTING ============ %v ============\n",
@@ -60,12 +67,18 @@ func TestTaprootAssetsDaemon(t *testing.T) {
 			// created and later discarded for each test run to
 			// assure no state is taken over between runs.
 			tapdHarness, uniHarness, proofCourier := setupHarnesses(
-				t1, ht, lndHarness,
+				t1, ht, lndHarness, uniServerLndHarness,
 				testCase.proofCourierType,
 			)
 			lndHarness.EnsureConnected(
 				lndHarness.Alice, lndHarness.Bob,
 			)
+			lndHarness.EnsureConnected(
+				lndHarness.Alice, uniServerLndHarness,
+			)
+			lndHarness.EnsureConnected(
+				lndHarness.Bob, uniServerLndHarness,
+			)
 
 			lndHarness.Alice.AddToLogf(logLine)
 			lndHarness.Bob.AddToLogf(logLine)

itest/test_harness.go

@@ -290,11 +290,13 @@ func nextAvailablePort() int {
 // setupHarnesses creates new server and client harnesses that are connected
 // to each other through an in-memory gRPC connection.
 func setupHarnesses(t *testing.T, ht *harnessTest,
-	lndHarness *lntest.HarnessTest,
+	lndHarness *lntest.HarnessTest, uniServerLndHarness *node.HarnessNode,
 	proofCourierType proof.CourierType) (*tapdHarness,
 	*universeServerHarness, proof.CourierHarness) {
 
-	universeServer := newUniverseServerHarness(t, ht, lndHarness.Bob)
+	// Create a new universe server harness and start it.
+	t.Log("Starting universe server harness")
+	universeServer := newUniverseServerHarness(t, ht, uniServerLndHarness)
 
 	t.Logf("Starting universe server harness, listening on %v",
 		universeServer.ListenAddr)

itest/universe_server_harness.go

@@ -14,6 +14,10 @@ type universeServerHarness struct {
 
 	// ListenAddr is the address that the service is listening on.
 	ListenAddr string
+
+	// lndHarness is the instance of the lnd harness that the service is
+	// using.
+	LndHarness *node.HarnessNode
 }
 
 func newUniverseServerHarness(t *testing.T, ht *harnessTest,
@@ -28,6 +32,7 @@ func newUniverseServerHarness(t *testing.T, ht *harnessTest,
 	return &universeServerHarness{
 		service:    service,
 		ListenAddr: service.rpcHost(),
+		LndHarness: lndHarness,
 	}
 }