X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=common%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fcommon%2Fcrossconnect%2FCrossConnectImpl221Test.java;h=89ff463bcda46991939dfb7a9b333a4305d0a1f8;hb=1b2f9f488bdd54e577c88c230c4875daccc0b93c;hp=8068be6012448358f6cad9c9410c9b0491cb9cac;hpb=3cb0866be6bc8b477849b6ad61e152e565254058;p=transportpce.git diff --git a/common/src/test/java/org/opendaylight/transportpce/common/crossconnect/CrossConnectImpl221Test.java b/common/src/test/java/org/opendaylight/transportpce/common/crossconnect/CrossConnectImpl221Test.java index 8068be601..89ff463bc 100644 --- a/common/src/test/java/org/opendaylight/transportpce/common/crossconnect/CrossConnectImpl221Test.java +++ b/common/src/test/java/org/opendaylight/transportpce/common/crossconnect/CrossConnectImpl221Test.java @@ -8,16 +8,20 @@ package org.opendaylight.transportpce.common.crossconnect; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.anyLong; +import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.when; +import static org.opendaylight.mdsal.common.api.CommitInfo.emptyFluentFuture; -import java.math.BigDecimal; import java.util.List; import java.util.Optional; import java.util.concurrent.CompletableFuture; -import org.junit.Assert; -import org.junit.Before; -import org.junit.Test; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.mockito.Mockito; import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.binding.api.MountPoint; @@ -28,17 +32,18 @@ import org.opendaylight.transportpce.common.Timeouts; import org.opendaylight.transportpce.common.device.DeviceTransaction; import org.opendaylight.transportpce.common.device.DeviceTransactionManager; import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.NodesBuilder; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev201012.network.NodesKey; +import org.opendaylight.transportpce.common.fixedflex.SpectrumInformation; import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.OpticalControlMode; -import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPorts; -import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev170206.degree.ConnectionPortsBuilder; +import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.OrgOpenroadmDeviceData; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.OrgOpenroadmDevice; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.org.openroadm.device.RoadmConnections; +import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.org.openroadm.device.RoadmConnectionsBuilder; import org.opendaylight.yang.gen.v1.http.org.openroadm.device.rev181019.org.openroadm.device.container.org.openroadm.device.RoadmConnectionsKey; -import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev201211.otn.renderer.input.Nodes; +import org.opendaylight.yang.gen.v1.http.org.transportpce.common.types.rev220926.otn.renderer.nodes.Nodes; import org.opendaylight.yangtools.util.concurrent.FluentFutures; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yangtools.yang.common.Decimal64; +import org.opendaylight.yangtools.yang.common.Uint32; public class CrossConnectImpl221Test { private CrossConnectImpl221 crossConnectImpl221 = null; @@ -48,74 +53,74 @@ public class CrossConnectImpl221Test { private MountPoint mountPointMock = mock(MountPoint.class); private DataBroker dataBrokerMock = mock(DataBroker.class); private ReadWriteTransaction rwTransactionMock = mock(ReadWriteTransaction.class); + private DeviceTransaction deviceTransaction = mock(DeviceTransaction.class); - @Before - public void setup() { + @BeforeEach + void setup() { deviceTransactionManager = mock(DeviceTransactionManager.class); crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager); //mock responses for deviceTransactionManager calls - InstanceIdentifier deviceIID = - InstanceIdentifier - .create(OrgOpenroadmDevice.class) - .child(RoadmConnections.class, new RoadmConnectionsKey("1")); + InstanceIdentifier deviceIID = InstanceIdentifier + .builderOfInherited(OrgOpenroadmDeviceData.class, OrgOpenroadmDevice.class) + .child(RoadmConnections.class, new RoadmConnectionsKey("1")) + .build(); - Mockito.when(deviceTransactionManager.getDataFromDevice("deviceId", + when(deviceTransactionManager.getDataFromDevice("deviceId", LogicalDatastoreType.CONFIGURATION, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT)) .thenReturn(Optional.of(mock(RoadmConnections.class))); } @Test - public void getCrossConnectTest() { + void getCrossConnectTest() { Optional res = crossConnectImpl221.getCrossConnect("deviceId", "1"); - Assert.assertTrue("Optional object should have a value", res.isPresent()); + assertTrue(res.isPresent(), "Optional object should have a value"); } @Test - public void postCrossConnectTest() { - Mockito.when(mountPointServiceMock.getMountPoint(any())).thenReturn(Optional.of(mountPointMock)); - Mockito.when(mountPointMock.getService(any())).thenReturn(Optional.of(dataBrokerMock)); - Mockito.when(dataBrokerMock.newReadWriteTransaction()).thenReturn(rwTransactionMock); - Mockito.when(rwTransactionMock.commit()).thenReturn(FluentFutures.immediateNullFluentFuture()); + void postCrossConnectTest() { + when(mountPointServiceMock.getMountPoint(any())).thenReturn(Optional.of(mountPointMock)); + when(mountPointMock.getService(any())).thenReturn(Optional.of(dataBrokerMock)); + when(dataBrokerMock.newReadWriteTransaction()).thenReturn(rwTransactionMock); + when(rwTransactionMock.commit()).thenReturn(FluentFutures.immediateNullFluentFuture()); deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointServiceMock, 3000); crossConnectImpl221 = new CrossConnectImpl221(deviceTransactionManager); - Optional res = crossConnectImpl221.postCrossConnect("deviceId", "srcTp", "destTp", 1, 8); - Assert.assertEquals(res.get(), "srcTp-destTp-1:8"); + SpectrumInformation spectrumInformation = new SpectrumInformation(); + spectrumInformation.setWaveLength(Uint32.valueOf(1)); + spectrumInformation.setLowerSpectralSlotNumber(761); + spectrumInformation.setHigherSpectralSlotNumber(768); + Optional res = crossConnectImpl221.postCrossConnect("deviceId", "srcTp", "destTp", spectrumInformation); + assertEquals(res.get(), "srcTp-destTp-761:768"); } - @Test(expected = NullPointerException.class) - public void setPowerLevelTest() { - InstanceIdentifier deviceIID = - InstanceIdentifier.create(OrgOpenroadmDevice.class) - .child(RoadmConnections.class, new RoadmConnectionsKey("1")); - Mockito.when(deviceTransactionManager.getDataFromDevice("deviceId", - LogicalDatastoreType.OPERATIONAL, deviceIID, + @Test + void setPowerLevelTest() { + InstanceIdentifier deviceIID = InstanceIdentifier + .builderOfInherited(OrgOpenroadmDeviceData.class, OrgOpenroadmDevice.class) + .child(RoadmConnections.class, new RoadmConnectionsKey("1")) + .build(); + when(deviceTransactionManager.getDataFromDevice("deviceId", + LogicalDatastoreType.CONFIGURATION, deviceIID, Timeouts.DEVICE_READ_TIMEOUT, Timeouts.DEVICE_READ_TIMEOUT_UNIT)) - .thenReturn(Optional.of(mock(RoadmConnections.class))); - - Mockito.when(deviceTransactionManager.getDeviceTransaction("deviceId")) - .thenReturn(CompletableFuture.completedFuture(Optional.of(mock(DeviceTransaction.class)))); - boolean res = crossConnectImpl221 - .setPowerLevel("deviceId", OpticalControlMode.GainLoss, new BigDecimal(100), "1"); + .thenReturn(Optional.of(new RoadmConnectionsBuilder().setConnectionName("1").build())); - Assert.assertTrue("set Level should be true", true); + when(deviceTransactionManager.getDeviceTransaction("deviceId")) + .thenReturn(CompletableFuture.completedFuture(Optional.of(deviceTransaction))); + doReturn(emptyFluentFuture()).when(deviceTransaction).commit(anyLong(), any()); + crossConnectImpl221.setPowerLevel("deviceId", OpticalControlMode.GainLoss, Decimal64.valueOf("100"), "1"); + assertTrue(true, "set Level should be true"); } - @Test(expected = NullPointerException.class) - public void postOtnCrossConnect() { - NodesBuilder nodesBldr = new NodesBuilder().withKey(new NodesKey("nodeId")).setNodeId("nodeId"); + @Test + void postOtnCrossConnect() { Nodes nodes = Mockito.mock(Nodes.class); - Mockito.when(nodes.getNodeId()).thenReturn("nodeId"); - Mockito.when(deviceTransactionManager.getDeviceTransaction(any())) - .thenReturn(CompletableFuture.completedFuture(Optional.of(mock(DeviceTransaction.class)))); - Optional res = crossConnectImpl221.postOtnCrossConnect(List.of("src1", "src2"), nodes); - Assert.assertTrue("Optional value should have a value", res.isPresent()); - } - - - private ConnectionPorts getConnectionPorts(String c1, String p1) { - return new ConnectionPortsBuilder().setCircuitPackName(c1).setPortName(p1).build(); + when(nodes.getNodeId()).thenReturn("nodeId"); + when(deviceTransactionManager.getDeviceTransaction(any())) + .thenReturn(CompletableFuture.completedFuture(Optional.of(deviceTransaction))); + doReturn(emptyFluentFuture()).when(deviceTransaction).commit(anyLong(), any()); + Optional res = crossConnectImpl221.postOtnCrossConnect(List.of("src1", "src2"), nodes); + assertTrue(res.isPresent(), "Optional value should have a value"); } }