Added rest commands.

15 files changed, 776 insertions, 8 deletions

diff --git a/juick-commands/src/main/java/com/juick/command/BlacklistTag.java b/juick-commands/src/main/java/com/juick/command/BlacklistTag.java
new file mode 100644
index 00000000..2ce455dc
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/BlacklistTag.java
@@ -0,0 +1,61 @@
+package com.juick.command;
+
+import com.juick.Tag;
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.PrivacyQueriesService;
+import com.juick.service.TagService;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class BlacklistTag extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^bl\\s\\*(\\S+)$", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+    private final TagService tagService;
+    private final PrivacyQueriesService privacyQueriesService;
+
+    @Autowired
+    public BlacklistTag(UserService userService, TagService tagService, PrivacyQueriesService privacyQueriesService) {
+        this.userService = userService;
+        this.tagService = tagService;
+        this.privacyQueriesService = privacyQueriesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "BL *tag - add *tag to your blacklist";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        User blUser = getUserService().getUserByName(arguments[0]);
+        if (blUser != null) {
+            Tag tag = getTagService().getTag(arguments[0], false);
+            if (tag != null) {
+                PrivacyQueriesService.PrivacyResult result = getPrivacyQueriesService().blacklistTag(sender, tag);
+                if (result == PrivacyQueriesService.PrivacyResult.Added) {
+                    return "Tag added to your blacklist";
+                } else {
+                    return "Tag removed from your blacklist";
+                }
+            }
+        }
+        return "Tag not found";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/BlacklistUser.java b/juick-commands/src/main/java/com/juick/command/BlacklistUser.java
new file mode 100644
index 00000000..f2682c6a
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/BlacklistUser.java
@@ -0,0 +1,54 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.PrivacyQueriesService;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class BlacklistUser extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^bl\\s+@([^\\s\\n+]+)", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+    private final PrivacyQueriesService privacyQueriesService;
+
+    @Autowired
+    public BlacklistUser(UserService userService, PrivacyQueriesService privacyQueriesService) {
+        this.userService = userService;
+        this.privacyQueriesService = privacyQueriesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "BL @username - add @username to your blacklist";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        User blUser = getUserService().getUserByName(arguments[0]);
+        if (blUser != null) {
+            PrivacyQueriesService.PrivacyResult result = getPrivacyQueriesService().blacklistUser(sender, blUser);
+            if (result == PrivacyQueriesService.PrivacyResult.Added) {
+                return "User added to your blacklist";
+            } else {
+                return "User removed from your blacklist";
+            }
+        }
+        return "User not found";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/LastMessages.java b/juick-commands/src/main/java/com/juick/command/LastMessages.java
new file mode 100644
index 00000000..77ba8a81
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/LastMessages.java
@@ -0,0 +1,46 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.formatters.PlainTextFormatter;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.MessagesService;
+import lombok.Getter;
+import org.springframework.stereotype.Component;
+
+import java.util.Collections;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class LastMessages implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("^#\\+$", Pattern.CASE_INSENSITIVE);
+
+    private final MessagesService messagesService;
+
+    public LastMessages(MessagesService messagesService) {
+        this.messagesService = messagesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "#+ - Show last Juick messages";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        return "Last messages:\n"
+            + getMessagesService().getMessages(getMessagesService().getAll(sender.getUid(), 0)).stream()
+            .sorted(Collections.reverseOrder())
+            .map(PlainTextFormatter::formatPostSummary).collect(Collectors.joining("\n\n"));
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/Login.java b/juick-commands/src/main/java/com/juick/command/Login.java
new file mode 100644
index 00000000..0dc6a021
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/Login.java
@@ -0,0 +1,42 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class Login implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("^login$", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+
+    @Autowired
+    public Login(UserService userService) {
+        this.userService = userService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "LOGIN - log in to Juick website";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        return "http://juick.com/login?hash=" + getUserService().getHashByUID(sender.getUid());
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/PrivateMessage.java b/juick-commands/src/main/java/com/juick/command/PrivateMessage.java
index e41b0037..069bc367 100644
--- a/juick-commands/src/main/java/com/juick/command/PrivateMessage.java
+++ b/juick-commands/src/main/java/com/juick/command/PrivateMessage.java
@@ -6,8 +6,12 @@ import com.juick.service.PMQueriesService;
 import com.juick.service.UserService;
 import lombok.Getter;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import rocks.xmpp.addr.Jid;
+import rocks.xmpp.core.stanza.model.Message;
 
+import java.util.List;
 import java.util.regex.Pattern;
 
 /**
@@ -22,6 +26,9 @@ public class PrivateMessage extends MultiArgsCommand {
     private final UserService userService;
     private final PMQueriesService pmQueriesService;
 
+    @Value("${xmppbot_jid}")
+    private Jid jid;
+
     @Autowired
     public PrivateMessage(UserService userService, PMQueriesService pmQueriesService) {
         this.userService = userService;
@@ -42,17 +49,61 @@ public class PrivateMessage extends MultiArgsCommand {
     protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
         String addressee = arguments[0];
         String body = arguments[1];
+        int ret;
+
+        int addresseeUid;
+        List<String> jids_to = null;
+        boolean haveInRoster;
 
-        User toUser = getUserService().getUserByName(addressee);
+        addresseeUid = addressee.indexOf('@') > 0 ? getUserService().getUIDbyJID(addressee) : getUserService().getUIDbyName(addressee);
 
-        if (toUser.getUid() > 0) {
-            if (!getUserService().isInBLAny(toUser.getUid(), sender.getUid())) {
-                if (getPmQueriesService().createPM(sender.getUid(), toUser.getUid(), body)) {
-                    protocolListener.privateMessage(sender, toUser, body);
-                    return "Private message sent";
+        if (addresseeUid > 0) {
+            if (!getUserService().isInBLAny(addresseeUid, sender.getUid())) {
+                if (getPmQueriesService().createPM(sender.getUid(), addresseeUid, body)) {
+                    jids_to = getUserService().getJIDsbyUID(addresseeUid);
+                    ret = 200;
+                } else {
+                    ret = 500;
                 }
+            } else {
+                ret = 403;
             }
+        } else {
+            ret = 404;
         }
-        return "Error";
+
+        if (ret == 200) {
+            Message msg = new Message();
+            msg.setFrom(getJid().asBareJid());
+            msg.setTo(Jid.of(Integer.toString(addresseeUid), "push.juick.com", null));
+            com.juick.Message jmsg = new com.juick.Message();
+            jmsg.setUser(sender);
+            jmsg.setText(body);
+            msg.addExtension(jmsg);
+            //TODO fix external dependency
+            //router.sendStanza(msg);
+
+            msg.setTo(Jid.of(Integer.toString(addresseeUid), "ws.juick.com", null));
+            //TODO fix external dependency
+            //router.sendStanza(msg);
+
+            for (String userJid : jids_to) {
+                Message mm = new Message();
+                mm.setTo(Jid.of(userJid));
+                mm.setType(Message.Type.CHAT);
+                haveInRoster = getPmQueriesService().havePMinRoster(sender.getUid(), userJid);
+                if (haveInRoster) {
+                    mm.setFrom(Jid.of(sender.getName(), "juick.com", "Juick"));
+                    mm.setBody(body);
+                } else {
+                    mm.setFrom(getJid());
+                    mm.setBody("Private message from @" + sender.getName() + ":\n" + body);
+                }
+                //TODO fix external dependency
+                //xmpp.sendOut(ClientMessage.from(mm));
+            }
+        }
+
+        return ret == 200 ? "Private message sent" : "Error " + ret;
     }
 }
diff --git a/juick-commands/src/main/java/com/juick/command/Recommendations.java b/juick-commands/src/main/java/com/juick/command/Recommendations.java
new file mode 100644
index 00000000..c7f38003
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/Recommendations.java
@@ -0,0 +1,62 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.ShowQueriesService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class Recommendations implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("@", Pattern.CASE_INSENSITIVE);
+
+    private final ShowQueriesService showQueriesService;
+
+    @Autowired
+    public Recommendations(ShowQueriesService showQueriesService) {
+        this.showQueriesService = showQueriesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "@ - Show recommendations and popular personal blogs";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        StringBuilder msg = new StringBuilder();
+        msg.append("Recommended blogs");
+        List<String> recommendedUsers = getShowQueriesService().getRecommendedUsers(sender);
+        if (recommendedUsers.size() > 0) {
+            for (String user : recommendedUsers) {
+                msg.append("\n@").append(user);
+            }
+        } else {
+            msg.append("\nNo recommendations now. Subscribe to more blogs. ;)");
+        }
+        msg.append("\n\nTop 10 personal blogs:");
+        List<String> topUsers = getShowQueriesService().getTopUsers();
+        if (topUsers.size() > 0) {
+            for (String user : topUsers) {
+                msg.append("\n@").append(user);
+            }
+        } else {
+            msg.append("\nNo top users. Empty DB? ;)");
+        }
+        return msg.toString();
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/ShowBlacklist.java b/juick-commands/src/main/java/com/juick/command/ShowBlacklist.java
new file mode 100644
index 00000000..bd4df7df
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ShowBlacklist.java
@@ -0,0 +1,68 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.TagService;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ShowBlacklist implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("^bl$", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+    private final TagService tagService;
+
+    @Autowired
+    public ShowBlacklist(UserService userService, TagService tagService) {
+        this.userService = userService;
+        this.tagService = tagService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "BL - Show your blacklist";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        List<User> blusers = getUserService().getUserBLUsers(sender.getUid());
+        List<String> bltags = getTagService().getUserBLTags(sender.getUid());
+
+        StringBuilder txt = new StringBuilder();
+        if (bltags.size() > 0) {
+            for (String bltag : bltags) {
+                txt.append("*").append(bltag).append("\n");
+            }
+
+            if (blusers.size() > 0) {
+                txt.append("\n");
+            }
+        }
+        if (blusers.size() > 0) {
+            for (User bluser : blusers) {
+                txt.append("@").append(bluser.getName()).append("\n");
+            }
+        }
+        if (txt.length() == 0) {
+            txt.append("You don't have any users or tags in your blacklist.");
+        }
+
+        return txt.toString();
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/ShowFavorites.java b/juick-commands/src/main/java/com/juick/command/ShowFavorites.java
new file mode 100644
index 00000000..ced28936
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ShowFavorites.java
@@ -0,0 +1,54 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.formatters.PlainTextFormatter;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.MessagesService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ShowFavorites implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("!", Pattern.CASE_INSENSITIVE);
+
+    private final MessagesService messagesService;
+
+    @Autowired
+    public ShowFavorites(MessagesService messagesService) {
+        this.messagesService = messagesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "! - Show your favorite messages";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        List<Integer> mids = getMessagesService().getUserRecommendations(sender.getUid(), 0);
+        if (mids.size() > 0) {
+            List<com.juick.Message> messages = getMessagesService().getMessages(mids);
+            return "Favorite messages: \n" + String.join("\n", messages.stream()
+                .sorted(Collections.reverseOrder())
+                .map(PlainTextFormatter::formatPost)
+                .collect(Collectors.toList()));
+        }
+        return "No favorite messages, try to \"like\" something ;)";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/ShowSubscriptions.java b/juick-commands/src/main/java/com/juick/command/ShowSubscriptions.java
new file mode 100644
index 00000000..ad35a4c2
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ShowSubscriptions.java
@@ -0,0 +1,53 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.SubscriptionService;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ShowSubscriptions implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("S", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+    private final SubscriptionService subscriptionService;
+
+    public ShowSubscriptions(UserService userService, SubscriptionService subscriptionService) {
+        this.userService = userService;
+        this.subscriptionService = subscriptionService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "S - Show your subscriptions";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        List<User> friends = getUserService().getUserFriends(sender.getUid());
+        List<String> tags = getSubscriptionService().getSubscribedTags(sender);
+        String msg = friends.size() > 0 ? "You are subscribed to users:" + friends.stream().map(u -> "\n@" + u.getName())
+            .collect(Collectors.joining())
+            : "You are not subscribed to any user.";
+        msg += tags.size() > 0 ? "\nYou are subscribed to tags:" + tags.stream().map(t -> "\n*" + t)
+            .collect(Collectors.joining())
+            : "\nYou are not subscribed to any tag.";
+        return msg;
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/ShowTags.java b/juick-commands/src/main/java/com/juick/command/ShowTags.java
new file mode 100644
index 00000000..186919ad
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ShowTags.java
@@ -0,0 +1,48 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.helpers.TagStats;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.TagService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ShowTags implements Command {
+
+    private static final Pattern PATTERN = Pattern.compile("\\*", Pattern.CASE_INSENSITIVE);
+
+    private final TagService tagService;
+
+    @Autowired
+    public ShowTags(TagService tagService) {
+        this.tagService = tagService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "* - Show your tags";
+    }
+
+    @Override
+    public String execute(User sender, ProtocolListener protocolListener, String command) {
+        List<TagStats> tags = getTagService().getUserTagStats(sender.getUid());
+        return "Your tags: (tag - messages)\n" +
+            tags.stream()
+                .map(t -> String.format("\n*%s - %d", t.getTag().getName(), t.getUsageCount())).collect(Collectors.joining());
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/ShowUserInfo.java b/juick-commands/src/main/java/com/juick/command/ShowUserInfo.java
new file mode 100644
index 00000000..336b2e0d
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ShowUserInfo.java
@@ -0,0 +1,55 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.formatters.PlainTextFormatter;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.MessagesService;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ShowUserInfo extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^@([^\\s\\n+]+)(\\+?)$", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+    private final MessagesService messagesService;
+
+    public ShowUserInfo(UserService userService, MessagesService messagesService) {
+        this.userService = userService;
+        this.messagesService = messagesService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "@username+ - Show user's info and last 10 messages (@username++ - second page, ..)";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        User blogUser = getUserService().getUserByName(arguments[0]);
+        int page = arguments[1].length();
+        if (blogUser.getUid() > 0) {
+            List<Integer> mids = getMessagesService().getUserBlog(blogUser.getUid(), 0, page);
+            List<com.juick.Message> messages = getMessagesService().getMessages(mids);
+            return String.format("Last messages from @%s:\n%s", arguments[0],
+                String.join("\n", messages.stream()
+                    .map(PlainTextFormatter::formatPost).collect(Collectors.toList())));
+        }
+        return "User not found";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/SubscribeMessage.java b/juick-commands/src/main/java/com/juick/command/SubscribeMessage.java
new file mode 100644
index 00000000..893c0b65
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/SubscribeMessage.java
@@ -0,0 +1,60 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.MessagesService;
+import com.juick.service.SubscriptionService;
+import lombok.Getter;
+import org.apache.commons.lang3.math.NumberUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class SubscribeMessage extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^([su])\\s+#(\\d+)$", Pattern.CASE_INSENSITIVE);
+
+    private final MessagesService messagesService;
+    private final SubscriptionService subscriptionService;
+
+    @Autowired
+    public SubscribeMessage(MessagesService messagesService, SubscriptionService subscriptionService) {
+        this.messagesService = messagesService;
+        this.subscriptionService = subscriptionService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "S #1234 - subscribe to comments\nU #1234 - unsubscribe to comments";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        boolean subscribe = arguments[0].equalsIgnoreCase("s");
+        int mid = NumberUtils.toInt(arguments[1], 0);
+        if (getMessagesService().getMessage(mid) != null) {
+            if (subscribe) {
+                if (getSubscriptionService().subscribeMessage(mid, sender.getUid())) {
+                    return "Subscribed";
+                }
+            } else {
+                if (getSubscriptionService().unSubscribeMessage(mid, sender.getUid())) {
+                    return "Unsubscribed from #" + mid;
+                }
+                return "You was not subscribed to #" + mid;
+            }
+        }
+        return "Error";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/SubscribeTag.java b/juick-commands/src/main/java/com/juick/command/SubscribeTag.java
new file mode 100644
index 00000000..ce9ebc20
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/SubscribeTag.java
@@ -0,0 +1,58 @@
+package com.juick.command;
+
+import com.juick.Tag;
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.SubscriptionService;
+import com.juick.service.TagService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class SubscribeTag extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^([su])\\s+\\*(\\S+)$", Pattern.CASE_INSENSITIVE);
+
+    private final TagService tagService;
+    private final SubscriptionService subscriptionService;
+
+    @Autowired
+    public SubscribeTag(TagService tagService, SubscriptionService subscriptionService) {
+        this.tagService = tagService;
+        this.subscriptionService = subscriptionService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "S *tag - subscribe to tag\nU *tag - unsubscribe from tag";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        boolean subscribe = arguments[0].equalsIgnoreCase("s");
+        Tag tag = getTagService().getTag(arguments[1], true);
+        if (subscribe) {
+            if (getSubscriptionService().subscribeTag(sender, tag)) {
+                return "Subscribed";
+            }
+        } else {
+            if (getSubscriptionService().unSubscribeTag(sender, tag)) {
+                return "Unsubscribed from " + tag.getName();
+            }
+            return "You was not subscribed to " + tag.getName();
+        }
+        return "Error";
+    }
+}
diff --git a/juick-commands/src/main/java/com/juick/command/SubscribeUser.java b/juick-commands/src/main/java/com/juick/command/SubscribeUser.java
index 7589a954..f8204525 100644
--- a/juick-commands/src/main/java/com/juick/command/SubscribeUser.java
+++ b/juick-commands/src/main/java/com/juick/command/SubscribeUser.java
@@ -35,7 +35,7 @@ public class SubscribeUser extends MultiArgsCommand {
 
     @Override
     public String help() {
-        return "S @user - subscribe to user's posts";
+        return "S @user - subscribe to user's posts\n U @user - unsubscribe to user's posts";
     }
 
     @Override
diff --git a/juick-commands/src/main/java/com/juick/command/ToggleSubscriptions.java b/juick-commands/src/main/java/com/juick/command/ToggleSubscriptions.java
new file mode 100644
index 00000000..737565f9
--- /dev/null
+++ b/juick-commands/src/main/java/com/juick/command/ToggleSubscriptions.java
@@ -0,0 +1,56 @@
+package com.juick.command;
+
+import com.juick.User;
+import com.juick.server.protocol.ProtocolListener;
+import com.juick.service.UserService;
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.regex.Pattern;
+
+/**
+ * @author ma1uta
+ */
+@Component
+@Getter
+public class ToggleSubscriptions extends MultiArgsCommand {
+
+    private static final Pattern PATTERN = Pattern.compile("^(on|off)$", Pattern.CASE_INSENSITIVE);
+
+    private final UserService userService;
+
+    @Autowired
+    public ToggleSubscriptions(UserService userService) {
+        this.userService = userService;
+    }
+
+    @Override
+    public Pattern pattern() {
+        return PATTERN;
+    }
+
+    @Override
+    public String help() {
+        return "ON/OFF - Enable/disable subscriptions delivery";
+    }
+
+    @Override
+    protected String execute(User sender, ProtocolListener protocolListener, String... arguments) {
+        UserService.ActiveStatus newStatus;
+        String retValUpdated;
+        if (arguments[0].toLowerCase().equals("on")) {
+            newStatus = UserService.ActiveStatus.Active;
+            retValUpdated = "Notifications are activated for " + sender.getJid();
+        } else {
+            newStatus = UserService.ActiveStatus.Inactive;
+            retValUpdated = "Notifications are disabled for " + sender.getJid();
+        }
+
+        if (getUserService().setActiveStatusForJID(sender.getJid(), newStatus)) {
+            return retValUpdated;
+        } else {
+            return String.format("Subscriptions status for %s was not changed", sender.getJid());
+        }
+    }
+}