common/src/main/java/org/opendaylight/transportpce/common/mapping/MappingUtilsImpl.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.common.mapping;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12 import java.util.Optional;
  13 import java.util.concurrent.ExecutionException;
  14 import org.opendaylight.mdsal.binding.api.DataBroker;
  15 import org.opendaylight.mdsal.binding.api.ReadTransaction;
  16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  17 import org.opendaylight.transportpce.common.StringConstants;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.Network;
  19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mc.capabilities.McCapabilities;
  20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.Nodes;
  21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.NodesKey;
  22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.nodes.NodeInfo;
  23 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If100GE;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If100GEODU4;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GE;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GEODU2;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If10GEODU2e;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If1GE;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If1GEODU0;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.If400GE;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCH;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOCHOTU4ODU4;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.IfOTUCnODUCn;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
  35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 public class MappingUtilsImpl implements MappingUtils {
  40
  41     private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
  42
  43     private final DataBroker dataBroker;
  44
  45     public MappingUtilsImpl(DataBroker dataBroker) {
  46
  47         this.dataBroker = dataBroker;
  48
  49     }
  50
  51     public String getOpenRoadmVersion(String nodeId) {
  52         /*
  53          * Getting physical mapping corresponding to logical connection point
  54          */
  55         InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
  56                 new NodesKey(nodeId)).child(NodeInfo.class).build();
  57         try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
  58             Optional<NodeInfo> nodeInfoObj =
  59                     readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
  60             if (nodeInfoObj.isPresent()) {
  61                 NodeInfo nodInfo = nodeInfoObj.get();
  62                 switch (nodInfo.getOpenroadmVersion()) {
  63                     case _710:
  64                         return StringConstants.OPENROADM_DEVICE_VERSION_7_1_0;
  65                     case _221:
  66                         return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
  67                     case _121:
  68                         return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
  69                     default:
  70                         LOG.warn("unknown openROADM device version");
  71                 }
  72             } else {
  73                 LOG.warn("Could not find mapping for nodeId {}", nodeId);
  74             }
  75         } catch (InterruptedException | ExecutionException ex) {
  76             LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
  77         }
  78         return null;
  79     }
  80
  81     /*
  82     * (non-Javadoc)
  83     *
  84     * @see org.opendaylight.transportpce.common.mapping.MappingUtils#getMcCapabilitiesForNode(java.lang.String)
  85     */
  86     @Override
  87     public List<McCapabilities> getMcCapabilitiesForNode(String nodeId) {
  88         List<McCapabilities> mcCapabilities = new ArrayList<>();
  89         InstanceIdentifier<Nodes> nodePortMappingIID = InstanceIdentifier.builder(Network.class)
  90                 .child(Nodes.class, new NodesKey(nodeId)).build();
  91         try (ReadTransaction readTx = this.dataBroker.newReadOnlyTransaction()) {
  92             Optional<Nodes> nodePortMapObject = readTx.read(LogicalDatastoreType.CONFIGURATION, nodePortMappingIID)
  93                     .get();
  94             if (nodePortMapObject.isPresent()) {
  95                 LOG.info("Found node {}", nodeId);
  96                 Nodes node = nodePortMapObject.get();
  97                 mcCapabilities.addAll(node.nonnullMcCapabilities().values());
  98             }
  99         } catch (ExecutionException e) {
 100             LOG.error("Something went wrong while getting node {}", nodeId, e);
 101         } catch (InterruptedException e) {
 102             LOG.error("Request interrupted for node {} interrupted", nodeId, e);
 103             Thread.currentThread().interrupt();
 104         }
 105         LOG.info("Capabilitities for node {}: {}", nodeId, mcCapabilities);
 106         return mcCapabilities;
 107     }
 108
 109     public static Class<? extends SupportedIfCapability> convertSupIfCapa(String ifCapType) {
 110         switch (ifCapType) {
 111             case "IfOTUCnODUCn":
 112                 return IfOTUCnODUCn.class;
 113             case "IfOCHOTU4ODU4":
 114                 return IfOCHOTU4ODU4.class;
 115             case "IfOCH":
 116                 return IfOCH.class;
 117             case "If100GEODU4":
 118                 return If100GEODU4.class;
 119             case "If10GEODU2e":
 120                 return If10GEODU2e.class;
 121             case "If10GEODU2":
 122                 return If10GEODU2.class;
 123             case "If1GEODU0":
 124                 return If1GEODU0.class;
 125             case "If400GE":
 126                 return If400GE.class;
 127             case "If100GE":
 128                 return If100GE.class;
 129             case "If10GE":
 130                 return If10GE.class;
 131             case "If1GE":
 132                 return If1GE.class;
 133             default:
 134                 return null;
 135         }
 136     }
 137 }