Catalog alignment
[sdc.git] / catalog-be / src / main / java / org / openecomp / sdc / be / tosca / GroupExportParserImpl.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * SDC
4  * ================================================================================
5  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.openecomp.sdc.be.tosca;
22
23 import fj.data.Either;
24 import org.apache.commons.lang.StringUtils;
25 import org.openecomp.sdc.be.components.impl.exceptions.SdcResourceNotFoundException;
26 import org.openecomp.sdc.be.dao.janusgraph.JanusGraphOperationStatus;
27 import org.openecomp.sdc.be.datatypes.elements.PropertyDataDefinition;
28 import org.openecomp.sdc.be.model.CapabilityDefinition;
29 import org.openecomp.sdc.be.model.Component;
30 import org.openecomp.sdc.be.model.ComponentInstanceProperty;
31 import org.openecomp.sdc.be.model.DataTypeDefinition;
32 import org.openecomp.sdc.be.model.GroupDefinition;
33 import org.openecomp.sdc.be.model.GroupInstance;
34 import org.openecomp.sdc.be.model.GroupInstanceProperty;
35 import org.openecomp.sdc.be.model.cache.ApplicationDataTypeCache;
36 import org.openecomp.sdc.be.model.utils.ComponentUtilities;
37 import org.openecomp.sdc.be.model.utils.GroupUtils;
38 import org.openecomp.sdc.be.tosca.model.IToscaMetadata;
39 import org.openecomp.sdc.be.tosca.model.ToscaGroupTemplate;
40 import org.openecomp.sdc.be.tosca.model.ToscaMetadata;
41 import org.openecomp.sdc.be.tosca.model.ToscaTemplateCapability;
42 import org.openecomp.sdc.be.tosca.model.VfModuleToscaMetadata;
43 import org.openecomp.sdc.common.api.Constants;
44 import org.openecomp.sdc.common.log.wrappers.Logger;
45 import org.springframework.beans.factory.annotation.Autowired;
46 import org.springframework.stereotype.Service;
47
48 import java.util.Collection;
49 import java.util.HashMap;
50 import java.util.List;
51 import java.util.Map;
52 import java.util.Optional;
53 import java.util.function.Predicate;
54 import java.util.function.Supplier;
55
56 import static java.util.stream.Collectors.toList;
57 import static java.util.stream.Collectors.toMap;
58 import static org.apache.commons.collections.CollectionUtils.isEmpty;
59 import static org.apache.commons.collections.CollectionUtils.isNotEmpty;
60 import static org.apache.commons.collections.MapUtils.isEmpty;
61 import static org.apache.commons.collections.MapUtils.isNotEmpty;
62 import static org.apache.commons.lang.StringUtils.isNotEmpty;
63 import static org.openecomp.sdc.be.model.utils.ComponentUtilities.getComponentInstanceNameByInstanceId;
64
65 @Service
66 public class GroupExportParserImpl implements GroupExportParser {
67
68     private static final Logger log = Logger.getLogger(GroupExportParserImpl.class);
69
70     private Map<String, DataTypeDefinition> dataTypes;
71     private ApplicationDataTypeCache dataTypeCache;
72     private PropertyConvertor propertyConvertor = PropertyConvertor.getInstance();
73     
74     @Autowired
75         public GroupExportParserImpl(ApplicationDataTypeCache dataTypeCache) {
76                 this.dataTypeCache = dataTypeCache;
77                 this.dataTypes = getDataTypes();
78         }
79     
80     private Map<String, DataTypeDefinition> getDataTypes()  {
81                 Either<Map<String, DataTypeDefinition>, JanusGraphOperationStatus> dataTypesEither = dataTypeCache.getAll();
82                 if (dataTypesEither.isRight()) {
83                         log.error("Failed to retrieve all data types {}", dataTypesEither.right().value()); 
84                         throw new SdcResourceNotFoundException(); 
85                 }
86                 
87                 return dataTypesEither.left().value();
88         }
89     
90         @Override
91         public Map<String, ToscaGroupTemplate> getGroups(Component component) {
92                 List<GroupDefinition> groups = component.getGroups();
93
94                 if (isEmpty(groups)) {
95                         return null;
96                 }
97                 
98                 return groups.stream()
99                                 .collect(toMap(GroupDefinition::getName,
100                                                   group -> getToscaGroupTemplate(component, group)));
101         }
102         
103         @Override
104         public ToscaGroupTemplate getToscaGroupTemplate(GroupInstance groupInstance, String componentInstanceInvariantName) {
105                 
106                 String groupName = groupInstance.getName();
107                 if (StringUtils.isNotEmpty(componentInstanceInvariantName)) {
108                         String prefix = componentInstanceInvariantName + Constants.GROUP_POLICY_NAME_DELIMETER;
109                         if (groupName.startsWith(prefix)) {
110                                 groupName = groupName.substring(prefix.length());
111                         }
112                 }
113                 String invariantUUID = groupInstance.getInvariantUUID();
114                 String groupUUID = groupInstance.getGroupUUID();
115                 String version = groupInstance.getVersion();
116                 List<GroupInstanceProperty> groupInstanceProperties = groupInstance.convertToGroupInstancesProperties();
117                 String groupType = groupInstance.getType();
118                 String customizationUUID = groupInstance.getCustomizationUUID();
119
120                 IToscaMetadata toscaMetadata = getToscaGroupTemplateMetadata(groupName, invariantUUID, groupUUID, version, groupType, customizationUUID);               
121                 Map<String, Object> properties = getToscaGroupTemplateProperties(groupInstanceProperties);
122                 
123         return new ToscaGroupTemplate(groupType, toscaMetadata, properties);
124         }
125
126         private ToscaGroupTemplate getToscaGroupTemplate(Component component, GroupDefinition groupDefinition) {
127
128                 String groupName = groupDefinition.getName();
129                 String invariantUUID = groupDefinition.getInvariantUUID();
130                 String groupUUID = groupDefinition.getGroupUUID();
131                 String version = groupDefinition.getVersion();
132                 String groupType = groupDefinition.getType();
133                 List<PropertyDataDefinition> groupDefinitionProperties = groupDefinition.getProperties();
134                 
135                 List<String> members = getToscaGroupTemplateMembers(component, groupDefinition.getMembers());
136                 IToscaMetadata toscaMetadata = getToscaGroupTemplateMetadata(groupName, invariantUUID, groupUUID, version,groupType, null);             
137                 Map<String, Object> properties = getToscaGroupTemplateProperties(groupDefinitionProperties);
138                 Map<String, ToscaTemplateCapability> capabilities = getToscaGroupTemplateCapabilities(groupDefinition);
139
140                 return new ToscaGroupTemplate(groupType, members, toscaMetadata, properties, capabilities);
141         }
142         
143         private Map<String, ToscaTemplateCapability> getToscaGroupTemplateCapabilities(GroupDefinition group) {
144                 if (isEmpty(group.getCapabilities())) {
145                         return null;
146                 }
147
148                 Map<String, ToscaTemplateCapability> toscaGroupTemplateCapabilities = group.getCapabilities().values()
149                                 .stream()
150                                 .flatMap(Collection::stream)
151                                 .filter(c -> isNotEmptyProperties(c.getProperties()))
152                                 .collect(toMap(c-> getCapabilityName(c, group), this::getToscaTemplateCapability));
153
154                 if (isNotEmpty(toscaGroupTemplateCapabilities)) {
155                         return toscaGroupTemplateCapabilities;
156                 } else {
157                         return null;
158                 }
159         }
160
161         private String getCapabilityName(CapabilityDefinition capability, GroupDefinition group) {
162         if(ComponentUtilities.isNotUpdatedCapReqName(group.getNormalizedName() + ".", capability.getName(), capability.getPreviousName())){
163                 return capability.getName();
164                 }
165                 return capability.getPreviousName();
166         }
167
168         private boolean isNotEmptyProperties(List<ComponentInstanceProperty> properties) {
169         return isNotEmpty(properties) && properties.stream()
170                                 .filter(isComponentInstancePropertiesNotEmpty())
171                                 .findFirst()
172                                 .isPresent();
173         }
174
175         private ToscaTemplateCapability getToscaTemplateCapability(CapabilityDefinition capability) {
176                 ToscaTemplateCapability toscaTemplateCapability = new ToscaTemplateCapability();
177                 Map<String, Object> toscaCapabilityProperties = capability.getProperties().stream()
178                                 .filter(isComponentInstancePropertiesNotEmpty())
179                                 .collect(toMap(ComponentInstanceProperty::getName,
180                                                                                   this::fetchCapabilityValue));
181                 if(isNotEmpty(toscaCapabilityProperties)) {
182                         toscaTemplateCapability.setProperties(toscaCapabilityProperties);
183                 }
184                 return toscaTemplateCapability;
185         }
186
187         private Predicate<? super ComponentInstanceProperty> isComponentInstancePropertiesNotEmpty() {
188                 return c -> {
189                         return (c.getName() != null && (c.getValue() != null || c.getDefaultValue() != null));
190                 };
191         }
192
193         private String fetchCapabilityValue(ComponentInstanceProperty componentInstanceProperty) {
194                 if(componentInstanceProperty.getValue() != null) {
195                         return componentInstanceProperty.getValue();
196                 }else {
197                         return componentInstanceProperty.getDefaultValue();
198                 }
199         }
200
201         private List<String> getToscaGroupTemplateMembers(Component component, Map<String, String> members) {
202                 if (members == null) {
203                         return null;
204                 }
205                 return members.values()
206                                 .stream()
207                                 .map(memberId -> getMemberNameByMemberId(component, memberId))
208                                 .filter(Optional::isPresent)
209                                 .map(Optional::get)
210                                 .collect(toList());
211         }
212
213         private Optional<String> getMemberNameByMemberId(Component component, String memberId) {
214         return getComponentInstanceNameByInstanceId(component, memberId);
215         }
216
217         private IToscaMetadata getToscaGroupTemplateMetadata(String groupName,String invariantUUID,
218                                                                      String groupUUID,String version,String type, String customizationUUID) {
219                                 
220                 IToscaMetadata toscaMetadata = getToscaMetadataByType(type);
221                 
222                 toscaMetadata.setName(groupName);
223                 toscaMetadata.setInvariantUUID(invariantUUID);
224                 toscaMetadata.setUUID(groupUUID);
225                 toscaMetadata.setVersion(version);
226                 toscaMetadata.setCustomizationUUID(customizationUUID);
227                 return toscaMetadata;
228         }
229
230         private IToscaMetadata getToscaMetadataByType(String type) {
231                 IToscaMetadata toscaMetadata;
232                 if (GroupUtils.isVfModule(type)) {
233                         toscaMetadata = new VfModuleToscaMetadata();
234                 } else {
235                         toscaMetadata = new ToscaMetadata();
236                 }
237                 return toscaMetadata;
238         }
239
240         private Map<String, Object> getToscaGroupTemplateProperties(List<? extends PropertyDataDefinition> tempProperties) {
241                                 
242                 if (isEmpty(tempProperties)) {
243                         return null;
244                 }
245                                 
246                 Map<String, Object> props = new HashMap<>();
247
248                 tempProperties.forEach(input -> 
249                         propertyConvertor.convertAndAddValue(dataTypes, props, input, getPropertyValue(input))
250                 );
251
252                 if (props.isEmpty()) {
253                         return null;
254                 } else {
255                         return props;
256                 }       
257         }
258
259         private Supplier<String> getPropertyValue(PropertyDataDefinition propertyDataDefinition) {
260                 return () -> {
261                         if (isNotEmpty(propertyDataDefinition.getValue())) {
262                                 return propertyDataDefinition.getValue();
263                         } else {
264                                 return propertyDataDefinition.getDefaultValue();
265                         }
266                 };
267         }
268 }