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