WebSVN – XServices – Diff – /xservices/trunk/src/java/net/brutex/xservices/ws/impl/XmlServiceImpl.java

 import java.io.UnsupportedEncodingException;
 import java.nio.charset.Charset;
 import java.nio.charset.IllegalCharsetNameException;
 import java.util.Iterator;
 import java.util.List;
-import java.util.StringTokenizer;
 import javax.jws.WebService;
-import javax.ws.rs.NotAuthorizedException;
 import javax.xml.namespace.QName;
 import javax.xml.stream.XMLOutputFactory;
 import javax.xml.stream.XMLStreamException;
-import javax.xml.stream.XMLStreamReader;
 import javax.xml.stream.XMLStreamWriter;
 import net.brutex.xservices.security.DirectoryPermission;
 import net.brutex.xservices.types.AttributeType;
 import net.brutex.xservices.types.NamespaceListType;
 import net.brutex.xservices.types.NamespaceType;
 import net.brutex.xservices.types.StringSplitType;
 import org.apache.axiom.om.OMNode;
 import org.apache.axiom.om.OMProcessingInstruction;
 import org.apache.axiom.om.OMText;
 import org.apache.axiom.om.OMXMLBuilderFactory;
 import org.apache.axiom.om.xpath.AXIOMXPath;
-import org.apache.log4j.Logger;
+import org.apache.logging.log4j.LogManager;
-import org.apache.shiro.SecurityUtils;
+import org.apache.logging.log4j.Logger;
-import org.apache.shiro.authz.UnauthorizedException;
 import org.apache.shiro.authz.annotation.RequiresPermissions;
 import org.jaxen.JaxenException;
 import org.jaxen.SimpleNamespaceContext;
 /**
  * @author Brian Rosenberger, bru(at)brutex.de
+ *
  */
 @WebService(targetNamespace = "http://ws.xservices.brutex.net", endpointInterface = "net.brutex.xservices.ws.XmlService", serviceName = "XmlService")
 public class XmlServiceImpl implements XmlService {
-	final Logger logger = Logger.getLogger(XmlServiceImpl.class);
+	private static final Logger logger = LogManager.getLogger();
 	public String insertNodesFromFile(FileResource res, NamespaceListType nsList, String xpath, String xmlFragment)
-	public String insertNodesFromFile(FileResource res, NamespaceListType nsList, String xpath, String xmlFragment) throws XServicesFault {
+			throws XServicesFault {
 		try {
 			AXIOMXPath axp = new AXIOMXPath(xpath);
-			InputStream is = res.getAntResource(null).getInputStream();
-			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is)
+			InputStream is = res.getAntResource(null).getInputStream();
-					.getDocument();
+			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
-			OMDocument fragdoc = null;
-			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
+			OMDocument fragdoc = null;
-				fragdoc = OMXMLBuilderFactory.createOMBuilder(
+			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
-						new StringReader("<XS>" + xmlFragment + "</XS>"))
+				fragdoc = OMXMLBuilderFactory.createOMBuilder(new StringReader("<XS>" + xmlFragment + "</XS>"))
 						.getDocument();
 			} else {
 			e.printStackTrace();
 			throw new XServicesFault(e);
+		}
+	}
+	public String replaceNodesFromFile(FileResource res, NamespaceListType nsList, String xpath, String xmlFragment)
-	public String replaceNodesFromFile(FileResource res, NamespaceListType nsList, String xpath, String xmlFragment) throws XServicesFault {
+			throws XServicesFault {
 		try {
-				AXIOMXPath axp = new AXIOMXPath(xpath);
+			AXIOMXPath axp = new AXIOMXPath(xpath);
-				InputStream is = res.getAntResource(null).getInputStream();
+			InputStream is = res.getAntResource(null).getInputStream();
-				OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
+			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
-				OMDocument fragdoc = null;
+			OMDocument fragdoc = null;
-				if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
-					fragdoc = OMXMLBuilderFactory.createOMBuilder(
+			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
-							new StringReader("<XS>" + xmlFragment + "</XS>"))
+				fragdoc = OMXMLBuilderFactory.createOMBuilder(new StringReader("<XS>" + xmlFragment + "</XS>"))
-							.getDocument();
+						.getDocument();
-				} else {
+			} else {
-					throw new XServicesFault("No xmldata to insert.");
-				}
-				// Initialize XPath context
-				SimpleNamespaceContext context = createContext(nsList);
-				axp.setNamespaceContext(context);
-				axp.addNamespaces(fragdoc.getOMDocumentElement());
-				OMDocument document = replaceNodes(sourcedoc, axp, fragdoc);
-				StringWriter sw = new StringWriter();
-				XMLOutputFactory xof = XMLOutputFactory.newInstance();
-				XMLStreamWriter writer = xof.createXMLStreamWriter(sw);
-				document.serialize(writer);
-				this.logger.trace(sw.getBuffer().toString());
-				return sw.getBuffer().toString();
-			} catch (JaxenException e) {
-				e.printStackTrace();
-				throw new XServicesFault(e);
-			} catch (XMLStreamException e) {
-				e.printStackTrace();
-				throw new XServicesFault(e);
-			} catch (IOException e) {
-				e.printStackTrace();
-				throw new XServicesFault(e);
+				throw new XServicesFault("No xmldata to insert.");
+			}
+			// Initialize XPath context
+			SimpleNamespaceContext context = createContext(nsList);
+			axp.setNamespaceContext(context);
+			axp.addNamespaces(fragdoc.getOMDocumentElement());
+			OMDocument document = replaceNodes(sourcedoc, axp, fragdoc);
+			StringWriter sw = new StringWriter();
+			XMLOutputFactory xof = XMLOutputFactory.newInstance();
+			XMLStreamWriter writer = xof.createXMLStreamWriter(sw);
+			document.serialize(writer);
+			this.logger.trace(sw.getBuffer().toString());
+			return sw.getBuffer().toString();
+		} catch (JaxenException e) {
+			e.printStackTrace();
+			throw new XServicesFault(e);
+		} catch (XMLStreamException e) {
+			e.printStackTrace();
+			throw new XServicesFault(e);
+		} catch (IOException e) {
+			e.printStackTrace();
+			throw new XServicesFault(e);
+		}
 	}
 	public String replaceNodes(String source, String encoding, NamespaceListType nsList, String xpath,
-	public String replaceNodes(String source, String encoding, NamespaceListType nsList, String xpath, String xmlFragment) throws XServicesFault {
+			String xmlFragment) throws XServicesFault {
 		encoding = validateEncoding(encoding);
 		try {
 			AXIOMXPath axp = new AXIOMXPath(xpath);
-			InputStream is = new ByteArrayInputStream(source.getBytes(encoding));
-			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is)
+			InputStream is = new ByteArrayInputStream(source.getBytes(encoding));
-					.getDocument();
+			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
-			OMDocument fragdoc = null;
-			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
+			OMDocument fragdoc = null;
-				fragdoc = OMXMLBuilderFactory.createOMBuilder(
+			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
-						new StringReader("<XS>" + xmlFragment + "</XS>"))
+				fragdoc = OMXMLBuilderFactory.createOMBuilder(new StringReader("<XS>" + xmlFragment + "</XS>"))
 						.getDocument();
 			} else {
 			throw new XServicesFault(e);
 		} catch (UnsupportedEncodingException e) {
 			throw new XServicesFault(e);
+		}
+	}
 	@RequiresPermissions("insertNodes")
