X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=cps-ncmp-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fcps%2Fncmp%2Fapi%2Fimpl%2Foperations%2FDmiModelOperations.java;h=3a281d740b5b85de0549d985ebe82c0217c81af8;hb=HEAD;hp=32b5cb7304b8290113a88b82bc8e11c426ff2acf;hpb=7bacf478fc69fb97d2abf29c4678552f58575b74;p=cps.git diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/operations/DmiModelOperations.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/operations/DmiModelOperations.java deleted file mode 100644 index 32b5cb730..000000000 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/operations/DmiModelOperations.java +++ /dev/null @@ -1,176 +0,0 @@ -/* - * ============LICENSE_START======================================================= - * Copyright (C) 2021-2023 Nordix Foundation - * Modifications Copyright (C) 2022 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. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.cps.ncmp.api.impl.operations; - -import static org.onap.cps.ncmp.api.impl.operations.RequiredDmiService.MODEL; - -import com.google.gson.JsonArray; -import com.google.gson.JsonObject; -import java.util.ArrayList; -import java.util.Collection; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import org.onap.cps.ncmp.api.impl.client.DmiRestClient; -import org.onap.cps.ncmp.api.impl.config.NcmpConfiguration; -import org.onap.cps.ncmp.api.impl.inventory.InventoryPersistence; -import org.onap.cps.ncmp.api.impl.utils.DmiServiceUrlBuilder; -import org.onap.cps.ncmp.api.impl.yangmodels.YangModelCmHandle; -import org.onap.cps.ncmp.api.models.YangResource; -import org.onap.cps.spi.model.ModuleReference; -import org.onap.cps.utils.JsonObjectMapper; -import org.springframework.http.ResponseEntity; -import org.springframework.stereotype.Component; - -/** - * Operations class for DMI Model. - */ -@Component -public class DmiModelOperations extends DmiOperations { - - /** - * Constructor for {@code DmiOperations}. This method also manipulates url properties. - * - * @param dmiRestClient {@code DmiRestClient} - */ - public DmiModelOperations(final InventoryPersistence inventoryPersistence, - final JsonObjectMapper jsonObjectMapper, - final NcmpConfiguration.DmiProperties dmiProperties, - final DmiRestClient dmiRestClient, final DmiServiceUrlBuilder dmiServiceUrlBuilder) { - super(inventoryPersistence, jsonObjectMapper, dmiProperties, dmiRestClient, dmiServiceUrlBuilder); - } - - /** - * Retrieves module references. - * - * @param yangModelCmHandle the yang model cm handle - * @return module references - */ - public List getModuleReferences(final YangModelCmHandle yangModelCmHandle) { - final DmiRequestBody dmiRequestBody = DmiRequestBody.builder().build(); - dmiRequestBody.asDmiProperties(yangModelCmHandle.getDmiProperties()); - final ResponseEntity dmiFetchModulesResponseEntity = getResourceFromDmiWithJsonData( - yangModelCmHandle.resolveDmiServiceName(MODEL), - jsonObjectMapper.asJsonString(dmiRequestBody), yangModelCmHandle.getId(), "modules"); - return toModuleReferences((Map) dmiFetchModulesResponseEntity.getBody()); - } - - /** - * Retrieve yang resources from dmi for any modules that CPS-NCMP hasn't cached before. - * - * @param yangModelCmHandle the yangModelCmHandle - * @param newModuleReferences the unknown module references - * @return yang resources as map of module name to yang(re)source - */ - public Map getNewYangResourcesFromDmi(final YangModelCmHandle yangModelCmHandle, - final Collection newModuleReferences) { - final String jsonWithDataAndDmiProperties = getRequestBodyToFetchYangResources( - newModuleReferences, yangModelCmHandle.getDmiProperties()); - final ResponseEntity responseEntity = getResourceFromDmiWithJsonData( - yangModelCmHandle.resolveDmiServiceName(MODEL), - jsonWithDataAndDmiProperties, - yangModelCmHandle.getId(), - "moduleResources"); - return asModuleNameToYangResourceMap(responseEntity); - } - - /** - * Get resources from DMI for modules. - * - * @param dmiServiceName dmi service name - * @param jsonRequestBody module names and revisions as JSON - * @param cmHandle cmHandle - * @param resourceName name of the resource(s) - * @return {@code ResponseEntity} response entity - */ - private ResponseEntity getResourceFromDmiWithJsonData(final String dmiServiceName, - final String jsonRequestBody, - final String cmHandle, - final String resourceName) { - final String dmiResourceDataUrl = getDmiResourceUrl(dmiServiceName, cmHandle, resourceName); - return dmiRestClient.postOperationWithJsonData(dmiResourceDataUrl, jsonRequestBody, - OperationType.READ); - } - - private static String getRequestBodyToFetchYangResources(final Collection newModuleReferences, - final List dmiProperties) { - final JsonArray moduleReferencesAsJson = getModuleReferencesAsJson(newModuleReferences); - final JsonObject data = new JsonObject(); - data.add("modules", moduleReferencesAsJson); - final JsonObject jsonRequestObject = new JsonObject(); - jsonRequestObject.add("data", data); - jsonRequestObject.add("cmHandleProperties", toJsonObject(dmiProperties)); - return jsonRequestObject.toString(); - } - - private static JsonArray getModuleReferencesAsJson(final Collection unknownModuleReferences) { - final JsonArray moduleReferences = new JsonArray(); - - for (final ModuleReference moduleReference : unknownModuleReferences) { - final JsonObject moduleReferenceAsJson = new JsonObject(); - moduleReferenceAsJson.addProperty("name", moduleReference.getModuleName()); - moduleReferenceAsJson.addProperty("revision", moduleReference.getRevision()); - moduleReferences.add(moduleReferenceAsJson); - } - return moduleReferences; - } - - private static JsonObject toJsonObject(final List - dmiProperties) { - final JsonObject asJsonObject = new JsonObject(); - for (final YangModelCmHandle.Property additionalProperty : dmiProperties) { - asJsonObject.addProperty(additionalProperty.getName(), additionalProperty.getValue()); - } - return asJsonObject; - } - - private List toModuleReferences(final Map dmiFetchModulesResponseAsMap) { - final List moduleReferences = new ArrayList<>(); - - if (dmiFetchModulesResponseAsMap != null) { - final List moduleReferencesAsList = (List) dmiFetchModulesResponseAsMap.get("schemas"); - if (moduleReferencesAsList != null) { - moduleReferencesAsList.forEach(moduleReferenceAsMap -> { - final ModuleReference moduleReference = - jsonObjectMapper.convertToValueType(moduleReferenceAsMap, ModuleReference.class); - moduleReferences.add(moduleReference); - }); - } - } - return moduleReferences; - } - - private Map asModuleNameToYangResourceMap(final ResponseEntity responseEntity) { - final Map yangResourcesModuleNameToContentMap = new HashMap<>(); - final List> yangResourcesAsList = (List) responseEntity.getBody(); - - if (yangResourcesAsList != null) { - yangResourcesAsList.forEach(yangResourceAsMap -> { - final YangResource yangResource = - jsonObjectMapper.convertToValueType(yangResourceAsMap, YangResource.class); - yangResourcesModuleNameToContentMap.put(yangResource.getModuleName(), - yangResource.getYangSource()); - }); - } - return yangResourcesModuleNameToContentMap; - } -}