Remove cluster replicas and patch domain replicas and introspectVersion (#3391)

Co-authored-by: Ryan Eberhard <ryan.eberhard@oracle.com>

Author: doxiao

integration-tests/src/test/java/oracle/weblogic/kubernetes/ItKubernetesDomainEvents.java

@@ -68,6 +68,7 @@
 import static oracle.weblogic.kubernetes.utils.ClusterUtils.addClusterToDomain;
 import static oracle.weblogic.kubernetes.utils.ClusterUtils.createClusterAndVerify;
 import static oracle.weblogic.kubernetes.utils.ClusterUtils.createClusterResource;
+import static oracle.weblogic.kubernetes.utils.ClusterUtils.removeReplicasSettingAndVerify;
 import static oracle.weblogic.kubernetes.utils.ClusterUtils.scaleCluster;
 import static oracle.weblogic.kubernetes.utils.CommonTestUtils.checkPodReadyAndServiceExists;
 import static oracle.weblogic.kubernetes.utils.CommonTestUtils.checkServiceExists;
@@ -413,17 +414,20 @@ void testDomainK8sEventsScalePastMaxWithoutChangingIntrospectVersion() {
   void testDomainK8sEventsScalePastMaxAndChangeIntrospectVersion() {
     OffsetDateTime timestamp = now();
     try {
-      logger.info("Scaling cluster using patching");
+      removeReplicasSettingAndVerify(domainUid, cluster1Name, domainNamespace3, replicaCount,
+          managedServerPodNamePrefix);
+
       String introspectVersion = assertDoesNotThrow(() -> getNextIntrospectVersion(domainUid, domainNamespace3));
-      assertFalse(scaleCluster(cluster1Name, domainNamespace3, 3), "failed to scale cluster via patching");
       String patchStr
           = "["
-          + "{\"op\": \"replace\", \"path\": \"/spec/introspectVersion\", \"value\": \"" + introspectVersion + "\"}"
+          + "{\"op\": \"replace\", \"path\": \"/spec/introspectVersion\", \"value\": \"" + introspectVersion + "\"},"
+          + "{\"op\": \"replace\", \"path\": \"/spec/replicas\", \"value\": 3}"
           + "]";
 
       logger.info("Updating introspect version  using patch string: {0}",  patchStr);
       assertTrue(patchDomainCustomResource(domainUid, domainNamespace3, new V1Patch(patchStr),
-              V1Patch.PATCH_FORMAT_JSON_PATCH), "Patch domain failed");
+          V1Patch.PATCH_FORMAT_JSON_PATCH), "Patch domain did not fail as expected");
+
 
       logger.info("verify the Failed event is generated");
       checkFailedEvent(opNamespace, domainNamespace3, domainUid, REPLICAS_TOO_HIGH_ERROR, "Warning", timestamp);

integration-tests/src/test/java/oracle/weblogic/kubernetes/utils/ClusterUtils.java

@@ -21,6 +21,7 @@
 import static oracle.weblogic.kubernetes.actions.impl.Cluster.listClusterCustomResources;
 import static oracle.weblogic.kubernetes.assertions.TestAssertions.clusterDoesNotExist;
 import static oracle.weblogic.kubernetes.assertions.TestAssertions.clusterExists;
+import static oracle.weblogic.kubernetes.utils.CommonTestUtils.checkPodReadyAndServiceExists;
 import static oracle.weblogic.kubernetes.utils.CommonTestUtils.testUntil;
 import static oracle.weblogic.kubernetes.utils.ThreadSafeLogger.getLogger;
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
@@ -154,4 +155,25 @@ public static DomainResource addClusterToDomain(String clusterResName, String na
     domain.getSpec().withCluster(new V1LocalObjectReference().name(clusterResName));
     return domain;
   }
+
+  /**
+   * Remove the replicas setting from a cluster resource.
+   *  @param domainUid uid of the domain
+   * @param clusterName name of the cluster resource
+   * @param namespace namespace
+   * @param replicaCount original replicaCount
+   * @param msPodNamePrefix prefix of managed server pod names
+   * */
+  public static void removeReplicasSettingAndVerify(String domainUid, String clusterName, String namespace,
+                                                    int replicaCount, String msPodNamePrefix) {
+    getLogger().info("Remove replicas setting from cluster resource {0} in namespace {1}", clusterName, namespace);
+    String patchStr = "[{\"op\": \"remove\",\"path\": \"/spec/replicas\"}]";
+    assertTrue(patchClusterCustomResource(clusterName, namespace, new V1Patch(patchStr),
+        V1Patch.PATCH_FORMAT_JSON_PATCH), "Patch cluster resource failed");
+
+    // verify there is no pod created larger than max size of cluster
+    for (int i = 1; i <= replicaCount; i++) {
+      checkPodReadyAndServiceExists(msPodNamePrefix + i, domainUid, namespace);
+    }
+  }
 }