servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/ModelMappingUtils.java

   1 /*
   2  * Copyright © 2017 Orange, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.transportpce.servicehandler;
   9
  10 import com.google.common.util.concurrent.ListenableFuture;
  11 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.PathComputationRequestOutput;
  12 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceAEnd;
  13 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceAEndBuilder;
  14 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceZEnd;
  15 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceZEndBuilder;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.service.path.rpc.result.PathDescription;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceDeleteInputBuilder;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestInput;
  19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestInputBuilder;
  20 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.node.types.rev181130.NodeIdType;
  21 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.ServiceEndpoint;
  22 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.configuration.response.common.ConfigurationResponseCommonBuilder;
  23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.response.parameters.ResponseParametersBuilder;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.LifecycleState;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU0;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU1;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2e;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU3;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU4;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUCn;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexCbr;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexFlexe;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexGfp;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexImp;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU0;
  39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU1;
  40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU2;
  41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU2e;
  42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU3;
  43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU4;
  44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTUCn;
  45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTUflex;
  46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OduRateIdentity;
  47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OtuRateIdentity;
  48 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateInput;
  49 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateOutput;
  50 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateOutputBuilder;
  51 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteInput;
  52 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteOutput;
  53 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteOutputBuilder;
  54 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckInput;
  55 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckOutput;
  56 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckOutputBuilder;
  57 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureInput;
  58 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureOutput;
  59 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureOutputBuilder;
  60 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteInput;
  61 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteOutput;
  62 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteOutputBuilder;
  63 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationInput;
  64 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationOutput;
  65 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationOutputBuilder;
  66 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateInput;
  67 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateOutput;
  68 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateOutputBuilder;
  69 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteInput;
  70 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteOutput;
  71 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteOutputBuilder;
  72 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.Services;
  73 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.ServicesBuilder;
  74 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.ServicesKey;
  75 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.RxDirection;
  76 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.RxDirectionBuilder;
  77 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.TxDirection;
  78 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.TxDirectionBuilder;
  79 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.handler.header.ServiceHandlerHeaderBuilder;
  80 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.path.PathDescriptionBuilder;
  81 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePaths;
  82 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsBuilder;
  83 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsKey;
  84 import org.opendaylight.yangtools.yang.common.RpcResult;
  85 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  86 import org.slf4j.Logger;
  87 import org.slf4j.LoggerFactory;
  88
  89 public final class ModelMappingUtils {
  90     private static final Logger LOG = LoggerFactory.getLogger(ModelMappingUtils.class);
  91
  92     private ModelMappingUtils() {
  93     }
  94
  95     public static ServiceImplementationRequestInput createServiceImplementationRequest(
  96             ServiceInput input,
  97             PathDescription pathDescription) {
  98         return new ServiceImplementationRequestInputBuilder()
  99             .setConnectionType(input.getConnectionType())
 100             .setServiceName(
 101                 input.isServiceReconfigure()
 102                     ? input.getNewServiceName()
 103                     : input.getServiceName())
 104             .setServiceAEnd(
 105                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 106                         .service.implementation.request.input.ServiceAEndBuilder()
 107                     .setServiceFormat(input.getServiceAEnd().getServiceFormat())
 108                     .setServiceRate(input.getServiceAEnd().getServiceRate())
 109                     .setOtuServiceRate(getOtuServiceRate(input.getServiceAEnd().getOtuServiceRate()))
 110                     .setOduServiceRate(getOduServiceRate(input.getServiceAEnd().getOduServiceRate()))
 111                     .setClli(input.getServiceAEnd().getClli())
 112                     .setNodeId(new NodeIdType(input.getServiceAEnd().getNodeId().getValue()).getValue())
 113                     .setTxDirection(
 114                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 115                                 .service.endpoint.sp.TxDirectionBuilder()
 116                             .setPort(
 117                                 input.getServiceAEnd().getTxDirection().values().stream().findFirst().get().getPort())
 118                             .build())
 119                     .setRxDirection(
 120                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 121                                 .service.endpoint.sp.RxDirectionBuilder()
 122                             .setPort(
 123                                 input.getServiceAEnd().getRxDirection().values().stream().findFirst().get().getPort())
 124                             .build())
 125                     .build())
 126             .setServiceZEnd(
 127                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 128                         .service.implementation.request.input.ServiceZEndBuilder()
 129                     .setServiceFormat(input.getServiceZEnd().getServiceFormat())
 130                     .setServiceRate(input.getServiceZEnd().getServiceRate())
 131                     .setOtuServiceRate(getOtuServiceRate(input.getServiceZEnd().getOtuServiceRate()))
 132                     .setOduServiceRate(getOduServiceRate(input.getServiceZEnd().getOduServiceRate()))
 133                     .setClli(input.getServiceZEnd().getClli())
 134                     .setNodeId(new NodeIdType(input.getServiceZEnd().getNodeId().getValue()).getValue())
 135                     .setTxDirection(
 136                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 137                                 .service.endpoint.sp.TxDirectionBuilder()
 138                             .setPort(
 139                                 input.getServiceZEnd().getTxDirection().values().stream().findFirst().get().getPort())
 140                             .build())
 141                     .setRxDirection(
 142                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 143                                 .service.endpoint.sp.RxDirectionBuilder()
 144                             .setPort(
 145                                 input.getServiceZEnd().getRxDirection().values().stream().findFirst().get().getPort())
 146                             .build())
 147                     .build())
 148             .setConnectionType(input.getConnectionType())
 149             .setServiceHandlerHeader(
 150                 new ServiceHandlerHeaderBuilder().setRequestId(input.getSdncRequestHeader().getRequestId()).build())
 151             .setPathDescription(
 152                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 153                         .service.implementation.request.input.PathDescriptionBuilder()
 154                     .setAToZDirection(pathDescription.getAToZDirection())
 155                     .setZToADirection(pathDescription.getZToADirection())
 156                     .build())
 157             .build();
 158     }
 159
 160     private static Class<? extends OduRateIdentity> getOduServiceRate(
 161             Class<? extends org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OduRateIdentity>
 162                 oduServiceRate) {
 163         if (oduServiceRate == null) {
 164             return null;
 165         }
 166         String oduRate = oduServiceRate.getSimpleName();
 167         LOG.info("ODU rate = {}", oduRate);
 168         //TODO a Map would probably be more indicated here
 169         switch (oduRate) {
 170             case "ODU0":
 171                 return ODU0.class;
 172             case "ODU1":
 173                 return ODU1.class;
 174             case "ODU2":
 175                 return ODU2.class;
 176             case "ODU2e":
 177                 return ODU2e.class;
 178             case "ODU3":
 179                 return ODU3.class;
 180             case "ODU4":
 181                 return ODU4.class;
 182             case "ODUCn":
 183                 return ODUCn.class;
 184             case "ODUflexCbr":
 185                 return ODUflexCbr.class;
 186             case "ODUflexFlexe":
 187                 return ODUflexFlexe.class;
 188             case "ODUflexGfp":
 189                 return ODUflexGfp.class;
 190             case "ODUflexImp":
 191                 return ODUflexImp.class;
 192             default:
 193                 LOG.error("OTU rate {} not recognized", oduRate);
 194         }
 195         return null;
 196     }
 197
 198     private static Class<? extends OtuRateIdentity> getOtuServiceRate(
 199             Class<? extends org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OtuRateIdentity>
 200                 otuServiceRate) {
 201         if (otuServiceRate == null) {
 202             return null;
 203         }
 204         String otuRate = otuServiceRate.getSimpleName();
 205         LOG.info("OTU rate = {}", otuRate);
 206         //TODO a Map would probably be more indicated here
 207         switch (otuRate) {
 208             case "OTU0":
 209                 return OTU0.class;
 210             case "OTU1":
 211                 return OTU1.class;
 212             case "OTU2":
 213                 return OTU2.class;
 214             case "OTU2e":
 215                 return OTU2e.class;
 216             case "OTU3":
 217                 return OTU3.class;
 218             case "OTU4":
 219                 return OTU4.class;
 220             case "OTUCn":
 221                 return OTUCn.class;
 222             case "OTUflex":
 223                 return OTUflex.class;
 224             default:
 225                 LOG.error("OTU rate {} not recognized", otuRate);
 226         }
 227         return null;
 228     }
 229
 230     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 231             .ServiceDeleteInput createServiceDeleteInput(ServiceInput serviceInput) {
 232         return new ServiceDeleteInputBuilder()
 233             .setServiceName(serviceInput.getServiceName())
 234             .setServiceHandlerHeader(
 235                 new ServiceHandlerHeaderBuilder()
 236                     .setRequestId(serviceInput.getSdncRequestHeader().getRequestId())
 237                     .build())
 238             .build();
 239     }
 240
 241     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 242             .ServiceDeleteInput createServiceDeleteInput(
 243                 ServiceRerouteInput serviceRerouteinput,
 244                 Services services) {
 245         return new ServiceDeleteInputBuilder()
 246             .setServiceName(serviceRerouteinput.getServiceName())
 247             .setServiceHandlerHeader(
 248                 new ServiceHandlerHeaderBuilder()
 249                     .setRequestId(services.getSdncRequestHeader().getRequestId())
 250                     .build())
 251             .build();
 252     }
 253
 254     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 255             .ServiceDeleteInput createServiceDeleteInput(
 256                 ServiceRestorationInput serviceRestorationInput,
 257                 Services services) {
 258         return new ServiceDeleteInputBuilder()
 259             .setServiceName(serviceRestorationInput.getServiceName())
 260             .setServiceHandlerHeader(
 261                 new ServiceHandlerHeaderBuilder()
 262                     .setRequestId(services.getSdncRequestHeader().getRequestId())
 263                     .build())
 264             .build();
 265     }
 266
 267     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 268             .ServiceDeleteInput createServiceDeleteInput(ServiceReconfigureInput serviceReconfigureInput) {
 269         String serviceName = serviceReconfigureInput.getServiceName();
 270         return new ServiceDeleteInputBuilder()
 271             .setServiceName(serviceName)
 272             .setServiceHandlerHeader(
 273                 new ServiceHandlerHeaderBuilder().setRequestId(serviceName + "-reconfigure").build())
 274             .build();
 275     }
 276
 277     public static ServiceAEnd createServiceAEnd(ServiceEndpoint serviceAEnd) {
 278         return new ServiceAEndBuilder()
 279             .setClli(serviceAEnd.getClli())
 280             .setNodeId(serviceAEnd.getNodeId().getValue())
 281             .setRxDirection(createRxDirection(serviceAEnd.getRxDirection().values().stream().findFirst().get()))
 282             .setServiceFormat(serviceAEnd.getServiceFormat())
 283             .setServiceRate(serviceAEnd.getServiceRate())
 284             .setTxDirection(createTxDirection(serviceAEnd.getTxDirection().values().stream().findFirst().get()))
 285             .build();
 286     }
 287
 288     public static ServiceZEnd createServiceZEnd(ServiceEndpoint serviceZEnd) {
 289         return new ServiceZEndBuilder()
 290             .setClli(serviceZEnd.getClli())
 291             .setNodeId(serviceZEnd.getNodeId().getValue())
 292             .setRxDirection(createRxDirection(serviceZEnd.getRxDirection().values().stream().findFirst().get()))
 293             .setServiceFormat(serviceZEnd.getServiceFormat())
 294             .setServiceRate(serviceZEnd.getServiceRate())
 295             .setTxDirection(createTxDirection(serviceZEnd.getTxDirection().values().stream().findFirst().get()))
 296             .build();
 297     }
 298
 299     public static RxDirection createRxDirection(
 300             org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 301                 .service.endpoint.RxDirection rxDirection) {
 302         return new RxDirectionBuilder().setPort(rxDirection.getPort()).build();
 303     }
 304
 305     public static TxDirection createTxDirection(
 306             org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 307                 .service.endpoint.TxDirection txDirection) {
 308         return new TxDirectionBuilder().setPort(txDirection.getPort()).build();
 309     }
 310
 311     public static ListenableFuture<RpcResult<ServiceDeleteOutput>> createDeleteServiceReply(
 312             ServiceDeleteInput input, String finalAck, String message, String responseCode) {
 313         return RpcResultBuilder
 314             .success(
 315                 new ServiceDeleteOutputBuilder()
 316                     .setConfigurationResponseCommon(
 317                         new ConfigurationResponseCommonBuilder()
 318                             .setAckFinalIndicator(finalAck)
 319                             .setResponseMessage(message)
 320                             .setResponseCode(responseCode)
 321                             .setRequestId(
 322                                 input.getSdncRequestHeader() == null
 323                                     ? null
 324                                     : input.getSdncRequestHeader().getRequestId())
 325                             .build())
 326                     .build())
 327             .buildFuture();
 328     }
 329
 330     public static ListenableFuture<RpcResult<TempServiceDeleteOutput>> createDeleteServiceReply(
 331             TempServiceDeleteInput input, String finalAck, String message, String responseCode) {
 332         return RpcResultBuilder
 333             .success(
 334                 new TempServiceDeleteOutputBuilder()
 335                     .setConfigurationResponseCommon(
 336                         new ConfigurationResponseCommonBuilder()
 337                             .setAckFinalIndicator(finalAck)
 338                             .setResponseMessage(message)
 339                             .setResponseCode(responseCode)
 340                             .setRequestId(null)
 341                             .build())
 342                     .build())
 343             .buildFuture();
 344     }
 345
 346     public static ListenableFuture<RpcResult<ServiceCreateOutput>> createCreateServiceReply(
 347             ServiceCreateInput input, String finalAck, String message, String responseCode) {
 348         return RpcResultBuilder
 349             .success(
 350                 new ServiceCreateOutputBuilder()
 351                     .setConfigurationResponseCommon(
 352                         new ConfigurationResponseCommonBuilder()
 353                             .setAckFinalIndicator(finalAck)
 354                             .setResponseMessage(message)
 355                             .setResponseCode(responseCode)
 356                             .setRequestId(
 357                                 input.getSdncRequestHeader() == null
 358                                     ? null
 359                                     : input.getSdncRequestHeader().getRequestId())
 360                             .build())
 361                     .setResponseParameters(new ResponseParametersBuilder().build())
 362                     .build())
 363             .buildFuture();
 364     }
 365
 366     public static ListenableFuture<RpcResult<TempServiceCreateOutput>> createCreateServiceReply(
 367             TempServiceCreateInput input, String finalAck, String message, String responseCode) {
 368         return RpcResultBuilder
 369             .success(
 370                 new TempServiceCreateOutputBuilder()
 371                     .setConfigurationResponseCommon(
 372                         new ConfigurationResponseCommonBuilder()
 373                             .setAckFinalIndicator(finalAck)
 374                              .setResponseMessage(message)
 375                             .setResponseCode(responseCode)
 376                             .setRequestId(
 377                                 input.getSdncRequestHeader() == null
 378                                     ? null
 379                                     : input.getSdncRequestHeader().getRequestId())
 380                             .build())
 381                     .setResponseParameters(new ResponseParametersBuilder().build())
 382                     .build())
 383             .buildFuture();
 384     }
 385
 386     public static ListenableFuture<RpcResult<ServiceFeasibilityCheckOutput>> createCreateServiceReply(
 387             ServiceFeasibilityCheckInput input, String finalAck, String message, String responseCode) {
 388         return RpcResultBuilder
 389             .success(
 390                 new ServiceFeasibilityCheckOutputBuilder()
 391                     .setConfigurationResponseCommon(
 392                         new ConfigurationResponseCommonBuilder()
 393                             .setAckFinalIndicator(finalAck)
 394                             .setResponseMessage(message)
 395                             .setResponseCode(responseCode)
 396                             .setRequestId(
 397                                 input.getSdncRequestHeader() == null
 398                                     ? null
 399                                     : input.getSdncRequestHeader().getRequestId())
 400                             .build())
 401                     .setResponseParameters(new ResponseParametersBuilder().build())
 402                     .build())
 403             .buildFuture();
 404     }
 405
 406     public static ListenableFuture<RpcResult<ServiceReconfigureOutput>> createCreateServiceReply(
 407             ServiceReconfigureInput input, String message) {
 408         return RpcResultBuilder
 409             .success(
 410                 new ServiceReconfigureOutputBuilder()
 411                     .setConfigurationResponseCommon(
 412                         new ConfigurationResponseCommonBuilder()
 413                             .setResponseMessage(message)
 414                             .build())
 415                     .build())
 416             .buildFuture();
 417     }
 418
 419     public static ListenableFuture<RpcResult<ServiceRerouteOutput>> createRerouteServiceReply(
 420             ServiceRerouteInput input, String finalAckYes, String message) {
 421         return RpcResultBuilder
 422             .success(
 423                 new ServiceRerouteOutputBuilder()
 424                     .setConfigurationResponseCommon(
 425                         new ConfigurationResponseCommonBuilder()
 426                             .setResponseMessage(message)
 427                             .build())
 428                     .setHardConstraints(null)
 429                     .setSoftConstraints(null)
 430                     .build())
 431             .buildFuture();
 432     }
 433
 434     public static ListenableFuture<RpcResult<ServiceRestorationOutput>> createRestoreServiceReply(String message) {
 435         return RpcResultBuilder
 436             .success(
 437                 new ServiceRestorationOutputBuilder()
 438                     .setConfigurationResponseCommon(
 439                         new ConfigurationResponseCommonBuilder()
 440                             .setResponseMessage(message)
 441                             .build())
 442                     .build())
 443             .buildFuture();
 444     }
 445
 446     public static Services mappingServices(
 447             ServiceCreateInput serviceCreateInput,
 448             ServiceReconfigureInput serviceReconfigureInput) {
 449         if (serviceCreateInput != null) {
 450             return new ServicesBuilder()
 451                 .setServiceName(serviceCreateInput.getServiceName())
 452                 .setAdministrativeState(AdminStates.OutOfService)
 453                 .setOperationalState(State.OutOfService)
 454                 .setCommonId(serviceCreateInput.getCommonId())
 455                 .setConnectionType(serviceCreateInput.getConnectionType())
 456                 .setCustomer(serviceCreateInput.getCustomer())
 457                 .setCustomerContact(serviceCreateInput.getCustomerContact())
 458                 .setHardConstraints(serviceCreateInput.getHardConstraints())
 459                 .setSoftConstraints(serviceCreateInput.getSoftConstraints())
 460                 .setSdncRequestHeader(serviceCreateInput.getSdncRequestHeader())
 461                 .setLifecycleState(LifecycleState.Planned)
 462                 .setServiceAEnd(
 463                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 464                             .service.ServiceAEndBuilder(serviceCreateInput.getServiceAEnd())
 465                         .build())
 466                 .setServiceZEnd(
 467                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 468                             .service.ServiceZEndBuilder(serviceCreateInput.getServiceZEnd())
 469                         .build())
 470                 .build();
 471         }
 472         if (serviceReconfigureInput != null) {
 473             return new ServicesBuilder()
 474                 .setServiceName(serviceReconfigureInput.getServiceName())
 475                 .setAdministrativeState(AdminStates.OutOfService)
 476                 .setOperationalState(State.OutOfService)
 477                 .setCommonId(serviceReconfigureInput.getCommonId())
 478                 .setConnectionType(serviceReconfigureInput.getConnectionType())
 479                 .setCustomer(serviceReconfigureInput.getCustomer())
 480                 .setCustomerContact(serviceReconfigureInput.getCustomerContact())
 481                 .setHardConstraints(serviceReconfigureInput.getHardConstraints())
 482                 .setSoftConstraints(serviceReconfigureInput.getSoftConstraints())
 483                 .setLifecycleState(LifecycleState.Planned)
 484                 .setServiceAEnd(
 485                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 486                             .service.ServiceAEndBuilder(serviceReconfigureInput.getServiceAEnd())
 487                         .build())
 488                 .setServiceZEnd(
 489                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 490                             .service.ServiceZEndBuilder(serviceReconfigureInput.getServiceZEnd())
 491                         .build())
 492                 .build();
 493         }
 494         //FIXME: Because of Silicon, we cannot have empty key.
 495         //it's this case possible ? There is a Junit test covering null
 496         //temporary workaround as now there is a null key check done by yangtools.
 497         //Functional review is needed
 498         LOG.warn("ServiceCreateInput and ServiceReconfigureInput are null");
 499         return new ServicesBuilder().withKey(new ServicesKey("unknown")).build();
 500     }
 501
 502     public static org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 503             .temp.service.list.Services mappingServices(TempServiceCreateInput tempServiceCreateInput) {
 504         return new org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 505                 .temp.service.list.ServicesBuilder()
 506             .setServiceName(tempServiceCreateInput.getCommonId())
 507             .setAdministrativeState(AdminStates.OutOfService)
 508             .setOperationalState(State.OutOfService)
 509             .setCommonId(tempServiceCreateInput.getCommonId())
 510             .setConnectionType(tempServiceCreateInput.getConnectionType())
 511             .setCustomer(tempServiceCreateInput.getCustomer())
 512             .setCustomerContact(tempServiceCreateInput.getCustomerContact())
 513             .setHardConstraints(tempServiceCreateInput.getHardConstraints())
 514             .setSoftConstraints(tempServiceCreateInput.getSoftConstraints())
 515             .setSdncRequestHeader(tempServiceCreateInput.getSdncRequestHeader())
 516             .setLifecycleState(LifecycleState.Planned)
 517             .setServiceAEnd(
 518                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 519                     .service.ServiceAEndBuilder(tempServiceCreateInput.getServiceAEnd()).build())
 520             .setServiceZEnd(
 521                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 522                     .service.ServiceZEndBuilder(tempServiceCreateInput.getServiceZEnd()).build())
 523             .build();
 524     }
 525
 526     public static ServicePaths mappingServicePaths(ServiceInput serviceInput, PathComputationRequestOutput output) {
 527         if (serviceInput == null) {
 528             //FIXME: Because of Silicon, we cannot have empty key.
 529             //it's this case possible ? There is a Junit test covering null
 530             //temporary workaround as now there is a null key check done by yangtools.
 531             //Functional review is needed
 532             LOG.warn("ServiceInput is null");
 533             return new ServicePathsBuilder().withKey(new ServicePathsKey("unknown")).build();
 534         }
 535
 536         ServicePathsBuilder servicePathBuilder =
 537             new ServicePathsBuilder()
 538                 .setServiceAEnd(
 539                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 540                             .service.path.ServiceAEndBuilder()
 541                         .setServiceFormat(serviceInput.getServiceAEnd().getServiceFormat())
 542                         .setServiceRate(serviceInput.getServiceAEnd().getServiceRate())
 543                         .setClli(serviceInput.getServiceAEnd().getClli())
 544                         .setNodeId(new NodeIdType(serviceInput.getServiceAEnd().getNodeId().getValue()).getValue())
 545                         .setTxDirection(
 546                             new org.opendaylight.yang.gen.v1
 547                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 548                                         .service.endpoint.sp.TxDirectionBuilder()
 549                                 .setPort(
 550                                     serviceInput.getServiceAEnd().getTxDirection()
 551                                         .values().stream().findFirst().get().getPort())
 552                                 .build())
 553                         .setRxDirection(
 554                             new org.opendaylight.yang.gen.v1
 555                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 556                                         .service.endpoint.sp.RxDirectionBuilder()
 557                                 .setPort(
 558                                     serviceInput.getServiceAEnd().getRxDirection()
 559                                         .values().stream().findFirst().get().getPort())
 560                                 .build())
 561                         .build())
 562                 .setServiceZEnd(
 563                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 564                             .service.path.ServiceZEndBuilder()
 565                         .setServiceFormat(serviceInput.getServiceZEnd().getServiceFormat())
 566                         .setServiceRate(serviceInput.getServiceZEnd().getServiceRate())
 567                         .setClli(serviceInput.getServiceZEnd().getClli())
 568                         .setNodeId(new NodeIdType(serviceInput.getServiceZEnd().getNodeId().getValue()).getValue())
 569                         .setTxDirection(
 570                             new org.opendaylight.yang.gen.v1
 571                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 572                                         .service.endpoint.sp.TxDirectionBuilder()
 573                                 .setPort(
 574                                     serviceInput.getServiceZEnd().getTxDirection()
 575                                         .values().stream().findFirst().get().getPort())
 576                                 .build())
 577                         .setRxDirection(
 578                             new org.opendaylight.yang.gen.v1
 579                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 580                                         .service.endpoint.sp.RxDirectionBuilder()
 581                                 .setPort(
 582                                     serviceInput.getServiceZEnd().getRxDirection()
 583                                         .values().stream().findFirst().get().getPort())
 584                                 .build())
 585                         .build())
 586                 .setServicePathName(serviceInput.getServiceName())
 587                 .setServiceHandlerHeader(
 588                     new ServiceHandlerHeaderBuilder()
 589                         .setRequestId(serviceInput.getSdncRequestHeader()
 590                         .getRequestId())
 591                         .build());
 592         if (serviceInput.getHardConstraints() != null) {
 593             servicePathBuilder.setHardConstraints(serviceInput.getHardConstraints());
 594         }
 595         if (serviceInput.getSoftConstraints() != null) {
 596             servicePathBuilder.setSoftConstraints(serviceInput.getSoftConstraints());
 597         }
 598
 599         if (output.getResponseParameters().getPathDescription() != null) {
 600             servicePathBuilder.setPathDescription(
 601                 new PathDescriptionBuilder(output.getResponseParameters().getPathDescription()).build());
 602         }
 603         return servicePathBuilder.build();
 604     }
 605
 606
 607     @edu.umd.cs.findbugs.annotations.SuppressFBWarnings(
 608         value = "PZLA_PREFER_ZERO_LENGTH_ARRAYS",
 609         justification = "not relevant to return and zero length array as we need real pos")
 610     public static int[] findTheLongestSubstring(String s1, String s2) {
 611         if ((s1 == null) || (s2 == null)) {
 612             return null;
 613         }
 614         int[][] dp = new int[s1.length() + 1][s2.length() + 1];
 615         int maxLen = 0;
 616         int endPos = 0;
 617         for (int i = 1; i < dp.length; i++) {
 618             for (int j = 1; j < dp[0].length; j++) {
 619                 char ch1 = s1.charAt(i - 1);
 620                 char ch2 = s2.charAt(j - 1);
 621                 if (ch1 == ch2) {
 622                     dp[i][j] = dp[i - 1][j - 1] + 1;
 623                     if (dp[i][j] >= maxLen) {
 624                         maxLen = dp[i][j];
 625                         endPos = i;
 626                     }
 627                 }
 628             }
 629         }
 630         return new int[] { endPos - maxLen, endPos };
 631     }
 632 }