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=========================================================
20 package org.openecomp.sdc.be.components.impl;
22 import java.util.ArrayList;
23 import java.util.Arrays;
24 import java.util.Collections;
25 import java.util.Iterator;
26 import java.util.List;
28 import java.util.Map.Entry;
29 import java.util.Optional;
30 import java.util.stream.Collectors;
32 import javax.annotation.Resource;
34 import org.apache.commons.collections.MapUtils;
35 import org.apache.commons.lang3.StringUtils;
36 import org.openecomp.sdc.be.dao.api.ActionStatus;
37 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
38 import org.openecomp.sdc.be.impl.ComponentsUtils;
39 import org.openecomp.sdc.be.model.InterfaceDefinition;
40 import org.openecomp.sdc.be.model.Model;
41 import org.openecomp.sdc.be.model.Operation;
42 import org.openecomp.sdc.be.model.operations.api.IInterfaceLifecycleOperation;
43 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
44 import org.openecomp.sdc.be.model.operations.impl.ModelOperation;
45 import org.openecomp.sdc.be.model.operations.impl.UniqueIdBuilder;
46 import org.openecomp.sdc.be.utils.TypeUtils.ToscaTagNamesEnum;
47 import org.openecomp.sdc.common.log.wrappers.Logger;
48 import org.openecomp.sdc.exception.ResponseFormat;
49 import org.springframework.stereotype.Component;
51 import fj.data.Either;
53 @Component("interfaceLifecycleTypeImportManager")
54 public class InterfaceLifecycleTypeImportManager {
56 private static final Logger log = Logger.getLogger(InterfaceLifecycleTypeImportManager.class);
58 private IInterfaceLifecycleOperation interfaceLifecycleOperation;
60 private ComponentsUtils componentsUtils;
62 private CommonImportManager commonImportManager;
64 private ModelOperation modelOperation;
66 public Either<List<InterfaceDefinition>, ResponseFormat> createLifecycleTypes(String interfaceLifecycleTypesYml, final String modelName) {
67 Either<List<InterfaceDefinition>, ActionStatus> interfaces = createInterfaceTypeFromYml(interfaceLifecycleTypesYml, modelName);
68 if (interfaces.isRight()) {
69 ActionStatus status = interfaces.right().value();
70 ResponseFormat responseFormat = componentsUtils.getResponseFormatByGroupType(status, null);
71 return Either.right(responseFormat);
73 return createInterfacesByDao(interfaces.left().value());
76 private Either<List<InterfaceDefinition>, ActionStatus> createInterfaceTypeFromYml(final String interfaceTypesYml, final String modelName) {
77 final Either<List<InterfaceDefinition>, ActionStatus> interfaceTypes = commonImportManager.createElementTypesFromYml(interfaceTypesYml, this::createInterfaceDefinition);
78 if (interfaceTypes.isLeft() && StringUtils.isNotEmpty(modelName)){
79 final Optional<Model> modelOptional = modelOperation.findModelByName(modelName);
80 if (modelOptional.isPresent()) {
81 interfaceTypes.left().value().forEach(interfaceType -> interfaceType.setModel(modelName));
82 return interfaceTypes;
84 return Either.right(ActionStatus.INVALID_MODEL);
86 return interfaceTypes;
89 private Either<List<InterfaceDefinition>, ResponseFormat> createInterfacesByDao(List<InterfaceDefinition> interfacesToCreate) {
90 List<InterfaceDefinition> createdInterfaces = new ArrayList<>();
91 Either<List<InterfaceDefinition>, ResponseFormat> eitherResult = Either.left(createdInterfaces);
92 Iterator<InterfaceDefinition> interfaceItr = interfacesToCreate.iterator();
93 boolean stopDao = false;
94 while (interfaceItr.hasNext() && !stopDao) {
95 InterfaceDefinition interfaceDef = interfaceItr.next();
96 log.info("send interfaceDefinition {} to dao for create", interfaceDef.getType());
97 Either<InterfaceDefinition, StorageOperationStatus> dataModelResponse = interfaceLifecycleOperation.createInterfaceType(interfaceDef);
98 if (dataModelResponse.isRight()) {
99 log.info("failed to create interface : {} error: {}", interfaceDef.getType(), dataModelResponse.right().value().name());
100 if (dataModelResponse.right().value() != StorageOperationStatus.SCHEMA_VIOLATION) {
101 ResponseFormat responseFormat = componentsUtils
102 .getResponseFormat(componentsUtils.convertFromStorageResponseForLifecycleType(dataModelResponse.right().value()),
103 interfaceDef.getType());
104 eitherResult = Either.right(responseFormat);
108 createdInterfaces.add(dataModelResponse.left().value());
110 if (!interfaceItr.hasNext()) {
111 log.info("lifecycle types were created successfully!!!");
117 private InterfaceDefinition createInterfaceDefinition(final String interfaceDefinition, final Map<String, Object> toscaJson) {
118 final InterfaceDefinition interfaceDef = new InterfaceDefinition();
119 interfaceDef.setType(interfaceDefinition);
120 final Object descriptionObj = toscaJson.get(ToscaTagNamesEnum.DESCRIPTION.getElementName());
121 if (descriptionObj instanceof String) {
122 interfaceDef.setDescription((String) descriptionObj);
124 final Object derivedFromObj = toscaJson.get(ToscaTagNamesEnum.DERIVED_FROM.getElementName());
125 if (derivedFromObj instanceof String) {
126 interfaceDef.setDerivedFrom((String) derivedFromObj);
128 final Object versionObj = toscaJson.get(ToscaTagNamesEnum.VERSION.getElementName());
129 if (versionObj instanceof String) {
130 interfaceDef.setVersion((String) versionObj);
132 final Object metadataObj = toscaJson.get(ToscaTagNamesEnum.METADATA.getElementName());
133 if (metadataObj instanceof Map) {
134 interfaceDef.setToscaPresentationValue(JsonPresentationFields.METADATA, metadataObj);
136 final Map<String, Object> operationsMap;
137 if (toscaJson.containsKey(ToscaTagNamesEnum.OPERATIONS.getElementName())) {
138 operationsMap = (Map<String, Object>) toscaJson.get(ToscaTagNamesEnum.OPERATIONS.getElementName());
140 final List<String> entitySchemaEntryList = Arrays
141 .asList(ToscaTagNamesEnum.DERIVED_FROM.getElementName(), ToscaTagNamesEnum.DESCRIPTION.getElementName(),
142 ToscaTagNamesEnum.VERSION.getElementName(), ToscaTagNamesEnum.METADATA.getElementName(),
143 ToscaTagNamesEnum.INPUTS.getElementName(), ToscaTagNamesEnum.NOTIFICATIONS.getElementName());
144 operationsMap = toscaJson.entrySet().stream().filter(interfaceEntry -> !entitySchemaEntryList.contains(interfaceEntry.getKey()))
145 .collect(Collectors.toMap(Entry::getKey, Entry::getValue));
147 interfaceDef.setOperationsMap(handleOperations(operationsMap));
151 private Map<String, Operation> handleOperations(final Map<String, Object> operationsToscaEntry) {
152 if (MapUtils.isEmpty(operationsToscaEntry)) {
153 return Collections.emptyMap();
155 return operationsToscaEntry.entrySet().stream()
156 .collect(Collectors.toMap(Entry::getKey, operationEntry -> createOperation((Map<String, Object>) operationEntry.getValue())));
159 private Operation createOperation(final Map<String, Object> toscaOperationMap) {
160 final Operation operation = new Operation();
161 operation.setDescription((String) toscaOperationMap.get(ToscaTagNamesEnum.DESCRIPTION.getElementName()));