@Override
public ListenableFuture<RpcResult<ServicePathOutput>> invoke(ServicePathInput input) {
- if (input.getOperation() != null) {
- if (input.getOperation().getIntValue() == 1) {
+ if (input.getOperation() == null) {
+ LOG.debug("A mandatory input argument is null");
+ return RpcResultBuilder
+ .success(new ServicePathOutputBuilder().setResult("Invalid operation").build())
+ .buildFuture();
+ }
+ return switch (input.getOperation()) {
+ case Create -> {
LOG.info("Create operation request received");
- return RpcResultBuilder.success(
- this.deviceRendererService.setupServicePath(input, null))
- .buildFuture();
- } else if (input.getOperation().getIntValue() == 2) {
+ yield RpcResultBuilder.success(this.deviceRendererService.setupServicePath(input, null))
+ .buildFuture();
+ }
+ case Delete -> {
LOG.info("Delete operation request received");
- return RpcResultBuilder
- .success(this.deviceRendererService.deleteServicePath(input))
- .buildFuture();
+ yield RpcResultBuilder.success(this.deviceRendererService.deleteServicePath(input))
+ .buildFuture();
}
- }
- return RpcResultBuilder
- .success(new ServicePathOutputBuilder().setResult("Invalid operation").build())
- .buildFuture();
+ };
}
-
}