summaryrefslogtreecommitdiffstats
path: root/catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java
diff options
context:
space:
mode:
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.java218
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
+ }
+
+ }
}