fix: SGDistributedLogs set version without patch number in generated SGCluster

Author: teoincontatto

stackgres-k8s/src/operator/src/main/java/io/stackgres/operator/conciliation/factory/distributedlogs/DistributedLogsCluster.java

@@ -13,6 +13,8 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import io.fabric8.kubernetes.api.model.ConfigMapVolumeSourceBuilder;
@@ -109,9 +111,14 @@ public static StackGresCluster getCluster(
             previousCluster
             .map(StackGresCluster::getMetadata)
             .map(ObjectMeta::getAnnotations)
-            .orElseGet(() -> Map.of(
-                StackGresContext.VERSION_KEY,
-                StackGresVersion.getStackGresVersion(distributedLogs).getVersion())))
+            .orElseGet(() -> Optional.of(distributedLogs)
+                .map(StackGresDistributedLogs::getMetadata)
+                .map(ObjectMeta::getAnnotations)
+                .map(Map::entrySet)
+                .stream()
+                .flatMap(Set::stream)
+                .filter(annotation -> annotation.getKey().equals(StackGresContext.VERSION_KEY))
+                .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue))))
         .withLabels(labelFactory.genericLabels(distributedLogs))
         .withNamespace(namespace)
         .withName(name)

stackgres-k8s/src/operator/src/main/java/io/stackgres/operator/conciliation/factory/distributedlogs/v14/DistributedLogsCluster.java

@@ -13,6 +13,8 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import io.fabric8.kubernetes.api.model.ConfigMapVolumeSourceBuilder;
@@ -108,9 +110,14 @@ public static StackGresCluster getCluster(
             previousCluster
             .map(StackGresCluster::getMetadata)
             .map(ObjectMeta::getAnnotations)
-            .orElseGet(() -> Map.of(
-                StackGresContext.VERSION_KEY,
-                StackGresVersion.getStackGresVersion(distributedLogs).getVersion())))
+            .orElseGet(() -> Optional.of(distributedLogs)
+                .map(StackGresDistributedLogs::getMetadata)
+                .map(ObjectMeta::getAnnotations)
+                .map(Map::entrySet)
+                .stream()
+                .flatMap(Set::stream)
+                .filter(annotation -> annotation.getKey().equals(StackGresContext.VERSION_KEY))
+                .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue))))
         .withLabels(labelFactory.genericLabels(distributedLogs))
         .withNamespace(namespace)
         .withName(name)