delete & create agent

Author: stargwq

platform-api/src/main/java/com/flow/platform/api/service/AgentServiceImpl.java

@@ -177,8 +177,7 @@ public void delete(AgentPath agentPath){
             HttpClient.build(platformURL.getAgentDeleteUrl())
                 .post(agent.toJson())
                 .withContentType(ContentType.APPLICATION_JSON)
-                .retry(httpRetryTimes)
-                .bodyAsString().getBody();
+                .retry(httpRetryTimes);
 
         } catch (UnsupportedEncodingException e) {
             throw new IllegalStatusException(e.getMessage());
@@ -194,15 +193,17 @@ private String buildAgentWebhook() {
      */
     private Agent findAgent(AgentPath agentPath){
         String url = platformURL.getAgentFindUrl() + "?" + "zone=" + agentPath.getZone() + "&" + "name=" + agentPath.getName();
-        String res = HttpClient.build(url)
+        HttpResponse<String> response = HttpClient.build(url)
             .get()
             .retry(httpRetryTimes)
-            .bodyAsString().getBody();
+            .bodyAsString();
 
-        if (Strings.isNullOrEmpty(res)) {
+        if (!response.hasSuccess()) {
             throw new HttpException("Unable to delete agent");
         }
-        Agent agent = Agent.parse(res, Agent.class);
+
+        Agent agent = Agent.parse(response.getBody(), Agent.class);
+
         if (agent.getStatus() == AgentStatus.BUSY){
             throw new IllegalStatusException("agent is busy, please wait");
         }

platform-control-center/src/main/java/com/flow/platform/cc/service/AgentServiceImpl.java

@@ -35,6 +35,7 @@
 import com.flow.platform.util.Logger;
 import com.google.common.base.Strings;
 import com.google.gson.annotations.Expose;
+import java.sql.SQLDataException;
 import java.time.ZonedDateTime;
 import java.time.temporal.ChronoUnit;
 import java.util.Collection;
@@ -227,6 +228,11 @@ public AgentSettings settings(String token) {
 
     @Override
     public void delete(Agent agent){
-        agentDao.delete(agent);
+        try {
+            agentDao.delete(agent);
+        } catch (Throwable e){
+            throw new UnsupportedOperationException("delete agent failure " + e.getMessage());
+        }
+
     }
 }