2 * Copyright © 2018 Orange Systems, 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.renderer;
10 import java.util.ArrayList;
11 import java.util.Arrays;
12 import java.util.Collection;
13 import java.util.List;
15 import java.util.concurrent.ExecutionException;
16 import org.junit.Assert;
17 import org.junit.Before;
18 import org.junit.Ignore;
19 import org.junit.Test;
20 import org.junit.runner.RunWith;
21 import org.junit.runners.Parameterized;
22 import org.opendaylight.transportpce.common.StringConstants;
23 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
24 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
25 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
26 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
27 import org.opendaylight.transportpce.renderer.utils.ServiceDeleteDataUtils;
28 import org.opendaylight.transportpce.renderer.utils.WaveLengthServiceUtils;
29 import org.opendaylight.transportpce.test.AbstractTest;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengths;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsBuilder;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1Builder;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.CpAttributesBuilder;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.CtpAttributesBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.PpAttributesBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.RxTtpAttributesBuilder;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.TxTtpAttributesBuilder;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrClientAttributesBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrNetworkAttributesBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrPortAttributesBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
48 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev200128.service.path.PathDescription;
49 import org.opendaylight.yangtools.yang.common.Uint32;
52 @RunWith(Parameterized.class)
53 public class NetworkModelWaveLengthServiceUseTest extends AbstractTest {
55 private NetworkModelWavelengthService networkModelWavelengthService;
56 private DeviceTransactionManager deviceTransactionManager;
58 private TerminationPoint1 terminationPoint1;
59 private org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1 terminatPoint2;
60 private PathDescription pathDescription;
62 private org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 node2;
65 public void setMountPoint() {
66 MountPointServiceStub mountPointService = new MountPointServiceStub(new MountPointStub(this.getDataBroker()));
67 this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
68 networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(this.getDataBroker());
71 public NetworkModelWaveLengthServiceUseTest(PathDescription pathDescription, TerminationPoint1 terminationPoint1,
73 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1 terminationPoint2,
74 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 node2) {
75 this.pathDescription = pathDescription;
76 this.terminationPoint1 = terminationPoint1;
77 this.terminatPoint2 = terminationPoint2;
82 @Parameterized.Parameters
83 public static Collection createParameters() {
84 List<Object[]> parameters = new ArrayList<>();
86 PathDescription pathDescription =
87 ServiceDeleteDataUtils.createTransactionPathDescription(StringConstants.TTP_TOKEN);
89 TerminationPoint1Builder terminationPoint1Builder = new TerminationPoint1Builder()
90 .setCtpAttributes((new CtpAttributesBuilder()).setUsedWavelengths(Map.of()).build())
91 .setCpAttributes((new CpAttributesBuilder()).setUsedWavelengths(Map.of()).build())
92 .setTxTtpAttributes((new TxTtpAttributesBuilder()).setUsedWavelengths(Map.of()).build())
93 .setRxTtpAttributes((new RxTtpAttributesBuilder()).setUsedWavelengths(Map.of()).build())
94 .setPpAttributes((new PpAttributesBuilder()).setUsedWavelength(Map.of()).build())
95 .setXpdrClientAttributes((new XpdrClientAttributesBuilder()).build())
96 .setXpdrNetworkAttributes((new XpdrNetworkAttributesBuilder()).build())
97 .setXpdrPortAttributes((new XpdrPortAttributesBuilder()).build());
99 AvailableWavelengths aval = new AvailableWavelengthsBuilder().setIndex(Uint32.valueOf(20)).build();
100 org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes.AvailableWavelengths avalSrg =
101 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
102 .AvailableWavelengthsBuilder().setIndex(Uint32.valueOf(20)).build();
103 Node1Builder node1Builder = new Node1Builder()
104 .setDegreeAttributes((new DegreeAttributesBuilder())
105 .setAvailableWavelengths(
106 Map.of(aval.key(),aval))
108 .setSrgAttributes((new SrgAttributesBuilder())
109 .setAvailableWavelengths(
110 Map.of(avalSrg.key(),avalSrg))
113 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder
114 terminationPoint2Builder =
115 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder();
117 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder node2Builder =
118 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder();
120 for (OpenroadmNodeType nodeType : Arrays
121 .asList(OpenroadmNodeType.XPONDER, OpenroadmNodeType.DEGREE, OpenroadmNodeType.SRG)) {
122 node2Builder.setNodeType(nodeType);
123 terminationPoint2Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
124 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build(),
125 terminationPoint2Builder.build(), node2Builder.build() });
128 for (OpenroadmTpType tpType : OpenroadmTpType.values()) {
129 node2Builder.setNodeType(OpenroadmNodeType.DEGREE);
130 terminationPoint2Builder.setTpType(tpType);
131 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build(),
132 terminationPoint2Builder.build(), node2Builder.build() });
139 public void freeWavelengthsTest() throws ExecutionException, InterruptedException {
140 WaveLengthServiceUtils.putTerminationPoint1ToDatastore("node1" + StringConstants.TTP_TOKEN,
141 StringConstants.TTP_TOKEN, this.terminationPoint1, this.deviceTransactionManager);
142 WaveLengthServiceUtils.putTerminationPoint2ToDatastore("node1" + StringConstants.TTP_TOKEN,
143 StringConstants.TTP_TOKEN, this.terminatPoint2, this.deviceTransactionManager);
144 WaveLengthServiceUtils.putNode1ToDatastore("node1" + StringConstants.TTP_TOKEN, this.node1,
145 this.deviceTransactionManager);
146 WaveLengthServiceUtils.putNode2ToDatastore("node1" + StringConstants.TTP_TOKEN, this.node2,
147 this.deviceTransactionManager);
148 this.networkModelWavelengthService.useWavelengths(this.pathDescription);
149 Node1 updatedNode1 = WaveLengthServiceUtils.getNode1FromDatastore("node1" + StringConstants.TTP_TOKEN,
150 this.deviceTransactionManager);
151 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 updatedNode2 =
152 WaveLengthServiceUtils.getNode2FromDatastore("node1" + StringConstants.TTP_TOKEN,
153 this.deviceTransactionManager);
154 TerminationPoint1 updatedTerminationPoint1 = WaveLengthServiceUtils
155 .getTerminationPoint1FromDatastore("node1" + StringConstants.TTP_TOKEN, StringConstants.TTP_TOKEN,
156 this.deviceTransactionManager);
157 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
158 .TerminationPoint1 updatedTerminationPoint2 = WaveLengthServiceUtils
159 .getTerminationPoint2FromDatastore("node1" + StringConstants.TTP_TOKEN, StringConstants.TTP_TOKEN,
160 this.deviceTransactionManager);
162 switch (updatedTerminationPoint2.getTpType()) {
163 //switch (((org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1)
164 // updatedTerminationPoint1).getTpType()) {
168 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
169 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
170 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
171 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
172 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
173 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
174 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
175 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
180 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
181 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
182 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
183 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
184 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
185 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
186 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
187 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
191 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
192 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
193 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
194 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
195 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
196 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
197 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
198 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
201 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
202 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
203 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
204 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
205 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
206 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
207 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
208 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
213 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
214 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
215 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
216 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
217 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
218 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
219 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
220 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
223 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
224 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
225 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
226 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
227 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
228 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes());
229 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
230 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
233 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
234 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
235 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
236 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
237 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
238 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
239 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes());
240 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
243 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
244 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
245 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
246 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
247 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
248 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
249 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
250 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes());
253 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
254 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
255 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
256 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
257 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
258 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
259 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
260 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
263 switch (updatedNode2.getNodeType()) {
264 //switch (((org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1) updatedNode1)
267 Assert.assertNull(updatedNode1.getDegreeAttributes());
268 Assert.assertFalse(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());
271 Assert.assertNull(updatedNode1.getSrgAttributes());
272 Assert.assertFalse(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
275 Assert.assertFalse(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
276 Assert.assertFalse(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());