Initial version

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/branches/3_3_1_branch@9059 b35dd754-fafc-0310-a699-88a17e54d16e

src/plugins/xmldebug/plugin.xml

+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+  Plugin configuration for the sessions debugger plugin.
+-->
+<plugin>
+    <class>org.jivesoftware.openfire.plugin.DebuggerPlugin</class>
+    <name>Debugger Plugin</name>
+    <description>Prints XML traffic to the stdout (raw and interpreted XML)</description>
+    <author>Jive Software</author>
+    <version>1.0</version>
+    <minServerVersion>3.2.0</minServerVersion>
+</plugin>
\ No newline at end of file

src/plugins/xmldebug/src/java/org/jivesoftware/openfire/plugin/DebuggerPlugin.java

+/**
+ * $RCSfile: $
+ * $Revision: $
+ * $Date: $
+ *
+ * Copyright (C) 2007 Jive Software. All rights reserved.
+ *
+ * This software is published under the terms of the GNU Public License (GPL),
+ * a copy of which is included in this distribution.
+ */
+
+package org.jivesoftware.openfire.plugin;
+
+import org.jivesoftware.openfire.XMPPServer;
+import org.jivesoftware.openfire.container.Plugin;
+import org.jivesoftware.openfire.container.PluginManager;
+import org.jivesoftware.openfire.interceptor.InterceptorManager;
+import org.jivesoftware.openfire.spi.ConnectionManagerImpl;
+import org.jivesoftware.util.JiveGlobals;
+import org.jivesoftware.util.PropertyEventDispatcher;
+import org.jivesoftware.util.PropertyEventListener;
+
+import java.io.File;
+import java.util.Map;
+
+/**
+ * Debugger plugin that prints XML traffic to stdout. By default it will only print
+ * raw XML traffic (by using a MINA filter). To turn on printing of interpreted XML
+ * (i.e. parsed XML) just enable the system property <tt>plugin.debugger.interpretedAllowed</tt>.
+ * There is no need to restart the plugin or the server.
+ *
+ * @author Gaston Dombiak
+ */
+public class DebuggerPlugin implements Plugin, PropertyEventListener {
+    private RawPrintFilter defaultPortFilter;
+    private RawPrintFilter oldPortFilter;
+
+    private InterpretedXMLPrinter interpretedPrinter;
+
+    public void initializePlugin(PluginManager manager, File pluginDirectory) {
+        // Add filter to filter chain builder
+        ConnectionManagerImpl connManager = (ConnectionManagerImpl) XMPPServer.getInstance().getConnectionManager();
+        defaultPortFilter = new RawPrintFilter();
+        connManager.getSocketAcceptor().getFilterChain().addBefore("xmpp", "rawDebugger", defaultPortFilter);
+        oldPortFilter = new RawPrintFilter();
+        connManager.getSSLSocketAcceptor().getFilterChain().addBefore("xmpp", "rawDebugger", oldPortFilter);
+
+        interpretedPrinter = new InterpretedXMLPrinter();
+        if (JiveGlobals.getBooleanProperty("plugin.debugger.interpretedAllowed")) {
+            // Add the packet interceptor that prints interpreted XML
+            InterceptorManager.getInstance().addInterceptor(interpretedPrinter);
+        }
+        // Listen to property events
+        PropertyEventDispatcher.addListener(this);
+    }
+
+    public void destroyPlugin() {
+        // Stop listening to property events
+        PropertyEventDispatcher.removeListener(this);
+        // Remove filter from filter chain builder
+        ConnectionManagerImpl connManager = (ConnectionManagerImpl) XMPPServer.getInstance().getConnectionManager();
+        connManager.getSocketAcceptor().getFilterChain().remove("rawDebugger");
+        connManager.getSSLSocketAcceptor().getFilterChain().remove("rawDebugger");
+        // Remove the filters from existing sessions
+        defaultPortFilter.shutdown();
+        oldPortFilter.shutdown();
+
+        // Remove the packet interceptor that prints interpreted XML
+        InterceptorManager.getInstance().removeInterceptor(interpretedPrinter);
+
+        defaultPortFilter = null;
+        oldPortFilter = null;
+        interpretedPrinter = null;
+    }
+
+
+    public void propertySet(String property, Map<String, Object> params) {
+        if (property.equals("plugin.debugger.interpretedAllowed")) {
+            if (Boolean.parseBoolean((String)params.get("value"))) {
+                InterceptorManager.getInstance().addInterceptor(interpretedPrinter);
+            }
+            else {
+                InterceptorManager.getInstance().removeInterceptor(interpretedPrinter);
+            }
+        }
+    }
+
+    public void propertyDeleted(String property, Map<String, Object> params) {
+        if (property.equals("plugin.debugger.interpretedAllowed")) {
+            InterceptorManager.getInstance().removeInterceptor(interpretedPrinter);
+        }
+    }
+
+    public void xmlPropertySet(String property, Map<String, Object> params) {
+        // Do nothing
+    }
+
+    public void xmlPropertyDeleted(String property, Map<String, Object> params) {
+        // Do nothing
+    }
+}

