2 * Copyright © 2021 Nokia, 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 static org.hamcrest.CoreMatchers.anyOf;
11 import static org.hamcrest.CoreMatchers.containsString;
12 import static org.hamcrest.CoreMatchers.either;
13 import static org.hamcrest.CoreMatchers.hasItem;
14 import static org.hamcrest.CoreMatchers.hasItems;
15 import static org.hamcrest.CoreMatchers.is;
16 import static org.hamcrest.MatcherAssert.assertThat;
17 import static org.junit.Assert.assertEquals;
18 import static org.junit.Assert.assertNull;
19 import static org.junit.Assert.assertTrue;
20 import static org.junit.Assert.fail;
22 import com.google.common.util.concurrent.FluentFuture;
23 import java.nio.charset.Charset;
24 import java.util.ArrayList;
25 import java.util.HashMap;
26 import java.util.List;
28 import java.util.Optional;
29 import java.util.UUID;
30 import java.util.concurrent.ExecutionException;
31 import java.util.stream.Collectors;
32 import org.eclipse.jdt.annotation.Nullable;
33 import org.junit.BeforeClass;
34 import org.junit.Test;
35 import org.opendaylight.mdsal.binding.api.DataBroker;
36 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
37 import org.opendaylight.transportpce.common.InstanceIdentifiers;
38 import org.opendaylight.transportpce.common.network.NetworkTransactionImpl;
39 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
40 import org.opendaylight.transportpce.common.network.RequestProcessor;
41 import org.opendaylight.transportpce.tapi.TapiStringConstants;
42 import org.opendaylight.transportpce.tapi.utils.TapiLink;
43 import org.opendaylight.transportpce.tapi.utils.TapiTopologyDataUtils;
44 import org.opendaylight.transportpce.test.AbstractTest;
45 import org.opendaylight.transportpce.test.utils.TopologyDataUtils;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmLinkType;
52 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmTpType;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
69 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.AdministrativeState;
70 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.CapacityUnit;
71 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.ForwardingDirection;
72 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LayerProtocolName;
73 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.LifecycleState;
74 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.OperationalState;
75 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortDirection;
76 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.PortRole;
77 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationDirection;
78 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.TerminationState;
79 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.Uuid;
80 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.Name;
81 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameKey;
82 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE100GigE;
83 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.dsr.rev181210.DIGITALSIGNALTYPE10GigELAN;
84 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU0;
85 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2;
86 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU2E;
87 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.odu.rev181210.ODUTYPEODU4;
88 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROMS;
89 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.photonic.media.rev181210.PHOTONICLAYERQUALIFIEROTSi;
90 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.ForwardingRule;
91 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.RuleType;
92 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.NodeRuleGroup;
93 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePoint;
94 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.OwnedNodeEdgePointKey;
95 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.NodeEdgePoint;
96 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.node.rule.group.Rule;
97 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
98 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
99 import org.opendaylight.yangtools.yang.common.Uint64;
100 import org.slf4j.Logger;
101 import org.slf4j.LoggerFactory;
103 public class ConvertORTopoToFullTapiTopoTest extends AbstractTest {
104 private static final Logger LOG = LoggerFactory.getLogger(ConvertORTopoToFullTapiTopoTest.class);
106 private static Node otnMuxA;
107 private static Node otnSwitch;
108 private static Node tpdr100G;
109 private static Node roadmA;
110 private static Node roadmC;
111 private static Network openroadmNet;
112 private static Map<LinkKey, org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
113 .networks.network.Link> ortopoLinks;
114 private static Uuid topologyUuid;
115 private static NetworkTransactionService networkTransactionService;
116 private static TapiLink tapiLink;
117 private static DataBroker dataBroker = getDataBroker();
120 public static void setUp() throws InterruptedException, ExecutionException {
121 TopologyDataUtils.writeTopologyFromFileToDatastore(getDataStoreContextUtil(),
122 TapiTopologyDataUtils.OPENROADM_TOPOLOGY_FILE, InstanceIdentifiers.OVERLAY_NETWORK_II);
123 TopologyDataUtils.writeTopologyFromFileToDatastore(getDataStoreContextUtil(),
124 TapiTopologyDataUtils.OPENROADM_NETWORK_FILE, InstanceIdentifiers.UNDERLAY_NETWORK_II);
125 TopologyDataUtils.writeTopologyFromFileToDatastore(getDataStoreContextUtil(),
126 TapiTopologyDataUtils.OTN_TOPOLOGY_FILE, InstanceIdentifiers.OTN_NETWORK_II);
127 TopologyDataUtils.writePortmappingFromFileToDatastore(getDataStoreContextUtil(),
128 TapiTopologyDataUtils.PORTMAPPING_FILE);
130 KeyedInstanceIdentifier<Node, NodeKey> muxAIID = InstanceIdentifier.create(Networks.class)
131 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
132 .class, new NetworkKey(new NetworkId("otn-topology")))
133 .child(Node.class, new NodeKey(new NodeId("SPDR-SA1-XPDR1")));
134 FluentFuture<Optional<Node>> muxAFuture = dataBroker.newReadOnlyTransaction()
135 .read(LogicalDatastoreType.CONFIGURATION, muxAIID);
136 otnMuxA = muxAFuture.get().get();
137 KeyedInstanceIdentifier<Node, NodeKey> muxCIID = InstanceIdentifier.create(Networks.class)
138 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
139 .class, new NetworkKey(new NetworkId("otn-topology")))
140 .child(Node.class, new NodeKey(new NodeId("SPDR-SC1-XPDR1")));
141 FluentFuture<Optional<Node>> muxCFuture = dataBroker.newReadOnlyTransaction()
142 .read(LogicalDatastoreType.CONFIGURATION, muxCIID);
143 muxCFuture.get().get();
144 KeyedInstanceIdentifier<Node, NodeKey> switchIID = InstanceIdentifier.create(Networks.class)
145 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
146 .class, new NetworkKey(new NetworkId("otn-topology")))
147 .child(Node.class, new NodeKey(new NodeId("SPDR-SA1-XPDR2")));
148 FluentFuture<Optional<Node>> switchFuture = dataBroker.newReadOnlyTransaction()
149 .read(LogicalDatastoreType.CONFIGURATION, switchIID);
150 otnSwitch = switchFuture.get().get();
151 KeyedInstanceIdentifier<Node, NodeKey> roadmaIID = InstanceIdentifier.create(Networks.class)
152 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
153 .class, new NetworkKey(new NetworkId("openroadm-network")))
154 .child(Node.class, new NodeKey(new NodeId("ROADM-A1")));
155 FluentFuture<Optional<Node>> roadmaFuture = dataBroker.newReadOnlyTransaction()
156 .read(LogicalDatastoreType.CONFIGURATION, roadmaIID);
157 roadmA = roadmaFuture.get().get();
158 KeyedInstanceIdentifier<Node, NodeKey> roadmcIID = InstanceIdentifier.create(Networks.class)
159 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
160 .class, new NetworkKey(new NetworkId("openroadm-network")))
161 .child(Node.class, new NodeKey(new NodeId("ROADM-C1")));
162 FluentFuture<Optional<Node>> roadmcFuture = dataBroker.newReadOnlyTransaction()
163 .read(LogicalDatastoreType.CONFIGURATION, roadmcIID);
164 roadmC = roadmcFuture.get().get();
166 KeyedInstanceIdentifier<Node, NodeKey> tpdrIID = InstanceIdentifier.create(Networks.class)
167 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
168 .class, new NetworkKey(new NetworkId("otn-topology")))
169 .child(Node.class, new NodeKey(new NodeId("XPDR-A1-XPDR1")));
170 FluentFuture<Optional<Node>> tpdrFuture = dataBroker.newReadOnlyTransaction()
171 .read(LogicalDatastoreType.CONFIGURATION, tpdrIID);
172 tpdr100G = tpdrFuture.get().get();
174 InstanceIdentifier<Network1> linksIID = InstanceIdentifier.create(Networks.class)
175 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
176 .class, new NetworkKey(new NetworkId("otn-topology")))
177 .augmentation(Network1.class);
178 FluentFuture<Optional<Network1>> linksFuture = dataBroker.newReadOnlyTransaction()
179 .read(LogicalDatastoreType.CONFIGURATION, linksIID);
180 linksFuture.get().get().getLink();
182 InstanceIdentifier<Network1> links1IID = InstanceIdentifier.create(Networks.class)
183 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
184 .class, new NetworkKey(new NetworkId("openroadm-topology")))
185 .augmentation(Network1.class);
186 FluentFuture<Optional<Network1>> links1Future = dataBroker.newReadOnlyTransaction()
187 .read(LogicalDatastoreType.CONFIGURATION, links1IID);
188 ortopoLinks = links1Future.get().get().getLink();
190 InstanceIdentifier<Network> ortopo1IID = InstanceIdentifier.create(Networks.class)
191 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network
192 .class, new NetworkKey(new NetworkId("openroadm-topology")));
193 FluentFuture<Optional<Network>> ortopoFuture = dataBroker.newReadOnlyTransaction()
194 .read(LogicalDatastoreType.CONFIGURATION, ortopo1IID);
195 openroadmNet = ortopoFuture.get().get();
197 topologyUuid = new Uuid(UUID.nameUUIDFromBytes(TapiStringConstants.T0_FULL_MULTILAYER.getBytes(
198 Charset.forName("UTF-8"))).toString());
199 networkTransactionService = new NetworkTransactionImpl(
200 new RequestProcessor(getDataStoreContextUtil().getDataBroker()));
201 tapiLink = new TapiLink(networkTransactionService);
202 LOG.info("TEST SETUP READY");
206 public void convertNodeWhenNoStates() {
207 Node tpdr = changeTerminationPointState(tpdr100G, "XPDR1-NETWORK1", "XPDR1-CLIENT1", null, null);
208 List<String> networkPortList = new ArrayList<>();
209 for (TerminationPoint tp : tpdr100G.augmentation(Node1.class).getTerminationPoint().values()) {
210 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
211 networkPortList.add(tp.getTpId().getValue());
214 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
215 tapiFactory.convertNode(tpdr, networkPortList);
217 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+DSR".getBytes(Charset.forName("UTF-8")))
219 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node dsrNode = tapiFactory
220 .getTapiNodes().get(new
221 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(dsrNodeUuid));
222 Uuid enetworkNepUuid = new Uuid(
223 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eODU+XPDR1-CLIENT1").getBytes(Charset.forName("UTF-8")))
225 Uuid inetworkNepUuid = new Uuid(
226 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iODU+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
228 OwnedNodeEdgePoint enepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enetworkNepUuid));
229 assertNull("Administrative State should not be present", enepN.getAdministrativeState());
230 assertNull("Operational State should not be present", enepN.getOperationalState());
232 OwnedNodeEdgePoint inepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inetworkNepUuid));
233 assertNull("Administrative State should not be present", inepN.getAdministrativeState());
234 assertNull("Operational State should not be present", inepN.getOperationalState());
236 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
238 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node otsiNode = tapiFactory
239 .getTapiNodes().get(new
240 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(otsiNodeUuid));
241 Uuid enepUuid = new Uuid(
242 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
244 OwnedNodeEdgePoint enep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enepUuid));
245 assertNull("Administrative State should not be present", enep.getAdministrativeState());
246 assertNull("Operational State should not be present", enep.getOperationalState());
248 Uuid inepUuid = new Uuid(
249 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
251 OwnedNodeEdgePoint inep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inepUuid));
252 assertNull("Administrative State should not be present", inep.getAdministrativeState());
253 assertNull("Operational State should not be present", inep.getOperationalState());
255 Uuid photnepUuid = new Uuid(
256 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
258 OwnedNodeEdgePoint photnep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(photnepUuid));
259 assertNull("Administrative State should not be present", photnep.getAdministrativeState());
260 assertNull("Operational State should not be present", photnep.getOperationalState());
264 public void convertNodeWhenBadStates1() {
265 Node tpdr = changeTerminationPointState(tpdr100G, "XPDR1-NETWORK1", "XPDR1-CLIENT1",
266 AdminStates.OutOfService, State.OutOfService);
267 List<String> networkPortList = new ArrayList<>();
268 for (TerminationPoint tp : tpdr100G.augmentation(Node1.class).getTerminationPoint().values()) {
269 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
270 networkPortList.add(tp.getTpId().getValue());
273 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
274 tapiFactory.convertNode(tpdr, networkPortList);
276 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+DSR".getBytes(Charset.forName("UTF-8")))
278 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node dsrNode = tapiFactory
279 .getTapiNodes().get(new
280 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(dsrNodeUuid));
281 Uuid enetworkNepUuid = new Uuid(
282 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eODU+XPDR1-CLIENT1").getBytes(Charset.forName("UTF-8")))
284 Uuid inetworkNepUuid = new Uuid(
285 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iODU+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
287 OwnedNodeEdgePoint enepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enetworkNepUuid));
288 assertEquals("Administrative State should be Locked",
289 AdministrativeState.LOCKED, enepN.getAdministrativeState());
290 assertEquals("Operational State should be Disabled",
291 OperationalState.DISABLED, enepN.getOperationalState());
293 OwnedNodeEdgePoint inepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inetworkNepUuid));
294 assertEquals("Administrative State should be Locked",
295 AdministrativeState.LOCKED, inepN.getAdministrativeState());
296 assertEquals("Operational State should be Disabled",
297 OperationalState.DISABLED, inepN.getOperationalState());
299 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
301 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node otsiNode = tapiFactory
302 .getTapiNodes().get(new
303 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(otsiNodeUuid));
304 Uuid enepUuid = new Uuid(
305 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
307 OwnedNodeEdgePoint enep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enepUuid));
308 assertEquals("Administrative State should be Locked",
309 AdministrativeState.LOCKED, enep.getAdministrativeState());
310 assertEquals("Operational State should be Disabled",
311 OperationalState.DISABLED, enep.getOperationalState());
313 Uuid inepUuid = new Uuid(
314 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
316 OwnedNodeEdgePoint inep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inepUuid));
317 assertEquals("Administrative State should be Locked",
318 AdministrativeState.LOCKED, inep.getAdministrativeState());
319 assertEquals("Operational State should be Disabled",
320 OperationalState.DISABLED, inep.getOperationalState());
322 Uuid photnepUuid = new Uuid(
323 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
325 OwnedNodeEdgePoint photnep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(photnepUuid));
326 assertEquals("Administrative State should be Locked",
327 AdministrativeState.LOCKED, photnep.getAdministrativeState());
328 assertEquals("Operational State should be Disabled",
329 OperationalState.DISABLED, photnep.getOperationalState());
333 public void convertNodeWhenBadStates2() {
334 Node tpdr = changeTerminationPointState(tpdr100G, "XPDR1-NETWORK1", "XPDR1-CLIENT1",
335 AdminStates.Maintenance, State.Degraded);
336 List<String> networkPortList = new ArrayList<>();
337 for (TerminationPoint tp : tpdr100G.augmentation(Node1.class).getTerminationPoint().values()) {
338 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
339 networkPortList.add(tp.getTpId().getValue());
342 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
343 tapiFactory.convertNode(tpdr, networkPortList);
345 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+DSR".getBytes(Charset.forName("UTF-8")))
347 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node dsrNode = tapiFactory
348 .getTapiNodes().get(new
349 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(dsrNodeUuid));
350 Uuid enetworkNepUuid = new Uuid(
351 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eODU+XPDR1-CLIENT1").getBytes(Charset.forName("UTF-8")))
353 Uuid inetworkNepUuid = new Uuid(
354 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iODU+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
356 OwnedNodeEdgePoint enepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enetworkNepUuid));
357 assertEquals("Administrative State should be Locked",
358 AdministrativeState.LOCKED, enepN.getAdministrativeState());
359 assertEquals("Operational State should be Disabled",
360 OperationalState.DISABLED, enepN.getOperationalState());
362 OwnedNodeEdgePoint inepN = dsrNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inetworkNepUuid));
363 assertEquals("Administrative State should be Locked",
364 AdministrativeState.LOCKED, inepN.getAdministrativeState());
365 assertEquals("Operational State should be Disabled",
366 OperationalState.DISABLED, inepN.getOperationalState());
368 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
370 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node otsiNode = tapiFactory
371 .getTapiNodes().get(new
372 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.NodeKey(otsiNodeUuid));
373 Uuid enepUuid = new Uuid(
374 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+eOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
376 OwnedNodeEdgePoint enep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(enepUuid));
377 assertEquals("Administrative State should be Locked",
378 AdministrativeState.LOCKED, enep.getAdministrativeState());
379 assertEquals("Operational State should be Disabled",
380 OperationalState.DISABLED, enep.getOperationalState());
382 Uuid inepUuid = new Uuid(
383 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+iOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
385 OwnedNodeEdgePoint inep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(inepUuid));
386 assertEquals("Administrative State should be Locked",
387 AdministrativeState.LOCKED, inep.getAdministrativeState());
388 assertEquals("Operational State should be Disabled",
389 OperationalState.DISABLED, inep.getOperationalState());
391 Uuid photnepUuid = new Uuid(
392 UUID.nameUUIDFromBytes(("XPDR-A1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
394 OwnedNodeEdgePoint photnep = otsiNode.nonnullOwnedNodeEdgePoint().get(new OwnedNodeEdgePointKey(photnepUuid));
395 assertEquals("Administrative State should be Locked",
396 AdministrativeState.LOCKED, photnep.getAdministrativeState());
397 assertEquals("Operational State should be Disabled",
398 OperationalState.DISABLED, photnep.getOperationalState());
402 public void convertNodeForTransponder100G() {
403 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
404 List<String> networkPortList = new ArrayList<>();
405 for (TerminationPoint tp : tpdr100G.augmentation(Node1.class).getTerminationPoint().values()) {
406 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
407 networkPortList.add(tp.getTpId().getValue());
410 tapiFactory.convertNode(tpdr100G, networkPortList);
411 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
412 = tapiFactory.getTapiNodes().values().stream()
413 .sorted((n1, n2) -> n1.getUuid().getValue().compareTo(n2.getUuid().getValue()))
414 .collect(Collectors.toList());
416 assertEquals("Node list size should be 2", 2, tapiFactory.getTapiNodes().size());
417 assertEquals("Link list size should be 2", 2, tapiFactory.getTapiLinks().size());
419 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+DSR".getBytes(Charset.forName("UTF-8")))
421 checkDsrNode(tapiNodes.get(1), dsrNodeUuid, "tpdr", "XPDR-A1-XPDR1");
422 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("XPDR-A1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
424 checkOtsiNode(tapiNodes.get(0), otsiNodeUuid, "tpdr", "XPDR-A1-XPDR1");
426 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link> tapiLinks
427 = tapiFactory.getTapiLinks().values().stream()
428 .sorted((l1, l2) -> l1.getUuid().getValue().compareTo(l2.getUuid().getValue()))
429 .collect(Collectors.toList());
430 checkTransitionalLink(tapiLinks.get(1), dsrNodeUuid, otsiNodeUuid,
431 "XPDR-A1-XPDR1+iODU+XPDR1-NETWORK1", "XPDR-A1-XPDR1+iOTSi+XPDR1-NETWORK1", "XPDR-A1-XPDR1");
435 public void convertNodeForOtnMuxponder() {
436 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
437 List<String> networkPortList = new ArrayList<>();
438 for (TerminationPoint tp : otnMuxA.augmentation(Node1.class).getTerminationPoint().values()) {
439 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
440 networkPortList.add(tp.getTpId().getValue());
443 tapiFactory.convertNode(otnMuxA, networkPortList);
444 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
445 = tapiFactory.getTapiNodes().values().stream()
446 .sorted((n1, n2) -> n1.getUuid().getValue().compareTo(n2.getUuid().getValue()))
447 .collect(Collectors.toList());
449 assertEquals("Node list size should be 2", 2, tapiFactory.getTapiNodes().size());
450 assertEquals("Link list size should be 1", 1, tapiFactory.getTapiLinks().size());
451 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR1+DSR".getBytes(Charset.forName("UTF-8")))
453 checkDsrNode(tapiNodes.get(0), dsrNodeUuid, "mux", "SPDR-SA1-XPDR1");
454 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
456 checkOtsiNode(tapiNodes.get(1), otsiNodeUuid, "mux", "SPDR-SA1-XPDR1");
458 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link> tapiLinks
459 = tapiFactory.getTapiLinks().values().stream()
460 .sorted((l1, l2) -> l1.getUuid().getValue().compareTo(l2.getUuid().getValue()))
461 .collect(Collectors.toList());
462 checkTransitionalLink(tapiLinks.get(0), dsrNodeUuid, otsiNodeUuid,
463 "SPDR-SA1-XPDR1+iODU+XPDR1-NETWORK1", "SPDR-SA1-XPDR1+iOTSi+XPDR1-NETWORK1", "SPDR-SA1-XPDR1");
467 public void convertNodeForOtnSwitch() {
468 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
469 List<String> networkPortList = new ArrayList<>();
470 for (TerminationPoint tp : otnSwitch.augmentation(Node1.class).getTerminationPoint().values()) {
471 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
472 networkPortList.add(tp.getTpId().getValue());
475 tapiFactory.convertNode(otnSwitch, networkPortList);
476 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
477 = tapiFactory.getTapiNodes().values().stream()
478 .sorted((n1, n2) -> n1.getUuid().getValue().compareTo(n2.getUuid().getValue()))
479 .collect(Collectors.toList());
481 assertEquals("Node list size should be 2", 2, tapiFactory.getTapiNodes().size());
482 assertEquals("Link list size should be 4", 4, tapiFactory.getTapiLinks().size());
484 Uuid dsrNodeUuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR2+DSR".getBytes(Charset.forName("UTF-8")))
486 checkDsrNode(tapiNodes.get(0), dsrNodeUuid, "switch", "SPDR-SA1-XPDR2");
487 Uuid otsiNodeUuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR2+OTSi".getBytes(Charset.forName("UTF-8")))
489 checkOtsiNode(tapiNodes.get(1), otsiNodeUuid, "switch", "SPDR-SA1-XPDR2");
491 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link> tapiLinks
492 = tapiFactory.getTapiLinks().values().stream()
493 .sorted((l1, l2) -> l1.getUuid().getValue().compareTo(l2.getUuid().getValue()))
494 .collect(Collectors.toList());
495 checkTransitionalLink(tapiLinks.get(2), dsrNodeUuid, otsiNodeUuid,
496 "SPDR-SA1-XPDR2+iODU+XPDR2-NETWORK4", "SPDR-SA1-XPDR2+iOTSi+XPDR2-NETWORK4", "SPDR-SA1-XPDR2");
500 public void convertNodeForRoadmWhenNoOtnMuxAttached() {
501 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
502 tapiFactory.convertRoadmNode(roadmA, openroadmNet);
504 assertEquals("Node list size should be 1", 1, tapiFactory.getTapiNodes().size());
505 assertEquals("Link list size should be empty", 0, tapiFactory.getTapiLinks().size());
506 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
507 = tapiFactory.getTapiNodes().values().stream().collect(Collectors.toList());
508 Uuid roadmNodeUuid = new Uuid(UUID.nameUUIDFromBytes((roadmA.getNodeId().getValue() + "+PHOTONIC_MEDIA")
509 .getBytes(Charset.forName("UTF-8"))).toString());
510 checkOtsiNode(tapiNodes.get(0), roadmNodeUuid, "roadm", "ROADM-A1");
514 public void convertNodeForRoadmWhenRoadmNeighborAttached() {
515 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
516 tapiFactory.convertRoadmNode(roadmA, openroadmNet);
517 tapiFactory.convertRoadmNode(roadmC, openroadmNet);
519 List<Link> rdmTordmLinkList = ortopoLinks.values().stream()
520 .filter(lk -> lk.augmentation(Link1.class).getLinkType().equals(OpenroadmLinkType.ROADMTOROADM))
521 .collect(Collectors.toList());
522 tapiFactory.convertRdmToRdmLinks(rdmTordmLinkList);
524 assertEquals("Node list size should be 2", 2, tapiFactory.getTapiNodes().size());
525 assertEquals("Link list size should be 1", 1, tapiFactory.getTapiLinks().size());
527 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
528 = tapiFactory.getTapiNodes().values().stream().collect(Collectors.toList());
529 Uuid roadmaNodeUuid = new Uuid(UUID.nameUUIDFromBytes((roadmA.getNodeId().getValue() + "+PHOTONIC_MEDIA")
530 .getBytes(Charset.forName("UTF-8"))).toString());
531 checkOtsiNode(tapiNodes.get(1), roadmaNodeUuid, "roadm", "ROADM-A1");
533 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link> links
534 = tapiFactory.getTapiLinks().values().stream()
535 .sorted((l1, l2) -> l1.getUuid().getValue().compareTo(l2.getUuid().getValue()))
536 .collect(Collectors.toList());
537 Uuid node1Uuid = new Uuid(UUID.nameUUIDFromBytes("ROADM-A1+PHOTONIC_MEDIA".getBytes(Charset.forName("UTF-8")))
539 Uuid node2Uuid = new Uuid(UUID.nameUUIDFromBytes("ROADM-C1+PHOTONIC_MEDIA".getBytes(Charset.forName("UTF-8")))
541 Uuid tp1Uuid = new Uuid(UUID.nameUUIDFromBytes("ROADM-A1+PHOTONIC_MEDIA+DEG2-TTP-TXRX"
542 .getBytes(Charset.forName("UTF-8"))).toString());
543 Uuid tp2Uuid = new Uuid(UUID.nameUUIDFromBytes(("ROADM-C1+PHOTONIC_MEDIA+DEG1-TTP-TXRX")
544 .getBytes(Charset.forName("UTF-8"))).toString());
546 new Uuid(UUID.nameUUIDFromBytes(
547 "ROADM-C1+PHOTONIC_MEDIA+DEG1-TTP-TXRXtoROADM-A1+PHOTONIC_MEDIA+DEG2-TTP-TXRX"
548 .getBytes(Charset.forName("UTF-8"))).toString());
549 checkOmsLink(links.get(0), node1Uuid, node2Uuid, tp1Uuid, tp2Uuid, linkUuid,
550 "ROADM-C1+PHOTONIC_MEDIA+DEG1-TTP-TXRXtoROADM-A1+PHOTONIC_MEDIA+DEG2-TTP-TXRX");
554 public void convertNodeForRoadmWhenOtnMuxAttached() {
555 ConvertORTopoToTapiFullTopo tapiFactory = new ConvertORTopoToTapiFullTopo(topologyUuid, tapiLink);
556 List<String> networkPortListA = new ArrayList<>();
557 for (TerminationPoint tp : otnMuxA.augmentation(Node1.class).getTerminationPoint().values()) {
558 if (tp.augmentation(TerminationPoint1.class).getTpType().equals(OpenroadmTpType.XPONDERNETWORK)) {
559 networkPortListA.add(tp.getTpId().getValue());
562 tapiFactory.convertNode(otnMuxA, networkPortListA);
563 tapiFactory.convertRoadmNode(roadmA, openroadmNet);
564 List<Link> xponderOutLinkList = ortopoLinks.values().stream()
565 .filter(lk -> lk.augmentation(Link1.class).getLinkType().equals(OpenroadmLinkType.XPONDEROUTPUT))
566 .filter(lk1 -> ((lk1.getSource().getSourceNode().equals(otnMuxA.getNodeId())
567 || lk1.getSource().getSourceNode().getValue().contains(roadmA.getNodeId().getValue()))
568 && (lk1.getDestination().getDestNode().equals(otnMuxA.getNodeId())
569 || lk1.getDestination().getDestNode().getValue().contains(roadmA.getNodeId().getValue()))))
570 .collect(Collectors.toList());
571 List<Link> xponderInLinkList = ortopoLinks.values().stream()
572 .filter(lk -> lk.augmentation(Link1.class).getLinkType().equals(OpenroadmLinkType.XPONDERINPUT))
573 .filter(lk1 -> ((lk1.getSource().getSourceNode().equals(otnMuxA.getNodeId())
574 || lk1.getSource().getSourceNode().getValue().contains(roadmA.getNodeId().getValue()))
575 && (lk1.getDestination().getDestNode().equals(otnMuxA.getNodeId())
576 || lk1.getDestination().getDestNode().getValue().contains(roadmA.getNodeId().getValue()))))
577 .collect(Collectors.toList());
578 xponderInLinkList.addAll(xponderOutLinkList);
579 tapiFactory.convertXpdrToRdmLinks(xponderInLinkList);
580 assertEquals("Node list size should be 3", 3, tapiFactory.getTapiNodes().size());
581 assertEquals("Link list size should be 2", 2, tapiFactory.getTapiLinks().size());
582 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node> tapiNodes
583 = tapiFactory.getTapiNodes().values().stream()
584 .sorted((n1, n2) -> n1.getUuid().getValue().compareTo(n2.getUuid().getValue()))
585 .collect(Collectors.toList());
586 Uuid roadmNodeUuid = new Uuid(UUID.nameUUIDFromBytes((roadmA.getNodeId().getValue() + "+PHOTONIC_MEDIA")
587 .getBytes(Charset.forName("UTF-8"))).toString());
588 checkOtsiNode(tapiNodes.get(1), roadmNodeUuid, "roadm", "ROADM-A1");
590 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link> links
591 = tapiFactory.getTapiLinks().values().stream()
592 .sorted((l1, l2) -> l1.getUuid().getValue().compareTo(l2.getUuid().getValue()))
593 .collect(Collectors.toList());
594 Uuid node1Uuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR1+OTSi".getBytes(Charset.forName("UTF-8")))
596 Uuid node2Uuid = new Uuid(UUID.nameUUIDFromBytes("ROADM-A1+PHOTONIC_MEDIA".getBytes(Charset.forName("UTF-8")))
598 Uuid tp1Uuid = new Uuid(UUID.nameUUIDFromBytes("SPDR-SA1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1"
599 .getBytes(Charset.forName("UTF-8"))).toString());
600 Uuid tp2Uuid = new Uuid(UUID.nameUUIDFromBytes(("ROADM-A1+PHOTONIC_MEDIA+SRG1-PP2-TXRX")
601 .getBytes(Charset.forName("UTF-8"))).toString());
603 new Uuid(UUID.nameUUIDFromBytes(
604 "ROADM-A1+PHOTONIC_MEDIA+SRG1-PP2-TXRXtoSPDR-SA1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1"
605 .getBytes(Charset.forName("UTF-8"))).toString());
606 checkXpdrRdmLink(links.get(1), node1Uuid, node2Uuid, tp1Uuid, tp2Uuid, linkUuid,
607 "ROADM-A1+PHOTONIC_MEDIA+SRG1-PP2-TXRXtoSPDR-SA1-XPDR1+PHOTONIC_MEDIA+XPDR1-NETWORK1");
610 private void checkDsrNode(org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node,
611 Uuid nodeUuid, String dsrNodeType, String nodeId) {
612 assertEquals("incorrect node uuid", nodeUuid, node.getUuid());
613 assertEquals("incorrect node name", nodeId + "+DSR", node.getName().get(
614 new NameKey("dsr/odu node name")).getValue());
615 assertEquals("administrative state should be UNLOCKED",
616 AdministrativeState.UNLOCKED, node.getAdministrativeState());
617 assertEquals("life-cycle state should be INSTALLED", LifecycleState.INSTALLED, node.getLifecycleState());
618 assertEquals("operational state should be ENABLED", OperationalState.ENABLED, node.getOperationalState());
619 assertThat("one value-name should be 'dsr/odu node name'",
620 new ArrayList<>(node.nonnullName().keySet()), hasItem(new NameKey("dsr/odu node name")));
621 assertEquals("dsr node should manage 2 protocol layers : dsr and odu",
622 2, node.getLayerProtocolName().size());
623 assertThat("dsr node should manage 2 protocol layers : dsr and odu",
624 node.getLayerProtocolName(), hasItems(LayerProtocolName.DSR, LayerProtocolName.ODU));
625 List<OwnedNodeEdgePoint> inepsN = node.nonnullOwnedNodeEdgePoint().values().stream()
626 .filter(n -> n.getName().containsKey(new NameKey("iNodeEdgePoint_N")))
627 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
628 .collect(Collectors.toList());
629 List<OwnedNodeEdgePoint> enepsN = node.nonnullOwnedNodeEdgePoint().values().stream()
630 .filter(n -> n.getName().containsKey(new NameKey("eNodeEdgePoint_N")))
631 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
632 .collect(Collectors.toList());
633 List<OwnedNodeEdgePoint> nepsC;
634 switch (dsrNodeType) {
636 nepsC = node.nonnullOwnedNodeEdgePoint().values().stream()
637 .filter(n -> n.getName().containsKey(new NameKey("NodeEdgePoint_C")))
638 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
639 .collect(Collectors.toList());
640 assertEquals("Switch-DSR node should have 4 eNEPs network", 4, enepsN.size());
641 assertEquals("Switch-DSR node should have 4 iNEPs network", 4, inepsN.size());
642 assertEquals("Switch-DSR node should have 4 NEPs client", 4, nepsC.size());
643 OwnedNodeEdgePoint nep1 = nepsC.get(2);
644 Uuid client4NepUuid = new Uuid(
645 UUID.nameUUIDFromBytes((nodeId + "+DSR+XPDR2-CLIENT4").getBytes(Charset.forName("UTF-8")))
647 checkNepClient100GSwitch(nep1, client4NepUuid, nodeId + "+DSR+XPDR2-CLIENT4", "NodeEdgePoint_C");
648 OwnedNodeEdgePoint enep2 = enepsN.get(2);
649 OwnedNodeEdgePoint inep2 = inepsN.get(3);
650 Uuid enetworkNepUuid = new Uuid(
651 UUID.nameUUIDFromBytes((nodeId + "+eODU+XPDR2-CLIENT4").getBytes(Charset.forName("UTF-8")))
653 Uuid inetworkNepUuid = new Uuid(
654 UUID.nameUUIDFromBytes((nodeId + "+iODU+XPDR2-NETWORK1").getBytes(Charset.forName("UTF-8")))
656 checkNepeODU4(enep2, enetworkNepUuid, nodeId + "+eODU+XPDR2-CLIENT4", "eNodeEdgePoint_N", false);
657 checkNepNetworkODU4(inep2, inetworkNepUuid, nodeId + "+iODU+XPDR2-NETWORK1", "iNodeEdgePoint_N", true);
658 List<NodeRuleGroup> nrgList = node.nonnullNodeRuleGroup().values().stream()
659 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
660 .collect(Collectors.toList());
661 checkNodeRuleGroupForSwitchDSR(nrgList, client4NepUuid, enetworkNepUuid, nodeUuid);
664 nepsC = node.nonnullOwnedNodeEdgePoint().values().stream()
665 .filter(n -> n.getName().containsKey(new NameKey("NodeEdgePoint_C")))
666 .sorted((nep3, nep4) -> nep3.getUuid().getValue().compareTo(nep4.getUuid().getValue()))
667 .collect(Collectors.toList());
668 assertEquals("Mux-DSR node should have 4 eNEP network", 4, enepsN.size());
669 assertEquals("Mux-DSR node should have 1 iNEP network", 1, inepsN.size());
670 assertEquals("Mux-DSR node should have 4 NEPs client", 4, nepsC.size());
671 OwnedNodeEdgePoint nep3 = nepsC.get(2);
672 Uuid client3NepUuid = new Uuid(
673 UUID.nameUUIDFromBytes((nodeId + "+DSR+XPDR1-CLIENT3").getBytes(Charset.forName("UTF-8")))
675 checkNepClient10G(nep3, client3NepUuid, nodeId + "+DSR+XPDR1-CLIENT3", "NodeEdgePoint_C");
676 OwnedNodeEdgePoint enep4 = enepsN.get(3);
677 OwnedNodeEdgePoint inep4 = inepsN.get(0);
678 Uuid enetworkNepUuid2 = new Uuid(
679 UUID.nameUUIDFromBytes((nodeId + "+eODU+XPDR1-CLIENT3").getBytes(Charset.forName("UTF-8")))
681 Uuid inetworkNepUuid2 = new Uuid(
682 UUID.nameUUIDFromBytes((nodeId + "+iODU+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
684 checkNepeODU4(enep4, enetworkNepUuid2, nodeId + "+eODU+XPDR1-CLIENT3", "eNodeEdgePoint_N", false);
685 checkNepNetworkODU4(inep4, inetworkNepUuid2, nodeId + "+iODU+XPDR1-NETWORK1", "iNodeEdgePoint_N",
687 List<NodeRuleGroup> nrgList2 = node.nonnullNodeRuleGroup().values().stream()
688 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
689 .collect(Collectors.toList());
690 checkNodeRuleGroupForMuxDSR(nrgList2, client3NepUuid, enetworkNepUuid2, nodeUuid);
693 nepsC = node.nonnullOwnedNodeEdgePoint().values().stream()
694 .filter(n -> n.getName().containsKey(new NameKey("100G-tpdr")))
695 .sorted((nep5, nep6) -> nep5.getUuid().getValue().compareTo(nep6.getUuid().getValue()))
696 .collect(Collectors.toList());
697 assertEquals("Tpdr-DSR node should have 2 eNEPs network", 2, enepsN.size());
698 assertEquals("Tpdr-DSR node should have 2 iNEPs network", 2, inepsN.size());
699 assertEquals("Tpdr-DSR node should have 2 NEPs client", 2, nepsC.size());
700 OwnedNodeEdgePoint nep5 = nepsC.get(0);
701 Uuid client1NepUuid = new Uuid(
702 UUID.nameUUIDFromBytes((nodeId + "+DSR+XPDR1-CLIENT1").getBytes(Charset.forName("UTF-8")))
704 checkNepClient100GTpdr(nep5, client1NepUuid, nodeId + "+DSR+XPDR1-CLIENT1", "100G-tpdr");
705 OwnedNodeEdgePoint enep6 = enepsN.get(0);
706 OwnedNodeEdgePoint inep6 = inepsN.get(1);
707 Uuid enetworkNepUuid3 = new Uuid(
708 UUID.nameUUIDFromBytes((nodeId + "+eODU+XPDR1-CLIENT1").getBytes(Charset.forName("UTF-8")))
710 Uuid inetworkNepUuid3 = new Uuid(
711 UUID.nameUUIDFromBytes((nodeId + "+iODU+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
713 checkNepeODU4(enep6, enetworkNepUuid3, nodeId + "+eODU+XPDR1-CLIENT1", "eNodeEdgePoint_N", false);
714 checkNepNetworkODU4(inep6, inetworkNepUuid3, nodeId + "+iODU+XPDR1-NETWORK1", "iNodeEdgePoint_N",
716 List<NodeRuleGroup> nrgList3 = node.nonnullNodeRuleGroup().values().stream()
717 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
718 .collect(Collectors.toList());
719 checkNodeRuleGroupForTpdrDSR(nrgList3, client1NepUuid, enetworkNepUuid3, nodeUuid);
727 private void checkOtsiNode(
728 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Node node,
729 Uuid nodeUuid, String otsiNodeType, String nodeId) {
730 assertEquals("incorrect node uuid", nodeUuid, node.getUuid());
731 List<OwnedNodeEdgePoint> nepsI = null;
732 List<OwnedNodeEdgePoint> nepsE = null;
733 List<OwnedNodeEdgePoint> nepsP = null;
734 List<OwnedNodeEdgePoint> nepsMc = null;
735 List<OwnedNodeEdgePoint> nepsOtsimc = null;
736 List<OwnedNodeEdgePoint> nepsPhot = null;
737 if (!otsiNodeType.equals("roadm")) {
738 assertEquals("incorrect node name", nodeId + "+OTSi", node.getName().get(
739 new NameKey("otsi node name")).getValue());
740 assertThat("one value-name should be 'dsr/odu node name'",
741 new ArrayList<>(node.nonnullName().keySet()), hasItem(new NameKey("otsi node name")));
742 nepsI = node.nonnullOwnedNodeEdgePoint().values().stream()
743 .filter(n -> n.getName().containsKey(new NameKey("iNodeEdgePoint")))
744 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
745 .collect(Collectors.toList());
746 nepsE = node.nonnullOwnedNodeEdgePoint().values().stream()
747 .filter(n -> n.getName().containsKey(new NameKey("eNodeEdgePoint")))
748 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
749 .collect(Collectors.toList());
750 nepsP = node.nonnullOwnedNodeEdgePoint().values().stream()
751 .filter(n -> n.getName().containsKey(new NameKey("PhotMedNodeEdgePoint")))
752 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
753 .collect(Collectors.toList());
755 assertEquals("incorrect node name", nodeId + "+PHOTONIC_MEDIA", node.getName().get(
756 new NameKey("roadm node name")).getValue());
757 assertThat("one value-name should be 'dsr/odu node name'",
758 new ArrayList<>(node.nonnullName().keySet()), hasItem(new NameKey("roadm node name")));
759 nepsMc = node.nonnullOwnedNodeEdgePoint().values().stream()
760 .filter(n -> n.getName().containsKey(new NameKey("MEDIA_CHANNELNodeEdgePoint")))
761 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
762 .collect(Collectors.toList());
763 nepsOtsimc = node.nonnullOwnedNodeEdgePoint().values().stream()
764 .filter(n -> n.getName().containsKey(new NameKey("OTSi_MEDIA_CHANNELNodeEdgePoint")))
765 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
766 .collect(Collectors.toList());
767 nepsPhot = node.nonnullOwnedNodeEdgePoint().values().stream()
768 .filter(n -> n.getName().containsKey(new NameKey("PHOTONIC_MEDIANodeEdgePoint")))
769 .sorted((nep1, nep2) -> nep1.getUuid().getValue().compareTo(nep2.getUuid().getValue()))
770 .collect(Collectors.toList());
772 assertEquals("administrative state should be UNLOCKED",
773 AdministrativeState.UNLOCKED, node.getAdministrativeState());
774 assertEquals("life-cycle state should be INSTALLED", LifecycleState.INSTALLED, node.getLifecycleState());
775 assertEquals("operational state should be ENABLED", OperationalState.ENABLED, node.getOperationalState());
776 assertEquals("otsi node should manage a single protocol layer : PHOTONIC_MEDIA",
777 1, node.getLayerProtocolName().size());
778 assertEquals("otsi node should manage a single protocol layer : PHOTONIC_MEDIA",
779 LayerProtocolName.PHOTONICMEDIA, node.getLayerProtocolName().stream().findFirst().get());
781 switch (otsiNodeType) {
783 assertEquals("Switch-OTSi node should have 4 eNEPs", 4, nepsE.size());
784 assertEquals("Switch-OTSi node should have 4 iNEPs", 4, nepsI.size());
785 assertEquals("Switch-OTSi node should have 4 photNEPs", 4, nepsP.size());
786 OwnedNodeEdgePoint nep1 = nepsI.get(1);
787 Uuid inepUuid = new Uuid(
788 UUID.nameUUIDFromBytes((nodeId + "+iOTSi+XPDR2-NETWORK2").getBytes(Charset.forName("UTF-8")))
790 checkNepOtsiNode(nep1, inepUuid, nodeId + "+iOTSi+XPDR2-NETWORK2", "iNodeEdgePoint", true);
791 OwnedNodeEdgePoint nep2 = nepsE.get(0);
792 Uuid enepUuid = new Uuid(
793 UUID.nameUUIDFromBytes((nodeId + "+eOTSi+XPDR2-NETWORK2").getBytes(Charset.forName("UTF-8")))
795 checkNepOtsiNode(nep2, enepUuid, nodeId + "+eOTSi+XPDR2-NETWORK2", "eNodeEdgePoint", false);
796 OwnedNodeEdgePoint photNep = nepsP.get(1);
797 Uuid pnepUuid = new Uuid(
798 UUID.nameUUIDFromBytes((nodeId + "+PHOTONIC_MEDIA+XPDR2-NETWORK2")
799 .getBytes(Charset.forName("UTF-8"))).toString());
800 checkNepOtsiNode(photNep, pnepUuid, nodeId + "+PHOTONIC_MEDIA+XPDR2-NETWORK2", "PhotMedNodeEdgePoint",
802 List<NodeRuleGroup> nrgList = node.nonnullNodeRuleGroup().values().stream()
803 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
804 .collect(Collectors.toList());
805 checkNodeRuleGroupForSwitchOTSi(nrgList, enepUuid, inepUuid, nodeUuid);
808 assertEquals("Mux-OTSi node should have 1 eNEP", 1, nepsE.size());
809 assertEquals("Mux-OTSi node should have 1 iNEPs", 1, nepsI.size());
810 assertEquals("Mux-OTSi node should have 1 photNEPs", 1, nepsP.size());
811 OwnedNodeEdgePoint nep3 = nepsE.get(0);
812 Uuid enepUuid2 = new Uuid(
813 UUID.nameUUIDFromBytes((nodeId + "+eOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
815 checkNepOtsiNode(nep3, enepUuid2, nodeId + "+eOTSi+XPDR1-NETWORK1", "eNodeEdgePoint", false);
816 OwnedNodeEdgePoint nep4 = nepsI.get(0);
817 Uuid inepUuid2 = new Uuid(
818 UUID.nameUUIDFromBytes((nodeId + "+iOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
820 checkNepOtsiNode(nep4, inepUuid2, nodeId + "+iOTSi+XPDR1-NETWORK1", "iNodeEdgePoint", true);
821 OwnedNodeEdgePoint photNep1 = nepsP.get(0);
822 Uuid pnep1Uuid = new Uuid(
823 UUID.nameUUIDFromBytes((nodeId + "+PHOTONIC_MEDIA+XPDR1-NETWORK1")
824 .getBytes(Charset.forName("UTF-8"))).toString());
825 checkNepOtsiNode(photNep1, pnep1Uuid, nodeId + "+PHOTONIC_MEDIA+XPDR1-NETWORK1", "PhotMedNodeEdgePoint",
827 List<NodeRuleGroup> nrgList2 = node.nonnullNodeRuleGroup().values().stream()
828 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
829 .collect(Collectors.toList());
830 checkNodeRuleGroupForMuxOTSi(nrgList2, enepUuid2, inepUuid2, nodeUuid);
833 assertEquals("Tpdr-OTSi node should have 2 eNEPs", 2, nepsE.size());
834 assertEquals("Tpdr-OTSi node should have 2 iNEPs", 2, nepsI.size());
835 assertEquals("Tpdr-OTSi node should have 2 photNEPs", 2, nepsP.size());
836 OwnedNodeEdgePoint nep5 = nepsE.get(0);
837 Uuid enepUuid3 = new Uuid(
838 UUID.nameUUIDFromBytes((nodeId + "+eOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
840 checkNepOtsiNode(nep5, enepUuid3, nodeId + "+eOTSi+XPDR1-NETWORK1", "eNodeEdgePoint", false);
841 OwnedNodeEdgePoint nep6 = nepsI.get(0);
842 Uuid inepUuid3 = new Uuid(
843 UUID.nameUUIDFromBytes((nodeId + "+iOTSi+XPDR1-NETWORK1").getBytes(Charset.forName("UTF-8")))
845 checkNepOtsiNode(nep6, inepUuid3, nodeId + "+iOTSi+XPDR1-NETWORK1", "iNodeEdgePoint", true);
846 OwnedNodeEdgePoint photNep2 = nepsP.get(0);
847 Uuid pnep2Uuid = new Uuid(
848 UUID.nameUUIDFromBytes((nodeId + "+PHOTONIC_MEDIA+XPDR1-NETWORK1")
849 .getBytes(Charset.forName("UTF-8"))).toString());
850 checkNepOtsiNode(photNep2, pnep2Uuid, nodeId + "+PHOTONIC_MEDIA+XPDR1-NETWORK1", "PhotMedNodeEdgePoint",
852 List<NodeRuleGroup> nrgList3 = node.nonnullNodeRuleGroup().values().stream()
853 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
854 .collect(Collectors.toList());
855 checkNodeRuleGroupForTpdrOTSi(nrgList3, enepUuid3, inepUuid3, nodeUuid);
858 assertEquals("Roadm node should have 10 MC NEPs", 10, nepsMc.size());
859 assertEquals("Roadm node should have 10 OTSiMC NEPs", 10, nepsOtsimc.size());
860 assertEquals("Roadm node should have 10 PHOT_MEDIA NEPs", 10, nepsPhot.size());
862 OwnedNodeEdgePoint nep7 = nepsMc.get(6);
863 Uuid mcnepUuid3 = new Uuid(
864 UUID.nameUUIDFromBytes((nodeId + "+MEDIA_CHANNEL+DEG1-TTP-TXRX").getBytes(Charset.forName("UTF-8")))
866 checkNepOtsiRdmNode(nep7, mcnepUuid3, nodeId + "+MEDIA_CHANNEL+DEG1-TTP-TXRX",
867 "MEDIA_CHANNELNodeEdgePoint", false);
868 OwnedNodeEdgePoint nep8 = nepsOtsimc.get(0);
869 Uuid otmcnepUuid3 = new Uuid(UUID.nameUUIDFromBytes((nodeId + "+OTSi_MEDIA_CHANNEL+DEG1-TTP-TXRX")
870 .getBytes(Charset.forName("UTF-8"))).toString());
871 checkNepOtsiRdmNode(nep8, otmcnepUuid3, nodeId + "+OTSi_MEDIA_CHANNEL+DEG1-TTP-TXRX",
872 "OTSi_MEDIA_CHANNELNodeEdgePoint", false);
873 OwnedNodeEdgePoint photNep3 = nepsPhot.get(3);
874 Uuid pnep3Uuid = new Uuid(
875 UUID.nameUUIDFromBytes((nodeId + "+PHOTONIC_MEDIA+DEG1-TTP-TXRX")
876 .getBytes(Charset.forName("UTF-8"))).toString());
877 checkNepOtsiRdmNode(photNep3, pnep3Uuid, nodeId + "+PHOTONIC_MEDIA+DEG1-TTP-TXRX",
878 "PHOTONIC_MEDIANodeEdgePoint", false);
880 OwnedNodeEdgePoint nep9 = nepsMc.get(0);
881 Uuid mcnepUuid4 = new Uuid(UUID.nameUUIDFromBytes((nodeId + "+MEDIA_CHANNEL+SRG1-PP1-TXRX")
882 .getBytes(Charset.forName("UTF-8"))).toString());
883 checkNepOtsiRdmNode(nep9, mcnepUuid4, nodeId + "+MEDIA_CHANNEL+SRG1-PP1-TXRX",
884 "MEDIA_CHANNELNodeEdgePoint", true);
885 OwnedNodeEdgePoint nep10 = nepsOtsimc.get(9);
886 Uuid otmcnepUuid4 = new Uuid(UUID.nameUUIDFromBytes((nodeId + "+OTSi_MEDIA_CHANNEL+SRG1-PP1-TXRX")
887 .getBytes(Charset.forName("UTF-8"))).toString());
888 checkNepOtsiRdmNode(nep10, otmcnepUuid4, nodeId + "+OTSi_MEDIA_CHANNEL+SRG1-PP1-TXRX",
889 "OTSi_MEDIA_CHANNELNodeEdgePoint", false);
890 OwnedNodeEdgePoint photNep4 = nepsPhot.get(4);
891 Uuid pnep4Uuid = new Uuid(UUID.nameUUIDFromBytes((nodeId + "+PHOTONIC_MEDIA+SRG1-PP1-TXRX")
892 .getBytes(Charset.forName("UTF-8"))).toString());
893 checkNepOtsiRdmNode(photNep4, pnep4Uuid, nodeId + "+PHOTONIC_MEDIA+SRG1-PP1-TXRX",
894 "PHOTONIC_MEDIANodeEdgePoint", false);
895 List<NodeRuleGroup> nrgList4 = node.nonnullNodeRuleGroup().values().stream()
896 .sorted((nrg1, nrg2) -> nrg1.getUuid().getValue().compareTo(nrg2.getUuid().getValue()))
897 .collect(Collectors.toList());
898 checkNodeRuleGroupForRdm(nrgList4, 30);
906 private void checkNepClient10G(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName) {
907 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
908 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
909 Name name = nameList.get(0);
910 assertEquals("value of client nep should be '" + portName + "'",
911 portName, name.getValue());
912 assertEquals("value-name of client nep for '" + portName + "' should be '" + nepName + "'",
913 nepName, name.getValueName());
914 assertEquals("Client nep should support 3 kind of cep",
915 3, nep.getSupportedCepLayerProtocolQualifier().size());
916 assertThat("client nep should support 3 kind of cep",
917 nep.getSupportedCepLayerProtocolQualifier(),
918 hasItems(ODUTYPEODU2.class, ODUTYPEODU2E.class, DIGITALSIGNALTYPE10GigELAN.class));
919 assertEquals("client nep should be of DSR protocol type", LayerProtocolName.DSR, nep.getLayerProtocolName());
920 checkCommonPartOfNep(nep, false);
923 private void checkNepeODU4(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName,
925 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
926 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
927 Name name = nameList.get(0);
928 assertEquals("value of eODU nep should be '" + portName + "'",
929 portName, name.getValue());
930 assertEquals("value-name of eODU nep for '" + portName + "' should be '" + nepName + "'",
931 nepName, name.getValueName());
932 // TODO: depending on the type of node there is one type or another
933 assertThat("eODU nep should support 1, 2 or 3 kind of cep, depending on client port",
934 nep.getSupportedCepLayerProtocolQualifier().size(), anyOf(is(1), is(2), is(3)));
935 assertTrue("eODU nep should support 1 kind of cep",
936 nep.getSupportedCepLayerProtocolQualifier().stream().anyMatch(splc -> splc.equals(ODUTYPEODU0.class)
937 || splc.equals(ODUTYPEODU2.class) || splc.equals(ODUTYPEODU2E.class)
938 || splc.equals(ODUTYPEODU4.class)));
939 assertEquals("eODU nep should be of ODU protocol type", LayerProtocolName.ODU, nep.getLayerProtocolName());
940 checkCommonPartOfNep(nep, withSip);
943 private void checkNepNetworkODU4(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName,
945 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
946 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
947 Name name = nameList.get(0);
948 assertEquals("value of network nep should be '" + portName + "'",
949 portName, name.getValue());
950 assertEquals("value-name of network nep for '" + portName + "' should be '" + nepName + "'",
951 nepName, name.getValueName());
952 assertEquals("Network nep should support 1 kind of cep",
953 1, nep.getSupportedCepLayerProtocolQualifier().size());
954 assertThat("network nep should support 1 kind of cep",
955 nep.getSupportedCepLayerProtocolQualifier(),
956 hasItem(ODUTYPEODU4.class));
957 assertEquals("network nep should be of ODU protocol type", LayerProtocolName.ODU, nep.getLayerProtocolName());
958 checkCommonPartOfNep(nep, withSip);
961 private void checkNodeRuleGroupForTpdrDSR(List<NodeRuleGroup> nrgList, Uuid clientNepUuid, Uuid networkNepUuid,
963 assertEquals("transponder DSR should contain 2 node rule group", 2, nrgList.size());
964 for (NodeRuleGroup nodeRuleGroup : nrgList) {
965 assertEquals("each node-rule-group should contain 2 NEP for transponder DSR",
966 2, nodeRuleGroup.getNodeEdgePoint().size());
968 List<NodeEdgePoint> nodeEdgePointList = new ArrayList<>(nrgList.get(0).nonnullNodeEdgePoint().values());
969 assertThat("node-rule-group nb 1 should be between nep-client1 and nep-network1",
970 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
971 either(containsString(networkNepUuid.getValue())).or(containsString(clientNepUuid.getValue())));
972 assertThat("node-rule-group nb 1 should be between nep-client1 and nep-network1",
973 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
974 either(containsString(networkNepUuid.getValue())).or(containsString(clientNepUuid.getValue())));
975 assertEquals("node-rule-group nb 1 should be between nep-client1 and nep-network1 of the same node",
976 nodeEdgePointList.get(0).getNodeUuid(), nodeUuid);
977 assertEquals("node-rule-group nb 1 should be between nep-client1 and nep-network1 of the same node",
978 nodeEdgePointList.get(1).getNodeUuid(), nodeUuid);
979 List<Rule> rule = new ArrayList<>(nrgList.get(1).nonnullRule().values());
980 assertEquals("node-rule-group nb 1 should contain a single rule", 1, rule.size());
981 assertEquals("local-id of the rule should be 'forward'",
982 "forward", rule.get(0).getLocalId());
983 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
984 ForwardingRule.MAYFORWARDACROSSGROUP, rule.get(0).getForwardingRule());
985 assertEquals("the rule type should be 'FORWARDING'",
986 RuleType.FORWARDING, rule.get(0).getRuleType());
989 private void checkNodeRuleGroupForMuxDSR(List<NodeRuleGroup> nrgList, Uuid clientNepUuid, Uuid networkNepUuid,
991 assertEquals("muxponder DSR should contain 4 node rule group", 4, nrgList.size());
992 for (NodeRuleGroup nodeRuleGroup : nrgList) {
993 assertEquals("each node-rule-group should contain 2 NEP for muxponder DSR",
994 2, nodeRuleGroup.getNodeEdgePoint().size());
996 List<NodeEdgePoint> nodeEdgePointList = new ArrayList<>(nrgList.get(2).nonnullNodeEdgePoint().values());
997 assertThat("node-rule-group nb 2 should be between nep-client4 and nep-network1",
998 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
999 either(containsString(networkNepUuid.getValue())).or(containsString(clientNepUuid.getValue())));
1000 assertThat("node-rule-group nb 2 should be between nep-client4 and nep-network1",
1001 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1002 either(containsString(networkNepUuid.getValue())).or(containsString(clientNepUuid.getValue())));
1003 assertEquals("node-rule-group nb 2 should be between nep-client4 and nep-network1 of the same node",
1004 nodeEdgePointList.get(0).getNodeUuid(), nodeUuid);
1005 assertEquals("node-rule-group nb 2 should be between nep-client4 and nep-network1 of the same node",
1006 nodeEdgePointList.get(1).getNodeUuid(), nodeUuid);
1007 List<Rule> rule = new ArrayList<>(nrgList.get(1).nonnullRule().values());
1008 assertEquals("node-rule-group nb 2 should contain a single rule", 1, rule.size());
1009 assertEquals("local-id of the rule should be 'forward'",
1010 "forward", rule.get(0).getLocalId());
1011 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1012 ForwardingRule.MAYFORWARDACROSSGROUP, rule.get(0).getForwardingRule());
1013 assertEquals("the rule type should be 'FORWARDING'",
1014 RuleType.FORWARDING, rule.get(0).getRuleType());
1017 private void checkNodeRuleGroupForSwitchDSR(List<NodeRuleGroup> nrgList, Uuid clientNepUuid, Uuid networkNepUuid,
1019 assertEquals("Switch-DSR should contain a single node rule group", 1, nrgList.size());
1020 assertEquals("Switch-DSR node-rule-group should contain 8 NEP", 8, nrgList.get(0).getNodeEdgePoint().size());
1021 List<NodeEdgePoint> nrg = nrgList.get(0).nonnullNodeEdgePoint().values().stream()
1022 .sorted((nrg1, nrg2) -> nrg1.getNodeEdgePointUuid().getValue()
1023 .compareTo(nrg2.getNodeEdgePointUuid().getValue()))
1024 .collect(Collectors.toList());
1025 assertEquals("in the sorted node-rule-group, nep number 7 should be XPDR2-NETWORK1",
1026 networkNepUuid, nrg.get(6).getNodeEdgePointUuid());
1027 assertEquals("in the sorted node-rule-group, nep number 4 should be XPDR2-CLIENT4",
1028 clientNepUuid, nrg.get(3).getNodeEdgePointUuid());
1029 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1030 nodeUuid, nrg.get(4).getNodeUuid());
1031 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1032 nodeUuid, nrg.get(3).getNodeUuid());
1034 List<Rule> ruleList = new ArrayList<>(nrgList.get(0).nonnullRule().values());
1035 assertEquals("node-rule-group should contain a single rule", 1, ruleList.size());
1036 assertEquals("local-id of the rule should be 'forward'",
1037 "forward", ruleList.get(0).getLocalId());
1038 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1039 ForwardingRule.MAYFORWARDACROSSGROUP, ruleList.get(0).getForwardingRule());
1040 assertEquals("the rule type should be 'FORWARDING'",
1041 RuleType.FORWARDING, ruleList.get(0).getRuleType());
1044 private void checkNodeRuleGroupForRdm(List<NodeRuleGroup> nrgList, int nbNeps) {
1045 assertEquals("RDM infra node - OTSi should contain a single node rule groups", 1, nrgList.size());
1047 List<NodeEdgePoint> nodeEdgePointList = new ArrayList<>(nrgList.get(0).getNodeEdgePoint().values());
1048 assertEquals("RDM infra node -rule-group should contain " + nbNeps + " NEP",
1049 nbNeps, nodeEdgePointList.size());
1051 assertNull("RDM infra node -rule-group should contain no NEP", nrgList.get(0).getNodeEdgePoint());
1053 List<Rule> ruleList = new ArrayList<>(nrgList.get(0).nonnullRule().values());
1054 assertEquals("node-rule-group should contain a single rule", 1, ruleList.size());
1055 assertEquals("local-id of the rule should be 'forward'",
1056 "forward", ruleList.get(0).getLocalId());
1057 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1058 ForwardingRule.MAYFORWARDACROSSGROUP, ruleList.get(0).getForwardingRule());
1059 assertEquals("the rule type should be 'FORWARDING'",
1060 RuleType.FORWARDING, ruleList.get(0).getRuleType());
1063 private void checkNodeRuleGroupForTpdrOTSi(List<NodeRuleGroup> nrgList, Uuid enepUuid, Uuid inepUuid,
1065 assertEquals("Tpdr-OTSi should contain two node rule groups", 2, nrgList.size());
1066 List<NodeEdgePoint> nodeEdgePointList = new ArrayList<>(nrgList.get(0).getNodeEdgePoint().values());
1067 assertEquals("Tpdr-OTSi node-rule-group should contain 2 NEP", 2, nodeEdgePointList.size());
1068 assertThat("Tpdr-OTSi node-rule-group should be between eNEP and iNEP of XPDR1-NETWORK1",
1069 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
1070 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1071 assertThat("Tpdr-OTSi node-rule-group should be between eNEP and iNEP of XPDR1-NETWORK1",
1072 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1073 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1074 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1075 nodeUuid, nodeEdgePointList.get(0).getNodeUuid());
1076 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1077 nodeUuid, nodeEdgePointList.get(1).getNodeUuid());
1078 List<Rule> ruleList = new ArrayList<>(nrgList.get(0).nonnullRule().values());
1079 assertEquals("node-rule-group should contain a single rule", 1, ruleList.size());
1080 assertEquals("local-id of the rule should be 'forward'",
1081 "forward", ruleList.get(0).getLocalId());
1082 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1083 ForwardingRule.MAYFORWARDACROSSGROUP, ruleList.get(0).getForwardingRule());
1084 assertEquals("the rule type should be 'FORWARDING'",
1085 RuleType.FORWARDING, ruleList.get(0).getRuleType());
1088 private void checkNodeRuleGroupForMuxOTSi(List<NodeRuleGroup> nrgList, Uuid enepUuid, Uuid inepUuid,
1090 assertEquals("Mux-OTSi should contain a single node rule group", 1, nrgList.size());
1091 List<NodeEdgePoint> nodeEdgePointList = new ArrayList<>(nrgList.get(0).getNodeEdgePoint().values());
1092 assertEquals("Mux-OTSi node-rule-group should contain 2 NEP", 2, nodeEdgePointList.size());
1093 assertThat("Mux-OTSi node-rule-group should be between eNEP and iNEP of XPDR1-NETWORK1",
1094 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
1095 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1096 assertThat("Mux-OTSi node-rule-group should be between eNEP and iNEP of XPDR1-NETWORK1",
1097 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1098 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1099 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1100 nodeUuid, nodeEdgePointList.get(0).getNodeUuid());
1101 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1102 nodeUuid, nodeEdgePointList.get(1).getNodeUuid());
1103 List<Rule> ruleList = new ArrayList<>(nrgList.get(0).nonnullRule().values());
1104 assertEquals("node-rule-group should contain a single rule", 1, ruleList.size());
1105 assertEquals("local-id of the rule should be 'forward'",
1106 "forward", ruleList.get(0).getLocalId());
1107 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1108 ForwardingRule.MAYFORWARDACROSSGROUP, ruleList.get(0).getForwardingRule());
1109 assertEquals("the rule type should be 'FORWARDING'",
1110 RuleType.FORWARDING, ruleList.get(0).getRuleType());
1113 private void checkNodeRuleGroupForSwitchOTSi(List<NodeRuleGroup> nrgList, Uuid enepUuid, Uuid inepUuid,
1115 assertEquals("Switch-OTSi should contain 4 node rule group", 4, nrgList.size());
1116 for (NodeRuleGroup nodeRuleGroup : nrgList) {
1117 assertEquals("each node-rule-group should contain 2 NEP for Switch-OTSi",
1118 2, nodeRuleGroup.getNodeEdgePoint().size());
1120 List<NodeEdgePoint> nodeEdgePointList1 = new ArrayList<>(nrgList.get(3).nonnullNodeEdgePoint().values());
1121 assertThat("Switch-OTSi node-rule-group nb 4 should be between eNEP and iNEP of XPDR2-NETWORK2",
1122 nodeEdgePointList1.get(0).getNodeEdgePointUuid().getValue(),
1123 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1124 assertThat("Switch-OTSi node-rule-group nb 4 should be between eNEP and iNEP of XPDR2-NETWORK2",
1125 nodeEdgePointList1.get(1).getNodeEdgePointUuid().getValue(),
1126 either(containsString(enepUuid.getValue())).or(containsString(inepUuid.getValue())));
1127 List<NodeEdgePoint> nodeEdgePointList0 = new ArrayList<>(nrgList.get(0).getNodeEdgePoint().values());
1128 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1129 nodeUuid, nodeEdgePointList0.get(0).getNodeUuid());
1130 assertEquals("any item of the node-rule-group should have the same nodeUuid",
1131 nodeUuid, nodeEdgePointList0.get(1).getNodeUuid());
1132 List<Rule> ruleList0 = new ArrayList<>(nrgList.get(0).nonnullRule().values());
1133 assertEquals("node-rule-group should contain a single rule", 1, ruleList0.size());
1134 assertEquals("local-id of the rule should be 'forward'",
1135 "forward", ruleList0.get(0).getLocalId());
1136 assertEquals("the forwarding rule should be 'MAYFORWARDACROSSGROUP'",
1137 ForwardingRule.MAYFORWARDACROSSGROUP, ruleList0.get(0).getForwardingRule());
1138 assertEquals("the rule type should be 'FORWARDING'",
1139 RuleType.FORWARDING, ruleList0.get(0).getRuleType());
1142 private void checkNepClient100GSwitch(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName) {
1143 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
1144 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
1145 assertEquals("value of client nep should be '" + portName + "'",
1146 portName, nameList.get(0).getValue());
1147 assertEquals("value-name of client nep for '" + portName + "' should be '" + nepName + "'",
1148 nepName, nameList.get(0).getValueName());
1149 assertEquals("Client nep should support 2 kind of cep",
1150 2, nep.getSupportedCepLayerProtocolQualifier().size());
1151 assertThat("client nep should support 2 kind of cep",
1152 nep.getSupportedCepLayerProtocolQualifier(),
1153 hasItems(ODUTYPEODU4.class, DIGITALSIGNALTYPE100GigE.class));
1154 assertEquals("client nep should be of DSR protocol type", LayerProtocolName.DSR, nep.getLayerProtocolName());
1155 checkCommonPartOfNep(nep, false);
1158 private void checkNepClient100GTpdr(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName) {
1159 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
1160 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
1161 assertEquals("value of client nep should be '" + portName + "'",
1162 portName, nameList.get(0).getValue());
1163 assertEquals("value-name of client nep for '" + portName + "' should be 100G-tpdr'",
1164 nepName, nameList.get(0).getValueName());
1165 assertEquals("Client nep should support 1 kind of cep",
1166 1, nep.getSupportedCepLayerProtocolQualifier().size());
1167 assertThat("client nep should support 2 kind of cep",
1168 nep.getSupportedCepLayerProtocolQualifier(),
1169 hasItems(DIGITALSIGNALTYPE100GigE.class));
1170 assertEquals("client nep should be of DSR protocol type", LayerProtocolName.DSR, nep.getLayerProtocolName());
1171 checkCommonPartOfNep(nep, false);
1174 private void checkNepOtsiNode(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName,
1176 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
1177 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
1178 assertEquals("value of OTSi nep should be '" + portName + "'",
1179 portName, nameList.get(0).getValue());
1180 assertEquals("value-name of OTSi nep should be '" + nepName + "'",
1181 nepName, nameList.get(0).getValueName());
1182 assertEquals("OTSi nep should support 2 kind of cep",
1183 2, nep.getSupportedCepLayerProtocolQualifier().size());
1184 assertThat("OTSi nep should support 2 kind of cep",
1185 nep.getSupportedCepLayerProtocolQualifier(),
1186 hasItems(PHOTONICLAYERQUALIFIEROMS.class, PHOTONICLAYERQUALIFIEROTSi.class));
1187 assertEquals("OTSi nep should be of PHOTONIC_MEDIA protocol type",
1188 LayerProtocolName.PHOTONICMEDIA, nep.getLayerProtocolName());
1189 checkCommonPartOfNep(nep, withSip);
1192 private void checkNepOtsiRdmNode(OwnedNodeEdgePoint nep, Uuid nepUuid, String portName, String nepName,
1194 assertEquals("bad uuid for " + portName, nepUuid, nep.getUuid());
1195 List<Name> nameList = new ArrayList<>(nep.nonnullName().values());
1196 assertEquals("value of OTSi nep should be '" + portName + "'",
1197 portName, nameList.get(0).getValue());
1198 assertEquals("value-name of OTSi nep should be '" + nepName + "'",
1199 nepName, nameList.get(0).getValueName());
1200 assertEquals("OTSi nep of RDM infra node should support only 1 kind of cep",
1201 1, nep.getSupportedCepLayerProtocolQualifier().size());
1202 assertThat("OTSi nep should support 2 kind of cep",
1203 nep.getSupportedCepLayerProtocolQualifier(),
1204 hasItems(PHOTONICLAYERQUALIFIEROMS.class));
1205 assertEquals("OTSi nep should be of PHOTONIC_MEDIA protocol type",
1206 LayerProtocolName.PHOTONICMEDIA, nep.getLayerProtocolName());
1207 checkCommonPartOfNep(nep, withSip);
1210 private void checkCommonPartOfNep(OwnedNodeEdgePoint nep, boolean withSip) {
1211 assertEquals("link port direction should be DIRECTIONAL",
1212 PortDirection.BIDIRECTIONAL, nep.getLinkPortDirection());
1213 assertEquals("administrative state should be UNLOCKED",
1214 AdministrativeState.UNLOCKED, nep.getAdministrativeState());
1215 assertEquals("termination state should be TERMINATED BIDIRECTIONAL",
1216 TerminationState.TERMINATEDBIDIRECTIONAL, nep.getTerminationState());
1217 assertEquals("life-cycle state should be INSTALLED", LifecycleState.INSTALLED, nep.getLifecycleState());
1219 assertEquals("Given nep should support 1 SIP", 1, nep.getMappedServiceInterfacePoint().size());
1221 assertEquals("termination direction should be BIDIRECTIONAL",
1222 TerminationDirection.BIDIRECTIONAL, nep.getTerminationDirection());
1223 assertEquals("operational state of client nep should be ENABLED",
1224 OperationalState.ENABLED, nep.getOperationalState());
1225 assertEquals("link-port-role of client nep should be SYMMETRIC",
1226 PortRole.SYMMETRIC, nep.getLinkPortRole());
1229 private void checkTransitionalLink(org.opendaylight.yang.gen.v1
1230 .urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link link,
1231 Uuid node1Uuid, Uuid node2Uuid, String tp1, String tp2, String ietfNodeId) {
1232 Uuid linkUuid = new Uuid(UUID.nameUUIDFromBytes((tp1 + "to" + tp2)
1233 .getBytes(Charset.forName("UTF-8"))).toString());
1234 assertEquals("bad uuid for link between DSR node " + tp1 + " and iOTSI port " + tp2, linkUuid, link.getUuid());
1235 assertEquals("Available capacity unit should be GBPS",
1236 CapacityUnit.GBPS, link.getAvailableCapacity().getTotalSize().getUnit());
1237 assertEquals("Available capacity -total size value should be 100",
1238 Uint64.valueOf(100), link.getAvailableCapacity().getTotalSize().getValue());
1239 assertEquals("transitional link should be between 2 nodes of protocol layers ODU and PHOTONIC_MEDIA",
1240 2, link.getTransitionedLayerProtocolName().size());
1241 assertThat("transitional link should be between 2 nodes of protocol layers ODU and PHOTONIC_MEDIA",
1242 link.getTransitionedLayerProtocolName(),
1243 hasItems(LayerProtocolName.ODU.getName(), LayerProtocolName.PHOTONICMEDIA.getName()));
1244 assertEquals("transitional link should be BIDIRECTIONAL",
1245 ForwardingDirection.BIDIRECTIONAL, link.getDirection());
1246 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
1247 .link.NodeEdgePoint> nodeEdgePointList = new ArrayList<>(link.nonnullNodeEdgePoint().values());
1248 assertEquals("topology uuid should be the same for the two termination point of the link",
1249 topologyUuid, nodeEdgePointList.get(0).getTopologyUuid());
1250 assertEquals("topology uuid should be the same for the two termination point of the link",
1251 topologyUuid, nodeEdgePointList.get(1).getTopologyUuid());
1252 assertThat("transitional links should terminate on DSR node and Photonic node",
1253 nodeEdgePointList.get(0).getNodeUuid().getValue(),
1254 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1255 assertThat("transitional links should terminate on DSR node and Photonic node",
1256 nodeEdgePointList.get(1).getNodeUuid().getValue(),
1257 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1258 Uuid nep1Uuid = new Uuid(UUID.nameUUIDFromBytes(tp1.getBytes(Charset.forName("UTF-8"))).toString());
1259 Uuid nep2Uuid = new Uuid(UUID.nameUUIDFromBytes(tp2.getBytes(Charset.forName("UTF-8"))).toString());
1260 assertThat("transitional links should terminate on " + tp1 + " and " + tp2 + " neps",
1261 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
1262 either(containsString(nep1Uuid.getValue())).or(containsString(nep2Uuid.getValue())));
1263 assertThat("transitional links should terminate on DSR node and Photonic node",
1264 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1265 either(containsString(nep1Uuid.getValue())).or(containsString(nep2Uuid.getValue())));
1269 private void checkOmsLink(org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210.topology.Link link,
1270 Uuid node1Uuid, Uuid node2Uuid, Uuid tp1Uuid, Uuid tp2Uuid, Uuid linkUuid,
1272 assertEquals("bad name for the link", linkName, link.getName().get(
1273 new NameKey("OMS link name")).getValue());
1274 assertEquals("bad uuid for link", linkUuid, link.getUuid());
1275 assertEquals("oms link should be between 2 nodes of protocol layers PHOTONIC_MEDIA",
1276 LayerProtocolName.PHOTONICMEDIA.getName(),
1277 link.getLayerProtocolName().stream().findFirst().get().getName());
1278 assertEquals("otn tapi link should be BIDIRECTIONAL",
1279 ForwardingDirection.BIDIRECTIONAL, link.getDirection());
1280 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
1281 .link.NodeEdgePoint> nodeEdgePointList = new ArrayList<>(link.nonnullNodeEdgePoint().values());
1282 assertEquals("oms link should be between 2 neps",2 , nodeEdgePointList.size());
1283 assertEquals("topology uuid should be the same for the two termination point of the link",
1284 topologyUuid, nodeEdgePointList.get(0).getTopologyUuid());
1285 assertEquals("topology uuid should be the same for the two termination point of the link",
1286 topologyUuid, nodeEdgePointList.get(1).getTopologyUuid());
1287 assertThat("oms links should terminate on two distinct nodes",
1288 nodeEdgePointList.get(0).getNodeUuid().getValue(),
1289 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1290 assertThat("oms links should terminate on two distinct nodes",
1291 nodeEdgePointList.get(1).getNodeUuid().getValue(),
1292 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1293 assertThat("oms links should terminate on two distinct tps",
1294 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1295 either(containsString(tp1Uuid.getValue())).or(containsString(tp2Uuid.getValue())));
1296 assertThat("oms links should terminate on two distinct tps",
1297 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
1298 either(containsString(tp1Uuid.getValue())).or(containsString(tp2Uuid.getValue())));
1301 private void checkXpdrRdmLink(org.opendaylight.yang.gen.v1.urn
1302 .onf.otcc.yang.tapi.topology.rev181210.topology.Link link,
1303 Uuid node1Uuid, Uuid node2Uuid, Uuid tp1Uuid, Uuid tp2Uuid, Uuid linkUuid,
1305 assertEquals("bad name for the link", linkName, link.getName().get(
1306 new NameKey("XPDR-RDM link name")).getValue());
1307 assertEquals("bad uuid for link", linkUuid, link.getUuid());
1308 assertEquals("oms link should be between 2 nodes of protocol layers PHOTONIC_MEDIA",
1309 LayerProtocolName.PHOTONICMEDIA.getName(),
1310 link.getLayerProtocolName().stream().findFirst().get().getName());
1311 assertEquals("otn tapi link should be BIDIRECTIONAL",
1312 ForwardingDirection.BIDIRECTIONAL, link.getDirection());
1313 List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev181210
1314 .link.NodeEdgePoint> nodeEdgePointList = new ArrayList<>(link.nonnullNodeEdgePoint().values());
1315 assertEquals("oms link should be between 2 neps",2 , nodeEdgePointList.size());
1316 assertEquals("topology uuid should be the same for the two termination point of the link",
1317 topologyUuid, nodeEdgePointList.get(0).getTopologyUuid());
1318 assertEquals("topology uuid should be the same for the two termination point of the link",
1319 topologyUuid, nodeEdgePointList.get(1).getTopologyUuid());
1320 assertThat("oms links should terminate on two distinct nodes",
1321 nodeEdgePointList.get(0).getNodeUuid().getValue(),
1322 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1323 assertThat("oms links should terminate on two distinct nodes",
1324 nodeEdgePointList.get(1).getNodeUuid().getValue(),
1325 either(containsString(node1Uuid.getValue())).or(containsString(node2Uuid.getValue())));
1326 assertThat("oms links should terminate on two distinct tps",
1327 nodeEdgePointList.get(0).getNodeEdgePointUuid().getValue(),
1328 either(containsString(tp1Uuid.getValue())).or(containsString(tp2Uuid.getValue())));
1329 assertThat("oms links should terminate on two distinct tps",
1330 nodeEdgePointList.get(1).getNodeEdgePointUuid().getValue(),
1331 either(containsString(tp1Uuid.getValue())).or(containsString(tp2Uuid.getValue())));
1334 private Node changeTerminationPointState(Node initialNode, String tpid, String tpid1, AdminStates admin,
1336 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder tpdr1Bldr
1337 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder(
1338 initialNode.augmentation(Node1.class));
1339 Map<TerminationPointKey, TerminationPoint> tps = new HashMap<>(tpdr1Bldr.getTerminationPoint());
1340 TerminationPointBuilder tpBldr = new TerminationPointBuilder(
1341 tps.get(new TerminationPointKey(new TpId(tpid))));
1342 tpBldr.addAugmentation(new TerminationPoint1Builder(tpBldr.augmentation(TerminationPoint1.class))
1343 .setAdministrativeState(admin)
1344 .setOperationalState(oper)
1346 tps.replace(tpBldr.key(), tpBldr.build());
1347 TerminationPointBuilder tpBldr1 = new TerminationPointBuilder(
1348 tps.get(new TerminationPointKey(new TpId(tpid1))));
1349 tpBldr1.addAugmentation(new TerminationPoint1Builder(tpBldr1.augmentation(TerminationPoint1.class))
1350 .setAdministrativeState(admin)
1351 .setOperationalState(oper)
1353 tps.replace(tpBldr1.key(), tpBldr1.build());
1354 tpdr1Bldr.setTerminationPoint(tps);
1355 return new NodeBuilder(initialNode).addAugmentation(tpdr1Bldr.build()).build();