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