tapi/src/main/java/org/opendaylight/transportpce/tapi/impl/rpc/GetNodeDetailsImpl.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 org.opendaylight.transportpce.tapi.utils.TapiContext;
  12 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.Uuid;
  13 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.GetNodeDetails;
  14 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.GetNodeDetailsInput;
  15 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.GetNodeDetailsOutput;
  16 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.GetNodeDetailsOutputBuilder;
  17 import org.opendaylight.yangtools.yang.common.ErrorType;
  18 import org.opendaylight.yangtools.yang.common.RpcResult;
  19 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23
  24 public class GetNodeDetailsImpl implements GetNodeDetails {
  25     private static final Logger LOG = LoggerFactory.getLogger(GetNodeDetailsImpl.class);
  26     private final TapiContext tapiContext;
  27
  28     public GetNodeDetailsImpl(TapiContext tapiContext) {
  29         this.tapiContext = tapiContext;
  30     }
  31
  32     @Override
  33     public ListenableFuture<RpcResult<GetNodeDetailsOutput>> invoke(GetNodeDetailsInput input) {
  34         // TODO Auto-generated method stub
  35         // TODO -> maybe we get errors when having CEPs?
  36         Uuid topoUuid = input.getTopologyId();
  37         // Node id: if roadm -> ROADM+PHOTONIC_MEDIA. if xpdr -> XPDR-XPDR+DSR/OTSi
  38         Uuid nodeUuid = input.getNodeId();
  39         org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.topology.rev221121.topology.Node node = this.tapiContext
  40                 .getTapiNode(topoUuid, nodeUuid);
  41         if (node == null) {
  42             LOG.error("Invalid TAPI node name");
  43             return RpcResultBuilder.<GetNodeDetailsOutput>failed()
  44                 .withError(ErrorType.RPC, "Invalid Tapi Node name")
  45                 .buildFuture();
  46         }
  47         return RpcResultBuilder.success(new GetNodeDetailsOutputBuilder()
  48                 .setNode(new org.opendaylight.yang.gen.v1.urn
  49                         .onf.otcc.yang.tapi.topology.rev221121.get.node.details.output.NodeBuilder(node).build())
  50                 .build()).buildFuture();
  51     }
  52
  53 }