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.apache.commons.collections4.MapUtils;
24 import org.openecomp.core.util.UniqueValueUtil;
25 import org.openecomp.core.utilities.orchestration.OnboardingTypesEnum;
26 import org.openecomp.sdc.activitylog.ActivityLogManager;
27 import org.openecomp.sdc.activitylog.ActivityLogManagerFactory;
28 import org.openecomp.sdc.activitylog.dao.type.ActivityLogEntity;
29 import org.openecomp.sdc.activitylog.dao.type.ActivityType;
30 import org.openecomp.sdc.common.errors.CoreException;
31 import org.openecomp.sdc.common.errors.ErrorCode;
32 import org.openecomp.sdc.common.errors.Messages;
33 import org.openecomp.sdc.datatypes.error.ErrorLevel;
34 import org.openecomp.sdc.datatypes.error.ErrorMessage;
35 import org.openecomp.sdc.datatypes.model.ItemType;
36 import org.openecomp.sdc.healing.factory.HealingManagerFactory;
37 import org.openecomp.sdc.itempermissions.ItemPermissionsManager;
38 import org.openecomp.sdc.itempermissions.ItemPermissionsManagerFactory;
39 import org.openecomp.sdc.itempermissions.impl.types.PermissionTypes;
40 import org.openecomp.sdc.logging.api.Logger;
41 import org.openecomp.sdc.logging.api.LoggerFactory;
42 import org.openecomp.sdc.logging.context.MdcUtil;
43 import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
44 import org.openecomp.sdc.logging.messages.AuditMessages;
45 import org.openecomp.sdc.logging.types.LoggerConstants;
46 import org.openecomp.sdc.logging.types.LoggerErrorCode;
47 import org.openecomp.sdc.logging.types.LoggerServiceName;
48 import org.openecomp.sdc.logging.types.LoggerTragetServiceName;
49 import org.openecomp.sdc.notification.dtos.Event;
50 import org.openecomp.sdc.notification.factories.NotificationPropagationManagerFactory;
51 import org.openecomp.sdc.notification.services.NotificationPropagationManager;
52 import org.openecomp.sdc.vendorsoftwareproduct.OrchestrationTemplateCandidateManagerFactory;
53 import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductManager;
54 import org.openecomp.sdc.vendorsoftwareproduct.VspManagerFactory;
55 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComputeEntity;
56 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.OnboardingMethod;
57 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.OrchestrationTemplateCandidateData;
58 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.OrchestrationTemplateEntity;
59 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.PackageInfo;
60 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
61 import org.openecomp.sdc.vendorsoftwareproduct.errors.CreatePackageForNonFinalVendorSoftwareProductErrorBuilder;
62 import org.openecomp.sdc.vendorsoftwareproduct.errors.OnboardingMethodErrorBuilder;
63 import org.openecomp.sdc.vendorsoftwareproduct.errors.PackageNotFoundErrorBuilder;
64 import org.openecomp.sdc.vendorsoftwareproduct.types.QuestionnaireResponse;
65 import org.openecomp.sdc.vendorsoftwareproduct.types.ValidationResponse;
66 import org.openecomp.sdc.versioning.ItemManager;
67 import org.openecomp.sdc.versioning.ItemManagerFactory;
68 import org.openecomp.sdc.versioning.VersioningManager;
69 import org.openecomp.sdc.versioning.VersioningManagerFactory;
70 import org.openecomp.sdc.versioning.dao.types.Version;
71 import org.openecomp.sdc.versioning.dao.types.VersionStatus;
72 import org.openecomp.sdc.versioning.errors.RequestedVersionInvalidErrorBuilder;
73 import org.openecomp.sdc.versioning.types.Item;
74 import org.openecomp.sdc.versioning.types.NotificationEventTypes;
75 import org.openecomp.sdcrests.item.rest.mapping.MapVersionToDto;
76 import org.openecomp.sdcrests.item.types.ItemCreationDto;
77 import org.openecomp.sdcrests.item.types.VersionDto;
78 import org.openecomp.sdcrests.vendorsoftwareproducts.types.PackageInfoDto;
79 import org.openecomp.sdcrests.vendorsoftwareproducts.types.QuestionnaireResponseDto;
80 import org.openecomp.sdcrests.vendorsoftwareproducts.types.ValidationResponseDto;
81 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VersionSoftwareProductActionRequestDto;
82 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspComputeDto;
83 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspDescriptionDto;
84 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspDetailsDto;
85 import org.openecomp.sdcrests.vendorsoftwareproducts.types.VspRequestDto;
86 import org.openecomp.sdcrests.vsp.rest.VendorSoftwareProducts;
87 import org.openecomp.sdcrests.vsp.rest.mapping.MapComputeEntityToVspComputeDto;
88 import org.openecomp.sdcrests.vsp.rest.mapping.MapItemToVspDetailsDto;
89 import org.openecomp.sdcrests.vsp.rest.mapping.MapPackageInfoToPackageInfoDto;
90 import org.openecomp.sdcrests.vsp.rest.mapping.MapQuestionnaireResponseToQuestionnaireResponseDto;
91 import org.openecomp.sdcrests.vsp.rest.mapping.MapValidationResponseToDto;
92 import org.openecomp.sdcrests.vsp.rest.mapping.MapVspDescriptionDtoToItem;
93 import org.openecomp.sdcrests.vsp.rest.mapping.MapVspDescriptionDtoToVspDetails;
94 import org.openecomp.sdcrests.vsp.rest.mapping.MapVspDetailsToDto;
95 import org.openecomp.sdcrests.wrappers.GenericCollectionWrapper;
96 import org.springframework.context.annotation.Scope;
97 import org.springframework.stereotype.Service;
99 import javax.inject.Named;
100 import javax.ws.rs.core.Response;
102 import java.io.IOException;
103 import java.util.Collection;
104 import java.util.HashMap;
105 import java.util.List;
106 import java.util.Map;
107 import java.util.Optional;
108 import java.util.function.Predicate;
110 import static org.openecomp.sdc.itempermissions.notifications.NotificationConstants.PERMISSION_USER;
111 import static org.openecomp.sdc.logging.messages.AuditMessages.SUBMIT_VSP_ERROR;
112 import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.UniqueValues.VENDOR_SOFTWARE_PRODUCT_NAME;
113 import static org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants.VALIDATION_VSP_NAME;
114 import static org.openecomp.sdc.versioning.VersioningNotificationConstansts.ITEM_ID;
115 import static org.openecomp.sdc.versioning.VersioningNotificationConstansts.ITEM_NAME;
116 import static org.openecomp.sdc.versioning.VersioningNotificationConstansts.SUBMIT_DESCRIPTION;
117 import static org.openecomp.sdc.versioning.VersioningNotificationConstansts.VERSION_ID;
118 import static org.openecomp.sdc.versioning.VersioningNotificationConstansts.VERSION_NAME;
122 @Service("vendorSoftwareProducts")
123 @Scope(value = "prototype")
124 public class VendorSoftwareProductsImpl implements VendorSoftwareProducts {
125 private static final String SUBMIT_ITEM = "Submit_Item";
127 private static final Logger LOGGER = LoggerFactory.getLogger(VendorSoftwareProductsImpl.class);
129 private static ItemCreationDto validationVsp;
131 private ItemManager itemManager = ItemManagerFactory.getInstance().createInterface();
132 private ItemPermissionsManager permissionsManager =
133 ItemPermissionsManagerFactory.getInstance().createInterface();
134 private VersioningManager versioningManager =
135 VersioningManagerFactory.getInstance().createInterface();
136 private VendorSoftwareProductManager vendorSoftwareProductManager =
137 VspManagerFactory.getInstance().createInterface();
138 private ActivityLogManager activityLogManager =
139 ActivityLogManagerFactory.getInstance().createInterface();
140 private NotificationPropagationManager notifier =
141 NotificationPropagationManagerFactory.getInstance().createInterface();
144 public Response createVsp(VspRequestDto vspRequestDto, String user) {
145 MdcUtil.initMdc(LoggerServiceName.Create_VSP.toString());
146 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.CREATE_VSP + vspRequestDto.getName());
148 ItemCreationDto itemCreationDto;
150 OnboardingMethod onboardingMethod;
152 onboardingMethod = OnboardingMethod.valueOf(vspRequestDto.getOnboardingMethod());
153 } catch (IllegalArgumentException e) {
154 throw getUnknownOnboardingMethod();
156 switch (onboardingMethod) {
159 Item item = new MapVspDescriptionDtoToItem().applyMapping(vspRequestDto, Item.class);
160 item.setType(ItemType.vsp.name());
161 item.addProperty(VspItemProperty.ONBOARDING_METHOD, onboardingMethod.name());
163 UniqueValueUtil.validateUniqueValue(VENDOR_SOFTWARE_PRODUCT_NAME, item.getName());
164 item = itemManager.create(item);
165 UniqueValueUtil.createUniqueValue(VENDOR_SOFTWARE_PRODUCT_NAME, item.getName());
167 Version version = versioningManager.create(item.getId(), new Version(), null);
169 VspDetails vspDetails =
170 new MapVspDescriptionDtoToVspDetails().applyMapping(vspRequestDto, VspDetails.class);
171 vspDetails.setId(item.getId());
172 vspDetails.setVersion(version);
173 vspDetails.setOnboardingMethod(vspRequestDto.getOnboardingMethod());
175 vendorSoftwareProductManager.createVsp(vspDetails);
176 versioningManager.publish(item.getId(), version, "Initial vsp:" + vspDetails.getName());
178 itemCreationDto = new ItemCreationDto();
179 itemCreationDto.setItemId(item.getId());
180 itemCreationDto.setVersion(new MapVersionToDto().applyMapping(version, VersionDto.class));
182 activityLogManager.logActivity(new ActivityLogEntity(vspDetails.getId(), version,
183 ActivityType.Create, user, true, "", ""));
186 throw getUnknownOnboardingMethod();
189 return Response.ok(itemCreationDto).build();
192 private CoreException getUnknownOnboardingMethod() {
193 ErrorCode onboardingMethodUpdateErrorCode = OnboardingMethodErrorBuilder
194 .getInvalidOnboardingMethodErrorBuilder();
195 MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_API,
196 LoggerTragetServiceName.ADD_VSP, ErrorLevel.ERROR.name(),
197 LoggerErrorCode.DATA_ERROR.getErrorCode(), onboardingMethodUpdateErrorCode.message());
198 return new CoreException(onboardingMethodUpdateErrorCode);
202 public Response listVsps(String versionStatus, String user) {
203 MdcUtil.initMdc(LoggerServiceName.List_VSP.toString());
205 Predicate<Item> itemPredicate;
206 if (VersionStatus.Certified.name().equals(versionStatus)) {
207 itemPredicate = item -> ItemType.vsp.name().equals(item.getType()) &&
208 item.getVersionStatusCounters().containsKey(VersionStatus.Certified);
210 } else if (VersionStatus.Draft.name().equals(versionStatus)) {
211 itemPredicate = item -> ItemType.vsp.name().equals(item.getType()) &&
212 item.getVersionStatusCounters().containsKey(VersionStatus.Draft) &&
213 userHasPermission(item.getId(), user);
216 itemPredicate = item -> ItemType.vsp.name().equals(item.getType());
219 GenericCollectionWrapper<VspDetailsDto> results = new GenericCollectionWrapper<>();
220 MapItemToVspDetailsDto mapper = new MapItemToVspDetailsDto();
221 itemManager.list(itemPredicate).stream()
222 .sorted((o1, o2) -> o2.getModificationTime().compareTo(o1.getModificationTime()))
223 .forEach(vspItem -> results.add(mapper.applyMapping(vspItem, VspDetailsDto.class)));
225 return Response.ok(results).build();
229 public Response getVsp(String vspId, String versionId, String user) {
230 MdcUtil.initMdc(LoggerServiceName.Get_VSP.toString());
232 Version version = versioningManager.get(vspId, new Version(versionId));
233 VspDetails vspDetails = vendorSoftwareProductManager.getVsp(vspId, version);
234 vspDetails.setWritetimeMicroSeconds(version.getModificationTime().getTime());
237 Optional<Version> healedVersion = HealingManagerFactory.getInstance().createInterface()
238 .healItemVersion(vspId, version, ItemType.vsp, false);
239 healedVersion.ifPresent(vspDetails::setVersion);
241 if (healedVersion.isPresent() && version.getStatus() == VersionStatus.Certified) {
243 submitHealedVsp(vspId, healedVersion.get(), user);
244 } catch (Exception ex) {
245 LOGGER.error("VSP Id {}: Error while submitting version {} " +
246 "created based on Certified version {} for healing purpose.",
247 vspId, healedVersion.get().getId(), versionId, ex.getMessage());
250 } catch (Exception e) {
251 LOGGER.error(String.format("Error while auto healing VSP with Id %s and version %s: %s",
252 vspId, versionId, e.getMessage()));
255 VspDetailsDto vspDetailsDto =
256 new MapVspDetailsToDto().applyMapping(vspDetails, VspDetailsDto.class);
257 addNetworkPackageInfo(vspId, version, vspDetailsDto);
259 return Response.ok(vspDetailsDto).build();
262 private void submitHealedVsp(String vspId, Version healedVersion, String user)
264 Optional<ValidationResponse>
265 validationResponse = submit(vspId, healedVersion, "Submit healed Vsp", user);
266 if (validationResponse.isPresent()) {
267 // TODO: 8/9/2017 before collaboration checkout was done at this scenario (equivalent
268 // to new version in collaboration). need to decide what should be done now.
269 throw new IllegalStateException("Certified vsp after healing failed on validation");
271 vendorSoftwareProductManager.createPackage(vspId, healedVersion);
275 public Response updateVsp(String vspId, String versionId, VspDescriptionDto vspDescriptionDto,
277 MdcUtil.initMdc(LoggerServiceName.Update_VSP.toString());
278 VspDetails vspDetails =
279 new MapVspDescriptionDtoToVspDetails().applyMapping(vspDescriptionDto, VspDetails.class);
280 vspDetails.setId(vspId);
281 vspDetails.setVersion(new Version(versionId));
283 vendorSoftwareProductManager.updateVsp(vspDetails);
285 return Response.ok().build();
289 public Response deleteVsp(String vspId, String user) {
290 MdcUtil.initMdc(LoggerServiceName.Delete_VSP.toString());
291 vendorSoftwareProductManager.deleteVsp(vspId);
293 return Response.ok().build();
297 public Response actOnVendorSoftwareProduct(VersionSoftwareProductActionRequestDto request,
298 String vspId, String versionId,
299 String user) throws IOException {
300 Version version = new Version(versionId);
302 switch (request.getAction()) {
304 if (!permissionsManager.isAllowed(vspId, user, SUBMIT_ITEM)) {
305 return Response.status(Response.Status.FORBIDDEN)
306 .entity(new Exception(Messages.PERMISSIONS_ERROR.getErrorMessage())).build();
309 request.getSubmitRequest() == null ? "" : request.getSubmitRequest().getMessage();
310 Optional<ValidationResponse> validationResponse = submit(vspId, version, message, user);
312 if (validationResponse.isPresent()) {
313 ValidationResponseDto validationResponseDto = new MapValidationResponseToDto()
314 .applyMapping(validationResponse.get(), ValidationResponseDto.class);
315 return Response.status(Response.Status.EXPECTATION_FAILED).entity(validationResponseDto)
319 notifyUsers(vspId, version, message, user, NotificationEventTypes.SUBMIT);
322 return createPackage(vspId, version);
326 return Response.ok().build();
330 public Response getValidationVsp(String user) throws Exception {
331 if (validationVsp != null) {
332 return Response.ok(validationVsp).build();
335 VspRequestDto validationVspRequest = new VspRequestDto();
336 validationVspRequest.setOnboardingMethod("HEAT");
337 validationVspRequest.setName(VALIDATION_VSP_NAME);
340 validationVsp = (ItemCreationDto) createVsp(validationVspRequest, user).getEntity();
341 return Response.ok(validationVsp).build();
343 } catch (CoreException validationVspAlreadyExistException) {
344 // find validationVsp
345 String validationVspId = itemManager.list(item ->
346 ItemType.vsp.name().equals(item.getType()) && VALIDATION_VSP_NAME.equals(item.getName()))
347 .stream().findFirst().orElseThrow(() -> new IllegalStateException("Vsp with name %s " +
348 "does not exist even though the name exists according to unique value util")).getId();
349 Version validationVspVersion = versioningManager.list(validationVspId).iterator().next();
351 validationVsp = new ItemCreationDto();
352 validationVsp.setItemId(validationVspId);
354 .setVersion(new MapVersionToDto().applyMapping(validationVspVersion, VersionDto.class));
356 return Response.ok(validationVsp).build();
361 public Response getOrchestrationTemplate(String vspId, String versionId, String user) {
362 MdcUtil.initMdc(LoggerServiceName.Get_Uploaded_File.toString());
363 byte[] orchestrationTemplateFile =
364 vendorSoftwareProductManager.getOrchestrationTemplateFile(vspId, new Version(versionId));
366 if (orchestrationTemplateFile == null) {
367 return Response.status(Response.Status.NOT_FOUND).build();
369 Response.ResponseBuilder response = Response.ok(orchestrationTemplateFile);
370 response.header("Content-Disposition", "attachment; filename=LatestHeatPackage.zip");
371 return response.build();
375 public Response listPackages(String category, String subCategory, String user) {
376 MdcUtil.initMdc(LoggerServiceName.List_Packages.toString());
377 List<PackageInfo> packageInfoList =
378 vendorSoftwareProductManager.listPackages(category, subCategory);
380 GenericCollectionWrapper<PackageInfoDto> results = new GenericCollectionWrapper<>();
381 MapPackageInfoToPackageInfoDto mapper = new MapPackageInfoToPackageInfoDto();
383 if (packageInfoList != null) {
384 for (PackageInfo packageInfo : packageInfoList) {
385 results.add(mapper.applyMapping(packageInfo, PackageInfoDto.class));
388 return Response.ok(results).build();
392 public Response getTranslatedFile(String vspId, String versionName, String user) {
393 MdcUtil.initMdc(LoggerServiceName.Get_Translated_File.toString());
395 List<Version> versions = versioningManager.list(vspId);
397 if (versionName == null) {
398 version = versions.stream().filter(ver -> VersionStatus.Certified == ver.getStatus())
399 .max((o1, o2) -> ((Double) Double.parseDouble(o1.getName()))
400 .compareTo(Double.parseDouble(o2.getName()))).orElseThrow(() -> {
401 MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
402 LoggerTragetServiceName.GET_TRANSLATED_FILE, ErrorLevel.ERROR.name(),
403 LoggerErrorCode.DATA_ERROR.getErrorCode(), "Package not found");
404 return new CoreException(new PackageNotFoundErrorBuilder(vspId).build());
407 version = versions.stream().filter(ver -> versionName.equals(ver.getName()))
408 .findFirst().orElseThrow(() -> {
409 MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
410 LoggerTragetServiceName.GET_TRANSLATED_FILE, ErrorLevel.ERROR.name(),
411 LoggerErrorCode.DATA_ERROR.getErrorCode(), "Package not found");
412 return new CoreException(new PackageNotFoundErrorBuilder(vspId).build());
415 if (version.getStatus() != VersionStatus.Certified) {
416 MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
417 LoggerTragetServiceName.GET_VERSION_INFO, ErrorLevel.ERROR.name(),
418 LoggerErrorCode.DATA_ERROR.getErrorCode(), "Invalid requested version");
419 throw new CoreException(new RequestedVersionInvalidErrorBuilder().build());
423 File zipFile = vendorSoftwareProductManager.getTranslatedFile(vspId, version);
425 Response.ResponseBuilder response = Response.ok(zipFile);
426 if (zipFile == null) {
427 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.IMPORT_FAIL + vspId);
428 return Response.status(Response.Status.NOT_FOUND).build();
430 response.header("Content-Disposition", "attachment; filename=" + zipFile.getName());
432 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.IMPORT_SUCCESS + vspId);
433 return response.build();
437 public Response getQuestionnaire(String vspId, String versionId, String user) {
438 MdcUtil.initMdc(LoggerServiceName.Get_Questionnaire_VSP.toString());
439 QuestionnaireResponse questionnaireResponse =
440 vendorSoftwareProductManager.getVspQuestionnaire(vspId, new Version(versionId));
442 if (questionnaireResponse.getErrorMessage() != null) {
443 return Response.status(Response.Status.EXPECTATION_FAILED).entity(
444 new MapQuestionnaireResponseToQuestionnaireResponseDto()
445 .applyMapping(questionnaireResponse, QuestionnaireResponseDto.class)).build();
448 QuestionnaireResponseDto result = new MapQuestionnaireResponseToQuestionnaireResponseDto()
449 .applyMapping(questionnaireResponse, QuestionnaireResponseDto.class);
450 return Response.ok(result).build();
454 public Response updateQuestionnaire(String questionnaireData, String vspId, String
455 versionId, String user) {
456 MdcUtil.initMdc(LoggerServiceName.Update_Questionnaire_VSP.toString());
457 vendorSoftwareProductManager
458 .updateVspQuestionnaire(vspId, new Version(versionId), questionnaireData);
459 return Response.ok().build();
463 public Response heal(String vspId, String versionId, String user) {
464 HealingManagerFactory.getInstance().createInterface()
465 .healItemVersion(vspId, new Version(versionId), ItemType.vsp, true);
466 return Response.ok().build();
470 public Response getVspInformationArtifact(String vspId, String versionId, String user) {
471 MdcUtil.initMdc(LoggerServiceName.Get_Information_Artifact.toString());
472 File textInformationArtifact =
473 vendorSoftwareProductManager.getInformationArtifact(vspId, new Version(versionId));
475 Response.ResponseBuilder response = Response.ok(textInformationArtifact);
476 if (textInformationArtifact == null) {
477 return Response.status(Response.Status.NOT_FOUND).build();
480 .header("Content-Disposition", "attachment; filename=" + textInformationArtifact.getName());
481 return response.build();
485 public Response listComputes(String vspId, String version, String user) {
487 Collection<ComputeEntity> computes =
488 vendorSoftwareProductManager.getComputeByVsp(vspId, new Version(version));
490 MapComputeEntityToVspComputeDto mapper = new MapComputeEntityToVspComputeDto();
491 GenericCollectionWrapper<VspComputeDto> results = new GenericCollectionWrapper<>();
492 for (ComputeEntity compute : computes) {
493 results.add(mapper.applyMapping(compute, VspComputeDto.class));
496 return Response.ok(results).build();
499 private Optional<ValidationResponse> submit(String vspId, Version version, String message,
500 String user) throws IOException {
501 MdcUtil.initMdc(LoggerServiceName.Submit_VSP.toString());
502 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.SUBMIT_VSP + vspId);
504 ValidationResponse validationResponse = vendorSoftwareProductManager.validate(vspId, version);
505 Map<String, List<ErrorMessage>> compilationErrors =
506 vendorSoftwareProductManager.compile(vspId, version);
507 if (!validationResponse.isValid() || MapUtils.isNotEmpty(compilationErrors)) {
508 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.SUBMIT_VSP_FAIL + vspId);
509 if (validationResponse.getVspErrors() != null) {
510 validationResponse.getVspErrors().forEach(errorCode -> LOGGER.audit(AuditMessages
511 .AUDIT_MSG + String.format(SUBMIT_VSP_ERROR, errorCode.message(), vspId)));
513 if (validationResponse.getUploadDataErrors() != null) {
514 validationResponse.getUploadDataErrors().values().forEach(errorMessages
515 -> printAuditForErrors(errorMessages, vspId, SUBMIT_VSP_ERROR));
517 activityLogManager.logActivity(
518 new ActivityLogEntity(vspId, version, ActivityType.Submit, user, false,
519 "Failed on validation before submit", ""));
520 return Optional.of(validationResponse);
523 versioningManager.submit(vspId, version, message);
525 LOGGER.audit(AuditMessages.AUDIT_MSG + AuditMessages.SUBMIT_VSP + vspId);
526 activityLogManager.logActivity(
527 new ActivityLogEntity(vspId, version, ActivityType.Submit, user, true, "", message));
528 return Optional.empty();
531 private void notifyUsers(String itemId, Version version, String message,
532 String userName, NotificationEventTypes eventType) {
533 Map<String, Object> eventProperties = new HashMap<>();
534 eventProperties.put(ITEM_NAME, itemManager.get(itemId).getName());
535 eventProperties.put(ITEM_ID, itemId);
537 Version ver = versioningManager.get(itemId, version);
538 eventProperties.put(VERSION_NAME, ver.getName());
539 eventProperties.put(VERSION_ID, ver.getId());
541 eventProperties.put(SUBMIT_DESCRIPTION, message);
542 eventProperties.put(PERMISSION_USER, userName);
544 Event syncEvent = new SyncEvent(eventType.getEventName(), itemId, eventProperties, itemId);
546 notifier.notifySubscribers(syncEvent, userName);
547 } catch (Exception e) {
548 LOGGER.error("Failed to send sync notification to users subscribed o item '" + itemId);
552 private class SyncEvent implements Event {
554 private String eventType;
555 private String originatorId;
556 private Map<String, Object> attributes;
557 private String entityId;
559 public SyncEvent(String eventType, String originatorId,
560 Map<String, Object> attributes, String entityId) {
561 this.eventType = eventType;
562 this.originatorId = originatorId;
563 this.attributes = attributes;
564 this.entityId = entityId;
568 public String getEventType() {
573 public String getOriginatorId() {
578 public Map<String, Object> getAttributes() {
583 public String getEntityId() {
588 private Response createPackage(String vspId, Version version) throws IOException {
589 MdcUtil.initMdc(LoggerServiceName.Create_Package.toString());
591 Version retrievedVersion = versioningManager.get(vspId, version);
592 if (retrievedVersion.getStatus() != VersionStatus.Certified) {
593 MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
594 LoggerTragetServiceName.CREATE_PACKAGE, ErrorLevel.ERROR.name(),
595 LoggerErrorCode.PERMISSION_ERROR.getErrorCode(), "Can't create package");
596 throw new CoreException(
597 new CreatePackageForNonFinalVendorSoftwareProductErrorBuilder(vspId, version)
600 PackageInfo packageInfo =
601 vendorSoftwareProductManager.createPackage(vspId, retrievedVersion);
602 return Response.ok(packageInfo == null
604 : new MapPackageInfoToPackageInfoDto().applyMapping(packageInfo, PackageInfoDto.class))
608 private void addNetworkPackageInfo(String vspId, Version version, VspDetailsDto vspDetailsDto) {
609 OrchestrationTemplateEntity orchestrationTemplateInfo =
610 vendorSoftwareProductManager.getOrchestrationTemplateInfo(vspId, version);
612 vspDetailsDto.setValidationData(orchestrationTemplateInfo.getValidationDataStructure());
613 vspDetailsDto.setNetworkPackageName(orchestrationTemplateInfo.getFileName());
614 vspDetailsDto.setOnboardingOrigin(orchestrationTemplateInfo.getFileSuffix() == null
615 ? OnboardingTypesEnum.NONE.toString()
616 : orchestrationTemplateInfo.getFileSuffix());
618 OrchestrationTemplateCandidateData candidateInfo =
619 OrchestrationTemplateCandidateManagerFactory.getInstance().createInterface()
620 .getInfo(vspId, version);
622 //todo - remove after fix missing candidate element
623 if(candidateInfo == null){
624 candidateInfo = new OrchestrationTemplateCandidateData();
625 candidateInfo.setFileSuffix("zip");
629 .setCandidateOnboardingOrigin( candidateInfo.getFileSuffix()
631 ? OnboardingTypesEnum.NONE.toString()
632 : candidateInfo.getFileSuffix());
635 private boolean userHasPermission(String itemId, String userId) {
636 String permission = permissionsManager.getUserItemPermiission(itemId, userId);
637 return (permission != null && permission
638 .matches(PermissionTypes.Contributor.name() + "|" + PermissionTypes.Owner.name()));
641 private void printAuditForErrors(List<ErrorMessage> errorList, String vspId, String auditType) {
642 errorList.forEach(errorMessage -> {
643 if (errorMessage.getLevel().equals(ErrorLevel.ERROR)) {
644 LOGGER.audit(AuditMessages.AUDIT_MSG + String.format(auditType, errorMessage.getMessage(),