fix: add WithClusterID to see its effect

waku-org · Mar 28, 2024 · 4266513 · 4266513
1 parent dc4ed27
commit 4266513
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/waku/v2/node/wakunode2_test.go b/waku/v2/node/wakunode2_test.go
@@ -346,20 +346,23 @@ func TestStaticShardingMultipleTopics(t *testing.T) {
 	wakuNode1, err := New(
 		WithHostAddress(hostAddr1),
 		WithWakuRelay(),
+		WithClusterID(uint16(20)),
 	)
 	require.NoError(t, err)
 	err = wakuNode1.Start(ctx)
 	require.NoError(t, err)
 	defer wakuNode1.Stop()
 
-	pubSubTopic1 := protocol.NewStaticShardingPubsubTopic(uint16(0), uint16(0))
+	pubSubTopic1 := protocol.NewStaticShardingPubsubTopic(uint16(21), uint16(0))
 	pubSubTopic1Str := pubSubTopic1.String()
 	contentTopic1 := "/test/2/my-app/sharded"
 
-	pubSubTopic2 := protocol.NewStaticShardingPubsubTopic(uint16(0), uint16(10))
+	pubSubTopic2 := protocol.NewStaticShardingPubsubTopic(uint16(21), uint16(10))
 	pubSubTopic2Str := pubSubTopic2.String()
 	contentTopic2 := "/test/3/my-app/sharded"
 
+	require.Equal(t, uint16(20), wakuNode1.ClusterID())
+
 	r := wakuNode1.Relay()
 
 	subs1, err := r.Subscribe(ctx, protocol.NewContentFilter(pubSubTopic1Str, contentTopic1))