mappingservice/implementation/src/test/java/org/opendaylight/lispflowmapping/implementation/util/LispNotificationHelperTest.java

   1 /*
   2  * Copyright (c) 2016 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.lispflowmapping.implementation.util;
   9
  10 import static org.junit.Assert.assertEquals;
  11 import static org.junit.Assert.assertNull;
  12
  13 import com.google.common.collect.Lists;
  14 import com.google.common.net.InetAddresses;
  15 import java.net.InetAddress;
  16 import java.net.UnknownHostException;
  17 import org.junit.Test;
  18 import org.opendaylight.lispflowmapping.lisp.type.LispMessage;
  19 import org.opendaylight.lispflowmapping.lisp.util.LispAddressUtil;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv6Address;
  25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
  26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.DistinguishedNameType;
  27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.SimpleAddress;
  28 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.ApplicationData;
  29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.ApplicationDataBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.DistinguishedNameBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.Ipv4PrefixBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.KeyValueAddress;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types.rev151105.lisp.address.address.KeyValueAddressBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.inet.binary.types.rev160303.IpAddressBinary;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.inet.binary.types.rev160303.Ipv4AddressBinary;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.inet.binary.types.rev160303.Ipv6AddressBinary;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.AddMapping;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.AddMappingBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.SiteId;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.container.Eid;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.mapping.record.container.MappingRecordBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.mapping.record.list.MappingRecordItem;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.mapping.record.list.MappingRecordItemBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.mapregisternotification.MapRegisterBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.rloc.container.Rloc;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.rloc.container.RlocBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.transport.address.TransportAddress;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.transport.address.TransportAddressBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.mappingservice.rev150906.EidUri;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.mappingservice.rev150906.MappingOrigin;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.mappingservice.rev150906.db.instance.MappingBuilder;
  52
  53 public class LispNotificationHelperTest {
  54
  55     private static final String IPV4_STRING = "1.2.3.0";
  56     private static final String IPV6_STRING = "1111:2222:3333:4444:5555:6666:7777:8888";
  57
  58     private static final Ipv4Address ADDRESS_IPV4 = new Ipv4Address(IPV4_STRING);
  59     private static final Ipv6Address ADDRESS_IPV6 = new Ipv6Address(IPV6_STRING);
  60     private static final Ipv4AddressBinary ADDRESS_IPV4_BINARY = new Ipv4AddressBinary(InetAddresses
  61             .forString(IPV4_STRING).getAddress());
  62     private static final Ipv6AddressBinary ADDRESS_IPV6_BINARY = new Ipv6AddressBinary(InetAddresses
  63             .forString(IPV6_STRING).getAddress());
  64
  65     private static final int PORT = 9999;
  66     private static final DistinguishedNameType DISTINGUISHED_NAME_TYPE =
  67             new DistinguishedNameType(IPV4_STRING + ":" + PORT);
  68
  69     private static final Eid EID_IPV4 = LispAddressUtil.asIpv4Eid(IPV4_STRING);
  70     private static final Eid EID_IPV6 = LispAddressUtil.asIpv6Eid(IPV6_STRING);
  71
  72     private static final Rloc RLOC_IPV4 = LispAddressUtil.toRloc(ADDRESS_IPV4);
  73     private static final Rloc RLOC_IPV6 = LispAddressUtil.toRloc(ADDRESS_IPV6);
  74     private static final Rloc RLOC_IPV4_BINARY = LispAddressUtil.toRloc(ADDRESS_IPV4_BINARY);
  75     private static final Rloc RLOC_IPV6_BINARY = LispAddressUtil.toRloc(ADDRESS_IPV6_BINARY);
  76     private static final Rloc RLOC_KEYVALUE_ADDRESS = new RlocBuilder().setAddress(getDefaultKeyValueAddress()).build();
  77     private static final Rloc RLOC_DISTINGUISHED_NAME_ADDRESS = new RlocBuilder()
  78             .setAddress(new DistinguishedNameBuilder().setDistinguishedName(DISTINGUISHED_NAME_TYPE).build()).build();
  79     private static final Rloc RLOC_APPLICATION_DATA_IPV4 = new RlocBuilder()
  80             .setAddress(getDefaultApplicationDataForIpv4()).build();
  81     private static final Rloc RLOC_APPLICATION_DATA_IPV6 = new RlocBuilder()
  82             .setAddress(getDefaultApplicationDataForIpv6()).build();
  83     private static final Rloc RLOC_APPLICATION_DATA_IPV6_PREFIX = new RlocBuilder()
  84             .setAddress(getDefaultApplicationDataForIpv4Prefix()).build();
  85     private static final Rloc RLOC_IPV4_PREFIX = new RlocBuilder()
  86             .setAddress(new Ipv4PrefixBuilder().setIpv4Prefix(new Ipv4Prefix(IPV4_STRING + "/20")).build()).build();
  87
  88     private static final SiteId SITE_ID = new SiteId(new byte[]{0, 1, 2, 3, 4, 5, 6, 7});
  89
  90
  91     /**
  92      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with Ipv4 type address.
  93      */
  94     @Test
  95     public void getTransportAddressFromRlocTest_withIpv4Address() {
  96         final TransportAddress result = new TransportAddressBuilder()
  97                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV4_BINARY))
  98                 .setPort(new PortNumber(LispMessage.PORT_NUM)).build();
  99
 100         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_IPV4));
 101     }
 102
 103     /**
 104      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with Ipv6 type address.
 105      */
 106     @Test
 107     public void getTransportAddressFromRlocTest_withIpv6Address() {
 108         final TransportAddress result = new TransportAddressBuilder()
 109                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV6_BINARY))
 110                 .setPort(new PortNumber(LispMessage.PORT_NUM)).build();
 111
 112         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_IPV6));
 113     }
 114
 115     /**
 116      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with Ipv4AddressBinary type address.
 117      */
 118     @Test
 119     public void getTransportAddressFromRlocTest_withIpv4AddressBinary() {
 120         final TransportAddress result = new TransportAddressBuilder()
 121                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV4_BINARY))
 122                 .setPort(new PortNumber(LispMessage.PORT_NUM)).build();
 123
 124         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_IPV4_BINARY));
 125     }
 126
 127     /**
 128      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with Ipv6AddressBinary type address.
 129      */
 130     @Test
 131     public void getTransportAddressFromRlocTest_withIpv6AddressBinary() {
 132         final TransportAddress result = new TransportAddressBuilder()
 133                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV6_BINARY))
 134                 .setPort(new PortNumber(LispMessage.PORT_NUM)).build();
 135
 136         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_IPV6_BINARY));
 137     }
 138
 139     /**
 140      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with KeyValueAddress type address.
 141      */
 142     @Test
 143     public void getTransportAddressFromRlocTest_withKeyValueAddress() {
 144         final TransportAddress result = new TransportAddressBuilder()
 145                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV4_BINARY))
 146                 .setPort(new PortNumber(PORT)).build();
 147
 148         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_KEYVALUE_ADDRESS));
 149     }
 150
 151     /**
 152      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with DistinguishedName type address.
 153      */
 154     @Test
 155     public void getTransportAddressFromRlocTest_withDistinguishedNameAddress() {
 156         final TransportAddress result = new TransportAddressBuilder()
 157                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV4_BINARY))
 158                 .setPort(new PortNumber(PORT)).build();
 159
 160         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_DISTINGUISHED_NAME_ADDRESS));
 161     }
 162
 163     /**
 164      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with ApplicationData type Ipv4 address.
 165      */
 166     @Test
 167     public void getTransportAddressFromRlocTest_withApplicationDataIpv4Address() {
 168         final TransportAddress result = new TransportAddressBuilder()
 169                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV4_BINARY))
 170                 .setPort(new PortNumber(PORT)).build();
 171
 172         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_APPLICATION_DATA_IPV4));
 173     }
 174
 175     /**
 176      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with ApplicationData type Ipv6 address.
 177      */
 178     @Test
 179     public void getTransportAddressFromRlocTest_withApplicationDataIpv6Address() {
 180         final TransportAddress result = new TransportAddressBuilder()
 181                 .setIpAddress(new IpAddressBinary(ADDRESS_IPV6_BINARY))
 182                 .setPort(new PortNumber(PORT)).build();
 183
 184         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_APPLICATION_DATA_IPV6));
 185     }
 186
 187     /**
 188      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with ApplicationData type address.
 189      */
 190     @Test(expected = NullPointerException.class)
 191     public void getTransportAddressFromRlocTest_withApplicationDataIpv4PrefixAddress() {
 192         final TransportAddress result = new TransportAddressBuilder().build();
 193
 194         assertEquals(result, LispNotificationHelper.getTransportAddressFromRloc(RLOC_APPLICATION_DATA_IPV6_PREFIX));
 195     }
 196
 197     /**
 198      * Tests {@link LispNotificationHelper#getTransportAddressFromRloc} method with Ipv4Prefix type address.
 199      * Null address expected.
 200      */
 201     @Test
 202     public void getTransportAddressFromRlocTest_withIpv4PrefixAddress() {
 203         assertNull(LispNotificationHelper.getTransportAddressFromRloc(RLOC_IPV4_PREFIX).getIpAddress());
 204     }
 205
 206     /**
 207      * Tests {@link LispNotificationHelper#getAddressByName} method with correct address.
 208      */
 209     @Test
 210     public void getAddressByNameTest() throws UnknownHostException {
 211         final InetAddress result = InetAddress.getByName(IPV4_STRING);
 212         assertEquals(result, LispNotificationHelper.getAddressByName(IPV4_STRING));
 213     }
 214
 215     /**
 216      * Tests {@link LispNotificationHelper#getAddressByName} method with invalid address.
 217      */
 218     @Test
 219     public void getAddressByNameTest_withInvalidAddress() {
 220         assertNull(LispNotificationHelper.getAddressByName("[" + IPV4_STRING));
 221     }
 222
 223     /**
 224      * Tests {@link LispNotificationHelper#getMapping} method with invalid address.
 225      */
 226     @Test
 227     public void getMappingTest() {
 228         final MappingBuilder mappingBuilder_1 = new MappingBuilder()
 229                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV4).build())
 230                 .setEidUri(new EidUri("ipv4:" + IPV4_STRING))
 231                 .setOrigin(MappingOrigin.Southbound)
 232                 .setSiteId(Lists.newArrayList(SITE_ID));
 233
 234         final MappingBuilder mappingBuilder_2 = new MappingBuilder()
 235                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV6).build())
 236                 .setEidUri(new EidUri("ipv6:" + IPV6_STRING))
 237                 .setOrigin(MappingOrigin.Southbound)
 238                 .setSiteId(Lists.newArrayList(SITE_ID));
 239
 240         assertEquals(Lists.newArrayList(mappingBuilder_1.build(), mappingBuilder_2.build()),
 241                 LispNotificationHelper.getMapping(getDefaultAddMapping(true)));
 242     }
 243
 244     /**
 245      * Tests {@link LispNotificationHelper#getMapping} method with invalid address, isXtrSiteIdPresent == false.
 246      */
 247     @Test
 248     public void getMappingTest_SiteIdNotPresent() {
 249         final MappingBuilder mappingBuilder_1 = new MappingBuilder()
 250                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV4).build())
 251                 .setEidUri(new EidUri("ipv4:" + IPV4_STRING))
 252                 .setOrigin(MappingOrigin.Southbound);
 253
 254         final MappingBuilder mappingBuilder_2 = new MappingBuilder()
 255                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV6).build())
 256                 .setEidUri(new EidUri("ipv6:" + IPV6_STRING))
 257                 .setOrigin(MappingOrigin.Southbound);
 258
 259         assertEquals(Lists.newArrayList(mappingBuilder_1.build(), mappingBuilder_2.build()),
 260                 LispNotificationHelper.getMapping(getDefaultAddMapping(false)));
 261     }
 262
 263     private static KeyValueAddress getDefaultKeyValueAddress() {
 264         return new KeyValueAddressBuilder()
 265                 .setKeyValueAddress(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types
 266                         .rev151105.lisp.address.address.key.value.address.KeyValueAddressBuilder()
 267                         .setKey(new SimpleAddress(new DistinguishedNameType("key")))
 268                         .setValue(new SimpleAddress(DISTINGUISHED_NAME_TYPE)).build())
 269                 .build();
 270     }
 271
 272     private static ApplicationData getDefaultApplicationDataForIpv4() {
 273         return new ApplicationDataBuilder()
 274                 .setApplicationData(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types
 275                         .rev151105.lisp.address.address.application.data.ApplicationDataBuilder()
 276                         .setAddress(new SimpleAddress(new IpAddress(ADDRESS_IPV4)))
 277                         .setLocalPortLow(new PortNumber(PORT)).build())
 278                 .build();
 279     }
 280
 281     private static ApplicationData getDefaultApplicationDataForIpv6() {
 282         return new ApplicationDataBuilder()
 283                 .setApplicationData(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types
 284                         .rev151105.lisp.address.address.application.data.ApplicationDataBuilder()
 285                         .setAddress(new SimpleAddress(new IpAddress(ADDRESS_IPV6)))
 286                         .setLocalPortLow(new PortNumber(PORT)).build())
 287                 .build();
 288     }
 289
 290     private static ApplicationData getDefaultApplicationDataForIpv4Prefix() {
 291         return new ApplicationDataBuilder()
 292                 .setApplicationData(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.lisp.address.types
 293                         .rev151105.lisp.address.address.application.data.ApplicationDataBuilder()
 294                         .setAddress(new SimpleAddress(new IpPrefix(new Ipv4Prefix(IPV4_STRING + "/20"))))
 295                         .setLocalPortLow(new PortNumber(PORT)).build())
 296                 .build();
 297     }
 298
 299     private static AddMapping getDefaultAddMapping(boolean isXtrSiteIdPresent) {
 300         final MappingRecordItem mappingRecordItem_1 = new MappingRecordItemBuilder()
 301                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV4).build()).build();
 302         final MappingRecordItem mappingRecordItem_2 = new MappingRecordItemBuilder()
 303                 .setMappingRecord(new MappingRecordBuilder().setEid(EID_IPV6).build()).build();
 304
 305         final MapRegisterBuilder mapRegisterBuilder = new MapRegisterBuilder()
 306                 .setMappingRecordItem(Lists.newArrayList(mappingRecordItem_1, mappingRecordItem_2))
 307                 .setXtrSiteIdPresent(isXtrSiteIdPresent)
 308                 .setSiteId(SITE_ID);
 309
 310         return new AddMappingBuilder().setMapRegister(mapRegisterBuilder.build()).build();
 311     }
 312 }