aboutsummaryrefslogtreecommitdiffstats
path: root/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
diff options
context:
space:
mode:
authora.sreekumar <ajith.sreekumar@bell.ca>2021-12-03 11:27:32 +0000
committera.sreekumar <ajith.sreekumar@bell.ca>2021-12-14 17:58:20 +0000
commit4694c152f69380f4d3d64bde0a13d15fb59a71f3 (patch)
tree38c9e0b1117323c58536706a66830109225d6200 /main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
parentc51fa0d4e953518571a115af4afdea80a17ed605 (diff)
Migrate pap startup & controllers to spring boot
This commit migrates pap config, startup and controllers to spring boot. Change-Id: Icf91d728160a23db614dfba6b40ddccd2f6163a5 Issue-ID: POLICY-3754 Signed-off-by: a.sreekumar <ajith.sreekumar@bell.ca>
Diffstat (limited to 'main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java')
-rw-r--r--main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java32
1 files changed, 17 insertions, 15 deletions
diff --git a/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java b/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
index f27a8d32..13deef40 100644
--- a/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
+++ b/main/src/test/java/org/onap/policy/pap/main/rest/TestPolicyComponentsHealthCheckProvider.java
@@ -30,11 +30,11 @@ import static org.mockito.Mockito.when;
import java.io.File;
import java.net.HttpURLConnection;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import javax.ws.rs.core.Response;
-import javax.ws.rs.core.Response.Status;
import org.apache.commons.lang3.tuple.Pair;
import org.junit.After;
import org.junit.Before;
@@ -44,7 +44,6 @@ import org.mockito.Mock;
import org.mockito.junit.MockitoJUnitRunner;
import org.onap.policy.common.endpoints.http.client.HttpClient;
import org.onap.policy.common.endpoints.http.client.HttpClientFactory;
-import org.onap.policy.common.endpoints.parameters.RestClientParameters;
import org.onap.policy.common.endpoints.report.HealthCheckReport;
import org.onap.policy.common.parameters.ParameterService;
import org.onap.policy.common.utils.coder.Coder;
@@ -62,6 +61,8 @@ import org.onap.policy.pap.main.PolicyModelsProviderFactoryWrapper;
import org.onap.policy.pap.main.parameters.CommonTestData;
import org.onap.policy.pap.main.parameters.PapParameterGroup;
import org.onap.policy.pap.main.startstop.PapActivator;
+import org.springframework.http.HttpStatus;
+import org.springframework.test.util.ReflectionTestUtils;
@RunWith(MockitoJUnitRunner.class)
public class TestPolicyComponentsHealthCheckProvider {
@@ -105,6 +106,8 @@ public class TestPolicyComponentsHealthCheckProvider {
private PapParameterGroup savedPapParameterGroup;
+ private PolicyComponentsHealthCheckProvider provider;
+
/**
* Configures mocks and objects.
*
@@ -145,15 +148,15 @@ public class TestPolicyComponentsHealthCheckProvider {
when(response3.getStatus()).thenReturn(HttpURLConnection.HTTP_OK);
when(response3.readEntity(DmaapGetTopicResponse.class)).thenReturn(createDmaapResponse());
when(client3.get()).thenReturn(response3);
-
+ List<HttpClient> clients = new ArrayList<>();
+ clients.add(client1);
+ clients.add(client2);
+ clients.add(client3);
PapParameterGroup papParameterGroup = ParameterService.get(PAP_GROUP_PARAMS_NAME);
- List<RestClientParameters> params = papParameterGroup.getHealthCheckRestClientParameters();
- when(clientFactory.build(params.get(0))).thenReturn(client1);
- when(clientFactory.build(params.get(1))).thenReturn(client2);
- when(clientFactory.build(params.get(2))).thenReturn(client3);
-
- PolicyComponentsHealthCheckProvider.initializeClientHealthCheckExecutorService(papParameterGroup,
- clientFactory);
+ provider = new PolicyComponentsHealthCheckProvider();
+ ReflectionTestUtils.setField(provider, "papParameterGroup", papParameterGroup);
+ provider.initializeClientHealthCheckExecutorService();
+ ReflectionTestUtils.setField(provider, "clients", clients);
}
/**
@@ -166,15 +169,14 @@ public class TestPolicyComponentsHealthCheckProvider {
} else {
ParameterService.deregister(PAP_GROUP_PARAMS_NAME);
}
- PolicyComponentsHealthCheckProvider.cleanup();
+ provider.cleanup();
}
@Test
public void testFetchPolicyComponentsHealthStatus_allHealthy() {
- PolicyComponentsHealthCheckProvider provider = new PolicyComponentsHealthCheckProvider();
- Pair<Status, Map<String, Object>> ret = provider.fetchPolicyComponentsHealthStatus();
- assertEquals(Response.Status.OK, ret.getLeft());
+ Pair<HttpStatus, Map<String, Object>> ret = provider.fetchPolicyComponentsHealthStatus();
+ assertEquals(HttpStatus.OK, ret.getLeft());
assertTrue((Boolean) ret.getRight().get(HEALTHY));
}
@@ -239,7 +241,7 @@ public class TestPolicyComponentsHealthCheckProvider {
}
private Map<String, Object> callFetchPolicyComponentsHealthStatus() {
- PolicyComponentsHealthCheckProvider provider = new PolicyComponentsHealthCheckProvider();
+
return provider.fetchPolicyComponentsHealthStatus().getRight();
}