X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fsal-netconf-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fsal%2Fconnect%2Fnetconf%2Fsal%2FNetconfDeviceSalFacadeTest.java;h=2b698008cdcc114a36582b49bfadbe0311a50053;hb=f7a7694b1604dfcd231c70506b468bdfad34c21d;hp=89f0ee26422afa6913ee219028d33618896d6404;hpb=476cc2164a06b77e7dd38859e0124d82cd2c8847;p=netconf.git diff --git a/netconf/sal-netconf-connector/src/test/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceSalFacadeTest.java b/netconf/sal-netconf-connector/src/test/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceSalFacadeTest.java index 89f0ee2642..2b698008cd 100644 --- a/netconf/sal-netconf-connector/src/test/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceSalFacadeTest.java +++ b/netconf/sal-netconf-connector/src/test/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceSalFacadeTest.java @@ -5,76 +5,56 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.netconf.sal.connect.netconf.sal; -import static org.mockito.Matchers.any; -import static org.mockito.Matchers.eq; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; import static org.mockito.Mockito.doNothing; -import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; -import static org.mockito.MockitoAnnotations.initMocks; import java.net.InetSocketAddress; -import java.util.Arrays; import java.util.List; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.Mock; -import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker; -import org.opendaylight.controller.md.sal.dom.api.DOMNotification; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; +import org.mockito.junit.MockitoJUnitRunner; +import org.opendaylight.mdsal.dom.api.DOMDataBroker; +import org.opendaylight.mdsal.dom.api.DOMNotification; +import org.opendaylight.netconf.dom.api.NetconfDataTreeService; +import org.opendaylight.netconf.sal.connect.api.RemoteDeviceServices; +import org.opendaylight.netconf.sal.connect.api.RemoteDeviceServices.Rpcs; +import org.opendaylight.netconf.sal.connect.netconf.NetconfDeviceSchema; import org.opendaylight.netconf.sal.connect.netconf.listener.NetconfDeviceCapabilities; import org.opendaylight.netconf.sal.connect.netconf.listener.NetconfSessionPreferences; import org.opendaylight.netconf.sal.connect.netconf.util.NetconfMessageTransformUtil; import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; -import org.powermock.api.mockito.PowerMockito; -import org.powermock.core.classloader.annotations.PrepareForTest; -import org.powermock.modules.junit4.PowerMockRunner; - -@RunWith(PowerMockRunner.class) -@PrepareForTest({NetconfDeviceTopologyAdapter.class, NetconfDeviceSalProvider.MountInstance.class, - NetconfSessionPreferences.class}) -public class NetconfDeviceSalFacadeTest { - - private NetconfDeviceSalFacade deviceFacade; +import org.opendaylight.yangtools.rfc8528.data.util.EmptyMountPointContext; +import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext; - private NetconfDeviceTopologyAdapter netconfDeviceTopologyAdapter; - private NetconfDeviceSalProvider.MountInstance mountInstance; +@RunWith(MockitoJUnitRunner.StrictStubs.class) +public class NetconfDeviceSalFacadeTest { + private final RemoteDeviceId remoteDeviceId = new RemoteDeviceId("test", new InetSocketAddress("127.0.0.1", 8000)); @Mock - private NetconfDeviceSalProvider salProvider; + private NetconfDeviceMount mountInstance; + + private NetconfDeviceSalFacade deviceFacade; @Before public void setUp() throws Exception { - initMocks(this); - final InetSocketAddress address = new InetSocketAddress("127.0.0.1", 8000); - final RemoteDeviceId remoteDeviceId = new RemoteDeviceId("test", address); + doNothing().when(mountInstance).onDeviceDisconnected(); - deviceFacade = new NetconfDeviceSalFacade(remoteDeviceId, salProvider); - - netconfDeviceTopologyAdapter = PowerMockito.mock(NetconfDeviceTopologyAdapter.class); - mountInstance = PowerMockito.mock(NetconfDeviceSalProvider.MountInstance.class); - - doReturn(netconfDeviceTopologyAdapter).when(salProvider).getTopologyDatastoreAdapter(); - doNothing().when(netconfDeviceTopologyAdapter) - .updateDeviceData(any(Boolean.class), any(NetconfDeviceCapabilities.class)); - - doReturn(mountInstance).when(salProvider).getMountInstance(); - doNothing().when(mountInstance).onTopologyDeviceDisconnected(); + deviceFacade = new NetconfDeviceSalFacade(remoteDeviceId, mountInstance, true); } @Test public void testOnDeviceDisconnected() { deviceFacade.onDeviceDisconnected(); - verify(netconfDeviceTopologyAdapter).updateDeviceData(eq(false), any(NetconfDeviceCapabilities.class)); - verify(mountInstance, times(1)).onTopologyDeviceDisconnected(); - + verify(mountInstance, times(1)).onDeviceDisconnected(); } @Test @@ -82,30 +62,29 @@ public class NetconfDeviceSalFacadeTest { final Throwable throwable = new Throwable(); deviceFacade.onDeviceFailed(throwable); - verify(netconfDeviceTopologyAdapter).setDeviceAsFailed(throwable); - verify(mountInstance, times(1)).onTopologyDeviceDisconnected(); + verify(mountInstance, times(1)).onDeviceDisconnected(); } @Test public void testOnDeviceClose() throws Exception { deviceFacade.close(); - verify(salProvider).close(); + verify(mountInstance).close(); } @Test public void testOnDeviceConnected() { - final SchemaContext schemaContext = mock(SchemaContext.class); + final EffectiveModelContext schemaContext = mock(EffectiveModelContext.class); - final NetconfSessionPreferences netconfSessionPreferences = - NetconfSessionPreferences.fromStrings(getCapabilities()); + final var netconfSessionPreferences = NetconfSessionPreferences.fromStrings( + List.of(NetconfMessageTransformUtil.NETCONF_CANDIDATE_URI.toString())); - final DOMRpcService deviceRpc = mock(DOMRpcService.class); - deviceFacade.onDeviceConnected(schemaContext, netconfSessionPreferences, deviceRpc); + final var deviceServices = new RemoteDeviceServices(mock(Rpcs.Normalized.class), null); + deviceFacade.onDeviceConnected( + new NetconfDeviceSchema(NetconfDeviceCapabilities.empty(), new EmptyMountPointContext(schemaContext)), + netconfSessionPreferences, deviceServices); - verify(mountInstance, times(1)).onTopologyDeviceConnected(eq(schemaContext), - any(DOMDataBroker.class), eq(deviceRpc), any(NetconfDeviceNotificationService.class)); - verify(netconfDeviceTopologyAdapter, - times(1)).updateDeviceData(true, netconfSessionPreferences.getNetconfDeviceCapabilities()); + verify(mountInstance, times(1)).onDeviceConnected(eq(schemaContext), eq(deviceServices), + any(DOMDataBroker.class), any(NetconfDataTreeService.class)); } @Test @@ -114,8 +93,4 @@ public class NetconfDeviceSalFacadeTest { deviceFacade.onNotification(domNotification); verify(mountInstance).publish(domNotification); } - - private static List getCapabilities() { - return Arrays.asList(NetconfMessageTransformUtil.NETCONF_CANDIDATE_URI.toString()); - } }