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.rev220615.PathComputationRequestOutput;
  13 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceAEnd;
  14 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceAEndBuilder;
  15 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceZEnd;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.path.computation.request.input.ServiceZEndBuilder;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220615.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.rev181130.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 ServiceZEnd createServiceZEnd(ServiceEndpoint serviceZEnd) {
 263         return new ServiceZEndBuilder()
 264             .setClli(serviceZEnd.getClli())
 265             .setNodeId(serviceZEnd.getNodeId().getValue())
 266             .setRxDirection(createRxDirection(serviceZEnd.getRxDirection().values().stream().findFirst().get()))
 267             .setServiceFormat(serviceZEnd.getServiceFormat())
 268             .setServiceRate(serviceZEnd.getServiceRate())
 269             .setTxDirection(createTxDirection(serviceZEnd.getTxDirection().values().stream().findFirst().get()))
 270             .build();
 271     }
 272
 273     public static RxDirection createRxDirection(
 274             org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 275                 .service.endpoint.RxDirection rxDirection) {
 276         return new RxDirectionBuilder().setPort(rxDirection.getPort()).build();
 277     }
 278
 279     public static TxDirection createTxDirection(
 280             org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 281                 .service.endpoint.TxDirection txDirection) {
 282         return new TxDirectionBuilder().setPort(txDirection.getPort()).build();
 283     }
 284
 285     public static ListenableFuture<RpcResult<ServiceDeleteOutput>> createDeleteServiceReply(
 286             ServiceDeleteInput input, String finalAck, String message, String responseCode) {
 287         return RpcResultBuilder
 288             .success(
 289                 new ServiceDeleteOutputBuilder()
 290                     .setConfigurationResponseCommon(
 291                         new ConfigurationResponseCommonBuilder()
 292                             .setAckFinalIndicator(finalAck)
 293                             .setResponseMessage(message)
 294                             .setResponseCode(responseCode)
 295                             .setRequestId(
 296                                 input.getSdncRequestHeader() == null
 297                                     ? null
 298                                     : input.getSdncRequestHeader().getRequestId())
 299                             .build())
 300                     .build())
 301             .buildFuture();
 302     }
 303
 304     public static ListenableFuture<RpcResult<TempServiceDeleteOutput>> createDeleteServiceReply(
 305             TempServiceDeleteInput input, String finalAck, String message, String responseCode) {
 306         return RpcResultBuilder
 307             .success(
 308                 new TempServiceDeleteOutputBuilder()
 309                     .setConfigurationResponseCommon(
 310                         new ConfigurationResponseCommonBuilder()
 311                             .setAckFinalIndicator(finalAck)
 312                             .setResponseMessage(message)
 313                             .setResponseCode(responseCode)
 314                             .setRequestId(null)
 315                             .build())
 316                     .build())
 317             .buildFuture();
 318     }
 319
 320     public static ListenableFuture<RpcResult<ServiceCreateOutput>> createCreateServiceReply(
 321             ServiceCreateInput input, String finalAck, String message, String responseCode) {
 322         return RpcResultBuilder
 323             .success(
 324                 new ServiceCreateOutputBuilder()
 325                     .setConfigurationResponseCommon(
 326                         new ConfigurationResponseCommonBuilder()
 327                             .setAckFinalIndicator(finalAck)
 328                             .setResponseMessage(message)
 329                             .setResponseCode(responseCode)
 330                             .setRequestId(
 331                                 input.getSdncRequestHeader() == null
 332                                     ? null
 333                                     : input.getSdncRequestHeader().getRequestId())
 334                             .build())
 335                     .setResponseParameters(new ResponseParametersBuilder().build())
 336                     .build())
 337             .buildFuture();
 338     }
 339
 340     public static ListenableFuture<RpcResult<TempServiceCreateOutput>> createCreateServiceReply(
 341             TempServiceCreateInput input, String finalAck, String message, String responseCode) {
 342         return RpcResultBuilder
 343             .success(
 344                 new TempServiceCreateOutputBuilder()
 345                     .setConfigurationResponseCommon(
 346                         new ConfigurationResponseCommonBuilder()
 347                             .setAckFinalIndicator(finalAck)
 348                              .setResponseMessage(message)
 349                             .setResponseCode(responseCode)
 350                             .setRequestId(
 351                                 input.getSdncRequestHeader() == null
 352                                     ? null
 353                                     : input.getSdncRequestHeader().getRequestId())
 354                             .build())
 355                     .setResponseParameters(new ResponseParametersBuilder().build())
 356                     .build())
 357             .buildFuture();
 358     }
 359
 360     public static ListenableFuture<RpcResult<ServiceFeasibilityCheckOutput>> createCreateServiceReply(
 361             ServiceFeasibilityCheckInput input, String finalAck, String message, String responseCode) {
 362         return RpcResultBuilder
 363             .success(
 364                 new ServiceFeasibilityCheckOutputBuilder()
 365                     .setConfigurationResponseCommon(
 366                         new ConfigurationResponseCommonBuilder()
 367                             .setAckFinalIndicator(finalAck)
 368                             .setResponseMessage(message)
 369                             .setResponseCode(responseCode)
 370                             .setRequestId(
 371                                 input.getSdncRequestHeader() == null
 372                                     ? null
 373                                     : input.getSdncRequestHeader().getRequestId())
 374                             .build())
 375                     .setResponseParameters(new ResponseParametersBuilder().build())
 376                     .build())
 377             .buildFuture();
 378     }
 379
 380     public static ListenableFuture<RpcResult<ServiceReconfigureOutput>> createCreateServiceReply(
 381             ServiceReconfigureInput input, String message) {
 382         return RpcResultBuilder
 383             .success(
 384                 new ServiceReconfigureOutputBuilder()
 385                     .setConfigurationResponseCommon(
 386                         new ConfigurationResponseCommonBuilder()
 387                             .setResponseMessage(message)
 388                             .build())
 389                     .build())
 390             .buildFuture();
 391     }
 392
 393     public static ListenableFuture<RpcResult<ServiceRerouteOutput>> createRerouteServiceReply(
 394             ServiceRerouteInput input, String finalAckYes, String message) {
 395         return RpcResultBuilder
 396             .success(
 397                 new ServiceRerouteOutputBuilder()
 398                     .setConfigurationResponseCommon(
 399                         new ConfigurationResponseCommonBuilder()
 400                             .setResponseMessage(message)
 401                             .build())
 402                     .setHardConstraints(null)
 403                     .setSoftConstraints(null)
 404                     .build())
 405             .buildFuture();
 406     }
 407
 408     public static ListenableFuture<RpcResult<ServiceRestorationOutput>> createRestoreServiceReply(String message) {
 409         return RpcResultBuilder
 410             .success(
 411                 new ServiceRestorationOutputBuilder()
 412                     .setConfigurationResponseCommon(
 413                         new ConfigurationResponseCommonBuilder()
 414                             .setResponseMessage(message)
 415                             .build())
 416                     .build())
 417             .buildFuture();
 418     }
 419
 420     public static Services mappingServices(
 421             ServiceCreateInput serviceCreateInput,
 422             ServiceReconfigureInput serviceReconfigureInput) {
 423         if (serviceCreateInput != null) {
 424             return new ServicesBuilder()
 425                 .setServiceName(serviceCreateInput.getServiceName())
 426                 .setAdministrativeState(AdminStates.OutOfService)
 427                 .setOperationalState(State.OutOfService)
 428                 .setCommonId(serviceCreateInput.getCommonId())
 429                 .setConnectionType(serviceCreateInput.getConnectionType())
 430                 .setCustomer(serviceCreateInput.getCustomer())
 431                 .setCustomerContact(serviceCreateInput.getCustomerContact())
 432                 .setServiceResiliency(serviceCreateInput.getServiceResiliency())
 433                 .setHardConstraints(serviceCreateInput.getHardConstraints())
 434                 .setSoftConstraints(serviceCreateInput.getSoftConstraints())
 435                 .setSdncRequestHeader(serviceCreateInput.getSdncRequestHeader())
 436                 .setLifecycleState(LifecycleState.Planned)
 437                 .setServiceAEnd(
 438                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 439                             .service.ServiceAEndBuilder(serviceCreateInput.getServiceAEnd())
 440                         .build())
 441                 .setServiceZEnd(
 442                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 443                             .service.ServiceZEndBuilder(serviceCreateInput.getServiceZEnd())
 444                         .build())
 445                 .build();
 446         }
 447         if (serviceReconfigureInput != null) {
 448             return new ServicesBuilder()
 449                 .setServiceName(serviceReconfigureInput.getServiceName())
 450                 .setAdministrativeState(AdminStates.OutOfService)
 451                 .setOperationalState(State.OutOfService)
 452                 .setCommonId(serviceReconfigureInput.getCommonId())
 453                 .setConnectionType(serviceReconfigureInput.getConnectionType())
 454                 .setCustomer(serviceReconfigureInput.getCustomer())
 455                 .setCustomerContact(serviceReconfigureInput.getCustomerContact())
 456                 .setHardConstraints(serviceReconfigureInput.getHardConstraints())
 457                 .setSoftConstraints(serviceReconfigureInput.getSoftConstraints())
 458                 .setLifecycleState(LifecycleState.Planned)
 459                 .setServiceAEnd(
 460                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 461                             .service.ServiceAEndBuilder(serviceReconfigureInput.getServiceAEnd())
 462                         .build())
 463                 .setServiceZEnd(
 464                     new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 465                             .service.ServiceZEndBuilder(serviceReconfigureInput.getServiceZEnd())
 466                         .build())
 467                 .build();
 468         }
 469         //FIXME: Because of Silicon, we cannot have empty key.
 470         //it's this case possible ? There is a Junit test covering null
 471         //temporary workaround as now there is a null key check done by yangtools.
 472         //Functional review is needed
 473         LOG.warn("ServiceCreateInput and ServiceReconfigureInput are null");
 474         return new ServicesBuilder().withKey(new ServicesKey("unknown")).build();
 475     }
 476
 477     public static org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 478             .temp.service.list.Services mappingServices(TempServiceCreateInput tempServiceCreateInput) {
 479         return new org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210
 480                 .temp.service.list.ServicesBuilder()
 481             .setServiceName(tempServiceCreateInput.getCommonId())
 482             .setAdministrativeState(AdminStates.OutOfService)
 483             .setOperationalState(State.OutOfService)
 484             .setCommonId(tempServiceCreateInput.getCommonId())
 485             .setConnectionType(tempServiceCreateInput.getConnectionType())
 486             .setCustomer(tempServiceCreateInput.getCustomer())
 487             .setCustomerContact(tempServiceCreateInput.getCustomerContact())
 488             .setHardConstraints(tempServiceCreateInput.getHardConstraints())
 489             .setSoftConstraints(tempServiceCreateInput.getSoftConstraints())
 490             .setSdncRequestHeader(tempServiceCreateInput.getSdncRequestHeader())
 491             .setLifecycleState(LifecycleState.Planned)
 492             .setServiceAEnd(
 493                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 494                     .service.ServiceAEndBuilder(tempServiceCreateInput.getServiceAEnd()).build())
 495             .setServiceZEnd(
 496                 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev211210
 497                     .service.ServiceZEndBuilder(tempServiceCreateInput.getServiceZEnd()).build())
 498             .build();
 499     }
 500
 501     public static ServicePaths mappingServicePaths(ServiceInput serviceInput, PathComputationRequestOutput output) {
 502         if (serviceInput == null) {
 503             //FIXME: Because of Silicon, we cannot have empty key.
 504             //it's this case possible ? There is a Junit test covering null
 505             //temporary workaround as now there is a null key check done by yangtools.
 506             //Functional review is needed
 507             LOG.warn("ServiceInput is null");
 508             return new ServicePathsBuilder().withKey(new ServicePathsKey("unknown")).build();
 509         }
 510
 511         ServicePathsBuilder servicePathBuilder =
 512             new ServicePathsBuilder()
 513                 .setServiceAEnd(
 514                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 515                             .service.path.ServiceAEndBuilder()
 516                         .setServiceFormat(serviceInput.getServiceAEnd().getServiceFormat())
 517                         .setServiceRate(serviceInput.getServiceAEnd().getServiceRate())
 518                         .setClli(serviceInput.getServiceAEnd().getClli())
 519                         .setNodeId(new NodeIdType(serviceInput.getServiceAEnd().getNodeId().getValue()).getValue())
 520                         .setTxDirection(
 521                             new org.opendaylight.yang.gen.v1
 522                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 523                                         .service.endpoint.sp.TxDirectionBuilder()
 524                                 .setPort(
 525                                     serviceInput.getServiceAEnd().getTxDirection()
 526                                         .values().stream().findFirst().get().getPort())
 527                                 .build())
 528                         .setRxDirection(
 529                             new org.opendaylight.yang.gen.v1
 530                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 531                                         .service.endpoint.sp.RxDirectionBuilder()
 532                                 .setPort(
 533                                     serviceInput.getServiceAEnd().getRxDirection()
 534                                         .values().stream().findFirst().get().getPort())
 535                                 .build())
 536                         .build())
 537                 .setServiceZEnd(
 538                     new org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118
 539                             .service.path.ServiceZEndBuilder()
 540                         .setServiceFormat(serviceInput.getServiceZEnd().getServiceFormat())
 541                         .setServiceRate(serviceInput.getServiceZEnd().getServiceRate())
 542                         .setClli(serviceInput.getServiceZEnd().getClli())
 543                         .setNodeId(new NodeIdType(serviceInput.getServiceZEnd().getNodeId().getValue()).getValue())
 544                         .setTxDirection(
 545                             new org.opendaylight.yang.gen.v1
 546                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 547                                         .service.endpoint.sp.TxDirectionBuilder()
 548                                 .setPort(
 549                                     serviceInput.getServiceZEnd().getTxDirection()
 550                                         .values().stream().findFirst().get().getPort())
 551                                 .build())
 552                         .setRxDirection(
 553                             new org.opendaylight.yang.gen.v1
 554                                     .http.org.transportpce.b.c._interface.service.types.rev220118
 555                                         .service.endpoint.sp.RxDirectionBuilder()
 556                                 .setPort(
 557                                     serviceInput.getServiceZEnd().getRxDirection()
 558                                         .values().stream().findFirst().get().getPort())
 559                                 .build())
 560                         .build())
 561                 .setServicePathName(serviceInput.getServiceName())
 562                 .setServiceHandlerHeader(
 563                     new ServiceHandlerHeaderBuilder()
 564                         .setRequestId(serviceInput.getSdncRequestHeader()
 565                         .getRequestId())
 566                         .build());
 567         if (serviceInput.getHardConstraints() != null) {
 568             servicePathBuilder.setHardConstraints(serviceInput.getHardConstraints());
 569         }
 570         if (serviceInput.getSoftConstraints() != null) {
 571             servicePathBuilder.setSoftConstraints(serviceInput.getSoftConstraints());
 572         }
 573
 574         if (output.getResponseParameters().getPathDescription() != null) {
 575             servicePathBuilder.setPathDescription(
 576                 new PathDescriptionBuilder(output.getResponseParameters().getPathDescription()).build());
 577         }
 578         return servicePathBuilder.build();
 579     }
 580
 581
 582     @edu.umd.cs.findbugs.annotations.SuppressFBWarnings(
 583         value = "PZLA_PREFER_ZERO_LENGTH_ARRAYS",
 584         justification = "not relevant to return and zero length array as we need real pos")
 585     public static int[] findTheLongestSubstring(String s1, String s2) {
 586         if ((s1 == null) || (s2 == null)) {
 587             return null;
 588         }
 589         int[][] dp = new int[s1.length() + 1][s2.length() + 1];
 590         int maxLen = 0;
 591         int endPos = 0;
 592         for (int i = 1; i < dp.length; i++) {
 593             for (int j = 1; j < dp[0].length; j++) {
 594                 char ch1 = s1.charAt(i - 1);
 595                 char ch2 = s2.charAt(j - 1);
 596                 if (ch1 == ch2) {
 597                     dp[i][j] = dp[i - 1][j - 1] + 1;
 598                     if (dp[i][j] >= maxLen) {
 599                         maxLen = dp[i][j];
 600                         endPos = i;
 601                     }
 602                 }
 603             }
 604         }
 605         return new int[] { endPos - maxLen, endPos };
 606     }
 607 }