Replaced all tabs with spaces in java and pom.xml
[so.git] / adapters / mso-openstack-adapters / src / main / java / org / onap / so / adapters / audit / AuditDeleteStackService.java
index 2c2b2f8..aca6e9e 100644 (file)
@@ -23,7 +23,6 @@ package org.onap.so.adapters.audit;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Optional;
-
 import org.camunda.bpm.client.task.ExternalTask;
 import org.camunda.bpm.client.task.ExternalTaskService;
 import org.onap.logging.ref.slf4j.ONAPLogConstants;
@@ -37,51 +36,57 @@ import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
 
 @Component
-public class AuditDeleteStackService extends AbstractAuditService{
-       
-       private static final Logger logger = LoggerFactory.getLogger(AuditDeleteStackService.class);
-       
-       @Autowired
-       public HeatStackAudit heatStackAudit; 
-       
-       @Autowired
-       public Environment env;
+public class AuditDeleteStackService extends AbstractAuditService {
+
+    private static final Logger logger = LoggerFactory.getLogger(AuditDeleteStackService.class);
+
+    @Autowired
+    public HeatStackAudit heatStackAudit;
+
+    @Autowired
+    public Environment env;
 
-       protected void executeExternalTask(ExternalTask externalTask, ExternalTaskService externalTaskService){
-               AuditInventory auditInventory = externalTask.getVariable("auditInventory");
-               Map<String, Object> variables = new HashMap<>();
-               setupMDC(externalTask);
-               boolean success = false;
-               try {
-                       logger.info("Executing External Task Audit Inventory, Retry Number: {} \n {}", auditInventory,externalTask.getRetries());
-                       Optional<AAIObjectAuditList> auditListOpt=heatStackAudit.auditHeatStack(auditInventory.getCloudRegion(), auditInventory.getCloudOwner(),
-                                       auditInventory.getTenantId(), auditInventory.getHeatStackName());
-                        if (auditListOpt.isPresent()) {
-                               GraphInventoryCommonObjectMapperProvider objectMapper = new GraphInventoryCommonObjectMapperProvider();
-                               variables.put("auditInventoryResult", objectMapper.getMapper().writeValueAsString(auditListOpt.get()));
-                               success = didDeleteAuditFail(auditListOpt);
-                       }
-               } catch (Exception e) {
-                       logger.error("Error during audit of stack", e);
-               }
-               variables.put("auditIsSuccessful", success);
-               if (success) {
-                       externalTaskService.complete(externalTask, variables);
-                       logger.debug("The External Task Id: {}  Successful", externalTask.getId());
-               } else {
-                       if(externalTask.getRetries() == null){
-                               logger.debug("The External Task Id: {}  Failed, Setting Retries to Default Start Value: {}", externalTask.getId(),getRetrySequence().length);
-                               externalTaskService.handleFailure(externalTask, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, getRetrySequence().length, 10000);                  
-                       }else if(externalTask.getRetries() != null &&
-                                       externalTask.getRetries()-1 == 0){
-                               logger.debug("The External Task Id: {}  Failed, All Retries Exhausted", externalTask.getId());
-                               externalTaskService.complete(externalTask);
-                       }else{
-                               logger.debug("The External Task Id: {}  Failed, Decrementing Retries: {} , Retry Delay: ", externalTask.getId(),externalTask.getRetries()-1, calculateRetryDelay(externalTask.getRetries()));
-                               externalTaskService.handleFailure(externalTask, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, externalTask.getRetries()-1, calculateRetryDelay(externalTask.getRetries()));
-                       }
-                       logger.debug("The External Task Id: {} Failed", externalTask.getId());
-               }
-       }
+    protected void executeExternalTask(ExternalTask externalTask, ExternalTaskService externalTaskService) {
+        AuditInventory auditInventory = externalTask.getVariable("auditInventory");
+        Map<String, Object> variables = new HashMap<>();
+        setupMDC(externalTask);
+        boolean success = false;
+        try {
+            logger.info("Executing External Task Audit Inventory, Retry Number: {} \n {}", auditInventory,
+                    externalTask.getRetries());
+            Optional<AAIObjectAuditList> auditListOpt = heatStackAudit.auditHeatStack(auditInventory.getCloudRegion(),
+                    auditInventory.getCloudOwner(), auditInventory.getTenantId(), auditInventory.getHeatStackName());
+            if (auditListOpt.isPresent()) {
+                GraphInventoryCommonObjectMapperProvider objectMapper = new GraphInventoryCommonObjectMapperProvider();
+                variables.put("auditInventoryResult", objectMapper.getMapper().writeValueAsString(auditListOpt.get()));
+                success = didDeleteAuditFail(auditListOpt);
+            }
+        } catch (Exception e) {
+            logger.error("Error during audit of stack", e);
+        }
+        variables.put("auditIsSuccessful", success);
+        if (success) {
+            externalTaskService.complete(externalTask, variables);
+            logger.debug("The External Task Id: {}  Successful", externalTask.getId());
+        } else {
+            if (externalTask.getRetries() == null) {
+                logger.debug("The External Task Id: {}  Failed, Setting Retries to Default Start Value: {}",
+                        externalTask.getId(), getRetrySequence().length);
+                externalTaskService.handleFailure(externalTask, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI,
+                        UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, getRetrySequence().length, 10000);
+            } else if (externalTask.getRetries() != null && externalTask.getRetries() - 1 == 0) {
+                logger.debug("The External Task Id: {}  Failed, All Retries Exhausted", externalTask.getId());
+                externalTaskService.complete(externalTask);
+            } else {
+                logger.debug("The External Task Id: {}  Failed, Decrementing Retries: {} , Retry Delay: ",
+                        externalTask.getId(), externalTask.getRetries() - 1,
+                        calculateRetryDelay(externalTask.getRetries()));
+                externalTaskService.handleFailure(externalTask, UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI,
+                        UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI, externalTask.getRetries() - 1,
+                        calculateRetryDelay(externalTask.getRetries()));
+            }
+            logger.debug("The External Task Id: {} Failed", externalTask.getId());
+        }
+    }
 
-}
\ No newline at end of file
+}