create sys topic in all nodes

talentone · Jun 2, 2023 · 66958e5 · 66958e5
1 parent e4d2ef5
commit 66958e5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/server/db/mongodb/tests/mongo_test.go b/server/db/mongodb/tests/mongo_test.go
@@ -523,7 +523,7 @@ func TestSubsForTopic(t *testing.T) {
 
 func TestFindUsers(t *testing.T) {
 	reqTags := [][]string{{"alice", "bob", "carol"}}
-	gotSubs, err := adp.FindUsers(types.ParseUserId("usr"+users[2].Id), reqTags, nil)
+	gotSubs, err := adp.FindUsers(types.ParseUserId("usr"+users[2].Id), reqTags, nil, true)
 	if err != nil {
 		t.Error(err)
 	}
@@ -534,7 +534,7 @@ func TestFindUsers(t *testing.T) {
 
 func TestFindTopics(t *testing.T) {
 	reqTags := [][]string{{"travel", "qwer", "asdf", "zxcv"}}
-	gotSubs, err := adp.FindTopics(reqTags, nil)
+	gotSubs, err := adp.FindTopics(reqTags, nil, true)
 	if err != nil {
 		t.Error(err)
 	}

diff --git a/server/hub.go b/server/hub.go
@@ -142,10 +142,8 @@ func newHub() *Hub {
 
 	go h.run()
 
-	if !globals.cluster.isRemoteTopic("sys") {
-		// Initialize system 'sys' topic. There is only one sys topic per cluster.
-		h.join <- &ClientComMessage{RcptTo: "sys", Original: "sys"}
-	}
+	// Initialize 'sys' topic. It will be initialized either as master or proxy.
+	h.join <- &ClientComMessage{RcptTo: "sys", Original: "sys"}
 
 	return h
 }