vid-app-common/src/main/java/org/onap/vid/services/ChangeManagementServiceImpl.java

   1 package org.onap.vid.services;
   2
   3 import org.apache.commons.lang3.tuple.ImmutablePair;
   4 import org.apache.commons.lang3.tuple.Pair;
   5 import org.hibernate.NonUniqueObjectException;
   6 import org.json.JSONObject;
   7 import org.json.simple.JSONArray;
   8 import org.json.simple.parser.JSONParser;
   9 import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
  10 import org.openecomp.portalsdk.core.service.DataAccessService;
  11 import org.openecomp.portalsdk.core.util.SystemProperties;
  12 import org.onap.vid.changeManagement.*;
  13 import org.onap.vid.exceptions.NotFoundException;
  14 import org.onap.vid.model.VNFDao;
  15 import org.onap.vid.model.VidWorkflow;
  16 import org.onap.vid.mso.MsoBusinessLogic;
  17 import org.onap.vid.mso.MsoResponseWrapperInterface;
  18 import org.onap.vid.mso.rest.Request;
  19 import org.onap.vid.scheduler.SchedulerProperties;
  20 import org.onap.vid.scheduler.SchedulerRestInterfaceFactory;
  21 import org.onap.vid.scheduler.SchedulerRestInterfaceIfc;
  22 import org.springframework.beans.factory.annotation.Autowired;
  23 import org.springframework.http.HttpStatus;
  24 import org.springframework.http.ResponseEntity;
  25 import org.springframework.stereotype.Service;
  26 import org.springframework.util.StringUtils;
  27 import org.springframework.web.multipart.MultipartFile;
  28
  29 import javax.ws.rs.BadRequestException;
  30 import java.util.*;
  31 import java.util.stream.Collectors;
  32
  33
  34 @Service
  35 public class ChangeManagementServiceImpl implements ChangeManagementService {
  36
  37     private final static String primaryKey = "payload";
  38     private final static Set<String> requiredKeys = new HashSet<>(Arrays.asList("request-parameters", "configuration-parameters"));
  39     private final DataAccessService dataAccessService;
  40     private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(ChangeManagementServiceImpl.class);
  41     private MsoBusinessLogic msoBusinessLogic;
  42     @Autowired
  43     private CsvService csvService;
  44
  45     @Autowired
  46     public ChangeManagementServiceImpl(DataAccessService dataAccessService, MsoBusinessLogic msoBusinessLogic) {
  47         this.dataAccessService = dataAccessService;
  48         this.msoBusinessLogic = msoBusinessLogic;
  49     }
  50
  51     @Override
  52     public Collection<Request> getMSOChangeManagements() throws Exception {
  53         Collection<Request> result = null;
  54             return msoBusinessLogic.getOrchestrationRequestsForDashboard();
  55     }
  56
  57     private RequestDetails findRequestByVnfName(List<RequestDetails> requests, String vnfName) {
  58
  59         if (requests == null)
  60             return null;
  61
  62         for (RequestDetails requestDetails : requests) {
  63             if (requestDetails.getVnfName().equals(vnfName)) {
  64                 return requestDetails;
  65             }
  66         }
  67
  68         return null;
  69     }
  70
  71     @Override
  72     public ResponseEntity<String> doChangeManagement(ChangeManagementRequest request, String vnfName) throws Exception {
  73         if (request == null)
  74             return null;
  75         ResponseEntity<String> response;
  76         RequestDetails currentRequestDetails = findRequestByVnfName(request.getRequestDetails(), vnfName);
  77         MsoResponseWrapperInterface msoResponseWrapperObject = null;
  78         if (currentRequestDetails != null) {
  79
  80             String serviceInstanceId = extractServiceInstanceId(currentRequestDetails, request.getRequestType());
  81             String vnfInstanceId = extractVnfInstanceId(currentRequestDetails, request.getRequestType());
  82             String requestType = request.getRequestType();
  83             try {
  84                 switch (requestType.toLowerCase()) {
  85                     case ChangeManagementRequest.UPDATE: {
  86                         msoResponseWrapperObject = msoBusinessLogic.updateVnf(currentRequestDetails, serviceInstanceId, vnfInstanceId);
  87                         break;
  88                     }
  89                     case ChangeManagementRequest.REPLACE: {
  90                         msoResponseWrapperObject = msoBusinessLogic.replaceVnf(currentRequestDetails, serviceInstanceId, vnfInstanceId);
  91                         break;
  92                     }
  93                     case ChangeManagementRequest.VNF_IN_PLACE_SOFTWARE_UPDATE: {
  94                         msoResponseWrapperObject = msoBusinessLogic.updateVnfSoftware(currentRequestDetails, serviceInstanceId, vnfInstanceId);
  95                         break;
  96                     }
  97                     case ChangeManagementRequest.CONFIG_UPDATE: {
  98                         msoResponseWrapperObject = msoBusinessLogic.updateVnfConfig(currentRequestDetails, serviceInstanceId, vnfInstanceId);
  99                         break;
 100                     }
 101                 }
 102                 response = new ResponseEntity<String>(msoResponseWrapperObject.getResponse(), HttpStatus.OK);
 103                 return response;
 104             } catch (Exception e) {
 105                 logger.error("Failure during doChangeManagement with request " + request.toString(), e);
 106                 throw e;
 107             }
 108
 109         }
 110
 111         // AH:TODO: return ChangeManagementResponse
 112         return null;
 113     }
 114
 115     private String extractVnfInstanceId(RequestDetails currentRequestDetails, String requestType) {
 116         if (currentRequestDetails.getVnfInstanceId() == null) {
 117             logger.error("Failed to extract vnfInstanceId");
 118             throw new BadRequestException("No vnfInstanceId in request " + requestType);
 119         }
 120         return currentRequestDetails.getVnfInstanceId();
 121     }
 122
 123     private String extractServiceInstanceId(RequestDetails currentRequestDetails, String requestType) {
 124         try {
 125             String serviceInstanceId = currentRequestDetails.getRelatedInstList().get(0).getRelatedInstance().getInstanceId();
 126             serviceInstanceId.toString(); //throw exception in case that serviceInstanceId is null...
 127             return serviceInstanceId;
 128         } catch (Exception e) {
 129             logger.error("Failed to extract serviceInstanceId");
 130             throw new BadRequestException("No instanceId in request " + requestType);
 131         }
 132     }
 133
 134     @Override
 135     public JSONArray getSchedulerChangeManagements() {
 136         JSONArray result = null;
 137         try {
 138             String path = SystemProperties.getProperty(SchedulerProperties.SCHEDULER_GET_SCHEDULES);
 139             org.onap.vid.scheduler.RestObject<String> restObject = new org.onap.vid.scheduler.RestObject<>();
 140             SchedulerRestInterfaceIfc restClient = SchedulerRestInterfaceFactory.getInstance();
 141
 142             String str = new String();
 143             restObject.set(str);
 144             restClient.Get(str, "", path, restObject);
 145             String restCallResult = restObject.get();
 146             JSONParser parser = new JSONParser();
 147             Object parserResult = parser.parse(restCallResult);
 148             result = (JSONArray) parserResult;
 149         } catch (Exception e) {
 150             e.printStackTrace();
 151         }
 152
 153         return result;
 154     }
 155
 156     @Override
 157     public Pair<String, Integer> deleteSchedule(String scheduleId) {
 158         try {
 159             String path = String.format(SystemProperties.getProperty(SchedulerProperties.SCHEDULER_DELETE_SCHEDULE), scheduleId);
 160             org.onap.vid.scheduler.RestObject<String> restObject = new org.onap.vid.scheduler.RestObject<>();
 161             SchedulerRestInterfaceIfc restClient = SchedulerRestInterfaceFactory.getInstance();
 162             String str = new String();
 163             restObject.set(str);
 164             restClient.Delete(str, "", path, restObject);
 165             String restCallResult = restObject.get();
 166             return new ImmutablePair<>(restCallResult, restObject.getStatusCode());
 167         } catch (Exception e) {
 168             logger.error(e.getMessage(), e);
 169             return new ImmutablePair<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR.value());
 170         }
 171     }
 172
 173     @Override
 174     public VnfWorkflowRelationResponse addVnfWorkflowRelation(VnfWorkflowRelationRequest vnfWorkflowRelationRequest) {
 175         VnfWorkflowRelationResponse vnfWorkflowRelationResponse = new VnfWorkflowRelationResponse();
 176         for (WorkflowsDetail workflowsDetail : vnfWorkflowRelationRequest.getWorkflowsDetails()) {
 177             if (StringUtils.isEmpty(workflowsDetail.getVnfDetails().getUUID()) ||
 178                     StringUtils.isEmpty(workflowsDetail.getVnfDetails().getInvariantUUID())) {
 179                 vnfWorkflowRelationResponse.getErrors().add("Using empty UUID or invariantUUID is not allowed. Relation details: " + workflowsDetail.toString());
 180                 continue;
 181             }
 182             @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(workflowsDetail.getVnfDetails().getUUID(), workflowsDetail.getVnfDetails().getInvariantUUID()), null, null);
 183             if (vnfList.size() == 0) {
 184                 vnfList.add(saveNewVnf(workflowsDetail));
 185             }
 186             @SuppressWarnings("unchecked") List<VidWorkflow> workflowList = dataAccessService.getList(VidWorkflow.class, String.format(" where wokflowName = '%s'", workflowsDetail.getWorkflowName()), null, null);
 187             if (workflowList.size() == 0) {
 188                 vnfWorkflowRelationResponse.getErrors().add("Not Found instance of workflow " + workflowsDetail.getWorkflowName() + " for vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and with invariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
 189                 continue;
 190             }
 191             vnfList.get(0).getWorkflows().add(workflowList.get(0));
 192             try {
 193                 dataAccessService.saveDomainObject(vnfList.get(0), null);
 194             } catch (NonUniqueObjectException e) {
 195                 //In case the relation already exists, we continue running on the list
 196             }
 197         }
 198         return vnfWorkflowRelationResponse;
 199     }
 200
 201     @Override
 202     public VnfWorkflowRelationResponse deleteVnfWorkflowRelation(VnfWorkflowRelationRequest vnfWorkflowRelationRequest) {
 203         VnfWorkflowRelationResponse vnfWorkflowRelationResponse = new VnfWorkflowRelationResponse();
 204         for (WorkflowsDetail workflowsDetail : vnfWorkflowRelationRequest.getWorkflowsDetails()) {
 205             @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(workflowsDetail.getVnfDetails().getUUID(), workflowsDetail.getVnfDetails().getInvariantUUID()), null, null);
 206             if (vnfList.size() != 1) {
 207                 vnfWorkflowRelationResponse.getErrors().add("Found " + vnfList.size() + " instances of vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and vnfInvariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
 208                 continue;
 209             }
 210             VidWorkflow vidWorkflow = getWorkflowOfVnf(vnfList.get(0), workflowsDetail.getWorkflowName());
 211             if (vidWorkflow == null) {
 212                 vnfWorkflowRelationResponse.getErrors().add("Not Found instance of workflow " + workflowsDetail.getWorkflowName() + " for vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and with invariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
 213                 continue;
 214             }
 215             vnfList.get(0).getWorkflows().remove(vidWorkflow);
 216             dataAccessService.saveDomainObject(vnfList.get(0), null);
 217         }
 218         return vnfWorkflowRelationResponse;
 219
 220     }
 221
 222     @Override
 223     public List<String> getWorkflowsForVnf(GetVnfWorkflowRelationRequest getVnfWorkflowRelationRequest) {
 224         List<VNFDao> vnfDaoList = new ArrayList<>();
 225         List<Set<String>> workflowsList = new ArrayList<>();
 226         getVnfDaoList(vnfDaoList, getVnfWorkflowRelationRequest);
 227         getWorkflowsList(workflowsList, vnfDaoList);
 228         return intersectWorkflows(workflowsList);
 229     }
 230
 231     private void getVnfDaoList(List<VNFDao> vnfDaoList, GetVnfWorkflowRelationRequest getVnfWorkflowRelationRequest) {
 232         for (VnfDetails vnfDetails : getVnfWorkflowRelationRequest.getVnfDetails()) {
 233             @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(vnfDetails.getUUID(), vnfDetails.getInvariantUUID()), null, null);
 234             if (vnfList.size() != 1) {
 235                 throw new NotFoundException("Found" + vnfList.size() + " instances of vnf with UUID" + vnfDetails.getUUID() + " and vnfInvariantUUID" + vnfDetails.getInvariantUUID());
 236             }
 237             vnfDaoList.add(vnfList.get(0));
 238         }
 239     }
 240
 241     private void getWorkflowsList(List<Set<String>> workflowsList, List<VNFDao> vnfDaoList) {
 242         for (VNFDao vnfDao : vnfDaoList) {
 243             Set<String> tempWorkflows = vnfDao.getWorkflows().stream().map(VidWorkflow::getWokflowName).collect(Collectors.toSet());
 244             workflowsList.add(tempWorkflows);
 245         }
 246     }
 247
 248     private List<String> intersectWorkflows(List<Set<String>> workflowsList) {
 249         Set<String> workflows = workflowsList.get(0);
 250         for (Set<String> workflow : workflowsList) {
 251             workflows.retainAll(workflow);
 252         }
 253         return new ArrayList<>(workflows);
 254     }
 255
 256     private String getVnfQueryString(String UUID, String invariantUUID) {
 257         return " where vnfInvariantUUID = '" + invariantUUID + "' and vnfUUID = '" + UUID + "'";
 258     }
 259
 260     private VidWorkflow getWorkflowOfVnf(VNFDao vnfDao, String workflowName) {
 261         VidWorkflow vidWorkflowRes = null;
 262         for (VidWorkflow vidWorkflow : vnfDao.getWorkflows()) {
 263             if (vidWorkflow.getWokflowName().equals(workflowName)) {
 264                 vidWorkflowRes = vidWorkflow;
 265             }
 266         }
 267         return vidWorkflowRes;
 268     }
 269
 270     private VNFDao saveNewVnf(WorkflowsDetail workflowsDetail) {
 271         VNFDao vnfDao = new VNFDao();
 272         vnfDao.setVnfUUID(workflowsDetail.getVnfDetails().getUUID());
 273         vnfDao.setVnfInvariantUUID(workflowsDetail.getVnfDetails().getInvariantUUID());
 274         dataAccessService.saveDomainObject(vnfDao, null);
 275         return vnfDao;
 276     }
 277
 278     @Override
 279     public VnfWorkflowRelationAllResponse getAllVnfWorkflowRelations() {
 280         @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, null);
 281         return new VnfWorkflowRelationAllResponse(
 282                 vnfList.stream()
 283                         .map(VnfDetailsWithWorkflows::new)
 284                         .collect(Collectors.toList()));
 285     }
 286
 287     @Override
 288     public String uploadConfigUpdateFile(MultipartFile file)
 289             throws Exception {
 290         JSONObject json = csvService.convertCsvToJson(csvService.readCsv(file));
 291         if (!validateJsonOutput(json))
 292             throw new BadRequestException("Invalid csv file");
 293         json = json.getJSONObject(primaryKey);
 294         json = new JSONObject().put(primaryKey, json.toString());
 295         return json.toString();
 296     }
 297
 298     private boolean validateJsonOutput(org.json.JSONObject json) {
 299         if (!json.has(primaryKey) || !json.getJSONObject(primaryKey).keySet().containsAll(requiredKeys))
 300             return false;
 301         return true;
 302     }
 303 }