ignore player functionality

Author: zefir-git

src/main/java/pro/cloudnode/smp/cloudnodemsg/message/Message.java

@@ -5,12 +5,15 @@
 import org.bukkit.OfflinePlayer;
 import org.bukkit.command.CommandSender;
 import org.bukkit.entity.Player;
+import org.bukkit.persistence.PersistentDataContainer;
 import org.bukkit.persistence.PersistentDataType;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 import pro.cloudnode.smp.cloudnodemsg.CloudnodeMSG;
 import pro.cloudnode.smp.cloudnodemsg.error.InvalidPlayerError;
 
+import java.util.Arrays;
+import java.util.HashSet;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.UUID;
@@ -32,10 +35,11 @@ public void send() throws InvalidPlayerError {
         final @NotNull String recipientUsername = playerOrServerUsername(this.recipient);
 
         sendMessage(sender, CloudnodeMSG.getInstance().config().outgoing(senderUsername, recipientUsername, message));
+        setReplyTo(sender, recipient);
+
+        if (recipient.isOnline() && Message.isIgnored(Objects.requireNonNull(recipient.getPlayer()), sender)) return;
         sendMessage(recipient, CloudnodeMSG.getInstance().config()
                 .incoming(senderUsername, recipientUsername, message));
-
-        setReplyTo(sender, recipient);
         setReplyTo(recipient, sender);
     }
 
@@ -78,4 +82,51 @@ public static void removeReplyTo(final @NotNull OfflinePlayer player) {
         else if (player.isOnline())
             Objects.requireNonNull(player.getPlayer()).getPersistentDataContainer().remove(REPLY_TO);
     }
+
+    public static final @NotNull NamespacedKey IGNORED_PLAYERS = new NamespacedKey(CloudnodeMSG.getInstance(), "ignored");
+
+    /**
+     * Get UUID set of ignored players from PDC string
+     *
+     * @param player The player
+     */
+    public static @NotNull HashSet<@NotNull UUID> getIgnored(final @NotNull Player player) {
+        final @NotNull Optional<@NotNull String> str = Optional.ofNullable(player.getPersistentDataContainer().get(IGNORED_PLAYERS, PersistentDataType.STRING));
+        return str.map(s -> new HashSet<>(Arrays.stream(s.split(";")).filter(e -> !e.isEmpty()).map(UUID::fromString).toList()))
+                .orElseGet(HashSet::new);
+    }
+
+    /**
+     * Check if a player is ignored
+     *
+     * @param player The player
+     * @param ignored The ignored player
+     */
+    public static boolean isIgnored(final @NotNull Player player, final @NotNull OfflinePlayer ignored) {
+        return getIgnored(player).contains(ignored.getUniqueId());
+    }
+
+    /**
+     * Ignore a player
+     *
+     * @param player The player
+     * @param ignore The player to ignore
+     */
+    public static void ignore(final @NotNull Player player, final @NotNull OfflinePlayer ignore) {
+        final @NotNull HashSet<@NotNull UUID> ignoredPlayers = getIgnored(player);
+        ignoredPlayers.add(ignore.getUniqueId());
+        player.getPersistentDataContainer().set(IGNORED_PLAYERS, PersistentDataType.STRING, String.join(";", ignoredPlayers.stream().map(UUID::toString).toList()));
+    }
+
+    /**
+     * Unignore a player
+     *
+     * @param player The player
+     * @param ignored The player to unignore
+     */
+    public static void unignore(final @NotNull Player player, final @NotNull OfflinePlayer ignored) {
+        final @NotNull HashSet<@NotNull UUID> ignoredPlayers = getIgnored(player);
+        ignoredPlayers.remove(ignored.getUniqueId());
+        player.getPersistentDataContainer().set(IGNORED_PLAYERS, PersistentDataType.STRING, String.join(";", ignoredPlayers.stream().map(UUID::toString).toList()));
+    }
 }