+ @Test
+ public void testCreatePolicyInstance() throws InterruptedException, ExecutionException {
+ CreatePolicyInstanceInputBuilder inputBuilder = new CreatePolicyInstanceInputBuilder();
+ inputBuilder.setNearRtRicId(nearRtRicId);
+ inputBuilder.setPolicyTypeId(policyTypeId);
+ inputBuilder.setPolicyInstanceId(policyTypeInstanceId);
+ Whitebox.setInternalState(nonrtRicApiProvider, "restAdapter", restAdapter);
+ String uri = nearRicUrlProvider.getPolicyInstanceId(inputBuilder.build().getNearRtRicId(),
+ String.valueOf(inputBuilder.build().getPolicyTypeId()), inputBuilder.getPolicyInstanceId());
+ ResponseEntity<Object> createPolicyInstanceResponse = new ResponseEntity<>(HttpStatus.CREATED);
+ when(restAdapter.put(eq(uri), anyObject())).thenReturn(createPolicyInstanceResponse);
+ ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> result =
+ nonrtRicApiProvider.createPolicyInstance(inputBuilder.build());
+ Assert.assertEquals(String.valueOf(HttpStatus.CREATED.value()), result.get().getResult().getCode());
+ }
+
+ @Test
+ public void testDeletePolicyInstance() throws InterruptedException, ExecutionException {
+ DeletePolicyInstanceInputBuilder inputBuilder = new DeletePolicyInstanceInputBuilder();
+ inputBuilder.setNearRtRicId(nearRtRicId);
+ inputBuilder.setPolicyTypeId(policyTypeId);
+ inputBuilder.setPolicyInstanceId(policyTypeInstanceId);
+ Whitebox.setInternalState(nonrtRicApiProvider, "restAdapter", restAdapter);
+ String uri = nearRicUrlProvider.getPolicyInstanceId(inputBuilder.build().getNearRtRicId(),
+ String.valueOf(inputBuilder.build().getPolicyTypeId()), inputBuilder.getPolicyInstanceId());
+ ResponseEntity<Object> deletePolicyInstanceResponse = new ResponseEntity<>(HttpStatus.NO_CONTENT);
+ when(restAdapter.delete(eq(uri))).thenReturn(deletePolicyInstanceResponse);
+ ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> result =
+ nonrtRicApiProvider.deletePolicyInstance(inputBuilder.build());
+ Assert.assertEquals(String.valueOf(HttpStatus.NO_CONTENT.value()), result.get().getResult().getCode());
+ }
+
+ @Test
+ public void testGetNearRTRICs() throws InterruptedException, ExecutionException {
+ GetNearRTRICsInputBuilder inputBuilder = new GetNearRTRICsInputBuilder();
+ ListenableFuture<RpcResult<GetNearRTRICsOutput>> result =
+ nonrtRicApiProvider.getNearRTRICs(inputBuilder.build());
+ Assert.assertEquals(String.valueOf(HttpStatus.OK.value()), result.get().getResult().getCode());
+ }
+