Support for Kubernetes exec command (#1604)

* Add support for Kubernetes exec API

* Update processing input stream and adding ExecResult return type

* clean up reading output thread join

* add test to call exec

* First code review changes

* Remove set/get methods in KubernetesExec

Author: lennyphan

new-integration-tests/src/test/java/oracle/weblogic/kubernetes/ItMiiDomain.java

@@ -17,6 +17,7 @@
 import io.kubernetes.client.openapi.models.V1EnvVar;
 import io.kubernetes.client.openapi.models.V1LocalObjectReference;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
+import io.kubernetes.client.openapi.models.V1Pod;
 import io.kubernetes.client.openapi.models.V1Secret;
 import io.kubernetes.client.openapi.models.V1SecretReference;
 import io.kubernetes.client.openapi.models.V1ServiceAccount;
@@ -36,6 +37,7 @@
 import oracle.weblogic.kubernetes.annotations.tags.MustNotRunInParallel;
 import oracle.weblogic.kubernetes.annotations.tags.Slow;
 import oracle.weblogic.kubernetes.extensions.LoggedTest;
+import oracle.weblogic.kubernetes.utils.ExecResult;
 import org.awaitility.core.ConditionFactory;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
@@ -74,6 +76,7 @@
 import static oracle.weblogic.kubernetes.actions.TestActions.deleteServiceAccount;
 import static oracle.weblogic.kubernetes.actions.TestActions.dockerLogin;
 import static oracle.weblogic.kubernetes.actions.TestActions.dockerPush;
+import static oracle.weblogic.kubernetes.actions.TestActions.execCommand;
 import static oracle.weblogic.kubernetes.actions.TestActions.getOperatorImageName;
 import static oracle.weblogic.kubernetes.actions.TestActions.installOperator;
 import static oracle.weblogic.kubernetes.actions.TestActions.uninstallOperator;
@@ -88,9 +91,11 @@
 import static oracle.weblogic.kubernetes.utils.FileUtils.checkDirectory;
 import static org.awaitility.Awaitility.with;
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
 
 // Test to create model in image domain and verify the domain started successfully
 @TestMethodOrder(MethodOrderer.OrderAnnotation.class)
@@ -107,6 +112,8 @@ class ItMiiDomain implements LoggedTest {
   private static final String DOMAIN_VERSION = "v7";
   private static final String API_VERSION = "weblogic.oracle/" + DOMAIN_VERSION;
 
+  private static final String READ_STATE_COMMAND = "/weblogic-operator/scripts/readState.sh";
+
   private static HelmParams opHelmParams = null;
   private static V1ServiceAccount serviceAccount = null;
   private String serviceAccountName = null;
@@ -300,6 +307,9 @@ public void testCreateMiiDomain() {
         adminServerPodName, domainNamespace);
     checkPodReady(adminServerPodName, domainUid, domainNamespace);
 
+    logger.info("Check admin server status by calling read state command");
+    checkServerReadyStatusByExec(adminServerPodName, domainNamespace);
+
     // check managed server pods are ready
     for (int i = 1; i <= replicaCount; i++) {
       logger.info("Wait for managed server pod {0} to be ready in namespace {1}",
@@ -757,4 +767,23 @@ private void checkServiceCreated(String serviceName, String domNamespace) {
 
   }
 
+  private void checkServerReadyStatusByExec(String podName, String namespace) {
+    final V1Pod pod = assertDoesNotThrow(() -> oracle.weblogic.kubernetes.assertions.impl.Kubernetes
+        .getPod(namespace, null, podName));
+
+    if (pod != null) {
+      ExecResult execResult = assertDoesNotThrow(
+          () -> execCommand(pod, null, true, READ_STATE_COMMAND));
+      if (execResult.exitValue() == 0) {
+        logger.info("execResult: " + execResult);
+        assertEquals("RUNNING", execResult.stdout(),
+            "Expected " + podName + ", in namespace " + namespace + ", to be in RUNNING ready status");
+      } else {
+        fail("Ready command failed with exit status code: " + execResult.exitValue());
+      }
+    } else {
+      fail("Did not find pod " + podName + " in namespace " + namespace);
+    }
+  }
+
 }

new-integration-tests/src/test/java/oracle/weblogic/kubernetes/actions/TestActions.java

@@ -3,6 +3,7 @@
 
 package oracle.weblogic.kubernetes.actions;
 
+import java.io.IOException;
 import java.util.List;
 
 import com.google.gson.JsonObject;
@@ -12,6 +13,7 @@
 import io.kubernetes.client.openapi.models.V1ConfigMap;
 import io.kubernetes.client.openapi.models.V1PersistentVolume;
 import io.kubernetes.client.openapi.models.V1PersistentVolumeClaim;
+import io.kubernetes.client.openapi.models.V1Pod;
 import io.kubernetes.client.openapi.models.V1Secret;
 import io.kubernetes.client.openapi.models.V1Service;
 import io.kubernetes.client.openapi.models.V1ServiceAccount;
@@ -21,6 +23,7 @@
 import oracle.weblogic.kubernetes.actions.impl.ClusterRoleBinding;
 import oracle.weblogic.kubernetes.actions.impl.ConfigMap;
 import oracle.weblogic.kubernetes.actions.impl.Domain;
+import oracle.weblogic.kubernetes.actions.impl.Exec;
 import oracle.weblogic.kubernetes.actions.impl.Namespace;
 import oracle.weblogic.kubernetes.actions.impl.Operator;
 import oracle.weblogic.kubernetes.actions.impl.OperatorParams;
@@ -36,6 +39,7 @@
 import oracle.weblogic.kubernetes.actions.impl.primitive.HelmParams;
 import oracle.weblogic.kubernetes.actions.impl.primitive.WebLogicImageTool;
 import oracle.weblogic.kubernetes.actions.impl.primitive.WitParams;
+import oracle.weblogic.kubernetes.utils.ExecResult;
 
 // this class essentially delegates to the impl classes, and "hides" all of the
 // detail impl classes - tests would only ever call methods in here, never
@@ -492,10 +496,10 @@ public static boolean buildAppArchive(AppParams params) {
 
   /**
    * Log in to a Docker registry.
-   * @param registryName registry name
-   * @param username user
-   * @param password password
-   * @return true if successfull
+   * @param registryName name of Docker registry
+   * @param username username for the Docker registry
+   * @param password password for the Docker registry
+   * @return true if successful, false otherwise
    */
   public static boolean dockerLogin(String registryName, String username, String password) {
     return Docker.login(registryName, username, password);
@@ -531,6 +535,27 @@ public static JsonObject createDockerConfigJson(String username, String password
     return Docker.createDockerConfigJson(username, password, email, registry);
   }
 
+  // ----------------------- Execute a Command   ---------------------------
+
+  /**
+   * Execute a command in a container.
+   *
+   * @param pod The pod where the command is to be run
+   * @param containerName The container in the Pod where the command is to be run. If no
+   *     container name is provided than the first container in the Pod is used.
+   * @param redirectToStdout copy process output to stdout
+   * @param command The command to run
+   * @return result of command execution
+   * @throws IOException if an I/O error occurs.
+   * @throws ApiException if Kubernetes client API call fails
+   * @throws InterruptedException if any thread has interrupted the current thread
+   */
+  public static ExecResult execCommand(V1Pod pod, String containerName, boolean redirectToStdout,
+      String... command)
+      throws IOException, ApiException, InterruptedException {
+    return Exec.exec(pod, containerName, redirectToStdout, command);
+  }
+
   // ------------------------ where does this go  -------------------------
 
   /**

new-integration-tests/src/test/java/oracle/weblogic/kubernetes/actions/impl/Exec.java

@@ -0,0 +1,33 @@
+// Copyright (c) 2020, Oracle Corporation and/or its affiliates.
+// Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
+
+package oracle.weblogic.kubernetes.actions.impl;
+
+import java.io.IOException;
+
+import io.kubernetes.client.openapi.ApiException;
+import io.kubernetes.client.openapi.models.V1Pod;
+import oracle.weblogic.kubernetes.actions.impl.primitive.Kubernetes;
+import oracle.weblogic.kubernetes.utils.ExecResult;
+
+public class Exec {
+
+  /**
+   * Execute a command in a container.
+   *
+   * @param pod The pod where the command is to be run
+   * @param containerName The container in the Pod where the command is to be run. If no
+   *     container name is provided than the first container in the Pod is used.
+   * @param redirectToStdout copy process output to stdout
+   * @param command The command to run
+   * @return result of command execution
+   * @throws IOException if an I/O error occurs.
+   * @throws ApiException if Kubernetes client API call fails
+   * @throws InterruptedException if any thread has interrupted the current thread
+   */
+  public static ExecResult exec(V1Pod pod, String containerName, boolean redirectToStdout,
+      String... command)
+      throws IOException, ApiException, InterruptedException {
+    return Kubernetes.exec(pod, containerName, redirectToStdout, command);
+  }
+}