Add UI support for adding tosca artifact types
[sdc.git] / catalog-model / src / main / java / org / openecomp / sdc / be / model / jsonjanusgraph / utils / ModelConverter.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.utils;
21
22 import com.google.common.collect.Lists;
23 import com.google.common.collect.Maps;
24 import java.util.ArrayList;
25 import java.util.Arrays;
26 import java.util.Collections;
27 import java.util.HashMap;
28 import java.util.HashSet;
29 import java.util.List;
30 import java.util.Map;
31 import java.util.Map.Entry;
32 import java.util.Objects;
33 import java.util.Optional;
34 import java.util.Set;
35 import java.util.function.Function;
36 import java.util.stream.Collectors;
37 import org.apache.commons.collections.CollectionUtils;
38 import org.apache.commons.collections.MapUtils;
39 import org.apache.commons.lang3.BooleanUtils;
40 import org.apache.commons.lang3.StringUtils;
41 import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
42 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
43 import org.openecomp.sdc.be.dao.jsongraph.GraphVertex;
44 import org.openecomp.sdc.be.dao.jsongraph.types.VertexTypeEnum;
45 import org.openecomp.sdc.be.dao.neo4j.GraphPropertiesDictionaryExtractor;
46 import org.openecomp.sdc.be.datatypes.category.MetadataKeyDataDefinition;
47 import org.openecomp.sdc.be.datatypes.components.ComponentMetadataDataDefinition;
48 import org.openecomp.sdc.be.datatypes.components.ResourceMetadataDataDefinition;
49 import org.openecomp.sdc.be.datatypes.components.ServiceMetadataDataDefinition;
50 import org.openecomp.sdc.be.datatypes.elements.AdditionalInfoParameterDataDefinition;
51 import org.openecomp.sdc.be.datatypes.elements.ArtifactDataDefinition;
52 import org.openecomp.sdc.be.datatypes.elements.AttributeDataDefinition;
53 import org.openecomp.sdc.be.datatypes.elements.CINodeFilterDataDefinition;
54 import org.openecomp.sdc.be.datatypes.elements.CapabilityDataDefinition;
55 import org.openecomp.sdc.be.datatypes.elements.ComponentInstanceDataDefinition;
56 import org.openecomp.sdc.be.datatypes.elements.CompositionDataDefinition;
57 import org.openecomp.sdc.be.datatypes.elements.DataTypeDataDefinition;
58 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathDataDefinition;
59 import org.openecomp.sdc.be.datatypes.elements.GroupDataDefinition;
60 import org.openecomp.sdc.be.datatypes.elements.GroupInstanceDataDefinition;
61 import org.openecomp.sdc.be.datatypes.elements.InterfaceDataDefinition;
62 import org.openecomp.sdc.be.datatypes.elements.ListCapabilityDataDefinition;
63 import org.openecomp.sdc.be.datatypes.elements.ListDataDefinition;
64 import org.openecomp.sdc.be.datatypes.elements.ListRequirementDataDefinition;
65 import org.openecomp.sdc.be.datatypes.elements.MapArtifactDataDefinition;
66 import org.openecomp.sdc.be.datatypes.elements.MapAttributesDataDefinition;
67 import org.openecomp.sdc.be.datatypes.elements.MapCapabilityProperty;
68 import org.openecomp.sdc.be.datatypes.elements.MapGroupsDataDefinition;
69 import org.openecomp.sdc.be.datatypes.elements.MapInterfaceDataDefinition;
70 import org.openecomp.sdc.be.datatypes.elements.MapListCapabilityDataDefinition;
71 import org.openecomp.sdc.be.datatypes.elements.MapListRequirementDataDefinition;
72 import org.openecomp.sdc.be.datatypes.elements.MapPropertiesDataDefinition;
73 import org.openecomp.sdc.be.datatypes.elements.OperationDataDefinition;
74 import org.openecomp.sdc.be.datatypes.elements.OperationInputDefinition;
75 import org.openecomp.sdc.be.datatypes.elements.PolicyDataDefinition;
76 import org.openecomp.sdc.be.datatypes.elements.ProductMetadataDataDefinition;
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.elements.SubstitutionFilterDataDefinition;
81 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
82 import org.openecomp.sdc.be.datatypes.enums.CreatedFrom;
83 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFields;
84 import org.openecomp.sdc.be.datatypes.enums.JsonPresentationFieldsExtractor;
85 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
86 import org.openecomp.sdc.be.model.AdditionalInformationDefinition;
87 import org.openecomp.sdc.be.model.ArtifactDefinition;
88 import org.openecomp.sdc.be.model.AttributeDefinition;
89 import org.openecomp.sdc.be.model.CapabilityDefinition;
90 import org.openecomp.sdc.be.model.CapabilityRequirementRelationship;
91 import org.openecomp.sdc.be.model.Component;
92 import org.openecomp.sdc.be.model.ComponentInstance;
93 import org.openecomp.sdc.be.model.ComponentInstanceAttribute;
94 import org.openecomp.sdc.be.model.ComponentInstanceInput;
95 import org.openecomp.sdc.be.model.ComponentInstanceInterface;
96 import org.openecomp.sdc.be.model.ComponentInstanceOutput;
97 import org.openecomp.sdc.be.model.ComponentInstanceProperty;
98 import org.openecomp.sdc.be.model.DataTypeDefinition;
99 import org.openecomp.sdc.be.model.DistributionStatusEnum;
100 import org.openecomp.sdc.be.model.GroupDefinition;
101 import org.openecomp.sdc.be.model.GroupInstance;
102 import org.openecomp.sdc.be.model.InputDefinition;
103 import org.openecomp.sdc.be.model.InterfaceDefinition;
104 import org.openecomp.sdc.be.model.MapInterfaceInstanceDataDefinition;
105 import org.openecomp.sdc.be.model.OutputDefinition;
106 import org.openecomp.sdc.be.model.PolicyDefinition;
107 import org.openecomp.sdc.be.model.PropertyDefinition;
108 import org.openecomp.sdc.be.model.RelationshipImpl;
109 import org.openecomp.sdc.be.model.RelationshipInfo;
110 import org.openecomp.sdc.be.model.RequirementCapabilityRelDef;
111 import org.openecomp.sdc.be.model.RequirementDefinition;
112 import org.openecomp.sdc.be.model.Resource;
113 import org.openecomp.sdc.be.model.Service;
114 import org.openecomp.sdc.be.model.category.CategoryDefinition;
115 import org.openecomp.sdc.be.model.category.SubCategoryDefinition;
116 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.NodeType;
117 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.TopologyTemplate;
118 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.ToscaElement;
119 import org.openecomp.sdc.be.model.jsonjanusgraph.datamodel.ToscaElementTypeEnum;
120 import org.openecomp.sdc.be.model.jsonjanusgraph.enums.JsonConstantKeysEnum;
121 import org.openecomp.sdc.be.model.operations.StorageException;
122 import org.openecomp.sdc.be.resources.data.ComponentMetadataData;
123 import org.openecomp.sdc.be.resources.data.ProductMetadataData;
124 import org.openecomp.sdc.be.resources.data.ResourceMetadataData;
125 import org.openecomp.sdc.be.resources.data.ServiceMetadataData;
126 import org.openecomp.sdc.be.ui.model.OperationUi;
127 import org.openecomp.sdc.be.ui.model.PropertyAssignmentUi;
128 import org.openecomp.sdc.common.log.wrappers.Logger;
129
130 public class ModelConverter {
131
132     public static final String CAP_PROP_DELIM = "#";
133     private static final Logger log = Logger.getLogger(ModelConverter.class);
134
135     private ModelConverter() {
136     }
137
138     @SuppressWarnings("unchecked")
139     public static <T extends ToscaElement> T convertToToscaElement(Component component) {
140         if (isAtomicComponent(component)) {
141             return (T) convertToNodeType(component);
142         }
143         return (T) convertToTopologyTemplate(component);
144     }
145
146     @SuppressWarnings("unchecked")
147     public static <T extends Component> T convertFromToscaElement(ToscaElement toscaElement) {
148         switch (toscaElement.getComponentType()) {
149             case RESOURCE:
150                 return (T) convertToResource(toscaElement);
151             case SERVICE:
152             case PRODUCT:
153                 return (T) convertToService(toscaElement);
154             default:
155                 return null;
156         }
157     }
158
159     public static boolean isAtomicComponent(Component component) {
160         ComponentTypeEnum componentType = component.getComponentType();
161         if (!componentType.equals(ComponentTypeEnum.RESOURCE)) {
162             return false;
163         }
164         Resource resource = (Resource) component;
165         ResourceTypeEnum resType = resource.getResourceType();
166         return isAtomicComponent(resType);
167     }
168
169     public static boolean isAtomicComponent(ResourceTypeEnum resourceType) {
170         if (resourceType == null) {
171             return false;
172         }
173         return resourceType.isAtomicType();
174     }
175
176     // **********************************************************
177     public static VertexTypeEnum getVertexType(Component component) {
178         VertexTypeEnum vertexType;
179         if (isAtomicComponent(component)) {
180             vertexType = VertexTypeEnum.NODE_TYPE;
181         } else {
182             vertexType = VertexTypeEnum.TOPOLOGY_TEMPLATE;
183         }
184         return vertexType;
185     }
186
187     public static VertexTypeEnum getVertexType(String resourceTypeName) {
188         ResourceTypeEnum resourceType = ResourceTypeEnum.getTypeByName(resourceTypeName);
189         if (isAtomicComponent(resourceType)) {
190             return VertexTypeEnum.NODE_TYPE;
191         } else {
192             return VertexTypeEnum.TOPOLOGY_TEMPLATE;
193         }
194     }
195
196     private static Service convertToService(ToscaElement toscaElement) {
197         Service service = new Service();
198         convertComponentFields(service, toscaElement);
199         convertServiceSpecificFields(toscaElement, service);
200         TopologyTemplate topologyTemplate = (TopologyTemplate) toscaElement;
201         convertComponentInstances(topologyTemplate, service);
202         convertInputs(topologyTemplate, service);
203         convertOutputs(topologyTemplate, service);
204         convertProperties(topologyTemplate, service);
205         convertPolicies(topologyTemplate, service);
206         convertAttributesToComponent(topologyTemplate, service);
207         convertGroups(topologyTemplate, service);
208         setCapabilitiesToComponentAndGroups(topologyTemplate, service);
209         convertPolicies(topologyTemplate, service);
210         convertRelations(topologyTemplate, service);
211         convertArtifacts(topologyTemplate, service);
212         convertServiceApiArtifacts(topologyTemplate, service);
213         convertServicePaths(topologyTemplate, service);
214         convertServiceInterfaces(topologyTemplate, service);
215         convertDataTypes(topologyTemplate, service);
216         convertNodeFiltersComponents(topologyTemplate, service);
217         convertSubstitutionFiltersComponents(topologyTemplate, service);
218         setCapabilitiesToComponent(topologyTemplate, service);
219         setRequirementsToComponent(topologyTemplate, service);
220         return service;
221     }
222
223     private static void convertServiceSpecificFields(ToscaElement toscaElement, Service service) {
224         service.setProjectCode((String) toscaElement.getMetadataValue(JsonPresentationFields.PROJECT_CODE));
225         service.setDistributionStatus(
226             DistributionStatusEnum.findState((String) toscaElement.getMetadataValue(JsonPresentationFields.DISTRIBUTION_STATUS)));
227         service.setEcompGeneratedNaming((Boolean) toscaElement.getMetadataValueOrDefault(JsonPresentationFields.ECOMP_GENERATED_NAMING, true));
228         service.setNamingPolicy((String) toscaElement.getMetadataValueOrDefault(JsonPresentationFields.NAMING_POLICY, StringUtils.EMPTY));
229         service.setEnvironmentContext((String) toscaElement.getMetadataValue(JsonPresentationFields.ENVIRONMENT_CONTEXT));
230         service.setInstantiationType((String) toscaElement.getMetadataValueOrDefault(JsonPresentationFields.INSTANTIATION_TYPE, StringUtils.EMPTY));
231     }
232
233     private static Resource convertToResource(ToscaElement toscaElement) {
234         Resource resource = new Resource();
235         convertComponentFields(resource, toscaElement);
236         resource.setResourceType(toscaElement.getResourceType());
237         if (toscaElement.getToscaType() == ToscaElementTypeEnum.NODE_TYPE) {
238             NodeType nodeType = (NodeType) toscaElement;
239             resource.setDerivedFrom(nodeType.getDerivedFrom());
240             resource.setDerivedList(nodeType.getDerivedList());
241             resource.setDerivedFromMapOfIdToName(nodeType.getDerivedFromMapOfIdToName());
242             resource.setAbstract((Boolean) nodeType.getMetadataValue(JsonPresentationFields.IS_ABSTRACT));
243             final String toscaVersion = nodeType.getToscaVersion();
244             if (toscaVersion != null) {
245                 resource.setToscaVersion(toscaVersion);
246             }
247             convertAttributesToResource(nodeType, resource);
248             convertCapabilities(nodeType, resource);
249             convertRequirements(nodeType, resource);
250             convertInterfaces(nodeType, resource);
251             convertDataTypes(nodeType, resource);
252         } else {
253             TopologyTemplate topologyTemplate = (TopologyTemplate) toscaElement;
254             if (resource.getResourceType() == ResourceTypeEnum.VF || resource.getResourceType() == ResourceTypeEnum.PNF) {
255                 resource.setCsarUUID((String) topologyTemplate.getMetadataValue(JsonPresentationFields.CSAR_UUID));
256                 resource.setCsarVersionId((String) topologyTemplate.getMetadataValue(JsonPresentationFields.CSAR_VERSION_ID));
257                 resource.setCsarVersion((String) topologyTemplate.getMetadataValue(JsonPresentationFields.CSAR_VERSION));
258                 resource.setImportedToscaChecksum((String) topologyTemplate.getMetadataValue(JsonPresentationFields.IMPORTED_TOSCA_CHECKSUM));
259                 convertInterfaces(topologyTemplate, resource);
260             }
261             convertComponentInstances(topologyTemplate, resource);
262             convertRelations(topologyTemplate, resource);
263             convertInputs(topologyTemplate, resource);
264             convertOutputs(topologyTemplate, resource);
265             convertGroups(topologyTemplate, resource);
266             setCapabilitiesToComponentAndGroups(topologyTemplate, resource);
267             convertPolicies(topologyTemplate, resource);
268             convertNodeFiltersComponents(topologyTemplate, resource);
269             convertSubstitutionFiltersComponents(topologyTemplate, resource);
270             convertProperties(topologyTemplate, resource);
271             convertAttributesToComponent(topologyTemplate, resource);
272             setCapabilitiesToComponent(topologyTemplate, resource);
273             setRequirementsToComponent(topologyTemplate, resource);
274             convertDataTypes(topologyTemplate, resource);
275         }
276         convertArtifacts(toscaElement, resource);
277         convertAdditionalInformation(toscaElement, resource);
278         return resource;
279     }
280
281     private static void convertInterfaces(TopologyTemplate toscaElement, Resource resource) {
282         Map<String, InterfaceDataDefinition> interfaces = toscaElement.getInterfaces();
283         Map<String, InterfaceDefinition> copy;
284         if (interfaces != null) {
285             copy = interfaces.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new InterfaceDefinition(e.getValue())));
286         } else {
287             copy = new HashMap<>();
288         }
289         resource.setInterfaces(copy);
290     }
291
292     private static void convertServiceInterfaces(TopologyTemplate toscaElement, Service service) {
293         Map<String, InterfaceDataDefinition> interfaces = toscaElement.getInterfaces();
294         Map<String, InterfaceDefinition> copy;
295         if (interfaces != null) {
296             copy = interfaces.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new InterfaceDefinition(e.getValue())));
297         } else {
298             copy = new HashMap<>();
299         }
300         service.setInterfaces(copy);
301     }
302
303     private static void convertAttributesToResource(NodeType nodeType, Resource resource) {
304         Map<String, AttributeDataDefinition> attributes = nodeType.getAttributes();
305         if (attributes != null) {
306             final Map<String, AttributeDefinition> attributeDefinitionMap = attributes.entrySet().stream()
307                 .collect(Collectors.toMap(Entry::getKey, o -> new AttributeDefinition(o.getValue())));
308             resource.setAttributes(new ArrayList<>(attributeDefinitionMap.values()));
309         }
310     }
311
312     private static void convertInterfaces(NodeType nodeType, Resource resource) {
313         Map<String, InterfaceDataDefinition> interfaceArtifacts = nodeType.getInterfaceArtifacts();
314         if (interfaceArtifacts != null) {
315             Map<String, InterfaceDefinition> interfaces = interfaceArtifacts.entrySet().stream()
316                 .collect(Collectors.toMap(Map.Entry::getKey, en -> new InterfaceDefinition(en.getValue())));
317             resource.setInterfaces(interfaces);
318         }
319     }
320
321     /**
322      * Converts component instances of topology template to component instances of resource
323      *
324      * @param topologyTemplate
325      * @param component
326      */
327     public static void convertComponentInstances(TopologyTemplate topologyTemplate, Component component) {
328         if (MapUtils.isNotEmpty(topologyTemplate.getComponentInstances())) {
329             setComponentInstancesAttributesToComponent(topologyTemplate, component);
330             setComponentInstancesPropertiesToComponent(topologyTemplate, component);
331             setComponentInstancesInputsToComponent(topologyTemplate, component);
332             setComponentInstancesOutputsToComponent(topologyTemplate, component);
333             setComponentInstancesToComponent(topologyTemplate, component);
334             setComponentInstancesCapabilitiesToComponentAndCI(topologyTemplate, component);
335             setComponentInstancesRequirementsToComponent(topologyTemplate, component);
336             setComponentInstancesArtifactsToComponent(topologyTemplate, component);
337             setComponentInstancesInterfacesToComponent(topologyTemplate, component);
338         }
339     }
340
341     private static void setComponentInstancesArtifactsToComponent(TopologyTemplate topologyTemplate, Component component) {
342         Map<String, MapArtifactDataDefinition> instDeploymentArtifacts = topologyTemplate.getInstDeploymentArtifacts();
343         Map<String, MapArtifactDataDefinition> instanceArtifacts = topologyTemplate.getInstanceArtifacts();
344         setComponentInstancesDeploymentArtifactsToComponent(instDeploymentArtifacts, component);
345         setComponentInstancesInformationalArtifactsToComponent(instanceArtifacts, component);
346     }
347
348     public static void setComponentInstancesInformationalArtifactsToComponent(Map<String, MapArtifactDataDefinition> instanceArtifacts,
349                                                                               Component component) {
350         List<ComponentInstance> instances = component.getComponentInstances();
351         if (instanceArtifacts != null && instances != null) {
352             instanceArtifacts.entrySet().forEach(e -> {
353                 Optional<ComponentInstance> ci = instances.stream().filter(i -> i.getUniqueId().equals(e.getKey())).findFirst();
354                 if (ci.isPresent()) {
355                     Map<String, ArtifactDataDefinition> mapToscaDataDefinition = e.getValue().getMapToscaDataDefinition();
356                     Map<String, ArtifactDefinition> deplArt = mapToscaDataDefinition.entrySet().stream()
357                         .collect(Collectors.toMap(Map.Entry::getKey, en -> new ArtifactDefinition(en.getValue())));
358                     ci.get().setArtifacts(deplArt);
359                 }
360             });
361         }
362     }
363
364     public static void setComponentInstancesDeploymentArtifactsToComponent(Map<String, MapArtifactDataDefinition> instDeploymentArtifacts,
365                                                                            Component component) {
366         List<ComponentInstance> instances = component.getComponentInstances();
367         if (instDeploymentArtifacts != null && instances != null) {
368             instDeploymentArtifacts.entrySet().forEach(e -> {
369                 Optional<ComponentInstance> ci = instances.stream().filter(i -> i.getUniqueId().equals(e.getKey())).findFirst();
370                 if (ci.isPresent()) {
371                     Map<String, ArtifactDataDefinition> mapToscaDataDefinition = e.getValue().getMapToscaDataDefinition();
372                     Map<String, ArtifactDefinition> deplArt = mapToscaDataDefinition.entrySet().stream()
373                         .collect(Collectors.toMap(Map.Entry::getKey, en -> new ArtifactDefinition(en.getValue())));
374                     ci.get().setDeploymentArtifacts(deplArt);
375                 }
376             });
377         }
378     }
379
380     public static void convertComponentInstances(Component component, TopologyTemplate topologyTemplate) {
381         if (!CollectionUtils.isEmpty(component.getComponentInstances())) {
382             setComponentInstancesAttributesToTopologyTemplate(component, topologyTemplate);
383             setComponentInstancesPropertiesToTopologyTemplate(component, topologyTemplate);
384             setComponentInstancesInputsToTopologyTemplate(component, topologyTemplate);
385             setComponentInstancesToTopologyTemplate(component, topologyTemplate);
386             setComponentInstancesArtifactsToTopologyTemplate(component, topologyTemplate);
387         }
388     }
389
390     public static void convertRelations(TopologyTemplate topologyTemplate, Component component) {
391         Map<String, RelationshipInstDataDefinition> relations = topologyTemplate.getRelations();
392         List<RequirementCapabilityRelDef> componentRelations;
393         if (relations != null && !relations.isEmpty()) {
394             componentRelations = relations.values().stream().map(ModelConverter::convertRelation).collect(Collectors.toList());
395         } else {
396             componentRelations = new ArrayList<>();
397         }
398         component.setComponentInstancesRelations(componentRelations);
399     }
400
401     public static RequirementCapabilityRelDef convertRelation(RelationshipInstDataDefinition relation) {
402         RequirementCapabilityRelDef requirementCapabilityRelDef = new RequirementCapabilityRelDef();
403         requirementCapabilityRelDef.setFromNode(relation.getFromId());
404         requirementCapabilityRelDef.setToNode(relation.getToId());
405         requirementCapabilityRelDef.setOriginUI(BooleanUtils.isTrue(relation.isOriginUI()));
406         CapabilityRequirementRelationship rel = new CapabilityRequirementRelationship();
407         RelationshipInfo relationshipPair = getRelationshipInfo(relation);
408         rel.setRelation(relationshipPair);
409         rel.setOperations(convertToOperations(relation.getInterfaces()));
410         requirementCapabilityRelDef.setRelationships(Arrays.asList(rel));
411         return requirementCapabilityRelDef;
412     }
413
414     private static List<OperationUi> convertToOperations(final ListDataDefinition<InterfaceDataDefinition> interfaces) {
415         if (interfaces == null || interfaces.isEmpty()) {
416             return Collections.emptyList();
417         }
418         final List<OperationUi> operationUiList = new ArrayList<>();
419         for (final InterfaceDataDefinition interfaceDataDefinition : interfaces.getListToscaDataDefinition()) {
420             if (MapUtils.isEmpty(interfaceDataDefinition.getOperations())) {
421                 continue;
422             }
423             for (final Entry<String, OperationDataDefinition> operationEntry : interfaceDataDefinition.getOperations().entrySet()) {
424                 final OperationUi operationUi = new OperationUi();
425                 operationUi.setOperationType(operationEntry.getKey());
426                 operationUi.setInterfaceType(interfaceDataDefinition.getType());
427                 final OperationDataDefinition operationDataDefinition = operationEntry.getValue();
428                 final ArtifactDataDefinition artifactDataDefinition = operationDataDefinition.getImplementation();
429                 if (artifactDataDefinition != null) {
430                     operationUi.setImplementation(artifactDataDefinition);
431                 }
432                 final ListDataDefinition<OperationInputDefinition> inputs = operationDataDefinition.getInputs();
433                 if (inputs != null && !inputs.isEmpty()) {
434                     final List<OperationInputDefinition> operationInputDefinitionList = inputs.getListToscaDataDefinition();
435                     operationInputDefinitionList.forEach(operationInputDefinition -> {
436                         final PropertyAssignmentUi propertyAssignmentUi = new PropertyAssignmentUi();
437                         propertyAssignmentUi.setName(operationInputDefinition.getLabel());
438                         propertyAssignmentUi.setType(operationInputDefinition.getType());
439                         propertyAssignmentUi.setValue(operationInputDefinition.getValue());
440                         operationUi.addToInputs(propertyAssignmentUi);
441                     });
442                 }
443                 operationUiList.add(operationUi);
444             }
445         }
446         return operationUiList;
447     }
448
449     /**
450      * @param relation
451      * @return
452      */
453     private static RelationshipInfo getRelationshipInfo(RelationshipInstDataDefinition relation) {
454         RelationshipInfo relationshipPair = new RelationshipInfo();
455         relationshipPair.setId(relation.getUniqueId());
456         relationshipPair.setCapabilityOwnerId(relation.getCapabilityOwnerId());
457         relationshipPair.setCapabilityUid(relation.getCapabilityId());
458         relationshipPair.setCapability(relation.getCapability());
459         relationshipPair.setRequirementOwnerId(relation.getRequirementOwnerId());
460         relationshipPair.setRequirementUid(relation.getRequirementId());
461         relationshipPair.setRequirement(relation.getRequirement());
462         RelationshipImpl relationship = new RelationshipImpl();
463         relationship.setType(relation.getType());
464         relationshipPair.setRelationships(relationship);
465         return relationshipPair;
466     }
467
468     public static List<RelationshipInstDataDefinition> convertRelationToToscaRelation(RequirementCapabilityRelDef relation) {
469         List<RelationshipInstDataDefinition> relationsList = new ArrayList<>();
470         List<CapabilityRequirementRelationship> relationship = relation.getRelationships();
471         relationship.forEach(p -> {
472             RelationshipInstDataDefinition requirementCapabilityRelDef = new RelationshipInstDataDefinition();
473             requirementCapabilityRelDef.setFromId(relation.getFromNode());
474             requirementCapabilityRelDef.setToId(relation.getToNode());
475             requirementCapabilityRelDef.setUniqueId(p.getRelation().getId());
476             requirementCapabilityRelDef.setCapabilityOwnerId(p.getRelation().getCapabilityOwnerId());
477             requirementCapabilityRelDef.setCapabilityId(p.getRelation().getCapabilityUid());
478             requirementCapabilityRelDef.setRequirementOwnerId(p.getRelation().getRequirementOwnerId());
479             requirementCapabilityRelDef.setRequirementId(p.getRelation().getRequirementUid());
480             requirementCapabilityRelDef.setRequirement(p.getRelation().getRequirement());
481             requirementCapabilityRelDef.setType(p.getRelation().getRelationship().getType());
482             requirementCapabilityRelDef.setCapability(p.getRelation().getCapability());
483             requirementCapabilityRelDef.setOriginUI(relation.isOriginUI());
484             relationsList.add(requirementCapabilityRelDef);
485         });
486         return relationsList;
487     }
488
489     private static void convertCapabilities(Component component, TopologyTemplate topologyTemplate) {
490         convertTopologyTemplateCapabilities(component, topologyTemplate);
491         if (componentInstancesCapabilitiesExist(component) || groupsCapabilitiesExist(component)) {
492             topologyTemplate.setCalculatedCapabilities(new HashMap<>());
493             topologyTemplate.setCalculatedCapabilitiesProperties(new HashMap<>());
494         }
495         convertComponentInstancesCapabilities(component, topologyTemplate);
496         convertGroupsCapabilities(component, topologyTemplate);
497     }
498
499     private static void convertGroupsCapabilities(Component component, TopologyTemplate topologyTemplate) {
500         if (groupsCapabilitiesExist(component)) {
501             component.getGroups().stream().filter(g -> MapUtils.isNotEmpty(g.getCapabilities()))
502                 .forEach(g -> addCapabilities(topologyTemplate, g.getCapabilities(), g.getUniqueId()));
503         }
504     }
505
506     private static void convertTopologyTemplateCapabilities(Component component, ToscaElement toscaElement) {
507         Map<String, List<CapabilityDefinition>> capabilities = component.getCapabilities();
508         Map<String, ListCapabilityDataDefinition> toscaCapMap = new HashMap<>();
509         Map<String, MapPropertiesDataDefinition> toscaCapPropMap = new HashMap<>();
510         if (MapUtils.isNotEmpty(capabilities)) {
511             capabilities.forEach((s, caps) -> {
512                 if (CollectionUtils.isNotEmpty(caps)) {
513                     List<CapabilityDataDefinition> capList = caps.stream()
514                         .filter(capabilityDefinition -> capabilityDefinition.getOwnerId().equals(component.getUniqueId()))
515                         .map(CapabilityDataDefinition::new).collect(Collectors.toList());
516                     populateCapabilityMap(toscaCapMap, toscaCapPropMap, s, caps, capList);
517                 }
518             });
519             toscaElement.setCapabilities(toscaCapMap);
520             toscaElement.setCapabilitiesProperties(toscaCapPropMap);
521         }
522     }
523
524     private static void populateCapabilityMap(Map<String, ListCapabilityDataDefinition> toscaCapMap,
525                                               Map<String, MapPropertiesDataDefinition> toscaCapPropMap, String s, List<CapabilityDefinition> caps,
526                                               List<CapabilityDataDefinition> capList) {
527         ListCapabilityDataDefinition listCapabilityDataDefinition = new ListCapabilityDataDefinition(capList);
528         toscaCapMap.put(s, listCapabilityDataDefinition);
529         for (CapabilityDefinition cap : caps) {
530             List<ComponentInstanceProperty> capPrps = cap.getProperties();
531             if (CollectionUtils.isNotEmpty(capPrps)) {
532                 MapPropertiesDataDefinition dataToCreate = new MapPropertiesDataDefinition();
533                 for (ComponentInstanceProperty cip : capPrps) {
534                     PropertyDataDefinition propertyDataDefinition = new PropertyDataDefinition(cip);
535                     propertyDataDefinition.setParentUniqueId(cap.getUniqueId());
536                     dataToCreate.put(cip.getName(), propertyDataDefinition);
537                 }
538                 toscaCapPropMap.put(s + CAP_PROP_DELIM + cap.getName(), dataToCreate);
539             }
540         }
541     }
542
543     private static void convertTopologyTemplateRequirements(Component component, ToscaElement toscaElement) {
544         Map<String, List<RequirementDefinition>> requirements = component.getRequirements();
545         Map<String, ListRequirementDataDefinition> toscaReqMap = new HashMap<>();
546         if (MapUtils.isNotEmpty(requirements)) {
547             requirements.forEach((s, reqs) -> {
548                 if (CollectionUtils.isNotEmpty(reqs)) {
549                     List<RequirementDataDefinition> reqList = reqs.stream()
550                         .filter(requirementDefinition -> requirementDefinition.getOwnerId().equals(component.getUniqueId()))
551                         .map(RequirementDataDefinition::new).collect(Collectors.toList());
552                     ListRequirementDataDefinition listRequirementDataDefinition = new ListRequirementDataDefinition(reqList);
553                     toscaReqMap.put(s, listRequirementDataDefinition);
554                 }
555             });
556             toscaElement.setRequirements(toscaReqMap);
557         }
558     }
559
560     private static void convertComponentInstancesCapabilities(Component component, TopologyTemplate topologyTemplate) {
561         if (componentInstancesCapabilitiesExist(component)) {
562             component.getComponentInstances().stream().filter(i -> MapUtils.isNotEmpty(i.getCapabilities()))
563                 .forEach(i -> addCapabilities(topologyTemplate, i.getCapabilities(), i.getUniqueId()));
564         }
565     }
566
567     private static void addCapabilities(TopologyTemplate topologyTemplate, Map<String, List<CapabilityDefinition>> capabilities, String ownerId) {
568         if (MapUtils.isNotEmpty(capabilities)) {
569             if (topologyTemplate.getCalculatedCapabilities() == null) {
570                 topologyTemplate.setCalculatedCapabilities(new HashMap<>());
571             }
572             topologyTemplate.getCalculatedCapabilities().put(ownerId, convertToMapListCapabiltyDataDefinition(capabilities));
573             if (topologyTemplate.getCalculatedCapabilitiesProperties() == null) {
574                 topologyTemplate.setCalculatedCapabilitiesProperties(new HashMap<>());
575             }
576             topologyTemplate.getCalculatedCapabilitiesProperties().put(ownerId, convertToMapOfMapCapabiltyProperties(capabilities, ownerId));
577         }
578     }
579
580     private static boolean componentInstancesCapabilitiesExist(Component component) {
581         return component.getCapabilities() != null && component.getComponentInstances() != null && component.getComponentInstances().stream()
582             .anyMatch(ci -> MapUtils.isNotEmpty(ci.getCapabilities()));
583     }
584
585     private static boolean groupsCapabilitiesExist(Component component) {
586         return component.getCapabilities() != null && component.getGroups() != null && component.getGroups().stream()
587             .anyMatch(g -> MapUtils.isNotEmpty(g.getCapabilities()));
588     }
589
590     public static MapCapabilityProperty convertToMapOfMapCapabilityProperties(Map<String, List<CapabilityDefinition>> capabilities, String ownerId,
591                                                                               boolean isAtomicType) {
592         Map<String, MapPropertiesDataDefinition> toscaCapPropMap = new HashMap<>();
593         if (MapUtils.isNotEmpty(capabilities)) {
594             capabilities.forEach((s, caps) -> addCapsProperties(ownerId, isAtomicType, toscaCapPropMap, caps));
595         }
596         return new MapCapabilityProperty(toscaCapPropMap);
597     }
598
599     private static void addCapsProperties(String ownerId, boolean isAtomicType, Map<String, MapPropertiesDataDefinition> toscaCapPropMap,
600                                           List<CapabilityDefinition> caps) {
601         if (CollectionUtils.isNotEmpty(caps)) {
602             caps.forEach(cap -> addCapProperties(ownerId, isAtomicType, toscaCapPropMap, cap));
603         }
604     }
605
606     private static void addCapProperties(String ownerId, boolean isAtomicType, Map<String, MapPropertiesDataDefinition> toscaCapPropMap,
607                                          CapabilityDefinition cap) {
608         if (CollectionUtils.isNotEmpty(cap.getProperties())) {
609             MapPropertiesDataDefinition dataToCreate = new MapPropertiesDataDefinition(
610                 cap.getProperties().stream().map(PropertyDataDefinition::new).collect(Collectors.toMap(PropertyDataDefinition::getName, p -> p)));
611             toscaCapPropMap.put(buildCapabilityPropertyKey(isAtomicType, cap.getType(), cap.getName(), ownerId, cap),
612                 new MapPropertiesDataDefinition(dataToCreate));
613         }
614     }
615
616     public static String buildCapabilityPropertyKey(boolean isAtomicType, String capabilityType, String capabilityName,
617                                                     String componentInstanceUniqueId, CapabilityDefinition cap) {
618         StringBuilder sb = new StringBuilder(componentInstanceUniqueId);
619         sb.append(CAP_PROP_DELIM).append(cap.getOwnerId()).append(CAP_PROP_DELIM);
620         if (!isAtomicType && !componentInstanceUniqueId.equals(cap.getOwnerId())) {
621             sb.append(cap.getOwnerId()).append(CAP_PROP_DELIM);
622         }
623         return sb.append(capabilityType).append(CAP_PROP_DELIM).append(capabilityName).toString();
624     }
625
626     public static MapCapabilityProperty convertToMapOfMapCapabiltyProperties(Map<String, List<CapabilityDefinition>> instCapabilities,
627                                                                              String ownerId) {
628         return convertToMapOfMapCapabiltyProperties(instCapabilities, ownerId, false);
629     }
630
631     public static MapCapabilityProperty convertToMapOfMapCapabiltyProperties(Map<String, List<CapabilityDefinition>> capabilities, String ownerId,
632                                                                              boolean fromCsar) {
633         Map<String, MapPropertiesDataDefinition> toscaCapPropMap = new HashMap<>();
634         if (MapUtils.isNotEmpty(capabilities)) {
635             capabilities.forEach((s, caps) -> {
636                 if (caps != null && !caps.isEmpty()) {
637                     MapPropertiesDataDefinition dataToCreate = new MapPropertiesDataDefinition();
638                     for (CapabilityDefinition cap : caps) {
639                         List<ComponentInstanceProperty> capPrps = cap.getProperties();
640                         if (capPrps != null) {
641                             for (ComponentInstanceProperty cip : capPrps) {
642                                 dataToCreate.put(cip.getName(), new PropertyDataDefinition(cip));
643                             }
644                             // format key of capability properties :
645
646                             // VF instance in service : instanceId#ownerId#type#capName
647
648                             // VFC instance ion VF : instanceId#ownerId#type#capName -> instanceId=ownerId
649                             StringBuilder sb = new StringBuilder(ownerId);
650                             sb.append(CAP_PROP_DELIM);
651                             if (fromCsar) {
652                                 sb.append(ownerId);
653                             } else {
654                                 sb.append(cap.getOwnerId());
655                             }
656                             sb.append(CAP_PROP_DELIM).append(s).append(CAP_PROP_DELIM).append(cap.getName());
657                             toscaCapPropMap.put(sb.toString(), new MapPropertiesDataDefinition(dataToCreate));
658                         }
659                     }
660                 }
661             });
662         }
663         return new MapCapabilityProperty(toscaCapPropMap);
664     }
665
666     private static MapListCapabilityDataDefinition convertToMapListCapabiltyDataDefinition(Map<String, List<CapabilityDefinition>> instCapabilities) {
667         Map<String, ListCapabilityDataDefinition> mapToscaDataDefinition = new HashMap<>();
668         for (Entry<String, List<CapabilityDefinition>> instCapability : instCapabilities.entrySet()) {
669             mapToscaDataDefinition.put(instCapability.getKey(),
670                 new ListCapabilityDataDefinition(instCapability.getValue().stream().map(CapabilityDataDefinition::new).collect(Collectors.toList())));
671         }
672         return new MapListCapabilityDataDefinition(mapToscaDataDefinition);
673     }
674
675     private static void convertRequirements(Component component, TopologyTemplate topologyTemplate) {
676         convertTopologyTemplateRequirements(component, topologyTemplate);
677         if (component.getRequirements() != null && component.getComponentInstances() != null) {
678             topologyTemplate.setCalculatedRequirements(new HashMap<>());
679             for (ComponentInstance instance : component.getComponentInstances()) {
680                 Map<String, List<RequirementDefinition>> instRequirements = instance.getRequirements();
681                 if (MapUtils.isNotEmpty(instRequirements)) {
682                     if (topologyTemplate.getCalculatedRequirements() == null) {
683                         topologyTemplate.setCalculatedRequirements(new HashMap<>());
684                     }
685                     topologyTemplate.getCalculatedRequirements()
686                         .put(instance.getUniqueId(), convertToMapListRequirementDataDefinition(instRequirements));
687                 }
688             }
689         }
690     }
691
692     private static MapListRequirementDataDefinition convertToMapListRequirementDataDefinition(
693         Map<String, List<RequirementDefinition>> instRequirements) {
694         Map<String, ListRequirementDataDefinition> mapToscaDataDefinition = new HashMap<>();
695         for (Entry<String, List<RequirementDefinition>> instRequirement : instRequirements.entrySet()) {
696             mapToscaDataDefinition.put(instRequirement.getKey(), new ListRequirementDataDefinition(
697                 instRequirement.getValue().stream().map(RequirementDataDefinition::new).collect(Collectors.toList())));
698         }
699         return new MapListRequirementDataDefinition(mapToscaDataDefinition);
700     }
701
702     @SuppressWarnings("unchecked")
703     private static void convertComponentFields(Component component, ToscaElement toscaElement) {
704         component.setName(toscaElement.getName());
705         component.setAllVersions(toscaElement.getAllVersions());
706         component.setCategories(toscaElement.getCategories());
707         component.setComponentType(toscaElement.getComponentType());
708         component.setCreationDate(toscaElement.getCreationDate());
709         component.setCreatorUserId(toscaElement.getCreatorUserId());
710         component.setCreatorFullName(toscaElement.getCreatorFullName());
711         component.setLastUpdateDate(toscaElement.getLastUpdateDate());
712         component.setLastUpdaterFullName(toscaElement.getLastUpdaterFullName());
713         component.setLastUpdaterUserId(toscaElement.getLastUpdaterUserId());
714         component.setNormalizedName(toscaElement.getNormalizedName());
715         component.setLifecycleState(toscaElement.getLifecycleState());
716         component.setVersion(toscaElement.getVersion());
717         component.setHighestVersion(toscaElement.isHighestVersion());
718         component.setUniqueId(toscaElement.getUniqueId());
719         component.setSystemName((String) toscaElement.getMetadataValue(JsonPresentationFields.SYSTEM_NAME));
720         component.setDerivedFromGenericType(toscaElement.getDerivedFromGenericType());
721         component.setDerivedFromGenericVersion(toscaElement.getDerivedFromGenericVersion());
722         if(toscaElement.getModel() != null) {
723             component.setModel(toscaElement.getModel());
724         }
725         Map<String, PropertyDataDefinition> properties = toscaElement.getProperties();
726         if (MapUtils.isNotEmpty(properties)) {
727             List<PropertyDefinition> propertiesMap = properties.values().stream().map(x -> new PropertyDefinition(x)).collect(Collectors.toList());
728             component.setProperties(propertiesMap);
729         }
730         //archive
731         component.setArchived(toscaElement.isArchived() == null ? false : toscaElement.isArchived());
732         component.setArchiveTime(toscaElement.getArchiveTime());
733         component.setVspArchived(toscaElement.isVspArchived() == null ? false : toscaElement.isVspArchived());
734         if (component.getComponentType() == ComponentTypeEnum.RESOURCE) {
735             Resource resource = (Resource) component;
736             resource.setAbstract((Boolean) toscaElement.getMetadataValue(JsonPresentationFields.IS_ABSTRACT));
737             resource.setToscaResourceName((String) toscaElement.getMetadataValue(JsonPresentationFields.TOSCA_RESOURCE_NAME));
738             resource.setVendorName((String) toscaElement.getMetadataValue(JsonPresentationFields.VENDOR_NAME));
739             resource.setVendorRelease((String) toscaElement.getMetadataValue(JsonPresentationFields.VENDOR_RELEASE));
740             // field isn't mandatory , but shouldn't be null(should be an empty string instead)
741             if (((String) toscaElement.getMetadataValue(JsonPresentationFields.RESOURCE_VENDOR_MODEL_NUMBER)) != null) {
742                 resource.setResourceVendorModelNumber((String) toscaElement.getMetadataValue(JsonPresentationFields.RESOURCE_VENDOR_MODEL_NUMBER));
743             } else {
744                 resource.setResourceVendorModelNumber("");
745             }
746         } else if (component.getComponentType() == ComponentTypeEnum.SERVICE) {
747             Service service = (Service) component;
748             if (((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_TYPE)) != null) {
749                 service.setServiceType((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_TYPE));
750             } else {
751                 service.setServiceType("");
752             }
753             if (((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_ROLE)) != null) {
754                 service.setServiceRole((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_ROLE));
755             } else {
756                 service.setServiceRole("");
757             }
758             if (((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_FUNCTION)) != null) {
759                 service.setServiceFunction((String) toscaElement.getMetadataValue(JsonPresentationFields.SERVICE_FUNCTION));
760             } else {
761                 service.setServiceFunction("");
762             }
763         }
764         component.setConformanceLevel((String) toscaElement.getMetadataValue(JsonPresentationFields.CONFORMANCE_LEVEL));
765         component.setIcon((String) toscaElement.getMetadataValue(JsonPresentationFields.ICON));
766         component.setDescription((String) toscaElement.getMetadataValue(JsonPresentationFields.DESCRIPTION));
767         component.setTags((List<String>) toscaElement.getMetadataValue(JsonPresentationFields.TAGS));
768         component.setInvariantUUID((String) toscaElement.getMetadataValue(JsonPresentationFields.INVARIANT_UUID));
769         component.setContactId((String) toscaElement.getMetadataValue(JsonPresentationFields.CONTACT_ID));
770         component.setUUID((String) toscaElement.getMetadataValue(JsonPresentationFields.UUID));
771         component.setIsDeleted((Boolean) toscaElement.getMetadataValue(JsonPresentationFields.IS_DELETED));
772         component.setModel((String) toscaElement.getMetadataValue(JsonPresentationFields.MODEL));
773         component.setToscaType(toscaElement.getToscaType().getValue());
774         final List<MetadataKeyDataDefinition> metadataKeys = getCategorySpecificMetadataKeys(toscaElement);
775         if (CollectionUtils.isNotEmpty(metadataKeys)) {
776             final Map<String, String> categorySpecificMetadata = new HashMap<>();
777             for (final MetadataKeyDataDefinition metadataKey : metadataKeys) {
778                 if (toscaElement.getMetadata().get(metadataKey.getName()) != null) {
779                     categorySpecificMetadata.put(metadataKey.getName(), (String) toscaElement.getMetadata().get(metadataKey.getName()));
780                 } else if (metadataKey.getDefaultValue() != null && metadataKey.isMandatory()) {
781                     categorySpecificMetadata.put(metadataKey.getName(), metadataKey.getDefaultValue());
782                 }
783             }
784             component.setCategorySpecificMetadata(categorySpecificMetadata);
785         }
786     }
787     
788     private static List<MetadataKeyDataDefinition> getCategorySpecificMetadataKeys(final ToscaElement toscaElement) {
789         final List<MetadataKeyDataDefinition> metadataKeys = new ArrayList<>();
790         final Optional<CategoryDefinition> category = getCategory(toscaElement);
791         if (category.isPresent()) {
792             if (CollectionUtils.isNotEmpty(category.get().getMetadataKeys())) {
793                 metadataKeys.addAll(category.get().getMetadataKeys());
794             }
795             final Optional<SubCategoryDefinition> subCategory = getSubCategory(category.get());
796             if (subCategory.isPresent() && CollectionUtils.isNotEmpty(subCategory.get().getMetadataKeys())) {
797                 metadataKeys.addAll(subCategory.get().getMetadataKeys());
798             }
799         }
800         return metadataKeys;
801     }
802
803     private static Optional<CategoryDefinition> getCategory(ToscaElement toscaElement) {
804         return CollectionUtils.isEmpty(toscaElement.getCategories()) ? Optional.empty() : Optional.of(toscaElement.getCategories().get(0));
805     }
806
807     private static Optional<SubCategoryDefinition> getSubCategory(CategoryDefinition category) {
808         return CollectionUtils.isEmpty(category.getSubcategories()) ? Optional.empty() : Optional.of(category.getSubcategories().get(0));
809     }
810
811     private static NodeType convertToNodeType(Component component) {
812         Resource resource = (Resource) component;
813         NodeType nodeType = new NodeType();
814         nodeType.setDerivedFrom(resource.getDerivedFrom());
815         nodeType.setDerivedList(resource.getDerivedList());
816         nodeType.setResourceType(resource.getResourceType());
817         final String toscaVersion = resource.getToscaVersion();
818         if (toscaVersion != null) {
819             nodeType.setToscaVersion(toscaVersion);
820         }
821         final List<DataTypeDefinition> dataTypes = resource.getDataTypes();
822         if (CollectionUtils.isNotEmpty(dataTypes)) {
823             nodeType
824                 .setDataTypes(dataTypes.stream().collect(Collectors.toMap(DataTypeDefinition::getName, dataTypeDefinition -> dataTypeDefinition)));
825         }
826         convertCommonToscaData(component, nodeType);
827         convertAdditionalInformation(component, nodeType);
828         convertArtifacts(resource, nodeType);
829         convertCapabilities(resource, nodeType);
830         convertRequirements(resource, nodeType);
831         convertAttributesToNodeType(resource, nodeType);
832         convertProperties(resource, nodeType);
833         convertInterfaces(resource, nodeType);
834         return nodeType;
835     }
836
837     private static void convertProperties(Resource resource, NodeType nodeType) {
838         List<PropertyDefinition> properties = resource.getProperties();
839         if (properties != null && !properties.isEmpty()) {
840             Map<String, PropertyDataDefinition> propertiesMap = properties.stream()
841                 .collect(Collectors.toMap(PropertyDefinition::getName, PropertyDataDefinition::new));
842             nodeType.setProperties(propertiesMap);
843         }
844     }
845
846     private static void convertInterfaces(Resource resource, NodeType nodeType) {
847         Map<String, InterfaceDefinition> interfaces = resource.getInterfaces();
848         if (interfaces != null) {
849             Map<String, InterfaceDataDefinition> interfaceArtifacts = interfaces.entrySet().stream()
850                 .collect(Collectors.toMap(Map.Entry::getKey, x -> new InterfaceDataDefinition(x.getValue())));
851             nodeType.setInterfaceArtifacts(interfaceArtifacts);
852         }
853     }
854
855     private static void convertAdditionalInformation(Component component, ToscaElement toscaElement) {
856         List<AdditionalInformationDefinition> additionalInformation = component.getAdditionalInformation();
857         if (additionalInformation != null) {
858             Map<String, AdditionalInfoParameterDataDefinition> addInfo = additionalInformation.stream()
859                 .collect(Collectors.toMap(AdditionalInformationDefinition::getUniqueId, AdditionalInfoParameterDataDefinition::new));
860             toscaElement.setAdditionalInformation(addInfo);
861         }
862     }
863
864     private static void convertAdditionalInformation(ToscaElement toscaElement, Component resource) {
865         Map<String, AdditionalInfoParameterDataDefinition> additionalInformation = toscaElement.getAdditionalInformation();
866         if (additionalInformation != null) {
867             List<AdditionalInformationDefinition> addInfo = additionalInformation.values().stream().map(AdditionalInformationDefinition::new)
868                 .collect(Collectors.toList());
869             resource.setAdditionalInformation(addInfo);
870         }
871     }
872
873     private static void convertArtifacts(ToscaElement toscaElement, Component component) {
874         Map<String, ArtifactDataDefinition> artifacts = toscaElement.getArtifacts();
875         Map<String, ArtifactDefinition> copy;
876         if (artifacts != null) {
877             copy = artifacts.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDefinition(e.getValue())));
878         } else {
879             copy = new HashMap<>();
880         }
881         component.setArtifacts(copy);
882         Map<String, ArtifactDataDefinition> toscaArtifacts = toscaElement.getToscaArtifacts();
883         if (toscaArtifacts != null) {
884             copy = toscaArtifacts.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDefinition(e.getValue())));
885         } else {
886             copy = new HashMap<>();
887         }
888         component.setToscaArtifacts(copy);
889         Map<String, ArtifactDataDefinition> deploymentArtifacts = toscaElement.getDeploymentArtifacts();
890         if (deploymentArtifacts != null) {
891             copy = deploymentArtifacts.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDefinition(e.getValue())));
892         } else {
893             copy = new HashMap<>();
894         }
895         component.setDeploymentArtifacts(copy);
896     }
897
898     private static void convertNodeFiltersComponents(final TopologyTemplate topologyTemplate, final Component component) {
899         final Map<String, CINodeFilterDataDefinition> filters = topologyTemplate.getNodeFilterComponents();
900         final Map<String, CINodeFilterDataDefinition> copy;
901         if (MapUtils.isNotEmpty(filters)) {
902             copy = filters.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new CINodeFilterDataDefinition(e.getValue())));
903         } else {
904             copy = new HashMap<>();
905         }
906         component.setNodeFilterComponents(copy);
907     }
908
909     private static void convertSubstitutionFiltersComponents(final TopologyTemplate topologyTemplate, final Component component) {
910         final SubstitutionFilterDataDefinition filters = topologyTemplate.getSubstitutionFilters();
911         if (filters == null){
912             component.setSubstitutionFilter(null);
913             return;
914         }
915         component.setSubstitutionFilter(new SubstitutionFilterDataDefinition(filters));
916     }
917
918     private static void convertServiceApiArtifacts(TopologyTemplate topologyTemplate, Service service) {
919         Map<String, ArtifactDataDefinition> serviceApiArtifacts = topologyTemplate.getServiceApiArtifacts();
920         Map<String, ArtifactDefinition> copy;
921         if (serviceApiArtifacts != null) {
922             copy = serviceApiArtifacts.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDefinition(e.getValue())));
923         } else {
924             copy = new HashMap<>();
925         }
926         service.setServiceApiArtifacts(copy);
927     }
928
929     private static void convertServicePaths(TopologyTemplate topologyTemplate, Service service) {
930         Map<String, ForwardingPathDataDefinition> servicePaths = topologyTemplate.getForwardingPaths();
931         Map<String, ForwardingPathDataDefinition> copy;
932         if (servicePaths != null) {
933             copy = servicePaths.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, e -> new ForwardingPathDataDefinition(e.getValue())));
934         } else {
935             copy = new HashMap<>();
936         }
937         service.setForwardingPaths(copy);
938     }
939
940     private static void convertArtifacts(Component component, ToscaElement toscaElement) {
941         Map<String, ArtifactDefinition> artifacts = component.getArtifacts();
942         if (artifacts != null) {
943             Map<String, ArtifactDataDefinition> copy = artifacts.entrySet().stream()
944                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
945             toscaElement.setArtifacts(copy);
946         }
947         Map<String, ArtifactDefinition> toscaArtifacts = component.getToscaArtifacts();
948         if (toscaArtifacts != null) {
949             Map<String, ArtifactDataDefinition> copy = toscaArtifacts.entrySet().stream()
950                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
951             toscaElement.setToscaArtifacts(copy);
952         }
953         Map<String, ArtifactDefinition> deploymentArtifacts = component.getDeploymentArtifacts();
954         if (deploymentArtifacts != null) {
955             Map<String, ArtifactDataDefinition> copy = deploymentArtifacts.entrySet().stream()
956                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
957             toscaElement.setDeploymentArtifacts(copy);
958         }
959     }
960
961     private static void convertServiceApiArtifacts(Service service, TopologyTemplate topologyTemplate) {
962         Map<String, ArtifactDefinition> serviceApiArtifacts = service.getServiceApiArtifacts();
963         if (serviceApiArtifacts != null) {
964             Map<String, ArtifactDataDefinition> copy = serviceApiArtifacts.entrySet().stream()
965                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
966             topologyTemplate.setServiceApiArtifacts(copy);
967         }
968     }
969
970     private static void convertCapabilities(Component component, NodeType toscaElement) {
971         Map<String, List<CapabilityDefinition>> capabilities = component.getCapabilities();
972         Map<String, ListCapabilityDataDefinition> toscaCapMap = new HashMap<>();
973         Map<String, MapPropertiesDataDefinition> toscaCapPropMap = new HashMap<>();
974         if (capabilities != null && !capabilities.isEmpty()) {
975             capabilities.forEach((s, caps) -> {
976                 if (caps != null && !caps.isEmpty()) {
977                     List<CapabilityDataDefinition> capList = caps.stream().map(CapabilityDataDefinition::new).collect(Collectors.toList());
978                     populateCapabilityMap(toscaCapMap, toscaCapPropMap, s, caps, capList);
979                 }
980             });
981             toscaElement.setCapabilities(toscaCapMap);
982             toscaElement.setCapabilitiesProperties(toscaCapPropMap);
983         }
984     }
985
986     private static void convertAttributesToNodeType(Resource component, NodeType nodeType) {
987         List<AttributeDefinition> attributes = component.getAttributes();
988         if (CollectionUtils.isNotEmpty(attributes)) {
989             Map<String, AttributeDataDefinition> attrsByName = attributes.stream()
990                 .collect(Collectors.toMap(AttributeDefinition::getName, Function.identity()));
991             nodeType.setAttributes(attrsByName);
992         }
993     }
994
995     private static void convertRequirements(Resource component, NodeType nodeType) {
996         Map<String, List<RequirementDefinition>> requirements = component.getRequirements();
997         Map<String, ListRequirementDataDefinition> toscaReqMap = new HashMap<>();
998         if (requirements != null && !requirements.isEmpty()) {
999             requirements.forEach((s, reqs) -> {
1000                 if (reqs != null && !reqs.isEmpty()) {
1001                     List<RequirementDataDefinition> reqList = reqs.stream().map(RequirementDataDefinition::new).collect(Collectors.toList());
1002                     ListRequirementDataDefinition listRequirementDataDefinition = new ListRequirementDataDefinition(reqList);
1003                     toscaReqMap.put(s, listRequirementDataDefinition);
1004                 }
1005             });
1006             nodeType.setRequirements(toscaReqMap);
1007         }
1008     }
1009
1010     private static void convertCapabilities(NodeType toscaElement, Component component) {
1011         Map<String, ListCapabilityDataDefinition> toscaCapabilities = toscaElement.getCapabilities();
1012         Map<String, MapPropertiesDataDefinition> toscaCapPropMap = toscaElement.getCapabilitiesProperties();
1013         Map<String, List<CapabilityDefinition>> capabilitiesMapFromMapObject = getCapabilitiesMapFromMapObject(toscaCapabilities, toscaCapPropMap);
1014         if (capabilitiesMapFromMapObject != null) {
1015             component.setCapabilities(capabilitiesMapFromMapObject);
1016         }
1017     }
1018
1019     public static Map<String, List<CapabilityDefinition>> getCapabilitiesMapFromMapObject(Map<String, ListCapabilityDataDefinition> toscaCapabilities,
1020                                                                                           Map<String, MapPropertiesDataDefinition> toscaCapPropMap) {
1021         Map<String, List<CapabilityDefinition>> compCap = new HashMap<>();
1022         if (toscaCapabilities == null || toscaCapabilities.isEmpty()) {
1023             return null;
1024         }
1025         toscaCapabilities.forEach((s, cap) -> {
1026             if (cap != null) {
1027                 List<CapabilityDataDefinition> capDataList = cap.getListToscaDataDefinition();
1028                 if (capDataList != null && !capDataList.isEmpty()) {
1029                     List<CapabilityDefinition> capList = capDataList.stream().map(CapabilityDefinition::new).collect(Collectors.toList());
1030                     compCap.put(s, capList);
1031                 }
1032             }
1033         });
1034         if (toscaCapPropMap != null && !toscaCapPropMap.isEmpty()) {
1035             toscaCapPropMap.forEach((s, capProp) -> {
1036                 String[] result = s.split(CAP_PROP_DELIM);
1037                 if (capProp != null) {
1038                     Map<String, PropertyDataDefinition> capMap = capProp.getMapToscaDataDefinition();
1039                     if (capMap != null && !capMap.isEmpty()) {
1040                         List<ComponentInstanceProperty> capPropsList = capMap.values().stream().map(ComponentInstanceProperty::new)
1041                             .collect(Collectors.toList());
1042                         List<CapabilityDefinition> cap = compCap.get(result[0]);
1043                         Optional<CapabilityDefinition> op = cap.stream().filter(c -> c.getName().equals(result[1])).findFirst();
1044                         op.ifPresent(capabilityDefinition -> capabilityDefinition.setProperties(capPropsList));
1045                     }
1046                 }
1047             });
1048         }
1049         return compCap;
1050     }
1051
1052     private static void convertGroups(TopologyTemplate toscaElement, Component component) {
1053         Map<String, GroupDataDefinition> toscaGroups = toscaElement.getGroups();
1054         List<GroupDefinition> groupDefinitions = null;
1055         if (MapUtils.isNotEmpty(toscaGroups)) {
1056             groupDefinitions = toscaGroups.values().stream().map(GroupDefinition::new).collect(Collectors.toList());
1057         }
1058         component.setGroups(groupDefinitions);
1059     }
1060
1061     private static void convertPolicies(TopologyTemplate toscaElement, Component component) {
1062         Map<String, PolicyDataDefinition> policies = toscaElement.getPolicies();
1063         Map<String, PolicyDefinition> policyDefinitions = null;
1064         if (MapUtils.isNotEmpty(policies)) {
1065             policyDefinitions = policies.values().stream().map(PolicyDefinition::new)
1066                 .collect(Collectors.toMap(PolicyDefinition::getUniqueId, Function.identity()));
1067         }
1068         component.setPolicies(policyDefinitions);
1069     }
1070
1071     private static void convertGroups(Component component, TopologyTemplate toscaElement) {
1072         List<GroupDefinition> groupDefinitions = component.getGroups();
1073         Map<String, GroupDataDefinition> groups = new HashMap<>();
1074         if (groupDefinitions != null && groups.isEmpty()) {
1075             groups = groupDefinitions.stream().collect(Collectors.toMap(GroupDefinition::getInvariantName, GroupDefinition::new));
1076         }
1077         toscaElement.setGroups(groups);
1078     }
1079
1080     private static void convertPolicies(Component component, TopologyTemplate toscaElement) {
1081         Map<String, PolicyDefinition> policyDefinitions = component.getPolicies();
1082         Map<String, PolicyDataDefinition> policies = new HashMap<>();
1083         if (MapUtils.isNotEmpty(policyDefinitions)) {
1084             policies = policyDefinitions.values().stream().collect((Collectors.toMap(PolicyDefinition::getUniqueId, PolicyDataDefinition::new)));
1085         }
1086         toscaElement.setPolicies(policies);
1087     }
1088
1089     private static void convertRequirements(NodeType toscaElement, Component component) {
1090         Map<String, ListRequirementDataDefinition> toscaRequirements = toscaElement.getRequirements();
1091         Map<String, List<RequirementDefinition>> compReqs = new HashMap<>();
1092         if (toscaRequirements == null || toscaRequirements.isEmpty()) {
1093             return;
1094         }
1095         toscaRequirements.forEach((s, req) -> {
1096             if (req != null) {
1097                 List<RequirementDataDefinition> reqDataList = req.getListToscaDataDefinition();
1098                 if (reqDataList != null && !reqDataList.isEmpty()) {
1099                     List<RequirementDefinition> reqList = reqDataList.stream().map(RequirementDefinition::new).collect(Collectors.toList());
1100                     compReqs.put(s, reqList);
1101                 }
1102             }
1103         });
1104         component.setRequirements(compReqs);
1105     }
1106
1107     private static TopologyTemplate convertToTopologyTemplate(Component component) {
1108         TopologyTemplate topologyTemplate;
1109         ComponentTypeEnum componentType = component.getComponentType();
1110         topologyTemplate = new TopologyTemplate();
1111         if (componentType == ComponentTypeEnum.RESOURCE) {
1112             Resource resource = (Resource) component;
1113             topologyTemplate.setResourceType(resource.getResourceType());
1114             topologyTemplate.setMetadataValue(JsonPresentationFields.CSAR_UUID, resource.getCsarUUID());
1115             topologyTemplate.setMetadataValue(JsonPresentationFields.CSAR_VERSION, resource.getCsarVersion());
1116             topologyTemplate.setMetadataValue(JsonPresentationFields.CSAR_VERSION_ID, resource.getCsarVersionId());
1117             topologyTemplate.setMetadataValue(JsonPresentationFields.IMPORTED_TOSCA_CHECKSUM, resource.getImportedToscaChecksum());
1118             convertTopologyTemplateInterfaces(resource, topologyTemplate);
1119         }
1120         if (componentType == ComponentTypeEnum.SERVICE) {
1121             convertServiceSpecificEntities((Service) component, topologyTemplate);
1122         }
1123         convertCommonToscaData(component, topologyTemplate);
1124         convertArtifacts(component, topologyTemplate);
1125         convertAdditionalInformation(component, topologyTemplate);
1126         convertComponentInstances(component, topologyTemplate);
1127         convertInputs(component, topologyTemplate);
1128         convertProperties(component, topologyTemplate);
1129         convertAttributesToTopologyTemplate(component, topologyTemplate);
1130         convertCapabilities(component, topologyTemplate);
1131         convertGroups(component, topologyTemplate);
1132         convertPolicies(component, topologyTemplate);
1133         convertRequirements(component, topologyTemplate);
1134         convertRelationsToComposition(component, topologyTemplate);
1135         return topologyTemplate;
1136     }
1137
1138     private static void convertTopologyTemplateInterfaces(Resource resource, TopologyTemplate topologyTemplate) {
1139         Map<String, InterfaceDefinition> interfaces = resource.getInterfaces();
1140         if (interfaces != null && !interfaces.isEmpty()) {
1141             Map<String, InterfaceDataDefinition> copy = interfaces.entrySet().stream()
1142                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new InterfaceDataDefinition(e.getValue())));
1143             topologyTemplate.setInterfaces(copy);
1144         }
1145     }
1146
1147     private static void convertServiceSpecificEntities(Service service, TopologyTemplate topologyTemplate) {
1148         convertServiceMetaData(service, topologyTemplate);
1149         convertServiceApiArtifacts(service, topologyTemplate);
1150         convertServicePaths(service, topologyTemplate);
1151         convertServiceInterfaces(topologyTemplate, service);
1152     }
1153
1154     private static void convertServicePaths(Service service, TopologyTemplate topologyTemplate) {
1155         Map<String, ForwardingPathDataDefinition> servicePaths = service.getForwardingPaths();
1156         if (servicePaths != null && !servicePaths.isEmpty()) {
1157             Map<String, ForwardingPathDataDefinition> copy = servicePaths.entrySet().stream()
1158                 .collect(Collectors.toMap(Map.Entry::getKey, e -> new ForwardingPathDataDefinition(e.getValue())));
1159             topologyTemplate.setForwardingPaths(copy);
1160         }
1161     }
1162
1163     private static void convertServiceMetaData(Service service, TopologyTemplate topologyTemplate) {
1164         if (service.getDistributionStatus() != null) {
1165             topologyTemplate.setMetadataValue(JsonPresentationFields.DISTRIBUTION_STATUS, service.getDistributionStatus().name());
1166         }
1167         topologyTemplate.setMetadataValue(JsonPresentationFields.PROJECT_CODE, service.getProjectCode());
1168         topologyTemplate.setMetadataValue(JsonPresentationFields.ECOMP_GENERATED_NAMING, service.isEcompGeneratedNaming());
1169         topologyTemplate.setMetadataValue(JsonPresentationFields.NAMING_POLICY, service.getNamingPolicy());
1170         topologyTemplate.setMetadataValue(JsonPresentationFields.ENVIRONMENT_CONTEXT, service.getEnvironmentContext());
1171         topologyTemplate.setMetadataValue(JsonPresentationFields.INSTANTIATION_TYPE, service.getInstantiationType());
1172     }
1173
1174     private static void convertRelationsToComposition(Component component, TopologyTemplate topologyTemplate) {
1175         List<RequirementCapabilityRelDef> componentInstancesRelations = component.getComponentInstancesRelations();
1176         if (componentInstancesRelations != null) {
1177             Map<String, CompositionDataDefinition> compositions = topologyTemplate.getCompositions();
1178             if (compositions == null) {
1179                 compositions = new HashMap<>();
1180             }
1181             CompositionDataDefinition compositionDataDefinition = compositions.get(JsonConstantKeysEnum.COMPOSITION.getValue());
1182             if (compositionDataDefinition == null) {
1183                 compositionDataDefinition = new CompositionDataDefinition();
1184                 compositions.put(JsonConstantKeysEnum.COMPOSITION.getValue(), compositionDataDefinition);
1185             }
1186             Map<String, RelationshipInstDataDefinition> relations = componentInstancesRelations.stream()
1187                 .flatMap(x -> convertRelationToToscaRelation(x).stream()).filter(i -> i.getUniqueId() != null)
1188                 .collect(Collectors.toMap(RelationshipInstDataDefinition::getUniqueId, Function.identity()));
1189             compositionDataDefinition.setRelations(relations);
1190         }
1191     }
1192
1193     private static void convertInputs(Component component, TopologyTemplate topologyTemplate) {
1194         List<InputDefinition> inputsList = component.getInputs();
1195         if (inputsList != null && !inputsList.isEmpty()) {
1196             Map<String, PropertyDataDefinition> inputsMap = inputsList.stream().map(PropertyDataDefinition::new)
1197                 .collect(Collectors.toMap(PropertyDataDefinition::getName, Function.identity()));
1198             topologyTemplate.setInputs(inputsMap);
1199         }
1200     }
1201
1202     private static void convertInputs(TopologyTemplate topologyTemplate, Component component) {
1203         Map<String, PropertyDataDefinition> inputsMap = topologyTemplate.getInputs();
1204         if (inputsMap != null && !inputsMap.isEmpty()) {
1205             List<InputDefinition> inputsList = inputsMap.values().stream().map(InputDefinition::new).collect(Collectors.toList());
1206             component.setInputs(inputsList);
1207         }
1208     }
1209
1210     private static void convertOutputs(final TopologyTemplate topologyTemplate, final Component component) {
1211         final Map<String, AttributeDataDefinition> outputsMap = topologyTemplate.getOutputs();
1212         if (MapUtils.isEmpty(outputsMap)) {
1213             return;
1214         }
1215         final List<OutputDefinition> outputList = outputsMap.values().stream().map(OutputDefinition::new).collect(Collectors.toList());
1216         component.setOutputs(outputList);
1217     }
1218
1219     private static void convertProperties(Component component, TopologyTemplate topologyTemplate) {
1220         List<PropertyDefinition> propertiesList = component.getProperties();
1221         if (propertiesList != null && !propertiesList.isEmpty()) {
1222             Map<String, PropertyDataDefinition> propertiesMap = propertiesList.stream().map(i -> new PropertyDataDefinition(i))
1223                 .collect(Collectors.toMap(i -> i.getName(), i -> i));
1224             topologyTemplate.setProperties(propertiesMap);
1225         }
1226     }
1227
1228     private static void convertAttributesToTopologyTemplate(final Component component, final TopologyTemplate topologyTemplate) {
1229         final List<AttributeDefinition> attributes = component.getAttributes();
1230         if (CollectionUtils.isNotEmpty(attributes)) {
1231             final Map<String, AttributeDataDefinition> attributeDataDefinitionMap = attributes.stream().map(AttributeDataDefinition::new)
1232                 .collect(Collectors.toMap(AttributeDataDefinition::getName, i -> i));
1233             topologyTemplate.setAttributes(attributeDataDefinitionMap);
1234         }
1235     }
1236
1237     private static void convertProperties(TopologyTemplate topologyTemplate, Component component) {
1238         Map<String, PropertyDataDefinition> propertiesMap = topologyTemplate.getProperties();
1239         if (propertiesMap != null && !propertiesMap.isEmpty()) {
1240             Map<String, PropertyDefinition> copy = propertiesMap.entrySet().stream()
1241                 .collect(Collectors.toMap(entry -> entry.getKey(), entry -> new PropertyDefinition(entry.getValue())));
1242             component.setProperties(new ArrayList<>(copy.values()));
1243         }
1244     }
1245
1246     private static void convertAttributesToComponent(final TopologyTemplate topologyTemplate, final Component component) {
1247         final Map<String, AttributeDataDefinition> attributes = topologyTemplate.getAttributes();
1248         if (MapUtils.isNotEmpty(attributes)) {
1249             Map<String, AttributeDefinition> copy = attributes.entrySet().stream()
1250                 .collect(Collectors.toMap(entry -> entry.getKey(), entry -> new AttributeDefinition(entry.getValue())));
1251             component.setAttributes(new ArrayList<>(copy.values()));
1252         }
1253     }
1254
1255     private static void convertDataTypes(final ToscaElement toscaElement, final Component component) {
1256         final Map<String, DataTypeDataDefinition> dataTypeDataMap = toscaElement.getDataTypes();
1257         if (MapUtils.isNotEmpty(dataTypeDataMap)) {
1258             final List<DataTypeDefinition> dataTypeDefinitionList = dataTypeDataMap.values().stream().map(dataTypeDataDefinition -> {
1259                 final DataTypeDefinition dataTypeDefinition = new DataTypeDefinition(dataTypeDataDefinition);
1260                 if (CollectionUtils.isNotEmpty(dataTypeDataDefinition.getPropertiesData())) {
1261                     log.debug("#convertDataTypes - propertiesData is not null. {}",
1262                         ReflectionToStringBuilder.toString(dataTypeDataDefinition.getPropertiesData()));
1263                     dataTypeDefinition
1264                         .setProperties(dataTypeDataDefinition.getPropertiesData().stream().map(PropertyDefinition::new).collect(Collectors.toList()));
1265                 } else {
1266                     log.debug("#convertDataTypes - propertiesData is null. ignore.");
1267                 }
1268                 return dataTypeDefinition;
1269             }).collect(Collectors.toList());
1270             component.setDataTypes(dataTypeDefinitionList);
1271         }
1272     }
1273
1274     private static void convertCommonToscaData(Component component, ToscaElement toscaElement) {
1275         toscaElement.setUUID(component.getUUID());
1276         toscaElement.setUniqueId(component.getUniqueId());
1277         toscaElement.setSystemName(component.getSystemName());
1278         toscaElement.setLifecycleState(component.getLifecycleState());
1279         toscaElement.setComponentType(component.getComponentType());
1280         toscaElement.setNormalizedName(component.getNormalizedName());
1281         toscaElement.setMetadataValue(JsonPresentationFields.NAME, component.getName());
1282         toscaElement.setCategories(component.getCategories());
1283         toscaElement.setCreatorUserId(component.getCreatorUserId());
1284         toscaElement.setCreationDate(component.getCreationDate());
1285         toscaElement.setCreatorFullName(component.getCreatorFullName());
1286         toscaElement.setHighestVersion(component.isHighestVersion());
1287         toscaElement.setLastUpdateDate(component.getLastUpdateDate());
1288         toscaElement.setLastUpdaterFullName(component.getLastUpdaterFullName());
1289         toscaElement.setLastUpdaterUserId(component.getLastUpdaterUserId());
1290         toscaElement.setDerivedFromGenericType(component.getDerivedFromGenericType());
1291         toscaElement.setDerivedFromGenericVersion(component.getDerivedFromGenericVersion());
1292         //Archive
1293         toscaElement.setArchived(component.isArchived() == null ? false : component.isArchived());
1294         toscaElement.setArchiveTime(component.getArchiveTime() == null ? 0L : component.getArchiveTime());
1295         toscaElement.setVspArchived(component.isVspArchived() == null ? false : component.isVspArchived());
1296         toscaElement.setLifecycleState(component.getLifecycleState());
1297         toscaElement.setMetadataValue(JsonPresentationFields.VERSION, component.getVersion());
1298         if (component.getComponentType() == ComponentTypeEnum.RESOURCE) {
1299             toscaElement.setMetadataValue(JsonPresentationFields.IS_ABSTRACT, ((Resource) component).isAbstract());
1300             toscaElement.setMetadataValue(JsonPresentationFields.TOSCA_RESOURCE_NAME, ((Resource) component).getToscaResourceName());
1301             toscaElement.setMetadataValue(JsonPresentationFields.VENDOR_NAME, ((Resource) component).getVendorName());
1302             toscaElement.setMetadataValue(JsonPresentationFields.VENDOR_RELEASE, ((Resource) component).getVendorRelease());
1303             toscaElement.setMetadataValue(JsonPresentationFields.MODEL, component.getModel());
1304             // field isn't mandatory , but shouldn't be null(should be an empty string instead)
1305             if (((Resource) component).getResourceVendorModelNumber() != null) {
1306                 toscaElement
1307                     .setMetadataValue(JsonPresentationFields.RESOURCE_VENDOR_MODEL_NUMBER, ((Resource) component).getResourceVendorModelNumber());
1308             } else {
1309                 toscaElement.setMetadataValue(JsonPresentationFields.RESOURCE_VENDOR_MODEL_NUMBER, "");
1310             }
1311         } else if (component.getComponentType() == ComponentTypeEnum.SERVICE) {
1312             // field isn't mandatory , but shouldn't be null(should be an empty string instead)
1313             if (((Service) component).getServiceType() != null) {
1314                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_TYPE, ((Service) component).getServiceType());
1315             } else {
1316                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_TYPE, "");
1317             }
1318             if (((Service) component).getServiceRole() != null) {
1319                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_ROLE, ((Service) component).getServiceRole());
1320             } else {
1321                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_ROLE, "");
1322             }
1323             if (((Service) component).getServiceFunction() != null) {
1324                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_FUNCTION, ((Service) component).getServiceFunction());
1325             } else {
1326                 toscaElement.setMetadataValue(JsonPresentationFields.SERVICE_FUNCTION, "");
1327             }
1328         }
1329         toscaElement.setMetadataValue(JsonPresentationFields.CONFORMANCE_LEVEL, component.getConformanceLevel());
1330         toscaElement.setMetadataValue(JsonPresentationFields.IS_DELETED, component.getIsDeleted());
1331         toscaElement.setMetadataValue(JsonPresentationFields.ICON, component.getIcon());
1332         toscaElement.setMetadataValue(JsonPresentationFields.DESCRIPTION, component.getDescription());
1333         toscaElement.setMetadataValue(JsonPresentationFields.TAGS, component.getTags());
1334         toscaElement.setMetadataValue(JsonPresentationFields.INVARIANT_UUID, component.getInvariantUUID());
1335         toscaElement.setMetadataValue(JsonPresentationFields.CONTACT_ID, component.getContactId());
1336         toscaElement.setMetadataValue(JsonPresentationFields.MODEL, component.getModel());
1337         toscaElement.setModel(component.getModel());
1338         for (final String key : component.getCategorySpecificMetadata().keySet()) {
1339             toscaElement.setMetadataValue(key, component.getCategorySpecificMetadata().get(key));
1340         }
1341         final List<DataTypeDefinition> dataTypes = component.getDataTypes();
1342         if (CollectionUtils.isNotEmpty(dataTypes)) {
1343             toscaElement
1344                 .setDataTypes(dataTypes.stream().collect(Collectors.toMap(DataTypeDefinition::getName, dataTypeDefinition -> dataTypeDefinition)));
1345         }
1346     }
1347
1348     private static void setComponentInstancesToComponent(TopologyTemplate topologyTemplate, Component component) {
1349         List<ComponentInstance> componentInstances = new ArrayList<>();
1350         ComponentInstance currComponentInstance;
1351         Map<String, CINodeFilterDataDefinition> nodeFilterComponents = topologyTemplate.getNodeFilterComponents();
1352         for (Map.Entry<String, ComponentInstanceDataDefinition> entry : topologyTemplate.getComponentInstances().entrySet()) {
1353             String key = entry.getKey();
1354             currComponentInstance = new ComponentInstance(topologyTemplate.getComponentInstances().get(key));
1355             if (topologyTemplate.getInstGroups() != null && topologyTemplate.getInstGroups().containsKey(key)) {
1356                 List<GroupInstance> groupInstances = topologyTemplate.getInstGroups().get(key).getMapToscaDataDefinition().entrySet().stream()
1357                     .map(e -> new GroupInstance(e.getValue())).collect(Collectors.toList());
1358                 currComponentInstance.setGroupInstances(groupInstances);
1359             }
1360             setComponentInstanceSource(currComponentInstance, component);
1361             if (MapUtils.isNotEmpty(nodeFilterComponents) && nodeFilterComponents.containsKey(key)) {
1362                 currComponentInstance.setNodeFilter(nodeFilterComponents.get(key));
1363             }
1364             if (topologyTemplate.getInstProperties() != null && topologyTemplate.getInstProperties().containsKey(key)
1365                 && topologyTemplate.getInstProperties().get(key) != null) {
1366                 List<PropertyDefinition> instanceProps = topologyTemplate.getInstProperties().get(key).getMapToscaDataDefinition().entrySet().stream()
1367                     .map(e -> new PropertyDefinition(e.getValue())).collect(Collectors.toList());
1368                 currComponentInstance.setProperties(instanceProps);
1369             }
1370             if (topologyTemplate.getInstInputs() != null && topologyTemplate.getInstInputs().containsKey(key)
1371                 && topologyTemplate.getInstInputs().get(key) != null) {
1372                 List<InputDefinition> instanceInputs = topologyTemplate.getInstInputs().get(key).getMapToscaDataDefinition().entrySet().stream()
1373                     .map(e -> new InputDefinition(e.getValue())).collect(Collectors.toList());
1374                 currComponentInstance.setInputs(instanceInputs);
1375             }
1376             final Map<String, MapAttributesDataDefinition> instAttributes = topologyTemplate.getInstAttributes();
1377             if (instAttributes != null && instAttributes.containsKey(key) && instAttributes.get(key) != null) {
1378                 currComponentInstance.setAttributes(
1379                     instAttributes.get(key).getMapToscaDataDefinition().values().stream().map(AttributeDefinition::new).collect(Collectors.toList()));
1380             }
1381             if (topologyTemplate.getComponentInstInterfaces() != null && topologyTemplate.getComponentInstInterfaces().containsKey(key)
1382                 && topologyTemplate.getComponentInstInterfaces().get(key) != null) {
1383                 Map<String, Object> interfacesMap = topologyTemplate.getComponentInstInterfaces().get(key).getMapToscaDataDefinition().entrySet()
1384                     .stream().collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
1385                 currComponentInstance.setInterfaces(interfacesMap);
1386             }
1387             componentInstances.add(currComponentInstance);
1388         }
1389         component.setComponentInstances(componentInstances);
1390     }
1391
1392     public static List<ComponentInstance> getComponentInstancesFromMapObject(
1393         Map<String, ComponentInstanceDataDefinition> componentInstancesDefinitionMap, Component component) {
1394         List<ComponentInstance> componentInstances = new ArrayList<>();
1395         ComponentInstance currComponentInstance;
1396         for (Map.Entry<String, ComponentInstanceDataDefinition> entry : componentInstancesDefinitionMap.entrySet()) {
1397             String key = entry.getKey();
1398             currComponentInstance = new ComponentInstance(componentInstancesDefinitionMap.get(key));
1399             setComponentInstanceSource(currComponentInstance, component);
1400             componentInstances.add(currComponentInstance);
1401         }
1402         return componentInstances;
1403     }
1404
1405     private static void setComponentInstanceSource(ComponentInstance currComponentInstance, Component component) {
1406         if (Objects.isNull(currComponentInstance.getCreatedFrom())) {
1407             if (ComponentTypeEnum.RESOURCE.equals(component.getComponentType())) {
1408                 Resource resource = (Resource) component;
1409                 if (isFromCsar(resource)) {
1410                     currComponentInstance.setCreatedFrom(CreatedFrom.CSAR);
1411                 } else {
1412                     currComponentInstance.setCreatedFrom(CreatedFrom.UI);
1413                 }
1414             }
1415         }
1416     }
1417
1418     private static boolean isFromCsar(Resource resource) {
1419         return resource.getResourceType() == ResourceTypeEnum.VF || resource.getResourceType() == ResourceTypeEnum.CVFC
1420             || resource.getResourceType() == ResourceTypeEnum.PNF;
1421     }
1422
1423     private static void setComponentInstancesInputsToComponent(TopologyTemplate topologyTemplate, Component component) {
1424         if (topologyTemplate.getInstInputs() != null) {
1425             Map<String, List<ComponentInstanceInput>> inputs = new HashMap<>();
1426             for (Entry<String, MapPropertiesDataDefinition> entry : topologyTemplate.getInstInputs().entrySet()) {
1427                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1428                     String key = entry.getKey();
1429                     List<ComponentInstanceInput> componentInstanceAttributes = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1430                         .map(e -> new ComponentInstanceInput(e.getValue())).collect(Collectors.toList());
1431                     inputs.put(key, componentInstanceAttributes);
1432                 }
1433             }
1434             component.setComponentInstancesInputs(inputs);
1435         }
1436     }
1437
1438     private static void setComponentInstancesOutputsToComponent(final TopologyTemplate topologyTemplate, final Component component) {
1439         if (topologyTemplate.getInstOutputs() != null) {
1440             final Map<String, List<ComponentInstanceOutput>> outputs = new HashMap<>();
1441             for (final Entry<String, MapAttributesDataDefinition> entry : topologyTemplate.getInstOutputs().entrySet()) {
1442                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1443                     final String key = entry.getKey();
1444                     final List<ComponentInstanceOutput> componentInstanceAttributes = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1445                         .map(e -> new ComponentInstanceOutput(e.getValue())).collect(Collectors.toList());
1446                     outputs.put(key, componentInstanceAttributes);
1447                 }
1448             }
1449             component.setComponentInstancesOutputs(outputs);
1450         }
1451     }
1452
1453     private static void setComponentInstancesPropertiesToComponent(TopologyTemplate topologyTemplate, Component component) {
1454         if (topologyTemplate.getInstProperties() != null) {
1455             Map<String, List<ComponentInstanceProperty>> properties = new HashMap<>();
1456             for (Entry<String, MapPropertiesDataDefinition> entry : topologyTemplate.getInstProperties().entrySet()) {
1457                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1458                     String key = entry.getKey();
1459                     List<ComponentInstanceProperty> componentInstanceAttributes = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1460                         .map(e -> new ComponentInstanceProperty(new PropertyDefinition(e.getValue()))).collect(Collectors.toList());
1461                     properties.put(key, componentInstanceAttributes);
1462                 }
1463             }
1464             component.setComponentInstancesProperties(properties);
1465         }
1466     }
1467
1468     public static Map<String, List<ComponentInstanceAttribute>> getComponentInstancesAttributes(
1469         Map<String, MapAttributesDataDefinition> mapAttributesDataDefinitionMap) {
1470         Map<String, List<ComponentInstanceAttribute>> attributes = new HashMap<>();
1471         for (Map.Entry<String, MapAttributesDataDefinition> entry : mapAttributesDataDefinitionMap.entrySet()) {
1472             if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1473                 String key = entry.getKey();
1474                 List<ComponentInstanceAttribute> componentInstanceAttributes = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1475                     .map(e -> new ComponentInstanceAttribute(new AttributeDefinition(e.getValue()))).collect(Collectors.toList());
1476                 attributes.put(key, componentInstanceAttributes);
1477             }
1478         }
1479         return attributes;
1480     }
1481
1482     private static void setComponentInstancesInterfacesToComponent(TopologyTemplate topologyTemplate, Component component) {
1483         if (topologyTemplate.getInstInterfaces() != null) {
1484             Map<String, List<ComponentInstanceInterface>> interfaces = new HashMap<>();
1485             for (Map.Entry<String, MapInterfaceInstanceDataDefinition> entry : topologyTemplate.getInstInterfaces().entrySet()) {
1486                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1487                     String key = entry.getKey();
1488                     List<ComponentInstanceInterface> componentInstanceInterfaces = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1489                         .map(e -> new ComponentInstanceInterface(e.getKey(), e.getValue())).collect(Collectors.toList());
1490                     interfaces.put(key, componentInstanceInterfaces);
1491                 }
1492             }
1493             component.setComponentInstancesInterfaces(interfaces);
1494         } else if (topologyTemplate.getComponentInstInterfaces() != null) {
1495             Map<String, List<ComponentInstanceInterface>> interfaces = new HashMap<>();
1496             for (Map.Entry<String, MapInterfaceDataDefinition> entry : topologyTemplate.getComponentInstInterfaces().entrySet()) {
1497                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1498                     String key = entry.getKey();
1499                     List<ComponentInstanceInterface> componentInstanceInterfaces = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1500                         .map(e -> new ComponentInstanceInterface(e.getKey(), e.getValue())).collect(Collectors.toList());
1501                     interfaces.put(key, componentInstanceInterfaces);
1502                 }
1503             }
1504             component.setComponentInstancesInterfaces(interfaces);
1505         }
1506     }
1507
1508     private static void setComponentInstancesAttributesToComponent(TopologyTemplate topologyTemplate, Component component) {
1509         if (topologyTemplate.getInstAttributes() != null) {
1510             Map<String, List<ComponentInstanceAttribute>> attributes = new HashMap<>();
1511             for (Map.Entry<String, MapAttributesDataDefinition> entry : topologyTemplate.getInstAttributes().entrySet()) {
1512                 if (entry.getValue() != null && entry.getValue().getMapToscaDataDefinition() != null) {
1513                     String key = entry.getKey();
1514                     List<ComponentInstanceAttribute> componentInstanceAttributes = entry.getValue().getMapToscaDataDefinition().entrySet().stream()
1515                         .map(e -> new ComponentInstanceAttribute(new AttributeDefinition(e.getValue()))).collect(Collectors.toList());
1516                     attributes.put(key, componentInstanceAttributes);
1517                 }
1518             }
1519             component.setComponentInstancesAttributes(attributes);
1520         }
1521     }
1522
1523     public static void setComponentInstancesRequirementsToComponent(TopologyTemplate topologyTemplate, Component component) {
1524         if (topologyTemplate.getCalculatedRequirements() != null) {
1525             // Requirements of component organized by capability
1526             Map<String, List<RequirementDefinition>> instanceRequiermentsFromMapObject = getInstanceRequirementsFromMapObject(
1527                 topologyTemplate.getCalculatedRequirements(), component);
1528             component.setRequirements(instanceRequiermentsFromMapObject);
1529         }
1530     }
1531
1532     public static Map<String, List<RequirementDefinition>> getInstanceRequirementsFromMapObject(
1533         Map<String, MapListRequirementDataDefinition> mapListRequirements, Component component) {
1534         // Requirements of component organized by capability
1535         Map<String, List<RequirementDefinition>> instancesRequirements = new HashMap<>();
1536         if (mapListRequirements != null) {
1537             Map<String, ComponentInstance> instancesMap = new HashMap<>();
1538             for (ComponentInstance currInstance : component.getComponentInstances()) {
1539                 instancesMap.put(currInstance.getUniqueId(), currInstance);
1540             }
1541             for (Map.Entry<String, MapListRequirementDataDefinition> entry : mapListRequirements.entrySet()) {
1542                 String instanceId = entry.getKey();
1543                 // Requirements of instance organized by capability
1544                 Map<String, ListRequirementDataDefinition> capsMapList = entry.getValue().getMapToscaDataDefinition();
1545                 if (capsMapList != null) {
1546                     for (Entry<String, ListRequirementDataDefinition> entryTypeList : capsMapList.entrySet()) {
1547                         String capabilityType = entryTypeList.getKey();
1548                         List<RequirementDefinition> caps = entryTypeList.getValue().getListToscaDataDefinition().stream()
1549                             .map(RequirementDefinition::new).collect(Collectors.toList());
1550                         if (instancesRequirements.containsKey(capabilityType)) {
1551                             instancesRequirements.get(capabilityType).addAll(caps);
1552                         } else {
1553                             instancesRequirements.put(capabilityType, caps);
1554                         }
1555                         if (MapUtils.isEmpty(instancesMap.get(instanceId).getRequirements())) {
1556                             instancesMap.get(instanceId).setRequirements(new HashMap<>());
1557                         }
1558                         instancesMap.get(instanceId).getRequirements().put(capabilityType, new ArrayList<>(caps));
1559                     }
1560                 }
1561             }
1562             component.setRequirements(instancesRequirements);
1563         }
1564         return instancesRequirements;
1565     }
1566
1567     public static void setComponentInstancesCapabilitiesToComponentAndCI(TopologyTemplate topologyTemplate, Component component) {
1568         Map<String, MapCapabilityProperty> calculatedCapProperties = topologyTemplate.getCalculatedCapabilitiesProperties();
1569         if (topologyTemplate.getCalculatedCapabilities() != null) {
1570             // capabilities of component organized by type
1571             Map<String, List<CapabilityDefinition>> instancesCapabilities = new HashMap<>();
1572             Map<String, ComponentInstance> instancesMap = new HashMap<>();
1573             for (ComponentInstance currInstance : component.getComponentInstances()) {
1574                 instancesMap.put(currInstance.getUniqueId(), currInstance);
1575             }
1576             for (Map.Entry<String, MapListCapabilityDataDefinition> entry : topologyTemplate.getCalculatedCapabilities().entrySet()) {
1577                 String instanceId = entry.getKey();
1578                 // capabilities of instance organized by type
1579                 Map<String, ListCapabilityDataDefinition> capsMapList = entry.getValue().getMapToscaDataDefinition();
1580                 if (capsMapList != null) {
1581                     for (Entry<String, ListCapabilityDataDefinition> entryTypeList : capsMapList.entrySet()) {
1582                         String capabilityType = entryTypeList.getKey();
1583                         List<CapabilityDefinition> caps = entryTypeList.getValue().getListToscaDataDefinition().stream()
1584                             .map(cap -> mergeInstCapabiltyWithProperty(cap, instanceId, calculatedCapProperties)).collect(Collectors.toList());
1585                         if (instancesCapabilities.containsKey(capabilityType)) {
1586                             instancesCapabilities.get(capabilityType).addAll(caps);
1587                         } else {
1588                             instancesCapabilities.put(capabilityType, caps);
1589                         }
1590                         ComponentInstance instance = instancesMap.get(instanceId);
1591                         if (instance == null) {
1592                             log.error("instance is null for id {} entry {}", instanceId,
1593                                 entry.getValue().getToscaPresentationValue(JsonPresentationFields.NAME));
1594                         } else {
1595                             if (MapUtils.isEmpty(instance.getCapabilities())) {
1596                                 instance.setCapabilities(new HashMap<>());
1597                             }
1598                             instance.getCapabilities().put(capabilityType, new ArrayList<>(caps));
1599                         }
1600                     }
1601                 }
1602             }
1603             component.setCapabilities(instancesCapabilities);
1604         }
1605     }
1606
1607     private static void setCapabilitiesToComponent(TopologyTemplate topologyTemplate, Component component) {
1608         Map<String, ListCapabilityDataDefinition> capabilities = topologyTemplate.getCapabilities();
1609         Map<String, MapPropertiesDataDefinition> capabilitiesProperties = topologyTemplate.getCapabilitiesProperties();
1610         Map<String, List<CapabilityDefinition>> allCapabilities = new HashMap<>();
1611         if (MapUtils.isNotEmpty(capabilities)) {
1612             allCapabilities.putAll(groupCapabilityByType(capabilities));
1613         }
1614         if (MapUtils.isNotEmpty(capabilitiesProperties)) {
1615             capabilitiesProperties.forEach((s, capProp) -> {
1616                 String[] result = s.split(CAP_PROP_DELIM);
1617                 if (capProp != null) {
1618                     Map<String, PropertyDataDefinition> capMap = capProp.getMapToscaDataDefinition();
1619                     if (MapUtils.isNotEmpty(capMap)) {
1620                         List<ComponentInstanceProperty> capPropsList = capMap.values().stream().map(ComponentInstanceProperty::new)
1621                             .collect(Collectors.toList());
1622                         List<CapabilityDefinition> cap = allCapabilities.get(result[0]);
1623                         if (cap != null) {
1624                             Optional<CapabilityDefinition> op = cap.stream().filter(c -> c.getName().equals(result[1])).findFirst();
1625                             op.ifPresent(capabilityDefinition -> capabilityDefinition.setProperties(capPropsList));
1626                         }
1627                     }
1628                 }
1629             });
1630         }
1631         Map<String, List<CapabilityDefinition>> componentCapabilities = component.getCapabilities();
1632         if (MapUtils.isNotEmpty(componentCapabilities)) {
1633             mergeCapabilityMap(allCapabilities, componentCapabilities);
1634         }
1635         component.setCapabilities(allCapabilities);
1636     }
1637
1638     private static void mergeCapabilityMap(Map<String, List<CapabilityDefinition>> map1, Map<String, List<CapabilityDefinition>> map2) {
1639         map1.forEach((key1, val1) -> map2.forEach((key2, val2) -> {
1640             if (key1.equals(key2)) {
1641                 val2.addAll(val1);
1642             }
1643         }));
1644         map1.putAll(map2);
1645     }
1646
1647     private static Map<String, List<CapabilityDefinition>> groupCapabilityByType(Map<String, ListCapabilityDataDefinition> capabilities) {
1648         Map<String, List<CapabilityDefinition>> groupedCapabilities = new HashMap<>();
1649         Set<String> typesSet = new HashSet<>();
1650         List<CapabilityDefinition> allCapabilityDefinitions = new ArrayList<>();
1651         for (Entry<String, ListCapabilityDataDefinition> capabilitiesEntry : capabilities.entrySet()) {
1652             typesSet.addAll(capabilitiesEntry.getValue().getListToscaDataDefinition().stream().map(CapabilityDataDefinition::getType)
1653                 .collect(Collectors.toSet()));
1654             allCapabilityDefinitions.addAll(
1655                 capabilitiesEntry.getValue().getListToscaDataDefinition().stream().map(CapabilityDefinition::new).collect(Collectors.toList()));
1656         }
1657         for (String capType : typesSet) {
1658             groupedCapabilities.put(capType,
1659                 allCapabilityDefinitions.stream().filter(capabilityDefinition -> capabilityDefinition.getType().equals(capType))
1660                     .collect(Collectors.toList()));
1661         }
1662         return groupedCapabilities;
1663     }
1664
1665     private static void setRequirementsToComponent(TopologyTemplate topologyTemplate, Component component) {
1666         Map<String, ListRequirementDataDefinition> requirements = topologyTemplate.getRequirements();
1667         Map<String, List<RequirementDefinition>> componentRequirements = component.getRequirements();
1668         if (MapUtils.isNotEmpty(requirements)) {
1669             if (componentRequirements == null) {
1670                 componentRequirements = new HashMap<>();
1671             }
1672             componentRequirements.putAll(groupRequirementByType(requirements));
1673             component.setRequirements(componentRequirements);
1674         }
1675     }
1676
1677     private static Map<String, List<RequirementDefinition>> groupRequirementByType(Map<String, ListRequirementDataDefinition> requirements) {
1678         Map<String, List<RequirementDefinition>> groupedRequirement = new HashMap<>();
1679         Set<String> typesSet = new HashSet<>();
1680         List<RequirementDefinition> allRequirements = new ArrayList<>();
1681         for (Entry<String, ListRequirementDataDefinition> requirementsEntry : requirements.entrySet()) {
1682             typesSet.addAll(requirementsEntry.getValue().getListToscaDataDefinition().stream().map(RequirementDataDefinition::getCapability)
1683                 .collect(Collectors.toSet()));
1684             allRequirements.addAll(
1685                 requirementsEntry.getValue().getListToscaDataDefinition().stream().map(RequirementDefinition::new).collect(Collectors.toList()));
1686         }
1687         for (String capType : typesSet) {
1688             groupedRequirement.put(capType,
1689                 allRequirements.stream().filter(requirementDefinition -> requirementDefinition.getCapability().equals(capType))
1690                     .collect(Collectors.toList()));
1691         }
1692         return groupedRequirement;
1693     }
1694
1695     private static void setCapabilitiesToComponentAndGroups(TopologyTemplate topologyTemplate, Component component) {
1696         Map<String, MapCapabilityProperty> calculatedCapProperties = topologyTemplate.getCalculatedCapabilitiesProperties();
1697         if (capabilitiesAndGroupsExist(topologyTemplate, component)) {
1698             Map<String, GroupDefinition> groupsMap = component.getGroups().stream()
1699                 .collect(Collectors.toMap(GroupDefinition::getUniqueId, Function.identity()));
1700             for (Map.Entry<String, MapListCapabilityDataDefinition> entry : topologyTemplate.getCalculatedCapabilities().entrySet()) {
1701                 findSetCapabilitiesToComponentAndGroup(calculatedCapProperties, component, groupsMap, entry);
1702             }
1703         }
1704     }
1705
1706     private static boolean capabilitiesAndGroupsExist(TopologyTemplate topologyTemplate, Component component) {
1707         return MapUtils.isNotEmpty(topologyTemplate.getCalculatedCapabilities()) && CollectionUtils.isNotEmpty(component.getGroups());
1708     }
1709
1710     private static void findSetCapabilitiesToComponentAndGroup(Map<String, MapCapabilityProperty> calculatedCapProperties, Component component,
1711                                                                Map<String, GroupDefinition> groupsMap,
1712                                                                Map.Entry<String, MapListCapabilityDataDefinition> entry) {
1713         String uniqueId = entry.getKey();
1714         if (groupsMap.containsKey(uniqueId)) {
1715             setCapabilitiesToComponentAndGroup(calculatedCapProperties, component, entry, groupsMap.get(uniqueId));
1716         } else {
1717             log.warn("The group with uniqueId {} was not found", uniqueId);
1718         }
1719     }
1720
1721     private static void setCapabilitiesToComponentAndGroup(Map<String, MapCapabilityProperty> calculatedCapProperties, Component component,
1722                                                            Map.Entry<String, MapListCapabilityDataDefinition> entry, GroupDefinition group) {
1723         for (Entry<String, ListCapabilityDataDefinition> entryTypeList : entry.getValue().getMapToscaDataDefinition().entrySet()) {
1724             String capabilityType = entryTypeList.getKey();
1725             List<CapabilityDefinition> caps = entryTypeList.getValue().getListToscaDataDefinition().stream()
1726                 .map(cap -> mergeInstCapabiltyWithProperty(cap, group.getUniqueId(), calculatedCapProperties)).collect(Collectors.toList());
1727             if (component.getCapabilities().containsKey(capabilityType)) {
1728                 component.getCapabilities().get(capabilityType).addAll(caps);
1729             } else {
1730                 component.getCapabilities().put(capabilityType, caps);
1731             }
1732             group.getCapabilities().put(capabilityType, Lists.newArrayList(caps));
1733         }
1734     }
1735
1736     private static CapabilityDefinition mergeInstCapabiltyWithProperty(CapabilityDataDefinition cap, String ownerId,
1737                                                                        Map<String, MapCapabilityProperty> calculatedCapProperties) {
1738         CapabilityDefinition capability = new CapabilityDefinition(cap);
1739         if (calculatedCapProperties != null) {
1740             MapCapabilityProperty mapOfMapPropertiesDataDefinition = calculatedCapProperties.get(ownerId);
1741             if (mapOfMapPropertiesDataDefinition != null && mapOfMapPropertiesDataDefinition.getMapToscaDataDefinition() != null) {
1742                 Map<String, MapPropertiesDataDefinition> toscaCapPropMap = mapOfMapPropertiesDataDefinition.getMapToscaDataDefinition();
1743                 toscaCapPropMap.forEach((keyPath, capProp) -> findConvertSetProperties(cap, ownerId, capability, keyPath, capProp));
1744             }
1745         }
1746         return capability;
1747     }
1748
1749     private static void findConvertSetProperties(CapabilityDataDefinition cap, String primaryPathKey, CapabilityDefinition capability, String path,
1750                                                  MapPropertiesDataDefinition capProp) {
1751         // format key of capability properties :
1752
1753         // VF instance in service : instanceId#ownerId#type#capName
1754
1755         // VFC instance in VF : instanceId#type#capName -> instanceId=ownerId
1756
1757         // Group in service : groupName#ownerId#type#capName
1758
1759         // Group in VF : groupName#type#capName -> groupName=ownerId
1760         String[] result = path.split(CAP_PROP_DELIM);
1761         if (result.length < 4) {
1762             log.debug("wrong key format for capabilty, key {}", capProp);
1763             return;
1764         }
1765         if (relatedPropertiesExist(cap, primaryPathKey, capProp, result)) {
1766             capability.setProperties(
1767                 capProp.getMapToscaDataDefinition().values().stream().map(ComponentInstanceProperty::new).collect(Collectors.toList()));
1768         }
1769     }
1770
1771     private static boolean relatedPropertiesExist(CapabilityDataDefinition cap, String primaryPathKey, MapPropertiesDataDefinition capProp,
1772                                                   String[] result) {
1773         return capProp != null && MapUtils.isNotEmpty(capProp.getMapToscaDataDefinition()) && areRelatedProperties(cap, primaryPathKey, result);
1774     }
1775
1776     private static boolean areRelatedProperties(CapabilityDataDefinition cap, String primaryPathKey, String[] result) {
1777         int primaryKeyIndex = 0;
1778         int ownerIndex = 1;
1779         int typeIndex = result.length - 2;
1780         int nameIndex = result.length - 1;
1781         return result[typeIndex].equals(cap.getType()) && result[nameIndex].equals(cap.getName()) && cap.getOwnerId().equals(result[ownerIndex])
1782             && primaryPathKey.equals(result[primaryKeyIndex]);
1783     }
1784
1785     private static void setComponentInstancesToTopologyTemplate(Component component, TopologyTemplate topologyTemplate) {
1786         Map<String, ComponentInstanceDataDefinition> componentInstances = new HashMap<>();
1787         ComponentInstanceDataDefinition convertedInstance;
1788         if (component.getComponentInstances() != null) {
1789             for (ComponentInstance instance : component.getComponentInstances()) {
1790                 convertedInstance = new ComponentInstanceDataDefinition(instance);
1791                 if (instance.getGroupInstances() != null) {
1792                     MapGroupsDataDefinition groupsMap = new MapGroupsDataDefinition();
1793                     groupsMap.setMapToscaDataDefinition(instance.getGroupInstances().stream().map(GroupInstanceDataDefinition::new)
1794                         .collect(Collectors.toMap(GroupInstanceDataDefinition::getName, Function.identity())));
1795                     if (topologyTemplate.getInstGroups() == null) {
1796                         topologyTemplate.setInstGroups(new HashMap<>());
1797                     }
1798                     topologyTemplate.getInstGroups().put(instance.getUniqueId(), groupsMap);
1799                 }
1800                 componentInstances.put(instance.getUniqueId(), convertedInstance);
1801             }
1802         }
1803         topologyTemplate.setComponentInstances(componentInstances);
1804     }
1805
1806     private static void setComponentInstancesInputsToTopologyTemplate(Component component, TopologyTemplate topologyTemplate) {
1807         if (component.getComponentInstancesInputs() != null) {
1808             topologyTemplate.setInstInputs(new HashMap<>());
1809             MapPropertiesDataDefinition inputsMap;
1810             for (Entry<String, List<ComponentInstanceInput>> entry : component.getComponentInstancesInputs().entrySet()) {
1811                 inputsMap = new MapPropertiesDataDefinition();
1812                 inputsMap.setMapToscaDataDefinition(entry.getValue().stream().map(PropertyDataDefinition::new)
1813                     .collect(Collectors.toMap(PropertyDataDefinition::getName, Function.identity())));
1814                 topologyTemplate.getInstInputs().put(entry.getKey(), inputsMap);
1815             }
1816         }
1817     }
1818
1819     private static void setComponentInstancesPropertiesToTopologyTemplate(Component component, TopologyTemplate topologyTemplate) {
1820         if (component.getComponentInstancesProperties() != null) {
1821             topologyTemplate.setInstProperties(new HashMap<>());
1822             MapPropertiesDataDefinition propertiesMap;
1823             for (Entry<String, List<ComponentInstanceProperty>> entry : component.getComponentInstancesProperties().entrySet()) {
1824                 propertiesMap = new MapPropertiesDataDefinition();
1825                 propertiesMap.setMapToscaDataDefinition(entry.getValue().stream().map(PropertyDataDefinition::new)
1826                     .collect(Collectors.toMap(PropertyDataDefinition::getName, Function.identity())));
1827                 topologyTemplate.getInstProperties().put(entry.getKey(), propertiesMap);
1828             }
1829         }
1830     }
1831
1832     private static void setComponentInstancesArtifactsToTopologyTemplate(Component component, TopologyTemplate topologyTemplate) {
1833         List<ComponentInstance> componentInstances = component.getComponentInstances();
1834         if (componentInstances != null) {
1835             topologyTemplate.setInstanceArtifacts(new HashMap<>());
1836             topologyTemplate.setInstDeploymentArtifacts(new HashMap<>());
1837             for (ComponentInstance ci : componentInstances) {
1838                 Map<String, ArtifactDefinition> artifacts = ci.getArtifacts();
1839                 if (artifacts != null) {
1840                     Map<String, ArtifactDataDefinition> mapToscaDataDefinitionArtifact = artifacts.entrySet().stream()
1841                         .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
1842                     MapArtifactDataDefinition insArtifact = new MapArtifactDataDefinition(mapToscaDataDefinitionArtifact);
1843                     topologyTemplate.getInstanceArtifacts().put(ci.getUniqueId(), insArtifact);
1844                 }
1845                 Map<String, ArtifactDefinition> deplArtifacts = ci.getDeploymentArtifacts();
1846                 if (deplArtifacts != null) {
1847                     Map<String, ArtifactDataDefinition> mapToscaDataDefinitionDepArtifact = deplArtifacts.entrySet().stream()
1848                         .collect(Collectors.toMap(Map.Entry::getKey, e -> new ArtifactDataDefinition(e.getValue())));
1849                     MapArtifactDataDefinition insDepArtifact = new MapArtifactDataDefinition(mapToscaDataDefinitionDepArtifact);
1850                     topologyTemplate.getInstDeploymentArtifacts().put(ci.getUniqueId(), insDepArtifact);
1851                 }
1852             }
1853         }
1854     }
1855
1856     private static void setComponentInstancesAttributesToTopologyTemplate(Component component, TopologyTemplate topologyTemplate) {
1857         if (component.getComponentInstancesAttributes() != null) {
1858             topologyTemplate.setInstAttributes(new HashMap<>());
1859             for (Entry<String, List<ComponentInstanceAttribute>> entry : component.getComponentInstancesAttributes().entrySet()) {
1860                 final MapAttributesDataDefinition attributesMap = new MapAttributesDataDefinition();
1861                 attributesMap.setMapToscaDataDefinition(entry.getValue().stream().map(AttributeDefinition::new)
1862                     .collect(Collectors.toMap(AttributeDefinition::getName, Function.identity(), (entity1, entity2) -> entity1)));
1863                 topologyTemplate.getInstAttributes().put(entry.getKey(), attributesMap);
1864             }
1865         }
1866     }
1867
1868     public static ComponentMetadataData convertToComponentMetadata(GraphVertex vertex) {
1869         ComponentMetadataData metadata;
1870         switch (vertex.getType()) {
1871             case SERVICE:
1872                 metadata = new ServiceMetadataData(new GraphPropertiesDictionaryExtractor(vertex.getMetadataJson()));
1873                 break;
1874             case RESOURCE:
1875                 metadata = new ResourceMetadataData(new GraphPropertiesDictionaryExtractor(vertex.getMetadataJson()));
1876                 break;
1877             case PRODUCT:
1878                 metadata = new ProductMetadataData(new GraphPropertiesDictionaryExtractor(vertex.getMetadataJson()));
1879                 break;
1880             default:
1881                 throw new StorageException(JanusGraphOperationStatus.INVALID_TYPE);
1882         }
1883         metadata.getMetadataDataDefinition().setUniqueId(vertex.getUniqueId());
1884         metadata.getMetadataDataDefinition().setLastUpdateDate((Long) vertex.getJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE));
1885         metadata.getMetadataDataDefinition().setUUID((String) vertex.getJsonMetadataField(JsonPresentationFields.UUID));
1886         metadata.getMetadataDataDefinition().setState((String) vertex.getJsonMetadataField(JsonPresentationFields.LIFECYCLE_STATE));
1887         return metadata;
1888     }
1889
1890     public static ComponentMetadataDataDefinition convertToComponentMetadataDataDefinition(GraphVertex vertex) {
1891         ComponentMetadataDataDefinition metadata;
1892         switch (vertex.getType()) {
1893             case SERVICE:
1894                 metadata = new ServiceMetadataDataDefinition(new JsonPresentationFieldsExtractor(vertex.getMetadataJson()));
1895                 break;
1896             case RESOURCE:
1897                 metadata = new ResourceMetadataDataDefinition(new JsonPresentationFieldsExtractor(vertex.getMetadataJson()));
1898                 break;
1899             case PRODUCT:
1900                 metadata = new ProductMetadataDataDefinition(new JsonPresentationFieldsExtractor(vertex.getMetadataJson()));
1901                 break;
1902             default:
1903                 throw new StorageException(JanusGraphOperationStatus.INVALID_TYPE);
1904         }
1905         metadata.setUniqueId(vertex.getUniqueId());
1906         metadata.setLastUpdateDate((Long) vertex.getJsonMetadataField(JsonPresentationFields.LAST_UPDATE_DATE));
1907         metadata.setUUID((String) vertex.getJsonMetadataField(JsonPresentationFields.UUID));
1908         metadata.setState((String) vertex.getJsonMetadataField(JsonPresentationFields.LIFECYCLE_STATE));
1909         return metadata;
1910     }
1911
1912     public static List<GroupDefinition> convertToGroupDefinitions(Map<String, GroupDataDefinition> groups) {
1913         List<GroupDefinition> groupDefinitions = new ArrayList<>();
1914         if (MapUtils.isNotEmpty(groups)) {
1915             groupDefinitions = groups.values().stream().map(GroupDefinition::new).collect(Collectors.toList());
1916         }
1917         return groupDefinitions;
1918     }
1919
1920     public static Map<String, MapCapabilityProperty> extractCapabilityProperteisFromInstances(List<ComponentInstance> instances, boolean fromCsar) {
1921         return instances.stream().collect(Collectors.toMap(ComponentInstanceDataDefinition::getUniqueId,
1922             ci -> convertToMapOfMapCapabiltyProperties(ci.getCapabilities(), ci.getUniqueId(), fromCsar)));
1923     }
1924
1925     public static Map<String, MapCapabilityProperty> extractCapabilityPropertiesFromGroups(List<GroupDefinition> groups, boolean fromCsar) {
1926         if (CollectionUtils.isNotEmpty(groups)) {
1927             return groups.stream().collect(Collectors
1928                 .toMap(GroupDefinition::getUniqueId, g -> convertToMapOfMapCapabiltyProperties(g.getCapabilities(), g.getUniqueId(), fromCsar)));
1929         }
1930         return Maps.newHashMap();
1931     }
1932
1933     public static Map<String, MapListCapabilityDataDefinition> extractCapabilitiesFromGroups(final List<GroupDefinition> groupDefinitions) {
1934         Map<String, MapListCapabilityDataDefinition> calculatedCapabilities = Maps.newHashMap();
1935         for (GroupDefinition groupDefinition : groupDefinitions) {
1936             calculatedCapabilities
1937                 .put(groupDefinition.getUniqueId(), new MapListCapabilityDataDefinition(buildMapOfListsOfCapabilities(groupDefinition)));
1938         }
1939         return calculatedCapabilities;
1940     }
1941
1942     private static Map<String, ListCapabilityDataDefinition> buildMapOfListsOfCapabilities(GroupDefinition groupDefinition) {
1943         return groupDefinition.getCapabilities().entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey,
1944             e -> new ListCapabilityDataDefinition(e.getValue().stream().map(CapabilityDataDefinition::new).collect(Collectors.toList()))));
1945     }
1946 }