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

   1 package org.openecomp.sdcrests.vsp.rest.services;
   2
   3 import org.apache.commons.beanutils.BeanUtils;
   4 import org.apache.commons.lang3.tuple.Pair;
   5 import org.apache.cxf.jaxrs.ext.multipart.Attachment;
   6 import org.openecomp.core.validation.errors.ErrorMessagesFormatBuilder;
   7 import org.openecomp.sdc.activitylog.ActivityLogManager;
   8 import org.openecomp.sdc.activitylog.ActivityLogManagerFactory;
   9 import org.openecomp.sdc.activitylog.dao.type.ActivityLogEntity;
  10 import org.openecomp.sdc.activitylog.dao.type.ActivityType;
  11 import org.openecomp.sdc.common.errors.Messages;
  12 import org.openecomp.sdc.logging.api.Logger;
  13 import org.openecomp.sdc.logging.api.LoggerFactory;
  14 import org.openecomp.sdc.logging.context.MdcUtil;
  15 import org.openecomp.sdc.logging.messages.AuditMessages;
  16 import org.openecomp.sdc.logging.types.LoggerServiceName;
  17 import org.openecomp.sdc.vendorsoftwareproduct.OrchestrationTemplateCandidateManager;
  18 import org.openecomp.sdc.vendorsoftwareproduct.OrchestrationTemplateCandidateManagerFactory;
  19 import org.openecomp.sdc.vendorsoftwareproduct.types.OrchestrationTemplateActionResponse;
  20 import org.openecomp.sdc.vendorsoftwareproduct.types.UploadFileResponse;
  21 import org.openecomp.sdc.vendorsoftwareproduct.types.ValidationResponse;
  22 import org.openecomp.sdc.vendorsoftwareproduct.types.candidateheat.FilesDataStructure;
  23 import org.openecomp.sdc.versioning.dao.types.Version;
  24 import org.openecomp.sdcrests.vendorsoftwareproducts.types.FileDataStructureDto;
  25 import org.openecomp.sdcrests.vendorsoftwareproducts.types.OrchestrationTemplateActionResponseDto;
  26 import org.openecomp.sdcrests.vendorsoftwareproducts.types.UploadFileResponseDto;
  27 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ValidationResponseDto;
  28 import org.openecomp.sdcrests.vsp.rest.OrchestrationTemplateCandidate;
  29 import org.openecomp.sdcrests.vsp.rest.mapping.MapFilesDataStructureToDto;
  30 import org.openecomp.sdcrests.vsp.rest.mapping.MapUploadFileResponseToUploadFileResponseDto;
  31 import org.openecomp.sdcrests.vsp.rest.mapping.MapValidationResponseToDto;
  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.io.IOException;
  38 import java.io.InputStream;
  39 import java.lang.reflect.InvocationTargetException;
  40 import java.util.Optional;
  41
  42 import static org.openecomp.core.utilities.file.FileUtils.getFileExtension;
  43 import static org.openecomp.core.utilities.file.FileUtils.getNetworkPackageName;
  44
  45 @Named
  46 @Service("orchestrationTemplateCandidate")
  47 @Scope(value = "prototype")
  48 public class OrchestrationTemplateCandidateImpl implements OrchestrationTemplateCandidate {
  49
  50   private OrchestrationTemplateCandidateManager candidateManager =
  51       OrchestrationTemplateCandidateManagerFactory.getInstance().createInterface();
  52   private ActivityLogManager activityLogManager =
  53       ActivityLogManagerFactory.getInstance().createInterface();
  54
  55   private static final Logger logger =
  56       LoggerFactory.getLogger(OrchestrationTemplateCandidateImpl.class);
  57
  58   @Override
  59   public Response upload(String vspId, String versionId, Attachment fileToUpload, String user) {
  60     MdcUtil.initMdc(LoggerServiceName.Upload_File.toString());
  61     logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.UPLOAD_HEAT + vspId);
  62
  63     String filename = fileToUpload.getContentDisposition().getParameter("filename");
  64     UploadFileResponse uploadFileResponse = candidateManager
  65         .upload(vspId, new Version(versionId), fileToUpload.getObject(InputStream.class),
  66             getFileExtension(filename), getNetworkPackageName(filename));
  67
  68     UploadFileResponseDto uploadFileResponseDto = new MapUploadFileResponseToUploadFileResponseDto()
  69         .applyMapping(uploadFileResponse, UploadFileResponseDto.class);
  70
  71     return Response.ok(uploadFileResponseDto).build();
  72   }
  73
  74   @Override
  75   public Response get(String vspId, String versionId, String user) throws IOException {
  76     Optional<Pair<String, byte[]>> zipFile = candidateManager.get(vspId, new Version(versionId));
  77
  78     if (!zipFile.isPresent()) {
  79       return Response.status(Response.Status.NOT_FOUND).build();
  80     }
  81     Response.ResponseBuilder response = Response.ok(zipFile.get().getRight());
  82     String filename = "Candidate." + zipFile.get().getLeft();
  83     response.header("Content-Disposition", "attachment; filename=" + filename);
  84     return response.build();
  85   }
  86
  87   @Override
  88   public Response process(String vspId, String versionId, String user)
  89       throws InvocationTargetException, IllegalAccessException {
  90
  91     Version version = new Version(versionId);
  92     OrchestrationTemplateActionResponse response = candidateManager.process(vspId, version);
  93
  94     activityLogManager.logActivity(new ActivityLogEntity(vspId, version,
  95         ActivityType.Upload_Network_Package, user, true, "", ""));
  96
  97     OrchestrationTemplateActionResponseDto responseDto =
  98         new OrchestrationTemplateActionResponseDto();
  99     BeanUtils.copyProperties(responseDto, response);
 100
 101     return Response.ok(responseDto).build();
 102   }
 103
 104   @Override
 105   public Response updateFilesDataStructure(
 106       String vspId, String versionId, FileDataStructureDto fileDataStructureDto, String user)
 107       throws Exception {
 108
 109     FilesDataStructure fileDataStructure = new FilesDataStructure();
 110     try {
 111       BeanUtils.copyProperties(fileDataStructure, fileDataStructureDto);
 112     } catch (IllegalAccessException | InvocationTargetException exception) {
 113       String errorWithParameters = ErrorMessagesFormatBuilder
 114           .getErrorWithParameters(Messages.MAPPING_OBJECTS_FAILURE.getErrorMessage(),
 115               fileDataStructureDto.toString(), fileDataStructure.toString());
 116       throw new Exception(errorWithParameters, exception);
 117     }
 118     ValidationResponse response = candidateManager
 119         .updateFilesDataStructure(vspId, new Version(versionId), fileDataStructure);
 120
 121     if (!response.isValid()) {
 122       return Response.status(Response.Status.EXPECTATION_FAILED).entity(
 123           new MapValidationResponseToDto()
 124               .applyMapping(response, ValidationResponseDto.class)).build();
 125     }
 126     return Response.ok(fileDataStructureDto).build();
 127   }
 128
 129   @Override
 130   public Response getFilesDataStructure(String vspId, String versionId, String user)
 131       throws Exception {
 132     Optional<FilesDataStructure> filesDataStructure =
 133         candidateManager.getFilesDataStructure(vspId, new Version(versionId));
 134
 135     FileDataStructureDto fileDataStructureDto =
 136         filesDataStructure.map(dataStructure -> new MapFilesDataStructureToDto()
 137             .applyMapping(dataStructure, FileDataStructureDto.class))
 138             .orElse(new FileDataStructureDto());
 139     return Response.ok(fileDataStructureDto).build();
 140   }
 141 }