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.client.aai.AAIObjectType;
35 import org.onap.so.client.aai.entities.AAIResultWrapper;
36 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
37 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
38 import org.onap.so.client.graphinventory.entities.uri.Depth;
39 import org.onap.so.client.aai.mapper.AAIObjectMapper;
40 import org.onap.so.db.catalog.beans.OrchestrationStatus;
41 import org.springframework.beans.factory.annotation.Autowired;
42 import org.springframework.stereotype.Component;
45 public class AAINetworkResources {
47 private InjectionHelper injectionHelper;
50 private AAIObjectMapper aaiObjectMapper;
52 public void updateNetwork(L3Network network) {
53 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
54 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
55 injectionHelper.getAaiClient().update(networkURI, aaiL3Network);
58 public void createNetworkConnectToServiceInstance(L3Network network, ServiceInstance serviceInstance) {
59 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
60 network.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
61 AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
62 serviceInstance.getServiceInstanceId());
63 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
64 injectionHelper.getAaiClient().createIfNotExists(networkURI, Optional.of(aaiL3Network)).connect(networkURI, serviceInstanceURI);
67 public void deleteNetwork(L3Network network) {
68 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
69 injectionHelper.getAaiClient().delete(networkURI);
72 public Optional<VpnBinding> getVpnBinding(AAIResourceUri netBindingUri) {
73 return injectionHelper.getAaiClient().get(netBindingUri).asBean(VpnBinding.class);
76 public Optional<NetworkPolicy> getNetworkPolicy(AAIResourceUri netPolicyUri) {
77 return injectionHelper.getAaiClient().get(netPolicyUri).asBean(NetworkPolicy.class);
80 public Optional<RouteTableReference> getRouteTable(AAIResourceUri rTableUri) {
81 return injectionHelper.getAaiClient().get(rTableUri).asBean(RouteTableReference.class);
84 public Optional<org.onap.aai.domain.yang.L3Network> queryNetworkById(L3Network l3network) {
85 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
86 AAIResultWrapper aaiWrapper = injectionHelper.getAaiClient().get(uri);
87 return aaiWrapper.asBean(org.onap.aai.domain.yang.L3Network.class);
90 public AAIResultWrapper queryNetworkWrapperById(L3Network l3network) {
91 AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
92 return injectionHelper.getAaiClient().get(uri);
95 public void createNetworkInstanceGroup(InstanceGroup instanceGroup) {
96 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
97 org.onap.aai.domain.yang.InstanceGroup aaiInstanceGroup = aaiObjectMapper.mapInstanceGroup(instanceGroup);
98 injectionHelper.getAaiClient().create(instanceGroupURI, aaiInstanceGroup);
101 public void createNetworkCollection(Collection networkCollection) {
102 AAIResourceUri networkCollectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
103 networkCollection.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
104 org.onap.aai.domain.yang.Collection aaiCollection = aaiObjectMapper.mapCollection(networkCollection);
105 injectionHelper.getAaiClient().create(networkCollectionURI, aaiCollection);
108 public void connectNetworkToTenant(L3Network l3network, CloudRegion cloudRegion) {
109 AAIResourceUri tenantURI = AAIUriFactory.createResourceUri(AAIObjectType.TENANT,
110 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId(), cloudRegion.getTenantId());
111 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
112 injectionHelper.getAaiClient().connect(tenantURI, networkURI);
115 public void connectNetworkToCloudRegion(L3Network l3network, CloudRegion cloudRegion) {
116 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
117 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
118 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
119 injectionHelper.getAaiClient().connect(cloudRegionURI, networkURI);
122 public void connectNetworkToNetworkCollectionInstanceGroup(L3Network l3network, InstanceGroup instanceGroup) {
123 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
124 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
125 injectionHelper.getAaiClient().connect(netwrokCollectionInstanceGroupURI, networkURI);
128 public void connectNetworkToNetworkCollectionServiceInstance(L3Network l3network, ServiceInstance networkCollectionServiceInstance) {
129 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
130 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
131 injectionHelper.getAaiClient().connect(networkCollectionServiceInstanceUri, networkURI);
134 public void connectNetworkCollectionInstanceGroupToNetworkCollection(InstanceGroup instanceGroup, Collection networkCollection) {
135 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
136 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
137 injectionHelper.getAaiClient().connect(networkCollectionUri, netwrokCollectionInstanceGroupURI);
140 public void connectNetworkCollectionToServiceInstance(Collection networkCollection, ServiceInstance networkCollectionServiceInstance) {
141 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
142 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
143 injectionHelper.getAaiClient().connect(networkCollectionUri, networkCollectionServiceInstanceUri);
146 public void deleteCollection(Collection collection) {
147 AAIResourceUri collectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, collection.getId());
148 injectionHelper.getAaiClient().delete(collectionURI);
151 public void deleteNetworkInstanceGroup(InstanceGroup instanceGroup) {
152 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
153 injectionHelper.getAaiClient().delete(instanceGroupURI);