Add a test for a database exception during subsciption listeners gathering

Author: Lloyd Watkin

src/test/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/get/SubscriptionsGetTest.java

@@ -220,4 +220,5 @@ public void addsInvitedByToUserSubscriptionsListIfUser() throws Exception {
         Assert.assertEquals(1, response.getChildElement().element("subscriptions").elements("subscription").size());
 
     }
+
 }

src/test/java/org/buddycloud/channelserver/packetprocessor/iq/namespace/pubsub/set/NodeDeleteTest.java

@@ -8,6 +8,7 @@
 
 import org.buddycloud.channelserver.Configuration;
 import org.buddycloud.channelserver.channel.ChannelManager;
+import org.buddycloud.channelserver.db.exception.NodeStoreException;
 import org.buddycloud.channelserver.packetHandler.iq.IQTestHandler;
 import org.buddycloud.channelserver.pubsub.affiliation.Affiliations;
 import org.buddycloud.channelserver.pubsub.model.NodeSubscription;
@@ -284,4 +285,30 @@ public void testSuccessfulDeleteWithSubscribers() throws Exception {
         Assert.assertEquals(node,
                 eventEl.element("delete").attributeValue("node"));
     }
+    
+    @Test
+    public void databaseExceptionWhenGettingListenersSendsMinimalNotifications() throws Exception {
+        IQ request = readStanzaAsIq("/iq/pubsub/delete/request-with-node.stanza");
+        Element deleteEl = request.getChildElement().element("delete");
+
+        String node = deleteEl.attributeValue("node");
+        Mockito.when(channelManager.nodeExists(node)).thenReturn(true);
+
+        Mockito.doThrow(new NodeStoreException()).when(channelManager)
+            .getNodeSubscriptionListeners(Mockito.anyString());
+        
+        Mockito.when(channelManager.getNodeMembership(node, jid)).thenReturn(
+                new NodeMembershipImpl(node, jid, Subscriptions.subscribed,
+                        Affiliations.owner, null));
+
+        nodeDelete.process(deleteEl, jid, request, null);
+        IQ response = (IQ) queue.poll();
+
+        Assert.assertNull(response.getError());
+        Assert.assertEquals(request.getID(), response.getID());
+        Assert.assertEquals(Type.result, response.getType());
+
+        int adminCount = Configuration.getInstance().getAdminUsers().size();
+        Assert.assertEquals(adminCount, queue.size());
+    }
 }