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
9 package org.opendaylight.transportpce.renderer.provisiondevice;
11 import java.util.ArrayList;
12 import java.util.List;
14 import org.junit.Assert;
15 import org.junit.Test;
16 import org.mockito.Mockito;
17 import org.opendaylight.controller.md.sal.binding.api.MountPoint;
18 import org.opendaylight.controller.md.sal.binding.api.MountPointService;
19 import org.opendaylight.transportpce.common.StringConstants;
20 import org.opendaylight.transportpce.common.crossconnect.CrossConnect;
21 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
22 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121;
23 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl22;
24 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
25 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
26 import org.opendaylight.transportpce.common.mapping.MappingUtils;
27 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
28 import org.opendaylight.transportpce.common.mapping.PortMapping;
29 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
30 import org.opendaylight.transportpce.common.mapping.PortMappingVersion121;
31 import org.opendaylight.transportpce.common.mapping.PortMappingVersion22;
32 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
33 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
34 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
35 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
36 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl22;
37 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
38 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
39 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
40 import org.opendaylight.transportpce.renderer.utils.ServiceImplementationDataUtils;
41 import org.opendaylight.transportpce.test.AbstractTest;
42 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.RendererRollbackInput;
43 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.RendererRollbackInputBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev170228.RendererRollbackOutput;
45 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.node.interfaces.NodeInterface;
46 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.node.interfaces.NodeInterfaceBuilder;
47 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.node.interfaces.NodeInterfaceKey;
49 public class DeviceRendererServiceImplRollbackTest extends AbstractTest {
51 private DeviceRendererService deviceRendererService;
52 private CrossConnect crossConnect;
53 private OpenRoadmInterfaces openRoadmInterfaces;
54 private MappingUtils mappingUtils;
55 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
56 private OpenRoadmInterfacesImpl22 openRoadmInterfacesImpl22;
57 private PortMappingVersion22 portMappingVersion22;
58 private PortMappingVersion121 portMappingVersion121;
59 private CrossConnectImpl121 crossConnectImpl121;
60 private CrossConnectImpl22 crossConnectImpl22;
62 private void setMountPoint(MountPoint mountPoint) {
63 MountPointService mountPointService = new MountPointServiceStub(mountPoint);
64 DeviceTransactionManager deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
65 this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
66 this.openRoadmInterfacesImpl22 = new OpenRoadmInterfacesImpl22(deviceTransactionManager);
67 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
68 this.mappingUtils = Mockito.spy(this.mappingUtils);
69 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
70 openRoadmInterfacesImpl121, openRoadmInterfacesImpl22);
71 this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
72 this.portMappingVersion22 =
73 new PortMappingVersion22(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
74 this.portMappingVersion121 = new PortMappingVersion121(getDataBroker(), deviceTransactionManager,
75 this.openRoadmInterfaces);
76 this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
77 this.crossConnectImpl22 = new CrossConnectImpl22(deviceTransactionManager);
78 this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
79 this.crossConnectImpl22);
80 this.crossConnect = Mockito.spy(this.crossConnect);
81 PortMapping portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion22, this.mappingUtils,
82 this.portMappingVersion121);
83 OpenRoadmInterfaceFactory openRoadmInterfaceFactory =
84 new OpenRoadmInterfaceFactory(portMapping, this.openRoadmInterfaces);
85 this.deviceRendererService = new DeviceRendererServiceImpl(this.getDataBroker(),
86 deviceTransactionManager, openRoadmInterfaceFactory, this.openRoadmInterfaces, this.crossConnect,
93 public void testRollbackEmptyInterface() {
94 setMountPoint(new MountPointStub(getDataBroker()));
95 RendererRollbackInput rendererRollbackInput = ServiceImplementationDataUtils.buildRendererRollbackInput();
96 RendererRollbackOutput rendererRollbackOutput =
97 this.deviceRendererService.rendererRollback(rendererRollbackInput);
98 Assert.assertTrue(rendererRollbackOutput.isSuccess());
99 Assert.assertTrue(rendererRollbackOutput.getFailedToRollback().isEmpty());
103 public void testRollbackConnectionIdNotExist() {
104 setMountPoint(new MountPointStub(getDataBroker()));
106 NodeInterfaceBuilder nodeInterfaceBuilder = new NodeInterfaceBuilder();
107 nodeInterfaceBuilder.setNodeId("node1");
108 nodeInterfaceBuilder.withKey(new NodeInterfaceKey("node1"));
109 List<String> connectionID = new ArrayList<>();
110 connectionID.add("node1-PP");
111 nodeInterfaceBuilder.setConnectionId(connectionID);
112 List<NodeInterface> nodeInterfaces = new ArrayList<>();
113 nodeInterfaces.add(nodeInterfaceBuilder.build());
114 RendererRollbackInputBuilder rendererRollbackInputBuilder = new RendererRollbackInputBuilder();
115 rendererRollbackInputBuilder.setNodeInterface(nodeInterfaces);
116 Mockito.doReturn(StringConstants.OPENROADM_DEVICE_VERSION_1_2_1).when(this.mappingUtils)
117 .getOpenRoadmVersion("node1");
118 RendererRollbackOutput rendererRollbackOutput =
119 this.deviceRendererService.rendererRollback(rendererRollbackInputBuilder.build());
120 Assert.assertFalse(rendererRollbackOutput.isSuccess());
121 Assert.assertEquals(1, rendererRollbackOutput.getFailedToRollback().size());
122 Assert.assertEquals("node1", rendererRollbackOutput.getFailedToRollback().get(0).getNodeId());
126 public void testRollbackConnectionId() {
127 setMountPoint(new MountPointStub(getDataBroker()));
129 NodeInterfaceBuilder nodeInterfaceBuilder = new NodeInterfaceBuilder();
130 nodeInterfaceBuilder.setNodeId("node1");
131 nodeInterfaceBuilder.withKey(new NodeInterfaceKey("node1"));
132 List<String> connectionID = new ArrayList<>();
133 connectionID.add("src-PP-dest-PP-20");
134 nodeInterfaceBuilder.setConnectionId(connectionID);
135 List<NodeInterface> nodeInterfaces = new ArrayList<>();
136 nodeInterfaces.add(nodeInterfaceBuilder.build());
137 RendererRollbackInputBuilder rendererRollbackInputBuilder = new RendererRollbackInputBuilder();
138 rendererRollbackInputBuilder.setNodeInterface(nodeInterfaces);
140 Mockito.doReturn(true).when(this.crossConnect).deleteCrossConnect("node1", connectionID.get(0));
141 RendererRollbackOutput rendererRollbackOutput =
142 this.deviceRendererService.rendererRollback(rendererRollbackInputBuilder.build());
143 Assert.assertTrue("Rollback must success when cross connect returns true", rendererRollbackOutput.isSuccess());
144 Assert.assertEquals(1, rendererRollbackOutput.getFailedToRollback().size());
145 Assert.assertTrue("There must not be any failed interfaces when cross connect returns true",
146 rendererRollbackOutput.getFailedToRollback().get(0).getInterface().isEmpty());
148 Mockito.doReturn(false).when(this.crossConnect).deleteCrossConnect("node1", connectionID.get(0));
149 rendererRollbackOutput =
150 this.deviceRendererService.rendererRollback(rendererRollbackInputBuilder.build());
151 Assert.assertFalse("Rollback must fail when cross connect returns false",rendererRollbackOutput.isSuccess());
152 Assert.assertEquals(1, rendererRollbackOutput.getFailedToRollback().size());
153 Assert.assertFalse(rendererRollbackOutput.getFailedToRollback().get(0).getInterface().isEmpty());
154 Assert.assertEquals("node1", rendererRollbackOutput.getFailedToRollback().get(0).getNodeId());
156 Mockito.verify(this.crossConnect, Mockito.times(2)).deleteCrossConnect("node1", connectionID.get(0));
160 public void testRollbackInterfaces() throws OpenRoadmInterfaceException {
161 setMountPoint(new MountPointStub(getDataBroker()));
163 NodeInterfaceBuilder nodeInterfaceBuilder = new NodeInterfaceBuilder();
164 nodeInterfaceBuilder.setNodeId("node1");
165 nodeInterfaceBuilder.withKey(new NodeInterfaceKey("node1"));
166 nodeInterfaceBuilder.setConnectionId(new ArrayList<>());
167 List<String> oduInterfacesId = new ArrayList<>();
168 oduInterfacesId.add("node1-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN + "-ODU");
169 nodeInterfaceBuilder.setOduInterfaceId(oduInterfacesId);
170 List<String> otuInterfacesId = new ArrayList<>();
171 otuInterfacesId.add("node1-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN + "-OTU");
172 nodeInterfaceBuilder.setOtuInterfaceId(otuInterfacesId);
173 List<String> ochInterfacesId = new ArrayList<>();
174 ochInterfacesId.add("node1-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN + "-20");
175 nodeInterfaceBuilder.setOchInterfaceId(ochInterfacesId);
176 List<NodeInterface> nodeInterfaces = new ArrayList<>();
177 nodeInterfaces.add(nodeInterfaceBuilder.build());
178 RendererRollbackInputBuilder rendererRollbackInputBuilder = new RendererRollbackInputBuilder();
179 rendererRollbackInputBuilder.setNodeInterface(nodeInterfaces);
181 Mockito.doNothing().when(this.openRoadmInterfaces).deleteInterface(Mockito.eq("node1"), Mockito.anyString());
182 RendererRollbackOutput rendererRollbackOutput =
183 this.deviceRendererService.rendererRollback(rendererRollbackInputBuilder.build());
184 Assert.assertTrue(rendererRollbackOutput.isSuccess());
185 Assert.assertFalse(rendererRollbackOutput.getFailedToRollback().isEmpty());
186 Assert.assertTrue(rendererRollbackOutput.getFailedToRollback().get(0).getInterface().isEmpty());
187 Mockito.verify(this.crossConnect, Mockito.times(0)).deleteCrossConnect(Mockito.anyString(),
188 Mockito.anyString());
189 Mockito.verify(this.openRoadmInterfaces, Mockito.times(3)).deleteInterface(Mockito.eq("node1"),
190 Mockito.anyString());
194 public void testRollbackInterfacesException() throws OpenRoadmInterfaceException {
195 setMountPoint(new MountPointStub(getDataBroker()));
197 NodeInterfaceBuilder nodeInterfaceBuilder = new NodeInterfaceBuilder();
198 nodeInterfaceBuilder.setNodeId("node1");
199 nodeInterfaceBuilder.withKey(new NodeInterfaceKey("node1"));
200 nodeInterfaceBuilder.setConnectionId(new ArrayList<>());
201 List<String> ethInterfacesId = new ArrayList<>();
202 ethInterfacesId.add("node1-" + OpenRoadmInterfacesImpl.CLIENT_TOKEN + "-ETHERNET");
203 nodeInterfaceBuilder.setEthInterfaceId(ethInterfacesId);
204 List<NodeInterface> nodeInterfaces = new ArrayList<>();
205 nodeInterfaces.add(nodeInterfaceBuilder.build());
206 RendererRollbackInputBuilder rendererRollbackInputBuilder = new RendererRollbackInputBuilder();
207 rendererRollbackInputBuilder.setNodeInterface(nodeInterfaces);
209 Mockito.doThrow(OpenRoadmInterfaceException.class).when(this.openRoadmInterfaces)
210 .deleteInterface(Mockito.eq("node1"), Mockito.anyString());
211 RendererRollbackOutput rendererRollbackOutput =
212 this.deviceRendererService.rendererRollback(rendererRollbackInputBuilder.build());
213 Assert.assertFalse(rendererRollbackOutput.isSuccess());
214 Assert.assertEquals(1,rendererRollbackOutput.getFailedToRollback().size());
215 Assert.assertEquals(1, rendererRollbackOutput.getFailedToRollback().get(0).getInterface().size());
216 Assert.assertEquals(ethInterfacesId.get(0), rendererRollbackOutput.getFailedToRollback().get(0)
217 .getInterface().get(0));
218 Mockito.verify(this.crossConnect, Mockito.times(0))
219 .deleteCrossConnect(Mockito.anyString(), Mockito.anyString());
220 Mockito.verify(this.openRoadmInterfaces, Mockito.times(1))
221 .deleteInterface("node1",ethInterfacesId.get(0));