mosgi/jmx.httpconnector/src/main/java/org/apache/felix/mosgi/jmx/httpconnector/mx4j/tools/adaptor/http/DefaultProcessor.java - felix - 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.apache.felix.mosgi.jmx.httpconnector.mx4j.tools.adaptor.http;

 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.PrintWriter;

 import org.w3c.dom.Attr;
 import org.w3c.dom.Document;
 import org.w3c.dom.NamedNodeMap;
 import org.w3c.dom.Node;
 import org.w3c.dom.NodeList;

 import org.osgi.framework.ServiceReference;
 import org.osgi.service.log.LogService;

 import org.apache.felix.mosgi.jmx.httpconnector.HttpConnectorActivator;


 /**
  * DefaultPostProcessor doesn't alter the result, just publising the xml file
  *
  * @author    <a href="mailto:tibu@users.sourceforge.net">Carlos Quiroz</a>
  * @version   $Revision: 1.1.1.1 $
  */

 public class DefaultProcessor implements ProcessorMBean
 {

 	private final static String ENCODING = "UTF-8";
 	private boolean canonical = false;
 	public String getName()
 	{
 		return "Default XML Processor";
 	}

 	public void writeResponse(HttpOutputStream out, HttpInputStream in, Document document)
 			throws IOException
 	{
 		out.setCode(HttpConstants.STATUS_OKAY);
 		out.setHeader("Content-Type", "text/xml");
 		out.sendHeaders();
 		print(new PrintWriter(out), document);
 		ByteArrayOutputStream o = new ByteArrayOutputStream();
 		print(new PrintWriter(o), document);
 		DefaultProcessor.log(LogService.LOG_INFO,new String(o.toByteArray()),null);
 	}

 	public void writeError(HttpOutputStream out, HttpInputStream in, Exception e)
 			throws IOException
 	{
 		if (e instanceof HttpException)
 		{
 			out.setCode(((HttpException)e).getCode());
 			out.setHeader("Content-Type", "text/xml");
 			out.sendHeaders();
 			print(new PrintWriter(out), ((HttpException)e).getResponseDoc());
 		}
 	}

 	public String preProcess(String path)
 	{
 		// The only special case. The root is routed to the the server request
 		if (path.equals("/"))
 		{
 			path = "/server";
 		}
 		return path;
 	}

 	public String notFoundElement(String path, HttpOutputStream out, HttpInputStream in)
 			throws IOException, HttpException
 	{
 		// no processing. Unknown elements are not found
 		throw new HttpException(HttpConstants.STATUS_NOT_FOUND, "Path " + path + " not found");
 	}

 	// ripped from Xerces samples
 	protected void print(PrintWriter out, Node node)
 	{
 		// is there anything to do?
 		if (node == null)
 		{
 			return;
 		}
 		int type = node.getNodeType();
 		switch (type)
 		{
 			// print document
 			case Node.DOCUMENT_NODE:
 				{
 					if (!canonical)
 					{
 						out.println("<?xml version=\"1.0\" encoding=\"" + ENCODING + "\"?>");
 					}
 					NodeList children = node.getChildNodes();
 					for (int iChild = 0; iChild < children.getLength(); iChild++)
 					{
 						print(out, children.item(iChild));
 					}
 					out.flush();
 					break;
 				}
 				// print element with attributes
 			case Node.ELEMENT_NODE:
 				{
 					out.print('<');
 					out.print(node.getNodeName());
 					Attr attrs[] = sortAttributes(node.getAttributes());
 					for (int i = 0; i < attrs.length; i++)
 					{
 						Attr attr = attrs[i];
 						out.print(' ');
 						out.print(attr.getNodeName());
 						out.print("=\"");
 						out.print(normalize(attr.getNodeValue()));
 						out.print('"');
 					}
 					out.print('>');
 					NodeList children = node.getChildNodes();
 					if (children != null)
 					{
 						int len = children.getLength();
 						for (int i = 0; i < len; i++)
 						{
 							print(out, children.item(i));
 						}
 					}
 					break;
 				}
 				// handle entity reference nodes
 			case Node.ENTITY_REFERENCE_NODE:
 				{
 					if (canonical)
 					{
 						NodeList children = node.getChildNodes();
 						if (children != null)
 						{
 							int len = children.getLength();
 							for (int i = 0; i < len; i++)
 							{
 								print(out, children.item(i));
 							}
 						}
 					}
 					else
 					{
 						out.print('&');
 						out.print(node.getNodeName());
 						out.print(';');
 					}
 					break;
 				}
 			// print cdata sections
 			case Node.CDATA_SECTION_NODE:
 				{
 					if (canonical)
 					{
 						out.print(normalize(node.getNodeValue()));
 					}
 					else
 					{
 						out.print("<![CDATA[");
 						out.print(node.getNodeValue());
 						out.print("]]>");
 					}
 					break;
 				}
 				// print text
 			case Node.TEXT_NODE:
 				{
 					out.print(normalize(node.getNodeValue()));
 					break;
 				}
 				// print processing instruction
 			case Node.PROCESSING_INSTRUCTION_NODE:
 				{
 					out.print("<?");
 					out.print(node.getNodeName());
 					String data = node.getNodeValue();
 					if (data != null && data.length() > 0)
 					{
 						out.print(' ');
 						out.print(data);
 					}
 					out.println("?>");
 					break;
 				}
 		}
 		if (type == Node.ELEMENT_NODE)
 		{
 			out.print("</");
 			out.print(node.getNodeName());
 			out.print('>');
 		}
 		out.flush();
 	}
 	// print(Node)

 	/**
 	 * Returns a sorted list of attributes.
 	 *
 	 * @param attrs  Description of Parameter
 	 * @return       Description of the Returned Value
 	 * @since
 	 */

 	protected Attr[] sortAttributes(NamedNodeMap attrs)
 	{
 		int len = (attrs != null) ? attrs.getLength() : 0;
 		Attr array[] = new Attr[len];
 		for (int i = 0; i < len; i++)
 		{
 			array[i] = (Attr)attrs.item(i);
 		}
 		for (int i = 0; i < len - 1; i++)
 		{
 			String name = array[i].getNodeName();
 			int index = i;
 			for (int j = i + 1; j < len; j++)
 			{
 				String curName = array[j].getNodeName();
 				if (curName.compareTo(name) < 0)
 				{
 					name = curName;
 					index = j;
 				}
 			}
 			if (index != i)
 			{
 				Attr temp = array[i];
 				array[i] = array[index];
 				array[index] = temp;
 			}
 		}
 		return (array);
 	}

 	/**
 	 * Normalizes the given string.
 	 *
 	 * @param s  Description of Parameter
 	 * @return   Description of the Returned Value
 	 * @since
 	 */

 	protected String normalize(String s)
 	{
 		StringBuffer str = new StringBuffer();
 		int len = (s != null) ? s.length() : 0;
 		for (int i = 0; i < len; i++)
 		{
 			char ch = s.charAt(i);
 			switch (ch)
 			{
 				case '<':
 					{
 						str.append("&lt;");
 						break;
 					}
 				case '>':
 					{
 						str.append("&gt;");
 						break;
 					}
 				case '&':
 					{
 						str.append("&amp;");
 						break;
 					}
 				case '"':
 					{
 						str.append("&quot;");
 						break;
 					}
 				case '\'':
 					{
 						str.append("&apos;");
 						break;
 					}
 				case '\r':
 				case '\n':
 					{
 						if (canonical)
 						{
 							str.append("&#");
 							str.append(Integer.toString(ch));
 							str.append(';');
 							break;
 						}
 					// else, default append char
 					}
 				default:
 					{
 						str.append(ch);
 					}
 			}
 		}
 		return (str.toString());
 	}

   private static void log(int prio, String message, Throwable t){
     if (HttpConnectorActivator.bc!=null){
       ServiceReference logSR=HttpConnectorActivator.bc.getServiceReference(LogService.class.getName());
       if (logSR!=null){
         ((LogService)HttpConnectorActivator.bc.getService(logSR)).log(prio, message, t);
       }else{
         System.out.println("No Log Service");
       }
     }else{
       System.out.println(DefaultProcessor.class.getName()+".log: No bundleContext");
     }
   }
 }
	/*
	* 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.apache.felix.mosgi.jmx.httpconnector.mx4j.tools.adaptor.http;

	import java.io.ByteArrayOutputStream;
	import java.io.IOException;
	import java.io.PrintWriter;

	import org.w3c.dom.Attr;
	import org.w3c.dom.Document;
	import org.w3c.dom.NamedNodeMap;
	import org.w3c.dom.Node;
	import org.w3c.dom.NodeList;

	import org.osgi.framework.ServiceReference;
	import org.osgi.service.log.LogService;

	import org.apache.felix.mosgi.jmx.httpconnector.HttpConnectorActivator;


	/**
	* DefaultPostProcessor doesn't alter the result, just publising the xml file
	*
	* @author <a href="mailto:tibu@users.sourceforge.net">Carlos Quiroz</a>
	* @version $Revision: 1.1.1.1 $
	*/

	public class DefaultProcessor implements ProcessorMBean
	{

	private final static String ENCODING = "UTF-8";
	private boolean canonical = false;
	public String getName()
	{
	return "Default XML Processor";
	}

	public void writeResponse(HttpOutputStream out, HttpInputStream in, Document document)
	throws IOException
	{
	out.setCode(HttpConstants.STATUS_OKAY);
	out.setHeader("Content-Type", "text/xml");
	out.sendHeaders();
	print(new PrintWriter(out), document);
	ByteArrayOutputStream o = new ByteArrayOutputStream();
	print(new PrintWriter(o), document);
	DefaultProcessor.log(LogService.LOG_INFO,new String(o.toByteArray()),null);
	}

	public void writeError(HttpOutputStream out, HttpInputStream in, Exception e)
	throws IOException
	{
	if (e instanceof HttpException)
	{
	out.setCode(((HttpException)e).getCode());
	out.setHeader("Content-Type", "text/xml");
	out.sendHeaders();
	print(new PrintWriter(out), ((HttpException)e).getResponseDoc());
	}
	}

	public String preProcess(String path)
	{
	// The only special case. The root is routed to the the server request
	if (path.equals("/"))
	{
	path = "/server";
	}
	return path;
	}

	public String notFoundElement(String path, HttpOutputStream out, HttpInputStream in)
	throws IOException, HttpException
	{
	// no processing. Unknown elements are not found
	throw new HttpException(HttpConstants.STATUS_NOT_FOUND, "Path " + path + " not found");
	}

	// ripped from Xerces samples
	protected void print(PrintWriter out, Node node)
	{
	// is there anything to do?
	if (node == null)
	{
	return;
	}
	int type = node.getNodeType();
	switch (type)
	{
	// print document
	case Node.DOCUMENT_NODE:
	{
	if (!canonical)
	{
	out.println("<?xml version=\"1.0\" encoding=\"" + ENCODING + "\"?>");
	}
	NodeList children = node.getChildNodes();
	for (int iChild = 0; iChild < children.getLength(); iChild++)
	{
	print(out, children.item(iChild));
	}
	out.flush();
	break;
	}
	// print element with attributes
	case Node.ELEMENT_NODE:
	{
	out.print('<');
	out.print(node.getNodeName());
	Attr attrs[] = sortAttributes(node.getAttributes());
	for (int i = 0; i < attrs.length; i++)
	{
	Attr attr = attrs[i];
	out.print(' ');
	out.print(attr.getNodeName());
	out.print("=\"");
	out.print(normalize(attr.getNodeValue()));
	out.print('"');
	}
	out.print('>');
	NodeList children = node.getChildNodes();
	if (children != null)
	{
	int len = children.getLength();
	for (int i = 0; i < len; i++)
	{
	print(out, children.item(i));
	}
	}
	break;
	}
	// handle entity reference nodes
	case Node.ENTITY_REFERENCE_NODE:
	{
	if (canonical)
	{
	NodeList children = node.getChildNodes();
	if (children != null)
	{
	int len = children.getLength();
	for (int i = 0; i < len; i++)
	{
	print(out, children.item(i));
	}
	}
	}
	else
	{
	out.print('&');
	out.print(node.getNodeName());
	out.print(';');
	}
	break;
	}
	// print cdata sections
	case Node.CDATA_SECTION_NODE:
	{
	if (canonical)
	{
	out.print(normalize(node.getNodeValue()));
	}
	else
	{
	out.print("<![CDATA[");
	out.print(node.getNodeValue());
	out.print("]]>");
	}
	break;
	}
	// print text
	case Node.TEXT_NODE:
	{
	out.print(normalize(node.getNodeValue()));
	break;
	}
	// print processing instruction
	case Node.PROCESSING_INSTRUCTION_NODE:
	{
	out.print("<?");
	out.print(node.getNodeName());
	String data = node.getNodeValue();
	if (data != null && data.length() > 0)
	{
	out.print(' ');
	out.print(data);
	}
	out.println("?>");
	break;
	}
	}
	if (type == Node.ELEMENT_NODE)
	{
	out.print("</");
	out.print(node.getNodeName());
	out.print('>');
	}
	out.flush();
	}
	// print(Node)

	/**
	* Returns a sorted list of attributes.
	*
	* @param attrs Description of Parameter
	* @return Description of the Returned Value
	* @since
	*/

	protected Attr[] sortAttributes(NamedNodeMap attrs)
	{
	int len = (attrs != null) ? attrs.getLength() : 0;
	Attr array[] = new Attr[len];
	for (int i = 0; i < len; i++)
	{
	array[i] = (Attr)attrs.item(i);
	}
	for (int i = 0; i < len - 1; i++)
	{
	String name = array[i].getNodeName();
	int index = i;
	for (int j = i + 1; j < len; j++)
	{
	String curName = array[j].getNodeName();
	if (curName.compareTo(name) < 0)
	{
	name = curName;
	index = j;
	}
	}
	if (index != i)
	{
	Attr temp = array[i];
	array[i] = array[index];
	array[index] = temp;
	}
	}
	return (array);
	}

	/**
	* Normalizes the given string.
	*
	* @param s Description of Parameter
	* @return Description of the Returned Value
	* @since
	*/

	protected String normalize(String s)
	{
	StringBuffer str = new StringBuffer();
	int len = (s != null) ? s.length() : 0;
	for (int i = 0; i < len; i++)
	{
	char ch = s.charAt(i);
	switch (ch)
	{
	case '<':
	{
	str.append("<");
	break;
	}
	case '>':
	{
	str.append(">");
	break;
	}
	case '&':
	{
	str.append("&");
	break;
	}
	case '"':
	{
	str.append(""");
	break;
	}
	case '\'':
	{
	str.append("'");
	break;
	}
	case '\r':
	case '\n':
	{
	if (canonical)
	{
	str.append("&#");
	str.append(Integer.toString(ch));
	str.append(';');
	break;
	}
	// else, default append char
	}
	default:
	{
	str.append(ch);
	}
	}
	}
	return (str.toString());
	}

	private static void log(int prio, String message, Throwable t){
	if (HttpConnectorActivator.bc!=null){
	ServiceReference logSR=HttpConnectorActivator.bc.getServiceReference(LogService.class.getName());
	if (logSR!=null){
	((LogService)HttpConnectorActivator.bc.getService(logSR)).log(prio, message, t);
	}else{
	System.out.println("No Log Service");
	}
	}else{
	System.out.println(DefaultProcessor.class.getName()+".log: No bundleContext");
	}
	}
	}