Convert PowerMgmtImpl of olm into a Component

[transportpce.git] / olm / src / test / java / org / opendaylight / transportpce / olm / OlmPowerServiceRpcImplTest.java

diff --git a/olm/src/test/java/org/opendaylight/transportpce/olm/OlmPowerServiceRpcImplTest.java b/olm/src/test/java/org/opendaylight/transportpce/olm/OlmPowerServiceRpcImplTest.java
index bd7696a2703ffb112ca765bbc24f8213ff9f11f9..a75623d65bffadf8930e1bd19d89e3f274c9a42b 100644 (file)
--- a/olm/src/test/java/org/opendaylight/transportpce/olm/OlmPowerServiceRpcImplTest.java
+++ b/olm/src/test/java/org/opendaylight/transportpce/olm/OlmPowerServiceRpcImplTest.java
@@ -8,6 +8,9 @@
 
 package org.opendaylight.transportpce.olm;
 
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
 import com.google.common.util.concurrent.ListenableFuture;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -15,9 +18,8 @@ import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ExecutionException;
-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.MountPoint;
 import org.opendaylight.mdsal.binding.api.MountPointService;
@@ -26,6 +28,7 @@ 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;
@@ -34,10 +37,12 @@ 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.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.power.PowerMgmt;
 import org.opendaylight.transportpce.olm.power.PowerMgmtImpl;
 import org.opendaylight.transportpce.olm.service.OlmPowerService;
@@ -46,15 +51,15 @@ 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.test.AbstractTest;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmInput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.GetPmOutputBuilder;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupInput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupOutput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerSetupOutputBuilder;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerTurndownInput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerTurndownOutput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.ServicePowerTurndownOutputBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmInput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmOutput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.GetPmOutputBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupInput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupOutput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerSetupOutputBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerTurndownInput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerTurndownOutput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.ServicePowerTurndownOutputBuilder;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.CurrentPmlist;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.CurrentPmlistBuilder;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.pm.rev161014.current.pm.LayerRateBuilder;
@@ -89,15 +94,18 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
     private OlmPowerServiceRpcImpl olmPowerServiceRpc;
     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;
 
-    @Before
+    @BeforeEach
     public void setUp() {
-        this.mountPoint = new MountPointStub(this.getDataBroker());
+        this.mountPoint = new MountPointStub(getDataBroker());
         this.mountPointService = new MountPointServiceStub(mountPoint);
         this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
         this.mappingUtils = Mockito.spy(new MappingUtilsImpl(getDataBroker()));
@@ -106,21 +114,24 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
         this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
         this.crossConnectImpl121 = new CrossConnectImpl121(deviceTransactionManager);
         this.crossConnectImpl22 = new CrossConnectImpl221(deviceTransactionManager);
+        this.crossConnectImpl710 = new CrossConnectImpl710(deviceTransactionManager);
         this.crossConnect = new CrossConnectImpl(deviceTransactionManager, this.mappingUtils, this.crossConnectImpl121,
-                this.crossConnectImpl22);
+                this.crossConnectImpl22, this.crossConnectImpl710);
+        this.portMappingVersion710 = new PortMappingVersion710(getDataBroker(), deviceTransactionManager);
+        this.portMappingVersion22 = new PortMappingVersion221(getDataBroker(), deviceTransactionManager);
+        this.portMappingVersion121 = new PortMappingVersion121(getDataBroker(), deviceTransactionManager);
+        this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710,
+            this.portMappingVersion22, this.portMappingVersion121);
         this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
-        this.openRoadmInterfacesImpl22 = new OpenRoadmInterfacesImpl221(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.portMappingVersion22 =
-                new PortMappingVersion221(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
-        this.portMappingVersion121 =
-                new PortMappingVersion121(getDataBroker(), deviceTransactionManager, this.openRoadmInterfaces);
-        this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion22, this.portMappingVersion121);
+                this.mappingUtils,this.openRoadmInterfacesImpl121,this.openRoadmInterfacesImpl22,
+            this.openRoadmInterfacesImpl710);
         this.portMapping = Mockito.spy(this.portMapping);
