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
10 * http://www.apache.org/licenses/LICENSE-2.0
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
16 * ============LICENSE_END==========================================================================
19 * Convert capabilities of netconfnode into internal format. Boron and Carbon are providing
22 package org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice;
24 import java.text.DateFormat;
25 import java.text.SimpleDateFormat;
26 import java.util.ArrayList;
27 import java.util.Date;
28 import java.util.List;
29 import java.util.Optional;
30 import javax.annotation.Nullable;
31 import org.eclipse.jdt.annotation.NonNull;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.connection.oper.AvailableCapabilities;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.connection.oper.UnavailableCapabilities;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.connection.oper.available.capabilities.AvailableCapability;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.connection.oper.unavailable.capabilities.UnavailableCapability;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev221225.NetconfNode;
37 import org.opendaylight.yangtools.yang.common.QName;
38 import org.opendaylight.yangtools.yang.common.QNameModule;
39 import org.opendaylight.yangtools.yang.common.Revision;
40 import org.slf4j.Logger;
41 import org.slf4j.LoggerFactory;
44 * Wrapper class for capabilites for Boron and later releases. Uses generics because yang model was changed from Boron
45 * to later version. Interface class:
46 * org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapability
48 public class Capabilities {
50 private static final Logger LOG = LoggerFactory.getLogger(Capabilities.class);
52 private static final String UNSUPPORTED = "Unsupported";
53 private static final DateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
55 private final List<String> capabilities = new ArrayList<>();
57 private Capabilities() {}
59 public static Capabilities getAvailableCapabilities(@Nullable NetconfNode nnode) {
60 LOG.debug("GetAvailableCapabilities for node");
61 Capabilities capabilities = new Capabilities();
63 AvailableCapabilities availableCapabilites = nnode.getAvailableCapabilities();
64 if (availableCapabilites != null) {
65 capabilities.constructor(availableCapabilites.getAvailableCapability());
67 LOG.debug("empty capabilites");
70 LOG.debug("No node provided");
75 public static Capabilities getUnavailableCapabilities(NetconfNode nnode) {
76 LOG.debug("GetUnavailableCapabilities for node");
77 Capabilities capabilities = new Capabilities();
79 UnavailableCapabilities availableCapabilites = nnode.getUnavailableCapabilities();
80 if (availableCapabilites != null) {
81 capabilities.constructor2(availableCapabilites.getUnavailableCapability());
83 LOG.debug("empty capabilites");
86 LOG.debug("No node provided");
93 * Does all construction steps
95 * @param pcapabilities with a list of capabilities.
97 private void constructor(List<AvailableCapability> pcapabilities) {
98 if (pcapabilities != null) {
99 for (AvailableCapability capability : pcapabilities) {
100 this.capabilities.add(capability.getCapability());
105 private void constructor2(List<UnavailableCapability> pcapabilities) {
106 if (pcapabilities != null) {
107 for (UnavailableCapability capability : pcapabilities) {
108 this.capabilities.add(capability.getCapability());
116 * @return List<String> with capabilites
118 public List<String> getCapabilities() {
123 * Verify if the namespace is supported
125 * @param qCapability from model
126 * @return true if namespace is supported
128 public boolean isSupportingNamespace(QName qCapability) {
129 String namespace = qCapability.getNamespace().toString();
130 return isSupportingNamespaceAndRevision(namespace, null);
134 * Verify if the namespace is supported
139 public boolean isSupportingNamespace(String namespace) {
140 return isSupportingNamespaceAndRevision(namespace, null);
144 * check if the namespace and its revision are supported by the given capabilities
146 * @param qCapability capability from the model
147 * @return true if supporting the model AND revision<br>
148 * false if revision not available or both not found.
150 public boolean isSupportingNamespaceAndRevision(QName qCapability) {
151 String namespace = qCapability.getNamespace().toString();
152 String revision = getRevisionString(qCapability);
153 return revision == null ? false : isSupportingNamespaceAndRevision(namespace, revision);
157 * check if the namespace and its revision of module are supported by the given capabilities
160 * @return true if supporting the model AND revision<br>
161 * false if revision not available or both not found.
163 public boolean isSupportingNamespaceAndRevision(QNameModule module) {
164 String namespace = module.getNamespace().toString();
165 @NonNull Optional<Revision> revision = module.getRevision();
166 return revision.isEmpty() ? false : isSupportingNamespaceAndRevision(namespace, revision.get().toString());
170 * Provide namespace and its revision as String.
172 * @param qCapability capability from the model
175 public static String getNamespaceAndRevisionAsString(QName qCapability) {
176 StringBuffer res = new StringBuffer();
177 res.append(qCapability.getNamespace().toString());
179 String revisionString = getRevisionString(qCapability);
180 if (revisionString != null) {
182 res.append(revisionString);
185 return res.toString();
190 * @param namespace requested
191 * @param revision request or null for any revision
192 * @return true if existing
194 public boolean isSupportingNamespaceAndRevision(String namespace, @Nullable String revision) {
195 LOG.trace("isSupportingNamespaceAndRevision: Model namespace {}?[revision {}]", namespace, revision);
197 final String nsAndRev = String.format("%s?revision=%s", namespace, revision);
198 for (String capability : capabilities) {
199 //if (capability.contains(namespace) && (revision == null || capability.contains(revision))) {
200 if (capability.contains(revision != null ? nsAndRev : namespace)) {
201 LOG.trace("Verify true with: {}", capability);
204 LOG.trace("Verify false with: {}", capability);
211 * Provide revision as String from QName, considering older formats.
213 * @param qCapability that specifies the revision
214 * @return String with revisiondate or null
216 private static String getRevisionString(QName qCapability) {
217 Object revisionObject = qCapability.getRevision();
218 String revision = null;
219 if (revisionObject instanceof Optional) {
220 if (((Optional<?>) revisionObject).isPresent()) {
221 revisionObject = ((Optional<?>) revisionObject).get();
222 LOG.debug("Unwrapp Optional: {}", revisionObject != null ? revisionObject.getClass() : null);
225 if (revisionObject == null) {
227 } else if (revisionObject instanceof String) {
228 revision = (String) revisionObject;
229 } else if (revisionObject instanceof Date) {
230 revision = formatter.format((Date) revisionObject);
232 revision = revisionObject.toString();
233 LOG.debug("Revision number type not supported. Use toString().String:{} Class:{} ", revisionObject,
234 revisionObject.getClass().getName());
240 * Get revision of first entry of related capability
242 * @param qCapability that specifies the namespace
243 * @return String with date or
245 public String getRevisionForNamespace(QName qCapability) {
246 String namespace = qCapability.getNamespace().toString();
247 for (String capability : capabilities) {
248 if (capability.contains(namespace)) {
249 Optional<Revision> revisionOpt = QName.create(capability).getRevision();
250 if (revisionOpt.isPresent()) {
251 return revisionOpt.get().toString();
259 * Verify if QName namespace is supported by capabilities
261 * @param revision result of getRevisionForNamespace()
262 * @return true if namespace is supported.
264 static public boolean isNamespaceSupported(String revision) {
265 return !UNSUPPORTED.equals(revision);
269 public String toString() {
270 return "Capabilities [capabilities=" + capabilities + "]";