import static org.opendaylight.transportpce.common.StringConstants.OPENROADM_DEVICE_VERSION_1_2_1;
import static org.opendaylight.transportpce.common.StringConstants.OPENROADM_DEVICE_VERSION_2_2_1;
+import static org.opendaylight.transportpce.common.StringConstants.OPENROADM_DEVICE_VERSION_7_1;
import java.util.Optional;
import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
import org.opendaylight.transportpce.common.mapping.MappingUtils;
+import org.opendaylight.transportpce.common.mapping.PortMapping;
import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.interfaces.grp.InterfaceBuilder;
+import org.osgi.service.component.annotations.Activate;
+import org.osgi.service.component.annotations.Component;
+import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
+@Component
public class OpenRoadmInterfacesImpl implements OpenRoadmInterfaces {
private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmInterfacesImpl.class);
- private final DeviceTransactionManager deviceTransactionManager;
OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
+ OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
MappingUtils mappingUtils;
+ @Activate
+ public OpenRoadmInterfacesImpl(@Reference DeviceTransactionManager deviceTransactionManager,
+ @Reference MappingUtils mappingUtils, @Reference PortMapping portMapping) {
+ this(deviceTransactionManager, mappingUtils,
+ new OpenRoadmInterfacesImpl121(deviceTransactionManager),
+ new OpenRoadmInterfacesImpl221(deviceTransactionManager, portMapping),
+ new OpenRoadmInterfacesImpl710(deviceTransactionManager, portMapping));
+ }
+
public OpenRoadmInterfacesImpl(DeviceTransactionManager deviceTransactionManager, MappingUtils mappingUtils,
OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121,
- OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221) {
- this.deviceTransactionManager = deviceTransactionManager;
+ OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221,
+ OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710) {
this.mappingUtils = mappingUtils;
this.openRoadmInterfacesImpl121 = openRoadmInterfacesImpl121;
this.openRoadmInterfacesImpl221 = openRoadmInterfacesImpl221;
+ this.openRoadmInterfacesImpl710 = openRoadmInterfacesImpl710;
}
@Override
public <T> void postInterface(String nodeId, T ifBuilder) throws OpenRoadmInterfaceException {
- String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
- LOG.info("Interface post request received for node {} with version {}",nodeId,openRoadmVersion);
- if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
- LOG.info("Device Version is 1.2.1");
- InterfaceBuilder ifBuilder121 = convertInstanceOfInterface(ifBuilder, InterfaceBuilder.class);
- openRoadmInterfacesImpl121.postInterface(nodeId,ifBuilder121);
- }
- else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2_1)) {
- org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.interfaces.grp.InterfaceBuilder
- ifBuilder22 = convertInstanceOfInterface(ifBuilder, org.opendaylight.yang.gen.v1.http.org.openroadm
- .device.rev181019.interfaces.grp.InterfaceBuilder.class);
- openRoadmInterfacesImpl221.postInterface(nodeId,ifBuilder22);
+ switch (mappingUtils.getOpenRoadmVersion(nodeId)) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ LOG.info("postInterface for 1.2.1 device {}", nodeId);
+ InterfaceBuilder ifBuilder121 = convertInstanceOfInterface(ifBuilder, InterfaceBuilder.class);
+ openRoadmInterfacesImpl121.postInterface(nodeId,ifBuilder121);
+ return;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ LOG.info("postInterface for 2.2.1 device {}", nodeId);
+ org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.interfaces.grp.InterfaceBuilder
+ ifBuilder22 = convertInstanceOfInterface(ifBuilder, org.opendaylight.yang.gen.v1
+ .http.org.openroadm.device.rev181019.interfaces.grp.InterfaceBuilder.class);
+ openRoadmInterfacesImpl221.postInterface(nodeId,ifBuilder22);
+ return;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ LOG.info("postInterface for 7.1.0 device {}", nodeId);
+ org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.interfaces.grp.InterfaceBuilder
+ ifBuilder71 = convertInstanceOfInterface(ifBuilder, org.opendaylight.yang.gen.v1
+ .http.org.openroadm.device.rev200529.interfaces.grp.InterfaceBuilder.class);
+ openRoadmInterfacesImpl710.postInterface(nodeId, ifBuilder71);
+ return;
+ default:
+ LOG.error("postInterface unknown ordm version error device {}", nodeId);
+ return;
}
}
@Override
+ @SuppressWarnings("unchecked")
public <T> Optional<T> getInterface(String nodeId, String interfaceName) throws OpenRoadmInterfaceException {
String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
- LOG.info("Interface get request received for node {} with version {}",nodeId,openRoadmVersion);
- if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
- LOG.info("Device Version is 1.2.1");
- return (Optional<T>) openRoadmInterfacesImpl121.getInterface(nodeId,interfaceName);
- }
- else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2_1)) {
- return (Optional<T>) openRoadmInterfacesImpl221.getInterface(nodeId,interfaceName);
+ LOG.info("Interface get request received for node {} with version {}", nodeId, openRoadmVersion);
+ switch (openRoadmVersion) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ return (Optional<T>) openRoadmInterfacesImpl121.getInterface(nodeId,interfaceName);
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ return (Optional<T>) openRoadmInterfacesImpl221.getInterface(nodeId,interfaceName);
+ case OPENROADM_DEVICE_VERSION_7_1:
+ return (Optional<T>) openRoadmInterfacesImpl710.getInterface(nodeId,interfaceName);
+ default:
+ LOG.error("getInterface unknown ordm version error device {}", nodeId);
+ return Optional.empty();
}
- return null;
}
@Override
throws OpenRoadmInterfaceException {
String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
- LOG.info("Interface delete request received for node {} with version {}",nodeId,openRoadmVersion);
- if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
- LOG.info("Device Version is 1.2.1");
- openRoadmInterfacesImpl121.deleteInterface(nodeId,interfaceName);
- }
- else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2_1)) {
- openRoadmInterfacesImpl221.deleteInterface(nodeId,interfaceName);
+ LOG.info("Interface delete request received for node {} with version {}", nodeId, openRoadmVersion);
+ switch (openRoadmVersion) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ openRoadmInterfacesImpl121.deleteInterface(nodeId,interfaceName);
+ return;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ openRoadmInterfacesImpl221.deleteInterface(nodeId,interfaceName);
+ return;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ openRoadmInterfacesImpl710.deleteInterface(nodeId,interfaceName);
+ return;
+ default:
+ LOG.error("deleteInterface unknown ordm version error device {}", nodeId);
+ return;
}
}
@Override
public void postEquipmentState(String nodeId, String circuitPackName, boolean activate)
throws OpenRoadmInterfaceException {
- String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
- LOG.info("Interface delete request received for node {} with version {}",nodeId,openRoadmVersion);
- if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_1_2_1)) {
- LOG.info("Device Version is 1.2.1");
- openRoadmInterfacesImpl121.postEquipmentState(nodeId, circuitPackName, activate);
+ String openRoadmVersion = mappingUtils.getOpenRoadmVersion(nodeId);
+ LOG.info("Request received for node {} with version {} to change equipment-state of cp {}.",
+ nodeId,openRoadmVersion, circuitPackName);
+ switch (openRoadmVersion) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ openRoadmInterfacesImpl121.postEquipmentState(nodeId, circuitPackName, activate);
+ return;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ openRoadmInterfacesImpl221.postEquipmentState(nodeId, circuitPackName, activate);
+ return;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ openRoadmInterfacesImpl710.postEquipmentState(nodeId, circuitPackName, activate);
+ return;
+ default:
+ LOG.error("postEquipmentState unknown ordm version error device {}", nodeId);
+ return;
}
- else if (openRoadmVersion.equals(OPENROADM_DEVICE_VERSION_2_2_1)) {
- openRoadmInterfacesImpl221.postEquipmentState(nodeId, circuitPackName, activate);
+ }
+
+ @Override
+ public <T> void postOTNInterface(String nodeId, T ifBuilder)
+ throws OpenRoadmInterfaceException {
+
+ switch (mappingUtils.getOpenRoadmVersion(nodeId)) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ LOG.error("postOTNInterface unsupported ordm version 1.2.1 error device {}", nodeId);
+ return;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.interfaces.grp.InterfaceBuilder
+ ifBuilder22 = (org.opendaylight.yang.gen.v1
+ .http.org.openroadm.device.rev181019.interfaces.grp.InterfaceBuilder) ifBuilder;
+ openRoadmInterfacesImpl221.postInterface(nodeId, ifBuilder22);
+ return;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev200529.interfaces.grp.InterfaceBuilder
+ ifBuilder71 = (org.opendaylight.yang.gen.v1
+ .http.org.openroadm.device.rev200529.interfaces.grp.InterfaceBuilder) ifBuilder;
+ openRoadmInterfacesImpl710.postInterface(nodeId, ifBuilder71);
+ return;
+ default:
+ LOG.error("postOTNInterface unknown ordm version error device {}", nodeId);
+ return;
}
+ }
+
+ @Override
+ public void postOTNEquipmentState(String nodeId, String circuitPackName, boolean activate)
+ throws OpenRoadmInterfaceException {
+ switch (mappingUtils.getOpenRoadmVersion(nodeId)) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ LOG.error("postOTNEquipmentState unsupported ordm version 1.2.1 error device {}", nodeId);
+ return;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ openRoadmInterfacesImpl221.postEquipmentState(nodeId, circuitPackName, activate);
+ return;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ openRoadmInterfacesImpl710.postEquipmentState(nodeId, circuitPackName, activate);
+ return;
+ default:
+ LOG.error("postOTNEquipmentState unknown ordm version error device {}", nodeId);
+ return;
+ }
}
private <T> T convertInstanceOfInterface(Object object, Class<T> classToCast) {
return null;
}
}
+
+ @Override
+ public String getSupportedInterface(String nodeId, String interfaceName) {
+ String supportedInterface = "";
+ switch (mappingUtils.getOpenRoadmVersion(nodeId)) {
+ case OPENROADM_DEVICE_VERSION_1_2_1:
+ supportedInterface = openRoadmInterfacesImpl121.getSupportedInterface(nodeId,interfaceName);
+ break;
+ case OPENROADM_DEVICE_VERSION_2_2_1:
+ supportedInterface = openRoadmInterfacesImpl221.getSupportedInterface(nodeId,interfaceName);
+ break;
+ case OPENROADM_DEVICE_VERSION_7_1:
+ supportedInterface = openRoadmInterfacesImpl710.getSupportedInterface(nodeId,interfaceName);
+ break;
+ default:
+ LOG.error("getSupportedInterface unknown ordm version error device {}", nodeId);
+ }
+ return supportedInterface;
+ }
+
}
Code Review / transportpce.git / blobdiff