Use Topology Node in place of Inventory Node
[ovsdb.git] / openstack / net-virt / src / test / java / org / opendaylight / ovsdb / openstack / netvirt / impl / VlanConfigurationCacheImplTest.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 package org.opendaylight.ovsdb.openstack.netvirt.impl;
9
10 import static org.junit.Assert.assertEquals;
11 import static org.mockito.Matchers.any;
12 import static org.mockito.Matchers.anyString;
13 import static org.mockito.Matchers.same;
14 import static org.mockito.Mockito.mock;
15 import static org.mockito.Mockito.when;
16
17 import java.util.HashSet;
18 import java.util.Set;
19 import java.util.concurrent.ConcurrentHashMap;
20
21 import org.junit.Before;
22 import org.junit.Ignore;
23 import org.junit.Test;
24 import org.junit.runner.RunWith;
25 import org.mockito.InjectMocks;
26 import org.mockito.Mock;
27 import org.mockito.runners.MockitoJUnitRunner;
28 import org.opendaylight.neutron.spi.NeutronNetwork;
29 import org.opendaylight.ovsdb.lib.notation.Column;
30 import org.opendaylight.ovsdb.lib.notation.Row;
31 import org.opendaylight.ovsdb.lib.notation.UUID;
32 import org.opendaylight.ovsdb.lib.schema.GenericTableSchema;
33 import org.opendaylight.ovsdb.schema.openvswitch.Interface;
34 import org.opendaylight.ovsdb.schema.openvswitch.Port;
35 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
36
37 /**
38  * Unit test for {@link VlanConfigurationCacheImpl}
39  */
40 @RunWith(MockitoJUnitRunner.class)
41 public class VlanConfigurationCacheImplTest {
42
43     @InjectMocks public VlanConfigurationCacheImpl vlanConfigurationCacheImpl;
44     @InjectMocks private TenantNetworkManagerImpl tenantNetworkManagerImpl = mock(TenantNetworkManagerImpl.class);
45
46     private static final String NODE_UUID = "nodeUUID";
47     private static final String NETWORK_ID= "networkId";
48
49     /**
50      * Function configuring the node
51      */
52     @Before
53     public void setUp(){
54         Row row = mock(Row.class);
55         Port port = mock(Port.class);
56
57         ConcurrentHashMap<String, Row> ovsTable;
58         ovsTable = new ConcurrentHashMap<>();
59         ovsTable.put(NODE_UUID, row);
60
61         Set<Long> tags = new HashSet<Long>();
62         tags.add(Long.valueOf(1));
63
64         UUID uuid = mock(UUID.class);
65         Set<UUID> uuidSet = new HashSet<>();
66         uuidSet.add(uuid);
67
68         Column<GenericTableSchema, Set<Long>> longColumnMock = mock(Column.class);
69         Column<GenericTableSchema, Set<UUID>> uuidColumnMock = mock(Column.class);
70
71         Interface iface = mock(Interface.class);
72         NeutronNetwork neutronNetwork = mock(NeutronNetwork.class);
73
74         /* TODO SB_MIGRATION */
75         //when(ovsdbConfigurationService.getRows(any(Node.class), anyString())).thenReturn(ovsTable);
76         //when(ovsdbConfigurationService.getTypedRow(any(Node.class), same(Port.class), any(Row.class))).thenReturn(port);
77
78         when(port.getTagColumn()).thenReturn(longColumnMock);
79         when(longColumnMock.getData()).thenReturn(tags);
80         when(port.getInterfacesColumn()).thenReturn(uuidColumnMock);
81         when(uuidColumnMock.getData()).thenReturn(uuidSet);
82
83         //when(ovsdbConfigurationService.getRow(any(Node.class), anyString(), anyString())).thenReturn(row);
84         //when(ovsdbConfigurationService.getTypedRow(any(Node.class), same(Interface.class), any(Row.class))).thenReturn(iface);
85
86         when(tenantNetworkManagerImpl.getTenantNetwork(any(Interface.class))).thenReturn(neutronNetwork);
87         when(neutronNetwork.getNetworkUUID()).thenReturn(NETWORK_ID);
88     }
89
90     /**
91      * Test method {@link VlanConfigurationCacheImpl#assignInternalVlan(Node, String)}
92      */
93     /* TODO SB_MIGRATION */
94     @Ignore
95     @Test
96     public void testAssignInternalVlan() {
97         assertEquals("Error, did not return the correct internalVlanId (first added)", 1, (int) vlanConfigurationCacheImpl.assignInternalVlan(any(Node.class), NETWORK_ID));
98         assertEquals("Error, did not return the correct internalVlanId (second added)", 2, (int) vlanConfigurationCacheImpl.assignInternalVlan(any(Node.class), NETWORK_ID + "1"));
99     }
100
101     /**
102      * Test method {@link VlanConfigurationCacheImpl#reclaimInternalVlan(Node, String)}
103      */
104     @Test
105     public void testReclaimInternalVlan(){
106         /* TODO SB_MIGRATION */
107         //assertEquals("Error, did not return the correct internalVlanId", 1, (int) vlanConfigurationCacheImpl.reclaimInternalVlan(any(Node.class), NETWORK_ID));
108     }
109
110     /**
111      * Test method {@link VlanConfigurationCacheImpl#getInternalVlan(Node, String)}
112      */
113     @Test
114     public void testGetInternalVlan(){
115         /* TODO SB_MIGRATION */
116         //assertEquals("Error, did not return the correct internalVlan", 1, (int) vlanConfigurationCacheImpl.getInternalVlan(any(Node.class), NETWORK_ID));
117     }
118 }