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