bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/orchestration/AAIVnfResources.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.client.orchestration;
  24
  25 import java.util.Optional;
  26
  27 import org.onap.so.bpmn.common.InjectionHelper;
  28 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
  29 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
  30 import org.onap.so.bpmn.servicedecomposition.bbobjects.LineOfBusiness;
  31 import org.onap.so.bpmn.servicedecomposition.bbobjects.Platform;
  32 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
  33 import org.onap.so.client.aai.AAIObjectType;
  34 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  35 import org.onap.so.client.aai.entities.uri.AAIUriFactory;
  36 import org.onap.so.client.aai.mapper.AAIObjectMapper;
  37 import org.onap.so.db.catalog.beans.OrchestrationStatus;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40 import org.springframework.beans.factory.annotation.Autowired;
  41 import org.springframework.stereotype.Component;
  42
  43 @Component
  44 public class AAIVnfResources {
  45         private static final Logger logger = LoggerFactory.getLogger(AAIVnfResources.class);
  46
  47         @Autowired
  48         private InjectionHelper injectionHelper;
  49
  50         @Autowired
  51         private AAIObjectMapper aaiObjectMapper;
  52
  53         public void createVnfandConnectServiceInstance(GenericVnf vnf, ServiceInstance serviceInstance) {
  54                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  55                 vnf.setOrchestrationStatus(OrchestrationStatus.INVENTORIED);
  56                 AAIResourceUri serviceInstanceURI = AAIUriFactory.createResourceUri(AAIObjectType.SERVICE_INSTANCE,
  57                                 serviceInstance.getServiceInstanceId());
  58                 injectionHelper.getAaiClient().createIfNotExists(vnfURI, Optional.of(aaiObjectMapper.mapVnf(vnf))).connect(vnfURI, serviceInstanceURI);
  59         }
  60
  61         public void createPlatformandConnectVnf(Platform platform, GenericVnf vnf) {
  62                 AAIResourceUri platformURI = AAIUriFactory.createResourceUri(AAIObjectType.PLATFORM, platform.getPlatformName());
  63                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  64                 injectionHelper.getAaiClient().createIfNotExists(platformURI, Optional.of(platform)).connect(vnfURI, platformURI);
  65         }
  66
  67         public void createLineOfBusinessandConnectVnf(LineOfBusiness lineOfBusiness, GenericVnf vnf) {
  68                 AAIResourceUri lineOfBusinessURI = AAIUriFactory.createResourceUri(AAIObjectType.LINE_OF_BUSINESS, lineOfBusiness.getLineOfBusinessName());
  69                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  70                 injectionHelper.getAaiClient().createIfNotExists(lineOfBusinessURI, Optional.of(lineOfBusiness)).connect(vnfURI, lineOfBusinessURI);
  71         }
  72
  73         public void deleteVnf(GenericVnf vnf) {
  74                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  75                 injectionHelper.getAaiClient().delete(vnfURI);
  76         }
  77
  78         public void updateOrchestrationStatusVnf(GenericVnf vnf, OrchestrationStatus orchestrationStatus) {
  79                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  80
  81                 GenericVnf copiedVnf = vnf.shallowCopyId();
  82
  83                 vnf.setOrchestrationStatus(orchestrationStatus);
  84                 copiedVnf.setOrchestrationStatus(orchestrationStatus);
  85                 injectionHelper.getAaiClient().update(vnfURI, aaiObjectMapper.mapVnf(copiedVnf));
  86         }
  87
  88         public void updateObjectVnf(GenericVnf vnf) {
  89                 AAIResourceUri vnfUri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
  90                 injectionHelper.getAaiClient().update(vnfUri, aaiObjectMapper.mapVnf(vnf));
  91         }
  92
  93         /**
  94          * Retrieve Generic VNF from AAI using vnf Id
  95          * @param vnfId - vnf-id required vnf
  96          * @return AAI Generic Vnf
  97          */
  98         public Optional<org.onap.aai.domain.yang.GenericVnf> getGenericVnf( String vnfId) {
  99                 return injectionHelper.getAaiClient()
 100                                 .get(org.onap.aai.domain.yang.GenericVnf.class, AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId));
 101         }
 102
 103         /**
 104          * Check inMaint flag value of Generic VNF from AAI using vnf Id
 105          * @param vnfId - vnf-id required vnf
 106          * @return inMaint flag value
 107          */
 108         public boolean checkInMaintFlag(String vnfId) {
 109                 org.onap.aai.domain.yang.GenericVnf vnf = injectionHelper.getAaiClient()
 110                                 .get(org.onap.aai.domain.yang.GenericVnf.class, AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId))
 111                                 .orElse(new org.onap.aai.domain.yang.GenericVnf());
 112                 return vnf.isInMaint();
 113         }
 114
 115         public void connectVnfToCloudRegion(GenericVnf vnf, CloudRegion cloudRegion) {
 116                 AAIResourceUri cloudRegionURI = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION,
 117                                 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId());
 118                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
 119                 injectionHelper.getAaiClient().connect(vnfURI,cloudRegionURI);
 120         }
 121
 122         public void connectVnfToTenant(GenericVnf vnf, CloudRegion cloudRegion) {
 123                 AAIResourceUri tenantURI = AAIUriFactory.createResourceUri(AAIObjectType.TENANT,
 124                                 cloudRegion.getCloudOwner(), cloudRegion.getLcpCloudRegionId(), cloudRegion.getTenantId());
 125                 AAIResourceUri vnfURI = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnf.getVnfId());
 126                 injectionHelper.getAaiClient().connect(tenantURI, vnfURI);
 127         }
 128 }