blob: 7fcc61391315ddf6a15a15b86170318077654754 (
plain)
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
|
/*-
* ============LICENSE_START=======================================================
* ONAP - SO
* ================================================================================
* Copyright (C) 2017 - 2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Modifications Copyright (c) 2019 Samsung
* ================================================================================
* 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.
* ============LICENSE_END=========================================================
*/
package org.onap.so.bpmn.servicedecomposition.tasks;
import java.util.List;
import java.util.Optional;
import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
import org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network;
import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
import org.onap.so.client.aai.AAICommonObjectMapperProvider;
import org.onap.so.client.aai.AAIObjectType;
import org.onap.so.client.aai.entities.AAIResultWrapper;
import org.onap.so.client.aai.entities.Relationships;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.fasterxml.jackson.core.JsonProcessingException;
@Component
public class CloudInfoFromAAI {
private static final Logger logger = LoggerFactory.getLogger(CloudInfoFromAAI.class);
@Autowired
private BBInputSetupUtils bbInputSetupUtils;
public void setBbInputSetupUtils(BBInputSetupUtils bbInputSetupUtils) {
this.bbInputSetupUtils = bbInputSetupUtils;
}
protected Optional<CloudRegion> getCloudInfoFromAAI(ServiceInstance serviceInstance) throws JsonProcessingException {
Optional<Relationships> relationshipsOp = Optional.empty();
if(!serviceInstance.getVnfs().isEmpty()) {
GenericVnf vnf = serviceInstance.getVnfs().get(0);
org.onap.aai.domain.yang.GenericVnf aaiVnf = bbInputSetupUtils.getAAIGenericVnf(vnf.getVnfId());
AAIResultWrapper vnfWrapper = new AAIResultWrapper(
new AAICommonObjectMapperProvider().getMapper().writeValueAsString(aaiVnf));
relationshipsOp = getRelationshipsFromWrapper(vnfWrapper);
} else if(!serviceInstance.getNetworks().isEmpty()) {
L3Network network = serviceInstance.getNetworks().get(0);
org.onap.aai.domain.yang.L3Network aaiL3Network = bbInputSetupUtils.getAAIL3Network(network.getNetworkId());
AAIResultWrapper networkWrapper = new AAIResultWrapper(
new AAICommonObjectMapperProvider().getMapper().writeValueAsString(aaiL3Network));
relationshipsOp = getRelationshipsFromWrapper(networkWrapper);
} else {
logger.debug("BBInputSetup could not find a cloud region or tenant, since there are no resources under the SI.");
return Optional.empty();
}
if (relationshipsOp.isPresent()) {
return getRelatedCloudRegionAndTenant(relationshipsOp.get());
} else {
logger.debug("BBInputSetup could not find a cloud region or tenant");
return Optional.empty();
}
}
protected Optional<Relationships> getRelationshipsFromWrapper(AAIResultWrapper wrapper) {
Optional<Relationships> relationshipsOp;
relationshipsOp = wrapper.getRelationships();
if(relationshipsOp.isPresent()) {
return relationshipsOp;
}
return Optional.empty();
}
protected Optional<CloudRegion> getRelatedCloudRegionAndTenant(Relationships relationships) {
CloudRegion cloudRegion = new CloudRegion();
List<AAIResultWrapper> cloudRegions = relationships.getByType(AAIObjectType.CLOUD_REGION);
List<AAIResultWrapper> tenants = relationships.getByType(AAIObjectType.TENANT);
if(!cloudRegions.isEmpty()) {
AAIResultWrapper cloudRegionWrapper = cloudRegions.get(0);
Optional<org.onap.aai.domain.yang.CloudRegion> aaiCloudRegionOp = cloudRegionWrapper
.asBean(org.onap.aai.domain.yang.CloudRegion.class);
if(aaiCloudRegionOp.isPresent()) {
org.onap.aai.domain.yang.CloudRegion aaiCloudRegion = aaiCloudRegionOp.get();
cloudRegion.setCloudOwner(aaiCloudRegion.getCloudOwner());
cloudRegion.setCloudRegionVersion(aaiCloudRegion.getCloudRegionVersion());
cloudRegion.setLcpCloudRegionId(aaiCloudRegion.getCloudRegionId());
cloudRegion.setComplex(aaiCloudRegion.getComplexName());
}
}
if(!tenants.isEmpty()) {
AAIResultWrapper tenantWrapper = tenants.get(0);
Optional<org.onap.aai.domain.yang.Tenant> aaiTenantOp = tenantWrapper
.asBean(org.onap.aai.domain.yang.Tenant.class);
if(aaiTenantOp.isPresent()) {
org.onap.aai.domain.yang.Tenant aaiTenant = aaiTenantOp.get();
cloudRegion.setTenantId(aaiTenant.getTenantId());
}
}
return Optional.of(cloudRegion);
}
}
|
