diff options
Diffstat (limited to 'a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java')
-rw-r--r-- | a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java | 144 |
1 files changed, 102 insertions, 42 deletions
diff --git a/a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java b/a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java index 901bc008..8901ab07 100644 --- a/a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java +++ b/a1-adapter/a1-adapter-api/provider/src/test/java/org/onap/ccsdk/features/a1/adapter/A1AdapterProviderTest.java @@ -37,9 +37,21 @@ import org.onap.ccsdk.sli.core.sli.SvcLogicException; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.DeleteA1PolicyInputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.DeleteA1PolicyOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.DeleteA1PolicyOutputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyInputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyOutputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyStatusInputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyStatusOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyStatusOutputBuilder; import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyTypeInputBuilder; import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyTypeOutput; import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.GetA1PolicyTypeOutputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.PutA1PolicyInputBuilder; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.PutA1PolicyOutput; +import org.opendaylight.yang.gen.v1.org.onap.a1.adapter.rev200122.PutA1PolicyOutputBuilder; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -52,50 +64,98 @@ import org.slf4j.LoggerFactory; @RunWith(MockitoJUnitRunner.Silent.class) public class A1AdapterProviderTest { - protected static final Logger LOG = LoggerFactory.getLogger(A1AdapterProviderTest.class); + protected static final Logger LOG = LoggerFactory.getLogger(A1AdapterProviderTest.class); - class A1AdapterProviderMock extends A1AdapterProvider { + class A1AdapterProviderMock extends A1AdapterProvider { - A1AdapterProviderMock(final DataBroker dataBroker, - final NotificationPublishService notificationPublishService, - final RpcProviderRegistry rpcProviderRegistry, final A1AdapterClient A1AdapterClient) { - super(dataBroker, mockNotificationPublishService, mockRpcProviderRegistry, a1AdapterClient); + A1AdapterProviderMock(final DataBroker dataBroker, final NotificationPublishService notificationPublishService, + final RpcProviderRegistry rpcProviderRegistry, final A1AdapterClient A1AdapterClient) { + super(dataBroker, mockNotificationPublishService, mockRpcProviderRegistry, a1AdapterClient); + } + + } + + private A1AdapterProviderMock a1AdapterProviderMock = null; + @Mock + private DataBroker dataBroker; + @Mock + private NotificationPublishService mockNotificationPublishService; + @Mock + private RpcProviderRegistry mockRpcProviderRegistry; + @Mock + private A1AdapterClient a1AdapterClient; + private static String module = "A1-ADAPTER-API"; + private static String mode = "sync"; + + @Before + public void setUp() throws Exception { + + a1AdapterProviderMock = new A1AdapterProviderMock(dataBroker, mockNotificationPublishService, + mockRpcProviderRegistry, a1AdapterClient); + a1AdapterProviderMock = Mockito.spy(a1AdapterProviderMock); + + } + + @Test + public void test_deleteA1PolicyType() throws SvcLogicException, InterruptedException, ExecutionException { + String rpc = "deleteA1Policy"; + Properties respProps = new Properties(); + DeleteA1PolicyInputBuilder inputBuilder = new DeleteA1PolicyInputBuilder(); + when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); + when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(DeleteA1PolicyOutputBuilder.class), + any(Properties.class))).thenReturn(respProps); + ListenableFuture<RpcResult<DeleteA1PolicyOutput>> result = + a1AdapterProviderMock.deleteA1Policy(inputBuilder.build()); + assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); } - } - - private A1AdapterProviderMock a1AdapterProviderMock = null; - @Mock - private DataBroker dataBroker; - @Mock - private NotificationPublishService mockNotificationPublishService; - @Mock - private RpcProviderRegistry mockRpcProviderRegistry; - @Mock - private A1AdapterClient a1AdapterClient; - private static String module = "A1-ADAPTER-API"; - private static String mode = "sync"; - - @Before - public void setUp() throws Exception { - - a1AdapterProviderMock = new A1AdapterProviderMock(dataBroker, mockNotificationPublishService, - mockRpcProviderRegistry, a1AdapterClient); - a1AdapterProviderMock = Mockito.spy(a1AdapterProviderMock); - - } - - @Test - public void test_getA1PolicyType() - throws SvcLogicException, InterruptedException, ExecutionException { - String rpc = "getA1PolicyType"; - Properties respProps = new Properties(); - GetA1PolicyTypeInputBuilder inputBuilder = new GetA1PolicyTypeInputBuilder(); - when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); - when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), - any(GetA1PolicyTypeOutputBuilder.class), any(Properties.class))).thenReturn(respProps); - ListenableFuture<RpcResult<GetA1PolicyTypeOutput>> result = - a1AdapterProviderMock.getA1PolicyType(inputBuilder.build()); - assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); - } + @Test + public void test_getA1Policy() throws SvcLogicException, InterruptedException, ExecutionException { + String rpc = "getA1Policy"; + Properties respProps = new Properties(); + GetA1PolicyInputBuilder inputBuilder = new GetA1PolicyInputBuilder(); + when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); + when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetA1PolicyOutputBuilder.class), + any(Properties.class))).thenReturn(respProps); + ListenableFuture<RpcResult<GetA1PolicyOutput>> result = a1AdapterProviderMock.getA1Policy(inputBuilder.build()); + assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); + } + + @Test + public void test_getA1PolicyType() throws SvcLogicException, InterruptedException, ExecutionException { + String rpc = "getA1PolicyType"; + Properties respProps = new Properties(); + GetA1PolicyTypeInputBuilder inputBuilder = new GetA1PolicyTypeInputBuilder(); + when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); + when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetA1PolicyTypeOutputBuilder.class), + any(Properties.class))).thenReturn(respProps); + ListenableFuture<RpcResult<GetA1PolicyTypeOutput>> result = + a1AdapterProviderMock.getA1PolicyType(inputBuilder.build()); + assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); + } + + @Test + public void test_getA1PolicyStatus() throws SvcLogicException, InterruptedException, ExecutionException { + String rpc = "getA1PolicyStatus"; + Properties respProps = new Properties(); + GetA1PolicyStatusInputBuilder inputBuilder = new GetA1PolicyStatusInputBuilder(); + when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); + when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetA1PolicyStatusOutputBuilder.class), + any(Properties.class))).thenReturn(respProps); + ListenableFuture<RpcResult<GetA1PolicyStatusOutput>> result = + a1AdapterProviderMock.getA1PolicyStatus(inputBuilder.build()); + assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); + } + + @Test + public void test_putA1Policy() throws SvcLogicException, InterruptedException, ExecutionException { + String rpc = "putA1Policy"; + Properties respProps = new Properties(); + PutA1PolicyInputBuilder inputBuilder = new PutA1PolicyInputBuilder(); + when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true); + when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(PutA1PolicyOutputBuilder.class), + any(Properties.class))).thenReturn(respProps); + ListenableFuture<RpcResult<PutA1PolicyOutput>> result = a1AdapterProviderMock.putA1Policy(inputBuilder.build()); + assertEquals("200", String.valueOf(result.get().getResult().getHttpStatus())); + } } |