-	public String insertNodes(String source, String encoding, NamespaceListType nsList, String xpath, String xmlFragment) throws XServicesFault {
+	public String insertNodes(String source, String encoding, NamespaceListType nsList, String xpath,
+			String xmlFragment) throws XServicesFault {
 		encoding = validateEncoding(encoding);
 		try {
 			AXIOMXPath axp = new AXIOMXPath(xpath);
 			InputStream is = new ByteArrayInputStream(source.getBytes(encoding));
-			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is)
+			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
-					.getDocument();
 			OMDocument fragdoc = null;
 			if ((xmlFragment != null) && (new String(xmlFragment).length() > 0)) {
-				fragdoc = OMXMLBuilderFactory.createOMBuilder(
-						new StringReader("<XS>" + xmlFragment + "</XS>"))
+				fragdoc = OMXMLBuilderFactory.createOMBuilder(new StringReader("<XS>" + xmlFragment + "</XS>"))
 						.getDocument();
 			} else {
 				throw new XServicesFault("No xmldata to insert.");
+			}
 			throw new XServicesFault(e);
+		}
+	}
 	public String wrapInCDATA(String data) throws XServicesFault {
-		String result ="";
+		String result = "";
 		String[] tokens = data.split("\\]\\]>", -1);
-		for(int i=0; i<tokens.length; i++) {
+		for (int i = 0; i < tokens.length; i++) {
+			result += tokens[i];
-			result +=  tokens[i];
+			if (i + 1 < tokens.length)
-			if (i+1 < tokens.length ) result += "]]]]><![CDATA[>";
+				result += "]]]]><![CDATA[>";
 		}
 		result = "<![CDATA[" + result + "]]>";
 		return result;
 	}
 	public StringSplitType selectXPath(String source, String encoding, NamespaceListType nsList, String xpath)
-	public StringSplitType selectXPath(String source, String encoding, NamespaceListType nsList, String xpath) throws XServicesFault {
+			throws XServicesFault {
 		encoding = validateEncoding(encoding);
 		try {
 			StringSplitType rarray = new StringSplitType();
 			AXIOMXPath axp = new AXIOMXPath(xpath);
 			InputStream is = new ByteArrayInputStream(source.getBytes(encoding));
 			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
 			// Initialize XPath context
 			SimpleNamespaceContext context = createContext(nsList);
 			axp.setNamespaceContext(context);
 			List results = axp.selectNodes(sourcedoc);
-			for(Object o : results) {
+			for (Object o : results) {
 				String text = null;
-				if(o instanceof OMNode) {
+				if (o instanceof OMNode) {
-					switch (((OMNode)o).getType()) {
+					switch (((OMNode) o).getType()) {
-						case OMNode.TEXT_NODE:
+					case OMNode.TEXT_NODE:
-							text = ((OMText)o).getText();
+						text = ((OMText) o).getText();
-							break;
+						break;
-						case OMNode.COMMENT_NODE:
+					case OMNode.COMMENT_NODE:
-							text = ((OMComment)o).getValue();
+						text = ((OMComment) o).getValue();
-							break;
+						break;
-						case OMNode.PI_NODE:
+					case OMNode.PI_NODE:
-							text = ((OMProcessingInstruction)o).getValue();
+						text = ((OMProcessingInstruction) o).getValue();
-							break;
+						break;
-						default:
+					default:
-							StringWriter sw = new StringWriter();
+						StringWriter sw = new StringWriter();
-							XMLOutputFactory xof = XMLOutputFactory.newInstance();
+						XMLOutputFactory xof = XMLOutputFactory.newInstance();
-							XMLStreamWriter writer = xof.createXMLStreamWriter(sw);
+						XMLStreamWriter writer = xof.createXMLStreamWriter(sw);
-							((OMNode)o).serialize(writer);
+						((OMNode) o).serialize(writer);
-							writer.flush();
+						writer.flush();
-							text = sw.toString();
+						text = sw.toString();
 					}
-				} else if(o instanceof OMAttribute) {
+				} else if (o instanceof OMAttribute) {
-					text = ((OMAttribute)o).getAttributeValue();
+					text = ((OMAttribute) o).getAttributeValue();
 				} else {
 					text = String.valueOf(o);
+				}
-				rarray.addStringMatch(text);
 				rarray.addStringMatch(text);
+			}
 			return rarray;
-			} catch (JaxenException e) {
+		} catch (JaxenException e) {
 			e.printStackTrace();
 			throw new XServicesFault(e);
 		} catch (XMLStreamException e) {
-				// TODO Auto-generated catch block
+			// TODO Auto-generated catch block
 			throw new XServicesFault(e.getMessage());
-			} catch (UnsupportedEncodingException e) {
+		} catch (UnsupportedEncodingException e) {
-				throw new XServicesFault(e);
+			throw new XServicesFault(e);
 		}
+	}
 	public String setAttribute(String source, String encoding, NamespaceListType nsList, String xpath,
-	public String setAttribute(String source, String encoding, NamespaceListType nsList, String xpath, AttributeType attr) throws XServicesFault {
+			AttributeType attr) throws XServicesFault {
 		encoding = validateEncoding(encoding);
 		try {
 			StringSplitType rarray = new StringSplitType();
 			AXIOMXPath axp = new AXIOMXPath(xpath);
 			InputStream is = new ByteArrayInputStream(source.getBytes(encoding));
 			OMDocument sourcedoc = OMXMLBuilderFactory.createOMBuilder(is).getDocument();
 			OMFactory fac = OMAbstractFactory.getOMFactory();
 			// Initialize XPath context
 			SimpleNamespaceContext context = createContext(nsList);
 			axp.setNamespaceContext(context);
 			List results = axp.selectNodes(sourcedoc);
-			for(Object o : results) {
+			for (Object o : results) {
 				String text = null;
-				if(o instanceof OMNode) {
+				if (o instanceof OMNode) {
-					switch (((OMNode)o).getType()) {
+					switch (((OMNode) o).getType()) {
-						case OMNode.ELEMENT_NODE:
+					case OMNode.ELEMENT_NODE:
-							OMElement node = ((OMElement)o);
+						OMElement node = ((OMElement) o);
-							if(attr.value == null) {
+						if (attr.value == null) {
-								node.removeAttribute( node.getAttribute(new QName(attr.name)));
+							node.removeAttribute(node.getAttribute(new QName(attr.name)));
-							} else {
+						} else {
-								node.addAttribute(attr.name, attr.value, node.getNamespace());
+							node.addAttribute(attr.name, attr.value, node.getNamespace());
-							}
+						}
-							break;
+						break;
-						default:
+					default:
-							throw new XServicesFault("XPath expression did not match an element node.");
+						throw new XServicesFault("XPath expression did not match an element node.");
+					}
 				} else {
 					throw new XServicesFault("XPath expression did not match a node.");
+				}
+			}
 			StringWriter sw = new StringWriter();
 			XMLOutputFactory xof = XMLOutputFactory.newInstance();
 			XMLStreamWriter writer = xof.createXMLStreamWriter(sw);
 			sourcedoc.serialize(writer);
 			writer.flush();
 			return sw.toString();
-			} catch (JaxenException e) {
+		} catch (JaxenException e) {
 			e.printStackTrace();
 			throw new XServicesFault(e);
 		} catch (XMLStreamException e) {
-				// TODO Auto-generated catch block
+			// TODO Auto-generated catch block
 			throw new XServicesFault(e.getMessage());
-			} catch (UnsupportedEncodingException e) {
+		} catch (UnsupportedEncodingException e) {
-				throw new XServicesFault(e);
+			throw new XServicesFault(e);
 		}
+	}
 	private OMDocument insertNodes(OMDocument xmldocument, AXIOMXPath axp, OMDocument xmlfragment)
-	private OMDocument insertNodes(OMDocument xmldocument, AXIOMXPath axp,OMDocument xmlfragment) throws XServicesFault {
+			throws XServicesFault {
 		List<?> olist = null;
-		try {
-			olist = axp.selectNodes(xmldocument.getOMDocumentElement());
+		try {
-			this.logger.debug("XPath '" + axp.toString() + "' has "
-					+ olist.size() + " matches.");
+			olist = axp.selectNodes(xmldocument.getOMDocumentElement());
-			this.logger.trace("XPath root expression is: '" + axp.debug()
+			this.logger.debug("XPath '" + axp.toString() + "' has " + olist.size() + " matches.");
-					+ "'.");
+			this.logger.trace("XPath root expression is: '" + axp.debug() + "'.");
 		} catch (JaxenException e) {
 			throw new XServicesFault(e.getMessage(), e);
-		}
 		if (olist.size() == 0)
-			throw new XServicesFault(Messages.getString("XmlService.no_match",
+		if (olist.size() == 0)
-					new Object[] { axp.toString() }));
+			throw new XServicesFault(Messages.getString("XmlService.no_match", new Object[] { axp.toString() }));
 		// Prepare children to insert
 		xmlfragment.build();
 		// Determine what has been matched
-		OMContainer match = null;
+		// Determine what has been matched
-		for (Object o : olist) {
+		OMContainer match = null;
-			Iterator<?> children = xmlfragment.getOMDocumentElement()
+		for (Object o : olist) {
-					.getChildren();
+			Iterator<?> children = xmlfragment.getOMDocumentElement().getChildren();
 					// match = node.getParent();
 					match = (OMContainer) node;
 					this.logger.debug(Messages.getString("XmlService.10"));
 					break;
 				default:
-					this.logger.error("XPath matched "
+					this.logger
-							+ o.getClass().getCanonicalName() + " Node Type:"
+							.error("XPath matched " + o.getClass().getCanonicalName() + " Node Type:" + node.getType());
-							+ node.getType());
 					this.logger.error(Messages.getString("XmlService.11"));
-					throw new XServicesFault(
-							Messages.getString("XmlService.12"));
+					throw new XServicesFault(Messages.getString("XmlService.12"));
+				}
 			} else {
-				this.logger.error("XPath matched "
-						+ o.getClass().getCanonicalName());
+				this.logger.error("XPath matched " + o.getClass().getCanonicalName());
 				this.logger.error(Messages.getString("XmlService.11"));
 				throw new XServicesFault(Messages.getString("XmlService.12"));
+			}
 		xmldocument.build();
 		return xmldocument;
+	}
-	}
 	private OMDocument replaceNodes(OMDocument xmldocument, AXIOMXPath axp, OMDocument xmlfragment)
-	private OMDocument replaceNodes(OMDocument xmldocument, AXIOMXPath axp, OMDocument xmlfragment) throws XServicesFault {
+			throws XServicesFault {
 		List<?> olist = null;
-		try {
-			olist = axp.selectNodes(xmldocument.getOMDocumentElement());
+		try {
-			this.logger.debug("XPath '" + axp.toString() + "' has "
-					+ olist.size() + " matches.");
+			olist = axp.selectNodes(xmldocument.getOMDocumentElement());
-			this.logger.trace("XPath root expression is: '" + axp.debug()
+			this.logger.debug("XPath '" + axp.toString() + "' has " + olist.size() + " matches.");
-					+ "'.");
+			this.logger.trace("XPath root expression is: '" + axp.debug() + "'.");
 		} catch (JaxenException e) {
 			throw new XServicesFault(e.getMessage(), e);
-		}
 		if (olist.size() == 0)
-			throw new XServicesFault(Messages.getString("XmlService.no_match",
+		if (olist.size() == 0)
-					new Object[] { axp.toString() }));
+			throw new XServicesFault(Messages.getString("XmlService.no_match", new Object[] { axp.toString() }));
 		// Prepare children to insert
 		xmlfragment.build();
 		// Determine what has been matched
-		OMNode match = null;
+		// Determine what has been matched
-		for (Object o : olist) {
+		OMNode match = null;
-			Iterator<?> children = xmlfragment.getOMDocumentElement()
+		for (Object o : olist) {
-					.getChildren();
+			Iterator<?> children = xmlfragment.getOMDocumentElement().getChildren();
 					if ((o instanceof OMDocument))
 						match = ((OMDocument) o).getOMDocumentElement();
 					this.logger.debug(Messages.getString("XmlService.8"));
 					break;
 				default:
-					this.logger.error("XPath matched "
+					this.logger
-							+ o.getClass().getCanonicalName() + " Node Type:"
+							.error("XPath matched " + o.getClass().getCanonicalName() + " Node Type:" + node.getType());
-							+ node.getType());
 					this.logger.error(Messages.getString("XmlService.11"));
-					throw new XServicesFault(
-							Messages.getString("XmlService.12"));
+					throw new XServicesFault(Messages.getString("XmlService.12"));
+				}
 			} else {
-				this.logger.error("XPath matched "
-						+ o.getClass().getCanonicalName());
+				this.logger.error("XPath matched " + o.getClass().getCanonicalName());
 				this.logger.error(Messages.getString("XmlService.11"));
 				throw new XServicesFault(Messages.getString("XmlService.12"));
+			}
+	}
 	private SimpleNamespaceContext createContext(NamespaceListType nsList) {
 		// Initialize XPath context
 		SimpleNamespaceContext context = new SimpleNamespaceContext();
-		if(nsList != null) {
+		if (nsList != null) {
 			for (NamespaceType ns : nsList.getNamespaces()) {
 				context.addNamespace(ns.getPrefix(), ns.getUri().toString());
-				this.logger.debug(Messages.getString("XmlService.0")
+				this.logger.debug(
-						+ ns.getPrefix() + "=\"" + ns.getUri().toString()
-						+ "\"'");
+						Messages.getString("XmlService.0") + ns.getPrefix() + "=\"" + ns.getUri().toString() + "\"'");
+			}
 		} else {
 			logger.debug("No namespaces defined.");
+		}
 		return context;
+	}
+	private String validateEncoding(String encoding) throws XServicesFault {
+		if (encoding == null || encoding.equals("")) {
-	private String validateEncoding(String encoding) throws XServicesFault {
+			encoding = Charset.defaultCharset().displayName();
 		if(encoding == null || encoding.equals("")) { encoding=Charset.defaultCharset().displayName(); }
 		try {
 			Charset.isSupported(encoding);
 		} catch (IllegalCharsetNameException e) {
-			throw new XServicesFault("Endcoding '"+encoding+"' is not supported by this JRE.");
+			throw new XServicesFault("Endcoding '" + encoding + "' is not supported by this JRE.");
+		}
-		logger.debug("Setting source xml string encoding to '"+encoding+"'");
+		logger.debug("Setting source xml string encoding to '" + encoding + "'");
-		return encoding;
 		return encoding;

Subversion Repositories XServices

(root)/xservices/trunk/src/java/net/brutex/xservices/ws/impl/XmlServiceImpl.java @ 195 – Rev 177 → 185