- nonrtRicApiProvider = new NonrtRicApiProvider(dataBroker, mockNotificationPublishService,
- mockRpcProviderRegistry);
- }
-
- @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());
- }
-
- @Test
- public void testCreatePolicyType() throws InterruptedException, ExecutionException {
- CreatePolicyTypeInputBuilder inputBuilder = new CreatePolicyTypeInputBuilder();
- inputBuilder.setNearRtRicId(nearRtRicId);
- inputBuilder.setPolicyTypeId(policyTypeId);
- Whitebox.setInternalState(nonrtRicApiProvider, "restAdapter", restAdapter);
- String uri = nearRicUrlProvider.getPolicyTypeId(inputBuilder.build().getNearRtRicId(),
- String.valueOf(inputBuilder.build().getPolicyTypeId()));
- ResponseEntity<Object> createPolicyTypeResponse = new ResponseEntity<>(HttpStatus.CREATED);
- when(restAdapter.put(eq(uri), anyObject())).thenReturn(createPolicyTypeResponse);
- ListenableFuture<RpcResult<CreatePolicyTypeOutput>> result =
- nonrtRicApiProvider.createPolicyType(inputBuilder.build());
- Assert.assertEquals(String.valueOf(HttpStatus.CREATED.value()), result.get().getResult().getCode());