fix pubsub topic subscription

sourcenetwork · Oct 7, 2024 · 5d16912 · 5d16912
1 parent e86699e
commit 5d16912
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/net/server.go b/net/server.go
@@ -273,9 +273,9 @@ func (s *server) publishLog(ctx context.Context, topic string, req *pushLogReque
 	t, ok := s.topics[topic]
 	s.mu.Unlock()
 	if !ok {
-		subscribe := true
-		if topic != req.SchemaRoot && s.hasPubSubTopic(req.SchemaRoot) {
-			subscribe = false
+		subscribe := false
+		if topic != req.SchemaRoot && !s.hasPubSubTopic(req.SchemaRoot) {
+			subscribe = true
 		}
 		err := s.addPubSubTopic(topic, subscribe, nil)
 		if err != nil {