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