import org.opendaylight.transportpce.servicehandler.ServiceInput;
import org.opendaylight.transportpce.servicehandler.utils.ServiceDataUtils;
import org.opendaylight.transportpce.test.AbstractTest;
import org.opendaylight.transportpce.servicehandler.ServiceInput;
import org.opendaylight.transportpce.servicehandler.utils.ServiceDataUtils;
import org.opendaylight.transportpce.test.AbstractTest;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.PathComputationRequestOutput;
-import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.PathComputationRequestOutputBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev190624.PathComputationRequestOutput;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev190624.PathComputationRequestOutputBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommon;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommonBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.State;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommon;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.configuration.response.common.ConfigurationResponseCommonBuilder;
import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.State;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.response.parameters.sp.ResponseParametersBuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.response.parameters.sp.response.parameters.PathDescriptionBuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.response.parameters.sp.ResponseParametersBuilder;
import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev171016.response.parameters.sp.response.parameters.PathDescriptionBuilder;
public class ServiceDataStoreOperationsImplTest extends AbstractTest {
private ServiceDataStoreOperationsImpl serviceDataStoreOperations;
public class ServiceDataStoreOperationsImplTest extends AbstractTest {
private ServiceDataStoreOperationsImpl serviceDataStoreOperations;
- Optional<Services> oService = this.serviceDataStoreOperations.getService("service 1");
- Assert.assertFalse(oService.isPresent());
+ Optional<Services> optService = this.serviceDataStoreOperations.getService("service 1");
+ Assert.assertFalse(optService.isPresent());
ServiceCreateInput createInput = ServiceDataUtils.buildServiceCreateInput();
this.serviceDataStoreOperations.createService(createInput);
ServiceCreateInput createInput = ServiceDataUtils.buildServiceCreateInput();
this.serviceDataStoreOperations.createService(createInput);
- Optional<Services> oService = this.serviceDataStoreOperations.getService(createInput.getServiceName());
- Assert.assertTrue(oService.isPresent());
- Assert.assertEquals(createInput.getServiceName(), oService.get().getServiceName());
+ Optional<Services> optService = this.serviceDataStoreOperations.getService(createInput.getServiceName());
+ Assert.assertTrue(optService.isPresent());
+ Assert.assertEquals(createInput.getServiceName(), optService.get().getServiceName());
public void modifyServiceIsSuccessfulForPresentService() {
ServiceCreateInput createInput = ServiceDataUtils.buildServiceCreateInput();
this.serviceDataStoreOperations.createService(createInput);
public void modifyServiceIsSuccessfulForPresentService() {
ServiceCreateInput createInput = ServiceDataUtils.buildServiceCreateInput();
this.serviceDataStoreOperations.createService(createInput);
- OperationResult result =
- this.serviceDataStoreOperations.modifyService(createInput.getServiceName(), State.InService, State.InService);
+ OperationResult result = this.serviceDataStoreOperations.modifyService(createInput.getServiceName(),
+ State.InService, State.InService);
Assert.assertTrue(result.isSuccess());
}
@Test
public void getTempServiceFromEmptyDataStoreShouldBeEmpty() {
Optional<org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.temp.service.list
Assert.assertTrue(result.isSuccess());
}
@Test
public void getTempServiceFromEmptyDataStoreShouldBeEmpty() {
Optional<org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.temp.service.list
- .Services> oService = this.serviceDataStoreOperations.getTempService("service 1");
- Assert.assertFalse(oService.isPresent());
+ .Services> optService = this.serviceDataStoreOperations.getTempService("service 1");
+ Assert.assertFalse(optService.isPresent());
this.serviceDataStoreOperations.createTempService(createInput);
Optional<org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.temp.service.list
this.serviceDataStoreOperations.createTempService(createInput);
Optional<org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.temp.service.list
- .Services> oService = this.serviceDataStoreOperations.getTempService(createInput.getCommonId());
- Assert.assertTrue(oService.isPresent());
- Assert.assertEquals(createInput.getCommonId(), oService.get().getCommonId());
+ .Services> optService = this.serviceDataStoreOperations.getTempService(createInput.getCommonId());
+ Assert.assertTrue(optService.isPresent());
+ Assert.assertEquals(createInput.getCommonId(), optService.get().getCommonId());
public void modifyTempServiceIsSuccessfulForPresentTempService() {
TempServiceCreateInput createInput = ServiceDataUtils.buildTempServiceCreateInput();
this.serviceDataStoreOperations.createTempService(createInput);
public void modifyTempServiceIsSuccessfulForPresentTempService() {
TempServiceCreateInput createInput = ServiceDataUtils.buildTempServiceCreateInput();
this.serviceDataStoreOperations.createTempService(createInput);
- OperationResult result =
- this.serviceDataStoreOperations.modifyTempService(createInput.getCommonId(), State.InService, State.InService);
+ OperationResult result = this.serviceDataStoreOperations.modifyTempService(createInput.getCommonId(),
+ State.InService, State.InService);
.setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
.setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
ResponseParameters responseParameters = new ResponseParametersBuilder()
.setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
.setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
ResponseParameters responseParameters = new ResponseParametersBuilder()
- .setPathDescription(new PathDescriptionBuilder()
- .setAToZDirection(new AToZDirectionBuilder().setAToZWavelengthNumber(1L).setRate(1L).build())
- .setZToADirection(new ZToADirectionBuilder().setZToAWavelengthNumber(1L).setRate(1L).build()).build()).build();
+ .setPathDescription(new PathDescriptionBuilder()
+ .setAToZDirection(new AToZDirectionBuilder().setAToZWavelengthNumber(1L).setRate(1L).build())
+ .setZToADirection(new ZToADirectionBuilder().setZToAWavelengthNumber(1L).setRate(1L).build()).build())
+ .build();
this.serviceDataStoreOperations.createService(createInput);
ServiceInput serviceInput = new ServiceInput(createInput);
ConfigurationResponseCommon configurationResponseCommon = new ConfigurationResponseCommonBuilder()
this.serviceDataStoreOperations.createService(createInput);
ServiceInput serviceInput = new ServiceInput(createInput);
ConfigurationResponseCommon configurationResponseCommon = new ConfigurationResponseCommonBuilder()
- .setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
- .setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
+ .setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
+ .setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
ResponseParameters responseParameters = new ResponseParametersBuilder().build();
PathComputationRequestOutput pathComputationRequestOutput = new PathComputationRequestOutputBuilder()
ResponseParameters responseParameters = new ResponseParametersBuilder().build();
PathComputationRequestOutput pathComputationRequestOutput = new PathComputationRequestOutputBuilder()
this.serviceDataStoreOperations.createService(createInput);
ServiceInput serviceInput = new ServiceInput(createInput);
ConfigurationResponseCommon configurationResponseCommon = new ConfigurationResponseCommonBuilder()
this.serviceDataStoreOperations.createService(createInput);
ServiceInput serviceInput = new ServiceInput(createInput);
ConfigurationResponseCommon configurationResponseCommon = new ConfigurationResponseCommonBuilder()
- .setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
- .setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
+ .setRequestId("request 1").setAckFinalIndicator(ResponseCodes.FINAL_ACK_NO)
+ .setResponseCode(ResponseCodes.RESPONSE_OK).setResponseMessage("PCE calculation in progress").build();
- .setPathDescription(new PathDescriptionBuilder()
- .setAToZDirection(new AToZDirectionBuilder().setAToZWavelengthNumber(1L).setRate(1L).build())
- .setZToADirection(new ZToADirectionBuilder().setZToAWavelengthNumber(1L).setRate(1L).build()).build()).build();
+ .setPathDescription(new PathDescriptionBuilder()
+ .setAToZDirection(new AToZDirectionBuilder().setAToZWavelengthNumber(1L).setRate(1L).build())
+ .setZToADirection(new ZToADirectionBuilder().setZToAWavelengthNumber(1L).setRate(1L).build()).build())
+ .build();
this.serviceDataStoreOperations.createServicePath(serviceInput, pathComputationRequestOutput);
OperationResult result = this.serviceDataStoreOperations.deleteServicePath(serviceInput.getServiceName());
Assert.assertTrue(result.isSuccess());
}
this.serviceDataStoreOperations.createServicePath(serviceInput, pathComputationRequestOutput);
OperationResult result = this.serviceDataStoreOperations.deleteServicePath(serviceInput.getServiceName());
Assert.assertTrue(result.isSuccess());
}