adapters/etsi-sol003-adapter/etsi-sol003-lcm/etsi-sol003-lcm-adapter/src/main/java/org/onap/so/adapters/etsisol003adapter/lcm/extclients/aai/AaiServiceProviderImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.so.adapters.etsisol003adapter.lcm.extclients.aai;
  22
  23 import org.onap.aai.domain.yang.EsrSystemInfoList;
  24 import org.onap.aai.domain.yang.EsrVnfm;
  25 import org.onap.aai.domain.yang.EsrVnfmList;
  26 import org.onap.aai.domain.yang.GenericVnf;
  27 import org.onap.aai.domain.yang.GenericVnfs;
  28 import org.onap.aai.domain.yang.Vserver;
  29 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory;
  30 import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder;
  31 import org.onap.aaiclient.client.graphinventory.entities.uri.Depth;
  32 import org.onap.so.adapters.etsisol003adapter.lcm.v1.model.Tenant;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35 import org.springframework.beans.factory.annotation.Autowired;
  36 import org.springframework.stereotype.Service;
  37
  38 @Service
  39 public class AaiServiceProviderImpl implements AaiServiceProvider {
  40
  41     private static final Logger logger = LoggerFactory.getLogger(AaiServiceProviderImpl.class);
  42     private final AaiClientProvider aaiClientProvider;
  43
  44     @Autowired
  45     public AaiServiceProviderImpl(final AaiClientProvider aaiClientProvider) {
  46         this.aaiClientProvider = aaiClientProvider;
  47     }
  48
  49     @Override
  50     public GenericVnf invokeGetGenericVnf(final String vnfId) {
  51         return aaiClientProvider.getAaiClient()
  52                 .get(GenericVnf.class,
  53                         AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().genericVnf(vnfId)))
  54                 .orElseGet(() -> {
  55                     logger.debug("No vnf found in AAI with ID: {}", vnfId);
  56                     return null;
  57                 });
  58     }
  59
  60     @Override
  61     public GenericVnfs invokeQueryGenericVnf(final String selfLink) {
  62         return aaiClientProvider.getAaiClient().get(GenericVnfs.class, AAIUriFactory
  63                 .createResourceUri(AAIFluentTypeBuilder.network().genericVnfs()).queryParam("selflink", selfLink))
  64                 .orElseGet(() -> {
  65                     logger.debug("No vnf found in AAI with selflink: {}", selfLink);
  66                     return null;
  67                 });
  68     }
  69
  70     @Override
  71     public EsrVnfmList invokeGetVnfms() {
  72         return aaiClientProvider.getAaiClient()
  73                 .get(EsrVnfmList.class,
  74                         AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.externalSystem().esrVnfmList()))
  75                 .orElseGet(() -> {
  76                     logger.debug("No VNFMs in AAI");
  77                     return null;
  78                 });
  79     }
  80
  81     @Override
  82     public EsrVnfm invokeGetVnfm(final String vnfmId) {
  83         return aaiClientProvider.getAaiClient()
  84                 .get(EsrVnfm.class, AAIUriFactory
  85                         .createResourceUri(AAIFluentTypeBuilder.externalSystem().esrVnfm(vnfmId)).depth(Depth.ONE))
  86                 .orElseGet(() -> {
  87                     logger.debug("VNFM not found in AAI");
  88                     return null;
  89                 });
  90     }
  91
  92     @Override
  93     public EsrSystemInfoList invokeGetVnfmEsrSystemInfoList(final String vnfmId) {
  94         return aaiClientProvider.getAaiClient()
  95                 .get(EsrSystemInfoList.class,
  96                         AAIUriFactory.createResourceUri(
  97                                 AAIFluentTypeBuilder.externalSystem().esrVnfm(vnfmId).esrSystemInfoList()))
  98                 .orElseGet(() -> {
  99                     logger.debug("VNFM ESR system info list not found in AAI");
 100                     return null;
 101                 });
 102     }
 103
 104     @Override
 105     public void invokePatchGenericVnf(final GenericVnf vnf) {
 106         aaiClientProvider.getAaiClient().update(
 107                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().genericVnf(vnf.getVnfId())), vnf);
 108     }
 109
 110     @Override
 111     public void invokePutGenericVnfToVnfmRelationship(final GenericVnf vnf, final String vnfmId) {
 112         aaiClientProvider.getAaiClient().connect(
 113                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.externalSystem().esrVnfm(vnfmId)),
 114                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().genericVnf(vnf.getVnfId())));
 115     }
 116
 117     @Override
 118     public void invokePutVserver(final String cloudOwner, final String cloudRegion, final String tenant,
 119             final Vserver vserver) {
 120         aaiClientProvider
 121                 .getAaiClient().create(
 122                         AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure()
 123                                 .cloudRegion(cloudOwner, cloudRegion).tenant(tenant).vserver(vserver.getVserverId())),
 124                         vserver);
 125     }
 126
 127     @Override
 128     public void invokePutVserverToVnfRelationship(final String cloudOwner, final String cloudRegion,
 129             final String tenant, final Vserver vserver, final String vnfId) {
 130         aaiClientProvider.getAaiClient().connect(
 131                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure()
 132                         .cloudRegion(cloudOwner, cloudRegion).tenant(tenant).vserver(vserver.getVserverId())),
 133                 AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().genericVnf(vnfId)));
 134     }
 135
 136     @Override
 137     public void invokeDeleteVserver(final String cloudOwner, final String cloudRegion, final String tenant,
 138             final String vserverId) {
 139         aaiClientProvider.getAaiClient().delete(AAIUriFactory.createResourceUri(AAIFluentTypeBuilder
 140                 .cloudInfrastructure().cloudRegion(cloudOwner, cloudRegion).tenant(tenant).vserver(vserverId)));
 141     }
 142
 143     @Override
 144     public Tenant invokeGetTenant(final String cloudOwner, final String cloudRegion, final String tenantId) {
 145         return aaiClientProvider.getAaiClient().get(Tenant.class, AAIUriFactory.createResourceUri(
 146                 AAIFluentTypeBuilder.cloudInfrastructure().cloudRegion(cloudOwner, cloudRegion).tenant(tenantId)))
 147                 .orElseGet(() -> {
 148                     logger.debug("Tenant not found in AAI");
 149                     return null;
 150                 });
 151     }
 152
 153     @Override
 154     public EsrSystemInfoList invokeGetCloudRegionEsrSystemInfoList(final String cloudOwner, final String cloudRegion) {
 155         return aaiClientProvider
 156                 .getAaiClient().get(EsrSystemInfoList.class, AAIUriFactory.createResourceUri(AAIFluentTypeBuilder
 157                         .cloudInfrastructure().cloudRegion(cloudOwner, cloudRegion).esrSystemInfoList()))
 158                 .orElseGet(() -> {
 159                     logger.debug("Cloud esr system info list not found in AAI");
 160                     return null;
 161                 });
 162     }
 163
 164 }