X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRepositorySupervisionTest.java;h=fb8d46fddaa37ca7e4513448cf9ba87aa9da4319;hb=23b444705e97a325ad51ad6104b5cfd97730dce4;hp=20e54f0c6d73fcdedcb8da73d0c87cef14302e46;hpb=e8c7fa0b02b0918b3b56a1fc162968a3eef282dc;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/tasks/RepositorySupervisionTest.java b/policy-agent/src/test/java/org/oransc/policyagent/tasks/RepositorySupervisionTest.java index 20e54f0c..fb8d46fd 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/tasks/RepositorySupervisionTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/tasks/RepositorySupervisionTest.java @@ -35,9 +35,7 @@ import java.util.Vector; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; -import org.junit.runner.RunWith; import org.mockito.Mock; -import org.mockito.junit.MockitoJUnitRunner; import org.mockito.junit.jupiter.MockitoExtension; import org.oransc.policyagent.clients.A1Client; import org.oransc.policyagent.clients.A1ClientFactory; @@ -57,7 +55,6 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @ExtendWith(MockitoExtension.class) -@RunWith(MockitoJUnitRunner.class) public class RepositorySupervisionTest { @Mock A1Client a1ClientMock; @@ -111,9 +108,6 @@ public class RepositorySupervisionTest { PolicyTypes types = new PolicyTypes(); Services services = new Services(); - RepositorySupervision supervisorUnderTest = - new RepositorySupervision(rics, policies, a1ClientFactory, types, services); - Mono> policyIds = Mono.just(Arrays.asList("policyId1", "policyId2")); doReturn(policyIds).when(a1ClientMock).getPolicyTypeIdentities(); @@ -122,11 +116,14 @@ public class RepositorySupervisionTest { doReturn(Mono.just("OK")).when(a1ClientMock).putPolicy(any()); doReturn(Flux.empty()).when(a1ClientMock).deleteAllPolicies(); + RepositorySupervision supervisorUnderTest = + new RepositorySupervision(rics, policies, a1ClientFactory, types, services); + supervisorUnderTest.checkAllRics(); - await().untilAsserted(() -> RicState.IDLE.equals(ric1.state())); - await().untilAsserted(() -> RicState.IDLE.equals(ric2.state())); - await().untilAsserted(() -> RicState.IDLE.equals(ric3.state())); + await().untilAsserted(() -> RicState.IDLE.equals(ric1.getState())); + await().untilAsserted(() -> RicState.IDLE.equals(ric2.getState())); + await().untilAsserted(() -> RicState.IDLE.equals(ric3.getState())); verify(a1ClientMock, times(3)).deleteAllPolicies(); verifyNoMoreInteractions(a1ClientMock);