openstack/net-virt/src/test/java/org/opendaylight/ovsdb/openstack/netvirt/NetworkHandlerTest.java

   1 /*
   2  * Copyright (c) 2015 Inocybe 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.ovsdb.openstack.netvirt;
  10
  11 import static org.junit.Assert.assertEquals;
  12 import static org.mockito.Matchers.any;
  13 import static org.mockito.Matchers.anyString;
  14 import static org.mockito.Matchers.same;
  15 import static org.mockito.Mockito.mock;
  16 import static org.mockito.Mockito.times;
  17 import static org.mockito.Mockito.verify;
  18 import static org.mockito.Mockito.when;
  19
  20 import java.net.HttpURLConnection;
  21 import java.util.ArrayList;
  22 import java.util.HashSet;
  23 import java.util.List;
  24 import java.util.Set;
  25 import java.util.concurrent.ConcurrentHashMap;
  26 import java.util.concurrent.ConcurrentMap;
  27
  28 import org.junit.Ignore;
  29 import org.junit.Test;
  30 import org.junit.runner.RunWith;
  31 import org.mockito.InjectMocks;
  32 import org.mockito.Mock;
  33 import org.mockito.Mockito;
  34 import org.mockito.runners.MockitoJUnitRunner;
  35 import org.opendaylight.neutron.spi.INeutronNetworkCRUD;
  36 import org.opendaylight.neutron.spi.NeutronNetwork;
  37 import org.opendaylight.ovsdb.lib.notation.Column;
  38 import org.opendaylight.ovsdb.lib.notation.Row;
  39 import org.opendaylight.ovsdb.lib.notation.UUID;
  40 import org.opendaylight.ovsdb.lib.schema.GenericTableSchema;
  41 import org.opendaylight.ovsdb.openstack.netvirt.api.Action;
  42 import org.opendaylight.ovsdb.openstack.netvirt.api.BridgeConfigurationManager;
  43 import org.opendaylight.ovsdb.openstack.netvirt.api.TenantNetworkManager;
  44 import org.opendaylight.ovsdb.openstack.netvirt.impl.NeutronL3Adapter;
  45 import org.opendaylight.ovsdb.schema.openvswitch.Interface;
  46 import org.opendaylight.ovsdb.schema.openvswitch.Port;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  48
  49 /**
  50  * Unit test for {@link NetworkHandler}
  51  */
  52 @RunWith(MockitoJUnitRunner.class)
  53 public class NetworkHandlerTest {
  54
  55     @InjectMocks NetworkHandler networkHandler;
  56
  57     @Mock NeutronNetwork neutronNetwork;
  58
  59     @Mock private NeutronL3Adapter neutronL3Adapter;
  60     @Mock private TenantNetworkManager tenantNetworkManager;
  61     @Mock private INeutronNetworkCRUD neutronNetworkCache;
  62     @Mock private BridgeConfigurationManager bridgeConfigurationManager;
  63
  64     /**
  65      * Test method {@link NetworkHandler#canCreateNetwork(NeutronNetwork)}
  66      */
  67     @Test
  68     public void testCanCreateNetwork() {
  69         when(neutronNetwork.isShared())
  70                                     .thenReturn(true)
  71                                     .thenReturn(false);
  72         assertEquals("Error, did not return the correct HTTP flag", HttpURLConnection.HTTP_NOT_ACCEPTABLE, networkHandler.canCreateNetwork(neutronNetwork));
  73         assertEquals("Error, did not return the correct HTTP flag", HttpURLConnection.HTTP_CREATED, networkHandler.canCreateNetwork(neutronNetwork));
  74     }
  75
  76     /**
  77      * Test method {@link NetworkHandler#canUpdateNetwork(NeutronNetwork, NeutronNetwork)}
  78      */
  79     @Test
  80     public void testCanUpdateNetwork() {
  81         assertEquals("Error, did not return the correct HTTP flag", HttpURLConnection.HTTP_OK, networkHandler.canUpdateNetwork(neutronNetwork, neutronNetwork));
  82     }
  83
  84     /**
  85      * Test method {@link NetworkHandler#canDeleteNetwork(NeutronNetwork)}
  86      */
  87     @Test
  88     public void testCanDeleteNetwork() {
  89         assertEquals("Error, did not return the correct HTTP flag", HttpURLConnection.HTTP_OK, networkHandler.canDeleteNetwork(neutronNetwork));
  90     }
  91
  92     /**
  93      * Test method {@link NetworkHandler#processEvent(AbstractEvent)}
  94      */
  95     /* TODO SB_MIGRATION */ @Ignore
  96     @Test
  97     public void testProcessEvent() {
  98         NetworkHandler networkHandlerSpy = Mockito.spy(networkHandler);
  99
 100         NorthboundEvent ev = mock(NorthboundEvent.class);
 101         when(ev.getNeutronNetwork()).thenReturn(neutronNetwork);
 102
 103         when(ev.getAction()).thenReturn(Action.ADD);
 104         networkHandlerSpy.processEvent(ev);
 105         verify(neutronL3Adapter, times(1)).handleNeutronNetworkEvent(any(NeutronNetwork.class), same(Action.ADD));
 106
 107         when(ev.getAction()).thenReturn(Action.UPDATE);
 108         networkHandlerSpy.processEvent(ev);
 109         verify(neutronL3Adapter, times(1)).handleNeutronNetworkEvent(any(NeutronNetwork.class), same(Action.UPDATE));
 110
 111         /* configuration needed to pass doNeutronNetworkDeleted() function*/
 112         Node node = mock(Node.class);
 113         List<Node> nodes = new ArrayList();
 114         nodes.add(node);
 115         /* TODO SB_MIGRATION */
 116         //when(connectionService.getNodes()).thenReturn(nodes);
 117
 118         ConcurrentMap<String, Row> ports = new ConcurrentHashMap<>();
 119         Row row = mock(Row.class);
 120         ports.put("key", row);
 121         //when(ovsdbConfigurationService.getRows(any(Node.class), anyString())).thenReturn(ports);
 122
 123         Port port = mock(Port.class);
 124         Column<GenericTableSchema, Set<UUID>> portColumns = mock(Column.class);
 125         Set<UUID> interfaceUUIDs = new HashSet<UUID>();
 126         UUID uuid = mock(UUID.class);
 127         interfaceUUIDs.add(uuid);
 128         when(port.getInterfacesColumn()).thenReturn(portColumns);
 129         when(portColumns.getData()).thenReturn(interfaceUUIDs);
 130         //when(ovsdbConfigurationService.getTypedRow(any(Node.class), same(Port.class), any(Row.class))).thenReturn(port);
 131
 132         Interface iface = mock(Interface.class);
 133         Column<GenericTableSchema, String> ifaceColumns = mock(Column.class);
 134         when(iface.getTypeColumn()).thenReturn(ifaceColumns);
 135         when(ifaceColumns.getData()).thenReturn(NetworkHandler.NETWORK_TYPE_VXLAN);
 136         //when(ovsdbConfigurationService.getTypedRow(any(Node.class), same(Interface.class), any(Row.class))).thenReturn(iface);
 137         /**/
 138
 139         when(ev.getAction()).thenReturn(Action.DELETE);
 140         networkHandlerSpy.processEvent(ev);
 141         /* TODO SB_MIGRATION */
 142         //verify(neutronL3Adapter, times(1)).handleNeutronNetworkEvent(any(NeutronNetwork.class), same(Action.DELETE));
 143         verify(networkHandlerSpy, times(1)).canDeleteNetwork(any(NeutronNetwork.class));
 144         verify(tenantNetworkManager, times(1)).networkDeleted(anyString());
 145     }
 146 }