X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Ftest%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fclients%2FA1ClientFactoryTest.java;h=2095470115712a22214ee982721383b07346c8ea;hb=e0fab9aec406c7d9d6e34c5a94cbe7341a99ceb7;hp=926485dcf5fc175ac5791f742f1578d188f1e2ec;hpb=6c1af5cf09756b4c91a786f90f65f5b94ca21aa7;p=nonrtric.git diff --git a/policy-agent/src/test/java/org/oransc/policyagent/clients/A1ClientFactoryTest.java b/policy-agent/src/test/java/org/oransc/policyagent/clients/A1ClientFactoryTest.java index 926485dc..20954701 100644 --- a/policy-agent/src/test/java/org/oransc/policyagent/clients/A1ClientFactoryTest.java +++ b/policy-agent/src/test/java/org/oransc/policyagent/clients/A1ClientFactoryTest.java @@ -2,7 +2,7 @@ * ========================LICENSE_START================================= * O-RAN-SC * %% - * Copyright (C) 2019 Nordix Foundation + * Copyright (C) 2020 Nordix Foundation * %% * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -25,13 +25,10 @@ import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.ArgumentMatchers.any; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.spy; -import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; -import ch.qos.logback.classic.Level; -import ch.qos.logback.classic.spi.ILoggingEvent; -import ch.qos.logback.core.read.ListAppender; import java.util.Vector; + import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; @@ -41,7 +38,7 @@ import org.oransc.policyagent.clients.A1Client.A1ProtocolType; import org.oransc.policyagent.configuration.ApplicationConfig; import org.oransc.policyagent.configuration.ImmutableRicConfig; import org.oransc.policyagent.repository.Ric; -import org.oransc.policyagent.utils.LoggingUtils; + import reactor.core.publisher.Mono; import reactor.test.StepVerifier; @@ -54,16 +51,16 @@ public class A1ClientFactoryTest { private ApplicationConfig applicationConfigMock; @Mock - A1Client stdA1ClientMock; + A1Client clientMock1; @Mock - A1Client oscA1ClientMock; + A1Client clientMock2; @Mock - A1Client sdncOscA1ClientMock; + A1Client clientMock3; @Mock - A1Client sdnrOnapA1ClientMock; + A1Client clientMock4; private ImmutableRicConfig ricConfig = ImmutableRicConfig.builder().name(RIC_NAME).baseUrl("baseUrl").managedElementIds(new Vector<>()).build(); @@ -77,136 +74,64 @@ public class A1ClientFactoryTest { } @Test - public void createStd_ok() { - whenGetProtocolVersionSdnrOnapA1ClientThrowException(); - whenGetProtocolVersionSdncOscA1ClientThrowException(); - whenGetProtocolVersionOscA1ClientThrowException(); - whenGetProtocolVersionStdA1ClientReturnCorrectProtocol(); + public void getProtocolVersion_ok() { + whenGetProtocolVersionThrowException(clientMock1); + whenGetProtocolVersionReturn(clientMock2, A1ProtocolType.STD_V1_1); + doReturn(clientMock1, clientMock2).when(factoryUnderTest).createClient(any(), any()); - StepVerifier.create(factoryUnderTest.createA1Client(ric)) // - .expectSubscription() // - .expectNext(stdA1ClientMock) // - .verifyComplete(); + A1Client client = factoryUnderTest.createA1Client(ric).block(); - assertEquals(A1ProtocolType.STD_V1, ric.getProtocolVersion(), "Not correct protocol"); + assertEquals(clientMock2, client, "Not correct client returned"); + assertEquals(A1ProtocolType.STD_V1_1, ric.getProtocolVersion(), "Not correct protocol"); } @Test - public void createOsc_ok() { - whenGetProtocolVersionSdnrOnapA1ClientThrowException(); - whenGetProtocolVersionSdncOscA1ClientThrowException(); - whenGetProtocolVersionOscA1ClientReturnCorrectProtocol(); - - StepVerifier.create(factoryUnderTest.createA1Client(ric)) // - .expectSubscription() // - .expectNext(oscA1ClientMock) // - .verifyComplete(); + public void getProtocolVersion_ok_Last() { + whenGetProtocolVersionThrowException(clientMock1, clientMock2, clientMock3); + whenGetProtocolVersionReturn(clientMock4, A1ProtocolType.STD_V1_1); + doReturn(clientMock1, clientMock2, clientMock3, clientMock4).when(factoryUnderTest).createClient(any(), any()); - assertEquals(A1ProtocolType.OSC_V1, ric.getProtocolVersion(), "Not correct protocol"); - } - - @Test - public void createSdncOsc_ok() { - whenGetProtocolVersionSdnrOnapA1ClientThrowException(); - whenGetProtocolVersionSdncOscA1ClientReturnCorrectProtocol(); - - StepVerifier.create(factoryUnderTest.createA1Client(ric)) // - .expectSubscription() // - .expectNext(sdncOscA1ClientMock) // - .verifyComplete(); - - assertEquals(A1ProtocolType.SDNC_OSC, ric.getProtocolVersion(), "Not correct protocol"); - } - - @Test - public void createSdnrOnap_ok() { - whenGetProtocolVersionSdnrOnapA1ClientReturnCorrectProtocol(); - - StepVerifier.create(factoryUnderTest.createA1Client(ric)) // - .expectSubscription() // - .expectNext(sdnrOnapA1ClientMock) // - .verifyComplete(); + A1Client client = factoryUnderTest.createA1Client(ric).block(); - assertEquals(A1ProtocolType.SDNR_ONAP, ric.getProtocolVersion(), "Not correct protocol"); + assertEquals(clientMock4, client, "Not correct client returned"); + assertEquals(A1ProtocolType.STD_V1_1, ric.getProtocolVersion(), "Not correct protocol"); } @Test - public void createWithNoProtocol_error() { - whenGetProtocolVersionSdnrOnapA1ClientThrowException(); - whenGetProtocolVersionSdncOscA1ClientThrowException(); - whenGetProtocolVersionOscA1ClientThrowException(); - whenGetProtocolVersionStdA1ClientThrowException(); + public void getProtocolVersion_error() { + whenGetProtocolVersionThrowException(clientMock1, clientMock2, clientMock3, clientMock4); + doReturn(clientMock1, clientMock2, clientMock3, clientMock4).when(factoryUnderTest).createClient(any(), any()); - final ListAppender logAppender = LoggingUtils.getLogListAppender(A1ClientFactory.class); StepVerifier.create(factoryUnderTest.createA1Client(ric)) // .expectSubscription() // - .expectErrorMatches( - throwable -> throwable instanceof Exception && throwable.getMessage().equals(EXCEPTION_MESSAGE)) + .expectErrorMatches(throwable -> throwable.getMessage().equals(EXCEPTION_MESSAGE)) // .verify(); - assertEquals(Level.WARN, logAppender.list.get(0).getLevel(), "Warning not logged"); - assertTrue(logAppender.list.toString().contains("Could not get protocol version from RIC: " + RIC_NAME), - "Correct message not logged"); - assertEquals(A1ProtocolType.UNKNOWN, ric.getProtocolVersion(), "Not correct protocol"); } - @Test - public void createWithProtocolInRic_noTrialAndError() { - doReturn(stdA1ClientMock).when(factoryUnderTest).createStdA1ClientImpl(any(Ric.class)); - - ric.setProtocolVersion(A1ProtocolType.STD_V1); - - StepVerifier.create(factoryUnderTest.createA1Client(ric)) // - .expectSubscription() // - .expectNext(stdA1ClientMock) // - .verifyComplete(); - - assertEquals(A1ProtocolType.STD_V1, ric.getProtocolVersion(), "Not correct protocol"); - - verifyNoMoreInteractions(sdnrOnapA1ClientMock); - verifyNoMoreInteractions(sdncOscA1ClientMock); - verifyNoMoreInteractions(oscA1ClientMock); - verifyNoMoreInteractions(stdA1ClientMock); + private A1Client createClient(A1ProtocolType version) { + return factoryUnderTest.createClient(ric, version); } - private void whenGetProtocolVersionSdnrOnapA1ClientThrowException() { - doReturn(sdnrOnapA1ClientMock).when(factoryUnderTest).createSdnrOnapA1Client(ric); - when(sdnrOnapA1ClientMock.getProtocolVersion()).thenReturn(Mono.error(new Exception(EXCEPTION_MESSAGE))); - } - - private void whenGetProtocolVersionSdnrOnapA1ClientReturnCorrectProtocol() { - doReturn(sdnrOnapA1ClientMock).when(factoryUnderTest).createSdnrOnapA1Client(any(Ric.class)); - when(sdnrOnapA1ClientMock.getProtocolVersion()).thenReturn(Mono.just(A1ProtocolType.SDNR_ONAP)); - } - - private void whenGetProtocolVersionSdncOscA1ClientThrowException() { - doReturn(sdncOscA1ClientMock).when(factoryUnderTest).createSdncOscA1Client(any(Ric.class)); - when(sdncOscA1ClientMock.getProtocolVersion()).thenReturn(Mono.error(new Exception(EXCEPTION_MESSAGE))); - } - - private void whenGetProtocolVersionSdncOscA1ClientReturnCorrectProtocol() { - doReturn(sdncOscA1ClientMock).when(factoryUnderTest).createSdncOscA1Client(any(Ric.class)); - when(sdncOscA1ClientMock.getProtocolVersion()).thenReturn(Mono.just(A1ProtocolType.SDNC_OSC)); - } - - private void whenGetProtocolVersionOscA1ClientThrowException() { - doReturn(oscA1ClientMock).when(factoryUnderTest).createOscA1Client(any(Ric.class)); - when(oscA1ClientMock.getProtocolVersion()).thenReturn(Mono.error(new Exception(EXCEPTION_MESSAGE))); + @Test + public void create_check_types() { + assertTrue(createClient(A1ProtocolType.STD_V1_1) instanceof StdA1ClientVersion1); + assertTrue(createClient(A1ProtocolType.OSC_V1) instanceof OscA1Client); + assertTrue(createClient(A1ProtocolType.SDNC_ONAP) instanceof SdncOnapA1Client); + assertTrue(createClient(A1ProtocolType.SDNC_OSC_STD_V1_1) instanceof SdncOscA1Client); + assertTrue(createClient(A1ProtocolType.SDNC_OSC_OSC_V1) instanceof SdncOscA1Client); + assertTrue(createClient(A1ProtocolType.UNKNOWN) == null); } - private void whenGetProtocolVersionOscA1ClientReturnCorrectProtocol() { - doReturn(oscA1ClientMock).when(factoryUnderTest).createOscA1Client(any(Ric.class)); - when(oscA1ClientMock.getProtocolVersion()).thenReturn(Mono.just(A1ProtocolType.OSC_V1)); + private void whenGetProtocolVersionThrowException(A1Client... clientMocks) { + for (A1Client clientMock : clientMocks) { + when(clientMock.getProtocolVersion()).thenReturn(Mono.error(new Exception(EXCEPTION_MESSAGE))); + } } - private void whenGetProtocolVersionStdA1ClientThrowException() { - doReturn(stdA1ClientMock).when(factoryUnderTest).createStdA1ClientImpl(any(Ric.class)); - when(stdA1ClientMock.getProtocolVersion()).thenReturn(Mono.error(new Exception(EXCEPTION_MESSAGE))); + private void whenGetProtocolVersionReturn(A1Client clientMock, A1ProtocolType protocol) { + when(clientMock.getProtocolVersion()).thenReturn(Mono.just(protocol)); } - private void whenGetProtocolVersionStdA1ClientReturnCorrectProtocol() { - doReturn(stdA1ClientMock).when(factoryUnderTest).createStdA1ClientImpl(any(Ric.class)); - when(stdA1ClientMock.getProtocolVersion()).thenReturn(Mono.just(A1ProtocolType.STD_V1)); - } }