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.Optional;
  11 import java.util.concurrent.ExecutionException;
  12 import org.opendaylight.mdsal.binding.api.DataBroker;
  13 import org.opendaylight.mdsal.binding.api.ReadTransaction;
  14 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  15 import org.opendaylight.transportpce.common.StringConstants;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.Network;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.network.Nodes;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.network.NodesKey;
  19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.network.nodes.NodeInfo;
  20 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  21 import org.slf4j.Logger;
  22 import org.slf4j.LoggerFactory;
  23
  24 public class MappingUtilsImpl implements MappingUtils {
  25
  26     private static final Logger LOG = LoggerFactory.getLogger(MappingUtilsImpl.class);
  27
  28     private final DataBroker dataBroker;
  29
  30     public MappingUtilsImpl(DataBroker dataBroker) {
  31
  32         this.dataBroker = dataBroker;
  33
  34     }
  35
  36     public String getOpenRoadmVersion(String nodeId) {
  37         /*
  38          * Getting physical mapping corresponding to logical connection point
  39          */
  40         InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
  41                 new NodesKey(nodeId)).child(NodeInfo.class).build();
  42         try (ReadTransaction readTx = dataBroker.newReadOnlyTransaction()) {
  43             Optional<NodeInfo> nodeInfoObj =
  44                     readTx.read(LogicalDatastoreType.CONFIGURATION, nodeInfoIID).get();
  45             if (nodeInfoObj.isPresent()) {
  46                 NodeInfo nodInfo = nodeInfoObj.get();
  47                 switch (nodInfo.getOpenroadmVersion()) {
  48                     case _221:
  49                         return StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
  50                     case _121:
  51                         return StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
  52                     default:
  53                         LOG.warn("unknown openROADM device version");
  54                 }
  55             } else {
  56                 LOG.warn("Could not find mapping for nodeId {}", nodeId);
  57             }
  58         } catch (InterruptedException | ExecutionException ex) {
  59             LOG.error("Unable to read mapping for nodeId {}",nodeId, ex);
  60         }
  61         return null;
  62     }
  63 }