fix: fix update stream

snapp-incubator · Jul 16, 2024 · 8022ab5 · 8022ab5
1 parent 3f7b729
commit 8022ab5
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/internal/natsclient/jetstream.go b/internal/natsclient/jetstream.go
@@ -98,11 +98,8 @@ func (j *Jetstream) UpdateOrCreateStream() {
 func (j *Jetstream) updateStream(stream Stream, info *nats.StreamInfo) {
 	subjects := append(info.Config.Subjects, stream.Subject)
 	slices.Sort(subjects)
-	subjects = slices.Compact(subjects)
-	_, err := j.jetstream.UpdateStream(&nats.StreamConfig{
-		Name:     stream.Name,
-		Subjects: subjects,
-	})
+	info.Config.Subjects = slices.Compact(subjects)
+	_, err := j.jetstream.UpdateStream(&info.Config)
 	if err != nil {
 		j.logger.Error("could not add subject to existing stream", zap.String("stream", stream.Name), zap.Error(err))
 	}