sdnr/wt/netconfnode-state-service/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/netconfnodestateservice/impl/NetconfAccessorImpl.java

   1 /**
   2  * ============LICENSE_START========================================================================
   3  * ONAP : ccsdk feature sdnr wt
   4  * =================================================================================================
   5  * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
   6  * =================================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   8  * in compliance with the License. You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software distributed under the License
  13  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  14  * or implied. See the License for the specific language governing permissions and limitations under
  15  * the License.
  16  * ============LICENSE_END==========================================================================
  17  */
  18 package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.impl;
  19
  20 import com.google.common.util.concurrent.ListenableFuture;
  21 import com.google.common.util.concurrent.SettableFuture;
  22 import java.util.Optional;
  23 import javax.annotation.Nonnull;
  24 import org.eclipse.jdt.annotation.NonNull;
  25 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.Capabilities;
  26 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfAccessor;
  27 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.TransactionUtils;
  28 import org.opendaylight.mdsal.binding.api.DataBroker;
  29 import org.opendaylight.mdsal.binding.api.MountPoint;
  30 import org.opendaylight.mdsal.binding.api.NotificationService;
  31 import org.opendaylight.mdsal.binding.api.RpcConsumerRegistry;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.CreateSubscriptionInput;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.CreateSubscriptionInputBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.CreateSubscriptionOutput;
  35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.NotificationsService;
  36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.notification._1._0.rev080714.StreamNameType;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeConnectionStatus.ConnectionStatus;
  39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
  40 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  41 import org.opendaylight.yangtools.yang.binding.NotificationListener;
  42 import org.opendaylight.yangtools.yang.common.RpcResult;
  43 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  44 import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
  45 import org.slf4j.Logger;
  46 import org.slf4j.LoggerFactory;
  47
  48 public class NetconfAccessorImpl implements NetconfAccessor {
  49
  50     private static final Logger log = LoggerFactory.getLogger(NetconfAccessorImpl.class);
  51
  52     private final NodeId nodeId;
  53     private final DataBroker dataBroker;
  54     private final TransactionUtils transactionUtils;
  55     private final MountPoint mountpoint;
  56     private final NetconfNode netconfNode;
  57     private final Capabilities capabilities;
  58
  59     /**
  60      * Contains all data to access and manage netconf device
  61      * @param nodeId  of managed netconf node
  62      * @param netconfNode information
  63      * @param dataBroker to access node
  64      * @param mountpoint of netconfNode
  65      * @param transactionUtils with read an write functions
  66      */
  67     public NetconfAccessorImpl(NodeId nodeId, NetconfNode netconfNode, DataBroker dataBroker, MountPoint mountpoint,
  68             TransactionUtils transactionUtils) {
  69         super();
  70         this.nodeId = nodeId;
  71         this.netconfNode = netconfNode;
  72         this.dataBroker = dataBroker;
  73         this.mountpoint = mountpoint;
  74         this.transactionUtils = transactionUtils;
  75
  76         ConnectionStatus csts = netconfNode != null ? netconfNode.getConnectionStatus() : null;
  77         this.capabilities = Capabilities.getAvailableCapabilities(csts != null ? netconfNode : null);
  78     }
  79
  80     /**
  81      * @param nodeId     with uuid of managed netconf node
  82      * @param dataBroker to access node
  83      */
  84     public NetconfAccessorImpl(String nodeId, NetconfNode netconfNode, DataBroker dataBroker, MountPoint mountpoint,
  85             TransactionUtils transactionUtils) {
  86         this(new NodeId(nodeId), netconfNode, dataBroker, mountpoint, transactionUtils);
  87     }
  88
  89     @Override
  90     public NodeId getNodeId() {
  91         return nodeId;
  92     }
  93
  94     @Override
  95     public DataBroker getDataBroker() {
  96         return dataBroker;
  97     }
  98     @Override
  99     public MountPoint getMountpoint() {
 100         return mountpoint;
 101     }
 102     @Override
 103     public TransactionUtils getTransactionUtils() {
 104         return transactionUtils;
 105     }
 106     @Override
 107     public NetconfNode getNetconfNode() {
 108         return netconfNode;
 109     }
 110     @Override
 111     public Capabilities getCapabilites() {
 112         return capabilities;
 113     }
 114
 115     @Override
 116     public @NonNull <T extends NotificationListener> ListenerRegistration<NotificationListener> doRegisterNotificationListener(@NonNull T listener) {
 117         log.info("Begin register listener for Mountpoint {}", mountpoint.getIdentifier().toString());
 118         final Optional<NotificationService> optionalNotificationService = mountpoint
 119                 .getService(NotificationService.class);
 120         final NotificationService notificationService = optionalNotificationService.get();
 121         final ListenerRegistration<NotificationListener> ranListenerRegistration = notificationService
 122                 .registerNotificationListener(listener);
 123         log.info("End registration listener for Mountpoint {} Listener: {} Result: {}",
 124                 mountpoint.getIdentifier().toString(), optionalNotificationService, ranListenerRegistration);
 125         return ranListenerRegistration;
 126     }
 127
 128     @Override
 129     public ListenableFuture<RpcResult<CreateSubscriptionOutput>> registerNotificationsStream(String streamName) {
 130
 131         String failMessage = "";
 132         final Optional<RpcConsumerRegistry> optionalRpcConsumerService =
 133                 mountpoint.getService(RpcConsumerRegistry.class);
 134         if (optionalRpcConsumerService.isPresent()) {
 135             final RpcConsumerRegistry rpcConsumerRegitry = optionalRpcConsumerService.get();
 136             @Nonnull
 137             final NotificationsService rpcService = rpcConsumerRegitry.getRpcService(NotificationsService.class);
 138
 139             final CreateSubscriptionInputBuilder createSubscriptionInputBuilder = new CreateSubscriptionInputBuilder();
 140             createSubscriptionInputBuilder.setStream(new StreamNameType(streamName));
 141             log.info("Event listener triggering notification stream {} for node {}", streamName, nodeId);
 142             try {
 143                 CreateSubscriptionInput createSubscriptionInput = createSubscriptionInputBuilder.build();
 144                 if (createSubscriptionInput == null) {
 145                     failMessage = "createSubscriptionInput is null for mountpoint " + nodeId;
 146                 } else {
 147                     return rpcService.createSubscription(createSubscriptionInput);
 148                 }
 149             } catch (NullPointerException e) {
 150                 failMessage = "createSubscription failed";
 151             }
 152         } else {
 153             failMessage = "No RpcConsumerRegistry avaialble.";
 154         }
 155         log.warn(failMessage);
 156         RpcResultBuilder<CreateSubscriptionOutput> result = RpcResultBuilder.failed();
 157         result.withError(ErrorType.APPLICATION, failMessage);
 158         SettableFuture<RpcResult<CreateSubscriptionOutput>> res = SettableFuture.create();
 159         res.set(result.build());
 160         return res;
 161     }
 162
 163
 164 }