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