[ONOS-4879][ONOS-5024][ONOS-5025]TE Topology NBI
The APP introduces IETF TE Topology YANG models as RESTCONF NBI,
and it works as an adapter for data conversion between
YMS(YANG generated JAVA classes) and TE Topology Core subsystem.
The APP implements the following interfaces:
IetfNetworkService Interface
IetfTopologyService Interface
IetfNetworkTopologyService Interface
Change-Id: I761ff684bde4b64ca42bb1b0d5b1ddfb8a2377fd
diff --git a/apps/tenbi/utils/src/main/java/org/onosproject/teyang/utils/topology/NodeConverter.java b/apps/tenbi/utils/src/main/java/org/onosproject/teyang/utils/topology/NodeConverter.java
new file mode 100644
index 0000000..0af2b13
--- /dev/null
+++ b/apps/tenbi/utils/src/main/java/org/onosproject/teyang/utils/topology/NodeConverter.java
@@ -0,0 +1,567 @@
+/*
+ * Copyright 2016 Open Networking Laboratory
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onosproject.teyang.utils.topology;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import java.util.List;
+
+import org.onosproject.tetopology.management.api.KeyId;
+import org.onosproject.tetopology.management.api.node.InterfaceSwitchingCapability;
+import org.onosproject.tetopology.management.api.node.NetworkNodeKey;
+import org.onosproject.tetopology.management.api.node.TeNetworkTopologyId;
+import org.onosproject.tetopology.management.api.node.TeNode;
+import org.onosproject.tetopology.management.api.node.TerminationCapability;
+import org.onosproject.tetopology.management.api.node.TerminationPoint;
+import org.onosproject.tetopology.management.api.node.TerminationPointKey;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev20130715.ietfinettypes.DomainName;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208.ietfnetwork.NetworkId;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208.ietfnetwork.NodeId;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208
+ .ietfnetwork.networks.network.DefaultNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208
+ .ietfnetwork.networks.network.Node;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208
+ .ietfnetwork.networks.network.node.DefaultSupportingNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev20151208
+ .ietfnetwork.networks.network.node.SupportingNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev20151208
+ .ietfnetworktopology.TpId;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev20151208
+ .ietfnetworktopology.networks.network.node.AugmentedNdNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev20151208
+ .ietfnetworktopology.networks.network.node.DefaultAugmentedNdNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.AugmentedNwNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.DefaultAugmentedNwNode;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.DefaultTe;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.DefaultTe.TeBuilder;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.Te;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.Config;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.DefaultConfig;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.DefaultState;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.DefaultTunnelTerminationPoint;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.State;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.TunnelTerminationPoint;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.DefaultTeNodeAttributes;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.TeNodeAttributes;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes.ConnectivityMatrix;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes
+ .DefaultConnectivityMatrix;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes.DefaultUnderlayTopology;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes.UnderlayTopology;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes
+ .connectivitymatrix.DefaultFrom;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.config.tenodeattributes
+ .connectivitymatrix.DefaultTo;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint
+ .config.DefaultTerminationCapability;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.types.rev20160705.ietftetypes.TeNodeId;
+import org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.types.rev20160705.ietftetypes.TeTopologyId;
+
+import com.google.common.collect.Lists;
+
+/**
+ * Node conversion functions.
+ */
+public final class NodeConverter {
+
+ private static final String E_NULL_TE_SUBSYSTEM_TE_NODE = "TeSubsystem teNode object cannot be null";
+ private static final String E_NULL_TE_SUBSYSTEM_TE_TUNNEL_TP = "TeSubsystem teTunnelTp object cannot be null";
+ private static final String E_NULL_TE_SUBSYSTEM_NODE = "TeSubsystem ndoe object cannot be null";
+ private static final String E_NULL_YANG_NODE = "Yang node object cannot be null";
+
+ // no instantiation
+ private NodeConverter() {
+ }
+
+ /**
+ * TE Node Config object conversion from TE Topology subsystem to YANG.
+ *
+ * @param teSubsystemTeNode TE node object
+ * @return TE Node Config YANG object
+ */
+ private static Config teNode2YangConfig(TeNode teSubsystemTeNode) {
+ checkNotNull(teSubsystemTeNode, E_NULL_TE_SUBSYSTEM_TE_NODE);
+
+ TeNodeAttributes.TeNodeAttributesBuilder teNodeAttributesConfigBuilder =
+ DefaultTeNodeAttributes.builder()
+ .isAbstract(teSubsystemTeNode.isAbstract());
+ if (teSubsystemTeNode.adminStatus() != null) {
+ teNodeAttributesConfigBuilder = teNodeAttributesConfigBuilder
+ .adminStatus(EnumConverter
+ .teSubsystem2YangAdminStatus(teSubsystemTeNode
+ .adminStatus()));
+ }
+
+ if (teSubsystemTeNode.name() != null) {
+ teNodeAttributesConfigBuilder = teNodeAttributesConfigBuilder
+ .name(DomainName.fromString(teSubsystemTeNode.name()));
+ }
+
+ if (teSubsystemTeNode.underlayTopology() != null) {
+ teNodeAttributesConfigBuilder = teNodeAttributesConfigBuilder
+ .underlayTopology(teNode2YangUnderlayConfig(teSubsystemTeNode.underlayTopology()));
+ }
+
+ if (teSubsystemTeNode.connectivityMatrices() != null) {
+ ConnectivityMatrix.ConnectivityMatrixBuilder connectivityMatrixConfigBuilder =
+ DefaultConnectivityMatrix.builder();
+ for (org.onosproject.tetopology.management.api.node.ConnectivityMatrix teCm : teSubsystemTeNode.
+ connectivityMatrices()) {
+ connectivityMatrixConfigBuilder = connectivityMatrixConfigBuilder
+ .id(teCm.id())
+ .isAllowed(teCm.isAllowed())
+ .from(new DefaultFrom.FromBuilder()
+ .tpRef(TpId.fromString(teCm.from().tpId()
+ .toString()))
+ .build())
+ .to(new DefaultTo.ToBuilder()
+ .tpRef(TpId.fromString(teCm.to().tpId()
+ .toString()))
+ .build());
+ teNodeAttributesConfigBuilder = teNodeAttributesConfigBuilder
+ .addToConnectivityMatrix(connectivityMatrixConfigBuilder
+ .build());
+ }
+ }
+
+
+ Config.ConfigBuilder yangConfigBuilder = DefaultConfig.builder();
+ yangConfigBuilder = yangConfigBuilder.teNodeAttributes(teNodeAttributesConfigBuilder.build());
+
+ return yangConfigBuilder.build();
+ }
+
+ private static UnderlayTopology teNode2YangUnderlayConfig(TeNetworkTopologyId underlayTopology) {
+ UnderlayTopology.UnderlayTopologyBuilder underlayConfigBuilder = DefaultUnderlayTopology
+ .builder()
+ .networkIdRef(NetworkId.fromString(underlayTopology.getNetworkId().toString()))
+ .teTopologyIdRef(TeTopologyId
+ .fromString(underlayTopology
+ .getTopologyId().topologyId()));
+ return underlayConfigBuilder.build();
+ }
+
+ /**
+ * TE Node State object conversion from TE Topology subsystem to YANG.
+ *
+ * @param teSubsystemTeNode TE node object
+ * @return TE Node State YANG object
+ */
+ private static State teNode2YangState(TeNode teSubsystemTeNode) {
+ checkNotNull(teSubsystemTeNode, E_NULL_TE_SUBSYSTEM_TE_NODE);
+
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708.ietftetopology
+ .networks.network.node.augmentednwnode.te.state.TeNodeAttributes
+ .TeNodeAttributesBuilder teNodeAttributesStateBuilder =
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708.ietftetopology
+ .networks.network.node.augmentednwnode.te.state.DefaultTeNodeAttributes.builder()
+ .isAbstract(teSubsystemTeNode.isAbstract());
+
+ if (teSubsystemTeNode.adminStatus() != null) {
+ teNodeAttributesStateBuilder = teNodeAttributesStateBuilder
+ .adminStatus(EnumConverter
+ .teSubsystem2YangAdminStatus(teSubsystemTeNode
+ .adminStatus()));
+ }
+
+ if (teSubsystemTeNode.name() != null) {
+ teNodeAttributesStateBuilder = teNodeAttributesStateBuilder
+ .name(DomainName.fromString(teSubsystemTeNode.name()));
+ }
+
+ if (teSubsystemTeNode.underlayTopology() != null) {
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708.ietftetopology
+ .networks.network.node.augmentednwnode.te.state.tenodeattributes.UnderlayTopology.
+ UnderlayTopologyBuilder underlayStateBuilder =
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708.ietftetopology
+ .networks.network.node.augmentednwnode.te.state.tenodeattributes.DefaultUnderlayTopology
+ .builder();
+ underlayStateBuilder = underlayStateBuilder
+ .networkIdRef(NetworkId.fromString(teSubsystemTeNode
+ .underlayTopology().getNetworkId().toString()))
+ .teTopologyIdRef(TeTopologyId.fromString(teSubsystemTeNode
+ .underlayTopology().getTopologyId().topologyId()));
+ teNodeAttributesStateBuilder = teNodeAttributesStateBuilder
+ .underlayTopology(underlayStateBuilder.build());
+ }
+
+ if (teSubsystemTeNode.connectivityMatrices() != null) {
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708.ietftetopology
+ .networks.network.node.augmentednwnode.te.state.tenodeattributes.ConnectivityMatrix
+ .ConnectivityMatrixBuilder
+ connectivityMatrixStateBuilder = org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
+ .te.topology.rev20160708.ietftetopology.networks.network.node.augmentednwnode
+ .te.state.tenodeattributes.DefaultConnectivityMatrix
+ .builder();
+ for (org.onosproject.tetopology.management.api.node.ConnectivityMatrix teCm : teSubsystemTeNode
+ .connectivityMatrices()) {
+ connectivityMatrixStateBuilder = connectivityMatrixStateBuilder
+ .id(teCm.id())
+ .isAllowed(teCm.isAllowed())
+ .from(new org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology
+ .rev20160708.ietftetopology.networks.network.node.augmentednwnode.te.state
+ .tenodeattributes.connectivitymatrix.DefaultFrom.FromBuilder()
+ .tpRef(TpId.fromString(teCm.from().tpId()
+ .toString()))
+ .build())
+ .to(new org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology
+ .rev20160708.ietftetopology.networks.network.node.augmentednwnode.te.state
+ .tenodeattributes.connectivitymatrix.DefaultTo.ToBuilder()
+ .tpRef(TpId.fromString(teCm.to().tpId()
+ .toString()))
+ .build());
+ teNodeAttributesStateBuilder = teNodeAttributesStateBuilder
+ .addToConnectivityMatrix(connectivityMatrixStateBuilder
+ .build());
+ }
+ }
+
+ State.StateBuilder yangStateBuilder = DefaultState.builder();
+ yangStateBuilder = yangStateBuilder.teNodeAttributes(teNodeAttributesStateBuilder.build());
+
+ if (teSubsystemTeNode.opStatus() != null) {
+ yangStateBuilder = yangStateBuilder.operStatus(EnumConverter
+ .teSubsystem2YangOperStatus(teSubsystemTeNode
+ .opStatus()));
+ }
+
+ return yangStateBuilder.build();
+ }
+
+ /**
+ * TE Node TunnelTerminationPoint object conversion from TE Topology subsystem to YANG.
+ *
+ * @param teTunnelTp TE TunnelTerminationPoint object
+ * @return TunnelTerminationPoint YANG object
+ */
+ private static TunnelTerminationPoint teSubsystem2YangTtp(
+ org.onosproject.tetopology.management.api.node.TunnelTerminationPoint teTunnelTp) {
+ checkNotNull(teTunnelTp, E_NULL_TE_SUBSYSTEM_TE_TUNNEL_TP);
+
+ TunnelTerminationPoint.TunnelTerminationPointBuilder tunnelTpBuilder =
+ DefaultTunnelTerminationPoint.builder().tunnelTpId(teTunnelTp.getTunnelTpId());
+
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint
+ .Config.ConfigBuilder ttpConfigBuilder =
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint
+ .DefaultConfig.builder();
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint
+ .State.StateBuilder ttpStateBuilder =
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint
+ .DefaultState.builder();
+
+ if (Long.valueOf(teTunnelTp.getInterLayerLockId()) != null) {
+ ttpConfigBuilder = ttpConfigBuilder.interLayerLockId(teTunnelTp.getInterLayerLockId());
+ ttpStateBuilder = ttpStateBuilder.interLayerLockId(teTunnelTp.getInterLayerLockId());
+ }
+
+ if (teTunnelTp.getSwitchingCapabilities() != null) {
+ // FIXME: switchingCapabilities is a list in
+ // teSubsystem, but is not a list in yang. how to handle
+ // this?
+ for (InterfaceSwitchingCapability iscTe : teTunnelTp.getSwitchingCapabilities()) {
+ // ttpConfigBuilder =
+ // ttpConfigBuilder.switchingCapability(switchingCapability)
+ // ttpStateBuilder =
+ // ttpStateBuilder.switchingCapability(switchingCapability)
+ }
+ }
+
+ if (teTunnelTp.getTerminationCapabilities() != null) {
+ for (TerminationCapability tcap : teTunnelTp.getTerminationCapabilities()) {
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint.config
+ .TerminationCapability.TerminationCapabilityBuilder
+ tcapConfigBuilder = DefaultTerminationCapability.builder();
+ // FIXME: at this moment, tcap does not have any getter or setter.
+ // add the following getLinkTpId possibly other attributes to Core data structure
+ // tcapConfigBuilder =
+ // tcapConfigBuilder.linkTp(TpId.fromString(tcap.getLinkTpId.toString()));
+ ttpConfigBuilder = ttpConfigBuilder.addToTerminationCapability(tcapConfigBuilder.build());
+
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint.state
+ .TerminationCapability.TerminationCapabilityBuilder tcapStateBuilder =
+ org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.te.topology.rev20160708
+ .ietftetopology.networks.network.node.augmentednwnode.te.tunnelterminationpoint.state
+ .DefaultTerminationCapability.builder();
+ // FIXME: at this moment, tcap does not have any getter or setter.
+ // add the following getLinkTpId possibly other attributes to Core data structure
+ // tcapConfigBuilder =
+ // tcapConfigBuilder.linkTp(TpId.fromString(tcap.getLinkTpId.toString()));
+ ttpStateBuilder = ttpStateBuilder.addToTerminationCapability(tcapStateBuilder.build());
+ }
+ }
+
+ tunnelTpBuilder = tunnelTpBuilder.config(ttpConfigBuilder.build())
+ .state(ttpStateBuilder.build());
+
+ return tunnelTpBuilder.build();
+ }
+
+ /**
+ * Node object conversion from TE Topology subsystem to YANG.
+ *
+ * @param teSubsystem TE subsystem node object
+ * @return YANG node object
+ */
+ public static Node teSubsystem2YangNode(org.onosproject.tetopology.management.api.node.NetworkNode teSubsystem) {
+ checkNotNull(teSubsystem, E_NULL_TE_SUBSYSTEM_NODE);
+
+ NodeId nodeId = NodeId.fromString(teSubsystem.nodeId().toString());
+ Node.NodeBuilder builder = DefaultNode.builder().nodeId(nodeId);
+
+ if (teSubsystem.getSupportingNodeIds() != null) {
+ List<SupportingNode> sNodes = Lists.newArrayList();
+ SupportingNode.SupportingNodeBuilder spNodeBuilder = DefaultSupportingNode
+ .builder();
+ for (NetworkNodeKey nodeKey : teSubsystem.getSupportingNodeIds()) {
+ sNodes.add(spNodeBuilder
+ .networkRef(NetworkId
+ .fromString(nodeKey.networkId().toString()))
+ .nodeRef(NodeId.fromString(nodeKey.nodeId().toString()))
+ .build());
+ }
+ builder = builder.supportingNode(sNodes);
+ }
+
+ if (teSubsystem.getTerminationPoints() != null) {
+ AugmentedNdNode.AugmentedNdNodeBuilder tpAugmentBuilder = DefaultAugmentedNdNode
+ .builder();
+ List<TerminationPoint> teSubsystemTeTp = teSubsystem
+ .getTerminationPoints();
+ for (TerminationPoint teTp : teSubsystemTeTp) {
+ tpAugmentBuilder.addToTerminationPoint(TerminationPointConverter
+ .teSubsystem2YangTerminationPoint(teTp));
+ }
+ builder.addYangAugmentedInfo(tpAugmentBuilder.build(),
+ AugmentedNdNode.class);
+ }
+
+ if (teSubsystem.getTe() != null) {
+ AugmentedNwNode.AugmentedNwNodeBuilder nodeAugmentBuilder = DefaultAugmentedNwNode
+ .builder();
+
+ TeNode teSubsystemTeNode = teSubsystem.getTe();
+
+ TeBuilder yangTeBuilder = DefaultTe.builder();
+
+ if (teSubsystemTeNode.teNodeId() != null) {
+ yangTeBuilder = yangTeBuilder.teNodeId(TeNodeId
+ .fromString(teSubsystemTeNode.teNodeId().toString()));
+ }
+
+ // Set configuration data
+ // Set state data
+ yangTeBuilder = yangTeBuilder.config(teNode2YangConfig(teSubsystemTeNode))
+ .state(teNode2YangState(teSubsystemTeNode));
+
+ if (teSubsystemTeNode.tunnelTerminationPoints() != null) {
+ for (org.onosproject.tetopology.management.api.node.TunnelTerminationPoint
+ teTunnelTp : teSubsystemTeNode.tunnelTerminationPoints()) {
+ yangTeBuilder = yangTeBuilder.addToTunnelTerminationPoint(teSubsystem2YangTtp(teTunnelTp));
+ }
+ }
+
+ nodeAugmentBuilder = nodeAugmentBuilder.te(yangTeBuilder.build());
+ builder.addYangAugmentedInfo(nodeAugmentBuilder.build(),
+ AugmentedNwNode.class);
+ }
+ return builder.build();
+ }
+
+ /**
+ * Node object conversion from YANG to TE Topology subsystem.
+ *
+ * @param yangNode YANG node object
+ * @param yangNetworkId YANG networkId object
+ * @return TE subsystem node object
+ */
+ public static org.onosproject.tetopology.management.api.node.NetworkNode
+ yang2TeSubsystemNode(Node yangNode, NetworkId yangNetworkId) {
+ checkNotNull(yangNode, E_NULL_YANG_NODE);
+
+ org.onosproject.tetopology.management.api.node.DefaultNetworkNode node =
+ new org.onosproject.tetopology.management.api.node.DefaultNetworkNode(
+ KeyId.keyId(yangNode.nodeId().uri().string()));
+
+ if (yangNode.supportingNode() != null) {
+ List<NetworkNodeKey> spNodes = Lists.newArrayList();
+ for (SupportingNode yangSpNode : yangNode.supportingNode()) {
+ NetworkNodeKey nodeKey = new NetworkNodeKey(KeyId.keyId(yangSpNode.nodeRef().uri().toString()),
+ KeyId.keyId(yangSpNode.networkRef().uri().toString()));
+ spNodes.add(nodeKey);
+ }
+ node.setSupportingNodeIds(spNodes);
+ }
+
+ if (yangNode.yangAugmentedInfoMap() != null
+ && !yangNode.yangAugmentedInfoMap().isEmpty()) {
+
+ AugmentedNdNode yangTpNodeAugment = (AugmentedNdNode) yangNode
+ .yangAugmentedInfo(AugmentedNdNode.class);
+ if (yang2TeSubsystemTpNodeAugment(yangTpNodeAugment) != null) {
+ node.setTerminationPoints(yang2TeSubsystemTpNodeAugment(yangTpNodeAugment));
+ }
+
+ AugmentedNwNode yangNodeAugment = (AugmentedNwNode) yangNode
+ .yangAugmentedInfo(AugmentedNwNode.class);
+ if (yangNodeAugment != null && yangNodeAugment.te() != null && yangNodeAugment.te().teNodeId() != null) {
+ Te yangNodeAugTe = yangNodeAugment.te();
+ TeNode teNode = yang2TeSubsystemNodeAugment(yangNodeAugTe, yangNetworkId, yangNode.nodeId());
+ node.setTe(teNode);
+ }
+ }
+
+ return node;
+ }
+
+ private static TeNode yang2TeSubsystemNodeConnectivityMatrix(TeNode teNode,
+ String networkId, String nodeId, List<ConnectivityMatrix> yangMatrix) {
+ List<org.onosproject.tetopology.management.api.node.ConnectivityMatrix> teCmList =
+ Lists.newArrayList();
+ for (ConnectivityMatrix cmYang : yangMatrix) {
+ Long id = cmYang.id();
+ TerminationPointKey from = new TerminationPointKey(
+ KeyId.keyId(networkId),
+ KeyId.keyId(nodeId),
+ KeyId.keyId(cmYang.from().tpRef().uri().toString()));
+ TerminationPointKey to = new TerminationPointKey(
+ KeyId.keyId(networkId),
+ KeyId.keyId(nodeId),
+ KeyId.keyId(cmYang.to().tpRef().uri().toString()));
+ boolean isAllowed = cmYang.isAllowed();
+ org.onosproject.tetopology.management.api.node.ConnectivityMatrix cmTe =
+ new org.onosproject.tetopology.management.api.node.ConnectivityMatrix(
+ id, from, to, isAllowed);
+ teCmList.add(cmTe);
+ }
+ teNode.setConnectivityMatrices(teCmList);
+ return teNode;
+ }
+
+ private static TeNode yang2TeSubsystemNodeUnderlayTopology(TeNode teNode,
+ UnderlayTopology ut) {
+ TeNetworkTopologyId underlayTopology =
+ new TeNetworkTopologyId(KeyId.keyId(ut.networkIdRef().uri().toString()),
+ new org.onosproject.tetopology.management.api.TeTopologyId(
+ ut.providerIdRef().uint32(),
+ ut.clientIdRef().uint32(),
+ ut.teTopologyIdRef().toString()));
+ teNode.setUnderlayTopology(underlayTopology);
+ return teNode;
+ }
+
+ private static TeNode yang2TeSubsystemTtp(TeNode teNode,
+ List<TunnelTerminationPoint> ttps) {
+ List<org.onosproject.tetopology.management.api.node.TunnelTerminationPoint> ttpTeList =
+ Lists.newArrayList();
+ for (TunnelTerminationPoint ttpYang : ttps) {
+ org.onosproject.tetopology.management.api.node.TunnelTerminationPoint ttpTe =
+ new org.onosproject.tetopology.management.api.node.TunnelTerminationPoint(
+ ttpYang.tunnelTpId());
+ ttpTe.setInterLayerLockId(ttpYang.config().interLayerLockId());
+ // FIXME: go through
+ // ttpYang.config().switchingCapability() and populate
+ // ttpTe.setSwitchingCapabilities(switchingCapabilities);
+ // FIXME: go through
+ // ttpYang.config().terminationCapability() and populate
+ // ttpTe.setTerminationCapability(terminationCapability);
+ ttpTeList.add(ttpTe);
+ }
+ teNode.setTunnelTerminationPoints(ttpTeList);
+
+ return teNode;
+ }
+
+ private static TeNode yang2TeSubsystemNodeAugment(Te yangNodeAugTe,
+ NetworkId yangNetworkId, NodeId yangNodeId) {
+ TeNode teNode = new TeNode(yangNodeAugTe.teNodeId().toString());
+ Config ynodeAugCfg = yangNodeAugTe.config();
+ if (ynodeAugCfg != null) {
+ TeNodeAttributes teNodeAttr = ynodeAugCfg.teNodeAttributes();
+ if (teNodeAttr != null) {
+ teNode.setAbstract(teNodeAttr.isAbstract());
+
+ if (teNodeAttr.adminStatus() != null) {
+ teNode.setAdminStatus(EnumConverter.yang2TeSubsystemAdminStatus(
+ ynodeAugCfg.teNodeAttributes().adminStatus()));
+ }
+
+ if (yangNodeAugTe.state() != null &&
+ yangNodeAugTe.state().operStatus() != null) {
+ teNode.setOpStatus(EnumConverter.yang2TeSubsystemOpStatus(
+ yangNodeAugTe.state().operStatus()));
+ }
+
+ if (teNodeAttr.connectivityMatrix() != null) {
+ teNode = yang2TeSubsystemNodeConnectivityMatrix(teNode,
+ yangNetworkId.uri().toString(),
+ yangNodeId.uri().toString(),
+ teNodeAttr.connectivityMatrix());
+ }
+
+ if (teNodeAttr.underlayTopology() != null) {
+ teNode = yang2TeSubsystemNodeUnderlayTopology(teNode,
+ teNodeAttr.underlayTopology());
+ }
+ }
+ }
+
+ if (yangNodeAugTe.tunnelTerminationPoint() != null) {
+ teNode = yang2TeSubsystemTtp(teNode, yangNodeAugTe.tunnelTerminationPoint());
+ }
+ return teNode;
+ }
+
+ private static List<TerminationPoint> yang2TeSubsystemTpNodeAugment(AugmentedNdNode yangTpNodeAugment) {
+ if (yangTpNodeAugment.terminationPoint() != null) {
+ List<TerminationPoint> teTpList = Lists.newArrayList();
+ for (org.onosproject.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
+ .rev20151208.ietfnetworktopology.networks.network.node.augmentedndnode.TerminationPoint
+ yangTpnode : yangTpNodeAugment.terminationPoint()) {
+ teTpList.add(TerminationPointConverter.yang2teSubsystemTerminationPoint(yangTpnode));
+ }
+ return teTpList;
+ }
+ return null;
+ }
+}