adapters/mso-vnfm-adapter/mso-vnfm-etsi-adapter/src/main/java/org/onap/so/adapters/vnfmadapter/extclients/vnfm/VnfmHelper.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.vnfmadapter.extclients.vnfm;
  22
  23 import com.google.common.reflect.TypeToken;
  24 import com.google.gson.Gson;
  25 import com.google.gson.JsonElement;
  26 import com.google.gson.JsonObject;
  27 import java.util.ArrayList;
  28 import java.util.List;
  29 import java.util.Map;
  30 import org.onap.aai.domain.yang.EsrSystemInfo;
  31 import org.onap.so.adapters.vnfmadapter.extclients.aai.AaiServiceProvider;
  32 import org.onap.so.adapters.vnfmadapter.extclients.vim.model.AccessInfo;
  33 import org.onap.so.adapters.vnfmadapter.extclients.vim.model.InterfaceInfo;
  34 import org.onap.so.adapters.vnfmadapter.extclients.vim.model.VimCredentials;
  35 import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InstantiateVnfRequest;
  36 import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks;
  37 import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo;
  38 import org.onap.vnfmadapter.v1.model.CreateVnfRequest;
  39 import org.onap.vnfmadapter.v1.model.ExternalVirtualLink;
  40 import org.onap.vnfmadapter.v1.model.Tenant;
  41 import org.slf4j.Logger;
  42 import org.slf4j.LoggerFactory;
  43 import org.springframework.beans.factory.annotation.Autowired;
  44 import org.springframework.stereotype.Service;
  45
  46 /**
  47  * Provides helper methods for interactions with VNFM.
  48  */
  49 @Service
  50 public class VnfmHelper {
  51
  52     private static final Logger logger = LoggerFactory.getLogger(VnfmHelper.class);
  53     private static final String SEPARATOR = "_";
  54     private final AaiServiceProvider aaiServiceProvider;
  55
  56     @Autowired
  57     public VnfmHelper(final AaiServiceProvider aaiServiceProvider) {
  58         this.aaiServiceProvider = aaiServiceProvider;
  59     }
  60
  61     /**
  62      * Create an {@link InstantiateVnfRequest} to send in an instantiation request to a VNFM.
  63      *
  64      * @param tenant the tenant the request is to be fulfilled on
  65      * @param createVnfRequest the request received by the VNFM adapter
  66      */
  67     public InstantiateVnfRequest createInstantiateRequest(final Tenant tenant,
  68             final CreateVnfRequest createVnfRequest) {
  69         final InstantiateVnfRequest instantiateVnfRequest = new InstantiateVnfRequest();
  70         instantiateVnfRequest.setFlavourId(getFlavourId());
  71         instantiateVnfRequest.setVimConnectionInfo(getVimConnectionInfos(tenant));
  72         instantiateVnfRequest
  73                 .setAdditionalParams(getAdditionalParametersAsJsonObject(createVnfRequest.getAdditionalParams()));
  74         instantiateVnfRequest.setExtVirtualLinks(getExternalVirtualLinks(createVnfRequest.getExternalVirtualLinks()));
  75         createVnfRequest.getExternalVirtualLinks();
  76         return instantiateVnfRequest;
  77     }
  78
  79     private String getFlavourId() {
  80         // TODO read from csar
  81         return "default";
  82     }
  83
  84     private List<VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo> getVimConnectionInfos(final Tenant tenant) {
  85         final List<VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo> connectionInfos = new ArrayList<>();
  86         connectionInfos.add(getVimConnectionInfo(tenant));
  87         return connectionInfos;
  88     }
  89
  90     private VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo getVimConnectionInfo(final Tenant tenant) {
  91         final EsrSystemInfo esrSystemInfo =
  92                 aaiServiceProvider.invokeGetCloudRegionEsrSystemInfoList(tenant.getCloudOwner(), tenant.getRegionName())
  93                         .getEsrSystemInfo().iterator().next();
  94
  95         final VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo vnfInstancesVimConnectionInfo =
  96                 new VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo();
  97         final String vimId = createVimId(tenant.getCloudOwner(), tenant.getRegionName());
  98         vnfInstancesVimConnectionInfo.setId(vimId);
  99         vnfInstancesVimConnectionInfo.setVimId(vimId);
 100         vnfInstancesVimConnectionInfo.setVimType(esrSystemInfo.getType());
 101         vnfInstancesVimConnectionInfo.setInterfaceInfo(getInterfaceInfo(esrSystemInfo.getServiceUrl()));
 102         vnfInstancesVimConnectionInfo.setAccessInfo(getAccessInfo(esrSystemInfo, tenant.getTenantId()));
 103         return vnfInstancesVimConnectionInfo;
 104     }
 105
 106     private InterfaceInfo getInterfaceInfo(final String url) {
 107         final InterfaceInfo interfaceInfo = new InterfaceInfo();
 108         interfaceInfo.setIdentityEndPoint(url);
 109         return interfaceInfo;
 110     }
 111
 112     private AccessInfo getAccessInfo(final EsrSystemInfo esrSystemInfo, final String tenantId) {
 113         final AccessInfo accessInfo = new AccessInfo();
 114         accessInfo.setProjectId(tenantId);
 115         accessInfo.setDomainName(esrSystemInfo.getCloudDomain());
 116
 117         final VimCredentials vimCredentials = new VimCredentials();
 118         vimCredentials.setUsername(esrSystemInfo.getUserName());
 119         vimCredentials.setPassword(esrSystemInfo.getPassword());
 120         accessInfo.setCredentials(vimCredentials);
 121         return accessInfo;
 122     }
 123
 124     private String createVimId(final String cloudOwner, final String cloudRegion) {
 125         return cloudOwner + SEPARATOR + cloudRegion;
 126     }
 127
 128     private JsonObject getAdditionalParametersAsJsonObject(final Map<String, String> additionalParameters) {
 129         final JsonObject additionalParametersJsonObject = new JsonObject();
 130         if (additionalParameters != null) {
 131             for (final Map.Entry<String, JsonElement> item : new Gson().toJsonTree(additionalParameters)
 132                     .getAsJsonObject().entrySet()) {
 133                 additionalParametersJsonObject.add(item.getKey(), item.getValue());
 134             }
 135         } else {
 136             logger.warn("No additional parameters were specified for the operation");
 137         }
 138         return additionalParametersJsonObject;
 139     }
 140
 141     private List<VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks> getExternalVirtualLinks(
 142             final List<ExternalVirtualLink> extVirtualLinks) {
 143         if (extVirtualLinks != null) {
 144             final String extVirtualLinksJsonObject =
 145                     new Gson().toJson(extVirtualLinks, new TypeToken<List<ExternalVirtualLink>>() {}.getType());
 146             return new Gson().fromJson(extVirtualLinksJsonObject,
 147                     new TypeToken<List<VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks>>() {}.getType());
 148         }
 149         return null;
 150     }
 151
 152 }