+ public static ServiceZEnd createServiceZEnd(ServiceEndpoint serviceZEnd) {
+ return new ServiceZEndBuilder()
+ .setClli(serviceZEnd.getClli())
+ .setNodeId(serviceZEnd.getNodeId().getValue())
+ .setRxDirection(createRxDirection(serviceZEnd.getRxDirection().values().stream().findFirst().get()))
+ .setServiceFormat(serviceZEnd.getServiceFormat())
+ .setServiceRate(serviceZEnd.getServiceRate())
+ .setTxDirection(createTxDirection(serviceZEnd.getTxDirection().values().stream().findFirst().get()))
+ .build();
+ }
+
+ public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
+ .path.computation.reroute.request.input.ServiceZEnd createServiceZEndReroute(ServiceEndpoint serviceZEnd) {
+ return new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
+ .path.computation.reroute.request.input.ServiceZEndBuilder()
+ .setClli(serviceZEnd.getClli())
+ .setNodeId(serviceZEnd.getNodeId().getValue())
+ .setRxDirection(createRxDirection(serviceZEnd.getRxDirection().values().stream().findFirst().get()))
+ .setServiceFormat(serviceZEnd.getServiceFormat())
+ .setServiceRate(serviceZEnd.getServiceRate())
+ .setTxDirection(createTxDirection(serviceZEnd.getTxDirection().values().stream().findFirst().get()))
+ .build();
+ }
+
+ public static RxDirection createRxDirection(
+ org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
+ .service.endpoint.RxDirection rxDirection) {
+ return new RxDirectionBuilder().setPort(rxDirection.getPort()).build();
+ }
+
+ public static TxDirection createTxDirection(
+ org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
+ .service.endpoint.TxDirection txDirection) {
+ return new TxDirectionBuilder().setPort(txDirection.getPort()).build();
+ }
+
+ public static ListenableFuture<RpcResult<ServiceDeleteOutput>> createDeleteServiceReply(
+ ServiceDeleteInput input, String finalAck, String message, String responseCode) {
+ return RpcResultBuilder
+ .success(
+ new ServiceDeleteOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setAckFinalIndicator(finalAck)
+ .setResponseMessage(message)
+ .setResponseCode(responseCode)
+ .setRequestId(
+ input.getSdncRequestHeader() == null
+ ? null
+ : input.getSdncRequestHeader().getRequestId())
+ .build())
+ .build())
+ .buildFuture();
+ }
+
+ public static ListenableFuture<RpcResult<TempServiceDeleteOutput>> createDeleteServiceReply(
+ TempServiceDeleteInput input, String finalAck, String message, String responseCode) {
+ return RpcResultBuilder
+ .success(
+ new TempServiceDeleteOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setAckFinalIndicator(finalAck)
+ .setResponseMessage(message)
+ .setResponseCode(responseCode)
+ .setRequestId(null)
+ .build())
+ .build())
+ .buildFuture();
+ }
+
+ public static ListenableFuture<RpcResult<ServiceCreateOutput>> createCreateServiceReply(
+ ServiceCreateInput input, String finalAck, String message, String responseCode) {
+ return RpcResultBuilder
+ .success(
+ new ServiceCreateOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setAckFinalIndicator(finalAck)
+ .setResponseMessage(message)
+ .setResponseCode(responseCode)
+ .setRequestId(
+ input.getSdncRequestHeader() == null
+ ? null
+ : input.getSdncRequestHeader().getRequestId())
+ .build())
+ .setResponseParameters(new ResponseParametersBuilder().build())
+ .build())
+ .buildFuture();
+ }
+
+ public static ListenableFuture<RpcResult<TempServiceCreateOutput>> createCreateServiceReply(
+ TempServiceCreateInput input, String finalAck, String message, String responseCode) {
+ return RpcResultBuilder
+ .success(
+ new TempServiceCreateOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setAckFinalIndicator(finalAck)
+ .setResponseMessage(message)
+ .setResponseCode(responseCode)
+ .setRequestId(
+ input.getSdncRequestHeader() == null
+ ? null
+ : input.getSdncRequestHeader().getRequestId())
+ .build())
+ .setResponseParameters(new ResponseParametersBuilder().build())
+ .build())
+ .buildFuture();
+ }
+
+ public static ListenableFuture<RpcResult<ServiceFeasibilityCheckOutput>> createCreateServiceReply(
+ ServiceFeasibilityCheckInput input, String finalAck, String message, String responseCode) {
+ return RpcResultBuilder
+ .success(
+ new ServiceFeasibilityCheckOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setAckFinalIndicator(finalAck)
+ .setResponseMessage(message)
+ .setResponseCode(responseCode)
+ .setRequestId(
+ input.getSdncRequestHeader() == null
+ ? null
+ : input.getSdncRequestHeader().getRequestId())
+ .build())
+ .setResponseParameters(new ResponseParametersBuilder().build())
+ .build())
+ .buildFuture();
+ }
+
+ public static ListenableFuture<RpcResult<ServiceReconfigureOutput>> createCreateServiceReply(
+ ServiceReconfigureInput input, String message) {
+ return RpcResultBuilder
+ .success(
+ new ServiceReconfigureOutputBuilder()
+ .setConfigurationResponseCommon(
+ new ConfigurationResponseCommonBuilder()
+ .setResponseMessage(message)
+ .build())
+ .build())
+ .buildFuture();