openecomp-be/lib/openecomp-healing-lib/openecomp-sdc-healing-impl/src/main/java/org/openecomp/sdc/healing/healers/HeatToToscaTranslationHealer.java

   1 package org.openecomp.sdc.healing.healers;
   2
   3
   4 import org.openecomp.core.model.dao.ServiceModelDao;
   5 import org.openecomp.core.model.dao.ServiceModelDaoFactory;
   6 import org.openecomp.core.model.dao.ServiceTemplateDaoFactory;
   7 import org.openecomp.core.model.dao.ServiceTemplateDaoInter;
   8 import org.openecomp.core.model.types.ServiceElement;
   9 import org.openecomp.core.translator.datatypes.TranslatorOutput;
  10 import org.openecomp.core.utilities.file.FileContentHandler;
  11 import org.openecomp.core.utilities.orchestration.OnboardingTypesEnum;
  12 import org.openecomp.sdc.common.utils.CommonUtil;
  13 import org.openecomp.sdc.common.utils.SdcCommon;
  14 import org.openecomp.sdc.healing.interfaces.Healer;
  15 import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
  16 import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
  17 import org.openecomp.sdc.translator.services.heattotosca.HeatToToscaUtil;
  18 import org.openecomp.sdc.vendorsoftwareproduct.dao.OrchestrationTemplateDao;
  19 import org.openecomp.sdc.vendorsoftwareproduct.dao.OrchestrationTemplateDaoFactory;
  20 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.UploadDataEntity;
  21 import org.openecomp.sdc.versioning.dao.types.Version;
  22
  23 import java.util.Map;
  24 import java.util.Objects;
  25 import java.util.Optional;
  26
  27 public class HeatToToscaTranslationHealer implements Healer  {
  28
  29   private static final OrchestrationTemplateDao orchestrationTemplateDao =
  30       OrchestrationTemplateDaoFactory.getInstance().createInterface();
  31   private static final ServiceModelDao<ToscaServiceModel, ServiceElement> serviceModelDao =
  32       ServiceModelDaoFactory.getInstance().createInterface();
  33   public static final ServiceTemplateDaoInter
  34       templateDao = ServiceTemplateDaoFactory.getInstance().createInterface();
  35   private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
  36
  37   public HeatToToscaTranslationHealer(){
  38
  39   }
  40
  41   @Override
  42   public Object heal(Map<String, Object> healingParams) throws Exception {
  43     mdcDataDebugMessage.debugEntryMessage(null, null);
  44     String vspId = (String) healingParams.get(SdcCommon.VSP_ID);
  45     Version version = (Version) healingParams.get(SdcCommon.VERSION);
  46     String user = (String) healingParams.get(SdcCommon.USER);
  47     UploadDataEntity uploadData =
  48         orchestrationTemplateDao.getOrchestrationTemplate(vspId, version);
  49
  50     if (Objects.isNull(uploadData) || Objects.isNull(uploadData.getContentData())) {
  51       return Optional.empty();
  52     }
  53
  54     FileContentHandler fileContentHandler;
  55     TranslatorOutput translatorOutput;
  56     try {
  57       fileContentHandler = CommonUtil.validateAndUploadFileContent(OnboardingTypesEnum.ZIP, uploadData
  58           .getContentData().array());
  59       translatorOutput =
  60           HeatToToscaUtil.loadAndTranslateTemplateData(fileContentHandler);
  61     }catch (Exception e){
  62       return Optional.empty();
  63     }
  64
  65     if(Objects.isNull(translatorOutput)){
  66       return Optional.empty();
  67     }
  68
  69     if (translatorOutput != null && translatorOutput.getToscaServiceModel() == null) {
  70       return Optional.empty();
  71     }
  72       //templateDao.deleteAll(vspId, version);
  73     serviceModelDao.deleteAll(vspId,version);
  74     serviceModelDao.storeServiceModel(vspId, version,
  75         translatorOutput.getToscaServiceModel());
  76     mdcDataDebugMessage.debugExitMessage("VSP id", vspId);
  77
  78     return translatorOutput;
  79
  80   }
  81 }