-        this.powerMgmt = new PowerMgmtImpl(this.getDataBroker(), this.openRoadmInterfaces, this.crossConnect,
-            this.deviceTransactionManager);
-        this.olmPowerService = new OlmPowerServiceImpl(this.getDataBroker(), this.powerMgmt,
+        this.powerMgmt = new PowerMgmtImpl(this.openRoadmInterfaces, this.crossConnect,
+            this.deviceTransactionManager, this.portMapping, 1000, 1000);
+        this.olmPowerService = new OlmPowerServiceImpl(getDataBroker(), this.powerMgmt,
             this.deviceTransactionManager, this.portMapping,mappingUtils,openRoadmInterfaces);
         this.olmPowerServiceRpc = new OlmPowerServiceRpcImpl(this.olmPowerService);
         //TODO
@@ -132,13 +143,13 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
         GetPmInput input = OlmPowerServiceRpcImplUtil.getGetPmInput();
         //TODO
 //        ListenableFuture<RpcResult<GetPmOutput>> output = this.olmPowerServiceRpc.getPm(input);
-//        Assert.assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
-//        Assert.assertEquals(null, output.get().getResult().getResourceId());
-//        Assert.assertEquals(null, output.get().getResult().getMeasurements());
-//        Assert.assertEquals(null, output.get().getResult().getGranularity());
-//        Assert.assertEquals(null, output.get().getResult().getNodeId());
-//        Assert.assertEquals(null, output.get().getResult().getResourceIdentifier());
-//        Assert.assertEquals(null, output.get().getResult().getResourceType());
+//        assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
+//        assertEquals(null, output.get().getResult().getResourceId());
+//        assertEquals(null, output.get().getResult().getMeasurements());
+//        assertEquals(null, output.get().getResult().getGranularity());
+//        assertEquals(null, output.get().getResult().getNodeId());
+//        assertEquals(null, output.get().getResult().getResourceIdentifier());
+//        assertEquals(null, output.get().getResult().getResourceType());
     }
 
     @Test
@@ -180,12 +191,12 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
         Optional<CurrentPmlist> currentPmlistOptional = Optional.of(new CurrentPmlistBuilder()
             .setCurrentPm(currentPmList).build());
 
-        org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output.Measurements
-            measurements1 = new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm
+        org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.get.pm.output.Measurements
+            measurements1 = new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.get.pm
                 .output.MeasurementsBuilder().setPmparameterName("name").setPmparameterValue("1234").build();
 
 
-        List<org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev170418.get.pm.output
+        List<org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.olm.rev210618.get.pm.output
             .Measurements> measurementsList1 = new ArrayList<>();
         measurementsList1.add(measurements1);
 
@@ -199,8 +210,8 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
 
         ListenableFuture<RpcResult<GetPmOutput>> output = this.olmPowerServiceRpc.getPm(input);
         //TODO
-//        Assert.assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
-//        Assert.assertEquals(null, output.get().getResult().getResourceId());
+//        assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
+//        assertEquals(null, output.get().getResult().getResourceId());
     }
 
 //    @Test
@@ -226,8 +237,8 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
 //
 //        Mockito.doReturn(pmOutputBuilder.build()).when(this.olmPowerService).getPm(Mockito.any());
 //        ListenableFuture<RpcResult<GetPmOutput>> output = this.olmPowerServiceRpc.getPm(input);
-//        Assert.assertEquals(pmOutputBuilder.build(), output.get().getResult());
-//        Assert.assertEquals(true, output.get().isSuccessful());
+//        assertEquals(pmOutputBuilder.build(), output.get().getResult());
+//        assertEquals(true, output.get().isSuccessful());
 //    }
 
     @Test
@@ -235,13 +246,13 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
         GetPmInput input = OlmPowerServiceRpcImplUtil.getGetPmInput();
         ListenableFuture<RpcResult<GetPmOutput>> output = this.olmPowerServiceRpc.getPm(input);
         //TODO
