2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdcrests.vsp.rest.services;
23 import org.openecomp.sdc.activityLog.ActivityLogManager;
24 import org.openecomp.sdc.activityLog.ActivityLogManagerFactory;
25 import org.openecomp.sdc.logging.api.Logger;
26 import org.openecomp.sdc.logging.api.LoggerFactory;
27 import org.openecomp.sdc.logging.context.MdcUtil;
28 import org.openecomp.sdc.logging.messages.AuditMessages;
29 import org.openecomp.sdc.logging.types.LoggerConstants;
30 import org.openecomp.sdc.logging.types.LoggerServiceName;
31 import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductManager;
32 import org.openecomp.sdc.vendorsoftwareproduct.VspManagerFactory;
33 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.PackageInfo;
34 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
35 import org.openecomp.sdc.vendorsoftwareproduct.types.QuestionnaireResponse;
36 import org.openecomp.sdc.vendorsoftwareproduct.types.ValidationResponse;
37 import org.openecomp.sdc.vendorsoftwareproduct.types.VersionedVendorSoftwareProductInfo;
38 import org.openecomp.sdc.versioning.dao.types.Version;
39 import org.openecomp.sdc.versioning.types.VersionInfo;
40 import org.openecomp.sdc.versioning.types.VersionableEntityAction;
41 import org.openecomp.sdcrests.vendorsoftwareproducts.types.PackageInfoDto;
42 import org.openecomp.sdcrests.vendorsoftwareproducts.types.QuestionnaireResponseDto;
43 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ValidationResponseDto;
44 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VersionSoftwareProductActionRequestDto;
45 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspCreationDto;
46 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspDescriptionDto;
47 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspDetailsDto;
48 import org.openecomp.sdcrests.vsp.rest.VendorSoftwareProducts;
49 import org.openecomp.sdcrests.vsp.rest.mapping.MapPackageInfoToPackageInfoDto;
50 import org.openecomp.sdcrests.vsp.rest.mapping.MapQuestionnaireResponseToQuestionnaireResponseDto;
51 import org.openecomp.sdcrests.vsp.rest.mapping.MapValidationResponseToDto;
52 import org.openecomp.sdcrests.vsp.rest.mapping.MapVersionedVendorSoftwareProductInfoToVspDetailsDto;
53 import org.openecomp.sdcrests.vsp.rest.mapping.MapVspDescriptionDtoToVspDetails;
54 import org.openecomp.sdcrests.vsp.rest.mapping.MspVspDetailsToVspCreationDto;
55 import org.openecomp.sdcrests.wrappers.GenericCollectionWrapper;
56 import org.openecomp.sdcrests.wrappers.StringWrapperResponse;
58 import org.springframework.context.annotation.Scope;
59 import org.springframework.stereotype.Service;
61 import javax.inject.Named;
62 import javax.ws.rs.core.Response;
64 import java.io.IOException;
65 import java.util.List;
69 @Service("vendorSoftwareProducts")
70 @Scope(value = "prototype")
71 public class VendorSoftwareProductsImpl implements VendorSoftwareProducts {
73 private VendorSoftwareProductManager vendorSoftwareProductManager =
74 VspManagerFactory.getInstance().createInterface();
76 private static final Logger logger =
77 LoggerFactory.getLogger(VendorSoftwareProductsImpl.class);
79 private ActivityLogManager activityLogManager =
80 ActivityLogManagerFactory.getInstance().createInterface();
83 public Response createVsp(VspDescriptionDto vspDescriptionDto, String user) {
84 MdcUtil.initMdc(LoggerServiceName.Create_VSP.toString());
85 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.CREATE_VSP + vspDescriptionDto.getName());
87 VspDetails vspDetails =
88 new MapVspDescriptionDtoToVspDetails().applyMapping(vspDescriptionDto, VspDetails.class);
90 vspDetails = vendorSoftwareProductManager.createVsp(vspDetails, user);
92 MspVspDetailsToVspCreationDto mapping = new MspVspDetailsToVspCreationDto();
93 VspCreationDto vspCreationDto = mapping.applyMapping(vspDetails, VspCreationDto.class);
95 return Response.ok(vspCreationDto).build();
99 public Response listVsps(String versionFilter, String user) {
100 MdcUtil.initMdc(LoggerServiceName.List_VSP.toString());
101 List<VersionedVendorSoftwareProductInfo> vspList =
102 vendorSoftwareProductManager.listVsps(versionFilter, user);
104 GenericCollectionWrapper<VspDetailsDto> results = new GenericCollectionWrapper<>();
105 if (!vspList.isEmpty()) {
106 MapVersionedVendorSoftwareProductInfoToVspDetailsDto mapper =
107 new MapVersionedVendorSoftwareProductInfoToVspDetailsDto();
108 for (VersionedVendorSoftwareProductInfo versionedVsp : vspList) {
109 results.add(mapper.applyMapping(versionedVsp, VspDetailsDto.class));
113 return Response.ok(results).build();
117 public Response getVsp(String vspId, String versionId, String user) {
118 MdcUtil.initMdc(LoggerServiceName.Get_VSP.toString());
121 VspDetails vspDetails =
122 vendorSoftwareProductManager
123 .getVsp(vspId, resolveVspVersion(vspId, versionId, user, VersionableEntityAction.Read),
126 VersionInfo versionInfo = getVersionInfo(vspId, VersionableEntityAction.Read, user);
129 if (vspDetails.getOldVersion() != null && !"".equals(vspDetails.getOldVersion())) {
130 if (Version.valueOf(versionId).equals(versionInfo.getActiveVersion())) {
132 Version healedVersion = vendorSoftwareProductManager.callAutoHeal(vspId, versionInfo,
135 vendorSoftwareProductManager
136 .getVsp(vspId, resolveVspVersion(vspId, healedVersion.toString(), user,
137 VersionableEntityAction.Read), user);
138 versionInfo = getVersionInfo(vspId, VersionableEntityAction.Read, user);
139 } catch (Exception e) {
145 VspDetailsDto vspDetailsDto = vspDetails == null
147 : new MapVersionedVendorSoftwareProductInfoToVspDetailsDto()
148 .applyMapping(new VersionedVendorSoftwareProductInfo(vspDetails, versionInfo),
149 VspDetailsDto.class);
151 return Response.ok(vspDetailsDto).build();
155 public Response updateVsp(String vspId, String versionId, VspDescriptionDto vspDescriptionDto,
157 MdcUtil.initMdc(LoggerServiceName.Update_VSP.toString());
158 VspDetails vspDetails =
159 new MapVspDescriptionDtoToVspDetails().applyMapping(vspDescriptionDto, VspDetails.class);
160 vspDetails.setId(vspId);
161 vspDetails.setVersion(resolveVspVersion(vspId, null, user, VersionableEntityAction.Write));
163 vendorSoftwareProductManager.updateVsp(vspDetails, user);
165 return Response.ok().build();
169 public Response deleteVsp(String vspId, String user) {
170 MdcUtil.initMdc(LoggerServiceName.Delete_VSP.toString());
171 vendorSoftwareProductManager.deleteVsp(vspId, user);
173 return Response.ok().build();
177 public Response actOnVendorSoftwareProduct(String vspId, String versionId,
178 VersionSoftwareProductActionRequestDto request,
179 String user) throws IOException {
181 switch (request.getAction()) {
183 MDC.put(LoggerConstants.SERVICE_NAME, LoggerServiceName.Checkout_VSP.toString());
184 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.CHECK_OUT_VSP + vspId);
185 vendorSoftwareProductManager.checkout(vspId, user);
188 MDC.put(LoggerConstants.SERVICE_NAME, LoggerServiceName.Undo_Checkout_VSP.toString());
189 vendorSoftwareProductManager.undoCheckout(vspId, user);
192 MDC.put(LoggerConstants.SERVICE_NAME, LoggerServiceName.Checkin_VSP.toString());
193 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.CHECK_IN_VSP + vspId);
194 vendorSoftwareProductManager.checkin(vspId, user);
197 MDC.put(LoggerConstants.SERVICE_NAME, LoggerServiceName.Submit_VSP.toString());
198 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.SUBMIT_VSP + vspId);
199 ValidationResponse validationResponse = vendorSoftwareProductManager.submit(vspId, user);
200 if (!validationResponse.isValid()) {
201 return Response.status(Response.Status.EXPECTATION_FAILED).entity(
202 new MapValidationResponseToDto()
203 .applyMapping(validationResponse, ValidationResponseDto.class)).build();
207 MDC.put(LoggerConstants.SERVICE_NAME, LoggerServiceName.Create_Package.toString());
209 PackageInfo packageInfo = vendorSoftwareProductManager.createPackage(vspId,
210 resolveVspVersion(vspId, null, user, VersionableEntityAction.Read), user);
211 return Response.ok(packageInfo == null
213 : new MapPackageInfoToPackageInfoDto().applyMapping(packageInfo, PackageInfoDto.class))
218 return Response.ok().build();
222 public Response getValidationVsp(String user)
224 String validationVspId = vendorSoftwareProductManager.fetchValidationVsp(user);
225 StringWrapperResponse response = new StringWrapperResponse(validationVspId);
226 return Response.ok(response).build();
231 public Response getOrchestrationTemplate(String vspId, String versionId, String user) {
232 MdcUtil.initMdc(LoggerServiceName.Get_Uploaded_File.toString());
233 byte[] orchestrationTemplateFile =
234 vendorSoftwareProductManager
235 .getOrchestrationTemplateFile(vspId,
236 resolveVspVersion(vspId, versionId, user, VersionableEntityAction.Read), user);
238 if (orchestrationTemplateFile == null) {
239 return Response.status(Response.Status.NOT_FOUND).build();
241 Response.ResponseBuilder response = Response.ok(orchestrationTemplateFile);
242 response.header("Content-Disposition", "attachment; filename=LatestHeatPackage.zip");
243 return response.build();
247 public Response listPackages(String category, String subCategory, String user) {
248 MdcUtil.initMdc(LoggerServiceName.List_Packages.toString());
249 List<PackageInfo> packageInfoList =
250 vendorSoftwareProductManager.listPackages(category, subCategory);
252 GenericCollectionWrapper<PackageInfoDto> results = new GenericCollectionWrapper<>();
253 MapPackageInfoToPackageInfoDto mapper = new MapPackageInfoToPackageInfoDto();
255 if (packageInfoList != null) {
256 for (PackageInfo packageInfo : packageInfoList) {
257 results.add(mapper.applyMapping(packageInfo, PackageInfoDto.class));
260 return Response.ok(results).build();
264 public Response getTranslatedFile(String vspId, String versionId, String user) {
265 MdcUtil.initMdc(LoggerServiceName.Get_Translated_File.toString());
267 Version version = Version.valueOf(versionId);
268 Version resolvedVersion = version == null
269 ? getVersionInfo(vspId, VersionableEntityAction.Read, user).getLatestFinalVersion()
272 File zipFile = vendorSoftwareProductManager.getTranslatedFile(vspId, resolvedVersion, user);
274 Response.ResponseBuilder response = Response.ok(zipFile);
275 if (zipFile == null) {
276 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.IMPORT_FAIL + vspId);
277 return Response.status(Response.Status.NOT_FOUND).build();
279 response.header("Content-Disposition", "attachment; filename=" + zipFile.getName());
281 logger.audit(AuditMessages.AUDIT_MSG + AuditMessages.IMPORT_SUCCESS + vspId);
282 return response.build();
286 public Response getQuestionnaire(String vspId, String versionId, String user) {
287 MdcUtil.initMdc(LoggerServiceName.Get_Questionnaire_VSP.toString());
288 QuestionnaireResponse questionnaireResponse =
289 vendorSoftwareProductManager.getVspQuestionnaire(vspId,
290 resolveVspVersion(vspId, versionId, user, VersionableEntityAction.Read), user);
292 if (questionnaireResponse.getErrorMessage() != null) {
293 return Response.status(Response.Status.EXPECTATION_FAILED).entity(
294 new MapQuestionnaireResponseToQuestionnaireResponseDto()
295 .applyMapping(questionnaireResponse, QuestionnaireResponseDto.class)).build();
298 QuestionnaireResponseDto result = new MapQuestionnaireResponseToQuestionnaireResponseDto()
299 .applyMapping(questionnaireResponse, QuestionnaireResponseDto.class);
300 return Response.ok(result).build();
304 public Response updateQuestionnaire(String questionnaireData, String vspId, String
305 versionId, String user) {
306 MdcUtil.initMdc(LoggerServiceName.Update_Questionnaire_VSP.toString());
307 vendorSoftwareProductManager.updateVspQuestionnaire(vspId,
308 resolveVspVersion(vspId, null, user, VersionableEntityAction.Write),
309 questionnaireData, user);
310 return Response.ok().build();
314 public Response heal(String vspId, String versionId, String user) {
315 vendorSoftwareProductManager.heal(vspId, Version.valueOf(versionId), user);
317 return Response.ok().build();
321 public Response getVspInformationArtifact(String vspId, String versionId, String user) {
322 MdcUtil.initMdc(LoggerServiceName.Get_Information_Artifact.toString());
323 File textInformationArtifact =
324 vendorSoftwareProductManager.getInformationArtifact(vspId,
325 resolveVspVersion(vspId, versionId, user, VersionableEntityAction.Read), user);
327 Response.ResponseBuilder response = Response.ok(textInformationArtifact);
328 if (textInformationArtifact == null) {
329 return Response.status(Response.Status.NOT_FOUND).build();
332 .header("Content-Disposition", "attachment; filename=" + textInformationArtifact.getName());
333 return response.build();