catalog-model/src/main/java/org/openecomp/sdc/be/model/jsonjanusgraph/operations/NodeTemplateOperation.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 package org.openecomp.sdc.be.model.jsonjanusgraph.operations;
  21
  22 import fj.data.Either;
  23 import java.io.IOException;
  24 import java.util.ArrayList;
  25 import java.util.Arrays;
  26 import java.util.EnumMap;
  27 import java.util.HashMap;
  28 import java.util.HashSet;
  29 import java.util.Iterator;
  30 import java.util.List;
  31 import java.util.Map;
  32 import java.util.Map.Entry;
  33 import java.util.Optional;
  34 import java.util.Set;
  35 import java.util.UUID;
  36 import java.util.function.BiPredicate;
  37 import java.util.stream.Collectors;
  38 import org.apache.commons.collections.CollectionUtils;
  39 import org.apache.commons.collections.MapUtils;
  40 import org.apache.commons.lang3.StringUtils;
  41 import org.apache.commons.lang3.tuple.ImmutablePair;
  42 import org.apache.commons.lang3.tuple.Pair;
  43 import org.apache.tinkerpop.gremlin.structure.Direction;
  44 import org.apache.tinkerpop.gremlin.structure.Edge;
  45 import org.janusgraph.core.JanusGraphVertex;
  46 import org.openecomp.sdc.be.config.BeEcompErrorManager;
  47 import org.openecomp.sdc.be.config.ConfigurationManager;
  48 import org.openecomp.sdc.be.dao.api.ActionStatus;
  49 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
  50 import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
  51 import org.openecomp.sdc.be.dao.jsongraph.types.EdgeLabelEnum;
  52 import org.openecomp.sdc.be.dao.jsongraph.types.EdgePropertyEnum;
  53 import org.openecomp.sdc.be.dao.jsongraph.types.JsonParseFlagEnum;
  54 import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
  55 import org.openecomp.sdc.be.dao.jsongraph.utils.JsonParserUtils;
  56 import org.openecomp.sdc.be.datatypes.elements.ArtifactDataDefinition;
  57 import org.openecomp.sdc.be.datatypes.elements.CapabilityDataDefinition;
  58 import org.openecomp.sdc.be.datatypes.elements.ComponentInstanceDataDefinition;
  59 import org.openecomp.sdc.be.datatypes.elements.CompositionDataDefinition;
  60 import org.openecomp.sdc.be.datatypes.elements.GroupDataDefinition;
  61 import org.openecomp.sdc.be.datatypes.elements.GroupInstanceDataDefinition;
  62 import org.openecomp.sdc.be.datatypes.elements.InterfaceDataDefinition;
  63 import org.openecomp.sdc.be.datatypes.elements.ListCapabilityDataDefinition;
  64 import org.openecomp.sdc.be.datatypes.elements.ListDataDefinition;
  65 import org.openecomp.sdc.be.datatypes.elements.ListRequirementDataDefinition;
  66 import org.openecomp.sdc.be.datatypes.elements.MapArtifactDataDefinition;
  67 import org.openecomp.sdc.be.datatypes.elements.MapAttributesDataDefinition;
  68 import org.openecomp.sdc.be.datatypes.elements.MapCapabilityProperty;
  69 import org.openecomp.sdc.be.datatypes.elements.MapDataDefinition;
  70 import org.openecomp.sdc.be.datatypes.elements.MapGroupsDataDefinition;
  71 import org.openecomp.sdc.be.datatypes.elements.MapInterfaceDataDefinition;
  72 import org.openecomp.sdc.be.datatypes.elements.MapListCapabilityDataDefinition;
  73 import org.openecomp.sdc.be.datatypes.elements.MapListRequirementDataDefinition;
  74 import org.openecomp.sdc.be.datatypes.elements.MapPropertiesDataDefinition;
  75 import org.openecomp.sdc.be.datatypes.elements.OperationDataDefinition;
  76 import org.openecomp.sdc.be.datatypes.elements.OperationInputDefinition;
  77 import org.openecomp.sdc.be.datatypes.elements.PropertyDataDefinition;
  78 import org.openecomp.sdc.be.datatypes.elements.RelationshipInstDataDefinition;
  79 import org.openecomp.sdc.be.datatypes.elements.RequirementDataDefinition;
  80 import org.openecomp.sdc.be.datatypes.enums.GraphPropertyEnum;
  81 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
  82 import org.openecomp.sdc.be.datatypes.enums.OriginTypeEnum;
  83 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
  84 import org.openecomp.sdc.be.datatypes.tosca.ToscaDataDefinition;
  85 import org.openecomp.sdc.be.model.ArtifactDefinition;
  86 import org.openecomp.sdc.be.model.CapabilityDefinition;
  87 import org.openecomp.sdc.be.model.CapabilityRequirementRelationship;
  88 import org.openecomp.sdc.be.model.Component;
  89 import org.openecomp.sdc.be.model.ComponentInstance;
  90 import org.openecomp.sdc.be.model.ComponentInstanceAttribute;
  91 import org.openecomp.sdc.be.model.ComponentInstanceInput;
  92 import org.openecomp.sdc.be.model.ComponentInstanceOutput;
  93 import org.openecomp.sdc.be.model.ComponentInstanceProperty;
  94 import org.openecomp.sdc.be.model.ComponentParametersView;
  95 import org.openecomp.sdc.be.model.GroupDefinition;
  96 import org.openecomp.sdc.be.model.GroupInstance;
  97 import org.openecomp.sdc.be.model.InputDefinition;
  98 import org.openecomp.sdc.be.model.PropertyDefinition;
  99 import org.openecomp.sdc.be.model.RelationshipImpl;
 100 import org.openecomp.sdc.be.model.RelationshipInfo;
 101 import org.openecomp.sdc.be.model.RequirementCapabilityRelDef;
 102 import org.openecomp.sdc.be.model.RequirementDefinition;
 103 import org.openecomp.sdc.be.model.User;
 104 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.NodeType;
 105 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.TopologyTemplate;
 106 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.ToscaElement;
 107 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.ToscaElementTypeEnum;
 108 import org.openecomp.sdc.be.model.jsonjanusgraph.enums.JsonConstantKeysEnum;
 109 import org.openecomp.sdc.be.model.jsonjanusgraph.operations.exception.OperationException;
 110 import org.openecomp.sdc.be.model.jsonjanusgraph.utils.ModelConverter;
 111 import org.openecomp.sdc.be.model.operations.StorageException;
 112 import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus;
 113 import org.openecomp.sdc.be.model.operations.impl.DaoStatusConverter;
 114 import org.openecomp.sdc.be.model.operations.impl.UniqueIdBuilder;
 115 import org.openecomp.sdc.be.ui.model.OperationUi;
 116 import org.openecomp.sdc.common.api.ArtifactGroupTypeEnum;
 117 import org.openecomp.sdc.common.api.ArtifactTypeEnum;
 118 import org.openecomp.sdc.common.jsongraph.util.CommonUtility;
 119 import org.openecomp.sdc.common.jsongraph.util.CommonUtility.LogLevelEnum;
 120 import org.openecomp.sdc.common.log.elements.ErrorLogOptionalData;
 121 import org.openecomp.sdc.common.log.elements.LoggerSupportability;
 122 import org.openecomp.sdc.common.log.enums.EcompLoggerErrorCode;
 123 import org.openecomp.sdc.common.log.enums.LogLevel;
 124 import org.openecomp.sdc.common.log.enums.LoggerSupportabilityActions;
 125 import org.openecomp.sdc.common.log.enums.StatusCode;
 126 import org.openecomp.sdc.common.log.wrappers.Logger;
 127 import org.openecomp.sdc.common.util.ValidationUtils;
 128
 129 @org.springframework.stereotype.Component("node-template-operation")
 130 public class NodeTemplateOperation extends BaseOperation {
 131
 132     public static final Integer NON_HEAT_TIMEOUT = 0;
 133     static final String HEAT_ENV_NAME = "heatEnv";
 134     static final String HEAT_VF_ENV_NAME = "VfHeatEnv";
 135     static final String HEAT_ENV_SUFFIX = "env";
 136     private static final String FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR = "Failed to fetch container vertex {} error {}";
 137     private static final String FAILED_TO_UPDATE_TOPOLOGY_TEMPLATE_WITH_NEW_COMPONENT_INSTANCE = "Failed to update topology template {} with new component instance {}. ";
 138     private static final String ARTIFACT_PLACEHOLDER_TYPE = "type";
 139     private static final String ARTIFACT_PLACEHOLDER_DISPLAY_NAME = "displayName";
 140     private static final Object ARTIFACT_PLACEHOLDER_DESCRIPTION = "description";
 141     private static final Logger log = Logger.getLogger(NodeTemplateOperation.class.getName());
 142     private static final LoggerSupportability loggerSupportability = LoggerSupportability.getLogger(NodeTemplateOperation.class.getName());
 143     private static Integer defaultHeatTimeout;
 144
 145     public NodeTemplateOperation() {
 146         defaultHeatTimeout = ConfigurationManager.getConfigurationManager().getConfiguration().getHeatArtifactDeploymentTimeout().getDefaultMinutes();
 147         if ((defaultHeatTimeout == null) || (defaultHeatTimeout < 1)) {
 148             defaultHeatTimeout = 60;
 149         }
 150     }
 151
 152     public static Integer getDefaultHeatTimeout() {
 153         return defaultHeatTimeout;
 154     }
 155
 156     public static String createCapPropertyKey(String key, String instanceId) {
 157         StringBuffer sb = new StringBuffer(instanceId);
 158         sb.append(ModelConverter.CAP_PROP_DELIM).append(instanceId).append(ModelConverter.CAP_PROP_DELIM).append(key);
 159         return sb.toString();
 160     }
 161
 162     Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> addComponentInstanceToTopologyTemplate(TopologyTemplate container,
 163                                                                                                                    ToscaElement originToscaElement,
 164                                                                                                                    String instanceNumberSuffix,
 165                                                                                                                    ComponentInstance componentInstance,
 166                                                                                                                    boolean allowDeleted, User user) {
 167         Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> result = null;
 168         Either<TopologyTemplate, StorageOperationStatus> addComponentInstanceRes = null;
 169         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Going to create component instance {} in component {}", componentInstance,
 170             container.getUniqueId());
 171         ComponentInstanceDataDefinition componentInstanceData = null;
 172         Either<String, StorageOperationStatus> newInstanceNameRes = null;
 173         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao
 174             .getVertexById(container.getUniqueId(), JsonParseFlagEnum.ParseJson);
 175         if (metadataVertex.isRight()) {
 176             JanusGraphOperationStatus status = metadataVertex.right().value();
 177             if (status == JanusGraphOperationStatus.NOT_FOUND) {
 178                 status = JanusGraphOperationStatus.INVALID_ID;
 179             }
 180             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status));
 181         }
 182         if (result == null) {
 183             newInstanceNameRes = buildValidateInstanceName(container, originToscaElement, componentInstance, instanceNumberSuffix);
 184             if (newInstanceNameRes.isRight()) {
 185                 result = Either.right(newInstanceNameRes.right().value());
 186             }
 187         }
 188         if (result == null) {
 189             componentInstanceData = buildComponentInstanceDataDefinition(componentInstance, container.getUniqueId(),
 190                 newInstanceNameRes.left().value(), true, originToscaElement);
 191             addComponentInstanceRes = addComponentInstanceToTopologyTemplate(container, originToscaElement, componentInstanceData,
 192                 metadataVertex.left().value(), allowDeleted, user);
 193             if (addComponentInstanceRes.isRight()) {
 194                 StorageOperationStatus status = addComponentInstanceRes.right().value();
 195                 if (status == StorageOperationStatus.NOT_FOUND) {
 196                     status = StorageOperationStatus.INVALID_ID;
 197                 }
 198                 result = Either.right(status);
 199             }
 200             final TopologyTemplate updatedContainer = addComponentInstanceRes.left().value();
 201             if (componentInstance.getOriginType() == OriginTypeEnum.ServiceProxy
 202                 || componentInstance.getOriginType() == OriginTypeEnum.ServiceSubstitution) {
 203                 result = addCapAndReqToProxyServiceInstance(updatedContainer, componentInstance, componentInstanceData);
 204                 if (result.isRight()) {
 205                     return result;
 206                 }
 207                 result = addServiceInstancePropertiesToProxyServiceInstance(updatedContainer, componentInstance);
 208                 if (result.isRight()) {
 209                     return result;
 210                 }
 211                 result = addServiceInstanceInputsToProxyServiceInstance(updatedContainer, componentInstance);
 212                 if (result.isRight()) {
 213                     return result;
 214                 }
 215             }
 216             if (componentInstance.getOriginType() == OriginTypeEnum.ServiceProxy
 217                 || componentInstance.getOriginType() == OriginTypeEnum.ServiceSubstitution || componentInstance.getOriginType() == OriginTypeEnum.VF
 218                 || componentInstance.getOriginType() == OriginTypeEnum.VFC) {
 219                 result = addComponentInstanceInterfacesToTopologyTemplate(updatedContainer, componentInstance);
 220                 if (result.isRight()) {
 221                     return result;
 222                 }
 223             }
 224         }
 225         if (result == null) {
 226             result = Either.left(new ImmutablePair<>(addComponentInstanceRes.left().value(), componentInstanceData.getUniqueId()));
 227         }
 228         return result;
 229     }
 230
 231     private Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> addCapAndReqToProxyServiceInstance(
 232         TopologyTemplate updatedContainer, ComponentInstance componentInstance, ComponentInstanceDataDefinition componentInstanceData) {
 233         Map<String, MapListCapabilityDataDefinition> calcCap = updatedContainer.getCalculatedCapabilities();
 234         Map<String, MapListRequirementDataDefinition> calcReg = updatedContainer.getCalculatedRequirements();
 235         Map<String, MapCapabilityProperty> calcCapProp = updatedContainer.getCalculatedCapabilitiesProperties();
 236         Map<String, List<CapabilityDefinition>> additionalCap = componentInstance.getCapabilities();
 237         Map<String, List<RequirementDefinition>> additionalReq = componentInstance.getRequirements();
 238         MapListCapabilityDataDefinition allCalculatedCap =
 239             calcCap == null || !calcCap.containsKey(componentInstanceData.getUniqueId()) ? new MapListCapabilityDataDefinition()
 240                 : calcCap.get(componentInstanceData.getUniqueId());
 241         /******** capability ****************************/
 242         StorageOperationStatus status = deleteToscaDataDeepElementsBlockOfToscaElement(updatedContainer.getUniqueId(),
 243             EdgeLabelEnum.CALCULATED_CAPABILITIES, VertexTypeEnum.CALCULATED_CAPABILITIES, componentInstanceData.getUniqueId());
 244         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 245             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove calculated capabilty  for instance {} in container {}. error {] ",
 246                 componentInstanceData.getUniqueId(), updatedContainer.getUniqueId(), status);
 247             return Either.right(status);
 248         }
 249
 250         if (additionalCap != null && !additionalCap.isEmpty()) {
 251
 252             Map<String, ListCapabilityDataDefinition> serverCap = additionalCap.entrySet().stream()
 253                 .collect(Collectors.toMap(Map.Entry::getKey,
 254                     en -> new ListCapabilityDataDefinition(en.getValue().stream().map(CapabilityDataDefinition::new).collect(Collectors.toList()))));
 255
 256             serverCap.entrySet().forEach(entryPerType -> entryPerType.getValue().getListToscaDataDefinition().forEach(cap -> {
 257                 cap.addToPath(componentInstance.getUniqueId());
 258                 allCalculatedCap.add(entryPerType.getKey(), cap);
 259             }));
 260
 261             addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(), EdgeLabelEnum.CALCULATED_CAPABILITIES,
 262                 VertexTypeEnum.CALCULATED_CAPABILITIES, allCalculatedCap, componentInstance.getUniqueId());
 263
 264             /******** capability property ****************************/
 265             status = deleteToscaDataDeepElementsBlockOfToscaElement(updatedContainer.getUniqueId(), EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
 266                 VertexTypeEnum.CALCULATED_CAP_PROPERTIES, componentInstanceData.getUniqueId());
 267             if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 268                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
 269                     "Failed to remove calculated capabilty properties for instance {} in container {}. error {] ",
 270                     componentInstanceData.getUniqueId(), updatedContainer.getUniqueId(), status);
 271                 return Either.right(status);
 272             }
 273             MapCapabilityProperty allCalculatedCapProp =
 274                 calcCapProp == null || !calcCapProp.containsKey(componentInstanceData.getUniqueId()) ? new MapCapabilityProperty()
 275                     : calcCapProp.get(componentInstanceData.getUniqueId());
 276             additionalCap.forEach((s, caps) -> {
 277                 if (caps != null && !caps.isEmpty()) {
 278                     MapPropertiesDataDefinition dataToCreate;
 279                     for (CapabilityDefinition cap : caps) {
 280                         dataToCreate = new MapPropertiesDataDefinition();
 281                         List<ComponentInstanceProperty> capPrps = cap.getProperties();
 282                         if (capPrps != null) {
 283                             for (ComponentInstanceProperty cip : capPrps) {
 284                                 dataToCreate.put(cip.getName(), new PropertyDataDefinition(cip));
 285                             }
 286                             StringBuilder sb = new StringBuilder(componentInstance.getUniqueId());
 287                             sb.append(ModelConverter.CAP_PROP_DELIM);
 288                             sb.append(cap.getOwnerId());
 289                             sb.append(ModelConverter.CAP_PROP_DELIM).append(s).append(ModelConverter.CAP_PROP_DELIM).append(cap.getName());
 290                             allCalculatedCapProp.put(sb.toString(), dataToCreate);
 291                         }
 292                     }
 293                 }
 294             });
 295             addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(), EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
 296                 VertexTypeEnum.CALCULATED_CAP_PROPERTIES, allCalculatedCapProp, componentInstance.getUniqueId());
 297         }
 298         /******** Requirements property ****************************/
 299         if (additionalReq != null && !additionalReq.isEmpty()) {
 300
 301             MapListRequirementDataDefinition allCalculatedReq =
 302                 calcReg == null || !calcReg.containsKey(componentInstanceData.getUniqueId()) ? new MapListRequirementDataDefinition()
 303                     : calcReg.get(componentInstanceData.getUniqueId());
 304             status = deleteToscaDataDeepElementsBlockOfToscaElement(updatedContainer.getUniqueId(), EdgeLabelEnum.CALCULATED_REQUIREMENTS,
 305                 VertexTypeEnum.CALCULATED_REQUIREMENTS, componentInstanceData.getUniqueId());
 306             if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 307                 CommonUtility
 308                     .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove calculated Requirements for instance {} in container {}. error {] ",
 309                         componentInstanceData.getUniqueId(), updatedContainer.getUniqueId(), status);
 310                 return Either.right(status);
 311             }
 312
 313             Map<String, ListRequirementDataDefinition> serverReq = additionalReq.entrySet().stream()
 314                 .collect(Collectors.toMap(Map.Entry::getKey, en -> new ListRequirementDataDefinition(
 315                     en.getValue().stream().map(RequirementDataDefinition::new).collect(Collectors.toList()))));
 316
 317             serverReq.entrySet().forEach(entryPerType -> entryPerType.getValue().getListToscaDataDefinition().forEach(cap -> {
 318                 cap.addToPath(componentInstance.getUniqueId());
 319                 allCalculatedReq.add(entryPerType.getKey(), cap);
 320             }));
 321
 322             addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(), EdgeLabelEnum.CALCULATED_REQUIREMENTS,
 323                 VertexTypeEnum.CALCULATED_REQUIREMENTS, allCalculatedReq, componentInstance.getUniqueId());
 324
 325         }
 326
 327         Either<ToscaElement, StorageOperationStatus> updatedComponentInstanceRes = topologyTemplateOperation
 328             .getToscaElement(updatedContainer.getUniqueId());
 329         if (updatedComponentInstanceRes.isRight()) {
 330             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch updated topology template {} with new component instance {}. ",
 331                 updatedContainer.getName(), componentInstance.getName());
 332             Either.right(updatedComponentInstanceRes.right().value());
 333         }
 334         return Either.left(new ImmutablePair<>((TopologyTemplate) updatedComponentInstanceRes.left().value(), componentInstanceData.getUniqueId()));
 335     }
 336
 337     private Either<String, StorageOperationStatus> buildValidateInstanceName(TopologyTemplate container, ToscaElement originToscaElement,
 338                                                                              ComponentInstance componentInstance, String instanceNumberSuffix) {
 339
 340         Either<String, StorageOperationStatus> result = null;
 341         String instanceName = componentInstance.getName();
 342         if (StringUtils.isEmpty(instanceName) || instanceName.equalsIgnoreCase(originToscaElement.getName())
 343             || componentInstance.getOriginType() == OriginTypeEnum.ServiceProxy
 344             || componentInstance.getOriginType() == OriginTypeEnum.ServiceSubstitution) {
 345             instanceName = buildComponentInstanceName(instanceNumberSuffix, instanceName);
 346         } else if (!isUniqueInstanceName(container, componentInstance.getName())) {
 347             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
 348                 "Failed to create component instance with name {} on component container {}. The instance with the same name already exists. ",
 349                 componentInstance.getName(), container.getName());
 350             result = Either.right(StorageOperationStatus.ENTITY_ALREADY_EXISTS);
 351         }
 352         if (result == null) {
 353             result = Either.left(instanceName);
 354         }
 355         return result;
 356     }
 357
 358     private Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> addServiceInstancePropertiesToProxyServiceInstance(
 359         TopologyTemplate updatedContainer, ComponentInstance componentInstance) {
 360
 361         List<PropertyDefinition> propertiesList = componentInstance.getProperties();
 362
 363         if (propertiesList != null && !propertiesList.isEmpty()) {
 364             Map<String, PropertyDataDefinition> propertiesMap = propertiesList.stream().map(PropertyDataDefinition::new)
 365                 .collect(Collectors.toMap(
 366                     PropertyDataDefinition::getName, i -> i));
 367             MapPropertiesDataDefinition instProperties = new MapPropertiesDataDefinition(propertiesMap);
 368             Map<String, MapPropertiesDataDefinition> instPropertiesMap = new HashMap<>();
 369             instPropertiesMap.put(componentInstance.getUniqueId(), instProperties);
 370             updatedContainer.setInstProperties(instPropertiesMap);
 371             Either<GraphVertex, JanusGraphOperationStatus> getToscaElementRes = janusGraphDao
 372                 .getVertexById(updatedContainer.getUniqueId(), JsonParseFlagEnum.NoParse);
 373             if (getToscaElementRes.isLeft()) {
 374                 deleteToscaDataDeepElementsBlockToToscaElement(getToscaElementRes.left().value(), EdgeLabelEnum.INST_PROPERTIES,
 375                     VertexTypeEnum.INST_PROPERTIES, componentInstance.getUniqueId());
 376             }
 377             StorageOperationStatus status = addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(),
 378                 EdgeLabelEnum.INST_PROPERTIES, VertexTypeEnum.INST_PROPERTIES, instProperties,
 379                 componentInstance.getUniqueId());
 380             if (status != StorageOperationStatus.OK) {
 381                 return Either.right(status);
 382             }
 383
 384
 385         }
 386         return Either.left(new ImmutablePair<>(updatedContainer, componentInstance.getUniqueId()));
 387     }
 388
 389     private Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> addServiceInstanceInputsToProxyServiceInstance(
 390         TopologyTemplate updatedContainer, ComponentInstance componentInstance) {
 391
 392         List<InputDefinition> inputsList = componentInstance.getInputs();
 393
 394         if (CollectionUtils.isNotEmpty(inputsList)) {
 395             Map<String, PropertyDataDefinition> inputsMap = inputsList.stream().map(
 396                 PropertyDataDefinition::new).collect(Collectors.toMap(PropertyDataDefinition::getName, i -> i));
 397             MapPropertiesDataDefinition instInputs = new MapPropertiesDataDefinition(inputsMap);
 398             Map<String, MapPropertiesDataDefinition> instInputsMap = new HashMap<>();
 399             instInputsMap.put(componentInstance.getUniqueId(), instInputs);
 400             updatedContainer.setInstInputs(instInputsMap);
 401
 402             StorageOperationStatus status =
 403                 addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(),
 404                     EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS, instInputs,
 405                     componentInstance.getUniqueId());
 406             if (status != StorageOperationStatus.OK) {
 407                 return Either.right(status);
 408             }
 409         }
 410
 411         return Either.left(new ImmutablePair<>(updatedContainer, componentInstance.getUniqueId()));
 412     }
 413
 414     private Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> addComponentInstanceInterfacesToTopologyTemplate(
 415         TopologyTemplate updatedContainer, ComponentInstance componentInstance) {
 416         Map<String, Object> interfaces = componentInstance.getInterfaces();
 417
 418         if (MapUtils.isNotEmpty(interfaces)) {
 419             Map<String, InterfaceDataDefinition> interfacesMap = interfaces.entrySet().stream()
 420                 .collect(Collectors.toMap(e -> ((InterfaceDataDefinition) e.getValue()).getUniqueId(), e -> (InterfaceDataDefinition) e.getValue()));
 421             MapInterfaceDataDefinition instInterfaces = new MapInterfaceDataDefinition(interfacesMap);
 422
 423             Map<String, MapInterfaceDataDefinition> instInterfacesMap = new HashMap<>();
 424             instInterfacesMap.put(componentInstance.getUniqueId(), instInterfaces);
 425             updatedContainer.setComponentInstInterfaces(instInterfacesMap);
 426
 427             StorageOperationStatus status =
 428                 addToscaDataDeepElementsBlockToToscaElement(updatedContainer.getUniqueId(),
 429                     EdgeLabelEnum.INST_INTERFACES, VertexTypeEnum.INST_INTERFACES, instInterfaces,
 430                     componentInstance.getUniqueId());
 431
 432             if (status != StorageOperationStatus.OK) {
 433                 return Either.right(status);
 434             }
 435         }
 436
 437         return Either.left(new ImmutablePair<>(updatedContainer, componentInstance.getUniqueId()));
 438     }
 439
 440     public Either<TopologyTemplate, StorageOperationStatus> addComponentInstanceToTopologyTemplate(
 441         TopologyTemplate container, ToscaElement originToscaElement,
 442         ComponentInstanceDataDefinition componentInstance, GraphVertex metadataVertex, boolean allowDeleted,
 443         User user) {
 444
 445         Either<TopologyTemplate, StorageOperationStatus> result = null;
 446         Either<ToscaElement, StorageOperationStatus> updateContainerComponentRes = null;
 447         String containerComponentId = container.getUniqueId();
 448         CommonUtility.addRecordToLog(log, LogLevelEnum.TRACE, "Going to create component instance {} in component {}", componentInstance,
 449             containerComponentId);
 450         String instOriginComponentId = componentInstance.getComponentUid();
 451         Either<GraphVertex, JanusGraphOperationStatus> updateElement = null;
 452
 453         Boolean isDeleted = (Boolean) originToscaElement.getMetadataValue(JsonPresentationFields.IS_DELETED);
 454
 455         if (!allowDeleted && (isDeleted != null) && isDeleted) {
 456             CommonUtility
 457                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Component {} is already deleted. Cannot add component instance", instOriginComponentId);
 458             result = Either.right(StorageOperationStatus.INVALID_ID);
 459         }
 460         Boolean isArchived = originToscaElement.isArchived();
 461         if (isArchived != null && isArchived) {
 462             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to create instance {}. Origin {} component is archived . ",
 463                 componentInstance.getName(), originToscaElement.getName());
 464             result = Either.right(StorageOperationStatus.COMPONENT_IS_ARCHIVED);
 465         }
 466
 467         if (result == null) {
 468             container.addComponentInstance(componentInstance);
 469             metadataVertex.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
 470             topologyTemplateOperation.fillToscaElementVertexData(metadataVertex, container, JsonParseFlagEnum.ParseAll);
 471             updateElement = janusGraphDao.updateVertex(metadataVertex);
 472             if (updateElement.isRight()) {
 473                 CommonUtility
 474                     .addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_UPDATE_TOPOLOGY_TEMPLATE_WITH_NEW_COMPONENT_INSTANCE, container.getName(),
 475                         componentInstance.getName());
 476                 result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value()));
 477             }
 478         }
 479         if (result == null) {
 480             Either<GraphVertex, StorageOperationStatus> addToscaDataRes = addComponentInstanceToscaDataToContainerComponent(originToscaElement,
 481                 componentInstance, updateElement.left().value());
 482             if (addToscaDataRes.isRight()) {
 483                 result = Either.right(addToscaDataRes.right().value());
 484             }
 485         }
 486         if (result == null) {
 487             StorageOperationStatus createInstanceEdge = createInstanceEdge(metadataVertex, componentInstance);
 488             result = createInstanceEdge == StorageOperationStatus.OK ? null : Either.right(createInstanceEdge);
 489         }
 490
 491         if (result == null) {
 492             updateContainerComponentRes = topologyTemplateOperation.getToscaElement(containerComponentId);
 493             if (updateContainerComponentRes.isRight()) {
 494                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch updated topology template {} with new component instance {}. ",
 495                     container.getName(), componentInstance.getName());
 496                 result = Either.right(updateContainerComponentRes.right().value());
 497             }
 498         }
 499         if (result == null) {
 500             result = Either.left((TopologyTemplate) updateContainerComponentRes.left().value());
 501         }
 502         return result;
 503     }
 504
 505     public Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> updateComponentInstanceMetadataOfTopologyTemplate(
 506         TopologyTemplate container, ToscaElement originToscaElement, ComponentInstance componentInstance) {
 507
 508         Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> result = null;
 509         Either<ToscaElement, StorageOperationStatus> updateContainerComponentRes = null;
 510
 511         String containerComponentId = container.getUniqueId();
 512         CommonUtility
 513             .addRecordToLog(log, LogLevelEnum.TRACE, "Going to update component instance metadata {} of container component {}", componentInstance,
 514                 containerComponentId);
 515         ComponentInstanceDataDefinition componentInstanceData = null;
 516
 517         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao
 518             .getVertexById(container.getUniqueId(), JsonParseFlagEnum.ParseMetadata);
 519         if (metadataVertex.isRight()) {
 520             JanusGraphOperationStatus status = metadataVertex.right().value();
 521             if (status == JanusGraphOperationStatus.NOT_FOUND) {
 522                 status = JanusGraphOperationStatus.INVALID_ID;
 523             }
 524             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status));
 525         }
 526         if (result == null) {
 527             componentInstanceData = buildComponentInstanceDataDefinition(componentInstance, container.getUniqueId(), componentInstance.getName(),
 528                 false, originToscaElement);
 529             container.addComponentInstance(componentInstanceData);
 530             metadataVertex.left().value().setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
 531             topologyTemplateOperation.fillToscaElementVertexData(metadataVertex.left().value(), container, JsonParseFlagEnum.ParseAll);
 532             Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao
 533                 .updateVertex(metadataVertex.left().value());
 534             if (updateElement.isRight()) {
 535                 CommonUtility
 536                     .addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_UPDATE_TOPOLOGY_TEMPLATE_WITH_NEW_COMPONENT_INSTANCE, container.getName(),
 537                         componentInstance.getName());
 538                 result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value()));
 539             }
 540         }
 541         if (result == null) {
 542             updateContainerComponentRes = topologyTemplateOperation.getToscaElement(containerComponentId);
 543             if (updateContainerComponentRes.isRight()) {
 544                 CommonUtility
 545                     .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch updated topology template {} with updated component instance {}. ",
 546                         container.getName(), componentInstance.getName());
 547                 result = Either.right(updateContainerComponentRes.right().value());
 548             }
 549         }
 550         if (result == null) {
 551             result = Either
 552                 .left(new ImmutablePair<>((TopologyTemplate) updateContainerComponentRes.left().value(), componentInstanceData.getUniqueId()));
 553         }
 554         return result;
 555     }
 556
 557     public Either<TopologyTemplate, StorageOperationStatus> updateComponentInstanceMetadataOfTopologyTemplate(TopologyTemplate container,
 558                                                                                                               ComponentParametersView filter) {
 559
 560         Either<TopologyTemplate, StorageOperationStatus> result = null;
 561         Either<ToscaElement, StorageOperationStatus> updateContainerComponentRes = null;
 562
 563         String containerComponentId = container.getUniqueId();
 564         CommonUtility
 565             .addRecordToLog(log, LogLevelEnum.TRACE, "Going to update component instance metadata  of container component {}", containerComponentId);
 566
 567         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao
 568             .getVertexById(container.getUniqueId(), JsonParseFlagEnum.ParseMetadata);
 569         if (metadataVertex.isRight()) {
 570             JanusGraphOperationStatus status = metadataVertex.right().value();
 571             if (status == JanusGraphOperationStatus.NOT_FOUND) {
 572                 status = JanusGraphOperationStatus.INVALID_ID;
 573             }
 574             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status));
 575         }
 576         if (result == null) {
 577             metadataVertex.left().value().setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
 578             topologyTemplateOperation.fillToscaElementVertexData(metadataVertex.left().value(), container, JsonParseFlagEnum.ParseAll);
 579             Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao
 580                 .updateVertex(metadataVertex.left().value());
 581             if (updateElement.isRight()) {
 582                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update topology template {}. ", container.getName());
 583                 result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value()));
 584             }
 585         }
 586         if (result == null) {
 587             updateContainerComponentRes = topologyTemplateOperation.getToscaElement(containerComponentId, filter);
 588             if (updateContainerComponentRes.isRight()) {
 589                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch updated topology template {}. ", container.getName());
 590                 result = Either.right(updateContainerComponentRes.right().value());
 591             }
 592         }
 593         if (result == null) {
 594             result = Either.left((TopologyTemplate) updateContainerComponentRes.left().value());
 595         }
 596         return result;
 597     }
 598
 599     public Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> deleteComponentInstanceFromTopologyTemplate(
 600         TopologyTemplate container, String componentInstanceId) {
 601
 602         Either<ImmutablePair<TopologyTemplate, String>, StorageOperationStatus> result = null;
 603         Either<ToscaElement, StorageOperationStatus> updateContainerComponentRes = null;
 604
 605         String containerComponentId = container.getUniqueId();
 606         CommonUtility
 607             .addRecordToLog(log, LogLevelEnum.TRACE, "Going to update component instance metadata {} of container component {}", componentInstanceId,
 608                 containerComponentId);
 609
 610         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao
 611             .getVertexById(container.getUniqueId(), JsonParseFlagEnum.ParseMetadata);
 612         if (metadataVertex.isRight()) {
 613             JanusGraphOperationStatus status = metadataVertex.right().value();
 614             if (status == JanusGraphOperationStatus.NOT_FOUND) {
 615                 status = JanusGraphOperationStatus.INVALID_ID;
 616             }
 617             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status));
 618         }
 619         GraphVertex containerV = null;
 620         ComponentInstanceDataDefinition removedComponentInstance = null;
 621         if (result == null) {
 622             removedComponentInstance = container.getComponentInstances().remove(componentInstanceId);
 623             containerV = metadataVertex.left().value();
 624             StorageOperationStatus status = removeRelationsOfInstance(container, componentInstanceId, containerV);
 625             if (status != StorageOperationStatus.OK) {
 626                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to delete relation for component instance {} in container. error {}",
 627                     componentInstanceId, container.getUniqueId(), status);
 628                 result = Either.right(status);
 629             }
 630
 631             containerV.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
 632             topologyTemplateOperation.fillToscaElementVertexData(containerV, container, JsonParseFlagEnum.ParseAll);
 633             Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao.updateVertex(containerV);
 634             if (updateElement.isRight()) {
 635                 CommonUtility
 636                     .addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_UPDATE_TOPOLOGY_TEMPLATE_WITH_NEW_COMPONENT_INSTANCE, container.getName(),
 637                         componentInstanceId);
 638                 result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value()));
 639             }
 640         }
 641         if (result == null) {
 642             StorageOperationStatus status = deleteComponentInstanceToscaDataFromContainerComponent(containerV, componentInstanceId);
 643             if (status != StorageOperationStatus.OK) {
 644                 CommonUtility
 645                     .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to delete data  for instance {} in container {}. error {] ", componentInstanceId,
 646                         container.getUniqueId(), status);
 647                 return Either.right(status);
 648             }
 649             ComponentInstance componentInstance = new ComponentInstance(removedComponentInstance);
 650             StorageOperationStatus createInstanceEdge = removeInstanceEdge(containerV, componentInstance);
 651             result = createInstanceEdge == StorageOperationStatus.OK ? null : Either.right(createInstanceEdge);
 652         }
 653         if (result == null) {
 654             updateContainerComponentRes = topologyTemplateOperation.getToscaElement(containerComponentId);
 655             if (updateContainerComponentRes.isRight()) {
 656                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
 657                     "Failed to fetch updated topology template {} after deleting the component instance {}. ", container.getName(),
 658                     componentInstanceId);
 659                 result = Either.right(updateContainerComponentRes.right().value());
 660             }
 661         }
 662         if (result == null) {
 663             result = Either.left(new ImmutablePair<>((TopologyTemplate) updateContainerComponentRes.left().value(), componentInstanceId));
 664         }
 665         return result;
 666     }
 667
 668     private StorageOperationStatus removeRelationsOfInstance(TopologyTemplate container, String ciToRemove, GraphVertex containerV) {
 669         CompositionDataDefinition composition = container.getCompositions().get(JsonConstantKeysEnum.COMPOSITION.getValue());
 670         if (composition != null) {
 671             Map<String, RelationshipInstDataDefinition> relations = composition.getRelations();
 672             if (MapUtils.isNotEmpty(relations)) {
 673                 Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capResult = fetchContainerCalculatedCapability(
 674                     containerV, EdgeLabelEnum.CALCULATED_CAPABILITIES);
 675                 if (capResult.isRight()) {
 676                     return capResult.right().value();
 677
 678                 }
 679                 Map<String, MapListCapabilityDataDefinition> calculatedCapabilty = capResult.left().value().getRight();
 680
 681                 Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capFullResult = fetchContainerCalculatedCapability(
 682                     containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES);
 683                 if (capFullResult.isRight()) {
 684                     return capFullResult.right().value();
 685
 686                 }
 687                 Map<String, MapListCapabilityDataDefinition> fullFilledCapabilty = capFullResult.left().value().getRight();
 688
 689                 Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqResult = fetchContainerCalculatedRequirement(
 690                     containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS);
 691                 if (reqResult.isRight()) {
 692                     return reqResult.right().value();
 693                 }
 694                 Map<String, MapListRequirementDataDefinition> calculatedRequirement = reqResult.left().value().getRight();
 695
 696                 Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqFullResult = fetchContainerCalculatedRequirement(
 697                     containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS);
 698                 if (reqResult.isRight()) {
 699                     return reqResult.right().value();
 700                 }
 701                 Map<String, MapListRequirementDataDefinition> fullfilledRequirement = reqFullResult.left().value().getRight();
 702
 703                 Iterator<Entry<String, RelationshipInstDataDefinition>> iterator = relations.entrySet().iterator();
 704                 while (iterator.hasNext()) {
 705                     Entry<String, RelationshipInstDataDefinition> relation = iterator.next();
 706                     RelationshipInstDataDefinition relationToDelete = relation.getValue();
 707                     if (relationToDelete.getFromId().equals(ciToRemove) || relationToDelete.getToId().equals(ciToRemove)) {
 708                         iterator.remove();
 709                         if (relationToDelete.getFromId().equals(ciToRemove)) {
 710                             updateCalculatedRequirementsAfterDeleteRelation(calculatedRequirement, fullfilledRequirement, ciToRemove,
 711                                 relationToDelete, null);
 712                             updateCalculatedCapabiltyAfterDeleteRelation(calculatedCapabilty, fullFilledCapabilty, relationToDelete.getToId(),
 713                                 relationToDelete, null);
 714                         }
 715                         if (relationToDelete.getToId().equals(ciToRemove)) {
 716                             updateCalculatedRequirementsAfterDeleteRelation(calculatedRequirement, fullfilledRequirement,
 717                                 relationToDelete.getFromId(), relationToDelete, null);
 718                             updateCalculatedCapabiltyAfterDeleteRelation(calculatedCapabilty, fullFilledCapabilty, ciToRemove, relationToDelete,
 719                                 null);
 720                         }
 721                     }
 722                 }
 723                 return updateAllAndCalculatedCapReqOnGraph(container.getUniqueId(), containerV, capResult, capFullResult, reqResult, reqFullResult);
 724             }
 725         }
 726         return StorageOperationStatus.OK;
 727     }
 728
 729     private StorageOperationStatus deleteComponentInstanceToscaDataFromContainerComponent(GraphVertex containerV, String componentInstanceId) {
 730         StorageOperationStatus status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.CALCULATED_CAPABILITIES,
 731             VertexTypeEnum.CALCULATED_CAPABILITIES, componentInstanceId);
 732         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 733             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove calculated capabilty  for instance {} in container {}. error {] ",
 734                 componentInstanceId, containerV.getUniqueId(), status);
 735             return status;
 736         }
 737         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
 738             VertexTypeEnum.CALCULATED_CAP_PROPERTIES, componentInstanceId);
 739         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 740             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
 741                 "Failed to remove calculated capabilty properties for instance {} in container {}. error {] ", componentInstanceId,
 742                 containerV.getUniqueId(), status);
 743             return status;
 744         }
 745         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS,
 746             VertexTypeEnum.CALCULATED_REQUIREMENTS, componentInstanceId);
 747         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 748             CommonUtility
 749                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove calculated requirement  for instance {} in container {}. error {] ",
 750                     componentInstanceId, containerV.getUniqueId(), status);
 751             return status;
 752         }
 753         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES,
 754             VertexTypeEnum.FULLFILLED_CAPABILITIES, componentInstanceId);
 755         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 756             CommonUtility
 757                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove fullfilled capabilities  for instance {} in container {}. error {] ",
 758                     componentInstanceId, containerV.getUniqueId(), status);
 759             return status;
 760         }
 761         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS,
 762             VertexTypeEnum.FULLFILLED_REQUIREMENTS, componentInstanceId);
 763         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 764             CommonUtility
 765                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove fullfilled requirement  for instance {} in container {}. error {] ",
 766                     componentInstanceId, containerV.getUniqueId(), status);
 767             return status;
 768         }
 769         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_ATTRIBUTES, VertexTypeEnum.INST_ATTRIBUTES,
 770             componentInstanceId);
 771         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 772             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove attributes for instance {} in container {}. error {] ",
 773                 componentInstanceId, containerV.getUniqueId(), status);
 774             return status;
 775         }
 776         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_PROPERTIES, VertexTypeEnum.INST_PROPERTIES,
 777             componentInstanceId);
 778         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 779             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove properties for instance {} in container {}. error {] ",
 780                 componentInstanceId, containerV.getUniqueId(), status);
 781             return status;
 782         }
 783         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS,
 784             componentInstanceId);
 785         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 786             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove instance inputs  for instance {} in container {}. error {] ",
 787                 componentInstanceId, containerV.getUniqueId(), status);
 788             return status;
 789         }
 790         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_GROUPS, VertexTypeEnum.INST_GROUPS,
 791             componentInstanceId);
 792         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 793             CommonUtility
 794                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove fullfilled requirement  for instance {} in container {}. error {] ",
 795                     componentInstanceId, containerV.getUniqueId(), status);
 796             return status;
 797         }
 798         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_DEPLOYMENT_ARTIFACTS,
 799             VertexTypeEnum.INST_DEPLOYMENT_ARTIFACTS, componentInstanceId);
 800         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 801             CommonUtility
 802                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove instance deployment artifacts  for instance {} in container {}. error {] ",
 803                     componentInstanceId, containerV.getUniqueId(), status);
 804             return status;
 805         }
 806         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INSTANCE_ARTIFACTS, VertexTypeEnum.INSTANCE_ARTIFACTS,
 807             componentInstanceId);
 808         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 809             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove instance artifacts  for instance {} in container {}. error {] ",
 810                 componentInstanceId, containerV.getUniqueId(), status);
 811             return status;
 812         }
 813         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.EXTERNAL_REFS, VertexTypeEnum.EXTERNAL_REF,
 814             componentInstanceId);
 815         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 816             CommonUtility
 817                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to remove instance external refs  for instance {} in container {}. error {] ",
 818                     componentInstanceId, containerV.getUniqueId(), status);
 819             return status;
 820         }
 821         status = deleteToscaDataDeepElementsBlockToToscaElement(containerV, EdgeLabelEnum.INST_INTERFACES,
 822             VertexTypeEnum.INST_INTERFACES, componentInstanceId);
 823         if (status != StorageOperationStatus.OK && status != StorageOperationStatus.NOT_FOUND) {
 824             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
 825                 "Failed to remove service instance interfaces  for instance {} in container {}. " +
 826                     "error {] ", componentInstanceId, containerV.getUniqueId(), status);
 827             return status;
 828         }
 829         return StorageOperationStatus.OK;
 830     }
 831
 832     protected Either<GraphVertex, StorageOperationStatus> addComponentInstanceToscaDataToContainerComponent(ToscaElement originToscaElement,
 833                                                                                                             ComponentInstanceDataDefinition componentInstance,
 834                                                                                                             GraphVertex updatedContainerVertex) {
 835
 836         Either<GraphVertex, StorageOperationStatus> result;
 837         StorageOperationStatus status;
 838         if (originToscaElement.getToscaType() == ToscaElementTypeEnum.NODE_TYPE) {
 839             status = addComponentInstanceToscaDataToNodeTypeContainer((NodeType) originToscaElement, componentInstance, updatedContainerVertex);
 840         } else {
 841             status = addComponentInstanceToscaDataToTopologyTemplateContainer((TopologyTemplate) originToscaElement, componentInstance,
 842                 updatedContainerVertex);
 843         }
 844         if (status == StorageOperationStatus.OK) {
 845             result = Either.left(updatedContainerVertex);
 846         } else {
 847             result = Either.right(status);
 848         }
 849         return result;
 850     }
 851
 852     private StorageOperationStatus addComponentInstanceToscaDataToTopologyTemplateContainer(TopologyTemplate originTopologyTemplate,
 853                                                                                             ComponentInstanceDataDefinition componentInstance,
 854                                                                                             GraphVertex updatedContainerVertex) {
 855
 856         StorageOperationStatus status;
 857
 858         status = addCalculatedCapReqFromTopologyTemplate(originTopologyTemplate, componentInstance, updatedContainerVertex);
 859
 860         if (status != StorageOperationStatus.OK) {
 861
 862             return status;
 863         }
 864
 865         MapPropertiesDataDefinition instInputs = new MapPropertiesDataDefinition(originTopologyTemplate.getInputs());
 866         MapPropertiesDataDefinition instInputsAsProperties = turnInputsIntoProperties(instInputs);
 867
 868         status = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS,
 869             instInputsAsProperties, componentInstance.getUniqueId());
 870         if (status != StorageOperationStatus.OK) {
 871             return status;
 872         }
 873
 874         return status;
 875     }
 876
 877     private MapPropertiesDataDefinition turnInputsIntoProperties(MapPropertiesDataDefinition instInput) {
 878         if (instInput.getMapToscaDataDefinition() != null) {
 879             for (PropertyDataDefinition currProp : instInput.getMapToscaDataDefinition().values()) {
 880                 String temp = currProp.getValue();
 881                 currProp.setValue(currProp.getDefaultValue());
 882                 currProp.setDefaultValue(temp);
 883             }
 884         }
 885         return instInput;
 886     }
 887
 888     private MapListCapabilityDataDefinition prepareCalculatedCapabiltyForTopologyTemplate(
 889         Map<String, ListCapabilityDataDefinition> capabilities,
 890         ComponentInstanceDataDefinition componentInstance,
 891         MapListCapabilityDataDefinition calculatedCap) {
 892         MapListCapabilityDataDefinition allCalculatedCap =
 893             new MapListCapabilityDataDefinition(calculatedCap);
 894         populateCapability(capabilities, componentInstance, allCalculatedCap);
 895         return allCalculatedCap;
 896     }
 897
 898     private void populateCapability(Map<String, ListCapabilityDataDefinition> capabilities,
 899                                     ComponentInstanceDataDefinition componentInstance,
 900                                     MapListCapabilityDataDefinition allCalculatedCap) {
 901         capabilities.forEach((key, value) -> {
 902             List<CapabilityDataDefinition> listCapabilities = value.getListToscaDataDefinition()
 903                 .stream().map(CapabilityDataDefinition::new).collect(Collectors.toList());
 904             listCapabilities.forEach(cap -> {
 905                 cap.setSource(componentInstance.getComponentUid());
 906                 cap.addToPath(componentInstance.getUniqueId());
 907                 log.debug("enter populateCapability,get Capability OwnerId:{},get componentInstance UniqueId:{}",
 908                     cap.getOwnerId(), componentInstance.getUniqueId());
 909                 cap.setOwnerId(componentInstance.getUniqueId());
 910                 log.debug("enter populateCapability,get Capability OwnerName:{},get componentInstance Name:{}",
 911                     cap.getOwnerName(), componentInstance.getName());
 912                 if (cap.getOwnerName() == null || cap.getOwnerName().isEmpty()) {
 913                     cap.setOwnerName(componentInstance.getName());
 914                 }
 915                 cap.setLeftOccurrences(cap.getMaxOccurrences());
 916                 allCalculatedCap.add(key, cap);
 917             });
 918         });
 919     }
 920
 921     private MapListRequirementDataDefinition prepareCalculatedRequirementForTopologyTemplate(
 922         Map<String, ListRequirementDataDefinition> requirements,
 923         ComponentInstanceDataDefinition componentInstance,
 924         MapListRequirementDataDefinition calculatedReqs) {
 925         MapListRequirementDataDefinition allCalculatedReq =
 926             new MapListRequirementDataDefinition(calculatedReqs);
 927
 928         populateRequirement(requirements, componentInstance, allCalculatedReq);
 929         return allCalculatedReq;
 930     }
 931
 932     private void populateRequirement(Map<String, ListRequirementDataDefinition> requirements,
 933                                      ComponentInstanceDataDefinition componentInstance,
 934                                      MapListRequirementDataDefinition allCalculatedReq) {
 935         requirements.forEach((key, value) -> {
 936             List<RequirementDataDefinition> listRequirements = value.getListToscaDataDefinition()
 937                 .stream().map(RequirementDataDefinition::new).collect(Collectors.toList());
 938             listRequirements.forEach(req -> {
 939                 req.setSource(componentInstance.getComponentUid());
 940                 req.addToPath(componentInstance.getUniqueId());
 941                 log.debug("enter populateRequirement,get init Requirements OwnerId:{},get componentInstance UniqueId:{}",
 942                     req.getOwnerId(), componentInstance.getUniqueId());
 943                 if (req.getOwnerId() == null || req.getOwnerId().isEmpty()) {
 944                     req.setOwnerId(componentInstance.getUniqueId());
 945                 }
 946                 log.debug("enter populateRequirement,get init Requirements OwnerName:{}", req.getOwnerName());
 947                 if (req.getOwnerName() == null || req.getOwnerName().isEmpty()) {
 948                     req.setOwnerName(componentInstance.getName());
 949                 }
 950                 req.setLeftOccurrences(req.getMaxOccurrences());
 951                 allCalculatedReq.add(key, req);
 952             });
 953         });
 954     }
 955
 956     private StorageOperationStatus addCalculatedCapReqFromTopologyTemplate(TopologyTemplate originTopologyTemplate,
 957                                                                            ComponentInstanceDataDefinition componentInstance,
 958                                                                            GraphVertex updatedContainerVertex) {
 959         Map<String, MapListCapabilityDataDefinition> calculatedCapabilities = originTopologyTemplate.getCalculatedCapabilities();
 960
 961         MapListCapabilityDataDefinition allCalculatedCap = new MapListCapabilityDataDefinition();
 962         if (calculatedCapabilities != null) {
 963             calculatedCapabilities.forEach((key1, value1) -> {
 964                 final Map<String, ListCapabilityDataDefinition> mapByType = value1.getMapToscaDataDefinition();
 965                 mapByType.forEach((key, value) -> value.getListToscaDataDefinition().stream()
 966                     .filter(CapabilityDataDefinition::isExternal)
 967                     .forEach(cap -> {
 968                         cap.addToPath(componentInstance.getUniqueId());
 969                         allCalculatedCap.add(key, cap);
 970                     }));
 971             });
 972         }
 973         MapListCapabilityDataDefinition allCaps;
 974         Map<String, ListCapabilityDataDefinition> capabilities = originTopologyTemplate.getCapabilities();
 975         if (MapUtils.isNotEmpty(capabilities)) {
 976             allCaps = prepareCalculatedCapabiltyForTopologyTemplate(capabilities, componentInstance,
 977                 allCalculatedCap);
 978         } else {
 979             allCaps = new MapListCapabilityDataDefinition(allCalculatedCap);
 980         }
 981         if (!allCaps.isEmpty()) {
 982             StorageOperationStatus calculatedCapabilitiesResult =
 983                 addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex,
 984                     EdgeLabelEnum.CALCULATED_CAPABILITIES, VertexTypeEnum.CALCULATED_CAPABILITIES,
 985                     allCaps, componentInstance.getUniqueId());
 986             if (calculatedCapabilitiesResult != StorageOperationStatus.OK) {
 987                 return calculatedCapabilitiesResult;
 988             }
 989             MapListCapabilityDataDefinition fullCalculatedCap = new MapListCapabilityDataDefinition();
 990             calculatedCapabilitiesResult = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex,
 991                 EdgeLabelEnum.FULLFILLED_CAPABILITIES, VertexTypeEnum.FULLFILLED_CAPABILITIES,
 992                 fullCalculatedCap, componentInstance.getUniqueId());
 993             if (calculatedCapabilitiesResult != StorageOperationStatus.OK) {
 994                 return calculatedCapabilitiesResult;
 995             }
 996         }
 997         Map<String, MapListRequirementDataDefinition> calculatedRequirements =
 998             originTopologyTemplate.getCalculatedRequirements();
 999         MapListRequirementDataDefinition allCalculatedReq = new MapListRequirementDataDefinition();
