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