import org.oransc.policyagent.exceptions.ServiceException;
import org.springframework.http.MediaType;
import org.oransc.policyagent.exceptions.ServiceException;
import org.springframework.http.MediaType;
JsonObject jsonRootObject = getJsonRootObject();
ApplicationConfigParser.ConfigParserResult result = parserUnderTest.parse(jsonRootObject);
JsonObject jsonRootObject = getJsonRootObject();
ApplicationConfigParser.ConfigParserResult result = parserUnderTest.parse(jsonRootObject);
() -> assertEquals("admin", actualPublisherConfig.get("password"), "Wrong password"),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualPublisherConfig.get("TransportType"),
"Wrong TransportType"),
() -> assertEquals("admin", actualPublisherConfig.get("password"), "Wrong password"),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualPublisherConfig.get("TransportType"),
"Wrong TransportType"),
- () -> assertEquals(15000, actualPublisherConfig.get("timeout"), "Wrong timeout"),
- () -> assertEquals(100, actualPublisherConfig.get("limit"), "Wrong limit"));
+ () -> assertEquals("15000", actualPublisherConfig.get("timeout"), "Wrong timeout"),
+ () -> assertEquals("100", actualPublisherConfig.get("limit"), "Wrong limit"));
Properties actualConsumerConfig = result.dmaapConsumerConfig();
assertAll("consumerConfig",
Properties actualConsumerConfig = result.dmaapConsumerConfig();
assertAll("consumerConfig",
() -> assertEquals("policy-agent", actualConsumerConfig.get("id"), "Wrong id"),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualConsumerConfig.get("TransportType"),
"Wrong TransportType"),
() -> assertEquals("policy-agent", actualConsumerConfig.get("id"), "Wrong id"),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualConsumerConfig.get("TransportType"),
"Wrong TransportType"),
- () -> assertEquals(15000, actualConsumerConfig.get("timeout"), "Wrong timeout"),
- () -> assertEquals(100, actualConsumerConfig.get("limit"), "Wrong limit"));
+ () -> assertEquals("15000", actualConsumerConfig.get("timeout"), "Wrong timeout"),
+ () -> assertEquals("100", actualConsumerConfig.get("limit"), "Wrong limit"));
Map<String, ControllerConfig> controllers = result.controllerConfigs();
assertEquals(1, controllers.size(), "size");
Map<String, ControllerConfig> controllers = result.controllerConfigs();
assertEquals(1, controllers.size(), "size");
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config").getAsJsonObject("streams_publishes");
JsonObject fake_info_object = new JsonObject();
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config").getAsJsonObject("streams_publishes");
JsonObject fake_info_object = new JsonObject();
public String toString() {
return String.format("[dmaap_publisher=%s, fake_info_object=%s]", dmaap_publisher.toString(),
fake_info_object.toString());
public String toString() {
return String.format("[dmaap_publisher=%s, fake_info_object=%s]", dmaap_publisher.toString(),
fake_info_object.toString());
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config").getAsJsonObject("streams_subscribes");
JsonObject fake_info_object = new JsonObject();
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config").getAsJsonObject("streams_subscribes");
JsonObject fake_info_object = new JsonObject();
public String toString() {
return String.format("[dmaap_subscriber=%s, fake_info_object=%s]", dmaap_subscriber.toString(),
fake_info_object.toString());
public String toString() {
return String.format("[dmaap_subscriber=%s, fake_info_object=%s]", dmaap_subscriber.toString(),
fake_info_object.toString());
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrl = "WrongTopicUrl";
JsonObject json = getDmaapInfo(jsonRootObject, "streams_subscribes", "dmaap_subscriber");
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrl = "WrongTopicUrl";
JsonObject json = getDmaapInfo(jsonRootObject, "streams_subscribes", "dmaap_subscriber");
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrl = "WrongTopicUrl";
JsonObject json = getDmaapInfo(jsonRootObject, "streams_publishes", "dmaap_publisher");
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrl = "WrongTopicUrl";
JsonObject json = getDmaapInfo(jsonRootObject, "streams_publishes", "dmaap_publisher");
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config");
json.remove("ric");
JsonObject jsonRootObject = getJsonRootObject();
JsonObject json = jsonRootObject.getAsJsonObject("config");
json.remove("ric");
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrlString =
"http://admin:admin@localhost:6845/events/A1-POLICY-AGENT-READ/users/policy-agent/wrong-topic-url";
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrlString =
"http://admin:admin@localhost:6845/events/A1-POLICY-AGENT-READ/users/policy-agent/wrong-topic-url";
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrlString =
"http://admin:admin@localhost:6845/events/A1-POLICY-AGENT-WRITE/wrong-topic-url";
JsonObject jsonRootObject = getJsonRootObject();
final String wrongTopicUrlString =
"http://admin:admin@localhost:6845/events/A1-POLICY-AGENT-WRITE/wrong-topic-url";
String dmaapPublisherOrSubscriber) throws Exception {
return jsonRootObject.getAsJsonObject("config").getAsJsonObject(streamsPublishesOrSubscribes)
.getAsJsonObject(dmaapPublisherOrSubscriber).getAsJsonObject("dmaap_info");
String dmaapPublisherOrSubscriber) throws Exception {
return jsonRootObject.getAsJsonObject("config").getAsJsonObject(streamsPublishesOrSubscribes)
.getAsJsonObject(dmaapPublisherOrSubscriber).getAsJsonObject("dmaap_info");