interfacemgr/interfacemgr-impl/src/test/java/org/opendaylight/vpnservice/interfacemgr/test/VlanInterfaceConfigurationTest.java

   1 /*
   2  * Copyright (c) 2015 Ericsson India Global Services Pvt Ltd. 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
   9 package org.opendaylight.vpnservice.interfacemgr.test;
  10
  11 import static org.mockito.Matchers.any;
  12 import static org.mockito.Mockito.*;
  13
  14 import com.google.common.base.Optional;
  15 import com.google.common.util.concurrent.Futures;
  16
  17 import java.math.BigInteger;
  18
  19 import org.junit.After;
  20 import org.junit.Before;
  21 import org.junit.Test;
  22 import org.junit.runner.RunWith;
  23 import org.mockito.Mock;
  24 import org.mockito.Mockito;
  25 import org.mockito.runners.MockitoJUnitRunner;
  26 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  27 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  28 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  29 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  30 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
  31 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  32 import org.opendaylight.idmanager.IdManager;
  33 import org.opendaylight.vpnservice.interfacemgr.IfmUtil;
  34 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.confighelpers.OvsInterfaceConfigAddHelper;
  35 import org.opendaylight.vpnservice.interfacemgr.renderer.ovs.confighelpers.OvsInterfaceConfigRemoveHelper;
  36 import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager;
  37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.L2vlan;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.alivenessmonitor.rev150629.AlivenessMonitorService;
  43 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  44 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  45
  46 @RunWith(MockitoJUnitRunner.class)
  47 public class VlanInterfaceConfigurationTest {
  48
  49     @Mock
  50     DataBroker dataBroker;
  51     @Mock
  52     AlivenessMonitorService alivenessMonitorService;
  53     @Mock IdManager idManager;
  54     @Mock ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
  55     @Mock ReadOnlyTransaction mockReadTx;
  56     @Mock WriteTransaction mockWriteTx;
  57     @Mock IMdsalApiManager mdsalApiManager;
  58     OvsInterfaceConfigAddHelper addHelper;
  59     OvsInterfaceConfigRemoveHelper removeHelper;
  60
  61     NodeConnectorId nodeConnectorId;
  62     NodeConnector nodeConnector;
  63     Interface vlanInterfaceEnabled;
  64     Interface vlanInterfaceDisabled;
  65     InstanceIdentifier<Interface> interfaceInstanceIdentifier;
  66     InstanceIdentifier<NodeConnector> nodeConnectorInstanceIdentifier;
  67     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> interfaceStateIdentifier;
  68     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface stateInterface;
  69
  70     @Before
  71     public void setUp() throws Exception {
  72         when(dataBroker.registerDataChangeListener(
  73                 any(LogicalDatastoreType.class),
  74                 any(InstanceIdentifier.class),
  75                 any(DataChangeListener.class),
  76                 any(DataChangeScope.class)))
  77                 .thenReturn(dataChangeListenerRegistration);
  78         setupMocks();
  79     }
  80
  81     @After
  82     public void cleanUp(){
  83     }
  84
  85     private void setupMocks() {
  86         nodeConnectorId = InterfaceManagerTestUtil.buildNodeConnectorId(BigInteger.valueOf(1), 1);
  87         nodeConnector = InterfaceManagerTestUtil.buildNodeConnector(nodeConnectorId);
  88         vlanInterfaceEnabled = InterfaceManagerTestUtil.buildInterface(InterfaceManagerTestUtil.interfaceName, "Test Vlan Interface1", true, L2vlan.class, BigInteger.valueOf(1));
  89         vlanInterfaceDisabled = InterfaceManagerTestUtil.buildInterface(InterfaceManagerTestUtil.interfaceName, "Test Vlan Interface1", false, L2vlan.class, BigInteger.valueOf(1));
  90         interfaceInstanceIdentifier = IfmUtil.buildId(InterfaceManagerTestUtil.interfaceName);
  91         nodeConnectorInstanceIdentifier = InterfaceManagerTestUtil.getNcIdent("openflow:1", nodeConnectorId);
  92         interfaceStateIdentifier = IfmUtil.buildStateInterfaceId(vlanInterfaceEnabled.getName());
  93         stateInterface = InterfaceManagerTestUtil.buildStateInterface(InterfaceManagerTestUtil.interfaceName, nodeConnectorId);
  94
  95         // Setup mocks
  96         when(dataBroker.newReadOnlyTransaction()).thenReturn(mockReadTx);
  97         when(dataBroker.newWriteOnlyTransaction()).thenReturn(mockWriteTx);
  98     }
  99
 100     @Test
 101     public void testAddVlanInterfaceWhenSwitchIsNotConnected() {
 102         Optional<Interface> expectedInterface = Optional.of(vlanInterfaceEnabled);
 103         Optional<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> expectedStateInterface = Optional.of(stateInterface);
 104
 105         doReturn(Futures.immediateCheckedFuture(expectedInterface)).when(mockReadTx).read(
 106                         LogicalDatastoreType.CONFIGURATION, interfaceInstanceIdentifier);
 107         doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(
 108                LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier);
 109
 110         addHelper.addConfiguration(dataBroker, null, vlanInterfaceEnabled, idManager);
 111
 112         //Nothing to verify, since when switch is not connected we don't do any datastore operation
 113
 114     }
 115
 116     @Test
 117     public void testAddVlanInterfaceWhenSwitchIsConnected() {
 118         Optional<Interface> expectedInterface = Optional.of(vlanInterfaceEnabled);
 119         Optional<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> expectedStateInterface = Optional.of(stateInterface);
 120
 121         doReturn(Futures.immediateCheckedFuture(expectedInterface)).when(mockReadTx).read(
 122                 LogicalDatastoreType.CONFIGURATION, interfaceInstanceIdentifier);
 123         doReturn(Futures.immediateCheckedFuture(expectedStateInterface)).when(mockReadTx).read(
 124                 LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier);
 125
 126         addHelper.addConfiguration(dataBroker, null, vlanInterfaceEnabled, idManager);
 127
 128         //Nothing to verify, since when adminstate is enabled and switch opstate is already up,
 129         //we don't do any datastore operation
 130     }
 131
 132     @Test
 133     public void testAddVlanInterfaceWhenAdminStateDisabled() {
 134         Optional<Interface> expectedInterface = Optional.of(vlanInterfaceEnabled);
 135         Optional<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> expectedStateInterface =
 136                 Optional.of(stateInterface);
 137
 138         doReturn(Futures.immediateCheckedFuture(expectedInterface)).when(mockReadTx).read(
 139                 LogicalDatastoreType.CONFIGURATION, interfaceInstanceIdentifier);
 140         doReturn(Futures.immediateCheckedFuture(expectedStateInterface)).when(mockReadTx).read(
 141                 LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier);
 142
 143         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder ifaceBuilder = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder();
 144         ifaceBuilder.setOperStatus(OperStatus.Down);
 145         ifaceBuilder.setKey(IfmUtil.getStateInterfaceKeyFromName(vlanInterfaceEnabled.getName()));
 146         stateInterface = ifaceBuilder.build();
 147
 148         addHelper.addConfiguration(dataBroker, null, vlanInterfaceDisabled, idManager);
 149
 150         //verification
 151         verify(mockWriteTx).merge(LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier, stateInterface);
 152     }
 153
 154     @Test
 155     public void testDeleteVlanInterface() {
 156         Optional<Interface> expected = Optional.of(vlanInterfaceEnabled);
 157         Optional<NodeConnector> expectedNc = Optional.of(nodeConnector);
 158         Optional<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> expectedStateIf = Optional.of(stateInterface);
 159         doReturn(Futures.immediateCheckedFuture(expected)).when(mockReadTx).read(
 160                         LogicalDatastoreType.CONFIGURATION, interfaceInstanceIdentifier);
 161         doReturn(Futures.immediateCheckedFuture(expectedNc)).when(mockReadTx).read(
 162                         LogicalDatastoreType.OPERATIONAL, nodeConnectorInstanceIdentifier);
 163         doReturn(Futures.immediateCheckedFuture(expectedStateIf)).when(mockReadTx).read(
 164                         LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier);
 165
 166         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder ifaceBuilder = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder();
 167         ifaceBuilder.setOperStatus(OperStatus.Down);
 168         ifaceBuilder.setKey(IfmUtil.getStateInterfaceKeyFromName(vlanInterfaceEnabled.getName()));
 169         stateInterface = ifaceBuilder.build();
 170
 171         removeHelper.removeConfiguration(dataBroker,alivenessMonitorService, vlanInterfaceEnabled, idManager,
 172                 mdsalApiManager, null);
 173
 174         //verification
 175         verify(mockWriteTx).merge(LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier, stateInterface);
 176     }
 177 }