if audit fails write sub interface data to a ai

[so.git] / adapters / mso-openstack-adapters / src / main / java / org / onap / so / adapters / audit / AuditStackServiceData.java

diff --git a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditCreateStackService.java b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackServiceData.java
similarity index 66%
rename from adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditCreateStackService.java
rename to adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackServiceData.java
index 24980ae..da6bea7 100644 (file)
--- a/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditCreateStackService.java
+++ b/adapters/mso-openstack-adapters/src/main/java/org/onap/so/adapters/audit/AuditStackServiceData.java
@@ -22,26 +22,29 @@
 
 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;
 import org.onap.so.audit.beans.AuditInventory;
+import org.onap.so.client.graphinventory.GraphInventoryCommonObjectMapperProvider;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
 
 @Component
-public class AuditCreateStackService {
+public class AuditStackServiceData {
        
        private static final String UNABLE_TO_FIND_ALL_V_SERVERS_AND_L_INTERACES_IN_A_AI = "Unable to find all VServers and L-Interaces in A&AI";
        
-       private static final int[] RETRY_SEQUENCE = new int[] { 1, 1, 2, 3, 5, 8, 13, 20};
-
-       
-       private static final Logger logger = LoggerFactory.getLogger(AuditCreateStackService.class);
+       private static final Logger logger = LoggerFactory.getLogger(AuditStackServiceData.class);
        
        @Autowired
        public HeatStackAudit heatStackAudit; 
@@ -51,35 +54,39 @@ public class AuditCreateStackService {
 
        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());
-                       success=heatStackAudit.auditHeatStackCreate(auditInventory.getCloudRegion(), auditInventory.getCloudOwner(),
+                       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 = !didAuditFail(auditListOpt);
+               }
                } catch (Exception e) {
                        logger.error("Error during audit of stack", e);
                }
-               
+               variables.put("auditIsSuccessful", success);
                if (success) {
-                       externalTaskService.complete(externalTask);
+                       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(),RETRY_SEQUENCE.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, RETRY_SEQUENCE.length, 10000);                      
+                               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.handleBpmnError(externalTask, "AuditAAIInventoryFailure", "Number of Retries Exceeded auditing inventory");
+                               logger.debug("The External Task Id: {}  Failed, All Retries Exhausted", externalTask.getId());                           
+                               externalTaskService.complete(externalTask, variables);
                        }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());
                }
-               
-               
        }
        private void setupMDC(ExternalTask externalTask) {
                String msoRequestId = externalTask.getVariable("mso-request-id");
@@ -87,8 +94,29 @@ public class AuditCreateStackService {
                        MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, msoRequestId);
        }
        protected long calculateRetryDelay(int currentRetries){
-               int retrySequence = RETRY_SEQUENCE.length - currentRetries;
+               int retrySequence = getRetrySequence().length - currentRetries;
                long retryMultiplier = Long.parseLong(env.getProperty("mso.workflow.topics.retryMultiplier","6000"));
-               return RETRY_SEQUENCE[retrySequence] * retryMultiplier;
+               return Integer.parseInt(getRetrySequence()[retrySequence]) * retryMultiplier;
+       }
+       
+       /**
+        * @param auditHeatStackFailed
+        * @param auditList
+        * @return
+        */
+       protected boolean didAuditFail(Optional<AAIObjectAuditList> auditList) {
+               if (auditList.get().getAuditList() != null && !auditList.get().getAuditList().isEmpty()) {
+                       if (logger.isInfoEnabled()) {
+                               logger.info("Audit Results: {}", auditList.get().toString());
+                       }
+                       return auditList.get().getAuditList().stream().filter(auditObject -> !auditObject.isDoesObjectExist())
+                                       .findFirst().map(v -> true).orElse(false);
+               } else {
+                       return false;
+               }
        }
+       public String[] getRetrySequence() {
+                return env.getProperty("mso.workflow.topics.retrySequence",String[].class);
+       }
+
 }