re base code
[sdc.git] / catalog-be / src / test / java / org / openecomp / sdc / be / components / distribution / engine / DistributionEngineClusterHealthTest.java
1 package org.openecomp.sdc.be.components.distribution.engine;
2
3 import mockit.Deencapsulation;
4 import org.junit.Test;
5 import org.openecomp.sdc.be.components.BeConfDependentTest;
6 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngineClusterHealth.HealthCheckScheduledTask;
7 import org.openecomp.sdc.common.api.HealthCheckInfo;
8
9 import java.util.HashMap;
10 import java.util.LinkedList;
11 import java.util.Map;
12 import java.util.concurrent.atomic.AtomicBoolean;
13
14 public class DistributionEngineClusterHealthTest extends BeConfDependentTest{
15
16         private DistributionEngineClusterHealth createTestSubject() {
17                 return new DistributionEngineClusterHealth();
18         }
19
20         @Test
21         public void testInit() throws Exception {
22                 DistributionEngineClusterHealth testSubject;
23
24                 // default test
25                 testSubject = createTestSubject();
26                 Deencapsulation.invoke(testSubject, "init");
27         }
28
29         @Test
30         public void testDestroy() throws Exception {
31                 DistributionEngineClusterHealth testSubject;
32
33                 // default test
34                 testSubject = createTestSubject();
35                 Deencapsulation.invoke(testSubject, "destroy");
36         }
37
38         @Test
39         public void testStartHealthCheckTask() throws Exception {
40                 DistributionEngineClusterHealth testSubject;
41                 Map<String, AtomicBoolean> envNamePerStatus = null;
42                 boolean startTask = false;
43
44                 // default test
45                 testSubject = createTestSubject();
46                 testSubject.startHealthCheckTask(envNamePerStatus, startTask);
47         }
48
49         @Test
50         public void testStartHealthCheckTask_1() throws Exception {
51                 DistributionEngineClusterHealth testSubject;
52                 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
53
54                 // default test
55                 testSubject = createTestSubject();
56                 testSubject.init();
57                 testSubject.startHealthCheckTask(envNamePerStatus);
58         }
59
60         @Test
61         public void testHealthCheckScheduledTask() throws Exception {
62                 DistributionEngineClusterHealth testSubject;
63                 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
64
65                 // default test
66                 testSubject = createTestSubject();
67                 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
68                 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
69                 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
70                 healthCheckCalls.add(hcc);
71                 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
72                 
73                 Deencapsulation.invoke(healthCheckScheduledTask, "queryUeb");
74         }
75         
76         @Test
77         public void testHealthCheckScheduledTaskRun() throws Exception {
78                 DistributionEngineClusterHealth testSubject;
79                 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
80                 envNamePerStatus.put("mock", new AtomicBoolean(true));
81                 // default test
82                 testSubject = createTestSubject();
83                 testSubject.startHealthCheckTask(envNamePerStatus, false);
84                 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
85                 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
86                 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
87                 healthCheckCalls.add(hcc);
88                 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
89                 
90                 Deencapsulation.invoke(healthCheckScheduledTask, "run");
91         }
92         
93         @Test
94         public void testHealthCheckScheduledTaskRun_2() throws Exception {
95                 DistributionEngineClusterHealth testSubject;
96                 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
97                 envNamePerStatus.put("mock", new AtomicBoolean(false));
98                 // default test
99                 testSubject = createTestSubject();
100                 testSubject.startHealthCheckTask(envNamePerStatus, false);
101                 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
102                 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
103                 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
104                 healthCheckCalls.add(hcc);
105                 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
106                 
107                 Deencapsulation.invoke(healthCheckScheduledTask, "run");
108         }
109         
110         @Test
111         public void testLogAlarm() throws Exception {
112                 DistributionEngineClusterHealth testSubject;
113                 boolean lastHealthState = false;
114
115                 // default test
116                 testSubject = createTestSubject();
117                 Deencapsulation.invoke(testSubject, "logAlarm", new Object[] { lastHealthState });
118         }
119         
120         @Test
121         public void testGetHealthCheckInfo() throws Exception {
122                 DistributionEngineClusterHealth testSubject;
123                 HealthCheckInfo result;
124
125                 // default test
126                 testSubject = createTestSubject();
127                 result = testSubject.getHealthCheckInfo();
128         }
129
130         @Test
131         public void testSetHealthCheckUebIsDisabled() throws Exception {
132                 DistributionEngineClusterHealth testSubject;
133
134                 // default test
135                 testSubject = createTestSubject();
136                 testSubject.setHealthCheckUebIsDisabled();
137         }
138
139         @Test
140         public void testSetHealthCheckUebConfigurationError() throws Exception {
141                 DistributionEngineClusterHealth testSubject;
142
143                 // default test
144                 testSubject = createTestSubject();
145                 testSubject.setHealthCheckUebConfigurationError();
146         }
147
148         @Test
149         public void testSetHealthCheckOkAndReportInCaseLastStateIsDown() throws Exception {
150                 DistributionEngineClusterHealth testSubject;
151
152                 // default test
153                 testSubject = createTestSubject();
154                 testSubject.setHealthCheckOkAndReportInCaseLastStateIsDown();
155         }
156 }