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<RouteTableReference> getRouteTable(AAIResourceUri rTableUri) {
89 return injectionHelper.getAaiClient().get(rTableUri).asBean(RouteTableReference.class);
92 public Optional<org.onap.aai.domain.yang.L3Network> queryNetworkById(L3Network l3network) {
93 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
94 AAIResultWrapper aaiWrapper = injectionHelper.getAaiClient().get(uri);
95 return aaiWrapper.asBean(org.onap.aai.domain.yang.L3Network.class);
98 public AAIResultWrapper queryNetworkWrapperById(L3Network l3network) {
99 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
100 return injectionHelper.getAaiClient().get(uri);
103 public void createNetworkInstanceGroup(InstanceGroup instanceGroup) {
104 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
105 org.onap.aai.domain.yang.InstanceGroup aaiInstanceGroup = aaiObjectMapper.mapInstanceGroup(instanceGroup);
106 injectionHelper.getAaiClient().create(instanceGroupURI, aaiInstanceGroup);
109 public void createNetworkCollection(Collection networkCollection) {
110 AAIResourceUri networkCollectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
111 networkCollection.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
112 org.onap.aai.domain.yang.Collection aaiCollection = aaiObjectMapper.mapCollection(networkCollection);
113 injectionHelper.getAaiClient().create(networkCollectionURI, aaiCollection);
116 public void connectNetworkToTenant(L3Network l3network, CloudRegion cloudRegion) {
117 AAIResourceUri tenantURI = AAIUriFactory.createResourceUri(AAIObjectType.TENANT,
118 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId(), cloudRegion.getTenantId());
119 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
120 injectionHelper.getAaiClient().connect(tenantURI, networkURI);
123 public void connectNetworkToCloudRegion(L3Network l3network, CloudRegion cloudRegion) {
124 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
125 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
126 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
127 injectionHelper.getAaiClient().connect(networkURI,cloudRegionURI);
130 public void connectNetworkToNetworkCollectionInstanceGroup(L3Network l3network, InstanceGroup instanceGroup) {
131 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
132 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
133 injectionHelper.getAaiClient().connect(netwrokCollectionInstanceGroupURI, networkURI);
136 public void connectNetworkToNetworkCollectionServiceInstance(L3Network l3network, ServiceInstance networkCollectionServiceInstance) {
137 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
138 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
139 injectionHelper.getAaiClient().connect(networkCollectionServiceInstanceUri, networkURI);
142 public void connectNetworkCollectionInstanceGroupToNetworkCollection(InstanceGroup instanceGroup, Collection networkCollection) {
143 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
144 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
145 injectionHelper.getAaiClient().connect(networkCollectionUri, netwrokCollectionInstanceGroupURI);
148 public void connectInstanceGroupToCloudRegion(InstanceGroup instanceGroup, CloudRegion cloudRegion) {
149 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
150 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
151 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
152 injectionHelper.getAaiClient().connect(instanceGroupURI, cloudRegionURI, AAIEdgeLabel.USES);
155 public void connectNetworkCollectionToServiceInstance(Collection networkCollection, ServiceInstance networkCollectionServiceInstance) {
156 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
157 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
158 injectionHelper.getAaiClient().connect(networkCollectionUri, networkCollectionServiceInstanceUri);
161 public void deleteCollection(Collection collection) {
162 AAIResourceUri collectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, collection.getId());
163 injectionHelper.getAaiClient().delete(collectionURI);
166 public void deleteNetworkInstanceGroup(InstanceGroup instanceGroup) {
167 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
168 injectionHelper.getAaiClient().delete(instanceGroupURI);