bpmn/MSOCommonBPMN/src/main/java/org/onap/so/bpmn/servicedecomposition/tasks/BBInputSetupUtils.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright (c) 2019 Samsung
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.bpmn.servicedecomposition.tasks;
  24
  25 import java.io.IOException;
  26 import java.util.ArrayList;
  27 import java.util.Arrays;
  28 import java.util.List;
  29 import java.util.Map;
  30 import java.util.Optional;
  31 import org.onap.aai.domain.yang.CloudRegion;
  32 import org.onap.aai.domain.yang.Configuration;
  33 import org.onap.aai.domain.yang.Configurations;
  34 import org.onap.aai.domain.yang.GenericVnf;
  35 import org.onap.aai.domain.yang.GenericVnfs;
  36 import org.onap.aai.domain.yang.InstanceGroup;
  37 import org.onap.aai.domain.yang.L3Network;
  38 import org.onap.aai.domain.yang.L3Networks;
  39 import org.onap.aai.domain.yang.ServiceInstance;
  40 import org.onap.aai.domain.yang.ServiceInstances;
  41 import org.onap.aai.domain.yang.ServiceSubscription;
  42 import org.onap.aai.domain.yang.VfModule;
  43 import org.onap.aai.domain.yang.VolumeGroup;
  44 import org.onap.aai.domain.yang.VolumeGroups;
  45 import org.onap.aai.domain.yang.VpnBinding;
  46 import org.onap.so.bpmn.common.InjectionHelper;
  47 import org.onap.so.bpmn.servicedecomposition.bbobjects.Customer;
  48 import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
  49 import org.onap.so.bpmn.servicedecomposition.tasks.exceptions.MultipleObjectsFoundException;
  50 import org.onap.so.bpmn.servicedecomposition.tasks.exceptions.NoServiceInstanceFoundException;
  51 import org.onap.aaiclient.client.aai.AAIObjectPlurals;
  52 import org.onap.aaiclient.client.aai.AAIObjectType;
  53 import org.onap.aaiclient.client.aai.AAIResourcesClient;
  54 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper;
  55 import org.onap.aaiclient.client.aai.entities.uri.AAIPluralResourceUri;
  56 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri;
  57 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
  58 import org.onap.aaiclient.client.graphinventory.entities.uri.Depth;
  59 import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
  60 import org.onap.so.db.catalog.beans.CollectionResourceInstanceGroupCustomization;
  61 import org.onap.so.db.catalog.beans.CvnfcConfigurationCustomization;
  62 import org.onap.so.db.catalog.beans.NetworkCollectionResourceCustomization;
  63 import org.onap.so.db.catalog.beans.Service;
  64 import org.onap.so.db.catalog.beans.VfModuleCustomization;
  65 import org.onap.so.db.catalog.beans.VnfcInstanceGroupCustomization;
  66 import org.onap.so.db.catalog.client.CatalogDbClient;
  67 import org.onap.so.db.request.beans.InfraActiveRequests;
  68 import org.onap.so.db.request.beans.RequestProcessingData;
  69 import org.onap.so.db.request.client.RequestsDbClient;
  70 import org.onap.so.serviceinstancebeans.CloudConfiguration;
  71 import org.onap.so.serviceinstancebeans.ModelType;
  72 import org.onap.so.serviceinstancebeans.RelatedInstance;
  73 import org.onap.so.serviceinstancebeans.RelatedInstanceList;
  74 import org.onap.so.serviceinstancebeans.RequestDetails;
  75 import org.slf4j.Logger;
  76 import org.slf4j.LoggerFactory;
  77 import org.springframework.beans.factory.annotation.Autowired;
  78 import org.springframework.stereotype.Component;
  79 import com.fasterxml.jackson.core.JsonProcessingException;
  80 import com.fasterxml.jackson.databind.DeserializationFeature;
  81 import com.fasterxml.jackson.databind.ObjectMapper;
  82 import com.fasterxml.jackson.databind.SerializationFeature;
  83 import com.fasterxml.jackson.databind.type.TypeFactory;
  84
  85 @Component("BBInputSetupUtils")
  86 public class BBInputSetupUtils {
  87
  88     private static final Logger logger = LoggerFactory.getLogger(BBInputSetupUtils.class);
  89     private ObjectMapper objectMapper = new ObjectMapper();
  90     private static final String REQUEST_ERROR = "Could not find request.";
  91     private static final String DATA_LOAD_ERROR = "Could not process loading data from database";
  92     private static final String DATA_PARSE_ERROR = "Could not parse data";
  93     private static final String PROCESSING_DATA_NAME_EXECUTION_FLOWS = "flowExecutionPath";
  94
  95     @Autowired
  96     protected CatalogDbClient catalogDbClient;
  97
  98     @Autowired
  99     protected RequestsDbClient requestsDbClient;
 100
 101     @Autowired
 102     protected InjectionHelper injectionHelper;
 103
 104     public RelatedInstance getRelatedInstanceByType(RequestDetails requestDetails, ModelType modelType) {
 105         if (requestDetails.getRelatedInstanceList() != null) {
 106             for (RelatedInstanceList relatedInstanceList : requestDetails.getRelatedInstanceList()) {
 107                 RelatedInstance relatedInstance = relatedInstanceList.getRelatedInstance();
 108                 if (relatedInstance != null && relatedInstance.getModelInfo() != null
 109                         && relatedInstance.getModelInfo().getModelType() != null
 110                         && relatedInstance.getModelInfo().getModelType().equals(modelType)) {
 111                     return relatedInstance;
 112                 }
 113             }
 114         }
 115         return null;
 116     }
 117
 118     public void updateInfraActiveRequestVnfId(InfraActiveRequests request, String vnfId) {
 119         if (request != null) {
 120             request.setVnfId(vnfId);
 121             this.requestsDbClient.updateInfraActiveRequests(request);
 122         } else {
 123             logger.debug(REQUEST_ERROR);
 124         }
 125     }
 126
 127     public void updateInfraActiveRequestVfModuleId(InfraActiveRequests request, String vfModuleId) {
 128         if (request != null) {
 129             request.setVfModuleId(vfModuleId);
 130             this.requestsDbClient.updateInfraActiveRequests(request);
 131         } else {
 132             logger.debug(REQUEST_ERROR);
 133         }
 134     }
 135
 136     public void updateInfraActiveRequestVolumeGroupId(InfraActiveRequests request, String volumeGroupId) {
 137         if (request != null) {
 138             request.setVolumeGroupId(volumeGroupId);
 139             this.requestsDbClient.updateInfraActiveRequests(request);
 140         } else {
 141             logger.debug(REQUEST_ERROR);
 142         }
 143     }
 144
 145     public void updateInfraActiveRequestNetworkId(InfraActiveRequests request, String networkId) {
 146         if (request != null) {
 147             request.setNetworkId(networkId);
 148             this.requestsDbClient.updateInfraActiveRequests(request);
 149         } else {
 150             logger.debug(REQUEST_ERROR);
 151         }
 152     }
 153
 154     public void persistFlowExecutionPath(String requestId, List<ExecuteBuildingBlock> flowsToExecute) {
 155
 156         if (requestId != null) {
 157             List<String> flows = new ArrayList<>();
 158             ObjectMapper om = new ObjectMapper();
 159             try {
 160                 for (ExecuteBuildingBlock ebb : flowsToExecute) {
 161                     flows.add(om.writeValueAsString(ebb));
 162                 }
 163             } catch (JsonProcessingException e) {
 164                 logger.error(DATA_PARSE_ERROR, e);
 165             }
 166
 167             this.requestsDbClient.persistProcessingData(flows.toString(), requestId);
 168         } else {
 169             logger.debug(REQUEST_ERROR);
 170         }
 171     }
 172
 173     public InfraActiveRequests loadInfraActiveRequestById(String requestId) {
 174
 175         return this.requestsDbClient.getInfraActiveRequestbyRequestId(requestId);
 176     }
 177
 178     public InfraActiveRequests loadOriginalInfraActiveRequestById(String requestId) {
 179         return this.requestsDbClient.getInfraActiveRequestbyRequestId(
 180                 this.requestsDbClient.getInfraActiveRequestbyRequestId(requestId).getOriginalRequestId());
 181     }
 182
 183     public List<ExecuteBuildingBlock> loadOriginalFlowExecutionPath(String requestId) {
 184         if (requestId != null) {
 185             InfraActiveRequests request = loadInfraActiveRequestById(requestId);
 186             if (request.getOriginalRequestId() != null) {
 187                 RequestProcessingData requestProcessingData =
 188                         this.requestsDbClient.getRequestProcessingDataBySoRequestIdAndName(
 189                                 request.getOriginalRequestId(), PROCESSING_DATA_NAME_EXECUTION_FLOWS);
 190                 try {
 191                     ObjectMapper om = new ObjectMapper();
 192                     TypeFactory typeFactory = objectMapper.getTypeFactory();
 193                     return om.readValue(requestProcessingData.getValue(),
 194                             typeFactory.constructCollectionType(List.class, ExecuteBuildingBlock.class));
 195                 } catch (Exception e) {
 196                     logger.error(DATA_LOAD_ERROR, e);
 197                     throw new RuntimeException("Error Loading Original Request Data", e);
 198                 }
 199             } else {
 200                 throw new RuntimeException("Original Request Id is null for record: " + requestId);
 201             }
 202         } else {
 203             throw new RuntimeException("Null Request Id Passed in");
 204         }
 205     }
 206
 207     public Service getCatalogServiceByModelUUID(String modelUUID) {
 208         return catalogDbClient.getServiceByID(modelUUID);
 209     }
 210
 211     public Service getCatalogServiceByModelVersionAndModelInvariantUUID(String modelVersion,
 212             String modelInvariantUUID) {
 213         return catalogDbClient.getServiceByModelVersionAndModelInvariantUUID(modelVersion, modelInvariantUUID);
 214     }
 215
 216     public CollectionNetworkResourceCustomization getCatalogCollectionNetworkResourceCustByID(String key) {
 217         return catalogDbClient.getCollectionNetworkResourceCustomizationByID(key);
 218     }
 219
 220     public NetworkCollectionResourceCustomization getCatalogNetworkCollectionResourceCustByID(
 221             String collectionCustomizationId) {
 222         return catalogDbClient.getNetworkCollectionResourceCustomizationByID(collectionCustomizationId);
 223     }
 224
 225     public VfModuleCustomization getVfModuleCustomizationByModelCuztomizationUUID(String modelCustomizationUUID) {
 226         return catalogDbClient.getVfModuleCustomizationByModelCuztomizationUUID(modelCustomizationUUID);
 227     }
 228
 229     public CvnfcConfigurationCustomization getCvnfcConfigurationCustomization(String serviceModelUUID,
 230             String vnfCustomizationUuid, String vfModuleCustomizationUuid, String cvnfcCustomizationUuid) {
 231         return catalogDbClient.getCvnfcCustomization(serviceModelUUID, vnfCustomizationUuid, vfModuleCustomizationUuid,
 232                 cvnfcCustomizationUuid);
 233     }
 234
 235     public List<VnfcInstanceGroupCustomization> getVnfcInstanceGroups(String modelCustomizationUUID) {
 236         return catalogDbClient.getVnfcInstanceGroupsByVnfResourceCust(modelCustomizationUUID);
 237     }
 238
 239     public Map<String, String> getURIKeysFromServiceInstance(String serviceInstanceId) {
 240         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId);
 241         return uri.getURIKeys();
 242     }
 243
 244     protected RequestDetails getRequestDetails(String requestId) throws IOException {
 245         if (requestId != null && !requestId.isEmpty()) {
 246             InfraActiveRequests activeRequest = this.getInfraActiveRequest(requestId);
 247             String requestBody = activeRequest.getRequestBody().replaceAll("\\\\", "");
 248             objectMapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);
 249             objectMapper.configure(DeserializationFeature.UNWRAP_ROOT_VALUE, true);
 250             return objectMapper.readValue(requestBody, RequestDetails.class);
 251         } else {
 252             return null;
 253         }
 254     }
 255
 256     protected InfraActiveRequests getInfraActiveRequest(String requestId) {
 257         if (requestId != null && !requestId.isEmpty()) {
 258             return requestsDbClient.getInfraActiveRequestbyRequestId(requestId);
 259         } else {
 260             return null;
 261         }
 262     }
 263
 264     protected CloudRegion getCloudRegion(CloudConfiguration cloudConfiguration) {
 265         if (cloudConfiguration != null) {
 266             String cloudRegionId = cloudConfiguration.getLcpCloudRegionId();
 267             String cloudOwner = cloudConfiguration.getCloudOwner();
 268             if (cloudRegionId != null && cloudOwner != null && !cloudRegionId.isEmpty() && !cloudOwner.isEmpty()) {
 269                 return injectionHelper.getAaiClient().get(CloudRegion.class, AAIUriFactory
 270                         .createResourceUri(AAIObjectType.CLOUD_REGION, cloudOwner, cloudRegionId).depth(Depth.TWO))
 271                         .orElse(null);
 272
 273             } else {
 274                 return null;
 275             }
 276         } else {
 277             return null;
 278         }
 279     }
 280
 281     public InstanceGroup getAAIInstanceGroup(String instanceGroupId) {
 282         return injectionHelper.getAaiClient().get(InstanceGroup.class,
 283                 AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroupId)).orElse(null);
 284     }
 285
 286     public org.onap.aai.domain.yang.Customer getAAICustomer(String globalSubscriberId) {
 287         return injectionHelper.getAaiClient().get(org.onap.aai.domain.yang.Customer.class,
 288                 AAIUriFactory.createResourceUri(AAIObjectType.CUSTOMER, globalSubscriberId)).orElse(null);
 289     }
 290
 291     public ServiceSubscription getAAIServiceSubscription(String globalSubscriberId, String subscriptionServiceType) {
 292
 293         if (globalSubscriberId == null || globalSubscriberId.equals("") || subscriptionServiceType == null
 294                 || subscriptionServiceType.equals("")) {
 295             return null;
 296         } else {
 297             return injectionHelper.getAaiClient().get(ServiceSubscription.class, AAIUriFactory
 298                     .createResourceUri(AAIObjectType.SERVICE_SUBSCRIPTION, globalSubscriberId, subscriptionServiceType))
 299                     .orElse(null);
 300         }
 301
 302     }
 303
 304     public ServiceInstance getAAIServiceInstanceById(String serviceInstanceId) {
 305         return injectionHelper.getAaiClient()
 306                 .get(ServiceInstance.class, AAIUriFactory
 307                         .createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId).depth(Depth.TWO))
 308                 .orElse(null);
 309     }
 310
 311     protected ServiceInstance getAAIServiceInstanceByIdAndCustomer(String globalCustomerId, String serviceType,
 312             String serviceInstanceId) {
 313         return injectionHelper.getAaiClient().get(ServiceInstance.class, AAIUriFactory
 314                 .createResourceUri(AAIObjectType.SERVICE_INSTANCE, globalCustomerId, serviceType, serviceInstanceId)
 315                 .depth(Depth.TWO)).orElse(null);
 316     }
 317
 318     public org.onap.aai.domain.yang.ServiceInstance getAAIServiceInstanceByName(String serviceInstanceName,
 319             Customer customer) throws Exception {
 320         Optional<org.onap.aai.domain.yang.ServiceInstance> aaiServiceInstance =
 321                 injectionHelper.getAaiClient()
 322                         .getOne(ServiceInstances.class, org.onap.aai.domain.yang.ServiceInstance.class, AAIUriFactory
 323                                 .createResourceUri(AAIObjectPlurals.SERVICE_INSTANCE, customer.getGlobalCustomerId(),
 324                                         customer.getServiceSubscription().getServiceType())
 325                                 .queryParam("service-instance-name", serviceInstanceName).depth(Depth.TWO));
 326
 327         return aaiServiceInstance.orElse(null);
 328     }
 329
 330     public Optional<ServiceInstance> getAAIServiceInstanceByName(String globalCustomerId, String serviceType,
 331             String serviceInstanceName) {
 332
 333         return injectionHelper.getAaiClient().getOne(ServiceInstances.class, ServiceInstance.class,
 334                 AAIUriFactory.createResourceUri(AAIObjectPlurals.SERVICE_INSTANCE, globalCustomerId, serviceType)
 335                         .queryParam("service-instance-name", serviceInstanceName).depth(Depth.TWO));
 336     }
 337
 338     public org.onap.so.db.catalog.beans.InstanceGroup getCatalogInstanceGroup(String modelUUID) {
 339         return this.catalogDbClient.getInstanceGroupByModelUUID(modelUUID);
 340     }
 341
 342     public List<CollectionResourceInstanceGroupCustomization> getCollectionResourceInstanceGroupCustomization(
 343             String modelCustomizationUUID) {
 344         return this.catalogDbClient
 345                 .getCollectionResourceInstanceGroupCustomizationByModelCustUUID(modelCustomizationUUID);
 346     }
 347
 348     public AAIResultWrapper getAAIResourceDepthOne(AAIResourceUri aaiResourceUri) {
 349         AAIResourceUri clonedUri = aaiResourceUri.clone();
 350         return this.injectionHelper.getAaiClient().get(clonedUri.depth(Depth.ONE));
 351     }
 352
 353     public AAIResultWrapper getAAIResourceDepthTwo(AAIResourceUri aaiResourceUri) {
 354         AAIResourceUri clonedUri = aaiResourceUri.clone();
 355         return this.injectionHelper.getAaiClient().get(clonedUri.depth(Depth.TWO));
 356     }
 357
 358     public Configuration getAAIConfiguration(String configurationId) {
 359         return this.getConcreteAAIResource(Configuration.class, AAIObjectType.CONFIGURATION, configurationId);
 360     }
 361
 362     public GenericVnf getAAIGenericVnf(String vnfId) {
 363         return getConcreteAAIResource(GenericVnf.class, AAIObjectType.GENERIC_VNF, vnfId);
 364     }
 365
 366     public VpnBinding getAAIVpnBinding(String vpnBindingId) {
 367         return getConcreteAAIResource(VpnBinding.class, AAIObjectType.VPN_BINDING, vpnBindingId);
 368     }
 369
 370     public VolumeGroup getAAIVolumeGroup(String cloudOwnerId, String cloudRegionId, String volumeGroupId) {
 371         return getConcreteAAIResource(VolumeGroup.class, AAIObjectType.VOLUME_GROUP, cloudOwnerId, cloudRegionId,
 372                 volumeGroupId);
 373     }
 374
 375     public VfModule getAAIVfModule(String vnfId, String vfModuleId) {
 376         return getConcreteAAIResource(VfModule.class, AAIObjectType.VF_MODULE, vnfId, vfModuleId);
 377     }
 378
 379     public L3Network getAAIL3Network(String networkId) {
 380         return getConcreteAAIResource(L3Network.class, AAIObjectType.L3_NETWORK, networkId);
 381     }
 382
 383     private <T> T getConcreteAAIResource(Class<T> clazz, AAIObjectType objectType, Object... ids) {
 384         return injectionHelper.getAaiClient()
 385                 .get(clazz, AAIUriFactory.createResourceUri(objectType, ids).depth(Depth.ONE)).orElseGet(() -> {
 386                     logger.debug("No resource of type: {} matched by ids: {}", objectType.typeName(),
 387                             Arrays.toString(ids));
 388                     return null;
 389                 });
 390     }
 391
 392     public Optional<ServiceInstance> getRelatedServiceInstanceFromInstanceGroup(String instanceGroupId)
 393             throws Exception {
 394         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.INSTANCE_GROUP, instanceGroupId)
 395                 .relatedTo(AAIObjectPlurals.SERVICE_INSTANCE);
 396         Optional<ServiceInstances> serviceInstances = injectionHelper.getAaiClient().get(ServiceInstances.class, uri);
 397         ServiceInstance serviceInstance = null;
 398         if (!serviceInstances.isPresent()) {
 399             logger.debug("No ServiceInstances were found");
 400             return Optional.empty();
 401         } else {
 402             if (serviceInstances.get().getServiceInstance().isEmpty()) {
 403                 throw new NoServiceInstanceFoundException("No ServiceInstances Returned");
 404             } else if (serviceInstances.get().getServiceInstance().size() > 1) {
 405                 String message = String.format("Mulitple service instances were found for instance-group-id: %s.",
 406                         instanceGroupId);
 407                 throw new MultipleObjectsFoundException(message);
 408             } else {
 409                 serviceInstance = serviceInstances.get().getServiceInstance().get(0);
 410             }
 411             return Optional.of(serviceInstance);
 412         }
 413     }
 414
 415     public Optional<L3Network> getRelatedNetworkByNameFromServiceInstance(String serviceInstanceId, String networkName)
 416             throws MultipleObjectsFoundException {
 417         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId)
 418                 .relatedTo(AAIObjectPlurals.L3_NETWORK).queryParam("network-name", networkName);
 419         Optional<L3Networks> networks = injectionHelper.getAaiClient().get(L3Networks.class, uri);
 420         L3Network network = null;
 421         if (!networks.isPresent()) {
 422             logger.debug("No Networks matched by name");
 423             return Optional.empty();
 424         } else {
 425             if (networks.get().getL3Network().size() > 1) {
 426                 String message =
 427                         String.format("Multiple networks found for service-instance-id: %s and network-name: %s.",
 428                                 serviceInstanceId, networkName);
 429                 throw new MultipleObjectsFoundException(message);
 430             } else {
 431                 network = networks.get().getL3Network().get(0);
 432             }
 433             return Optional.of(network);
 434         }
 435     }
 436
 437     public Optional<GenericVnf> getRelatedVnfByNameFromServiceInstance(String serviceInstanceId, String vnfName) {
 438         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId)
 439                 .relatedTo(AAIObjectPlurals.GENERIC_VNF).queryParam("vnf-name", vnfName);
 440         return injectionHelper.getAaiClient().getOne(GenericVnfs.class, GenericVnf.class, uri);
 441
 442     }
 443
 444     public Optional<VolumeGroup> getRelatedVolumeGroupByNameFromVnf(String vnfId, String volumeGroupName) {
 445         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId)
 446                 .relatedTo(AAIObjectPlurals.VOLUME_GROUP).queryParam("volume-group-name", volumeGroupName);
 447         return injectionHelper.getAaiClient().getOne(VolumeGroups.class, VolumeGroup.class, uri);
 448     }
 449
 450     public Optional<VolumeGroup> getRelatedVolumeGroupByIdFromVnf(String vnfId, String volumeGroupId) {
 451         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId)
 452                 .relatedTo(AAIObjectPlurals.VOLUME_GROUP).queryParam("volume-group-id", volumeGroupId);
 453         return injectionHelper.getAaiClient().getOne(VolumeGroups.class, VolumeGroup.class, uri);
 454     }
 455
 456     public Optional<VolumeGroup> getRelatedVolumeGroupByNameFromVfModule(String vnfId, String vfModuleId,
 457             String volumeGroupName) throws Exception {
 458         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.VF_MODULE, vnfId, vfModuleId)
 459                 .relatedTo(AAIObjectPlurals.VOLUME_GROUP).queryParam("volume-group-name", volumeGroupName);
 460         return injectionHelper.getAaiClient().getOne(VolumeGroups.class, VolumeGroup.class, uri);
 461     }
 462
 463     public Optional<VolumeGroup> getRelatedVolumeGroupFromVfModule(String vnfId, String vfModuleId) throws Exception {
 464         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.VF_MODULE, vnfId, vfModuleId)
 465                 .relatedTo(AAIObjectPlurals.VOLUME_GROUP);
 466         return injectionHelper.getAaiClient().getOne(VolumeGroups.class, VolumeGroup.class, uri);
 467     }
 468
 469     public Optional<org.onap.aai.domain.yang.VpnBinding> getAICVpnBindingFromNetwork(
 470             org.onap.aai.domain.yang.L3Network aaiLocalNetwork) {
 471         AAIResultWrapper networkWrapper = new AAIResultWrapper(aaiLocalNetwork);
 472         if (networkWrapper.getRelationships().isPresent()
 473                 && !networkWrapper.getRelationships().get().getRelatedUris(AAIObjectType.VPN_BINDING).isEmpty()) {
 474             return getAAIResourceDepthOne(
 475                     networkWrapper.getRelationships().get().getRelatedUris(AAIObjectType.VPN_BINDING).get(0))
 476                             .asBean(org.onap.aai.domain.yang.VpnBinding.class);
 477         }
 478         return Optional.empty();
 479     }
 480
 481     public ServiceInstances getAAIServiceInstancesGloballyByName(String serviceInstanceName) {
 482
 483         return injectionHelper.getAaiClient()
 484                 .get(ServiceInstances.class, AAIUriFactory.createNodesUri(AAIObjectPlurals.SERVICE_INSTANCE)
 485                         .queryParam("service-instance-name", serviceInstanceName))
 486                 .orElseGet(() -> {
 487                     logger.debug("No Service Instance matched by name");
 488                     return null;
 489                 });
 490     }
 491
 492     public boolean existsAAINetworksGloballyByName(String networkName) {
 493
 494         AAIPluralResourceUri l3networkUri =
 495                 AAIUriFactory.createResourceUri(AAIObjectPlurals.L3_NETWORK).queryParam("network-name", networkName);
 496         AAIResourcesClient aaiRC = injectionHelper.getAaiClient();
 497         return aaiRC.exists(l3networkUri);
 498     }
 499
 500     public boolean existsAAIVfModuleGloballyByName(String vfModuleName) {
 501         AAIPluralResourceUri vfModuleUri =
 502                 AAIUriFactory.createNodesUri(AAIObjectPlurals.VF_MODULE).queryParam("vf-module-name", vfModuleName);
 503         return injectionHelper.getAaiClient().exists(vfModuleUri);
 504     }
 505
 506     public boolean existsAAIConfigurationGloballyByName(String configurationName) {
 507         AAIPluralResourceUri configUri = AAIUriFactory.createResourceUri(AAIObjectPlurals.CONFIGURATION)
 508                 .queryParam("configuration-name", configurationName);
 509         return injectionHelper.getAaiClient().exists(configUri);
 510     }
 511
 512     public boolean existsAAIVolumeGroupGloballyByName(String volumeGroupName) {
 513         AAIPluralResourceUri volumeGroupUri = AAIUriFactory.createNodesUri(AAIObjectPlurals.VOLUME_GROUP)
 514                 .queryParam("volume-group-name", volumeGroupName);
 515         return injectionHelper.getAaiClient().exists(volumeGroupUri);
 516     }
 517
 518     public GenericVnfs getAAIVnfsGloballyByName(String vnfName) {
 519
 520         return injectionHelper.getAaiClient()
 521                 .get(GenericVnfs.class,
 522                         AAIUriFactory.createNodesUri(AAIObjectPlurals.GENERIC_VNF).queryParam("vnf-name", vnfName))
 523                 .orElseGet(() -> {
 524                     logger.debug("No GenericVnfs matched by name");
 525                     return null;
 526                 });
 527     }
 528
 529     public Optional<Configuration> getRelatedConfigurationByNameFromServiceInstance(String serviceInstanceId,
 530             String configurationName) {
 531         AAIPluralResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE, serviceInstanceId)
 532                 .relatedTo(AAIObjectPlurals.CONFIGURATION).queryParam("configuration-name", configurationName);
 533         return injectionHelper.getAaiClient().getOne(Configurations.class, Configuration.class, uri);
 534     }
 535 }