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.crossconnect.CrossConnectImpl710;
28 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
29 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
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.mapping.PortMappingVersion710;
37 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
38 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
39 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
40 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
41 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221;
42 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl710;
43 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface121;
44 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface221;
45 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface710;
46 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
47 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface221;
48 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface710;
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.transportpce.test.stub.MountPointServiceStub;
55 import org.opendaylight.transportpce.test.stub.MountPointStub;
56 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev210618.ServicePathOutputBuilder;
57 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInputBuilder;
59 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutput;
60 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutputBuilder;
61 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService;
62 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.Measurements;
63 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.MeasurementsBuilder;
64 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestInput;
65 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestOutput;
66 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmGranularity;
67 import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
68 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev201211.olm.get.pm.input.ResourceIdentifierBuilder;
69 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
72 public class RendererServiceOperationsImplTest extends AbstractTest {
74 private MountPointService mountPointService;
75 private DeviceTransactionManager deviceTransactionManager;
76 private RendererServiceOperationsImpl rendererServiceOperations;
77 private OpenRoadmInterfaces openRoadmInterfaces;
78 private DeviceRendererService deviceRenderer;
79 private OtnDeviceRendererService otnDeviceRendererService;
80 private PortMapping portMapping;
81 private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
82 private CrossConnect crossConnect;
83 private TransportpceOlmService olmService;
84 private MappingUtils mappingUtils;
85 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
86 private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
87 private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
88 private PortMappingVersion710 portMappingVersion710;
89 private PortMappingVersion221 portMappingVersion22;
90 private PortMappingVersion121 portMappingVersion121;
91 private CrossConnectImpl121 crossConnectImpl121;
92 private CrossConnectImpl221 crossConnectImpl221;
93 private CrossConnectImpl710 crossConnectImpl710;
95 private void setMountPoint(MountPoint mountPoint) {
96 this.mountPointService = new MountPointServiceStub(mountPoint);
97 this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
98 this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
99 this.openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
100 this.openRoadmInterfacesImpl710 = new OpenRoadmInterfacesImpl710(deviceTransactionManager);
101 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
102 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
103 openRoadmInterfacesImpl121, openRoadmInterfacesImpl221, openRoadmInterfacesImpl710);
104 this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
105 this.portMappingVersion22 =
106 new PortMappingVersion221(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
107 this.portMappingVersion121 =
108 new PortMappingVersion121(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
109 this.portMappingVersion710 =
110 new PortMappingVersion710(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
111 this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710, this.portMappingVersion22,
112 this.portMappingVersion121);
113 OpenRoadmInterface121 openRoadmInterface121 = new OpenRoadmInterface121(portMapping,openRoadmInterfaces);
114 OpenRoadmInterface221 openRoadmInterface221 = new OpenRoadmInterface221(portMapping,openRoadmInterfaces);
115 OpenRoadmInterface710 openRoadmInterface710 = new OpenRoadmInterface710(portMapping,openRoadmInterfaces);
116 OpenRoadmOtnInterface221 openRoadmOTNInterface221 = new OpenRoadmOtnInterface221(portMapping,
117 openRoadmInterfaces);
118 OpenRoadmOtnInterface710 openRoadmOtnInterface710 = new OpenRoadmOtnInterface710(portMapping,
119 openRoadmInterfaces);
120 this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(this.mappingUtils,openRoadmInterface121,
121 openRoadmInterface221, openRoadmInterface710, openRoadmOTNInterface221, openRoadmOtnInterface710);
122 this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
123 this.crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
124 this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
125 this.crossConnectImpl221, this.crossConnectImpl710);
129 public void setUp() throws OpenRoadmInterfaceException {
130 setMountPoint(new MountPointStub(getDataBroker()));
131 this.olmService = new OlmServiceStub();
132 this.deviceRenderer = new DeviceRendererServiceImpl(this.getDataBroker(), this.deviceTransactionManager,
133 openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping, null);
134 this.otnDeviceRendererService = new OtnDeviceRendererServiceImpl(openRoadmInterfaceFactory, this.crossConnect,
135 openRoadmInterfaces, this.deviceTransactionManager, null);
136 Mockito.doNothing().when(this.openRoadmInterfaces).postEquipmentState(Mockito.anyString(),
137 Mockito.anyString(), Mockito.anyBoolean());
138 NotificationPublishService notificationPublishService = new NotificationPublishServiceMock();
139 this.olmService = Mockito.spy(this.olmService);
140 this.deviceRenderer = Mockito.spy(this.deviceRenderer);
141 this.rendererServiceOperations = new RendererServiceOperationsImpl(this.deviceRenderer,
142 this.otnDeviceRendererService, this.olmService, getDataBroker(), notificationPublishService, null);
144 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
146 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
151 public void serviceImplementationTerminationPointAsResourceTtp() throws InterruptedException, ExecutionException {
153 ServiceImplementationRequestInput input = ServiceDataUtils
154 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
155 writePortMapping(input, StringConstants.TTP_TOKEN);
156 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
158 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
160 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
161 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
166 public void serviceImplementationTerminationPointAsResourceTtp2() throws InterruptedException, ExecutionException {
168 ServiceImplementationRequestInput input = ServiceDataUtils
169 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
170 writePortMapping(input, StringConstants.TTP_TOKEN);
171 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
173 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
175 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
176 .servicePowerSetup(Mockito.any());
177 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
178 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
183 public void serviceImplementationTerminationPointAsResourcePp() throws InterruptedException, ExecutionException {
185 ServiceImplementationRequestInput input = ServiceDataUtils
186 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.PP_TOKEN);
187 writePortMapping(input, StringConstants.PP_TOKEN);
188 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
190 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
192 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
193 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
198 public void serviceImplementationTerminationPointAsResourceNetwork()
199 throws InterruptedException, ExecutionException {
201 ServiceImplementationRequestInput input = ServiceDataUtils
202 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
203 writePortMapping(input, StringConstants.NETWORK_TOKEN);
204 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
206 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
208 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
209 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
214 public void serviceImplementationTerminationPointAsResourceClient()
215 throws InterruptedException, ExecutionException {
217 ServiceImplementationRequestInput input = ServiceDataUtils
218 // .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.CLIENT_TOKEN);
219 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.CLIENT_TOKEN);
220 // writePortMapping(input, OpenRoadmInterfacesImpl.CLIENT_TOKEN);
221 writePortMapping(input, StringConstants.CLIENT_TOKEN);
222 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
223 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
227 public void serviceImplementationTerminationPointAsResourceNoMapping()
228 throws InterruptedException, ExecutionException {
230 String[] interfaceTokens = {
231 StringConstants.NETWORK_TOKEN,
232 StringConstants.CLIENT_TOKEN,
233 StringConstants.TTP_TOKEN,
234 StringConstants.PP_TOKEN
237 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("failed")
239 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
242 for (String tpToken : interfaceTokens) {
243 ServiceImplementationRequestInput input = ServiceDataUtils
244 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
245 ServiceImplementationRequestOutput result =
246 this.rendererServiceOperations.serviceImplementation(input).get();
247 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
248 result.getConfigurationResponseCommon().getResponseCode());
252 private void writePortMapping(ServiceImplementationRequestInput input, String tpToken) {
253 MountPointUtils.writeMapping(
254 input.getServiceAEnd().getNodeId(),
255 input.getServiceAEnd().getNodeId() + "-" + tpToken,
256 this.deviceTransactionManager
258 MountPointUtils.writeMapping(
259 input.getServiceZEnd().getNodeId(),
260 input.getServiceZEnd().getNodeId() + "-"
261 + input.getServiceAEnd().getNodeId() + "-" + tpToken,
262 this.deviceTransactionManager
264 MountPointUtils.writeMapping(
265 input.getServiceAEnd().getNodeId(),
266 input.getServiceAEnd().getNodeId() + "-"
267 + input.getServiceZEnd().getNodeId() + "-" + tpToken,
268 this.deviceTransactionManager
270 MountPointUtils.writeMapping(
271 input.getServiceZEnd().getNodeId(),
272 input.getServiceZEnd().getNodeId() + "-" + tpToken,
273 this.deviceTransactionManager
278 public void serviceImplementationRollbackAllNecessary() throws InterruptedException, ExecutionException {
280 ServiceImplementationRequestInput input = ServiceDataUtils
281 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
282 writePortMapping(input, StringConstants.NETWORK_TOKEN);
283 Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
284 .servicePowerSetup(Mockito.any());
285 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
286 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
290 private GetPmInput createGetPmInput(String nodeId, String tp) {
291 GetPmInputBuilder getPmIpBldr = new GetPmInputBuilder();
292 getPmIpBldr.setNodeId(nodeId);
293 getPmIpBldr.setGranularity(PmGranularity._15min);
294 ResourceIdentifierBuilder rsrcBldr = new ResourceIdentifierBuilder();
295 rsrcBldr.setResourceName(tp + "-OTU");
296 getPmIpBldr.setResourceIdentifier(rsrcBldr.build());
297 getPmIpBldr.setResourceType(ResourceTypeEnum.Interface);
298 return getPmIpBldr.build();
302 public void serviceImplementationServiceInActive() throws InterruptedException, ExecutionException {
304 ServiceImplementationRequestInput input = ServiceDataUtils
305 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
306 writePortMapping(input, StringConstants.NETWORK_TOKEN);
307 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
308 .setPmparameterValue("1").build();
309 List<Measurements> measurementsList = new ArrayList<Measurements>();
310 measurementsList.add(measurements);
311 GetPmOutput getPmOutput = new GetPmOutputBuilder()
312 .setNodeId("node1").setMeasurements(measurementsList).build();
313 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
314 .getPm(Mockito.any());
315 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
316 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
321 public void serviceImplementationServiceInActive2() throws InterruptedException, ExecutionException {
323 ServiceImplementationRequestInput input = ServiceDataUtils
324 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
325 writePortMapping(input, StringConstants.NETWORK_TOKEN);
326 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
327 .setPmparameterValue("1").build();
328 List<Measurements> measurementsList = new ArrayList<Measurements>();
329 measurementsList.add(measurements);
330 GetPmOutput getPmOutput = new GetPmOutputBuilder()
331 .setNodeId("node1").setMeasurements(measurementsList).build();
332 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
333 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
335 Mockito.when(this.olmService.getPm(Mockito.any()))
336 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
337 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
338 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
343 public void serviceImplementationServiceInActive3() throws InterruptedException, ExecutionException {
345 ServiceImplementationRequestInput input = ServiceDataUtils
346 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
347 writePortMapping(input, StringConstants.NETWORK_TOKEN);
348 Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
349 .setPmparameterValue("1").build();
350 List<Measurements> measurementsList = new ArrayList<Measurements>();
351 measurementsList.add(measurements);
352 GetPmOutput getPmOutput = new GetPmOutputBuilder()
353 .setNodeId("node1").setMeasurements(measurementsList).build();
354 GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
355 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
357 GetPmInput getPmInputZ = createGetPmInput("XPONDER-2-3",
358 StringConstants.NETWORK_TOKEN);
359 GetPmInput getPmInputA = createGetPmInput("XPONDER-1-2",
360 StringConstants.NETWORK_TOKEN);
362 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZ)))
363 .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
364 Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputA)))
365 .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
366 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
367 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
372 public void serviceImplementationServiceActive() throws InterruptedException, ExecutionException {
374 ServiceImplementationRequestInput input = ServiceDataUtils
375 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
376 writePortMapping(input, StringConstants.NETWORK_TOKEN);
377 GetPmOutput getPmOutput = new GetPmOutputBuilder()
378 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
379 GetPmOutput getPmOutput1 = null;
380 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput1)
382 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
384 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
386 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
387 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
392 public void serviceImplementationServiceActive2() throws InterruptedException, ExecutionException {
394 ServiceImplementationRequestInput input = ServiceDataUtils
395 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
396 writePortMapping(input, StringConstants.NETWORK_TOKEN);
397 GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
398 Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput)
400 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
402 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
404 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
405 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
410 public void serviceImplementationServiceInActive4() throws InterruptedException, ExecutionException {
412 ServiceImplementationRequestInput input = ServiceDataUtils
413 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
414 writePortMapping(input, StringConstants.NETWORK_TOKEN);
415 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
416 .setPmparameterValue("1").build();
417 List<Measurements> measurementsList = new ArrayList<Measurements>();
418 measurementsList.add(measurements);
419 GetPmOutput getPmOutput = new GetPmOutputBuilder()
420 .setNodeId("node1").setMeasurements(measurementsList).build();
422 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
423 .getPm(Mockito.any());
424 ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
426 Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
428 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
429 Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
434 public void serviceImplementationServiceInActive5() throws InterruptedException, ExecutionException {
436 ServiceImplementationRequestInput input = ServiceDataUtils
437 .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
438 writePortMapping(input, StringConstants.NETWORK_TOKEN);
439 Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
440 .setPmparameterValue("112000000000d").build();
441 List<Measurements> measurementsList = new ArrayList<Measurements>();
442 measurementsList.add(measurements);
443 GetPmOutput getPmOutput = new GetPmOutputBuilder()
444 .setNodeId("node1").setMeasurements(measurementsList).build();
446 Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
447 .getPm(Mockito.any());
448 ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
449 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());