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 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupInput;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupInputBuilder;
  19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.ServicePathInput;
  20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.ServicePathInputBuilder;
  21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceDeleteOutput;
  22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceDeleteOutputBuilder;
  23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceImplementationRequestInput;
  24 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceImplementationRequestOutput;
  25 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev171017.ServiceImplementationRequestOutputBuilder;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommon;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommonBuilder;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceDeleteInput;
  29 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.PathDescription;
  30 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.atoz.direction.AToZ;
  31 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.path.description.ztoa.direction.ZToA;
  32 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.pce.resource.resource.resource.TerminationPoint;
  33 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.Nodes;
  34 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesBuilder;
  35 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.renderer.input.NodesKey;
  36 import org.opendaylight.yangtools.yang.common.RpcResult;
  37 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40
  41 public final class ModelMappingUtils {
  42
  43     private static final Logger LOG = LoggerFactory.getLogger(ModelMappingUtils.class);
  44     private static final String TERMINATION_POINT = "TerminationPoint";
  45
  46     private ModelMappingUtils() {
  47     }
  48
  49     public static ServicePowerSetupInput createServicePowerSetupInput(List<Nodes> olmList,
  50         ServiceImplementationRequestInput input) {
  51         ServicePowerSetupInputBuilder olmSetupBldr = new ServicePowerSetupInputBuilder();
  52         olmSetupBldr.setNodes(olmList);
  53         olmSetupBldr.setWaveNumber(input.getPathDescription().getAToZDirection().getAToZWavelengthNumber());
  54         return olmSetupBldr.build();
  55     }
  56
  57     public static ServiceImplementationRequestOutput createServiceImplResponse(String responseCode, String message) {
  58         ServiceImplementationRequestOutputBuilder outputBldr = new ServiceImplementationRequestOutputBuilder();
  59         outputBldr.setConfigurationResponseCommon(createCommonResponse(responseCode, message));
  60         return outputBldr.build();
  61     }
  62
  63     public static ServiceDeleteOutput createServiceDeleteResponse(String responseCode, String message) {
  64         ServiceDeleteOutputBuilder outputBldr = new ServiceDeleteOutputBuilder();
  65         outputBldr.setConfigurationResponseCommon(createCommonResponse(responseCode, message));
  66         return outputBldr.build();
  67     }
  68
  69     public static ConfigurationResponseCommon createCommonResponse(String responseCode, String message) {
  70         ConfigurationResponseCommonBuilder cmBldr = new ConfigurationResponseCommonBuilder();
  71         cmBldr.setResponseMessage(message);
  72         cmBldr.setResponseCode(responseCode);
  73         return cmBldr.build();
  74     }
  75
  76     public static ListenableFuture<RpcResult<ServiceImplementationRequestOutput>>
  77         createServiceImplementationRpcResponse(ServiceImplementationRequestOutput payload) {
  78         return RpcResultBuilder.success(payload).buildFuture();
  79     }
  80
  81     public static ListenableFuture<RpcResult<ServiceDeleteOutput>>
  82         createServiceDeleteRpcResponse(ServiceDeleteOutput payload) {
  83         return RpcResultBuilder.success(payload).buildFuture();
  84     }
  85
  86     public static ServicePathInputData rendererCreateServiceInputAToZ(String serviceName,
  87         PathDescription pathDescription) {
  88         ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder();
  89         servicePathInputBuilder.setServiceName(serviceName);
  90         NodeLists nodeLists = getNodesListAToZ(pathDescription.getAToZDirection().getAToZ().iterator());
  91         servicePathInputBuilder.setServiceName(serviceName);
  92         servicePathInputBuilder.setOperation(ServicePathInput.Operation.Create);
  93         servicePathInputBuilder.setWaveNumber(new Long(pathDescription.getAToZDirection().getAToZWavelengthNumber()));
  94         servicePathInputBuilder.setNodes(nodeLists.getList());
  95         return new ServicePathInputData(servicePathInputBuilder.build(), nodeLists);
  96     }
  97
  98     public static ServicePathInputData rendererCreateServiceInputZToA(String serviceName,
  99         PathDescription pathDescription) {
 100         ServicePathInputBuilder servicePathInputBuilder = new ServicePathInputBuilder();
 101         NodeLists nodeLists = getNodesListZtoA(pathDescription.getZToADirection().getZToA().iterator());
 102         servicePathInputBuilder.setOperation(ServicePathInput.Operation.Create);
 103         servicePathInputBuilder.setServiceName(serviceName);
 104         servicePathInputBuilder.setWaveNumber(new Long(pathDescription.getZToADirection().getZToAWavelengthNumber()));
 105         servicePathInputBuilder.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         servicePathInput.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().getImplementedInterface().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                 nb.withKey(new NodesKey(values.getNodeID()));
 173                 nb.setDestTp(desID);
 174                 nb.setSrcTp(srcID);
 175                 list.add(nb.build());
 176
 177                 NodesBuilder olmNb = new NodesBuilder();
 178                 olmNb.setNodeId(values.getNodeID());
 179                 olmNb.setDestTp(desID);
 180                 olmNb.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().getImplementedInterface().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(OpenRoadmInterfacesImpl.TTP_TOKEN)
 219                         && !tpID.contains(OpenRoadmInterfacesImpl.PP_TOKEN)
 220                         && !tpID.contains(OpenRoadmInterfacesImpl.NETWORK_TOKEN)
 221                         && !tpID.contains(OpenRoadmInterfacesImpl.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                 nb.withKey(new NodesKey(values.getNodeID()));
 249                 nb.setDestTp(desID);
 250                 nb.setSrcTp(srcID);
 251                 list.add(nb.build());
 252
 253                 NodesBuilder olmNb = new NodesBuilder();
 254                 olmNb.setNodeId(values.getNodeID());
 255                 olmNb.setDestTp(desID);
 256                 olmNb.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 }