Merge pull request #466 from csmith/master

Add source checks for eventbus handlers.

awaycolours/src/com/dmdirc/addons/awaycolours/AwayColoursManager.java

 
     @Handler
     public void handleAwayEvent(final ChannelUserAwayEvent event) {
-            event.getUser().setDisplayProperty(DisplayProperty.FOREGROUND_COLOUR, colour);
-            event.getChannel().refreshClients();
+        event.getUser().setDisplayProperty(DisplayProperty.FOREGROUND_COLOUR, colour);
+        event.getChannel().refreshClients();
     }
 
     @Handler

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

 
     @VisibleForTesting
     void checkWho() {
-        connectionManager.getConnections().forEach(
-                connection -> connection.getGroupChatManager().getChannels().forEach(channel -> {
-                    if (channel.getWindowModel().getConfigManager()
-                            .getOptionBool(domain, "sendwho")) {
-                        channel.requestUsersInfo();
-                    }
-                }));
+        connection.getGroupChatManager().getChannels().forEach(channel -> {
+            if (channel.getWindowModel().getConfigManager().getOptionBool(domain, "sendwho")) {
+                channel.requestUsersInfo();
+            }
+        });
     }
 
     @VisibleForTesting
     @VisibleForTesting
     @Handler
     void handleAwayEvent(final ChannelUserAwayEvent event) {
-        if (!event.getReason().isPresent()) {
+        if (event.getChannel().getConnection().equals(connection)
+                && !event.getReason().isPresent()) {
             event.setDisplayProperty(DisplayProperty.DO_NOT_DISPLAY, true);
             final boolean notseen = !users.containsKey(event.getUser().getNickname());
             users.put(event.getUser().getNickname(), event.getUser());
     @VisibleForTesting
     @Handler
     void handleServerNumericEvent(final ServerNumericEvent event) {
-        if (event.getNumeric() == 301) {
+        if (event.getConnection().equals(connection) && event.getNumeric() == 301) {
             final String nickname = event.getArgs()[3];
             final String reason = event.getArgs()[4];
             users.removeAll(nickname).forEach(u -> u.getGroupChat().getEventBus()

contactlist/src/com/dmdirc/addons/contactlist/ContactListListener.java

 
     @Handler
     public void handleClientsUpdated(final NickListClientsChangedEvent event) {
-        event.getUsers().forEach(this::clientAdded);
+        if (event.getChannel().equals(groupChat)) {
+            event.getUsers().forEach(this::clientAdded);
+        }
     }
 
     @Handler
     public void handleClientAdded(final NickListClientAddedEvent event) {
-        clientAdded(event.getUser());
+        if (event.getChannel().equals(groupChat)) {
+            clientAdded(event.getUser());
+        }
     }
 
     @Handler
     public void handleUserAway(final ChannelUserAwayEvent event) {
-        clientAdded(event.getUser());
+        if (event.getChannel().equals(groupChat)) {
+            clientAdded(event.getUser());
+        }
     }
 
     @Handler
     public void handleUserBack(final ChannelUserBackEvent event) {
-        clientAdded(event.getUser());
+        if (event.getChannel().equals(groupChat)) {
+            clientAdded(event.getUser());
+        }
     }
 
     @Handler
     public void windowClosing(final FrameClosingEvent event) {
-        removeListeners();
+        if (event.getSource().equals(groupChat.getWindowModel())) {
+            removeListeners();
+        }
     }
 
     void clientAdded(final GroupChatUser client) {

debug/src/com/dmdirc/addons/debug/RawWindow.java

 import com.dmdirc.parser.events.DataOutEvent;
 import com.dmdirc.parser.interfaces.Parser;
 import com.dmdirc.ui.core.components.WindowComponent;
-import com.dmdirc.ui.input.TabCompleterFactory;
 import com.dmdirc.ui.messages.BackBufferFactory;
 
 import java.util.Arrays;
 
     private final Connection connection;
 
-    public RawWindow(
-            final Connection connection,
-            final TabCompleterFactory tabCompleterFactory,
-            final BackBufferFactory backBufferFactory) {
+    public RawWindow(final Connection connection, final BackBufferFactory backBufferFactory) {
         super("raw", "Raw", "(Raw log)",
                 connection.getWindowModel().getConfigManager(),
                 backBufferFactory,
 
     @Handler
     public void handleServerConnecting(final ServerConnectingEvent connectingEvent) {
-        connection.getParser().map(Parser::getCallbackManager).ifPresent(c -> c.subscribe(this));
+        if (connectingEvent.getConnection().equals(connection)) {
+            connection.getParser()
+                    .map(Parser::getCallbackManager)
+                    .ifPresent(c -> c.subscribe(this));
+        }
     }
 
     @Handler

debug/src/com/dmdirc/addons/debug/RawWindowFactory.java

     }
 
     public RawWindow getRawWindow(final Connection connection) {
-        final RawWindow rawWindow = new RawWindow(connection,
-                tabCompleterFactory,  backBufferFactory);
+        final RawWindow rawWindow = new RawWindow(connection, backBufferFactory);
         rawWindow.setInputModel(
                 new DefaultInputModel(
                         connection::sendLine,

debug/src/com/dmdirc/addons/debug/commands/EventBusViewer.java

 
         @Handler
         public void handleFrameClosing(final FrameClosingEvent event) {
-            eventBus.unsubscribe(this);
+            if (event.getSource().equals(target)) {
+                eventBus.unsubscribe(this);
+            }
         }
 
         @Handler

identd/src/com/dmdirc/addons/identd/IdentdManager.java

      * Called when the plugin is loaded.
      */
     public void onLoad() {
-        // Add action hooks
         eventBus.subscribe(this);
 
         if (config.getOptionBool(domain, "advanced.alwaysOn")) {
     @Handler
     public void handleServerConnecting(final ServerConnectingEvent event) {
         synchronized (connections) {
-                if (connections.isEmpty()) {
-                    server.startServer();
-                }
-                connections.add(event.getConnection());
+            if (connections.isEmpty()) {
+                server.startServer();
             }
+            connections.add(event.getConnection());
+        }
     }
 
     @Handler
 
     private void handleServerRemoved(final Connection connection) {
         synchronized (connections) {
-                connections.remove(connection);
+            connections.remove(connection);
 
-                if (connections.isEmpty() && !config.getOptionBool(domain, "advanced.alwaysOn")) {
-                    server.stopServer();
-                }
+            if (connections.isEmpty() && !config.getOptionBool(domain, "advanced.alwaysOn")) {
+                server.stopServer();
             }
+        }
     }
 
-
-
     @Handler
     public void showConfig(final ClientPrefsOpenedEvent event) {
         final PreferencesDialogModel manager = event.getModel();

jpq/src/com/dmdirc/addons/jpq/GroupChatHandler.java

     @VisibleForTesting
     @Handler
     void handleJoin(final ChannelJoinEvent event) {
-        hideEvent(event);
+        if (event.getChannel().equals(groupChat)) {
+            hideEvent(event);
+        }
     }
 
     @SuppressWarnings("TypeMayBeWeakened")
     @VisibleForTesting
     @Handler
     void handlePart(final ChannelPartEvent event) {
-        hideEvent(event);
+        if (event.getChannel().equals(groupChat)) {
+            hideEvent(event);
+        }
     }
 
     @SuppressWarnings("TypeMayBeWeakened")
     @VisibleForTesting
     @Handler
     void handleQuit(final ChannelQuitEvent event) {
-        hideEvent(event);
+        if (event.getChannel().equals(groupChat)) {
+            hideEvent(event);
+        }
     }
 
     private void hideEvent(final DisplayableEvent event) {

parserdebug/src/com/dmdirc/addons/parserdebug/ParserDebugManager.java

 
     @Handler
     public void handleServerDisconnected(final ServerDisconnectedEvent event) {
-            final Parser parser = event.getConnection().getParser().get();
-            if (registeredParsers.containsKey(parser)) {
-                removeParser(parser, false);
-            }
+        final Parser parser = event.getConnection().getParser().get();
+        if (registeredParsers.containsKey(parser)) {
+            removeParser(parser, false);
+        }
     }
 
     @Handler

ui_swing/src/com/dmdirc/addons/ui_swing/components/NickList.java

 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleClientsChanged(final NickListClientsChangedEvent event) {
-        nicklistModel.replace(event.getUsers());
+        if (event.getChannel().getWindowModel().equals(frame.getContainer())) {
+            nicklistModel.replace(event.getUsers());
+        }
     }
 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleNickListUpdated(final NickListUpdatedEvent event) {
-        nicklistModel.sort();
-        repaint();
+        if (event.getChannel().getWindowModel().equals(frame.getContainer())) {
+            nicklistModel.sort();
+            repaint();
+        }
     }
 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleClientAdded(final NickListClientAddedEvent event) {
-        nicklistModel.add(event.getUser());
+        if (event.getChannel().getWindowModel().equals(frame.getContainer())) {
+            nicklistModel.add(event.getUser());
+        }
     }
 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleClientRemoved(final NickListClientRemovedEvent event) {
-        nicklistModel.remove(event.getUser());
+        if (event.getChannel().getWindowModel().equals(frame.getContainer())) {
+            nicklistModel.remove(event.getUser());
+        }
     }
 
 }

ui_swing/src/com/dmdirc/addons/ui_swing/components/TopicBar.java

 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleTopicChanged(final ChannelTopicChangeEvent event) {
-        topicChanged(event.getChannel(), event.getTopic());
+        if (event.getChannel().equals(channel)) {
+            topicChanged(event.getChannel(), event.getTopic());
+        }
     }
 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleTopicUnset(final ChannelTopicUnsetEvent event) {
-        topicChanged(event.getChannel(), null);
+        if (event.getChannel().equals(channel)) {
+            topicChanged(event.getChannel(), null);
+        }
     }
 
     private void topicChanged(final GroupChat channel, final Topic topic) {

ui_swing/src/com/dmdirc/addons/ui_swing/components/frames/ChannelFrame.java

     @Override
     @Handler(invocation = EdtHandlerInvocation.class)
     public void windowClosing(final FrameClosingEvent event) {
-        saveSplitPanePosition();
-        topicBar.close();
-        dialogProvider.dispose(groupChat);
-        super.windowClosing(event);
+        if (event.getSource().equals(getContainer())) {
+            saveSplitPanePosition();
+            topicBar.close();
+            dialogProvider.dispose(groupChat);
+            super.windowClosing(event);
+        }
     }
 
     @Override

ui_swing/src/com/dmdirc/addons/ui_swing/components/frames/ServerFrame.java

 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleCertProblem(final ServerCertificateProblemEncounteredEvent event) {
-        if (sslDialog != null) {
-            sslDialog.dispose();
-        }
+        if (event.getConnection().equals(connection)) {
+            if (sslDialog != null) {
+                sslDialog.dispose();
+            }
 
-        sslDialog = sslDialogFactory.create(event);
-        sslDialog.display();
+            sslDialog = sslDialogFactory.create(event);
+            sslDialog.display();
+        }
     }
 
     @Handler(invocation = EdtHandlerInvocation.class)
     public void handleCertProblemResolved(final ServerCertificateProblemResolvedEvent event) {
-        if (sslDialog != null) {
-            sslDialog.dispose();
+        if (event.getConnection().equals(connection)) {
+            if (sslDialog != null) {
+                sslDialog.dispose();
+            }
         }
     }
 
     @Override
     @Handler(invocation = EdtHandlerInvocation.class)
     public void windowClosing(final FrameClosingEvent event) {
-        connection.getWindowModel().getEventBus().unsubscribe(this);
-        dialogProvider.dispose(connection);
-        super.windowClosing(event);
+        if (event.getSource().equals(frameParent)) {
+            connection.getWindowModel().getEventBus().unsubscribe(this);
+            dialogProvider.dispose(connection);
+            super.windowClosing(event);
+        }
     }
 
     @Override

windowflashing/src/com/dmdirc/addons/windowflashing/WindowFlashingManager.java

         }
     }
 
-
-
     @Handler
     public void showConfig(final ClientPrefsOpenedEvent event) {
         final PreferencesDialogModel manager = event.getModel();