diff options
Diffstat (limited to 'core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java')
| -rw-r--r-- | core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java | 184 |
1 files changed, 182 insertions, 2 deletions
diff --git a/core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java b/core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java index 9cfc305c9..5760bdfd4 100644 --- a/core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java +++ b/core/sliPluginUtils/provider/src/main/java/org/onap/ccsdk/sli/core/slipluginutils/SliTopologyUtils.java @@ -17,17 +17,29 @@ */ package org.onap.ccsdk.sli.core.slipluginutils; +import com.google.common.collect.ImmutableSet; +import com.google.gson.JsonArray; +import com.google.gson.JsonElement; +import com.google.gson.JsonObject; +import com.google.gson.JsonParser; import org.apache.commons.lang3.StringUtils; import org.onap.ccsdk.sli.core.sli.SvcLogicContext; import org.onap.ccsdk.sli.core.sli.SvcLogicException; import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.JsonParserHelper; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.graph.DijkstraGraphSearch; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.graph.Graph; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.graph.Path; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.topology.*; +import org.onap.ccsdk.sli.core.slipluginutils.slitopologyutils.topology.LogicalLink; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.util.ArrayList; +import java.util.List; import java.util.Map; public class SliTopologyUtils implements SvcLogicJavaPlugin { - private static final Logger LOG = LoggerFactory.getLogger(SliTopologyUtils.class); public static final String SUCCESS_CONSTANT = "success"; public static final String FAILURE_CONSTANT = "failure"; @@ -61,8 +73,97 @@ public class SliTopologyUtils implements SvcLogicJavaPlugin { checkParameters(parameters, new String[]{ "pnfs-pfx", "links-pfx", "src-node", "dst-node", "response-pfx"}, LOG); - return SUCCESS_CONSTANT; + boolean outputFullPath = false; + String outputEndToEnd = parameters.get("output-end-to-end-path"); + + if (outputEndToEnd != null && outputEndToEnd.equals("true")){ + outputFullPath = true; + LOG.debug( "OutputEndToEndPath enabled"); + } + + String pnfsStr = ctx.toJsonString(parameters.get("pnfs-pfx")); + String lkStr = ctx.toJsonString(parameters.get("links-pfx")); + + if (pnfsStr.isEmpty()){ + LOG.warn("Pnf Array attributes are empty"); + throw new Exception( "Pnf Array attributes are empty"); + } + + if (lkStr.isEmpty()){ + LOG.warn("Logical-links Array attributes are empty"); + throw new Exception( "Logical-links Array attributes are empty"); + } + + LOG.debug("Pnf Json String is: {}", pnfsStr); + + String srcNodeStr = parameters.get("src-node"); + String dstNodeStr = parameters.get("dst-node"); + + if( srcNodeStr.isEmpty() || dstNodeStr.isEmpty()){ + LOG.warn("Src or Dst node is empty"); + throw new Exception("Src or Dst node is empty"); + } + + JsonParser jp = new JsonParser(); + + JsonArray pnfArr = ((JsonObject) jp.parse(pnfsStr)).getAsJsonArray("pnf"); + JsonArray lkArr = ((JsonObject) jp.parse(lkStr)).getAsJsonArray("logical-link"); + LOG.debug("Creating graph with {} pnf(s) and {} link(s)", pnfArr.size(), lkArr.size()); + Graph<Pnf, LogicalLink> graph = buildGraph(pnfArr, lkArr); + + Pnf src = new Pnf(srcNodeStr); + Pnf dst = new Pnf(dstNodeStr); + + if (!graph.getVertexes().contains(src) || !graph.getVertexes().contains(dst)){ + LOG.warn("Src or Dst node doesn't exist"); + throw new Exception("Src or Dst node doesn't exist"); + } + + DijkstraGraphSearch.Result result = + new DijkstraGraphSearch<Pnf, LogicalLink>().search(graph, src, dst,null, -1); + LOG.debug("Path Computing results: {}", result.paths().toString()); + + if (result.paths().size() > 0){ + JsonObject root = new JsonObject(); + JsonArray solnList = new JsonArray(); + Path<Pnf, LogicalLink> path = (Path<Pnf, LogicalLink>) result.paths().iterator().next(); + for (LogicalLink logicalLink : path.edges()) { + if ( ((OtnLink) logicalLink.underlayLink()).isInnerDomain() && !outputFullPath ){ + //Ignore inner domain links + } else { + JsonObject curLink = new JsonObject(); + String srcNode = logicalLink.src().toString(); + String dstNode = logicalLink.dst().toString(); + String srcPInterface = ((OtnLink) logicalLink.underlayLink()).src().pInterfaceName().getName(); + String dstPInterface = ((OtnLink) logicalLink.underlayLink()).dst().pInterfaceName().getName(); + String linkName = ((OtnLink) logicalLink.underlayLink()).linkName(); + curLink.addProperty("src_node", srcNode); + curLink.addProperty("dst_node", dstNode); + curLink.addProperty("src_pinterface", srcPInterface); + curLink.addProperty("dst_pinterface", dstPInterface); + curLink.addProperty("original_link", linkName); + + solnList.add(curLink); + } + } + root.add("solutions", solnList); + //Write result back to context memory; + String pp = parameters.get("response-pfx").isEmpty() ? "" : parameters.get("response-pfx") + "."; + Map<String, String> mm = null; + mm = JsonParserHelper.convertToProperties(root.toString()); + if (mm != null) { + for (Map.Entry<String, String> entry : mm.entrySet()) { + ctx.setAttribute(pp + entry.getKey(), entry.getValue()); + } + } + LOG.debug("SliTopologyUtils: path computation succeeds in finding the shortest path;" + + " result has been written back into context memory."); + return SUCCESS_CONSTANT; + } else { + LOG.debug("SliTopologyUtils: no valid path found."); + return NOT_FOUND_CONSTANT; + } } catch( Exception e ) { throw new SvcLogicException( "An error occurred in the computePath Execute node", e ); @@ -71,6 +172,85 @@ public class SliTopologyUtils implements SvcLogicJavaPlugin { } } + private static Graph<Pnf, LogicalLink> buildGraph(JsonArray pnfs, JsonArray llks) { + ImmutableSet.Builder pnfSetBlder = ImmutableSet.builder(); + ImmutableSet.Builder lkSetBlder = ImmutableSet.builder(); + + //Create Immutable set of Pnf; + for (int i = 0,e = pnfs.size(); i < e; i++){ + JsonElement pnfName = ((JsonObject) pnfs.get(i)).get("pnf-name"); + + if (pnfName != null){ + String pnfNameStr = pnfName.getAsString(); + + if (pnfNameStr != null && !pnfNameStr.isEmpty()){ + pnfSetBlder.add(new Pnf(pnfNameStr)); + } + + } else { + LOG.debug("SliTopologyUtils: invalid pnf: {}", ((JsonObject) pnfs.get(i)).toString()); + } + } + + //Create Immutable set of Logical-Link + for (int i = 0,e = llks.size(); i < e; i++){ + JsonObject lkRoot = ((JsonObject) llks.get(i)); + JsonElement relationList = lkRoot.get("relationship-list"); + + if (relationList != null) { + JsonElement relationListArray = ((JsonObject) relationList).get("relationship"); + + if (relationListArray != null){ + List<String> pnfNameStrList = new ArrayList<>(); + List<String> pInterfaceStrList= new ArrayList<>(); + + for (int j = 0,k = ((JsonArray) relationListArray).size(); j < k; j++){ + JsonObject relation = ((JsonArray) relationListArray).get(j).getAsJsonObject(); + JsonElement relatedTo = relation.getAsJsonPrimitive("related-to"); + + if (relatedTo != null && relatedTo.getAsString().equals("p-interface")){ + JsonArray data = relation.getAsJsonArray("relationship-data"); + for (int m = 0, n = data.size(); m < n; m++){ + JsonObject dataKeyValue = data.get(m).getAsJsonObject(); + + if (dataKeyValue.get("relationship-key").getAsString().equals("pnf.pnf-name")){ + pnfNameStrList.add(dataKeyValue.get("relationship-value").getAsString()); + } else if (dataKeyValue.get("relationship-key").getAsString() + .equals("p-interface.interface-name")){ + pInterfaceStrList.add(dataKeyValue.get("relationship-value").getAsString()); + } + } + } + } + + if (pnfNameStrList.size() == 2 && pnfNameStrList.size() == 2){ + String pnf1NameStr = pnfNameStrList.get(0); + String pnf2NameStr = pnfNameStrList.get(1); + String pI1NameStr = pInterfaceStrList.get(0); + String pI2NameStr = pInterfaceStrList.get(1); + Pnf pnf1 = new Pnf(pnf1NameStr); + Pnf pnf2 = new Pnf(pnf2NameStr); + PInterfaceName pI1Name = PInterfaceName.of(pI1NameStr); + PInterfaceName pI2Name = PInterfaceName.of(pI2NameStr); + PInterface pI1 = new PInterface(pnf1NameStr, pI1Name); + PInterface pI2 = new PInterface(pnf1NameStr, pI2Name); + String linkName_f = pI1Name.getNetworkId() + "-linkId-" + + pI1Name.getPnfId() + "-" + + pI1Name.getLtpId(); + String linkName_b = pI2Name.getNetworkId() + + "-linkId-" + pI2Name.getPnfId() + + "-" + pI2Name.getLtpId(); + OtnLink link_f = new OtnLink(linkName_f, pI1, pI2); + OtnLink link_b = new OtnLink(linkName_b, pI2, pI1); + lkSetBlder.add(new LogicalLink(pnf1, pnf2, link_f)); + lkSetBlder.add(new LogicalLink(pnf2, pnf1, link_b)); + } + } + } + } + return new Graph<Pnf, LogicalLink>(pnfSetBlder.build(), lkSetBlder.build()); + } + /** * Throws an exception and writes an error to the log file if a required * parameters is not found in the parametersMap. |