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/ComponentMonitoringUploadsImpl.java

   1 package org.openecomp.sdcrests.vsp.rest.services;
   2
   3 import org.apache.cxf.jaxrs.ext.multipart.Attachment;
   4 import org.openecomp.core.enrichment.types.MonitoringUploadType;
   5 import org.openecomp.core.validation.errors.ErrorMessagesFormatBuilder;
   6 import org.openecomp.sdc.common.errors.Messages;
   7 import org.openecomp.sdc.vendorsoftwareproduct.ComponentManager;
   8 import org.openecomp.sdc.vendorsoftwareproduct.ComponentManagerFactory;
   9 import org.openecomp.sdc.vendorsoftwareproduct.MonitoringUploadsManager;
  10 import org.openecomp.sdc.vendorsoftwareproduct.MonitoringUploadsManagerFactory;
  11 import org.openecomp.sdc.vendorsoftwareproduct.types.schemagenerator.MonitoringUploadStatus;
  12 import org.openecomp.sdc.versioning.dao.types.Version;
  13 import org.openecomp.sdcrests.vendorsoftwareproducts.types.MonitoringUploadStatusDto;
  14 import org.openecomp.sdcrests.vsp.rest.ComponentMonitoringUploads;
  15 import org.openecomp.sdcrests.vsp.rest.mapping.MapMonitoringUploadStatusToDto;
  16 import org.springframework.context.annotation.Scope;
  17 import org.springframework.stereotype.Service;
  18
  19 import javax.inject.Named;
  20 import javax.ws.rs.core.Response;
  21 import java.io.InputStream;
  22
  23 /**
  24  * @author katyr
  25  * @since June 26, 2017
  26  */
  27
  28 @Named
  29 @Service("componentMonitoringUploads")
  30 @Scope(value = "prototype")
  31 //@Validated
  32 public class ComponentMonitoringUploadsImpl implements ComponentMonitoringUploads {
  33   private MonitoringUploadsManager
  34       monitoringUploadsManager = MonitoringUploadsManagerFactory.getInstance().createInterface();
  35   private ComponentManager componentManager =
  36       ComponentManagerFactory.getInstance().createInterface();
  37
  38   @Override
  39   public Response upload(Attachment attachment,
  40                          String vspId, String versionId, String componentId, String type,
  41                          String user) throws Exception {
  42
  43     Version version = new Version(versionId);
  44     componentManager.validateComponentExistence(vspId, version, componentId);
  45
  46     MonitoringUploadType monitoringUploadType = getMonitoringUploadType(vspId, componentId, type);
  47     monitoringUploadsManager.upload(attachment.getObject(InputStream.class),
  48         attachment.getContentDisposition().getParameter("filename"), vspId, version, componentId,
  49         monitoringUploadType);
  50     return Response.ok().build();
  51   }
  52
  53   private MonitoringUploadType getMonitoringUploadType(String vspId, String componentId,
  54                                                        String type) throws Exception {
  55     MonitoringUploadType monitoringUploadType;
  56     try {
  57       monitoringUploadType = MonitoringUploadType.valueOf(type);
  58     } catch (IllegalArgumentException exception) {
  59       String errorWithParameters = ErrorMessagesFormatBuilder
  60           .getErrorWithParameters(Messages.ILLEGAL_MONITORING_ARTIFACT_TYPE.getErrorMessage(),
  61               componentId, vspId);
  62       throw new Exception(errorWithParameters, exception);
  63     }
  64     return monitoringUploadType;
  65   }
  66
  67   @Override
  68   public Response delete(String vspId, String versionId, String componentId,
  69                          String type, String user) throws Exception {
  70
  71     MonitoringUploadType monitoringUploadType = getMonitoringUploadType(vspId, componentId, type);
  72
  73     Version version = new Version(versionId);
  74     componentManager.validateComponentExistence(vspId, version, componentId);
  75     monitoringUploadsManager.delete(vspId, version, componentId, monitoringUploadType);
  76     return Response.ok().build();
  77   }
  78
  79   @Override
  80   public Response list(String vspId, String versionId, String componentId,
  81                        String user) {
  82
  83     Version version = new Version(versionId);
  84     componentManager.validateComponentExistence(vspId, version, componentId);
  85
  86     MonitoringUploadStatus response =
  87         monitoringUploadsManager.listFilenames(vspId, version, componentId);
  88
  89     MonitoringUploadStatusDto returnEntity =
  90         new MapMonitoringUploadStatusToDto()
  91             .applyMapping(response, MonitoringUploadStatusDto.class);
  92     return Response.status(Response.Status.OK).entity(returnEntity).build();
  93   }
  94 }