bgp/topology-provider/src/main/java/org/opendaylight/bgpcep/bgp/topology/provider/ProtocolUtil.java

   1 /*
   2  * Copyright (c) 2018 AT&T Intellectual Property. 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.bgpcep.bgp.topology.provider;
   9
  10 import com.google.common.io.BaseEncoding;
  11 import java.math.BigDecimal;
  12 import java.nio.ByteBuffer;
  13 import java.util.ArrayList;
  14 import java.util.List;
  15 import java.util.stream.Collectors;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.IsisAreaIdentifier;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.NodeFlagBits;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.NodeIdentifier;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.TopologyIdentifier;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.linkstate.object.type.link._case.LinkDescriptors;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.linkstate.path.attribute.link.state.attribute.link.attributes._case.LinkAttributes;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.linkstate.path.attribute.link.state.attribute.node.attributes._case.NodeAttributes;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.linkstate.path.attribute.link.state.attribute.prefix.attributes._case.PrefixAttributes;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.linkstate.routes.linkstate.routes.LinkstateRoute;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.CRouterIdentifier;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.IsisNodeCase;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.IsisPseudonodeCase;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.OspfNodeCase;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.OspfPseudonodeCase;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.isis.node._case.IsisNode;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.isis.pseudonode._case.IsisPseudonode;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120.node.identifier.c.router.identifier.ospf.pseudonode._case.OspfPseudonode;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.network.concepts.rev131125.Bandwidth;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.SrlgId;
  35 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.IsoNetId;
  36 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.IsoPseudonodeId;
  37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.IsoSystemId;
  38 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.isis.link.attributes.IsisLinkAttributesBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.isis.node.attributes.IsisNodeAttributesBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.isis.node.attributes.isis.node.attributes.IsoBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.srlg.attributes.SrlgValues;
  42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.srlg.attributes.SrlgValuesBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.ted.link.attributes.SrlgBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.ted.link.attributes.UnreservedBandwidth;
  45 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.ted.link.attributes.UnreservedBandwidthBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.ted.rev131021.ted.link.attributes.UnreservedBandwidthKey;
  47 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.link.attributes.IgpLinkAttributesBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.node.attributes.IgpNodeAttributesBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.nt.l3.unicast.igp.topology.rev131021.igp.node.attributes.igp.node.attributes.PrefixBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.Prefix1;
  51 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.Prefix1Builder;
  52 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.link.attributes.OspfLinkAttributesBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.node.attributes.OspfNodeAttributesBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.node.attributes.ospf.node.attributes.router.type.AbrBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.node.attributes.ospf.node.attributes.router.type.InternalBuilder;
  56 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.node.attributes.ospf.node.attributes.router.type.PseudonodeBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.prefix.attributes.OspfPrefixAttributesBuilder;
  58 import org.opendaylight.yangtools.yang.common.Empty;
  59 import org.opendaylight.yangtools.yang.common.Uint8;
  60
  61 public final class ProtocolUtil {
  62     private ProtocolUtil() {
  63         // Hidden on purpose
  64     }
  65
  66     public static void augmentProtocolId(final LinkstateRoute value, final PrefixAttributes pa,
  67             final PrefixBuilder pb) {
  68         switch (value.getProtocolId()) {
  69             case Direct:
  70             case IsisLevel1:
  71             case IsisLevel2:
  72             case Static:
  73             case Ospf:
  74                 if (pa != null && pa.getOspfForwardingAddress() != null) {
  75                     pb.addAugmentation(Prefix1.class, new Prefix1Builder().setOspfPrefixAttributes(
  76                             new OspfPrefixAttributesBuilder().setForwardingAddress(pa.getOspfForwardingAddress()
  77                                     .getIpv4AddressNoZone()).build()).build());
  78                 }
  79                 break;
  80             default:
  81                 break;
  82         }
  83     }
  84
  85     public static void augmentProtocolId(final LinkstateRoute value, final IgpNodeAttributesBuilder inab,
  86             final NodeAttributes na, final NodeIdentifier nd) {
  87         switch (value.getProtocolId()) {
  88             case Direct:
  89             case Static:
  90             case IsisLevel1:
  91             case IsisLevel2:
  92                 inab.addAugmentation(
  93                         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
  94                                 .IgpNodeAttributes1.class, isisNodeAttributes(nd, na));
  95                 break;
  96             case Ospf:
  97                 inab.addAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
  98                         .IgpNodeAttributes1.class, ospfNodeAttributes(nd, na));
  99                 break;
 100             default:
 101                 break;
 102         }
 103     }
 104
 105     public static void augmentProtocolId(final LinkstateRoute value, final IgpLinkAttributesBuilder ilab,
 106             final LinkAttributes la, final LinkDescriptors ld) {
 107         switch (value.getProtocolId()) {
 108             case Direct:
 109             case Static:
 110             case IsisLevel1:
 111             case IsisLevel2:
 112                 ilab.addAugmentation(
 113                         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
 114                                 .IgpLinkAttributes1.class, isisLinkAttributes(ld.getMultiTopologyId(), la));
 115                 break;
 116             case OspfV3:
 117             case Ospf:
 118                 ilab.addAugmentation(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
 119                         .IgpLinkAttributes1.class, ospfLinkAttributes(ld.getMultiTopologyId(), la));
 120                 break;
 121             default:
 122                 break;
 123         }
 124     }
 125
 126     private static org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
 127             .IgpNodeAttributes1 isisNodeAttributes(final NodeIdentifier node, final NodeAttributes na) {
 128         final org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.isis.node
 129                 .attributes.isis.node.attributes.TedBuilder tb = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml
 130                 .ns.yang.network.isis.topology.rev131021.isis.node.attributes.isis.node.attributes.TedBuilder();
 131         final IsisNodeAttributesBuilder ab = new IsisNodeAttributesBuilder();
 132
 133         if (na != null) {
 134             if (na.getIpv4RouterId() != null) {
 135                 tb.setTeRouterIdIpv4(na.getIpv4RouterId());
 136             }
 137             if (na.getIpv6RouterId() != null) {
 138                 tb.setTeRouterIdIpv6(na.getIpv6RouterId());
 139             }
 140             if (na.getTopologyIdentifier() != null) {
 141                 ab.setMultiTopologyId(nodeMultiTopology(na.getTopologyIdentifier()));
 142             }
 143         }
 144
 145         final CRouterIdentifier ri = node.getCRouterIdentifier();
 146         if (ri instanceof IsisPseudonodeCase) {
 147             final IsisPseudonode pn = ((IsisPseudonodeCase) ri).getIsisPseudonode();
 148             final IsoBuilder b = new IsoBuilder();
 149             final String systemId = UriBuilder.isoId(pn.getIsIsRouterIdentifier().getIsoSystemId());
 150             b.setIsoSystemId(new IsoSystemId(systemId));
 151             b.setIsoPseudonodeId(new IsoPseudonodeId(BaseEncoding.base16()
 152                     .encode(new byte[]{pn.getPsn().byteValue()})));
 153             ab.setIso(b.build());
 154             if (na != null) {
 155                 ab.setNet(toIsoNetIds(na.getIsisAreaId(), systemId));
 156             }
 157         } else if (ri instanceof IsisNodeCase) {
 158             final IsisNode in = ((IsisNodeCase) ri).getIsisNode();
 159             final String systemId = UriBuilder.isoId(in.getIsoSystemId());
 160             ab.setIso(new IsoBuilder().setIsoSystemId(new IsoSystemId(systemId)).build());
 161             if (na != null) {
 162                 ab.setNet(toIsoNetIds(na.getIsisAreaId(), systemId));
 163             }
 164         }
 165
 166         ab.setTed(tb.build());
 167
 168         return new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
 169                 .IgpNodeAttributes1Builder().setIsisNodeAttributes(ab.build()).build();
 170     }
 171
 172     private static org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
 173             .IgpNodeAttributes1 ospfNodeAttributes(
 174             final NodeIdentifier node, final NodeAttributes na) {
 175         final org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.node
 176                 .attributes.ospf.node.attributes.TedBuilder tb = new org.opendaylight.yang.gen.v1.urn.tbd
 177                 .params.xml.ns.yang.ospf.topology.rev131021.ospf.node.attributes.ospf.node.attributes.TedBuilder();
 178         final OspfNodeAttributesBuilder ab = new OspfNodeAttributesBuilder();
 179         if (na != null) {
 180             if (na.getIpv4RouterId() != null) {
 181                 tb.setTeRouterIdIpv4(na.getIpv4RouterId());
 182             }
 183             if (na.getIpv6RouterId() != null) {
 184                 tb.setTeRouterIdIpv6(na.getIpv6RouterId());
 185             }
 186             if (na.getTopologyIdentifier() != null) {
 187                 ab.setMultiTopologyId(nodeMultiTopology(na.getTopologyIdentifier()));
 188             }
 189             final CRouterIdentifier ri = node.getCRouterIdentifier();
 190             if (ri instanceof OspfPseudonodeCase) {
 191                 final OspfPseudonode pn = ((OspfPseudonodeCase) ri).getOspfPseudonode();
 192
 193                 ab.setRouterType(new PseudonodeBuilder().setPseudonode(Empty.getInstance()).build());
 194                 ab.setDrInterfaceId(pn.getLanInterface().getValue());
 195             } else if (ri instanceof OspfNodeCase && na.getNodeFlags() != null) {
 196                 // TODO: what should we do with in.getOspfRouterId()?
 197
 198                 final NodeFlagBits nf = na.getNodeFlags();
 199                 if (nf.isAbr() != null) {
 200                     ab.setRouterType(new AbrBuilder().setAbr(nf.isAbr() ? Empty.getInstance() : null).build());
 201                 } else if (nf.isExternal() != null) {
 202                     ab.setRouterType(new InternalBuilder().setInternal(nf.isExternal() ? null : Empty.getInstance())
 203                         .build());
 204                 }
 205             }
 206         }
 207         ab.setTed(tb.build());
 208         return new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
 209                 .IgpNodeAttributes1Builder().setOspfNodeAttributes(ab.build()).build();
 210     }
 211
 212
 213     private static List<IsoNetId> toIsoNetIds(final List<IsisAreaIdentifier> areaIds, final String systemId) {
 214         return areaIds.stream().map(input -> new IsoNetId(UriBuilder.toIsoNetId(input, systemId)))
 215                 .collect(Collectors.toList());
 216     }
 217
 218     private static List<Uint8> nodeMultiTopology(final List<TopologyIdentifier> list) {
 219         final List<Uint8> ret = new ArrayList<>(list.size());
 220         for (final TopologyIdentifier id : list) {
 221             ret.add(Uint8.valueOf(id.getValue()));
 222         }
 223         return ret;
 224     }
 225
 226     private static org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
 227             .IgpLinkAttributes1 ospfLinkAttributes(final TopologyIdentifier topologyIdentifier,
 228             final LinkAttributes la) {
 229         final org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021.ospf.link.attributes
 230                 .ospf.link.attributes.TedBuilder tb = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang
 231                 .ospf.topology.rev131021.ospf.link.attributes.ospf.link.attributes.TedBuilder();
 232
 233         if (la != null) {
 234             if (la.getAdminGroup() != null) {
 235                 tb.setColor(la.getAdminGroup().getValue());
 236             }
 237             if (la.getTeMetric() != null) {
 238                 tb.setTeDefaultMetric(la.getTeMetric().getValue());
 239             }
 240             if (la.getUnreservedBandwidth() != null) {
 241                 tb.setUnreservedBandwidth(unreservedBandwidthList(la.getUnreservedBandwidth()));
 242             }
 243             if (la.getMaxLinkBandwidth() != null) {
 244                 tb.setMaxLinkBandwidth(bandwidthToBigDecimal(la.getMaxLinkBandwidth()));
 245             }
 246             if (la.getMaxReservableBandwidth() != null) {
 247                 tb.setMaxResvLinkBandwidth(bandwidthToBigDecimal(la.getMaxReservableBandwidth()));
 248             }
 249             if (la.getSharedRiskLinkGroups() != null) {
 250                 final List<SrlgValues> srlgs = new ArrayList<>();
 251                 for (final SrlgId id : la.getSharedRiskLinkGroups()) {
 252                     srlgs.add(new SrlgValuesBuilder().setSrlgValue(id.getValue()).build());
 253                 }
 254                 tb.setSrlg(new SrlgBuilder().setSrlgValues(srlgs).build());
 255             }
 256         }
 257
 258         final OspfLinkAttributesBuilder ilab = new OspfLinkAttributesBuilder();
 259         ilab.setTed(tb.build());
 260         if (topologyIdentifier != null) {
 261             ilab.setMultiTopologyId(Uint8.valueOf(topologyIdentifier.getValue()));
 262         }
 263
 264         return new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.ospf.topology.rev131021
 265                 .IgpLinkAttributes1Builder().setOspfLinkAttributes(ilab.build()).build();
 266     }
 267
 268
 269     private static org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
 270             .IgpLinkAttributes1 isisLinkAttributes(
 271             final TopologyIdentifier topologyIdentifier, final LinkAttributes la) {
 272         final org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021.isis
 273                 .link.attributes.isis.link.attributes.TedBuilder tb = new org.opendaylight.yang.gen.v1.urn.tbd.params
 274                 .xml.ns.yang.network.isis.topology.rev131021.isis.link.attributes.isis.link.attributes.TedBuilder();
 275
 276         if (la != null) {
 277             if (la.getAdminGroup() != null) {
 278                 tb.setColor(la.getAdminGroup().getValue());
 279             }
 280             if (la.getTeMetric() != null) {
 281                 tb.setTeDefaultMetric(la.getTeMetric().getValue());
 282             }
 283             if (la.getUnreservedBandwidth() != null) {
 284                 tb.setUnreservedBandwidth(unreservedBandwidthList(la.getUnreservedBandwidth()));
 285             }
 286             if (la.getMaxLinkBandwidth() != null) {
 287                 tb.setMaxLinkBandwidth(bandwidthToBigDecimal(la.getMaxLinkBandwidth()));
 288             }
 289             if (la.getMaxReservableBandwidth() != null) {
 290                 tb.setMaxResvLinkBandwidth(bandwidthToBigDecimal(la.getMaxReservableBandwidth()));
 291             }
 292             if (la.getSharedRiskLinkGroups() != null) {
 293                 final List<SrlgValues> srlgs = new ArrayList<>();
 294                 for (final SrlgId id : la.getSharedRiskLinkGroups()) {
 295                     srlgs.add(new SrlgValuesBuilder().setSrlgValue(id.getValue()).build());
 296                 }
 297                 tb.setSrlg(new SrlgBuilder().setSrlgValues(srlgs).build());
 298             }
 299         }
 300
 301         final IsisLinkAttributesBuilder ilab = new IsisLinkAttributesBuilder();
 302         ilab.setTed(tb.build());
 303         if (topologyIdentifier != null) {
 304             ilab.setMultiTopologyId(Uint8.valueOf(topologyIdentifier.getValue()));
 305         }
 306
 307         return new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.isis.topology.rev131021
 308                 .IgpLinkAttributes1Builder().setIsisLinkAttributes(ilab.build()).build();
 309     }
 310
 311     private static Float bandwidthToFloat(final Bandwidth bandwidth) {
 312         return ByteBuffer.wrap(bandwidth.getValue()).getFloat();
 313     }
 314
 315     private static BigDecimal bandwidthToBigDecimal(final Bandwidth bandwidth) {
 316         return BigDecimal.valueOf(bandwidthToFloat(bandwidth));
 317     }
 318
 319     private static List<UnreservedBandwidth> unreservedBandwidthList(
 320             final List<? extends org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang
 321                 .bgp.linkstate.rev200120.UnreservedBandwidth> input) {
 322         final List<UnreservedBandwidth> ret = new ArrayList<>(input.size());
 323
 324         for (final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.linkstate.rev200120
 325                 .UnreservedBandwidth bandwidth : input) {
 326             ret.add(new UnreservedBandwidthBuilder().setBandwidth(bandwidthToBigDecimal(bandwidth.getBandwidth()))
 327                     .withKey(new UnreservedBandwidthKey(bandwidth.getPriority())).build());
 328         }
 329
 330         return ret;
 331     }
 332 }