opendaylight/md-sal/messagebus-impl/src/test/java/org/opendaylight/controller/messagebus/eventsources/netconf/NetconfEventSourceTest.java

   1 ///*
   2 // * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3 // *
   4 // * This program and the accompanying materials are made available under the
   5 // * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6 // * and is available at http://www.eclipse.org/legal/epl-v10.html
   7 // */
   8 //package org.opendaylight.controller.messagebus.eventsources.netconf;
   9 //
  10 //
  11 //import static org.junit.Assert.assertNotNull;
  12 //import static org.mockito.Matchers.any;
  13 //import static org.mockito.Mockito.doReturn;
  14 //import static org.mockito.Mockito.mock;
  15 //
  16 //import java.net.URI;
  17 //import java.util.HashMap;
  18 //import java.util.HashSet;
  19 //import java.util.Map;
  20 //import java.util.Set;
  21 //
  22 //import org.junit.Before;
  23 //import org.junit.Test;
  24 //import org.opendaylight.controller.md.sal.binding.api.BindingService;
  25 //import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  26 //import org.opendaylight.controller.md.sal.binding.api.MountPoint;
  27 //import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  28 //import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  29 //import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
  30 //import org.opendaylight.controller.md.sal.dom.api.DOMMountPoint;
  31 //import org.opendaylight.controller.md.sal.dom.api.DOMNotificationPublishService;
  32 //import org.opendaylight.controller.md.sal.dom.api.DOMNotificationService;
  33 //import org.opendaylight.controller.md.sal.dom.api.DOMRpcService;
  34 //import org.opendaylight.controller.md.sal.dom.api.DOMService;
  35 //import org.opendaylight.controller.sal.binding.api.RpcConsumerRegistry;
  36 //import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.NotificationPattern;
  37 //import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.TopicId;
  38 //import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.JoinTopicInput;
  39 //import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.NotificationsService;
  40 //import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.rev080714.Netconf;
  41 //import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netmod.notification.rev080714.netconf.Streams;
  42 //import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeFields.ConnectionStatus;
  43 //import org.opendaylight.yangtools.concepts.ListenerRegistration;
  44 //import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  45 //import org.opendaylight.yangtools.yang.common.QName;
  46 //import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
  47 //import org.opendaylight.yangtools.yang.model.api.NotificationDefinition;
  48 //import org.opendaylight.yangtools.yang.model.api.SchemaContext;
  49 //import org.opendaylight.yangtools.yang.model.api.SchemaPath;
  50 //
  51 //import com.google.common.base.Optional;
  52 //import com.google.common.util.concurrent.CheckedFuture;
  53 //
  54 //public class NetconfEventSourceTest {
  55 //
  56 //    NetconfEventSource netconfEventSource;
  57 //    DOMMountPoint domMountPointMock;
  58 //    MountPoint mountPointMock;
  59 //    JoinTopicInput joinTopicInputMock;
  60 //
  61 //    @Before
  62 //    public void setUp() throws Exception {
  63 //        Map<String, String> streamMap = new HashMap<>();
  64 //        streamMap.put("uriStr1", "string2");
  65 //        domMountPointMock = mock(DOMMountPoint.class);
  66 //        mountPointMock = mock(MountPoint.class);
  67 //        DOMNotificationPublishService domNotificationPublishServiceMock = mock(DOMNotificationPublishService.class);
  68 //        RpcConsumerRegistry rpcConsumerRegistryMock = mock(RpcConsumerRegistry.class);
  69 //        Optional<BindingService> onlyOptionalMock = (Optional<BindingService>) mock(Optional.class);
  70 //        NotificationsService notificationsServiceMock = mock(NotificationsService.class);
  71 //        doReturn(notificationsServiceMock).when(rpcConsumerRegistryMock).getRpcService(NotificationsService.class);
  72 //
  73 //        Optional<DataBroker> optionalMpDataBroker = (Optional<DataBroker>) mock(Optional.class);
  74 //        DataBroker mpDataBroker = mock(DataBroker.class);
  75 //        doReturn(optionalMpDataBroker).when(mountPointMock).getService(DataBroker.class);
  76 //        doReturn(true).when(optionalMpDataBroker).isPresent();
  77 //        doReturn(mpDataBroker).when(optionalMpDataBroker).get();
  78 //
  79 //        ReadOnlyTransaction rtx = mock(ReadOnlyTransaction.class);
  80 //        doReturn(rtx).when(mpDataBroker).newReadOnlyTransaction();
  81 //        CheckedFuture<Optional<Streams>, ReadFailedException> checkFeature = (CheckedFuture<Optional<Streams>, ReadFailedException>)mock(CheckedFuture.class);
  82 //        InstanceIdentifier<Streams> pathStream = InstanceIdentifier.builder(Netconf.class).child(Streams.class).build();
  83 //        doReturn(checkFeature).when(rtx).read(LogicalDatastoreType.OPERATIONAL, pathStream);
  84 //        Optional<Streams> avStreams = NetconfTestUtils.getAvailableStream("stream01", true);
  85 //        doReturn(avStreams).when(checkFeature).checkedGet();
  86 //
  87 //        netconfEventSource = new NetconfEventSource(
  88 //                NetconfTestUtils.getNetconfNode("NodeId1", "node.test.local", ConnectionStatus.Connected, NetconfTestUtils.notification_capability_prefix),
  89 //                streamMap,
  90 //                domMountPointMock,
  91 //                mountPointMock ,
  92 //                domNotificationPublishServiceMock);
  93 //
  94 //    }
  95 //
  96 //    @Test
  97 //    public void joinTopicTest() throws Exception{
  98 //        joinTopicTestHelper();
  99 //        assertNotNull("JoinTopic return value has not been created correctly.", netconfEventSource.joinTopic(joinTopicInputMock));
 100 //    }
 101 //
 102 //    private void joinTopicTestHelper() throws Exception{
 103 //        joinTopicInputMock = mock(JoinTopicInput.class);
 104 //        TopicId topicId = new TopicId("topicID007");
 105 //        doReturn(topicId).when(joinTopicInputMock).getTopicId();
 106 //        NotificationPattern notificationPatternMock = mock(NotificationPattern.class);
 107 //        doReturn(notificationPatternMock).when(joinTopicInputMock).getNotificationPattern();
 108 //        doReturn("uriStr1").when(notificationPatternMock).getValue();
 109 //
 110 //        SchemaContext schemaContextMock = mock(SchemaContext.class);
 111 //        doReturn(schemaContextMock).when(domMountPointMock).getSchemaContext();
 112 //        Set<NotificationDefinition> notificationDefinitionSet = new HashSet<>();
 113 //        NotificationDefinition notificationDefinitionMock = mock(NotificationDefinition.class);
 114 //        notificationDefinitionSet.add(notificationDefinitionMock);
 115 //
 116 //        URI uri = new URI("uriStr1");
 117 //        QName qName = new QName(uri, "localName1");
 118 //        org.opendaylight.yangtools.yang.model.api.SchemaPath schemaPath = SchemaPath.create(true, qName);
 119 //        doReturn(notificationDefinitionSet).when(schemaContextMock).getNotifications();
 120 //        doReturn(schemaPath).when(notificationDefinitionMock).getPath();
 121 //
 122 //        Optional<DOMNotificationService> domNotificationServiceOptionalMock = (Optional<DOMNotificationService>) mock(Optional.class);
 123 //        doReturn(domNotificationServiceOptionalMock).when(domMountPointMock).getService(DOMNotificationService.class);
 124 //        doReturn(true).when(domNotificationServiceOptionalMock).isPresent();
 125 //
 126 //        DOMNotificationService domNotificationServiceMock = mock(DOMNotificationService.class);
 127 //        doReturn(domNotificationServiceMock).when(domNotificationServiceOptionalMock).get();
 128 //        ListenerRegistration<NetconfEventSource> listenerRegistrationMock = (ListenerRegistration<NetconfEventSource>)mock(ListenerRegistration.class);
 129 //        doReturn(listenerRegistrationMock).when(domNotificationServiceMock).registerNotificationListener(any(NetconfEventSource.class), any(SchemaPath.class));
 130 //
 131 //        Optional<DOMService> optionalMock = (Optional<DOMService>) mock(Optional.class);
 132 //        doReturn(optionalMock).when(domMountPointMock).getService(DOMRpcService.class);
 133 //        doReturn(true).when(optionalMock).isPresent();
 134 //        DOMRpcService domRpcServiceMock = mock(DOMRpcService.class);
 135 //        doReturn(domRpcServiceMock).when(optionalMock).get();
 136 //        CheckedFuture checkedFutureMock = mock(CheckedFuture.class);
 137 //        doReturn(checkedFutureMock).when(domRpcServiceMock).invokeRpc(any(SchemaPath.class), any(ContainerNode.class));
 138 //
 139 //    }
 140 //
 141 //}