X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fclients%2FSdncOscA1Client.java;h=67d42d7c9ae835666288ee0de86c5d2b449bff01;hb=9f9cde2f0d76ad943f5dfcf50548be5800834a2f;hp=993088aa29ebbce8eac765f40c368b1d1ec9de7d;hpb=7619c78eac9c8a1ad1e17e0a74d93acd04238ce8;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/clients/SdncOscA1Client.java b/policy-agent/src/main/java/org/oransc/policyagent/clients/SdncOscA1Client.java index 993088aa..67d42d7c 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/clients/SdncOscA1Client.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/clients/SdncOscA1Client.java @@ -70,7 +70,7 @@ public class SdncOscA1Client implements A1Client { SdncOscAdapterInput inputParams = ImmutableSdncOscAdapterInput.builder() // .nearRtRicUrl(ricConfig.baseUrl()) // .build(); - String inputJsonString = createInputJsonString(gson.toJson(inputParams)); + String inputJsonString = createInputJsonString(inputParams); logger.debug("POST getPolicyTypeIdentities inputJsonString = {}", inputJsonString); return restClient @@ -85,7 +85,7 @@ public class SdncOscA1Client implements A1Client { SdncOscAdapterInput inputParams = ImmutableSdncOscAdapterInput.builder() // .nearRtRicUrl(ricConfig.baseUrl()) // .build(); - String inputJsonString = createInputJsonString(gson.toJson(inputParams)); + String inputJsonString = createInputJsonString(inputParams); logger.debug("POST getPolicyIdentities inputJsonString = {}", inputJsonString); return restClient @@ -101,7 +101,7 @@ public class SdncOscA1Client implements A1Client { .nearRtRicUrl(ricConfig.baseUrl()) // .policyTypeId(policyTypeId) // .build(); - String inputJsonString = createInputJsonString(gson.toJson(inputParams)); + String inputJsonString = createInputJsonString(inputParams); logger.debug("POST getPolicyType inputJsonString = {}", inputJsonString); return restClient @@ -119,7 +119,7 @@ public class SdncOscA1Client implements A1Client { .policyId(policy.id()) // .policy(policy.json()) // .build(); - String inputJsonString = createInputJsonString(gson.toJson(inputParams)); + String inputJsonString = createInputJsonString(inputParams); logger.debug("POST putPolicy inputJsonString = {}", inputJsonString); return restClient @@ -146,7 +146,7 @@ public class SdncOscA1Client implements A1Client { .nearRtRicUrl(ricConfig.baseUrl()) // .policyId(policyId) // .build(); - String inputJsonString = createInputJsonString(gson.toJson(inputParams)); + String inputJsonString = createInputJsonString(inputParams); logger.debug("POST deletePolicy inputJsonString = {}", inputJsonString); return restClient.postWithAuthHeader("/A1-ADAPTER-API:deletePolicy", inputJsonString, a1ControllerUsername, @@ -159,9 +159,9 @@ public class SdncOscA1Client implements A1Client { .flatMap(x -> Mono.just(A1ProtocolType.SDNC_OSC)); } - private String createInputJsonString(String paramsJson) { + private String createInputJsonString(SdncOscAdapterInput inputParams) { JSONObject inputJson = new JSONObject(); - inputJson.put("input", new JSONObject(paramsJson)); + inputJson.put("input", new JSONObject(gson.toJson(inputParams))); return inputJson.toString(); }