src/plugins/xmldebug/src/java/org/jivesoftware/openfire/plugin/InterpretedXMLPrinter.java

+/**
+ * $RCSfile: $
+ * $Revision: $
+ * $Date: $
+ *
+ * Copyright (C) 2007 Jive Software. All rights reserved.
+ *
+ * This software is published under the terms of the GNU Public License (GPL),
+ * a copy of which is included in this distribution.
+ */
+
+package org.jivesoftware.openfire.plugin;
+
+import org.jivesoftware.openfire.interceptor.PacketInterceptor;
+import org.jivesoftware.openfire.interceptor.PacketRejectedException;
+import org.jivesoftware.openfire.session.Session;
+import org.xmpp.packet.Packet;
+
+/**
+ * Packet interceptor that prints to the stdout XML packets (i.e. XML after
+ * it was parsed).<p>
+ *
+ * If you find in the logs an entry for raw XML, an entry that a session was closed and
+ * never find the corresponding interpreted XML for the raw XML then there was an error
+ * while parsing the XML that closed the session. 
+ *
+ * @author Gaston Dombiak.
+ */
+public class InterpretedXMLPrinter implements PacketInterceptor {
+
+    public void interceptPacket(Packet packet, Session session, boolean incoming, boolean processed)
+            throws PacketRejectedException {
+        if (!processed && incoming) {
+            System.out.println("INTERPRETED: " + packet.toXML());
+        }
+    }
+}

src/plugins/xmldebug/src/java/org/jivesoftware/openfire/plugin/RawPrintFilter.java

+/**
+ * $RCSfile: $
+ * $Revision: $
+ * $Date: $
+ *
+ * Copyright (C) 2007 Jive Software. All rights reserved.
+ *
+ * This software is published under the terms of the GNU Public License (GPL),
+ * a copy of which is included in this distribution.
+ */
+
+package org.jivesoftware.openfire.plugin;
+
+import org.apache.mina.common.ByteBuffer;
+import org.apache.mina.common.IoFilterAdapter;
+import org.apache.mina.common.IoSession;
+
+import java.nio.CharBuffer;
+import java.nio.charset.Charset;
+import java.util.Collection;
+import java.util.concurrent.ConcurrentLinkedQueue;
+
+/**
+ * MINA filter that prints to the stdout received XML stanzas before they are actually parsed and
+ * also prints XML stanzas as sent to the XMPP entities. Moreover, it also prints information when
+ * a session is closed. 
+ *
+ * @author Gaston Dombiak
+ */
+public class RawPrintFilter extends IoFilterAdapter {
+        private Collection<IoSession> sessions = new ConcurrentLinkedQueue<IoSession>();
+
+        public void messageReceived(NextFilter nextFilter, IoSession session, Object message) throws Exception {
+            // Decode the bytebuffer and print it to the stdout
+            if (message instanceof ByteBuffer) {
+                ByteBuffer byteBuffer = (ByteBuffer) message;
+                // Keep current position in the buffer
+                int currentPos = byteBuffer.position();
+                // Decode buffer
+                Charset encoder = Charset.forName("UTF-8");
+                CharBuffer charBuffer = encoder.decode(byteBuffer.buf());
+                // Print buffer content
+                System.out.println("RECV (" + session.hashCode() + "): " + charBuffer);
+                // Reset to old position in the buffer
+                byteBuffer.position(currentPos);
+            }
+            // Pass the message to the next filter
+            super.messageReceived(nextFilter, session, message);
+        }
+
+        public void messageSent(NextFilter nextFilter, IoSession session, Object message) throws Exception {
+            System.out.println("SENT (" + session.hashCode() + "): " +
+                    Charset.forName("UTF-8").decode(((ByteBuffer) message).buf()));
+
+            // Pass the message to the next filter
+            super.messageSent(nextFilter, session, message);
+        }
+
+
+        public void shutdown() {
+            // Remove this filter from sessions that are using it
+            for (IoSession session : sessions) {
+                session.getFilterChain().remove("rawDebugger");
+            }
+            sessions = null;
+        }
+
+        public void sessionCreated(NextFilter nextFilter, IoSession session) throws Exception {
+            // Keep track of sessions using this filter
+            sessions.add(session);
+
+            super.sessionCreated(nextFilter, session);
+        }
+
+        public void sessionClosed(NextFilter nextFilter, IoSession session) throws Exception {
+            // Update list of sessions using this filter
+            sessions.remove(session);
+            // Print that a session was closed
+            System.out.println("CLOSED (" + session.hashCode() + ") ");
+
+            super.sessionClosed(nextFilter, session);
+        }
+    }
\ No newline at end of file