import static org.onap.sdnc.northbound.GenericResourceApiProvider.INVALID_INPUT_ERROR_MESSAGE;
import static org.onap.sdnc.northbound.GenericResourceApiProvider.NO_SERVICE_LOGIC_ACTIVE;
import static org.onap.sdnc.northbound.GenericResourceApiProvider.NULL_OR_EMPTY_ERROR_PARAM;
-import static org.onap.sdnc.northbound.util.MDSALUtil.build;
import static org.onap.sdnc.northbound.util.MDSALUtil.contrailRouteResponseInformation;
import static org.onap.sdnc.northbound.util.MDSALUtil.contrailRouteTopologyOperationInput;
import static org.onap.sdnc.northbound.util.MDSALUtil.contrailRouteTopologyOperationOutput;
import static org.onap.sdnc.northbound.util.MDSALUtil.serviceStatus;
import java.time.Instant;
+
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;
import org.mockito.runners.MockitoJUnitRunner;
import org.onap.sdnc.northbound.util.PropBuilder;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.TransactionChainClosedException;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.TransactionChainClosedException;
+import org.opendaylight.mdsal.binding.api.WriteTransaction;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.ContrailRouteTopologyOperationInput;
import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.ContrailRouteTopologyOperationOutput;
import org.opendaylight.yang.gen.v1.org.onap.sdnc.northbound.generic.resource.rev170824.OperStatusData.LastAction;
@Test
public void should_fail_when_service_instance_id_not_present() throws Exception {
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput());
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput().build();
ContrailRouteTopologyOperationOutput output =
exec(genericResourceApiProvider::contrailRouteTopologyOperation, input, RpcResult::getResult);
@Test
public void should_fail_when_invalid_service_data() throws Exception {
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput()
- .setSdncRequestHeader(build(sdncRequestHeader()
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput()
+ .setSdncRequestHeader(sdncRequestHeader()
.setSvcRequestId("test-svc-request-id")
- .setSvcAction(SvcAction.Assign)
- ))
- .setServiceInformation(build(serviceInformationBuilder()
- .setServiceInstanceId("test-service-instance-id")
- ))
- );
+ .setSvcAction(SvcAction.Assign).build()
+ )
+ .setServiceInformation(serviceInformationBuilder()
+ .setServiceInstanceId("test-service-instance-id").build()
+ ).build();
ContrailRouteTopologyOperationOutput output =
exec(genericResourceApiProvider::contrailRouteTopologyOperation, input, RpcResult::getResult);
svcClient.mockHasGraph(true);
svcClient.mockExecute(new RuntimeException("test exception"));
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput()
- .setSdncRequestHeader(build(sdncRequestHeader()
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput()
+ .setSdncRequestHeader(sdncRequestHeader()
.setSvcRequestId("test-svc-request-id")
- .setSvcAction(SvcAction.Assign)
- ))
- .setServiceInformation(build(serviceInformationBuilder()
- .setServiceInstanceId("test-service-instance-id")
- ))
- );
+ .setSvcAction(SvcAction.Assign).build()
+ )
+ .setServiceInformation(serviceInformationBuilder()
+ .setServiceInstanceId("test-service-instance-id").build()
+ ).build();
persistServiceInDataBroker(input);
svcClient.mockHasGraph(false);
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput()
- .setSdncRequestHeader(build(sdncRequestHeader()
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput()
+ .setSdncRequestHeader(sdncRequestHeader()
.setSvcRequestId("test-svc-request-id")
- .setSvcAction(SvcAction.Assign)
- ))
- .setServiceInformation(build(serviceInformationBuilder()
- .setServiceInstanceId("test-service-instance-id")
- ))
- );
+ .setSvcAction(SvcAction.Assign).build()
+ )
+ .setServiceInformation(serviceInformationBuilder()
+ .setServiceInstanceId("test-service-instance-id").build()
+ ).build();
persistServiceInDataBroker(input);
svcClient.mockExecute(svcResultProp);
svcClient.mockHasGraph(true);
WriteTransaction mockWriteTransaction = mock(WriteTransaction.class);
- when(mockWriteTransaction.submit()).thenThrow(new TransactionChainClosedException("test exception"));
+ when(mockWriteTransaction.commit()).thenThrow(new TransactionChainClosedException("test exception"));
DataBroker spyDataBroker = Mockito.spy(dataBroker);
when(spyDataBroker.newWriteOnlyTransaction()).thenReturn(mockWriteTransaction);
genericResourceApiProvider.setDataBroker(spyDataBroker);
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput()
- .setSdncRequestHeader(build(sdncRequestHeader()
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput()
+ .setSdncRequestHeader(sdncRequestHeader()
.setSvcRequestId("test-svc-request-id")
- .setSvcAction(SvcAction.Assign)
- ))
- .setServiceInformation(build(serviceInformationBuilder()
- .setServiceInstanceId("test-service-instance-id")
- ))
- );
+ .setSvcAction(SvcAction.Assign).build()
+ )
+ .setServiceInformation(serviceInformationBuilder()
+ .setServiceInstanceId("test-service-instance-id").build()
+ ).build();
persistServiceInDataBroker(input);
svcResultProp.set("contrail-route-object-path", "contrailRouteObjectPath: XYZ");
svcClient.mockExecute(svcResultProp);
- ContrailRouteTopologyOperationInput input = build(contrailRouteTopologyOperationInput()
- .setSdncRequestHeader(build(sdncRequestHeader()
+ ContrailRouteTopologyOperationInput input = contrailRouteTopologyOperationInput()
+ .setSdncRequestHeader(sdncRequestHeader()
.setSvcRequestId("test-svc-request-id")
- .setSvcAction(SvcAction.Assign)
- ))
- .setRequestInformation(build(requestInformation()
+ .setSvcAction(SvcAction.Assign).build()
+ )
+ .setRequestInformation(requestInformation()
.setRequestId("test-request-id")
- .setRequestAction(RequestInformation.RequestAction.CreateServiceInstance)
- ))
- .setServiceInformation(build(serviceInformationBuilder()
- .setServiceInstanceId("test-service-instance-id")
- ))
- );
+ .setRequestAction(RequestInformation.RequestAction.CreateServiceInstance).build()
+ )
+ .setServiceInformation(serviceInformationBuilder()
+ .setServiceInstanceId("test-service-instance-id").build()
+ ).build();
Service service = persistServiceInDataBroker(input);
private Service persistServiceInDataBroker(ContrailRouteTopologyOperationInput input) throws Exception {
- Service service = build(service()
+ Service service = service()
.setServiceInstanceId(input.getServiceInformation().getServiceInstanceId())
- .setServiceData(build(serviceData()
- .setServiceLevelOperStatus(build(serviceLevelOperStatus()
+ .setServiceData(serviceData()
+ .setServiceLevelOperStatus(serviceLevelOperStatus()
.setOrderStatus(OrderStatus.Created)
.setModifyTimestamp(Instant.now().toString())
.setLastSvcRequestId(input.getSdncRequestHeader().getSvcRequestId())
.setLastRpcAction(LastRpcAction.Activate)
.setLastOrderStatus(LastOrderStatus.PendingAssignment)
.setLastAction(LastAction.ActivateNetworkInstance)
- .setCreateTimestamp(Instant.now().toString())
- ))
- ))
- );
+ .setCreateTimestamp(Instant.now().toString()).build()
+ ).build()
+ ).build();
db.write(true, service, LogicalDatastoreType.CONFIGURATION);
return service;
}
private ContrailRouteTopologyOperationOutput createExpectedOutput(PropBuilder propBuilder,
ContrailRouteTopologyOperationInput input) {
- return build(contrailRouteTopologyOperationOutput()
- .setContrailRouteResponseInformation(build(contrailRouteResponseInformation()
- .setObjectPath(propBuilder.get("contrail-route-object-path"))))
+ return contrailRouteTopologyOperationOutput()
+ .setContrailRouteResponseInformation(contrailRouteResponseInformation()
+ .setObjectPath(propBuilder.get("contrail-route-object-path")).build()
+ )
.setSvcRequestId(input.getSdncRequestHeader().getSvcRequestId())
.setResponseCode(propBuilder.get(svcClient.errorCode))
.setAckFinalIndicator(propBuilder.get(svcClient.ackFinal))
.setResponseMessage(propBuilder.get(svcClient.errorMessage))
- .setServiceResponseInformation(build(serviceResponseInformation()
+ .setServiceResponseInformation(serviceResponseInformation()
.setInstanceId(input.getServiceInformation().getServiceInstanceId())
- .setObjectPath(propBuilder.get(svcClient.serviceObjectPath))
- ))
- );
+ .setObjectPath(propBuilder.get(svcClient.serviceObjectPath)).build()
+ ).build();
}
private Service createExpectedService(
ServiceInformation expectedServiceInformation = expectedInput.getServiceInformation();
- return build(service()
+ return service()
.setServiceInstanceId(expectedServiceInformation.getServiceInstanceId())
- .setServiceData(build(serviceData()))
+ .setServiceData(serviceData().build())
.setServiceData(expectedServiceData)
- .setServiceStatus(build(serviceStatus()))
- );
+ .setServiceStatus(serviceStatus().build()).build();
}
}