diff options
Diffstat (limited to 'so-cnf-adapter-application/src/test/java/org/onap/so/adapters/cnf/service/healthcheck/HealthCheckServiceTest.java')
-rw-r--r-- | so-cnf-adapter-application/src/test/java/org/onap/so/adapters/cnf/service/healthcheck/HealthCheckServiceTest.java | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/so-cnf-adapter-application/src/test/java/org/onap/so/adapters/cnf/service/healthcheck/HealthCheckServiceTest.java b/so-cnf-adapter-application/src/test/java/org/onap/so/adapters/cnf/service/healthcheck/HealthCheckServiceTest.java new file mode 100644 index 0000000..9a043ba --- /dev/null +++ b/so-cnf-adapter-application/src/test/java/org/onap/so/adapters/cnf/service/healthcheck/HealthCheckServiceTest.java @@ -0,0 +1,81 @@ +package org.onap.so.adapters.cnf.service.healthcheck; + +import static java.util.Arrays.asList; +import static org.assertj.core.api.Assertions.assertThat; +import static org.junit.jupiter.api.Assertions.*; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.doReturn; +import static org.mockito.Mockito.times; +import static org.mockito.Mockito.verify; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.UUID; + +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; +import org.mockito.InjectMocks; +import org.mockito.Mock; +import org.mockito.Mockito; +import org.mockito.MockitoAnnotations; +import org.onap.so.adapters.cnf.client.MulticloudClient; +import org.onap.so.adapters.cnf.model.CheckInstanceRequest; +import org.onap.so.adapters.cnf.model.InstanceRequest; +import org.onap.so.adapters.cnf.model.healthcheck.HealthCheckResponse; +import org.onap.so.adapters.cnf.model.healthcheck.K8sRbInstanceHealthCheck; +import org.onap.so.adapters.cnf.model.healthcheck.K8sRbInstanceHealthCheckSimple; +import org.onap.so.client.exception.BadResponseException; + +class HealthCheckServiceTest { + + @InjectMocks + HealthCheckService healthCheckService; + + @Mock + MulticloudClient multicloudClient; + + @BeforeEach + void setUp() { + MockitoAnnotations.initMocks(this); + } + + @Test + void healthCheckTest() { + try { + doReturn(getK8sRbInstanceHealthCheckSimple()).when(multicloudClient).startInstanceHealthCheck(any()); + doReturn(getK8sRbInstanceHealthCheck()).when(multicloudClient).getInstanceHealthCheck(any(),any()); + HealthCheckResponse response = healthCheckService.healthCheck(getTestCheckInstanceRequest()); + + verify(multicloudClient, times(3)).startInstanceHealthCheck(any()); + verify(multicloudClient, times(3)).getInstanceHealthCheck(any(),any()); + assertThat(response.getInstanceResponse()).hasSize(getTestCheckInstanceRequest().getInstances().size()); + } catch (Exception e) { + e.printStackTrace(); + } + } + + private CheckInstanceRequest getTestCheckInstanceRequest(){ + CheckInstanceRequest checkInstanceRequest=new CheckInstanceRequest() ; + checkInstanceRequest.setInstances(asList(getRandomInstance(),getRandomInstance(),getRandomInstance())); + return checkInstanceRequest; + } + + private InstanceRequest getRandomInstance(){ + InstanceRequest instanceRequest=new InstanceRequest(); + instanceRequest.setInstanceId(UUID.randomUUID().toString()); + return instanceRequest; + } + + private K8sRbInstanceHealthCheckSimple getK8sRbInstanceHealthCheckSimple(){ + K8sRbInstanceHealthCheckSimple k8sRbInstanceHealthCheckSimple=new K8sRbInstanceHealthCheckSimple(); + k8sRbInstanceHealthCheckSimple.setId(UUID.randomUUID().toString()); + k8sRbInstanceHealthCheckSimple.setStatus("RUNNING"); + return k8sRbInstanceHealthCheckSimple; + } + + private K8sRbInstanceHealthCheck getK8sRbInstanceHealthCheck(){ + K8sRbInstanceHealthCheck k8sRbInstanceHealthCheck=new K8sRbInstanceHealthCheck(); + k8sRbInstanceHealthCheck.setStatus("STOPPED"); + return k8sRbInstanceHealthCheck; + } +}
\ No newline at end of file |