bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/config/OpenConfigMappingUtilTest.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.protocol.bgp.rib.impl.config;
   9
  10 import static junit.framework.TestCase.assertFalse;
  11 import static org.junit.Assert.assertArrayEquals;
  12 import static org.junit.Assert.assertEquals;
  13 import static org.junit.Assert.assertNull;
  14 import static org.junit.Assert.assertTrue;
  15 import static org.mockito.Mockito.doReturn;
  16 import static org.mockito.MockitoAnnotations.initMocks;
  17 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.AFI_SAFI;
  18 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.AFI_SAFI_IPV4;
  19 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.MD5_PASSWORD;
  20 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.NEIGHBOR_ADDRESS;
  21 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.PORT;
  22 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.SHORT;
  23 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.createAfiSafi;
  24 import static org.opendaylight.protocol.bgp.rib.impl.config.BgpPeerTest.createNeighborExpected;
  25 import static org.opendaylight.protocol.bgp.rib.impl.config.OpenConfigMappingUtil.HOLDTIMER;
  26 import static org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IetfInetUtil.INSTANCE;
  27
  28 import com.google.common.collect.ImmutableMap;
  29 import java.math.BigDecimal;
  30 import java.nio.charset.StandardCharsets;
  31 import java.util.ArrayList;
  32 import java.util.HashMap;
  33 import java.util.List;
  34 import java.util.Map;
  35 import org.junit.Assert;
  36 import org.junit.Before;
  37 import org.junit.Test;
  38 import org.mockito.Mock;
  39 import org.opendaylight.protocol.bgp.mode.api.PathSelectionMode;
  40 import org.opendaylight.protocol.bgp.mode.impl.add.all.paths.AllPathSelection;
  41 import org.opendaylight.protocol.bgp.mode.impl.add.n.paths.AddPathBestNPathSelection;
  42 import org.opendaylight.protocol.bgp.openconfig.spi.BGPTableTypeRegistryConsumer;
  43 import org.opendaylight.protocol.bgp.parser.BgpTableTypeImpl;
  44 import org.opendaylight.protocol.bgp.parser.spi.pojo.RevisedErrorHandlingSupportImpl;
  45 import org.opendaylight.protocol.bgp.rib.impl.spi.RIB;
  46 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.multiprotocol.rev151009.bgp.common.afi.safi.list.AfiSafi;
  47 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.multiprotocol.rev151009.bgp.common.afi.safi.list.AfiSafiBuilder;
  48 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.multiprotocol.rev151009.bgp.common.afi.safi.list.AfiSafiKey;
  49 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.BgpNeighborTransportConfig;
  50 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.graceful.restart.GracefulRestartBuilder;
  51 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.AfiSafis;
  52 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.AfiSafisBuilder;
  53 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.ConfigBuilder;
  54 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.ErrorHandlingBuilder;
  55 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.RouteReflectorBuilder;
  56 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.TimersBuilder;
  57 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.Transport;
  58 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.TransportBuilder;
  59 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.transport.Config;
  60 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbors.Neighbor;
  61 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbors.NeighborBuilder;
  62 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbors.NeighborKey;
  63 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.peer.group.PeerGroup;
  64 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.peer.group.PeerGroupBuilder;
  65 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.top.Bgp;
  66 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.top.bgp.Neighbors;
  67 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV4UNICAST;
  68 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV6LABELLEDUNICAST;
  69 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.IPV6UNICAST;
  70 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.PeerType;
  71 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.types.rev151009.RrClusterIdType;
  72 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.NetworkInstances;
  73 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.NetworkInstance;
  74 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.NetworkInstanceKey;
  75 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.network.instance.Protocols;
  76 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.network.instance.protocols.Protocol;
  77 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.network.instance.rev151018.network.instance.top.network.instances.network.instance.protocols.ProtocolKey;
  78 import org.opendaylight.yang.gen.v1.http.openconfig.net.yang.policy.types.rev151009.BGP;
  79 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
  80 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  81 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressNoZone;
  82 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  83 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4AddressNoZone;
  84 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.BgpTableType;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.SendReceive;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamilies;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamiliesBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalAddPathsConfigBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalConfigAugmentation;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.GlobalConfigAugmentationBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfig;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborAddPathsConfigBuilder;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfig;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborPeerGroupConfigBuilder;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfig;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NeighborTransportConfigBuilder;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.NetworkInstanceProtocol;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.PeerGroupTransportConfig;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.PeerGroupTransportConfigBuilder;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.PeerRole;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv4AddressFamily;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.Ipv6AddressFamily;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.MplsLabeledVpnSubsequentAddressFamily;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.UnicastSubsequentAddressFamily;
 106 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 107 import org.opendaylight.yangtools.yang.common.Uint16;
 108 import org.opendaylight.yangtools.yang.common.Uint32;
 109 import org.opendaylight.yangtools.yang.common.Uint8;
 110
 111 public class OpenConfigMappingUtilTest {
 112     private static final Neighbor NEIGHBOR = createNeighborExpected(NEIGHBOR_ADDRESS);
 113     private static final String KEY = "bgp";
 114     private static final InstanceIdentifier<Bgp> BGP_II = InstanceIdentifier.create(NetworkInstances.class)
 115         .child(NetworkInstance.class, new NetworkInstanceKey("identifier-test")).child(Protocols.class)
 116         .child(Protocol.class, new ProtocolKey(BGP.class, KEY)).augmentation(NetworkInstanceProtocol.class)
 117             .child(Bgp.class);
 118     private static final NeighborKey NEIGHBOR_KEY = new NeighborKey(NEIGHBOR_ADDRESS);
 119     private static final Ipv4Address ROUTER_ID = new Ipv4Address("1.2.3.4");
 120     private static final Ipv4Address CLUSTER_ID = new Ipv4Address("4.3.2.1");
 121     private static final Ipv4AddressNoZone LOCAL_HOST = new Ipv4AddressNoZone("127.0.0.1");
 122
 123     private static final Uint8 ALL_PATHS = Uint8.ZERO;
 124     private static final Uint8 N_PATHS = Uint8.TWO;
 125     private static final PathSelectionMode ADD_PATH_BEST_N_PATH_SELECTION =
 126             new AddPathBestNPathSelection(N_PATHS.toJava());
 127     private static final PathSelectionMode ADD_PATH_BEST_ALL_PATH_SELECTION = new AllPathSelection();
 128     private static final BgpTableType BGP_TABLE_TYPE_IPV4 = new BgpTableTypeImpl(Ipv4AddressFamily.class,
 129             UnicastSubsequentAddressFamily.class);
 130     private static final BgpTableType BGP_TABLE_TYPE_IPV6
 131             = new BgpTableTypeImpl(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class);
 132
 133     private static final AsNumber AS = new AsNumber(Uint32.valueOf(72));
 134     private static final AsNumber GLOBAL_AS = new AsNumber(Uint32.valueOf(73));
 135     private static final List<AddressFamilies> FAMILIES;
 136     private static final List<BgpTableType> TABLE_TYPES;
 137     private static final List<AfiSafi> AFISAFIS = new ArrayList<>();
 138     private static final BigDecimal DEFAULT_TIMERS = BigDecimal.valueOf(30);
 139
 140     static {
 141         FAMILIES = new ArrayList<>();
 142         FAMILIES.add(new AddressFamiliesBuilder()
 143                 .setAfi(Ipv4AddressFamily.class).setSafi(UnicastSubsequentAddressFamily.class)
 144                 .setSendReceive(SendReceive.Both).build());
 145         FAMILIES.add(new AddressFamiliesBuilder()
 146                 .setAfi(Ipv6AddressFamily.class).setSafi(UnicastSubsequentAddressFamily.class)
 147                 .setSendReceive(SendReceive.Send).build());
 148         FAMILIES.add(new AddressFamiliesBuilder()
 149                 .setAfi(Ipv6AddressFamily.class).setSafi(MplsLabeledVpnSubsequentAddressFamily.class)
 150                 .setSendReceive(SendReceive.Receive).build());
 151         TABLE_TYPES = new ArrayList<>();
 152         TABLE_TYPES.add(new BgpTableTypeImpl(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class));
 153         TABLE_TYPES.add(new BgpTableTypeImpl(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class));
 154         AFISAFIS.add(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
 155                 .addAugmentation(new GlobalAddPathsConfigBuilder().setReceive(Boolean.TRUE)
 156                         .setSendMax(N_PATHS).build()).build());
 157         AFISAFIS.add(new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
 158                 .addAugmentation(new GlobalAddPathsConfigBuilder().setReceive(Boolean.TRUE)
 159                         .setSendMax(ALL_PATHS).build()).build());
 160     }
 161
 162     @Mock
 163     private BGPTableTypeRegistryConsumer tableTypeRegistry;
 164
 165     @Mock
 166     private RIB rib;
 167
 168     @Before
 169     public void setUp() {
 170         initMocks(this);
 171         doReturn(java.util.Optional.of(BGP_TABLE_TYPE_IPV4))
 172             .when(this.tableTypeRegistry).getTableType(IPV4UNICAST.class);
 173         doReturn(java.util.Optional.of(BGP_TABLE_TYPE_IPV6))
 174             .when(this.tableTypeRegistry).getTableType(IPV6UNICAST.class);
 175         doReturn(java.util.Optional.of(new BgpTableTypeImpl(Ipv6AddressFamily.class,
 176                 MplsLabeledVpnSubsequentAddressFamily.class)))
 177             .when(this.tableTypeRegistry).getTableType(IPV6LABELLEDUNICAST.class);
 178         doReturn(java.util.Optional.of(IPV4UNICAST.class))
 179             .when(this.tableTypeRegistry).getAfiSafiType(BGP_TABLE_TYPE_IPV4);
 180         doReturn(java.util.Optional.of(IPV6UNICAST.class))
 181             .when(this.tableTypeRegistry).getAfiSafiType(BGP_TABLE_TYPE_IPV6);
 182         doReturn(AS).when(this.rib).getLocalAs();
 183     }
 184
 185     @Test
 186     public void testGetRibInstanceName() {
 187         assertEquals(KEY, OpenConfigMappingUtil.getRibInstanceName(BGP_II));
 188     }
 189
 190     @Test
 191     public void testGetHoldTimer() {
 192         assertEquals(DEFAULT_TIMERS.toBigInteger().intValue(),
 193                 OpenConfigMappingUtil.getHoldTimer(NEIGHBOR, null));
 194         assertEquals(HOLDTIMER,
 195                 OpenConfigMappingUtil.getHoldTimer(new NeighborBuilder().build(), null));
 196
 197         assertEquals(DEFAULT_TIMERS.toBigInteger().intValue(),
 198                 OpenConfigMappingUtil.getHoldTimer(NEIGHBOR, new PeerGroupBuilder().build()));
 199         TimersBuilder builder = new TimersBuilder().setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net
 200                 .yang.bgp.rev151009.bgp.neighbor.group.timers.ConfigBuilder().setHoldTime(BigDecimal.TEN).build());
 201         assertEquals(BigDecimal.TEN.intValue(), OpenConfigMappingUtil.getHoldTimer(NEIGHBOR, new PeerGroupBuilder()
 202                 .setTimers(builder.build()).build()));
 203     }
 204
 205     @Test
 206     public void testGetRemotePeerAs() {
 207         final ConfigBuilder configBuilder = new ConfigBuilder();
 208         assertEquals(AS, OpenConfigMappingUtil.getRemotePeerAs(NEIGHBOR.getConfig(), null, null));
 209         assertEquals(AS, OpenConfigMappingUtil.getRemotePeerAs(configBuilder.build(), null,
 210                 this.rib.getLocalAs()));
 211
 212         assertEquals(AS, OpenConfigMappingUtil.getRemotePeerAs(NEIGHBOR.getConfig(),
 213                 new PeerGroupBuilder().build(), null));
 214         assertEquals(AS, OpenConfigMappingUtil.getRemotePeerAs(configBuilder.build(), new PeerGroupBuilder().build(),
 215                 this.rib.getLocalAs()));
 216
 217         assertEquals(AS, OpenConfigMappingUtil.getRemotePeerAs(null, new PeerGroupBuilder()
 218                         .setConfig(new ConfigBuilder().setPeerAs(AS).build()).build(), null));
 219     }
 220
 221     @Test
 222     public void testGetLocalPeerAs() {
 223         final ConfigBuilder configBuilder = new ConfigBuilder();
 224         assertEquals(GLOBAL_AS,OpenConfigMappingUtil.getLocalPeerAs(null, GLOBAL_AS));
 225         assertEquals(AS, OpenConfigMappingUtil.getLocalPeerAs(configBuilder.setLocalAs(AS).build(), GLOBAL_AS));
 226     }
 227
 228     @Test
 229     public void testIsActive() {
 230         final TransportBuilder builder = new TransportBuilder();
 231         assertTrue(OpenConfigMappingUtil.isActive(new NeighborBuilder().build(), null));
 232         assertTrue(OpenConfigMappingUtil.isActive(new NeighborBuilder()
 233                 .setTransport(builder.build()).build(), null));
 234
 235         final Transport activeFalse = builder.setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp
 236                 .rev151009.bgp.neighbor.group.transport.ConfigBuilder().setPassiveMode(true).build()).build();
 237         assertFalse(OpenConfigMappingUtil.isActive(new NeighborBuilder().setTransport(activeFalse).build(),
 238                 null));
 239
 240         assertTrue(OpenConfigMappingUtil.isActive(new NeighborBuilder().build(),
 241                 new PeerGroupBuilder().build()));
 242         assertFalse(OpenConfigMappingUtil.isActive(new NeighborBuilder().build(),
 243                 new PeerGroupBuilder().setTransport(activeFalse).build()));
 244     }
 245
 246     @Test
 247     public void testGetRetryTimer() {
 248         assertEquals(DEFAULT_TIMERS.toBigInteger().intValue(),
 249                 OpenConfigMappingUtil.getRetryTimer(NEIGHBOR, null));
 250         assertEquals(DEFAULT_TIMERS.toBigInteger().intValue(),
 251                 OpenConfigMappingUtil.getRetryTimer(new NeighborBuilder().build(), null));
 252         TimersBuilder builder = new TimersBuilder().setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net
 253                 .yang.bgp.rev151009.bgp.neighbor.group.timers.ConfigBuilder().setConnectRetry(BigDecimal.TEN).build());
 254         assertEquals(BigDecimal.TEN.intValue(), OpenConfigMappingUtil.getRetryTimer(new NeighborBuilder()
 255                 .setTimers(builder.build()).build(), null));
 256
 257         assertEquals(DEFAULT_TIMERS.toBigInteger().intValue(),
 258                 OpenConfigMappingUtil.getRetryTimer(NEIGHBOR, new PeerGroupBuilder().build()));
 259         assertEquals(BigDecimal.TEN.intValue(), OpenConfigMappingUtil.getRetryTimer(NEIGHBOR,
 260                 new PeerGroupBuilder().setTimers(builder.build()).build()));
 261     }
 262
 263     @Test
 264     public void testGetNeighborKey() {
 265         assertArrayEquals(MD5_PASSWORD.getBytes(StandardCharsets.US_ASCII),
 266             OpenConfigMappingUtil.getNeighborKey(NEIGHBOR).get(INSTANCE.inetAddressFor(NEIGHBOR_ADDRESS)));
 267         assertNull(OpenConfigMappingUtil.getNeighborKey(new NeighborBuilder().build()));
 268         assertNull(OpenConfigMappingUtil.getNeighborKey(new NeighborBuilder().setConfig(new ConfigBuilder()
 269                 .build()).build()));
 270     }
 271
 272     @Test
 273     public void testGetNeighborInstanceIdentifier() {
 274         assertEquals(BGP_II.child(Neighbors.class).child(Neighbor.class, NEIGHBOR_KEY),
 275             OpenConfigMappingUtil.getNeighborInstanceIdentifier(BGP_II, NEIGHBOR_KEY));
 276
 277     }
 278
 279     @Test
 280     public void testGetNeighborInstanceName() {
 281         assertEquals(NEIGHBOR_ADDRESS.getIpv4Address().getValue(), OpenConfigMappingUtil
 282                 .getNeighborInstanceName(BGP_II.child(Neighbors.class).child(Neighbor.class, NEIGHBOR_KEY)));
 283     }
 284
 285     @Test
 286     public void testGetPort() {
 287         final TransportBuilder transport = new TransportBuilder();
 288         assertEquals(PORT, OpenConfigMappingUtil.getPort(NEIGHBOR, null));
 289         assertEquals(PORT, OpenConfigMappingUtil.getPort(new NeighborBuilder()
 290                 .setTransport(transport.build()).build(), null));
 291         assertEquals(PORT, OpenConfigMappingUtil.getPort(new NeighborBuilder().setTransport(
 292                 transport.setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor
 293                         .group.transport.ConfigBuilder().build()).build()).build(), null));
 294         final PortNumber newPort = new PortNumber(Uint16.valueOf(111));
 295         final Config portConfig = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor
 296                 .group.transport.ConfigBuilder().addAugmentation(NeighborTransportConfig.class,
 297                 new NeighborTransportConfigBuilder().setRemotePort(newPort).build()).build();
 298         assertEquals(newPort, OpenConfigMappingUtil.getPort(new NeighborBuilder().setTransport(
 299                 transport.setConfig(portConfig).build()).build(), null));
 300
 301         assertEquals(newPort, OpenConfigMappingUtil.getPort(new NeighborBuilder()
 302                 .setTransport(transport.setConfig(portConfig).build()).build(), new PeerGroupBuilder().build()));
 303
 304         final Config portConfigGroup = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp
 305                 .neighbor.group.transport.ConfigBuilder().addAugmentation(PeerGroupTransportConfig.class,
 306                 new PeerGroupTransportConfigBuilder().setRemotePort(newPort).build()).build();
 307         assertEquals(newPort, OpenConfigMappingUtil.getPort(new NeighborBuilder().build(), new PeerGroupBuilder()
 308                 .setTransport(transport.setConfig(portConfigGroup).build()).build()));
 309     }
 310
 311     @Test
 312     public void testGetLocalAddress() {
 313         assertNull(OpenConfigMappingUtil.getLocalAddress(null));
 314         final TransportBuilder transport = new TransportBuilder();
 315         assertNull(OpenConfigMappingUtil.getLocalAddress(transport.build()));
 316         assertNull(OpenConfigMappingUtil.getLocalAddress(transport.setConfig(
 317                 new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.transport
 318                         .ConfigBuilder().build()).build()));
 319         assertEquals(new IpAddressNoZone(LOCAL_HOST), OpenConfigMappingUtil.getLocalAddress(transport.setConfig(
 320                 new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.transport
 321                         .ConfigBuilder().setLocalAddress(new BgpNeighborTransportConfig
 322                         .LocalAddress(new IpAddress(new Ipv4Address(LOCAL_HOST.getValue())))).build()).build()));
 323     }
 324
 325     @Test
 326     public void testGetAfiSafiWithDefault() {
 327         final AfiSafi v4afi = new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class).build();
 328         final ImmutableMap<AfiSafiKey, AfiSafi> defaultValue = ImmutableMap.of(v4afi.key(), v4afi);
 329         assertEquals(defaultValue, OpenConfigMappingUtil.getAfiSafiWithDefault(null, true));
 330         final AfiSafis afiSafi = new AfiSafisBuilder().build();
 331         assertEquals(defaultValue, OpenConfigMappingUtil.getAfiSafiWithDefault(afiSafi, true));
 332
 333         final AfiSafi afiSafiIpv6 = new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
 334                 .addAugmentation(NeighborAddPathsConfig.class,
 335             new NeighborAddPathsConfigBuilder().setReceive(true).setSendMax(SHORT).build()).build();
 336         final List<AfiSafi> afiSafiIpv6List = new ArrayList<>();
 337         afiSafiIpv6List.add(afiSafiIpv6);
 338
 339         final List<AfiSafi> expected = new ArrayList<>(afiSafiIpv6List);
 340         expected.add(AFI_SAFI_IPV4);
 341
 342         final Map<AfiSafiKey, AfiSafi> v6 = OpenConfigMappingUtil.getAfiSafiWithDefault(new AfiSafisBuilder()
 343             .setAfiSafi(afiSafiIpv6List).build(), true);
 344         assertEquals(2, v6.size());
 345         assertTrue(v6.containsValue(afiSafiIpv6));
 346         assertTrue(v6.containsValue(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class).build()));
 347         assertEquals(AFI_SAFI, OpenConfigMappingUtil.getAfiSafiWithDefault(createAfiSafi(), true));
 348
 349         assertTrue(OpenConfigMappingUtil.getAfiSafiWithDefault(null, false).isEmpty());
 350         assertTrue(OpenConfigMappingUtil.getAfiSafiWithDefault(afiSafi, false).isEmpty());
 351         assertEquals(afiSafiIpv6, OpenConfigMappingUtil.getAfiSafiWithDefault(new AfiSafisBuilder()
 352                 .setAfiSafi(afiSafiIpv6List).build(), false).values().iterator().next());
 353         assertEquals(AFI_SAFI, OpenConfigMappingUtil.getAfiSafiWithDefault(createAfiSafi(), false));
 354     }
 355
 356     @Test
 357     public void testGetGlobalClusterIdentifier() {
 358         final org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.global.base
 359                 .ConfigBuilder configBuilder = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009
 360                 .bgp.global.base.ConfigBuilder();
 361         configBuilder.setRouterId(ROUTER_ID);
 362         assertEquals(ROUTER_ID.getValue(),
 363                 OpenConfigMappingUtil.getGlobalClusterIdentifier(configBuilder.build()).getValue());
 364
 365         configBuilder.addAugmentation(GlobalConfigAugmentation.class, new GlobalConfigAugmentationBuilder()
 366                 .setRouteReflectorClusterId(new RrClusterIdType(CLUSTER_ID)).build()).build();
 367         assertEquals(CLUSTER_ID.getValue(),
 368                 OpenConfigMappingUtil.getGlobalClusterIdentifier(configBuilder.build()).getValue());
 369     }
 370
 371     @Test
 372     public void testGetNeighborClusterIdentifier() {
 373
 374         assertNull(OpenConfigMappingUtil.getNeighborClusterIdentifier(null, null));
 375
 376         final PeerGroupBuilder peerGroup = new PeerGroupBuilder();
 377         assertNull(OpenConfigMappingUtil.getNeighborClusterIdentifier(null, peerGroup.build()));
 378
 379         final RouteReflectorBuilder configBuilder = new RouteReflectorBuilder();
 380         assertNull(OpenConfigMappingUtil.getNeighborClusterIdentifier(configBuilder.build(), peerGroup.build()));
 381
 382         configBuilder.setConfig(new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor
 383                 .group.route.reflector.ConfigBuilder()
 384                 .setRouteReflectorClusterId(new RrClusterIdType(CLUSTER_ID)).build()).build();
 385         assertEquals(CLUSTER_ID.getValue(), OpenConfigMappingUtil.getNeighborClusterIdentifier(configBuilder.build(),
 386                 peerGroup.build()).getValue());
 387
 388         assertEquals(CLUSTER_ID.getValue(), OpenConfigMappingUtil.getNeighborClusterIdentifier(null,
 389                 peerGroup.setRouteReflector(configBuilder.build()).build()).getValue());
 390     }
 391
 392     @Test
 393     public void isAppNeighbor() {
 394         assertFalse(OpenConfigMappingUtil.isApplicationPeer(new NeighborBuilder()
 395                 .setConfig(new ConfigBuilder().build()).build()));
 396         final Neighbor neighbor = new NeighborBuilder().setConfig(new ConfigBuilder()
 397                 .addAugmentation(NeighborPeerGroupConfig.class, new NeighborPeerGroupConfigBuilder()
 398                         .setPeerGroup(OpenConfigMappingUtil.APPLICATION_PEER_GROUP_NAME).build()).build()).build();
 399         assertTrue(OpenConfigMappingUtil.isApplicationPeer(neighbor));
 400     }
 401
 402     @Test
 403     public void toPathSelectionMode() {
 404         final List<AfiSafi> families = new ArrayList<>();
 405         families.add(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
 406             .addAugmentation(new GlobalAddPathsConfigBuilder().setSendMax(N_PATHS).build()).build());
 407         families.add(new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
 408             .addAugmentation(new GlobalAddPathsConfigBuilder().setSendMax(ALL_PATHS).build()).build());
 409         final Map<BgpTableType, PathSelectionMode> result = OpenConfigMappingUtil
 410                 .toPathSelectionMode(families, this.tableTypeRegistry);
 411         final Map<BgpTableType, PathSelectionMode> expected = new HashMap<>();
 412         expected.put(new BgpTableTypeImpl(Ipv4AddressFamily.class, UnicastSubsequentAddressFamily.class),
 413                 ADD_PATH_BEST_N_PATH_SELECTION);
 414         expected.put(new BgpTableTypeImpl(Ipv6AddressFamily.class, UnicastSubsequentAddressFamily.class),
 415                 ADD_PATH_BEST_ALL_PATH_SELECTION);
 416         // FIXME: these assertions are wrong, as they perform lookup on non-existing keys
 417         assertEquals(expected.get(0), result.get(0));
 418         assertEquals(expected.get(1), result.get(1));
 419     }
 420
 421     @Test
 422     public void toPeerRole() {
 423         Neighbor neighbor = new NeighborBuilder().setConfig(new ConfigBuilder()
 424                 .setPeerType(PeerType.EXTERNAL).build()).build();
 425         PeerRole peerRoleResult = OpenConfigMappingUtil.toPeerRole(neighbor);
 426         Assert.assertEquals(PeerRole.Ebgp, peerRoleResult);
 427
 428         neighbor = new NeighborBuilder().setConfig(new ConfigBuilder().setPeerType(PeerType.INTERNAL).build()).build();
 429         peerRoleResult = OpenConfigMappingUtil.toPeerRole(neighbor);
 430         Assert.assertEquals(PeerRole.Ibgp, peerRoleResult);
 431
 432         neighbor = new NeighborBuilder()
 433             .setRouteReflector(new RouteReflectorBuilder().setConfig(
 434                     new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp
 435                 .neighbor.group.route.reflector.ConfigBuilder().setRouteReflectorClient(true).build()).build()).build();
 436         peerRoleResult = OpenConfigMappingUtil.toPeerRole(neighbor);
 437         Assert.assertEquals(PeerRole.RrClient, peerRoleResult);
 438     }
 439
 440     @Test
 441     public void toAddPathCapability() {
 442         final List<AfiSafi> families = new ArrayList<>();
 443         families.add(new AfiSafiBuilder().setAfiSafiName(IPV4UNICAST.class)
 444             .addAugmentation(NeighborAddPathsConfig.class,
 445                 new NeighborAddPathsConfigBuilder()
 446                     .setReceive(Boolean.TRUE).setSendMax(ALL_PATHS).build()).build());
 447         families.add(new AfiSafiBuilder().setAfiSafiName(IPV6UNICAST.class)
 448             .addAugmentation(NeighborAddPathsConfig.class,
 449                 new NeighborAddPathsConfigBuilder()
 450                     .setReceive(Boolean.FALSE).setSendMax(N_PATHS).build()).build());
 451         families.add(new AfiSafiBuilder().setAfiSafiName(IPV6LABELLEDUNICAST.class)
 452             .addAugmentation(NeighborAddPathsConfig.class,
 453                 new NeighborAddPathsConfigBuilder().setReceive(Boolean.FALSE).build()).build());
 454         final List<AddressFamilies> result = OpenConfigMappingUtil
 455                 .toAddPathCapability(families, this.tableTypeRegistry);
 456         assertEquals(FAMILIES, result);
 457     }
 458
 459     @Test
 460     public void getGracefulRestartTimerTest() {
 461         final int neighborTimer = 5;
 462         final int peerGroupTimer = 10;
 463         final Neighbor emptyNeighbor = new NeighborBuilder().build();
 464         final PeerGroup emptyPeer = new PeerGroupBuilder().build();
 465         Neighbor neighbor = new NeighborBuilder()
 466                 .setGracefulRestart(new GracefulRestartBuilder()
 467                         .setConfig(createGracefulConfig(Uint16.valueOf(neighborTimer)))
 468                         .build()).build();
 469         PeerGroup peerGroup = new PeerGroupBuilder()
 470                 .setGracefulRestart(new GracefulRestartBuilder()
 471                         .setConfig(createGracefulConfig(Uint16.valueOf(peerGroupTimer)))
 472                         .build()).build();
 473         // both timers present, pick peer group one
 474         int timer = OpenConfigMappingUtil.getGracefulRestartTimer(neighbor, peerGroup, HOLDTIMER);
 475         assertEquals(peerGroupTimer, timer);
 476
 477         // peer group missing graceful restart, use neighbor timer
 478         timer = OpenConfigMappingUtil.getGracefulRestartTimer(neighbor, emptyPeer, HOLDTIMER);
 479         assertEquals(neighborTimer, timer);
 480
 481         // graceful restart enabled but timer not set, use hold time
 482         peerGroup = new PeerGroupBuilder()
 483                 .setGracefulRestart(new GracefulRestartBuilder()
 484                         .setConfig(createGracefulConfig(null))
 485                         .build()).build();
 486         timer = OpenConfigMappingUtil.getGracefulRestartTimer(emptyNeighbor, peerGroup, HOLDTIMER);
 487         assertEquals(HOLDTIMER, timer);
 488     }
 489
 490     private static org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.graceful.restart.graceful
 491             .restart.Config createGracefulConfig(final Uint16 restartTimer) {
 492         return new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.graceful.restart.graceful
 493                 .restart.ConfigBuilder().setRestartTime(restartTimer).build();
 494     }
 495
 496     @Test
 497     public void getRevisedErrorHandlingTest() {
 498         final NeighborBuilder neighbor = new NeighborBuilder();
 499         final PeerGroupBuilder peerGroup = new PeerGroupBuilder();
 500         final org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp.rev151009.bgp.neighbor.group.error.handling
 501                 .ConfigBuilder errorHandlingConfig = new org.opendaylight.yang.gen.v1.http.openconfig.net.yang.bgp
 502                         .rev151009.bgp.neighbor.group.error.handling.ConfigBuilder();
 503         // error handling not set -> null
 504         assertNull(OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ibgp, peerGroup.build(),
 505                 neighbor.build()));
 506         // error handling for peer group disabled, neighbor not set -> null
 507         peerGroup.setErrorHandling(new ErrorHandlingBuilder()
 508                 .setConfig(errorHandlingConfig.setTreatAsWithdraw(false).build())
 509                 .build());
 510         assertNull(OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ibgp, peerGroup.build(),
 511                 neighbor.build()));
 512         // error handling for peer group enabled, neighbor not set, Igp -> error handling for internal peer
 513         peerGroup.setErrorHandling(new ErrorHandlingBuilder()
 514                 .setConfig(errorHandlingConfig.setTreatAsWithdraw(true).build())
 515                 .build());
 516         assertEquals(RevisedErrorHandlingSupportImpl.forInternalPeer(),
 517                 OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ibgp, peerGroup.build(), neighbor.build()));
 518         // error handling for peer group enabled, neighbor disabled -> null
 519         neighbor.setErrorHandling(new ErrorHandlingBuilder()
 520                 .setConfig(errorHandlingConfig.setTreatAsWithdraw(false).build())
 521                 .build());
 522         assertNull(OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ibgp, peerGroup.build(),
 523                 neighbor.build()));
 524         // error handling for peer group enabled, neighbor enabled, Igb -> error handling for internal peer
 525         neighbor.setErrorHandling(new ErrorHandlingBuilder()
 526                 .setConfig(errorHandlingConfig.setTreatAsWithdraw(true).build())
 527                 .build());
 528         assertEquals(RevisedErrorHandlingSupportImpl.forInternalPeer(),
 529                 OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ibgp, peerGroup.build(), neighbor.build()));
 530         // error handling for peer group enabled, neighbor enabled, Egb -> error handling for external peer
 531         neighbor.setErrorHandling(new ErrorHandlingBuilder()
 532                 .setConfig(errorHandlingConfig.setTreatAsWithdraw(true).build())
 533                 .build());
 534         assertEquals(RevisedErrorHandlingSupportImpl.forExternalPeer(),
 535                 OpenConfigMappingUtil.getRevisedErrorHandling(PeerRole.Ebgp, peerGroup.build(), neighbor.build()));
 536     }
 537 }