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