catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/InterfaceLifecycleTypeImportManager.java

   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 java.util.ArrayList;
  24 import java.util.HashMap;
  25 import java.util.Iterator;
  26 import java.util.List;
  27 import java.util.Map;
  28
  29 import javax.annotation.Resource;
  30
  31 import org.openecomp.sdc.be.dao.api.ActionStatus;
  32 import org.openecomp.sdc.be.impl.ComponentsUtils;
  33 import org.openecomp.sdc.be.model.InterfaceDefinition;
  34 import org.openecomp.sdc.be.model.Operation;
  35 import org.openecomp.sdc.be.model.operations.api.IInterfaceLifecycleOperation;
  36 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
  37 import org.openecomp.sdc.exception.ResponseFormat;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40 import org.springframework.stereotype.Component;
  41
  42 import fj.data.Either;
  43
  44 @Component("interfaceLifecycleTypeImportManager")
  45 public class InterfaceLifecycleTypeImportManager {
  46
  47         @Resource
  48         private IInterfaceLifecycleOperation interfaceLifecycleOperation;
  49
  50         @Resource
  51         private ComponentsUtils componentsUtils;
  52         @Resource
  53         private CommonImportManager commonImportManager;
  54
  55         private static Logger log = LoggerFactory.getLogger(InterfaceLifecycleTypeImportManager.class.getName());
  56
  57         public Either<List<InterfaceDefinition>, ResponseFormat> createLifecycleTypes(String interfaceLifecycleTypesYml) {
  58
  59                 Either<List<InterfaceDefinition>, ActionStatus> interfaces = createLifecyclyTypeFromYml(interfaceLifecycleTypesYml);
  60                 if (interfaces.isRight()) {
  61                         ActionStatus status = interfaces.right().value();
  62                         ResponseFormat responseFormat = componentsUtils.getResponseFormatByGroupType(status, null);
  63                         return Either.right(responseFormat);
  64                 }
  65                 return createInterfacesByDao(interfaces.left().value());
  66
  67         }
  68
  69         private Either<List<InterfaceDefinition>, ActionStatus> createLifecyclyTypeFromYml(String interfaceLifecycleTypesYml) {
  70                 return commonImportManager.createElementTypesFromYml(interfaceLifecycleTypesYml, (lifecycleTypeName, lifecycleTypeJsonData) -> createLifecycleType(lifecycleTypeName, lifecycleTypeJsonData));
  71
  72         }
  73
  74         private Either<List<InterfaceDefinition>, ResponseFormat> createInterfacesByDao(List<InterfaceDefinition> interfacesToCreate) {
  75                 List<InterfaceDefinition> createdInterfaces = new ArrayList<>();
  76                 Either<List<InterfaceDefinition>, ResponseFormat> eitherResult = Either.left(createdInterfaces);
  77                 Iterator<InterfaceDefinition> interfaceItr = interfacesToCreate.iterator();
  78                 boolean stopDao = false;
  79                 while (interfaceItr.hasNext() && !stopDao) {
  80                         InterfaceDefinition interfaceDef = interfaceItr.next();
  81
  82                         log.info("send interfaceDefinition {} to dao for create", interfaceDef.getType());
  83
  84                         Either<InterfaceDefinition, StorageOperationStatus> dataModelResponse = interfaceLifecycleOperation.createInterfaceType(interfaceDef);
  85                         if (dataModelResponse.isRight()) {
  86                                 log.info("failed to create interface : {}  error: {}", interfaceDef.getType(), dataModelResponse.right().value().name());
  87                                 if (dataModelResponse.right().value() != StorageOperationStatus.SCHEMA_VIOLATION) {
  88                                         ResponseFormat responseFormat = componentsUtils.getResponseFormat(componentsUtils.convertFromStorageResponseForLifecycleType(dataModelResponse.right().value()), interfaceDef.getType());
  89                                         eitherResult = Either.right(responseFormat);
  90                                         stopDao = true;
  91                                 }
  92
  93                         } else {
  94                                 createdInterfaces.add(dataModelResponse.left().value());
  95                         }
  96                         if (!interfaceItr.hasNext()) {
  97                                 log.info("lifecycle types were created successfully!!!");
  98                         }
  99                 }
 100                 return eitherResult;
 101         }
 102
 103         private InterfaceDefinition createLifecycleType(String interfaceDefinition, Map<String, Object> toscaJson) {
 104                 InterfaceDefinition interfaceDef = new InterfaceDefinition();
 105                 interfaceDef.setType(interfaceDefinition);
 106
 107                 Map<String, Operation> operations = new HashMap<String, Operation>();
 108
 109                 for (Map.Entry<String, Object> entry : toscaJson.entrySet()) {
 110                         Operation operation = new Operation();
 111                         Map<String, Object> opProp = (Map<String, Object>) entry.getValue();
 112
 113                         operation.setDescription((String) opProp.get("description"));
 114                         operations.put(entry.getKey(), operation);
 115                 }
 116                 interfaceDef.setOperations(operations);
 117                 return interfaceDef;
 118         }
 119
 120         public static void setLog(Logger log) {
 121                 InterfaceLifecycleTypeImportManager.log = log;
 122         }
 123
 124 }