gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2020 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.ccsdk.features.sdnr.northbound.a1Adapter;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.mockito.ArgumentMatchers.any;
  26 import static org.mockito.ArgumentMatchers.eq;
  27 import static org.mockito.Mockito.when;
  28 import com.google.common.util.concurrent.ListenableFuture;
  29 import java.util.Properties;
  30 import java.util.concurrent.ExecutionException;
  31 import org.junit.Before;
  32 import org.junit.Test;
  33 import org.junit.runner.RunWith;
  34 import org.mockito.Mock;
  35 import org.mockito.Mockito;
  36 import org.mockito.junit.MockitoJUnitRunner;
  37 import org.onap.ccsdk.sli.core.sli.SvcLogicException;
  38 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  39 import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
  40 import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
  41 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceInput;
  42 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceInputBuilder;
  43 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutput;
  44 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyInstanceOutputBuilder;
  45 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInput;
  46 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeInputBuilder;
  47 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutput;
  48 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.CreatePolicyTypeOutputBuilder;
  49 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInput;
  50 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceInputBuilder;
  51 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutput;
  52 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyInstanceOutputBuilder;
  53 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInput;
  54 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeInputBuilder;
  55 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutput;
  56 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.DeletePolicyTypeOutputBuilder;
  57 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInput;
  58 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckInputBuilder;
  59 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutput;
  60 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetHealthCheckOutputBuilder;
  61 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInput;
  62 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsInputBuilder;
  63 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutput;
  64 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetNearRTRICsOutputBuilder;
  65 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInput;
  66 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceInputBuilder;
  67 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutput;
  68 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstanceOutputBuilder;
  69 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInput;
  70 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesInputBuilder;
  71 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutput;
  72 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyInstancesOutputBuilder;
  73 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInput;
  74 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeInputBuilder;
  75 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutput;
  76 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypeOutputBuilder;
  77 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInput;
  78 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesInputBuilder;
  79 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutput;
  80 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetPolicyTypesOutputBuilder;
  81 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusInputBuilder;
  82 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutput;
  83 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.GetStatusOutputBuilder;
  84 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateInputBuilder;
  85 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutput;
  86 import org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev191212.NotifyPolicyEnforcementUpdateOutputBuilder;
  87 import org.opendaylight.yangtools.concepts.Builder;
  88 import org.opendaylight.yangtools.yang.common.RpcResult;
  89 import org.slf4j.Logger;
  90 import org.slf4j.LoggerFactory;
  91
  92 /**
  93  * This class Tests all the methods in A1AdapterProvider
  94  *
  95  * @author lathishbabu.ganesan@est.tech
  96  *
  97  */
  98
  99 @RunWith(MockitoJUnitRunner.Silent.class)
 100 public class A1AdapterProviderTest {
 101
 102     protected static final Logger LOG = LoggerFactory.getLogger(A1AdapterProviderTest.class);
 103
 104     class A1AdapterProviderMock extends A1AdapterProvider {
 105
 106         A1AdapterProviderMock(final DataBroker dataBroker, final NotificationPublishService notificationPublishService,
 107                 final RpcProviderRegistry rpcProviderRegistry, final A1AdapterClient A1AdapterClient) {
 108             super(dataBroker, mockNotificationPublishService, mockRpcProviderRegistry, a1AdapterClient);
 109         }
 110
 111         @Override
 112         public Builder<?> getServiceData(String svcOperation) {
 113             return null;
 114         }
 115     }
 116
 117     private A1AdapterProviderMock a1AdapterProviderMock = null;
 118     @Mock
 119     private DataBroker dataBroker;
 120     @Mock
 121     private NotificationPublishService mockNotificationPublishService;
 122     @Mock
 123     private RpcProviderRegistry mockRpcProviderRegistry;
 124     @Mock
 125     private A1AdapterClient a1AdapterClient;
 126     private static String module = "A1-ADAPTER-API";
 127     private static String mode = "sync";
 128
 129     @Before
 130     public void setUp() throws Exception {
 131
 132         a1AdapterProviderMock = new A1AdapterProviderMock(dataBroker, mockNotificationPublishService,
 133                 mockRpcProviderRegistry, a1AdapterClient);
 134         a1AdapterProviderMock = Mockito.spy(a1AdapterProviderMock);
 135
 136     }
 137
 138     @Test
 139     public void test_GetNearRT_RICs() throws SvcLogicException, InterruptedException, ExecutionException {
 140         GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
 141         nearRTRICsOutputBuilder.setResponseCode("200");
 142         String rpc = "getNearRT-RICs";
 143         Properties respProps = new Properties();
 144         GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
 145         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 146         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetNearRTRICsOutputBuilder.class),
 147                 any(Properties.class))).thenReturn(respProps);
 148         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
 149         ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
 150                 a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
 151         assertNotNull(result.get().getResult().getResponseCode());
 152     }
 153
 154     @Test
 155     public void test_GetNearRT_RICs_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
 156         GetNearRTRICsInput getNearRTRICsInput = null;
 157         String rpc = "getNearRT-RICs";
 158         GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
 159         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
 160         ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
 161                 a1AdapterProviderMock.getNearRTRICs(getNearRTRICsInput);
 162         assertEquals("Input is null", result.get().getResult().getResponseCode());
 163     }
 164
 165     @Test
 166     public void test_GetNearRT_RICs_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 167         GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
 168         String rpc = "getNearRT-RICs";
 169         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
 170         GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
 171         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 172         ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
 173                 a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
 174         assertEquals("503", result.get().getResult().getResponseCode());
 175     }
 176
 177     @Test
 178     public void test_GetNearRT_RICs_With_DG_Exception()
 179             throws SvcLogicException, InterruptedException, ExecutionException {
 180         GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
 181         String rpc = "getNearRT-RICs";
 182         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
 183         GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
 184         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 185         ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
 186                 a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
 187         assertEquals("500", result.get().getResult().getResponseCode());
 188     }
 189
 190     @Test
 191     public void test_GetNearRT_RICs_With_DG_Execute_Exception()
 192             throws SvcLogicException, InterruptedException, ExecutionException {
 193         GetNearRTRICsOutputBuilder nearRTRICsOutputBuilder = new GetNearRTRICsOutputBuilder();
 194         String rpc = "getNearRT-RICs";
 195         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) nearRTRICsOutputBuilder);
 196         GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
 197         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 198         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetNearRTRICsOutputBuilder.class),
 199                 any(Properties.class))).thenThrow(new SvcLogicException());
 200         ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
 201                 a1AdapterProviderMock.getNearRTRICs(inputBuilder.build());
 202         assertEquals("500", result.get().getResult().getResponseCode());
 203     }
 204
 205     @Test
 206     public void test_getHealthCheck() throws SvcLogicException, InterruptedException, ExecutionException {
 207         String rpc = "getHealthCheck";
 208         Properties respProps = new Properties();
 209         GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
 210         healthCheckOutputBuilder.setResponseCode("200");
 211         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
 212         GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
 213         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 214         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetHealthCheckOutputBuilder.class),
 215                 any(Properties.class))).thenReturn(respProps);
 216         ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
 217                 a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
 218         assertNotNull(result.get().getResult().getResponseCode());
 219     }
 220
 221     @Test
 222     public void test_getHealthCheck_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
 223         GetHealthCheckInput getHealthCheckInput = null;
 224         String rpc = "getHealthCheck";
 225         GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
 226         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
 227         ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
 228                 a1AdapterProviderMock.getHealthCheck(getHealthCheckInput);
 229         assertEquals("Input is null", result.get().getResult().getResponseCode());
 230     }
 231
 232     @Test
 233     public void test_getHealthCheck_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 234         GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
 235         String rpc = "getHealthCheck";
 236         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
 237         GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
 238         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 239         ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
 240                 a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
 241         assertEquals("503", result.get().getResult().getResponseCode());
 242     }
 243
 244     @Test
 245     public void test_getHealthCheck_With_DG_Exception()
 246             throws SvcLogicException, InterruptedException, ExecutionException {
 247         GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
 248         String rpc = "getHealthCheck";
 249         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
 250         GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
 251         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 252         ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
 253                 a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
 254         assertEquals("500", result.get().getResult().getResponseCode());
 255     }
 256
 257     @Test
 258     public void test_getHealthCheck_With_DG_Execute_Exception()
 259             throws SvcLogicException, InterruptedException, ExecutionException {
 260         GetHealthCheckOutputBuilder healthCheckOutputBuilder = new GetHealthCheckOutputBuilder();
 261         String rpc = "getHealthCheck";
 262         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) healthCheckOutputBuilder);
 263         GetHealthCheckInputBuilder inputBuilder = new GetHealthCheckInputBuilder();
 264         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 265         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetHealthCheckOutputBuilder.class),
 266                 any(Properties.class))).thenThrow(new SvcLogicException());
 267         ListenableFuture<RpcResult<GetHealthCheckOutput>> result =
 268                 a1AdapterProviderMock.getHealthCheck(inputBuilder.build());
 269         assertEquals("500", result.get().getResult().getResponseCode());
 270     }
 271
 272     @Test
 273     public void test_getPolicyTypes() throws SvcLogicException, InterruptedException, ExecutionException {
 274         GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
 275         policyTypesOutputBuilder.setResponseCode("200");
 276         String rpc = "getPolicyTypes";
 277         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
 278         Properties respProps = new Properties();
 279         GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
 280         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 281         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypesOutputBuilder.class),
 282                 eq(null))).thenReturn(respProps);
 283         ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
 284                 a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
 285         assertNotNull(result.get().getResult().getResponseCode());
 286     }
 287
 288     @Test
 289     public void test_getPolicyTypes_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
 290         GetPolicyTypesInput getHealthCheckInput = null;
 291         String rpc = "getPolicyTypes";
 292         GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
 293         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
 294         ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
 295                 a1AdapterProviderMock.getPolicyTypes(getHealthCheckInput);
 296         assertEquals("Input is null", result.get().getResult().getResponseCode());
 297     }
 298
 299     @Test
 300     public void test_getPolicyTypes_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 301         GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
 302         String rpc = "getPolicyTypes";
 303         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
 304         GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
 305         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 306         ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
 307                 a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
 308         assertEquals("503", result.get().getResult().getResponseCode());
 309     }
 310
 311     @Test
 312     public void test_getPolicyTypes_With_DG_Exception()
 313             throws SvcLogicException, InterruptedException, ExecutionException {
 314         GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
 315         String rpc = "getPolicyTypes";
 316         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
 317         GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
 318         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 319         ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
 320                 a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
 321         assertEquals("500", result.get().getResult().getResponseCode());
 322     }
 323
 324     @Test
 325     public void test_getPolicyTypes_With_DG_Execute_Exception()
 326             throws SvcLogicException, InterruptedException, ExecutionException {
 327         GetPolicyTypesOutputBuilder policyTypesOutputBuilder = new GetPolicyTypesOutputBuilder();
 328         String rpc = "getPolicyTypes";
 329         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypesOutputBuilder);
 330         GetPolicyTypesInputBuilder inputBuilder = new GetPolicyTypesInputBuilder();
 331         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 332         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypesOutputBuilder.class),
 333                 any(Properties.class))).thenThrow(new SvcLogicException());
 334         ListenableFuture<RpcResult<GetPolicyTypesOutput>> result =
 335                 a1AdapterProviderMock.getPolicyTypes(inputBuilder.build());
 336         assertEquals("500", result.get().getResult().getResponseCode());
 337     }
 338
 339     @Test
 340     public void test_createPolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
 341         CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
 342         createPolicyTypeOutputBuilder.setResponseCode("200");
 343         String rpc = "createPolicyType";
 344         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
 345         Properties respProps = new Properties();
 346         CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
 347         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 348         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(CreatePolicyTypeOutputBuilder.class),
 349                 eq(null))).thenReturn(respProps);
 350         ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
 351                 a1AdapterProviderMock.createPolicyType(inputBuilder.build());
 352         assertNotNull(result.get().getResult().getResponseCode());
 353     }
 354
 355     @Test
 356     public void test_createPolicyType_With_No_Input()
 357             throws SvcLogicException, InterruptedException, ExecutionException {
 358         CreatePolicyTypeInput createPolicyTypeInput = null;
 359         String rpc = "createPolicyType";
 360         CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
 361         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
 362         ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
 363                 a1AdapterProviderMock.createPolicyType(createPolicyTypeInput);
 364         assertEquals("Input is null", result.get().getResult().getResponseCode());
 365     }
 366
 367     @Test
 368     public void test_createPolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 369         CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
 370         String rpc = "createPolicyType";
 371         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
 372         CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
 373         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 374         ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
 375                 a1AdapterProviderMock.createPolicyType(inputBuilder.build());
 376         assertEquals("503", result.get().getResult().getResponseCode());
 377     }
 378
 379     @Test
 380     public void test_createPolicyType_With_DG_Exception()
 381             throws SvcLogicException, InterruptedException, ExecutionException {
 382         CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
 383         String rpc = "createPolicyType";
 384         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
 385         CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
 386         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 387         ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
 388                 a1AdapterProviderMock.createPolicyType(inputBuilder.build());
 389         assertEquals("500", result.get().getResult().getResponseCode());
 390     }
 391
 392     @Test
 393     public void test_createPolicyType_With_DG_Execute_Exception()
 394             throws SvcLogicException, InterruptedException, ExecutionException {
 395         CreatePolicyTypeOutputBuilder createPolicyTypeOutputBuilder = new CreatePolicyTypeOutputBuilder();
 396         String rpc = "createPolicyType";
 397         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyTypeOutputBuilder);
 398         CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
 399         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 400         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(CreatePolicyTypeOutputBuilder.class),
 401                 any(Properties.class))).thenThrow(new SvcLogicException());
 402         ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
 403                 a1AdapterProviderMock.createPolicyType(inputBuilder.build());
 404         assertEquals("500", result.get().getResult().getResponseCode());
 405     }
 406
 407     @Test
 408     public void test_getPolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
 409         GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
 410         policyTypeOutputBuilder.setResponseCode("200");
 411         String rpc = "getPolicyType";
 412         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
 413         Properties respProps = new Properties();
 414         GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
 415         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 416         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 417                 eq(null))).thenReturn(respProps);
 418         ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
 419                 a1AdapterProviderMock.getPolicyType(inputBuilder.build());
 420         assertNotNull(result.get().getResult().getResponseCode());
 421     }
 422
 423     @Test
 424     public void test_getPolicyType_With_No_Input() throws SvcLogicException, InterruptedException, ExecutionException {
 425         GetPolicyTypeInput getPolicyTypeInput = null;
 426         String rpc = "getPolicyType";
 427         GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
 428         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
 429         ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
 430                 a1AdapterProviderMock.getPolicyType(getPolicyTypeInput);
 431         assertEquals("Input is null", result.get().getResult().getResponseCode());
 432     }
 433
 434     @Test
 435     public void test_getPolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 436         GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
 437         String rpc = "getPolicyType";
 438         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
 439         GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
 440         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 441         ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
 442                 a1AdapterProviderMock.getPolicyType(inputBuilder.build());
 443         assertEquals("503", result.get().getResult().getResponseCode());
 444     }
 445
 446     @Test
 447     public void test_getPolicyType_With_DG_Exception()
 448             throws SvcLogicException, InterruptedException, ExecutionException {
 449         GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
 450         String rpc = "getPolicyType";
 451         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
 452         GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
 453         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 454         ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
 455                 a1AdapterProviderMock.getPolicyType(inputBuilder.build());
 456         assertEquals("500", result.get().getResult().getResponseCode());
 457     }
 458
 459     @Test
 460     public void test_getPolicyType_With_DG_Execute_Exception()
 461             throws SvcLogicException, InterruptedException, ExecutionException {
 462         GetPolicyTypeOutputBuilder policyTypeOutputBuilder = new GetPolicyTypeOutputBuilder();
 463         String rpc = "getPolicyType";
 464         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyTypeOutputBuilder);
 465         GetPolicyTypeInputBuilder inputBuilder = new GetPolicyTypeInputBuilder();
 466         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 467         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 468                 any(Properties.class))).thenThrow(new SvcLogicException());
 469         ListenableFuture<RpcResult<GetPolicyTypeOutput>> result =
 470                 a1AdapterProviderMock.getPolicyType(inputBuilder.build());
 471         assertEquals("500", result.get().getResult().getResponseCode());
 472     }
 473
 474     @Test
 475     public void test_deletePolicyType() throws SvcLogicException, InterruptedException, ExecutionException {
 476         DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
 477         deletePolicyTypeOutputBuilder.setResponseCode("200");
 478         String rpc = "deletePolicyType";
 479         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
 480         Properties respProps = new Properties();
 481         DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
 482         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 483         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 484                 eq(null))).thenReturn(respProps);
 485         ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
 486                 a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
 487         assertNotNull(result.get().getResult().getResponseCode());
 488     }
 489
 490     @Test
 491     public void test_deletePolicyType_With_No_Input()
 492             throws SvcLogicException, InterruptedException, ExecutionException {
 493         DeletePolicyTypeInput deletePolicyTypeInput = null;
 494         String rpc = "deletePolicyType";
 495         DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
 496         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
 497         ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
 498                 a1AdapterProviderMock.deletePolicyType(deletePolicyTypeInput);
 499         assertEquals("Input is null", result.get().getResult().getResponseCode());
 500     }
 501
 502     @Test
 503     public void test_deletePolicyType_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 504         DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
 505         String rpc = "deletePolicyType";
 506         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
 507         DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
 508         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 509         ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
 510                 a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
 511         assertEquals("503", result.get().getResult().getResponseCode());
 512     }
 513
 514     @Test
 515     public void test_deletePolicyType_With_DG_Exception()
 516             throws SvcLogicException, InterruptedException, ExecutionException {
 517         DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
 518         String rpc = "deletePolicyType";
 519         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
 520         DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
 521         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 522         ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
 523                 a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
 524         assertEquals("500", result.get().getResult().getResponseCode());
 525     }
 526
 527     @Test
 528     public void test_deletePolicyType_With_DG_Execute_Exception()
 529             throws SvcLogicException, InterruptedException, ExecutionException {
 530         DeletePolicyTypeOutputBuilder deletePolicyTypeOutputBuilder = new DeletePolicyTypeOutputBuilder();
 531         String rpc = "deletePolicyType";
 532         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyTypeOutputBuilder);
 533         DeletePolicyTypeInputBuilder inputBuilder = new DeletePolicyTypeInputBuilder();
 534         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 535         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(DeletePolicyTypeOutputBuilder.class),
 536                 any(Properties.class))).thenThrow(new SvcLogicException());
 537         ListenableFuture<RpcResult<DeletePolicyTypeOutput>> result =
 538                 a1AdapterProviderMock.deletePolicyType(inputBuilder.build());
 539         assertEquals("500", result.get().getResult().getResponseCode());
 540     }
 541
 542     @Test
 543     public void test_getPolicyInstances() throws SvcLogicException, InterruptedException, ExecutionException {
 544         GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
 545         policyInstancesOutputBuilder.setResponseCode("200");
 546         String rpc = "getPolicyInstances";
 547         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
 548         Properties respProps = new Properties();
 549         GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
 550         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 551         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 552                 eq(null))).thenReturn(respProps);
 553         ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
 554                 a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
 555         assertNotNull(result.get().getResult().getResponseCode());
 556     }
 557
 558     @Test
 559     public void test_getPolicyInstances_With_No_Input()
 560             throws SvcLogicException, InterruptedException, ExecutionException {
 561         GetPolicyInstancesInput getPolicyInstancesInput = null;
 562         String rpc = "getPolicyInstances";
 563         GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
 564         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
 565         ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
 566                 a1AdapterProviderMock.getPolicyInstances(getPolicyInstancesInput);
 567         assertEquals("Input is null", result.get().getResult().getResponseCode());
 568     }
 569
 570     @Test
 571     public void test_getPolicyInstances_With_No_DG()
 572             throws SvcLogicException, InterruptedException, ExecutionException {
 573         GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
 574         String rpc = "getPolicyInstances";
 575         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
 576         GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
 577         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 578         ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
 579                 a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
 580         assertEquals("503", result.get().getResult().getResponseCode());
 581     }
 582
 583     @Test
 584     public void test_getPolicyInstances_With_DG_Exception()
 585             throws SvcLogicException, InterruptedException, ExecutionException {
 586         GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
 587         String rpc = "getPolicyInstances";
 588         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
 589         GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
 590         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 591         ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
 592                 a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
 593         assertEquals("500", result.get().getResult().getResponseCode());
 594     }
 595
 596     @Test
 597     public void test_getPolicyInstances_With_DG_Execute_Exception()
 598             throws SvcLogicException, InterruptedException, ExecutionException {
 599         GetPolicyInstancesOutputBuilder policyInstancesOutputBuilder = new GetPolicyInstancesOutputBuilder();
 600         String rpc = "getPolicyInstances";
 601         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstancesOutputBuilder);
 602         GetPolicyInstancesInputBuilder inputBuilder = new GetPolicyInstancesInputBuilder();
 603         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 604         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
 605                 any(GetPolicyInstancesOutputBuilder.class), any(Properties.class))).thenThrow(new SvcLogicException());
 606         ListenableFuture<RpcResult<GetPolicyInstancesOutput>> result =
 607                 a1AdapterProviderMock.getPolicyInstances(inputBuilder.build());
 608         assertEquals("500", result.get().getResult().getResponseCode());
 609     }
 610
 611     @Test
 612     public void test_createPolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
 613         CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
 614         createPolicyInstanceOutputBuilder.setResponseCode("200");
 615         String rpc = "createPolicyInstance";
 616         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
 617         Properties respProps = new Properties();
 618         CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
 619         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 620         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
 621                 any(CreatePolicyInstanceOutputBuilder.class), eq(null))).thenReturn(respProps);
 622         ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
 623                 a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
 624         assertNotNull(result.get().getResult().getResponseCode());
 625     }
 626
 627     @Test
 628     public void test_createPolicyInstance_With_No_Input()
 629             throws SvcLogicException, InterruptedException, ExecutionException {
 630         CreatePolicyInstanceInput createPolicyInstanceInput = null;
 631         String rpc = "createPolicyInstance";
 632         CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
 633         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
 634         ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
 635                 a1AdapterProviderMock.createPolicyInstance(createPolicyInstanceInput);
 636         assertEquals("Input is null", result.get().getResult().getResponseCode());
 637     }
 638
 639     @Test
 640     public void test_createPolicyInstance_With_No_DG()
 641             throws SvcLogicException, InterruptedException, ExecutionException {
 642         CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
 643         String rpc = "createPolicyInstance";
 644         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
 645         CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
 646         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 647         ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
 648                 a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
 649         assertEquals("503", result.get().getResult().getResponseCode());
 650     }
 651
 652     @Test
 653     public void test_createPolicyInstance_With_DG_Exception()
 654             throws SvcLogicException, InterruptedException, ExecutionException {
 655         CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
 656         String rpc = "createPolicyInstance";
 657         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
 658         CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
 659         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 660         ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
 661                 a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
 662         assertEquals("500", result.get().getResult().getResponseCode());
 663     }
 664
 665     @Test
 666     public void test_createPolicyInstance_With_DG_Execute_Exception()
 667             throws SvcLogicException, InterruptedException, ExecutionException {
 668         CreatePolicyInstanceOutputBuilder createPolicyInstanceOutputBuilder = new CreatePolicyInstanceOutputBuilder();
 669         String rpc = "createPolicyInstance";
 670         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) createPolicyInstanceOutputBuilder);
 671         CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
 672         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 673         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode),
 674                 any(CreatePolicyInstanceOutputBuilder.class), any(Properties.class)))
 675                         .thenThrow(new SvcLogicException());
 676         ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
 677                 a1AdapterProviderMock.createPolicyInstance(inputBuilder.build());
 678         assertEquals("500", result.get().getResult().getResponseCode());
 679     }
 680
 681     @Test
 682     public void test_getPolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
 683         GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
 684         policyInstanceOutputBuilder.setResponseCode("200");
 685         String rpc = "getPolicyInstance";
 686         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
 687         Properties respProps = new Properties();
 688         GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
 689         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 690         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 691                 eq(null))).thenReturn(respProps);
 692         ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
 693                 a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
 694         assertNotNull(result.get().getResult().getResponseCode());
 695     }
 696
 697     @Test
 698     public void test_getPolicyInstance_With_No_Input()
 699             throws SvcLogicException, InterruptedException, ExecutionException {
 700         GetPolicyInstanceInput getPolicyInstanceInput = null;
 701         String rpc = "getPolicyInstance";
 702         GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
 703         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
 704         ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
 705                 a1AdapterProviderMock.getPolicyInstance(getPolicyInstanceInput);
 706         assertEquals("Input is null", result.get().getResult().getResponseCode());
 707     }
 708
 709     @Test
 710     public void test_getPolicyInstance_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 711         GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
 712         String rpc = "getPolicyInstance";
 713         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
 714         GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
 715         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 716         ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
 717                 a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
 718         assertEquals("503", result.get().getResult().getResponseCode());
 719     }
 720
 721     @Test
 722     public void test_getPolicyInstance_With_DG_Exception()
 723             throws SvcLogicException, InterruptedException, ExecutionException {
 724         GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
 725         String rpc = "getPolicyInstance";
 726         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
 727         GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
 728         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 729         ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
 730                 a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
 731         assertEquals("500", result.get().getResult().getResponseCode());
 732     }
 733
 734     @Test
 735     public void test_getPolicyInstance_With_DG_Execute_Exception()
 736             throws SvcLogicException, InterruptedException, ExecutionException {
 737         GetPolicyInstanceOutputBuilder policyInstanceOutputBuilder = new GetPolicyInstanceOutputBuilder();
 738         String rpc = "getPolicyInstance";
 739         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) policyInstanceOutputBuilder);
 740         GetPolicyInstanceInputBuilder inputBuilder = new GetPolicyInstanceInputBuilder();
 741         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 742         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyInstanceOutputBuilder.class),
 743                 any(Properties.class))).thenThrow(new SvcLogicException());
 744         ListenableFuture<RpcResult<GetPolicyInstanceOutput>> result =
 745                 a1AdapterProviderMock.getPolicyInstance(inputBuilder.build());
 746         assertEquals("500", result.get().getResult().getResponseCode());
 747     }
 748
 749     @Test
 750     public void test_deletePolicyInstance() throws SvcLogicException, InterruptedException, ExecutionException {
 751         DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
 752         deletePolicyInstanceOutputBuilder.setResponseCode("200");
 753         String rpc = "deletePolicyInstance";
 754         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
 755         Properties respProps = new Properties();
 756         DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
 757         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 758         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 759                 eq(null))).thenReturn(respProps);
 760         ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
 761                 a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
 762         assertNotNull(result.get().getResult().getResponseCode());
 763     }
 764
 765     @Test
 766     public void test_deletePolicyInstance_With_No_Input()
 767             throws SvcLogicException, InterruptedException, ExecutionException {
 768         DeletePolicyInstanceInput deletePolicyInstanceInput = null;
 769         String rpc = "deletePolicyInstance";
 770         DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
 771         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
 772         ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
 773                 a1AdapterProviderMock.deletePolicyInstance(deletePolicyInstanceInput);
 774         assertEquals("Input is null", result.get().getResult().getResponseCode());
 775     }
 776
 777     @Test
 778     public void test_deletePolicyInstance_With_No_DG() throws SvcLogicException, InterruptedException, ExecutionException {
 779         DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
 780         String rpc = "deletePolicyInstance";
 781         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
 782         DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
 783         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(Boolean.FALSE);
 784         ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
 785                 a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
 786         assertEquals("503", result.get().getResult().getResponseCode());
 787     }
 788
 789     @Test
 790     public void test_deletePolicyInstance_With_DG_Exception()
 791             throws SvcLogicException, InterruptedException, ExecutionException {
 792         DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
 793         String rpc = "deletePolicyInstance";
 794         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
 795         DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
 796         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenThrow(new SvcLogicException());
 797         ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
 798                 a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
 799         assertEquals("500", result.get().getResult().getResponseCode());
 800     }
 801
 802     @Test
 803     public void test_deletePolicyInstance_With_DG_Execute_Exception()
 804             throws SvcLogicException, InterruptedException, ExecutionException {
 805         DeletePolicyInstanceOutputBuilder deletePolicyInstanceOutputBuilder = new DeletePolicyInstanceOutputBuilder();
 806         String rpc = "deletePolicyInstance";
 807         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) deletePolicyInstanceOutputBuilder);
 808         DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
 809         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 810         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(DeletePolicyInstanceOutputBuilder.class),
 811                 any(Properties.class))).thenThrow(new SvcLogicException());
 812         ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
 813                 a1AdapterProviderMock.deletePolicyInstance(inputBuilder.build());
 814         assertEquals("500", result.get().getResult().getResponseCode());
 815     }
 816
 817     @Test
 818     public void test_getStatus() throws SvcLogicException, InterruptedException, ExecutionException {
 819         GetStatusOutputBuilder statusOutputBuilder = new GetStatusOutputBuilder();
 820         statusOutputBuilder.setResponseCode("200");
 821         String rpc = "getStatus";
 822         when(a1AdapterProviderMock.getServiceData(rpc)).thenReturn((Builder) statusOutputBuilder);
 823         Properties respProps = new Properties();
 824         GetStatusInputBuilder inputBuilder = new GetStatusInputBuilder();
 825         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 826         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 827                 eq(null))).thenReturn(respProps);
 828         ListenableFuture<RpcResult<GetStatusOutput>> result = a1AdapterProviderMock.getStatus(inputBuilder.build());
 829         assertNotNull(result.get().getResult().getResponseCode());
 830     }
 831
 832     @Test
 833     public void test_notifyPolicyEnforcementUpdate()
 834             throws SvcLogicException, InterruptedException, ExecutionException {
 835         NotifyPolicyEnforcementUpdateOutputBuilder notifyPolicyEnforcementUpdateOutputBuilder =
 836                 new NotifyPolicyEnforcementUpdateOutputBuilder();
 837         notifyPolicyEnforcementUpdateOutputBuilder.setResponseCode("200");
 838         String rpc = "notifyPolicyEnforcementUpdate";
 839         when(a1AdapterProviderMock.getServiceData(rpc))
 840                 .thenReturn((Builder) notifyPolicyEnforcementUpdateOutputBuilder);
 841         Properties respProps = new Properties();
 842         NotifyPolicyEnforcementUpdateInputBuilder inputBuilder = new NotifyPolicyEnforcementUpdateInputBuilder();
 843         when(a1AdapterClient.hasGraph(module, rpc, null, mode)).thenReturn(true);
 844         when(a1AdapterClient.execute(eq(module), eq(rpc), eq(null), eq(mode), any(GetPolicyTypeOutputBuilder.class),
 845                 eq(null))).thenReturn(respProps);
 846         ListenableFuture<RpcResult<NotifyPolicyEnforcementUpdateOutput>> result =
 847                 a1AdapterProviderMock.notifyPolicyEnforcementUpdate(inputBuilder.build());
 848         assertNotNull(result.get().getResult().getResponseCode());
 849     }
 850
 851
 852 }