bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/orchestration/AAINetworkResources.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.onap.so.client.orchestration;
  22
  23 import java.util.Optional;
  24
  25 import org.onap.aai.domain.yang.NetworkPolicies;
  26 import org.onap.aai.domain.yang.NetworkPolicy;
  27 import org.onap.aai.domain.yang.RouteTableReference;
  28 import org.onap.aai.domain.yang.VpnBinding;
  29 import org.onap.so.bpmn.common.InjectionHelper;
  30 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
  31 import org.onap.so.bpmn.servicedecomposition.bbobjects.Collection;
  32 import org.onap.so.bpmn.servicedecomposition.bbobjects.InstanceGroup;
  33 import org.onap.so.bpmn.servicedecomposition.bbobjects.L3Network;
  34 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
  35 import org.onap.so.bpmn.servicedecomposition.bbobjects.Subnet;
  36 import org.onap.so.client.aai.AAIObjectType;
  37 import org.onap.so.client.aai.entities.AAIEdgeLabel;
  38 import org.onap.so.client.aai.entities.AAIResultWrapper;
  39 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  40 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
  41 import org.onap.so.client.graphinventory.entities.uri.Depth;
  42 import org.onap.so.client.aai.mapper.AAIObjectMapper;
  43 import org.onap.so.db.catalog.beans.OrchestrationStatus;
  44 import org.springframework.beans.factory.annotation.Autowired;
  45 import org.springframework.stereotype.Component;
  46
  47 @Component
  48 public class AAINetworkResources {
  49
  50         @Autowired
  51         private InjectionHelper injectionHelper;
  52
  53         @Autowired
  54         private AAIObjectMapper aaiObjectMapper;
  55
  56         public void updateNetwork(L3Network network) {
  57                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
  58                 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
  59                 injectionHelper.getAaiClient().update(networkURI, aaiL3Network);
  60         }
  61
  62         public void updateSubnet(L3Network network, Subnet subnet) {
  63                 AAIResourceUri subnetURI = AAIUriFactory.createResourceUri(AAIObjectType.SUBNET, network.getNetworkId(), subnet.getSubnetId());
  64                 org.onap.aai.domain.yang.Subnet aaiSubnet = aaiObjectMapper.mapSubnet(subnet);
  65                 injectionHelper.getAaiClient().update(subnetURI, aaiSubnet);
  66         }
  67
  68         public void createNetworkConnectToServiceInstance(L3Network network, ServiceInstance serviceInstance) {
  69                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
  70                 network.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
  71                 AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
  72                                 serviceInstance.getServiceInstanceId());
  73                 org.onap.aai.domain.yang.L3Network aaiL3Network = aaiObjectMapper.mapNetwork(network);
  74                 injectionHelper.getAaiClient().createIfNotExists(networkURI, Optional.of(aaiL3Network)).connect(networkURI, serviceInstanceURI);
  75         }
  76
  77         public void deleteNetwork(L3Network network) {
  78                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, network.getNetworkId());
  79                 injectionHelper.getAaiClient().delete(networkURI);
  80         }
  81
  82         public Optional<VpnBinding> getVpnBinding(AAIResourceUri netBindingUri) {
  83                 return injectionHelper.getAaiClient().get(netBindingUri.depth(Depth.TWO)).asBean(VpnBinding.class);
  84         }
  85
  86         public Optional<NetworkPolicy> getNetworkPolicy(AAIResourceUri netPolicyUri) {
  87                 return injectionHelper.getAaiClient().get(netPolicyUri).asBean(NetworkPolicy.class);
  88         }
  89
  90         public Optional<NetworkPolicies> getNetworkPolicies(AAIResourceUri netPoliciesUri) {
  91                 return injectionHelper.getAaiClient().get(netPoliciesUri).asBean(NetworkPolicies.class);
  92         }
  93
  94         public Optional<org.onap.aai.domain.yang.Subnet> getSubnet(AAIResourceUri subnetUri) {
  95                 return injectionHelper.getAaiClient().get(subnetUri).asBean(org.onap.aai.domain.yang.Subnet.class);
  96         }
  97
  98         public Optional<RouteTableReference> getRouteTable(AAIResourceUri rTableUri) {
  99                 return injectionHelper.getAaiClient().get(rTableUri).asBean(RouteTableReference.class);
 100         }
 101
 102         public Optional<org.onap.aai.domain.yang.L3Network> queryNetworkById(L3Network l3network) {
 103                 AAIResourceUri  uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
 104                 AAIResultWrapper aaiWrapper = injectionHelper.getAaiClient().get(uri);
 105                 return aaiWrapper.asBean(org.onap.aai.domain.yang.L3Network.class);
 106         }
 107
 108         public AAIResultWrapper queryNetworkWrapperById(L3Network l3network) {
 109                 AAIResourceUri  uri = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK,l3network.getNetworkId()).depth(Depth.ALL);
 110                 return injectionHelper.getAaiClient().get(uri);
 111         }
 112
 113         public void createNetworkInstanceGroup(InstanceGroup instanceGroup) {
 114                 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
 115                 org.onap.aai.domain.yang.InstanceGroup aaiInstanceGroup = aaiObjectMapper.mapInstanceGroup(instanceGroup);
 116                 injectionHelper.getAaiClient().create(instanceGroupURI, aaiInstanceGroup);
 117         }
 118
 119         public void createNetworkCollection(Collection networkCollection) {
 120                 AAIResourceUri networkCollectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
 121                 networkCollection.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
 122                 org.onap.aai.domain.yang.Collection aaiCollection = aaiObjectMapper.mapCollection(networkCollection);
 123                 injectionHelper.getAaiClient().create(networkCollectionURI, aaiCollection);
 124         }
 125
 126         public void connectNetworkToTenant(L3Network l3network, CloudRegion cloudRegion) {
 127                 AAIResourceUri tenantURI = AAIUriFactory.createResourceUri(AAIObjectType.TENANT,
 128                                 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId(), cloudRegion.getTenantId());
 129                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
 130                 injectionHelper.getAaiClient().connect(tenantURI, networkURI);
 131         }
 132
 133         public void connectNetworkToCloudRegion(L3Network l3network, CloudRegion cloudRegion) {
 134                 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
 135                                 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
 136                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
 137                 injectionHelper.getAaiClient().connect(networkURI,cloudRegionURI);
 138         }
 139
 140         public void connectNetworkToNetworkCollectionInstanceGroup(L3Network l3network, InstanceGroup instanceGroup) {
 141                 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
 142                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
 143                 injectionHelper.getAaiClient().connect(netwrokCollectionInstanceGroupURI, networkURI);
 144         }
 145
 146         public void connectNetworkToNetworkCollectionServiceInstance(L3Network l3network, ServiceInstance networkCollectionServiceInstance) {
 147                 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
 148                 AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, l3network.getNetworkId());
 149                 injectionHelper.getAaiClient().connect(networkCollectionServiceInstanceUri, networkURI);
 150         }
 151
 152         public void connectNetworkCollectionInstanceGroupToNetworkCollection(InstanceGroup instanceGroup, Collection networkCollection) {
 153                 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
 154                 AAIResourceUri netwrokCollectionInstanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
 155                 injectionHelper.getAaiClient().connect(networkCollectionUri, netwrokCollectionInstanceGroupURI);
 156         }
 157
 158         public void connectInstanceGroupToCloudRegion(InstanceGroup instanceGroup, CloudRegion cloudRegion) {
 159                 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
 160                                 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
 161                 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
 162                 injectionHelper.getAaiClient().connect(instanceGroupURI, cloudRegionURI, AAIEdgeLabel.USES);
 163         }
 164
 165         public void connectNetworkCollectionToServiceInstance(Collection networkCollection, ServiceInstance networkCollectionServiceInstance) {
 166                 AAIResourceUri networkCollectionUri = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, networkCollection.getId());
 167                 AAIResourceUri networkCollectionServiceInstanceUri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, networkCollectionServiceInstance.getServiceInstanceId());
 168                 injectionHelper.getAaiClient().connect(networkCollectionUri, networkCollectionServiceInstanceUri);
 169         }
 170
 171         public void deleteCollection(Collection collection) {
 172                 AAIResourceUri collectionURI = AAIUriFactory.createResourceUri(AAIObjectType.COLLECTION, collection.getId());
 173                 injectionHelper.getAaiClient().delete(collectionURI);
 174         }
 175
 176         public void deleteNetworkInstanceGroup(InstanceGroup instanceGroup) {
 177                 AAIResourceUri instanceGroupURI = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroup.getId());
 178                 injectionHelper.getAaiClient().delete(instanceGroupURI);
 179         }
 180
 181         public void createNetworkPolicy(org.onap.so.bpmn.servicedecomposition.bbobjects.NetworkPolicy networkPolicy) {
 182                 NetworkPolicy aaiNetworkPolicy = aaiObjectMapper.mapNetworkPolicy(networkPolicy);
 183                 String networkPolicyId = networkPolicy.getNetworkPolicyId();
 184                 AAIResourceUri netUri = AAIUriFactory.createResourceUri(AAIObjectType.NETWORK_POLICY, networkPolicyId);
 185                 injectionHelper.getAaiClient().create(netUri, aaiNetworkPolicy);
 186         }
 187
 188         public void deleteNetworkPolicy(String networkPolicyId) {
 189                 AAIResourceUri networkPolicyURI = AAIUriFactory.createResourceUri(AAIObjectType.NETWORK_POLICY, networkPolicyId);
 190                 injectionHelper.getAaiClient().delete(networkPolicyURI);
 191         }
 192 }