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