diff options
Diffstat (limited to 'src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java')
| -rw-r--r-- | src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java | 195 |
1 files changed, 18 insertions, 177 deletions
diff --git a/src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java b/src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java index 9034b17..3691d12 100644 --- a/src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java +++ b/src/main/java/de/cowtipper/cowlection/handler/FriendsHandler.java @@ -2,213 +2,57 @@ package de.cowtipper.cowlection.handler; import com.google.gson.JsonParseException; import com.google.gson.reflect.TypeToken; -import com.mojang.realmsclient.util.Pair; import de.cowtipper.cowlection.Cowlection; -import de.cowtipper.cowlection.command.exception.ApiContactException; -import de.cowtipper.cowlection.command.exception.MooCommandException; +import de.cowtipper.cowlection.config.MooConfig; import de.cowtipper.cowlection.data.Friend; -import de.cowtipper.cowlection.data.HyPlayerData; -import de.cowtipper.cowlection.util.*; +import de.cowtipper.cowlection.util.GsonUtils; import io.netty.util.internal.ConcurrentSet; -import net.minecraft.client.Minecraft; -import net.minecraft.command.PlayerNotFoundException; -import net.minecraft.event.ClickEvent; -import net.minecraft.event.HoverEvent; -import net.minecraft.util.ChatComponentText; -import net.minecraft.util.ChatStyle; -import net.minecraft.util.EnumChatFormatting; import org.apache.commons.io.FileUtils; -import org.apache.commons.lang3.time.DurationFormatUtils; import java.io.File; import java.io.IOException; import java.lang.reflect.Type; import java.nio.charset.StandardCharsets; -import java.util.*; -import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.atomic.AtomicInteger; +import java.util.Set; +import java.util.TreeSet; import java.util.stream.Collectors; public class FriendsHandler { - private static final long UPDATE_FREQUENCY_DEFAULT = TimeUnit.HOURS.toMillis(10); private final Cowlection main; private final Set<Friend> bestFriends = new ConcurrentSet<>(); private final File bestFriendsFile; - private final AtomicInteger bestFriendNameCheckingQueue = new AtomicInteger(); - private final AtomicInteger bestFriendOnlineStatusQueue = new AtomicInteger(); - private final Set<String> bestFriendsOnlineStatusWithApiErrors = new ConcurrentSet<>(); - private long nextBestFriendOnlineCheck = 0; public FriendsHandler(Cowlection main, File friendsFile) { this.main = main; this.bestFriendsFile = friendsFile; loadBestFriends(); - doBestFriendsNameChangeCheck(); - } - - public boolean isBestFriend(String playerName, boolean ignoreCase) { - if (ignoreCase) { - return bestFriends.stream().map(Friend::getName).anyMatch(playerName::equalsIgnoreCase); - } else { - return bestFriends.stream().map(Friend::getName).anyMatch(playerName::equals); - } - } - - public void addBestFriend(String name) { - if (name.isEmpty()) { - return; - } - - ApiUtils.fetchFriendData(name, friend -> { - if (friend == null) { - throw new ApiContactException("Mojang", "didn't add " + name + " as a best friend."); - } else if (friend.equals(Friend.FRIEND_NOT_FOUND)) { - throw new PlayerNotFoundException("There is no player with the name " + EnumChatFormatting.DARK_RED + name + EnumChatFormatting.RED + "."); - } else { - boolean added = bestFriends.add(friend); - if (added) { - main.getChatHelper().sendMessage(EnumChatFormatting.GREEN, "Added " + EnumChatFormatting.DARK_GREEN + friend.getName() + EnumChatFormatting.GREEN + " as best friend."); - saveBestFriends(); - } - } - }); } public boolean removeBestFriend(String name) { boolean removed = bestFriends.removeIf(friend -> friend.getName().equalsIgnoreCase(name)); if (removed) { + if (bestFriends.size() == 0) { + MooConfig.doBestFriendsOnlineCheck = false; + main.getConfig().syncFromFields(); + } saveBestFriends(); } return removed; } - public Set<String> getBestFriends() { - return bestFriends.stream().map(Friend::getName).collect(Collectors.toCollection(TreeSet::new)); - } - - public Friend getBestFriend(String name) { - return bestFriends.stream().filter(friend -> friend.getName().equalsIgnoreCase(name)).findFirst().orElse(Friend.FRIEND_NOT_FOUND); - } - - private Friend getBestFriend(UUID uuid) { - return bestFriends.stream().filter(friend -> friend.getUuid().equals(uuid)).findFirst().orElse(Friend.FRIEND_NOT_FOUND); - } - - public void doBestFriendsNameChangeCheck() { - bestFriends.stream().filter(friend -> System.currentTimeMillis() - friend.getLastChecked() > UPDATE_FREQUENCY_DEFAULT) - .forEach(friend1 -> { - bestFriendNameCheckingQueue.incrementAndGet(); - doBestFriendNameChangeCheck(friend1, false); - }); + public void removeAllBestFriends() { + bestFriends.clear(); + MooConfig.doBestFriendsOnlineCheck = false; + main.getConfig().syncFromFields(); + saveBestFriends(); } - public void doBestFriendNameChangeCheck(Friend friend, boolean isCommandTriggered) { - ApiUtils.fetchCurrentName(friend, newName -> { - if (newName == null) { - // skipping friend, something went wrong with API request - if (isCommandTriggered) { - throw new ApiContactException("Mojang", "couldn't check " + EnumChatFormatting.DARK_RED + friend.getName() + EnumChatFormatting.RED + " (possible) new player name"); - } - } else if (newName.equals(ApiUtils.UUID_NOT_FOUND)) { - throw new PlayerNotFoundException("How did you manage to get a unique id on your best friends list that has no name attached to it?"); - } else if (newName.equals(friend.getName())) { - // name hasn't changed, only updating lastChecked timestamp - Friend bestFriend = getBestFriend(friend.getUuid()); - if (!bestFriend.equals(Friend.FRIEND_NOT_FOUND)) { - bestFriend.setLastChecked(System.currentTimeMillis()); - if (isCommandTriggered) { - throw new MooCommandException(friend.getName() + " hasn't changed their name"); - } - } - } else { - // name has changed - main.getChatHelper().sendMessage(new ChatComponentText("Your best friend " + EnumChatFormatting.DARK_GREEN + friend.getName() + EnumChatFormatting.GREEN + " changed the name to " + EnumChatFormatting.DARK_GREEN + newName + EnumChatFormatting.GREEN + ".").setChatStyle(new ChatStyle() - .setColor(EnumChatFormatting.GREEN) - .setChatClickEvent(new ClickEvent(ClickEvent.Action.OPEN_URL, "https://namemc.com/search?q=" + newName)) - .setChatHoverEvent(new HoverEvent(HoverEvent.Action.SHOW_TEXT, new ChatComponentText(EnumChatFormatting.YELLOW + "View " + EnumChatFormatting.GOLD + newName + EnumChatFormatting.YELLOW + "'s name history on namemc.com"))))); - - Friend bestFriend = getBestFriend(friend.getUuid()); - if (!bestFriend.equals(Friend.FRIEND_NOT_FOUND)) { - bestFriend.setName(newName); - bestFriend.setLastChecked(System.currentTimeMillis()); - } - } - if (isCommandTriggered) { - saveBestFriends(); - } else { - int remainingFriendsToCheck = bestFriendNameCheckingQueue.decrementAndGet(); - if (remainingFriendsToCheck == 0) { - // we're done with checking for name changes, save updates to file! - saveBestFriends(); - } - } - }); - } - - public void runBestFriendsOnlineCheck(boolean isCommandTriggered) { - long now = System.currentTimeMillis(); - int delay = (isCommandTriggered ? 5 : 1) * 60000; - if (nextBestFriendOnlineCheck < now) { - // ^ prevent too frequent checks - nextBestFriendOnlineCheck = now + delay; - bestFriendOnlineStatusQueue.set(0); - bestFriendsOnlineStatusWithApiErrors.clear(); - final Map<String, HyPlayerData> onlineBestFriends = new ConcurrentHashMap<>(); - - main.getLogger().info("Checking best friends online status... (might take a bit)"); - - for (Friend bestFriend : bestFriends) { - bestFriendOnlineStatusQueue.incrementAndGet(); - ApiUtils.fetchHyPlayerDetails(bestFriend, hyPlayerData -> { - if (hyPlayerData != null && !hyPlayerData.hasNeverLoggedOut() && hyPlayerData.getLastLogin() > hyPlayerData.getLastLogout()) { - // online & not hiding their online status - main.getPlayerCache().addBestFriend(bestFriend.getName()); - - onlineBestFriends.put(bestFriend.getName(), hyPlayerData); - } - - int remainingFriendsToCheck = bestFriendOnlineStatusQueue.decrementAndGet(); - if (remainingFriendsToCheck == 0 && Minecraft.getMinecraft().thePlayer != null) { - // we're done with checking for online status - MooChatComponent bestFriendsComponent = new MooChatComponent("⬤ Online best friends (" - + EnumChatFormatting.DARK_GREEN + onlineBestFriends.size() + EnumChatFormatting.GREEN + "/" + EnumChatFormatting.DARK_GREEN + bestFriends.size() + EnumChatFormatting.GREEN + "): ").green(); - if (onlineBestFriends.isEmpty()) { - bestFriendsComponent.appendText("none..."); - } else { - TreeMap<String, HyPlayerData> onlineBestFriendsSorted = new TreeMap<>(onlineBestFriends); - for (Map.Entry<String, HyPlayerData> bestFriendData : onlineBestFriendsSorted.entrySet()) { - if (bestFriendsComponent.getSiblings().size() > 0) { - bestFriendsComponent.appendSibling(new MooChatComponent(", ").green()); - } - HyPlayerData hyBestFriendData = bestFriendData.getValue(); - Pair<String, String> lastOnline = Utils.getDurationAsWords(hyBestFriendData.getLastLogin()); - bestFriendsComponent.appendSibling(new MooChatComponent(bestFriendData.getKey()).darkGreen() - .setHover(new MooChatComponent(hyBestFriendData.getLastGame()).yellow().appendFreshSibling(new MooChatComponent("Online for " + (lastOnline.second() != null ? lastOnline.second() : lastOnline.first())).white()))); - } - } - if (bestFriendsOnlineStatusWithApiErrors.size() > 0) { - String bestFriendsWithApiErrors = String.join(EnumChatFormatting.RED + ", " + EnumChatFormatting.DARK_RED, bestFriendsOnlineStatusWithApiErrors); - bestFriendsComponent.appendFreshSibling(new MooChatComponent("Failed to check " + EnumChatFormatting.DARK_RED + bestFriendsOnlineStatusWithApiErrors.size() + EnumChatFormatting.RED + " best friends' online status due to Hypixel API errors: " + EnumChatFormatting.DARK_RED + bestFriendsWithApiErrors).red()); - bestFriendsOnlineStatusWithApiErrors.clear(); - } - if (isCommandTriggered) { - main.getChatHelper().sendMessage(bestFriendsComponent); - } else { - // delay by 4 seconds so the message doesn't get buried due to the server welcome messages - new TickDelay(() -> main.getChatHelper().sendMessage(bestFriendsComponent), 80); - } - } - }); - } - } else { - new TickDelay(() -> main.getChatHelper().sendMessage(EnumChatFormatting.RED, "Couldn't check best friends online status because it has not been long enough since the last check. Next check via " + EnumChatFormatting.WHITE + "/moo online" + EnumChatFormatting.RED + " available in " + DurationFormatUtils.formatDurationWords(nextBestFriendOnlineCheck - System.currentTimeMillis(), true, true)), - isCommandTriggered ? 1 : 100); - } + public Set<String> getBestFriends() { + return bestFriends.stream().map(Friend::getName).collect(Collectors.toCollection(TreeSet::new)); } - public void addErroredApiRequest(String playerName) { - bestFriendsOnlineStatusWithApiErrors.add(playerName); + public int getBestFriendsListSize() { + return bestFriends.size(); } public synchronized void saveBestFriends() { @@ -222,10 +66,7 @@ public class FriendsHandler { private void loadBestFriends() { try { - boolean createdNewFile = this.bestFriendsFile.createNewFile(); - - this.bestFriends.clear(); - if (!createdNewFile) { + if (this.bestFriendsFile.exists()) { String bestFriendsData = FileUtils.readFileToString(this.bestFriendsFile, StandardCharsets.UTF_8); if (bestFriendsData.length() > 0) { this.bestFriends.addAll(parseJson(bestFriendsData)); |