2 * Copyright (c) 2016 Hewlett-Packard Development Company, L.P. All rights reserved.
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
8 package org.opendaylight.netvirt.neutronvpn;
10 import static org.mockito.ArgumentMatchers.any;
11 import static org.mockito.Mockito.doReturn;
12 import static org.mockito.Mockito.when;
14 import java.util.ArrayList;
15 import java.util.List;
16 import java.util.Optional;
17 import org.junit.After;
18 import org.junit.Before;
19 import org.junit.Test;
20 import org.junit.runner.RunWith;
21 import org.mockito.Mock;
22 import org.mockito.junit.MockitoJUnitRunner;
23 import org.opendaylight.genius.datastoreutils.listeners.DataTreeEventCallbackRegistrar;
24 import org.opendaylight.infrautils.caches.baseimpl.internal.CacheManagersRegistryImpl;
25 import org.opendaylight.infrautils.caches.guava.internal.GuavaCacheProvider;
26 import org.opendaylight.infrautils.jobcoordinator.internal.JobCoordinatorImpl;
27 import org.opendaylight.infrautils.metrics.MetricProvider;
28 import org.opendaylight.infrautils.metrics.testimpl.TestMetricProviderImpl;
29 import org.opendaylight.mdsal.binding.api.DataBroker;
30 import org.opendaylight.mdsal.binding.api.ReadTransaction;
31 import org.opendaylight.mdsal.binding.api.WriteTransaction;
32 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
33 import org.opendaylight.netvirt.elanmanager.api.IElanService;
34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.ElanInstances;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.instances.ElanInstance;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.instances.ElanInstanceKey;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.config.rev160806.NeutronvpnConfig;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.port.attributes.FixedIps;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.port.attributes.FixedIpsBuilder;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.PortBuilder;
49 import org.opendaylight.yangtools.util.concurrent.FluentFutures;
50 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
52 @RunWith(MockitoJUnitRunner.class)
53 public class NeutronPortChangeListenerTest {
55 NeutronPortChangeListener neutronPortChangeListener;
58 DataBroker dataBroker;
60 NeutronvpnManager neutronvpnManager;
62 NeutronvpnNatManager neutronvpnNatManager;
64 WriteTransaction mockWriteTx;
66 ReadTransaction mockReadTx;
70 ElanInstance elanInstance;
72 NeutronSubnetGwMacResolver gwMacResolver;
74 IElanService elanService;
76 IdManagerService idManager;
78 IPV6InternetDefaultRouteProgrammer ipV6InternetDefRt;
80 DataTreeEventCallbackRegistrar dataTreeEventCallbackRegistrar;
82 NeutronvpnConfig neutronvpnConfig;
85 MetricProvider metricProvider = new TestMetricProviderImpl();
87 private final JobCoordinatorImpl jobCoordinator = new JobCoordinatorImpl(metricProvider);
91 doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
92 when(mockReadTx.read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class)))
93 .thenReturn(FluentFutures.immediateFluentFuture(Optional.of(mockNetwork)));
94 neutronPortChangeListener = new NeutronPortChangeListener(dataBroker, neutronvpnManager, neutronvpnNatManager,
95 gwMacResolver, elanService, jobCoordinator, new NeutronvpnUtils(dataBroker, idManager, jobCoordinator,
97 new HostConfigCache(dataBroker, new GuavaCacheProvider(new CacheManagersRegistryImpl())),
98 dataTreeEventCallbackRegistrar,neutronvpnConfig);
99 InstanceIdentifier<ElanInstance> elanIdentifierId = InstanceIdentifier.builder(ElanInstances.class)
100 .child(ElanInstance.class,
101 new ElanInstanceKey(new Uuid("12345678-1234-1234-1234-123456789012").getValue())).build();
105 public void cleanup() {
106 jobCoordinator.destroy();
110 public void addPort__Ipv6FixedIps() throws Exception {
111 PortBuilder pb = new PortBuilder();
112 pb.setUuid(new Uuid("12345678-1234-1234-1234-123456789012"));
113 pb.setNetworkId(new Uuid("12345678-1234-1234-1234-123456789012"));
114 pb.setMacAddress(new MacAddress("AA:BB:CC:DD:EE:FF"));
115 IpAddress ipv6 = new IpAddress(new Ipv6Address("1::1"));
116 FixedIpsBuilder fib = new FixedIpsBuilder();
117 fib.setIpAddress(ipv6);
118 fib.setSubnetId(new Uuid("12345678-1234-1234-1234-123456789012"));
119 List<FixedIps> fixedIps = new ArrayList<>();
120 fixedIps.add(fib.build());
121 pb.setFixedIps(fixedIps);
122 Port port = pb.build();
123 neutronPortChangeListener.add(InstanceIdentifier.create(Port.class), port);
127 public void addPort__Ipv4FixedIps() throws Exception {
128 PortBuilder pb = new PortBuilder();
129 pb.setUuid(new Uuid("12345678-1234-1234-1234-123456789012"));
130 pb.setNetworkId(new Uuid("12345678-1234-1234-1234-123456789012"));
131 pb.setMacAddress(new MacAddress("AA:BB:CC:DD:EE:FF"));
132 IpAddress ipv4 = new IpAddress(new Ipv4Address("2.2.2.2"));
133 FixedIpsBuilder fib = new FixedIpsBuilder();
134 fib.setIpAddress(ipv4);
135 fib.setSubnetId(new Uuid("12345678-1234-1234-1234-123456789012"));
136 List<FixedIps> fixedIps = new ArrayList<>();
137 fixedIps.add(fib.build());
138 pb.setFixedIps(fixedIps);
139 Port port = pb.build();
140 neutronPortChangeListener.add(InstanceIdentifier.create(Port.class), port);
144 public void addPort__NoFixedIps() throws Exception {
145 PortBuilder pb = new PortBuilder();
146 pb.setUuid(new Uuid("12345678-1234-1234-1234-123456789012"));
147 pb.setNetworkId(new Uuid("12345678-1234-1234-1234-123456789012"));
148 pb.setMacAddress(new MacAddress("AA:BB:CC:DD:EE:FF"));
149 List<FixedIps> fixedIps = new ArrayList<>();
150 pb.setFixedIps(fixedIps);
151 Port port = pb.build();
152 neutronPortChangeListener.add(InstanceIdentifier.create(Port.class), port);