Decouple config and netconf subsystems.

[controller.git] / opendaylight / config / config-manager-facade-xml / src / main / java / org / opendaylight / controller / config / facade / xml / runtime / InstanceRuntime.java

diff --git a/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/runtime/InstanceRuntime.java b/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/runtime/InstanceRuntime.java
new file mode 100644 (file)
index 0000000..96287c7
--- /dev/null
+++ b/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/runtime/InstanceRuntime.java
@@ -0,0 +1,120 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.controller.config.facade.xml.runtime;
+
+import com.google.common.base.Optional;
+import com.google.common.base.Predicate;
+import com.google.common.collect.Collections2;
+import com.google.common.collect.Sets;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Set;
+import javax.management.ObjectName;
+import org.opendaylight.controller.config.facade.xml.mapping.config.InstanceConfig;
+import org.opendaylight.controller.config.facade.xml.osgi.EnumResolver;
+import org.opendaylight.controller.config.util.xml.XmlUtil;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+
+public class InstanceRuntime {
+
+    /**
+     *
+     */
+    private static final String KEY_ATTRIBUTE_KEY = "key";
+
+    private final InstanceConfig instanceMapping;
+    private final Map<String, InstanceRuntime> childrenMappings;
+    private final Map<String, String> jmxToYangChildRbeMapping;
+
+    public InstanceRuntime(InstanceConfig instanceMapping, Map<String, InstanceRuntime> childrenMappings,
+            Map<String, String> jmxToYangChildRbeMapping) {
+        this.instanceMapping = instanceMapping;
+        this.childrenMappings = childrenMappings;
+        this.jmxToYangChildRbeMapping = jmxToYangChildRbeMapping;
+    }
+
+    /**
+     * Finds all children runtime beans, same properties and values as current
+     * root + any number of additional properties
+     */
+    private Set<ObjectName> findChildren(ObjectName innerRootBean, Set<ObjectName> childRbeOns) {
+        final Map<String, String> wantedProperties = innerRootBean.getKeyPropertyList();
+
+        return Sets.newHashSet(Collections2.filter(childRbeOns, new Predicate<ObjectName>() {
+
+            @Override
+            public boolean apply(ObjectName on) {
+                Map<String, String> localProperties = on.getKeyPropertyList();
+                for (Entry<String, String> propertyEntry : wantedProperties.entrySet()) {
+                    if (!localProperties.containsKey(propertyEntry.getKey())){
+                        return false;
+                    }
+                    if (!localProperties.get(propertyEntry.getKey()).equals(propertyEntry.getValue())){
+                        return false;
+                    }
+                    if (localProperties.size() <= wantedProperties.size()){
+                        return false;
+                    }
+                }
+                return true;
+            }
+        }));
+    }
+
+    /**
+     * Finds next level root runtime beans, beans that have the same properties
+     * as current root + one additional
+     */
+    private Set<ObjectName> getRootBeans(Set<ObjectName> childRbeOns, final String string, final int keyListSize) {
+        return Sets.newHashSet(Collections2.filter(childRbeOns, new Predicate<ObjectName>() {
+
+            @Override
+            public boolean apply(ObjectName on) {
+                if (on.getKeyPropertyList().size() != keyListSize + 1){
+                    return false;
+                }
+                return on.getKeyPropertyList().containsKey(string);
+            }
+        }));
+    }
+
+    public Element toXml(ObjectName rootOn, Set<ObjectName> childRbeOns, Document document, Element parentElement, String namespace, final EnumResolver enumResolver) {
+        return toXml(rootOn, childRbeOns, document, null, parentElement, namespace, enumResolver);
+    }
+
+    public Element toXml(ObjectName rootOn, Set<ObjectName> childRbeOns, Document document, String instanceIndex,
+                         Element parentElement, String namespace, final EnumResolver enumResolver) {
+        Element xml = instanceMapping.toXml(rootOn, namespace, document, parentElement, enumResolver);
+
+        if (instanceIndex != null) {
+            xml.setAttribute(KEY_ATTRIBUTE_KEY, instanceIndex);
+        }
+
+        for (Entry<String, InstanceRuntime> childMappingEntry : childrenMappings.entrySet()) {
+            Set<ObjectName> innerRootBeans = getRootBeans(childRbeOns, childMappingEntry.getKey(), rootOn
+                    .getKeyPropertyList().size());
+
+            for (ObjectName objectName : innerRootBeans) {
+                Set<ObjectName> innerChildRbeOns = findChildren(objectName, childRbeOns);
+                String runtimeInstanceIndex = objectName.getKeyProperty(childMappingEntry.getKey());
+
+                String elementName = jmxToYangChildRbeMapping.get(childMappingEntry.getKey());
+
+                Element innerXml = XmlUtil.createElement(document, elementName, Optional.of(namespace));
+                childMappingEntry.getValue().toXml(objectName, innerChildRbeOns, document,
+                        runtimeInstanceIndex, innerXml, namespace, enumResolver);
+                xml.appendChild(innerXml);
+            }
+        }
+
+        return xml;
+    }
+
+}