aboutsummaryrefslogtreecommitdiffstats
path: root/sdnr/northbound/a1Adapter/provider/src/test
diff options
context:
space:
mode:
authorLathish <lathishbabu.ganesan@est.tech>2020-07-16 15:46:14 +0100
committerLathish <lathishbabu.ganesan@est.tech>2020-07-20 16:20:40 +0100
commitad7220f5dcb8a3acd43bca1d855012a441e97d5c (patch)
tree459cda7b0134702cb7e1fc501e69b61cc9cd7533 /sdnr/northbound/a1Adapter/provider/src/test
parent96aeff5a753e008add7a879198ba3229f4b6016b (diff)
Updated A1 Yang model
Issue-ID: CCSDK-2581 Change-Id: I816cac765c2cf09c3d0911b98b3361ef8cb3696f Signed-off-by: Lathish <lathishbabu.ganesan@est.tech>
Diffstat (limited to 'sdnr/northbound/a1Adapter/provider/src/test')
-rw-r--r--sdnr/northbound/a1Adapter/provider/src/test/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProviderTest.java823
1 files changed, 1 insertions, 822 deletions
diff --git a/sdnr/northbound/a1Adapter/provider/src/test/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProviderTest.java b/sdnr/northbound/a1Adapter/provider/src/test/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProviderTest.java
index fa8a82c8f..8fea501ff 100644
--- a/sdnr/northbound/a1Adapter/provider/src/test/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProviderTest.java
+++ b/sdnr/northbound/a1Adapter/provider/src/test/java/org/onap/ccsdk/features/sdnr/northbound/a1Adapter/A1AdapterProviderTest.java
@@ -20,74 +20,6 @@
package org.onap.ccsdk.features.sdnr.northbound.a1Adapter;
-import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.Mockito.when;
-import com.google.common.util.concurrent.ListenableFuture;
-import java.util.Properties;
-import java.util.concurrent.ExecutionException;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.mockito.Mock;
-import org.mockito.Mockito;
-import org.mockito.junit.MockitoJUnitRunner;
-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.ccsdk.rev191212.CreatePolicyInstanceInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateInputBuilder;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutput;
-import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutputBuilder;
-import org.opendaylight.yangtools.concepts.Builder;
-import org.opendaylight.yangtools.yang.common.RpcResult;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
/**
* This class Tests all the methods in A1AdapterProvider
*
@@ -95,757 +27,4 @@ import org.slf4j.LoggerFactory;
*
*/
-@RunWith(MockitoJUnitRunner.Silent.class)
-public class A1AdapterProviderTest {
-
- protected static final Logger LOG = LoggerFactory.getLogger(A1AdapterProviderTest.class);
-
- class A1AdapterProviderMock extends A1AdapterProvider {
-
- A1AdapterProviderMock(final DataBroker dataBroker, final NotificationPublishService notificationPublishService,
- final RpcProviderRegistry rpcProviderRegistry, final A1AdapterClient A1AdapterClient) {
- super(dataBroker, mockNotificationPublishService, mockRpcProviderRegistry, a1AdapterClient);
- }
-
- @Override
- public Builder<?> getServiceData(String svcOperation) {
- return null;
- }
- }
-
- 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_GetNearRT_RICs() throws SvcLogicException, InterruptedException, ExecutionException {
- GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
- nearRTRICsOutputBuilder.setResponseCode("200");
- String rpc = "getNearRT-RICs";
- Properties respProps = new Properties();
- GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetNearRTRICsOutputBuilder.class),
- any(Properties.class))).thenReturn(respProps);
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
- ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
- a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_GetNearRT_RICs_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
- GetNearRTRICsInput getNearRTRICsInput = null;
- String rpc = "getNearRT-RICs";
- GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
- ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
- a1AdapterProviderMock.getNearRTRICs(getNearRTRICsInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_GetNearRT_RICs_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
- String rpc = "getNearRT-RICs";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
- GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
- a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_GetNearRT_RICs_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
- String rpc = "getNearRT-RICs";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
- GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
- a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_GetNearRT_RICs_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
- String rpc = "getNearRT-RICs";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
- GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetNearRTRICsOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
- a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getHealthCheck() throws SvcLogicException, InterruptedException, ExecutionException {
- String rpc = "getHealthCheck";
- Properties respProps = new Properties();
- GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
- healthCheckOutputBuilder.setResponseCode("200");
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
- GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetHealthCheckOutputBuilder.class),
- any(Properties.class))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
- a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getHealthCheck_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
- GetHealthCheckInput getHealthCheckInput = null;
- String rpc = "getHealthCheck";
- GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
- ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
- a1AdapterProviderMock.getHealthCheck(getHealthCheckInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getHealthCheck_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
- String rpc = "getHealthCheck";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
- GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
- a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getHealthCheck_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
- String rpc = "getHealthCheck";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
- GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
- a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getHealthCheck_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
- String rpc = "getHealthCheck";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
- GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetHealthCheckOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
- a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyTypes() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
- policyTypesOutputBuilder.setResponseCode("200");
- String rpc = "getPolicyTypes";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
- Properties respProps = new Properties();
- GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypesOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
- a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyTypes_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypesInput getHealthCheckInput = null;
- String rpc = "getPolicyTypes";
- GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
- ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
- a1AdapterProviderMock.getPolicyTypes(getHealthCheckInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyTypes_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
- String rpc = "getPolicyTypes";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
- GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
- a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyTypes_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
- String rpc = "getPolicyTypes";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
- GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
- a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyTypes_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
- String rpc = "getPolicyTypes";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
- GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypesOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
- a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
- createPolicyTypeOutputBuilder.setResponseCode("200");
- String rpc = "createPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
- Properties respProps = new Properties();
- CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(CreatePolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- a1AdapterProviderMock.createPolicyType(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyType_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyTypeInput createPolicyTypeInput = null;
- String rpc = "createPolicyType";
- CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- a1AdapterProviderMock.createPolicyType(createPolicyTypeInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
- String rpc = "createPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
- CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- a1AdapterProviderMock.createPolicyType(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyType_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
- String rpc = "createPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
- CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- a1AdapterProviderMock.createPolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyType_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
- String rpc = "createPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
- CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(CreatePolicyTypeOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- a1AdapterProviderMock.createPolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
- policyTypeOutputBuilder.setResponseCode("200");
- String rpc = "getPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
- Properties respProps = new Properties();
- GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
- a1AdapterProviderMock.getPolicyType(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyType_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypeInput getPolicyTypeInput = null;
- String rpc = "getPolicyType";
- GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
- ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
- a1AdapterProviderMock.getPolicyType(getPolicyTypeInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
- String rpc = "getPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
- GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
- a1AdapterProviderMock.getPolicyType(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyType_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
- String rpc = "getPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
- GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
- a1AdapterProviderMock.getPolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyType_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
- String rpc = "getPolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
- GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
- a1AdapterProviderMock.getPolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
- deletePolicyTypeOutputBuilder.setResponseCode("200");
- String rpc = "deletePolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
- Properties respProps = new Properties();
- DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
- a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyType_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyTypeInput deletePolicyTypeInput = null;
- String rpc = "deletePolicyType";
- DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
- ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
- a1AdapterProviderMock.deletePolicyType(deletePolicyTypeInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
- String rpc = "deletePolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
- DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
- a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyType_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
- String rpc = "deletePolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
- DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
- a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyType_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
- String rpc = "deletePolicyType";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
- DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(DeletePolicyTypeOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
- a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstances() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
- policyInstancesOutputBuilder.setResponseCode("200");
- String rpc = "getPolicyInstances";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
- Properties respProps = new Properties();
- GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
- a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstances_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstancesInput getPolicyInstancesInput = null;
- String rpc = "getPolicyInstances";
- GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
- ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
- a1AdapterProviderMock.getPolicyInstances(getPolicyInstancesInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstances_With_No_DG()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
- String rpc = "getPolicyInstances";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
- GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
- a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstances_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
- String rpc = "getPolicyInstances";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
- GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
- a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstances_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
- String rpc = "getPolicyInstances";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
- GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
- any(GetPolicyInstancesOutputBuilder.class), any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
- a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
- createPolicyInstanceOutputBuilder.setResponseCode("200");
- String rpc = "createPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
- Properties respProps = new Properties();
- CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
- any(CreatePolicyInstanceOutputBuilder.class), eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
- a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyInstance_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyInstanceInput createPolicyInstanceInput = null;
- String rpc = "createPolicyInstance";
- CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
- ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
- a1AdapterProviderMock.createPolicyInstance(createPolicyInstanceInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyInstance_With_No_DG()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
- String rpc = "createPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
- CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
- a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyInstance_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
- String rpc = "createPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
- CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
- a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_createPolicyInstance_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
- String rpc = "createPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
- CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
- any(CreatePolicyInstanceOutputBuilder.class), any(Properties.class)))
- .thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
- a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
- policyInstanceOutputBuilder.setResponseCode("200");
- String rpc = "getPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
- Properties respProps = new Properties();
- GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
- a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstance_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstanceInput getPolicyInstanceInput = null;
- String rpc = "getPolicyInstance";
- GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
- ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
- a1AdapterProviderMock.getPolicyInstance(getPolicyInstanceInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstance_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
- String rpc = "getPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
- GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
- a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstance_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
- String rpc = "getPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
- GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
- a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getPolicyInstance_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
- String rpc = "getPolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
- GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyInstanceOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
- a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
- deletePolicyInstanceOutputBuilder.setResponseCode("200");
- String rpc = "deletePolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
- Properties respProps = new Properties();
- DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
- a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyInstance_With_No_Input()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyInstanceInput deletePolicyInstanceInput = null;
- String rpc = "deletePolicyInstance";
- DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
- ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
- a1AdapterProviderMock.deletePolicyInstance(deletePolicyInstanceInput);
- assertEquals("Input is null", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyInstance_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
- String rpc = "deletePolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
- DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
- ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
- a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
- assertEquals("503", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyInstance_With_DG_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
- String rpc = "deletePolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
- DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
- a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_deletePolicyInstance_With_DG_Execute_Exception()
- throws SvcLogicException, InterruptedException, ExecutionException {
- DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
- String rpc = "deletePolicyInstance";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
- DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(DeletePolicyInstanceOutputBuilder.class),
- any(Properties.class))).thenThrow(new SvcLogicException());
- ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
- a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
- assertEquals("500", result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_getStatus() throws SvcLogicException, InterruptedException, ExecutionException {
- GetStatusOutputBuilder statusOutputBuilder = new GetStatusOutputBuilder();
- statusOutputBuilder.setResponseCode("200");
- String rpc = "getStatus";
- when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) statusOutputBuilder);
- Properties respProps = new Properties();
- GetStatusInputBuilder inputBuilder = new GetStatusInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<GetStatusOutput>> result = a1AdapterProviderMock.getStatus(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
- @Test
- public void test_notifyPolicyEnforcementUpdate()
- throws SvcLogicException, InterruptedException, ExecutionException {
- NotifyPolicyEnforcementUpdateOutputBuilder notifyPolicyEnforcementUpdateOutputBuilder =
- new NotifyPolicyEnforcementUpdateOutputBuilder();
- notifyPolicyEnforcementUpdateOutputBuilder.setResponseCode("200");
- String rpc = "notifyPolicyEnforcementUpdate";
- when(a1AdapterProviderMock.getServiceData(rpc))
- .thenReturn((Builder) notifyPolicyEnforcementUpdateOutputBuilder);
- Properties respProps = new Properties();
- NotifyPolicyEnforcementUpdateInputBuilder inputBuilder = new NotifyPolicyEnforcementUpdateInputBuilder();
- when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
- when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
- eq(null))).thenReturn(respProps);
- ListenableFuture<RpcResult<NotifyPolicyEnforcementUpdateOutput>> result =
- a1AdapterProviderMock.notifyPolicyEnforcementUpdate(inputBuilder.build());
- assertEquals("200",result.get().getResult().getResponseCode());
- }
-
-
-}
+public class A1AdapterProviderTest {} \ No newline at end of file