Feat: Add support for redeployment of an existing environment (#62)

* Update: Add support for environment rebuild in upload API

Modified the upload API to support updating an existing environment of a property and added functionality for triggering a redeployment of an existing environment. Introduced a new boolean attribute 'rebuild' in the form data. When set to true, it initiates a redeployment process while keeping all other form attributes and processes unchanged. This commit includes all related changes.

* Refactor: Change `rebuildEnvironment` field type to String and add parsing logic

* Fix: Address "spec is immutable" error for bound claims

Author: arkaprovob

src/main/java/io/spaship/operator/api/SpaDeploymentController.java

@@ -45,7 +45,9 @@ public String uploadSPA(@MultipartForm FormData formData) {
     var response = requestTagging(formData.website);
     //[0]file-path[1]unique-trace-id[2]website-name
     var fileUploadParams = new Triplet<>(formData.getfilePath(), response, formData.website);
-    spaUploadHandlerService.handleFileUpload(fileUploadParams);
+    boolean rebuild = Boolean.parseBoolean(formData.rebuildEnvironment);
+    spaUploadHandlerService.handleFileUpload(fileUploadParams,rebuild);
+
     JsonObject object = new JsonObject();
     object.put("description", response.getValue0());
     object.put("traceId", response.getValue1());

src/main/java/io/spaship/operator/business/SPAUploadHandler.java

@@ -50,7 +50,7 @@ public SPAUploadHandler(Operator k8sOperator, SideCarOperations sideCarOperation
 
 
   //[0]file-store-path[1]ops-tracing-id[2]website-name
-  public void handleFileUpload(Triplet<Path, Pair<String, UUID>, String> input) {
+  public void handleFileUpload(Triplet<Path, Pair<String, UUID>, String> input, boolean rebuildEnvironment) {
     LOG.debug("     deployment process initiated with details {}", input);
 
     Uni.createFrom()
@@ -59,7 +59,7 @@ public void handleFileUpload(Triplet<Path, Pair<String, UUID>, String> input) {
       .map(this::buildEnvironmentList)
       .onItem()
       .transformToMulti(envList -> Multi.createFrom().iterable(envList))
-      .map(this::processEnvironment)
+      .map((Environment env) -> processEnvironment(env, rebuildEnvironment))
       .map(this::createOrUpdateSPA)
       .onFailure()
       .recoverWithItem(throwable -> {
@@ -232,7 +232,7 @@ private void logOperationDetails(OperationResponse operationResponse) {
     }
   }
 
-  private OperationResponse processEnvironment(Environment env) {
+  private OperationResponse processEnvironment(Environment env, boolean rebuildEnvironment) {
     if (env.isUpdateRestriction() && k8sOperator.environmentExists(env)) {
       LOG.debug("environment exists but update restriction enforced, " +
         "environment details are as follows {}", env);
@@ -253,7 +253,7 @@ private OperationResponse processEnvironment(Environment env) {
         .build();
     }
 
-    return k8sOperator.createOrUpdateEnvironment(env);
+    return k8sOperator.createOrUpdateEnvironment(env, rebuildEnvironment);
   }
 
   private OperationResponse appDeleteOps(Environment environment) {

src/main/java/io/spaship/operator/service/Operations.java

@@ -5,7 +5,7 @@
 
 public interface Operations {
 
-  OperationResponse createOrUpdateEnvironment(Environment environment);
+  OperationResponse createOrUpdateEnvironment(Environment environment, boolean rebuildEnvironment);
 
 
 }

src/main/java/io/spaship/operator/service/k8s/Operator.java

@@ -67,16 +67,18 @@ private String setAppInstanceValue() {
         return propertyValue;
     }
 
-    public OperationResponse createOrUpdateEnvironment(Environment environment) {
+
+
+    public OperationResponse createOrUpdateEnvironment(Environment environment, boolean rebuildEnvironment) {
 
         propertyValidation();
 
         ReUsableItems.enforceOpsLocking(new Pair<>(environment.getIdentification(), environment.getTraceID()));
 
         boolean envExists = environmentExists(environment);
         LOG.debug("envExists is {}", envExists);
-        if (!envExists)
-            createNewEnvironment(environment);
+        if (!envExists || rebuildEnvironment)
+            createNewEnvironment(environment, rebuildEnvironment);
         String sideCarSvcUrl = environmentSidecarUrl(environment);
         // todo mutability is not good, we should not change the state of the object
         environment.setOperationPerformed(true);
@@ -140,12 +142,13 @@ public Uni<OperationResponse> deleteEnvironment(Environment environment) {
 
     }
 
-    void createNewEnvironment(Environment environment) {
-        if (!nameSpaceExists(environment))
+    void createNewEnvironment(Environment environment, boolean rebuildEnvironment) {
+        if (!rebuildEnvironment && !nameSpaceExists(environment)) {
             createMpPlusProject(environment);
+        }
         KubernetesList result = buildK8sResourceList(environment);
         LOG.debug("create environment is in progress");
-        processK8sList(result, environment.getTraceID(), environment.getNameSpace());
+        processK8sList(result, environment.getTraceID(), environment.getNameSpace(),rebuildEnvironment);
     }
 
     // TODO: this implementation is mp+ specific, using inheritance
@@ -373,7 +376,7 @@ public boolean isEnvironmentAvailable(Environment environment) {
     }
 
     // TODO remove if blocks
-    private void processK8sList(KubernetesList result, UUID tracing, String nameSpace) {
+    private void processK8sList(KubernetesList result, UUID tracing, String nameSpace, boolean rebuildEnvironment) {
 
         var eb = EventStructure.builder().uuid(tracing.toString());
 
@@ -400,7 +403,7 @@ private void processK8sList(KubernetesList result, UUID tracing, String nameSpac
                         .state("StatefulSet created");
 
             }
-            if (item instanceof PersistentVolumeClaim pvc) {
+            if (!rebuildEnvironment && item instanceof PersistentVolumeClaim pvc) {
                 LOG.debug("creating new pvc in K8s, tracing = {}", tracing);
                 ocClient.persistentVolumeClaims().inNamespace(nameSpace).resource(pvc).createOrReplace();
                 eb.websiteName(item.getMetadata().getLabels().get(ApplicationConstants.WEBSITE))

src/main/java/io/spaship/operator/type/FormData.java

@@ -25,6 +25,9 @@ public class FormData {
   @RestForm("spa")
   public FileUpload file;
 
+  @RestForm("rebuild")
+  public String rebuildEnvironment;
+
   public String fileName() {
     validateFileUpload();
     return this.file.fileName();