diff options
author | ToineSiebelink <toine.siebelink@est.tech> | 2021-12-02 13:53:24 +0000 |
---|---|---|
committer | ToineSiebelink <toine.siebelink@est.tech> | 2021-12-03 10:14:54 +0000 |
commit | c60d8590ffe123dce9f6b455fa615573ee75b767 (patch) | |
tree | 3c72c3a4a83fa88d2e2acf32cddf71c15245581a /src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java | |
parent | c24a6781eea0729f97cb7b593114b43c0ecef96e (diff) |
Fix conversion to string for result from YangResource request on SDN-C
-Extracted out relevant method to separate class
-Added comprehensive tests around relevant methods
Issue-ID: CPS-788
Signed-off-by: ToineSiebelink <toine.siebelink@est.tech>
Change-Id: Icb2104ca606b28f1904ead368bcde27f578e7e53
Diffstat (limited to 'src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java')
-rw-r--r-- | src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java | 41 |
1 files changed, 10 insertions, 31 deletions
diff --git a/src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java b/src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java index 99127e66..27a292de 100644 --- a/src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java +++ b/src/main/java/org/onap/cps/ncmp/dmi/service/DmiServiceImpl.java @@ -23,12 +23,12 @@ package org.onap.cps.ncmp.dmi.service; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.gson.Gson; -import com.google.gson.JsonObject; +import com.fasterxml.jackson.databind.ObjectWriter; import java.util.ArrayList; import java.util.Collection; import java.util.LinkedHashMap; import java.util.List; +import java.util.Map; import lombok.extern.slf4j.Slf4j; import org.onap.cps.ncmp.dmi.config.DmiPluginConfig.DmiPluginProperties; import org.onap.cps.ncmp.dmi.exception.CmHandleRegistrationException; @@ -61,7 +61,6 @@ public class DmiServiceImpl implements DmiService { private DmiPluginProperties dmiPluginProperties; private static final String RESPONSE_CODE = "response code : "; private static final String MESSAGE = " message : "; - private static final String IETF_NETCONF_MONITORING_OUTPUT = "ietf-netconf-monitoring:output"; /** * Constructor. @@ -96,11 +95,12 @@ public class DmiServiceImpl implements DmiService { @Override public YangResources getModuleResources(final String cmHandle, final List<ModuleReference> moduleReferences) { final YangResources yangResources = new YangResources(); - for (final var moduleReference : moduleReferences) { - final var moduleRequest = createModuleRequest(moduleReference); + for (final ModuleReference moduleReference : moduleReferences) { + final String moduleRequest = createModuleRequest(moduleReference); final ResponseEntity<String> responseEntity = sdncOperations.getModuleResource(cmHandle, moduleRequest); if (responseEntity.getStatusCode() == HttpStatus.OK) { - yangResources.add(toYangResource(moduleReference, responseEntity)); + final YangResource yangResource = YangResourceExtractor.toYangResource(moduleReference, responseEntity); + yangResources.add(yangResource); } else if (responseEntity.getStatusCode() == HttpStatus.NOT_FOUND) { log.error("SDNC did not return a module resource for the given cmHandle {}", cmHandle); throw new ModuleResourceNotFoundException(cmHandle, @@ -140,7 +140,7 @@ public class DmiServiceImpl implements DmiService { } private ModuleSetSchemas toModuleSetSchemas(final ModuleSchema moduleSchema) { - final var moduleSetSchemas = new ModuleSetSchemas(); + final ModuleSetSchemas moduleSetSchemas = new ModuleSetSchemas(); moduleSetSchemas.setModuleName(moduleSchema.getIdentifier()); moduleSetSchemas.setNamespace(moduleSchema.getNamespace()); moduleSetSchemas.setRevision(moduleSchema.getVersion()); @@ -186,13 +186,13 @@ public class DmiServiceImpl implements DmiService { } private String createModuleRequest(final ModuleReference moduleReference) { - final var ietfNetconfModuleReferences = new LinkedHashMap<>(); + final Map ietfNetconfModuleReferences = new LinkedHashMap<String, String>(); ietfNetconfModuleReferences.put("ietf-netconf-monitoring:identifier", moduleReference.getName()); ietfNetconfModuleReferences.put("ietf-netconf-monitoring:version", moduleReference.getRevision()); - final var writer = objectMapper.writer().withRootName("ietf-netconf-monitoring:input"); + final ObjectWriter objectWriter = objectMapper.writer().withRootName("ietf-netconf-monitoring:input"); final String moduleRequest; try { - moduleRequest = writer.writeValueAsString(ietfNetconfModuleReferences); + moduleRequest = objectWriter.writeValueAsString(ietfNetconfModuleReferences); } catch (final JsonProcessingException e) { log.error("JSON exception occurred when creating the module request for the given module reference {}", moduleReference.getName()); @@ -202,25 +202,4 @@ public class DmiServiceImpl implements DmiService { return moduleRequest; } - private YangResource toYangResource(final ModuleReference moduleReference, - final ResponseEntity<String> response) { - final YangResource yangResource = new YangResource(); - yangResource.setModuleName(moduleReference.getName()); - yangResource.setRevision(moduleReference.getRevision()); - yangResource.setYangSource(extractYangSourceFromBody(response)); - return yangResource; - } - - private String extractYangSourceFromBody(final ResponseEntity<String> responseEntity) { - final var responseBodyAsJsonObject = new Gson().fromJson(responseEntity.getBody(), JsonObject.class); - if (responseBodyAsJsonObject.getAsJsonObject(IETF_NETCONF_MONITORING_OUTPUT) == null - || responseBodyAsJsonObject.getAsJsonObject(IETF_NETCONF_MONITORING_OUTPUT) - .getAsJsonPrimitive("data") == null) { - log.error("Error occurred when trying to parse the response body from sdnc {}", responseEntity.getBody()); - throw new ModuleResourceNotFoundException(responseEntity.getBody(), - "Error occurred when trying to parse the response body from sdnc."); - } - return responseBodyAsJsonObject.getAsJsonObject(IETF_NETCONF_MONITORING_OUTPUT).getAsJsonPrimitive("data") - .toString(); - } } |