From 6e273517868e587a4884f41374b224b8020345ea Mon Sep 17 00:00:00 2001 From: lresende Date: Mon, 15 Sep 2008 18:30:56 +0000 Subject: TUSCANY-2538 - Merging changes from trunk to add default processor to handle unknown content in composite files git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@695573 13f79535-47bb-0310-9956-ffa450edef68 --- .../processor/DefaultUnknownElementProcessor.java | 272 +++++++++++++++++++++ .../processor/ExtensibleStAXArtifactProcessor.java | 7 +- 2 files changed, 278 insertions(+), 1 deletion(-) create mode 100644 branches/sca-java-1.3.2/modules/contribution/src/main/java/org/apache/tuscany/sca/contribution/processor/DefaultUnknownElementProcessor.java (limited to 'branches/sca-java-1.3.2/modules/contribution') diff --git a/branches/sca-java-1.3.2/modules/contribution/src/main/java/org/apache/tuscany/sca/contribution/processor/DefaultUnknownElementProcessor.java b/branches/sca-java-1.3.2/modules/contribution/src/main/java/org/apache/tuscany/sca/contribution/processor/DefaultUnknownElementProcessor.java new file mode 100644 index 0000000000..d52a110c05 --- /dev/null +++ b/branches/sca-java-1.3.2/modules/contribution/src/main/java/org/apache/tuscany/sca/contribution/processor/DefaultUnknownElementProcessor.java @@ -0,0 +1,272 @@ +package org.apache.tuscany.sca.contribution.processor; + +import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; +import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; + +import java.util.ArrayList; +import java.util.logging.Level; +import java.util.logging.Logger; + +import javax.xml.namespace.QName; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamReader; +import javax.xml.stream.XMLStreamWriter; + +import org.apache.tuscany.sca.assembly.builder.impl.ProblemImpl; +import org.apache.tuscany.sca.monitor.Monitor; +import org.apache.tuscany.sca.monitor.Problem; +import org.apache.tuscany.sca.monitor.Problem.Severity; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.NamedNodeMap; +import org.w3c.dom.Node; +import org.w3c.dom.traversal.DocumentTraversal; +import org.w3c.dom.traversal.NodeFilter; +import org.w3c.dom.traversal.NodeIterator; +import org.w3c.dom.traversal.TreeWalker; + +public class DefaultUnknownElementProcessor{ + + private Monitor monitor; + private static final Logger logger = Logger.getLogger(DefaultUnknownElementProcessor.class.getName()); + + public DefaultUnknownElementProcessor(Monitor monitor){ + this.monitor = monitor; + } + private DocumentBuilderFactory documentBuilderFactory; + private Document document; + + /** + * Reads the contetns of the unknown elements and generates the DOM + * @param reader + * @param name + * @return + * @throws XMLStreamException + */ + public Object read(XMLStreamReader reader, QName name) throws XMLStreamException{ + + int event = reader.getEventType(); + int level = 0; + ArrayList elementList = new ArrayList(); + document = createDocument(); + while(reader.hasNext()){ + switch(event){ + case START_ELEMENT: + elementList.add(reader.getName().getLocalPart()); + if(level == 0){ + generateDOM(reader,null); + level++; + } + else{ + generateDOM(reader,elementList.get(elementList.size()-2).toString()); + } + + break; + case END_ELEMENT: + elementList.remove(reader.getName().getLocalPart()); + } + if(reader.hasNext()){ + event = reader.next(); + } + + if(event == START_ELEMENT || event == END_ELEMENT){ + if(reader.getName().equals(name)){ + break; + } + } + } + return document; + } + + /** + * Writes unknown portions back to the writer + * @param model + * @param writer + */ + public void write(Object model, XMLStreamWriter writer) { + + if( ! (model instanceof Document)) { + return; + } + + Document doc = (Document)model; + try{ + DocumentTraversal traversal = (DocumentTraversal)doc; + TreeWalker walker = traversal.createTreeWalker(doc.getDocumentElement(),NodeFilter.SHOW_ALL, null, true); + writeDOM(walker,writer); + } + catch(Exception e){ + if (logger.isLoggable(Level.SEVERE)) { + logger.log(Level.SEVERE, "Document not created "); + } + error("Document not created",document,e); + } + } + + /** + * Method to generate the DOM + * @param reader + * @param parent + * @throws Exception + */ + //private void generateDOM(String elementText, String parent) { + private void generateDOM(XMLStreamReader reader, String parent) { + try{ + String elePrefix = reader.getPrefix(); + String eleQName = reader.getLocalName(); + if (elePrefix != null && elePrefix.length() != 0) { + eleQName = elePrefix + ":" + eleQName; + } + + Element element = document.createElementNS(reader.getNamespaceURI(), eleQName); + + int attributeCount = reader.getAttributeCount(); + for(int i = 0;i < attributeCount;i++){ + String ns = reader.getAttributeNamespace(i); + String prefix = reader.getAttributePrefix(i); + String qname = reader.getAttributeLocalName(i); + String value = reader.getAttributeValue(i); + if (prefix != null && prefix.length() != 0) { + qname = prefix + ":" + qname; + } + element.setAttributeNS(ns,qname,value); + } + if(parent == null){ + if(document != null){ + document.appendChild(element); + } + else{ + if (logger.isLoggable(Level.SEVERE)) { + logger.log(Level.SEVERE, "Document not created "); + } + error("Document not created",document,element); + } + } + else{ + Node parentNode = getParentNode(document,parent); + if(parentNode != null){ + parentNode.appendChild(element); + } + else{ + if (logger.isLoggable(Level.SEVERE)) { + logger.log(Level.SEVERE, "Parent node not found"); + } + error("Parent node not found",document,parentNode.getNodeName()); + } + } + } + catch(Exception e){ + e.printStackTrace(); + if (logger.isLoggable(Level.SEVERE)) { + logger.log(Level.SEVERE, "Document not created "); + } + error("Document not created",document,e); + } + } + + /** + * Method to create an empty document + * @return + */ + private Document createDocument() { + try { + if (documentBuilderFactory == null) { + documentBuilderFactory = DocumentBuilderFactory.newInstance(); + } + document = documentBuilderFactory.newDocumentBuilder().newDocument(); + return document; + } catch (ParserConfigurationException e) { + e.printStackTrace(); + } + return null; + } + + /** + * Method to traverse the DOM structure and write the elements + * @param walker + * @param writer + * @throws XMLStreamException + */ + private void writeDOM(TreeWalker walker,XMLStreamWriter writer) throws XMLStreamException { + + Node parent = walker.getCurrentNode(); + + writer.writeStartElement(parent.getPrefix(), parent.getLocalName(), parent.getNamespaceURI()); + + NamedNodeMap attributes = parent.getAttributes(); + + for(int i = 0;i processor = (StAXArtifactProcessor)processors.getProcessor(name); if (processor == null) { + DefaultUnknownElementProcessor unknownElementProcessor = new DefaultUnknownElementProcessor(monitor); Location location = source.getLocation(); if (logger.isLoggable(Level.WARNING)) { logger.warning("Element " + name + " cannot be processed. (" + location + ")"); } warning("ElementCannotBeProcessed", processors, name, location); - return null; + //return null; + return unknownElementProcessor.read(source,name); } return processor.read(source); } @@ -152,6 +155,8 @@ public class ExtensibleStAXArtifactProcessor if (processor != null) { processor.write(model, outputSource); } else { + DefaultUnknownElementProcessor unknownElementProcessor = new DefaultUnknownElementProcessor(monitor); + unknownElementProcessor.write(model,outputSource); if (logger.isLoggable(Level.WARNING)) { logger.warning("No StAX processor is configured to handle " + model.getClass()); } -- cgit v1.2.3