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 org.junit.Assert;
  13 import org.junit.Before;
  14 import org.junit.Test;
  15 import org.mockito.Mockito;
  16 import org.opendaylight.controller.md.sal.binding.api.MountPoint;
  17 import org.opendaylight.controller.md.sal.binding.api.MountPointService;
  18 import org.opendaylight.transportpce.common.ResponseCodes;
  19 import org.opendaylight.transportpce.common.crossconnect.CrossConnect;
  20 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
  21 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
  22 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
  23 import org.opendaylight.transportpce.common.mapping.PortMapping;
  24 import org.opendaylight.transportpce.common.mapping.PortMappingImpl;
  25 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
  26 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
  27 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
  28 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthService;
  29 import org.opendaylight.transportpce.renderer.NetworkModelWavelengthServiceImpl;
  30 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
  31 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
  32 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
  33 import org.opendaylight.transportpce.renderer.stub.OlmServiceStub;
  34 import org.opendaylight.transportpce.renderer.utils.MountPointUtils;
  35 import org.opendaylight.transportpce.renderer.utils.ServiceDataUtils;
  36 import org.opendaylight.transportpce.test.AbstractTest;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.types.rev161014.PmGranularity;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceTypeEnum;
  39 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestInput;
  40 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestOutput;
  41 import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev170907.olm.get.pm.input.ResourceIdentifierBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmInput;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmInputBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmOutput;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.GetPmOutputBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.OlmService;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.get.pm.output.Measurements;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.olm.rev170418.get.pm.output.MeasurementsBuilder;
  49 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  50
  51 public class RendererServiceOperationsImplTest extends AbstractTest {
  52
  53     private MountPointService mountPointService;
  54     private DeviceTransactionManager deviceTransactionManager;
  55     private RendererServiceOperationsImpl rendererServiceOperations;
  56     private OpenRoadmInterfaces openRoadmInterfaces;
  57     private DeviceRendererService deviceRenderer;
  58     private PortMapping portMapping;
  59     private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
  60     private CrossConnect crossConnect;
  61     private OlmService olmService;
  62     private NetworkModelWavelengthService networkModelWavelengthService;
  63
  64     private void setMountPoint(MountPoint mountPoint) {
  65         this.mountPointService = new MountPointServiceStub(mountPoint);
  66         this.deviceTransactionManager = new DeviceTransactionManagerImpl(this.mountPointService, 3000);
  67         this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(this.deviceTransactionManager);
  68         this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces);
  69         this.portMapping = new PortMappingImpl(this.getDataBroker(), this.deviceTransactionManager,
  70             openRoadmInterfaces);
  71         this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(portMapping,
  72             openRoadmInterfaces);
  73         this.crossConnect = new CrossConnectImpl(this.deviceTransactionManager);
  74         this.deviceRenderer = new DeviceRendererServiceImpl(this.getDataBroker(),
  75             this.deviceTransactionManager, openRoadmInterfaceFactory, openRoadmInterfaces, crossConnect, portMapping);
  76     }
  77
  78     @Before
  79     public void setUp() throws OpenRoadmInterfaceException {
  80         setMountPoint(new MountPointStub(getDataBroker()));
  81         this.olmService = new OlmServiceStub();
  82         this.olmService = Mockito.spy(this.olmService);
  83         this.networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(getDataBroker());
  84         this.rendererServiceOperations =  new RendererServiceOperationsImpl(this.deviceRenderer, this.olmService,
  85             getDataBroker(), this.networkModelWavelengthService);
  86         Mockito.doNothing().when(this.openRoadmInterfaces).postEquipmentState(Mockito.anyString(),
  87                 Mockito.anyString(), Mockito.anyBoolean());
  88     }
  89
  90
  91     @Test
  92     public void serviceImplementationTerminationPointAsResourceTtp() {
  93
  94         ServiceImplementationRequestInput input = ServiceDataUtils
  95             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.TTP_TOKEN);
  96         writePortMapping(input, OpenRoadmInterfacesImpl.TTP_TOKEN);
  97         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
  98         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
  99
 100     }
 101
 102     @Test
 103     public void serviceImplementationTerminationPointAsResourcePp() {
 104
 105         ServiceImplementationRequestInput input = ServiceDataUtils
 106             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.PP_TOKEN);
 107         writePortMapping(input, OpenRoadmInterfacesImpl.PP_TOKEN);
 108         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 109         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 110
 111     }
 112
 113     @Test
 114     public void serviceImplementationTerminationPointAsResourceNetwork() {
 115
 116         ServiceImplementationRequestInput input = ServiceDataUtils
 117             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 118         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 119         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 120         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 121
 122     }
 123
 124     @Test
 125     public void serviceImplementationTerminationPointAsResourceClient() {
 126         ServiceImplementationRequestInput input = ServiceDataUtils
 127             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.CLIENT_TOKEN);
 128         writePortMapping(input, OpenRoadmInterfacesImpl.CLIENT_TOKEN);
 129         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 130         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 131     }
 132
 133     @Test
 134     public void serviceImplementationTerminationPointAsResourceNoMapping() {
 135         String[] interfaceTokens = {
 136             OpenRoadmInterfacesImpl.NETWORK_TOKEN,
 137             OpenRoadmInterfacesImpl.CLIENT_TOKEN,
 138             OpenRoadmInterfacesImpl.TTP_TOKEN,
 139             OpenRoadmInterfacesImpl.PP_TOKEN
 140         };
 141
 142         for (String tpToken : interfaceTokens) {
 143             ServiceImplementationRequestInput input = ServiceDataUtils
 144                 .buildServiceImplementationRequestInputTerminationPointResource(tpToken);
 145             ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 146             if (tpToken.equals(OpenRoadmInterfacesImpl.CLIENT_TOKEN)) {
 147                 Assert.assertEquals(ResponseCodes.RESPONSE_OK,
 148                     result.getConfigurationResponseCommon().getResponseCode());
 149             } else {
 150                 Assert.assertEquals(ResponseCodes.RESPONSE_FAILED,
 151                     result.getConfigurationResponseCommon().getResponseCode());
 152             }
 153         }
 154     }
 155
 156     private void writePortMapping(ServiceImplementationRequestInput input, String tpToken) {
 157         MountPointUtils.writeMapping(
 158             input.getServiceAEnd().getNodeId(),
 159             input.getServiceAEnd().getNodeId() + "-" + tpToken,
 160             this.deviceTransactionManager
 161         );
 162         MountPointUtils.writeMapping(
 163                 input.getServiceZEnd().getNodeId(),
 164                 input.getServiceZEnd().getNodeId() + "-"
 165                     + input.getServiceAEnd().getNodeId() + "-" + tpToken,
 166                 this.deviceTransactionManager
 167         );
 168         MountPointUtils.writeMapping(
 169                 input.getServiceAEnd().getNodeId(),
 170                 input.getServiceAEnd().getNodeId() + "-"
 171                     + input.getServiceZEnd().getNodeId() + "-" + tpToken,
 172                 this.deviceTransactionManager
 173         );
 174         MountPointUtils.writeMapping(
 175             input.getServiceZEnd().getNodeId(),
 176             input.getServiceZEnd().getNodeId() + "-" + tpToken,
 177             this.deviceTransactionManager
 178         );
 179     }
 180
 181     @Test
 182     public void serviceImplementationRollbackAllNecessary() {
 183
 184         ServiceImplementationRequestInput input = ServiceDataUtils
 185             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 186         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 187         Mockito.doReturn(RpcResultBuilder.failed().buildFuture()).when(this.olmService)
 188             .servicePowerSetup(Mockito.any());
 189         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 190         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 191
 192     }
 193
 194     private GetPmInput createGetPmInput(String nodeId, String tp) {
 195         GetPmInputBuilder getPmIpBldr = new GetPmInputBuilder();
 196         getPmIpBldr.setNodeId(nodeId);
 197         getPmIpBldr.setGranularity(PmGranularity._15min);
 198         ResourceIdentifierBuilder rsrcBldr = new ResourceIdentifierBuilder();
 199         rsrcBldr.setResourceName(tp + "-OTU");
 200         getPmIpBldr.setResourceIdentifier(rsrcBldr.build());
 201         getPmIpBldr.setResourceType(ResourceTypeEnum.Interface);
 202         return getPmIpBldr.build();
 203     }
 204
 205     @Test
 206     public void serviceImplementationServiceInActive() {
 207
 208         ServiceImplementationRequestInput input = ServiceDataUtils
 209             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 210         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 211         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 212             .setPmparameterValue("1").build();
 213         List<Measurements> measurementsList = new ArrayList<Measurements>();
 214         measurementsList.add(measurements);
 215         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 216             .setNodeId("node1").setMeasurements(measurementsList).build();
 217         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 218             .getPm(Mockito.any());
 219         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 220         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 221
 222     }
 223
 224     @Test
 225     public void serviceImplementationServiceInActive2() {
 226
 227         ServiceImplementationRequestInput input = ServiceDataUtils
 228             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 229         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 230         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 231             .setPmparameterValue("1").build();
 232         List<Measurements> measurementsList = new ArrayList<Measurements>();
 233         measurementsList.add(measurements);
 234         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 235             .setNodeId("node1").setMeasurements(measurementsList).build();
 236         GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
 237             .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 238
 239         GetPmInput getPmInputZZ = createGetPmInput(input.getServiceZEnd().getNodeId(),
 240             input.getServiceZEnd().getNodeId() + "-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 241         GetPmInput getPmInputAZ = createGetPmInput(input.getServiceAEnd().getNodeId(),
 242             input.getServiceAEnd().getNodeId() + "-" + input.getServiceZEnd().getNodeId() + "-"
 243                 + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 244
 245         GetPmInput getPmInputZA = createGetPmInput(input.getServiceZEnd().getNodeId(),
 246             input.getServiceZEnd().getNodeId() + "-" + input.getServiceAEnd().getNodeId() + "-"
 247                 + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 248         GetPmInput getPmInputAA = createGetPmInput(input.getServiceAEnd().getNodeId(),
 249             input.getServiceAEnd().getNodeId() + "-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 250
 251         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZZ)))
 252             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 253         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputAZ)))
 254             .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
 255         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZA)))
 256             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 257         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputAA)))
 258             .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
 259         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 260         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 261
 262     }
 263
 264     @Test
 265     public void serviceImplementationServiceInActive3() {
 266
 267         ServiceImplementationRequestInput input = ServiceDataUtils
 268             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 269         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 270         Measurements measurements = new MeasurementsBuilder().setPmparameterName("FECUncorrectableBlocks")
 271             .setPmparameterValue("1").build();
 272         List<Measurements> measurementsList = new ArrayList<Measurements>();
 273         measurementsList.add(measurements);
 274         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 275                 .setNodeId("node1").setMeasurements(measurementsList).build();
 276         GetPmOutput getPmOutput2 = new GetPmOutputBuilder()
 277                 .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 278
 279         GetPmInput getPmInputZZ = createGetPmInput(input.getServiceZEnd().getNodeId(),
 280             input.getServiceZEnd().getNodeId() + "-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 281         GetPmInput getPmInputAZ = createGetPmInput(input.getServiceAEnd().getNodeId(),
 282             input.getServiceAEnd().getNodeId() + "-" + input.getServiceZEnd().getNodeId() + "-"
 283                 + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 284
 285         GetPmInput getPmInputZA = createGetPmInput(input.getServiceZEnd().getNodeId(),
 286             input.getServiceZEnd().getNodeId() + "-" + input.getServiceAEnd().getNodeId() + "-"
 287                 + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 288         GetPmInput getPmInputAA = createGetPmInput(input.getServiceAEnd().getNodeId(),
 289             input.getServiceAEnd().getNodeId() + "-" + OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 290
 291         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZZ)))
 292             .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
 293         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputAZ)))
 294             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 295         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputZA)))
 296             .thenReturn(RpcResultBuilder.success(getPmOutput2).buildFuture());
 297         Mockito.when(this.olmService.getPm(Mockito.eq(getPmInputAA)))
 298             .thenReturn(RpcResultBuilder.success(getPmOutput).buildFuture());
 299         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 300         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 301
 302     }
 303
 304     @Test
 305     public void serviceImplementationServiceActive() {
 306
 307         ServiceImplementationRequestInput input = ServiceDataUtils
 308             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 309         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 310         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 311             .setNodeId("node1").setMeasurements(new ArrayList<>()).build();
 312         GetPmOutput getPmOutput1 = null;
 313         Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput1)
 314             .buildFuture());
 315         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 316         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 317
 318     }
 319
 320     @Test
 321     public void serviceImplementationServiceActive2() {
 322
 323         ServiceImplementationRequestInput input = ServiceDataUtils
 324             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 325         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 326         GetPmOutput getPmOutput = new GetPmOutputBuilder().setMeasurements(new ArrayList<>()).build();
 327         Mockito.when(this.olmService.getPm(Mockito.any())).thenReturn(RpcResultBuilder.success(getPmOutput)
 328             .buildFuture());
 329         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 330         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 331
 332     }
 333
 334     @Test
 335     public void serviceImplementationServiceInActive4() {
 336
 337         ServiceImplementationRequestInput input = ServiceDataUtils
 338             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 339         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 340         Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
 341             .setPmparameterValue("1").build();
 342         List<Measurements> measurementsList = new ArrayList<Measurements>();
 343         measurementsList.add(measurements);
 344         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 345             .setNodeId("node1").setMeasurements(measurementsList).build();
 346
 347         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 348             .getPm(Mockito.any());
 349         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 350         Assert.assertEquals(ResponseCodes.RESPONSE_OK, result.getConfigurationResponseCommon().getResponseCode());
 351
 352     }
 353
 354     @Test
 355     public void serviceImplementationServiceInActive5() {
 356
 357         ServiceImplementationRequestInput input = ServiceDataUtils
 358             .buildServiceImplementationRequestInputTerminationPointResource(OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 359         writePortMapping(input, OpenRoadmInterfacesImpl.NETWORK_TOKEN);
 360         Measurements measurements = new MeasurementsBuilder().setPmparameterName("preFECCorrectedErrors")
 361             .setPmparameterValue("112000000000d").build();
 362         List<Measurements> measurementsList = new ArrayList<Measurements>();
 363         measurementsList.add(measurements);
 364         GetPmOutput getPmOutput = new GetPmOutputBuilder()
 365             .setNodeId("node1").setMeasurements(measurementsList).build();
 366
 367         Mockito.doReturn(RpcResultBuilder.success(getPmOutput).buildFuture()).when(this.olmService)
 368             .getPm(Mockito.any());
 369         ServiceImplementationRequestOutput result = this.rendererServiceOperations.serviceImplementation(input);
 370         Assert.assertEquals(ResponseCodes.RESPONSE_FAILED, result.getConfigurationResponseCommon().getResponseCode());
 371
 372     }
 373 }