tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/TapiTopologyImpl.java

   1 /*
   2  * Copyright © 2019 Orange, 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.tapi.topology;
   9
  10 import com.google.common.util.concurrent.FluentFuture;
  11 import com.google.common.util.concurrent.ListenableFuture;
  12 import java.nio.charset.Charset;
  13 import java.util.ArrayList;
  14 import java.util.Collection;
  15 import java.util.HashMap;
  16 import java.util.Iterator;
  17 import java.util.List;
  18 import java.util.Map;
  19 import java.util.Map.Entry;
  20 import java.util.Optional;
  21 import java.util.UUID;
  22 import java.util.concurrent.ExecutionException;
  23 import java.util.stream.Collectors;
  24 import org.eclipse.jdt.annotation.NonNull;
  25 import org.eclipse.jdt.annotation.Nullable;
  26 import org.opendaylight.mdsal.binding.api.DataBroker;
  27 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  28 import org.opendaylight.transportpce.common.InstanceIdentifiers;
  29 import org.opendaylight.transportpce.common.NetworkUtils;
  30 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mapping.Mapping;
  31 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mapping.MappingKey;
  32 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.Nodes;
  33 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.NodesKey;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmLinkType;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmNodeType;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmTpType;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
  41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
  42 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
  43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
  46 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.AdministrativeState;
  47 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LayerProtocolName;
  48 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LifecycleState;
  49 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.OperationalState;
  50 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Uuid;
  51 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.Name;
  52 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameKey;
  54 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.ForwardingRule;
  55 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetLinkDetailsInput;
  56 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetLinkDetailsOutput;
  57 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetNodeDetailsInput;
  58 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetNodeDetailsOutput;
  59 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetNodeEdgePointDetailsInput;
  60 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetNodeEdgePointDetailsOutput;
  61 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetTopologyDetailsInput;
  62 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetTopologyDetailsOutput;
  63 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetTopologyDetailsOutputBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetTopologyListInput;
  65 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.GetTopologyListOutput;
  66 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.RuleType;
  67 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.TapiTopologyService;
  68 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.get.topology.details.output.Topology;
  69 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.get.topology.details.output.TopologyBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroup;
  71 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupKey;
  73 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePoint;
  74 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointKey;
  75 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.Rule;
  76 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleKey;
  78 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.LinkKey;
  79 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey;
  81 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  82 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
  83 import org.opendaylight.yangtools.yang.common.RpcResult;
  84 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  85 import org.slf4j.Logger;
  86 import org.slf4j.LoggerFactory;
  87
  88 public class TapiTopologyImpl implements TapiTopologyService {
  89
  90     private static final Logger LOG = LoggerFactory.getLogger(TapiTopologyImpl.class);
  91     private final DataBroker dataBroker;
  92
  93     public TapiTopologyImpl(DataBroker dataBroker) {
  94         this.dataBroker = dataBroker;
  95     }
  96
  97     @Override
  98     public ListenableFuture<RpcResult<GetNodeDetailsOutput>> getNodeDetails(GetNodeDetailsInput input) {
  99         // TODO Auto-generated method stub
 100         return null;
 101     }
 102
 103     @Override
 104     public ListenableFuture<RpcResult<GetTopologyDetailsOutput>> getTopologyDetails(GetTopologyDetailsInput input) {
 105         if (!TopologyUtils.T0_MULTILAYER.equals(input.getTopologyIdOrName())
 106              && !TopologyUtils.TPDR_100G.equals(input.getTopologyIdOrName())) {
 107             LOG.error("Invalid TAPI topology name");
 108             return RpcResultBuilder.success(new GetTopologyDetailsOutputBuilder().build()).buildFuture();
 109         }
 110         try {
 111             LOG.info("Building TAPI Topology abstraction for {}", input.getTopologyIdOrName());
 112             Topology topology = createAbstractedOtnTopology();
 113             if (TopologyUtils.TPDR_100G.equals(input.getTopologyIdOrName())) {
 114                 topology = createAbstracted100GTpdrTopology(topology);
 115             }
 116             return RpcResultBuilder.success(new GetTopologyDetailsOutputBuilder().setTopology(topology).build())
 117                 .buildFuture();
 118         } catch (TapiTopologyException e) {
 119             LOG.error("error building TAPI topology");
 120             return RpcResultBuilder.success(new GetTopologyDetailsOutputBuilder().build()).buildFuture();
 121         }
 122     }
 123
 124     private Topology createAbstracted100GTpdrTopology(Topology topology) {
 125         List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> dsrNodes
 126             = topology.nonnullNode().values().stream()
 127                 .filter(node -> node.getLayerProtocolName().contains(LayerProtocolName.DSR))
 128                 .collect(Collectors.toList());
 129         List<OwnedNodeEdgePoint> nep100GTpdrList = new ArrayList<>();
 130         for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node2 : dsrNodes) {
 131             List<OwnedNodeEdgePoint> nepList = node2.getOwnedNodeEdgePoint().values().stream()
 132                 .filter(nep -> nep.getName().containsKey(new NameKey("100G-tpdr"))).collect(Collectors.toList());
 133             nep100GTpdrList.addAll(nepList);
 134         }
 135         Name topoName = new NameBuilder().setValue(TopologyUtils.TPDR_100G).setValueName("TAPI Topology Name").build();
 136         Uuid topoUuid = new Uuid(UUID.nameUUIDFromBytes(TopologyUtils.TPDR_100G.getBytes(Charset.forName("UTF-8")))
 137             .toString());
 138         org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node
 139             = createTapiNode(nep100GTpdrList, topoUuid);
 140         return new TopologyBuilder()
 141             .setName(Map.of(topoName.key(), topoName))
 142             .setUuid(topoUuid)
 143             .setNode(Map.of(node.key(), node))
 144             .build();
 145     }
 146
 147     private Network readTopology(InstanceIdentifier<Network> networkIID)
 148         throws TapiTopologyException {
 149         Network topology = null;
 150         FluentFuture<Optional<Network>> topologyFuture = dataBroker.newReadOnlyTransaction()
 151             .read(LogicalDatastoreType.CONFIGURATION, networkIID);
 152         try {
 153             topology = topologyFuture.get().get();
 154         } catch (InterruptedException e) {
 155             Thread.currentThread().interrupt();
 156             throw new TapiTopologyException("Unable to get from mdsal topology: " + networkIID
 157                 .firstKeyOf(Network.class).getNetworkId().getValue(), e);
 158         } catch (ExecutionException e) {
 159             throw new TapiTopologyException("Unable to get from mdsal topology: " + networkIID
 160                 .firstKeyOf(Network.class).getNetworkId().getValue(), e);
 161         }
 162         return topology;
 163     }
 164
 165     private Topology createAbstractedOtnTopology() throws TapiTopologyException {
 166         // read openroadm-topology
 167         Network openroadmTopo = readTopology(InstanceIdentifiers.OVERLAY_NETWORK_II);
 168         List<Link> linkList = new ArrayList<>();
 169         if (openroadmTopo.augmentation(Network1.class) != null) {
 170             linkList.addAll(openroadmTopo.augmentation(Network1.class).getLink().values());
 171         }
 172         List<Link> xponderOutLinkList = linkList.stream()
 173                 .filter(lk -> lk.augmentation(Link1.class).getLinkType().equals(OpenroadmLinkType.XPONDEROUTPUT))
 174                 .collect(Collectors.toList());
 175         List<Link> xponderInLinkList = linkList.stream()
 176                 .filter(lk -> lk.augmentation(Link1.class).getLinkType().equals(OpenroadmLinkType.XPONDERINPUT))
 177                 .collect(Collectors.toList());
 178         // read otn-topology
 179         Network otnTopo = readTopology(InstanceIdentifiers.OTN_NETWORK_II);
 180         Map<NodeId, Node> otnNodeMap = otnTopo.nonnullNode().values().stream()
 181             .collect(Collectors.toMap(Node::getNodeId, node -> node));
 182
 183         Map<String, List<String>> networkPortMap = new HashMap<>();
 184         Iterator<Entry<NodeId, Node>> itOtnNodeMap = otnNodeMap.entrySet().iterator();
 185         while (itOtnNodeMap.hasNext()) {
 186             Entry<NodeId, Node> entry = itOtnNodeMap.next();
 187             String portMappingNodeId = entry.getValue().getSupportingNode().values().stream()
 188                 .filter(sn -> sn.getNetworkRef().getValue().equals(NetworkUtils.UNDERLAY_NETWORK_ID))
 189                 .findFirst()
 190                 .get().getNodeRef().getValue();
 191             List<String> networkPortList = new ArrayList<>();
 192             for (TerminationPoint tp : entry.getValue().augmentation(Node1.class).getTerminationPoint().values()) {
 193                 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)
 194                     &&
 195                     checkTp(entry.getKey().getValue(), portMappingNodeId, tp, xponderOutLinkList, xponderInLinkList)) {
 196                     networkPortList.add(tp.getTpId().getValue());
 197                 }
 198             }
 199             if (!networkPortList.isEmpty()) {
 200                 networkPortMap.put(entry.getKey().getValue(), networkPortList);
 201             }
 202         }
 203         Map<NodeKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
 204             tapiNodeList = new HashMap<>();
 205         Map<LinkKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link>
 206             tapiLinkList = new HashMap<>();
 207         Uuid topoUuid = new Uuid(UUID.nameUUIDFromBytes(TopologyUtils.T0_MULTILAYER.getBytes(Charset.forName("UTF-8")))
 208             .toString());
 209         ConvertORTopoToTapiTopo tapiFactory = new ConvertORTopoToTapiTopo(topoUuid);
 210         Iterator<Entry<String, List<String>>> it = networkPortMap.entrySet().iterator();
 211         while (it.hasNext()) {
 212             String nodeId = it.next().getKey();
 213             tapiFactory.convertNode(otnNodeMap.get(new NodeId(nodeId)), networkPortMap.get(nodeId));
 214             tapiNodeList.putAll(tapiFactory.getTapiNodes());
 215             tapiLinkList.putAll(tapiFactory.getTapiLinks());
 216         }
 217         if (openroadmTopo.nonnullNode().values().stream().filter(nt ->
 218                 nt.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1.class)
 219                 .getNodeType().equals(OpenroadmNodeType.SRG)).count() > 0) {
 220             tapiFactory.convertRoadmInfrastructure();
 221             tapiNodeList.putAll(tapiFactory.getTapiNodes());
 222             tapiLinkList.putAll(tapiFactory.getTapiLinks());
 223         } else {
 224             LOG.warn("Unable to abstract an ROADM infrasctructure from openroadm-topology");
 225         }
 226         if (otnTopo.augmentation(Network1.class) != null) {
 227             Map<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
 228                 .network.LinkKey, Link> otnLinkMap = otnTopo.augmentation(Network1.class).getLink();
 229             tapiFactory.convertLinks(otnLinkMap);
 230             tapiLinkList.putAll(tapiFactory.getTapiLinks());
 231         }
 232         Name name = new NameBuilder().setValue(TopologyUtils.T0_MULTILAYER).setValueName("TAPI Topology Name").build();
 233         return new TopologyBuilder()
 234                 .setName(Map.of(name.key(), name))
 235                 .setUuid(topoUuid)
 236                 .setNode(tapiNodeList)
 237                 .setLink(tapiLinkList).build();
 238     }
 239
 240     @Override
 241     public ListenableFuture<RpcResult<GetNodeEdgePointDetailsOutput>> getNodeEdgePointDetails(
 242         GetNodeEdgePointDetailsInput input) {
 243         // TODO Auto-generated method stub
 244         return null;
 245     }
 246
 247     @Override
 248     public ListenableFuture<RpcResult<GetLinkDetailsOutput>> getLinkDetails(GetLinkDetailsInput input) {
 249         // TODO Auto-generated method stub
 250         return null;
 251     }
 252
 253     @Override
 254     public ListenableFuture<RpcResult<GetTopologyListOutput>> getTopologyList(GetTopologyListInput input) {
 255         // TODO Auto-generated method stub
 256         return null;
 257     }
 258
 259     private org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node
 260             createTapiNode(List<OwnedNodeEdgePoint> nepList, Uuid topoUuid) {
 261         Name name = new NameBuilder().setValueName("Tpdr100g node name").setValue("Tpdr100g over WDM node").build();
 262         Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepMap = new HashMap<>();
 263         for (OwnedNodeEdgePoint ownedNodeEdgePoint : nepList) {
 264             onepMap.put(ownedNodeEdgePoint.key(), ownedNodeEdgePoint);
 265         }
 266         Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes(name.getValue().getBytes(Charset.forName("UTF-8"))).toString());
 267         return new NodeBuilder()
 268                 .setUuid(nodeUuid)
 269                 .setName(Map.of(name.key(), name))
 270                 .setLayerProtocolName(List.of(LayerProtocolName.ETH))
 271                 .setAdministrativeState(AdministrativeState.UNLOCKED)
 272                 .setOperationalState(OperationalState.ENABLED)
 273                 .setLifecycleState(LifecycleState.INSTALLED)
 274                 .setOwnedNodeEdgePoint(onepMap)
 275                 .setNodeRuleGroup(createNodeRuleGroupFor100gTpdrNode(topoUuid, nodeUuid, nepList))
 276                 .build();
 277     }
 278
 279     private boolean checkTp(String nodeIdTopo, String nodeIdPortMap, TerminationPoint tp, List<Link> xpdOut, List<
 280         Link> xpdIn) {
 281         String networkLcp;
 282         if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERCLIENT)) {
 283             networkLcp = tp.augmentation(
 284                 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev201019.TerminationPoint1.class)
 285                 .getAssociatedConnectionMapPort();
 286         } else {
 287             networkLcp = tp.getTpId().getValue();
 288         }
 289         @NonNull
 290         KeyedInstanceIdentifier<Mapping, MappingKey> pmIID = InstanceIdentifier.create(
 291             org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.Network.class)
 292             .child(Nodes.class, new NodesKey(nodeIdPortMap)).child(Mapping.class, new MappingKey(networkLcp));
 293         @NonNull
 294         FluentFuture<Optional<Mapping>> mappingOpt = dataBroker.newReadOnlyTransaction().read(
 295             LogicalDatastoreType.CONFIGURATION, pmIID);
 296         Mapping mapping = null;
 297         if (mappingOpt.isDone()) {
 298             try {
 299                 mapping = mappingOpt.get().get();
 300             } catch (InterruptedException | ExecutionException e) {
 301                 LOG.error("Error getting mapping for {}", networkLcp,e);
 302                 return false;
 303             }
 304         } else {
 305             LOG.error("Impossible to get mapping of associated network port {} of tp {}", networkLcp, tp.getTpId()
 306                 .getValue());
 307             return false;
 308         }
 309         String networkPortDirection = mapping.getPortDirection();
 310         long count = 0;
 311         switch (networkPortDirection) {
 312             case "bidirectional":
 313                 count += xpdOut.stream().filter(lk -> lk.getSource().getSourceNode().getValue().equals(nodeIdTopo) && lk
 314                     .getSource().getSourceTp().equals(networkLcp)).count();
 315                 count += xpdIn.stream().filter(lk -> lk.getDestination().getDestNode().getValue().equals(nodeIdTopo)
 316                     && lk.getDestination().getDestTp().equals(networkLcp)).count();
 317                 return (count == 2);
 318             case "tx":
 319             case "rx":
 320                 @Nullable
 321                 String partnerLcp = mapping.getPartnerLcp();
 322                 if (mapping.getPortQual().equals("tx")) {
 323                     count += xpdOut.stream().filter(lk -> lk.getSource().getSourceNode().getValue().equals(nodeIdTopo)
 324                         && lk.getSource().getSourceTp().equals(networkLcp)).count();
 325                     count += xpdIn.stream().filter(lk -> lk.getDestination().getDestNode().getValue().equals(nodeIdTopo)
 326                         && lk.getDestination().getDestTp().equals(partnerLcp)).count();
 327                 }
 328                 if (mapping.getPortQual().equals("rx")) {
 329                     count += xpdIn.stream().filter(lk -> lk.getDestination().getDestNode().getValue().equals(nodeIdTopo)
 330                         && lk.getDestination().getDestTp().equals(networkLcp)).count();
 331                     count += xpdOut.stream().filter(lk -> lk.getSource().getSourceNode().getValue().equals(nodeIdTopo)
 332                         && lk.getSource().getSourceTp().equals(partnerLcp)).count();
 333                 }
 334                 return (count == 2);
 335             default:
 336                 LOG.error("Invalid port direction for {}", networkLcp);
 337                 return false;
 338         }
 339     }
 340
 341     private Map<NodeRuleGroupKey, NodeRuleGroup> createNodeRuleGroupFor100gTpdrNode(Uuid topoUuid, Uuid nodeUuid,
 342         Collection<OwnedNodeEdgePoint> onepl) {
 343         Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
 344             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
 345             nepMap = new HashMap<>();
 346         for (OwnedNodeEdgePoint onep : onepl) {
 347             org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint
 348                 nep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
 349                     .NodeEdgePointBuilder()
 350                 .setTopologyUuid(topoUuid)
 351                 .setNodeUuid(nodeUuid)
 352                 .setNodeEdgePointUuid(onep.key().getUuid())
 353                 .build();
 354             nepMap.put(nep.key(), nep);
 355         }
 356         Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupMap = new HashMap<>();
 357         Map<RuleKey, Rule> ruleList = new HashMap<>();
 358         Rule rule = new RuleBuilder()
 359             .setLocalId("forward")
 360             .setForwardingRule(ForwardingRule.MAYFORWARDACROSSGROUP)
 361             .setRuleType(RuleType.FORWARDING)
 362             .build();
 363         ruleList.put(rule.key(), rule);
 364         NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
 365             .setUuid(new Uuid(UUID.nameUUIDFromBytes(("rdm infra node rule group").getBytes(Charset.forName("UTF-8")))
 366                 .toString()))
 367             .setRule(ruleList)
 368             .setNodeEdgePoint(nepMap)
 369             .build();
 370         nodeRuleGroupMap.put(nodeRuleGroup.key(), nodeRuleGroup);
 371         return nodeRuleGroupMap;
 372     }
 373 }