package org.oransc.policyagent.clients;
-import com.google.gson.FieldNamingPolicy;
-import com.google.gson.Gson;
-import com.google.gson.GsonBuilder;
-
import java.util.Arrays;
import java.util.Vector;
import reactor.core.publisher.Mono;
public class A1ClientHelper {
- private static Gson gson = new GsonBuilder() //
- .setFieldNamingPolicy(FieldNamingPolicy.LOWER_CASE_WITH_DASHES) //
- .create();
private A1ClientHelper() {
}
- protected static <T> String createInputJsonString(T inputParams) {
- JSONObject inputJson = new JSONObject();
- inputJson.put("input", gson.toJson(inputParams));
- return inputJson.toString();
- }
-
protected static Mono<String> createOutputJsonResponse(String key, String value) {
JSONObject paramsJson = new JSONObject();
paramsJson.put(key, value);
RicConfig cfg = ImmutableRicConfig.builder().name("ric") //
.baseUrl(url) //
.managedElementIds(new Vector<String>(Arrays.asList("kista_1", "kista_2"))) //
+ .controllerName("") //
.build();
return new Ric(cfg);
}
.ric(createRic(nearRtRicUrl)) //
.type(createPolicyType(type)) //
.lastModified("now") //
+ .isTransient(false) //
.build();
}