Implement composition state change method in parsers

Change-Id: Iece6afe9fba02126f203cb1aecd702bc9303b981
Depends-On: Ic893051d84bc4ab47274b2bf9c967db8ba951eea
Reviewed-on: http://gerrit.dmdirc.com/2132
Automatic-Compile: DMDirc Build Manager
Reviewed-by: Greg Holmes <greg@dmdirc.com>

src/com/dmdirc/addons/parser_msn/MSNParser.java

@@ -25,6 +25,7 @@ package com.dmdirc.addons.parser_msn;
 import com.dmdirc.parser.common.BaseParser;
 import com.dmdirc.parser.common.ChannelJoinRequest;
 import com.dmdirc.parser.common.ChildImplementations;
+import com.dmdirc.parser.common.CompositionState;
 import com.dmdirc.parser.common.DefaultStringConverter;
 import com.dmdirc.parser.common.QueuePriority;
 import com.dmdirc.parser.interfaces.ChannelInfo;
@@ -462,4 +463,10 @@ public class MSNParser extends BaseParser {
     public void removeClient(final MsnContact contact) {
         clients.remove(contact.getEmail().getEmailAddress());
     }
+
+    /** {@inheritDoc} */
+    @Override
+    public void setCompositionState(final String host, final CompositionState state) {
+        // Do nothing
+    }
 }

src/com/dmdirc/addons/parser_twitter/Twitter.java

@@ -35,6 +35,7 @@ import com.dmdirc.interfaces.ConfigChangeListener;
 import com.dmdirc.logger.ErrorManager;
 import com.dmdirc.parser.common.CallbackManager;
 import com.dmdirc.parser.common.ChannelJoinRequest;
+import com.dmdirc.parser.common.CompositionState;
 import com.dmdirc.parser.common.DefaultStringConverter;
 import com.dmdirc.parser.common.IgnoreList;
 import com.dmdirc.parser.common.QueuePriority;
@@ -1649,4 +1650,10 @@ public class Twitter implements Parser, TwitterErrorHandler, TwitterRawHandler,
         return Arrays.asList(new String[]{"Twitter IRC parser: " + getServerName()});
     }
 
+    /** {@inheritDoc} */
+    @Override
+    public void setCompositionState(final String host, final CompositionState state) {
+        // Do nothing
+    }
+
 }

src/com/dmdirc/addons/parser_xmpp/XmppParser.java

@@ -90,6 +90,9 @@ public class XmppParser extends BaseSocketAwareParser {
     /** The connection to use. */
     private XMPPConnection connection;
 
+    /** The state manager for the current connection. */
+    private ChatStateManager stateManager;
+
     /** A cache of known chats. */
     private final Map<String, Chat> chats = new HashMap<String, Chat>();
 
@@ -451,7 +454,7 @@ public class XmppParser extends BaseSocketAwareParser {
             connection.sendPacket(new Presence(Presence.Type.available, null, priority, Presence.Mode.available));
             connection.getRoster().addRosterListener(new RosterListenerImpl());
 
-            ChatStateManager.getInstance(connection);
+            stateManager = ChatStateManager.getInstance(connection);
 
             setServerName(connection.getServiceName());
 
@@ -522,6 +525,35 @@ public class XmppParser extends BaseSocketAwareParser {
                 AwayState.AWAY, AwayState.HERE, null);
     }
 
+    /** {@inheritDoc} */
+    @Override
+    public void setCompositionState(final String host, final CompositionState state) {
+        final Chat chat = chats.get(parseHostmask(host)[0]);
+
+        ChatState newState;
+
+        switch (state) {
+            case ENTERED_TEXT:
+                newState = ChatState.paused;
+                break;
+            case TYPING:
+                newState = ChatState.composing;
+                break;
+            case IDLE:
+            default:
+                newState = ChatState.active;
+                break;
+        }
+
+        if (chat != null && stateManager != null) {
+            try {
+                stateManager.setCurrentState(newState, chat);
+            } catch (XMPPException ex) {
+                // Can't set chat state... Oh well?
+            }
+        }
+    }
+
     private class ConnectionListenerImpl implements ConnectionListener {
 
         /** {@inheritDoc} */