renderer/src/test/java/org/opendaylight/transportpce/renderer/provisiondevice/RendererServiceOperationsImplTest.java

   1 /*
   2  * Copyright © 2018 Orange Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.transportpce.renderer.provisiondevice;
   9
  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.fixedflex.FixedFlexImpl;
  30 import org.opendaylight.transportpce.common.fixedflex.FixedFlexInterface;
  31 import org.opendaylight.transportpce.common.fixedflex.FlexGridImpl;
  32 import org.opendaylight.transportpce.common.mapping.MappingUtils;
  33 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
  34 import org.opendaylight.transportpce.common.mapping.PortMapping;
  35 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
  36 import org.opendaylight.transportpce.common.mapping.PortMappingVersion121;
  37 import org.opendaylight.transportpce.common.mapping.PortMappingVersion221;
  38 import org.opendaylight.transportpce.common.mapping.PortMappingVersion710;
  39 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
  40 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
  41 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
  42 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
  43 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221;
  44 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl710;
  45 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthService;
  46 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthServiceImpl;
  47 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface121;
  48 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterface221;
  49 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
  50 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmOtnInterface221;
  51 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
  52 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
  53 import org.opendaylight.transportpce.renderer.stub.OlmServiceStub;
  54 import org.opendaylight.transportpce.renderer.utils.MountPointUtils;
  55 import org.opendaylight.transportpce.renderer.utils.NotificationPublishServiceMock;
  56 import org.opendaylight.transportpce.renderer.utils.ServiceDataUtils;
  57 import org.opendaylight.transportpce.test.AbstractTest;
  58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev200128.ServicePathOutputBuilder;
  59 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
  60 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInputBuilder;
  61 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutput;
  62 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutputBuilder;
  63 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.TransportpceOlmService;
  64 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.Measurements;
  65 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.MeasurementsBuilder;
  66 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestInput;
  67 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev201125.ServiceImplementationRequestOutput;
  68 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmGranularity;
  69 import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
  70 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev200615.olm.get.pm.input.ResourceIdentifierBuilder;
  71 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  72
  73 @Ignore
  74 public class RendererServiceOperationsImplTest extends AbstractTest {
  75
  76     private MountPointService mountPointService;
  77     private DeviceTransactionManager deviceTransactionManager;
  78     private RendererServiceOperationsImpl rendererServiceOperations;
  79     private OpenRoadmInterfaces openRoadmInterfaces;
  80     private DeviceRendererService deviceRenderer;
  81     private OtnDeviceRendererService otnDeviceRendererService;
  82     private PortMapping portMapping;
  83     private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
  84     private CrossConnect crossConnect;
  85     private TransportpceOlmService olmService;
  86     private NetworkModelWavelengthService networkModelWavelengthService;
  87     private MappingUtils mappingUtils;
  88     private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
  89     private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
  90     private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
  91     private PortMappingVersion710 portMappingVersion710;
  92     private PortMappingVersion221 portMappingVersion22;
  93     private PortMappingVersion121 portMappingVersion121;
  94     private CrossConnectImpl121 crossConnectImpl121;
  95     private CrossConnectImpl221 crossConnectImpl221;
  96
  97     private void setMountPoint(MountPoint mountPoint) {
  98         this.mountPointService = new MountPointServiceStub(mountPoint);
  99         this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
 100         this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
 101         this.openRoadmInterfacesImpl221 = new OpenRoadmInterfacesImpl221(deviceTransactionManager);
 102         this.openRoadmInterfacesImpl710 = new OpenRoadmInterfacesImpl710(deviceTransactionManager);
 103         this.mappingUtils = new MappingUtilsImpl(getDataBroker());
 104         this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
 105             openRoadmInterfacesImpl121, openRoadmInterfacesImpl221, openRoadmInterfacesImpl710);
 106         this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
 107         this.portMappingVersion22 =
 108             new PortMappingVersion221(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
 109         this.portMappingVersion121 =
 110             new PortMappingVersion121(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
 111         this.portMappingVersion710 =
 112             new PortMappingVersion710(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
 113         this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710, this.portMappingVersion22,
 114             this.portMappingVersion121);
 115         FixedFlexInterface fixedFlexInterface = new FixedFlexImpl();
 116         FlexGridImpl flexGrid = new FlexGridImpl();
 117         OpenRoadmInterface121 openRoadmInterface121 = new OpenRoadmInterface121(portMapping,openRoadmInterfaces);
 118         OpenRoadmInterface221 openRoadmInterface221 = new OpenRoadmInterface221(portMapping,openRoadmInterfaces,
 119             fixedFlexInterface, flexGrid);
 120         OpenRoadmOtnInterface221 openRoadmOTNInterface = new OpenRoadmOtnInterface221(portMapping, openRoadmInterfaces);
 121         this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(this.mappingUtils,openRoadmInterface121,
 122             openRoadmInterface221, openRoadmOTNInterface);
 123         this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
 124         this.crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager);
 125         this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
 126             this.crossConnectImpl221);
 127     }
 128
 129     @Before
 130     public void setUp() throws OpenRoadmInterfaceException {
 131         setMountPoint(new MountPointStub(getDataBroker()));
 132         this.olmService = new OlmServiceStub();
 133         this.networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(getDataBroker());
 134         this.deviceRenderer = new DeviceRendererServiceImpl(this.getDataBroker(), this.deviceTransactionManager,
 135             openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping, null);
 136         this.otnDeviceRendererService = new OtnDeviceRendererServiceImpl(openRoadmInterfaceFactory, this.crossConnect,
 137             openRoadmInterfaces, this.deviceTransactionManager, null);
 138         Mockito.doNothing().when(this.openRoadmInterfaces).postEquipmentState(Mockito.anyString(),
 139             Mockito.anyString(), Mockito.anyBoolean());
 140         NotificationPublishService notificationPublishService = new NotificationPublishServiceMock();
 141         this.olmService = Mockito.spy(this.olmService);
 142         this.deviceRenderer = Mockito.spy(this.deviceRenderer);
 143         this.rendererServiceOperations =  new RendererServiceOperationsImpl(this.deviceRenderer,
 144             this.otnDeviceRendererService, this.olmService, getDataBroker(), this.networkModelWavelengthService,
 145             notificationPublishService);
 146
 147         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 148             .setSuccess(true);
 149         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 150             Mockito.any());
 151     }
 152
 153     @Test
 154     public void serviceImplementationTerminationPointAsResourceTtp() throws InterruptedException, ExecutionException {
 155
 156         ServiceImplementationRequestInput input = ServiceDataUtils
 157             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
 158         writePortMapping(input, StringConstants.TTP_TOKEN);
 159         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 160             .setSuccess(true);
 161         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 162             Mockito.any());
 163         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 164         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 165
 166     }
 167
 168     @Test
 169     public void serviceImplementationTerminationPointAsResourceTtp2() throws InterruptedException, ExecutionException {
 170
 171         ServiceImplementationRequestInput input = ServiceDataUtils
 172             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.TTP_TOKEN);
 173         writePortMapping(input, StringConstants.TTP_TOKEN);
 174         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 175             .setSuccess(true);
 176         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 177             Mockito.any());
 178         Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
 179             .servicePowerSetup(Mockito.any());
 180         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 181         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 182
 183     }
 184
 185     @Test
 186     public void serviceImplementationTerminationPointAsResourcePp() throws InterruptedException, ExecutionException {
 187
 188         ServiceImplementationRequestInput input = ServiceDataUtils
 189             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.PP_TOKEN);
 190         writePortMapping(input, StringConstants.PP_TOKEN);
 191         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 192             .setSuccess(true);
 193         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 194             Mockito.any());
 195         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 196         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 197
 198     }
 199
 200     @Test
 201     public void serviceImplementationTerminationPointAsResourceNetwork()
 202         throws InterruptedException, ExecutionException {
 203
 204         ServiceImplementationRequestInput input = ServiceDataUtils
 205             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 206         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 207         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 208             .setSuccess(true);
 209         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 210             Mockito.any());
 211         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 212         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 213
 214     }
 215
 216     @Test
 217     public void serviceImplementationTerminationPointAsResourceClient()
 218         throws InterruptedException, ExecutionException {
 219
 220         ServiceImplementationRequestInput input = ServiceDataUtils
 221      //       .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.CLIENT_TOKEN);
 222             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.CLIENT_TOKEN);
 223      //   writePortMapping(input, OpenRoadmInterfacesImpl.CLIENT_TOKEN);
 224         writePortMapping(input, StringConstants.CLIENT_TOKEN);
 225         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 226         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 227     }
 228
 229     @Test
 230     public void serviceImplementationTerminationPointAsResourceNoMapping()
 231         throws InterruptedException, ExecutionException {
 232
 233         String[] interfaceTokens = {
 234             StringConstants.NETWORK_TOKEN,
 235             StringConstants.CLIENT_TOKEN,
 236             StringConstants.TTP_TOKEN,
 237             StringConstants.PP_TOKEN
 238         };
 239
 240         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("failed")
 241             .setSuccess(false);
 242         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 243             Mockito.any());
 244
 245         for (String tpToken : interfaceTokens) {
 246             ServiceImplementationRequestInput input = ServiceDataUtils
 247                 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
 248             ServiceImplementationRequestOutput result =
 249                 this.rendererServiceOperations.serviceImplementation(input).get();
 250             Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
 251                 result.getConfigurationResponseCommon().getResponseCode());
 252         }
 253     }
 254
 255     private void writePortMapping(ServiceImplementationRequestInput input, String tpToken) {
 256         MountPointUtils.writeMapping(
 257             input.getServiceAEnd().getNodeId(),
 258             input.getServiceAEnd().getNodeId() + "-" + tpToken,
 259             this.deviceTransactionManager
 260         );
 261         MountPointUtils.writeMapping(
 262             input.getServiceZEnd().getNodeId(),
 263             input.getServiceZEnd().getNodeId() + "-"
 264                 + input.getServiceAEnd().getNodeId() + "-" + tpToken,
 265             this.deviceTransactionManager
 266         );
 267         MountPointUtils.writeMapping(
 268             input.getServiceAEnd().getNodeId(),
 269             input.getServiceAEnd().getNodeId() + "-"
 270                 + input.getServiceZEnd().getNodeId() + "-" + tpToken,
 271             this.deviceTransactionManager
 272         );
 273         MountPointUtils.writeMapping(
 274             input.getServiceZEnd().getNodeId(),
 275             input.getServiceZEnd().getNodeId() + "-" + tpToken,
 276             this.deviceTransactionManager
 277         );
 278     }
 279
 280     @Test
 281     public void serviceImplementationRollbackAllNecessary() throws InterruptedException, ExecutionException {
 282
 283         ServiceImplementationRequestInput input = ServiceDataUtils
 284             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 285         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 286         Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
 287             .servicePowerSetup(Mockito.any());
 288         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 289         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 290
 291     }
 292
 293     private GetPmInput createGetPmInput(String nodeId, String tp) {
 294         GetPmInputBuilder getPmIpBldr = new GetPmInputBuilder();
 295         getPmIpBldr.setNodeId(nodeId);
 296         getPmIpBldr.setGranularity(PmGranularity._15min);
 297         ResourceIdentifierBuilder rsrcBldr = new ResourceIdentifierBuilder();
 298         rsrcBldr.setResourceName(tp + "-OTU");
 299         getPmIpBldr.setResourceIdentifier(rsrcBldr.build());
 300         getPmIpBldr.setResourceType(ResourceTypeEnum.Interface);
 301         return getPmIpBldr.build();
 302     }
 303
 304     @Test
 305     public void serviceImplementationServiceInActive() throws InterruptedException, ExecutionException {
 306
 307         ServiceImplementationRequestInput input = ServiceDataUtils
 308             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 309         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 310         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 311             .setPmparameterValue("1").build();
 312         List<Measurements> measurementsList = new ArrayList<Measurements>();
 313         measurementsList.add(measurements);
 314         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 315             .setNodeId("node1").setMeasurements(measurementsList).build();
 316         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 317             .getPm(Mockito.any());
 318         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 319         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 320
 321     }
 322
 323     @Test
 324     public void serviceImplementationServiceInActive2() throws InterruptedException, ExecutionException {
 325
 326         ServiceImplementationRequestInput input = ServiceDataUtils
 327             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 328         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 329         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 330             .setPmparameterValue("1").build();
 331         List<Measurements> measurementsList = new ArrayList<Measurements>();
 332         measurementsList.add(measurements);
 333         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 334             .setNodeId("node1").setMeasurements(measurementsList).build();
 335         GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
 336             .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 337
 338         Mockito.when(this.olmService.getPm(Mockito.any()))
 339             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 340         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 341         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 342
 343     }
 344
 345     @Test
 346     public void serviceImplementationServiceInActive3() throws InterruptedException, ExecutionException {
 347
 348         ServiceImplementationRequestInput input = ServiceDataUtils
 349             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 350         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 351         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 352             .setPmparameterValue("1").build();
 353         List<Measurements> measurementsList = new ArrayList<Measurements>();
 354         measurementsList.add(measurements);
 355         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 356             .setNodeId("node1").setMeasurements(measurementsList).build();
 357         GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
 358             .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 359
 360         GetPmInput getPmInputZ = createGetPmInput("XPONDER-2-3",
 361             StringConstants.NETWORK_TOKEN);
 362         GetPmInput getPmInputA = createGetPmInput("XPONDER-1-2",
 363             StringConstants.NETWORK_TOKEN);
 364
 365         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZ)))
 366             .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
 367         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputA)))
 368             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 369         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 370         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 371
 372     }
 373
 374     @Test
 375     public void serviceImplementationServiceActive() throws InterruptedException, ExecutionException {
 376
 377         ServiceImplementationRequestInput input = ServiceDataUtils
 378             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 379         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 380         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 381             .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 382         GetPmOutput getPmOutput1 = null;
 383         Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput1)
 384             .buildFuture());
 385         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 386             .setSuccess(true);
 387         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 388             Mockito.any());
 389         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 390         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 391
 392     }
 393
 394     @Test
 395     public void serviceImplementationServiceActive2() throws InterruptedException, ExecutionException {
 396
 397         ServiceImplementationRequestInput input = ServiceDataUtils
 398             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 399         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 400         GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
 401         Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput)
 402             .buildFuture());
 403         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 404             .setSuccess(true);
 405         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 406             Mockito.any());
 407         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 408         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 409
 410     }
 411
 412     @Test
 413     public void serviceImplementationServiceInActive4() throws InterruptedException, ExecutionException {
 414
 415         ServiceImplementationRequestInput input = ServiceDataUtils
 416             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 417         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 418         Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
 419             .setPmparameterValue("1").build();
 420         List<Measurements> measurementsList = new ArrayList<Measurements>();
 421         measurementsList.add(measurements);
 422         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 423             .setNodeId("node1").setMeasurements(measurementsList).build();
 424
 425         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 426             .getPm(Mockito.any());
 427         ServicePathOutputBuilder mockOutputBuilder = new ServicePathOutputBuilder().setResult("success")
 428             .setSuccess(true);
 429         Mockito.doReturn(mockOutputBuilder.build()).when(this.deviceRenderer).setupServicePath(Mockito.any(),
 430             Mockito.any());
 431         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 432         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 433
 434     }
 435
 436     @Test
 437     public void serviceImplementationServiceInActive5() throws InterruptedException, ExecutionException {
 438
 439         ServiceImplementationRequestInput input = ServiceDataUtils
 440             .buildServiceImplementationRequestInputTerminationPointResource(StringConstants.NETWORK_TOKEN);
 441         writePortMapping(input, StringConstants.NETWORK_TOKEN);
 442         Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
 443             .setPmparameterValue("112000000000d").build();
 444         List<Measurements> measurementsList = new ArrayList<Measurements>();
 445         measurementsList.add(measurements);
 446         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 447             .setNodeId("node1").setMeasurements(measurementsList).build();
 448
 449         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 450             .getPm(Mockito.any());
 451         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input).get();
 452         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 453
 454     }
 455 }