remove idle suffix from bg deploy

multiapps-controller-api/src/main/resources/mtarest.yaml

@@ -37,127 +37,6 @@ paths:
             $ref: "#/definitions/Info"
       security:
       - oauth2: []
-  /api/v1/spaces/{spaceGuid}/files:
-    get:
-      summary: ""
-      description: "Retrieves all Multi-Target Application files "
-      operationId: "getMtaFiles"
-      produces:
-      - "application/json"
-      parameters:
-      - name: "spaceGuid"
-        in: "path"
-        description: "GUID of space with mtas"
-        required: true
-        type: "string"
-      - name: "namespace"
-        in: "query"
-        description: "Filter mtas by namespace"
-        required: false
-        type: "string"
-      responses:
-        200:
-          description: "OK"
-          schema:
-            type: "array"
-            items:
-              $ref: "#/definitions/FileMetadata"
-      security:
-      - oauth2: []
-    post:
-      summary: ""
-      description: "Uploads a Multi Target Application archive or an Extension Descriptor "
-      operationId: "uploadMtaFile"
-      consumes:
-      - "multipart/form-data"
-      produces:
-      - "application/json"
-      parameters:
-      - name: "spaceGuid"
-        in: "path"
-        description: "GUID of space you wish to deploy in"
-        required: true
-        type: "string"
-      - name: "namespace"
-        in: "query"
-        description: "file namespace"
-        required: false
-        type: "string"
-      responses:
-        200:
-          description: "successful operation"
-          schema:
-            $ref: "#/definitions/FileMetadata"
-        201:
-          description: "Created"
-          schema:
-            $ref: "#/definitions/FileMetadata"
-      security:
-      - oauth2: []
-  /api/v1/spaces/{spaceGuid}/files/async:
-    post:
-      summary: ""
-      description: "Uploads a Multi Target Application archive or an Extension Descriptor\
-        \ from a remote endpoint"
-      operationId: "startUploadFromUrl"
-      consumes:
-      - "application/json"
-      parameters:
-      - name: "spaceGuid"
-        in: "path"
-        description: "GUID of space you wish to deploy in"
-        required: true
-        type: "string"
-      - name: "namespace"
-        in: "query"
-        description: "file namespace"
-        required: false
-        type: "string"
-      - in: "body"
-        name: "body"
-        description: "URL reference to a remote file"
-        required: false
-        schema:
-          $ref: "#/definitions/FileUrl"
-      responses:
-        202:
-          description: "Accepted"
-      security:
-      - oauth2: []
-  /api/v1/spaces/{spaceGuid}/files/jobs/{jobId}:
-    get:
-      summary: ""
-      description: "Gets the status of an async upload job"
-      operationId: "getAsyncUploadJob"
-      produces:
-      - "application/json"
-      parameters:
-      - name: "spaceGuid"
-        in: "path"
-        description: "GUID of space you wish to deploy in"
-        required: true
-        type: "string"
-      - name: "namespace"
-        in: "query"
-        description: "file namespace"
-        required: false
-        type: "string"
-      - name: "jobId"
-        in: "path"
-        description: "ID of the upload job"
-        required: true
-        type: "string"
-      responses:
-        200:
-          description: "OK"
-          schema:
-            $ref: "#/definitions/AsyncUploadResult"
-        201:
-          description: "Created"
-          schema:
-            $ref: "#/definitions/AsyncUploadResult"
-      security:
-      - oauth2: []
   /api/v1/spaces/{spaceGuid}/mtas:
     get:
       summary: ""
@@ -403,66 +282,6 @@ securityDefinitions:
     flow: "password"
     scopes: {}
 definitions:
-  AsyncUploadResult:
-    type: "object"
-    properties:
-      status:
-        type: "string"
-        readOnly: true
-        enum:
-        - "RUNNING"
-        - "FINISHED"
-        - "ERROR"
-      bytes_processed:
-        type: "integer"
-        format: "int64"
-        readOnly: true
-      error:
-        type: "string"
-        readOnly: true
-      file:
-        readOnly: true
-        $ref: "#/definitions/FileMetadata"
-      mta_id:
-        type: "string"
-        readOnly: true
-      client_actions:
-        type: "array"
-        readOnly: true
-        items:
-          type: "string"
-          enum:
-          - "RETRY_UPLOAD"
-  FileMetadata:
-    type: "object"
-    properties:
-      id:
-        type: "string"
-        readOnly: true
-      name:
-        type: "string"
-        readOnly: true
-      size:
-        type: "integer"
-        readOnly: true
-      digest:
-        type: "string"
-        readOnly: true
-      digestAlgorithm:
-        type: "string"
-        readOnly: true
-      space:
-        type: "string"
-        readOnly: true
-      namespace:
-        type: "string"
-        readOnly: true
-  FileUrl:
-    type: "object"
-    properties:
-      file_url:
-        type: "string"
-        readOnly: true
   Info:
     type: "object"
     properties:

