intial change for voyager-java-integ-test

Author: maggiehe00

integration-tests/src/test/java/oracle/kubernetes/operator/ITOperator.java

@@ -55,11 +55,13 @@ public class ITOperator extends BaseTest {
   private static boolean SMOKETEST;
   private static boolean JENKINS;
   private static boolean INGRESSPERDOMAIN = true;
+  private static boolean VOYAGER;
 
   // Set QUICKTEST env var to true to run a small subset of tests.
   // Set SMOKETEST env var to true to run an even smaller subset
   // of tests, plus leave domain1 up and running when the test completes.
   // set INGRESSPERDOMAIN to false to create LB's ingress by kubectl yaml file
+  // set VOYAGER to true to use it as loadBalancer
   static {
     QUICKTEST =
         System.getenv("QUICKTEST") != null && System.getenv("QUICKTEST").equalsIgnoreCase("true");
@@ -72,6 +74,7 @@ public class ITOperator extends BaseTest {
     if (System.getenv("INGRESSPERDOMAIN") != null) {
       INGRESSPERDOMAIN = new Boolean(System.getenv("INGRESSPERDOMAIN")).booleanValue();
     }
+    VOYAGER = System.getenv("VOYAGER") != null && System.getenv("VOYAGER").equalsIgnoreCase("true");
   }
 
   /**
@@ -236,6 +239,10 @@ public void testTwoDomainsManagedByTwoOperators() throws Exception {
       wlstDomainMap.put("domainUID", "domain1onpvwlst");
       wlstDomainMap.put("adminNodePort", new Integer("30702"));
       wlstDomainMap.put("t3ChannelPort", new Integer("30031"));
+      if (VOYAGER) {
+        wlstDomainMap.put("loadBalancer", "VOYAGER");
+        logger.info("domain1onpvwlst loadBalancer is set to: " + wlstDomainMap.get("loadBalancer"));
+      }
       if (!INGRESSPERDOMAIN) {
         wlstDomainMap.put("ingressPerDomain", new Boolean("false"));
         logger.info(
@@ -257,6 +264,15 @@ public void testTwoDomainsManagedByTwoOperators() throws Exception {
       wdtDomainMap.put("adminNodePort", new Integer("30703"));
       wdtDomainMap.put("t3ChannelPort", new Integer("30041"));
       // wdtDomainMap.put("clusterType", "Configured");
+      if (VOYAGER) {
+        wdtDomainMap.put("loadBalancer", "VOYAGER");
+        wdtDomainMap.put("loadBalancerWebPort", new Integer("30306"));
+        logger.info(
+            "domain2onpvwdt loadBalancer is set to: "
+                + wdtDomainMap.get("loadBalancer")
+                + " with loadBalancerWebPort:"
+                + wdtDomainMap.get("loadBalancerWebPort"));
+      }
       if (!INGRESSPERDOMAIN) {
         wdtDomainMap.put("ingressPerDomain", new Boolean("false"));
         logger.info(

integration-tests/src/test/java/oracle/kubernetes/operator/utils/Domain.java

@@ -810,15 +810,20 @@ private void createLoadBalancer() throws Exception {
     lbMap.put("serviceName", domainUid + "-cluster-" + domainMap.get("clusterName"));
     lbMap.put("loadBalancer", domainMap.getOrDefault("loadBalancer", loadBalancer));
     lbMap.put("ingressPerDomain", domainMap.getOrDefault("ingressPerDomain", ingressPerDomain));
+    lbMap.put(
+        "loadBalancerWebPort", domainMap.getOrDefault("loadBalancerWebPort", loadBalancerWebPort));
     lbMap.put("clusterName", domainMap.get("clusterName"));
 
     loadBalancer = (String) lbMap.get("loadBalancer");
+    loadBalancerWebPort = ((Integer) lbMap.get("loadBalancerWebPort")).intValue();
     ingressPerDomain = ((Boolean) lbMap.get("ingressPerDomain")).booleanValue();
     logger.info(
         "For this domain loadBalancer is: "
             + loadBalancer
             + " ingressPerDomain is: "
-            + ingressPerDomain);
+            + ingressPerDomain
+            + " loadBalancerWebPort is: "
+            + loadBalancerWebPort);
 
     if (loadBalancer.equals("TRAEFIK") && !ingressPerDomain) {
       lbMap.put("name", "traefik-hostrouting-" + domainUid);
@@ -828,6 +833,10 @@ private void createLoadBalancer() throws Exception {
       lbMap.put("name", "traefik-ingress-" + domainUid);
     }
 
+    if (loadBalancer.equals("VOYAGER") && ingressPerDomain) {
+      lbMap.put("name", "voyager-ingress-" + domainUid);
+    }
+
     if (loadBalancer.equals("APACHE")) {
       /* lbMap.put("loadBalancerAppPrepath", "/weblogic");
       lbMap.put("loadBalancerExposeAdminPort", new Boolean(true)); */
@@ -926,11 +935,11 @@ private void callWebAppAndCheckForServerNameInResponse(
                 + " \n "
                 + result.stdout());
       } else {
-        logger.info("webapp invoked successfully");
+        logger.info("webapp invoked successfully for curlCmd:" + curlCmd);
       }
       if (verifyLoadBalancing) {
         String response = result.stdout().trim();
-        // logger.info("response "+ response);
+        logger.info("response: " + response); // TODO remove later!
         for (String key : managedServers.keySet()) {
           if (response.contains(key)) {
             managedServers.put(key, new Boolean(true));
@@ -943,6 +952,7 @@ private void callWebAppAndCheckForServerNameInResponse(
     // error if any managedserver value is false
     if (verifyLoadBalancing) {
       for (Map.Entry<String, Boolean> entry : managedServers.entrySet()) {
+        logger.info("Load balancer will try to reach server " + entry.getKey());
         if (!entry.getValue().booleanValue()) {
           throw new RuntimeException(
               "FAILURE: Load balancer can not reach server " + entry.getKey());

integration-tests/src/test/java/oracle/kubernetes/operator/utils/LoadBalancer.java

@@ -42,6 +42,22 @@ public LoadBalancer(Map lbMap) throws Exception {
         createTraefikIngressPerDomain();
       }
     }
+
+    if (lbMap.get("loadBalancer").equals("VOYAGER")) {
+      String cmdLb = "helm list voyager-operator | grep DEPLOYED";
+      logger.info("Executing cmd " + cmdLb);
+      ExecResult result = ExecCommand.exec(cmdLb);
+      if (result.exitValue() != 0) {
+        createVoyagerLoadBalancer();
+        logger.info("Sleeping for 30 seconds to ensure voyager to be ready");
+        Thread.sleep(30 * 1000);
+      }
+
+      if (((Boolean) lbMap.get("ingressPerDomain")).booleanValue()) {
+        logger.info("Is going to createVoyagerIngressPerDomain");
+        createVoyagerIngressPerDomain();
+      }
+    }
   }
 
   public void createTraefikLoadBalancer() throws Exception {
@@ -148,6 +164,90 @@ private void createTraefikIngress() throws Exception {
     logger.info("Command returned " + outputStr);
   }
 
+  public void createVoyagerLoadBalancer() throws Exception {
+
+    String cmd1 = "helm repo add appscode https://charts.appscode.com/stable/";
+    logger.info("Executing Add Appscode Chart Repository cmd " + cmd1);
+
+    executeHelmCommand(cmd1);
+
+    String cmd2 = "helm repo update";
+    logger.info("Executing Appscode Chart Repository upgrade cmd " + cmd2);
+
+    executeHelmCommand(cmd2);
+
+    String cmd3 =
+        "helm install appscode/voyager --name voyager-operator --version 7.4.0 --namespace voyage "
+            + "--set cloudProvider=baremetal --set apiserver.enableValidatingWebhook=false";
+    logger.info("Executing Install voyager operator cmd " + cmd3);
+
+    executeHelmCommand(cmd3);
+  }
+
+  private void createVoyagerIngressPerDomain() throws Exception {
+    upgradeVoyagerNamespace();
+    logger.info("Sleeping for 20 seconds after upgradeVoyagerNamespace ");
+    Thread.sleep(20 * 1000);
+    createVoyagerIngress();
+    logger.info("Sleeping for 20 seconds after createVoyagerIngress ");
+    Thread.sleep(20 * 1000);
+  }
+
+  private void upgradeVoyagerNamespace() throws Exception {
+
+    StringBuffer cmd = new StringBuffer("helm upgrade ");
+    cmd.append("--reuse-values ")
+        .append("--set ")
+        .append("\"")
+        .append("kubernetes.namespaces={voyager,")
+        .append(lbMap.get("namespace"))
+        .append("}")
+        .append("\"")
+        .append(" --version 7.4.0")
+        .append(" --set cloudProvider=baremetal")
+        .append(" --set apiserver.enableValidatingWebhook=false")
+        .append(" voyager-operator")
+        .append(" appscode/voyager");
+
+    logger.info(" upgradeVoyagerNamespace() Running " + cmd.toString());
+    executeHelmCommand(cmd.toString());
+  }
+
+  private void createVoyagerIngress() throws Exception {
+
+    String chartDir = BaseTest.getProjectRoot() + "/integration-tests/src/test/resources/charts";
+
+    StringBuffer cmd = new StringBuffer("cd ");
+    cmd.append(chartDir).append(" && helm install ingress-per-domain ");
+    cmd.append(" --name ")
+        .append(lbMap.get("name"))
+        .append(" --namespace ")
+        .append(lbMap.get("namespace"))
+        .append(" --set type=VOYAGER")
+        .append(" --set ")
+        .append("wlsDomain.domainUID=")
+        .append(lbMap.get("domainUID"))
+        .append(" --set ")
+        .append("wlsDomain.clusterName=")
+        .append(lbMap.get("clusterName"))
+        .append(" --set ")
+        .append("voyager.webPort=")
+        .append(lbMap.get("loadBalancerWebPort"));
+
+    logger.info("createVoyagerIngress() Running " + cmd.toString());
+    executeHelmCommand(cmd.toString());
+  }
+
+  private void executeHelmCommand(String cmd) throws Exception {
+    ExecResult result = ExecCommand.exec(cmd);
+    if (result.exitValue() != 0) {
+      logger.info("executeHelmCommand failed with " + cmd);
+      reportHelmInstallFailure(cmd, result);
+    }
+    String outputStr = result.stdout().trim();
+    logger.info("Command returned " + outputStr);
+  }
+
   private void reportHelmInstallFailure(String cmd, ExecResult result) throws Exception {
     throw new RuntimeException(getExecFailure(cmd, result));
   }

integration-tests/src/test/resources/charts/ingress-per-domain/values.yaml

@@ -24,4 +24,4 @@ voyager:
   # web port
   webPort: 30305
   # stats port
-  statsPort: 30315
+  #statsPort: 30315