1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/*
* ============LICENSE_START=======================================================
* Copyright (C) 2021 Pantheon.tech
* Modifications (C) 2021-2022 Nordix Foundation
* Modifications Copyright (C) 2022 Bell Canada
* Modifications Copyright (C) 2022-2023 TechMahindra Ltd.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
package org.onap.cps.utils;
import static java.util.stream.Collectors.groupingBy;
import static java.util.stream.Collectors.mapping;
import static java.util.stream.Collectors.toUnmodifiableList;
import static java.util.stream.Collectors.toUnmodifiableMap;
import com.google.common.collect.ImmutableMap;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.onap.cps.spi.model.DataNode;
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class DataMapUtils {
/**
* Converts DataNode structure into a map including the root node identifier for a JSON response.
*
* @param dataNode data node object
* @return a map representing same data with the root node identifier
*/
public static Map<String, Object> toDataMapWithIdentifier(final DataNode dataNode, final String prefix) {
final String nodeIdentifierWithPrefix = getNodeIdentifierWithPrefix(dataNode.getXpath(), prefix);
return ImmutableMap.<String, Object>builder().put(nodeIdentifierWithPrefix, toDataMap(dataNode)).build();
}
/**
* Converts DataNode structure into a map including the root node identifier for a JSON response.
*
* @param dataNode data node object
* @return a map representing same data with the root node identifier
*/
public static Map<String, Object> toDataMapWithIdentifierAndAnchor(final DataNode dataNode, final String prefix) {
final String nodeIdentifierWithPrefix = getNodeIdentifierWithPrefix(dataNode.getXpath(), prefix);
final Map<String, Object> dataMap = ImmutableMap.<String, Object>builder()
.put(nodeIdentifierWithPrefix, toDataMap(dataNode)).build();
return ImmutableMap.<String, Object>builder().put("anchorName", dataNode.getAnchorName())
.put("dataNode", dataMap).build();
}
/**
* Converts DataNode structure into a map for a JSON response.
*
* @param dataNode data node object
* @return a map representing same data
*/
public static Map<String, Object> toDataMap(final DataNode dataNode) {
return ImmutableMap.<String, Object>builder()
.putAll(dataNode.getLeaves())
.putAll(listElementsAsMap(dataNode.getChildDataNodes()))
.putAll(containerElementsAsMap(dataNode.getChildDataNodes()))
.build();
}
private static Map<String, Object> listElementsAsMap(final Collection<DataNode> dataNodes) {
if (dataNodes.isEmpty()) {
return Collections.emptyMap();
}
return ImmutableMap.<String, Object>builder()
.putAll(
dataNodes.stream()
.filter(dataNode -> isListElement(dataNode.getXpath()))
.collect(groupingBy(
dataNode -> getNodeIdentifier(dataNode.getXpath()),
mapping(DataMapUtils::toDataMap, toUnmodifiableList())
))
).build();
}
private static Map<String, Object> containerElementsAsMap(final Collection<DataNode> dataNodes) {
if (dataNodes.isEmpty()) {
return Collections.emptyMap();
}
return dataNodes.stream()
.filter(dataNode -> isContainerNode(dataNode.getXpath()))
.collect(
toUnmodifiableMap(
dataNode -> getNodeIdentifier(dataNode.getXpath()),
DataMapUtils::toDataMap
));
}
private static String getNodeIdentifier(String xpath) {
if (xpath.endsWith("]")) {
xpath = xpath.substring(0, xpath.lastIndexOf('['));
}
final int fromIndex = xpath.lastIndexOf('/') + 1;
return xpath.substring(fromIndex);
}
private static String getNodeIdentifierWithPrefix(final String xpath, final String moduleNamePrefix) {
if (moduleNamePrefix != null) {
return moduleNamePrefix + ":" + getNodeIdentifier(xpath);
}
return getNodeIdentifier(xpath);
}
private static boolean isContainerNode(final String xpath) {
return !isListElement(xpath);
}
private static boolean isListElement(final String xpath) {
return xpath.endsWith("]");
}
}
|
