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;
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;
private PortMappingVersion221 portMappingVersion22;
private PortMappingVersion121 portMappingVersion121;
- @Before
+ @BeforeEach
public void setUp() {
this.mountPoint = new MountPointStub(getDataBroker());
this.mountPointService = new MountPointServiceStub(mountPoint);
this.portMapping = new PortMappingImpl(getDataBroker(), this.portMappingVersion710,
this.portMappingVersion22, this.portMappingVersion121);
this.openRoadmInterfacesImpl121 = new OpenRoadmInterfacesImpl121(deviceTransactionManager);
- this.openRoadmInterfacesImpl22 = new OpenRoadmInterfacesImpl221(deviceTransactionManager, this.portMapping,
- this.portMappingVersion22);
- this.openRoadmInterfacesImpl710 = new OpenRoadmInterfacesImpl710(deviceTransactionManager, this.portMapping,
- this.portMappingVersion710);
+ 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.portMapping = Mockito.spy(this.portMapping);
- this.powerMgmt = new PowerMgmtImpl(getDataBroker(), this.openRoadmInterfaces, this.crossConnect,
- this.deviceTransactionManager, this.portMapping);
+ 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);
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
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
//
// 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
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
.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());
}
.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());
}
/*
.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
.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
.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());
}
**/
}