Tank API V2 Clients Release

agent/agent_standalone/pom.xml

@@ -16,7 +16,7 @@
   <dependencies>
     <dependency>
       <groupId>${project.groupId}</groupId>
-      <artifactId>agent-client</artifactId>
+      <artifactId>tank-api</artifactId>
       <version>${project.version}</version>
     </dependency>
 

agent/agent_standalone/src/main/java/com/intuit/tank/standalone/agent/StandaloneAgentStartup.java

@@ -28,7 +28,7 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import com.intuit.tank.AgentServiceClient;
+import com.intuit.tank.rest.mvc.rest.clients.AgentClient;
 import com.intuit.tank.harness.HostInfo;
 import com.intuit.tank.vm.agent.messages.AgentAvailability;
 import com.intuit.tank.vm.agent.messages.AgentAvailabilityStatus;
@@ -37,23 +37,23 @@
 public class StandaloneAgentStartup implements Runnable {
 
     private static Logger LOG = LogManager.getLogger(StandaloneAgentStartup.class);
-    public static final String SERVICE_RELATIVE_PATH = "/rest/v1/agent-service";
+    public static final String SERVICE_RELATIVE_PATH = "/v2/agent";
     private static String API_HARNESS_COMMAND = "./startAgent.sh";
     public static final String METHOD_SETTINGS = "/settings";
-    public static final String METHOD_SUPPORT = "/supportFiles";
+    public static final String METHOD_SUPPORT = "/support-files";
     private static final long PING_TIME = 1000 * 60 * 5;// five minutes
 
     private String controllerBase;
     private AgentAvailability currentAvailability;
-    private AgentServiceClient agentClient;
+    private AgentClient agentClient;
     private String instanceId;
     private String hostname;
     private int capacity = 4000;
 
     @Override
     public void run() {
         CommandListener.startHttpServer(CommandListener.PORT, this);
-        agentClient = new AgentServiceClient(controllerBase);
+        agentClient = new AgentClient(controllerBase);
 
         if (hostname != null) {
             instanceId = hostname;
@@ -152,7 +152,7 @@ private void sendAvailability() {
                 currentAvailability.getInstanceUrl(), currentAvailability.getCapacity(),
                 currentAvailability.getAvailabilityStatus());
         LOG.info("Sending availaability: " + ToStringBuilder.reflectionToString(availability));
-        agentClient.standaloneAgentAvailable(availability);
+        agentClient.setStandaloneAgentAvailability(availability);
     }
 
     public static void main(String[] args) {

agent/agent_standalone_pkg/pom.xml

@@ -26,20 +26,40 @@
     <plugins>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
-        <artifactId>maven-deploy-plugin</artifactId>
-        <configuration>
-          <skip>true</skip>
-        </configuration>
+        <artifactId>maven-shade-plugin</artifactId>
+        <version>3.1.1</version>
+        <executions>
+          <execution>
+            <phase>package</phase>
+            <goals>
+              <goal>shade</goal>
+            </goals>
+            <configuration>
+              <createDependencyReducedPom>false</createDependencyReducedPom>
+              <outputFile>target/agent-standalone-all.jar</outputFile>gs
+              <transformers>
+                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                  <mainClass>com.intuit.tank.standalone.agent.StandaloneAgentStartup</mainClass>
+                </transformer>
+              </transformers>
+              <filters>
+                <filter>
+                  <artifact>*:*</artifact>
+                  <excludes>
+                    <exclude>**/Log4j2Plugins.dat</exclude>
+                  </excludes>
+                </filter>
+              </filters>
+            </configuration>
+          </execution>
+        </executions>
       </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-assembly-plugin</artifactId>
-
         <configuration>
-
           <finalName>agent-standalone</finalName>
           <descriptors>
-            <descriptor>src/main/assembly/assembly.xml</descriptor>
             <descriptor>src/main/assembly/zip-assembly.xml</descriptor>
           </descriptors>
           <archive>

agent/agent_startup/src/main/java/com/intuit/tank/agent/AgentStartup.java

@@ -34,10 +34,10 @@
 
 public class AgentStartup implements Runnable {
     private static final Logger logger = LogManager.getLogger(AgentStartup.class);
-    private static final String SERVICE_RELATIVE_PATH = "/rest/v1/agent-service";
+    private static final String SERVICE_RELATIVE_PATH = "/v2/agent";
     private static final String METHOD_SETTINGS = "/settings";
     private static final String API_HARNESS_COMMAND = "./startAgent.sh";
-    private static final String METHOD_SUPPORT = "/supportFiles";
+    private static final String METHOD_SUPPORT = "/support-files";
     private static final int[] FIBONACCI = new int[] { 1, 1, 2, 3, 5, 8, 13 };
 
     private final String controllerBaseUrl;
@@ -120,5 +120,8 @@ private static void usage() {
         System.out.println("Tank Test Startup Usage:");
         System.out.println("java -cp agent-startup-pkg-1.0-all.jar com/intuit/tank/agent/AgentStartup <options>");
         System.out.println("-controller=<controller_base_url>:  The url of the controller to get test info from");
+        System.out.println("Service Path: " + SERVICE_RELATIVE_PATH);
+        System.out.println("Settings Method: " + METHOD_SETTINGS);
+        System.out.println("Support Files Method: " + METHOD_SUPPORT);
     }
 }

agent/apiharness/pom.xml

@@ -27,6 +27,12 @@
       <version>${project.version}</version>
     </dependency>
 
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>tank-api</artifactId>
+      <version>${project.version}</version>
+    </dependency>
+
     <dependency>
       <groupId>${project.groupId}</groupId>
       <artifactId>agent-client</artifactId>
@@ -81,5 +87,4 @@
       <version>${project.version}</version>
     </dependency>
   </dependencies>
-
 </project>

agent/apiharness/src/main/java/com/intuit/tank/harness/APIMonitor.java

@@ -18,10 +18,10 @@
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
-import com.intuit.tank.CloudServiceClient;
-import com.intuit.tank.api.model.v1.cloud.CloudVmStatus;
-import com.intuit.tank.api.model.v1.cloud.VMStatus;
-import com.intuit.tank.api.model.v1.cloud.ValidationStatus;
+import com.intuit.tank.rest.mvc.rest.clients.AgentClient;
+import com.intuit.tank.vm.vmManager.models.CloudVmStatus;
+import com.intuit.tank.vm.vmManager.models.VMStatus;
+import com.intuit.tank.vm.vmManager.models.ValidationStatus;
 import com.intuit.tank.harness.logging.LogUtil;
 import com.intuit.tank.reporting.api.TPSInfoContainer;
 import com.intuit.tank.vm.agent.messages.WatsAgentStatusResponse;
@@ -36,7 +36,7 @@ public class APIMonitor implements Runnable {
     private static final int MIN_REPORT_TIME = 15000;
     private static Logger LOG = LogManager.getLogger(APIMonitor.class);
     private static boolean doMonitor = true;
-    private static CloudServiceClient client;
+    private static AgentClient client;
     private static CloudVmStatus status;
     private long reportInterval = APIMonitor.MIN_REPORT_TIME;
     private boolean isLocal;
@@ -45,7 +45,7 @@ public APIMonitor(Boolean isLocal, CloudVmStatus vmStatus) {
         this.isLocal = isLocal;
         status = vmStatus;
         try {
-            client = new CloudServiceClient(APITestHarness.getInstance().getTankConfig().getControllerBase());
+            client = new AgentClient(APITestHarness.getInstance().getTankConfig().getControllerBase());
             reportInterval = Math.max(APITestHarness.getInstance().getTankConfig().getAgentConfig()
                     .getStatusReportIntervalMilis(reportInterval), MIN_REPORT_TIME);
         } catch (Exception e) {
@@ -65,15 +65,15 @@ public void run() {
                     newStatus.setTotalTps(tpsInfo.getTotalTps());
                     sendTps(tpsInfo);
                 }
-                if (!isLocal) client.setVmStatus(newStatus.getInstanceId(), newStatus);
+                if (!isLocal) client.setInstanceStatus(newStatus.getInstanceId(), newStatus);
                 APITestHarness.getInstance().checkAgentThreads();
                 Thread.sleep(reportInterval);
             } catch (Exception t) {
                 LOG.error(LogUtil.getLogMessage("Unable to send status metrics | " + t.getMessage()), t);
             }
         }
         CloudVmStatus newStatus = createStatus(APITestHarness.getInstance().getStatus());
-        client.setVmStatus(newStatus.getInstanceId(), newStatus);
+        client.setInstanceStatus(newStatus.getInstanceId(), newStatus);
     }
 
     private void sendTps(final TPSInfoContainer tpsInfo) {
@@ -136,7 +136,7 @@ public synchronized static void setJobStatus(JobStatus jobStatus) {
                         stats.getMaxVirtualUsers(),
                         stats.getCurrentNumberUsers(), status.getStartTime(), endTime);
                 status.setUserDetails(APITestHarness.getInstance().getUserTracker().getSnapshot());
-                client.setVmStatus(status.getInstanceId(), status);
+                client.setInstanceStatus(status.getInstanceId(), status);
             } catch (Exception e) {
                 LOG.error("Error sending status to controller: " + e.toString(), e);
             }

agent/apiharness/src/main/java/com/intuit/tank/harness/APITestHarness.java

@@ -41,10 +41,10 @@
 import org.apache.logging.log4j.core.config.LoggerConfig;
 import org.apache.logging.log4j.message.ObjectMessage;
 
-import com.intuit.tank.AgentServiceClient;
-import com.intuit.tank.api.model.v1.cloud.CloudVmStatus;
-import com.intuit.tank.api.model.v1.cloud.VMStatus;
-import com.intuit.tank.api.model.v1.cloud.ValidationStatus;
+import com.intuit.tank.rest.mvc.rest.clients.AgentClient;
+import com.intuit.tank.vm.vmManager.models.CloudVmStatus;
+import com.intuit.tank.vm.vmManager.models.VMStatus;
+import com.intuit.tank.vm.vmManager.models.ValidationStatus;
 import com.intuit.tank.harness.data.HDTestPlan;
 import com.intuit.tank.harness.data.HDWorkload;
 import com.intuit.tank.harness.logging.LogUtil;
@@ -252,7 +252,7 @@ private void startHttp(String baseUrl) {
         if (baseUrl == null) {
             baseUrl = AmazonUtil.getControllerBaseUrl();
         }
-        AgentServiceClient client = new AgentServiceClient(baseUrl);
+        AgentClient client = new AgentClient(baseUrl);
         String instanceUrl = null;
         int retryCount = 0;
         while (instanceUrl == null) {

agent/apiharness/src/main/java/com/intuit/tank/harness/UserTracker.java

@@ -19,7 +19,7 @@
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import com.intuit.tank.api.model.v1.cloud.UserDetail;
+import com.intuit.tank.vm.vmManager.models.UserDetail;
 
 /**
  * 

agent/apiharness/src/test/java/com/intuit/tank/harness/APIMonitorTest.java

@@ -1,8 +1,8 @@
 package com.intuit.tank.harness;
 
-import com.intuit.tank.api.model.v1.cloud.CloudVmStatus;
-import com.intuit.tank.api.model.v1.cloud.VMStatus;
-import com.intuit.tank.api.model.v1.cloud.ValidationStatus;
+import com.intuit.tank.vm.vmManager.models.CloudVmStatus;
+import com.intuit.tank.vm.vmManager.models.VMStatus;
+import com.intuit.tank.vm.vmManager.models.ValidationStatus;
 import com.intuit.tank.vm.api.enumerated.JobStatus;
 import com.intuit.tank.vm.api.enumerated.VMImageType;
 import com.intuit.tank.vm.api.enumerated.VMRegion;

agent/apiharness/src/test/java/com/intuit/tank/harness/UserTrackerTest.java

@@ -18,7 +18,7 @@
 
 import java.util.List;
 
-import com.intuit.tank.api.model.v1.cloud.UserDetail;
+import com.intuit.tank.vm.vmManager.models.UserDetail;
 import com.intuit.tank.test.TestGroups;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;

agent/apiharness_pkg/pom.xml

@@ -36,35 +36,38 @@
     <plugins>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
-        <artifactId>maven-deploy-plugin</artifactId>
-        <configuration>
-          <skip>true</skip>
-        </configuration>
-      </plugin>
-      <plugin>
-        <groupId>org.apache.maven.plugins</groupId>
-        <artifactId>maven-assembly-plugin</artifactId>
-        <configuration>
-        <finalName>apiharness-1.0</finalName>
-          <descriptors>
-            <descriptor>src/main/assembly/assembly.xml</descriptor>
-          </descriptors>
-          <archive>
-            <manifest>
-              <mainClass>com.intuit.tank.harness.APITestHarness</mainClass>
-            </manifest>
-          </archive>
-        </configuration>
+        <artifactId>maven-shade-plugin</artifactId>
+        <version>3.1.1</version>
         <executions>
           <execution>
-            <id>make-assembly</id> <!-- this is used for inheritance merges -->
-            <phase>package</phase> <!-- bind to the packaging phase -->
+            <phase>package</phase>
             <goals>
-              <goal>single</goal>
+              <goal>shade</goal>
             </goals>
+            <configuration>
+              <createDependencyReducedPom>false</createDependencyReducedPom>
+              <outputFile>target/apiharness-1.0-all.jar</outputFile>
+              <transformers>
+                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                  <mainClass>com.intuit.tank.harness.APITestHarness</mainClass>
+                </transformer>
+              </transformers>
+              <filters>
+                <filter>
+                  <artifact>*:*</artifact>
+                  <excludes>
+                    <exclude>**/Log4j2Plugins.dat</exclude>
+                  </excludes>
+                </filter>
+              </filters>
+            </configuration>
           </execution>
         </executions>
       </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-jarsigner-plugin</artifactId>
+      </plugin>
     </plugins>
   </build>
 

api/src/main/java/com/intuit/tank/vm/api/service/v1/project/ProjectServiceUrlBuilder.java

@@ -39,7 +39,7 @@ private ProjectServiceUrlBuilder() {
      */
     public static String getScriptXmlUrl(String jobId) {
         String baseUrl = new TankConfig().getControllerBase();
-        return baseUrl + "/rest/v1/project-service/script/" + jobId;
+        return baseUrl + "/v2/jobs/script/" + jobId;
     }
 
 }

rest/api/cloud/src/main/java/com/intuit/tank/api/cloud/VMTracker.java → api/src/main/java/com/intuit/tank/vm/vmManager/VMTracker.java

@@ -1,7 +1,7 @@
 /**
  * Copyright 2011 Intuit Inc. All Rights Reserved
  */
-package com.intuit.tank.api.cloud;
+package com.intuit.tank.vm.vmManager;
 
 /*
  * #%L
@@ -20,9 +20,9 @@
 
 import javax.annotation.Nonnull;
 
-import com.intuit.tank.api.model.v1.cloud.CloudVmStatus;
-import com.intuit.tank.api.model.v1.cloud.CloudVmStatusContainer;
-import com.intuit.tank.api.model.v1.cloud.ProjectStatusContainer;
+import com.intuit.tank.vm.vmManager.models.CloudVmStatus;
+import com.intuit.tank.vm.vmManager.models.CloudVmStatusContainer;
+import com.intuit.tank.vm.vmManager.models.ProjectStatusContainer;
 import com.intuit.tank.vm.event.JobEvent;
 
 /**