Migrate addresstracker notification integration
[l2switch.git] / addresstracker / implementation / src / test / java / org / opendaylight / l2switch / addresstracker / addressobserver / AddressObserverUsingIpv4Test.java
1 /*
2  * Copyright (c) 2014 Cisco Systems, Inc. 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.l2switch.addresstracker.addressobserver;
9
10 import static org.mockito.ArgumentMatchers.any;
11 import static org.mockito.Mockito.mock;
12 import static org.mockito.Mockito.times;
13 import static org.mockito.Mockito.verify;
14
15 import java.util.ArrayList;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.PacketChain;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.PacketChainBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.packet.chain.packet.RawPacketBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.basepacket.rev140528.packet.chain.grp.packet.chain.packet.raw.packet.RawPacketFieldsBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ethernet.rev140528.ethernet.packet.received.packet.chain.packet.EthernetPacketBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ipv4.rev140528.Ipv4PacketReceived;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ipv4.rev140528.Ipv4PacketReceivedBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.ipv4.rev140528.ipv4.packet.received.packet.chain.packet.Ipv4PacketBuilder;
30
31 public class AddressObserverUsingIpv4Test {
32
33     private AddressObservationWriter addressObservationWriterMock;
34
35     @Before
36     public void init() {
37         addressObservationWriterMock = mock(AddressObservationWriter.class);
38     }
39
40     @Test
41     public void onIpv4PacketReceivedTest() throws Exception {
42         ArrayList<PacketChain> packetChainList = new ArrayList<>();
43         packetChainList.add(new PacketChainBuilder()
44                 .setPacket(new RawPacketBuilder().setRawPacketFields(new RawPacketFieldsBuilder().build()).build())
45                 .build());
46         packetChainList.add(new PacketChainBuilder()
47                 .setPacket(new EthernetPacketBuilder().setSourceMac(new MacAddress("aa:bb:cc:dd:ee:ff")).build())
48                 .build());
49         packetChainList.add(new PacketChainBuilder()
50                 .setPacket(new Ipv4PacketBuilder().setSourceIpv4(new Ipv4Address("1.2.3.4")).build()).build());
51
52         Ipv4PacketReceived ipv4PktReceived = new Ipv4PacketReceivedBuilder().setPacketChain(packetChainList).build();
53         AddressObserverUsingIpv4 addressObserverIpv4 = new AddressObserverUsingIpv4(addressObservationWriterMock);
54         addressObserverIpv4.onNotification(ipv4PktReceived);
55
56         verify(addressObservationWriterMock, times(1)).addAddress(any(MacAddress.class), any(IpAddress.class), any());
57     }
58
59     @Test
60     public void onIpv4PacketReceivedNullInputTest1() throws Exception {
61
62         Ipv4PacketReceived ipv4PktReceived = new Ipv4PacketReceivedBuilder().setPacketChain(null).build();
63         AddressObserverUsingIpv4 addressObserverIpv4 = new AddressObserverUsingIpv4(addressObservationWriterMock);
64         addressObserverIpv4.onNotification(ipv4PktReceived);
65
66         verify(addressObservationWriterMock, times(0)).addAddress(any(MacAddress.class), any(IpAddress.class),
67                 any(NodeConnectorRef.class));
68     }
69
70     @Test
71     public void onIpv4PacketReceivedNullInputTest2() throws Exception {
72
73         ArrayList<PacketChain> packetChainList = new ArrayList<>();
74         packetChainList.add(new PacketChainBuilder().setPacket(new RawPacketBuilder().build()).build());
75         packetChainList.add(new PacketChainBuilder()
76                 .setPacket(new EthernetPacketBuilder().setSourceMac(new MacAddress("aa:bb:cc:dd:ee:ff")).build())
77                 .build());
78
79         Ipv4PacketReceived ipv4PktReceived = new Ipv4PacketReceivedBuilder().setPacketChain(packetChainList).build();
80         AddressObserverUsingIpv4 addressObserverIpv4 = new AddressObserverUsingIpv4(addressObservationWriterMock);
81         addressObserverIpv4.onNotification(ipv4PktReceived);
82
83         verify(addressObservationWriterMock, times(0)).addAddress(any(MacAddress.class), any(IpAddress.class),
84                 any(NodeConnectorRef.class));
85     }
86
87     @Test
88     public void onIpv4PacketReceivedNullInputTest3() throws Exception {
89
90         ArrayList<PacketChain> packetChainList = new ArrayList<>();
91         packetChainList.add(new PacketChainBuilder().setPacket(new RawPacketBuilder().build()).build());
92         packetChainList.add(new PacketChainBuilder()
93                 .setPacket(new EthernetPacketBuilder().setSourceMac(new MacAddress("aa:bb:cc:dd:ee:ff")).build())
94                 .build());
95         packetChainList.add(new PacketChainBuilder()
96                 .setPacket(new Ipv4PacketBuilder().setSourceIpv4(new Ipv4Address("0.0.0.0")).build()).build());
97
98         Ipv4PacketReceived ipv4PktReceived = new Ipv4PacketReceivedBuilder().setPacketChain(packetChainList).build();
99         AddressObserverUsingIpv4 addressObserverIpv4 = new AddressObserverUsingIpv4(addressObservationWriterMock);
100         addressObserverIpv4.onNotification(ipv4PktReceived);
101
102         verify(addressObservationWriterMock, times(0)).addAddress(any(MacAddress.class), any(IpAddress.class),
103                 any(NodeConnectorRef.class));
104     }
105 }