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
131
132
133
134
135
|
/*
* Copyright 2016-2017, Nokia Corporation
*
* 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.
*/
package org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.notification;
import com.google.gson.Gson;
import io.reactivex.Observable;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.onap.aai.model.Relationship;
import org.onap.aai.model.RelationshipData;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.onap.direct.AAIRestApiProvider;
import org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.vnfm.CbamRestApiProvider;
import org.slf4j.Logger;
import static com.google.common.collect.Iterables.find;
import static org.onap.vfc.nfvo.driver.vnfm.svnfm.nokia.util.CbamUtils.SEPARATOR;
/**
* Handles the common management of changing entities in AAI
*/
abstract class AbstractManager {
protected final AAIRestApiProvider aaiRestApiProvider;
protected final CbamRestApiProvider cbamRestApiProvider;
AbstractManager(AAIRestApiProvider aaiRestApiProvider, CbamRestApiProvider cbamRestApiProvider) {
this.aaiRestApiProvider = aaiRestApiProvider;
this.cbamRestApiProvider = cbamRestApiProvider;
}
/**
* @param key the key of the relationship
* @param value the value of the relationship
* @return the relationship
*/
protected static RelationshipData buildRelationshipData(String key, String value) {
RelationshipData data = new RelationshipData();
data.setRelationshipKey(key);
data.setRelationshipValue(value);
return data;
}
/**
* Extract mandatory value from the additional data on LCN resources
*
* @param additionalData the additional data
* @param key the key of the additional data
* @return the value of the additional data
*/
protected static String extractMandatoryValue(Object additionalData, String key) {
return new Gson().toJsonTree(additionalData).getAsJsonObject().get(key).getAsString();
}
/**
* Create or update the singleton relationship. Singleton means that relationships can only have a
* single {@link Relationship} with the given {@link Relationship#getRelatedTo} value
*
* @param relationships the list of relationships
* @param relationship the expected relationship
*/
protected static void addSingletonRelation(List<Relationship> relationships, Relationship relationship) {
boolean found = false;
for (Relationship currentRelationShip : relationships) {
if (relationship.getRelatedTo().equals(currentRelationShip.getRelatedTo())) {
found = true;
}
}
if (!found) {
relationships.add(relationship);
} else {
Relationship existingRelationShip = find(relationships, currentRelationShip -> currentRelationShip.getRelatedTo().equals(relationship.getRelatedTo()));
existingRelationShip.getRelationshipData().clear();
existingRelationShip.getRelationshipData().addAll(relationship.getRelationshipData());
}
}
/**
* Add the given relationship if it is already not part of the relationships
*
* @param relationships the relationships
* @param relationship the relationship to be added
*/
protected static void addMissingRelation(List<Relationship> relationships, Relationship relationship) {
for (Relationship currentRelationShip : relationships) {
if (currentRelationShip.getRelatedTo().equals(relationship.getRelatedTo())
&& compositeKeys(currentRelationShip.getRelationshipData()).equals(compositeKeys(relationship.getRelationshipData()))) {
return;
}
}
relationships.add(relationship);
}
private static Set<String> compositeKeys(List<RelationshipData> data) {
Set<String> keys = new HashSet<>();
for (RelationshipData relationshipData : data) {
keys.add(relationshipData.getRelationshipKey() + SEPARATOR + relationshipData.getRelationshipValue());
}
return keys;
}
/**
* @return the concrete logger to be used
*/
protected abstract Logger getLogger();
/**
* Creates or returns a REST resource instance
*
* @param get provides an existing instance
* @param newInstance the empty instance if the resource does not exists
* @param <T> the type of the resource
* @return the created or queried resource
*/
protected <T> T createOrGet(Observable<T> get, T newInstance) {
try {
return get.blockingFirst();
} catch (Exception e) {
getLogger().debug("The resource was not found in AAI", e);
return newInstance;
}
}
}
|
