Merge pull request #666 from csmith/master

Add source checks for eventbus handlers.

src/com/dmdirc/GroupChatManagerImpl.java

 
     @Handler
     void handleChannelClosing(final ChannelClosedEvent event) {
-        final GroupChat channel = event.getChannel();
-        connection.getWindowModel().getInputModel().get().getTabCompleter()
-                .removeEntry(TabCompletionType.CHANNEL, channel.getName());
-        channels.remove(channel.getName());
-        channel.getEventBus().unsubscribe(this);
+        if (event.getChannel().getConnection().equals(connection)) {
+            final GroupChat channel = event.getChannel();
+            connection.getWindowModel().getInputModel().get().getTabCompleter()
+                    .removeEntry(TabCompletionType.CHANNEL, channel.getName());
+            channels.remove(channel.getName());
+            channel.getEventBus().unsubscribe(this);
+        }
     }
 
 }

src/com/dmdirc/Server.java

         windowModel.getConfigManager().addChangeListener("formatter", "serverName", configListener);
         windowModel.getConfigManager().addChangeListener("formatter", "serverTitle", configListener);
 
-        this.highlightManager = new HighlightManager(windowModel.getConfigManager(),
+        this.highlightManager = new HighlightManager(
+                windowModel,
+                windowModel.getConfigManager(),
                 new ColourManager(windowModel.getConfigManager()));
         highlightManager.init();
         windowModel.getEventBus().subscribe(highlightManager);
 
     @Handler
     private void handleClose(final FrameClosingEvent event) {
-        if (event.getSource() == windowModel) {
+        if (event.getSource().equals(windowModel)) {
             synchronized (myStateLock) {
                 eventHandler.unregisterCallbacks();
                 windowModel.getConfigManager().removeListener(configListener);

src/com/dmdirc/ui/messages/HighlightManager.java

 import com.dmdirc.events.ServerConnectedEvent;
 import com.dmdirc.events.ServerNickChangeEvent;
 import com.dmdirc.interfaces.User;
+import com.dmdirc.interfaces.WindowModel;
 import com.dmdirc.interfaces.config.AggregateConfigProvider;
 import com.dmdirc.util.colours.Colour;
 
             "(\\p{Space}|\\p{Punct}|$).*";
 
     private final Collection<Pattern> patterns = new ArrayList<>();
+    private final WindowModel serverWindow;
     private final AggregateConfigProvider configProvider;
     private final ColourManager colourManager;
 
     private Optional<Colour> foregroundColour = Optional.empty();
 
     public HighlightManager(
+            final WindowModel serverWindow,
             final AggregateConfigProvider configProvider,
             final ColourManager colourManager) {
+        this.serverWindow = serverWindow;
         this.configProvider = configProvider;
         this.colourManager = colourManager;
     }
 
     @Handler
     void handleChannelMessage(final BaseChannelTextEvent event) {
-        if (patterns.stream().anyMatch(p -> p.matcher(event.getMessage()).matches())) {
+        if (event.getChannel().getConnection().get().getWindowModel().equals(serverWindow)
+                && patterns.stream().anyMatch(p -> p.matcher(event.getMessage()).matches())) {
             setColours(event);
             event.getChannel().getEventBus().publishAsync(new ChannelHighlightEvent(event));
         }
 
     @Handler
     void handleQueryMessage(final BaseQueryTextEvent event) {
-        if (patterns.stream().anyMatch(p -> p.matcher(event.getMessage()).matches())) {
+        if (event.getUser().getConnection().getWindowModel().equals(serverWindow)
+                && patterns.stream().anyMatch(p -> p.matcher(event.getMessage()).matches())) {
             setColours(event);
             event.getQuery().getEventBus().publishAsync(new QueryHighlightEvent(event));
         }
 
     @Handler
     void handleNickChange(final ServerNickChangeEvent event) {
-        setNickname(event.getNewNick());
+        if (event.getConnection().getWindowModel().equals(serverWindow)) {
+            setNickname(event.getNewNick());
+        }
     }
 
     @Handler
     void handleConnected(final ServerConnectedEvent event) {
-        patterns.clear();
+        if (event.getConnection().getWindowModel().equals(serverWindow)) {
+            patterns.clear();
 
-        event.getConnection().getProfile().getHighlights()
-                .stream()
-                .map(this::compile)
-                .forEach(patterns::add);
+            event.getConnection().getProfile().getHighlights()
+                    .stream()
+                    .map(this::compile)
+                    .forEach(patterns::add);
 
-        event.getConnection().getLocalUser()
-                .map(User::getNickname)
-                .ifPresent(this::setNickname);
+            event.getConnection().getLocalUser()
+                    .map(User::getNickname)
+                    .ifPresent(this::setNickname);
+        }
     }
 
     @ConfigBinding(domain = "ui", key = "highlightLineForegroundColour", required = false)

test/com/dmdirc/ui/messages/HighlightManagerTest.java

 import com.dmdirc.interfaces.Connection;
 import com.dmdirc.interfaces.GroupChatUser;
 import com.dmdirc.interfaces.User;
+import com.dmdirc.interfaces.WindowModel;
 import com.dmdirc.interfaces.config.AggregateConfigProvider;
 
 import com.google.common.collect.Lists;
 public class HighlightManagerTest {
 
     @Mock private Connection connection;
+    @Mock private WindowModel windowModel;
     @Mock private User user;
     @Mock private Profile profile;
 
     public void setup() {
         when(connection.getLocalUser()).thenReturn(Optional.of(user));
         when(connection.getProfile()).thenReturn(profile);
+        when(connection.getWindowModel()).thenReturn(windowModel);
 
         when(channel.getEventBus()).thenReturn(eventBus);
 
-        manager = new HighlightManager(configProvider, colourManager);
+        manager = new HighlightManager(windowModel, configProvider, colourManager);
     }
 
     @Test