import java.net.URI;
import javax.ws.rs.Path;
+import javax.ws.rs.WebApplicationException;
+import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;
import org.opendaylight.mdsal.dom.api.DOMMountPoint;
import org.opendaylight.mdsal.dom.api.DOMRpcResult;
import org.opendaylight.restconf.nb.rfc8040.rests.utils.CreateStreamUtil;
import org.opendaylight.restconf.nb.rfc8040.rests.utils.RestconfInvokeOperationsUtil;
import org.opendaylight.restconf.nb.rfc8040.rests.utils.RestconfStreamsConstants;
+import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.model.api.RpcDefinition;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
resultData = result.getResult();
resultNodeSchema = (RpcDefinition) payload.getInstanceIdentifierContext().getSchemaNode();
}
- return new NormalizedNodeContext(new InstanceIdentifierContext<>(null, resultNodeSchema,
- mountPoint, schemaContextRef.get()), resultData);
+
+ if (resultData != null && ((ContainerNode) resultData).getValue().isEmpty()) {
+ throw new WebApplicationException(Response.Status.NO_CONTENT);
+ } else {
+ return new NormalizedNodeContext(new InstanceIdentifierContext<>(null, resultNodeSchema,
+ mountPoint, schemaContextRef.get()), resultData);
+ }
}
}
import static org.mockito.Mockito.when;
import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateFluentFuture;
+import java.util.Collections;
+import javax.ws.rs.WebApplicationException;
+import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;
+import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mock;
import org.opendaylight.restconf.nb.rfc8040.handlers.TransactionChainHandler;
import org.opendaylight.restconf.nb.rfc8040.references.SchemaContextRef;
import org.opendaylight.yangtools.yang.common.QName;
+import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
+import org.opendaylight.yangtools.yang.data.api.schema.LeafNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.model.api.RpcDefinition;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
}
@Test
- public void testInvokeRpc() throws Exception {
+ public void testInvokeRpcWithNonEmptyOutput() {
final String identifier = "invoke-rpc-module:rpcTest";
- final NormalizedNode<?, ?> result = mock(NormalizedNode.class);
+ final ContainerNode result = mock(ContainerNode.class);
+ final LeafNode outputChild = mock(LeafNode.class);
+ when(result.getValue()).thenReturn(Collections.singleton(outputChild));
+
final NormalizedNodeContext payload = prepNNC(result);
final UriInfo uriInfo = mock(UriInfo.class);
assertEquals(result, rpc.getData());
}
+ @Test
+ public void testInvokeRpcWithEmptyOutput() {
+ final String identifier = "invoke-rpc-module:rpcTest";
+ final ContainerNode result = mock(ContainerNode.class);
+
+ final NormalizedNodeContext payload = prepNNC(result);
+ final UriInfo uriInfo = mock(UriInfo.class);
+
+ WebApplicationException exceptionToBeThrown = null;
+ try {
+ this.invokeOperationsService.invokeRpc(identifier, payload, uriInfo);
+ } catch (final WebApplicationException exception) {
+ exceptionToBeThrown = exception;
+
+ }
+ Assert.assertNotNull("WebApplicationException with status code 204 is expected.", exceptionToBeThrown);
+ Assert.assertEquals(Response.Status.NO_CONTENT.getStatusCode(), exceptionToBeThrown.getResponse().getStatus());
+ }
+
private NormalizedNodeContext prepNNC(final NormalizedNode<?, ?> result) {
final InstanceIdentifierContext<?> context = mock(InstanceIdentifierContext.class);
final RpcDefinition schemaNode = mock(RpcDefinition.class);