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