diff options
Diffstat (limited to 'server-core/src/main/java/com/juick/server/protocol')
-rw-r--r-- | server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java b/server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java index e9e129a9..f1e98eb9 100644 --- a/server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java +++ b/server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java @@ -68,8 +68,8 @@ public class JuickProtocol { public ProtocolReply postMessage(User user, String input) { List<Tag> tags = TagQueries.fromString(sql, input, false); String body = input.substring(TagUtils.toString(tags).length()); - int mid = MessagesQueries.createMessage(sql, user.getUID(), body, null, tags); - SubscriptionsQueries.subscribeMessage(sql, mid, user.getUID()); + int mid = MessagesQueries.createMessage(sql, user.getUid(), body, null, tags); + SubscriptionsQueries.subscribeMessage(sql, mid, user.getUid()); //app.events().publishEvent(new JuickMessageEvent(app.messages().getMessage(mid))); return new ProtocolReply("New message posted.\n#" + mid + " " + baseUri + mid, Optional.of(json.serializeList(Collections.singletonList(MessagesQueries.getMessage(sql, mid))))); @@ -79,7 +79,7 @@ public class JuickProtocol { public ProtocolReply commandLast(User user, String... arguments) { // number of + is the page count int page = arguments[0].length() - 1; - List<Integer> mids = MessagesQueries.getAll(sql, user.getUID(), page); + List<Integer> mids = MessagesQueries.getAll(sql, user.getUid(), page); List<Message> messages = MessagesQueries.getMessages(sql, mids); return new ProtocolReply("Last messages: \n" + String.join("\n", messages.stream().map(PlainTextFormatter::formatPost) .collect(Collectors.toList())), Optional.of(json.serializeList(messages))); @@ -91,8 +91,8 @@ public class JuickProtocol { List<User> blusers; List<String> bltags; - blusers = UserQueries.getUserBLUsers(sql, user_from.getUID()); - bltags = TagQueries.getUserBLTags(sql, user_from.getUID()); + blusers = UserQueries.getUserBLUsers(sql, user_from.getUid()); + bltags = TagQueries.getUserBLTags(sql, user_from.getUid()); String txt = ""; @@ -107,7 +107,7 @@ public class JuickProtocol { } if (blusers.size() > 0) { for (User bluser : blusers) { - txt += "@" + bluser.getUName() + "\n"; + txt += "@" + bluser.getName() + "\n"; } } if (txt.isEmpty()) { @@ -175,7 +175,7 @@ public class JuickProtocol { @UserCommand(pattern = "\\*", help = "* - Show your tags") public ProtocolReply commandTags(User currentUser, String... args) { - List<Tag> tags = TagQueries.getUserTagsAll(sql, currentUser.getUID()); + List<Tag> tags = TagQueries.getUserTagsAll(sql, currentUser.getUid()); String msg = "Your tags: (tag - messages)\n" + tags.stream() .map(t -> String.format("\n*%s - %d", t.getName(), t.UsageCnt)).collect(Collectors.joining()); @@ -184,7 +184,7 @@ public class JuickProtocol { @UserCommand(pattern = "!", help = "! - Show your favorite messages") public ProtocolReply commandFavorites(User currentUser, String... args) { - List<Integer> mids = MessagesQueries.getUserRecommendations(sql, currentUser.getUID(), 0); + List<Integer> mids = MessagesQueries.getUserRecommendations(sql, currentUser.getUid(), 0); if (mids.size() > 0) { List<Message> messages = MessagesQueries.getMessages(sql, mids); return new ProtocolReply("Favorite messages: \n" + String.join("\n", messages.stream().map(PlainTextFormatter::formatPost) @@ -199,7 +199,7 @@ public class JuickProtocol { User blogUser = UserQueries.getUserByName(sql, arguments[0]); int page = arguments[1].length(); if (blogUser != null) { - List<Integer> mids = MessagesQueries.getUserBlog(sql, blogUser.getUID(), 0, page); + List<Integer> mids = MessagesQueries.getUserBlog(sql, blogUser.getUid(), 0, page); List<Message> messages = MessagesQueries.getMessages(sql, mids); return new ProtocolReply(String.format("Last messages from @%s:\n%s", arguments[0], String.join("\n", messages.stream() @@ -214,7 +214,7 @@ public class JuickProtocol { public ProtocolReply commandDel(User user, String... args) { try { int mid = Integer.parseInt(args[0]); - if (MessagesQueries.deleteMessage(sql, user.getUID(), mid)) { + if (MessagesQueries.deleteMessage(sql, user.getUid(), mid)) { return new ProtocolReply(String.format("Message %s deleted", mid), Optional.empty()); } } catch (NumberFormatException e) { @@ -226,7 +226,7 @@ public class JuickProtocol { @UserCommand(pattern = "^\\s*login\\s*$", patternFlags = Pattern.CASE_INSENSITIVE, help = "LOGIN - log in to Juick website") public ProtocolReply commandLogin(User user, String... arguments) { - return new ProtocolReply(baseUri + "?" + UserQueries.getHashByUID(sql, user.getUID()), + return new ProtocolReply(baseUri + "?" + UserQueries.getHashByUID(sql, user.getUid()), Optional.empty()); } @@ -234,7 +234,7 @@ public class JuickProtocol { public ProtocolReply commandMyFeed(User user, String... arguments) { // number of # is the page count int page = arguments[0].length() - 1; - List<Integer> mids = MessagesQueries.getMyFeed(sql, user.getUID(), page); + List<Integer> mids = MessagesQueries.getMyFeed(sql, user.getUid(), page); List<Message> messages = MessagesQueries.getMessages(sql, mids); // TODO: add instructions for empty feed return new ProtocolReply("Your feed: \n" + String.join("\n", @@ -286,11 +286,11 @@ public class JuickProtocol { } if (uid_to > 0) { - if (!UserQueries.isInBLAny(sql, uid_to, user_from.getUID())) { - if (PMQueries.createPM(sql, user_from.getUID(), uid_to, body)) { + if (!UserQueries.isInBLAny(sql, uid_to, user_from.getUid())) { + if (PMQueries.createPM(sql, user_from.getUid(), uid_to, body)) { //jid_to = UserQueries.getJIDsbyUID(sql, uid_to); if (jid_to != null) { - haveInRoster = PMQueries.havePMinRoster(sql, user_from.getUID(), jid_to); + haveInRoster = PMQueries.havePMinRoster(sql, user_from.getUid(), jid_to); } ret = 200; } else { @@ -316,11 +316,11 @@ public class JuickProtocol { mm.to = new JID(jid_to); mm.type = Message.Type.chat; if (haveInRoster) { - mm.from = new JID(user_from.getUName(), getDomain(), "Juick"); + mm.from = new JID(user_from.getName(), getDomain(), "Juick"); mm.body = body; } else { mm.from = new JID("juick", getDomain(), "Juick"); - mm.body = "Private message from @" + user_from.getUName() + ":\n" + body; + mm.body = "Private message from @" + user_from.getName() + ":\n" + body; } return Collections.singletonList(mm); } @@ -373,13 +373,13 @@ public class JuickProtocol { String txt = args[5]; List<Tag> messageTags = TagQueries.fromString(sql, txt, true); if (messageTags.size() > 0) { - if (user.getUID() != MessagesQueries.getMessageAuthor(sql, mid).getUID()) { + if (user.getUid() != MessagesQueries.getMessageAuthor(sql, mid).getUid()) { return new ProtocolReply("It is not your message", Optional.empty()); } TagQueries.updateTags(sql, mid, messageTags); return new ProtocolReply("Tags are updated", Optional.empty()); } else { - int newrid = MessagesQueries.createReply(sql, mid, rid, user.getUID(), txt, null); + int newrid = MessagesQueries.createReply(sql, mid, rid, user.getUid(), txt, null); return new ProtocolReply("Reply posted.\n#" + mid + "/" + newrid + " " + baseUri + mid + "/" + newrid, Optional.of(json.serializeList(Collections.singletonList(MessagesQueries.getReply(sql, mid, newrid))))); @@ -397,11 +397,11 @@ public class JuickProtocol { return new ProtocolReply("Error", Optional.empty()); } if (subscribe) { - if (SubscriptionsQueries.subscribeMessage(sql, mid, user.getUID())) { + if (SubscriptionsQueries.subscribeMessage(sql, mid, user.getUid())) { return new ProtocolReply("Subscribed", Optional.empty()); } } else { - if (SubscriptionsQueries.unSubscribeMessage(sql, mid, user.getUID())) { + if (SubscriptionsQueries.unSubscribeMessage(sql, mid, user.getUid())) { return new ProtocolReply("Unsubscribed from #" + mid, Optional.empty()); } return new ProtocolReply("You was not subscribed to #" + mid, Optional.empty()); @@ -413,7 +413,7 @@ public class JuickProtocol { public ProtocolReply commandSubscribeUser(User user, String... args) { boolean subscribe = args[0].equalsIgnoreCase("s"); User toUser = UserQueries.getUserByName(sql, args[1]); - if (toUser.getUID() > 0) { + if (toUser.getUid() > 0) { if (subscribe) { if (SubscriptionsQueries.subscribeUser(sql, user, toUser)) { return new ProtocolReply("Subscribed", Optional.empty()); @@ -422,9 +422,9 @@ public class JuickProtocol { } } else { if (SubscriptionsQueries.unSubscribeUser(sql, user, toUser)) { - return new ProtocolReply("Unsubscribed from @" + toUser.getUName(), Optional.empty()); + return new ProtocolReply("Unsubscribed from @" + toUser.getName(), Optional.empty()); } - return new ProtocolReply("You was not subscribed to @" + toUser.getUName(), Optional.empty()); + return new ProtocolReply("You was not subscribed to @" + toUser.getName(), Optional.empty()); } } return new ProtocolReply("Error", Optional.empty()); |