Fixing update HEAT

1. Update component dependencies based on new Heat
2. Retain VSP data on Heat re-upload
3. Unit tests
4. Code reformatting and refactoring for compliance

Issue ID: SDC-655

Change-Id: Ib4822d3e7ec69293d2d544044909f0a22ab224ac
Signed-off-by: ojasdubey <ojas.dubey@amdocs.com>

3 files changed, 375 insertions, 222 deletions

diff --git a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/OrchestrationUtil.java b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/OrchestrationUtil.java
index 9d7421f336..2ee7b263b9 100644
--- a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/OrchestrationUtil.java
+++ b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/OrchestrationUtil.java
@@ -1,6 +1,10 @@
 package org.openecomp.sdc.vendorsoftwareproduct.impl.orchestration;
 
+import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.GENERAL_COMPONENT_ID;
+import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.UniqueValues.PROCESS_NAME;
+
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.MapUtils;
 import org.openecomp.core.model.dao.ServiceModelDao;
 import org.openecomp.core.model.dao.ServiceModelDaoFactory;
 import org.openecomp.core.util.UniqueValueUtil;
@@ -22,6 +26,8 @@ import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentArtifactDao;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDao;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDaoFactory;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDependencyModelDao;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDependencyModelDaoFactory;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.MonitoringUploadDaoFactory;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.NicDao;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.NicDaoFactory;
@@ -31,6 +37,7 @@ import org.openecomp.sdc.vendorsoftwareproduct.dao.ProcessDao;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.ProcessDaoFactory;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductDao;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductDaoFactory;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentDependencyModelEntity;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentEntity;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentMonitoringUploadEntity;
 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.NicEntity;
