renderer/src/main/java/org/opendaylight/transportpce/renderer/ModelMappingUtils.java

   1 /*
   2  * Copyright © 2017 AT&T 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.renderer;
   9
  10 import com.google.common.util.concurrent.ListenableFuture;
  11 import java.util.ArrayList;
  12 import java.util.Iterator;
  13 import java.util.List;
  14 import java.util.Map;
  15 import java.util.TreeMap;
  16
  17 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
  18 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommon;
  19 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommonBuilder;
  20 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceDeleteInput;
  21 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.PathDescription;
  22 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.atoz.direction.AToZ;
  23 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ztoa.direction.ZToA;
  24 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.resource.resource.TerminationPoint;
  25 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceDeleteOutput;
  26 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceDeleteOutputBuilder;
  27 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestInput;
  28 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestOutput;
  29 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestOutputBuilder;
  30 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.Nodes;
  31 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesBuilder;
  32 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesKey;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.ServicePowerSetupInput;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.ServicePowerSetupInputBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.ServicePathInput;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.ServicePathInputBuilder;
  37 import org.opendaylight.yangtools.yang.common.RpcResult;
  38 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  39 import org.slf4j.Logger;
  40 import org.slf4j.LoggerFactory;
  41
  42 public final class ModelMappingUtils {
  43
  44     private static final Logger LOG = LoggerFactory.getLogger(ModelMappingUtils.class);
  45     private static final String TERMINATION_POINT = "TerminationPoint";
  46
  47     private ModelMappingUtils() {
  48     }
  49
  50     public static ServicePowerSetupInput createServicePowerSetupInput(List<Nodes> olmList,
  51         ServiceImplementationRequestInput input) {
  52         ServicePowerSetupInputBuilder olmSetupBldr = new ServicePowerSetupInputBuilder();
  53         olmSetupBldr.setNodes(olmList);
  54         olmSetupBldr.setWaveNumber(input.getPathDescription().getAToZDirection().getAToZWavelengthNumber());
  55         return olmSetupBldr.build();
  56     }
  57
  58     public static ServiceImplementationRequestOutput createServiceImplResponse(String responseCode, String message) {
  59         ServiceImplementationRequestOutputBuilder outputBldr = new ServiceImplementationRequestOutputBuilder();
  60         outputBldr.setConfigurationResponseCommon(createCommonResponse(responseCode, message));
  61         return outputBldr.build();
  62     }
  63
  64     public static ServiceDeleteOutput createServiceDeleteResponse(String responseCode, String message) {
  65         ServiceDeleteOutputBuilder outputBldr = new ServiceDeleteOutputBuilder();
  66         outputBldr.setConfigurationResponseCommon(createCommonResponse(responseCode, message));
  67         return outputBldr.build();
  68     }
  69
  70     public static ConfigurationResponseCommon createCommonResponse(String responseCode, String message) {
  71         ConfigurationResponseCommonBuilder cmBldr = new ConfigurationResponseCommonBuilder();
  72         cmBldr.setResponseMessage(message);
  73         cmBldr.setResponseCode(responseCode);
  74         return cmBldr.build();
  75     }
  76
  77     public static ListenableFuture<RpcResult<ServiceImplementationRequestOutput>>
  78         createRpcResponse(ServiceImplementationRequestOutput payload) {
  79         return RpcResultBuilder.success(payload).buildFuture();
  80     }
  81
  82     public static ServicePathInputData rendererCreateServiceInputAToZ(String serviceName,
  83         PathDescription pathDescription) {
  84         ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder();
  85         servicePathInputBuilder.setServiceName(serviceName);
  86         NodeLists nodeLists = getNodesListAToZ(pathDescription.getAToZDirection().getAToZ().iterator());
  87         servicePathInputBuilder.setServiceName(serviceName);
  88         servicePathInputBuilder.setOperation(ServicePathInput.Operation.Create);
  89         servicePathInputBuilder.setWaveNumber(new Long(pathDescription.getAToZDirection().getAToZWavelengthNumber()));
  90         servicePathInputBuilder.setNodes(nodeLists.getList());
  91         return new ServicePathInputData(servicePathInputBuilder.build(), nodeLists);
  92     }
  93
  94     public static ServicePathInputData rendererCreateServiceInputZToA(String serviceName,
  95         PathDescription pathDescription) {
  96         ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder();
  97         NodeLists nodeLists = getNodesListZtoA(pathDescription.getZToADirection().getZToA().iterator());
  98         servicePathInputBuilder.setOperation(ServicePathInput.Operation.Create);
  99         servicePathInputBuilder.setServiceName(serviceName);
 100         servicePathInputBuilder.setWaveNumber(new Long(pathDescription.getZToADirection().getZToAWavelengthNumber()));
 101         servicePathInputBuilder.setNodes(nodeLists.getList());
 102         return new ServicePathInputData(servicePathInputBuilder.build(), nodeLists);
 103     }
 104
 105     public static ServicePathInput rendererDeleteServiceInput(String serviceName,
 106         ServiceDeleteInput serviceDeleteInput) {
 107         ServicePathInputBuilder servicePathInput = new ServicePathInputBuilder();
 108         servicePathInput.setServiceName(serviceName);
 109         //TODO: finish model-model mapping
 110         return servicePathInput.build();
 111     }
 112
 113     public static NodeLists getNodesListZtoA(Iterator<ZToA> iterator) {
 114         Map<Integer, NodeIdPair> treeMap = new TreeMap<>();
 115         List<Nodes> olmList = new ArrayList<>();
 116         List<Nodes> list = new ArrayList<>();
 117         String resourceType;
 118         TerminationPoint tp;
 119         String tpID = "";
 120         String nodeID = "";
 121         String sortId = "";
 122         while (iterator.hasNext()) {
 123             ZToA pathDesObj = iterator.next();
 124             resourceType = pathDesObj.getResource().getResource().getImplementedInterface().getSimpleName();
 125             LOG.info("Inside AtoZ {}", resourceType);
 126
 127             try {
 128                 if (TERMINATION_POINT.equals(resourceType)) {
 129                     tp = (TerminationPoint) pathDesObj.getResource().getResource();
 130                     LOG.info(" TP is {} {}", tp.getTerminationPointIdentifier().getTpId(),
 131                             tp.getTerminationPointIdentifier().getNodeId());
 132                     tpID = tp.getTerminationPointIdentifier().getTpId();
 133                     nodeID = tp.getTerminationPointIdentifier().getNodeId();
 134                     sortId = pathDesObj.getId();
 135
 136                     //TODO: do not rely on ID to be in certain format
 137                     if (tpID.contains("CTP") || tpID.contains("CP")) {
 138                         continue;
 139                     }
 140                     if (!tpID.contains("TTP") && !tpID.contains("PP") && !tpID.contains("NETWORK")
 141                             && !tpID.contains("CLIENT")) {
 142                         continue;
 143                     }
 144
 145                     int[] pos = findTheLongestSubstring(nodeID, tpID);
 146                     //TODO: do not rely on nodeId to be integer
 147                     int id = Integer.parseInt(sortId);
 148                    treeMap.put(id, new NodeIdPair(nodeID.substring(0, pos[0] - 1), tpID));
 149                 } else if (resourceType.equals("Link")) {
 150                     LOG.info("The type is link");
 151                 } else {
 152                     LOG.info("The type is not indentified: {}", resourceType);
 153                 }
 154             } catch (IllegalArgumentException | SecurityException e) {
 155                 // TODO Auto-generated catch block
 156                 LOG.error("Dont find the getResource method", e);
 157             }
 158         }
 159
 160         String desID = null;
 161         String srcID = null;
 162         for (NodeIdPair values : treeMap.values()) {
 163             if (srcID == null) {
 164                 srcID = values.getTpID();
 165             } else if (desID == null) {
 166                 desID = values.getTpID();
 167                 NodesBuilder nb = new NodesBuilder();
 168                 nb.withKey(new NodesKey(values.getNodeID()));
 169                 nb.setDestTp(desID);
 170                 nb.setSrcTp(srcID);
 171                 list.add(nb.build());
 172
 173                 NodesBuilder olmNb = new NodesBuilder();
 174                 olmNb.setNodeId(values.getNodeID());
 175                 olmNb.setDestTp(desID);
 176                 olmNb.setSrcTp(srcID);
 177                 olmList.add(olmNb.build());
 178                 srcID = null;
 179                 desID = null;
 180             } else {
 181                 LOG.warn("both, the source and destination id are null!");
 182             }
 183         }
 184         return new NodeLists(olmList, list);
 185     }
 186
 187     public static NodeLists getNodesListAToZ(Iterator<AToZ> iterator) {
 188         Map<Integer, NodeIdPair> treeMap = new TreeMap<>();
 189         List<Nodes> list = new ArrayList<>();
 190         List<Nodes> olmList = new ArrayList<>();
 191         String resourceType;
 192         TerminationPoint tp;
 193         String tpID = "";
 194         String nodeID = "";
 195         String sortId = "";
 196
 197         while (iterator.hasNext()) {
 198             AToZ pathDesObj = iterator.next();
 199             resourceType = pathDesObj.getResource().getResource().getImplementedInterface().getSimpleName();
 200             LOG.info("Inside AtoZ {}", resourceType);
 201             try {
 202                 if (TERMINATION_POINT.equals(resourceType)) {
 203                     tp = (TerminationPoint) pathDesObj.getResource().getResource();
 204                     LOG.info(" TP is {} {}", tp.getTerminationPointIdentifier().getTpId(),
 205                             tp.getTerminationPointIdentifier().getNodeId());
 206                     tpID = tp.getTerminationPointIdentifier().getTpId();
 207                     nodeID = tp.getTerminationPointIdentifier().getNodeId();
 208                     sortId = pathDesObj.getId();
 209
 210                     //TODO: do not rely on ID to be in certain format
 211                     if (tpID.contains("CTP") || tpID.contains("CP")) {
 212                         continue;
 213                     }
 214                     if (!tpID.contains(OpenRoadmInterfacesImpl.TTP_TOKEN)
 215                         && !tpID.contains(OpenRoadmInterfacesImpl.PP_TOKEN)
 216                         && !tpID.contains(OpenRoadmInterfacesImpl.NETWORK_TOKEN)
 217                         && !tpID.contains(OpenRoadmInterfacesImpl.CLIENT_TOKEN)) {
 218                         continue;
 219                     }
 220
 221                     int[] pos = findTheLongestSubstring(nodeID, tpID);
 222                     //TODO: do not rely on nodeId to be integer
 223                     int id = Integer.parseInt(sortId);
 224                    treeMap.put(id, new NodeIdPair(nodeID.substring(0, pos[0] - 1), tpID));
 225                 } else if (resourceType.equals("Link")) {
 226                     LOG.info("The type is link");
 227                 } else {
 228                     LOG.info("The type is not indentified: {}", resourceType);
 229                 }
 230             } catch (IllegalArgumentException | SecurityException e) {
 231                 //TODO: Auto-generated catch block
 232                 LOG.error("Dont find the getResource method", e);
 233             }
 234         }
 235
 236         String desID = null;
 237         String srcID = null;
 238         for (NodeIdPair values : treeMap.values()) {
 239             if (srcID == null) {
 240                 srcID = values.getTpID();
 241             } else if (desID == null) {
 242                 desID = values.getTpID();
 243                 NodesBuilder nb = new NodesBuilder();
 244                 nb.withKey(new NodesKey(values.getNodeID()));
 245                 nb.setDestTp(desID);
 246                 nb.setSrcTp(srcID);
 247                 list.add(nb.build());
 248
 249                 NodesBuilder olmNb = new NodesBuilder();
 250                 olmNb.setNodeId(values.getNodeID());
 251                 olmNb.setDestTp(desID);
 252                 olmNb.setSrcTp(srcID);
 253                 olmList.add(olmNb.build());
 254                 srcID = null;
 255                 desID = null;
 256             } else {
 257                 LOG.warn("both, the source and destination id are null!");
 258             }
 259         }
 260         return new NodeLists(olmList, list);
 261     }
 262
 263     public static int[] findTheLongestSubstring(String s1, String s2) {
 264         if ((s1 == null) || (s2 == null)) {
 265             return null;
 266         }
 267         int[][] dp = new int[s1.length() + 1][s2.length() + 1];
 268         int maxLen = 0;
 269         int endPos = 0;
 270         for (int i = 1; i < dp.length; i++) {
 271             for (int j = 1; j < dp[0].length; j++) {
 272                 char ch1 = s1.charAt(i - 1);
 273                 char ch2 = s2.charAt(j - 1);
 274                 if (ch1 == ch2) {
 275                     dp[i][j] = dp[i - 1][j - 1] + 1;
 276                     if (dp[i][j] >= maxLen) {
 277                         maxLen = dp[i][j];
 278                         endPos = i;
 279                     }
 280                 }
 281             }
 282         }
 283         return new int[] { endPos - maxLen, endPos };
 284     }
 285
 286 }