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.provisiondevice;
10 import static org.junit.jupiter.api.Assertions.assertEquals;
11 import static org.mockito.ArgumentMatchers.any;
12 import static org.mockito.ArgumentMatchers.anyBoolean;
13 import static org.mockito.ArgumentMatchers.anyString;
14 import static org.mockito.ArgumentMatchers.eq;
15 import static org.mockito.Mockito.doNothing;
16 import static org.mockito.Mockito.doReturn;
17 import static org.mockito.Mockito.mock;
18 import static org.mockito.Mockito.spy;
19 import static org.mockito.Mockito.when;
21 import java.util.ArrayList;
22 import java.util.List;
23 import java.util.concurrent.ExecutionException;
24 import org.junit.jupiter.api.BeforeEach;
25 import org.junit.jupiter.api.Test;
26 import org.opendaylight.mdsal.binding.api.MountPoint;
27 import org.opendaylight.mdsal.binding.api.MountPointService;
28 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
29 import org.opendaylight.transportpce.common.ResponseCodes;
30 import org.opendaylight.transportpce.common.StringConstants;
31 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
32 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
33 import org.opendaylight.transportpce.common.mapping.MappingUtils;
34 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
35 import org.opendaylight.transportpce.common.mapping.PortMapping;
36 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
37 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
38 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
39 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
40 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221;
41 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl710;
42 import org.opendaylight.transportpce.renderer.provisiondevice.notification.NotificationSender;
43 import org.opendaylight.transportpce.renderer.stub.OlmServiceStub;
44 import org.opendaylight.transportpce.renderer.utils.NotificationPublishServiceMock;
45 import org.opendaylight.transportpce.renderer.utils.ServiceDataUtils;
46 import org.opendaylight.transportpce.test.AbstractTest;
47 import org.opendaylight.transportpce.test.stub.MountPointServiceStub;
48 import org.opendaylight.transportpce.test.stub.MountPointStub;
49 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev211004.ServicePathOutputBuilder;
50 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmInput;
51 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmInputBuilder;
52 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmOutput;
53 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmOutputBuilder;
54 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.TransportpceOlmService;
55 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.get.pm.output.Measurements;
56 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.get.pm.output.MeasurementsBuilder;
57 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestInput;
58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestOutput;
59 import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
60 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev220926.PmGranularity;
61 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev220926.olm.get.pm.input.ResourceIdentifierBuilder;
62 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
64 public class RendererServiceOperationsImplTest extends AbstractTest {
66 private MountPointService mountPointService;
67 private DeviceTransactionManager deviceTransactionManager;
68 private final DeviceRendererService deviceRenderer = mock(DeviceRendererService.class);
69 private final OtnDeviceRendererService otnDeviceRendererService = mock(OtnDeviceRendererService.class);
70 private final PortMapping portMapping = mock(PortMapping.class);
71 private RendererServiceOperationsImpl rendererServiceOperations;
72 private OpenRoadmInterfaces openRoadmInterfaces;
73 private TransportpceOlmService olmService;
74 private MappingUtils mappingUtils;
75 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
76 private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
77 private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
79 private void setMountPoint(MountPoint mountPoint) {
80 this.mountPointService = new MountPointServiceStub(mountPoint);
81 this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
82 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
83 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
84 openRoadmInterfacesImpl121, openRoadmInterfacesImpl221, openRoadmInterfacesImpl710);
85 this.openRoadmInterfaces = spy(this.openRoadmInterfaces);
89 void setUp() throws OpenRoadmInterfaceException {
90 setMountPoint(new MountPointStub(getDataBroker()));
91 this.olmService = new OlmServiceStub();
92 doNothing().when(this.openRoadmInterfaces).postEquipmentState(anyString(), anyString(), anyBoolean());
93 NotificationPublishService notificationPublishService = new NotificationPublishServiceMock();
94 this.olmService = spy(this.olmService);
95 this.rendererServiceOperations = new RendererServiceOperationsImpl(deviceRenderer, otnDeviceRendererService,
96 this.olmService, getDataBroker(), new NotificationSender(notificationPublishService), portMapping);
100 void serviceImplementationTerminationPointAsResourceTtp() throws InterruptedException, ExecutionException {
101 ServiceImplementationRequestInput input = ServiceDataUtils
102 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
103 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
105 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
106 ServiceImplementationRequestOutput result =
107 this.rendererServiceOperations.serviceImplementation(input, false).get();
108 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
112 void serviceImplementationTerminationPointAsResourceTtp2() throws InterruptedException, ExecutionException {
113 ServiceImplementationRequestInput input = ServiceDataUtils
114 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
115 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
117 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
118 doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService).servicePowerSetup(any());
119 ServiceImplementationRequestOutput result =
120 this.rendererServiceOperations.serviceImplementation(input, false).get();
121 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
125 void serviceImplementationTerminationPointAsResourcePp() throws InterruptedException, ExecutionException {
126 ServiceImplementationRequestInput input = ServiceDataUtils
127 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.PP_TOKEN);
128 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
130 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
131 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
133 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
137 void serviceImplementationTerminationPointAsResourceNetwork() throws InterruptedException, ExecutionException {
138 ServiceImplementationRequestInput input = ServiceDataUtils
139 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
140 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
142 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
143 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
145 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
149 void serviceImplementationTerminationPointAsResourceClient() throws InterruptedException, ExecutionException {
150 ServiceImplementationRequestInput input = ServiceDataUtils
151 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.CLIENT_TOKEN);
152 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
154 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
155 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
157 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
161 void serviceImplementationTerminationPointAsResourceNoMapping() throws InterruptedException, ExecutionException {
162 String[] interfaceTokens = {
163 StringConstants.NETWORK_TOKEN,
164 StringConstants.CLIENT_TOKEN,
165 StringConstants.TTP_TOKEN,
166 StringConstants.PP_TOKEN
169 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("failed")
171 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
173 for (String tpToken : interfaceTokens) {
174 ServiceImplementationRequestInput input = ServiceDataUtils
175 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
176 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
179 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
184 void serviceImplementationRollbackAllNecessary() throws InterruptedException, ExecutionException {
185 ServiceImplementationRequestInput input = ServiceDataUtils
186 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
187 // writePortMapping(input, StringConstants.NETWORK_TOKEN);
188 doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService).servicePowerSetup(any());
189 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
191 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
195 void serviceImplementationServiceInActive() throws InterruptedException, ExecutionException {
196 ServiceImplementationRequestInput input = ServiceDataUtils
197 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
198 List<Measurements> measurementsList = new ArrayList<Measurements>();
199 measurementsList.add(new MeasurementsBuilder()
200 .setPmparameterName("FECUncorrectableBlocks")
201 .setPmparameterValue("1")
203 GetPmOutput getPmOutput = new GetPmOutputBuilder()
205 .setMeasurements(measurementsList)
207 doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService).getPm(any());
208 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
210 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
214 void serviceImplementationServiceInActive2() throws InterruptedException, ExecutionException {
215 ServiceImplementationRequestInput input = ServiceDataUtils
216 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
217 List<Measurements> measurementsList = new ArrayList<Measurements>();
218 measurementsList.add(new MeasurementsBuilder()
219 .setPmparameterName("FECUncorrectableBlocks")
220 .setPmparameterValue("1")
222 GetPmOutput getPmOutput = new GetPmOutputBuilder()
224 .setMeasurements(measurementsList)
227 when(this.olmService.getPm(any())).thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
228 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
230 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
234 void serviceImplementationServiceInActive3() throws InterruptedException, ExecutionException {
235 List<Measurements> measurementsList = new ArrayList<Measurements>();
236 measurementsList.add(new MeasurementsBuilder()
237 .setPmparameterName("FECUncorrectableBlocks")
238 .setPmparameterValue("1")
240 GetPmOutput getPmOutput = new GetPmOutputBuilder().setNodeId("node1").setMeasurements(measurementsList).build();
241 GetPmOutput getPmOutput2 = new GetPmOutputBuilder().setNodeId("node1").setMeasurements(new ArrayList<>())
244 GetPmInput getPmInputZ = createGetPmInput("XPONDER-2-3", StringConstants.NETWORK_TOKEN);
245 GetPmInput getPmInputA = createGetPmInput("XPONDER-1-2", StringConstants.NETWORK_TOKEN);
247 when(this.olmService.getPm(eq(getPmInputZ))).thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
248 when(this.olmService.getPm(eq(getPmInputA))).thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
249 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
251 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
252 ServiceImplementationRequestInput input = ServiceDataUtils
253 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
254 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
256 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
260 void serviceImplementationServiceActive() throws InterruptedException, ExecutionException {
261 ServiceImplementationRequestInput input = ServiceDataUtils
262 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
263 GetPmOutput getPmOutput1 = null;
264 when(this.olmService.getPm(any())).thenReturn(RpcResultBuilder.success(getPmOutput1).buildFuture());
265 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
267 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
268 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
270 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
274 void serviceImplementationServiceActive2() throws InterruptedException, ExecutionException {
275 ServiceImplementationRequestInput input = ServiceDataUtils
276 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
277 GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
278 when(this.olmService.getPm(any())).thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
279 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
281 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
282 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
284 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
288 void serviceImplementationServiceInActive4() throws InterruptedException, ExecutionException {
289 List<Measurements> measurementsList = new ArrayList<Measurements>();
290 measurementsList.add(new MeasurementsBuilder()
291 .setPmparameterName("preFECCorrectedErrors")
292 .setPmparameterValue("1")
294 GetPmOutput getPmOutput = new GetPmOutputBuilder()
296 .setMeasurements(measurementsList)
299 doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService).getPm(any());
300 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
302 doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(any(), any(), any());
303 ServiceImplementationRequestInput input = ServiceDataUtils
304 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
305 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
307 assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
311 void serviceImplementationServiceInActive5() throws InterruptedException, ExecutionException {
312 ServiceImplementationRequestInput input = ServiceDataUtils
313 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
314 List<Measurements> measurementsList = new ArrayList<Measurements>();
315 measurementsList.add(new MeasurementsBuilder()
316 .setPmparameterName("preFECCorrectedErrors")
317 .setPmparameterValue("112000000000d")
319 GetPmOutput getPmOutput = new GetPmOutputBuilder()
321 .setMeasurements(measurementsList)
324 doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService).getPm(any());
325 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input,
327 assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
330 private GetPmInput createGetPmInput(String nodeId, String tp) {
331 return new GetPmInputBuilder()
333 .setGranularity(PmGranularity._15min)
334 .setResourceIdentifier(new ResourceIdentifierBuilder().setResourceName(tp + "-OTU").build())
335 .setResourceType(ResourceTypeEnum.Interface)