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 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 final Logger log = LoggerFactory.getLogger(InterfaceLifecycleTypeImportManager.class);
  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.setOperationsMap(operations);
 117         return interfaceDef;
 118     }
 119 }