catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/DistributionEnginePollingTaskTest.java

   1 package org.openecomp.sdc.be.components.distribution.engine;
   2
   3 import mockit.Deencapsulation;
   4 import org.junit.Test;
   5 import org.mockito.Mock;
   6 import org.mockito.Mockito;
   7 import org.openecomp.sdc.be.components.BeConfDependentTest;
   8 import org.openecomp.sdc.be.components.distribution.engine.report.DistributionCompleteReporter;
   9 import org.openecomp.sdc.be.config.DistributionEngineConfiguration;
  10 import org.openecomp.sdc.be.impl.ComponentsUtils;
  11 import org.openecomp.sdc.be.resources.data.OperationalEnvironmentEntry;
  12
  13 public class DistributionEnginePollingTaskTest extends BeConfDependentTest {
  14
  15         @Mock
  16         private ComponentsUtils componentsUtils;
  17
  18         private DistributionEnginePollingTask createTestSubject() {
  19                 componentsUtils = Mockito.mock(ComponentsUtils.class);
  20                 DistributionEngineConfiguration distributionEngineConfiguration = configurationManager
  21                                 .getDistributionEngineConfiguration();
  22
  23                 return new DistributionEnginePollingTask(distributionEngineConfiguration,
  24                                 new DistributionCompleteReporterMock(), componentsUtils, new DistributionEngineClusterHealth(),
  25                                 new OperationalEnvironmentEntry());
  26         }
  27
  28         @Test
  29         public void testStartTask() throws Exception {
  30                 DistributionEnginePollingTask testSubject;
  31                 String topicName = "";
  32
  33                 // default test
  34                 testSubject = createTestSubject();
  35                 testSubject.startTask(topicName);
  36         }
  37
  38         @Test
  39         public void testStopTask() throws Exception {
  40                 DistributionEnginePollingTask testSubject;
  41
  42                 // default test
  43                 testSubject = createTestSubject();
  44                 testSubject.stopTask();
  45         }
  46
  47         @Test
  48         public void testDestroy() throws Exception {
  49                 DistributionEnginePollingTask testSubject;
  50
  51                 // default test
  52                 testSubject = createTestSubject();
  53                 testSubject.destroy();
  54         }
  55
  56         @Test
  57         public void testRun() throws Exception {
  58                 DistributionEnginePollingTask testSubject;
  59
  60                 // default test
  61                 testSubject = createTestSubject();
  62                 testSubject.run();
  63         }
  64
  65         @Test
  66         public void testHandleDistributionNotificationMsg() throws Exception {
  67                 DistributionEnginePollingTask testSubject;
  68                 DistributionStatusNotification notification = new DistributionStatusNotification();
  69                 notification.setDistributionID("mock");
  70                 notification.setConsumerID("mock");
  71                 notification.setArtifactURL("mock");
  72                 notification.setTimestamp(435435);
  73                 notification.setStatus(DistributionStatusNotificationEnum.ALREADY_DEPLOYED);
  74                 notification.setErrorReason("mock");
  75
  76
  77
  78                 // default test
  79                 testSubject = createTestSubject();
  80                 Mockito.doNothing().when(componentsUtils).auditDistributionStatusNotification( Mockito.anyString(),
  81                                 Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), Mockito.anyString(),
  82                                 Mockito.anyString(), Mockito.anyString());
  83                 Deencapsulation.invoke(testSubject, "handleDistributionNotificationMsg",
  84                                 notification);
  85         }
  86
  87         @Test
  88         public void testShutdownExecutor() throws Exception {
  89                 DistributionEnginePollingTask testSubject;
  90
  91                 // default test
  92                 testSubject = createTestSubject();
  93                 Deencapsulation.invoke(testSubject, "shutdownExecutor");
  94         }
  95
  96         private class DistributionCompleteReporterMock implements DistributionCompleteReporter {
  97
  98                 @Override
  99                 public void reportDistributionComplete(DistributionStatusNotification distributionStatusNotification) {
 100                         // TODO Auto-generated method stub
 101
 102                 }
 103
 104         }
 105 }