Merge pull request #343 from csmith/channelwho

Add framework for channel who plugin.

channelwho/src/com/dmdirc/addons/channelwho/ChannelWhoManager.java

@@ -22,22 +22,60 @@
 
 package com.dmdirc.addons.channelwho;
 
+import com.dmdirc.DMDircMBassador;
+import com.dmdirc.events.ServerConnectingEvent;
+import com.dmdirc.events.ServerDisconnectedEvent;
+import com.dmdirc.interfaces.Connection;
+import com.dmdirc.interfaces.ConnectionManager;
 import com.dmdirc.plugins.PluginDomain;
 
 import javax.inject.Inject;
 
+import net.engio.mbassy.listener.Handler;
+
 /**
  * Provides channel who support in DMDirc.
  */
 public class ChannelWhoManager {
 
+    private final ConnectionManager connectionManager;
+    private final DMDircMBassador eventBus;
+
     @Inject
-    public ChannelWhoManager(@PluginDomain(ChannelWhoPlugin.class) final String domain) {
+    public ChannelWhoManager(
+            @PluginDomain(ChannelWhoPlugin.class) final String domain,
+            final ConnectionManager connectionManager,
+            final DMDircMBassador eventBus) {
+        this.connectionManager = connectionManager;
+        this.eventBus = eventBus;
     }
 
     public void load() {
+        eventBus.subscribe(this);
+        connectionManager.getConnections().forEach(this::addConnectionHandler);
     }
 
     public void unload() {
+        connectionManager.getConnections().forEach(this::removeConnectionHandler);
+        eventBus.unsubscribe(this);
+    }
+
+    private void addConnectionHandler(final Connection connection) {
+        // TODO: Create a handler class which will monitor settings + handle timers.
+    }
+
+    private void removeConnectionHandler(final Connection connection) {
+        // TODO: Remove handlers
     }
+
+    @Handler
+    private void handleServerConnectingEvent(final ServerConnectingEvent event) {
+        addConnectionHandler(event.getConnection());
+    }
+
+    @Handler
+    private void handleServerDisconnectedEvent(final ServerDisconnectedEvent event) {
+        removeConnectionHandler(event.getConnection());
+    }
+
 }

channelwho/src/com/dmdirc/addons/channelwho/ChannelWhoPlugin.java

@@ -38,7 +38,7 @@ public class ChannelWhoPlugin extends BasePlugin {
     public void load(final PluginInfo pluginInfo, final ObjectGraph graph) {
         super.load(pluginInfo, graph);
 
-        setObjectGraph(graph.plus(new ChannelWhoManager(pluginInfo.getDomain())));
+        setObjectGraph(graph.plus(new ChannelWhoModule(pluginInfo.getDomain())));
         manager = getObjectGraph().get(ChannelWhoManager.class);
     }
 

channelwho/test/com/dmdirc/addons/channelwho/ChannelWhoManagerTest.java

@@ -22,19 +22,26 @@
 
 package com.dmdirc.addons.channelwho;
 
+import com.dmdirc.DMDircMBassador;
+import com.dmdirc.interfaces.ConnectionManager;
+
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.mockito.Mock;
 import org.mockito.runners.MockitoJUnitRunner;
 
 @RunWith(MockitoJUnitRunner.class)
 public class ChannelWhoManagerTest {
 
+    @Mock private ConnectionManager connectionManager;
+    @Mock private DMDircMBassador eventBus;
+
     private ChannelWhoManager instance;
 
     @Before
     public void setUp() throws Exception {
-        instance = new ChannelWhoManager("test");
+        instance = new ChannelWhoManager("test", connectionManager, eventBus);
     }
 
     @Test