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