X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=restconf%2Fsal-rest-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Frestconf%2Fimpl%2Ftest%2FRestconfImplTest.java;h=c08b3349989469d993b880f86fc458d0e98ebef6;hb=4281bb297a90bc3c71a50d610147727ff67ea9ea;hp=1c57effe4590a7bd2760907a100d255b687faf82;hpb=d5db0ba4b6233134e2c90b88e2a4fc4d9590749a;p=netconf.git diff --git a/restconf/sal-rest-connector/src/test/java/org/opendaylight/controller/sal/restconf/impl/test/RestconfImplTest.java b/restconf/sal-rest-connector/src/test/java/org/opendaylight/controller/sal/restconf/impl/test/RestconfImplTest.java index 1c57effe45..c08b334998 100644 --- a/restconf/sal-rest-connector/src/test/java/org/opendaylight/controller/sal/restconf/impl/test/RestconfImplTest.java +++ b/restconf/sal-rest-connector/src/test/java/org/opendaylight/controller/sal/restconf/impl/test/RestconfImplTest.java @@ -13,20 +13,32 @@ import static org.mockito.Matchers.any; import static org.mockito.Matchers.anyBoolean; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.spy; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; + import com.google.common.base.Optional; +import com.google.common.collect.Lists; +import com.google.common.collect.Sets; import com.google.common.util.concurrent.Futures; import java.io.FileNotFoundException; +import java.net.URI; import java.text.ParseException; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Map.Entry; import java.util.Set; import javax.ws.rs.core.MultivaluedHashMap; +import javax.ws.rs.core.MultivaluedMap; +import javax.ws.rs.core.UriBuilder; import javax.ws.rs.core.UriInfo; import org.junit.Before; import org.junit.BeforeClass; import org.junit.Test; +import org.mockito.Mockito; import org.opendaylight.controller.md.sal.dom.api.DOMMountPoint; import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult; import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; @@ -34,19 +46,30 @@ import org.opendaylight.netconf.sal.restconf.impl.BrokerFacade; import org.opendaylight.netconf.sal.restconf.impl.ControllerContext; import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext; import org.opendaylight.netconf.sal.restconf.impl.NormalizedNodeContext; +import org.opendaylight.netconf.sal.restconf.impl.RestconfDocumentedException; +import org.opendaylight.netconf.sal.restconf.impl.RestconfError; +import org.opendaylight.netconf.sal.restconf.impl.RestconfError.ErrorTag; +import org.opendaylight.netconf.sal.restconf.impl.RestconfError.ErrorType; import org.opendaylight.netconf.sal.restconf.impl.RestconfImpl; +import org.opendaylight.netconf.sal.streams.listeners.Notificator; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; +import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifierWithPredicates; +import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; +import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild; +import org.opendaylight.yangtools.yang.data.api.schema.LeafSetEntryNode; +import org.opendaylight.yangtools.yang.data.api.schema.LeafSetNode; +import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.model.api.Module; +import org.opendaylight.yangtools.yang.model.api.RpcDefinition; import org.opendaylight.yangtools.yang.model.api.SchemaContext; import org.opendaylight.yangtools.yang.model.api.SchemaNode; import org.opendaylight.yangtools.yang.model.api.SchemaPath; import org.opendaylight.yangtools.yang.parser.spi.meta.ReactorException; /** - * @See {@link InvokeRpcMethodTest} - * + * See {@link InvokeRpcMethodTest}. */ public class RestconfImplTest { @@ -60,9 +83,8 @@ public class RestconfImplTest { final Set allModules = schemaContext.getModules(); assertNotNull(allModules); - controllerContext = spy(ControllerContext.getInstance()); + controllerContext = ControllerContext.getInstance(); controllerContext.setSchemas(schemaContext); - } @Before @@ -71,12 +93,49 @@ public class RestconfImplTest { this.restconfImpl.setControllerContext(controllerContext); } + @Test + public void binaryKeyTest() { + final List al = new ArrayList<>(); + al.add(new Byte((byte) 1)); + binaryKeyTest(al, al); + } + + private void binaryKeyTest(final List al, final List al2) { + + final QName keyDef = QName.create("test:key:binary", "2017-14-08", "b1"); + + final Map uriKeyValues = new HashMap<>(); + uriKeyValues.put(keyDef, al.toArray()); + + final MapEntryNode payload = mock(MapEntryNode.class); + final NodeIdentifierWithPredicates nodeIdWithPred = + new NodeIdentifierWithPredicates(keyDef, keyDef, al2.toArray()); + when(payload.getIdentifier()).thenReturn(nodeIdWithPred); + + final List keyDefinitions = new ArrayList<>(); + keyDefinitions.add(keyDef); + RestconfImpl.isEqualUriAndPayloadKeyValues(uriKeyValues, payload, keyDefinitions); + } + + @Test + public void binaryKeyFailTest() { + final List al = new ArrayList<>(); + al.add(new Byte((byte) 1)); + final List al2 = new ArrayList<>(); + try { + binaryKeyTest(al, al2); + } catch (final RestconfDocumentedException e) { + final RestconfError err = e.getErrors().iterator().next(); + assertEquals(ErrorType.PROTOCOL, err.getErrorType()); + assertEquals(ErrorTag.INVALID_VALUE, err.getErrorTag()); + } + } + @SuppressWarnings("unchecked") @Test public void testExample() throws FileNotFoundException, ParseException { @SuppressWarnings("rawtypes") - final - NormalizedNode normalizedNodeData = TestUtils.prepareNormalizedNodeWithIetfInterfacesInterfacesData(); + final NormalizedNode normalizedNodeData = TestUtils.prepareNormalizedNodeWithIetfInterfacesInterfacesData(); final BrokerFacade brokerFacade = mock(BrokerFacade.class); when(brokerFacade.readOperationalData(any(YangInstanceIdentifier.class))).thenReturn(normalizedNodeData); assertEquals(normalizedNodeData, @@ -100,9 +159,82 @@ public class RestconfImplTest { doReturn(mount).when(iiCtx).getMountPoint(); final DOMRpcService rpcService = mock(DOMRpcService.class); doReturn(Optional.of(rpcService)).when(mount).getService(DOMRpcService.class); - doReturn(Futures.immediateCheckedFuture(mock(DOMRpcResult.class))).when(rpcService).invokeRpc(any(SchemaPath.class), any(NormalizedNode.class)); + doReturn(Futures.immediateCheckedFuture(mock(DOMRpcResult.class))).when(rpcService) + .invokeRpc(any(SchemaPath.class), any(NormalizedNode.class)); this.restconfImpl.invokeRpc("randomId", ctx, uriInfo); this.restconfImpl.invokeRpc("ietf-netconf", ctx, uriInfo); verify(rpcService, times(2)).invokeRpc(any(SchemaPath.class), any(NormalizedNode.class)); } + + /** + * Create notification stream for toaster module. + */ + @Test + public void createNotificationStreamTest() { + final NormalizedNodeContext payload = mock(NormalizedNodeContext.class); + final InstanceIdentifierContext iiCtx = mock(InstanceIdentifierContext.class); + doReturn(iiCtx).when(payload).getInstanceIdentifierContext(); + + final SchemaNode schemaNode = mock(SchemaNode.class, + Mockito.withSettings().extraInterfaces(RpcDefinition.class)); + doReturn(schemaNode).when(iiCtx).getSchemaNode(); + doReturn(mock(SchemaPath.class)).when(schemaNode).getPath(); + + doReturn(QName.create("urn:opendaylight:params:xml:ns:yang:controller:md:sal:remote", + "2014-01-14", "create-notification-stream")).when(schemaNode).getQName(); + doReturn(null).when(iiCtx).getMountPoint(); + + final Set> children = Sets.newHashSet(); + final DataContainerChild child = mock(DataContainerChild.class, + Mockito.withSettings().extraInterfaces(LeafSetNode.class)); + + final LeafSetEntryNode entryNode = mock(LeafSetEntryNode.class); + when(entryNode.getValue()).thenReturn("(http://netconfcentral.org/ns/toaster?revision=2009-11-20)toastDone"); + when(((LeafSetNode) child).getValue()).thenReturn(Sets.newHashSet(entryNode)); + children.add(child); + + final NormalizedNode normalizedNode = mock(NormalizedNode.class, + Mockito.withSettings().extraInterfaces(ContainerNode.class)); + doReturn(normalizedNode).when(payload).getData(); + doReturn(children).when(normalizedNode).getValue(); + + // register notification + final NormalizedNodeContext context = this.restconfImpl + .invokeRpc("sal-remote:create-notification-stream", payload, null); + assertNotNull(context); + } + + /** + * Subscribe for notification stream of toaster module. + */ + @Test + public void subscribeToNotificationStreamTest() throws Exception { + final String identifier = "create-notification-stream/toaster:toastDone"; + + // register test notification stream + final SchemaPath path = SchemaPath.create( + true, QName.create("http://netconfcentral.org/ns/toaster", "2009-11-20", "toastDone")); + Notificator.createNotificationListener(Lists.newArrayList(path), identifier, "XML"); + + final UriInfo uriInfo = mock(UriInfo.class); + final UriBuilder uriBuilder = mock(UriBuilder.class); + when(uriBuilder.port(8181)).thenReturn(uriBuilder); + when(uriBuilder.replacePath(identifier)).thenReturn(uriBuilder); + when(uriBuilder.build()).thenReturn(new URI("")); + when(uriBuilder.scheme("ws")).thenReturn(uriBuilder); + when(uriInfo.getAbsolutePathBuilder()).thenReturn(uriBuilder); + final MultivaluedMap map = mock(MultivaluedMap.class); + final Set>> set = new HashSet<>(); + when(map.entrySet()).thenReturn(set); + when(uriInfo.getQueryParameters()).thenReturn(map); + + final BrokerFacade brokerFacade = mock(BrokerFacade.class); + this.restconfImpl.setBroker(brokerFacade); + + // subscribe to stream and verify response + final NormalizedNodeContext response = this.restconfImpl.subscribeToStream(identifier, uriInfo); + + // remove test notification stream + Notificator.removeAllListeners(); + } }