/* * Copyright © 2019 Orange, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.transportpce.olm.power; import static org.junit.jupiter.api.Assertions.assertEquals; import java.util.HashMap; import java.util.Map; import java.util.Optional; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.mockito.ArgumentMatchers; import org.mockito.Mockito; import org.opendaylight.mdsal.binding.api.MountPoint; import org.opendaylight.mdsal.binding.api.MountPointService; import org.opendaylight.transportpce.common.StringConstants; import org.opendaylight.transportpce.common.crossconnect.CrossConnect; import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl; import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121; import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl221; import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl710; import org.opendaylight.transportpce.common.device.DeviceTransactionManager; import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl; import org.opendaylight.transportpce.common.mapping.MappingUtils; import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl; import org.opendaylight.transportpce.common.mapping.PortMapping; import org.opendaylight.transportpce.common.mapping.PortMappingImpl; import org.opendaylight.transportpce.common.mapping.PortMappingVersion121; import org.opendaylight.transportpce.common.mapping.PortMappingVersion221; import org.opendaylight.transportpce.common.mapping.PortMappingVersion710; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221; import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl710; import org.opendaylight.transportpce.olm.stub.MountPointServiceStub; import org.opendaylight.transportpce.olm.stub.MountPointStub; import org.opendaylight.transportpce.olm.util.OlmPowerServiceRpcImplUtil; import org.opendaylight.transportpce.olm.util.OlmUtils; import org.opendaylight.transportpce.test.AbstractTest; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupInput; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.OpenroadmNodeVersion; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.mapping.Mapping; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.mapping.MappingBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.mapping.MappingKey; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.network.Nodes; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.network.NodesBuilder; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.network.nodes.NodeInfoBuilder; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.OpticalControlMode; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.RatioDB; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.interfaces.grp.InterfaceBuilder; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.NodeTypes; import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.Interface1Builder; import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.ots.container.Ots; import org.opendaylight.yang.gen.v1.http.org.openroadm.optical.transport.interfaces.rev161014.ots.container.OtsBuilder; import org.opendaylight.yangtools.yang.common.Decimal64; @Disabled public class PowerMgmtPowerMockTest extends AbstractTest { private MountPoint mountPoint; private MountPointService mountPointService; private DeviceTransactionManager deviceTransactionManager; private CrossConnect crossConnect; private OpenRoadmInterfaces openRoadmInterfaces; private PortMapping portMapping; private PowerMgmt powerMgmt; private CrossConnectImpl121 crossConnectImpl121; private CrossConnectImpl221 crossConnectImpl22; private CrossConnectImpl710 crossConnectImpl710; private MappingUtils mappingUtils; private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121; private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl22; private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710; private PortMappingVersion710 portMappingVersion710; private PortMappingVersion221 portMappingVersion22; private PortMappingVersion121 portMappingVersion121; @BeforeEach void setUp() { this.mountPoint = new MountPointStub(getDataBroker()); this.mountPointService = new MountPointServiceStub(mountPoint); this.mappingUtils = new MappingUtilsImpl(getDataBroker()); this.mappingUtils = Mockito.spy(new MappingUtilsImpl(getDataBroker())); Mockito.doReturn(StringConstants.OPENROADM_DEVICE_VERSION_1_2_1).when(mappingUtils) .getOpenRoadmVersion(Mockito.anyString()); this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000); this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager); this.crossConnectImpl22 = new CrossConnectImpl221(deviceTransactionManager); this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121, this.crossConnectImpl22, this.crossConnectImpl710); this.portMappingVersion22 = new PortMappingVersion221(getDataBroker(), deviceTransactionManager); this.portMappingVersion121 = new PortMappingVersion121(getDataBroker(), deviceTransactionManager); this.portMappingVersion710 = new PortMappingVersion710(getDataBroker(), deviceTransactionManager); this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710, this.portMappingVersion22, this.portMappingVersion121); this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager); this.openRoadmInterfacesImpl22 = new OpenRoadmInterfacesImpl221(deviceTransactionManager, this.portMapping); this.openRoadmInterfacesImpl710 = new OpenRoadmInterfacesImpl710(deviceTransactionManager, this.portMapping); this.openRoadmInterfaces = new OpenRoadmInterfacesImpl((this.deviceTransactionManager), this.mappingUtils,this.openRoadmInterfacesImpl121,this.openRoadmInterfacesImpl22, this.openRoadmInterfacesImpl710); this.openRoadmInterfaces = Mockito.spy(this.openRoadmInterfaces); this.portMapping = Mockito.spy(this.portMapping); this.powerMgmt = new PowerMgmtImpl(this.openRoadmInterfaces, this.crossConnect, this.deviceTransactionManager, this.portMapping, 1000, 1000); } @Test void testSetPowerMockingUtil() { Mockito.mockStatic(OlmUtils.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getXpdrNodesFromNodesBuilderDeg()); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput2(); boolean output = this.powerMgmt.setPower(input); assertEquals(false, output); } @Test void testSetPowerMockingUtilNetwokType() throws OpenRoadmInterfaceException { Mockito.mockStatic(OlmUtils.class); Mockito.mockStatic(PowerMgmtVersion121.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getXpdrNodesFromNodesBuilderNetwork()); Map txPowerRangeMap = new HashMap<>(); Mockito.when(PowerMgmtVersion121.getXponderPowerRange( Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), ArgumentMatchers.eq(deviceTransactionManager))) .thenReturn(txPowerRangeMap); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput2(); OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy = Mockito.mock(OpenRoadmInterfacesImpl121.class); Mockito.when(openRoadmInterfacesImpl121Spy.getInterface(Mockito.anyString(), Mockito.anyString())) .thenReturn(Optional.empty()); PowerMgmtImpl powerMgmtImpl = getNewPowerMgmt(openRoadmInterfacesImpl121Spy,this.crossConnect); boolean output = powerMgmtImpl.setPower(input); assertEquals(true, output); } @Test void testSetPowerMockingUtilNetwokTypeMoreThanOneNode() throws OpenRoadmInterfaceException { Mockito.mockStatic(OlmUtils.class); Mockito.mockStatic(PowerMgmtVersion121.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getXpdrNodesFromNodesBuilderNetwork()); Map txPowerRangeMap = new HashMap<>(); Mockito.when(PowerMgmtVersion121 .getXponderPowerRange(Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), ArgumentMatchers.eq(deviceTransactionManager))) .thenReturn(txPowerRangeMap); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput2(); OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy = Mockito.mock(OpenRoadmInterfacesImpl121.class); Mockito.when(openRoadmInterfacesImpl121Spy.getInterface(Mockito.anyString(), Mockito.anyString())) .thenReturn(Optional.empty()); PowerMgmtImpl powerMgmtImpl = getNewPowerMgmt(openRoadmInterfacesImpl121Spy,this.crossConnect); boolean output = powerMgmtImpl.setPower(input); assertEquals(true, output); } @Test void testSetPowerXpdrNodes() { Mockito.mockStatic(OlmUtils.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getXpdrNodesFromNodesBuilderDeg()); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput3(); boolean output = this.powerMgmt.setPower(input); assertEquals(true, output); } @Test void testSetPowerRdmNodesReturnInterfaceEmpty() throws OpenRoadmInterfaceException { Mockito.mockStatic(OlmUtils.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getRdmNodesFromNodesBuilder()); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput3(); OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy = Mockito.mock(OpenRoadmInterfacesImpl121.class); Mockito.when(openRoadmInterfacesImpl121Spy.getInterface(Mockito.anyString(), Mockito.anyString())) .thenReturn(Optional.empty()); PowerMgmtImpl powerMgmtImpl = getNewPowerMgmt(openRoadmInterfacesImpl121Spy,this.crossConnect); boolean output = powerMgmtImpl.setPower(input); assertEquals(false, output); } @Test void testSetPowerRdmNodesThrowsException() throws OpenRoadmInterfaceException { Mockito.mockStatic(OlmUtils.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getRdmNodesFromNodesBuilder()); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput3(); OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy = Mockito.mock(OpenRoadmInterfacesImpl121.class); Mockito.when(openRoadmInterfacesImpl121Spy.getInterface(Mockito.anyString(), Mockito.anyString())) .thenThrow(new OpenRoadmInterfaceException("error thrown by unit tests ")); PowerMgmtImpl powerMgmtImpl = getNewPowerMgmt(openRoadmInterfacesImpl121Spy,this.crossConnect); boolean output = powerMgmtImpl.setPower(input); assertEquals(false, output); } @Test void testSetPowerRdmNodesReturnInterface() throws OpenRoadmInterfaceException { Mockito.mockStatic(OlmUtils.class); Mockito.when(this.portMapping.getNode(Mockito.anyString())) .thenReturn(getRdmNodesFromNodesBuilder()); ServicePowerSetupInput input = OlmPowerServiceRpcImplUtil.getServicePowerSetupInput3(); OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy = Mockito.mock(OpenRoadmInterfacesImpl121.class); Ots ots = new OtsBuilder().setSpanLossTransmit(new RatioDB(Decimal64.valueOf("23"))).build(); Interface1Builder intf1Builder = new Interface1Builder(); Mockito.when(openRoadmInterfacesImpl121Spy.getInterface(Mockito.anyString(), Mockito.anyString())).thenReturn( Optional.of(new InterfaceBuilder().addAugmentation(intf1Builder.setOts(ots).build()) .build())); CrossConnect crossConnectMock = Mockito.mock(CrossConnectImpl.class); Mockito.when(crossConnectMock .setPowerLevel(Mockito.anyString(), OpticalControlMode.Power.getName(), Mockito.any(), Mockito.anyString())).thenReturn(true); PowerMgmtImpl powerMgmtImpl = getNewPowerMgmt(openRoadmInterfacesImpl121Spy,crossConnectMock); boolean output = powerMgmtImpl.setPower(input); assertEquals(true, output); } private PowerMgmtImpl getNewPowerMgmt(OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121Spy, CrossConnect crossConnectMock) { OpenRoadmInterfacesImpl openRoadmInterfacesSpy = new OpenRoadmInterfacesImpl((this.deviceTransactionManager), this.mappingUtils, openRoadmInterfacesImpl121Spy, this.openRoadmInterfacesImpl22, this.openRoadmInterfacesImpl710); openRoadmInterfacesSpy = Mockito.spy(openRoadmInterfacesSpy); return new PowerMgmtImpl(openRoadmInterfacesSpy, crossConnectMock, this.deviceTransactionManager, this.portMapping, 0, 0); } private Nodes getXpdrNodesFromNodesBuilderDeg() { MappingBuilder mappingBuilder = getMappingBuilderDeg(); Mapping mapping = mappingBuilder.build(); return new NodesBuilder().setNodeId("node 1") .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr).build()) .setMapping(Map.of(mapping.key(),mapping)) .build(); } private Nodes getXpdrNodesFromNodesBuilderNetwork() { MappingBuilder mappingBuilder = getMappingBuilderNetWork(); Mapping mapping = mappingBuilder.build(); return new NodesBuilder().setNodeId("node 1") .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr) .setOpenroadmVersion(OpenroadmNodeVersion._121) .build()) .setMapping(Map.of(mapping.key(),mapping)) .build(); } private Nodes getRdmNodesFromNodesBuilder() { MappingBuilder mappingBuilder = getMappingBuilderDeg(); Mapping mapping = mappingBuilder.build(); return new NodesBuilder().setNodeId("node 1").setNodeInfo( new NodeInfoBuilder().setNodeType(NodeTypes.Rdm) .setOpenroadmVersion(OpenroadmNodeVersion._121) .build()) .setMapping(Map.of(mapping.key(),mapping)) .build(); } private MappingBuilder getMappingBuilderDeg() { return new MappingBuilder() .withKey(new MappingKey("deg")) .setLogicalConnectionPoint("logicalConnPoint") .setSupportingOts("OTS") .setSupportingCircuitPackName("2/0") .setSupportingOms("OMS") .setSupportingPort("8080") .setSupportingCircuitPackName("circuit1"); } private MappingBuilder getMappingBuilderNetWork() { return new MappingBuilder() .withKey(new MappingKey("network")) .setLogicalConnectionPoint("logicalConnPoint") .setSupportingOts("OTS") .setSupportingCircuitPackName("2/0") .setSupportingOms("OMS") .setSupportingPort("8080") .setSupportingCircuitPackName("circuit1"); } }