src/org/openmeetings/app/sip/xmlrpc/test/OpenXgXmlWriter.java - openmeetings - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you under the Apache License, Version 2.0 (the
  * "License") +  you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
  *
  *   http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  * KIND, either express or implied.  See the License for the
  * specific language governing permissions and limitations
  * under the License.
  */
 package org.openmeetings.app.sip.xmlrpc.test;


 import java.io.File;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.io.Writer;
 import java.util.HashMap;
 import java.util.Map;

 import javax.xml.XMLConstants;

 import org.apache.ws.commons.serialize.XMLWriter;
 import org.openmeetings.app.OpenmeetingsVariables;
 import org.red5.logging.Red5LoggerFactory;
 import org.slf4j.Logger;
 import org.xml.sax.Attributes;
 import org.xml.sax.Locator;
 import org.xml.sax.SAXException;

 public class OpenXgXmlWriter implements XMLWriter {

 	private static final Logger log = Red5LoggerFactory.getLogger(OpenXgXmlWriter.class, OpenmeetingsVariables.webAppRootKey);

 	private static final int STATE_OUTSIDE = 0;
 	private static final int STATE_IN_START_ELEMENT = 1;
 	private static final int STATE_IN_ELEMENT = 2;

 	private String encoding, indentString, lineFeed;
 	private Writer w;

 	private Writer debugw;

 	private Locator l;
 	private Map<String, String> delayedPrefixes;
 	int curIndent = 0;
 	private int state;
 	private boolean declarating, indenting, flushing;


 	public void setEncoding(String pEncoding) { encoding = pEncoding; }
 	public String getEncoding() { return encoding; }
 	public void setDeclarating(boolean pDeclarating) { declarating = pDeclarating; }
 	public boolean isDeclarating() { return declarating; }
 	public void setIndenting(boolean pIndenting) { indenting = pIndenting; }
 	public boolean isIndenting() { return indenting; }
 	public void setIndentString(String pIndentString) { indentString = pIndentString; }
 	public String getIndentString() { return indentString; }
 	public void setLineFeed(String pLineFeed) { lineFeed = pLineFeed; }
 	public String getLineFeed() { return lineFeed; }
 	public void setFlushing(boolean pFlushing) { flushing = pFlushing; }
 	public boolean isFlushing() { return flushing; }

 	/** <p>Sets the JaxbXMLSerializers Writer.</p>
 	 */
 	public void setWriter(Writer pWriter) {

 		File file = new File("test.xml");
 		//w = pWriter;
 		try {
 			w = new FileWriter(file);
 		} catch (IOException e) {
 			log.error("[setWriter]",e);
 		}
 		debugw = pWriter;
 	}

 	/** <p>Returns the JaxbXMLSerializers Writer.</p>
 	 */
 	public Writer getWriter() {
 		//return w;
 		return debugw;
 	}

 	/** Sets the locator.
 	 *
 	 * @param pLocator A locator for use in case of errors
 	 * @see #getDocumentLocator
 	 */
 	public void setDocumentLocator(Locator pLocator) { l = pLocator; }

 	/** Returns the locator
 	 * @return A locator previously set with setDocumentLocator or null.
 	 * @see #setDocumentLocator
 	 */
 	public Locator getDocumentLocator() { return l; }

 	/**
 	 * <p>Starts use of a namespace prefix.</p>
 	 *
 	 * @param namespaceURI The namespace URI
 	 * @param prefix The prefix
 	 * @throws SAXException Not actually thrown, just for compliance to the interface specification.
 	 */
 	public void startPrefixMapping(String prefix, String namespaceURI)
 	throws SAXException {
 		if (delayedPrefixes == null) {
 			delayedPrefixes = new HashMap<String, String>();
 		}
 		if ("".equals(prefix)) {
 			if (namespaceURI.equals(prefix)) {
 				return;
 			}
 			prefix = XMLConstants.XMLNS_ATTRIBUTE;
 		} else {
 			prefix = XMLConstants.XMLNS_ATTRIBUTE + ":" + prefix;
 		}
 		delayedPrefixes.put(prefix, namespaceURI);
 	}

 	/** <p>Terminates use of a namespace prefix.</p>
 	 *
 	 * @param prefix The prefix being abandoned.
 	 * @throws SAXException Not actually thrown, just for compliance to the interface specification.
 	 */
 	public void endPrefixMapping(String prefix) throws SAXException {
 		if (delayedPrefixes != null) {
 			if ("".equals(prefix)) {
 				prefix = XMLConstants.XMLNS_ATTRIBUTE;
 			} else {
 				prefix = XMLConstants.XMLNS_ATTRIBUTE + ":" + prefix;
 			}
 			delayedPrefixes.remove(prefix);
 		}
 	}

 	/** <p>Starts a document.</p>
 	 * @throws SAXException Not actually thrown, just for compliance to the interface specification.
 	 */
 	public void startDocument() throws SAXException {
 		if (delayedPrefixes != null) {
 			delayedPrefixes.clear();
 		}
 		state = STATE_OUTSIDE;
 		curIndent = 0;
 		if (isDeclarating()  &&  w != null) {
 			try {
 				w.write("<?xml version=\"1.0\"");
 				String enc = getEncoding();
 				if (enc != null) {
 					w.write(" encoding=\"");
 					w.write(enc);
 					w.write("\"");
 				}
 				w.write("?>");
 				if (isIndenting()) {
 					String lf = getLineFeed();
 					if (lf != null) {
 						w.write(lf);
 					}
 				}
 			} catch (IOException e) {
 				throw new SAXException("Failed to write XML declaration: " + e.getMessage(), e);
 			}
 		}
 	}

 	/** <p>This method finishs the handlers action. After calling endDocument you
 	 * may start a new action by calling startDocument again.</p>
 	 *
 	 * @throws SAXException Not actually thrown, just for compliance to the
 	 *   interface specification.
 	 */
 	public void endDocument() throws SAXException {
 		if (isFlushing()  &&  w != null) {
 			try {

 				debugw.write("");

 				log.debug(":: endDocument ::");
 				log.debug(":: endDocument ::" +w.toString());

 				debugw.flush();

 				w.flush();
 			} catch (IOException e) {
 				throw new SAXException("Failed to flush target writer: " + e.getMessage(), e);
 			}
 		}
 	}

 	/** Calls the character method with the same arguments.
 	 * @param ch A string of whitespace characters being inserted into the document.
 	 * @param start The index of the first character.
 	 * @param length The number of characters.
 	 * @throws SAXException Thrown in case of an IOException.
 	 */
 	public void ignorableWhitespace(char[] ch, int start, int length)
 	throws SAXException {
 		characters(ch, start, length);
 	}

 	private void stopTerminator() throws java.io.IOException {
 		if (state == STATE_IN_START_ELEMENT) {
 			if (w != null) {
 				w.write('>');
 			}
 			state = STATE_IN_ELEMENT;
 		}
 	}

 	/** Inserts a string of characters into the document.
 	 * @param ch The characters being inserted. A substring, to be precise.
 	 * @param start Index of the first character
 	 * @param length Number of characters being inserted
 	 * @throws SAXException Thrown in case of an IOException
 	 */
 	public void characters(char[] ch, int start, int length) throws SAXException {
 		try {
 			stopTerminator();
 			if (w == null) return;
 			int end = start+length;
 			for (int i = start;  i < end;  i++) {
 				char c = ch[i];
 				switch (c) {
 				case '&':  w.write("&amp;"); break;
 				case '<':  w.write("&lt;");  break;
 				case '>':  w.write("&gt;");  break;
 				case '\n':
 				case '\r':
 				case '\t':
 					w.write(c); break;
 				default:
 					if (canEncode(c)) {
 						w.write(c);
 					} else {
 						w.write("&#");
 						w.write(Integer.toString(c));
 						w.write(";");
 					}
 				break;
 				}
 			}
 		} catch (IOException e) {
 			throw new SAXException(e);
 		}
 	}

 	public boolean canEncode(char c) {
 		return c == '\n'  ||  (c >= ' '  &&  c < 0x7f);
 	}


 	/** <p>Terminates an element.</p>
 	 *
 	 * @param namespaceURI The namespace URI, if any, or null
 	 * @param localName The local name, without prefix, or null
 	 * @param qName The qualified name, including a prefix, or null
 	 * @throws SAXException Thrown in case of an IOException.
 	 */
 	public void endElement(String namespaceURI, String localName, String qName)
 			throws SAXException {
 		if (isIndenting()) {
 			--curIndent;
 		}
 		if (w != null) {
 			try {
 				if (state == STATE_IN_START_ELEMENT) {
 					w.write("/>");
 					state = STATE_OUTSIDE;
 				} else {
 					if (state == STATE_OUTSIDE) {
 						indentMe();
 					}
 					w.write("</");
 					w.write(qName);
 					w.write('>');
 				}
 				state = STATE_OUTSIDE;
 			} catch (java.io.IOException e) {
 				throw new SAXException(e);
 			}
 		}
 	}

 	private void indentMe() throws java.io.IOException {
 		if (w != null) {
 			if (isIndenting()) {
 				String s = getLineFeed();
 				if (s != null) {
 					w.write(s);
 				}
 				s = getIndentString();
 				if (s != null) {
 					for (int i = 0;  i < curIndent;  i++) {
 						w.write(s);
 					}
 				}
 			}
 		}
 	}

 	private void writeCData(String v) throws java.io.IOException {
 		int len = v.length();
 		for (int j = 0;  j < len;  j++) {
 			char c = v.charAt(j);
 			switch (c) {
 			case '&':  w.write("&amp;");  break;
 			case '<':  w.write("&lt;");   break;
 			case '>':  w.write("&gt;");   break;
 			case '\'': w.write("&apos;"); break;
 			case '"':  w.write("&quot;"); break;
 			default:
 				if (canEncode(c)) {
 					w.write(c);
 				} else {
 					w.write("&#");
 					w.write(Integer.toString(c));
 					w.write(';');
 				}
 			break;
 			}
 		}
 	}

 	/** Starts a new element.
 	 *
 	 * @param namespaceURI The namespace URI, if any, or null
 	 * @param localName The local name, without prefix, or null
 	 * @param qName The qualified name, including a prefix, or null
 	 * @param attr The element attributes
 	 * @throws SAXException Thrown in case of an IOException.
 	 */
 	public void startElement(String namespaceURI, String localName, String qName,
 			Attributes attr) throws SAXException {
 		try {
 			stopTerminator();
 			if (isIndenting()) {
 				if (curIndent > 0) {
 					indentMe();
 				}
 				curIndent++;
 			}

 			if (w != null) {
 				w.write('<');
 				w.write(qName);
 				if (attr != null) {
 					for (int i = attr.getLength();  i > 0;) {
 						w.write(' ');
 						String name = attr.getQName(--i);
 						w.write(name);
 						if (delayedPrefixes != null) {
 							delayedPrefixes.remove(name);
 						}
 						w.write("=\"");
 						writeCData(attr.getValue(i));
 						w.write('"');
 					}
 				}
 				if (delayedPrefixes != null  &&  delayedPrefixes.size() > 0) {
 					for (Map.Entry<String, String> entry : delayedPrefixes.entrySet()) {
 						w.write(' ');
 						w.write(entry.getKey());
 						w.write("=\"");
 						w.write(entry.getValue());
 						w.write('"');
 					}
 					delayedPrefixes.clear();
 				}
 			}
 			state = STATE_IN_START_ELEMENT;
 		} catch (java.io.IOException e) {
 			throw new SAXException(e);
 		}
 	}

 	/** Not actually implemented, because I don't know how to skip entities.
 	 *
 	 * @param ent The entity being skipped.
 	 * @throws SAXException Not actually thrown, just for compliance to the interface specification.
 	 */
 	public void skippedEntity(String ent) throws SAXException {
 		throw new SAXException("Don't know how to skip entities");
 	}

 	/** Inserts a processing instruction.
 	 *
 	 * @param target The PI target
 	 * @param data The PI data
 	 * @throws SAXException Thrown in case of an IOException
 	 */
 	public void processingInstruction(String target, String data)
 	throws SAXException {
 		try {
 			stopTerminator();
 			if (w != null) {
 				w.write("<?");
 				w.write(target);
 				w.write(' ');
 				w.write(data);
 				w.write("?>");
 			}
 		} catch (java.io.IOException e) {
 			throw new SAXException(e);
 		}
 	}
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you under the Apache License, Version 2.0 (the
	* "License") + you may not use this file except in compliance
	* with the License. You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing,
	* software distributed under the License is distributed on an
	* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
	* KIND, either express or implied. See the License for the
	* specific language governing permissions and limitations
	* under the License.
	*/
	package org.openmeetings.app.sip.xmlrpc.test;


	import java.io.File;
	import java.io.FileWriter;
	import java.io.IOException;
	import java.io.Writer;
	import java.util.HashMap;
	import java.util.Map;

	import javax.xml.XMLConstants;

	import org.apache.ws.commons.serialize.XMLWriter;
	import org.openmeetings.app.OpenmeetingsVariables;
	import org.red5.logging.Red5LoggerFactory;
	import org.slf4j.Logger;
	import org.xml.sax.Attributes;
	import org.xml.sax.Locator;
	import org.xml.sax.SAXException;

	public class OpenXgXmlWriter implements XMLWriter {

	private static final Logger log = Red5LoggerFactory.getLogger(OpenXgXmlWriter.class, OpenmeetingsVariables.webAppRootKey);

	private static final int STATE_OUTSIDE = 0;
	private static final int STATE_IN_START_ELEMENT = 1;
	private static final int STATE_IN_ELEMENT = 2;

	private String encoding, indentString, lineFeed;
	private Writer w;

	private Writer debugw;

	private Locator l;
	private Map<String, String> delayedPrefixes;
	int curIndent = 0;
	private int state;
	private boolean declarating, indenting, flushing;


	public void setEncoding(String pEncoding) { encoding = pEncoding; }
	public String getEncoding() { return encoding; }
	public void setDeclarating(boolean pDeclarating) { declarating = pDeclarating; }
	public boolean isDeclarating() { return declarating; }
	public void setIndenting(boolean pIndenting) { indenting = pIndenting; }
	public boolean isIndenting() { return indenting; }
	public void setIndentString(String pIndentString) { indentString = pIndentString; }
	public String getIndentString() { return indentString; }
	public void setLineFeed(String pLineFeed) { lineFeed = pLineFeed; }
	public String getLineFeed() { return lineFeed; }
	public void setFlushing(boolean pFlushing) { flushing = pFlushing; }
	public boolean isFlushing() { return flushing; }

	/** <p>Sets the JaxbXMLSerializers Writer.</p>
	*/
	public void setWriter(Writer pWriter) {

	File file = new File("test.xml");
	//w = pWriter;
	try {
	w = new FileWriter(file);
	} catch (IOException e) {
	log.error("[setWriter]",e);
	}
	debugw = pWriter;
	}

	/** <p>Returns the JaxbXMLSerializers Writer.</p>
	*/
	public Writer getWriter() {
	//return w;
	return debugw;
	}

	/** Sets the locator.
	*
	* @param pLocator A locator for use in case of errors
	* @see #getDocumentLocator
	*/
	public void setDocumentLocator(Locator pLocator) { l = pLocator; }

	/** Returns the locator
	* @return A locator previously set with setDocumentLocator or null.
	* @see #setDocumentLocator
	*/
	public Locator getDocumentLocator() { return l; }

	/**
	* <p>Starts use of a namespace prefix.</p>
	*
	* @param namespaceURI The namespace URI
	* @param prefix The prefix
	* @throws SAXException Not actually thrown, just for compliance to the interface specification.
	*/
	public void startPrefixMapping(String prefix, String namespaceURI)
	throws SAXException {
	if (delayedPrefixes == null) {
	delayedPrefixes = new HashMap<String, String>();
	}
	if ("".equals(prefix)) {
	if (namespaceURI.equals(prefix)) {
	return;
	}
	prefix = XMLConstants.XMLNS_ATTRIBUTE;
	} else {
	prefix = XMLConstants.XMLNS_ATTRIBUTE + ":" + prefix;
	}
	delayedPrefixes.put(prefix, namespaceURI);
	}

	/** <p>Terminates use of a namespace prefix.</p>
	*
	* @param prefix The prefix being abandoned.
	* @throws SAXException Not actually thrown, just for compliance to the interface specification.
	*/
	public void endPrefixMapping(String prefix) throws SAXException {
	if (delayedPrefixes != null) {
	if ("".equals(prefix)) {
	prefix = XMLConstants.XMLNS_ATTRIBUTE;
	} else {
	prefix = XMLConstants.XMLNS_ATTRIBUTE + ":" + prefix;
	}
	delayedPrefixes.remove(prefix);
	}
	}

	/** <p>Starts a document.</p>
	* @throws SAXException Not actually thrown, just for compliance to the interface specification.
	*/
	public void startDocument() throws SAXException {
	if (delayedPrefixes != null) {
	delayedPrefixes.clear();
	}
	state = STATE_OUTSIDE;
	curIndent = 0;
	if (isDeclarating() && w != null) {
	try {
	w.write("<?xml version=\"1.0\"");
	String enc = getEncoding();
	if (enc != null) {
	w.write(" encoding=\"");
	w.write(enc);
	w.write("\"");
	}
	w.write("?>");
	if (isIndenting()) {
	String lf = getLineFeed();
	if (lf != null) {
	w.write(lf);
	}
	}
	} catch (IOException e) {
	throw new SAXException("Failed to write XML declaration: " + e.getMessage(), e);
	}
	}
	}

	/** <p>This method finishs the handlers action. After calling endDocument you
	* may start a new action by calling startDocument again.</p>
	*
	* @throws SAXException Not actually thrown, just for compliance to the
	* interface specification.
	*/
	public void endDocument() throws SAXException {
	if (isFlushing() && w != null) {
	try {

	debugw.write("");

	log.debug(":: endDocument ::");
	log.debug(":: endDocument ::" +w.toString());

	debugw.flush();

	w.flush();
	} catch (IOException e) {
	throw new SAXException("Failed to flush target writer: " + e.getMessage(), e);
	}
	}
	}

	/** Calls the character method with the same arguments.
	* @param ch A string of whitespace characters being inserted into the document.
	* @param start The index of the first character.
	* @param length The number of characters.
	* @throws SAXException Thrown in case of an IOException.
	*/
	public void ignorableWhitespace(char[] ch, int start, int length)
	throws SAXException {
	characters(ch, start, length);
	}

	private void stopTerminator() throws java.io.IOException {
	if (state == STATE_IN_START_ELEMENT) {
	if (w != null) {
	w.write('>');
	}
	state = STATE_IN_ELEMENT;
	}
	}

	/** Inserts a string of characters into the document.
	* @param ch The characters being inserted. A substring, to be precise.
	* @param start Index of the first character
	* @param length Number of characters being inserted
	* @throws SAXException Thrown in case of an IOException
	*/
	public void characters(char[] ch, int start, int length) throws SAXException {
	try {
	stopTerminator();
	if (w == null) return;
	int end = start+length;
	for (int i = start; i < end; i++) {
	char c = ch[i];
	switch (c) {
	case '&': w.write("&"); break;
	case '<': w.write("<"); break;
	case '>': w.write(">"); break;
	case '\n':
	case '\r':
	case '\t':
	w.write(c); break;
	default:
	if (canEncode(c)) {
	w.write(c);
	} else {
	w.write("&#");
	w.write(Integer.toString(c));
	w.write(";");
	}
	break;
	}
	}
	} catch (IOException e) {
	throw new SAXException(e);
	}
	}

	public boolean canEncode(char c) {
	return c == '\n' \|\| (c >= ' ' && c < 0x7f);
	}


	/** <p>Terminates an element.</p>
	*
	* @param namespaceURI The namespace URI, if any, or null
	* @param localName The local name, without prefix, or null
	* @param qName The qualified name, including a prefix, or null
	* @throws SAXException Thrown in case of an IOException.
	*/
	public void endElement(String namespaceURI, String localName, String qName)
	throws SAXException {
	if (isIndenting()) {
	--curIndent;
	}
	if (w != null) {
	try {
	if (state == STATE_IN_START_ELEMENT) {
	w.write("/>");
	state = STATE_OUTSIDE;
	} else {
	if (state == STATE_OUTSIDE) {
	indentMe();
	}
	w.write("</");
	w.write(qName);
	w.write('>');
	}
	state = STATE_OUTSIDE;
	} catch (java.io.IOException e) {
	throw new SAXException(e);
	}
	}
	}

	private void indentMe() throws java.io.IOException {
	if (w != null) {
	if (isIndenting()) {
	String s = getLineFeed();
	if (s != null) {
	w.write(s);
	}
	s = getIndentString();
	if (s != null) {
	for (int i = 0; i < curIndent; i++) {
	w.write(s);
	}
	}
	}
	}
	}

	private void writeCData(String v) throws java.io.IOException {
	int len = v.length();
	for (int j = 0; j < len; j++) {
	char c = v.charAt(j);
	switch (c) {
	case '&': w.write("&"); break;
	case '<': w.write("<"); break;
	case '>': w.write(">"); break;
	case '\'': w.write("'"); break;
	case '"': w.write("""); break;
	default:
	if (canEncode(c)) {
	w.write(c);
	} else {
	w.write("&#");
	w.write(Integer.toString(c));
	w.write(';');
	}
	break;
	}
	}
	}

	/** Starts a new element.
	*
	* @param namespaceURI The namespace URI, if any, or null
	* @param localName The local name, without prefix, or null
	* @param qName The qualified name, including a prefix, or null
	* @param attr The element attributes
	* @throws SAXException Thrown in case of an IOException.
	*/
	public void startElement(String namespaceURI, String localName, String qName,
	Attributes attr) throws SAXException {
	try {
	stopTerminator();
	if (isIndenting()) {
	if (curIndent > 0) {
	indentMe();
	}
	curIndent++;
	}

	if (w != null) {
	w.write('<');
	w.write(qName);
	if (attr != null) {
	for (int i = attr.getLength(); i > 0;) {
	w.write(' ');
	String name = attr.getQName(--i);
	w.write(name);
	if (delayedPrefixes != null) {
	delayedPrefixes.remove(name);
	}
	w.write("=\"");
	writeCData(attr.getValue(i));
	w.write('"');
	}
	}
	if (delayedPrefixes != null && delayedPrefixes.size() > 0) {
	for (Map.Entry<String, String> entry : delayedPrefixes.entrySet()) {
	w.write(' ');
	w.write(entry.getKey());
	w.write("=\"");
	w.write(entry.getValue());
	w.write('"');
	}
	delayedPrefixes.clear();
	}
	}
	state = STATE_IN_START_ELEMENT;
	} catch (java.io.IOException e) {
	throw new SAXException(e);
	}
	}

	/** Not actually implemented, because I don't know how to skip entities.
	*
	* @param ent The entity being skipped.
	* @throws SAXException Not actually thrown, just for compliance to the interface specification.
	*/
	public void skippedEntity(String ent) throws SAXException {
	throw new SAXException("Don't know how to skip entities");
	}

	/** Inserts a processing instruction.
	*
	* @param target The PI target
	* @param data The PI data
	* @throws SAXException Thrown in case of an IOException
	*/
	public void processingInstruction(String target, String data)
	throws SAXException {
	try {
	stopTerminator();
	if (w != null) {
	w.write("<?");
	w.write(target);
	w.write(' ');
	w.write(data);
	w.write("?>");
	}
	} catch (java.io.IOException e) {
	throw new SAXException(e);
	}
	}
	}