aboutsummaryrefslogtreecommitdiffstats
path: root/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java')
-rw-r--r--src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java153
1 files changed, 0 insertions, 153 deletions
diff --git a/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java b/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java
deleted file mode 100644
index bfec3d97..00000000
--- a/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java
+++ /dev/null
@@ -1,153 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * org.onap.dcaegen2.collectors.ves
- * ================================================================================
- * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
- * Copyright (C) 2018 Nokia. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.dcae.controller;
-
-import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
-import static com.github.tomakehurst.wiremock.client.WireMock.get;
-import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
-import static com.github.tomakehurst.wiremock.client.WireMock.urlEqualTo;
-import static org.assertj.core.api.Java6Assertions.assertThat;
-import static org.onap.dcae.TestingUtilities.assertFailureHasInfo;
-import static org.onap.dcae.controller.ConfigSource.getAppConfig;
-
-import io.vavr.control.Try;
-import org.json.JSONObject;
-import org.junit.Test;
-import org.onap.dcae.WiremockBasedTest;
-
-
-public class ConfigCBSSourceTest extends WiremockBasedTest {
-
- @Test
- public void shouldReturnValidAppConfiguration() {
- // given
- String sampleConfigForVES = "{\"collector.port\": 8080}";
-
- stubConsulToReturnLocalAddressOfCBS();
- stubCBSToReturnAppConfig(sampleConfigForVES);
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertThat(actual.get().toString()).isEqualTo(new JSONObject(sampleConfigForVES).toString());
- }
-
- @Test
- public void shouldReturnFailureOnFailureToCommunicateWithConsul() {
- // given
- stubFor(get(urlEqualTo("/v1/catalog/service/CBSName"))
- .willReturn(aResponse().withStatus(400)));
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "HTTP", "Consul", "400",
- "http://localhost:" + wireMockRule.port() + "/v1/catalog/service/CBSName");
- }
-
- @Test
- public void shouldReturnFailureOnBadJsonFromConsul() {
- // given
- stubFor(get(urlEqualTo("/v1/catalog/service/CBSName"))
- .willReturn(aResponse().withStatus(200).withBody("[{")));
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "JSON", "array", "[{");
- }
-
- @Test
- public void shouldReturnFailureOnInvalidCatalogFormat() {
- // given
- String notAListCatalog = ""
- + "{"
- + "\"ServiceAddress\":\"localhost\","
- + "\"ServicePort\":" + wireMockRule.port()
- + "}";
-
- stubFor(get(urlEqualTo("/v1/catalog/service/CBSName"))
- .willReturn(aResponse().withStatus(200).withBody(notAListCatalog)));
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "JSON", "array", notAListCatalog);
- }
-
-
- @Test
- public void shouldReturnFailureIfConfigIsMissingRequiredProperties() {
- // given
- String actualConf = "{\"ServicePort\":" + wireMockRule.port() + "}";
- String asCatalog = "[" + actualConf + "]";
-
- stubFor(get(urlEqualTo("/v1/catalog/service/CBSName"))
- .willReturn(aResponse().withStatus(200).withBody(asCatalog)));
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "ServiceAddress", "ServicePort", "missing", actualConf);
- }
-
-
- @Test
- public void shouldReturnFailureOnFailureToCommunicateWithCBS() {
- // given
- stubFor(get(urlEqualTo("/v1/catalog/service/CBSName"))
- .willReturn(aResponse().withStatus(200).withBody(validLocalCBSConf())));
- stubFor(get(urlEqualTo("/service_component/VESCollector"))
- .willReturn(aResponse().withStatus(400)));
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "HTTP", "CBS", "400",
- "http://localhost:" + wireMockRule.port() + "/service_component/VESCollector");
- }
-
- @Test
- public void shouldReturnFailureIfAppIsInvalidJsonDocument() {
- // given
- String invalidAppConf = "[$";
- stubConsulToReturnLocalAddressOfCBS();
- stubCBSToReturnAppConfig(invalidAppConf);
-
- // when
- Try<JSONObject> actual = tryToGetConfig();
-
- // then
- assertFailureHasInfo(actual, "JSON", "document", invalidAppConf);
- }
-
- private Try<JSONObject> tryToGetConfig() {
- return getAppConfig(new EnvProps("http", "localhost", wireMockRule.port(), "http", "CBSName", "VESCollector"));
- }
-}
-