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.Test;
16 import org.mockito.Mockito;
17 import org.opendaylight.mdsal.binding.api.MountPoint;
18 import org.opendaylight.mdsal.binding.api.MountPointService;
19 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
20 import org.opendaylight.transportpce.common.ResponseCodes;
21 import org.opendaylight.transportpce.common.StringConstants;
22 import org.opendaylight.transportpce.common.crossconnect.CrossConnect;
23 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
24 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121;
25 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl221;
26 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
27 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
28 import org.opendaylight.transportpce.common.fixedflex.FixedFlexImpl;
29 import org.opendaylight.transportpce.common.fixedflex.FixedFlexInterface;
30 import org.opendaylight.transportpce.common.mapping.MappingUtils;
31 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
32 import org.opendaylight.transportpce.common.mapping.PortMapping;
33 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
34 import org.opendaylight.transportpce.common.mapping.PortMappingVersion121;
35 import org.opendaylight.transportpce.common.mapping.PortMappingVersion221;
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.renderer.NetworkModelWavelengthService;
42 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthServiceImpl;
43 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface121;
44 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface221;
45 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
46 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface221;
47 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
48 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
49 import org.opendaylight.transportpce.renderer.stub.OlmServiceStub;
50 import org.opendaylight.transportpce.renderer.utils.MountPointUtils;
51 import org.opendaylight.transportpce.renderer.utils.NotificationPublishServiceMock;
52 import org.opendaylight.transportpce.renderer.utils.ServiceDataUtils;
53 import org.opendaylight.transportpce.test.AbstractTest;
54 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
55 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInputBuilder;
56 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutput;
57 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutputBuilder;
58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService;
59 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.Measurements;
60 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.MeasurementsBuilder;
61 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.device.rev200128.ServicePathOutputBuilder;
62 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev200520.ServiceImplementationRequestInput;
63 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev200520.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.rev200615.olm.get.pm.input.ResourceIdentifierBuilder;
67 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
69 public class RendererServiceOperationsImplTest extends AbstractTest {
71 private MountPointService mountPointService;
72 private DeviceTransactionManager deviceTransactionManager;
73 private RendererServiceOperationsImpl rendererServiceOperations;
74 private OpenRoadmInterfaces openRoadmInterfaces;
75 private DeviceRendererService deviceRenderer;
76 private PortMapping portMapping;
77 private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
78 private CrossConnect crossConnect;
79 private TransportpceOlmService olmService;
80 private NetworkModelWavelengthService networkModelWavelengthService;
81 private MappingUtils mappingUtils;
82 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
83 private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
84 private PortMappingVersion221 portMappingVersion22;
85 private PortMappingVersion121 portMappingVersion121;
86 private CrossConnectImpl121 crossConnectImpl121;
87 private CrossConnectImpl221 crossConnectImpl221;
89 private void setMountPoint(MountPoint mountPoint) {
90 this.mountPointService = new MountPointServiceStub(mountPoint);
91 this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
92 this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
93 this.openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
94 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
95 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
96 openRoadmInterfacesImpl121, openRoadmInterfacesImpl221);
97 this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
98 this.portMappingVersion22 =
99 new PortMappingVersion221(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
100 this.portMappingVersion121 =
101 new PortMappingVersion121(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
102 this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion22,
103 this.portMappingVersion121);
104 FixedFlexInterface fixedFlexInterface = new FixedFlexImpl();
105 OpenRoadmInterface121 openRoadmInterface121 = new OpenRoadmInterface121(portMapping,openRoadmInterfaces);
106 OpenRoadmInterface221 openRoadmInterface221 = new OpenRoadmInterface221(portMapping,openRoadmInterfaces,
108 OpenRoadmOtnInterface221 openRoadmOTNInterface = new OpenRoadmOtnInterface221(portMapping, openRoadmInterfaces);
109 this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(this.mappingUtils,openRoadmInterface121,
110 openRoadmInterface221, openRoadmOTNInterface);
111 this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
112 this.crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
113 this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
114 this.crossConnectImpl221);
118 public void setUp() throws OpenRoadmInterfaceException {
119 setMountPoint(new MountPointStub(getDataBroker()));
120 this.olmService = new OlmServiceStub();
121 this.networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(getDataBroker());
122 this.deviceRenderer = new DeviceRendererServiceImpl(this.getDataBroker(), this.deviceTransactionManager,
123 openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping, null);
124 Mockito.doNothing().when(this.openRoadmInterfaces).postEquipmentState(Mockito.anyString(),
125 Mockito.anyString(), Mockito.anyBoolean());
126 NotificationPublishService notificationPublishService = new NotificationPublishServiceMock();
128 this.olmService = Mockito.spy(this.olmService);
129 this.deviceRenderer = Mockito.spy(this.deviceRenderer);
130 this.rendererServiceOperations = new RendererServiceOperationsImpl(this.deviceRenderer, this.olmService,
131 getDataBroker(), this.networkModelWavelengthService, notificationPublishService);
133 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
135 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
140 public void serviceImplementationTerminationPointAsResourceTtp() throws InterruptedException, ExecutionException {
142 ServiceImplementationRequestInput input = ServiceDataUtils
143 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
144 writePortMapping(input, StringConstants.TTP_TOKEN);
145 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
147 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
149 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
150 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
155 public void serviceImplementationTerminationPointAsResourceTtp2() throws InterruptedException, ExecutionException {
157 ServiceImplementationRequestInput input = ServiceDataUtils
158 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
159 writePortMapping(input, StringConstants.TTP_TOKEN);
160 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
162 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
164 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
165 .servicePowerSetup(Mockito.any());
166 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
167 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
172 public void serviceImplementationTerminationPointAsResourcePp() throws InterruptedException, ExecutionException {
174 ServiceImplementationRequestInput input = ServiceDataUtils
175 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.PP_TOKEN);
176 writePortMapping(input, StringConstants.PP_TOKEN);
177 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
179 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
181 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
182 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
187 public void serviceImplementationTerminationPointAsResourceNetwork()
188 throws InterruptedException, ExecutionException {
190 ServiceImplementationRequestInput input = ServiceDataUtils
191 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
192 writePortMapping(input, StringConstants.NETWORK_TOKEN);
193 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
195 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
197 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
198 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
203 public void serviceImplementationTerminationPointAsResourceClient()
204 throws InterruptedException, ExecutionException {
206 ServiceImplementationRequestInput input = ServiceDataUtils
207 // .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.CLIENT_TOKEN);
208 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.CLIENT_TOKEN);
209 // writePortMapping(input, OpenRoadmInterfacesImpl.CLIENT_TOKEN);
210 writePortMapping(input, StringConstants.CLIENT_TOKEN);
211 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
212 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
216 public void serviceImplementationTerminationPointAsResourceNoMapping()
217 throws InterruptedException, ExecutionException {
219 String[] interfaceTokens = {
220 StringConstants.NETWORK_TOKEN,
221 StringConstants.CLIENT_TOKEN,
222 StringConstants.TTP_TOKEN,
223 StringConstants.PP_TOKEN
226 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("failed")
228 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
231 for (String tpToken : interfaceTokens) {
232 ServiceImplementationRequestInput input = ServiceDataUtils
233 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
234 ServiceImplementationRequestOutput result =
235 this.rendererServiceOperations.serviceImplementation(input).get();
236 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
237 result.getConfigurationResponseCommon().getResponseCode());
241 private void writePortMapping(ServiceImplementationRequestInput input, String tpToken) {
242 MountPointUtils.writeMapping(
243 input.getServiceAEnd().getNodeId(),
244 input.getServiceAEnd().getNodeId() + "-" + tpToken,
245 this.deviceTransactionManager
247 MountPointUtils.writeMapping(
248 input.getServiceZEnd().getNodeId(),
249 input.getServiceZEnd().getNodeId() + "-"
250 + input.getServiceAEnd().getNodeId() + "-" + tpToken,
251 this.deviceTransactionManager
253 MountPointUtils.writeMapping(
254 input.getServiceAEnd().getNodeId(),
255 input.getServiceAEnd().getNodeId() + "-"
256 + input.getServiceZEnd().getNodeId() + "-" + tpToken,
257 this.deviceTransactionManager
259 MountPointUtils.writeMapping(
260 input.getServiceZEnd().getNodeId(),
261 input.getServiceZEnd().getNodeId() + "-" + tpToken,
262 this.deviceTransactionManager
267 public void serviceImplementationRollbackAllNecessary() throws InterruptedException, ExecutionException {
269 ServiceImplementationRequestInput input = ServiceDataUtils
270 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
271 writePortMapping(input, StringConstants.NETWORK_TOKEN);
272 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
273 .servicePowerSetup(Mockito.any());
274 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
275 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
279 private GetPmInput createGetPmInput(String nodeId, String tp) {
280 GetPmInputBuilder getPmIpBldr = new GetPmInputBuilder();
281 getPmIpBldr.setNodeId(nodeId);
282 getPmIpBldr.setGranularity(PmGranularity._15min);
283 ResourceIdentifierBuilder rsrcBldr = new ResourceIdentifierBuilder();
284 rsrcBldr.setResourceName(tp + "-OTU");
285 getPmIpBldr.setResourceIdentifier(rsrcBldr.build());
286 getPmIpBldr.setResourceType(ResourceTypeEnum.Interface);
287 return getPmIpBldr.build();
291 public void serviceImplementationServiceInActive() throws InterruptedException, ExecutionException {
293 ServiceImplementationRequestInput input = ServiceDataUtils
294 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
295 writePortMapping(input, StringConstants.NETWORK_TOKEN);
296 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
297 .setPmparameterValue("1").build();
298 List<Measurements> measurementsList = new ArrayList<Measurements>();
299 measurementsList.add(measurements);
300 GetPmOutput getPmOutput = new GetPmOutputBuilder()
301 .setNodeId("node1").setMeasurements(measurementsList).build();
302 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
303 .getPm(Mockito.any());
304 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
305 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
310 public void serviceImplementationServiceInActive2() throws InterruptedException, ExecutionException {
312 ServiceImplementationRequestInput input = ServiceDataUtils
313 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
314 writePortMapping(input, StringConstants.NETWORK_TOKEN);
315 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
316 .setPmparameterValue("1").build();
317 List<Measurements> measurementsList = new ArrayList<Measurements>();
318 measurementsList.add(measurements);
319 GetPmOutput getPmOutput = new GetPmOutputBuilder()
320 .setNodeId("node1").setMeasurements(measurementsList).build();
321 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
322 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
324 Mockito.when(this.olmService.getPm(Mockito.any()))
325 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
326 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
327 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
332 public void serviceImplementationServiceInActive3() throws InterruptedException, ExecutionException {
334 ServiceImplementationRequestInput input = ServiceDataUtils
335 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
336 writePortMapping(input, StringConstants.NETWORK_TOKEN);
337 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
338 .setPmparameterValue("1").build();
339 List<Measurements> measurementsList = new ArrayList<Measurements>();
340 measurementsList.add(measurements);
341 GetPmOutput getPmOutput = new GetPmOutputBuilder()
342 .setNodeId("node1").setMeasurements(measurementsList).build();
343 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
344 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
346 GetPmInput getPmInputZ = createGetPmInput("XPONDER-2-3",
347 StringConstants.NETWORK_TOKEN);
348 GetPmInput getPmInputA = createGetPmInput("XPONDER-1-2",
349 StringConstants.NETWORK_TOKEN);
351 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZ)))
352 .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
353 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputA)))
354 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
355 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
356 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
361 public void serviceImplementationServiceActive() throws InterruptedException, ExecutionException {
363 ServiceImplementationRequestInput input = ServiceDataUtils
364 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
365 writePortMapping(input, StringConstants.NETWORK_TOKEN);
366 GetPmOutput getPmOutput = new GetPmOutputBuilder()
367 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
368 GetPmOutput getPmOutput1 = null;
369 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput1)
371 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
373 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
375 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
376 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
381 public void serviceImplementationServiceActive2() throws InterruptedException, ExecutionException {
383 ServiceImplementationRequestInput input = ServiceDataUtils
384 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
385 writePortMapping(input, StringConstants.NETWORK_TOKEN);
386 GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
387 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput)
389 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
391 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
393 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
394 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
399 public void serviceImplementationServiceInActive4() throws InterruptedException, ExecutionException {
401 ServiceImplementationRequestInput input = ServiceDataUtils
402 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
403 writePortMapping(input, StringConstants.NETWORK_TOKEN);
404 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
405 .setPmparameterValue("1").build();
406 List<Measurements> measurementsList = new ArrayList<Measurements>();
407 measurementsList.add(measurements);
408 GetPmOutput getPmOutput = new GetPmOutputBuilder()
409 .setNodeId("node1").setMeasurements(measurementsList).build();
411 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
412 .getPm(Mockito.any());
413 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
415 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
417 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
418 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
423 public void serviceImplementationServiceInActive5() throws InterruptedException, ExecutionException {
425 ServiceImplementationRequestInput input = ServiceDataUtils
426 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
427 writePortMapping(input, StringConstants.NETWORK_TOKEN);
428 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
429 .setPmparameterValue("112000000000d").build();
430 List<Measurements> measurementsList = new ArrayList<Measurements>();
431 measurementsList.add(measurements);
432 GetPmOutput getPmOutput = new GetPmOutputBuilder()
433 .setNodeId("node1").setMeasurements(measurementsList).build();
435 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
436 .getPm(Mockito.any());
437 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
438 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());