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