@@ -52,231 +59,371 @@ import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
-
-import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.GENERAL_COMPONENT_ID;
-import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.UniqueValues.PROCESS_NAME;
+import java.util.Set;
+import java.util.stream.Collectors;
 
 public class OrchestrationUtil {
 
-    public static final String ORCHESTRATION_CONFIG_NAMESPACE = "orchestration";
-    public static final String ORCHESTRATION_IMPL_KEY = "orchestration_impl";
-
-
-    private static VendorSoftwareProductDao vendorSoftwareProductDao =
-        VendorSoftwareProductDaoFactory.getInstance().createInterface();
-    private static NicDao nicDao = NicDaoFactory.getInstance().createInterface();
-    private static ComponentArtifactDao componentArtifactDao = MonitoringUploadDaoFactory.getInstance().createInterface();
-    private static ProcessDao processDao = ProcessDaoFactory.getInstance().createInterface();
-    private static OrchestrationTemplateDao orchestrationTemplateDataDao =
-        OrchestrationTemplateDaoFactory.getInstance().createInterface();
-    private static ComponentDao componentDao =
-        ComponentDaoFactory.getInstance().createInterface();
-    private static ServiceModelDao serviceModelDao = ServiceModelDaoFactory.getInstance()
-        .createInterface();
-    private static CompositionEntityDataManager compositionEntityDataManager =
-        CompositionEntityDataManagerFactory.getInstance().createInterface();
-    private static CompositionDataExtractor compositionDataExtractor =
-        CompositionDataExtractorFactory.getInstance().createInterface();
-
-    public static Optional<FileContentHandler> getFileContentMap(OnboardingTypesEnum type,
-                                                                 UploadFileResponse uploadFileResponse,
-                                                                 byte[] uploadedFileData) {
-        FileContentHandler contentMap = null;
-        try {
-            contentMap = CommonUtil.validateAndUploadFileContent(type, uploadedFileData);
-        } catch (IOException exception) {
-            uploadFileResponse.addStructureError(
-                    SdcCommon.UPLOAD_FILE,
-                    new ErrorMessage(ErrorLevel.ERROR, Messages.INVALID_ZIP_FILE.getErrorMessage()));
-        } catch (CoreException coreException) {
-            uploadFileResponse.addStructureError(
-                    SdcCommon.UPLOAD_FILE, new ErrorMessage(ErrorLevel.ERROR, coreException.getMessage()));
-        }
-        return Optional.ofNullable(contentMap);
+  public static final String ORCHESTRATION_CONFIG_NAMESPACE = "orchestration";
+  public static final String ORCHESTRATION_IMPL_KEY = "orchestration_impl";
+
+
+  private VendorSoftwareProductDao vendorSoftwareProductDao;
+  private NicDao nicDao;
+  private ComponentArtifactDao componentArtifactDao;
+  private ProcessDao processDao;
+  private OrchestrationTemplateDao orchestrationTemplateDataDao;
+  private ComponentDao componentDao;
+  private ServiceModelDao serviceModelDao;
+  private ComponentDependencyModelDao componentDependencyModelDao;
+  private CompositionEntityDataManager compositionEntityDataManager;
+  private CompositionDataExtractor compositionDataExtractor;
+
+  public OrchestrationUtil() {
+    this (VendorSoftwareProductDaoFactory.getInstance().createInterface(),
+          NicDaoFactory.getInstance().createInterface(),
+        MonitoringUploadDaoFactory.getInstance().createInterface(),
+        ProcessDaoFactory.getInstance().createInterface(),
+        OrchestrationTemplateDaoFactory.getInstance().createInterface(),
+        ComponentDaoFactory.getInstance().createInterface(),
+        ServiceModelDaoFactory.getInstance().createInterface(),
+        ComponentDependencyModelDaoFactory.getInstance().createInterface(),
+        CompositionEntityDataManagerFactory.getInstance().createInterface(),
+        CompositionDataExtractorFactory.getInstance().createInterface());
+  }
+
+  public OrchestrationUtil(
+      VendorSoftwareProductDao vendorSoftwareProductDao,
+      NicDao nicDao,
+      ComponentArtifactDao componentArtifactDao,
+      ProcessDao processDao,
+      OrchestrationTemplateDao orchestrationTemplateDataDao,
+      ComponentDao componentDao,
+      ServiceModelDao serviceModelDao,
+      ComponentDependencyModelDao componentDependencyModelDao,
+      CompositionEntityDataManager compositionEntityDataManager,
+      CompositionDataExtractor compositionDataExtractor) {
+    this.vendorSoftwareProductDao = vendorSoftwareProductDao;
+    this.nicDao = nicDao;
+    this.componentArtifactDao = componentArtifactDao;
+    this.processDao = processDao;
+    this.orchestrationTemplateDataDao = orchestrationTemplateDataDao;
+    this.componentDao = componentDao;
+    this.serviceModelDao = serviceModelDao;
+    this.componentDependencyModelDao = componentDependencyModelDao;
+    this.compositionEntityDataManager = compositionEntityDataManager;
+    this.compositionDataExtractor = compositionDataExtractor;
+  }
+
+  public static Optional<FileContentHandler> getFileContentMap(OnboardingTypesEnum type,
+                                                               UploadFileResponse
+                                                                   uploadFileResponse,
+                                                               byte[] uploadedFileData) {
+    FileContentHandler contentMap = null;
+    try {
+      contentMap = CommonUtil.validateAndUploadFileContent(type, uploadedFileData);
+    } catch (IOException exception) {
+      uploadFileResponse.addStructureError(
+          SdcCommon.UPLOAD_FILE,
+          new ErrorMessage(ErrorLevel.ERROR, Messages.INVALID_ZIP_FILE.getErrorMessage()));
+    } catch (CoreException coreException) {
+      uploadFileResponse.addStructureError(
+          SdcCommon.UPLOAD_FILE, new ErrorMessage(ErrorLevel.ERROR, coreException.getMessage()));
+    }
+    return Optional.ofNullable(contentMap);
+  }
+
+  public void backupComponentsQuestionnaireBeforeDelete(String vspId, Version activeVersion,
+                                           Map<String, String> componentsQustanniare,
+                                           Map<String, Map<String, String>>
+                                               componentNicsQustanniare,
+                                           Map<String, Collection<ComponentMonitoringUploadEntity>>
+                                               componentMibList,
+                                           Map<String, Collection<ProcessEntity>>
+                                               componentProcesses,
+                                           Map<String, ProcessEntity> processArtifact) {
+    //backup VSP processes
+    backupProcess(vspId, activeVersion, GENERAL_COMPONENT_ID, GENERAL_COMPONENT_ID,
+        componentProcesses, processArtifact);
+    Collection<ComponentEntity> componentsCompositionAndQuestionnaire = vendorSoftwareProductDao
+        .listComponentsCompositionAndQuestionnaire(vspId,
+            activeVersion);
+    componentsCompositionAndQuestionnaire.forEach(componentEntity ->
+        backupComponentQuestionnaire(vspId, activeVersion, componentEntity, componentsQustanniare,
+            componentNicsQustanniare, componentMibList, componentProcesses, processArtifact));
+  }
+
+  private void backupComponentQuestionnaire(String vspId, Version activeVersion,
+                                            ComponentEntity componentEntity,
+                                            Map<String, String> componentsQustanniare,
+                                            Map<String, Map<String, String>>
+                                                componentNicsQustanniare,
+                                            Map<String, Collection<ComponentMonitoringUploadEntity>>
+                                                componentMibList,
+                                            Map<String, Collection<ProcessEntity>>
+                                                componentProcesses,
+                                            Map<String, ProcessEntity> processArtifact) {
+    String componentName = componentEntity.getComponentCompositionData().getName();
+    backupMibData(componentsQustanniare, componentMibList, componentName, componentEntity, vspId,
+        activeVersion);
+    backupComponentProcessData(componentNicsQustanniare, vspId, activeVersion, componentName,
+        componentEntity, componentProcesses, processArtifact);
+  }
+
+  private void backupMibData(Map<String, String> componentsQustanniare,
+                             Map<String, Collection<ComponentMonitoringUploadEntity>>
+                                 componentMibList,
+                             String componentName, ComponentEntity componentEntity,
+                             String vspId, Version activeVersion) {
+    componentsQustanniare.put(componentName, componentEntity.getQuestionnaireData());
+    //backup mib
+    Collection<ComponentMonitoringUploadEntity> componentMib =
+        componentArtifactDao.listArtifacts(new
+            ComponentMonitoringUploadEntity(vspId, activeVersion, componentEntity.getId(), null));
+    if (CollectionUtils.isNotEmpty(componentMib)) {
+      componentMibList.put(componentName, componentMib);
     }
+  }
 
-    public static void backupComponentsQuestionnaireBeforeDelete(String vspId, Version activeVersion,
-                                                           Map<String, String> componentsQustanniare,
-                                                           Map<String, Map<String, String>>
-                                                               componentNicsQustanniare,
-                                                           Map<String, Collection<ComponentMonitoringUploadEntity>>
-                                                               componentMibList,
-                                                           Map<String, Collection<ProcessEntity>>
-                                                               componentProcesses,
-                                                           Map<String, ProcessEntity> processArtifact) {
-        //backup VSP processes
-        backupProcess(vspId, activeVersion, GENERAL_COMPONENT_ID, GENERAL_COMPONENT_ID,
-            componentProcesses, processArtifact);
-        Collection<ComponentEntity> componentsCompositionAndQuestionnaire = vendorSoftwareProductDao
-            .listComponentsCompositionAndQuestionnaire(vspId,
-                activeVersion);
-        componentsCompositionAndQuestionnaire.forEach(componentEntity -> {
-            String componentName = componentEntity.getComponentCompositionData().getName();
-            componentsQustanniare.put(componentName, componentEntity
-                .getQuestionnaireData());
-            Collection<NicEntity>
-                nics = nicDao.list(new NicEntity(vspId, activeVersion, componentEntity.getId(), null));
-            //backup mib
-            Collection<ComponentMonitoringUploadEntity> componentMib =
-                componentArtifactDao.listArtifacts(new
-                    ComponentMonitoringUploadEntity(vspId, activeVersion, componentEntity.getId(),
-                    null));
-            if (CollectionUtils.isNotEmpty(componentMib)) {
-                componentMibList.put(componentName,componentMib);
-            }
-
-            //backup component processes
-            backupProcess(vspId, activeVersion, componentEntity.getId(), componentName,
-                componentProcesses, processArtifact);
-            if (CollectionUtils.isNotEmpty(nics)) {
-                Map<String, String> nicsQustanniare = new HashMap<>();
-                nics.forEach(nicEntity -> {
-                    NicEntity nic = nicDao.get(new NicEntity(vspId, activeVersion, componentEntity.getId(),
-                        nicEntity.getId()));
-                    NicEntity nicQuestionnaire = nicDao.getQuestionnaireData(vspId, activeVersion,
-                        componentEntity.getId(), nicEntity.getId());
-
-                    nicsQustanniare
-                        .put(nicEntity.getNicCompositionData().getName(),
-                            nicQuestionnaire.getQuestionnaireData());
-                });
-                componentNicsQustanniare.put(componentName, nicsQustanniare);
-            }
-        });
+  private void backupComponentProcessData(Map<String, Map<String, String>> componentNicsQustanniare,
+                                          String vspId, Version activeVersion, String componentName,
+                                          ComponentEntity componentEntity,
+                                          Map<String, Collection<ProcessEntity>> componentProcesses,
+                                          Map<String, ProcessEntity> processArtifact) {
+    Collection<NicEntity>
+        nics = nicDao.list(new NicEntity(vspId, activeVersion, componentEntity.getId(), null));
+    //backup component processes
+    backupProcess(vspId, activeVersion, componentEntity.getId(), componentName,
+        componentProcesses, processArtifact);
+    if (CollectionUtils.isNotEmpty(nics)) {
+      Map<String, String> nicsQustanniare = new HashMap<>();
+      nics.forEach(nicEntity -> {
+        NicEntity nic = nicDao.get(new NicEntity(vspId, activeVersion, componentEntity.getId(),
+            nicEntity.getId()));
+        NicEntity nicQuestionnaire = nicDao.getQuestionnaireData(vspId, activeVersion,
+            componentEntity.getId(), nicEntity.getId());
+
+        nicsQustanniare
+            .put(nicEntity.getNicCompositionData().getName(),
+                nicQuestionnaire.getQuestionnaireData());
+      });
+      componentNicsQustanniare.put(componentName, nicsQustanniare);
     }
+  }
 
-    private static void backupProcess(String vspId, Version activeVersion, String componentId,
-                               String componentName, Map<String,
-        Collection<ProcessEntity>> processes,
-                               Map<String, ProcessEntity> processArtifact) {
-        Collection<ProcessEntity> processList = vendorSoftwareProductDao.listProcesses(vspId,
-            activeVersion, componentId);
-        if (!processList.isEmpty()) {
-            processes.put(componentName, processList);
-            processList.forEach(process -> {
-                //ProcessArtifactEntity artifact = vendorSoftwareProductDao.getProcessArtifact(vspId,
-                //    activeVersion, componentId, process.getId());
-                ProcessEntity artifact =
-                    processDao.get(new ProcessEntity(vspId, activeVersion, componentId, process.getId()));
-                if (artifact.getArtifact() != null) {
-                    processArtifact.put(process.getId(), artifact);
-                }
-            });
+  private void backupProcess(String vspId, Version activeVersion, String componentId,
+                                    String componentName, Map<String,
+      Collection<ProcessEntity>> processes,
+                                    Map<String, ProcessEntity> processArtifact) {
+    Collection<ProcessEntity> processList = vendorSoftwareProductDao.listProcesses(vspId,
+        activeVersion, componentId);
+    if (!processList.isEmpty()) {
+      processes.put(componentName, processList);
+      processList.forEach(process -> {
+        ProcessEntity artifact =
+            processDao.get(new ProcessEntity(vspId, activeVersion, componentId, process.getId()));
+        if (artifact.getArtifact() != null) {
+          processArtifact.put(process.getId(), artifact);
         }
+      });
     }
+  }
 
-    public static void retainComponentQuestionnaireData(String vspId, Version activeVersion,
-                                                  Map<String, String> componentsQustanniare,
-                                                  Map<String, Map<String, String>>
-                                                      componentNicsQustanniare,
-                                                  Map<String, Collection<ComponentMonitoringUploadEntity>> componentMibList,
-                                                  Map<String, Collection<ProcessEntity>> processes,
-                                                  Map<String, ProcessEntity> processArtifact) {
-        //VSP processes
-        restoreProcess(vspId, activeVersion, GENERAL_COMPONENT_ID, GENERAL_COMPONENT_ID, processes,
+  public void retainComponentQuestionnaireData(String vspId, Version activeVersion,
+                          Map<String, String> componentsQustanniare,
+                          Map<String, Map<String, String>>
+                              componentNicsQustanniare,
+                          Map<String, Collection<ComponentMonitoringUploadEntity>> componentMibList,
+                          Map<String, Collection<ProcessEntity>> processes,
+                          Map<String, ProcessEntity> processArtifact) {
+    //VSP processes
+    restoreProcess(vspId, activeVersion, GENERAL_COMPONENT_ID, GENERAL_COMPONENT_ID, processes,
+        processArtifact);
+    Collection<ComponentEntity>
+        components = vendorSoftwareProductDao.listComponents(vspId, activeVersion);
+    components.forEach(componentEntity -> {
+      String componentName = componentEntity.getComponentCompositionData().getName();
+      if (componentsQustanniare.containsKey(componentName)) {
+        //Restore component questionnaire
+        componentDao.updateQuestionnaireData(vspId, activeVersion,
+            componentEntity.getId(),
+            componentsQustanniare.get(componentEntity.getComponentCompositionData()
+                .getName()));
+        //Restore component nic questionnaire
+        if (componentNicsQustanniare.containsKey(componentName)) {
+          restoreComponentNicQuestionnaire(vspId, activeVersion, componentName, componentEntity,
+              componentNicsQustanniare);
+        }
+        //MIB //todo add for VES_EVENTS
+        if (componentMibList.containsKey(componentName)) {
+          restoreComponentMibData(componentName, componentEntity, componentMibList);
+        }
+        //VFC processes
+        restoreProcess(vspId, activeVersion, componentEntity.getId(), componentName, processes,
             processArtifact);
-        Collection<ComponentEntity>
-            components = vendorSoftwareProductDao.listComponents(vspId, activeVersion);
-        components.forEach(componentEntity -> {
-            String componentName = componentEntity.getComponentCompositionData().getName();
-            if (componentsQustanniare.containsKey(componentName)) {
-                componentDao.updateQuestionnaireData(vspId, activeVersion,
-                    componentEntity.getId(),
-                    componentsQustanniare.get(componentEntity.getComponentCompositionData()
-                        .getName()));
-                if (componentNicsQustanniare.containsKey(componentName)) {
-                    Map<String, String> nicsQustanniare = componentNicsQustanniare.get(componentName);
-                    Collection<NicEntity>
-                        nics =
-                        nicDao.list(new NicEntity(vspId, activeVersion, componentEntity.getId(), null));
-                    nics.forEach(nicEntity -> {
-                        if (nicsQustanniare.containsKey(nicEntity.getNicCompositionData().getName())) {
-                            nicDao.updateQuestionnaireData(vspId, activeVersion,
-                                componentEntity.getId(), nicEntity.getId(),
-                                nicsQustanniare.get(nicEntity.getNicCompositionData().getName()));
-                        }
-                    });
-                }
-                //MIB //todo add for VES_EVENTS
-                if (componentMibList.containsKey(componentName)) {
-                    Collection<ComponentMonitoringUploadEntity> mibList =
-                        componentMibList.get(componentName);
-                    mibList.forEach(mib -> {
-                        mib.setComponentId(componentEntity.getId());
-                        componentArtifactDao.create(mib);
-                    });
-                }
-                //VFC processes
-                restoreProcess(vspId, activeVersion, componentEntity.getId(), componentName, processes,
-                    processArtifact);
-            }
-        });
-    }
+      }
+    });
+  }
 
-    private static void restoreProcess(String vspId, Version activeVersion, String componentId,
-                                String componentName,
-                                Map<String, Collection<ProcessEntity>> processes,
-                                Map<String, ProcessEntity> processArtifact) {
-        if (processes.containsKey(componentName)) {
-            Collection<ProcessEntity> processList = processes.get(componentName);
-            processList.forEach(process -> {
-                //Reatin VFC process
-                if (!GENERAL_COMPONENT_ID.equals(componentId) && processArtifact.containsKey(process.getId
-                    ())) {
-                    ProcessEntity artifact = processArtifact.get(process.getId());
-                    artifact.setComponentId(componentId);
-                    UniqueValueUtil.createUniqueValue(PROCESS_NAME, vspId, activeVersion.toString(),
-                        componentId, process.getName());
-                    vendorSoftwareProductDao.createProcess(artifact);
-                }
-            });
+  private void restoreComponentNicQuestionnaire(String vspId, Version activeVersion,
+                                                String componentName,
+                                                ComponentEntity componentEntity,
+                                                Map<String, Map<String, String>>
+                                                    componentNicsQustanniare) {
+    Map<String, String> nicsQustanniare = componentNicsQustanniare.get(componentName);
+    Collection<NicEntity> nics =
+        nicDao.list(new NicEntity(vspId, activeVersion, componentEntity.getId(), null));
+    nics.forEach(nicEntity -> {
+      if (nicsQustanniare.containsKey(nicEntity.getNicCompositionData().getName())) {
+        nicDao.updateQuestionnaireData(vspId, activeVersion,
+            componentEntity.getId(), nicEntity.getId(),
+            nicsQustanniare.get(nicEntity.getNicCompositionData().getName()));
+      }
+    });
+  }
+
+  private void restoreComponentMibData(String componentName,
+                                       ComponentEntity componentEntity,
+                                       Map<String, Collection<ComponentMonitoringUploadEntity>>
+                                           componentMibList) {
+    Collection<ComponentMonitoringUploadEntity> mibList = componentMibList.get(componentName);
+    mibList.forEach(mib -> {
+      mib.setComponentId(componentEntity.getId());
+      componentArtifactDao.create(mib);
+    });
+  }
+
+  private void restoreProcess(String vspId, Version activeVersion, String componentId,
+                                     String componentName,
+                                     Map<String, Collection<ProcessEntity>> processes,
+                                     Map<String, ProcessEntity> processArtifact) {
+    if (processes.containsKey(componentName)) {
+      Collection<ProcessEntity> processList = processes.get(componentName);
+      processList.forEach(process -> {
+        //Reatin VFC process
+        if (!GENERAL_COMPONENT_ID.equals(componentId)
+            && processArtifact.containsKey(process.getId())) {
+          ProcessEntity artifact = processArtifact.get(process.getId());
+          artifact.setComponentId(componentId);
+          UniqueValueUtil.createUniqueValue(PROCESS_NAME, vspId, activeVersion.toString(),
+              componentId, process.getName());
+          vendorSoftwareProductDao.createProcess(artifact);
         }
+      });
     }
+  }
 
-    public static void deleteUploadDataAndContent(String vspId, Version version) {
-        //fixme change this when more tables are zusammenized
-        vendorSoftwareProductDao.deleteUploadData(vspId, version);
-    }
+  public void deleteUploadDataAndContent(String vspId, Version version) {
+    //fixme change this when more tables are zusammenized
+    vendorSoftwareProductDao.deleteUploadData(vspId, version);
+  }
 
-    public static void saveUploadData(String vspId, Version activeVersion, InputStream uploadedFileData,
-                                      FileContentHandler fileContentMap, HeatStructureTree tree) {
-        Map<String, Object> manifestAsMap =
-            fileContentMap.containsFile(SdcCommon.MANIFEST_NAME) ?
-            (Map<String, Object>) JsonUtil.json2Object(fileContentMap.getFileContent(
-                SdcCommon.MANIFEST_NAME), Map.class)
+  public void saveUploadData(String vspId, Version activeVersion,
+                                    InputStream uploadedFileData,
+                                    FileContentHandler fileContentMap, HeatStructureTree tree) {
+    Map<String, Object> manifestAsMap =
+        fileContentMap.containsFile(SdcCommon.MANIFEST_NAME)
+            ? (Map<String, Object>) JsonUtil.json2Object(fileContentMap.getFileContent(
+            SdcCommon.MANIFEST_NAME), Map.class)
             : new HashMap<>();
 
-        UploadData uploadData = new UploadData();
-        uploadData.setContentData(ByteBuffer.wrap(FileUtils.toByteArray(uploadedFileData)));
-        uploadData.setValidationDataStructure(new ValidationStructureList(tree));
-        uploadData.setPackageName(Objects.isNull(manifestAsMap.get("name")) ? null :
-            (String) manifestAsMap.get("name"));
-        uploadData.setPackageVersion(Objects.isNull(manifestAsMap.get("version")) ? null :
-            (String) manifestAsMap.get("version"));
-        orchestrationTemplateDataDao.updateOrchestrationTemplateData(vspId, uploadData);
+    UploadData uploadData = new UploadData();
+    uploadData.setContentData(ByteBuffer.wrap(FileUtils.toByteArray(uploadedFileData)));
+    uploadData.setValidationDataStructure(new ValidationStructureList(tree));
+    uploadData.setPackageName(Objects.isNull(manifestAsMap.get("name")) ? null :
+        (String) manifestAsMap.get("name"));
+    uploadData.setPackageVersion(Objects.isNull(manifestAsMap.get("version")) ? null :
+        (String) manifestAsMap.get("version"));
+    orchestrationTemplateDataDao.updateOrchestrationTemplateData(vspId, uploadData);
+  }
+
+  public void saveServiceModel(String vspId,
+                                      Version version,
+                                      ToscaServiceModel serviceModelToExtract,
+                                      ToscaServiceModel serviceModelToStore) {
+    if (serviceModelToExtract != null) {
+      serviceModelDao.storeServiceModel(vspId, version, serviceModelToStore);
+      //Extracting the compostion data from the output service model of the first phase of
+      // translation
+      compositionEntityDataManager.saveCompositionData(vspId, version,
+          compositionDataExtractor.extractServiceCompositionData(serviceModelToExtract));
     }
+  }
+
+  public static HeatStructureTree createHeatTree(FileContentHandler fileContentMap,
+                                                 Map<String, List<ErrorMessage>> validationErrors) {
+    HeatTreeManager heatTreeManager = HeatTreeManagerUtil.initHeatTreeManager(fileContentMap);
+    heatTreeManager.createTree();
+    heatTreeManager.addErrors(validationErrors);
+    return heatTreeManager.getTree();
+  }
+
+  public void updateVspComponentDependencies(String vspId, Version activeVersion,
+                                                    Map<String, String>
+                                                        vspComponentIdNameInfoBeforeProcess) {
+    Map<String, String> updatedVspComponentNameIdInfo = getVspComponentNameIdInfo(vspId,
+        activeVersion);
+    if (MapUtils.isNotEmpty(updatedVspComponentNameIdInfo)) {
+      Set<String> updatedVspComponentNames = updatedVspComponentNameIdInfo.keySet();
+      Collection<ComponentDependencyModelEntity> componentDependencies =
+          vendorSoftwareProductDao.listComponentDependencies(vspId, activeVersion);
+      if (CollectionUtils.isNotEmpty(componentDependencies)) {
+        updateComponentDependency(vspComponentIdNameInfoBeforeProcess, componentDependencies,
+            updatedVspComponentNames, updatedVspComponentNameIdInfo);
+      }
+    }
+  }
+
+
+  private void updateComponentDependency(Map<String, String> vspComponentIdNameInfoBeforeProcess,
+                                         Collection<ComponentDependencyModelEntity>
+                                             componentDependencies,
+                                         Set<String> updatedVspComponentNames,
+                                         Map<String, String> updatedVspComponentNameIdInfo) {
+    for (ComponentDependencyModelEntity componentDependency : componentDependencies) {
+      String sourceComponentName = vspComponentIdNameInfoBeforeProcess.get(componentDependency
+          .getSourceComponentId());
+      String targetComponentName = vspComponentIdNameInfoBeforeProcess.get(componentDependency
+          .getTargetComponentId());
+      if (updatedVspComponentNames.contains(sourceComponentName)
+          && (updatedVspComponentNames.contains(targetComponentName))) {
+        String newSourceComponentId = updatedVspComponentNameIdInfo.get(sourceComponentName);
+        componentDependency.setSourceComponentId(newSourceComponentId);
+        String newTargetComponentId = updatedVspComponentNameIdInfo.get(targetComponentName);
+        componentDependency.setTargetComponentId(newTargetComponentId);
+        componentDependencyModelDao.update(componentDependency);
+      } else {
+        componentDependencyModelDao.delete(componentDependency);
+      }
+    }
+  }
+
+  public Map<String, String> getVspComponentIdNameInfo(String vspId, Version activeVersion) {
+    Collection<ComponentEntity> updatedVspComponents =
+        vendorSoftwareProductDao.listComponents(vspId, activeVersion);
+    Map<String, String> vspComponentIdNameMap = new HashMap<>();
+    if (CollectionUtils.isNotEmpty(updatedVspComponents)) {
+      vspComponentIdNameMap = updatedVspComponents.stream()
+          .filter(componentEntity -> componentEntity.getComponentCompositionData() != null)
+          .collect(Collectors.toMap(componentEntity -> componentEntity.getId(),
+              componentEntity -> componentEntity.getComponentCompositionData().getName()));
 
-    public static void saveServiceModel(String vspId,
-                                        Version version,
-                                        ToscaServiceModel serviceModelToExtract,
-                                        ToscaServiceModel serviceModelToStore){
-        if (serviceModelToExtract != null) {
-            serviceModelDao.storeServiceModel(vspId, version, serviceModelToStore);
-            //Extracting the compostion data from the output service model of the first phase of
-            // translation
-            compositionEntityDataManager.saveCompositionData(vspId, version,
-                compositionDataExtractor.extractServiceCompositionData(serviceModelToExtract));
-//            OrchestrationUtil.retainComponentQuestionnaireData(vspId, version, componentsQuestionnaire,
-//                componentNicsQuestionnaire, componentMibList, processes, processArtifact);
-        }
     }
+    return vspComponentIdNameMap;
+  }
 
-    public static HeatStructureTree createHeatTree(FileContentHandler fileContentMap,
-                                                   Map<String, List<ErrorMessage>> validationErrors){
-        HeatTreeManager heatTreeManager = HeatTreeManagerUtil.initHeatTreeManager(fileContentMap);
-        heatTreeManager.createTree();
-        heatTreeManager.addErrors(validationErrors);
-        return heatTreeManager.getTree();
+  private Map<String, String> getVspComponentNameIdInfo(String vspId,
+                                                              Version activeVersion) {
+    Collection<ComponentEntity> updatedVspComponents =
+        vendorSoftwareProductDao.listComponents(vspId, activeVersion);
+    Map<String, String> vspComponentNameIdMap = new HashMap<>();
+    if (CollectionUtils.isNotEmpty(updatedVspComponents)) {
+      vspComponentNameIdMap = updatedVspComponents.stream()
+          .filter(componentEntity -> componentEntity.getComponentCompositionData() != null)
+          .collect(Collectors.toMap(componentEntity -> componentEntity
+            .getComponentCompositionData().getName(), componentEntity -> componentEntity.getId()));
     }
+    return vspComponentNameIdMap;
+  }
 
 }
diff --git a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessCsarHandler.java b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessCsarHandler.java
index 4866d93411..3dd118e8ec 100644
--- a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessCsarHandler.java
+++ b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessCsarHandler.java
@@ -92,20 +92,20 @@ public class OrchestrationTemplateProcessCsarHandler implements OrchestrationTem
     Map<String, Collection<ComponentMonitoringUploadEntity>> componentMibList = new HashMap<>();
     Map<String, Collection<ProcessEntity>> processes = new HashMap<>();
     Map<String, ProcessEntity> processArtifact = new HashMap<>();
-
-    OrchestrationUtil.backupComponentsQuestionnaireBeforeDelete(vspId,
+    OrchestrationUtil orchestrationUtil = new OrchestrationUtil();
+    orchestrationUtil.backupComponentsQuestionnaireBeforeDelete(vspId,
         version, componentsQuestionnaire,
         componentNicsQuestionnaire, componentMibList, processes, processArtifact);
 
     Optional<ByteArrayInputStream> zipByteArrayInputStream = candidateService
         .fetchZipFileByteArrayInputStream(vspId, candidateData, null, OnboardingTypesEnum.CSAR, errors);
 
-    OrchestrationUtil.deleteUploadDataAndContent(vspId, version);
-    OrchestrationUtil.saveUploadData(
+    orchestrationUtil.deleteUploadDataAndContent(vspId, version);
+    orchestrationUtil.saveUploadData(
         vspId, version, zipByteArrayInputStream.get(), fileContentHandler, tree);
 
     ToscaServiceModel toscaServiceModel = toscaConverter.convert(fileContentHandler);
-    OrchestrationUtil.saveServiceModel(vspId, version, toscaServiceModel, toscaServiceModel);
+    orchestrationUtil.saveServiceModel(vspId, version, toscaServiceModel, toscaServiceModel);
 
   }
 
diff --git a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessZipHandler.java b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessZipHandler.java
index cceacd47b3..85ac26223f 100644
--- a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessZipHandler.java
+++ b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/orchestration/process/OrchestrationTemplateProcessZipHandler.java
@@ -1,5 +1,7 @@
 package org.openecomp.sdc.vendorsoftwareproduct.impl.orchestration.process;
 
+import static org.openecomp.sdc.logging.messages.AuditMessages.HEAT_VALIDATION_ERROR;
+
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.openecomp.core.model.dao.ServiceModelDao;
@@ -49,8 +51,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 
-import static org.openecomp.sdc.logging.messages.AuditMessages.HEAT_VALIDATION_ERROR;
-
 public class OrchestrationTemplateProcessZipHandler implements OrchestrationTemplateProcessHandler {
   Logger logger = LoggerFactory.getLogger(OrchestrationTemplateProcessZipHandler.class);
   private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
@@ -68,18 +68,20 @@ public class OrchestrationTemplateProcessZipHandler implements OrchestrationTemp
   public OrchestrationTemplateProcessZipHandler(){}
 
   public OrchestrationTemplateActionResponse process(VspDetails vspDetails,
-                                                     OrchestrationTemplateCandidateData candidateData,
+                                                     OrchestrationTemplateCandidateData
+                                                         candidateData,
                                                      String user) {
     String vspId = vspDetails.getId();
     Version version = vspDetails.getVersion();
-    logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.HEAT_VALIDATION_STARTED +
-        vspId);
+    logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.HEAT_VALIDATION_STARTED
+        + vspId);
     OrchestrationTemplateActionResponse response = new OrchestrationTemplateActionResponse();
     UploadFileResponse uploadFileResponse = new UploadFileResponse();
     Optional<FileContentHandler> fileContent =
         OrchestrationUtil
             .getFileContentMap(
-                OnboardingTypesEnum.ZIP, uploadFileResponse, candidateData.getContentData().array());
+                OnboardingTypesEnum.ZIP, uploadFileResponse,
+                candidateData.getContentData().array());
     if (!fileContent.isPresent()) {
       response.addStructureErrors(uploadFileResponse.getErrors());
       mdcDataDebugMessage.debugExitMessage("VSP id", vspId);
@@ -124,18 +126,21 @@ public class OrchestrationTemplateProcessZipHandler implements OrchestrationTemp
     Map<String, Collection<ProcessEntity>> processes = new HashMap<>();
     Map<String, ProcessEntity> processArtifact = new HashMap<>();
 
-    OrchestrationUtil.backupComponentsQuestionnaireBeforeDelete(vspId,
+    OrchestrationUtil orchestrationUtil = new OrchestrationUtil();
+    Map<String, String> vspComponentIdNameInfoBeforeProcess =
+        orchestrationUtil.getVspComponentIdNameInfo(vspId, version);
+    orchestrationUtil.backupComponentsQuestionnaireBeforeDelete(vspId,
         version, componentsQuestionnaire,
         componentNicsQuestionnaire, componentMibList, processes, processArtifact);
 
-    OrchestrationUtil.deleteUploadDataAndContent(vspId, version);
-    OrchestrationUtil.saveUploadData(vspId, version, zipByteArrayInputStream.get(), fileContentMap,
+    orchestrationUtil.deleteUploadDataAndContent(vspId, version);
+    orchestrationUtil.saveUploadData(vspId, version, zipByteArrayInputStream.get(), fileContentMap,
         tree);
 
     response.getErrors().values().forEach(errorList -> printAuditForErrors(errorList,vspId,
         HEAT_VALIDATION_ERROR));
-    if ( MapUtils.isEmpty(MessageContainerUtil.getMessageByLevel(ErrorLevel.ERROR, response.getErrors
-        ()))) {
+    if ( MapUtils.isEmpty(MessageContainerUtil.getMessageByLevel(ErrorLevel.ERROR,
+        response.getErrors()))) {
       logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.HEAT_VALIDATION_COMPLETED + vspId);
     }
 
@@ -145,11 +150,12 @@ public class OrchestrationTemplateProcessZipHandler implements OrchestrationTemp
         HeatToToscaUtil.loadAndTranslateTemplateData(fileContentMap);
 
     ToscaServiceModel toscaServiceModel = translatorOutput.getToscaServiceModel();
-    OrchestrationUtil.saveServiceModel(vspId, version, translatorOutput
+    orchestrationUtil.saveServiceModel(vspId, version, translatorOutput
         .getNonUnifiedToscaServiceModel(), toscaServiceModel);
-    OrchestrationUtil.retainComponentQuestionnaireData(vspId, version, componentsQuestionnaire,
+    orchestrationUtil.retainComponentQuestionnaireData(vspId, version, componentsQuestionnaire,
         componentNicsQuestionnaire, componentMibList, processes, processArtifact);
-
+    orchestrationUtil.updateVspComponentDependencies(vspId, version,
+        vspComponentIdNameInfoBeforeProcess);
     logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.HEAT_TRANSLATION_COMPLETED + vspId);
     uploadFileResponse.addStructureErrors(uploadErrors);