src/test/java/org/onap/dcae/controller/ConfigLoaderIntegrationE2ETest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * org.onap.dcaegen2.collectors.ves
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * Copyright (C) 2018 Nokia. All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21 package org.onap.dcae.controller;
  22
  23 import static io.vavr.API.Map;
  24 import static org.assertj.core.api.Assertions.assertThat;
  25 import static org.mockito.Mockito.mock;
  26 import static org.mockito.Mockito.times;
  27 import static org.mockito.Mockito.verify;
  28 import static org.mockito.Mockito.verifyZeroInteractions;
  29 import static org.mockito.Mockito.when;
  30 import static org.onap.dcae.TestingUtilities.createTemporaryFile;
  31 import static org.onap.dcae.TestingUtilities.readFile;
  32 import static org.onap.dcae.TestingUtilities.readJSONFromFile;
  33 import static org.onap.dcae.common.publishing.VavrUtils.f;
  34
  35 import java.nio.file.Path;
  36 import java.nio.file.Paths;
  37 import org.json.JSONObject;
  38 import org.junit.Test;
  39 import org.junit.runner.RunWith;
  40 import org.mockito.Mock;
  41 import org.mockito.junit.MockitoJUnitRunner;
  42 import org.onap.dcae.ApplicationSettings;
  43 import org.onap.dcae.WiremockBasedTest;
  44 import org.onap.dcae.common.publishing.DMaaPConfigurationParser;
  45 import org.onap.dcae.common.publishing.EventPublisher;
  46
  47 @RunWith(MockitoJUnitRunner.Silent.class)
  48 public class ConfigLoaderIntegrationE2ETest extends WiremockBasedTest {
  49
  50     @Test
  51     public void testSuccessfulE2EFlow() {
  52         // given
  53         Path dMaaPConfigFile = createTemporaryFile("{}");
  54         Path collectorPropertiesFile = createTemporaryFile("");
  55         Path dMaaPConfigSource = Paths.get("src/test/resources/testParseDMaaPCredentialsGen2.json");
  56         JSONObject dMaaPConf = readJSONFromFile(dMaaPConfigSource);
  57         stubConsulToReturnLocalAddressOfCBS();
  58         stubCBSToReturnAppConfig(f("{\"collector.port\": 8080, \"streams_publishes\": %s}}", dMaaPConf));
  59
  60         EventPublisher eventPublisherMock = mock(EventPublisher.class);
  61         ConfigFilesFacade configFilesFacade = new ConfigFilesFacade(dMaaPConfigFile, collectorPropertiesFile);
  62         ConfigLoader configLoader = new ConfigLoader(eventPublisherMock::reconfigure, configFilesFacade, ConfigSource::getAppConfig, () -> wiremockBasedEnvProps());
  63         configLoader.updateConfig();
  64         // then
  65         assertThat(readJSONFromFile(dMaaPConfigSource).toString()).isEqualTo(dMaaPConf.toString());
  66         assertThat(readFile(collectorPropertiesFile).trim()).isEqualTo("collector.port = 8080");
  67         verify(eventPublisherMock, times(1)).reconfigure(
  68             DMaaPConfigurationParser.parseToDomainMapping(dMaaPConf).get()
  69         );
  70     }
  71
  72     @Test
  73     public void shouldNotReconfigureNotOverwriteIfConfigurationHasNotChanged() {
  74         // given
  75         Path dMaaPConfigFile = createTemporaryFile("{}");
  76         Path collectorPropertiesFile = createTemporaryFile("");
  77         JSONObject dMaaPConf = readJSONFromFile(Paths.get("src/test/resources/testParseDMaaPCredentialsGen2.json"));
  78         stubConsulToReturnLocalAddressOfCBS();
  79         stubCBSToReturnAppConfig(f("{\"collector.port\": 8080, \"streams_publishes\": %s}}", dMaaPConf));
  80         EventPublisher eventPublisherMock = mock(EventPublisher.class);
  81         ConfigFilesFacade configFilesFacade = new ConfigFilesFacade(dMaaPConfigFile, collectorPropertiesFile);
  82         configFilesFacade.writeProperties(Map("collector.port", "8080"));
  83         configFilesFacade.writeDMaaPConfiguration(dMaaPConf);
  84
  85         // when
  86         ConfigLoader configLoader = new ConfigLoader(eventPublisherMock::reconfigure, configFilesFacade, ConfigSource::getAppConfig, () -> wiremockBasedEnvProps());
  87         configLoader.updateConfig();
  88
  89         // then
  90         verifyZeroInteractions(eventPublisherMock);
  91     }
  92
  93 }