common/src/main/java/org/opendaylight/transportpce/common/openroadminterfaces/OpenRoadmInterfacesImpl.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
   9 package org.opendaylight.transportpce.common.openroadminterfaces;
  10
  11 import static org.opendaylight.transportpce.common.StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
  12 import static org.opendaylight.transportpce.common.StringConstants.OPENROADM_DEVICE_VERSION_2_2;
  13
  14 import java.util.Optional;
  15 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
  16 import org.opendaylight.transportpce.common.mapping.MappingUtils;
  17 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.interfaces.grp.InterfaceBuilder;
  18 import org.slf4j.Logger;
  19 import org.slf4j.LoggerFactory;
  20
  21
  22 public class OpenRoadmInterfacesImpl implements OpenRoadmInterfaces {
  23
  24     private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmInterfacesImpl.class);
  25
  26     private final DeviceTransactionManager deviceTransactionManager;
  27     OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
  28     OpenRoadmInterfacesImpl22 openRoadmInterfacesImpl22;
  29     MappingUtils mappingUtils;
  30
  31     // TODO move somewhere to constants
  32     public static final String NETWORK_TOKEN = "NETWORK";
  33     public static final String TTP_TOKEN = "TTP";
  34     public static final String CLIENT_TOKEN = "CLIENT";
  35     public static final String PP_TOKEN = "PP";
  36
  37
  38     public OpenRoadmInterfacesImpl(DeviceTransactionManager deviceTransactionManager,MappingUtils mappingUtils,
  39         OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121,OpenRoadmInterfacesImpl22 openRoadmInterfacesImpl22) {
  40         this.deviceTransactionManager = deviceTransactionManager;
  41         this.mappingUtils = mappingUtils;
  42         this.openRoadmInterfacesImpl121 = openRoadmInterfacesImpl121;
  43         this.openRoadmInterfacesImpl22 = openRoadmInterfacesImpl22;
  44     }
  45
  46     @Override
  47     public <T> void postInterface(String nodeId, T ifBuilder) throws OpenRoadmInterfaceException {
  48
  49         String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
  50         LOG.info("Interface post request received for node {} with version {}",nodeId,openRoadmVersion);
  51         if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
  52             LOG.info("Device Version is 1.2.1");
  53             InterfaceBuilder ifBuilder121 = convertInstanceOfInterface(ifBuilder, InterfaceBuilder.class);
  54             openRoadmInterfacesImpl121.postInterface(nodeId,ifBuilder121);
  55         }
  56         else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2)) {
  57             org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev171215.interfaces.grp.InterfaceBuilder
  58                 ifBuilder22 = convertInstanceOfInterface(ifBuilder, org.opendaylight.yang.gen.v1.http.org.openroadm
  59                 .device.rev171215.interfaces.grp.InterfaceBuilder.class);
  60             openRoadmInterfacesImpl22.postInterface(nodeId,ifBuilder22);
  61         }
  62     }
  63
  64     @Override
  65     public <T> Optional<T>  getInterface(String nodeId, String interfaceName) throws OpenRoadmInterfaceException {
  66
  67         String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
  68         LOG.info("Interface get request received for node {} with version {}",nodeId,openRoadmVersion);
  69         if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
  70             LOG.info("Device Version is 1.2.1");
  71             return (Optional<T>) openRoadmInterfacesImpl121.getInterface(nodeId,interfaceName);
  72         }
  73         else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2)) {
  74             return (Optional<T>) openRoadmInterfacesImpl22.getInterface(nodeId,interfaceName);
  75         }
  76         return null;
  77     }
  78
  79     @Override
  80     public void deleteInterface(String nodeId, String interfaceName)
  81         throws OpenRoadmInterfaceException {
  82
  83         String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
  84         LOG.info("Interface delete request received for node {} with version {}",nodeId,openRoadmVersion);
  85         if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
  86             LOG.info("Device Version is 1.2.1");
  87             openRoadmInterfacesImpl121.deleteInterface(nodeId,interfaceName);
  88         }
  89         else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2)) {
  90             openRoadmInterfacesImpl22.deleteInterface(nodeId,interfaceName);
  91         }
  92     }
  93
  94     @Override
  95     public void postEquipmentState(String nodeId, String circuitPackName, boolean activate)
  96         throws OpenRoadmInterfaceException {
  97         String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
  98
  99         LOG.info("Interface delete request received for node {} with version {}",nodeId,openRoadmVersion);
 100         if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
 101             LOG.info("Device Version is 1.2.1");
 102             openRoadmInterfacesImpl121.postEquipmentState(nodeId, circuitPackName, activate);
 103         }
 104         else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2)) {
 105             openRoadmInterfacesImpl22.postEquipmentState(nodeId, circuitPackName, activate);
 106         }
 107
 108     }
 109
 110     private <T> T convertInstanceOfInterface(Object object, Class<T> classToCast) {
 111         try {
 112             return classToCast.cast(object);
 113         } catch (ClassCastException e) {
 114             return null;
 115         }
 116     }
 117 }