- public ListenableFuture<RpcResult<CreatePolicyInstanceOutput>> createPolicyInstance(
- CreatePolicyInstanceInput input) {
- log.info("Start of createPolicyInstance");
- CreatePolicyInstanceOutputBuilder responseBuilder = new CreatePolicyInstanceOutputBuilder();
- try {
- String uri = nearRicUrlProvider.getPolicyInstanceId(String.valueOf(input.getNearRtRicId()),
- String.valueOf(input.getPolicyTypeId()), String.valueOf(input.getPolicyInstanceId()));
- log.info("PUT Request input.getPolicyInstance() : {} ", input.getPolicyInstance());
- ResponseEntity<Void> response = restAdapter.put(uri, input.getPolicyInstance());
- responseBuilder.setCode(response.getStatusCode().toString());
- } catch (NearRtRicNotFoundException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(HttpStatus.INTERNAL_SERVER_ERROR.toString());
- } catch (RestClientResponseException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(String.valueOf(ex.getRawStatusCode()));
- }
- log.info("End of createPolicyInstance");
- RpcResult<CreatePolicyInstanceOutput> rpcResult = RpcResultBuilder
- .<CreatePolicyInstanceOutput>status(true).withResult(responseBuilder.build()).build();
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<CreatePolicyTypeOutput>> createPolicyType(
- CreatePolicyTypeInput input) {
- log.info("Start of createPolicyType");
- CreatePolicyTypeOutputBuilder responseBuilder = new CreatePolicyTypeOutputBuilder();
- try {
- String uri = nearRicUrlProvider.getPolicyTypeId(String.valueOf(input.getNearRtRicId()),
- String.valueOf(input.getPolicyTypeId()));
- log.info("PUT Request input.getPolicyType() : {} ", input.getPolicyType());
- ResponseEntity<Void> response = restAdapter.put(uri, input.getPolicyType());
- responseBuilder.setCode(response.getStatusCode().toString());
- } catch (NearRtRicNotFoundException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(HttpStatus.INTERNAL_SERVER_ERROR.toString());
- } catch (RestClientResponseException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(String.valueOf(ex.getRawStatusCode()));
- }
- log.info("End of createPolicyType");
- RpcResult<CreatePolicyTypeOutput> rpcResult = RpcResultBuilder
- .<CreatePolicyTypeOutput>status(true).withResult(responseBuilder.build()).build();
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<DeletePolicyInstanceOutput>> deletePolicyInstance(
- DeletePolicyInstanceInput input) {
- log.info("Start of deletePolicyInstance");
- DeletePolicyInstanceOutputBuilder responseBuilder = new DeletePolicyInstanceOutputBuilder();
- try {
- String uri = nearRicUrlProvider.getPolicyInstanceId(String.valueOf(input.getNearRtRicId()),
- String.valueOf(input.getPolicyTypeId()), String.valueOf(input.getPolicyInstanceId()));
- ResponseEntity<Void> response = restAdapter.delete(uri);
- responseBuilder.setCode(response.getStatusCode().toString());
- } catch (NearRtRicNotFoundException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(HttpStatus.INTERNAL_SERVER_ERROR.toString());
- } catch (RestClientResponseException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(String.valueOf(ex.getRawStatusCode()));
- }
- log.info("End of deletePolicyInstance");
- RpcResult<DeletePolicyInstanceOutput> rpcResult = RpcResultBuilder
- .<DeletePolicyInstanceOutput>status(true).withResult(responseBuilder.build()).build();
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<DeletePolicyTypeOutput>> deletePolicyType(
- DeletePolicyTypeInput input) {
- log.info("Start of deletePolicyType");
- DeletePolicyTypeOutputBuilder responseBuilder = new DeletePolicyTypeOutputBuilder();
- try {
- String uri = nearRicUrlProvider.getPolicyTypeId(String.valueOf(input.getNearRtRicId()),
- String.valueOf(input.getPolicyTypeId()));
- ResponseEntity<Void> response = restAdapter.delete(uri);
- responseBuilder.setCode(response.getStatusCode().toString());
- } catch (NearRtRicNotFoundException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(HttpStatus.INTERNAL_SERVER_ERROR.toString());
- } catch (RestClientResponseException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(String.valueOf(ex.getRawStatusCode()));
- }
- log.info("End of deletePolicyType");
- RpcResult<DeletePolicyTypeOutput> rpcResult = RpcResultBuilder
- .<DeletePolicyTypeOutput>status(true).withResult(responseBuilder.build()).build();
- return Futures.immediateFuture(rpcResult);
- }
-
- @Override
- public ListenableFuture<RpcResult<GetHealthCheckOutput>> getHealthCheck(
- GetHealthCheckInput input) {
- log.info("Start of getHealthCheck");
- GetHealthCheckOutputBuilder responseBuilder = new GetHealthCheckOutputBuilder();
- try {
- String uri = nearRicUrlProvider.getHealthCheck(String.valueOf(input.getNearRtRicId()));
- ResponseEntity<Object> response = restAdapter.get(uri, Object.class);
- responseBuilder.setHealthStatus(false);
- if (response.getStatusCode().equals(HttpStatus.OK)) {
- responseBuilder.setHealthStatus(true);
- }
- responseBuilder.setCode(response.getStatusCode().toString());
- } catch (NearRtRicNotFoundException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(HttpStatus.INTERNAL_SERVER_ERROR.toString());
- } catch (RestClientResponseException ex) {
- log.error("Caught exception: {}", ex);
- responseBuilder.setCode(String.valueOf(ex.getRawStatusCode()));