2 * Copyright © 2024 Orange, Inc. and others. All rights reserved.
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
8 package org.opendaylight.transportpce.tapi.impl.rpc;
10 import com.google.common.util.concurrent.ListenableFuture;
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;
28 public class InitRoadmRoadmTapiLinkImpl implements InitRoadmRoadmTapiLink {
29 private static final Logger LOG = LoggerFactory.getLogger(InitRoadmRoadmTapiLinkImpl.class);
31 private TapiLink tapiLink;
32 private TapiNetworkUtilsImpl tapiNetworkUtilsImpl;
34 public InitRoadmRoadmTapiLinkImpl(TapiLink tapiLink, TapiNetworkUtilsImpl tapiNetworkUtilsImpl) {
35 this.tapiLink = tapiLink;
36 this.tapiNetworkUtilsImpl = tapiNetworkUtilsImpl;
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();
55 LOG.error("Error creating link object");
56 return RpcResultBuilder.<InitRoadmRoadmTapiLinkOutput>failed()
57 .withError(ErrorType.RPC, "Failed to create link in topology")
60 if (tapiNetworkUtilsImpl.putLinkInTopology(link)) {
61 output = new InitRoadmRoadmTapiLinkOutputBuilder()
62 .setResult("Link created in tapi topology. Link-uuid = " + link.getUuid());
64 return RpcResultBuilder.success(output.build()).buildFuture();