openecomp-be/api/openecomp-sdc-rest-webapp/vendor-software-products-rest/vendor-software-products-rest-services/src/main/java/org/openecomp/sdcrests/vsp/rest/services/ComputeImpl.java

   1 package org.openecomp.sdcrests.vsp.rest.services;
   2
   3 import org.apache.commons.collections4.CollectionUtils;
   4 import org.openecomp.sdc.logging.context.MdcUtil;
   5 import org.openecomp.sdc.logging.types.LoggerServiceName;
   6 import org.openecomp.sdc.vendorsoftwareproduct.ComponentManager;
   7 import org.openecomp.sdc.vendorsoftwareproduct.ComponentManagerFactory;
   8 import org.openecomp.sdc.vendorsoftwareproduct.ComputeManager;
   9 import org.openecomp.sdc.vendorsoftwareproduct.ComputeManagerFactory;
  10 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComputeEntity;
  11 import org.openecomp.sdc.vendorsoftwareproduct.types.CompositionEntityResponse;
  12 import org.openecomp.sdc.vendorsoftwareproduct.types.ListComputeResponse;
  13 import org.openecomp.sdc.vendorsoftwareproduct.types.QuestionnaireResponse;
  14 import org.openecomp.sdc.vendorsoftwareproduct.types.composition.CompositionEntityValidationData;
  15 import org.openecomp.sdc.vendorsoftwareproduct.types.composition.ComputeData;
  16 import org.openecomp.sdc.versioning.dao.types.Version;
  17 import org.openecomp.sdcrests.vendorsoftwareproducts.types.CompositionEntityResponseDto;
  18 import org.openecomp.sdcrests.vendorsoftwareproducts.types.CompositionEntityValidationDataDto;
  19 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ComputeCreationDto;
  20 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ComputeDetailsDto;
  21 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ComputeDto;
  22 import org.openecomp.sdcrests.vendorsoftwareproducts.types.QuestionnaireResponseDto;
  23 import org.openecomp.sdcrests.vsp.rest.Compute;
  24 import org.openecomp.sdcrests.vsp.rest.mapping.MapCompositionEntityResponseToDto;
  25 import org.openecomp.sdcrests.vsp.rest.mapping.MapCompositionEntityValidationDataToDto;
  26 import org.openecomp.sdcrests.vsp.rest.mapping.MapComputeDataToComputeDetailsDto;
  27 import org.openecomp.sdcrests.vsp.rest.mapping.MapComputeDetailsDtoToComputeEntity;
  28 import org.openecomp.sdcrests.vsp.rest.mapping.MapComputeEntityToComputeCreationDto;
  29 import org.openecomp.sdcrests.vsp.rest.mapping.MapComputeEntityToComputeDto;
  30 import org.openecomp.sdcrests.vsp.rest.mapping.MapQuestionnaireResponseToQuestionnaireResponseDto;
  31 import org.openecomp.sdcrests.wrappers.GenericCollectionWrapper;
  32 import org.springframework.context.annotation.Scope;
  33 import org.springframework.stereotype.Service;
  34
  35 import javax.inject.Named;
  36 import javax.ws.rs.core.Response;
  37 import java.util.Collection;
  38
  39 @Named
  40 @Service("computes")
  41 @Scope(value = "prototype")
  42 public class ComputeImpl implements Compute {
  43   private ComputeManager computetManager =
  44       ComputeManagerFactory.getInstance().createInterface();
  45   private ComponentManager componentManager =
  46       ComponentManagerFactory.getInstance().createInterface();
  47
  48   @Override
  49   public Response list(String vspId, String versionId, String componentId, String user) {
  50     MdcUtil.initMdc(LoggerServiceName.List_Computes.toString());
  51     Version version = new Version(versionId);
  52     componentManager.validateComponentExistence(vspId, version, componentId);
  53     Collection<ListComputeResponse> computes =
  54         computetManager.listComputes(vspId, version, componentId);
  55
  56     MapComputeEntityToComputeDto mapper = new MapComputeEntityToComputeDto();
  57     GenericCollectionWrapper<ComputeDto> results = new GenericCollectionWrapper<>();
  58     for (ListComputeResponse compute : computes) {
  59       results.add(mapper.applyMapping(compute, ComputeDto.class));
  60     }
  61
  62     return Response.ok(results).build();
  63   }
  64
  65   @Override
  66   public Response get(String vspId, String versionId, String componentId, String computeId,
  67                       String user) {
  68     MdcUtil.initMdc(LoggerServiceName.Get_Compute.toString());
  69     Version version = new Version(versionId);
  70     componentManager.validateComponentExistence(vspId, version, componentId);
  71     CompositionEntityResponse<ComputeData> response =
  72         computetManager.getCompute(vspId, version, componentId, computeId);
  73
  74     CompositionEntityResponseDto<ComputeDetailsDto> responseDto = new
  75         CompositionEntityResponseDto<>();
  76     new MapCompositionEntityResponseToDto<>(new MapComputeDataToComputeDetailsDto(),
  77         ComputeDetailsDto.class).doMapping(response, responseDto);
  78     return Response.ok(responseDto).build();
  79   }
  80
  81   @Override
  82   public Response create(ComputeDetailsDto request, String vspId, String versionId,
  83                          String componentId, String user) {
  84     MdcUtil.initMdc(LoggerServiceName.Create_Compute.toString());
  85     ComputeEntity compute = new MapComputeDetailsDtoToComputeEntity().applyMapping(request,
  86         ComputeEntity.class);
  87     compute.setVspId(vspId);
  88     compute.setVersion(new Version(versionId));
  89     compute.setComponentId(componentId);
  90     componentManager.validateComponentExistence(vspId, compute.getVersion(), componentId);
  91
  92     ComputeEntity createdCompute = computetManager.createCompute(compute);
  93
  94     MapComputeEntityToComputeCreationDto mapper = new MapComputeEntityToComputeCreationDto();
  95     ComputeCreationDto createdComputeDto =
  96         mapper.applyMapping(createdCompute, ComputeCreationDto.class);
  97     return Response.ok(createdComputeDto != null ? createdComputeDto : null).build();
  98   }
  99
 100   @Override
 101   public Response update(ComputeDetailsDto request, String vspId, String versionId,
 102                          String componentId, String computeFlavorId, String user) {
 103     MdcUtil.initMdc(LoggerServiceName.Update_Compute.toString());
 104     ComputeEntity compute =
 105         new MapComputeDetailsDtoToComputeEntity().applyMapping(request, ComputeEntity.class);
 106     compute.setVspId(vspId);
 107     compute.setVersion(new Version(versionId));
 108     compute.setComponentId(componentId);
 109     compute.setId(computeFlavorId);
 110
 111     componentManager.validateComponentExistence(vspId, compute.getVersion(), componentId);
 112     CompositionEntityValidationData validationData = computetManager.updateCompute(compute);
 113     return validationData != null && CollectionUtils.isNotEmpty(validationData.getErrors())
 114         ? Response.status(Response.Status.EXPECTATION_FAILED).entity(
 115         new MapCompositionEntityValidationDataToDto().applyMapping(validationData,
 116             CompositionEntityValidationDataDto.class)).build() : Response.ok().build();
 117   }
 118
 119   @Override
 120   public Response delete(String vspId, String versionId, String componentId, String computeFlavorId,
 121                          String user) {
 122     MdcUtil.initMdc(LoggerServiceName.Delete_Compute.toString());
 123     Version version = new Version(versionId);
 124     componentManager.validateComponentExistence(vspId, version, componentId);
 125     computetManager.deleteCompute(vspId, version, componentId, computeFlavorId);
 126     return Response.ok().build();
 127   }
 128
 129   @Override
 130   public Response getQuestionnaire(String vspId, String versionId, String componentId,
 131                                    String computeFlavorId, String user) {
 132     MdcUtil.initMdc(LoggerServiceName.Get_Questionnaire_Compute.toString());
 133     Version version = new Version(versionId);
 134     componentManager.validateComponentExistence(vspId, version, componentId);
 135     QuestionnaireResponse questionnaireResponse =
 136         computetManager.getComputeQuestionnaire(vspId, version, componentId, computeFlavorId);
 137
 138     QuestionnaireResponseDto result = new MapQuestionnaireResponseToQuestionnaireResponseDto()
 139         .applyMapping(questionnaireResponse, QuestionnaireResponseDto.class);
 140     return Response.ok(result).build();
 141   }
 142
 143   @Override
 144   public Response updateQuestionnaire(String questionnaireData, String vspId, String versionId,
 145                                       String componentId, String computeFlavorId, String user) {
 146     MdcUtil.initMdc(LoggerServiceName.Update_Questionnaire_Compute.toString());
 147     Version version = new Version(versionId);
 148     componentManager.validateComponentExistence(vspId, version, componentId);
 149     computetManager.updateComputeQuestionnaire(vspId, version, componentId, computeFlavorId,
 150         questionnaireData);
 151     return Response.ok().build();
 152   }
 153 }