Initial version. JM-311

git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@1555 b35dd754-fafc-0310-a699-88a17e54d16e

src/java/org/jivesoftware/messenger/handler/IQLastActivityHandler.java

+package org.jivesoftware.messenger.handler;
+
+import org.dom4j.Element;
+import org.jivesoftware.messenger.IQHandlerInfo;
+import org.jivesoftware.messenger.PresenceManager;
+import org.jivesoftware.messenger.XMPPServer;
+import org.jivesoftware.messenger.auth.UnauthorizedException;
+import org.jivesoftware.messenger.disco.ServerFeaturesProvider;
+import org.jivesoftware.messenger.roster.RosterItem;
+import org.jivesoftware.messenger.user.User;
+import org.jivesoftware.messenger.user.UserManager;
+import org.jivesoftware.messenger.user.UserNotFoundException;
+import org.xmpp.packet.IQ;
+import org.xmpp.packet.PacketError;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+
+/**
+ * Implements the TYPE_IQ jabber:iq:last protocol (last activity). Allows users to find out
+ * the number of seconds another user has been offline. This information is only available to
+ * those users that already subscribed to the users presence. Otherwhise, a <tt>forbidden</tt>
+ * error will be returned.
+ *
+ * @author Gaston Dombiak
+ */
+public class IQLastActivityHandler extends IQHandler implements ServerFeaturesProvider {
+
+    private IQHandlerInfo info;
+    private PresenceManager presenceManager;
+
+    public IQLastActivityHandler() {
+        super("XMPP Last Activity Handler");
+        info = new IQHandlerInfo("query", "jabber:iq:last");
+    }
+
+    public IQ handleIQ(IQ packet) throws UnauthorizedException {
+        IQ reply = IQ.createResultIQ(packet);
+        Element lastActivity = reply.setChildElement("query", "jabber:iq:last");
+        String sender = packet.getFrom().getNode();
+        String username = packet.getTo().getNode();
+
+        // Check if any of the usernames is null
+        if (sender == null || username == null) {
+            reply.setError(PacketError.Condition.forbidden);
+            return reply;
+        }
+
+        try {
+            User user = UserManager.getInstance().getUser(username);
+            RosterItem item = user.getRoster().getRosterItem(packet.getFrom());
+            // Check that the user requesting this information is subscribed to the user's presence
+            if (item.getSubStatus() == RosterItem.SUB_FROM ||
+                    item.getSubStatus() == RosterItem.SUB_BOTH) {
+                if (sessionManager.getSessions(username).isEmpty()) {
+                    // The user is offline so answer the user's "last available time and the
+                    // status message of the last unavailable presence received from the user"
+                    long lastActivityTime = presenceManager.getLastActivity(user);
+                    lastActivity.addAttribute("seconds", String.valueOf(lastActivityTime));
+                    String lastStatus = presenceManager.getLastPresenceStatus(user);
+                    if (lastStatus != null && lastStatus.length() > 0) {
+                        lastActivity.setText(lastStatus);
+                    }
+                }
+                else {
+                    // The user is online so answer seconds=0
+                    lastActivity.addAttribute("seconds", "0");
+                }
+            }
+            else {
+                reply.setError(PacketError.Condition.forbidden);
+            }
+        }
+        catch (UserNotFoundException e) {
+            reply.setError(PacketError.Condition.forbidden);
+        }
+        return reply;
+    }
+
+    public IQHandlerInfo getInfo() {
+        return info;
+    }
+
+    public Iterator getFeatures() {
+        ArrayList features = new ArrayList();
+        features.add("jabber:iq:last");
+        return features.iterator();
+    }
+
+    public void initialize(XMPPServer server) {
+        super.initialize(server);
+        presenceManager = server.getPresenceManager();
+    }
+}
\ No newline at end of file