gerrit.onap Code Review - sdc.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.openecomp.sdc.be.components.impl;
  22
  23 import fj.data.Either;
  24 import java.util.ArrayList;
  25 import java.util.Arrays;
  26 import java.util.Collections;
  27 import java.util.Iterator;
  28 import java.util.List;
  29 import java.util.Map;
  30 import java.util.Map.Entry;
  31 import java.util.stream.Collectors;
  32 import javax.annotation.Resource;
  33 import org.apache.commons.collections.MapUtils;
  34 import org.openecomp.sdc.be.dao.api.ActionStatus;
  35 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
  36 import org.openecomp.sdc.be.impl.ComponentsUtils;
  37 import org.openecomp.sdc.be.model.InterfaceDefinition;
  38 import org.openecomp.sdc.be.model.Operation;
  39 import org.openecomp.sdc.be.model.operations.api.IInterfaceLifecycleOperation;
  40 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  41 import org.openecomp.sdc.be.utils.TypeUtils.ToscaTagNamesEnum;
  42 import org.openecomp.sdc.common.log.wrappers.Logger;
  43 import org.openecomp.sdc.exception.ResponseFormat;
  44 import org.springframework.stereotype.Component;
  45
  46 @Component("interfaceLifecycleTypeImportManager")
  47 public class InterfaceLifecycleTypeImportManager {
  48
  49     @Resource
  50     private IInterfaceLifecycleOperation interfaceLifecycleOperation;
  51
  52     @Resource
  53     private ComponentsUtils componentsUtils;
  54     @Resource
  55     private CommonImportManager commonImportManager;
  56
  57     private static final Logger log = Logger.getLogger(InterfaceLifecycleTypeImportManager.class);
  58
  59     public Either<List<InterfaceDefinition>, ResponseFormat> createLifecycleTypes(String interfaceLifecycleTypesYml) {
  60
  61         Either<List<InterfaceDefinition>, ActionStatus> interfaces = createInterfaceTypeFromYml(interfaceLifecycleTypesYml);
  62         if (interfaces.isRight()) {
  63             ActionStatus status = interfaces.right().value();
  64             ResponseFormat responseFormat = componentsUtils.getResponseFormatByGroupType(status, null);
  65             return Either.right(responseFormat);
  66         }
  67         return createInterfacesByDao(interfaces.left().value());
  68
  69     }
  70
  71     private Either<List<InterfaceDefinition>, ActionStatus> createInterfaceTypeFromYml(final String interfaceTypesYml) {
  72         return commonImportManager.createElementTypesFromYml(interfaceTypesYml, this::createInterfaceDefinition);
  73
  74     }
  75
  76     private Either<List<InterfaceDefinition>, ResponseFormat> createInterfacesByDao(List<InterfaceDefinition> interfacesToCreate) {
  77         List<InterfaceDefinition> createdInterfaces = new ArrayList<>();
  78         Either<List<InterfaceDefinition>, ResponseFormat> eitherResult = Either.left(createdInterfaces);
  79         Iterator<InterfaceDefinition> interfaceItr = interfacesToCreate.iterator();
  80         boolean stopDao = false;
  81         while (interfaceItr.hasNext() && !stopDao) {
  82             InterfaceDefinition interfaceDef = interfaceItr.next();
  83
  84             log.info("send interfaceDefinition {} to dao for create", interfaceDef.getType());
  85
  86             Either<InterfaceDefinition, StorageOperationStatus> dataModelResponse = interfaceLifecycleOperation.createInterfaceType(interfaceDef);
  87             if (dataModelResponse.isRight()) {
  88                 log.info("failed to create interface : {}  error: {}", interfaceDef.getType(), dataModelResponse.right().value().name());
  89                 if (dataModelResponse.right().value() != StorageOperationStatus.SCHEMA_VIOLATION) {
  90                     ResponseFormat responseFormat = componentsUtils.getResponseFormat(componentsUtils.convertFromStorageResponseForLifecycleType(dataModelResponse.right().value()), interfaceDef.getType());
  91                     eitherResult = Either.right(responseFormat);
  92                     stopDao = true;
  93                 }
  94
  95             } else {
  96                 createdInterfaces.add(dataModelResponse.left().value());
  97             }
  98             if (!interfaceItr.hasNext()) {
  99                 log.info("lifecycle types were created successfully!!!");
 100             }
 101         }
 102         return eitherResult;
 103     }
 104
 105     private InterfaceDefinition createInterfaceDefinition(final String interfaceDefinition,
 106                                                           final Map<String, Object> toscaJson) {
 107         final InterfaceDefinition interfaceDef = new InterfaceDefinition();
 108         interfaceDef.setType(interfaceDefinition);
 109         final Object descriptionObj = toscaJson.get(ToscaTagNamesEnum.DESCRIPTION.getElementName());
 110         if (descriptionObj instanceof String) {
 111             interfaceDef.setDescription((String) descriptionObj);
 112         }
 113         final Object derivedFromObj = toscaJson.get(ToscaTagNamesEnum.DERIVED_FROM.getElementName());
 114         if (derivedFromObj instanceof String) {
 115             interfaceDef.setDerivedFrom((String) derivedFromObj);
 116         }
 117         final Object versionObj = toscaJson.get(ToscaTagNamesEnum.VERSION.getElementName());
 118         if (versionObj instanceof String) {
 119             interfaceDef.setVersion((String) versionObj);
 120         }
 121
 122         final Object metadataObj = toscaJson.get(ToscaTagNamesEnum.METADATA.getElementName());
 123         if (metadataObj instanceof Map) {
 124             interfaceDef.setToscaPresentationValue(JsonPresentationFields.METADATA, metadataObj);
 125         }
 126
 127         final Map<String, Object> operationsMap;
 128         if (toscaJson.containsKey(ToscaTagNamesEnum.OPERATIONS.getElementName())) {
 129             operationsMap = (Map<String, Object>) toscaJson.get(ToscaTagNamesEnum.OPERATIONS.getElementName());
 130         } else {
 131             final List<String> entitySchemaEntryList = Arrays
 132                 .asList(ToscaTagNamesEnum.DERIVED_FROM.getElementName(),
 133                     ToscaTagNamesEnum.DESCRIPTION.getElementName(),
 134                     ToscaTagNamesEnum.VERSION.getElementName(),
 135                     ToscaTagNamesEnum.METADATA.getElementName(),
 136                     ToscaTagNamesEnum.INPUTS.getElementName(),
 137                     ToscaTagNamesEnum.NOTIFICATIONS.getElementName());
 138             operationsMap = toscaJson.entrySet().stream()
 139                 .filter(interfaceEntry -> !entitySchemaEntryList.contains(interfaceEntry.getKey()))
 140                 .collect(Collectors.toMap(Entry::getKey, Entry::getValue));
 141         }
 142         interfaceDef.setOperationsMap(handleOperations(operationsMap));
 143         return interfaceDef;
 144     }
 145
 146     private Map<String, Operation> handleOperations(final Map<String, Object> operationsToscaEntry) {
 147         if (MapUtils.isEmpty(operationsToscaEntry)) {
 148             return Collections.emptyMap();
 149         }
 150         return operationsToscaEntry.entrySet().stream()
 151             .collect(Collectors.toMap(Entry::getKey,
 152                 operationEntry -> createOperation((Map<String, Object>) operationEntry.getValue())));
 153     }
 154
 155     private Operation createOperation(final Map<String, Object> toscaOperationMap) {
 156         final Operation operation = new Operation();
 157         operation.setDescription((String) toscaOperationMap.get(ToscaTagNamesEnum.DESCRIPTION.getElementName()));
 158         return operation;
 159     }
 160 }