+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2019 Nordix Foundation.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.so.adapters.vnfmadapter.extclients.vnfm;
+
+import com.google.common.reflect.TypeToken;
+import com.google.gson.Gson;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import org.onap.aai.domain.yang.EsrSystemInfo;
+import org.onap.so.adapters.vnfmadapter.extclients.aai.AaiServiceProvider;
+import org.onap.so.adapters.vnfmadapter.extclients.vim.model.AccessInfo;
+import org.onap.so.adapters.vnfmadapter.extclients.vim.model.InterfaceInfo;
+import org.onap.so.adapters.vnfmadapter.extclients.vim.model.VimCredentials;
+import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InstantiateVnfRequest;
+import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks;
+import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo;
+import org.onap.vnfmadapter.v1.model.CreateVnfRequest;
+import org.onap.vnfmadapter.v1.model.ExternalVirtualLink;
+import org.onap.vnfmadapter.v1.model.Tenant;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * Provides helper methods for interactions with VNFM.
+ */
+@Service
+public class VnfmHelper {
+
+ private static final Logger logger = LoggerFactory.getLogger(VnfmHelper.class);
+ private static final String SEPARATOR = "_";
+ private final AaiServiceProvider aaiServiceProvider;
+
+ @Autowired
+ public VnfmHelper(final AaiServiceProvider aaiServiceProvider) {
+ this.aaiServiceProvider = aaiServiceProvider;
+ }
+
+ /**
+ * Create an {@link InstantiateVnfRequest} to send in an instantiation request to a VNFM.
+ *
+ * @param tenant the tenant the request is to be fulfilled on
+ * @param createVnfRequest the request received by the VNFM adapter
+ */
+ public InstantiateVnfRequest createInstantiateRequest(final Tenant tenant,
+ final CreateVnfRequest createVnfRequest) {
+ final InstantiateVnfRequest instantiateVnfRequest = new InstantiateVnfRequest();
+ instantiateVnfRequest.setFlavourId(getFlavourId());
+ instantiateVnfRequest.setVimConnectionInfo(getVimConnectionInfos(tenant));
+ instantiateVnfRequest
+ .setAdditionalParams(getAdditionalParametersAsJsonObject(createVnfRequest.getAdditionalParams()));
+ instantiateVnfRequest.setExtVirtualLinks(getExternalVirtualLinks(createVnfRequest.getExternalVirtualLinks()));
+ createVnfRequest.getExternalVirtualLinks();
+ return instantiateVnfRequest;
+ }
+
+ private String getFlavourId() {
+ // TODO read from csar
+ return "default";
+ }
+
+ private List<VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo> getVimConnectionInfos(final Tenant tenant) {
+ final List<VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo> connectionInfos = new ArrayList<>();
+ connectionInfos.add(getVimConnectionInfo(tenant));
+ return connectionInfos;
+ }
+
+ private VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo getVimConnectionInfo(final Tenant tenant) {
+ final EsrSystemInfo esrSystemInfo =
+ aaiServiceProvider.invokeGetCloudRegionEsrSystemInfoList(tenant.getCloudOwner(), tenant.getRegionName())
+ .getEsrSystemInfo().iterator().next();
+
+ final VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo vnfInstancesVimConnectionInfo =
+ new VnfInstancesvnfInstanceIdinstantiateVimConnectionInfo();
+ final String vimId = createVimId(tenant.getCloudOwner(), tenant.getRegionName());
+ vnfInstancesVimConnectionInfo.setId(vimId);
+ vnfInstancesVimConnectionInfo.setVimId(vimId);
+ vnfInstancesVimConnectionInfo.setVimType(esrSystemInfo.getType());
+ vnfInstancesVimConnectionInfo.setInterfaceInfo(getInterfaceInfo(esrSystemInfo.getServiceUrl()));
+ vnfInstancesVimConnectionInfo.setAccessInfo(getAccessInfo(esrSystemInfo, tenant.getTenantId()));
+ return vnfInstancesVimConnectionInfo;
+ }
+
+ private InterfaceInfo getInterfaceInfo(final String url) {
+ final InterfaceInfo interfaceInfo = new InterfaceInfo();
+ interfaceInfo.setIdentityEndPoint(url);
+ return interfaceInfo;
+ }
+
+ private AccessInfo getAccessInfo(final EsrSystemInfo esrSystemInfo, final String tenantId) {
+ final AccessInfo accessInfo = new AccessInfo();
+ accessInfo.setProjectId(tenantId);
+ accessInfo.setDomainName(esrSystemInfo.getCloudDomain());
+
+ final VimCredentials vimCredentials = new VimCredentials();
+ vimCredentials.setUsername(esrSystemInfo.getUserName());
+ vimCredentials.setPassword(esrSystemInfo.getPassword());
+ accessInfo.setCredentials(vimCredentials);
+ return accessInfo;
+ }
+
+ private String createVimId(final String cloudOwner, final String cloudRegion) {
+ return cloudOwner + SEPARATOR + cloudRegion;
+ }
+
+ private JsonObject getAdditionalParametersAsJsonObject(final Map<String, String> additionalParameters) {
+ final JsonObject additionalParametersJsonObject = new JsonObject();
+ if (additionalParameters != null) {
+ for (final Map.Entry<String, JsonElement> item : new Gson().toJsonTree(additionalParameters)
+ .getAsJsonObject().entrySet()) {
+ additionalParametersJsonObject.add(item.getKey(), item.getValue());
+ }
+ } else {
+ logger.warn("No additional parameters were specified for the operation");
+ }
+ return additionalParametersJsonObject;
+ }
+
+ private List<VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks> getExternalVirtualLinks(
+ final List<ExternalVirtualLink> extVirtualLinks) {
+ if (extVirtualLinks != null) {
+ final String extVirtualLinksJsonObject =
+ new Gson().toJson(extVirtualLinks, new TypeToken<List<ExternalVirtualLink>>() {}.getType());
+ return new Gson().fromJson(extVirtualLinksJsonObject,
+ new TypeToken<List<VnfInstancesvnfInstanceIdinstantiateExtVirtualLinks>>() {}.getType());
+ }
+ return null;
+ }
+
+}