networkmodel/src/test/java/org/opendaylight/transportpce/networkmodel/util/test/NetworkmodelTestUtil.java

   1 /*
   2  * Copyright © 2020 Orange Labs, 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.transportpce.networkmodel.util.test;
   9
  10 import com.google.common.collect.ImmutableList;
  11 import java.util.ArrayList;
  12 import java.util.List;
  13 import org.opendaylight.transportpce.common.NetworkUtils;
  14 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.Nodes;
  15 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.NodesBuilder;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.Mapping;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.MappingBuilder;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.NodeInfoBuilder;
  19 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1;
  20 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder;
  21 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.NodeTypes;
  22 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.PortQual;
  23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.XpdrNodeTypes;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODTU4TsAllocated;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODU4;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.TerminationPoint1;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.TerminationPoint1Builder;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.TpSupportedInterfaces;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181019.If100GE;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181019.IfOCH;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181019.SupportedIfCapability;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.IfOCHOTU4ODU4;
  39 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev181130.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
  40 import org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.OtnLinkType;
  41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
  42 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
  43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
  46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
  50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
  52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
  53 import org.opendaylight.yangtools.yang.common.Uint16;
  54 import org.opendaylight.yangtools.yang.common.Uint32;
  55 import org.slf4j.Logger;
  56 import org.slf4j.LoggerFactory;
  57
  58 public final class NetworkmodelTestUtil {
  59
  60     private static final Logger LOG = LoggerFactory.getLogger(NetworkmodelTestUtil.class);
  61
  62     public static Nodes createMappingForRdm(String nodeId, String clli, int degNb, int srgNb) {
  63         List<Mapping> mappingList = new ArrayList<>();
  64         createDegreeMappings(mappingList, 1, degNb);
  65         createSrgMappings(mappingList, 1, srgNb);
  66         Nodes mappingNode = new NodesBuilder()
  67             .setNodeId(nodeId)
  68             .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Rdm).setNodeClli(clli).build())
  69             .setMapping(mappingList)
  70             .build();
  71         return mappingNode;
  72     }
  73
  74     public static Nodes createMappingForXpdr(String nodeId, String clli, int networkPortNb, int clientPortNb,
  75         XpdrNodeTypes xpdrNodeType) {
  76         List<Mapping> mappingList = new ArrayList<>();
  77         createXpdrMappings(mappingList, networkPortNb, clientPortNb, xpdrNodeType);
  78         Nodes mappingNode = new NodesBuilder()
  79             .setNodeId(nodeId)
  80             .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr).setNodeClli(clli).build())
  81             .setMapping(mappingList)
  82             .build();
  83         LOG.info("mapping = {}", mappingNode.toString());
  84         return mappingNode;
  85     }
  86
  87     public static List<Link> createSuppOTNLinks(OtnLinkType type, int availBW) {
  88         String prefix = null;
  89         if (OtnLinkType.OTU4.equals(type)) {
  90             prefix = "OTU4-";
  91         } else if (OtnLinkType.ODTU4.equals(type)) {
  92             prefix = "ODU4-";
  93         }
  94         Link linkAZ = new LinkBuilder()
  95             .setLinkId(new LinkId(prefix + "SPDRA-XPDR1-XPDR1-NETWORK1toSPDRZ-XPDR1-XPDR1-NETWORK1"))
  96             .setSource(new SourceBuilder()
  97                     .setSourceNode(new NodeId("SPDRA-XPDR1"))
  98                     .setSourceTp("XPDR1-NETWORK1").build())
  99             .setDestination(new DestinationBuilder()
 100                     .setDestNode(new NodeId("SPDRZ-XPDR1"))
 101                     .setDestTp("XPDR1-NETWORK1").build())
 102             .addAugmentation(
 103                 Link1.class,
 104                 new Link1Builder()
 105                     .setLinkType(OpenroadmLinkType.OTNLINK)
 106                     .setOppositeLink(new LinkId(prefix + "SPDRZ-XPDR1-XPDR1-NETWORK1toSPDRA-XPDR1-XPDR1-NETWORK1"))
 107                     .build())
 108             .addAugmentation(
 109                 org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1.class,
 110                 new org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1Builder()
 111                     .setAvailableBandwidth(Uint32.valueOf(availBW))
 112                     .setUsedBandwidth(Uint32.valueOf(100000 - availBW))
 113                     .build())
 114             .addAugmentation(
 115                 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1.class,
 116                 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1Builder()
 117                     .setOtnLinkType(type)
 118                     .build())
 119             .build();
 120         Link linkZA = new LinkBuilder()
 121             .setLinkId(new LinkId(prefix + "SPDRZ-XPDR1-XPDR1-NETWORK1toSPDRA-XPDR1-XPDR1-NETWORK1"))
 122             .setSource(new SourceBuilder()
 123                     .setSourceNode(new NodeId("SPDRZ-XPDR1"))
 124                     .setSourceTp("XPDR1-NETWORK1").build())
 125             .setDestination(new DestinationBuilder()
 126                     .setDestNode(new NodeId("SPDRA-XPDR1"))
 127                     .setDestTp("XPDR1-NETWORK1").build())
 128             .addAugmentation(
 129                 Link1.class,
 130                 new Link1Builder()
 131                     .setLinkType(OpenroadmLinkType.OTNLINK)
 132                     .setOppositeLink(new LinkId(prefix + "SPDRA-XPDR1-XPDR1-NETWORK1toSPDRZ-XPDR1-XPDR1-NETWORK1"))
 133                     .build())
 134             .addAugmentation(
 135                 org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1.class,
 136                 new org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1Builder()
 137                     .setAvailableBandwidth(Uint32.valueOf(availBW))
 138                     .setUsedBandwidth(Uint32.valueOf(100000 - availBW))
 139                     .build())
 140             .addAugmentation(
 141                 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1.class,
 142                 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1Builder()
 143                     .setOtnLinkType(type)
 144                     .build())
 145             .build();
 146         List<Link> links = new ArrayList<>();
 147         links.add(linkAZ);
 148         links.add(linkZA);
 149         return links;
 150     }
 151
 152     public static List<TerminationPoint> createTpList(boolean withTpnTsPool) {
 153         SupportedInterfaceCapability supCapa = new SupportedInterfaceCapabilityBuilder()
 154             .setIfCapType(IfOCHOTU4ODU4.class)
 155             .build();
 156         List<SupportedInterfaceCapability> supInterCapaList = new ArrayList<>();
 157         supInterCapaList.add(supCapa);
 158         TpSupportedInterfaces tpSuppInter = new TpSupportedInterfacesBuilder()
 159             .setSupportedInterfaceCapability(supInterCapaList)
 160             .build();
 161         XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder()
 162             .setRate(ODU4.class);
 163         if (withTpnTsPool) {
 164             List<Uint16> tsPool = new ArrayList<>();
 165             for (int i = 0; i < 80; i++) {
 166                 tsPool.add(Uint16.valueOf(i + 1));
 167             }
 168             xtpcaBldr.setTsPool(tsPool);
 169             List<Uint16> tpnPool = new ArrayList<>();
 170             for (int i = 1; i <= 80; i++) {
 171                 tpnPool.add(Uint16.valueOf(i));
 172             }
 173             xtpcaBldr.setOdtuTpnPool(
 174                     ImmutableList.of(
 175                         new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class).setTpnPool(tpnPool).build()));
 176         }
 177         TerminationPoint1 otnTp1 = new TerminationPoint1Builder()
 178             .setTpSupportedInterfaces(tpSuppInter)
 179             .setXpdrTpPortConnectionAttributes(xtpcaBldr.build())
 180             .build();
 181         SupportingTerminationPoint supTermPointA = new SupportingTerminationPointBuilder()
 182             .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
 183             .setNodeRef(new NodeId("SPDRA-XPDR1"))
 184             .setTpRef("XPDR1-NETWORK1")
 185             .build();
 186         List<SupportingTerminationPoint> supTermPointListA = new ArrayList<>();
 187         supTermPointListA.add(supTermPointA);
 188         TerminationPoint tpA = new TerminationPointBuilder()
 189             .setTpId(new TpId("XPDR1-NETWORK1"))
 190             .setSupportingTerminationPoint(supTermPointListA)
 191             .addAugmentation(TerminationPoint1.class, otnTp1)
 192             .addAugmentation(
 193                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1.class,
 194                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
 195                 .setTpType(OpenroadmTpType.XPONDERNETWORK)
 196                 .build())
 197             .build();
 198         SupportingTerminationPoint supTermPointZ = new SupportingTerminationPointBuilder()
 199             .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
 200             .setNodeRef(new NodeId("SPDRZ-XPDR1"))
 201             .setTpRef("XPDR1-NETWORK1")
 202             .build();
 203         List<SupportingTerminationPoint> supTermPointListZ = new ArrayList<>();
 204         supTermPointListZ.add(supTermPointZ);
 205         TerminationPoint tpZ = new TerminationPointBuilder()
 206             .setTpId(new TpId("XPDR1-NETWORK1"))
 207             .setSupportingTerminationPoint(supTermPointListZ)
 208             .addAugmentation(TerminationPoint1.class, otnTp1)
 209             .addAugmentation(
 210                 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1.class,
 211                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
 212                 .setTpType(OpenroadmTpType.XPONDERNETWORK)
 213                 .build())
 214             .build();
 215         List<TerminationPoint> tps = new ArrayList<>();
 216         tps.add(tpA);
 217         tps.add(tpZ);
 218         return tps;
 219     }
 220
 221     private static List<Mapping> createDegreeMappings(List<Mapping> mappingList, int degNbStart, int degNbStop) {
 222         for (int i = degNbStart; i <= degNbStop; i++) {
 223             Mapping mapping = new MappingBuilder()
 224                 .setLogicalConnectionPoint("DEG" + i + "-TTP-TXRX")
 225                 .setPortDirection("bidirectional")
 226                 .setSupportingPort("L1")
 227                 .setSupportingCircuitPackName(i + "/0")
 228                 .setSupportingOts("OTS-DEG" + i + "-TTP-TXRX")
 229                 .setSupportingOms("OMS-DEG" + i + "-TTP-TXRX")
 230                 .build();
 231             mappingList.add(mapping);
 232         }
 233         return mappingList;
 234     }
 235
 236     private static List<Mapping> createSrgMappings(List<Mapping> mappingList, int srgNbStart, int srgNbStop) {
 237         for (int i = srgNbStart; i <= srgNbStop; i++) {
 238             for (int j = 1; j <= 4; j++) {
 239                 Mapping mapping = new MappingBuilder()
 240                     .setLogicalConnectionPoint("SRG" + i + "-PP" + j + "-TXRX")
 241                     .setPortDirection("bidirectional")
 242                     .setSupportingPort("C" + j)
 243                     .setSupportingCircuitPackName(3 + i + "/0")
 244                     .build();
 245                 mappingList.add(mapping);
 246             }
 247         }
 248         return mappingList;
 249     }
 250
 251     private static List<Mapping> createXpdrMappings(List<Mapping> mappingList, int networkPortNb, int clientPortNb,
 252         XpdrNodeTypes xpdrNodeType) {
 253         for (int i = 1; i <= networkPortNb; i++) {
 254             List<Class<? extends SupportedIfCapability>> supportedIntf = new ArrayList<>();
 255             supportedIntf.add(IfOCH.class);
 256             MappingBuilder mappingBldr = new MappingBuilder()
 257                 .setLogicalConnectionPoint("XPDR1-NETWORK" + i)
 258                 .setPortDirection("bidirectional")
 259                 .setSupportingPort("1")
 260                 .setSupportedInterfaceCapability(supportedIntf)
 261                 .setConnectionMapLcp("XPDR1-CLIENT" + i)
 262                 .setPortQual(PortQual.XpdrNetwork.getName())
 263                 .setSupportingCircuitPackName("1/0/" + i + "-PLUG-NET");
 264             if (xpdrNodeType != null) {
 265                 mappingBldr.setXponderType(xpdrNodeType);
 266             }
 267             mappingList.add(mappingBldr.build());
 268         }
 269         for (int i = 1; i <= clientPortNb; i++) {
 270             List<Class<? extends SupportedIfCapability>> supportedIntf = new ArrayList<>();
 271             supportedIntf.add(If100GE.class);
 272             Mapping mapping = new MappingBuilder()
 273                 .setLogicalConnectionPoint("XPDR1-CLIENT" + i)
 274                 .setPortDirection("bidirectional")
 275                 .setSupportingPort("C1")
 276                 .setSupportedInterfaceCapability(supportedIntf)
 277                 .setConnectionMapLcp("XPDR1-NETWORK" + i)
 278                 .setPortQual(PortQual.XpdrClient.getName())
 279                 .setSupportingCircuitPackName("1/0/" + i + "-PLUG-CLIENT")
 280                 .build();
 281             mappingList.add(mapping);
 282         }
 283         return mappingList;
 284     }
 285
 286     private NetworkmodelTestUtil() {
 287     }
 288 }