aboutsummaryrefslogtreecommitdiff
path: root/server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java
diff options
context:
space:
mode:
Diffstat (limited to 'server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java')
-rw-r--r--server-core/src/main/java/com/juick/server/protocol/JuickProtocol.java48
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());
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-01 01:48:49 +0000