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

   1 /*
   2  * Copyright (c) 2016 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 com.google.common.base.Optional;
  12 import com.google.common.util.concurrent.Futures;
  13 import org.junit.After;
  14 import org.junit.Before;
  15 import org.junit.Test;
  16 import org.junit.runner.RunWith;
  17 import org.mockito.Mock;
  18 import org.mockito.runners.MockitoJUnitRunner;
  19 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  20 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  21 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  22 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  23 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
  24 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  25 import org.opendaylight.vpnservice.interfacemgr.IfmUtil;
  26 import org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.confighelpers.HwVTEPConfigRemoveHelper;
  27 import org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.confighelpers.HwVTEPInterfaceConfigAddHelper;
  28 import org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.statehelpers.HwVTEPInterfaceStateRemoveHelper;
  29 import org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.statehelpers.HwVTEPInterfaceStateUpdateHelper;
  30 import org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.utilities.SouthboundUtils;
  31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.EncapsulationTypeVxlanOverIpv4;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalLocatorAugmentation;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepPhysicalLocatorAugmentationBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical._switch.attributes.Tunnels;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical._switch.attributes.TunnelsBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.physical._switch.attributes.TunnelsKey;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.tunnel.attributes.BfdParams;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.tunnel.attributes.BfdStatus;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.tunnel.attributes.BfdStatusBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.TunnelInstanceInterfaceMap;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.tunnel.instance._interface.map.TunnelInstanceInterface;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.tunnel.instance._interface.map.TunnelInstanceInterfaceBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.tunnel.instance._interface.map.TunnelInstanceInterfaceKey;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.IfTunnel;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.ParentRefs;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.TunnelTypeVxlan;
  49 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  50 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
  51 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointKey;
  53 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  54 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  55
  56 import java.math.BigInteger;
  57 import java.util.ArrayList;
  58 import java.util.List;
  59
  60 import static org.mockito.Matchers.any;
  61 import static org.mockito.Mockito.*;
  62
  63 @RunWith(MockitoJUnitRunner.class)
  64 public class HwVTEPConfigurationTest {
  65
  66     @Mock DataBroker dataBroker;
  67     @Mock ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
  68     @Mock ReadOnlyTransaction mockReadTx;
  69     @Mock WriteTransaction mockWriteTx;
  70     @Mock InstanceIdentifier<TunnelInstanceInterface> tunnelInterfaceId;
  71     @Mock TunnelInstanceInterface tunnelInterface;
  72     @Mock Tunnels newTunnel;
  73     @Mock Tunnels oldTunnel;
  74     HwVTEPInterfaceConfigAddHelper addHelper;
  75     HwVTEPConfigRemoveHelper removeHelper;
  76     HwVTEPInterfaceStateUpdateHelper updateHelper;
  77     HwVTEPInterfaceStateRemoveHelper stateRemoveHelper;
  78
  79     BigInteger dpId = BigInteger.valueOf(1);
  80     Interface hwVTEPInterfaceEnabled;
  81     Interface hwVTEPInterfaceDisabled;
  82     ParentRefs parentRefs;
  83     IfTunnel ifTunnel;
  84     InstanceIdentifier<TerminationPoint> tpPath;
  85     TerminationPoint terminationPoint;
  86     InstanceIdentifier<Node> physicalSwitchId;
  87     InstanceIdentifier<Node> globalId;
  88     InstanceIdentifier<Tunnels> tunnelsInstanceIdentifier;
  89     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> interfaceStateIdentifier;
  90
  91     @Before
  92     public void setUp() throws Exception {
  93         when(dataBroker.registerDataChangeListener(
  94                 any(LogicalDatastoreType.class),
  95                 any(InstanceIdentifier.class),
  96                 any(DataChangeListener.class),
  97                 any(DataChangeScope.class)))
  98                 .thenReturn(dataChangeListenerRegistration);
  99         setupMocks();
 100     }
 101
 102     @After
 103     public void cleanUp(){
 104     }
 105
 106     private void setupMocks() {
 107         hwVTEPInterfaceEnabled = InterfaceManagerTestUtil.buildTunnelInterface(dpId, InterfaceManagerTestUtil.tunnelInterfaceName ,"Test hwVTEP Interface1", true, TunnelTypeVxlan.class, "192.168.56.101", "192.168.56.102");
 108         hwVTEPInterfaceDisabled = InterfaceManagerTestUtil.buildTunnelInterface(dpId, InterfaceManagerTestUtil.tunnelInterfaceName ,"Test hwVTEP Interface1", false, TunnelTypeVxlan.class, "192.168.56.101", "192.168.56.102");
 109         interfaceStateIdentifier = IfmUtil.buildStateInterfaceId(hwVTEPInterfaceEnabled.getName());
 110         parentRefs = hwVTEPInterfaceEnabled.getAugmentation(ParentRefs.class);
 111         ifTunnel = hwVTEPInterfaceEnabled.getAugmentation(IfTunnel.class);
 112         physicalSwitchId = SouthboundUtils.createPhysicalSwitchInstanceIdentifier("s1");
 113         globalId = SouthboundUtils.createPhysicalSwitchInstanceIdentifier("s1");
 114         tunnelsInstanceIdentifier = org.opendaylight.vpnservice.interfacemgr.renderer.hwvtep.utilities.SouthboundUtils.
 115                 createTunnelsInstanceIdentifier(physicalSwitchId,
 116                         ifTunnel.getTunnelSource(), ifTunnel.getTunnelDestination());
 117         tunnelInterfaceId = InstanceIdentifier.builder(TunnelInstanceInterfaceMap.class).
 118                 child(TunnelInstanceInterface.class, new TunnelInstanceInterfaceKey(tunnelsInstanceIdentifier.toString())).build();
 119         tunnelInterface = new TunnelInstanceInterfaceBuilder().
 120                 setTunnelInstanceIdentifier(tunnelsInstanceIdentifier.toString()).setKey(new TunnelInstanceInterfaceKey(tunnelsInstanceIdentifier.toString())).setInterfaceName(hwVTEPInterfaceEnabled.getName()).build();
 121
 122         //Setup termination points
 123         TerminationPointKey tpKey = SouthboundUtils.getTerminationPointKey(ifTunnel.getTunnelDestination().getIpv4Address().getValue());
 124         tpPath = SouthboundUtils.createInstanceIdentifier(globalId, tpKey);
 125         TerminationPointBuilder tpBuilder = new TerminationPointBuilder();
 126         HwvtepPhysicalLocatorAugmentationBuilder tpAugmentationBuilder =
 127                 new HwvtepPhysicalLocatorAugmentationBuilder();
 128         tpBuilder.setKey(tpKey);
 129         tpBuilder.setTpId(tpKey.getTpId());
 130         tpAugmentationBuilder.setEncapsulationType(EncapsulationTypeVxlanOverIpv4.class);
 131         SouthboundUtils.setDstIp(tpAugmentationBuilder, ifTunnel.getTunnelDestination());
 132         tpBuilder.addAugmentation(HwvtepPhysicalLocatorAugmentation.class, tpAugmentationBuilder.build());
 133         terminationPoint = tpBuilder.build();
 134         // Setup mocks
 135         when(dataBroker.newReadOnlyTransaction()).thenReturn(mockReadTx);
 136         when(dataBroker.newWriteOnlyTransaction()).thenReturn(mockWriteTx);
 137     }
 138
 139     @Test
 140     public void testAddHwVTEPInterfaceWithGlobalNodeId() {
 141         addHelper.addConfiguration(dataBroker, physicalSwitchId, globalId,
 142                 hwVTEPInterfaceEnabled, ifTunnel);
 143
 144         //Verify
 145         verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, tpPath, terminationPoint, true);
 146         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, tunnelInterfaceId, tunnelInterface, true);
 147     }
 148
 149     @Test
 150     public void testAddHwVTEPInterfaceWithoutGlobalNodeId() {
 151
 152         addHelper.addConfiguration(dataBroker, physicalSwitchId ,null ,
 153                 hwVTEPInterfaceEnabled, ifTunnel);
 154
 155         //Verification already performed in testAddHwVTEPInterfaceWithGlobalNodeId()
 156     }
 157
 158     @Test
 159     public void testAddHwVTEPInterfaceWhenAdminStateDisabled() {
 160
 161         addHelper.addConfiguration(dataBroker, physicalSwitchId, globalId,
 162                 hwVTEPInterfaceDisabled, ifTunnel);
 163
 164         //Verification already performed in testAddHwVTEPInterfaceWithGlobalNodeId()
 165     }
 166     @Test
 167     public void testDeleteHWVTEPInterface() {
 168         removeHelper.removeConfiguration(dataBroker, hwVTEPInterfaceEnabled, physicalSwitchId, globalId);
 169         //verification
 170         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION, tpPath);
 171         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, interfaceStateIdentifier);
 172         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, tunnelsInstanceIdentifier);
 173     }
 174
 175     @Test
 176     public void testUpdatePhysicalSwitch(){
 177
 178         Optional<TunnelInstanceInterface> tunnelInterfaceOptional = Optional.of(tunnelInterface);
 179
 180         doReturn(Futures.immediateCheckedFuture(tunnelInterfaceOptional)).when(mockReadTx).read(
 181                 LogicalDatastoreType.OPERATIONAL, tunnelInterfaceId);
 182         List<BfdStatus> bfdStatus = new ArrayList<BfdStatus>();
 183         bfdStatus.add(new BfdStatusBuilder().setBfdStatusKey(SouthboundUtils.BFD_OP_STATE).setBfdStatusValue(SouthboundUtils.BFD_STATE_UP).build());
 184         List bfdStatusSpy = spy(bfdStatus);
 185         when(newTunnel.getBfdStatus()).thenReturn(bfdStatusSpy);
 186         updateHelper.updatePhysicalSwitch(dataBroker, tunnelsInstanceIdentifier, newTunnel, oldTunnel);
 187
 188         //verify
 189         InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> ifStateId =
 190                 IfmUtil.buildStateInterfaceId(hwVTEPInterfaceEnabled.getName());
 191         InterfaceBuilder ifaceBuilder = new InterfaceBuilder().setOperStatus(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus.Up);
 192         ifaceBuilder.setKey(IfmUtil.getStateInterfaceKeyFromName(hwVTEPInterfaceEnabled.getName()));
 193         verify(mockWriteTx).merge(LogicalDatastoreType.OPERATIONAL, ifStateId, ifaceBuilder.build());
 194     }
 195
 196     @Test
 197     public void testStartBFDMonitoring(){
 198
 199         updateHelper.startBfdMonitoring(dataBroker, tunnelsInstanceIdentifier, newTunnel);
 200
 201         TunnelsBuilder tBuilder = new TunnelsBuilder();
 202         tBuilder.setKey(new TunnelsKey(newTunnel.getLocalLocatorRef(), newTunnel.getRemoteLocatorRef()));
 203         tBuilder.setLocalLocatorRef(newTunnel.getLocalLocatorRef());
 204         tBuilder.setRemoteLocatorRef(newTunnel.getLocalLocatorRef());
 205         List <BfdParams> bfdParams = new ArrayList<>();
 206         SouthboundUtils.fillBfdParameters(bfdParams, null);
 207         tBuilder.setBfdParams(bfdParams);
 208         //Verify
 209         verify(mockWriteTx).put(LogicalDatastoreType.CONFIGURATION, tunnelsInstanceIdentifier, tBuilder.build(), true);
 210     }
 211
 212     @Test
 213     public void testRemoveExternalTunnels(){
 214
 215         stateRemoveHelper.removeExternalTunnel(dataBroker, tunnelsInstanceIdentifier);
 216
 217         //Verify
 218         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION, tunnelsInstanceIdentifier);
 219     }
 220 }