package org.opendaylight.controller.sal.rest.impl; import java.util.Set; import javax.activation.UnsupportedDataTypeException; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; import javax.xml.parsers.ParserConfigurationException; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.data.api.CompositeNode; import org.opendaylight.yangtools.yang.data.api.Node; import org.opendaylight.yangtools.yang.data.api.SimpleNode; import org.opendaylight.yangtools.yang.model.api.ChoiceCaseNode; import org.opendaylight.yangtools.yang.model.api.ChoiceNode; import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode; import org.opendaylight.yangtools.yang.model.api.DataNodeContainer; 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.TypeDefinition; import org.opendaylight.yangtools.yang.model.api.YangNode; import org.opendaylight.yangtools.yang.model.api.type.IdentityrefTypeDefinition; import org.w3c.dom.Document; import org.w3c.dom.Element; import com.google.common.base.Preconditions; public class XmlMapper { public Document write(CompositeNode data, DataNodeContainer schema) throws UnsupportedDataTypeException { Preconditions.checkNotNull(data); Preconditions.checkNotNull(schema); DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance(); Document doc = null; try { DocumentBuilder bob = dbf.newDocumentBuilder(); doc = bob.newDocument(); } catch (ParserConfigurationException e) { return null; } if (schema instanceof ContainerSchemaNode || schema instanceof ListSchemaNode) { doc.appendChild(translateToXmlAndReturnRootElement(doc, data, schema)); return doc; } else { throw new UnsupportedDataTypeException( "Schema can be ContainerSchemaNode or ListSchemaNode. Other types are not supported yet."); } } private Element translateToXmlAndReturnRootElement(Document doc, Node data, YangNode schema) throws UnsupportedDataTypeException { QName dataType = data.getNodeType(); Element itemEl = doc.createElementNS(dataType.getNamespace().toString(), dataType.getLocalName()); if (data instanceof SimpleNode) { if (schema instanceof LeafListSchemaNode) { writeValueOfNodeByType(itemEl, (SimpleNode) data, ((LeafListSchemaNode) schema).getType()); } else if (schema instanceof LeafSchemaNode) { writeValueOfNodeByType(itemEl, (SimpleNode) data, ((LeafSchemaNode) schema).getType()); } else { Object value = data.getValue(); if (value != null) { itemEl.setTextContent(String.valueOf(value)); } } } else { // CompositeNode for (Node child : ((CompositeNode) data).getChildren()) { DataSchemaNode childSchema = findFirstSchemaForNode(child, ((DataNodeContainer) schema).getChildNodes()); if (childSchema == null) { throw new UnsupportedDataTypeException("Probably the data node \"" + child.getNodeType().getLocalName() + "\" is not conform to schema"); } itemEl.appendChild(translateToXmlAndReturnRootElement(doc, child, childSchema)); } } return itemEl; } private void writeValueOfNodeByType(Element element, SimpleNode node, TypeDefinition type) { TypeDefinition baseType = resolveBaseTypeFrom(type); if (baseType instanceof IdentityrefTypeDefinition && node.getValue() instanceof QName) { QName value = (QName) node.getValue(); element.setAttribute("xmlns:x", value.getNamespace().toString()); element.setTextContent("x:" + value.getLocalName()); } else { Object value = node.getValue(); if (value != null) { element.setTextContent(String.valueOf(value)); } } } private DataSchemaNode findFirstSchemaForNode(Node node, Set dataSchemaNode) { for (DataSchemaNode dsn : dataSchemaNode) { if (node.getNodeType().getLocalName().equals(dsn.getQName().getLocalName())) { return dsn; } else if (dsn instanceof ChoiceNode) { for (ChoiceCaseNode choiceCase : ((ChoiceNode) dsn).getCases()) { DataSchemaNode foundDsn = findFirstSchemaForNode(node, choiceCase.getChildNodes()); if (foundDsn != null) { return foundDsn; } } } } return null; } private TypeDefinition resolveBaseTypeFrom(TypeDefinition type) { return type.getBaseType() != null ? resolveBaseTypeFrom(type.getBaseType()) : type; } }