diff options
Diffstat (limited to 'catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java')
-rw-r--r-- | catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java | 218 |
1 files changed, 109 insertions, 109 deletions
diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java index be450c493b..95e3553990 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java @@ -7,9 +7,9 @@ * 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. @@ -20,120 +20,120 @@ package org.openecomp.sdc.be.components.distribution.engine; -import mockit.Deencapsulation; -import org.junit.Test; +import java.lang.reflect.Method; +import java.util.HashSet; +import java.util.LinkedList; +import java.util.List; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; import org.mockito.Mock; import org.mockito.Mockito; import org.openecomp.sdc.be.components.BeConfDependentTest; import org.openecomp.sdc.be.components.distribution.engine.report.DistributionCompleteReporter; +import org.openecomp.sdc.be.config.ConfigurationManager; import org.openecomp.sdc.be.config.DistributionEngineConfiguration; import org.openecomp.sdc.be.impl.ComponentsUtils; import org.openecomp.sdc.be.resources.data.OperationalEnvironmentEntry; +import org.openecomp.sdc.common.impl.ExternalConfiguration; +import org.openecomp.sdc.common.impl.FSConfigurationSource; import org.openecomp.sdc.common.log.wrappers.LoggerSdcAudit; -import java.util.HashSet; -import java.util.LinkedList; -import java.util.List; - -public class DistributionEnginePollingTaskTest extends BeConfDependentTest { - - @Mock - private ComponentsUtils componentsUtils; - - private DistributionEnginePollingTask createTestSubject() { - componentsUtils = Mockito.mock(ComponentsUtils.class); - DistributionEngineConfiguration distributionEngineConfiguration = configurationManager - .getDistributionEngineConfiguration(); - distributionEngineConfiguration.setDistributionNotifTopicName("StamName"); - distributionEngineConfiguration.setDistributionStatusTopicName("StamName"); - List uebList = new LinkedList<>(); - uebList.add("FirstUEBserver.com"); - distributionEngineConfiguration.setUebServers(uebList); - - OperationalEnvironmentEntry environmentEntry = new OperationalEnvironmentEntry(); - HashSet<String> dmaapUebAddress = new HashSet<>(); - dmaapUebAddress.add("STAM"); - environmentEntry.setDmaapUebAddress(dmaapUebAddress); - return new DistributionEnginePollingTask(distributionEngineConfiguration, - new DistributionCompleteReporterMock(), componentsUtils, new DistributionEngineClusterHealth(), - environmentEntry); - } - - @Test - public void testStartTask() throws Exception { - DistributionEnginePollingTask testSubject; - String topicName = "UEBTopic"; - - // default test - testSubject = createTestSubject(); - testSubject.startTask(topicName); - } - - @Test - public void testStopTask() throws Exception { - DistributionEnginePollingTask testSubject; - - // default test - testSubject = createTestSubject(); - testSubject.stopTask(); - } - - @Test - public void testDestroy() throws Exception { - DistributionEnginePollingTask testSubject; - - // default test - testSubject = createTestSubject(); - testSubject.destroy(); - } - - @Test - public void testRun() throws Exception { - DistributionEnginePollingTask testSubject; - - // default test - testSubject = createTestSubject(); - testSubject.run(); - } - - @Test - public void testHandleDistributionNotificationMsg() throws Exception { - DistributionEnginePollingTask testSubject; - DistributionStatusNotification notification = new DistributionStatusNotification(); - notification.setDistributionID("mock"); - notification.setConsumerID("mock"); - notification.setArtifactURL("mock"); - notification.setTimestamp(435435); - notification.setStatus(DistributionStatusNotificationEnum.ALREADY_DEPLOYED); - notification.setErrorReason("mock"); - - - - // default test - testSubject = createTestSubject(); - Mockito.doNothing().when(componentsUtils).auditDistributionStatusNotification( Mockito.anyString(), - Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), - Mockito.anyString(), Mockito.anyString(), Mockito.isNull()); - Deencapsulation.invoke(testSubject, "handleDistributionNotificationMsg", - notification, new LoggerSdcAudit(DistributionEnginePollingTask.class)); - } - - @Test - public void testShutdownExecutor() throws Exception { - DistributionEnginePollingTask testSubject; - - // default test - testSubject = createTestSubject(); - Deencapsulation.invoke(testSubject, "shutdownExecutor"); - } - - private class DistributionCompleteReporterMock implements DistributionCompleteReporter { - - @Override - public void reportDistributionComplete(DistributionStatusNotification distributionStatusNotification) { - // TODO Auto-generated method stub - - } - - } +class DistributionEnginePollingTaskTest extends BeConfDependentTest { + + // TODO - remove this setup after migration to Junit5 BeConfDependentTest + @BeforeAll + private static void setup() { + configurationManager = + new ConfigurationManager(new FSConfigurationSource(ExternalConfiguration.getChangeListener(), "src/test/resources/config/catalog-be")); + } + + @Mock + private ComponentsUtils componentsUtils; + + private DistributionEnginePollingTask createTestSubject() { + componentsUtils = Mockito.mock(ComponentsUtils.class); + DistributionEngineConfiguration distributionEngineConfiguration = configurationManager + .getDistributionEngineConfiguration(); + distributionEngineConfiguration.setDistributionNotifTopicName("StamName"); + distributionEngineConfiguration.setDistributionStatusTopicName("StamName"); + List uebList = new LinkedList<>(); + uebList.add("FirstUEBserver.com"); + distributionEngineConfiguration.setUebServers(uebList); + + OperationalEnvironmentEntry environmentEntry = new OperationalEnvironmentEntry(); + HashSet<String> dmaapUebAddress = new HashSet<>(); + dmaapUebAddress.add("STAM"); + environmentEntry.setDmaapUebAddress(dmaapUebAddress); + return new DistributionEnginePollingTask(distributionEngineConfiguration, + new DistributionCompleteReporterMock(), componentsUtils, new DistributionEngineClusterHealth(), environmentEntry); + } + + @Test + void testStartTask() throws Exception { + DistributionEnginePollingTask testSubject; + String topicName = "UEBTopic"; + + // default test + testSubject = createTestSubject(); + testSubject.startTask(topicName); + } + + @Test + void testStopTask() throws Exception { + DistributionEnginePollingTask testSubject; + + // default test + testSubject = createTestSubject(); + testSubject.stopTask(); + } + + @Test + void testDestroy() throws Exception { + DistributionEnginePollingTask testSubject; + + // default test + testSubject = createTestSubject(); + testSubject.destroy(); + } + + @Test + void testRun() throws Exception { + DistributionEnginePollingTask testSubject; + + // default test + testSubject = createTestSubject(); + testSubject.run(); + } + + @Test + void testHandleDistributionNotificationMsg() throws Exception { + DistributionEnginePollingTask testSubject; + final DistributionStatusNotification notification = new DistributionStatusNotification(); + notification.setDistributionID("mock"); + notification.setConsumerID("mock"); + notification.setArtifactURL("mock"); + notification.setTimestamp(435435); + notification.setStatus(DistributionStatusNotificationEnum.ALREADY_DEPLOYED); + notification.setErrorReason("mock"); + + // default test + testSubject = createTestSubject(); + Mockito.doNothing().when(componentsUtils).auditDistributionStatusNotification(Mockito.anyString(), + Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), + Mockito.anyString(), Mockito.anyString(), Mockito.isNull()); + + final Class[] argClasses = {DistributionStatusNotification.class, LoggerSdcAudit.class}; + final Method method = DistributionEnginePollingTask.class.getDeclaredMethod("handleDistributionNotificationMsg", argClasses); + method.setAccessible(true); + method.invoke(testSubject, notification, new LoggerSdcAudit(DistributionEnginePollingTask.class)); + } + + private class DistributionCompleteReporterMock implements DistributionCompleteReporter { + + @Override + public void reportDistributionComplete(DistributionStatusNotification distributionStatusNotification) { + // TODO Auto-generated method stub + } + + } } |