Added conversion of notification to data DOM.

[yangtools.git] / yang / yang-data-impl / src / main / java / org / opendaylight / yangtools / yang / data / impl / codec / xml / XmlDocumentUtils.java

diff --git a/yang/yang-data-impl/src/main/java/org/opendaylight/yangtools/yang/data/impl/codec/xml/XmlDocumentUtils.java b/yang/yang-data-impl/src/main/java/org/opendaylight/yangtools/yang/data/impl/codec/xml/XmlDocumentUtils.java
index 63fb0a3772586b0dc9b9f4b6c9d5f509297b71c4..6bb6e26001f3b1945fe0cfd51f7843f14c8ab705 100644 (file)
--- a/yang/yang-data-impl/src/main/java/org/opendaylight/yangtools/yang/data/impl/codec/xml/XmlDocumentUtils.java
+++ b/yang/yang-data-impl/src/main/java/org/opendaylight/yangtools/yang/data/impl/codec/xml/XmlDocumentUtils.java
@@ -36,6 +36,7 @@ import org.opendaylight.yangtools.yang.model.api.DataSchemaNode;
 import org.opendaylight.yangtools.yang.model.api.LeafListSchemaNode;
 import org.opendaylight.yangtools.yang.model.api.LeafSchemaNode;
 import org.opendaylight.yangtools.yang.model.api.ListSchemaNode;
+import org.opendaylight.yangtools.yang.model.api.NotificationDefinition;
 import org.opendaylight.yangtools.yang.model.api.SchemaNode;
 import org.opendaylight.yangtools.yang.model.api.TypeDefinition;
 import org.opendaylight.yangtools.yang.model.api.type.IdentityrefTypeDefinition;
@@ -155,10 +156,13 @@ public class XmlDocumentUtils {
                 element.setAttribute("xmlns:" + prefix, value.getNamespace().toString());
                 element.setTextContent(prefix + ":" + value.getLocalName());
             } else {
+                Object value = node.getValue();
                 logger.debug("Value of {}:{} is not instance of QName but is {}", baseType.getQName().getNamespace(), //
                         baseType.getQName().getLocalName(), //
-                        node.getValue().getClass());
-                element.setTextContent(String.valueOf(node.getValue()));
+                        value != null ? value.getClass() : "null");
+                if (value != null) {
+                    element.setTextContent(String.valueOf(value));
+                }
             }
         } else {
             if (node.getValue() != null) {
@@ -345,6 +349,63 @@ public class XmlDocumentUtils {
         });
 
     }
+    
+    /**
+     * Converts XML Document containing notification data from Netconf device to
+     * Data DOM Nodes. <br>
+     * By specification defined in <a
+     * href="http://tools.ietf.org/search/rfc6020#section-7.14">RFC 6020</a>
+     * there are xml elements containing notifications metadata, like eventTime
+     * or root notification element which specifies namespace for which is
+     * notification defined in yang model. Those elements MUST be stripped off
+     * notifications body. This method returns pure notification body which
+     * begins in element which is equal to notifications name defined in
+     * corresponding yang model. Rest of notification metadata are obfuscated,
+     * thus Data DOM contains only pure notification body.
+     * 
+     * @param document
+     *            XML Document containing notification body
+     * @param notifications
+     *            Notifications Definition Schema
+     * @return Data DOM Nodes containing xml notification body definition or
+     *         <code>null</code> if there is no NotificationDefinition with
+     *         Element with equal notification QName defined in XML Document.
+     */
+    public static CompositeNode notificationToDomNodes(final Document document,
+            final Optional<Set<NotificationDefinition>> notifications) {
+        if (notifications.isPresent() && (document != null) && (document.getDocumentElement() != null)) {
+            final NodeList originChildNodes = document.getDocumentElement().getChildNodes();
+
+            for (int i = 0; i < originChildNodes.getLength(); i++) {
+                org.w3c.dom.Node child = originChildNodes.item(i);
+                if (child instanceof Element) {
+                    final Element childElement = (Element) child;
+                    final QName partialQName = qNameFromElement(childElement);
+                    final Optional<NotificationDefinition> notificationDef = findNotification(partialQName,
+                            notifications.get());
+                    if (notificationDef.isPresent()) {
+                        final Set<DataSchemaNode> dataNodes = notificationDef.get().getChildNodes();
+                        final List<Node<?>> domNodes = toDomNodes(childElement,
+                                Optional.<Set<DataSchemaNode>> fromNullable(dataNodes));
+                        return ImmutableCompositeNode.create(partialQName, domNodes);
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
+    private static Optional<NotificationDefinition> findNotification(final QName notifName,
+            final Set<NotificationDefinition> notifications) {
+        if ((notifName != null) && (notifications != null)) {
+            for (final NotificationDefinition notification : notifications) {
+                if ((notification != null) && notifName.isEqualWithoutRevision(notification.getQName())) {
+                    return Optional.<NotificationDefinition>fromNullable(notification);
+                }
+            }
+        }
+        return Optional.<NotificationDefinition>absent();
+    }
 
     private static final <T> List<T> forEachChild(NodeList nodes, Function<Element, Optional<T>> forBody) {
         ImmutableList.Builder<T> ret = ImmutableList.<T> builder();