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.collect.ImmutableMap;
  11 import com.google.common.util.concurrent.ListenableFuture;
  12 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.PathComputationRequestOutput;
  13 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.path.computation.request.input.ServiceAEnd;
  14 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.path.computation.request.input.ServiceAEndBuilder;
  15 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.path.computation.request.input.ServiceZEnd;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.path.computation.request.input.ServiceZEndBuilder;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.service.path.rpc.result.PathDescription;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceDeleteInputBuilder;
  19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestInput;
  20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.ServiceImplementationRequestInputBuilder;
  21 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.node.types.rev210528.NodeIdType;
  22 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.ServiceEndpoint;
  23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.configuration.response.common.ConfigurationResponseCommonBuilder;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210.response.parameters.ResponseParametersBuilder;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.LifecycleState;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU0;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU1;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2e;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU3;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU4;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUCn;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexCbr;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexFlexe;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexGfp;
  38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODUflexImp;
  39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU0;
  40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU1;
  41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU2;
  42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU2e;
  43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU3;
  44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTU4;
  45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTUCn;
  46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OTUflex;
  47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OduRateIdentity;
  48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OtuRateIdentity;
  49 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateInput;
  50 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateOutput;
  51 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceCreateOutputBuilder;
  52 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteInput;
  53 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteOutput;
  54 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceDeleteOutputBuilder;
  55 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckInput;
  56 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckOutput;
  57 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceFeasibilityCheckOutputBuilder;
  58 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureInput;
  59 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureOutput;
  60 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceReconfigureOutputBuilder;
  61 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteInput;
  62 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteOutput;
  63 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRerouteOutputBuilder;
  64 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationInput;
  65 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationOutput;
  66 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.ServiceRestorationOutputBuilder;
  67 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateInput;
  68 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateOutput;
  69 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceCreateOutputBuilder;
  70 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteInput;
  71 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteOutput;
  72 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.TempServiceDeleteOutputBuilder;
  73 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.Services;
  74 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.ServicesBuilder;
  75 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.ServicesKey;
  76 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.RxDirection;
  77 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.RxDirectionBuilder;
  78 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.TxDirection;
  79 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.endpoint.sp.TxDirectionBuilder;
  80 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.handler.header.ServiceHandlerHeaderBuilder;
  81 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.path.PathDescriptionBuilder;
  82 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePaths;
  83 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsBuilder;
  84 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsKey;
  85 import org.opendaylight.yangtools.yang.common.RpcResult;
  86 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  87 import org.slf4j.Logger;
  88 import org.slf4j.LoggerFactory;
  89
  90 public final class ModelMappingUtils {
  91     private static final Logger LOG = LoggerFactory.getLogger(ModelMappingUtils.class);
  92
  93     private static final ImmutableMap<String, OduRateIdentity> ODU_RATE_MAP =
  94         ImmutableMap.<String, OduRateIdentity>builder()
  95             .put("ODU0", ODU0.VALUE)
  96             .put("ODU1", ODU1.VALUE)
  97             .put("ODU2", ODU2.VALUE)
  98             .put("ODU2e", ODU2e.VALUE)
  99             .put("ODU3", ODU3.VALUE)
 100             .put("ODU4", ODU4.VALUE)
 101             .put("ODUCn", ODUCn.VALUE)
 102             .put("ODUflexCbr", ODUflexCbr.VALUE)
 103             .put("ODUflexFlexe", ODUflexFlexe.VALUE)
 104             .put("ODUflexGfp", ODUflexGfp.VALUE)
 105             .put("ODUflexImp", ODUflexImp.VALUE)
 106             .build();
 107
 108     private static final ImmutableMap<String, OtuRateIdentity> OTU_RATE_MAP =
 109         ImmutableMap.<String, OtuRateIdentity>builder()
 110             .put("OTU0", OTU0.VALUE)
 111             .put("OTU1", OTU1.VALUE)
 112             .put("OTU2", OTU2.VALUE)
 113             .put("OTU2e", OTU2e.VALUE)
 114             .put("OTU3", OTU3.VALUE)
 115             .put("OTU4", OTU4.VALUE)
 116             .put("OTUCn", OTUCn.VALUE)
 117             .put("OTUflex", OTUflex.VALUE)
 118             .build();
 119
 120     private ModelMappingUtils() {
 121     }
 122
 123     public static ServiceImplementationRequestInput createServiceImplementationRequest(
 124             ServiceInput input,
 125             PathDescription pathDescription) {
 126         return new ServiceImplementationRequestInputBuilder()
 127             .setConnectionType(input.getConnectionType())
 128             .setServiceName(
 129                 input.isServiceReconfigure()
 130                     ? input.getNewServiceName()
 131                     : input.getServiceName())
 132             .setServiceAEnd(
 133                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 134                         .service.implementation.request.input.ServiceAEndBuilder()
 135                     .setServiceFormat(input.getServiceAEnd().getServiceFormat())
 136                     .setServiceRate(input.getServiceAEnd().getServiceRate())
 137                     .setOtuServiceRate(getOtuServiceRate(input.getServiceAEnd().getOtuServiceRate()))
 138                     .setOduServiceRate(getOduServiceRate(input.getServiceAEnd().getOduServiceRate()))
 139                     .setClli(input.getServiceAEnd().getClli())
 140                     .setNodeId(new NodeIdType(input.getServiceAEnd().getNodeId().getValue()).getValue())
 141                     .setTxDirection(
 142                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 143                                 .service.endpoint.sp.TxDirectionBuilder()
 144                             .setPort(
 145                                 input.getServiceAEnd().getTxDirection().values().stream().findFirst().get().getPort())
 146                             .build())
 147                     .setRxDirection(
 148                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 149                                 .service.endpoint.sp.RxDirectionBuilder()
 150                             .setPort(
 151                                 input.getServiceAEnd().getRxDirection().values().stream().findFirst().get().getPort())
 152                             .build())
 153                     .build())
 154             .setServiceZEnd(
 155                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 156                         .service.implementation.request.input.ServiceZEndBuilder()
 157                     .setServiceFormat(input.getServiceZEnd().getServiceFormat())
 158                     .setServiceRate(input.getServiceZEnd().getServiceRate())
 159                     .setOtuServiceRate(getOtuServiceRate(input.getServiceZEnd().getOtuServiceRate()))
 160                     .setOduServiceRate(getOduServiceRate(input.getServiceZEnd().getOduServiceRate()))
 161                     .setClli(input.getServiceZEnd().getClli())
 162                     .setNodeId(new NodeIdType(input.getServiceZEnd().getNodeId().getValue()).getValue())
 163                     .setTxDirection(
 164                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 165                                 .service.endpoint.sp.TxDirectionBuilder()
 166                             .setPort(
 167                                 input.getServiceZEnd().getTxDirection().values().stream().findFirst().get().getPort())
 168                             .build())
 169                     .setRxDirection(
 170                         new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 171                                 .service.endpoint.sp.RxDirectionBuilder()
 172                             .setPort(
 173                                 input.getServiceZEnd().getRxDirection().values().stream().findFirst().get().getPort())
 174                             .build())
 175                     .build())
 176             .setConnectionType(input.getConnectionType())
 177             .setServiceHandlerHeader(
 178                 new ServiceHandlerHeaderBuilder().setRequestId(input.getSdncRequestHeader().getRequestId()).build())
 179             .setPathDescription(
 180                 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 181                         .service.implementation.request.input.PathDescriptionBuilder()
 182                     .setAToZDirection(pathDescription.getAToZDirection())
 183                     .setZToADirection(pathDescription.getZToADirection())
 184                     .build())
 185             .build();
 186     }
 187
 188     private static OduRateIdentity getOduServiceRate(OduRateIdentity oduServiceRate) {
 189         if (oduServiceRate == null || !ODU_RATE_MAP.containsKey(oduServiceRate.toString())) {
 190             LOG.error("ODU rate {} not recognized", oduServiceRate);
 191             return null;
 192         }
 193         return ODU_RATE_MAP.get(oduServiceRate.toString());
 194     }
 195
 196     private static OtuRateIdentity getOtuServiceRate(OtuRateIdentity otuServiceRate) {
 197         if (otuServiceRate == null || !OTU_RATE_MAP.containsKey(otuServiceRate.toString())) {
 198             LOG.error("OTU rate {} not recognized", otuServiceRate);
 199             return null;
 200         }
 201         return OTU_RATE_MAP.get(otuServiceRate.toString());
 202     }
 203
 204     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 205             .ServiceDeleteInput createServiceDeleteInput(ServiceInput serviceInput) {
 206         return new ServiceDeleteInputBuilder()
 207             .setServiceName(serviceInput.getServiceName())
 208             .setServiceHandlerHeader(
 209                 new ServiceHandlerHeaderBuilder()
 210                     .setRequestId(serviceInput.getSdncRequestHeader().getRequestId())
 211                     .build())
 212             .build();
 213     }
 214
 215     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 216             .ServiceDeleteInput createServiceDeleteInput(
 217                 ServiceRerouteInput serviceRerouteinput,
 218                 Services services) {
 219         return new ServiceDeleteInputBuilder()
 220             .setServiceName(serviceRerouteinput.getServiceName())
 221             .setServiceHandlerHeader(
 222                 new ServiceHandlerHeaderBuilder()
 223                     .setRequestId(services.getSdncRequestHeader().getRequestId())
 224                     .build())
 225             .build();
 226     }
 227
 228     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 229             .ServiceDeleteInput createServiceDeleteInput(
 230                 ServiceRestorationInput serviceRestorationInput,
 231                 Services services) {
 232         return new ServiceDeleteInputBuilder()
 233             .setServiceName(serviceRestorationInput.getServiceName())
 234             .setServiceHandlerHeader(
 235                 new ServiceHandlerHeaderBuilder()
 236                     .setRequestId(services.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(ServiceReconfigureInput serviceReconfigureInput) {
 243         String serviceName = serviceReconfigureInput.getServiceName();
 244         return new ServiceDeleteInputBuilder()
 245             .setServiceName(serviceName)
 246             .setServiceHandlerHeader(
 247                 new ServiceHandlerHeaderBuilder().setRequestId(serviceName + "-reconfigure").build())
 248             .build();
 249     }
 250
 251     public static ServiceAEnd createServiceAEnd(ServiceEndpoint serviceAEnd) {
 252         return new ServiceAEndBuilder()
 253             .setClli(serviceAEnd.getClli())
 254             .setNodeId(serviceAEnd.getNodeId().getValue())
 255             .setRxDirection(createRxDirection(serviceAEnd.getRxDirection().values().stream().findFirst().get()))
 256             .setServiceFormat(serviceAEnd.getServiceFormat())
 257             .setServiceRate(serviceAEnd.getServiceRate())
 258             .setTxDirection(createTxDirection(serviceAEnd.getTxDirection().values().stream().findFirst().get()))
 259             .build();
 260     }
 261
 262     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
 263             .path.computation.reroute.request.input.ServiceAEnd createServiceAEndReroute(ServiceEndpoint serviceAEnd) {
 264         return new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
 265                 .path.computation.reroute.request.input.ServiceAEndBuilder()
 266                 .setClli(serviceAEnd.getClli())
 267                 .setNodeId(serviceAEnd.getNodeId().getValue())
 268                 .setRxDirection(createRxDirection(serviceAEnd.getRxDirection().values().stream().findFirst().get()))
 269                 .setServiceFormat(serviceAEnd.getServiceFormat())
 270                 .setServiceRate(serviceAEnd.getServiceRate())
 271                 .setTxDirection(createTxDirection(serviceAEnd.getTxDirection().values().stream().findFirst().get()))
 272                 .build();
 273     }
 274
 275     public static ServiceZEnd createServiceZEnd(ServiceEndpoint serviceZEnd) {
 276         return new ServiceZEndBuilder()
 277             .setClli(serviceZEnd.getClli())
 278             .setNodeId(serviceZEnd.getNodeId().getValue())
 279             .setRxDirection(createRxDirection(serviceZEnd.getRxDirection().values().stream().findFirst().get()))
 280             .setServiceFormat(serviceZEnd.getServiceFormat())
 281             .setServiceRate(serviceZEnd.getServiceRate())
 282             .setTxDirection(createTxDirection(serviceZEnd.getTxDirection().values().stream().findFirst().get()))
 283             .build();
 284     }
 285
 286     public static org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
 287             .path.computation.reroute.request.input.ServiceZEnd createServiceZEndReroute(ServiceEndpoint serviceZEnd) {
 288         return new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808
 289                 .path.computation.reroute.request.input.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, String responseCode) {
 421         return RpcResultBuilder
 422             .success(
 423                 new ServiceRerouteOutputBuilder()
 424                     .setConfigurationResponseCommon(
 425                         new ConfigurationResponseCommonBuilder()
 426                              .setAckFinalIndicator(finalAckYes)
 427                              .setResponseCode(responseCode)
 428                              .setResponseMessage(message)
 429                              .build())
 430                     .setHardConstraints(null)
 431                     .setSoftConstraints(null)
 432                     .build())
 433             .buildFuture();
 434     }
 435
 436     public static ListenableFuture<RpcResult<ServiceRestorationOutput>> createRestoreServiceReply(String message) {
 437         return RpcResultBuilder
 438             .success(
 439                 new ServiceRestorationOutputBuilder()
 440                     .setConfigurationResponseCommon(
 441                         new ConfigurationResponseCommonBuilder()
 442                             .setResponseMessage(message)
 443                             .build())
 444                     .build())
 445             .buildFuture();
 446     }
 447
 448     public static Services mappingServices(
 449             ServiceCreateInput serviceCreateInput,
 450             ServiceReconfigureInput serviceReconfigureInput) {
 451         if (serviceCreateInput != null) {
 452             return new ServicesBuilder()
 453                 .setServiceName(serviceCreateInput.getServiceName())
 454                 .setAdministrativeState(AdminStates.OutOfService)
 455                 .setOperationalState(State.OutOfService)
 456                 .setCommonId(serviceCreateInput.getCommonId())
 457                 .setConnectionType(serviceCreateInput.getConnectionType())
 458                 .setCustomer(serviceCreateInput.getCustomer())
 459                 .setCustomerContact(serviceCreateInput.getCustomerContact())
 460                 .setServiceResiliency(serviceCreateInput.getServiceResiliency())
 461                 .setHardConstraints(serviceCreateInput.getHardConstraints())
 462                 .setSoftConstraints(serviceCreateInput.getSoftConstraints())
 463                 .setSdncRequestHeader(serviceCreateInput.getSdncRequestHeader())
 464                 .setLifecycleState(LifecycleState.Planned)
 465                 .setServiceAEnd(
 466                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 467                             .service.ServiceAEndBuilder(serviceCreateInput.getServiceAEnd())
 468                         .build())
 469                 .setServiceZEnd(
 470                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 471                             .service.ServiceZEndBuilder(serviceCreateInput.getServiceZEnd())
 472                         .build())
 473                 .build();
 474         }
 475         if (serviceReconfigureInput != null) {
 476             return new ServicesBuilder()
 477                 .setServiceName(serviceReconfigureInput.getServiceName())
 478                 .setAdministrativeState(AdminStates.OutOfService)
 479                 .setOperationalState(State.OutOfService)
 480                 .setCommonId(serviceReconfigureInput.getCommonId())
 481                 .setConnectionType(serviceReconfigureInput.getConnectionType())
 482                 .setCustomer(serviceReconfigureInput.getCustomer())
 483                 .setCustomerContact(serviceReconfigureInput.getCustomerContact())
 484                 .setHardConstraints(serviceReconfigureInput.getHardConstraints())
 485                 .setSoftConstraints(serviceReconfigureInput.getSoftConstraints())
 486                 .setLifecycleState(LifecycleState.Planned)
 487                 .setServiceAEnd(
 488                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 489                             .service.ServiceAEndBuilder(serviceReconfigureInput.getServiceAEnd())
 490                         .build())
 491                 .setServiceZEnd(
 492                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 493                             .service.ServiceZEndBuilder(serviceReconfigureInput.getServiceZEnd())
 494                         .build())
 495                 .build();
 496         }
 497         //FIXME: Because of Silicon, we cannot have empty key.
 498         //it's this case possible ? There is a Junit test covering null
 499         //temporary workaround as now there is a null key check done by yangtools.
 500         //Functional review is needed
 501         LOG.warn("ServiceCreateInput and ServiceReconfigureInput are null");
 502         return new ServicesBuilder().withKey(new ServicesKey("unknown")).build();
 503     }
 504
 505     public static org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 506             .temp.service.list.Services mappingServices(TempServiceCreateInput tempServiceCreateInput) {
 507         return new org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 508                 .temp.service.list.ServicesBuilder()
 509             .setServiceName(tempServiceCreateInput.getCommonId())
 510             .setAdministrativeState(AdminStates.OutOfService)
 511             .setOperationalState(State.OutOfService)
 512             .setCommonId(tempServiceCreateInput.getCommonId())
 513             .setConnectionType(tempServiceCreateInput.getConnectionType())
 514             .setCustomer(tempServiceCreateInput.getCustomer())
 515             .setCustomerContact(tempServiceCreateInput.getCustomerContact())
 516             .setHardConstraints(tempServiceCreateInput.getHardConstraints())
 517             .setSoftConstraints(tempServiceCreateInput.getSoftConstraints())
 518             .setSdncRequestHeader(tempServiceCreateInput.getSdncRequestHeader())
 519             .setLifecycleState(LifecycleState.Planned)
 520             .setServiceAEnd(
 521                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 522                     .service.ServiceAEndBuilder(tempServiceCreateInput.getServiceAEnd()).build())
 523             .setServiceZEnd(
 524                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 525                     .service.ServiceZEndBuilder(tempServiceCreateInput.getServiceZEnd()).build())
 526             .build();
 527     }
 528
 529     public static ServicePaths mappingServicePaths(ServiceInput serviceInput, PathComputationRequestOutput output) {
 530         if (serviceInput == null) {
 531             //FIXME: Because of Silicon, we cannot have empty key.
 532             //it's this case possible ? There is a Junit test covering null
 533             //temporary workaround as now there is a null key check done by yangtools.
 534             //Functional review is needed
 535             LOG.warn("ServiceInput is null");
 536             return new ServicePathsBuilder().withKey(new ServicePathsKey("unknown")).build();
 537         }
 538
 539         ServicePathsBuilder servicePathBuilder =
 540             new ServicePathsBuilder()
 541                 .setServiceAEnd(
 542                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 543                             .service.path.ServiceAEndBuilder()
 544                         .setServiceFormat(serviceInput.getServiceAEnd().getServiceFormat())
 545                         .setServiceRate(serviceInput.getServiceAEnd().getServiceRate())
 546                         .setClli(serviceInput.getServiceAEnd().getClli())
 547                         .setNodeId(new NodeIdType(serviceInput.getServiceAEnd().getNodeId().getValue()).getValue())
 548                         .setTxDirection(
 549                             new org.opendaylight.yang.gen.v1
 550                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 551                                         .service.endpoint.sp.TxDirectionBuilder()
 552                                 .setPort(
 553                                     serviceInput.getServiceAEnd().getTxDirection()
 554                                         .values().stream().findFirst().get().getPort())
 555                                 .build())
 556                         .setRxDirection(
 557                             new org.opendaylight.yang.gen.v1
 558                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 559                                         .service.endpoint.sp.RxDirectionBuilder()
 560                                 .setPort(
 561                                     serviceInput.getServiceAEnd().getRxDirection()
 562                                         .values().stream().findFirst().get().getPort())
 563                                 .build())
 564                         .build())
 565                 .setServiceZEnd(
 566                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 567                             .service.path.ServiceZEndBuilder()
 568                         .setServiceFormat(serviceInput.getServiceZEnd().getServiceFormat())
 569                         .setServiceRate(serviceInput.getServiceZEnd().getServiceRate())
 570                         .setClli(serviceInput.getServiceZEnd().getClli())
 571                         .setNodeId(new NodeIdType(serviceInput.getServiceZEnd().getNodeId().getValue()).getValue())
 572                         .setTxDirection(
 573                             new org.opendaylight.yang.gen.v1
 574                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 575                                         .service.endpoint.sp.TxDirectionBuilder()
 576                                 .setPort(
 577                                     serviceInput.getServiceZEnd().getTxDirection()
 578                                         .values().stream().findFirst().get().getPort())
 579                                 .build())
 580                         .setRxDirection(
 581                             new org.opendaylight.yang.gen.v1
 582                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 583                                         .service.endpoint.sp.RxDirectionBuilder()
 584                                 .setPort(
 585                                     serviceInput.getServiceZEnd().getRxDirection()
 586                                         .values().stream().findFirst().get().getPort())
 587                                 .build())
 588                         .build())
 589                 .setServicePathName(serviceInput.getServiceName())
 590                 .setServiceHandlerHeader(
 591                     new ServiceHandlerHeaderBuilder()
 592                         .setRequestId(serviceInput.getSdncRequestHeader()
 593                         .getRequestId())
 594                         .build());
 595         if (serviceInput.getHardConstraints() != null) {
 596             servicePathBuilder.setHardConstraints(serviceInput.getHardConstraints());
 597         }
 598         if (serviceInput.getSoftConstraints() != null) {
 599             servicePathBuilder.setSoftConstraints(serviceInput.getSoftConstraints());
 600         }
 601
 602         if (output.getResponseParameters().getPathDescription() != null) {
 603             servicePathBuilder.setPathDescription(
 604                 new PathDescriptionBuilder(output.getResponseParameters().getPathDescription()).build());
 605         }
 606         return servicePathBuilder.build();
 607     }
 608
 609
 610     @edu.umd.cs.findbugs.annotations.SuppressFBWarnings(
 611         value = "PZLA_PREFER_ZERO_LENGTH_ARRAYS",
 612         justification = "not relevant to return and zero length array as we need real pos")
 613     public static int[] findTheLongestSubstring(String s1, String s2) {
 614         if ((s1 == null) || (s2 == null)) {
 615             return null;
 616         }
 617         int[][] dp = new int[s1.length() + 1][s2.length() + 1];
 618         int maxLen = 0;
 619         int endPos = 0;
 620         for (int i = 1; i < dp.length; i++) {
 621             for (int j = 1; j < dp[0].length; j++) {
 622                 char ch1 = s1.charAt(i - 1);
 623                 char ch2 = s2.charAt(j - 1);
 624                 if (ch1 == ch2) {
 625                     dp[i][j] = dp[i - 1][j - 1] + 1;
 626                     if (dp[i][j] >= maxLen) {
 627                         maxLen = dp[i][j];
 628                         endPos = i;
 629                     }
 630                 }
 631             }
 632         }
 633         return new int[] { endPos - maxLen, endPos };
 634     }
 635 }