/*- * ============LICENSE_START======================================================= * ONAP - SO * ================================================================================ * Copyright (C) 2019 Bell Canada * ================================================================================ * 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. * ============LICENSE_END========================================================= */ package org.onap.so.client.cds; import static org.onap.so.client.cds.ConfigureInstanceParamsUtil.applyParamsToObject; import org.apache.commons.lang3.StringUtils; import com.google.gson.JsonObject; import org.onap.so.client.exception.PayloadGenerationException; import org.onap.so.serviceinstancebeans.Service; import org.onap.so.serviceinstancebeans.Vnfs; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.List; import java.util.Map; import java.util.Optional; @Component public class ConfigureInstanceParamsForVnf { @Autowired private ExtractServiceFromUserParameters extractServiceFromUserParameters; /** * Read instance parameters for VNF and put into JsonObject. * * @param jsonObject - JsonObject which will hold the payload to send to CDS. * @param userParamsFromRequest - User parameters. * @param modelCustomizationUuid - Unique ID for Vnf. * @throws PayloadGenerationException if it doesn't able to populate instance parameters from SO payload. */ public void populateInstanceParams(JsonObject jsonObject, List> userParamsFromRequest, String modelCustomizationUuid, String vnfInstanceName) throws PayloadGenerationException { try { Optional service = extractServiceFromUserParameters.getServiceFromRequestUserParams(userParamsFromRequest); if (service.isPresent()) { List> instanceParamsList; if (StringUtils.isNotBlank(vnfInstanceName)) { instanceParamsList = getInstanceParamByVnfInstanceName(service.get(), vnfInstanceName); } else { instanceParamsList = getInstanceParamForVnf(service.get(), modelCustomizationUuid); } applyParamsToObject(instanceParamsList, jsonObject); } } catch (Exception e) { throw new PayloadGenerationException("Failed to resolve instance parameters", e); } } private List> getInstanceParamByVnfInstanceName(Service service, String instanceName) throws PayloadGenerationException { return service.getResources().getVnfs().stream().filter(vnf -> instanceName.equals(vnf.getInstanceName())) .findFirst().map(Vnfs::getInstanceParams).orElseThrow( () -> new PayloadGenerationException("Could not find vnf with instanceName: " + instanceName)); } private List> getInstanceParamForVnf(Service service, String genericVnfModelCustomizationUuid) throws PayloadGenerationException { Optional foundedVnf = service.getResources().getVnfs().stream() .filter(vnfs -> vnfs.getModelInfo().getModelCustomizationId().equals(genericVnfModelCustomizationUuid)) .findFirst(); if (foundedVnf.isPresent()) { return foundedVnf.get().getInstanceParams(); } else { throw new PayloadGenerationException(String.format( "Can not find vnf for genericVnfModelCustomizationUuid: %s", genericVnfModelCustomizationUuid)); } } }