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 java.util.ArrayList;
11 import java.util.List;
12 import java.util.concurrent.ExecutionException;
13 import org.junit.Assert;
14 import org.junit.Before;
15 import org.junit.Ignore;
16 import org.junit.Test;
17 import org.mockito.Mockito;
18 import org.opendaylight.mdsal.binding.api.MountPoint;
19 import org.opendaylight.mdsal.binding.api.MountPointService;
20 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
21 import org.opendaylight.transportpce.common.ResponseCodes;
22 import org.opendaylight.transportpce.common.StringConstants;
23 import org.opendaylight.transportpce.common.crossconnect.CrossConnect;
24 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
25 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121;
26 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl221;
27 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
28 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
29 import org.opendaylight.transportpce.common.mapping.MappingUtils;
30 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
31 import org.opendaylight.transportpce.common.mapping.PortMapping;
32 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
33 import org.opendaylight.transportpce.common.mapping.PortMappingVersion121;
34 import org.opendaylight.transportpce.common.mapping.PortMappingVersion221;
35 import org.opendaylight.transportpce.common.mapping.PortMappingVersion710;
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.openroadminterface.OpenRoadmInterface121;
43 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface221;
44 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface710;
45 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
46 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface221;
47 import org.opendaylight.transportpce.renderer.stub.OlmServiceStub;
48 import org.opendaylight.transportpce.renderer.utils.MountPointUtils;
49 import org.opendaylight.transportpce.renderer.utils.NotificationPublishServiceMock;
50 import org.opendaylight.transportpce.renderer.utils.ServiceDataUtils;
51 import org.opendaylight.transportpce.test.AbstractTest;
52 import org.opendaylight.transportpce.test.stub.MountPointServiceStub;
53 import org.opendaylight.transportpce.test.stub.MountPointStub;
54 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev200128.ServicePathOutputBuilder;
55 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
56 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInputBuilder;
57 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutput;
58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutputBuilder;
59 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService;
60 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.Measurements;
61 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.MeasurementsBuilder;
62 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestInput;
63 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestOutput;
64 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmGranularity;
65 import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
66 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev201211.olm.get.pm.input.ResourceIdentifierBuilder;
67 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
70 public class RendererServiceOperationsImplTest extends AbstractTest {
72 private MountPointService mountPointService;
73 private DeviceTransactionManager deviceTransactionManager;
74 private RendererServiceOperationsImpl rendererServiceOperations;
75 private OpenRoadmInterfaces openRoadmInterfaces;
76 private DeviceRendererService deviceRenderer;
77 private OtnDeviceRendererService otnDeviceRendererService;
78 private PortMapping portMapping;
79 private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
80 private CrossConnect crossConnect;
81 private TransportpceOlmService olmService;
82 private MappingUtils mappingUtils;
83 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
84 private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
85 private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
86 private PortMappingVersion710 portMappingVersion710;
87 private PortMappingVersion221 portMappingVersion22;
88 private PortMappingVersion121 portMappingVersion121;
89 private CrossConnectImpl121 crossConnectImpl121;
90 private CrossConnectImpl221 crossConnectImpl221;
92 private void setMountPoint(MountPoint mountPoint) {
93 this.mountPointService = new MountPointServiceStub(mountPoint);
94 this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
95 this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
96 this.openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
97 this.openRoadmInterfacesImpl710 = new OpenRoadmInterfacesImpl710(deviceTransactionManager);
98 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
99 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
100 openRoadmInterfacesImpl121, openRoadmInterfacesImpl221, openRoadmInterfacesImpl710);
101 this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
102 this.portMappingVersion22 =
103 new PortMappingVersion221(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
104 this.portMappingVersion121 =
105 new PortMappingVersion121(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
106 this.portMappingVersion710 =
107 new PortMappingVersion710(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
108 this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710, this.portMappingVersion22,
109 this.portMappingVersion121);
110 OpenRoadmInterface121 openRoadmInterface121 = new OpenRoadmInterface121(portMapping,openRoadmInterfaces);
111 OpenRoadmInterface221 openRoadmInterface221 = new OpenRoadmInterface221(portMapping,openRoadmInterfaces);
112 OpenRoadmInterface710 openRoadmInterface710 = new OpenRoadmInterface710(portMapping,openRoadmInterfaces);
113 OpenRoadmOtnInterface221 openRoadmOTNInterface = new OpenRoadmOtnInterface221(portMapping, openRoadmInterfaces);
114 this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(this.mappingUtils,openRoadmInterface121,
115 openRoadmInterface221, openRoadmInterface710, openRoadmOTNInterface);
116 this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
117 this.crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
118 this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
119 this.crossConnectImpl221);
123 public void setUp() throws OpenRoadmInterfaceException {
124 setMountPoint(new MountPointStub(getDataBroker()));
125 this.olmService = new OlmServiceStub();
126 this.deviceRenderer = new DeviceRendererServiceImpl(this.getDataBroker(), this.deviceTransactionManager,
127 openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping, null);
128 this.otnDeviceRendererService = new OtnDeviceRendererServiceImpl(openRoadmInterfaceFactory, this.crossConnect,
129 openRoadmInterfaces, this.deviceTransactionManager, null);
130 Mockito.doNothing().when(this.openRoadmInterfaces).postEquipmentState(Mockito.anyString(),
131 Mockito.anyString(), Mockito.anyBoolean());
132 NotificationPublishService notificationPublishService = new NotificationPublishServiceMock();
133 this.olmService = Mockito.spy(this.olmService);
134 this.deviceRenderer = Mockito.spy(this.deviceRenderer);
135 this.rendererServiceOperations = new RendererServiceOperationsImpl(this.deviceRenderer,
136 this.otnDeviceRendererService, this.olmService, getDataBroker(), notificationPublishService);
138 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
140 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
145 public void serviceImplementationTerminationPointAsResourceTtp() throws InterruptedException, ExecutionException {
147 ServiceImplementationRequestInput input = ServiceDataUtils
148 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
149 writePortMapping(input, StringConstants.TTP_TOKEN);
150 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
152 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
154 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
155 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
160 public void serviceImplementationTerminationPointAsResourceTtp2() throws InterruptedException, ExecutionException {
162 ServiceImplementationRequestInput input = ServiceDataUtils
163 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
164 writePortMapping(input, StringConstants.TTP_TOKEN);
165 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
167 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
169 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
170 .servicePowerSetup(Mockito.any());
171 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
172 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
177 public void serviceImplementationTerminationPointAsResourcePp() throws InterruptedException, ExecutionException {
179 ServiceImplementationRequestInput input = ServiceDataUtils
180 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.PP_TOKEN);
181 writePortMapping(input, StringConstants.PP_TOKEN);
182 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
184 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
186 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
187 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
192 public void serviceImplementationTerminationPointAsResourceNetwork()
193 throws InterruptedException, ExecutionException {
195 ServiceImplementationRequestInput input = ServiceDataUtils
196 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
197 writePortMapping(input, StringConstants.NETWORK_TOKEN);
198 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
200 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
202 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
203 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
208 public void serviceImplementationTerminationPointAsResourceClient()
209 throws InterruptedException, ExecutionException {
211 ServiceImplementationRequestInput input = ServiceDataUtils
212 // .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.CLIENT_TOKEN);
213 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.CLIENT_TOKEN);
214 // writePortMapping(input, OpenRoadmInterfacesImpl.CLIENT_TOKEN);
215 writePortMapping(input, StringConstants.CLIENT_TOKEN);
216 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
217 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
221 public void serviceImplementationTerminationPointAsResourceNoMapping()
222 throws InterruptedException, ExecutionException {
224 String[] interfaceTokens = {
225 StringConstants.NETWORK_TOKEN,
226 StringConstants.CLIENT_TOKEN,
227 StringConstants.TTP_TOKEN,
228 StringConstants.PP_TOKEN
231 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("failed")
233 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
236 for (String tpToken : interfaceTokens) {
237 ServiceImplementationRequestInput input = ServiceDataUtils
238 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
239 ServiceImplementationRequestOutput result =
240 this.rendererServiceOperations.serviceImplementation(input).get();
241 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
242 result.getConfigurationResponseCommon().getResponseCode());
246 private void writePortMapping(ServiceImplementationRequestInput input, String tpToken) {
247 MountPointUtils.writeMapping(
248 input.getServiceAEnd().getNodeId(),
249 input.getServiceAEnd().getNodeId() + "-" + tpToken,
250 this.deviceTransactionManager
252 MountPointUtils.writeMapping(
253 input.getServiceZEnd().getNodeId(),
254 input.getServiceZEnd().getNodeId() + "-"
255 + input.getServiceAEnd().getNodeId() + "-" + tpToken,
256 this.deviceTransactionManager
258 MountPointUtils.writeMapping(
259 input.getServiceAEnd().getNodeId(),
260 input.getServiceAEnd().getNodeId() + "-"
261 + input.getServiceZEnd().getNodeId() + "-" + tpToken,
262 this.deviceTransactionManager
264 MountPointUtils.writeMapping(
265 input.getServiceZEnd().getNodeId(),
266 input.getServiceZEnd().getNodeId() + "-" + tpToken,
267 this.deviceTransactionManager
272 public void serviceImplementationRollbackAllNecessary() throws InterruptedException, ExecutionException {
274 ServiceImplementationRequestInput input = ServiceDataUtils
275 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
276 writePortMapping(input, StringConstants.NETWORK_TOKEN);
277 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
278 .servicePowerSetup(Mockito.any());
279 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
280 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
284 private GetPmInput createGetPmInput(String nodeId, String tp) {
285 GetPmInputBuilder getPmIpBldr = new GetPmInputBuilder();
286 getPmIpBldr.setNodeId(nodeId);
287 getPmIpBldr.setGranularity(PmGranularity._15min);
288 ResourceIdentifierBuilder rsrcBldr = new ResourceIdentifierBuilder();
289 rsrcBldr.setResourceName(tp + "-OTU");
290 getPmIpBldr.setResourceIdentifier(rsrcBldr.build());
291 getPmIpBldr.setResourceType(ResourceTypeEnum.Interface);
292 return getPmIpBldr.build();
296 public void serviceImplementationServiceInActive() throws InterruptedException, ExecutionException {
298 ServiceImplementationRequestInput input = ServiceDataUtils
299 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
300 writePortMapping(input, StringConstants.NETWORK_TOKEN);
301 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
302 .setPmparameterValue("1").build();
303 List<Measurements> measurementsList = new ArrayList<Measurements>();
304 measurementsList.add(measurements);
305 GetPmOutput getPmOutput = new GetPmOutputBuilder()
306 .setNodeId("node1").setMeasurements(measurementsList).build();
307 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
308 .getPm(Mockito.any());
309 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
310 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
315 public void serviceImplementationServiceInActive2() throws InterruptedException, ExecutionException {
317 ServiceImplementationRequestInput input = ServiceDataUtils
318 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
319 writePortMapping(input, StringConstants.NETWORK_TOKEN);
320 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
321 .setPmparameterValue("1").build();
322 List<Measurements> measurementsList = new ArrayList<Measurements>();
323 measurementsList.add(measurements);
324 GetPmOutput getPmOutput = new GetPmOutputBuilder()
325 .setNodeId("node1").setMeasurements(measurementsList).build();
326 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
327 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
329 Mockito.when(this.olmService.getPm(Mockito.any()))
330 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
331 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
332 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
337 public void serviceImplementationServiceInActive3() throws InterruptedException, ExecutionException {
339 ServiceImplementationRequestInput input = ServiceDataUtils
340 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
341 writePortMapping(input, StringConstants.NETWORK_TOKEN);
342 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
343 .setPmparameterValue("1").build();
344 List<Measurements> measurementsList = new ArrayList<Measurements>();
345 measurementsList.add(measurements);
346 GetPmOutput getPmOutput = new GetPmOutputBuilder()
347 .setNodeId("node1").setMeasurements(measurementsList).build();
348 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
349 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
351 GetPmInput getPmInputZ = createGetPmInput("XPONDER-2-3",
352 StringConstants.NETWORK_TOKEN);
353 GetPmInput getPmInputA = createGetPmInput("XPONDER-1-2",
354 StringConstants.NETWORK_TOKEN);
356 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZ)))
357 .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
358 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputA)))
359 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
360 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
361 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
366 public void serviceImplementationServiceActive() throws InterruptedException, ExecutionException {
368 ServiceImplementationRequestInput input = ServiceDataUtils
369 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
370 writePortMapping(input, StringConstants.NETWORK_TOKEN);
371 GetPmOutput getPmOutput = new GetPmOutputBuilder()
372 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
373 GetPmOutput getPmOutput1 = null;
374 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput1)
376 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
378 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
380 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
381 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
386 public void serviceImplementationServiceActive2() throws InterruptedException, ExecutionException {
388 ServiceImplementationRequestInput input = ServiceDataUtils
389 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
390 writePortMapping(input, StringConstants.NETWORK_TOKEN);
391 GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
392 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput)
394 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
396 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
398 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
399 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
404 public void serviceImplementationServiceInActive4() throws InterruptedException, ExecutionException {
406 ServiceImplementationRequestInput input = ServiceDataUtils
407 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
408 writePortMapping(input, StringConstants.NETWORK_TOKEN);
409 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
410 .setPmparameterValue("1").build();
411 List<Measurements> measurementsList = new ArrayList<Measurements>();
412 measurementsList.add(measurements);
413 GetPmOutput getPmOutput = new GetPmOutputBuilder()
414 .setNodeId("node1").setMeasurements(measurementsList).build();
416 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
417 .getPm(Mockito.any());
418 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
420 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
422 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
423 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
428 public void serviceImplementationServiceInActive5() throws InterruptedException, ExecutionException {
430 ServiceImplementationRequestInput input = ServiceDataUtils
431 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
432 writePortMapping(input, StringConstants.NETWORK_TOKEN);
433 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
434 .setPmparameterValue("112000000000d").build();
435 List<Measurements> measurementsList = new ArrayList<Measurements>();
436 measurementsList.add(measurements);
437 GetPmOutput getPmOutput = new GetPmOutputBuilder()
438 .setNodeId("node1").setMeasurements(measurementsList).build();
440 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
441 .getPm(Mockito.any());
442 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
443 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());