1000         if (calculatedRequirements != null) {
1001             calculatedRequirements.forEach((key, value) -> {
1002                 Map<String, ListRequirementDataDefinition> mapByType =
1003                     value.getMapToscaDataDefinition();
1004                 mapByType.forEach((key1, value1) -> value1.getListToscaDataDefinition().stream()
1005                     .filter(RequirementDataDefinition::isExternal).forEach(req -> {
1006                         req.addToPath(componentInstance.getUniqueId());
1007                         req.setExternal(false);
1008                         allCalculatedReq.add(key1, req);
1009                     }));
1010             });
1011
1012         }
1013
1014         MapListRequirementDataDefinition allReqs;
1015         Map<String, ListRequirementDataDefinition> requirements = originTopologyTemplate.getRequirements();
1016         if (MapUtils.isNotEmpty(requirements)) {
1017             allReqs = prepareCalculatedRequirementForTopologyTemplate(requirements,
1018                 componentInstance, allCalculatedReq);
1019         } else {
1020             allReqs = new MapListRequirementDataDefinition(allCalculatedReq);
1021         }
1022
1023         if (!allReqs.isEmpty()) {
1024             StorageOperationStatus calculatedRequirementResult =
1025                 addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex,
1026                     EdgeLabelEnum.CALCULATED_REQUIREMENTS, VertexTypeEnum.CALCULATED_REQUIREMENTS,
1027                     allReqs, componentInstance.getUniqueId());
1028             if (calculatedRequirementResult != StorageOperationStatus.OK) {
1029                 return calculatedRequirementResult;
1030             }
1031             MapListRequirementDataDefinition fullCalculatedReq = new MapListRequirementDataDefinition();
1032             calculatedRequirementResult = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex,
1033                 EdgeLabelEnum.FULLFILLED_REQUIREMENTS, VertexTypeEnum.FULLFILLED_REQUIREMENTS,
1034                 fullCalculatedReq,
1035                 componentInstance.getUniqueId());
1036             if (calculatedRequirementResult != StorageOperationStatus.OK) {
1037                 return calculatedRequirementResult;
1038             }
1039         }
1040         Map<String, MapCapabilityProperty> calculatedCapabilitiesProperties = originTopologyTemplate.getCalculatedCapabilitiesProperties();
1041         Map<String, MapPropertiesDataDefinition> updateKeyMap = new HashMap<>();
1042
1043         if (calculatedCapabilitiesProperties != null && !calculatedCapabilitiesProperties.isEmpty()) {
1044             for (MapCapabilityProperty map : calculatedCapabilitiesProperties.values()) {
1045                 for (Entry<String, MapPropertiesDataDefinition> entry : map.getMapToscaDataDefinition().entrySet()) {
1046                     String newKey = (componentInstance.getUniqueId() + ModelConverter.CAP_PROP_DELIM + entry.getKey());
1047                     updateKeyMap.put(newKey, entry.getValue());
1048                 }
1049             }
1050         }
1051         Map<String, MapPropertiesDataDefinition> capabilitiesProperties =
1052             originTopologyTemplate.getCapabilitiesProperties();
1053         Map<String, MapPropertiesDataDefinition> updateKeyMapCapabilitiesProperties;
1054         if (MapUtils.isNotEmpty(capabilitiesProperties)) {
1055             updateKeyMapCapabilitiesProperties = capabilitiesProperties.entrySet().stream()
1056                 .collect(Collectors.toMap(e -> createCapPropertyKey(e.getKey(),
1057                     componentInstance.getUniqueId()), Entry::getValue));
1058         } else {
1059             updateKeyMapCapabilitiesProperties = new HashMap<>();
1060         }
1061         updateKeyMap.putAll(updateKeyMapCapabilitiesProperties);
1062         MapCapabilityProperty mapCapabilityProperty = new MapCapabilityProperty(updateKeyMap);
1063
1064         if (MapUtils.isNotEmpty(capabilitiesProperties) || MapUtils.isNotEmpty(calculatedCapabilitiesProperties)) {
1065             StorageOperationStatus calculatedResult =
1066                 addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex,
1067                     EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
1068                     VertexTypeEnum.CALCULATED_CAP_PROPERTIES, mapCapabilityProperty,
1069                     componentInstance.getUniqueId());
1070             if (calculatedResult != StorageOperationStatus.OK) {
1071                 return calculatedResult;
1072             }
1073         }
1074         return StorageOperationStatus.OK;
1075     }
1076
1077     public CapabilityDataDefinition updateComponentInstanceCapabilities(final String componentId, final String componentInstanceUniqueId,
1078                                                                         final CapabilityDataDefinition capabilityDataDefinition) {
1079
1080         final GraphVertex containerVertex = findComponentVertex(componentId).orElse(null);
1081         if (containerVertex == null) {
1082             throw new OperationException(ActionStatus.COMPONENT_NOT_FOUND, componentId);
1083         }
1084
1085         final Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>> capabilityVertexAndDataPair =
1086             findCapabilityVertex(containerVertex).orElse(null);
1087         if (capabilityVertexAndDataPair == null) {
1088             throw new OperationException(ActionStatus.CAPABILITY_OF_INSTANCE_NOT_FOUND_ON_CONTAINER, capabilityDataDefinition.getName(),
1089                 capabilityDataDefinition.getOwnerName(), componentId);
1090         }
1091         final GraphVertex capabilitiesVertex = capabilityVertexAndDataPair.getLeft();
1092         final Map<String, MapListCapabilityDataDefinition> capabilityDataMap = capabilityVertexAndDataPair.getRight();
1093
1094         final CapabilityDataDefinition actualCapabilityDataDefinition =
1095             findCapability(capabilityDataMap, componentInstanceUniqueId, capabilityDataDefinition.getType(), capabilityDataDefinition.getUniqueId())
1096                 .orElse(null);
1097         if (actualCapabilityDataDefinition == null) {
1098             throw new OperationException(ActionStatus.CAPABILITY_OF_INSTANCE_NOT_FOUND_ON_CONTAINER, capabilityDataDefinition.getName(),
1099                 capabilityDataDefinition.getOwnerName(), componentId);
1100         }
1101         bindCapabilityDefinition(capabilityDataDefinition, actualCapabilityDataDefinition);
1102
1103         var storageOperationStatus = updateCapabilityVertex(containerVertex, capabilitiesVertex);
1104         if (storageOperationStatus != StorageOperationStatus.OK) {
1105             throw new OperationException(ActionStatus.COMPONENT_INSTANCE_CAPABILITY_UPDATE_ERROR, capabilityDataDefinition.getName());
1106         }
1107         return new CapabilityDataDefinition(actualCapabilityDataDefinition);
1108     }
1109
1110     private void bindCapabilityDefinition(final CapabilityDataDefinition fromCapabilityDefinition,
1111                                           final CapabilityDataDefinition capabilityDefinitionToUpdate) {
1112         capabilityDefinitionToUpdate.setExternal(fromCapabilityDefinition.isExternal());
1113     }
1114
1115     private Optional<GraphVertex> findComponentVertex(final String componentId) {
1116         final Either<GraphVertex, JanusGraphOperationStatus> componentEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1117         if (componentEither.isRight()) {
1118             final JanusGraphOperationStatus error = componentEither.right().value();
1119             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1120             if (error == JanusGraphOperationStatus.NOT_FOUND) {
1121                 return Optional.empty();
1122             }
1123             log.error(EcompLoggerErrorCode.BUSINESS_PROCESS_ERROR, NodeTemplateOperation.class.getName(), (ErrorLogOptionalData) null,
1124                 FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1125             throw new OperationException(ActionStatus.COMPONENT_FIND_ERROR, componentId);
1126         }
1127         return Optional.ofNullable(componentEither.left().value());
1128     }
1129
1130     private Optional<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>> findCapabilityVertex(final GraphVertex containerVertex) {
1131
1132         final Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capabilitiesEither =
1133             fetchContainerCalculatedCapability(containerVertex, EdgeLabelEnum.CALCULATED_CAPABILITIES);
1134         if (capabilitiesEither.isRight()) {
1135             final StorageOperationStatus error = capabilitiesEither.right().value();
1136             if (error == StorageOperationStatus.NOT_FOUND) {
1137                 return Optional.empty();
1138             }
1139             log.error(EcompLoggerErrorCode.BUSINESS_PROCESS_ERROR, NodeTemplateOperation.class.getName(), (ErrorLogOptionalData) null,
1140                 FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, containerVertex.getUniqueId(), error);
1141             throw new OperationException(ActionStatus.COMPONENT_CAPABILITIES_FIND_ERROR, containerVertex.getUniqueId());
1142         }
1143         return Optional.ofNullable(capabilitiesEither.left().value());
1144     }
1145
1146     private Optional<CapabilityDataDefinition> findCapability(final Map<String, MapListCapabilityDataDefinition> capabilityMap,
1147                                                               final String componentInstanceUniqueId,
1148                                                               final String capabilityType,
1149                                                               final String capabilityUniqueId) {
1150         var componentInstanceCapabilitiesMap = capabilityMap.get(componentInstanceUniqueId);
1151         if (componentInstanceCapabilitiesMap == null || componentInstanceCapabilitiesMap.isEmpty()) {
1152             return Optional.empty();
1153         }
1154         var listCapabilityDataDefinition = componentInstanceCapabilitiesMap.getMapToscaDataDefinition().get(capabilityType);
1155         if (listCapabilityDataDefinition == null || listCapabilityDataDefinition.isEmpty()) {
1156             return Optional.empty();
1157         }
1158
1159         return listCapabilityDataDefinition.getListToscaDataDefinition().stream()
1160             .filter(e -> e.getUniqueId().equals(capabilityUniqueId))
1161             .findFirst();
1162     }
1163
1164     public StorageOperationStatus updateComponentInstanceRequirement(String componentId, String componentInstanceUniqueId,
1165                                                                      RequirementDataDefinition requirementDataDefinition) {
1166         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao
1167             .getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1168         if (containerVEither.isRight()) {
1169             JanusGraphOperationStatus error = containerVEither.right().value();
1170             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1171             return StorageOperationStatus.GENERAL_ERROR;
1172         }
1173         GraphVertex containerV = containerVEither.left().value();
1174         return updateComponentInstanceRequirement(componentId, componentInstanceUniqueId, requirementDataDefinition, containerV);
1175     }
1176
1177     private StorageOperationStatus updateComponentInstanceRequirement(String componentId, String componentInstanceUniqueId,
1178                                                                       RequirementDataDefinition requirementDataDefinition, GraphVertex containerV) {
1179         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> existingReqs = getCalculatedRequirements(
1180             componentId);
1181         if (existingReqs.isRight()) {
1182             return existingReqs.right().value();
1183         }
1184         MapListRequirementDataDefinition componentInstanceRequirementsMap = existingReqs.left().value().getRight().get(componentInstanceUniqueId);
1185         if (componentInstanceRequirementsMap == null) {
1186             return StorageOperationStatus.NOT_FOUND;
1187         }
1188         ListRequirementDataDefinition listRequirementDataDefinition = componentInstanceRequirementsMap.getMapToscaDataDefinition()
1189             .get(requirementDataDefinition.getCapability());
1190
1191         listRequirementDataDefinition.getListToscaDataDefinition().stream()
1192             .filter(e -> requirementDataDefinition.getOwnerId().equals(e.getOwnerId()) && requirementDataDefinition.getName().equals(e.getName()))
1193             .forEach(r -> r.setExternal(requirementDataDefinition.isExternal()));
1194
1195         return updateCalculatedReqOnGraph(componentId, containerV, existingReqs);
1196     }
1197
1198     private Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> getCalculatedRequirements(
1199         String componentId) {
1200         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> result = null;
1201         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao
1202             .getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1203         if (containerVEither.isRight()) {
1204             JanusGraphOperationStatus error = containerVEither.right().value();
1205             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1206             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
1207         }
1208         if (result == null) {
1209             GraphVertex containerV = containerVEither.left().value();
1210             result = fetchContainerCalculatedRequirement(containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS);
1211         }
1212         return result;
1213     }
1214
1215     private StorageOperationStatus updateCalculatedReqOnGraph(String componentId, GraphVertex containerV,
1216                                                               Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqResult
1217     ) {
1218         containerV.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
1219         Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao.updateVertex(containerV);
1220         if (updateElement.isRight()) {
1221             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update topology template {} with new relations error {}. ", componentId,
1222                 updateElement.right().value());
1223             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value());
1224         }
1225
1226         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Update calculated requirement for container {}", containerV.getUniqueId());
1227         Either<GraphVertex, JanusGraphOperationStatus> status = updateOrCopyOnUpdate(reqResult.left().value().getLeft(), containerV,
1228             EdgeLabelEnum.CALCULATED_REQUIREMENTS);
1229         if (status.isRight()) {
1230             JanusGraphOperationStatus error = status.right().value();
1231             CommonUtility
1232                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update calculated requiremnt for container {} error {}", containerV.getUniqueId(),
1233                     error);
1234             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1235         }
1236         return StorageOperationStatus.OK;
1237     }
1238
1239     private StorageOperationStatus updateCapabilityVertex(final GraphVertex containerVertex, final GraphVertex capabilitiesVertex) {
1240         containerVertex.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
1241         final Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao.updateVertex(containerVertex);
1242         if (updateElement.isRight()) {
1243             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update topology template '{}' with new capabilities. Error '{}'.",
1244                 containerVertex.getUniqueId(), updateElement.right().value());
1245             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value());
1246         }
1247
1248         final Either<GraphVertex, JanusGraphOperationStatus> statusEither =
1249             updateOrCopyOnUpdate(capabilitiesVertex, containerVertex, EdgeLabelEnum.CALCULATED_CAPABILITIES);
1250         if (statusEither.isRight()) {
1251             JanusGraphOperationStatus error = statusEither.right().value();
1252             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
1253                 "Failed to update calculated capability for container {} error {}", containerVertex.getUniqueId(), error);
1254             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1255         }
1256         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Updated calculated capability for container '{}'", containerVertex.getUniqueId());
1257         return StorageOperationStatus.OK;
1258     }
1259
1260     private StorageOperationStatus addComponentInstanceToscaDataToNodeTypeContainer(NodeType originNodeType,
1261                                                                                     ComponentInstanceDataDefinition componentInstance,
1262                                                                                     GraphVertex updatedContainerVertex) {
1263
1264         StorageOperationStatus status;
1265
1266         if (MapUtils.isNotEmpty(originNodeType.getProperties())) {
1267             MapPropertiesDataDefinition instProperties =
1268                 new MapPropertiesDataDefinition(originNodeType.getProperties());
1269             status = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.INST_PROPERTIES,
1270                 VertexTypeEnum.INST_PROPERTIES, instProperties, componentInstance.getUniqueId());
1271             if (status != StorageOperationStatus.OK) {
1272                 return status;
1273             }
1274         }
1275
1276         if (MapUtils.isNotEmpty(originNodeType.getAttributes())) {
1277             MapAttributesDataDefinition instAttributes =
1278                 new MapAttributesDataDefinition(originNodeType.getAttributes());
1279             status = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.INST_ATTRIBUTES,
1280                 VertexTypeEnum.INST_ATTRIBUTES, instAttributes, componentInstance.getUniqueId());
1281             if (status != StorageOperationStatus.OK) {
1282                 return status;
1283             }
1284         }
1285
1286         return addCalculatedCapReqFromNodeType(originNodeType, componentInstance, updatedContainerVertex);
1287     }
1288
1289     public MapArtifactDataDefinition prepareInstDeploymentArtifactPerInstance(Map<String, ArtifactDataDefinition> deploymentArtifacts,
1290                                                                               String componentInstanceId, User user, String envType) {
1291         if (deploymentArtifacts != null && envType.equals(HEAT_VF_ENV_NAME)) {
1292             Map<String, ArtifactDataDefinition> instDeploymentArtifacts = new HashMap<>();
1293
1294             deploymentArtifacts.entrySet().forEach(e -> {
1295                 ArtifactDataDefinition artifact = e.getValue();
1296                 String type = artifact.getArtifactType();
1297                 if (type.equalsIgnoreCase(ArtifactTypeEnum.HEAT.getType()) || type.equalsIgnoreCase(ArtifactTypeEnum.HEAT_NET.getType()) || type
1298                     .equalsIgnoreCase(ArtifactTypeEnum.HEAT_VOL.getType())) {
1299                     ArtifactDataDefinition artifactEnv = createArtifactPlaceHolderInfo(artifact, componentInstanceId, user, envType);
1300                     instDeploymentArtifacts.put(artifactEnv.getArtifactLabel(), artifactEnv);
1301                 }
1302             });
1303
1304             deploymentArtifacts.putAll(instDeploymentArtifacts);
1305
1306             return new MapArtifactDataDefinition(deploymentArtifacts);
1307
1308         }
1309         return null;
1310     }
1311
1312     @SuppressWarnings({"unchecked"})
1313     private ArtifactDataDefinition createArtifactPlaceHolderInfo(ArtifactDataDefinition artifactHeat, String componentId, User user,
1314                                                                  String heatEnvType) {
1315         Map<String, Object> deploymentResourceArtifacts = ConfigurationManager.getConfigurationManager().getConfiguration()
1316             .getDeploymentResourceInstanceArtifacts();
1317         if (deploymentResourceArtifacts == null) {
1318             log.debug("no deployment artifacts are configured for generated artifacts");
1319             return null;
1320         }
1321         Map<String, Object> placeHolderData = (Map<String, Object>) deploymentResourceArtifacts.get(heatEnvType);
1322         if (placeHolderData == null) {
1323             log.debug("no env type {} are configured for generated artifacts", heatEnvType);
1324             return null;
1325         }
1326
1327         String envLabel = (artifactHeat.getArtifactLabel() + HEAT_ENV_SUFFIX).toLowerCase();
1328
1329         ArtifactDataDefinition artifactInfo = new ArtifactDataDefinition();
1330
1331         String artifactName = (String) placeHolderData.get(ARTIFACT_PLACEHOLDER_DISPLAY_NAME);
1332         String artifactType = (String) placeHolderData.get(ARTIFACT_PLACEHOLDER_TYPE);
1333         String artifactDescription = (String) placeHolderData.get(ARTIFACT_PLACEHOLDER_DESCRIPTION);
1334
1335         artifactInfo.setArtifactDisplayName(artifactName);
1336         artifactInfo.setArtifactLabel(envLabel);
1337         artifactInfo.setArtifactType(artifactType);
1338         artifactInfo.setDescription(artifactDescription);
1339         artifactInfo.setArtifactGroupType(artifactHeat.getArtifactGroupType());
1340         setDefaultArtifactTimeout(artifactHeat.getArtifactGroupType(), artifactInfo);
1341         artifactInfo.setGeneratedFromId(artifactHeat.getUniqueId());
1342         // clone heat parameters in case of heat env only not VF heat env
1343         if (heatEnvType.equals(HEAT_ENV_NAME)) {
1344             artifactInfo.setHeatParameters(artifactHeat.getHeatParameters());
1345         }
1346         setArtifactPlaceholderCommonFields(componentId, user, artifactInfo);
1347
1348         return artifactInfo;
1349     }
1350
1351     public void setDefaultArtifactTimeout(ArtifactGroupTypeEnum groupType, ArtifactDataDefinition artifactInfo) {
1352         if (groupType.equals(ArtifactGroupTypeEnum.DEPLOYMENT)) {
1353             artifactInfo.setTimeout(defaultHeatTimeout);
1354         } else {
1355             artifactInfo.setTimeout(NON_HEAT_TIMEOUT);
1356         }
1357     }
1358
1359     private void setArtifactPlaceholderCommonFields(String resourceId, User user, ArtifactDataDefinition artifactInfo) {
1360         if (resourceId != null) {
1361             String uniqueId = UniqueIdBuilder.buildPropertyUniqueId(resourceId.toLowerCase(), artifactInfo.getArtifactLabel().toLowerCase());
1362             artifactInfo.setUniqueId(uniqueId);
1363         }
1364         artifactInfo.setUserIdCreator(user.getUserId());
1365         String fullName = user.getFullName();
1366         artifactInfo.setUpdaterFullName(fullName);
1367
1368         long time = System.currentTimeMillis();
1369
1370         artifactInfo.setCreatorFullName(fullName);
1371         artifactInfo.setCreationDate(time);
1372
1373         artifactInfo.setLastUpdateDate(time);
1374         artifactInfo.setUserIdLastUpdater(user.getUserId());
1375
1376         artifactInfo.setMandatory(true);
1377     }
1378
1379     /**
1380      * @param originNodeType
1381      * @param componentInstance
1382      * @param updatedContainerVertex
1383      * @return
1384      */
1385     private StorageOperationStatus addCalculatedCapReqFromNodeType(NodeType originNodeType, ComponentInstanceDataDefinition componentInstance,
1386                                                                    GraphVertex updatedContainerVertex) {
1387         Map<String, ListCapabilityDataDefinition> capabilities = originNodeType.getCapabilities();
1388         MapListCapabilityDataDefinition allCalculatedCap = prepareCalculatedCapabiltyForNodeType(capabilities, componentInstance);
1389         StorageOperationStatus calculatedResult;
1390         if (allCalculatedCap != null) {
1391             calculatedResult = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.CALCULATED_CAPABILITIES,
1392                 VertexTypeEnum.CALCULATED_CAPABILITIES, allCalculatedCap, componentInstance.getUniqueId());
1393             if (calculatedResult != StorageOperationStatus.OK) {
1394                 return calculatedResult;
1395             }
1396         }
1397         Map<String, MapPropertiesDataDefinition> capabiltiesProperties = originNodeType.getCapabilitiesProperties();
1398         if (capabiltiesProperties != null) {
1399             Map<String, MapPropertiesDataDefinition> updateKeyMap = capabiltiesProperties.entrySet().stream()
1400                 .collect(Collectors.toMap(e -> createCapPropertyKey(e.getKey(), componentInstance.getUniqueId()), Entry::getValue));
1401             MapCapabilityProperty mapCapabilityProperty = new MapCapabilityProperty(updateKeyMap);
1402             calculatedResult = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
1403                 VertexTypeEnum.CALCULATED_CAP_PROPERTIES, mapCapabilityProperty, componentInstance.getUniqueId());
1404             if (calculatedResult != StorageOperationStatus.OK) {
1405                 return calculatedResult;
1406             }
1407         }
1408         MapListCapabilityDataDefinition fullCalculatedCap = new MapListCapabilityDataDefinition();
1409         calculatedResult = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.FULLFILLED_CAPABILITIES,
1410             VertexTypeEnum.FULLFILLED_CAPABILITIES, fullCalculatedCap, componentInstance.getUniqueId());
1411         if (calculatedResult != StorageOperationStatus.OK) {
1412             return calculatedResult;
1413         }
1414         Map<String, ListRequirementDataDefinition> requirements = originNodeType.getRequirements();
1415         MapListRequirementDataDefinition allCalculatedReq = prepareCalculatedRequirementForNodeType(requirements, componentInstance);
1416         StorageOperationStatus status;
1417         if (allCalculatedReq != null) {
1418             status = addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.CALCULATED_REQUIREMENTS,
1419                 VertexTypeEnum.CALCULATED_REQUIREMENTS, allCalculatedReq, componentInstance.getUniqueId());
1420             if (status != StorageOperationStatus.OK) {
1421                 return status;
1422             }
1423         }
1424         MapListRequirementDataDefinition fullCalculatedReq = new MapListRequirementDataDefinition();
1425         return addToscaDataDeepElementsBlockToToscaElement(updatedContainerVertex, EdgeLabelEnum.FULLFILLED_REQUIREMENTS,
1426             VertexTypeEnum.FULLFILLED_REQUIREMENTS, fullCalculatedReq, componentInstance.getUniqueId());
1427     }
1428
1429     /**
1430      * Prepares a map of capabilities lists Produces a deep copy of the received map of capabilities Sets values to the specific fields according to
1431      * received component instance
1432      *
1433      * @param capabilities
1434      * @param componentInstance
1435      * @return
1436      */
1437     public MapListCapabilityDataDefinition prepareCalculatedCapabiltyForNodeType(Map<String, ListCapabilityDataDefinition> capabilities,
1438                                                                                  ComponentInstanceDataDefinition componentInstance) {
1439         if (capabilities != null) {
1440             MapListCapabilityDataDefinition allCalculatedCap = new MapListCapabilityDataDefinition();
1441             populateCapability(capabilities, componentInstance, allCalculatedCap);
1442             return allCalculatedCap;
1443         }
1444         return null;
1445     }
1446
1447     /**
1448      * Prepares a map of requirements lists Produces a deep copy of the received map of requirements Sets values to the specific fields according to
1449      * received component instance
1450      *
1451      * @param requirements
1452      * @param componentInstance
1453      * @return
1454      */
1455     public MapListRequirementDataDefinition prepareCalculatedRequirementForNodeType(Map<String, ListRequirementDataDefinition> requirements,
1456                                                                                     ComponentInstanceDataDefinition componentInstance) {
1457         if (requirements != null) {
1458             MapListRequirementDataDefinition allCalculatedReq = new MapListRequirementDataDefinition();
1459             populateRequirement(requirements, componentInstance, allCalculatedReq);
1460             return allCalculatedReq;
1461         }
1462         return null;
1463     }
1464
1465     public StorageOperationStatus addGroupInstancesToComponentInstance(Component containerComponent,
1466                                                                        ComponentInstanceDataDefinition componentInstance,
1467                                                                        List<GroupDefinition> groups,
1468                                                                        Map<String, List<ArtifactDefinition>> groupInstancesArtifacts) {
1469         StorageOperationStatus result = null;
1470         Map<String, GroupInstanceDataDefinition> groupInstanceToCreate = new HashMap<>();
1471         if (groupInstancesArtifacts != null && CollectionUtils.isNotEmpty(groups)) {
1472             for (Map.Entry<String, List<ArtifactDefinition>> groupArtifacts : groupInstancesArtifacts.entrySet()) {
1473                 Optional<GroupDefinition> groupOptional = groups.stream().filter(g -> g.getUniqueId().equals(groupArtifacts.getKey())).findFirst();
1474                 if (groupOptional.isPresent()) {
1475                     GroupInstanceDataDefinition groupInstance = buildGroupInstanceDataDefinition((GroupDataDefinition) groupOptional.get(),
1476                         (ComponentInstanceDataDefinition) componentInstance, null);
1477                     groupInstance.setGroupInstanceArtifacts(
1478                         groupArtifacts.getValue().stream().map(ArtifactDataDefinition::getUniqueId).collect(Collectors.toList()));
1479                     groupInstance.setGroupInstanceArtifactsUuid(
1480                         groupArtifacts.getValue().stream().map(ArtifactDataDefinition::getArtifactUUID).collect(Collectors.toList()));
1481                     groupInstanceToCreate.put(groupInstance.getName(), groupInstance);
1482                 }
1483             }
1484         }
1485         if (MapUtils.isNotEmpty(groupInstanceToCreate)) {
1486             result = addToscaDataDeepElementsBlockToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_GROUPS,
1487                 VertexTypeEnum.INST_GROUPS, new MapDataDefinition<>(groupInstanceToCreate), componentInstance.getUniqueId());
1488         }
1489         if (result == null) {
1490             result = StorageOperationStatus.OK;
1491         }
1492         return result;
1493     }
1494
1495     private ComponentInstanceDataDefinition buildComponentInstanceDataDefinition(ComponentInstance resourceInstance, String containerComponentId,
1496                                                                                  String instanceNewName, boolean generateUid,
1497                                                                                  ToscaElement originToscaElement) {
1498         String ciOriginComponentUid = resourceInstance.getComponentUid();
1499         if (!ValidationUtils.validateStringNotEmpty(resourceInstance.getCustomizationUUID())) {
1500             resourceInstance.setCustomizationUUID(generateCustomizationUUID());
1501         }
1502         ComponentInstanceDataDefinition dataDefinition = new ComponentInstanceDataDefinition(resourceInstance);
1503         Long creationDate = resourceInstance.getCreationTime();
1504         Long modificationTime;
1505         if (creationDate == null) {
1506             creationDate = System.currentTimeMillis();
1507             modificationTime = creationDate;
1508         } else {
1509             modificationTime = System.currentTimeMillis();
1510         }
1511         dataDefinition.setComponentUid(ciOriginComponentUid);
1512         dataDefinition.setCreationTime(creationDate);
1513         dataDefinition.setModificationTime(modificationTime);
1514         if (StringUtils.isNotEmpty(instanceNewName)) {
1515             dataDefinition.setName(instanceNewName);
1516             resourceInstance.setName(instanceNewName);
1517         }
1518         if (StringUtils.isNotEmpty(dataDefinition.getName())) {
1519             dataDefinition.setNormalizedName(ValidationUtils.normalizeComponentInstanceName(dataDefinition.getName()));
1520         }
1521         dataDefinition.setIcon(resourceInstance.getIcon());
1522         if (generateUid) {
1523             dataDefinition.setUniqueId(
1524                 UniqueIdBuilder.buildResourceInstanceUniuqeId(containerComponentId, ciOriginComponentUid, dataDefinition.getNormalizedName()));
1525             resourceInstance.setUniqueId(dataDefinition.getUniqueId());
1526         }
1527         if (StringUtils.isEmpty(dataDefinition.getComponentVersion()) && originToscaElement != null) {
1528             dataDefinition.setComponentVersion((String) originToscaElement.getMetadataValue(JsonPresentationFields.VERSION));
1529         }
1530         if (StringUtils.isEmpty(dataDefinition.getComponentName()) && originToscaElement != null) {
1531             dataDefinition.setComponentName((String) originToscaElement.getMetadataValue(JsonPresentationFields.NAME));
1532         }
1533         if (originToscaElement != null && dataDefinition.getToscaComponentName() == null) {
1534             dataDefinition.setToscaComponentName((String) originToscaElement.getMetadataValue(JsonPresentationFields.TOSCA_RESOURCE_NAME));
1535         }
1536         if (dataDefinition.getOriginType() == null && originToscaElement != null) {
1537             ResourceTypeEnum resourceType = originToscaElement.getResourceType();
1538             OriginTypeEnum originType = OriginTypeEnum.findByValue(resourceType.name());
1539             dataDefinition.setOriginType(originType);
1540         }
1541         if (dataDefinition.getOriginType() == OriginTypeEnum.ServiceProxy) {
1542             dataDefinition.setIsProxy(true);
1543         }
1544         return dataDefinition;
1545     }
1546
1547     private Boolean isUniqueInstanceName(TopologyTemplate container, String instanceName) {
1548         Boolean isUniqueName = true;
1549         try {
1550             isUniqueName = container.getComponentInstances().values().stream()
1551                 .noneMatch(ci -> ci.getName() != null && ci.getName().equals(instanceName));
1552         } catch (Exception e) {
1553             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
1554                 "Exception occured during fetching component instance with name {} from component container {}. {} ", instanceName,
1555                 container.getName(), e.getMessage());
1556         }
1557         return isUniqueName;
1558     }
1559
1560     private String buildComponentInstanceName(String instanceSuffixNumber, String instanceName) {
1561         return instanceName + " " + (instanceSuffixNumber == null ? 0 : instanceSuffixNumber);
1562     }
1563
1564     public Either<RequirementCapabilityRelDef, StorageOperationStatus> associateResourceInstances(Component component, String componentId,
1565                                                                                                   RequirementCapabilityRelDef relation) {
1566         List<RequirementCapabilityRelDef> relations = new ArrayList<>();
1567         relations.add(relation);
1568         Either<List<RequirementCapabilityRelDef>, StorageOperationStatus> associateResourceInstances = associateResourceInstances(component,
1569             componentId, relations);
1570         if (associateResourceInstances.isRight()) {
1571             return Either.right(associateResourceInstances.right().value());
1572         }
1573         return Either.left(associateResourceInstances.left().value().get(0));
1574     }
1575
1576     @SuppressWarnings({"unchecked"})
1577     public <T extends ToscaDataDefinition> Either<List<RequirementCapabilityRelDef>, StorageOperationStatus> associateResourceInstances(
1578         Component component, String componentId, List<RequirementCapabilityRelDef> relations) {
1579         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1580         if (containerVEither.isRight()) {
1581             JanusGraphOperationStatus error = containerVEither.right().value();
1582             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1583             return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
1584         }
1585         GraphVertex containerV = containerVEither.left().value();
1586         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capResult = fetchContainerCalculatedCapability(
1587             containerV, EdgeLabelEnum.CALCULATED_CAPABILITIES);
1588         if (capResult.isRight()) {
1589             return Either.right(capResult.right().value());
1590         }
1591         Map<String, MapListCapabilityDataDefinition> calculatedCapabilty = capResult.left().value().getRight();
1592         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capFullResult = fetchContainerCalculatedCapability(
1593             containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES);
1594         if (capResult.isRight()) {
1595             return Either.right(capResult.right().value());
1596         }
1597         Map<String, MapListCapabilityDataDefinition> fullFilledCapabilty = capFullResult.left().value().getRight();
1598         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqResult = fetchContainerCalculatedRequirement(
1599             containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS);
1600         if (reqResult.isRight()) {
1601             return Either.right(reqResult.right().value());
1602         }
1603         Map<String, MapListRequirementDataDefinition> calculatedRequirement = reqResult.left().value().getRight();
1604         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqFullResult = fetchContainerCalculatedRequirement(
1605             containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS);
1606         if (reqResult.isRight()) {
1607             return Either.right(reqResult.right().value());
1608         }
1609         Map<String, MapListRequirementDataDefinition> fullfilledRequirement = reqFullResult.left().value().getRight();
1610         Map<String, CompositionDataDefinition> jsonComposition = (Map<String, CompositionDataDefinition>) containerV.getJson();
1611         CompositionDataDefinition compositionDataDefinition = jsonComposition.get(JsonConstantKeysEnum.COMPOSITION.getValue());
1612         StorageOperationStatus status;
1613         List<RequirementCapabilityRelDef> relationsList = new ArrayList<>();
1614         for (RequirementCapabilityRelDef relation : relations) {
1615             List<CapabilityRequirementRelationship> relationshipsResult = new ArrayList<>();
1616             String fromNode = relation.getFromNode();
1617             String toNode = relation.getToNode();
1618             List<CapabilityRequirementRelationship> relationships = relation.getRelationships();
1619             if (relationships == null || relationships.isEmpty()) {
1620                 BeEcompErrorManager.getInstance()
1621                     .logBeFailedAddingResourceInstanceError("AssociateResourceInstances - missing relationship", fromNode, componentId);
1622                 CommonUtility
1623                     .addRecordToLog(log, LogLevelEnum.DEBUG, "No requirement definition sent in order to set the relation between {} to {}", fromNode,
1624                         toNode);
1625                 loggerSupportability.log(LogLevel.INFO, LoggerSupportabilityActions.CREATE_RELATION.getName(),
1626                     "componentId: " + componentId + " No requirement definition sent in order to set the relation between: " + fromNode + " to: "
1627                         + toNode);
1628                 return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(JanusGraphOperationStatus.ILLEGAL_ARGUMENT));
1629             }
1630             for (final CapabilityRequirementRelationship relationship : relationships) {
1631                 final String requirement = relationship.getRelation().getRequirement();
1632                 Either<Map<JsonPresentationFields, T>, StorageOperationStatus> associateRes = connectInstancesInContainer(fromNode, toNode,
1633                     relationship.getRelation(), relation.isOriginUI(), calculatedCapabilty, calculatedRequirement, fullFilledCapabilty,
1634                     fullfilledRequirement, compositionDataDefinition, containerV.getUniqueId());
1635                 if (associateRes.isRight()) {
1636                     status = associateRes.right().value();
1637                     BeEcompErrorManager.getInstance()
1638                         .logBeFailedAddingResourceInstanceError("AssociateResourceInstances - missing relationship", fromNode, componentId);
1639                     loggerSupportability.log(LogLevel.INFO, LoggerSupportabilityActions.CREATE_RELATIONS.name(), StatusCode.ERROR,
1640                         "missing relationship: " + fromNode, "ComopnentId: " + componentId);
1641                     CommonUtility
1642                         .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to associate resource instance {} to resource instance {}. status is {}",
1643                             fromNode, toNode, status);
1644                     return Either.right(status);
1645                 }
1646                 final Map<JsonPresentationFields, T> relationshipFieldsMap = associateRes.left().value();
1647                 final RelationshipInstDataDefinition relationshipInstData = (RelationshipInstDataDefinition) relationshipFieldsMap
1648                     .get(JsonPresentationFields.RELATIONSHIP);
1649                 createRelationshipInterfaces(relationship.getOperations()).ifPresent(relationshipInstData::setInterfaces);
1650                 RelationshipImpl relationshipImplResult = new RelationshipImpl();
1651                 relationshipImplResult.setType(relationshipInstData.getType());
1652                 RelationshipInfo requirementAndRelationshipPair = new RelationshipInfo(requirement, relationshipImplResult);
1653                 requirementAndRelationshipPair.setCapability(relationship.getRelation().getCapability());
1654                 requirementAndRelationshipPair.setRequirement(relationship.getRelation().getRequirement());
1655                 requirementAndRelationshipPair.setCapabilityOwnerId(relationshipInstData.getCapabilityOwnerId());
1656                 requirementAndRelationshipPair.setRequirementOwnerId(relationshipInstData.getRequirementOwnerId());
1657                 requirementAndRelationshipPair.setCapabilityUid(relationship.getRelation().getCapabilityUid());
1658                 requirementAndRelationshipPair.setRequirementUid(relationship.getRelation().getRequirementUid());
1659                 requirementAndRelationshipPair.setId(relationshipInstData.getUniqueId());
1660                 CapabilityRequirementRelationship capReqRel = new CapabilityRequirementRelationship();
1661                 capReqRel.setRelation(requirementAndRelationshipPair);
1662                 capReqRel.setCapability((CapabilityDataDefinition) relationshipFieldsMap.get(JsonPresentationFields.CAPABILITY));
1663                 capReqRel.setRequirement((RequirementDataDefinition) relationshipFieldsMap.get(JsonPresentationFields.REQUIREMENT));
1664                 capReqRel.setOperations(relationship.getOperations());
1665                 relationshipsResult.add(capReqRel);
1666                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "update customization UUID for from CI {} and to CI {}", relation.getFromNode(),
1667                     relation.getToNode());
1668                 status = updateCustomizationUUID(relation.getFromNode(), compositionDataDefinition);
1669                 if (status != StorageOperationStatus.OK) {
1670                     loggerSupportability.log(LogLevel.INFO, LoggerSupportabilityActions.CREATE_RELATIONS.name(), StatusCode.ERROR,
1671                         "ERROR while update customization UUID for from CI " + relation.getFromNode() + " and to CI: " + relation.getToNode());
1672                     return Either.right(status);
1673                 }
1674                 status = updateCustomizationUUID(relation.getToNode(), compositionDataDefinition);
1675                 if (status != StorageOperationStatus.OK) {
1676                     loggerSupportability.log(LogLevel.INFO, LoggerSupportabilityActions.CREATE_RELATIONS.name(), StatusCode.ERROR,
1677                         "ERROR while update customization UUID for from CI " + relation.getFromNode() + " and to CI: " + relation.getToNode());
1678                     return Either.right(status);
1679                 }
1680             }
1681             RequirementCapabilityRelDef reqCapRelDef = new RequirementCapabilityRelDef(relation);
1682             reqCapRelDef.setRelationships(relationshipsResult);
1683             relationsList.add(reqCapRelDef);
1684         }
1685         status = updateAllAndCalculatedCapReqOnGraph(componentId, containerV, capResult, capFullResult, reqResult, reqFullResult);
1686         if (status != StorageOperationStatus.OK) {
1687             return Either.right(status);
1688         }
1689         return Either.left(relationsList);
1690     }
1691
1692     private Optional<ListDataDefinition<InterfaceDataDefinition>> createRelationshipInterfaces(final List<OperationUi> operationList) {
1693         if (CollectionUtils.isEmpty(operationList)) {
1694             return Optional.empty();
1695         }
1696         final ListDataDefinition<InterfaceDataDefinition> interfaceList = new ListDataDefinition<>();
1697         final Map<String, List<OperationUi>> operationByInterfaceType = operationList.stream()
1698             .collect(Collectors.groupingBy(OperationUi::getInterfaceType));
1699         for (final Entry<String, List<OperationUi>> interfaceEntry : operationByInterfaceType.entrySet()) {
1700             interfaceList.add(createInterface(interfaceEntry.getKey(), interfaceEntry.getValue()));
1701         }
1702         return Optional.of(interfaceList);
1703     }
1704
1705     private InterfaceDataDefinition createInterface(final String interfaceType, final List<OperationUi> operationList) {
1706         final InterfaceDataDefinition interfaceDataDefinition = new InterfaceDataDefinition();
1707         interfaceDataDefinition.setType(interfaceType);
1708         if (CollectionUtils.isNotEmpty(operationList)) {
1709             final Map<String, OperationDataDefinition> operationMap = operationList.stream()
1710                 .collect(Collectors.toMap(OperationUi::getOperationType, this::createOperation));
1711             interfaceDataDefinition.setOperations(operationMap);
1712         }
1713         return interfaceDataDefinition;
1714     }
1715
1716     private OperationDataDefinition createOperation(final OperationUi operation) {
1717         final OperationDataDefinition operationDataDefinition = new OperationDataDefinition();
1718         operationDataDefinition.setName(operation.getOperationType());
1719         operationDataDefinition.setUniqueId(UUID.randomUUID().toString());
1720         final ArtifactDataDefinition implementation = new ArtifactDataDefinition();
1721         implementation.setArtifactName(operation.getImplementation());
1722         operationDataDefinition.setImplementation(implementation);
1723         if (CollectionUtils.isNotEmpty(operation.getInputs())) {
1724             final ListDataDefinition<OperationInputDefinition> inputs = new ListDataDefinition<>();
1725             operation.getInputs().forEach(input -> {
1726                 final OperationInputDefinition operationInputDefinition = new OperationInputDefinition();
1727                 operationInputDefinition.setLabel(input.getName());
1728                 operationInputDefinition.setType(input.getType());
1729                 operationInputDefinition.setValue(input.getValue());
1730                 inputs.add(operationInputDefinition);
1731             });
1732             operationDataDefinition.setInputs(inputs);
1733         }
1734         return operationDataDefinition;
1735     }
1736
1737     private StorageOperationStatus updateAllAndCalculatedCapReqOnGraph(String componentId, GraphVertex containerV,
1738                                                                        Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capResult,
1739                                                                        Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capFullResult,
1740                                                                        Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqResult,
1741                                                                        Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqFullResult) {
1742         containerV.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
1743         Either<GraphVertex, JanusGraphOperationStatus> updateElement = janusGraphDao.updateVertex(containerV);
1744         if (updateElement.isRight()) {
1745             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update topology template {} with new relations error {}. ", componentId,
1746                 updateElement.right().value());
1747             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value());
1748         }
1749         // update cap/req jsons, fulfilled cap/req jsons!!!!!
1750         Either<GraphVertex, JanusGraphOperationStatus> status;
1751         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Update calculated capabilty for container {}", containerV.getUniqueId());
1752         status = updateOrCopyOnUpdate(capResult.left().value().getLeft(), containerV, EdgeLabelEnum.CALCULATED_CAPABILITIES);
1753         if (status.isRight()) {
1754             JanusGraphOperationStatus error = status.right().value();
1755             CommonUtility
1756                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update calculated capabilty for container {} error {}", containerV.getUniqueId(),
1757                     error);
1758             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1759         }
1760         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Update calculated requirement for container {}", containerV.getUniqueId());
1761         status = updateOrCopyOnUpdate(reqResult.left().value().getLeft(), containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS);
1762         if (status.isRight()) {
1763             JanusGraphOperationStatus error = status.right().value();
1764             CommonUtility
1765                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update calculated requiremnt for container {} error {}", containerV.getUniqueId(),
1766                     error);
1767             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1768         }
1769         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Update fullfilled capabilty for container {}", containerV.getUniqueId());
1770         status = updateOrCopyOnUpdate(capFullResult.left().value().getLeft(), containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES);
1771         if (status.isRight()) {
1772             JanusGraphOperationStatus error = status.right().value();
1773             CommonUtility
1774                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update fullfilled capabilty for container {} error {}", containerV.getUniqueId(),
1775                     error);
1776             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1777         }
1778         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Update fullfilled requirement for container {}", containerV.getUniqueId());
1779         status = updateOrCopyOnUpdate(reqFullResult.left().value().getLeft(), containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS);
1780         if (status.isRight()) {
1781             JanusGraphOperationStatus error = status.right().value();
1782             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update fullfilled requirement for container {} error {}",
1783                 containerV.getUniqueId(), error);
1784             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error);
1785         }
1786         return StorageOperationStatus.OK;
1787     }
1788
1789     @SuppressWarnings({"unchecked"})
1790     public Either<RequirementCapabilityRelDef, StorageOperationStatus> dissociateResourceInstances(String componentId,
1791                                                                                                    RequirementCapabilityRelDef requirementDef) {
1792         if (requirementDef.getRelationships() == null) {
1793             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No relation pair in request [ {} ]", requirementDef);
1794             return Either.right(StorageOperationStatus.BAD_REQUEST);
1795         }
1796         String fromResInstanceUid = requirementDef.getFromNode();
1797         String toResInstanceUid = requirementDef.getToNode();
1798         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1799         if (containerVEither.isRight()) {
1800             JanusGraphOperationStatus error = containerVEither.right().value();
1801             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1802             return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
1803         }
1804         GraphVertex containerV = containerVEither.left().value();
1805         // DE191707 - validations
1806         Map<String, CompositionDataDefinition> jsonComposition = (Map<String, CompositionDataDefinition>) containerV.getJson();
1807         CompositionDataDefinition compositionDataDefinition = jsonComposition.get(JsonConstantKeysEnum.COMPOSITION.getValue());
1808         Map<String, ComponentInstanceDataDefinition> componentInstances = compositionDataDefinition.getComponentInstances();
1809         ComponentInstanceDataDefinition ciFrom = componentInstances.get(fromResInstanceUid);
1810         if (ciFrom == null) {
1811             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "FROM instance {} isn't under container {}", fromResInstanceUid, componentId);
1812             return Either.right(StorageOperationStatus.NOT_FOUND);
1813         }
1814         ComponentInstanceDataDefinition ciTo = componentInstances.get(toResInstanceUid);
1815         if (ciFrom == ciTo) {
1816             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "TO instance {} isn't under container {}", toResInstanceUid, componentId);
1817             return Either.right(StorageOperationStatus.NOT_FOUND);
1818         }
1819         Map<String, RelationshipInstDataDefinition> relations = compositionDataDefinition.getRelations();
1820         List<CapabilityRequirementRelationship> relationPairList = requirementDef.getRelationships();
1821         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capResult = fetchContainerCalculatedCapability(
1822             containerV, EdgeLabelEnum.CALCULATED_CAPABILITIES);
1823         if (capResult.isRight()) {
1824             return Either.right(capResult.right().value());
1825         }
1826         Map<String, MapListCapabilityDataDefinition> calculatedCapability = capResult.left().value().getRight();
1827         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capFullResult = fetchContainerCalculatedCapability(
1828             containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES);
1829         if (capResult.isRight()) {
1830             return Either.right(capResult.right().value());
1831         }
1832         Map<String, MapListCapabilityDataDefinition> fulfilledCapability = capFullResult.left().value().getRight();
1833         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqResult = fetchContainerCalculatedRequirement(
1834             containerV, EdgeLabelEnum.CALCULATED_REQUIREMENTS);
1835         if (reqResult.isRight()) {
1836             return Either.right(reqResult.right().value());
1837         }
1838         Map<String, MapListRequirementDataDefinition> calculatedRequirement = reqResult.left().value().getRight();
1839         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqFullResult = fetchContainerCalculatedRequirement(
1840             containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS);
1841         if (reqResult.isRight()) {
1842             return Either.right(reqResult.right().value());
1843         }
1844         Map<String, MapListRequirementDataDefinition> fulfilledRequirement = reqFullResult.left().value().getRight();
1845         for (CapabilityRequirementRelationship relationPair : relationPairList) {
1846             Iterator<Entry<String, RelationshipInstDataDefinition>> iterator = relations.entrySet().iterator();
1847             boolean isDeleted = false;
1848             while (iterator.hasNext()) {
1849                 Entry<String, RelationshipInstDataDefinition> entryInJson = iterator.next();
1850                 RelationshipInstDataDefinition relationInJson = entryInJson.getValue();
1851                 if (relationInJson.getFromId().equals(fromResInstanceUid) && relationInJson.getToId().equals(toResInstanceUid) && relationInJson
1852                     .getUniqueId().equals(relationPair.getRelation().getId())) {
1853                     if (relationPair.getRelation().equalsTo(relationInJson)) {
1854                         CommonUtility
1855                             .addRecordToLog(log, LogLevelEnum.DEBUG, "Remove relation from {} to {} capability {} capOwnerId {} reqOwnerId {} ",
1856                                 toResInstanceUid, componentId, relationInJson.getType(), relationInJson.getCapabilityOwnerId(),
1857                                 relationInJson.getRequirementOwnerId());
1858                         iterator.remove();
1859                         // update calculated cap/req
1860                         StorageOperationStatus status = updateCalculatedCapabiltyAfterDeleteRelation(calculatedCapability, fulfilledCapability,
1861                             toResInstanceUid, relationInJson, relationPair);
1862                         if (status != StorageOperationStatus.OK) {
1863                             return Either.right(status);
1864                         }
1865                         status = updateCalculatedRequirementsAfterDeleteRelation(calculatedRequirement, fulfilledRequirement, fromResInstanceUid,
1866                             relationInJson, relationPair);
1867                         if (status != StorageOperationStatus.OK) {
1868                             return Either.right(status);
1869                         }
1870                         isDeleted = true;
1871                     }
1872                 }
1873             }
1874             if (!isDeleted) {
1875                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No relation to delete from {} to {} capabilty {} capOwnerId {} reqOwnerId {} ",
1876                     toResInstanceUid, componentId, relationPair.getCapability(), relationPair.getRelation().getCapabilityOwnerId(),
1877                     relationPair.getRelation().getRequirementOwnerId());
1878                 return Either.right(StorageOperationStatus.NOT_FOUND);
1879             }
1880         }
1881         StorageOperationStatus status = updateCustomizationUUID(fromResInstanceUid, compositionDataDefinition);
1882         if (status != StorageOperationStatus.OK) {
1883             return Either.right(status);
1884         }
1885         status = updateCustomizationUUID(toResInstanceUid, compositionDataDefinition);
1886         if (status != StorageOperationStatus.OK) {
1887             return Either.right(status);
1888         }
1889         // update jsons
1890
1891         // update metadata of container and composition json
1892         status = updateAllAndCalculatedCapReqOnGraph(componentId, containerV, capResult, capFullResult, reqResult, reqFullResult);
1893         if (status != StorageOperationStatus.OK) {
1894             return Either.right(status);
1895         }
1896         return Either.left(requirementDef);
1897     }
1898
1899     /**
1900      * Retrieves fulfilled requirement according to relation and received predicate
1901      *
1902      * @param componentId
1903      * @param instanceId
1904      * @param foundRelation
1905      * @param predicate
1906      * @return
1907      */
1908     public Either<RequirementDataDefinition, StorageOperationStatus> getFulfilledRequirementByRelation(String componentId, String instanceId,
1909                                                                                                        RequirementCapabilityRelDef foundRelation,
1910                                                                                                        BiPredicate<RelationshipInfo, RequirementDataDefinition> predicate) {
1911         Either<RequirementDataDefinition, StorageOperationStatus> result = null;
1912         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> reqFullResult = null;
1913         MapListRequirementDataDefinition reqMapOfLists = null;
1914         Optional<RequirementDataDefinition> foundRequirement;
1915         RelationshipInfo relationshipInfo = foundRelation.resolveSingleRelationship().getRelation();
1916         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1917         if (containerVEither.isRight()) {
1918             JanusGraphOperationStatus error = containerVEither.right().value();
1919             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1920             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
1921         }
1922         if (result == null) {
1923             GraphVertex containerV = containerVEither.left().value();
1924             reqFullResult = fetchContainerCalculatedRequirement(containerV, EdgeLabelEnum.FULLFILLED_REQUIREMENTS);
1925             if (reqFullResult.isRight()) {
1926                 result = Either.right(reqFullResult.right().value());
1927             }
1928         }
1929         if (result == null) {
1930             Map<String, MapListRequirementDataDefinition> fulfilledRequirement = reqFullResult.left().value().getRight();
1931             reqMapOfLists = fulfilledRequirement.get(instanceId);
1932             if (reqMapOfLists == null) {
1933                 result = Either.right(StorageOperationStatus.NOT_FOUND);
1934             }
1935         }
1936         if (result == null && reqMapOfLists != null) {
1937             for (ListRequirementDataDefinition requirements : reqMapOfLists.getMapToscaDataDefinition().values()) {
1938                 foundRequirement = requirements.getListToscaDataDefinition().stream().filter(req -> predicate.test(relationshipInfo, req))
1939                     .findFirst();
1940                 if (foundRequirement.isPresent()) {
1941                     result = Either.left(foundRequirement.get());
1942                 }
1943             }
1944         }
1945         return result;
1946     }
1947
1948     /**
1949      * Retrieves fulfilled capability according to relation and received predicate
1950      *
1951      * @param componentId
1952      * @param instanceId
1953      * @param foundRelation
1954      * @param predicate
1955      * @return
1956      */
1957     public Either<CapabilityDataDefinition, StorageOperationStatus> getFulfilledCapabilityByRelation(String componentId, String instanceId,
1958                                                                                                      RequirementCapabilityRelDef foundRelation,
1959                                                                                                      BiPredicate<RelationshipInfo, CapabilityDataDefinition> predicate) {
1960         Either<CapabilityDataDefinition, StorageOperationStatus> result = null;
1961         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> capFullResult = null;
1962         MapListCapabilityDataDefinition capMapOfLists = null;
1963         Optional<CapabilityDataDefinition> foundRequirement;
1964         RelationshipInfo relationshipInfo = foundRelation.resolveSingleRelationship().getRelation();
1965         Either<GraphVertex, JanusGraphOperationStatus> containerVEither = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
1966         if (containerVEither.isRight()) {
1967             JanusGraphOperationStatus error = containerVEither.right().value();
1968             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, FAILED_TO_FETCH_CONTAINER_VERTEX_ERROR, componentId, error);
1969             result = Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
1970         }
1971         if (result == null) {
1972             GraphVertex containerV = containerVEither.left().value();
1973             capFullResult = fetchContainerCalculatedCapability(containerV, EdgeLabelEnum.FULLFILLED_CAPABILITIES);
1974             if (capFullResult.isRight()) {
1975                 result = Either.right(capFullResult.right().value());
1976             }
1977         }
1978         if (result == null) {
1979             Map<String, MapListCapabilityDataDefinition> fulfilledCapability = capFullResult.left().value().getRight();
1980             capMapOfLists = fulfilledCapability.get(instanceId);
1981             if (capMapOfLists == null) {
1982                 result = Either.right(StorageOperationStatus.NOT_FOUND);
1983             }
1984         }
1985         if (result == null && capMapOfLists != null) {
1986             for (ListCapabilityDataDefinition capabilities : capMapOfLists.getMapToscaDataDefinition().values()) {
1987                 foundRequirement = capabilities.getListToscaDataDefinition().stream().filter(cap -> predicate.test(relationshipInfo, cap))
1988                     .findFirst();
1989                 if (foundRequirement.isPresent()) {
1990                     result = Either.left(foundRequirement.get());
1991                 }
1992             }
1993         }
1994         return result;
1995     }
1996
1997     private StorageOperationStatus updateCalculatedRequirementsAfterDeleteRelation(
1998         Map<String, MapListRequirementDataDefinition> calculatedRequirement, Map<String, MapListRequirementDataDefinition> fullFilledRequirement,
1999         String fromResInstanceUid, RelationshipInstDataDefinition relation, CapabilityRequirementRelationship relationship) {
2000         StorageOperationStatus status;
2001         String hereIsTheKey = null;
2002         MapListRequirementDataDefinition reqByInstance = calculatedRequirement.get(fromResInstanceUid);
2003         if (reqByInstance == null || reqByInstance.findKeyByItemUidMatch(relation.getRequirementId()) == null) {
2004             // move from fulfilled
2005             status = moveFromFullFilledRequirement(calculatedRequirement, fullFilledRequirement, fromResInstanceUid, relation, hereIsTheKey,
2006                 relationship);
2007         } else {
2008             hereIsTheKey = reqByInstance.findKeyByItemUidMatch(relation.getRequirementId());
2009             ListRequirementDataDefinition reqByType = reqByInstance.findByKey(hereIsTheKey);
2010             Optional<RequirementDataDefinition> requirementOptional = reqByType.getListToscaDataDefinition().stream().filter(
2011                 req -> req.getOwnerId().equals(relation.getRequirementOwnerId()) && req.getName().equals(relation.getRequirement()) && req
2012                     .getUniqueId().equals(relation.getRequirementId())).findFirst();
2013             if (requirementOptional.isPresent()) {
2014                 RequirementDataDefinition requirement = requirementOptional.get();
2015                 String leftOccurrences = requirement.getLeftOccurrences();
2016                 if (leftOccurrences != null && !leftOccurrences.equals(RequirementDataDefinition.MAX_OCCURRENCES)) {
2017                     Integer leftIntValue = Integer.parseInt(leftOccurrences);
2018                     ++leftIntValue;
2019                     requirement.setLeftOccurrences(String.valueOf(leftIntValue));
2020                 }
2021                 if (relationship != null) {
2022                     relationship.setRequirement(requirement);
2023                 }
2024                 status = StorageOperationStatus.OK;
2025             } else {
2026                 // move from fulfilled
2027                 status = moveFromFullFilledRequirement(calculatedRequirement, fullFilledRequirement, fromResInstanceUid, relation, hereIsTheKey,
2028                     relationship);
2029             }
2030         }
2031         return status;
2032     }
2033
2034     private StorageOperationStatus updateCalculatedCapabiltyAfterDeleteRelation(Map<String, MapListCapabilityDataDefinition> calculatedCapability,
2035                                                                                 Map<String, MapListCapabilityDataDefinition> fullFilledCapability,
2036                                                                                 String toResInstanceUid, RelationshipInstDataDefinition relation,
2037                                                                                 CapabilityRequirementRelationship relationship) {
2038         StorageOperationStatus status;
2039         String hereIsTheKey = null;
2040         MapListCapabilityDataDefinition capByInstance = calculatedCapability.get(toResInstanceUid);
2041         if (capByInstance == null || capByInstance.findKeyByItemUidMatch(relation.getCapabilityId()) == null) {
2042             // move from fulfilled
2043             status = moveFromFullFilledCapabilty(calculatedCapability, fullFilledCapability, toResInstanceUid, relation, hereIsTheKey, relationship);
2044         } else {
2045             hereIsTheKey = capByInstance.findKeyByItemUidMatch(relation.getCapabilityId());
2046             ListCapabilityDataDefinition capByType = capByInstance.findByKey(hereIsTheKey);
2047             Optional<CapabilityDataDefinition> capabilityOptional = capByType.getListToscaDataDefinition().stream()
2048                 .filter(cap -> cap.getOwnerId().equals(relation.getCapabilityOwnerId()) && cap.getUniqueId().equals(relation.getCapabilityId()))
2049                 .findFirst();
2050             if (capabilityOptional.isPresent()) {
2051                 CapabilityDataDefinition capability = capabilityOptional.get();
2052                 String leftOccurrences = capability.getLeftOccurrences();
2053                 if (leftOccurrences != null && !leftOccurrences.equals(CapabilityDataDefinition.MAX_OCCURRENCES)) {
2054                     Integer leftIntValue = Integer.parseInt(leftOccurrences);
2055                     ++leftIntValue;
2056                     capability.setLeftOccurrences(String.valueOf(leftIntValue));
2057                 }
2058                 if (relationship != null) {
2059                     relationship.setCapability(capability);
2060                 }
2061                 status = StorageOperationStatus.OK;
2062             } else {
2063                 // move from fulfilled
2064                 status = moveFromFullFilledCapabilty(calculatedCapability, fullFilledCapability, toResInstanceUid, relation, hereIsTheKey,
2065                     relationship);
2066             }
2067         }
2068         return status;
2069     }
2070
2071     private StorageOperationStatus moveFromFullFilledCapabilty(Map<String, MapListCapabilityDataDefinition> calculatedCapability,
2072                                                                Map<String, MapListCapabilityDataDefinition> fullFilledCapability,
2073                                                                String toResInstanceUid, RelationshipInstDataDefinition relation, String hereIsTheKey,
2074                                                                CapabilityRequirementRelationship relationship) {
2075         MapListCapabilityDataDefinition capByInstance = fullFilledCapability.get(toResInstanceUid);
2076         if (capByInstance == null) {
2077             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No capability in fulfilled list for instance {} ", toResInstanceUid);
2078             return StorageOperationStatus.GENERAL_ERROR;
2079         }
2080         if (null == hereIsTheKey) {
2081             hereIsTheKey = capByInstance.findKeyByItemUidMatch(relation.getCapabilityId());
2082         }
2083         if (null == hereIsTheKey) {
2084             CommonUtility
2085                 .addRecordToLog(log, LogLevelEnum.DEBUG, "No capability with id {} in fulfilled list for instance {} ", relation.getCapabilityId(),
2086                     toResInstanceUid);
2087             return StorageOperationStatus.GENERAL_ERROR;
2088         }
2089         ListCapabilityDataDefinition capByType = capByInstance.findByKey(hereIsTheKey);
2090         Iterator<CapabilityDataDefinition> iterator = capByType.getListToscaDataDefinition().iterator();
2091         boolean found = false;
2092         while (iterator.hasNext()) {
2093             CapabilityDataDefinition cap = iterator.next();
2094             if (cap.getOwnerId().equals(relation.getCapabilityOwnerId()) && cap.getUniqueId().equals(relation.getCapabilityId())) {
2095                 found = true;
2096                 iterator.remove();
2097                 // return to calculated list
2098                 String leftOccurrences = cap.getLeftOccurrences();
2099                 Integer leftIntValue = Integer.parseInt(leftOccurrences);
2100                 ++leftIntValue;
2101                 cap.setLeftOccurrences(String.valueOf(leftIntValue));
2102                 MapListCapabilityDataDefinition mapListCapaDataDef = calculatedCapability.get(toResInstanceUid);
2103                 if (mapListCapaDataDef == null) {
2104                     mapListCapaDataDef = new MapListCapabilityDataDefinition();
2105                 }
2106                 ListCapabilityDataDefinition findByKey = mapListCapaDataDef.findByKey(hereIsTheKey);
2107                 if (findByKey == null) {
2108                     findByKey = new ListCapabilityDataDefinition();
2109                     mapListCapaDataDef.put(hereIsTheKey, findByKey);
2110                 }
2111                 findByKey.add(cap);
2112                 if (relationship != null) {
2113                     relationship.setCapability(cap);
2114                 }
2115                 break;
2116             }
2117         }
2118         if (!found) {
2119             CommonUtility
2120                 .addRecordToLog(log, LogLevelEnum.DEBUG, "No capability type {} with ownerId {} in fulfilled list for instance {} ", hereIsTheKey,
2121                     relation.getCapabilityOwnerId(), toResInstanceUid);
2122             return StorageOperationStatus.GENERAL_ERROR;
2123         }
2124         return StorageOperationStatus.OK;
2125     }
2126
2127     private StorageOperationStatus moveFromFullFilledRequirement(Map<String, MapListRequirementDataDefinition> calculatedRequirement,
2128                                                                  Map<String, MapListRequirementDataDefinition> fullFilledRequirement,
2129                                                                  String fromResInstanceUid, RelationshipInstDataDefinition relation,
2130                                                                  String hereIsTheKey, CapabilityRequirementRelationship relationship) {
2131         MapListRequirementDataDefinition reqByInstance = fullFilledRequirement.get(fromResInstanceUid);
2132         if (reqByInstance == null) {
2133             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No requirement in fullfilled list for instance {} ", fromResInstanceUid);
2134             return StorageOperationStatus.GENERAL_ERROR;
2135         }
2136         if (null == hereIsTheKey) {
2137             hereIsTheKey = reqByInstance.findKeyByItemUidMatch(relation.getRequirementId());
2138         }
2139         if (null == hereIsTheKey) {
2140             CommonUtility
2141                 .addRecordToLog(log, LogLevelEnum.DEBUG, "No requirement with id {} in fulfilled list for instance {} ", relation.getRequirementId(),
2142                     fromResInstanceUid);
2143             return StorageOperationStatus.GENERAL_ERROR;
2144         }
2145         ListRequirementDataDefinition reqByType = reqByInstance.findByKey(hereIsTheKey);
2146         Iterator<RequirementDataDefinition> iterator = reqByType.getListToscaDataDefinition().iterator();
2147         boolean found = false;
2148         while (iterator.hasNext()) {
2149             RequirementDataDefinition req = iterator.next();
2150             if (req.getOwnerId().equals(relation.getRequirementOwnerId()) && req.getName().equals(relation.getRequirement()) && req.getUniqueId()
2151                 .equals(relation.getRequirementId())) {
2152                 found = true;
2153                 iterator.remove();
2154                 // return to calculated list
2155                 String leftOccurrences = req.getLeftOccurrences();
2156                 Integer leftIntValue = Integer.parseInt(leftOccurrences);
2157                 ++leftIntValue;
2158                 req.setLeftOccurrences(String.valueOf(leftIntValue));
2159                 MapListRequirementDataDefinition mapListReqDataDef = calculatedRequirement.get(fromResInstanceUid);
2160                 if (mapListReqDataDef == null) {
2161                     mapListReqDataDef = new MapListRequirementDataDefinition();
2162                 }
2163                 ListRequirementDataDefinition findByKey = mapListReqDataDef.findByKey(hereIsTheKey);
2164                 if (findByKey == null) {
2165                     findByKey = new ListRequirementDataDefinition();
2166                     mapListReqDataDef.put(hereIsTheKey, findByKey);
2167                 }
2168                 findByKey.add(req);
2169                 if (relationship != null) {
2170                     relationship.setRequirement(req);
2171                 }
2172                 break;
2173             }
2174         }
2175         if (!found) {
2176             CommonUtility
2177                 .addRecordToLog(log, LogLevelEnum.DEBUG, "No requirement type {} with ownerId {} in fulfilled list for instance {} ", hereIsTheKey,
2178                     relation.getRequirementOwnerId(), fromResInstanceUid);
2179             return StorageOperationStatus.GENERAL_ERROR;
2180         }
2181         return StorageOperationStatus.OK;
2182     }
2183
2184     public StorageOperationStatus updateCustomizationUUID(String componentInstanceId, CompositionDataDefinition compositionDataDefinition) {
2185         ComponentInstanceDataDefinition componentInstance = compositionDataDefinition.getComponentInstances().get(componentInstanceId);
2186         if (componentInstance == null) {
2187             CommonUtility
2188                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch component instance by id {} from map of instances ", componentInstanceId);
2189             return StorageOperationStatus.NOT_FOUND;
2190         }
2191         UUID uuid = UUID.randomUUID();
2192         componentInstance.setCustomizationUUID(uuid.toString());
2193         return StorageOperationStatus.OK;
2194     }
2195
2196     public <T extends ToscaDataDefinition> Either<Map<JsonPresentationFields, T>, StorageOperationStatus> connectInstancesInContainer(
2197         String fromResInstanceUid, String toResInstanceUid, RelationshipInfo relationPair, boolean originUI,
2198         Map<String, MapListCapabilityDataDefinition> calculatedCapabilty, Map<String, MapListRequirementDataDefinition> calculatedRequirement,
2199         Map<String, MapListCapabilityDataDefinition> fullfilledCapabilty, Map<String, MapListRequirementDataDefinition> fullfilledRequirement,
2200         CompositionDataDefinition compositionDataDefinition, String containerId) {
2201         String requirement = relationPair.getRequirement();
2202         Map<String, ComponentInstanceDataDefinition> componentInstances = compositionDataDefinition.getComponentInstances();
2203         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
2204             "Going to associate resource instance {} to resource instance {} under component {}. Requirement is {}.", fromResInstanceUid,
2205             toResInstanceUid, containerId, requirement);
2206         ComponentInstanceDataDefinition fromResourceInstData = componentInstances.get(fromResInstanceUid);
2207         if (fromResourceInstData == null) {
2208             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to find from resource instance {}.", fromResInstanceUid);
2209             return Either.right(StorageOperationStatus.NOT_FOUND);
2210         }
2211         ComponentInstanceDataDefinition toResourceInstData = componentInstances.get(toResInstanceUid);
2212         if (toResourceInstData == null) {
2213             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to find to resource instance {}.", toResInstanceUid);
2214             return Either.right(StorageOperationStatus.NOT_FOUND);
2215         }
2216         Either<Map<JsonPresentationFields, T>, StorageOperationStatus> reqVsCap = connectRequirementVsCapability(fromResourceInstData,
2217             toResourceInstData, relationPair, originUI, calculatedCapabilty, calculatedRequirement, fullfilledCapabilty, fullfilledRequirement,
2218             containerId);
2219         if (reqVsCap.isRight()) {
2220             StorageOperationStatus status = reqVsCap.right().value();
2221             CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG,
2222                 "Failed to connect requirement {} between resource instance {} to resource instance {}. status is {}", requirement,
2223                 fromResInstanceUid, toResInstanceUid, status);
2224             return Either.right(status);
2225         }
2226         Map<JsonPresentationFields, T> relationship = reqVsCap.left().value();
2227         // add to json new relations
2228         compositionDataDefinition.addRelation(((RelationshipInstDataDefinition) relationship.get(JsonPresentationFields.RELATIONSHIP)).getUniqueId(),
2229             (RelationshipInstDataDefinition) relationship.get(JsonPresentationFields.RELATIONSHIP));
2230         return Either.left(relationship);
2231     }
2232
2233     private Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, StorageOperationStatus> fetchContainerCalculatedCapability(
2234         GraphVertex containerV, EdgeLabelEnum capLabel) {
2235         Either<Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>>, JanusGraphOperationStatus> calculatedCapabiltyEither = getDataAndVertexFromGraph(
2236             containerV, capLabel);
2237         if (calculatedCapabiltyEither.isRight()) {
2238             JanusGraphOperationStatus error = calculatedCapabiltyEither.right().value();
2239             CommonUtility
2240                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated capabilties for container {}.", containerV.getUniqueId(), error);
2241             return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
2242         }
2243         Pair<GraphVertex, Map<String, MapListCapabilityDataDefinition>> calculatedCapabilty = calculatedCapabiltyEither.left().value();
2244         return Either.left(calculatedCapabilty);
2245     }
2246
2247     private Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, StorageOperationStatus> fetchContainerCalculatedRequirement(
2248         GraphVertex containerV, EdgeLabelEnum reqLabel) {
2249         Either<Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>>, JanusGraphOperationStatus> calculatedRequirementEither = getDataAndVertexFromGraph(
2250             containerV, reqLabel);
2251         if (calculatedRequirementEither.isRight()) {
2252             JanusGraphOperationStatus error = calculatedRequirementEither.right().value();
2253             CommonUtility
2254                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated requirements for container {}.", containerV.getUniqueId(),
2255                     error);
2256             return Either.right(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(error));
2257         }
2258         Pair<GraphVertex, Map<String, MapListRequirementDataDefinition>> calculatedRequirement = calculatedRequirementEither.left().value();
2259         return Either.left(calculatedRequirement);
2260     }
2261
2262     @SuppressWarnings("unchecked")
2263     private <T extends ToscaDataDefinition> Either<Map<JsonPresentationFields, T>, StorageOperationStatus> connectRequirementVsCapability(
2264         ComponentInstanceDataDefinition fromResInstance, ComponentInstanceDataDefinition toResInstance, RelationshipInfo relationPair,
2265         boolean originUI, Map<String, MapListCapabilityDataDefinition> calculatedCapabilty,
2266         Map<String, MapListRequirementDataDefinition> calculatedRequirement, Map<String, MapListCapabilityDataDefinition> fullfilledCapabilty,
2267         Map<String, MapListRequirementDataDefinition> fullfilledRequirement, String containerId) {
2268         String type = relationPair.getRelationship().getType();
2269         // capability
2270         String toInstId = toResInstance.getUniqueId();
2271         MapListCapabilityDataDefinition mapListCapabilityDataDefinition = calculatedCapabilty.get(toInstId);
2272         Map<JsonPresentationFields, T> capReqRelationship = new EnumMap<>(JsonPresentationFields.class);
2273         if (mapListCapabilityDataDefinition == null) {
2274             CommonUtility
2275                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated capabilities for instance {} in container {}.", toInstId,
2276                     containerId);
2277             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2278         }
2279         ListCapabilityDataDefinition listCapabilityDataDefinition = mapListCapabilityDataDefinition.getMapToscaDataDefinition().get(type);
2280         if (listCapabilityDataDefinition == null) {
2281             CommonUtility
2282                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated capabilities for type {} for instance {} in container {}.", type,
2283                     toInstId, containerId);
2284             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2285         }
2286         CapabilityDataDefinition capabilityForRelation = null;
2287         Iterator<CapabilityDataDefinition> iteratorCap = listCapabilityDataDefinition.getListToscaDataDefinition().iterator();
2288         while (iteratorCap.hasNext()) {
2289             CapabilityDataDefinition cap = iteratorCap.next();
2290             if (cap.getUniqueId().equals(relationPair.getCapabilityUid()) && cap.getOwnerId().equals(relationPair.getCapabilityOwnerId())) {
2291                 capabilityForRelation = cap;
2292                 capReqRelationship.put(JsonPresentationFields.CAPABILITY, (T) capabilityForRelation);
2293                 String leftOccurrences = cap.getLeftOccurrences();
2294                 if (leftOccurrences != null && !leftOccurrences.equals(CapabilityDataDefinition.MAX_OCCURRENCES)) {
2295                     Integer leftIntValue = Integer.parseInt(leftOccurrences);
2296                     if (leftIntValue > 0) {
2297                         --leftIntValue;
2298                         capabilityForRelation.setLeftOccurrences(String.valueOf(leftIntValue));
2299                         if (leftIntValue == 0) {
2300                             // remove from calculated
2301                             iteratorCap.remove();
2302                             // move to fulfilled
2303                             MapListCapabilityDataDefinition mapListCapabiltyFullFilledInst = fullfilledCapabilty.get(toInstId);
2304                             if (mapListCapabiltyFullFilledInst == null) {
2305                                 mapListCapabiltyFullFilledInst = new MapListCapabilityDataDefinition();
2306                                 fullfilledCapabilty.put(toInstId, mapListCapabiltyFullFilledInst);
2307                             }
2308                             ListCapabilityDataDefinition listCapabilityFull = mapListCapabiltyFullFilledInst.findByKey(type);
2309                             if (listCapabilityFull == null) {
2310                                 listCapabilityFull = new ListCapabilityDataDefinition();
2311                                 mapListCapabiltyFullFilledInst.put(type, listCapabilityFull);
2312                             }
2313                             listCapabilityFull.add(capabilityForRelation);
2314                         }
2315                         break;
2316                     } else {
2317                         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No left occurrences capabilty {} to {} in container {}.",
2318                             capabilityForRelation.getType(), toInstId, containerId);
2319                         return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2320                     }
2321                 }
2322             }
2323         }
2324         if (capabilityForRelation == null) {
2325             CommonUtility
2326                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch capabilty for type {} for instance {} in container {}.", type, toInstId,
2327                     containerId);
2328             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2329         }
2330         // requirements
2331         String fromInstId = fromResInstance.getUniqueId();
2332         MapListRequirementDataDefinition mapListRequirementDataDefinition = calculatedRequirement.get(fromInstId);
2333         if (mapListRequirementDataDefinition == null) {
2334             CommonUtility
2335                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated requirements for instance {} in container {}.", fromInstId,
2336                     containerId);
2337             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2338         }
2339         ListRequirementDataDefinition listRequirementDataDefinition = mapListRequirementDataDefinition.getMapToscaDataDefinition().get(type);
2340         if (listRequirementDataDefinition == null) {
2341             CommonUtility
2342                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch calculated requirements for type {} for instance {} in container {}.", type,
2343                     fromInstId, containerId);
2344             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2345         }
2346         RequirementDataDefinition requirementForRelation = null;
2347         Iterator<RequirementDataDefinition> iteratorReq = listRequirementDataDefinition.getListToscaDataDefinition().iterator();
2348         while (iteratorReq.hasNext()) {
2349             RequirementDataDefinition req = iteratorReq.next();
2350             if (req.getUniqueId().equals(relationPair.getRequirementUid()) && req.getOwnerId().equals(relationPair.getRequirementOwnerId())) {
2351                 requirementForRelation = req;
2352                 capReqRelationship.put(JsonPresentationFields.REQUIREMENT, (T) requirementForRelation);
2353                 String leftOccurrences = req.getLeftOccurrences();
2354                 if (leftOccurrences != null && !leftOccurrences.equals(RequirementDataDefinition.MAX_OCCURRENCES)) {
2355                     Integer leftIntValue = Integer.parseInt(leftOccurrences);
2356                     if (leftIntValue > 0) {
2357                         --leftIntValue;
2358                         req.setLeftOccurrences(String.valueOf(leftIntValue));
2359                         if (leftIntValue == 0) {
2360                             // remove from calculated
2361                             iteratorReq.remove();
2362                             // move to fulfilled
2363                             MapListRequirementDataDefinition mapListRequirementFullFilledInst = fullfilledRequirement.get(fromInstId);
2364                             if (mapListRequirementFullFilledInst == null) {
2365                                 mapListRequirementFullFilledInst = new MapListRequirementDataDefinition();
2366                                 fullfilledRequirement.put(fromInstId, mapListRequirementFullFilledInst);
2367                             }
2368                             ListRequirementDataDefinition listRequirementFull = mapListRequirementFullFilledInst.findByKey(type);
2369                             if (listRequirementFull == null) {
2370                                 listRequirementFull = new ListRequirementDataDefinition();
2371                                 mapListRequirementFullFilledInst.put(type, listRequirementFull);
2372                             }
2373                             listRequirementFull.add(requirementForRelation);
2374                         }
2375                         break;
2376                     } else {
2377                         CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "No left occurrences requirement {} from {} to {} in container {}.",
2378                             requirementForRelation.getCapability(), fromInstId, toInstId, containerId);
2379                         return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2380                     }
2381                 }
2382             }
2383         }
2384         if (requirementForRelation == null) {
2385             CommonUtility
2386                 .addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to fetch requirement for type {} for instance {} in container {}.", type, toInstId,
2387                     containerId);
2388             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2389         }
2390         if (!capabilityForRelation.getType().equals(requirementForRelation.getCapability())) {
2391             CommonUtility
2392                 .addRecordToLog(log, LogLevelEnum.DEBUG, "No macth for capability from type {} and requirement {} from {} to {} in container {}.",
2393                     capabilityForRelation.getType(), requirementForRelation.getCapability(), fromInstId, toInstId, containerId);
2394             return Either.right(StorageOperationStatus.MATCH_NOT_FOUND);
2395         }
2396         RelationshipInstDataDefinition relationshipTypeData = buildRelationshipInstData(fromInstId, toInstId, relationPair, originUI);
2397         if (requirementForRelation.getRelationship() != null) {
2398             relationshipTypeData.setType(requirementForRelation.getRelationship());
2399         }
2400         capReqRelationship.put(JsonPresentationFields.RELATIONSHIP, (T) relationshipTypeData);
2401         return Either.left(capReqRelationship);
2402     }
2403
2404     private RelationshipInstDataDefinition buildRelationshipInstData(String fromResInstanceUid, String toInstId, RelationshipInfo relationPair,
2405                                                                      boolean originUI) {
2406         RelationshipInstDataDefinition relationshipInstData = new RelationshipInstDataDefinition();
2407         relationshipInstData.setUniqueId(UniqueIdBuilder.buildRelationsipInstInstanceUid(fromResInstanceUid, toInstId));
2408         relationshipInstData.setType(relationPair.getRelationship().getType());
2409         Long creationDate = System.currentTimeMillis();
2410         relationshipInstData.setCreationTime(creationDate);
2411         relationshipInstData.setModificationTime(creationDate);
2412         relationshipInstData.setCapabilityOwnerId(relationPair.getCapabilityOwnerId());
2413         relationshipInstData.setRequirementOwnerId(relationPair.getRequirementOwnerId());
2414         relationshipInstData.setCapabilityId(relationPair.getCapabilityUid());
2415         relationshipInstData.setRequirementId(relationPair.getRequirementUid());
2416         relationshipInstData.setFromId(fromResInstanceUid);
2417         relationshipInstData.setToId(toInstId);
2418         relationshipInstData.setRequirement(relationPair.getRequirement());
2419         relationshipInstData.setCapability(relationPair.getCapability());
2420         relationshipInstData.setOriginUI(originUI);
2421         return relationshipInstData;
2422     }
2423
2424     public <T extends Component> Map<String, ComponentInstanceDataDefinition> associateComponentInstancesToComponent(Component containerComponent,
2425                                                                                                                      Map<ComponentInstance, T> componentInstanceTMap,
2426                                                                                                                      GraphVertex containerVertex,
2427                                                                                                                      boolean allowDeleted,
2428                                                                                                                      boolean isUpdateCsar) {
2429         String containerId = containerComponent.getUniqueId();
2430         Map<String, ComponentInstanceDataDefinition> instancesJsonData;
2431         Either<GraphVertex, JanusGraphOperationStatus> updateElement = null;
2432         if (!validateInstanceNames(componentInstanceTMap)) {
2433             throw new StorageException(StorageOperationStatus.INCONSISTENCY);
2434         }
2435         if (!allowDeleted && !validateDeletedResources(componentInstanceTMap)) {
2436             throw new StorageException(StorageOperationStatus.INCONSISTENCY);
2437         }
2438         instancesJsonData = convertToComponentInstanceDataDefinition(componentInstanceTMap, containerId, isUpdateCsar);
2439         if (MapUtils.isNotEmpty(instancesJsonData)) {
2440             containerVertex.setJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE, System.currentTimeMillis());
2441             Map<String, CompositionDataDefinition> compositions = new HashMap<>();
2442             CompositionDataDefinition composition = new CompositionDataDefinition();
2443             composition.setComponentInstances(instancesJsonData);
2444             compositions.put(JsonConstantKeysEnum.COMPOSITION.getValue(), composition);
2445             containerVertex.setJson(compositions);
2446             updateElement = janusGraphDao.updateVertex(containerVertex);
2447             if (updateElement.isRight()) {
2448                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Failed to update topology template {} with new component instances. ",
2449                     containerComponent.getName());
2450                 throw new StorageException(DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateElement.right().value()));
2451             }
2452         }
2453         if (updateElement != null) {
2454             GraphVertex vertexC = updateElement.left().value();
2455             instancesJsonData.entrySet().forEach(i -> createInstanceEdge(vertexC, i.getValue()));
2456         }
2457         return instancesJsonData;
2458     }
2459
2460     private <T extends Component> Map<String, ComponentInstanceDataDefinition> convertToComponentInstanceDataDefinition(
2461         Map<ComponentInstance, T> componentInstanceTMap, String containerId, boolean isUpdateCsar) {
2462         Map<String, ComponentInstanceDataDefinition> instances = new HashMap<>();
2463         for (Entry<ComponentInstance, T> entry : componentInstanceTMap.entrySet()) {
2464             ComponentInstanceDataDefinition instance = buildComponentInstanceDataDefinition(entry.getKey(), containerId, null,
2465                 !isUpdateCsar || entry.getKey().isCreatedFromCsar(), ModelConverter.convertToToscaElement(entry.getValue()));
2466             instances.put(instance.getUniqueId(), instance);
2467         }
2468         return instances;
2469     }
2470
2471     private <T extends Component> boolean validateDeletedResources(Map<ComponentInstance, T> resourcesInstancesMap) {
2472         boolean result = true;
2473         for (Component component : resourcesInstancesMap.values()) {
2474             if (component.getIsDeleted() != null && component.getIsDeleted()) {
2475                 CommonUtility
2476                     .addRecordToLog(log, LogLevelEnum.DEBUG, "Component {} is already deleted. Cannot add component instance. ", component.getName());
2477                 result = false;
2478                 break;
2479             }
2480         }
2481         return result;
2482     }
2483
2484     private <T extends Component> boolean validateInstanceNames(Map<ComponentInstance, T> resourcesInstancesMap) {
2485         boolean result = true;
2486         Set<String> names = new HashSet<>();
2487         for (ComponentInstance instance : resourcesInstancesMap.keySet()) {
2488             if (StringUtils.isEmpty(instance.getName())) {
2489                 CommonUtility.addRecordToLog(log, LogLevelEnum.DEBUG, "Component instance {} name is empty. Cannot add component instance. ",
2490                     instance.getUniqueId());
2491                 result = false;
2492                 break;
2493             } else if (names.contains(instance.getName())) {
2494                 CommonUtility
2495                     .addRecordToLog(log, LogLevelEnum.DEBUG, "Component instance with the name {} already exsists. Cannot add component instance. ",
2496                         instance.getName());
2497                 result = false;
2498                 break;
2499             } else {
2500                 names.add(instance.getName());
2501             }
2502         }
2503         return result;
2504     }
2505
2506     public StorageOperationStatus addDeploymentArtifactsToInstance(String toscaElementId, String instanceId,
2507                                                                    Map<String, ArtifactDataDefinition> instDeplArtifacts) {
2508         return addArtifactsToInstance(toscaElementId, instanceId, instDeplArtifacts, EdgeLabelEnum.INST_DEPLOYMENT_ARTIFACTS,
2509             VertexTypeEnum.INST_DEPLOYMENT_ARTIFACTS);
2510     }
2511
2512     public StorageOperationStatus addInformationalArtifactsToInstance(String toscaElementId, String instanceId,
2513                                                                       Map<String, ArtifactDataDefinition> instDeplArtifacts) {
2514         return addArtifactsToInstance(toscaElementId, instanceId, instDeplArtifacts, EdgeLabelEnum.INSTANCE_ARTIFACTS,
2515             VertexTypeEnum.INSTANCE_ARTIFACTS);
2516     }
2517
2518     public StorageOperationStatus addArtifactsToInstance(String toscaElementId, String instanceId,
2519                                                          Map<String, ArtifactDataDefinition> instDeplArtifacts, EdgeLabelEnum edgeLabel,
2520                                                          VertexTypeEnum vertexType) {
2521         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao.getVertexById(toscaElementId, JsonParseFlagEnum.NoParse);
2522         if (metadataVertex.isRight()) {
2523             JanusGraphOperationStatus status = metadataVertex.right().value();
2524             if (status == JanusGraphOperationStatus.NOT_FOUND) {
2525                 status = JanusGraphOperationStatus.INVALID_ID;
2526             }
2527             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status);
2528         }
2529         MapArtifactDataDefinition instArtifacts = new MapArtifactDataDefinition(instDeplArtifacts);
2530         return addToscaDataDeepElementsBlockToToscaElement(metadataVertex.left().value(), edgeLabel, vertexType, instArtifacts, instanceId);
2531     }
2532
2533     @SuppressWarnings({"unchecked"})
2534     public StorageOperationStatus generateCustomizationUUIDOnInstance(String componentId, String instanceId) {
2535         Either<GraphVertex, JanusGraphOperationStatus> metadataVertex = janusGraphDao.getVertexById(componentId, JsonParseFlagEnum.ParseAll);
2536         if (metadataVertex.isRight()) {
2537             JanusGraphOperationStatus status = metadataVertex.right().value();
2538             if (status == JanusGraphOperationStatus.NOT_FOUND) {
2539                 status = JanusGraphOperationStatus.INVALID_ID;
2540             }
2541             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(status);
2542         }
2543         GraphVertex metaVertex = metadataVertex.left().value();
2544         Map<String, CompositionDataDefinition> json = (Map<String, CompositionDataDefinition>) metaVertex.getJson();
2545         CompositionDataDefinition compositionDataDefinition = json.get(JsonConstantKeysEnum.COMPOSITION.getValue());
2546         StorageOperationStatus status = updateCustomizationUUID(instanceId, compositionDataDefinition);
2547         if (status != StorageOperationStatus.OK) {
2548             log.debug("Failed to update customization UUID for instance {} in component {} error {}", instanceId, componentId, status);
2549             return status;
2550         }
2551         Either<GraphVertex, JanusGraphOperationStatus> updateVertex = janusGraphDao.updateVertex(metaVertex);
2552         if (updateVertex.isRight()) {
2553             log.debug("Failed to update vertex of component {} error {}", componentId, updateVertex.right().value());
2554             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(updateVertex.right().value());
2555         }
2556         return StorageOperationStatus.OK;
2557     }
2558
2559     public StorageOperationStatus generateCustomizationUUIDOnInstanceGroup(String componentId, String instanceId, List<String> groupInstances) {
2560         if (groupInstances != null) {
2561             Either<Map<String, MapGroupsDataDefinition>, JanusGraphOperationStatus> dataFromGraph = getDataFromGraph(componentId,
2562                 EdgeLabelEnum.INST_GROUPS);
2563             if (dataFromGraph.isRight()) {
2564                 return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(dataFromGraph.right().value());
2565             }
2566             MapGroupsDataDefinition grInstPerInstance = dataFromGraph.left().value().get(instanceId);
2567             if (grInstPerInstance == null) {
2568                 log.debug("No  instance groups for instance {} in component {}", instanceId, componentId);
2569                 return StorageOperationStatus.NOT_FOUND;
2570             }
2571             for (String instGroupForUpdate : groupInstances) {
2572                 GroupInstanceDataDefinition groupInst = grInstPerInstance.findByKey(instGroupForUpdate);
2573                 if (groupInst == null) {
2574                     log.debug("No group instance {} in group list  for instance {} in component {}", instGroupForUpdate, instanceId, componentId);
2575                     continue;
2576                 }
2577                 UUID uuid = UUID.randomUUID();
2578                 groupInst.setCustomizationUUID(uuid.toString());
2579             }
2580         }
2581         return StorageOperationStatus.OK;
2582     }
2583
2584     public StorageOperationStatus addGroupInstancesToComponentInstance(Component containerComponent, ComponentInstance componentInstance,
2585                                                                        List<GroupInstance> groupInstances) {
2586         return addToscaDataDeepElementsBlockToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_GROUPS, VertexTypeEnum.INST_GROUPS,
2587             new MapDataDefinition<>(groupInstances.stream().collect(Collectors.toMap(GroupInstanceDataDefinition::getName, gi -> gi))),
2588             componentInstance.getUniqueId());
2589     }
2590
2591     public StorageOperationStatus addDeploymentArtifactsToComponentInstance(Component containerComponent, ComponentInstance componentInstance,
2592                                                                             Map<String, ArtifactDefinition> deploymentArtifacts) {
2593         return addToscaDataDeepElementsBlockToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_DEPLOYMENT_ARTIFACTS,
2594             VertexTypeEnum.INST_DEPLOYMENT_ARTIFACTS, new MapDataDefinition<>(deploymentArtifacts), componentInstance.getUniqueId());
2595     }
2596
2597     public StorageOperationStatus updateComponentInstanceProperty(Component containerComponent, String componentInstanceId,
2598                                                                   ComponentInstanceProperty property) {
2599         List<String> pathKeys = new ArrayList<>();
2600         pathKeys.add(componentInstanceId);
2601         return updateToscaDataDeepElementOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_PROPERTIES,
2602             VertexTypeEnum.INST_PROPERTIES, property, pathKeys, JsonPresentationFields.NAME);
2603     }
2604
2605     public StorageOperationStatus updateComponentInstanceCapabilityProperty(Component containerComponent, String componentInstanceId,
2606                                                                             String capabilityPropertyKey, ComponentInstanceProperty property) {
2607         List<String> pathKeys = new ArrayList<>();
2608         pathKeys.add(componentInstanceId);
2609         pathKeys.add(capabilityPropertyKey);
2610         return updateToscaDataDeepElementOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.CALCULATED_CAP_PROPERTIES,
2611             VertexTypeEnum.CALCULATED_CAP_PROPERTIES, property, pathKeys, JsonPresentationFields.NAME);
2612     }
2613
2614     public StorageOperationStatus overrideComponentCapabilitiesProperties(Component containerComponent,
2615                                                                           Map<String, MapCapabilityProperty> capabilityPropertyMap) {
2616         return overrideToscaDataOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.CALCULATED_CAP_PROPERTIES, capabilityPropertyMap);
2617     }
2618
2619     public StorageOperationStatus addComponentInstanceProperty(Component containerComponent, String componentInstanceId,
2620                                                                ComponentInstanceProperty property) {
2621         List<String> pathKeys = new ArrayList<>();
2622         pathKeys.add(componentInstanceId);
2623         return addToscaDataDeepElementToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_PROPERTIES, VertexTypeEnum.INST_PROPERTIES,
2624             property, pathKeys, JsonPresentationFields.NAME);
2625     }
2626
2627     public StorageOperationStatus updateComponentInstanceProperties(Component containerComponent, String componentInstanceId,
2628                                                                     List<ComponentInstanceProperty> properties) {
2629         List<String> pathKeys = new ArrayList<>();
2630         pathKeys.add(componentInstanceId);
2631         return updateToscaDataDeepElementsOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_PROPERTIES,
2632             VertexTypeEnum.INST_PROPERTIES, properties, pathKeys, JsonPresentationFields.NAME);
2633     }
2634
2635     public StorageOperationStatus updateComponentInstanceAttributes(final Component containerComponent, final String componentInstanceId,
2636                                                                     final List<ComponentInstanceAttribute> attributes) {
2637         final List<String> pathKeys = Arrays.asList(componentInstanceId);
2638         return updateToscaDataDeepElementsOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_ATTRIBUTES,
2639             VertexTypeEnum.INST_ATTRIBUTES, attributes, pathKeys, JsonPresentationFields.NAME);
2640     }
2641
2642     public StorageOperationStatus updateComponentInstanceAttribute(final Component containerComponent, final String componentInstanceId,
2643                                                                    final ComponentInstanceAttribute attribute) {
2644         final List<String> pathKeys = Arrays.asList(componentInstanceId);
2645         return updateToscaDataDeepElementOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_ATTRIBUTES,
2646             VertexTypeEnum.INST_ATTRIBUTES, attribute, pathKeys, JsonPresentationFields.NAME);
2647     }
2648
2649     public StorageOperationStatus addComponentInstanceAttribute(Component containerComponent, String componentInstanceId,
2650                                                                 ComponentInstanceAttribute attribute) {
2651         List<String> pathKeys = new ArrayList<>();
2652         pathKeys.add(componentInstanceId);
2653         return addToscaDataDeepElementToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_ATTRIBUTES, VertexTypeEnum.INST_ATTRIBUTES,
2654             attribute, pathKeys, JsonPresentationFields.NAME);
2655     }
2656
2657     public StorageOperationStatus updateComponentInstanceInput(Component containerComponent, String componentInstanceId,
2658                                                                ComponentInstanceInput property) {
2659         List<String> pathKeys = new ArrayList<>();
2660         pathKeys.add(componentInstanceId);
2661         return updateToscaDataDeepElementOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS,
2662             property, pathKeys, JsonPresentationFields.NAME);
2663     }
2664
2665     public StorageOperationStatus updateComponentInstanceOutput(Component containerComponent, String componentInstanceId,
2666                                                                 ComponentInstanceOutput property) {
2667         List<String> pathKeys = new ArrayList<>();
2668         pathKeys.add(componentInstanceId);
2669         return updateToscaDataDeepElementOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_OUTPUTS, VertexTypeEnum.INST_OUTPUTS,
2670             property, pathKeys, JsonPresentationFields.NAME);
2671     }
2672
2673     public StorageOperationStatus updateComponentInstanceInputs(Component containerComponent, String componentInstanceId,
2674                                                                 List<ComponentInstanceInput> properties) {
2675         List<String> pathKeys = new ArrayList<>();
2676         pathKeys.add(componentInstanceId);
2677         return updateToscaDataDeepElementsOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS,
2678             properties, pathKeys, JsonPresentationFields.NAME);
2679     }
2680
2681     public StorageOperationStatus updateComponentInstanceOutputs(Component containerComponent, String componentInstanceId,
2682                                                                  List<ComponentInstanceOutput> properties) {
2683         List<String> pathKeys = new ArrayList<>();
2684         pathKeys.add(componentInstanceId);
2685         return updateToscaDataDeepElementsOfToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_OUTPUTS, VertexTypeEnum.INST_OUTPUTS,
2686             properties, pathKeys, JsonPresentationFields.NAME);
2687     }
2688
2689     public StorageOperationStatus addComponentInstanceInput(Component containerComponent, String componentInstanceId,
2690                                                             ComponentInstanceInput property) {
2691         List<String> pathKeys = new ArrayList<>();
2692         pathKeys.add(componentInstanceId);
2693         return addToscaDataDeepElementToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_INPUTS, VertexTypeEnum.INST_INPUTS,
2694             property, pathKeys, JsonPresentationFields.NAME);
2695     }
2696
2697     public StorageOperationStatus addComponentInstanceOutput(Component containerComponent, String componentInstanceId,
2698                                                              ComponentInstanceOutput property) {
2699         List<String> pathKeys = new ArrayList<>() {
2700         };
2701         pathKeys.add(componentInstanceId);
2702         return addToscaDataDeepElementToToscaElement(containerComponent.getUniqueId(), EdgeLabelEnum.INST_OUTPUTS, VertexTypeEnum.INST_OUTPUTS,
2703             property, pathKeys, JsonPresentationFields.NAME);
2704     }
2705
2706     public StorageOperationStatus createInstanceEdge(GraphVertex metadataVertex, ComponentInstanceDataDefinition componentInstance) {
2707         String instUniqueId = componentInstance.getUniqueId();
2708         // create edge between container and origin ( in case of proxy this edge will be to ProxyService node type)
2709         StorageOperationStatus result = createOrUpdateInstanceEdge(metadataVertex, EdgeLabelEnum.INSTANCE_OF, componentInstance.getComponentUid(),
2710             instUniqueId).either(v -> StorageOperationStatus.OK, DaoStatusConverter::convertJanusGraphStatusToStorageStatus);
2711         if (result == StorageOperationStatus.OK && componentInstance.getIsProxy()) {
2712             // create edge between container and service origin
2713             result = createOrUpdateInstanceEdge(metadataVertex, EdgeLabelEnum.PROXY_OF, componentInstance.getSourceModelUid(), instUniqueId)
2714                 .either(v -> StorageOperationStatus.OK, DaoStatusConverter::convertJanusGraphStatusToStorageStatus);
2715         }
2716         return result;
2717     }
2718
2719     public StorageOperationStatus createAllottedOfEdge(String componentId, String instanceId, String serviceUUID) {
2720         Either<GraphVertex, JanusGraphOperationStatus> vertexById = janusGraphDao.getVertexById(componentId);
2721         if (vertexById.isRight()) {
2722             log.debug("Failed to fetch component metadata vertex for id {} error {}", componentId, vertexById.right().value());
2723             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(vertexById.right().value());
2724         }
2725         GraphVertex metadataVertex = vertexById.left().value();
2726         EnumMap<GraphPropertyEnum, Object> props = new EnumMap<>(GraphPropertyEnum.class);
2727         props.put(GraphPropertyEnum.UUID, serviceUUID);
2728         props.put(GraphPropertyEnum.IS_HIGHEST_VERSION, true);
2729         EnumMap<GraphPropertyEnum, Object> hasNot = new EnumMap<>(GraphPropertyEnum.class);
2730         hasNot.put(GraphPropertyEnum.IS_DELETED, true);
2731         Either<List<GraphVertex>, JanusGraphOperationStatus> byCriteria = janusGraphDao
2732             .getByCriteria(VertexTypeEnum.TOPOLOGY_TEMPLATE, props, hasNot, JsonParseFlagEnum.ParseMetadata);
2733         if (byCriteria.isRight()) {
2734             log.debug("Failed to fetch vertex by criteria {} error {}", props, byCriteria.right().value());
2735             return DaoStatusConverter.convertJanusGraphStatusToStorageStatus(byCriteria.right().value());
2736         }
2737         List<GraphVertex> vertecies = byCriteria.left().value();
2738         StorageOperationStatus result = StorageOperationStatus.OK;
2739         if (vertecies != null) {
2740             GraphVertex serviceVertex = vertecies.get(0);
2741             //remove previous edges
2742             log.debug("Try to create or update edge between resource {} and service {} ", metadataVertex, serviceVertex.getUniqueId());
2743             // create edge between container and service reference
2744             result = createOrUpdateInstanceEdge(metadataVertex, EdgeLabelEnum.ALLOTTED_OF, serviceVertex.getUniqueId(), instanceId)
2745                 .either(v -> StorageOperationStatus.OK, DaoStatusConverter::convertJanusGraphStatusToStorageStatus);
2746         }
2747         return result;
2748     }
2749
2750     public StorageOperationStatus removeInstanceEdge(GraphVertex metadataVertex, ComponentInstanceDataDefinition componentInstance) {
2751         String instUniqueId = componentInstance.getUniqueId();
2752         // create edge between container and origin ( in case of proxy this edge will be to ProxyService node type)
2753         StorageOperationStatus result = removeOrUpdateInstanceEdge(metadataVertex, EdgeLabelEnum.INSTANCE_OF, componentInstance.getComponentUid(),
2754             instUniqueId).either(v -> StorageOperationStatus.OK, DaoStatusConverter::convertJanusGraphStatusToStorageStatus);
2755         if (componentInstance.getIsProxy()) {
2756             // create edge between container and service origin
2757             result = removeOrUpdateInstanceEdge(metadataVertex, EdgeLabelEnum.PROXY_OF, componentInstance.getSourceModelUid(), instUniqueId)
2758                 .either(v -> StorageOperationStatus.OK, DaoStatusConverter::convertJanusGraphStatusToStorageStatus);
2759         }
2760         return result;
2761     }
2762
2763     private Either<GraphVertex, JanusGraphOperationStatus> createOrUpdateInstanceEdge(GraphVertex metadataVertex, EdgeLabelEnum edgeLabel,
2764                                                                                       String componentUid, String instUniqueId) {
2765         Map<GraphPropertyEnum, Object> properties = new EnumMap<>(GraphPropertyEnum.class);
2766         properties.put(GraphPropertyEnum.UNIQUE_ID, componentUid);
2767         return janusGraphDao.getEdgeByChildrenVertexProperties(metadataVertex, edgeLabel, properties).left()
2768             .bind(v -> addInstanceToPropertyOnEdge(instUniqueId, v, metadataVertex)).right()
2769             .bind(s -> createInstanceEdge(metadataVertex, edgeLabel, componentUid, instUniqueId, s));
2770     }
2771
2772     private Either<GraphVertex, JanusGraphOperationStatus> removeOrUpdateInstanceEdge(GraphVertex metadataVertex, EdgeLabelEnum edgeLabel,
2773                                                                                       String componentUid, String instUniqueId) {
2774         Map<GraphPropertyEnum, Object> properties = new EnumMap<>(GraphPropertyEnum.class);
2775         properties.put(GraphPropertyEnum.UNIQUE_ID, componentUid);
2776         return janusGraphDao.getEdgeByChildrenVertexProperties(metadataVertex, edgeLabel, properties).left()
2777             .bind(v -> removeInstanceFromPropertyOnEdge(instUniqueId, v, metadataVertex)).right()
2778             .map(err -> removeInstanceEdgeLogError(metadataVertex, edgeLabel, componentUid, err));
2779     }
2780
2781     private Either<GraphVertex, JanusGraphOperationStatus> addInstanceToPropertyOnEdge(String instUniqueId, Edge edge, GraphVertex metadataVertex) {
2782         // edge exist need to add instance id to list on edge's property
2783         List<String> property = (List<String>) janusGraphDao.getProperty(edge, EdgePropertyEnum.INSTANCES);
2784         if (property == null) {
2785             property = new ArrayList<>();
2786         }
2787         Optional<String> findFirst = property.stream().filter(a -> a.equals(instUniqueId)).findFirst();
2788         if (!findFirst.isPresent()) {
2789             property.add(instUniqueId);
2790         }
2791         try {
2792             String jsonArr = JsonParserUtils.toJson(property);
2793             log.debug("Update INSTANCES edge property with value {} ", jsonArr);
2794             edge.property(EdgePropertyEnum.INSTANCES.getProperty(), jsonArr);
2795         } catch (IOException e) {
2796             log.debug("Failed to convert INSTANCES edge property to json for container {}", metadataVertex.getUniqueId(), e);
2797             return Either.right(JanusGraphOperationStatus.GENERAL_ERROR);
2798         }
2799         return Either.left(metadataVertex);
2800     }
2801
2802     private Either<GraphVertex, JanusGraphOperationStatus> removeInstanceFromPropertyOnEdge(String instUniqueId, Edge edge,
2803                                                                                             GraphVertex metadataVertex) {
2804         // edge exist need to add instance id to list on edge's property
2805         List<String> property = (List<String>) janusGraphDao.getProperty(edge, EdgePropertyEnum.INSTANCES);
2806         if (property == null) {
2807             property = new ArrayList<>();
2808         }
2809         Optional<String> findFirst = property.stream().filter(a -> a.equals(instUniqueId)).findFirst();
2810         if (findFirst.isPresent()) {
2811             property.remove(instUniqueId);
2812         }
2813         if (property.isEmpty()) {
2814             // For last instance need to remove edge
2815             edge.remove();
2816         } else {
2817             try {
2818                 String jsonArr = JsonParserUtils.toJson(property);
2819                 edge.property(EdgePropertyEnum.INSTANCES.getProperty(), jsonArr);
2820             } catch (IOException e) {
2821                 log.debug("Failed to convert INSTANCES edge property to json for container {}", metadataVertex.getUniqueId(), e);
2822                 return Either.right(JanusGraphOperationStatus.GENERAL_ERROR);
2823             }
2824         }
2825         return Either.left(metadataVertex);
2826     }
2827
2828     private Either<GraphVertex, JanusGraphOperationStatus> createInstanceEdge(GraphVertex metadataVertex, EdgeLabelEnum edgeLabel,
2829                                                                               String componentUid, String instUniqueId,
2830                                                                               JanusGraphOperationStatus retrieveEdgeStatus) {
2831         if (retrieveEdgeStatus == JanusGraphOperationStatus.NOT_FOUND) {
2832             // create new edge
2833             Either<GraphVertex, JanusGraphOperationStatus> vertexById = janusGraphDao.getVertexById(componentUid);
2834             if (vertexById.isRight()) {
2835                 return vertexById;
2836             }
2837             GraphVertex originVertex = vertexById.left().value();
2838             Map<EdgePropertyEnum, Object> edgeProps = new EnumMap<>(EdgePropertyEnum.class);
2839             List<String> instList = new ArrayList<>();
2840             instList.add(instUniqueId);
2841             edgeProps.put(EdgePropertyEnum.INSTANCES, instList);
2842             log.debug("Create new edge {} between {} and {} and properties {} ", edgeLabel, metadataVertex.getUniqueId(), originVertex.getUniqueId(),
2843                 edgeProps);
2844             JanusGraphOperationStatus edgeResult = janusGraphDao.createEdge(metadataVertex, originVertex, edgeLabel, edgeProps);
2845             return edgeResult == JanusGraphOperationStatus.OK ? Either.left(metadataVertex) : Either.right(edgeResult);
2846         }
2847         // error
2848         log.debug("Failed to fetch edge with label {} and to vertex with id {} error {} ", edgeLabel, componentUid, retrieveEdgeStatus);
2849         return Either.right(retrieveEdgeStatus);
2850     }
2851
2852     private JanusGraphOperationStatus removeInstanceEdgeLogError(GraphVertex metadataVertex, EdgeLabelEnum edgeLabel, String componentUid,
2853                                                                  JanusGraphOperationStatus retrieveEdgeStatus) {
2854         if (retrieveEdgeStatus == JanusGraphOperationStatus.NOT_FOUND) {
2855             log.debug("No edge {} to remove between container {} and origin {}", edgeLabel, metadataVertex.getUniqueId(), componentUid);
2856         } else {
2857             // error
2858             log.debug("Failed to fetch edge with label {} and to vertex with id {} error {} ", edgeLabel, componentUid, retrieveEdgeStatus);
2859         }
2860         return retrieveEdgeStatus;
2861     }
2862
2863     public void removeAllAllotedEdges(String uniqueId) {
2864         Either<GraphVertex, JanusGraphOperationStatus> vertexById = janusGraphDao.getVertexById(uniqueId);
2865         if (vertexById.isLeft()) {
2866             GraphVertex originVertex = vertexById.left().value();
2867             JanusGraphVertex vertex = originVertex.getVertex();
2868             Iterator<Edge> edges = vertex.edges(Direction.OUT, EdgeLabelEnum.ALLOTTED_OF.name());
2869             while (edges != null && edges.hasNext()) {
2870                 Edge edge = edges.next();
2871                 edge.remove();
2872             }
2873         }
2874     }
2875 }