Skip to content

Commit

Permalink
Revert "Tank API V2 Clients Release (#245)"
Browse files Browse the repository at this point in the history
This reverts commit ec74378.
  • Loading branch information
Zakaria-Kofiro authored Jun 30, 2023
1 parent ec74378 commit 08606ce
Show file tree
Hide file tree
Showing 126 changed files with 424 additions and 3,547 deletions.
40 changes: 1 addition & 39 deletions agent/agent_standalone/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -16,46 +16,8 @@
<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>tank-api</artifactId>
<artifactId>agent-client</artifactId>
<version>${project.version}</version>
<exclusions>
<exclusion>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-ui</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>script-engine</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>data-access</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>tank-vm-manager</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>tank-script-processor</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>api</artifactId>
</exclusion>
<exclusion>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
</exclusion>
<exclusion>
<groupId>jakarta.xml.bind</groupId>
<artifactId>jakarta.xml.bind-api</artifactId>
</exclusion>
</exclusions>
</dependency>

<dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import com.intuit.tank.rest.mvc.rest.clients.AgentClient;
import com.intuit.tank.AgentServiceClient;
import com.intuit.tank.harness.HostInfo;
import com.intuit.tank.vm.agent.messages.AgentAvailability;
import com.intuit.tank.vm.agent.messages.AgentAvailabilityStatus;
Expand All @@ -37,23 +37,23 @@
public class StandaloneAgentStartup implements Runnable {

private static Logger LOG = LogManager.getLogger(StandaloneAgentStartup.class);
public static final String SERVICE_RELATIVE_PATH = "/v2/agent";
public static final String SERVICE_RELATIVE_PATH = "/rest/v1/agent-service";
private static String API_HARNESS_COMMAND = "./startAgent.sh";
public static final String METHOD_SETTINGS = "/settings";
public static final String METHOD_SUPPORT = "/support-files";
public static final String METHOD_SUPPORT = "/supportFiles";
private static final long PING_TIME = 1000 * 60 * 5;// five minutes

private String controllerBase;
private AgentAvailability currentAvailability;
private AgentClient agentClient;
private AgentServiceClient agentClient;
private String instanceId;
private String hostname;
private int capacity = 4000;

@Override
public void run() {
CommandListener.startHttpServer(CommandListener.PORT, this);
agentClient = new AgentClient(controllerBase);
agentClient = new AgentServiceClient(controllerBase);

if (hostname != null) {
instanceId = hostname;
Expand Down Expand Up @@ -152,7 +152,7 @@ private void sendAvailability() {
currentAvailability.getInstanceUrl(), currentAvailability.getCapacity(),
currentAvailability.getAvailabilityStatus());
LOG.info("Sending availaability: " + ToStringBuilder.reflectionToString(availability));
agentClient.setStandaloneAgentAvailability(availability);
agentClient.standaloneAgentAvailable(availability);
}

public static void main(String[] args) {
Expand Down
5 changes: 0 additions & 5 deletions agent/agent_standalone_pkg/src/main/assembly/assembly.xml
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,6 @@
<useProjectArtifact>true</useProjectArtifact>
<unpack>true</unpack>
<scope>runtime</scope>
<unpackOptions>
<excludes>
<exclude>**/Log4j2Plugins.dat</exclude>
</excludes>
</unpackOptions>
</dependencySet>
</dependencySets>
</assembly>
Original file line number Diff line number Diff line change
Expand Up @@ -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 = "/v2/agent";
private static final String SERVICE_RELATIVE_PATH = "/rest/v1/agent-service";
private static final String METHOD_SETTINGS = "/settings";
private static final String API_HARNESS_COMMAND = "./startAgent.sh";
private static final String METHOD_SUPPORT = "/support-files";
private static final String METHOD_SUPPORT = "/supportFiles";
private static final int[] FIBONACCI = new int[] { 1, 1, 2, 3, 5, 8, 13 };

private final String controllerBaseUrl;
Expand Down Expand Up @@ -120,8 +120,5 @@ 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);
}
}
45 changes: 1 addition & 44 deletions agent/apiharness/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -27,50 +27,6 @@
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>tank-api</artifactId>
<version>${project.version}</version>
<exclusions>
<exclusion>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-ui</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>script-engine</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>data-access</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>tank-vm-manager</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>tank-script-processor</artifactId>
</exclusion>
<exclusion>
<groupId>${project.groupId}</groupId>
<artifactId>api</artifactId>
</exclusion>
<exclusion>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
</exclusion>
<exclusion>
<groupId>jakarta.xml.bind</groupId>
<artifactId>jakarta.xml.bind-api</artifactId>
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>agent-client</artifactId>
Expand Down Expand Up @@ -125,4 +81,5 @@
<version>${project.version}</version>
</dependency>
</dependencies>

