2 * Copyright © 2019 Orange, Inc. and others. All rights reserved.
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
8 package org.opendaylight.transportpce.tapi.topology;
10 import java.nio.charset.Charset;
11 import java.util.ArrayList;
12 import java.util.Collection;
13 import java.util.Collections;
14 import java.util.HashMap;
15 import java.util.HashSet;
16 import java.util.Iterator;
17 import java.util.List;
19 import java.util.Map.Entry;
21 import java.util.UUID;
22 import java.util.stream.Collectors;
23 import org.opendaylight.transportpce.tapi.TapiStringConstants;
24 import org.opendaylight.transportpce.tapi.utils.TapiLink;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev201211.xpdr.odu.switching.pools.OduSwitchingPools;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev201211.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev201211.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev201211.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev201211.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListKey;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmNodeType;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmTpType;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.Node1;
38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
41 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.AdministrativeState;
42 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.ForwardingDirection;
43 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LAYERPROTOCOLQUALIFIER;
44 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LayerProtocolName;
45 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LifecycleState;
46 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.OperationalState;
47 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortDirection;
48 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortRole;
49 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationDirection;
50 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationState;
51 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Uuid;
52 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.Name;
53 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameBuilder;
54 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameKey;
55 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE100GigE;
56 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE10GigELAN;
57 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2;
58 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2E;
59 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU4;
60 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROMS;
61 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROTSi;
62 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.ForwardingRule;
63 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.RuleType;
64 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePoint;
65 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePointBuilder;
66 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.link.NodeEdgePointKey;
67 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroup;
68 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupBuilder;
69 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroupKey;
70 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePoint;
71 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointBuilder;
72 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointKey;
73 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePoint;
74 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePointBuilder;
75 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.edge.point.MappedServiceInterfacePointKey;
76 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.Rule;
77 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleBuilder;
78 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.RuleKey;
79 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link;
80 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.LinkBuilder;
81 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.LinkKey;
82 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeBuilder;
83 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey;
84 import org.opendaylight.yangtools.yang.common.Uint16;
85 import org.slf4j.Logger;
86 import org.slf4j.LoggerFactory;
89 public class ConvertORTopoToTapiTopo {
91 private static final Logger LOG = LoggerFactory.getLogger(ConvertORTopoToTapiTopo.class);
92 private String ietfNodeId;
93 private OpenroadmNodeType ietfNodeType;
94 private AdminStates ietfNodeAdminState;
95 private State ietfNodeOperState;
96 private List<TerminationPoint> oorClientPortList;
97 private List<TerminationPoint> oorNetworkPortList;
98 private OduSwitchingPools oorOduSwitchingPool;
99 private Uuid tapiTopoUuid;
100 private Map<NodeKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
102 private Map<LinkKey, Link> tapiLinks;
103 private Map<String, Uuid> uuidMap;
104 private final TapiLink tapiLink;
107 public ConvertORTopoToTapiTopo(Uuid tapiTopoUuid, TapiLink tapiLink) {
108 this.tapiTopoUuid = tapiTopoUuid;
109 this.tapiNodes = new HashMap<>();
110 this.tapiLinks = new HashMap<>();
111 this.uuidMap = new HashMap<>();
112 this.tapiLink = tapiLink;
115 public void convertNode(Node ietfNode, List<String> networkPorts) {
116 this.ietfNodeId = ietfNode.getNodeId().getValue();
117 if (ietfNode.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1.class)
121 this.ietfNodeType = ietfNode.augmentation(
122 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1.class).getNodeType();
123 this.ietfNodeAdminState = ietfNode.augmentation(
124 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1.class)
125 .getAdministrativeState();
126 this.ietfNodeOperState = ietfNode.augmentation(
127 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1.class)
128 .getOperationalState();
129 this.oorNetworkPortList = ietfNode.augmentation(
130 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
131 .getTerminationPoint().values().stream()
132 .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
133 == OpenroadmTpType.XPONDERNETWORK.getIntValue()
134 && networkPorts.contains(tp.getTpId().getValue()))
135 .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
136 .collect(Collectors.toList());
137 if (!OpenroadmNodeType.TPDR.equals(this.ietfNodeType)) {
138 this.oorOduSwitchingPool = ietfNode.augmentation(Node1.class).getSwitchingPools().getOduSwitchingPools()
139 .values().stream().findFirst().get();
140 this.oorClientPortList = ietfNode.augmentation(
141 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
142 .getTerminationPoint().values().stream()
143 .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
144 == OpenroadmTpType.XPONDERCLIENT.getIntValue())
145 .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
146 .collect(Collectors.toList());
148 this.oorOduSwitchingPool = createOduSwitchingPoolForTp100G();
149 List<TpId> tpList = this.oorOduSwitchingPool.getNonBlockingList().values().stream()
150 .flatMap(nbl -> nbl.getTpList().stream())
151 .collect(Collectors.toList());
152 this.oorClientPortList = ietfNode.augmentation(
153 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class)
154 .getTerminationPoint().values().stream()
155 .filter(tp -> tp.augmentation(TerminationPoint1.class).getTpType().getIntValue()
156 == OpenroadmTpType.XPONDERCLIENT.getIntValue() && tpList.contains(tp.getTpId()))
157 .sorted((tp1, tp2) -> tp1.getTpId().getValue().compareTo(tp2.getTpId().getValue()))
158 .collect(Collectors.toList());
159 this.oorClientPortList.forEach(tp -> LOG.info("tp = {}", tp.getTpId()));
162 // node creation [DSR/ODU]
163 LOG.info("creation of a DSR/ODU node for {}", this.ietfNodeId);
164 Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", this.ietfNodeId,
165 TapiStringConstants.DSR)).getBytes(Charset.forName("UTF-8"))).toString());
166 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.DSR), nodeUuid);
167 Name nameDsr = new NameBuilder().setValueName("dsr/odu node name")
168 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.DSR)).build();
169 Name nameNodeType = new NameBuilder().setValueName("Node Type")
170 .setValue(this.ietfNodeType.getName()).build();
171 Set<LayerProtocolName> dsrLayerProtocols = Set.of(LayerProtocolName.DSR, LayerProtocolName.ODU);
172 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology
173 .Node dsrNode = createTapiNode(Map.of(nameDsr.key(), nameDsr, nameNodeType.key(), nameNodeType),
175 tapiNodes.put(dsrNode.key(), dsrNode);
177 // node creation [otsi]
178 LOG.info("creation of an OTSi node for {}", this.ietfNodeId);
179 nodeUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", this.ietfNodeId, TapiStringConstants.OTSI))
180 .getBytes(Charset.forName("UTF-8"))).toString());
181 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI), nodeUuid);
182 Name nameOtsi = new NameBuilder().setValueName("otsi node name")
183 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)).build();
184 Set<LayerProtocolName> otsiLayerProtocols = Set.of(LayerProtocolName.PHOTONICMEDIA);
185 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology
186 .Node otsiNode = createTapiNode(Map.of(nameOtsi.key(), nameOtsi, nameNodeType.key(), nameNodeType),
188 tapiNodes.put(otsiNode.key(), otsiNode);
190 // transitional link cration between network nep of DSR/ODU node and iNep of otsi node
191 LOG.info("creation of transitional links between DSR/ODU and OTSi nodes");
192 createTapiTransitionalLinks();
195 public void convertLinks(Map<
196 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
198 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
200 List<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
201 .Link> otnLinkList = new ArrayList<>(otnLinkMap.values());
202 Collections.sort(otnLinkList, (l1, l2) -> l1.getLinkId().getValue()
203 .compareTo(l2.getLinkId().getValue()));
204 List<String> linksToNotConvert = new ArrayList<>();
205 LOG.info("creation of {} otn links", otnLinkMap.size() / 2);
206 for (org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network
207 .Link otnlink : otnLinkList) {
208 if (!linksToNotConvert.contains(otnlink.getLinkId().getValue())) {
209 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
210 .network.Link oppositeLink = otnLinkMap.get(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns
211 .yang.ietf.network.topology.rev180226.networks.network.LinkKey(otnlink.augmentation(Link1.class)
212 .getOppositeLink()));
214 AdminStates oppLnkAdmState = null;
215 State oppLnkOpState = null;
216 String oppositeLinkId = null;
217 if (oppositeLink != null) {
218 oppLnkAdmState = oppositeLink.augmentation(Link1.class).getAdministrativeState();
219 oppLnkOpState = oppositeLink.augmentation(Link1.class).getOperationalState();
220 oppositeLinkId = oppositeLink.getLinkId().getValue();
223 otnlink.augmentation(Link1.class).getAdministrativeState() == null
224 || oppLnkAdmState == null
226 : this.tapiLink.setTapiAdminState(
227 otnlink.augmentation(Link1.class).getAdministrativeState(), oppLnkAdmState).getName();
228 String operState = otnlink.augmentation(Link1.class).getOperationalState() == null
229 || oppLnkOpState == null
231 : this.tapiLink.setTapiOperationalState(
232 otnlink.augmentation(Link1.class).getOperationalState(), oppLnkOpState).getName();
234 String prefix = otnlink.getLinkId().getValue().split("-")[0];
235 String nodesQual = prefix.equals("OTU4") ? TapiStringConstants.OTSI : TapiStringConstants.DSR;
236 String tpsQual = prefix.equals("OTU4") ? TapiStringConstants.I_OTSI : TapiStringConstants.E_ODU;
237 LayerProtocolName layerProtocolName = prefix.equals("OTU4") ? LayerProtocolName.PHOTONICMEDIA
238 : LayerProtocolName.ODU;
240 Link tapLink = this.tapiLink.createTapiLink(otnlink.getSource().getSourceNode().getValue(),
241 otnlink.getSource().getSourceTp().getValue(), otnlink.getDestination().getDestNode().getValue(),
242 otnlink.getDestination().getDestTp().getValue(), TapiStringConstants.OTN_XPDR_XPDR_LINK, nodesQual,
243 nodesQual, tpsQual, tpsQual, adminState, operState, Set.of(layerProtocolName),
244 Set.of(layerProtocolName.getName()), this.tapiTopoUuid);
245 linksToNotConvert.add(oppositeLinkId);
246 tapiLinks.put(tapLink.key(), tapLink);
251 public void convertRoadmInfrastructure() {
252 LOG.info("abstraction of the ROADM infrastructure towards a photonic node");
253 Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes(TapiStringConstants.RDM_INFRA
254 .getBytes(Charset.forName("UTF-8"))).toString());
255 Name nodeName = new NameBuilder().setValueName("otsi node name").setValue(TapiStringConstants.RDM_INFRA)
257 Name nameNodeType = new NameBuilder().setValueName("Node Type")
258 .setValue(OpenroadmNodeType.ROADM.getName()).build();
259 Set<LayerProtocolName> nodeLayerProtocols = Set.of(LayerProtocolName.PHOTONICMEDIA);
261 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiPhotonicNodes
262 = pruneTapiPhotonicNodes();
263 Map<String, String> photonicNepUuisMap = convertListNodeWithListNepToMapForUuidAndName(tapiPhotonicNodes);
264 // nep creation for rdm infra abstraction node
265 Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepMap = createNepForRdmNode(photonicNepUuisMap.size());
266 // node rule group creation
267 Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList
268 = createNodeRuleGroupForRdmNode(nodeUuid, onepMap.values());
269 // build RDM infra node abstraction
270 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node rdmNode = new NodeBuilder()
272 .setName(Map.of(nodeName.key(), nodeName, nameNodeType.key(), nameNodeType))
273 .setLayerProtocolName(nodeLayerProtocols)
274 .setAdministrativeState(AdministrativeState.UNLOCKED)
275 .setOperationalState(OperationalState.ENABLED)
276 .setLifecycleState(LifecycleState.INSTALLED)
277 .setOwnedNodeEdgePoint(onepMap)
278 .setNodeRuleGroup(nodeRuleGroupList)
280 tapiNodes.put(rdmNode.key(), rdmNode);
282 // OMS link creation between photonoci nodes and RDM infra abstraction node
283 Map<String, String> rdmInfraNepUuisMap = convertListNodeWithListNepToMapForUuidAndName(List.of(rdmNode));
284 if (photonicNepUuisMap.size() != rdmInfraNepUuisMap.size()) {
285 LOG.warn("Unable to build OMS links between photonics nodes and RDM infrasctructure abstraction");
287 createTapiOmsLinks(photonicNepUuisMap, rdmInfraNepUuisMap);
291 private OduSwitchingPools createOduSwitchingPoolForTp100G() {
292 Map<NonBlockingListKey, NonBlockingList> nblMap = new HashMap<>();
294 for (TerminationPoint tp : this.oorNetworkPortList) {
295 TpId tpid1 = tp.getTpId();
296 TpId tpid2 = tp.augmentation(
297 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1.class)
298 .getAssociatedConnectionMapTp().iterator().next();
299 Set<TpId> tpList = new HashSet<>();
302 NonBlockingList nbl = new NonBlockingListBuilder()
303 .setNblNumber(Uint16.valueOf(count))
306 nblMap.put(nbl.key(), nbl);
309 return new OduSwitchingPoolsBuilder()
310 .setNonBlockingList(nblMap)
311 .setSwitchingPoolNumber(Uint16.valueOf(1))
315 private List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
316 pruneTapiPhotonicNodes() {
317 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
318 prunedTapiPhotonicNodes = new ArrayList<>();
319 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiPhotonicNodes
320 = this.tapiNodes.values().stream()
321 .filter(n -> LayerProtocolName.PHOTONICMEDIA.equals(n.getLayerProtocolName().stream().findFirst().get()))
322 .collect(Collectors.toList());
323 for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node
324 : tapiPhotonicNodes) {
325 Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepM = new HashMap<>();
326 for (Map.Entry<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> entry : node.getOwnedNodeEdgePoint().entrySet()) {
327 if (entry.getValue().getName().values().stream()
328 .filter(name -> name.getValueName().startsWith("eNodeEdgePoint")).count() > 0) {
329 onepM.put(entry.getKey(), entry.getValue());
332 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node prunedNode
333 = new NodeBuilder(node).setOwnedNodeEdgePoint(onepM).build();
334 prunedTapiPhotonicNodes.add(prunedNode);
336 return prunedTapiPhotonicNodes;
339 private Map<String, String> convertListNodeWithListNepToMapForUuidAndName(
340 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> nodes) {
341 Map<String, String> uuidNameMap = new HashMap<>();
342 for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node : nodes) {
343 for (OwnedNodeEdgePoint nep : node.nonnullOwnedNodeEdgePoint().values()) {
344 String nodeUuid = node.getUuid().getValue();
345 String nepUuid = nep.getUuid().getValue();
346 String nodeName = node.getName().get(new NameKey("otsi node name")).getValue();
347 String nepName = nep.getName().get(new NameKey(nep.getName().keySet().stream().findFirst().get()))
349 uuidNameMap.put(String.join("--", nodeUuid, nepUuid), String.join("--", nodeName, nepName));
355 private org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node
356 createTapiNode(Map<NameKey, Name> nodeNames, Set<LayerProtocolName> layerProtocols) {
357 Uuid nodeUuid = null;
358 Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl = new HashMap<>();
359 Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList = new HashMap<>();
360 Map<RuleKey, Rule> ruleList = new HashMap<>();
361 Rule rule = new RuleBuilder()
362 .setLocalId("forward")
363 .setForwardingRule(ForwardingRule.MAYFORWARDACROSSGROUP)
364 .setRuleType(RuleType.FORWARDING)
366 ruleList.put(rule.key(), rule);
367 if (layerProtocols.contains(LayerProtocolName.DSR)) {
368 nodeUuid = getNodeUuid4Dsr(onepl, nodeRuleGroupList, ruleList);
369 } else if (layerProtocols.contains(LayerProtocolName.PHOTONICMEDIA)) {
370 nodeUuid = getNodeUuid4Photonic(onepl, nodeRuleGroupList, ruleList);
372 LOG.error("Undefined LayerProtocolName for {} node {}", nodeNames.get(nodeNames.keySet().iterator().next())
373 .getValueName(), nodeNames.get(nodeNames.keySet().iterator().next()).getValue());
375 return new NodeBuilder()
378 .setLayerProtocolName(layerProtocols)
379 .setAdministrativeState(this.tapiLink.setTapiAdminState(this.ietfNodeAdminState.getName()))
380 .setOperationalState(this.tapiLink.setTapiOperationalState(this.ietfNodeOperState.getName()))
381 .setLifecycleState(LifecycleState.INSTALLED)
382 .setOwnedNodeEdgePoint(onepl)
383 .setNodeRuleGroup(nodeRuleGroupList)
387 private Uuid getNodeUuid4Photonic(Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl,
388 Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList,
389 Map<RuleKey, Rule> ruleList) {
391 nodeUuid = this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI));
392 // iNep creation on otsi node
393 for (int i = 0; i < oorNetworkPortList.size(); i++) {
394 Uuid nepUuid1 = new Uuid(UUID.nameUUIDFromBytes(
395 (String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
396 oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8")))
398 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
399 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid1);
400 Name onedName = new NameBuilder()
401 .setValueName("iNodeEdgePoint")
402 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
403 oorNetworkPortList.get(i).getTpId().getValue()))
406 OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
407 LayerProtocolName.PHOTONICMEDIA, LayerProtocolName.PHOTONICMEDIA, true,
408 String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI));
409 onepl.put(onep.key(), onep);
411 // eNep creation on otsi node
412 for (int i = 0; i < oorNetworkPortList.size(); i++) {
413 Uuid nepUuid2 = new Uuid(UUID.nameUUIDFromBytes(
414 (String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
415 oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8")))
417 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
418 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid2);
419 Name onedName = new NameBuilder()
420 .setValueName("eNodeEdgePoint")
421 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
422 oorNetworkPortList.get(i).getTpId().getValue()))
425 OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
426 LayerProtocolName.PHOTONICMEDIA, LayerProtocolName.PHOTONICMEDIA, true,
427 String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI));
428 onepl.put(onep.key(), onep);
430 // create NodeRuleGroup
432 for (TerminationPoint tp : this.oorNetworkPortList) {
433 Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
434 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
435 nepList = new HashMap<>();
436 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
437 .NodeEdgePoint inep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
438 .node.rule.group.NodeEdgePointBuilder()
439 .setTopologyUuid(tapiTopoUuid)
440 .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)))
441 .setNodeEdgePointUuid(
442 this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.I_OTSI,
443 tp.getTpId().getValue()))).build();
444 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
445 .NodeEdgePoint enep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
446 .node.rule.group.NodeEdgePointBuilder()
447 .setTopologyUuid(tapiTopoUuid)
448 .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.OTSI)))
449 .setNodeEdgePointUuid(
450 this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.E_OTSI,
451 tp.getTpId().getValue())))
453 nepList.put(inep.key(), inep);
454 nepList.put(enep.key(), enep);
455 NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
457 UUID.nameUUIDFromBytes(("otsi node rule group " + count).getBytes(Charset.forName("UTF-8")))
460 .setNodeEdgePoint(nepList)
462 nodeRuleGroupList.put(nodeRuleGroup.key(), nodeRuleGroup);
468 private Uuid getNodeUuid4Dsr(Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepl,
469 Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupList, Map<RuleKey, Rule> ruleList) {
471 nodeUuid = this.uuidMap.get(String.join("+", this.ietfNodeId, TapiStringConstants.DSR));
472 // client nep creation on DSR/ODU node
473 for (int i = 0; i < oorClientPortList.size(); i++) {
474 Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes(
475 (String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
476 oorClientPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString());
477 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
478 oorClientPortList.get(i).getTpId().getValue()), nepUuid);
479 NameBuilder nameBldr = new NameBuilder().setValue(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
480 oorClientPortList.get(i).getTpId().getValue()));
482 if (OpenroadmNodeType.TPDR.equals(this.ietfNodeType)) {
483 name = nameBldr.setValueName("100G-tpdr").build();
485 name = nameBldr.setValueName("NodeEdgePoint_C").build();
488 OwnedNodeEdgePoint onep = createNep(oorClientPortList.get(i), Map.of(name.key(), name),
489 LayerProtocolName.ETH, LayerProtocolName.DSR, true, String.join("+", this.ietfNodeId,
490 TapiStringConstants.DSR));
491 onepl.put(onep.key(), onep);
493 // network nep creation on DSR/ODU node
494 for (int i = 0; i < oorNetworkPortList.size(); i++) {
495 Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes(
496 (String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
497 oorNetworkPortList.get(i).getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString());
498 this.uuidMap.put(String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
499 oorNetworkPortList.get(i).getTpId().getValue()), nepUuid);
500 Name onedName = new NameBuilder()
501 .setValueName("iNodeEdgePoint_N")
502 .setValue(String.join("+", this.ietfNodeId, TapiStringConstants.I_ODU,
503 oorNetworkPortList.get(i).getTpId().getValue()))
506 OwnedNodeEdgePoint onep = createNep(oorNetworkPortList.get(i), Map.of(onedName.key(), onedName),
507 LayerProtocolName.ODU, LayerProtocolName.DSR, true, String.join("+", this.ietfNodeId,
508 TapiStringConstants.I_ODU));
509 onepl.put(onep.key(), onep);
511 // create NodeRuleGroup
513 for (NonBlockingList nbl : this.oorOduSwitchingPool.nonnullNonBlockingList().values()) {
514 Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
515 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
516 nepList = new HashMap<>();
517 for (TpId tp : nbl.getTpList()) {
518 if (this.uuidMap.containsKey(String.join("+", this.ietfNodeId, TapiStringConstants.DSR,
519 tp.getValue())) || this.uuidMap.containsKey(String.join(
520 "+", this.ietfNodeId, TapiStringConstants.I_ODU, tp.getValue()))) {
521 String qual = tp.getValue().contains("CLIENT") ? TapiStringConstants.DSR
522 : TapiStringConstants.I_ODU;
523 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint
524 nep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
525 .NodeEdgePointBuilder()
526 .setTopologyUuid(tapiTopoUuid)
527 .setNodeUuid(this.uuidMap.get(String.join("+", this.ietfNodeId,
528 TapiStringConstants.DSR)))
529 .setNodeEdgePointUuid(this.uuidMap.get(String.join("+", this.ietfNodeId,
530 qual, tp.getValue())))
532 nepList.put(nep.key(), nep);
535 NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
537 UUID.nameUUIDFromBytes(("dsr node rule group " + count).getBytes(Charset.forName("UTF-8")))
540 .setNodeEdgePoint(nepList)
542 nodeRuleGroupList.put(nodeRuleGroup.key(), nodeRuleGroup);
548 private OwnedNodeEdgePoint createNep(TerminationPoint oorTp, Map<NameKey, Name> nepNames,
549 LayerProtocolName nepProtocol, LayerProtocolName nodeProtocol,
550 boolean withSip, String keyword) {
551 String key = String.join("+", keyword, oorTp.getTpId().getValue());
552 AdministrativeState adminState = (oorTp.augmentation(TerminationPoint1.class).getAdministrativeState() != null)
553 ? this.tapiLink.setTapiAdminState(oorTp.augmentation(TerminationPoint1.class).getAdministrativeState()
556 OperationalState operState = (oorTp.augmentation(TerminationPoint1.class).getOperationalState() != null)
557 ? this.tapiLink.setTapiOperationalState(oorTp.augmentation(TerminationPoint1.class).getOperationalState()
560 OwnedNodeEdgePointBuilder onepBldr = new OwnedNodeEdgePointBuilder()
561 .setUuid(this.uuidMap.get(key))
562 .setLayerProtocolName(nepProtocol)
564 .setSupportedCepLayerProtocolQualifier(createSupportedCepLayerProtocolQualifier(oorTp, nodeProtocol))
565 .setLinkPortDirection(PortDirection.BIDIRECTIONAL)
566 .setLinkPortRole(PortRole.SYMMETRIC)
567 .setAdministrativeState(adminState)
568 .setOperationalState(operState)
569 .setLifecycleState(LifecycleState.INSTALLED)
570 .setTerminationDirection(TerminationDirection.BIDIRECTIONAL)
571 .setTerminationState(TerminationState.TERMINATEDBIDIRECTIONAL);
573 onepBldr.setMappedServiceInterfacePoint(createSIP(1, oorTp, keyword));
575 return onepBldr.build();
578 private Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> createNepForRdmNode(int nbNep) {
579 Map<OwnedNodeEdgePointKey, OwnedNodeEdgePoint> onepMap = new HashMap<>();
580 for (int i = 1; i <= nbNep; i++) {
581 Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes((String.join("+", "roadm node", "nep", String.valueOf(i)))
582 .getBytes(Charset.forName("UTF-8"))).toString());
583 Name nepName = new NameBuilder()
584 .setValueName("NodeEdgePoint name")
585 .setValue(new StringBuilder("NodeEdgePoint_").append(i).toString())
587 OwnedNodeEdgePoint onep = new OwnedNodeEdgePointBuilder()
589 .setLayerProtocolName(LayerProtocolName.PHOTONICMEDIA)
590 .setName(Map.of(nepName.key(), nepName))
591 .setSupportedCepLayerProtocolQualifier(Set.of(PHOTONICLAYERQUALIFIEROMS.VALUE))
592 .setLinkPortDirection(PortDirection.BIDIRECTIONAL).setLinkPortRole(PortRole.SYMMETRIC)
593 .setAdministrativeState(AdministrativeState.UNLOCKED).setOperationalState(OperationalState.ENABLED)
594 .setLifecycleState(LifecycleState.INSTALLED).setTerminationDirection(TerminationDirection.BIDIRECTIONAL)
595 .setTerminationState(TerminationState.TERMINATEDBIDIRECTIONAL)
597 onepMap.put(onep.key(), onep);
602 private Map<NodeRuleGroupKey, NodeRuleGroup> createNodeRuleGroupForRdmNode(Uuid nodeUuid,
603 Collection<OwnedNodeEdgePoint> onepl) {
604 Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePointKey,
605 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint>
606 nepMap = new HashMap<>();
607 for (OwnedNodeEdgePoint onep : onepl) {
608 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint
609 nep = new org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group
610 .NodeEdgePointBuilder()
611 .setTopologyUuid(tapiTopoUuid)
612 .setNodeUuid(nodeUuid)
613 .setNodeEdgePointUuid(onep.key().getUuid())
615 nepMap.put(nep.key(), nep);
617 Map<NodeRuleGroupKey, NodeRuleGroup> nodeRuleGroupMap = new HashMap<>();
618 Map<RuleKey, Rule> ruleList = new HashMap<>();
619 Rule rule = new RuleBuilder()
620 .setLocalId("forward")
621 .setForwardingRule(ForwardingRule.MAYFORWARDACROSSGROUP)
622 .setRuleType(RuleType.FORWARDING)
624 ruleList.put(rule.key(), rule);
625 NodeRuleGroup nodeRuleGroup = new NodeRuleGroupBuilder()
626 .setUuid(new Uuid(UUID.nameUUIDFromBytes(("rdm infra node rule group").getBytes(Charset.forName("UTF-8")))
629 .setNodeEdgePoint(nepMap)
631 nodeRuleGroupMap.put(nodeRuleGroup.key(), nodeRuleGroup);
632 return nodeRuleGroupMap;
635 private Map<MappedServiceInterfacePointKey, MappedServiceInterfacePoint> createSIP(int nb, TerminationPoint tp,
637 Map<MappedServiceInterfacePointKey, MappedServiceInterfacePoint> msipl = new HashMap<>();
638 for (int i = 0; i < nb; i++) {
639 MappedServiceInterfacePoint msip = new MappedServiceInterfacePointBuilder()
640 .setServiceInterfacePointUuid(new Uuid(UUID.nameUUIDFromBytes((String.join("+", "SIP", nodeId,
641 tp.getTpId().getValue())).getBytes(Charset.forName("UTF-8"))).toString()))
643 msipl.put(msip.key(), msip);
648 private Set<LAYERPROTOCOLQUALIFIER>
649 createSupportedCepLayerProtocolQualifier(TerminationPoint tp, LayerProtocolName lpn) {
650 Set<LAYERPROTOCOLQUALIFIER> sclpqSet = new HashSet<>();
651 Collection<SupportedInterfaceCapability> sicList = tp.augmentation(
652 org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.TerminationPoint1.class)
653 .getTpSupportedInterfaces()
654 .getSupportedInterfaceCapability().values();
655 for (SupportedInterfaceCapability sic : sicList) {
656 String ifCapType = sic.getIfCapType().toString().split("\\{")[0];
657 switch (lpn.getName()) {
661 sclpqSet.add(ODUTYPEODU2E.VALUE);
662 sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
665 sclpqSet.add(ODUTYPEODU2.VALUE);
666 sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
669 sclpqSet.add(DIGITALSIGNALTYPE10GigELAN.VALUE);
672 sclpqSet.add(DIGITALSIGNALTYPE100GigE.VALUE);
673 sclpqSet.add(ODUTYPEODU4.VALUE);
676 sclpqSet.add(DIGITALSIGNALTYPE100GigE.VALUE);
678 case "IfOCHOTU4ODU4":
680 sclpqSet.add(ODUTYPEODU4.VALUE);
683 LOG.error("IfCapability type not managed");
687 case "PHOTONIC_MEDIA":
688 if (ifCapType.equals("IfOCHOTU4ODU4") || ifCapType.equals("IfOCH")) {
689 sclpqSet.add(PHOTONICLAYERQUALIFIEROTSi.VALUE);
690 sclpqSet.add(PHOTONICLAYERQUALIFIEROMS.VALUE);
694 LOG.error("Layer Protocol Name is unknown");
701 private void createTapiTransitionalLinks() {
702 for (TerminationPoint tp : this.oorNetworkPortList) {
703 Link transiLink = tapiLink.createTapiLink(this.ietfNodeId, tp.getTpId().getValue(), this.ietfNodeId,
704 tp.getTpId().getValue(), TapiStringConstants.TRANSITIONAL_LINK, TapiStringConstants.DSR,
705 TapiStringConstants.OTSI, TapiStringConstants.I_ODU, TapiStringConstants.I_OTSI,
706 "inService", "inService", Set.of(LayerProtocolName.ODU, LayerProtocolName.PHOTONICMEDIA),
707 Set.of(LayerProtocolName.ODU.getName(), LayerProtocolName.PHOTONICMEDIA.getName()),
709 this.tapiLinks.put(transiLink.key(), transiLink);
713 private void createTapiOmsLinks(Map<String, String> photonicNepUuisMap, Map<String, String> rdmInfraNepUuisMap) {
714 Iterator<Entry<String, String>> it1 = photonicNepUuisMap.entrySet().iterator();
715 Iterator<Entry<String, String>> it2 = rdmInfraNepUuisMap.entrySet().iterator();
716 while (it1.hasNext()) {
717 Map<NodeEdgePointKey, NodeEdgePoint> nepMap = new HashMap<>();
718 Map.Entry<String, String> photonicEntry = it1.next();
719 Map.Entry<String, String> rdmEntry = it2.next();
720 Uuid sourceUuidTp = new Uuid(photonicEntry.getKey().split("--")[1]);
721 Uuid sourceUuidNode = new Uuid(photonicEntry.getKey().split("--")[0]);
722 Uuid destUuidTp = new Uuid(rdmEntry.getKey().split("--")[1]);
723 Uuid destUuidNode = new Uuid(rdmEntry.getKey().split("--")[0]);
724 NodeEdgePoint sourceNep = new NodeEdgePointBuilder()
725 .setTopologyUuid(this.tapiTopoUuid)
726 .setNodeUuid(sourceUuidNode)
727 .setNodeEdgePointUuid(sourceUuidTp)
729 nepMap.put(sourceNep.key(), sourceNep);
730 NodeEdgePoint destNep = new NodeEdgePointBuilder()
731 .setTopologyUuid(this.tapiTopoUuid)
732 .setNodeUuid(destUuidNode)
733 .setNodeEdgePointUuid(destUuidTp)
735 nepMap.put(destNep.key(), destNep);
736 Name linkName = new NameBuilder().setValueName("OMS link name")
737 .setValue(String.join(" and ", photonicEntry.getValue(), rdmEntry.getValue()))
739 Link omsLink = new LinkBuilder()
741 UUID.nameUUIDFromBytes((String.join(" and ", photonicEntry.getValue(), rdmEntry.getValue()))
742 .getBytes(Charset.forName("UTF-8")))
744 .setName(Map.of(linkName.key(), linkName))
745 .setLayerProtocolName(Set.of(LayerProtocolName.PHOTONICMEDIA))
746 .setNodeEdgePoint(nepMap)
747 .setDirection(ForwardingDirection.BIDIRECTIONAL)
749 this.tapiLinks.put(omsLink.key(), omsLink);
753 public Map<NodeKey, org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node>
758 public Map<LinkKey, Link> getTapiLinks() {