multiapps-controller-core/src/main/java/org/cloudfoundry/multiapps/controller/core/Messages.java

@@ -179,7 +179,7 @@ public final class Messages {
     public static final String THREAD_MONITOR_CACHE_TIMEOUT = "Flowable thread monitor cache timeout: {0} seconds";
     public static final String SPACE_DEVELOPERS_CACHE_TIME_IN_SECONDS = "Cache for list of space developers per SpaceGUID: {0} seconds";
     public static final String APP_SHUTDOWN_REQUEST = "Application with id:\"{0}\", instance id:\"{1}\", instance index:\"{2}\", is requested to shutdown. Timeout to wait before shutdown of Flowable job executor:\"{3}\" seconds.";
-    public static final String APP_SHUTDOWNED = "Application with id:\"{0}\", instance id:\"{1}\", instance index:\"{2}\", is shutdowned. Timeout to wait before shutdown of Flowable job executor:\"{3}\" seconds.";
+    public static final String APP_SUCCESSFULLY_SHUTDOWN = "Application with id:\"{0}\", instance id:\"{1}\", instance index:\"{2}\", is shutdown. Timeout to wait before shutdown of Flowable job executor:\"{3}\" seconds.";
     public static final String APP_SHUTDOWN_STATUS_MONITOR = "Monitor shutdown status of application with id:\"{0}\", instance id:\"{1}\", instance index:\"{2}\". Status:\"{3}\".";
     public static final String CONTROLLER_CLIENT_SSL_HANDSHAKE_TIMEOUT_IN_SECONDS = "Controller client SSL handshake timeout in seconds: {0}";
     public static final String CONTROLLER_CLIENT_CONNECT_TIMEOUT_IN_SECONDS = "Controller client connect timeout in seconds: {0}";

multiapps-controller-core/src/main/java/org/cloudfoundry/multiapps/controller/core/cf/detect/AppSuffixDeterminer.java

@@ -10,7 +10,7 @@ public AppSuffixDeterminer(boolean keepOriginalNamesAfterDeploy, boolean isAfter
         this.isAfterResumePhase = isAfterResumePhase;
     }
 
-    public boolean shouldAppendApplicationSuffix() {
+    public boolean shouldAppendIdleSuffix() {
         return keepOriginalNamesAfterDeploy && isAfterResumePhase;
     }
 }

multiapps-controller-core/src/main/java/org/cloudfoundry/multiapps/controller/core/cf/v2/ApplicationCloudModelBuilder.java

@@ -152,7 +152,7 @@ private DeployedMtaApplication findDeployedApplication(String moduleName, Deploy
 
     private String getApplicationName(Module module) {
         String applicationName = NameUtil.getApplicationName(module);
-        if (appSuffixDeterminer.shouldAppendApplicationSuffix()) {
+        if (appSuffixDeterminer.shouldAppendIdleSuffix()) {
             applicationName += BlueGreenApplicationNameSuffix.IDLE.asSuffix();
         }
         return applicationName;

multiapps-controller-core/src/test/java/org/cloudfoundry/multiapps/controller/core/cf/detect/AppSuffixDeterminerTest.java

@@ -1,18 +1,18 @@
 package org.cloudfoundry.multiapps.controller.core.cf.detect;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
 import java.util.stream.Stream;
 
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.Arguments;
 import org.junit.jupiter.params.provider.MethodSource;
 
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
 class AppSuffixDeterminerTest {
 
     static Stream<Arguments> testAppSuffixDeterminer() {
         return Stream.of(
-        //@formatter:off
+            //@formatter:off
             // (1) Keep original app names is not set and the process is not after resume phase
             Arguments.of(false, false, false),
             // (2) Keep original app names is set but the process is not after resume phase
@@ -29,6 +29,6 @@ static Stream<Arguments> testAppSuffixDeterminer() {
     @MethodSource
     void testAppSuffixDeterminer(boolean keepOriginalNamesAfterDeploy, boolean isAfterResumePhase, boolean shouldAppendApplicationSuffix) {
         AppSuffixDeterminer appSuffixDeterminer = new AppSuffixDeterminer(keepOriginalNamesAfterDeploy, isAfterResumePhase);
-        assertEquals(shouldAppendApplicationSuffix, appSuffixDeterminer.shouldAppendApplicationSuffix());
+        assertEquals(shouldAppendApplicationSuffix, appSuffixDeterminer.shouldAppendIdleSuffix());
     }
 }

multiapps-controller-process/src/main/java/org/cloudfoundry/multiapps/controller/process/Messages.java

@@ -161,7 +161,6 @@ public class Messages {
     public static final String ERROR_MONITORING_OPERATIONS_OVER_SERVICES = "Error monitoring operations over services";
     public static final String ERROR_DELETING_REMAINING_FILE_PARTS = "Error deleting remaining file parts";
     public static final String ERROR_DETECTING_APPLICATIONS_TO_RENAME = "Error detecting applications to rename";
-    public static final String ERROR_RENAMING_NEW_APPLICATIONS = "Error renaming new applications";
     public static final String ERROR_MONITORING_CREATION_OR_UPDATE_OF_SERVICES = "Error monitoring creation or update of services";
     public static final String ERROR_MONITORING_DELETION_OF_SERVICES = "Error monitoring deletion of services";
     public static final String SERVICE_IS_ALREADY_DELETED = "Service \"{0}\" is already deleted";

multiapps-controller-process/src/main/java/org/cloudfoundry/multiapps/controller/process/steps/CreateOrUpdateAppStep.java

@@ -18,6 +18,7 @@
 import org.cloudfoundry.multiapps.controller.client.facade.CloudControllerClient;
 import org.cloudfoundry.multiapps.controller.client.facade.CloudCredentials;
 import org.cloudfoundry.multiapps.controller.client.facade.domain.CloudApplication;
+import org.cloudfoundry.multiapps.controller.client.facade.domain.ImmutableCloudApplication;
 import org.cloudfoundry.multiapps.controller.client.facade.domain.ImmutableStaging;
 import org.cloudfoundry.multiapps.controller.client.facade.domain.Staging;
 import org.cloudfoundry.multiapps.controller.client.facade.dto.ApplicationToCreateDto;
@@ -28,8 +29,11 @@
 import org.cloudfoundry.multiapps.controller.core.cf.clients.AppBoundServiceInstanceNamesGetter;
 import org.cloudfoundry.multiapps.controller.core.cf.clients.WebClientFactory;
 import org.cloudfoundry.multiapps.controller.core.helpers.ApplicationFileDigestDetector;
+import org.cloudfoundry.multiapps.controller.core.model.BlueGreenApplicationNameSuffix;
 import org.cloudfoundry.multiapps.controller.core.security.token.TokenService;
 import org.cloudfoundry.multiapps.controller.core.util.ApplicationConfiguration;
+import org.cloudfoundry.multiapps.controller.persistence.model.ConfigurationSubscription;
+import org.cloudfoundry.multiapps.controller.persistence.services.ConfigurationSubscriptionService;
 import org.cloudfoundry.multiapps.controller.persistence.services.FileStorageException;
 import org.cloudfoundry.multiapps.controller.process.Messages;
 import org.cloudfoundry.multiapps.controller.process.util.ApplicationAttributeUpdater;
@@ -59,6 +63,8 @@ public class CreateOrUpdateAppStep extends SyncFlowableStep {
     private WebClientFactory webClientFactory;
     @Inject
     private ApplicationConfiguration configuration;
+    @Inject
+    private ConfigurationSubscriptionService subscriptionService;
 
     @Override
     protected StepPhase executeStep(ProcessContext context) throws FileStorageException {
@@ -95,7 +101,9 @@ protected AppBoundServiceInstanceNamesGetter getAppBoundServiceInstanceNamesGett
         return new AppBoundServiceInstanceNamesGetter(configuration, webClientFactory, credentials, correlationId);
     }
 
-    private StepFlowHandler createStepFlowHandler(ProcessContext context, CloudControllerClient client, CloudApplicationExtended app,
+    private StepFlowHandler createStepFlowHandler(ProcessContext context,
+                                                  CloudControllerClient client,
+                                                  CloudApplicationExtended app,
                                                   CloudApplication existingApp) {
         if (existingApp == null) {
             return new CreateAppFlowHandler(context, client, app);
@@ -213,7 +221,9 @@ private class UpdateAppFlowHandler extends StepFlowHandler {
 
         final CloudApplication existingApp;
 
-        public UpdateAppFlowHandler(ProcessContext context, CloudControllerClient client, CloudApplicationExtended app,
+        public UpdateAppFlowHandler(ProcessContext context,
+                                    CloudControllerClient client,
+                                    CloudApplicationExtended app,
                                     CloudApplication existingApp) {
             super(context, client, app);
             this.existingApp = existingApp;
@@ -231,7 +241,9 @@ public void handleApplicationAttributes() {
 
             reportApplicationUpdateStatus(app, arePropertiesChanged);
             context.setVariable(Variables.VCAP_APP_PROPERTIES_CHANGED, arePropertiesChanged);
+
             updateApplicationEnvironment();
+            updateApplicationName();
         }
 
         private void updateApplicationEnvironment() {
@@ -279,6 +291,31 @@ private UpdateStrategy getEnvUpdateStrategy() {
                       .shouldKeepExistingEnv() ? UpdateStrategy.MERGE : UpdateStrategy.REPLACE;
         }
 
+        public void updateApplicationName() {
+            boolean processIsBlueGreenWithIdleSuffix = StepsUtil.getAppSuffixDeterminer(context)
+                                                                .shouldAppendIdleSuffix();
+            if (!processIsBlueGreenWithIdleSuffix) {
+                return;
+            }
+
+            String oldName = existingApp.getName();
+            String newName = BlueGreenApplicationNameSuffix.removeSuffix(oldName);
+            if (oldName.equals(newName)) {
+                getStepLogger().info(Messages.THE_DETECTED_APPLICATION_HAS_THE_SAME_NAME_AS_THE_NEW_ONE);
+                return;
+            }
+
+            getStepLogger().info(Messages.RENAMING_APPLICATION_0_TO_1, oldName, newName);
+            client.rename(oldName, newName);
+
+            context.setVariable(Variables.EXISTING_APP, ImmutableCloudApplication.copyOf(existingApp)
+                                                                                 .withName(newName));
+            context.setVariable(Variables.APP_TO_PROCESS, ImmutableCloudApplicationExtended.copyOf(app)
+                                                                                           .withName(newName));
+
+            updateConfigurationSubscribers(oldName, newName);
+        }
+
         @Override
         public void handleApplicationServices() {
             if (context.getVariable(Variables.SHOULD_SKIP_SERVICE_REBINDING)) {
@@ -298,6 +335,40 @@ public void printStepEndMessage() {
             getStepLogger().debug(Messages.APP_UPDATED, app.getName());
         }
 
+        private void updateConfigurationSubscribers(String oldAppName, String newAppName) {
+            String mtaId = context.getVariable(Variables.MTA_ID);
+            String spaceGuid = context.getVariable(Variables.SPACE_GUID);
+
+            List<ConfigurationSubscription> subscriptions = subscriptionService.createQuery()
+                                                                               .mtaId(mtaId)
+                                                                               .spaceId(spaceGuid)
+                                                                               .list();
+            for (ConfigurationSubscription subscription : subscriptions) {
+                if (oldAppName.equals(subscription.getAppName())) {
+                    getStepLogger().debug(Messages.UPDATING_CONFIGURATION_SUBSCRIPTION_0_WITH_NAME_1, subscription.getAppName(),
+                                          newAppName);
+                    updateConfigurationSubscription(subscription, newAppName);
+                }
+            }
+        }
+
+        private void updateConfigurationSubscription(ConfigurationSubscription subscription, String newAppName) {
+            ConfigurationSubscription newSubscription = createNewSubscription(subscription, newAppName);
+            subscriptionService.update(subscription, newSubscription);
+        }
+
+        private ConfigurationSubscription createNewSubscription(ConfigurationSubscription subscription, String newAppName) {
+            return new ConfigurationSubscription(subscription.getId(),
+                                                 subscription.getMtaId(),
+                                                 subscription.getSpaceId(),
+                                                 newAppName,
+                                                 subscription.getFilter(),
+                                                 subscription.getModuleDto(),
+                                                 subscription.getResourceDto(),
+                                                 subscription.getModuleId(),
+                                                 subscription.getResourceId());
+        }
+
         private List<String> getMtaAndExistingServices() {
             var serviceNamesGetter = getAppBoundServiceInstanceNamesGetter(context);
             return Stream.of(app.getServices(), serviceNamesGetter.getServiceInstanceNamesBoundToApp(existingApp.getGuid()))