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