1 package org.openecomp.sdc.be.components.health;
3 import mockit.Deencapsulation;
4 import org.apache.commons.lang3.tuple.Pair;
5 import org.junit.Assert;
7 import org.openecomp.sdc.be.components.BeConfDependentTest;
8 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngineClusterHealth;
9 import org.openecomp.sdc.be.components.distribution.engine.DmaapHealth;
10 import org.openecomp.sdc.be.switchover.detector.SwitchoverDetector;
11 import org.openecomp.sdc.common.api.HealthCheckInfo;
12 import org.springframework.test.util.ReflectionTestUtils;
14 import java.util.LinkedList;
15 import java.util.List;
17 public class HealthCheckBusinessLogicTest extends BeConfDependentTest{
19 private HealthCheckBusinessLogic createTestSubject() {
20 HealthCheckBusinessLogic healthCheckBusinessLogic = new HealthCheckBusinessLogic();
21 DmaapHealth dmaapHealth = new DmaapHealth();
22 ReflectionTestUtils.setField(healthCheckBusinessLogic, "dmaapHealth", dmaapHealth);
23 DistributionEngineClusterHealth distributionEngineClusterHealth = new DistributionEngineClusterHealth();
24 ReflectionTestUtils.setField(healthCheckBusinessLogic, "distributionEngineClusterHealth", distributionEngineClusterHealth);
25 SwitchoverDetector switchoverDetector = new SwitchoverDetector();
26 ReflectionTestUtils.setField(healthCheckBusinessLogic, "switchoverDetector", switchoverDetector);
27 List<HealthCheckInfo> prevBeHealthCheckInfos = new LinkedList<>();
28 ReflectionTestUtils.setField(healthCheckBusinessLogic, "prevBeHealthCheckInfos", prevBeHealthCheckInfos);
29 return healthCheckBusinessLogic;
33 public void testInit() throws Exception {
34 HealthCheckBusinessLogic testSubject;
37 testSubject = createTestSubject();
42 public void testIsDistributionEngineUp() throws Exception {
43 HealthCheckBusinessLogic testSubject;
47 testSubject = createTestSubject();
48 result = testSubject.isDistributionEngineUp();
52 public void testGetBeHealthCheckInfosStatus() throws Exception {
53 HealthCheckBusinessLogic testSubject;
54 Pair<Boolean, List<HealthCheckInfo>> result;
57 testSubject = createTestSubject();
58 result = testSubject.getBeHealthCheckInfosStatus();
62 public void testGetBeHealthCheckInfos() throws Exception {
63 HealthCheckBusinessLogic testSubject;
64 List<HealthCheckInfo> result;
69 testSubject = createTestSubject();
70 result = Deencapsulation.invoke(testSubject, "getBeHealthCheckInfos");
74 public void testGetEsHealthCheck() throws Exception {
75 HealthCheckBusinessLogic testSubject;
76 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
77 List<HealthCheckInfo> result;
80 testSubject = createTestSubject();
81 result = Deencapsulation.invoke(testSubject, "getEsHealthCheck", healthCheckInfos);
85 public void testGetBeHealthCheck() throws Exception {
86 HealthCheckBusinessLogic testSubject;
87 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
88 List<HealthCheckInfo> result;
91 testSubject = createTestSubject();
92 result = Deencapsulation.invoke(testSubject, "getBeHealthCheck", healthCheckInfos);
96 public void testGetDmaapHealthCheck() throws Exception {
97 HealthCheckBusinessLogic testSubject;
98 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
99 List<HealthCheckInfo> result;
102 testSubject = createTestSubject();
103 result = Deencapsulation.invoke(testSubject, "getDmaapHealthCheck", healthCheckInfos);
107 public void testGetTitanHealthCheck() throws Exception {
108 HealthCheckBusinessLogic testSubject;
109 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
110 List<HealthCheckInfo> result;
113 testSubject = createTestSubject();
114 result = testSubject.getTitanHealthCheck(healthCheckInfos);
118 public void testGetCassandraHealthCheck() throws Exception {
119 HealthCheckBusinessLogic testSubject;
120 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
121 List<HealthCheckInfo> result;
124 testSubject = createTestSubject();
125 result = Deencapsulation.invoke(testSubject, "getCassandraHealthCheck", healthCheckInfos);
129 public void testGetDistributionEngineCheck() throws Exception {
130 HealthCheckBusinessLogic testSubject;
131 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
134 testSubject = createTestSubject();
135 Deencapsulation.invoke(testSubject, "getDistributionEngineCheck", healthCheckInfos);
139 public void testGetAmdocsHealthCheck() throws Exception {
140 HealthCheckBusinessLogic testSubject;
141 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
142 List<HealthCheckInfo> result;
145 testSubject = createTestSubject();
146 result = Deencapsulation.invoke(testSubject, "getAmdocsHealthCheck", healthCheckInfos);
150 public void testGetDcaeHealthCheck() throws Exception {
151 HealthCheckBusinessLogic testSubject;
152 List<HealthCheckInfo> healthCheckInfos = new LinkedList<>();
153 List<HealthCheckInfo> result;
156 testSubject = createTestSubject();
157 result = Deencapsulation.invoke(testSubject, "getDcaeHealthCheck", healthCheckInfos);
161 public void testGetHostedComponentsBeHealthCheck() throws Exception {
162 HealthCheckBusinessLogic testSubject;
163 String componentName = "mock";
164 String healthCheckUrl = "mock";
165 HealthCheckInfo result;
168 testSubject = createTestSubject();
169 result = Deencapsulation.invoke(testSubject, "getHostedComponentsBeHealthCheck",
170 componentName, healthCheckUrl);
173 testSubject = createTestSubject();
175 result = Deencapsulation.invoke(testSubject, "getHostedComponentsBeHealthCheck",
176 componentName, healthCheckUrl);
180 public void testDestroy() throws Exception {
181 HealthCheckBusinessLogic testSubject;
184 testSubject = createTestSubject();
185 Deencapsulation.invoke(testSubject, "destroy");
189 public void testLogAlarm() throws Exception {
190 HealthCheckBusinessLogic testSubject;
191 String componentChangedMsg = "mock";
194 testSubject = createTestSubject();
195 Deencapsulation.invoke(testSubject, "logAlarm", componentChangedMsg);
199 public void testGetSiteMode() throws Exception {
200 HealthCheckBusinessLogic testSubject;
204 testSubject = createTestSubject();
205 result = testSubject.getSiteMode();
209 public void testAnyStatusChanged() throws Exception {
210 HealthCheckBusinessLogic testSubject;
211 List<HealthCheckInfo> beHealthCheckInfos = null;
212 List<HealthCheckInfo> prevBeHealthCheckInfos = null;
216 testSubject = createTestSubject();
217 beHealthCheckInfos = null;
218 prevBeHealthCheckInfos = null;
219 result = testSubject.anyStatusChanged(beHealthCheckInfos, prevBeHealthCheckInfos);
220 Assert.assertEquals(false, result);
223 testSubject = createTestSubject();
224 prevBeHealthCheckInfos = null;
225 beHealthCheckInfos = null;
226 result = testSubject.anyStatusChanged(beHealthCheckInfos, prevBeHealthCheckInfos);
227 Assert.assertEquals(false, result);
230 testSubject = createTestSubject();
231 beHealthCheckInfos = null;
232 prevBeHealthCheckInfos = null;
233 result = testSubject.anyStatusChanged(beHealthCheckInfos, prevBeHealthCheckInfos);
234 Assert.assertEquals(false, result);
237 testSubject = createTestSubject();
238 prevBeHealthCheckInfos = null;
239 beHealthCheckInfos = null;
240 result = testSubject.anyStatusChanged(beHealthCheckInfos, prevBeHealthCheckInfos);
241 Assert.assertEquals(false, result);
245 public void testBuildOnBoardingHealthCheckUrl() throws Exception {
246 HealthCheckBusinessLogic testSubject;
250 testSubject = createTestSubject();
251 result = Deencapsulation.invoke(testSubject, "buildOnBoardingHealthCheckUrl");
255 public void testBuildDcaeHealthCheckUrl() throws Exception {
256 HealthCheckBusinessLogic testSubject;
260 testSubject = createTestSubject();
261 result = Deencapsulation.invoke(testSubject, "buildDcaeHealthCheckUrl");