2 * ============LICENSE_START=======================================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.so.client.orchestration;
23 import java.util.Optional;
25 import org.onap.aai.domain.yang.NetworkPolicy;
26 import org.onap.aai.domain.yang.RouteTableReference;
27 import org.onap.aai.domain.yang.VpnBinding;
28 import org.onap.so.bpmn.common.InjectionHelper;
29 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
30 import org.onap.so.bpmn.servicedecomposition.bbobjects.Collection;
31 import org.onap.so.bpmn.servicedecomposition.bbobjects.InstanceGroup;
32 import org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network;
33 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
34 import org.onap.so.bpmn.servicedecomposition.bbobjects.Subnet;
35 import org.onap.so.client.aai.AAIObjectType;
36 import org.onap.so.client.aai.entities.AAIEdgeLabel;
37 import org.onap.so.client.aai.entities.AAIResultWrapper;
38 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
39 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
40 import org.onap.so.client.graphinventory.entities.uri.Depth;
41 import org.onap.so.client.aai.mapper.AAIObjectMapper;
42 import org.onap.so.db.catalog.beans.OrchestrationStatus;
43 import org.springframework.beans.factory.annotation.Autowired;
44 import org.springframework.stereotype.Component;
47 public class AAINetworkResources {
49 private InjectionHelper injectionHelper;
52 private AAIObjectMapper aaiObjectMapper;
54 public void updateNetwork(L3Network network) {
55 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
56 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
57 injectionHelper.getAaiClient().update(networkURI, aaiL3Network);
60 public void updateSubnet(L3Network network, Subnet subnet) {
61 AAIResourceUri subnetURI = AAIUriFactory.createResourceUri(AAIObjectType.SUBNET, network.getNetworkId(), subnet.getSubnetId());
62 org.onap.aai.domain.yang.Subnet aaiSubnet = aaiObjectMapper.mapSubnet(subnet);
63 injectionHelper.getAaiClient().update(subnetURI, aaiSubnet);
66 public void createNetworkConnectToServiceInstance(L3Network network, ServiceInstance serviceInstance) {
67 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
68 network.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
69 AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
70 serviceInstance.getServiceInstanceId());
71 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
72 injectionHelper.getAaiClient().createIfNotExists(networkURI, Optional.of(aaiL3Network)).connect(networkURI, serviceInstanceURI);
75 public void deleteNetwork(L3Network network) {
76 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
77 injectionHelper.getAaiClient().delete(networkURI);
80 public Optional<VpnBinding> getVpnBinding(AAIResourceUri netBindingUri) {
81 return injectionHelper.getAaiClient().get(netBindingUri.depth(Depth.TWO)).asBean(VpnBinding.class);
84 public Optional<NetworkPolicy> getNetworkPolicy(AAIResourceUri netPolicyUri) {
85 return injectionHelper.getAaiClient().get(netPolicyUri).asBean(NetworkPolicy.class);
88 public Optional<org.onap.aai.domain.yang.Subnet> getSubnet(AAIResourceUri subnetUri) {
89 return injectionHelper.getAaiClient().get(subnetUri).asBean(org.onap.aai.domain.yang.Subnet.class);
92 public Optional<RouteTableReference> getRouteTable(AAIResourceUri rTableUri) {
93 return injectionHelper.getAaiClient().get(rTableUri).asBean(RouteTableReference.class);
96 public Optional<org.onap.aai.domain.yang.L3Network> queryNetworkById(L3Network l3network) {
97 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
98 AAIResultWrapper aaiWrapper = injectionHelper.getAaiClient().get(uri);
99 return aaiWrapper.asBean(org.onap.aai.domain.yang.L3Network.class);
102 public AAIResultWrapper queryNetworkWrapperById(L3Network l3network) {
103 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
104 return injectionHelper.getAaiClient().get(uri);
107 public void createNetworkInstanceGroup(InstanceGroup instanceGroup) {
108 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
109 org.onap.aai.domain.yang.InstanceGroup aaiInstanceGroup = aaiObjectMapper.mapInstanceGroup(instanceGroup);
110 injectionHelper.getAaiClient().create(instanceGroupURI, aaiInstanceGroup);
113 public void createNetworkCollection(Collection networkCollection) {
114 AAIResourceUri networkCollectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
115 networkCollection.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
116 org.onap.aai.domain.yang.Collection aaiCollection = aaiObjectMapper.mapCollection(networkCollection);
117 injectionHelper.getAaiClient().create(networkCollectionURI, aaiCollection);
120 public void connectNetworkToTenant(L3Network l3network, CloudRegion cloudRegion) {
121 AAIResourceUri tenantURI = AAIUriFactory.createResourceUri(AAIObjectType.TENANT,
122 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId(), cloudRegion.getTenantId());
123 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
124 injectionHelper.getAaiClient().connect(tenantURI, networkURI);
127 public void connectNetworkToCloudRegion(L3Network l3network, CloudRegion cloudRegion) {
128 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
129 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
130 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
131 injectionHelper.getAaiClient().connect(networkURI,cloudRegionURI);
134 public void connectNetworkToNetworkCollectionInstanceGroup(L3Network l3network, InstanceGroup instanceGroup) {
135 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
136 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
137 injectionHelper.getAaiClient().connect(netwrokCollectionInstanceGroupURI, networkURI);
140 public void connectNetworkToNetworkCollectionServiceInstance(L3Network l3network, ServiceInstance networkCollectionServiceInstance) {
141 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
142 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
143 injectionHelper.getAaiClient().connect(networkCollectionServiceInstanceUri, networkURI);
146 public void connectNetworkCollectionInstanceGroupToNetworkCollection(InstanceGroup instanceGroup, Collection networkCollection) {
147 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
148 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
149 injectionHelper.getAaiClient().connect(networkCollectionUri, netwrokCollectionInstanceGroupURI);
152 public void connectInstanceGroupToCloudRegion(InstanceGroup instanceGroup, CloudRegion cloudRegion) {
153 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
154 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
155 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
156 injectionHelper.getAaiClient().connect(instanceGroupURI, cloudRegionURI, AAIEdgeLabel.USES);
159 public void connectNetworkCollectionToServiceInstance(Collection networkCollection, ServiceInstance networkCollectionServiceInstance) {
160 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
161 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
162 injectionHelper.getAaiClient().connect(networkCollectionUri, networkCollectionServiceInstanceUri);
165 public void deleteCollection(Collection collection) {
166 AAIResourceUri collectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, collection.getId());
167 injectionHelper.getAaiClient().delete(collectionURI);
170 public void deleteNetworkInstanceGroup(InstanceGroup instanceGroup) {
171 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
172 injectionHelper.getAaiClient().delete(instanceGroupURI);