fix: avoid overwrite sharded cluster objects during creation of dependent clusters

Author: teoincontatto

stackgres-k8s/src/operator/src/main/java/io/stackgres/operator/conciliation/shardedcluster/context/ShardedClusterCoordinatorClusterContextAppender.java

@@ -5,6 +5,7 @@
 
 package io.stackgres.operator.conciliation.shardedcluster.context;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.stackgres.common.crd.sgcluster.StackGresCluster;
 import io.stackgres.common.crd.sgshardedcluster.StackGresShardedCluster;
 import io.stackgres.common.crd.sgshardedcluster.StackGresShardingType;
@@ -19,12 +20,15 @@ public class ShardedClusterCoordinatorClusterContextAppender {
 
   private final ShardedClusterCoordinatorPrimaryEndpointsContextAppender
       shardedClusterCoordinatorPrimaryEndpointsContextAppender;
+  private final ObjectMapper objectMapper;
 
   public ShardedClusterCoordinatorClusterContextAppender(
       ShardedClusterCoordinatorPrimaryEndpointsContextAppender
-          shardedClusterCoordinatorPrimaryEndpointsContextAppender) {
+          shardedClusterCoordinatorPrimaryEndpointsContextAppender,
+      ObjectMapper objectMapper) {
     this.shardedClusterCoordinatorPrimaryEndpointsContextAppender =
         shardedClusterCoordinatorPrimaryEndpointsContextAppender;
+    this.objectMapper = objectMapper;
   }
 
   public void appendContext(StackGresShardedCluster cluster, Builder contextBuilder) {
@@ -33,7 +37,8 @@ public void appendContext(StackGresShardedCluster cluster, Builder contextBuilde
     shardedClusterCoordinatorPrimaryEndpointsContextAppender.appendContext(coordinator, contextBuilder);
   }
 
-  private StackGresCluster getCoordinatorCluster(StackGresShardedCluster cluster) {
+  private StackGresCluster getCoordinatorCluster(StackGresShardedCluster original) {
+    StackGresShardedCluster cluster = objectMapper.convertValue(original, StackGresShardedCluster.class);
     switch (StackGresShardingType.fromString(cluster.getSpec().getType())) {
       case CITUS:
         return StackGresShardedClusterForCitusUtil.getCoordinatorCluster(cluster);

stackgres-k8s/src/operator/src/main/java/io/stackgres/operator/conciliation/shardedcluster/context/ShardedClusterShardsClustersContextAppender.java

@@ -8,6 +8,7 @@
 import java.util.List;
 import java.util.stream.IntStream;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.stackgres.common.crd.sgcluster.StackGresCluster;
 import io.stackgres.common.crd.sgshardedcluster.StackGresShardedCluster;
 import io.stackgres.common.crd.sgshardedcluster.StackGresShardingType;
@@ -22,12 +23,15 @@ public class ShardedClusterShardsClustersContextAppender {
 
   private final ShardedClusterShardsPrimaryEndpointsContextAppender
       shardedClusterShardsPrimaryEndpointsContextAppender;
+  private final ObjectMapper objectMapper;
 
   public ShardedClusterShardsClustersContextAppender(
       ShardedClusterShardsPrimaryEndpointsContextAppender
-          shardedClusterShardsPrimaryEndpointsContextAppender) {
+          shardedClusterShardsPrimaryEndpointsContextAppender,
+      ObjectMapper objectMapper) {
     this.shardedClusterShardsPrimaryEndpointsContextAppender =
         shardedClusterShardsPrimaryEndpointsContextAppender;
+    this.objectMapper = objectMapper;
   }
 
   public void appendContext(StackGresShardedCluster cluster, Builder contextBuilder) {
@@ -42,7 +46,8 @@ private List<StackGresCluster> getShardsClusters(StackGresShardedCluster cluster
         .toList();
   }
 
-  private StackGresCluster getShardsCluster(StackGresShardedCluster cluster, int index) {
+  private StackGresCluster getShardsCluster(StackGresShardedCluster original, int index) {
+    StackGresShardedCluster cluster = objectMapper.convertValue(original, StackGresShardedCluster.class);
     switch (StackGresShardingType.fromString(cluster.getSpec().getType())) {
       case CITUS:
         return StackGresShardedClusterForCitusUtil.getShardsCluster(cluster, index);