tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/rpc/InitRoadmRoadmTapiLinkImpl.java

   1 /*
   2  * Copyright © 2024 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.tapi.impl.rpc;
   9
  10 import com.google.common.util.concurrent.ListenableFuture;
  11 import java.util.Set;
  12 import org.opendaylight.transportpce.tapi.TapiStringConstants;
  13 import org.opendaylight.transportpce.tapi.topology.TapiNetworkUtilsImpl;
  14 import org.opendaylight.transportpce.tapi.utils.TapiLink;
  15 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.tapinetworkutils.rev230728.InitRoadmRoadmTapiLink;
  16 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.tapinetworkutils.rev230728.InitRoadmRoadmTapiLinkInput;
  17 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.tapinetworkutils.rev230728.InitRoadmRoadmTapiLinkOutput;
  18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.tapinetworkutils.rev230728.InitRoadmRoadmTapiLinkOutputBuilder;
  19 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.LayerProtocolName;
  20 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.Link;
  21 import org.opendaylight.yangtools.yang.common.ErrorType;
  22 import org.opendaylight.yangtools.yang.common.RpcResult;
  23 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  24 import org.slf4j.Logger;
  25 import org.slf4j.LoggerFactory;
  26
  27
  28 public class InitRoadmRoadmTapiLinkImpl implements InitRoadmRoadmTapiLink {
  29     private static final Logger LOG = LoggerFactory.getLogger(InitRoadmRoadmTapiLinkImpl.class);
  30
  31     private TapiLink tapiLink;
  32     private TapiNetworkUtilsImpl tapiNetworkUtilsImpl;
  33
  34     public InitRoadmRoadmTapiLinkImpl(TapiLink tapiLink, TapiNetworkUtilsImpl tapiNetworkUtilsImpl) {
  35         this.tapiLink = tapiLink;
  36         this.tapiNetworkUtilsImpl = tapiNetworkUtilsImpl;
  37     }
  38
  39     @Override
  40     public ListenableFuture<RpcResult<InitRoadmRoadmTapiLinkOutput>> invoke(InitRoadmRoadmTapiLinkInput input) {
  41         // TODO --> need to check if the nodes and neps exist in the topology
  42         String sourceNode = input.getRdmANode();
  43         String sourceTp = input.getDegATp();
  44         String destNode = input.getRdmZNode();
  45         String destTp = input.getDegZTp();
  46         Link link = this.tapiLink.createTapiLink(sourceNode, sourceTp, destNode, destTp,
  47             TapiStringConstants.OMS_RDM_RDM_LINK, TapiStringConstants.PHTNC_MEDIA, TapiStringConstants.PHTNC_MEDIA,
  48             TapiStringConstants.PHTNC_MEDIA_OTS, TapiStringConstants.PHTNC_MEDIA_OTS,
  49             this.tapiLink.getAdminState(sourceNode, sourceTp, destNode, destTp),
  50             this.tapiLink.getOperState(sourceNode, sourceTp, destNode, destTp),
  51             Set.of(LayerProtocolName.PHOTONICMEDIA), Set.of(LayerProtocolName.PHOTONICMEDIA.getName()),
  52             tapiNetworkUtilsImpl.getTapiTopoUuid());
  53         InitRoadmRoadmTapiLinkOutputBuilder output = new InitRoadmRoadmTapiLinkOutputBuilder();
  54         if (link == null) {
  55             LOG.error("Error creating link object");
  56             return RpcResultBuilder.<InitRoadmRoadmTapiLinkOutput>failed()
  57                 .withError(ErrorType.RPC, "Failed to create link in topology")
  58                 .buildFuture();
  59         }
  60         if (tapiNetworkUtilsImpl.putLinkInTopology(link)) {
  61             output = new InitRoadmRoadmTapiLinkOutputBuilder()
  62                 .setResult("Link created in tapi topology. Link-uuid = " + link.getUuid());
  63         }
  64         return RpcResultBuilder.success(output.build()).buildFuture();
  65     }
  66 }