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