fix: missed to add Replicas

mynaparrot · Dec 7, 2024 · fb6cba0 · fb6cba0
1 parent 8a744fd
commit fb6cba0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/services/nats/user_modify.go b/pkg/services/nats/user_modify.go
@@ -56,7 +56,8 @@ func (s *NatsService) AddUser(roomId, userId, name string, isAdmin, isPresenter
 
 	// now we'll create different bucket for info
 	kv, err = s.js.CreateOrUpdateKeyValue(s.ctx, jetstream.KeyValueConfig{
-		Bucket: fmt.Sprintf(UserInfoBucket, roomId, userId),
+		Replicas: s.app.NatsInfo.NumReplicas,
+		Bucket:   fmt.Sprintf(UserInfoBucket, roomId, userId),
 	})
 	if err != nil {
 		return err