Optimize method for reading the files generated by the Terraform

eclipse-xpanse · Nov 8, 2024 · 5c84c3c · 5c84c3c
1 parent 7e2ec28
commit 5c84c3c
Show file tree

Hide file tree

Showing 11 changed files with 489 additions and 487 deletions.
diff --git a/...java/org/eclipse/xpanse/terraform/boot/api/controllers/TerraformBootFromDirectoryApi.java b/...java/org/eclipse/xpanse/terraform/boot/api/controllers/TerraformBootFromDirectoryApi.java
@@ -10,9 +10,12 @@
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.Pattern;
+import java.io.File;
+import java.util.List;
 import java.util.Objects;
 import java.util.UUID;
 import lombok.extern.slf4j.Slf4j;
@@ -27,10 +30,9 @@
 import org.eclipse.xpanse.terraform.boot.models.response.TerraformResult;
 import org.eclipse.xpanse.terraform.boot.models.validation.TerraformValidationResult;
 import org.eclipse.xpanse.terraform.boot.terraform.service.TerraformDirectoryService;
+import org.eclipse.xpanse.terraform.boot.terraform.service.TerraformScriptsHelper;
 import org.eclipse.xpanse.terraform.boot.terraform.tool.TerraformVersionsHelper;
 import org.slf4j.MDC;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.CrossOrigin;
@@ -53,14 +55,10 @@
 @RequestMapping("/terraform-boot/directory")
 public class TerraformBootFromDirectoryApi {
 
-    private final TerraformDirectoryService terraformDirectoryService;
-
-    @Autowired
-    public TerraformBootFromDirectoryApi(
-            @Qualifier("terraformDirectoryService")
-            TerraformDirectoryService terraformDirectoryService) {
-        this.terraformDirectoryService = terraformDirectoryService;
-    }
+    @Resource
+    private TerraformDirectoryService directoryService;
+    @Resource
+    private TerraformScriptsHelper scriptsHelper;
 
     /**
      * Method to validate Terraform modules.
@@ -83,7 +81,7 @@ public TerraformValidationResult validateFromDirectory(
             @PathVariable("terraform_version") String terraformVersion) {
         UUID uuid = UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
-        return terraformDirectoryService.tfValidateFromDirectory(moduleDirectory, terraformVersion);
+        return directoryService.tfValidateFromDirectory(moduleDirectory, terraformVersion);
     }
 
     /**
@@ -105,7 +103,8 @@ public TerraformResult deployFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        return terraformDirectoryService.deployFromDirectory(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        return directoryService.deployFromDirectory(request, moduleDirectory, scriptFiles);
     }
 
     /**
@@ -127,7 +126,8 @@ public TerraformResult modifyFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        return terraformDirectoryService.modifyFromDirectory(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        return directoryService.modifyFromDirectory(request, moduleDirectory, scriptFiles);
     }
 
     /**
@@ -150,7 +150,8 @@ public TerraformResult destroyFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        return terraformDirectoryService.destroyFromDirectory(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        return directoryService.destroyFromDirectory(request, moduleDirectory, scriptFiles);
     }
 
     /**
@@ -174,8 +175,7 @@ public TerraformPlan plan(
                 : (Objects.nonNull(uuid) ? uuid : UUID.randomUUID());
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        return terraformDirectoryService.getTerraformPlanFromDirectory(request,
-                moduleDirectory);
+        return directoryService.getTerraformPlanFromDirectory(request, moduleDirectory);
     }
 
     /**
@@ -196,7 +196,8 @@ public void asyncDeployFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        terraformDirectoryService.asyncDeployWithScripts(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        directoryService.asyncDeployWithScripts(request, moduleDirectory, scriptFiles);
     }
 
     /**
@@ -217,7 +218,8 @@ public void asyncModifyFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        terraformDirectoryService.asyncModifyWithScripts(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        directoryService.asyncModifyWithScripts(request, moduleDirectory, scriptFiles);
     }
 
     /**
@@ -238,6 +240,7 @@ public void asyncDestroyFromDirectory(
                 ? request.getRequestId() : UUID.randomUUID();
         MDC.put(REQUEST_ID, uuid.toString());
         request.setRequestId(uuid);
-        terraformDirectoryService.asyncDestroyWithScripts(request, moduleDirectory);
+        List<File> scriptFiles = scriptsHelper.getDeploymentFilesFromTaskWorkspace(moduleDirectory);
+        directoryService.asyncDestroyWithScripts(request, moduleDirectory, scriptFiles);
     }
 }
diff --git a/.../xpanse/terraform/boot/models/request/directory/TerraformDestroyFromDirectoryRequest.java b/.../xpanse/terraform/boot/models/request/directory/TerraformDestroyFromDirectoryRequest.java
@@ -24,7 +24,7 @@
 public class TerraformDestroyFromDirectoryRequest {
 
     @Schema(description = "Id of the request")
-    UUID requestId;
+    private UUID requestId;
 
     @NotNull
     @NotBlank

diff --git a/...e/xpanse/terraform/boot/models/request/directory/TerraformModifyFromDirectoryRequest.java b/...e/xpanse/terraform/boot/models/request/directory/TerraformModifyFromDirectoryRequest.java
@@ -24,7 +24,7 @@
 public class TerraformModifyFromDirectoryRequest {
 
     @Schema(description = "Id of the request")
-    UUID requestId;
+    private UUID requestId;
 
     @NotNull
     @NotBlank

diff --git a/src/main/java/org/eclipse/xpanse/terraform/boot/models/response/TerraformResult.java b/src/main/java/org/eclipse/xpanse/terraform/boot/models/response/TerraformResult.java
@@ -32,7 +32,7 @@ public class TerraformResult {
     private String terraformState;
     @Schema(description = "Data of all other files generated by the terraform execution."
             + "The map key contains the file name and value is the file contents as string.")
-    private Map<String, String> importantFileContentMap;
+    private Map<String, String> generatedFileContentMap;
     @Schema(description = "The version of the Terraform binary used to execute scripts.")
     private String terraformVersionUsed;
 }
diff --git a/...ava/org/eclipse/xpanse/terraform/boot/models/validation/TerraformValidateDiagnostics.java b/...ava/org/eclipse/xpanse/terraform/boot/models/validation/TerraformValidateDiagnostics.java
@@ -6,6 +6,7 @@
 package org.eclipse.xpanse.terraform.boot.models.validation;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 
 /**
@@ -15,6 +16,7 @@
 @JsonIgnoreProperties(ignoreUnknown = true)
 public class TerraformValidateDiagnostics {
 
+    @Schema(description = "Detail of validation error.")
     private String detail;
 
 }