</project>
Original file line number Diff line number Diff line change
Expand Up @@ -18,10 +18,10 @@
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

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.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.harness.logging.LogUtil;
import com.intuit.tank.reporting.api.TPSInfoContainer;
import com.intuit.tank.vm.agent.messages.WatsAgentStatusResponse;
Expand All @@ -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 AgentClient client;
private static CloudServiceClient client;
private static CloudVmStatus status;
private long reportInterval = APIMonitor.MIN_REPORT_TIME;
private boolean isLocal;
Expand All @@ -45,7 +45,7 @@ public APIMonitor(Boolean isLocal, CloudVmStatus vmStatus) {
this.isLocal = isLocal;
status = vmStatus;
try {
client = new AgentClient(APITestHarness.getInstance().getTankConfig().getControllerBase());
client = new CloudServiceClient(APITestHarness.getInstance().getTankConfig().getControllerBase());
reportInterval = Math.max(APITestHarness.getInstance().getTankConfig().getAgentConfig()
.getStatusReportIntervalMilis(reportInterval), MIN_REPORT_TIME);
} catch (Exception e) {
Expand All @@ -65,15 +65,15 @@ public void run() {
newStatus.setTotalTps(tpsInfo.getTotalTps());
sendTps(tpsInfo);
}
if (!isLocal) client.setInstanceStatus(newStatus.getInstanceId(), newStatus);
if (!isLocal) client.setVmStatus(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.setInstanceStatus(newStatus.getInstanceId(), newStatus);
client.setVmStatus(newStatus.getInstanceId(), newStatus);
}

private void sendTps(final TPSInfoContainer tpsInfo) {
Expand Down Expand Up @@ -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.setInstanceStatus(status.getInstanceId(), status);
client.setVmStatus(status.getInstanceId(), status);
} catch (Exception e) {
LOG.error("Error sending status to controller: " + e.toString(), e);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@
import org.apache.logging.log4j.core.config.LoggerConfig;
import org.apache.logging.log4j.message.ObjectMessage;

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.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.harness.data.HDTestPlan;
import com.intuit.tank.harness.data.HDWorkload;
import com.intuit.tank.harness.logging.LogUtil;
Expand Down Expand Up @@ -252,7 +252,7 @@ private void startHttp(String baseUrl) {
if (baseUrl == null) {
baseUrl = AmazonUtil.getControllerBaseUrl();
}
AgentClient client = new AgentClient(baseUrl);
AgentServiceClient client = new AgentServiceClient(baseUrl);
String instanceUrl = null;
int retryCount = 0;
while (instanceUrl == null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import java.util.Map;
import java.util.stream.Collectors;

import com.intuit.tank.vm.vmManager.models.UserDetail;
import com.intuit.tank.api.model.v1.cloud.UserDetail;

/**
*
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package com.intuit.tank.harness;

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.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.api.enumerated.JobStatus;
import com.intuit.tank.vm.api.enumerated.VMImageType;
import com.intuit.tank.vm.api.enumerated.VMRegion;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

import java.util.List;

import com.intuit.tank.vm.vmManager.models.UserDetail;
import com.intuit.tank.api.model.v1.cloud.UserDetail;
import com.intuit.tank.test.TestGroups;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
Expand Down
5 changes: 0 additions & 5 deletions agent/apiharness_pkg/src/main/assembly/assembly.xml
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,6 @@
<useProjectArtifact>true</useProjectArtifact>
<unpack>true</unpack>
<scope>runtime</scope>
<unpackOptions>
<excludes>
<exclude>**/Log4j2Plugins.dat</exclude>
</excludes>
</unpackOptions>
</dependencySet>
</dependencySets>
</assembly>
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ private ProjectServiceUrlBuilder() {
*/
public static String getScriptXmlUrl(String jobId) {
String baseUrl = new TankConfig().getControllerBase();
return baseUrl + "/v2/jobs/script/" + jobId;
return baseUrl + "/rest/v1/project-service/script/" + jobId;
}

}
Loading

0 comments on commit 08606ce

Please sign in to comment.