Add skeleton of node configuration result parser

Author: Lloyd Watkin

src/main/java/org/buddycloud/channelserver/channel/ChannelManagerImpl.java

@@ -83,6 +83,12 @@ public Map<String, String> getNodeConf(String nodeId)
 			throws NodeStoreException {
 		return nodeStore.getNodeConf(nodeId);
 	}
+	
+
+	@Override
+	public boolean isCachedNodeConfig(String nodeId) throws NodeStoreException {
+		return nodeStore.isCachedNodeConfig(nodeId);
+	}
 
 	@Override
 	public boolean nodeExists(String nodeId) throws NodeStoreException {

src/main/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/PubSubResult.java

@@ -7,6 +7,7 @@
 import org.buddycloud.channelserver.channel.ChannelManager;
 import org.buddycloud.channelserver.packetprocessor.PacketProcessor;
 import org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result.AffiliationsResult;
+import org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result.Configuration;
 import org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result.ItemsResult;
 import org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result.SubscriptionsResult;
 import org.buddycloud.channelserver.queue.FederatedQueueManager;
@@ -42,6 +43,7 @@ private void initElementProcessors() {
 	    elementProcessors.add(new SubscriptionsResult(channelManager));
 	    elementProcessors.add(new AffiliationsResult(channelManager));
 	    elementProcessors.add(new ItemsResult(channelManager));
+	    elementProcessors.add(new Configuration(channelManager));
 	}
 
 	@Override

src/main/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/result/Configuration.java

@@ -0,0 +1,46 @@
+package org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result;
+
+import java.util.List;
+
+import org.apache.log4j.Logger;
+import org.buddycloud.channelserver.channel.ChannelManager;
+import org.buddycloud.channelserver.db.exception.NodeStoreException;
+import org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.PubSubElementProcessorAbstract;
+import org.buddycloud.channelserver.pubsub.model.NodeSubscription;
+import org.buddycloud.channelserver.pubsub.model.impl.NodeSubscriptionImpl;
+import org.buddycloud.channelserver.pubsub.subscription.Subscriptions;
+import org.dom4j.Element;
+import org.xmpp.packet.IQ;
+import org.xmpp.packet.JID;
+
+public class Configuration extends PubSubElementProcessorAbstract {
+
+	private IQ request;
+	private boolean ownerRequest;
+	private String lastNode = "";
+
+	private static final Logger logger = Logger
+			.getLogger(Configuration.class);
+
+	public Configuration(ChannelManager channelManager) {
+		this.channelManager = channelManager;
+	}
+
+	@Override
+	public void process(Element elm, JID actorJID, IQ reqIQ, Element rsm)
+			throws Exception {
+		this.request = reqIQ;
+
+		if (-1 != request.getFrom().toString().indexOf("@")) {
+			logger.debug("Ignoring result packet, only interested in stanzas "
+					+ "from other buddycloud servers");
+			return;
+		}
+
+	}
+
+	@Override
+	public boolean accept(Element elm) {
+		return elm.getName().equals("configure");
+	}
+}

src/test/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/result/ConfigurationTest.java

@@ -0,0 +1,53 @@
+package org.buddycloud.channelserver.packetprocessor.iq.namespace.pubsub.result;
+
+import junit.framework.Assert;
+
+import org.buddycloud.channelserver.channel.ChannelManager;
+import org.buddycloud.channelserver.packetHandler.iq.IQTestHandler;
+import org.buddycloud.channelserver.pubsub.affiliation.Affiliations;
+import org.buddycloud.channelserver.pubsub.model.NodeSubscription;
+import org.dom4j.Element;
+import org.dom4j.tree.BaseElement;
+import org.junit.Before;
+import org.junit.Test;
+import org.mockito.Mockito;
+import org.xmpp.packet.IQ;
+import org.xmpp.packet.JID;
+
+public class ConfigurationTest extends IQTestHandler {
+
+	private IQ resultWithNode;
+	private IQ resultNoNode;
+	private Configuration confResult;
+	private Element element;
+
+	private String node = "/user/pamela@denmark.lit/posts";
+	private JID jid = new JID("juliet@shakespeare.lit");
+	private ChannelManager channelManager;
+
+	@Before
+	public void setUp() throws Exception {
+
+		channelManager = Mockito.mock(ChannelManager.class);
+
+		confResult = new Configuration(channelManager);
+		resultWithNode = readStanzaAsIq("/iq/pubsub/subscriptions/reply-with-node.stanza");
+		resultNoNode = readStanzaAsIq("/iq/pubsub/subscriptions/reply-no-node.stanza");
+
+		element = new BaseElement("configure");
+		element.addAttribute("node", node);
+
+		confResult.setChannelManager(channelManager);
+	}
+
+	@Test
+	public void testPassingConfigureAsElementNameReturnsTrue() {
+		Assert.assertTrue(confResult.accept(element));
+	}
+
+	@Test
+	public void testPassingNotConfigureAsElementNameReturnsFalse() {
+		Element element = new BaseElement("not-configure");
+		Assert.assertFalse(confResult.accept(element));
+	}
+}