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=b1f397a4d4e023c73fbcf98f36e007c78bf3cc61;hb=4891734864ae374cf6ff357f41cc840c4f685300;hp=791acee24d0dd7226d75e48c1bb80d9419aaad82;hpb=de026fb34e3dc3200acdb022782fe68615176ead;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 791acee2..b1f397a4 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 @@ -47,6 +47,7 @@ import org.oransc.policyagent.repository.PolicyTypes; import org.oransc.policyagent.repository.Ric; import org.oransc.policyagent.repository.Ric.RicState; import org.oransc.policyagent.repository.Rics; +import org.oransc.policyagent.repository.Services; import reactor.core.publisher.Mono; @ExtendWith(MockitoExtension.class) @@ -62,13 +63,13 @@ public class RepositorySupervisionTest { .baseUrl("baseUrl1") // .managedElementIds(new Vector(Arrays.asList("kista_1", "kista_2"))) // .build()); - ric1.setState(Ric.RicState.ACTIVE); + ric1.setState(Ric.RicState.IDLE); Ric ric2 = new Ric(ImmutableRicConfig.builder() // .name("ric2") // .baseUrl("baseUrl2") // .managedElementIds(new Vector(Arrays.asList("kista_3", "kista_4"))) // .build()); - ric2.setState(Ric.RicState.NOT_REACHABLE); + ric2.setState(Ric.RicState.UNDEFINED); Ric ric3 = new Ric(ImmutableRicConfig.builder() // .name("ric3") // .baseUrl("baseUrl3") // @@ -94,8 +95,10 @@ public class RepositorySupervisionTest { Policies policies = new Policies(); policies.put(policy1); PolicyTypes types = new PolicyTypes(); + Services services = new Services(); - RepositorySupervision supervisorUnderTest = new RepositorySupervision(rics, policies, a1ClientMock, types); + RepositorySupervision supervisorUnderTest = + new RepositorySupervision(rics, policies, a1ClientMock, types, services); Mono> policyIds = Mono.just(Arrays.asList("policyId1", "policyId2")); when(a1ClientMock.getPolicyIdentities(anyString())).thenReturn(policyIds); @@ -105,9 +108,9 @@ public class RepositorySupervisionTest { supervisorUnderTest.checkAllRics(); - await().untilAsserted(() -> RicState.ACTIVE.equals(ric1.state())); - await().untilAsserted(() -> RicState.ACTIVE.equals(ric2.state())); - await().untilAsserted(() -> RicState.ACTIVE.equals(ric3.state())); + await().untilAsserted(() -> RicState.IDLE.equals(ric1.state())); + await().untilAsserted(() -> RicState.IDLE.equals(ric2.state())); + await().untilAsserted(() -> RicState.IDLE.equals(ric3.state())); verify(a1ClientMock).deletePolicy("baseUrl1", "policyId2"); verify(a1ClientMock).deletePolicy("baseUrl2", "policyId2");