org.onap migration

Change-Id: I52f0b2851f2c765752b6d21f49b32136d7d72a3d
Issue-ID: VID-86
Signed-off-by: Ofir Sonsino <os0695@att.com>

1 files changed, 303 insertions, 0 deletions

diff --git a/vid-app-common/src/main/java/org/onap/vid/services/ChangeManagementServiceImpl.java b/vid-app-common/src/main/java/org/onap/vid/services/ChangeManagementServiceImpl.java
new file mode 100644
index 000000000..078f44945
--- /dev/null
+++ b/vid-app-common/src/main/java/org/onap/vid/services/ChangeManagementServiceImpl.java
@@ -0,0 +1,303 @@
+package org.onap.vid.services;
+
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.apache.commons.lang3.tuple.Pair;
+import org.hibernate.NonUniqueObjectException;
+import org.json.JSONObject;
+import org.json.simple.JSONArray;
+import org.json.simple.parser.JSONParser;
+import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
+import org.openecomp.portalsdk.core.service.DataAccessService;
+import org.openecomp.portalsdk.core.util.SystemProperties;
+import org.onap.vid.changeManagement.*;
+import org.onap.vid.exceptions.NotFoundException;
+import org.onap.vid.model.VNFDao;
+import org.onap.vid.model.VidWorkflow;
+import org.onap.vid.mso.MsoBusinessLogic;
+import org.onap.vid.mso.MsoResponseWrapperInterface;
+import org.onap.vid.mso.rest.Request;
+import org.onap.vid.scheduler.SchedulerProperties;
+import org.onap.vid.scheduler.SchedulerRestInterfaceFactory;
+import org.onap.vid.scheduler.SchedulerRestInterfaceIfc;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.ws.rs.BadRequestException;
+import java.util.*;
+import java.util.stream.Collectors;
+
+
+@Service
+public class ChangeManagementServiceImpl implements ChangeManagementService {
+
+    private final static String primaryKey = "payload";
+    private final static Set<String> requiredKeys = new HashSet<>(Arrays.asList("request-parameters", "configuration-parameters"));
+    private final DataAccessService dataAccessService;
+    private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(ChangeManagementServiceImpl.class);
+    private MsoBusinessLogic msoBusinessLogic;
+    @Autowired
+    private CsvService csvService;
+
+    @Autowired
+    public ChangeManagementServiceImpl(DataAccessService dataAccessService, MsoBusinessLogic msoBusinessLogic) {
+        this.dataAccessService = dataAccessService;
+        this.msoBusinessLogic = msoBusinessLogic;
+    }
+
+    @Override
+    public Collection<Request> getMSOChangeManagements() throws Exception {
+        Collection<Request> result = null;
+            return msoBusinessLogic.getOrchestrationRequestsForDashboard();
+    }
+
+    private RequestDetails findRequestByVnfName(List<RequestDetails> requests, String vnfName) {
+
+        if (requests == null)
+            return null;
+
+        for (RequestDetails requestDetails : requests) {
+            if (requestDetails.getVnfName().equals(vnfName)) {
+                return requestDetails;
+            }
+        }
+
+        return null;
+    }
+
+    @Override
+    public ResponseEntity<String> doChangeManagement(ChangeManagementRequest request, String vnfName) throws Exception {
+        if (request == null)
+            return null;
+        ResponseEntity<String> response;
+        RequestDetails currentRequestDetails = findRequestByVnfName(request.getRequestDetails(), vnfName);
+        MsoResponseWrapperInterface msoResponseWrapperObject = null;
+        if (currentRequestDetails != null) {
+
+            String serviceInstanceId = extractServiceInstanceId(currentRequestDetails, request.getRequestType());
+            String vnfInstanceId = extractVnfInstanceId(currentRequestDetails, request.getRequestType());
+            String requestType = request.getRequestType();
+            try {
+                switch (requestType.toLowerCase()) {
+                    case ChangeManagementRequest.UPDATE: {
+                        msoResponseWrapperObject = msoBusinessLogic.updateVnf(currentRequestDetails, serviceInstanceId, vnfInstanceId);
+                        break;
+                    }
+                    case ChangeManagementRequest.REPLACE: {
+                        msoResponseWrapperObject = msoBusinessLogic.replaceVnf(currentRequestDetails, serviceInstanceId, vnfInstanceId);
+                        break;
+                    }
+                    case ChangeManagementRequest.VNF_IN_PLACE_SOFTWARE_UPDATE: {
+                        msoResponseWrapperObject = msoBusinessLogic.updateVnfSoftware(currentRequestDetails, serviceInstanceId, vnfInstanceId);
+                        break;
+                    }
+                    case ChangeManagementRequest.CONFIG_UPDATE: {
+                        msoResponseWrapperObject = msoBusinessLogic.updateVnfConfig(currentRequestDetails, serviceInstanceId, vnfInstanceId);
+                        break;
+                    }
+                }
+                response = new ResponseEntity<String>(msoResponseWrapperObject.getResponse(), HttpStatus.OK);
+                return response;
+            } catch (Exception e) {
+                logger.error("Failure during doChangeManagement with request " + request.toString(), e);
+                throw e;
+            }
+
+        }
+
+        // AH:TODO: return ChangeManagementResponse
+        return null;
+    }
+
+    private String extractVnfInstanceId(RequestDetails currentRequestDetails, String requestType) {
+        if (currentRequestDetails.getVnfInstanceId() == null) {
+            logger.error("Failed to extract vnfInstanceId");
+            throw new BadRequestException("No vnfInstanceId in request " + requestType);
+        }
+        return currentRequestDetails.getVnfInstanceId();
+    }
+
+    private String extractServiceInstanceId(RequestDetails currentRequestDetails, String requestType) {
+        try {
+            String serviceInstanceId = currentRequestDetails.getRelatedInstList().get(0).getRelatedInstance().getInstanceId();
+            serviceInstanceId.toString(); //throw exception in case that serviceInstanceId is null...
+            return serviceInstanceId;
+        } catch (Exception e) {
+            logger.error("Failed to extract serviceInstanceId");
+            throw new BadRequestException("No instanceId in request " + requestType);
+        }
+    }
+
+    @Override
+    public JSONArray getSchedulerChangeManagements() {
+        JSONArray result = null;
+        try {
+            String path = SystemProperties.getProperty(SchedulerProperties.SCHEDULER_GET_SCHEDULES);
+            org.onap.vid.scheduler.RestObject<String> restObject = new org.onap.vid.scheduler.RestObject<>();
+            SchedulerRestInterfaceIfc restClient = SchedulerRestInterfaceFactory.getInstance();
+
+            String str = new String();
+            restObject.set(str);
+            restClient.Get(str, "", path, restObject);
+            String restCallResult = restObject.get();
+            JSONParser parser = new JSONParser();
+            Object parserResult = parser.parse(restCallResult);
+            result = (JSONArray) parserResult;
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return result;
+    }
+
+    @Override
+    public Pair<String, Integer> deleteSchedule(String scheduleId) {
+        try {
+            String path = String.format(SystemProperties.getProperty(SchedulerProperties.SCHEDULER_DELETE_SCHEDULE), scheduleId);
+            org.onap.vid.scheduler.RestObject<String> restObject = new org.onap.vid.scheduler.RestObject<>();
+            SchedulerRestInterfaceIfc restClient = SchedulerRestInterfaceFactory.getInstance();
+            String str = new String();
+            restObject.set(str);
+            restClient.Delete(str, "", path, restObject);
+            String restCallResult = restObject.get();
+            return new ImmutablePair<>(restCallResult, restObject.getStatusCode());
+        } catch (Exception e) {
+            logger.error(e.getMessage(), e);
+            return new ImmutablePair<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR.value());
+        }
+    }
+
+    @Override
+    public VnfWorkflowRelationResponse addVnfWorkflowRelation(VnfWorkflowRelationRequest vnfWorkflowRelationRequest) {
+        VnfWorkflowRelationResponse vnfWorkflowRelationResponse = new VnfWorkflowRelationResponse();
+        for (WorkflowsDetail workflowsDetail : vnfWorkflowRelationRequest.getWorkflowsDetails()) {
+            if (StringUtils.isEmpty(workflowsDetail.getVnfDetails().getUUID()) ||
+                    StringUtils.isEmpty(workflowsDetail.getVnfDetails().getInvariantUUID())) {
+                vnfWorkflowRelationResponse.getErrors().add("Using empty UUID or invariantUUID is not allowed. Relation details: " + workflowsDetail.toString());
+                continue;
+            }
+            @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(workflowsDetail.getVnfDetails().getUUID(), workflowsDetail.getVnfDetails().getInvariantUUID()), null, null);
+            if (vnfList.size() == 0) {
+                vnfList.add(saveNewVnf(workflowsDetail));
+            }
+            @SuppressWarnings("unchecked") List<VidWorkflow> workflowList = dataAccessService.getList(VidWorkflow.class, String.format(" where wokflowName = '%s'", workflowsDetail.getWorkflowName()), null, null);
+            if (workflowList.size() == 0) {
+                vnfWorkflowRelationResponse.getErrors().add("Not Found instance of workflow " + workflowsDetail.getWorkflowName() + " for vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and with invariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
+                continue;
+            }
+            vnfList.get(0).getWorkflows().add(workflowList.get(0));
+            try {
+                dataAccessService.saveDomainObject(vnfList.get(0), null);
+            } catch (NonUniqueObjectException e) {
+                //In case the relation already exists, we continue running on the list
+            }
+        }
+        return vnfWorkflowRelationResponse;
+    }
+
+    @Override
+    public VnfWorkflowRelationResponse deleteVnfWorkflowRelation(VnfWorkflowRelationRequest vnfWorkflowRelationRequest) {
+        VnfWorkflowRelationResponse vnfWorkflowRelationResponse = new VnfWorkflowRelationResponse();
+        for (WorkflowsDetail workflowsDetail : vnfWorkflowRelationRequest.getWorkflowsDetails()) {
+            @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(workflowsDetail.getVnfDetails().getUUID(), workflowsDetail.getVnfDetails().getInvariantUUID()), null, null);
+            if (vnfList.size() != 1) {
+                vnfWorkflowRelationResponse.getErrors().add("Found " + vnfList.size() + " instances of vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and vnfInvariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
+                continue;
+            }
+            VidWorkflow vidWorkflow = getWorkflowOfVnf(vnfList.get(0), workflowsDetail.getWorkflowName());
+            if (vidWorkflow == null) {
+                vnfWorkflowRelationResponse.getErrors().add("Not Found instance of workflow " + workflowsDetail.getWorkflowName() + " for vnf with UUID " + workflowsDetail.getVnfDetails().getUUID() + " and with invariantUUID " + workflowsDetail.getVnfDetails().getInvariantUUID());
+                continue;
+            }
+            vnfList.get(0).getWorkflows().remove(vidWorkflow);
+            dataAccessService.saveDomainObject(vnfList.get(0), null);
+        }
+        return vnfWorkflowRelationResponse;
+
+    }
+
+    @Override
+    public List<String> getWorkflowsForVnf(GetVnfWorkflowRelationRequest getVnfWorkflowRelationRequest) {
+        List<VNFDao> vnfDaoList = new ArrayList<>();
+        List<Set<String>> workflowsList = new ArrayList<>();
+        getVnfDaoList(vnfDaoList, getVnfWorkflowRelationRequest);
+        getWorkflowsList(workflowsList, vnfDaoList);
+        return intersectWorkflows(workflowsList);
+    }
+
+    private void getVnfDaoList(List<VNFDao> vnfDaoList, GetVnfWorkflowRelationRequest getVnfWorkflowRelationRequest) {
+        for (VnfDetails vnfDetails : getVnfWorkflowRelationRequest.getVnfDetails()) {
+            @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, getVnfQueryString(vnfDetails.getUUID(), vnfDetails.getInvariantUUID()), null, null);
+            if (vnfList.size() != 1) {
+                throw new NotFoundException("Found" + vnfList.size() + " instances of vnf with UUID" + vnfDetails.getUUID() + " and vnfInvariantUUID" + vnfDetails.getInvariantUUID());
+            }
+            vnfDaoList.add(vnfList.get(0));
+        }
+    }
+
+    private void getWorkflowsList(List<Set<String>> workflowsList, List<VNFDao> vnfDaoList) {
+        for (VNFDao vnfDao : vnfDaoList) {
+            Set<String> tempWorkflows = vnfDao.getWorkflows().stream().map(VidWorkflow::getWokflowName).collect(Collectors.toSet());
+            workflowsList.add(tempWorkflows);
+        }
+    }
+
+    private List<String> intersectWorkflows(List<Set<String>> workflowsList) {
+        Set<String> workflows = workflowsList.get(0);
+        for (Set<String> workflow : workflowsList) {
+            workflows.retainAll(workflow);
+        }
+        return new ArrayList<>(workflows);
+    }
+
+    private String getVnfQueryString(String UUID, String invariantUUID) {
+        return " where vnfInvariantUUID = '" + invariantUUID + "' and vnfUUID = '" + UUID + "'";
+    }
+
+    private VidWorkflow getWorkflowOfVnf(VNFDao vnfDao, String workflowName) {
+        VidWorkflow vidWorkflowRes = null;
+        for (VidWorkflow vidWorkflow : vnfDao.getWorkflows()) {
+            if (vidWorkflow.getWokflowName().equals(workflowName)) {
+                vidWorkflowRes = vidWorkflow;
+            }
+        }
+        return vidWorkflowRes;
+    }
+
+    private VNFDao saveNewVnf(WorkflowsDetail workflowsDetail) {
+        VNFDao vnfDao = new VNFDao();
+        vnfDao.setVnfUUID(workflowsDetail.getVnfDetails().getUUID());
+        vnfDao.setVnfInvariantUUID(workflowsDetail.getVnfDetails().getInvariantUUID());
+        dataAccessService.saveDomainObject(vnfDao, null);
+        return vnfDao;
+    }
+
+    @Override
+    public VnfWorkflowRelationAllResponse getAllVnfWorkflowRelations() {
+        @SuppressWarnings("unchecked") List<VNFDao> vnfList = dataAccessService.getList(VNFDao.class, null);
+        return new VnfWorkflowRelationAllResponse(
+                vnfList.stream()
+                        .map(VnfDetailsWithWorkflows::new)
+                        .collect(Collectors.toList()));
+    }
+
+    @Override
+    public String uploadConfigUpdateFile(MultipartFile file)
+            throws Exception {
+        JSONObject json = csvService.convertCsvToJson(csvService.readCsv(file));
+        if (!validateJsonOutput(json))
+            throw new BadRequestException("Invalid csv file");
+        json = json.getJSONObject(primaryKey);
+        json = new JSONObject().put(primaryKey, json.toString());
+        return json.toString();
+    }
+
+    private boolean validateJsonOutput(org.json.JSONObject json) {
+        if (!json.has(primaryKey) || !json.getJSONObject(primaryKey).keySet().containsAll(requiredKeys))
+            return false;
+        return true;
+    }
+}