X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fconfiguration%2FApplicationConfigParserTest.java;h=79eb07a6d140f03ad7da559e28fd1d61124090f9;hb=bfdd5bb6f922b2ffbf87251e607de3ae73782984;hp=02c84db878a9ccecc2c26b14b0221c9508a699d5;hpb=8f1c85c3604a0d10675cacd16a7b67dca346d478;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/configuration/ApplicationConfigParserTest.java b/policy-agent/src/test/java/org/oransc/policyagent/configuration/ApplicationConfigParserTest.java index 02c84db8..79eb07a6 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/configuration/ApplicationConfigParserTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/configuration/ApplicationConfigParserTest.java @@ -39,6 +39,7 @@ import java.io.InputStreamReader; import java.net.MalformedURLException; import java.net.URL; import java.nio.charset.StandardCharsets; +import java.util.Map; import java.util.Properties; import org.junit.jupiter.api.Test; @@ -51,12 +52,12 @@ public class ApplicationConfigParserTest { ApplicationConfigParser parserUnderTest = new ApplicationConfigParser(); @Test - public void whenCorrectDmaapConfig() throws Exception { + public void whenCorrectConfig() throws Exception { JsonObject jsonRootObject = getJsonRootObject(); - parserUnderTest.parse(jsonRootObject); + ApplicationConfigParser.ConfigParserResult result = parserUnderTest.parse(jsonRootObject); - Properties actualPublisherConfig = parserUnderTest.getDmaapPublisherConfig(); + Properties actualPublisherConfig = result.dmaapPublisherConfig(); assertAll("publisherConfig", () -> assertEquals("localhost:6845/events", actualPublisherConfig.get("ServiceName"), "Wrong ServiceName"), () -> assertEquals("A1-POLICY-AGENT-WRITE", actualPublisherConfig.get("topic"), "Wrong topic"), @@ -67,10 +68,10 @@ public class ApplicationConfigParserTest { () -> 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 = parserUnderTest.getDmaapConsumerConfig(); + Properties actualConsumerConfig = result.dmaapConsumerConfig(); assertAll("consumerConfig", () -> assertEquals("localhost:6845/events", actualConsumerConfig.get("ServiceName"), "Wrong ServiceName"), () -> assertEquals("A1-POLICY-AGENT-READ", actualConsumerConfig.get("topic"), "Wrong topic"), @@ -83,8 +84,18 @@ public class ApplicationConfigParserTest { () -> 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 controllers = result.controllerConfigs(); + assertEquals(1, controllers.size(), "size"); + ImmutableControllerConfig expectedControllerConfig = ImmutableControllerConfig.builder() // + .baseUrl("http://localhost:8083/") // + .name("controller1") // + .userName("user") // + .password("password") // + .build(); // + assertEquals(expectedControllerConfig, controllers.get("controller1"), "controller contents"); } private JsonObject getJsonRootObject() throws JsonIOException, JsonSyntaxException, IOException { @@ -190,7 +201,7 @@ public class ApplicationConfigParserTest { JsonObject jsonRootObject = getJsonRootObject(); JsonObject json = jsonRootObject.getAsJsonObject("config"); json.remove("ric"); - final String message = "Could not find member: ric in: " + json; + final String message = "Could not find member: 'ric' in: " + json; Exception actualException = assertThrows(ServiceException.class, () -> parserUnderTest.parse(jsonRootObject));