-//        Assert.assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
-//        Assert.assertEquals(null, output.get().getResult().getResourceId());
-//        Assert.assertEquals(null, output.get().getResult().getMeasurements());
-//        Assert.assertEquals(null, output.get().getResult().getGranularity());
-//        Assert.assertEquals(null, output.get().getResult().getNodeId());
-//        Assert.assertEquals(null, output.get().getResult().getResourceIdentifier());
-//        Assert.assertEquals(null, output.get().getResult().getResourceType());
+//        assertEquals(new GetPmOutputBuilder().build(), output.get().getResult());
+//        assertEquals(null, output.get().getResult().getResourceId());
+//        assertEquals(null, output.get().getResult().getMeasurements());
+//        assertEquals(null, output.get().getResult().getGranularity());
+//        assertEquals(null, output.get().getResult().getNodeId());
+//        assertEquals(null, output.get().getResult().getResourceIdentifier());
+//        assertEquals(null, output.get().getResult().getResourceType());
     }
 
     @Test
@@ -252,10 +263,10 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
                 .thenReturn(RpcResultBuilder.success(new ServicePowerSetupOutputBuilder()
                         .setResult("Success").build()).buildFuture());
         ListenableFuture<RpcResult<ServicePowerSetupOutput>> output = this.olmPowerServiceRpc.servicePowerSetup(input);
-        Assert.assertEquals(new ServicePowerSetupOutputBuilder().setResult("Success").build(), output.get()
+        assertEquals(new ServicePowerSetupOutputBuilder().setResult("Success").build(), output.get()
                 .getResult());
-        Assert.assertEquals("Success", output.get().getResult().getResult());
-        Assert.assertEquals(true, output.get().isSuccessful());
+        assertEquals("Success", output.get().getResult().getResult());
+        assertEquals(true, output.get().isSuccessful());
     }
 
 
@@ -268,10 +279,10 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
                         .setResult("Success").build()).buildFuture());
         ListenableFuture<RpcResult<ServicePowerTurndownOutput>> output = this.olmPowerServiceRpc
             .servicePowerTurndown(input);
-        Assert.assertEquals(new ServicePowerTurndownOutputBuilder().setResult("Success").build(), output.get()
+        assertEquals(new ServicePowerTurndownOutputBuilder().setResult("Success").build(), output.get()
             .getResult());
-        Assert.assertEquals("Success", output.get().getResult().getResult());
-        Assert.assertEquals(true, output.get().isSuccessful());
+        assertEquals("Success", output.get().getResult().getResult());
+        assertEquals(true, output.get().isSuccessful());
     }
 
     /*
@@ -284,10 +295,10 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
                         .setResult("Failed").build()).buildFuture());
         ListenableFuture<RpcResult<CalculateSpanlossBaseOutput>> output = this.olmPowerServiceRpc
             .calculateSpanlossBase(input);
-        Assert.assertEquals(new CalculateSpanlossBaseOutputBuilder().setResult("Failed").build(),
+        assertEquals(new CalculateSpanlossBaseOutputBuilder().setResult("Failed").build(),
             output.get().getResult());
-        Assert.assertEquals("Failed", output.get().getResult().getResult());
-        Assert.assertEquals(true, output.get().isSuccessful());
+        assertEquals("Failed", output.get().getResult().getResult());
+        assertEquals(true, output.get().isSuccessful());
     }*/
 
     //TODO
@@ -300,8 +311,8 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
                         .setResult("success").build()).buildFuture());
         ListenableFuture<RpcResult<CalculateSpanlossCurrentOutput>> output = this.olmPowerServiceRpc
             .calculateSpanlossCurrent(input);
-        Assert.assertEquals(null, output.get().getResult());
-        Assert.assertEquals(true, output.get().isSuccessful());
+        assertEquals(null, output.get().getResult());
+        assertEquals(true, output.get().isSuccessful());
     }
 
     @Test
@@ -313,8 +324,8 @@ public class OlmPowerServiceRpcImplTest extends AbstractTest {
                         .setResult(null).build()).buildFuture());
         ListenableFuture<RpcResult<ServicePowerResetOutput>> output = this.olmPowerServiceRpc
             .servicePowerReset(input);
-        Assert.assertEquals(null, output.get().getResult());
-        Assert.assertEquals(true, output.get().isSuccessful());
+        assertEquals(null, output.get().getResult());
+        assertEquals(true, output.get().isSuccessful());
     }
 **/
 }