gerrit.onap Code Review - so.git/blob

   1 package org.onap.so.adapters.tasks.orchestration;
   2
   3 import java.io.ByteArrayInputStream;
   4 import java.io.StringReader;
   5 import java.util.HashMap;
   6 import java.util.Map;
   7 import java.util.Optional;
   8 import javax.xml.bind.JAXB;
   9 import javax.xml.parsers.DocumentBuilder;
  10 import javax.xml.parsers.DocumentBuilderFactory;
  11 import javax.xml.ws.Holder;
  12 import org.camunda.bpm.client.task.ExternalTask;
  13 import org.camunda.bpm.client.task.ExternalTaskService;
  14 import org.onap.so.adapters.network.MsoNetworkAdapterImpl;
  15 import org.onap.so.adapters.nwrest.CreateNetworkRequest;
  16 import org.onap.so.adapters.vnf.MsoVnfAdapterImpl;
  17 import org.onap.so.adapters.vnf.MsoVnfPluginAdapterImpl;
  18 import org.onap.so.adapters.vnf.VnfAdapterUtils;
  19 import org.onap.so.adapters.vnfrest.CreateVfModuleRequest;
  20 import org.onap.so.adapters.vnfrest.CreateVolumeGroupRequest;
  21 import org.onap.so.logging.tasks.AuditMDCSetup;
  22 import org.onap.so.utils.ExternalTaskUtils;
  23 import org.slf4j.Logger;
  24 import org.slf4j.LoggerFactory;
  25 import org.springframework.beans.factory.annotation.Autowired;
  26 import org.springframework.stereotype.Component;
  27
  28 @Component
  29 public class RollbackService extends ExternalTaskUtils {
  30
  31     private static final Logger logger = LoggerFactory.getLogger(RollbackService.class);
  32
  33     @Autowired
  34     private MsoVnfAdapterImpl vnfAdapterImpl;
  35
  36     @Autowired
  37     private MsoNetworkAdapterImpl networkAdapterImpl;
  38
  39     @Autowired
  40     private VnfAdapterUtils vnfAdapterUtils;
  41
  42     @Autowired
  43     private MsoVnfPluginAdapterImpl vnfPluginImpl;
  44
  45     @Autowired
  46     private AuditMDCSetup mdcSetup;
  47
  48     public void executeExternalTask(ExternalTask externalTask, ExternalTaskService externalTaskService) {
  49         mdcSetup.setupMDC(externalTask);
  50         logger.debug("Starting External Task Rollback Service");
  51         Map<String, Object> variables = new HashMap<>();
  52         boolean success = false;
  53         boolean pollRollbackStatus = false;
  54         try {
  55             String xmlRequest = externalTask.getVariable("openstackAdapterTaskRequest");
  56             if (xmlRequest != null) {
  57                 Optional<String> requestType = findRequestType(xmlRequest);
  58                 if ("createVolumeGroupRequest".equals(requestType.get())) {
  59                     logger.debug("Executing External Task Rollback Service for Create Volume Group");
  60                     CreateVolumeGroupRequest req =
  61                             JAXB.unmarshal(new StringReader(xmlRequest), CreateVolumeGroupRequest.class);
  62                     boolean isMulticloud = vnfAdapterUtils.isMulticloudMode(null, req.getCloudSiteId());
  63                     if (!isMulticloud) {
  64                         vnfAdapterImpl.deleteVfModule(req.getCloudSiteId(), req.getCloudOwner(), req.getTenantId(),
  65                                 req.getVolumeGroupName(), null, req.getMsoRequest(), new Holder<>());
  66                         pollRollbackStatus = true;
  67                         success = true;
  68                     } else {
  69                         vnfPluginImpl.deleteVnf(req.getCloudSiteId(), req.getCloudOwner(), req.getTenantId(),
  70                                 req.getVolumeGroupName(), req.getMsoRequest());
  71                         pollRollbackStatus = false;
  72                         success = true;
  73                     }
  74                 } else if ("createVfModuleRequest".equals(requestType.get())) {
  75                     logger.debug("Executing External Task Rollback Service for Create Vf Module");
  76                     CreateVfModuleRequest req =
  77                             JAXB.unmarshal(new StringReader(xmlRequest), CreateVfModuleRequest.class);
  78                     boolean isMulticloud = vnfAdapterUtils.isMulticloudMode(null, req.getCloudSiteId());
  79                     if (!isMulticloud) {
  80                         vnfAdapterImpl.deleteVfModule(req.getCloudSiteId(), req.getCloudOwner(), req.getTenantId(),
  81                                 req.getVfModuleName(), req.getModelCustomizationUuid(), req.getMsoRequest(),
  82                                 new Holder<>());
  83                         pollRollbackStatus = true;
  84                         success = true;
  85                     } else {
  86                         pollRollbackStatus = false;
  87                         success = true;
  88                     }
  89                 } else if ("createNetworkRequest".equals(requestType.get())) {
  90                     logger.debug("Executing External Task Rollback Service for Create Network");
  91                     Holder<Boolean> networkDeleted = new Holder<>();
  92                     CreateNetworkRequest req = JAXB.unmarshal(new StringReader(xmlRequest), CreateNetworkRequest.class);
  93                     networkAdapterImpl.deleteNetwork(req.getCloudSiteId(), req.getTenantId(), req.getNetworkType(),
  94                             req.getModelCustomizationUuid(), req.getNetworkName(), req.getMsoRequest(), networkDeleted,
  95                             false);
  96                     pollRollbackStatus = true;
  97                     success = true;
  98                 }
  99             }
 100         } catch (Exception e) {
 101             logger.error("Error during External Task Rollback Service", e);
 102         }
 103         variables.put("OpenstackRollbackSuccess", success);
 104         variables.put("rollbackPerformed", true);
 105         variables.put("PollRollbackStatus", pollRollbackStatus);
 106         if (success) {
 107             externalTaskService.complete(externalTask, variables);
 108             logger.debug("The External Task Id: {}  Successful", externalTask.getId());
 109         } else {
 110             logger.debug("The External Task Id: {}  Failed. Not Retrying", externalTask.getId());
 111             externalTaskService.complete(externalTask, variables);
 112         }
 113     }
 114
 115     protected Optional<String> findRequestType(String xmlString) {
 116         try {
 117             DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
 118             DocumentBuilder builder = factory.newDocumentBuilder();
 119             org.w3c.dom.Document doc;
 120             doc = builder.parse(new ByteArrayInputStream(xmlString.getBytes("UTF-8")));
 121             return Optional.of(doc.getDocumentElement().getNodeName());
 122         } catch (Exception e) {
 123             logger.error("Error Finding Request Type", e);
 124             return Optional.empty();
 125         }
 126     }
 127
 128 }