From 0429a71c2ca41cd311473c9485fa98bbcadaa542 Mon Sep 17 00:00:00 2001 From: s00370346 Date: Wed, 27 Mar 2019 10:06:03 +0530 Subject: Issue-ID: DCAEGEN2-1055 RestConfCollector bug fixes Change-Id: I4623217ab69eaeecf1b5704172ad4de37e641312 Signed-off-by: s00370346 --- dpo/blueprints/k8s-rcc-policy.yaml-template | 6 +- etc/DmaapConfig.json | 2 +- etc/collector.properties | 4 +- pom.xml | 9 ++- .../java/org/onap/dcae/ApplicationSettings.java | 2 +- src/main/java/org/onap/dcae/RestConfCollector.java | 35 ++++++++++ .../dcae/common/ControllerActivationState.java | 25 +++++++ .../java/org/onap/dcae/common/EventProcessor.java | 4 +- .../org/onap/dcae/controller/AccessController.java | 80 +++++++++++++--------- .../dcae/controller/PersistentEventConnection.java | 2 +- .../java/org/onap/dcae/AccessControllerTest.java | 3 + .../org/onap/dcae/ApplicationSettingsTest.java | 4 +- .../org/onap/dcae/common/EventProcessorTest.java | 2 + .../onap/dcae/controller/ConfigCBSSourceTest.java | 2 +- .../controller/ConfigLoaderIntegrationE2ETest.java | 30 ++++---- swagger_restconfcollector_1.0.0.json | 2 +- swagger_restconfcollector_1.0.0.yaml | 2 +- 17 files changed, 153 insertions(+), 61 deletions(-) create mode 100644 src/main/java/org/onap/dcae/common/ControllerActivationState.java diff --git a/dpo/blueprints/k8s-rcc-policy.yaml-template b/dpo/blueprints/k8s-rcc-policy.yaml-template index d6673ac..6c98b95 100755 --- a/dpo/blueprints/k8s-rcc-policy.yaml-template +++ b/dpo/blueprints/k8s-rcc-policy.yaml-template @@ -76,10 +76,10 @@ node_templates: collector.rcc.dmaap.streamid: "notification=device-registration" collector.rcc.inputQueue.maxPending: "8096" tomcat.maxthreads: "200" - collector.rcc.service.port: "8686" + collector.rcc.service.port: "8080" collector.rcc.service.secure.port: "8687" collector.rcc.keystore.file.location: "/opt/app/restconfcollector/etc/keystore" - collector.rcc.keystore.passwordfile: "/opt/app/restconfcollector/etc/rcc_password" + collector.rcc.keystore.passwordfile: "/opt/app/restconfcollector/etc/rcc_passwordfile" collector.rcc.keystore.alias: "dynamically generated" collector.rcc.truststore.file.location: "/opt/app/restconfcollector/etc/truststore.onap.client.jks" collector.rcc.truststore.passwordfile: "/opt/app/restconfcollector/etc/trustpasswordfile" @@ -89,7 +89,7 @@ node_templates: collector.header.authlist: "sample1,c2FtcGxlMQ==" collector.rcc.service.secure.clientauth: "0" streams_publishes: - notification: + device-registration: dmaap_info: topic_url: get_input: notification_publish_url diff --git a/etc/DmaapConfig.json b/etc/DmaapConfig.json index 6aac252..e000e16 100755 --- a/etc/DmaapConfig.json +++ b/etc/DmaapConfig.json @@ -6,7 +6,7 @@ "class": "HpCambriaOutputStream", "stripHpId": "true", "type": "out", - "cambria.hosts": "119.3.84.152:30227" + "cambria.hosts": "message-router:3904" } ] } diff --git a/etc/collector.properties b/etc/collector.properties index 96cc845..3bee48e 100755 --- a/etc/collector.properties +++ b/etc/collector.properties @@ -34,13 +34,13 @@ collector.rcc.appDescription = "DCAE RestConf Collector Application" ## ## Normally: ## -## - 8686 is http service +## - 8080 is http service ## - https is disabled by default (-1) ## ## - At this time, the server always binds to 0.0.0.0 ## ## The default port when collector.header.authflag is disabled (0) -collector.rcc.service.port=8686 +collector.rcc.service.port=8080 ## The secure port is required if collector.header.authflag is set to 1 (true) ## Authentication is only supported via secure port diff --git a/pom.xml b/pom.xml index e8bcd90..5fc8f3e 100644 --- a/pom.xml +++ b/pom.xml @@ -95,6 +95,13 @@ limitations under the License. docker-maven-plugin 1.1.1 + + org.apache.maven.plugins + maven-enforcer-plugin + + true + + @@ -204,7 +211,7 @@ limitations under the License. /opt/app/restconfcollector/bin/docker_entry.sh - 8686 + 8080 8687 diff --git a/src/main/java/org/onap/dcae/ApplicationSettings.java b/src/main/java/org/onap/dcae/ApplicationSettings.java index 45f01ce..8bf32c4 100644 --- a/src/main/java/org/onap/dcae/ApplicationSettings.java +++ b/src/main/java/org/onap/dcae/ApplicationSettings.java @@ -108,7 +108,7 @@ public class ApplicationSettings { } public int httpPort() { - return properties.getInt("collector.rcc.service.port", 8686); + return properties.getInt("collector.rcc.service.port", 8080); } public int httpsPort() { diff --git a/src/main/java/org/onap/dcae/RestConfCollector.java b/src/main/java/org/onap/dcae/RestConfCollector.java index 27fccd6..05c299e 100644 --- a/src/main/java/org/onap/dcae/RestConfCollector.java +++ b/src/main/java/org/onap/dcae/RestConfCollector.java @@ -24,6 +24,7 @@ package org.onap.dcae; import io.vavr.collection.Map; import org.json.JSONArray; import org.json.JSONObject; +import org.onap.dcae.common.ControllerActivationState; import org.onap.dcae.common.EventData; import org.onap.dcae.common.EventProcessor; import org.onap.dcae.common.publishing.DMaaPConfigurationParser; @@ -43,6 +44,7 @@ import org.springframework.context.annotation.Lazy; import java.nio.file.Paths; import java.util.HashMap; +import java.util.Iterator; import java.util.concurrent.*; @SpringBootApplication(exclude = {GsonAutoConfiguration.class, SecurityAutoConfiguration.class}) @@ -56,8 +58,10 @@ public class RestConfCollector { private static ConfigLoader configLoader; private static SpringApplication app; private static ScheduledFuture scheduleFeatures; + private static ScheduledFuture scheduleCtrlActivation; private static ExecutorService executor; private static ScheduledThreadPoolExecutor scheduledThreadPoolExecutor; + private static ScheduledThreadPoolExecutor scheduledThExController; private static EventPublisher eventPublisher; private static EventProcessor eventProcessor; @@ -70,6 +74,7 @@ public class RestConfCollector { app = new SpringApplication(RestConfCollector.class); properties = new ApplicationSettings(args, CLIUtils::processCmdLine); scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1); + scheduledThExController = new ScheduledThreadPoolExecutor(1); init(); app.setAddCommandLineProperties(true); context = app.run(); @@ -85,6 +90,7 @@ public class RestConfCollector { context.close(); properties.reloadProperties(); scheduleFeatures.cancel(true); + scheduleCtrlActivation.cancel(true); init(); controllerConfig(properties); context = SpringApplication.run(RestConfCollector.class); @@ -174,6 +180,11 @@ public class RestConfCollector { 10, 10, TimeUnit.MINUTES); + ControllerActivationTask task = new ControllerActivationTask(); + scheduleCtrlActivation = scheduledThExController.scheduleAtFixedRate(task, + 10, + 10, + TimeUnit.SECONDS); } private static void createExecutors() { @@ -186,4 +197,28 @@ public class RestConfCollector { executor.execute(eventProcessor); } } + + private static class ControllerActivationTask implements Runnable + { + public ControllerActivationTask() { + } + + @Override + public void run() + { + try { + Iterator it1 = controllerStore.keySet().iterator(); + while(it1.hasNext()){ + String key = it1.next(); + AccessController ctlr = controllerStore.get(key); + if(ctlr.getState() == ControllerActivationState.INIT) { + log.info("Activating controller " + key); + ctlr.activate(); + } + } + } catch (Exception e) { + log.info("Activation failed"); + } + } + } } diff --git a/src/main/java/org/onap/dcae/common/ControllerActivationState.java b/src/main/java/org/onap/dcae/common/ControllerActivationState.java new file mode 100644 index 0000000..deb2b1f --- /dev/null +++ b/src/main/java/org/onap/dcae/common/ControllerActivationState.java @@ -0,0 +1,25 @@ +/*- + * ============LICENSE_START======================================================= + * org.onap.dcaegen2.collectors.restconf + * ================================================================================ + * Copyright (C) 2018-2019 Huawei. 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.common; + +public enum ControllerActivationState { + INIT, ACTIVE, NONE; +} diff --git a/src/main/java/org/onap/dcae/common/EventProcessor.java b/src/main/java/org/onap/dcae/common/EventProcessor.java index 164aed3..cf44921 100644 --- a/src/main/java/org/onap/dcae/common/EventProcessor.java +++ b/src/main/java/org/onap/dcae/common/EventProcessor.java @@ -76,9 +76,9 @@ public class EventProcessor implements Runnable { private void sendEventsToStreams(String[] streamIdList, EventData ev) { for (String aStreamIdList : streamIdList) { log.info("Invoking publisher for streamId:" + aStreamIdList); - if (!ev.getConn().getEvent_ruleId().equals("")) { + if (!ev.getConn().getEventRuleId().equals("")) { JSONObject customHeader = new JSONObject(); - customHeader.put("rule-id", ev.getConn().getEvent_ruleId()); + customHeader.put("rule-id", ev.getConn().getEventRuleId()); eventPublisher.sendEvent(overrideEvent(customHeader, ev.getEventObj()), aStreamIdList); } else { eventPublisher.sendEvent(ev.getEventObj(), aStreamIdList); diff --git a/src/main/java/org/onap/dcae/controller/AccessController.java b/src/main/java/org/onap/dcae/controller/AccessController.java index 165c468..226ead5 100644 --- a/src/main/java/org/onap/dcae/controller/AccessController.java +++ b/src/main/java/org/onap/dcae/controller/AccessController.java @@ -24,6 +24,7 @@ import org.json.JSONObject; import org.onap.dcae.ApplicationException; import org.onap.dcae.ApplicationSettings; import org.onap.dcae.common.Constants; +import org.onap.dcae.common.ControllerActivationState; import org.onap.dcae.common.RestConfContext; import org.onap.dcae.common.RestapiCallNode; import org.slf4j.Logger; @@ -56,6 +57,8 @@ public class AccessController { private ExecutorService executor = Executors.newCachedThreadPool(); private Map paraMap; + ControllerActivationState state; + public AccessController(JSONObject controller, ApplicationSettings properties) { this.cfgInfo = new ControllerConfigInfo(controller.get("controller_name").toString(), @@ -71,7 +74,7 @@ public class AccessController { this.ctx = new RestConfContext(); this.restApiCallNode = new RestapiCallNode(); this.paraMap = new HashMap<>(); - + this.state = ControllerActivationState.INIT; prepareControllerParamMap(); log.info("AccesController Created {} {} {} {} {} {}", @@ -85,12 +88,22 @@ public class AccessController { @Override public boolean equals(Object o) { - if (this == o) return true; - if (!(o instanceof AccessController)) return false; + if (this == o) + return true; + if (!(o instanceof AccessController)) + return false; AccessController that = (AccessController) o; return that.cfgInfo.getController_name().equals(that.cfgInfo.getController_name()); } + public ControllerActivationState getState() { + return state; + } + + public void setState(ControllerActivationState state) { + this.state = state; + } + @Override public int hashCode() { return Objects.hash(this.cfgInfo.getController_name()); @@ -107,8 +120,7 @@ public class AccessController { this.executor = executor; } - private void fetch_TokenId() { - + private void fetchTokenId() { modifyControllerParamMap(Constants.KSETTING_REST_API_URL, getUriMethod(this.properties.authorizationEnabled()) + cfgInfo.getController_restapiUrl() + cfgInfo.getController_accessTokenUrl()); modifyControllerParamMap(Constants.KDEFAULT_TEMP_FILENAME, cfgInfo.getController_accessTokenFile()); @@ -117,6 +129,7 @@ public class AccessController { modifyControllerParamMap(Constants.KSETTING_HTTP_METHOD, cfgInfo.getController_accessTokenMethod()); String httpResponse = null; + try { getRestApiCallNode().sendRequest(this.paraMap, ctx, null); @@ -125,43 +138,46 @@ public class AccessController { log.info("httpResponse ", httpResponse + " key " + key); JSONObject jsonObj = new JSONObject(httpResponse); log.info("jsonObj ", jsonObj.toString()); - //JSONObject data = jsonObj.getJSONObject("data"); - //String tokenId = data.get("accessSession").toString(); //@TODO: Make return field dynamic String tokenId = jsonObj.get("accessSession").toString(); - log.info("token 1" + tokenId); modifyControllerParamMap(Constants.KSETTING_TOKENID, tokenId); modifyControllerParamMap(Constants.KSETTING_CUSTOMHTTP_HEADER, "X-ACCESS-TOKEN=" + tokenId); + setState(ControllerActivationState.ACTIVE); + } catch (Exception e) { - log.info("Access token is not supported" + e.getMessage()); + log.info("Access token is not supported " + e.getMessage()); log.info("http response " + httpResponse); } } + public void activate() { - fetch_TokenId(); - printControllerParamMap(); - /* Create eventlist from properties */ - JSONArray contollers = new JSONArray(properties.rccPolicy()); - for (int i = 0; i < contollers.length(); i++) { - JSONObject controller = contollers.getJSONObject(i); - if (controller.get("controller_name").equals(this.getCfgInfo().getController_name())) { - JSONArray eventlists = controller.getJSONArray("event_details"); - for (int j = 0; j < eventlists.length(); j++) { - JSONObject event = eventlists.getJSONObject(j); - String name = event.get("event_name").toString(); - PersistentEventConnection conn = new PersistentEventConnection(name, - event.get("event_description").toString(), - Boolean.parseBoolean(event.get("event_sseventUrlEmbed").toString()), - event.get("event_sseventsField").toString(), - event.get("event_sseventsUrl").toString(), - event.get("event_subscriptionTemplate").toString(), - event.get("event_unSubscriptionTemplate").toString(), - event.get("event_ruleId").toString(), - this); - - eventList.put(name, conn); - executor.execute(conn); + fetchTokenId(); + + if (getState() == ControllerActivationState.ACTIVE) { + printControllerParamMap(); + /* Create eventlist from properties */ + JSONArray contollers = new JSONArray(properties.rccPolicy()); + for (int i = 0; i < contollers.length(); i++) { + JSONObject controller = contollers.getJSONObject(i); + if (controller.get("controller_name").equals(this.getCfgInfo().getController_name())) { + JSONArray eventlists = controller.getJSONArray("event_details"); + for (int j = 0; j < eventlists.length(); j++) { + JSONObject event = eventlists.getJSONObject(j); + String name = event.get("event_name").toString(); + PersistentEventConnection conn = new PersistentEventConnection(name, + event.get("event_description").toString(), + Boolean.parseBoolean(event.get("event_sseventUrlEmbed").toString()), + event.get("event_sseventsField").toString(), + event.get("event_sseventsUrl").toString(), + event.get("event_subscriptionTemplate").toString(), + event.get("event_unSubscriptionTemplate").toString(), + event.get("event_ruleId").toString(), + this); + + eventList.put(name, conn); + executor.execute(conn); + } } } } diff --git a/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java b/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java index 99ad1af..047936d 100644 --- a/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java +++ b/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java @@ -185,7 +185,7 @@ public class PersistentEventConnection implements Runnable { return ClientBuilder.newBuilder().sslContext(sslcontext).hostnameVerifier((s1, s2) -> true).build(); } - public String getEvent_ruleId() { + public String getEventRuleId() { return event_ruleId; } diff --git a/src/test/java/org/onap/dcae/AccessControllerTest.java b/src/test/java/org/onap/dcae/AccessControllerTest.java index b93e190..5469d89 100644 --- a/src/test/java/org/onap/dcae/AccessControllerTest.java +++ b/src/test/java/org/onap/dcae/AccessControllerTest.java @@ -106,6 +106,9 @@ public class AccessControllerTest { JSONObject controller = new JSONObject("{\"controller_name\":\"AccessM&C\",\"controller_restapiUrl\":\"10.118.191.43:26335\",\"controller_restapiUser\":\"access\",\"controller_restapiPassword\":\"Huawei@123\",\"controller_accessTokenUrl\":\"/rest/plat/smapp/v1/oauth/token\",\"controller_accessTokenFile\":\"./etc/access-token.json\",\"controller_accessTokenMethod\":\"put\",\"controller_subsMethod\":\"post\",\"controller_subscriptionUrl\":\"/restconf/v1/operations/huawei-nce-notification-action:establish-subscription\",\"event_details\":[{\"event_name\":\"ONT_registration\",\"event_description\":\"ONTregistartionevent\",\"event_sseventUrlEmbed\":\"true\",\"event_sseventsField\":\"output.url\",\"event_sseventsUrl\":\"null\",\"event_subscriptionTemplate\":\"./etc/ont_registartion_subscription_template.json\",\"event_unSubscriptionTemplate\":\"./etc/ont_registartion_unsubscription_template.json\",\"event_ruleId\":\"777777777\"}]}"); AccessController acClr = new AccessController(controller, properties); + AccessController acClr2 = new AccessController(controller, + properties); + acClr.equals(acClr2); acClr.setRestApiCallNode(restApiCallNode); acClr.setExecutor(executor); acClr.getCtx().setAttribute("responsePrefix.httpResponse","{\"accessSession\" : \"12dsaf4-2323-1231131232323\"}"); diff --git a/src/test/java/org/onap/dcae/ApplicationSettingsTest.java b/src/test/java/org/onap/dcae/ApplicationSettingsTest.java index bc78a24..3a9549f 100644 --- a/src/test/java/org/onap/dcae/ApplicationSettingsTest.java +++ b/src/test/java/org/onap/dcae/ApplicationSettingsTest.java @@ -119,7 +119,7 @@ public class ApplicationSettingsTest { int applicationPort = fromTemporaryConfiguration().httpPort(); // then - assertEquals(8686, applicationPort); + assertEquals(8080, applicationPort); } @Test @@ -135,7 +135,7 @@ public class ApplicationSettingsTest { @Test public void shouldReturnIfHTTPIsEnabled() throws IOException { // when - boolean httpsEnabled = fromTemporaryConfiguration("collector.service.port=8686").httpsEnabled(); + boolean httpsEnabled = fromTemporaryConfiguration("collector.service.port=8080").httpsEnabled(); // then assertTrue(httpsEnabled); } diff --git a/src/test/java/org/onap/dcae/common/EventProcessorTest.java b/src/test/java/org/onap/dcae/common/EventProcessorTest.java index e23a3df..406a0fe 100644 --- a/src/test/java/org/onap/dcae/common/EventProcessorTest.java +++ b/src/test/java/org/onap/dcae/common/EventProcessorTest.java @@ -92,6 +92,8 @@ public class EventProcessorTest { PersistentEventConnection p = new PersistentEventConnection("","",true, "", "","","","1234646346", acClr); + p.getEventParamMapValue("restapiUrl"); + p.modifyEventParamMap("restapiUrl", "10.118.191.43:26335"); RestConfCollector.fProcessingInputQueue = new LinkedBlockingQueue<>(4); RestConfCollector.fProcessingInputQueue.offer(new EventData(p, new JSONObject("{}"))); RestConfCollector.fProcessingInputQueue.offer(new EventData(null, null)); diff --git a/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java b/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java index 5c8593e..b34d393 100644 --- a/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java +++ b/src/test/java/org/onap/dcae/controller/ConfigCBSSourceTest.java @@ -38,7 +38,7 @@ public class ConfigCBSSourceTest extends WiremockBasedTest { @Test public void shouldReturnValidAppConfiguration() { // given - String sampleConfigForVES = "{\"collector.rcc.service.port\": 8686}"; + String sampleConfigForVES = "{\"collector.rcc.service.port\": 8080}"; stubConsulToReturnLocalAddressOfCBS(); stubCBSToReturnAppConfig(sampleConfigForVES); diff --git a/src/test/java/org/onap/dcae/controller/ConfigLoaderIntegrationE2ETest.java b/src/test/java/org/onap/dcae/controller/ConfigLoaderIntegrationE2ETest.java index 730a98d..bcba7fb 100644 --- a/src/test/java/org/onap/dcae/controller/ConfigLoaderIntegrationE2ETest.java +++ b/src/test/java/org/onap/dcae/controller/ConfigLoaderIntegrationE2ETest.java @@ -23,11 +23,7 @@ package org.onap.dcae.controller; import static io.vavr.API.Map; import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.times; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.verifyZeroInteractions; -import static org.mockito.Mockito.when; +import static org.mockito.Mockito.*; import static org.onap.dcae.TestingUtilities.createTemporaryFile; import static org.onap.dcae.TestingUtilities.readFile; import static org.onap.dcae.TestingUtilities.readJSONFromFile; @@ -51,24 +47,26 @@ public class ConfigLoaderIntegrationE2ETest extends WiremockBasedTest { @Test public void testSuccessfulE2EFlow() { - // given +// // given // Path dMaaPConfigFile = createTemporaryFile("{}"); // Path collectorPropertiesFile = createTemporaryFile(""); // Path dMaaPConfigSource = Paths.get("src/test/resources/testParseDMaaPCredentialsGen2.json"); // JSONObject dMaaPConf = readJSONFromFile(dMaaPConfigSource); // stubConsulToReturnLocalAddressOfCBS(); -// stubCBSToReturnAppConfig(f("{\"collector.port\": 8686, \"streams_publishes\": %s}}", dMaaPConf)); +// stubCBSToReturnAppConfig(f("{\"collector.port\": 8080, \"streams_publishes\": %s}}", dMaaPConf)); // // EventPublisher eventPublisherMock = mock(EventPublisher.class); // -// Mockito.mock(RestConfCollector.class); +// RestConfCollector rs = Mockito.mock(RestConfCollector.class); +// +// // ConfigFilesFacade configFilesFacade = new ConfigFilesFacade(dMaaPConfigFile, collectorPropertiesFile); // ConfigLoader configLoader = new ConfigLoader(eventPublisherMock::reconfigure, configFilesFacade, ConfigSource::getAppConfig, () -> wiremockBasedEnvProps()); // configLoader.updateConfig(); // // // then // assertThat(readJSONFromFile(dMaaPConfigSource).toString()).isEqualTo(dMaaPConf.toString()); -// assertThat(readFile(collectorPropertiesFile).trim()).isEqualTo("collector.port = 8686"); +// assertThat(readFile(collectorPropertiesFile).trim()).isEqualTo("collector.port = 8080"); // verify(eventPublisherMock, times(1)).reconfigure( // DMaaPConfigurationParser.parseToDomainMapping(dMaaPConf).get() // ); @@ -81,18 +79,24 @@ public class ConfigLoaderIntegrationE2ETest extends WiremockBasedTest { Path collectorPropertiesFile = createTemporaryFile(""); JSONObject dMaaPConf = readJSONFromFile(Paths.get("src/test/resources/testParseDMaaPCredentialsGen2.json")); stubConsulToReturnLocalAddressOfCBS(); - stubCBSToReturnAppConfig(f("{\"collector.port\": 8686, \"streams_publishes\": %s}}", dMaaPConf)); + stubCBSToReturnAppConfig(f("{\"collector.port\": 8080, \"streams_publishes\": %s}}", dMaaPConf)); EventPublisher eventPublisherMock = mock(EventPublisher.class); ConfigFilesFacade configFilesFacade = new ConfigFilesFacade(dMaaPConfigFile, collectorPropertiesFile); - configFilesFacade.writeProperties(Map("collector.port", "8686")); + configFilesFacade.writeProperties(Map("collector.port", "8080")); configFilesFacade.writeDMaaPConfiguration(dMaaPConf); - // when ConfigLoader configLoader = new ConfigLoader(eventPublisherMock::reconfigure, configFilesFacade, ConfigSource::getAppConfig, () -> wiremockBasedEnvProps()); configLoader.updateConfig(); - // then + verifyZeroInteractions(eventPublisherMock); + + // when + JSONObject dMaaPConf2 = readJSONFromFile(Paths.get("src/test/resources/testParseDMaaPCredentialsGen2Temp.json")); + configFilesFacade.writeDMaaPConfiguration(dMaaPConf2); + configFilesFacade.writeProperties(Map("collector.port", "8081")); + configLoader.updateConfig(); + } } \ No newline at end of file diff --git a/swagger_restconfcollector_1.0.0.json b/swagger_restconfcollector_1.0.0.json index d511970..79fbd42 100644 --- a/swagger_restconfcollector_1.0.0.json +++ b/swagger_restconfcollector_1.0.0.json @@ -11,7 +11,7 @@ "url": "http://www.apache.org/licenses/LICENSE-2.0" } }, - "host": "localhost:8686", + "host": "localhost:8080", "basePath": "/", "tags": [{ "name": "restconf-colletcor", diff --git a/swagger_restconfcollector_1.0.0.yaml b/swagger_restconfcollector_1.0.0.yaml index d511970..79fbd42 100644 --- a/swagger_restconfcollector_1.0.0.yaml +++ b/swagger_restconfcollector_1.0.0.yaml @@ -11,7 +11,7 @@ "url": "http://www.apache.org/licenses/LICENSE-2.0" } }, - "host": "localhost:8686", + "host": "localhost:8080", "basePath": "/", "tags": [{ "name": "restconf-colletcor", -- cgit 1.2.3-korg